[TASK] Code working again. Introduced basic protocol handler structures.
This commit is contained in:
parent
3bd7a6e0f9
commit
4bbb9bf548
|
@ -41,11 +41,11 @@ abstract class Client_AbstractClient {
|
||||||
* Forwards incoming data to the ProtocolParser.
|
* Forwards incoming data to the ProtocolParser.
|
||||||
* Calls protected processData()
|
* Calls protected processData()
|
||||||
* @param string $rawData
|
* @param string $rawData
|
||||||
* @return void
|
* @return string
|
||||||
*/
|
*/
|
||||||
public function processRawData($rawData) {
|
public function processRawData($rawData) {
|
||||||
$contentObject = $this->protocolHandler->parse($rawData);
|
$contentObject = $this->protocolHandler->parse($rawData);
|
||||||
$this->processContentObject($contentObject);
|
return $this->processContentObject($contentObject);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
|
@ -33,6 +33,7 @@ class Client_IrcClient extends Client_AbstractClient {
|
||||||
* @return string
|
* @return string
|
||||||
*/
|
*/
|
||||||
public function processContentObject($contentObject) {
|
public function processContentObject($contentObject) {
|
||||||
|
var_dump($contentObject);
|
||||||
$data = $contentObject->rawData;
|
$data = $contentObject->rawData;
|
||||||
//echo "[RECV] ".$data;
|
//echo "[RECV] ".$data;
|
||||||
|
|
||||||
|
|
|
@ -1,6 +1,6 @@
|
||||||
<?php
|
<?php
|
||||||
$clientManager = new Client_ClientManager();
|
$clientManager = new Client_ClientManager();
|
||||||
$clientManager->registerProtocol("irc", "Client_IrcClient");
|
$clientManager->registerProtocol("Irc", "Client_IrcClient");
|
||||||
$clientManager->registerProtocol("jpt", "Client_BotClient");
|
$clientManager->registerProtocol("jpt", "Client_BotClient");
|
||||||
|
|
||||||
$freenode = $clientManager->createTcpConnection("freenode", "Irc");
|
$freenode = $clientManager->createTcpConnection("freenode", "Irc");
|
||||||
|
@ -30,9 +30,9 @@ $eloxoph = $clientManager->createTcpConnection("eloxoph", "irc");
|
||||||
$clientManager->attachConfig($config_eloxoph, $eloxoph);
|
$clientManager->attachConfig($config_eloxoph, $eloxoph);
|
||||||
$eloxoph->connect("irc.eloxoph.com", 6667);*/
|
$eloxoph->connect("irc.eloxoph.com", 6667);*/
|
||||||
|
|
||||||
$srv = $clientManager->createTcpConnection("srv", "jpt");
|
/*$srv = $clientManager->createTcpConnection("srv", "jpt");
|
||||||
$srv->bind("localhost", 7777);
|
$srv->bind("localhost", 7777);
|
||||||
$srv->listen();
|
$srv->listen();*/
|
||||||
|
|
||||||
while($clientManager->countConnections() > 0) {
|
while($clientManager->countConnections() > 0) {
|
||||||
$clientManager->work();
|
$clientManager->work();
|
||||||
|
|
Loading…
Reference in New Issue