aboutsummaryrefslogtreecommitdiffstats
path: root/adenosine-pds/src/repo.rs
diff options
context:
space:
mode:
Diffstat (limited to 'adenosine-pds/src/repo.rs')
-rw-r--r--adenosine-pds/src/repo.rs19
1 files changed, 9 insertions, 10 deletions
diff --git a/adenosine-pds/src/repo.rs b/adenosine-pds/src/repo.rs
index 442f81b..c75ba15 100644
--- a/adenosine-pds/src/repo.rs
+++ b/adenosine-pds/src/repo.rs
@@ -8,7 +8,6 @@ use libipld::multihash::Code;
use libipld::prelude::Codec;
use libipld::store::DefaultParams;
use libipld::{Block, Cid, Ipld};
-use log::debug;
use std::borrow::Cow;
use std::collections::BTreeMap;
use std::collections::HashSet;
@@ -74,7 +73,7 @@ impl RepoStore {
record: &S,
) -> Result<String> {
let block = Block::<DefaultParams>::encode(DagCborCodec, Code::Sha2_256, record)?;
- let cid = block.cid().clone();
+ let cid = *block.cid();
self.db
.put_block(block, None)
.context("writing IPLD DAG-CBOR record to blockstore")?;
@@ -84,7 +83,7 @@ impl RepoStore {
/// Returns CID that was inserted
pub fn put_blob(&mut self, data: &[u8]) -> Result<String> {
let block = Block::<DefaultParams>::encode(libipld::raw::RawCodec, Code::Sha2_256, data)?;
- let cid = block.cid().clone();
+ let cid = *block.cid();
self.db
.put_block(block, None)
.context("writing non-record blob to blockstore")?;
@@ -164,7 +163,7 @@ impl RepoStore {
let mut collections: HashSet<String> = Default::default();
// XXX: confirm that keys actually start with leading slash
for k in map.keys() {
- let coll = k.split("/").nth(1).unwrap();
+ let coll = k.split('/').nth(1).unwrap();
collections.insert(coll.to_string());
}
Ok(collections.into_iter().collect())
@@ -216,16 +215,16 @@ impl RepoStore {
})?;
self.db
.alias(did.as_bytes().to_vec(), Some(&Cid::from_str(&commit_cid)?))?;
- Ok(commit_cid.to_string())
+ Ok(commit_cid)
}
pub fn mst_from_map(&mut self, map: &BTreeMap<String, String>) -> Result<String> {
// TODO: not unwrap in iter
- let mut cid_map: BTreeMap<String, Cid> = BTreeMap::from_iter(
+ let cid_map: BTreeMap<String, Cid> = BTreeMap::from_iter(
map.iter()
- .map(|(k, v)| (k.to_string(), Cid::from_str(&v).unwrap())),
+ .map(|(k, v)| (k.to_string(), Cid::from_str(v).unwrap())),
);
- let mst_cid = generate_mst(&mut self.db, &mut cid_map)?;
+ let mst_cid = generate_mst(&mut self.db, &cid_map)?;
Ok(mst_cid.to_string())
}
@@ -237,7 +236,7 @@ impl RepoStore {
Ok(cid_map)
}
- pub fn update_mst(&mut self, mst_cid: &str, mutations: &Vec<Mutation>) -> Result<String> {
+ pub fn update_mst(&mut self, mst_cid: &str, mutations: &[Mutation]) -> Result<String> {
let mut cid_map = self.mst_to_cid_map(mst_cid)?;
for m in mutations.iter() {
match m {
@@ -254,7 +253,7 @@ impl RepoStore {
}
}
}
- let mst_cid = generate_mst(&mut self.db, &mut cid_map)?;
+ let mst_cid = generate_mst(&mut self.db, &cid_map)?;
Ok(mst_cid.to_string())
}