From 38e72c6c4f405f6b265f69b6e2748452c81f704b Mon Sep 17 00:00:00 2001 From: Alexander Batischev Date: Wed, 21 Jul 2021 22:19:47 +0300 Subject: Replace IndexResult with plain Result --- src/index.rs | 35 ++++++++++++++++------------------- 1 file changed, 16 insertions(+), 19 deletions(-) (limited to 'src') diff --git a/src/index.rs b/src/index.rs index 887238c..e6bbb95 100644 --- a/src/index.rs +++ b/src/index.rs @@ -33,11 +33,8 @@ pub enum IndexError { SqlError(#[from] rusqlite::Error), } -/// A result from an `Index` operation. -pub type IndexResult = Result; - impl Index { - pub fn new>(dirname: P) -> IndexResult { + pub fn new>(dirname: P) -> Result { let filename = dirname.as_ref().join("meta.db"); let conn = if filename.exists() { sql::open_db(&filename)? @@ -53,30 +50,30 @@ impl Index { }) } - pub fn insert_meta(&mut self, id: ChunkId, meta: ChunkMeta) -> IndexResult<()> { + pub fn insert_meta(&mut self, id: ChunkId, meta: ChunkMeta) -> Result<(), IndexError> { let t = self.conn.transaction()?; sql::insert(&t, &id, &meta)?; t.commit()?; Ok(()) } - pub fn get_meta(&self, id: &ChunkId) -> IndexResult { + pub fn get_meta(&self, id: &ChunkId) -> Result { sql::lookup(&self.conn, id) } - pub fn remove_meta(&mut self, id: &ChunkId) -> IndexResult<()> { + pub fn remove_meta(&mut self, id: &ChunkId) -> Result<(), IndexError> { sql::remove(&self.conn, id) } - pub fn find_by_sha256(&self, sha256: &str) -> IndexResult> { + pub fn find_by_sha256(&self, sha256: &str) -> Result, IndexError> { sql::find_by_256(&self.conn, sha256) } - pub fn find_generations(&self) -> IndexResult> { + pub fn find_generations(&self) -> Result, IndexError> { sql::find_generations(&self.conn) } - pub fn all_chunks(&self) -> IndexResult> { + pub fn all_chunks(&self) -> Result, IndexError> { sql::find_chunk_ids(&self.conn) } } @@ -155,14 +152,14 @@ mod test { } mod sql { - use super::{IndexError, IndexResult}; + use super::IndexError; use crate::chunkid::ChunkId; use crate::chunkmeta::ChunkMeta; use log::error; use rusqlite::{params, Connection, OpenFlags, Row, Transaction}; use std::path::Path; - pub fn create_db(filename: &Path) -> IndexResult { + pub fn create_db(filename: &Path) -> Result { let flags = OpenFlags::SQLITE_OPEN_CREATE | OpenFlags::SQLITE_OPEN_READ_WRITE; let conn = Connection::open_with_flags(filename, flags)?; conn.execute( @@ -178,14 +175,14 @@ mod sql { Ok(conn) } - pub fn open_db(filename: &Path) -> IndexResult { + pub fn open_db(filename: &Path) -> Result { let flags = OpenFlags::SQLITE_OPEN_READ_WRITE; let conn = Connection::open_with_flags(filename, flags)?; conn.pragma_update(None, "journal_mode", &"WAL")?; Ok(conn) } - pub fn insert(t: &Transaction, chunkid: &ChunkId, meta: &ChunkMeta) -> IndexResult<()> { + pub fn insert(t: &Transaction, chunkid: &ChunkId, meta: &ChunkMeta) -> Result<(), IndexError> { let chunkid = format!("{}", chunkid); let sha256 = meta.sha256(); let generation = if meta.is_generation() { 1 } else { 0 }; @@ -197,12 +194,12 @@ mod sql { Ok(()) } - pub fn remove(conn: &Connection, chunkid: &ChunkId) -> IndexResult<()> { + pub fn remove(conn: &Connection, chunkid: &ChunkId) -> Result<(), IndexError> { conn.execute("DELETE FROM chunks WHERE id IS ?1", params![chunkid])?; Ok(()) } - pub fn lookup(conn: &Connection, id: &ChunkId) -> IndexResult { + pub fn lookup(conn: &Connection, id: &ChunkId) -> Result { let mut stmt = conn.prepare("SELECT * FROM chunks WHERE id IS ?1")?; let iter = stmt.query_map(params![id], |row| row_to_meta(row))?; let mut metas: Vec = vec![]; @@ -225,7 +222,7 @@ mod sql { Ok(r) } - pub fn find_by_256(conn: &Connection, sha256: &str) -> IndexResult> { + pub fn find_by_256(conn: &Connection, sha256: &str) -> Result, IndexError> { let mut stmt = conn.prepare("SELECT id FROM chunks WHERE sha256 IS ?1")?; let iter = stmt.query_map(params![sha256], |row| row_to_id(row))?; let mut ids = vec![]; @@ -236,7 +233,7 @@ mod sql { Ok(ids) } - pub fn find_generations(conn: &Connection) -> IndexResult> { + pub fn find_generations(conn: &Connection) -> Result, IndexError> { let mut stmt = conn.prepare("SELECT id FROM chunks WHERE generation IS 1")?; let iter = stmt.query_map(params![], |row| row_to_id(row))?; let mut ids = vec![]; @@ -247,7 +244,7 @@ mod sql { Ok(ids) } - pub fn find_chunk_ids(conn: &Connection) -> IndexResult> { + pub fn find_chunk_ids(conn: &Connection) -> Result, IndexError> { let mut stmt = conn.prepare("SELECT id FROM chunks WHERE generation IS 0")?; let iter = stmt.query_map(params![], |row| row_to_id(row))?; let mut ids = vec![]; -- cgit v1.2.1