mirror of https://github.com/axmolengine/axmol.git
[v3-update-sio] updates SocketIO tests and examples for using the SocketIO extension
Signed-off-by: Chris Hannon <himynameschris@gmail.com>
This commit is contained in:
Chris Hannon
parent
5af28838d2
commit
fb10217e2b
|
|
@ -1,11 +1,28 @@
|
|||
//
|
||||
// SocketIOTest.cpp
|
||||
// TestCpp
|
||||
//
|
||||
// Created by Chris Hannon on 6/26/13.
|
||||
//
|
||||
//
|
||||
/****************************************************************************
|
||||
Copyright (c) 2015 Chris Hannon http://www.channon.us
|
||||
Copyright (c) 2013-2015 Chukong Technologies Inc.
|
||||
|
||||
http://www.cocos2d-x.org
|
||||
|
||||
Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
of this software and associated documentation files (the "Software"), to deal
|
||||
in the Software without restriction, including without limitation the rights
|
||||
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
||||
copies of the Software, and to permit persons to whom the Software is
|
||||
furnished to do so, subject to the following conditions:
|
||||
|
||||
The above copyright notice and this permission notice shall be included in
|
||||
all copies or substantial portions of the Software.
|
||||
|
||||
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
||||
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
||||
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
||||
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
|
||||
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
|
||||
THE SOFTWARE.
|
||||
|
||||
****************************************************************************/
|
||||
|
||||
#include "SocketIOTest.h"
|
||||
#include "../ExtensionsTest.h"
|
||||
|
|
@ -22,74 +39,75 @@ SocketIOTests::SocketIOTests()
|
|||
SocketIOTest::SocketIOTest()
|
||||
: _sioClient(nullptr)
|
||||
, _sioEndpoint(nullptr)
|
||||
{
|
||||
//set the clients to nullptr until we are ready to connect
|
||||
, _sioClientStatus(nullptr)
|
||||
{//set the clients to nullptr until we are ready to connect
|
||||
|
||||
Size winSize = Director::getInstance()->getWinSize();
|
||||
|
||||
const int MARGIN = 40;
|
||||
const int SPACE = 35;
|
||||
|
||||
auto menuRequest = Menu::create();
|
||||
menuRequest->setPosition(Vec2::ZERO);
|
||||
addChild(menuRequest);
|
||||
|
||||
// Test to create basic client in the default namespace
|
||||
auto labelSIOClient = Label::createWithTTF("Open SocketIO Client", "fonts/arial.ttf", 22);
|
||||
auto itemSIOClient = MenuItemLabel::create(labelSIOClient, CC_CALLBACK_1(SocketIOTest::onMenuSIOClientClicked, this));
|
||||
|
||||
const int MARGIN = 40;
|
||||
const int SPACE = 35;
|
||||
|
||||
auto menuRequest = Menu::create();
|
||||
menuRequest->setPosition(Vec2::ZERO);
|
||||
addChild(menuRequest);
|
||||
|
||||
// Test to create basic client in the default namespace
|
||||
auto labelSIOClient = Label::createWithTTF("Open SocketIO Client", "fonts/arial.ttf", 22);
|
||||
auto itemSIOClient = MenuItemLabel::create(labelSIOClient, CC_CALLBACK_1(SocketIOTest::onMenuSIOClientClicked, this));
|
||||
itemSIOClient->setPosition(Vec2(VisibleRect::left().x + labelSIOClient->getContentSize().width / 2 + 5, winSize.height - MARGIN - SPACE));
|
||||
menuRequest->addChild(itemSIOClient);
|
||||
menuRequest->addChild(itemSIOClient);
|
||||
|
||||
// Test to create a client at the endpoint '/testpoint'
|
||||
auto labelSIOEndpoint = Label::createWithTTF("Open SocketIO Endpoint", "fonts/arial.ttf", 22);
|
||||
auto itemSIOEndpoint = MenuItemLabel::create(labelSIOEndpoint, CC_CALLBACK_1(SocketIOTest::onMenuSIOEndpointClicked, this));
|
||||
auto labelSIOEndpoint = Label::createWithTTF("Open SocketIO Endpoint", "fonts/arial.ttf", 22);
|
||||
auto itemSIOEndpoint = MenuItemLabel::create(labelSIOEndpoint, CC_CALLBACK_1(SocketIOTest::onMenuSIOEndpointClicked, this));
|
||||
itemSIOEndpoint->setPosition(Vec2(VisibleRect::right().x - labelSIOEndpoint->getContentSize().width / 2 - 5, winSize.height - MARGIN - SPACE));
|
||||
menuRequest->addChild(itemSIOEndpoint);
|
||||
menuRequest->addChild(itemSIOEndpoint);
|
||||
|
||||
// Test sending message to default namespace
|
||||
auto labelTestMessage = Label::createWithTTF("Send Test Message", "fonts/arial.ttf", 22);
|
||||
auto itemTestMessage = MenuItemLabel::create(labelTestMessage, CC_CALLBACK_1(SocketIOTest::onMenuTestMessageClicked, this));
|
||||
itemTestMessage->setPosition(Vec2(VisibleRect::left().x + labelTestMessage->getContentSize().width / 2 + 5, winSize.height - MARGIN - 2 * SPACE));
|
||||
menuRequest->addChild(itemTestMessage);
|
||||
auto labelTestMessage = Label::createWithTTF("Send Test Message", "fonts/arial.ttf", 22);
|
||||
auto itemTestMessage = MenuItemLabel::create(labelTestMessage, CC_CALLBACK_1(SocketIOTest::onMenuTestMessageClicked, this));
|
||||
itemTestMessage->setPosition(Vec2(VisibleRect::left().x + labelTestMessage->getContentSize().width / 2 + 5, winSize.height - MARGIN - 2 * SPACE));
|
||||
menuRequest->addChild(itemTestMessage);
|
||||
|
||||
// Test sending message to the endpoint '/testpoint'
|
||||
auto labelTestMessageEndpoint = Label::createWithTTF("Test Endpoint Message", "fonts/arial.ttf", 22);
|
||||
auto itemTestMessageEndpoint = MenuItemLabel::create(labelTestMessageEndpoint, CC_CALLBACK_1(SocketIOTest::onMenuTestMessageEndpointClicked, this));
|
||||
itemTestMessageEndpoint->setPosition(Vec2(VisibleRect::right().x - labelTestMessageEndpoint->getContentSize().width / 2 - 5, winSize.height - MARGIN - 2 * SPACE));
|
||||
menuRequest->addChild(itemTestMessageEndpoint);
|
||||
auto labelTestMessageEndpoint = Label::createWithTTF("Test Endpoint Message", "fonts/arial.ttf", 22);
|
||||
auto itemTestMessageEndpoint = MenuItemLabel::create(labelTestMessageEndpoint, CC_CALLBACK_1(SocketIOTest::onMenuTestMessageEndpointClicked, this));
|
||||
itemTestMessageEndpoint->setPosition(Vec2(VisibleRect::right().x - labelTestMessageEndpoint->getContentSize().width / 2 - 5, winSize.height - MARGIN - 2 * SPACE));
|
||||
menuRequest->addChild(itemTestMessageEndpoint);
|
||||
|
||||
// Test sending event 'echotest' to default namespace
|
||||
auto labelTestEvent = Label::createWithTTF("Send Test Event", "fonts/arial.ttf", 22);
|
||||
auto itemTestEvent = MenuItemLabel::create(labelTestEvent, CC_CALLBACK_1(SocketIOTest::onMenuTestEventClicked, this));
|
||||
itemTestEvent->setPosition(Vec2(VisibleRect::left().x + labelTestEvent->getContentSize().width / 2 + 5, winSize.height - MARGIN - 3 * SPACE));
|
||||
menuRequest->addChild(itemTestEvent);
|
||||
auto labelTestEvent = Label::createWithTTF("Send Test Event", "fonts/arial.ttf", 22);
|
||||
auto itemTestEvent = MenuItemLabel::create(labelTestEvent, CC_CALLBACK_1(SocketIOTest::onMenuTestEventClicked, this));
|
||||
itemTestEvent->setPosition(Vec2(VisibleRect::left().x + labelTestEvent->getContentSize().width / 2 + 5, winSize.height - MARGIN - 3 * SPACE));
|
||||
menuRequest->addChild(itemTestEvent);
|
||||
|
||||
// Test sending event 'echotest' to the endpoint '/testpoint'
|
||||
auto labelTestEventEndpoint = Label::createWithTTF("Test Endpoint Event", "fonts/arial.ttf", 22);
|
||||
auto itemTestEventEndpoint = MenuItemLabel::create(labelTestEventEndpoint, CC_CALLBACK_1(SocketIOTest::onMenuTestEventEndpointClicked, this));
|
||||
itemTestEventEndpoint->setPosition(Vec2(VisibleRect::right().x - labelTestEventEndpoint->getContentSize().width / 2 - 5, winSize.height - MARGIN - 3 * SPACE));
|
||||
menuRequest->addChild(itemTestEventEndpoint);
|
||||
auto labelTestEventEndpoint = Label::createWithTTF("Test Endpoint Event", "fonts/arial.ttf", 22);
|
||||
auto itemTestEventEndpoint = MenuItemLabel::create(labelTestEventEndpoint, CC_CALLBACK_1(SocketIOTest::onMenuTestEventEndpointClicked, this));
|
||||
itemTestEventEndpoint->setPosition(Vec2(VisibleRect::right().x - labelTestEventEndpoint->getContentSize().width / 2 - 5, winSize.height - MARGIN - 3 * SPACE));
|
||||
menuRequest->addChild(itemTestEventEndpoint);
|
||||
|
||||
// Test disconnecting basic client
|
||||
auto labelTestClientDisconnect = Label::createWithTTF("Disconnect Socket", "fonts/arial.ttf", 22);
|
||||
auto itemClientDisconnect = MenuItemLabel::create(labelTestClientDisconnect, CC_CALLBACK_1(SocketIOTest::onMenuTestClientDisconnectClicked, this));
|
||||
itemClientDisconnect->setPosition(Vec2(VisibleRect::left().x + labelTestClientDisconnect->getContentSize().width / 2 + 5, winSize.height - MARGIN - 4 * SPACE));
|
||||
menuRequest->addChild(itemClientDisconnect);
|
||||
auto labelTestClientDisconnect = Label::createWithTTF("Disconnect Socket", "fonts/arial.ttf", 22);
|
||||
auto itemClientDisconnect = MenuItemLabel::create(labelTestClientDisconnect, CC_CALLBACK_1(SocketIOTest::onMenuTestClientDisconnectClicked, this));
|
||||
itemClientDisconnect->setPosition(Vec2(VisibleRect::left().x + labelTestClientDisconnect->getContentSize().width / 2 + 5, winSize.height - MARGIN - 4 * SPACE));
|
||||
menuRequest->addChild(itemClientDisconnect);
|
||||
|
||||
// Test disconnecting the endpoint '/testpoint'
|
||||
auto labelTestEndpointDisconnect = Label::createWithTTF("Disconnect Endpoint", "fonts/arial.ttf", 22);
|
||||
auto itemTestEndpointDisconnect = MenuItemLabel::create(labelTestEndpointDisconnect, CC_CALLBACK_1(SocketIOTest::onMenuTestEndpointDisconnectClicked, this));
|
||||
itemTestEndpointDisconnect->setPosition(Vec2(VisibleRect::right().x - labelTestEndpointDisconnect->getContentSize().width / 2 - 5, winSize.height - MARGIN - 4 * SPACE));
|
||||
menuRequest->addChild(itemTestEndpointDisconnect);
|
||||
|
||||
auto labelTestEndpointDisconnect = Label::createWithTTF("Disconnect Endpoint", "fonts/arial.ttf", 22);
|
||||
auto itemTestEndpointDisconnect = MenuItemLabel::create(labelTestEndpointDisconnect, CC_CALLBACK_1(SocketIOTest::onMenuTestEndpointDisconnectClicked, this));
|
||||
itemTestEndpointDisconnect->setPosition(Vec2(VisibleRect::right().x - labelTestEndpointDisconnect->getContentSize().width / 2 - 5, winSize.height - MARGIN - 4 * SPACE));
|
||||
menuRequest->addChild(itemTestEndpointDisconnect);
|
||||
|
||||
// Shared Status Label
|
||||
_sioClientStatus = Label::createWithTTF("Not connected...", "fonts/arial.ttf", 14, Size(320, 100), TextHAlignment::LEFT);
|
||||
_sioClientStatus->setAnchorPoint(Vec2(0, 0));
|
||||
_sioClientStatus->setPosition(Vec2(VisibleRect::left().x, VisibleRect::rightBottom().y));
|
||||
this->addChild(_sioClientStatus);
|
||||
_sioClientStatus = Label::createWithTTF("Not connected...", "fonts/arial.ttf", 14, Size(320, 100), TextHAlignment::LEFT);
|
||||
_sioClientStatus->setAnchorPoint(Vec2(0, 0));
|
||||
_sioClientStatus->setPosition(Vec2(VisibleRect::left().x, VisibleRect::rightBottom().y));
|
||||
this->addChild(_sioClientStatus);
|
||||
}
|
||||
|
||||
SocketIOTest::~SocketIOTest()
|
||||
|
||||
SocketIOTest::~SocketIOTest(void)
|
||||
{
|
||||
}
|
||||
|
||||
|
|
@ -99,7 +117,7 @@ void SocketIOTest::testevent(SIOClient *client, const std::string& data) {
|
|||
log("SocketIOTest::testevent called with data: %s", data.c_str());
|
||||
|
||||
std::stringstream s;
|
||||
s << client->getTag() << " received event testevent with data: " << data.c_str();
|
||||
s << client->getTag() << " received event testevent with data: " << data.c_str();
|
||||
|
||||
_sioClientStatus->setString(s.str().c_str());
|
||||
|
||||
|
|
@ -110,35 +128,101 @@ void SocketIOTest::echotest(SIOClient *client, const std::string& data) {
|
|||
log("SocketIOTest::echotest called with data: %s", data.c_str());
|
||||
|
||||
std::stringstream s;
|
||||
s << client->getTag() << " received event echotest with data: " << data.c_str();
|
||||
s << client->getTag() << " received event echotest with data: " << data.c_str();
|
||||
|
||||
_sioClientStatus->setString(s.str().c_str());
|
||||
|
||||
}
|
||||
|
||||
// onMessage is no longer a required override from the delegate class
|
||||
// 'message' events and handlers are now registered in the same way that other events are
|
||||
void SocketIOTest::message(network::SIOClient* client, const std::string& data)
|
||||
{
|
||||
log("SocketIOTest::message received: %s", data.c_str());
|
||||
|
||||
std::stringstream s;
|
||||
s << client->getTag() << " received message with content: " << data.c_str();
|
||||
_sioClientStatus->setString(s.str().c_str());
|
||||
|
||||
}
|
||||
|
||||
void SocketIOTest::json(network::SIOClient* client, const std::string& data)
|
||||
{
|
||||
log("SocketIOTest::json received: %s", data.c_str());
|
||||
|
||||
std::stringstream s;
|
||||
s << client->getTag() << " received json message with content: " << data.c_str();
|
||||
_sioClientStatus->setString(s.str().c_str());
|
||||
|
||||
}
|
||||
|
||||
void SocketIOTest::connect(network::SIOClient* client, const std::string& data)
|
||||
{
|
||||
log("SocketIOTest::connect called");
|
||||
|
||||
std::stringstream s;
|
||||
s << client->getTag() << " connected!";
|
||||
_sioClientStatus->setString(s.str().c_str());
|
||||
|
||||
}
|
||||
|
||||
void SocketIOTest::disconnect(network::SIOClient* client, const std::string& data)
|
||||
{
|
||||
log("SocketIOTest::disconnect called");
|
||||
|
||||
std::stringstream s;
|
||||
s << client->getTag() << " disconnected by server!";
|
||||
_sioClientStatus->setString(s.str().c_str());
|
||||
|
||||
this->closedSocketAction(client);
|
||||
|
||||
}
|
||||
|
||||
void SocketIOTest::closedSocketAction(network::SIOClient* client)
|
||||
{
|
||||
//set the local pointer to nullptr or connect to another client
|
||||
//the client object will be released on its own after this method completes
|
||||
if (client == _sioClient) {
|
||||
|
||||
_sioClient = nullptr;
|
||||
}
|
||||
else if (client == _sioEndpoint) {
|
||||
|
||||
_sioEndpoint = nullptr;
|
||||
}
|
||||
}
|
||||
|
||||
void SocketIOTest::onMenuSIOClientClicked(cocos2d::Ref *sender)
|
||||
{
|
||||
//create a client by using this static method, url does not need to contain the protocol
|
||||
_sioClient = SocketIO::connect("ws://channon.us:3000", *this);
|
||||
_sioClient = SocketIO::connect("ws://dev.channon.us:3009", *this);
|
||||
//you may set a tag for the client for reference in callbacks
|
||||
_sioClient->setTag("Test Client");
|
||||
|
||||
//register event callbacks using the CC_CALLBACK_2() macro and passing the instance of the target class
|
||||
_sioClient->on("testevent", CC_CALLBACK_2(SocketIOTest::testevent, this));
|
||||
_sioClient->on("echotest", CC_CALLBACK_2(SocketIOTest::echotest, this));
|
||||
_sioClient->on("message", CC_CALLBACK_2(SocketIOTest::message, this));
|
||||
_sioClient->on("json", CC_CALLBACK_2(SocketIOTest::json, this));
|
||||
_sioClient->on("connect", CC_CALLBACK_2(SocketIOTest::connect, this));
|
||||
_sioClient->on("disconnect", CC_CALLBACK_2(SocketIOTest::disconnect, this));
|
||||
|
||||
}
|
||||
|
||||
void SocketIOTest::onMenuSIOEndpointClicked(cocos2d::Ref *sender)
|
||||
{
|
||||
//repeat the same connection steps for the namespace "testpoint"
|
||||
_sioEndpoint = SocketIO::connect("ws://channon.us:3000/testpoint", *this);
|
||||
_sioEndpoint = SocketIO::connect("ws://dev.channon.us:3009/testpoint", *this);
|
||||
//a tag to differentiate in shared callbacks
|
||||
_sioEndpoint->setTag("Test Endpoint");
|
||||
_sioEndpoint->setTag("Test Endpoint");
|
||||
|
||||
//demonstrating how callbacks can be shared within a delegate
|
||||
_sioEndpoint->on("testevent", CC_CALLBACK_2(SocketIOTest::testevent, this));
|
||||
_sioEndpoint->on("echotest", CC_CALLBACK_2(SocketIOTest::echotest, this));
|
||||
_sioEndpoint->on("message", CC_CALLBACK_2(SocketIOTest::message, this));
|
||||
_sioEndpoint->on("json", CC_CALLBACK_2(SocketIOTest::json, this));
|
||||
_sioEndpoint->on("connect", CC_CALLBACK_2(SocketIOTest::connect, this));
|
||||
_sioEndpoint->on("disconnect", CC_CALLBACK_2(SocketIOTest::disconnect, this));
|
||||
|
||||
}
|
||||
|
||||
|
|
@ -146,14 +230,14 @@ void SocketIOTest::onMenuTestMessageClicked(cocos2d::Ref *sender)
|
|||
{
|
||||
//check that the socket is != nullptr before sending or emitting events
|
||||
//the client should be nullptr either before initialization and connection or after disconnect
|
||||
if(_sioClient != nullptr) _sioClient->send("Hello Socket.IO!");
|
||||
if (_sioClient != nullptr) _sioClient->send("Hello Socket.IO!");
|
||||
|
||||
}
|
||||
|
||||
void SocketIOTest::onMenuTestMessageEndpointClicked(cocos2d::Ref *sender)
|
||||
{
|
||||
|
||||
if(_sioEndpoint != nullptr) _sioEndpoint->send("Hello Socket.IO!");
|
||||
if (_sioEndpoint != nullptr) _sioEndpoint->send("Hello Socket.IO!");
|
||||
|
||||
}
|
||||
|
||||
|
|
@ -161,71 +245,64 @@ void SocketIOTest::onMenuTestEventClicked(cocos2d::Ref *sender)
|
|||
{
|
||||
//check that the socket is != nullptr before sending or emitting events
|
||||
//the client should be nullptr either before initialization and connection or after disconnect
|
||||
if(_sioClient != nullptr) _sioClient->emit("echotest","[{\"name\":\"myname\",\"type\":\"mytype\"}]");
|
||||
if (_sioClient != nullptr) _sioClient->emit("echotest", "{\"name\":\"myname\",\"type\":\"mytype\"}");
|
||||
|
||||
}
|
||||
|
||||
void SocketIOTest::onMenuTestEventEndpointClicked(cocos2d::Ref *sender)
|
||||
{
|
||||
|
||||
if(_sioEndpoint != nullptr) _sioEndpoint->emit("echotest","[{\"name\":\"myname\",\"type\":\"mytype\"}]");
|
||||
if (_sioEndpoint != nullptr) _sioEndpoint->emit("echotest", "{\"name\":\"myname\",\"type\":\"mytype\"}");
|
||||
|
||||
}
|
||||
|
||||
void SocketIOTest::onMenuTestClientDisconnectClicked(cocos2d::Ref *sender)
|
||||
{
|
||||
// Disconnecting from the default namespace "" or "/" will also disconnect all other endpoints
|
||||
std::stringstream s;
|
||||
|
||||
if(_sioClient != nullptr) _sioClient->disconnect();
|
||||
if (_sioClient != nullptr) {
|
||||
s << _sioClient->getTag() << " manually closed!";
|
||||
_sioClient->disconnect();
|
||||
_sioClient = nullptr;
|
||||
}
|
||||
else {
|
||||
s << "Socket.io Test Client not initialized!";
|
||||
}
|
||||
|
||||
_sioClientStatus->setString(s.str().c_str());
|
||||
|
||||
}
|
||||
|
||||
void SocketIOTest::onMenuTestEndpointDisconnectClicked(cocos2d::Ref *sender)
|
||||
{
|
||||
|
||||
if(_sioEndpoint != nullptr) _sioEndpoint->disconnect();
|
||||
|
||||
}
|
||||
|
||||
// Delegate methods
|
||||
|
||||
void SocketIOTest::onConnect(network::SIOClient* client)
|
||||
{
|
||||
log("SocketIOTest::onConnect called");
|
||||
|
||||
std::stringstream s;
|
||||
s << client->getTag() << " connected!";
|
||||
|
||||
if (_sioEndpoint != nullptr) {
|
||||
s << _sioEndpoint->getTag() << " manually closed!";
|
||||
_sioEndpoint->disconnect();
|
||||
_sioEndpoint = nullptr;
|
||||
}
|
||||
else {
|
||||
s << "Socket.io Test Endpoint not initialized!";
|
||||
}
|
||||
|
||||
_sioClientStatus->setString(s.str().c_str());
|
||||
|
||||
}
|
||||
|
||||
void SocketIOTest::onMessage(network::SIOClient* client, const std::string& data)
|
||||
{
|
||||
log("SocketIOTest::onMessage received: %s", data.c_str());
|
||||
|
||||
std::stringstream s;
|
||||
s << client->getTag() << " received message with content: " << data.c_str();
|
||||
_sioClientStatus->setString(s.str().c_str());
|
||||
|
||||
}
|
||||
// SIODelegate methods to catch network/socket level events outside of the socket.io events
|
||||
|
||||
void SocketIOTest::onClose(network::SIOClient* client)
|
||||
{
|
||||
log("SocketIOTest::onClose called");
|
||||
|
||||
std::stringstream s;
|
||||
s << client->getTag() << " closed!";
|
||||
s << client->getTag() << " closed!";
|
||||
_sioClientStatus->setString(s.str().c_str());
|
||||
|
||||
//set the local pointer to nullptr or connect to another client
|
||||
//the client object will be released on its own after this method completes
|
||||
if(client == _sioClient) {
|
||||
|
||||
_sioClient = nullptr;
|
||||
} else if(client == _sioEndpoint) {
|
||||
|
||||
_sioEndpoint = nullptr;
|
||||
}
|
||||
|
||||
this->closedSocketAction(client);
|
||||
|
||||
}
|
||||
|
||||
void SocketIOTest::onError(network::SIOClient* client, const std::string& data)
|
||||
|
|
@ -233,6 +310,6 @@ void SocketIOTest::onError(network::SIOClient* client, const std::string& data)
|
|||
log("SocketIOTest::onError received: %s", data.c_str());
|
||||
|
||||
std::stringstream s;
|
||||
s << client->getTag() << " received error with content: " << data.c_str();
|
||||
s << client->getTag() << " received error with content: " << data.c_str();
|
||||
_sioClientStatus->setString(s.str().c_str());
|
||||
}
|
||||
|
|
|
|||
|
|
@ -1,10 +1,29 @@
|
|||
//
|
||||
// SocketIOTest.h
|
||||
// TestCpp
|
||||
//
|
||||
// Created by Chris Hannon on 6/26/13.
|
||||
//
|
||||
//
|
||||
/****************************************************************************
|
||||
Copyright (c) 2015 Chris Hannon http://www.channon.us
|
||||
Copyright (c) 2013-2015 Chukong Technologies Inc.
|
||||
|
||||
http://www.cocos2d-x.org
|
||||
|
||||
Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
of this software and associated documentation files (the "Software"), to deal
|
||||
in the Software without restriction, including without limitation the rights
|
||||
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
||||
copies of the Software, and to permit persons to whom the Software is
|
||||
furnished to do so, subject to the following conditions:
|
||||
|
||||
The above copyright notice and this permission notice shall be included in
|
||||
all copies or substantial portions of the Software.
|
||||
|
||||
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
||||
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
||||
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
||||
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
|
||||
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
|
||||
THE SOFTWARE.
|
||||
|
||||
****************************************************************************/
|
||||
|
||||
#ifndef __TestCpp__SocketIOTest__
|
||||
#define __TestCpp__SocketIOTest__
|
||||
|
||||
|
|
@ -24,27 +43,63 @@ public:
|
|||
SocketIOTest();
|
||||
virtual ~SocketIOTest();
|
||||
|
||||
virtual void onConnect(cocos2d::network::SIOClient* client);
|
||||
virtual void onMessage(cocos2d::network::SIOClient* client, const std::string& data);
|
||||
virtual void onClose(cocos2d::network::SIOClient* client);
|
||||
virtual void onError(cocos2d::network::SIOClient* client, const std::string& data);
|
||||
/**
|
||||
* @brief Used for network level socket close (not for disconnect from the socket.io server)
|
||||
*/
|
||||
virtual void onClose(cocos2d::network::SIOClient* client);
|
||||
/**
|
||||
* @brief Used for network level socket error (not for disconnect from the socket.io server)
|
||||
**/
|
||||
virtual void onError(cocos2d::network::SIOClient* client, const std::string& data);
|
||||
/**
|
||||
* @brief Common function to call on both socket.io disconnect and websocket close
|
||||
**/
|
||||
void closedSocketAction(cocos2d::network::SIOClient* client);
|
||||
|
||||
// test action handlers for main Test Client that connects to defaul namespace "" or "/"
|
||||
void onMenuSIOClientClicked(cocos2d::Ref *sender);
|
||||
void onMenuTestMessageClicked(cocos2d::Ref *sender);
|
||||
void onMenuTestEventClicked(cocos2d::Ref *sender);
|
||||
void onMenuTestClientDisconnectClicked(cocos2d::Ref *sender);
|
||||
|
||||
// test action handlers for Test Endpoint that connects to /testpoint endpoint
|
||||
void onMenuSIOEndpointClicked(cocos2d::Ref *sender);
|
||||
void onMenuTestMessageEndpointClicked(cocos2d::Ref *sender);
|
||||
void onMenuTestEventEndpointClicked(cocos2d::Ref *sender);
|
||||
void onMenuTestEndpointDisconnectClicked(cocos2d::Ref *sender);
|
||||
|
||||
// custom handlers for socket.io related events
|
||||
|
||||
/**
|
||||
* @brief Socket.io event handler for custom event "testevent"
|
||||
**/
|
||||
void testevent(cocos2d::network::SIOClient *client, const std::string& data);
|
||||
/**
|
||||
* @brief Socket.io event handler for custom event "echoevent"
|
||||
**/
|
||||
void echotest(cocos2d::network::SIOClient *client, const std::string& data);
|
||||
/**
|
||||
* @brief Socket.io event handler for event "connect"
|
||||
**/
|
||||
void connect(cocos2d::network::SIOClient* client, const std::string& data);
|
||||
/**
|
||||
* @brief Socket.io event handler for event "disconnect"
|
||||
**/
|
||||
void disconnect(cocos2d::network::SIOClient* client, const std::string& data);
|
||||
/**
|
||||
* @brief Socket.io event handler for event "message"
|
||||
**/
|
||||
void message(cocos2d::network::SIOClient* client, const std::string& data);
|
||||
/**
|
||||
* @brief Socket.io event handler for event "json"
|
||||
* This is only used in v 0.9.x, in 1.x this is handled as a "message" event
|
||||
**/
|
||||
void json(cocos2d::network::SIOClient* client, const std::string& data);
|
||||
|
||||
virtual std::string title() const override{ return "SocketIO Extension Test"; }
|
||||
|
||||
protected:
|
||||
|
||||
cocos2d::network::SIOClient *_sioClient, *_sioEndpoint;
|
||||
|
||||
cocos2d::Label *_sioClientStatus;
|
||||
|
|
|
|||
Loading…
Reference in New Issue