From 8e76f57f956fa713849226c00720c07ecd24f238 Mon Sep 17 00:00:00 2001
From: oppiliappan <me@oppi.li>
Date: Tue, 16 Sep 2025 14:46:02 +0100
Subject: [PATCH] appview/ingester: ingest sh.tangled.label.definition

Signed-off-by: oppiliappan <me@oppi.li>
---
 appview/ingester.go    | 58 +++++++++++++++++++++++++++++++++++++++++-
 appview/state/state.go |  1 +
 2 files changed, 58 insertions(+), 1 deletion(-)

diff --git a/appview/ingester.go b/appview/ingester.go
index 4e37802e..91b150a2 100644
--- a/appview/ingester.go
+++ b/appview/ingester.go
@@ -77,6 +77,8 @@ func (i *Ingester) Ingest() processFunc {
 				err = i.ingestIssue(ctx, e)
 			case tangled.RepoIssueCommentNSID:
 				err = i.ingestIssueComment(e)
+			case tangled.LabelDefinitionNSID:
+				err = i.ingestLabelDefinition(e)
 			}
 			l = i.Logger.With("nsid", e.Commit.Collection)
 		}
@@ -866,7 +868,7 @@ func (i *Ingester) ingestIssueComment(e *models.Event) error {
 			return fmt.Errorf("invalid record: %w", err)
 		}
 
-		comment, err := db.IssueCommentFromRecord(ddb, did, rkey, record)
+		comment, err := db.IssueCommentFromRecord(did, rkey, record)
 		if err != nil {
 			return fmt.Errorf("failed to parse comment from record: %w", err)
 		}
@@ -896,3 +898,57 @@ func (i *Ingester) ingestIssueComment(e *models.Event) error {
 
 	return nil
 }
+
+func (i *Ingester) ingestLabelDefinition(e *models.Event) error {
+	did := e.Did
+	rkey := e.Commit.RKey
+
+	var err error
+
+	l := i.Logger.With("handler", "ingestLabelDefinition", "nsid", e.Commit.Collection, "did", did, "rkey", rkey)
+	l.Info("ingesting record")
+
+	ddb, ok := i.Db.Execer.(*db.DB)
+	if !ok {
+		return fmt.Errorf("failed to index label definition, invalid db cast")
+	}
+
+	switch e.Commit.Operation {
+	case models.CommitOperationCreate, models.CommitOperationUpdate:
+		raw := json.RawMessage(e.Commit.Record)
+		record := tangled.LabelDefinition{}
+		err = json.Unmarshal(raw, &record)
+		if err != nil {
+			return fmt.Errorf("invalid record: %w", err)
+		}
+
+		def, err := db.LabelDefinitionFromRecord(did, rkey, record)
+		if err != nil {
+			return fmt.Errorf("failed to parse labeldef from record: %w", err)
+		}
+
+		if err := i.Validator.ValidateLabelDefinition(def); err != nil {
+			return fmt.Errorf("failed to validate labeldef: %w", err)
+		}
+
+		_, err = db.AddLabelDefinition(ddb, def)
+		if err != nil {
+			return fmt.Errorf("failed to create labeldef: %w", err)
+		}
+
+		return nil
+
+	case models.CommitOperationDelete:
+		if err := db.DeleteLabelDefinition(
+			ddb,
+			db.FilterEq("did", did),
+			db.FilterEq("rkey", rkey),
+		); err != nil {
+			return fmt.Errorf("failed to delete labeldef record: %w", err)
+		}
+
+		return nil
+	}
+
+	return nil
+}
diff --git a/appview/state/state.go b/appview/state/state.go
index 419a5ccb..9a4d540c 100644
--- a/appview/state/state.go
+++ b/appview/state/state.go
@@ -102,6 +102,7 @@ func Make(ctx context.Context, config *config.Config) (*State, error) {
 			tangled.StringNSID,
 			tangled.RepoIssueNSID,
 			tangled.RepoIssueCommentNSID,
+			tangled.LabelDefinitionNSID,
 		},
 		nil,
 		slog.Default(),
-- 
2.51.2