+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 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 +105 +106 +107 +108 +109 +110 +111 +112 +113 +114 +115 +116 +117 +118 +119 +120 +121 +122 +123 +124 +125 +126 +127 +128 +129 +130 +131 +132 +133 +134 +135 +136 +137 +138 +139 +140 +141 +142 +143 +144 +145 +146 +147 +148 +149 +150 +151 +152 +153 +154 +155 +156 +157 +158 +159 +160 +161 +162 +163 +164 +165 +166 +167 +168 +169 +170 +171 +172 +173 +174 +175 +176 +177 +178 +179 +180 +181 +182 +183 +184 +185 +186 +187 +188 +189 +190 +191 +192 +193 +194 +195 +196 +197 +198 +199 +200 +201 +202 +203 +204 +205 +206 +207 +208 +209 +210 +211 +212 +213 +214 +215 +216 +217 +218 +219 +220 +221 +222 +223 +224 +225 +226 +227 +228 +229 +230 +231 +232 +233 +234 +235 +236 +237 +238 +239 +240 +241 +242 +243 +244 +245 +246 +247 +248 +249 +250 +251 +252 +253 +254 +255 +256 +257 +258 +259 +260 +261 +262 +263 +264 +265 +266 +267 +268 +269 +270 +271 +272 +273 +274 | 1x +1x +1x +1x +1x +1x +1x +1x + + + + + + + + + + + +1x +4x +4x +4x +1x +1x +1x +1x +3x +3x +4x +1x +1x +1x +1x +2x +2x +2x +2x +2x +2x +2x +2x +2x +4x +1x +1x +1x +1x +1x +1x +5x +5x +5x +5x +5x +2x +2x +2x +2x +3x +5x +1x +1x +1x +2x +5x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +4x +4x +2x +2x +2x +4x +1x +1x +1x +1x +1x +1x +8x +8x +14x +14x +14x +3x +3x +14x +2x +2x +14x +2x +2x +2x +1x +24x +24x +24x +1x +1x +23x +23x +24x +3x +3x +20x +20x +24x +12x +12x +12x +5x +5x +12x +3x +3x +12x +12x +12x +24x +9x +9x +9x +4x +4x +9x +1x +1x +9x +7x +7x +7x +7x +1x +19x +19x +23x +23x +23x +23x +5x +5x +18x +18x +18x +18x +18x +23x +4x +4x +14x +14x +14x +14x +14x +14x +23x +1x +1x +13x +23x +11x +11x +2x +2x +23x +2x +2x +2x +1x +1x +2x +23x +10x +10x +10x +1x +23x +23x +23x +34x +34x +34x +34x +34x +34x +34x +34x +34x +34x +34x +3x +3x +31x +31x +31x +31x +31x +31x +31x +31x +34x +1x +1x +30x +30x +30x +30x +34x +1x +1x +29x +29x +29x +29x +29x +29x +29x +29x +34x +7x +7x +22x +22x +34x +2x +2x +22x +34x +20x +20x +3x +3x +34x +2x +2x +1x +1x +2x +34x +7x +7x +7x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x +1x + | import qs from 'querystring';
+
+const MATCHES_KEY = 'match_key';
+const HTTP_CODES = {
+ notFound: 404,
+ internalServerError: 500,
+};
+
+function redirect(r) {
+ let matchList;
+ try {
+ matchList = extractMatchesFromRequest(r, matches);
+ } catch (e) {
+ r.error(e.message);
+ r.return(HTTP_CODES.internalServerError);
+ return;
+ }
+ redirectForMatchList(r, matchList);
+}
+
+function extractMatchesFromRequest(r, matches) {
+ let matchList;
+ if (!r.variables[MATCHES_KEY]) {
+ throw Error(
+ `cannot redirect the request; the ${MATCHES_KEY} is not defined on the request object`,
+ );
+ }
+
+ let key = r.variables[MATCHES_KEY];
+ if (!matches[key]) {
+ throw Error(
+ `cannot redirect the request; the key ${key} is not defined on the matches object`,
+ );
+ }
+
+ // matchList is a list of http matches in order of precedence.
+ // We will accept the first match that the request satisfies.
+ // If there's a match, redirect request to internal location block.
+ // If an exception occurs, return 500.
+ // If no matches are found, return 404.
+ matchList = matches[key];
+ try {
+ verifyMatchList(matchList);
+ } catch (e) {
+ throw Error(`cannot redirect the request; ${matchList} matches list is not valid: ${e}`);
+ }
+
+ return matchList;
+}
+
+function redirectForMatchList(r, matchList) {
+ let match;
+ try {
+ match = findWinningMatch(r, matchList);
+ } catch (e) {
+ r.error(e.message);
+ r.return(HTTP_CODES.internalServerError);
+ return;
+ }
+
+ if (!match) {
+ r.return(HTTP_CODES.notFound);
+ return;
+ }
+
+ if (!match.redirectPath) {
+ r.error(
+ `cannot redirect the request; the match ${JSON.stringify(
+ match,
+ )} does not have a redirectPath set`,
+ );
+ r.return(HTTP_CODES.internalServerError);
+ return;
+ }
+
+ // If performing a rewrite, $request_uri won't be used,
+ // so we have to preserve args in the internal redirect.
+ let args = qs.stringify(r.args);
+ if (args) {
+ args = '?' + args;
+ }
+
+ r.internalRedirect(match.redirectPath + args);
+}
+
+function verifyMatchList(matchList) {
+ if (!Array.isArray(matchList)) {
+ throw Error(`cannot redirect the request; expected a list of matches, got ${matchList}`);
+ }
+
+ if (matchList.length === 0) {
+ throw Error(`cannot redirect the request; matches is an empty list`);
+ }
+
+ return;
+}
+
+function findWinningMatch(r, matches) {
+ for (let i = 0; i < matches.length; i++) {
+ try {
+ let found = testMatch(r, matches[i]);
+ if (found) {
+ return matches[i];
+ }
+ } catch (e) {
+ throw e;
+ }
+ }
+
+ return null;
+}
+
+function testMatch(r, match) {
+ // check for any
+ if (match.any) {
+ return true;
+ }
+
+ // check method
+ if (match.method && r.method !== match.method) {
+ return false;
+ }
+
+ // check headers
+ if (match.headers) {
+ try {
+ let found = headersMatch(r.headersIn, match.headers);
+ if (!found) {
+ return false;
+ }
+ } catch (e) {
+ throw e;
+ }
+ }
+
+ // check params
+ if (match.params) {
+ try {
+ let found = paramsMatch(r.args, match.params);
+ if (!found) {
+ return false;
+ }
+ } catch (e) {
+ throw e;
+ }
+ }
+
+ // all match conditions are satisfied so return true
+ return true;
+}
+
+function headersMatch(requestHeaders, headers) {
+ for (let i = 0; i < headers.length; i++) {
+ const h = headers[i];
+ const kv = h.split(':');
+
+ if (kv.length !== 3) {
+ throw Error(`invalid header match: ${h}`);
+ }
+ // Header names are compared in a case-insensitive manner, meaning header name "FOO" is equivalent to "foo".
+ // The NGINX request's headersIn object lookup is case-insensitive as well.
+ // This means that requestHeaders['FOO'] is equivalent to requestHeaders['foo'].
+ let val = requestHeaders[kv[0]];
+
+ if (!val) {
+ return false;
+ }
+
+ // split on comma because nginx uses commas to delimit multiple header values
+ const values = val.split(',');
+
+ let type = kv[1];
+ // verify the type of header match
+ if (!(type == 'Exact' || type == 'RegularExpression')) {
+ throw Error(`invalid header match type: ${type}`);
+ }
+
+ if (type === 'Exact') {
+ console.log('exact')
+ if (!values.includes(kv[2])) {
+ return false;
+ }
+ } else if (type === 'RegularExpression') {
+ console.log('regexp')
+ console.log(!values.some(v => new RegExp(kv[2]).test(v)))
+ if (!values.some((v) => new RegExp(kv[2]).test(v))) {
+ return false;
+ }
+ }
+ }
+
+ return true;
+}
+
+function paramsMatch(requestParams, params) {
+ console.log("paramsMatch")
+ for (let i = 0; i < params.length; i++) {
+ let p = params[i];
+ // We store query parameter matches as strings with the format "key=MatchType=value"; however, there may be more than one
+ // instance of "=" in the string.
+ // To recover the key and value, we need to find the first occurrence of "=" in the string.
+ const firstIdx = p.indexOf('=');
+
+ console.log(firstIdx)
+ // Check for an improperly constructed query parameter match. There are two possible error cases:
+ // (1) if the index is -1, then there are no "=" in the string (e.g. "keyExactvalue")
+ // (2) if the index is 0, then there is no key in the string (e.g. "=Exact=value").
+ if (firstIdx === -1 || firstIdx === 0) {
+ throw Error(`invalid query parameter: ${p}`);
+ }
+
+ // find the next occurence of "=" in the string
+ const idx = p.indexOf('=', firstIdx + 1);
+
+ // Check for an improperly constructed query parameter match. There are three possible error cases:
+ // (1) if the index is -1, then there are no second occurence of "=" in the string (e.g. "Exactvalue")
+ // (2) if the index is 0, then there is no value in the string and has only one "=" (e.g. "key=Exact").
+ // (3) if the index is equal to length -1, then there is no key and type in the string (e.g. "=Exact=value").
+ if (idx === -1 || idx === 0 || idx === p.length - 1) {
+ throw Error(`invalid query parameter: ${p}`);
+ }
+
+ // extract the type match from the string
+ const type = p.slice(firstIdx + 1, idx);
+
+ if (!(type == 'Exact' || type == 'RegularExpression')) {
+ throw Error(`invalid header match type: ${type}`);
+ }
+
+ // Divide string into key value using the index.
+ let kv = [p.slice(0, firstIdx), p.slice(idx + 1)];
+
+ // val can either be a string or an array of strings.
+ // Also, the NGINX request's args object lookup is case-sensitive.
+ // For example, 'a=1&b=2&A=3&b=4' will be parsed into {a: "1", b: ["2", "4"], A: "3"}
+ let val = requestParams[kv[0]];
+ if (!val) {
+ return false;
+ }
+
+ // If val is an array, we will match against the first element in the array according to the Gateway API spec.
+ if (Array.isArray(val)) {
+ val = val[0];
+ }
+
+ if (type === 'Exact') {
+ console.log('exact')
+ if (val !== kv[1]) {
+ return false;
+ }
+ } else if (type === 'RegularExpression') {
+ console.log('regexp')
+ if (!new RegExp(kv[1]).test(val)) {
+ return false;
+ }
+ }
+ }
+
+ return true;
+}
+
+export default {
+ redirect,
+ redirectForMatchList,
+ extractMatchesFromRequest,
+ MATCHES_KEY,
+ verifyMatchList,
+ testMatch,
+ findWinningMatch,
+ headersMatch,
+ paramsMatch,
+ HTTP_CODES,
+};
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| httpmatches.js | +
+
+ |
+ 95.97% | +262/273 | +100% | +69/69 | +87.5% | +7/8 | +95.97% | +262/273 | +