Merge branch 'r/paopao-ce-pro' into r/paopao-ce-xtra

internal/dao/slonik/slonik.go

@@ -49,24 +49,12 @@ func NewDataService() (core.DataService, core.VersionInfo) {
 	var (
 		v   core.VersionInfo
 		cis core.CacheIndexService
-		ips core.IndexPostsService
 	)
 	db := pgxDB()
 	pvs := security.NewPhoneVerifyService()
 	ams := NewAuthorizationManageService()
 	ths := newTweetHelpService(db)
-
-	// initialize core.IndexPostsService
-	if cfg.If("Friendship") {
-		ips = newFriendIndexService(db, ams, ths)
-	} else if cfg.If("Followship") {
-		ips = newFollowIndexService(db, ths)
-	} else if cfg.If("Lightship") {
-		ips = newLightIndexService(db, ths)
-	} else {
-		// default use lightship post index service
-		ips = newLightIndexService(db, ths)
-	}
+	ips := newShipIndexService(db, ams, ths)
 
 	// initialize core.CacheIndexService
 	cfg.On(cfg.Actions{

internal/dao/slonik/timeline.go

@@ -13,62 +13,23 @@ import (
 )
 
 var (
-	_ core.IndexPostsService = (*friendIndexSrv)(nil)
-	_ core.IndexPostsService = (*followIndexSrv)(nil)
-	_ core.IndexPostsService = (*lightIndexSrv)(nil)
+	_ core.IndexPostsService = (*shipIndexSrv)(nil)
 	_ core.IndexPostsService = (*simpleIndexPostsSrv)(nil)
 )
 
-type friendIndexSrv struct {
+type shipIndexSrv struct {
 	*pgxSrv
 	ams core.AuthorizationManageService
 	ths core.TweetHelpService
 }
 
-type followIndexSrv struct {
-	*pgxSrv
-	ths core.TweetHelpService
-}
-
-type lightIndexSrv struct {
-	*pgxSrv
-	ths core.TweetHelpService
-}
-
 type simpleIndexPostsSrv struct {
 	*pgxSrv
 	ths core.TweetHelpService
 }
 
 // IndexPosts 根据userId查询广场推文列表，简单做到不同用户的主页都是不同的；
-func (s *friendIndexSrv) IndexPosts(user *ms.User, offset int, limit int) (*ms.IndexTweetList, error) {
-	// TODO
-	return nil, debug.ErrNotImplemented
-}
-
-func (s *friendIndexSrv) TweetTimeline(userId int64, offset int, limit int) (*cs.TweetBox, error) {
-	// TODO
-	return nil, debug.ErrNotImplemented
-}
-
-// IndexPosts 根据userId查询广场推文列表，简单做到不同用户的主页都是不同的；
-func (s *followIndexSrv) IndexPosts(user *ms.User, offset int, limit int) (*ms.IndexTweetList, error) {
-	// TODO
-	return nil, debug.ErrNotImplemented
-}
-
-func (s *followIndexSrv) TweetTimeline(userId int64, offset int, limit int) (*cs.TweetBox, error) {
-	// TODO
-	return nil, debug.ErrNotImplemented
-}
-
-// IndexPosts 根据userId查询广场推文列表，简单做到不同用户的主页都是不同的；
-func (s *lightIndexSrv) IndexPosts(user *ms.User, offset int, limit int) (*ms.IndexTweetList, error) {
-	// TODO
-	return nil, debug.ErrNotImplemented
-}
-
-func (s *lightIndexSrv) TweetTimeline(userId int64, offset int, limit int) (*cs.TweetBox, error) {
+func (s *shipIndexSrv) IndexPosts(user *ms.User, offset int, limit int) (*ms.IndexTweetList, error) {
 	// TODO
 	return nil, debug.ErrNotImplemented
 }
@@ -84,27 +45,13 @@ func (s *simpleIndexPostsSrv) TweetTimeline(userId int64, offset int, limit int)
 	return nil, debug.ErrNotImplemented
 }
 
-func newFriendIndexService(db *pgx.Conn, ams core.AuthorizationManageService, ths core.TweetHelpService) core.IndexPostsService {
-	return &friendIndexSrv{
+func newShipIndexService(db *pgx.Conn, ams core.AuthorizationManageService, ths core.TweetHelpService) core.IndexPostsService {
+	return &shipIndexSrv{
 		ams:    ams,
 		pgxSrv: newPgxSrv(db),
 	}
 }
 
-func newFollowIndexService(db *pgx.Conn, ths core.TweetHelpService) core.IndexPostsService {
-	return &followIndexSrv{
-		ths:    ths,
-		pgxSrv: newPgxSrv(db),
-	}
-}
-
-func newLightIndexService(db *pgx.Conn, ths core.TweetHelpService) core.IndexPostsService {
-	return &lightIndexSrv{
-		ths:    ths,
-		pgxSrv: newPgxSrv(db),
-	}
-}
-
 func newSimpleIndexPostsService(db *pgx.Conn, ths core.TweetHelpService) core.IndexPostsService {
 	return &simpleIndexPostsSrv{
 		ths:    ths,