Initial commit

app/bff/bff/internal/server/server.go

@@ -313,7 +313,6 @@ func (s *Server) Initialize() error {
 				MessageClient:  c.BizServiceClient,
 				MediaClient:    c.MediaClient,
 				UsernameClient: c.BizServiceClient,
-				WebpageClient:  c.BizServiceClient,
 				SyncClient:     c.SyncClient,
 			}))
 

app/bff/messages/internal/config/config.go

@@ -34,6 +34,5 @@ type Config struct {
 	MessageClient  zrpc.RpcClientConf
 	MediaClient    zrpc.RpcClientConf
 	UsernameClient zrpc.RpcClientConf
-	WebpageClient  zrpc.RpcClientConf
 	SyncClient     *kafka.KafkaProducerConf
 }

app/bff/messages/internal/core/core_messages_helper.go

@@ -17,7 +17,6 @@ import (
 	"github.com/teamgram/proto/mtproto"
 	userpb "github.com/teamgram/teamgram-server/app/service/biz/user/user"
 	"github.com/teamgram/teamgram-server/app/service/biz/username/username"
-	webpagepb "github.com/teamgram/teamgram-server/app/service/biz/webpage/webpage"
 	mediapb "github.com/teamgram/teamgram-server/app/service/media/media"
 	"github.com/teamgram/teamgram-server/pkg/mention"
 	"github.com/teamgram/teamgram-server/pkg/phonenumber"
@@ -388,16 +387,16 @@ func (c *MessagesCore) fixMessageEntities(fromId int64, peer *mtproto.PeerUtil,
 		}
 
 		if canEmbedLink {
-			// TODO(@benqi): disable
-			if webpage, err := c.svcCtx.Dao.WebpageClient.WebpageGetWebPagePreview(c.ctx, &webpagepb.TLWebpageGetWebPagePreview{
-				Message: firstUrl,
-			}); err != nil {
-				// nil
-			} else {
-				message.Media = mtproto.MakeTLMessageMediaWebPage(&mtproto.MessageMedia{
-					Webpage: webpage,
-				}).To_MessageMedia()
-			}
+			//// TODO(@benqi): disable
+			//if webpage, err := c.svcCtx.Dao.WebpageClient.WebpageGetWebPagePreview(c.ctx, &webpagepb.TLWebpageGetWebPagePreview{
+			//	Message: firstUrl,
+			//}); err != nil {
+			//	// nil
+			//} else {
+			//	message.Media = mtproto.MakeTLMessageMediaWebPage(&mtproto.MessageMedia{
+			//		Webpage: webpage,
+			//	}).To_MessageMedia()
+			//}
 		}
 	}
 

app/bff/messages/internal/dao/dao.go

@@ -29,7 +29,6 @@ import (
 	message_client "github.com/teamgram/teamgram-server/app/service/biz/message/client"
 	user_client "github.com/teamgram/teamgram-server/app/service/biz/user/client"
 	username_client "github.com/teamgram/teamgram-server/app/service/biz/username/client"
-	webpage_client "github.com/teamgram/teamgram-server/app/service/biz/webpage/client"
 	idgen_client "github.com/teamgram/teamgram-server/app/service/idgen/client"
 	media_client "github.com/teamgram/teamgram-server/app/service/media/client"
 )
@@ -39,7 +38,6 @@ type Dao struct {
 	user_client.UserClient
 	chat_client.ChatClient
 	media_client.MediaClient
-	webpage_client.WebpageClient
 	username_client.UsernameClient
 	message_client.MessageClient
 	idgen_client.IDGenClient2
@@ -53,7 +51,6 @@ func New(c config.Config) *Dao {
 		UserClient:     user_client.NewUserClient(rpcx.GetCachedRpcClient(c.UserClient)),
 		ChatClient:     chat_client.NewChatClient(rpcx.GetCachedRpcClient(c.ChatClient)),
 		MediaClient:    media_client.NewMediaClient(rpcx.GetCachedRpcClient(c.MediaClient)),
-		WebpageClient:  webpage_client.NewWebpageClient(rpcx.GetCachedRpcClient(c.WebpageClient)),
 		DialogClient:   dialog_client.NewDialogClient(rpcx.GetCachedRpcClient(c.DialogClient)),
 		IDGenClient2:   idgen_client.NewIDGenClient2(rpcx.GetCachedRpcClient(c.IdgenClient)),
 		MessageClient:  message_client.NewMessageClient(rpcx.GetCachedRpcClient(c.MessageClient)),

app/service/biz/biz/internal/server/server.go

@@ -37,8 +37,7 @@ import (
 	"github.com/teamgram/teamgram-server/app/service/biz/user/user"
 	username_helper "github.com/teamgram/teamgram-server/app/service/biz/username"
 	"github.com/teamgram/teamgram-server/app/service/biz/username/username"
-	webpage_helper "github.com/teamgram/teamgram-server/app/service/biz/webpage"
-	"github.com/teamgram/teamgram-server/app/service/biz/webpage/webpage"
+
 	"github.com/zeromicro/go-zero/core/conf"
 	"github.com/zeromicro/go-zero/core/logx"
 	"github.com/zeromicro/go-zero/zrpc"
@@ -141,14 +140,6 @@ func (s *Server) Initialize() error {
 				Mysql:         c.Mysql,
 				Cache:         c.Cache,
 			}))
-
-		// webpage_helper
-		webpage.RegisterRPCWebpageServer(
-			grpcServer,
-			webpage_helper.New(webpage_helper.Config{
-				RpcServerConf: c.RpcServerConf,
-				Mysql:         c.Mysql,
-			}))
 	})
 
 	// logx.Must(err)