From fae406c573f85b5f83b213533786631fe8bba866 Mon Sep 17 00:00:00 2001
From: quettabit <dwarak@s2.dev>
Date: Sun, 10 Aug 2025 02:47:51 -0600
Subject: [PATCH] initial commit

---
 src/streamstore/_mappers.py | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/streamstore/_mappers.py b/src/streamstore/_mappers.py
index 68abb48..d6ed45c 100644
--- a/src/streamstore/_mappers.py
+++ b/src/streamstore/_mappers.py
@@ -36,7 +36,9 @@
 
 def append_record_message(record: Record) -> msgs.AppendRecord:
     headers = [msgs.Header(name=name, value=value) for (name, value) in record.headers]
-    return msgs.AppendRecord(headers=headers, body=record.body)
+    return msgs.AppendRecord(
+        timestamp=record.timestamp, headers=headers, body=record.body
+    )
 
 
 def append_input_message(stream: str, input: AppendInput) -> msgs.AppendInput: