chris/timepulse
chris/timepulse
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fit notify route

Browse Source
This commit is contained in:
chris 2025-10-09 12:31:52 -04:00
parent 74ad2750b0
commit 37f02ae29b
1 changed files with 41 additions and 37 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

78
server.js
View File

@ -341,35 +341,16 @@ app.post('/subscribe', authenticateToken, async (req, res) => {
} }
}); });
app.get('/api/user/notes', authenticateToken, async (req, res) => {
try {
const notes = await db.all("SELECT admin_username, note_text, created_at FROM notes WHERE employee_user_id = ? ORDER BY created_at DESC", [req.user.id]);
try {
const userSubs = await db.all('SELECT subscription_object FROM subscriptions WHERE user_id = ?', [userId]);
const payload = JSON.stringify({ app.get('/api/user/notes', authenticateToken, async (req, res) => {
title: 'You Have a New Note', try {
body: `A new note has been added by ${adminUsername}.` const notes = await db.all("SELECT admin_username, note_text, created_at FROM notes WHERE employee_user_id = ? ORDER BY created_at DESC", [req.user.id]);
}); // The notification block has been removed from here.
res.json(notes);
const promises = userSubs.map(s => { } catch (err) {
const subscription = JSON.parse(s.subscription_object); res.status(500).json({ message: 'Failed to fetch notes.' });
return webpush.sendNotification(subscription, payload).catch(err => { }
if (err.statusCode === 410) db.run('DELETE FROM subscriptions WHERE subscription_object = ?', [s.subscription_object]); });
else console.error('Error sending employee notification:', err);
});
});
await Promise.all(promises);
} catch (notifyError) {
console.error('Failed to send employee notification:', notifyError);
}
res.json(notes);
} catch (err) {
res.status(500).json({ message: 'Failed to fetch notes.' });
}
});
// --- Admin User Management --- // --- Admin User Management ---
app.get('/api/admin/users', authenticateToken, requireRole('admin'), async (req, res) => { app.get('/api/admin/users', authenticateToken, requireRole('admin'), async (req, res) => {
@ -617,17 +598,40 @@ app.post('/api/admin/notify', authenticateToken, requireRole('admin'), async (re
} }
}); });
app.post('/api/admin/notes', authenticateToken, requireRole('admin'), async (req, res) => { app.post('/api/admin/notes', authenticateToken, requireRole('admin'), async (req, res) => {
try {
const { userId, noteText } = req.body;
const adminUsername = req.user.username;
if (!userId || !noteText) return res.status(400).json({ message: "Employee and note text are required." });
await db.run('INSERT INTO notes (admin_username, employee_user_id, note_text) VALUES (?, ?, ?)', [adminUsername, userId, noteText]);
// --- START: NOTIFICATION CODE (Correct Placement) ---
try { try {
const { userId, noteText } = req.body; const userSubs = await db.all('SELECT subscription_object FROM subscriptions WHERE user_id = ?', [userId]);
const adminUsername = req.user.username; const payload = JSON.stringify({
if (!userId || !noteText) return res.status(400).json({ message: "Employee and note text are required." }); title: 'You Have a New Note',
await db.run('INSERT INTO notes (admin_username, employee_user_id, note_text) VALUES (?, ?, ?)', [adminUsername, userId, noteText]); body: `A new note has been added by ${adminUsername}.`
res.status(201).json({ message: "Note successfully posted." }); });
} catch (err) {
res.status(500).json({ message: 'Failed to post note.' }); const promises = userSubs.map(s => {
const subscription = JSON.parse(s.subscription_object);
return webpush.sendNotification(subscription, payload).catch(err => {
if (err.statusCode === 410) db.run('DELETE FROM subscriptions WHERE subscription_object = ?', [s.subscription_object]);
else console.error('Error sending employee notification:', err);
});
});
await Promise.all(promises);
} catch (notifyError) {
console.error('Failed to send employee notification:', notifyError);
} }
}); // --- END: NOTIFICATION CODE ---
res.status(201).json({ message: "Note successfully posted." });
} catch (err) {
res.status(500).json({ message: 'Failed to post note.' });
}
});
// NEW: Endpoint to UPDATE a specific time-off request // NEW: Endpoint to UPDATE a specific time-off request
app.put('/api/user/time-off-requests/:id', authenticateToken, async (req, res) => { app.put('/api/user/time-off-requests/:id', authenticateToken, async (req, res) => {