namespace Org\Shipsimu\Hub\Generic;
// Import application-specific stuff
+use Org\ShipSimu\Hub\Communicator\Communicator;
use Org\Shipsimu\Hub\Container\Socket\StorableSocket;
+use Org\Shipsimu\Hub\Crawler\Crawler;
+use Org\Shipsimu\Hub\Crawler\Source\Source;
+use Org\Shipsimu\Hub\Crawler\Source\Url\UrlSource;
use Org\Shipsimu\Hub\Handler\Protocol\HandleableProtocol;
use Org\Shipsimu\Hub\Handler\Network\RawData\HandleableRawData;
use Org\Shipsimu\Hub\Information\ShareableInfo;
*/
private $universalNodeLocatorInstance = NULL;
+ /**
+ * An instance of a communicator
+ */
+ private $communicatorInstance = NULL;
+
+ /**
+ * An instance of a Source class
+ */
+ private $sourceInstance = NULL;
+
+ /**
+ * An instance of a UrlSource class
+ */
+ private $urlSourceInstance = NULL;
+
+ /**
+ * An instance of a Crawler class
+ */
+ private $crawlerInstance = NULL;
+
/**
* Name of used protocol
*/
return $this->universalNodeLocatorInstance;
}
+ /**
+ * Getter for communicator instance
+ *
+ * @return $communicatorInstance An instance of a Communicator class
+ */
+ public final function getCommunicatorInstance () {
+ return $this->communicatorInstance;
+ }
+
+ /**
+ * Setter for communicator instance
+ *
+ * @param $communicatorInstance An instance of a Communicator class
+ * @return void
+ */
+ protected final function setCommunicatorInstance (Communicator $communicatorInstance) {
+ $this->communicatorInstance = $communicatorInstance;
+ }
+
+ /**
+ * Setter for a Source instance
+ *
+ * @param $sourceInstance An instance of a Source class
+ * @return void
+ */
+ protected final function setSourceInstance (Source $sourceInstance) {
+ $this->sourceInstance = $sourceInstance;
+ }
+
+ /**
+ * Getter for a Source instance
+ *
+ * @return $sourceInstance An instance of a Source class
+ */
+ protected final function getSourceInstance () {
+ return $this->sourceInstance;
+ }
+
+ /**
+ * Setter for a UrlSource instance
+ *
+ * @param $urlSourceInstance An instance of a UrlSource class
+ * @return void
+ */
+ public final function setUrlSourceInstance (UrlSource $urlSourceInstance) {
+ $this->urlSourceInstance = $urlSourceInstance;
+ }
+
+ /**
+ * Getter for a UrlSource instance
+ *
+ * @return $urlSourceInstance An instance of a UrlSource class
+ */
+ public final function getUrlSourceInstance () {
+ return $this->urlSourceInstance;
+ }
+
+ /**
+ * Setter for a Crawler instance
+ *
+ * @param $crawlerInstance An instance of a Crawler class
+ * @return void
+ */
+ protected final function setCrawlerInstance (Crawler $crawlerInstance) {
+ $this->crawlerInstance = $crawlerInstance;
+ }
+
+ /**
+ * Getter for a Crawler instance
+ *
+ * @return $crawlerInstance An instance of a Crawler class
+ */
+ protected final function getCrawlerInstance () {
+ return $this->crawlerInstance;
+ }
+
}
namespace Org\Shipsimu\Hub\Communicator;
// Import application-specific stuff
+use Org\Shipsimu\Hub\Factory\State\Communicator\CommunicatorStateFactory;
use Org\Shipsimu\Hub\Generic\BaseHubSystem;
// Import framework stuff
// Own namespace
namespace Org\Shipsimu\Hub\Crawler\Communicator\Node;
+// Import application-specific stuff
+use Org\Shipsimu\Hub\Communicator\BaseCommunicator;
+use Org\ShipSimu\Hub\Communicator\Communicator;
+
// Import framework stuff
use Org\Mxchange\CoreFramework\Registry\Registerable;
// Own namespace
namespace Org\Shipsimu\Hub\Miner\Communicator\Node;
+// Import application-specific stuff
+use Org\Shipsimu\Hub\Communicator\BaseCommunicator;
+use Org\ShipSimu\Hub\Communicator\Communicator;
+
// Import framework stuff
use Org\Mxchange\CoreFramework\Registry\Registerable;
public function addExtraFilters (Controller $controllerInstance, Responseable $responseInstance) {
$this->partialStub('Please implement this method.');
}
-}
-// [EOF]
-?>
+}
namespace Org\Shipsimu\Hub\Crawler;
// Import application-specific stuff
+use Org\Shipsimu\Hub\Crawler\Factory\State\CrawlerStateFactory;
use Org\Shipsimu\Hub\Generic\BaseHubSystem;
// Import framework stuff
public function addExtraFilters (Controller $controllerInstance, Responseable $responseInstance) {
$this->partialStub('Please implement this method.');
}
-}
-// [EOF]
-?>
+}
*
* @param $configEntry A configuration entry naming the real class' name
* @parasm $communicatorType Type of the communicator, can currently be 'node'
- * @return $communicatorInstance A communicator instance
+ * @return $communicatorInstance An instance of a Communicator class
*/
public static final function createCommunicatorInstance ($configEntry, $communicatorType) {
// If there is no communicator?
<?php
// Own namespace
-namespace Org\Shipsimu\Hub\Source\Unit;
+namespace Org\Shipsimu\Hub\Crawler\Source\Unit;
// Import framework stuff
use Org\Mxchange\CoreFramework\Factory\ObjectFactory;
<?php
// Own namespace
-namespace Org\Shipsimu\Hub\Source\Url;
+namespace Org\Shipsimu\Hub\Crawler\Source\Url;
// Import framework stuff
use Org\Mxchange\CoreFramework\Factory\ObjectFactory;
// Own namespace
namespace Org\Shipsimu\Hub\Factory\State\Communicator;
+// Import application-specific stuff
+use Org\ShipSimu\Hub\Communicator\Communicator;
+
// Import framework stuff
use Org\Mxchange\CoreFramework\Factory\ObjectFactory;
* given communicator instance.
*
* @param $stateName Name of the state
- * @param $communicatorInstance A Communicator class instance
- * @return $stateInstance A Stateable class instance
+ * @param $communicatorInstance An instance of a Communicator class
+ * @return $stateInstance An instance of a Stateable class
*/
public static final function createCommunicatorStateInstanceByName ($stateName, Communicator $communicatorInstance) {
// Then construct the class' configuraton entry
<?php
// Own namespace
-namespace Org\Shipsimu\Hub\Factory\State\Crawler;
+namespace Org\Shipsimu\Hub\Crawler\Factory\State;
// Import framework stuff
use Org\Mxchange\CoreFramework\Factory\ObjectFactory;
*/
public function execute (Requestable $requestInstance, Responseable $responseInstance) {
// Get crawler instance
- //$crawlerInstance = Registry::getRegistry()->getInstance('crawler');
+ $crawlerInstance = Registry::getRegistry()->getInstance('crawler');
// Get a new task handler instance
$handlerInstance = ObjectFactory::createObjectByConfiguredName('task_handler_class');
// 10) URL sources
foreach (explode(':', $this->getConfigInstance()->getConfigEntry('crawler_url_stacks')) as $stack) {
// Init task instance
- $taskInstance = ObjectFactory::createObjectByConfiguredName('crawler_url_source_' . $stack . '_task_class');
+ $taskInstance = ObjectFactory::createObjectByConfiguredName('crawler_url_source_' . $stack . '_task_class', array($crawlerInstance));
// And register it
$handlerInstance->registerTask('crawler_url_source_' . $stack, $taskInstance);
use Org\Shipsimu\Hub\Generic\BaseHubSystem;
/**
- * A general Scanner class
+ * A general scanner class
*
* @author Roland Haeder <webmaster@ship-simu.org>
* @version 0.0.0
// Own namespace
namespace Org\Shipsimu\Hub\Crawler\Scanner\UploadedList;
+// Import application-specific stuff
+use Org\Shipsimu\Hub\Scanner\BaseScanner;
+use Org\Shipsimu\Hub\Scanner\Scanner;
+
// Import framework stuff
use Org\Mxchange\CoreFramework\Registry\Registerable;
<?php
// Own namespace
-namespace Org\Shipsimu\Hub\Source;
+namespace Org\Shipsimu\Hub\Crawler\Source;
// Import application-specific stuff
use Org\Shipsimu\Hub\Generic\BaseHubSystem;
/**
- * A general Source class
+ * A general source class
*
* @author Roland Haeder <webmaster@shipsimu.org>
* @version 0.0.0
<?php
+// Own namespace
+namespace Org\Shipsimu\Hub\Crawler\Source\Url;
+
+// Import application-specific stuff
+use Org\Shipsimu\Hub\Crawler\Source\BaseSource;
+
+// Import framework stuff
+use Org\Mxchange\CoreFramework\Factory\Stack\FileStackFactory;
+
/**
* A general URL source class
*
<?php
// Own namespace
-namespace Org\Shipsimu\Hub\Source\Unit;
+namespace Org\Shipsimu\Hub\Crawler\Source\Unit;
+
+// Import application-specific stuff
+use Org\Shipsimu\Hub\Crawler\Source\BaseSource;
// Import framework stuff
use Org\Mxchange\CoreFramework\Factory\ObjectFactory;
/**
* Creates an instance of this class
*
- * @return $sourceInstance An instance of a Source class
+ * @return $sourceInstance An instance of a UnitSource class
*/
public final static function createTestUnitSource () {
// Get new instance
// Own namespace
namespace Org\Shipsimu\Hub\Crawler\Source\FoundRss;
+// Import application-specific stuff
+use Org\Shipsimu\Hub\Crawler\Source\Url\BaseUrlSource;
+use Org\Shipsimu\Hub\Crawler\Source\Url\UrlSource;
+
// Import framework stuff
use Org\Mxchange\CoreFramework\Registry\Registerable;
/**
* Creates an instance of this class
*
- * @return $sourceInstance An instance of a Source class
+ * @return $sourceInstance An instance of an UrlSource class
*/
public final static function createCrawlerFoundRssUrlSource () {
// Get new instance
public function fillUrlStack () {
$this->partialStub('Please implement this method.');
}
-}
-// [EOF]
-?>
+}
// Own namespace
namespace Org\Shipsimu\Hub\Crawler\Source\LocalStart;
+// Import application-specific stuff
+use Org\Shipsimu\Hub\Crawler\Source\Url\BaseUrlSource;
+use Org\Shipsimu\Hub\Crawler\Source\Url\UrlSource;
+
// Import framework stuff
use Org\Mxchange\CoreFramework\Registry\Registerable;
/**
* Creates an instance of this class
*
- * @return $sourceInstance An instance of a Source class
+ * @return $sourceInstance An instance of an UrlSource class
*/
public final static function createCrawlerLocalStartUrlSource () {
// Get new instance
public function fillUrlStack () {
$this->partialStub('Please implement this method.');
}
-}
-// [EOF]
-?>
+}
// Own namespace
namespace Org\Shipsimu\Hub\Crawler\Source\RssStart;
+// Import application-specific stuff
+use Org\Shipsimu\Hub\Crawler\Source\Url\BaseUrlSource;
+use Org\Shipsimu\Hub\Crawler\Source\Url\UrlSource;
+
// Import framework stuff
use Org\Mxchange\CoreFramework\Registry\Registerable;
/**
* Creates an instance of this class
*
- * @return $sourceInstance An instance of a Source class
+ * @return $sourceInstance An instance of an UrlSource class
*/
public final static function createCrawlerRssStartUrlSource () {
// Get new instance
public function fillUrlStack () {
$this->partialStub('Please implement this method.');
}
-}
-// [EOF]
-?>
+}
// Own namespace
namespace Org\Shipsimu\Hub\Crawler\Source\Url\UploadList;
+// Import application-specific stuff
+use Org\Shipsimu\Hub\Crawler\Source\Url\BaseUrlSource;
+use Org\Shipsimu\Hub\Crawler\Source\Url\UrlSource;
+
// Import framework stuff
use Org\Mxchange\CoreFramework\Factory\ObjectFactory;
use Org\Mxchange\CoreFramework\Generic\NullPointerException;
/**
* Creates an instance of this class
*
- * @return $sourceInstance An instance of a Source class
+ * @return $sourceInstance An instance of an UrlSource class
*/
public final static function createCrawlerUploadedListUrlSource () {
// Get new instance
// Own namespace
namespace Org\Shipsimu\Hub\State\Communicator;
+// Import application-specific stuff
+use Org\Shipsimu\Hub\Communicator\BaseCommunicator;
+use Org\ShipSimu\Hub\Communicator\Communicator;
+use Org\Shipsimu\Hub\Communicator\State\BaseCommunicatorState;
+
// Import framework stuff
use Org\Mxchange\CoreFramework\State\Stateable;
// Return the prepared instance
return $stateInstance;
}
-}
-// [EOF]
-?>
+}
// Own namespace
namespace Org\Shipsimu\Hub\Communicator\State;
+// Import application-specific stuff
+use Org\ShipSimu\Hub\Communicator\Communicator;
+
// Import framework stuff
use Org\Mxchange\CoreFramework\State\BaseState;
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
abstract class BaseCommunicatorState extends BaseState {
+ /**
+ * An instance of a communicator
+ */
+ private $communicatorInstance = NULL;
+
/**
* Protected constructor
*
} // END - if
}
+ /**
+ * Getter for communicator instance
+ *
+ * @return $communicatorInstance An instance of a Communicator class
+ */
+ public final function getCommunicatorInstance () {
+ return $this->communicatorInstance;
+ }
+
+ /**
+ * Setter for communicator instance
+ *
+ * @param $communicatorInstance An instance of a Communicator class
+ * @return void
+ */
+ protected final function setCommunicatorInstance (Communicator $communicatorInstance) {
+ $this->communicatorInstance = $communicatorInstance;
+ }
+
}
// Own namespace
namespace Org\Shipsimu\Hub\State\Communicator;
+// Import application-specific stuff
+use Org\Shipsimu\Hub\Communicator\BaseCommunicator;
+use Org\ShipSimu\Hub\Communicator\Communicator;
+use Org\Shipsimu\Hub\Communicator\State\BaseCommunicatorState;
+
// Import framework stuff
use Org\Mxchange\CoreFramework\Executor\Executor;
use Org\Mxchange\CoreFramework\State\Stateable;
*/
public function executeState (Executor $executorInstance) {
}
+
}
// Own namespace
namespace Org\Shipsimu\Hub\State\Crawler;
+// Import application-specific stuff
+use Org\Shipsimu\Hub\Crawler\State\BaseCrawlerState;
+
// Import framework stuff
use Org\Mxchange\CoreFramework\Executor\Executor;
use Org\Mxchange\CoreFramework\State\Stateable;
// Own namespace
namespace Org\Shipsimu\Hub\State\Crawler;
+// Import application-specific stuff
+use Org\Shipsimu\Hub\Crawler\State\BaseCrawlerState;
+
// Import framework stuff
use Org\Mxchange\CoreFramework\Executor\Executor;
use Org\Mxchange\CoreFramework\State\Stateable;
// Own namespace
namespace Org\Shipsimu\Hub\State\Crawler;
+// Import application-specific stuff
+use Org\Shipsimu\Hub\Crawler\State\BaseCrawlerState;
+use Org\Shipsimu\Hub\Crawler\Factory\State\CrawlerStateFactory;
+
// Import framework stuff
use Org\Mxchange\CoreFramework\Executor\Executor;
use Org\Mxchange\CoreFramework\State\Stateable;
// Change state to 'booting'
CrawlerStateFactory::createCrawlerStateInstanceByName('booting');
}
+
}
<?php
// Own namespace
-namespace Org\Shipsimu\Hub\Task\Source\Url;
+namespace Org\Shipsimu\Hub\Crawler\Task\Source\Url;
// Import application-specific stuff
-use Org\Shipsimu\Hub\Source\Url\UrlSourceObjectFactory;
+use Org\Shipsimu\Hub\Crawler\Crawler;
+use Org\Shipsimu\Hub\Crawler\Source\Url\UrlSourceObjectFactory;
// Import framework stuff
use Org\Mxchange\CoreFramework\Task\BaseTask;
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
abstract class BaseUrlSourceTask extends BaseTask {
+ /**
+ * An instance of a Crawler class
+ */
+ private $crawlerInstance = NULL;
+
/**
* Protected constructor
*
$sourceInstance = UrlSourceObjectFactory::createUrlSourceInstance($this);
// And set it here
- $this->setUrlSourceInstance($sourceInstance);
+ $this->getCrawlerInstance()->setUrlSourceInstance($sourceInstance);
+ }
+
+ /**
+ * Setter for a Crawler instance
+ *
+ * @param $crawlerInstance An instance of a Crawler class
+ * @return void
+ */
+ protected final function setCrawlerInstance (Crawler $crawlerInstance) {
+ $this->crawlerInstance = $crawlerInstance;
+ }
+
+ /**
+ * Getter for a Crawler instance
+ *
+ * @return $crawlerInstance An instance of a Crawler class
+ */
+ protected final function getCrawlerInstance () {
+ return $this->crawlerInstance;
}
}
// Own namespace
namespace Org\Shipsimu\Hub\Crawler\Task\Communicator\Node;
+// Import application-specific stuff
+use Org\Shipsimu\Hub\Factory\Communicator\CommunicatorFactory;
+
// Import framework stuff
use Org\Mxchange\CoreFramework\Registry\Registry;
use Org\Mxchange\CoreFramework\Task\BaseTask;
<?php
// Own namespace
-namespace Org\Shipsimu\Hub\Crawler\Ping;
+namespace Org\Shipsimu\Hub\Crawler\Task\Ping;
// Import framework stuff
use Org\Mxchange\CoreFramework\Task\BaseTask;
// Own namespace
namespace Org\Shipsimu\Hub\Crawler\Task\Source\FoundRss;
+// Import application-specific stuff
+use Org\Shipsimu\Hub\Crawler\Crawler;
+use Org\Shipsimu\Hub\Crawler\Task\Source\Url\BaseUrlSourceTask;
+
// Import framework stuff
use Org\Mxchange\CoreFramework\Task\Taskable;
use Org\Mxchange\CoreFramework\Visitor\Visitable;
/**
* Creates an instance of this class
*
+ * @param $crawlerInstance An instance of a Crawler class
* @return $taskInstance An instance of a Visitable class
*/
- public final static function createCrawlerUrlSourceFoundRssTask () {
+ public final static function createCrawlerUrlSourceFoundRssTask (Crawler $crawlerInstance) {
// Get new instance
$taskInstance = new CrawlerUrlSourceFoundRssTask();
+ // Set crawler instance here
+ $taskInstance->setCrawlerInstance($crawlerInstance);
+
// Return the prepared instance
return $taskInstance;
}
*/
public function executeTask () {
// Get source instance
- $sourceInstance = $this->getUrlSourceInstance();
+ $sourceInstance = $this->getCrawlerInstance()->getUrlSourceInstance();
// Is it not set?
if (is_null($sourceInstance)) {
$this->initUrlSourceTask();
// And re-get it
- $sourceInstance = $this->getUrlSourceInstance();
+ $sourceInstance = $this->getCrawlerInstance()->getUrlSourceInstance();
} // END - if
// Get the URL source instance and fill the stack with crawl entries
// Own namespace
namespace Org\Shipsimu\Hub\Crawler\Task\Source\LocalStart;
+// Import application-specific stuff
+use Org\Shipsimu\Hub\Crawler\Crawler;
+use Org\Shipsimu\Hub\Crawler\Task\Source\Url\BaseUrlSourceTask;
+
// Import framework stuff
use Org\Mxchange\CoreFramework\Task\Taskable;
use Org\Mxchange\CoreFramework\Visitor\Visitable;
/**
* Creates an instance of this class
*
+ * @param $crawlerInstance An instance of a Crawler class
* @return $taskInstance An instance of a Visitable class
*/
- public final static function createCrawlerUrlSourceLocalStartTask () {
+ public final static function createCrawlerUrlSourceLocalStartTask (Crawler $crawlerInstance) {
// Get new instance
$taskInstance = new CrawlerUrlSourceLocalStartTask();
+ // Set crawler instance here
+ $taskInstance->setCrawlerInstance($crawlerInstance);
+
// Return the prepared instance
return $taskInstance;
}
*/
public function executeTask () {
// Get source instance
- $sourceInstance = $this->getUrlSourceInstance();
+ $sourceInstance = $this->getCrawlerInstance()->getUrlSourceInstance();
// Is it not set?
if (is_null($sourceInstance)) {
$this->initUrlSourceTask();
// And re-get it
- $sourceInstance = $this->getUrlSourceInstance();
+ $sourceInstance = $this->getCrawlerInstance()->getUrlSourceInstance();
} // END - if
// Get the URL source instance and fill the stack with crawl entries
// Own namespace
namespace Org\Shipsimu\Hub\Crawler\Task\Source\RssStart;
+// Import application-specific stuff
+use Org\Shipsimu\Hub\Crawler\Crawler;
+use Org\Shipsimu\Hub\Crawler\Task\Source\Url\BaseUrlSourceTask;
+
// Import framework stuff
use Org\Mxchange\CoreFramework\Task\Taskable;
use Org\Mxchange\CoreFramework\Visitor\Visitable;
/**
* Creates an instance of this class
*
+ * @param $crawlerInstance An instance of a Crawler class
* @return $taskInstance An instance of a Visitable class
*/
- public final static function createCrawlerUrlSourceRssStartTask () {
+ public final static function createCrawlerUrlSourceRssStartTask (Crawler $crawlerInstance) {
// Get new instance
$taskInstance = new CrawlerUrlSourceRssStartTask();
+ // Set crawler instance here
+ $taskInstance->setCrawlerInstance($crawlerInstance);
+
// Return the prepared instance
return $taskInstance;
}
*/
public function executeTask () {
// Get source instance
- $sourceInstance = $this->getUrlSourceInstance();
+ $sourceInstance = $this->getCrawlerInstance()->getUrlSourceInstance();
// Is it not set?
if (is_null($sourceInstance)) {
$this->initUrlSourceTask();
// And re-get it
- $sourceInstance = $this->getUrlSourceInstance();
+ $sourceInstance = $this->getCrawlerInstance()->getUrlSourceInstance();
} // END - if
// Get the URL source instance and fill the stack with crawl entries
// Own namespace
namespace Org\Shipsimu\Hub\Crawler\Task\Source\UploadedList;
+// Import application-specific stuff
+use Org\Shipsimu\Hub\Crawler\Crawler;
+use Org\Shipsimu\Hub\Crawler\Task\Source\Url\BaseUrlSourceTask;
+
// Import framework stuff
use Org\Mxchange\CoreFramework\Task\Taskable;
use Org\Mxchange\CoreFramework\Visitor\Visitable;
/**
* Creates an instance of this class
*
+ * @param $crawlerInstance An instance of a Crawler class
* @return $taskInstance An instance of a Visitable class
*/
- public final static function createCrawlerUrlSourceUploadedListTask () {
+ public final static function createCrawlerUrlSourceUploadedListTask (Crawler $crawlerInstance) {
// Get new instance
$taskInstance = new CrawlerUrlSourceUploadedListTask();
+ // Set cralwer instance here
+ $taskInstance->setCrawlerInstance($crawlerInstance);
+
// Return the prepared instance
return $taskInstance;
}
*/
public function executeTask () {
// Get source instance
- $sourceInstance = $this->getUrlSourceInstance();
+ $sourceInstance = $this->getCrawlerInstance()->getUrlSourceInstance();
// Is it not set?
if (is_null($sourceInstance)) {
$this->initUrlSourceTask();
// And re-get it
- $sourceInstance = $this->getUrlSourceInstance();
+ $sourceInstance = $this->getCrawlerInstance()->getUrlSourceInstance();
} // END - if
// Get the URL source instance and fill the stack with crawl entries
// Own namespace
namespace Org\Shipsimu\Hub\Miner\Task\Communicator\Node;
+// Import application-specific stuff
+use Org\Shipsimu\Hub\Factory\Communicator\CommunicatorFactory;
+
// Import framework stuff
use Org\Mxchange\CoreFramework\Task\BaseTask;
use Org\Mxchange\CoreFramework\Task\Taskable;
$cfg->setConfigEntry('crawler_node_communicator_task_class', 'Org\Shipsimu\Hub\Crawler\Task\Communicator\Node\CrawlerNodeCommunicatorTask');
// CFG: CRAWLER-URL-LOCAL-START-STACK-CLASS
-$cfg->setConfigEntry('crawler_url_local_start_stack_class', 'Org\Mxchange\CoreFramework\Stack\Filesystem\FiFoFileStack');
+$cfg->setConfigEntry('crawler_url_local_start_stack_class', 'Org\Mxchange\CoreFramework\Stacker\Filesystem\FiFoFileStack');
// CFG: CRAWLER-URL-UPLOADED-LIST-STACK-CLASS
-$cfg->setConfigEntry('crawler_url_uploaded_list_stack_class', 'Org\Mxchange\CoreFramework\Stack\Filesystem\FiFoFileStack');
+$cfg->setConfigEntry('crawler_url_uploaded_list_stack_class', 'Org\Mxchange\CoreFramework\Stacker\Filesystem\FiFoFileStack');
// CFG: CRAWLER-URL-RSS-START-STACK-CLASS
-$cfg->setConfigEntry('crawler_url_rss_start_stack_class', 'Org\Mxchange\CoreFramework\Stack\Filesystem\FiFoFileStack');
+$cfg->setConfigEntry('crawler_url_rss_start_stack_class', 'Org\Mxchange\CoreFramework\Stacker\Filesystem\FiFoFileStack');
// CFG: CRAWLER-URL-FOUND-RSS-STACK-CLASS
-$cfg->setConfigEntry('crawler_url_found_rss_stack_class', 'Org\Mxchange\CoreFramework\Stack\Filesystem\FiFoFileStack');
+$cfg->setConfigEntry('crawler_url_found_rss_stack_class', 'Org\Mxchange\CoreFramework\Stacker\Filesystem\FiFoFileStack');
// CFG: CRAWLER-URL-LOCAL-START-FILE-STACK-INDEX-CLASS
$cfg->setConfigEntry('crawler_url_local_start_file_stack_index_class', 'Org\Mxchange\CoreFramework\Index\Stack\FileStackIndex');
$cfg->setConfigEntry('task_crawler_snippet_extractor_max_runs', 0);
// CFG: CRAWLER-PING-TASK-CLASS
-$cfg->setConfigEntry('crawler_ping_task_class', 'CrawlerPingTask');
+$cfg->setConfigEntry('crawler_ping_task_class', 'Org\Shipsimu\Hub\Crawler\Task\Ping\CrawlerPingTask');
// CFG: TASK-CRAWLER-PING-STARTUP-DELAY
$cfg->setConfigEntry('task_crawler_ping_startup_delay', 1500);
* @return void
*/
function execute ();
-}
-// [EOF]
-?>
+}
<?php
// Own namespace
-namespace Org\Shipsimu\Hub\Source;
+namespace Org\Shipsimu\Hub\Crawler\Source;
// Import application-specific stuff
use Org\Shipsimu\Hub\Generic\HubInterface;
*/
interface Source extends HubInterface {
}
-
-// [EOF]
-?>
<?php
+// Own namespace
+namespace Org\Shipsimu\Hub\Crawler\Source\Unit;
+
+// Import application-specific stuff
+use Org\Shipsimu\Hub\Crawler\Source\Source;
+
/**
* An interface for unit sources
*
* @return $message A message from our source
*/
function generateMessageFromSource ();
-}
-// [EOF]
-?>
+}
<?php
+// Own namespace
+namespace Org\Shipsimu\Hub\Crawler\Source\Url;
+
+// Import application-specific stuff
+use Org\Shipsimu\Hub\Crawler\Source\Source;
+
/**
* An interface for URL sources
*
* @return $isEmpty Whether the stack 'urls' is empty.
*/
function isUrlStackEmpty ();
-}
-// [EOF]
-?>
+}
-Subproject commit ee94e79ac63d2c612ca96ba1928f9400026ce4c0
+Subproject commit bb121094b0c87c1ed028dfb5f86565b782742e6d
projects / hub.git / commitdiff