Validate dirOath in FileMetadataRepository

blockchain-watcher/src/infrastructure/repositories/FileMetadataRepository.ts

@@ -9,9 +9,9 @@ export class FileMetadataRepository implements MetadataRepository<any>, Reposito
   private readonly dirPath: string;
   private readonly cfg: Config;
 
-  constructor(cfg: Config) {
+  constructor(cfg: Config, dirPath: string) {
     this.cfg = cfg;
-    this.dirPath = this.cfg!.metadata!.dir;
+    this.dirPath = dirPath;
 
     if (!fs.existsSync(this.dirPath)) {
       fs.mkdirSync(this.dirPath, { recursive: true });
@@ -27,7 +27,7 @@ export class FileMetadataRepository implements MetadataRepository<any>, Reposito
   }
 
   createInstance() {
-    return new FileMetadataRepository(this.cfg);
+    return new FileMetadataRepository(this.cfg, this.dirPath);
   }
 
   async get(id: string): Promise<any> {

blockchain-watcher/src/infrastructure/repositories/StaticJobRepository.ts

@@ -45,7 +45,7 @@ export class StaticJobRepository implements JobRepository {
       solanaSlotRepo: SolanaSlotRepository;
     }
   ) {
-    this.fileRepo = new FileMetadataRepository(cfg);
+    this.fileRepo = new FileMetadataRepository(cfg, cfg.jobs.dir);
     this.blockRepoProvider = blockRepoProvider;
     this.metadataRepo = repos.metadataRepo;
     this.statsRepo = repos.statsRepo;

blockchain-watcher/src/infrastructure/repositories/strategies/RepositoriesStrategy.ts

@@ -20,7 +20,7 @@ export class RepositoriesStrategy {
   executeStatic(): Map<string, any> {
     const repositories = [
       new SnsEventRepository(this.snsClient!, this.cfg),
-      new FileMetadataRepository(this.cfg),
+      new FileMetadataRepository(this.cfg, this.cfg.metadata?.dir!),
       new PromStatRepository(),
     ];
 

blockchain-watcher/test/infrastructure/repositories/FileMetadataRepo.test.ts

@@ -6,7 +6,7 @@ import { configMock } from "../../mock/configMock";
 describe("FileMetadataRepository", () => {
   const dirPath = "./metadata-repo";
   const cfg = configMock();
-  const repo = new FileMetadataRepository(cfg);
+  const repo = new FileMetadataRepository(cfg, dirPath);
 
   beforeEach(() => {
     if (!fs.existsSync(dirPath)) {