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
57 lines
2.1 KiB
Go
57 lines
2.1 KiB
Go
// Copyright (c) 2026 Lark Technologies Pte. Ltd.
|
|
// SPDX-License-Identifier: MIT
|
|
|
|
package whiteboard
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"time"
|
|
|
|
"github.com/larksuite/cli/errs"
|
|
"github.com/larksuite/cli/internal/event"
|
|
"github.com/larksuite/cli/internal/validate"
|
|
)
|
|
|
|
// cleanupTimeout bounds how long the unsubscribe call has to finish during
|
|
// PreConsume cleanup so a stuck OAPI cannot block process shutdown.
|
|
const cleanupTimeout = 5 * time.Second
|
|
|
|
// whiteboardSubscriptionPreConsume calls the whiteboard event subscribe OAPI
|
|
// and returns a cleanup that invokes the matching unsubscribe.
|
|
//
|
|
// board.whiteboard.updated_v1 is subscribed per-whiteboard (by whiteboard_id),
|
|
// so the path contains a :whiteboard_id placeholder that must be supplied via params.
|
|
func whiteboardSubscriptionPreConsume(eventType string) func(context.Context, event.APIClient, map[string]string) (func() error, error) {
|
|
return func(ctx context.Context, rt event.APIClient, params map[string]string) (func() error, error) {
|
|
if rt == nil {
|
|
return nil, errs.NewInternalError(errs.SubtypeUnknown,
|
|
"runtime API client is required for pre-consume subscription")
|
|
}
|
|
whiteboardID := params["whiteboard_id"]
|
|
if whiteboardID == "" {
|
|
return nil, errs.NewValidationError(errs.SubtypeInvalidArgument,
|
|
"param whiteboard_id is required for %s", eventType).
|
|
WithParam("--param").
|
|
WithHint("pass it as --param whiteboard_id=<id>; run `lark-cli event schema %s` for details", eventType)
|
|
}
|
|
encoded := validate.EncodePathSegment(whiteboardID)
|
|
subscribePath := fmt.Sprintf("/open-apis/board/v1/whiteboards/%s/subscribe", encoded)
|
|
unsubscribePath := fmt.Sprintf("/open-apis/board/v1/whiteboards/%s/unsubscribe", encoded)
|
|
|
|
body := map[string]string{"event_type": eventType}
|
|
if _, err := rt.CallAPI(ctx, "POST", subscribePath, body); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return func() error {
|
|
cleanupCtx, cancel := context.WithTimeout(context.Background(), cleanupTimeout)
|
|
defer cancel()
|
|
if _, err := rt.CallAPI(cleanupCtx, "POST", unsubscribePath, body); err != nil {
|
|
return err
|
|
}
|
|
return nil
|
|
}, nil
|
|
}
|
|
}
|