Function labelDeps

internal/httpapi/messages_labels_test.go:16–46

labelDeps builds a server whose ModifyMessageLabels fake maps message ids to outcomes: "msg_cap" → cap exceeded, "msg_missing" → not found, anything else → echo the add list as the post-update set.

()

// outcomes: "msg_cap" → cap exceeded, "msg_missing" → not found, anything else
// → echo the add list as the post-update set.
func labelDeps() Deps {
	return Deps{
		Authenticator: func(r *http.Request) (*identity.User, error) {
			if r.Header.Get("Authorization") == "Bearer good" {
				return &identity.User{ID: "u_1", Email: "owner@acme.com"}, nil
			}
			return nil, errors.New("unauthorized")
		},
		GetAgent: func(ctx context.Context, address string) (*identity.AgentIdentity, error) {
			if address == "support@acme.com" {
				a := sampleAgent()
				return &a, nil
			}
			return nil, errors.New("not found")
		},
		ModifyMessageLabels: func(ctx context.Context, messageID, agentID string, add, remove []string) ([]string, error) {
			if agentID != "support@acme.com" {
				return nil, errors.New("unexpected agent")
			}
			switch messageID {
			case "msg_cap":
				return nil, identity.ErrLabelLimitExceeded
			case "msg_missing":
				return nil, identity.ErrMessageNotFound
			default:
				return add, nil
			}
		},
		Legacy: http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { w.WriteHeader(http.StatusTeapot) }),
	}
}

func TestUpdateMessageLabels_AddRemove(t *testing.T) {
	srv := httptest.NewServer(New(labelDeps()))