(t *testing.T)
| 2742 | } |
| 2743 | |
| 2744 | func newIntegrationRuntime(t *testing.T) integrationRuntime { |
| 2745 | t.Helper() |
| 2746 | |
| 2747 | homePaths := newTestHomePaths(t) |
| 2748 | socketPath := shortSocketPath(t) |
| 2749 | writeAgentDef(t, homePaths, "coder") |
| 2750 | |
| 2751 | workspace := t.TempDir() |
| 2752 | cfg := aghconfig.DefaultWithHome(homePaths) |
| 2753 | cfg.Daemon.Socket = socketPath |
| 2754 | cfg.Network.Enabled = false |
| 2755 | cfg.Providers = map[string]aghconfig.ProviderConfig{ |
| 2756 | "fake": {Command: "fake-agent"}, |
| 2757 | } |
| 2758 | |
| 2759 | registry, err := globaldb.OpenGlobalDB(context.Background(), homePaths.DatabaseFile) |
| 2760 | if err != nil { |
| 2761 | t.Fatalf("OpenGlobalDB() error = %v", err) |
| 2762 | } |
| 2763 | t.Cleanup(func() { |
| 2764 | if err := registry.Close(context.Background()); err != nil { |
| 2765 | t.Fatalf("registry.Close() error = %v", err) |
| 2766 | } |
| 2767 | }) |
| 2768 | resourceKernel, err := resources.NewKernel(registry.DB()) |
| 2769 | if err != nil { |
| 2770 | t.Fatalf("resources.NewKernel() error = %v", err) |
| 2771 | } |
| 2772 | resourceActor := resources.MutationActor{ |
| 2773 | Kind: resources.MutationActorKindDaemon, |
| 2774 | ID: "uds-integration", |
| 2775 | Source: resources.ResourceSource{ |
| 2776 | Kind: resources.ResourceSourceKind("daemon"), |
| 2777 | ID: "uds-integration", |
| 2778 | }, |
| 2779 | MaxScope: resources.ResourceScope{Kind: resources.ResourceScopeKindGlobal}, |
| 2780 | } |
| 2781 | resourceCodecs := resources.NewCodecRegistry() |
| 2782 | toolCodec, err := toolspkg.NewResourceCodec() |
| 2783 | if err != nil { |
| 2784 | t.Fatalf("toolspkg.NewResourceCodec() error = %v", err) |
| 2785 | } |
| 2786 | if err := resources.RegisterCodec(resourceCodecs, toolCodec); err != nil { |
| 2787 | t.Fatalf("resources.RegisterCodec(tool) error = %v", err) |
| 2788 | } |
| 2789 | jobCodec, err := automationpkg.NewJobResourceCodec() |
| 2790 | if err != nil { |
| 2791 | t.Fatalf("automation.NewJobResourceCodec() error = %v", err) |
| 2792 | } |
| 2793 | if err := resources.RegisterCodec(resourceCodecs, jobCodec); err != nil { |
| 2794 | t.Fatalf("resources.RegisterCodec(automation.job) error = %v", err) |
| 2795 | } |
| 2796 | jobResourceStore, err := resources.NewStore(resourceKernel, jobCodec) |
| 2797 | if err != nil { |
| 2798 | t.Fatalf("resources.NewStore(automation.job) error = %v", err) |
| 2799 | } |
| 2800 | triggerCodec, err := automationpkg.NewTriggerResourceCodec() |
| 2801 | if err != nil { |
no test coverage detected