diff --git a/internal/push/offlinepush/fcm/push.go b/internal/push/offlinepush/fcm/push.go index 77b8c8f7a..0d29d4d1c 100644 --- a/internal/push/offlinepush/fcm/push.go +++ b/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 { diff --git a/internal/push/push_to_client.go b/internal/push/push_to_client.go index c83abd28f..6a4da0914 100644 --- a/internal/push/push_to_client.go +++ b/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 } diff --git a/pkg/common/cmd/rpc.go b/pkg/common/cmd/rpc.go index 5212ddf6e..048f91a04 100644 --- a/pkg/common/cmd/rpc.go +++ b/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) } }