feat: support searching character & person

canal/canal.go

@@ -26,6 +26,8 @@ import (
 
 	"github.com/bangumi/server/config"
 	"github.com/bangumi/server/dal"
+	"github.com/bangumi/server/internal/character"
+	"github.com/bangumi/server/internal/person"
 	"github.com/bangumi/server/internal/pkg/cache"
 	"github.com/bangumi/server/internal/pkg/driver"
 	"github.com/bangumi/server/internal/pkg/logger"
@@ -62,7 +64,8 @@ func Main() error {
 		fx.Provide(
 			driver.NewMysqlSqlDB,
 			driver.NewRueidisClient, logger.Copy, cache.NewRedisCache,
-			subject.NewMysqlRepo, search.New, session.NewMysqlRepo, session.New,
+			subject.NewMysqlRepo, character.NewMysqlRepo, person.NewMysqlRepo,
+			search.New, session.NewMysqlRepo, session.New,
 			driver.NewS3,
 			tag.NewCachedRepo,
 			tag.NewMysqlRepo,

canal/event.go

@@ -124,6 +124,10 @@
 		err = e.OnSubjectField(ctx, key, p)
 	case "chii_subjects":
 		err = e.OnSubject(ctx, key, p)
+	case "chii_characters":
+		err = e.OnCharacter(ctx, key, p)
+	case "chii_persons":
+		err = e.OnPerson(ctx, key, p)
 	case "chii_members":
 		err = e.OnUserChange(ctx, key, p)
 	}

canal/on_character.go

@@ -0,0 +1,45 @@
+package canal
+
+import (
+	"context"
+	"encoding/json"
+
+	"github.com/trim21/errgo"
+	"go.uber.org/zap"
+
+	"github.com/bangumi/server/internal/model"
+	"github.com/bangumi/server/internal/search"
+)
+
+type CharacterKey struct {
+	ID model.CharacterID `json:"crt_id"`
+}
+
+func (e *eventHandler) OnCharacter(ctx context.Context, key json.RawMessage, payload Payload) error {
+	var k CharacterKey
+	if err := json.Unmarshal(key, &k); err != nil {
+		return err
+	}
+	return e.onCharacterChange(ctx, k.ID, payload.Op)
+}
+
+func (e *eventHandler) onCharacterChange(ctx context.Context, characterID model.CharacterID, op string) error {
+	switch op {
+	case opCreate:
+		if err := e.search.EventAdded(ctx, characterID, search.SearchTargetCharacter); err != nil {
+			return errgo.Wrap(err, "search.OnCharacterAdded")
+		}
+	case opUpdate, opSnapshot:
+		if err := e.search.EventUpdate(ctx, characterID, search.SearchTargetCharacter); err != nil {
+			return errgo.Wrap(err, "search.OnCharacterUpdate")
+		}
+	case opDelete:
+		if err := e.search.EventDelete(ctx, characterID, search.SearchTargetCharacter); err != nil {
+			return errgo.Wrap(err, "search.OnCharacterDelete")
+		}
+	default:
+		e.log.Warn("unexpected operator", zap.String("op", op))
+	}
+
+	return nil
+}

canal/on_person.go

@@ -0,0 +1,44 @@
+package canal
+
+import (
+	"context"
+	"encoding/json"
+
+	"github.com/trim21/errgo"
+	"go.uber.org/zap"
+
+	"github.com/bangumi/server/internal/model"
+	"github.com/bangumi/server/internal/search"
+)
+
+type PersonKey struct {
+	ID model.PersonID `json:"prsn_id"`
+}
+
+func (e *eventHandler) OnPerson(ctx context.Context, key json.RawMessage, payload Payload) error {
+	var k PersonKey
+	if err := json.Unmarshal(key, &k); err != nil {
+		return err
+	}
+	return e.onPersonChange(ctx, k.ID, payload.Op)
+}
+
+func (e *eventHandler) onPersonChange(ctx context.Context, personID model.PersonID, op string) error {
+	switch op {
+	case opCreate:
+		if err := e.search.EventAdded(ctx, personID, search.SearchTargetPerson); err != nil {
+			return errgo.Wrap(err, "search.OnPersonAdded")
+		}
+	case opUpdate, opSnapshot:
+		if err := e.search.EventUpdate(ctx, personID, search.SearchTargetPerson); err != nil {
+			return errgo.Wrap(err, "search.OnPersonUpdate")
+		}
+	case opDelete:
+		if err := e.search.EventDelete(ctx, personID, search.SearchTargetPerson); err != nil {
+			return errgo.Wrap(err, "search.OnPersonDelete")
+		}
+	default:
+		e.log.Warn("unexpected operator", zap.String("op", op))
+	}
+	return nil
+}

canal/on_subject.go

@@ -22,8 +22,17 @@
 	"go.uber.org/zap"
 
 	"github.com/bangumi/server/internal/model"
+	"github.com/bangumi/server/internal/search"
 )
 
+type SubjectKey struct {
+	ID model.SubjectID `json:"subject_id"`
+}
+
+type SubjectFieldKey struct {
+	ID model.SubjectID `json:"field_sid"`
+}
+
 func (e *eventHandler) OnSubject(ctx context.Context, key json.RawMessage, payload Payload) error {
 	var k SubjectKey
 	if err := json.Unmarshal(key, &k); err != nil {
@@ -45,15 +54,15 @@
 func (e *eventHandler) onSubjectChange(ctx context.Context, subjectID model.SubjectID, op string) error {
 	switch op {
 	case opCreate:
-		if err := e.search.OnSubjectAdded(ctx, subjectID); err != nil {
+		if err := e.search.EventAdded(ctx, subjectID, search.SearchTargetSubject); err != nil {
 			return errgo.Wrap(err, "search.OnSubjectAdded")
 		}
 	case opUpdate, opSnapshot:
-		if err := e.search.OnSubjectUpdate(ctx, subjectID); err != nil {
+		if err := e.search.EventUpdate(ctx, subjectID, search.SearchTargetSubject); err != nil {
 			return errgo.Wrap(err, "search.OnSubjectUpdate")
 		}
 	case opDelete:
-		if err := e.search.OnSubjectDelete(ctx, subjectID); err != nil {
+		if err := e.search.EventDelete(ctx, subjectID, search.SearchTargetSubject); err != nil {
 			return errgo.Wrap(err, "search.OnSubjectDelete")
 		}
 	default:
@@ -62,11 +71,3 @@
 
 	return nil
 }
-
-type SubjectKey struct {
-	ID model.SubjectID `json:"subject_id"`
-}
-
-type SubjectFieldKey struct {
-	ID model.SubjectID `json:"field_sid"`
-}

cmd/web/cmd.go

@@ -88,7 +88,8 @@ func start() error {
 			index.NewMysqlRepo, auth.NewMysqlRepo, episode.NewMysqlRepo, revision.NewMysqlRepo, infra.NewMysqlRepo,
 			timeline.NewMysqlRepo, pm.NewMysqlRepo, notification.NewMysqlRepo,
 
-			dam.New, subject.NewMysqlRepo, subject.NewCachedRepo, person.NewMysqlRepo,
+			dam.New, subject.NewMysqlRepo, subject.NewCachedRepo,
+			character.NewMysqlRepo, person.NewMysqlRepo,
 
 			tag.NewCachedRepo, tag.NewMysqlRepo,