license_cache.php

<?php
require_once __DIR__ . "/common.php";
require_once __DIR__ . "/lmtools.php";

db_connect($db);

$sql = <<<SQL
INSERT IGNORE INTO `available` (`license_id`, `date`, `num_licenses`)
SELECT `licenses`.`id`, NOW(), ? FROM `licenses`
JOIN `servers` ON `licenses`.`server_id`=`servers`.`id`
JOIN `features` ON `licenses`.`feature_id`=`features`.`id`
WHERE `servers`.`name`=? AND `features`.`name`=?;
SQL;
$query = $db->prepare($sql);

$servers = db_get_servers($db, array('name', 'license_manager'));
$lmtools = new lmtools();

$db->begin_transaction(MYSQLI_TRANS_START_READ_WRITE);
foreach ($servers as $server) {
    if ($lmtools->lm_open($server['license_manager'], 'license_cache', $server['name']) === false) {
        $db->rollback();
        fprintf(STDERR, "%s\n", $lmtools->err);
        exit(1);
    }

    $lmdata = $lmtools->lm_nextline();
    if ($lmdata === false) {
        $db->rollback();
        fprintf(STDERR, "%s\n", $lmtools->err);
        exit(1);
    }

    while (!is_null($lmdata)) {
        $query->bind_param("iss", $lmdata['num_licenses'], $server['name'], $lmdata['feature']);
        if ($query->execute() === false) {
            $db->rollback();
            fprintf(STDERR, "MySQL: %s\n", $query->error);
            exit(1);
        }

        $lmdata = $lmtools->lm_nextline();
        if ($lmdata === false) {
            $db->rollback();
            fprintf(STDERR, "%s\n", $lmtools->err);
            exit(1);
        }
    }
}

$db->commit();
$db->close();
?>