test(wecom_aibot): adapt webhook tests to channel interface

This commit is contained in:
Hoshina 2026-03-19 21:15:49 +08:00
parent 7e9cdf9e7d
commit 6f503d2441

View file

@ -146,10 +146,14 @@ func TestWeComAIBotChannelGetStreamResponseProcessingMessage(t *testing.T) {
} }
messageBus := bus.NewMessageBus() messageBus := bus.NewMessageBus()
ch, err := NewWeComAIBotChannel(cfg, messageBus) channel, err := NewWeComAIBotChannel(cfg, messageBus)
if err != nil { if err != nil {
t.Fatalf("Failed to create channel: %v", err) t.Fatalf("Failed to create channel: %v", err)
} }
ch, ok := channel.(*WeComAIBotChannel)
if !ok {
t.Fatal("Expected webhook mode channel")
}
task := &streamTask{ task := &streamTask{
StreamID: "stream-default", StreamID: "stream-default",
@ -189,10 +193,14 @@ func TestWeComAIBotChannelGetStreamResponseProcessingMessage(t *testing.T) {
} }
messageBus := bus.NewMessageBus() messageBus := bus.NewMessageBus()
ch, err := NewWeComAIBotChannel(cfg, messageBus) channel, err := NewWeComAIBotChannel(cfg, messageBus)
if err != nil { if err != nil {
t.Fatalf("Failed to create channel: %v", err) t.Fatalf("Failed to create channel: %v", err)
} }
ch, ok := channel.(*WeComAIBotChannel)
if !ok {
t.Fatal("Expected webhook mode channel")
}
task := &streamTask{ task := &streamTask{
StreamID: "stream-custom", StreamID: "stream-custom",