Merge pull request #24 from supabase/chore/migrations

feat: self-managed migrations

README.md

@@ -81,9 +81,9 @@ This server synchronizes your Stripe account to a Postgres database. It can be a
 - Update your Stripe account with all valid webhooks and get the webhook secret
 - `mv .env.sample .env` and then rename all the variables
 - Make sure the database URL has search_path `stripe`. eg: `DATABASE_URL=postgres://postgres:postgres@hostname:5432/postgres?sslmode=disable&search_path=stripe`
-- Run `dbmate up`
 - Deploy the [docker image](https://hub.docker.com/r/supabase/stripe-sync-engine) to your favourite hosting service and expose port `8080`
   - eg: `docker run -e PORT=8080 --env-file .env supabase/stripe-sync-engine`
+  - This will automatically run any migrations on your database
 - Point your Stripe webooks to your deployed app.
 ## Future ideas
 
@@ -96,7 +96,6 @@ This server synchronizes your Stripe account to a Postgres database. It can be a
 - Create a Postgres database on [supabase.com](https://supabase.com) (or another Postgres provider)
 - Update Stripe with all valid webhooks and get the webhook secret
 - `mv .env.sample .env` and then rename all the variables
-- run `dbmate up` to run all the database migrations
 
 **Develop**
 

db/migrations/0000_initial_migration.sql

@@ -0,0 +1 @@
+select 1;

db/migrations/20210428143846_products.sql → db/migrations/0001_products.sql

@@ -1,6 +1,4 @@
--- migrate:up
-
-create table "stripe"."products" (
+create table if not exists "stripe"."products" (
   "id" text primary key,
   "object" text,
   "active" boolean,
@@ -17,7 +15,3 @@ create table "stripe"."products" (
   "updated" integer,
   "url" text
 );
-
--- migrate:down
-
-drop table "stripe"."products";

db/migrations/20210429122427_customers.sql → db/migrations/0002_customers.sql

@@ -1,7 +1,4 @@
--- migrate:up
-
-
-create table "stripe"."customers" (
+create table if not exists "stripe"."customers" (
   "id" text primary key,
   "object" text,
   "address" jsonb,
@@ -24,10 +21,3 @@ create table "stripe"."customers" (
   "preferred_locales" jsonb,
   "tax_exempt" text
 );
-
-
-
--- migrate:down
-
-
-drop table "stripe"."customers";

db/migrations/20210429132018_prices.sql → db/migrations/0003_prices.sql

@@ -1,9 +1,17 @@
--- migrate:up
+DO $$
+BEGIN
+    IF NOT EXISTS (SELECT 1 FROM pg_type WHERE typname = 'pricing_type') THEN
+        create type "stripe"."pricing_type" as enum ('one_time', 'recurring');
+    END IF;
+    IF NOT EXISTS (SELECT 1 FROM pg_type WHERE typname = 'pricing_tiers') THEN
+      create type "stripe"."pricing_tiers" as enum ('graduated', 'volume');
+    END IF;
+    --more types here...
+END
+$$;
 
-create type "stripe"."pricing_type" as enum ('one_time', 'recurring');
-create type "stripe"."pricing_tiers" as enum ('graduated', 'volume');
 
-create table "stripe"."prices" (
+create table if not exists "stripe"."prices" (
   "id" text primary key,
   "object" text,
   "active" boolean,
@@ -24,9 +32,3 @@ create table "stripe"."prices" (
   "product" text references stripe.products
 );
 
--- migrate:down
-
-drop table "stripe"."prices";
-drop type "stripe"."pricing_type";
-drop type "stripe"."pricing_tiers";
-

db/migrations/20210429140401_subscriptions.sql → db/migrations/0004_subscriptions.sql

@@ -1,7 +1,21 @@
--- migrate:up
 
-create type "stripe"."subscription_status" as enum ('trialing', 'active', 'canceled', 'incomplete', 'incomplete_expired', 'past_due', 'unpaid');
-create table "stripe"."subscriptions" (
+DO $$
+BEGIN
+    IF NOT EXISTS (SELECT 1 FROM pg_type WHERE typname = 'subscription_status') THEN
+        create type "stripe"."subscription_status" as enum (
+          'trialing',
+          'active',
+          'canceled',
+          'incomplete',
+          'incomplete_expired',
+          'past_due',
+          'unpaid'
+        );
+    END IF;
+END
+$$;
+
+create table if not exists "stripe"."subscriptions" (
   "id" text primary key,
   "object" text,
   "cancel_at_period_end" boolean,
@@ -40,8 +54,3 @@ create table "stripe"."subscriptions" (
   "plan" text -- not yet joined
 );
 
-
--- migrate:down
-
-drop table "stripe"."subscriptions";
-drop type "stripe"."subscription_status";

db/migrations/20210501054139_invoices.sql → db/migrations/0005_invoices.sql

@@ -1,8 +1,14 @@
--- migrate:up
 
+DO $$
+BEGIN
+    IF NOT EXISTS (SELECT 1 FROM pg_type WHERE typname = 'invoice_status') THEN
+        create type "stripe"."invoice_status" as enum ('draft', 'open', 'paid', 'uncollectible', 'void');
+    END IF;
+END
+$$;
 
-create type "stripe"."invoice_status" as enum ('draft', 'open', 'paid', 'uncollectible', 'void');
-create table "stripe"."invoices" (
+
+create table if not exists "stripe"."invoices" (
   "id" text primary key,
   "object" text,
   "auto_advance" boolean,
@@ -69,10 +75,3 @@ create table "stripe"."invoices" (
   "on_behalf_of" text, -- not yet implemented
   "charge" text -- not yet implemented
 );
-
-
-
--- migrate:down
-
-drop table "stripe"."invoices";
-drop type "stripe"."invoice_status";

db/migrations/20210501054140_charges.sql → db/migrations/0006_charges.sql

@@ -1,6 +1,5 @@
--- migrate:up
 
-CREATE TABLE stripe.charges (
+create table if not exists "stripe".charges (
     id text primary key,
     object text,
     card jsonb,
@@ -42,7 +41,3 @@ CREATE TABLE stripe.charges (
     statement_description text,
     payment_method_details jsonb
 );
-
--- migrate:down
-
-drop table "stripe"."charges";

db/migrations/20210501054141_coupons.sql → db/migrations/0007_coupons.sql

@@ -1,6 +1,4 @@
--- migrate:up
-
-CREATE TABLE stripe.coupons (
+create table if not exists "stripe".coupons (
     id text primary key,
     object text,
     name text,
@@ -19,7 +17,3 @@ CREATE TABLE stripe.coupons (
     duration_in_months bigint,
     percent_off_precise double precision
 );
-
--- migrate:down
-
-drop table "stripe"."coupons";

db/migrations/20210501054142_disputes.sql → db/migrations/0008_disputes.sql

@@ -1,6 +1,4 @@
--- migrate:up
-
-CREATE TABLE stripe.disputes (
+create table if not exists "stripe".disputes (
     id text primary key,
     object text,
     amount bigint,
@@ -17,8 +15,3 @@ CREATE TABLE stripe.disputes (
     balance_transactions jsonb,
     is_charge_refundable boolean
 );
-
-
--- migrate:down
-
-drop table "stripe"."disputes";

db/migrations/20210501054144_events.sql → db/migrations/0009_events.sql

@@ -1,7 +1,4 @@
--- migrate:up
-
-
-CREATE TABLE stripe.events (
+create table if not exists "stripe".events (
     id text primary key,
     object text,
     data jsonb,
@@ -13,8 +10,3 @@ CREATE TABLE stripe.events (
     api_version text,
     pending_webhooks bigint
 );
-
-
--- migrate:down
-
-drop table "stripe"."events";

db/migrations/20210501054145_payouts.sql → db/migrations/0010_payouts.sql

@@ -1,7 +1,4 @@
--- migrate:up
-
-
-CREATE TABLE stripe.payouts (
+create table if not exists "stripe".payouts (
     id text primary key,
     object text,
     date text,
@@ -31,8 +28,3 @@ CREATE TABLE stripe.payouts (
     statement_description text,
     failure_balance_transaction text
 );
-
-
--- migrate:down
-
-drop table "stripe"."payouts";

db/migrations/20210501054146_plans.sql → db/migrations/0011_plans.sql

@@ -1,7 +1,4 @@
--- migrate:up
-
-
-CREATE TABLE "stripe"."plans" (
+create table if not exists "stripe"."plans" (
     id text primary key,
     object text,
     name text,
@@ -26,8 +23,3 @@ CREATE TABLE "stripe"."plans" (
     statement_descriptor text,
     statement_description text
 );
-
-
--- migrate:down
-
-drop table "stripe"."plans";