Function create

worker/src/destinations/adapters/s3.ts:49–106

(rawConfig)

    { id: 'publicUrl', label: 'Public URL prefix', type: 'text' },
  ],
  create(rawConfig) {
    return {
      async save(
        input: DestinationSaveInput,
        context: ExecutionContext,
      ): Promise<DestinationSaveResult> {
        const config = ensureS3Config(rawConfig);
        const credentials = ensureAwsCredentials(config);
        const key = buildObjectKey(config, input.fileName);

        const client = new S3Client({
          region: credentials.region ?? config.region ?? 'us-east-1',
          endpoint: config.endpoint,
          forcePathStyle: config.forcePathStyle,
          credentials: {
            accessKeyId: credentials.accessKeyId,
            secretAccessKey: credentials.secretAccessKey,
            sessionToken: credentials.sessionToken,
          },
        });

        context.logger.info(
          `[Destination:S3] Uploading ${input.fileName} (${input.buffer.byteLength} bytes) to s3://${config.bucket}/${key}`,
        );

        const command = new PutObjectCommand({
          Bucket: config.bucket,
          Key: key,
          Body: input.buffer,
          ContentType: input.mimeType,
          Metadata: {
            'shipsec-run-id': context.runId,
            'shipsec-component-ref': context.componentRef,
          },
        });

        const response = await client.send(command);
        const uri = `s3://${config.bucket}/${key}`;
        const publicUrl = config.publicUrl
          ? `${config.publicUrl.replace(/\/+$/, '')}/${key}`
          : undefined;

        return {
          remoteUploads: [
            {
              type: 's3',
              bucket: config.bucket,
              key,
              uri,
              url: publicUrl,
              region: credentials.region ?? config.region,
              etag: typeof response.ETag === 'string' ? response.ETag.replace(/"/g, '') : undefined,
            },
          ],
        };
      },
    };
  },