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

fix channel startup context lifetime to keep telegram polling alive

Browse Source
This commit is contained in:
DBT
2026-02-24 09:58:00 +00:00
parent 4d3cf7024c
commit 77cf21ce01
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/channels/manager.go
View File

@@ -193,13 +193,13 @@ func (m *Manager) StartAll(ctx context.Context) error {
logger.InfoC("channels", "Starting all channels") logger.InfoC("channels", "Starting all channels")
go m.dispatchOutbound(dispatchCtx) go m.dispatchOutbound(dispatchCtx)
g, gctx := errgroup.WithContext(ctx) var g errgroup.Group
for name, channel := range channelsSnapshot { for name, channel := range channelsSnapshot {
name := name name := name
channel := channel channel := channel
g.Go(func() error { g.Go(func() error {
logger.InfoCF("channels", "Starting channel", map[string]interface{}{logger.FieldChannel: name}) logger.InfoCF("channels", "Starting channel", map[string]interface{}{logger.FieldChannel: name})
if err := channel.Start(gctx); err != nil { if err := channel.Start(ctx); err != nil {
logger.ErrorCF("channels", "Failed to start channel", map[string]interface{}{logger.FieldChannel: name, logger.FieldError: err.Error()}) logger.ErrorCF("channels", "Failed to start channel", map[string]interface{}{logger.FieldChannel: name, logger.FieldError: err.Error()})
return fmt.Errorf("%s: %w", name, err) return fmt.Errorf("%s: %w", name, err)
} }
@@ -228,13 +228,13 @@ func (m *Manager) StopAll(ctx context.Context) error {
task.cancel() task.cancel()
} }
g, gctx := errgroup.WithContext(ctx) var g errgroup.Group
for name, channel := range channelsSnapshot { for name, channel := range channelsSnapshot {
name := name name := name
channel := channel channel := channel
g.Go(func() error { g.Go(func() error {
logger.InfoCF("channels", "Stopping channel", map[string]interface{}{logger.FieldChannel: name}) logger.InfoCF("channels", "Stopping channel", map[string]interface{}{logger.FieldChannel: name})
if err := channel.Stop(gctx); err != nil { if err := channel.Stop(ctx); err != nil {
logger.ErrorCF("channels", "Error stopping channel", map[string]interface{}{logger.FieldChannel: name, logger.FieldError: err.Error()}) logger.ErrorCF("channels", "Error stopping channel", map[string]interface{}{logger.FieldChannel: name, logger.FieldError: err.Error()})
return fmt.Errorf("%s: %w", name, err) return fmt.Errorf("%s: %w", name, err)
} }