File tree Expand file tree Collapse file tree 6 files changed +33
-33
lines changed Expand file tree Collapse file tree 6 files changed +33
-33
lines changed Original file line number Diff line number Diff line change @@ -2,32 +2,32 @@ function authorize(r) {
2
2
var signature = r . headersIn . Signature ;
3
3
4
4
if ( ! signature ) {
5
- r . error ( "No signature" ) ;
5
+ r . error ( "No signature" ) ;
6
6
r . return ( 401 ) ;
7
7
return ;
8
8
}
9
9
10
- if ( r . method != 'GET' ) {
11
- r . error ( `Unsupported method: ${ r . method } ` ) ;
10
+ if ( r . method != 'GET' ) {
11
+ r . error ( `Unsupported method: ${ r . method } ` ) ;
12
12
r . return ( 401 ) ;
13
13
return ;
14
- }
14
+ }
15
15
16
- var args = r . variables . args ;
16
+ var args = r . variables . args ;
17
17
18
18
var h = require ( 'crypto' ) . createHmac ( 'sha1' , process . env . SECRET_KEY ) ;
19
19
20
- h . update ( r . uri ) . update ( args ? args : "" ) ;
20
+ h . update ( r . uri ) . update ( args ? args : "" ) ;
21
21
22
22
var req_sig = h . digest ( "base64" ) ;
23
23
24
24
if ( req_sig != signature ) {
25
25
r . error ( `Invalid signature: ${ req_sig } \n` ) ;
26
- r . return ( 401 ) ;
26
+ r . return ( 401 ) ;
27
27
return ;
28
28
}
29
29
30
- r . return ( 200 ) ;
30
+ r . return ( 200 ) ;
31
31
}
32
32
33
33
export default { authorize}
Original file line number Diff line number Diff line change @@ -8,7 +8,7 @@ function authorize(r) {
8
8
9
9
var h = require ( 'crypto' ) . createHmac ( 'sha1' , process . env . SECRET_KEY ) ;
10
10
11
- h . update ( r . uri ) ;
11
+ h . update ( r . uri ) ;
12
12
13
13
switch ( r . method ) {
14
14
case 'GET' :
Original file line number Diff line number Diff line change @@ -24,7 +24,7 @@ function commit_db(map) {
24
24
25
25
try {
26
26
fs . writeFileSync ( DB , JSON . stringify ( map ) ) ;
27
- } catch ( e ) {
27
+ } catch ( e ) {
28
28
ret = 500 ;
29
29
}
30
30
Original file line number Diff line number Diff line change 1
1
async function join ( r ) {
2
- join_subrequests ( r , [ '/foo' , '/bar' ] ) ;
2
+ join_subrequests ( r , [ '/foo' , '/bar' ] ) ;
3
3
}
4
4
5
5
async function join_subrequests ( r , subs ) {
6
6
let results = await Promise . all ( subs . map ( uri => r . subrequest ( uri ) ) ) ;
7
7
8
- let response = results . map ( reply => ( {
8
+ let response = results . map ( reply => ( {
9
9
uri : reply . uri ,
10
10
code : reply . status ,
11
11
body : reply . responseBody ,
12
- } ) ) ;
12
+ } ) ) ;
13
13
14
14
r . return ( 200 , JSON . stringify ( response ) ) ;
15
15
}
Original file line number Diff line number Diff line change @@ -2,23 +2,23 @@ var fs = require('fs');
2
2
var STORAGE = "/tmp/njs_storage"
3
3
4
4
function push ( r ) {
5
- fs . appendFileSync ( STORAGE , r . requestBody ) ;
6
- r . return ( 200 ) ;
5
+ fs . appendFileSync ( STORAGE , r . requestBody ) ;
6
+ r . return ( 200 ) ;
7
7
}
8
8
9
9
function flush ( r ) {
10
- fs . writeFileSync ( STORAGE , "" ) ;
11
- r . return ( 200 ) ;
10
+ fs . writeFileSync ( STORAGE , "" ) ;
11
+ r . return ( 200 ) ;
12
12
}
13
13
14
14
function read ( r ) {
15
- var data = "" ;
16
- try {
17
- data = fs . readFileSync ( STORAGE ) ;
18
- } catch ( e ) {
19
- }
15
+ var data = "" ;
16
+ try {
17
+ data = fs . readFileSync ( STORAGE ) ;
18
+ } catch ( e ) {
19
+ }
20
20
21
- r . return ( 200 , data ) ;
21
+ r . return ( 200 , data ) ;
22
22
}
23
23
24
24
export default { push, flush, read} ;
Original file line number Diff line number Diff line change 1
1
var is_http = 0 ;
2
2
3
3
function detect_http ( s ) {
4
- s . on ( 'upload' , function ( data , flags ) {
5
- var n = data . indexOf ( '\r\n' ) ;
6
- if ( n != - 1 && data . substr ( 0 , n - 1 ) . endsWith ( " HTTP/1." ) ) {
7
- is_http = 1 ;
8
- }
4
+ s . on ( 'upload' , function ( data , flags ) {
5
+ var n = data . indexOf ( '\r\n' ) ;
6
+ if ( n != - 1 && data . substr ( 0 , n - 1 ) . endsWith ( " HTTP/1." ) ) {
7
+ is_http = 1 ;
8
+ }
9
9
10
- if ( data . length || flags . last ) {
11
- s . done ( ) ;
12
- }
13
- } ) ;
10
+ if ( data . length || flags . last ) {
11
+ s . done ( ) ;
12
+ }
13
+ } ) ;
14
14
}
15
15
16
16
function upstream_type ( s ) {
17
- return is_http ? "httpback" : "tcpback" ;
17
+ return is_http ? "httpback" : "tcpback" ;
18
18
}
19
19
20
20
export default { detect_http, upstream_type}
You can’t perform that action at this time.
0 commit comments