feat: setup logger

Author: sosweetham

evault.docker-compose.yml

@@ -16,7 +16,7 @@ services:
       - W3ID=${W3ID}
     volumes:
       - secrets:/app/secrets
-    networks: 
+    networks:
       - graphnet
     depends_on:
       - neo4j
@@ -45,6 +45,13 @@ services:
       - neo4j_logs:/log
     networks:
       - graphnet
+  loki:
+    image: grafana/loki:latest
+    container_name: loki
+    networks:
+      - graphnet
+    ports:
+      - "3100:3100"
 
 volumes:
   neo4j_data:

infrastructure/web3-adapter/package.json

@@ -18,6 +18,8 @@
         "axios": "^1.6.7",
         "evault-core": "workspace:*",
         "graphql-request": "^6.1.0",
+        "pino": "^9.8.0",
+        "pino-loki": "^2.6.0",
         "sqlite3": "^5.1.7",
         "test": "^3.3.0",
         "uuid": "^11.1.0",
@@ -35,6 +37,8 @@
     "jest": {
         "preset": "ts-jest",
         "testEnvironment": "node",
-        "testMatch": ["**/__tests__/**/*.test.ts"]
+        "testMatch": [
+            "**/__tests__/**/*.test.ts"
+        ]
     }
 }

infrastructure/web3-adapter/src/index.ts

@@ -6,6 +6,7 @@ import { fromGlobal, toGlobal } from "./mapper/mapper";
 import type { IMapping } from "./mapper/mapper.types";
 import axios from "axios";
 import { v4 as uuidv4 } from "uuid";
+import { logger } from "./logging";
 
 /**
  * Standalone function to spin up an eVault
@@ -99,7 +100,7 @@ export async function createGroupEVault(
     try {
         // Step 1: Spin up the eVault
         const evault = await spinUpEVault(registryUrl, provisionerUrl, finalVerificationCode);
-        
+
         // Step 2: Create GroupManifest with exponential backoff
         const manifestId = await createGroupManifestWithRetry(
             registryUrl,
@@ -138,7 +139,7 @@ async function createGroupManifestWithRetry(
     maxRetries = 10
 ): Promise<string> {
     const now = new Date().toISOString();
-    
+
     const groupManifest: GroupManifest = {
         eName: w3id,
         name: groupData.name,
@@ -155,12 +156,12 @@ async function createGroupManifestWithRetry(
     for (let attempt = 1; attempt <= maxRetries; attempt++) {
         try {
             console.log(`Attempting to create GroupManifest in eVault (attempt ${attempt}/${maxRetries})`);
-            
+
             const response = await axios.get(
                 new URL(`resolve?w3id=${w3id}`, registryUrl).toString()
             );
             const endpoint = new URL("/graphql", response.data.uri).toString();
-            
+
             const { GraphQLClient } = await import("graphql-request");
             const client = new GraphQLClient(endpoint);
 
@@ -229,7 +230,7 @@ export class Web3Adapter {
             dbPath: string;
             registryUrl: string;
             platform: string;
-            provisionerUrl?: string; 
+            provisionerUrl?: string;
         },
     ) {
         this.readPaths();
@@ -277,6 +278,8 @@ export class Web3Adapter {
             data.id as string,
         );
 
+        logger.info(`Handling change for table ${tableName} with data: ${JSON.stringify(data)}`)
+
         if (!this.mapping[tableName]) return
         console.log("We get here?")
         // If we already have a mapping, use that global ID
@@ -375,7 +378,7 @@ export class Web3Adapter {
         provisionerUrl?: string
     ): Promise<{ w3id: string; uri: string }> {
         const finalProvisionerUrl = provisionerUrl || this.config.provisionerUrl;
-        
+
         if (!finalProvisionerUrl) {
             throw new Error("Provisioner URL is required. Please provide it in config or as parameter.");
         }
@@ -404,7 +407,7 @@ export class Web3Adapter {
         provisionerUrl?: string
     ): Promise<{ w3id: string; uri: string; manifestId: string }> {
         const finalProvisionerUrl = provisionerUrl || this.config.provisionerUrl;
-        
+
         if (!finalProvisionerUrl) {
             throw new Error("Provisioner URL is required. Please provide it in config or as parameter.");
         }

infrastructure/web3-adapter/src/logging/index.ts

@@ -0,0 +1,2 @@
+export * from "./transport";
+export * from "./logger";

infrastructure/web3-adapter/src/logging/logger.ts

@@ -0,0 +1,4 @@
+import pino from "pino";
+import { transport } from "./transport";
+
+export const logger = pino(transport)

infrastructure/web3-adapter/src/logging/transport.ts

@@ -0,0 +1,18 @@
+import {transport as pinoTransport} from "pino"
+import type { LokiOptions } from "pino-loki"
+
+export const transport = pinoTransport<LokiOptions>({
+    target: "pino-loki",
+    options: {
+        host: process.env.LOKI_URL || "http://loki:3100",
+        labels: {
+            app: "web3-adapter",
+        },
+        basicAuth:{
+            username: process.env.LOKI_USERNAME || "admin",
+            password: process.env.LOKI_PASSWORD || "admin"
+        }
+    }
+})
+
+