|
|
@ -45,9 +45,9 @@ func (p *S3ObjectPresigner) CheckAndPresign(ctx context.Context) {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
if s3ObjectPayload.LastPresignedTime != nil {
|
|
|
|
if s3ObjectPayload.LastPresignedTime != nil {
|
|
|
|
// Skip if the presigned URL is still valid for the next 6 days.
|
|
|
|
// Skip if the presigned URL is still valid for the next 4 days.
|
|
|
|
// The default expiration time is 7 days.
|
|
|
|
// The expiration time is set to 5 days.
|
|
|
|
if time.Now().Before(s3ObjectPayload.LastPresignedTime.AsTime().Add(6 * 24 * time.Hour)) {
|
|
|
|
if time.Now().Before(s3ObjectPayload.LastPresignedTime.AsTime().Add(4 * 24 * time.Hour)) {
|
|
|
|
continue
|
|
|
|
continue
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -74,6 +74,7 @@ func (p *S3ObjectPresigner) CheckAndPresign(ctx context.Context) {
|
|
|
|
s3ObjectPayload.S3Config = s3Config
|
|
|
|
s3ObjectPayload.S3Config = s3Config
|
|
|
|
s3ObjectPayload.LastPresignedTime = timestamppb.New(time.Now())
|
|
|
|
s3ObjectPayload.LastPresignedTime = timestamppb.New(time.Now())
|
|
|
|
if err := p.Store.UpdateResource(ctx, &store.UpdateResource{
|
|
|
|
if err := p.Store.UpdateResource(ctx, &store.UpdateResource{
|
|
|
|
|
|
|
|
ID: resource.ID,
|
|
|
|
Reference: &presignURL,
|
|
|
|
Reference: &presignURL,
|
|
|
|
Payload: &storepb.ResourcePayload{
|
|
|
|
Payload: &storepb.ResourcePayload{
|
|
|
|
Payload: &storepb.ResourcePayload_S3Object_{
|
|
|
|
Payload: &storepb.ResourcePayload_S3Object_{
|
|
|
|