chore(cardano-services): avoid MISSING PREPARED STATEMENT log messages

input-output-hk · May 7, 2024 · c15f308 · c15f308
1 parent afea738
commit c15f308
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/packages/cardano-services/src/StakePool/DbSyncStakePoolProvider/StakePoolBuilder.ts b/packages/cardano-services/src/StakePool/DbSyncStakePoolProvider/StakePoolBuilder.ts
@@ -183,7 +183,10 @@ export class StakePoolBuilder {
 
   public async getLastEpoch() {
     this.#logger.debug('About to query last epoch');
-    const result: QueryResult<EpochModel> = await this.#db.query(Queries.findLastEpoch);
+    const result: QueryResult<EpochModel> = await this.#db.query({
+      name: 'current_epoch',
+      text: findLastEpoch
+    });
     const lastEpoch = result.rows[0];
     if (!lastEpoch) throw new ProviderError(ProviderFailure.Unknown, null, "Couldn't find last epoch");
     return lastEpoch.no;

diff --git a/packages/cardano-services/src/util/polling/DbSyncEpochPollService.ts b/packages/cardano-services/src/util/polling/DbSyncEpochPollService.ts
@@ -47,7 +47,10 @@ export class DbSyncEpochPollService implements EpochMonitor {
    * @returns {number} epoch number
    */
   async #queryLastEpoch() {
-    const result: QueryResult<EpochModel> = await this.#db.query(findLastEpoch);
+    const result: QueryResult<EpochModel> = await this.#db.query({
+      name: 'current_epoch',
+      text: findLastEpoch
+    });
     return Cardano.EpochNo(result.rows[0].no);
   }