| /// <reference path="../../../typings/node/node.d.ts" /> |
| /// <reference path="../../../typings/mocha/mocha.d.ts" /> |
| /// <reference path="../../../typings/chai/chai.d.ts" /> |
| |
| 'use strict'; |
| |
| var path = require('path'); |
| var echo = require('../echo-chunks'); |
| var helper = require('../../test-helper'); |
| var gateway = require('../../../gateway/lib/gateway'); |
| var config = helper.config(); |
| |
| var chai = require('chai'); |
| var should = chai.should(); |
| var request = require('supertest'); |
| |
| var reference1 = |
| '<message>\n' + |
| ' <delay>100</delay>\n' + |
| ' <times>1</times>\n' + |
| '\n' + |
| ' <chunk>1</chunk>\n' + |
| ' <headers>\n' + |
| ' <accept-encoding>gzip, deflate</accept-encoding>\n' + |
| ' <user-agent>node-superagent/1.3.0</user-agent>\n' + |
| ' <connection>close</connection>\n' + |
| ' </headers>\n' + |
| '</message>\n'; |
| |
| var reference1_uppercase = |
| '<MESSAGE>\n' + |
| ' <DELAY>100</DELAY>\n' + |
| ' <TIMES>1</TIMES>\n' + |
| '\n' + |
| ' <CHUNK>1</CHUNK>\n' + |
| ' <HEADERS>\n' + |
| ' <ACCEPT-ENCODING>GZIP, DEFLATE</ACCEPT-ENCODING>\n' + |
| ' <USER-AGENT>NODE-SUPERAGENT/1.3.0</USER-AGENT>\n' + |
| ' <CONNECTION>CLOSE</CONNECTION>\n' + |
| ' </HEADERS>\n' + |
| '</MESSAGE>\n'; |
| |
| var reference2 = |
| '<message>\n' + |
| ' <delay>100</delay>\n' + |
| ' <times>1</times>\n' + |
| '\n' + |
| ' <chunk>1</chunk>\n' + |
| ' <headers>\n' + |
| ' <accept-encoding>gzip, deflate</accept-encoding>\n' + |
| ' <user-agent>node-superagent/1.3.0</user-agent>\n' + |
| ' <content-type>text/xml</content-type>\n' + |
| ' <connection>close</connection>\n' + |
| ' <content-length>234</content-length>\n' + |
| ' </headers>\n' + |
| ' <body>\n' + |
| reference1 + |
| ' </body>\n' + |
| '</message>\n'; |
| |
| var reference2_uppercase = |
| '<MESSAGE>\n' + |
| ' <DELAY>100</DELAY>\n' + |
| ' <TIMES>1</TIMES>\n' + |
| '\n' + |
| ' <CHUNK>1</CHUNK>\n' + |
| ' <HEADERS>\n' + |
| ' <ACCEPT-ENCODING>GZIP, DEFLATE</ACCEPT-ENCODING>\n' + |
| ' <USER-AGENT>NODE-SUPERAGENT/1.3.0</USER-AGENT>\n' + |
| ' <CONTENT-TYPE>TEXT/XML</CONTENT-TYPE>\n' + |
| ' <CONNECTION>CLOSE</CONNECTION>\n' + |
| ' <CONTENT-LENGTH>234</CONTENT-LENGTH>\n' + |
| ' </HEADERS>\n' + |
| ' <BODY>\n' + |
| reference1_uppercase + |
| ' </BODY>\n' + |
| '</MESSAGE>\n'; |
| |
| var reference2_uppercase_chunked = |
| '<MESSAGE>\n' + |
| ' <DELAY>100</DELAY>\n' + |
| ' <TIMES>1</TIMES>\n' + |
| '\n' + |
| ' <CHUNK>1</CHUNK>\n' + |
| ' <HEADERS>\n' + |
| ' <ACCEPT-ENCODING>GZIP, DEFLATE</ACCEPT-ENCODING>\n' + |
| ' <USER-AGENT>NODE-SUPERAGENT/1.3.0</USER-AGENT>\n' + |
| ' <CONTENT-TYPE>TEXT/XML</CONTENT-TYPE>\n' + |
| ' <CONNECTION>CLOSE</CONNECTION>\n' + |
| ' <TRANSFER-ENCODING>CHUNKED</TRANSFER-ENCODING>\n' + |
| ' </HEADERS>\n' + |
| ' <BODY>\n' + |
| reference1_uppercase + |
| ' </BODY>\n' + |
| '</MESSAGE>\n'; |
| |
| // replace Apigee Volos implementations with Memory versions |
| var replaceVolosApigeeWithMemory = function(gateway, impl) { |
| var base = path.join(process.cwd(), impl, 'node_modules'); |
| var apigee = require(path.join(base, 'volos-' + impl + '-apigee')); |
| var memory = require(path.join(base, 'volos-' + impl + '-memory')); |
| Object.keys(apigee).forEach(function(key) { |
| apigee[key] = memory[key]; |
| }); |
| } |
| replaceVolosApigeeWithMemory(gateway, 'analytics'); |
| |
| describe('transformation tests', function() { |
| |
| var url = '/hello?delay=100×=1'; |
| var echoServer; |
| |
| before(function(done) { |
| echo.start(function(err, es) { |
| if (err) return done(err); |
| echoServer = es; |
| done(); |
| }); |
| }); |
| |
| after(function() { |
| echo.stop(); |
| }); |
| |
| describe('response', function() { |
| |
| describe('just accumulate', function() { |
| |
| var gatewayServer; |
| var proxy; |
| |
| before(function(done) { |
| config.edgemicro.plugins.sequence = ['accumulate-response']; |
| helper.startServersWithTarget(config, echoServer, function(err, s) { |
| if (err) { return done(err); } |
| gatewayServer = s; |
| proxy = gatewayServer.proxy; |
| done(); |
| }); |
| }); |
| |
| after(function() { |
| gateway.stop(); |
| }); |
| |
| it('accumulate', function(done) { |
| request(proxy) |
| .get(url) |
| .expect(200) |
| .end(function(err, res) { |
| if (err) { return done(err); } |
| res.should.have.property('text').that.is.a.String; |
| res.text.length.should.be.above(0); |
| res.text.should.equal(reference1); |
| done(); |
| }); |
| }); |
| }); |
| |
| describe('just transform', function() { |
| |
| var gatewayServer; |
| var proxy; |
| |
| before(function(done) { |
| config.edgemicro.plugins.sequence = ['transform-uppercase']; |
| helper.startServersWithTarget(config, echoServer, function(err, s) { |
| if (err) { return done(err); } |
| gatewayServer = s; |
| proxy = gatewayServer.proxy; |
| done(); |
| }); |
| }); |
| |
| after(function() { |
| gateway.stop(); |
| }); |
| |
| it('transform', function(done) { |
| request(proxy) |
| .get(url) |
| .expect(200) |
| .end(function(err, res) { |
| if (err) { return done(err); } |
| res.should.have.property('text').that.is.a.String; |
| res.text.length.should.be.above(0); |
| res.text.should.equal(reference1_uppercase); |
| done(); |
| }); |
| }); |
| }); |
| |
| describe('accumulate then transform', function() { |
| |
| var gatewayServer; |
| var proxy; |
| |
| before(function(done) { |
| // sequnce is reversed for responses, these plugins modify responses |
| config.edgemicro.plugins.sequence = ['transform-uppercase', 'accumulate-response']; |
| helper.startServersWithTarget(config, echoServer, function(err, s) { |
| if (err) { return done(err); } |
| gatewayServer = s; |
| proxy = gatewayServer.proxy; |
| done(); |
| }); |
| }); |
| |
| after(function() { |
| gateway.stop(); |
| }); |
| |
| it('accumulate-transform', function(done) { |
| request(proxy) |
| .get(url) |
| .expect(200) |
| .end(function(err, res) { |
| if (err) { return done(err); } |
| res.should.have.property('text').that.is.a.String; |
| res.text.length.should.be.above(0); |
| res.text.should.equal(reference1_uppercase); |
| done(); |
| }); |
| }); |
| }); |
| |
| describe('transform then accumulate', function() { |
| |
| var gatewayServer; |
| var proxy; |
| |
| before(function(done) { |
| // sequnce is reversed for responses, these plugins modify responses |
| config.edgemicro.plugins.sequence = ['accumulate-response', 'transform-uppercase']; |
| helper.startServersWithTarget(config, echoServer, function(err, s) { |
| if (err) { return done(err); } |
| gatewayServer = s; |
| proxy = gatewayServer.proxy; |
| done(); |
| }); |
| }); |
| |
| after(function() { |
| gateway.stop(); |
| }); |
| |
| it('transform-accumulate', function(done) { |
| request(proxy) |
| .get(url) |
| .expect(200) |
| .end(function(err, res) { |
| if (err) { return done(err); } |
| res.should.have.property('text').that.is.a.String; |
| res.text.length.should.be.above(0); |
| res.text.should.equal(reference1_uppercase); |
| done(); |
| }); |
| }); |
| }); |
| }); |
| |
| describe('request', function() { |
| |
| describe('just accumulate', function() { |
| |
| var gatewayServer; |
| var proxy; |
| |
| before(function(done) { |
| config.edgemicro.plugins.sequence = ['accumulate-request']; |
| helper.startServersWithTarget(config, echoServer, function(err, s) { |
| if (err) { return done(err); } |
| gatewayServer = s; |
| proxy = gatewayServer.proxy; |
| done(); |
| }); |
| }); |
| |
| after(function() { |
| gateway.stop(); |
| }); |
| |
| it('accumulate', function(done) { |
| request(proxy) |
| .post(url) |
| .set('content-type', 'text/xml') |
| .send(reference1) |
| .expect(200) |
| .end(function(err, res) { |
| if (err) { return done(err); } |
| res.should.have.property('text').that.is.a.String; |
| res.text.length.should.be.above(0); |
| res.text.should.equal(reference2); |
| done(); |
| }); |
| }); |
| }); |
| |
| describe('just transform', function() { |
| |
| var gatewayServer; |
| var proxy; |
| |
| before(function(done) { |
| config.edgemicro.plugins.sequence = ['transform-uppercase']; |
| helper.startServersWithTarget(config, echoServer, function(err, s) { |
| if (err) { return done(err); } |
| gatewayServer = s; |
| proxy = gatewayServer.proxy; |
| done(); |
| }); |
| }); |
| |
| after(function() { |
| gateway.stop(); |
| }); |
| |
| it('transform', function(done) { |
| request(proxy) |
| .post(url) |
| .set('content-type', 'text/xml') |
| .send(reference1) |
| .expect(200) |
| .end(function(err, res) { |
| if (err) { return done(err); } |
| res.should.have.property('text').that.is.a.String; |
| res.text.length.should.be.above(0); |
| res.text.should.equal(reference2_uppercase_chunked); |
| done(); |
| }); |
| }); |
| }); |
| |
| describe('accumulate then transform', function() { |
| |
| var gatewayServer; |
| var proxy; |
| |
| before(function(done) { |
| config.edgemicro.plugins.sequence = ['accumulate-request', 'transform-uppercase']; |
| helper.startServersWithTarget(config, echoServer, function(err, s) { |
| if (err) { return done(err); } |
| gatewayServer = s; |
| proxy = gatewayServer.proxy; |
| done(); |
| }); |
| }); |
| |
| after(function() { |
| gateway.stop(); |
| }); |
| |
| it('accumulate-transform', function(done) { |
| request(proxy) |
| .post(url) |
| .set('content-type', 'text/xml') |
| .send(reference1) |
| .expect(200) |
| .end(function(err, res) { |
| if (err) { return done(err); } |
| res.should.have.property('text').that.is.a.String; |
| res.text.length.should.be.above(0); |
| res.text.should.equal(reference2_uppercase); |
| done(); |
| }); |
| }); |
| }); |
| |
| describe('transform then accumulate', function() { |
| |
| var gatewayServer; |
| var proxy; |
| |
| before(function(done) { |
| config.edgemicro.plugins.sequence = ['transform-uppercase', 'accumulate-request']; |
| helper.startServersWithTarget(config, echoServer, function(err, s) { |
| if (err) { return done(err); } |
| gatewayServer = s; |
| proxy = gatewayServer.proxy; |
| done(); |
| }); |
| }); |
| |
| after(function() { |
| gateway.stop(); |
| }); |
| |
| it('transform-accumulate', function(done) { |
| request(proxy) |
| .post(url) |
| .set('content-type', 'text/xml') |
| .send(reference1) |
| .expect(200) |
| .end(function(err, res) { |
| if (err) { return done(err); } |
| res.should.have.property('text').that.is.a.String; |
| res.text.length.should.be.above(0); |
| res.text.should.equal(reference2_uppercase); |
| done(); |
| }); |
| }); |
| }); |
| }); |
| |
| }); |
