fix: tests

Author: juanmahidalgo

src/ports/squids/component.ts

@@ -134,19 +134,19 @@ export async function createSubsquidComponent({
                   }
                   squid.metrics[networkName] = metrics
                 } else {
-                  logger?.error(`Failed to fetch metrics for network ${getSquidsNetworksMapping()[index].name}:`, result.reason)
+                  logger.error(`Failed to fetch metrics for network ${getSquidsNetworksMapping()[index].name}:`, result.reason)
                 }
               })
             } catch (error) {
-              logger?.error(`Failed to fetch metrics for ${ip}:`, { error: String(error) })
+              logger.error(`Failed to fetch metrics for ${ip}:`, { error: String(error) })
             }
           }
 
           // Only include complete squid objects
           if (squid.created_at && squid.health_status && squid.service_status) {
             return squid as Squid
           } else {
-            logger?.warn(`Skipping incomplete squid: ${squid.service_name}`)
+            logger.warn(`Skipping incomplete squid: ${squid.service_name}`)
             return null
           }
         })
@@ -155,7 +155,7 @@ export async function createSubsquidComponent({
       // Filter out null values
       return results.filter((squid): squid is Squid => squid !== null)
     } catch (error) {
-      logger?.error('Error listing services:', { error: String(error) })
+      logger.error('Error listing services:', { error: String(error) })
       return []
     }
   }
@@ -168,9 +168,9 @@ export async function createSubsquidComponent({
         desiredCount: 0
       })
       await client.send(updateServiceCommand)
-      logger?.info(`Service ${serviceName} stopped!`)
+      logger.info(`Service ${serviceName} stopped!`)
     } catch (error) {
-      logger?.error('Error stopping service:', { error: String(error), service: serviceName })
+      logger.error('Error stopping service:', { error: String(error), service: serviceName })
     }
   }
 
@@ -181,7 +181,7 @@ export async function createSubsquidComponent({
 
     // NOTE: in the future, depending on the project we might want to run the promote query in a different db
     await dappsDatabase.query(promoteQuery)
-    logger?.info(`The ${serviceName} was promoted and the active schema is ${schemaName}`)
+    logger.info(`The ${serviceName} was promoted and the active schema is ${schemaName}`)
 
     // Call marketplace server to recreate triggers and refresh materialized view for marketplace or trades squids
     if (serviceName.includes('marketplace-squid-server') || serviceName.includes('trades-squid-server')) {

test/unit/squid-controller.spec.ts

@@ -19,6 +19,13 @@ describe('createSubsquidComponent', () => {
     fetchMock = { fetch: jest.fn() } as IFetchComponent
     dappsDatabaseMock = { query: jest.fn() } as unknown as IPgComponent
     configMock = { requireString: jest.fn().mockResolvedValue('test-cluster') } as unknown as IConfigComponent
+    logsMock = {
+      getLogger: jest.fn().mockReturnValue({
+        info: jest.fn(),
+        error: jest.fn(),
+        warn: jest.fn()
+      })
+    } as unknown as ILoggerComponent
 
     ecsClientMock = new ECSClient({ region: 'us-east-1' })
     ;(ECSClient as jest.Mock).mockImplementation(() => ecsClientMock)