Merge pull request #203 from proto-kit/feature/processor-2

Feature/processor-2

Author: maht0rz

package-lock.json

@@ -30,7 +30,7 @@ export abstract class SchemaGeneratingGraphqlModule<
 export abstract class ResolverFactoryGraphqlModule<
   Config = NoConfig,
 > extends GraphqlModule<Config> {
-  public abstract resolvers(): NonEmptyArray<Function>;
+  public abstract resolvers(): Promise<NonEmptyArray<Function>>;
 }
 
 export function graphqlModule() {

packages/api/src/graphql/GraphqlModule.ts

@@ -71,7 +71,8 @@ export class GraphqlSequencerModule<GraphQLModules extends GraphqlModulesRecord>
         const module = this.resolve(
           moduleName
         ) as ResolverFactoryGraphqlModule<unknown>;
-        this.graphqlServer.registerResolvers(module.resolvers());
+        // eslint-disable-next-line no-await-in-loop
+        this.graphqlServer.registerResolvers(await module.resolvers());
       } else {
         this.graphqlServer.registerModule(moduleClass);
 

packages/api/src/graphql/GraphqlSequencerModule.ts

@@ -440,7 +440,6 @@ export class ModuleContainer<
           throw errors.unableToDecorateModule(containedModuleName);
         }
         this.decorateModule(moduleName, containedModule);
-
         containedModule.create(() => {
           const container = this.container.createChildContainer();
           container.reset();

packages/common/src/config/ModuleContainer.ts

@@ -0,0 +1,8 @@
+/*
+  Warnings:
+
+  - Added the required column `events` to the `TransactionExecutionResult` table without a default value. This is not possible if the table is not empty.
+
+*/
+-- AlterTable
+ALTER TABLE "TransactionExecutionResult" ADD COLUMN     "events" JSON NOT NULL;

packages/indexer/prisma/migrations/20241018144754_events/migration.sql

@@ -53,6 +53,7 @@ model TransactionExecutionResult {
   protocolTransitions Json    @db.Json
   status              Boolean
   statusMessage       String?
+  events              Json    @db.Json
 
   tx     Transaction @relation(fields: [txHash], references: [hash])
   txHash String      @id

packages/indexer/prisma/schema.prisma

@@ -44,7 +44,7 @@ import {
   applyResolversEnhanceMap,
 } from "./generated/type-graphql";
 
-function cleanResolvers(resolvers: NonEmptyArray<Function>) {
+export function cleanResolvers(resolvers: NonEmptyArray<Function>) {
   return resolvers.map((resolver) => {
     const methods = Object.getOwnPropertyNames(resolver.prototype).map(
       (method) => method.toLowerCase()
@@ -85,10 +85,6 @@ export class GeneratedResolverFactoryGraphqlModule extends ResolverFactoryGraphq
     @inject("GraphqlServer") public graphqlServer: GraphqlServer
   ) {
     super();
-
-    this.graphqlServer.setContext({
-      prisma: this.initializePrismaClient(),
-    });
   }
 
   public async initializePrismaClient() {
@@ -102,7 +98,11 @@ export class GeneratedResolverFactoryGraphqlModule extends ResolverFactoryGraphq
     return prismaClient;
   }
 
-  public resolvers(): NonEmptyArray<Function> {
+  public async resolvers(): Promise<NonEmptyArray<Function>> {
+    this.graphqlServer.setContext({
+      prisma: await this.initializePrismaClient(),
+    });
+
     // basic way to limit the number of results returned at the argument level
     const resolversEnchanceMap: ResolversEnhanceMap = {
       Block: {

packages/indexer/src/api/GeneratedResolverFactoryGraphqlModule.ts

@@ -36,8 +36,9 @@ export class IndexBlockTask
       await this.blockStorage.pushResult(input.result);
     } catch (error) {
       log.error("Failed to index block", input.block.height.toBigInt(), error);
-      throw error;
+      return;
     }
+
     log.info(`Block ${input.block.height.toBigInt()} indexed sucessfully`);
   }
 

packages/indexer/src/tasks/IndexBlockTask.ts

@@ -0,0 +1 @@
+DATABASE_URL=postgresql://admin:password@localhost:5432/protokit?schema=public

packages/processor/.env

@@ -0,0 +1,4 @@
+{
+  "extends": "../../.eslintrc",
+  "ignorePatterns": ["src/api/generated/**"]
+}