client_inventory

var (
	ErrorUnableToParseKafkaApiLine = errors.New("unable to parse Kafka API line")
	ErrorUnableToParseTimestamp    = errors.New("unable to parse timestamp")
	ErrorUnsupportedLogLine        = errors.New("unsupported log line")
)

var (
	TimestampPattern     = regexp.MustCompile(`^\[([^\]]+)\]`)
	ApiKeyPattern        = regexp.MustCompile(`apiKey=([^,\)]+)`)
	ClientIdPattern      = regexp.MustCompile(`clientId=([^,\)]+)`)
	BrokerFetcherPattern = regexp.MustCompile(`broker-(\d+)-fetcher-(\d+)`)

	ProducerTopicPattern = regexp.MustCompile(`partitionSizes=\[(.+)-\d+=`)
	ConsumerTopicPattern = regexp.MustCompile(`FetchTopic\(topic='([^']+)'`)

	// IAM-specific pattern to extract ARN
	IAMPrincipalArnPattern = regexp.MustCompile(`principal:\[IAM\]:\[(arn:aws:[^\]]+)\]:`)
	// SASL_SCRAM-specific pattern to extract User:username
	SASLSCRAMPrincipalPattern = regexp.MustCompile(`principal:(User:[^ ]+)`)
	// TLS pattern - extract User:CN= and any additional certificate info (requires SSL protocol)
	TLSPrincipalPattern = regexp.MustCompile(`securityProtocol:SSL,principal:(User:CN=[^(]+?)\s*\(`)
	// Anonymous pattern - detect unauthenticated requests with User:ANONYMOUS
	AnonymousPrincipalPattern = regexp.MustCompile(`principal:(User:ANONYMOUS)`)
)

var (
	// lines that match this pattern will be parsed by kafka trace line parser
	KafkaApiTracePattern = regexp.MustCompile(`^\[.*\] TRACE \[KafkaApi-\d+\].*\(kafka\.server\.KafkaApis\)$`)
)