1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
|
//>>built
define("dojox/analytics/_base", ["dojo/_base/lang", "dojo/_base/config", "dojo/ready", "dojo/_base/unload",
"dojo/_base/sniff", "dojo/_base/xhr", "dojo/_base/json", "dojo/io-query", "dojo/io/script"
], function(lang, config, ready, unload, has, xhr, json, ioQuery, scriptIO){
/*=====
ready = dojo.ready;
ioQuery = dojo/io-query;
scriptIO = dojo/io/script;
=====*/
var Analytics = function(){
// summary: TODOC
// where we store data until we're ready to send it off.
//
//the data queue;
this._data = [];
//id of messages for this session/page
this._id = 1;
//some default values
this.sendInterval = config["sendInterval"] || 5000;
this.inTransitRetry = config["inTransitRetry"] || 200;
this.dataUrl = config["analyticsUrl"] || require.toUrl("dojox/analytics/logger/dojoxAnalytics.php");
this.sendMethod = config["sendMethod"] || "xhrPost";
this.maxRequestSize = has("ie") ? 2000 : config["maxRequestSize"] || 4000;
//while we can go ahead and being logging as soon as this constructor is completed
//we're not going to schedule pushing data to the server until after the page
//has completed loading
ready(this, "schedulePusher");
unload.addOnUnload(this, "pushData", true);
};
lang.extend(Analytics, {
schedulePusher: function(/* Int */interval){
// summary: Schedule the data pushing routines to happen in interval ms
setTimeout(lang.hitch(this, "checkData"), interval || this.sendInterval);
},
addData: function(dataType, data){
// summary:
// add data to the queue. Will be pusshed to the server on the next
// data push
if(arguments.length > 2){
// FIXME: var c = dojo._toArray(arguments) ?
var c = [];
for(var i = 1; i < arguments.length; i++){
c.push(arguments[i]);
}
data = c;
}
this._data.push({ plugin: dataType, data: data });
},
checkData: function(){
// summary: TODOC?
if(this._inTransit){
this.schedulePusher(this.inTransitRetry);
return;
}
if(this.pushData()){ return; }
this.schedulePusher();
},
pushData: function(){
// summary:
// pushes data to the server if any exists. If a push is done, return
// the deferred after hooking up completion callbacks. If there is no data
// to be pushed, return false;
if(this._data.length){
//clear the queue
this._inTransit = this._data;
this._data = [];
var def;
switch(this.sendMethod){
case "script":
def = scriptIO.get({
url: this.getQueryPacket(),
preventCache: 1,
callbackParamName: "callback"
});
break;
case "xhrPost":
default:
def = xhr.post({
url:this.dataUrl,
content:{
id: this._id++,
data: json.toJson(this._inTransit)
}
});
break;
}
def.addCallback(this, "onPushComplete");
return def;
}
return false;
},
getQueryPacket: function(){
// summary: TODOC
while(true){
var content = {
id: this._id++,
data: json.toJson(this._inTransit)
};
//FIXME would like a much better way to get the query down to length
var query = this.dataUrl + '?' + ioQuery.objectToQuery(content);
if(query.length > this.maxRequestSize){
this._data.unshift(this._inTransit.pop());
this._split = 1;
}else{
return query;
}
}
},
onPushComplete: function(results){
// summary:
// If our data push was successfully, remove the _inTransit data and schedule the next
// parser run.
if(this._inTransit){
delete this._inTransit;
}
if(this._data.length > 0){
this.schedulePusher(this.inTransitRetry);
}else{
this.schedulePusher();
}
}
});
//create the analytics singleton
return lang.setObject("dojox.analytics",new Analytics());
});
|
