From cbdf009d46e53ed8de046a30f08896752bd63c5e Mon Sep 17 00:00:00 2001 From: Roy Hyunjin Han Date: Sun, 30 Nov 2014 05:17:22 -0500 Subject: [PATCH] Add content-type --- experiments/app.js | 1 + experiments/client1.py | 31 +++++++++++++++++++------------ experiments/proxy.js | 3 ++- 3 files changed, 22 insertions(+), 13 deletions(-) diff --git a/experiments/app.js b/experiments/app.js index 8beb129..4df4754 100644 --- a/experiments/app.js +++ b/experiments/app.js @@ -1,3 +1,4 @@ +// DEBUG=* node app.js var app = require('express')(); var server = require('http').Server(app); var io = require('socket.io')(server); diff --git a/experiments/client1.py b/experiments/client1.py index 55fd870..0a270d4 100644 --- a/experiments/client1.py +++ b/experiments/client1.py @@ -46,8 +46,10 @@ def get_timestamp(): return timestamp +base_url = 'http://localhost:8000' + + print '*** Connect' -base_url = 'http://localhost:9000' session = requests.Session() print session.cookies.items() url = base_url + '/socket.io/' @@ -70,8 +72,6 @@ print packet_json['sid'] assert packet_type == 0 -"" -base_url = 'http://localhost:9000' url = base_url + '/socket.io/' response = session.get(url, params={ 'EIO': 3, @@ -105,11 +105,14 @@ def make_header(content): for index in xrange(len(length_string)): header_digits.append(ord(length_string[index]) - 48) header_digits.append(255) + print '---' + for x in header_digits: + print str(x) + print '---' return ''.join(chr(x) for x in header_digits) # print '***' -# base_url = 'http://localhost:9000' # url = base_url + '/socket.io/' # response = session.get(url, params={ # 'EIO': 3, @@ -130,7 +133,6 @@ packets = [ ] payload = encode_payload(packets) print payload -base_url = 'http://localhost:9000' url = base_url + '/socket.io/' print session.cookies.items() response = session.post(url, params={ @@ -138,7 +140,9 @@ response = session.post(url, params={ 'transport': 'polling', 't': get_timestamp(), 'sid': packet_json['sid'], -}, data=payload) +}, data=payload, headers={ + 'content-type': 'application/octet-stream', +}) print response.url print response.content @@ -152,7 +156,6 @@ packets = [ ] payload = encode_payload(packets) print payload -base_url = 'http://localhost:9000' url = base_url + '/socket.io/' print session.cookies.items() response = session.post(url, params={ @@ -160,7 +163,9 @@ response = session.post(url, params={ 'transport': 'polling', 't': get_timestamp(), 'sid': packet_json['sid'], -}, data=payload) +}, data=payload, headers={ + 'content-type': 'application/octet-stream', +}) print response.url print response.content @@ -172,14 +177,15 @@ packets = [ ] payload = encode_payload(packets) print payload -base_url = 'http://localhost:9000' url = base_url + '/socket.io/' response = session.post(url, params={ 'EIO': 3, 'transport': 'polling', 't': get_timestamp(), 'sid': packet_json['sid'], -}, data=payload) +}, data=payload, headers={ + 'content-type': 'application/octet-stream', +}) print response.url print response.content # packets = get_packets(response.content) @@ -193,14 +199,15 @@ packets = [ ] payload = encode_payload(packets) print payload -base_url = 'http://localhost:9000' url = base_url + '/socket.io/' response = session.post(url, params={ 'EIO': 3, 'transport': 'polling', 't': get_timestamp(), 'sid': packet_json['sid'], -}, data=payload) +}, data=payload, headers={ + 'content-type': 'application/octet-stream', +}) print response.url print response.content """ diff --git a/experiments/proxy.js b/experiments/proxy.js index 4dec919..756da12 100644 --- a/experiments/proxy.js +++ b/experiments/proxy.js @@ -2,7 +2,8 @@ var proxy = require('http-proxy').createProxyServer({ target: {host: 'localhost', port: 9000} }); var server = require('http').createServer(function(req, res) { - console.log('[REQUEST] ' + req.url); + console.log('[REQUEST.%s] %s', req.method, req.url); + console.log(req['headers']); if (req.method == 'POST') { var body = ''; req.on('data', function (data) {