From affbd927ef478d00cf675e67d77b0aa73c1833ac Mon Sep 17 00:00:00 2001
From: dhawos <git.6fnul@passmail.net>
Date: Sun, 28 Jun 2026 14:25:08 +0200
Subject: [PATCH] fix indexing timestamp

---
 indexer/firehose.go | 15 +++++++++++----
 1 file changed, 11 insertions(+), 4 deletions(-)

diff --git a/indexer/firehose.go b/indexer/firehose.go
index 010b94d..4db7057 100644
--- a/indexer/firehose.go
+++ b/indexer/firehose.go
@@ -8,6 +8,7 @@ import (
 	"log/slog"
 	"net/http"
 	"slices"
+	"time"
 
 	"github.com/bluesky-social/indigo/api/atproto"
 	"github.com/bluesky-social/indigo/api/bsky"
@@ -107,12 +108,18 @@ func (fh *FirehoseListener) SubscribeFirehose(ctx context.Context, channels *Blu
 
 func HandlePosts(ctx context.Context, input <-chan *BlueskyPost, es *elasticsearch.TypedClient) {
 	for post := range input {
+		createdAt, err := time.Parse(time.RFC3339Nano, post.post.CreatedAt)
+		if err != nil {
+			slog.Error("parsing post time", slog.Any("err", err))
+			return
+		}
 		if slices.Contains(post.post.Langs, "fr") {
 			err := insertPost(ctx, es, &PostDocument{
-				Cid:     post.cid,
-				Text:    post.post.Text,
-				Likes:   0,
-				Reposts: 0,
+				Cid:       post.cid,
+				Text:      post.post.Text,
+				Likes:     0,
+				Reposts:   0,
+				CreatedAt: createdAt,
 			})
 			if err != nil {
 				slog.Error("failed to index post", slog.Any("err", err))
-- 
2.51.2