diff --git a/docs/catalog/stripe.md b/docs/catalog/stripe.md index 31dc46d11..511a1d979 100644 --- a/docs/catalog/stripe.md +++ b/docs/catalog/stripe.md @@ -1010,6 +1010,7 @@ create foreign table stripe.subscriptions ( currency text, current_period_start timestamp, current_period_end timestamp, + status text, attrs jsonb ) server stripe_server diff --git a/wrappers/src/fdw/stripe_fdw/README.md b/wrappers/src/fdw/stripe_fdw/README.md index b13cfa9c2..d26081f62 100644 --- a/wrappers/src/fdw/stripe_fdw/README.md +++ b/wrappers/src/fdw/stripe_fdw/README.md @@ -10,6 +10,7 @@ This is a foreign data wrapper for [Stripe](https://stripe.com/) developed using | Version | Date | Notes | | ------- | ---------- | ---------------------------------------------------- | +| 0.1.13 | 2026-08-10 | Added missing 'status' column to 'subscriptions' | | 0.1.12 | 2025-03-06 | Added import foreign schema support | | 0.1.11 | 2024-09-20 | Added Meter object | | 0.1.10 | 2024-08-26 | Added 'api_key_name' server option | diff --git a/wrappers/src/fdw/stripe_fdw/stripe_fdw.rs b/wrappers/src/fdw/stripe_fdw/stripe_fdw.rs index fc35a6e2d..61ccdf81f 100644 --- a/wrappers/src/fdw/stripe_fdw/stripe_fdw.rs +++ b/wrappers/src/fdw/stripe_fdw/stripe_fdw.rs @@ -340,6 +340,7 @@ fn create_table_config() -> TableConfig { ("currency", "text"), ("current_period_start", "timestamp"), ("current_period_end", "timestamp"), + ("status", "text"), ], ), ), @@ -667,7 +668,7 @@ fn inc_stats_request_cnt(stats_metadata: &mut JsonB) -> StripeFdwResult<()> { } #[wrappers_fdw( - version = "0.1.12", + version = "0.1.13", author = "Supabase", website = "https://github.com/supabase/wrappers/tree/main/wrappers/src/fdw/stripe_fdw", error_type = "StripeFdwError" diff --git a/wrappers/src/fdw/stripe_fdw/tests.rs b/wrappers/src/fdw/stripe_fdw/tests.rs index d0a8c9a96..9a8e0ed6a 100644 --- a/wrappers/src/fdw/stripe_fdw/tests.rs +++ b/wrappers/src/fdw/stripe_fdw/tests.rs @@ -392,16 +392,20 @@ mod tests { .unwrap(), ) .zip(r.get_by_name::("current_period_end").unwrap()) + .zip(r.get_by_name::<&str, _>("status").unwrap()) }) .collect::>(); assert_eq!( results, vec![( ( - ("cus_QXg1o8vcGmoR32", "usd"), + ( + ("cus_QXg1o8vcGmoR32", "usd"), + Timestamp::try_from(287883090000000i64).unwrap() + ), Timestamp::try_from(287883090000000i64).unwrap() ), - Timestamp::try_from(287883090000000i64).unwrap() + "active" )] );