light9 Changeset - 82e98aa4d159

Changeset - 82e98aa4d159

Parent rev.

Child rev.

[Not reviewed]

default

0 5 0

drewp@bigasterisk.com - 6 years ago 2019-06-04 17:17:55
drewp@bigasterisk.com

reformatting and typing
Ignore-this: 208dd84c52c544998142de6622fced2c

4 files changed with 32 insertions and 23 deletions:

bin/musictime

light9/ascoltami/musictime_client.py

light9/vidref/videorecorder.py

tasks.py

0 comments (0 inline, 0 general)

bin/musictime

➞

Show inline comments

@@ @@ -3,14 +3,13 @@ import run_local # noqa @@
 import light9.networking
 import tkinter as tk
 import time
 import json
 from twisted.internet import reactor, tksupport, task, defer
 from twisted.internet import reactor, tksupport, task
 from light9.ascoltami.musictime_client import MusicTime
 mt = MusicTime()
 class MusicTimeTk(tk.Frame, MusicTime):
     def __init__(self, master, url):
@@ @@ -40,6 +39,7 @@ class MusicTimeTk(tk.Frame, MusicTime): @@
         t = self.getLatest().get('t', 0)
         self.timevar.set(t)
 if __name__ == "__main__":
     from optparse import OptionParser
     parser = OptionParser()
@@ @@ -51,4 +51,3 @@ if __name__ == "__main__": @@
     MusicTimeTk(root, options.url).pack(expand=1, fill='both')
     tksupport.install(root, ms=20)
     reactor.run()

light9/ascoltami/musictime_client.py

➞

Show inline comments

@@ @@ -20,7 +20,8 @@ class MusicTime(object): @@
                  period=.2,
                  onChange=lambda position: None,
                  pollCurvecalc='ignored'):
         """period is the seconds between http time requests.
         """period is the seconds between
         http time requests.
         We call onChange with the time in seconds and the total time

light9/vidref/videorecorder.py

➞

Show inline comments

 from dataclasses import dataclass
 from queue import Queue
 from typing import Optional
 import time, logging, os, traceback, sys
 import gi
 gi.require_version('Gst', '1.0')
 gi.require_version('GstBase', '1.0')
 from PIL import Image
 from gi.repository import Gst
 from rx.subjects import BehaviorSubject
 from dataclasses import dataclass
 from PIL import Image
 from twisted.internet import defer, threads
 from queue import Queue
 from light9.vidref.replay import framerate, songDir, takeDir, snapshotDir
 from typing import Set, Optional
 import moviepy.editor
 import numpy
 from light9.ascoltami.musictime_client import MusicTime
 from light9.newtypes import Song
 from IPython.core import ultratb
 sys.excepthook = ultratb.FormattedTB(mode='Verbose',
                                      color_scheme='Linux',
@@ @@ -22,6 +24,7 @@ sys.excepthook = ultratb.FormattedTB(mod @@
 log = logging.getLogger()
 @dataclass(frozen=True)
 class CaptureFrame:
     img: Image
@@ @@ -29,6 +32,7 @@ class CaptureFrame: @@
     t: float
     isPlaying: bool
 class FramesToVideoFiles:
     """
@@ @@ -46,12 +50,13 @@ class FramesToVideoFiles: @@
     nextWriteAction: 'ignore'
     """
     def __init__(self, frames: BehaviorSubject):
         self.frames = frames
         self.nextImg = None
+        self.nextImg: Optional[CaptureFrame] = None
         self.currentOutputClip = None
         self.currentOutputSong = None
+        self.currentOutputSong: Optional[Song] = None
         self.nextWriteAction = 'ignore'
         self.frames.subscribe(on_next=self.onFrame)
@@ @@ -75,7 +80,7 @@ class FramesToVideoFiles: @@
             # stop
             self.nextWriteAction = 'close'
         else:
-            raise NotImplementedError
+            raise NotImplementedError(str(vars()))
     def save(self, outBase):
         """
@@ @@ -93,11 +98,14 @@ class FramesToVideoFiles: @@
         self.currentOutputClip.fps = 5
         log.info(f'write_videofile {outBase} start')
         try:
             self.currentOutputClip.write_videofile(
                 outBase + '.mp4',
                 audio=False, preset='ultrafast', verbose=True, bitrate='150000')
             self.currentOutputClip.write_videofile(outBase + '.mp4',
                                                    audio=False,
                                                    preset='ultrafast',
                                                    logger=None,
                                                    bitrate='150000')
         except (StopIteration, RuntimeError):
             pass
             self.frameMap.close()
         log.info('write_videofile done')
         self.currentOutputClip = None
@@ @@ -110,11 +118,10 @@ class FramesToVideoFiles: @@
             time.sleep(.03)
         cf, self.nextImg = self.nextImg, None
         self.frameMap.write(
             f'video {video_time_secs:g} = song {cf.t:g}\n')
         self.frameMap.flush()
         self.frameMap.write(f'video {video_time_secs:g} = song {cf.t:g}\n')
         return numpy.asarray(cf.img)
 class GstSource:
     def __init__(self, dev):
@@ @@ -123,7 +130,8 @@ class GstSource: @@
         """
         Gst.init(None)
         self.musicTime = MusicTime(pollCurvecalc=False)
         self.liveImages: BehaviorSubject[Optional[CaptureFrame]] = BehaviorSubject(None)
         self.liveImages: BehaviorSubject[
             Optional[CaptureFrame]] = BehaviorSubject(None)
         size = [640, 480]
@@ @@ -167,8 +175,8 @@ class GstSource: @@
             latest = self.musicTime.getLatest()
             if 'song' in latest:
                 self.liveImages.on_next(
                     CaptureFrame(img, Song(latest['song']),
                                  latest['t'], latest['playing']))
                     CaptureFrame(img, Song(latest['song']), latest['t'],
                                  latest['playing']))
         except Exception:
             traceback.print_exc()
         return Gst.FlowReturn.OK

tasks.py

➞

Show inline comments

@@ @@ -45,6 +45,7 @@ def mypy(ctx): @@
     run(['bin/keyboardcomposer'])
     run(['bin/effectsequencer'])
     run(['bin/ascoltami2'])
     run(['bin/vidref'])
     #for src in bin_sources:
     #    print(f"mypy {src}")
     #    run([src])# + pkg_sources())

0 comments (0 inline, 0 general)