Feature/random data provider

.env.bitbucket

@@ -8,4 +8,6 @@ API_PORT=3001
 SAFE_BLOCK_DELAY=2
 START_BLOCK=0
 PERSISTENCE=INMEMORY
+SGX_ENABLED=false
+RANDOMDOTORG_API_KEY=ba3139ef-4f53-48fc-a7e8-af437005e09c
 

.env.local

@@ -8,3 +8,5 @@ API_PORT=3001
 SAFE_BLOCK_DELAY=2
 START_BLOCK=0
 PERSISTENCE=INMEMORY
+SGX_ENABLED=false
+RANDOMDOTORG_API_KEY=ba3139ef-4f53-48fc-a7e8-af437005e09c

.env.test

@@ -8,3 +8,5 @@ API_PORT=3001
 SAFE_BLOCK_DELAY=2
 START_BLOCK=0
 PERSISTENCE=INMEMORY
+SGX_ENABLED=false
+RANDOMDOTORG_API_KEY=ba3139ef-4f53-48fc-a7e8-af437005e09c

.env.tpl

@@ -8,3 +8,5 @@ API_PORT=3001
 SAFE_BLOCK_DELAY=0
 START_BLOCK=0
 PERSISTENCE=INMEMORY
+SGX_ENABLED=false
+RANDOMDOTORG_API_KEY=ba3139ef-4f53-48fc-a7e8-af437005e09c

.gitignore

@@ -7,4 +7,4 @@ node_modules
 logs/*
 !logs/.gitkeep
 /docs/_build/
-dist
+dist

Dockerfile

@@ -1,4 +1,19 @@
-FROM node:10.15
+FROM sebvaucher/sgx-base:sgx_2.5
+
+# Add SGX SDK libs to source. It does what 'source /opt/intel/sgxsdk/environment' does
+ENV SGX_SDK /opt/intel/sgxsdk
+ENV PATH=$SGX_SDK/bin:$SGX_SDK/bin/x64:$PATH \
+    PKG_CONFIG_PATH=$SGX_SDK/pkgconfig:$PKG_CONFIG_PATH \
+    LD_LIBRARY_PATH=$SGX_SDK/sdk_libs:./libs:$LD_LIBRARY_PATH
+
+# Install nodejs dependencies
+RUN apt-get update -q -q && \
+    apt-get install curl libssl1.0-dev --yes
+
+# Install nodejs v11
+RUN curl -sL https://deb.nodesource.com/setup_10.x | bash -
+RUN apt-get install -y nodejs
+RUN npm install npm --global
 
 # Create app directory
 WORKDIR /usr/src/app

docker-compose.yml

@@ -9,6 +9,9 @@ services:
             - mongo
         ports:
             - ${API_PORT}:${API_PORT}
+        devices:
+            - /dev/isgx
+            - /dev/mei0
         command: bash -c "./wait-for-it.sh mongo:27017 && npm start"
     mongo:
         container_name: oracle-db

package.json

@@ -44,10 +44,12 @@
     "dotenv": "6.0.0",
     "execution-time": "1.3.0",
     "express": "4.16.3",
+    "ffi": "2.3.0",
     "jsonpath": "1.0.2",
     "lodash": "4.17.11",
     "mongoose": "5.3.12",
     "node-schedule": "1.3.0",
+    "ref": "1.3.5",
     "web3": "1.0.0-beta.36",
     "web3-eth-contract": "1.0.0-beta.55",
     "web3-utils": "1.0.0-beta.55",
@@ -59,8 +61,12 @@
   "devDependencies": {
     "@types/dotenv": "6.1.1",
     "@types/express": "4.17.0",
+    "@types/ffi": "0.2.2",
+    "@types/jsonpath": "0.2.0",
     "@types/lodash": "4.14.134",
     "@types/mongoose": "5.5.6",
+    "@types/nock": "10.0.3",
+    "@types/ref": "0.0.28",
     "chai": "4.1.2",
     "chai-as-promised": "7.1.1",
     "coveralls": "3.0.2",

src/application/dataFetcher/AxiosUrlDataFetcherAdapter.ts

@@ -1,8 +1,8 @@
-import Request from '@core/domain/request/Request';
 import axios from 'axios';
 
 import DataFetcher from '@core/domain/common/port/DataFetcherPort';
 import { HttpError } from '@core/domain/common/utils/error';
+import Request from '@core/domain/request/Request';
 import RequestUrlParser from '@core/domain/request/RequestUrlParser';
 
 class AxiosUrlDataFetcherAdapter implements DataFetcher {

src/application/dataFetcher/random/RandomDotOrgDataFetcherAdapter.spec.ts

@@ -0,0 +1,34 @@
+import { expect } from 'chai';
+import { describe, it } from 'mocha';
+import * as nock from 'nock';
+
+import Request from '@core/domain/request/Request';
+import {response} from '@testData/application/dataFetcher/random/RandomDotOrgResponse';
+import RandomDotOrgDataFetcherAdapter from './RandomDotOrgDataFetcherAdapter';
+
+describe('RandomSgxDataFetcherAdapter', () => {
+  const request = new Request('SOME_REQUEST_ID', 'random(0,10)', null);
+
+  it('return first data item on successful response', async () => {
+    // given
+    nock('https://api.random.org')
+      .post('/json-rpc/2/invoke')
+      .reply(200, response);
+    const sut = new RandomDotOrgDataFetcherAdapter('some-api-key');
+    // when
+    const result = await sut.fetch(request);
+    // then
+    expect(result).to.equal('2');
+  });
+
+  it('throw error on failed response', async () => {
+    // given
+    nock('https://api.random.org')
+      .post('/json-rpc/2/invoke')
+      .reply(500);
+    const sut = new RandomDotOrgDataFetcherAdapter('some-api-key');
+    // when
+    // then
+    return expect(sut.fetch(request)).to.be.rejected;
+  });
+});

src/application/dataFetcher/random/RandomDotOrgDataFetcherAdapter.ts

@@ -0,0 +1,54 @@
+import RequestUrlParser from '@core/domain/request/RequestUrlParser';
+import axios from 'axios';
+import * as jp from 'jsonpath';
+
+import DataFetcher from '@core/domain/common/port/DataFetcherPort';
+import { HttpError } from '@core/domain/common/utils/error';
+import Request from '@core/domain/request/Request';
+
+class RandomDotOrgDataFetcherAdapter implements DataFetcher {
+  constructor(private apiKey: string) {}
+
+  async fetch(request: Request) {
+    let response;
+
+    const min = RequestUrlParser.resolveLeftSideBound(request.url);
+    const max = RequestUrlParser.resolveRightSideBound(request.url);
+
+    try {
+      response = await axios({
+        method: 'post',
+        url: 'https://api.random.org/json-rpc/2/invoke',
+        headers: {
+          'Content-Type': 'application/json',
+        },
+        data: this.createRequestData(Number(min), Number(max)),
+      });
+
+      return jp.value(response.data, 'result.random.data[0]').toString();
+    } catch (e) {
+      const randomDotOrgErrorCode = jp.value(response.data, 'error.code').toString();
+      const randomDotOrgErrorMessage = jp.value(response.data, 'error.message').toString();
+
+      throw new HttpError(randomDotOrgErrorMessage, randomDotOrgErrorCode);
+    }
+  }
+
+  private createRequestData(min: number, max: number): string {
+    return JSON.stringify({
+      jsonrpc: '2.0',
+      method: 'generateIntegers',
+      params: {
+        apiKey: this.apiKey,
+        n: 1,
+        min,
+        max,
+        replacement: true,
+        base: 10,
+      },
+      id: 0,
+    });
+  }
+}
+
+export default RandomDotOrgDataFetcherAdapter;