const WebSocketsDb = t.middleware(async ({ next, ctx }) => {
  const { dbWebSockets, pool } = createDBWebSocket(ctx.c.env.DATABASE_URL);

  const res = await next({
    ctx: {
      ...ctx,
      db: dbWebSockets,
    },
  });

  // still not sure which of these waitUntil to use since it is running in a worker
  ctx.c.executionCtx.waitUntil(pool.end());
  ctx.c.event.waitUntil(pool.end());

  return res;
});

export const router = t.router;
export const publicProcedure = t.procedure;
export const protectedProcedure = t.procedure.use(isAuthenticated);
export const publicProcedureWebSockets = t.procedure.use(WebSocketsDb);
export const protectedProcedureWebSockets =
  protectedProcedure.use(WebSocketsDb);

const WebSocketsDb = t.middleware(async ({ next, ctx }) => {
  const { dbWebSockets, pool } = createDBWebSocket(ctx.c.env.DATABASE_URL);

  const res = await next({
    ctx: {
      ...ctx,
      db: dbWebSockets,
    },
  });

  // still not sure which of these waitUntil to use since it is running in a worker
  ctx.c.executionCtx.waitUntil(pool.end());
  ctx.c.event.waitUntil(pool.end());

  return res;
});

export const router = t.router;
export const publicProcedure = t.procedure;
export const protectedProcedure = t.procedure.use(isAuthenticated);
export const publicProcedureWebSockets = t.procedure.use(WebSocketsDb);
export const protectedProcedureWebSockets =
  protectedProcedure.use(WebSocketsDb);

export const createDBWebSocket = (DATABASE_URL: string) => {
  const pool = new Pool({ connectionString: DATABASE_URL });
  return drizzleServerless(pool, {
    schema,
    logger: true,
  });
};

export const createDBWebSocket = (DATABASE_URL: string) => {
  const pool = new Pool({ connectionString: DATABASE_URL });
  return drizzleServerless(pool, {
    schema,
    logger: true,
  });
};