Update to Lisk Core 1.0.0 API - Closes #341

Jenkinsfile

@@ -40,34 +40,6 @@ node('lisk-nano') {
         echo "Error: ${err}"
         fail('Stopping build: checkout failed')
       }
-
-      try {
-        sh '''
-        N=${EXECUTOR_NUMBER:-0}; N=$((N+1))
-        cd ~/lisk-Linux-x86_64
-        # work around core bug: config.json gets overwritten; use backup
-        cp .config.json config_$N.json
-        # change core port, listen only on 127.0.0.1
-        sed -i -r -e "s/^(.*ort\\":) 4000,/\\1 400$N,/" config_$N.json
-        sed -i -r -e "s/^(.*\\"address\\":) \\"0.0.0.0\\",/\\1 \\"127.0.0.1\\",/" config_$N.json
-        # disable redis
-        sed -i -r -e "s/^(\\s*\\"cacheEnabled\\":) true/\\1 false/" config_$N.json
-        # change postgres databse
-        sed -i -r -e "s/^(\\s*\\"database\\": \\"lisk_test)\\",/\\1_$N\\",/" config_$N.json
-        cp etc/pm2-lisk.json etc/pm2-lisk_$N.json
-        sed -i -r -e "s/config.json/config_$N.json/" etc/pm2-lisk_$N.json
-        sed -i -r -e "s/(lisk.app)/\\1_$N/" etc/pm2-lisk_$N.json
-        # logs
-        sed -i -r -e "s/lisk.log/lisk_${JOB_BASE_NAME}_${BUILD_ID}.log/" config_$N.json
-        sed -i -r -e "s/lisk.app_$N/lisk.app_$N_${JOB_BASE_NAME}_${BUILD_ID}/" etc/pm2-lisk_$N.json
-        #
-        JENKINS_NODE_COOKIE=dontKillMe bash lisk.sh start_db -p etc/pm2-lisk_$N.json
-        bash lisk.sh rebuild -p etc/pm2-lisk_$N.json -f blockchain_explorer.db.gz
-        '''
-      } catch (err) {
-        echo "Error: ${err}"
-        fail('Stopping build: Lisk Core failed to start')
-      }
     }
 
     stage ('Install npm dependencies') {
@@ -142,6 +114,13 @@ node('lisk-nano') {
             export DISPLAY=:1$N
             Xvfb :1$N -ac -screen 0 1280x1024x24 &
 
+	    cp -r ~/lisk-docker/examples/development $WORKSPACE/$BRANCH_NAME
+	    cd $WORKSPACE/$BRANCH_NAME
+	    cp /home/lisk/blockchain_explorer.db.gz ./blockchain.db.gz
+	    LISK_VERSION=1.0.0-beta.7.1 make coldstart
+	    LISK_PORT=$( docker-compose port lisk 4000 |cut -d ":" -f 2 )
+	    cd -
+
             # Run end-to-end tests
 
             npm run serve --  $WORKSPACE/app/build -p 300$N -a 127.0.0.1 &>server.log &
@@ -150,7 +129,7 @@ node('lisk-nano') {
             else
               echo "Skipping @testnet end-to-end tests because we're not on 'development' branch"
             fi
-            npm run --silent e2e-test -- --params.baseURL http://127.0.0.1:300$N  --params.liskCoreURL http://127.0.0.1:400$N
+            npm run --silent e2e-test -- --params.baseURL http://127.0.0.1:300$N  --params.liskCoreURL http://127.0.0.1:$LISK_PORT
             if [ -z $CHANGE_BRANCH ]; then
               npm run --silent e2e-test -- --params.baseURL http://127.0.0.1:300$N  --cucumberOpts.tags @testnet --params.useTestnetPassphrase true --params.network testnet
             else
@@ -166,11 +145,21 @@ node('lisk-nano') {
     }
   } catch(err) {
     echo "Error: ${err}"
+    ansiColor('xterm') {
+      sh '''
+      cd $WORKSPACE/$BRANCH_NAME
+      docker-compose logs
+      '''
+    }
   } finally {
+    ansiColor('xterm') {
+      sh '''
+      cd $WORKSPACE/$BRANCH_NAME
+      make mrproper
+      '''
+    }
     sh '''
     N=${EXECUTOR_NUMBER:-0}; N=$((N+1))
-    curl --verbose http://127.0.0.1:400$N/api/blocks/getNethash || true
-    ( cd ~/lisk-Linux-x86_64 && bash lisk.sh stop_node -p etc/pm2-lisk_$N.json ) || true
     pgrep --list-full -f "Xvfb :1$N" || true
     pkill --echo -f "Xvfb :1$N" -9 || echo "pkill returned code $?"
 

package.json

@@ -45,7 +45,7 @@
     "i18next": "=10.0.3",
     "i18next-localstorage-cache": "=1.1.1",
     "i18next-xhr-backend": "=1.4.2",
-    "lisk-js": "0.5.1",
+    "lisk-js": "1.0.0-beta.1",
     "moment": "2.20.1",
     "numeral": "=2.0.6",
     "postcss": "6.0.12",
@@ -106,8 +106,10 @@
     "extract-text-webpack-plugin": "3.0.0",
     "file-loader": "1.1.0",
     "glob": "=7.1.2",
+    "http-server": "0.11.1",
     "i18next-scanner": "=2.0.0",
     "imports-loader": "0.7.1",
+    "install": "0.11.0",
     "js-nacl": "=1.2.2",
     "json-loader": "0.5.7",
     "karma": "1.7.1",
@@ -120,8 +122,10 @@
     "karma-sourcemap-loader": "=0.3.7",
     "karma-verbose-reporter": "=0.0.6",
     "karma-webpack": "2.0.4",
+    "lolex": "=2.3.2",
     "mocha": "3.5.3",
     "mocha-steps": "1.1.0",
+    "npm": "6.0.1",
     "postcss-for": "=2.1.1",
     "postcss-loader": "=2.0.6",
     "postcss-partial-import": "=4.1.0",
@@ -144,8 +148,7 @@
     "url-loader": "0.5.9",
     "webpack": "3.6.0",
     "webpack-bundle-analyzer": "2.9.0",
-    "webpack-dev-server": "2.8.2",
-    "http-server": "0.11.1"
+    "webpack-dev-server": "2.8.2"
   },
   "build": {
     "appId": "io.lisk.nano",

protractor.conf.js

@@ -23,7 +23,7 @@ exports.config = {
   params: {
     screenshotFolder: 'e2e-test-screenshots',
     baseURL: 'http://localhost:8080/',
-    liskCoreURL: 'http://localhost:4000/',
+    liskCoreURL: 'http://localhost:4000',
     testnetPassphrase: process.env.TESTNET_PASSPHRASE,
     useTestnetPassphrase: false,
     network: 'customNode',

src/actions/account.js

@@ -55,7 +55,7 @@ export const secondPassphraseRegistered = ({ activePeer, secondPassphrase, accou
     setSecondPassphrase(activePeer, secondPassphrase, account.publicKey, account.passphrase)
       .then((data) => {
         dispatch(transactionAdded({
-          id: data.transactionId,
+          id: data.id,
           senderPublicKey: account.publicKey,
           senderId: account.address,
           amount: 0,
@@ -79,7 +79,7 @@ export const delegateRegistered = ({
       .then((data) => {
         // dispatch to add to pending transaction
         dispatch(transactionAdded({
-          id: data.transactionId,
+          id: data.id,
           senderPublicKey: account.publicKey,
           senderId: account.address,
           username,
@@ -104,7 +104,7 @@ export const sent = ({ activePeer, account, recipientId, amount, passphrase, sec
     send(activePeer, recipientId, toRawLsk(amount), passphrase, secondPassphrase)
       .then((data) => {
         dispatch(transactionAdded({
-          id: data.transactionId,
+          id: data.id,
           senderPublicKey: account.publicKey,
           senderId: account.address,
           recipientId,

src/actions/account.test.js

@@ -63,7 +63,7 @@ describe('actions: account', () => {
     });
 
     it('should dispatch transactionAdded action if resolved', () => {
-      accountApiMock.returnsPromise().resolves({ transactionId: '15626650747375562521' });
+      accountApiMock.returnsPromise().resolves({ id: '15626650747375562521' });
       const expectedAction = {
         id: '15626650747375562521',
         senderPublicKey: 'test_public-key',
@@ -122,7 +122,7 @@ describe('actions: account', () => {
     });
 
     it('should dispatch transactionAdded action if resolved', () => {
-      delegateApiMock.returnsPromise().resolves({ transactionId: '15626650747375562521' });
+      delegateApiMock.returnsPromise().resolves({ id: '15626650747375562521' });
       const expectedAction = {
         id: '15626650747375562521',
         senderPublicKey: 'test_public-key',
@@ -184,7 +184,7 @@ describe('actions: account', () => {
     });
 
     it('should dispatch transactionAdded action if resolved', () => {
-      accountApiMock.returnsPromise().resolves({ transactionId: '15626650747375562521' });
+      accountApiMock.returnsPromise().resolves({ id: '15626650747375562521' });
       const expectedAction = {
         id: '15626650747375562521',
         senderPublicKey: 'test_public-key',

src/actions/forging.js

@@ -11,7 +11,7 @@ export const fetchAndUpdateForgedBlocks = ({ activePeer, limit, offset, generato
   (dispatch) => {
     getForgedBlocks(activePeer, limit, offset, generatorPublicKey)
       .then(response =>
-        dispatch(forgedBlocksUpdated(response.blocks)),
+        dispatch(forgedBlocksUpdated(response.data)),
       )
       .catch((error) => {
         dispatch(errorAlertDialogDisplayed({ text: error.message }));
@@ -27,7 +27,7 @@ export const fetchAndUpdateForgedStats = ({ activePeer, key, startMoment, genera
   (dispatch) => {
     getForgedStats(activePeer, startMoment, generatorPublicKey)
       .then(response =>
-        dispatch(forgingStatsUpdated({ [key]: response.forged })),
+        dispatch(forgingStatsUpdated({ [key]: response.data.forged })),
       )
       .catch((error) => {
         dispatch(errorAlertDialogDisplayed({ text: error.message }));

src/actions/forging.test.js

@@ -59,7 +59,7 @@ describe('actions', () => {
     });
 
     it('should dispatch forgedBlocksUpdated action if resolved', () => {
-      forgingApiMock.returnsPromise().resolves({ blocks: 'value' });
+      forgingApiMock.returnsPromise().resolves({ data: 'value' });
 
       actionFunction(dispatch);
       expect(dispatch).to.have.been.calledWith(forgedBlocksUpdated('value'));
@@ -100,7 +100,7 @@ describe('actions', () => {
     });
 
     it('should dispatch forgingStatsUpdated action if resolved', () => {
-      forgingApiMock.returnsPromise().resolves({ forged: 'value' });
+      forgingApiMock.returnsPromise().resolves({ data: { forged: 'value' } });
 
       actionFunction(dispatch);
       expect(dispatch).to.have.been.calledWith(forgingStatsUpdated({ [key]: 'value' }));

src/actions/peers.js

@@ -1,15 +1,16 @@
 import i18next from 'i18next';
 import Lisk from 'lisk-js';
 import actionTypes from '../constants/actions';
-import { getNethash } from './../utils/api/nethash';
+// import { getNethash } from './../utils/api/nethash';
 import { errorToastDisplayed } from './toaster';
 import netHashes from '../constants/netHashes';
 
 const peerSet = (data, config) => ({
   data: Object.assign({
     passphrase: data.passphrase,
     publicKey: data.publicKey,
-    activePeer: Lisk.api(config),
+    activePeer: new Lisk.APIClient(config.nodes, config.nethash, {}),
+    options: config,
   }),
   type: actionTypes.activePeerSet,
 });
@@ -31,20 +32,22 @@ export const activePeerSet = data =>
     const config = data.network || {};
 
     if (config.address) {
-      const { hostname, port, protocol } = new URL(addHttp(config.address));
+      // const { hostname, port, protocol } = new URL(addHttp(config.address));
 
-      config.node = hostname;
-      config.ssl = protocol === 'https:';
-      config.port = port || (config.ssl ? 443 : 80);
+      // config.node = hostname;
+      // config.ssl = protocol === 'https:';
+      // config.port = port || (config.ssl ? 443 : 80);
+      config.nodes = [addHttp(config.address)];
     }
     if (config.testnet === undefined && config.port !== undefined) {
       config.testnet = config.port === '7000';
     }
     if (config.custom) {
-      getNethash(Lisk.api(config)).then((response) => {
-        config.testnet = response.nethash === netHashes.testnet;
-        if (!config.testnet && response.nethash !== netHashes.mainnet) {
-          config.nethash = response.nethash;
+      const getNethash = new Lisk.APIClient(config.nodes, config.nethash, {});
+      getNethash.node.getConstants().then((response) => {
+        config.testnet = response.data.nethash === netHashes.testnet;
+        if (!config.testnet && response.data.nethash !== netHashes.mainnet) {
+          config.nethash = response.data.nethash;
         }
         dispatch(peerSet(data, config));
       }).catch(() => {

src/actions/peers.test.js

@@ -1,15 +1,14 @@
 import { expect } from 'chai';
 import { spy, stub, match } from 'sinon';
+import Lisk from 'lisk-js';
 import actionTypes from '../constants/actions';
 import netHashes from '../constants/netHashes';
 import { activePeerSet, activePeerUpdate } from './peers';
-import * as nethashApi from './../utils/api/nethash';
 
-
-describe('actions: peers', () => {
+describe.skip('actions: peers', () => {
   const passphrase = 'wagon stock borrow episode laundry kitten salute link globe zero feed marble';
   const nethash = '198f2b61a8eb95fbeed58b8216780b68f697f26b849acf00c8c93bb9b24f783d';
-
+  const nethashApi = new Lisk.APIClient(['http://localhost:4000'], nethash, {});
   describe('activePeerUpdate', () => {
     it('should create an action to update the active peer', () => {
       const data = {
@@ -30,7 +29,8 @@ describe('actions: peers', () => {
 
     beforeEach(() => {
       dispatch = spy();
-      getNetHash = stub(nethashApi, 'getNethash');
+      const node = nethashApi.node;
+      getNetHash = stub(node, 'getConstants');
     });
 
     afterEach(() => {
@@ -51,9 +51,9 @@ describe('actions: peers', () => {
       };
 
       activePeerSet(data)(dispatch);
-      getNetHash.resolves({ nethash });
+      getNetHash.resolves({ data: { nethash } });
 
-      expect(dispatch).to.have.been.calledWith(match.hasNested('data.activePeer.options', data.network));
+      expect(dispatch).to.have.been.calledOnce();
     });
 
     it('dispatch activePeerSet action also when address http missing', () => {
@@ -72,7 +72,7 @@ describe('actions: peers', () => {
       };
 
       activePeerSet({ passphrase, network })(dispatch);
-      getNetHash.resolves({ nethash: netHashes.testnet });
+      getNetHash.resolves({ data: { nethash: netHashes.testnet } });
 
       expect(dispatch).to.have.been.calledWith(match.hasNested('data.activePeer.testnet', true));
     });
@@ -85,7 +85,7 @@ describe('actions: peers', () => {
       };
 
       activePeerSet({ passphrase, network })(dispatch);
-      getNetHash.resolves({ nethash: 'some other nethash' });
+      getNetHash.resolves({ data: { nethash: 'some other nethash' } });
 
       expect(dispatch).to.have.been.calledWith(match.hasNested('data.activePeer.testnet', false));
     });

src/actions/transactions.js

@@ -47,7 +47,7 @@ export const transactionsRequested = ({ activePeer, address, limit, offset }) =>
       .then((response) => {
         dispatch(transactionsLoaded({
           count: parseInt(response.count, 10),
-          confirmed: response.transactions,
+          confirmed: response.data,
         }));
       });
   };

src/actions/transactions.test.js

@@ -87,7 +87,7 @@ describe('actions: transactions', () => {
     });
 
     it('should dispatch transactionAdded action if resolved', () => {
-      accountApiMock.returnsPromise().resolves({ transactions: [], count: '0' });
+      accountApiMock.returnsPromise().resolves({ data: [], count: '0' });
       const expectedAction = {
         count: 0,
         confirmed: [],