bf9395e022
CI / license-header (push) Has been skipped
CI / e2e-dry-run (push) Has been skipped
CI / fast-gate (push) Failing after 0s
Test PR Label Logic / test-pr-labels (push) Failing after 1s
Skill Format Check / check-format (push) Failing after 2s
CI / security (push) Failing after 5s
CI / unit-test (push) Has been skipped
CI / lint (push) Has been skipped
CI / script-test (push) Has been skipped
CI / deterministic-gate (push) Has been skipped
CI / coverage (push) Has been skipped
CI / results (push) Has been cancelled
CI / deadcode (push) Has been cancelled
CI / e2e-live (push) Has been cancelled
31 lines
730 B
Go
31 lines
730 B
Go
// Copyright (c) 2026 Lark Technologies Pte. Ltd.
|
|
// SPDX-License-Identifier: MIT
|
|
|
|
package vc
|
|
|
|
import (
|
|
"context"
|
|
"encoding/json"
|
|
"reflect"
|
|
"testing"
|
|
)
|
|
|
|
type stubAPIClient struct {
|
|
callFn func(ctx context.Context, method, path string, body any) (json.RawMessage, error)
|
|
}
|
|
|
|
func (s *stubAPIClient) CallAPI(ctx context.Context, method, path string, body any) (json.RawMessage, error) {
|
|
if s.callFn == nil {
|
|
return nil, nil
|
|
}
|
|
return s.callFn(ctx, method, path, body)
|
|
}
|
|
|
|
func assertSubscriptionRequest(t *testing.T, gotBody any, wantEventType string) {
|
|
t.Helper()
|
|
want := map[string]string{"event_type": wantEventType}
|
|
if !reflect.DeepEqual(gotBody, want) {
|
|
t.Fatalf("request body = %#v, want %#v", gotBody, want)
|
|
}
|
|
}
|