fix(in Progress): issues #589 #590 additionally added rabbitmq upload to the filebase exchange

Author: Params10

contracts/package.json

@@ -69,6 +69,8 @@
     "typescript": "^4.6.4"
   },
   "dependencies": {
-    "@kleros/vea-contracts": "^0.1.12"
+    "@kleros/vea-contracts": "^0.1.12",
+    "aws-sdk": "^2.1329.0",
+    "uuid": "^9.0.0"
   }
 }

contracts/scripts/policyUpdate.ts

@@ -0,0 +1,117 @@
+import { deployments, getNamedAccounts, getChainId, ethers } from "hardhat";
+import { PolicyRegistry } from "../typechain-types";
+import fs from "fs";
+const AWS = require("aws-sdk");
+const { v4: uuidv4 } = require("uuid");
+const id = uuidv4();
+const currentDate = new Date();
+const formattedDate = `${currentDate.getFullYear()}/${(currentDate.getMonth() + 1)
+  .toString()
+  .padStart(2, "0")}/${currentDate.getDate().toString().padStart(2, "0")}`;
+const S3_PATH = formattedDate + "/" + id + "/";
+
+const s3 = new AWS.S3({
+  endpoint: "https://s3.filebase.com",
+  region: "us-east-1",
+  signatureVersion: "v4",
+  accessKeyId: process.env.FILEBASE_ACCESS_KEY,
+  secretAccessKey: process.env.FILEBASE_SECRET_KEY,
+});
+enum HomeChains {
+  ARBITRUM_ONE = 42161,
+  ARBITRUM_RINKEBY = 421611,
+  ARBITRUM_GOERLI = 421613,
+  HARDHAT = 31337,
+}
+async function main(filePath: string) {
+  let courtsV1;
+  fs.readFile(filePath, "utf8", (err, jsonString) => {
+    if (err) {
+      console.log("File read failed:", err);
+      return;
+    }
+    const json = JSON.parse(jsonString);
+    courtsV1 = json.map((courtDetails) => ({
+      ...courtDetails,
+      name: courtDetails.name,
+      description: courtDetails.description,
+      summary: courtDetails.summary,
+      court: courtDetails.court,
+      uri: courtDetails.uri,
+    }));
+  });
+
+  // fallback to hardhat node signers on local network
+  // const governor = (await getNamedAccounts()).governor ?? (await ethers.getSigners())[0].address;
+  const governor = (await ethers.getSigners())[0];
+  const chainId = Number(await getChainId());
+  if (!HomeChains[chainId]) {
+    console.error(`Aborting: script is not compatible with ${chainId}`);
+    return;
+  } else {
+    console.log("deploying to %s with deployer %s", HomeChains[chainId], governor);
+  }
+
+  //--------uncomment once configuration is set in deployments------
+  // const policyRegistryDeployment = await deployments.get("PolicyRegistry");
+  const policyRegistry = (await ethers.getContractAt(
+    "PolicyRegistry",
+    "0xAF0F49Fe110b48bd512F00d51D141F023c9a9106" // arbitrumgoerli contract address
+    // policyRegistryDeployment.address
+  )) as PolicyRegistry;
+  for (const courtObject of courtsV1) {
+    var courtV2 = courtObject.court + 1;
+    var filename = courtObject.name.replace(" ", "-").concat(".json");
+    const data = { name: courtObject.name, description: courtObject.description, summary: courtObject.summary };
+    let response = await uploadFormDataToIPFS(data, filename);
+    console.log(response);
+
+    if (response && response.statusCode === 200) {
+      try {
+        console.log(courtV2, courtObject.name);
+        const data = await JSON.parse(response.body);
+        const cid = "/ipfs/" + data.message.Metadata.cid;
+        console.log(cid, "cid");
+        await policyRegistry.connect(governor).setPolicy(courtV2, courtObject.name, cid);
+      } catch (error) {
+        console.log(error);
+      }
+    }
+  }
+}
+
+const uploadFormDataToIPFS = async (data, filename) => {
+  try {
+    const params = {
+      Bucket: process.env.FILEBASE_BUCKET_NAME,
+      Key: S3_PATH + filename,
+      ContentType: "application/json",
+      Body: Buffer.from(JSON.stringify(data)),
+    };
+    const request = await s3.upload(params).promise();
+
+    const head_params = {
+      Bucket: process.env.FILEBASE_BUCKET_NAME,
+      Key: request.key,
+    };
+    const head = await s3.headObject(head_params).promise();
+
+    return {
+      statusCode: 200,
+      body: JSON.stringify({ message: head }),
+    };
+  } catch (error) {
+    console.log(error);
+
+    return {
+      statusCode: 500,
+      body: JSON.stringify({ message: error }),
+    };
+  }
+};
+main("./config/policies.v1.mainnet.json")
+  .then(() => process.exit(0))
+  .catch((error) => {
+    console.error(error);
+    process.exit(1);
+  });