fix: add original id to the stream

This commit is contained in:
Namekuji 2023-08-06 15:04:14 -04:00
parent 1a34dee366
commit 10e81de1a6
No known key found for this signature in database
GPG key ID: 1D62332C07FBA532

View file

@ -35,7 +35,7 @@ impl MigrationTrait for Migration {
redis_conn.del::<_, ()>(key).unwrap();
for (j, v) in stream_ids.enumerate() {
redis_conn
.xadd(key, v, &[("note", &all_elems[j])])
.xadd(key, v, &[("note", &all_elems[j][1][1])])
.unwrap_or(());
}