light9 Changeset - c5974a6bbc28

Changeset - c5974a6bbc28

Parent rev.

Child rev.

[Not reviewed]

default

0 3 0

drewp@bigasterisk.com - 20 months ago 2023-05-18 17:13:55
drewp@bigasterisk.com

reformat

3 files changed with 14 insertions and 20 deletions:

light9/collector/output.py

light9/web/live/Light9LiveControls.ts

light9/web/live/index.html

0 comments (0 inline, 0 general)

light9/collector/output.py

➞

Show inline comments

@@ @@ -6,6 +6,7 @@ import usb.core @@
 import logging
 from twisted.internet import threads, reactor, task
 from light9.metrics import metrics
 log = logging.getLogger('output')
 logAllDmx = logging.getLogger('output.allDmx')
@@ @@ -42,8 +43,7 @@ class Output(object): @@
         self._currentBuffer = buf
     def _periodicLog(self):
         msg = '%s: %s' % (self.shortId(), ' '.join(map(str,
                                                        self._currentBuffer)))
         msg = '%s: %s' % (self.shortId(), ' '.join(map(str, self._currentBuffer)))
         if msg != self._lastLoggedMsg:
             log.debug(msg)
             self._lastLoggedMsg = msg
@@ @@ -87,8 +87,7 @@ class BackgroundLoopOutput(Output): @@
         def done(worked):
             metrics('write_success', output=self.shortId()).incr()
             reactor.callLater(max(0, start + 1 / self.rate - time.time()),
                               self._loop)
             reactor.callLater(max(0, start + 1 / self.rate - time.time()), self._loop)
         def err(e):
             metrics('write_fail', output=self.shortId()).incr()
@@ @@ -120,8 +119,7 @@ class FtdiDmx(BackgroundLoopOutput): @@
             if logAllDmx.isEnabledFor(logging.DEBUG):
                 # for testing fps, smooth fades, etc
                 logAllDmx.debug('%s: %s...' %
                                 (self.shortId(), ' '.join(map(str, buf[:32]))))
                 logAllDmx.debug('%s: %s...' % (self.shortId(), ' '.join(map(str, buf[:32]))))
             self.dmx.send_dmx(buf)
@@ @@ -148,8 +146,7 @@ class ArtnetDmx(BackgroundLoopOutput): @@
             if logAllDmx.isEnabledFor(logging.DEBUG):
                 # for testing fps, smooth fades, etc
                 logAllDmx.debug('%s: %s...' %
                                 (self.shortId(), ' '.join(map(str, buf[:32]))))
                 logAllDmx.debug('%s: %s...' % (self.shortId(), ' '.join(map(str, buf[:32]))))
             if self.sequence_counter:
                 self.sequence_counter += 1
@@ @@ -162,8 +159,7 @@ class ArtnetDmx(BackgroundLoopOutput): @@
             packet.append(universe_nr & 0xFF)  # Universe LowByte
             packet.append(universe_nr >> 8 & 0xFF)  # Universe HighByte
             packet.extend(struct.pack(
                 '>h', len(buf)))  # Pack the number of channels Big endian
             packet.extend(struct.pack('>h', len(buf)))  # Pack the number of channels Big endian
             packet.extend(buf)
             self._socket.sendto(packet, ('127.0.0.1', 6454))
@@ @@ -171,7 +167,7 @@ class ArtnetDmx(BackgroundLoopOutput): @@
 class Udmx(BackgroundLoopOutput):
     def __init__(self, uri, bus, address, lastDmxChannel, rate=22):
+    def __init__(self, uri: URIRef, bus: int, address: int, lastDmxChannel: int, rate=22):
         self.bus = bus
         self.address = address
         self.lastDmxChannel = lastDmxChannel
@@ @@ -216,9 +212,7 @@ class Udmx(BackgroundLoopOutput): @@
                 if logAllDmx.isEnabledFor(logging.DEBUG):
                     # for testing fps, smooth fades, etc
                     logAllDmx.debug(
                         '%s: %s...' %
                         (self.shortId(), ' '.join(map(str, buf[:32]))))
                     logAllDmx.debug('%s: %s...' % (self.shortId(), ' '.join(map(str, buf[:32]))))
                 sent = self.dev.send_multi_value(1, buf)
                 if sent != len(buf):
@@ @@ -240,8 +234,7 @@ class Udmx(BackgroundLoopOutput): @@
                     metrics('write_pipe_error', output=self.shortId()).inc()
                     return
                 msg = 'usb: sending %s bytes to %r; error %r' % (len(buf),
                                                                  self.uri, e)
                 msg = 'usb: sending %s bytes to %r; error %r' % (len(buf), self.uri, e)
                 log.warn(msg)
                 if e.errno == 13:  # permissions

light9/web/live/Light9LiveControls.ts

➞

Show inline comments

@@ @@ -96,7 +96,7 @@ export class Light9LiveControls extends @@
     this.devices = [];
     let classes = this.graph.subjects(U("rdf:type"), U(":DeviceClass"));
     log(`found ${classes.length} device classes`)
+    log(`found ${classes.length} device classes`);
     uniq(sortBy(classes, "value"), true).forEach((dc) => {
       sortBy(this.graph.subjects(U("rdf:type"), dc), "value").forEach((dev) => {
         this.devices.push(dev as NamedNode);

light9/web/live/index.html

➞

Show inline comments

-<!doctype html>
+<!DOCTYPE html>
 <html>
   <head>
     <title>device control</title>
     <meta charset="utf-8" />
     <link rel="stylesheet" href="../style.css">
+    <link rel="stylesheet" href="../style.css" />
     <script type="module" src="../live/Light9LiveControls"></script>
   </head>
   <body>
     <style>
      body, html {
       body,
       html {
          margin: 0;
+     }
      light9-live-controls {

0 comments (0 inline, 0 general)