Function TestEnvConcurrentExtendWithMutation

cel/env_test.go:283–329

(t *testing.T)

}

func TestEnvConcurrentExtendWithMutation(t *testing.T) {
	t.Parallel()
	baseEnv, err := NewCustomEnv(StdLib())
	if err != nil {
		t.Fatalf("NewCustomEnv() failed: %v", err)
	}
	var wg sync.WaitGroup
	for i := 0; i < 50; i++ {
		wg.Add(1)
		go func(id int) {
			defer wg.Done()
			fnName := fmt.Sprintf("custom_func_%d", id)
			extEnv, err := baseEnv.Extend(
				Function(fnName,
					Overload(fnName+"_int", []*Type{IntType}, IntType,
						UnaryBinding(func(val ref.Val) ref.Val {
							return val
						}),
					),
				),
			)
			if err != nil {
				t.Errorf("Extend() failed: %v", err)
				return
			}
			ast, iss := extEnv.Compile(fmt.Sprintf("%s(42) == 42", fnName))
			if iss.Err() != nil {
				t.Errorf("Compile() failed: %v", iss.Err())
				return
			}
			prg, err := extEnv.Program(ast)
			if err != nil {
				t.Errorf("Program() failed: %v", err)
				return
			}
			out, _, err := prg.Eval(NoVars())
			if err != nil {
				t.Errorf("Eval() failed: %v", err)
				return
			}
			if out.Value() != true {
				t.Errorf("got %v, wanted true", out.Value())
			}
		}(i)
	}
	wg.Wait()
}