+1 -14

src/modules/atproto/infrastructure/services/AtProtoJetstreamService.ts

View file Reviewed

··· 1 1 import WebSocket from 'ws'; 2 2 import { IFirehoseService } from '../../application/services/IFirehoseService'; 3 3 import { FirehoseEventHandler } from '../../application/handlers/FirehoseEventHandler'; 4 4 - import { 5 5 - Environment, 6 6 - EnvironmentConfigService, 7 7 - } from 'src/shared/infrastructure/config/EnvironmentConfigService'; 4 4 + import { EnvironmentConfigService } from 'src/shared/infrastructure/config/EnvironmentConfigService'; 8 5 import { FirehoseEvent } from '../../domain/FirehoseEvent'; 9 6 10 7 const DEBUG_LOGGING = true; // Set to false to disable debug logs ··· 261 258 262 259 private getFilteredCollections(): string[] { 263 260 const collections = this.configService.getAtProtoCollections(); 264 264 - const envConfig = new EnvironmentConfigService(); 265 261 266 266 - // skip margin records in prod env for now 267 267 - if (envConfig.get().environment === Environment.PROD) { 268 268 - return [ 269 269 - collections.card, 270 270 - collections.collection, 271 271 - collections.collectionLink, 272 272 - collections.collectionLinkRemoval, 273 273 - ]; 274 274 - } 275 262 return [ 276 263 collections.card, 277 264 collections.collection,

-5

src/modules/sync/application/useCases/SyncAccountDataUseCase.ts

View file Reviewed

··· 51 51 try { 52 52 const envConfig = new EnvironmentConfigService(); 53 53 54 54 - // skip syncs in prod env for now 55 55 - if (envConfig.get().environment === Environment.PROD) { 56 56 - return ok(undefined); 57 57 - } 58 58 - 59 54 console.log( 60 55 `[SYNC] SyncAccountDataUseCase triggered for curator: ${request.curatorId}, card: ${request.cardId}`, 61 56 );