release: v0.9.1-beta2

VERSION

@@ -1 +1 @@
-0.9.1-beta1
+0.9.1-beta2

kobrax_client.py

@@ -124,6 +124,10 @@ class KobraXClient:
         return (f"anycubic/anycubicCloud/v1/slicer/printer/"
                 f"{self.mode_id}/{self.device_id}/{msg_type}")
 
+    def _web_topic(self, msg_type: str) -> str:
+        return (f"anycubic/anycubicCloud/v1/web/printer/"
+                f"{self.mode_id}/{self.device_id}/{msg_type}")
+
     def _sub_topic(self) -> str:
         return (f"anycubic/anycubicCloud/v1/printer/public/"
                 f"{self.mode_id}/{self.device_id}/#")
@@ -345,6 +349,23 @@ class KobraXClient:
             return None
         return entry["result"]
 
+    def publish_web(self, msg_type: str, action: str, data=None) -> None:
+        """Fire-and-forget publish on the web/printer topic (used for runtime updates during print)."""
+        msgid   = str(uuid.uuid4())
+        payload = json.dumps({
+            "type":      msg_type,
+            "action":    action,
+            "msgid":     msgid,
+            "timestamp": int(time.time() * 1000),
+            "data":      data,
+        }, separators=(",", ":"))
+        topic = self._web_topic(msg_type)
+        try:
+            with self._lock:
+                self._sock.sendall(_build_publish(topic, payload))
+        except Exception as e:
+            print(f"[kobrax] web send error: {e}")
+
     # -- High-level commands -------------------------------------------------
 
     def query_info(self) -> dict | None:

kobrax_moonraker_bridge.py

@@ -82,6 +82,7 @@ class KobraXBridge:
             "fan_speed":          0,
             "light_on":           False,
             "light_brightness":   80,
+            "taskid":             "-1",
         }
         self._ams_slots: list[dict] = []
         self._ams_loaded_slot: int = -1
@@ -125,6 +126,8 @@ class KobraXBridge:
             self._state["curr_layer"] = d["curr_layer"]
         if "total_layers" in d:
             self._state["total_layers"] = d["total_layers"]
+        if "taskid" in d:
+            self._state["taskid"] = str(d["taskid"])
         self._push_status_update()
 
     def _on_info(self, payload: dict):
@@ -1642,18 +1645,29 @@ function toggleCam(){if(camOn)camStop();else camStart()}
         nozzle = body.get("nozzle")
         bed    = body.get("bed")
         loop = asyncio.get_event_loop()
+        printing = self._state.get("print_state") == "printing"
+        if printing:
+            # During print: runtime update via web/printer topic, one setting at a time
+            taskid = self._state.get("taskid", "-1")
             if nozzle is not None:
                 n = int(float(nozzle))
-            await loop.run_in_executor(None, lambda: self.client.publish(
-                "tempature", "set",
-                {"type": 0, "target_nozzle_temp": n, "target_hotbed_temp": 0},
-                timeout=0
+                await loop.run_in_executor(None, lambda: self.client.publish_web(
+                    "print", "update",
+                    {"taskid": taskid, "settings": {"target_nozzle_temp": n}},
                 ))
             if bed is not None:
                 b = int(float(bed))
+                await loop.run_in_executor(None, lambda: self.client.publish_web(
+                    "print", "update",
+                    {"taskid": taskid, "settings": {"target_hotbed_temp": b}},
+                ))
+        else:
+            # Idle: standard tempature/set with both values
+            n = int(float(nozzle)) if nozzle is not None else int(self._state["nozzle_target"])
+            b = int(float(bed))    if bed    is not None else int(self._state["bed_target"])
             await loop.run_in_executor(None, lambda: self.client.publish(
                 "tempature", "set",
-                {"type": 1, "target_hotbed_temp": b, "target_nozzle_temp": 0},
+                {"target_nozzle_temp": n, "target_hotbed_temp": b},
                 timeout=0
             ))
         return web.json_response({"result": "ok"})