taler-typescript-core

commit 7a4815a2c1ba68bb1aa2fc221c2fc2bfeb2d3948
parent 082b84c455f4854183bba63a7ea0e6f4e8094862
Author: Florian Dold <florian@dold.me>
Date:   Mon, 20 Oct 2025 20:02:13 +0200

wallet-core: minor logging improvements

Diffstat:
M
packages/taler-wallet-core/src/deposits.ts
 | 
1
-
M
packages/taler-wallet-core/src/shepherd.ts
 | 
13
++-----------

2 files changed, 2 insertions(+), 12 deletions(-)
diff --git a/packages/taler-wallet-core/src/deposits.ts b/packages/taler-wallet-core/src/deposits.ts
@@ -848,7 +848,6 @@ async function refundDepositGroup(
   // before doing the refresh.
   const refundReqPerCoin: ExchangeRefundRequest[] = Array(newTxPerCoin.length);
 
-  logger.info(`status per coin: ${j2s(depositGroup.statusPerCoin)}`);
   for (let i = 0; i < statusPerCoin.length; i++) {
     const st = statusPerCoin[i];
     switch (st) {
diff --git a/packages/taler-wallet-core/src/shepherd.ts b/packages/taler-wallet-core/src/shepherd.ts
@@ -411,15 +411,13 @@ export class TaskSchedulerImpl implements TaskScheduler {
         logger.trace(`task ${taskId} cancelled, not processing result`);
         return;
       }
+      logger.trace(`Shepherd for ${taskId} got result ${res.type}`);
       wex.oc.observe({
         type: ObservabilityEventType.ShepherdTaskResult,
         resultType: res.type,
       });
       switch (res.type) {
         case TaskRunResultType.Error: {
-          logger.trace(
-            `Shepherd for ${taskId} got error result: ${j2s(res.errorDetail)}`,
-          );
           const retryRecord = await storePendingTaskError(
             this.ws,
             taskId,
@@ -427,12 +425,11 @@ export class TaskSchedulerImpl implements TaskScheduler {
           );
           const t = timestampAbsoluteFromDb(retryRecord.retryInfo.nextRetry);
           const delay = AbsoluteTime.remaining(t);
-          logger.trace(`Waiting for ${delay.d_ms} ms`);
+          logger.trace(`Stored error for ${taskId}, waiting for ${delay.d_ms} ms`);
           await this.wait(taskId, info, delay);
           break;
         }
         case TaskRunResultType.Backoff: {
-          logger.trace(`Shepherd for ${taskId} got backoff result.`);
           const retryRecord = await storePendingTaskPending(this.ws, taskId);
           const t = timestampAbsoluteFromDb(retryRecord.retryInfo.nextRetry);
           const delay = AbsoluteTime.remaining(t);
@@ -441,14 +438,10 @@ export class TaskSchedulerImpl implements TaskScheduler {
           break;
         }
         case TaskRunResultType.Progress: {
-          logger.trace(
-            `Shepherd for ${taskId} got progress result, re-running immediately.`,
-          );
           await storeTaskProgress(this.ws, taskId);
           break;
         }
         case TaskRunResultType.ScheduleLater: {
-          logger.trace(`Shepherd for ${taskId} got schedule-later result.`);
           const retryRecord = await storePendingTaskPending(
             this.ws,
             taskId,
@@ -461,7 +454,6 @@ export class TaskSchedulerImpl implements TaskScheduler {
           break;
         }
         case TaskRunResultType.Finished:
-          logger.trace(`Shepherd for ${taskId} got finished result.`);
           await storePendingTaskFinished(this.ws, taskId);
           return;
         case TaskRunResultType.LongpollReturnedPending: {
@@ -482,7 +474,6 @@ export class TaskSchedulerImpl implements TaskScheduler {
           break;
         }
         case TaskRunResultType.NetworkRequired: {
-          logger.trace(`Shepherd for ${taskId} got network-required result.`);
           await storePendingTaskPending(this.ws, taskId);
           const delay = Duration.getForever();
           logger.trace(`Not retrying task until network is restored.`);