pub async fn upsert_download_event<'q, 'e, E>(
    executor: E,
    uuid: String,
    status: String,
) -> Result<(), sqlx::Error>
where
    E: Executor<'e>,
    E::Database: sqlx::Database,
    DateTime<Utc>: sqlx::Type< E::Database > + sqlx::Encode<'q, E::Database>,
    String: sqlx::Type< E::Database > + sqlx::Encode<'q, E::Database>
{
    let query = sqlx::query(
        r#"
        INSERT INTO m3u8_download_event (
            created_at,
            updated_at,
            uuid,
            status
        )
        VALUES ($1, $2, $3, $4)
        ON CONFLICT (uuid) DO UPDATE
        SET updated_at = EXCLUDED.updated_at,
            status = EXCLUDED.status
        "#,
    )
    .bind(Utc::now())
    .bind(Utc::now())
    .bind(uuid)
    .bind(status);

    query.execute(executor).await?;

    Ok(())
}