feat: impl CreateFeedActionSet UpdateFeedActionSet `ListFeedActio…

…nSets`

app/sephirah/internal/biz/bizyesod/feed_action.go

@@ -0,0 +1,57 @@
+package bizyesod
+
+import (
+	"context"
+
+	"github.com/tuihub/librarian/app/sephirah/internal/biz/bizutils"
+	"github.com/tuihub/librarian/app/sephirah/internal/model/modelyesod"
+	"github.com/tuihub/librarian/internal/lib/libauth"
+	"github.com/tuihub/librarian/internal/model"
+	pb "github.com/tuihub/protos/pkg/librarian/sephirah/v1"
+
+	"github.com/go-kratos/kratos/v2/errors"
+)
+
+func (y *Yesod) CreateFeedActionSet(
+	ctx context.Context,
+	set *modelyesod.FeedActionSet,
+) (model.InternalID, *errors.Error) {
+	claims := libauth.FromContextAssertUserType(ctx)
+	if claims == nil {
+		return 0, bizutils.NoPermissionError()
+	}
+	id, err := y.searcher.NewID(ctx)
+	if err != nil {
+		return 0, pb.ErrorErrorReasonUnspecified("%s", err.Error())
+	}
+	set.ID = id
+	err = y.repo.CreateFeedActionSet(ctx, claims.UserID, set)
+	if err != nil {
+		return 0, pb.ErrorErrorReasonUnspecified("%s", err.Error())
+	}
+	return set.ID, nil
+}
+
+func (y *Yesod) UpdateFeedActionSet(ctx context.Context, set *modelyesod.FeedActionSet) *errors.Error {
+	claims := libauth.FromContextAssertUserType(ctx)
+	if claims == nil {
+		return bizutils.NoPermissionError()
+	}
+	err := y.repo.UpdateFeedActionSet(ctx, claims.UserID, set)
+	if err != nil {
+		return pb.ErrorErrorReasonUnspecified("%s", err.Error())
+	}
+	return nil
+}
+
+func (y *Yesod) ListFeedActionSets(ctx context.Context, paging model.Paging) ([]*modelyesod.FeedActionSet, int, *errors.Error) {
+	claims := libauth.FromContextAssertUserType(ctx)
+	if claims == nil {
+		return nil, 0, bizutils.NoPermissionError()
+	}
+	sets, total, err := y.repo.ListFeedActionSets(ctx, claims.UserID, paging)
+	if err != nil {
+		return nil, 0, pb.ErrorErrorReasonUnspecified("%s", err.Error())
+	}
+	return sets, total, nil
+}

app/sephirah/internal/biz/bizyesod/yesod.go

@@ -53,6 +53,9 @@ type YesodRepo interface {
 	ListFeedItemsInCollection(context.Context, model.InternalID, model.Paging, []model.InternalID, []string,
 		[]string, []string, *model.TimeRange) ([]*modelyesod.FeedItemDigest, int, error)
 	GetFeedOwner(context.Context, model.InternalID) (*modeltiphereth.User, error)
+	CreateFeedActionSet(context.Context, model.InternalID, *modelyesod.FeedActionSet) error
+	UpdateFeedActionSet(context.Context, model.InternalID, *modelyesod.FeedActionSet) error
+	ListFeedActionSets(context.Context, model.InternalID, model.Paging) ([]*modelyesod.FeedActionSet, int, error)
 }
 
 type Yesod struct {

app/sephirah/internal/data/internal/converter/converter.go

@@ -100,6 +100,9 @@ func ToBizFeedConfig(a *ent.FeedConfig) *modelyesod.FeedConfig {
 func ToBizFeedConfigList(a []*ent.FeedConfig) []*modelyesod.FeedConfig {
 	return toBiz.ToBizFeedConfigList(a)
 }
+func ToBizFeedActionSetList(a []*ent.FeedActionSet) []*modelyesod.FeedActionSet {
+	return toBiz.ToBizFeedActionSetList(a)
+}
 func ToBizFeed(a *ent.Feed) *modelfeed.Feed {
 	return toBiz.ToBizFeed(a)
 }

app/sephirah/internal/data/internal/converter/ent_to_biz.go

@@ -113,6 +113,10 @@ type toBizConverter interface { //nolint:unused // used by generator
 	// goverter:enum:map LatestPullStatusFailed FeedConfigPullStatusFailed
 	ToBizFeedConfigPullStatus(feedconfig.LatestPullStatus) modelyesod.FeedConfigPullStatus
 
+	// goverter:matchIgnoreCase
+	ToBizFeedActionSet(*ent.FeedActionSet) *modelyesod.FeedActionSet
+	ToBizFeedActionSetList([]*ent.FeedActionSet) []*modelyesod.FeedActionSet
+
 	// goverter:matchIgnoreCase
 	// goverter:ignore Items
 	// goverter:ignore FeedType

app/sephirah/internal/data/yesod.go

@@ -8,6 +8,7 @@ import (
 	"github.com/tuihub/librarian/app/sephirah/internal/data/internal/converter"
 	"github.com/tuihub/librarian/app/sephirah/internal/data/internal/ent"
 	"github.com/tuihub/librarian/app/sephirah/internal/data/internal/ent/feed"
+	"github.com/tuihub/librarian/app/sephirah/internal/data/internal/ent/feedactionset"
 	"github.com/tuihub/librarian/app/sephirah/internal/data/internal/ent/feedconfig"
 	"github.com/tuihub/librarian/app/sephirah/internal/data/internal/ent/feeditem"
 	"github.com/tuihub/librarian/app/sephirah/internal/data/internal/ent/feeditemcollection"
@@ -43,7 +44,8 @@ func (y *yesodRepo) CreateFeedConfig(ctx context.Context, owner model.InternalID
 		SetPullInterval(c.PullInterval).
 		SetLatestPullStatus(converter.ToEntFeedConfigLatestPullStatus(c.LatestPullStatus)).
 		SetLatestPullMessage("").
-		SetHideItems(c.HideItems)
+		SetHideItems(c.HideItems).
+		AddFeedActionSetIDs(c.ActionSets...)
 	return q.Exec(ctx)
 }
 
@@ -74,6 +76,9 @@ func (y *yesodRepo) UpdateFeedConfig(ctx context.Context, userID model.InternalI
 	if c.PullInterval > 0 {
 		q.SetPullInterval(c.PullInterval).SetNextPullBeginAt(time.Now())
 	}
+	if c.ActionSets != nil {
+		q.ClearFeedActionSet().AddFeedActionSetIDs(c.ActionSets...)
+	}
 	q.SetHideItems(c.HideItems)
 	return q.Exec(ctx)
 }
@@ -522,3 +527,51 @@ func (y *yesodRepo) GetFeedOwner(ctx context.Context, id model.InternalID) (*mod
 	}
 	return converter.ToBizUser(only), nil
 }
+
+func (y *yesodRepo) CreateFeedActionSet(ctx context.Context, id model.InternalID, set *modelyesod.FeedActionSet) error {
+	return y.data.db.FeedActionSet.Create().
+		SetOwnerID(id).
+		SetID(set.ID).
+		SetName(set.Name).
+		SetDescription(set.Description).
+		SetActions(set.Actions).
+		Exec(ctx)
+}
+
+func (y *yesodRepo) UpdateFeedActionSet(ctx context.Context, id model.InternalID, set *modelyesod.FeedActionSet) error {
+	return y.data.db.FeedActionSet.UpdateOneID(set.ID).
+		Where(feedactionset.HasOwnerWith(user.IDEQ(id))).
+		SetName(set.Name).
+		SetDescription(set.Description).
+		SetActions(set.Actions).
+		Exec(ctx)
+}
+
+func (y *yesodRepo) ListFeedActionSets(ctx context.Context, id model.InternalID, paging model.Paging) ([]*modelyesod.FeedActionSet, int, error) {
+	var res []*modelyesod.FeedActionSet
+	var total int
+	err := y.data.WithTx(ctx, func(tx *ent.Tx) error {
+		u, err := tx.User.Get(ctx, id)
+		if err != nil {
+			return err
+		}
+		q := tx.User.QueryFeedActionSet(u)
+		total, err = q.Count(ctx)
+		if err != nil {
+			return err
+		}
+		sets, err := q.
+			Limit(paging.ToLimit()).
+			Offset(paging.ToOffset()).
+			All(ctx)
+		if err != nil {
+			return err
+		}
+		res = converter.ToBizFeedActionSetList(sets)
+		return nil
+	})
+	if err != nil {
+		return nil, 0, err
+	}
+	return res, total, nil
+}

app/sephirah/internal/model/converter/biz_to_pb.go

@@ -141,6 +141,10 @@ type toPBConverter interface { //nolint:unused // used by generator
 	ToPBFeedItemDigest(*modelyesod.FeedItemDigest) *pb.FeedItemDigest
 	ToPBFeedItemDigestList([]*modelyesod.FeedItemDigest) []*pb.FeedItemDigest
 
+	// goverter:matchIgnoreCase
+	ToPBFeedActionSet(*modelyesod.FeedActionSet) *pb.FeedActionSet
+	ToPBFeedActionSetList([]*modelyesod.FeedActionSet) []*pb.FeedActionSet
+
 	// goverter:matchIgnoreCase
 	ToPBFeedItemCollection(*modelyesod.FeedItemCollection) *pb.FeedItemCollection
 	ToPBFeedItemCollectionList([]*modelyesod.FeedItemCollection) []*pb.FeedItemCollection

app/sephirah/internal/model/converter/converter.go

@@ -90,6 +90,9 @@ func ToPBEnclosure(a *modelfeed.Enclosure) *librarian.FeedEnclosure {
 func ToPBFeedConfig(a *modelyesod.FeedConfig) *pb.FeedConfig {
 	return toPB.ToPBFeedConfig(a)
 }
+func ToPBFeedActionSetList(a []*modelyesod.FeedActionSet) []*pb.FeedActionSet {
+	return toPB.ToPBFeedActionSetList(a)
+}
 func ToPBFeedWithConfig(a *modelyesod.FeedWithConfig) *pb.ListFeedConfigsResponse_FeedWithConfig {
 	return toPB.ToPBFeedWithConfig(a)
 }
@@ -184,6 +187,9 @@ func ToBizFeedConfigStatusList(a []pb.FeedConfigStatus) []modelyesod.FeedConfigS
 func ToBizFeedItemCollection(a *pb.FeedItemCollection) *modelyesod.FeedItemCollection {
 	return toBiz.ToBizFeedItemCollection(a)
 }
+func ToBizFeedActionSet(a *pb.FeedActionSet) *modelyesod.FeedActionSet {
+	return toBiz.ToBizFeedActionSet(a)
+}
 func ToBizTimeRange(a *librarian.TimeRange) *model.TimeRange {
 	return toBiz.ToBizTimeRange(a)
 }

app/sephirah/internal/model/converter/pb_to_biz.go

@@ -115,6 +115,9 @@ type toBizConverter interface { //nolint:unused // used by generator
 	ToBizFeedConfigPullStatus(pb.FeedConfigPullStatus) modelyesod.FeedConfigPullStatus
 	ToBizFeedConfigStatusList([]pb.FeedConfigStatus) []modelyesod.FeedConfigStatus
 
+	// goverter:matchIgnoreCase
+	ToBizFeedActionSet(*pb.FeedActionSet) *modelyesod.FeedActionSet
+
 	// goverter:matchIgnoreCase
 	ToBizFeedItemCollection(*pb.FeedItemCollection) *modelyesod.FeedItemCollection
 

app/sephirah/internal/service/yesod.go

@@ -54,6 +54,46 @@ func (s *LibrarianSephirahServiceService) ListFeedConfigs(
 		FeedsWithConfig: converter.ToPBFeedWithConfigList(feeds),
 	}, nil
 }
+func (s *LibrarianSephirahServiceService) CreateFeedActionSet(
+	ctx context.Context,
+	req *pb.CreateFeedActionSetRequest,
+) (*pb.CreateFeedActionSetResponse, error) {
+	id, err := s.y.CreateFeedActionSet(ctx, converter.ToBizFeedActionSet(req.GetActionSet()))
+	if err != nil {
+		return nil, err
+	}
+	return &pb.CreateFeedActionSetResponse{
+		Id: converter.ToPBInternalID(id),
+	}, nil
+}
+func (s *LibrarianSephirahServiceService) UpdateFeedActionSet(
+	ctx context.Context,
+	req *pb.UpdateFeedActionSetRequest,
+) (*pb.UpdateFeedActionSetResponse, error) {
+	err := s.y.UpdateFeedActionSet(ctx, converter.ToBizFeedActionSet(req.GetActionSet()))
+	if err != nil {
+		return nil, err
+	}
+	return &pb.UpdateFeedActionSetResponse{}, nil
+}
+func (s *LibrarianSephirahServiceService) ListFeedActionSets(
+	ctx context.Context,
+	req *pb.ListFeedActionSetsRequest,
+) (*pb.ListFeedActionSetsResponse, error) {
+	if req.GetPaging() == nil {
+		return nil, pb.ErrorErrorReasonBadRequest("")
+	}
+	actions, total, err := s.y.ListFeedActionSets(ctx,
+		model.ToBizPaging(req.GetPaging()),
+	)
+	if err != nil {
+		return nil, err
+	}
+	return &pb.ListFeedActionSetsResponse{
+		Paging:     &librarian.PagingResponse{TotalSize: int64(total)},
+		ActionSets: converter.ToPBFeedActionSetList(actions),
+	}, nil
+}
 func (s *LibrarianSephirahServiceService) ListFeedCategories(
 	ctx context.Context,
 	req *pb.ListFeedCategoriesRequest,