chore: add-console-telemetry

Author: ryanbas21

e2e/mock-api-v2/package.json

@@ -7,15 +7,21 @@
   "main": "./src/main.js",
   "scripts": {
     "build": "pnpm nx nxBuild",
-    "dev": "pnpm nx build --watch & node dist/src/main.js --watch-path=./",
+    "dev": "node dist/src/main.js --watch-path=./",
     "lint": "pnpm nx nxLint",
     "serve": "node dist/src/main.js",
     "test": "pnpm nx nxTest"
   },
   "dependencies": {
     "@effect/language-service": "catalog:effect",
+    "@effect/opentelemetry": "0.53.1",
     "@effect/platform": "catalog:effect",
     "@effect/platform-node": "catalog:effect",
+    "@opentelemetry/sdk-logs": "0.202.0",
+    "@opentelemetry/sdk-metrics": "2.0.1",
+    "@opentelemetry/sdk-trace-base": "2.0.1",
+    "@opentelemetry/sdk-trace-node": "2.0.1",
+    "@opentelemetry/sdk-trace-web": "2.0.1",
     "effect": "catalog:effect",
     "nanoid": "5.1.5"
   },

e2e/mock-api-v2/src/handlers/authorize.handler.ts

@@ -18,7 +18,7 @@ const AuthorizeHandlerMock = HttpApiBuilder.group(MockApi, 'Authorization', (han
       const response = yield* handleAuthorize(urlParams);
 
       return response.body;
-    }),
+    }).pipe(Effect.withSpan('DavinciAuthorize')),
   ),
 );
 

e2e/mock-api-v2/src/handlers/healthcheck.handler.ts

@@ -3,7 +3,9 @@ import { MockApi } from '../spec.js';
 import { Effect } from 'effect';
 
 const HealthCheckLive = HttpApiBuilder.group(MockApi, 'Healthcheck', (handlers) =>
-  handlers.handle('HealthCheck', () => Effect.succeed('Healthy')),
+  handlers.handle('HealthCheck', () =>
+    Effect.succeed('Healthy').pipe(Effect.withSpan('HealthCheck')),
+  ),
 );
 
 export { HealthCheckLive };

e2e/mock-api-v2/src/handlers/open-id-configuration.handler.ts

@@ -19,7 +19,7 @@ import { HttpApiBuilder } from '@effect/platform';
 const OpenidConfigMock = HttpApiBuilder.group(MockApi, 'OpenIDConfig', (handlers) =>
   handlers.handle(
     'openid',
-    Effect.fn(function* () {
+    Effect.fn('OpenId')(function* () {
       const value = yield* Effect.succeed(openidConfigurationResponse);
       return value;
     }),

e2e/mock-api-v2/src/handlers/token.handler.ts

@@ -16,7 +16,7 @@ const TokensHandler = HttpApiBuilder.group(MockApi, 'Tokens', (handlers) =>
       const tokens = yield* getTokens(null);
 
       return tokens;
-    }),
+    }).pipe(Effect.withSpan('TokensHandler')),
   ),
 );
 

e2e/mock-api-v2/src/handlers/userinfo.handler.ts

@@ -22,7 +22,7 @@ const UserInfoMockHandler = HttpApiBuilder.group(MockApi, 'Protected Requests',
       const response = yield* getUserInfo(authToken);
 
       return response;
-    }),
+    }).pipe(Effect.withSpan('UserInfoHandler')),
   ),
 );
 

e2e/mock-api-v2/src/main.ts

@@ -21,6 +21,13 @@ import { UserInfoMockService } from './services/userinfo.service.js';
 import { AuthorizationMock } from './middleware/Authorization.js';
 import { SessionMiddlewareMock } from './middleware/Session.js';
 import { SessionStorage } from './services/session.service.js';
+import { NodeSdk } from '@effect/opentelemetry';
+import { BatchSpanProcessor, ConsoleSpanExporter } from '@opentelemetry/sdk-trace-base';
+
+const NodeSdkLive = NodeSdk.layer(() => ({
+  resource: { serviceName: 'Mock-Api' },
+  spanProcessor: new BatchSpanProcessor(new ConsoleSpanExporter()),
+}));
 
 const APIMock = HttpApiBuilder.api(MockApi).pipe(
   Layer.provide(HealthCheckLive),
@@ -40,6 +47,7 @@ const ServerMock = HttpApiBuilder.serve(HttpMiddleware.logger).pipe(
   Layer.provide(SessionMiddlewareMock),
   Layer.provide(SessionStorage.Default),
   Layer.provide(AuthorizeMock),
+  Layer.provide(NodeSdkLive),
   Layer.provide(
     HttpApiBuilder.middlewareCors({
       allowedMethods: ['GET', 'PUT', 'POST', 'OPTIONS'],

e2e/mock-api-v2/src/services/session.service.ts

@@ -30,13 +30,13 @@ export class SessionStorage extends Effect.Service<SessionStorage>()('SessionSto
     };
 
     return {
-      createSession: (data: SessionData) => {
+      createSession: Effect.fn('CreateSessionMiddleware')(function* (data: SessionData) {
         const sessionId = nanoid();
         _store.set(sessionId, data);
-        return Effect.succeed(data);
-      },
+        return data;
+      }),
 
-      getSession: Effect.fn(function* (sessionId: string) {
+      getSession: Effect.fn('GetSessionMiddleware')(function* (sessionId: string) {
         const session = _store.get(sessionId);
 
         if (!session) {
@@ -52,20 +52,26 @@ export class SessionStorage extends Effect.Service<SessionStorage>()('SessionSto
         return session;
       }),
 
-      deleteSession: Effect.fn(function* (sessionId: string) {
+      deleteSession: Effect.fn('DeleteSessionMiddleware')(function* (sessionId: string) {
         _store.delete(sessionId);
         return undefined;
       }),
 
-      updateSession: Effect.fn(function* (sessionId: string, data: SessionData) {
+      updateSession: Effect.fn('UpdateSessionMiddleware')(function* (
+        sessionId: string,
+        data: SessionData,
+      ) {
         if (!_store.has(sessionId)) {
           return new Error('Session not found');
         }
         _store.set(sessionId, data);
         return data;
       }),
 
-      refreshSession: Effect.fn(function* (sessionId: string, expiryDate?: Date) {
+      refreshSession: Effect.fn('RefreshSessionMiddleware')(function* (
+        sessionId: string,
+        expiryDate?: Date,
+      ) {
         const session = _store.get(sessionId);
 
         if (!session) {
@@ -87,7 +93,7 @@ export class SessionStorage extends Effect.Service<SessionStorage>()('SessionSto
 
       isSessionExpired,
 
-      cleanupExpiredSessions: Effect.fn(function* () {
+      cleanupExpiredSessions: Effect.fn('CleanupExpiredSessionsMiddleware')(function* () {
         for (const [sessionId, session] of _store.entries()) {
           if (isSessionExpired(session)) {
             _store.delete(sessionId);