66 lines
No EOL
2.9 KiB
C#
66 lines
No EOL
2.9 KiB
C#
using System.Net.Mime;
|
|
using System.Text;
|
|
using Iceshrimp.Backend.Controllers.Attributes;
|
|
using Iceshrimp.Backend.Controllers.Schemas;
|
|
using Iceshrimp.Backend.Core.Database;
|
|
using Iceshrimp.Backend.Core.Federation.ActivityPub;
|
|
using Iceshrimp.Backend.Core.Federation.ActivityStreams;
|
|
using Iceshrimp.Backend.Core.Federation.ActivityStreams.Types;
|
|
using Iceshrimp.Backend.Core.Middleware;
|
|
using Iceshrimp.Backend.Core.Queues;
|
|
using Iceshrimp.Backend.Core.Services;
|
|
using Microsoft.AspNetCore.Mvc;
|
|
using Microsoft.EntityFrameworkCore;
|
|
|
|
namespace Iceshrimp.Backend.Controllers;
|
|
|
|
[ApiController]
|
|
[Tags("ActivityPub")]
|
|
[UseNewtonsoftJson]
|
|
public class ActivityPubController : Controller {
|
|
[HttpGet("/notes/{id}")]
|
|
[AuthorizedFetch]
|
|
[MediaTypeRouteFilter("application/activity+json", "application/ld+json")]
|
|
[Produces("application/activity+json", "application/ld+json; profile=\"https://www.w3.org/ns/activitystreams\"")]
|
|
[ProducesResponseType(StatusCodes.Status200OK, Type = typeof(ASNote))]
|
|
[ProducesResponseType(StatusCodes.Status401Unauthorized, Type = typeof(ErrorResponse))]
|
|
[ProducesResponseType(StatusCodes.Status404NotFound, Type = typeof(ErrorResponse))]
|
|
public async Task<IActionResult> GetNote(string id, [FromServices] DatabaseContext db,
|
|
[FromServices] NoteRenderer noteRenderer) {
|
|
var note = await db.Notes.FirstOrDefaultAsync(p => p.Id == id);
|
|
if (note == null) return NotFound();
|
|
var rendered = noteRenderer.Render(note);
|
|
var compacted = LdHelpers.Compact(rendered);
|
|
return Ok(compacted);
|
|
}
|
|
|
|
[HttpGet("/users/{id}")]
|
|
[AuthorizedFetch]
|
|
[MediaTypeRouteFilter("application/activity+json", "application/ld+json")]
|
|
[Produces("application/activity+json", "application/ld+json; profile=\"https://www.w3.org/ns/activitystreams\"")]
|
|
[ProducesResponseType(StatusCodes.Status200OK, Type = typeof(ASActor))]
|
|
[ProducesResponseType(StatusCodes.Status404NotFound, Type = typeof(ErrorResponse))]
|
|
public async Task<IActionResult> GetUser(string id,
|
|
[FromServices] DatabaseContext db,
|
|
[FromServices] UserRenderer userRenderer) {
|
|
var user = await db.Users.FirstOrDefaultAsync(p => p.Id == id);
|
|
if (user == null) return NotFound();
|
|
var rendered = await userRenderer.RenderAsync(user);
|
|
var compacted = LdHelpers.Compact(rendered);
|
|
return Ok(compacted);
|
|
}
|
|
|
|
[HttpPost("/inbox")]
|
|
[HttpPost("/users/{id}/inbox")]
|
|
[AuthorizedFetch(true)]
|
|
[EnableRequestBuffering(1024 * 1024)]
|
|
[Produces("text/plain")]
|
|
[Consumes(MediaTypeNames.Application.Json)]
|
|
public async Task<IActionResult> Inbox(string? id, [FromServices] QueueService queues) {
|
|
using var reader = new StreamReader(Request.Body, Encoding.UTF8, true, 1024, true);
|
|
var body = await reader.ReadToEndAsync();
|
|
Request.Body.Position = 0;
|
|
await queues.InboxQueue.EnqueueAsync(new InboxJob { Body = body, InboxUserId = id });
|
|
return Accepted();
|
|
}
|
|
} |