atridad/pollo
1
0
Fork 0
Code Activity Actions

Hotfix... ready for PRIME TIME!

Browse source
This commit is contained in:
Atridad Lahiji 2023-07-25 12:40:00 -06:00 • committed by atridadl
parent 01fe7cd4e9
commit 446c768d51
No known key found for this signature in database
5 changed files with 32 additions and 35 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
src/components/Navbar.tsx
View file

@ -96,11 +96,12 @@ const Navbar: React.FC<NavbarProps> = ({ title }) => {
</Link> </Link>
</li> </li>
)} )}
<li> <button
<a onClick={ () => void signOut({ callbackUrl: "/" }) }> className="btn btn-secondary btn-sm text-center whitespace-nowrap"
onClick={() => void signOut({ callbackUrl: "/" })}
>
Sign Out Sign Out
</a> </button>
</li>
</ul> </ul>
</div> </div>
</div> </div>

12
src/server/ably.ts
View file

@ -2,16 +2,12 @@ import Ably from "ably";
import { env } from "~/env.mjs"; import { env } from "~/env.mjs";
import type { EventType } from "../utils/types"; import type { EventType } from "../utils/types";
const ablyRest = new Ably.Rest(env.ABLY_PRIVATE_KEY); export const publishToChannel = async (
export const publishToChannel = (
channel: string, channel: string,
event: EventType, event: EventType,
message: string message: string
) => { ) => {
try { const ably = new Ably.Rest.Promise(env.ABLY_PRIVATE_KEY);
ablyRest.channels.get(`${env.APP_ENV}-${channel}`).publish(event, message); const ablyChannel = ably.channels.get(`${env.APP_ENV}-${channel}`);
} catch (error) { await ablyChannel.publish(event, message, { quickAck: true });
console.log(`❌❌❌ Failed to send message!`);
}
}; };

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

@ -27,7 +27,7 @@ export const roomRouter = createTRPCRouter({
await invalidateCache(`kv_roomcount_admin`); await invalidateCache(`kv_roomcount_admin`);
await invalidateCache(`kv_roomlist_${ctx.session.user.id}`); await invalidateCache(`kv_roomlist_${ctx.session.user.id}`);
publishToChannel( await publishToChannel(
`${ctx.session.user.id}`, `${ctx.session.user.id}`,
"ROOM_LIST_UPDATE", "ROOM_LIST_UPDATE",
"CREATE" "CREATE"
@ -201,7 +201,7 @@ export const roomRouter = createTRPCRouter({
}); });
if (newRoom) { if (newRoom) {
publishToChannel(`${newRoom.id}`, "ROOM_UPDATE", "UPDATE"); await publishToChannel(`${newRoom.id}`, "ROOM_UPDATE", "UPDATE");
} }
return !!newRoom; return !!newRoom;
@ -222,13 +222,13 @@ export const roomRouter = createTRPCRouter({
await invalidateCache(`kv_votecount_admin`); await invalidateCache(`kv_votecount_admin`);
await invalidateCache(`kv_roomlist_${ctx.session.user.id}`); await invalidateCache(`kv_roomlist_${ctx.session.user.id}`);
publishToChannel( await publishToChannel(
`${ctx.session.user.id}`, `${ctx.session.user.id}`,
"ROOM_LIST_UPDATE", "ROOM_LIST_UPDATE",
"DELETE" "DELETE"
); );
publishToChannel(`${deletedRoom.id}`, "ROOM_UPDATE", "DELETE"); await publishToChannel(`${deletedRoom.id}`, "ROOM_UPDATE", "DELETE");
} }
return !!deletedRoom; return !!deletedRoom;

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

@ -100,7 +100,7 @@ export const voteRouter = createTRPCRouter({
await invalidateCache(`kv_votecount_admin`); await invalidateCache(`kv_votecount_admin`);
await invalidateCache(`kv_votes_${input.roomId}`); await invalidateCache(`kv_votes_${input.roomId}`);
publishToChannel(`${vote.roomId}`, "VOTE_UPDATE", "UPDATE"); await publishToChannel(`${vote.roomId}`, "VOTE_UPDATE", "UPDATE");
} }
return !!vote; return !!vote;

2
src/server/api/trpc.ts
View file

@ -118,7 +118,7 @@ const enforceRouteProtection = t.middleware(async ({ ctx, next }) => {
const { success } = await rateLimit.limit( const { success } = await rateLimit.limit(
`${env.APP_ENV}_${ctx.session.user.id}` `${env.APP_ENV}_${ctx.session.user.id}`
); );
console.log(success);
if (!success) throw new TRPCError({ code: "TOO_MANY_REQUESTS" }); if (!success) throw new TRPCError({ code: "TOO_MANY_REQUESTS" });
return next({ return next({