Interactions with SC

Author: morrigan

.gitignore

@@ -1,2 +1,3 @@
 .idea
-node_modules
+node_modules
+config.js

config.js config.example.jsconfig.js renamed to config.example.js

@@ -2,5 +2,7 @@ module.exports = {
     name: 'API',
     env: process.env.NODE_ENV || 'development',
     port: process.env.PORT || 3000,
-    base_url: process.env.BASE_URL || 'http://localhost:3000'
+    contractAddress: '',
+    RPCEndpoint: 'http://neo.marinpetrunic.com:30333/',
+    wif: '',
 };

controllers/exchange.controller.js

@@ -0,0 +1,11 @@
+const defaultCurrency = 'USD';
+
+function getNEOPrice(currency = defaultCurrency) {
+    // TODO: fetch live ticker to get the last price
+    return 30;  // 1 NEO = 30$
+}
+
+exports.calculateAmountOfNEO = function(amount, currency = defaultCurrency) {
+    const price = getNEOPrice();
+    return Math.round(amount / price);
+};

controllers/payment.controller.js

@@ -1,10 +1,42 @@
 const CronJob = require('cron').CronJob;
+const neo = require('neo-api-js');
+const Neon = require('neon-js');
 
-exports.create_savings = function (data) {
+const config = require('../config');
+const NodeService = require("../services/node");
 
+exports.open_savings = function (amount) {
+    const account = Neon.getAccountFromWIFKey(config.wif);
+    const scriptHash = Neon.getScriptHashFromAddress(config.contractAddress);
+    const invoke = { operation: 'create', scriptHash };
+    const intents = [{ assetId: Neon.ASSETS['NEO'], value: amount, scriptHash }];
+    const gasCost = 0.5;
+    let signedTx;
+    console.log("HERE");
+    NodeService.getBalance(config.contractAddress).then((response) => {
+        // const balance = response.result.balance;
+        console.log("Balance is:", response);
+        const unsignedTx = Neon.create.invocation(account.publicKey, response, intents, invoke, gasCost, { version: 1 });
+        signedTx = Neon.signTransaction(unsignedTx, account.privateKey);
+        const hexTx = Neon.serializeTransaction(signedTx);
+        return Neon.queryRPC(net, 'sendrawtransaction', [hexTx], 4);
+    }).catch(function(error) {
+        console.log(error);
+    }).then((res) => {
+        if (res.result === true) {
+            res.txid = Neon.getTransactionHash(signedTx)
+        }
+        return res
+    })
 };
 
 exports.start_payment_cron = function (until, period) {
+    /*
+     Should use pollingPolicy?
+     const pollingPolicy = neo.service.createPollingPolicy(interval);
+     pollingPolicy.onInterval(function () {
+     });*/
+
     const endDate = new Date(until);
     const currentDate = new Date();
     const hours = currentDate.getHours();

index.js

@@ -1,6 +1,6 @@
 const config = require('./config');
 const restify = require('restify');
-const restifyPlugins = require('restify-plugins');
+const restifyPlugins = require('restify').plugins;
 const restifyValidation = require('node-restify-validation');
 const restifyErrors = require('restify-errors');
 

package.json

@@ -7,6 +7,7 @@
   "license": "MIT",
   "dependencies": {
     "cron": "^1.3.0",
+    "neo-api-js": "git+https://github.com/CityOfZion/neo-api-js.git",
     "neon-js": "git+https://github.com/CityOfZion/neon-js.git",
     "node-restify-validation": "^1.1.1",
     "restify": "^6.3.1",

routes/index.js

@@ -8,8 +8,8 @@ const paymentController = require('../controllers/payment.controller');
 module.exports = function(server) {
 
     server.get('/test', (req, res, next) => {
-        paymentController.start_payment_cron("11.8.2017. 00:17", "seconds");
-        next();
+        // paymentController.start_payment_cron("11.8.2017. 00:17", "seconds");
+        paymentController.open_savings(10);
     });
 
     /**
@@ -32,7 +32,7 @@ module.exports = function(server) {
         }
 
         const data = req.body;
-        paymentController.create_savings(data);
+        paymentController.open_savings(data);
     });
 
     /**

services/node.js

@@ -0,0 +1,22 @@
+const neo = require('neo-api-js');
+
+const config = require('../config');
+
+module.exports = {
+
+    getBalance: (address) => {
+        const node = neo.node(config.RPCEndpoint);
+        console.log(address);
+        return node.getBalance(address);
+    },
+
+    queryRPC: (node, method, params) => {
+        const jsonRequest = _axios2.default.create({ headers: { 'Content-Type': 'application/json' } });
+        const jsonRpcData = { method: method, params: params, id: id, jsonrpc: '2.0' };
+        return getRPCEndpoint(net).then(function (rpcEndpoint) {
+            return jsonRequest.post(rpcEndpoint, jsonRpcData).then(function (response) {
+                return response.data;
+            });
+        });
+    }
+};

yarn.lock

@@ -274,8 +274,8 @@ code-point-at@^1.0.0:
   resolved "https://registry.yarnpkg.com/code-point-at/-/code-point-at-1.1.0.tgz#0d070b4d043a5bea33a2f1a40e2edb3d9a4ccf77"
 
 color-convert@^1.9.0:
-  version "1.9.0"
-  resolved "https://registry.yarnpkg.com/color-convert/-/color-convert-1.9.0.tgz#1accf97dd739b983bf994d56fec8f95853641b7a"
+  version "1.9.1"
+  resolved "https://registry.yarnpkg.com/color-convert/-/color-convert-1.9.1.tgz#c1261107aeb2f294ebffec9ed9ecad529a6097ed"
   dependencies:
     color-name "^1.1.1"
 
@@ -1199,9 +1199,15 @@ negotiator@^0.6.1:
   version "0.6.1"
   resolved "https://registry.yarnpkg.com/negotiator/-/negotiator-0.6.1.tgz#2b327184e8992101177b28563fb5e7102acd0ca9"
 
+"neo-api-js@git+https://github.com/CityOfZion/neo-api-js.git":
+  version "1.0.1"
+  resolved "git+https://github.com/CityOfZion/neo-api-js.git#0b051fce92627f1d3169b63481ab6d0d4e5c5bba"
+  dependencies:
+    axios "^0.16.2"
+
 "neon-js@git+https://github.com/CityOfZion/neon-js.git":
   version "1.1.1"
-  resolved "git+https://github.com/CityOfZion/neon-js.git#6fc9b5a4dbc8018f3d60701ebd5d2b261b1ddab6"
+  resolved "git+https://github.com/CityOfZion/neon-js.git#0ae7ed07bebe5fff325b9530e8e942068ae771c9"
   dependencies:
     axios "^0.16.2"
     base-x "^3.0.2"
@@ -1375,7 +1381,7 @@ performance-now@^0.2.0:
   version "0.2.0"
   resolved "https://registry.yarnpkg.com/performance-now/-/performance-now-0.2.0.tgz#33ef30c5c77d4ea21c5a53869d91b56d8f2555e5"
 
-pidusage@^1.1.6:
+pidusage@^1.2.0:
   version "1.2.0"
   resolved "https://registry.yarnpkg.com/pidusage/-/pidusage-1.2.0.tgz#65ee96ace4e08a4cd3f9240996c85b367171ee92"
 
@@ -1550,8 +1556,8 @@ restify-plugins@^1.6.0:
     vasync "^1.6.3"
 
 restify@^6.3.1:
-  version "6.3.1"
-  resolved "https://registry.yarnpkg.com/restify/-/restify-6.3.1.tgz#23f68eb91cf184913f48bc3285311e56534167a1"
+  version "6.3.2"
+  resolved "https://registry.yarnpkg.com/restify/-/restify-6.3.2.tgz#959062c4403e687d39abe43a6c87b10cca12458a"
   dependencies:
     assert-plus "^1.0.0"
     bunyan "^1.8.12"
@@ -1566,7 +1572,7 @@ restify@^6.3.1:
     mime "^1.4.1"
     negotiator "^0.6.1"
     once "^1.4.0"
-    pidusage "^1.1.6"
+    pidusage "^1.2.0"
     qs "^6.5.1"
     restify-errors "^5.0.0"
     semver "^5.4.1"