constants

const (
	QuarkusHealthPathReady = "/q/health/ready"
	QuarkusHealthPathLive  = "/q/health/live"

	// Quarkus Health Check Probe configuration.
	// See: https://quarkus.io/guides/smallrye-health#running-the-health-check
	QuarkusHealthPathStarted = "/q/health/started"
)

const (
	QuarkusHTTP                      = "quarkus-http"
	Post                             = "POST"
	DefaultHTTPProtocol              = "http"
	ConfigMapWorkflowPropsVolumeName = "workflow-properties"

	JobServiceRequestEventsURL                      = "mp.messaging.outgoing.kogito-job-service-job-request-events.url"
	JobServiceRequestEventsConnector                = "mp.messaging.outgoing.kogito-job-service-job-request-events.connector"
	JobServiceRequestEventsMethod                   = "mp.messaging.outgoing.kogito-job-service-job-request-events.method"
	JobServiceStatusChangeEvents                    = "kogito.jobs-service.http.job-status-change-events"
	JobServiceStatusChangeEventsURL                 = "mp.messaging.outgoing.kogito-job-service-job-status-events-http.url"
	JobServiceStatusChangeEventsConnector           = "mp.messaging.outgoing.kogito-job-service-job-status-events-http.connector"
	JobServiceStatusChangeEventsMethod              = "mp.messaging.outgoing.kogito-job-service-job-status-events-http.method"
	JobServiceURLProtocol                           = "http"
	JobServiceDataSourceReactiveURL                 = "quarkus.datasource.reactive.url"
	JobServiceJobEventsPath                         = "/v2/jobs/events"
	JobServiceLeaderCheckExpirationInSeconds        = "kogito.jobs-service.management.leader-check.expiration-in-seconds"
	DefaultJobServiceLeaderCheckExpirationInSeconds = "60"

	KogitoProcessInstancesEventsConnector = "mp.messaging.outgoing.kogito-processinstances-events.connector"
	KogitoProcessInstancesEventsMethod    = "mp.messaging.outgoing.kogito-processinstances-events.method"
	KogitoProcessInstancesEventsURL       = "mp.messaging.outgoing.kogito-processinstances-events.url"
	KogitoProcessInstancesEventsEnabled   = "kogito.events.processinstances.enabled"
	KogitoProcessInstancesEventsPath      = "/processes"
	// KogitoProcessInstancesMultiEventsPath Same value as KogitoProcessInstancesEventsPath intentionally
	KogitoProcessInstancesMultiEventsPath       = "/processes"
	KogitoProcessDefinitionsEventsConnector     = "mp.messaging.outgoing.kogito-processdefinitions-events.connector"
	KogitoProcessDefinitionsEventsMethod        = "mp.messaging.outgoing.kogito-processdefinitions-events.method"
	KogitoProcessDefinitionsEventsURL           = "mp.messaging.outgoing.kogito-processdefinitions-events.url"
	KogitoProcessDefinitionsEventsEnabled       = "kogito.events.processdefinitions.enabled"
	KogitoProcessDefinitionsEventsErrorsEnabled = "kogito.events.processdefinitions.errors.propagate"
	KogitoProcessDefinitionsEventsPath          = "/definitions"
	KogitoUserTasksEventsEnabled                = "kogito.events.usertasks.enabled"
	KogitoJobsPath                              = "/jobs"
	// KogitoDataIndexHealthCheckEnabled configures if a workflow must check for the data index availability as part
	// of its start health check.
	KogitoDataIndexHealthCheckEnabled = "kogito.data-index.health-enabled"
	// KogitoDataIndexURL configures the data index url, this value can be used internally by the workflow.
	KogitoDataIndexURL = "kogito.data-index.url"

	// KogitoJobServiceHealthCheckEnabled configures if a workflow must check for the job service availability as part
	// of its start health check.
	KogitoJobServiceHealthCheckEnabled = "kogito.jobs-service.health-enabled"
	// KogitoJobServiceURL configures the jobs service, this value can be used internally by the workflow.
	KogitoJobServiceURL                            = "kogito.jobs-service.url"
	KogitoServiceURLProperty                       = "kogito.service.url"
	KogitoServiceURLProtocol                       = "http"
	DataIndexKafkaSmallRyeHealthProperty           = `quarkus.smallrye-health.check."io.quarkus.kafka.client.health.KafkaHealthCheck".enabled`
	JobServiceKafkaSmallRyeHealthProperty          = `quarkus.smallrye-health.check."io.quarkus.kafka.client.health.KafkaHealthCheck".enabled`
	JobServiceLeaderLivenessSmallRyeHealthProperty = `quarkus.smallrye-health.check."org.kie.kogito.jobs.service.management.JobServiceLeaderLivenessHealthCheck".enabled`
	DataIndexKafkaHealthCheck                      = `quarkus.smallrye-health.check."io.quarkus.kafka.client.health.KafkaHealthCheck".enabled`
	JobServiceKSinkInjectionHealthCheck            = `quarkus.smallrye-health.check."org.kie.kogito.jobs.service.messaging.http.health.knative.KSinkInjectionHealthCheck".enabled`

	DataIndexServiceName = "data-index-service"
	JobServiceName       = "jobs-service"
	ImageNamePrefix      = "docker.io/apache/incubator-kie-kogito"
	DataIndexName        = "data-index"
	KogitoDBMigratorTool = "db-migrator-tool"

	DefaultPostgresServiceName string = "postgresql"
	DefaultDatabaseName        string = "sonataflow"
	DefaultPostgreSQLPort      int    = 5432
)

const (
	RequeueAfterFailure          = 3 * time.Minute
	RequeueAfterFollowDeployment = 5 * time.Second
	RequeueAfterIsRunning        = 1 * time.Minute
	// RecoverDeploymentErrorRetries how many times the operator should try to recover from a failure before giving up
	RecoverDeploymentErrorRetries = 3
	// RequeueRecoverDeploymentErrorInterval interval between recovering from failures
	RequeueRecoverDeploymentErrorInterval = RecoverDeploymentErrorInterval * time.Minute
	RecoverDeploymentErrorInterval        = 10
	DefaultHTTPWorkflowPortInt            = 8080
	// MaxWorkflowFinalizerAttempts how many times the operator will try to execute a SonataFlow CRD finalizer.
	MaxWorkflowFinalizerAttempts = 3
	// WorkflowFinalizerRetryInterval interval between SonataFlow CRD finalizer execution attempts.
	WorkflowFinalizerRetryInterval = 5 * time.Second
	// WorkflowFinalizerSchedulingRetryInterval interval for the operator to retry to schedule a failing finalizer scheduling.
	WorkflowFinalizerSchedulingRetryInterval = 5 * time.Second
	// EventDeliveryTimeout delivery timeout for the cloud events produced by the operator.
	EventDeliveryTimeout = 30 * time.Second
)

const (
	KogitoOutgoingEventsURL       = "mp.messaging.outgoing.kogito_outgoing_stream.url"
	KogitoOutgoingEventsConnector = "mp.messaging.outgoing.kogito_outgoing_stream.connector"
	KogitoIncomingEventsConnector = "mp.messaging.incoming.kogito_incoming_stream.connector"
	KogitoIncomingEventsPath      = "mp.messaging.incoming.kogito_incoming_stream.path"
	KnativeHealthEnabled          = "org.kie.kogito.addons.knative.eventing.health-enabled"
	KnativeInjectedEnvVar         = "${K_SINK}"
	TriggerFinalizer              = "trigger-deletion"
	WorkflowFinalizer             = "workflow-deletion"
	QuarkusDevUICorsEnabled       = "quarkus.dev-ui.cors.enabled"
	QuarkusDevUIHosts             = "quarkus.dev-ui.hosts"
	KogitoEventsGrouping          = "kogito.events.grouping"
	KogitoEventsGroupingBinary    = "kogito.events.grouping.binary"
	KogitoEventsGroupingCompress  = "kogito.events.grouping.compress"
)