You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by da...@apache.org on 2015/11/30 22:06:25 UTC
[19/98] [abbrv] [partial] incubator-apex-malhar git commit: Removing
all web demos
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/http-proxy/test/core/simple/test-http-set-cookies.js
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/http-proxy/test/core/simple/test-http-set-cookies.js b/web/demos/package/node_modules/http-proxy/test/core/simple/test-http-set-cookies.js
deleted file mode 100644
index aac2994..0000000
--- a/web/demos/package/node_modules/http-proxy/test/core/simple/test-http-set-cookies.js
+++ /dev/null
@@ -1,84 +0,0 @@
-// Copyright Joyent, Inc. and other Node contributors.
-//
-// Permission is hereby granted, free of charge, to any person obtaining a
-// copy of this software and associated documentation files (the
-// "Software"), to deal in the Software without restriction, including
-// without limitation the rights to use, copy, modify, merge, publish,
-// distribute, sublicense, and/or sell copies of the Software, and to permit
-// persons to whom the Software is furnished to do so, subject to the
-// following conditions:
-//
-// The above copyright notice and this permission notice shall be included
-// in all copies or substantial portions of the Software.
-//
-// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
-// OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
-// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN
-// NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
-// DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR
-// OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE
-// USE OR OTHER DEALINGS IN THE SOFTWARE.
-
-var common = require('../common');
-var assert = require('assert');
-var http = require('http');
-
-var nresponses = 0;
-
-var server = http.createServer(function (req, res) {
- if (req.url == '/one') {
- res.writeHead(200, [['set-cookie', 'A'],
- ['content-type', 'text/plain']]);
- res.end('one\n');
- } else {
- res.writeHead(200, [['set-cookie', 'A'],
- ['set-cookie', 'B'],
- ['content-type', 'text/plain']]);
- res.end('two\n');
- }
-});
-server.listen(common.PORT);
-
-server.on('listening', function () {
- //
- // one set-cookie header
- //
- http.get({ port: common.PROXY_PORT, path: '/one' }, function (res) {
- // set-cookie headers are always return in an array.
- // even if there is only one.
- assert.deepEqual(['A'], res.headers['set-cookie']);
- assert.equal('text/plain', res.headers['content-type']);
-
- res.on('data', function (chunk) {
- console.log(chunk.toString());
- });
-
- res.on('end', function () {
- if (++nresponses == 2) {
- server.close();
- }
- });
- });
-
- // two set-cookie headers
-
- http.get({ port: common.PROXY_PORT, path: '/two' }, function (res) {
- assert.deepEqual(['A', 'B'], res.headers['set-cookie']);
- assert.equal('text/plain', res.headers['content-type']);
-
- res.on('data', function (chunk) {
- console.log(chunk.toString());
- });
-
- res.on('end', function () {
- if (++nresponses == 2) {
- server.close();
- }
- });
- });
-
-});
-
-process.on('exit', function () {
- assert.equal(2, nresponses);
-});
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/http-proxy/test/core/simple/test-http-status-code.js
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/http-proxy/test/core/simple/test-http-status-code.js b/web/demos/package/node_modules/http-proxy/test/core/simple/test-http-status-code.js
deleted file mode 100644
index dffbaf7..0000000
--- a/web/demos/package/node_modules/http-proxy/test/core/simple/test-http-status-code.js
+++ /dev/null
@@ -1,69 +0,0 @@
-// Copyright Joyent, Inc. and other Node contributors.
-//
-// Permission is hereby granted, free of charge, to any person obtaining a
-// copy of this software and associated documentation files (the
-// "Software"), to deal in the Software without restriction, including
-// without limitation the rights to use, copy, modify, merge, publish,
-// distribute, sublicense, and/or sell copies of the Software, and to permit
-// persons to whom the Software is furnished to do so, subject to the
-// following conditions:
-//
-// The above copyright notice and this permission notice shall be included
-// in all copies or substantial portions of the Software.
-//
-// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
-// OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
-// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN
-// NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
-// DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR
-// OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE
-// USE OR OTHER DEALINGS IN THE SOFTWARE.
-
-// libuv-broken
-
-
-var common = require('../common');
-var assert = require('assert');
-var http = require('http');
-
-// Simple test of Node's HTTP ServerResponse.statusCode
-// ServerResponse.prototype.statusCode
-
-var testsComplete = 0;
-var tests = [200, 202, 300, 404, 500];
-var testIdx = 0;
-
-var s = http.createServer(function (req, res) {
- var t = tests[testIdx];
- res.writeHead(t, {'Content-Type': 'text/plain'});
- console.log('--\nserver: statusCode after writeHead: ' + res.statusCode);
- assert.equal(res.statusCode, t);
- res.end('hello world\n');
-});
-
-s.listen(common.PORT, nextTest);
-
-
-function nextTest() {
- if (testIdx + 1 === tests.length) {
- return s.close();
- }
- var test = tests[testIdx];
-
- http.get({ port: common.PROXY_PORT }, function (response) {
- console.log('client: expected status: ' + test);
- console.log('client: statusCode: ' + response.statusCode);
- assert.equal(response.statusCode, test);
- response.on('end', function () {
- testsComplete++;
- testIdx += 1;
- nextTest();
- });
- });
-}
-
-
-process.on('exit', function () {
- assert.equal(4, testsComplete);
-});
-
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/http-proxy/test/core/simple/test-http-upgrade-server2.js
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/http-proxy/test/core/simple/test-http-upgrade-server2.js b/web/demos/package/node_modules/http-proxy/test/core/simple/test-http-upgrade-server2.js
deleted file mode 100644
index a527376..0000000
--- a/web/demos/package/node_modules/http-proxy/test/core/simple/test-http-upgrade-server2.js
+++ /dev/null
@@ -1,72 +0,0 @@
-// Copyright Joyent, Inc. and other Node contributors.
-//
-// Permission is hereby granted, free of charge, to any person obtaining a
-// copy of this software and associated documentation files (the
-// "Software"), to deal in the Software without restriction, including
-// without limitation the rights to use, copy, modify, merge, publish,
-// distribute, sublicense, and/or sell copies of the Software, and to permit
-// persons to whom the Software is furnished to do so, subject to the
-// following conditions:
-//
-// The above copyright notice and this permission notice shall be included
-// in all copies or substantial portions of the Software.
-//
-// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
-// OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
-// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN
-// NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
-// DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR
-// OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE
-// USE OR OTHER DEALINGS IN THE SOFTWARE.
-
-var common = require('../common');
-var assert = require('assert');
-var http = require('http');
-var net = require('net');
-
-var server = http.createServer(function (req, res) {
- common.error('got req');
- throw new Error('This shouldn\'t happen.');
-});
-
-server.on('upgrade', function (req, socket, upgradeHead) {
- common.error('got upgrade event');
- // test that throwing an error from upgrade gets
- // is uncaught
- throw new Error('upgrade error');
-});
-
-var gotError = false;
-
-process.on('uncaughtException', function (e) {
- common.error('got \'clientError\' event');
- assert.equal('upgrade error', e.message);
- gotError = true;
- process.exit(0);
-});
-
-
-server.listen(common.PORT, function () {
- var c = net.createConnection(common.PROXY_PORT);
-
- c.on('connect', function () {
- common.error('client wrote message');
- c.write('GET /blah HTTP/1.1\r\n' +
- 'Upgrade: WebSocket\r\n' +
- 'Connection: Upgrade\r\n' +
- '\r\n\r\nhello world');
- });
-
- c.on('end', function () {
- c.end();
- });
-
- c.on('close', function () {
- common.error('client close');
- server.close();
- });
-});
-
-process.on('exit', function () {
- assert.ok(gotError);
-});
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/http-proxy/test/core/simple/test-http.js
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/http-proxy/test/core/simple/test-http.js b/web/demos/package/node_modules/http-proxy/test/core/simple/test-http.js
deleted file mode 100644
index e082eb2..0000000
--- a/web/demos/package/node_modules/http-proxy/test/core/simple/test-http.js
+++ /dev/null
@@ -1,108 +0,0 @@
-// Copyright Joyent, Inc. and other Node contributors.
-//
-// Permission is hereby granted, free of charge, to any person obtaining a
-// copy of this software and associated documentation files (the
-// "Software"), to deal in the Software without restriction, including
-// without limitation the rights to use, copy, modify, merge, publish,
-// distribute, sublicense, and/or sell copies of the Software, and to permit
-// persons to whom the Software is furnished to do so, subject to the
-// following conditions:
-//
-// The above copyright notice and this permission notice shall be included
-// in all copies or substantial portions of the Software.
-//
-// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
-// OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
-// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN
-// NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
-// DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR
-// OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE
-// USE OR OTHER DEALINGS IN THE SOFTWARE.
-
-var common = require('../common');
-var assert = require('assert');
-var http = require('http');
-var url = require('url');
-
-function p(x) {
- common.error(common.inspect(x));
-}
-
-var responses_sent = 0;
-var responses_recvd = 0;
-var body0 = '';
-var body1 = '';
-
-var server = http.Server(function (req, res) {
- if (responses_sent == 0) {
- assert.equal('GET', req.method);
- assert.equal('/hello', url.parse(req.url).pathname);
-
- console.dir(req.headers);
- assert.equal(true, 'accept' in req.headers);
- assert.equal('*/*', req.headers['accept']);
-
- assert.equal(true, 'foo' in req.headers);
- assert.equal('bar', req.headers['foo']);
- }
-
- if (responses_sent == 1) {
- assert.equal('POST', req.method);
- assert.equal('/world', url.parse(req.url).pathname);
- this.close();
- }
-
- req.on('end', function () {
- res.writeHead(200, {'Content-Type': 'text/plain'});
- res.write('The path was ' + url.parse(req.url).pathname);
- res.end();
- responses_sent += 1;
- });
-
- //assert.equal('127.0.0.1', res.connection.remoteAddress);
-});
-server.listen(common.PORT);
-
-server.on('listening', function () {
- var agent = new http.Agent({ port: common.PROXY_PORT, maxSockets: 1 });
- http.get({
- port: common.PROXY_PORT,
- path: '/hello',
- headers: {'Accept': '*/*', 'Foo': 'bar'},
- agent: agent
- }, function (res) {
- assert.equal(200, res.statusCode);
- responses_recvd += 1;
- res.setEncoding('utf8');
- res.on('data', function (chunk) { body0 += chunk; });
- common.debug('Got /hello response');
- });
-
- setTimeout(function () {
- var req = http.request({
- port: common.PROXY_PORT,
- method: 'POST',
- path: '/world',
- agent: agent
- }, function (res) {
- assert.equal(200, res.statusCode);
- responses_recvd += 1;
- res.setEncoding('utf8');
- res.on('data', function (chunk) { body1 += chunk; });
- common.debug('Got /world response');
- });
- req.end();
- }, 1);
-});
-
-process.on('exit', function () {
- common.debug('responses_recvd: ' + responses_recvd);
- assert.equal(2, responses_recvd);
-
- common.debug('responses_sent: ' + responses_sent);
- assert.equal(2, responses_sent);
-
- assert.equal('The path was /hello', body0);
- assert.equal('The path was /world', body1);
-});
-
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/http-proxy/test/examples-test.js
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/http-proxy/test/examples-test.js b/web/demos/package/node_modules/http-proxy/test/examples-test.js
deleted file mode 100644
index 36beb89..0000000
--- a/web/demos/package/node_modules/http-proxy/test/examples-test.js
+++ /dev/null
@@ -1,26 +0,0 @@
-/*
- * examples.js: Tests which ensure all examples do not throw errors.
- *
- * (C) 2010, Charlie Robbins
- *
- */
-
-var vows = require('vows')
- macros = require('./macros'),
- examples = macros.examples;
-
-//
-// Suppress `EADDRINUSE` errors since
-// we are just checking for require-time errors
-//
-process.on('uncaughtException', function (err) {
- if (err.code !== 'EADDRINUSE') {
- throw err;
- }
-});
-
-vows.describe('node-http-proxy/examples').addBatch(
- examples.shouldHaveDeps()
-).addBatch(
- examples.shouldHaveNoErrors()
-).export(module);
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/http-proxy/test/fixtures/agent2-cert.pem
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/http-proxy/test/fixtures/agent2-cert.pem b/web/demos/package/node_modules/http-proxy/test/fixtures/agent2-cert.pem
deleted file mode 100644
index 8e4354d..0000000
--- a/web/demos/package/node_modules/http-proxy/test/fixtures/agent2-cert.pem
+++ /dev/null
@@ -1,13 +0,0 @@
------BEGIN CERTIFICATE-----
-MIIB7DCCAZYCCQC7gs0MDNn6MTANBgkqhkiG9w0BAQUFADB9MQswCQYDVQQGEwJV
-UzELMAkGA1UECBMCQ0ExCzAJBgNVBAcTAlNGMQ8wDQYDVQQKEwZKb3llbnQxEDAO
-BgNVBAsTB05vZGUuanMxDzANBgNVBAMTBmFnZW50MjEgMB4GCSqGSIb3DQEJARYR
-cnlAdGlueWNsb3Vkcy5vcmcwHhcNMTEwMzE0MTgyOTEyWhcNMzgwNzI5MTgyOTEy
-WjB9MQswCQYDVQQGEwJVUzELMAkGA1UECBMCQ0ExCzAJBgNVBAcTAlNGMQ8wDQYD
-VQQKEwZKb3llbnQxEDAOBgNVBAsTB05vZGUuanMxDzANBgNVBAMTBmFnZW50MjEg
-MB4GCSqGSIb3DQEJARYRcnlAdGlueWNsb3Vkcy5vcmcwXDANBgkqhkiG9w0BAQEF
-AANLADBIAkEAyXb8FrRdKbhrKLgLSsn61i1C7w7fVVVd7OQsmV/7p9WB2lWFiDlC
-WKGU9SiIz/A6wNZDUAuc2E+VwtpCT561AQIDAQABMA0GCSqGSIb3DQEBBQUAA0EA
-C8HzpuNhFLCI3A5KkBS5zHAQax6TFUOhbpBCR0aTDbJ6F1liDTK1lmU/BjvPoj+9
-1LHwrmh29rK8kBPEjmymCQ==
------END CERTIFICATE-----
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/http-proxy/test/fixtures/agent2-csr.pem
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/http-proxy/test/fixtures/agent2-csr.pem b/web/demos/package/node_modules/http-proxy/test/fixtures/agent2-csr.pem
deleted file mode 100644
index a670c4c..0000000
--- a/web/demos/package/node_modules/http-proxy/test/fixtures/agent2-csr.pem
+++ /dev/null
@@ -1,10 +0,0 @@
------BEGIN CERTIFICATE REQUEST-----
-MIIBXTCCAQcCAQAwfTELMAkGA1UEBhMCVVMxCzAJBgNVBAgTAkNBMQswCQYDVQQH
-EwJTRjEPMA0GA1UEChMGSm95ZW50MRAwDgYDVQQLEwdOb2RlLmpzMQ8wDQYDVQQD
-EwZhZ2VudDIxIDAeBgkqhkiG9w0BCQEWEXJ5QHRpbnljbG91ZHMub3JnMFwwDQYJ
-KoZIhvcNAQEBBQADSwAwSAJBAMl2/Ba0XSm4ayi4C0rJ+tYtQu8O31VVXezkLJlf
-+6fVgdpVhYg5QlihlPUoiM/wOsDWQ1ALnNhPlcLaQk+etQECAwEAAaAlMCMGCSqG
-SIb3DQEJBzEWExRBIGNoYWxsZW5nZSBwYXNzd29yZDANBgkqhkiG9w0BAQUFAANB
-AJnll2pt5l0pzskQSpjjLVTlFDFmJr/AZ3UK8v0WxBjYjCe5Jx4YehkChpxIyDUm
-U3J9q9MDUf0+Y2+EGkssFfk=
------END CERTIFICATE REQUEST-----
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/http-proxy/test/fixtures/agent2-key.pem
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/http-proxy/test/fixtures/agent2-key.pem b/web/demos/package/node_modules/http-proxy/test/fixtures/agent2-key.pem
deleted file mode 100644
index 522903c..0000000
--- a/web/demos/package/node_modules/http-proxy/test/fixtures/agent2-key.pem
+++ /dev/null
@@ -1,9 +0,0 @@
------BEGIN RSA PRIVATE KEY-----
-MIIBOgIBAAJBAMl2/Ba0XSm4ayi4C0rJ+tYtQu8O31VVXezkLJlf+6fVgdpVhYg5
-QlihlPUoiM/wOsDWQ1ALnNhPlcLaQk+etQECAwEAAQJBAMT6Bf34+UHKY1ObpsbH
-9u2jsVblFq1rWvs8GPMY6oertzvwm3DpuSUp7PTgOB1nLTLYtCERbQ4ovtN8tn3p
-OHUCIQDzIEGsoCr5vlxXvy2zJwu+fxYuhTZWMVuo1397L0VyhwIhANQh+yzqUgaf
-WRtSB4T2W7ADtJI35ET61jKBty3CqJY3AiAIwju7dVW3A5WeD6Qc1SZGKZvp9yCb
-AFI2BfVwwaY11wIgXF3PeGcvACMyMWsuSv7aPXHfliswAbkWuzcwA4TW01ECIGWa
-cgsDvVFxmfM5NPSuT/UDTa6R5BFISB5ea0N0AR3I
------END RSA PRIVATE KEY-----
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/http-proxy/test/fixtures/agent2.cnf
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/http-proxy/test/fixtures/agent2.cnf b/web/demos/package/node_modules/http-proxy/test/fixtures/agent2.cnf
deleted file mode 100644
index 0a9f2c7..0000000
--- a/web/demos/package/node_modules/http-proxy/test/fixtures/agent2.cnf
+++ /dev/null
@@ -1,19 +0,0 @@
-[ req ]
-default_bits = 1024
-days = 999
-distinguished_name = req_distinguished_name
-attributes = req_attributes
-prompt = no
-
-[ req_distinguished_name ]
-C = US
-ST = CA
-L = SF
-O = Joyent
-OU = Node.js
-CN = agent2
-emailAddress = ry@tinyclouds.org
-
-[ req_attributes ]
-challengePassword = A challenge password
-
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/http-proxy/test/helpers/http.js
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/http-proxy/test/helpers/http.js b/web/demos/package/node_modules/http-proxy/test/helpers/http.js
deleted file mode 100644
index aaf7a80..0000000
--- a/web/demos/package/node_modules/http-proxy/test/helpers/http.js
+++ /dev/null
@@ -1,182 +0,0 @@
-/*
- * http.js: Top level include for node-http-proxy http helpers
- *
- * (C) 2010 Nodejitsu Inc.
- * MIT LICENCE
- *
- */
-
-var assert = require('assert'),
- http = require('http'),
- https = require('https'),
- url = require('url'),
- async = require('async'),
- helpers = require('./index'),
- protocols = helpers.protocols,
- httpProxy = require('../../lib/node-http-proxy');
-
-//
-// ### function createServerPair (options, callback)
-// #### @options {Object} Options to create target and proxy server.
-// #### @callback {function} Continuation to respond to when complete.
-//
-// Creates http target and proxy servers
-//
-exports.createServerPair = function (options, callback) {
- async.series([
- //
- // 1. Create the target server
- //
- function createTarget(next) {
- exports.createServer(options.target, next);
- },
- //
- // 2. Create the proxy server
- //
- function createTarget(next) {
- exports.createProxyServer(options.proxy, next);
- }
- ], callback);
-};
-
-//
-// ### function createServer (options, callback)
-// #### @options {Object} Options for creatig an http server.
-// #### @port {number} Port to listen on
-// #### @output {string} String to write to each HTTP response
-// #### @headers {Object} Headers to assert are sent by `node-http-proxy`.
-// #### @callback {function} Continuation to respond to when complete.
-//
-// Creates a target server that the tests will proxy to.
-//
-exports.createServer = function (options, callback) {
- //
- // Request handler to use in either `http`
- // or `https` server.
- //
- function requestHandler(req, res) {
- if (options.headers) {
- Object.keys(options.headers).forEach(function (key) {
- assert.equal(req.headers[key], options.headers[key]);
- });
- }
-
- if (options.outputHeaders) {
- Object.keys(options.outputHeaders).forEach(function (header) {
- res.setHeader(header, options.outputHeaders[header]);
- });
- }
-
- setTimeout(function() {
- res.writeHead(200, { 'Content-Type': 'text/plain' });
- res.write(options.output || 'hello proxy');
- res.end();
- }, options.latency || 1);
- }
-
- var server = protocols.target === 'https'
- ? https.createServer(helpers.https, requestHandler)
- : http.createServer(requestHandler);
-
- server.listen(options.port, function () {
- callback(null, this);
- });
-};
-
-//
-// ### function createProxyServer (options, callback)
-// #### @options {Object} Options for creatig an http server.
-// #### @port {number} Port to listen on
-// #### @latency {number} Latency of this server in milliseconds
-// #### @proxy {Object} Options to pass to the HttpProxy.
-// #### @routing {boolean} Enables `httpProxy.RoutingProxy`
-// #### @callback {function} Continuation to respond to when complete.
-//
-// Creates a proxy server that the tests will request against.
-//
-exports.createProxyServer = function (options, callback) {
- if (!options.latency) {
- if (protocols.proxy === 'https') {
- options.proxy.https = helpers.https;
- }
- options.proxy.rejectUnauthorized = false;
-
- return httpProxy
- .createServer(options.proxy)
- .listen(options.port, function () {
- callback(null, this);
- });
- }
-
- var server,
- proxy;
-
- proxy = options.routing
- ? new httpProxy.RoutingProxy(options.proxy)
- : new httpProxy.HttpProxy(options.proxy);
-
- //
- // Request handler to use in either `http`
- // or `https` server.
- //
- function requestHandler(req, res) {
- var buffer = httpProxy.buffer(req);
-
- if (options.outputHeaders) {
- Object.keys(options.outputHeaders).forEach(function (header) {
- res.setHeader(header, options.outputHeaders[header]);
- });
- }
- setTimeout(function () {
- //
- // Setup options dynamically for `RoutingProxy.prototype.proxyRequest`
- // or `HttpProxy.prototype.proxyRequest`.
- //
- buffer = options.routing ? { buffer: buffer } : buffer;
- proxy.proxyRequest(req, res, buffer);
- }, options.latency);
- }
-
- server = protocols.proxy === 'https'
- ? https.createServer(helpers.https, requestHandler)
- : http.createServer(requestHandler);
-
- server.listen(options.port, function () {
- callback(null, this);
- });
-};
-
-//
-// ### function assignPortsToRoutes (routes)
-// #### @routes {Object} Routing table to assign ports to
-//
-// Assigns dynamic ports to the `routes` for runtime testing.
-//
-exports.assignPortsToRoutes = function (routes) {
- Object.keys(routes).forEach(function (source) {
- routes[source] = routes[source].replace('{PORT}', helpers.nextPort);
- });
-
- return routes;
-};
-
-//
-// ### function parseRoutes (options)
-// #### @options {Object} Options to use when parsing routes
-// #### @protocol {string} Protocol to use in the routes
-// #### @routes {Object} Routes to parse.
-//
-// Returns an Array of fully-parsed URLs for the source and
-// target of `options.routes`.
-//
-exports.parseRoutes = function (options) {
- var protocol = options.protocol || 'http',
- routes = options.routes;
-
- return Object.keys(routes).map(function (source) {
- return {
- source: url.parse(protocol + '://' + source),
- target: url.parse(protocol + '://' + routes[source])
- };
- });
-};
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/http-proxy/test/helpers/index.js
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/http-proxy/test/helpers/index.js b/web/demos/package/node_modules/http-proxy/test/helpers/index.js
deleted file mode 100644
index 7e3c3f4..0000000
--- a/web/demos/package/node_modules/http-proxy/test/helpers/index.js
+++ /dev/null
@@ -1,105 +0,0 @@
-/*
- * index.js: Top level include for node-http-proxy helpers
- *
- * (C) 2010 Nodejitsu Inc.
- * MIT LICENCE
- *
- */
-
-var fs = require('fs'),
- path = require('path');
-
-var fixturesDir = path.join(__dirname, '..', 'fixtures');
-
-//
-// @https {Object}
-// Returns the necessary `https` credentials.
-//
-Object.defineProperty(exports, 'https', {
- get: function () {
- delete this.https;
- return this.https = {
- key: fs.readFileSync(path.join(fixturesDir, 'agent2-key.pem'), 'utf8'),
- cert: fs.readFileSync(path.join(fixturesDir, 'agent2-cert.pem'), 'utf8')
- };
- }
-});
-
-//
-// @protocols {Object}
-// Returns an object representing the desired protocols
-// for the `proxy` and `target` server.
-//
-Object.defineProperty(exports, 'protocols', {
- get: function () {
- delete this.protocols;
- return this.protocols = {
- target: exports.argv.target || 'http',
- proxy: exports.argv.proxy || 'http'
- };
- }
-});
-
-//
-// @nextPort {number}
-// Returns an auto-incrementing port for tests.
-//
-Object.defineProperty(exports, 'nextPort', {
- get: function () {
- var current = this.port || 9050;
- this.port = current + 1;
- return current;
- }
-});
-
-//
-// @nextPortPair {Object}
-// Returns an auto-incrementing pair of ports for tests.
-//
-Object.defineProperty(exports, 'nextPortPair', {
- get: function () {
- return {
- target: this.nextPort,
- proxy: this.nextPort
- };
- }
-});
-
-//
-// ### function describe(prefix)
-// #### @prefix {string} Prefix to use before the description
-//
-// Returns a string representing the protocols that this suite
-// is testing based on CLI arguments.
-//
-exports.describe = function (prefix, base) {
- prefix = prefix || '';
- base = base || 'http';
-
- function protocol(endpoint) {
- return exports.protocols[endpoint] === 'https'
- ? base + 's'
- : base;
- }
-
- return [
- 'node-http-proxy',
- prefix,
- [
- protocol('proxy'),
- '-to-',
- protocol('target')
- ].join('')
- ].filter(Boolean).join('/');
-};
-
-//
-// Expose the CLI arguments
-//
-exports.argv = require('optimist').argv;
-
-//
-// Export additional helpers for `http` and `websockets`.
-//
-exports.http = require('./http');
-exports.ws = require('./ws');
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/http-proxy/test/helpers/ws.js
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/http-proxy/test/helpers/ws.js b/web/demos/package/node_modules/http-proxy/test/helpers/ws.js
deleted file mode 100644
index a490522..0000000
--- a/web/demos/package/node_modules/http-proxy/test/helpers/ws.js
+++ /dev/null
@@ -1,112 +0,0 @@
-/*
- * ws.js: Top level include for node-http-proxy websocket helpers
- *
- * (C) 2010 Nodejitsu Inc.
- * MIT LICENCE
- *
- */
-
-var assert = require('assert'),
- https = require('https'),
- async = require('async'),
- io = require('socket.io'),
- ws = require('ws'),
- helpers = require('./index'),
- protocols = helpers.protocols,
- http = require('./http');
-
-//
-// ### function createServerPair (options, callback)
-// #### @options {Object} Options to create target and proxy server.
-// #### @target {Object} Options for the target server.
-// #### @proxy {Object} Options for the proxy server.
-// #### @callback {function} Continuation to respond to when complete.
-//
-// Creates http target and proxy servers
-//
-exports.createServerPair = function (options, callback) {
- async.series([
- //
- // 1. Create the target server
- //
- function createTarget(next) {
- exports.createServer(options.target, next);
- },
- //
- // 2. Create the proxy server
- //
- function createTarget(next) {
- http.createProxyServer(options.proxy, next);
- }
- ], callback);
-};
-
-//
-// ### function createServer (options, callback)
-// #### @options {Object} Options for creating the socket.io or ws server.
-// #### @raw {boolean} Enables ws.Websocket server.
-//
-// Creates a socket.io or ws server using the specified `options`.
-//
-exports.createServer = function (options, callback) {
- return options.raw
- ? exports.createWsServer(options, callback)
- : exports.createSocketIoServer(options, callback);
-};
-
-//
-// ### function createSocketIoServer (options, callback)
-// #### @options {Object} Options for creating the socket.io server
-// #### @port {number} Port to listen on
-// #### @input {string} Input to expect from the only socket
-// #### @output {string} Output to send the only socket
-//
-// Creates a socket.io server on the specified `options.port` which
-// will expect `options.input` and then send `options.output`.
-//
-exports.createSocketIoServer = function (options, callback) {
- var server = protocols.target === 'https'
- ? io.listen(options.port, helpers.https, callback)
- : io.listen(options.port, callback);
-
- server.sockets.on('connection', function (socket) {
- socket.on('incoming', function (data) {
- assert.equal(data, options.input);
- socket.emit('outgoing', options.output);
- });
- });
-};
-
-//
-// ### function createWsServer (options, callback)
-// #### @options {Object} Options for creating the ws.Server instance
-// #### @port {number} Port to listen on
-// #### @input {string} Input to expect from the only socket
-// #### @output {string} Output to send the only socket
-//
-// Creates a ws.Server instance on the specified `options.port` which
-// will expect `options.input` and then send `options.output`.
-//
-exports.createWsServer = function (options, callback) {
- var server,
- wss;
-
- if (protocols.target === 'https') {
- server = https.createServer(helpers.https, function (req, res) {
- req.writeHead(200);
- req.end();
- }).listen(options.port, callback);
-
- wss = new ws.Server({ server: server });
- }
- else {
- wss = new ws.Server({ port: options.port }, callback);
- }
-
- wss.on('connection', function (socket) {
- socket.on('message', function (data) {
- assert.equal(data, options.input);
- socket.send(options.output);
- });
- });
-};
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/http-proxy/test/http/http-test.js
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/http-proxy/test/http/http-test.js b/web/demos/package/node_modules/http-proxy/test/http/http-test.js
deleted file mode 100644
index 81f8726..0000000
--- a/web/demos/package/node_modules/http-proxy/test/http/http-test.js
+++ /dev/null
@@ -1,102 +0,0 @@
-/*
- node-http-proxy-test.js: http proxy for node.js
-
- Copyright (c) 2010 Charlie Robbins, Marak Squires and Fedor Indutny
-
- Permission is hereby granted, free of charge, to any person obtaining
- a copy of this software and associated documentation files (the
- "Software"), to deal in the Software without restriction, including
- without limitation the rights to use, copy, modify, merge, publish,
- distribute, sublicense, and/or sell copies of the Software, and to
- permit persons to whom the Software is furnished to do so, subject to
- the following conditions:
-
- The above copyright notice and this permission notice shall be
- included in all copies or substantial portions of the Software.
-
- THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
- EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
- MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
- NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
- LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
- OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
- WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
-
-*/
-
-var assert = require('assert'),
- fs = require('fs'),
- path = require('path'),
- async = require('async'),
- request = require('request'),
- vows = require('vows'),
- macros = require('../macros'),
- helpers = require('../helpers');
-
-var routeFile = path.join(__dirname, 'config.json');
-
-vows.describe(helpers.describe()).addBatch({
- "With a valid target server": {
- "and no latency": {
- "and no headers": macros.http.assertProxied(),
- "and headers": macros.http.assertProxied({
- request: { headers: { host: 'unknown.com' } }
- }),
- "and request close connection header": macros.http.assertProxied({
- request: { headers: { connection: "close" } },
- outputHeaders: { connection: "close" }
- }),
- "and request keep alive connection header": macros.http.assertProxied({
- request: { headers: { connection: "keep-alive" } },
- outputHeaders: { connection: "keep-alive" }
- }),
- "and response close connection header": macros.http.assertProxied({
- request: { headers: { connection: "" } }, // Must explicitly set to "" because otherwise node will automatically add a "connection: keep-alive" header
- targetHeaders: { connection: "close" },
- outputHeaders: { connection: "close" }
- }),
- "and response keep-alive connection header": macros.http.assertProxied({
- request: { headers: { connection: "" } }, // Must explicitly set to "" because otherwise node will automatically add a "connection: keep-alive" header
- targetHeaders: { connection: "keep-alive" },
- outputHeaders: { connection: "keep-alive" }
- }),
- "and response keep-alive connection header from http 1.0 client": macros.http.assertRawHttpProxied({
- rawRequest: "GET / HTTP/1.0\r\n\r\n",
- targetHeaders: { connection: "keep-alive" },
- match: /connection: close/i
- }),
- "and request keep alive from http 1.0 client": macros.http.assertRawHttpProxied({
- rawRequest: "GET / HTTP/1.0\r\nConnection: Keep-Alive\r\n\r\n",
- targetHeaders: { connection: "keep-alive" },
- match: /connection: keep-alive/i
- }),
- "and no connection header": macros.http.assertProxied({
- request: { headers: { connection: "" } }, // Must explicitly set to "" because otherwise node will automatically add a "connection: keep-alive" header
- outputHeaders: { connection: "keep-alive" }
- }),
- "and forwarding enabled": macros.http.assertForwardProxied()
- },
- "and latency": {
- "and no headers": macros.http.assertProxied({
- latency: 2000
- }),
- "and response headers": macros.http.assertProxied({
- targetHeaders: { "x-testheader": "target" },
- proxyHeaders: { "X-TestHeader": "proxy" },
- outputHeaders: { "x-testheader": "target" },
- latency: 1000
- })
- },
- "and timeout set": macros.http.assertProxied({
- shouldFail: true,
- timeout: 2000,
- requestLatency: 4000
- })
- },
- "With a no valid target server": {
- "and no latency": macros.http.assertInvalidProxy(),
- "and latency": macros.http.assertInvalidProxy({
- latency: 2000
- })
- }
-}).export(module);
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/http-proxy/test/http/routing-table-test.js
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/http-proxy/test/http/routing-table-test.js b/web/demos/package/node_modules/http-proxy/test/http/routing-table-test.js
deleted file mode 100644
index f3dcf31..0000000
--- a/web/demos/package/node_modules/http-proxy/test/http/routing-table-test.js
+++ /dev/null
@@ -1,107 +0,0 @@
-/*
- * routing-table-test.js: Tests for the proxying using the ProxyTable object.
- *
- * (C) 2010, Charlie Robbins
- *
- */
-
-var assert = require('assert'),
- fs = require('fs'),
- path = require('path'),
- async = require('async'),
- request = require('request'),
- vows = require('vows'),
- macros = require('../macros'),
- helpers = require('../helpers');
-
-var routeFile = path.join(__dirname, 'config.json');
-
-vows.describe(helpers.describe('routing-table')).addBatch({
- "With a routing table": {
- "with latency": macros.http.assertProxiedToRoutes({
- latency: 2000,
- routes: {
- "icanhaz.com": "127.0.0.1:{PORT}",
- "latency.com": "127.0.0.1:{PORT}"
- }
- }),
- "addHost() / removeHost()": macros.http.assertDynamicProxy({
- hostnameOnly: true,
- routes: {
- "static.com": "127.0.0.1:{PORT}",
- "removed.com": "127.0.0.1:{PORT}"
- }
- }, {
- add: [{ host: 'dynamic1.com', target: '127.0.0.1:' }],
- drop: ['removed.com']
- }),
- "using RegExp": macros.http.assertProxiedToRoutes({
- routes: {
- "foo.com": "127.0.0.1:{PORT}",
- "bar.com": "127.0.0.1:{PORT}",
- "baz.com/taco": "127.0.0.1:{PORT}",
- "pizza.com/taco/muffins": "127.0.0.1:{PORT}",
- "blah.com/me": "127.0.0.1:{PORT}/remapped",
- "bleh.com/remap/this": "127.0.0.1:{PORT}/remap/remapped",
- "test.com/double/tap": "127.0.0.1:{PORT}/remap"
- }
- }),
- "using hostnameOnly": macros.http.assertProxiedToRoutes({
- hostnameOnly: true,
- routes: {
- "foo.com": "127.0.0.1:{PORT}",
- "bar.com": "127.0.0.1:{PORT}"
- }
- }),
- "using pathnameOnly": macros.http.assertProxiedToRoutes({
- pathnameOnly: true,
- routes: {
- "/foo": "127.0.0.1:{PORT}",
- "/bar": "127.0.0.1:{PORT}",
- "/pizza": "127.0.0.1:{PORT}"
- }
- }),
- "using a routing file": macros.http.assertProxiedToRoutes({
- filename: routeFile,
- routes: {
- "foo.com": "127.0.0.1:{PORT}",
- "bar.com": "127.0.0.1:{PORT}"
- }
- }, {
- "after the file has been modified": {
- topic: function () {
- var config = JSON.parse(fs.readFileSync(routeFile, 'utf8')),
- protocol = helpers.protocols.proxy,
- port = helpers.nextPort,
- that = this;
-
- config.router['dynamic.com'] = "127.0.0.1:" + port;
- fs.writeFileSync(routeFile, JSON.stringify(config));
-
- async.parallel([
- function waitForRoutes(next) {
- that.proxyServer.on('routes', next);
- },
- async.apply(
- helpers.http.createServer,
- {
- port: port,
- output: 'hello from dynamic.com'
- }
- )
- ], function () {
- request({
- uri: protocol + '://127.0.0.1:' + that.port,
- headers: {
- host: 'dynamic.com'
- }
- }, that.callback);
- });
- },
- "should receive 'hello from dynamic.com'": function (err, res, body) {
- assert.equal(body, 'hello from dynamic.com');
- }
- }
- })
- }
-}).export(module);
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/http-proxy/test/macros/examples.js
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/http-proxy/test/macros/examples.js b/web/demos/package/node_modules/http-proxy/test/macros/examples.js
deleted file mode 100644
index 9d4202e..0000000
--- a/web/demos/package/node_modules/http-proxy/test/macros/examples.js
+++ /dev/null
@@ -1,101 +0,0 @@
-/*
- * examples.js: Macros for testing code in examples/
- *
- * (C) 2010 Nodejitsu Inc.
- * MIT LICENCE
- *
- */
-
-var assert = require('assert'),
- fs = require('fs'),
- path = require('path'),
- spawn = require('child_process').spawn,
- async = require('async');
-
-var rootDir = path.join(__dirname, '..', '..'),
- examplesDir = path.join(rootDir, 'examples');
-
-//
-// ### function shouldHaveDeps ()
-//
-// Ensures that all `npm` dependencies are installed in `/examples`.
-//
-exports.shouldHaveDeps = function () {
- return {
- "Before testing examples": {
- topic: function () {
- async.waterfall([
- //
- // 1. Read files in examples dir
- //
- async.apply(fs.readdir, examplesDir),
- //
- // 2. If node_modules exists, continue. Otherwise
- // exec `npm` to install them
- //
- function checkNodeModules(files, next) {
- if (files.indexOf('node_modules') !== -1) {
- return next();
- }
-
- var child = spawn('npm', ['install', '-f'], {
- cwd: examplesDir
- });
-
- child.on('exit', function (code) {
- return code
- ? next(new Error('npm install exited with non-zero exit code'))
- : next();
- });
- },
- //
- // 3. Read files in examples dir again to ensure the install
- // worked as expected.
- //
- async.apply(fs.readdir, examplesDir),
- ], this.callback);
- },
- "examples/node_modules should exist": function (err, files) {
- assert.notEqual(files.indexOf('node_modules'), -1);
- }
- }
- }
-};
-
-//
-// ### function shouldRequire (file)
-// #### @file {string} File to attempt to require
-//
-// Returns a test which attempts to require `file`.
-//
-exports.shouldRequire = function (file) {
- return {
- "should have no errors": function () {
- try { assert.isObject(require(file)) }
- catch (ex) { assert.isNull(ex) }
- }
- };
-};
-
-//
-// ### function shouldHaveNoErrors ()
-//
-// Returns a vows context that attempts to require
-// every relevant example file in `examples`.
-//
-exports.shouldHaveNoErrors = function () {
- var context = {};
-
- ['balancer', 'http', 'middleware', 'websocket'].forEach(function (dir) {
- var name = 'examples/' + dir,
- files = fs.readdirSync(path.join(rootDir, 'examples', dir));
-
- files.forEach(function (file) {
- context[name + '/' + file] = exports.shouldRequire(path.join(
- examplesDir, dir, file
- ));
- });
- });
-
- return context;
-};
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/http-proxy/test/macros/http.js
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/http-proxy/test/macros/http.js b/web/demos/package/node_modules/http-proxy/test/macros/http.js
deleted file mode 100644
index d3d8342..0000000
--- a/web/demos/package/node_modules/http-proxy/test/macros/http.js
+++ /dev/null
@@ -1,531 +0,0 @@
-/*
- * http.js: Macros for proxying HTTP requests
- *
- * (C) 2010 Nodejitsu Inc.
- * MIT LICENCE
- *
- */
-
-var assert = require('assert'),
- fs = require('fs'),
- async = require('async'),
- net = require('net'),
- request = require('request'),
- helpers = require('../helpers/index');
-
-//
-// ### function assertRequest (options)
-// #### @options {Object} Options for this request assertion.
-// #### @request {Object} Options to use for `request`.
-// #### @assert {Object} Test assertions against the response.
-//
-// Makes a request using `options.request` and then asserts the response
-// and body against anything in `options.assert`.
-//
-exports.assertRequest = function (options) {
- return {
- topic: function () {
- //
- // Now make the HTTP request and assert.
- //
- options.request.rejectUnauthorized = false;
- request(options.request, this.callback);
- },
- "should succeed": function (err, res, body) {
- assert.isNull(err);
- if (options.assert.headers) {
- Object.keys(options.assert.headers).forEach(function(header){
- assert.equal(res.headers[header], options.assert.headers[header]);
- });
- }
-
- if (options.assert.body) {
- assert.equal(body, options.assert.body);
- }
-
- if (options.assert.statusCode) {
- assert.equal(res.statusCode, options.assert.statusCode);
- }
- }
- };
-};
-
-//
-// ### function assertFailedRequest (options)
-// #### @options {Object} Options for this failed request assertion.
-// #### @request {Object} Options to use for `request`.
-// #### @assert {Object} Test assertions against the response.
-//
-// Makes a request using `options.request` and then asserts the response
-// and body against anything in `options.assert`.
-//
-exports.assertFailedRequest = function (options) {
- return {
- topic: function () {
- //
- // Now make the HTTP request and assert.
- //
- options.request.rejectUnauthorized = false;
- request(options.request, this.callback);
- },
- "should not succeed": function (err, res, body) {
- assert.notStrictEqual(err,null);
- }
- };
-};
-
-//
-// ### function assertProxied (options)
-// #### @options {Object} Options for this test
-// #### @latency {number} Latency in milliseconds for the proxy server.
-// #### @ports {Object} Ports for the request (target, proxy).
-// #### @output {string} Output to assert from.
-// #### @forward {Object} Options for forward proxying.
-//
-// Creates a complete end-to-end test for requesting against an
-// http proxy.
-//
-exports.assertProxied = function (options) {
- options = options || {};
-
- var ports = options.ports || helpers.nextPortPair,
- output = options.output || 'hello world from ' + ports.target,
- outputHeaders = options.outputHeaders,
- targetHeaders = options.targetHeaders,
- proxyHeaders = options.proxyHeaders,
- protocol = helpers.protocols.proxy,
- req = options.request || {},
- timeout = options.timeout || null,
- assertFn = options.shouldFail
- ? exports.assertFailedRequest
- : exports.assertRequest;
-
- req.uri = req.uri || protocol + '://127.0.0.1:' + ports.proxy;
-
- return {
- topic: function () {
- //
- // Create a target server and a proxy server
- // using the `options` supplied.
- //
- helpers.http.createServerPair({
- target: {
- output: output,
- outputHeaders: targetHeaders,
- port: ports.target,
- headers: req.headers,
- latency: options.requestLatency
- },
- proxy: {
- latency: options.latency,
- port: ports.proxy,
- outputHeaders: proxyHeaders,
- proxy: {
- forward: options.forward,
- target: {
- https: helpers.protocols.target === 'https',
- host: '127.0.0.1',
- port: ports.target
- },
- timeout: timeout
- }
- }
- }, this.callback);
- },
- "the proxy request": assertFn({
- request: req,
- assert: {
- headers: outputHeaders,
- body: output
- }
- })
- };
-};
-
-//
-// ### function assertRawHttpProxied (options)
-// #### @options {Object} Options for this test
-// #### @rawRequest {string} Raw HTTP request to perform.
-// #### @match {RegExp} Output to match in the response.
-// #### @latency {number} Latency in milliseconds for the proxy server.
-// #### @ports {Object} Ports for the request (target, proxy).
-// #### @output {string} Output to assert from.
-// #### @forward {Object} Options for forward proxying.
-//
-// Creates a complete end-to-end test for requesting against an
-// http proxy.
-//
-exports.assertRawHttpProxied = function (options) {
- // Don't test raw requests over HTTPS since options.rawRequest won't be
- // encrypted.
- if(helpers.protocols.proxy == 'https') {
- return true;
- }
-
- options = options || {};
-
- var ports = options.ports || helpers.nextPortPair,
- output = options.output || 'hello world from ' + ports.target,
- outputHeaders = options.outputHeaders,
- targetHeaders = options.targetHeaders,
- proxyHeaders = options.proxyHeaders,
- protocol = helpers.protocols.proxy,
- timeout = options.timeout || null,
- assertFn = options.shouldFail
- ? exports.assertFailedRequest
- : exports.assertRequest;
-
- return {
- topic: function () {
- var topicCallback = this.callback;
-
- //
- // Create a target server and a proxy server
- // using the `options` supplied.
- //
- helpers.http.createServerPair({
- target: {
- output: output,
- outputHeaders: targetHeaders,
- port: ports.target,
- latency: options.requestLatency
- },
- proxy: {
- latency: options.latency,
- port: ports.proxy,
- outputHeaders: proxyHeaders,
- proxy: {
- forward: options.forward,
- target: {
- https: helpers.protocols.target === 'https',
- host: '127.0.0.1',
- port: ports.target
- },
- timeout: timeout
- }
- }
- }, function() {
- var response = '';
- var client = net.connect(ports.proxy, '127.0.0.1', function() {
- client.write(options.rawRequest);
- });
-
- client.on('data', function(data) {
- response += data.toString();
- });
-
- client.on('end', function() {
- topicCallback(null, options.match, response);
- });
- });
- },
- "should succeed": function(err, match, response) {
- assert.match(response, match);
- }
- };
-};
-
-//
-// ### function assertInvalidProxy (options)
-// #### @options {Object} Options for this test
-// #### @latency {number} Latency in milliseconds for the proxy server
-// #### @ports {Object} Ports for the request (target, proxy)
-//
-// Creates a complete end-to-end test for requesting against an
-// http proxy with no target server.
-//
-exports.assertInvalidProxy = function (options) {
- options = options || {};
-
- var ports = options.ports || helpers.nextPortPair,
- req = options.request || {},
- protocol = helpers.protocols.proxy;
-
-
- req.uri = req.uri || protocol + '://127.0.0.1:' + ports.proxy;
-
- return {
- topic: function () {
- //
- // Only create the proxy server, simulating a reverse-proxy
- // to an invalid location.
- //
- helpers.http.createProxyServer({
- latency: options.latency,
- port: ports.proxy,
- proxy: {
- target: {
- host: '127.0.0.1',
- port: ports.target
- }
- }
- }, this.callback);
- },
- "the proxy request": exports.assertRequest({
- request: req,
- assert: {
- statusCode: 500
- }
- })
- };
-};
-
-//
-// ### function assertForwardProxied (options)
-// #### @options {Object} Options for this test.
-//
-// Creates a complete end-to-end test for requesting against an
-// http proxy with both a valid and invalid forward target.
-//
-exports.assertForwardProxied = function (options) {
- var forwardPort = helpers.nextPort;
-
- return {
- topic: function () {
- helpers.http.createServer({
- output: 'hello from forward',
- port: forwardPort
- }, this.callback);
- },
- "and a valid forward target": exports.assertProxied({
- forward: {
- port: forwardPort,
- host: '127.0.0.1'
- }
- }),
- "and an invalid forward target": exports.assertProxied({
- forward: {
- port: 9898,
- host: '127.0.0.1'
- }
- })
- };
-};
-
-//
-// ### function assertProxiedtoRoutes (options, nested)
-// #### @options {Object} Options for this ProxyTable-based test
-// #### @routes {Object|string} Routes to use for the proxy.
-// #### @hostnameOnly {boolean} Enables hostnameOnly routing.
-// #### @nested {Object} Nested vows to add to the returned context.
-//
-// Creates a complete end-to-end test for requesting against an
-// http proxy using `options.routes`:
-//
-// 1. Creates target servers for all routes in `options.routes.`
-// 2. Creates a proxy server.
-// 3. Ensure requests to the proxy server for all route targets
-// returns the unique expected output.
-//
-exports.assertProxiedToRoutes = function (options, nested) {
- //
- // Assign dynamic ports to the routes to use.
- //
- options.routes = helpers.http.assignPortsToRoutes(options.routes);
-
- //
- // Parse locations from routes for making assertion requests.
- //
- var locations = helpers.http.parseRoutes(options),
- port = options.pport || helpers.nextPort,
- protocol = helpers.protocols.proxy,
- context,
- proxy;
-
- if (options.filename) {
- //
- // If we've been passed a filename write the routes to it
- // and setup the proxy options to use that file.
- //
- fs.writeFileSync(options.filename, JSON.stringify({ router: options.routes }));
- proxy = { router: options.filename };
- }
- else {
- //
- // Otherwise just use the routes themselves.
- //
- proxy = {
- hostnameOnly: options.hostnameOnly,
- pathnameOnly: options.pathnameOnly,
- router: options.routes
- };
- }
-
- //
- // Set the https options if necessary
- //
- if (helpers.protocols.target === 'https') {
- proxy.target = { https: true };
- }
-
- //
- // Create the test context which creates all target
- // servers for all routes and a proxy server.
- //
- context = {
- topic: function () {
- var that = this;
-
- async.waterfall([
- //
- // 1. Create all the target servers
- //
- async.apply(
- async.forEach,
- locations,
- function createRouteTarget(location, next) {
- helpers.http.createServer({
- port: location.target.port,
- output: 'hello from ' + location.source.href
- }, next);
- }
- ),
- //
- // 2. Create the proxy server
- //
- async.apply(
- helpers.http.createProxyServer,
- {
- port: port,
- latency: options.latency,
- routing: true,
- proxy: proxy
- }
- )
- ], function (_, server) {
- //
- // 3. Set the proxy server for later use
- //
- that.proxyServer = server;
- that.callback();
- });
-
- //
- // 4. Assign the port to the context for later use
- //
- this.port = port;
- },
- //
- // Add an extra assertion to a route which
- // should respond with 404
- //
- "a request to unknown.com": exports.assertRequest({
- assert: { statusCode: 404 },
- request: {
- uri: protocol + '://127.0.0.1:' + port,
- headers: {
- host: 'unknown.com'
- }
- }
- })
- };
-
- //
- // Add test assertions for each of the route locations.
- //
- locations.forEach(function (location) {
- context[location.source.href] = exports.assertRequest({
- request: {
- uri: protocol + '://127.0.0.1:' + port + location.source.path,
- headers: {
- host: location.source.hostname
- }
- },
- assert: {
- body: 'hello from ' + location.source.href
- }
- });
- });
-
- //
- // If there are any nested vows to add to the context
- // add them before returning the full context.
- //
- if (nested) {
- Object.keys(nested).forEach(function (key) {
- context[key] = nested[key];
- });
- }
-
- return context;
-};
-
-//
-// ### function assertDynamicProxy (static, dynamic)
-// Asserts that after the `static` routes have been tested
-// and the `dynamic` routes are added / removed the appropriate
-// proxy responses are received.
-//
-exports.assertDynamicProxy = function (static, dynamic) {
- var proxyPort = helpers.nextPort,
- protocol = helpers.protocols.proxy,
- context;
-
- if (dynamic.add) {
- dynamic.add = dynamic.add.map(function (dyn) {
- dyn.port = helpers.nextPort;
- dyn.target = dyn.target + dyn.port;
- return dyn;
- });
- }
-
- context = {
- topic: function () {
- var that = this;
-
- setTimeout(function () {
- if (dynamic.drop) {
- dynamic.drop.forEach(function (dropHost) {
- that.proxyServer.proxy.removeHost(dropHost);
- });
- }
-
- if (dynamic.add) {
- async.forEachSeries(dynamic.add, function addOne (dyn, next) {
- that.proxyServer.proxy.addHost(dyn.host, dyn.target);
- helpers.http.createServer({
- port: dyn.port,
- output: 'hello ' + dyn.host
- }, next);
- }, that.callback);
- }
- else {
- that.callback();
- }
- }, 200);
- }
- };
-
- if (dynamic.drop) {
- dynamic.drop.forEach(function (dropHost) {
- context[dropHost] = exports.assertRequest({
- assert: { statusCode: 404 },
- request: {
- uri: protocol + '://127.0.0.1:' + proxyPort,
- headers: {
- host: dropHost
- }
- }
- });
- });
- }
-
- if (dynamic.add) {
- dynamic.add.forEach(function (dyn) {
- context[dyn.host] = exports.assertRequest({
- assert: { body: 'hello ' + dyn.host },
- request: {
- uri: protocol + '://127.0.0.1:' + proxyPort,
- headers: {
- host: dyn.host
- }
- }
- });
- });
- }
-
- static.pport = proxyPort;
- return exports.assertProxiedToRoutes(static, {
- "once the server has started": context
- });
-};
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/http-proxy/test/macros/index.js
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/http-proxy/test/macros/index.js b/web/demos/package/node_modules/http-proxy/test/macros/index.js
deleted file mode 100644
index c01f962..0000000
--- a/web/demos/package/node_modules/http-proxy/test/macros/index.js
+++ /dev/null
@@ -1,11 +0,0 @@
-/*
- * index.js: Top level include for node-http-proxy macros
- *
- * (C) 2010 Nodejitsu Inc.
- * MIT LICENCE
- *
- */
-
-exports.examples = require('./examples');
-exports.http = require('./http');
-exports.ws = require('./ws');
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/http-proxy/test/macros/ws.js
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/http-proxy/test/macros/ws.js b/web/demos/package/node_modules/http-proxy/test/macros/ws.js
deleted file mode 100644
index 508725a..0000000
--- a/web/demos/package/node_modules/http-proxy/test/macros/ws.js
+++ /dev/null
@@ -1,232 +0,0 @@
-/*
- * ws.js: Macros for proxying Websocket requests
- *
- * (C) 2010 Nodejitsu Inc.
- * MIT LICENCE
- *
- */
-
-var assert = require('assert'),
- fs = require('fs'),
- async = require('async'),
- io = require('socket.io-client'),
- WebSocket = require('ws'),
- helpers = require('../helpers/index');
-
-//
-// ### function assertSendRecieve (options)
-// #### @options {Object} Options for creating this assertion.
-// #### @raw {boolean} Enables raw `ws.WebSocket`.
-// #### @uri {string} URI of the proxy server.
-// #### @input {string} Input to assert sent to the target ws server.
-// #### @output {string} Output to assert from the taget ws server.
-//
-// Creates a `socket.io` or raw `WebSocket` connection and asserts that
-// `options.input` is sent to and `options.output` is received from the
-// connection.
-//
-exports.assertSendReceive = function (options) {
- if (!options.raw) {
- return {
- topic: function () {
- var socket = io.connect(options.uri);
- socket.on('outgoing', this.callback.bind(this, null));
- socket.emit('incoming', options.input);
- },
- "should send input and receive output": function (_, data) {
- assert.equal(data, options.output);
- }
- };
- }
-
- return {
- topic: function () {
- var socket = new WebSocket(options.uri);
- socket.on('message', this.callback.bind(this, null));
- socket.on('open', function () {
- socket.send(options.input);
- });
- },
- "should send input and recieve output": function (_, data, flags) {
- assert.equal(data, options.output);
- }
- };
-};
-
-//
-// ### function assertProxied (options)
-// #### @options {Object} Options for this test
-// #### @latency {number} Latency in milliseconds for the proxy server.
-// #### @ports {Object} Ports for the request (target, proxy).
-// #### @input {string} Input to assert sent to the target ws server.
-// #### @output {string} Output to assert from the taget ws server.
-// #### @raw {boolean} Enables raw `ws.Server` usage.
-//
-// Creates a complete end-to-end test for requesting against an
-// http proxy.
-//
-exports.assertProxied = function (options) {
- options = options || {};
-
- var ports = options.ports || helpers.nextPortPair,
- input = options.input || 'hello world to ' + ports.target,
- output = options.output || 'hello world from ' + ports.target,
- protocol = helpers.protocols.proxy;
-
- if (options.raw) {
- protocol = helpers.protocols.proxy === 'https'
- ? 'wss'
- : 'ws';
- }
-
- return {
- topic: function () {
- helpers.ws.createServerPair({
- target: {
- input: input,
- output: output,
- port: ports.target,
- raw: options.raw
- },
- proxy: {
- latency: options.latency,
- port: ports.proxy,
- proxy: {
- target: {
- https: helpers.protocols.target === 'https',
- host: '127.0.0.1',
- port: ports.target
- }
- }
- }
- }, this.callback);
- },
- "the proxy Websocket connection": exports.assertSendReceive({
- uri: protocol + '://127.0.0.1:' + ports.proxy,
- input: input,
- output: output,
- raw: options.raw
- })
- };
-};
-
-//
-// ### function assertProxiedtoRoutes (options, nested)
-// #### @options {Object} Options for this ProxyTable-based test
-// #### @raw {boolean} Enables ws.Server usage.
-// #### @routes {Object|string} Routes to use for the proxy.
-// #### @hostnameOnly {boolean} Enables hostnameOnly routing.
-// #### @nested {Object} Nested vows to add to the returned context.
-//
-// Creates a complete end-to-end test for requesting against an
-// http proxy using `options.routes`:
-//
-// 1. Creates target servers for all routes in `options.routes.`
-// 2. Creates a proxy server.
-// 3. Ensure Websocket connections to the proxy server for all route targets
-// can send input and recieve output.
-//
-exports.assertProxiedToRoutes = function (options, nested) {
- //
- // Assign dynamic ports to the routes to use.
- //
- options.routes = helpers.http.assignPortsToRoutes(options.routes);
-
- //
- // Parse locations from routes for making assertion requests.
- //
- var locations = helpers.http.parseRoutes(options),
- protocol = helpers.protocols.proxy,
- port = helpers.nextPort,
- context,
- proxy;
-
- if (options.raw) {
- protocol = helpers.protocols.proxy === 'https'
- ? 'wss'
- : 'ws';
- }
-
- if (options.filename) {
- //
- // If we've been passed a filename write the routes to it
- // and setup the proxy options to use that file.
- //
- fs.writeFileSync(options.filename, JSON.stringify({ router: options.routes }));
- proxy = { router: options.filename };
- }
- else {
- //
- // Otherwise just use the routes themselves.
- //
- proxy = {
- hostnameOnly: options.hostnameOnly,
- router: options.routes
- };
- }
-
- //
- // Create the test context which creates all target
- // servers for all routes and a proxy server.
- //
- context = {
- topic: function () {
- var that = this;
-
- async.waterfall([
- //
- // 1. Create all the target servers
- //
- async.apply(
- async.forEach,
- locations,
- function createRouteTarget(location, next) {
- helpers.ws.createServer({
- raw: options.raw,
- port: location.target.port,
- output: 'hello from ' + location.source.href,
- input: 'hello to ' + location.source.href
- }, next);
- }
- ),
- //
- // 2. Create the proxy server
- //
- async.apply(
- helpers.http.createProxyServer,
- {
- port: port,
- latency: options.latency,
- routing: true,
- proxy: proxy
- }
- )
- ], function (_, server) {
- //
- // 3. Set the proxy server for later use
- //
- that.proxyServer = server;
- that.callback();
- });
-
- //
- // 4. Assign the port to the context for later use
- //
- this.port = port;
- }
- };
-
- //
- // Add test assertions for each of the route locations.
- //
- locations.forEach(function (location) {
- context[location.source.href] = exports.assertSendRecieve({
- uri: protocol + '://127.0.0.1:' + port + location.source.path,
- output: 'hello from ' + location.source.href,
- input: 'hello to ' + location.source.href,
- raw: options.raw
- });
- });
-
- return context;
-};
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/http-proxy/test/ws/routing-table-test.js
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/http-proxy/test/ws/routing-table-test.js b/web/demos/package/node_modules/http-proxy/test/ws/routing-table-test.js
deleted file mode 100644
index e04d647..0000000
--- a/web/demos/package/node_modules/http-proxy/test/ws/routing-table-test.js
+++ /dev/null
@@ -1,25 +0,0 @@
-/*
- * routing-tabletest.js: Test for proxying `socket.io` and raw `WebSocket` requests using a ProxyTable.
- *
- * (C) 2010 Nodejitsu Inc.
- * MIT LICENCE
- *
- */
-
-var vows = require('vows'),
- macros = require('../macros'),
- helpers = require('../helpers/index');
-
-vows.describe(helpers.describe('routing-proxy', 'ws')).addBatch({
- "With a valid target server": {
- "and no latency": {
- "using ws": macros.ws.assertProxied(),
- "using socket.io": macros.ws.assertProxied({
- raw: true
- }),
- },
- // "and latency": macros.websocket.assertProxied({
- // latency: 2000
- // })
- }
-}).export(module);
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/http-proxy/test/ws/socket.io-test.js
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/http-proxy/test/ws/socket.io-test.js b/web/demos/package/node_modules/http-proxy/test/ws/socket.io-test.js
deleted file mode 100644
index d833109..0000000
--- a/web/demos/package/node_modules/http-proxy/test/ws/socket.io-test.js
+++ /dev/null
@@ -1,20 +0,0 @@
-/*
- * socket.io-test.js: Test for proxying `socket.io` requests.
- *
- * (C) 2010 Nodejitsu Inc.
- * MIT LICENCE
- *
- */
-
-var vows = require('vows'),
- macros = require('../macros'),
- helpers = require('../helpers/index');
-
-vows.describe(helpers.describe('socket.io', 'ws')).addBatch({
- "With a valid target server": {
- "and no latency": macros.ws.assertProxied(),
- // "and latency": macros.ws.assertProxied({
- // latency: 2000
- // })
- }
-}).export(module);
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/http-proxy/test/ws/ws-test.js
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/http-proxy/test/ws/ws-test.js b/web/demos/package/node_modules/http-proxy/test/ws/ws-test.js
deleted file mode 100644
index f354915..0000000
--- a/web/demos/package/node_modules/http-proxy/test/ws/ws-test.js
+++ /dev/null
@@ -1,23 +0,0 @@
-/*
- * ws-test.js: Tests for proxying raw Websocket requests.
- *
- * (C) 2010 Nodejitsu Inc.
- * MIT LICENCE
- *
- */
-
-var vows = require('vows'),
- macros = require('../macros'),
- helpers = require('../helpers/index');
-
-vows.describe(helpers.describe('websocket', 'ws')).addBatch({
- "With a valid target server": {
- "and no latency": macros.ws.assertProxied({
- raw: true
- }),
- // "and latency": macros.ws.assertProxied({
- // raw: true,
- // latency: 2000
- // })
- }
-}).export(module);
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/jquery-deferred/.npmignore
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/jquery-deferred/.npmignore b/web/demos/package/node_modules/jquery-deferred/.npmignore
deleted file mode 100644
index 9533d1f..0000000
--- a/web/demos/package/node_modules/jquery-deferred/.npmignore
+++ /dev/null
@@ -1,6 +0,0 @@
-support
-test
-examples
-*.sock
-node_modules
-npm-debug.log
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/jquery-deferred/History.md
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/jquery-deferred/History.md b/web/demos/package/node_modules/jquery-deferred/History.md
deleted file mode 100644
index c8aa68f..0000000
--- a/web/demos/package/node_modules/jquery-deferred/History.md
+++ /dev/null
@@ -1,5 +0,0 @@
-
-0.0.1 / 2010-01-03
-==================
-
- * Initial release
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/jquery-deferred/Makefile
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/jquery-deferred/Makefile b/web/demos/package/node_modules/jquery-deferred/Makefile
deleted file mode 100644
index c618c43..0000000
--- a/web/demos/package/node_modules/jquery-deferred/Makefile
+++ /dev/null
@@ -1,7 +0,0 @@
-
-test:
- @echo "Test start"
- node ./test/jquery-deferred.test.js
- @echo "Test complete."
-
-.PHONY: test
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/jquery-deferred/Readme.md
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/jquery-deferred/Readme.md b/web/demos/package/node_modules/jquery-deferred/Readme.md
deleted file mode 100644
index 76285d6..0000000
--- a/web/demos/package/node_modules/jquery-deferred/Readme.md
+++ /dev/null
@@ -1,45 +0,0 @@
-
-jquery-deferred
-=============================
-
-jQuery deferred lib for nodeJS.
-
-jQuery.Deferred(), is a chainable utility object that can register multiple callbacks into callback queues, invoke callback queues, and relay the success or failure state of any synchronous or asynchronous function.
-
-Doc [http://api.jquery.com/category/deferred-object/](http://api.jquery.com/category/deferred-object/)
-
-Installation
------------------------------
-
-> npm install jquery-deferred
-
-In nodeJS
-
-`var jQuery = require('jquery-deferred');`
-
-
-
-## License
-
-(The MIT License)
-
-Copyright (c) 2011 Hidden <zzdhidden@gmail.com>
-
-Permission is hereby granted, free of charge, to any person obtaining
-a copy of this software and associated documentation files (the
-'Software'), to deal in the Software without restriction, including
-without limitation the rights to use, copy, modify, merge, publish,
-distribute, sublicense, and/or sell copies of the Software, and to
-permit persons to whom the Software is furnished to do so, subject to
-the following conditions:
-
-The above copyright notice and this permission notice shall be
-included in all copies or substantial portions of the Software.
-
-THE SOFTWARE IS PROVIDED 'AS IS', WITHOUT WARRANTY OF ANY KIND,
-EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
-MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.
-IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY
-CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT,
-TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE
-SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/jquery-deferred/index.js
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/jquery-deferred/index.js b/web/demos/package/node_modules/jquery-deferred/index.js
deleted file mode 100644
index 1f4b92b..0000000
--- a/web/demos/package/node_modules/jquery-deferred/index.js
+++ /dev/null
@@ -1,2 +0,0 @@
-
-module.exports = require('./lib/jquery-deferred');
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/jquery-deferred/lib/jquery-callbacks.js
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/jquery-deferred/lib/jquery-callbacks.js b/web/demos/package/node_modules/jquery-deferred/lib/jquery-callbacks.js
deleted file mode 100644
index feb959d..0000000
--- a/web/demos/package/node_modules/jquery-deferred/lib/jquery-callbacks.js
+++ /dev/null
@@ -1,206 +0,0 @@
-var jQuery = module.exports = require("./jquery-core.js"),
- core_rspace = /\s+/;
-/**
-* jQuery Callbacks
-*
-* Code from: https://github.com/jquery/jquery/blob/master/src/callbacks.js
-*
-*/
-
-
-// String to Object options format cache
-var optionsCache = {};
-
-// Convert String-formatted options into Object-formatted ones and store in cache
-function createOptions( options ) {
- var object = optionsCache[ options ] = {};
- jQuery.each( options.split( core_rspace ), function( _, flag ) {
- object[ flag ] = true;
- });
- return object;
-}
-
-/*
- * Create a callback list using the following parameters:
- *
- * options: an optional list of space-separated options that will change how
- * the callback list behaves or a more traditional option object
- *
- * By default a callback list will act like an event callback list and can be
- * "fired" multiple times.
- *
- * Possible options:
- *
- * once: will ensure the callback list can only be fired once (like a Deferred)
- *
- * memory: will keep track of previous values and will call any callback added
- * after the list has been fired right away with the latest "memorized"
- * values (like a Deferred)
- *
- * unique: will ensure a callback can only be added once (no duplicate in the list)
- *
- * stopOnFalse: interrupt callings when a callback returns false
- *
- */
-jQuery.Callbacks = function( options ) {
-
- // Convert options from String-formatted to Object-formatted if needed
- // (we check in cache first)
- options = typeof options === "string" ?
- ( optionsCache[ options ] || createOptions( options ) ) :
- jQuery.extend( {}, options );
-
- var // Last fire value (for non-forgettable lists)
- memory,
- // Flag to know if list was already fired
- fired,
- // Flag to know if list is currently firing
- firing,
- // First callback to fire (used internally by add and fireWith)
- firingStart,
- // End of the loop when firing
- firingLength,
- // Index of currently firing callback (modified by remove if needed)
- firingIndex,
- // Actual callback list
- list = [],
- // Stack of fire calls for repeatable lists
- stack = !options.once && [],
- // Fire callbacks
- fire = function( data ) {
- memory = options.memory && data;
- fired = true;
- firingIndex = firingStart || 0;
- firingStart = 0;
- firingLength = list.length;
- firing = true;
- for ( ; list && firingIndex < firingLength; firingIndex++ ) {
- if ( list[ firingIndex ].apply( data[ 0 ], data[ 1 ] ) === false && options.stopOnFalse ) {
- memory = false; // To prevent further calls using add
- break;
- }
- }
- firing = false;
- if ( list ) {
- if ( stack ) {
- if ( stack.length ) {
- fire( stack.shift() );
- }
- } else if ( memory ) {
- list = [];
- } else {
- self.disable();
- }
- }
- },
- // Actual Callbacks object
- self = {
- // Add a callback or a collection of callbacks to the list
- add: function() {
- if ( list ) {
- // First, we save the current length
- var start = list.length;
- (function add( args ) {
- jQuery.each( args, function( _, arg ) {
- var type = jQuery.type( arg );
- if ( type === "function" ) {
- if ( !options.unique || !self.has( arg ) ) {
- list.push( arg );
- }
- } else if ( arg && arg.length && type !== "string" ) {
- // Inspect recursively
- add( arg );
- }
- });
- })( arguments );
- // Do we need to add the callbacks to the
- // current firing batch?
- if ( firing ) {
- firingLength = list.length;
- // With memory, if we're not firing then
- // we should call right away
- } else if ( memory ) {
- firingStart = start;
- fire( memory );
- }
- }
- return this;
- },
- // Remove a callback from the list
- remove: function() {
- if ( list ) {
- jQuery.each( arguments, function( _, arg ) {
- var index;
- while( ( index = jQuery.inArray( arg, list, index ) ) > -1 ) {
- list.splice( index, 1 );
- // Handle firing indexes
- if ( firing ) {
- if ( index <= firingLength ) {
- firingLength--;
- }
- if ( index <= firingIndex ) {
- firingIndex--;
- }
- }
- }
- });
- }
- return this;
- },
- // Control if a given callback is in the list
- has: function( fn ) {
- return jQuery.inArray( fn, list ) > -1;
- },
- // Remove all callbacks from the list
- empty: function() {
- list = [];
- return this;
- },
- // Have the list do nothing anymore
- disable: function() {
- list = stack = memory = undefined;
- return this;
- },
- // Is it disabled?
- disabled: function() {
- return !list;
- },
- // Lock the list in its current state
- lock: function() {
- stack = undefined;
- if ( !memory ) {
- self.disable();
- }
- return this;
- },
- // Is it locked?
- locked: function() {
- return !stack;
- },
- // Call all callbacks with the given context and arguments
- fireWith: function( context, args ) {
- args = args || [];
- args = [ context, args.slice ? args.slice() : args ];
- if ( list && ( !fired || stack ) ) {
- if ( firing ) {
- stack.push( args );
- } else {
- fire( args );
- }
- }
- return this;
- },
- // Call all the callbacks with the given arguments
- fire: function() {
- self.fireWith( this, arguments );
- return this;
- },
- // To know if the callbacks have already been called at least once
- fired: function() {
- return !!fired;
- }
- };
-
- return self;
-};
-
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/jquery-deferred/lib/jquery-core.js
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/jquery-deferred/lib/jquery-core.js b/web/demos/package/node_modules/jquery-deferred/lib/jquery-core.js
deleted file mode 100644
index bc38e88..0000000
--- a/web/demos/package/node_modules/jquery-deferred/lib/jquery-core.js
+++ /dev/null
@@ -1,155 +0,0 @@
-/**
-* jQuery core object.
-*
-* Worker with jQuery deferred
-*
-* Code from: https://github.com/jquery/jquery/blob/master/src/core.js
-*
-*/
-
-var jQuery = module.exports = {
- type: type
- , isArray: isArray
- , isFunction: isFunction
- , isPlainObject: isPlainObject
- , each: each
- , extend: extend
- , noop: function() {}
-};
-
-var toString = Object.prototype.toString;
-
-var class2type = {};
-// Populate the class2type map
-"Boolean Number String Function Array Date RegExp Object".split(" ").forEach(function(name) {
- class2type[ "[object " + name + "]" ] = name.toLowerCase();
-});
-
-
-function type( obj ) {
- return obj == null ?
- String( obj ) :
- class2type[ toString.call(obj) ] || "object";
-}
-
-function isFunction( obj ) {
- return jQuery.type(obj) === "function";
-}
-
-function isArray( obj ) {
- return jQuery.type(obj) === "array";
-}
-
-function each( object, callback, args ) {
- var name, i = 0,
- length = object.length,
- isObj = length === undefined || isFunction( object );
-
- if ( args ) {
- if ( isObj ) {
- for ( name in object ) {
- if ( callback.apply( object[ name ], args ) === false ) {
- break;
- }
- }
- } else {
- for ( ; i < length; ) {
- if ( callback.apply( object[ i++ ], args ) === false ) {
- break;
- }
- }
- }
-
- // A special, fast, case for the most common use of each
- } else {
- if ( isObj ) {
- for ( name in object ) {
- if ( callback.call( object[ name ], name, object[ name ] ) === false ) {
- break;
- }
- }
- } else {
- for ( ; i < length; ) {
- if ( callback.call( object[ i ], i, object[ i++ ] ) === false ) {
- break;
- }
- }
- }
- }
-
- return object;
-}
-
-function isPlainObject( obj ) {
- // Must be an Object.
- if ( !obj || jQuery.type(obj) !== "object" ) {
- return false;
- }
- return true;
-}
-
-function extend() {
- var options, name, src, copy, copyIsArray, clone,
- target = arguments[0] || {},
- i = 1,
- length = arguments.length,
- deep = false;
-
- // Handle a deep copy situation
- if ( typeof target === "boolean" ) {
- deep = target;
- target = arguments[1] || {};
- // skip the boolean and the target
- i = 2;
- }
-
- // Handle case when target is a string or something (possible in deep copy)
- if ( typeof target !== "object" && !jQuery.isFunction(target) ) {
- target = {};
- }
-
- // extend jQuery itself if only one argument is passed
- if ( length === i ) {
- target = this;
- --i;
- }
-
- for ( ; i < length; i++ ) {
- // Only deal with non-null/undefined values
- if ( (options = arguments[ i ]) != null ) {
- // Extend the base object
- for ( name in options ) {
- src = target[ name ];
- copy = options[ name ];
-
- // Prevent never-ending loop
- if ( target === copy ) {
- continue;
- }
-
- // Recurse if we're merging plain objects or arrays
- if ( deep && copy && ( jQuery.isPlainObject(copy) || (copyIsArray = jQuery.isArray(copy)) ) ) {
- if ( copyIsArray ) {
- copyIsArray = false;
- clone = src && jQuery.isArray(src) ? src : [];
-
- } else {
- clone = src && jQuery.isPlainObject(src) ? src : {};
- }
-
- // Never move original objects, clone them
- target[ name ] = jQuery.extend( deep, clone, copy );
-
- // Don't bring in undefined values
- } else if ( copy !== undefined ) {
- target[ name ] = copy;
- }
- }
- }
- }
-
- // Return the modified object
- return target;
-};
-
-