Change on files
This commit is contained in:
+1
-1
@@ -1,4 +1,4 @@
|
||||
using Musify.Application.Common;
|
||||
using Musify.Application.Shared;
|
||||
using Musify.Application.Events;
|
||||
|
||||
namespace Musify.Infrastructure.MassTransit.Arguments
|
||||
|
||||
@@ -1,4 +1,4 @@
|
||||
using Musify.Application.Common;
|
||||
using Musify.Application.Shared;
|
||||
using Musify.Application.Events;
|
||||
|
||||
namespace Musify.Infrastructure.MassTransit.Arguments
|
||||
|
||||
+1
-1
@@ -1,6 +1,6 @@
|
||||
using MassTransit;
|
||||
using MassTransit.Courier.Contracts;
|
||||
using Musify.Application.Common;
|
||||
using Musify.Application.Shared;
|
||||
using Musify.Application.Events;
|
||||
using Musify.Infrastructure.Configuration;
|
||||
using Musify.Infrastructure.MassTransit.Activities;
|
||||
|
||||
+1
-1
@@ -1,6 +1,6 @@
|
||||
using MassTransit;
|
||||
using MassTransit.Courier.Contracts;
|
||||
using Musify.Application.Common;
|
||||
using Musify.Application.Shared;
|
||||
using Musify.Application.Events;
|
||||
using Musify.Infrastructure.MassTransit.Activities.Files;
|
||||
using Musify.Infrastructure.MassTransit.Activities.PlayLists;
|
||||
|
||||
@@ -228,7 +228,7 @@ namespace Musify.Infrastructure.Services
|
||||
}
|
||||
}
|
||||
|
||||
public async IAsyncEnumerable<(string Key, DateTime LastModifiedUtc)> ListObjectsAsync(
|
||||
public async IAsyncEnumerable<StorageObject> ListObjectsAsync(
|
||||
string bucket, string prefix, [System.Runtime.CompilerServices.EnumeratorCancellation] CancellationToken cancellationToken)
|
||||
{
|
||||
var listRequest = new ListObjectsV2Request
|
||||
@@ -242,7 +242,7 @@ namespace Musify.Infrastructure.Services
|
||||
{
|
||||
listResponse = await amazonS3.ListObjectsV2Async(listRequest, cancellationToken);
|
||||
foreach (var obj in listResponse.S3Objects)
|
||||
yield return (obj.Key, (obj.LastModified ?? DateTime.UtcNow).ToUniversalTime());
|
||||
yield return new StorageObject(obj.Key, (obj.LastModified ?? DateTime.UtcNow).ToUniversalTime());
|
||||
|
||||
listRequest.ContinuationToken = listResponse.NextContinuationToken;
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user