File Manager

✏️ Edit File: /home/u625410797/domains/monothailand.com/public_html/ecotect_air/api/v1/programs/assign.php

<?php
// =============================================================================
// API: ASSIGN / UNASSIGN CONTROL PROGRAM TO DEVICE SLOT
// Method: POST (assign), DELETE (unassign)
// Description: Assigns a control program to a device slot
// Auth: JWT Required
// =============================================================================
header("Content-Type: application/json; charset=UTF-8");
header('Access-Control-Allow-Origin: *');
header('Access-Control-Allow-Methods: GET, POST, PUT, DELETE, OPTIONS');
header('Access-Control-Allow-Headers: Content-Type, Authorization, X-Api-Key');
require_once '../../../config.php';

if ($_SERVER['REQUEST_METHOD'] === 'OPTIONS') {
    http_response_code(200);
    exit;
}

if (!in_array($_SERVER['REQUEST_METHOD'], ['POST', 'DELETE'])) {
    Response::error(405, "Method Not Allowed");
}

$auth = Security::requireAuth();
$userId = $auth['user_id'] ?? $auth['id'] ?? null;

$input = json_decode(file_get_contents('php://input'), true);

if (!isset($input['slot_id'])) {
    Response::error(400, "Missing Parameter", "slot_id is required");
}

$slotId = Security::sanitize($input['slot_id']);

try {
    // Verify slot exists
    $slotStmt = $pdo->prepare("SELECT id, name FROM device_slots WHERE id = ?");
    $slotStmt->execute([$slotId]);
    $slot = $slotStmt->fetch();

if (!$slot) {
        Response::error(404, "Not Found", "Device slot not found");
    }

if ($_SERVER['REQUEST_METHOD'] === 'DELETE') {
        // UNASSIGN - remove program assignment
        $deleteStmt = $pdo->prepare("DELETE FROM device_program_assignments WHERE slot_id = ?");
        $deleteStmt->execute([$slotId]);

if ($deleteStmt->rowCount() === 0) {
            Response::error(404, "Not Found", "No program assignment found for this slot");
        }

// Queue command to device to clear program
        $cmdStmt = $pdo->prepare("INSERT INTO commands (slot_id, command, payload, status) VALUES (?, 'set_program', ?, 'pending')");
        $cmdStmt->execute([$slotId, json_encode(['action' => 'clear'])]);

Response::success([
            'slot_id' => $slotId,
            'command_id' => $pdo->lastInsertId()
        ], "Program unassigned successfully");

} else {
        // ASSIGN - set program for slot
        if (!isset($input['program_id'])) {
            Response::error(400, "Missing Parameter", "program_id is required");
        }

$programId = Security::sanitize($input['program_id']);

// Verify program exists
        $progStmt = $pdo->prepare("SELECT id, name, program_type, loop1_start_temp, loop2_saturation_duration, loop3_cut_duration FROM control_programs WHERE id = ?");
        $progStmt->execute([$programId]);
        $program = $progStmt->fetch();

if (!$program) {
            Response::error(404, "Not Found", "Control program not found");
        }

// Upsert assignment (INSERT ... ON DUPLICATE KEY UPDATE)
        $assignStmt = $pdo->prepare("
            INSERT INTO device_program_assignments (slot_id, program_id, assigned_by, assigned_at)
            VALUES (?, ?, ?, NOW())
            ON DUPLICATE KEY UPDATE
                program_id = VALUES(program_id),
                assigned_by = VALUES(assigned_by),
                assigned_at = NOW()
        ");
        $assignStmt->execute([$slotId, $programId, $userId]);

// [DECONSTRUCTION] Hardening: Validate parameters against bot-spec before queuing
        $pType = $program['program_type'];
        $l1 = (float)$program['loop1_start_temp'];
        $l2 = (int)$program['loop2_saturation_duration'];
        $l3 = (int)$program['loop3_cut_duration'];

// Guard: Prevent invalid program logic that could damage hardware
        if ($l1 < 5 || $l1 > 40) $l1 = 18.0; 
        if ($l2 < 60) $l2 = 900;
        if ($l3 < 30) $l3 = 180;

// Queue command to device with program parameters (Aligned with main.c)
        $payload = json_encode([
            'action' => 'set',
            'program_name' => $program['name'],
            'program_type' => $pType,
            'loop1_temp' => $l1,
            'loop2'      => $l2,
            'loop3_duration' => $l3
        ]);

$cmdStmt = $pdo->prepare("INSERT INTO commands (slot_id, command, payload, status) VALUES (?, 'set_program', ?, 'pending')");
        $cmdStmt->execute([$slotId, $payload]);

Response::success([
            'slot_id' => $slotId,
            'slot_name' => $slot['name'],
            'program_id' => $programId,
            'program_name' => $program['name'],
            'program_type' => $program['program_type'],
            'command_id' => $pdo->lastInsertId()
        ], "Program assigned successfully");
    }

} catch (Exception $e) {
    error_log("Program Assign Error: " . $e->getMessage());
    Response::error(500, "Database Error", $e->getMessage());
}
?>

Batal

⬅ Naik ke v1 7 item

Nama	Tipe	Ukuran	Diubah	Aksi
🐘assign.php	php	4.8 KB	2026-07-03 01:36	✏️ Edit 👁️ View
🐘bulk_assign.php	php	4.4 KB	2026-07-03 01:37	✏️ Edit 👁️ View
🐘create.php	php	7.3 KB	2026-07-03 01:37	✏️ Edit 👁️ View
🐘get.php	php	2.8 KB	2026-07-03 01:37	✏️ Edit 👁️ View
🐘get_assignment.php	php	2.8 KB	2026-07-03 01:37	✏️ Edit 👁️ View
🐘list.php	php	2.4 KB	2026-07-03 01:37	✏️ Edit 👁️ View
🐘reset.php	php	5 KB	2026-07-03 01:37	✏️ Edit 👁️ View