From d4d298e1ac2c1e6d4a1859c98def828da0681158 Mon Sep 17 00:00:00 2001
From: Mike Dilger <mike@mikedilger.com>
Date: Tue, 20 Feb 2024 07:54:20 +1300
Subject: [PATCH] Store: ci index, ordered by created_at (reverse)

---
 src/store/mod.rs | 23 ++++++++++++++++++++++-
 1 file changed, 22 insertions(+), 1 deletion(-)

diff --git a/src/store/mod.rs b/src/store/mod.rs
index edddf3a..6b2424b 100644
--- a/src/store/mod.rs
+++ b/src/store/mod.rs
@@ -17,6 +17,7 @@ pub struct Store {
     events: EventStore,
     env: Env,
     ids: Database<UnalignedSlice<u8>, OwnedType<usize>>,
+    ci: Database<UnalignedSlice<u8>, OwnedType<usize>>,
     akci: Database<UnalignedSlice<u8>, OwnedType<usize>>,
     atci: Database<UnalignedSlice<u8>, OwnedType<usize>>,
     ktci: Database<UnalignedSlice<u8>, OwnedType<usize>>,
@@ -57,6 +58,11 @@ impl Store {
             .types::<UnalignedSlice<u8>, OwnedType<usize>>()
             .name("ids")
             .create(&mut txn)?;
+        let ci = env
+            .database_options()
+            .types::<UnalignedSlice<u8>, OwnedType<usize>>()
+            .name("ci")
+            .create(&mut txn)?;
         let akci = env
             .database_options()
             .types::<UnalignedSlice<u8>, OwnedType<usize>>()
@@ -101,6 +107,7 @@ impl Store {
             events,
             env,
             ids,
+            ci,
             akci,
             atci,
             ktci,
@@ -404,6 +411,10 @@ impl Store {
         // Index by id
         self.ids.put(txn, event.id().0.as_slice(), &offset)?;
 
+        // Index by created_at and id
+        self.ci
+            .put(txn, &Self::key_ci(event.created_at(), event.id()), &offset)?;
+
         // Index by author and kind (with created_at and id)
         self.akci.put(
             txn,
@@ -484,7 +495,9 @@ impl Store {
             }
         }
 
-        // Index by author and kind (with created_at and id)
+        self.ci
+            .delete(txn, &Self::key_ci(event.created_at(), event.id()))?;
+
         self.akci.delete(
             txn,
             &Self::key_akci(event.pubkey(), event.kind(), event.created_at(), event.id()),
@@ -585,6 +598,14 @@ impl Store {
         Ok(())
     }
 
+    fn key_ci(created_at: Time, id: Id) -> Vec<u8> {
+        let mut key: Vec<u8> =
+            Vec::with_capacity(std::mem::size_of::<Time>() + std::mem::size_of::<Id>());
+        key.extend((u64::MAX - created_at.0).to_be_bytes().as_slice());
+        key.extend(id.as_slice());
+        key
+    }
+
     // For looking up event by Author and Kind
     // author(32) + kind(2) + reversecreatedat(8) + id(32)
     #[allow(dead_code)]