Arbitrum / Chainlink

contracts/chainlink/Operator.sol

@@ -0,0 +1,4 @@
+// SPDX-License-Identifier: MIT
+pragma solidity ^0.7.0;
+
+import '@chainlink/contracts/src/v0.7/Operator.sol';

hardhat.config.ts

@@ -42,6 +42,15 @@ const config: HardhatUserConfig = {
           },
         },
       },
+      {
+        version: '^0.7.0',
+        settings: {
+          optimizer: {
+            enabled: true,
+            runs: 200,
+          },
+        },
+      },
       {
         version: '0.6.6',
         settings: {

services/chainlink-nodes/example-v2-job-spec.toml

@@ -0,0 +1,23 @@
+type = "directrequest"
+schemaVersion = 1
+name = "StakingParametricReq"
+forwardingAllowed = false
+maxTaskDuration = "0s"
+contractAddress = "0xFooBar"
+minContractPaymentLinkJuels = "0"
+observationSource = """
+    decode_log   [type=ethabidecodelog
+                  abi="OracleRequest(bytes32 indexed specId, address requester, bytes32 requestId, uint256 payment, address callbackAddr, bytes4 callbackFunctionId, uint256 cancelExpiration, uint256 dataVersion, bytes data)"
+                  data="$(jobRun.logData)"
+                  topics="$(jobRun.logTopics)"]
+    decode_cbor  [type=cborparse data="$(decode_log.data)"]
+    fetch        [type=bridge name="staking-parametric" requestData="{\\"id\\": $(jobSpec.externalJobID), \\"data\\": { \\"sla_monitoring_start\\": $(decode_cbor.sla_monitoring_start), \\"sla_monitoring_end\\": $(decode_cbor.sla_monitoring_end), \\"sla_address\\": $(decode_cbor.sla_address), \\"network_name\\": $(decode_cbor.network_name)}}"]
+    parse        [type=jsonparse path="data,result" data="$(fetch)"]
+    encode_data  [type=ethabiencode abi="(uint256 value)" data="{ \\"value\\": $(parse) }"]
+    encode_tx    [type=ethabiencode
+                  abi="fulfillOracleRequest(bytes32 requestId, uint256 payment, address callbackAddress, bytes4 callbackFunctionId, uint256 expiration, bytes32 data)"
+                  data="{\\"requestId\\": $(decode_log.requestId), \\"payment\\": $(decode_log.payment), \\"callbackAddress\\": $(decode_log.callbackAddr), \\"callbackFunctionId\\": $(decode_log.callbackFunctionId), \\"expiration\\": $(decode_log.cancelExpiration), \\"data\\": $(encode_data)}"
+                 ]
+    submit_tx    [type=ethtx to="0xFooBar" data="$(encode_tx)"]
+    decode_log -> decode_cbor -> fetch -> parse -> encode_data -> encode_tx -> submit_tx
+"""

subtasks.ts

@@ -1881,11 +1881,37 @@ subtask(SUB_TASK_NAMES.REQUEST_SLI, undefined).setAction(
     let tx;
     if (taskArgs.retry) {
       console.log('Retrying request...');
+
+      // const linkToken = await get(CONTRACT_NAMES.LinkToken);
+
+      // const token = await ERC20__factory.connect(linkToken.address, signer);
+
+      // let approval = await token.approve(
+      //   '0x834B065cf4Ac904E4bFfd983Ec2b2A6c8Af8AD7E',
+      //   toWei('10')
+      // );
+
+      // approval.wait();
+
       const messenger = IMessenger__factory.connect(
         await sla.messengerAddress(),
         await ethers.getSigner(deployer)
       );
-      tx = await messenger.retryRequest(slaAddress, nextVerifiablePeriod);
+
+      tx = await messenger.retryRequest(
+        sla.address,
+        Number(nextVerifiablePeriod),
+        {
+          ...(hre.network.config.gas !== 'auto' &&
+            hre.network.config.chainId != 137 && {
+              gasLimit: hre.network.config.gas,
+            }),
+          ...(hre.network.config.gas !== 'auto' &&
+            hre.network.config.chainId == 137 && {
+              gasPrice: hre.network.config.gas,
+            }),
+        }
+      );
     } else {
       console.log('Requesting SLI...');
       tx = await slaRegistry.requestSLI(