refactor: add contracts provider integration to pinner

packages/concordia-app/src/redux/sagas/orbitSaga.js

@@ -5,9 +5,9 @@ import {
 import { breezeActions } from '@ezerous/breeze';
 import { drizzleActions } from '@ezerous/drizzle';
 
-import { contracts } from 'concordia-contracts';
 import { EthereumContractIdentityProvider } from '@ezerous/eth-identity-provider';
 import { FORUM_CONTRACT } from 'concordia-shared/src/constants/contracts/ContractNames';
+import drizzleOptions from '../../options/drizzleOptions';
 
 function* initOrbitDatabases(action) {
   const { account, breeze } = action;
@@ -24,7 +24,7 @@ function* orbitSaga() {
 
   const { drizzle: { web3 } } = res[0];
   const networkId = yield call([web3.eth.net, web3.eth.net.getId]);
-  const contractAddress = contracts
+  const contractAddress = drizzleOptions.contracts
     .find((contract) => contract.contractName === FORUM_CONTRACT)
     .networks[networkId].address;
 

packages/concordia-pinner/package.json

@@ -32,6 +32,7 @@
     "orbit-db": "~0.26.0",
     "orbit-db-identity-provider": "~0.3.1",
     "rimraf": "~3.0.2",
+    "unirest": "^0.6.0",
     "web3": "~1.3.0",
     "web3-eth-contract": "^1.3.1",
     "wrtc": "~0.4.6"

packages/concordia-pinner/src/index.js

@@ -7,6 +7,7 @@ import getWeb3ProviderUrl from 'concordia-shared/src/utils/web3';
 import { createOrbitInstance, getPeerDatabases, openKVDBs } from './utils/orbitUtils';
 import ipfsOptions from './options/ipfsOptions';
 import startAPI from './app';
+import downloadContractArtifacts from './utils/drizzleUtils';
 
 process.on('unhandledRejection', (error) => {
   // This happens when attempting to initialize without any available Swarm addresses (e.g. Rendezvous)
@@ -21,16 +22,26 @@ process.on('unhandledRejection', (error) => {
 });
 
 const getDeployedContract = async (web3) => {
-  const forumContract = contracts.find((contract) => contract.contractName === FORUM_CONTRACT);
+  let forumContractPromise;
 
-  return web3.eth.net.getId()
-    .then((networkId) => forumContract.networks[networkId].address)
-    .then((contractAddress) => {
-      Contract.setProvider(getWeb3ProviderUrl());
-      const contract = new Contract(forumContract.abi, contractAddress);
+  if (process.env.USE_EXTERNAL_CONTRACTS_PROVIDER) {
+    console.log('Downloading contracts.');
+    forumContractPromise = downloadContractArtifacts()
+      .then((remoteContracts) => remoteContracts
+        .find((remoteContract) => remoteContract.contractName === FORUM_CONTRACT));
+  } else {
+    forumContractPromise = Promise.resolve(contracts.find((contract) => contract.contractName === FORUM_CONTRACT));
+  }
+
+  return forumContractPromise
+    .then((forumContract) => web3.eth.net.getId()
+      .then((networkId) => forumContract.networks[networkId].address)
+      .then((contractAddress) => {
+        Contract.setProvider(getWeb3ProviderUrl());
+        const contract = new Contract(forumContract.abi, contractAddress);
 
-      return { contract, contractAddress };
-    });
+        return { contract, contractAddress };
+      }));
 };
 
 // Open & replicate databases of existing users

packages/concordia-pinner/src/utils/drizzleUtils.js

@@ -0,0 +1,50 @@
+import unirest from 'unirest';
+import {
+  contractsProviderHost,
+  contractsProviderPort,
+  contractsVersionHash,
+} from 'concordia-shared/src/environment/interpolated/contractsProvider';
+import { pinnerApiHost, pinnerApiPort } from 'concordia-shared/src/environment/interpolated/pinner';
+import { FORUM_CONTRACT } from 'concordia-shared/src/constants/contracts/ContractNames';
+
+function getContractsDownloadRequest() {
+  const HOST = pinnerApiHost;
+  const PORT = pinnerApiPort;
+
+  return unirest(
+    'GET',
+    `http://${contractsProviderHost}:${contractsProviderPort}/contracts/${contractsVersionHash}`,
+  ).headers({
+    'Access-Control-Allow-Origin': `${HOST}:${PORT}`,
+    'Access-Control-Allow-Credentials': 'true',
+  });
+}
+
+const validateRemoteContracts = (remoteContracts) => {
+  if (!remoteContracts
+    .map((remoteContract) => remoteContract.contractName)
+    .includes(FORUM_CONTRACT)) {
+    throw new Error('Forum contract is missing from artifacts.');
+  }
+};
+
+const downloadContractArtifacts = () => {
+  const request = getContractsDownloadRequest();
+
+  return new Promise((resolve, reject) => request
+    .end((response) => {
+      if (response.error) {
+        reject(new Error(`Remote contract artifacts download request failed!\n${response.error}`));
+      }
+
+      resolve(response.raw_body);
+    })).then((contractsRawData) => {
+    const remoteContracts = JSON.parse(contractsRawData);
+
+    validateRemoteContracts(remoteContracts);
+
+    return remoteContracts;
+  });
+};
+
+export default downloadContractArtifacts;

packages/concordia-shared/src/constants/configuration/defaults.js

@@ -4,6 +4,7 @@ const CONTRACTS_PROVIDER_PORT_DEFAULT = '8400';
 const CONTRACTS_VERSION_HASH_DEFAULT = 'latest';
 
 // Pinner
+const PINNER_API_HOST_DEFAULT = '127.0.0.1';
 const PINNER_API_PORT_DEFAULT = 4444;
 
 // Rendezvous
@@ -25,6 +26,7 @@ module.exports = Object.freeze({
     hash: CONTRACTS_VERSION_HASH_DEFAULT,
   },
   pinner: {
+    host: PINNER_API_HOST_DEFAULT,
     port: PINNER_API_PORT_DEFAULT,
   },
   rendezvous: {

packages/concordia-shared/src/environment/interpolated/pinner.js

@@ -1,12 +1,15 @@
 const {
   pinner: {
+    host: PINNER_API_HOST_DEFAULT,
     port: PINNER_API_PORT_DEFAULT,
   },
 } = require('../../constants/configuration/defaults');
-const { pinnerApiPortEnv } = require('../pinnerEnv');
+const { pinnerApiHostEnv, pinnerApiPortEnv } = require('../pinnerEnv');
 
+const pinnerApiHost = pinnerApiHostEnv || PINNER_API_HOST_DEFAULT;
 const pinnerApiPort = pinnerApiPortEnv || PINNER_API_PORT_DEFAULT;
 
 module.exports = {
+  pinnerApiHost,
   pinnerApiPort,
 };

packages/concordia-shared/src/environment/pinnerEnv.js

@@ -1,7 +1,9 @@
 // Depending on the package user (app in contrast to any of the other packages) the env var names should either include
 // the REACT_APP_ prefix or not
+const pinnerApiHostEnv = process.env.REACT_APP_PINNER_API_HOST || process.env.PINNER_API_HOST;
 const pinnerApiPortEnv = process.env.REACT_APP_PINNER_API_PORT || process.env.PINNER_API_PORT;
 
 module.exports = {
+  pinnerApiHostEnv,
   pinnerApiPortEnv,
 };