diff options
Diffstat (limited to 'packages/taler-wallet-core/src/observable-wrappers.ts')
-rw-r--r-- | packages/taler-wallet-core/src/observable-wrappers.ts | 46 |
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(); } |