[Proxy colonies] Feat: create proxy chain block ingestor

.eslintrc.js

@@ -8,13 +8,19 @@ module.exports = {
   parserOptions: {
     ecmaVersion: 'latest',
     sourceType: 'module',
-    project: ['./tsconfig.json'],
+    project: [
+      './tsconfig.base.json',
+      './packages/*/tsconfig.json',
+      './apps/*/tsconfig.json'
+    ],
+    tsconfigRootDir: __dirname, 
   },
   rules: {
     semi: 'off',
     '@typescript-eslint/semi': ['error', 'always'],
     '@typescript-eslint/strict-boolean-expressions': 'off',
     '@typescript-eslint/restrict-template-expressions': 'off',
+    '@typescript-eslint/consistent-type-definitions': 'off',
     'comma-dangle': 'off',
     '@typescript-eslint/comma-dangle': ['error', 'always-multiline'],
     '@typescript-eslint/no-misused-promises': 'off',
@@ -25,6 +31,10 @@ module.exports = {
     'no-useless-return': 'off',
     '@typescript-eslint/member-delimiter-style': 'off',
     '@typescript-eslint/indent': 'off',
+    '@typescript-eslint/array-type': 'off',
+    '@typescript-eslint/prefer-nullish-coalescing': 'off',
+    '@typescript-eslint/prefer-optional-chain': 'off',
+    '@typescript-eslint/return-await': 'off',
     '@typescript-eslint/space-before-function-paren': [
       'error',
       {
@@ -34,5 +44,5 @@ module.exports = {
       },
     ],
   },
-  ignorePatterns: ['codegen.ts', 'src/graphql/generated.ts'],
+  ignorePatterns: ['packages/graphql/codegen.ts', 'packages/graphql/src/generated.ts'],
 };

.gitignore

@@ -70,6 +70,7 @@ typings/
 
 # dotenv environment variables file
 .env
+.env.proxy-2
 .env.test
 
 # parcel-bundler cache (https://parceljs.org/)
@@ -102,5 +103,3 @@ dist
 
 # TernJS port file
 .tern-port
-
-stats

Dockerfile

@@ -18,3 +18,10 @@ COPY --from=build /workspace /workspace
 WORKDIR /workspace/apps/main-chain
 CMD ["pnpm", "--filter", "@joincolony/main-chain", "prod"]
 
+# Proxy Chain Stage
+FROM base AS proxy-chain
+WORKDIR /workspace
+COPY --from=build /workspace /workspace
+WORKDIR /workspace/apps/proxy-chain
+CMD ["pnpm", "--filter", "@joincolony/proxy-chain", "prod"]
+

apps/main-chain/.env.example

@@ -1,2 +1,3 @@
 CHAIN_RPC_ENDPOINT=http://localhost:8545
 CHAIN_NETWORK_CONTRACT=0x777760996135F0791E2e1a74aFAa060711197777
+STATS_PORT=10001

apps/main-chain/package.json

@@ -1,16 +1,18 @@
 {
-    "name": "@joincolony/main-chain",
-    "version": "1.0.0",
-    "main": "src/index.ts",
-    "scripts": {
-      "build": "rm -rf dist/* && npx tsc",
-      "start": "node -r ts-node/register/transpile-only -r tsconfig-paths/register -r ./src/env.ts dist/index.js",
-      "dev": "NODE_ENV=development ts-node-dev -r tsconfig-paths/register -r ./src/env.ts src/index.ts",
-      "prod": "pnpm run build && NODE_ENV=production pnpm run start",
-      "typecheck": "tsc --noEmit"
-    },
-    "dependencies": {
-      "@joincolony/graphql": "workspace:*"
-    }
+  "name": "@joincolony/main-chain",
+  "version": "1.0.0",
+  "main": "src/index.ts",
+  "scripts": {
+    "build": "rm -rf dist/* && npx tsc",
+    "start": "node -r ts-node/register/transpile-only -r tsconfig-paths/register -r ./dist/env.js dist/index.js",
+    "dev": "NODE_ENV=development ts-node-dev -r tsconfig-paths/register -r ./src/env.ts src/index.ts",
+    "prod": "pnpm run build && NODE_ENV=production pnpm run start",
+    "typecheck": "tsc --noEmit"
+  },
+  "dependencies": {
+    "@joincolony/graphql": "workspace:*",
+    "@joincolony/clients": "workspace:*",
+    "@joincolony/blocks": "workspace:*",
+    "@joincolony/utils": "workspace:*"
   }
-  
+}

apps/main-chain/src/amplifyClient.ts

@@ -1,61 +1,8 @@
-import { Amplify, API, graphqlOperation } from 'aws-amplify';
-import { GraphQLQuery } from '@aws-amplify/api';
-import { DocumentNode, isExecutableDefinitionNode } from 'graphql';
-import { verbose } from '~utils';
+import { AmplifyClient } from '@joincolony/clients';
 
-export default (): void => {
-  Amplify.configure({
-    aws_appsync_graphqlEndpoint: `${process.env.AWS_APPSYNC_ENDPOINT}`,
-    aws_appsync_authenticationType: 'API_KEY',
-    aws_appsync_apiKey: process.env.AWS_APPSYNC_KEY,
-  });
-};
+const amplifyClient = new AmplifyClient(
+  process.env.AWS_APPSYNC_ENDPOINT || '',
+  process.env.AWS_APPSYNC_KEY || '',
+);
 
-export type GraphQLFnReturn<T> = Promise<
-  ReturnType<typeof API.graphql<GraphQLQuery<T>>> | undefined
->;
-
-export const query = async <T, TVariables extends Record<string, unknown>>(
-  queryDocument: DocumentNode,
-  variables?: TVariables,
-): GraphQLFnReturn<T> => {
-  try {
-    const result = await API.graphql<GraphQLQuery<T>>(
-      graphqlOperation(queryDocument, variables),
-    );
-
-    return result;
-  } catch (error) {
-    const definitionNode = queryDocument.definitions[0];
-    const queryName = isExecutableDefinitionNode(definitionNode)
-      ? definitionNode.name?.value
-      : 'Unknown';
-    console.error(`Could not fetch query ${queryName}`, error);
-    return undefined;
-  }
-};
-
-export const mutate = async <
-  T,
-  TVariables extends Record<string, unknown> = {},
->(
-  mutationDocument: DocumentNode,
-  variables?: TVariables,
-): GraphQLFnReturn<T> => {
-  try {
-    const result = await API.graphql<GraphQLQuery<T>>(
-      graphqlOperation(mutationDocument, variables),
-    );
-
-    return result;
-  } catch (error: any) {
-    const definitionNode = mutationDocument.definitions[0];
-    const mutationName = isExecutableDefinitionNode(definitionNode)
-      ? definitionNode.name?.value
-      : 'Unknown';
-
-    const errMsg = 'errors' in error ? error.errors : error;
-    verbose(`Could not execute mutation ${mutationName}. Error: `, errMsg);
-    return undefined;
-  }
-};
+export default amplifyClient;

apps/main-chain/src/blockManager.ts

@@ -0,0 +1,8 @@
+import { BlockManager } from '@joincolony/blocks';
+import eventManager from '~eventManager';
+import rpcProvider from '~provider';
+import statsManager from '~statsManager';
+
+const blockManager = new BlockManager(eventManager, rpcProvider, statsManager);
+
+export default blockManager;