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",