atridad/pollo
1
0
Fork 0
Code Activity Actions

Cache fixes

Browse source
This commit is contained in:
Atridad Lahiji 2023-06-28 12:18:15 -06:00 • committed by atridadl
parent 4ab086933e
commit b88fc0213a
No known key found for this signature in database
5 changed files with 19 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
.env.example
View file

@ -4,6 +4,7 @@ DATABASE_URL=""
# Redis # Redis
UPSTASH_REDIS_REST_URL="" UPSTASH_REDIS_REST_URL=""
UPSTASH_REDIS_REST_TOKEN="" UPSTASH_REDIS_REST_TOKEN=""
UPSTASH_REDIS_EXPIRY_SECONDS=""
UPSTASH_RATELIMIT_REQUESTS="" UPSTASH_RATELIMIT_REQUESTS=""
UPSTASH_RATELIMIT_SECONDS="" UPSTASH_RATELIMIT_SECONDS=""

2
src/env.mjs
View file

@ -8,6 +8,7 @@ const server = z.object({
DATABASE_URL: z.string().url(), DATABASE_URL: z.string().url(),
UPSTASH_REDIS_REST_URL: z.string().url(), UPSTASH_REDIS_REST_URL: z.string().url(),
UPSTASH_REDIS_REST_TOKEN: z.string(), UPSTASH_REDIS_REST_TOKEN: z.string(),
UPSTASH_REDIS_EXPIRY_SECONDS: z.string(),
UPSTASH_RATELIMIT_REQUESTS: z.string(), UPSTASH_RATELIMIT_REQUESTS: z.string(),
UPSTASH_RATELIMIT_SECONDS: z.string(), UPSTASH_RATELIMIT_SECONDS: z.string(),
NODE_ENV: z.enum(["development", "test", "production"]), NODE_ENV: z.enum(["development", "test", "production"]),
@ -50,6 +51,7 @@ const processEnv = {
DATABASE_URL: process.env.DATABASE_URL, DATABASE_URL: process.env.DATABASE_URL,
UPSTASH_REDIS_REST_URL: process.env.UPSTASH_REDIS_REST_URL, UPSTASH_REDIS_REST_URL: process.env.UPSTASH_REDIS_REST_URL,
UPSTASH_REDIS_REST_TOKEN: process.env.UPSTASH_REDIS_REST_TOKEN, UPSTASH_REDIS_REST_TOKEN: process.env.UPSTASH_REDIS_REST_TOKEN,
UPSTASH_REDIS_EXPIRY_SECONDS: process.env.UPSTASH_REDIS_EXPIRY_SECONDS,
UPSTASH_RATELIMIT_REQUESTS: process.env.UPSTASH_RATELIMIT_REQUESTS, UPSTASH_RATELIMIT_REQUESTS: process.env.UPSTASH_RATELIMIT_REQUESTS,
UPSTASH_RATELIMIT_SECONDS: process.env.UPSTASH_RATELIMIT_SECONDS, UPSTASH_RATELIMIT_SECONDS: process.env.UPSTASH_RATELIMIT_SECONDS,
NODE_ENV: process.env.NODE_ENV, NODE_ENV: process.env.NODE_ENV,

7
src/server/api/routers/room.ts
View file

@ -90,7 +90,8 @@ export const roomRouter = createTRPCRouter({
await redis.set( await redis.set(
`${env.APP_ENV}_kv_roomlist_${ctx.session.user.id}`, `${env.APP_ENV}_kv_roomlist_${ctx.session.user.id}`,
roomList roomList,
{ ex: Number(env.UPSTASH_REDIS_EXPIRY_SECONDS) }
); );
return roomList; return roomList;
@ -107,7 +108,9 @@ export const roomRouter = createTRPCRouter({
} else { } else {
const roomsCount = await ctx.prisma.room.count(); const roomsCount = await ctx.prisma.room.count();
await redis.set(`${env.APP_ENV}_kv_roomcount_admin`, roomsCount); await redis.set(`${env.APP_ENV}_kv_roomcount_admin`, roomsCount, {
ex: Number(env.UPSTASH_REDIS_EXPIRY_SECONDS),
});
return roomsCount; return roomsCount;
} }

8
src/server/api/routers/user.ts
View file

@ -21,7 +21,9 @@ export const userRouter = createTRPCRouter({
} else { } else {
const usersCount = await ctx.prisma.user.count(); const usersCount = await ctx.prisma.user.count();
await redis.set(`${env.APP_ENV}_kv_usercount_admin`, usersCount); await redis.set(`${env.APP_ENV}_kv_usercount_admin`, usersCount, {
ex: Number(env.UPSTASH_REDIS_EXPIRY_SECONDS),
});
return usersCount; return usersCount;
} }
@ -90,7 +92,9 @@ export const userRouter = createTRPCRouter({
}, },
}); });
await redis.set(`${env.APP_ENV}_kv_userlist_admin`, users); await redis.set(`${env.APP_ENV}_kv_userlist_admin`, users, {
ex: Number(env.UPSTASH_REDIS_EXPIRY_SECONDS),
});
return users; return users;
} }

7
src/server/api/routers/vote.ts
View file

@ -17,7 +17,9 @@ export const voteRouter = createTRPCRouter({
} else { } else {
const votesCount = await ctx.prisma.vote.count(); const votesCount = await ctx.prisma.vote.count();
await redis.set(`${env.APP_ENV}_kv_votecount_admin`, votesCount); await redis.set(`${env.APP_ENV}_kv_votecount_admin`, votesCount, {
ex: Number(env.UPSTASH_REDIS_EXPIRY_SECONDS),
});
return votesCount; return votesCount;
} }
@ -63,7 +65,8 @@ export const voteRouter = createTRPCRouter({
await redis.set( await redis.set(
`${env.APP_ENV}_kv_votes_${input.roomId}`, `${env.APP_ENV}_kv_votes_${input.roomId}`,
votesByRoomId votesByRoomId,
{ ex: Number(env.UPSTASH_REDIS_EXPIRY_SECONDS) }
); );
return votesByRoomId; return votesByRoomId;