Update turbowarp-server/qr-converter.py

turbowarp-server/qr-converter.py

@@ -19,28 +19,34 @@ def get_var(name):
     try:
         value = tw.get_variable(name=name, name_literal=False)
         
-        # 様々な型を文字列に変換
+        # デバッグ用に生の値を出力
+        print(f"[DEBUG] Raw value of '{name}': {value} (type: {type(value).__name__})")
+        
+        # Noneの場合は"0"として扱う
         if value is None:
-            return None
-        elif isinstance(value, (int, float)):
+            print(f"[WARNING] Variable '{name}' is None, treating as '0'")
+            return "0"
+        
+        # 様々な型を文字列に変換
+        if isinstance(value, (int, float)):
             value = str(int(value))  # 浮動小数点の場合は整数に変換してから文字列に
-            print(f"[GET] Variable '{name}' converted from number to string")
+            print(f"[GET] Variable '{name}' converted from number to string: '{value}'")
         elif not isinstance(value, str):
             value = str(value)
-            print(f"[GET] Variable '{name}' converted from {type(value).__name__} to string")
+            print(f"[GET] Variable '{name}' converted from {type(value).__name__} to string: '{value}'")
         
         # 表示用に切り詰め
         display_value = value[:50] + "..." if len(value) > 50 else value
-        #print(f"[GET] Variable '{name}' = {display_value}")
+        print(f"[GET] Variable '{name}' = '{display_value}'")
         return value
     except Exception as e:
         print(f"[ERROR] Failed to get variable '{name}': {e}")
-        return None
+        return "0"  # エラー時も"0"を返す
 
 def set_var(name, value):
     try:
         tw.set_variable(name=name, value=value, name_literal=False)
-        print(f"[SET] Variable '{name}' = {value[:50]}..." if len(value) > 50 else f"[SET] Variable '{name}' = {value}")
+        print(f"[SET] Variable '{name}' = '{value[:50]}...'" if len(value) > 50 else f"[SET] Variable '{name}' = '{value}'")
         return True
     except Exception as e:
         print(f"[ERROR] Failed to set variable '{name}': {e}")
@@ -135,13 +141,25 @@ def split_packets(data, max_length=9998):
 # --- メインループ ---
 print("[INFO] Starting main loop...")
 last_processed_id = ""  # 最後に処理したIDを記録
+
+# 初期化時に変数をリセット
 set_var("n0", "0")
 set_var("n1", "0")
+time.sleep(1)  # 設定が反映されるのを待つ
+
 while True:
     try:
+        # 変数を取得
         n1 = get_var("n1")
         n0 = get_var("n0")
         
+        # デバッグ情報
+        print(f"[DEBUG] n0='{n0}', n1='{n1[:30]}...' if n1 and len(n1)>30 else n1")
+        
+        # n0が利用可能かチェック（厳密な比較）
+        is_n0_free = (n0 == "0")
+        print(f"[DEBUG] is_n0_free: {is_n0_free}")
+        
         # n1が存在し、長さが3以上で、先頭が"0"（新規リクエスト）
         if n1 and len(n1) >= 3 and n1[0] == "0":
             user_id = n1[1:3]  # ユーザーID（2桁）
@@ -149,6 +167,7 @@ while True:
             
             print(f"[INFO] Received request from user {user_id}")
             print(f"[INFO] Request data length: {len(request_data)}")
+            print(f"[INFO] Request data preview: {request_data[:50]}...")
             
             # 同じリクエストを繰り返し処理しないようにチェック
             if request_data == last_processed_id:
@@ -160,7 +179,7 @@ while True:
                 continue
             
             # n0が利用可能かチェック
-            if n0 == "0" or n0 is None:
+            if is_n0_free:
                 print("[INFO] n0 is free, starting processing...")
                 
                 # 処理中フラグをセット
@@ -172,7 +191,9 @@ while True:
                 
                 # プロンプトをデコード（先頭の"0" + ユーザーID(2桁)を除去）
                 encoded_prompt = request_data[3:]
+                print(f"[INFO] Encoded prompt length: {len(encoded_prompt)}")
                 prompt = decode_prompt(encoded_prompt)
+                print(f"[INFO] Decoded prompt: '{prompt}'")
                 
                 # 画像生成
                 img = generate_image(prompt)
@@ -181,7 +202,7 @@ while True:
                 # パケット分割
                 packets = split_packets(scratch_data)
                 
-                # 最初のパケットを送信
+                # パケット送信
                 for i, pkt in enumerate(packets):
                     print(f"[INFO] Sending packet {i+1}/{len(packets)}")
                     set_var("n1", "10" + pkt)
@@ -190,15 +211,17 @@ while True:
                         # 次のパケットのACKを待つ
                         print("[INFO] Waiting for ACK '11'...")
                         ack_timeout = 0
+                        ack_received = False
                         while ack_timeout < 50:  # 5秒タイムアウト
                             current_n1 = get_var("n1")
                             if current_n1 == "11":
                                 print("[INFO] Received ACK")
+                                ack_received = True
                                 break
                             time.sleep(0.3)
                             ack_timeout += 1
                         
-                        if ack_timeout >= 50:
+                        if not ack_received:
                             print("[ERROR] ACK timeout")
                             set_var("n0", "0")
                             break
@@ -206,28 +229,37 @@ while True:
                         # 最後のパケットは完了を待つ
                         print("[INFO] Waiting for completion '99'...")
                         complete_timeout = 0
+                        complete_received = False
                         while complete_timeout < 50:
                             current_n1 = get_var("n1")
                             if current_n1 == "99":
                                 print("[INFO] Received completion signal")
+                                complete_received = True
                                 break
                             time.sleep(0.3)
                             complete_timeout += 1
+                        
+                        if not complete_received:
+                            print("[ERROR] Completion timeout")
                 
                 # 完了後リセット
                 print("[INFO] Transmission complete. Resetting n0.")
                 set_var("n0", "0")
                 last_processed_id = request_data  # 処理済みとして記録
+                print(f"[INFO] Set last_processed_id to: {last_processed_id[:50]}...")
                 
             else:
                 print("[INFO] n0 is busy, waiting...")
         else:
-            # 何もしない
-            pass
+            # n1が条件を満たさない場合
+            if n1:
+                print(f"[DEBUG] n1 does not meet conditions: first char='{n1[0] if n1 else 'None'}', length={len(n1) if n1 else 0}")
+            else:
+                print("[DEBUG] n1 is None or empty")
             
     except Exception as e:
         print(f"[ERROR] Exception in main loop: {e}")
         import traceback
         traceback.print_exc()
     
-    time.sleep(0.2)
+    time.sleep(0.5)  # 少し長めの待機時間