summaryrefslogtreecommitdiff
path: root/src/conversation/repo.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/conversation/repo.rs')
-rw-r--r--src/conversation/repo.rs15
1 files changed, 5 insertions, 10 deletions
diff --git a/src/conversation/repo.rs b/src/conversation/repo.rs
index e40a5bd..7e38b62 100644
--- a/src/conversation/repo.rs
+++ b/src/conversation/repo.rs
@@ -59,9 +59,8 @@ impl Conversations<'_> {
created,
id,
name: name.clone(),
- deleted_at: None,
+ deleted: None,
},
- deleted: None,
};
Ok(conversation)
@@ -93,9 +92,8 @@ impl Conversations<'_> {
created: Instant::new(row.created_at, row.created_sequence),
id: row.id,
name: Name::optional(row.display_name, row.canonical_name)?.unwrap_or_default(),
- deleted_at: row.deleted_at,
+ deleted: Instant::optional(row.deleted_at, row.deleted_sequence),
},
- deleted: Instant::optional(row.deleted_at, row.deleted_sequence),
})
})
.fetch_one(&mut *self.0)
@@ -131,9 +129,8 @@ impl Conversations<'_> {
created: Instant::new(row.created_at, row.created_sequence),
id: row.id,
name: Name::optional(row.display_name, row.canonical_name)?.unwrap_or_default(),
- deleted_at: row.deleted_at,
+ deleted: Instant::optional(row.deleted_at, row.deleted_sequence),
},
- deleted: Instant::optional(row.deleted_at, row.deleted_sequence),
})
})
.fetch(&mut *self.0)
@@ -170,9 +167,8 @@ impl Conversations<'_> {
created: Instant::new(row.created_at, row.created_sequence),
id: row.id,
name: Name::optional(row.display_name, row.canonical_name)?.unwrap_or_default(),
- deleted_at: row.deleted_at,
+ deleted: Instant::optional(row.deleted_at, row.deleted_sequence),
},
- deleted: Instant::optional(row.deleted_at, row.deleted_sequence),
})
})
.fetch(&mut *self.0)
@@ -297,9 +293,8 @@ impl Conversations<'_> {
created: Instant::new(row.created_at, row.created_sequence),
id: row.id,
name: Name::optional(row.display_name, row.canonical_name)?.unwrap_or_default(),
- deleted_at: row.deleted_at,
+ deleted: Instant::optional(row.deleted_at, row.deleted_sequence),
},
- deleted: Instant::optional(row.deleted_at, row.deleted_sequence),
})
})
.fetch(&mut *self.0)