1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104
|
#!/usr/bin/perl
# (C) Dmitry Volyntsev
# (C) Nginx, Inc.
# Tests for stream njs module, js_var directive.
###############################################################################
use warnings;
use strict;
use Test::More;
BEGIN { use FindBin; chdir($FindBin::Bin); }
use lib 'lib';
use Test::Nginx;
use Test::Nginx::Stream qw/ stream /;
###############################################################################
select STDERR; $| = 1;
select STDOUT; $| = 1;
my $t = Test::Nginx->new()->has(qw/stream stream_return/)
->write_file_expand('nginx.conf', <<'EOF');
%%TEST_GLOBALS%%
daemon off;
events {
}
stream {
%%TEST_GLOBALS_STREAM%%
js_import test.js;
js_var $foo;
js_var $XXXXXXXXXXXXXXXX;
js_var $bar a:$remote_addr;
js_set $var test.varr;
js_set $lowkey test.lowkey;
js_set $lowkey_set test.lowkey_set;
server {
listen 127.0.0.1:8081;
return $bar$foo;
}
server {
listen 127.0.0.1:8082;
return $var$foo;
}
server {
listen 127.0.0.1:8083;
return $lowkey;
}
server {
listen 127.0.0.1:8084;
return $lowkey_set;
}
}
EOF
$t->write_file('test.js', <<EOF);
function varr(s) {
s.variables.foo = 'xxx';
return '';
}
function lowkey(s) {
const name = 'X'.repeat(16);
let v = s.variables[name];
return name;
}
function lowkey_set(s) {
const name = 'X'.repeat(16);
s.variables[name] = 1;
return name;
}
export default {varr, lowkey, lowkey_set};
EOF
$t->try_run('no stream js_var')->plan(4);
###############################################################################
is(stream('127.0.0.1:' . port(8081))->io('###'), 'a:127.0.0.1',
'default value');
is(stream('127.0.0.1:' . port(8082))->io('###'), 'xxx', 'value set');
is(stream('127.0.0.1:' . port(8083))->io('###'), 'XXXXXXXXXXXXXXXX',
'variable name is not overwritten while reading');
is(stream('127.0.0.1:' . port(8084))->io('###'), 'XXXXXXXXXXXXXXXX',
'variable name is not overwritten while writing');
###############################################################################
|