Compare revisions

0a506deb · 0a506deb · 0a506deb · 0a506deb · 0a506deb · 0a506deb
--- a/contrib/aura-player/public/index.html
+++ b/contrib/aura-player/public/index.html
+<!DOCTYPE html>
+<html lang="en">
+<head>
+	<meta charset='utf-8'>
+	<meta name='viewport' content='width=device-width,initial-scale=1'>
+
+	<title>Svelte app</title>
+
+	<link rel='icon' type='image/png' href='/favicon.png'>
+	<link rel="stylesheet" href="/bootstrap.css">
+	<!--<link rel='stylesheet' href='/global.css'>-->
+	<link rel='stylesheet' href='/build/bundle.css'>
+
+	<script defer src='/build/bundle.js'></script>
+</head>
+<body>
+</body>
+</html>
--- a/contrib/aura-player/rollup.config.js
+++ b/contrib/aura-player/rollup.config.js
+import svelte from 'rollup-plugin-svelte';
+import resolve from '@rollup/plugin-node-resolve';
+import commonjs from 'rollup-plugin-commonjs';
+import livereload from 'rollup-plugin-livereload';
+import { terser } from 'rollup-plugin-terser';
+
+const production = !process.env.ROLLUP_WATCH;
+
+export default {
+	input: 'src/main.js',
+	output: {
+		sourcemap: true,
+		format: 'iife',
+		name: 'app',
+		file: 'public/build/bundle.js'
+	},
+	plugins: [
+		svelte({
+			// enable run-time checks when not in production
+			dev: !production,
+			// we'll extract any component CSS out into
+			// a separate file — better for performance
+			css: css => {
+				css.write('public/build/bundle.css');
+			}
+		}),
+
+		// If you have external dependencies installed from
+		// npm, you'll most likely need these plugins. In
+		// some cases you'll need additional configuration —
+		// consult the documentation for details:
+		// https://github.com/rollup/rollup-plugin-commonjs
+		resolve({
+			browser: true,
+			dedupe: importee => importee === 'svelte' || importee.startsWith('svelte/')
+		}),
+		commonjs(),
+
+		// In dev mode, call `npm run start` once
+		// the bundle has been generated
+		!production && serve(),
+
+		// Watch the `public` directory and refresh the
+		// browser on changes when not in production
+		!production && livereload('public'),
+
+		// If we're building for production (npm run build
+		// instead of npm run dev), minify
+		production && terser()
+	],
+	watch: {
+		clearScreen: false
+	}
+};
+
+function serve() {
+	let started = false;
+
+	return {
+		writeBundle() {
+			if (!started) {
+				started = true;
+
+				require('child_process').spawn('npm', ['run', 'start', '--', '--dev'], {
+					stdio: ['ignore', 'inherit', 'inherit'],
+					shell: true
+				});
+			}
+		}
+	};
+}
\ No newline at end of file
--- a/contrib/aura-player/src/App.svelte
+++ b/contrib/aura-player/src/App.svelte
+<script>
+	import TrackService from './TrackService.svelte';
+
+	let query = "trackservice/3";
+	let result;
+
+	async function getResult() {
+		// FIXME Configure DataURL and Port
+		let response = await fetch(`http://localhost:3333/api/v1/${query}`);
+		let text = await response.text();
+		let data = text;
+		return data;
+	}
+
+	function submitHandler() {
+		result = getResult();
+		query = "";
+	}
+
+	submitHandler();
+</script>
+
+<div class="container mt-5">
+	<div class="row">
+		<div class="col-md"></div>
+		<div class="col-md-8 text-center">
+			<h1 class="display-4">Track Service</h1>
+
+
+			{#if result===undefined}
+
+			<p></p>
+
+			{:else}
+
+			{#await result}
+
+			<div class="spinner-border mt-5" role="status">
+    			<span class="sr-only">Loading...</span>
+  			</div>
+
+			{:then value}
+
+			<TrackService data={value} />
+
+			{:catch error}
+
+			<TrackService data={error.message}/>
+				
+			{/await}
+
+			{/if}
+		</div>
+		<div class="col-md"></div>
+	</div>
+</div>
\ No newline at end of file
--- a/contrib/aura-player/src/TrackService.svelte
+++ b/contrib/aura-player/src/TrackService.svelte
+<script>
+import { fly } from 'svelte/transition';
+export let data;
+</script>
+    
+<div class="card mt-5" transition:fly="{{ y: 150, duration: 300 }}">
+    <div class="card-body">
+        <h5 class="card-title">{data}</h5>
+    </div>
+</div>
\ No newline at end of file
--- a/contrib/aura-player/src/main.js
+++ b/contrib/aura-player/src/main.js
+import App from './App.svelte';
+
+const app = new App({
+	target: document.body
+});
+
+export default app;
\ No newline at end of file
--- a/contrib/aura-player/svelte-README.md
+++ b/contrib/aura-player/svelte-README.md
+*Looking for a shareable component template? Go here --> [sveltejs/component-template](https://github.com/sveltejs/component-template)*
+
+---
+
+# svelte app
+
+This is a project template for [Svelte](https://svelte.dev) apps. It lives at https://github.com/sveltejs/template.
+
+To create a new project based on this template using [degit](https://github.com/Rich-Harris/degit):
+
+```bash
+npx degit sveltejs/template svelte-app
+cd svelte-app
+```
+
+*Note that you will need to have [Node.js](https://nodejs.org) installed.*
+
+
+## Get started
+
+Install the dependencies...
+
+```bash
+cd svelte-app
+npm install
+```
+
+...then start [Rollup](https://rollupjs.org):
+
+```bash
+npm run dev
+```
+
+Navigate to [localhost:5000](http://localhost:5000). You should see your app running. Edit a component file in `src`, save it, and reload the page to see your changes.
+
+By default, the server will only respond to requests from localhost. To allow connections from other computers, edit the `sirv` commands in package.json to include the option `--host 0.0.0.0`.
+
+
+## Building and running in production mode
+
+To create an optimised version of the app:
+
+```bash
+npm run build
+```
+
+You can run the newly built app with `npm run start`. This uses [sirv](https://github.com/lukeed/sirv), which is included in your package.json's `dependencies` so that the app will work when you deploy to platforms like [Heroku](https://heroku.com).
+
+
+## Single-page app mode
+
+By default, sirv will only respond to requests that match files in `public`. This is to maximise compatibility with static fileservers, allowing you to deploy your app anywhere.
+
+If you're building a single-page app (SPA) with multiple routes, sirv needs to be able to respond to requests for *any* path. You can make it so by editing the `"start"` command in package.json:
+
+```js
+"start": "sirv public --single"
+```
+
+
+## Deploying to the web
+
+### With [now](https://zeit.co/now)
+
+Install `now` if you haven't already:
+
+```bash
+npm install -g now
+```
+
+Then, from within your project folder:
+
+```bash
+cd public
+now deploy --name my-project
+```
+
+As an alternative, use the [Now desktop client](https://zeit.co/download) and simply drag the unzipped project folder to the taskbar icon.
+
+### With [surge](https://surge.sh/)
+
+Install `surge` if you haven't already:
+
+```bash
+npm install -g surge
+```
+
+Then, from within your project folder:
+
+```bash
+npm run build
+surge public my-project.surge.sh
+```
--- a/docs/configuration-guide.md
+++ b/docs/configuration-guide.md
+
+# Aura Engine Configuration Guide
+
+This page goes into detail on what is possible to configure within the engine.
+
+## Soundcard
+
+Configure your audio device in the `[soundcard]` section of `engine.ini`.
+
+You can configure up to **five** line IN and OUT stereo channels. Your hardware should
+support that. When you use JACK, you will see the additional elements popping up when
+viewing your connections (with e.g. Patchage).
+
+**Pulse Audio:** When using Ubuntu, Pulse Audio is selected by default. This is convenient,
+as you won't have the need to adapt any Engine setting to get audio playing initially.
+
+**ALSA:** When you use ALSA, you will have to play around with ALSA settings. In the folder
+`./modules/liquidsoap` is a scipt called alsa_settings_tester.liq. You can start it
+with 'liquidsoap -v --debug alsa_settings_tester.liq'. Changing and playing with
+settings may help you to find correct ALSA settings.
+
+**Jack Audio**: Beside ALSA the sound servers such as 
+is supported.
+
+Install the JACK daemon and GUI:
+```bash
+    sudo apt-get install jackd qjackctl 
+```
+
+Please ensure to enable "*realtime process priority*" when installing JACK to keep latency low.
+Now, you are able to configure your hardware settings using following command:
+
+```bash
+    qjackctl
+```
+
+Next you need to install the JACK plugin for Liquidsoap:
+
+```bash
+sudo apt install \
+    liquidsoap-plugin-jack
+```
+
+
+## Recordings
+
+You can configure up to **five** recorders in the `[recording]`.
+
+## Streams
+
+You can configure up to **five** streams in the `[streams]`.
+
+## Fallbacks
+
+Configure fallback handling in the `[fallback]` section.
+
+## Database
+
+Configure your engine database in the `[database]` section.
+
+## Monitoring
+
+Configure monitoring parameters in the `[monitoring]` section.
+
+## Web User Interface
+
+Configure the web interface in the `[web-ui]` section.
+
+## Administrator Emails
+
+Configure the email server for admin mails in the `[mail]` section.
+
+## API Endpoints
+
+Configure connections to the other Aura components in the `[dataurls]` section.
+
+## Fading
+
+Configure fading parameters in the `[fading]` section.
+
+## Logging
+
+Configure log handling in the `[logging]` section.
+
+## User
+
+Configure the executing system user in the `[user]` section.
+
+## Socket
+
+Configure socket connectivity in the `[socket]` section.
+
+## Redis
+
+Configure Redis connectivity in the `[redis]` section.
+
+
+## Frequently Asked Questions
+
+### Which Audio Interface / Soundcard is compatible with Aura?
+
+Basically any audio device which is supported by Linux Debian/Ubuntu and has ALSA drivers.
+Engine has been tested with following audio interfaces:
+
+- ASUS Xonar DGX,
+- Roland Duo-Capture Ex
+- Onboard Soundcard (HDA Intel ALC262)
+- Native Instruments Komplete Audio 6
+
+
+### ALSA Settings
+
+#### Install: I don't want to install all Liquidsoap Audio plugins. How?
+
+Depending on what stream you are going to send, and what recordings you are going to use,
+install one or some of the following:
+
+```bash
+sudo apt install \
+    liquidsoap-plugin-aac # for aac support
+    liquidsoap-plugin-flac # for flac support
+    liquidsoap-plugin-lame liquidsoap-plugin-mad # for mp3 support
+    liquidsoap-plugin-opus # for opus support
+    liquidsoap-plugin-vorbis # for ogg support
+```
+
+#### In the Liquidsoap Logs I get 'Error when starting output output_lineout_0: Failure("Error while setting open_pcm: Device or resource busy")!'. What does it mean?
+
+You probably have set a wrong or occupied device ID.
+
+
+#### How can I find the audio device IDs, required for settings in engine.ini?
+
+* **ALSA**: You can get the device numbers or IDs by executing:
+
+    cat /proc/asound/cards
+
+* **Pulse Audio**: You might not need this for Pulse Audio, but still, to see all available devices use:
+
+    pactl list
+
+
+
+**If you cannot find correct ALSA settings**  
+Well, this is - at least for me - a hard one. I could not manage to find correct ALSA settings for the above mentioned soundcards. The best experience i had with the ASUS Xonar DGX, but still very problematic (especially the first couple of minutes after starting liquidsoap). Since i enabled JACK support i only use that. It is also a bit of trial and error, but works pretty much out of the box.
+
+**If you experience 'hangs' or other artefacts on the output signal**
+ * reduce the quality (especially, when hangs are on the stream) or
+ * install the realtime kernel with
+
+   ```bash
+   apt install linux-image-rt-amd64
+   reboot
+   ```
+
+   or
+ * invest in better hardware
\ No newline at end of file
--- a/docs/developer-guide.md
+++ b/docs/developer-guide.md
+# Aura Engine Development Guide
+
+This page gives insights on extending Aura Engine internals or through the API.
+
+
+## Architecture
+
+AURA Engine as part of the AURA Radio Suite uses an modulear architecture
+based on a REST API. All external information is retrieved using JSON data-structures.
+
+To get the basic architectural overview, visit the [Aura Meta](https://gitlab.servus.at/autoradio/meta) repository.
+
+## Required Data Sources
+
+The AURA Project "**Dashboard**" provides the GUI to organize shows, schedules/timelsots
+and organize uploads in form of playlists. Those playlists can be organized in timeslots
+using a fancy calendar interface.
+
+These data-sources need to be configurated in the "engine.ini" configuration file:
+
+    # The URL to get the Calendar via PV/Steering
+    calendarurl="http://localhost:8000/api/v1/playout"
+
+    # The URL to get show details via PV/Steering
+    api_show_url="http://localhost:8000/api/v1/shows/${ID}/"
+
+The AURA Project "**Tank**" on the other hand delivers information on the tracks, playlists
+to be played and its meta-data:
+
+    # The URL to get playlist details via Tank
+    importerurl="http://localhost:8040/api/v1/shows/${SLUG}/playlists"
+
+
+More information you can find here: <https://gitlab.servus.at/autoradio/meta/blob/master/api-definition.md>
+
+
+## Provided API Endpoints
+
+**Soundserverstate:** Returns true and false values of the internal In- and Outputs  
+
+    /api/v1/soundserver_state
+
+**Trackservice:**
+
+/api/v1/trackservice/<selected_date>  
+/api/v1/trackservice/
+
+
+## Components
+
+
+**aura.py**: It is the server which is connected to the external programme source (e.g. aura steering and tank), to liquidsoap and is listening for redis pubsub messages. This precious little server is telling liquidsoap what to play and when.
+
+**Guru**: The commandline tool for interacting with the server. Also provides the communication from Liquidsoap to the Python (Command-)Server.
+
+**Liquidsoap**: The heart of AuRa Engine. It uses the built in mixer, to switch between different sources. It records everything and streams everything depending on your settings in aura.ini.
+
+
+## Running the Engine
+
+Aura Engine is consisting of two components: The Python Engine and Liquidsoap Core.
+
+It's important to start both components in the correct order:
+
+    1. Run the Python engine
+
+    ./run.sh
+
+    2. Run the Liquidsoap core
+
+    ./run.sh lqs
--- a/docs/engine-features.md
+++ b/docs/engine-features.md
+# Aura Engine Features
+
+This page gives a more detailed overview of the Aura Engine features.
+
+## Input
+
+### Play audio from multiple sources
+
+It's possible to air playlists with music or recordings stored on the **filessystem**,
+via external **streams** or live from a **studio**.
+
+### Dynamic switching of sources
+
+    TODO extend: * switch the soundserver at the correct time to a given source for a specific show
+
+## Output
+
+### Record output to filesystem
+
+    TODO extend:  * record what is broadcasted
+
+### Stream output to an Icecast Server
+
+    TODO extend:  * stream to an icecast server
+
+### Multichannel Line-out
+
+    TODO extend:  * play to line-out
+
+## Blank Detenction / Silence Detecter
+
+The engine offers a simple way to detect scenarios where no music is on air.
+It possible to configure the sensitivity of the Silence Detector and automatically
+transition play-out to a Fallback Playlist (see Auto Pilot).
+
+## Auto Pilot a.k.a. Fallback Handling
+
+In case there is no schedule delivered by Steering, engine provides multiple
+fallback handling scenarios. The available fallbacks are evaluated in following order:
+
+1. **Timeslot Fallback**:
+
+2. **Show Fallback**:
+
+3. **Station Fallback**:
+
+3.1 Station Fallback via remote playlist
+
+3.2 Station Fallback via local music folder
+
+Note: All filenames in the music folder should be ASCII encoded, otherwise this may cause engine failures.
+
+# Track-Service API
+
+The Track Service API provides following endpoints:
+
+* `/api/v1/` ............. Returns all Track Service entries for the last three hours
+* `/api/v1/$ID` .......... Returns a Track Service entry by ID
+* `/api/v1/current` ...... Returns the currently playing track
+* `/api/v1/day/$DAY` ..... Returns the tracks for a given day formated as `YYYY-MM-DD`
+
+The Swagger Specification of a Track Service entry as YAML looks like this:
+
+```yaml
+    components:
+    schemas:
+        TrackService:
+        properties:
+            album: {}
+            artist: {}
+            duration: {}
+            fallback: {}
+            id: {}
+            schedule_start: {}
+            title: {}
+            track_start: {}
+        type: object
+    info:
+    title: Swagger API Specification for Aura Engine
+    version: 1.0.0
+    openapi: 3.0.2
+    paths: {}
+```
+
+# Programme API
\ No newline at end of file
--- a/errormessages/communicator_error.js
+++ b/errormessages/communicator_error.js
+{
+}
\ No newline at end of file
--- a/errormessages/controller_error.js
+++ b/errormessages/controller_error.js
+{
+  "allData": {
+    "id": "01",
+    "00": "Global Metadata delivered",
+    "01": "Could not get Data from Sound Engine"
+  },
+  "channel_insert": {
+    "id": "02",
+    "00": "On Channel ::channel:: insert ::uri:: at position ::pos::",
+    "02": "On Channel ::channel:: could not insert ::uri:: at position ::pos::"
+  },
+  "channel_move": {
+    "id": "03",
+    "00": "On Channel ::channel:: moved Item from ::fromPos:: to position ::toPos::",
+    "01": "Warning: Position ::fromPos:: out of range",
+    "02": "Warning: Cannot move to same position",
+    "03": "On Channel ::channel:: could not move from position ::fromPos:: to  position ::toPos::"
+  },
+  "channel_off": {
+    "id": "04",
+    "00": "Channel ::channel:: off",
+    "01": "Could not activate Channel ::channel::"
+  },
+  "channel_on": {
+    "id": "05",
+    "00": "Channel ::channel:: on",
+    "01": "Could not deactivate Channel ::channel::"
+  },
+  "channel_queue": {
+    "id": "06",
+    "00": "Channel Queue for ::channel:: delivered",
+    "01": "Could not get channel queue from channel ::channel::",
+    "02": "Could not get channel queue from channel ::channel::",
+    "03": "Could not get channel queue from channel ::channel::"
+  },
+  "channel_remove": {
+    "id": "07",
+    "00": "Removed item on position ::pos:: from channel ::channel::",
+    "01": "Could not remove item on position ::pos:: from channel ::channel::",
+    "02": "Warning: position ::pos:: out of range'"
+  },
+  "channel_seek": {
+    "id": "08",
+    "00": "Seeked channel ::channel:: ::duration:: seconds",
+    "01": "Could not seek channel ::channel:: ::duration:: seconds"
+  },
+  "channel_skip": {
+    "id": "09",
+    "00": "Skipped channel ::channel::",
+    "01": "0 Channels listed",
+    "02": "Could not get channels from sound engine",
+    "03": "Could not skip ::channel::"
+  },
+  "channel_volume": {
+    "id": "10",
+    "00": "Volume ::volume::% set on channel ::channel::",
+    "01": "Could not set volume to ::volume::% on channel ::channel::",
+    "02": "0 Channels listed",
+    "03": "Could not get channels from sound engine"
+  },
+  "currentData": {
+    "id": "11",
+    "00": "Current track metadata delivered",
+    "01": "Nothing seems to be on air",
+    "02": "Could not detect metadata"
+  },
+  "help": {
+    "id": "12",
+    "00": "none",
+    "01": "Could not open help file"
+  },
+  "listChannels": {
+    "id": "13",
+    "00": "Listed Channels",
+    "01": "0 Channels listed",
+    "02": "Could not get channels from sound engine"
+  },
+  "message": {
+    "id": "14",
+    "00": "none"
+  },
+  "playlist_data": {
+    "id": "15",
+    "00": "Playlist data delivered"
+  },
+  "playlist_flush": {
+    "id": "16",
+    "00": "Flushed playlist",
+    "01": "Could not flush playlist"
+  },
+  "playlist_insert": {
+    "id": "17",
+    "00": "Insert track ::uri:: on position ::pos::"
+  },
+  "playlist_load": {
+    "id": "18",
+    "00": "Load Playlist ::uri::",
+    "01": "Could not load Playlist ::uri::",
+    "02": "Playlist is not well formed XML"
+  },
+  "playlist_move": {
+    "id": "19",
+    "00": "Moved playlist track from position ::fromPos:: to ::toPos::"
+  },
+  "playlist_pause": {
+    "id": "20",
+    "00": "Playlist paused",
+    "01": "Playlist already paused"
+  },
+  "playlist_stop": {
+    "id": "21",
+    "00": "Playlist stopped",
+    "01": "Playlist already stopped"
+  },
+  "playlist_play": {
+    "id": "22",
+    "00": "Playlist started",
+    "01": "Playlist already playing",
+    "02": "0 Channels listed",
+    "03": "Could not get channels from sound engine"
+  },
+  "playlist_push": {
+    "id": "23",
+    "00": "Playlist: pushed ::uri::",
+    "01": "Could not push ::uri::"
+  },
+  "playlist_remove": {
+    "id": "24",
+    "00": "Removed track on position ::pos:: from playlist",
+    "01": "Could not remove track on position ::pos:: from playlist"
+  },
+  "playlist_seek": {
+    "id": "25",
+    "00": "Seeked playlist ::duration:: seconds",
+    "01": "Could not seek playlist ::duration:: seconds"
+  },
+  "playlist_skip": {
+    "id": "26",
+    "00": "Could not skip playlist"
+  },
+  "recorder_data": {
+    "id": "27",
+    "00": "Delivered recorder data",
+    "01": "Could not deliver recorder data"
+  },
+  "recorder_start": {
+    "id": "28",
+    "00": "Recorder started",
+    "01": "Could not start recorder"
+  },
+  "recorder_stop": {
+    "id": "29",
+    "00": "Recorder stopped",
+    "01": "Could not stop recorder"
+  },
+  "scheduler_reload": {
+    "id": "30",
+    "00": "Reload signal was sent to scheduler",
+    "01": "Could not find the scheduler process"
+  },
+  "sendLqcCommand": {
+    "id": "31",
+    "01": "Soundengine not running",
+    "02": "Recorder not running"
+  },
+  "get_channel_state": {
+    "id": "32",
+    "00": "Channels ::channel:: state",
+    "01": "Could not get channel state from channel ::channel::"
+  },
+  "setPassword": {
+    "id": "33",
+    "00": "Successfull set password",
+    "01": "Not enough access rights for this operation"
+  },
+  "addUser": {
+    "id": "34",
+    "00": "Successfull add user ::username::",
+    "01": "Not enough access rights for this operation"
+  },
+  "delUser": {
+    "id": "35",
+    "00": "Successfull removed user ::username::",
+    "01": "Not enough access rights for this operation"
+  },
+  "scheduler_data": {
+    "id": "36",
+    "00": "Successfull delivered scheduler config",
+    "01": "Scheduler config seems to be broken"
+  },
+  "scheduler_store": {
+    "id": "37",
+    "00": "Successfull stored scheduler config",
+    "01": "Not enough access rights for this operation",
+    "02": "Could not store a valid scheduler XML"
+  },
+  "getUserlist": {
+    "id": "38",
+    "00": "Userlist was successfully delivered",
+    "01": "Not enough access rights for this operation"
+  },
+  "get_act_programme": {
+    "id": "39",
+    "00": "Successfully fetched the program",
+    "01": "Cannot fetch actual program"
+  }
+}
\ No newline at end of file
--- a/errormessages/scheduler_error.js
+++ b/errormessages/scheduler_error.js
+{
+  "exec_job": {
+    "id": "01",
+    "00": "Execute job ::job::",
+    "01": "Fatal: Could not execute job ::job::. Command ::exec:: results in Exception ::Exception::. Stopped watcher"
+  },
+  "schedule_job": {
+    "id": "02",
+    "00": "Scheduled job ::job:: for ::scheduled_for:: at ::scheduled_at::",
+    "01": "Could not execute job"
+  },
+  "load_playlist": {
+    "id": "03",
+    "00": "Load playlist ::uri::",
+    "01": "Could not load playlist ::uri::. File does not exist!",
+    "02": "Controller failed to load playlist ::uri::. Message was '::message::'"
+  },
+  "play_playlist": {
+    "id": "04",
+    "00": "Started playlist",
+    "01": "Controller failed to start playlist. Message was '::message::'"
+  },
+  "stop_playlist": {
+    "id": "05",
+    "00": "Started playlist",
+    "01": "Controller failed to start playlist. Message was '::message::'"
+  },
+  "start_recording": {
+    "id": "06",
+    "00": "Started recording",
+    "01": "Controller failed to start recording. Message was '::message::'"
+  },
+  "stop_recording": {
+    "id": "07",
+    "00": "Stopped recording",
+    "01": "Controller failed to stop recording. Message was '::message::'"
+  },
+  "precache": {
+    "id": "08",
+    "00": "Precached playlists",
+    "01": "Could not precache playlist."
+  },
+  "clean_cached": {
+    "id": "09",
+    "00": "Cleaned cache",
+    "01": "Could not clean cache"
+  },
+  "on_start": {
+    "id": "10",
+    "00": "Do initial jobs",
+    "01": "Could not do initial jobs"
+  },
+  "lookup_prearranged": {
+    "id": "11",
+    "00": "Lookup for prearranged tracks",
+    "01": "No system channel available"
+  },
+  "start_prearranged": {
+    "id": "12",
+    "00": "Started preaarranged tracks"
+  },
+  "end_prearranged": {
+    "id": "13",
+    "00": "Stopped preaarranged tracks"
+  }
+}
\ No newline at end of file
--- a/guru.py
+++ b/guru.py
+#!/usr/bin/python3.7
+
+#
+#  engine
+#
+#  Playout Daemon for autoradio project
+#
+#
+#  Copyright (C) 2017-2018 Gottfried Gaisbauer <gottfried.gaisbauer@servus.at>
+#
+#  This file is part of engine.
+#
+#  engine 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, either version 3 of the License, or
+#  any later version.
+#
+#  engine 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 engine. If not, see <http://www.gnu.org/licenses/>.
+#
+
+import time
+import sys
+import redis
+
+from pathlib import Path
+from argparse import ArgumentParser
+
+# own libs
+from modules.cli_tool.padavan import Padavan
+from libraries.exceptions.auraexceptions import PlaylistException
+from libraries.base.config import AuraConfig
+
+
+class Guru():
+    """
+        Command Line Interface (CLI) for Aura Engine.
+    """
+    # config_path = "%s/configuration/engine.ini" % Path(__file__).parent.absolute()
+    config = AuraConfig()
+    parser = None
+    args = None
+
+    # ------------------------------------------------------------------------------------------ #
+    def __init__(self):
+        self.init_argument_parser()
+        self.handle_arguments()
+
+    def handle_arguments(self):
+        if self.args.stoptime:
+            start = time.time()
+
+        if not self.args.quiet:
+            print("Guru thinking...")
+
+        try:
+            p = Padavan(self.args, self.config)
+            p.meditate()
+        except PlaylistException as pe:
+            # typically there is no next file found
+            if not self.args.quiet:
+                print(pe)
+            else:
+                print("")
+            exit(4)
+        except redis.exceptions.TimeoutError:
+            print("Timeout when waiting for redis message. Is AURA daemon running? Exiting...")
+            exit(3)
+
+        if not self.args.quiet:
+            print("...result: ")
+
+        if p.stringreply != "":
+            #print(p.stringreply)
+            if p.stringreply[len(p.stringreply)-1] == "\n":
+                print(p.stringreply[0:len(p.stringreply) - 1])
+            else:
+                print(p.stringreply[0:len(p.stringreply)])
+
+        if self.args.stoptime:
+            end = time.time()
+            exectime = end-start
+            print("execution time: "+str(exectime)+"s")
+
+    def init_argument_parser(self):
+
+        try:
+            self.create_parser()
+            self.args = self.parser.parse_args()
+
+        except (ValueError, TypeError) as e:
+            if self.parser is not None:
+                self.parser.print_help()
+            print()
+            print(e)
+            exit(1)
+
+    def create_parser(self):
+        self.parser = ArgumentParser()
+
+        # options
+        self.parser.add_argument("-sep", "--stop-execution-time", action="store_true", dest="stoptime",   default=False, help="Prints the execution time at the end of the skript")
+        self.parser.add_argument("-q",   "--quiet",               action="store_true", dest="quiet",      default=False, help="Just the result will outputed to stout")
+        self.parser.add_argument("-rd",  "--recreate-database",   action="store_true", dest="recreatedb", default=False, help="Do you want to recreate the database?")
+
+        # getter
+        self.parser.add_argument("-pcs", "--print-connection-status", action="store_true", dest="get_connection_status",  default=False, help="Prints the status of the connection to liquidsoap, pv and tank")
+        self.parser.add_argument("-gam", "--get-active-mixer",        action="store_true", dest="get_active_mixer",       default=False, help="Which mixer is activated?")
+        self.parser.add_argument("-pms", "--print-mixer-status",      action="store_true", dest="get_mixer_status",       default=False, help="Prints all mixer sources and their states")
+        self.parser.add_argument("-pap", "--print-act-programme",     action="store_true", dest="get_act_programme",      default=False, help="Prints the actual Programme, the controller holds")
+
+        # liquid manipulation
+        self.parser.add_argument("-am", "--select-mixer",    action="store", dest="select_mixer",   default=-1, metavar="MIXERNAME",                     help="Which mixer should be activated?")
+        self.parser.add_argument("-dm", "--de-select-mixer", action="store", dest="deselect_mixer", default=-1, metavar="MIXERNAME",                     help="Which mixer should be activated?")
+        self.parser.add_argument("-vm", "--volume",          action="store", dest="set_volume",     default=0,  metavar=("MIXERNUM", "VOLUME"), nargs=2, help="Set volume of a mixer source", type=int)
+
+        # shutdown server
+        self.parser.add_argument("-sd", "--shutdown", action="store_true", dest="shutdown", default=False, help="Shutting down aura server")
+
+        # playlist in/output
+        self.parser.add_argument("-fnp", "--fetch-new-programmes",  action="store_true", dest="fetch_new_programme",   default=False, help="Fetch new programmes from api_calendar_url in engine.ini")
+        self.parser.add_argument("-pmq", "--print-message-queue",   action="store_true", dest="print_message_queue",   default=False, help="Prints message queue")
+
+        # send a redis message
+        self.parser.add_argument("-rm", "--redis-message", action="store", dest="redis_message", default=False, metavar=("CHANNEL", "MESSAGE"), nargs=2, help="Send a redis message to the Listeners")
+
+        # calls from liquidsoap
+        self.parser.add_argument("-gnf", "--get-next-file-for", action="store",      dest="get_file_for", default=False, metavar="PLAYLISTTYPE",                    help="For which type you wanna GET a next audio file?")
+        self.parser.add_argument("-snf", "--set-next-file-for", action="store",      dest="set_file_for", default=False, metavar=("PLAYLISTTYPE", "FILE"), nargs=2, help="For which type you wanna SET a next audio file?")
+        self.parser.add_argument("-np",  "--now-playing",       action="store_true", dest="now_playing",  default=False,                                            help="Which source is now playing")
+        self.parser.add_argument("-ip",  "--init-player",       action="store_true", dest="init_player",  default=False,                                            help="Reset liquidsoap volume and mixer activations?")
+        self.parser.add_argument("-ts",  "--adapt-trackservice-title", action="store", dest="adapt_trackservice_title",  default=False, metavar="TITLE",            help="Update trackservice entry due to fallback")
+
+        if len(sys.argv) == 1:
+            raise ValueError("No Argument passed!")
+
+
+def valid_playlist_entry(argument):
+    from datetime import datetime
+
+    try:
+
+        index = int(argument[0])
+        fromtime = datetime.strptime(argument[1], "%Y-%m-%d")
+        source = argument[2]
+        return index, fromtime, source
+    except:
+        msg = "Not a valid date: '{0}'.".format(argument[0])
+        print(msg)
+        raise
+
+
+# # ## ## ## ## ## # #
+# # ENTRY FUNCTION # #
+# # ## ## ## ## ## # #
+def main():
+    Guru()
+# # ## ## ## ## ## ## # #
+# # End ENTRY FUNCTION # #
+# # ## ## ## ## ## ## # #
+
+
+if __name__ == "__main__":
+    main()
--- a/initdb.py
+++ b/initdb.py
--- a/install.sh
+++ b/install.sh
+python3.7 $(which pip3) install -r requirements.txt
\ No newline at end of file
--- a/libraries/base/config.py
+++ b/libraries/base/config.py
--- a/libraries/base/logger.py
+++ b/libraries/base/logger.py
--- a/libraries/database/broadcasts.py
+++ b/libraries/database/broadcasts.py
--- a/libraries/database/statestore.py
+++ b/libraries/database/statestore.py
--- a/libraries/enum/auraenumerations.py
+++ b/libraries/enum/auraenumerations.py
No results found