suite

type AppUnderTest interface {
	Context() context.Context
	Stop()
	WaitDone()
}

type DbSubscriberAssertion func(t *testing.T, fetcher *DbSubscriberFetcher)

type DbSubscriberFetcher struct {
	// contains filtered or unexported fields
}

type DbSubscriberTestCase struct {
	Name    string
	ModelId string
	Version int
	Input   any
	Assert  DbSubscriberAssertion
}

type DdbSubscriberAssertion func(t *testing.T, fetcher *DdbSubscriberFetcher)

type DdbSubscriberFetcher struct {
	// contains filtered or unexported fields
}

type DdbSubscriberTestCase struct {
	Name          string
	SourceModelId string
	TargetModelId string
	Version       int
	Input         any
	Assert        DdbSubscriberAssertion
}

type HttpserverTestCase struct {
	Method  string
	Url     string
	Headers map[string]string
	// Body will be used as the request body. Supported request body data types is `string`,
	// `[]byte`, `struct`, `map`, `slice` and `io.Reader`. Body value can be pointer or non-pointer.
	// Automatic marshalling for JSON and XML content type, if it is `struct`, `map`, or `slice`.
	//
	// If you call EncodeBodyProtobuf on your body before assigning it to this field, it will instead be
	// encoded using protobuf.
	//
	// To send the contents of a file, you can use ReadBodyFile and assign the result to this field. The
	// test suite will read the file contents and send it as your request.
	Body any
	// ExpectedStatusCode describes the status code the last response is required to have.
	ExpectedStatusCode int
	// ExpectedRedirectsToFollow describes the number of redirects we want to follow. It is an error if less redirects
	// are performed. More redirects result in the last redirect being returned as the response instead (e.g., if it is
	// to some external site or with a protocol different from HTTP(S) like intent://) and do not result in an error.
	ExpectedRedirectsToFollow int
	// ExpectedResult defines the *type* the final response should be parsed into. You can then access the unmarshalled
	// response in response.Result().
	ExpectedResult any
	// ExpectedErr is compared with the error returned by the HTTP request. Only the error messages have to match.
	ExpectedErr error
	// Assert allows you to provide an assertion function that can be passed to validate certain post conditions (like
	// messages being written to the correct queues).
	// It also allows to check that the response carries the correct response body, redirects to the correct
	//	// location, or has the correct headers set. You don't need to validate the response status here, this is already
	//	// performed automatically.
	Assert func(response *resty.Response) error
	// AssertResultFile can be used to read the expected response body from a file, which will be used to check equality
	// with the actual response body. If the file name extension is .json, the equality check is done via assert.JSONEq.
	AssertResultFile string
}

type HttpserverTestCaseListProvider func() []*HttpserverTestCase

type KvStoreSubscriberAssertion func(t *testing.T, fetcher *KvstoreSubscriberFetcher)

type KvstoreSubscriberFetcher struct {
	// contains filtered or unexported fields
}

type KvstoreSubscriberTestCase struct {
	Name    string
	ModelId string
	Input   any
	Version int
	Assert  KvStoreSubscriberAssertion
}

type Option func(s *SuiteConfiguration)

type ProtobufEncodable interface {
	ToMessage() (proto.Message, error)
}

type StreamTestCase struct {
	Input  map[string][]StreamTestCaseInput
	Output map[string][]StreamTestCaseOutput
	Assert func() error
}

type StreamTestCaseInput struct {
	Attributes map[string]string
	Body       any
}

type StreamTestCaseOutput struct {
	Model              any
	ExpectedAttributes map[string]string
	ExpectedBody       any
}

type StreamTestCaseProvider func() *StreamTestCase

type SubscriberTestCase interface {
	GetName() string
	GetModelId() string
	GetInput() any
	GetVersion() int
}

type SubscriptionFetcherOption func(*subscriberFetcherOptions)

type Suite struct {
	*assert.Assertions
	// contains filtered or unexported fields
}

type SuiteConfiguration struct {
	// contains filtered or unexported fields
}

type TestCaseBuilder func(suite TestingSuite, method reflect.Method) (TestCaseRunner, error)

type TestCaseMatcher func(suite TestingSuite, method reflect.Method) error

type TestCaseRunner func(t *testing.T, suite TestingSuite, suiteConf *SuiteConfiguration, environment *env.Environment)

type TestingSuite interface {
	Env() *env.Environment
	SetEnv(environment *env.Environment)
	SetT(t *testing.T)
	T() *testing.T
	SetupSuite() []Option
}

type TestingSuiteApiDefinitionsAware interface {
	SetupApiDefinitions() httpserver.Definer
}

type TestingSuiteApplicationAware interface {
	SetupApplication() error
}

type TestingSuiteSetupTestAware interface {
	SetupTest() error
}

type TestingSuiteTearDownTestAware interface {
	TearDownTest() error
}

type ToHttpserverTestCaseList interface {
	ToTestCaseList() []*HttpserverTestCase
}

type ToStreamTestCase interface {
	ToTestCase() *StreamTestCase
}