- ioBroker Community Home
- Deutsch
- ioBroker Allgemein
- Adapter Klipper-Moonraker
NEWS
Adapter Klipper-Moonraker
-
Ich war so frei und habe eine Scriptversion gebsatelt.
Die Dezimaldaten werden direkt konvertiert sodas direkt lesbare Datenpunkte entstehen.
Das ganze kann als Script in iobroker verwendet werden.
Einfach Moonraker ip anpassen, ggf Alexa ID anpassen.
Der Code darf gerne ganz oder Teilweise für den Adapter genutzt werden.// ======== CONFIG ======== const MOONRAKER_HOST = "192.168.1.160"; const MOONRAKER_PORT = 7125; const BASE = `http://${MOONRAKER_HOST}:${MOONRAKER_PORT}`; const POLL_MS = 10_000; // Ablagepfad in ioBroker const ROOT = "javascript.0.moonraker.Kossel"; // Optional: Testfunktion (Alexa-Ansage jede Minute) const ENABLE_TEST_SPEAK = false; // ← bei Bedarf auf true const ALEXA_SPEAK_DP = "alexa2.0.Echo-Devices.IDANPASSEN.Commands.speak"; // Deine Echo-ID einsetzen const TEST_MESSAGE = "Moonraker Script Test läuft."; // ======== HELFER ======== // HTTP GET (Node.js Core) function httpGet(url, timeout = 5000) { return new Promise((resolve, reject) => { const http = require("http"); const req = http.get(url, (res) => { if (res.statusCode < 200 || res.statusCode >= 300) { reject(new Error(`HTTP ${res.statusCode} for ${url}`)); res.resume(); return; } let data = ""; res.setEncoding("utf8"); res.on("data", (chunk) => (data += chunk)); res.on("end", () => { try { resolve(JSON.parse(data)); } catch (e) { reject(new Error(`JSON parse error for ${url}: ${e.message}`)); } }); }); req.on("error", reject); req.setTimeout(timeout, () => { req.destroy(new Error(`Timeout after ${timeout}ms for ${url}`)); }); }); } // State-Helper async function ensureState(id, def) { if (!existsState(id)) { await createStateAsync(id, def, { role: def.common?.role || "state" }); } } async function writeNum(id, val, unit = "", role = "value") { await ensureState(id, { type: "number", read: true, write: false, def: 0, name: id.split(".").slice(-1)[0], role, unit }); setState(id, { val: Number(val), ack: true }); } async function writeStr(id, val, role = "text") { await ensureState(id, { type: "string", read: true, write: false, def: "", name: id.split(".").slice(-1)[0], role }); setState(id, { val: String(val ?? ""), ack: true }); } async function writeBool(id, val, role = "indicator") { await ensureState(id, { type: "boolean", read: true, write: false, def: false, name: id.split(".").slice(-1)[0], role }); setState(id, { val: !!val, ack: true }); } // Formatierungen / Konvertierungen function toPercent01(v) { if (v == null || isNaN(v)) return null; return Math.round(Number(v) * 1000) / 10; // 1 Nachkommastelle } function toHMS(seconds) { if (seconds == null || isNaN(seconds)) return ""; const s = Math.max(0, Math.floor(seconds)); const h = Math.floor(s / 3600); const m = Math.floor((s % 3600) / 60); const sec = s % 60; return `${String(h).padStart(2, "0")}:${String(m).padStart(2, "0")}:${String(sec).padStart(2, "0")}`; } function round1(v) { if (v == null || isNaN(v)) return null; return Math.round(Number(v) * 10) / 10; } // Dynamik-Cache für Objekte (Fans, Temp-Sensoren, etc.) let discovered = { fans: [], tempSensors: [], hasHeaterBed: false, hasExtruder: false, hasDisplayStatus: false, hasGcodeMove: false, hasVirtualSd: false, hasToolhead: false, hasPrintStats: false, lastDiscoveryTs: 0 }; async function discoverObjects() { try { const list = await httpGet(`${BASE}/printer/objects/list`); const raw = list?.result?.objects; let names = []; if (Array.isArray(raw)) { names = raw .map((o) => (typeof o === "string" ? o : (o && o.name) ? String(o.name) : "")) .filter((n) => typeof n === "string" && n.length > 0); } else if (raw && typeof raw === "object") { names = Object.keys(raw); } else { names = []; } const isStr = (n) => typeof n === "string" && n.length > 0; discovered.fans = names.filter((n) => isStr(n) && (n.startsWith("fan") || n.startsWith("heater_fan") || n.startsWith("controller_fan") || n.startsWith("fan_generic")) ); discovered.tempSensors = names.filter((n) => isStr(n) && (n.startsWith("temperature_sensor") || n.startsWith("temperature_fan") || n.startsWith("bme280") || n.startsWith("htu21d") || n.startsWith("lm75")) ); discovered.hasHeaterBed = names.includes("heater_bed"); discovered.hasExtruder = names.includes("extruder"); discovered.hasDisplayStatus = names.includes("display_status"); discovered.hasGcodeMove = names.includes("gcode_move"); discovered.hasVirtualSd = names.includes("virtual_sdcard"); discovered.hasToolhead = names.includes("toolhead"); discovered.hasPrintStats = names.includes("print_stats"); discovered.lastDiscoveryTs = Date.now(); await writeStr(`${ROOT}.meta.last_discovery`, new Date().toISOString()); await writeNum(`${ROOT}.meta.discovered.fans_count`, discovered.fans.length, "", "value"); await writeNum(`${ROOT}.meta.discovered.temp_sensors_count`, discovered.tempSensors.length, "", "value"); } catch (e) { log(`Moonraker discovery error: ${e.message}`, "warn"); } } function buildQueryParams() { const objs = ["print_stats"]; if (discovered.hasHeaterBed) objs.push("heater_bed"); if (discovered.hasExtruder) objs.push("extruder"); if (discovered.hasDisplayStatus) objs.push("display_status"); if (discovered.hasGcodeMove) objs.push("gcode_move"); if (discovered.hasVirtualSd) objs.push("virtual_sdcard"); if (discovered.hasToolhead) objs.push("toolhead"); if (discovered.hasPrintStats) objs.push("print_stats"); objs.push(...discovered.fans); objs.push(...discovered.tempSensors); const q = objs.map(encodeURIComponent).join("&"); return `${BASE}/printer/objects/query?${q}`; } // ======== REST DES POLLERS (pollOnce, Startup, Timer, etc.) ======== // Alexa-Ansage Tracking (Doppelansagen vermeiden) let lastPrintState = ""; let lastAnnouncedFile = ""; let lastAnnouncedTs = 0; const ANNOUNCE_COOLDOWN_MS = 5 * 60 * 1000; // 5 Minuten async function pollOnce() { try { // 1) Basisinfos const [serverInfo, printerInfo] = await Promise.all([ httpGet(`${BASE}/server/info`), httpGet(`${BASE}/printer/info`) ]); const s = serverInfo?.result || {}; await writeStr(`${ROOT}.server.version`, s.version || ""); await writeStr(`${ROOT}.server.klippy_state`, s.klippy_state || ""); await writeStr(`${ROOT}.server.hostname`, s.hostname || ""); await writeStr(`${ROOT}.server.websocket_address`, s.websocket_address || ""); const p = printerInfo?.result || {}; await writeStr(`${ROOT}.printer.state`, p.state || "unknown"); await writeBool(`${ROOT}.printer.ready`, p.state === "ready", "indicator.reachable"); // 2) Objekte ggf. alle 5 Min neu entdecken if (Date.now() - discovered.lastDiscoveryTs > 5 * 60 * 1000 || discovered.lastDiscoveryTs === 0) { await discoverObjects(); } // 3) Printer Objects abfragen const queryUrl = buildQueryParams(); const q = await httpGet(queryUrl); const res = q?.result?.status || {}; // ---- print_stats ---- let currentFilename = ""; let layerInfo = { current: null, total: null }; let metaFromFile = { layer_height: null, object_height: null }; if (res.print_stats) { const ps = res.print_stats; await writeStr(`${ROOT}.print_stats.state`, ps.state || ""); await writeStr(`${ROOT}.print_stats.filename`, ps.filename || ""); await writeStr(`${ROOT}.print_stats.message`, ps.message || ""); currentFilename = ps.filename || ""; // === Alexa-Ansage bei Fertigstellung === try { let shouldAnnounce = false; if ((ps.state || "") === "complete") { if (currentFilename) { if (currentFilename !== lastAnnouncedFile) { shouldAnnounce = true; lastAnnouncedFile = currentFilename; } } else if (lastPrintState !== "complete" && (Date.now() - lastAnnouncedTs) > ANNOUNCE_COOLDOWN_MS) { shouldAnnounce = true; } } if (shouldAnnounce) { const msg = currentFilename ? `Druckauftrag abgeschlossen: ${currentFilename}.` : "Der 3D Druck ist fertig."; setState(ALEXA_SPEAK_DP, { val: msg, ack: false }); // nutzt deinen Alexa-Datenpunkt lastAnnouncedTs = Date.now(); await writeStr(`${ROOT}.meta.last_completed_file`, currentFilename || ""); await writeStr(`${ROOT}.meta.last_announcement`, new Date().toISOString()); } lastPrintState = ps.state || ""; } catch (e) { log("Alexa-Fertig-Ansage fehlgeschlagen: " + e.message, "warn"); } if (ps.total_duration != null) await writeStr(`${ROOT}.print_stats.total_duration_hms`, toHMS(ps.total_duration), "time"); if (ps.print_duration != null) await writeStr(`${ROOT}.print_stats.print_duration_hms`, toHMS(ps.print_duration), "time"); if (ps.filament_used != null) { const m = Math.round((Number(ps.filament_used) || 0) / 10) / 100; // mm → m await writeNum(`${ROOT}.print_stats.filament_used_m`, m, "m", "value.length"); } if (ps.progress != null) { await writeNum(`${ROOT}.print_stats.progress_percent`, toPercent01(ps.progress), "%", "value.percent"); } // Layer bevorzugt aus print_stats.info (nur vorhanden, wenn Slicer SET_PRINT_STATS_INFO mitschreibt) const info = ps.info || {}; if (info.current_layer != null) layerInfo.current = Number(info.current_layer); if (info.total_layer != null) layerInfo.total = Number(info.total_layer); } // ---- toolhead (für Z→Layer-Fallback) ---- let zPos = null; if (res.toolhead) { const th = res.toolhead; if (Array.isArray(th.position)) { const [x, y, z] = th.position; zPos = (z != null ? Number(z) : null); await writeNum(`${ROOT}.toolhead.x`, round1(x), "mm", "value.length"); await writeNum(`${ROOT}.toolhead.y`, round1(y), "mm", "value.length"); await writeNum(`${ROOT}.toolhead.z`, round1(z), "mm", "value.length"); } if (th.max_velocity != null) await writeNum(`${ROOT}.toolhead.max_velocity`, round1(th.max_velocity), "mm/s", "value.speed"); if (th.max_accel != null) await writeNum(`${ROOT}.toolhead.max_accel`, round1(th.max_accel), "mm/s²", "value.acceleration"); if (th.homing_origin && Array.isArray(th.homing_origin)) { const [hx, hy, hz] = th.homing_origin; await writeNum(`${ROOT}.toolhead.homing_origin.x`, round1(hx), "mm", "value.length"); await writeNum(`${ROOT}.toolhead.homing_origin.y`, round1(hy), "mm", "value.length"); await writeNum(`${ROOT}.toolhead.homing_origin.z`, round1(hz), "mm", "value.length"); } if (th.print_time != null) await writeStr(`${ROOT}.toolhead.print_time_hms`, toHMS(th.print_time), "time"); } // ---- gcode_move ---- if (res.gcode_move) { const gm = res.gcode_move; if (gm.speed != null) await writeNum(`${ROOT}.gcode_move.speed`, round1(gm.speed), "mm/s", "value.speed"); if (gm.speed_factor != null) await writeNum(`${ROOT}.gcode_move.speed_factor_percent`, toPercent01(gm.speed_factor), "%", "value.percent"); if (gm.extrude_factor != null) await writeNum(`${ROOT}.gcode_move.extrude_factor_percent`, toPercent01(gm.extrude_factor), "%", "value.percent"); if (Array.isArray(gm.gcode_position)) { const [x, y, z, e] = gm.gcode_position; await writeNum(`${ROOT}.gcode_move.gcode_x`, round1(x), "mm", "value.length"); await writeNum(`${ROOT}.gcode_move.gcode_y`, round1(y), "mm", "value.length"); await writeNum(`${ROOT}.gcode_move.gcode_z`, round1(z), "mm", "value.length"); await writeNum(`${ROOT}.gcode_move.gcode_e`, round1(e), "mm", "value.length"); } } // ---- heater_bed ---- if (res.heater_bed) { const hb = res.heater_bed; if (hb.temperature != null) await writeNum(`${ROOT}.heater_bed.temperature`, round1(hb.temperature), "°C", "value.temperature"); if (hb.target != null) await writeNum(`${ROOT}.heater_bed.target`, round1(hb.target), "°C", "value.temperature"); if (hb.power != null) await writeNum(`${ROOT}.heater_bed.power_percent`, toPercent01(hb.power), "%", "value.percent"); } // ---- extruder ---- if (res.extruder) { const ex = res.extruder; if (ex.temperature != null) await writeNum(`${ROOT}.extruder.temperature`, round1(ex.temperature), "°C", "value.temperature"); if (ex.target != null) await writeNum(`${ROOT}.extruder.target`, round1(ex.target), "°C", "value.temperature"); if (ex.power != null) await writeNum(`${ROOT}.extruder.power_percent`, toPercent01(ex.power), "%", "value.percent"); if (ex.pressure_advance != null) await writeNum(`${ROOT}.extruder.pressure_advance`, round1(ex.pressure_advance), "", "value"); if (ex.smooth_time != null) await writeNum(`${ROOT}.extruder.smooth_time`, round1(ex.smooth_time), "s", "value.interval"); } // ---- virtual_sdcard ---- if (res.virtual_sdcard) { const vsd = res.virtual_sdcard; if (vsd.progress != null) await writeNum(`${ROOT}.virtual_sdcard.progress_percent`, toPercent01(vsd.progress), "%", "value.percent"); if (vsd.file_position != null) await writeNum(`${ROOT}.virtual_sdcard.file_position`, Number(vsd.file_position), "B", "value"); } // ---- display_status ---- if (res.display_status) { const ds = res.display_status; await writeStr(`${ROOT}.display_status.message`, ds.message || ""); if (ds.progress != null) await writeNum(`${ROOT}.display_status.progress_percent`, toPercent01(ds.progress), "%", "value.percent"); } // ---- Fans ---- for (const f of discovered.fans) { const key = f; const safeKey = key.replace(/\s+/g, "_"); const obj = res[key]; if (!obj) continue; if (obj.speed != null) await writeNum(`${ROOT}.fans.${safeKey}.speed_percent`, toPercent01(obj.speed), "%", "value.percent"); if (obj.rpm != null) await writeNum(`${ROOT}.fans.${safeKey}.rpm`, Number(obj.rpm), "rpm", "value"); } // ---- Temperatur-Sensoren ---- for (const t of discovered.tempSensors) { const key = t; const safeKey = key.replace(/\s+/g, "_"); const obj = res[key]; if (!obj) continue; if (obj.temperature != null) await writeNum(`${ROOT}.temp_sensors.${safeKey}.temperature`, round1(obj.temperature), "°C", "value.temperature"); if (obj.speed != null) await writeNum(`${ROOT}.temp_sensors.${safeKey}.speed_percent`, toPercent01(obj.speed), "%", "value.percent"); } // ---- Datei-Metadaten (Layer-Fallback) ---- if ((layerInfo.total == null || layerInfo.current == null) && currentFilename) { try { const meta = await httpGet(`${BASE}/server/files/metadata?filename=${encodeURIComponent(currentFilename)}`); const md = meta?.result || {}; const lh = md?.layer_height ?? md?.slicer?.layer_height ?? null; const oh = md?.object_height ?? md?.metadata?.object_height ?? null; if (lh != null) metaFromFile.layer_height = Number(lh); if (oh != null) metaFromFile.object_height = Number(oh); if (metaFromFile.layer_height != null) await writeNum(`${ROOT}.file.meta.layer_height_mm`, round1(metaFromFile.layer_height), "mm", "value.length"); if (metaFromFile.object_height != null) await writeNum(`${ROOT}.file.meta.object_height_mm`, round1(metaFromFile.object_height), "mm", "value.length"); if (layerInfo.total == null && metaFromFile.layer_height && metaFromFile.object_height) { layerInfo.total = Math.max(1, Math.round(metaFromFile.object_height / metaFromFile.layer_height)); } if (layerInfo.current == null && metaFromFile.layer_height && zPos != null) { layerInfo.current = Math.max(0, Math.min(layerInfo.total || 999999, Math.floor(zPos / metaFromFile.layer_height))); } } catch (e) { // nicht kritisch } } // ---- Layer in Datenpunkte schreiben ---- if (layerInfo.current != null) await writeNum(`${ROOT}.layers.current`, layerInfo.current, "", "value"); if (layerInfo.total != null) await writeNum(`${ROOT}.layers.total`, layerInfo.total, "", "value"); if (layerInfo.current != null && layerInfo.total != null && layerInfo.total > 0) { const pct = Math.round((layerInfo.current / layerInfo.total) * 1000) / 10; await writeNum(`${ROOT}.layers.progress_percent`, pct, "%", "value.percent"); } await writeStr(`${ROOT}.meta.last_update`, new Date().toISOString(), "date"); await writeBool(`${ROOT}.meta.ok`, true, "indicator.working"); } catch (e) { await writeBool(`${ROOT}.meta.ok`, false, "indicator.working"); await writeStr(`${ROOT}.meta.error`, e.message || String(e)); log(`Moonraker poll error: ${e.message}`, "warn"); } } // ======== STARTUP ======== (async () => { await ensureState(`${ROOT}.meta.ok`, { type: "boolean", def: false, read: true, write: false, role: "indicator.working" }); await discoverObjects(); pollOnce(); })(); // Intervall let pollTimer = setInterval(pollOnce, POLL_MS); // ======== OPTIONALE TESTFUNKTION (Alexa) ======== let testTimer = null; if (ENABLE_TEST_SPEAK) { testTimer = setInterval(() => { try { setState(ALEXA_SPEAK_DP, { val: TEST_MESSAGE, ack: false }); } catch (e) { log("Alexa-Testansage fehlgeschlagen: " + e.message, "warn"); } }, 60_000); }
ioBroker@Debian 12 VM auf Proxmox 8.4.1 | HP Proliant DL380G9 | DS923+ 10TB | RS4021+ 144TB | Unifi Netzwerk 6AP, 3 EtagenSwitche | Anycubic MegaS+Kossel+Chiron, Elektroniker und Funkamateur
-
@merlin123
so mach ich es

(ip vom Drucker anpassen)
<block xmlns="https://developers.google.com/blockly/xml" type="on" id="/Z2O}ZB#,a]kn33Dz4F$" x="116" y="2253"> <field name="OID">mqtt.0.Mainsail.klipper.state.print_stats.filename</field> <field name="CONDITION">ne</field> <field name="ACK_CONDITION"></field> <statement name="STATEMENT"> <block type="variables_set" id="y[Oc#E_92,_2BKo4(5~["> <field name="VAR" id="BXYL{xhaLkN~v2Ldl!%!">text</field> <value name="VALUE"> <block type="get_attr" id="XXR]WqWt.=HMLUr3gR}@"> <value name="PATH"> <shadow type="text" id="rrx*$IEHd@w{;*~Z+8`n"> <field name="TEXT">value</field> </shadow> </value> <value name="OBJECT"> <shadow type="get_object" id="^cMzi*_aj{`Pl0P725m~"> <field name="OID">Object ID</field> </shadow> <block type="on_source" id="pgo{+7GzQz;]qj)e34}A"> <field name="ATTR">state.val</field> </block> </value> </block> </value> <next> <block type="update" id="bIOV@RC*Q+u,j_l+cDZ,"> <mutation xmlns="http://www.w3.org/1999/xhtml" delay_input="false"></mutation> <field name="OID">0_userdata.0.Klipper.API.Printjob.Name</field> <field name="WITH_DELAY">FALSE</field> <value name="VALUE"> <block type="text_getSubstring" id=";P~^,bl^VhcaeFBrn4B7"> <mutation at1="false" at2="true"></mutation> <field name="WHERE1">FIRST</field> <field name="WHERE2">FROM_START</field> <value name="STRING"> <block type="variables_get" id=".)~:q(Mh|eeSdPJRu*2!"> <field name="VAR" id="BXYL{xhaLkN~v2Ldl!%!">text</field> </block> </value> <value name="AT2"> <block type="math_arithmetic" id="~]oa3qPRWU)spG%YB1]]"> <field name="OP">MINUS</field> <value name="A"> <shadow type="math_number" id="PqrA)w7#cW-.+R7[s$Ut"> <field name="NUM">1</field> </shadow> <block type="text_indexOf" id="r51`DlwiN)v*}8k4q}5p"> <field name="END">FIRST</field> <value name="VALUE"> <block type="variables_get" id="sqPwTzw6?t1]F1dwmj|P"> <field name="VAR" id="BXYL{xhaLkN~v2Ldl!%!">text</field> </block> </value> <value name="FIND"> <shadow type="text" id="NN88q$[rF?qy3R1S,=Fk"> <field name="TEXT">.gcode</field> </shadow> </value> </block> </value> <value name="B"> <shadow type="math_number" id="Gp.#K1A?Y{{b4u]f,mK_"> <field name="NUM">1</field> </shadow> </value> </block> </value> </block> </value> <next> <block type="update" id="v~`h#IPc]?2X#3=M{X[a"> <mutation xmlns="http://www.w3.org/1999/xhtml" delay_input="false"></mutation> <field name="OID">0_userdata.0.Klipper.API.Printjob.Thumbnail</field> <field name="WITH_DELAY">FALSE</field> <value name="VALUE"> <block type="text_join" id="=uC)c{XD(`=yL3+qnM$/"> <mutation items="3"></mutation> <value name="ADD0"> <block type="text" id="+hu6Z]DDV49vxZEG3^KI"> <field name="TEXT">http://192.168.178.113/server/files/gcodes/.thumbs/</field> </block> </value> <value name="ADD1"> <block type="text_getSubstring" id=".jX}L{b`]tqX[lP+wIR2"> <mutation at1="false" at2="true"></mutation> <field name="WHERE1">FIRST</field> <field name="WHERE2">FROM_START</field> <value name="STRING"> <block type="variables_get" id="ZUXf!~C]B[?oTqjrU3mF"> <field name="VAR" id="BXYL{xhaLkN~v2Ldl!%!">text</field> </block> </value> <value name="AT2"> <block type="math_arithmetic" id="rArUrH5JD`!U0PI6`=Lt"> <field name="OP">MINUS</field> <value name="A"> <shadow type="math_number" id="PqrA)w7#cW-.+R7[s$Ut"> <field name="NUM">1</field> </shadow> <block type="text_indexOf" id="Gji4dA%oP(rS[%9W%X(m"> <field name="END">FIRST</field> <value name="VALUE"> <block type="variables_get" id="i=BXKzmS]z$x=!47DA!B"> <field name="VAR" id="BXYL{xhaLkN~v2Ldl!%!">text</field> </block> </value> <value name="FIND"> <shadow type="text" id="nTgAoKx?A/?1e#g9JTXQ"> <field name="TEXT">.gcode</field> </shadow> </value> </block> </value> <value name="B"> <shadow type="math_number" id="u3_-Ii7/U+4%YQw8Az@I"> <field name="NUM">1</field> </shadow> </value> </block> </value> </block> </value> <value name="ADD2"> <block type="text" id="sn3+k)T(}R(KvqNhQ6;v"> <field name="TEXT">.png</field> </block> </value> </block> </value> </block> </next> </block> </next> </block> </statement> </block>@stenmic sagte in Adapter Klipper-Moonraker:

@stenmic
Sehr cooles VIS-Design.
Würdest Du das teilen?Gruß Daniel
-
Ich war so frei und habe eine Scriptversion gebsatelt.
Die Dezimaldaten werden direkt konvertiert sodas direkt lesbare Datenpunkte entstehen.
Das ganze kann als Script in iobroker verwendet werden.
Einfach Moonraker ip anpassen, ggf Alexa ID anpassen.
Der Code darf gerne ganz oder Teilweise für den Adapter genutzt werden.// ======== CONFIG ======== const MOONRAKER_HOST = "192.168.1.160"; const MOONRAKER_PORT = 7125; const BASE = `http://${MOONRAKER_HOST}:${MOONRAKER_PORT}`; const POLL_MS = 10_000; // Ablagepfad in ioBroker const ROOT = "javascript.0.moonraker.Kossel"; // Optional: Testfunktion (Alexa-Ansage jede Minute) const ENABLE_TEST_SPEAK = false; // ← bei Bedarf auf true const ALEXA_SPEAK_DP = "alexa2.0.Echo-Devices.IDANPASSEN.Commands.speak"; // Deine Echo-ID einsetzen const TEST_MESSAGE = "Moonraker Script Test läuft."; // ======== HELFER ======== // HTTP GET (Node.js Core) function httpGet(url, timeout = 5000) { return new Promise((resolve, reject) => { const http = require("http"); const req = http.get(url, (res) => { if (res.statusCode < 200 || res.statusCode >= 300) { reject(new Error(`HTTP ${res.statusCode} for ${url}`)); res.resume(); return; } let data = ""; res.setEncoding("utf8"); res.on("data", (chunk) => (data += chunk)); res.on("end", () => { try { resolve(JSON.parse(data)); } catch (e) { reject(new Error(`JSON parse error for ${url}: ${e.message}`)); } }); }); req.on("error", reject); req.setTimeout(timeout, () => { req.destroy(new Error(`Timeout after ${timeout}ms for ${url}`)); }); }); } // State-Helper async function ensureState(id, def) { if (!existsState(id)) { await createStateAsync(id, def, { role: def.common?.role || "state" }); } } async function writeNum(id, val, unit = "", role = "value") { await ensureState(id, { type: "number", read: true, write: false, def: 0, name: id.split(".").slice(-1)[0], role, unit }); setState(id, { val: Number(val), ack: true }); } async function writeStr(id, val, role = "text") { await ensureState(id, { type: "string", read: true, write: false, def: "", name: id.split(".").slice(-1)[0], role }); setState(id, { val: String(val ?? ""), ack: true }); } async function writeBool(id, val, role = "indicator") { await ensureState(id, { type: "boolean", read: true, write: false, def: false, name: id.split(".").slice(-1)[0], role }); setState(id, { val: !!val, ack: true }); } // Formatierungen / Konvertierungen function toPercent01(v) { if (v == null || isNaN(v)) return null; return Math.round(Number(v) * 1000) / 10; // 1 Nachkommastelle } function toHMS(seconds) { if (seconds == null || isNaN(seconds)) return ""; const s = Math.max(0, Math.floor(seconds)); const h = Math.floor(s / 3600); const m = Math.floor((s % 3600) / 60); const sec = s % 60; return `${String(h).padStart(2, "0")}:${String(m).padStart(2, "0")}:${String(sec).padStart(2, "0")}`; } function round1(v) { if (v == null || isNaN(v)) return null; return Math.round(Number(v) * 10) / 10; } // Dynamik-Cache für Objekte (Fans, Temp-Sensoren, etc.) let discovered = { fans: [], tempSensors: [], hasHeaterBed: false, hasExtruder: false, hasDisplayStatus: false, hasGcodeMove: false, hasVirtualSd: false, hasToolhead: false, hasPrintStats: false, lastDiscoveryTs: 0 }; async function discoverObjects() { try { const list = await httpGet(`${BASE}/printer/objects/list`); const raw = list?.result?.objects; let names = []; if (Array.isArray(raw)) { names = raw .map((o) => (typeof o === "string" ? o : (o && o.name) ? String(o.name) : "")) .filter((n) => typeof n === "string" && n.length > 0); } else if (raw && typeof raw === "object") { names = Object.keys(raw); } else { names = []; } const isStr = (n) => typeof n === "string" && n.length > 0; discovered.fans = names.filter((n) => isStr(n) && (n.startsWith("fan") || n.startsWith("heater_fan") || n.startsWith("controller_fan") || n.startsWith("fan_generic")) ); discovered.tempSensors = names.filter((n) => isStr(n) && (n.startsWith("temperature_sensor") || n.startsWith("temperature_fan") || n.startsWith("bme280") || n.startsWith("htu21d") || n.startsWith("lm75")) ); discovered.hasHeaterBed = names.includes("heater_bed"); discovered.hasExtruder = names.includes("extruder"); discovered.hasDisplayStatus = names.includes("display_status"); discovered.hasGcodeMove = names.includes("gcode_move"); discovered.hasVirtualSd = names.includes("virtual_sdcard"); discovered.hasToolhead = names.includes("toolhead"); discovered.hasPrintStats = names.includes("print_stats"); discovered.lastDiscoveryTs = Date.now(); await writeStr(`${ROOT}.meta.last_discovery`, new Date().toISOString()); await writeNum(`${ROOT}.meta.discovered.fans_count`, discovered.fans.length, "", "value"); await writeNum(`${ROOT}.meta.discovered.temp_sensors_count`, discovered.tempSensors.length, "", "value"); } catch (e) { log(`Moonraker discovery error: ${e.message}`, "warn"); } } function buildQueryParams() { const objs = ["print_stats"]; if (discovered.hasHeaterBed) objs.push("heater_bed"); if (discovered.hasExtruder) objs.push("extruder"); if (discovered.hasDisplayStatus) objs.push("display_status"); if (discovered.hasGcodeMove) objs.push("gcode_move"); if (discovered.hasVirtualSd) objs.push("virtual_sdcard"); if (discovered.hasToolhead) objs.push("toolhead"); if (discovered.hasPrintStats) objs.push("print_stats"); objs.push(...discovered.fans); objs.push(...discovered.tempSensors); const q = objs.map(encodeURIComponent).join("&"); return `${BASE}/printer/objects/query?${q}`; } // ======== REST DES POLLERS (pollOnce, Startup, Timer, etc.) ======== // Alexa-Ansage Tracking (Doppelansagen vermeiden) let lastPrintState = ""; let lastAnnouncedFile = ""; let lastAnnouncedTs = 0; const ANNOUNCE_COOLDOWN_MS = 5 * 60 * 1000; // 5 Minuten async function pollOnce() { try { // 1) Basisinfos const [serverInfo, printerInfo] = await Promise.all([ httpGet(`${BASE}/server/info`), httpGet(`${BASE}/printer/info`) ]); const s = serverInfo?.result || {}; await writeStr(`${ROOT}.server.version`, s.version || ""); await writeStr(`${ROOT}.server.klippy_state`, s.klippy_state || ""); await writeStr(`${ROOT}.server.hostname`, s.hostname || ""); await writeStr(`${ROOT}.server.websocket_address`, s.websocket_address || ""); const p = printerInfo?.result || {}; await writeStr(`${ROOT}.printer.state`, p.state || "unknown"); await writeBool(`${ROOT}.printer.ready`, p.state === "ready", "indicator.reachable"); // 2) Objekte ggf. alle 5 Min neu entdecken if (Date.now() - discovered.lastDiscoveryTs > 5 * 60 * 1000 || discovered.lastDiscoveryTs === 0) { await discoverObjects(); } // 3) Printer Objects abfragen const queryUrl = buildQueryParams(); const q = await httpGet(queryUrl); const res = q?.result?.status || {}; // ---- print_stats ---- let currentFilename = ""; let layerInfo = { current: null, total: null }; let metaFromFile = { layer_height: null, object_height: null }; if (res.print_stats) { const ps = res.print_stats; await writeStr(`${ROOT}.print_stats.state`, ps.state || ""); await writeStr(`${ROOT}.print_stats.filename`, ps.filename || ""); await writeStr(`${ROOT}.print_stats.message`, ps.message || ""); currentFilename = ps.filename || ""; // === Alexa-Ansage bei Fertigstellung === try { let shouldAnnounce = false; if ((ps.state || "") === "complete") { if (currentFilename) { if (currentFilename !== lastAnnouncedFile) { shouldAnnounce = true; lastAnnouncedFile = currentFilename; } } else if (lastPrintState !== "complete" && (Date.now() - lastAnnouncedTs) > ANNOUNCE_COOLDOWN_MS) { shouldAnnounce = true; } } if (shouldAnnounce) { const msg = currentFilename ? `Druckauftrag abgeschlossen: ${currentFilename}.` : "Der 3D Druck ist fertig."; setState(ALEXA_SPEAK_DP, { val: msg, ack: false }); // nutzt deinen Alexa-Datenpunkt lastAnnouncedTs = Date.now(); await writeStr(`${ROOT}.meta.last_completed_file`, currentFilename || ""); await writeStr(`${ROOT}.meta.last_announcement`, new Date().toISOString()); } lastPrintState = ps.state || ""; } catch (e) { log("Alexa-Fertig-Ansage fehlgeschlagen: " + e.message, "warn"); } if (ps.total_duration != null) await writeStr(`${ROOT}.print_stats.total_duration_hms`, toHMS(ps.total_duration), "time"); if (ps.print_duration != null) await writeStr(`${ROOT}.print_stats.print_duration_hms`, toHMS(ps.print_duration), "time"); if (ps.filament_used != null) { const m = Math.round((Number(ps.filament_used) || 0) / 10) / 100; // mm → m await writeNum(`${ROOT}.print_stats.filament_used_m`, m, "m", "value.length"); } if (ps.progress != null) { await writeNum(`${ROOT}.print_stats.progress_percent`, toPercent01(ps.progress), "%", "value.percent"); } // Layer bevorzugt aus print_stats.info (nur vorhanden, wenn Slicer SET_PRINT_STATS_INFO mitschreibt) const info = ps.info || {}; if (info.current_layer != null) layerInfo.current = Number(info.current_layer); if (info.total_layer != null) layerInfo.total = Number(info.total_layer); } // ---- toolhead (für Z→Layer-Fallback) ---- let zPos = null; if (res.toolhead) { const th = res.toolhead; if (Array.isArray(th.position)) { const [x, y, z] = th.position; zPos = (z != null ? Number(z) : null); await writeNum(`${ROOT}.toolhead.x`, round1(x), "mm", "value.length"); await writeNum(`${ROOT}.toolhead.y`, round1(y), "mm", "value.length"); await writeNum(`${ROOT}.toolhead.z`, round1(z), "mm", "value.length"); } if (th.max_velocity != null) await writeNum(`${ROOT}.toolhead.max_velocity`, round1(th.max_velocity), "mm/s", "value.speed"); if (th.max_accel != null) await writeNum(`${ROOT}.toolhead.max_accel`, round1(th.max_accel), "mm/s²", "value.acceleration"); if (th.homing_origin && Array.isArray(th.homing_origin)) { const [hx, hy, hz] = th.homing_origin; await writeNum(`${ROOT}.toolhead.homing_origin.x`, round1(hx), "mm", "value.length"); await writeNum(`${ROOT}.toolhead.homing_origin.y`, round1(hy), "mm", "value.length"); await writeNum(`${ROOT}.toolhead.homing_origin.z`, round1(hz), "mm", "value.length"); } if (th.print_time != null) await writeStr(`${ROOT}.toolhead.print_time_hms`, toHMS(th.print_time), "time"); } // ---- gcode_move ---- if (res.gcode_move) { const gm = res.gcode_move; if (gm.speed != null) await writeNum(`${ROOT}.gcode_move.speed`, round1(gm.speed), "mm/s", "value.speed"); if (gm.speed_factor != null) await writeNum(`${ROOT}.gcode_move.speed_factor_percent`, toPercent01(gm.speed_factor), "%", "value.percent"); if (gm.extrude_factor != null) await writeNum(`${ROOT}.gcode_move.extrude_factor_percent`, toPercent01(gm.extrude_factor), "%", "value.percent"); if (Array.isArray(gm.gcode_position)) { const [x, y, z, e] = gm.gcode_position; await writeNum(`${ROOT}.gcode_move.gcode_x`, round1(x), "mm", "value.length"); await writeNum(`${ROOT}.gcode_move.gcode_y`, round1(y), "mm", "value.length"); await writeNum(`${ROOT}.gcode_move.gcode_z`, round1(z), "mm", "value.length"); await writeNum(`${ROOT}.gcode_move.gcode_e`, round1(e), "mm", "value.length"); } } // ---- heater_bed ---- if (res.heater_bed) { const hb = res.heater_bed; if (hb.temperature != null) await writeNum(`${ROOT}.heater_bed.temperature`, round1(hb.temperature), "°C", "value.temperature"); if (hb.target != null) await writeNum(`${ROOT}.heater_bed.target`, round1(hb.target), "°C", "value.temperature"); if (hb.power != null) await writeNum(`${ROOT}.heater_bed.power_percent`, toPercent01(hb.power), "%", "value.percent"); } // ---- extruder ---- if (res.extruder) { const ex = res.extruder; if (ex.temperature != null) await writeNum(`${ROOT}.extruder.temperature`, round1(ex.temperature), "°C", "value.temperature"); if (ex.target != null) await writeNum(`${ROOT}.extruder.target`, round1(ex.target), "°C", "value.temperature"); if (ex.power != null) await writeNum(`${ROOT}.extruder.power_percent`, toPercent01(ex.power), "%", "value.percent"); if (ex.pressure_advance != null) await writeNum(`${ROOT}.extruder.pressure_advance`, round1(ex.pressure_advance), "", "value"); if (ex.smooth_time != null) await writeNum(`${ROOT}.extruder.smooth_time`, round1(ex.smooth_time), "s", "value.interval"); } // ---- virtual_sdcard ---- if (res.virtual_sdcard) { const vsd = res.virtual_sdcard; if (vsd.progress != null) await writeNum(`${ROOT}.virtual_sdcard.progress_percent`, toPercent01(vsd.progress), "%", "value.percent"); if (vsd.file_position != null) await writeNum(`${ROOT}.virtual_sdcard.file_position`, Number(vsd.file_position), "B", "value"); } // ---- display_status ---- if (res.display_status) { const ds = res.display_status; await writeStr(`${ROOT}.display_status.message`, ds.message || ""); if (ds.progress != null) await writeNum(`${ROOT}.display_status.progress_percent`, toPercent01(ds.progress), "%", "value.percent"); } // ---- Fans ---- for (const f of discovered.fans) { const key = f; const safeKey = key.replace(/\s+/g, "_"); const obj = res[key]; if (!obj) continue; if (obj.speed != null) await writeNum(`${ROOT}.fans.${safeKey}.speed_percent`, toPercent01(obj.speed), "%", "value.percent"); if (obj.rpm != null) await writeNum(`${ROOT}.fans.${safeKey}.rpm`, Number(obj.rpm), "rpm", "value"); } // ---- Temperatur-Sensoren ---- for (const t of discovered.tempSensors) { const key = t; const safeKey = key.replace(/\s+/g, "_"); const obj = res[key]; if (!obj) continue; if (obj.temperature != null) await writeNum(`${ROOT}.temp_sensors.${safeKey}.temperature`, round1(obj.temperature), "°C", "value.temperature"); if (obj.speed != null) await writeNum(`${ROOT}.temp_sensors.${safeKey}.speed_percent`, toPercent01(obj.speed), "%", "value.percent"); } // ---- Datei-Metadaten (Layer-Fallback) ---- if ((layerInfo.total == null || layerInfo.current == null) && currentFilename) { try { const meta = await httpGet(`${BASE}/server/files/metadata?filename=${encodeURIComponent(currentFilename)}`); const md = meta?.result || {}; const lh = md?.layer_height ?? md?.slicer?.layer_height ?? null; const oh = md?.object_height ?? md?.metadata?.object_height ?? null; if (lh != null) metaFromFile.layer_height = Number(lh); if (oh != null) metaFromFile.object_height = Number(oh); if (metaFromFile.layer_height != null) await writeNum(`${ROOT}.file.meta.layer_height_mm`, round1(metaFromFile.layer_height), "mm", "value.length"); if (metaFromFile.object_height != null) await writeNum(`${ROOT}.file.meta.object_height_mm`, round1(metaFromFile.object_height), "mm", "value.length"); if (layerInfo.total == null && metaFromFile.layer_height && metaFromFile.object_height) { layerInfo.total = Math.max(1, Math.round(metaFromFile.object_height / metaFromFile.layer_height)); } if (layerInfo.current == null && metaFromFile.layer_height && zPos != null) { layerInfo.current = Math.max(0, Math.min(layerInfo.total || 999999, Math.floor(zPos / metaFromFile.layer_height))); } } catch (e) { // nicht kritisch } } // ---- Layer in Datenpunkte schreiben ---- if (layerInfo.current != null) await writeNum(`${ROOT}.layers.current`, layerInfo.current, "", "value"); if (layerInfo.total != null) await writeNum(`${ROOT}.layers.total`, layerInfo.total, "", "value"); if (layerInfo.current != null && layerInfo.total != null && layerInfo.total > 0) { const pct = Math.round((layerInfo.current / layerInfo.total) * 1000) / 10; await writeNum(`${ROOT}.layers.progress_percent`, pct, "%", "value.percent"); } await writeStr(`${ROOT}.meta.last_update`, new Date().toISOString(), "date"); await writeBool(`${ROOT}.meta.ok`, true, "indicator.working"); } catch (e) { await writeBool(`${ROOT}.meta.ok`, false, "indicator.working"); await writeStr(`${ROOT}.meta.error`, e.message || String(e)); log(`Moonraker poll error: ${e.message}`, "warn"); } } // ======== STARTUP ======== (async () => { await ensureState(`${ROOT}.meta.ok`, { type: "boolean", def: false, read: true, write: false, role: "indicator.working" }); await discoverObjects(); pollOnce(); })(); // Intervall let pollTimer = setInterval(pollOnce, POLL_MS); // ======== OPTIONALE TESTFUNKTION (Alexa) ======== let testTimer = null; if (ENABLE_TEST_SPEAK) { testTimer = setInterval(() => { try { setState(ALEXA_SPEAK_DP, { val: TEST_MESSAGE, ack: false }); } catch (e) { log("Alexa-Testansage fehlgeschlagen: " + e.message, "warn"); } }, 60_000); }
@Lucifor1976 sagte in Adapter Klipper-Moonraker:
Das ganze kann als Script in iobroker verwendet werden.
Danke für das Script.
Funktioniert super. Nur ballert es das Log voll, wenn der Drucker aus ist.2025-12-04 07:47:07.644 warn script.js.3D-Drucker.Snapmaker_U1: Moonraker poll error: Timeout after 5000ms for http://10.0.1.244:80/server/infoGibt es eine Möglichkeit, diese Meldung zu unterdrücken?
PS: kannst du den View exportieren? ;)
° Node.js Update ---> iob nodejs-update
° Fixer ---> iob fix -
@stenmic sagte in Adapter Klipper-Moonraker:

@stenmic
Sehr cooles VIS-Design.
Würdest Du das teilen?Gruß Daniel
° Node.js Update ---> iob nodejs-update
° Fixer ---> iob fix -
@Lucifor1976 sagte in Adapter Klipper-Moonraker:
Das ganze kann als Script in iobroker verwendet werden.
Danke für das Script.
Funktioniert super. Nur ballert es das Log voll, wenn der Drucker aus ist.2025-12-04 07:47:07.644 warn script.js.3D-Drucker.Snapmaker_U1: Moonraker poll error: Timeout after 5000ms for http://10.0.1.244:80/server/infoGibt es eine Möglichkeit, diese Meldung zu unterdrücken?
PS: kannst du den View exportieren? ;)
@Negalein sagte in Adapter Klipper-Moonraker:
Gibt es eine Möglichkeit, diese Meldung zu unterdrücken?
stell die instanz auf error um.
gruß vom Woody
HAPPINESS is not a DESTINATION, it's a WAY of LIFE! -
Ich war so frei und habe eine Scriptversion gebsatelt.
Die Dezimaldaten werden direkt konvertiert sodas direkt lesbare Datenpunkte entstehen.
Das ganze kann als Script in iobroker verwendet werden.
Einfach Moonraker ip anpassen, ggf Alexa ID anpassen.
Der Code darf gerne ganz oder Teilweise für den Adapter genutzt werden.// ======== CONFIG ======== const MOONRAKER_HOST = "192.168.1.160"; const MOONRAKER_PORT = 7125; const BASE = `http://${MOONRAKER_HOST}:${MOONRAKER_PORT}`; const POLL_MS = 10_000; // Ablagepfad in ioBroker const ROOT = "javascript.0.moonraker.Kossel"; // Optional: Testfunktion (Alexa-Ansage jede Minute) const ENABLE_TEST_SPEAK = false; // ← bei Bedarf auf true const ALEXA_SPEAK_DP = "alexa2.0.Echo-Devices.IDANPASSEN.Commands.speak"; // Deine Echo-ID einsetzen const TEST_MESSAGE = "Moonraker Script Test läuft."; // ======== HELFER ======== // HTTP GET (Node.js Core) function httpGet(url, timeout = 5000) { return new Promise((resolve, reject) => { const http = require("http"); const req = http.get(url, (res) => { if (res.statusCode < 200 || res.statusCode >= 300) { reject(new Error(`HTTP ${res.statusCode} for ${url}`)); res.resume(); return; } let data = ""; res.setEncoding("utf8"); res.on("data", (chunk) => (data += chunk)); res.on("end", () => { try { resolve(JSON.parse(data)); } catch (e) { reject(new Error(`JSON parse error for ${url}: ${e.message}`)); } }); }); req.on("error", reject); req.setTimeout(timeout, () => { req.destroy(new Error(`Timeout after ${timeout}ms for ${url}`)); }); }); } // State-Helper async function ensureState(id, def) { if (!existsState(id)) { await createStateAsync(id, def, { role: def.common?.role || "state" }); } } async function writeNum(id, val, unit = "", role = "value") { await ensureState(id, { type: "number", read: true, write: false, def: 0, name: id.split(".").slice(-1)[0], role, unit }); setState(id, { val: Number(val), ack: true }); } async function writeStr(id, val, role = "text") { await ensureState(id, { type: "string", read: true, write: false, def: "", name: id.split(".").slice(-1)[0], role }); setState(id, { val: String(val ?? ""), ack: true }); } async function writeBool(id, val, role = "indicator") { await ensureState(id, { type: "boolean", read: true, write: false, def: false, name: id.split(".").slice(-1)[0], role }); setState(id, { val: !!val, ack: true }); } // Formatierungen / Konvertierungen function toPercent01(v) { if (v == null || isNaN(v)) return null; return Math.round(Number(v) * 1000) / 10; // 1 Nachkommastelle } function toHMS(seconds) { if (seconds == null || isNaN(seconds)) return ""; const s = Math.max(0, Math.floor(seconds)); const h = Math.floor(s / 3600); const m = Math.floor((s % 3600) / 60); const sec = s % 60; return `${String(h).padStart(2, "0")}:${String(m).padStart(2, "0")}:${String(sec).padStart(2, "0")}`; } function round1(v) { if (v == null || isNaN(v)) return null; return Math.round(Number(v) * 10) / 10; } // Dynamik-Cache für Objekte (Fans, Temp-Sensoren, etc.) let discovered = { fans: [], tempSensors: [], hasHeaterBed: false, hasExtruder: false, hasDisplayStatus: false, hasGcodeMove: false, hasVirtualSd: false, hasToolhead: false, hasPrintStats: false, lastDiscoveryTs: 0 }; async function discoverObjects() { try { const list = await httpGet(`${BASE}/printer/objects/list`); const raw = list?.result?.objects; let names = []; if (Array.isArray(raw)) { names = raw .map((o) => (typeof o === "string" ? o : (o && o.name) ? String(o.name) : "")) .filter((n) => typeof n === "string" && n.length > 0); } else if (raw && typeof raw === "object") { names = Object.keys(raw); } else { names = []; } const isStr = (n) => typeof n === "string" && n.length > 0; discovered.fans = names.filter((n) => isStr(n) && (n.startsWith("fan") || n.startsWith("heater_fan") || n.startsWith("controller_fan") || n.startsWith("fan_generic")) ); discovered.tempSensors = names.filter((n) => isStr(n) && (n.startsWith("temperature_sensor") || n.startsWith("temperature_fan") || n.startsWith("bme280") || n.startsWith("htu21d") || n.startsWith("lm75")) ); discovered.hasHeaterBed = names.includes("heater_bed"); discovered.hasExtruder = names.includes("extruder"); discovered.hasDisplayStatus = names.includes("display_status"); discovered.hasGcodeMove = names.includes("gcode_move"); discovered.hasVirtualSd = names.includes("virtual_sdcard"); discovered.hasToolhead = names.includes("toolhead"); discovered.hasPrintStats = names.includes("print_stats"); discovered.lastDiscoveryTs = Date.now(); await writeStr(`${ROOT}.meta.last_discovery`, new Date().toISOString()); await writeNum(`${ROOT}.meta.discovered.fans_count`, discovered.fans.length, "", "value"); await writeNum(`${ROOT}.meta.discovered.temp_sensors_count`, discovered.tempSensors.length, "", "value"); } catch (e) { log(`Moonraker discovery error: ${e.message}`, "warn"); } } function buildQueryParams() { const objs = ["print_stats"]; if (discovered.hasHeaterBed) objs.push("heater_bed"); if (discovered.hasExtruder) objs.push("extruder"); if (discovered.hasDisplayStatus) objs.push("display_status"); if (discovered.hasGcodeMove) objs.push("gcode_move"); if (discovered.hasVirtualSd) objs.push("virtual_sdcard"); if (discovered.hasToolhead) objs.push("toolhead"); if (discovered.hasPrintStats) objs.push("print_stats"); objs.push(...discovered.fans); objs.push(...discovered.tempSensors); const q = objs.map(encodeURIComponent).join("&"); return `${BASE}/printer/objects/query?${q}`; } // ======== REST DES POLLERS (pollOnce, Startup, Timer, etc.) ======== // Alexa-Ansage Tracking (Doppelansagen vermeiden) let lastPrintState = ""; let lastAnnouncedFile = ""; let lastAnnouncedTs = 0; const ANNOUNCE_COOLDOWN_MS = 5 * 60 * 1000; // 5 Minuten async function pollOnce() { try { // 1) Basisinfos const [serverInfo, printerInfo] = await Promise.all([ httpGet(`${BASE}/server/info`), httpGet(`${BASE}/printer/info`) ]); const s = serverInfo?.result || {}; await writeStr(`${ROOT}.server.version`, s.version || ""); await writeStr(`${ROOT}.server.klippy_state`, s.klippy_state || ""); await writeStr(`${ROOT}.server.hostname`, s.hostname || ""); await writeStr(`${ROOT}.server.websocket_address`, s.websocket_address || ""); const p = printerInfo?.result || {}; await writeStr(`${ROOT}.printer.state`, p.state || "unknown"); await writeBool(`${ROOT}.printer.ready`, p.state === "ready", "indicator.reachable"); // 2) Objekte ggf. alle 5 Min neu entdecken if (Date.now() - discovered.lastDiscoveryTs > 5 * 60 * 1000 || discovered.lastDiscoveryTs === 0) { await discoverObjects(); } // 3) Printer Objects abfragen const queryUrl = buildQueryParams(); const q = await httpGet(queryUrl); const res = q?.result?.status || {}; // ---- print_stats ---- let currentFilename = ""; let layerInfo = { current: null, total: null }; let metaFromFile = { layer_height: null, object_height: null }; if (res.print_stats) { const ps = res.print_stats; await writeStr(`${ROOT}.print_stats.state`, ps.state || ""); await writeStr(`${ROOT}.print_stats.filename`, ps.filename || ""); await writeStr(`${ROOT}.print_stats.message`, ps.message || ""); currentFilename = ps.filename || ""; // === Alexa-Ansage bei Fertigstellung === try { let shouldAnnounce = false; if ((ps.state || "") === "complete") { if (currentFilename) { if (currentFilename !== lastAnnouncedFile) { shouldAnnounce = true; lastAnnouncedFile = currentFilename; } } else if (lastPrintState !== "complete" && (Date.now() - lastAnnouncedTs) > ANNOUNCE_COOLDOWN_MS) { shouldAnnounce = true; } } if (shouldAnnounce) { const msg = currentFilename ? `Druckauftrag abgeschlossen: ${currentFilename}.` : "Der 3D Druck ist fertig."; setState(ALEXA_SPEAK_DP, { val: msg, ack: false }); // nutzt deinen Alexa-Datenpunkt lastAnnouncedTs = Date.now(); await writeStr(`${ROOT}.meta.last_completed_file`, currentFilename || ""); await writeStr(`${ROOT}.meta.last_announcement`, new Date().toISOString()); } lastPrintState = ps.state || ""; } catch (e) { log("Alexa-Fertig-Ansage fehlgeschlagen: " + e.message, "warn"); } if (ps.total_duration != null) await writeStr(`${ROOT}.print_stats.total_duration_hms`, toHMS(ps.total_duration), "time"); if (ps.print_duration != null) await writeStr(`${ROOT}.print_stats.print_duration_hms`, toHMS(ps.print_duration), "time"); if (ps.filament_used != null) { const m = Math.round((Number(ps.filament_used) || 0) / 10) / 100; // mm → m await writeNum(`${ROOT}.print_stats.filament_used_m`, m, "m", "value.length"); } if (ps.progress != null) { await writeNum(`${ROOT}.print_stats.progress_percent`, toPercent01(ps.progress), "%", "value.percent"); } // Layer bevorzugt aus print_stats.info (nur vorhanden, wenn Slicer SET_PRINT_STATS_INFO mitschreibt) const info = ps.info || {}; if (info.current_layer != null) layerInfo.current = Number(info.current_layer); if (info.total_layer != null) layerInfo.total = Number(info.total_layer); } // ---- toolhead (für Z→Layer-Fallback) ---- let zPos = null; if (res.toolhead) { const th = res.toolhead; if (Array.isArray(th.position)) { const [x, y, z] = th.position; zPos = (z != null ? Number(z) : null); await writeNum(`${ROOT}.toolhead.x`, round1(x), "mm", "value.length"); await writeNum(`${ROOT}.toolhead.y`, round1(y), "mm", "value.length"); await writeNum(`${ROOT}.toolhead.z`, round1(z), "mm", "value.length"); } if (th.max_velocity != null) await writeNum(`${ROOT}.toolhead.max_velocity`, round1(th.max_velocity), "mm/s", "value.speed"); if (th.max_accel != null) await writeNum(`${ROOT}.toolhead.max_accel`, round1(th.max_accel), "mm/s²", "value.acceleration"); if (th.homing_origin && Array.isArray(th.homing_origin)) { const [hx, hy, hz] = th.homing_origin; await writeNum(`${ROOT}.toolhead.homing_origin.x`, round1(hx), "mm", "value.length"); await writeNum(`${ROOT}.toolhead.homing_origin.y`, round1(hy), "mm", "value.length"); await writeNum(`${ROOT}.toolhead.homing_origin.z`, round1(hz), "mm", "value.length"); } if (th.print_time != null) await writeStr(`${ROOT}.toolhead.print_time_hms`, toHMS(th.print_time), "time"); } // ---- gcode_move ---- if (res.gcode_move) { const gm = res.gcode_move; if (gm.speed != null) await writeNum(`${ROOT}.gcode_move.speed`, round1(gm.speed), "mm/s", "value.speed"); if (gm.speed_factor != null) await writeNum(`${ROOT}.gcode_move.speed_factor_percent`, toPercent01(gm.speed_factor), "%", "value.percent"); if (gm.extrude_factor != null) await writeNum(`${ROOT}.gcode_move.extrude_factor_percent`, toPercent01(gm.extrude_factor), "%", "value.percent"); if (Array.isArray(gm.gcode_position)) { const [x, y, z, e] = gm.gcode_position; await writeNum(`${ROOT}.gcode_move.gcode_x`, round1(x), "mm", "value.length"); await writeNum(`${ROOT}.gcode_move.gcode_y`, round1(y), "mm", "value.length"); await writeNum(`${ROOT}.gcode_move.gcode_z`, round1(z), "mm", "value.length"); await writeNum(`${ROOT}.gcode_move.gcode_e`, round1(e), "mm", "value.length"); } } // ---- heater_bed ---- if (res.heater_bed) { const hb = res.heater_bed; if (hb.temperature != null) await writeNum(`${ROOT}.heater_bed.temperature`, round1(hb.temperature), "°C", "value.temperature"); if (hb.target != null) await writeNum(`${ROOT}.heater_bed.target`, round1(hb.target), "°C", "value.temperature"); if (hb.power != null) await writeNum(`${ROOT}.heater_bed.power_percent`, toPercent01(hb.power), "%", "value.percent"); } // ---- extruder ---- if (res.extruder) { const ex = res.extruder; if (ex.temperature != null) await writeNum(`${ROOT}.extruder.temperature`, round1(ex.temperature), "°C", "value.temperature"); if (ex.target != null) await writeNum(`${ROOT}.extruder.target`, round1(ex.target), "°C", "value.temperature"); if (ex.power != null) await writeNum(`${ROOT}.extruder.power_percent`, toPercent01(ex.power), "%", "value.percent"); if (ex.pressure_advance != null) await writeNum(`${ROOT}.extruder.pressure_advance`, round1(ex.pressure_advance), "", "value"); if (ex.smooth_time != null) await writeNum(`${ROOT}.extruder.smooth_time`, round1(ex.smooth_time), "s", "value.interval"); } // ---- virtual_sdcard ---- if (res.virtual_sdcard) { const vsd = res.virtual_sdcard; if (vsd.progress != null) await writeNum(`${ROOT}.virtual_sdcard.progress_percent`, toPercent01(vsd.progress), "%", "value.percent"); if (vsd.file_position != null) await writeNum(`${ROOT}.virtual_sdcard.file_position`, Number(vsd.file_position), "B", "value"); } // ---- display_status ---- if (res.display_status) { const ds = res.display_status; await writeStr(`${ROOT}.display_status.message`, ds.message || ""); if (ds.progress != null) await writeNum(`${ROOT}.display_status.progress_percent`, toPercent01(ds.progress), "%", "value.percent"); } // ---- Fans ---- for (const f of discovered.fans) { const key = f; const safeKey = key.replace(/\s+/g, "_"); const obj = res[key]; if (!obj) continue; if (obj.speed != null) await writeNum(`${ROOT}.fans.${safeKey}.speed_percent`, toPercent01(obj.speed), "%", "value.percent"); if (obj.rpm != null) await writeNum(`${ROOT}.fans.${safeKey}.rpm`, Number(obj.rpm), "rpm", "value"); } // ---- Temperatur-Sensoren ---- for (const t of discovered.tempSensors) { const key = t; const safeKey = key.replace(/\s+/g, "_"); const obj = res[key]; if (!obj) continue; if (obj.temperature != null) await writeNum(`${ROOT}.temp_sensors.${safeKey}.temperature`, round1(obj.temperature), "°C", "value.temperature"); if (obj.speed != null) await writeNum(`${ROOT}.temp_sensors.${safeKey}.speed_percent`, toPercent01(obj.speed), "%", "value.percent"); } // ---- Datei-Metadaten (Layer-Fallback) ---- if ((layerInfo.total == null || layerInfo.current == null) && currentFilename) { try { const meta = await httpGet(`${BASE}/server/files/metadata?filename=${encodeURIComponent(currentFilename)}`); const md = meta?.result || {}; const lh = md?.layer_height ?? md?.slicer?.layer_height ?? null; const oh = md?.object_height ?? md?.metadata?.object_height ?? null; if (lh != null) metaFromFile.layer_height = Number(lh); if (oh != null) metaFromFile.object_height = Number(oh); if (metaFromFile.layer_height != null) await writeNum(`${ROOT}.file.meta.layer_height_mm`, round1(metaFromFile.layer_height), "mm", "value.length"); if (metaFromFile.object_height != null) await writeNum(`${ROOT}.file.meta.object_height_mm`, round1(metaFromFile.object_height), "mm", "value.length"); if (layerInfo.total == null && metaFromFile.layer_height && metaFromFile.object_height) { layerInfo.total = Math.max(1, Math.round(metaFromFile.object_height / metaFromFile.layer_height)); } if (layerInfo.current == null && metaFromFile.layer_height && zPos != null) { layerInfo.current = Math.max(0, Math.min(layerInfo.total || 999999, Math.floor(zPos / metaFromFile.layer_height))); } } catch (e) { // nicht kritisch } } // ---- Layer in Datenpunkte schreiben ---- if (layerInfo.current != null) await writeNum(`${ROOT}.layers.current`, layerInfo.current, "", "value"); if (layerInfo.total != null) await writeNum(`${ROOT}.layers.total`, layerInfo.total, "", "value"); if (layerInfo.current != null && layerInfo.total != null && layerInfo.total > 0) { const pct = Math.round((layerInfo.current / layerInfo.total) * 1000) / 10; await writeNum(`${ROOT}.layers.progress_percent`, pct, "%", "value.percent"); } await writeStr(`${ROOT}.meta.last_update`, new Date().toISOString(), "date"); await writeBool(`${ROOT}.meta.ok`, true, "indicator.working"); } catch (e) { await writeBool(`${ROOT}.meta.ok`, false, "indicator.working"); await writeStr(`${ROOT}.meta.error`, e.message || String(e)); log(`Moonraker poll error: ${e.message}`, "warn"); } } // ======== STARTUP ======== (async () => { await ensureState(`${ROOT}.meta.ok`, { type: "boolean", def: false, read: true, write: false, role: "indicator.working" }); await discoverObjects(); pollOnce(); })(); // Intervall let pollTimer = setInterval(pollOnce, POLL_MS); // ======== OPTIONALE TESTFUNKTION (Alexa) ======== let testTimer = null; if (ENABLE_TEST_SPEAK) { testTimer = setInterval(() => { try { setState(ALEXA_SPEAK_DP, { val: TEST_MESSAGE, ack: false }); } catch (e) { log("Alexa-Testansage fehlgeschlagen: " + e.message, "warn"); } }, 60_000); }
@Lucifor1976 sagte in Adapter Klipper-Moonraker:
Ich war so frei und habe eine Scriptversion gebsatelt.
Das hatte ich mir auch installiert, nachdem Du das gepostet hast, aber dann ging der Drucker kaputt (nein, nicht wegen dem Script ;-) ). Frage: was muß ich reinschreiben, damit mir mehrere ALEXAs eine Sprachausgabe machen?
-
@Negalein sagte in Adapter Klipper-Moonraker:
Gibt es eine Möglichkeit, diese Meldung zu unterdrücken?
stell die instanz auf error um.
@da_Woody sagte in Adapter Klipper-Moonraker:
stell die instanz auf error um.
habs mit einem Blockly gelöst.
wenn Shelly an, dann Script start
wenn Shelly aus, dann Script stopp.° Node.js Update ---> iob nodejs-update
° Fixer ---> iob fix -
Ich war so frei und habe eine Scriptversion gebsatelt.
Die Dezimaldaten werden direkt konvertiert sodas direkt lesbare Datenpunkte entstehen.
Das ganze kann als Script in iobroker verwendet werden.
Einfach Moonraker ip anpassen, ggf Alexa ID anpassen.
Der Code darf gerne ganz oder Teilweise für den Adapter genutzt werden.// ======== CONFIG ======== const MOONRAKER_HOST = "192.168.1.160"; const MOONRAKER_PORT = 7125; const BASE = `http://${MOONRAKER_HOST}:${MOONRAKER_PORT}`; const POLL_MS = 10_000; // Ablagepfad in ioBroker const ROOT = "javascript.0.moonraker.Kossel"; // Optional: Testfunktion (Alexa-Ansage jede Minute) const ENABLE_TEST_SPEAK = false; // ← bei Bedarf auf true const ALEXA_SPEAK_DP = "alexa2.0.Echo-Devices.IDANPASSEN.Commands.speak"; // Deine Echo-ID einsetzen const TEST_MESSAGE = "Moonraker Script Test läuft."; // ======== HELFER ======== // HTTP GET (Node.js Core) function httpGet(url, timeout = 5000) { return new Promise((resolve, reject) => { const http = require("http"); const req = http.get(url, (res) => { if (res.statusCode < 200 || res.statusCode >= 300) { reject(new Error(`HTTP ${res.statusCode} for ${url}`)); res.resume(); return; } let data = ""; res.setEncoding("utf8"); res.on("data", (chunk) => (data += chunk)); res.on("end", () => { try { resolve(JSON.parse(data)); } catch (e) { reject(new Error(`JSON parse error for ${url}: ${e.message}`)); } }); }); req.on("error", reject); req.setTimeout(timeout, () => { req.destroy(new Error(`Timeout after ${timeout}ms for ${url}`)); }); }); } // State-Helper async function ensureState(id, def) { if (!existsState(id)) { await createStateAsync(id, def, { role: def.common?.role || "state" }); } } async function writeNum(id, val, unit = "", role = "value") { await ensureState(id, { type: "number", read: true, write: false, def: 0, name: id.split(".").slice(-1)[0], role, unit }); setState(id, { val: Number(val), ack: true }); } async function writeStr(id, val, role = "text") { await ensureState(id, { type: "string", read: true, write: false, def: "", name: id.split(".").slice(-1)[0], role }); setState(id, { val: String(val ?? ""), ack: true }); } async function writeBool(id, val, role = "indicator") { await ensureState(id, { type: "boolean", read: true, write: false, def: false, name: id.split(".").slice(-1)[0], role }); setState(id, { val: !!val, ack: true }); } // Formatierungen / Konvertierungen function toPercent01(v) { if (v == null || isNaN(v)) return null; return Math.round(Number(v) * 1000) / 10; // 1 Nachkommastelle } function toHMS(seconds) { if (seconds == null || isNaN(seconds)) return ""; const s = Math.max(0, Math.floor(seconds)); const h = Math.floor(s / 3600); const m = Math.floor((s % 3600) / 60); const sec = s % 60; return `${String(h).padStart(2, "0")}:${String(m).padStart(2, "0")}:${String(sec).padStart(2, "0")}`; } function round1(v) { if (v == null || isNaN(v)) return null; return Math.round(Number(v) * 10) / 10; } // Dynamik-Cache für Objekte (Fans, Temp-Sensoren, etc.) let discovered = { fans: [], tempSensors: [], hasHeaterBed: false, hasExtruder: false, hasDisplayStatus: false, hasGcodeMove: false, hasVirtualSd: false, hasToolhead: false, hasPrintStats: false, lastDiscoveryTs: 0 }; async function discoverObjects() { try { const list = await httpGet(`${BASE}/printer/objects/list`); const raw = list?.result?.objects; let names = []; if (Array.isArray(raw)) { names = raw .map((o) => (typeof o === "string" ? o : (o && o.name) ? String(o.name) : "")) .filter((n) => typeof n === "string" && n.length > 0); } else if (raw && typeof raw === "object") { names = Object.keys(raw); } else { names = []; } const isStr = (n) => typeof n === "string" && n.length > 0; discovered.fans = names.filter((n) => isStr(n) && (n.startsWith("fan") || n.startsWith("heater_fan") || n.startsWith("controller_fan") || n.startsWith("fan_generic")) ); discovered.tempSensors = names.filter((n) => isStr(n) && (n.startsWith("temperature_sensor") || n.startsWith("temperature_fan") || n.startsWith("bme280") || n.startsWith("htu21d") || n.startsWith("lm75")) ); discovered.hasHeaterBed = names.includes("heater_bed"); discovered.hasExtruder = names.includes("extruder"); discovered.hasDisplayStatus = names.includes("display_status"); discovered.hasGcodeMove = names.includes("gcode_move"); discovered.hasVirtualSd = names.includes("virtual_sdcard"); discovered.hasToolhead = names.includes("toolhead"); discovered.hasPrintStats = names.includes("print_stats"); discovered.lastDiscoveryTs = Date.now(); await writeStr(`${ROOT}.meta.last_discovery`, new Date().toISOString()); await writeNum(`${ROOT}.meta.discovered.fans_count`, discovered.fans.length, "", "value"); await writeNum(`${ROOT}.meta.discovered.temp_sensors_count`, discovered.tempSensors.length, "", "value"); } catch (e) { log(`Moonraker discovery error: ${e.message}`, "warn"); } } function buildQueryParams() { const objs = ["print_stats"]; if (discovered.hasHeaterBed) objs.push("heater_bed"); if (discovered.hasExtruder) objs.push("extruder"); if (discovered.hasDisplayStatus) objs.push("display_status"); if (discovered.hasGcodeMove) objs.push("gcode_move"); if (discovered.hasVirtualSd) objs.push("virtual_sdcard"); if (discovered.hasToolhead) objs.push("toolhead"); if (discovered.hasPrintStats) objs.push("print_stats"); objs.push(...discovered.fans); objs.push(...discovered.tempSensors); const q = objs.map(encodeURIComponent).join("&"); return `${BASE}/printer/objects/query?${q}`; } // ======== REST DES POLLERS (pollOnce, Startup, Timer, etc.) ======== // Alexa-Ansage Tracking (Doppelansagen vermeiden) let lastPrintState = ""; let lastAnnouncedFile = ""; let lastAnnouncedTs = 0; const ANNOUNCE_COOLDOWN_MS = 5 * 60 * 1000; // 5 Minuten async function pollOnce() { try { // 1) Basisinfos const [serverInfo, printerInfo] = await Promise.all([ httpGet(`${BASE}/server/info`), httpGet(`${BASE}/printer/info`) ]); const s = serverInfo?.result || {}; await writeStr(`${ROOT}.server.version`, s.version || ""); await writeStr(`${ROOT}.server.klippy_state`, s.klippy_state || ""); await writeStr(`${ROOT}.server.hostname`, s.hostname || ""); await writeStr(`${ROOT}.server.websocket_address`, s.websocket_address || ""); const p = printerInfo?.result || {}; await writeStr(`${ROOT}.printer.state`, p.state || "unknown"); await writeBool(`${ROOT}.printer.ready`, p.state === "ready", "indicator.reachable"); // 2) Objekte ggf. alle 5 Min neu entdecken if (Date.now() - discovered.lastDiscoveryTs > 5 * 60 * 1000 || discovered.lastDiscoveryTs === 0) { await discoverObjects(); } // 3) Printer Objects abfragen const queryUrl = buildQueryParams(); const q = await httpGet(queryUrl); const res = q?.result?.status || {}; // ---- print_stats ---- let currentFilename = ""; let layerInfo = { current: null, total: null }; let metaFromFile = { layer_height: null, object_height: null }; if (res.print_stats) { const ps = res.print_stats; await writeStr(`${ROOT}.print_stats.state`, ps.state || ""); await writeStr(`${ROOT}.print_stats.filename`, ps.filename || ""); await writeStr(`${ROOT}.print_stats.message`, ps.message || ""); currentFilename = ps.filename || ""; // === Alexa-Ansage bei Fertigstellung === try { let shouldAnnounce = false; if ((ps.state || "") === "complete") { if (currentFilename) { if (currentFilename !== lastAnnouncedFile) { shouldAnnounce = true; lastAnnouncedFile = currentFilename; } } else if (lastPrintState !== "complete" && (Date.now() - lastAnnouncedTs) > ANNOUNCE_COOLDOWN_MS) { shouldAnnounce = true; } } if (shouldAnnounce) { const msg = currentFilename ? `Druckauftrag abgeschlossen: ${currentFilename}.` : "Der 3D Druck ist fertig."; setState(ALEXA_SPEAK_DP, { val: msg, ack: false }); // nutzt deinen Alexa-Datenpunkt lastAnnouncedTs = Date.now(); await writeStr(`${ROOT}.meta.last_completed_file`, currentFilename || ""); await writeStr(`${ROOT}.meta.last_announcement`, new Date().toISOString()); } lastPrintState = ps.state || ""; } catch (e) { log("Alexa-Fertig-Ansage fehlgeschlagen: " + e.message, "warn"); } if (ps.total_duration != null) await writeStr(`${ROOT}.print_stats.total_duration_hms`, toHMS(ps.total_duration), "time"); if (ps.print_duration != null) await writeStr(`${ROOT}.print_stats.print_duration_hms`, toHMS(ps.print_duration), "time"); if (ps.filament_used != null) { const m = Math.round((Number(ps.filament_used) || 0) / 10) / 100; // mm → m await writeNum(`${ROOT}.print_stats.filament_used_m`, m, "m", "value.length"); } if (ps.progress != null) { await writeNum(`${ROOT}.print_stats.progress_percent`, toPercent01(ps.progress), "%", "value.percent"); } // Layer bevorzugt aus print_stats.info (nur vorhanden, wenn Slicer SET_PRINT_STATS_INFO mitschreibt) const info = ps.info || {}; if (info.current_layer != null) layerInfo.current = Number(info.current_layer); if (info.total_layer != null) layerInfo.total = Number(info.total_layer); } // ---- toolhead (für Z→Layer-Fallback) ---- let zPos = null; if (res.toolhead) { const th = res.toolhead; if (Array.isArray(th.position)) { const [x, y, z] = th.position; zPos = (z != null ? Number(z) : null); await writeNum(`${ROOT}.toolhead.x`, round1(x), "mm", "value.length"); await writeNum(`${ROOT}.toolhead.y`, round1(y), "mm", "value.length"); await writeNum(`${ROOT}.toolhead.z`, round1(z), "mm", "value.length"); } if (th.max_velocity != null) await writeNum(`${ROOT}.toolhead.max_velocity`, round1(th.max_velocity), "mm/s", "value.speed"); if (th.max_accel != null) await writeNum(`${ROOT}.toolhead.max_accel`, round1(th.max_accel), "mm/s²", "value.acceleration"); if (th.homing_origin && Array.isArray(th.homing_origin)) { const [hx, hy, hz] = th.homing_origin; await writeNum(`${ROOT}.toolhead.homing_origin.x`, round1(hx), "mm", "value.length"); await writeNum(`${ROOT}.toolhead.homing_origin.y`, round1(hy), "mm", "value.length"); await writeNum(`${ROOT}.toolhead.homing_origin.z`, round1(hz), "mm", "value.length"); } if (th.print_time != null) await writeStr(`${ROOT}.toolhead.print_time_hms`, toHMS(th.print_time), "time"); } // ---- gcode_move ---- if (res.gcode_move) { const gm = res.gcode_move; if (gm.speed != null) await writeNum(`${ROOT}.gcode_move.speed`, round1(gm.speed), "mm/s", "value.speed"); if (gm.speed_factor != null) await writeNum(`${ROOT}.gcode_move.speed_factor_percent`, toPercent01(gm.speed_factor), "%", "value.percent"); if (gm.extrude_factor != null) await writeNum(`${ROOT}.gcode_move.extrude_factor_percent`, toPercent01(gm.extrude_factor), "%", "value.percent"); if (Array.isArray(gm.gcode_position)) { const [x, y, z, e] = gm.gcode_position; await writeNum(`${ROOT}.gcode_move.gcode_x`, round1(x), "mm", "value.length"); await writeNum(`${ROOT}.gcode_move.gcode_y`, round1(y), "mm", "value.length"); await writeNum(`${ROOT}.gcode_move.gcode_z`, round1(z), "mm", "value.length"); await writeNum(`${ROOT}.gcode_move.gcode_e`, round1(e), "mm", "value.length"); } } // ---- heater_bed ---- if (res.heater_bed) { const hb = res.heater_bed; if (hb.temperature != null) await writeNum(`${ROOT}.heater_bed.temperature`, round1(hb.temperature), "°C", "value.temperature"); if (hb.target != null) await writeNum(`${ROOT}.heater_bed.target`, round1(hb.target), "°C", "value.temperature"); if (hb.power != null) await writeNum(`${ROOT}.heater_bed.power_percent`, toPercent01(hb.power), "%", "value.percent"); } // ---- extruder ---- if (res.extruder) { const ex = res.extruder; if (ex.temperature != null) await writeNum(`${ROOT}.extruder.temperature`, round1(ex.temperature), "°C", "value.temperature"); if (ex.target != null) await writeNum(`${ROOT}.extruder.target`, round1(ex.target), "°C", "value.temperature"); if (ex.power != null) await writeNum(`${ROOT}.extruder.power_percent`, toPercent01(ex.power), "%", "value.percent"); if (ex.pressure_advance != null) await writeNum(`${ROOT}.extruder.pressure_advance`, round1(ex.pressure_advance), "", "value"); if (ex.smooth_time != null) await writeNum(`${ROOT}.extruder.smooth_time`, round1(ex.smooth_time), "s", "value.interval"); } // ---- virtual_sdcard ---- if (res.virtual_sdcard) { const vsd = res.virtual_sdcard; if (vsd.progress != null) await writeNum(`${ROOT}.virtual_sdcard.progress_percent`, toPercent01(vsd.progress), "%", "value.percent"); if (vsd.file_position != null) await writeNum(`${ROOT}.virtual_sdcard.file_position`, Number(vsd.file_position), "B", "value"); } // ---- display_status ---- if (res.display_status) { const ds = res.display_status; await writeStr(`${ROOT}.display_status.message`, ds.message || ""); if (ds.progress != null) await writeNum(`${ROOT}.display_status.progress_percent`, toPercent01(ds.progress), "%", "value.percent"); } // ---- Fans ---- for (const f of discovered.fans) { const key = f; const safeKey = key.replace(/\s+/g, "_"); const obj = res[key]; if (!obj) continue; if (obj.speed != null) await writeNum(`${ROOT}.fans.${safeKey}.speed_percent`, toPercent01(obj.speed), "%", "value.percent"); if (obj.rpm != null) await writeNum(`${ROOT}.fans.${safeKey}.rpm`, Number(obj.rpm), "rpm", "value"); } // ---- Temperatur-Sensoren ---- for (const t of discovered.tempSensors) { const key = t; const safeKey = key.replace(/\s+/g, "_"); const obj = res[key]; if (!obj) continue; if (obj.temperature != null) await writeNum(`${ROOT}.temp_sensors.${safeKey}.temperature`, round1(obj.temperature), "°C", "value.temperature"); if (obj.speed != null) await writeNum(`${ROOT}.temp_sensors.${safeKey}.speed_percent`, toPercent01(obj.speed), "%", "value.percent"); } // ---- Datei-Metadaten (Layer-Fallback) ---- if ((layerInfo.total == null || layerInfo.current == null) && currentFilename) { try { const meta = await httpGet(`${BASE}/server/files/metadata?filename=${encodeURIComponent(currentFilename)}`); const md = meta?.result || {}; const lh = md?.layer_height ?? md?.slicer?.layer_height ?? null; const oh = md?.object_height ?? md?.metadata?.object_height ?? null; if (lh != null) metaFromFile.layer_height = Number(lh); if (oh != null) metaFromFile.object_height = Number(oh); if (metaFromFile.layer_height != null) await writeNum(`${ROOT}.file.meta.layer_height_mm`, round1(metaFromFile.layer_height), "mm", "value.length"); if (metaFromFile.object_height != null) await writeNum(`${ROOT}.file.meta.object_height_mm`, round1(metaFromFile.object_height), "mm", "value.length"); if (layerInfo.total == null && metaFromFile.layer_height && metaFromFile.object_height) { layerInfo.total = Math.max(1, Math.round(metaFromFile.object_height / metaFromFile.layer_height)); } if (layerInfo.current == null && metaFromFile.layer_height && zPos != null) { layerInfo.current = Math.max(0, Math.min(layerInfo.total || 999999, Math.floor(zPos / metaFromFile.layer_height))); } } catch (e) { // nicht kritisch } } // ---- Layer in Datenpunkte schreiben ---- if (layerInfo.current != null) await writeNum(`${ROOT}.layers.current`, layerInfo.current, "", "value"); if (layerInfo.total != null) await writeNum(`${ROOT}.layers.total`, layerInfo.total, "", "value"); if (layerInfo.current != null && layerInfo.total != null && layerInfo.total > 0) { const pct = Math.round((layerInfo.current / layerInfo.total) * 1000) / 10; await writeNum(`${ROOT}.layers.progress_percent`, pct, "%", "value.percent"); } await writeStr(`${ROOT}.meta.last_update`, new Date().toISOString(), "date"); await writeBool(`${ROOT}.meta.ok`, true, "indicator.working"); } catch (e) { await writeBool(`${ROOT}.meta.ok`, false, "indicator.working"); await writeStr(`${ROOT}.meta.error`, e.message || String(e)); log(`Moonraker poll error: ${e.message}`, "warn"); } } // ======== STARTUP ======== (async () => { await ensureState(`${ROOT}.meta.ok`, { type: "boolean", def: false, read: true, write: false, role: "indicator.working" }); await discoverObjects(); pollOnce(); })(); // Intervall let pollTimer = setInterval(pollOnce, POLL_MS); // ======== OPTIONALE TESTFUNKTION (Alexa) ======== let testTimer = null; if (ENABLE_TEST_SPEAK) { testTimer = setInterval(() => { try { setState(ALEXA_SPEAK_DP, { val: TEST_MESSAGE, ack: false }); } catch (e) { log("Alexa-Testansage fehlgeschlagen: " + e.message, "warn"); } }, 60_000); }
@Lucifor1976 sagte in Adapter Klipper-Moonraker:
Ich war so frei und habe eine Scriptversion gebsatelt.
ich habe einen Drucker mit 4 Extruder.
Werden auch in Klipper erkannt.Das Script kennt leider nur 1 Extruder.


° Node.js Update ---> iob nodejs-update
° Fixer ---> iob fix -
wo in den hunderten DP von
klipper-moonraker.0find ich die Restdauer des aktuellem Druckjob?° Node.js Update ---> iob nodejs-update
° Fixer ---> iob fix -
Gibt es nicht. Muss man sich selbst berechnen. Blocklybeispiel von mir: https://pastebin.com/vjXPfyyK
..:: So long! Tom ::..
NUC7i3 (Ubuntu Proxmox VM) | Echo Dots 2+3. Gen | Xiaomi Sensoren | Mi Robot 1S | Yeelight | Sonoff | Shelly | H801 RGB | Gosund SP1 | NodeMCU+ESP32 | Kostal Plenticore PV+BYD | openWB
-
Gibt es nicht. Muss man sich selbst berechnen. Blocklybeispiel von mir: https://pastebin.com/vjXPfyyK
@Diginix sagte in Adapter Klipper-Moonraker:
Gibt es nicht. Muss man sich selbst berechnen.
Danke
Wo wird die Zeit gespeichert?
Sehe im Blockly nur Debug Output° Node.js Update ---> iob nodejs-update
° Fixer ---> iob fix -
@Diginix sagte in Adapter Klipper-Moonraker:
Gibt es nicht. Muss man sich selbst berechnen.
Danke
Wo wird die Zeit gespeichert?
Sehe im Blockly nur Debug Output@Negalein Musst dir selbst Objekte erstellen (z.B.
0_userdata.0.3D_Printer.print_time_remaining) und dort wo der Debug Block ist mit dem "aktualisiere Objekt" Block und dem Wert ergänzen.
..:: So long! Tom ::..
NUC7i3 (Ubuntu Proxmox VM) | Echo Dots 2+3. Gen | Xiaomi Sensoren | Mi Robot 1S | Yeelight | Sonoff | Shelly | H801 RGB | Gosund SP1 | NodeMCU+ESP32 | Kostal Plenticore PV+BYD | openWB
-
@Negalein Musst dir selbst Objekte erstellen (z.B.
0_userdata.0.3D_Printer.print_time_remaining) und dort wo der Debug Block ist mit dem "aktualisiere Objekt" Block und dem Wert ergänzen.
° Node.js Update ---> iob nodejs-update
° Fixer ---> iob fix -
@Negalein Sieht für mich so aus. Die Restzeit wird als Sekundenwert in das Objekt geschrieben. In meiner VIS formatiere ich das dann. Man könnte es natürlich auch schon formatiert als String in das Objekt schreiben. Das musst du für dich entscheiden.
..:: So long! Tom ::..
NUC7i3 (Ubuntu Proxmox VM) | Echo Dots 2+3. Gen | Xiaomi Sensoren | Mi Robot 1S | Yeelight | Sonoff | Shelly | H801 RGB | Gosund SP1 | NodeMCU+ESP32 | Kostal Plenticore PV+BYD | openWB
-
@Negalein Sieht für mich so aus. Die Restzeit wird als Sekundenwert in das Objekt geschrieben. In meiner VIS formatiere ich das dann. Man könnte es natürlich auch schon formatiert als String in das Objekt schreiben. Das musst du für dich entscheiden.
mir schmeisst es wärend des Drucks diese Meldung ins Log
at Object.<anonymous> (script.js.3D-Drucker.Restzeit_Klipper:6:5)° Node.js Update ---> iob nodejs-update
° Fixer ---> iob fix -
@merlin123
so mach ich es

(ip vom Drucker anpassen)
<block xmlns="https://developers.google.com/blockly/xml" type="on" id="/Z2O}ZB#,a]kn33Dz4F$" x="116" y="2253"> <field name="OID">mqtt.0.Mainsail.klipper.state.print_stats.filename</field> <field name="CONDITION">ne</field> <field name="ACK_CONDITION"></field> <statement name="STATEMENT"> <block type="variables_set" id="y[Oc#E_92,_2BKo4(5~["> <field name="VAR" id="BXYL{xhaLkN~v2Ldl!%!">text</field> <value name="VALUE"> <block type="get_attr" id="XXR]WqWt.=HMLUr3gR}@"> <value name="PATH"> <shadow type="text" id="rrx*$IEHd@w{;*~Z+8`n"> <field name="TEXT">value</field> </shadow> </value> <value name="OBJECT"> <shadow type="get_object" id="^cMzi*_aj{`Pl0P725m~"> <field name="OID">Object ID</field> </shadow> <block type="on_source" id="pgo{+7GzQz;]qj)e34}A"> <field name="ATTR">state.val</field> </block> </value> </block> </value> <next> <block type="update" id="bIOV@RC*Q+u,j_l+cDZ,"> <mutation xmlns="http://www.w3.org/1999/xhtml" delay_input="false"></mutation> <field name="OID">0_userdata.0.Klipper.API.Printjob.Name</field> <field name="WITH_DELAY">FALSE</field> <value name="VALUE"> <block type="text_getSubstring" id=";P~^,bl^VhcaeFBrn4B7"> <mutation at1="false" at2="true"></mutation> <field name="WHERE1">FIRST</field> <field name="WHERE2">FROM_START</field> <value name="STRING"> <block type="variables_get" id=".)~:q(Mh|eeSdPJRu*2!"> <field name="VAR" id="BXYL{xhaLkN~v2Ldl!%!">text</field> </block> </value> <value name="AT2"> <block type="math_arithmetic" id="~]oa3qPRWU)spG%YB1]]"> <field name="OP">MINUS</field> <value name="A"> <shadow type="math_number" id="PqrA)w7#cW-.+R7[s$Ut"> <field name="NUM">1</field> </shadow> <block type="text_indexOf" id="r51`DlwiN)v*}8k4q}5p"> <field name="END">FIRST</field> <value name="VALUE"> <block type="variables_get" id="sqPwTzw6?t1]F1dwmj|P"> <field name="VAR" id="BXYL{xhaLkN~v2Ldl!%!">text</field> </block> </value> <value name="FIND"> <shadow type="text" id="NN88q$[rF?qy3R1S,=Fk"> <field name="TEXT">.gcode</field> </shadow> </value> </block> </value> <value name="B"> <shadow type="math_number" id="Gp.#K1A?Y{{b4u]f,mK_"> <field name="NUM">1</field> </shadow> </value> </block> </value> </block> </value> <next> <block type="update" id="v~`h#IPc]?2X#3=M{X[a"> <mutation xmlns="http://www.w3.org/1999/xhtml" delay_input="false"></mutation> <field name="OID">0_userdata.0.Klipper.API.Printjob.Thumbnail</field> <field name="WITH_DELAY">FALSE</field> <value name="VALUE"> <block type="text_join" id="=uC)c{XD(`=yL3+qnM$/"> <mutation items="3"></mutation> <value name="ADD0"> <block type="text" id="+hu6Z]DDV49vxZEG3^KI"> <field name="TEXT">http://192.168.178.113/server/files/gcodes/.thumbs/</field> </block> </value> <value name="ADD1"> <block type="text_getSubstring" id=".jX}L{b`]tqX[lP+wIR2"> <mutation at1="false" at2="true"></mutation> <field name="WHERE1">FIRST</field> <field name="WHERE2">FROM_START</field> <value name="STRING"> <block type="variables_get" id="ZUXf!~C]B[?oTqjrU3mF"> <field name="VAR" id="BXYL{xhaLkN~v2Ldl!%!">text</field> </block> </value> <value name="AT2"> <block type="math_arithmetic" id="rArUrH5JD`!U0PI6`=Lt"> <field name="OP">MINUS</field> <value name="A"> <shadow type="math_number" id="PqrA)w7#cW-.+R7[s$Ut"> <field name="NUM">1</field> </shadow> <block type="text_indexOf" id="Gji4dA%oP(rS[%9W%X(m"> <field name="END">FIRST</field> <value name="VALUE"> <block type="variables_get" id="i=BXKzmS]z$x=!47DA!B"> <field name="VAR" id="BXYL{xhaLkN~v2Ldl!%!">text</field> </block> </value> <value name="FIND"> <shadow type="text" id="nTgAoKx?A/?1e#g9JTXQ"> <field name="TEXT">.gcode</field> </shadow> </value> </block> </value> <value name="B"> <shadow type="math_number" id="u3_-Ii7/U+4%YQw8Az@I"> <field name="NUM">1</field> </shadow> </value> </block> </value> </block> </value> <value name="ADD2"> <block type="text" id="sn3+k)T(}R(KvqNhQ6;v"> <field name="TEXT">.png</field> </block> </value> </block> </value> </block> </next> </block> </next> </block> </statement> </block>@stenmic sagte in Adapter Klipper-Moonraker:
so mach ich es
ich verwende dein Thjmbnail-Blockly, aber mir wird nichts in den DP geschrieben.
Thumb-URL =
http://10.0.1.244/server/files/gcodes/.thumbs/Santa%20Cat_PLA-300x300.png?date=1765399759.793023

° Node.js Update ---> iob nodejs-update
° Fixer ---> iob fix -
mir schmeisst es wärend des Drucks diese Meldung ins Log
at Object.<anonymous> (script.js.3D-Drucker.Restzeit_Klipper:6:5)@Negalein sagte in Adapter Klipper-Moonraker:
mir schmeisst es wärend des Drucks diese Meldung ins Log
at Object.<anonymous> (script.js.3D-Drucker.Restzeit_Klipper:6:5)Sieht für mich so aus als dass es das Objekt, welches du beschreiben willst, nicht gibt.
Schalte mal auf die Javascriptansicht im Blockly und poste daraus Zeile 6...:: So long! Tom ::..
NUC7i3 (Ubuntu Proxmox VM) | Echo Dots 2+3. Gen | Xiaomi Sensoren | Mi Robot 1S | Yeelight | Sonoff | Shelly | H801 RGB | Gosund SP1 | NodeMCU+ESP32 | Kostal Plenticore PV+BYD | openWB
-
@Negalein sagte in Adapter Klipper-Moonraker:
mir schmeisst es wärend des Drucks diese Meldung ins Log
at Object.<anonymous> (script.js.3D-Drucker.Restzeit_Klipper:6:5)Sieht für mich so aus als dass es das Objekt, welches du beschreiben willst, nicht gibt.
Schalte mal auf die Javascriptansicht im Blockly und poste daraus Zeile 6.@Diginix sagte in Adapter Klipper-Moonraker:
Sieht für mich so aus als dass es das Objekt, welches du beschreiben willst, nicht gibt.
on({ id: 'klipper-moonraker.0.display_status.progress' /* Progress in Percent */, change: 'ne' }, async (obj) => { let value = obj.state.val; let oldValue = obj.oldState.val; if (getState('klipper-moonraker.0.print_stats.print_duration').val > 0) { setState('0_userdata.0.3DDrucker.Snapmaker_U1.Restzeit' /* Restzeit */, ((obj.state ? obj.state.val : '') < 1 ? Math.round(((1 - (obj.state ? obj.state.val : '')) * getState('klipper-moonraker.0.print_stats.print_duration').val) / (obj.state ? obj.state.val : '')) : 0), true); setState('0_userdata.0.3DDrucker.Snapmaker_U1.Endzeit' /* Endzeit */, formatDate(getDateObject(((new Date().getTime()) + ((obj.state ? obj.state.val : '') < 1 ? Math.round((((1 - (obj.state ? obj.state.val : '')) * getState('klipper-moonraker.0.print_stats.print_duration').val) / (obj.state ? obj.state.val : '')) * 1000) : 0))), 'TT.MM.JJJJ SS:mm'), true); } });
° Node.js Update ---> iob nodejs-update
° Fixer ---> iob fix -
@Diginix sagte in Adapter Klipper-Moonraker:
Sieht für mich so aus als dass es das Objekt, welches du beschreiben willst, nicht gibt.
on({ id: 'klipper-moonraker.0.display_status.progress' /* Progress in Percent */, change: 'ne' }, async (obj) => { let value = obj.state.val; let oldValue = obj.oldState.val; if (getState('klipper-moonraker.0.print_stats.print_duration').val > 0) { setState('0_userdata.0.3DDrucker.Snapmaker_U1.Restzeit' /* Restzeit */, ((obj.state ? obj.state.val : '') < 1 ? Math.round(((1 - (obj.state ? obj.state.val : '')) * getState('klipper-moonraker.0.print_stats.print_duration').val) / (obj.state ? obj.state.val : '')) : 0), true); setState('0_userdata.0.3DDrucker.Snapmaker_U1.Endzeit' /* Endzeit */, formatDate(getDateObject(((new Date().getTime()) + ((obj.state ? obj.state.val : '') < 1 ? Math.round((((1 - (obj.state ? obj.state.val : '')) * getState('klipper-moonraker.0.print_stats.print_duration').val) / (obj.state ? obj.state.val : '')) * 1000) : 0))), 'TT.MM.JJJJ SS:mm'), true); } });
Daran stört er sich:
@Negalein sagte in Adapter Klipper-Moonraker:setState('0_userdata.0.3DDrucker.Snapmaker_U1.Endzeit'
Ist die Objekt-ID von Endzeit aus deinem Screenshot
0_userdata.0.3DDrucker.Snapmaker_U1.Endzeit?Falls das eigentlich alles passt. Einfach das Skript mal stoppen und nochmal starten oder im Blocklymodus bei den "Aktualisiere" Blöcken noch mal neu die zwei Objekte per Klick auswählen.
btw: Hast du den Snapmaker U1 über die Kickstarter Aktion gekauft und wie zufrieden bist du mit dem Kopfwechsel bzw. den Ergebnissen?
..:: So long! Tom ::..
NUC7i3 (Ubuntu Proxmox VM) | Echo Dots 2+3. Gen | Xiaomi Sensoren | Mi Robot 1S | Yeelight | Sonoff | Shelly | H801 RGB | Gosund SP1 | NodeMCU+ESP32 | Kostal Plenticore PV+BYD | openWB
-
Daran stört er sich:
@Negalein sagte in Adapter Klipper-Moonraker:setState('0_userdata.0.3DDrucker.Snapmaker_U1.Endzeit'
Ist die Objekt-ID von Endzeit aus deinem Screenshot
0_userdata.0.3DDrucker.Snapmaker_U1.Endzeit?Falls das eigentlich alles passt. Einfach das Skript mal stoppen und nochmal starten oder im Blocklymodus bei den "Aktualisiere" Blöcken noch mal neu die zwei Objekte per Klick auswählen.
btw: Hast du den Snapmaker U1 über die Kickstarter Aktion gekauft und wie zufrieden bist du mit dem Kopfwechsel bzw. den Ergebnissen?
@Diginix sagte in Adapter Klipper-Moonraker:
Falls das eigentlich alles passt. Einfach das Skript mal stoppen und nochmal starten oder im Blocklymodus bei den "Aktualisiere" Blöcken noch mal neu die zwei Objekte per Klick auswählen.
Ja, das passt alles.
Ich machs nochmal neu.btw: Hast du den Snapmaker U1 über die Kickstarter Aktion gekauft und wie zufrieden bist du mit dem Kopfwechsel bzw. den Ergebnissen?
Ja, war einer der Ersten.
Hatte Kontakt zu einem Beta-Tester. Deshalb kannte ich das Teil schon. ;)Kopfwechsel ist extrem schnell.
Qualität mit Standardsettings out of the Box ist Hammer.° Node.js Update ---> iob nodejs-update
° Fixer ---> iob fix
