51 lines
1.9 KiB
C#
51 lines
1.9 KiB
C#
using System.Text.Json;
|
|
using System.Text.Json.Nodes;
|
|
using Alchegos.Core.Services.RabbitMQ;
|
|
|
|
namespace Alchegos.Webhook.Handlers.GiteaEventHandlers;
|
|
|
|
public class IssuesEventHandler : IGiteaEventHandler
|
|
{
|
|
public async Task HandleAsync(JsonNode payload, IRabbitPublisher publisher)
|
|
{
|
|
string action = payload["action"]?.ToString() ?? "";
|
|
string repo_url = payload["repository"]?["url"]?.ToString();
|
|
string repo_owner = payload["repository"]?["owner"]?["login"]?.ToString();
|
|
string repo_name = payload["repository"]?["name"]?.ToString();
|
|
string issue_url = payload["issue"]?["url"]?.ToString();
|
|
string issue_id = payload["issue"]?["id"]?.ToString();
|
|
|
|
var labels = payload["issue"]?["labels"]?.AsArray() ?? new JsonArray();
|
|
|
|
var routingKeys = new Dictionary<string, string>
|
|
{
|
|
{"status/ready", "ready_to_develop"},
|
|
{"status/completed", "task_completed"}
|
|
};
|
|
|
|
if (action is "opened" or "label_updated")
|
|
{
|
|
foreach (var label in labels)
|
|
{
|
|
string labelName = label["name"]?.ToString().Trim() ?? label.ToString().Trim();
|
|
if (routingKeys.TryGetValue(labelName, out string routingKey))
|
|
{
|
|
var message = new Dictionary<string, string>
|
|
{
|
|
{ "repo_url", repo_url },
|
|
{ "repo_owner", repo_owner },
|
|
{ "repo_name", repo_name },
|
|
{ "issue_url", issue_url },
|
|
{ "issue_id", issue_id },
|
|
};
|
|
await publisher.PublishAsync(
|
|
exchange: "alchegos",
|
|
routingKey: routingKey,
|
|
message: JsonSerializer.Serialize(message));
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|