[DRAFT] Migrate signer-service to Typescript

package.json

@@ -59,7 +59,7 @@
     "react-router-dom": "^6.8.1",
     "react-toastify": "^10.0.6",
     "stellar-base": "^11.0.1",
-    "stellar-sdk": "^11.3.0",
+    "stellar-sdk": "^13.1.0",
     "tailwind": "^4.0.0",
     "tailwindcss": "^3.4.3",
     "viem": "^2.21.43",

signer-service/.swcrc

@@ -0,0 +1,12 @@
+{
+  "jsc": {
+    "parser": {
+      "syntax": "typescript",
+      "tsx": false
+    },
+    "target": "es2020"
+  },
+  "module": {
+    "type": "commonjs"
+  }
+}

signer-service/package.json

@@ -10,13 +10,15 @@
     "yarn": "*"
   },
   "scripts": {
-    "precommit": "yarn lint-staged && yarn lint",
-    "start": "node ./src/index.js",
-    "dev": "nodemon ./src/index.js",
+    "type-check": "tsc --noEmit",
     "lint-staged": "prettier --write --ignore-unknown",
     "lint": "eslint ./src/ --ignore-path .gitignore --ignore-pattern internals/scripts",
     "lint:fix": "yarn lint --fix",
     "lint:watch": "yarn lint --watch",
+    "precommit": "yarn lint-staged && yarn lint",
+    "start": "node ./dist/index.js",
+    "dev": "nodemon --watch ./src/index.ts --exec 'yarn build && yarn start'",
+    "build": "yarn type-check && swc src --out-dir dist --copy-files",
     "test": "vitest",
     "validate": "yarn lint && yarn test",
     "postpublish": "git push --tags"
@@ -43,19 +45,31 @@
     "mongoose": "^5.2.17",
     "morgan": "^1.8.1",
     "siwe": "^2.3.2",
-    "stellar-sdk": "^11.3.0",
+    "stellar-sdk": "^13.1.0",
     "viem": "^2.21.3",
     "winston": "^3.1.0"
   },
   "devDependencies": {
+    "@pendulum-chain/types": "^1.1.1",
+    "@stellar/stellar-sdk": "^13.1.0",
+    "@swc/cli": "^0.5.2",
+    "@swc/core": "^1.10.4",
+    "@types/body-parser": "^1.19.5",
+    "@types/compression": "^1.7.5",
+    "@types/cookie-parser": "^1.4.8",
+    "@types/cors": "^2.8.17",
+    "@types/express": "^5.0.0",
+    "@types/method-override": "^3.0.0",
+    "@types/morgan": "^1.9.9",
     "eslint": "^7.29.0",
     "eslint-config-airbnb-base": "^14.2.0",
     "eslint-config-prettier": "^8.8.0",
     "eslint-plugin-import": "^2.2.0",
     "husky": "^3.0.7",
     "mocha": "^6.2.2",
     "nodemon": "^2.0.1",
-    "prettier": "^2.8.7"
+    "prettier": "^2.8.7",
+    "typescript": "^5.7.2"
   },
   "packageManager": "yarn@4.4.1"
 }

signer-service/src/api/controllers/email.controller.ts

@@ -0,0 +1,26 @@
+import { Request, Response } from 'express';
+import { config } from '../../config/vars';
+import { storeDataInGoogleSpreadsheet } from './googleSpreadSheet.controller';
+
+const { spreadsheet } = config;
+
+const enum EmailSheetHeaders {
+  Timestamp = 'timestamp',
+  Email = 'email',
+  TransactionId = 'transactionId',
+}
+
+const EMAIL_SHEET_HEADER_VALUES = [
+  EmailSheetHeaders.Timestamp,
+  EmailSheetHeaders.Email,
+  EmailSheetHeaders.TransactionId,
+];
+
+export { EMAIL_SHEET_HEADER_VALUES };
+
+export const storeEmail = async (req: Request, res: Response): Promise<void> => {
+  if (!spreadsheet.emailSheetId) {
+    throw new Error('Email sheet ID is not configured');
+  }
+  await storeDataInGoogleSpreadsheet(req, res, spreadsheet.emailSheetId, EMAIL_SHEET_HEADER_VALUES);
+};

signer-service/src/api/controllers/googleSpreadSheet.controller.ts

@@ -0,0 +1,54 @@
+import 'dotenv/config';
+import { Request, Response } from 'express';
+import { config } from '../../config/vars';
+import { initGoogleSpreadsheet, getOrCreateSheet, appendData } from '../services/spreadsheet.service';
+import { APIError } from '../errors/api-error';
+import { GoogleCredentials } from '../services/spreadsheet.service';
+
+type SheetHeaderValues = readonly string[];
+
+interface SpreadsheetResponse {
+  message: string;
+}
+
+interface SpreadsheetErrorResponse {
+  error: string;
+  details?: string;
+}
+
+export async function storeDataInGoogleSpreadsheet(
+  req: Request,
+  res: Response,
+  spreadsheetId: string,
+  sheetHeaderValues: SheetHeaderValues,
+): Promise<Response<SpreadsheetResponse | SpreadsheetErrorResponse>> {
+  try {
+    // Ensure credentials are fully defined
+    const credentials: GoogleCredentials = {
+      email: config.spreadsheet.googleCredentials.email ?? '',
+      key: config.spreadsheet.googleCredentials.key ?? '',
+    };
+
+    const sheet = await initGoogleSpreadsheet(spreadsheetId, credentials).then((doc) =>
+      getOrCreateSheet(doc, [...sheetHeaderValues]),
+    );
+
+    if (!sheet) {
+      throw new APIError({
+        message: 'Failed to store data. Sheet unavailable.',
+        status: 500,
+        isPublic: true,
+      });
+    }
+
+    await appendData(sheet, req.body);
+    return res.status(200).json({ message: 'Data stored successfully' });
+  } catch (error) {
+    console.error('Error in storeData:', error);
+    const errorMessage = error instanceof Error ? error.message : 'Unknown error occurred';
+    return res.status(500).json({
+      error: 'Failed to store data',
+      details: errorMessage,
+    });
+  }
+}

signer-service/src/api/controllers/moonbeam.controller.ts

@@ -0,0 +1,103 @@
+import { createWalletClient, createPublicClient, http, encodeFunctionData, Hash, Address } from 'viem';
+import { moonbeam } from 'viem/chains';
+import { privateKeyToAccount } from 'viem/accounts';
+import Big from 'big.js';
+import { Request, Response } from 'express';
+
+import {
+  MOONBEAM_EXECUTOR_PRIVATE_KEY,
+  MOONBEAM_RECEIVER_CONTRACT_ADDRESS,
+  MOONBEAM_FUNDING_AMOUNT_UNITS,
+} from '../../constants/constants';
+import { SlackNotifier } from '../services/slack.service';
+// @ts-ignore
+import splitReceiverABI from '../../../../mooncontracts/splitReceiverABI.json';
+
+interface XcmPayload {
+  id: string;
+  payload: string;
+}
+
+interface StatusResponse {
+  status: boolean;
+  public: Address | undefined;
+}
+
+const createClients = (executorAccount: ReturnType<typeof privateKeyToAccount>) => {
+  const walletClient = createWalletClient({
+    account: executorAccount,
+    chain: moonbeam,
+    transport: http(),
+  });
+
+  const publicClient = createPublicClient({
+    chain: moonbeam,
+    transport: http(),
+  });
+
+  return { walletClient, publicClient };
+};
+
+export const executeXcmController = async (req: Request<{}, {}, XcmPayload>, res: Response) => {
+  const { id, payload } = req.body;
+
+  try {
+    if (!MOONBEAM_EXECUTOR_PRIVATE_KEY) {
+      throw new Error('Moonbeam executor private key not configured');
+    }
+    const moonbeamExecutorAccount = privateKeyToAccount(MOONBEAM_EXECUTOR_PRIVATE_KEY as `0x${string}`);
+    const { walletClient, publicClient } = createClients(moonbeamExecutorAccount);
+
+    const data = encodeFunctionData({
+      abi: splitReceiverABI,
+      functionName: 'executeXCM',
+      args: [id, payload],
+    });
+
+    try {
+      const { maxFeePerGas, maxPriorityFeePerGas } = await publicClient.estimateFeesPerGas();
+      const hash = await walletClient.sendTransaction({
+        to: MOONBEAM_RECEIVER_CONTRACT_ADDRESS,
+        value: 0n,
+        data,
+        maxFeePerGas,
+        maxPriorityFeePerGas,
+      });
+      return res.json({ hash });
+    } catch (error) {
+      console.error('Error executing XCM:', error);
+      return res.status(400).json({ error: 'Invalid transaction' });
+    }
+  } catch (error) {
+    console.error('Error executing XCM:', error);
+    return res.status(500).json({ error: 'Internal Server Error' });
+  }
+};
+
+export const sendStatusWithPk = async (): Promise<StatusResponse> => {
+  const slackService = new SlackNotifier();
+  let moonbeamExecutorAccount;
+
+  try {
+    if (!MOONBEAM_EXECUTOR_PRIVATE_KEY) {
+      throw new Error('Moonbeam executor private key not configured');
+    }
+    moonbeamExecutorAccount = privateKeyToAccount(MOONBEAM_EXECUTOR_PRIVATE_KEY as `0x${string}`);
+    const { publicClient } = createClients(moonbeamExecutorAccount);
+
+    const balance = await publicClient.getBalance({ address: moonbeamExecutorAccount.address });
+    const minimumBalance = BigInt(Big(MOONBEAM_FUNDING_AMOUNT_UNITS).times(Big(10).pow(18)).toString());
+
+    if (balance < minimumBalance) {
+      await slackService.sendMessage({
+        text: `Current balance of funding account is ${balance} GLMR please charge the account ${moonbeamExecutorAccount.address}.`,
+      });
+      return { status: false, public: moonbeamExecutorAccount.address };
+    }
+
+    return { status: true, public: moonbeamExecutorAccount.address };
+  } catch (error) {
+    console.error('Error fetching Moonbeam executor balance:', error);
+    return { status: false, public: moonbeamExecutorAccount?.address };
+  }
+};