wip: attempts to add a prisma transport for logger

Author: anthonydmays

lib/javascript/fullstack_demo/prisma/schema.prisma

@@ -18,3 +18,12 @@ model Todos {
   created_at DateTime @default(now()) @db.Timestamptz(6)
   updated_at DateTime @default(now()) @db.Timestamp(6)
 }
+
+/// This model contains row level security and requires additional setup for migrations. Visit https://pris.ly/d/row-level-security for more info.
+model Logs {
+  id        String   @id @default(dbgenerated("gen_random_uuid()")) @db.Uuid
+  level     String   @db.VarChar
+  message   String   @default("") @db.VarChar
+  timestamp DateTime @db.Timestamp(6)
+  meta      Json?    @db.Json
+}

lib/javascript/fullstack_demo/src/components/todo-list/todo-list.tsx

@@ -1,4 +1,6 @@
 import { Todo } from '@/models';
+import { logger } from '@/util/client-logger';
+import { LogEvent } from '@/util/events';
 import { TodoComponent } from './todo';
 
 export type TodoProps = {
@@ -8,6 +10,7 @@ export type TodoProps = {
 
 export const TodoList: React.FC<TodoProps> = ({ todos, onChange }) => {
   const toggleTodo = async (id: number) => {
+    logger.event(LogEvent.TODO_TOGGLE, { id });
     const todo = todos.find((todo) => todo.id === id);
     if (!todo) return;
     todo.completed = !todo.completed;
@@ -21,6 +24,7 @@ export const TodoList: React.FC<TodoProps> = ({ todos, onChange }) => {
   };
 
   const deleteTodo = async (id: number) => {
+    logger.event(LogEvent.TODO_DELETE, { id });
     await fetch(`/api/todos/${id}`, {
       method: 'DELETE',
     });

lib/javascript/fullstack_demo/src/logger.ts

@@ -1,4 +1,5 @@
 import { Log } from '@/models';
+import { LogEvent } from './events';
 import { Logger, LogLevel } from './logger';
 
 const FLUSH_AFTER_SIZE = 15;
@@ -13,7 +14,7 @@ class ClientLogger implements Logger {
     setInterval(() => this.flush(), FLUSH_INTERVAL_MS);
   }
 
-  log(level: LogLevel, message: string, vars?: {}): void {
+  log(level: LogLevel, message: string, vars = {}): void {
     vars = { ...this.getDefaultVars(), ...(vars || {}) };
     this.buffer.push({ level, message, vars });
     if (this.buffer.length >= FLUSH_AFTER_SIZE && !this.flushing) {
@@ -75,15 +76,18 @@ class ClientLogger implements Logger {
     return new Promise((resolve) => setTimeout(resolve, ms));
   }
 
-  debug(format: string, vars?: {}): void {
+  debug(format: string, vars = {}): void {
     this.log('debug', format, vars);
   }
-  info(format: string, vars?: {}): void {
+  info(format: string, vars = {}): void {
     this.log('info', format, vars);
   }
-  error(format: string, vars?: {}): void {
+  error(format: string, vars = {}): void {
     this.log('error', format, vars);
   }
+  event(eventId: LogEvent, vars = {}): void {
+    this.log('info', '', { ...vars, eventId });
+  }
 }
 
 export const logger = new ClientLogger();

lib/javascript/fullstack_demo/src/util/client-logger.ts

@@ -0,0 +1,5 @@
+export enum LogEvent {
+  TODO_TOGGLE = 'todo_toggle',
+  TODO_DELETE = 'todo_delete',
+  TODO_ADD = 'todo_add',
+}

lib/javascript/fullstack_demo/src/util/events.ts

@@ -1,8 +1,11 @@
+import { LogEvent } from './events';
+
 export interface Logger {
   log(level: LogLevel, message: string, vars?: {}): void;
   debug(format: string, vars?: {}): void;
   info(format: string, vars?: {}): void;
   error(format: string, vars?: {}): void;
+  event(id: LogEvent, vars?: {}): void;
 }
 
 export type LogLevel = 'debug' | 'info' | 'error' | 'warn';

lib/javascript/fullstack_demo/src/util/logger.ts

@@ -0,0 +1,27 @@
+import { PrismaClient } from '@prisma/client';
+import Transport from 'winston-transport';
+
+export class PrismaTransport extends Transport {
+  private readonly client = new PrismaClient();
+
+  constructor(opts: any) {
+    super(opts);
+  }
+
+  log(info: any, callback: () => void): void {
+    setImmediate(() => {
+      this.emit('logged', info);
+    });
+
+    this.client.logs.create({
+      data: {
+        level: info.level,
+        message: info.message,
+        meta: info.vars,
+        timestamp: info.timestamp,
+      },
+    });
+
+    callback();
+  }
+}

lib/javascript/fullstack_demo/src/util/prisma-transport.ts

@@ -1,7 +1,9 @@
 import { auth } from '@clerk/nextjs/server';
 import { headers } from 'next/headers';
 import winston, { format } from 'winston';
+import { LogEvent } from './events';
 import { Logger, LogLevel } from './logger';
+import { PrismaTransport } from './prisma-transport';
 const { combine, timestamp, json } = format;
 
 export class WinstonLogger implements Logger {
@@ -22,29 +24,35 @@ export class WinstonLogger implements Logger {
       transports: [
         new winston.transports.Console({ level: 'info' }),
         new winston.transports.File({ filename: 'debug.log', level: 'debug' }),
+        new PrismaTransport({ level: 'debug' }),
       ],
     });
   }
 
-  async log(level: LogLevel, message: string, vars: {}) {
+  async log(level: LogLevel, message: string, vars = {}) {
     const { userId } = await auth();
     this.winstonLogger.log(level.toLowerCase(), message, { ...vars, userId });
   }
 
-  async debug(format: string, vars: {}) {
+  async debug(format: string, vars = {}) {
     const { userId } = await auth();
     this.winstonLogger.debug(format, { ...vars, userId });
   }
 
-  async info(format: string, vars: {}) {
+  async info(format: string, vars = {}) {
     const { userId } = await auth();
     this.winstonLogger.info(format, { ...vars, userId });
   }
 
-  async error(format: string, vars: {}) {
+  async error(format: string, vars = {}) {
     const { userId } = await auth();
     this.winstonLogger.error(format, { ...vars, userId });
   }
+
+  async event(eventId: LogEvent, vars = {}) {
+    const { userId } = await auth();
+    this.winstonLogger.debug('', { ...vars, userId, eventId });
+  }
 }
 
 export const logger = new WinstonLogger();