You can now close this window and log in to the app.
`); } catch (err) { console.error(err); res.status(500).send('Server Error'); } }); app.get('/verification_status', authenticateToken, async (req, res) => { try { const {rows} = await pool.query('SELECT is_verified FROM users WHERE id = $1', [req.user]); if (rows.length === 0) return res.status(404).json({error: 'User not found'}); res.status(200).json({is_verified: rows[0].is_verified}); } catch (err) { console.error(err); res.status(500).json({ error: 'Internal server error' }); } }); app.post('/resend_verification', authenticateToken, async (req, res) => { const ip = req.ip || req.connection.remoteAddress; try { await resendVerificationRateLimiter.consume(ip); } catch (rejRes) { return res.status(429).json({ error: 'Please wait before requesting another verification email.', retryAfter: Math.ceil(rejRes.msBeforeNext / 1000) // seconds }); } try { const {rows} = await pool.query('SELECT email, name, is_verified FROM users WHERE id = $1', [req.user]); if (rows.length === 0) return res.status(404).json({error: 'User not found'}); const user = rows[0]; if (user.is_verified) { return res.status(400).json({error: 'Email already verified'}); } const token = crypto.randomBytes(32).toString('hex'); await pool.query('UPDATE users SET verification_token = $1 WHERE id = $2', [token, req.user]); await sendVerificationEmail(user.email, token, user.name); res.status(200).json({ message: 'Verification email sent' }); } catch (err) { console.error(err); res.status(500).json({ error: 'Internal server error' }); } }); app.get('/verify', authenticateToken, async (req, res) => { try { // Issue a new token to extend session const newToken = await createToken(req.user); res.status(200).json({token: newToken}); } catch { res.status(500).json({ error: 'server error' }); } }); app.get('/device_list', authenticateToken, async (req, res) => { try { console.log("device List request"); console.log(req.user); const {rows} = await pool.query('select id, device_name, max_ports from devices where user_id = $1', [req.user]); const deviceNames = rows.map(row => row.device_name); const deviceIds = rows.map(row => row.id); const maxPorts = rows.map(row => row.max_ports); res.status(200).json({ device_ids: deviceIds, devices: deviceNames, max_ports: maxPorts }); } catch { res.status(500).json({error: 'Internal Server Error'}); } }); app.get('/device_name', authenticateToken, async (req, res) => { console.log("deviceName"); try { const {deviceId} = req.query; const {rows} = await pool.query('select device_name, max_ports from devices where id=$1 and user_id=$2', [deviceId, req.user]); if (rows.length != 1) return res.sendStatus(404); const deviceName = rows[0].device_name; const maxPorts = rows[0].max_ports; res.status(200).json({device_name: deviceName, max_ports: maxPorts}); } catch { res.sendStatus(500); } }); app.get('/peripheral_list', authenticateToken, async (req, res) => { console.log("periph list") try { const {deviceId} = req.query; const {rows} = await pool.query('select id, peripheral_number, peripheral_name from peripherals where device_id=$1 and user_id=$2', [deviceId, req.user]); const peripheralIds = rows.map(row => row.id); const portNums = rows.map(row => row.peripheral_number); const peripheralNames = rows.map(row => row.peripheral_name); res.status(200).json({peripheral_ids: peripheralIds, port_nums: portNums, peripheral_names: peripheralNames}); } catch { res.sendStatus(500); } }) app.post('/add_device', authenticateToken, async (req, res) => { try { console.log("add device request"); console.log(req.user); console.log(req.peripheral); const {deviceName, maxPorts} = req.body; console.log(deviceName); const ports = maxPorts || 4; // Default to 4 for multi-port devices const {rows} = await pool.query("insert into devices (user_id, device_name, max_ports) values ($1, $2, $3) returning id", [req.user, deviceName, ports] ); // finish token return based on device ID. const deviceInitToken = await createTempPeriphToken(rows[0].id); res.status(201).json({token: deviceInitToken}); } catch (err) { console.log(err); if (err.code == '23505') { return res.status(409).json({ error: 'Device Name in use' }); } res.status(500).json({error: 'Internal Server Error'}); } }); app.post('/add_peripheral', authenticateToken, async (req, res) => { try { const {device_id, port_num, peripheral_name} = req.body; await pool.query("insert into peripherals (device_id, peripheral_number, peripheral_name, user_id) values ($1, $2, $3, $4)", [device_id, port_num, peripheral_name, req.user] ); res.sendStatus(201); } catch (err){ if (err.code == '23505') return res.sendStatus(409); res.sendStatus(500); } }); app.get('/verify_device', authenticateToken, async (req, res) => { console.log("device verify"); try{ console.log(req.peripheral); // Check if this is a single-port device const {rows: deviceRows} = await pool.query("select max_ports, user_id from devices where id=$1", [req.peripheral]); if (deviceRows.length === 0) { return res.status(404).json({error: "Device not found"}); } const maxPorts = deviceRows[0].max_ports; const userId = deviceRows[0].user_id; // For single-port devices, automatically create the peripheral if it doesn't exist if (maxPorts === 1) { const {rows: periphRows} = await pool.query( "select id from peripherals where device_id=$1", [req.peripheral] ); if (periphRows.length === 0) { // Create default peripheral for C6 device await pool.query( "insert into peripherals (device_id, peripheral_number, peripheral_name, user_id) values ($1, 1, $2, $3)", [req.peripheral, "Main Blind", userId] ); console.log("Created default peripheral for single-port device"); } } await pool.query("delete from device_tokens where device_id=$1", [req.peripheral]); const newToken = await createPeripheralToken(req.peripheral); console.log("New Token", newToken); res.json({token: newToken, id: req.peripheral}); } catch (error) { console.error("Error in verify_device:", error); res.status(500).json({error: "server error"}); } }); // no longer polling server - using webSocket // app.get('/position', authenticateToken, async (req, res) => { // console.log("devicepos"); // try { // const {rows} = await pool.query("select last_pos, peripheral_number, await_calib from peripherals where device_id=$1", // [req.peripheral]); // if (rows.length == 0) { // return res.sendStatus(404); // } // res.status(200).json(rows); // } catch { // res.status(500).json({error: "server error"}); // } // }); app.post('/manual_position_update', authenticateToken, async (req, res) => { console.log("setpos"); try { const {periphId, periphNum, deviceId, newPos} = req.body; const changedPosList = [{periphNum: periphNum, periphID: periphId, pos: newPos}]; // Schedule the job to run immediately const job = await agenda.now('posChange', {deviceID: deviceId, changedPosList: changedPosList, userID: req.user}); res.status(202).json({ // 202 Accepted, as processing happens in background success: true, message: 'Request accepted for immediate processing.', jobId: job.attrs._id }); } catch (error) { console.error('Error triggering immediate action:', error); res.status(500).json({ success: false, message: 'Failed to trigger immediate action', error: error.message }); } }); app.post('/calib', authenticateToken, async (req, res) => { console.log("calibrate"); try { const {periphId} = req.body; // Schedule the job to run immediately const job = await agenda.now('calib', {periphID: periphId, userID: req.user}); res.status(202).json({ // 202 Accepted, as processing happens in background success: true, message: 'Request accepted for immediate processing.', jobId: job.attrs._id }); } catch (err) { console.error('Error triggering immediate action:', err); res.sendStatus(500); } }) app.post('/cancel_calib', authenticateToken, async (req, res) => { console.log("cancelCalib"); try { const {periphId} = req.body; const job = await agenda.now('cancel_calib', {periphID: periphId, userID: req.user}); res.status(202).json({ // 202 Accepted, as processing happens in background success: true, message: 'Request accepted for immediate processing.', jobId: job.attrs._id }); } catch { res.sendStatus(500); } }); app.get('/peripheral_status', authenticateToken, async (req, res) => { console.log("status"); try { const {periphId} = req.query; const {rows} = await pool.query("select last_pos, last_set, calibrated, await_calib from peripherals where id=$1 and user_id=$2", [periphId, req.user] ); if (rows.length != 1) return res.sendStatus(404); res.status(200).json({last_pos: rows[0].last_pos, last_set: rows[0].last_set, calibrated: rows[0].calibrated, await_calib: rows[0].await_calib}); } catch { res.sendStatus(500); } }); app.get('/peripheral_name', authenticateToken, async (req, res) => { console.log("urmom"); try { const {periphId} = req.query; const {rows} = await pool.query("select peripheral_name from peripherals where id=$1 and user_id=$2", [periphId, req.user] ); if (rows.length != 1) return res.sendStatus(404); res.status(200).json({name: rows[0].peripheral_name}); } catch { res.sendStatus(500); } }) app.get('/device_connection_status', authenticateToken, async (req, res) => { console.log("device connection status"); try { const {deviceId} = req.query; // Verify device belongs to user const {rows: deviceRows} = await pool.query("select id from devices where id=$1 and user_id=$2", [deviceId, req.user] ); if (deviceRows.length != 1) return res.sendStatus(404); // Check if device has an active socket connection const {rows} = await pool.query("select connected from device_tokens where device_id=$1 and connected=TRUE", [deviceId] ); res.status(200).json({connected: rows.length > 0}); } catch { res.sendStatus(500); } }) app.post('/completed_calib', authenticateToken, async (req, res) => { console.log("calibration complete"); try { const {portNum} = req.body; const result = await pool.query("update peripherals set calibrated=true, await_calib=false where device_id=$1 and peripheral_number=$2", [req.peripheral, portNum] ); if (result.rowCount === 0) return res.sendStatus(404); res.sendStatus(204); } catch (error) { console.error(error); res.sendStatus(500); } }); app.post('/rename_device', authenticateToken, async (req, res) => { console.log("Hub rename"); try { const {deviceId, newName} = req.body; const result = await pool.query("update devices set device_name=$1 where id=$2 and user_id=$3", [newName, deviceId, req.user]); if (result.rowCount === 0) return res.sendStatus(404); res.sendStatus(204); } catch (err) { if (err.code == '23505') return res.sendStatus(409); console.error(err); res.sendStatus(500); } }); app.post('/rename_peripheral', authenticateToken, async (req, res) => { console.log("Hub rename"); try { const {periphId, newName} = req.body; const result = await pool.query("update peripherals set peripheral_name=$1 where id=$2 and user_id=$3", [newName, periphId, req.user]); if (result.rowCount === 0) return res.sendStatus(404); res.sendStatus(204); } catch (err) { if (err.code == '23505') return res.sendStatus(409); console.error(err); res.sendStatus(500); } }); app.post('/rename_group', authenticateToken, async (req, res) => { console.log("Rename group"); try { const {groupId, newName} = req.body; const result = await pool.query("update groups set name=$1 where id=$2 and user_id=$3", [newName, groupId, req.user]); if (result.rowCount === 0) return res.status(404).json({ error: 'Group not found' }); res.sendStatus(204); } catch (err) { if (err.code == '23505') return res.status(409).json({ error: 'Group name must be unique' }); console.error(err); res.sendStatus(500); } }); app.post('/update_group', authenticateToken, async (req, res) => { console.log("Update group members"); try { const { groupId, peripheral_ids } = req.body; if (!groupId || !peripheral_ids || !Array.isArray(peripheral_ids)) { return res.status(400).json({ error: 'Invalid request parameters' }); } // Verify group belongs to user const {rows: groupRows} = await pool.query( 'SELECT id FROM groups WHERE id=$1 AND user_id=$2', [groupId, req.user] ); if (groupRows.length === 0) { return res.status(404).json({ error: 'Group not found' }); } // Verify all peripherals belong to user const {rows: periphRows} = await pool.query( 'SELECT id FROM peripherals WHERE id = ANY($1::int[]) AND user_id=$2', [peripheral_ids, req.user] ); if (periphRows.length !== peripheral_ids.length) { return res.status(403).json({ error: 'One or more peripherals do not belong to you' }); } // Check if this exact peripheral set already exists in another group const {rows: duplicateRows} = await pool.query( `SELECT g.id, g.name FROM groups g JOIN ( SELECT group_id, array_agg(peripheral_id ORDER BY peripheral_id) as periph_set FROM group_peripherals GROUP BY group_id ) gp ON g.id = gp.group_id WHERE gp.periph_set = $1::int[] AND g.user_id = $2 AND g.id != $3`, [peripheral_ids.sort((a, b) => a - b), req.user, groupId] ); if (duplicateRows.length > 0) { return res.status(409).json({ error: 'This combination of blinds already exists in another group', existing_group: duplicateRows[0].name }); } // Delete existing group_peripherals entries await pool.query('DELETE FROM group_peripherals WHERE group_id=$1', [groupId]); // Insert new group_peripherals entries const insertValues = peripheral_ids.map(pid => `(${groupId}, ${pid})`).join(','); await pool.query(`INSERT INTO group_peripherals (group_id, peripheral_id) VALUES ${insertValues}`); res.status(200).json({ success: true, message: 'Group updated successfully' }); } catch (error) { console.error('Error updating group:', error); res.status(500).json({ error: 'Internal Server Error' }); } }); app.post('/delete_device', authenticateToken, async (req, res) => { console.log("delete device"); try { const {deviceId} = req.body; const {rows} = await pool.query("delete from devices where user_id=$1 and id=$2 returning id", [req.user, deviceId] ); if (rows.length != 1) { return res.status(404).json({ error: 'Device not found' }); } // Get socket ID before deleting tokens const {rows: tokenRows} = await pool.query( "select socket from device_tokens where device_id=$1 and connected=TRUE", [rows[0].id] ); // Delete device tokens await pool.query("delete from device_tokens where device_id=$1", [rows[0].id]); // Forcefully disconnect the Socket.IO connection if device is connected if (tokenRows.length > 0) { tokenRows.forEach(row => { if (row.socket) { const socket = io.sockets.sockets.get(row.socket); if (socket) { console.log(`Forcefully disconnecting device socket ${row.socket}`); socket.emit('device_deleted', { message: 'Device has been deleted from the account' }); socket.disconnect(true); } } }); } res.sendStatus(204); } catch (error) { console.error("Error deleting device:", error); res.status(500).json({error: "server error"}); } }); app.post('/delete_peripheral', authenticateToken, async (req, res) => { console.log("delete peripheral"); try { const {periphId} = req.body; const {rows} = await pool.query("delete from peripherals where user_id = $1 and id=$2 returning id", [req.user, periphId] ); if (rows.length != 1) { return res.status(404).json({ error: 'Device not found' }); } res.sendStatus(204); } catch { res.sendStatus(500); } }) // Helper function to create cron expression from time and days function createCronExpression(time, daysOfWeek) { const cronDays = daysOfWeek.join(','); return `${time.minute} ${time.hour} * * ${cronDays}`; } // Helper function to find and verify a schedule job belongs to the user async function findUserScheduleJob(jobId, userId) { const jobs = await agenda.jobs({ _id: new ObjectId(jobId), 'data.userID': userId }); return jobs.length === 1 ? jobs[0] : null; } app.post('/add_schedule', authenticateToken, async (req, res) => { console.log("add schedule"); try { const {periphId, periphNum, deviceId, newPos, time, daysOfWeek} = req.body; // Validate required fields if (!periphId || periphNum === undefined || !deviceId || newPos === undefined || !time || !daysOfWeek || daysOfWeek.length === 0) { return res.status(400).json({ error: 'Missing required fields' }); } // Create cron expression const cronExpression = createCronExpression(time, daysOfWeek); // Check for duplicate schedule const existingJobs = await agenda.jobs({ 'name': 'posChangeScheduled', 'data.changedPosList.0.periphID': periphId, 'data.userID': req.user }); // Check if any existing job has the same cron expression (time + days) const duplicate = existingJobs.find(job => { const jobCron = job.attrs.repeatInterval; return jobCron === cronExpression; }); if (duplicate) { console.log("Duplicate schedule detected"); return res.status(409).json({ success: false, message: 'A schedule with the same time and days already exists for this blind', duplicate: true }); } const changedPosList = [{periphNum: periphNum, periphID: periphId, pos: newPos}]; // Schedule the recurring job const job = await agenda.create('posChangeScheduled', { deviceID: deviceId, changedPosList: changedPosList, userID: req.user }); job.repeatEvery(cronExpression, { skipImmediate: true }); await job.save(); res.status(201).json({ success: true, message: 'Schedule created successfully', jobId: job.attrs._id }); } catch (error) { console.error('Error creating schedule:', error); res.status(500).json({ success: false, message: 'Failed to create schedule', error: error.message }); } }); app.post('/delete_schedule', authenticateToken, async (req, res) => { console.log("delete schedule"); try { const {jobId} = req.body; if (!jobId) { return res.status(400).json({ error: 'Missing jobId' }); } // Find and verify the existing job belongs to the user const existingJob = await findUserScheduleJob(jobId, req.user); if (!existingJob) { return res.status(404).json({ error: 'Schedule not found' }); } // Remove the job await existingJob.remove(); console.log("Schedule deleted successfully:", jobId); res.status(200).json({ success: true, message: 'Schedule deleted successfully' }); } catch (error) { console.error('Error deleting schedule:', error); res.status(500).json({ success: false, message: 'Failed to delete schedule', error: error.message }); } }); app.post('/update_schedule', authenticateToken, async (req, res) => { console.log("update schedule"); console.log("Request body:", req.body); try { const {jobId, periphId, periphNum, deviceId, newPos, time, daysOfWeek} = req.body; console.log("jobId type:", typeof jobId, "value:", jobId); // Validate required fields if (!jobId || !periphId || periphNum === undefined || !deviceId || newPos === undefined || !time || !daysOfWeek || daysOfWeek.length === 0) { console.log("Missing required fields"); return res.status(400).json({ error: 'Missing required fields' }); } // Find and verify the existing job belongs to the user console.log("Searching for job with _id:", jobId, "and userID:", req.user); const existingJob = await findUserScheduleJob(jobId, req.user); console.log("Found job:", existingJob ? 'yes' : 'no'); if (!existingJob) { console.log("Schedule not found"); return res.status(404).json({ error: 'Schedule not found' }); } console.log("Removing old job..."); // Cancel the old job await existingJob.remove(); // Create cron expression const cronExpression = createCronExpression(time, daysOfWeek); const changedPosList = [{periphNum: periphNum, periphID: periphId, pos: newPos}]; console.log("Creating new job with cron:", cronExpression); // Create new job with updated schedule const job = await agenda.create('posChangeScheduled', { deviceID: deviceId, changedPosList: changedPosList, userID: req.user }); job.repeatEvery(cronExpression, { skipImmediate: true }); await job.save(); console.log("Job saved successfully with ID:", job.attrs._id); res.status(200).json({ success: true, message: 'Schedule updated successfully', jobId: job.attrs._id }); } catch (error) { console.error('Error updating schedule:', error); res.status(500).json({ success: false, message: 'Failed to update schedule', error: error.message }); } }); server.listen(port, '127.0.0.1', () => { console.log(`Example app listening on 127.0.0.1:${port}`); }); app.post('/periph_schedule_list', authenticateToken, async (req, res) => { try { console.log("Schedule List request for user:", req.user); const { periphId } = req.body; if (!periphId) { return res.status(400).json({ error: 'periphId is required in the request body.' }); } // FIX 1: Assign the returned array directly to a variable (e.g., 'jobs') const jobs = await agenda.jobs({ 'name': 'posChangeScheduled', 'data.changedPosList': { $size: 1 }, 'data.changedPosList.0.periphID': periphId, 'data.userID': req.user }); // FIX 2: Use .filter() and .map() to handle all cases cleanly. // This creates a cleaner, more predictable transformation pipeline. const details = jobs // Step 1: Filter out any jobs that are not recurring. .filter(job => job.attrs.repeatInterval) // Step 2: Map the remaining recurring jobs to our desired format. .map(job => { const { repeatInterval, data, repeatTimezone } = job.attrs; try { const interval = cronParser.parseExpression(repeatInterval, { tz: repeatTimezone || undefined }); const fields = interval.fields; // Make sure to declare the variable const parsedSchedule = { minutes: fields.minute, hours: fields.hour, daysOfMonth: fields.dayOfMonth, months: fields.month, daysOfWeek: fields.dayOfWeek, }; return { id: job.attrs._id, // It's good practice to return the job ID schedule: parsedSchedule, pos: data.changedPosList[0].pos }; } catch (err) { // If parsing fails for a specific job, log it and filter it out. console.error(`Could not parse "${repeatInterval}" for job ${job.attrs._id}. Skipping.`); return null; // Return null for now } }) // Step 3: Filter out any nulls that resulted from a parsing error. .filter(detail => detail !== null); res.status(200).json({ scheduledUpdates: details }); } catch (error) { // FIX 3: Capture and log the actual error console.error("Error in /periph_schedule_list:", error); res.status(500).json({ error: 'Internal Server Error' }); } }); app.get('/group_list', authenticateToken, async (req, res) => { console.log("group_list request for user:", req.user); try { // Get all groups for the user - no joins needed for menu view const {rows} = await pool.query( 'SELECT id, name, created_at FROM groups WHERE user_id = $1 ORDER BY name', [req.user] ); res.status(200).json({ groups: rows }); } catch (error) { console.error("Error in /group_list:", error); res.status(500).json({ error: 'Internal Server Error' }); } }); app.post('/add_group', authenticateToken, async (req, res) => { console.log("add_group request for user:", req.user); try { const { name, peripheral_ids } = req.body; // Validate input if (!name || !name.trim()) { return res.status(400).json({ error: 'Group name is required' }); } if (!peripheral_ids || !Array.isArray(peripheral_ids) || peripheral_ids.length < 2) { return res.status(400).json({ error: 'At least 2 peripherals are required' }); } // Verify all peripherals belong to the user const verifyQuery = ` SELECT id FROM peripherals WHERE id = ANY($1) AND user_id = $2 `; const { rows: verifiedPeripherals } = await pool.query(verifyQuery, [peripheral_ids, req.user]); if (verifiedPeripherals.length !== peripheral_ids.length) { return res.status(403).json({ error: 'Invalid peripheral IDs' }); } // Sort peripheral IDs for consistent comparison const sortedPeripheralIds = [...peripheral_ids].sort((a, b) => a - b); // Check if a group with this exact set of peripherals already exists const duplicateCheckQuery = ` SELECT g.id, g.name FROM groups g JOIN group_peripherals gp ON g.id = gp.group_id WHERE g.user_id = $1 GROUP BY g.id HAVING array_agg(gp.peripheral_id ORDER BY gp.peripheral_id) = $2::int[] `; const { rows: duplicateGroups } = await pool.query(duplicateCheckQuery, [req.user, sortedPeripheralIds]); if (duplicateGroups.length > 0) { return res.status(409).json({ error: `A group named "${duplicateGroups[0].name}" already contains these exact blinds`, duplicate: true, existing_group_name: duplicateGroups[0].name }); } // Insert into groups table const insertGroupQuery = ` INSERT INTO groups (user_id, name) VALUES ($1, $2) RETURNING id `; const { rows: groupRows } = await pool.query(insertGroupQuery, [req.user, name.trim()]); const groupId = groupRows[0].id; // Insert into group_peripherals table const insertPeripheralsQuery = ` INSERT INTO group_peripherals (group_id, peripheral_id) VALUES ${peripheral_ids.map((_, i) => `($1, $${i + 2})`).join(', ')} `; await pool.query(insertPeripheralsQuery, [groupId, ...peripheral_ids]); res.status(201).json({ success: true, group_id: groupId, message: 'Group created successfully' }); } catch (error) { console.error("Error in /add_group:", error); // Handle unique constraint violation (duplicate group name) if (error.code === '23505') { return res.status(409).json({ error: 'A group with this name already exists' }); } res.status(500).json({ error: 'Internal Server Error' }); } }); app.post('/delete_group', authenticateToken, async (req, res) => { console.log("delete_group request for user:", req.user); try { const { groupId } = req.body; if (!groupId) { return res.status(400).json({ error: 'Group ID is required' }); } // Delete the group - CASCADE will automatically delete group_peripherals entries const { rows } = await pool.query( 'DELETE FROM groups WHERE id = $1 AND user_id = $2 RETURNING id, name', [groupId, req.user] ); if (rows.length === 0) { return res.status(404).json({ error: 'Group not found' }); } console.log(`Group "${rows[0].name}" deleted successfully`); res.sendStatus(204); } catch (error) { console.error("Error in /delete_group:", error); res.status(500).json({ error: 'Internal Server Error' }); } }); app.get('/group_details', authenticateToken, async (req, res) => { console.log("group_details request for user:", req.user); try { const { groupId } = req.query; if (!groupId) { return res.status(400).json({ error: 'Group ID is required' }); } // Get group info and all peripherals with their device info const { rows } = await pool.query(` SELECT g.id as group_id, g.name as group_name, json_agg( json_build_object( 'peripheral_id', p.id, 'peripheral_name', p.peripheral_name, 'peripheral_number', p.peripheral_number, 'device_id', p.device_id, 'last_pos', p.last_pos, 'calibrated', p.calibrated ) ORDER BY p.peripheral_name ) as peripherals FROM groups g JOIN group_peripherals gp ON g.id = gp.group_id JOIN peripherals p ON gp.peripheral_id = p.id WHERE g.id = $1 AND g.user_id = $2 GROUP BY g.id, g.name `, [groupId, req.user]); if (rows.length === 0) { return res.status(404).json({ error: 'Group not found' }); } res.status(200).json(rows[0]); } catch (error) { console.error("Error in /group_details:", error); res.status(500).json({ error: 'Internal Server Error' }); } }); app.post('/group_position_update', authenticateToken, async (req, res) => { console.log("group_position_update request for user:", req.user); try { const { groupId, newPos } = req.body; if (!groupId || newPos === undefined) { return res.status(400).json({ error: 'Group ID and position are required' }); } // Get all peripherals in the group with their device info const { rows: peripherals } = await pool.query(` SELECT p.id, p.peripheral_number, p.device_id FROM group_peripherals gp JOIN peripherals p ON gp.peripheral_id = p.id JOIN groups g ON gp.group_id = g.id WHERE g.id = $1 AND g.user_id = $2 `, [groupId, req.user]); if (peripherals.length === 0) { return res.status(404).json({ error: 'Group not found or empty' }); } // Group peripherals by device to send commands efficiently const deviceMap = new Map(); peripherals.forEach(p => { if (!deviceMap.has(p.device_id)) { deviceMap.set(p.device_id, []); } deviceMap.get(p.device_id).push({ periphNum: p.peripheral_number, periphID: p.id, pos: newPos }); }); // Schedule position change jobs for each device const jobPromises = Array.from(deviceMap.entries()).map(([deviceId, changedPosList]) => agenda.now('posChange', { deviceID: deviceId, changedPosList, userID: req.user }) ); await Promise.all(jobPromises); res.status(202).json({ success: true, message: 'Group position update accepted', peripherals_updated: peripherals.length }); } catch (error) { console.error("Error in /group_position_update:", error); res.status(500).json({ error: 'Internal Server Error' }); } }); app.post('/add_group_schedule', authenticateToken, async (req, res) => { console.log("add_group_schedule"); try { const { groupId, newPos, time, daysOfWeek } = req.body; if (!groupId || newPos === undefined || !time || !daysOfWeek || !Array.isArray(daysOfWeek)) { return res.status(400).json({ error: 'Missing required fields' }); } // Verify group belongs to user const {rows: groupRows} = await pool.query( 'SELECT id FROM groups WHERE id=$1 AND user_id=$2', [groupId, req.user] ); if (groupRows.length === 0) { return res.status(404).json({ error: 'Group not found' }); } // Check for duplicate schedule const cronExpression = createCronExpression(time, daysOfWeek); const existingJobs = await agenda.jobs({ name: 'groupPosChangeScheduled', 'data.groupID': groupId, 'data.userID': req.user }); for (const existingJob of existingJobs) { if (existingJob.attrs.repeatInterval === cronExpression && existingJob.attrs.data.newPos === newPos) { return res.status(409).json({ error: 'Duplicate schedule already exists' }); } } // Create the job const job = await agenda.create('groupPosChangeScheduled', { groupID: groupId, newPos, userID: req.user }); job.repeatEvery(cronExpression, { timezone: 'America/New_York', skipImmediate: true }); await job.save(); res.status(201).json({ success: true, message: 'Group schedule created successfully', jobId: job.attrs._id }); } catch (error) { console.error('Error creating group schedule:', error); res.status(500).json({ error: 'Internal server error' }); } }); app.post('/delete_group_schedule', authenticateToken, async (req, res) => { console.log("delete_group_schedule"); try { const { jobId } = req.body; if (!jobId) { return res.status(400).json({ error: 'Missing jobId' }); } const job = await findUserScheduleJob(jobId, req.user); if (!job) { return res.status(404).json({ error: 'Schedule not found' }); } await job.remove(); res.status(200).json({ success: true, message: 'Group schedule deleted successfully' }); } catch (error) { console.error('Error deleting group schedule:', error); res.status(500).json({ error: 'Internal server error' }); } }); app.post('/update_group_schedule', authenticateToken, async (req, res) => { console.log("update_group_schedule"); try { const { jobId, newPos, time, daysOfWeek } = req.body; if (!jobId || newPos === undefined || !time || !daysOfWeek) { return res.status(400).json({ error: 'Missing required fields' }); } const job = await findUserScheduleJob(jobId, req.user); if (!job) { return res.status(404).json({ error: 'Schedule not found' }); } const groupId = job.attrs.data.groupID; const cronExpression = createCronExpression(time, daysOfWeek); // Check for duplicates excluding current job const existingJobs = await agenda.jobs({ name: 'groupPosChangeScheduled', 'data.groupID': groupId, 'data.userID': req.user, _id: { $ne: new ObjectId(jobId) } }); for (const existingJob of existingJobs) { if (existingJob.attrs.repeatInterval === cronExpression && existingJob.attrs.data.newPos === newPos) { return res.status(409).json({ error: 'Duplicate schedule already exists' }); } } // Update job job.attrs.data.newPos = newPos; job.repeatEvery(cronExpression, { timezone: 'America/New_York', skipImmediate: true }); await job.save(); res.status(200).json({ success: true, message: 'Group schedule updated successfully' }); } catch (error) { console.error('Error updating group schedule:', error); res.status(500).json({ error: 'Internal server error' }); } }); app.post('/group_schedule_list', authenticateToken, async (req, res) => { try { const { groupId } = req.body; if (!groupId) { return res.status(400).json({ error: 'Missing groupId' }); } // Verify group belongs to user const {rows: groupRows} = await pool.query( 'SELECT id FROM groups WHERE id=$1 AND user_id=$2', [groupId, req.user] ); if (groupRows.length === 0) { return res.status(404).json({ error: 'Group not found' }); } const jobs = await agenda.jobs({ name: 'groupPosChangeScheduled', 'data.groupID': groupId, 'data.userID': req.user }); const scheduledUpdates = jobs.map(job => { const interval = cronParser.parseExpression(job.attrs.repeatInterval); const schedule = { minutes: interval.fields.minute, hours: interval.fields.hour, daysOfWeek: interval.fields.dayOfWeek }; return { id: job.attrs._id, pos: job.attrs.data.newPos, schedule }; }); res.status(200).json({ scheduledUpdates }); } catch (error) { console.error('Error fetching group schedules:', error); res.status(500).json({ error: 'Internal server error' }); } });