project basic structure

Author: alexk-blackops

.gitignore

@@ -0,0 +1 @@
+node_modules

index.js

@@ -0,0 +1,21 @@
+var util   = require('util'),
+    access = require('./lib/access'),
+    logger = require('./lib/logger'),
+    api    = require('./lib/api'),
+    CONFIG = require('./lib/config'),
+    sender = require('./sender');
+
+module.exports = {
+    CONFIG: CONFIG,
+
+    start: function () {
+        
+    },
+
+    log: logger.methods.log,
+    debug: logger.methods.debug,
+    info: logger.methods.info,
+    warn: logger.methods.warn,
+    error: logger.methods.error,
+    postLogs: api.postLogs
+}

lib/api.js

@@ -0,0 +1,58 @@
+var os = require('os'),
+    send = require('./sender'),
+    access = require('.access'),
+    logger = require('./logger'),
+    CONFIG = require('./config'),
+    pkginfo = require('pkginfo')(module, 'name'),
+
+    options = {
+        host: CONFIG.HOST,
+        port: CONFIG.PORT,
+        method: 'POST',
+        headers: {
+            Content-Type: 'application/json',
+            X-Stackify-Key: CONFIG.LICENSE_KEY,
+            X-Stackify-PV: 'V1'
+        }
+    }
+
+module.exports = {
+
+    identifyApp: function identifyApp (licenseKey) {
+        var options = options,
+            data = {
+                "DeviceName": os.hostname(),
+                "AppName": module.exports.name
+            },
+            callback = function(data) {
+                CONFIG.APP_DETAILS = data.toJSON();
+            },
+            fail = function() {
+                setTimeout(function() {
+                    identifyApp(licenseKey)
+                }, CONFIG.REQUEST_TIMER)
+            }
+
+        options.path = CONFIG.IDENTIFY_PATH;    
+
+        send(options, data, callback, fail);
+    };
+
+    postLogs: function postLogs(messages, cb, fail) {
+        var options = options,
+            callback = cb || function(data) {
+                logger.storage = logger.storage.slice(CONFIG.MSG_LIMIT)
+            },
+            fail = function() {
+                setTimeout(function() {
+                    postLogs(messages, callback, fail)
+                }, CONFIG.REQUEST_TIMER)
+            },
+            data = CONFIG.APP_DETAILS;
+
+        data.Msgs = messages;
+        options.path = CONFIG.LOG_SAVE_PATH;
+
+        send(options, data, callback, fail);
+    };
+}

lib/config.js

@@ -0,0 +1,12 @@
+module.exports = {
+	'HOST': '1',
+	'PORT': 1,
+	'IDENTIFY_PATH': '1',
+	'LOG_SAVE_PATH': '1',
+	'LICENSE_KEY': '1',
+	'MSG_LIMIT': 20, // number of messages
+	'SCAN_TIMER': 30, // sec
+	'REQUEST_TIMER': 30, // sec
+	'REQUEST_ATTEMPTS': 20, // number of attempts if API call isn't succesful
+	'ERROR_FLOOD_LIMIT': 100 // limit of the same error message per minute
+}

lib/error.js

@@ -0,0 +1,55 @@
+var api = require('./api'),
+    CONFIG = require('./config'),
+    checkMeta = function(meta) {
+        if (Object.prototype.toString.call(meta) === '[object Object]') {
+            if (Object.keys(meta).length === 1) {
+                try {
+                    JSON.stringify(meta);
+                } catch(e) {
+                    return false;
+                }
+                return [Object.keys(meta)[0], meta[Object.keys(meta)[0]]];
+            }
+        }
+        return false;
+    }
+
+module.exports.storage = storage = [];
+module.exports.flag = flag = true;
+module.exports.lastSent = lastSent = Date.now();
+module.exports.timeout = timeout = undefined;
+module.exports.methods = {
+
+    log: function log (level, msg, meta) {
+        var rec = {
+                level: level,
+                msg: msg,
+                timestamp: new Date().toUTCString()
+            },
+            metaIsValid = checkMeta(meta),
+            msgs;
+
+        if (meta && metaIsValid) {
+            rec[metaIsValid[0]] = metaIsValid[1];
+        }    
+
+        storage.push(rec);
+
+        if (storage.length >= CONFIG.MSG_LIMIT && CONFIG.APP_DETAILS) {
+            msgs = storage.slice(0, CONFIG.MSG_LIMIT);
+            api.postLogs(msgs);
+        }
+    },
+    debug: function debug (msg) {
+        this.log.call(this, 'debug', msg, meta);
+    },
+    info: function info(msg) {
+        this.log.call(this, 'info', msg, meta);
+    },
+    warn: function warn (msg) {
+        this.log.call(this, 'warn', msg, meta);       
+    },
+    error: function error (msg) {
+        this.log.call(this, 'error', msg, meta);
+    }
+}

lib/logger.js

@@ -0,0 +1,27 @@
+module.exports = function sender(options, data, cb, fail) {
+
+    callback = function(response) {
+        var str = '';
+
+        //another chunk of data has been recieved, so append it to `str`
+        response.on('data', function (chunk) {
+            str += chunk;
+        });
+
+        //the whole response has been recieved, so we just print it out here
+        response.on('end', function () {
+            if (response.statusCode === 200) {
+                cb(str);
+            } else {
+                if (fail) {
+                    fail();
+                }
+            }
+        });
+    },
+
+    req = http.request(options, callback);
+
+    req.write(data);
+    req.end();
+};

lib/sender.js

@@ -0,0 +1,19 @@
+{
+  "name": "stackify-logger",
+  "version": "1.0.0",
+  "description": "Stackify logging package",
+  "main": "index.js",
+  "scripts": {
+    "test": "not specified yet"
+  },
+  "keywords": [
+    "stackify",
+    "logger"
+  ],
+  "author": "Stackify",
+  "license": "ISC",
+  "dependencies": {
+    "on-finished": "^2.1.1",
+    "pkginfo": "^0.3.0"
+  }
+}

package.json

@@ -0,0 +1,11 @@
+var pkginfo = require('pkginfo')(module, 'name');
+var config = require('./lib/config');
+var stackify = require('./index');
+var test2 = require('./test2');
+stackify.warn('sdf');
+stackify.error('wefsdf');
+stackify.print();
+console.dir(module.exports.name);
+config.GHET = 'test';
+console.dir(config);
+test2();