[Xc admin] proposer server (#816)

* Proposer server

* Add package-lock.json

* Add rpc as enviornment variables

Author: guibescos

governance/xc_admin/packages/proposer_server/package.json

@@ -0,0 +1,30 @@
+{
+  "name": "proposer_server",
+  "version": "0.0.0",
+  "description": "A server that proposes the instructions that it receives to the multisig",
+  "private": "true",
+  "author": "",
+  "homepage": "https://github.com/pyth-network/pyth-crosschain",
+  "license": "ISC",
+  "main": "src/index.ts",
+  "repository": {
+    "type": "git",
+    "url": "git+https://github.com/pyth-network/pyth-crosschain.git"
+  },
+  "bugs": {
+    "url": "https://github.com/pyth-network/pyth-crosschain/issues"
+  },
+  "scripts": {
+    "build": "tsc",
+    "format": "prettier --write \"src/**/*.ts\""
+  },
+  "dependencies": {
+    "@coral-xyz/anchor": "^0.27.0",
+    "@pythnetwork/client": "^2.17.0",
+    "@solana/web3.js": "^1.76.0",
+    "@sqds/mesh": "^1.0.6",
+    "cors": "^2.8.5",
+    "ts-node": "^10.9.1",
+    "xc_admin_common": "*"
+  }
+}

governance/xc_admin/packages/proposer_server/src/index.ts

@@ -0,0 +1,89 @@
+import express, { Request, Response } from "express";
+import cors from "cors";
+import {
+  Cluster,
+  Connection,
+  Keypair,
+  PublicKey,
+  TransactionInstruction,
+} from "@solana/web3.js";
+import {
+  envOrErr,
+  getMultisigCluster,
+  isRemoteCluster,
+  PRICE_FEED_MULTISIG,
+  proposeInstructions,
+  WORMHOLE_ADDRESS,
+} from "xc_admin_common";
+import * as fs from "fs";
+import { getPythClusterApiUrl, PythCluster } from "@pythnetwork/client";
+import SquadsMesh from "@sqds/mesh";
+import NodeWallet from "@coral-xyz/anchor/dist/cjs/nodewallet";
+
+const PORT: number = Number(process.env.PORT ?? "3000");
+const KEYPAIR: Keypair = Keypair.fromSecretKey(
+  Uint8Array.from(JSON.parse(fs.readFileSync(envOrErr("WALLET"), "ascii")))
+);
+const MAINNET_RPC: string =
+  process.env.MAINNET_RPC ?? getPythClusterApiUrl("mainnet-beta");
+const DEVNET_RPC: string =
+  process.env.DEVNET_RPC ?? getPythClusterApiUrl("devnet");
+const TESTNET_RPC: string =
+  process.env.TESTNET_RPC ?? getPythClusterApiUrl("testnet");
+const LOCALNET_RPC: string =
+  process.env.LOCALNET_RPC ?? getPythClusterApiUrl("localnet");
+
+const RPC_URLS: Record<Cluster | "localnet", string> = {
+  "mainnet-beta": MAINNET_RPC,
+  devnet: DEVNET_RPC,
+  testnet: TESTNET_RPC,
+  localnet: LOCALNET_RPC,
+};
+
+const app = express();
+
+app.use(cors());
+app.use(express.json());
+
+app.post("/api/propose", async (req: Request, res: Response) => {
+  try {
+    const instructions: TransactionInstruction[] = req.body.instructions.map(
+      (ix: any) =>
+        new TransactionInstruction({
+          data: Buffer.from(ix.data),
+          programId: new PublicKey(ix.programId),
+          keys: ix.keys.map((key: any) => {
+            return {
+              isSigner: key.isSigner,
+              isWritable: key.isWritable,
+              pubkey: new PublicKey(key.pubkey),
+            };
+          }),
+        })
+    );
+
+    const cluster: PythCluster = req.body.cluster;
+
+    const proposeSquads: SquadsMesh = new SquadsMesh({
+      connection: new Connection(RPC_URLS[getMultisigCluster(cluster)]),
+      wallet: new NodeWallet(KEYPAIR),
+    });
+
+    const proposalPubkey = await proposeInstructions(
+      proposeSquads,
+      PRICE_FEED_MULTISIG[getMultisigCluster(cluster)],
+      instructions,
+      isRemoteCluster(cluster),
+      WORMHOLE_ADDRESS[getMultisigCluster(cluster)]
+    );
+    res.status(200).json({ proposalPubkey });
+  } catch (error) {
+    if (error instanceof Error) {
+      res.status(500).json(error.message);
+    } else {
+      res.status(500).json("An unknown error occurred");
+    }
+  }
+});
+
+app.listen(PORT);

governance/xc_admin/packages/proposer_server/tsconfig.json

@@ -0,0 +1,10 @@
+{
+  "extends": "../../../../tsconfig.base.json",
+  "include": ["src"],
+  "exclude": ["node_modules", "**/__tests__/*"],
+  "compilerOptions": {
+    "rootDir": "src/",
+    "outDir": "./lib",
+    "skipLibCheck": true
+  }
+}