Initial commit

Author: zubairov

LICENSE

@@ -0,0 +1,13 @@
+Copyright 2016 elastic.io GmbH <[email protected]> (https://elastic.io)
+
+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
+
+ http://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.

README.md

@@ -0,0 +1,61 @@
+# pubsub-component [![NPM version][npm-image]][npm-url] [![Build Status][travis-image]][travis-url] [![Dependency Status][daviddm-image]][daviddm-url]
+> Pub/Sub Component for async communication with queues and topics
+
+# pubsub-component
+PubSub component for the [elastic.io platform](http://www.elastic.io "elastic.io platform")
+
+If you plan to **deploy it into [elastic.io platform](http://www.elastic.io "elastic.io platform") you must follow sets of instructions to succseed**. 
+
+## Before you Begin
+
+Before you can deploy any code into elastic.io **you must be a registered elastic.io platform user**. Please see our home page at [http://www.elastic.io](http://www.elastic.io) to learn how. 
+
+We'll use git and SSH public key authentication to upload your component code, therefore you must **[upload your SSH Key](http://docs.elastic.io/docs/ssh-key)**. 
+
+> If you fail to upload you SSH Key you will get **permission denied** error during the deployment.
+
+## Getting Started
+
+After registration and uploading of your SSH Key you can proceed to deploy it into our system. At this stage we suggest you to:
+* [Create a team](http://docs.elastic.io/docs/teams) to work on your new component. This is not required but will be automatically created using random naming by our system so we suggest you name your team accordingly.
+* [Create a repository](http://docs.elastic.io/docs/component-repositories) where your new component is going to *reside* inside the team that you have just created.
+
+Now as you have a team name and component repository name you can add a new git remote where code shall be pushed to. It is usually displayed on the empty repository page:
+
+```bash
+$ git remote add elasticio [email protected]:your-repository.git
+```
+
+Obviously the naming of your team and repository is entirely upto you and if you do not put any corresponding naming our system will auto generate it for you but the naming might not entirely correspond to your project requirements.
+Now we are ready to push it:
+
+```bash
+$ git push elasticio master
+```
+
+## Authentication
+
+This component is using the internal RabbitMQ instance that is available as part of elastic.io
+infrastructure, it expects following environment variables to be present when started:
+* ``ELASTICIO_AMQP_URI`` something like ``amqp://foo:bar@server``
+* ``ELASTICIO_MESSAGE_CRYPTO_IV`` key for symmetric encryption
+* ``ELASTICIO_MESSAGE_CRYPTO_PASSWORD`` password for symmetric encryption
+* ``ELASTICIO_PUBLISH_MESSAGES_TO`` AMQP exchange name, like ``56a63248661ec20500000014_user``
+
+ 
+## Known issues
+
+No known issues are there yet.
+
+
+## License
+
+Apache-2.0 © [elastic.io GmbH](https://elastic.io)
+
+
+[npm-image]: https://badge.fury.io/js/pubsub-component.svg
+[npm-url]: https://npmjs.org/package/pubsub-component
+[travis-image]: https://travis-ci.org/elasticio/pubsub-component.svg?branch=master
+[travis-url]: https://travis-ci.org/elasticio/pubsub-component
+[daviddm-image]: https://david-dm.org/elasticio/pubsub-component.svg?theme=shields.io
+[daviddm-url]: https://david-dm.org/elasticio/pubsub-component

component.json

@@ -0,0 +1,23 @@
+{
+  "title": "PubSub",
+  "description": "Pub/Sub Component for async communication with queues and topics",
+  "credentials": {
+    "fields": {
+      "name": {
+        "label": "My API Key",
+        "required": true,
+        "viewClass": "TextFieldView"
+      }
+    }
+  },
+  "actions": {
+    "publish": {
+      "title": "Publish",
+      "main": "./lib/actions/publish.js",
+      "metadata": {
+        "in": "./lib/schemas/publish.in.json",
+        "out": "./lib/schemas/publish.out.json"
+      }
+    }
+  }
+}

lib/actions/publish.js

@@ -0,0 +1,39 @@
+'use strict';
+const eioUtils = require('elasticio-node').messages;
+const co = require('co');
+const rp = require('request-promise');
+
+module.exports.process = processAction;
+
+/**
+ * This method will be called from elastic.io platform providing following data
+ *
+ * @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) {
+  console.log('Action started, snapshot=%j', snapshot);
+
+  co(function*() {
+    console.log('Creating new request bin');
+
+    const bin = yield rp({
+      method: 'POST',
+      uri: 'http://requestb.in/api/v1/bins',
+      json: true
+    });
+
+    console.log('New request bin created bin=%j', bin);
+
+    this.emit('data', eioUtils.newMessageWithBody(bin));
+
+    console.log('Processing completed');
+
+    this.emit('end');
+  }.bind(this)).catch(err => {
+    console.log('Error occurred', err.stack || err);
+    this.emit('error', err);
+    this.emit('end');
+  });
+}

lib/schemas/publish.in.json

@@ -0,0 +1,10 @@
+{
+  "type": "object",
+  "properties": {
+    "inValue": {
+      "type": "string",
+      "required": true,
+      "title": "Input Value"
+    }
+  }
+}

lib/schemas/publish.out.json

@@ -0,0 +1,10 @@
+{
+  "type": "object",
+  "properties": {
+    "outValue": {
+      "type": "string",
+      "required": true,
+      "title": "Output Value"
+    }
+  }
+}

logo.png

@@ -0,0 +1,44 @@
+{
+  "name": "pub-sub",
+  "version": "0.0.0",
+  "description": "Pub/Sub Component for async communication with queues and topics",
+  "homepage": "http://www.elastic.io",
+  "author": {
+    "name": "elastic.io GmbH",
+    "email": "[email protected]",
+    "url": "https://elastic.io"
+  },
+  "files": [
+    "lib"
+  ],
+  "main": "lib/index.js",
+  "keywords": [
+    "elasticio",
+    "component",
+    "ipas",
+    "amqp",
+    "rabbitmq",
+    "pubsub",
+    "elasticio-component"
+  ],
+  "dependencies": {
+    "co": "^4.6.0",
+    "bluebird": "^3.4.6",
+    "request": "^2.75.0",
+    "request-promise": "^4.1.1",
+    "elasticio-sailor-nodejs": "1.3.0",
+    "elasticio-node": "0.0.5"
+  },
+  "devDependencies": {
+    "eslint": "^2.1.0",
+    "eslint-config-xo-space": "^0.10.0"
+  },
+  "eslintConfig": {
+    "extends": "xo-space",
+    "env": {
+      "mocha": true
+    }
+  },
+  "repository": "elasticio/pub-sub",
+  "license": "Apache-2.0"
+}

package.json

@@ -0,0 +1,26 @@
+'use strict';
+const co = require('co');
+const rp = require('request-promise');
+
+// 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);
+
+  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');
+
+    cb(null, {verified: true});
+  }).catch(err => {
+    console.log('Error occurred', err.stack || err);
+    cb(err , {verified: false});
+  });
+};