File Explorer

/var/runtime/node_modules/@aws-sdk/node_modules/aws-crt/lib/native
This explorer reads the filesystem of the server it runs on, so /workspace/user isn't present here. Browsing and the terminal still work against this server's own disk from /.
0 dirs
33 files
eventstream_headers.spec.ts9.4 KB · 261 lines
1/*2 * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.3 * SPDX-License-Identifier: Apache-2.0.4 */5 6import * as eventstream from './eventstream';7 8jest.setTimeout(10000);9 10let DEFAULT_HEADER_NAME: string = "MyHeader";11 12test('Eventstream header - new failure, empty name', async () => {13    expect(() => {eventstream.Header.newBoolean("", true);}).toThrow();14});15 16test('Eventstream header - new failure, too long name', async () => {17    expect(() => {eventstream.Header.newBoolean("aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa", true);}).toThrow();18});19 20function checkTypeCasts(header: eventstream.Header, type: eventstream.HeaderType) {21 22    expect(header.type).toEqual(type);23 24    if (type != eventstream.HeaderType.BooleanTrue && type != eventstream.HeaderType.BooleanFalse) {25        expect(() => {26            header.asBoolean();27        }).toThrow();28    }29 30    if (type != eventstream.HeaderType.Byte) {31        expect(() => {32            header.asByte();33        }).toThrow();34    }35 36    if (type != eventstream.HeaderType.Int16) {37        expect(() => {38            header.asInt16();39        }).toThrow();40    }41 42    if (type != eventstream.HeaderType.Int32) {43        expect(() => {44            header.asInt32();45        }).toThrow();46    }47 48    if (type != eventstream.HeaderType.Int64) {49        expect(() => {50            header.asInt64();51        }).toThrow();52    }53 54    if (type != eventstream.HeaderType.Timestamp) {55        expect(() => {56            header.asTimestamp();57        }).toThrow();58    }59 60    if (type != eventstream.HeaderType.String) {61        expect(() => {62            header.asString();63        }).toThrow();64    }65 66    if (type != eventstream.HeaderType.ByteBuffer) {67        expect(() => {68            header.asByteBuffer();69        }).toThrow();70    }71 72    if (type != eventstream.HeaderType.UUID) {73        expect(() => {74            header.asUUID();75        }).toThrow();76    }77}78 79test('Eventstream header - new true boolean success', async () => {80    let header : eventstream.Header = eventstream.Header.newBoolean(DEFAULT_HEADER_NAME, true);81    expect(header.name).toEqual(DEFAULT_HEADER_NAME);82 83    checkTypeCasts(header, eventstream.HeaderType.BooleanTrue);84 85    expect(header.asBoolean()).toEqual(true);86});87 88test('Eventstream header - new false boolean success', async () => {89    let header : eventstream.Header = eventstream.Header.newBoolean(DEFAULT_HEADER_NAME, false);90    expect(header.name).toEqual(DEFAULT_HEADER_NAME);91 92    checkTypeCasts(header, eventstream.HeaderType.BooleanFalse);93 94    expect(header.asBoolean()).toEqual(false);95});96 97test('Eventstream header - new byte failure, out-of-bounds value', async () => {98    expect(() => {eventstream.Header.newByte(DEFAULT_HEADER_NAME, 128);}).toThrow();99});100 101test('Eventstream header - new byte failure, fractional value', async () => {102    expect(() => {eventstream.Header.newByte(DEFAULT_HEADER_NAME, .5);}).toThrow();103});104 105test('Eventstream header - new byte success', async () => {106    let header : eventstream.Header = eventstream.Header.newByte(DEFAULT_HEADER_NAME, 5);107    expect(header.name).toEqual(DEFAULT_HEADER_NAME);108 109    checkTypeCasts(header, eventstream.HeaderType.Byte);110 111    expect(header.asByte()).toEqual(5);112});113 114test('Eventstream header - new int16 failure, out-of-bounds value', async () => {115    expect(() => {eventstream.Header.newInt16(DEFAULT_HEADER_NAME, 32768);}).toThrow();116});117 118test('Eventstream header - new int16 failure, fractional value', async () => {119    expect(() => {eventstream.Header.newInt16(DEFAULT_HEADER_NAME, 1024.2);}).toThrow();120});121 122test('Eventstream header - new int16 success', async () => {123    let header : eventstream.Header = eventstream.Header.newInt16(DEFAULT_HEADER_NAME, -255);124    expect(header.name).toEqual(DEFAULT_HEADER_NAME);125 126    checkTypeCasts(header, eventstream.HeaderType.Int16);127 128    expect(header.asInt16()).toEqual(-255);129});130 131test('Eventstream header - new int32 failure, out-of-bounds value', async () => {132    expect(() => {eventstream.Header.newInt32(DEFAULT_HEADER_NAME, Number.MAX_SAFE_INTEGER);}).toThrow();133});134 135test('Eventstream header - new int32 failure, fractional value', async () => {136    expect(() => {eventstream.Header.newInt32(DEFAULT_HEADER_NAME, -65536.82);}).toThrow();137});138 139test('Eventstream header - new int32 success', async () => {140    let large_int32 : number = (1 << 30) - 1;141    let header : eventstream.Header = eventstream.Header.newInt32(DEFAULT_HEADER_NAME, large_int32);142    expect(header.name).toEqual(DEFAULT_HEADER_NAME);143 144    checkTypeCasts(header, eventstream.HeaderType.Int32);145 146    expect(header.asInt32()).toEqual(large_int32);147});148 149test('Eventstream header - new int64 from bigint failure, out-of-bounds value', async () => {150    let too_big : bigint = BigInt("9223372036854775807000453053");151 152    expect(() => {eventstream.Header.newInt64FromBigint(DEFAULT_HEADER_NAME, too_big);}).toThrow();153});154 155test('Eventstream header - new int64 from bigint(9223372036854775807) success', async () => {156    let large_int64 : bigint = BigInt("9223372036854775807");157    let header : eventstream.Header = eventstream.Header.newInt64FromBigint(DEFAULT_HEADER_NAME, large_int64);158    expect(header.name).toEqual(DEFAULT_HEADER_NAME);159 160    checkTypeCasts(header, eventstream.HeaderType.Int64);161 162    expect(header.asInt64()).toEqual(large_int64);163});164 165test('Eventstream header - new int64 from bigint(-1) success', async () => {166    let int64 : bigint = BigInt("-1");167    let header : eventstream.Header = eventstream.Header.newInt64FromBigint(DEFAULT_HEADER_NAME, int64);168    expect(header.name).toEqual(DEFAULT_HEADER_NAME);169 170    checkTypeCasts(header, eventstream.HeaderType.Int64);171 172    expect(header.asInt64()).toEqual(int64);173});174 175test('Eventstream header - new int64 from number failure, fractional value', async () => {176    expect(() => {eventstream.Header.newInt64FromNumber(DEFAULT_HEADER_NAME, Number.MAX_VALUE);}).toThrow();177});178 179test('Eventstream header - new int64 from number(MAX_SAFE_INTEGER) success', async () => {180    let header : eventstream.Header = eventstream.Header.newInt64FromNumber(DEFAULT_HEADER_NAME, Number.MAX_SAFE_INTEGER);181    expect(header.name).toEqual(DEFAULT_HEADER_NAME);182 183    checkTypeCasts(header, eventstream.HeaderType.Int64);184 185    expect(header.asInt64()).toEqual(BigInt(Number.MAX_SAFE_INTEGER));186});187 188test('Eventstream header - new int64 from number(-1) success', async () => {189    let header : eventstream.Header = eventstream.Header.newInt64FromNumber(DEFAULT_HEADER_NAME, -1);190    expect(header.name).toEqual(DEFAULT_HEADER_NAME);191 192    checkTypeCasts(header, eventstream.HeaderType.Int64);193 194    expect(header.asInt64()).toEqual(BigInt(-1));195});196 197test('Eventstream header - new int64 from number(-65537) success', async () => {198    let header : eventstream.Header = eventstream.Header.newInt64FromNumber(DEFAULT_HEADER_NAME, -65537);199    expect(header.name).toEqual(DEFAULT_HEADER_NAME);200 201    checkTypeCasts(header, eventstream.HeaderType.Int64);202 203    expect(header.asInt64()).toEqual(BigInt(-65537));204});205 206test('Eventstream header - new byte buffer success', async () => {207    let testPayload : Buffer = Buffer.from("Derp", "utf-8");208    let header : eventstream.Header = eventstream.Header.newByteBuffer(DEFAULT_HEADER_NAME, testPayload);209    expect(header.name).toEqual(DEFAULT_HEADER_NAME);210 211    checkTypeCasts(header, eventstream.HeaderType.ByteBuffer);212 213    expect(header.asByteBuffer()).toEqual(Buffer.from("Derp", "utf-8"));214});215 216test('Eventstream header - new string success', async () => {217    let header : eventstream.Header = eventstream.Header.newString(DEFAULT_HEADER_NAME, "HelloWorld");218    expect(header.name).toEqual(DEFAULT_HEADER_NAME);219 220    checkTypeCasts(header, eventstream.HeaderType.String);221 222    expect(header.asString()).toEqual("HelloWorld");223});224 225test('Eventstream header - new timestamp from epoch seconds failure, bad value', async () => {226    expect(() => {eventstream.Header.newTimeStampFromSecondsSinceEpoch(DEFAULT_HEADER_NAME, Number.MAX_VALUE);}).toThrow();227});228 229test('Eventstream header - new timestamp from epoch seconds success', async () => {230    let header : eventstream.Header = eventstream.Header.newTimeStampFromSecondsSinceEpoch(DEFAULT_HEADER_NAME, Number.MAX_SAFE_INTEGER);231    expect(header.name).toEqual(DEFAULT_HEADER_NAME);232 233    checkTypeCasts(header, eventstream.HeaderType.Timestamp);234 235    expect(header.asTimestamp()).toEqual(Number.MAX_SAFE_INTEGER);236});237 238test('Eventstream header - new timestamp from date success', async () => {239    let someDate = new Date();240    let header : eventstream.Header = eventstream.Header.newTimeStampFromDate(DEFAULT_HEADER_NAME, someDate);241    expect(header.name).toEqual(DEFAULT_HEADER_NAME);242 243    checkTypeCasts(header, eventstream.HeaderType.Timestamp);244 245    expect(header.asTimestamp()).toEqual(someDate.getTime());246});247 248test('Eventstream header - new uuid failure, bad value', async () => {249    expect(() => {eventstream.Header.newUUID(DEFAULT_HEADER_NAME, Buffer.from("Derp", "utf-8"));}).toThrow();250});251 252test('Eventstream header - new uuid success', async () => {253    let uuidBuffer = new ArrayBuffer(16);254    let header : eventstream.Header = eventstream.Header.newUUID(DEFAULT_HEADER_NAME, uuidBuffer);255    expect(header.name).toEqual(DEFAULT_HEADER_NAME);256 257    checkTypeCasts(header, eventstream.HeaderType.UUID);258 259    expect(header.asUUID()).toEqual(new ArrayBuffer(16));260});261