mirror of
https://github.com/larksuite/cli.git
synced 2026-09-14 18:42:53 +08:00
liuxinyanglxy
3f77eded9d
Framework support for resource-scoped event subscriptions, so one EventKey can fan out into independent per-resource subscription scopes: - KeyDefinition gains SubscriptionKey / NormalizeParams / Match hooks - ComputeSubscriptionID derives a dedup identity from (EventKey, sub-key params); plumbed through bus Hub, consume loop, and the Hello / PreShutdownCheck / ConsumerInfo protocol messages - add a synchronous Match filter stage before Process - change PreConsume cleanup to func() error and surface cleanup (unsubscribe) failures as WARN with an idempotency note - adapt minutes/vc/whiteboard PreConsume to the new cleanup signature - render SubscriptionID / SubscriptionKey in event status & schema output No domain wires these hooks yet; covered by unit tests using bus/protocol doubles. (Mail, the original exerciser, is intentionally not included.) Change-Id: Ifc743f1aa0bc4dff0c8a1e35da24883694fe7699
47 lines
1.1 KiB
Go
47 lines
1.1 KiB
Go
// Copyright (c) 2026 Lark Technologies Pte. Ltd.
|
|
// SPDX-License-Identifier: MIT
|
|
|
|
package consume
|
|
|
|
import (
|
|
"net"
|
|
"testing"
|
|
"time"
|
|
)
|
|
|
|
// doHello must apply a read deadline on HelloAck so a wedged bus doesn't hang the consumer.
|
|
func TestDoHello_ReadDeadline(t *testing.T) {
|
|
server, client := net.Pipe()
|
|
defer server.Close()
|
|
defer client.Close()
|
|
|
|
go func() {
|
|
buf := make([]byte, 4096)
|
|
for {
|
|
if _, err := server.Read(buf); err != nil {
|
|
return
|
|
}
|
|
}
|
|
}()
|
|
|
|
start := time.Now()
|
|
done := make(chan error, 1)
|
|
go func() {
|
|
_, _, err := doHello(client, "im.msg", []string{"im.msg"}, "")
|
|
done <- err
|
|
}()
|
|
|
|
select {
|
|
case err := <-done:
|
|
elapsed := time.Since(start)
|
|
if err == nil {
|
|
t.Fatal("doHello returned nil error when server never replied; must fail with deadline-driven error")
|
|
}
|
|
if elapsed > helloAckTimeout+2*time.Second {
|
|
t.Errorf("doHello returned %v after %v; deadline should fire within ~%v", err, elapsed, helloAckTimeout)
|
|
}
|
|
case <-time.After(helloAckTimeout + 3*time.Second):
|
|
t.Fatal("doHello hung past deadline + 3s slack: read deadline is missing or not being honoured")
|
|
}
|
|
}
|