First Commit

Application/Application.csproj

@@ -0,0 +1,30 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>net10.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+	<RootNamespace>Musify.Application</RootNamespace>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Ardalis.Result" Version="10.1.0" />
+    <PackageReference Include="DispatchR.Mediator" Version="2.1.1" />
+    <PackageReference Include="Microsoft.EntityFrameworkCore" Version="10.0.5" />
+    <PackageReference Include="X.PagedList" Version="10.5.9" />
+    <PackageReference Include="X.PagedList.EF" Version="10.5.9" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\Musify.Backend\Domain.csproj" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <Folder Include="Configuration\" />
+    <Folder Include="Contracts\Application\" />
+    <Folder Include="PlayLists\Commands\CreatePlayList\" />
+    <Folder Include="PlayLists\Commands\DeletePlayList\" />
+    <Folder Include="PlayLists\Commands\UpdatePlayList\" />
+  </ItemGroup>
+
+</Project>

Application/ApplicationDependencyInjection.cs

@@ -0,0 +1,6 @@
+namespace Musify.Application
+{
+    public static class ApplicationDependencyInjection
+    {
+    }
+}

Application/Contracts/Infrastructure/IDatabase.cs

@@ -0,0 +1,18 @@
+using Microsoft.EntityFrameworkCore;
+using Musify.Domain.Entities;
+
+namespace Musify.Application.Contracts.Infrastructure
+{
+    public interface IDatabase
+    {
+        DbSet<User> Users { get; }
+
+        DbSet<PlayList> PlayLists { get; }
+
+        DbSet<Track> Tracks { get; }
+
+        DbSet<PlayListHasTrack> PlayListHasTracks { get; }
+
+        Task<int> SaveChangesAsync(CancellationToken cancellationToken);
+    }
+}

Application/Contracts/Infrastructure/IKeycloakUserClient.cs

@@ -0,0 +1,22 @@
+using Ardalis.Result;
+using Musify.Application.Users.Contracts;
+
+namespace Musify.Application.Contracts.Infrastructure
+{
+    public interface IKeycloakUserClient
+    {
+        Task<Result<KeycloakUserResponse>> GetUserByIdAsync(string keycloakId, CancellationToken cancellationToken);
+
+        Task<IReadOnlyCollection<KeycloakUserResponse>> GetUsersAsync(
+            CancellationToken cancellationToken,
+            string search = "",
+            int first = 0,
+            int max = 20,
+            string username = "");
+
+        Task<int> GetUsersCountAsync(
+            CancellationToken cancellationToken,
+            string search = "",
+            string username = "");
+    }
+}

Application/Contracts/Infrastructure/IStorageHandler.cs

@@ -0,0 +1,17 @@
+using Ardalis.Result;
+
+namespace Musify.Application.Contracts.Infrastructure
+{
+    public interface IStorageHandler
+    {
+        Task<Result<Stream>> GetFile(string bucketName, string keyName, CancellationToken cancellationToken);
+
+        Task<string> GetUrl(string bucketName, string keyName, TimeSpan ExpirationTime, CancellationToken cancellationToken);
+
+        Task<Result<string>> UploadFile(Stream sourceStream, string contentType, string bucketName, string keyName, CancellationToken cancellationToken);
+
+        Task<Result> TransferFiles(string sourceDirectory, string bucketName, string route, CancellationToken cancellationToken);
+
+        Task<Result> RemoveFile(string bucketName, string keyName, CancellationToken cancellationToken);
+    }
+}

Application/PlayLists/Contracts/PaginatedPlayListResponse.cs

@@ -0,0 +1,12 @@
+namespace Musify.Application.PlayLists.Contracts
+{
+    public record PaginatedPlayListResponse(
+        IReadOnlyCollection<PlayListResponse> PlayLists,
+        int PageNumber,
+        int PageSize,
+        int PageCount,
+        int TotalItemCount,
+        bool HasNextPage,
+        bool HasPreviousPage
+    );
+}

Application/PlayLists/Contracts/PlayListResponse.cs

@@ -0,0 +1,10 @@
+namespace Musify.Application.PlayLists.Contracts
+{
+    public record PlayListResponse(
+        Guid Id,
+        string Name,
+        string Description,
+        string ImageName,
+        DateTime CreatedAt,
+        DateTime UpdatedAt);
+}

Application/PlayLists/Queries/GetPlayListById/GetPlayListByIdQuery.cs

@@ -0,0 +1,9 @@
+using Ardalis.Result;
+using DispatchR.Abstractions.Send;
+using Musify.Application.PlayLists.Contracts;
+
+namespace Musify.Application.PlayLists.Queries.GetPlayListById
+{
+    public record GetPlayListByIdQuery(Guid Id)
+        : IRequest<GetPlayListByIdQuery, Result<PlayListResponse>>;
+}

Application/PlayLists/Queries/GetPlayListById/GetPlayListByIdQueryHandler.cs

@@ -0,0 +1,29 @@
+using Ardalis.Result;
+using DispatchR.Abstractions.Send;
+using Microsoft.EntityFrameworkCore;
+using Musify.Application.Contracts.Infrastructure;
+using Musify.Application.PlayLists.Contracts;
+
+namespace Musify.Application.PlayLists.Queries.GetPlayListById
+{
+    public class GetPlayListByIdQueryHandler(IDatabase database)
+        : IRequestHandler<GetPlayListByIdQuery, Task<Result<PlayListResponse>> >
+    {
+        public async Task<Result<PlayListResponse>> Handle(GetPlayListByIdQuery request, CancellationToken cancellationToken)
+        {
+            var playList = await database.PlayLists
+                .AsNoTracking()
+                .SingleOrDefaultAsync(p => p.Id == request.Id, cancellationToken);
+
+            return playList is not null
+                ? Result.Success(new PlayListResponse(
+                    playList.Id,
+                    playList.Name,
+                    playList.Description,
+                    playList.ImageName,
+                    playList.CreatedDate,
+                    playList.UpdatedDate))
+                : Result.NotFound("Playlist not found.");
+        }
+    }
+}

Application/PlayLists/Queries/GetPlayLists/GetPlayListsQuery.cs

@@ -0,0 +1,9 @@
+using Ardalis.Result;
+using DispatchR.Abstractions.Send;
+using Musify.Application.PlayLists.Contracts;
+
+namespace Musify.Application.PlayLists.Queries.GetPlayLists
+{
+    public record GetPlayListsQuery(int PageNumber = 1, int PageSize = 10)
+        : IRequest<GetPlayListsQuery, Result<PaginatedPlayListResponse>>;
+}

Application/PlayLists/Queries/GetPlayLists/GetPlayListsQueryHandler.cs

@@ -0,0 +1,44 @@
+using Ardalis.Result;
+using DispatchR.Abstractions.Send;
+using Microsoft.EntityFrameworkCore;
+using Musify.Application.Contracts.Infrastructure;
+using Musify.Application.PlayLists.Contracts;
+using X.PagedList.EF;
+
+namespace Musify.Application.PlayLists.Queries.GetPlayLists
+{
+    public class GetPlayListsQueryHandler(IDatabase database)
+        : IRequestHandler<GetPlayListsQuery, Task<Result<PaginatedPlayListResponse>> >
+    {
+        public async Task<Result<PaginatedPlayListResponse>> Handle(GetPlayListsQuery request, CancellationToken cancellationToken)
+        {
+            var pageNumber = request.PageNumber < 1 ? 1 : request.PageNumber;
+            var pageSize = request.PageSize < 1 ? 10 : request.PageSize;
+
+            var totalCount = await database.PlayLists.CountAsync(cancellationToken);
+
+            var pagedPlayLists = await database.PlayLists
+                .AsNoTracking()
+                .OrderBy(p => p.Id)
+                .Select(p => new PlayListResponse(
+                    p.Id,
+                    p.Name,
+                    p.Description,
+                    p.ImageName,
+                    p.CreatedDate,
+                    p.UpdatedDate))
+                .ToPagedListAsync(pageNumber, pageSize, totalCount, cancellationToken);
+
+            var response = new PaginatedPlayListResponse(
+                pagedPlayLists.ToArray(),
+                pagedPlayLists.PageNumber,
+                pagedPlayLists.PageSize,
+                pagedPlayLists.PageCount,
+                pagedPlayLists.TotalItemCount,
+                pagedPlayLists.HasNextPage,
+                pagedPlayLists.HasPreviousPage);
+
+            return Result.Success(response);
+        }
+    }
+}

Application/PlayLists/Queries/GetPlayListsByUserId/GetPlayListsByUserIdQuery.cs

@@ -0,0 +1,13 @@
+using Ardalis.Result;
+using DispatchR.Abstractions.Send;
+using Musify.Application.PlayLists.Contracts;
+
+namespace Musify.Application.PlayLists.Queries.GetPlayListsByUserId
+{
+    public record GetPlayListsByUserIdQuery(
+        Guid UserId,
+        string Name = "",
+        int PageNumber = 1,
+        int PageSize = 10)
+        : IRequest<GetPlayListsByUserIdQuery, Result<PaginatedPlayListResponse>>;
+}

Application/PlayLists/Queries/GetPlayListsByUserId/GetPlayListsByUserIdQueryHandler.cs

@@ -0,0 +1,51 @@
+using Ardalis.Result;
+using DispatchR.Abstractions.Send;
+using Microsoft.EntityFrameworkCore;
+using Musify.Application.Contracts.Infrastructure;
+using Musify.Application.PlayLists.Contracts;
+using X.PagedList.EF;
+
+namespace Musify.Application.PlayLists.Queries.GetPlayListsByUserId
+{
+    public class GetPlayListsByUserIdQueryHandler(IDatabase database)
+        : IRequestHandler<GetPlayListsByUserIdQuery, Task<Result<PaginatedPlayListResponse>> >
+    {
+        public async Task<Result<PaginatedPlayListResponse>> Handle(GetPlayListsByUserIdQuery request, CancellationToken cancellationToken)
+        {
+            var pageNumber = request.PageNumber < 1 ? 1 : request.PageNumber;
+            var pageSize = request.PageSize < 1 ? 10 : request.PageSize;
+            var normalizedName = request.Name.Trim().ToUpperInvariant();
+
+            var playListsQuery = database.PlayLists
+                .AsNoTracking()
+                .Where(p => p.UserId == request.UserId);
+
+            if (!string.IsNullOrWhiteSpace(normalizedName))
+                playListsQuery = playListsQuery.Where(p => p.NormalizedName.Contains(normalizedName));
+
+            var totalCount = await playListsQuery.CountAsync(cancellationToken);
+
+            var pagedPlayLists = await playListsQuery
+                .OrderBy(p => p.CreatedDate)
+                .Select(p => new PlayListResponse(
+                    p.Id,
+                    p.Name,
+                    p.Description,
+                    p.ImageName,
+                    p.CreatedDate,
+                    p.UpdatedDate))
+                .ToPagedListAsync(pageNumber, pageSize, totalCount, cancellationToken);
+
+            var response = new PaginatedPlayListResponse(
+                pagedPlayLists.ToArray(),
+                pagedPlayLists.PageNumber,
+                pagedPlayLists.PageSize,
+                pagedPlayLists.PageCount,
+                pagedPlayLists.TotalItemCount,
+                pagedPlayLists.HasNextPage,
+                pagedPlayLists.HasPreviousPage);
+
+            return Result.Success(response);
+        }
+    }
+}

Application/Users/Commands/CreateUser/CreateUserCommand.cs

@@ -0,0 +1,9 @@
+using Ardalis.Result;
+using DispatchR.Abstractions.Send;
+using Musify.Application.Users.Contracts;
+
+namespace Musify.Application.Users.Commands.CreateUser
+{
+    public record CreateUserCommand(Guid Id)
+        : IRequest<CreateUserCommand, Result<UserResponse>>;
+}

Application/Users/Commands/CreateUser/CreateUserCommandHandler.cs

@@ -0,0 +1,46 @@
+using Ardalis.Result;
+using DispatchR.Abstractions.Send;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.Extensions.Logging;
+using Musify.Application.Contracts.Infrastructure;
+using Musify.Application.Users.Contracts;
+using Musify.Domain.Entities;
+
+namespace Musify.Application.Users.Commands.CreateUser
+{
+    public class CreateUserCommandHandler(IDatabase database, IKeycloakUserClient keycloakUserClient, ILogger<CreateUserCommandHandler> logger)
+        : IRequestHandler<CreateUserCommand, Task<Result<UserResponse> >>
+    {
+        public async Task<Result<UserResponse>> Handle(CreateUserCommand request, CancellationToken cancellationToken)
+        {
+            logger.LogDebug("Handling {CommandName} with Id: {UserId}", nameof(CreateUserCommand), request.Id);
+
+            var existingUser = database.Users.SingleOrDefaultAsync(u => u.Id == request.Id, cancellationToken);
+
+            if (existingUser is not null)
+                return Result<UserResponse>.Conflict($"A user with Id {request.Id} already exists.");
+
+            var keycloakUser = await keycloakUserClient.GetUserByIdAsync(request.Id.ToString(), cancellationToken);
+
+            if (!keycloakUser.IsSuccess)
+                return Result.NotFound("Keycloak user not found.");
+
+            var newUser = new User
+            {
+                Id = request.Id
+            };
+
+            await database.Users.AddAsync(newUser, cancellationToken);
+
+            await database.SaveChangesAsync(cancellationToken);
+
+            return Result.Created(new UserResponse(
+                newUser.Id.ToString(),
+                keycloakUser.Value.Name,
+                keycloakUser.Value.FirstName,
+                keycloakUser.Value.SecondName,
+                newUser.CreatedAt,
+                newUser.UpdatedAt));
+        }
+    }
+}

Application/Users/Commands/DeleteUser/DeleteUserCommand.cs

@@ -0,0 +1,8 @@
+using Ardalis.Result;
+using DispatchR.Abstractions.Send;
+
+namespace Musify.Application.Users.Commands.DeleteUser
+{
+    public record DeleteUserCommand(Guid Id)
+        : IRequest<DeleteUserCommand, Result>;
+}

Application/Users/Commands/DeleteUser/DeleteUserCommandHandler.cs

@@ -0,0 +1,24 @@
+using Ardalis.Result;
+using DispatchR.Abstractions.Send;
+using Musify.Application.Contracts.Infrastructure;
+
+namespace Musify.Application.Users.Commands.DeleteUser
+{
+    public class DeleteUserCommandHandler(IDatabase database)
+        : IRequestHandler<DeleteUserCommand, Task<Result>>
+    {
+        public async Task<Result> Handle(DeleteUserCommand request, CancellationToken cancellationToken)
+        {
+            var existingUser = await database.Users.FindAsync(request.Id, cancellationToken);
+
+            if (existingUser is null)
+                return Result.NotFound();
+
+            database.Users.Remove(existingUser);
+
+            await database.SaveChangesAsync(cancellationToken);
+
+            return Result.NoContent();
+        }
+    }
+}

Application/Users/Contracts/KeycloakUserResponse.cs

@@ -0,0 +1,8 @@
+namespace Musify.Application.Users.Contracts
+{
+    public record KeycloakUserResponse(
+        Guid Id,
+        string Name,
+        string FirstName,
+        string SecondName);
+}

Application/Users/Contracts/PaginatedUserResponse.cs

@@ -0,0 +1,12 @@
+namespace Musify.Application.Users.Contracts
+{
+    public record PaginatedUserResponse(
+        IReadOnlyCollection<UserResponse> Users,
+        int PageNumber,
+        int PageSize,
+        int PageCount,
+        int TotalItemCount,
+        bool HasNextPage,
+        bool HasPreviousPage
+    );
+}

Application/Users/Contracts/UserResponse.cs

@@ -0,0 +1,10 @@
+namespace Musify.Application.Users.Contracts
+{
+    public record UserResponse(
+        string Id,
+        string Name,
+        string FirstName,
+        string SecondName,
+        DateTime CreatedAt,
+        DateTime UpdatedAt);
+}

Application/Users/Queries/GetUserById/GetUserByIdQuery.cs

@@ -0,0 +1,9 @@
+using Ardalis.Result;
+using DispatchR.Abstractions.Send;
+using Musify.Application.Users.Contracts;
+
+namespace Musify.Application.Users.Queries.GetUserById
+{
+    public record GetUserByIdQuery(Guid Id)
+        : IRequest<GetUserByIdQuery, Task<Result<UserResponse> >>;
+}

Application/Users/Queries/GetUserById/GetUserByIdQueryHandler.cs

@@ -0,0 +1,35 @@
+using Ardalis.Result;
+using DispatchR.Abstractions.Send;
+using Microsoft.EntityFrameworkCore;
+using Musify.Application.Contracts.Infrastructure;
+using Musify.Application.Users.Contracts;
+
+namespace Musify.Application.Users.Queries.GetUserById
+{
+    public class GetUserByIdQueryHandler(IDatabase database, IKeycloakUserClient keycloakUserClient)
+        : IRequestHandler<GetUserByIdQuery, Task<Result<UserResponse>>>
+    {
+        public async Task<Result<UserResponse>> Handle(GetUserByIdQuery request, CancellationToken cancellationToken)
+        {
+            var user = await database.Users
+                .AsNoTracking()
+                .SingleOrDefaultAsync(u => u.Id == request.Id, cancellationToken);
+
+            if (user is null)
+                return Result.NotFound("User not found.");
+
+            var keycloakUser = await keycloakUserClient.GetUserByIdAsync(user.Id.ToString(), cancellationToken);
+
+            if (!keycloakUser.IsSuccess)
+                return Result.NotFound("Keycloak user not found.");
+
+            return Result.Success(new UserResponse(
+                user.Id.ToString(),
+                keycloakUser.Value.Name,
+                keycloakUser.Value.FirstName,
+                keycloakUser.Value.SecondName,
+                user.CreatedAt,
+                user.UpdatedAt));
+        }
+    }
+}

Application/Users/Queries/GetUserByKeycloakId/GetUserByKeycloakCommand.cs

@@ -0,0 +1,9 @@
+using Ardalis.Result;
+using DispatchR.Abstractions.Send;
+using Musify.Application.Users.Contracts;
+
+namespace Musify.Application.Users.Queries.GetUserByKeycloakId
+{
+    public record GetUserByKeycloakQuery(Guid Id)
+        : IRequest<GetUserByKeycloakQuery, Task<Result<UserResponse> >>;
+}

Application/Users/Queries/GetUserByKeycloakId/GetUserByKeycloakCommandHandler.cs

@@ -0,0 +1,35 @@
+using Ardalis.Result;
+using DispatchR.Abstractions.Send;
+using Microsoft.EntityFrameworkCore;
+using Musify.Application.Contracts.Infrastructure;
+using Musify.Application.Users.Contracts;
+
+namespace Musify.Application.Users.Queries.GetUserByKeycloakId
+{
+    public class GetUserByKeycloakQueryHandler(IDatabase database, IKeycloakUserClient keycloakUserClient)
+        : IRequestHandler<GetUserByKeycloakQuery, Task<Result<UserResponse>>>
+    {
+        public async Task<Result<UserResponse>> Handle(GetUserByKeycloakQuery request, CancellationToken cancellationToken)
+        {
+            var user = await database.Users
+                .AsNoTracking()
+                .SingleOrDefaultAsync(u => u.Id == request.Id, cancellationToken);
+
+            if (user is null)
+                return Result.NotFound("User not found.");
+
+            var keycloakUser = await keycloakUserClient.GetUserByIdAsync(user.Id.ToString(), cancellationToken);
+
+            if (!keycloakUser.IsSuccess)
+                return Result.NotFound("Keycloak user not found.");
+
+            return Result.Success(new UserResponse(
+                user.Id.ToString(),
+                keycloakUser.Value.Name,
+                keycloakUser.Value.FirstName,
+                keycloakUser.Value.SecondName,
+                user.CreatedAt,
+                user.UpdatedAt));
+        }
+    }
+}

Application/Users/Queries/GetUsers/GetUsersCommand.cs

@@ -0,0 +1,9 @@
+using Ardalis.Result;
+using DispatchR.Abstractions.Send;
+using Musify.Application.Users.Contracts;
+
+namespace Musify.Application.Users.Queries.GetUsers
+{
+    public record GetUsersCommand(int PageNumber, int PageSize, string UsernameSearch)
+        : IRequest<GetUsersCommand, Task<Result<PaginatedUserResponse>> >;
+}

Application/Users/Queries/GetUsers/GetUsersCommandHandler.cs

@@ -0,0 +1,59 @@
+using Ardalis.Result;
+using DispatchR.Abstractions.Send;
+using Microsoft.EntityFrameworkCore;
+using Musify.Application.Contracts.Infrastructure;
+using Musify.Application.Users.Contracts;
+using X.PagedList;
+using X.PagedList.Extensions;
+
+namespace Musify.Application.Users.Queries.GetUsers
+{
+    public class GetUsersQueryHandler(IDatabase database, IKeycloakUserClient keycloakUserClient)
+        : IRequestHandler<GetUsersCommand, Task<Result<PaginatedUserResponse> >>
+    {
+        public async Task<Result<PaginatedUserResponse>> Handle(GetUsersCommand request, CancellationToken cancellationToken)
+        {
+            var pageNumber = request.PageNumber < 1 ? 1 : request.PageNumber;
+            var pageSize = request.PageSize < 1 ? 10 : request.PageSize;
+            var first = (pageNumber - 1) * pageSize;
+
+            var keycloakUsers = await keycloakUserClient.GetUsersAsync(
+                cancellationToken,
+                first: first,
+                max: pageSize,
+                search: request.UsernameSearch);
+
+            var keycloakIds = keycloakUsers.Select(u => u.Id).ToList();
+
+            var databaseUsers = await database.Users
+                .Where(u => keycloakIds.Contains(u.Id))
+                .ToListAsync(cancellationToken);
+
+            var users = databaseUsers
+                .Join(keycloakUsers, db => db.Id, kc => kc.Id,
+                    (databaseSource, keycloakSource) => new UserResponse(
+                        keycloakSource.Id.ToString(),
+                        keycloakSource.Name,
+                        keycloakSource.FirstName,
+                        keycloakSource.SecondName,
+                        databaseSource.CreatedAt,
+                        databaseSource.UpdatedAt))
+                .ToArray();
+
+            var totalItemCount = await keycloakUserClient.GetUsersCountAsync(cancellationToken, search: request.UsernameSearch);
+
+            var pagedUsers = new StaticPagedList<UserResponse>(users, pageNumber, pageSize, totalItemCount);
+
+            var response = new PaginatedUserResponse(
+                pagedUsers.ToArray(),
+                pagedUsers.PageNumber,
+                pagedUsers.PageSize,
+                pagedUsers.PageCount,
+                pagedUsers.TotalItemCount,
+                pagedUsers.HasNextPage,
+                pagedUsers.HasPreviousPage);
+
+            return Result.Success(response);
+        }
+    }
+}