working prototype (with ufw service)

app.js

@@ -2,7 +2,8 @@ var Savetime = require('./lib/Savetime');
 var SavetimePluginSocketio = require('./lib/Savetime/PluginSocketio');
 
 var serviceMachine = require('./lib/ServiceMachine');
-var ServiceLogic = require('./lib/ServiceLogic');
+// var ServiceLogic = require('./lib/ServiceLogic/Fake');
+var ServiceLogic = require('./lib/ServiceLogic/Ufw');
 serviceMachine.register(ServiceLogic);
 
 var billingMachine = require('./lib/BillingMachine');

lib/ServiceLogic.js

@@ -7,7 +7,7 @@ var ServiceLogic = module.exports = boop.extend({
 
     IN_switching_on : function (session, state, transition, msg) {
         console.log('Service IN:', state.name);
-        this.doIfup(function (error) {
+        this.doSwitchUp(function (error) {
             if(error) {
                 session.maybeDispatch({msgId:'error'});
                 return;
@@ -23,7 +23,7 @@ var ServiceLogic = module.exports = boop.extend({
 
     IN_switching_off : function (session, state, transition, msg) {
         console.log('Service IN:', state.name);
-        this.doIfdown(function (error) {
+        this.doSwitchDown(function (error) {
             if(error) {
                 session.maybeDispatch({msgId:'error'});
                 return;
@@ -42,15 +42,11 @@ var ServiceLogic = module.exports = boop.extend({
         session.output.emit(state.name);
     },
 
-    doIfup : function (next) {
-        setTimeout(function () {
-            next(null);
-        }, 1000);
+    doSwitchUp : function (next) {
+        throw new Error('EABSTRACT');
     },
 
-    doIfdown : function (next) {
-        setTimeout(function () {
-            next(null);
-        }, 1000);
+    doSwitchDown : function (next) {
+        throw new Error('EABSTRACT');
     }
 });

lib/ServiceLogic/Fake.js

@@ -0,0 +1,16 @@
+var ServiceLogic = require('../ServiceLogic');
+
+var ServiceLogic_Fake = module.exports = ServiceLogic.extend({
+
+    doSwitchUp : function (next) {
+        setTimeout(function () {
+            next(null);
+        }, 1000);
+    },
+
+    doSwitchDown : function (next) {
+        setTimeout(function () {
+            next(null);
+        }, 1000);
+    }
+});

lib/ServiceLogic/Ufw.js

@@ -0,0 +1,30 @@
+var path = require('path');
+var child_process = require('child_process');
+var ServiceLogic = require('../ServiceLogic');
+
+var SCRIPT_UP = path.resolve(__dirname + '/ufw/ufw-up.sh');
+var SCRIPT_DOWN = path.resolve(__dirname + '/ufw/ufw-down.sh');
+
+
+var ServiceLogic_Ufw = module.exports = ServiceLogic.extend({
+
+    doSwitchUp : function (next) {
+        child_process.exec(SCRIPT_UP, function (error, stdout, stderr) {
+            if(error) {
+                next(error);
+                return;
+            }
+            next();
+        });
+    },
+
+    doSwitchDown : function (next) {
+        child_process.exec(SCRIPT_DOWN, function (error, stdout, stderr) {
+            if(error) {
+                next(error);
+                return;
+            }
+            next();
+        });
+    }
+});

lib/ServiceLogic/ufw/ufw-down.sh

@@ -0,0 +1,4 @@
+#!/bin/sh
+UFW=`which ufw`
+${UFW} reject out http
+${UFW} reject out https

lib/ServiceLogic/ufw/ufw-up.sh

@@ -0,0 +1,4 @@
+#!/bin/sh
+UFW=`which ufw`
+${UFW} --force delete reject out http
+${UFW} --force delete reject out https