Skip to content

Commit a525b24

Browse files
alexforsythalexforsyth
committed
feat: prettify codebase
1 parent 69a231b commit a525b24

File tree

58 files changed

+176
-652
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

58 files changed

+176
-652
lines changed

‎packages/chunked-blob-reader-native/src/index.ts

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -18,9 +18,7 @@ export function blobReader(
1818
resolve();
1919
return;
2020
}
21-
fileReader.readAsDataURL(
22-
blob.slice(totalBytesRead, Math.min(size, totalBytesRead + chunkSize))
23-
);
21+
fileReader.readAsDataURL(blob.slice(totalBytesRead, Math.min(size, totalBytesRead + chunkSize)));
2422
};
2523

2624
fileReader.onload = event => {

‎packages/chunked-blob-reader/src/index.ts

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -17,9 +17,7 @@ export function blobReader(
1717
resolve();
1818
return;
1919
}
20-
fileReader.readAsArrayBuffer(
21-
blob.slice(totalBytesRead, Math.min(size, totalBytesRead + chunkSize))
22-
);
20+
fileReader.readAsArrayBuffer(blob.slice(totalBytesRead, Math.min(size, totalBytesRead + chunkSize)));
2321
}
2422

2523
fileReader.addEventListener("load", event => {

‎packages/chunked-stream-reader-node/src/index.ts

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -11,12 +11,7 @@ export function streamReader(
1111
stream.on("end", () => {
1212
if (temporaryBuffer?.byteLength) {
1313
for (let i = 0; i < temporaryBuffer.byteLength; i += chunkSize) {
14-
onChunk(
15-
temporaryBuffer.subarray(
16-
i,
17-
Math.min(i + chunkSize, temporaryBuffer.byteLength)
18-
)
19-
);
14+
onChunk(temporaryBuffer.subarray(i, Math.min(i + chunkSize, temporaryBuffer.byteLength)));
2015
}
2116
// clear the temporaryBuffer
2217
temporaryBuffer = void 0;

‎packages/config-resolver/src/RegionConfig.ts

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -12,9 +12,7 @@ interface PreviouslyResolved {
1212
export interface RegionResolvedConfig {
1313
region: Provider<string>;
1414
}
15-
export function resolveRegionConfig<T>(
16-
input: T & RegionInputConfig & PreviouslyResolved
17-
): T & RegionResolvedConfig {
15+
export function resolveRegionConfig<T>(input: T & RegionInputConfig & PreviouslyResolved): T & RegionResolvedConfig {
1816
const region = input.region || input.regionDefaultProvider(input as any);
1917
return {
2018
...input,

‎packages/credential-provider-cognito-identity/src/resolveLogins.spec.ts

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -5,13 +5,11 @@ describe("resolveLogins", () => {
55
expect(
66
await resolveLogins({
77
"www.amazon.com": "string token",
8-
"cognito-idp.us-east-1.amazonaws.com/us-east-1_123456789": () =>
9-
Promise.resolve("potential refreshing token")
8+
"cognito-idp.us-east-1.amazonaws.com/us-east-1_123456789": () => Promise.resolve("potential refreshing token")
109
})
1110
).toEqual({
1211
"www.amazon.com": "string token",
13-
"cognito-idp.us-east-1.amazonaws.com/us-east-1_123456789":
14-
"potential refreshing token"
12+
"cognito-idp.us-east-1.amazonaws.com/us-east-1_123456789": "potential refreshing token"
1513
});
1614
});
1715
});

‎packages/credential-provider-cognito-identity/src/resolveLogins.ts

Lines changed: 9 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -5,23 +5,15 @@ import { Logins, ResolvedLogins } from "./Logins";
55
*/
66
export function resolveLogins(logins: Logins): Promise<ResolvedLogins> {
77
return Promise.all(
8-
Object.keys(logins).reduce(
9-
(
10-
arr: Array<[string, string] | Promise<[string, string]>>,
11-
name: string
12-
) => {
13-
const tokenOrProvider = logins[name];
14-
if (typeof tokenOrProvider === "string") {
15-
arr.push([name, tokenOrProvider] as [string, string]);
16-
} else {
17-
arr.push(
18-
tokenOrProvider().then(token => [name, token] as [string, string])
19-
);
20-
}
21-
return arr;
22-
},
23-
[] as Array<Promise<[string, string]>>
24-
)
8+
Object.keys(logins).reduce((arr: Array<[string, string] | Promise<[string, string]>>, name: string) => {
9+
const tokenOrProvider = logins[name];
10+
if (typeof tokenOrProvider === "string") {
11+
arr.push([name, tokenOrProvider] as [string, string]);
12+
} else {
13+
arr.push(tokenOrProvider().then(token => [name, token] as [string, string]));
14+
}
15+
return arr;
16+
}, [] as Array<Promise<[string, string]>>)
2517
).then(resolvedPairs =>
2618
resolvedPairs.reduce((logins: ResolvedLogins, [key, value]) => {
2719
logins[key] = value;

‎packages/credential-provider-imds/src/fromContainerMetadata.spec.ts

Lines changed: 6 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -5,10 +5,7 @@ import {
55
fromContainerMetadata
66
} from "./fromContainerMetadata";
77
import { httpGet } from "./remoteProvider/httpGet";
8-
import {
9-
fromImdsCredentials,
10-
ImdsCredentials
11-
} from "./remoteProvider/ImdsCredentials";
8+
import { fromImdsCredentials, ImdsCredentials } from "./remoteProvider/ImdsCredentials";
129

1310
const mockHttpGet = <any>httpGet;
1411
jest.mock("./remoteProvider/httpGet", () => ({ httpGet: jest.fn() }));
@@ -72,9 +69,7 @@ describe("fromContainerMetadata", () => {
7269
it("should resolve credentials by fetching them from the container metadata service", async () => {
7370
mockHttpGet.mockReturnValue(Promise.resolve(JSON.stringify(creds)));
7471

75-
expect(await fromContainerMetadata()()).toEqual(
76-
fromImdsCredentials(creds)
77-
);
72+
expect(await fromContainerMetadata()()).toEqual(fromImdsCredentials(creds));
7873
});
7974

8075
it("should retry the fetching operation up to maxRetries times", async () => {
@@ -84,26 +79,20 @@ describe("fromContainerMetadata", () => {
8479
}
8580
mockHttpGet.mockReturnValueOnce(Promise.resolve(JSON.stringify(creds)));
8681

87-
expect(await fromContainerMetadata({ maxRetries })()).toEqual(
88-
fromImdsCredentials(creds)
89-
);
82+
expect(await fromContainerMetadata({ maxRetries })()).toEqual(fromImdsCredentials(creds));
9083
expect(mockHttpGet.mock.calls.length).toEqual(maxRetries);
9184
});
9285

9386
it("should retry responses that receive invalid response values", async () => {
9487
for (const key of Object.keys(creds)) {
9588
const invalidCreds: any = { ...creds };
9689
delete invalidCreds[key];
97-
mockHttpGet.mockReturnValueOnce(
98-
Promise.resolve(JSON.stringify(invalidCreds))
99-
);
90+
mockHttpGet.mockReturnValueOnce(Promise.resolve(JSON.stringify(invalidCreds)));
10091
}
10192
mockHttpGet.mockReturnValueOnce(Promise.resolve(JSON.stringify(creds)));
10293

10394
await fromContainerMetadata({ maxRetries: 100 })();
104-
expect(mockHttpGet.mock.calls.length).toEqual(
105-
Object.keys(creds).length + 1
106-
);
95+
expect(mockHttpGet.mock.calls.length).toEqual(Object.keys(creds).length + 1);
10796
});
10897

10998
it("should pass relevant configuration to httpGet", async () => {
@@ -127,13 +116,7 @@ describe("fromContainerMetadata", () => {
127116
mockHttpGet.mockReturnValue(Promise.resolve(JSON.stringify(creds)));
128117
await fromContainerMetadata({ timeout })();
129118
expect(mockHttpGet.mock.calls.length).toEqual(1);
130-
const {
131-
protocol,
132-
hostname,
133-
path,
134-
port,
135-
timeout: actualTimeout
136-
} = mockHttpGet.mock.calls[0][0];
119+
const { protocol, hostname, path, port, timeout: actualTimeout } = mockHttpGet.mock.calls[0][0];
137120
expect(protocol).toBe("http:");
138121
expect(hostname).toBe("localhost");
139122
expect(path).toBe("/path");

‎packages/eventstream-marshaller/src/Int64.spec.ts

Lines changed: 4 additions & 40 deletions
Original file line numberDiff line numberDiff line change
@@ -2,61 +2,25 @@ import { Int64 } from "./Int64";
22

33
describe("Int64", () => {
44
it("should hold integers greater than Number.MAX_SAFE_INTEGER without losing precision", () => {
5-
const bytes = Uint8Array.from([
6-
0x7f,
7-
0xff,
8-
0xff,
9-
0xff,
10-
0xff,
11-
0xff,
12-
0xff,
13-
0xff
14-
]);
5+
const bytes = Uint8Array.from([0x7f, 0xff, 0xff, 0xff, 0xff, 0xff, 0xff, 0xff]);
156

167
expect(new Int64(bytes).bytes).toEqual(bytes);
178
});
189

1910
it("should allow the use of Int64s in arithmetic expressions", () => {
20-
const bytes = Uint8Array.from([
21-
0x00,
22-
0x00,
23-
0x00,
24-
0x00,
25-
0x00,
26-
0x00,
27-
0x00,
28-
0x10
29-
]);
11+
const bytes = Uint8Array.from([0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x10]);
3012

3113
expect((new Int64(bytes) as any) + 4).toBe(20);
3214
});
3315

3416
it("should allow the use of negative Int64s in arithmetic expressions", () => {
35-
const bytes = Uint8Array.from([
36-
0xff,
37-
0xf0,
38-
0x00,
39-
0x00,
40-
0x00,
41-
0x00,
42-
0x00,
43-
0x00
44-
]);
17+
const bytes = Uint8Array.from([0xff, 0xf0, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00]);
4518

4619
expect((new Int64(bytes) as any) + 2 ** 52).toBe(0);
4720
});
4821

4922
it("should stringify negative Int64s in base 10", () => {
50-
const bytes = Uint8Array.from([
51-
0xff,
52-
0xff,
53-
0xff,
54-
0xff,
55-
0xff,
56-
0xff,
57-
0xff,
58-
0xe2
59-
]);
23+
const bytes = Uint8Array.from([0xff, 0xff, 0xff, 0xff, 0xff, 0xff, 0xff, 0xe2]);
6024

6125
expect(String(new Int64(bytes))).toBe("-30");
6226
});

‎packages/eventstream-marshaller/src/splitMessage.ts

Lines changed: 8 additions & 31 deletions
Original file line numberDiff line numberDiff line change
@@ -20,49 +20,32 @@ export interface MessageParts {
2020
/**
2121
* @internal
2222
*/
23-
export function splitMessage({
24-
byteLength,
25-
byteOffset,
26-
buffer
27-
}: ArrayBufferView): MessageParts {
23+
export function splitMessage({ byteLength, byteOffset, buffer }: ArrayBufferView): MessageParts {
2824
if (byteLength < MINIMUM_MESSAGE_LENGTH) {
29-
throw new Error(
30-
"Provided message too short to accommodate event stream message overhead"
31-
);
25+
throw new Error("Provided message too short to accommodate event stream message overhead");
3226
}
3327

3428
const view = new DataView(buffer, byteOffset, byteLength);
3529

3630
const messageLength = view.getUint32(0, false);
3731

3832
if (byteLength !== messageLength) {
39-
throw new Error(
40-
"Reported message length does not match received message length"
41-
);
33+
throw new Error("Reported message length does not match received message length");
4234
}
4335

4436
const headerLength = view.getUint32(PRELUDE_MEMBER_LENGTH, false);
4537
const expectedPreludeChecksum = view.getUint32(PRELUDE_LENGTH, false);
46-
const expectedMessageChecksum = view.getUint32(
47-
byteLength - CHECKSUM_LENGTH,
48-
false
49-
);
38+
const expectedMessageChecksum = view.getUint32(byteLength - CHECKSUM_LENGTH, false);
5039

51-
const checksummer = new Crc32().update(
52-
new Uint8Array(buffer, byteOffset, PRELUDE_LENGTH)
53-
);
40+
const checksummer = new Crc32().update(new Uint8Array(buffer, byteOffset, PRELUDE_LENGTH));
5441
if (expectedPreludeChecksum !== checksummer.digest()) {
5542
throw new Error(
5643
`The prelude checksum specified in the message (${expectedPreludeChecksum}) does not match the calculated CRC32 checksum (${checksummer.digest()})`
5744
);
5845
}
5946

6047
checksummer.update(
61-
new Uint8Array(
62-
buffer,
63-
byteOffset + PRELUDE_LENGTH,
64-
byteLength - (PRELUDE_LENGTH + CHECKSUM_LENGTH)
65-
)
48+
new Uint8Array(buffer, byteOffset + PRELUDE_LENGTH, byteLength - (PRELUDE_LENGTH + CHECKSUM_LENGTH))
6649
);
6750
if (expectedMessageChecksum !== checksummer.digest()) {
6851
throw new Error(
@@ -71,17 +54,11 @@ export function splitMessage({
7154
}
7255

7356
return {
74-
headers: new DataView(
75-
buffer,
76-
byteOffset + PRELUDE_LENGTH + CHECKSUM_LENGTH,
77-
headerLength
78-
),
57+
headers: new DataView(buffer, byteOffset + PRELUDE_LENGTH + CHECKSUM_LENGTH, headerLength),
7958
body: new Uint8Array(
8059
buffer,
8160
byteOffset + PRELUDE_LENGTH + CHECKSUM_LENGTH + headerLength,
82-
messageLength -
83-
headerLength -
84-
(PRELUDE_LENGTH + CHECKSUM_LENGTH + CHECKSUM_LENGTH)
61+
messageLength - headerLength - (PRELUDE_LENGTH + CHECKSUM_LENGTH + CHECKSUM_LENGTH)
8562
)
8663
};
8764
}

‎packages/eventstream-serde-browser/src/utils.ts

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -2,9 +2,7 @@
22
* A util function converting ReadableStream into an async iterable.
33
* Reference: https://jakearchibald.com/2017/async-iterators-and-generators/#making-streams-iterate
44
*/
5-
export const readableStreamtoIterable = <T>(
6-
readableStream: ReadableStream<T>
7-
): AsyncIterable<T> => ({
5+
export const readableStreamtoIterable = <T>(readableStream: ReadableStream<T>): AsyncIterable<T> => ({
86
[Symbol.asyncIterator]: async function* () {
97
const reader = readableStream.getReader();
108
try {
@@ -22,9 +20,7 @@ export const readableStreamtoIterable = <T>(
2220
/**
2321
* A util function converting async iterable to a ReadableStream.
2422
*/
25-
export const iterableToReadableStream = <T>(
26-
asyncIterable: AsyncIterable<T>
27-
): ReadableStream<T> => {
23+
export const iterableToReadableStream = <T>(asyncIterable: AsyncIterable<T>): ReadableStream<T> => {
2824
const iterator = asyncIterable[Symbol.asyncIterator]();
2925
return new ReadableStream({
3026
async pull(controller) {

‎packages/eventstream-serde-config-resolver/src/index.ts

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,4 @@
1-
import {
2-
Decoder,
3-
Encoder,
4-
EventStreamMarshaller,
5-
EventStreamSerdeProvider
6-
} from "@aws-sdk/types";
1+
import { Decoder, Encoder, EventStreamMarshaller, EventStreamSerdeProvider } from "@aws-sdk/types";
72
export interface EventStreamSerdeInputConfig {}
83

94
export interface EventStreamSerdeResolvedConfig {

‎packages/eventstream-serde-node/src/utils.ts

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -8,9 +8,7 @@ import { Readable } from "stream";
88
* Reference: https://nodejs.org/docs/latest-v11.x/api/stream.html#stream_readable_symbol_asynciterator
99
*/
1010

11-
export async function* readabletoIterable<T>(
12-
readStream: Readable
13-
): AsyncIterable<T> {
11+
export async function* readabletoIterable<T>(readStream: Readable): AsyncIterable<T> {
1412
let streamEnded = false;
1513
let generationEnded = false;
1614
const records = new Array<T>();
@@ -33,9 +31,7 @@ export async function* readabletoIterable<T>(
3331
});
3432

3533
while (!generationEnded) {
36-
const value = await new Promise<T>(resolve =>
37-
setTimeout(() => resolve(records.shift()), 0)
38-
);
34+
const value = await new Promise<T>(resolve => setTimeout(() => resolve(records.shift()), 0));
3935
if (value) {
4036
yield value;
4137
}

0 commit comments

Comments
 (0)