root/trunk/midgard/tools/midrepository/spool.php.in

<?
define('DEBUG', 1);
define('THIS_MGDDB', 1);

require_once 'paths.php';
require_once 'vcconfig.php';
require_once 'DataWorkFlow.php';

mgd_auth_midgard($rootuser, $rootpwd, false);
$midgard = mgd_get_midgard();

$host = mgd_get_host($midgard->host);
if ($host->port == 80) {
  define ('LOCK', '/tmp/spool.lock.LIVE');
  require_once 'live.php';
} else {
  define ('LOCK', '/tmp/spool.lock.HEAD');
  require_once 'staging.php';
}

/* function mtimeCmp($f1, $f2) {
  return (filemtime($f1) < filemtime($f2))?-1:1;
}*/

function microtimeCmp($f1, $f2) {
  $b1 = basename($f1);
  $b2 = basename($f2);
  $chunks1 = explode('.', $b1);
  $chunks2 = explode('.', $b2);
  return ($chunks1[1] > $chunks2[1])?1:-1;
}

if (@stat(LOCK)) {
  die( "Spool busy.");
}

touch(LOCK);

wfInit();
$vcs = VCSessionRegistry::getDefaultVCSession();

/** first handle status for "not current" parts / wf-procs **/
$parts = MgdPart::searchNotCurrent();
if (is_array($parts)) {
  foreach ($parts as $part) {
    $myPart = MgdPart::readById($part);
    echo "<h2>HANDLE PENDING PART " . $myPart->getGuid() . "</h2>";
    $myPart->handleStatus();
  }
}

$procs = WorkflowProc::searchNotCurrent();
if (is_array($procs)) {
  foreach ($procs as $proc) {
    echo "<h2>HANDLE PENDING WFPROC " . $proc . "</h2>";
    $myProc = WorkflowProc::readById($proc);
    $myProc->handleStatus();
  }
}

$MgdDB = $vcs->getMgdDB();
$allnewfiles = array();
$d = dir($VCSessionConf['fsconf']['incoming']);
while (false !== ($dent = $d->read())) {
  if ($dent == '..' or $dent == '.')
    continue;
  $fullname = $VCSessionConf['fsconf']['incoming'] . "/$dent";
  if (@stat("$fullname.lock"))
    continue;
  $author = substr($dent, 0, 32);
  if (!is_guid($author)) {
    continue;
  }
  echo "HIER: $fullname";flush();
  $archive = new MgdArchive($fullname);
  if (is_object($archive)) {
    $allnewfiles[$author][] = $fullname;
  }
  echo $dent."<br>\n";
}
$d->close();  

//ob_implicit_flush();
foreach($allnewfiles as $author => $newfiles) {
  print_r($newfiles);
  usort($newfiles, 'microtimeCmp');
  foreach($newfiles as $newfile) {
    echo "<h2>HANDLE INCOMING FILE " . $newfile . "</h2>";
    echo "<br><br><br>ARCHIVE: $newfile<br>";
    $archive = new MgdArchive($newfile);
    if (is_object($archive)) {
      echo "JUHU, ICH BIN WIRKLICH EIN ARCHIV.<br>";
      $guids = $archive->listGuids();
      if (!is_array($guids)) {
        $archive->deleteFile();
        continue;
      }
      echo "FOLGENDE GUIDS NENNE ICH MEIN: ";
      var_dump($guids);
      echo "<br>";
      $newguids = MgdPart::searchNewGuids($guids);
      echo "DAVON SIND FOLGENDE NEU: ";
      var_dump($newguids);
      echo "<br>";
      if (is_array($newguids)) {
        foreach($newguids as $newguid) {
          $part = MgdPart::brew($newguid, PART_NEW_DB);
          $part->write();
          echo "LOCKING NEW OBJ " . $newguid . "<br>";
          $part->lock();
        }
      }
      $parts = array();
      foreach($guids as $guid) {
        $parts[] = MgdPart::readByGuid($guid);
      }
      $current = true;
      foreach($parts as $part) {
        if ($part->getStatus() != PART_CURRENT) {
          if (!in_array($guid, $newguids)) {
            $current = false;
            break;
          }
        } else {
          echo "LOCKING OLD OBJ " . $part->getGuid() . "<br>";
          $part->lock();
        }
      }
      if ($current) {
        $MgdDB->importKeepDeleted($archive);
        $archive->deleteFile();
        foreach ($parts as $part) {
          echo "<b>";
          echo $MgdDB->get_path_by_guid($part->getGuid());
          echo "</b><br>";
          $part->setStatus(PART_NEW_DB, $author);
        }
        echo "KLINK 4.";
      }
      foreach($parts as $part) {
        echo "UNLOCKING OBJ " . $part->getGuid() . "<br>";
        $part->unlock();
        echo "RETURN : " . $part->handleStatus();
      }
    } 
  }
}

/* $log = ob_get_contents();
$fp = fopen ('/var/mgd/spool.log', 'a');
fwrite($fp, $log);
fclose($fp);
ob_end_flush();
*/
unlink(LOCK);

?>