summaryrefslogtreecommitdiff
path: root/packages/taler-wallet-core/src/operations
diff options
context:
space:
mode:
authorFlorian Dold <florian@dold.me>2022-03-24 01:10:34 +0100
committerFlorian Dold <florian@dold.me>2022-03-24 01:10:41 +0100
commit9d38cb56a6fa4c9a975df339cb0aa08f040368c1 (patch)
treecc2fac95abe164b9da325de34a256f14ece9d9c9 /packages/taler-wallet-core/src/operations
parentcc18751e72435544297de4f5b5a6b318fbba9cd1 (diff)
downloadwallet-core-9d38cb56a6fa4c9a975df339cb0aa08f040368c1.tar.gz
wallet-core-9d38cb56a6fa4c9a975df339cb0aa08f040368c1.tar.bz2
wallet-core-9d38cb56a6fa4c9a975df339cb0aa08f040368c1.zip
wallet: crypto worker fixes, better taler-crypto-worker integration
Diffstat (limited to 'packages/taler-wallet-core/src/operations')
-rw-r--r--packages/taler-wallet-core/src/operations/refresh.ts17
1 files changed, 14 insertions, 3 deletions
diff --git a/packages/taler-wallet-core/src/operations/refresh.ts b/packages/taler-wallet-core/src/operations/refresh.ts
index a77738262..2ab06abae 100644
--- a/packages/taler-wallet-core/src/operations/refresh.ts
+++ b/packages/taler-wallet-core/src/operations/refresh.ts
@@ -797,11 +797,22 @@ async function processRefreshGroupImpl(
return;
}
// Process refresh sessions of the group in parallel.
+ logger.trace("processing refresh sessions for old coins");
const ps = refreshGroup.oldCoinPubs.map((x, i) =>
- processRefreshSession(ws, refreshGroupId, i),
+ processRefreshSession(ws, refreshGroupId, i).catch((x) => {
+ logger.warn("process refresh session got exception");
+ logger.warn(`exc ${x}`);
+ logger.warn(`exc stack ${x.stack}`);
+ }),
);
- await Promise.all(ps);
- logger.trace("refresh finished");
+ try {
+ logger.trace("waiting for refreshes");
+ await Promise.all(ps);
+ logger.trace("refresh finished");
+ } catch (e) {
+ logger.warn("process refresh sessions got exception");
+ logger.warn(`exception: ${e}`);
+ }
}
async function processRefreshSession(