Function newFakeInit

engine/resources/http_client_test.go:125–168

(t *testing.T)

}

func newFakeInit(t *testing.T) *fakeInit {
	t.Helper()
	tmpdir := t.TempDir()
	fi := &fakeInit{
		events: make(chan struct{}, 8),
		sent:   make(chan *HTTPClientSends, 8),
	}
	fi.init = &engine.Init{
		VarDir: func(p string) (string, error) {
			return filepath.Join(tmpdir, p), nil
		},
		Event: func(ctx context.Context) error {
			select {
			case fi.events <- struct{}{}:
				return nil
			case <-ctx.Done():
				return ctx.Err()
			}
		},
		Refresh: func() bool { return fi.refresh.Load() },
		Send: func(v interface{}) error {
			s, ok := v.(*HTTPClientSends)
			if !ok {
				return fmt.Errorf("unexpected Send payload %T", v)
			}
			// Copy so callers can't observe later mutation.
			cp := *s
			if s.Content != nil {
				c := *s.Content
				cp.Content = &c
			}
			fi.sent <- &cp
			return nil
		},
		Debug: testing.Verbose(),
		Logf:  func(format string, v ...interface{}) { t.Logf("res: "+format, v...) },
	}
	fi.init.Local = (&local.API{
		Prefix: filepath.Join(tmpdir, "local"),
		Debug:  testing.Verbose(),
		Logf:   func(format string, v ...interface{}) { t.Logf("local: "+format, v...) },
	}).Init()
	return fi
}

// drainSent pulls a Send payload non-blockingly. Returns nil if none pending.
func (obj *fakeInit) drainSent() *HTTPClientSends {