Skip to content
  • Home
  • Aktuell
  • Tags
  • 0 Ungelesen 0
  • Kategorien
  • Unreplied
  • Beliebt
  • GitHub
  • Docu
  • Hilfe
Skins
  • Light
  • Brite
  • Cerulean
  • Cosmo
  • Flatly
  • Journal
  • Litera
  • Lumen
  • Lux
  • Materia
  • Minty
  • Morph
  • Pulse
  • Sandstone
  • Simplex
  • Sketchy
  • Spacelab
  • United
  • Yeti
  • Zephyr
  • Dark
  • Cyborg
  • Darkly
  • Quartz
  • Slate
  • Solar
  • Superhero
  • Vapor

  • Standard: (Kein Skin)
  • Kein Skin
Einklappen
ioBroker Logo

Community Forum

donate donate
  1. ioBroker Community Home
  2. Deutsch
  3. ioBroker Allgemein
  4. Adapter Klipper-Moonraker

NEWS

  • Jahresrückblick 2025 – unser neuer Blogbeitrag ist online! ✨
    BluefoxB
    Bluefox
    14
    1
    154

  • Neuer Blogbeitrag: Monatsrückblick - Dezember 2025 🎄
    BluefoxB
    Bluefox
    12
    1
    566

  • Weihnachtsangebot 2025! 🎄
    BluefoxB
    Bluefox
    24
    1
    1.7k

Adapter Klipper-Moonraker

Geplant Angeheftet Gesperrt Verschoben ioBroker Allgemein
klippermoonrakeradapter update
162 Beiträge 25 Kommentatoren 22.8k Aufrufe 22 Watching
  • Älteste zuerst
  • Neuste zuerst
  • Meiste Stimmen
Antworten
  • In einem neuen Thema antworten
Anmelden zum Antworten
Dieses Thema wurde gelöscht. Nur Nutzer mit entsprechenden Rechten können es sehen.
  • 1Topf1 1Topf

    @diginix

    Ich habe es anders gelöst. In der main.js /opt/iobroker/node_modules/iobroker.klipper-moonraker/main.js hab ich die Zeit für den reconnect von 10 auf 7200 Sekunden gesetzt. In Notepad++ ist das bei mir die Zeile 335.

    		// Handle closure of socket connection, try to connect again in 10seconds (if adapter enabled)
    		ws.on('close', () => {
    			console.log(`Connection closed`);
    			this.log.info(`Connection closed`);
    			this.setState('info.connection', false, true);
    			connectionState = false;
    
    			// Try to reconnect if connections is closed after 10 seconds
    			if (reconnectTimer) {
    				clearTimeout(reconnectTimer);
    				reconnectTimer = null;
    			}
    			reconnectTimer = setTimeout(() => {
    				console.log(`Trying to reconnect`);
    				this.log.info(`Trying to reconnect`);
    				if (this.config.auth) {
    					try {
    						this.getOneShotToken();
    					} catch (e) {
    						this.log.error(e.message);
    					}
    				}
    				this.handleWebSocket();
    			}, (7200_000));
    		});
    
    mcm1957M Offline
    mcm1957M Offline
    mcm1957
    schrieb am zuletzt editiert von
    #117

    Wenn ich nicht übersehen habe ist der Adapter klipper-moonraker nicht in den Repositories verfügbar. Eine INstallation ist daher nur via GitHub möglich. Der Status des Adapters muss daher als im ALPHA Test definiert werden.

    Da dieses Topic nicht im Testerbereich liegt eine WARNING an alle User die sich nicht als ALPHA Tester bezeichnen:

    Von direkten Installation von GitHub - insbesondere auf produktiven Systemen - wird explizit abgeraten.

    GitHub Versionen können sich jederzeit (auch kurzfristig) ändern und durchaus auch in sich inkonsistent und fehlerhaft sein. Versionsangaben von GitHub Installationen sind Schall und Rauch da die Versionsnummer zumindest bei Verwendung der standardmäßigen Umgebung erst im Zuge der Releaseerstellung geändert wird.

    Auf explizite Aufforderung durch den Entwickler kann eine GitHub Installation zur Fehlereingrenzung oder zum Test neuer Funktionalität - unter Inkaufnahme des erhöhten Risikos - natürlich erfolgen.

    Adapter die nur via GitHub oder npm (also NICHT aus einem der beiden Repositories) installierbar sind sind mit erhöhter Vorsicht zu betrachten. Hier sollte der Entwickler drum ersucht werden eine Aufnahme in die Repositories zu veranlassen indem z.B. ein Issue im Adapterrepository erstellt wird.

    Und falls es irgendwie unklar ist:

    ioBroker unterstützt folgende Arten von Installation:

    • aus dem STABLE Repository

      Das sind Adapter Releases die keine groben Fehler aufweisen (sollten). Natürlich kann es auch dort Fehler geben, die Behebung davon obliegt dem jeweiligen Dev und kann ggF auch dauern.

    • aus dem LATEST Repository

      Das sind Adapter Releases die neu erstellt wurden und nur rudimentär getestet sind - oft auch als BETA Releases bezeichnet. Releases aus dem LATEST sind primär für unsere zahlreichen freiwilligen Tester gedacht. BETA / LATEST Releases können durchaus Fehler aufweisen - auch wenn ich davon ausgehe dass jeder aintainer dies zu vermeiden versucht. Vom Einsatz auf produktiven Systemen wird abgeraten außer man braucht irgenein neues Feature (z.B. neues Gerät) unbedingt. Hier muss dann jeder Entscheiden was ihm wichtig ist.

    • direkt von GITHUB

      Von Installationen direkt aus Giuthub wird definitiv abgeraten außer auf Anweisung des Maintainers und für den Fall dass man gemeinsam mit diesem etwas testen will. Details siehe oben.

    • direkt von npm

      Diese Installation kann erforderlich sein, wenn man eine bestimmte Version installieren möchte / muss. Im Normalfall sollte man direkte npm Installationen ebenso meiden wie direkte GitHub Installationen - ausgenommen um z.B. zu einer bekannten Version downzugraden - obwohl hier wenigstens ein definierter Stand garantiert ist.

    Adapter die NUR via npm und/oder nur via GitHub installierbar sind sollte man meiden - diese wurden nicht mal einem rudimentären Review unterzogen und sollten mit dem Attribut "vollständig auf eigenes Risiko verwenden" installiert werden. Hier empfiehlt es sich den Developer zu ersuchen eine Aufnahme in die Repos zu veranlassen. Wenn dieser darauf nicht reagiert sollte man von einer eher kurzen und unklaren Lebensdauer des Adapters ausgehen. Support meiner-/unsererseits für solche Adapter ist mit Sicherheit minimalistisch.

    Entwicklung u Betreuung: envertech-pv, hoymiles-ms, ns-client, pid, snmp Adapter;
    Support Repositoryverwaltung.

    Wer Danke sagen will, kann nen Kaffee spendieren: https://paypal.me/mcm1957atiobroker

    LESEN - gute Forenbeitrage

    1 Antwort Letzte Antwort
    0
    • N Netcrusher

      Moin zusammen, ich habe mir ein Script geschrieben, welches periodisch die moonraker api nach den wichtigsten Infos abfragt und in iobroker Javascript States schreibt. Das wäre mit Hilfe der moonraker API-Dokumentation auch recht einfach erweiterbar.
      Falls es jemand gebrauchen kann (ohne Gewähr):

      const printerName = 'VORON'; // Replace with your actual printer name
      const printerBaseUrl = 'http://192.168.2.32'; // Replace with your actual moonraker ip
      const updateInterval = 20000; // 20 seconds
      
      // Function to make an HTTP request and return a promise
      function getPrinterStatus(url) {
          return new Promise((resolve, reject) => {
              const request = require('request');
              request(url, { json: true }, (err, res, body) => {
                  if (err) {
                      reject(err);
                  } else {
                      resolve(body);
                  }
              });
          });
      }
      
      // Function to get metadata for the given filename
      function getFileMetadata(filename) {
          const metadataUrl = printerBaseUrl + `/server/files/metadata?filename=${encodeURIComponent(filename)}`;
          return getPrinterStatus(metadataUrl); // Reusing the HTTP request function
      }
      
      // Function to convert seconds to HH:MM:SS
      function toHHMMSS(seconds) {
          const hours = Math.floor(seconds / 3600);
          const minutes = Math.floor((seconds % 3600) / 60);
          const sec = Math.floor(seconds % 60);
          return [hours, minutes, sec]
              .map(v => v < 10 ? "0" + v : v)
              .join(":");
      }
      
      // Function to update the online status of the printer
      function updatePrinterOnlineStatus(isOnline) {
          const onlineStateName = `${printerName}.onlineStatus`;
          createOrUpdateState(onlineStateName, isOnline);
      }
      
      // Function to create or update ioBroker states
      function createOrUpdateState(fullStateName, value, key='') {
      
          // Check if the key contains 'duration' and format it if it does
          if (key.includes('duration')) {
              value = toHHMMSS(value);
          }
      
          // Check if the key contains 'progress' and multiply by 100 and round it if it does
          if (key.includes('progress')) {
              value = Math.round(value * 100); // Converts to percentage and rounds to the nearest integer
          }
      
          if (!existsState(fullStateName)) {
              createState(fullStateName, {
                  type: typeof value,
                  read: true,
                  write: false,
                  desc: 'Printer status value'
              }, () => {
                  setState(fullStateName, value, true);
              });
          } else {
              setState(fullStateName, value, true);
          }
      }
      
      // Function to process the printer status and update the ioBroker states
      function processPrinterStatus(printerData, parentKey = '') {
          Object.keys(printerData).forEach(key => {
              const value = printerData[key];
              let fullStateName = `${printerName}`;
              if (parentKey) {
                  fullStateName += `.${parentKey}`;
              }
              fullStateName += `.${key}`;
      
              if (value !== null && typeof value === 'object' && !(value instanceof Array)) {
                  // It's a nested object, so we need to recurse
                  processPrinterStatus(value, key);
              } else {
                  // It's a value, so we create or update the state
                  createOrUpdateState(fullStateName, value, key);
              }
          });
      }
      
      // Function to nullify file metadata states in ioBroker
      function nullifyFileMetadataStates() {
      
          var states = $(`*.${printerName}.file_metadata.*`/*Printer file metadata*/);
       
          states.each(function(id, i){
              setState(id, {val: null, ack: true});
          });
      }
      
      // Polling function
      function startPolling() {
          setInterval(() => {
              getPrinterStatus(printerBaseUrl + '/printer/objects/query?display_status&print_stats&extruder&heater_bed&system_stats')
                  .then(response => {
                      if (response && response.result) {
                          
                          const printStats = response.result.status.print_stats || {};
                          const filename = printStats.filename;
                          
                          // Update printer status
                          processPrinterStatus(response.result);
      
                          // If there is a filename, get and process the file metadata
                          if (filename) {
                              getFileMetadata(filename).then(metadataResponse => {
                                  if (metadataResponse && metadataResponse.result) {
                                      processPrinterStatus(metadataResponse.result, 'file_metadata');
                                  }
                              }).catch(error => {
                                  console.error('Error fetching file metadata:', error);
                              });
                          } else {
                              // If filename is empty, nullify all file_metadata states
                              nullifyFileMetadataStates();
                          }
                          
                          updatePrinterOnlineStatus(true); // Printer is online
                      }
                  })
                  .catch(error => {
                      console.log('Error fetching printer status... setting Printer offline');
                      updatePrinterOnlineStatus(false); // Printer is offline
                  });
          }, updateInterval);
      }
      
      // Start the polling process
      startPolling();
      

      b083f8f8-1b4c-4307-9d56-b21237644d11-image.png

      C Offline
      C Offline
      CaesarII
      schrieb am zuletzt editiert von
      #118

      @netcrusher
      dein Skript gefällt mir sehr gut. Ein dickes DANKE dafür.
      Allerdings hätte da 2 Wünsche.
      -Wäre es möglich dass der Ausgabepfad nicht in javascript.0 sondern ein Verzeichnis in 0_userdata die Daten schreibt?
      -Dann bekomme ich eine Fehlermeldung über "request package is deprecated - please use httpGet (or a stable lib like axios) instead!"
      Würde mich freuen wenn der Skript wieder ohne Fehlermeldungen funktioniert.

      foxriver76F 1 Antwort Letzte Antwort
      0
      • C CaesarII

        @netcrusher
        dein Skript gefällt mir sehr gut. Ein dickes DANKE dafür.
        Allerdings hätte da 2 Wünsche.
        -Wäre es möglich dass der Ausgabepfad nicht in javascript.0 sondern ein Verzeichnis in 0_userdata die Daten schreibt?
        -Dann bekomme ich eine Fehlermeldung über "request package is deprecated - please use httpGet (or a stable lib like axios) instead!"
        Würde mich freuen wenn der Skript wieder ohne Fehlermeldungen funktioniert.

        foxriver76F Offline
        foxriver76F Offline
        foxriver76
        Developer
        schrieb am zuletzt editiert von
        #119

        @caesarii auch gerne mal 0.1.1 probieren ob das problem behoben ist dass der reconnect nicht funktioniert.

        Videotutorials & mehr

        Hier könnt ihr mich unterstützen.

        C 1 Antwort Letzte Antwort
        0
        • foxriver76F foxriver76

          @caesarii auch gerne mal 0.1.1 probieren ob das problem behoben ist dass der reconnect nicht funktioniert.

          C Offline
          C Offline
          CaesarII
          schrieb am zuletzt editiert von
          #120

          @foxriver76
          0.1.1 installiert und auch getestet
          Jedoch startet der Adapter gerade bei meinem aktuellen Druck nicht richtig und liefert keine aktuellen Daten. Erst ein "Neu starten" löst das Problem. Dann funktioniert auch alles perfekt.
          Das andere Problem ist wenn der 3D-Drucker ausgeschaltet ist, bekomme ich quasi im Minutentackt die Error Meldung dass keine Verbindung zu moonraker besteht. Hab mir damit geholfen dass ich den Adapter erst dann starte nachdem auch den 3D-Drucker mit Spannung versorgt wird (timeout 30000).

          Wenn ich irgendwie behilflich sein kann kein Problem.

          1 Antwort Letzte Antwort
          0
          • Lucifor1976L Offline
            Lucifor1976L Offline
            Lucifor1976
            schrieb am zuletzt editiert von
            #121

            Sehr schön das sich jemand um Klipper kümmert :)

            Gerade zwei Instanzen installiert.

            Was mir direkt auffällt:

            Progress stimmt nicht mit Klipper überein Klipper= 35% Adapter = 44%? Wobei der Progress /100 angezeigt wird?
            (klipper-moonraker.0.display_status.progress)

            Verbrauchtes Filament stimmt nicht mit Klipper überein, Klipper= 1m Adapter 1,2m
            (klipper-moonraker.0.print_stats.total_duration)

            Der Gerade gedruckte Layer wird nicht übertragen. (Null)
            (klipper-moonraker.0.print_stats.info.current_layer)
            Ebenfalls für Total Layer
            (klipper-moonraker.0.print_stats.info.total_layer)

            Ansonsten saubere Arbeit :) und Danke dafür.

            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

            mcm1957M 1 Antwort Letzte Antwort
            0
            • Lucifor1976L Lucifor1976

              Sehr schön das sich jemand um Klipper kümmert :)

              Gerade zwei Instanzen installiert.

              Was mir direkt auffällt:

              Progress stimmt nicht mit Klipper überein Klipper= 35% Adapter = 44%? Wobei der Progress /100 angezeigt wird?
              (klipper-moonraker.0.display_status.progress)

              Verbrauchtes Filament stimmt nicht mit Klipper überein, Klipper= 1m Adapter 1,2m
              (klipper-moonraker.0.print_stats.total_duration)

              Der Gerade gedruckte Layer wird nicht übertragen. (Null)
              (klipper-moonraker.0.print_stats.info.current_layer)
              Ebenfalls für Total Layer
              (klipper-moonraker.0.print_stats.info.total_layer)

              Ansonsten saubere Arbeit :) und Danke dafür.

              mcm1957M Offline
              mcm1957M Offline
              mcm1957
              schrieb am zuletzt editiert von
              #122

              @lucifor1976

              Der Adapter ioBroker.klipper-moonraker ist NICHT in einem repository gelistet.

              Von direkten Installation von GitHub - insbesondere auf produktiven Systemen - wird explizit abgeraten.

              GitHub Versionen können sich jederzeit (auch kurzfristig) ändern und durchaus auch in sich inkonsistent und fehlerhaft sein. Versionsangaben von GitHub Installationen sind Schall und Rauch da die Versionsnummer zumindest bei Verwendung der standardmäßigen Umgebung erst im Zuge der Releaseerstellung geändert wird.

              Auf explizite Aufforderung durch den Entwickler kann eine GitHub Installation zur Fehlereingrenzung oder zum Test neuer Funktionalität - unter Inkaufnahme des erhöhten Risikos - natürlich erfolgen.

              Adapter die nur via GitHub oder npm (also NICHT aus einem der beiden Repositories) installierbar sind sind mit erhöhter Vorsicht zu betrachten. Hier sollte der Entwickler drum ersucht werden eine Aufnahme in die Repositories zu veranlassen indem z.B. ein Issue im Adapterrepository erstellt wird.

              Und falls es irgendwie unklar ist:

              ioBroker unterstützt folgende Arten von Installation:

              • aus dem STABLE Repository

                Das sind Adapter Releases die keine groben Fehler aufweisen (sollten). Natürlich kann es auch dort Fehler geben, die Behebung davon obliegt dem jeweiligen Dev und kann ggF auch dauern.

              • aus dem LATEST Repository

                Das sind Adapter Releases die neu erstellt wurden und nur rudimentär getestet sind - oft auch als BETA Releases bezeichnet. Releases aus dem LATEST sind primär für unsere zahlreichen freiwilligen Tester gedacht. BETA / LATEST Releases können durchaus Fehler aufweisen - auch wenn ich davon ausgehe dass jeder aintainer dies zu vermeiden versucht. Vom Einsatz auf produktiven Systemen wird abgeraten außer man braucht irgenein neues Feature (z.B. neues Gerät) unbedingt. Hier muss dann jeder Entscheiden was ihm wichtig ist.

              • direkt von GITHUB

                Von Installationen direkt aus Giuthub wird definitiv abgeraten außer auf Anweisung des Maintainers und für den Fall dass man gemeinsam mit diesem etwas testen will. Details siehe oben.

              • direkt von npm

                Diese Installation kann erforderlich sein, wenn man eine bestimmte Version installieren möchte / muss. Im Normalfall sollte man direkte npm Installationen ebenso meiden wie direkte GitHub Installationen - ausgenommen um z.B. zu einer bekannten Version downzugraden - obwohl hier wenigstens ein definierter Stand garantiert ist.

              Adapter die NUR via npm und/oder nur via GitHub installierbar sind sollte man meiden - diese wurden nicht mal einem rudimentären Review unterzogen und sollten mit dem Attribut "vollständig auf eigenes Risiko verwenden" installiert werden. Hier empfiehlt es sich den Developer zu ersuchen eine Aufnahme in die Repos zu veranlassen. Wenn dieser darauf nicht reagiert sollte man von einer eher kurzen und unklaren Lebensdauer des Adapters ausgehen. Support meiner-/unsererseits für solche Adapter ist mit Sicherheit minimalistisch.

              @mcm1957

              Entwicklung u Betreuung: envertech-pv, hoymiles-ms, ns-client, pid, snmp Adapter;
              Support Repositoryverwaltung.

              Wer Danke sagen will, kann nen Kaffee spendieren: https://paypal.me/mcm1957atiobroker

              LESEN - gute Forenbeitrage

              1 Antwort Letzte Antwort
              1
              • Lucifor1976L Offline
                Lucifor1976L Offline
                Lucifor1976
                schrieb am zuletzt editiert von Lucifor1976
                #123

                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);
                }
                

                iScreen Shoter - Firefox - 250816165523.jpg

                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

                NegaleinN 1Topf1 3 Antworten Letzte Antwort
                3
                • S stenmic

                  @merlin123
                  so mach ich es

                  IMG_0967.jpeg

                  IMG_0966.jpeg
                  (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>
                  
                  

                  D Offline
                  D Offline
                  DoubleD
                  schrieb am zuletzt editiert von
                  #124

                  @stenmic sagte in Adapter Klipper-Moonraker:

                  IMG_0967.jpeg

                  @stenmic
                  Sehr cooles VIS-Design.
                  Würdest Du das teilen?

                  Gruß Daniel

                  NegaleinN 1 Antwort Letzte Antwort
                  0
                  • Lucifor1976L Lucifor1976

                    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);
                    }
                    

                    iScreen Shoter - Firefox - 250816165523.jpg

                    NegaleinN Offline
                    NegaleinN Offline
                    Negalein
                    Global Moderator
                    schrieb am zuletzt editiert von
                    #125

                    @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/info
                    

                    Gibt es eine Möglichkeit, diese Meldung zu unterdrücken?

                    PS: kannst du den View exportieren? ;)

                    ° Node.js Update ---> iob nodejs-update
                    ° Fixer ---> iob fix

                    da_WoodyD 1 Antwort Letzte Antwort
                    0
                    • D DoubleD

                      @stenmic sagte in Adapter Klipper-Moonraker:

                      IMG_0967.jpeg

                      @stenmic
                      Sehr cooles VIS-Design.
                      Würdest Du das teilen?

                      Gruß Daniel

                      NegaleinN Offline
                      NegaleinN Offline
                      Negalein
                      Global Moderator
                      schrieb am zuletzt editiert von
                      #126

                      @stenmic

                      Sehr cooles VIS-Design.
                      Würdest Du das teilen?

                      würde mich auch freuen

                      ° Node.js Update ---> iob nodejs-update
                      ° Fixer ---> iob fix

                      1 Antwort Letzte Antwort
                      0
                      • NegaleinN Negalein

                        @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/info
                        

                        Gibt es eine Möglichkeit, diese Meldung zu unterdrücken?

                        PS: kannst du den View exportieren? ;)

                        da_WoodyD Offline
                        da_WoodyD Offline
                        da_Woody
                        schrieb am zuletzt editiert von
                        #127

                        @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!

                        NegaleinN 1 Antwort Letzte Antwort
                        0
                        • Lucifor1976L Lucifor1976

                          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);
                          }
                          

                          iScreen Shoter - Firefox - 250816165523.jpg

                          1Topf1 Offline
                          1Topf1 Offline
                          1Topf
                          schrieb am zuletzt editiert von
                          #128

                          @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?

                          1 Antwort Letzte Antwort
                          0
                          • da_WoodyD da_Woody

                            @Negalein sagte in Adapter Klipper-Moonraker:

                            Gibt es eine Möglichkeit, diese Meldung zu unterdrücken?

                            stell die instanz auf error um.

                            NegaleinN Offline
                            NegaleinN Offline
                            Negalein
                            Global Moderator
                            schrieb am zuletzt editiert von
                            #129

                            @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

                            1 Antwort Letzte Antwort
                            0
                            • Lucifor1976L Lucifor1976

                              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);
                              }
                              

                              iScreen Shoter - Firefox - 250816165523.jpg

                              NegaleinN Offline
                              NegaleinN Offline
                              Negalein
                              Global Moderator
                              schrieb am zuletzt editiert von
                              #130

                              @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.

                              1c9daef3-b983-4450-8866-d388b5e86f59-image.png

                              04693235-9514-4efe-8219-f0e67a105ca8-image.png

                              ° Node.js Update ---> iob nodejs-update
                              ° Fixer ---> iob fix

                              1 Antwort Letzte Antwort
                              0
                              • NegaleinN Offline
                                NegaleinN Offline
                                Negalein
                                Global Moderator
                                schrieb am zuletzt editiert von
                                #131

                                @da_woody

                                wo in den hunderten DP von klipper-moonraker.0 find ich die Restdauer des aktuellem Druckjob?

                                ° Node.js Update ---> iob nodejs-update
                                ° Fixer ---> iob fix

                                1 Antwort Letzte Antwort
                                0
                                • DiginixD Offline
                                  DiginixD Offline
                                  Diginix
                                  schrieb am zuletzt editiert von
                                  #132

                                  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

                                  NegaleinN 1 Antwort Letzte Antwort
                                  0
                                  • DiginixD Diginix

                                    Gibt es nicht. Muss man sich selbst berechnen. Blocklybeispiel von mir: https://pastebin.com/vjXPfyyK

                                    NegaleinN Offline
                                    NegaleinN Offline
                                    Negalein
                                    Global Moderator
                                    schrieb am zuletzt editiert von
                                    #133

                                    @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

                                    DiginixD 1 Antwort Letzte Antwort
                                    0
                                    • NegaleinN Negalein

                                      @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

                                      DiginixD Offline
                                      DiginixD Offline
                                      Diginix
                                      schrieb am zuletzt editiert von Diginix
                                      #134

                                      @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.

                                      8bf8538b-e2dd-4c15-bd85-db59ba3ea9cb-image.png

                                      ..:: 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

                                      NegaleinN 1 Antwort Letzte Antwort
                                      1
                                      • DiginixD Diginix

                                        @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.

                                        8bf8538b-e2dd-4c15-bd85-db59ba3ea9cb-image.png

                                        NegaleinN Offline
                                        NegaleinN Offline
                                        Negalein
                                        Global Moderator
                                        schrieb am zuletzt editiert von Negalein
                                        #135

                                        @Diginix sagte in Adapter Klipper-Moonraker:

                                        Musst dir selbst Objekte erstellen

                                        Danke

                                        passt so?

                                        72d442ec-7c6b-4928-bdee-b6b71123b9bd-image.png

                                        ° Node.js Update ---> iob nodejs-update
                                        ° Fixer ---> iob fix

                                        DiginixD 1 Antwort Letzte Antwort
                                        0
                                        • NegaleinN Negalein

                                          @Diginix sagte in Adapter Klipper-Moonraker:

                                          Musst dir selbst Objekte erstellen

                                          Danke

                                          passt so?

                                          72d442ec-7c6b-4928-bdee-b6b71123b9bd-image.png

                                          DiginixD Offline
                                          DiginixD Offline
                                          Diginix
                                          schrieb am zuletzt editiert von
                                          #136

                                          @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

                                          NegaleinN 1 Antwort Letzte Antwort
                                          1
                                          Antworten
                                          • In einem neuen Thema antworten
                                          Anmelden zum Antworten
                                          • Älteste zuerst
                                          • Neuste zuerst
                                          • Meiste Stimmen


                                          Support us

                                          ioBroker
                                          Community Adapters
                                          Donate
                                          FAQ Cloud / IOT
                                          HowTo: Node.js-Update
                                          HowTo: Backup/Restore
                                          Downloads
                                          BLOG

                                          341

                                          Online

                                          32.5k

                                          Benutzer

                                          81.8k

                                          Themen

                                          1.3m

                                          Beiträge
                                          Community
                                          Impressum | Datenschutz-Bestimmungen | Nutzungsbedingungen | Einwilligungseinstellungen
                                          ioBroker Community 2014-2025
                                          logo
                                          • Anmelden

                                          • Du hast noch kein Konto? Registrieren

                                          • Anmelden oder registrieren, um zu suchen
                                          • Erster Beitrag
                                            Letzter Beitrag
                                          0
                                          • Home
                                          • Aktuell
                                          • Tags
                                          • Ungelesen 0
                                          • Kategorien
                                          • Unreplied
                                          • Beliebt
                                          • GitHub
                                          • Docu
                                          • Hilfe