Add Trait for Database<T> and Transaction<T> about arangors HOT 4 CLOSED

trait DbClient {
    async fn aql_query<R>(&self, aql: AqlQuery<'_>) -> Result<Vec<R>, ClientError>
        where R: DeserializeOwned + Send;
}

impl<T> DbClient for Database<T>
    where T: ClientExt + Send {
    async fn aql_query<R>(&self, aql: AqlQuery<'_>) -> Result<Vec<R>, ClientError>
        where R: DeserializeOwned + Send {
        self.aql_query(aql).await
    }
}

impl<T> DbClient for Transaction<T>
    where T: ClientExt + Send {
    async fn aql_query<R>(&self, aql: AqlQuery<'_>) -> Result<Vec<R>, ClientError>
        where R: DeserializeOwned + Send {
        self.aql_query(aql).await
    }
}

impl<T> UserDAO for T
where T: DbClient + Send + Sync{
    async fn add_user(&self, user: User) -> Result<User, DAOError> {
        let json = serde_json::value::to_value(&user).unwrap();

    let aql = AqlQuery::builder()
        .query(r#"
                INSERT @user INTO @@collection
                LET result = NEW
                RETURN {_id:result._id, _key:result._key, _rev:result._rev}
                "#)
        .bind_var("user", json)
        .bind_var("@collection", USERS_COLLECTION)
        .build();

    let resp: Vec<DocumentHeader> = db.aql_query(aql).await?;

    if let Some(header) = resp.into_iter().next() {
        user.document_header = Some(header);
        return Ok(user);
    }
    Err("Response was empty".into())
    }
}