From ecd5f5d13936dd097b12766cb95a568ad5b073a9 Mon Sep 17 00:00:00 2001
From: Melodi <62381002+Melodi17@users.noreply.github.com>
Date: Tue, 27 Oct 2026 23:04:59 +1000
Subject: feat: lots of stuff

---
 src/marlin.web/Controllers/DispatchController.cs | 71 ------------------------
 1 file changed, 71 deletions(-)
 delete mode 100644 src/marlin.web/Controllers/DispatchController.cs

(limited to 'src/marlin.web/Controllers/DispatchController.cs')

diff --git a/src/marlin.web/Controllers/DispatchController.cs b/src/marlin.web/Controllers/DispatchController.cs
deleted file mode 100644
index a37d5fa..0000000
--- a/src/marlin.web/Controllers/DispatchController.cs
+++ /dev/null
@@ -1,71 +0,0 @@
-namespace marlin.web.Controllers;
-
-using core.models;
-using core.models.meta;
-using core.util;
-using Data;
-using Microsoft.AspNetCore.Authorization;
-using Microsoft.AspNetCore.Mvc;
-using Microsoft.EntityFrameworkCore;
-using Models;
-using Services;
-using Util;
-
-[Route("api/dispatch")]
-[ApiController]
-[Authorize(Policy = "Agent")]
-public class DispatchController(ApplicationDbContext dbContext) : ControllerBase
-{
-    [HttpPost("handshake")]
-    public async Task<ActionResult<AgentConfiguration>> Handshake(AgentStatus status, CancellationToken ct)
-    {
-        var agentId = User.RequireAgentId();
-
-        var agent = await dbContext.Agents
-            .FirstAsync(x => x.Id == agentId, ct);
-
-        foreach (var capability in status.CapabilitySet.Items)
-            agent.Capabilities.Items[capability.Key] = capability.Value;
-
-        await dbContext.SaveChangesAsync(ct);
-
-        return new AgentConfiguration(
-            Name: agent.Name,
-            MaxConcurrentJobs: agent.MaxConcurrentJobs
-        );
-    }
-    
-    [HttpGet("queue")]
-    public async Task<ActionResult<DispatchJob?>> Queue(CancellationToken ct)
-    {
-        var agentId = User.RequireAgentId();
-
-        var nextJob = await dbContext
-            .Jobs
-            .Include(x => x.Source)
-            .Include(x => x.Branch)
-            .Include(x => x.Commit)
-            .Where(x => x.Status == JobStatus.Pending && x.AgentId == null)
-            .OrderBy(x => x.CreatedAt)
-            .FirstOrDefaultAsync(ct);
-
-        if (nextJob == null)
-            return (DispatchJob?) null;
-
-        string claimToken = SecureTokenGenerator.CreateClaimToken();
-        nextJob.ClaimToken = claimToken;
-        nextJob.AgentId = agentId;
-
-        await dbContext.SaveChangesAsync(ct);
-
-        return new DispatchJob(
-            Id: nextJob.Id,
-            Token: claimToken,
-            Vcs: nextJob.Source.UpstreamUrl,
-            Ref: nextJob.Branch.Name,
-            Commit: nextJob.Commit.Hash,
-            Recipe: nextJob.Recipe
-        );
-    } 
-}
-
-- 
cgit v1.3.1