Method loadInbound

internal/httpapi/outbound.go:221–238

loadInbound resolves the owned agent + the inbound message (404 if missing or not on this agent).

(ctx context.Context, address, msgID string)

// loadInbound resolves the owned agent + the inbound message (404 if missing
// or not on this agent).
func (s *Server) loadInbound(ctx context.Context, address, msgID string) (*identity.AgentIdentity, *identity.Message, *identity.User, error) {
	ag, err := s.resolveOwnedAgent(ctx, address)
	if err != nil {
		return nil, nil, nil, err
	}
	user, uerr := s.requireUser(ctx)
	if uerr != nil {
		return nil, nil, nil, uerr
	}
	if s.deps.GetInboundMessage == nil {
		return nil, nil, nil, NewError(http.StatusInternalServerError, "internal_error", "outbound unavailable")
	}
	in, err := s.deps.GetInboundMessage(ctx, msgID)
	if err != nil || in == nil || in.AgentID != ag.ID {
		return nil, nil, nil, NewError(http.StatusNotFound, "not_found", "message not found")
	}
	return ag, in, user, nil
}

func (s *Server) handleReply(ctx context.Context, in *replyInput) (*sendOutput, error) {
	ag, inbound, user, err := s.loadInbound(ctx, in.Address, in.ID)