(t *testing.T, ctx context.Context, agentsDir string)
| 91 | } |
| 92 | |
| 93 | func startServer(t *testing.T, ctx context.Context, agentsDir string) string { |
| 94 | t.Helper() |
| 95 | |
| 96 | var store mockStore |
| 97 | runConfig := config.RuntimeConfig{} |
| 98 | |
| 99 | sources, err := config.ResolveSources(agentsDir, nil) |
| 100 | require.NoError(t, err) |
| 101 | srv, err := New(ctx, store, &runConfig, 0, sources, "") |
| 102 | require.NoError(t, err) |
| 103 | |
| 104 | socketPath := "unix://" + filepath.Join(t.TempDir(), "sock") |
| 105 | ln, err := Listen(ctx, socketPath) |
| 106 | require.NoError(t, err) |
| 107 | go func() { |
| 108 | <-ctx.Done() |
| 109 | _ = ln.Close() |
| 110 | }() |
| 111 | |
| 112 | go func() { |
| 113 | _ = srv.Serve(ctx, ln) |
| 114 | }() |
| 115 | |
| 116 | return socketPath |
| 117 | } |
| 118 | |
| 119 | func httpGET(t *testing.T, ctx context.Context, socketPath, path string) []byte { |
| 120 | t.Helper() |
no test coverage detected