Fix fetch urls

client/.env

@@ -0,0 +1 @@
+VITE_API_PREFIX=http://localhost:4202

client/.env.production

@@ -0,0 +1 @@
+VITE_API_PREFIX=

client/src/promisePipelines/fetchPipeline.ts

@@ -1,14 +1,17 @@
-import { httpMiddleware, marshalMiddleware, zodMiddleware } from './middleware/index'
+import * as middleware from './middleware/index'
 import { useWithGet, useWithPost } from '~/composables/useWithFetch'
 
 export const withGet = useWithGet()
 export const withPost = useWithPost()
 
-withGet.useBefore(marshalMiddleware)
-withPost.useBefore(marshalMiddleware)
+withGet.useBefore(middleware.devMiddleware)
+withPost.useBefore(middleware.devMiddleware)
 
-withGet.useAfter(httpMiddleware)
-withPost.useAfter(httpMiddleware)
+withGet.useBefore(middleware.marshalMiddleware)
+withPost.useBefore(middleware.marshalMiddleware)
 
-withGet.useAfter(zodMiddleware)
-withPost.useAfter(zodMiddleware)
+withGet.useAfter(middleware.httpMiddleware)
+withPost.useAfter(middleware.httpMiddleware)
+
+withGet.useAfter(middleware.zodMiddleware)
+withPost.useAfter(middleware.zodMiddleware)

client/src/promisePipelines/middleware/devMiddleware.ts

@@ -0,0 +1,8 @@
+import { Middleware } from '~/composables/useWith'
+import { RequestContext } from '~/composables/useWithFetch'
+
+export const devMiddleware: Middleware<RequestContext> = async (context) => {
+  context.url = import.meta.env.VITE_API_PREFIX + context.url
+  console.log('devMiddleware', context.url)
+  return context
+}

client/src/promisePipelines/middleware/index.ts

@@ -1,4 +1,5 @@
 export { authMiddleware } from './authMiddleware'
+export { devMiddleware } from './devMiddleware'
 export { httpMiddleware } from './httpMiddleware.ts'
 export { marshalMiddleware } from './marshalMiddleware.ts'
 export { zodMiddleware } from './zodMiddleware'

client/src/promisePipelines/middleware/marshalMiddleware.ts

@@ -10,7 +10,6 @@ export const marshalMiddleware: Middleware<RequestContext> = async (context) =>
   }
 
   if (context.body) {
-    console.log('context.body', context.body, typeof context.body)
     context.body = JSON.stringify(context.body)
     context.headers = {
       ...context.headers,

client/src/promisePipelines/sseMiddleware/devMiddleware.ts

@@ -0,0 +1,8 @@
+import { Middleware } from '~/composables/useWith'
+import { RequestContext } from '~/composables/useWithSSE'
+
+export const devMiddleware: Middleware<RequestContext> = async (context) => {
+  context.url = import.meta.env.VITE_API_PREFIX + context.url
+  console.log('devMiddleware', context.url)
+  return context
+}

client/src/promisePipelines/sseMiddleware/index.ts

@@ -1,2 +1,3 @@
+export { devMiddleware } from './devMiddleware'
 export { loggingMiddleware } from './loggingMiddleware'
 export { unmarshalMiddleware } from './unmarshalMiddleware'

client/src/promisePipelines/ssePiepeline.ts

@@ -1,7 +1,9 @@
-import { unmarshalMiddleware } from './sseMiddleware/index'
+import * as middleware from './sseMiddleware/index'
 import { useWithSSE } from '~/composables/useWithSSE'
 
 export const withSSE = useWithSSE()
 
-withSSE.useAfter(unmarshalMiddleware)
+withSSE.useBefore(middleware.devMiddleware)
+
+withSSE.useAfter(middleware.unmarshalMiddleware)
 // withSSE.useAfter(loggingMiddleware)

client/src/queries/emojiQueries.ts

@@ -22,7 +22,7 @@ type WeatherEmojiResponse = z.infer<typeof WeatherEmojiResponseSchema>
 export const emojiQueries = {
   getWeatherEmoji: async (params: GetWeatherEmojiParams) => (
     withGet.execute({
-      url: 'http://localhost:4202/api/weather-emoji',
+      url: '/api/weather-emoji',
       queryString: params,
       responseSchema: WeatherEmojiResponseSchema,
       headers: {

client/src/queries/logStreamQueries.ts

@@ -35,7 +35,7 @@ type LogResponse = z.infer<typeof LogResponseSchema>
 export const logStreamQueries = {
   connectLogs: async (params: ConnectLogsParams) => {
     const { data } = await withSSE.execute({
-      url: 'http://localhost:4202/stream/logs',
+      url: '/stream/logs',
       responseSchema: LogResponseSchema,
       onMessage: params.onMessage,
     })
@@ -44,7 +44,7 @@ export const logStreamQueries = {
   },
   sendLog: async (params: SendLogParams) => {
     const { data } = await withPost.execute({
-      url: 'http://localhost:4202/api/log',
+      url: '/api/log',
       body: params,
       responseSchema: LogResponseSchema,
     })

client/src/queries/weatherQueries.ts

@@ -21,7 +21,7 @@ type WeatherResponse = z.infer<typeof WeatherResponseSchema>
 export const weatherQueries = {
   getWeather: async (params: GetWeatherParams) => {
     const { data } = await withGet.execute({
-      url: 'http://localhost:4202/api/weather',
+      url: '/api/weather',
       queryString: params,
       responseSchema: WeatherResponseSchema,
       headers: {