feat: deploying multiple messengers

Author: matiasbn

chainlinkUtils.ts

@@ -1,11 +1,6 @@
 import axios from 'axios';
 import { ChainlinkNodeConfiguration } from './types';
 
-const fs = require('fs');
-
-const appRoot = require('app-root-path');
-const dslaProtocolJsonPath = `${appRoot.path}/services/dsla-protocol.json`;
-
 let cookies = {};
 
 const getChainlinkSessionCookie = async (node: ChainlinkNodeConfiguration) => {
@@ -45,9 +40,11 @@ const getChainlinkAccounts = async (node: ChainlinkNodeConfiguration) => {
   return data;
 };
 
-const getChainlinkBridge = async (node: ChainlinkNodeConfiguration) => {
+const getChainlinkBridges = async (node: ChainlinkNodeConfiguration) => {
   const sessionCookie = await getChainlinkSessionCookie(node);
-  const { data } = await axios({
+  const {
+    data: { data },
+  } = await axios({
     method: 'get',
     url: `${node.restApiUrl}${
       node.restApiPort ? ':' + node.restApiPort : undefined
@@ -58,15 +55,14 @@ const getChainlinkBridge = async (node: ChainlinkNodeConfiguration) => {
     },
     withCredentials: true,
   });
-  const jobJson = JSON.parse(fs.readFileSync(dslaProtocolJsonPath));
-  return data.data.find(
-    (bridge) => bridge.attributes.name === jobJson.tasks[0].type
-  );
+  return data;
 };
 
-const getChainlinkJob = async (node: ChainlinkNodeConfiguration) => {
+const getChainlinkJobs = async (node: ChainlinkNodeConfiguration) => {
   const sessionCookie = await getChainlinkSessionCookie(node);
-  const { data } = await axios({
+  const {
+    data: { data },
+  } = await axios({
     method: 'get',
     url: `${node.restApiUrl}${
       node.restApiPort ? ':' + node.restApiPort : undefined
@@ -77,10 +73,7 @@ const getChainlinkJob = async (node: ChainlinkNodeConfiguration) => {
     },
     withCredentials: true,
   });
-  const jobJson = JSON.parse(fs.readFileSync(dslaProtocolJsonPath));
-  return data.data.find((job) =>
-    job.attributes.tasks.some((task) => task.type === jobJson.tasks[0].type)
-  );
+  return data;
 };
 
 const getChainlinkJobId = async (node: ChainlinkNodeConfiguration) => {
@@ -99,7 +92,11 @@ const getChainlinkJobId = async (node: ChainlinkNodeConfiguration) => {
   return `0x${data.data[0].id}`;
 };
 
-const postChainlinkJob = async (node: ChainlinkNodeConfiguration) => {
+const postChainlinkJob = async (
+  node: ChainlinkNodeConfiguration,
+  jobName,
+  oracleContractAddress
+) => {
   const sessionCookie = await getChainlinkSessionCookie(node);
   const { data } = await axios({
     method: 'post',
@@ -111,15 +108,41 @@ const postChainlinkJob = async (node: ChainlinkNodeConfiguration) => {
       'Content-Type': 'application/json',
     },
     // eslint-disable-next-line global-require,import/no-dynamic-require
-    data: require(dslaProtocolJsonPath),
+    data: {
+      initiators: [
+        {
+          type: 'RunLog',
+          params: {
+            address: oracleContractAddress,
+          },
+        },
+      ],
+      tasks: [
+        {
+          type: jobName,
+        },
+        {
+          type: 'copy',
+          params: {
+            copyPath: ['result'],
+          },
+        },
+        {
+          type: 'ethtx',
+        },
+      ],
+      minPayment: '10000000000',
+    },
     withCredentials: true,
   });
   return data;
 };
 
-const postChainlinkBridge = async (node: ChainlinkNodeConfiguration) => {
-  const jobJson = JSON.parse(fs.readFileSync(dslaProtocolJsonPath));
-
+const postChainlinkBridge = async (
+  node: ChainlinkNodeConfiguration,
+  useCaseName,
+  externalAdapterUrl
+) => {
   const sessionCookie = await getChainlinkSessionCookie(node);
   const { data } = await axios({
     method: 'post',
@@ -131,8 +154,8 @@ const postChainlinkBridge = async (node: ChainlinkNodeConfiguration) => {
       'Content-Type': 'application/json',
     },
     data: {
-      name: jobJson.tasks[0].type,
-      url: node.externalAdapterUrl,
+      name: useCaseName,
+      url: externalAdapterUrl,
     },
     withCredentials: true,
   });
@@ -159,9 +182,9 @@ export {
   deleteJob,
   postChainlinkJob,
   postChainlinkBridge,
-  getChainlinkJob,
+  getChainlinkJobs,
   getChainlinkJobId,
-  getChainlinkBridge,
+  getChainlinkBridges,
   getChainlinkAccounts,
   getChainlinkSessionCookie,
 };

constants.ts

@@ -51,6 +51,11 @@ export enum DEPLOYMENT_TAGS {
   Chainlink = 'chainlink',
   Services = 'services',
   Details = 'details',
+  Messengers = 'messengers',
+}
+
+export enum USE_CASES {
+  STAKING_EFFICIENCY = 'staking-efficiency',
 }
 
 export enum NETWORKS {

deploy/3_deploy_messengers.ts

@@ -0,0 +1,37 @@
+import { StackticalConfiguration } from '../types';
+import { CONTRACT_NAMES, DEPLOYMENT_TAGS } from '../constants';
+import { SUB_TASK_NAMES } from '../subtasks';
+
+module.exports = async ({ getNamedAccounts, deployments, network, run }) => {
+  const { stacktical }: { stacktical: StackticalConfiguration } =
+    network.config;
+  const { deployer } = await getNamedAccounts();
+  const { deploy, get } = deployments;
+  const stringUtils = await get(CONTRACT_NAMES.StringUtils);
+  const periodRegistry = await get(CONTRACT_NAMES.PeriodRegistry);
+  const linkToken = await get(CONTRACT_NAMES.LinkToken);
+
+  for (let messenger of stacktical.bootstrap.registry.messengers) {
+    const saId = await run(SUB_TASK_NAMES.SET_PRECOORDINATOR, {
+      useCaseName: messenger.useCaseName,
+    });
+    const preCoordinator = await get(CONTRACT_NAMES.PreCoordinator);
+    const feeMultiplier = stacktical.chainlink.nodesConfiguration.length;
+    await deploy(messenger.contract, {
+      from: deployer,
+      log: true,
+      args: [
+        preCoordinator.address,
+        linkToken.address,
+        saId,
+        feeMultiplier,
+        periodRegistry.address,
+      ],
+      libraries: {
+        StringUtils: stringUtils.address,
+      },
+    });
+  }
+};
+
+module.exports.tags = [DEPLOYMENT_TAGS.Messengers];