script

internal/push/offlinepush/fcm/push.go

@@ -39,7 +39,7 @@ func NewClient(cache cache.Model) *Fcm {
 		panic(err.Error())
 		return nil
 	}
-	return &Fcm{fcmMsgCli: fcmMsgClient}
+	return &Fcm{fcmMsgCli: fcmMsgClient, cache: cache}
 }
 
 func (f *Fcm) Push(ctx context.Context, userIDs []string, title, content string, opts *offlinepush.Opts) error {

internal/push/push_to_client.go

@@ -95,7 +95,6 @@ func (p *Pusher) MsgToUser(ctx context.Context, userID string, msg *sdkws.MsgDat
 				return nil
 			}
 		}
-
 		if err := callbackOfflinePush(ctx, userIDs, msg, &[]string{}); err != nil {
 			return err
 		}

pkg/common/cmd/rpc.go

@@ -3,6 +3,7 @@ package cmd
 import (
 	"OpenIM/internal/startrpc"
 	"OpenIM/pkg/discoveryregistry"
+	"fmt"
 	"github.com/spf13/cobra"
 	"google.golang.org/grpc"
 )
@@ -18,6 +19,7 @@ func NewRpcCmd(rpcRegisterName string) *RpcCmd {
 
 func (r *RpcCmd) AddRpc(rpcFn func(client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) error) {
 	r.Command.RunE = func(cmd *cobra.Command, args []string) error {
+		fmt.Println(r.getPortFlag(cmd), r.rpcRegisterName, r.getPrometheusPortFlag(cmd), rpcFn)
 		return startrpc.Start(r.getPortFlag(cmd), r.rpcRegisterName, r.getPrometheusPortFlag(cmd), rpcFn)
 	}
 }