+5
-11
appview/ingester.go
+5
-11
appview/ingester.go
···
885
record := tangled.RepoIssueComment{}
886
err = json.Unmarshal(raw, &record)
887
if err != nil {
888
-
l.Error("invalid record", "err", err)
889
-
return err
890
}
891
892
comment, err := db.IssueCommentFromRecord(ddb, did, rkey, record)
893
if err != nil {
894
-
l.Error("failed to parse comment from record", "err", err)
895
-
return err
896
}
897
898
sanitizer := markup.NewSanitizer()
···
902
903
err = db.NewIssueComment(ddb, &comment)
904
if err != nil {
905
-
l.Error("failed to create issue comment", "err", err)
906
-
return err
907
}
908
909
return nil
···
913
record := tangled.RepoIssueComment{}
914
err = json.Unmarshal(raw, &record)
915
if err != nil {
916
-
l.Error("invalid record", "err", err)
917
-
return err
918
}
919
920
sanitizer := markup.NewSanitizer()
···
924
925
err = db.UpdateCommentByRkey(ddb, did, rkey, record.Body)
926
if err != nil {
927
-
l.Error("failed to update issue comment", "err", err)
928
-
return err
929
}
930
931
return nil
932
933
case models.CommitOperationDelete:
934
if err := db.DeleteCommentByRkey(ddb, did, rkey); err != nil {
935
-
l.Error("failed to delete", "err", err)
936
return fmt.Errorf("failed to delete issue comment record: %w", err)
937
}
938
···
885
record := tangled.RepoIssueComment{}
886
err = json.Unmarshal(raw, &record)
887
if err != nil {
888
+
return fmt.Errorf("invalid record: %w", err)
889
}
890
891
comment, err := db.IssueCommentFromRecord(ddb, did, rkey, record)
892
if err != nil {
893
+
return fmt.Errorf("failed to parse comment from record: %w", err)
894
}
895
896
sanitizer := markup.NewSanitizer()
···
900
901
err = db.NewIssueComment(ddb, &comment)
902
if err != nil {
903
+
return fmt.Errorf("failed to create issue comment: %w", err)
904
}
905
906
return nil
···
910
record := tangled.RepoIssueComment{}
911
err = json.Unmarshal(raw, &record)
912
if err != nil {
913
+
return fmt.Errorf("invalid record: %w", err)
914
}
915
916
sanitizer := markup.NewSanitizer()
···
920
921
err = db.UpdateCommentByRkey(ddb, did, rkey, record.Body)
922
if err != nil {
923
+
return fmt.Errorf("failed to update issue comment: %w", err)
924
}
925
926
return nil
927
928
case models.CommitOperationDelete:
929
if err := db.DeleteCommentByRkey(ddb, did, rkey); err != nil {
930
return fmt.Errorf("failed to delete issue comment record: %w", err)
931
}
932