in transcodelauncher/copier.go [67:88]
func (c *Copier) DoesFileExist(ctx context.Context, bucket string, key string) (bool, error) {
req := &s3.HeadObjectInput{
Bucket: aws.String(bucket),
Key: aws.String(key),
}
log.Printf("Checking for existence of s3://%s/%s", bucket, key)
_, err := c.client.HeadObject(ctx, req)
if err != nil {
var ae smithy.APIError
if errors.As(err, &ae) {
if ae.ErrorCode() == "NotFound" {
return false, nil
} else {
log.Printf("ERROR Could not check file s3://%s/%s %s %s", bucket, key, ae.ErrorCode(), ae.ErrorMessage())
return false, err
}
}
return false, err
}
return true, nil
}