astra
/
plc-mirror
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Cutoff at 240 days.

main
mathan 2024-05-15 20:56:06 -07:00
parent 621ce539cf
commit ca7d5956eb
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
db-migration/migrations/20240515_export_ladder_views.sql
View File

@ -7,28 +7,33 @@ CASE
END; END;
$$ LANGUAGE sql STRICT IMMUTABLE; $$ LANGUAGE sql STRICT IMMUTABLE;
drop materialized view export_likes_ladder;
create materialized view export_likes_ladder create materialized view export_likes_ladder
as select repos.did as ":START_ID", as select repos.did as ":START_ID",
split_part(jsonb_extract_path_text(content, 'subject', 'uri'), '/', 3) as ":END_ID", split_part(jsonb_extract_path_text(content, 'subject', 'uri'), '/', 3) as ":END_ID",
sum(ladderq(records.created_at::TIMESTAMP)) as "count:long" sum(ladderq(records.created_at::TIMESTAMP)) as "count:long"
from records join repos on records.repo = repos.id from records join repos on records.repo = repos.id
where records.collection = 'app.bsky.feed.like' where records.collection = 'app.bsky.feed.like'
and records.created_at > CURRENT_DATE - INTERVAL '240' DAY
and repos.did <> split_part(jsonb_extract_path_text(content, 'subject', 'uri'), '/', 3) and repos.did <> split_part(jsonb_extract_path_text(content, 'subject', 'uri'), '/', 3)
group by repos.did, split_part(jsonb_extract_path_text(content, 'subject', 'uri'), '/', 3) group by repos.did, split_part(jsonb_extract_path_text(content, 'subject', 'uri'), '/', 3)
with no data; with no data;
create index export_like_subject_ladder on export_likes_ladder (":END_ID"); create index export_like_subject_ladder on export_likes_ladder (":END_ID");
drop materialized view export_replies_ladder;
create materialized view export_replies_ladder create materialized view export_replies_ladder
as select repos.did as ":START_ID", as select repos.did as ":START_ID",
split_part(jsonb_extract_path_text(content, 'reply', 'parent', 'uri'), '/', 3) as ":END_ID", split_part(jsonb_extract_path_text(content, 'reply', 'parent', 'uri'), '/', 3) as ":END_ID",
sum(ladderq(records.created_at::TIMESTAMP)) as "count:long" sum(ladderq(records.created_at::TIMESTAMP)) as "count:long"
from records join repos on records.repo = repos.id from records join repos on records.repo = repos.id
where records.collection = 'app.bsky.feed.post' where records.collection = 'app.bsky.feed.post'
and records.created_at > CURRENT_DATE - INTERVAL '240' DAY
and repos.did <> split_part(jsonb_extract_path_text(content, 'reply', 'parent', 'uri'), '/', 3) and repos.did <> split_part(jsonb_extract_path_text(content, 'reply', 'parent', 'uri'), '/', 3)
group by repos.did, split_part(jsonb_extract_path_text(content, 'reply', 'parent', 'uri'), '/', 3) group by repos.did, split_part(jsonb_extract_path_text(content, 'reply', 'parent', 'uri'), '/', 3)
with no data; with no data;
create index export_reply_subject_ladder on export_replies_ladder (":END_ID"); create index export_reply_subject_ladder on export_replies_ladder (":END_ID");
drop materialized view export_dids_ladder;
create materialized view export_dids_ladder create materialized view export_dids_ladder
as select distinct did as "did:ID" from ( as select distinct did as "did:ID" from (
select did from repos select did from repos