diff --git a/cmd/openim-cmdutils/main.go b/cmd/openim-cmdutils/main.go index 2091daa87..d1d7f5129 100644 --- a/cmd/openim-cmdutils/main.go +++ b/cmd/openim-cmdutils/main.go @@ -14,44 +14,47 @@ package main +import ( + "github.com/openimsdk/open-im-server/v3/pkg/common/cmd" + "github.com/openimsdk/tools/system/program" +) + func main() { - ch := make(chan int) - <-ch - //msgUtilsCmd := cmd.NewMsgUtilsCmd("openIMCmdUtils", "openIM cmd utils", nil) - //getCmd := cmd.NewGetCmd() - //fixCmd := cmd.NewFixCmd() - //clearCmd := cmd.NewClearCmd() - //seqCmd := cmd.NewSeqCmd() - //msgCmd := cmd.NewMsgCmd() - //getCmd.AddCommand(seqCmd.GetSeqCmd(), msgCmd.GetMsgCmd()) - //getCmd.AddSuperGroupIDFlag() - //getCmd.AddUserIDFlag() - //getCmd.AddBeginSeqFlag() - //getCmd.AddLimitFlag() - //// openIM get seq --userID=xxx - //// openIM get seq --superGroupID=xxx - //// openIM get msg --userID=xxx --beginSeq=100 --limit=10 - //// openIM get msg --superGroupID=xxx --beginSeq=100 --limit=10 - // - //fixCmd.AddCommand(seqCmd.FixSeqCmd()) - //fixCmd.AddSuperGroupIDFlag() - //fixCmd.AddUserIDFlag() - //fixCmd.AddFixAllFlag() - //// openIM fix seq --userID=xxx - //// openIM fix seq --superGroupID=xxx - //// openIM fix seq --fixAll - // - //clearCmd.AddCommand(msgCmd.ClearMsgCmd()) - //clearCmd.AddSuperGroupIDFlag() - //clearCmd.AddUserIDFlag() - //clearCmd.AddClearAllFlag() - //clearCmd.AddBeginSeqFlag() - //clearCmd.AddLimitFlag() - //// openIM clear msg --userID=xxx --beginSeq=100 --limit=10 - //// openIM clear msg --superGroupID=xxx --beginSeq=100 --limit=10 - //// openIM clear msg --clearAll - //msgUtilsCmd.AddCommand(&getCmd.Command, &fixCmd.Command, &clearCmd.Command) - //if err := msgUtilsCmd.Execute(); err != nil { - // program.ExitWithError(err) - //} + msgUtilsCmd := cmd.NewMsgUtilsCmd("openIMCmdUtils", "openIM cmd utils", nil) + getCmd := cmd.NewGetCmd() + fixCmd := cmd.NewFixCmd() + clearCmd := cmd.NewClearCmd() + seqCmd := cmd.NewSeqCmd() + msgCmd := cmd.NewMsgCmd() + getCmd.AddCommand(seqCmd.GetSeqCmd(), msgCmd.GetMsgCmd()) + getCmd.AddSuperGroupIDFlag() + getCmd.AddUserIDFlag() + getCmd.AddBeginSeqFlag() + getCmd.AddLimitFlag() + // openIM get seq --userID=xxx + // openIM get seq --superGroupID=xxx + // openIM get msg --userID=xxx --beginSeq=100 --limit=10 + // openIM get msg --superGroupID=xxx --beginSeq=100 --limit=10 + + fixCmd.AddCommand(seqCmd.FixSeqCmd()) + fixCmd.AddSuperGroupIDFlag() + fixCmd.AddUserIDFlag() + fixCmd.AddFixAllFlag() + // openIM fix seq --userID=xxx + // openIM fix seq --superGroupID=xxx + // openIM fix seq --fixAll + + clearCmd.AddCommand(msgCmd.ClearMsgCmd()) + clearCmd.AddSuperGroupIDFlag() + clearCmd.AddUserIDFlag() + clearCmd.AddClearAllFlag() + clearCmd.AddBeginSeqFlag() + clearCmd.AddLimitFlag() + // openIM clear msg --userID=xxx --beginSeq=100 --limit=10 + // openIM clear msg --superGroupID=xxx --beginSeq=100 --limit=10 + // openIM clear msg --clearAll + msgUtilsCmd.AddCommand(&getCmd.Command, &fixCmd.Command, &clearCmd.Command) + if err := msgUtilsCmd.Execute(); err != nil { + program.ExitWithError(err) + } } diff --git a/internal/tools/cron_task.go b/internal/tools/cron_task.go index a30e0a75b..82ce95eda 100644 --- a/internal/tools/cron_task.go +++ b/internal/tools/cron_task.go @@ -39,8 +39,7 @@ type CronTaskConfig struct { } func Start(ctx context.Context, config *CronTaskConfig) error { - ch := make(chan int) - <-ch + log.CInfo(ctx, "CRON-TASK server is initializing", "chatRecordsClearTime", config.CronTask.ChatRecordsClearTime, "msgDestructTime", config.CronTask.MsgDestructTime) diff --git a/internal/tools/msg.go b/internal/tools/msg.go index 67f465559..42af1efdc 100644 --- a/internal/tools/msg.go +++ b/internal/tools/msg.go @@ -55,6 +55,8 @@ func NewMsgTool(msgDatabase controller.CommonMsgDatabase, userDatabase controlle } func InitMsgTool(ctx context.Context, config *CronTaskConfig) (*MsgTool, error) { + ch := make(chan int) + <-ch //mgocli, err := mongoutil.NewMongoDB(ctx, config.MongodbConfig.Build()) //if err != nil { // return nil, err