mirror of
https://github.com/uNetworking/uWebSockets.js.git
synced 2026-04-16 23:00:27 -04:00
76 lines
3.0 KiB
JavaScript
76 lines
3.0 KiB
JavaScript
/*
|
|
* Authored by Alex Hultman, 2018-2026.
|
|
* Intellectual property of third-party.
|
|
|
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
* you may not use this file except in compliance with the License.
|
|
* You may obtain a copy of the License at
|
|
|
|
* http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
* Unless required by applicable law or agreed to in writing, software
|
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
* See the License for the specific language governing permissions and
|
|
* limitations under the License.
|
|
*/
|
|
|
|
module.exports = (() => {
|
|
try {
|
|
return require('./uws_' + process.platform + '_' + process.arch + '_' + process.versions.modules + '.node');
|
|
} catch (e) {
|
|
throw new Error('This version of uWS.js (v20.60.0) supports only Node.js versions 20, 22, 24 and 25 on (glibc) Linux, macOS and Windows, on Tier 1 platforms (https://github.com/nodejs/node/blob/master/BUILDING.md#platform-list).\n\n' + e.toString());
|
|
}
|
|
})();
|
|
|
|
const MAX_U8 = Math.pow(2, 8) - 1;
|
|
const MAX_U16 = Math.pow(2, 16) - 1;
|
|
const textEncoder = new TextEncoder();
|
|
|
|
/**
|
|
* @param {RecognizedString|undefined} value
|
|
* @return {Uint8Array<ArrayBuffer>}
|
|
*/
|
|
const toUint8Array = (value) => {
|
|
if (value === undefined) return new Uint8Array(0);
|
|
else if (typeof value === 'string') return textEncoder.encode(value);
|
|
else if (value instanceof ArrayBuffer) return new Uint8Array(value);
|
|
else return new Uint8Array(value.buffer, value.byteOffset, value.byteLength);
|
|
};
|
|
|
|
module.exports.DeclarativeResponse = class DeclarativeResponse {
|
|
constructor() {
|
|
this.instructions = [];
|
|
}
|
|
|
|
// Append instruction and 1-byte length values
|
|
_appendInstruction(opcode, ...values) {
|
|
this.instructions.push(opcode);
|
|
values.forEach(value => {
|
|
const uint8Array = toUint8Array(value);
|
|
if (uint8Array.byteLength > MAX_U8) throw new RangeError('Data length exceeds '+ MAX_U8);
|
|
this.instructions.push(uint8Array.byteLength, ...uint8Array);
|
|
});
|
|
}
|
|
|
|
// Append instruction and 2-byte length value
|
|
_appendInstructionWithLength(opcode, value) {
|
|
const uint8Array = toUint8Array(value);
|
|
if (uint8Array.byteLength > MAX_U16) throw new RangeError('Data length exceeds '+ MAX_U16);
|
|
this.instructions.push(opcode, uint8Array.byteLength & 0xff, (uint8Array.byteLength >> 8) & 0xff, ...uint8Array);
|
|
}
|
|
|
|
writeHeader(key, value) { return this._appendInstruction(1, key, value), this; }
|
|
writeBody() { return this.instructions.push(2), this; }
|
|
writeQueryValue(key) { return this._appendInstruction(3, key), this; }
|
|
writeHeaderValue(key) { return this._appendInstruction(4, key), this; }
|
|
write(value) { return this._appendInstructionWithLength(5, value), this; }
|
|
writeParameterValue(key) { return this._appendInstruction(6, key), this; }
|
|
writeStatus(status) { return this._appendInstruction(7, status), this; }
|
|
|
|
end(value) {
|
|
this._appendInstructionWithLength(0, value);
|
|
return new Uint8Array(this.instructions).buffer;
|
|
}
|
|
}
|