+server.ts RawHistoryFolder

1import { error } from '@sveltejs/kit';
2import { sseEmitter } from '$lib/sseEmitter';
3import db from '$lib/db/db.server';
4import { users } from '$lib/db/schema';
5import { eq } from 'drizzle-orm';
6import { validateSessionToken, generateSessionToken, createSession } from '$lib/api/session.server';
7import { setSessionTokenCookie } from '$lib/api/session.cookie';
8
9export async function POST({ request, cookies, locals }) {
10    if (!locals.user) {
11        throw error(401, 'Authentication required');
12    }
13
14    const { status } = await request.json();
15    const validStatuses = ['online', 'away', 'busy', 'offline'];
16    if (!validStatuses.includes(status)) {
17        throw error(400, 'Invalid status');
18    }
19
20    const userId = locals.user.id;
21    console.debug('Updating status for user', userId, 'to', status);
22
23    // Update the user status in the database
24    await db.update(users)
25        .set({ status, lastSeen: status === 'offline' ? Date.now() : null })
26        .where(eq(users.id, userId));
27    console.debug('Status updated in database');
28
29    // Renew session if status is online and session is near expiry
30    if (status === 'online') {
31        const token = cookies.get('session');
32        if (token) {
33            const result = await validateSessionToken(token);
34            if (result.session) {
35                const now = Date.now();
36                const remaining = result.session.expiresAt - now;
37                const threshold = 15 * 60 * 1000; // 15 minutes in milliseconds
38                if (remaining < threshold) {
39                    const newToken = generateSessionToken();
40                    const newSession = await createSession(newToken, userId);
41                    setSessionTokenCookie({ cookies }, newToken, newSession.expiresAt);
42                    console.debug('Session renewed for user', userId);
43                }
44            }
45        }
46    }
47
48    // Broadcast the status update via SSE
49    sseEmitter.emit('sse', { type: 'userStatusUpdate', data: { userId, status, lastSeen: status === 'offline' ? Date.now() : null } });
50
51    return new Response(JSON.stringify({ success: true }), { status: 200, headers: { 'Content-Type': 'application/json' } });
52}