forked from coracle/caravel
Compare commits
2 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| c4aaed1452 | |||
| a79c43e17e |
@@ -151,7 +151,11 @@ impl Billing {
|
|||||||
return Ok(());
|
return Ok(());
|
||||||
}
|
}
|
||||||
|
|
||||||
tracing::info!(source, relay_count = relays.len(), "reconciling relay billing state");
|
tracing::info!(
|
||||||
|
source,
|
||||||
|
relay_count = relays.len(),
|
||||||
|
"reconciling relay billing state"
|
||||||
|
);
|
||||||
|
|
||||||
for relay in relays {
|
for relay in relays {
|
||||||
if let Err(error) = self.sync_relay_subscription_for_relay(&relay).await {
|
if let Err(error) = self.sync_relay_subscription_for_relay(&relay).await {
|
||||||
@@ -765,8 +769,9 @@ impl Billing {
|
|||||||
}
|
}
|
||||||
|
|
||||||
pub async fn stripe_create_customer(&self, tenant_pubkey: &str) -> Result<String> {
|
pub async fn stripe_create_customer(&self, tenant_pubkey: &str) -> Result<String> {
|
||||||
let short_pubkey: String = tenant_pubkey.chars().take(12).collect();
|
let short_pubkey: String = tenant_pubkey.chars().take(8).collect();
|
||||||
let display_name = format!("Caravel tenant {short_pubkey}");
|
let nostr_name = self.robot.fetch_nostr_name(tenant_pubkey).await;
|
||||||
|
let display_name = nostr_name.unwrap_or_else(|| short_pubkey.clone());
|
||||||
let idempotency_key = self.idempotency_key(&["create_customer", tenant_pubkey]);
|
let idempotency_key = self.idempotency_key(&["create_customer", tenant_pubkey]);
|
||||||
|
|
||||||
let resp = self
|
let resp = self
|
||||||
@@ -998,8 +1003,7 @@ impl Billing {
|
|||||||
customer_id: &str,
|
customer_id: &str,
|
||||||
price_id: &str,
|
price_id: &str,
|
||||||
) -> Result<(String, String)> {
|
) -> Result<(String, String)> {
|
||||||
let idempotency_key =
|
let idempotency_key = self.idempotency_key(&["create_subscription", customer_id, price_id]);
|
||||||
self.idempotency_key(&["create_subscription", customer_id, price_id]);
|
|
||||||
let resp = self
|
let resp = self
|
||||||
.http
|
.http
|
||||||
.post(format!("{STRIPE_API}/subscriptions"))
|
.post(format!("{STRIPE_API}/subscriptions"))
|
||||||
@@ -1726,5 +1730,4 @@ mod tests {
|
|||||||
assert_eq!(billing.stripe_secret_key, "sk_test_dummy");
|
assert_eq!(billing.stripe_secret_key, "sk_test_dummy");
|
||||||
assert_eq!(billing.stripe_webhook_secret, "whsec_test_dummy");
|
assert_eq!(billing.stripe_webhook_secret, "whsec_test_dummy");
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -160,6 +160,25 @@ impl Robot {
|
|||||||
Ok(relays)
|
Ok(relays)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
pub async fn fetch_nostr_name(&self, pubkey: &str) -> Option<String> {
|
||||||
|
let pubkey = PublicKey::parse(pubkey).ok()?;
|
||||||
|
let filter = Filter::new().author(pubkey).kind(Kind::Metadata).limit(1);
|
||||||
|
let events = self
|
||||||
|
.indexer_client
|
||||||
|
.fetch_events(filter, Duration::from_secs(5))
|
||||||
|
.await
|
||||||
|
.ok()?;
|
||||||
|
let event = events.into_iter().max_by_key(|e| e.created_at)?;
|
||||||
|
let content: serde_json::Value = serde_json::from_str(&event.content).ok()?;
|
||||||
|
let name = content
|
||||||
|
.get("display_name")
|
||||||
|
.or_else(|| content.get("name"))
|
||||||
|
.and_then(|v| v.as_str())
|
||||||
|
.map(|s| s.trim().to_string())
|
||||||
|
.filter(|s| !s.is_empty())?;
|
||||||
|
Some(name)
|
||||||
|
}
|
||||||
|
|
||||||
async fn fetch_messaging_relays_from_outbox(
|
async fn fetch_messaging_relays_from_outbox(
|
||||||
&self,
|
&self,
|
||||||
recipient: &str,
|
recipient: &str,
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
import { createSignal } from "solid-js"
|
import { createSignal } from "solid-js"
|
||||||
import { updateRelayById, deactivateRelayById, reactivateRelayById, getLatestOpenInvoice, type Relay } from "@/lib/hooks"
|
import { updateRelayById, deactivateRelayById, reactivateRelayById, getLatestOpenInvoice, tenantNeedsPaymentSetup, type Relay } from "@/lib/hooks"
|
||||||
import { setToastMessage } from "@/components/Toast"
|
import { setToastMessage } from "@/components/Toast"
|
||||||
import type { Invoice, PlanId } from "@/lib/api"
|
import type { Invoice, PlanId } from "@/lib/api"
|
||||||
|
|
||||||
@@ -31,6 +31,7 @@ export default function useRelayToggles(
|
|||||||
) {
|
) {
|
||||||
const [busy, setBusy] = createSignal(false)
|
const [busy, setBusy] = createSignal(false)
|
||||||
const [pendingInvoice, setPendingInvoice] = createSignal<Invoice | undefined>()
|
const [pendingInvoice, setPendingInvoice] = createSignal<Invoice | undefined>()
|
||||||
|
const [pendingPaymentSetup, setPendingPaymentSetup] = createSignal(false)
|
||||||
|
|
||||||
async function updateRelay(next: Relay, previous: Relay) {
|
async function updateRelay(next: Relay, previous: Relay) {
|
||||||
mutate(next)
|
mutate(next)
|
||||||
@@ -101,8 +102,12 @@ export default function useRelayToggles(
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (plan !== "free") {
|
if (plan !== "free") {
|
||||||
const invoice = await getLatestOpenInvoice()
|
const needsSetup = await tenantNeedsPaymentSetup()
|
||||||
if (invoice) setPendingInvoice(invoice)
|
if (needsSetup) {
|
||||||
|
const invoice = await getLatestOpenInvoice()
|
||||||
|
if (invoice) setPendingInvoice(invoice)
|
||||||
|
setPendingPaymentSetup(true)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -116,5 +121,5 @@ export default function useRelayToggles(
|
|||||||
onToggleLivekitSupport: () => toggle("livekit_enabled", relay()?.plan !== "free"),
|
onToggleLivekitSupport: () => toggle("livekit_enabled", relay()?.plan !== "free"),
|
||||||
}
|
}
|
||||||
|
|
||||||
return { busy, handleDeactivate, handleReactivate, handleUpdatePlan, pendingInvoice, clearPendingInvoice: () => setPendingInvoice(undefined), toggles }
|
return { busy, handleDeactivate, handleReactivate, handleUpdatePlan, pendingInvoice, clearPendingInvoice: () => setPendingInvoice(undefined), pendingPaymentSetup, clearPendingPaymentSetup: () => setPendingPaymentSetup(false), toggles }
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
import { useParams } from "@solidjs/router"
|
import { useParams } from "@solidjs/router"
|
||||||
import { createMemo, createResource, createSignal, Show } from "solid-js"
|
import { createEffect, 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 PaymentDialog from "@/components/PaymentDialog"
|
||||||
@@ -28,13 +28,20 @@ export default function RelayDetail() {
|
|||||||
})
|
})
|
||||||
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, pendingInvoice, clearPendingInvoice, toggles } = useRelayToggles(relayId, relay, { refetch, mutate })
|
const { busy, handleDeactivate, handleReactivate, handleUpdatePlan, pendingInvoice, clearPendingInvoice, pendingPaymentSetup, clearPendingPaymentSetup, toggles } = useRelayToggles(relayId, relay, { refetch, mutate })
|
||||||
|
|
||||||
const [tenant, { refetch: refetchTenant }] = useTenant()
|
const [tenant, { refetch: refetchTenant }] = useTenant()
|
||||||
const [paymentSetupOpen, setPaymentSetupOpen] = createSignal(false)
|
const [paymentSetupOpen, setPaymentSetupOpen] = createSignal(false)
|
||||||
const [invoiceDialogOpen, setInvoiceDialogOpen] = createSignal(false)
|
const [invoiceDialogOpen, setInvoiceDialogOpen] = createSignal(false)
|
||||||
const [paymentBannerDismissed, setPaymentBannerDismissed] = createSignal(false)
|
const [paymentBannerDismissed, setPaymentBannerDismissed] = createSignal(false)
|
||||||
|
|
||||||
|
createEffect(() => {
|
||||||
|
if (pendingPaymentSetup() && !pendingInvoice()) {
|
||||||
|
setPaymentSetupOpen(true)
|
||||||
|
clearPendingPaymentSetup()
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
const isPaidRelay = createMemo(() => {
|
const isPaidRelay = createMemo(() => {
|
||||||
const r = relay()
|
const r = relay()
|
||||||
if (!r) return false
|
if (!r) return false
|
||||||
|
|||||||
@@ -3,13 +3,15 @@ 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 PaymentDialog from "@/components/PaymentDialog"
|
import PaymentDialog from "@/components/PaymentDialog"
|
||||||
|
import PaymentSetup from "@/components/PaymentSetup"
|
||||||
import RelayForm, { type RelayFormValues } from "@/components/RelayForm"
|
import RelayForm, { type RelayFormValues } from "@/components/RelayForm"
|
||||||
import { createRelayForActiveTenant, getLatestOpenInvoice } from "@/lib/hooks"
|
import { createRelayForActiveTenant, getLatestOpenInvoice, tenantNeedsPaymentSetup } from "@/lib/hooks"
|
||||||
import type { Invoice } from "@/lib/api"
|
import type { Invoice } from "@/lib/api"
|
||||||
|
|
||||||
export default function RelayNew() {
|
export default function RelayNew() {
|
||||||
const navigate = useNavigate()
|
const navigate = useNavigate()
|
||||||
const [pendingInvoice, setPendingInvoice] = createSignal<Invoice | undefined>()
|
const [pendingInvoice, setPendingInvoice] = createSignal<Invoice | undefined>()
|
||||||
|
const [paymentSetupOpen, setPaymentSetupOpen] = createSignal(false)
|
||||||
let createdRelayId = ""
|
let createdRelayId = ""
|
||||||
|
|
||||||
async function handleSubmit(values: RelayFormValues) {
|
async function handleSubmit(values: RelayFormValues) {
|
||||||
@@ -17,9 +19,14 @@ export default function RelayNew() {
|
|||||||
createdRelayId = relay.id
|
createdRelayId = relay.id
|
||||||
|
|
||||||
if (values.plan !== "free") {
|
if (values.plan !== "free") {
|
||||||
const invoice = await getLatestOpenInvoice()
|
const needsSetup = await tenantNeedsPaymentSetup()
|
||||||
if (invoice) {
|
if (needsSetup) {
|
||||||
setPendingInvoice(invoice)
|
const invoice = await getLatestOpenInvoice()
|
||||||
|
if (invoice) {
|
||||||
|
setPendingInvoice(invoice)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
setPaymentSetupOpen(true)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -27,8 +34,13 @@ export default function RelayNew() {
|
|||||||
navigate(`/relays/${relay.id}`)
|
navigate(`/relays/${relay.id}`)
|
||||||
}
|
}
|
||||||
|
|
||||||
function handleDialogClose() {
|
function handleInvoiceClose() {
|
||||||
setPendingInvoice(undefined)
|
setPendingInvoice(undefined)
|
||||||
|
setPaymentSetupOpen(true)
|
||||||
|
}
|
||||||
|
|
||||||
|
function handleSetupClose() {
|
||||||
|
setPaymentSetupOpen(false)
|
||||||
navigate(`/relays/${createdRelayId}`)
|
navigate(`/relays/${createdRelayId}`)
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -47,10 +59,14 @@ export default function RelayNew() {
|
|||||||
<PaymentDialog
|
<PaymentDialog
|
||||||
invoice={inv()}
|
invoice={inv()}
|
||||||
open={true}
|
open={true}
|
||||||
onClose={handleDialogClose}
|
onClose={handleInvoiceClose}
|
||||||
/>
|
/>
|
||||||
)}
|
)}
|
||||||
</Show>
|
</Show>
|
||||||
|
<PaymentSetup
|
||||||
|
open={paymentSetupOpen()}
|
||||||
|
onClose={handleSetupClose}
|
||||||
|
/>
|
||||||
</PageContainer>
|
</PageContainer>
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user