{h}
● {i.type}	{i.vcpu}	{i.mem}	0 ? "var(--text-warning)" : "var(--text-dim)", }} > {i.gpu > 0 ? `${i.gpu}× ${i.gpuType} (${i.gpuMem}GB)` : "—"}	{i.net}	{i.price.toFixed(2)}

{h}

● {i.type}

{i.vcpu}

{i.mem}

0 ? "var(--text-warning)" : "var(--text-dim)", }} > {i.gpu > 0 ? `${i.gpu}× ${i.gpuType} (${i.gpuMem}GB)` : "—"}

{i.net}

{i.price.toFixed(2)}

{content} {measured !== null && (

)}

, document.body, ); })(); if (children) { return ( setBtnRect(null)} style={{ display: "inline-flex" }} > {children} {popup} ); } return ( {popup} ); } /* ── LiveTerminal ── */ function LiveTerminal({ lines, isRunning, title, style, bare }) { const scrollRef = useRef(null); useEffect(() => { const el = scrollRef.current; if (!el) return; const isNearBottom = el.scrollHeight - el.scrollTop - el.clientHeight < 50; if (isNearBottom) el.scrollTop = el.scrollHeight; }, [lines]); const clsColor = { dim: "var(--text-dim)", cmd: "var(--text-success)", ok: "var(--text-success)", info: "var(--text-secondary)", err: "var(--text-danger)", warn: "var(--text-warning)", done: "var(--text-success)", addr: "var(--text-accent)", }; const content = (

{lines.map((line, i) => (

{line.text}

))} {isRunning && ( ▌ )}

); if (bare) { return (

{content}

); } return (

{title || "OpenGRIS Scaler — deploy log"}

{content}

); } /* ── SchedulerLogTerminal ── */ const POLL_INTERVALS = [ { label: "15s", value: 15000 }, { label: "30s", value: 30000 }, { label: "1m", value: 60000 }, { label: "5m", value: 300000 }, ]; function SchedulerLogTerminal({ instanceId, region, credentials, isActive }) { const [lines, setLines] = useState([]); const [status, setStatus] = useState("idle"); const [errorMsg, setError] = useState(null); const [intervalMs, setIntervalMs] = useState(15000); const [nextFetchAt, setNextFetchAt] = useState(null); const [countdown, setCountdown] = useState(null); const [fetching, setFetching] = useState(false); const pollRef = useRef(null); const triggerRef = useRef(null); const intervalMsRef = useRef(intervalMs); const byteOffsetRef = useRef(0); const pendingPartialRef = useRef(""); const credentialsRef = useRef(credentials); credentialsRef.current = credentials; useEffect(() => { intervalMsRef.current = intervalMs; }, [intervalMs]); const fetchLogs = useCallback(async () => { try { const ssm = new AWS.SSM({ region, credentials: new AWS.Credentials( credentialsRef.current.accessKeyId, credentialsRef.current.secretKey, ), }); const command = `tail -c +$((${byteOffsetRef.current}+1)) /var/log/scaler.log 2>/dev/null`; let commandId; try { const r = await ssm .sendCommand({ InstanceIds: [instanceId], DocumentName: "AWS-RunShellScript", Parameters: { commands: [command] }, TimeoutSeconds: 30, }) .promise(); commandId = r.Command.CommandId; } catch (err) { if (err.code === "InvalidInstanceId") { setLines([{ text: "Instance not yet registered with SSM — retrying...", cls: "warn" }]); } else if (err.code === "AccessDeniedException") { setStatus("error"); setError("Permission denied. Your IAM user needs ssm:SendCommand and ssm:GetCommandInvocation."); } else if ( err.code === "InvalidClientTokenId" || err.code === "AuthFailure" || /invalid.*token/i.test(err.message) ) { setStatus("error"); setError("Invalid AWS credentials. Re-enter your Access Key ID and Secret Access Key in the Configuration tab."); } else { setStatus("error"); setError("SSM error: " + err.message); } return false; } for (let i = 0; i < 12; i++) { await new Promise((r) => setTimeout(r, 2500)); try { const inv = await ssm .getCommandInvocation({ CommandId: commandId, InstanceId: instanceId }) .promise(); if (inv.Status === "Success" || inv.Status === "Failed") { const output = inv.StandardOutputContent || ""; if (output) { const isFirstContent = byteOffsetRef.current === 0; byteOffsetRef.current += output.length; const chunks = (pendingPartialRef.current + output).split("\n"); pendingPartialRef.current = chunks.pop(); const newLines = chunks.map((text) => ({ text, cls: "info" })); setLines((prev) => (isFirstContent ? newLines : [...prev, ...newLines])); return true; } if (byteOffsetRef.current === 0) { setLines([{ text: "Waiting for log file...", cls: "warn" }]); } return false; } } catch (_) { break; } } return false; } catch (_) { return false; } }, [instanceId, region]); const hasCredentials = credentials.accessKeyId && credentials.secretKey; useEffect(() => { byteOffsetRef.current = 0; pendingPartialRef.current = ""; setLines([]); setStatus("idle"); }, [instanceId, hasCredentials]); useEffect(() => { if (!isActive || !instanceId || !hasCredentials) return; setStatus("polling"); let cancelled = false; const run = async () => { if (cancelled) return; setFetching(true); setNextFetchAt(null); const hadContent = await fetchLogs(); if (cancelled) return; setFetching(false); if (hadContent) { pollRef.current = setTimeout(run, 0); } else { const ms = intervalMsRef.current; setNextFetchAt(Date.now() + ms); setCountdown(Math.round(ms / 1000)); pollRef.current = setTimeout(run, ms); } }; triggerRef.current = () => { clearTimeout(pollRef.current); run(); }; run(); return () => { cancelled = true; clearTimeout(pollRef.current); triggerRef.current = null; }; }, [isActive, instanceId, hasCredentials, fetchLogs, intervalMs]); useEffect(() => { if (!nextFetchAt) { setCountdown(null); return; } const tick = setInterval(() => { setCountdown(Math.max(0, Math.round((nextFetchAt - Date.now()) / 1000))); }, 1000); return () => clearInterval(tick); }, [nextFetchAt]); if (!hasCredentials) return (

Re-enter your AWS credentials in the Configuration tab to view scheduler logs.

); if (status === "error") return (

{errorMsg}

); const labelMs = POLL_INTERVALS.find((o) => o.value === intervalMs)?.label ?? "15s"; const hasLogContent = lines.some((line) => line.cls === "info"); return (

/var/log/scaler.log · refresh every {(fetching || countdown !== null) && ( <> · {fetching ? "refreshing..." : `next refresh in ${countdown}s`} )}

); } /* ── WorkerManagerTypeSelect ── */ const WM_TYPE_DEFS = [ { value: "orb_aws_ec2", label: "AWS EC2", badge: "AWS", desc: "Managed EC2 instances via ORB worker manager", }, { value: "oci_raw", label: "OCI Container Instance", badge: "OCI", desc: "Oracle Cloud Infrastructure - container instances via OCIR", }, { value: "aws_raw_ecs", label: "AWS ECS", badge: "AWS", desc: "Container tasks on Elastic Container Service", disabled: true, }, { value: "aws_hpc", label: "AWS Batch", badge: "AWS", desc: "High-performance compute via AWS Batch", disabled: true, }, { value: "symphony", label: "IBM Spectrum Symphony", badge: "IBM", desc: "IBM Spectrum Symphony grid via soamapi", disabled: true, }, { value: "oci_hpc", label: "OCI HPC", badge: "OCI", desc: "Oracle Cloud Infrastructure - per-task container instance jobs", disabled: true, }, ]; function WorkerManagerTypeSelect({ value, onChange }) { const [open, setOpen] = useState(false); const triggerRef = useRef(null); const dropdownRef = useRef(null); const [dropdownStyle, setDropdownStyle] = useState({}); useEffect(() => { function handleClick(e) { if ( triggerRef.current && !triggerRef.current.contains(e.target) && dropdownRef.current && !dropdownRef.current.contains(e.target) ) setOpen(false); } document.addEventListener("mousedown", handleClick); return () => document.removeEventListener("mousedown", handleClick); }, []); const openDropdown = () => { if (!triggerRef.current) return; const r = triggerRef.current.getBoundingClientRect(); setDropdownStyle({ position: "fixed", top: r.bottom + 4, left: r.left, minWidth: r.width, }); setOpen(true); }; const selected = WM_TYPE_DEFS.find((t) => t.value === value); return (

{open && ReactDOM.createPortal(

{WM_TYPE_DEFS.map((t) => (

{ if (!t.disabled) { onChange(t.value); setOpen(false); } }} style={{ padding: "9px 12px", cursor: t.disabled ? "not-allowed" : "pointer", display: "flex", alignItems: "center", gap: 10, opacity: t.disabled ? 0.4 : 1, background: t.value === value ? "rgba(0,200,224,0.08)" : "transparent", borderBottom: "1px solid rgba(255,255,255,0.04)", }} onMouseEnter={(e) => { if (!t.disabled && t.value !== value) e.currentTarget.style.background = "var(--bg-surface)"; }} onMouseLeave={(e) => { if (!t.disabled && t.value !== value) e.currentTarget.style.background = "transparent"; }} > {t.badge} {t.label} {t.desc} {t.value === value && ( ✓ )} {t.disabled && ( Soon )}

))}

, document.body, )}

); } /* ── PolicyDropdown ── */ const POLICY_OPTIONS = [ { value: "simple", label: "Load Balancer", desc: "Distributes tasks evenly across all configured worker managers.", }, { value: "waterfall_v1", label: "Waterfall", desc: "Fills worker managers in priority order, spilling to the next only when the current is saturated.", }, { value: null, label: "Lowest Cost (greedy)", desc: "Routes tasks to the cheapest available worker manager. Not yet implemented.", disabled: true, }, ]; function PolicyDropdown({ value, onChange }) { const [open, setOpen] = useState(false); const triggerRef = useRef(null); const dropdownRef = useRef(null); const [dropdownStyle, setDropdownStyle] = useState({}); useEffect(() => { function handleClick(e) { if ( triggerRef.current && !triggerRef.current.contains(e.target) && dropdownRef.current && !dropdownRef.current.contains(e.target) ) setOpen(false); } function handleScroll() { setOpen(false); } document.addEventListener("mousedown", handleClick); document.addEventListener("scroll", handleScroll, true); return () => { document.removeEventListener("mousedown", handleClick); document.removeEventListener("scroll", handleScroll, true); }; }, []); const openDropdown = () => { if (!triggerRef.current) return; const r = triggerRef.current.getBoundingClientRect(); setDropdownStyle({ position: "fixed", top: r.bottom + 4, left: r.left, width: r.width }); setOpen(true); }; const selected = POLICY_OPTIONS.find((o) => o.value === value) || POLICY_OPTIONS[0]; return (

{open && ReactDOM.createPortal(

{POLICY_OPTIONS.map((opt) => (

{ if (!opt.disabled) { onChange(opt.value); setOpen(false); } }} style={{ padding: "10px 12px", cursor: opt.disabled ? "not-allowed" : "pointer", background: opt.value === value ? "rgba(0,200,224,0.08)" : "transparent", borderBottom: "1px solid rgba(255,255,255,0.04)", opacity: opt.disabled ? 0.45 : 1, }} onMouseEnter={(e) => { if (!opt.disabled && opt.value !== value) e.currentTarget.style.background = "var(--bg-surface)"; }} onMouseLeave={(e) => { if (!opt.disabled && opt.value !== value) e.currentTarget.style.background = "transparent"; }} >

{opt.label} {opt.value === value && ( ✓ )}

{opt.desc}

))}

, document.body )}

); } Object.assign(window, { SecretInput, RegionSelect, OciRegionSelect, OciShapeSelect, InstancePicker, TerminalWindow, DeployDetails, HelpTip, LiveTerminal, SchedulerLogTerminal, WorkerManagerTypeSelect, PolicyDropdown, });