Skip to content

Supabase - new codebase - Recoup-Migrations #1

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
sweetmantech merged 1 commit into from
Dec 18, 2025
Merged

Supabase - new codebase - Recoup-Migrations #1

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
171 changes: 171 additions & 0 deletions supabase/migrations/20241106161733_add_get_campaign.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,171 @@
set check_function_bodies = off;

CREATE OR REPLACE FUNCTION public.get_campaign(email text, artistid text, clientid text)
RETURNS jsonb
LANGUAGE plpgsql
AS $function$DECLARE
client_ids text[] := ARRAY[]::text[];
BEGIN
IF $3 != '' THEN
client_ids := ARRAY[$3];
ELSIF $2 != '' THEN
SELECT ARRAY(
SELECT "clientId"::text
FROM "campaigns" c
WHERE c."artistId" = $2::UUID
) INTO client_ids;
ELSE
WITH artist_ids AS (
SELECT (jsonb_array_elements_text("artistIds"))::UUID AS artist_id
FROM "accounts" a
WHERE a."email" = $1
)
SELECT ARRAY(
SELECT "clientId"
FROM "campaigns" c
WHERE c."artistId" IN (SELECT artist_id FROM artist_ids)
) INTO client_ids;
END IF;

RETURN (
SELECT jsonb_build_object(
'albums', (
SELECT jsonb_agg(album_name ORDER BY popularity DESC) AS album_names
FROM (
SELECT DISTINCT
album_element->>'name' AS album_name,
(album_element->>'popularity')::int AS popularity
FROM (
SELECT jsonb_array_elements("savedAlbums") AS album_element
FROM "fans"
WHERE "clientId" = ANY(client_ids)
AND "savedAlbums" IS NOT NULL
AND jsonb_typeof("savedAlbums") = 'array' -- Ensure it's an array
) AS subquery
WHERE album_element->>'name' IS NOT NULL
) AS unique_albums
),
'tracks', (
SELECT jsonb_agg(track_name ORDER BY popularity DESC) AS track_names
FROM (
SELECT DISTINCT
track_element->>'name' AS track_name,
(track_element->>'popularity')::int AS popularity
FROM (
SELECT jsonb_array_elements("topTracks") AS track_element
FROM "fans"
WHERE "clientId" = ANY(client_ids)
AND "topTracks" IS NOT NULL
AND jsonb_typeof("topTracks") = 'array' -- Ensure it's an array
UNION ALL
SELECT jsonb_array_elements("savedTracks") AS track_element
FROM "fans"
WHERE "clientId" = ANY(client_ids)
AND "savedTracks" IS NOT NULL
AND jsonb_typeof("savedTracks") = 'array' -- Ensure it's an array
) AS track_subquery
WHERE track_element->>'name' IS NOT NULL
) AS unique_tracks
),
'artists', (
SELECT jsonb_agg(artist_name ORDER BY popularity DESC) AS artist_names
FROM (
SELECT DISTINCT
artist_element->>'name' AS artist_name,
(artist_element->>'popularity')::int AS popularity
FROM (
SELECT jsonb_array_elements("followedArtists") AS artist_element
FROM "fans"
WHERE "clientId" = ANY(client_ids)
AND "followedArtists" IS NOT NULL
AND jsonb_typeof("followedArtists") = 'array' -- Ensure it's an array
UNION ALL
SELECT jsonb_array_elements("topArtists") AS artist_element
FROM "fans"
WHERE "clientId" = ANY(client_ids)
AND "topArtists" IS NOT NULL
AND jsonb_typeof("topArtists") = 'array' -- Ensure it's an array
) AS artist_subquery
WHERE artist_element->>'name' IS NOT NULL
) AS unique_artists
),
'audio_books', (
SELECT jsonb_agg(audio_book_name::text) AS audio_book_names
FROM (
SELECT DISTINCT
audio_book_element->>'name' AS audio_book_name
FROM (
SELECT jsonb_array_elements("savedAudioBooks") AS audio_book_element
FROM "fans"
WHERE "clientId" = ANY(client_ids)
AND "savedAudioBooks" IS NOT NULL
AND jsonb_typeof("savedAudioBooks") = 'array' -- Ensure it's an array
) AS subquery
WHERE audio_book_element->>'name' IS NOT NULL
) AS unique_audio_books
),
'shows', (
SELECT jsonb_agg(show_name::text) AS show_names
FROM (
SELECT DISTINCT
show_element->>'name' AS show_name
FROM (
SELECT jsonb_array_elements("savedShows") AS show_element
FROM "fans"
WHERE "clientId" = ANY(client_ids)
AND "savedShows" IS NOT NULL
AND jsonb_typeof("savedShows") = 'array' -- Ensure it's an array
) AS subquery
WHERE show_element->>'name' IS NOT NULL
) AS unique_shows
),
'playlist', (
SELECT jsonb_agg(playlist_name::text) AS playlist_names
FROM (
SELECT DISTINCT
playlist_element->>'name' AS playlist_name
FROM (
SELECT jsonb_array_elements("playlist") AS playlist_element
FROM "fans"
WHERE "clientId" = ANY(client_ids)
AND "playlist" IS NOT NULL
AND jsonb_typeof("playlist") = 'array' -- Ensure it's an array
) AS subquery
WHERE playlist_element->>'name' IS NOT NULL
) AS unique_playlists
),
'episodes', (
SELECT jsonb_agg(episodes_name::text) AS episodes_names
FROM (
SELECT DISTINCT
episodes_element->>'name' AS episodes_name
FROM (
SELECT jsonb_array_elements("episodes") AS episodes_element
FROM "fans"
WHERE "clientId" = ANY(client_ids)
AND "episodes" IS NOT NULL
AND jsonb_typeof("episodes") = 'array' -- Ensure it's an array
) AS subquery
WHERE episodes_element->>'name' IS NOT NULL
) AS unique_episodes
),
'fans', (
SELECT jsonb_agg(subquery)
FROM (
SELECT
f.display_name,
f.country,
f.email,
f.product
FROM "fans" f
WHERE f."clientId" = ANY(client_ids)
AND f."display_name" IS NOT NULL
AND f."email" IS NOT NULL
) AS subquery
)
)
);
END;$function$
;


169 changes: 169 additions & 0 deletions supabase/migrations/20241108055712_get_all_fans.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,169 @@
set check_function_bodies = off;

CREATE OR REPLACE FUNCTION public.get_campaign(email text, artistid text, clientid text)
RETURNS jsonb
LANGUAGE plpgsql
AS $function$DECLARE
client_ids text[] := ARRAY[]::text[];
BEGIN
IF $3 != '' THEN
client_ids := ARRAY[$3];
ELSIF $2 != '' THEN
SELECT ARRAY(
SELECT "clientId"::text
FROM "campaigns" c
WHERE c."artistId" = $2::UUID
) INTO client_ids;
ELSE
WITH artist_ids AS (
SELECT (jsonb_array_elements_text("artistIds"))::UUID AS artist_id
FROM "accounts" a
WHERE a."email" = $1
)
SELECT ARRAY(
SELECT "clientId"
FROM "campaigns" c
WHERE c."artistId" IN (SELECT artist_id FROM artist_ids)
) INTO client_ids;
END IF;

RETURN (
SELECT jsonb_build_object(
'albums', (
SELECT jsonb_agg(album_name ORDER BY popularity DESC) AS album_names
FROM (
SELECT DISTINCT
album_element->>'name' AS album_name,
(album_element->>'popularity')::int AS popularity
FROM (
SELECT jsonb_array_elements("savedAlbums") AS album_element
FROM "fans"
WHERE "clientId" = ANY(client_ids)
AND "savedAlbums" IS NOT NULL
AND jsonb_typeof("savedAlbums") = 'array' -- Ensure it's an array
) AS subquery
WHERE album_element->>'name' IS NOT NULL
) AS unique_albums
),
'tracks', (
SELECT jsonb_agg(track_name ORDER BY popularity DESC) AS track_names
FROM (
SELECT DISTINCT
track_element->>'name' AS track_name,
(track_element->>'popularity')::int AS popularity
FROM (
SELECT jsonb_array_elements("topTracks") AS track_element
FROM "fans"
WHERE "clientId" = ANY(client_ids)
AND "topTracks" IS NOT NULL
AND jsonb_typeof("topTracks") = 'array' -- Ensure it's an array
UNION ALL
SELECT jsonb_array_elements("savedTracks") AS track_element
FROM "fans"
WHERE "clientId" = ANY(client_ids)
AND "savedTracks" IS NOT NULL
AND jsonb_typeof("savedTracks") = 'array' -- Ensure it's an array
) AS track_subquery
WHERE track_element->>'name' IS NOT NULL
) AS unique_tracks
),
'artists', (
SELECT jsonb_agg(artist_name ORDER BY popularity DESC) AS artist_names
FROM (
SELECT DISTINCT
artist_element->>'name' AS artist_name,
(artist_element->>'popularity')::int AS popularity
FROM (
SELECT jsonb_array_elements("followedArtists") AS artist_element
FROM "fans"
WHERE "clientId" = ANY(client_ids)
AND "followedArtists" IS NOT NULL
AND jsonb_typeof("followedArtists") = 'array' -- Ensure it's an array
UNION ALL
SELECT jsonb_array_elements("topArtists") AS artist_element
FROM "fans"
WHERE "clientId" = ANY(client_ids)
AND "topArtists" IS NOT NULL
AND jsonb_typeof("topArtists") = 'array' -- Ensure it's an array
) AS artist_subquery
WHERE artist_element->>'name' IS NOT NULL
) AS unique_artists
),
'audio_books', (
SELECT jsonb_agg(audio_book_name::text) AS audio_book_names
FROM (
SELECT DISTINCT
audio_book_element->>'name' AS audio_book_name
FROM (
SELECT jsonb_array_elements("savedAudioBooks") AS audio_book_element
FROM "fans"
WHERE "clientId" = ANY(client_ids)
AND "savedAudioBooks" IS NOT NULL
AND jsonb_typeof("savedAudioBooks") = 'array' -- Ensure it's an array
) AS subquery
WHERE audio_book_element->>'name' IS NOT NULL
) AS unique_audio_books
),
'shows', (
SELECT jsonb_agg(show_name::text) AS show_names
FROM (
SELECT DISTINCT
show_element->>'name' AS show_name
FROM (
SELECT jsonb_array_elements("savedShows") AS show_element
FROM "fans"
WHERE "clientId" = ANY(client_ids)
AND "savedShows" IS NOT NULL
AND jsonb_typeof("savedShows") = 'array' -- Ensure it's an array
) AS subquery
WHERE show_element->>'name' IS NOT NULL
) AS unique_shows
),
'playlist', (
SELECT jsonb_agg(playlist_name::text) AS playlist_names
FROM (
SELECT DISTINCT
playlist_element->>'name' AS playlist_name
FROM (
SELECT jsonb_array_elements("playlist") AS playlist_element
FROM "fans"
WHERE "clientId" = ANY(client_ids)
AND "playlist" IS NOT NULL
AND jsonb_typeof("playlist") = 'array' -- Ensure it's an array
) AS subquery
WHERE playlist_element->>'name' IS NOT NULL
) AS unique_playlists
),
'episodes', (
SELECT jsonb_agg(episodes_name::text) AS episodes_names
FROM (
SELECT DISTINCT
episodes_element->>'name' AS episodes_name
FROM (
SELECT jsonb_array_elements("episodes") AS episodes_element
FROM "fans"
WHERE "clientId" = ANY(client_ids)
AND "episodes" IS NOT NULL
AND jsonb_typeof("episodes") = 'array' -- Ensure it's an array
) AS subquery
WHERE episodes_element->>'name' IS NOT NULL
) AS unique_episodes
),
'fans', (
SELECT jsonb_agg(subquery)
FROM (
SELECT
f.display_name,
f.country,
f.email,
f.product
FROM "fans" f
WHERE f."clientId" = ANY(client_ids)
) AS subquery
)
)
);
END;$function$
;


10 changes: 10 additions & 0 deletions supabase/migrations/20241111092359_update_campaignId_of_luhtyler.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,10 @@
create table if not exists "public"."fans" (
"id" uuid not null default gen_random_uuid(),
"clientId" text
);

ALTER TABLE "public"."fans" ADD COLUMN "campaignId" TEXT;

UPDATE "public"."fans" SET "campaignId" = 'b658c81f-fab7-48e2-9284-d3a85e49304a' WHERE "clientId" = 'LUHTYLER';


Loading