Function NewWithOptionalRuntime

admin/testadmin/testadmin.go:80–226

(t *testing.T, startRt bool)

}

func NewWithOptionalRuntime(t *testing.T, startRt bool) *Fixture {
	ctx := t.Context()

	// Postgres
	pg := pgtestcontainer.New(t)
	t.Cleanup(func() { pg.Terminate(t) })

	// Logger
	cfg := zap.NewProductionConfig()
	cfg.Level.SetLevel(zap.ErrorLevel)
	logger, err := cfg.Build()
	require.NoError(t, err)

	// Sender
	sender := email.NewTestSender()
	emailClient := email.New(sender)

	// Application-managed column encryption keyring
	keyring, err := database.NewRandomKeyring()
	require.NoError(t, err)
	keyringJSON, err := json.Marshal(keyring)
	require.NoError(t, err)

	// Ports and external URLs - find both ports (guaranteed to be different)
	port, runtimePort := findTwoPorts(t)
	externalURL := fmt.Sprintf("http://localhost:%d", port)
	var runtimeExternalURL string
	if startRt {
		runtimeExternalURL = fmt.Sprintf("http://localhost:%d", runtimePort)
	} else {
		runtimeExternalURL = "http://example.org"
	}
	frontendURL := "http://frontend.mock"

	// JWT issuer
	issuer, err := runtimeauth.NewEphemeralIssuer(externalURL)
	require.NoError(t, err)

	// Runtime provisioner - if startRt is false, we set up a provisioner that points to a non-existent runtime server.
	runtimeAudienceURL := runtimeExternalURL
	defaultProvisioner := "static"
	provisionerSetJSON := must(json.Marshal(map[string]any{
		"static": map[string]any{
			"type": "static",
			"spec": map[string]any{
				"runtimes": []map[string]any{
					{
						"host":         runtimeExternalURL,
						"slots":        1000000,
						"audience_url": runtimeAudienceURL,
					},
				},
			},
		},
	}))

	// Initialize mock AI using drivers.Open pattern
	mockAIHandle, err := drivers.Open("mock_ai", "", "test", map[string]any{}, storage.MustNew(os.TempDir(), nil), activity.NewNoopClient(), logger)