DBT/clawgo
1
0
Fork 0
mirror of https://github.com/YspCoder/clawgo.git synced 2026-05-21 07:07:29 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: allow enabling weixin before binding

Browse Source
This commit is contained in:
lpf
2026-03-24 11:09:03 +08:00
parent 731fc9c99c
commit 428d944e52
2 changed files with 9 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
pkg/channels/manager.go
View File

@@ -93,24 +93,17 @@ func (m *Manager) initChannels() error {
} }
if m.config.Channels.Weixin.Enabled { if m.config.Channels.Weixin.Enabled {
if len(m.config.Channels.Weixin.Accounts) == 0 && strings.TrimSpace(m.config.Channels.Weixin.BotToken) == "" { weixin, err := NewWeixinChannel(m.config.Channels.Weixin, m.bus)
logger.WarnCF("channels", 0, map[string]interface{}{ if err != nil {
"channel": "weixin", logger.ErrorCF("channels", 0, map[string]interface{}{
"error": "missing accounts", logger.FieldChannel: "weixin",
logger.FieldError: err.Error(),
}) })
} else { } else {
weixin, err := NewWeixinChannel(m.config.Channels.Weixin, m.bus) m.channels["weixin"] = weixin
if err != nil { logger.InfoCF("channels", 0, map[string]interface{}{
logger.ErrorCF("channels", 0, map[string]interface{}{ logger.FieldChannel: "weixin",
logger.FieldChannel: "weixin", })
logger.FieldError: err.Error(),
})
} else {
m.channels["weixin"] = weixin
logger.InfoCF("channels", 0, map[string]interface{}{
logger.FieldChannel: "weixin",
})
}
} }
} }

3
pkg/config/validate.go
View File

@@ -187,9 +187,6 @@ func Validate(cfg *Config) []error {
if cfg.Channels.OutboundDedupeWindowSeconds <= 0 { if cfg.Channels.OutboundDedupeWindowSeconds <= 0 {
errs = append(errs, fmt.Errorf("channels.outbound_dedupe_window_seconds must be > 0")) errs = append(errs, fmt.Errorf("channels.outbound_dedupe_window_seconds must be > 0"))
} }
if cfg.Channels.Weixin.Enabled && len(cfg.Channels.Weixin.Accounts) == 0 && strings.TrimSpace(cfg.Channels.Weixin.BotToken) == "" {
errs = append(errs, fmt.Errorf("channels.weixin.accounts or channels.weixin.bot_token is required when channels.weixin.enabled=true"))
}
if cfg.Channels.Telegram.Enabled && cfg.Channels.Telegram.Token == "" { if cfg.Channels.Telegram.Enabled && cfg.Channels.Telegram.Token == "" {
errs = append(errs, fmt.Errorf("channels.telegram.token is required when channels.telegram.enabled=true")) errs = append(errs, fmt.Errorf("channels.telegram.token is required when channels.telegram.enabled=true"))
} }