diff --git a/packages/server/package.json b/packages/server/package.json index 37df7138d7..9a70ecba9c 100644 --- a/packages/server/package.json +++ b/packages/server/package.json @@ -159,7 +159,6 @@ "@types/tar": "6.1.5", "@types/tmp": "0.2.6", "@types/uuid": "8.3.4", - "@smithy/types": "4.0.0", "chance": "^1.1.12", "copyfiles": "2.4.1", "docker-compose": "0.23.17", diff --git a/packages/server/src/integrations/s3.ts b/packages/server/src/integrations/s3.ts index 52830fb7c1..88d00724f1 100644 --- a/packages/server/src/integrations/s3.ts +++ b/packages/server/src/integrations/s3.ts @@ -10,7 +10,6 @@ import { import { S3, S3ClientConfig } from "@aws-sdk/client-s3" import csv from "csvtojson" import stream from "stream" -import { NodeJsClient } from "@smithy/types" interface S3Config { region: string @@ -159,7 +158,7 @@ const SCHEMA: Integration = { class S3Integration implements IntegrationBase { private readonly config: S3ClientConfig - private client: NodeJsClient + private client: S3 constructor(config: S3Config) { this.config = { @@ -176,7 +175,7 @@ class S3Integration implements IntegrationBase { delete this.config.endpoint } - this.client = new S3(this.config) as NodeJsClient + this.client = new S3(this.config) } async testConnection() { @@ -263,7 +262,7 @@ class S3Integration implements IntegrationBase { .on("error", () => { csvError = true }) - fileStream.on("finish", () => { + fileStream.on("end", () => { resolve(response) }) }).catch(err => {