added basic api initialization

Author: arunoda

lib/apm.js

@@ -0,0 +1,60 @@
+var http = Npm.require('http');
+Apm = {};
+
+Apm.connect = function(appId, appSecret, options) {
+  options = options || {};
+
+  var endpoint = options.endpoint || "http://localhost:11011";
+
+  if(appId && appSecret) {
+    schedulePayloadSend();
+  } else {
+    throw new Error('APM: AppId and AppSecret required!');
+  }
+
+  var retries = 0;
+
+  function sendPayload() {
+    var payload = {methods: _.values(MethodsStore)};
+    MethodsStore = {};
+    var headers = {'METEOR_APM_APPID': appId, 'METEOR_APM_SECRET': appSecret};
+    var httpOptions = {headers: headers, data: payload};
+
+    callHTTP();
+
+    function callHTTP() {
+      try {
+        var response = HTTP.call('POST', endpoint, httpOptions);
+        processResponse(response);
+      } catch(err) {
+        tryAgain(err);
+      }
+    }
+
+    function processResponse(response) {
+      if(response.statusCode == '401') {
+        throw new Error('APM: AppId, AppSecret combination is invalid');
+      } else if(response.statusCode == '200') {
+        //success send again in 10 secs
+        schedulePayloadSend();
+      } else {
+        tryAgain();
+      }
+    }
+
+    function tryAgain(err) {
+      if(++retries < 5) {
+        Meteor.setTimeout(callHTTP, 1000 * retries);
+      } else {
+        console.error('APM: Error sending payload(dropped after 5 tries) ', err.message);
+        retries = 0;
+        schedulePayloadSend();
+      }
+    }
+
+  }
+  
+  function schedulePayloadSend() {
+    Meteor.setTimeout(sendPayload, 1000 * 10); 
+  }
+};

lib/notification_manager.js

@@ -7,6 +7,11 @@ function _NotficationManager() {
 }
 
 _NotficationManager.prototype.methodTrackEvent = function(type, data, ampInfo) {
+  if(!Fibers.current) {
+    //we don't need to track methodEvents when there don't exists a fiber
+    return;
+  }
+
   ampInfo = ampInfo || Fibers.current.__apmInfo;
   if(ampInfo && ampInfo.method) {
     var method = this._ensureMethodExists(ampInfo);

package.js

@@ -6,6 +6,7 @@ Npm.depends({
 
 });
 
+
 Package.on_use(function(api) {
   api.use(['minimongo', 'livedata', 'mongo-livedata', 'ejson', 'underscore', 'http'], ['server']);
   api.add_files([
@@ -15,6 +16,9 @@ Package.on_use(function(api) {
     'lib/hijack/db.js',
     'lib/hijack/http.js',
     'lib/hijack/async.js',
+    'lib/apm.js',
     'lib/test_methods.js'
   ], 'server');
-});
+  
+  api.export('Apm');
+});

test/connect.js

@@ -0,0 +1,3 @@
+if(Meteor.isServer) {
+  Apm.connect('appId', 'appSecret');
+}

todo

@@ -6,7 +6,7 @@ Hijack Sessions
 Hijack DB
 add cursor methods
 Notification Manager
-* Api Initialization
+Api Initialization
 
 * Some Other Stuff to Hijack
 ----------------------------

tools/mock_engine.js

@@ -0,0 +1,25 @@
+var http = require('http');
+var app = http.createServer(function(req, res) {
+  console.log("AUTH:", req.headers);
+  var data = "";
+  req.on('data', ondata);
+  req.once('end', onend);
+  req.socket.setKeepAlive(false);
+
+  res.writeHead(200);
+
+  function ondata(d) {
+    data += d.toString();
+  }
+
+  function onend() {
+    console.log('DATA:', data);
+    req.removeListener('data', ondata);
+    res.end();
+  }
+});
+
+var port = process.env.PORT || 11011;
+console.log('Mock APM Engine started on port: ', port);
+app.listen(port);
+