From: Ben Beltran Date: Wed, 24 Apr 2013 13:46:28 +0000 (-0500) Subject: New changes from nitro X-Git-Url: https://git.r.bdr.sh/rbdr/cologne/commitdiff_plain/c35e454310676fa3fca931bdb5c4e56a01775ef4 New changes from nitro --- diff --git a/lib/cobalt.js b/lib/cobalt.js index 771c9c7..5ae39f2 100644 --- a/lib/cobalt.js +++ b/lib/cobalt.js @@ -28,6 +28,18 @@ Cobalt.Logger.Socket = require('./loggers/socket.js').Socket; } + Cobalt.now = function () { + if (typeof performance !== 'undefined') { + return performance.timing.navigationStart + performance.now(); + } + + if (typeof Microtime !== 'undefined') { + return Microtime.nowDouble() * 1000; + } + + return Date.now(); + } + Cobalt.Console = Class(Cobalt, 'Console')({ prototype : { from : "Generic Cobalt Logger", @@ -64,13 +76,16 @@ // Builds a Cobalt Log Object buildLog : function (item, level) { - var co = this; + var co = this, oldItem; if (!item._cobaltLog) { if (typeof item !== "object") { - item = { _cobaltLog : true, message : item.toString() }; + item = {message : item.toString() }; + } else { + item.message = JSON.stringify(item); } + item._cobaltLog = true; item._from = co.from; item._level = item._level || level || 7; item._levelString = co._levelString(item._level); @@ -99,15 +114,20 @@ _log : function (severity) { var co = this, logString, + logObjectArray = [], i, j; for (i = 1; i < arguments.length; i++) { - logObject = co.buildLog(arguments[i], severity); - - for (j = 0; j < co.loggers.length; j++) { - co.loggers[j].log(logObject); + if (typeof arguments[i] === 'undefined') { + logObjectArray.push(co.buildLog("undefined", severity)); + } else { + logObjectArray.push(co.buildLog(arguments[i], severity)); } } + + for (j = 0; j < co.loggers.length; j++) { + co.loggers[j].log.apply(co.loggers[j], logObjectArray); + } }, log : function () { @@ -246,6 +266,10 @@ } }); + if (Cobalt.Console.__objectSpy) { + Cobalt.Console.__objectSpy.destroy(); + } + if (typeof require === 'function') { global.Formatter = Cobalt.Formatter; global.Logger = Cobalt.Logger; diff --git a/lib/ext/socket_helper.js b/lib/ext/socket_helper.js index 661d435..50fe5bc 100644 --- a/lib/ext/socket_helper.js +++ b/lib/ext/socket_helper.js @@ -1,6 +1,6 @@ var bindEvents = function (socket, logger) { - socket.on('log', function (logObject) { - logger.log(logObject); + socket.on('log', function (logArgs) { + logger.log.apply(logger, logArgs); }); } diff --git a/lib/formatters/event_tracker.js b/lib/formatters/event_tracker.js new file mode 100644 index 0000000..53cef95 --- /dev/null +++ b/lib/formatters/event_tracker.js @@ -0,0 +1,270 @@ +(function (global) { + var Module; + + // Load up dependencies + if (typeof require === 'function') { + var Ne = require('neon'); + Module = Ne.Module; + } else { + Module = global.Module; + } + + var Cobalt = {}; + Module(Cobalt, 'Formatter')({}); + + Cobalt.Formatter.EventTracker = Module(Cobalt.Formatter, 'EventTracker')({ + + // Main formatter entry point, validate type and send to proper format + // method + format : function (logObject) { + switch(this._validateFormat(logObject)){ + case 'error': + return this._formatError(logObject); + break; + case 'event': + logObject._type = 'event'; + return this._formatEvent(logObject); + break; + } + return undefined; + }, + + // Format error + _formatError : function (logObject) { + var errorObject; + + errorObject = logObject.error; + errorObject._type = 'error'; + + if (typeof Client !== 'undefined') { + errorObject.site_id = Client.pageInfo.site.id; + }else if (global.data && global.data.site && global.data.site.id) { + errorObject.site_id = global.data.site.id; + } + errorObject.scoped_class_name = errorObject.meta.scopedClassName; + errorObject.user_agent = global.navigator.userAgent; + + return errorObject; + }, + + // Format the event + _formatEvent : function (logObject) { + var eventToSend; + + eventToSend = this._createStructure(logObject); + + return eventToSend; + }, + + // Check for the fingerprint of an event or an error + _validateFormat : function (logObject) { + if (typeof logObject === 'object'){ + // Check for error object (must have meta) + if (logObject.hasOwnProperty('error')) { + if (logObject.error.hasOwnProperty('meta')) { + return 'error'; + } + // Check for event object (must have type) + } else if (logObject.hasOwnProperty('event')) { + if (logObject.event.hasOwnProperty('type')) { + return 'event'; + } + } + } + return undefined; + }, + + // This was ported as-is, but It's weird that we're doing lithium logic in + // here. TODO: Please move this elsewhere. - ben + _pushToLithium : function (object) { + var lithiumEvent; + + if (typeof Li !== 'undefined') { + if (Li.stack) { + lithiumEvent = { + type : object.event.type, + instanceName : (object.event.data) ? (object.event.data.name || object.event.data.id || '---') : '---', + time : global.Cobalt.now() + }; + + Li.events.push(lithiumEvent); + Li.stack.push(lithiumEvent); + + // Another note: There was another push to Li.stack that checked if it + // was typeof === array. Which will never happen since array is typeof + // Object. But I could be wrong. So... yeah. That. + + if (Li.events.length > 20) { + Li.stack.shift(); + } + } + } + }, + + // Create the main structure, also push to lithium + _createStructure : function (logObject) { + var event = {}; + + this._pushToLithium(logObject); + + event.site_id = global.Client ? Client.pageInfo.site.id : 'client not found'; + event.event_type = logObject.event.type; + + event.data = logObject.event.data || {}; + event.data = this._process(event.data); + event.data.user_time_stamp = global.Cobalt.now(); + + event = this._addSiteData(event); + event = this._addTrackingData(event); + + event._type = 'event'; + + return event; + }, + + // Add required data from siteInfo + _addSiteData : function (event) { + if (typeof siteInfo !== 'undefined') { + event.data.trial_period_days_left = siteInfo.trialPeriodDaysLeft; + event.data.billing_status = siteInfo.billingStatus; + event.data.is_admin_on_trial = siteInfo.isAdminOnTrial; + event.data.is_new_site = siteInfo.isNewSite; + event.data.is_for_play = siteInfo.forPlay; + event.data.page_path = siteInfo.currentPagePath; + } + + return event; + }, + + // Add required tracking variables for ad campaigns and such + _addTrackingData : function (event) { + if (typeof siteInfo !== 'undefined' && siteInfo.trackingVariables) { + event.data.initial_referring_domain = siteInfo.trackingVariables.initial_referring_domain; + event.data.referrer = siteInfo.trackingVariables.referrer; + event.data.search_keyword = siteInfo.trackingVariables.search_keyword; + event.data.utm_campaign = siteInfo.trackingVariables.utm_campaign; + event.data.utm_content = siteInfo.trackingVariables.utm_content; + event.data.utm_medium = siteInfo.trackingVariables.utm_medium; + event.data.utm_source = siteInfo.trackingVariables.utm_source; + event.data.utm_term = siteInfo.trackingVariables.utm_term; + } + + return event; + }, + + // Send data through processors to extract valuable metadata + _process : function (data) { + if( typeof data !== 'undefined' && typeof data.constructor !== 'undefined' && typeof data.constructor.className !== 'undefined' ){ + switch( data.constructor.className ){ + case 'App': + return { meta: this._processApp(data) }; + + case 'Entry': + return { meta: this._processEntry(data) }; + + case 'Dot': + return { meta: this._processDot(data) }; + + case 'SiteSkin': + return { meta: this._processSiteSkin(data) }; + + case 'RepositorySkin': + return { meta: this._processRepositorySkin(data) }; + + default : + //do nothing and create an snapshot for the object + var snapshot = {}; + + $.each(data, function(i, el){ + if(typeof el === 'string' || typeof el === 'number' || typeof el === 'boolean'){ + snapshot[i] = el; + } + }); + + return { meta: { status: 'No processor for '+data.constructor.className, snapshot: snapshot } }; + } + + }else{ + // No process for you + return { meta: data }; + } + }, + + _processApp : function (data) { + var eventData = { + displayName : data.record.displayName, + repositoryAppId : data.record.repositoryApp().id, + repositoryAppName : data.record.repositoryApp().name + }; + + return { app: eventData }; + }, + + _processEntry : function (data) { + //get app data + var app = this.processApp( Client.page['app_' + data.appId] ); + + var entry = { + id : data.id, + fieldValues : {} + }; + + //parse and save fieldvalues + $.each(data.fieldValues, function(i, field){ + entry.fieldValues[field.fieldName] = field.value; + }); + + return {app: app, entry : entry}; + }, + + _processDot : function (data) { + var target = { type: data.ruleTree.type }; + + switch (target.type){ + case 'app' : + target.app = this.processApp( Client.page['app_'+data.ruleTree.id.replace('app_style_','')] ).app; + break; + } + + var dot = { + type: data.type, + name: data.name + }; + + return {target: target, dot : dot}; + }, + + _processSiteSkin : function (data) { + return { siteSkin : { + skinName: skinData.name, + skinId: skinData.id + } + }; + }, + + _processRepositorySkin : function (data) { + var skin = { + id : data.id, + name : data.name, + userName : data.userName, + acquireMode : data.acquireMode, + amountInCents : data.amountInCents, + featured : data.featured, + installCount : data.installCount, + popular : data.popular + }; + + return { repositorySkin: skin }; + } + }); + + if (Cobalt.Formatter.EventTracker.__objectSpy) { + Cobalt.Formatter.EventTracker.__objectSpy.destroy(); + } + + if (typeof require === 'function') { + global.EventTracker = Cobalt.Formatter.EventTracker; + } else { + global.Cobalt.Formatter.EventTracker = Cobalt.Formatter.EventTracker; + } +}(typeof window !== 'undefined' ? window : (typeof exports !== 'undefined' ? exports : self))); diff --git a/lib/formatters/token.js b/lib/formatters/token.js index 40d4f59..f562f1c 100644 --- a/lib/formatters/token.js +++ b/lib/formatters/token.js @@ -71,6 +71,10 @@ } }); + if (Cobalt.Formatter.Token.__objectSpy) { + Cobalt.Formatter.Token.__objectSpy.destroy(); + } + if (typeof require === 'function') { global.Token = Cobalt.Formatter.Token; } else { diff --git a/lib/loggers/console.js b/lib/loggers/console.js index 3dc4b1d..5002502 100644 --- a/lib/loggers/console.js +++ b/lib/loggers/console.js @@ -16,7 +16,7 @@ Cobalt.Logger.JsConsole = Class(Cobalt.Logger, 'JsConsole')({ prototype : { - console : console, + console : null, formatterOpts : {}, init : function (config) { @@ -30,12 +30,19 @@ } }, - log : function (logObject) { - var message; + log : function () { + var i, messageArray = [], message, severity; - message = this.format(logObject); + for (i = 0; i < arguments.length; i++) { + messageArray.push(this.format(arguments[i])); + if (!severity) { + severity = arguments[i]._level + } + } + + message = messageArray.join(' '); - switch (logObject._level){ + switch (severity){ case 0: case 1: case 2: @@ -68,6 +75,10 @@ } }); + if (Cobalt.Logger.JsConsole.__objectSpy) { + Cobalt.Logger.JsConsole.__objectSpy.destroy(); + } + if (typeof require === 'function') { global.JsConsole = Cobalt.Logger.JsConsole; } else { diff --git a/lib/loggers/socket.js b/lib/loggers/socket.js index 8d0ff55..d9ae055 100644 --- a/lib/loggers/socket.js +++ b/lib/loggers/socket.js @@ -22,12 +22,22 @@ this._socket = io.connect(this.serverUrl); }, - log : function (logObject) { - this._socket.emit('log', logObject); + log : function () { + var i, messageArray = []; + + for (i = 0; i < arguments.length; i++) { + messageArray.push(arguments[i]); + } + + this._socket.emit('log', messageArray); } } }); + if (Cobalt.Logger.Socket.__objectSpy) { + Cobalt.Logger.Socket.__objectSpy.destroy(); + } + if (typeof require === 'function') { global.Socket = Cobalt.Logger.Socket; } else {