chore: begin porting code from playground

This commit is contained in:
Stevan Freeborn
2025-05-07 23:54:46 -05:00
parent 30dbba37be
commit 3f4ab165ce
19 changed files with 230 additions and 24 deletions
+2
View File
@@ -0,0 +1,2 @@
[*.cs]
dotnet_diagnostic.CA2007.severity = none
@@ -0,0 +1,16 @@
namespace StevesBot.Worker.Discord;
internal class DiscordClientException : Exception
{
public DiscordClientException()
{
}
public DiscordClientException(string message) : base(message)
{
}
public DiscordClientException(string message, Exception innerException) : base(message, innerException)
{
}
}
@@ -0,0 +1,8 @@
namespace StevesBot.Worker.Discord;
internal class DiscordClientOptions
{
public string ApiUrl { get; init; } = string.Empty;
public string AppToken { get; init; } = string.Empty;
public int Intents { get; init; }
}
@@ -0,0 +1,16 @@
namespace StevesBot.Worker.Discord.Events;
internal record DiscordEvent
{
[JsonPropertyName("op")]
public int Op { get; init; }
[JsonPropertyName("s")]
public int? Sequence { get; init; }
[JsonPropertyName("t")]
public string? Type { get; init; }
[JsonPropertyName("d")]
public object? Data { get; init; }
}
@@ -0,0 +1,24 @@
namespace StevesBot.Worker.Discord.Events;
internal class DiscordEventConverter : JsonConverter<DiscordEvent>
{
private const string OpPropertyName = "op";
public override DiscordEvent? Read(ref Utf8JsonReader reader, Type typeToConvert, JsonSerializerOptions options)
{
using var jsonDoc = JsonDocument.ParseValue(ref reader);
var root = jsonDoc.RootElement;
var op = root.GetProperty(OpPropertyName).GetInt32();
return op switch
{
DiscordOpCodes.Hello => JsonSerializer.Deserialize<HelloDiscordEvent>(root.GetRawText(), options),
_ => JsonSerializer.Deserialize<DiscordEvent>(root.GetRawText(), options)
};
}
public override void Write(Utf8JsonWriter writer, DiscordEvent value, JsonSerializerOptions options)
{
throw new NotImplementedException();
}
}
@@ -0,0 +1,6 @@
namespace StevesBot.Worker.Discord.Events;
internal static class DiscordOpCodes
{
public const int Hello = 10;
}
@@ -0,0 +1,13 @@
namespace StevesBot.Worker.Discord.Events;
internal record HelloDiscordEvent : DiscordEvent
{
[JsonPropertyName("d")]
public new HelloData? Data { get; init; }
}
internal record HelloData
{
[JsonPropertyName("heartbeat_interval")]
public int HeartbeatInterval { get; init; }
}
+1 -1
View File
@@ -4,4 +4,4 @@ var builder = Host.CreateApplicationBuilder(args);
builder.Services.AddHostedService<Worker>();
var host = builder.Build();
host.Run();
await host.RunAsync();
+5 -3
View File
@@ -1,13 +1,15 @@
<Project Sdk="Microsoft.NET.Sdk.Worker">
<PropertyGroup>
<TargetFramework>net9.0</TargetFramework>
<Nullable>enable</Nullable>
<ImplicitUsings>enable</ImplicitUsings>
<UserSecretsId>dotnet-StevesBot.Worker-0b7a94ae-5cbd-406d-8422-1c791715ef7d</UserSecretsId>
</PropertyGroup>
<ItemGroup>
<PackageReference Include="Microsoft.Extensions.Hosting" Version="9.0.4" />
</ItemGroup>
<ItemGroup>
<InternalsVisibleTo Include="$(AssemblyName).Tests" />
<InternalsVisibleTo Include="DynamicProxyGenAssembly2" />
</ItemGroup>
</Project>
+2
View File
@@ -0,0 +1,2 @@
global using System.Text.Json;
global using System.Text.Json.Serialization;
+3 -2
View File
@@ -1,6 +1,6 @@
namespace StevesBot.Worker;
public class Worker : BackgroundService
internal class Worker : BackgroundService
{
private readonly ILogger<Worker> _logger;
@@ -15,8 +15,9 @@ public class Worker : BackgroundService
{
if (_logger.IsEnabled(LogLevel.Information))
{
_logger.LogInformation("Worker running at: {time}", DateTimeOffset.Now);
_logger.LogInformation("Worker running at: {Time}", DateTimeOffset.Now);
}
await Task.Delay(1000, stoppingToken);
}
}
@@ -0,0 +1,13 @@
{
"Logging": {
"LogLevel": {
"Default": "Information",
"Microsoft.Hosting.Lifetime": "Information"
}
},
"DiscordClientOptions": {
"ApiUrl": "ApiUrl",
"AppToken": "AppToken",
"Intents": 0
}
}