Add project files.
This commit is contained in:
@@ -0,0 +1,130 @@
|
||||
using Mediator;
|
||||
using Musify.Application.PlayLists.Commands;
|
||||
using Musify.Application.PlayLists.Queries;
|
||||
using WebApi.DataTransferObjects.PlayLists;
|
||||
using WebApi.Extensions;
|
||||
|
||||
namespace WebApi.Endpoints;
|
||||
|
||||
public static class PlayListEndpoints
|
||||
{
|
||||
public static IEndpointRouteBuilder MapPlayListEndpoints(this IEndpointRouteBuilder app)
|
||||
{
|
||||
var group = app.MapGroup("/api/playlists")
|
||||
.WithTags("PlayLists");
|
||||
|
||||
group.MapGet("/", GetPlayLists)
|
||||
.WithName("GetPlayLists")
|
||||
.WithSummary("Get paginated playlists.");
|
||||
|
||||
group.MapGet("/{id:guid}", GetPlayListById)
|
||||
.WithName("GetPlayListById")
|
||||
.WithSummary("Get a playlist by ID.");
|
||||
|
||||
group.MapGet("/users/{userId:guid}", GetPlayListsByUserId)
|
||||
.WithName("GetPlayListsByUserId")
|
||||
.WithSummary("Get paginated playlists for a user.");
|
||||
|
||||
group.MapPost("/users/{userId:guid}", CreatePlayList)
|
||||
.WithName("CreatePlayList")
|
||||
.WithSummary("Create a new playlist.");
|
||||
|
||||
group.MapPut("/{playlistId:guid}/users/{userId:guid}", UpdatePlayList)
|
||||
.WithName("UpdatePlayList")
|
||||
.WithSummary("Update an existing playlist.");
|
||||
|
||||
group.MapDelete("/{playlistId:guid}/users/{userId:guid}", DeletePlayList)
|
||||
.WithName("DeletePlayList")
|
||||
.WithSummary("Delete a playlist.");
|
||||
|
||||
group.MapPost("/upload-picture/users/{userId:guid}", RequestPlayListPictureUpload)
|
||||
.WithName("RequestPlayListPictureUpload")
|
||||
.WithSummary("Request a pre-signed URL to upload a playlist picture.");
|
||||
|
||||
return app;
|
||||
}
|
||||
|
||||
private static async Task<IResult> GetPlayLists(
|
||||
IMediator mediator,
|
||||
int pageNumber = 1,
|
||||
int pageSize = 10,
|
||||
CancellationToken ct = default)
|
||||
{
|
||||
var result = await mediator.Send(new GetPlayListsQuery(pageNumber, pageSize), ct);
|
||||
return result.ToHttpResult();
|
||||
}
|
||||
|
||||
private static async Task<IResult> GetPlayListById(
|
||||
IMediator mediator,
|
||||
Guid id,
|
||||
CancellationToken ct)
|
||||
{
|
||||
var result = await mediator.Send(new GetPlayListByIdQuery(id), ct);
|
||||
return result.ToHttpResult();
|
||||
}
|
||||
|
||||
private static async Task<IResult> GetPlayListsByUserId(
|
||||
IMediator mediator,
|
||||
Guid userId,
|
||||
string? name,
|
||||
int pageNumber = 1,
|
||||
int pageSize = 10,
|
||||
CancellationToken ct = default)
|
||||
{
|
||||
var result = await mediator.Send(new GetPlayListsByUserIdQuery(userId, name, pageNumber, pageSize), ct);
|
||||
return result.ToHttpResult();
|
||||
}
|
||||
|
||||
private static async Task<IResult> CreatePlayList(
|
||||
IMediator mediator,
|
||||
Guid userId,
|
||||
CreatePlayListRequest request,
|
||||
CancellationToken ct)
|
||||
{
|
||||
var result = await mediator.Send(
|
||||
new CreatePlayListCommand(userId, request.Name, request.Description, request.PictureIntentId),
|
||||
ct);
|
||||
|
||||
if (!result.IsSuccess)
|
||||
return result.ToHttpResult();
|
||||
|
||||
return Results.Created($"/api/playlists/{result.Value.Id}", result.Value);
|
||||
}
|
||||
|
||||
private static async Task<IResult> UpdatePlayList(
|
||||
IMediator mediator,
|
||||
Guid userId,
|
||||
Guid playlistId,
|
||||
UpdatePlayListRequest request,
|
||||
CancellationToken ct)
|
||||
{
|
||||
var result = await mediator.Send(
|
||||
new UpdatePlayListCommand(userId, playlistId, request.NewName, request.NewDescription, request.NewPictureIntentId),
|
||||
ct);
|
||||
|
||||
return result.ToHttpResult();
|
||||
}
|
||||
|
||||
private static async Task<IResult> DeletePlayList(
|
||||
IMediator mediator,
|
||||
Guid userId,
|
||||
Guid playlistId,
|
||||
CancellationToken ct)
|
||||
{
|
||||
var result = await mediator.Send(new DeletePlayListCommand(userId, playlistId), ct);
|
||||
return result.ToHttpResult();
|
||||
}
|
||||
|
||||
private static async Task<IResult> RequestPlayListPictureUpload(
|
||||
IMediator mediator,
|
||||
Guid userId,
|
||||
RequestPlayListPictureUploadRequest request,
|
||||
CancellationToken ct)
|
||||
{
|
||||
var result = await mediator.Send(
|
||||
new RequestPlayListPictureUploadCommand(userId, request.FileType, request.ContentType, request.ExpectedSizeBytes),
|
||||
ct);
|
||||
|
||||
return result.ToHttpResult();
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,119 @@
|
||||
using Mediator;
|
||||
using Musify.Application.Tracks.Commands;
|
||||
using Musify.Application.Tracks.Queries;
|
||||
using WebApi.DataTransferObjects.Tracks;
|
||||
using WebApi.Extensions;
|
||||
|
||||
namespace WebApi.Endpoints;
|
||||
|
||||
public static class TrackEndpoints
|
||||
{
|
||||
public static IEndpointRouteBuilder MapTrackEndpoints(this IEndpointRouteBuilder app)
|
||||
{
|
||||
var group = app.MapGroup("/api/tracks")
|
||||
.WithTags("Tracks");
|
||||
|
||||
group.MapGet("/", GetTracks)
|
||||
.WithName("GetTracks")
|
||||
.WithSummary("Get paginated tracks.");
|
||||
|
||||
group.MapGet("/{id:guid}", GetTrackById)
|
||||
.WithName("GetTrackById")
|
||||
.WithSummary("Get a track by ID.");
|
||||
|
||||
group.MapGet("/users/{userId:guid}", GetTracksByUserId)
|
||||
.WithName("GetTracksByUserId")
|
||||
.WithSummary("Get paginated tracks for a user.");
|
||||
|
||||
group.MapPost("/users/{userId:guid}", CreateTrack)
|
||||
.WithName("CreateTrack")
|
||||
.WithSummary("Create a new track.");
|
||||
|
||||
group.MapDelete("/{trackId:guid}/users/{userId:guid}", DeleteTrack)
|
||||
.WithName("DeleteTrack")
|
||||
.WithSummary("Delete a track.");
|
||||
|
||||
group.MapPost("/upload-urls/users/{userId:guid}", RequestTrackUploadUrls)
|
||||
.WithName("RequestTrackUploadUrls")
|
||||
.WithSummary("Request pre-signed URLs to upload track picture and audio.");
|
||||
|
||||
return app;
|
||||
}
|
||||
|
||||
private static async Task<IResult> GetTracks(
|
||||
IMediator mediator,
|
||||
int pageNumber = 1,
|
||||
int pageSize = 10,
|
||||
CancellationToken ct = default)
|
||||
{
|
||||
var result = await mediator.Send(new GetTracksQuery(pageNumber, pageSize), ct);
|
||||
return result.ToHttpResult();
|
||||
}
|
||||
|
||||
private static async Task<IResult> GetTrackById(
|
||||
IMediator mediator,
|
||||
Guid id,
|
||||
CancellationToken ct)
|
||||
{
|
||||
var result = await mediator.Send(new GetTrackByIdQuery(id), ct);
|
||||
return result.ToHttpResult();
|
||||
}
|
||||
|
||||
private static async Task<IResult> GetTracksByUserId(
|
||||
IMediator mediator,
|
||||
Guid userId,
|
||||
string? name,
|
||||
int pageNumber = 1,
|
||||
int pageSize = 10,
|
||||
CancellationToken ct = default)
|
||||
{
|
||||
var result = await mediator.Send(new GetTracksByUserIdQuery(userId, name, pageNumber, pageSize), ct);
|
||||
return result.ToHttpResult();
|
||||
}
|
||||
|
||||
private static async Task<IResult> CreateTrack(
|
||||
IMediator mediator,
|
||||
Guid userId,
|
||||
CreateTrackRequest request,
|
||||
CancellationToken ct)
|
||||
{
|
||||
var result = await mediator.Send(
|
||||
new CreateTrackCommand(userId, request.Title, request.PictureIntentId, request.AudioIntentId),
|
||||
ct);
|
||||
|
||||
if (!result.IsSuccess)
|
||||
return result.ToHttpResult();
|
||||
|
||||
return Results.Created($"/api/tracks/{result.Value.Id}", result.Value);
|
||||
}
|
||||
|
||||
private static async Task<IResult> DeleteTrack(
|
||||
IMediator mediator,
|
||||
Guid userId,
|
||||
Guid trackId,
|
||||
CancellationToken ct)
|
||||
{
|
||||
var result = await mediator.Send(new DeleteTrackCommand(userId, trackId), ct);
|
||||
return result.ToHttpResult();
|
||||
}
|
||||
|
||||
private static async Task<IResult> RequestTrackUploadUrls(
|
||||
IMediator mediator,
|
||||
Guid userId,
|
||||
RequestTrackUploadUrlsRequest request,
|
||||
CancellationToken ct)
|
||||
{
|
||||
var result = await mediator.Send(
|
||||
new RequestTrackUploadUrlsCommand(
|
||||
userId,
|
||||
request.PictureFileType,
|
||||
request.PictureContentType,
|
||||
request.AudioFileType,
|
||||
request.AudioContentType,
|
||||
request.ExpectedPictureSizeBytes,
|
||||
request.ExpectedAudioSizeBytes),
|
||||
ct);
|
||||
|
||||
return result.ToHttpResult();
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,78 @@
|
||||
using Mediator;
|
||||
using Musify.Application.Users.Commands;
|
||||
using Musify.Application.Users.Queries;
|
||||
using WebApi.DataTransferObjects.Users;
|
||||
using WebApi.Extensions;
|
||||
|
||||
namespace WebApi.Endpoints;
|
||||
|
||||
public static class UserEndpoints
|
||||
{
|
||||
public static IEndpointRouteBuilder MapUserEndpoints(this IEndpointRouteBuilder app)
|
||||
{
|
||||
var group = app.MapGroup("/api/users")
|
||||
.WithTags("Users");
|
||||
|
||||
group.MapGet("/", GetUsers)
|
||||
.WithName("GetUsers")
|
||||
.WithSummary("Get paginated users.");
|
||||
|
||||
group.MapGet("/{id:guid}", GetUserById)
|
||||
.WithName("GetUserById")
|
||||
.WithSummary("Get a user by ID.");
|
||||
|
||||
group.MapGet("/keycloak/{id:guid}", GetUserByKeycloak)
|
||||
.WithName("GetUserByKeycloak")
|
||||
.WithSummary("Get a user by Keycloak ID.");
|
||||
|
||||
group.MapPost("/", CreateUser)
|
||||
.WithName("CreateUser")
|
||||
.WithSummary("Create a new user.");
|
||||
|
||||
return app;
|
||||
}
|
||||
|
||||
private static async Task<IResult> GetUsers(
|
||||
IMediator mediator,
|
||||
int pageNumber = 1,
|
||||
int pageSize = 10,
|
||||
string? usernameSearch = null,
|
||||
CancellationToken ct = default)
|
||||
{
|
||||
var result = await mediator.Send(new GetUsersQuery(pageNumber, pageSize, usernameSearch), ct);
|
||||
return result.ToHttpResult();
|
||||
}
|
||||
|
||||
private static async Task<IResult> GetUserById(
|
||||
IMediator mediator,
|
||||
Guid id,
|
||||
CancellationToken ct)
|
||||
{
|
||||
var result = await mediator.Send(new GetUserByIdQuery(id), ct);
|
||||
return result.ToHttpResult();
|
||||
}
|
||||
|
||||
private static async Task<IResult> GetUserByKeycloak(
|
||||
IMediator mediator,
|
||||
Guid id,
|
||||
CancellationToken ct)
|
||||
{
|
||||
var result = await mediator.Send(new GetUserByKeycloakQuery(id), ct);
|
||||
return result.ToHttpResult();
|
||||
}
|
||||
|
||||
private static async Task<IResult> CreateUser(
|
||||
IMediator mediator,
|
||||
CreateUserRequest request,
|
||||
CancellationToken ct)
|
||||
{
|
||||
var result = await mediator.Send(
|
||||
new CreateUserCommand(request.Id, request.Name, request.FirstName, request.SecondName),
|
||||
ct);
|
||||
|
||||
if (!result.IsSuccess)
|
||||
return result.ToHttpResult();
|
||||
|
||||
return Results.Created($"/api/users/{result.Value.Id}", result.Value);
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user