Discord-History-Tracker/app/Server/Endpoints/TrackChannelEndpoint.cs

using System.Net;
using System.Text.Json;
using System.Threading;
using System.Threading.Tasks;
using DHT.Server.Data;
using DHT.Server.Database;
using DHT.Utils.Http;
using Microsoft.AspNetCore.Http;

namespace DHT.Server.Endpoints;

sealed class TrackChannelEndpoint(IDatabaseFile db) : BaseEndpoint(db) {
	protected override async Task Respond(HttpRequest request, HttpResponse response, CancellationToken cancellationToken) {
		var root = await ReadJson(request);
		var server = ReadServer(root.RequireObject("server"), "server");
		var channel = ReadChannel(root.RequireObject("channel"), "channel", server.Id);

		await Db.Servers.Add([server]);
		await Db.Channels.Add([channel]);
	}

	private static Data.Server ReadServer(JsonElement json, string path) => new () {
		Id = json.RequireSnowflake("id", path),
		Name = json.RequireString("name", path),
		Type = ServerTypes.FromString(json.RequireString("type", path)) ?? throw new HttpException(HttpStatusCode.BadRequest, "Server type must be either 'SERVER', 'GROUP', or 'DM'.")
	};

	private static Channel ReadChannel(JsonElement json, string path, ulong serverId) => new () {
		Id = json.RequireSnowflake("id", path),
		Server = serverId,
		Name = json.RequireString("name", path),
		ParentId = json.HasKey("parent") ? json.RequireSnowflake("parent", path) : null,
		Position = json.HasKey("position") ? json.RequireInt("position", path, min: 0) : null,
		Topic = json.HasKey("topic") ? json.RequireString("topic", path) : null,
		Nsfw = json.HasKey("nsfw") ? json.RequireBool("nsfw", path) : null
	};
}