Add initial bridge implementation (#1767)

Author: dguenther

.env.template

@@ -1,6 +1,9 @@
 API_URL=http://localhost:8003
 BLOCK_EXPLORER_URL=http://localhost:3000
 BLOCK_LOADER_TRANSACTION_TIMEOUT=5000
+CHAINPORT_API_URL=https://preprod-api.chainport.io/
+CHAINPORT_API_VERSION=2
+CHAINPORT_NETWORK_ID=22
 CORS_ENABLED=true
 DATABASE_CONNECTION_POOL_URL=postgres://postgres:password@localhost:5432/ironfish_api_development
 DATABASE_URL=postgres://postgres:password@localhost:5432/ironfish_api_development

.env.test

@@ -1,6 +1,9 @@
 API_URL=http://localhost:8003
 BLOCK_EXPLORER_URL=test
 BLOCK_LOADER_TRANSACTION_TIMEOUT=5000
+CHAINPORT_API_URL=https://preprod-api.chainport.io/
+CHAINPORT_API_VERSION=2
+CHAINPORT_NETWORK_ID=22
 CORS_ENABLED=true
 DATABASE_CONNECTION_POOL_URL=postgres://postgres:password@localhost:5432/ironfish_api_test
 DATABASE_URL=postgres://postgres:password@localhost:5432/ironfish_api_test

package.json

@@ -39,7 +39,7 @@
     "@types/compression": "1.7.5",
     "@types/express": "4.17.20",
     "@types/faker": "5.5.9",
-    "@types/jest": "27.5.0",
+    "@types/jest": "29.5.13",
     "@types/passport": "1.0.14",
     "@types/semver": "7.5.3",
     "@types/supertest": "2.0.15",
@@ -55,9 +55,9 @@
     "eslint-plugin-prettier": "4.2.1",
     "eslint-plugin-simple-import-sort": "10.0.0",
     "faker": "5.5.3",
-    "jest": "27.5.1",
+    "jest": "29.7.0",
     "prettier": "2.8.8",
-    "prisma": "5.13.0",
+    "prisma": "5.20.0",
     "run-script-webpack-plugin": "0.2.0",
     "supertest": "6.3.3",
     "ts-jest": "29.1.1",
@@ -70,18 +70,20 @@
   },
   "dependencies": {
     "@influxdata/influxdb-client": "1.33.2",
+    "@nestjs/axios": "3.0.3",
     "@nestjs/common": "8.4.7",
     "@nestjs/config": "3.1.1",
     "@nestjs/core": "8.4.7",
     "@nestjs/microservices": "8.4.7",
     "@nestjs/passport": "10.0.2",
     "@nestjs/platform-express": "8.4.7",
     "@nestjs/swagger": "5.2.1",
-    "@prisma/client": "5.13.0",
+    "@prisma/client": "5.20.0",
     "@sindresorhus/is": "4.6.0",
     "assert": "2.0.0",
+    "axios": "1.7.7",
     "class-transformer": "0.5.1",
-    "class-validator": "0.13.2",
+    "class-validator": "0.14.1",
     "cluster": "0.7.7",
     "compression": "1.7.4",
     "dd-trace": "4.16.0",

src/app.module.ts

@@ -17,6 +17,7 @@ import { AuthModule } from './auth/auth.module';
 import { BlocksRestModule } from './blocks/blocks.rest.module';
 import { BlocksDailyJobsModule } from './blocks-daily/blocks-daily.jobs.module';
 import { BlocksDailyRestModule } from './blocks-daily/blocks-daily.rest.module';
+import { BridgesRestModule } from './bridges/bridges.rest.module';
 import { RequireSslMiddleware } from './common/middlewares/require-ssl.middleware';
 import { DatadogModule } from './datadog/datadog.module';
 import { FaucetTransactionsRestModule } from './faucet-transactions/faucet-transactions.rest.module';
@@ -34,6 +35,7 @@ export const REST_MODULES = [
   AssetsRestModule,
   BlocksDailyRestModule,
   BlocksRestModule,
+  BridgesRestModule,
   FaucetTransactionsRestModule,
   HealthRestModule,
   SupplyRestModule,
@@ -52,6 +54,9 @@ export const REST_MODULES = [
         API_URL: joi.string().required(),
         BLOCK_EXPLORER_URL: joi.string().required(),
         BLOCK_LOADER_TRANSACTION_TIMEOUT: joi.number().optional(),
+        CHAINPORT_API_URL: joi.string().required(),
+        CHAINPORT_API_VERSION: joi.number().required(),
+        CHAINPORT_NETWORK_ID: joi.string().required(),
         CORS_ENABLED: joi.boolean().default(true),
         DATABASE_CONNECTION_POOL_URL: joi.string().required(),
         DATABASE_URL: joi.string().required(),

src/asset-descriptions/__snapshots__/asset-descriptions.controller.spec.ts.snap

@@ -1,10 +1,10 @@
 // Jest Snapshot v1, https://goo.gl/fbAQLP
 
 exports[`AssetDescriptionsController GET /asset_descriptions with an invalid query returns a 422 1`] = `
-Object {
+{
   "error": "Unprocessable Entity",
-  "message": Array [
-    "\\"asset\\" required to query for asset descriptions",
+  "message": [
+    ""asset" required to query for asset descriptions",
     "asset must be a string",
   ],
   "statusCode": 422,

src/assets/__snapshots__/assets.controller.spec.ts.snap

@@ -1,10 +1,10 @@
 // Jest Snapshot v1, https://goo.gl/fbAQLP
 
 exports[`AssetsController GET /assets/find with an invalid query returns a 422 1`] = `
-Object {
+{
   "error": "Unprocessable Entity",
-  "message": Array [
-    "\\"id\\" required to query for asset",
+  "message": [
+    ""id" required to query for asset",
     "id must be a string",
   ],
   "statusCode": 422,

src/blocks/__snapshots__/blocks.controller.spec.ts.snap

@@ -1,17 +1,17 @@
 // Jest Snapshot v1, https://goo.gl/fbAQLP
 
 exports[`BlocksController GET /blocks with invalid sequence_gte and sequence_lt parameters when sequence_gte > sequence_lt returns a 422 1`] = `
-Object {
+{
   "error": "Unprocessable Entity",
   "message": "'sequence_gte' must be strictly less than 'sequence_lt'.",
   "statusCode": 422,
 }
 `;
 
 exports[`BlocksController GET /blocks with invalid sequence_gte and sequence_lt parameters when sequence_gte and sequence_lt are not at least 1 returns a 422 1`] = `
-Object {
+{
   "error": "Unprocessable Entity",
-  "message": Array [
+  "message": [
     "sequence_gte must not be less than 1",
     "sequence_lt must not be less than 1",
   ],
@@ -20,27 +20,27 @@ Object {
 `;
 
 exports[`BlocksController GET /blocks with invalid sequence_gte and sequence_lt parameters when the range is too long returns a 422 1`] = `
-Object {
+{
   "error": "Unprocessable Entity",
   "message": "Range is too long. Max sequence difference is 1000.",
   "statusCode": 422,
 }
 `;
 
 exports[`BlocksController GET /blocks/find with neither a matching hash nor sequence returns a 404 1`] = `
-Object {
+{
   "message": "Not Found",
   "statusCode": 404,
 }
 `;
 
 exports[`BlocksController GET /blocks/find with neither a valid hash nor sequence returns a 422 1`] = `
-Object {
+{
   "error": "Unprocessable Entity",
-  "message": Array [
-    "\\"hash\\" or \\"sequence\\" required to query for single block",
+  "message": [
+    ""hash" or "sequence" required to query for single block",
     "hash must be a string",
-    "\\"hash\\" or \\"sequence\\" required to query for single block",
+    ""hash" or "sequence" required to query for single block",
     "sequence must be an integer number",
     "sequence must not be less than 1",
     "sequence must not be greater than 9007199254740991",
@@ -50,57 +50,57 @@ Object {
 `;
 
 exports[`BlocksController GET /blocks/metrics with a time range longer than the supported range returns a 422 1`] = `
-Object {
+{
   "error": "Unprocessable Entity",
   "message": "Time range too long",
   "statusCode": 422,
 }
 `;
 
 exports[`BlocksController GET /blocks/metrics with invalid granularity returns a 422 1`] = `
-Object {
+{
   "error": "Unprocessable Entity",
-  "message": "\\"granularity\\" must be \\"day\\"",
+  "message": ""granularity" must be "day"",
   "statusCode": 422,
 }
 `;
 
 exports[`BlocksController GET /blocks/metrics with missing arguments returns a 422 1`] = `
-Object {
+{
   "error": "Unprocessable Entity",
-  "message": Array [
+  "message": [
     "start must be a Date instance",
     "end must be a Date instance",
-    "granularity must be a valid enum value",
+    "granularity must be one of the following values: day, lifetime, total",
   ],
   "statusCode": 422,
 }
 `;
 
 exports[`BlocksController GET /blocks/metrics with start after end returns a 422 1`] = `
-Object {
+{
   "error": "Unprocessable Entity",
-  "message": "\\"start\\" must be stricly less than \\"end\\"",
+  "message": ""start" must be strictly less than "end"",
   "statusCode": 422,
 }
 `;
 
 exports[`BlocksController POST /blocks with a missing api key returns a 401 1`] = `
-Object {
+{
   "message": "Unauthorized",
   "statusCode": 401,
 }
 `;
 
 exports[`BlocksController POST /blocks with missing arguments returns a 422 1`] = `
-Object {
+{
   "error": "Unprocessable Entity",
-  "message": Array [
+  "message": [
     "blocks.0.hash must be a string",
     "blocks.0.sequence must be an integer number",
     "blocks.0.sequence must not be greater than 9007199254740991",
     "blocks.0.difficulty must be an integer number",
-    "blocks.0.type must be a valid enum value",
+    "blocks.0.type must be one of the following values: connected, disconnected, fork",
     "blocks.0.timestamp must be a Date instance",
     "blocks.0.graffiti must be a string",
     "blocks.0.size must be a positive number",
@@ -114,26 +114,26 @@ Object {
 `;
 
 exports[`BlocksController POST /blocks with too many blocks returns a 422 1`] = `
-Object {
+{
   "error": "Unprocessable Entity",
-  "message": Array [
-    "blocks must contain not more than 3000 elements",
+  "message": [
+    "blocks must contain no more than 3000 elements",
   ],
   "statusCode": 422,
 }
 `;
 
 exports[`BlocksController POST /blocks/disconnect with a missing api key returns a 401 1`] = `
-Object {
+{
   "message": "Unauthorized",
   "statusCode": 401,
 }
 `;
 
 exports[`BlocksController POST /blocks/disconnect with missing arguments returns a 422 1`] = `
-Object {
+{
   "error": "Unprocessable Entity",
-  "message": Array [
+  "message": [
     "sequence_gt must be an integer number",
     "sequence_gt must not be less than 1",
     "sequence_gt must not be greater than 9007199254740991",

src/blocks/blocks.controller.spec.ts

@@ -12,7 +12,7 @@ import { GraphileWorkerService } from '../graphile-worker/graphile-worker.servic
 import { PrismaService } from '../prisma/prisma.service';
 import { bootstrapTestApp } from '../test/test-app';
 import { BlocksService } from './blocks.service';
-import { UpsertBlocksDto } from './dto/upsert-blocks.dto';
+import { BlockDto, UpsertBlocksDto } from './dto/upsert-blocks.dto';
 import { BlockOperation } from './enums/block-operation';
 import { SerializedBlockWithTransactions } from './interfaces/serialized-block-with-transactions';
 
@@ -85,7 +85,7 @@ describe('BlocksController', () => {
 
     describe('with too many blocks', () => {
       it('returns a 422', async () => {
-        const blocks = [];
+        const blocks: BlockDto[] = [];
         for (let i = 0; i < 3001; i++) {
           blocks.push({
             hash: uuid(),
@@ -94,7 +94,6 @@ describe('BlocksController', () => {
             type: BlockOperation.CONNECTED,
             sequence: faker.datatype.number(),
             timestamp: new Date(),
-            transactions_count: 0,
             graffiti: uuid(),
             previous_block_hash: uuid(),
             size: faker.datatype.number({ min: 1 }),

src/blocks/blocks.controller.ts

@@ -319,7 +319,7 @@ export class BlocksController {
     if (start >= end) {
       return {
         isValid: false,
-        error: '"start" must be stricly less than "end"',
+        error: '"start" must be strictly less than "end"',
       };
     }