initial commit

Author: matthewgoslett

.editorconfig

@@ -0,0 +1,13 @@
+# editorconfig.org
+root = true
+
+[*]
+indent_style = space
+indent_size = 2
+end_of_line = lf
+charset = utf-8
+trim_trailing_whitespace = true
+insert_final_newline = true
+
+[*.md]
+trim_trailing_whitespace = false

.eslintrc

@@ -0,0 +1,15 @@
+{
+  "extends": "google",
+  "env": {
+    "node": true,
+    "es6": true
+  },
+  "rules": {
+    "max-len": ["error", {
+      "ignoreComments": true,
+      "ignoreUrls": true,
+      "ignoreStrings": true,
+      "ignoreRegExpLiterals": true
+    }]
+  }
+}

.gitignore

@@ -0,0 +1,68 @@
+
+# Created by https://www.gitignore.io/api/node
+
+### Node ###
+# Logs
+logs
+*.log
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*
+
+# Runtime data
+pids
+*.pid
+*.seed
+*.pid.lock
+
+# Directory for instrumented libs generated by jscoverage/JSCover
+lib-cov
+
+# Coverage directory used by tools like istanbul
+coverage
+
+# nyc test coverage
+.nyc_output
+
+# Grunt intermediate storage (http://gruntjs.com/creating-plugins#storing-task-files)
+.grunt
+
+# Bower dependency directory (https://bower.io/)
+bower_components
+
+# node-waf configuration
+.lock-wscript
+
+# Compiled binary addons (http://nodejs.org/api/addons.html)
+build/Release
+
+# Dependency directories
+node_modules/
+jspm_packages/
+
+# Typescript v1 declaration files
+typings/
+
+# Optional npm cache directory
+.npm
+
+# Optional eslint cache
+.eslintcache
+
+# Optional REPL history
+.node_repl_history
+
+# Output of 'npm pack'
+*.tgz
+
+# Yarn Integrity file
+.yarn-integrity
+
+# dotenv environment variables file
+.env
+
+
+# End of https://www.gitignore.io/api/node
+
+.idea
+lib

.npmignore

@@ -0,0 +1,68 @@
+
+# Created by https://www.gitignore.io/api/node
+
+### Node ###
+# Logs
+logs
+*.log
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*
+
+# Runtime data
+pids
+*.pid
+*.seed
+*.pid.lock
+
+# Directory for instrumented libs generated by jscoverage/JSCover
+lib-cov
+
+# Coverage directory used by tools like istanbul
+coverage
+
+# nyc test coverage
+.nyc_output
+
+# Grunt intermediate storage (http://gruntjs.com/creating-plugins#storing-task-files)
+.grunt
+
+# Bower dependency directory (https://bower.io/)
+bower_components
+
+# node-waf configuration
+.lock-wscript
+
+# Compiled binary addons (http://nodejs.org/api/addons.html)
+build/Release
+
+# Dependency directories
+node_modules/
+jspm_packages/
+
+# Typescript v1 declaration files
+typings/
+
+# Optional npm cache directory
+.npm
+
+# Optional eslint cache
+.eslintcache
+
+# Optional REPL history
+.node_repl_history
+
+# Output of 'npm pack'
+*.tgz
+
+# Yarn Integrity file
+.yarn-integrity
+
+# dotenv environment variables file
+.env
+
+
+# End of https://www.gitignore.io/api/node
+
+.idea
+src

.travis.yml

@@ -0,0 +1,8 @@
+language: node_js
+
+node_js:
+  - "node"
+  - "7"
+  - "6"
+  - "5"
+  - "4"

Dockerfile

@@ -0,0 +1,15 @@
+FROM node:7.9.0
+MAINTAINER Superbalist <tech+docker@superbalist.com>
+
+RUN mkdir -p /usr/src/app
+WORKDIR /usr/src/app
+
+COPY package.json /usr/src/app/
+RUN npm install
+
+COPY src /usr/src/app/src/
+COPY examples /usr/src/app/examples/
+
+RUN npm run build
+
+CMD ["/bin/bash"]

LICENSE

@@ -0,0 +1,21 @@
+The MIT License (MIT)
+
+Copyright (c) 2017 Superbalist.com a division of Takealot Online (Pty) Ltd
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

Makefile

@@ -0,0 +1,8 @@
+up:
+	@docker-compose rm -f
+	@docker-compose pull
+	@sed -e "s/HOSTIP/$$(docker-machine ip)/g" docker-compose.yml | docker-compose --file - up --build -d
+	@docker-compose run js-pubsub-http /bin/bash
+
+down:
+	@docker-compose stop -t 1

README.md

@@ -0,0 +1,85 @@
+# @superbalist/js-pubsub-http
+
+An HTTP adapter for the [js-pubsub](https://github.com/Superbalist/js-pubsub) package.
+
+[![Author](http://img.shields.io/badge/author-@superbalist-blue.svg?style=flat-square)](https://twitter.com/superbalist)
+[![Build Status](https://img.shields.io/travis/Superbalist/js-pubsub-http/master.svg?style=flat-square)](https://travis-ci.org/Superbalist/js-pubsub-http)
+[![Software License](https://img.shields.io/badge/license-MIT-brightgreen.svg?style=flat-square)](LICENSE)
+[![NPM Version](https://img.shields.io/npm/v/@superbalist/js-pubsub-http.svg)](https://www.npmjs.com/package/@superbalist/js-pubsub-http)
+[![NPM Downloads](https://img.shields.io/npm/dt/@superbalist/js-pubsub-http.svg)](https://www.npmjs.com/package/@superbalist/js-pubsub-http)
+
+This adapter assumes that you have a HTTP service which accepts an array of messages POSTed to a
+/messages/(channel) end-point.
+
+## Installation
+
+```bash
+npm install @superbalist/js-pubsub-http
+```
+    
+## Usage
+```node
+'use strict';
+
+let pubsub = require('@google-cloud/pubsub');
+let GoogleCloudPubSubAdapter = require('@superbalist/js-pubsub-google-cloud');
+let HTTPPubSubAdapter = require('@superbalist/js-pubsub-http');
+
+process.env.GOOGLE_APPLICATION_CREDENTIALS = '/path/to/your-gcloud-key.json';
+
+// create the underlying adapter which is going to be decorated
+let client = pubsub({
+  projectId: 'your-project-id-here',
+});
+
+let googleCloudAdapter = new GoogleCloudPubSubAdapter(client);
+
+// now create our decorator
+// the decorator will proxy subscribe calls straight to the googleCloudAdapter
+// publish calls will be POSTed to the service uri
+let adapter = new HTTPPubSubAdapter('http://127.0.0.1', googleCloudAdapter);
+
+adapter.subscribe('my_channel', (message) => {
+  console.log(message);
+  console.log(typeof message);
+});
+
+// consume messages
+// note: this is a blocking call
+adapter.subscribe('my_channel', (message) => {
+  console.log(message);
+  console.log(typeof message);
+});
+
+// publish messages
+adapter.publish('my_channel', {first_name: 'Matthew'});
+adapter.publish('my_channel', 'Hello World');
+
+// publish multiple messages
+let messages = [
+  'message 1',
+  'message 2',
+];
+adapter.publishBatch('my_channel', messages);
+```
+
+## TODO
+
+* Add unit tests
+
+## Examples
+
+The library comes with [examples](examples) for the adapter and a [Dockerfile](Dockerfile) for
+running the example scripts.
+
+Run `make up`.
+
+You will start at a `bash` prompt in the `/usr/src/app` directory.
+
+If you need another shell to publish a message to a blocking consumer, you can run `docker-compose run js-pubsub-http /bin/bash`
+
+To run the examples:
+```bash
+$ ./run_consumer.sh
+$ ./run_publisher.sh (in a separate shell)
+```

changelog.md

@@ -0,0 +1,5 @@
+# Changelog
+
+## 1.0.0 - 2017-05-23
+
+* Initial release