From b1ce1927022d374198441afafeb27199fc8a052a Mon Sep 17 00:00:00 2001
From: eunhhu <necpition205@gmail.com>
Date: Thu, 24 Sep 2026 17:14:54 +0100
Subject: Establish native micro runtime checkpoint

---
 prototypes/workbench/remote.mjs | 89 +++++++++++++++++++++++++++++++++++++++++
 1 file changed, 89 insertions(+)
 create mode 100644 prototypes/workbench/remote.mjs

(limited to 'prototypes/workbench/remote.mjs')

diff --git a/prototypes/workbench/remote.mjs b/prototypes/workbench/remote.mjs
new file mode 100644
index 0000000..6ee6a59
--- /dev/null
+++ b/prototypes/workbench/remote.mjs
@@ -0,0 +1,89 @@
+import http from 'node:http';
+import { MAX_PROJECT_BYTES, parseProject } from './web/project.mjs';
+
+const maxRevision = 9223372036854775807n;
+function revisionText(value, allowZero = false) {
+  if (typeof value !== 'string' || !/^(0|[1-9]\d*)$/.test(value) ||
+      value.length > 19 || BigInt(value) > maxRevision || (!allowZero && value === '0'))
+    throw new Error('revision은 범위 안의 정수 문자열이어야 합니다.');
+  return value;
+}
+
+export function remoteTarget(base, key) {
+  const url = new URL(base);
+  if (url.protocol !== 'http:' || !['127.0.0.1', 'localhost'].includes(url.hostname) ||
+      url.username || url.password || url.pathname !== '/' || url.search || url.hash)
+    throw new Error('현재 연결 호스트는 로컬 http://127.0.0.1:PORT 형식을 사용합니다.');
+  if (!/^[A-Za-z0-9_-]{1,64}$/.test(key)) throw new Error('작업물 이름은 영문·숫자·_·- 1~64자입니다.');
+  url.hostname = '127.0.0.1';
+  url.pathname = `/objects/${key}`;
+  return url;
+}
+
+function request(url, method, body, headers = {}) {
+  return new Promise((resolve, reject) => {
+    let done = false;
+    const finish = (error, value) => {
+      if (done) return;
+      done = true;
+      clearTimeout(deadline);
+      if (error) reject(error); else resolve(value);
+    };
+    const req = http.request(url, { method, agent: false, headers: { ...headers,
+      'Content-Length': body?.byteLength ?? 0, Connection: 'close' } }, (res) => {
+      const chunks = [];
+      let size = 0;
+      res.on('data', (chunk) => {
+        size += chunk.length;
+        if (size > MAX_PROJECT_BYTES) {
+          const error = new Error('서버 작업물이 허용 크기를 넘었습니다.');
+          finish(error);
+          res.destroy(error);
+          req.destroy(error);
+        } else chunks.push(chunk);
+      });
+      res.on('error', (error) => finish(error));
+      res.on('aborted', () => finish(new Error('응답이 완료되기 전에 연결이 끊겼습니다.')));
+      res.on('end', () => {
+        if (res.statusCode !== 200) {
+          const error = new Error(`원격 작업 실패: ${res.statusCode} ${res.headers['x-pure-error'] ?? ''}`.trim());
+          error.status = res.statusCode;
+          error.etag = res.headers.etag;
+          finish(error);
+          return;
+        }
+        try {
+          const match = /^"([1-9]\d*)"$/.exec(res.headers.etag ?? '');
+          if (!match) throw new Error('서버의 revision 응답이 올바르지 않습니다.');
+          const revision = revisionText(match[1]);
+          finish(null, { revision, bytes: Buffer.concat(chunks, size) });
+        } catch (error) { finish(error); }
+      });
+    });
+    const deadline = setTimeout(() => {
+      const error = new Error('원격 작업 시간 초과: 저장 완료 여부는 다시 확인해야 합니다.');
+      finish(error);
+      req.destroy(error);
+    }, 12000);
+    req.on('error', (error) => finish(error));
+    req.end(body);
+  });
+}
+
+export async function pushProject(target, expected, project) {
+  revisionText(expected, true);
+  const text = JSON.stringify(project);
+  parseProject(text);
+  const body = Buffer.from(text, 'utf8');
+  const headers = expected === '0' ? { 'If-None-Match': '*' } : { 'If-Match': `"${expected}"` };
+  const result = await request(target, 'PUT', body, headers);
+  return result.revision;
+}
+
+export async function pullProject(target) {
+  const result = await request(target, 'GET');
+  const text = new TextDecoder('utf-8', { fatal: true }).decode(result.bytes);
+  const project = parseProject(text);
+  if (project.version !== 2) throw new Error('현재 배치를 포함한 version 2 작업물이 필요합니다.');
+  return { project, revision: result.revision };
+}
-- 
cgit v1.2.3