def extractCommandArguments()

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
  }