Source: client/composite-client.js

  1. /*
  2.  * Copyright 2023, TeamDev. All rights reserved.
  3.  *
  4.  * Licensed under the Apache License, Version 2.0 (the "License");
  5.  * you may not use this file except in compliance with the License.
  6.  * You may obtain a copy of the License at
  7.  *
  8.  * http://www.apache.org/licenses/LICENSE-2.0
  9.  *
  10.  * Redistribution and use in source and/or binary forms, with or without
  11.  * modification, must retain the above copyright notice and the following
  12.  * disclaimer.
  13.  *
  14.  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
  15.  * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
  16.  * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
  17.  * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
  18.  * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
  19.  * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
  20.  * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
  21.  * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
  22.  * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
  23.  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
  24.  * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  25.  */
  27. "use strict";
  29. import {Client} from "./client";
  31. /**
  32.  * A {@link Client} that delegates requests to case-specific client implementations.
  33.  *
  34.  * @see QueryingClient
  35.  * @see SubscribingClient
  36.  * @see CommandingClient
  37.  */
  38. export class CompositeClient extends Client {
  40.   constructor(querying, subscribing, commanding) {
  41.     super();
  43.     /**
  44.      * @type QueryingClient
  45.      *
  46.      * @private
  47.      */
  48.     this._querying = querying;
  50.     /**
  51.      * @type SubscribingClient
  52.      *
  53.      * @private
  54.      */
  55.     this._subscribing = subscribing;
  57.     /**
  58.      * @type CommandingClient
  59.      *
  60.      * @private
  61.      */
  62.     this._commanding = commanding;
  63.   }
  65.   /**
  66.    * @override
  67.    */
  68.   select(entityType) {
  69.     return this._querying.select(entityType, this);
  70.   }
  72.   /**
  73.    * @override
  74.    */
  75.   read(query) {
  76.     return this._querying.read(query);
  77.   }
  79.   /**
  80.    * @override
  81.    */
  82.   newQuery() {
  83.     return this._querying.newQuery();
  84.   }
  86.   /**
  87.    * @override
  88.    */
  89.   subscribeTo(entityType) {
  90.     return this._subscribing.subscribeTo(entityType, this);
  91.   }
  93.   /**
  94.    * @override
  95.    */
  96.   cancelAllSubscriptions() {
  97.     this._subscribing.cancelAllSubscriptions();
  98.   }
  100.   /**
  101.    * @override
  102.    */
  103.   subscribeToEvent(eventType) {
  104.     return this._subscribing.subscribeToEvent(eventType, this);
  105.   }
  107.   /**
  108.    * @override
  109.    */
  110.   subscribe(topic) {
  111.     return this._subscribing.subscribe(topic)
  112.   }
  114.   /**
  115.    * @override
  116.    */
  117.   subscribeToEvents(topic) {
  118.     return this._subscribing.subscribeToEvents(topic);
  119.   }
  121.   /**
  122.    * @override
  123.    */
  124.   newTopic() {
  125.     return this._subscribing.newTopic();
  126.   }
  128.   /**
  129.    * @override
  130.    */
  131.   command(commandMessage) {
  132.     return this._commanding.command(commandMessage, this);
  133.   }
  135.   /**
  136.    * @override
  137.    */
  138.   post(command, onAck) {
  139.     this._commanding.post(command, onAck);
  140.   }
  141. }