Log HTTP requests

Refs https://discordapp.com/channels/795981131316985866/1179003112107810837/1179147870985793576

package.json

@@ -23,6 +23,7 @@
   },
   "dependencies": {
     "@effect/platform": "^0.31.2",
+    "@effect/platform-node": "^0.32.3",
     "@effect/schema": "^0.49.4",
     "doi-ts": "^0.1.7",
     "effect": "^2.0.0-next.56",

src/index.ts

@@ -1,9 +1,35 @@
-import { HttpClient } from '@effect/platform'
-import { Effect, Layer } from 'effect'
+import { HttpClient } from '@effect/platform-node'
+import { Effect, Layer, LogLevel, Logger } from 'effect'
 import IoRedis from 'ioredis'
 import { program } from './Program.js'
 import * as Redis from './Redis.js'
 
+const HttpClientLive = Layer.succeed(
+  HttpClient.client.Client,
+  HttpClient.client.makeDefault(request =>
+    Effect.Do.pipe(
+      Effect.tap(() => Effect.logDebug('Sending HTTP Request').pipe(Effect.annotateLogs({ headers: request.headers }))),
+      Effect.zipRight(HttpClient.client.fetch()(request)),
+      Effect.tap(response =>
+        Effect.logDebug('Received HTTP response').pipe(
+          Effect.annotateLogs({ status: response.status, headers: response.headers }),
+        ),
+      ),
+      Effect.tapErrorTag('RequestError', error =>
+        Effect.logError('Error sending HTTP request').pipe(
+          Effect.annotateLogs({ reason: error.reason, error: error.error }),
+        ),
+      ),
+      Effect.annotateLogs({
+        url: request.url,
+        urlParams: HttpClient.urlParams.toString(request.urlParams),
+        method: request.method,
+      }),
+      Effect.withLogSpan('fetch'),
+    ),
+  ),
+)
+
 const RedisLive = Layer.effect(
   Redis.Redis,
   Effect.gen(function* (_) {
@@ -15,8 +41,8 @@ const RedisLive = Layer.effect(
   }),
 )
 
-const ProgramLive = Layer.mergeAll(HttpClient.client.layer, RedisLive)
+const ProgramLive = Layer.mergeAll(HttpClientLive, RedisLive)
 
-const runnable = Effect.provide(program, ProgramLive).pipe(Effect.scoped)
+const runnable = Effect.provide(program, ProgramLive).pipe(Effect.scoped, Logger.withMinimumLogLevel(LogLevel.Debug))
 
 await Effect.runPromise(runnable)