path: root/Zotlabs/Daemon/Cache_query.php

<?php

namespace Zotlabs\Daemon;

use Zotlabs\Lib\Cache;
use Zotlabs\Lib\Config;

class Cache_query {

	static public function run($argc, $argv) {

		if(! $argc == 3)
			return;

		$r = null;
		$key = $argv[1];

		$pid = Config::Get('procid', $key, false);
		if ($pid && (function_exists('posix_kill') ? posix_kill($pid, 0) : true)) {
			logger($key . ': procedure already run with pid ' . $pid, LOGGER_DEBUG);
			return;
		}

		$pid = getmypid();
		Config::Set('procid', $key, $pid);

		array_shift($argv);
		array_shift($argv);

		$arr = json_decode(base64_decode($argv[0]), true);

		$r = call_user_func_array('q', $arr);

		if(is_array($r)) {
			Cache::set($key, serialize($r));
		}

		Config::Delete('procid', $key);

		return;
	}
}