Skip to content

Commit

Permalink
test
Browse files Browse the repository at this point in the history
  • Loading branch information
thelostone-mc committed Sep 10, 2024
1 parent 235b80e commit 8914871
Showing 1 changed file with 12 additions and 12 deletions.
24 changes: 12 additions & 12 deletions src/database/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -124,8 +124,8 @@ export class Database {

// Acquire locks for all schemas
const chainDataLockId = generateLockId(this.chainDataSchemaName);
const ipfsDataLockId = generateLockId(this.ipfsDataSchemaName);
const priceDataLockId = generateLockId(this.priceDataSchemaName);
// const ipfsDataLockId = generateLockId(this.ipfsDataSchemaName);
// const priceDataLockId = generateLockId(this.priceDataSchemaName);

// Track acquired locks
const acquiredLocks: number[] = [];
Expand All @@ -140,16 +140,16 @@ export class Database {
// if (priceDataLockAcquired) acquiredLocks.push(priceDataLockId);

// NOTE: We are forcibly acquiring locks for IPFS and Price data schemas
await forciblyAcquireLockForSchema(priceDataLockId);
await forciblyAcquireLockForSchema(priceDataLockId);
acquiredLocks.push(ipfsDataLockId);
acquiredLocks.push(priceDataLockId);

// this.#logger.info(`Lock Status =>
// Chain Data (${chainDataLockId}): ${chainDataLockAcquired},
// IPFS Data (${ipfsDataLockId}): ${ipfsDataLockAcquired},
// Price Data (${priceDataLockId}): ${priceDataLockAcquired}
// `);
// await forciblyAcquireLockForSchema(ipfsDataLockId);
// await forciblyAcquireLockForSchema(priceDataLockId);
// acquiredLocks.push(ipfsDataLockId);
// acquiredLocks.push(priceDataLockId);

this.#logger.info(`Lock Status =>
Chain Data (${chainDataLockId}): ${chainDataLockAcquired}
`);
// IPFS Data (${ipfsDataLockId}): ${ipfsDataLockAcquired},
// Price Data (${priceDataLockId}): ${priceDataLockAcquired}

return {
release: async () => {
Expand Down

0 comments on commit 8914871

Please sign in to comment.