Update subscriptions.py

subscriptions.py

@@ -12,7 +12,7 @@ SUPABASE_KEY = os.getenv("SUPABASE_SERVICE_ROLE_KEY")
 supabase: Client = create_client(SUPABASE_URL, SUPABASE_KEY)
 POSTGRE_SECRET = os.getenv("POSTGRE_SECRET")
 
-conn = psycopg.connect(POSTGRE_SECRET, row_factory=dict_row)
+conn = psycopg.connect(POSTGRE_SECRET, row_factory=dict_row, sslmode="verify-full", sslrootcert="prod-ca-2021.crt")
 
 
 async def get_conn():
@@ -87,7 +87,36 @@ async def fetch_subscription(jwt: str):
         except psycopg.OperationalError:
             connection = psycopg.connect(POSTGRE_SECRET, row_factory=dict_row)
             with connection.cursor() as cur:
-                cur.execute(""" ... same SQL ... """, (email,))
+                cur.execute("""
+                    with cust as (
+                        select id 
+                        from stripe.customers 
+                        where email = %s
+                    ),
+                    subs as (
+                        select
+                            s.id as subscription_id,
+                            s.status,
+                            s.current_period_end,
+                            s.items->'data'->0->'price'->>'id' as price_id
+                        from stripe.subscriptions s
+                        join cust on s.customer = cust.id
+                        where s.status in ('active', 'trialing', 'past_due')
+                    )
+                    select
+                        subs.subscription_id,
+                        subs.status,
+                        subs.current_period_end,
+                        subs.price_id,
+                        prices.nickname,
+                        prices.product as product_id,
+                        products.name as product_name
+                    from subs
+                    left join stripe.prices prices
+                      on prices.id = subs.price_id
+                    left join stripe.products products
+                      on prices.product = products.id;
+                """, (email,))
                 rows = cur.fetchall()
 
     if not rows: