t1c.dev
forked from
rocksky.app/rocksky
A decentralized music tracking and discovery platform built on AT Protocol 馃幍
tsiry-sandratraina.com
1use std::sync::{Arc, Mutex};
2
3use crate::core::*;
4use anyhow::Error;
5use duckdb::Connection;
6use sqlx::{Pool, Postgres};
7
8pub async fn sync(conn: Arc<Mutex<Connection>>, pool: &Pool<Postgres>) -> Result<(), Error> {
9 load_tracks(conn.clone(), pool).await?;
10 load_artists(conn.clone(), pool).await?;
11 load_albums(conn.clone(), pool).await?;
12 load_users(conn.clone(), pool).await?;
13 load_scrobbles(conn.clone(), pool).await?;
14 load_album_tracks(conn.clone(), pool).await?;
15 load_loved_tracks(conn.clone(), pool).await?;
16 load_artist_tracks(conn.clone(), pool).await?;
17 load_artist_albums(conn.clone(), pool).await?;
18 load_user_albums(conn.clone(), pool).await?;
19 load_user_artists(conn.clone(), pool).await?;
20 load_user_tracks(conn.clone(), pool).await?;
21
22 Ok(())
23}