Function attTestServer

internal/httpapi/attachment_endpoint_test.go:40–89

(t *testing.T, opts ...func(*Deps))

}

func attTestServer(t *testing.T, opts ...func(*Deps)) *httptest.Server {
	t.Helper()
	u := &identity.User{ID: "u_1", Email: "owner@acme.com"}
	deps := Deps{
		PrincipalAuthenticator: func(r *http.Request) (*identity.Principal, error) {
			switch r.Header.Get("Authorization") {
			case "Bearer acct":
				return &identity.Principal{User: u, Scope: identity.ScopeAccount}, nil
			case "Bearer agtOther":
				return &identity.Principal{User: u, Scope: identity.ScopeAgent, AgentID: "other@acme.com"}, nil
			}
			return nil, errors.New("unauthorized")
		},
		AuthChallenge: func(r *http.Request) string { return `Bearer realm="e2a"` },
		GetAgent: func(ctx context.Context, address string) (*identity.AgentIdentity, error) {
			switch address {
			case "support@acme.com":
				a := sampleAgent()
				return &a, nil
			case "other@acme.com":
				// A second agent of the same owner — used to prove a download token
				// minted for support's message can't be replayed against other's path.
				a := sampleAgent()
				a.ID = "other@acme.com"
				return &a, nil
			}
			return nil, errors.New("not found")
		},
		GetMessage: func(ctx context.Context, id, agentID string) (*identity.Message, error) {
			if agentID != "support@acme.com" {
				return nil, errors.New("not found")
			}
			switch id {
			case "msg_att":
				return &identity.Message{ID: id, Direction: "inbound", Recipient: "support@acme.com", RawMessage: attMultipart()}, nil
			case "msg_big":
				return &identity.Message{ID: id, Direction: "inbound", Recipient: "support@acme.com", RawMessage: attBig()}, nil
			}
			return nil, errors.New("not found")
		},
		AttachmentStore: NewNativeAttachmentStore("test-secret-test-secret", "http://att.test"),
		Legacy:          http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { w.WriteHeader(http.StatusTeapot) }),
	}
	for _, o := range opts {
		o(&deps)
	}
	srv := httptest.NewServer(New(deps).Router)
	t.Cleanup(srv.Close)
	return srv
}

func getJSONAtt(t *testing.T, url, bearer string) (int, map[string]any) {
	t.Helper()