Newer
Older
#!/usr/bin/env python
# -*- coding: utf-8 -*-
#
# combacscheduler.py
#
# Copyright 2014 BFR <info@freie-radios.de>
#
# This program is free software; you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation; Version 3 of the License
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with this program; if not, the license can be downloaded here:
#
# http://www.gnu.org/licenses/gpl.html
# Meta
__version__ = '0.1.1'
__license__ = "GNU General Public License (GPL) Version 3"
__version_info__ = (0, 1, 1)
__author__ = 'Michael Liebler <michael-liebler@radio-z.net>'
"""
Comba Scheduler Klasse
Is holding the eventqueue
"""
import signal
import pyev
import os
import os.path
import time
import simplejson
import datetime

Gottfried Gaisbauer
committed
import decimal
import json
import sqlalchemy

Gottfried Gaisbauer
committed
import sys

Gottfried Gaisbauer
committed
from datetime import timedelta
from dateutil.relativedelta import relativedelta
import logging
from glob import glob
import threading
# Die eigenen Bibliotheken
from libraries.base.schedulerconfig import AuraSchedulerConfig
from modules.communication.redis.messenger import RedisMessenger
from libraries.base.calendar import AuraCalendarService
from modules.scheduling.models import ModelBroadcastEventOverrides
from libraries.database.broadcasts import ScheduleEntry, Model

Gottfried Gaisbauer
committed
from libraries.exceptions.auraexceptions import NoProgrammeLoadedException

Gottfried Gaisbauer
committed
def alchemyencoder(obj):
"""JSON encoder function for SQLAlchemy special classes."""
if isinstance(obj, datetime.date):
return obj.isoformat()
elif isinstance(obj, decimal.Decimal):
return float(obj)
elif isinstance(obj, sqlalchemy.orm.state.InstanceState):
return ""
# elif isinstance(obj, bool):
# if obj:
# return "True"
# return "False"
else:
return obj

Gottfried Gaisbauer
committed
"""
Comba Scheduler Class
Gets data from pv and importer, stores and fires events,
Liefert Start und Stop Jobs an den Comba Controller, lädt XML-Playlisten und räumt auf
"""

Gottfried Gaisbauer
committed
class AuraScheduler():
redismessenger = RedisMessenger()
liquidsoapcommunicator = None

Gottfried Gaisbauer
committed
schedule_entries = None

Gottfried Gaisbauer
committed
message_timer = []
schedulerconfig = None

Gottfried Gaisbauer
committed
job_result = {}
programme = None
client = None

Gottfried Gaisbauer
committed
debug = False

Gottfried Gaisbauer
committed
active_entry = None
def __init__(self, config): #, liquidsoap_client):
"""
Constructor
@type config: string

Gottfried Gaisbauer
committed
@param config: Pfad zur aura.ini
"""
self.auraconfig = config
self.debug = config.get("debug")
# Messenger für Systemzustände initieren
self.redismessenger.set_channel('scheduler')
self.redismessenger.set_section('execjob')
self.redismessenger.set_mail_addresses(self.auraconfig.get('frommail'), self.auraconfig.get('adminmail'))

Gottfried Gaisbauer
committed
self.schedulerconfig = self.auraconfig.get("scheduler_config_file")
# Die Signale, die Abbruch signalisieren
self.stopsignals = (signal.SIGTERM, signal.SIGINT)
# das pyev Loop-Object
self.loop = pyev.default_loop()
# Das ist kein Reload
self.initial = True
# Der Scheduler wartet noch auf den Start Befehl
self.ready = False
# DIe Config laden

Gottfried Gaisbauer
committed
self.__load_config__()
self.scriptdir = os.path.dirname(os.path.abspath(__file__)) + '/..'
#errors_file = os.path.dirname(os.path.realpath(__file__)) + '/error/scheduler_error.js'
json_data = open(self.auraconfig.get("install_dir") + "/errormessages/scheduler_error.js")
self.errorData = simplejson.load(json_data)
# init database ?
self.init_database()
self.redismessenger.send('Scheduler started', '0000', 'success', 'initApp', None, 'appinternal')
# ------------------------------------------------------------------------------------------ #
def init_database(self):
import sys
# check if tables do exist. if not create them
try:
ScheduleEntry.select_all()
except sqlalchemy.exc.ProgrammingError as e:
if e.__dict__["code"] == "f405":
Model.recreate_db()
else:
raise
# ------------------------------------------------------------------------------------------ #
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
# def set(self, key, value):
# """
# Eine property setzen
# @type key: string
# @param key: Der Key
# @type value: mixed
# @param value: Beliebiger Wert
# """
# self.__dict__[key] = value
# ------------------------------------------------------------------------------------------ #
# def get(self, key, default=None):
# """
# Eine property holen
# @type key: string
# @param key: Der Key
# @type default: mixed
# @param default: Beliebiger Wert#
#
# """
# if key not in self.__dict__:
# if default:
# self.set(key, default)
# else:
# return None
# return self.__dict__[key]
# ------------------------------------------------------------------------------------------ #

Gottfried Gaisbauer
committed
def reload_config(self):
"""
Reload Scheduler - Config neu einlesen
"""
self.stop()
# Scheduler Config neu laden

Gottfried Gaisbauer
committed
if self.__load_config__():
self.redismessenger.send('Scheduler reloaded by user', '0500', 'success', 'reload', None, 'appinternal')
self.start()
# ------------------------------------------------------------------------------------------ #
def get_active_source(self):

Gottfried Gaisbauer
committed
now_unix = time.mktime(datetime.datetime.now().timetuple())

Gottfried Gaisbauer
committed
lastentry = None
# load programme if necessary
if self.programme is None:
print("want to get active channel, but have to load programme first")

Gottfried Gaisbauer
committed
# get active source
for entry in self.programme:
# check if lastentry is set and if act entry is in the future

Gottfried Gaisbauer
committed
if lastentry is not None and entry.entry_start_unix > now_unix:
# return lastentry if so

Gottfried Gaisbauer
committed
break
lastentry = entry
if actsource.startswith("file") or actsource.startswith("pool") or actsource.startswith("playlist"):
print("AuraScheduler found upcoming source '" + str(entry.__dict__) + "'! returning: fs")

Gottfried Gaisbauer
committed
return "fs"
elif actsource.startswith("http"):
print("AuraScheduler found upcoming source '" + str(entry.__dict__) + "'! returning: http")

Gottfried Gaisbauer
committed
return "http"
elif actsource.startswith("linein"):
print("AuraScheduler found upcoming source '" + str(entry.__dict__) + "'! returning: linein")

Gottfried Gaisbauer
committed
return "linein"

Gottfried Gaisbauer
committed
return ""
# ------------------------------------------------------------------------------------------ #
def load_programme_from_db(self, silent=False):
if not silent:
print("i am the scheduler and i am holding the following stuff")
# now in unixtime
now_unix = time.mktime(datetime.datetime.now().timetuple())
# switch to check if its the first stream in loaded programme
first_stream_in_programme = False
for entry in self.programme:
# since we get also programmes from act hour, filter these out
if entry.entry_start_unix > now_unix:

Gottfried Gaisbauer
committed
diff = diff/100 # testing purpose

Gottfried Gaisbauer
committed
# create the activation threads and run them after <diff> seconds
self.add_or_update_timer(entry, diff, self.liquidsoapcommunicator.activate, "linein")

Gottfried Gaisbauer
committed
elif entry.source.startswith("http"):
if first_stream_in_programme:
self.liquidsoapcommunicator.next_stream_source(entry.source)
first_stream_in_programme = False
self.add_or_update_timer(entry, diff, self.liquidsoapcommunicator.activate, "http")

Gottfried Gaisbauer
committed
elif entry.source.startswith("file"):
self.add_or_update_timer(entry, diff, self.liquidsoapcommunicator.activate, "fs")

Gottfried Gaisbauer
committed
print("WARNING: Cannot understand source '" + entry.source + "' from " + str(entry.__dict__))
print(" Not setting any activation Thread!")
if not silent:
print(entry.__dict__)

Gottfried Gaisbauer
committed
# ------------------------------------------------------------------------------------------ #
def add_or_update_timer(self, entry, diff, func, type):
# check if something is planned at given time
planned_timer = self.is_something_planned_at_time(entry.entry_start)

Gottfried Gaisbauer
committed
# if something is planned on entry.entry_start
if planned_timer:
planned_entry = planned_timer.entry
# check if the playlist_id's are different
if planned_entry.playlist_id != entry.playlist_id:
# if not stop the old timer and remove it from the list
self.stop_timer(planned_timer)
# and create a new one
self.create_timer(entry, diff, func, type)
# if the playlist id's do not differ => do nothing, they are the same

Gottfried Gaisbauer
committed
# if nothing is planned at given time, create a new timer

Gottfried Gaisbauer
committed
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
else:
self.create_timer(entry, diff, func, type)
# ------------------------------------------------------------------------------------------ #
def stop_timer(self, timer):
# stop timer
timer.cancel()
# and remove it
self.message_timer.remove(timer)
# ------------------------------------------------------------------------------------------ #
def create_timer(self, entry, diff, func, type):
t = MessageTimer(diff, func, [entry, type], self.debug)
self.message_timer.append(t)
t.start()
# ------------------------------------------------------------------------------------------ #
def is_something_planned_at_time(self, time):
for t in self.message_timer:
if t.entry.entry_start == time:
return t
return False
# ------------------------------------------------------------------------------------------ #
def find_entry_in_timers(self, entry):
# check if a playlist id is already pla
for t in self.message_timer:
if t.entry.playlist_id == entry.playlist_id and t.entry.entry_start == entry.entry_start:
return t
return False
# ------------------------------------------------------------------------------------------ #
def get_act_programme(self):
programme_as_string = ""

Gottfried Gaisbauer
committed
if self.programme is None:
raise NoProgrammeLoadedException("")
try:
programme_as_string = json.dumps([p._asdict() for p in self.programme], default=alchemyencoder)
except:
traceback.print_exc()
return programme_as_string

Gottfried Gaisbauer
committed
# ------------------------------------------------------------------------------------------ #
def print_message_queue(self):
message_queue = ""
for t in self.message_timer:
message_queue += t.get_info()+"\n"
return message_queue
# ------------------------------------------------------------------------------------------ #
def swap_playlist_entries(self, indexes):
from_entry = None
to_entry = None
from_idx = indexes["from_index"]
to_idx = indexes["to_index"]
for p in self.programme:
if p.programme_index == int(from_idx):
from_entry = p
if p.programme_index == int(to_idx):
to_entry = p
if from_entry is not None and to_entry is not None:
break
if from_entry is None or to_entry is None:
return "From or To Entry not found!"
swap_source = from_entry.source
from_entry.source = to_entry.source
to_entry.source = swap_source
# and return the programme with swapped entries
return self.get_act_programme()
# ------------------------------------------------------------------------------------------ #

Gottfried Gaisbauer
committed
def __load_config__(self):
"""
Scheduler-Config importieren
@rtype: boolean
@return: True/False
"""
# Wenn das Scheduling bereits läuft, muss der Scheduler nicht unbedingt angehalten werden
error_type = 'fatal' if self.initial else 'error'
# watcher_jobs = self.getJobs()
try:
# Die Jobs aus der Config ...

Gottfried Gaisbauer
committed
watcher_jobs = self.get_jobs()
except:
self.redismessenger.send('Config is broken', '0301', error_type, 'loadConfig', None, 'config')
if self.initial:
self.ready = False
return False
# Fehlermeldung senden, wenn keine Jobs gefunden worden sind
if len(watcher_jobs) == 0:
self.redismessenger.send('No Jobs found in Config', '0302', error_type, 'loadConfig', None, 'config')
# Der erste Watcher ist ein Signal-Watcher, der den sauberen Abbruch ermöglicht
self.watchers = [pyev.Signal(sig, self.loop, self.signal_cb)
for sig in self.stopsignals]
# Der zweite Watcher soll das Signal zum Reload der Config ermöglicen
sig_reload = self.loop.signal(signal.SIGUSR1, self.signal_reload)
self.watchers.append(sig_reload)
# Der dritte Watcher sendet alle 20 Sekunden ein Lebenszeichen

Gottfried Gaisbauer
committed
say_alive = self.loop.timer(0, 20, self.say_alive)
self.watchers.append(say_alive)
# Der vierte Watcher schaut alle 20 Sekunden nach, ob eine Vorproduktion eingespielt werden soll
lookup_prearranged = self.loop.timer(0, 20, self.lookup_prearranged)
self.watchers.append(lookup_prearranged)
# Der fünfte Watcher führt initiale Jobs durch
on_start = self.loop.timer(0, 30, self.on_start)
self.watchers.append(on_start)
# Nun Watcher für alle Jobs aus der Config erstellen
for watcher_job in watcher_jobs:
watcher = pyev.Scheduler(self.schedule_job, self.loop, self.exec_job, watcher_job)
# Jeder watcher wird von der Scheduler Funktion schedule_job schedult und vom Callback exec_job ausgeführt
# watcher_job wird an watcher.data übergeben
# schedule_job meldet an den Loop den nächsten Zeitpunkt von watcher_job['time']
# exec_job führt die Funktion dieser Klasse aus, die von watcher_job['job'] bezeichnet wird
self.watchers.append(watcher)
# Es kann losgehen
self.ready = True
return True

Gottfried Gaisbauer
committed
def get_jobs(self):
error_type = 'fatal' if self.initial else 'error'
try:
# Das scheduler.xml laden

Gottfried Gaisbauer
committed
self.schedulerconfig = AuraSchedulerConfig(self.schedulerconfig)
except:
# Das scheint kein gültiges XML zu sein
self.redismessenger.send('Config is broken', '0301', error_type, 'loadConfig', None, 'config')
# Wenn das beim Start passiert können wir nix tun
if self.initial:
self.ready = False
return False
jobs = self.schedulerconfig.getJobs()
for job in jobs:
if job['job'] == 'start_recording' or job['job'] == 'play_playlist':

Gottfried Gaisbauer
committed
stopjob = self.__get_stop_job__(job)
jobs.append(stopjob)
return jobs
# -----------------------------------------------------------------------#

Gottfried Gaisbauer
committed
def __get_stop_job__(self, startjob):
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
job = {}
job['job'] = 'stop_playlist' if startjob['job'] == 'play_playlist' else 'stop_recording'
if startjob['day'] == 'all':
job['day'] = startjob['day']
else:
if startjob['time'] < startjob['until']:
job['day'] = startjob['day']
else:
try:
day = int(startjob['day'])
stopday = 0 if day > 5 else day+1
job['day'] = str(stopday)
except:
job['day'] = 'all'
job['time'] = startjob['until']
return job
# ------------------------------------------------------------------------------------------ #
def start(self):
"""
Event Loop starten
"""
# Alle watcher starten
for watcher in self.watchers:
watcher.start()
logging.debug("{0}: started".format(self))
try:
self.loop.start()
except:
self.redismessenger.send("Loop did'nt start", '0302', 'fatal', 'appstart', None, 'appinternal')
else:
self.redismessenger.send("Scheduler started", '0100', 'success', 'appstart', None, 'appinternal')
# ------------------------------------------------------------------------------------------ #
def stop(self):
"""
Event Loop stoppen
"""
self.loop.stop(pyev.EVBREAK_ALL)
# alle watchers stoppen und entfernen
while self.watchers:
self.watchers.pop().stop()
self.redismessenger.send("Loop stopped", '0400', 'success', 'appstart', None, 'appinternal')
# ------------------------------------------------------------------------------------------ #

Gottfried Gaisbauer
committed
def say_alive(self, watcher, revents):
"""
Alle 20 Sekunden ein Lebenssignal senden
@type watcher: object
@param watcher: Das watcher Objekt
@type revents: object
@param revents: Event Callbacks
"""
print("AuraScheduler saying alive")
# ------------------------------------------------------------------------------------------ #
def signal_cb(self, loop, revents):
"""
Signalverarbeitung bei Abbruch
@type loop: object
@param loop: Das py_ev loop Objekt
@type revents: object
@param revents: Event Callbacks
"""
self.redismessenger.send("Received stop signal", '1100', 'success', 'appstop', None, 'appinternal')
self.stop()
# ------------------------------------------------------------------------------------------ #
def signal_reload(self, loop, revents):
"""
Lädt Scheduling-Konfiguration neu bei Signal SIGUSR1
@type loop: object
@param loop: Das py_ev loop Objekt
@type revents: object
@param revents: Event Callbacks
"""
self.redismessenger.send("Comba Scheduler gracefull restarted", '1200', 'success', 'appreload', None, 'appinternal')

Gottfried Gaisbauer
committed
self.reload_config()
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
# ------------------------------------------------------------------------------------------ #
def schedule_job(self, watcher, now):
"""
Callback zum Scheduling eines Jobs
@type watcher: object
@param watcher: Das watcher Objekt
@type now: float
@param now: Aktuelle Zeit in Sekunden
@rtype: float
@return: Die Zeit zu der der Job ausgeführt werden soll in Sekunden
"""
# nächstes Ereignis dieses Watchers aus den watcher data
data = watcher.data.copy()
next_schedule = data['time']
# Minuten und Stunden
(next_hour, next_minute) = next_schedule.split(':')
# Zum Vergleich die aktuelle und die auszuführende Unhrzeit in Integer wandeln
today_time = int(datetime.datetime.now().strftime('%H%M'))
next_time = int(next_hour + next_minute)
# Wenn der Job erst morgen ausgeführt werden soll ist day_offset 1
day_offset = 1 if (today_time >= next_time) else 0
# Ist ein Tag angegeben
if 'day' in data:
try:
#Montag ist 0
dayofweek = int(data['day'])
delta = relativedelta(hour=int(next_hour), minute=int(next_minute), second=0, microsecond=0, weekday=dayofweek)
except:
#Fallback - day ist vermutlich ein String
delta = relativedelta(hour=int(next_hour), minute=int(next_minute), second=0, microsecond=0)
else:
delta = relativedelta(hour=int(next_hour), minute=int(next_minute), second=0, microsecond=0)
# Ermittle das Datumsobjekt
schedule_result = datetime.datetime.now() + timedelta(day_offset) + delta
# In Sekunden umrechnen
result = time.mktime(schedule_result.timetuple())
schedule_time_human = datetime.datetime.fromtimestamp(int(result)).strftime('%Y-%m-%d %H:%M:%S')
time_now = datetime.datetime.fromtimestamp(time.time()).strftime('%Y-%m-%d %H:%M:%S')
date_human = datetime.datetime.fromtimestamp(int(result)).strftime('%Y-%m-%d')
time_human = datetime.datetime.fromtimestamp(int(result)).strftime('%H:%M')
# Events feuern, zum stoppen und starten einer Playlist
# TODO: Diese events müssen bei einem Reset gelöscht werden
# Es sollte sicher sein, einfach alle keys mit playerevent_*_playliststart unc playerevent_*_playliststop zu löschen
if 'job' in data:
if data['job'] == 'play_playlist':
event = {'job': 'play_playlist', 'date': date_human, 'time': time_human}
self.redismessenger.queue_add_event('playliststart', str(schedule_time_human).replace(' ', 'T'), event, 'player')
if data['job'] == 'stop_playlist':
event = {'job': 'stop_playlist', 'date': date_human, 'time': time_human}
self.redismessenger.queue_add_event('playliststop', str(schedule_time_human).replace(' ', 'T'), event, 'player')
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
data['scheduled_at'] = time_now
data['scheduled_for'] = schedule_time_human
self.info('schedule_job', data, '00', simplejson.dumps(data), 'schedulejob')
# das nächste mal starten wir diesen Job in result Sekunden
return result
# ------------------------------------------------------------------------------------------ #
def exec_job(self, watcher, revents):
"""
Callback, um einen Job auszuführen
@type watcher: object
@param watcher: Das watcher Objekt
@type revents: object
@param revents: Event Callbacks
"""
data = watcher.data.copy()
# Welcher Job ausgeführt werden soll wird in watcher.data vermerkt
job = data['job']
# Job ausführen
try:
exec("a=self." + job + "(data)")
except Exception as e:
data['exec'] = 'exec"a=self.' + job + '(' + simplejson.dumps(data) + ')"'
data['Exception'] = str(e)
self.fatal('exec_job', data, '01', simplejson.dumps(data))
watcher.stop() #stop the watcher
else:
self.success('exec_job', data, '00', simplejson.dumps(data))
# ------------------------------------------------------------------------------------------ #

Gottfried Gaisbauer
committed
def clear_channel(self, channel):
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
"""
Schaltet auto-Channel aus und common-Channel ein
Skippt anschließend ggf. verbleibende Tracks vom auto-Channel
@type channel: str
@param channel: Kanal
"""
def _get_data(result):
"""
Untermethode: prüft ob noch tracks im Channel Queue sind
"""
try:
if result['success'] == 'success':
if 'value' in result:
return result['value']
else:
return True
else:
return False
except:
return False
# Common Channel laut
self.client.channel_set_volume('common', 100)
# Auto-Channel leise
self.client.channel_set_volume(channel, 0)
# Channel Queue holen
data = self.client.get_channelqueue(channel)
# Channel initial skippen...
self.client.channel_skip(channel)
queue = _get_data(data)
# ...für jeden track erneut skippen
if queue and 'tracks' in queue:
tracks = queue['tracks']
for track in tracks:
time.sleep(1.0)
self.client.channel_skip(channel)
# Auto Channel für erneute Verwendung ausschalten und laut stellen
self.client.channel_off(channel)
self.client.channel_set_volume(channel, 100)
# ------------------------------------------------------------------------------------------ #

Gottfried Gaisbauer
committed
def run_channel(self, channel):
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
self.client.channel_set_volume('common', 0)
self.client.channel_set_volume(channel, 100)
self.client.channel_on(channel)
# ------------------------------------------------------------------------------------------ #
def lookup_prearranged(self, watcher, revents):
"""
Job-Methode. Spielt ggf. Vorproduktionen aus
Diese wird als Trackliste auf einen von zwei Extra-Channels (auto1 und 2) gelegt
@type watcher: object
@param watcher: Das watcher Objekt
@type revents: object
@param revents: Event Callbacks
"""
# Vorproduktion in den nächsten 20 Sekunden vorgemerkt?
tracks = ModelBroadcastEventOverrides.upcoming(datetime.datetime.now(),20)
#print(tracks)
# print(type(tracks))
if tracks and len(tracks) > 0:
# alle tracks enthalten die Information über den zugehörigen broadcast event
event = tracks[0].broadcast_event
# freien preprod channel checken,
channel = 'auto1'
if not self.client.channel_is_active('auto1'):
channel = 'auto1'
elif not self.client.channel_is_active('auto2'):
channel = 'auto2'
else:
self.error('lookup_prearranged', "false", '01')
return
# tracks in preprod channel laden
pos = 0
for track in tracks:
self.client.channel_track_insert(channel, track.location, pos)
pos = pos + 1
now = datetime.datetime.now()
# zeitgesteuert einschalten
on = (event.start - now).total_seconds()

Gottfried Gaisbauer
committed
threading.Timer(on, self.run_channel, [channel]).start()
# zeitgesteuert skippen
off = (event.end - now).total_seconds()

Gottfried Gaisbauer
committed
threading.Timer(off, self.clear_channel, [channel]).start()
# ------------------------------------------------------------------------------------------ #
def on_start(self, watcher, revents):
self.client.playlist_play()
self.client.playlist_pause()
watcher.stop()
# ------------------------------------------------------------------------------------------ #
def load_playlist(self, data=None):
"""
Playlist laden
"""
store = AuraCalendarService()

Gottfried Gaisbauer
committed
self.__prepare_playlist_store__(store, datetime.datetime.now(), data)
uri = store.get_uri()
store.start()
# wait until childs thread returns
store.join()
data = {}
data['uri'] = uri
result = self.client.playlist_load(uri)

Gottfried Gaisbauer
committed
if self.__check_result__(result):
self.success('load_playlist', data, '00')
else:
self.error('load_playlist', data, '02')
# ------------------------------------------------------------------------------------------ #

Gottfried Gaisbauer
committed
@staticmethod
def __prepare_playlist_store__(self, store, dateBegin, data):
"""
Playlist speichern
"""
try:
fromtime = data['from']
until = data['until']
except:
return
# Das aktuelle Datum
today_time = dateBegin.strftime('%H:%M')
# Wir müssen ermitteln, ob die eigentliche Abspielzeit vielleicht erst morgen ist
day_offset = 1 if (today_time > fromtime) else 0
start_date = dateBegin + timedelta(day_offset)
# datefrom ist Datum, an dem die Playlist beginnen soll
datefrom = str(start_date.strftime('%F')) + ' ' + fromtime
# Die Playlist holen

Gottfried Gaisbauer
committed
store.set_date_from(datefrom)
store.set_until_time(until)
# ------------------------------------------------------------------------------------------ #
def play_playlist(self, data):
"""
Playlist starten
"""

Gottfried Gaisbauer
committed
# TODO: Fehler auswerten
result = self.client.playlist_play()

Gottfried Gaisbauer
committed
if self.__check_result__(result):
self.success('play_playlist', result, '00')
else:
self.error('play_playlist', result, '01')
# ------------------------------------------------------------------------------------------ #
def stop_playlist(self, data):
"""
Playlist anhalten
"""

Gottfried Gaisbauer
committed
# TODO: Fehler auswerten
if self.get('has_input_device'):
result = self.client.playlist_pause()
else:
result = self.client.playlist_stop()

Gottfried Gaisbauer
committed
if self.__check_result__(result):
self.success('stop_playlist', result, '00')
else:
self.error('stop_playlist', result, '01')
# ------------------------------------------------------------------------------------------ #
def start_recording(self, data):
"""
Aufnahme starten
"""
result = self.client.recorder_start()
# store = AuraCalendarService()
# self._preparePlaylistStore(store, datetime.datetime.now(), data)
# uri = store.getUri()
# store.start()

Gottfried Gaisbauer
committed
if self.__check_result__(result):
self.success('start_recording', result, '00')
else:
self.error('start_recording', result, '01')
# ------------------------------------------------------------------------------------------ #
def stop_recording(self, data):
"""
Aufnahme anhalten
"""
result = self.client.recorder_stop()

Gottfried Gaisbauer
committed
if self.__check_result__(result):
self.success('stop_recording', result, '00')
else:
self.error('stop_recording', result, '01')
# ------------------------------------------------------------------------------------------ #
def precache(self, data):
"""
Playlisten 7 Tage im Voraus abholen
"""
# periods = self.config.getPlayPeriods() + self.config.getRecordPeriods()
# timeBegin = datetime.datetime.now()
# for i in range(0, int(self.get('calendar_precache_days'))):
# for period in periods:
# store = AuraCalendarService()
# self._preparePlaylistStore(store, timeBegin, period)
# store.start()
# counter = 40
# while counter > 0 and store.is_alive():
# counter = counter - 1
# time.sleep(0.1)
# timeBegin = timeBegin + datetime.timedelta(1)
853
854
855
856
857
858
859
860
861
862
863
864
865
866
867
868
869
870
871
872
873
874
875
876
877
878
879
880
881
882
883
884
885
886
887
888
889
890
891
892
893
894
self.success('precache')
# ------------------------------------------------------------------------------------------ #
def clean_cached(self, data):
"""
Nicht mehr benötigte Audios und Playlisten löschen
@type data: dict
@param data: das job dict
"""
# Zeitdauer, die Dateien aufgehoben werden sollen
try:
savetime = int(data['daysolder']) * 86400
except:
savetime = 3*86400
# Jetzt ist Jetzt
now = time.time()
files = []
# Alle Audiodateien finden
for dir, _, _ in os.walk(self.audiobase):
# Leere Verzeichnisse löschen
if len(os.listdir(dir)) == 0:
try:
os.rmdir(dir)
except:
#TODO: Fehlemeldung
pass
else:
files.extend(glob(os.path.join(dir, '*.wav')))
# Alle Dateien löschen, die älter als savetime sind
for file in files:
if os.path.isfile(file) and os.stat(file).st_mtime < now - savetime:
try:
os.remove(file)
except:
#TODO: Fehlemeldung
pass
self.success('clean_cached')
# ------------------------------------------------------------------------------------------ #

Gottfried Gaisbauer
committed
def __get_error__(self, job, errornumber, data):
896
897
898
899
900
901
902
903
904
905
906
907
908
909
910
911
912
913
914
915
916
917
918
919
920
921
922
923
924
925
926
927
928
929
930
"""
Privat: Ermittelt Fehlermeldung, Job-Name (Klassenmethode) und Fehlercode für den Job aus error/controller_error.js
@type errornumber: string
@param errornumber: Die interne Fehlernummer der aufrufenden Methode
"""
### weil es eine "bound method" ist, kommmt data als string an!???
if data == None:
data = {}
if type(data) == type(str()):
data = simplejson.loads(data)
hasData = isinstance(data, (dict)) and len(data) > 0
if job in self.errorData:
errMsg = self.errorData[job][errornumber]
errID = self.errorData[job]['id'] + str(errornumber)
if hasData:
for key in data.keys():
errMsg = errMsg.replace('::' + key + '::', str(data[key]))
data['message'] = errMsg
data['job'] = job
data['code'] = errID
return data
# ------------------------------------------------------------------------------------------ #
def success(self, job, data=None, errnum='00', value='', section='execjob'):
"""
Erfolgsmeldung loggen
@type errnum: string
@param errnum: Errornummer der aufrufenden Funktion
@type value: string
@param value: Optionaler Wert
@type section: string
@param section: Gültigkeitsbereich
"""

Gottfried Gaisbauer
committed
error = self.__get_error__(job, errnum, data)
self.job_result = {'message': error['message'], 'code': error['code'], 'success': 'success',
'job': error['job'], 'value': value, 'section': section}
self.redismessenger.send(error['message'], error['code'], 'success', error['job'], value, section)
# ------------------------------------------------------------------------------------------ #
def info(self, job, data=None, errnum='01', value='', section='execjob'):
"""
Info loggen
@type errnum: string
@param errnum: Errornummer der aufrufenden Funktion
@type value: string
@param value: Optionaler Wert
@type section: string
@param section: Gültigkeitsbereich
"""

Gottfried Gaisbauer
committed
error = self.__get_error__(job, errnum, data)
self.job_result = {'message': error['message'], 'code': error['code'], 'success': 'info', 'job': error['job'],
'value': value, 'section': section}
self.redismessenger.send(error['message'], error['code'], 'info', error['job'], value, section)
# ------------------------------------------------------------------------------------------ #
def warning(self, job, data=None, errnum='01', value='', section='execjob'):
"""
Warnung loggen
@type errnum: string
@param errnum: Errornummer der aufrufenden Funktion
@type value: string
@param value: Optionaler Wert
@type section: string
@param section: Gültigkeitsbereich
"""

Gottfried Gaisbauer
committed
error = self.__get_error__(job, errnum, data)
self.job_result = {'message': error['message'], 'code': error['code'], 'success': 'warning',
'job': error['job'], 'value': value, 'section': section}
self.redismessenger.send(error['message'], error['code'], 'warning', error['job'], value, section)
# ------------------------------------------------------------------------------------------ #
def error(self, job, data=None, errnum='01', value='', section='execjob'):
"""
Error loggen
@type errnum: string
@param errnum: Errornummer der aufrufenden Funktion
@type value: string
@param value: Optionaler Wert
@type section: string
@param section: Gültigkeitsbereich
"""

Gottfried Gaisbauer
committed
error = self.__get_error__(job, errnum, data)
self.job_result = {'message': error['message'], 'code': error['code'], 'success': 'error', 'job': error['job'],
'value': value, 'section': section}
self.redismessenger.send(error['message'], error['code'], 'error', error['job'], value, section)
# ------------------------------------------------------------------------------------------ #
def fatal(self, job, data=None, errnum='01', value='', section='execjob'):
"""
Fatal error loggen
@type errnum: string
@param errnum: Errornummer der aufrufenden Funktion
@type value: string
@param value: Optionaler Wert
@type section: string
@param section: Gültigkeitsbereich
"""

Gottfried Gaisbauer
committed
error = self.__get_error__(job, errnum, data)
self.job_result = {'message': error['message'], 'code': error['code'], 'success': 'fatal', 'job': error['job'],
'value': value, 'section': section}
self.redismessenger.send(error['message'], error['code'], 'fatal', error['job'], value, section)
# ------------------------------------------------------------------------------------------ #