first version

Author: jamesjara

example/example.js

@@ -0,0 +1,18 @@
+
+var KEY = 'MM72AkzHXdHpC8iP65VVEEVrJjp7zkgd';
+
+var ds = require('loopback').createDataSource({connector: require('../'), key: KEY});
+
+var Shodan = ds.createModel('shodan', {
+    type: {type: String, id: true, required: true}
+});
+
+console.log(Shodan);
+
+Shodan.search("port:80", function (err, data) {
+    if (err) {
+        console.log(err);
+    } else {
+        console.log(data);
+    }
+});

index.js

@@ -0,0 +1 @@
+module.exports = require('./lib/shodan');

lib/shodan.js

@@ -0,0 +1,104 @@
+/* jamesjara, netdb.io */
+
+'use strict';
+
+var shodanLib = require('shodan-client'),
+    util = require('util'),
+    Connector = require('loopback-connector').Connector,
+    Shodan = function Shodan() {};  
+
+/* eslint-disable no-unused-vars */
+var shodanInstance = {}; 
+/* eslint-enable no-unused-vars */
+
+var ShodanConnector = function ShodanConnector(settings) {
+  assert(typeof settings.api_key === 'string', 'cannot init connector without api key');
+  if (settings.api_key){
+    this.shodan = shodanLib;
+  }
+
+  this.key = settings.api_key;
+  shodanInstance = this.shodan;
+};
+
+ShodanConnector.initialize = function (dataSource, callback) {
+  dataSource.connector = new ShodanConnector(dataSource.settings);
+  callback();
+};
+
+ShodanConnector.prototype.DataAccessObject = Shodan;
+
+/**
+ * Send transactional email with options
+ * Full list of options are available here: https://www.npmjs.com/package/sendgrid#available-params
+ *
+ * @param {Object} options
+ * {
+ *   from: { name: "John", email: "john@cellarise.com" },
+ *   to: "[email protected]",
+ *   subject: "Test mail",
+ *   text: "Plain text message",
+ *   html: "<b>Html messages</b> here"
+ * }
+ *
+ * @param {Function} cb callback
+ * @returns {Function} deferred promise
+ */
+Shodan.query = function (options, cb) { // eslint-disable-line
+  var dataSource = this.dataSource,
+    connector = dataSource.connector,
+    deferred = Q.defer(),
+    request;
+
+  var fn = function (err, result) {
+    if (err) {
+      deferred.reject(err);
+    } else {
+      deferred.resolve(result);
+    }
+    return cb && cb(err, result);
+  };
+
+  if (options.__data) {
+    options = R.clone(options.__data);
+  } else {
+    options = R.clone(options);
+  }
+
+  assert(connector, 'Cannot query without a connector!');
+
+  if (connector.shodan) {
+
+  shodanLib.search('asterisk port:5061', 'YOURKEYHERE', searchOpts)
+    .then(res => {
+      console.log('Result:');
+      fn(null, options);
+    })
+    .catch(err => {
+      console.log('Error:');
+      console.log(err);
+      fn(null, response);
+    });
+
+ 
+  } else {
+    process.nextTick(function nextTick() { // eslint-disable-line
+      fn(null, options);
+    });
+  }
+  return deferred.promise;
+};
+
+/**
+ * Query Shodan instance using instance
+ */
+
+Shodan.prototype.query = function protoQuery(fn) {
+  return this.constructor.query(this, fn);
+};
+
+/**
+ * Export the connector class
+ */
+module.exports = ShodanConnector;
+

package.json

@@ -0,0 +1,32 @@
+{
+  "name": "shodan-api-strongloop-connector",
+  "version": "1.0.0",
+  "description": "Strongloop connector for shodan APi",
+  "main": "index.js",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "repository": {
+    "type": "git",
+    "url": "git+https://github.com/jamesjara/shodan-api-strongloop-connector.git"
+  },
+  "keywords": [
+    "strongloop",
+    "shodan",
+    "connector",
+    "api"
+  ],
+  "dependencies": {
+    "shodan-client": "2.0.0",
+    "loopback-connector": "*"
+  },
+  "author": "jamesjara", 
+  "license": {
+    "name": "MIT",
+    "url": "https://github.com/jamesjara/shodan-api-strongloop-connector/blob/master/LICENSE"
+  },
+  "bugs": {
+    "url": "https://github.com/jamesjara/shodan-api-strongloop-connector/issues"
+  },
+  "homepage": "https://github.com/jamesjara/shodan-api-strongloop-connector#readme"
+}