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