pipeline {
  agent { label 'maven' }
  options {
    timestamps()
    ansiColor('xterm')
  }
  stages {
    stage('Prepare Metadata') {
      steps {
        script {
          wrap([$class: 'BuildUser']) {
            env.RUN_TRIGGER_USER = env.BUILD_USER_ID ?: env.BUILD_USER ?: 'system'
            env.RUN_TRIGGER_NAME = env.BUILD_USER ?: env.BUILD_USER_ID ?: 'system'
          }
          currentBuild.displayName = "#${env.BUILD_NUMBER} ${params.BROWSER}/${params.HEADLESS}"
          currentBuild.description =
            "by=${env.RUN_TRIGGER_NAME}; repo=${params.QA_REPO_URL}; ref=${params.QA_REPO_REF}; mode=${params.EXECUTION_MODE}"
        }
      }
    }
    stage('Run Selenium Tests In Docker') {
      steps {
        sh '''
          set -eux
          git config --global --add safe.directory '*' || true
          rm -rf ./sources
          git clone "${QA_REPO_URL}" ./sources
          git -C ./sources checkout "${QA_REPO_REF}"
          GIT_SHA="$(git -C ./sources rev-parse --short HEAD)"
          REMOTE_FACTORY="./sources/src/main/java/ru/kovbasa/driver/RemoteDriverFactory.java"
          if [ -f "${REMOTE_FACTORY}" ] && ! grep -q "selenoid.video.enabled" "${REMOTE_FACTORY}"; then
            sed -i 's/"enableVideo", false/"enableVideo", Boolean.parseBoolean(System.getProperty("selenoid.video.enabled", "false"))/' "${REMOTE_FACTORY}"
          fi
          if ! grep -q "<artifactId>allure-junit5</artifactId>" ./sources/pom.xml; then
            awk -v ver="${ALLURE_ADAPTER_VERSION}" '
              index($0, "</dependencies>") && !done {
                print "        <dependency>"
                print "            <groupId>io.qameta.allure</groupId>"
                print "            <artifactId>allure-junit5</artifactId>"
                print "            <version>" ver "</version>"
                print "            <scope>test</scope>"
                print "        </dependency>"
                done=1
              }
              { print }
            ' ./sources/pom.xml > ./sources/pom.xml.tmp
            mv ./sources/pom.xml.tmp ./sources/pom.xml
          fi

          rm -rf ./artifacts
          mkdir -p ./artifacts
          {
            echo "job=${JOB_NAME}"
            echo "build=${BUILD_NUMBER}"
            echo "trigger_user=${RUN_TRIGGER_USER}"
            echo "trigger_name=${RUN_TRIGGER_NAME}"
            echo "qa_repo_url=${QA_REPO_URL}"
            echo "qa_repo_ref=${QA_REPO_REF}"
            echo "qa_repo_sha=${GIT_SHA}"
            echo "browser=${BROWSER}"
            echo "headless=${HEADLESS}"
            echo "execution_mode=${EXECUTION_MODE}"
            echo "selenoid_url=${SELENOID_URL}"
            echo "base_url=${BASE_URL}"
            echo "timestamp_utc=$(date -u +%Y-%m-%dT%H:%M:%SZ)"
          } > ./artifacts/run-info.txt

          EXTRA_ARGS=""
          if [ "${BROWSER}" = "chrome" ]; then
            EXTRA_ARGS="-Dchrome.binary=/usr/bin/chromium"
          fi
          VIDEO_ARGS=""
          SELENOID_BASE=""
          SELENOID_VIDEO_BEFORE="./artifacts/selenoid-videos-before.txt"
          SELENOID_VIDEO_AFTER="./artifacts/selenoid-videos-after.txt"
          SELENOID_VIDEO_NEW="./artifacts/selenoid-videos-new.txt"
          : > "${SELENOID_VIDEO_BEFORE}"
          : > "${SELENOID_VIDEO_AFTER}"
          : > "${SELENOID_VIDEO_NEW}"
          if [ "${EXECUTION_MODE}" = "selenoid" ]; then
            case "${BROWSER}" in
              chrome) docker pull selenoid/vnc:chrome_128.0 || true ;;
              firefox) docker pull selenoid/vnc:firefox_125.0 || true ;;
            esac
            docker pull selenoid/video-recorder:latest-release || docker pull selenoid/video-recorder:latest || true
            VIDEO_ARGS="-Dselenoid.video.enabled=true"
            if [ -n "${SELENOID_URL}" ]; then
              SELENOID_BASE="${SELENOID_URL%/wd/hub}"
              (curl -fsS "${SELENOID_BASE}/video/" || true) \
                | tr '"' '\n' \
                | grep -E '\\.mp4$' \
                | sort -u > "${SELENOID_VIDEO_BEFORE}" || true
            fi
          fi

          CID="$(docker create \
            --add-host=host.docker.internal:host-gateway \
            localhost:5005/otus/test-selenium:1.0.0 \
            bash -lc "set -e; cd /workspace; mvn -Dallure.version=${ALLURE_ADAPTER_VERSION} -Dexecution.mode=${EXECUTION_MODE} -Dbrowser=${BROWSER} -Dbrowser.version= -Dselenoid.url=${SELENOID_URL} -Dbase.url=${BASE_URL} -Dselenide.headless=${HEADLESS} -Dallure.results.directory=target/allure-results ${VIDEO_ARGS} ${EXTRA_ARGS} test")"
          cleanup_container() {
            docker rm -f "${CID}" >/dev/null 2>&1 || true
          }
          trap cleanup_container EXIT INT TERM
          tar -C ./sources -cf - . | docker cp - "${CID}:/workspace"
          set +e
          docker start -a "${CID}"
          TEST_RC=$?
          docker cp "${CID}:/workspace/target" "./artifacts" || true
          mkdir -p ./artifacts/target/allure-results
          if [ "${EXECUTION_MODE}" = "selenoid" ] && [ -n "${SELENOID_URL}" ]; then
            (curl -fsS "${SELENOID_BASE}/video/" || true) \
              | tr '"' '\n' \
              | grep -E '\\.mp4$' \
              | sort -u > "${SELENOID_VIDEO_AFTER}" || true
            comm -13 "${SELENOID_VIDEO_BEFORE}" "${SELENOID_VIDEO_AFTER}" > "${SELENOID_VIDEO_NEW}" || true
            if [ ! -s "${SELENOID_VIDEO_NEW}" ]; then
              cp "${SELENOID_VIDEO_AFTER}" "${SELENOID_VIDEO_NEW}" || true
            fi
            while IFS= read -r video_file; do
              [ -n "${video_file}" ] || continue
              downloaded=0
              for i in $(seq 1 20); do
                if curl -fsS "${SELENOID_BASE}/video/${video_file}" -o "./artifacts/target/${video_file}"; then
                  downloaded=1
                  break
                fi
                sleep 2
              done
              if [ "${downloaded}" -ne 1 ]; then
                echo "Failed to fetch Selenoid video: ${video_file}"
              fi
            done < "${SELENOID_VIDEO_NEW}"
          fi

          ATTACHMENT_COUNT=0
          ATTACHMENTS_MANIFEST="./artifacts/target/allure-results/.external-attachments.txt"
          : > "${ATTACHMENTS_MANIFEST}"
          ATTACH_FILES="$(find ./artifacts -type f \\( -iname '*.png' -o -iname '*.jpg' -o -iname '*.jpeg' -o -iname '*.mp4' -o -iname '*.webm' \\) 2>/dev/null || true)"
          if [ -n "${ATTACH_FILES}" ]; then
            while IFS= read -r attachment_file; do
              if [ -z "${attachment_file}" ] || [ ! -f "${attachment_file}" ]; then
                continue
              fi
              ATTACHMENT_COUNT=$((ATTACHMENT_COUNT + 1))
              ext="$(echo "${attachment_file}" | awk -F. '{print tolower($NF)}')"
              mime="application/octet-stream"
              case "${ext}" in
                png) mime="image/png" ;;
                jpg|jpeg) mime="image/jpeg" ;;
                mp4) mime="video/mp4" ;;
                webm) mime="video/webm" ;;
              esac
              source_name="external-attachment-${ATTACHMENT_COUNT}.${ext}"
              cp "${attachment_file}" "./artifacts/target/allure-results/${source_name}" || continue
              safe_name="$(basename "${attachment_file}" | sed 's/"/\\"/g')"
              printf '%s|%s|%s\n' "${safe_name}" "${mime}" "${source_name}" >> "${ATTACHMENTS_MANIFEST}"
            done <<EOF
${ATTACH_FILES}
EOF
          fi
          if [ "${ATTACHMENT_COUNT}" -gt 0 ]; then
            ATTACHMENTS_JSON="$(awk -F'|' 'BEGIN{first=1} {if(!first){printf(",")} first=0; gsub(/"/,"\\\"", $1); printf("{\\\"name\\\":\\\"%s\\\",\\\"type\\\":\\\"%s\\\",\\\"source\\\":\\\"%s\\\"}", $1, $2, $3)}' "${ATTACHMENTS_MANIFEST}")"
            EXTRA_UUID="$(cat /proc/sys/kernel/random/uuid)"
            TS_MS="$(( $(date +%s) * 1000 ))"
            cat > "./artifacts/target/allure-results/${EXTRA_UUID}-result.json" <<EOF
{
  "uuid": "${EXTRA_UUID}",
  "historyId": "external-artifacts-${BUILD_NUMBER}",
  "name": "Collected artifacts",
  "fullName": "pipeline.CollectedArtifacts",
  "status": "passed",
  "stage": "finished",
  "start": ${TS_MS},
  "stop": ${TS_MS},
  "labels": [
    {"name": "suite", "value": "Pipeline Artifacts"},
    {"name": "package", "value": "pipeline"},
    {"name": "testClass", "value": "CollectedArtifacts"},
    {"name": "testMethod", "value": "attach"}
  ],
  "attachments": [${ATTACHMENTS_JSON}],
  "steps": [],
  "parameters": []
}
EOF
          fi
          {
            echo "job=${JOB_NAME}"
            echo "build=${BUILD_NUMBER}"
            echo "trigger.user=${RUN_TRIGGER_USER}"
            echo "trigger.name=${RUN_TRIGGER_NAME}"
            echo "repo.url=${QA_REPO_URL}"
            echo "repo.ref=${QA_REPO_REF}"
            echo "repo.sha=${GIT_SHA}"
            echo "browser=${BROWSER}"
            echo "headless=${HEADLESS}"
            echo "execution.mode=${EXECUTION_MODE}"
            echo "base.url=${BASE_URL}"
            echo "video.selection=all-new-from-selenoid"
          } > ./artifacts/target/allure-results/environment.properties
          cat > ./artifacts/target/allure-results/executor.json <<EOF
{
  "name": "Jenkins",
  "type": "jenkins",
  "url": "${JENKINS_URL}",
  "buildName": "${JOB_NAME} #${BUILD_NUMBER}",
  "buildUrl": "${BUILD_URL}",
  "reportUrl": "${BUILD_URL}allure",
  "buildOrder": ${BUILD_NUMBER}
}
EOF
          cat > ./artifacts/target/allure-results/categories.json <<'EOF'
[
  {
    "name": "Infrastructure issues",
    "matchedStatuses": ["broken"],
    "messageRegex": ".*(Connection refused|No route to host|timed out|timeout).*"
  },
  {
    "name": "UI locator/assertion issues",
    "matchedStatuses": ["failed", "broken"],
    "messageRegex": ".*(Element not found|NoSuchElement|AssertionError).*"
  }
]
EOF
          trap - EXIT INT TERM
          docker rm -f "${CID}" || true
          exit "${TEST_RC}"
        '''
      }
    }
  }
  post {
    always {
      script {
        try {
          allure commandline: 'allure', includeProperties: false, jdk: '', results: [[path: 'artifacts/target/allure-results']]
        } catch (Exception ex) {
          echo "Allure publisher unavailable: ${ex.message}"
        }
      }
      junit allowEmptyResults: true, testResults: 'artifacts/target/surefire-reports/*.xml'
      archiveArtifacts allowEmptyArchive: true, artifacts: 'artifacts/run-info.txt,artifacts/target/**'
    }
  }
}