blob: b6943550f3c481133ed6bb1f523bead26e89e8f6 [file] [log] [blame]
#!/usr/bin/perl
# (C) Roman Arutyunyan
# (C) Dmitry Volyntsev
# (C) Nginx, Inc.
# Tests for http njs module.
###############################################################################
use warnings;
use strict;
use Test::More;
use Socket qw/ CRLF /;
BEGIN { use FindBin; chdir($FindBin::Bin); }
use lib 'lib';
use Test::Nginx;
###############################################################################
select STDERR; $| = 1;
select STDOUT; $| = 1;
my $t = Test::Nginx->new()->has(qw/http rewrite/)
->write_file_expand('nginx.conf', <<'EOF');
%%TEST_GLOBALS%%
daemon off;
events {
}
http {
%%TEST_GLOBALS_HTTP%%
js_set $test_method test.method;
js_set $test_version test.version;
js_set $test_addr test.addr;
js_set $test_uri test.uri;
js_set $test_arg test.arg;
js_set $test_iarg test.iarg;
js_set $test_var test.variable;
js_set $test_type test.type;
js_set $test_global test.global_obj;
js_set $test_log test.log;
js_set $test_except test.except;
js_import test.js;
server {
listen 127.0.0.1:8080;
server_name localhost;
location /njs {
js_content test.njs;
}
location /method {
return 200 $test_method;
}
location /version {
return 200 $test_version;
}
location /addr {
return 200 $test_addr;
}
location /uri {
return 200 $test_uri;
}
location /arg {
return 200 $test_arg;
}
location /iarg {
return 200 $test_iarg;
}
location /var {
return 200 $test_var;
}
location /global {
return 200 $test_global;
}
location /body {
js_content test.request_body;
}
location /in_file {
client_body_in_file_only on;
js_content test.request_body;
}
location /status {
js_content test.status;
}
location /request_body {
js_content test.request_body;
}
location /request_body_cache {
js_content test.request_body_cache;
}
location /send {
js_content test.send;
}
location /return_method {
js_content test.return_method;
}
location /arg_keys {
js_content test.arg_keys;
}
location /type {
js_content test.type;
}
location /log {
return 200 $test_log;
}
location /except {
return 200 $test_except;
}
location /content_except {
js_content test.content_except;
}
location /content_empty {
js_content test.content_empty;
}
}
}
EOF
$t->write_file('test.js', <<EOF);
var global = ['n', 'j', 's'].join("");
function test_njs(r) {
r.return(200, njs.version);
}
function method(r) {
return 'method=' + r.method;
}
function version(r) {
return 'version=' + r.httpVersion;
}
function addr(r) {
return 'addr=' + r.remoteAddress;
}
function uri(r) {
return 'uri=' + r.uri;
}
function arg(r) {
return 'arg=' + r.args.foo;
}
function iarg(r) {
var s = '', a;
for (a in r.args) {
if (a.substr(0, 3) == 'foo') {
s += r.args[a];
}
}
return s;
}
function variable(r) {
return 'variable=' + r.variables.remote_addr;
}
function global_obj(r) {
return 'global=' + global;
}
function status(r) {
r.status = 204;
r.sendHeader();
r.finish();
}
function request_body(r) {
try {
var body = r.requestBody;
r.return(200, body);
} catch (e) {
r.return(500, e.message);
}
}
function request_body_cache(r) {
function t(v) {return Buffer.isBuffer(v) ? 'buffer' : (typeof v);}
r.return(200,
`requestText:\${t(r.requestText)} requestBuffer:\${t(r.requestBuffer)}`);
}
function send(r) {
var a, s;
r.status = 200;
r.sendHeader();
for (a in r.args) {
if (a.substr(0, 3) == 'foo') {
s = r.args[a];
r.send('n=' + a + ', v=' + s.substr(0, 2) + ' ');
}
}
r.finish();
}
function return_method(r) {
r.return(Number(r.args.c), r.args.t);
}
function arg_keys(r) {
r.return(200, Object.keys(r.args).sort());
}
function type(r) {
var p = r.args.path.split('.').reduce((a, v) => a[v], r);
var typ = Buffer.isBuffer(p) ? 'buffer' : (typeof p);
r.return(200, `type: \${typ}`);
}
function log(r) {
r.log('SEE-LOG');
}
function except(r) {
var fs = require('fs');
fs.readFileSync();
}
function content_except(r) {
JSON.parse({}.a.a);
}
function content_empty(r) {
}
export default {njs:test_njs, method, version, addr, uri, arg, iarg,
variable, global_obj, status, request_body,
request_body_cache, send, return_method, arg_keys,
type, log, except, content_except, content_empty};
EOF
$t->try_run('no njs available')->plan(33);
###############################################################################
like(http_get('/method'), qr/method=GET/, 'r.method');
like(http_get('/version'), qr/version=1.0/, 'r.httpVersion');
like(http_get('/addr'), qr/addr=127.0.0.1/, 'r.remoteAddress');
like(http_get('/uri'), qr/uri=\/uri/, 'r.uri');
like(http_get('/arg?foO=12345'), qr/arg=12345/, 'r.args');
like(http_get('/iarg?foo=12345&foo2=bar&nn=22&foo-3=z'), qr/12345barz/,
'r.args iteration');
like(http_get('/iarg?foo=123&foo2=&foo3&foo4=456'), qr/123undefined456/,
'r.args iteration 2');
like(http_get('/iarg?foo=123&foo2=&foo3'), qr/123/, 'r.args iteration 3');
like(http_get('/iarg?foo=123&foo2='), qr/123/, 'r.args iteration 4');
like(http_get('/status'), qr/204 No Content/, 'r.status');
like(http_post('/body'), qr/REQ-BODY/, 'request body');
like(http_post('/in_file'), qr/request body is in a file/,
'request body in file');
like(http_post_big('/body'), qr/200.*^(1234567890){1024}$/ms,
'request body big');
like(http_get('/send?foo=12345&n=11&foo-2=bar&ndd=&foo-3=z'),
qr/n=foo, v=12 n=foo-2, v=ba n=foo-3, v=z/, 'r.send');
like(http_get('/return_method?c=200'), qr/200 OK.*\x0d\x0a?\x0d\x0a?$/s,
'return code');
like(http_get('/return_method?c=200&t=SEE-THIS'), qr/200 OK.*^SEE-THIS$/ms,
'return text');
like(http_get('/return_method?c=301&t=path'), qr/ 301 .*Location: path/s,
'return redirect');
like(http_get('/return_method?c=404'), qr/404 Not.*html/s, 'return error page');
like(http_get('/return_method?c=inv'), qr/ 500 /, 'return invalid');
like(http_get('/arg_keys?b=1&c=2&a=5'), qr/a,b,c/m, 'r.args sorted keys');
TODO: {
local $TODO = 'not yet'
unless http_get('/njs') =~ /^([.0-9]+)$/m && $1 ge '0.5.0';
like(http_get('/type?path=variables.host'), qr/200 OK.*type: string$/s,
'variables type');
like(http_get('/type?path=rawVariables.host'), qr/200 OK.*type: buffer$/s,
'rawVariables type');
like(http_post('/type?path=requestBody'), qr/200 OK.*type: string$/s,
'requestBody type');
like(http_post('/type?path=requestText'), qr/200 OK.*type: string$/s,
'requestText type');
like(http_post('/type?path=requestBuffer'), qr/200 OK.*type: buffer$/s,
'requestBuffer type');
like(http_post('/request_body_cache'),
qr/requestText:string requestBuffer:buffer$/s, 'request body cache');
}
like(http_get('/var'), qr/variable=127.0.0.1/, 'r.variables');
like(http_get('/global'), qr/global=njs/, 'global code');
like(http_get('/log'), qr/200 OK/, 'r.log');
http_get('/except');
http_get('/content_except');
like(http_get('/content_empty'), qr/500 Internal Server Error/,
'empty handler');
$t->stop();
ok(index($t->read_file('error.log'), 'SEE-LOG') > 0, 'log js');
ok(index($t->read_file('error.log'), 'at fs.readFileSync') > 0,
'js_set backtrace');
ok(index($t->read_file('error.log'), 'at JSON.parse') > 0,
'js_content backtrace');
###############################################################################
sub http_get_hdr {
my ($url, %extra) = @_;
return http(<<EOF, %extra);
GET $url HTTP/1.0
FoO: 12345
EOF
}
sub http_get_ihdr {
my ($url, %extra) = @_;
return http(<<EOF, %extra);
GET $url HTTP/1.0
foo: 12345
Host: localhost
foo2: bar
X-xxx: more
foo-3: z
EOF
}
sub http_post {
my ($url, %extra) = @_;
my $p = "POST $url HTTP/1.0" . CRLF .
"Host: localhost" . CRLF .
"Content-Length: 8" . CRLF .
CRLF .
"REQ-BODY";
return http($p, %extra);
}
sub http_post_big {
my ($url, %extra) = @_;
my $p = "POST $url HTTP/1.0" . CRLF .
"Host: localhost" . CRLF .
"Content-Length: 10240" . CRLF .
CRLF .
("1234567890" x 1024);
return http($p, %extra);
}
###############################################################################