diff options
author | Teddy Wing | 2021-05-30 01:19:14 +0200 |
---|---|---|
committer | Teddy Wing | 2021-05-30 01:19:14 +0200 |
commit | 37cbbc279736f10224ec36356eb2b7620b028081 (patch) | |
tree | 2f9bab187b855d1cb055cb655826512121bff4b7 /src | |
parent | 98cc67ceb69eea34e61ca08e51cd89a4bb483d66 (diff) | |
download | reflectub-37cbbc279736f10224ec36356eb2b7620b028081.tar.bz2 |
database: Change `GithubRepo` arguments to `Repo`
Also change `repo_insert()` to take only a single repo instead of a
slice of them.
Diffstat (limited to 'src')
-rw-r--r-- | src/database.rs | 28 |
1 files changed, 13 insertions, 15 deletions
diff --git a/src/database.rs b/src/database.rs index 4c14f2e..83a27b3 100644 --- a/src/database.rs +++ b/src/database.rs @@ -77,23 +77,21 @@ impl Db { pub async fn repo_insert( &mut self, - repos: &[GithubRepo], + repo: Repo, ) -> Result<(), Box<dyn std::error::Error>> { let mut tx = self.connection.begin().await?; - for repo in repos { - sqlx::query(r#" - INSERT INTO repositories - (id, name, updated_at) - VALUES - (?, ?, ?) - "#) - .bind(repo.id) - .bind(&repo.name) - .bind(&repo.updated_at) - .execute(&mut tx) - .await?; - } + sqlx::query(r#" + INSERT INTO repositories + (id, name, updated_at) + VALUES + (?, ?, ?) + "#) + .bind(repo.id) + .bind(&repo.name) + .bind(&repo.updated_at) + .execute(&mut tx) + .await?; tx.commit().await?; @@ -105,7 +103,7 @@ impl Db { Ok(false) } - pub fn repo_update(repo: &GithubRepo) -> Result<(), Box<dyn std::error::Error>> { + pub fn repo_update(repo: &Repo) -> Result<(), Box<dyn std::error::Error>> { Ok(()) } } |