Skip to content

GitLab

VeryVanilla
VeryVanilla
Commit 0829a628 authored by Red Bot's avatar Red Bot
Browse files
Options

removing old mq2discord

parent 1bcd319d
Expand all Hide whitespace changes
Inline Side-by-side
Showing with 0 additions and 20839 deletions
MQ2Discord/DiscordClient.cpp deleted 100644 → 0
View file @ 1bcd319d
#include "sleepy_disord/websocketpp_websocket.h"
#include <nlohmann/json.hpp>
#include "SafeQueue.h"
// Queue for messages to be sent to discord channel
SafeQueue<std::string> toDiscord;
// Queue for messages to be displayed in chat
SafeQueue<std::string> fromDiscord;
std::thread * g_pThread;
std::atomic_bool bRun(false);
std::atomic_bool bFinished(false);
std::string escape_json(const std::string &s) {
std::ostringstream o;
for (auto c = s.cbegin(); c != s.cend(); c++) {
if (*c == '"' || *c == '\\' || ('\x00' <= *c && *c <= '\x1f')) {
o << "\\u"
<< std::hex << std::setw(4) << std::setfill('0') << (int)*c;
}
else {
o << *c;
}
}
return o.str();
}
// Real simple client, all it does is invoke a callback when a message is received
class CallbackDiscordClient : public SleepyDiscord::DiscordClient {
public:
using SleepyDiscord::DiscordClient::DiscordClient;
CallbackDiscordClient(const std::string token, std::function<void(SleepyDiscord::Message &)> callback)
: SleepyDiscord::DiscordClient(token, 2), // 0 is numThreads, doesn't do anything if < 3
_callback(callback)
{
}
void onMessage(SleepyDiscord::Message message) {
if (_callback)
_callback(message);
}
private:
std::function<void(SleepyDiscord::Message &)> _callback;
};
void DiscordThread(std::string token, std::string channelId, std::string controlUserId, std::string connectMsg)
{
try
{
CallbackDiscordClient client(token, [&](SleepyDiscord::Message & msg) {
if (msg.author.ID == controlUserId && msg.channelID == channelId)
fromDiscord.enqueue(msg.content);
});
fromDiscord.enqueue(connectMsg);
unsigned int loopCount = 0;
while (bRun)
{
// Poll to receive messages
client.poll();
// Send messages from queue, combine them if there's multiple as the API has rate limiting
std::string msg, combinedMsg;
while (combinedMsg.length() <= 1800 && toDiscord.tryDequeue(msg))
{
combinedMsg += msg + "\n";
}
if (combinedMsg != "")
{
auto response = client.sendMessage(channelId, escape_json(combinedMsg));
if (response.statusCode != 200)
toDiscord.enqueue("[MQ2Discord] Error, response text: " + response.text);
}
// Every minute, send typing, to keep connection alive. Crude timer based on 1s sleep below
if (loopCount++ % 60 == 0)
client.sendTyping(channelId);
using namespace std::chrono_literals;
std::this_thread::sleep_for(1000ms);
}
fromDiscord.enqueue("Disconnected");
}
catch (std::exception & e)
{
fromDiscord.enqueue(std::string("Exception: ") + e.what());
}
bFinished = true;
}
\ No newline at end of file
MQ2Discord/DiscordClient.h deleted 100644 → 0
View file @ 1bcd319d
#pragma once
#include "SafeQueue.h"
#include <string>
#include <thread>
#include <atomic>
// Queue for messages to be sent to discord channel
extern SafeQueue<std::string> toDiscord;
// Queue for messages to be displayed in chat
extern SafeQueue<std::string> fromDiscord;
extern std::thread * g_pThread;
extern std::atomic_bool bRun;
extern std::atomic_bool bFinished;
void DiscordThread(std::string token, std::string channelId, std::string controlUserId, std::string connectMsg);
MQ2Discord/ISXEQDiscord.cpp deleted 100644 → 0
View file @ 1bcd319d
//
// ISXEQDiscord
//
#pragma warning(disable:4996)
#include "../ISXEQClient.h"
#include "ISXEQDiscord.h"
// The mandatory pre-setup function. Our name is "ISXEQDiscord", and the class is ISXEQDiscord.
// This sets up a "ModulePath" variable which contains the path to this module in case we want it,
// and a "PluginLog" variable, which contains the path and filename of what we should use for our
// debug logging if we need it. It also sets up a variable "pExtension" which is the pointer to
// our instanced class.
ISXPreSetup("ISXEQDiscord", ISXEQDiscord);
// Basic LavishScript datatypes, these get retrieved on startup by our initialize function, so we can
// use them in our Top-Level Objects or custom datatypes
LSType *pStringType = 0;
LSType *pIntType = 0;
LSType *pBoolType = 0;
LSType *pFloatType = 0;
LSType *pTimeType = 0;
LSType *pByteType = 0;
ISInterface *pISInterface = 0;
HISXSERVICE hPulseService = 0;
HISXSERVICE hMemoryService = 0;
HISXSERVICE hServicesService = 0;
HISXSERVICE hEQChatService = 0;
HISXSERVICE hEQUIService = 0;
HISXSERVICE hEQGamestateService = 0;
HISXSERVICE hEQSpawnService = 0;
HISXSERVICE hEQZoneService = 0;
unsigned int ISXEQDiscordXML = 0;
// Forward declarations of callbacks
void __cdecl PulseService(bool Broadcast, unsigned int MSG, void *lpData);
void __cdecl MemoryService(bool Broadcast, unsigned int MSG, void *lpData);
void __cdecl ServicesService(bool Broadcast, unsigned int MSG, void *lpData);
// Initialize is called by Inner Space when the extension should initialize.
bool ISXEQDiscord::Initialize(ISInterface *p_ISInterface)
{
pISInterface = p_ISInterface;
// retrieve basic ISData types
pStringType = pISInterface->FindLSType("string");
pIntType = pISInterface->FindLSType("int");
pBoolType = pISInterface->FindLSType("bool");
pFloatType = pISInterface->FindLSType("float");
pTimeType = pISInterface->FindLSType("time");
pByteType = pISInterface->FindLSType("byte");
pISInterface->OpenSettings(XMLFileName);
LoadSettings();
ConnectServices();
RegisterCommands();
RegisterAliases();
RegisterDataTypes();
RegisterTopLevelObjects();
RegisterServices();
WriteChatf("ISXEQDiscord Loaded");
return true;
}
// shutdown sequence
void ISXEQDiscord::Shutdown()
{
// save settings, if you changed them and want to save them now. You should normally save
// changes immediately.
//pISInterface->ExportSet(ISXEQDiscordXML,XMLFileName);
pISInterface->UnloadSet(ISXEQDiscordXML);
DisconnectServices();
UnRegisterServices();
UnRegisterTopLevelObjects();
UnRegisterDataTypes();
UnRegisterAliases();
UnRegisterCommands();
}
void ISXEQDiscord::ConnectServices()
{
// connect to any services. Here we connect to "Pulse" which receives a
// message every frame (after the frame is displayed) and "Memory" which
// wraps "detours" and memory modifications
hPulseService = pISInterface->ConnectService(this, "Pulse", PulseService);
hMemoryService = pISInterface->ConnectService(this, "Memory", MemoryService);
hServicesService = pISInterface->ConnectService(this, "Services", ServicesService);
}
void ISXEQDiscord::RegisterCommands()
{
// add any commands
// pISInterface->AddCommand("MyCommand",MyCommand,true,false);
}
void ISXEQDiscord::RegisterAliases()
{
// add any aliases
}
void ISXEQDiscord::RegisterDataTypes()
{
// add any datatypes
// pMyType = new MyType;
// pISInterface->AddLSType(*pMyType);
}
void ISXEQDiscord::RegisterTopLevelObjects()
{
// add any Top-Level Objects
// pISInterface->AddTopLevelObject("MapSpawn",tloMapSpawn);
}
void ISXEQDiscord::RegisterServices()
{
// register any services. Here we demonstrate a service that does not use a
// callback
// set up a 1-way service (broadcast only)
// hISXEQDiscordService=pISInterface->RegisterService(this,"ISXEQDiscord Service",0);
// broadcast a message, which is worthless at this point because nobody will receive it
// (nobody has had a chance to connect)
// pISInterface->ServiceBroadcast(this,hISXEQDiscordService,ISXSERVICE_MSG+1,0);
}
void ISXEQDiscord::DisconnectServices()
{
// gracefully disconnect from services
if (hPulseService)
pISInterface->DisconnectService(this, hPulseService);
if (hMemoryService)
{
pISInterface->DisconnectService(this, hMemoryService);
// memory modifications are automatically undone when disconnecting
// also, since this service accepts messages from clients we should reset our handle to
// 0 to make sure we dont try to continue using it
hMemoryService = 0;
}
if (hServicesService)
pISInterface->DisconnectService(this, hServicesService);
}
void ISXEQDiscord::UnRegisterCommands()
{
// remove commands
// pISInterface->RemoveCommand("MyCommand");
}
void ISXEQDiscord::UnRegisterAliases()
{
// remove aliases
}
void ISXEQDiscord::UnRegisterDataTypes()
{
// remove data types
//if (pMyType)
//{
// pISInterface->RemoveLSType(*pMyType);
// delete pMyType;
//}
}
void ISXEQDiscord::UnRegisterTopLevelObjects()
{
// remove Top-Level Objects
// pISInterface->RemoveTopLevelObject("MapSpawn");
}
void ISXEQDiscord::UnRegisterServices()
{
// shutdown our own services
// if (hISXEQDiscordService)
// pISInterface->ShutdownService(this,hISXEQDiscordService);
}
void ISXEQDiscord::LoadSettings()
{
bool bChanged = false;
// open the settings file, and store the ID number in ISXEQDiscordXML
ISXEQDiscordXML = pISInterface->OpenSettings(XMLFileName);
// This ID is used to refer to the base set of the loaded settings
/*
Here is an example settings hierarchy:
base set
..settings
.."General" set
.."Characters" set
...."Server A" set
......"Character A" set
........settings
......"Character B" set
........settings
...."Server B" set
......"Character A" set
........settings
...."Server C" set
......"Character A" set
........settings
......"Character B" set
........settings
......"Character C" set
........settings
As you can see, there can be any number of nested sets, which can contain sets, settings, and comments.
Any set can be referred to by its ID. The base set is stored in ISXEQDiscordXML. Note that the settings
are NOT "xml" after loading them, they are simply settings stored in memory!
*/
// Get General set ID, which can be a child of the base set
if (unsigned int GeneralGUID = pISInterface->FindSet(ISXEQDiscordXML, "General"))
{
// retrieve a text setting from the General set
char Text[512];
if (pISInterface->GetSetting(GeneralGUID, "Name of setting", Text, 512))
{
// success
}
unsigned int IntSetting;
if (pISInterface->GetSetting(GeneralGUID, "Name of int setting", IntSetting))
{
// success
}
}
/*
Deeper sets and settings are accessed in exactly the same way. If a sub-set of General was to be used,
accessing it would work like so:
if (unsigned int SubSetGUID=pISInterface->FindSet(GeneralGUID,"Sub-set name"))
{
// got the sub-set
}
*/
// save settings if we changed them
if (bChanged)
pISInterface->ExportSet(ISXEQDiscordXML, XMLFileName);
// Note: ExportSet can save ANY set and its settings, sets, and comments as ANY filename. The "General" set
// could be stored as "General.XML" simply by doing pISInterface->ExportSet(GeneralGUID,"General.XML");
}
void __cdecl PulseService(bool Broadcast, unsigned int MSG, void *lpData)
{
if (MSG == PULSE_PULSE)
{
// Same as OnPulse
}
}
void __cdecl MemoryService(bool Broadcast, unsigned int MSG, void *lpData)
{
// no messages are currently associated with this service (other than
// system messages such as client disconnect), so do nothing.
}
void __cdecl EQUIService(bool Broadcast, unsigned int MSG, void *lpData)
{
switch (MSG)
{
case UISERVICE_CLEANUP:
// same as OnCleanUI
break;
case UISERVICE_RELOAD:
// same as OnReloadUI
break;
}
}
void __cdecl EQGamestateService(bool Broadcast, unsigned int MSG, void *lpData)
{
#define GameState ((unsigned int)lpData)
if (MSG == GAMESTATESERVICE_CHANGED)
{
// same as SetGameState
}
#undef GameState
}
void __cdecl EQSpawnService(bool Broadcast, unsigned int MSG, void *lpData)
{
switch (MSG)
{
#define pSpawn ((PSPAWNINFO)lpData)
case SPAWNSERVICE_ADDSPAWN:
// same as OnAddSpawn
break;
case SPAWNSERVICE_REMOVESPAWN:
// same as OnRemoveSpawn
break;
#undef pSpawn
#define pGroundItem ((PGROUNDITEM)lpData)
case SPAWNSERVICE_ADDITEM:
// same as OnAddGroundItem
break;
case SPAWNSERVICE_REMOVEITEM:
// same as OnRemoveGroundItem
break;
#undef pGroundItem
}
}
void __cdecl EQZoneService(bool Broadcast, unsigned int MSG, void *lpData)
{
switch (MSG)
{
case ZONESERVICE_BEGINZONE:
// same as OnBeginZone
break;
case ZONESERVICE_ENDZONE:
// same as OnEndZone
break;
case ZONESERVICE_ZONED:
// same as OnZoned
break;
}
}
void __cdecl EQChatService(bool Broadcast, unsigned int MSG, void *lpData)
{
#define pChat ((_EQChat*)lpData)
switch (MSG)
{
case CHATSERVICE_OUTGOING:
// same as OnWriteChatColor
break;
case CHATSERVICE_INCOMING:
// same as OnIncomingChat
break;
}
#undef pChat
}
// This uses the Services service to connect to ISXEQ services
void __cdecl ServicesService(bool Broadcast, unsigned int MSG, void *lpData)
{
#define Name ((char*)lpData)
switch (MSG)
{
case SERVICES_ADDED:
if (!stricmp(Name, "EQ UI Service"))
{
hEQUIService = pISInterface->ConnectService(pExtension, Name, EQUIService);
}
else if (!stricmp(Name, "EQ Gamestate Service"))
{
hEQGamestateService = pISInterface->ConnectService(pExtension, Name, EQGamestateService);
}
else if (!stricmp(Name, "EQ Spawn Service"))
{
hEQSpawnService = pISInterface->ConnectService(pExtension, Name, EQSpawnService);
}
else if (!stricmp(Name, "EQ Zone Service"))
{
hEQZoneService = pISInterface->ConnectService(pExtension, Name, EQZoneService);
}
else if (!stricmp(Name, "EQ Chat Service"))
{
hEQChatService = pISInterface->ConnectService(pExtension, Name, EQChatService);
}
break;
case SERVICES_REMOVED:
if (!stricmp(Name, "EQ UI Service"))
{
if (hEQUIService)
{
pISInterface->DisconnectService(pExtension, hEQUIService);
hEQUIService = 0;
}
}
else if (!stricmp(Name, "EQ Gamestate Service"))
{
if (hEQGamestateService)
{
pISInterface->DisconnectService(pExtension, hEQGamestateService);
hEQGamestateService = 0;
}
}
else if (!stricmp(Name, "EQ Spawn Service"))
{
if (hEQSpawnService)
{
pISInterface->DisconnectService(pExtension, hEQSpawnService);
hEQSpawnService = 0;
}
}
else if (!stricmp(Name, "EQ Zone Service"))
{
if (hEQZoneService)
{
pISInterface->DisconnectService(pExtension, hEQZoneService);
hEQZoneService = 0;
}
}
else if (!stricmp(Name, "EQ Chat Service"))
{
if (hEQChatService)
{
pISInterface->DisconnectService(pExtension, hEQChatService);
hEQChatService = 0;
}
}
break;
}
#undef Name
}
int MyCommand(int argc, char *argv[])
{
// IS Commands work just like console programs. argc is the argument (aka parameter) count,
// argv is an array containing them. The name of the command is always the first argument.
if (argc<2)
{
// This command requires arguments
WriteChatf("Syntax: %s <text>", argv[0]);
return 0;
}
char FullText[8192] = { 0 };
pISInterface->GetArgs(1, argc, argv, FullText, sizeof(FullText)); // this gets the rest of the arguments, from 1 to argc
WriteChatf("You passed the following text to the command:");
WriteChatf("%s", FullText);
// For most commands, you need to deal with only one argument at a time, instead of the entire line.
for (int i = 1; i < argc; i++)
{
WriteChatf("argv[%d]=\"%s\"", i, argv[i]);
}
// return 0 or greater for normal conditions, or return -1 for an error that should stop
// a script.
return 0;
}
MQ2Discord/ISXEQDiscord.h deleted 100644 → 0
View file @ 1bcd319d
#pragma once
#pragma pack(push)
#pragma pack(8)
#include <isxdk.h>
#pragma pack(pop)
class ISXEQDiscord :
public ISXInterface
{
public:
virtual bool Initialize(ISInterface *p_ISInterface);
virtual void Shutdown();
void LoadSettings();
void ConnectServices();
void RegisterCommands();
void RegisterAliases();
void RegisterDataTypes();
void RegisterTopLevelObjects();
void RegisterServices();
void DisconnectServices();
void UnRegisterCommands();
void UnRegisterAliases();
void UnRegisterDataTypes();
void UnRegisterTopLevelObjects();
void UnRegisterServices();
};
extern ISInterface *pISInterface;