certusone
/
wormhole-explorer
mirror of https://github.com/certusone/wormhole-explorer.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Mapped dirPath in FileMetadataRepository class

This commit is contained in:
Julian Merlo 2023-11-28 16:03:52 -03:00
parent 050e117a16
commit 9fc087ae4a
3 changed files with 6 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
blockchain-watcher/src/infrastructure/repositories/FileMetadataRepository.ts
View File

@ -7,11 +7,9 @@ const UTF8 = "utf8";
export class FileMetadataRepository implements MetadataRepository<any>, StaticStrategy {
private readonly dirPath: string;
private readonly cfg: Config;
constructor(cfg: Config) {
this.cfg = cfg;
this.dirPath = this.cfg.metadata?.dir!;
constructor(dirPath: string) {
this.dirPath = dirPath;
if (!fs.existsSync(this.dirPath)) {
fs.mkdirSync(this.dirPath, { recursive: true });
@ -19,7 +17,7 @@ export class FileMetadataRepository implements MetadataRepository<any>, StaticSt
}
apply(): boolean {
return this.cfg.metadata?.dir != undefined;
return this.dirPath != undefined;
}
getName(): string {
@ -27,7 +25,7 @@ export class FileMetadataRepository implements MetadataRepository<any>, StaticSt
}
createInstance() {
return new FileMetadataRepository(this.cfg);
return new FileMetadataRepository(this.dirPath);
}
async get(id: string): Promise<any> {

2
blockchain-watcher/src/infrastructure/repositories/StaticJobRepository.ts
View File

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

2
blockchain-watcher/src/infrastructure/repositories/strategies/RepositoriesStrategy.ts
View File

@ -23,7 +23,7 @@ export class RepositoriesStrategy {
const repositories: StaticStrategy[] = [
new SnsEventRepository(this.snsClient!, this.cfg),
new FileMetadataRepository(this.cfg),
new FileMetadataRepository(this.cfg.metadata!.dir!),
new PromStatRepository(),
];