enhancementservices

type AWSConfigV1 struct {
	BasicServiceWorkerConfig
	LambdaName string `json:"lambdaName"`
	AsyncFn    bool   `json:"asyncFunction"`
}

type BasicServiceWorkerConfig struct {
	Type    string `json:"type"`
	Version int64  `json:"version"`
}

type ExpandedNewEvidencePayload struct {
	NewEvidencePayload
	EvidenceID int64 `db:"id"`
}

type LambdaInvokableClient interface {
	// Invoke(input *lambda.InvokeInput) (*lambda.InvokeOutput, error)
	Invoke(ctx context.Context, params *lambda.InvokeInput, optFns ...func(*lambda.Options)) (*lambda.InvokeOutput, error)
}

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

type LambdaResponse struct {
	StatusCode int    `json:"statusCode"`
	Body       string `json:"body"`
}

type NewEvidencePayload struct {
	Type            string              `json:"type" db:"type"`
	EvidenceUUID    string              `json:"evidenceUuid"  db:"uuid"`
	OperationSlug   string              `json:"operationSlug" db:"operation_slug"`
	ContentType     string              `json:"contentType"   db:"content_type"`
	GlobalVariables []dtos.GlobalVar    `json:"globalVariables"`
	OperationVars   []dtos.OperationVar `json:"operationVariables"`
}

type ProcessResponse struct {
	Action  string  `json:"action"`  // Rejected | Deferred | Processed | Error
	Content *string `json:"content"` // Error => reason, Processed => Result
}

type RequestFn = func(method, url string, body io.Reader, updateRequest helpers.ModifyReqFunc) (*http.Response, error)

type SendServiceWorkerEventInput struct {
	Logger      logging.Logger
	WorkerNames []string
	Builder     func(db database.ConnectionProxy) ([]interface{}, error)
	EventType   string
}

type ServiceTestResult struct {
	// Message contains helpful text detailing _why_ there was a failure
	Message string
	// Live indicates if the service is available or not
	Live bool
	// Error indicates if there was some fundamental error that prevented a full test
	Error error
}

type ServiceWorker interface {
	Build(workerName string, config []byte) error
	Test() ServiceTestResult
	ProcessMetadata(evidenceID int64, payload *NewEvidencePayload) (*models.EvidenceMetadata, error)
	ProcessEvent(payload interface{}) error
}

type TestResp struct {
	Status  string  `json:"status"`
	Message *string `json:"message"`
}

type WebConfigV1 struct {
	BasicServiceWorkerConfig
	URL     string            `json:"url"`
	Headers map[string]string `json:"headers"`
}