samples: enable pubsub notifications (#48)

* samples: enable pubsub notifications

* 🦉 Updates from OwlBot

See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md

* ignore new doc link

Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>

Author: TrucHLe

contact-center-insights/enablePubSubNotifications.js

@@ -0,0 +1,58 @@
+// Copyright 2021 Google LLC
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     https://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+
+'use strict';
+
+function main(projectId, topicCreateConversation, topicCreateAnalysis) {
+  // [START contactcenterinsights_enable_pubsub_notifications]
+  /**
+   * TODO(developer): Uncomment these variables before running the sample.
+   */
+  // const projectId = 'my_project_id';
+  // const topicCreateConversation = 'projects/my_project_id/topics/my_topic_id';
+  // const topicCreateAnalysis = 'projects/my_project_id/topics/my_other_topic_id';
+
+  // Imports the Contact Center Insights client.
+  const {
+    ContactCenterInsightsClient,
+  } = require('@google-cloud/contact-center-insights');
+
+  // Instantiates a client.
+  const client = new ContactCenterInsightsClient();
+
+  async function enablePubSubNotifications() {
+    const [settings] = await client.updateSettings({
+      settings: {
+        name: client.settingsPath(projectId, 'us-central1'),
+        pubsubNotificationSettings: {
+          'create-conversation': topicCreateConversation,
+          'create-analysis': topicCreateAnalysis,
+        },
+      },
+      updateMask: {
+        paths: ['pubsub_notification_settings'],
+      },
+    });
+    console.info(`Enabled Pub/Sub notifications for ${settings.name}`);
+  }
+  enablePubSubNotifications();
+  // [END contactcenterinsights_enable_pubsub_notifications]
+}
+
+process.on('unhandledRejection', err => {
+  console.error(err.message);
+  process.exitCode = 1;
+});
+main(...process.argv.slice(2));

contact-center-insights/package.json

@@ -14,7 +14,8 @@
   },
   "dependencies": {
     "@google-cloud/bigquery": "^5.7.1",
-    "@google-cloud/contact-center-insights": "^1.4.0"
+    "@google-cloud/contact-center-insights": "^1.4.0",
+    "@google-cloud/pubsub": "^2.17.0"
   },
   "devDependencies": {
     "c8": "^7.1.0",

contact-center-insights/test/enablePubSubNotifications.test.js

@@ -0,0 +1,74 @@
+// Copyright 2021 Google LLC
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     https://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+
+'use strict';
+
+const {assert} = require('chai');
+const {after, before, describe, it} = require('mocha');
+const uuid = require('uuid');
+const cp = require('child_process');
+const execSync = cmd => cp.execSync(cmd, {encoding: 'utf-8'});
+
+const generateUuid = () => `${uuid.v4()}`.replace(/-/gi, '_');
+
+const {
+  ContactCenterInsightsClient,
+} = require('@google-cloud/contact-center-insights');
+const client = new ContactCenterInsightsClient();
+
+const {PubSub} = require('@google-cloud/pubsub');
+const pubSub = new PubSub();
+
+const conversationTopicId = `create-conversation-${generateUuid()}`;
+const analysisTopicId = `create-analysis-${generateUuid()}`;
+
+describe('EnablePubSubNotifications', () => {
+  let projectId;
+  let conversationTopic;
+  let analysisTopic;
+
+  before(async () => {
+    projectId = await client.getProjectId();
+    conversationTopic = `projects/${projectId}/topics/${conversationTopicId}`;
+    analysisTopic = `projects/${projectId}/topics/${analysisTopicId}`;
+
+    // Creates Pub/Sub topics.
+    await pubSub.createTopic(conversationTopic);
+    await pubSub.createTopic(analysisTopic);
+  });
+
+  after(async () => {
+    // Disables Pub/Sub notifications.
+    await client.updateSettings({
+      settings: {
+        name: client.settingsPath(projectId, 'us-central1'),
+        pubsubNotificationSettings: {},
+      },
+      updateMask: {
+        paths: ['pubsub_notification_settings'],
+      },
+    });
+
+    // Deletes Pub/Sub topics.
+    await pubSub.topic(conversationTopic).delete();
+    await pubSub.topic(analysisTopic).delete();
+  });
+
+  it('should enable Pub/Sub notifications', async () => {
+    const stdout = execSync(`node ./enablePubSubNotifications.js \
+                             ${projectId} ${conversationTopic} ${analysisTopic}`);
+    assert.match(stdout, new RegExp('Enabled Pub/Sub notifications'));
+  });
+});