Change on files
This commit is contained in:
@@ -23,6 +23,6 @@ namespace Musify.Application.Contracts
|
|||||||
|
|
||||||
Task RemoveFolderAsync(string bucket, string folderKey, CancellationToken cancellationToken);
|
Task RemoveFolderAsync(string bucket, string folderKey, CancellationToken cancellationToken);
|
||||||
|
|
||||||
IAsyncEnumerable<(string Key, DateTime LastModifiedUtc)> ListObjectsAsync(string bucket, string prefix, CancellationToken cancellationToken);
|
IAsyncEnumerable<StorageObject> ListObjectsAsync(string bucket, string prefix, CancellationToken cancellationToken);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -0,0 +1,4 @@
|
|||||||
|
namespace Musify.Application.Contracts
|
||||||
|
{
|
||||||
|
public record StorageObject(string Key, DateTime LastModifiedUtc);
|
||||||
|
}
|
||||||
@@ -1,4 +1,4 @@
|
|||||||
using Musify.Application.Common;
|
using Musify.Application.Shared;
|
||||||
|
|
||||||
namespace Musify.Application.Events
|
namespace Musify.Application.Events
|
||||||
{
|
{
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
using Musify.Application.Common;
|
using Musify.Application.Shared;
|
||||||
|
|
||||||
namespace Musify.Application.Events
|
namespace Musify.Application.Events
|
||||||
{
|
{
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
using Musify.Application.Common;
|
using Musify.Application.Shared;
|
||||||
|
|
||||||
namespace Musify.Application.Events
|
namespace Musify.Application.Events
|
||||||
{
|
{
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
using Musify.Application.Common;
|
using Musify.Application.Shared;
|
||||||
|
|
||||||
namespace Musify.Application.Events
|
namespace Musify.Application.Events
|
||||||
{
|
{
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
using Musify.Application.Common;
|
using Musify.Application.Shared;
|
||||||
|
|
||||||
namespace Musify.Application.Events
|
namespace Musify.Application.Events
|
||||||
{
|
{
|
||||||
|
|||||||
@@ -3,7 +3,7 @@ using Mediator;
|
|||||||
using Microsoft.EntityFrameworkCore;
|
using Microsoft.EntityFrameworkCore;
|
||||||
using Microsoft.Extensions.Logging;
|
using Microsoft.Extensions.Logging;
|
||||||
using Musify.Application.Configuration;
|
using Musify.Application.Configuration;
|
||||||
using Musify.Application.Common;
|
using Musify.Application.Shared;
|
||||||
using Musify.Application.Events;
|
using Musify.Application.Events;
|
||||||
using Musify.Application.PlayLists.Commands;
|
using Musify.Application.PlayLists.Commands;
|
||||||
using Musify.Application.PlayLists.Responses;
|
using Musify.Application.PlayLists.Responses;
|
||||||
|
|||||||
@@ -3,7 +3,7 @@ using Mediator;
|
|||||||
using Microsoft.EntityFrameworkCore;
|
using Microsoft.EntityFrameworkCore;
|
||||||
using Microsoft.Extensions.Logging;
|
using Microsoft.Extensions.Logging;
|
||||||
using Musify.Application.Configuration;
|
using Musify.Application.Configuration;
|
||||||
using Musify.Application.Common;
|
using Musify.Application.Shared;
|
||||||
using Musify.Application.Events;
|
using Musify.Application.Events;
|
||||||
using Musify.Application.PlayLists.Commands;
|
using Musify.Application.PlayLists.Commands;
|
||||||
using Musify.Application.PlayLists.Responses;
|
using Musify.Application.PlayLists.Responses;
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
namespace Musify.Application.Common
|
namespace Musify.Application.Shared
|
||||||
{
|
{
|
||||||
public record ImageSize(
|
public record ImageSize(
|
||||||
string SavePath,
|
string SavePath,
|
||||||
@@ -3,7 +3,7 @@ using Mediator;
|
|||||||
using Microsoft.EntityFrameworkCore;
|
using Microsoft.EntityFrameworkCore;
|
||||||
using Microsoft.Extensions.Logging;
|
using Microsoft.Extensions.Logging;
|
||||||
using Musify.Application.Configuration;
|
using Musify.Application.Configuration;
|
||||||
using Musify.Application.Common;
|
using Musify.Application.Shared;
|
||||||
using Musify.Application.Events;
|
using Musify.Application.Events;
|
||||||
using Musify.Application.Tracks.Commands;
|
using Musify.Application.Tracks.Commands;
|
||||||
using Musify.Application.Tracks.Responses;
|
using Musify.Application.Tracks.Responses;
|
||||||
|
|||||||
+1
-1
@@ -1,4 +1,4 @@
|
|||||||
using Musify.Application.Common;
|
using Musify.Application.Shared;
|
||||||
using Musify.Application.Events;
|
using Musify.Application.Events;
|
||||||
|
|
||||||
namespace Musify.Infrastructure.MassTransit.Arguments
|
namespace Musify.Infrastructure.MassTransit.Arguments
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
using Musify.Application.Common;
|
using Musify.Application.Shared;
|
||||||
using Musify.Application.Events;
|
using Musify.Application.Events;
|
||||||
|
|
||||||
namespace Musify.Infrastructure.MassTransit.Arguments
|
namespace Musify.Infrastructure.MassTransit.Arguments
|
||||||
|
|||||||
+1
-1
@@ -1,6 +1,6 @@
|
|||||||
using MassTransit;
|
using MassTransit;
|
||||||
using MassTransit.Courier.Contracts;
|
using MassTransit.Courier.Contracts;
|
||||||
using Musify.Application.Common;
|
using Musify.Application.Shared;
|
||||||
using Musify.Application.Events;
|
using Musify.Application.Events;
|
||||||
using Musify.Infrastructure.Configuration;
|
using Musify.Infrastructure.Configuration;
|
||||||
using Musify.Infrastructure.MassTransit.Activities;
|
using Musify.Infrastructure.MassTransit.Activities;
|
||||||
|
|||||||
+1
-1
@@ -1,6 +1,6 @@
|
|||||||
using MassTransit;
|
using MassTransit;
|
||||||
using MassTransit.Courier.Contracts;
|
using MassTransit.Courier.Contracts;
|
||||||
using Musify.Application.Common;
|
using Musify.Application.Shared;
|
||||||
using Musify.Application.Events;
|
using Musify.Application.Events;
|
||||||
using Musify.Infrastructure.MassTransit.Activities.Files;
|
using Musify.Infrastructure.MassTransit.Activities.Files;
|
||||||
using Musify.Infrastructure.MassTransit.Activities.PlayLists;
|
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)
|
string bucket, string prefix, [System.Runtime.CompilerServices.EnumeratorCancellation] CancellationToken cancellationToken)
|
||||||
{
|
{
|
||||||
var listRequest = new ListObjectsV2Request
|
var listRequest = new ListObjectsV2Request
|
||||||
@@ -242,7 +242,7 @@ namespace Musify.Infrastructure.Services
|
|||||||
{
|
{
|
||||||
listResponse = await amazonS3.ListObjectsV2Async(listRequest, cancellationToken);
|
listResponse = await amazonS3.ListObjectsV2Async(listRequest, cancellationToken);
|
||||||
foreach (var obj in listResponse.S3Objects)
|
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;
|
listRequest.ContinuationToken = listResponse.NextContinuationToken;
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user