_process.php

<?php

use DenisBeliaev\SitemapParser\Link;
use DenisBeliaev\SitemapParser\Page;

require_once __DIR__ . '/config.php';

$opts = getopt('s:p:t:');

$scope = $opts['s'];
$pPID = $opts['p'] ?? null;
$task = $opts['t'] ?? 'check';

$pdo = new PDO(DSN);

$stm = $pdo->prepare('SELECT url FROM pages WHERE scope=:scope');
$stm->execute([':scope' => $scope]);
$items = $stm->fetchAll(PDO::FETCH_COLUMN);
unset($stm);

$ch = curl_init();
if ($task == 'check') {
    curl_setopt($ch, CURLOPT_NOBODY, true);
} else if ($task == 'parse-links') {
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
}
foreach ($items as $item) {
    curl_setopt($ch, CURLOPT_URL, $item);
    $httpCode = 'ERR';
    if ($content = curl_exec($ch)) {
        $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
        if ($httpCode == 501 && $task == 'check') {
            curl_setopt($ch, CURLOPT_NOBODY, false);
            if ($content = curl_exec($ch)) {
                $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
            }
            curl_setopt($ch, CURLOPT_NOBODY, true);
        }
    }

    $pdo->setAttribute(PDO::ATTR_TIMEOUT, 100);
    $stm = $pdo->prepare('UPDATE pages SET status=:status WHERE url=:url');
    $stm->execute([':status' => $httpCode, ':url' => $item]);
    unset($stm);

    if ($task == 'parse-links') {
        $Page = new Page($content, $item);
        $links = $Page->links;
        foreach ($links as &$link) {
            $link = Link::normalize($link, $Page->base);
        }
        $links = array_unique(array_filter($links));

        foreach ($links as $key => &$link) {
            $link = [$item, $Page->links[$key], $link];
        }
        $links = array_filter($links, function ($value) use ($pdo) {
            $stm = $pdo->prepare('SELECT COUNT(url) FROM pages WHERE url=:url');
            $stm->execute([':url' => $value[2]]);
            $result = $stm->fetchColumn();
            return $result == 0;
        });
        if (!empty($links)) {
            $parameters = [];
            foreach ($links as $link) {
                $parameters[] = $link[0];
                $parameters[] = $link[1];
                $parameters[] = $link[2];
            }

            $pdo->setAttribute(PDO::ATTR_TIMEOUT, 100);
            $stm = $pdo->prepare('INSERT OR IGNORE INTO links (`page`, link, url) VALUES ' . implode(',', array_pad([], count($links), '(?,?,?)')));
            if ($stm == false) {
                fwrite(STDERR, $pdo->errorInfo()[2] . PHP_EOL);
                exit;
            }
            $stm->execute($parameters);
            unset($stm);
        }
    }

    if ($pPID && !isRunning($pPID)) {
        exit(1);
    }
}

unset($pdo);
curl_close($ch);

function isRunning($pid)
{
    if (function_exists('posix_kill')) {
        return posix_kill($pid, 0);
    }
    exec('ps -W -p ' . $pid, $out);
    return count($out) > 1;
}