in auditlog/src/main/scala/com/gerritforge/analytics/auditlog/spark/sql/udf/SparkExtractors.scala [61:76]
def extractCommandArguments(what: String, accessPath: String): Option[String] = accessPath match {
case "SSH_COMMAND" => extractGroup(GERRIT_SSH_COMMAND_ARGUMENTS, what)
case "GIT" =>
Option(
extractGroup(GIT_SSH_COMMAND_ARGUMENTS, what)
.getOrElse(extractOrElse(GIT_HTTP_COMMAND_ARGUMENTS, what, null))
)
case "REST_API" | "UNKNOWN" => Some(what)
case "JSON_RPC" => None
case null if what == "AUTH" => None
case unexpected =>
logger.warn(
s"Unexpected access path '$unexpected' encountered when extracting command arguments from '$what'"
)
None
}