light9 Changeset - fe3543310d34

Changeset - fe3543310d34

Parent rev.

Child rev.

[Not reviewed]

default

0 4 0

drewp@bigasterisk.com - 20 months ago 2023-05-24 06:56:20
drewp@bigasterisk.com

move uriTail to a better layer of code

4 files changed with 22 insertions and 23 deletions:

light9/collector/collector.py

light9/collector/output.py

light9/effect/sequencer/eval_faders.py

light9/newtypes.py

0 comments (0 inline, 0 general)

light9/collector/collector.py

➞

Show inline comments

@@ @@ -12,18 +12,11 @@ from light9.collector.weblisteners impor @@
 from light9.effect.settings import DeviceSettings
 from light9.namespaces import L9, RDF
 from light9.newtypes import (ClientSessionType, ClientType, DeviceAttr, DeviceClass, DeviceSetting, DeviceUri, DmxIndex, DmxMessageIndex, OutputAttr,
                              OutputRange, OutputUri, OutputValue, UnixTime, VTUnion)
+                             OutputRange, OutputUri, OutputValue, UnixTime, VTUnion, uriTail)
 log = logging.getLogger('collector')
 def uriTail(u: URIRef) -> str:
     tail = u.rstrip('/').rsplit('/', 1)[1]
     if not tail:
         tail = str(u)
     return tail
 def makeDmxMessageIndex(base: DmxIndex, offset: DmxIndex) -> DmxMessageIndex:
     return DmxMessageIndex(base + offset - 1)

light9/collector/output.py

➞

Show inline comments

 import asyncio
 from typing import cast
 from rdflib import URIRef
 import logging
 import socket
 import struct
 import time
 from typing import cast
 from light9.newtypes import uriTail
 import usb.core
 import logging
 from twisted.internet import threads, reactor, task
 from twisted.internet.interfaces import IReactorCore, IReactorTime
 from rdflib import URIRef
 from twisted.internet import reactor, task
 from twisted.internet.interfaces import IReactorCore
 from light9.metrics import metrics
 log = logging.getLogger('output')
@@ @@ -39,7 +42,7 @@ class Output: @@
     def shortId(self) -> str:
         """short string to distinguish outputs"""
-        return self.uri.rstrip('/').rsplit('/')[-1]
+        return uriTail(self.uri)
     def update(self, buf: bytes) -> None:
         """caller asks for the output to be this buffer"""

light9/effect/sequencer/eval_faders.py

➞

Show inline comments

 import asyncio
 from dataclasses import dataclass
 import logging
 import time
 from typing import Callable, Coroutine, List, Optional, cast
 from light9.collector.collector import uriTail
 from light9.typedgraph import typedValue
 from dataclasses import dataclass
 from typing import List, Optional, cast
 from rdfdb import SyncedGraph
 from rdflib import URIRef
 from rdflib.term import Node
 from light9.effect import effecteval
 from light9.effect.sequencer import Note
 from light9.effect.settings import DeviceSettings, EffectSettings
 from light9.effect.simple_outputs import SimpleOutputs
 from light9.metrics import metrics
 from light9.namespaces import L9, RDF
 from light9.newtypes import EffectAttr, EffectUri, NoteUri, UnixTime
 from rdflib.term import Node
 from light9.newtypes import EffectAttr, EffectUri, UnixTime
 from light9.typedgraph import typedValue
 log = logging.getLogger('seq.fader')

light9/newtypes.py

➞

Show inline comments

@@ @@ -30,3 +30,10 @@ DeviceSetting = Tuple[DeviceUri, DeviceA @@
 # Alternate output range for a device. Instead of outputting 0.0 to
 # 1.0, you can map that range into, say, 0.2 to 0.7
 OutputRange = NewType('OutputRange', Tuple[float, float])
 def uriTail(u: URIRef) -> str:
     tail = u.rstrip('/').rsplit('/', 1)[1]
     if not tail:
         tail = str(u)
     return tail

0 comments (0 inline, 0 general)