Function emptyS3Bucket

cmd/lambda-nat-proxy/cmd_destroy.go:202–248

(ctx context.Context, s3Client awsclients.S3API, bucketName string)

}

func emptyS3Bucket(ctx context.Context, s3Client awsclients.S3API, bucketName string) error {
	// List all objects
	input := &s3.ListObjectsV2Input{
		Bucket: aws.String(bucketName),
	}
	
	for {
		result, err := s3Client.ListObjectsV2WithContext(ctx, input)
		if err != nil {
			return fmt.Errorf("failed to list objects: %w", err)
		}
		
		if len(result.Contents) == 0 {
			break
		}
		
		// Delete objects in batch
		var objects []*s3.ObjectIdentifier
		for _, obj := range result.Contents {
			objects = append(objects, &s3.ObjectIdentifier{
				Key: obj.Key,
			})
		}
		
		deleteInput := &s3.DeleteObjectsInput{
			Bucket: aws.String(bucketName),
			Delete: &s3.Delete{
				Objects: objects,
			},
		}
		
		_, err = s3Client.DeleteObjectsWithContext(ctx, deleteInput)
		if err != nil {
			return fmt.Errorf("failed to delete objects: %w", err)
		}
		
		log.Printf("Deleted %d objects from bucket", len(objects))
		
		// Check if there are more objects
		if !*result.IsTruncated {
			break
		}
		input.ContinuationToken = result.NextContinuationToken
	}
	
	return nil
}

func deleteCloudWatchLogs(ctx context.Context, clients *awsclients.Clients, functionName string) error {
	logGroupName := fmt.Sprintf("/aws/lambda/%s", functionName)