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
42 lines
1.3 KiB
Go
42 lines
1.3 KiB
Go
// Copyright (c) 2026 Lark Technologies Pte. Ltd.
|
|
// SPDX-License-Identifier: MIT
|
|
|
|
package consume
|
|
|
|
import (
|
|
"crypto/sha256"
|
|
"encoding/base64"
|
|
"encoding/json"
|
|
"sort"
|
|
|
|
"github.com/larksuite/cli/internal/event"
|
|
)
|
|
|
|
// ComputeSubscriptionID returns a stable identifier scoped to (EventKey, values
|
|
// of the ParamDefs marked SubscriptionKey); the framework uses it to dedup
|
|
// PreConsume/cleanup gates and key Hub counts per-subscription. No SubscriptionKey
|
|
// params -> returns def.Key verbatim (legacy one-dimensional behavior).
|
|
//
|
|
// Stability contract: same EventKey + same normalized param values -> same ID
|
|
// across CLI versions; changing the encoding requires a wire-format bump.
|
|
func ComputeSubscriptionID(def *event.KeyDefinition, params map[string]string) string {
|
|
type kv struct {
|
|
Name string `json:"name"`
|
|
Value string `json:"value"`
|
|
}
|
|
var subParams []kv
|
|
for _, p := range def.Params {
|
|
if !p.SubscriptionKey {
|
|
continue
|
|
}
|
|
subParams = append(subParams, kv{Name: p.Name, Value: params[p.Name]})
|
|
}
|
|
if len(subParams) == 0 {
|
|
return def.Key
|
|
}
|
|
sort.Slice(subParams, func(i, j int) bool { return subParams[i].Name < subParams[j].Name })
|
|
raw, _ := json.Marshal(subParams) // err impossible: kv has no unmarshalable fields
|
|
sum := sha256.Sum256(raw)
|
|
return def.Key + ":" + base64.RawURLEncoding.EncodeToString(sum[:12])
|
|
}
|