Update turbowarp-server/qr-converter.py

turbowarp-server/qr-converter.py

@@ -1,164 +1,83 @@
-import scratchcommunication
 import time
 import requests
-import string
-import traceback
+import scratchcommunication
 
-PROJECT_ID = "1293030706"
-USERNAME = "server"
-CONTACT = "contact"
+PROJECT_ID = 1293030706
 
 tw = scratchcommunication.TwCloudConnection(
     project_id=PROJECT_ID,
-    username=USERNAME,
-    contact_info=CONTACT
+    username="server",
+    contact_info="contact"
 )
 
-# ---------------------
-# 文字テーブル
-# ---------------------
-CHARS = list(string.digits + string.ascii_lowercase)
-CHAR_TO_NUM = {c: i for i, c in enumerate(CHARS)}
-NUM_TO_CHAR = {i: c for i, c in enumerate(CHARS)}
-
-# ---------------------
-# 文字列エンコード / デコード
-# ---------------------
-def encode(text):
-    try:
-        out = ""
-        for c in text:
-            out += f"{CHAR_TO_NUM[c]:02d}"
-        return out
-    except Exception as e:
-        print(f"[ERROR] encode('{text}') failed: {e}")
-        traceback.print_exc()
-        return "00"
+# 文字→数値変換（a-z0-9 → 00-35）
+def encode_short_id(short_id):
+    chars = "abcdefghijklmnopqrstuvwxyz0123456789"
+    result = ""
+    for c in short_id:
+        index = chars.index(c)
+        result += f"{index:02d}"
+    return result
 
-def decode(data):
-    try:
-        out = ""
-        for i in range(0, len(data), 2):
-            num = int(data[i:i+2])
-            out += NUM_TO_CHAR.get(num, "0")
-        return out
-    except Exception as e:
-        print(f"[ERROR] decode('{data}') failed: {e}")
-        traceback.print_exc()
-        return "0"
-
-# ---------------------
-# クラウド変数操作
-# ---------------------
-def get_var(name):
-    try:
-        return tw.get_variable(name=name, name_literal=False)
-    except Exception:
-        return None
 
-def set_var(name, value):
-    try:
-        tw.set_variable(name=name, value=value, name_literal=False)
-    except Exception as e:
-        print(f"[ERROR] set_var('{name}', '{value}') failed: {e}")
-        traceback.print_exc()
-
-# ---------------------
-# n0管理
-# ---------------------
-def n0_is_free():
-    v = get_var("n0")
-    return v in [None, "0"]
-
-def set_n0(value):
-    set_var("n0", str(value))
-
-# ---------------------
-# データ送受信
-# ---------------------
-SLOT = "n1"
-buffers = {}
-
-def send(slot, text):
-    encoded = encode(text)
-    size = 99996
-    packets = [encoded[i:i+size] for i in range(0, len(encoded), size)]
-    total = len(packets)
-
-    for p in packets:
-        packet = f"1{total}0{p}"
-        start = time.time()
-        set_var(slot, packet)
-
-        while True:
-            v = get_var(slot)
-            if v and len(v) > 2 and v[2] == "1":
-                break
-            if time.time() - start > 10:
-                print(f"[WARN] send timeout for slot '{slot}'")
-                break
-            time.sleep(0.1)
-
-def receive(slot):
-    v = get_var(slot)
-    if not v or len(v) < 3:
-        return None
-
-    if v[0] != "0" or v[2] != "0":
-        return None
+last_n1 = None
 
+while True:
     try:
-        total = int(v[1])
-    except Exception as e:
-        print(f"[ERROR] Invalid total in slot '{slot}': {v}")
-        traceback.print_exc()
-        return None
+        n1 = str(tw.get_variable("n1"))
 
-    data = v[3:]
-    newv = v[:2] + "1" + v[3:]
-    set_var(slot, newv)
+        # 変化検知
+        if n1 != last_n1:
+            last_n1 = n1
 
-    if slot not in buffers:
-        buffers[slot] = []
+            # 最低3桁必要
+            if len(n1) < 3:
+                continue
 
-    buffers[slot].append(data)
+            mode = n1[0]  # 0 or 1
+            read_flag = n1[1]
 
-    if len(buffers[slot]) < total:
-        return None
+            # ---------------------------
+            # 📥 Scratch → サーバー
+            # ---------------------------
+            if mode == "0" and read_flag == "0":
+                # 使用中フラグ
+                tw.set_variable("n0", 1)
 
-    joined = "".join(buffers[slot])
-    buffers[slot] = []
-    return decode(joined)
+                # ID取得
+                recv_id = n1[2:]
+                print("受信ID:", recv_id)
 
-# ---------------------
-# メインループ
-# ---------------------
-while True:
-    try:
-        if n0_is_free():
-            received_id = receive(SLOT)
-            if received_id:
-                print(f"[INFO] Received ID: {received_id}")
-                set_n0(1)
-
-                try:
-                    url = f"https://20.rf.gd/set.php?project_id={received_id}"
-                    r = requests.get(url, timeout=10)
-                    r.raise_for_status()
-                    response_json = r.json()
-                    short_id = response_json.get("short_id", "0")
-                    print(f"[INFO] Server response short_id: {short_id}")
-                    send(SLOT, short_id)
-
-                except Exception as e:
-                    print(f"[ERROR] Server request failed for ID '{received_id}': {e}")
-                    traceback.print_exc()
-                    send(SLOT, "0")
-
-                set_n0(0)
+                # 既読に変更
+                tw.set_variable("n1", "0" + "1" + recv_id)
 
-    except Exception as e:
-        print(f"[ERROR] Main loop iteration failed: {e}")
-        traceback.print_exc()
+                # APIアクセス
+                url = f"https://20.rf.gd/set.php?project_id={recv_id}"
+                res = requests.get(url)
+                data = res.json()
+
+                short_id = data.get("short_id", "")
+                print("short_id:", short_id)
 
-    time.sleep(0.2)
+                # エンコード
+                encoded = encode_short_id(short_id)
+
+                # ---------------------------
+                # 📤 サーバー → Scratch
+                # ---------------------------
+                # 未読で送信
+                tw.set_variable("n1", "1" + "0" + encoded)
+
+            # ---------------------------
+            # 📬 既読検知（Scratch側）
+            # ---------------------------
+            elif mode == "1" and read_flag == "1":
+                # 使用終了
+                tw.set_variable("n0", 0)
+                print("通信終了")
+
+        time.sleep(0.2)
+
+    except Exception as e:
+        print("エラー:", e)
+        time.sleep(1)