test: fix select object content event stream test

Author: kuhe

clients/client-s3/test/integ/s3-selectObjectContent.integ.spec.ts

@@ -1,10 +1,8 @@
+import { requireRequestsFrom } from "@aws-sdk/aws-util-test/src";
 import { S3 } from "@aws-sdk/client-s3";
 import { HttpResponse } from "@smithy/protocol-http";
-import { Readable } from "stream";
 import { describe, expect, test as it } from "vitest";
 
-import { requireRequestsFrom } from "@aws-sdk/aws-util-test/src";
-
 describe("selectObjectContent", () => {
   const credentials = {
     accessKeyId: "INTEG",
@@ -34,16 +32,48 @@ describe("selectObjectContent", () => {
       .respondWith(
         new HttpResponse({
           statusCode: 200,
-          body: Readable.from([
-            `<?xml version="1.0" encoding="UTF-8"?>`,
-            `<Payload>`,
-            `<Records><Payload>blob</Payload></Records>`,
-            `<Stats><Details><BytesProcessed>100</BytesProcessed><BytesReturned>50</BytesReturned><BytesScanned>100</BytesScanned></Details></Stats>`,
-            `<Progress><Details><BytesProcessed>100</BytesProcessed><BytesReturned>50</BytesReturned><BytesScanned>100</BytesScanned></Details></Progress>`,
-            `<Cont></Cont>`,
-            `<End></End>`,
-            `</Payload>`,
-          ]),
+          headers: {
+            "x-amz-checksum-crc32": "3117266289",
+          },
+          body: {
+            *[Symbol.asyncIterator]() {
+              yield new Uint8Array([
+                /* message size */ ...[0, 0, 0, 97],
+                /* header size */ ...[0, 0, 0, 81],
+                /* prelude crc */ ...[221, 28, 224, 246],
+                /* headers */
+                /* :event-type */
+                11,
+                ...[58, 101, 118, 101, 110, 116, 45, 116, 121, 112, 101],
+                7,
+                /* End */
+                0,
+                3,
+                ...[69, 110, 100],
+                /* :content-type */
+                13,
+                ...[58, 99, 111, 110, 116, 101, 110, 116, 45, 116, 121, 112, 101],
+                7,
+                /* application/octet-stream */
+                0,
+                24,
+                ...[
+                  97, 112, 112, 108, 105, 99, 97, 116, 105, 111, 110, 47, 111, 99, 116, 101, 116, 45, 115, 116, 114,
+                  101, 97, 109,
+                ],
+                /* :message-type */
+                13,
+                ...[58, 109, 101, 115, 115, 97, 103, 101, 45, 116, 121, 112, 101],
+                7,
+                /* event */
+                0,
+                5,
+                ...[101, 118, 101, 110, 116],
+                /* message crc */
+                ...[75, 107, 103, 102],
+              ]);
+            },
+          },
         })
       );
 
@@ -69,5 +99,11 @@ describe("selectObjectContent", () => {
     expect(response.$metadata.httpStatusCode).toBe(200);
     expect(response).toHaveProperty("Payload");
     expect(response.Payload).toBeDefined();
+
+    const events = [];
+    for await (const event of response.Payload!) {
+      events.push(event);
+    }
+    expect(events).toEqual([{ End: {} }]);
   });
 });