ComAtprotoSync_GetRepo.cs

using Microsoft.AspNetCore.Http;

namespace dnproto.pds.xrpc;


public class ComAtprotoSync_GetRepo : BaseXrpcCommand
{
    public async Task<IResult> GetResponseAsync()
    {
        IncrementStatistics();
        
        //
        // Get did
        //
        string? did = HttpContext.Request.Query["did"];
        if(string.IsNullOrEmpty(did))
        {
            return Results.Json(new { error = "InvalidRequest", message = "Missing did" }, statusCode: 400);
        }

        if(did.Equals(Pds.PdsDb.GetConfigProperty("UserDid"), StringComparison.OrdinalIgnoreCase) == false)
        {
            return Results.Json(new { error = "NotFound", message = "Repo not found" }, statusCode: 404);
        }

        //
        // Write the MST to stream, using "application/vnd.ipld.car" content type
        //
        HttpContext.Response.ContentType = "application/vnd.ipld.car";
        await Pds.UserRepo.WriteToStreamAsync(HttpContext.Response.Body);
        return Results.Empty;
    }
}