mirror/aseprite
1
0
Fork 0
mirror of https://github.com/aseprite/aseprite.git synced 2025-03-29 19:20:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

Handle socket messages when window is out of focus

Browse Source
This commit is contained in:
lampysprites 2021-10-18 23:40:49 +07:00
parent 93fb40ad7d
commit 1f9c2e8987
1 changed files with 20 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/app/script/websocket_class.cpp
View File

@ -13,11 +13,14 @@
#include "app/script/engine.h"
#include "app/script/luacpp.h"
#include "app/script/security.h"
#include "ui/timer.h"
#include "ui/manager.h"
#include "ui/system.h"
#include <ixwebsocket/IXNetSystem.h>
#include <ixwebsocket/IXWebSocket.h>
#include <sstream>
#include <set>
namespace app {
namespace script {
@ -27,6 +30,9 @@ namespace {
// Additional "enum" value to make message callback simpler
#define MESSAGE_TYPE_BINARY ((int)ix::WebSocketMessageType::Fragment + 10)
static ui::Timer* timer;
static std::set<ix::WebSocket *> connections;
int WebSocket_new(lua_State* L)
{
static std::once_flag f;
@ -163,6 +169,13 @@ int WebSocket_connect(lua_State* L)
{
auto ws = get_ptr<ix::WebSocket>(L, 1);
ws->start();
if (connections.empty()) {
timer = new ui::Timer(33, ui::Manager::getDefault());
timer->start();
}
connections.insert(ws);
return 0;
}
@ -170,6 +183,13 @@ int WebSocket_close(lua_State* L)
{
auto ws = get_ptr<ix::WebSocket>(L, 1);
ws->stop();
connections.erase(ws);
if (connections.empty()) {
delete timer;
timer = nullptr;
}
return 0;
}