Function seedDaemonBridgeInstanceFixture

internal/daemon/daemon_integration_test.go:3996–4041

(
	t *testing.T,
	registry *globaldb.GlobalDB,
	req bridgepkg.CreateInstanceRequest,
)

}

func seedDaemonBridgeInstanceFixture(
	t *testing.T,
	registry *globaldb.GlobalDB,
	req bridgepkg.CreateInstanceRequest,
) *bridgepkg.BridgeInstance {
	t.Helper()

	if registry == nil {
		t.Fatal("seedDaemonBridgeInstanceFixture() registry = nil")
	}

	instance, err := bridgepkg.NewRegistry(registry).CreateInstance(testutil.Context(t), req)
	if err != nil {
		t.Fatalf("CreateInstance(%q) error = %v", strings.TrimSpace(req.ID), err)
	}

	kernel, err := resources.NewKernel(registry.DB())
	if err != nil {
		t.Fatalf("resources.NewKernel() error = %v", err)
	}
	codec, err := bridgepkg.NewBridgeInstanceResourceCodec(
		bridgeProviderLookup(newBridgeRuntime(registry, discardLogger(), nil, nil)),
	)
	if err != nil {
		t.Fatalf("NewBridgeInstanceResourceCodec() error = %v", err)
	}
	resourceStore, err := resources.NewStore(kernel, codec)
	if err != nil {
		t.Fatalf("resources.NewStore(bridge.instance) error = %v", err)
	}

	if _, err := resourceStore.Put(
		testutil.Context(t),
		resourceReconcileActor(),
		resources.Draft[bridgepkg.BridgeInstanceSpec]{
			ID:              instance.ID,
			Scope:           bridgepkg.ResourceScopeForBridge(instance.Scope, instance.WorkspaceID),
			ExpectedVersion: 0,
			Spec:            bridgepkg.BridgeInstanceSpecFromInstance(*instance),
		},
	); err != nil {
		t.Fatalf("bridge resource put(%q) error = %v", instance.ID, err)
	}

	return instance
}

func readDaemonInitializeMarkers(t *testing.T, path string) []daemonInitializeMarker {
	t.Helper()