@@ -10,13 +10,21 @@ data:
1010 \set jwt_secret `echo "$JWT_SECRET"`
1111 \set jwt_exp `echo "$JWT_EXP"`
1212
13- ALTER DATABASE postgres SET "app.settings.jwt_secret" TO :jwt_secret;
14- ALTER DATABASE postgres SET "app.settings.jwt_exp" TO :jwt_exp;
15- 99-logs .sql : |
13+ ALTER DATABASE postgres SET "app.settings.jwt_secret" TO :' jwt_secret' ;
14+ ALTER DATABASE postgres SET "app.settings.jwt_exp" TO :' jwt_exp' ;
15+ 99-pooler .sql : |
1616 \set pguser `echo "$POSTGRES_USER"`
1717
18+ \c _supabase
19+ create schema if not exists _supavisor;
20+ alter schema _supavisor owner to :pguser;
21+ \c postgres
22+ 99-logs.sql : |
23+ \set pguser `echo "$POSTGRES_USER"`
24+ \c _supabase
1825 create schema if not exists _analytics;
1926 alter schema _analytics owner to :pguser;
27+ \c postgres
2028 99-realtime.sql : |
2129 \set pguser `echo "$POSTGRES_USER"`
2230
3139 ALTER USER supabase_auth_admin WITH PASSWORD :'pgpass';
3240 ALTER USER supabase_functions_admin WITH PASSWORD :'pgpass';
3341 ALTER USER supabase_storage_admin WITH PASSWORD :'pgpass';
42+ 97-_supabase.sql : |
43+ \set pguser `echo "$POSTGRES_USER"`
44+
45+ CREATE DATABASE _supabase WITH OWNER :pguser;
3446 98-webhooks.sql : |
3547 BEGIN;
3648 -- Create pg_net extension
@@ -75,29 +87,29 @@ data:
7587 IF url IS NULL OR url = 'null' THEN
7688 RAISE EXCEPTION 'url argument is missing';
7789 END IF;
78-
90+
7991 IF method IS NULL OR method = 'null' THEN
8092 RAISE EXCEPTION 'method argument is missing';
8193 END IF;
82-
94+
8395 IF TG_ARGV[2] IS NULL OR TG_ARGV[2] = 'null' THEN
8496 headers = '{"Content-Type": "application/json"}'::jsonb;
8597 ELSE
8698 headers = TG_ARGV[2]::jsonb;
8799 END IF;
88-
100+
89101 IF TG_ARGV[3] IS NULL OR TG_ARGV[3] = 'null' THEN
90102 params = '{}'::jsonb;
91103 ELSE
92104 params = TG_ARGV[3]::jsonb;
93105 END IF;
94-
106+
95107 IF TG_ARGV[4] IS NULL OR TG_ARGV[4] = 'null' THEN
96108 timeout_ms = 1000;
97109 ELSE
98110 timeout_ms = TG_ARGV[4]::integer;
99111 END IF;
100-
112+
101113 CASE
102114 WHEN method = 'GET' THEN
103115 SELECT http_get INTO request_id FROM net.http_get(
@@ -114,7 +126,7 @@ data:
114126 'table', TG_TABLE_NAME,
115127 'schema', TG_TABLE_SCHEMA
116128 );
117-
129+
118130 SELECT http_post INTO request_id FROM net.http_post(
119131 url,
120132 payload,
@@ -125,12 +137,12 @@ data:
125137 ELSE
126138 RAISE EXCEPTION 'method argument % is invalid', method;
127139 END CASE;
128-
140+
129141 INSERT INTO supabase_functions.hooks
130142 (hook_table_id, hook_name, request_id)
131143 VALUES
132144 (TG_RELID, TG_NAME, request_id);
133-
145+
134146 RETURN NEW;
135147 END
136148 $function$;
@@ -240,4 +252,4 @@ data:
240252 REVOKE ALL ON FUNCTION supabase_functions.http_request() FROM PUBLIC;
241253 GRANT EXECUTE ON FUNCTION supabase_functions.http_request() TO postgres, anon, authenticated, service_role;
242254 COMMIT;
243- {{- end }}
255+ {{- end }}
0 commit comments