Function export_topics

backend/src/bin/export.rs:343–427

(builder: &mut Mutation, pool: &PgPool)

}

async fn export_topics(builder: &mut Mutation, pool: &PgPool) -> Result<()> {
    log::info!("saving topic blobs");

    let rows = sqlx::query_as::<_, TopicMetadataRow>(
        r#"select
            t.name,
            t.id::varchar,
            t.synonyms,
            t.root,
            t.created_at added,
            t.repository_id,
            tr.starts_at timerange_starts,
            tr.prefix_format timerange_prefix_format

        from topics t
        left join timeranges tr on tr.id = t.timerange_id"#,
    )
    .fetch_all(pool)
    .await
    .unwrap();

    for meta in &rows {
        let repo_id = RepoId::try_from(&meta.repository_id.to_string()).unwrap();
        let topic_id = sha256_id(&meta.id);

        let parent_topics = sqlx::query_as::<_, ParentTopicRow>(
            r#"select
                t.repository_id,
                tt.parent_id::varchar id,
                t.name

            from topic_topics tt
            join topics t on t.id = tt.parent_id
            left join timeranges tr on tr.id = t.timerange_id
            where tt.child_id = $1::uuid
            order by t.name"#,
        )
        .bind(&meta.id)
        .fetch_all(pool)
        .await
        .unwrap();

        let children = sqlx::query_as::<_, TopicChildRow>(
            r#"(
                select
                    t.created_at added,
                    'Topic' kind,
                    t.repository_id,
                    t.id::varchar,
                    t.name,
                    'url' as url

                from topic_topics tt
                join topics t on t.id = tt.child_id
                where tt.parent_id = $1::uuid
                order by t.name
            )