-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathmod.ts
131 lines (110 loc) · 2.81 KB
/
mod.ts
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
/*!
* Based on https://github.com/jshttp/vary/blob/master/index.js
* Copyright(c) 2014-2017 Douglas Christopher Wilson
* Copyright(c) 2020 Henry Zhuang
* MIT Licensed
*/
/**
* RegExp to match field-name in RFC 7230 sec 3.2
*
* field-name = token
* token = 1*tchar
* tchar = "!" / "#" / "$" / "%" / "&" / "'" / "*"
* / "+" / "-" / "." / "^" / "_" / "`" / "|" / "~"
* / DIGIT / ALPHA
* ; any VCHAR, except delimiters
*/
const FIELD_NAME_REGEXP = /^[!#$%&'*+\-.^_`|~0-9A-Za-z]+$/;
/**
* Append a field to a vary header.
*
* @param {String} header
* @param {String|Array} field
* @return {String}
* @public
*/
export function append(header: string, field: string | string[]): string {
// if (typeof header !== 'string') {
// throw new TypeError('header argument is required')
// }
// if (!field) {
// throw new TypeError('field argument is required')
// }
// existing, unspecified vary
if (header === "*") {
return header;
}
// get fields array
const fields = !Array.isArray(field) ? parse(String(field)) : field;
// assert on invalid field names
for (let j = 0; j < fields.length; j++) {
if (!FIELD_NAME_REGEXP.test(fields[j])) {
throw new TypeError(
`field argument contains an invalid header name \`${fields[j]}\``,
);
}
}
// enumerate current values
let val = header;
const vals = parse(header.toLowerCase());
// unspecified vary
if (fields.indexOf("*") !== -1 || vals.indexOf("*") !== -1) {
return "*";
}
for (let i = 0; i < fields.length; i++) {
const fld = fields[i].toLowerCase();
// append value (case-preserving)
if (vals.indexOf(fld) === -1) {
vals.push(fld);
val = val ? val + ", " + fields[i] : fields[i];
}
}
return val;
}
/**
* Parse a vary header into an array.
*
* @param {String} header
* @return {Array}
* @private
*/
function parse(header: string): string[] {
let end = 0;
const list = [];
let start = 0;
// gather tokens
for (let i = 0, len = header.length; i < len; i++) {
switch (header.charCodeAt(i)) {
case 0x20:/* */
if (start === end) {
start = end = i + 1;
}
break;
case 0x2c:/* , */
list.push(header.substring(start, end));
start = end = i + 1;
break;
default:
end = i + 1;
break;
}
}
// final token
list.push(header.substring(start, end));
return list;
}
/**
* Mark that a request is varied on a header field.
*
* @param {Headers} header
* @param {String|Array} field
* @public
*/
export function vary(header: Headers, field: string | string[]): void {
// get existing header
let val = header.get("vary") || "";
// set new header
if ((val = append(val, field))) {
header.set("vary", val);
}
}