hzhang/Alchegos.Webhook
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add: terminal tool

Browse Source
This commit is contained in:
h z
2025-05-01 23:01:29 +01:00
parent eee9eca6cb
commit 11fed38dff
18 changed files with 98 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
Handlers/GiteaEventHandlers/IGiteaEventHandler.cs Normal file
View File

@@ -0,0 +1,6 @@
namespace Alchegos.Webhook.Handlers.GiteaEventHandlers;
public interface IGiteaEventHandler: IWebhookEventHandler
{
}

24
Handlers/GiteaEventHandlers/IssueCommentEventHandler.cs Normal file
View File

@@ -0,0 +1,24 @@
using System.Text.Json;
using System.Text.Json.Nodes;
using Alchegos.Core.Services.RabbitMQ;
namespace Alchegos.Webhook.Handlers.GiteaEventHandlers;
public class IssueCommentEventHandler : IGiteaEventHandler
{
public async Task HandleAsync(JsonNode payload, IRabbitPublisher publisher)
{
if (payload["action"]?.ToString() != "created")
return;
Dictionary<string, string> message = new Dictionary<string, string>
{
{"repo_url", payload["repository"]?["url"]?.ToString()},
{"repo_owner", payload["repository"]?["owner"]?["login"]?.ToString()},
{"repo_name", payload["repository"]?["name"]?.ToString()},
{"issue_id", payload["issue"]?["id"]?.ToString()},
{"comment_id", payload["comment"]?["id"]?.ToString()},
};
await publisher.PublishAsync("alchegos", "issue_commented", JsonSerializer.Serialize(message));
}
}

50
Handlers/GiteaEventHandlers/IssuesEventHandler.cs Normal file
View File

@@ -0,0 +1,50 @@
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;
}
}
}
}
}

49
Handlers/GiteaEventHandlers/PullRequestEventHandler.cs Normal file
View File

@@ -0,0 +1,49 @@
using System.Text.Json;
using System.Text.Json.Nodes;
using Alchegos.Core.Services.RabbitMQ;
namespace Alchegos.Webhook.Handlers.GiteaEventHandlers;
public class PullRequestEventHandler : 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 branch = payload["pull_request"]?["head"]?["ref"]?.ToString();
JsonArray labels = payload["pull_request"]?["labels"]?.AsArray() ?? new JsonArray();
Dictionary<string, string> routingKeys = new Dictionary<string, string>
{
{"status/pending_review", "pull_request_pending_review"},
{"status/pending_test", "pull_request_pending_test"}
};
if (action is "opened" or "label_updated")
{
foreach (JsonNode label in labels)
{
string labelName = label["name"]?.ToString().Trim() ?? label.ToString().Trim();
if (routingKeys.TryGetValue(labelName, out string routingKey))
{
Dictionary<string, string> message = new Dictionary<string, string>
{
{"repo_url", repo_url},
{"repo_owner", repo_owner},
{"repo_name", repo_name},
{"branch", branch}
};
await publisher.PublishAsync(
exchange: "alchegos",
routingKey: routingKey,
message: JsonSerializer.Serialize(message)
);
break;
}
}
}
}
}

34
Handlers/GiteaEventHandlers/PushEventHandler.cs Normal file
View File

@@ -0,0 +1,34 @@
using System.Text.Json;
using System.Text.Json.Nodes;
using Alchegos.Core.Services.RabbitMQ;
namespace Alchegos.Webhook.Handlers.GiteaEventHandlers;
public class PushEventHandler : IGiteaEventHandler
{
public async Task HandleAsync(JsonNode payload, IRabbitPublisher publisher)
{
string branch = payload["ref"]?.ToString()?.Replace("refs/heads/", "") ?? "";
if (branch == "main")
return;
JsonArray commits = payload["commits"]?.AsArray() ?? new JsonArray();
foreach (var commit in commits)
{
if (commit["message"]?.ToString()?.Trim() == "init")
{
Dictionary<string, string> message = new Dictionary<string, string>
{
{"repo_url", payload["repository"]?["url"]?.ToString()},
{"repo_owner", payload["repository"]?["owner"]?["login"]?.ToString()},
{"repo_name", payload["repository"]?["name"]?.ToString()}
};
await publisher.PublishAsync(
exchange: "alchegos",
routingKey:"project_initialized",
message: JsonSerializer.Serialize(message));
break;
}
}
}
}