WIP: Transaction queuing and proof generation node

.babelrc

@@ -0,0 +1,10 @@
+{
+  "presets": ["env"],
+  "plugins": [
+    "babel-plugin-add-module-exports",
+    "transform-class-properties",
+    "transform-decorators-legacy",
+    "transform-object-rest-spread"
+  ]
+}
+

.circleci/config.yml

@@ -0,0 +1,40 @@
+version: 2.0
+jobs:
+  core_test:
+    working_directory: ~/repo
+    docker:
+    - image: circleci/node:10.16.0
+    - image: mysql:5
+      environment:
+        MYSQL_ROOT_PASSWORD: "123"
+    - image: rabbitmq:3.7
+    steps:
+      - checkout
+      - run:
+          name: "Pull Submodules"
+          command: 'git submodule update --init --recursive'
+      - run:
+          name: update-npm
+          command: 'sudo npm install -g npm@latest'
+      - restore_cache:
+          key: dependency-cache-{{ checksum "package.json" }}
+      - run:
+          name: install-npm-wee
+          command: npm install
+      - save_cache:
+          key: dependency-cache-{{ checksum "package.json" }}
+          paths:
+            - ./node_modules
+      - run:
+          name: setup-config
+          command: 'cp ./config/config-sample.json ./config/config.json'
+      - run:
+          name: create-DB
+          command: 'npm run create-DB'
+      - run:
+          command: 'npm run test'
+workflows:
+  version: 2
+  workflow:
+    jobs:
+    - core_test

.eslintrc.js

@@ -0,0 +1,8 @@
+module.exports = {
+  parser: 'babel-eslint',
+  extends: 'standard',
+  rules: {
+    'space-before-function-paren': ['error', 'never']
+  }
+}
+

.gitignore

@@ -0,0 +1,3 @@
+node_modules
+config/config.json
+test/testCount.json

.gitmodules

@@ -0,0 +1,3 @@
+[submodule "circomlib"]
+	path = circomlib
+	url = https://github.com/iden3/circomlib.git

DB/createDB.js

@@ -0,0 +1,23 @@
+'use strict';
+const config = require('../config/config.js');
+const {attachOnDuplicateUpdate} = require('knex-on-duplicate-update');
+
+async function createDatabase() {
+  const knexConfig = require(process.cwd() + '/DB/knexfile');
+  knexConfig.connection.database = null;
+  const knex = require('knex')(knexConfig);
+  attachOnDuplicateUpdate();
+  console.log("Creating database ", global.gConfig.db_name);
+  try {
+    await knex.raw('CREATE DATABASE ' + global.gConfig.db_name);
+  } catch (e) {
+    if (e.errno === 1007) {
+      console.log("DB already exits")
+    } else {
+      console.log("Error while creating database", e)
+    }
+  }
+  await knex.destroy();
+}
+
+createDatabase();

DB/dbClient.js

@@ -0,0 +1,7 @@
+const {attachOnDuplicateUpdate} = require('knex-on-duplicate-update');
+
+var config = require('./knexfile.js');
+var knex = require('knex')(config);
+attachOnDuplicateUpdate();
+
+export default knex

DB/knexfile.js

@@ -0,0 +1,16 @@
+var config = require('../config/config.js')
+
+module.exports = {
+  client: 'mysql',
+  connection: {
+    user: global.gConfig.user,
+    password: global.gConfig.password,
+    database: global.gConfig.db_name
+  },
+  pool: {
+    max: 1000
+  },
+  migrations: {
+    directory: './migrations',
+  },
+}

DB/migrations/20190524003152_create_tx_table.js

@@ -0,0 +1,39 @@
+exports.up = function(knex, Promise) {
+  return knex.schema.createTable("tx", function(t) {
+    t.string("hash")
+      .notNullable()
+      .primary()
+      .unique();
+    t.string("fromX").notNullable();
+    t.string("fromY").notNullable();
+    t.integer("fromIndex").notNullable();
+    t.string("toX").notNullable();
+    t.string("toY").notNullable();
+    t.integer("toIndex").notNullable();
+    t.integer("nonce").notNullable();
+    t.integer("amount").notNullable();
+    t.integer("tokenType").notNullable();
+    t.string("R8x").notNullable();
+    t.string("R8y").notNullable();
+    t.string("S").notNullable();
+    t.datetime("timestamp")
+      .notNullable()
+      .defaultTo(knex.fn.now());
+    // status definitions to later be included in a table like token type
+    // 0: processing
+    // 1: awaiting transfer inclusion in proof,
+    // 2: transfer included in proof,
+    // 3: awaiting withdraw inclusion in proof,
+    // TODO remove usage of 3
+    // 4: withdraw included in proof,
+    // 5: withdrawn on smart contract
+    t.integer("status")
+      .notNullable()
+      .defaultTo(0);
+    t.string("txRoot");
+  });
+};
+
+exports.down = function(knex, Promise) {
+  return knex.schema.dropTableIfExists("tx");
+};

DB/migrations/20190525210231_create_account.js

@@ -0,0 +1,23 @@
+exports.up = function(knex, Promise) {
+  return knex.schema.createTable("accounts", function(t) {
+    t.integer("index")
+      .primary()
+      .unique();
+    t.string("pubkeyX").notNullable();
+    t.string("pubkeyY").notNullable();
+    t.integer("balance").notNullable();
+    t.integer("nonce").defaultTo(0);
+    t.integer("tokenType").notNullable();
+    t.string("modifiedBy");
+    t.datetime("createdAt")
+      .defaultTo(knex.fn.now())
+      .notNullable();
+    t.datetime("updatedAt")
+      .defaultTo(knex.fn.now())
+      .notNullable();
+  });
+};
+
+exports.down = function(knex, Promise) {
+  return knex.schema.dropTableIfExists("accounts");
+};

DB/migrations/20190525210232_create_deposits.js

@@ -0,0 +1,13 @@
+module.exports = {
+  up: knex =>
+    knex.schema.createTable("deposits", table => {
+      table.string("txHash").notNullable().unique().primary();
+      table.integer("blockNumber").notNullable();
+      table.string("pubkeyX").notNullable();
+      table.string("pubkeyY").notNullable();
+      table.integer("amount").notNullable();
+      table.integer("tokenType").notNullable();
+      table.string("depositHash");
+    }),
+  down: knex => knex.schema.dropTable("deposits")
+};

DB/migrations/20190706235129_account_tree.js

@@ -0,0 +1,18 @@
+module.exports = {
+  up: knex =>
+    knex.schema.createTable("account_tree", table => {
+      table.integer("depth").notNullable();
+      table.integer("index").notNullable();
+      table.unique(["depth", "index"])
+      table.string("hash").notNullable();
+      table
+        .datetime("createdAt")
+        .notNullable()
+        .defaultTo(knex.fn.now());
+      table
+        .datetime("modifiedAt")
+        .notNullable()
+        .defaultTo(knex.fn.now());
+    }),
+  down: knex => knex.schema.dropTable("account_tree")
+};

DB/migrations/20190706235549_create_state_transition_table.js

@@ -0,0 +1,18 @@
+exports.up = function(knex, Promise) {
+  return knex.schema.createTable("state_transitions", function(t) {
+    t.string("txRoot")
+      .primary()
+      .unique()
+      .notNullable();
+    t.string("toIndexes").notNullable();
+    t.string("txHashes").notNullable();
+    t.json("proof").notNullable();
+    t.datetime("createdAt")
+      .notNullable()
+      .defaultTo(knex.fn.now());
+  });
+};
+
+exports.down = function(knex, Promise) {
+  return knex.schema.dropTableIfExists("state_transitions");
+};

README.md

@@ -0,0 +1,84 @@
+# RollupNC co-ordinator
+
+Acts as a co-ordinator between users for RollupNC
+
+## Install
+
+> Please ensure you have `rabbitmq-server` running in background
+
+Install node version 10.16.0, possibly using nvm
+
+```bash
+npm i
+```
+## Setup 
+
+- randomly generate coordinator prvkey and pubkey,
+- set DB password, and
+- initialise `zeroCache`.
+
+(from root directory)
+```bash
+cp config/config-sample.json config/config.json
+npm run setup
+```
+
+NB: you can manually change the secrets in `config.json` instead of running `npm run setup`.
+
+## Create Migration 
+```bash
+knex migrate:make account_tree  --knexfile=DB/knexfile.js
+```
+## Run Migrations
+
+```bash
+npm run migrations
+```
+
+> Note mysql needs to be installed
+
+## Reset DB and Rerun Migrations
+
+```bash
+npm run redo
+```
+
+## Alter genesis balance state
+
+To alter the genesis state, change config/genesis.json
+
+## Run
+
+> Please set configration as per requirement in config/config.json
+
+```bash
+npm run coordinator
+```
+
+## Send test transactions
+
+```bash
+bash sendTestRequests.sh
+```
+
+## Send test transaction
+
+```bash
+curl -X POST \
+  http://localhost:3000/submitTx \
+  -H 'Content-Type: application/json' \
+  -H 'Postman-Token: 6a5d7f6b-2189-4b7b-81c8-dd62067217a4' \
+  -H 'cache-control: no-cache' \
+  -d '{
+	"fromX":"5686635804472582232015924858874568287077998278299757444567424097636989354076",
+	"fromY":"20652491795398389193695348132128927424105970377868038232787590371122242422611",
+	"toX":"5188413625993601883297433934250988745151922355819390722918528461123462745458",
+	"toY":"12688531930957923993246507021135702202363596171614725698211865710242486568828",
+	"amount":"500",
+	"tokenType":"10",
+	"signature":{
+        "R8": "16983338799297102739311784762032344870039222281986241143318530383875079624912,17974713114491039907234265242193070110554943394288196512948620624137364193552",
+        "S": "1343828434385488942743107335063404632386867645513272609057729341930827645964"
+    }
+}'
+```

config/config-sample.json

@@ -0,0 +1,48 @@
+{
+  "development": {
+    "amqp_url": "amqp://localhost",
+    "tx_queue": "transfer",
+    "txs_per_snark": 8,
+    "log_level": "debug",
+    "poll_interval": "15000",
+    "contractAddress": "",
+    "RPC": "http://localhost:8545",
+    "tx_depth": 3,
+    "balance_depth": 12,
+    "host": "localhost",
+    "user": null,
+    "password": null,
+    "pubkey": null,
+    "prvkey": null,
+    "alicePubkey": null,
+    "alicePrvkey": null,
+    "bobPubkey": null,
+    "bobPrvkey": null,
+    "db_name": "rollupNC",
+    "port": 3000
+  },
+  "staging": {
+    "amqp_url": "amqp://localhost",
+    "tx_queue": "tx",
+    "txs_per_snark": 4,
+    "log_level": "info",
+    "poll_interval": "1000",
+    "contractAddress": "",
+    "RPC": "https://ropsten.etherscan.io",
+    "tx_depth": 2,
+    "balance_depth": 2,
+    "port": 3000
+  },
+  "production": {
+    "amqp_url": "amqp://<insert ip>",
+    "tx_queue": "tx",
+    "txs_per_snark": 4,
+    "log_level": "info",
+    "poll_interval": "1000",
+    "contractAddress": "",
+    "RPC": "https://mainnet.etherscan.io",
+    "tx_depth": 2,
+    "balance_depth": 2,
+    "port": 3000
+  }
+}

config/config.js

@@ -0,0 +1,13 @@
+// requires
+const _ = require("lodash");
+
+// module variables
+const config = require("./config.json");
+const defaultConfig = config.development;
+const environment = process.env.NODE_ENV || "development";
+const environmentConfig = config[environment];
+const finalConfig = _.merge(defaultConfig, environmentConfig);
+
+global.gConfig = finalConfig;
+
+console.log("Loaded config....");