pub async fn find_by_upstream_id(
    conn: &mut PgConnection,
    upstream_id: i32
) -> ModelResult<Option<User>>