diff --git a/app/api/trpc-edge/[trpc]/route.ts b/app/api/trpc-edge/[trpc]/route.ts index 3fbd38afa..57ab67e75 100644 --- a/app/api/trpc-edge/[trpc]/route.ts +++ b/app/api/trpc-edge/[trpc]/route.ts @@ -2,7 +2,6 @@ import { fetchRequestHandler } from '@trpc/server/adapters/fetch'; import { appRouterEdge } from '~/server/api/trpc.router'; import { createTRPCFetchContext } from '~/server/api/trpc.server'; -import { env } from '~/server/env.mjs'; const handlerEdgeRoutes = (req: Request) => fetchRequestHandler({ @@ -11,7 +10,7 @@ const handlerEdgeRoutes = (req: Request) => req, createContext: createTRPCFetchContext, onError: - env.NODE_ENV === 'development' + process.env.NODE_ENV === 'development' ? ({ path, error }) => console.error(`❌ tRPC-edge failed on ${path ?? ''}:`, error) : undefined, }); diff --git a/app/api/trpc-node/[trpc]/route.ts b/app/api/trpc-node/[trpc]/route.ts index 48f443ebe..1cd0dbd87 100644 --- a/app/api/trpc-node/[trpc]/route.ts +++ b/app/api/trpc-node/[trpc]/route.ts @@ -2,7 +2,6 @@ import { fetchRequestHandler } from '@trpc/server/adapters/fetch'; import { appRouterNode } from '~/server/api/trpc.router'; import { createTRPCFetchContext } from '~/server/api/trpc.server'; -import { env } from '~/server/env.mjs'; const handlerNodeRoutes = (req: Request) => fetchRequestHandler({ @@ -11,7 +10,7 @@ const handlerNodeRoutes = (req: Request) => req, createContext: createTRPCFetchContext, onError: - env.NODE_ENV === 'development' + process.env.NODE_ENV === 'development' ? ({ path, error }) => console.error(`❌ tRPC-node failed on ${path ?? ''}:`, error) : undefined, }); diff --git a/src/modules/llms/transports/server/openai/openai.streaming.ts b/src/modules/llms/transports/server/openai/openai.streaming.ts index 9d7ea2e3d..72717fd0c 100644 --- a/src/modules/llms/transports/server/openai/openai.streaming.ts +++ b/src/modules/llms/transports/server/openai/openai.streaming.ts @@ -3,7 +3,6 @@ import { NextRequest, NextResponse } from 'next/server'; import { createParser as createEventsourceParser, EventSourceParseCallback, EventSourceParser, ParsedEvent, ReconnectInterval } from 'eventsource-parser'; import { createEmptyReadableStream, debugGenerateCurlCommand, safeErrorString, SERVER_DEBUG_WIRE, serverFetchOrThrow } from '~/server/wire'; -import { env } from '~/server/env.mjs'; import type { AnthropicWire } from '../anthropic/anthropic.wiretypes'; import type { OpenAIWire } from './openai.wiretypes'; @@ -91,7 +90,7 @@ export async function openaiStreamingRelayHandler(req: NextRequest): Promise