forked from coracle/caravel
Compare commits
6 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 827c65c707 | |||
| a26bc1127d | |||
| bc79da34cf | |||
| 38e3a64312 | |||
| d209353abd | |||
| 08c9a2920b |
@@ -0,0 +1,11 @@
|
|||||||
|
CREATE INDEX IF NOT EXISTS idx_tenant_stripe_customer_id
|
||||||
|
ON tenant (stripe_customer_id);
|
||||||
|
|
||||||
|
CREATE INDEX IF NOT EXISTS idx_relay_tenant_id
|
||||||
|
ON relay (tenant, id);
|
||||||
|
|
||||||
|
CREATE INDEX IF NOT EXISTS idx_relay_tenant_status_plan
|
||||||
|
ON relay (tenant, status, plan);
|
||||||
|
|
||||||
|
CREATE INDEX IF NOT EXISTS idx_activity_resource_type_resource_id_created_at_id
|
||||||
|
ON activity (resource_type, resource_id, created_at DESC, id DESC);
|
||||||
+1
-1
@@ -132,7 +132,7 @@ Notes:
|
|||||||
|
|
||||||
- Serves `POST /relays/:id/deactivate`
|
- Serves `POST /relays/:id/deactivate`
|
||||||
- Authorizes admin or relay owner
|
- Authorizes admin or relay owner
|
||||||
- If relay is already inactive, return a `400` with `code=relay-is-inactive`
|
- If relay status is `inactive` or `delinquent`, return a `400` with `code=relay-is-inactive`
|
||||||
- Call `command.deactivate_relay`
|
- Call `command.deactivate_relay`
|
||||||
- Return `data` is empty
|
- Return `data` is empty
|
||||||
|
|
||||||
|
|||||||
+37
-7
@@ -26,12 +26,15 @@ Members:
|
|||||||
|
|
||||||
Manages the Stripe subscription and subscription items for a relay's tenant. Only paid (non-free) relays interact with Stripe. Free-only tenants have no subscription. Must be idempotent.
|
Manages the Stripe subscription and subscription items for a relay's tenant. Only paid (non-free) relays interact with Stripe. Free-only tenants have no subscription. Must be idempotent.
|
||||||
|
|
||||||
|
Stripe uses **pay-in-advance** by default: when a subscription is first created, Stripe immediately generates an open invoice for the current period. The `invoice.created` webhook fires shortly after and `handle_invoice_created` attempts payment.
|
||||||
|
|
||||||
- Fetch the relay and tenant associated with the `activity`
|
- Fetch the relay and tenant associated with the `activity`
|
||||||
- **If relay plan is `free`**: if the relay has a `stripe_subscription_item_id`, delete it via the Stripe API and call `command.delete_relay_subscription_item`. Then check cleanup (below). Return early.
|
- **If relay plan is `free`**: if the relay has a `stripe_subscription_item_id`, delete it via the Stripe API and call `command.delete_relay_subscription_item`. Then run downgrade proration validation by previewing the upcoming invoice and logging proration lines/amounts. Then check cleanup (below). Return early.
|
||||||
- **If relay is `inactive`**: if the relay has a `stripe_subscription_item_id`, delete it via the Stripe API and call `command.delete_relay_subscription_item`. Then check cleanup (below). Return early.
|
- **If relay is `inactive` or `delinquent`**: if the relay has a `stripe_subscription_item_id`, delete it via the Stripe API and call `command.delete_relay_subscription_item`. Then check cleanup (below). Return early.
|
||||||
- **If relay is `active` and on a paid plan**:
|
- **If relay is `active` and on a paid plan**:
|
||||||
- **Ensure subscription exists**: If the tenant has no `stripe_subscription_id`, create a Stripe subscription for the customer with `collection_method: "charge_automatically"` and the relay's price as the first item. Save the subscription ID via `command.set_tenant_subscription` and the item ID via `command.set_relay_subscription_item`. Return early.
|
- **Ensure subscription exists**: If the tenant has no `stripe_subscription_id`, create a Stripe subscription for the customer with `collection_method: "charge_automatically"` and the relay's price as the first item. Save the subscription ID via `command.set_tenant_subscription` and the item ID via `command.set_relay_subscription_item`. Return early.
|
||||||
- **Sync the subscription item**: If the tenant already has a subscription, create or update the relay's Stripe subscription item to the plan's `stripe_price_id` via the Stripe API, then call `command.set_relay_subscription_item`.
|
- **Sync the subscription item**: If the tenant already has a subscription, create or update the relay's Stripe subscription item to the plan's `stripe_price_id` via the Stripe API, then call `command.set_relay_subscription_item`.
|
||||||
|
- **Downgrade validation**: when changing an existing subscription item, detect if the new plan amount is lower than the current one. If yes, preview the upcoming Stripe invoice and log proration line/amount details to validate expected credit/proration behavior.
|
||||||
- **Clean up empty subscription**: After any item deletion, check if the tenant has any remaining active paid relays. If none and the tenant has a `stripe_subscription_id`, cancel the Stripe subscription immediately and call `command.clear_tenant_subscription`.
|
- **Clean up empty subscription**: After any item deletion, check if the tenant has any remaining active paid relays. If none and the tenant has a `stripe_subscription_id`, cancel the Stripe subscription immediately and call `command.clear_tenant_subscription`.
|
||||||
|
|
||||||
## `pub fn handle_webhook(&self, payload: &str, signature: &str) -> Result<()>`
|
## `pub fn handle_webhook(&self, payload: &str, signature: &str) -> Result<()>`
|
||||||
@@ -44,6 +47,7 @@ Manages the Stripe subscription and subscription items for a relay's tenant. Onl
|
|||||||
- `invoice.overdue` -> `self.handle_invoice_overdue`
|
- `invoice.overdue` -> `self.handle_invoice_overdue`
|
||||||
- `customer.subscription.updated` -> `self.handle_subscription_updated`
|
- `customer.subscription.updated` -> `self.handle_subscription_updated`
|
||||||
- `customer.subscription.deleted` -> `self.handle_subscription_deleted`
|
- `customer.subscription.deleted` -> `self.handle_subscription_deleted`
|
||||||
|
- `payment_method.attached` -> `self.handle_payment_method_attached`
|
||||||
- Unknown event types are ignored (return Ok)
|
- Unknown event types are ignored (return Ok)
|
||||||
|
|
||||||
## `pub async fn stripe_list_invoices(&self, customer_id: &str) -> Result<Value>`
|
## `pub async fn stripe_list_invoices(&self, customer_id: &str) -> Result<Value>`
|
||||||
@@ -66,16 +70,37 @@ Manages the Stripe subscription and subscription items for a relay's tenant. Onl
|
|||||||
- Creates a Stripe Customer Portal session for the given customer
|
- Creates a Stripe Customer Portal session for the given customer
|
||||||
- Returns the portal session URL
|
- Returns the portal session URL
|
||||||
|
|
||||||
|
## `pub async fn pay_outstanding_nwc_invoices(&self, tenant: &Tenant) -> Result<()>`
|
||||||
|
|
||||||
|
Called when a tenant first sets their NWC URL (via `PUT /tenants/:pubkey`). Attempts to pay any currently open invoices for the tenant using their NWC wallet, so that invoices created before NWC was configured are not left unpaid.
|
||||||
|
|
||||||
|
- If `tenant.nwc_url` is empty, return early.
|
||||||
|
- List all Stripe invoices for `tenant.stripe_customer_id` via `stripe_list_invoices`.
|
||||||
|
- For each invoice with `status == "open"` and `amount_due > 0`:
|
||||||
|
- Attempt NWC payment via `nwc_pay_invoice`.
|
||||||
|
- On success: call `stripe_pay_invoice_out_of_band` and `command.clear_tenant_nwc_error`.
|
||||||
|
- On failure: call `command.set_tenant_nwc_error` and log the error; continue to the next invoice.
|
||||||
|
|
||||||
|
## `pub async fn pay_outstanding_card_invoices(&self, tenant: &Tenant) -> Result<()>`
|
||||||
|
|
||||||
|
Attempts Stripe-side collection for open invoices when the tenant has a card on file.
|
||||||
|
|
||||||
|
- If tenant has no card payment method, return early.
|
||||||
|
- List all Stripe invoices for `tenant.stripe_customer_id`.
|
||||||
|
- For each invoice with `status == "open"` and `amount_due > 0`:
|
||||||
|
- Call Stripe `POST /v1/invoices/:id/pay` to retry collection using the card on file.
|
||||||
|
- Log and continue on failures.
|
||||||
|
|
||||||
## `fn handle_invoice_created(&self, invoice: &Invoice)`
|
## `fn handle_invoice_created(&self, invoice: &Invoice)`
|
||||||
|
|
||||||
Attempts to pay a new subscription invoice. Payment priority:
|
Attempts to pay a new subscription invoice. Because Stripe defaults to pay-in-advance, this webhook fires immediately when a subscription is created (i.e. when a paid relay is added or a plan is upgraded). Payment priority:
|
||||||
|
|
||||||
1. **NWC auto-pay**: If the tenant has a `nwc_url`:
|
1. **NWC auto-pay**: If the tenant has a `nwc_url`:
|
||||||
- Create a bolt11 Lightning invoice for the invoice amount using `self.nwc_url` (the receiving/system wallet)
|
- Create a bolt11 Lightning invoice for the invoice amount using `self.nwc_url` (the receiving/system wallet)
|
||||||
- Pay the bolt11 invoice using the tenant's `nwc_url` (the spending/tenant wallet)
|
- Pay the bolt11 invoice using the tenant's `nwc_url` (the spending/tenant wallet)
|
||||||
- If payment succeeds: call Stripe `POST /v1/invoices/:id/pay` with `paid_out_of_band: true`. Clear `nwc_error` via `command.clear_tenant_nwc_error`.
|
- If payment succeeds: call Stripe `POST /v1/invoices/:id/pay` with `paid_out_of_band: true`. Clear `nwc_error` via `command.clear_tenant_nwc_error`.
|
||||||
- If payment fails: set `nwc_error` on tenant via `command.set_tenant_nwc_error`. Fall through to next option.
|
- If payment fails: set `nwc_error` on tenant via `command.set_tenant_nwc_error`. Fall through to next option.
|
||||||
2. **Card on file**: If the tenant has a payment method on the Stripe customer, do nothing — Stripe will charge automatically.
|
2. **Card on file**: If the tenant has a payment method on the Stripe customer, do nothing here — Stripe will charge automatically for this invoice attempt.
|
||||||
3. **Manual payment**: If neither NWC nor card is available, send a DM via `robot.send_dm` notifying the tenant that payment is due with a link to the application for manual Lightning payment.
|
3. **Manual payment**: If neither NWC nor card is available, send a DM via `robot.send_dm` notifying the tenant that payment is due with a link to the application for manual Lightning payment.
|
||||||
|
|
||||||
Skip invoices with `amount_due` of 0.
|
Skip invoices with `amount_due` of 0.
|
||||||
@@ -85,7 +110,7 @@ Skip invoices with `amount_due` of 0.
|
|||||||
- Look up tenant by `stripe_customer_id`
|
- Look up tenant by `stripe_customer_id`
|
||||||
- If tenant has `past_due_at` set:
|
- If tenant has `past_due_at` set:
|
||||||
- Clear `past_due_at` via `command.clear_tenant_past_due`
|
- Clear `past_due_at` via `command.clear_tenant_past_due`
|
||||||
- Find all `inactive` relays for the tenant that were deactivated due to non-payment (i.e. relays on paid plans that are inactive)
|
- Find all `delinquent` relays on paid plans for the tenant (relays marked delinquent by the billing system due to non-payment)
|
||||||
- Reactivate each one via `command.activate_relay`
|
- Reactivate each one via `command.activate_relay`
|
||||||
|
|
||||||
## `fn handle_invoice_payment_failed(&self, invoice: &Invoice)`
|
## `fn handle_invoice_payment_failed(&self, invoice: &Invoice)`
|
||||||
@@ -98,7 +123,7 @@ Skip invoices with `amount_due` of 0.
|
|||||||
## `fn handle_invoice_overdue(&self, invoice: &Invoice)`
|
## `fn handle_invoice_overdue(&self, invoice: &Invoice)`
|
||||||
|
|
||||||
- Look up tenant by `stripe_customer_id`
|
- Look up tenant by `stripe_customer_id`
|
||||||
- Deactivate all active relays on paid plans via `command.deactivate_relay`
|
- Mark all active relays on paid plans as delinquent via `command.mark_relay_delinquent` (sets status to `delinquent`, distinct from user-initiated `deactivate_relay`)
|
||||||
- Send a DM via `robot.send_dm` notifying the tenant that their paid relays have been deactivated due to non-payment
|
- Send a DM via `robot.send_dm` notifying the tenant that their paid relays have been deactivated due to non-payment
|
||||||
|
|
||||||
## `fn handle_subscription_updated(&self, subscription: &Subscription)`
|
## `fn handle_subscription_updated(&self, subscription: &Subscription)`
|
||||||
@@ -106,9 +131,14 @@ Skip invoices with `amount_due` of 0.
|
|||||||
- Look up tenant by `stripe_customer_id`
|
- Look up tenant by `stripe_customer_id`
|
||||||
- If subscription status is `canceled` or `unpaid`:
|
- If subscription status is `canceled` or `unpaid`:
|
||||||
- Clear `stripe_subscription_id` via `command.clear_tenant_subscription`
|
- Clear `stripe_subscription_id` via `command.clear_tenant_subscription`
|
||||||
- Deactivate all active paid relays for the tenant via `command.deactivate_relay`
|
- Mark all active paid relays as delinquent via `command.mark_relay_delinquent`
|
||||||
|
|
||||||
## `fn handle_subscription_deleted(&self, subscription: &Subscription)`
|
## `fn handle_subscription_deleted(&self, subscription: &Subscription)`
|
||||||
|
|
||||||
- Look up tenant by `stripe_customer_id`
|
- Look up tenant by `stripe_customer_id`
|
||||||
- Clear `stripe_subscription_id` via `command.clear_tenant_subscription`
|
- Clear `stripe_subscription_id` via `command.clear_tenant_subscription`
|
||||||
|
|
||||||
|
## `fn handle_payment_method_attached(&self, stripe_customer_id: &str)`
|
||||||
|
|
||||||
|
- Look up tenant by `stripe_customer_id`
|
||||||
|
- Call `pay_outstanding_card_invoices` so invoices that were due before card setup are retried immediately
|
||||||
|
|||||||
@@ -44,6 +44,14 @@ Notes:
|
|||||||
|
|
||||||
- Sets relay status to `inactive`
|
- Sets relay status to `inactive`
|
||||||
- Logs activity as `(deactivate_relay, relay_id)`
|
- Logs activity as `(deactivate_relay, relay_id)`
|
||||||
|
- Used for user/admin-initiated deactivation only
|
||||||
|
|
||||||
|
## `pub fn mark_relay_delinquent(&self, relay: &Relay) -> Result<()>`
|
||||||
|
|
||||||
|
- Sets relay status to `delinquent`
|
||||||
|
- Logs activity as `(deactivate_relay, relay_id)`
|
||||||
|
- Used exclusively by the billing system when a relay's subscription becomes past due
|
||||||
|
- `delinquent` relays are automatically reactivated via `activate_relay` when payment is received
|
||||||
|
|
||||||
## `pub fn activate_relay(&self, relay: &Relay) -> Result<()>`
|
## `pub fn activate_relay(&self, relay: &Relay) -> Result<()>`
|
||||||
|
|
||||||
|
|||||||
@@ -69,7 +69,7 @@ A relay is a nostr relay owned by a `tenant` and hosted by the attached zooid in
|
|||||||
- `subdomain` - the relay's subdomain
|
- `subdomain` - the relay's subdomain
|
||||||
- `plan` - the relay's plan
|
- `plan` - the relay's plan
|
||||||
- `stripe_subscription_item_id` (nullable) - the Stripe subscription item id. Only set for relays on paid plans.
|
- `stripe_subscription_item_id` (nullable) - the Stripe subscription item id. Only set for relays on paid plans.
|
||||||
- `status` - `active|inactive`. Only `active` relays count toward billing.
|
- `status` - one of `active|inactive|delinquent`. Only `active` relays count toward billing. `delinquent` is set by the billing system when a relay's subscription becomes past due; `inactive` is set when a user or admin manually deactivates a relay.
|
||||||
- `synced` - whether the relay has been successfully synced to zooid at least once.
|
- `synced` - whether the relay has been successfully synced to zooid at least once.
|
||||||
- `sync_error` - a string indicating any errors encountered when synchronizing.
|
- `sync_error` - a string indicating any errors encountered when synchronizing.
|
||||||
- `info_name` - the relay's name
|
- `info_name` - the relay's name
|
||||||
|
|||||||
+125
-52
@@ -251,22 +251,16 @@ impl Api {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
fn prepare_relay(&self, mut relay: Relay) -> anyhow::Result<Relay> {
|
fn prepare_relay(&self, mut relay: Relay) -> std::result::Result<Relay, RelayValidationError> {
|
||||||
if !relay
|
validate_subdomain_label(&relay.subdomain)?;
|
||||||
.subdomain
|
|
||||||
.chars()
|
|
||||||
.all(|c| c.is_ascii_lowercase() || c.is_ascii_digit() || c == '-')
|
|
||||||
{
|
|
||||||
return Err(anyhow!("invalid-subdomain"));
|
|
||||||
}
|
|
||||||
|
|
||||||
let plan = Query::get_plan(&relay.plan).ok_or_else(|| anyhow!("invalid-plan"))?;
|
let plan = Query::get_plan(&relay.plan).ok_or(RelayValidationError::InvalidPlan)?;
|
||||||
|
|
||||||
if !plan.blossom && relay.blossom_enabled == 1 {
|
if !plan.blossom && relay.blossom_enabled == 1 {
|
||||||
return Err(anyhow!("premium-feature"));
|
return Err(RelayValidationError::PremiumFeature);
|
||||||
}
|
}
|
||||||
if !plan.livekit && relay.livekit_enabled == 1 {
|
if !plan.livekit && relay.livekit_enabled == 1 {
|
||||||
return Err(anyhow!("premium-feature"));
|
return Err(RelayValidationError::PremiumFeature);
|
||||||
}
|
}
|
||||||
|
|
||||||
if relay.schema.is_empty() {
|
if relay.schema.is_empty() {
|
||||||
@@ -289,6 +283,96 @@ impl Api {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
const SUBDOMAIN_LABEL_MAX_LEN: usize = 63;
|
||||||
|
const RESERVED_SUBDOMAIN_LABELS: [&str; 2] = ["api", "admin"];
|
||||||
|
|
||||||
|
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
|
||||||
|
enum SubdomainValidationError {
|
||||||
|
Empty,
|
||||||
|
TooLong,
|
||||||
|
Reserved,
|
||||||
|
EdgeHyphen,
|
||||||
|
InvalidCharacters,
|
||||||
|
}
|
||||||
|
|
||||||
|
impl SubdomainValidationError {
|
||||||
|
fn code(self) -> &'static str {
|
||||||
|
match self {
|
||||||
|
Self::Empty => "subdomain-empty",
|
||||||
|
Self::TooLong => "subdomain-too-long",
|
||||||
|
Self::Reserved => "subdomain-reserved",
|
||||||
|
Self::EdgeHyphen => "subdomain-invalid-hyphen",
|
||||||
|
Self::InvalidCharacters => "subdomain-invalid-characters",
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn message(self) -> &'static str {
|
||||||
|
match self {
|
||||||
|
Self::Empty => "subdomain is required",
|
||||||
|
Self::TooLong => "subdomain must be 63 characters or fewer",
|
||||||
|
Self::Reserved => "subdomain is reserved",
|
||||||
|
Self::EdgeHyphen => "subdomain cannot start or end with a hyphen",
|
||||||
|
Self::InvalidCharacters => {
|
||||||
|
"subdomain may only contain lowercase letters, numbers, and hyphens"
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
|
||||||
|
enum RelayValidationError {
|
||||||
|
InvalidPlan,
|
||||||
|
PremiumFeature,
|
||||||
|
Subdomain(SubdomainValidationError),
|
||||||
|
}
|
||||||
|
|
||||||
|
impl RelayValidationError {
|
||||||
|
fn code(self) -> &'static str {
|
||||||
|
match self {
|
||||||
|
Self::InvalidPlan => "invalid-plan",
|
||||||
|
Self::PremiumFeature => "premium-feature",
|
||||||
|
Self::Subdomain(reason) => reason.code(),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn message(self) -> &'static str {
|
||||||
|
match self {
|
||||||
|
Self::InvalidPlan => "plan not found",
|
||||||
|
Self::PremiumFeature => "feature requires a paid plan",
|
||||||
|
Self::Subdomain(reason) => reason.message(),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
impl From<SubdomainValidationError> for RelayValidationError {
|
||||||
|
fn from(value: SubdomainValidationError) -> Self {
|
||||||
|
Self::Subdomain(value)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn validate_subdomain_label(subdomain: &str) -> std::result::Result<(), SubdomainValidationError> {
|
||||||
|
if subdomain.is_empty() {
|
||||||
|
return Err(SubdomainValidationError::Empty);
|
||||||
|
}
|
||||||
|
if subdomain.len() > SUBDOMAIN_LABEL_MAX_LEN {
|
||||||
|
return Err(SubdomainValidationError::TooLong);
|
||||||
|
}
|
||||||
|
if subdomain.starts_with('-') || subdomain.ends_with('-') {
|
||||||
|
return Err(SubdomainValidationError::EdgeHyphen);
|
||||||
|
}
|
||||||
|
if RESERVED_SUBDOMAIN_LABELS.contains(&subdomain) {
|
||||||
|
return Err(SubdomainValidationError::Reserved);
|
||||||
|
}
|
||||||
|
if !subdomain
|
||||||
|
.chars()
|
||||||
|
.all(|c| c.is_ascii_lowercase() || c.is_ascii_digit() || c == '-')
|
||||||
|
{
|
||||||
|
return Err(SubdomainValidationError::InvalidCharacters);
|
||||||
|
}
|
||||||
|
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
fn ok<T: Serialize>(status: StatusCode, data: T) -> Response {
|
fn ok<T: Serialize>(status: StatusCode, data: T) -> Response {
|
||||||
(status, Json(OkResponse { data, code: "ok" })).into_response()
|
(status, Json(OkResponse { data, code: "ok" })).into_response()
|
||||||
}
|
}
|
||||||
@@ -316,6 +400,14 @@ fn parse_bool_default(value: i64, default: i64) -> i64 {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
fn relay_validation_error_response(error: RelayValidationError) -> Response {
|
||||||
|
err(
|
||||||
|
StatusCode::UNPROCESSABLE_ENTITY,
|
||||||
|
error.code(),
|
||||||
|
error.message(),
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
fn map_unique_error(err: &anyhow::Error) -> Option<&'static str> {
|
fn map_unique_error(err: &anyhow::Error) -> Option<&'static str> {
|
||||||
let sqlx_err = err.downcast_ref::<sqlx::Error>()?;
|
let sqlx_err = err.downcast_ref::<sqlx::Error>()?;
|
||||||
let sqlx::Error::Database(db_err) = sqlx_err else {
|
let sqlx::Error::Database(db_err) = sqlx_err else {
|
||||||
@@ -608,27 +700,9 @@ async fn create_relay(
|
|||||||
};
|
};
|
||||||
|
|
||||||
relay = match state.api.prepare_relay(relay) {
|
relay = match state.api.prepare_relay(relay) {
|
||||||
Err(e) if e.to_string() == "invalid-plan" => {
|
|
||||||
return Ok(err(
|
|
||||||
StatusCode::UNPROCESSABLE_ENTITY,
|
|
||||||
"invalid-plan",
|
|
||||||
"plan not found",
|
|
||||||
));
|
|
||||||
}
|
|
||||||
Ok(r) => r,
|
Ok(r) => r,
|
||||||
Err(e) if e.to_string() == "premium-feature" => {
|
Err(e) => {
|
||||||
return Ok(err(
|
return Ok(relay_validation_error_response(e));
|
||||||
StatusCode::UNPROCESSABLE_ENTITY,
|
|
||||||
"premium-feature",
|
|
||||||
"feature requires a paid plan",
|
|
||||||
));
|
|
||||||
}
|
|
||||||
Err(_) => {
|
|
||||||
return Ok(err(
|
|
||||||
StatusCode::UNPROCESSABLE_ENTITY,
|
|
||||||
"invalid-relay",
|
|
||||||
"relay validation failed",
|
|
||||||
));
|
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
@@ -712,27 +786,9 @@ async fn update_relay(
|
|||||||
}
|
}
|
||||||
|
|
||||||
relay = match state.api.prepare_relay(relay) {
|
relay = match state.api.prepare_relay(relay) {
|
||||||
Err(e) if e.to_string() == "invalid-plan" => {
|
|
||||||
return Ok(err(
|
|
||||||
StatusCode::UNPROCESSABLE_ENTITY,
|
|
||||||
"invalid-plan",
|
|
||||||
"plan not found",
|
|
||||||
));
|
|
||||||
}
|
|
||||||
Ok(r) => r,
|
Ok(r) => r,
|
||||||
Err(e) if e.to_string() == "premium-feature" => {
|
Err(e) => {
|
||||||
return Ok(err(
|
return Ok(relay_validation_error_response(e));
|
||||||
StatusCode::UNPROCESSABLE_ENTITY,
|
|
||||||
"premium-feature",
|
|
||||||
"feature requires a paid plan",
|
|
||||||
));
|
|
||||||
}
|
|
||||||
Err(_) => {
|
|
||||||
return Ok(err(
|
|
||||||
StatusCode::UNPROCESSABLE_ENTITY,
|
|
||||||
"invalid-relay",
|
|
||||||
"relay validation failed",
|
|
||||||
));
|
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
@@ -945,12 +1001,29 @@ async fn update_tenant(
|
|||||||
state.api.require_admin_or_tenant(&auth, &pubkey)?;
|
state.api.require_admin_or_tenant(&auth, &pubkey)?;
|
||||||
let mut tenant = state.api.get_tenant_or_404(&pubkey).await?;
|
let mut tenant = state.api.get_tenant_or_404(&pubkey).await?;
|
||||||
|
|
||||||
|
let nwc_previously_empty = tenant.nwc_url.is_empty();
|
||||||
if let Some(nwc_url) = payload.nwc_url {
|
if let Some(nwc_url) = payload.nwc_url {
|
||||||
tenant.nwc_url = nwc_url;
|
tenant.nwc_url = nwc_url;
|
||||||
}
|
}
|
||||||
|
|
||||||
match state.api.command.update_tenant(&tenant).await {
|
match state.api.command.update_tenant(&tenant).await {
|
||||||
Ok(()) => Ok(ok(StatusCode::OK, tenant)),
|
Ok(()) => {
|
||||||
|
// When NWC is first connected, attempt to pay any outstanding open invoices.
|
||||||
|
if nwc_previously_empty && !tenant.nwc_url.is_empty() {
|
||||||
|
let billing = state.api.billing.clone();
|
||||||
|
let tenant_clone = tenant.clone();
|
||||||
|
tokio::spawn(async move {
|
||||||
|
if let Err(e) = billing.pay_outstanding_nwc_invoices(&tenant_clone).await {
|
||||||
|
tracing::error!(
|
||||||
|
error = %e,
|
||||||
|
pubkey = %tenant_clone.pubkey,
|
||||||
|
"pay_outstanding_nwc_invoices failed after NWC setup"
|
||||||
|
);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
Ok(ok(StatusCode::OK, tenant))
|
||||||
|
}
|
||||||
Err(e) => Ok(err(
|
Err(e) => Ok(err(
|
||||||
StatusCode::INTERNAL_SERVER_ERROR,
|
StatusCode::INTERNAL_SERVER_ERROR,
|
||||||
"internal",
|
"internal",
|
||||||
|
|||||||
+254
-2
@@ -167,6 +167,8 @@ impl Billing {
|
|||||||
self.command
|
self.command
|
||||||
.delete_relay_subscription_item(&relay.id)
|
.delete_relay_subscription_item(&relay.id)
|
||||||
.await?;
|
.await?;
|
||||||
|
self.validate_downgrade_proration(&tenant, "free-plan-downgrade")
|
||||||
|
.await;
|
||||||
}
|
}
|
||||||
self.cleanup_empty_subscription(&tenant.pubkey).await?;
|
self.cleanup_empty_subscription(&tenant.pubkey).await?;
|
||||||
return Ok(());
|
return Ok(());
|
||||||
@@ -206,8 +208,28 @@ impl Billing {
|
|||||||
// Sync the subscription item: create or update
|
// Sync the subscription item: create or update
|
||||||
let subscription_id = tenant.stripe_subscription_id.as_ref().unwrap();
|
let subscription_id = tenant.stripe_subscription_id.as_ref().unwrap();
|
||||||
let item_id = if let Some(ref existing_item_id) = relay.stripe_subscription_item_id {
|
let item_id = if let Some(ref existing_item_id) = relay.stripe_subscription_item_id {
|
||||||
self.stripe_update_subscription_item(existing_item_id, stripe_price_id)
|
let is_downgrade = self
|
||||||
.await?
|
.is_subscription_item_downgrade(existing_item_id, plan.amount)
|
||||||
|
.await
|
||||||
|
.unwrap_or_else(|error| {
|
||||||
|
tracing::warn!(
|
||||||
|
error = %error,
|
||||||
|
relay_id = %relay.id,
|
||||||
|
"failed to determine relay plan downgrade direction"
|
||||||
|
);
|
||||||
|
false
|
||||||
|
});
|
||||||
|
|
||||||
|
let updated_item_id = self
|
||||||
|
.stripe_update_subscription_item(existing_item_id, stripe_price_id)
|
||||||
|
.await?;
|
||||||
|
|
||||||
|
if is_downgrade {
|
||||||
|
self.validate_downgrade_proration(&tenant, "paid-plan-downgrade")
|
||||||
|
.await;
|
||||||
|
}
|
||||||
|
|
||||||
|
updated_item_id
|
||||||
} else {
|
} else {
|
||||||
self.stripe_create_subscription_item(subscription_id, stripe_price_id)
|
self.stripe_create_subscription_item(subscription_id, stripe_price_id)
|
||||||
.await?
|
.await?
|
||||||
@@ -275,6 +297,10 @@ impl Billing {
|
|||||||
let customer = obj["customer"].as_str().unwrap_or_default();
|
let customer = obj["customer"].as_str().unwrap_or_default();
|
||||||
self.handle_subscription_deleted(customer).await?;
|
self.handle_subscription_deleted(customer).await?;
|
||||||
}
|
}
|
||||||
|
"payment_method.attached" => {
|
||||||
|
let customer = obj["customer"].as_str().unwrap_or_default();
|
||||||
|
self.handle_payment_method_attached(customer).await?;
|
||||||
|
}
|
||||||
_ => {}
|
_ => {}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -492,6 +518,103 @@ impl Billing {
|
|||||||
Ok(())
|
Ok(())
|
||||||
}
|
}
|
||||||
|
|
||||||
|
async fn handle_payment_method_attached(&self, stripe_customer_id: &str) -> Result<()> {
|
||||||
|
if stripe_customer_id.is_empty() {
|
||||||
|
return Ok(());
|
||||||
|
}
|
||||||
|
|
||||||
|
let Some(tenant) = self
|
||||||
|
.query
|
||||||
|
.get_tenant_by_stripe_customer_id(stripe_customer_id)
|
||||||
|
.await?
|
||||||
|
else {
|
||||||
|
return Ok(());
|
||||||
|
};
|
||||||
|
|
||||||
|
self.pay_outstanding_card_invoices(&tenant).await?;
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
|
async fn is_subscription_item_downgrade(
|
||||||
|
&self,
|
||||||
|
item_id: &str,
|
||||||
|
next_plan_amount: i64,
|
||||||
|
) -> Result<bool> {
|
||||||
|
let Some(current_price_id) = self.stripe_get_subscription_item_price_id(item_id).await?
|
||||||
|
else {
|
||||||
|
return Ok(false);
|
||||||
|
};
|
||||||
|
|
||||||
|
let Some(current_plan_amount) = Self::plan_amount_from_price_id(¤t_price_id) else {
|
||||||
|
return Ok(false);
|
||||||
|
};
|
||||||
|
|
||||||
|
Ok(next_plan_amount < current_plan_amount)
|
||||||
|
}
|
||||||
|
|
||||||
|
fn plan_amount_from_price_id(price_id: &str) -> Option<i64> {
|
||||||
|
Query::list_plans().into_iter().find_map(|plan| {
|
||||||
|
if plan.stripe_price_id.as_deref() == Some(price_id) {
|
||||||
|
Some(plan.amount)
|
||||||
|
} else {
|
||||||
|
None
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
async fn validate_downgrade_proration(&self, tenant: &crate::models::Tenant, context: &str) {
|
||||||
|
match self
|
||||||
|
.stripe_preview_upcoming_invoice(
|
||||||
|
&tenant.stripe_customer_id,
|
||||||
|
tenant.stripe_subscription_id.as_deref(),
|
||||||
|
)
|
||||||
|
.await
|
||||||
|
{
|
||||||
|
Ok(upcoming) => {
|
||||||
|
let lines = upcoming["lines"]["data"]
|
||||||
|
.as_array()
|
||||||
|
.cloned()
|
||||||
|
.unwrap_or_default();
|
||||||
|
let proration_lines = lines
|
||||||
|
.iter()
|
||||||
|
.filter(|line| line["proration"].as_bool().unwrap_or(false))
|
||||||
|
.count();
|
||||||
|
let amount_due = upcoming["amount_due"]
|
||||||
|
.as_i64()
|
||||||
|
.unwrap_or_else(|| upcoming["total"].as_i64().unwrap_or(0));
|
||||||
|
let currency = upcoming["currency"].as_str().unwrap_or("usd");
|
||||||
|
let preview_id = upcoming["id"].as_str().unwrap_or_default();
|
||||||
|
|
||||||
|
tracing::info!(
|
||||||
|
tenant_pubkey = %tenant.pubkey,
|
||||||
|
stripe_customer_id = %tenant.stripe_customer_id,
|
||||||
|
context,
|
||||||
|
preview_id,
|
||||||
|
proration_lines,
|
||||||
|
amount_due,
|
||||||
|
currency,
|
||||||
|
"validated Stripe proration preview for downgrade"
|
||||||
|
);
|
||||||
|
|
||||||
|
if proration_lines == 0 {
|
||||||
|
tracing::warn!(
|
||||||
|
tenant_pubkey = %tenant.pubkey,
|
||||||
|
context,
|
||||||
|
"downgrade proration preview has no proration lines; verify in Stripe dashboard"
|
||||||
|
);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
Err(error) => {
|
||||||
|
tracing::warn!(
|
||||||
|
error = %error,
|
||||||
|
tenant_pubkey = %tenant.pubkey,
|
||||||
|
context,
|
||||||
|
"failed to fetch downgrade proration preview"
|
||||||
|
);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
// --- Public API helpers ---
|
// --- Public API helpers ---
|
||||||
|
|
||||||
pub async fn get_invoice_with_tenant(
|
pub async fn get_invoice_with_tenant(
|
||||||
@@ -599,6 +722,93 @@ impl Billing {
|
|||||||
Ok(invoice_response.invoice)
|
Ok(invoice_response.invoice)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
pub async fn pay_outstanding_nwc_invoices(&self, tenant: &crate::models::Tenant) -> Result<()> {
|
||||||
|
if tenant.nwc_url.is_empty() {
|
||||||
|
return Ok(());
|
||||||
|
}
|
||||||
|
|
||||||
|
let invoices = self
|
||||||
|
.stripe_list_invoices(&tenant.stripe_customer_id)
|
||||||
|
.await?;
|
||||||
|
let invoices_arr = invoices.as_array().cloned().unwrap_or_default();
|
||||||
|
|
||||||
|
for invoice in &invoices_arr {
|
||||||
|
let status = invoice["status"].as_str().unwrap_or_default();
|
||||||
|
let amount_due = invoice["amount_due"].as_i64().unwrap_or(0);
|
||||||
|
let invoice_id = invoice["id"].as_str().unwrap_or_default();
|
||||||
|
let currency = invoice["currency"].as_str().unwrap_or("usd");
|
||||||
|
|
||||||
|
if status != "open" || amount_due == 0 || invoice_id.is_empty() {
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
match self
|
||||||
|
.nwc_pay_invoice(amount_due, currency, &tenant.nwc_url)
|
||||||
|
.await
|
||||||
|
{
|
||||||
|
Ok(()) => {
|
||||||
|
if let Err(e) = self.stripe_pay_invoice_out_of_band(invoice_id).await {
|
||||||
|
tracing::error!(
|
||||||
|
error = %e,
|
||||||
|
invoice_id,
|
||||||
|
"failed to mark invoice paid out of band"
|
||||||
|
);
|
||||||
|
} else {
|
||||||
|
let _ = self.command.clear_tenant_nwc_error(&tenant.pubkey).await;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
Err(e) => {
|
||||||
|
let error_msg = format!("{e}");
|
||||||
|
tracing::error!(
|
||||||
|
error = %e,
|
||||||
|
invoice_id,
|
||||||
|
"nwc payment failed for outstanding invoice"
|
||||||
|
);
|
||||||
|
let _ = self
|
||||||
|
.command
|
||||||
|
.set_tenant_nwc_error(&tenant.pubkey, &error_msg)
|
||||||
|
.await;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
|
async fn pay_outstanding_card_invoices(&self, tenant: &crate::models::Tenant) -> Result<()> {
|
||||||
|
if !self
|
||||||
|
.stripe_has_payment_method(&tenant.stripe_customer_id)
|
||||||
|
.await?
|
||||||
|
{
|
||||||
|
return Ok(());
|
||||||
|
}
|
||||||
|
|
||||||
|
let invoices = self
|
||||||
|
.stripe_list_invoices(&tenant.stripe_customer_id)
|
||||||
|
.await?;
|
||||||
|
let invoices_arr = invoices.as_array().cloned().unwrap_or_default();
|
||||||
|
|
||||||
|
for invoice in &invoices_arr {
|
||||||
|
let status = invoice["status"].as_str().unwrap_or_default();
|
||||||
|
let amount_due = invoice["amount_due"].as_i64().unwrap_or(0);
|
||||||
|
let invoice_id = invoice["id"].as_str().unwrap_or_default();
|
||||||
|
|
||||||
|
if status != "open" || amount_due == 0 || invoice_id.is_empty() {
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
if let Err(error) = self.stripe_pay_invoice(invoice_id).await {
|
||||||
|
tracing::error!(
|
||||||
|
error = %error,
|
||||||
|
invoice_id,
|
||||||
|
"failed to retry card payment for outstanding invoice"
|
||||||
|
);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
pub async fn stripe_create_portal_session(&self, customer_id: &str) -> Result<String> {
|
pub async fn stripe_create_portal_session(&self, customer_id: &str) -> Result<String> {
|
||||||
let resp = self
|
let resp = self
|
||||||
.http
|
.http
|
||||||
@@ -715,6 +925,48 @@ impl Billing {
|
|||||||
Ok(())
|
Ok(())
|
||||||
}
|
}
|
||||||
|
|
||||||
|
async fn stripe_pay_invoice(&self, invoice_id: &str) -> Result<()> {
|
||||||
|
self.http
|
||||||
|
.post(format!("{STRIPE_API}/invoices/{invoice_id}/pay"))
|
||||||
|
.bearer_auth(&self.stripe_secret_key)
|
||||||
|
.send()
|
||||||
|
.await?
|
||||||
|
.error_for_status()?;
|
||||||
|
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
|
async fn stripe_get_subscription_item_price_id(&self, item_id: &str) -> Result<Option<String>> {
|
||||||
|
let resp = self
|
||||||
|
.http
|
||||||
|
.get(format!("{STRIPE_API}/subscription_items/{item_id}"))
|
||||||
|
.bearer_auth(&self.stripe_secret_key)
|
||||||
|
.send()
|
||||||
|
.await?;
|
||||||
|
|
||||||
|
let body: serde_json::Value = resp.error_for_status()?.json().await?;
|
||||||
|
Ok(body["price"]["id"].as_str().map(ToString::to_string))
|
||||||
|
}
|
||||||
|
|
||||||
|
async fn stripe_preview_upcoming_invoice(
|
||||||
|
&self,
|
||||||
|
customer_id: &str,
|
||||||
|
subscription_id: Option<&str>,
|
||||||
|
) -> Result<serde_json::Value> {
|
||||||
|
let mut req = self
|
||||||
|
.http
|
||||||
|
.get(format!("{STRIPE_API}/invoices/upcoming"))
|
||||||
|
.bearer_auth(&self.stripe_secret_key)
|
||||||
|
.query(&[("customer", customer_id)]);
|
||||||
|
|
||||||
|
if let Some(subscription_id) = subscription_id {
|
||||||
|
req = req.query(&[("subscription", subscription_id)]);
|
||||||
|
}
|
||||||
|
|
||||||
|
let body: serde_json::Value = req.send().await?.error_for_status()?.json().await?;
|
||||||
|
Ok(body)
|
||||||
|
}
|
||||||
|
|
||||||
async fn stripe_pay_invoice_out_of_band(&self, invoice_id: &str) -> Result<()> {
|
async fn stripe_pay_invoice_out_of_band(&self, invoice_id: &str) -> Result<()> {
|
||||||
self.http
|
self.http
|
||||||
.post(format!("{STRIPE_API}/invoices/{invoice_id}/pay"))
|
.post(format!("{STRIPE_API}/invoices/{invoice_id}/pay"))
|
||||||
|
|||||||
@@ -0,0 +1,151 @@
|
|||||||
|
import { For, Show, createEffect, createSignal } from "solid-js"
|
||||||
|
import Modal from "@/components/Modal"
|
||||||
|
|
||||||
|
type ConfirmDialogProps = {
|
||||||
|
open: boolean
|
||||||
|
title: string
|
||||||
|
description: string
|
||||||
|
/** Optional bullet points shown in a warning box below the description */
|
||||||
|
details?: string[]
|
||||||
|
confirmLabel: string
|
||||||
|
busyLabel?: string
|
||||||
|
busy?: boolean
|
||||||
|
tone?: "danger" | "primary"
|
||||||
|
onConfirm: () => void | Promise<void>
|
||||||
|
onClose: () => void
|
||||||
|
}
|
||||||
|
|
||||||
|
const TONE_STYLES: Record<NonNullable<ConfirmDialogProps["tone"]>, string> = {
|
||||||
|
danger: "bg-red-600 text-white hover:bg-red-700",
|
||||||
|
primary: "bg-blue-600 text-white hover:bg-blue-700",
|
||||||
|
}
|
||||||
|
|
||||||
|
const DETAIL_BOX_STYLES: Record<NonNullable<ConfirmDialogProps["tone"]>, string> = {
|
||||||
|
danger: "border-amber-200 bg-amber-50 text-amber-800",
|
||||||
|
primary: "border-blue-200 bg-blue-50 text-blue-800",
|
||||||
|
}
|
||||||
|
|
||||||
|
type ConfirmDialogSnapshot = {
|
||||||
|
title: string
|
||||||
|
description: string
|
||||||
|
details?: string[]
|
||||||
|
confirmLabel: string
|
||||||
|
busyLabel?: string
|
||||||
|
busy: boolean
|
||||||
|
tone: NonNullable<ConfirmDialogProps["tone"]>
|
||||||
|
}
|
||||||
|
|
||||||
|
export default function ConfirmDialog(props: ConfirmDialogProps) {
|
||||||
|
const [snapshot, setSnapshot] = createSignal<ConfirmDialogSnapshot>({
|
||||||
|
title: props.title,
|
||||||
|
description: props.description,
|
||||||
|
details: props.details ? [...props.details] : undefined,
|
||||||
|
confirmLabel: props.confirmLabel,
|
||||||
|
busyLabel: props.busyLabel,
|
||||||
|
busy: props.busy ?? false,
|
||||||
|
tone: props.tone ?? "primary",
|
||||||
|
})
|
||||||
|
|
||||||
|
createEffect(() => {
|
||||||
|
if (!props.open) return
|
||||||
|
|
||||||
|
setSnapshot({
|
||||||
|
title: props.title,
|
||||||
|
description: props.description,
|
||||||
|
details: props.details ? [...props.details] : undefined,
|
||||||
|
confirmLabel: props.confirmLabel,
|
||||||
|
busyLabel: props.busyLabel,
|
||||||
|
busy: props.busy ?? false,
|
||||||
|
tone: props.tone ?? "primary",
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
|
const content = () => props.open
|
||||||
|
? {
|
||||||
|
title: props.title,
|
||||||
|
description: props.description,
|
||||||
|
details: props.details,
|
||||||
|
confirmLabel: props.confirmLabel,
|
||||||
|
busyLabel: props.busyLabel,
|
||||||
|
busy: props.busy ?? false,
|
||||||
|
tone: props.tone ?? "primary",
|
||||||
|
}
|
||||||
|
: snapshot()
|
||||||
|
const tone = () => content().tone
|
||||||
|
const confirmText = () => content().busy ? (content().busyLabel ?? content().confirmLabel) : content().confirmLabel
|
||||||
|
|
||||||
|
function handleClose() {
|
||||||
|
if (props.busy) return
|
||||||
|
props.onClose()
|
||||||
|
}
|
||||||
|
|
||||||
|
function handleConfirm() {
|
||||||
|
if (props.busy) return
|
||||||
|
void props.onConfirm()
|
||||||
|
}
|
||||||
|
|
||||||
|
return (
|
||||||
|
<Modal
|
||||||
|
open={props.open}
|
||||||
|
onClose={handleClose}
|
||||||
|
wrapperClass="fixed inset-0 z-50 flex items-center justify-center bg-black/50 p-4"
|
||||||
|
panelClass="w-full max-w-md rounded-2xl bg-white shadow-xl overflow-hidden"
|
||||||
|
>
|
||||||
|
<div class="px-6 pt-6 pb-4 border-b border-gray-100">
|
||||||
|
<div class="flex items-start justify-between gap-3">
|
||||||
|
<div>
|
||||||
|
<h2 class="text-lg font-semibold text-gray-900">{content().title}</h2>
|
||||||
|
</div>
|
||||||
|
<button
|
||||||
|
type="button"
|
||||||
|
onClick={handleClose}
|
||||||
|
disabled={content().busy}
|
||||||
|
class="shrink-0 rounded p-1 text-gray-400 hover:bg-gray-100 hover:text-gray-700 disabled:cursor-not-allowed disabled:opacity-50"
|
||||||
|
aria-label="Close"
|
||||||
|
>
|
||||||
|
<svg class="w-5 h-5" viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="2" stroke-linecap="round" stroke-linejoin="round">
|
||||||
|
<path d="M18 6L6 18M6 6l12 12" />
|
||||||
|
</svg>
|
||||||
|
</button>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<div class="px-6 py-4">
|
||||||
|
<div class="space-y-3 text-left">
|
||||||
|
<p class="text-sm text-gray-600">{content().description}</p>
|
||||||
|
<Show when={content().details && content().details!.length > 0}>
|
||||||
|
<ul class={`w-full rounded-lg border px-4 py-3 space-y-1.5 ${DETAIL_BOX_STYLES[tone()]}`}>
|
||||||
|
<For each={content().details}>
|
||||||
|
{(item) => (
|
||||||
|
<li class="flex items-start gap-2 text-sm">
|
||||||
|
<span class="mt-0.5 shrink-0 select-none">•</span>
|
||||||
|
<span>{item}</span>
|
||||||
|
</li>
|
||||||
|
)}
|
||||||
|
</For>
|
||||||
|
</ul>
|
||||||
|
</Show>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<div class="px-6 py-4 flex justify-end gap-3 border-t border-gray-100">
|
||||||
|
<button
|
||||||
|
type="button"
|
||||||
|
onClick={handleClose}
|
||||||
|
disabled={content().busy}
|
||||||
|
class="rounded-lg border border-gray-300 px-4 py-2 text-sm text-gray-700 transition-colors hover:bg-gray-50 disabled:cursor-not-allowed disabled:opacity-50"
|
||||||
|
>
|
||||||
|
Cancel
|
||||||
|
</button>
|
||||||
|
<button
|
||||||
|
type="button"
|
||||||
|
onClick={handleConfirm}
|
||||||
|
disabled={content().busy}
|
||||||
|
class={`rounded-lg px-4 py-2 text-sm font-medium transition-colors disabled:cursor-not-allowed disabled:opacity-50 ${TONE_STYLES[tone()]}`}
|
||||||
|
>
|
||||||
|
{confirmText()}
|
||||||
|
</button>
|
||||||
|
</div>
|
||||||
|
</Modal>
|
||||||
|
)
|
||||||
|
}
|
||||||
@@ -3,7 +3,6 @@ import QRCode from "qrcode"
|
|||||||
import Modal from "@/components/Modal"
|
import Modal from "@/components/Modal"
|
||||||
import PaymentSetup from "@/components/PaymentSetup"
|
import PaymentSetup from "@/components/PaymentSetup"
|
||||||
import { getInvoice, getInvoiceBolt11 } from "@/lib/api"
|
import { getInvoice, getInvoiceBolt11 } from "@/lib/api"
|
||||||
import { tenantNeedsPaymentSetup } from "@/lib/hooks"
|
|
||||||
|
|
||||||
type PayStatus = "idle" | "loading" | "success" | "error"
|
type PayStatus = "idle" | "loading" | "success" | "error"
|
||||||
type Bolt11Status = "idle" | "loading" | "ready" | "error"
|
type Bolt11Status = "idle" | "loading" | "ready" | "error"
|
||||||
@@ -26,8 +25,8 @@ export default function PaymentDialog(props: PaymentDialogProps) {
|
|||||||
const [bolt11Error, setBolt11Error] = createSignal("")
|
const [bolt11Error, setBolt11Error] = createSignal("")
|
||||||
const [payStatus, setPayStatus] = createSignal<PayStatus>("idle")
|
const [payStatus, setPayStatus] = createSignal<PayStatus>("idle")
|
||||||
const [payError, setPayError] = createSignal("")
|
const [payError, setPayError] = createSignal("")
|
||||||
const [showSetup, setShowSetup] = createSignal(false)
|
|
||||||
const [showPaymentSetup, setShowPaymentSetup] = createSignal(false)
|
const [showPaymentSetup, setShowPaymentSetup] = createSignal(false)
|
||||||
|
const [setupSaved, setSetupSaved] = createSignal(false)
|
||||||
|
|
||||||
async function loadBolt11() {
|
async function loadBolt11() {
|
||||||
if (!props.invoice.id) return
|
if (!props.invoice.id) return
|
||||||
@@ -63,7 +62,6 @@ export default function PaymentDialog(props: PaymentDialogProps) {
|
|||||||
const invoice = await getInvoice(props.invoice.id)
|
const invoice = await getInvoice(props.invoice.id)
|
||||||
if (invoice.status === "paid") {
|
if (invoice.status === "paid") {
|
||||||
setPayStatus("success")
|
setPayStatus("success")
|
||||||
tenantNeedsPaymentSetup().then(needs => setShowSetup(needs)).catch(() => {})
|
|
||||||
} else {
|
} else {
|
||||||
setPayStatus("error")
|
setPayStatus("error")
|
||||||
setPayError("Payment not yet confirmed. Please try again after sending.")
|
setPayError("Payment not yet confirmed. Please try again after sending.")
|
||||||
@@ -81,7 +79,6 @@ export default function PaymentDialog(props: PaymentDialogProps) {
|
|||||||
setBolt11Error("")
|
setBolt11Error("")
|
||||||
setBolt11("")
|
setBolt11("")
|
||||||
setQrDataUrl("")
|
setQrDataUrl("")
|
||||||
setShowSetup(false)
|
|
||||||
props.onClose()
|
props.onClose()
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -160,6 +157,15 @@ export default function PaymentDialog(props: PaymentDialogProps) {
|
|||||||
</button>
|
</button>
|
||||||
</div>
|
</div>
|
||||||
</Show>
|
</Show>
|
||||||
|
<div class="text-center pt-1">
|
||||||
|
<button
|
||||||
|
type="button"
|
||||||
|
onClick={() => setShowPaymentSetup(true)}
|
||||||
|
class="text-sm text-blue-600 hover:text-blue-700"
|
||||||
|
>
|
||||||
|
Set up payment method instead
|
||||||
|
</button>
|
||||||
|
</div>
|
||||||
</Show>
|
</Show>
|
||||||
</div>
|
</div>
|
||||||
}
|
}
|
||||||
@@ -172,15 +178,13 @@ export default function PaymentDialog(props: PaymentDialogProps) {
|
|||||||
</div>
|
</div>
|
||||||
<p class="text-sm font-medium text-gray-900">Payment confirmed!</p>
|
<p class="text-sm font-medium text-gray-900">Payment confirmed!</p>
|
||||||
<p class="text-xs text-gray-500">Thank you. Your account is up to date.</p>
|
<p class="text-xs text-gray-500">Thank you. Your account is up to date.</p>
|
||||||
<Show when={showSetup()}>
|
<button
|
||||||
<button
|
type="button"
|
||||||
type="button"
|
onClick={() => setShowPaymentSetup(true)}
|
||||||
onClick={() => setShowPaymentSetup(true)}
|
class="mt-2 text-sm font-medium text-blue-600 hover:text-blue-700"
|
||||||
class="mt-2 text-sm font-medium text-blue-600 hover:text-blue-700"
|
>
|
||||||
>
|
Set up automatic payments
|
||||||
Set up automatic payments
|
</button>
|
||||||
</button>
|
|
||||||
</Show>
|
|
||||||
</div>
|
</div>
|
||||||
</Show>
|
</Show>
|
||||||
</div>
|
</div>
|
||||||
@@ -228,7 +232,14 @@ export default function PaymentDialog(props: PaymentDialogProps) {
|
|||||||
</Modal>
|
</Modal>
|
||||||
<PaymentSetup
|
<PaymentSetup
|
||||||
open={showPaymentSetup()}
|
open={showPaymentSetup()}
|
||||||
onClose={() => setShowPaymentSetup(false)}
|
onClose={() => {
|
||||||
|
setShowPaymentSetup(false)
|
||||||
|
if (setupSaved()) {
|
||||||
|
setSetupSaved(false)
|
||||||
|
props.onClose()
|
||||||
|
}
|
||||||
|
}}
|
||||||
|
onSaved={() => setSetupSaved(true)}
|
||||||
/>
|
/>
|
||||||
</>
|
</>
|
||||||
)
|
)
|
||||||
|
|||||||
@@ -9,6 +9,7 @@ type Tab = "nwc" | "card"
|
|||||||
type PaymentSetupProps = {
|
type PaymentSetupProps = {
|
||||||
open: boolean
|
open: boolean
|
||||||
onClose: () => void
|
onClose: () => void
|
||||||
|
onSaved?: () => void
|
||||||
}
|
}
|
||||||
|
|
||||||
export default function PaymentSetup(props: PaymentSetupProps) {
|
export default function PaymentSetup(props: PaymentSetupProps) {
|
||||||
@@ -27,6 +28,7 @@ export default function PaymentSetup(props: PaymentSetupProps) {
|
|||||||
try {
|
try {
|
||||||
await updateActiveTenant({ nwc_url: url })
|
await updateActiveTenant({ nwc_url: url })
|
||||||
setSaved(true)
|
setSaved(true)
|
||||||
|
props.onSaved?.()
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
setError(e instanceof Error ? e.message : "Failed to save wallet connection")
|
setError(e instanceof Error ? e.message : "Failed to save wallet connection")
|
||||||
} finally {
|
} finally {
|
||||||
@@ -64,7 +66,7 @@ export default function PaymentSetup(props: PaymentSetupProps) {
|
|||||||
<div class="flex items-start justify-between gap-3">
|
<div class="flex items-start justify-between gap-3">
|
||||||
<div>
|
<div>
|
||||||
<h2 class="text-lg font-semibold text-gray-900">Set Up Payments</h2>
|
<h2 class="text-lg font-semibold text-gray-900">Set Up Payments</h2>
|
||||||
<p class="text-sm text-gray-500 mt-1">Choose how you'd like to pay for your relay.</p>
|
<p class="text-sm text-gray-500 mt-1">Choose how you'd like to pay once invoices are issued for your relay.</p>
|
||||||
</div>
|
</div>
|
||||||
<button
|
<button
|
||||||
type="button"
|
type="button"
|
||||||
@@ -144,7 +146,7 @@ export default function PaymentSetup(props: PaymentSetupProps) {
|
|||||||
<line x1="1" y1="10" x2="23" y2="10" />
|
<line x1="1" y1="10" x2="23" y2="10" />
|
||||||
</svg>
|
</svg>
|
||||||
</div>
|
</div>
|
||||||
<p class="text-sm text-gray-600">Add a payment card via Stripe to enable automatic billing.</p>
|
<p class="text-sm text-gray-600">Add a payment card via Stripe to enable automatic billing. If an invoice is currently due, we will retry collection after card setup.</p>
|
||||||
<button
|
<button
|
||||||
type="button"
|
type="button"
|
||||||
onClick={openPortal}
|
onClick={openPortal}
|
||||||
|
|||||||
@@ -2,6 +2,7 @@ import { A } from "@solidjs/router"
|
|||||||
import { Show, createEffect, createSignal, onCleanup } from "solid-js"
|
import { Show, createEffect, createSignal, onCleanup } from "solid-js"
|
||||||
import type { Relay, PlanId } from "@/lib/api"
|
import type { Relay, PlanId } from "@/lib/api"
|
||||||
import menuDotsIcon from "@/assets/menu-dots-2.svg"
|
import menuDotsIcon from "@/assets/menu-dots-2.svg"
|
||||||
|
import ConfirmDialog from "@/components/ConfirmDialog"
|
||||||
import Field from "@/components/Field"
|
import Field from "@/components/Field"
|
||||||
import PricingTable from "@/components/PricingTable"
|
import PricingTable from "@/components/PricingTable"
|
||||||
import ToggleButton from "@/components/ToggleButton"
|
import ToggleButton from "@/components/ToggleButton"
|
||||||
@@ -51,8 +52,8 @@ type RelayDetailCardProps = {
|
|||||||
currentMembers?: number
|
currentMembers?: number
|
||||||
showTenant?: boolean
|
showTenant?: boolean
|
||||||
editHref?: string
|
editHref?: string
|
||||||
onDeactivate?: () => void
|
onDeactivate?: () => void | Promise<void>
|
||||||
onReactivate?: () => void
|
onReactivate?: () => void | Promise<void>
|
||||||
deactivating?: boolean
|
deactivating?: boolean
|
||||||
reactivating?: boolean
|
reactivating?: boolean
|
||||||
onTogglePublicJoin?: () => void
|
onTogglePublicJoin?: () => void
|
||||||
@@ -76,6 +77,7 @@ export default function RelayDetailCard(props: RelayDetailCardProps) {
|
|||||||
}
|
}
|
||||||
const [menuOpen, setMenuOpen] = createSignal(false)
|
const [menuOpen, setMenuOpen] = createSignal(false)
|
||||||
const [plan, setPlan] = createSignal<PlanId>(props.relay.plan)
|
const [plan, setPlan] = createSignal<PlanId>(props.relay.plan)
|
||||||
|
const [pendingAction, setPendingAction] = createSignal<"deactivate" | "reactivate" | null>(null)
|
||||||
|
|
||||||
let menuContainerRef: HTMLDivElement | undefined
|
let menuContainerRef: HTMLDivElement | undefined
|
||||||
|
|
||||||
@@ -86,6 +88,24 @@ export default function RelayDetailCard(props: RelayDetailCardProps) {
|
|||||||
}
|
}
|
||||||
const planLimited = () => (props.enforcePlanLimits ?? true) && r().plan === "free"
|
const planLimited = () => (props.enforcePlanLimits ?? true) && r().plan === "free"
|
||||||
const showPlanActions = () => props.showPlanActions ?? true
|
const showPlanActions = () => props.showPlanActions ?? true
|
||||||
|
const actionBusy = () => pendingAction() === "deactivate" ? !!props.deactivating : pendingAction() === "reactivate" ? !!props.reactivating : false
|
||||||
|
const relayLabel = () => r().info_name || r().subdomain
|
||||||
|
const confirmTitle = () => pendingAction() === "deactivate" ? "Deactivate relay?" : "Reactivate relay?"
|
||||||
|
const confirmDescription = () => pendingAction() === "deactivate"
|
||||||
|
? `${relayLabel()} will be taken offline immediately.`
|
||||||
|
: `${relayLabel()} will come back online and start accepting connections.`
|
||||||
|
const confirmDetails = () => pendingAction() === "deactivate"
|
||||||
|
? [
|
||||||
|
"All client connections will be dropped immediately.",
|
||||||
|
"Members will be unable to read from or publish to the relay.",
|
||||||
|
"Scheduled and automated tasks (billing, syncing) will be paused.",
|
||||||
|
"All relay data, settings, and members are preserved, nothing is deleted.",
|
||||||
|
"You can reactivate at any time from this page.",
|
||||||
|
]
|
||||||
|
: undefined
|
||||||
|
const confirmLabel = () => pendingAction() === "deactivate" ? "Yes, deactivate" : "Yes, reactivate"
|
||||||
|
const confirmBusyLabel = () => pendingAction() === "deactivate" ? "Deactivating..." : "Reactivating..."
|
||||||
|
const confirmTone = () => pendingAction() === "deactivate" ? "danger" : "primary"
|
||||||
|
|
||||||
async function changePlan(plan: PlanId) {
|
async function changePlan(plan: PlanId) {
|
||||||
setPlan(plan)
|
setPlan(plan)
|
||||||
@@ -97,6 +117,29 @@ export default function RelayDetailCard(props: RelayDetailCardProps) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
function openActionDialog(action: "deactivate" | "reactivate") {
|
||||||
|
setMenuOpen(false)
|
||||||
|
setPendingAction(action)
|
||||||
|
}
|
||||||
|
|
||||||
|
function closeActionDialog() {
|
||||||
|
if (actionBusy()) return
|
||||||
|
setPendingAction(null)
|
||||||
|
}
|
||||||
|
|
||||||
|
async function confirmAction() {
|
||||||
|
const action = pendingAction()
|
||||||
|
if (!action) return
|
||||||
|
|
||||||
|
if (action === "deactivate") {
|
||||||
|
await props.onDeactivate?.()
|
||||||
|
} else {
|
||||||
|
await props.onReactivate?.()
|
||||||
|
}
|
||||||
|
|
||||||
|
setPendingAction(null)
|
||||||
|
}
|
||||||
|
|
||||||
createEffect(() => {
|
createEffect(() => {
|
||||||
if (!menuOpen()) return
|
if (!menuOpen()) return
|
||||||
|
|
||||||
@@ -128,7 +171,7 @@ export default function RelayDetailCard(props: RelayDetailCardProps) {
|
|||||||
<div class="flex items-start justify-between gap-4">
|
<div class="flex items-start justify-between gap-4">
|
||||||
<div class="flex items-start gap-4 min-w-0">
|
<div class="flex items-start gap-4 min-w-0">
|
||||||
<Show when={r().info_icon}>
|
<Show when={r().info_icon}>
|
||||||
<img src={r().info_icon} alt="" class="w-14 h-14 rounded-xl object-cover flex-shrink-0 border border-gray-200" />
|
<img src={r().info_icon} alt="" class="w-14 h-14 rounded-xl object-cover shrink-0 border border-gray-200" />
|
||||||
</Show>
|
</Show>
|
||||||
<div class="min-w-0">
|
<div class="min-w-0">
|
||||||
<div class="flex items-center gap-3 flex-wrap">
|
<div class="flex items-center gap-3 flex-wrap">
|
||||||
@@ -148,7 +191,7 @@ export default function RelayDetailCard(props: RelayDetailCardProps) {
|
|||||||
</div>
|
</div>
|
||||||
|
|
||||||
<Show when={props.editHref && (props.onDeactivate || props.onReactivate)}>
|
<Show when={props.editHref && (props.onDeactivate || props.onReactivate)}>
|
||||||
<div class="relative flex-shrink-0" ref={menuContainerRef}>
|
<div class="relative shrink-0" ref={menuContainerRef}>
|
||||||
<button
|
<button
|
||||||
type="button"
|
type="button"
|
||||||
class="inline-flex h-9 w-9 items-center justify-center rounded-lg border border-gray-200 hover:bg-gray-50"
|
class="inline-flex h-9 w-9 items-center justify-center rounded-lg border border-gray-200 hover:bg-gray-50"
|
||||||
@@ -177,8 +220,7 @@ export default function RelayDetailCard(props: RelayDetailCardProps) {
|
|||||||
type="button"
|
type="button"
|
||||||
class="block w-full text-left px-3 py-2 text-sm text-red-600 hover:bg-red-50 disabled:opacity-50"
|
class="block w-full text-left px-3 py-2 text-sm text-red-600 hover:bg-red-50 disabled:opacity-50"
|
||||||
onClick={() => {
|
onClick={() => {
|
||||||
setMenuOpen(false)
|
openActionDialog("deactivate")
|
||||||
props.onDeactivate?.()
|
|
||||||
}}
|
}}
|
||||||
disabled={props.deactivating}
|
disabled={props.deactivating}
|
||||||
>
|
>
|
||||||
@@ -190,8 +232,7 @@ export default function RelayDetailCard(props: RelayDetailCardProps) {
|
|||||||
type="button"
|
type="button"
|
||||||
class="block w-full text-left px-3 py-2 text-sm text-blue-600 hover:bg-blue-50 disabled:opacity-50"
|
class="block w-full text-left px-3 py-2 text-sm text-blue-600 hover:bg-blue-50 disabled:opacity-50"
|
||||||
onClick={() => {
|
onClick={() => {
|
||||||
setMenuOpen(false)
|
openActionDialog("reactivate")
|
||||||
props.onReactivate?.()
|
|
||||||
}}
|
}}
|
||||||
disabled={props.reactivating}
|
disabled={props.reactivating}
|
||||||
>
|
>
|
||||||
@@ -346,6 +387,19 @@ export default function RelayDetailCard(props: RelayDetailCardProps) {
|
|||||||
</Show>
|
</Show>
|
||||||
</DetailSection>
|
</DetailSection>
|
||||||
</Show>
|
</Show>
|
||||||
|
|
||||||
|
<ConfirmDialog
|
||||||
|
open={pendingAction() !== null}
|
||||||
|
title={confirmTitle()}
|
||||||
|
description={confirmDescription()}
|
||||||
|
details={confirmDetails()}
|
||||||
|
confirmLabel={confirmLabel()}
|
||||||
|
busyLabel={confirmBusyLabel()}
|
||||||
|
busy={actionBusy()}
|
||||||
|
tone={confirmTone()}
|
||||||
|
onConfirm={confirmAction}
|
||||||
|
onClose={closeActionDialog}
|
||||||
|
/>
|
||||||
</div>
|
</div>
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,6 +1,7 @@
|
|||||||
import { createEffect, createMemo, createSignal, For } from "solid-js"
|
import { createEffect, createMemo, createSignal, For } from "solid-js"
|
||||||
import type { Relay } from "@/lib/hooks"
|
import type { Relay } from "@/lib/hooks"
|
||||||
import { slugify } from "@/lib/slugify"
|
import { slugify } from "@/lib/slugify"
|
||||||
|
import { validateSubdomainLabel } from "@/lib/subdomain"
|
||||||
import { setToastMessage } from "@/components/Toast"
|
import { setToastMessage } from "@/components/Toast"
|
||||||
import { plans } from "@/lib/state"
|
import { plans } from "@/lib/state"
|
||||||
|
|
||||||
@@ -31,6 +32,12 @@ export default function RelayForm(props: RelayFormProps) {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
const subdomainError = validateSubdomainLabel(subdomain())
|
||||||
|
if (subdomainError) {
|
||||||
|
setToastMessage(subdomainError)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
setToastMessage("")
|
setToastMessage("")
|
||||||
setSubmitting(true)
|
setSubmitting(true)
|
||||||
|
|
||||||
|
|||||||
@@ -12,12 +12,14 @@ import {
|
|||||||
getTenant,
|
getTenant,
|
||||||
listRelayActivity,
|
listRelayActivity,
|
||||||
listRelays,
|
listRelays,
|
||||||
|
listTenantInvoices,
|
||||||
listTenantRelays,
|
listTenantRelays,
|
||||||
listTenants,
|
listTenants,
|
||||||
updateRelay,
|
updateRelay,
|
||||||
updateTenant,
|
updateTenant,
|
||||||
type Activity,
|
type Activity,
|
||||||
type CreateRelayInput,
|
type CreateRelayInput,
|
||||||
|
type Invoice,
|
||||||
type Relay,
|
type Relay,
|
||||||
type Tenant,
|
type Tenant,
|
||||||
type UpdateRelayInput,
|
type UpdateRelayInput,
|
||||||
@@ -137,6 +139,14 @@ export async function tenantNeedsPaymentSetup(): Promise<boolean> {
|
|||||||
return !tenant.nwc_url && !tenant.stripe_subscription_id
|
return !tenant.nwc_url && !tenant.stripe_subscription_id
|
||||||
}
|
}
|
||||||
|
|
||||||
|
export async function getLatestOpenInvoice(): Promise<Invoice | null> {
|
||||||
|
const invoices = await listTenantInvoices(account()!.pubkey)
|
||||||
|
const open = invoices
|
||||||
|
.filter(inv => inv.status === "open" && inv.amount_due > 0)
|
||||||
|
.sort((a, b) => b.period_start - a.period_start)
|
||||||
|
return open[0] ?? null
|
||||||
|
}
|
||||||
|
|
||||||
export async function getRelayMembers(url: string) {
|
export async function getRelayMembers(url: string) {
|
||||||
const management = new RelayManagement(new NostrRelay(url), account()!.signer)
|
const management = new RelayManagement(new NostrRelay(url), account()!.signer)
|
||||||
|
|
||||||
@@ -147,4 +157,4 @@ export async function getRelayMembers(url: string) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
export type { Activity, Relay, Tenant }
|
export type { Activity, Invoice, Relay, Tenant }
|
||||||
|
|||||||
@@ -0,0 +1,22 @@
|
|||||||
|
const SUBDOMAIN_LABEL_MAX_LEN = 63
|
||||||
|
const RESERVED_SUBDOMAIN_LABELS = new Set(["api", "admin"])
|
||||||
|
|
||||||
|
export function validateSubdomainLabel(subdomain: string): string | null {
|
||||||
|
if (subdomain.length === 0) {
|
||||||
|
return "subdomain is required"
|
||||||
|
}
|
||||||
|
if (subdomain.length > SUBDOMAIN_LABEL_MAX_LEN) {
|
||||||
|
return "subdomain must be 63 characters or fewer"
|
||||||
|
}
|
||||||
|
if (subdomain.startsWith("-") || subdomain.endsWith("-")) {
|
||||||
|
return "subdomain cannot start or end with a hyphen"
|
||||||
|
}
|
||||||
|
if (RESERVED_SUBDOMAIN_LABELS.has(subdomain)) {
|
||||||
|
return "subdomain is reserved"
|
||||||
|
}
|
||||||
|
if (!/^[a-z0-9-]+$/.test(subdomain)) {
|
||||||
|
return "subdomain may only contain lowercase letters, numbers, and hyphens"
|
||||||
|
}
|
||||||
|
|
||||||
|
return null
|
||||||
|
}
|
||||||
@@ -1,7 +1,7 @@
|
|||||||
import { createSignal } from "solid-js"
|
import { createSignal } from "solid-js"
|
||||||
import { updateRelayById, deactivateRelayById, reactivateRelayById, tenantNeedsPaymentSetup, type Relay } from "@/lib/hooks"
|
import { updateRelayById, deactivateRelayById, reactivateRelayById, getLatestOpenInvoice, type Relay } from "@/lib/hooks"
|
||||||
import { setToastMessage } from "@/components/Toast"
|
import { setToastMessage } from "@/components/Toast"
|
||||||
import type { PlanId } from "@/lib/api"
|
import type { Invoice, PlanId } from "@/lib/api"
|
||||||
|
|
||||||
function toBool(value: number | undefined, fallback: boolean): boolean {
|
function toBool(value: number | undefined, fallback: boolean): boolean {
|
||||||
if (value === 0) return false
|
if (value === 0) return false
|
||||||
@@ -30,7 +30,7 @@ export default function useRelayToggles(
|
|||||||
{ refetch, mutate }: RelayActions,
|
{ refetch, mutate }: RelayActions,
|
||||||
) {
|
) {
|
||||||
const [busy, setBusy] = createSignal(false)
|
const [busy, setBusy] = createSignal(false)
|
||||||
const [needsPaymentSetup, setNeedsPaymentSetup] = createSignal(false)
|
const [pendingInvoice, setPendingInvoice] = createSignal<Invoice | undefined>()
|
||||||
|
|
||||||
async function updateRelay(next: Relay, previous: Relay) {
|
async function updateRelay(next: Relay, previous: Relay) {
|
||||||
mutate(next)
|
mutate(next)
|
||||||
@@ -101,8 +101,8 @@ export default function useRelayToggles(
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (plan !== "free") {
|
if (plan !== "free") {
|
||||||
const needs = await tenantNeedsPaymentSetup()
|
const invoice = await getLatestOpenInvoice()
|
||||||
if (needs) setNeedsPaymentSetup(true)
|
if (invoice) setPendingInvoice(invoice)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -116,5 +116,5 @@ export default function useRelayToggles(
|
|||||||
onToggleLivekitSupport: () => toggle("livekit_enabled", relay()?.plan !== "free"),
|
onToggleLivekitSupport: () => toggle("livekit_enabled", relay()?.plan !== "free"),
|
||||||
}
|
}
|
||||||
|
|
||||||
return { busy, handleDeactivate, handleReactivate, handleUpdatePlan, needsPaymentSetup, clearNeedsPaymentSetup: () => setNeedsPaymentSetup(false), toggles }
|
return { busy, handleDeactivate, handleReactivate, handleUpdatePlan, pendingInvoice, clearPendingInvoice: () => setPendingInvoice(undefined), toggles }
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,14 +1,16 @@
|
|||||||
import { useParams } from "@solidjs/router"
|
import { useParams } from "@solidjs/router"
|
||||||
import { createMemo, createResource, Show } from "solid-js"
|
import { createMemo, createResource, createSignal, Show } from "solid-js"
|
||||||
import BackLink from "@/components/BackLink"
|
import BackLink from "@/components/BackLink"
|
||||||
import PageContainer from "@/components/PageContainer"
|
import PageContainer from "@/components/PageContainer"
|
||||||
|
import PaymentDialog from "@/components/PaymentDialog"
|
||||||
import PaymentSetup from "@/components/PaymentSetup"
|
import PaymentSetup from "@/components/PaymentSetup"
|
||||||
import RelayDetailCard from "@/components/RelayDetailCard"
|
import RelayDetailCard from "@/components/RelayDetailCard"
|
||||||
import ResourceState from "@/components/ResourceState"
|
import ResourceState from "@/components/ResourceState"
|
||||||
import useMinLoading from "@/components/useMinLoading"
|
import useMinLoading from "@/components/useMinLoading"
|
||||||
import ActivityFeed from "@/components/ActivityFeed"
|
import ActivityFeed from "@/components/ActivityFeed"
|
||||||
import { getRelayMembers, useRelay, useRelayActivity } from "@/lib/hooks"
|
import { getLatestOpenInvoice, getRelayMembers, useRelay, useRelayActivity, useTenant } from "@/lib/hooks"
|
||||||
import useRelayToggles from "@/lib/useRelayToggles"
|
import useRelayToggles from "@/lib/useRelayToggles"
|
||||||
|
import { plans } from "@/lib/state"
|
||||||
|
|
||||||
export default function RelayDetail() {
|
export default function RelayDetail() {
|
||||||
const params = useParams()
|
const params = useParams()
|
||||||
@@ -21,7 +23,32 @@ export default function RelayDetail() {
|
|||||||
const [members] = createResource(relayUrl, getRelayMembers)
|
const [members] = createResource(relayUrl, getRelayMembers)
|
||||||
const loading = useMinLoading(() => relay.loading && !relay())
|
const loading = useMinLoading(() => relay.loading && !relay())
|
||||||
const [activity] = useRelayActivity(relayId)
|
const [activity] = useRelayActivity(relayId)
|
||||||
const { busy, handleDeactivate, handleReactivate, handleUpdatePlan, needsPaymentSetup, clearNeedsPaymentSetup, toggles } = useRelayToggles(relayId, relay, { refetch, mutate })
|
const { busy, handleDeactivate, handleReactivate, handleUpdatePlan, pendingInvoice, clearPendingInvoice, toggles } = useRelayToggles(relayId, relay, { refetch, mutate })
|
||||||
|
|
||||||
|
const [tenant, { refetch: refetchTenant }] = useTenant()
|
||||||
|
const [paymentSetupOpen, setPaymentSetupOpen] = createSignal(false)
|
||||||
|
const [invoiceDialogOpen, setInvoiceDialogOpen] = createSignal(false)
|
||||||
|
const [paymentBannerDismissed, setPaymentBannerDismissed] = createSignal(false)
|
||||||
|
|
||||||
|
const isPaidRelay = createMemo(() => {
|
||||||
|
const r = relay()
|
||||||
|
if (!r) return false
|
||||||
|
const plan = plans().find(p => p.id === r.plan)
|
||||||
|
return !!(plan && plan.amount > 0)
|
||||||
|
})
|
||||||
|
|
||||||
|
const [openInvoice, { refetch: refetchOpenInvoice }] = createResource(
|
||||||
|
isPaidRelay,
|
||||||
|
async (paid) => paid ? getLatestOpenInvoice() : null
|
||||||
|
)
|
||||||
|
|
||||||
|
const showPaymentNudge = createMemo(() => {
|
||||||
|
if (paymentBannerDismissed()) return false
|
||||||
|
if (!isPaidRelay()) return false
|
||||||
|
const t = tenant()
|
||||||
|
if (!t) return false
|
||||||
|
return !t.nwc_url
|
||||||
|
})
|
||||||
|
|
||||||
return (
|
return (
|
||||||
<PageContainer>
|
<PageContainer>
|
||||||
@@ -30,6 +57,44 @@ export default function RelayDetail() {
|
|||||||
<Show when={!loading() && relay()}>
|
<Show when={!loading() && relay()}>
|
||||||
{(r) => (
|
{(r) => (
|
||||||
<div class="space-y-6 mb-6">
|
<div class="space-y-6 mb-6">
|
||||||
|
<Show when={showPaymentNudge()}>
|
||||||
|
<div class="rounded-lg border border-amber-200 bg-amber-50 p-4 flex items-start justify-between gap-4">
|
||||||
|
<div class="min-w-0">
|
||||||
|
<p class="text-sm font-medium text-amber-800">Payment setup recommended</p>
|
||||||
|
<p class="text-sm text-amber-700 mt-1">
|
||||||
|
This relay is on a paid plan. Invoices are due when your subscription starts. Set up NWC or Stripe for automatic payments, or pay open invoices via Lightning.
|
||||||
|
</p>
|
||||||
|
</div>
|
||||||
|
<div class="flex items-center gap-3 shrink-0">
|
||||||
|
<Show when={openInvoice()}>
|
||||||
|
<button
|
||||||
|
type="button"
|
||||||
|
onClick={() => setInvoiceDialogOpen(true)}
|
||||||
|
class="text-sm font-medium text-amber-800 underline hover:text-amber-900 whitespace-nowrap"
|
||||||
|
>
|
||||||
|
Pay invoice
|
||||||
|
</button>
|
||||||
|
</Show>
|
||||||
|
<button
|
||||||
|
type="button"
|
||||||
|
onClick={() => setPaymentSetupOpen(true)}
|
||||||
|
class="text-sm font-medium text-amber-800 underline hover:text-amber-900 whitespace-nowrap"
|
||||||
|
>
|
||||||
|
Set up payments
|
||||||
|
</button>
|
||||||
|
<button
|
||||||
|
type="button"
|
||||||
|
onClick={() => setPaymentBannerDismissed(true)}
|
||||||
|
aria-label="Dismiss"
|
||||||
|
class="text-amber-500 hover:text-amber-800 shrink-0"
|
||||||
|
>
|
||||||
|
<svg class="w-4 h-4" viewBox="0 0 24 24" fill="none" stroke="currentColor" stroke-width="2" stroke-linecap="round" stroke-linejoin="round">
|
||||||
|
<path d="M18 6L6 18M6 6l12 12" />
|
||||||
|
</svg>
|
||||||
|
</button>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
</Show>
|
||||||
<RelayDetailCard
|
<RelayDetailCard
|
||||||
relay={r()}
|
relay={r()}
|
||||||
currentMembers={members.length}
|
currentMembers={members.length}
|
||||||
@@ -45,9 +110,37 @@ export default function RelayDetail() {
|
|||||||
</div>
|
</div>
|
||||||
)}
|
)}
|
||||||
</Show>
|
</Show>
|
||||||
|
<Show when={pendingInvoice()}>
|
||||||
|
{(inv) => (
|
||||||
|
<PaymentDialog
|
||||||
|
invoice={inv()}
|
||||||
|
open={true}
|
||||||
|
onClose={() => {
|
||||||
|
clearPendingInvoice()
|
||||||
|
void refetchTenant()
|
||||||
|
void refetchOpenInvoice()
|
||||||
|
}}
|
||||||
|
/>
|
||||||
|
)}
|
||||||
|
</Show>
|
||||||
|
<Show when={openInvoice()}>
|
||||||
|
{(inv) => (
|
||||||
|
<PaymentDialog
|
||||||
|
invoice={inv()!}
|
||||||
|
open={invoiceDialogOpen()}
|
||||||
|
onClose={() => {
|
||||||
|
setInvoiceDialogOpen(false)
|
||||||
|
void refetchOpenInvoice()
|
||||||
|
}}
|
||||||
|
/>
|
||||||
|
)}
|
||||||
|
</Show>
|
||||||
<PaymentSetup
|
<PaymentSetup
|
||||||
open={needsPaymentSetup()}
|
open={paymentSetupOpen()}
|
||||||
onClose={clearNeedsPaymentSetup}
|
onClose={() => {
|
||||||
|
setPaymentSetupOpen(false)
|
||||||
|
void refetchTenant()
|
||||||
|
}}
|
||||||
/>
|
/>
|
||||||
</PageContainer>
|
</PageContainer>
|
||||||
)
|
)
|
||||||
|
|||||||
@@ -1,7 +1,6 @@
|
|||||||
import { useNavigate, useParams } from "@solidjs/router"
|
import { useNavigate, useParams } from "@solidjs/router"
|
||||||
import { Show } from "solid-js"
|
import { Show } from "solid-js"
|
||||||
import RelayForm, { type RelayFormValues } from "@/components/RelayForm"
|
import RelayForm, { type RelayFormValues } from "@/components/RelayForm"
|
||||||
import { slugify } from "@/lib/slugify"
|
|
||||||
import BackLink from "@/components/BackLink"
|
import BackLink from "@/components/BackLink"
|
||||||
import PageContainer from "@/components/PageContainer"
|
import PageContainer from "@/components/PageContainer"
|
||||||
import ResourceState from "@/components/ResourceState"
|
import ResourceState from "@/components/ResourceState"
|
||||||
@@ -18,7 +17,7 @@ export default function RelayEdit(props: { basePath?: string; title?: string })
|
|||||||
|
|
||||||
async function handleSubmit(values: RelayFormValues) {
|
async function handleSubmit(values: RelayFormValues) {
|
||||||
await updateRelayById(relayId(), {
|
await updateRelayById(relayId(), {
|
||||||
subdomain: slugify(values.subdomain),
|
subdomain: values.subdomain,
|
||||||
info_name: values.info_name.trim(),
|
info_name: values.info_name.trim(),
|
||||||
info_icon: values.info_icon.trim(),
|
info_icon: values.info_icon.trim(),
|
||||||
info_description: values.info_description.trim(),
|
info_description: values.info_description.trim(),
|
||||||
|
|||||||
@@ -1,14 +1,15 @@
|
|||||||
import { createSignal } from "solid-js"
|
import { createSignal, Show } from "solid-js"
|
||||||
import { useNavigate } from "@solidjs/router"
|
import { useNavigate } from "@solidjs/router"
|
||||||
import BackLink from "@/components/BackLink"
|
import BackLink from "@/components/BackLink"
|
||||||
import PageContainer from "@/components/PageContainer"
|
import PageContainer from "@/components/PageContainer"
|
||||||
import PaymentSetup from "@/components/PaymentSetup"
|
import PaymentDialog from "@/components/PaymentDialog"
|
||||||
import RelayForm, { type RelayFormValues } from "@/components/RelayForm"
|
import RelayForm, { type RelayFormValues } from "@/components/RelayForm"
|
||||||
import { createRelayForActiveTenant, tenantNeedsPaymentSetup } from "@/lib/hooks"
|
import { createRelayForActiveTenant, getLatestOpenInvoice } from "@/lib/hooks"
|
||||||
|
import type { Invoice } from "@/lib/api"
|
||||||
|
|
||||||
export default function RelayNew() {
|
export default function RelayNew() {
|
||||||
const navigate = useNavigate()
|
const navigate = useNavigate()
|
||||||
const [showPaymentSetup, setShowPaymentSetup] = createSignal(false)
|
const [pendingInvoice, setPendingInvoice] = createSignal<Invoice | undefined>()
|
||||||
let createdRelayId = ""
|
let createdRelayId = ""
|
||||||
|
|
||||||
async function handleSubmit(values: RelayFormValues) {
|
async function handleSubmit(values: RelayFormValues) {
|
||||||
@@ -16,9 +17,9 @@ export default function RelayNew() {
|
|||||||
createdRelayId = relay.id
|
createdRelayId = relay.id
|
||||||
|
|
||||||
if (values.plan !== "free") {
|
if (values.plan !== "free") {
|
||||||
const needs = await tenantNeedsPaymentSetup()
|
const invoice = await getLatestOpenInvoice()
|
||||||
if (needs) {
|
if (invoice) {
|
||||||
setShowPaymentSetup(true)
|
setPendingInvoice(invoice)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -27,7 +28,7 @@ export default function RelayNew() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
function handleDialogClose() {
|
function handleDialogClose() {
|
||||||
setShowPaymentSetup(false)
|
setPendingInvoice(undefined)
|
||||||
navigate(`/relays/${createdRelayId}`)
|
navigate(`/relays/${createdRelayId}`)
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -41,10 +42,15 @@ export default function RelayNew() {
|
|||||||
submitLabel="Create Relay"
|
submitLabel="Create Relay"
|
||||||
submittingLabel="Creating..."
|
submittingLabel="Creating..."
|
||||||
/>
|
/>
|
||||||
<PaymentSetup
|
<Show when={pendingInvoice()}>
|
||||||
open={showPaymentSetup()}
|
{(inv) => (
|
||||||
onClose={handleDialogClose}
|
<PaymentDialog
|
||||||
/>
|
invoice={inv()}
|
||||||
|
open={true}
|
||||||
|
onClose={handleDialogClose}
|
||||||
|
/>
|
||||||
|
)}
|
||||||
|
</Show>
|
||||||
</PageContainer>
|
</PageContainer>
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user