From 8dbd6313e52d4102697706dd9013a073c8bfe719 Mon Sep 17 00:00:00 2001
From: Bojan Serafimov <bojan.serafimov7@gmail.com>
Date: Tue, 3 May 2022 12:40:17 -0400
Subject: [PATCH] WIP

---
 pageserver/src/bin/replay.rs | 19 +++++++++++++++++++
 1 file changed, 19 insertions(+)
 create mode 100644 pageserver/src/bin/replay.rs

diff --git a/pageserver/src/bin/replay.rs b/pageserver/src/bin/replay.rs
new file mode 100644
index 0000000000..12977f5f65
--- /dev/null
+++ b/pageserver/src/bin/replay.rs
@@ -0,0 +1,19 @@
+use std::fs::File;
+use anyhow::Result;
+use postgres_ffi::waldecoder::WalStreamDecoder;
+use utils::lsn::Lsn;
+
+
+#[tokio::main]
+async fn main() -> Result<()> {
+    let partial_path = "/home/bojan/tmp/pg_wal/000000010000000000000017";
+    let startpos = Lsn(0);
+    let bytes = std::fs::read(partial_path)?;
+
+    let mut decoder = WalStreamDecoder::new(startpos);
+    decoder.feed_bytes(&bytes);
+    while let Some((lsn, rec)) = decoder.poll_decode()? {
+        println!("lsn: {}", lsn);
+    }
+    Ok(())
+}