feat: web sdk topics (#509)

* feat: add topics

* feat: adding pubsub client

* chore: refactoring integration test for common use

* chore: update types

* fix: handle 'only once' heders separately for unary vs streaming

packages/client-sdk-nodejs/package.json

@@ -50,7 +50,7 @@
     "uuid": "8.3.2"
   },
   "dependencies": {
-    "@gomomento/generated-types": "^0.61.0",
+    "@gomomento/generated-types": "0.61.2",
     "@gomomento/sdk-core": "file:../core",
     "@grpc/grpc-js": "1.8.14",
     "google-protobuf": "3.21.2",

packages/client-sdk-nodejs/src/index.ts

@@ -1,6 +1,7 @@
 import {CacheClient, SimpleCacheClient} from './cache-client';
 import {TopicClient} from './topic-client';
 import * as Configurations from './config/configurations';
+import {TopicClientProps} from './topic-client-props';
 
 // Cache Client Response Types
 import * as CacheGet from '@gomomento/sdk-core/dist/src/messages/responses/cache-get';
@@ -197,6 +198,7 @@ export {
   ItemGetType,
   // TopicClient Response types
   TopicClient,
+  TopicClientProps,
   TopicItem,
   TopicPublish,
   TopicSubscribe,

packages/client-sdk-nodejs/src/internal/data-client.ts

@@ -83,8 +83,9 @@ import grpcCache = cache.cache_client;
 import _Unbounded = cache_client._Unbounded;
 import ECacheResult = cache_client.ECacheResult;
 import _ItemGetTypeResponse = cache_client._ItemGetTypeResponse;
+import {IDataClient} from '@gomomento/sdk-core/dist/src/internal/clients';
 
-export class DataClient {
+export class DataClient implements IDataClient {
   private readonly clientWrapper: GrpcClientWrapper<grpcCache.ScsClient>;
   private readonly textEncoder: TextEncoder;
   private readonly configuration: Configuration;

packages/client-sdk-nodejs/src/internal/pubsub-client.ts

@@ -31,6 +31,7 @@ import {
 } from '@gomomento/sdk-core/dist/src/internal/utils';
 import {normalizeSdkError} from '@gomomento/sdk-core/dist/src/errors';
 import {SubscribeCallOptions} from '@gomomento/sdk-core/dist/src/utils';
+import {IPubsubClient} from '@gomomento/sdk-core/dist/src/internal/clients';
 
 /**
  * Encapsulates parameters for the `sendSubscribe` method.
@@ -68,7 +69,7 @@ interface PrepareSubscribeCallbackOptions extends SendSubscribeOptions {
   firstMessage: boolean;
 }
 
-export class PubsubClient {
+export class PubsubClient implements IPubsubClient {
   private readonly clientWrapper: GrpcClientWrapper<grpcPubsub.PubsubClient>;
   private readonly configuration: Configuration;
   private readonly credentialProvider: CredentialProvider;

packages/client-sdk-nodejs/src/topic-client.ts

@@ -6,15 +6,17 @@ import {
 } from '.';
 import {PubsubClient} from './internal/pubsub-client';
 import {TopicClientProps} from './topic-client-props';
+import {ITopicClient} from '@gomomento/sdk-core/dist/src/internal/clients/pubsub/ITopicClient';
+import {IPubsubClient} from '@gomomento/sdk-core/dist/src/internal/clients';
 
 /**
  * Momento Topic Client.
  *
  * Publish and subscribe to topics.
  */
-export class TopicClient {
+export class TopicClient implements ITopicClient {
   private readonly logger: MomentoLogger;
-  private readonly client: PubsubClient;
+  private readonly client: IPubsubClient;
 
   /**
    * Creates an instance of TopicClient.

packages/client-sdk-nodejs/test/integration/integration-setup.ts

@@ -1,16 +1,16 @@
 import {CacheClientProps} from '../../src/cache-client-props';
 import {testCacheName} from '@gomomento/common-integration-tests';
 import {
+  AuthClient,
   CreateCache,
   Configurations,
   DeleteCache,
   MomentoErrorCode,
   CacheClient,
   CredentialProvider,
   CollectionTtl,
+  TopicClient,
 } from '../../src';
-import {AuthClient} from '../../src/auth-client';
-
 const deleteCacheIfExists = async (momento: CacheClient, cacheName: string) => {
   const deleteResponse = await momento.deleteCache(cacheName);
   if (deleteResponse instanceof DeleteCache.Error) {
@@ -52,6 +52,13 @@ function momentoAuthClientForTesting(): AuthClient {
   return new AuthClient();
 }
 
+function momentoTopicClientForTesting(): TopicClient {
+  return new TopicClient({
+    configuration: IntegrationTestCacheClientProps.configuration,
+    credentialProvider: IntegrationTestCacheClientProps.credentialProvider,
+  });
+}
+
 export function SetupIntegrationTest(): {
   Momento: CacheClient;
   IntegrationTestCacheName: string;
@@ -81,6 +88,16 @@ export function SetupIntegrationTest(): {
   return {Momento: client, IntegrationTestCacheName: cacheName};
 }
 
+export function SetupTopicIntegrationTest(): {
+  topicClient: TopicClient;
+  Momento: CacheClient;
+  IntegrationTestCacheName: string;
+} {
+  const {Momento, IntegrationTestCacheName} = SetupIntegrationTest();
+  const topicClient = momentoTopicClientForTesting();
+  return {topicClient, Momento, IntegrationTestCacheName};
+}
+
 export function SetupAuthIntegrationTest(): {
   authClient: AuthClient;
   sessionToken: string;

packages/client-sdk-nodejs/test/integration/shared/topic-client.test.ts

@@ -0,0 +1,6 @@
+import {runTopicClientTests} from '@gomomento/common-integration-tests';
+import {SetupTopicIntegrationTest} from '../integration-setup';
+
+const {topicClient, Momento, IntegrationTestCacheName} =
+  SetupTopicIntegrationTest();
+runTopicClientTests(topicClient, Momento, IntegrationTestCacheName);