aboutsummaryrefslogtreecommitdiff
path: root/import/src/plugins/infojson.rs
diff options
context:
space:
mode:
Diffstat (limited to 'import/src/plugins/infojson.rs')
-rw-r--r--import/src/plugins/infojson.rs6
1 files changed, 3 insertions, 3 deletions
diff --git a/import/src/plugins/infojson.rs b/import/src/plugins/infojson.rs
index 3a48ce8..a48fca5 100644
--- a/import/src/plugins/infojson.rs
+++ b/import/src/plugins/infojson.rs
@@ -175,7 +175,7 @@ impl ImportPlugin for Infojson {
let data = serde_json::from_reader::<_, YVideo>(BufReader::new(File::open(path)?))?;
let title = clean_uploader_name(&data.title);
- ct.dba.db.transaction(&mut |txn| {
+ ct.ic.db.transaction(&mut |txn| {
let mut node = txn.get(parent)?.unwrap();
node = node.as_object().insert(NO_KIND, KIND_CHANNEL);
node = node.as_object().insert(NO_TITLE, title);
@@ -210,7 +210,7 @@ impl ImportPlugin for Infojson {
.find(is_info_json)
.map(|att| {
let data = ct
- .dba
+ .ic
.cache
.read(str::from_utf8(&att.data).unwrap())?
.ok_or(anyhow!("info json cache missing"))?;
@@ -236,7 +236,7 @@ impl ImportPlugin for Infojson {
KIND_VIDEO
};
- ct.dba.db.transaction(&mut |txn| {
+ ct.ic.db.transaction(&mut |txn| {
let mut node = txn.get(row)?.unwrap();
node = node.as_object().insert(NO_KIND, kind);
node = node.as_object().insert(NO_TITLE, &infojson.title);