wehub-resource-sync
a06f331eb8
CI / benchmark (push) Has been skipped
install-script / posix-syntax (push) Successful in 6m1s
CI / build-onnx (push) Failing after 6m43s
init-smoke / dry-run (push) Failing after 15m57s
security / govulncheck (push) Has been cancelled
security / trivy-fs (push) Has been cancelled
CI / test (1.26, ubuntu-latest) (push) Has been cancelled
Scorecard supply-chain security / Scorecard analysis (push) Has been cancelled
CI / test (1.26, macos-latest) (push) Has been cancelled
CI / build-windows (push) Has been cancelled
CI / lint (push) Has been cancelled
install-script / powershell-syntax (push) Has been cancelled
install-script / install (macos-14) (push) Has been cancelled
install-script / install (ubuntu-latest) (push) Has been cancelled
111 lines
3.3 KiB
Go
111 lines
3.3 KiB
Go
package indexer
|
|
|
|
import (
|
|
"path/filepath"
|
|
"testing"
|
|
|
|
"github.com/stretchr/testify/assert"
|
|
"github.com/stretchr/testify/require"
|
|
|
|
"github.com/zzet/gortex/internal/graph"
|
|
)
|
|
|
|
// PURPOSE — Cat 4 (PascalCase exact-name fallback): a dispatch whose name is a
|
|
// concrete PascalCase identifier that exactly matches an unregistered,
|
|
// non-suffixed Go function resolves ONLY when that function's signature
|
|
// matches the dispatch kind (activity→context.Context / workflow→
|
|
// workflow.Context) and the match is unique. Signature / kind mismatches must
|
|
// abstain — precision over recall (the edge is speculative + hidden).
|
|
//
|
|
// KEYWORDS — temporal, PascalCase, exact-name, signature-gate, Cat4
|
|
|
|
func TestTemporalE2E_PascalCaseExactSig_Resolves(t *testing.T) {
|
|
dir := t.TempDir()
|
|
writeFile(t, filepath.Join(dir, "workflow.go"), `package wf
|
|
|
|
import "go.temporal.io/sdk/workflow"
|
|
|
|
func OrderWorkflow(ctx workflow.Context) error {
|
|
return workflow.ExecuteChildWorkflow(ctx, ProcessPriceChange, nil).Get(ctx, nil)
|
|
}
|
|
|
|
func ProcessPriceChange(ctx workflow.Context) error { return nil }
|
|
`)
|
|
writeFile(t, filepath.Join(dir, "main.go"), `package wf
|
|
|
|
func setupWorker(w Worker) {
|
|
w.RegisterWorkflow(OrderWorkflow)
|
|
}
|
|
`)
|
|
g := graph.New()
|
|
idx := newTestIndexer(g)
|
|
_, err := idx.Index(dir)
|
|
require.NoError(t, err)
|
|
|
|
target := g.FindNodesByName("ProcessPriceChange")
|
|
require.Len(t, target, 1)
|
|
stub := stubEdgeFrom(t, g, "OrderWorkflow")
|
|
assert.Equal(t, target[0].ID, stub.To,
|
|
"exact-name workflow-shaped function must resolve via exact_sig")
|
|
assert.Equal(t, "exact_sig", stub.Meta["temporal_resolution_via"])
|
|
_, hidden := stub.Meta[graph.MetaSpeculative]
|
|
assert.True(t, hidden, "exact_sig resolution is speculative/hidden")
|
|
}
|
|
|
|
func TestTemporalE2E_PascalCaseExactSig_SignatureMismatchAbstains(t *testing.T) {
|
|
dir := t.TempDir()
|
|
writeFile(t, filepath.Join(dir, "workflow.go"), `package wf
|
|
|
|
import "go.temporal.io/sdk/workflow"
|
|
|
|
func OrderWorkflow(ctx workflow.Context) error {
|
|
return workflow.ExecuteActivity(ctx, ComputeTotals, nil).Get(ctx, nil)
|
|
}
|
|
|
|
func ComputeTotals(in int) int { return in }
|
|
`)
|
|
writeFile(t, filepath.Join(dir, "main.go"), `package wf
|
|
|
|
func setupWorker(w Worker) {
|
|
w.RegisterWorkflow(OrderWorkflow)
|
|
}
|
|
`)
|
|
g := graph.New()
|
|
idx := newTestIndexer(g)
|
|
_, err := idx.Index(dir)
|
|
require.NoError(t, err)
|
|
|
|
stub := stubEdgeFrom(t, g, "OrderWorkflow")
|
|
assert.Contains(t, stub.To, "unresolved::temporal::",
|
|
"a non-Temporal-shaped exact-name match must NOT resolve; got To=%s", stub.To)
|
|
}
|
|
|
|
func TestTemporalE2E_PascalCaseExactSig_KindMismatchAbstains(t *testing.T) {
|
|
dir := t.TempDir()
|
|
writeFile(t, filepath.Join(dir, "workflow.go"), `package wf
|
|
|
|
import "go.temporal.io/sdk/workflow"
|
|
|
|
func OrderWorkflow(ctx workflow.Context) error {
|
|
// activity dispatch onto a workflow-shaped function — kind mismatch.
|
|
return workflow.ExecuteActivity(ctx, SettleInvoice, nil).Get(ctx, nil)
|
|
}
|
|
|
|
func SettleInvoice(ctx workflow.Context) error { return nil }
|
|
`)
|
|
writeFile(t, filepath.Join(dir, "main.go"), `package wf
|
|
|
|
func setupWorker(w Worker) {
|
|
w.RegisterWorkflow(OrderWorkflow)
|
|
}
|
|
`)
|
|
g := graph.New()
|
|
idx := newTestIndexer(g)
|
|
_, err := idx.Index(dir)
|
|
require.NoError(t, err)
|
|
|
|
stub := stubEdgeFrom(t, g, "OrderWorkflow")
|
|
assert.Contains(t, stub.To, "unresolved::temporal::",
|
|
"activity dispatch onto a workflow.Context function must abstain; got To=%s", stub.To)
|
|
}
|