using Distribution.Infra.Authorization; using Microsoft.AspNetCore.Mvc; namespace Distribution.Features.Grn; [ApiController] public class GrnController(GrnService service, ICurrentUserService currentUser) : ControllerBase { [HttpGet("api/goods-receipts")] public async Task GetAll( [FromQuery] Guid? purchaseOrderId, [FromQuery] int page = 1, [FromQuery] int pageSize = 20) { var result = await service.GetAllAsync(purchaseOrderId, page, pageSize); return Ok(result); } [HttpGet("api/goods-receipts/{id:guid}")] public async Task GetById(Guid id) { var result = await service.GetByIdAsync(id); return result is null ? NotFound() : Ok(result); } [HttpPost("api/goods-receipts")] public async Task CreateFlat(CreateFlatGrnRequest request, CancellationToken ct) { // TEMPORARY: currentUser.UserId is always unset due to the broken auth middleware // (testbug.md #28) — fall back to the explicitly supplied user until that's fixed. var userId = currentUser.UserId ?? request.ReceivedByUserId; if (userId is null) return BadRequest(new { error = "ReceivedByUserId is required while auth is unavailable" }); try { var inner = new CreateGrnRequest(request.WarehouseId, request.Items); var result = await service.CreateAsync(request.PurchaseOrderId, inner, userId.Value, ct); return CreatedAtAction(nameof(GetById), new { id = result.Id }, result); } catch (InvalidOperationException ex) { return Conflict(new { error = ex.Message }); } } [HttpGet("api/purchase-orders/{id:guid}/goods-receipts")] public async Task GetByPurchaseOrder(Guid id) => Ok(await service.GetByPurchaseOrderIdAsync(id)); [HttpPost("api/purchase-orders/{id:guid}/goods-receipts")] public async Task Create(Guid id, CreateGrnRequest request, CancellationToken ct) { var userId = currentUser.UserId ?? request.ReceivedByUserId; if (userId is null) return BadRequest(new { error = "ReceivedByUserId is required while auth is unavailable" }); try { var result = await service.CreateAsync(id, request, userId.Value, ct); return CreatedAtAction(nameof(GetById), new { id = result.Id }, result); } catch (InvalidOperationException ex) { return Conflict(new { error = ex.Message }); } } }