Requirements
- Target platform
- OpenClaw
- Install method
- Manual import
- Extraction
- Extract archive
- Prerequisites
- OpenClaw
- Primary doc
- SKILL.md
Integrate Stripe usage-based billing with idempotent event ingestion, late-event handling, and pre-invoice reconciliation. Use when implementing usage meteri...
Integrate Stripe usage-based billing with idempotent event ingestion, late-event handling, and pre-invoice reconciliation. Use when implementing usage meteri...
Hand the extracted package to your coding agent with a concrete install brief instead of figuring it out manually.
I downloaded a skill package from Yavira. Read SKILL.md from the extracted folder and install it by following the included instructions. Tell me what you changed and call out any manual steps you could not complete.
I downloaded an updated skill package from Yavira. Read SKILL.md from the extracted folder, compare it with my current installation, and upgrade it while preserving any custom configuration unless the package docs explicitly say otherwise. Summarize what changed and any follow-up checks I should run.
StripeMeter is a Stripe-native usage metering system that ensures correct usage totals for usage-based billing. It dedupes retries, handles late events with watermarks, keeps running counters, and pushes only deltas to Stripe.
git clone https://github.com/geminimir/stripemeter && cd stripemeter cp .env.example .env && docker compose up -d && pnpm -r build pnpm db:migrate && pnpm dev
Every usage event stored with deterministic idempotency key. Events are never deleted or modified.
Pre-computed aggregations (sum/max/last) by tenant, metric, customer, and period. Updated in near-real-time.
Each counter maintains a watermark timestamp. Events within lateness window (default 48h) trigger re-aggregation.
Tracks pushed_total per subscription item and only sends delta to Stripe.
curl -X POST http://localhost:3000/v1/events/ingest \ -H "Content-Type: application/json" \ -d '{ "events": [{ "tenantId": "your-tenant-id", "metric": "api_calls", "customerRef": "cus_ABC123", "quantity": 100, "ts": "2025-01-16T14:30:00Z" }] }'
curl -X POST http://localhost:3000/v1/usage/projection \ -H "Content-Type: application/json" \ -d '{"tenantId": "your-tenant-id", "customerRef": "cus_ABC123"}'
Readiness: GET /health/ready Metrics: GET /metrics Events: GET /v1/events?tenantId=X&limit=10
import { createClient } from '@stripemeter/sdk-node'; const client = createClient({ apiUrl: 'http://localhost:3000', tenantId: 'your-tenant-id', customerId: 'cus_ABC123' }); // Track usage await client.track({ metric: 'api_calls', customerRef: 'cus_ABC123', quantity: 100, meta: { endpoint: '/v1/search' } }); // Get live usage const usage = await client.getUsage('cus_ABC123'); const projection = await client.getProjection('cus_ABC123');
from stripemeter import StripeMeterClient client = StripeMeterClient( api_url="http://localhost:3000", tenant_id="your-tenant-id", customer_id="cus_ABC123" ) client.track( metric="api_calls", customer_ref="cus_ABC123", quantity=100 )
For direct Stripe integration, use the stripe-driver package: import { StripeBillingDriverImpl } from '@stripemeter/stripe-driver'; const driver = new StripeBillingDriverImpl({ liveKey: process.env.STRIPE_SECRET_KEY, testKey: process.env.STRIPE_TEST_SECRET_KEY }); // Record usage to Stripe await driver.recordUsage({ mode: 'live', stripeAccount: 'default', subscriptionItemId: 'si_xxx', quantity: 100, periodStart: '2025-01-01', idempotencyKey: 'unique-key' }); // Get usage summary const summary = await driver.getUsageSummary( 'si_xxx', '2025-01-01', 'default' );
Test Stripe usage posting without affecting live invoices: Set STRIPE_TEST_SECRET_KEY in environment Mark price mapping with shadow=true Provide shadowStripeAccount, shadowPriceId Live invoices remain unaffected
import { InvoiceSimulator } from '@stripemeter/pricing-lib'; const simulator = new InvoiceSimulator(); const result = simulator.simulate({ customerId: 'test', periodStart: '2024-01-01', periodEnd: '2024-02-01', usageItems: [{ metric: 'api_calls', quantity: 25000, priceConfig: { model: 'tiered', currency: 'USD', tiers: [ { upTo: 10000, unitPrice: 0.01 }, { upTo: 50000, unitPrice: 0.008 }, { upTo: null, unitPrice: 0.005 } ] } }] });
stripemeter/ βββ packages/ β βββ core/ # Shared types, schemas β βββ database/ # Drizzle ORM + Redis β βββ pricing-lib/ # Pricing calculator β βββ stripe-driver/ # Direct Stripe API driver β βββ sdk-node/ # Node.js SDK β βββ sdk-python/ # Python SDK βββ apps/ β βββ api/ # REST API (Fastify) β βββ workers/ # Background workers (BullMQ) β βββ admin-ui/ # Admin dashboard β βββ customer-widget/# Embeddable widget
STRIPE_SECRET_KEY=sk_live_xxx # Live Stripe key STRIPE_TEST_SECRET_KEY=sk_test_xxx # Test Stripe key (for shadow mode) DATABASE_URL=postgres://... # PostgreSQL connection REDIS_URL=redis://... # Redis connection
# Send same event twice - counts once TENANT_ID=$(uuidgen) bash examples/api-calls/send.sh curl http://localhost:3000/metrics | grep ingest
Check drift between local totals and Stripe: Differences beyond 0.5% epsilon trigger investigation See RECONCILIATION.md for runbook
curl -X POST http://localhost:3000/v1/replay \ -H "Content-Type: application/json" \ -d '{"tenantId": "X", "dryRun": true}'
API Documentation Simulator Guide Reconciliation Runbook Alert Configuration
Agent frameworks, memory systems, reasoning layers, and model-native orchestration.
Largest current source with strong distribution and engagement signals.