Half way through the rewamp!

2025-03-04 08:51:40 -05:00 · 2017-04-22 12:12:16 +12:00 · 2017-04-22 12:12:16 +12:00 · 379e6bf9d7
commit 379e6bf9d7
parent 73bbc1db92
50 changed files with 13403 additions and 650 deletions
--- a/#communicator.js#
+++ b/#communicator.js#
@ -0,0 +1,19 @@
+///////////////////////////////////////////////////////////////////////////////
+//     A socket.js wrapper to abstract the communication with the server.    //
+///////////////////////////////////////////////////////////////////////////////
+
+const socketio = require('socket.io-client');
+
+///////////////////////////////////////////////////////////////////////////////
+//                                Declarations                               //
+///////////////////////////////////////////////////////////////////////////////
+
+// Object oriented `this`.
+let self = false;
+
+///////////////////////////////////////////////////////////////////////////////
+//                                    Code                                   //
+///////////////////////////////////////////////////////////////////////////////
+
+module.exports = function Communicator(){};
+
--- a/#main.js#
+++ b/#main.js#
@ -1,494 +0,0 @@
-///////////////////////////////////////////////////////////////////////////////////
-// Main Module - Communicates with the Server and Orchestrates the other Moules. //
-///////////////////////////////////////////////////////////////////////////////////
-
-const sock = require('socket.io-client');
-const ffmpeg = require('fluent-ffmpeg');
-const http = require('http');
-const path = require('path');
-const fs = require('fs');
-const WMStrm = require(__dirname + '/lib/memWrite.js');
-const exec = require('child_process').exec;
-const execSync = require('child_process').execSync;
-const spawnP = require('child_process').spawn;
-
-/**
- * Custom Modules
- * Yet to be initialized.
- */
-const logger = require('src/logger.js');
-
-///////////////////////////////////////////////////////////////////////////////
-//                                Declarations                               //
-///////////////////////////////////////////////////////////////////////////////
-
-// Force a Stop.
-let mustBe = false;
-
-// Restart the stream after it stopped.
-let restart = false;
-
-// Central State Variable
-// NOTE: Could be done with redux!
-let status = {
-    status: 0,
-    error: -1
-}
-
-// Minor declarations.
-let config, source, snapSource, stopTimeout;
-
-let spawn = function() {
-    source = 'rtsp://' + config.camIP + ':' + config.camPort + '/' + config.camProfile;
-    ffmpeg.setFfmpegPath(config.ffmpegPath);
-    delete cmd;
-    cmd = ffmpeg({
-        source: source,
-        stdoutLines: 20
-    });
-    if (config.customOutputOptions !== "")
-        cmd.outputOptions(config.customOutputOptions.replace(/\s+\,\s+/g, ',').replace(/\s+\-/g, ',-').split(','));
-    if (config.customAudioOptions !== "")
-        cmd.outputOptions(config.customAudioOptions.replace(/\s+\,\s+/g, ',').replace(/\s+\-/g, ',-').split(','));
-    else
-        cmd.AudioCodec('copy');
-    if (config.customVideoOptions !== "")
-        cmd.outputOptions(config.customVideoOptions.replace(/\s+\,\s+/g, ',').replace(/\s+\-/g, ',-').split(','));
-    else
-        cmd.videoCodec('copy');
-
-    cmd.on('start', function(commandLine) {
-            status.running = 0;
-            logger.log(logger.importance[4], 'Spawned Ffmpeg with command: ' + commandLine);
-        })
-        .on('end', function(o, e) {
-            imDead('Normal Stop.', e);
-        })
-        .on('error', function(err, o, e) {
-            if (err.message.indexOf(source) > -1)
-                criticalProblem(0, e, handleDisc, config.camIP, config.camPort);
-            else if (err.message.indexOf(source + 'Input/output error') > -1 || err.message.indexOf('rtmp://a.rtmp.youtube.com/live2/' + config.key) > -1)
-                criticalProblem(1, e, handleDisc, 'a.rtmp.youtube.com/live2/', 1935);
-            else if (err.message.indexOf('spawn') > -1 || err.message.indexOf('niceness') > -1)
-                criticalProblem(2, e, function() {});
-            else if (err.message.indexOf('SIGINT') > -1 || err.message.indexOf('SIGKILL') > -1)
-                imDead('Normal Stop.', e);
-            else
-                imDead(err.message, e);
-        })
-        .outputFormat('flv')
-        .outputOptions(['-bufsize 50000k', '-tune film'])
-        .output('rtmp://a.rtmp.youtube.com/live2/' + config.key);
-    
-    status.error = -1;
-    socket.emit('change', {
-        type: 'startStop',
-        change: {
-            running: 0,
-            error: -1
-        }
-    });
-    cmd.run();
-};
-
-let getSnap = function(cb) {
-    snapSource = 'rtsp://' + config.camIP + ':' + config.camPort + '/' + config.snapProfile;
-    let picBuff = new WMStrm();
-    recCmd = ffmpeg(snapSource)
-        .on('start', function(commandLine) {
-            logger.log(logger.importance[4], 'Snapshot ' + commandLine);
-        })
-        .on('error', function(err, o, e) {})
-        .outputFormat('mjpeg')
-        .frames(1)
-        .stream(picBuff, {
-            end: true
-        });
-    picBuff.on('finish', function() {
-        try {
-            cb(picBuff.memStore.toString('base64'));
-            delete pickBuff;
-        } catch (e) {
-            cb(false);
-        }
-    });
-}
-
-function imDead(why, e = '') {
-    if(stopTimeout) {
-	clearTimeout(stopTimeout);
-	stopTimeout = false;
-    }
-    
-    status.running = 1;
-    socket.emit('change', {
-        type: 'startStop',
-        change: {
-            running: 1
-        }
-    });
-    if (restart) {
-        spawn();
-        restart = false;
-    }
-    if (!mustBe) {
-        logger.log(logger.importance[2], 'Crash! ' + e);
-        setTimeout(function() {
-            spawn();
-        }, 1000);
-    }
-    mustBe = false;
-}
-
-function criticalProblem(err, e, handler, ...args) {
-    if (!mustBe) {
-        setTimeout(function() {
-            status.running = 2;
-            status.error = err;
-            logger.log(logger.importance[3], 'Critical Problem: ' + errors[err] + '\n' + e);
-            socket.emit('change', {
-                type: 'error',
-                change: {
-                    running: 2,
-                    error: err
-                }
-            });
-            handler(args)
-        }, 1000);
-    }
-    mustBe = false;
-}
-
-function handleDisc(info) {
-    let [host, port] = info;
-    isReachable(host, port, is => {
-        if (is) {
-            spawn();
-        } else {
-            setTimeout(function() {
-                handleDisc(info);
-            }, 10000);
-        }
-    });
-}
-
-function isReachable(host, port, callback) {
-    http.get({
-        host: host.split('/')[0],
-        port: port
-    }, function(res) {
-        callback(true);
-    }).on("error", function(e) {
-        if (e.message == "socket hang up") {
-            setTimeout(function() {
-                callback(true);
-            }, 1000);
-        } else
-            callback(false);
-    });
-}
-
-function stopFFMPEG() {
-    cmd.kill('SIGINT');
-    stopTimeout = setTimeout(() => {
-        logger.log(logger.importance[3], "Force Stop!");
-        cmd.kill();
-    }, 3000);
-}
-
-var commandHandlers = function commandHandlers(command, cb) {
-    var handlers = {
-        startStop: function() {
-	    if(restart)
-		return;
-	    
-            if (status.running !== 2)
-                if (status.running === 0) {
-                    logger.log(logger.importance[1], "Stop Command!");
-                    mustBe = true;
-                    stopFFMPEG();
-                    socket.emit('data', {
-                        type: 'message',
-                        data: {
-                            title: 'Success',
-                            type: 'success',
-                            text: 'Stopped!'
-                        }
-                    }, command.sender);
-                } else {
-                    logger.log(logger.importance[1], "Start Command!");
-                    spawn();
-                    socket.emit('data', {
-                        type: 'message',
-                        data: {
-                            title: 'Success',
-                            type: 'success',
-                            text: 'Started!'
-                        }
-                    }, command.sender);
-                }
-        },
-        snap: function() {
-            getSnap(snap => {
-                socket.emit('data', {
-                    type: 'snap',
-                    data: snap,
-                }, command.sender);
-            });
-        },
-        config: function() {
-            socket.emit('data', {
-                type: 'config',
-                data: config,
-            }, command.sender);
-        },
-        changeSettings: function() {
-            for (let set in command.data) {
-                if (typeof config[set] !== 'undefined')
-                    config[set] = command.data[set];
-            }
-            let oldConfigured;
-            if (config.configured === true)
-                oldConfigured = true;
-            config.configured = true;
-            fs.writeFile(__dirname + '/config.js',
-                JSON.stringify(config,
-                    undefined, 2),
-                function(err) {
-                    if (err) {
-                        socket.emit('data', {
-                            type: 'message',
-                            data: {
-                                title: 'Error',
-                                type: 'error',
-                                text: 'Can\'t save the Settings!\n' + err.message
-                            }
-                        }, command.sender);
-                    } else {
-                        restartSSH(() => {
-                            socket.emit('data', {
-                                type: 'message',
-                                data: {
-                                    title: 'Success',
-                                    type: 'success',
-                                    text: 'Settings Saved!'
-                                }
-                            }, command.sender);
-                            if (oldConfigured) {
-                                socket.emit('change', {
-                                    type: 'settings',
-                                    change: {
-                                        config: command.data
-                                    }
-                                });
-                                stopFFMPEG();
-                                spawn();
-                            } else {
-                                socket.disconnect();
-                                init();
-                            }
-                        });
-                    }
-                });
-        },
-        restart: function() {
-            if (status.running === 0) {
-                logger.log(logger.importance[1], "Restart Command!");
-                mustBe = true;
-                restart = true;
-                stopFFMPEG();
-            } else {
-                logger.log(logger.importance[1], "Start Command!");
-                spawn();
-            }
-            socket.emit('data', {
-                type: 'message',
-                data: {
-                    title: 'Success',
-                    type: 'success',
-                    text: 'Restarted!'
-                }
-            }, command.sender);
-        },
-        restartSSH: function() {
-            restartSSH(() => {
-                socket.emit('data', {
-                    type: 'message',
-                    data: {
-                        title: 'Success',
-                        type: 'success',
-                        text: 'Restarted SSH Tunnels!'
-                    }
-                }, command.sender);
-            });
-        },
-        getLogs: function() {
-          logger.query({limit: 100}, function (err, data) {
-		data = data.file;
-		if (err) {
-                    data = [];
-                } else
-                if (data.length === 0)
-                    data = [];
-                socket.emit('data', {
-                    type: 'logs',
-                    data: data
-                }, command.sender);
-            });
-        }
-    };
-
-    //call the handler
-    var call = handlers[command.command];
-    if (call)
-        call();
-}
-
-function restartSSH(cb) {
-    exec('forever stop SSH-Serv', () => {
-        connectSSH(() => {
-            socket.emit('change', {
-                change: {
-                    ssh: {
-                        port: status.ssh.port,
-                        camForwardPort: status.ssh.camForwardPort
-                    }
-                }
-            });
-            cb();
-        });
-    });
-}
-
-function handleKill() {
-    process.stdin.resume();
-    logger.log(logger.importance[0], "Received Shutdown Command");
-    mustBe = true;
-    cmd.kill();
-    process.exit(0);
-}
-
-process.on('SIGTERM', function() {
-    handleKill();
-});
-
-//let's go
-function init() {
-    config = readConfig();
-
-    if (config.configured) {
-        socket = sock(config.master + '/pi');
-        initSocket();
-        status.name = config.name;
-        if (!cmd)
-            spawn();
-    } else {
-        socket = sock(config.master + '/pi', {
-            query: "unconfigured=true"
-        });
-        status.running = 2;
-        initSocket();
-    }
-}
-
-
-function initSSH(cb) {
-    status.ssh = {
-        // that Could come from the Master server!
-        user: config['ssh-user'],
-        localUser: config['ssh-local-user'],
-        masterPort: config['ssh-port']
-    };
-
-    checkSSH((alive) => {
-        if (alive)
-            cb();
-        else
-            connectSSH(cb);
-    });
-}
-
-function connectSSH(cb = function() {
-    socket.emit('change', {
-        change: {
-            ssh: {
-                port: status.ssh.port,
-                camForwardPort: status.ssh.camForwardPort
-            }
-        }
-    });
-}) {
-    socket.emit('getSSHPort', ports => {
-        [status.ssh.port, status.ssh.camForwardPort] = ports;
-        let ssh = exec(`forever start -a --killSignal=SIGINT --uid SSH-Serv sshManager.js ${status.ssh.port} ${status.ssh.camForwardPort} ${config.camPanelPort}`, {
-            detached: true,
-            shell: true,
-            cwd: __dirname
-        });
-        ssh.on('error', (err) => {
-             socket.emit('data', {
-                    type: 'message',
-                    data: {
-                        title: 'Error',
-                        type: 'error',
-                        text: 'Could not start SSH tunnels!'
-                    }
-                }, command.sender);
-        });
-        cb();
-    });
-}
-
-function checkSSH(cb) {
-    let m, pid, alive;
-    let re = /SSH-Serv.*?sshManager\.js\s([0-9]+)\s([0-9]+).*log.*[^STOPPED]+/g;
-    exec('forever list', (error, stdout, stderr) => {
-        if (error)
-            throw error;
-        let alive = false;
-        while ((m = re.exec(stdout)) !== null) {
-            if (m.index === re.lastIndex) {
-                re.lastIndex++;
-            }
-            if (alive) {
-                exec('forever stop SSH-Serv');
-                cb(false)
-                return;
-            } else {
-                [, status.ssh.port, status.ssh.camForwardPort] = m;
-                alive = true;
-            }
-        }
-        cb(alive);
-    });
-}
-
-function initSocket() {
-    socket.on('connect', function() {
-        logger.log(logger.importance[0], 'Connected to Master: ' + config.master + '.');
-        if (config['ssh-user'])
-            initSSH(err => {
-                if (err)
-                    throw err;
-                socket.emit('meta', status);
-            });
-        else {
-            socket.emit('meta', status);
-        }
-    });
-
-    socket.on('disconnect', function() {
-        socket.disconnect();
-        init();
-    });
-
-    socket.on('command', (command, cb) => {
-        commandHandlers(command, cb);
-    });
-}
-
-function readConfig() {
-    return JSON.parse(fs.readFileSync(__dirname + '/config.js'));
-}
-
-init();
--- a/.#communicator.js
+++ b/.#communicator.js
@ -0,0 +1 @@
+hiro@ArLeenUX.857:1492754930
--- a/.#main.js
+++ b/.#main.js
@ -1 +0,0 @@
-hiro@ArLeenUX.4902:1492242088
--- a/.tern-port
+++ b/.tern-port
@ -1 +1 @@
-36411
+46703
--- a/.tern-project
+++ b/.tern-project
@ -1,7 +1,5 @@
 {
  "plugins": {
-    "node": {},
-   "lint": {},
-    "node-extension": {}
+    "node": {}
  }
-}
+}
--- a/communicator.js
+++ b/communicator.js
@ -0,0 +1,18 @@
+///////////////////////////////////////////////////////////////////////////////
+//     A socket.js wrapper to abstract the communication with the server.    //
+///////////////////////////////////////////////////////////////////////////////
+
+const socketio = require('socket.io-client');
+
+///////////////////////////////////////////////////////////////////////////////
+//                                Declarations                               //
+///////////////////////////////////////////////////////////////////////////////
+
+// Object oriented `this`.
+let self = false;
+
+///////////////////////////////////////////////////////////////////////////////
+//                                    Code                                   //
+///////////////////////////////////////////////////////////////////////////////
+
+module.exports = function Communicator(){};
--- a/communicator.js~
+++ b/communicator.js~
@ -0,0 +1,18 @@
+///////////////////////////////////////////////////////////////////////////////
+//     A socket.js wrapper to abstract the communication with the server.    //
+///////////////////////////////////////////////////////////////////////////////
+
+const socketio = require('socket.io-client');
+
+///////////////////////////////////////////////////////////////////////////////
+//                                Declarations                               //
+///////////////////////////////////////////////////////////////////////////////
+
+// Object oriented `this`.
+let self = false;
+
+///////////////////////////////////////////////////////////////////////////////
+//                                    Code                                   //
+///////////////////////////////////////////////////////////////////////////////
+
+module.exports = function Communicator(){}
--- a/main.js
+++ b/main.js
@ -79,7 +79,7 @@ let spawn = function() {
        .outputFormat('flv')
        .outputOptions(['-bufsize 50000k', '-tune film'])
        .output('rtmp://a.rtmp.youtube.com/live2/' + config.key);
-    
+
    status.error = -1;
    socket.emit('change', {
        type: 'startStop',
@ -115,11 +115,11 @@ let getSnap = function(cb) {
 }

 function imDead(why, e = '') {
-    if(stopTimeout) {
-	clearTimeout(stopTimeout);
-	stopTimeout = false;
+    if (stopTimeout) {
+        clearTimeout(stopTimeout);
+        stopTimeout = false;
    }
-    
+
    status.running = 1;
    socket.emit('change', {
        type: 'startStop',
@ -199,9 +199,9 @@ function stopFFMPEG() {
 var commandHandlers = function commandHandlers(command, cb) {
    var handlers = {
        startStop: function() {
-	    if(restart)
-		return;
-	    
+            if (restart)
+                return;
+
            if (status.running !== 2)
                if (status.running === 0) {
                    logger.log(logger.importance[1], "Stop Command!");
@ -323,9 +323,11 @@ var commandHandlers = function commandHandlers(command, cb) {
            });
        },
        getLogs: function() {
-          logger.query({limit: 100}, function (err, data) {
-		data = data.file;
-		if (err) {
+            logger.query({
+                limit: 100
+            }, function(err, data) {
+                data = data.file;
+                if (err) {
                    data = [];
                } else
                if (data.length === 0)
@ -426,14 +428,14 @@ function connectSSH(cb = function() {
            cwd: __dirname
        });
        ssh.on('error', (err) => {
-             socket.emit('data', {
-                    type: 'message',
-                    data: {
-                        title: 'Error',
-                        type: 'error',
-                        text: 'Could not start SSH tunnels!'
-                    }
-                }, command.sender);
+            socket.emit('data', {
+                type: 'message',
+                data: {
+                    title: 'Error',
+                    type: 'error',
+                    text: 'Could not start SSH tunnels!'
+                }
+            }, command.sender);
        });
        cb();
    });
--- a/out/fonts/OpenSans-Bold-webfont.eot
+++ b/out/fonts/OpenSans-Bold-webfont.eot
--- a/out/fonts/OpenSans-Bold-webfont.svg
+++ b/out/fonts/OpenSans-Bold-webfont.svg
--- a/out/fonts/OpenSans-Bold-webfont.woff
+++ b/out/fonts/OpenSans-Bold-webfont.woff
--- a/out/fonts/OpenSans-BoldItalic-webfont.eot
+++ b/out/fonts/OpenSans-BoldItalic-webfont.eot
--- a/out/fonts/OpenSans-BoldItalic-webfont.svg
+++ b/out/fonts/OpenSans-BoldItalic-webfont.svg
--- a/out/fonts/OpenSans-BoldItalic-webfont.woff
+++ b/out/fonts/OpenSans-BoldItalic-webfont.woff
--- a/out/fonts/OpenSans-Italic-webfont.eot
+++ b/out/fonts/OpenSans-Italic-webfont.eot
--- a/out/fonts/OpenSans-Italic-webfont.svg
+++ b/out/fonts/OpenSans-Italic-webfont.svg
--- a/out/fonts/OpenSans-Italic-webfont.woff
+++ b/out/fonts/OpenSans-Italic-webfont.woff
--- a/out/fonts/OpenSans-Light-webfont.eot
+++ b/out/fonts/OpenSans-Light-webfont.eot
--- a/out/fonts/OpenSans-Light-webfont.svg
+++ b/out/fonts/OpenSans-Light-webfont.svg
--- a/out/fonts/OpenSans-Light-webfont.woff
+++ b/out/fonts/OpenSans-Light-webfont.woff
--- a/out/fonts/OpenSans-LightItalic-webfont.eot
+++ b/out/fonts/OpenSans-LightItalic-webfont.eot
--- a/out/fonts/OpenSans-LightItalic-webfont.svg
+++ b/out/fonts/OpenSans-LightItalic-webfont.svg
--- a/out/fonts/OpenSans-LightItalic-webfont.woff
+++ b/out/fonts/OpenSans-LightItalic-webfont.woff
--- a/out/fonts/OpenSans-Regular-webfont.eot
+++ b/out/fonts/OpenSans-Regular-webfont.eot
--- a/out/fonts/OpenSans-Regular-webfont.svg
+++ b/out/fonts/OpenSans-Regular-webfont.svg
--- a/out/fonts/OpenSans-Regular-webfont.woff
+++ b/out/fonts/OpenSans-Regular-webfont.woff
--- a/out/index.html
+++ b/out/index.html
@ -0,0 +1,65 @@
+<!DOCTYPE html>
+<html lang="en">
+<head>
+    <meta charset="utf-8">
+    <title>JSDoc: Home</title>
+
+    <script src="scripts/prettify/prettify.js"> </script>
+    <script src="scripts/prettify/lang-css.js"> </script>
+    <!--[if lt IE 9]>
+      <script src="//html5shiv.googlecode.com/svn/trunk/html5.js"></script>
+    <![endif]-->
+    <link type="text/css" rel="stylesheet" href="styles/prettify-tomorrow.css">
+    <link type="text/css" rel="stylesheet" href="styles/jsdoc-default.css">
+</head>
+
+<body>
+
+<div id="main">
+
+    <h1 class="page-title">Home</h1>
+
+    
+
+
+
+    
+
+
+    <h3> </h3>
+
+
+
+
+
+
+
+
+
+
+    
+
+
+
+
+
+
+
+
+
+</div>
+
+<nav>
+    <h2><a href="index.html">Home</a></h2><h3>Modules</h3><ul><li><a href="module-State.html">State</a></li></ul>
+</nav>
+
+<br class="clear">
+
+<footer>
+    Documentation generated by <a href="https://github.com/jsdoc3/jsdoc">JSDoc 3.4.3</a> on Sat Apr 22 2017 12:09:23 GMT+1200 (NZST)
+</footer>
+
+<script> prettyPrint(); </script>
+<script src="scripts/linenumber.js"> </script>
+</body>
+</html>
--- a/out/module-State.html
+++ b/out/module-State.html
@ -0,0 +1,620 @@
+<!DOCTYPE html>
+<html lang="en">
+<head>
+    <meta charset="utf-8">
+    <title>JSDoc: Module: State</title>
+
+    <script src="scripts/prettify/prettify.js"> </script>
+    <script src="scripts/prettify/lang-css.js"> </script>
+    <!--[if lt IE 9]>
+      <script src="//html5shiv.googlecode.com/svn/trunk/html5.js"></script>
+    <![endif]-->
+    <link type="text/css" rel="stylesheet" href="styles/prettify-tomorrow.css">
+    <link type="text/css" rel="stylesheet" href="styles/jsdoc-default.css">
+</head>
+
+<body>
+
+<div id="main">
+
+    <h1 class="page-title">Module: State</h1>
+
+    
+
+
+
+
+<section>
+
+<header>
+    
+        
+            
+        
+    
+</header>
+
+<article>
+    <div class="container-overview">
+    
+        
+            <div class="description">Redux Wrapper to hold the state and communicate with the Server</div>
+        
+
+        
+            
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+<dl class="details">
+
+    
+
+    
+
+    
+
+    
+
+    
+
+    
+
+    
+
+    
+
+    
+
+    
+
+    
+
+    
+
+    
+    <dt class="tag-source">Source:</dt>
+    <dd class="tag-source"><ul class="dummy"><li>
+        <a href="status.js.html">status.js</a>, <a href="status.js.html#line1">line 1</a>
+    </li></ul></dd>
+    
+
+    
+
+    
+
+    
+</dl>
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+        
+    
+    </div>
+
+    
+
+    
+
+    
+
+     
+
+    
+
+    
+        <h3 class="subsection-title">Members</h3>
+
+        
+            
+<h4 class="name" id="~ActionDispatchers"><span class="type-signature">(inner) </span>Action Dispatchers<span class="type-signature"></span></h4>
+
+
+
+
+<div class="description">
+    The central redux state manager. The module exposes central action dispatchers. Updates to the state get communicated to the server.
+</div>
+
+
+
+
+
+
+
+<dl class="details">
+
+    
+
+    
+
+    
+
+    
+
+    
+
+    
+
+    
+
+    
+
+    
+
+    
+
+    
+
+    
+
+    
+    <dt class="tag-source">Source:</dt>
+    <dd class="tag-source"><ul class="dummy"><li>
+        <a href="status.js.html">status.js</a>, <a href="status.js.html#line54">line 54</a>
+    </li></ul></dd>
+    
+
+    
+
+    
+
+    
+</dl>
+
+
+
+
+
+
+        
+            
+<h4 class="name" id="~initialState"><span class="type-signature">(inner) </span>initialState<span class="type-signature"></span></h4>
+
+
+
+
+<div class="description">
+    Inital State for the app.
+</div>
+
+
+
+
+
+
+
+    <h5 class="subsection-title">Properties:</h5>
+
+    
+
+<table class="props">
+    <thead>
+    <tr>
+        
+        <th>Name</th>
+        
+
+        <th>Type</th>
+
+        
+
+        
+
+        <th class="last">Description</th>
+    </tr>
+    </thead>
+
+    <tbody>
+    
+
+        <tr>
+            
+                <td class="name"><code>stream</code></td>
+            
+
+            <td class="type">
+            
+                
+<span class="param-type">Object</span>
+
+
+            
+            </td>
+
+            
+
+            
+
+            <td class="description last">Stream Status.
+                <h6>Properties</h6>
+
+<table class="props">
+    <thead>
+    <tr>
+        
+        <th>Name</th>
+        
+
+        <th>Type</th>
+
+        
+
+        
+
+        <th class="last">Description</th>
+    </tr>
+    </thead>
+
+    <tbody>
+    
+
+        <tr>
+            
+                <td class="name"><code>running</code></td>
+            
+
+            <td class="type">
+            
+                
+<span class="param-type">bool</span>
+
+
+            
+            </td>
+
+            
+
+            
+
+            <td class="description last">Indicates wether the stream is running.</td>
+        </tr>
+
+    
+
+        <tr>
+            
+                <td class="name"><code>error</code></td>
+            
+
+            <td class="type">
+            
+                
+<span class="param-type">number</span>
+
+
+            
+            </td>
+
+            
+
+            
+
+            <td class="description last">Error code. Any number outside the range of the Error array in @see ffmpeg-command.js will be treated as non error. Most conveniently set: -1.</td>
+        </tr>
+
+    
+
+        <tr>
+            
+                <td class="name"><code>reconnecting</code></td>
+            
+
+            <td class="type">
+            
+                
+<span class="param-type">bool</span>
+
+
+            
+            </td>
+
+            
+
+            
+
+            <td class="description last">Indicates wether the program tries to reconnect to the camera or the internet.</td>
+        </tr>
+
+    
+    </tbody>
+</table>
+
+            </td>
+        </tr>
+
+    
+
+        <tr>
+            
+                <td class="name"><code>config</code></td>
+            
+
+            <td class="type">
+            
+                
+<span class="param-type">Object</span>
+
+
+            
+            </td>
+
+            
+
+            
+
+            <td class="description last">Configuration of the camera.</td>
+        </tr>
+
+    
+    </tbody>
+</table>
+
+
+
+
+<dl class="details">
+
+    
+
+    
+
+    
+
+    
+
+    
+
+    
+
+    
+
+    
+
+    
+
+    
+
+    
+
+    
+
+    
+    <dt class="tag-source">Source:</dt>
+    <dd class="tag-source"><ul class="dummy"><li>
+        <a href="status.js.html">status.js</a>, <a href="status.js.html#line23">line 23</a>
+    </li></ul></dd>
+    
+
+    
+
+    
+
+    
+</dl>
+
+
+
+
+
+
+        
+    
+
+    
+        <h3 class="subsection-title">Methods</h3>
+
+        
+            
+
+    
+
+    <h4 class="name" id="~applyDispatchers"><span class="type-signature">(inner) </span>applyDispatchers<span class="signature">(creators)</span><span class="type-signature"></span></h4>
+
+    
+
+
+
+<div class="description">
+    Adds prototypes for the action dispatchers to the State.
+</div>
+
+
+
+
+
+
+
+
+
+    <h5>Parameters:</h5>
+    
+
+<table class="params">
+    <thead>
+    <tr>
+        
+        <th>Name</th>
+        
+
+        <th>Type</th>
+
+        
+
+        
+
+        <th class="last">Description</th>
+    </tr>
+    </thead>
+
+    <tbody>
+    
+
+        <tr>
+            
+                <td class="name"><code>creators</code></td>
+            
+
+            <td class="type">
+            
+                
+<span class="param-type">Object</span>
+
+
+            
+            </td>
+
+            
+
+            
+
+            <td class="description last"></td>
+        </tr>
+
+    
+    </tbody>
+</table>
+
+
+
+
+
+
+<dl class="details">
+
+    
+
+    
+
+    
+
+    
+
+    
+
+    
+
+    
+
+    
+
+    
+
+    
+
+    
+
+    
+
+    
+    <dt class="tag-source">Source:</dt>
+    <dd class="tag-source"><ul class="dummy"><li>
+        <a href="status.js.html">status.js</a>, <a href="status.js.html#line114">line 114</a>
+    </li></ul></dd>
+    
+
+    
+
+    
+
+    
+</dl>
+
+
+
+
+
+
+
+
+
+
+
+<h5>Throws:</h5>
+
+        
+
+<dl>
+    <dt>
+        <div class="param-desc">
+        If a method with the creators name already exists. @see actionCreators.js
+        </div>
+    </dt>
+    <dd></dd>
+    <dt>
+        <dl>
+            <dt>
+                Type
+            </dt>
+            <dd>
+                
+<span class="param-type">Error</span>
+
+
+            </dd>
+        </dl>
+    </dt>
+    <dd></dd>
+</dl>
+
+
+    
+
+
+
+
+
+        
+    
+
+    
+
+    
+</article>
+
+</section>
+
+
+
+
+</div>
+
+<nav>
+    <h2><a href="index.html">Home</a></h2><h3>Modules</h3><ul><li><a href="module-State.html">State</a></li></ul>
+</nav>
+
+<br class="clear">
+
+<footer>
+    Documentation generated by <a href="https://github.com/jsdoc3/jsdoc">JSDoc 3.4.3</a> on Sat Apr 22 2017 12:09:23 GMT+1200 (NZST)
+</footer>
+
+<script> prettyPrint(); </script>
+<script src="scripts/linenumber.js"> </script>
+</body>
+</html>
--- a/out/scripts/linenumber.js
+++ b/out/scripts/linenumber.js
@ -0,0 +1,25 @@
+/*global document */
+(function() {
+    var source = document.getElementsByClassName('prettyprint source linenums');
+    var i = 0;
+    var lineNumber = 0;
+    var lineId;
+    var lines;
+    var totalLines;
+    var anchorHash;
+
+    if (source && source[0]) {
+        anchorHash = document.location.hash.substring(1);
+        lines = source[0].getElementsByTagName('li');
+        totalLines = lines.length;
+
+        for (; i < totalLines; i++) {
+            lineNumber++;
+            lineId = 'line' + lineNumber;
+            lines[i].id = lineId;
+            if (lineId === anchorHash) {
+                lines[i].className += ' selected';
+            }
+        }
+    }
+})();
--- a/out/scripts/prettify/Apache-License-2.0.txt
+++ b/out/scripts/prettify/Apache-License-2.0.txt
@ -0,0 +1,202 @@
+
+                                 Apache License
+                           Version 2.0, January 2004
+                        http://www.apache.org/licenses/
+
+   TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
+
+   1. Definitions.
+
+      "License" shall mean the terms and conditions for use, reproduction,
+      and distribution as defined by Sections 1 through 9 of this document.
+
+      "Licensor" shall mean the copyright owner or entity authorized by
+      the copyright owner that is granting the License.
+
+      "Legal Entity" shall mean the union of the acting entity and all
+      other entities that control, are controlled by, or are under common
+      control with that entity. For the purposes of this definition,
+      "control" means (i) the power, direct or indirect, to cause the
+      direction or management of such entity, whether by contract or
+      otherwise, or (ii) ownership of fifty percent (50%) or more of the
+      outstanding shares, or (iii) beneficial ownership of such entity.
+
+      "You" (or "Your") shall mean an individual or Legal Entity
+      exercising permissions granted by this License.
+
+      "Source" form shall mean the preferred form for making modifications,
+      including but not limited to software source code, documentation
+      source, and configuration files.
+
+      "Object" form shall mean any form resulting from mechanical
+      transformation or translation of a Source form, including but
+      not limited to compiled object code, generated documentation,
+      and conversions to other media types.
+
+      "Work" shall mean the work of authorship, whether in Source or
+      Object form, made available under the License, as indicated by a
+      copyright notice that is included in or attached to the work
+      (an example is provided in the Appendix below).
+
+      "Derivative Works" shall mean any work, whether in Source or Object
+      form, that is based on (or derived from) the Work and for which the
+      editorial revisions, annotations, elaborations, or other modifications
+      represent, as a whole, an original work of authorship. For the purposes
+      of this License, Derivative Works shall not include works that remain
+      separable from, or merely link (or bind by name) to the interfaces of,
+      the Work and Derivative Works thereof.
+
+      "Contribution" shall mean any work of authorship, including
+      the original version of the Work and any modifications or additions
+      to that Work or Derivative Works thereof, that is intentionally
+      submitted to Licensor for inclusion in the Work by the copyright owner
+      or by an individual or Legal Entity authorized to submit on behalf of
+      the copyright owner. For the purposes of this definition, "submitted"
+      means any form of electronic, verbal, or written communication sent
+      to the Licensor or its representatives, including but not limited to
+      communication on electronic mailing lists, source code control systems,
+      and issue tracking systems that are managed by, or on behalf of, the
+      Licensor for the purpose of discussing and improving the Work, but
+      excluding communication that is conspicuously marked or otherwise
+      designated in writing by the copyright owner as "Not a Contribution."
+
+      "Contributor" shall mean Licensor and any individual or Legal Entity
+      on behalf of whom a Contribution has been received by Licensor and
+      subsequently incorporated within the Work.
+
+   2. Grant of Copyright License. Subject to the terms and conditions of
+      this License, each Contributor hereby grants to You a perpetual,
+      worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+      copyright license to reproduce, prepare Derivative Works of,
+      publicly display, publicly perform, sublicense, and distribute the
+      Work and such Derivative Works in Source or Object form.
+
+   3. Grant of Patent License. Subject to the terms and conditions of
+      this License, each Contributor hereby grants to You a perpetual,
+      worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+      (except as stated in this section) patent license to make, have made,
+      use, offer to sell, sell, import, and otherwise transfer the Work,
+      where such license applies only to those patent claims licensable
+      by such Contributor that are necessarily infringed by their
+      Contribution(s) alone or by combination of their Contribution(s)
+      with the Work to which such Contribution(s) was submitted. If You
+      institute patent litigation against any entity (including a
+      cross-claim or counterclaim in a lawsuit) alleging that the Work
+      or a Contribution incorporated within the Work constitutes direct
+      or contributory patent infringement, then any patent licenses
+      granted to You under this License for that Work shall terminate
+      as of the date such litigation is filed.
+
+   4. Redistribution. You may reproduce and distribute copies of the
+      Work or Derivative Works thereof in any medium, with or without
+      modifications, and in Source or Object form, provided that You
+      meet the following conditions:
+
+      (a) You must give any other recipients of the Work or
+          Derivative Works a copy of this License; and
+
+      (b) You must cause any modified files to carry prominent notices
+          stating that You changed the files; and
+
+      (c) You must retain, in the Source form of any Derivative Works
+          that You distribute, all copyright, patent, trademark, and
+          attribution notices from the Source form of the Work,
+          excluding those notices that do not pertain to any part of
+          the Derivative Works; and
+
+      (d) If the Work includes a "NOTICE" text file as part of its
+          distribution, then any Derivative Works that You distribute must
+          include a readable copy of the attribution notices contained
+          within such NOTICE file, excluding those notices that do not
+          pertain to any part of the Derivative Works, in at least one
+          of the following places: within a NOTICE text file distributed
+          as part of the Derivative Works; within the Source form or
+          documentation, if provided along with the Derivative Works; or,
+          within a display generated by the Derivative Works, if and
+          wherever such third-party notices normally appear. The contents
+          of the NOTICE file are for informational purposes only and
+          do not modify the License. You may add Your own attribution
+          notices within Derivative Works that You distribute, alongside
+          or as an addendum to the NOTICE text from the Work, provided
+          that such additional attribution notices cannot be construed
+          as modifying the License.
+
+      You may add Your own copyright statement to Your modifications and
+      may provide additional or different license terms and conditions
+      for use, reproduction, or distribution of Your modifications, or
+      for any such Derivative Works as a whole, provided Your use,
+      reproduction, and distribution of the Work otherwise complies with
+      the conditions stated in this License.
+
+   5. Submission of Contributions. Unless You explicitly state otherwise,
+      any Contribution intentionally submitted for inclusion in the Work
+      by You to the Licensor shall be under the terms and conditions of
+      this License, without any additional terms or conditions.
+      Notwithstanding the above, nothing herein shall supersede or modify
+      the terms of any separate license agreement you may have executed
+      with Licensor regarding such Contributions.
+
+   6. Trademarks. This License does not grant permission to use the trade
+      names, trademarks, service marks, or product names of the Licensor,
+      except as required for reasonable and customary use in describing the
+      origin of the Work and reproducing the content of the NOTICE file.
+
+   7. Disclaimer of Warranty. Unless required by applicable law or
+      agreed to in writing, Licensor provides the Work (and each
+      Contributor provides its Contributions) on an "AS IS" BASIS,
+      WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+      implied, including, without limitation, any warranties or conditions
+      of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
+      PARTICULAR PURPOSE. You are solely responsible for determining the
+      appropriateness of using or redistributing the Work and assume any
+      risks associated with Your exercise of permissions under this License.
+
+   8. Limitation of Liability. In no event and under no legal theory,
+      whether in tort (including negligence), contract, or otherwise,
+      unless required by applicable law (such as deliberate and grossly
+      negligent acts) or agreed to in writing, shall any Contributor be
+      liable to You for damages, including any direct, indirect, special,
+      incidental, or consequential damages of any character arising as a
+      result of this License or out of the use or inability to use the
+      Work (including but not limited to damages for loss of goodwill,
+      work stoppage, computer failure or malfunction, or any and all
+      other commercial damages or losses), even if such Contributor
+      has been advised of the possibility of such damages.
+
+   9. Accepting Warranty or Additional Liability. While redistributing
+      the Work or Derivative Works thereof, You may choose to offer,
+      and charge a fee for, acceptance of support, warranty, indemnity,
+      or other liability obligations and/or rights consistent with this
+      License. However, in accepting such obligations, You may act only
+      on Your own behalf and on Your sole responsibility, not on behalf
+      of any other Contributor, and only if You agree to indemnify,
+      defend, and hold each Contributor harmless for any liability
+      incurred by, or claims asserted against, such Contributor by reason
+      of your accepting any such warranty or additional liability.
+
+   END OF TERMS AND CONDITIONS
+
+   APPENDIX: How to apply the Apache License to your work.
+
+      To apply the Apache License to your work, attach the following
+      boilerplate notice, with the fields enclosed by brackets "[]"
+      replaced with your own identifying information. (Don't include
+      the brackets!)  The text should be enclosed in the appropriate
+      comment syntax for the file format. We also recommend that a
+      file or class name and description of purpose be included on the
+      same "printed page" as the copyright notice for easier
+      identification within third-party archives.
+
+   Copyright [yyyy] [name of copyright owner]
+
+   Licensed under the Apache License, Version 2.0 (the "License");
+   you may not use this file except in compliance with the License.
+   You may obtain a copy of the License at
+
+       http://www.apache.org/licenses/LICENSE-2.0
+
+   Unless required by applicable law or agreed to in writing, software
+   distributed under the License is distributed on an "AS IS" BASIS,
+   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+   See the License for the specific language governing permissions and
+   limitations under the License.
--- a/out/scripts/prettify/lang-css.js
+++ b/out/scripts/prettify/lang-css.js
@ -0,0 +1,2 @@
+PR.registerLangHandler(PR.createSimpleLexer([["pln",/^[\t\n\f\r ]+/,null," \t\r\n"]],[["str",/^"(?:[^\n\f\r"\\]|\\(?:\r\n?|\n|\f)|\\[\S\s])*"/,null],["str",/^'(?:[^\n\f\r'\\]|\\(?:\r\n?|\n|\f)|\\[\S\s])*'/,null],["lang-css-str",/^url\(([^"')]*)\)/i],["kwd",/^(?:url|rgb|!important|@import|@page|@media|@charset|inherit)(?=[^\w-]|$)/i,null],["lang-css-kw",/^(-?(?:[_a-z]|\\[\da-f]+ ?)(?:[\w-]|\\\\[\da-f]+ ?)*)\s*:/i],["com",/^\/\*[^*]*\*+(?:[^*/][^*]*\*+)*\//],["com",
+/^(?:<\!--|--\>)/],["lit",/^(?:\d+|\d*\.\d+)(?:%|[a-z]+)?/i],["lit",/^#[\da-f]{3,6}/i],["pln",/^-?(?:[_a-z]|\\[\da-f]+ ?)(?:[\w-]|\\\\[\da-f]+ ?)*/i],["pun",/^[^\s\w"']+/]]),["css"]);PR.registerLangHandler(PR.createSimpleLexer([],[["kwd",/^-?(?:[_a-z]|\\[\da-f]+ ?)(?:[\w-]|\\\\[\da-f]+ ?)*/i]]),["css-kw"]);PR.registerLangHandler(PR.createSimpleLexer([],[["str",/^[^"')]+/]]),["css-str"]);
--- a/out/scripts/prettify/prettify.js
+++ b/out/scripts/prettify/prettify.js
@ -0,0 +1,28 @@
+var q=null;window.PR_SHOULD_USE_CONTINUATION=!0;
+(function(){function L(a){function m(a){var f=a.charCodeAt(0);if(f!==92)return f;var b=a.charAt(1);return(f=r[b])?f:"0"<=b&&b<="7"?parseInt(a.substring(1),8):b==="u"||b==="x"?parseInt(a.substring(2),16):a.charCodeAt(1)}function e(a){if(a<32)return(a<16?"\\x0":"\\x")+a.toString(16);a=String.fromCharCode(a);if(a==="\\"||a==="-"||a==="["||a==="]")a="\\"+a;return a}function h(a){for(var f=a.substring(1,a.length-1).match(/\\u[\dA-Fa-f]{4}|\\x[\dA-Fa-f]{2}|\\[0-3][0-7]{0,2}|\\[0-7]{1,2}|\\[\S\s]|[^\\]/g),a=
+[],b=[],o=f[0]==="^",c=o?1:0,i=f.length;c<i;++c){var j=f[c];if(/\\[bdsw]/i.test(j))a.push(j);else{var j=m(j),d;c+2<i&&"-"===f[c+1]?(d=m(f[c+2]),c+=2):d=j;b.push([j,d]);d<65||j>122||(d<65||j>90||b.push([Math.max(65,j)|32,Math.min(d,90)|32]),d<97||j>122||b.push([Math.max(97,j)&-33,Math.min(d,122)&-33]))}}b.sort(function(a,f){return a[0]-f[0]||f[1]-a[1]});f=[];j=[NaN,NaN];for(c=0;c<b.length;++c)i=b[c],i[0]<=j[1]+1?j[1]=Math.max(j[1],i[1]):f.push(j=i);b=["["];o&&b.push("^");b.push.apply(b,a);for(c=0;c<
+f.length;++c)i=f[c],b.push(e(i[0])),i[1]>i[0]&&(i[1]+1>i[0]&&b.push("-"),b.push(e(i[1])));b.push("]");return b.join("")}function y(a){for(var f=a.source.match(/\[(?:[^\\\]]|\\[\S\s])*]|\\u[\dA-Fa-f]{4}|\\x[\dA-Fa-f]{2}|\\\d+|\\[^\dux]|\(\?[!:=]|[()^]|[^()[\\^]+/g),b=f.length,d=[],c=0,i=0;c<b;++c){var j=f[c];j==="("?++i:"\\"===j.charAt(0)&&(j=+j.substring(1))&&j<=i&&(d[j]=-1)}for(c=1;c<d.length;++c)-1===d[c]&&(d[c]=++t);for(i=c=0;c<b;++c)j=f[c],j==="("?(++i,d[i]===void 0&&(f[c]="(?:")):"\\"===j.charAt(0)&&
+(j=+j.substring(1))&&j<=i&&(f[c]="\\"+d[i]);for(i=c=0;c<b;++c)"^"===f[c]&&"^"!==f[c+1]&&(f[c]="");if(a.ignoreCase&&s)for(c=0;c<b;++c)j=f[c],a=j.charAt(0),j.length>=2&&a==="["?f[c]=h(j):a!=="\\"&&(f[c]=j.replace(/[A-Za-z]/g,function(a){a=a.charCodeAt(0);return"["+String.fromCharCode(a&-33,a|32)+"]"}));return f.join("")}for(var t=0,s=!1,l=!1,p=0,d=a.length;p<d;++p){var g=a[p];if(g.ignoreCase)l=!0;else if(/[a-z]/i.test(g.source.replace(/\\u[\da-f]{4}|\\x[\da-f]{2}|\\[^UXux]/gi,""))){s=!0;l=!1;break}}for(var r=
+{b:8,t:9,n:10,v:11,f:12,r:13},n=[],p=0,d=a.length;p<d;++p){g=a[p];if(g.global||g.multiline)throw Error(""+g);n.push("(?:"+y(g)+")")}return RegExp(n.join("|"),l?"gi":"g")}function M(a){function m(a){switch(a.nodeType){case 1:if(e.test(a.className))break;for(var g=a.firstChild;g;g=g.nextSibling)m(g);g=a.nodeName;if("BR"===g||"LI"===g)h[s]="\n",t[s<<1]=y++,t[s++<<1|1]=a;break;case 3:case 4:g=a.nodeValue,g.length&&(g=p?g.replace(/\r\n?/g,"\n"):g.replace(/[\t\n\r ]+/g," "),h[s]=g,t[s<<1]=y,y+=g.length,
+t[s++<<1|1]=a)}}var e=/(?:^|\s)nocode(?:\s|$)/,h=[],y=0,t=[],s=0,l;a.currentStyle?l=a.currentStyle.whiteSpace:window.getComputedStyle&&(l=document.defaultView.getComputedStyle(a,q).getPropertyValue("white-space"));var p=l&&"pre"===l.substring(0,3);m(a);return{a:h.join("").replace(/\n$/,""),c:t}}function B(a,m,e,h){m&&(a={a:m,d:a},e(a),h.push.apply(h,a.e))}function x(a,m){function e(a){for(var l=a.d,p=[l,"pln"],d=0,g=a.a.match(y)||[],r={},n=0,z=g.length;n<z;++n){var f=g[n],b=r[f],o=void 0,c;if(typeof b===
+"string")c=!1;else{var i=h[f.charAt(0)];if(i)o=f.match(i[1]),b=i[0];else{for(c=0;c<t;++c)if(i=m[c],o=f.match(i[1])){b=i[0];break}o||(b="pln")}if((c=b.length>=5&&"lang-"===b.substring(0,5))&&!(o&&typeof o[1]==="string"))c=!1,b="src";c||(r[f]=b)}i=d;d+=f.length;if(c){c=o[1];var j=f.indexOf(c),k=j+c.length;o[2]&&(k=f.length-o[2].length,j=k-c.length);b=b.substring(5);B(l+i,f.substring(0,j),e,p);B(l+i+j,c,C(b,c),p);B(l+i+k,f.substring(k),e,p)}else p.push(l+i,b)}a.e=p}var h={},y;(function(){for(var e=a.concat(m),
+l=[],p={},d=0,g=e.length;d<g;++d){var r=e[d],n=r[3];if(n)for(var k=n.length;--k>=0;)h[n.charAt(k)]=r;r=r[1];n=""+r;p.hasOwnProperty(n)||(l.push(r),p[n]=q)}l.push(/[\S\s]/);y=L(l)})();var t=m.length;return e}function u(a){var m=[],e=[];a.tripleQuotedStrings?m.push(["str",/^(?:'''(?:[^'\\]|\\[\S\s]|''?(?=[^']))*(?:'''|$)|"""(?:[^"\\]|\\[\S\s]|""?(?=[^"]))*(?:"""|$)|'(?:[^'\\]|\\[\S\s])*(?:'|$)|"(?:[^"\\]|\\[\S\s])*(?:"|$))/,q,"'\""]):a.multiLineStrings?m.push(["str",/^(?:'(?:[^'\\]|\\[\S\s])*(?:'|$)|"(?:[^"\\]|\\[\S\s])*(?:"|$)|`(?:[^\\`]|\\[\S\s])*(?:`|$))/,
+q,"'\"`"]):m.push(["str",/^(?:'(?:[^\n\r'\\]|\\.)*(?:'|$)|"(?:[^\n\r"\\]|\\.)*(?:"|$))/,q,"\"'"]);a.verbatimStrings&&e.push(["str",/^@"(?:[^"]|"")*(?:"|$)/,q]);var h=a.hashComments;h&&(a.cStyleComments?(h>1?m.push(["com",/^#(?:##(?:[^#]|#(?!##))*(?:###|$)|.*)/,q,"#"]):m.push(["com",/^#(?:(?:define|elif|else|endif|error|ifdef|include|ifndef|line|pragma|undef|warning)\b|[^\n\r]*)/,q,"#"]),e.push(["str",/^<(?:(?:(?:\.\.\/)*|\/?)(?:[\w-]+(?:\/[\w-]+)+)?[\w-]+\.h|[a-z]\w*)>/,q])):m.push(["com",/^#[^\n\r]*/,
+q,"#"]));a.cStyleComments&&(e.push(["com",/^\/\/[^\n\r]*/,q]),e.push(["com",/^\/\*[\S\s]*?(?:\*\/|$)/,q]));a.regexLiterals&&e.push(["lang-regex",/^(?:^^\.?|[!+-]|!=|!==|#|%|%=|&|&&|&&=|&=|\(|\*|\*=|\+=|,|-=|->|\/|\/=|:|::|;|<|<<|<<=|<=|=|==|===|>|>=|>>|>>=|>>>|>>>=|[?@[^]|\^=|\^\^|\^\^=|{|\||\|=|\|\||\|\|=|~|break|case|continue|delete|do|else|finally|instanceof|return|throw|try|typeof)\s*(\/(?=[^*/])(?:[^/[\\]|\\[\S\s]|\[(?:[^\\\]]|\\[\S\s])*(?:]|$))+\/)/]);(h=a.types)&&e.push(["typ",h]);a=(""+a.keywords).replace(/^ | $/g,
+"");a.length&&e.push(["kwd",RegExp("^(?:"+a.replace(/[\s,]+/g,"|")+")\\b"),q]);m.push(["pln",/^\s+/,q," \r\n\t\xa0"]);e.push(["lit",/^@[$_a-z][\w$@]*/i,q],["typ",/^(?:[@_]?[A-Z]+[a-z][\w$@]*|\w+_t\b)/,q],["pln",/^[$_a-z][\w$@]*/i,q],["lit",/^(?:0x[\da-f]+|(?:\d(?:_\d+)*\d*(?:\.\d*)?|\.\d\+)(?:e[+-]?\d+)?)[a-z]*/i,q,"0123456789"],["pln",/^\\[\S\s]?/,q],["pun",/^.[^\s\w"-$'./@\\`]*/,q]);return x(m,e)}function D(a,m){function e(a){switch(a.nodeType){case 1:if(k.test(a.className))break;if("BR"===a.nodeName)h(a),
+a.parentNode&&a.parentNode.removeChild(a);else for(a=a.firstChild;a;a=a.nextSibling)e(a);break;case 3:case 4:if(p){var b=a.nodeValue,d=b.match(t);if(d){var c=b.substring(0,d.index);a.nodeValue=c;(b=b.substring(d.index+d[0].length))&&a.parentNode.insertBefore(s.createTextNode(b),a.nextSibling);h(a);c||a.parentNode.removeChild(a)}}}}function h(a){function b(a,d){var e=d?a.cloneNode(!1):a,f=a.parentNode;if(f){var f=b(f,1),g=a.nextSibling;f.appendChild(e);for(var h=g;h;h=g)g=h.nextSibling,f.appendChild(h)}return e}
+for(;!a.nextSibling;)if(a=a.parentNode,!a)return;for(var a=b(a.nextSibling,0),e;(e=a.parentNode)&&e.nodeType===1;)a=e;d.push(a)}var k=/(?:^|\s)nocode(?:\s|$)/,t=/\r\n?|\n/,s=a.ownerDocument,l;a.currentStyle?l=a.currentStyle.whiteSpace:window.getComputedStyle&&(l=s.defaultView.getComputedStyle(a,q).getPropertyValue("white-space"));var p=l&&"pre"===l.substring(0,3);for(l=s.createElement("LI");a.firstChild;)l.appendChild(a.firstChild);for(var d=[l],g=0;g<d.length;++g)e(d[g]);m===(m|0)&&d[0].setAttribute("value",
+m);var r=s.createElement("OL");r.className="linenums";for(var n=Math.max(0,m-1|0)||0,g=0,z=d.length;g<z;++g)l=d[g],l.className="L"+(g+n)%10,l.firstChild||l.appendChild(s.createTextNode("\xa0")),r.appendChild(l);a.appendChild(r)}function k(a,m){for(var e=m.length;--e>=0;){var h=m[e];A.hasOwnProperty(h)?window.console&&console.warn("cannot override language handler %s",h):A[h]=a}}function C(a,m){if(!a||!A.hasOwnProperty(a))a=/^\s*</.test(m)?"default-markup":"default-code";return A[a]}function E(a){var m=
+a.g;try{var e=M(a.h),h=e.a;a.a=h;a.c=e.c;a.d=0;C(m,h)(a);var k=/\bMSIE\b/.test(navigator.userAgent),m=/\n/g,t=a.a,s=t.length,e=0,l=a.c,p=l.length,h=0,d=a.e,g=d.length,a=0;d[g]=s;var r,n;for(n=r=0;n<g;)d[n]!==d[n+2]?(d[r++]=d[n++],d[r++]=d[n++]):n+=2;g=r;for(n=r=0;n<g;){for(var z=d[n],f=d[n+1],b=n+2;b+2<=g&&d[b+1]===f;)b+=2;d[r++]=z;d[r++]=f;n=b}for(d.length=r;h<p;){var o=l[h+2]||s,c=d[a+2]||s,b=Math.min(o,c),i=l[h+1],j;if(i.nodeType!==1&&(j=t.substring(e,b))){k&&(j=j.replace(m,"\r"));i.nodeValue=
+j;var u=i.ownerDocument,v=u.createElement("SPAN");v.className=d[a+1];var x=i.parentNode;x.replaceChild(v,i);v.appendChild(i);e<o&&(l[h+1]=i=u.createTextNode(t.substring(b,o)),x.insertBefore(i,v.nextSibling))}e=b;e>=o&&(h+=2);e>=c&&(a+=2)}}catch(w){"console"in window&&console.log(w&&w.stack?w.stack:w)}}var v=["break,continue,do,else,for,if,return,while"],w=[[v,"auto,case,char,const,default,double,enum,extern,float,goto,int,long,register,short,signed,sizeof,static,struct,switch,typedef,union,unsigned,void,volatile"],
+"catch,class,delete,false,import,new,operator,private,protected,public,this,throw,true,try,typeof"],F=[w,"alignof,align_union,asm,axiom,bool,concept,concept_map,const_cast,constexpr,decltype,dynamic_cast,explicit,export,friend,inline,late_check,mutable,namespace,nullptr,reinterpret_cast,static_assert,static_cast,template,typeid,typename,using,virtual,where"],G=[w,"abstract,boolean,byte,extends,final,finally,implements,import,instanceof,null,native,package,strictfp,super,synchronized,throws,transient"],
+H=[G,"as,base,by,checked,decimal,delegate,descending,dynamic,event,fixed,foreach,from,group,implicit,in,interface,internal,into,is,lock,object,out,override,orderby,params,partial,readonly,ref,sbyte,sealed,stackalloc,string,select,uint,ulong,unchecked,unsafe,ushort,var"],w=[w,"debugger,eval,export,function,get,null,set,undefined,var,with,Infinity,NaN"],I=[v,"and,as,assert,class,def,del,elif,except,exec,finally,from,global,import,in,is,lambda,nonlocal,not,or,pass,print,raise,try,with,yield,False,True,None"],
+J=[v,"alias,and,begin,case,class,def,defined,elsif,end,ensure,false,in,module,next,nil,not,or,redo,rescue,retry,self,super,then,true,undef,unless,until,when,yield,BEGIN,END"],v=[v,"case,done,elif,esac,eval,fi,function,in,local,set,then,until"],K=/^(DIR|FILE|vector|(de|priority_)?queue|list|stack|(const_)?iterator|(multi)?(set|map)|bitset|u?(int|float)\d*)/,N=/\S/,O=u({keywords:[F,H,w,"caller,delete,die,do,dump,elsif,eval,exit,foreach,for,goto,if,import,last,local,my,next,no,our,print,package,redo,require,sub,undef,unless,until,use,wantarray,while,BEGIN,END"+
+I,J,v],hashComments:!0,cStyleComments:!0,multiLineStrings:!0,regexLiterals:!0}),A={};k(O,["default-code"]);k(x([],[["pln",/^[^<?]+/],["dec",/^<!\w[^>]*(?:>|$)/],["com",/^<\!--[\S\s]*?(?:--\>|$)/],["lang-",/^<\?([\S\s]+?)(?:\?>|$)/],["lang-",/^<%([\S\s]+?)(?:%>|$)/],["pun",/^(?:<[%?]|[%?]>)/],["lang-",/^<xmp\b[^>]*>([\S\s]+?)<\/xmp\b[^>]*>/i],["lang-js",/^<script\b[^>]*>([\S\s]*?)(<\/script\b[^>]*>)/i],["lang-css",/^<style\b[^>]*>([\S\s]*?)(<\/style\b[^>]*>)/i],["lang-in.tag",/^(<\/?[a-z][^<>]*>)/i]]),
+["default-markup","htm","html","mxml","xhtml","xml","xsl"]);k(x([["pln",/^\s+/,q," \t\r\n"],["atv",/^(?:"[^"]*"?|'[^']*'?)/,q,"\"'"]],[["tag",/^^<\/?[a-z](?:[\w-.:]*\w)?|\/?>$/i],["atn",/^(?!style[\s=]|on)[a-z](?:[\w:-]*\w)?/i],["lang-uq.val",/^=\s*([^\s"'>]*(?:[^\s"'/>]|\/(?=\s)))/],["pun",/^[/<->]+/],["lang-js",/^on\w+\s*=\s*"([^"]+)"/i],["lang-js",/^on\w+\s*=\s*'([^']+)'/i],["lang-js",/^on\w+\s*=\s*([^\s"'>]+)/i],["lang-css",/^style\s*=\s*"([^"]+)"/i],["lang-css",/^style\s*=\s*'([^']+)'/i],["lang-css",
+/^style\s*=\s*([^\s"'>]+)/i]]),["in.tag"]);k(x([],[["atv",/^[\S\s]+/]]),["uq.val"]);k(u({keywords:F,hashComments:!0,cStyleComments:!0,types:K}),["c","cc","cpp","cxx","cyc","m"]);k(u({keywords:"null,true,false"}),["json"]);k(u({keywords:H,hashComments:!0,cStyleComments:!0,verbatimStrings:!0,types:K}),["cs"]);k(u({keywords:G,cStyleComments:!0}),["java"]);k(u({keywords:v,hashComments:!0,multiLineStrings:!0}),["bsh","csh","sh"]);k(u({keywords:I,hashComments:!0,multiLineStrings:!0,tripleQuotedStrings:!0}),
+["cv","py"]);k(u({keywords:"caller,delete,die,do,dump,elsif,eval,exit,foreach,for,goto,if,import,last,local,my,next,no,our,print,package,redo,require,sub,undef,unless,until,use,wantarray,while,BEGIN,END",hashComments:!0,multiLineStrings:!0,regexLiterals:!0}),["perl","pl","pm"]);k(u({keywords:J,hashComments:!0,multiLineStrings:!0,regexLiterals:!0}),["rb"]);k(u({keywords:w,cStyleComments:!0,regexLiterals:!0}),["js"]);k(u({keywords:"all,and,by,catch,class,else,extends,false,finally,for,if,in,is,isnt,loop,new,no,not,null,of,off,on,or,return,super,then,true,try,unless,until,when,while,yes",
+hashComments:3,cStyleComments:!0,multilineStrings:!0,tripleQuotedStrings:!0,regexLiterals:!0}),["coffee"]);k(x([],[["str",/^[\S\s]+/]]),["regex"]);window.prettyPrintOne=function(a,m,e){var h=document.createElement("PRE");h.innerHTML=a;e&&D(h,e);E({g:m,i:e,h:h});return h.innerHTML};window.prettyPrint=function(a){function m(){for(var e=window.PR_SHOULD_USE_CONTINUATION?l.now()+250:Infinity;p<h.length&&l.now()<e;p++){var n=h[p],k=n.className;if(k.indexOf("prettyprint")>=0){var k=k.match(g),f,b;if(b=
+!k){b=n;for(var o=void 0,c=b.firstChild;c;c=c.nextSibling)var i=c.nodeType,o=i===1?o?b:c:i===3?N.test(c.nodeValue)?b:o:o;b=(f=o===b?void 0:o)&&"CODE"===f.tagName}b&&(k=f.className.match(g));k&&(k=k[1]);b=!1;for(o=n.parentNode;o;o=o.parentNode)if((o.tagName==="pre"||o.tagName==="code"||o.tagName==="xmp")&&o.className&&o.className.indexOf("prettyprint")>=0){b=!0;break}b||((b=(b=n.className.match(/\blinenums\b(?::(\d+))?/))?b[1]&&b[1].length?+b[1]:!0:!1)&&D(n,b),d={g:k,h:n,i:b},E(d))}}p<h.length?setTimeout(m,
+250):a&&a()}for(var e=[document.getElementsByTagName("pre"),document.getElementsByTagName("code"),document.getElementsByTagName("xmp")],h=[],k=0;k<e.length;++k)for(var t=0,s=e[k].length;t<s;++t)h.push(e[k][t]);var e=q,l=Date;l.now||(l={now:function(){return+new Date}});var p=0,d,g=/\blang(?:uage)?-([\w.]+)(?!\S)/;m()};window.PR={createSimpleLexer:x,registerLangHandler:k,sourceDecorator:u,PR_ATTRIB_NAME:"atn",PR_ATTRIB_VALUE:"atv",PR_COMMENT:"com",PR_DECLARATION:"dec",PR_KEYWORD:"kwd",PR_LITERAL:"lit",
+PR_NOCODE:"nocode",PR_PLAIN:"pln",PR_PUNCTUATION:"pun",PR_SOURCE:"src",PR_STRING:"str",PR_TAG:"tag",PR_TYPE:"typ"}})();
--- a/out/status.js.html
+++ b/out/status.js.html
@ -0,0 +1,180 @@
+<!DOCTYPE html>
+<html lang="en">
+<head>
+    <meta charset="utf-8">
+    <title>JSDoc: Source: status.js</title>
+
+    <script src="scripts/prettify/prettify.js"> </script>
+    <script src="scripts/prettify/lang-css.js"> </script>
+    <!--[if lt IE 9]>
+      <script src="//html5shiv.googlecode.com/svn/trunk/html5.js"></script>
+    <![endif]-->
+    <link type="text/css" rel="stylesheet" href="styles/prettify-tomorrow.css">
+    <link type="text/css" rel="stylesheet" href="styles/jsdoc-default.css">
+</head>
+
+<body>
+
+<div id="main">
+
+    <h1 class="page-title">Source: status.js</h1>
+
+    
+
+
+
+    
+    <section>
+        <article>
+            <pre class="prettyprint source linenums"><code>/** Redux Wrapper to hold the state and communicate with the Server
+ * @module State
+ */
+
+const redux = require('redux');
+const logger = require('./logger');
+
+///////////////////////////////////////////////////////////////////////////////
+//                                Declarations                               //
+///////////////////////////////////////////////////////////////////////////////
+
+// Object oriented `this`.
+let self = false;
+
+/**
+ * Inital State for the app.
+ * @property { Object } stream Stream Status.
+ * @property { bool } stream.running Indicates wether the stream is running.
+ * @property { number } stream.error Error code. Any number outside the range of the Error array in @see ffmpeg-command.js will be treated as non error. Most conveniently set: -1.
+ * @property { bool } stream.reconnecting Indicates wether the program tries to reconnect to the camera or the internet.
+ * @property { Object } config Configuration of the camera.
+ */
+let initialState = {
+    stream: {
+	running: false,
+	error: -1,
+	reconnecting: false
+    },
+    config: {}
+}; // NOTE: Maybe in main.js
+
+// The socket.io connection from the main-module.
+let _communicator;
+
+// Actions
+const actions = require('./actions');
+
+// Action Creators
+const creators = require('./actionCreators');
+const dispatchers = redux.bindActionCreators(creators);
+
+// Reducer
+const reducer = require('./reducers');
+
+// Reference to the store of the application state.
+const store = redux.createStore(reducer, initialState);
+
+///////////////////////////////////////////////////////////////////////////////
+//                                    Code                                   //
+///////////////////////////////////////////////////////////////////////////////
+
+// TODO: Log state changes.
+
+/**
+ * The central redux state manager. The module exposes central action dispatchers. Updates to the state get communicated to the server.
+ *
+ * @constructor 
+ * @member [Action Dispatchers] The action creators (@see actionCreators.js) are bound to the dispatch function and made member of the State object.
+ * @param { Object } communicator A communicator object. @see communicator.js - Optional //TODO: Find proper tag.
+ */
+function State(communicator = false) {
+    // singleton
+    if (self)
+        return self;
+
+    // Make `new` optional.
+    if (!(this instanceof State))
+        return new State(_communicator);
+
+    _communicator = communicator;
+    
+    self = this;
+    return this;
+};
+
+applyDispatchers(creators);
+
+/**
+ * Set the communicator object and enable the state sync with the server.
+ * @param {Object} communicator A communicator object. @see communicator.js
+ */
+State.prototype.setCommunicator = function(communicator) {
+    if (_communicator)
+        _communicator = communicator;
+    else
+        logger.dbgmsdg("Invalid Communicator");
+};
+
+/**
+ * Wrapper for redux.
+ * @returns { Object } The current state.
+ */
+State.prototype.getState = function(){
+    return store.getState();
+};
+
+/**
+ * Get the current config.
+ * @returns { * } The current config.
+ */
+State.prototype.getConfig = function(){
+    return store.getState().config;
+};
+
+/**
+ * Utilities
+ */
+
+/**
+ * Adds prototypes for the action dispatchers to the State. 
+ * @param { Object } creators
+ * @throws { Error } If a method with the creators name already exists. @see actionCreators.js
+ */
+function applyDispatchers( creators ){
+    for(let creator in creators){
+	if(State.prototype[creator])
+	    throw new Error(`State has already a meber '${creator}'.`);
+	
+	State.prototype[creator] = function(){
+	    store.dispatch(creators[creator].apply(undefined, arguments));
+	};
+    }
+}
+
+
+module.exports = State;
+
+
+
+</code></pre>
+        </article>
+    </section>
+
+
+
+
+</div>
+
+<nav>
+    <h2><a href="index.html">Home</a></h2><h3>Modules</h3><ul><li><a href="module-State.html">State</a></li></ul>
+</nav>
+
+<br class="clear">
+
+<footer>
+    Documentation generated by <a href="https://github.com/jsdoc3/jsdoc">JSDoc 3.4.3</a> on Sat Apr 22 2017 12:09:23 GMT+1200 (NZST)
+</footer>
+
+<script> prettyPrint(); </script>
+<script src="scripts/linenumber.js"> </script>
+</body>
+</html>
--- a/out/styles/jsdoc-default.css
+++ b/out/styles/jsdoc-default.css
@ -0,0 +1,354 @@
+@font-face {
+    font-family: 'Open Sans';
+    font-weight: normal;
+    font-style: normal;
+    src: url('../fonts/OpenSans-Regular-webfont.eot');
+    src:
+        local('Open Sans'),
+        local('OpenSans'),
+        url('../fonts/OpenSans-Regular-webfont.eot?#iefix') format('embedded-opentype'),
+        url('../fonts/OpenSans-Regular-webfont.woff') format('woff'),
+        url('../fonts/OpenSans-Regular-webfont.svg#open_sansregular') format('svg');
+}
+
+@font-face {
+    font-family: 'Open Sans Light';
+    font-weight: normal;
+    font-style: normal;
+    src: url('../fonts/OpenSans-Light-webfont.eot');
+    src:
+        local('Open Sans Light'),
+        local('OpenSans Light'),
+        url('../fonts/OpenSans-Light-webfont.eot?#iefix') format('embedded-opentype'),
+        url('../fonts/OpenSans-Light-webfont.woff') format('woff'),
+        url('../fonts/OpenSans-Light-webfont.svg#open_sanslight') format('svg');
+}
+
+html
+{
+    overflow: auto;
+    background-color: #fff;
+    font-size: 14px;
+}
+
+body
+{
+    font-family: 'Open Sans', sans-serif;
+    line-height: 1.5;
+    color: #4d4e53;
+    background-color: white;
+}
+
+a, a:visited, a:active {
+    color: #0095dd;
+    text-decoration: none;
+}
+
+a:hover {
+    text-decoration: underline;
+}
+
+header
+{
+    display: block;
+    padding: 0px 4px;
+}
+
+tt, code, kbd, samp {
+    font-family: Consolas, Monaco, 'Andale Mono', monospace;
+}
+
+.class-description {
+    font-size: 130%;
+    line-height: 140%;
+    margin-bottom: 1em;
+    margin-top: 1em;
+}
+
+.class-description:empty {
+    margin: 0;
+}
+
+#main {
+    float: left;
+    width: 70%;
+}
+
+article dl {
+    margin-bottom: 40px;
+}
+
+section
+{
+    display: block;
+    background-color: #fff;
+    padding: 12px 24px;
+    border-bottom: 1px solid #ccc;
+    margin-right: 30px;
+}
+
+.variation {
+    display: none;
+}
+
+.signature-attributes {
+    font-size: 60%;
+    color: #aaa;
+    font-style: italic;
+    font-weight: lighter;
+}
+
+nav
+{
+    display: block;
+    float: right;
+    margin-top: 28px;
+    width: 30%;
+    box-sizing: border-box;
+    border-left: 1px solid #ccc;
+    padding-left: 16px;
+}
+
+nav ul {
+    font-family: 'Lucida Grande', 'Lucida Sans Unicode', arial, sans-serif;
+    font-size: 100%;
+    line-height: 17px;
+    padding: 0;
+    margin: 0;
+    list-style-type: none;
+}
+
+nav ul a, nav ul a:visited, nav ul a:active {
+    font-family: Consolas, Monaco, 'Andale Mono', monospace;
+    line-height: 18px;
+    color: #4D4E53;
+}
+
+nav h3 {
+    margin-top: 12px;
+}
+
+nav li {
+    margin-top: 6px;
+}
+
+footer {
+    display: block;
+    padding: 6px;
+    margin-top: 12px;
+    font-style: italic;
+    font-size: 90%;
+}
+
+h1, h2, h3, h4 {
+    font-weight: 200;
+    margin: 0;
+}
+
+h1
+{
+    font-family: 'Open Sans Light', sans-serif;
+    font-size: 48px;
+    letter-spacing: -2px;
+    margin: 12px 24px 20px;
+}
+
+h2, h3.subsection-title
+{
+    font-size: 30px;
+    font-weight: 700;
+    letter-spacing: -1px;
+    margin-bottom: 12px;
+}
+
+h3
+{
+    font-size: 24px;
+    letter-spacing: -0.5px;
+    margin-bottom: 12px;
+}
+
+h4
+{
+    font-size: 18px;
+    letter-spacing: -0.33px;
+    margin-bottom: 12px;
+    color: #4d4e53;
+}
+
+h5, .container-overview .subsection-title
+{
+    font-size: 120%;
+    font-weight: bold;
+    letter-spacing: -0.01em;
+    margin: 8px 0 3px 0;
+}
+
+h6
+{
+    font-size: 100%;
+    letter-spacing: -0.01em;
+    margin: 6px 0 3px 0;
+    font-style: italic;
+}
+
+table
+{
+    border-spacing: 0;
+    border: 0;
+    border-collapse: collapse;
+}
+
+td, th
+{
+    border: 1px solid #ddd;
+    margin: 0px;
+    text-align: left;
+    vertical-align: top;
+    padding: 4px 6px;
+    display: table-cell;
+}
+
+thead tr
+{
+    background-color: #ddd;
+    font-weight: bold;
+}
+
+th { border-right: 1px solid #aaa; }
+tr > th:last-child { border-right: 1px solid #ddd; }
+
+.ancestors { color: #999; }
+.ancestors a
+{
+    color: #999 !important;
+    text-decoration: none;
+}
+
+.clear
+{
+    clear: both;
+}
+
+.important
+{
+    font-weight: bold;
+    color: #950B02;
+}
+
+.yes-def {
+    text-indent: -1000px;
+}
+
+.type-signature {
+    color: #aaa;
+}
+
+.name, .signature {
+    font-family: Consolas, Monaco, 'Andale Mono', monospace;
+}
+
+.details { margin-top: 14px; border-left: 2px solid #DDD; }
+.details dt { width: 120px; float: left; padding-left: 10px;  padding-top: 6px; }
+.details dd { margin-left: 70px; }
+.details ul { margin: 0; }
+.details ul { list-style-type: none; }
+.details li { margin-left: 30px; padding-top: 6px; }
+.details pre.prettyprint { margin: 0 }
+.details .object-value { padding-top: 0; }
+
+.description {
+    margin-bottom: 1em;
+    margin-top: 1em;
+}
+
+.code-caption
+{
+    font-style: italic;
+    font-size: 107%;
+    margin: 0;
+}
+
+.prettyprint
+{
+    border: 1px solid #ddd;
+    width: 80%;
+    overflow: auto;
+}
+
+.prettyprint.source {
+    width: inherit;
+}
+
+.prettyprint code
+{
+    font-size: 100%;
+    line-height: 18px;
+    display: block;
+    padding: 4px 12px;
+    margin: 0;
+    background-color: #fff;
+    color: #4D4E53;
+}
+
+.prettyprint code span.line
+{
+  display: inline-block;
+}
+
+.prettyprint.linenums
+{
+  padding-left: 70px;
+  -webkit-user-select: none;
+  -moz-user-select: none;
+  -ms-user-select: none;
+  user-select: none;
+}
+
+.prettyprint.linenums ol
+{
+  padding-left: 0;
+}
+
+.prettyprint.linenums li
+{
+  border-left: 3px #ddd solid;
+}
+
+.prettyprint.linenums li.selected,
+.prettyprint.linenums li.selected *
+{
+  background-color: lightyellow;
+}
+
+.prettyprint.linenums li *
+{
+  -webkit-user-select: text;
+  -moz-user-select: text;
+  -ms-user-select: text;
+  user-select: text;
+}
+
+.params .name, .props .name, .name code {
+    color: #4D4E53;
+    font-family: Consolas, Monaco, 'Andale Mono', monospace;
+    font-size: 100%;
+}
+
+.params td.description > p:first-child,
+.props td.description > p:first-child
+{
+    margin-top: 0;
+    padding-top: 0;
+}
+
+.params td.description > p:last-child,
+.props td.description > p:last-child
+{
+    margin-bottom: 0;
+    padding-bottom: 0;
+}
+
+.disabled {
+    color: #454545;
+}
--- a/out/styles/prettify-jsdoc.css
+++ b/out/styles/prettify-jsdoc.css
@ -0,0 +1,111 @@
+/* JSDoc prettify.js theme */
+
+/* plain text */
+.pln {
+  color: #000000;
+  font-weight: normal;
+  font-style: normal;
+}
+
+/* string content */
+.str {
+  color: #006400;
+  font-weight: normal;
+  font-style: normal;
+}
+
+/* a keyword */
+.kwd {
+  color: #000000;
+  font-weight: bold;
+  font-style: normal;
+}
+
+/* a comment */
+.com {
+  font-weight: normal;
+  font-style: italic;
+}
+
+/* a type name */
+.typ {
+  color: #000000;
+  font-weight: normal;
+  font-style: normal;
+}
+
+/* a literal value */
+.lit {
+  color: #006400;
+  font-weight: normal;
+  font-style: normal;
+}
+
+/* punctuation */
+.pun {
+  color: #000000;
+  font-weight: bold;
+  font-style: normal;
+}
+
+/* lisp open bracket */
+.opn {
+  color: #000000;
+  font-weight: bold;
+  font-style: normal;
+}
+
+/* lisp close bracket */
+.clo {
+  color: #000000;
+  font-weight: bold;
+  font-style: normal;
+}
+
+/* a markup tag name */
+.tag {
+  color: #006400;
+  font-weight: normal;
+  font-style: normal;
+}
+
+/* a markup attribute name */
+.atn {
+  color: #006400;
+  font-weight: normal;
+  font-style: normal;
+}
+
+/* a markup attribute value */
+.atv {
+  color: #006400;
+  font-weight: normal;
+  font-style: normal;
+}
+
+/* a declaration */
+.dec {
+  color: #000000;
+  font-weight: bold;
+  font-style: normal;
+}
+
+/* a variable name */
+.var {
+  color: #000000;
+  font-weight: normal;
+  font-style: normal;
+}
+
+/* a function name */
+.fun {
+  color: #000000;
+  font-weight: bold;
+  font-style: normal;
+}
+
+/* Specify class=linenums on a pre to get line numbering */
+ol.linenums {
+  margin-top: 0;
+  margin-bottom: 0;
+}
--- a/out/styles/prettify-tomorrow.css
+++ b/out/styles/prettify-tomorrow.css
@ -0,0 +1,132 @@
+/* Tomorrow Theme */
+/* Original theme - https://github.com/chriskempson/tomorrow-theme */
+/* Pretty printing styles. Used with prettify.js. */
+/* SPAN elements with the classes below are added by prettyprint. */
+/* plain text */
+.pln {
+  color: #4d4d4c; }
+
+@media screen {
+  /* string content */
+  .str {
+    color: #718c00; }
+
+  /* a keyword */
+  .kwd {
+    color: #8959a8; }
+
+  /* a comment */
+  .com {
+    color: #8e908c; }
+
+  /* a type name */
+  .typ {
+    color: #4271ae; }
+
+  /* a literal value */
+  .lit {
+    color: #f5871f; }
+
+  /* punctuation */
+  .pun {
+    color: #4d4d4c; }
+
+  /* lisp open bracket */
+  .opn {
+    color: #4d4d4c; }
+
+  /* lisp close bracket */
+  .clo {
+    color: #4d4d4c; }
+
+  /* a markup tag name */
+  .tag {
+    color: #c82829; }
+
+  /* a markup attribute name */
+  .atn {
+    color: #f5871f; }
+
+  /* a markup attribute value */
+  .atv {
+    color: #3e999f; }
+
+  /* a declaration */
+  .dec {
+    color: #f5871f; }
+
+  /* a variable name */
+  .var {
+    color: #c82829; }
+
+  /* a function name */
+  .fun {
+    color: #4271ae; } }
+/* Use higher contrast and text-weight for printable form. */
+@media print, projection {
+  .str {
+    color: #060; }
+
+  .kwd {
+    color: #006;
+    font-weight: bold; }
+
+  .com {
+    color: #600;
+    font-style: italic; }
+
+  .typ {
+    color: #404;
+    font-weight: bold; }
+
+  .lit {
+    color: #044; }
+
+  .pun, .opn, .clo {
+    color: #440; }
+
+  .tag {
+    color: #006;
+    font-weight: bold; }
+
+  .atn {
+    color: #404; }
+
+  .atv {
+    color: #060; } }
+/* Style */
+/*
+pre.prettyprint {
+  background: white;
+  font-family: Consolas, Monaco, 'Andale Mono', monospace;
+  font-size: 12px;
+  line-height: 1.5;
+  border: 1px solid #ccc;
+  padding: 10px; }
+*/
+
+/* Specify class=linenums on a pre to get line numbering */
+ol.linenums {
+  margin-top: 0;
+  margin-bottom: 0; }
+
+/* IE indents via margin-left */
+li.L0,
+li.L1,
+li.L2,
+li.L3,
+li.L4,
+li.L5,
+li.L6,
+li.L7,
+li.L8,
+li.L9 {
+  /* */ }
+
+/* Alternate shading for lines */
+li.L1,
+li.L3,
+li.L5,
+li.L7,
+li.L9 {
+  /* */ }
--- a/package.json
+++ b/package.json
@ -1,16 +1,17 @@
 {
-    "name": "doccpi",
-    "version": "0.0.2",
-    "description": "Pi software for the DoC cams.",
-    "main": "main.js",
-    "scripts": {
-        "test": "echo \"Error: no test specified\" && exit 1"
-    },
-    "author": "Valentin Boettcher",
-    "license": "GPL-3.0",
-    "dependencies": {
-        "fluent-ffmpeg": "^2.1.0",
-        "socket.io-client": "^1.4.8",
-        "winston": "^2.2.0"
-    }
+  "name": "doccpi",
+  "version": "0.0.2",
+  "description": "Pi software for the DoC cams.",
+  "main": "main.js",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "author": "Valentin Boettcher",
+  "license": "GPL-3.0",
+  "dependencies": {
+    "fluent-ffmpeg": "^2.1.0",
+    "redux": "^3.6.0",
+    "socket.io-client": "^1.4.8",
+    "winston": "^2.2.0"
+  }
 }
--- a/src/#reducers.js#
+++ b/src/#reducers.js#
@ -0,0 +1,70 @@
+///////////////////////////////////////////////////////////////////////////////
+//                                  Reducers                                 //
+///////////////////////////////////////////////////////////////////////////////
+
+const redux = require('redux');
+const actions = require('./actions');
+
+let reducers = {};
+
+/**
+ * Set the streaming/error state.
+ */
+reducers.error = function(state = -1, action) {
+    switch (action.type) {
+    case actions.SET_ERROR:
+	if((typeof action.data) == 'undefined') {
+	    return action.data;
+            break;
+	}
+    default:
+        return state;
+    }
+};
+
+/**
+ * Set the streaming state.
+ */
+
+reducers.streaming = function(state = 'STOPPED', action) {
+    switch (action.type) {
+    case actions.REQUEST_START:
+    case actions.REQEST_STOP:
+	return 'STOPPING'
+    default:
+        return state;
+    }
+};
+
+/**
+ * Set the restart flag.
+ *
+ * The restart flag get's automaticly unset, as soon as the start action gets reduced.
+ */
+
+reducers.restart = function(state = false, action) {
+    switch (action.type) {
+    case actions.RESTART:
+	return true;
+    case actions.START:
+	return false;
+    default:
+        return state;
+    }
+};
+
+
+/**
+ * Update the config.
+ */
+reducers.config = function(state = {}, action) {
+    switch (action.type) {
+        case actions.UPDATE_CONFIG:
+            return Object.assign({}, state, action.data);
+            break;
+        default:
+            return state;
+    }
+};
+
+module.exports = redux.combineReducers(reducers);
--- a/src/.#reducers.js
+++ b/src/.#reducers.js
@ -0,0 +1 @@
+hiro@ArLeenUX.857:1492754930
--- a/src/actionCreators.js
+++ b/src/actionCreators.js
@ -0,0 +1,66 @@
+/**
+ * Action Creators
+ *
+ * The action creators create actions to alter the state. In this implementation they have no side effects.
+ */
+
+const actions = require('./actions');
+let creators = {};
+
+
+/**
+ * Creates a start action.
+ * @returns { Oject } Action
+ */
+creators.start = function() {
+    return {
+        type: actions.START
+    };
+};
+
+/**
+ * Creates a stop action.
+ * @returns { Oject } Action
+ */
+creators.stop = function() {
+    return {
+        type: actions.STOP
+    };
+};
+
+/**
+ * Creates a restart action.
+ * @returns { Oject } Action
+ */
+creators.restart = function() {
+    return {
+	type: actions.RESTART
+    };
+};
+
+
+/**
+ * Creates an action to set the Error.
+ * @param { Number } error The error code. @see ffmpegCommand.js
+ * @returns { Object } Action
+ */
+creators.setError = function(error) {
+    return {
+        type: actions.SET_ERROR,
+        data: error
+    };
+};
+
+/**
+ * Creates an action to update the config.
+ * @param { Object } configUpdate The changes to the config.
+ * @returns { Object } Action
+ */
+creators.updateConfig = function(configUpdate) {
+    return {
+        type: actions.UPDATE_CONFIG,
+        data: configUpdate
+    };
+};
+
+module.exports = creators;
--- a/src/actionCreators.js~
+++ b/src/actionCreators.js~
@ -0,0 +1,31 @@
+/**
+ * Action Creators
+ *
+ * The action creators create actions to alter the state. In this implementation they have no side effects.
+ */
+
+creators.start = function() {
+    return {
+        type: actions.START
+    };
+};
+
+creators.stop = function() {
+    return {
+        type: actions.STOP
+    };
+};
+
+creators.setError = function(error) {
+    return {
+        type: actions.SET_ERROR,
+        data: error
+    };
+};
+
+creators.updateConfig = function(configUpdate) {
+    return {
+        type: actions.UPDATE_CONFIG,
+        data: configUpdate
+    };
+};
--- a/src/actions.js
+++ b/src/actions.js
@ -0,0 +1,14 @@
+///////////////////////////////////////////////////////////////////////////////
+//                      The Actions to change the State                       //
+///////////////////////////////////////////////////////////////////////////////
+
+let actions = module.exports = {
+    UPDATE_CONFIG: 'UPDATE_CONFIG',
+    REQUEST_START: 'REQUEST_START',
+    SET_STARTED: 'SET_STATED',
+    REQUEST_STOP: 'REQUEST_STOP',
+    SET_STOPPED: 'SET_STOPPED',
+    REQUEST_RESTART: 'REQUEST_RESTART',
+    SET_ERROR: 'SET_ERROR',
+    TRY_RECONECT: 'TRY_RECONNECT'
+};
--- a/src/actions.js~
+++ b/src/actions.js~
@ -0,0 +1,11 @@
+///////////////////////////////////////////////////////////////////////////////
+//                      The Actions to change the State                       //
+///////////////////////////////////////////////////////////////////////////////
+
+let actions = module.exports = {
+    UPDATE_CONFIG : 'UPDATE_CONFIG',
+    START : 'START',
+    STOP : 'STOP',
+    SET_ERROR : 'SET_ERROR',
+    RESTART: 'RESTART'
+}
--- a/src/ffmpegCommand.js
+++ b/src/ffmpegCommand.js
@ -4,6 +4,7 @@

 const ffmpeg = require('fluent-ffmpeg');
 const http   = require('http');
+const logger = require('./logger');

 ///////////////////////////////////////////////////////////////////////////////
 //                                Declarations                               //
@ -18,10 +19,7 @@ let cmd = ffmpeg({
 });

 // The Config, Logger and a handle for the kill timeout.
-let config, logger, stopHandle = false, connectHandle = false;
-
-// True if stream should be restarted.
-let restart = false;
+let _config, _stopHandle = false, _connectHandle = false;

 // Error Texts
 let errorDescriptions = ['Camera Disconnected',
@ -29,38 +27,37 @@ let errorDescriptions = ['Camera Disconnected',
 			 'Wrong ffmpeg executable.',
 			 'Unknown Error - Restarting'];

-// Internal Status
-let status = {
-    streaming: false,
-    error: false
-};
-
 // The stream source url. Yet to be set.
 let source = "";

+// The State Object.
+let State;
+
 ///////////////////////////////////////////////////////////////////////////////
 //                                    Code                                   //
 ///////////////////////////////////////////////////////////////////////////////

 /**
 * Interface to the ffmpeg process. Uses fluent-ffmpeg.
- * @param {Object} _config Configuration for the stream. @see config.js.example
- * @param {Object} _logger Logger Instance from main module.
+ * @param {Object} config Configuration for the stream. @see config.js.example
 */
-let command =  function(_config, _logger){
+let Commander = function(State){
    // singleton
    if(self)
 	return self;

+    // Make `new` optional.
+    if(!(this instanceof Commander))
+	return new Commander(config, logger);
+
    
-    // TODO: Better Error Checking
-    if(!_config)
+    // TODO: Better Error Checkinglet
+    if(!config)
 	throw new Error("Invalid Config");

-    if(!_logger)
+    if(!logger)
 	throw new Error("Invalid Logger");

-    config = _config;

    self = this;
           
@ -98,6 +95,8 @@ let command =  function(_config, _logger){
 	cmd.on('end', stopped);
 	
        cmd.on('error', crashed);
+
+	return cmd;
    };

    let ffmpegCommand = function() {
@ -108,7 +107,7 @@ let command =  function(_config, _logger){
    // Start streaming.
    let start = function() {
 	// Ignore if we try to reconnect.
-	if(connectHandle)
+	if(_connectHandle)
 	    return;
 	
 	cmd.run();
@ -127,7 +126,7 @@ let command =  function(_config, _logger){
    let stop = function() {
 	cmd.kill('SIGINT');

-	stopHandle = setTimeout(() => {
+	_stopHandle = setTimeout(() => {
            logger.log(logger.importance[3], "Force Stop!");
            cmd.kill();
 	}, 3000);
@ -185,7 +184,7 @@ function crashed(error, stdout, stderr){
 	status.error = 0;

    // Can't connect to the Internet / YouTube
-    else if (err.message.indexOf(source + 'Input/output error') > -1 || err.message.indexOf('rtmp://a.rtmp.youtube.com/live2/' + config.key) > -1)
+    else if (err.message.indexOf(source + 'Input/output error') > -1 || err.message.indexOf('rtmp://a.rtmp.youtube.com/live2/' + _config.key) > -1)
 	status.error = 1;

    // Wrong FFMPEG Executable
@ -229,7 +228,7 @@ function tryReconnect( host, port ){
 	    // NOTE: Ugly!
 	    
            // We have a response! Connection works.
-	    connectHandle = false;
+	    _connectHandle = false;
 	    self.start();
        }, 1000);
    }).on("error", function(e) {
@ -238,12 +237,12 @@ function tryReconnect( host, port ){
 		// NOTE: Ugly!
 		
                // We have a response! Connection works.
-		connectHandle = false;
+		_connectHandle = false;
 		self.start();
            }, 1000);
        } else {
 	    // try again
-            connectHandle = setTimeout(function(){
+            _connectHandle = setTimeout(function(){
 		tryReconnect(host, port);
 	    }, 1000);
 	}
--- a/src/logger.js
+++ b/src/logger.js
@ -4,6 +4,14 @@

 let winston = require('winston');

+///////////////////////////////////////////////////////////////////////////////
+//                                Declarations                               //
+///////////////////////////////////////////////////////////////////////////////
+
+// Object oriented `this`.
+let self = false;
+
+// Custom log levels.
 const customLevels = {
    levels: {
        normal: 0,
@ -21,26 +29,48 @@ const customLevels = {
    }
 };

+///////////////////////////////////////////////////////////////////////////////
+//                                    Code                                   //
+///////////////////////////////////////////////////////////////////////////////
+
+/**
+ * Monkey Patching.
+ */
+
+
+/**
+ * Calls the logging function with arguments, if the node enviroment isn't in production mode.
+ */
+winston.Logger.prototype.dbgmsg = function() {
+    if (process.env.NODE_ENV !== 'production')
+	this.log.apply(undefined, arguments);
+};
+
 // Set the Colors
 winston.addColors(customLevels.colors);

-let logger = new(winston.Logger)({
-    levels: customLevels.levels,
-    transports: [
-        new(winston.transports.Console)({
-            level: 'success'
-        }),
-        new(winston.transports.File)({
-            filename: __dirname + '/process.log',
-            colorize: true,
-            timestamp: true,
-	    level: 'success',
-            json: true,
-            maxsize: 500000,
-            maxFiles: 10
-        })
-    ]
-});
+let logger = (function() {
+    if(!self)
+	self = new(winston.Logger)({
+	    levels: customLevels.levels,
+	    transports: [
+		new(winston.transports.Console)({
+		    level: 'success'
+		}),
+		new(winston.transports.File)({
+		    filename: __dirname + '/process.log',
+		    colorize: true,
+		    timestamp: true,
+		    level: 'success',
+		    json: true,
+		    maxsize: 500000,
+		    maxFiles: 10
+		})
+	    ]
+	});
+
+    return self;
+})();

 logger.importance = ['normal', 'info', 'warning', 'danger', 'success'];

--- a/src/reducers.js
+++ b/src/reducers.js
@ -0,0 +1,71 @@
+///////////////////////////////////////////////////////////////////////////////
+//                                  Reducers                                 //
+///////////////////////////////////////////////////////////////////////////////
+
+const redux = require('redux');
+const actions = require('./actions');
+
+let reducers = {};
+
+/**
+ * Set the streaming/error state.
+ */
+reducers.error = function(state = -1, action) {
+    switch (action.type) {
+    case actions.SET_ERROR:
+	if((typeof action.data) == 'undefined') {
+	    return action.data;
+            break;
+	}
+    default:
+        return state;
+    }
+};
+
+/**
+ * Set the streaming state.
+ */
+
+reducers.streaming = function(state = 'STOPPED', action) {
+    switch (action.type) {
+    case actions.START:
+    case actions.STOP:
+	return action.type == actions.START;
+	break;
+    default:
+        return state;
+    }
+};
+
+/**
+ * Set the restart flag.
+ *
+ * The restart flag get's automaticly unset, as soon as the start action gets reduced.
+ */
+
+reducers.restart = function(state = false, action) {
+    switch (action.type) {
+    case actions.RESTART:
+	return true;
+    case actions.START:
+	return false;
+    default:
+        return state;
+    }
+};
+
+
+/**
+ * Update the config.
+ */
+reducers.config = function(state = {}, action) {
+    switch (action.type) {
+        case actions.UPDATE_CONFIG:
+            return Object.assign({}, state, action.data);
+            break;
+        default:
+            return state;
+    }
+};
+
+module.exports = redux.combineReducers(reducers);
--- a/src/reducers.js~
+++ b/src/reducers.js~
@ -0,0 +1,71 @@
+///////////////////////////////////////////////////////////////////////////////
+//                                  Reducers                                 //
+///////////////////////////////////////////////////////////////////////////////
+
+const redux = require('redux');
+const actions = require('./actions');
+
+let reducers = {};
+
+/**
+ * Set the streaming/error state.
+ */
+reducers.error = function(state = -1, action) {
+    switch (action.type) {
+    case actions.SET_ERROR:
+	if((typeof action.data) == 'undefined') {
+	    return action.data;
+            break;
+	}
+    default:
+        return state;
+    }
+};
+
+/**
+ * Set the streaming state.
+ */
+
+reducers.streaming = function(state = false, action) {
+    switch (action.type) {
+    case actions.START:
+    case actions.STOP:
+	return action.type == actions.START;
+	break;
+    default:
+        return state;
+    }
+};
+
+/**
+ * Set the restart flag.
+ *
+ * The restart flag get's automaticly unset, as soon as the start action gets reduced.
+ */
+
+reducers.restart = function(state = false, action) {
+    switch (action.type) {
+    case actions.RESTART:
+	return true;
+    case actions.START:
+	return false;
+    default:
+        return state;
+    }
+};
+
+
+/**
+ * Update the config.
+ */
+reducers.config = function(state = {}, action) {
+    switch (action.type) {
+        case actions.UPDATE_CONFIG:
+            return Object.assign({}, state, action.data);
+            break;
+        default:
+            return state;
+    }
+};
+
+module.exports = redux.combineReducers(reducers);
--- a/src/state.js
+++ b/src/state.js
@ -0,0 +1,109 @@
+///////////////////////////////////////////////////////////////////////////////
+//      Redux Wrapper to hold the state and communicate with the Server.     //
+///////////////////////////////////////////////////////////////////////////////
+
+/**
+ * All actions are proxied via Socket.js
+ *
+ * The connection is managed by the main module.
+ */
+
+const redux = require('redux');
+
+///////////////////////////////////////////////////////////////////////////////
+//                                Declarations                               //
+///////////////////////////////////////////////////////////////////////////////
+
+// Object oriented `this`.
+let self = false;
+
+// Reference to the store.
+let store = false;
+
+/**
+ * Inital State for the app.
+ * @property { bool } streaming Indicates if the streaming process is running.
+ * @property { number } error Error code. Any number outside the range of the Error array in @see ffmpeg-command.js will be treated as non error. Most conveniently set: -1.
+ * @property { bool } configured Indicates if the camera is configured or not.
+ */
+let initialState = {
+    streaming: false,
+    error: -1,
+    config: {}
+}; // NOTE: Maybe in main.js
+
+// Reducer
+let streaming, error, config;
+const reducers = redux.combineReducers({
+    streaming,
+    error,
+    config
+});
+
+// The socket.io connection from the main-module.
+let _socket;
+
+/**
+ * Actions
+ */
+
+let SEND_MESSAGE = 'SEND_MESSAGE';
+let UPDATE_CONFIG = 'UPDATE_CONFIG';
+let START_STOP = 'START_STOP';
+let SET_ERROR = 'SET_ERROR';
+
+///////////////////////////////////////////////////////////////////////////////
+//                                    Code                                   //
+///////////////////////////////////////////////////////////////////////////////
+
+/**
+ * Wrapper to expose action creators and the store.
+ * @param { Object } socket Socket.io instance from the main module..
+ */
+module.exports = function state( socket ){
+    // singleton
+    if(self)
+	return self;
+
+    // Make `new` optional.
+    if(!(this instanceof createStore))
+	return new createStore(_socket);
+    
+    _socket = socket;
+    self = this;
+ 
+    return this;
+};
+
+/**
+ * Reducers
+ */
+
+// TODO: share the code!
+
+/**
+ * Set the streaming/error state.
+ */
+streaming = error = function(state, action) {
+    switch(action) {
+    case SET_ERROR:
+    case START_STOP:
+	return action.data;
+	break;
+    default:
+	return state;
+    }
+};
+
+/**
+ * Update the config.
+ */
+config = function(state, action) {
+    switch(action) {
+    case UPDATE_CONFIG:
+	return Object.assign({}, state, action.data);
+	break;
+    default:
+	return state;
+    }
+}
--- a/src/status.js
+++ b/src/status.js
@ -1,117 +1,129 @@
-///////////////////////////////////////////////////////////////////////////////
-//   Redux wrapper to hold the status object and the master server about changes.  //
-///////////////////////////////////////////////////////////////////////////////
+/** Redux Wrapper to hold the state and communicate with the Server
+ * @module State
+ */
+
+const redux = require('redux');
+const logger = require('./logger');

 ///////////////////////////////////////////////////////////////////////////////
 //                                Declarations                               //
 ///////////////////////////////////////////////////////////////////////////////

-// Reference to itself.
+// Object oriented `this`.
 let self = false;

+/**
+ * Inital State for the app.
+ * @property { Object } stream Stream Status.
+ * @property { bool } stream.running Indicates wether the stream is running.
+ * @property { number } stream.error Error code. Any number outside the range of the Error array in @see ffmpeg-command.js will be treated as non error. Most conveniently set: -1.
+ * @property { bool } stream.reconnecting Indicates wether the program tries to reconnect to the camera or the internet.
+ * @property { Object } config Configuration of the camera.
+ */
+let initialState = {
+    stream: {
+	running: false,
+	error: -1,
+	reconnecting: false
+    },
+    config: {}
+}; // NOTE: Maybe in main.js
+
 // The socket.io connection from the main-module.
-let _socket;
+let _communicator;

-// The Properties of the status.
-let _properties;
+// Actions
+const actions = require('./actions');

-// Allowed values for the properties.
-let _allowed;
+// Action Creators
+const creators = require('./actionCreators');
+const dispatchers = redux.bindActionCreators(creators);

-// Action names for the properties.
-let _actions;
+// Reducer
+const reducer = require('./reducers');
+
+// Reference to the store of the application state.
+const store = redux.createStore(reducer, initialState);

 ///////////////////////////////////////////////////////////////////////////////
 //                                    Code                                   //
 ///////////////////////////////////////////////////////////////////////////////

+// TODO: Log state changes.
+
 /**
- * Wrapper to hold the status object and the master server about changes.
+ * The central redux state manager. The module exposes central action dispatchers. Updates to the state get communicated to the server.
 *
- * The state is a shallow object which contains non-object values.
- * @param { Object } socket Socket.io instance from the main module..
- * @param { Object } properties The state properties to be set and read.
- * @param { Array } properties.name.allowed Array of allowed values. The first value is the default value.
- * @param { String } properties.name.action Name of the action to send to the server.
+ * @constructor 
+ * @member [Action Dispatchers] The action creators (@see actionCreators.js) are bound to the dispatch function and made member of the State object.
+ * @param { Object } communicator A communicator object. @see communicator.js - Optional //TODO: Find proper tag.
 */
-let state = function( socket, properties ){
+function State(communicator = false) {
    // singleton
-    if(self)
-	return self;
+    if (self)
+        return self;
+
+    // Make `new` optional.
+    if (!(this instanceof State))
+        return new State(_communicator);
+
+    _communicator = communicator;
    
    self = this;
-    _socket = socket;
-
-    // Initialize the Properties
-    for(let prop in properties){
-	// When already there or invalid, skip.
-	if(this[prop] || !(properties[prop] instanceof Array))
-	    continue;
-
-	// Set prop and allowed;  
-	_properties[prop] = properties[prop][0];
-	_allowed[prop] = Object.assign([], properties[prop]);
-	
-
-	// Getter function.
-	(
-	    function(prop){
-		Object.defineProperty(self, prop, {
-		    get: function(){
-			return this.get(prop);
-		    }
-		});
-	    }
-	)(prop);
-    }
-
    return this;
 };

-module.exports = state;
+applyDispatchers(creators);

 /**
- * Get a state value.
- * @param {String} prop Name of the state property.
- * @return { * } The properties value or false if it is not found.x
+ * Set the communicator object and enable the state sync with the server.
+ * @param {Object} communicator A communicator object. @see communicator.js
 */
-state.prototype.get = function(prop){
-    if(_properties[prop])
-	return _properties[prop];
+State.prototype.setCommunicator = function(communicator) {
+    if (_communicator)
+        _communicator = communicator;
    else
-	return false;
+        logger.dbgmsdg("Invalid Communicator");
 };

 /**
- * Set a state value.
- * @param {String} prop Name of the state property.
- * @param { * } value Value to set the property to.
- * @return { * } The properties new value or false if not allowed or not found.
- *
- * /**
- * Set state values.
- * @param { Object } properties An object with the properties to be changed.
- * @return { * } The properties new value or false if not allowed or not found.
+ * Wrapper for redux.
+ * @returns { Object } The current state.
 */
-state.prototype.set = function(prop, value){
-    let change;
-    
-    if(!value){
-	if(typeof prop !== 'object')
-	    return false;
-    } else {
-	if(typeof value == 'Object')
-    }
+State.prototype.getState = function(){
+    return store.getState();
+};

-    if(!_properties[prop] || !_properties[prop].allowed[value])
-	return false;
-
-    // NOTE: Maybe unmutable!
-    _properties[prop].value = value;
-    return _properties[prop].value;
+/**
+ * Get the current config.
+ * @returns { * } The current config.
+ */
+State.prototype.getConfig = function(){
+    return store.getState().config;
 };

 /**
 * Utilities
 */

+/**
+ * Adds prototypes for the action dispatchers to the State. 
+ * @param { Object } creators
+ * @throws { Error } If a method with the creators name already exists. @see actionCreators.js
+ */
+function applyDispatchers( creators ){
+    for(let creator in creators){
+	if(State.prototype[creator])
+	    throw new Error(`State has already a meber '${creator}'.`);
+	
+	State.prototype[creator] = function(){
+	    store.dispatch(creators[creator].apply(undefined, arguments));
+	};
+    }
+}
+
+
+module.exports = State;
+
+
+