feat: impl SearchNewAppInfos

app/sephirah/internal/biz/bizgebura/app_info.go

@@ -6,10 +6,12 @@ import (
 	"strconv"
 
 	"github.com/tuihub/librarian/app/sephirah/internal/biz/bizutils"
+	"github.com/tuihub/librarian/app/sephirah/internal/model/converter"
 	"github.com/tuihub/librarian/app/sephirah/internal/model/modelangela"
 	"github.com/tuihub/librarian/app/sephirah/internal/model/modelgebura"
 	"github.com/tuihub/librarian/internal/lib/libauth"
 	"github.com/tuihub/librarian/internal/model"
+	porter "github.com/tuihub/protos/pkg/librarian/porter/v1"
 	searcherpb "github.com/tuihub/protos/pkg/librarian/searcher/v1"
 	pb "github.com/tuihub/protos/pkg/librarian/sephirah/v1"
 
@@ -147,6 +149,34 @@ func (g *Gebura) SearchAppInfos(ctx context.Context, paging model.Paging, query
 	return res, 0, nil
 }
 
+func (g *Gebura) SearchNewAppInfos(
+	ctx context.Context,
+	paging model.Paging,
+	name string,
+	sourceFilter []string,
+) ([]*modelgebura.AppInfo, int, *errors.Error) {
+	if libauth.FromContextAssertUserType(ctx) == nil {
+		return nil, 0, bizutils.NoPermissionError()
+	}
+	if len(sourceFilter) == 0 {
+		sourceFilter = g.supv.GetFeatureSummary().SupportedAppInfoSources
+	}
+	if len(sourceFilter) == 0 {
+		return nil, 0, pb.ErrorErrorReasonBadRequest("no available info source")
+	}
+	var infos []*modelgebura.AppInfo
+	for _, source := range sourceFilter {
+		info, err := g.porter.SearchAppInfo(g.supv.CallAppInfoSource(ctx, source), &porter.SearchAppInfoRequest{
+			Name: name,
+		})
+		if err != nil {
+			continue
+		}
+		infos = append(infos, converter.ToBizAppInfoList(info.GetAppInfos())...)
+	}
+	return infos, 0, nil
+}
+
 func (g *Gebura) GetAppInfo(ctx context.Context, id model.InternalID) (*modelgebura.AppInfo, *errors.Error) {
 	if libauth.FromContextAssertUserType(ctx) == nil {
 		return nil, bizutils.NoPermissionError()

app/sephirah/internal/biz/bizgebura/gebura.go

@@ -7,10 +7,12 @@ import (
 	"github.com/tuihub/librarian/app/sephirah/internal/client"
 	"github.com/tuihub/librarian/app/sephirah/internal/model/modelangela"
 	"github.com/tuihub/librarian/app/sephirah/internal/model/modelgebura"
+	"github.com/tuihub/librarian/app/sephirah/internal/supervisor"
 	"github.com/tuihub/librarian/internal/lib/libauth"
 	"github.com/tuihub/librarian/internal/lib/libcache"
 	"github.com/tuihub/librarian/internal/lib/libmq"
 	"github.com/tuihub/librarian/internal/model"
+	porter "github.com/tuihub/protos/pkg/librarian/porter/v1"
 
 	"github.com/go-kratos/kratos/v2/errors"
 )
@@ -53,6 +55,8 @@ type Gebura struct {
 	repo GeburaRepo
 	// mapper         mapper.LibrarianMapperServiceClient
 	searcher           *client.Searcher
+	porter             porter.LibrarianPorterServiceClient
+	supv               *supervisor.Supervisor
 	updateAppInfoIndex *libmq.Topic[modelangela.UpdateAppInfoIndex]
 	pullAppInfo        *libmq.Topic[modelangela.PullAppInfo]
 	appInfoCache       *libcache.Map[modelgebura.AppInfoID, modelgebura.AppInfo]
@@ -63,6 +67,8 @@ func NewGebura(
 	auth *libauth.Auth,
 	// mClient mapper.LibrarianMapperServiceClient,
 	sClient *client.Searcher,
+	pClient porter.LibrarianPorterServiceClient,
+	supv *supervisor.Supervisor,
 	updateAppIndex *libmq.Topic[modelangela.UpdateAppInfoIndex],
 	pullAppInfo *libmq.Topic[modelangela.PullAppInfo],
 	appInfoCache *libcache.Map[modelgebura.AppInfoID, modelgebura.AppInfo],
@@ -72,6 +78,8 @@ func NewGebura(
 		repo: repo,
 		//mapper:         mClient,
 		searcher:           sClient,
+		porter:             pClient,
+		supv:               supv,
 		updateAppInfoIndex: updateAppIndex,
 		pullAppInfo:        pullAppInfo,
 		appInfoCache:       appInfoCache,

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

@@ -144,6 +144,9 @@ func ToBizDeviceInfo(a *pb.DeviceInfo) *modeltiphereth.DeviceInfo {
 func ToBizAppInfo(a *librarian.AppInfo) *modelgebura.AppInfo {
 	return toBiz.ToBizAppInfo(a)
 }
+func ToBizAppInfoList(a []*librarian.AppInfo) []*modelgebura.AppInfo {
+	return toBiz.ToBizAppInfoList(a)
+}
 func ToBizAppInfoID(a *librarian.AppInfoID) *modelgebura.AppInfoID {
 	return toBiz.ToBizAppInfoID(a)
 }

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

@@ -58,6 +58,7 @@ type toBizConverter interface { //nolint:unused // used by generator
 	// goverter:ignore BoundInternal
 	// goverter:ignore LatestUpdateTime
 	ToBizAppInfo(*librarian.AppInfo) *modelgebura.AppInfo
+	ToBizAppInfoList([]*librarian.AppInfo) []*modelgebura.AppInfo
 	// goverter:matchIgnoreCase
 	ToBizAppInfoDetail(*librarian.AppInfoDetails) *modelgebura.AppInfoDetails
 	ToBizAppTypeList([]librarian.AppType) []modelgebura.AppType

app/sephirah/internal/service/gebura.go

@@ -98,6 +98,22 @@ func (s *LibrarianSephirahServiceService) SearchAppInfos(ctx context.Context, re
 		AppInfos: converter.ToPBAppInfoMixedList(infos),
 	}, nil
 }
+func (s *LibrarianSephirahServiceService) SearchNewAppInfos(ctx context.Context, req *pb.SearchNewAppInfosRequest) (
+	*pb.SearchNewAppInfosResponse, error,
+) {
+	infos, total, err := s.g.SearchNewAppInfos(ctx,
+		model.ToBizPaging(req.GetPaging()),
+		req.GetName(),
+		req.GetSourceFilter(),
+	)
+	if err != nil {
+		return nil, err
+	}
+	return &pb.SearchNewAppInfosResponse{
+		Paging:   &librarian.PagingResponse{TotalSize: int64(total)},
+		AppInfos: converter.ToPBAppInfoList(infos),
+	}, nil
+}
 func (s *LibrarianSephirahServiceService) GetAppInfo(ctx context.Context, req *pb.GetAppInfoRequest) (
 	*pb.GetAppInfoResponse, error,
 ) {