aaac7fed
 liuqimichale
add
|
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
|
// Generated by CoffeeScript 1.12.7
(function() {
var XhrPollingReceiver, XhrStreamingReceiver, transport, utils,
extend = function(child, parent) { for (var key in parent) { if (hasProp.call(parent, key)) child[key] = parent[key]; } function ctor() { this.constructor = child; } ctor.prototype = parent.prototype; child.prototype = new ctor(); child.__super__ = parent.prototype; return child; },
hasProp = {}.hasOwnProperty;
transport = require('./transport');
utils = require('./utils');
XhrStreamingReceiver = (function(superClass) {
extend(XhrStreamingReceiver, superClass);
function XhrStreamingReceiver() {
return XhrStreamingReceiver.__super__.constructor.apply(this, arguments);
}
XhrStreamingReceiver.prototype.protocol = "xhr-streaming";
XhrStreamingReceiver.prototype.doSendFrame = function(payload) {
return XhrStreamingReceiver.__super__.doSendFrame.call(this, payload + '\n');
};
return XhrStreamingReceiver;
})(transport.ResponseReceiver);
XhrPollingReceiver = (function(superClass) {
extend(XhrPollingReceiver, superClass);
function XhrPollingReceiver() {
return XhrPollingReceiver.__super__.constructor.apply(this, arguments);
}
XhrPollingReceiver.prototype.protocol = "xhr-polling";
XhrPollingReceiver.prototype.max_response_size = 1;
return XhrPollingReceiver;
})(XhrStreamingReceiver);
exports.app = {
xhr_options: function(req, res) {
res.statusCode = 204;
res.setHeader('Access-Control-Allow-Methods', 'OPTIONS, POST');
res.setHeader('Access-Control-Max-Age', res.cache_for);
return '';
},
xhr_send: function(req, res, data) {
var d, i, jsonp, len, message, x;
if (!data) {
throw {
status: 500,
message: 'Payload expected.'
};
}
try {
d = JSON.parse(data);
} catch (error) {
x = error;
throw {
status: 500,
message: 'Broken JSON encoding.'
};
}
if (!d || d.__proto__.constructor !== Array) {
throw {
status: 500,
message: 'Payload expected.'
};
}
jsonp = transport.Session.bySessionId(req.session);
if (!jsonp) {
throw {
status: 404
};
}
for (i = 0, len = d.length; i < len; i++) {
message = d[i];
jsonp.didMessage(message);
}
res.setHeader('Content-Type', 'text/plain; charset=UTF-8');
res.writeHead(204);
res.end();
return true;
},
xhr_cors: function(req, res, content) {
var headers, origin;
if (this.options.disable_cors) {
return content;
}
if (!req.headers['origin']) {
origin = '*';
} else {
origin = req.headers['origin'];
res.setHeader('Access-Control-Allow-Credentials', 'true');
}
res.setHeader('Access-Control-Allow-Origin', origin);
res.setHeader('Vary', 'Origin');
headers = req.headers['access-control-request-headers'];
if (headers) {
res.setHeader('Access-Control-Allow-Headers', headers);
}
return content;
},
xhr_poll: function(req, res, _, next_filter) {
res.setHeader('Content-Type', 'application/javascript; charset=UTF-8');
res.writeHead(200);
transport.register(req, this, new XhrPollingReceiver(req, res, this.options));
return true;
},
xhr_streaming: function(req, res, _, next_filter) {
res.setHeader('Content-Type', 'application/javascript; charset=UTF-8');
res.writeHead(200);
res.write(Array(2049).join('h') + '\n');
transport.register(req, this, new XhrStreamingReceiver(req, res, this.options));
return true;
}
};
}).call(this);
|
