summaryrefslogtreecommitdiff
path: root/packages/taler-wallet-core/src/observable-wrappers.ts
diff options
context:
space:
mode:
Diffstat (limited to 'packages/taler-wallet-core/src/observable-wrappers.ts')
-rw-r--r--packages/taler-wallet-core/src/observable-wrappers.ts46
1 files changed, 4 insertions, 42 deletions
diff --git a/packages/taler-wallet-core/src/observable-wrappers.ts b/packages/taler-wallet-core/src/observable-wrappers.ts
index 5653f185e..5a8be9cf6 100644
--- a/packages/taler-wallet-core/src/observable-wrappers.ts
+++ b/packages/taler-wallet-core/src/observable-wrappers.ts
@@ -25,14 +25,8 @@ import { IDBDatabase } from "@gnu-taler/idb-bridge";
import {
ObservabilityContext,
ObservabilityEventType,
- RetryLoopOpts,
- getErrorDetailFromException,
+ RetryLoopOpts
} from "@gnu-taler/taler-util";
-import {
- HttpRequestLibrary,
- HttpRequestOptions,
- HttpResponse,
-} from "@gnu-taler/taler-util/http";
import { TaskIdStr } from "./common.js";
import { TalerCryptoInterface } from "./index.js";
import {
@@ -50,7 +44,7 @@ export class ObservableTaskScheduler implements TaskScheduler {
constructor(
private impl: TaskScheduler,
private oc: ObservabilityContext,
- ) {}
+ ) { }
private taskDepCache = new Set<string>();
@@ -70,7 +64,7 @@ export class ObservableTaskScheduler implements TaskScheduler {
getActiveTasks(): TaskIdStr[] {
return this.impl.getActiveTasks();
}
-
+
ensureRunning(): void {
return this.impl.ensureRunning();
}
@@ -110,38 +104,6 @@ export class ObservableTaskScheduler implements TaskScheduler {
}
}
-export class ObservableHttpClientLibrary implements HttpRequestLibrary {
- constructor(
- private impl: HttpRequestLibrary,
- private oc: ObservabilityContext,
- ) {}
- async fetch(
- url: string,
- opt?: HttpRequestOptions | undefined,
- ): Promise<HttpResponse> {
- this.oc.observe({
- type: ObservabilityEventType.HttpFetchStart,
- url: url,
- });
- try {
- const res = await this.impl.fetch(url, opt);
- this.oc.observe({
- type: ObservabilityEventType.HttpFetchFinishSuccess,
- url,
- status: res.status,
- });
- return res;
- } catch (e) {
- this.oc.observe({
- type: ObservabilityEventType.HttpFetchFinishError,
- url,
- error: getErrorDetailFromException(e),
- });
- throw e;
- }
- }
-}
-
const locRegex = /\s*at\s*([a-zA-Z0-9_.!]*)\s*/;
export function getCallerInfo(up: number = 2): string {
@@ -160,7 +122,7 @@ export class ObservableDbAccess<StoreMap> implements DbAccess<StoreMap> {
constructor(
private impl: DbAccess<StoreMap>,
private oc: ObservabilityContext,
- ) {}
+ ) { }
idbHandle(): IDBDatabase {
return this.impl.idbHandle();
}