aboutsummaryrefslogtreecommitdiff
path: root/bin/phinde-worker.php
diff options
context:
space:
mode:
authorChristian Weiske <cweiske@cweiske.de>2016-02-01 20:18:59 +0100
committerChristian Weiske <cweiske@cweiske.de>2016-02-01 20:18:59 +0100
commit7b4425b096fa8c18d0db9fd9b1ae96d63ee8af55 (patch)
tree2dc5d998a1fd0238592b451ff88b5c4cec064f9b /bin/phinde-worker.php
downloadphinde-7b4425b096fa8c18d0db9fd9b1ae96d63ee8af55.tar.gz
phinde-7b4425b096fa8c18d0db9fd9b1ae96d63ee8af55.zip
first kinda working version
Diffstat (limited to 'bin/phinde-worker.php')
-rwxr-xr-xbin/phinde-worker.php34
1 files changed, 34 insertions, 0 deletions
diff --git a/bin/phinde-worker.php b/bin/phinde-worker.php
new file mode 100755
index 0000000..e8253ff
--- /dev/null
+++ b/bin/phinde-worker.php
@@ -0,0 +1,34 @@
+#!/usr/bin/env php
+<?php
+namespace phinde;
+
+chdir(dirname($argv[0]));
+
+$gmworker = new \GearmanWorker();
+$gmworker->addServer('127.0.0.1');
+
+$gmworker->addFunction(
+ 'phinde_crawl',
+ function(\GearmanJob $job) {
+ $data = unserialize($job->workload());
+ echo "-- Crawling " . $data['url'] . "\n";
+ passthru('./crawl.php ' . escapeshellarg($data['url']));
+ }
+);
+$gmworker->addFunction(
+ 'phinde_index',
+ function(\GearmanJob $job) {
+ $data = unserialize($job->workload());
+ echo "-- Indexing " . $data['url'] . "\n";
+ passthru('./index.php ' . escapeshellarg($data['url']));
+ //exit();
+ }
+);
+
+while ($gmworker->work()) {
+ if ($gmworker->returnCode() != GEARMAN_SUCCESS) {
+ echo 'Error running job: ' . $gmworker->returnCode() . "\n";
+ break;
+ }
+}
+?>