initial commit

Signed-off-by: Austin Frey <[email protected]>

Author: austinfrey

.gitignore

@@ -0,0 +1 @@
+node_modules

faas/compose.js

@@ -0,0 +1,32 @@
+'use strict';
+
+const path = require('path');
+const BbPromise = require('bluebird');
+const got = require('got');
+
+const compose = baseUrl => {
+	return (initial, funcs) => {
+		const functions = funcs.map(func => {
+			return data => {
+				const options = {
+					method: 'POST',
+					body: data
+				};
+
+				const funcUrl = baseUrl + path.join('/function', func);
+				return got(funcUrl, options)
+					.then(res => BbPromise.resolve(res))
+					.catch(err => BbPromise.reject(err));
+			};
+		});
+
+		return functions.reduce(
+			(current, f) => {
+				return current.then(x => f(x.body));
+			},
+			new BbPromise(resolve => resolve(initial))
+		);
+	};
+};
+
+module.exports = compose;

faas/deploy.js

@@ -0,0 +1,24 @@
+'use strict';
+
+const got = require('got');
+
+const deploy = gateway => {
+	const url = gateway;
+
+	return (name, network, image) => {
+		const deployPath = '/system/functions';
+		const options = {
+			method: 'POST',
+			json: true,
+			body: {
+				service: name,
+				network,
+				image
+			}
+		};
+
+		return got(url + deployPath, options);
+	};
+};
+
+module.exports = deploy;

faas/index.js

@@ -0,0 +1,16 @@
+'use strict';
+
+const deploy = require('./deploy');
+const remove = require('./remove');
+const invoke = require('./invoke');
+const compose = require('./compose');
+
+const faas = url => ({
+	deploy: deploy(url),
+	remove: remove(url),
+	invoke: invoke(url),
+	compose: compose(url)
+});
+
+module.exports = faas;
+

faas/invoke.js

@@ -0,0 +1,24 @@
+'use strict';
+
+const path = require('path');
+const got = require('got');
+
+const invoke = gateway => {
+	const url = gateway;
+
+	return (name, data) => {
+		const funcPath = path.join('/function', name);
+		const options = {
+			method: 'POST',
+			json: true
+		};
+
+		if (data) {
+			options.body = data;
+		}
+
+		return got(url + funcPath, options);
+	};
+};
+
+module.exports = invoke;

faas/remove.js

@@ -0,0 +1,21 @@
+'use strict';
+
+const got = require('got');
+
+const remove = gateway => {
+	const url = gateway;
+
+	return name => {
+		const options = {
+			method: 'DELETE',
+			json: true,
+			body: {
+				functionName: name
+			}
+		};
+
+		return got(url + '/system/functions', options);
+	};
+};
+
+module.exports = remove;

index.js

@@ -0,0 +1,12 @@
+const Faas = require('./faas');
+
+const faas = Faas('http://localhost:8080');
+
+faas.deploy(
+	'yolo',
+	'func_functions',
+	'hello-serverless'
+)
+	.then(x => console.log(x))
+	.catch(err => console.log(err));
+