feat: pubsub mvp

examples/package.json

@@ -10,6 +10,8 @@
     "advanced": "tsc && node dist/advanced.js",
     "load-gen": "tsc && node dist/load-gen.js",
     "dictionary": "tsc && node dist/dictionary.js",
+    "topic-publish": "tsc && node dist/topic-publish.js",
+    "topic-subscribe": "tsc && node dist/topic-subscribe.js",
     "test": "jest",
     "lint": "eslint . --ext .ts",
     "format": "eslint . --ext .ts --fix"
@@ -31,7 +33,7 @@
   },
   "dependencies": {
     "@gomomento/generated-types": "0.32.1",
-    "@gomomento/sdk": "1.4.0",
+    "@gomomento/sdk": "../dist/src",
     "@grpc/grpc-js": "1.7.3",
     "hdr-histogram-js": "3.0.0",
     "node-fetch": "2.6.7",

examples/topic-publish.ts

@@ -0,0 +1,42 @@
+import {
+  TopicClient,
+  TopicPublish,
+  Configurations,
+  CredentialProvider,
+} from '@gomomento/sdk';
+
+async function main() {
+  const clargs = process.argv.slice(2);
+  if (clargs.length !== 3) {
+    console.error('Usage: topic-publish.ts <cacheName> <topicName> <value>');
+    return;
+  }
+  const cacheName = clargs[0];
+  const topicName = clargs[1];
+  const value = clargs[2];
+  const momento = new TopicClient({
+    configuration: Configurations.Laptop.v1(),
+    credentialProvider: CredentialProvider.fromEnvironmentVariable({
+      environmentVariableName: 'TEST_AUTH_TOKEN',
+    }),
+  });
+
+  console.log(
+    `Publishing cacheName=${cacheName}, topicName=${topicName}, value=${value}`
+  );
+  const publishResponse = await momento.publish(cacheName, topicName, value);
+  if (publishResponse instanceof TopicPublish.Success) {
+    console.log('Value published successfully!');
+  } else {
+    console.log(`Error publishing value: ${publishResponse.toString()}`);
+  }
+}
+
+main()
+  .then(() => {
+    console.log('success!!');
+  })
+  .catch((e: Error) => {
+    console.error(`An error occurred! ${e.message}`);
+    throw e;
+  });

examples/topic-subscribe.ts

@@ -0,0 +1,45 @@
+import {
+  TopicClient,
+  TopicSubscribe,
+  Configurations,
+  CredentialProvider,
+} from '@gomomento/sdk';
+
+async function main() {
+  const clargs = process.argv.slice(2);
+  if (clargs.length !== 2) {
+    console.error('Usage: topic-subscribe.ts <cacheName> <topicName>');
+    return;
+  }
+  const cacheName = clargs[0];
+  const topicName = clargs[1];
+  const momento = new TopicClient({
+    configuration: Configurations.Laptop.v1(),
+    credentialProvider: CredentialProvider.fromEnvironmentVariable({
+      environmentVariableName: 'TEST_AUTH_TOKEN',
+    }),
+  });
+
+  console.log(`Subscribing to cacheName=${cacheName}, topicName=${topicName}`);
+  await momento.subscribe(cacheName, topicName, {
+    dataListener: handleData,
+    errorListener: handleError,
+  });
+}
+
+function handleData(data: TopicSubscribe.Item) {
+  console.log('Data received from subscription stream; %s', data);
+}
+
+function handleError(error: TopicSubscribe.Error) {
+  console.log(`Error received from subscription stream; ${error.toString()}`);
+}
+
+main()
+  .then(() => {
+    console.log('success!!');
+  })
+  .catch((e: Error) => {
+    console.error(`An error occurred! ${e.message}`);
+    throw e;
+  });

package.json

@@ -47,7 +47,7 @@
     "uuid": "8.3.2"
   },
   "dependencies": {
-    "@gomomento/generated-types": "0.50.0",
+    "@gomomento/generated-types": "0.51.1",
     "@grpc/grpc-js": "1.7.3",
     "google-protobuf": "^3.21.2",
     "jwt-decode": "3.1.2"

src/index.ts

@@ -1,4 +1,5 @@
 import {CacheClient, SimpleCacheClient} from './cache-client';
+import {TopicClient} from './topic-client';
 import * as Configurations from './config/configurations';
 import * as CacheGet from './messages/responses/cache-get';
 import * as CacheListConcatenateBack from './messages/responses/cache-list-concatenate-back';
@@ -44,6 +45,8 @@ import * as CacheSortedSetGetScores from './messages/responses/cache-sorted-set-
 import * as CacheSortedSetIncrementScore from './messages/responses/cache-sorted-set-increment-score';
 import * as CacheSortedSetRemoveElement from './messages/responses/cache-sorted-set-remove-element';
 import * as CacheSortedSetRemoveElements from './messages/responses/cache-sorted-set-remove-elements';
+import * as TopicPublish from './messages/responses/topic-publish';
+import * as TopicSubscribe from './messages/responses/topic-subscribe';
 
 import {CacheInfo} from './messages/cache-info';
 import {CollectionTtl} from './utils/collection-ttl';
@@ -143,6 +146,9 @@ export {
   CacheSortedSetIncrementScore,
   CacheSortedSetRemoveElement,
   CacheSortedSetRemoveElements,
+  TopicClient,
+  TopicPublish,
+  TopicSubscribe,
   MomentoErrorCode,
   AlreadyExistsError,
   AuthenticationError,