From 1d967007207f9516709bfe92f02d7268a8b2ab70 Mon Sep 17 00:00:00 2001 From: lxcode Date: Thu, 6 Jun 2024 16:51:55 +0100 Subject: [PATCH] Record ReplyCount --- pkg/hydrator/hydrator.go | 1 + pkg/output/bq/schema/schema.go | 10 ++++++++++ 2 files changed, 11 insertions(+) diff --git a/pkg/hydrator/hydrator.go b/pkg/hydrator/hydrator.go index 95a2824..f7b8bf5 100644 --- a/pkg/hydrator/hydrator.go +++ b/pkg/hydrator/hydrator.go @@ -247,6 +247,7 @@ func (h *Hydrator) flattenPostView(post *bsky.FeedDefs_PostView) (result map[str result["CID"] = post.Cid result["LikeCount"] = post.LikeCount result["RepostCount"] = post.RepostCount + result["ReplyCount"] = post.ReplyCount result["LikeCount"] = post.LikeCount result["URI"] = post.Uri diff --git a/pkg/output/bq/schema/schema.go b/pkg/output/bq/schema/schema.go index 32334eb..9c64b39 100644 --- a/pkg/output/bq/schema/schema.go +++ b/pkg/output/bq/schema/schema.go @@ -312,6 +312,11 @@ func GetSchema() bigquery.Schema { "name": "LikeCount", "type": "INTEGER" }, + { + "mode": "NULLABLE", + "name": "ReplyCount", + "type": "INTEGER" + }, { "mode": "NULLABLE", "name": "RepostCount", @@ -660,6 +665,11 @@ func GetSchema() bigquery.Schema { "name": "RepostCount", "type": "INTEGER" }, + { + "mode": "NULLABLE", + "name": "ReplyCount", + "type": "INTEGER" + }, { "mode": "NULLABLE", "name": "Text",