Spaces:
Sleeping
Sleeping
| import { fetchWithTimeout } from "../shared/api.js"; | |
| import { getStorageItem } from "../shared/dom.js"; | |
| const TOKEN_KEY = "byte_dashboard_admin_token"; | |
| const ACTION_QUEUE_ENDPOINT = "./api/action-queue"; | |
| const OPS_PLAYBOOKS_ENDPOINT = "./api/ops-playbooks"; | |
| const OPS_PLAYBOOKS_TRIGGER_ENDPOINT = "./api/ops-playbooks/trigger"; | |
| const REQUEST_TIMEOUT_MS = 12000; | |
| function authHeaders() { | |
| const headers = {}; | |
| const token = getStorageItem(TOKEN_KEY); | |
| if (token) { | |
| headers["X-Byte-Admin-Token"] = token; | |
| } | |
| return headers; | |
| } | |
| function normalizeChannelId(channelId) { | |
| return ( | |
| String(channelId || "") | |
| .trim() | |
| .toLowerCase() || "default" | |
| ); | |
| } | |
| export async function getActionQueue({ status = "", limit = 80 } = {}, timeoutMs = REQUEST_TIMEOUT_MS) { | |
| const params = new URLSearchParams(); | |
| if (String(status || "").trim()) { | |
| params.set("status", String(status).trim()); | |
| } | |
| params.set("limit", String(limit || 80)); | |
| const endpoint = `${ACTION_QUEUE_ENDPOINT}?${params.toString()}`; | |
| return await fetchWithTimeout(endpoint, { method: "GET", headers: authHeaders() }, timeoutMs); | |
| } | |
| export async function decideActionQueueItem(actionId, decision, note = "", timeoutMs = REQUEST_TIMEOUT_MS) { | |
| const safeActionId = encodeURIComponent(String(actionId || "").trim()); | |
| return await fetchWithTimeout( | |
| `${ACTION_QUEUE_ENDPOINT}/${safeActionId}/decision`, | |
| { | |
| method: "POST", | |
| headers: authHeaders(), | |
| body: JSON.stringify({ | |
| decision: String(decision || "").trim().toLowerCase(), | |
| note: String(note || "").trim(), | |
| }), | |
| }, | |
| timeoutMs | |
| ); | |
| } | |
| export async function getOpsPlaybooks(channelId = "default", timeoutMs = REQUEST_TIMEOUT_MS) { | |
| const params = new URLSearchParams({ | |
| channel: normalizeChannelId(channelId), | |
| }); | |
| return await fetchWithTimeout( | |
| `${OPS_PLAYBOOKS_ENDPOINT}?${params.toString()}`, | |
| { method: "GET", headers: authHeaders() }, | |
| timeoutMs | |
| ); | |
| } | |
| export async function triggerOpsPlaybook( | |
| { playbookId = "", channelId = "default", reason = "manual_dashboard", force = false } = {}, | |
| timeoutMs = REQUEST_TIMEOUT_MS | |
| ) { | |
| return await fetchWithTimeout( | |
| OPS_PLAYBOOKS_TRIGGER_ENDPOINT, | |
| { | |
| method: "POST", | |
| headers: authHeaders(), | |
| body: JSON.stringify({ | |
| playbook_id: String(playbookId || "").trim().toLowerCase(), | |
| channel_id: normalizeChannelId(channelId), | |
| reason: String(reason || "manual_dashboard").trim(), | |
| force: Boolean(force), | |
| }), | |
| }, | |
| timeoutMs | |
| ); | |
| } | |