mirror of
https://github.com/larksuite/cli.git
synced 2026-09-14 18:42:53 +08:00
sang-neo03
ed7fdd1a27
* feat: add SubscriptionType and SingleConsumer to EventKey definition * feat: fetch subscribed callbacks from application/get * feat: build addons scan-to-enable deep link for event precheck * feat: route callback precheck to application/get and emit scan links * feat: add reject fields to hello_ack protocol message * feat: add exclusive registration to event bus hub * feat: reject duplicate consumer for SingleConsumer EventKey at bus handshake * feat: surface bus consumer rejection as failed_precondition error * fix: encode empty addons sides as [] not null per launcher contract * fix: report missing callbacks when console has none subscribed * feat: bound exclusive consumer cleanup wait with configurable timeout * refactor: drain exclusive-wait timer and document websocket-only callbacks * fix: use camelCase clientID param in event scan-to-enable link * test: cover null/omitted callbacks and assert typed error category * fix: keep auth login remediation for user-identity missing scopes * refactor: simplify SubscriptionType normalization to match validateAuth style
37 lines
1.2 KiB
Go
37 lines
1.2 KiB
Go
// Copyright (c) 2026 Lark Technologies Pte. Ltd.
|
|
// SPDX-License-Identifier: MIT
|
|
|
|
package consume
|
|
|
|
import (
|
|
"strings"
|
|
"testing"
|
|
|
|
"github.com/larksuite/cli/errs"
|
|
"github.com/larksuite/cli/internal/event/protocol"
|
|
)
|
|
|
|
func TestRejectionError_Rejected(t *testing.T) {
|
|
ack := &protocol.HelloAck{Type: protocol.MsgTypeHelloAck, Rejected: true, RejectReason: "another consumer (pid 9) is already running"}
|
|
err := rejectionError(ack, "im.message.receive_v1")
|
|
if err == nil {
|
|
t.Fatal("expected error for rejected ack")
|
|
}
|
|
prob, ok := errs.ProblemOf(err)
|
|
if !ok || prob.Category != errs.CategoryValidation || prob.Subtype != errs.SubtypeFailedPrecondition {
|
|
t.Errorf("problem = %v, want validation/failed_precondition; err=%q", prob, err.Error())
|
|
}
|
|
if !strings.Contains(err.Error(), "already running") {
|
|
t.Errorf("error = %q, want reject reason", err.Error())
|
|
}
|
|
}
|
|
|
|
func TestRejectionError_NotRejected(t *testing.T) {
|
|
if err := rejectionError(&protocol.HelloAck{Type: protocol.MsgTypeHelloAck}, "k"); err != nil {
|
|
t.Errorf("expected nil for non-rejected ack, got %v", err)
|
|
}
|
|
if err := rejectionError(nil, "k"); err != nil {
|
|
t.Errorf("expected nil for nil ack, got %v", err)
|
|
}
|
|
}
|