summaryrefslogtreecommitdiff
path: root/src/repo/channel.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/repo/channel.rs')
-rw-r--r--src/repo/channel.rs8
1 files changed, 5 insertions, 3 deletions
diff --git a/src/repo/channel.rs b/src/repo/channel.rs
index e85b898..6514426 100644
--- a/src/repo/channel.rs
+++ b/src/repo/channel.rs
@@ -2,7 +2,7 @@ use std::fmt;
use sqlx::{sqlite::Sqlite, SqliteConnection, Transaction};
-use crate::{clock::DateTime, id::Id as BaseId};
+use crate::{clock::DateTime, events::types::Sequence, id::Id as BaseId};
pub trait Provider {
fn channels(&mut self) -> Channels;
@@ -31,13 +31,14 @@ impl<'c> Channels<'c> {
created_at: &DateTime,
) -> Result<Channel, sqlx::Error> {
let id = Id::generate();
+ let sequence = Sequence::default();
let channel = sqlx::query_as!(
Channel,
r#"
insert
- into channel (id, name, created_at)
- values ($1, $2, $3)
+ into channel (id, name, created_at, last_sequence)
+ values ($1, $2, $3, $4)
returning
id as "id: Id",
name,
@@ -46,6 +47,7 @@ impl<'c> Channels<'c> {
id,
name,
created_at,
+ sequence,
)
.fetch_one(&mut *self.0)
.await?;