adding serviceinstanceservice

.cfignore

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

.gitignore

@@ -0,0 +1,6 @@
+logs/*
+!.gitkeep
+node_modules/
+tmp
+.DS_Store
+.idea

Procfile

@@ -0,0 +1 @@
+web: node ./server/app.js

manifest.yml

@@ -0,0 +1,6 @@
+---
+applications:
+- name: cf-mysql-node-broker
+memory: 256M
+instances: 1
+host: cf-mysql-node-broker

npm-debug.log

@@ -0,0 +1,36 @@
+0 info it worked if it ends with ok
+1 verbose cli [ 'node', '/usr/local/bin/npm', 'start' ]
+2 info using [email protected]
+3 info using [email protected]
+4 verbose node symlink /usr/local/bin/node
+5 verbose run-script [ 'prestart', 'start', 'poststart' ]
+6 info prestart [email protected]
+7 info start [email protected]
+8 verbose unsafe-perm in lifecycle true
+9 info [email protected] Failed to exec start script
+10 verbose stack Error: [email protected] start: `node ./server/app.js`
+10 verbose stack Exit status 8
+10 verbose stack     at EventEmitter.<anonymous> (/usr/local/lib/node_modules/npm/lib/utils/lifecycle.js:212:16)
+10 verbose stack     at EventEmitter.emit (events.js:98:17)
+10 verbose stack     at ChildProcess.<anonymous> (/usr/local/lib/node_modules/npm/lib/utils/spawn.js:14:12)
+10 verbose stack     at ChildProcess.emit (events.js:98:17)
+10 verbose stack     at maybeClose (child_process.js:756:16)
+10 verbose stack     at Process.ChildProcess._handle.onexit (child_process.js:823:5)
+11 verbose pkgid [email protected]
+12 verbose cwd /Users/xul15/Documents/work/nodejs_app/cf-mysql-node-broker
+13 error Darwin 13.4.0
+14 error argv "node" "/usr/local/bin/npm" "start"
+15 error node v0.10.33
+16 error npm  v2.1.8
+17 error code ELIFECYCLE
+18 error [email protected] start: `node ./server/app.js`
+18 error Exit status 8
+19 error Failed at the [email protected] start script 'node ./server/app.js'.
+19 error This is most likely a problem with the cf-mysql-node-broker package,
+19 error not with npm itself.
+19 error Tell the author that this fails on your system:
+19 error     node ./server/app.js
+19 error You can get their info via:
+19 error     npm owner ls cf-mysql-node-broker
+19 error There is likely additional logging output above.
+20 verbose exit [ 1, true ]

package.json

@@ -0,0 +1,38 @@
+{
+  "name": "cf-mysql-node-broker",
+  "version": "1.0.0",
+  "description": "mysql service broker built on node.js for cloud foundry",
+  "main": "index.js",
+  "scripts": {
+    "start": "node ./server/app.js",
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "repository": {
+    "type": "git",
+    "url": "https://github.com/komushi/cf-mysql-node-broker.git"
+  },
+  "keywords": [
+    "cf",
+    "cloud",
+    "foundry",
+    "service",
+    "broker"
+  ],
+  "author": "Lei Xu",
+  "license": "ISC",
+  "dependencies": {
+    "express": "~4.0.0",
+    "body-parser":"1.10.x",
+    "basic-auth":"~1.0.0",
+    "fs":"~0.0.2",
+    "js-yaml":"3.2.x",
+    "q":"1.1.x",
+    "mysql":"~2.5.0",
+    "cfenv":"1.0.x"
+
+  },
+  "bugs": {
+    "url": "https://github.com/komushi/cf-mysql-node-broker/issues"
+  },
+  "homepage": "https://github.com/komushi/cf-mysql-node-broker"
+}

resources/mysql.yml

@@ -0,0 +1,4 @@
+host: localhost
+port: 3306
+user: root
+password: 

resources/settings.yml

@@ -0,0 +1,32 @@
+# This file should not be used in deployed environments. Instead, set
+# the SETTINGS_PATH environment variable to point to a configuration
+# file that contains these settings.
+
+
+services:
+- name: p-mysql
+  id: 3101b971-1044-4816-a7ac-9ded2e028079
+  description: MySQL service for application development and testing
+  tags:
+    - mysql
+    - relational
+  max_db_per_node: 250
+  metadata:
+    displayName: MySQL for Pivotal CF
+    imageUrl: data:image/png;base64,iVBORw0KGgoAAAANSUhEUgAAAEAAAABACAYAAACqaXHeAAAACXBIWXMAAAsTAAALEwEAmpwYAAAAGXRFWHRTb2Z0d2FyZQBBZG9iZSBJbWFnZVJlYWR5ccllPAAABoxJREFUeNrkW01sG0UUnkQ90FNNOfVHilvKBQS2iASHVtiCHkAqxI3ECZG4KOJGnOZQxCVxeuHnEJz0BlVjF3FCyg9UooeKOogeqBTkOEov/DlS056a2hfCASm8b3izXY/XZr07Xq/hSSs7jr2775v3vu+92Zm+vb098X+2fR2/wAeZCL0k6YjzEeHXA9pXa3SU+H2R35f++nCu0sn76+tEBJDTcDDNjsd8nm6LjmU68gRGKdQAkONwesKA063AyDEY1dAAwI5n6RgIKHVrDETOLxC+ACDHEeL5AB13AiJNICwHCgATG0Y8ExIyX2Egqh0HgAku38E89xMNKQKh2M6P+tt0PsUSFTbnBcvqTeYj8wDwiZcc9DtstkD3mjWaAuz8Qo8VeXOUDhO+AeCwX+rRSvccgZD3DAATXrEHwr6VnW0lk00BYKkrdVHjTapDvFlP0aoZygXhfOzQETH0zHMi+vhBecAqD3fExRvfyldD6pDnvsRdBHCFd9PE1SOP7Rexw0esv1d/+8V6f+XNt8TQ08+KlTsbYv3etijdvyu/j8+rf+6KJz+eMYn1eYqCnFsAKn5GHyM5dfo1kTh+QgxEDorvf//H6QH6HH/Dyve35evLn12SzupRsTZ+Qbzy+aU6wAykQlSvFvc5OO+5qcHowfHRwRdEYe22GL56Wayzo05R0cy5GgNi0HmVCjlu050jgImv4oX14dR3774nR/Odr770lb+Zk0kJEM7TATtmJ0S9Ekx5lbzFkTHK4W0Z0n7Jq/LwgUwfRYqGbaJVKZz1csbRwRdlfk9+s2imtSNSXNnckDyAcxu2NEd6PQBc9HjKfTD5xRvXG8jMj01eWxTDX1wWs2fOSlVAihnkgpRTBKS9nvENSNlm2fed6WEPEoQUxkkVwC8GQXAEIOXnjCZGHw6PUMjPnhm2gMB5wSuw2deHTQEwVAcAhX/Ua/hj1Mqa1GGk4AT0vF1DBTh/qygW3x6TkmoHAdcyxQlc7FkRkPQjWUVNrzFS4ycTYoFy15sK7Ijn5z+RUXCFz6HkFZxgKBXqAIh7LXowKhi1OgIjNUD1d86njqs6QIGAFEFhZSgKvAEQY0L69f1pOUKDNFJ6/quQdaoCvYIApZGzHD8UxfiphAkAonYAIq5D/lRSlKhxgeN+Kz7XkkgRheuqGgHRZ6BIGrAD4HqSExdeuVMOxHF7RM1QmilSRSokjj9lhgzb/QEI71Ni+Llbq7JkdWtod5tJJXhEOrq72zRt4LQCACW3F4VxUoK2AQDh1ehGkZOR/e7ZGDeMokYHAXKZJADwuWqXIasAuLD2Yz2IDM76vbtWSgQeAZKISKdxtGNg8nG6aV0x4tT1naey1976AtxpUpgMSanTfIHJkrs/qDwGe8MhnbzAJfFDRxuaIdQBCHUoTictMAAQvpgkQYWnA3CgSSpBZfC/DnSE1uUVAFtBgIAOT84dEAiqmkNEgFOac851qwYwbZgYUQBUgooE5DTIcy1zwZoU1cmunv1/tlTikRQ/IRXDwByhRYIAIBEEAKpKhOOxw0cdSa4hRbTaH2pR8l9lluwA4I9REaDJWR86/q3TdBppyCZI1SQARREim2IJxMhvVXfE1Z9u1/3/pWMn5IyzMQCw+oqqopoIwTNAtNeYVkchNE+jrKeHmn8wUAss64XQctBp4GTo9CB/hp8JNKiyekDSryMSBmvF8OgpQII+a4N8QyHEj5Br3XZeFksjY9JBXf6UiiA9pk6/6jv8nSrBfLcBQK+A/h8yia7zwfRHDaMNbkAh5QSQGwGyPxnSmyE8O+v60je7RMJJVI7V3T+szxAFPkgw17QXYGQKYZJEkOHktSU50arKZ/kkitrmrfYnZVb1ZXROzVA2DFxQFxGbZek85iHhPPL/a4oGD7NSWf2DZusD8MXpMIGg1hzIKbnNjbbnIxDZNPppVwAwCKiUwrgg0mvjE3VaSttqPiAdtlTwYalm64j7W/TKiICJ/4DzM63WD7tZKBkKafRaVznlvdsUUJEwETZpdFvvu4lgV3OCjGKhx5xPutk/4HpStIdAKLh13hUHOHACgAjrynEQXradH3jdMhPnjios64g97x3y9FyAJRIgzIUk5KNeN0753jbHy2vQRicCdnwVtX27e4SMA2ADIsnV42gvOG4cAC0iUgyGqV5CbZ/Nmd5L3NfJ3eMMRlI82jjtNk2g4+AZjHKxkxuo+7qxfV4tUXOwkqk9wW7tbwEGAJwbJQSR3aMDAAAAAElFTkSuQmCC
+    longDescription: Provisioning a service instance creates a MySQL database. Binding applications to the instance creates unique credentials for each application to access the database
+    providerDisplayName: Pivotal Software
+    documentationUrl: http://docs.pivotal.io/p-mysql
+    supportUrl: http://support.pivotal.io
+  plans:
+  - name: 5mb
+    id: 2451fa22-df16-4c10-ba6e-1f682d3dcdc9
+    description: Shared MySQL Server, 5mb persistent disk, 40 max concurrent connections
+    max_storage_mb: 5 # in MB
+    metadata:
+      cost: 0.0
+      bullets:
+      - content: Shared MySQL server
+      - content: 5 MB storage
+      - content: 40 concurrent connections
+

server/app.js

@@ -0,0 +1,44 @@
+console.log("process.cwd():" + process.cwd());
+
+/**************************/
+/* config */
+var application_root = __dirname;
+var express = require("express");
+var path = require("path");
+var Q = require("q");
+var bodyParser = require('body-parser');
+// var api = require('./controllers/catalogController');
+var routes = require('./routes/routes');
+var basicAuth = require('./utils/basicAuth');
+var app = express();
+
+var allowCrossDomain = function(req, res, next) {
+    res.header('Access-Control-Allow-Origin', '*');
+    res.header('Access-Control-Allow-Methods', 'GET,PUT,POST,DELETE,OPTIONS');
+    res.header('Access-Control-Allow-Headers', 'Content-Type, Authorization, Content-Length, X-Requested-With');
+
+    // intercept OPTIONS method
+    if ('OPTIONS' == req.method) {
+      res.send(200);
+    }
+    else {
+      next();
+    }
+};
+
+app.disable('etag'); 
+app.use(allowCrossDomain);
+app.use(bodyParser.json());
+app.use(bodyParser.urlencoded({ 
+   extended: true 
+}));
+app.use(express.static(path.join(application_root, "public")));
+app.use('/v2', basicAuth.auth('test', 'test'));
+app.use('/', routes);
+
+/* config */
+/**************************/
+
+var server = app.listen((process.env.PORT || 9000), function() {
+  console.log('Express server listening on port ' + server.address().port);
+});

server/controllers/catalogController.js

@@ -0,0 +1,12 @@
+var resourceManager = require('../utils/resourceManager');
+
+exports.getCatalog = function(req, res) {
+
+    resourceManager.getResource("./resources/settings.yml", function (err, jsonString) {
+
+    	res.set('Content-Type', 'application/json');
+    	res.send(jsonString);
+    });
+
+};
+

server/controllers/serviceInstanceController.js

@@ -0,0 +1,22 @@
+var service = require('../services/serviceInstanceService.js');
+
+exports.getMySQL = function(req, res) {
+    service.executeQuery("select 1 + 1 as result", function (err, result) {
+
+    	console.log("result:" + JSON.stringify(result));
+    	res.set('Content-Type', 'application/json');
+    	res.send(result);
+    });
+
+};
+
+
+exports.create = function(req, res) {
+    service.update(req.params.id, function (err, result) {
+
+    	console.log("result:" + JSON.stringify(result));
+    	res.set('Content-Type', 'application/json');
+    	res.send(result);
+    });
+
+};

server/routes/routes.js

@@ -0,0 +1,47 @@
+var express=require('express');
+var catalogController = require('../controllers/catalogController');
+var serviceInstanceController = require('../controllers/serviceInstanceController');
+
+//configure routes
+
+var router=express.Router();
+
+/**************************/
+/* REST API hello */
+router.route('/v2')
+  .get(function (req, res) {
+   res.send('REST API is running.');
+   console.log("REST API is running.");
+});
+/* REST API hello */
+/**************************/
+
+/**************************/
+/* REST API /v2/catalog */
+router.route('/v2/catalog')
+  .get(function (req, res) {
+  	console.log("Begin: /v2/catalog");
+
+  	catalogController.getCatalog(req, res);
+
+  	console.log("End: /v2/catalog");
+});
+
+/* REST API getCountByCat */
+/**************************/
+
+/**************************/
+/* REST API /v2/catalog */
+router.route('/v2/service_instances/:instance_id')
+  .put(function (req, res) {
+  	console.log("Begin: /v2/service_instances/:instance_id");
+
+  	serviceInstanceController.getMySQL(req, res);
+
+  	console.log("End: /v2/service_instances/:instance_id");
+});
+
+/* REST API getCountByCat */
+/**************************/
+
+module.exports=router;

server/services/serviceInstanceService.js

@@ -0,0 +1,21 @@
+var mysqlManager = require('../utils/mysqlManager');
+
+
+exports.executeQuery = function(queryText, next) {
+
+
+	mysqlManager.executeQuery(queryText, next);
+
+
+};
+
+
+exports.update = function(instanceId, next) {
+
+
+	var queryText = "CREATE DATABASE " + instanceId;
+
+	mysqlManager.executeQuery(queryText, next);
+
+
+};

server/utils/basicAuth.js

@@ -0,0 +1,29 @@
+
+/**
+ * Your utility library for express
+ */
+
+var basicAuth = require('basic-auth');
+
+/**
+ * Simple basic auth middleware for use with Express 4.x.
+ *
+ * @example
+ * app.use('/api-requiring-auth', basicAuth.auth('username', 'password'));
+ *
+ * @param   {string}   username Expected username
+ * @param   {string}   password Expected password
+ * @returns {function} Express 4 middleware requiring the given credentials
+ */
+exports.auth = function(username, password) {
+  return function(req, res, next) {
+    var user = basicAuth(req);
+
+    if (!user || user.name !== username || user.pass !== password) {
+      res.set('WWW-Authenticate', 'Basic realm=Authorization Required');
+      return res.send(401);
+    }
+
+    next();
+  };
+};