ChronicStone Posts - Answer Overflow

ChronicStone

Explore posts from servers

NNuxt CDCloudflare Developers TtRPC

Posts Comments

CDCloudflare Developers

•Created by ChronicStone on 5/27/2024 in #general-help

Custom install command

I need to run a custom install command when installing packages for some reasons. Is there a way I can achieve this ?

3 replies

CDCloudflare Developers

•Created by ChronicStone on 1/9/2024 in #pages-help

Which object holds environment variables (Nuxt)

I just configured & deployed a nuxt app to be deployed to cloudflare pages. Environment variables are all setup, but I can't seem to access them, like to setup my drizzle DB connexion : (I'm using t3-env to valdiate & access my env vars : https://env.t3.gg/)

// db/index.ts
import { neon, neonConfig } from '@neondatabase/serverless';
import { drizzle as drizzleNeon } from 'drizzle-orm/neon-http';
import * as schema from './schema';
import { env } from '@/server/env';

neonConfig.fetchConnectionCache = true;

export const db = drizzleNeon(neon(env.DATABASE_URL), { schema, logger: false });

// db/index.ts
import { neon, neonConfig } from '@neondatabase/serverless';
import { drizzle as drizzleNeon } from 'drizzle-orm/neon-http';
import * as schema from './schema';
import { env } from '@/server/env';

neonConfig.fetchConnectionCache = true;

export const db = drizzleNeon(neon(env.DATABASE_URL), { schema, logger: false });

// server/env.ts

export const env = createEnv({
  server: {
    APP_BASE_URL: z.string().url(),
    APP_ENV: z.enum(['local', 'production']),
    DATABASE_URL: z.string().url(),
    DATABASE_SOURCE: z.enum(['neon', 'local']),
    CLERK_WEBHOOK_SECRET_KEY: z.string(),
    AWS_ACCESS_KEY_ID: z.string(),
    AWS_SECRET_ACCESS_KEY: z.string(),
    AWS_SES_REGION: z.string(),
    AWS_SES_SOURCE_EMAIL: z.string(),
    AWS_S3_REGION: z.string(),
    AWS_S3_BUCKET: z.string(),
    AWS_CLOUDFRONT_URL: z.string(),
    MAX_USER_PER_ORG: z.string().transform((v) => parseInt(v, 10)),
  },
});

// server/env.ts

export const env = createEnv({
  server: {
    APP_BASE_URL: z.string().url(),
    APP_ENV: z.enum(['local', 'production']),
    DATABASE_URL: z.string().url(),
    DATABASE_SOURCE: z.enum(['neon', 'local']),
    CLERK_WEBHOOK_SECRET_KEY: z.string(),
    AWS_ACCESS_KEY_ID: z.string(),
    AWS_SECRET_ACCESS_KEY: z.string(),
    AWS_SES_REGION: z.string(),
    AWS_SES_SOURCE_EMAIL: z.string(),
    AWS_S3_REGION: z.string(),
    AWS_S3_BUCKET: z.string(),
    AWS_CLOUDFRONT_URL: z.string(),
    MAX_USER_PER_ORG: z.string().transform((v) => parseInt(v, 10)),
  },
});

All these env vars are alaways empty & validation fails. By default it looks into process.env, but I can change the lookup object. But I'm still not sure to understand how I can access these env vars. I tried looking into globalThis, process.env, import.meta.env but none of these objects seem to hold my env vars.

2 replies

TtRPC

•Created by ChronicStone on 8/28/2023 in #❓-help

tRPC subscription : Access to socket ID from subscription

I'm trying to implement user online status in a reliable way on my app, on the "live" part of my app. It's done & working well, but on some cases where the connexion is cut & not restored, I can't trigger the mutation marking the user offline. Right now I'm handling this through the client only right now but in some instances, it's not reliable. What I'd like to do would be something like this : (For subscription I need to pass my authToken as an input since wsLink does not support dynamic header resolver yet to my knowledge).

userOnlineStatusChanged: publicProcedure
.input(z.object({ authToken: z.string() }))
.subscription(async ({ input, ctx, socket }) => {
  const user = await getUserFromJwt()
  if(!user) throw new TRPCError({ code: 'UNAUTHORIZED', message: '...' })

  // SOMEHOW GET SOCKET ID & ASSOCIATE IT TO USER :
  const storage = useStorage('db')
  storage.set(socket.id, user._id)
  

  return observable<{ userId: string; online: boolean }>((emit) => {
    mapEvents.on(
      'userOnlineStatusChanged',
      (params) => params.organizationId === user.organizationId && emit.next(params),
    );

    return () => {
      mapEvents.off(
        'userOnlineStatusChanged',
        (params) => params.organizationId === user.organizationId && emit.next(params),
      );
    };
  });
})

userOnlineStatusChanged: publicProcedure
.input(z.object({ authToken: z.string() }))
.subscription(async ({ input, ctx, socket }) => {
  const user = await getUserFromJwt()
  if(!user) throw new TRPCError({ code: 'UNAUTHORIZED', message: '...' })

  // SOMEHOW GET SOCKET ID & ASSOCIATE IT TO USER :
  const storage = useStorage('db')
  storage.set(socket.id, user._id)
  

  return observable<{ userId: string; online: boolean }>((emit) => {
    mapEvents.on(
      'userOnlineStatusChanged',
      (params) => params.organizationId === user.organizationId && emit.next(params),
    );

    return () => {
      mapEvents.off(
        'userOnlineStatusChanged',
        (params) => params.organizationId === user.organizationId && emit.next(params),
      );
    };
  });
})

The goal being that on disconnexion of the socket, I mark the user as disconnected from the server to make the whole thing more reliable :

5 replies

Gaming

Programming