File Explorer

1"use strict";2/*3 * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.4 * SPDX-License-Identifier: Apache-2.0.5 */6Object.defineProperty(exports, "__esModule", { value: true });7exports.unmarshalInt64BigintFromBuffer = exports.marshalInt64BigintAsBuffer = exports.MIN_INT64 = exports.MAX_INT64 = exports.MIN_INT32 = exports.MAX_INT32 = exports.MIN_INT16 = exports.MAX_INT16 = exports.MIN_INT8 = exports.MAX_INT8 = void 0;8const error_1 = require("./error");9/*10* Limits for header value validation11*/12exports.MAX_INT8 = 127;13exports.MIN_INT8 = -128;14exports.MAX_INT16 = 32767;15exports.MIN_INT16 = -32768;16exports.MAX_INT32 = 2147483647;17exports.MIN_INT32 = -2147483648;18exports.MAX_INT64 = BigInt("9223372036854775807");19exports.MIN_INT64 = BigInt("-9223372036854775808");20const MAX_UINT8_AS_BIGINT = BigInt("256");21/** @internal */22function marshalInt64BigintAsBuffer(value) {23    if (value < exports.MIN_INT64 || value > exports.MAX_INT64) {24        throw new error_1.CrtError("marshalInt64BigintAsBuffer expects a value that can fit in 8 bytes");25    }26    let buffer = new Uint8Array(8);27    /* encode the integer as a twos-complement byte sequence */28    if (value < 0) {29        value = -value - BigInt(1);30        for (let i = 0; i < 8; ++i) {31            buffer[i] = 255 - Number(value % MAX_UINT8_AS_BIGINT);32            value /= MAX_UINT8_AS_BIGINT;33        }34    }35    else {36        for (let i = 0; i < 8; ++i) {37            buffer[i] = Number(value % MAX_UINT8_AS_BIGINT);38            value /= MAX_UINT8_AS_BIGINT;39        }40    }41    return buffer;42}43exports.marshalInt64BigintAsBuffer = marshalInt64BigintAsBuffer;44/** @internal */45function unmarshalInt64BigintFromBuffer(buffer) {46    let value = BigInt(0);47    let byteView = new Uint8Array(buffer);48    if (byteView.length != 8) {49        throw new error_1.CrtError("unmarshalInt64BigintFromBuffer expects a byte buffer of length 8");50    }51    let shift = BigInt(1);52    let isNegative = (byteView[7] & 0x80) != 0;53    /* encoding is two's-complement, so treat negative and non-negative differently */54    if (isNegative) {55        for (let i = 0; i < byteView.length; ++i) {56            let byteValue = BigInt(255 - byteView[i]);57            value += (byteValue * shift);58            shift *= MAX_UINT8_AS_BIGINT;59        }60        value += BigInt(1);61        value = -value;62    }63    else {64        for (let i = 0; i < byteView.length; ++i) {65            let byteValue = BigInt(byteView[i]);66            value += (byteValue * shift);67            shift *= MAX_UINT8_AS_BIGINT;68        }69    }70    return value;71}72exports.unmarshalInt64BigintFromBuffer = unmarshalInt64BigintFromBuffer;73//# sourceMappingURL=eventstream_utils.js.map