All files / handlers/lambda s3EventHandler.ts

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
 
1x
1x
1x
 
1x
1x
 
 
1x
1x
1x
1x
1x
1x
1x
 
1x
 
 
1x
 
 
 
 
 
 
 
 
1x
 
 
 
 
import { S3Event, S3Handler } from 'aws-lambda';
import { ImageRepository } from '../../repositories/imageRepository';
import { getLogger } from '../../common/logger';
import { config } from '../../config/env';
 
const logger = getLogger('S3EventHandler');
const imageRepository = new ImageRepository();
 
// eslint-disable-next-line @typescript-eslint/no-explicit-any
export const handler: S3Handler = async (event: S3Event) => {
  for (const record of event.Records) {
    try {
      const bucket = record.s3.bucket.name;
      const key = record.s3.object.key;
      const imageId = key;
      const size = record.s3.object.size ?? 0;
 
      const publicUrl = `https://${bucket}.s3.${config.awsRegion}.amazonaws.com/${key}`;
 
      // Update DynamoDB record with publicUrl, status, and actual size
      await imageRepository.update({
        imageId,
        size,
        url: publicUrl,
        status: 'uploaded',
      });
 
      logger.info('Updated image metadata', { imageId, publicUrl, size });
    } catch (error) {
      logger.error('Failed to update image metadata', { error });
    }
  }
};