Now using external AMQP URI

Author: zubairov

component.json

@@ -1,6 +1,16 @@
 {
   "title": "PubSub",
   "description": "Pub/Sub Component for async communication with queues and topics",
+  "credentials": {
+    "fields": {
+      "amqpURI": {
+        "label": "AMQP URI",
+        "required": true,
+        "viewClass": "TextFieldView",
+        "placeholder": "amqp://foo:[email protected]"
+      }
+    }
+  },
   "actions": {
     "publish": {
       "title": "Publish",

lib/actions/publish.js

@@ -12,11 +12,10 @@ module.exports.process = processAction;
  *
  * @param msg incoming message object that contains ``body`` with payload
  * @param cfg configuration that is account information and configuration field values
- * @param snapshot - current values from the snapshot
  */
-function processAction(msg, cfg, snapshot) {
+function processAction(msg, cfg) {
   console.log('Action started');
-  const amqpURI = process.env.ELASTICIO_AMQP_URI;
+  const amqpURI = cfg.amqpURI;
   const amqpExchange = `pubsub_${process.env.ELASTICIO_TASK_ID}_${process.env.ELASTICIO_USER_ID}`;
   co(function*() {
     if (!conn) {

verifyCredentials.js

@@ -1,23 +1,20 @@
 'use strict';
 const co = require('co');
-const rp = require('request-promise');
+const amqp = require('amqplib');
 
 // This function will be called by the platform to verify credentials
 module.exports = function verifyCredentials(credentials, cb) {
   console.log('Credentials passed for verification %j', credentials);
-
+  const amqpURI = credentials.amqpURI;
+  const amqpExchange = 'verify_credentials_test';
   co(function*() {
-    console.log('Fetching user information');
-
-    const test = yield rp({
-      uri: 'https://cdn.elastic.io/test.json',
-      json: true
-    });
-
-    console.log('Fetched JSON value=%j', test);
-
-    console.log('Verification completed');
-
+    console.log('Connecting to amqpURI=%s', amqpURI);
+    const conn = yield amqp.connect(amqpURI);
+    console.log('Creating a confirm channel');
+    const channel = yield conn.createConfirmChannel();
+    console.log('Asserting topic exchange exchange=%s', amqpExchange);
+    yield channel.assertExchange(amqpExchange, 'topic', { durable: false });
+    console.log('Verified successfully');
     cb(null, {verified: true});
   }).catch(err => {
     console.log('Error occurred', err.stack || err);