mirror of
https://github.com/smallmain/cocos-enhance-kit.git
synced 2024-12-26 11:48:29 +00:00
301 lines
10 KiB
C++
301 lines
10 KiB
C++
/****************************************************************************
|
|
Copyright (c) 2015 Chris Hannon http://www.channon.us
|
|
Copyright (c) 2013-2016 Chukong Technologies Inc.
|
|
Copyright (c) 2017-2018 Xiamen Yaji Software Co., Ltd.
|
|
|
|
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.
|
|
|
|
*based on the SocketIO library created by LearnBoost at http://socket.io
|
|
*using spec version 1 found at https://github.com/LearnBoost/socket.io-spec
|
|
|
|
Usage is described below, a full working example can be found in TestCpp under ExtionsTest/NetworkTest/SocketIOTest
|
|
|
|
creating a new connection to a socket.io server running at localhost:3000
|
|
|
|
SIOClient *client = SocketIO::connect(*delegate, "ws://localhost:3000");
|
|
|
|
the connection process will begin and if successful delegate::onOpen will be called
|
|
if the connection process results in an error, delegate::onError will be called with the err msg
|
|
|
|
sending a message to the server
|
|
|
|
client->send("Hello!");
|
|
|
|
emitting an event to be handled by the server, argument json formatting is up to you
|
|
|
|
client->emit("eventname", "[{\"arg\":\"value\"}]");
|
|
|
|
registering an event callback, target should be a member function in a subclass of SIODelegate
|
|
CC_CALLBACK_2 is used to wrap the callback with std::bind and store as an SIOEvent
|
|
|
|
client->on("eventname", CC_CALLBACK_2(TargetClass::targetfunc, *targetclass_instance));
|
|
|
|
event target function should match this pattern, *this pointer will be made available
|
|
|
|
void TargetClass::targetfunc(SIOClient *, const std::string&)
|
|
|
|
disconnect from the endpoint by calling disconnect(), onClose will be called on the delegate once complete
|
|
in the onClose method the pointer should be set to NULL or used to connect to a new endpoint
|
|
|
|
client->disconnect();
|
|
|
|
****************************************************************************/
|
|
#pragma once
|
|
|
|
#include <string>
|
|
#include <unordered_map>
|
|
#include <functional>
|
|
#include "base/ccMacros.h"
|
|
#include "base/CCMap.h"
|
|
|
|
|
|
/**
|
|
* @addtogroup network
|
|
* @{
|
|
*/
|
|
|
|
NS_CC_BEGIN
|
|
|
|
namespace network {
|
|
|
|
//forward declarations
|
|
class SIOClientImpl;
|
|
class SIOClient;
|
|
|
|
/**
|
|
* Singleton and wrapper class to provide static creation method as well as registry of all sockets.
|
|
*
|
|
* @lua NA
|
|
*/
|
|
class CC_DLL SocketIO
|
|
{
|
|
public:
|
|
/**
|
|
* Get instance of SocketIO.
|
|
*
|
|
* @return SocketIO* the instance of SocketIO.
|
|
*/
|
|
static SocketIO* getInstance();
|
|
static void destroyInstance();
|
|
|
|
/**
|
|
* The delegate class to process socket.io events.
|
|
* @lua NA
|
|
*/
|
|
class SIODelegate
|
|
{
|
|
public:
|
|
/** Destructor of SIODelegate. */
|
|
virtual ~SIODelegate() {}
|
|
/**
|
|
* This is kept for backwards compatibility, connect is now fired as a socket.io event "connect"
|
|
*
|
|
* This function would be called when the related SIOClient object receive messages that mean it have connected to endpoint successfully.
|
|
*
|
|
* @param client the connected SIOClient object.
|
|
*/
|
|
virtual void onConnect(SIOClient* client) { CCLOG("SIODelegate onConnect fired"); };
|
|
/**
|
|
* This is kept for backwards compatibility, message is now fired as a socket.io event "message"
|
|
*
|
|
* This function would be called when the related SIOClient object receive message or json message.
|
|
*
|
|
* @param client the connected SIOClient object.
|
|
* @param data the message,it could be json message
|
|
*/
|
|
virtual void onMessage(SIOClient* client, const std::string& data) { CCLOG("SIODelegate onMessage fired with data: %s", data.c_str()); };
|
|
/**
|
|
* Pure virtual callback function, this function should be overridden by the subclass.
|
|
*
|
|
* This function would be called when the related SIOClient object disconnect or receive disconnect signal.
|
|
*
|
|
* @param client the connected SIOClient object.
|
|
*/
|
|
virtual void onClose(SIOClient* client) = 0;
|
|
/**
|
|
* Pure virtual callback function, this function should be overridden by the subclass.
|
|
*
|
|
* This function would be called when the related SIOClient object receive error signal or didn't connect the endpoint but do some network operation, eg.,send and emit,etc.
|
|
*
|
|
* @param client the connected SIOClient object.
|
|
* @param data the error message
|
|
*/
|
|
virtual void onError(SIOClient* client, const std::string& data) = 0;
|
|
/**
|
|
* Fire event to script when the related SIOClient object receive the fire event signal.
|
|
*
|
|
* @param client the connected SIOClient object.
|
|
* @param eventName the event's name.
|
|
* @param data the event's data information.
|
|
*/
|
|
virtual void fireEventToScript(SIOClient* client, const std::string& eventName, const std::string& data) { CCLOG("SIODelegate event '%s' fired with data: %s", eventName.c_str(), data.c_str()); };
|
|
};
|
|
|
|
/**
|
|
* Static client creation method, similar to socketio.connect(uri) in JS.
|
|
* @param uri the URI of the socket.io server.
|
|
* @param delegate the delegate which want to receive events from the socket.io client.
|
|
* @return SIOClient* an initialized SIOClient if connected successfully, otherwise nullptr.
|
|
*/
|
|
static SIOClient* connect(const std::string& uri, SIODelegate& delegate);
|
|
|
|
/**
|
|
* Static client creation method, similar to socketio.connect(uri) in JS.
|
|
* @param uri the URI of the socket.io server.
|
|
* @param delegate the delegate which want to receive events from the socket.io client.
|
|
* @param caFilePath The ca file path for wss connection
|
|
* @return SIOClient* an initialized SIOClient if connected successfully, otherwise nullptr.
|
|
*/
|
|
static SIOClient* connect(const std::string& uri, SIODelegate& delegate, const std::string& caFilePath);
|
|
|
|
/**
|
|
* Static client creation method, similar to socketio.connect(uri) in JS.
|
|
* @param delegate the delegate which want to receive events from the socket.io client.
|
|
* @param uri the URI of the socket.io server.
|
|
* @return SIOClient* an initialized SIOClient if connected successfully, otherwise nullptr.
|
|
*/
|
|
CC_DEPRECATED_ATTRIBUTE static SIOClient* connect(SIODelegate& delegate, const std::string& uri);
|
|
|
|
private:
|
|
|
|
SocketIO();
|
|
virtual ~SocketIO();
|
|
|
|
static SocketIO *_inst;
|
|
|
|
cocos2d::Map<std::string, SIOClientImpl*> _sockets;
|
|
|
|
SIOClientImpl* getSocket(const std::string& uri);
|
|
void addSocket(const std::string& uri, SIOClientImpl* socket);
|
|
void removeSocket(const std::string& uri);
|
|
|
|
friend class SIOClientImpl;
|
|
private:
|
|
CC_DISALLOW_COPY_AND_ASSIGN(SocketIO)
|
|
};
|
|
|
|
//c++11 style callbacks entities will be created using CC_CALLBACK (which uses std::bind)
|
|
typedef std::function<void(SIOClient*, const std::string&)> SIOEvent;
|
|
//c++11 map to callbacks
|
|
typedef std::unordered_map<std::string, SIOEvent> EventRegistry;
|
|
|
|
/**
|
|
* A single connection to a socket.io endpoint.
|
|
*
|
|
* @lua NA
|
|
*/
|
|
class CC_DLL SIOClient
|
|
: public cocos2d::Ref
|
|
{
|
|
private:
|
|
friend class SocketIO; // Only SocketIO class could contruct a SIOClient instance.
|
|
|
|
std::string _path, _tag;
|
|
bool _connected;
|
|
SIOClientImpl* _socket;
|
|
|
|
SocketIO::SIODelegate* _delegate;
|
|
|
|
EventRegistry _eventRegistry;
|
|
uint32_t _instanceId;
|
|
|
|
void fireEvent(const std::string& eventName, const std::string& data);
|
|
|
|
void onOpen();
|
|
void onConnect();
|
|
void socketClosed();
|
|
|
|
friend class SIOClientImpl;
|
|
|
|
/**
|
|
* Constructor of SIOClient class.
|
|
*
|
|
* @param host the string that represent the host address.
|
|
* @param port the int value represent the port number.
|
|
* @param path the string that represent endpoint.
|
|
* @param impl the SIOClientImpl object.
|
|
* @param delegate the SIODelegate object.
|
|
*/
|
|
SIOClient(const std::string& path, SIOClientImpl* impl, SocketIO::SIODelegate& delegate);
|
|
/**
|
|
* Destructor of SIOClient class.
|
|
*/
|
|
virtual ~SIOClient();
|
|
|
|
public:
|
|
/**
|
|
* Get the delegate for the client
|
|
* @return the delegate object for the client
|
|
*/
|
|
SocketIO::SIODelegate* getDelegate() { return _delegate; };
|
|
|
|
/**
|
|
* Disconnect from the endpoint, onClose will be called for the delegate when complete
|
|
*/
|
|
void disconnect();
|
|
/**
|
|
* Send a message to the socket.io server.
|
|
*
|
|
* @param s message.
|
|
*/
|
|
void send(const std::string& s);
|
|
/**
|
|
* Emit the eventname and the args to the endpoint that _path point to.
|
|
* @param eventname
|
|
* @param args
|
|
*/
|
|
void emit(const std::string& eventname, const std::string& args);
|
|
/**
|
|
* Used to register a socket.io event callback.
|
|
* Event argument should be passed using CC_CALLBACK2(&Base::function, this).
|
|
* @param eventName the name of event.
|
|
* @param e the callback function.
|
|
*/
|
|
void on(const std::string& eventName, SIOEvent e);
|
|
|
|
/**
|
|
* Set tag of SIOClient.
|
|
* The tag is used to distinguish the various SIOClient objects.
|
|
* @param tag string object.
|
|
*/
|
|
void setTag(const char* tag);
|
|
|
|
/**
|
|
* Get tag of SIOClient.
|
|
* @return const char* the pointer point to the _tag.
|
|
*/
|
|
const char* getTag()
|
|
{
|
|
return _tag.c_str();
|
|
}
|
|
|
|
/**
|
|
* Gets instance id
|
|
*/
|
|
uint32_t getInstanceId() const;
|
|
|
|
};
|
|
|
|
}
|
|
|
|
NS_CC_END
|
|
|
|
// end group
|
|
/// @}
|