uff, lot of work
This commit is contained in:
@@ -1,25 +1,17 @@
|
||||
namespace OwnChar.ServerNew.Api.Endpoint;
|
||||
using OwnChar.Api.Packets;
|
||||
|
||||
namespace OwnChar.Server.Api.Endpoint;
|
||||
|
||||
internal class ApiBuilder(WebApplication app) : IApiBuilder
|
||||
{
|
||||
public void Map(string method, string pattern, Delegate action)
|
||||
public void MapRequest(string pattern, Delegate action)
|
||||
{
|
||||
if (method == ApiRequestMethods.Get)
|
||||
app.MapGet(pattern, action);
|
||||
else if (method == ApiRequestMethods.Post)
|
||||
app.MapPost(pattern, action);
|
||||
else if (method == ApiRequestMethods.Put)
|
||||
app.MapPut(pattern, action);
|
||||
else if (method == ApiRequestMethods.Patch)
|
||||
app.MapPatch(pattern, action);
|
||||
else if (method == ApiRequestMethods.Delete)
|
||||
app.MapDelete(pattern, action);
|
||||
else
|
||||
throw new NotSupportedException();
|
||||
Map(pattern + "/{request}", action);
|
||||
}
|
||||
|
||||
public void Map(string pattern, Delegate action)
|
||||
{
|
||||
app.Map(pattern, action);
|
||||
//app.Map(pattern, action);
|
||||
app.MapPost(pattern, action);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
using System.Net;
|
||||
|
||||
namespace OwnChar.ServerNew.Api.Endpoint;
|
||||
namespace OwnChar.Server.Api.Endpoint;
|
||||
|
||||
public static class ApiRequestMethods
|
||||
{
|
||||
|
||||
@@ -1,6 +1,9 @@
|
||||
namespace OwnChar.ServerNew.Api.Endpoint;
|
||||
using OwnChar.Api.Packets;
|
||||
|
||||
namespace OwnChar.Server.Api.Endpoint;
|
||||
|
||||
public interface IApiBuilder
|
||||
{
|
||||
void MapRequest(string pattern, Delegate action);
|
||||
void Map(string path, Delegate action);
|
||||
}
|
||||
|
||||
@@ -1,4 +1,4 @@
|
||||
namespace OwnChar.ServerNew.Api.Endpoint;
|
||||
namespace OwnChar.Server.Api.Endpoint;
|
||||
|
||||
internal interface IApiEndpoint
|
||||
{
|
||||
|
||||
@@ -1,4 +1,7 @@
|
||||
namespace OwnChar.ServerNew.Api.Endpoint.Implementations;
|
||||
using OwnChar.Server.Api;
|
||||
using OwnChar.Server.Api.Endpoint;
|
||||
|
||||
namespace OwnChar.Server.Api.Endpoint.Implementations;
|
||||
|
||||
internal class CharactersApi(IServer server) : IApiEndpoint
|
||||
{
|
||||
|
||||
@@ -1,48 +1,188 @@
|
||||
namespace OwnChar.ServerNew.Api.Endpoint.Implementations;
|
||||
using OwnChar.Api.Packets;
|
||||
using OwnChar.Api.Packets.General;
|
||||
using OwnChar.Api.Packets.Groups;
|
||||
using OwnChar.Api.Updates;
|
||||
using OwnChar.Data;
|
||||
using OwnChar.Data.Model.Client;
|
||||
using OwnChar.Server.Data.Model;
|
||||
using OwnChar.Server.Extensions;
|
||||
|
||||
namespace OwnChar.Server.Api.Endpoint.Implementations;
|
||||
|
||||
internal class GroupsApi(IServer server) : IApiEndpoint
|
||||
{
|
||||
public void Initialize(IApiBuilder builder)
|
||||
{
|
||||
builder.MapRequest("/groups/get/byid", GetById);
|
||||
builder.MapRequest("/groups/get", Get);
|
||||
builder.MapRequest("/groups/create", Create);
|
||||
builder.MapRequest("/groups/update", Update);
|
||||
builder.MapRequest("/groups/delete", Delete);
|
||||
builder.MapRequest("/groups/members/get", GetMembers);
|
||||
builder.MapRequest("/groups/members/add", AddMembers);
|
||||
builder.MapRequest("/groups/members/update", UpdateMember);
|
||||
builder.MapRequest("/groups/members/remove", RemoveMembers);
|
||||
}
|
||||
|
||||
private IResult GetGroups()
|
||||
private IResult GetById(GetSinlgeObjectRequest request)
|
||||
{
|
||||
if (!server.CheckLogin(request, UserType.Guest, out UserAccountDb? user))
|
||||
return TypedResults.Unauthorized();
|
||||
|
||||
if (server.Data?.Set<GroupDb>().FirstOrDefault(n => n.Id == request.ObjectId && n.Members.Any(m => m.User != null && m.User.Id == user.Id)) is not GroupDb group)
|
||||
return TypedResults.Ok(new GetSingleObjectResponse<Group>(null).With(OwnCharResponseError.NotFound));
|
||||
|
||||
return TypedResults.Ok(new GetSingleObjectResponse<Group>(group.ToClient()));
|
||||
}
|
||||
|
||||
private IResult GetGroups(long characterId)
|
||||
private IResult Get(GetGroupsRequest request)
|
||||
{
|
||||
if (!server.CheckLogin(request, UserType.Guest, out UserAccountDb? user))
|
||||
return TypedResults.Unauthorized();
|
||||
|
||||
IQueryable<GroupDb> groups;
|
||||
|
||||
if (request.UseProfileId && server.Data!.Set<UserProfileDb>().FirstOrDefault(p => p.Id == request.ProfileId) is UserProfileDb profile)
|
||||
groups = server.Data!.Set<GroupDb>().Where(group => group.Members.Any(m => m.User != null && m.User.Id == profile.Id));
|
||||
else if (request.IncludeNonPublic && user.Is(UserType.Admin))
|
||||
groups = server.Data!.Set<GroupDb>();
|
||||
else
|
||||
groups = Array.Empty<GroupDb>().AsQueryable(); // Currently not supported.
|
||||
|
||||
return TypedResults.Ok(new GetGroupsResponse([.. groups.Select(g => g.ToClient())]));
|
||||
}
|
||||
|
||||
private IResult GetGroup(long groupId)
|
||||
private IResult Create(CreateGroupRequest request)
|
||||
{
|
||||
if (!server.CheckLogin(request, UserType.User, out UserAccountDb? user))
|
||||
return TypedResults.Unauthorized();
|
||||
|
||||
var group = new GroupDb();
|
||||
|
||||
if (!string.IsNullOrWhiteSpace(request.Name))
|
||||
group.Name = request.Name;
|
||||
|
||||
group.Members.Add(new()
|
||||
{
|
||||
User = user.Profile,
|
||||
Level = MemberLevel.Owner,
|
||||
});
|
||||
|
||||
server.Data!.Update(group);
|
||||
server.Data.SaveChanges();
|
||||
|
||||
return TypedResults.Ok(new CreateGroupResponse(group.ToClient()));
|
||||
}
|
||||
|
||||
private IResult CreateGroup(string name)
|
||||
private IResult Update(UpdateRequest request)
|
||||
{
|
||||
if (!server.CheckLogin(request, UserType.User, out UserAccountDb? user)
|
||||
|| server.Data?.Set<GroupDb>().FirstOrDefault(n => n.Id == request.Update.Id) is not GroupDb group
|
||||
|| !group.Members.Any(m => m.Id == user.Profile!.Id && m.Level >= MemberLevel.Admin
|
||||
|| user.IsNot(UserType.Admin)))
|
||||
return TypedResults.Unauthorized();
|
||||
|
||||
if (request.Update is not GroupUpdate update)
|
||||
return TypedResults.Ok(new UpdateResponse().With(OwnCharResponseError.Default));
|
||||
|
||||
group.Name = update.Name;
|
||||
group.Fandom = update.Fandom;
|
||||
|
||||
server.Data.Update(group);
|
||||
server.Data.SaveChanges();
|
||||
|
||||
return TypedResults.Ok(new UpdateResponse());
|
||||
}
|
||||
|
||||
private IResult UpdateGroup(int groupId, string name)
|
||||
private IResult Delete(DeleteObjectRequest request)
|
||||
{
|
||||
if (!server.CheckLogin(request, UserType.User, out UserAccountDb? user)
|
||||
|| server.Data?.Set<GroupDb>().FirstOrDefault(n => n.Id == request.ObjectId) is not GroupDb group
|
||||
|| !group.Members.Any(m => m.Id == user.Profile!.Id && m.Level >= MemberLevel.Owner)
|
||||
|| user.IsNot(UserType.Admin))
|
||||
return TypedResults.Unauthorized();
|
||||
|
||||
server.Data.Remove(group);
|
||||
server.Data.SaveChanges();
|
||||
|
||||
return TypedResults.Ok(new DeleteObjectResponse());
|
||||
}
|
||||
|
||||
private IResult DeleteGroup(int groupId)
|
||||
private IResult GetMembers(GetGroupMembersRequest request)
|
||||
{
|
||||
if (!server.CheckLogin(request, UserType.User, out UserAccountDb? user)
|
||||
|| server.Data?.Set<GroupDb>().FirstOrDefault(n => n.Id == request.GroupId) is not GroupDb group
|
||||
|| !group.Members.Any(m => m.Id == user.Profile!.Id && m.Level >= MemberLevel.Member)
|
||||
|| user.IsNot(UserType.Admin))
|
||||
return TypedResults.Unauthorized();
|
||||
|
||||
var members = group.Members.Select(n => n.ToClient());
|
||||
return TypedResults.Ok(new GetGroupMembersResponse(members.ToList()));
|
||||
}
|
||||
|
||||
private IResult AddMember(int groupId, long memberId)
|
||||
private IResult AddMembers(GroupMemberAddRequest request)
|
||||
{
|
||||
if (!server.CheckLogin(request, UserType.User, out UserAccountDb? user)
|
||||
|| server.Data?.Set<GroupDb>().FirstOrDefault(n => n.Id == request.GroupId) is not GroupDb group
|
||||
|| !group.Members.Any(m => m.Id == user.Profile!.Id && m.Level >= MemberLevel.Admin)
|
||||
|| user.IsNot(UserType.Admin))
|
||||
return TypedResults.Unauthorized();
|
||||
|
||||
var addedMembers = new List<MemberEntryDb>();
|
||||
|
||||
foreach (var kvp in request.Members)
|
||||
{
|
||||
if (group.Members.FirstOrDefault(m => m.User != null && m.User.Id == kvp.Key) is not MemberEntryDb member
|
||||
&& server.Data.Set<UserProfileDb>().FirstOrDefault(u => u.Id == kvp.Key) is UserProfileDb mu)
|
||||
{
|
||||
member = new()
|
||||
{
|
||||
User = mu,
|
||||
Level = kvp.Value,
|
||||
};
|
||||
server.Data.Update(member);
|
||||
server.Data.Update(group);
|
||||
server.Data.SaveChanges();
|
||||
}
|
||||
}
|
||||
|
||||
return TypedResults.Ok(new GroupMemberAddResponse(addedMembers.Select(m => m.ToClient()).ToList()));
|
||||
}
|
||||
|
||||
private IResult RemoveMember(int groupId, long memberId)
|
||||
private IResult UpdateMember(UpdateRequest request)
|
||||
{
|
||||
if (!server.CheckLogin(request, UserType.User, out UserAccountDb? user)
|
||||
|| server.Data?.Set<GroupDb>().FirstOrDefault(n => n.Id == request.Update.Id) is not GroupDb group
|
||||
|| group.Members.FirstOrDefault(m => m.Id == request.Update.Id) is not MemberEntryDb member
|
||||
|| !group.Members.Any(m => m.Id == user.Profile!.Id && m.Level >= MemberLevel.Admin
|
||||
|| user.IsNot(UserType.Admin)))
|
||||
return TypedResults.Unauthorized();
|
||||
|
||||
if (request.Update is not MemberUpdate update)
|
||||
return TypedResults.Ok(new UpdateResponse().With(OwnCharResponseError.Default));
|
||||
|
||||
member.Level = update.Level;
|
||||
|
||||
server.Data.Update(member);
|
||||
server.Data.SaveChanges();
|
||||
|
||||
return TypedResults.Ok(new UpdateResponse());
|
||||
}
|
||||
|
||||
private IResult RemoveMembers(DeleteObjectRequest request)
|
||||
{
|
||||
if (!server.CheckLogin(request, UserType.User, out UserAccountDb? user)
|
||||
|| server.Data?.Set<MemberEntryDb>().FirstOrDefault(m => m.Id == request.ObjectId) is not MemberEntryDb member
|
||||
|| server.Data?.Set<GroupDb>().FirstOrDefault(n => n.Members.Contains(member)) is not GroupDb group
|
||||
|| !group.Members.Any(m => m.Id == user.Profile!.Id && m.Level >= MemberLevel.Admin
|
||||
|| user.IsNot(UserType.Admin)))
|
||||
return TypedResults.Unauthorized();
|
||||
|
||||
group.Members.Remove(member);
|
||||
server.Data.Remove(member);
|
||||
server.Data.Update(group);
|
||||
server.Data.SaveChanges();
|
||||
|
||||
return TypedResults.Ok(new DeleteObjectResponse());
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,8 +1,9 @@
|
||||
using OwnChar.Base.Data.Requests;
|
||||
using OwnChar.Base.Data.Responses;
|
||||
using OwnChar.Api.Packets;
|
||||
using OwnChar.Api.Packets.General;
|
||||
using OwnChar.Server.Data.Model;
|
||||
using OwnChar.Server.Extensions;
|
||||
|
||||
namespace OwnChar.ServerNew.Api.Endpoint.Implementations;
|
||||
namespace OwnChar.Server.Api.Endpoint.Implementations;
|
||||
|
||||
internal class LoginApi(ServerContext server) : IApiEndpoint
|
||||
{
|
||||
@@ -20,13 +21,13 @@ internal class LoginApi(ServerContext server) : IApiEndpoint
|
||||
&& server.Data.Set<UserAccountDb>()?.FirstOrDefault(n => n.Username == request.Username && n.Password == request.Password) is UserAccountDb acc
|
||||
&& acc.Profile != null)
|
||||
{
|
||||
result = new(new(acc), new(acc.Profile), server.Login(acc));
|
||||
result = new(acc.ToClient(), acc.Profile.ToClient(), server.Login(acc));
|
||||
}
|
||||
else
|
||||
{
|
||||
result = new(null, null, null)
|
||||
{
|
||||
ErrorCode = Base.Data.OwnCharResponseError.NotAuthorized
|
||||
ErrorCode = OwnCharResponseError.NotFound,
|
||||
};
|
||||
}
|
||||
|
||||
@@ -36,6 +37,6 @@ internal class LoginApi(ServerContext server) : IApiEndpoint
|
||||
private IResult Logout(LogoutRequest request)
|
||||
{
|
||||
server.Logout(request.AuthSecret);
|
||||
return TypedResults.Ok();
|
||||
return TypedResults.Ok(new LogoutResponse());
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,4 +1,6 @@
|
||||
namespace OwnChar.ServerNew.Api.Endpoint.Implementations;
|
||||
using OwnChar.Server.Api;
|
||||
|
||||
namespace OwnChar.Server.Api.Endpoint.Implementations;
|
||||
|
||||
internal class UsersApi(IServer server) : IApiEndpoint
|
||||
{
|
||||
|
||||
Reference in New Issue
Block a user