Composable Ecto.Query fragments mirroring the Accrue.Billing.Subscription predicates.

Every predicate in Accrue.Billing.Subscription has a matching query fragment here so you can filter subscriptions in the database with the same semantics as the in-memory predicates. Prefer these fragments over direct .status comparisons in where clauses — the predicates on Accrue.Billing.Subscription are the correct way to check subscription state, as direct comparisons miss edge cases like cancel_at_period_end and ended_at that the predicates cover.

All functions accept an optional queryable (default Accrue.Billing.Subscription) and compose via |>:

import Ecto.Query

from(s in Subscription, where: s.customer_id == ^id)
|> Accrue.Billing.Query.active()
|> Repo.all()