cdpi.cpp

// Content Delivery Platform Integrations

#include "engine.h"
#include "controller.h"
#include <stddef.h>
#if defined(USE_STEAM)
#define HAS_STEAM 1

#ifndef nullptr
#define nullptr NULL
#endif
#ifndef static_assert
#define static_assert(x, y) assert(x)
#endif

#include <steam_gameserver.h>
#include <steam_api_flat.h> // C++ API crashes when compiled with MingW
#endif
#if !defined(STANDALONE) && defined(USE_DISCORD)
#define HAS_DISCORD 1
#define DISCORD_DYNAMIC_LIB 1
#include <discord_rpc.h>
//#include <discord_register.h>
#endif

namespace cdpi
{
    int curapis = NONE;

    namespace steam
    {
        SVAR(IDF_READONLY, steamusername, "");
        SVAR(IDF_READONLY, steamuserid, "");
        SVAR(IDF_READONLY, steamserverid, "");

#ifdef HAS_STEAM
        int curoverlay = 0, curplayers = 0;
        bool servconnected = false;
        ISteamUser *user = NULL;
        ISteamFriends *friends = NULL;
        ISteamUserStats *stats = NULL;
        ISteamClient *client = NULL, *sclient = NULL;
        ISteamGameServer *serv = NULL;
	ISteamInput *input = NULL;
        HSteamPipe umpipe = 0, smpipe = 0;
        HSteamUser uupipe = 0, supipe = 0;
        HAuthTicket authticket = k_HAuthTicketInvalid;

        VAR(IDF_PERSIST, steamclient, 0, 1, 1);
        VAR(IDF_PERSIST, steamserver, 0, eServerModeAuthentication, eServerModeAuthenticationAndSecure);

        uint64_steamid strtosid(const char *sid)
        {
            return uint64_steamid(uint64(strtoll(sid, NULL, 10)));
        }

        class steamcb
        {
            public:
                void getnumplayers();
            private:
                STEAM_CALLBACK(steamcb, overlayactivated, GameOverlayActivated_t);
                void on_getnumplayers(NumberOfCurrentPlayers_t *p, bool b);
                CCallResult<steamcb, NumberOfCurrentPlayers_t> numplayers;
                STEAM_GAMESERVER_CALLBACK(steamcb, serversconnected, SteamServersConnected_t);
                STEAM_GAMESERVER_CALLBACK(steamcb, serversconnfail, SteamServerConnectFailure_t);
                STEAM_GAMESERVER_CALLBACK(steamcb, serversdisconnected, SteamServersDisconnected_t);
                STEAM_GAMESERVER_CALLBACK(steamcb, policyresponse, GSPolicyResponse_t);
                STEAM_GAMESERVER_CALLBACK(steamcb, authticketresponse, ValidateAuthTicketResponse_t);
        } cbs;

        void steamcb::overlayactivated(GameOverlayActivated_t *p)
        {
            if(p->m_bActive) conoutf(colourwhite, "Steam overlay opened.");
            else conoutf(colourwhite, "Steam overlay closed.");
            curoverlay = p->m_bActive != 0 ? totalmillis : -totalmillis;
        }

        void steamcb::getnumplayers()
        {
            SteamAPICall_t hSteamAPICall = SteamAPI_ISteamUserStats_GetNumberOfCurrentPlayers(stats);
            numplayers.Set(hSteamAPICall, this, &steamcb::on_getnumplayers);
        }

        void steamcb::on_getnumplayers(NumberOfCurrentPlayers_t *p, bool b)
        {
            if(b || !p->m_bSuccess) return;
            curplayers = p->m_cPlayers;
            conoutf(colourwhite, "Number of Steam users currently playing: %d", curplayers);
        }

        void steamcb::serversconnected(SteamServersConnected_t *p)
        {
            conoutf(colourwhite, "Server connected to Steam successfully.");
            servconnected = true;
        }

        void steamcb::serversconnfail(SteamServerConnectFailure_t *p)
        {
            servconnected = false;
            conoutf(colourred, "Server failed to connect to Steam.");
        }

        void steamcb::serversdisconnected(SteamServersDisconnected_t *p)
        {
            servconnected = false;
            conoutf(colourred, "Server got logged out of Steam.");
        }

        void steamcb::policyresponse(GSPolicyResponse_t *p)
        {
            defformatstring(id, SI64, SteamAPI_ISteamGameServer_GetSteamID(serv));
            setsvar("steamserverid", id);
            conoutf(colourwhite, "Game server SteamID: %s (%s)", id, SteamAPI_ISteamGameServer_BSecure(serv) ? "VAC" : "Non-VAC");
        }

        void steamcb::authticketresponse(ValidateAuthTicketResponse_t *p)
        {
            defformatstring(id, SI64, p->m_SteamID.ConvertToUint64());
            server::clientsteamticket(id, p->m_eAuthSessionResponse == k_EAuthSessionResponseOK);
        }

        void clientcancelticket()
        {
            if(authticket == k_HAuthTicketInvalid) return;
            if(curapis&SWCLIENT) SteamAPI_ISteamUser_CancelAuthTicket(user, authticket);
            authticket = k_HAuthTicketInvalid;
        }

        void cleanup(int apis = -1)
        {
            int check = apis >= 0 ? apis : curapis;
            if(check&SWCLIENT)
            {
                clientcancelticket();
                SteamAPI_Shutdown();
                conoutf(colourwhite, "Steam API has been shutdown.");
                curoverlay = 0;
                client = NULL;
                user = NULL;
                friends = NULL;
                stats = NULL;
                umpipe = uupipe = 0;
                curapis &= ~SWCLIENT;
            }
            if(check&SWSERVER)
            {
                SteamAPI_ISteamGameServer_SetAdvertiseServerActive(serv, false);
                SteamAPI_ISteamGameServer_LogOff(serv);
                SteamGameServer_Shutdown();
                sclient = NULL;
                serv = NULL;
                servconnected = false;
                conoutf(colourwhite, "Steam GameServer has been shutdown.");
                curapis &= ~SWSERVER;
            }
        }

        bool initclient()
        {
            if(!steamclient) return true;
            if(versionsteamid && !strncmp(versionbranch, "steam", 5) && SteamAPI_RestartAppIfNecessary(versionsteamid)) return false;

            SteamErrMsg errmsg;
            if(SteamAPI_InitFlat(&errmsg) != ESteamAPIInitResult::k_ESteamAPIInitResult_OK)
            {
                conoutf(colourred, "Steam API failed to start: %s", errmsg);
                return true;
            }
            curapis |= SWCLIENT;

            client = (ISteamClient *)SteamClient(); //SteamInternal_CreateInterface(STEAMCLIENT_INTERFACE_VERSION);
            if(!client) { conoutf(colourred, "Failed to get Steam client interface."); cleanup(SWCLIENT); return true; }
            umpipe = SteamAPI_GetHSteamPipe();
            if(!umpipe) { conoutf(colourred, "Failed to get Steam main pipe."); cleanup(SWCLIENT); return true; }
            uupipe = SteamAPI_GetHSteamUser();
            if(!uupipe)
            {
                conoutf(colourred, "Current Steam user pipe is invalid, trying to connect to global user.");
                uupipe = SteamAPI_ISteamClient_ConnectToGlobalUser(client, umpipe);
                if(!uupipe) { conoutf(colourred, "Failed to get Steam user pipe."); cleanup(SWCLIENT); return true; }
            }
            user = (ISteamUser *)SteamAPI_ISteamClient_GetISteamUser(client, uupipe, umpipe, STEAMUSER_INTERFACE_VERSION);
            if(!user) { conoutf(colourred, "Failed to get Steam user interface."); cleanup(SWCLIENT); return true; }
            friends = (ISteamFriends *)SteamAPI_ISteamClient_GetISteamFriends(client, uupipe, umpipe, STEAMFRIENDS_INTERFACE_VERSION);
            if(!friends) { conoutf(colourred, "Failed to get Steam friends interface."); cleanup(SWCLIENT); return true; }
            stats = (ISteamUserStats *)SteamAPI_ISteamClient_GetISteamUserStats(client, uupipe, umpipe, STEAMUSERSTATS_INTERFACE_VERSION);
            if(!stats) { conoutf(colourred, "Failed to get Steam stats interface."); cleanup(SWCLIENT); return true; }
	    input = (ISteamInput *)SteamAPI_ISteamClient_GetISteamInput(client, uupipe, umpipe, STEAMINPUT_INTERFACE_VERSION);
	    if (!input) { conoutf(colourred, "Failed to get Steam Input interface."); cleanup(SWCLIENT); return true; }
	    input->Init(false);
	    controller::init_action_handles();

            const char *name = SteamAPI_ISteamFriends_GetPersonaName(friends);
            if(name && *name)
            {
                setsvar("steamusername", name);
                conoutf(colourwhite, "Current Steam Handle: %s", name);
            }
            if(SteamAPI_ISteamUser_BLoggedOn(user))
            {
                defformatstring(id, SI64, SteamAPI_ISteamUser_GetSteamID(user));
                setsvar("steamuserid", id);
                conoutf(colourwhite, "Current Steam UserID: %s", id);
            }
            conoutf(colourwhite, "Steam API initialised successfully.");
            cbs.getnumplayers();
            return true;
        }

        void initserver()
        {
            if(!steamserver) return;
            if(!SteamGameServer_Init(INADDR_ANY, serverport, serverport+2, EServerMode(steamserver), versionstring))
            {
                conoutf(colourred, "Steam GameServer API failed to start.");
                return;
            }

            curapis |= SWSERVER;

            sclient = (ISteamClient *)SteamGameServerClient(); //SteamInternal_CreateInterface(STEAMCLIENT_INTERFACE_VERSION);
            if(!sclient) { conoutf(colourred, "Failed to get Steam client interface."); cleanup(SWSERVER); return; }
            smpipe = SteamGameServer_GetHSteamPipe();
            if(!smpipe) { conoutf(colourred, "Failed to get Steam main pipe."); cleanup(SWSERVER); return; }
            supipe = SteamGameServer_GetHSteamUser();
            if(!supipe) { conoutf(colourred, "Failed to get Steam user pipe."); cleanup(SWSERVER); return; }
            serv = (ISteamGameServer *)SteamAPI_ISteamClient_GetISteamGameServer(sclient, supipe, smpipe, STEAMGAMESERVER_INTERFACE_VERSION);
            if(!serv) { conoutf(colourred, "Failed to get Steam server interface."); cleanup(SWSERVER); return; }

            defformatstring(steamappid, "%d", versionsteamid);
            SteamAPI_ISteamGameServer_SetModDir(serv, versionfname);
            SteamAPI_ISteamGameServer_SetProduct(serv, steamappid);
            SteamAPI_ISteamGameServer_SetGameDescription(serv, versiondesc);
            SteamAPI_ISteamGameServer_SetDedicatedServer(serv, servertype >= 3);
            SteamAPI_ISteamGameServer_LogOnAnonymous(serv);
            SteamAPI_ISteamGameServer_SetAdvertiseServerActive(serv, true);
            conoutf(colourwhite, "Steam GameServer API initialised successfully.");
        }

        void servupdate()
        {
            SteamAPI_ISteamGameServer_SetMaxPlayerCount(serv, server::maxslots());
            SteamAPI_ISteamGameServer_SetPasswordProtected(serv, false);
            SteamAPI_ISteamGameServer_SetServerName(serv, server::getserverdesc());
            SteamAPI_ISteamGameServer_SetSpectatorPort(serv, serverport);
            SteamAPI_ISteamGameServer_SetSpectatorServerName(serv, server::getserverdesc());
            SteamAPI_ISteamGameServer_SetBotPlayerCount(serv, 0);
            SteamAPI_ISteamGameServer_SetMapName(serv, server::getmapname());
        }

        static int lastframe = 0;
        void runframe()
        {
            if(lastframe && totalmillis-lastframe < 100) return; // 10 Hz
            if(curapis&SWCLIENT) SteamAPI_RunCallbacks();
            if(curapis&SWSERVER)
            {
                SteamGameServer_RunCallbacks();
                if(servconnected) servupdate();
            }
            lastframe = totalmillis;
        }

        void clientconnect()
        {
            //if(!(curapis&SWCLIENT)) return;
            //SteamFriends()->SetRichPresence( "connect", rgchConnectString );
        }

        void clientdisconnect()
        {
            if(!(curapis&SWCLIENT)) return;
            clientcancelticket();
        }

        bool clientauthticket(char *token, uint *tokenlen, ENetAddress *addr)
        {
            if(!(curapis&SWCLIENT)) return false;
            clientcancelticket();
            if(!addr) return false;

            SteamNetworkingIdentity snid;
            SteamAPI_SteamNetworkingIdentity_SetIPv4Addr(&snid, addr->host, addr->port);
            authticket = SteamAPI_ISteamUser_GetAuthSessionTicket(user, token, 1024, tokenlen, &snid);
            conoutf(colourwhite, "Generating Auth Ticket: %u (%u)", authticket, *tokenlen);
            return authticket != k_HAuthTicketInvalid;
        }

        bool clientready()
        {
            return curapis&SWCLIENT ? true : false;
        }

        int serverauthmode()
        {
            if(!(curapis&SWSERVER)) return 0;
            switch(steamserver)
            {
                case eServerModeAuthenticationAndSecure: return 2;
                case eServerModeAuthentication: return 1;
                case eServerModeNoAuthentication: default: return 0;
            }
            return 0;
        }

        bool serverparseticket(const char *steamid, const uchar *token, uint tokenlen)
        {
            if(!(curapis&SWSERVER)) return false;
            uint64_steamid sid = strtosid(steamid);
            if(SteamAPI_ISteamGameServer_BeginAuthSession(serv, token, tokenlen, sid) != k_EBeginAuthSessionResultOK) return false;
            return true;
        }

        void servercancelticket(const char *steamid)
        {
            if(!(curapis&SWSERVER)) return;
            uint64_steamid sid = strtosid(steamid);
            SteamAPI_ISteamGameServer_EndAuthSession(serv, sid);
        }
#else
        bool clientauthticket(char *token, uint *tokenlen, ENetAddress *addr) { return false; }
        int serverauthmode() { return 0; }
        bool serverparseticket(const char *steamid, const uchar *token, uint tokenlen) { return false; }
        void servercancelticket(const char *steamid) {}
#endif
    }
#ifdef HAS_DISCORD
    namespace discord
    {
        VAR(IDF_PERSIST, discordenabled, 0, 1, 1);
        VAR(IDF_PERSIST, discordpresence, 0, 3, 3); // bitwise: 0 = off, 1 = public, 2 = private (offline) as well

        void ready(const DiscordUser *u)
        {
            conoutf(colourwhite, "Discord: connected to user %s#%s - %s", u->username, u->discriminator, u->userId);
        }

        void disconnected(int errcode, const char *message)
        {
            conoutf(colourwhite, "Discord: disconnected (%d: %s)", errcode, message);
        }

        void error(int errcode, const char  *message)
        {
            conoutf(colourred, "Discord: error (%d: %s)", errcode, message);
        }

        void joingame(const char *secret)
        {
            conoutf(colourwhite, "Discord: join (%s)", secret);
        }

        void spectategame(const char *secret)
        {
            conoutf(colourwhite, "Discord: spectate (%s)", secret);
        }

        void joinrequest(const DiscordUser *u)
        {
            conoutf(colourwhite, "Discord: join request from %s#%s - %s", u->username, u->discriminator, u->userId);
            //response = DISCORD_REPLY_YES;
            //response = DISCORD_REPLY_NO;
            //Discord_Respond(u->userId, response);
        }

        void cleanup()
        {
            if(!(curapis&DISCORD)) return;;
            Discord_Shutdown();
            conoutf(colourwhite, "Discord API has been shutdown.");
        }

        void init()
        {
            if(!*versiondiscordid) return;
            DiscordEventHandlers handlers;
            memset(&handlers, 0, sizeof(handlers));
            handlers.ready = ready;
            handlers.errored = error;
            handlers.disconnected = disconnected;
            handlers.joinGame = joingame;
            handlers.spectateGame = spectategame;
            handlers.joinRequest = joinrequest;
            defformatstring(str, "%d", versionsteamid);
            Discord_Initialize(versiondiscordid, &handlers, 0, str); // todo: update for autoregister
            conoutf(colourwhite, "Discord API initialised successfully.");
            curapis |= DISCORD;
        }

        static int lastframe = 0, lastpresence = 0;
        static string state = "", details = "";
        void runframe()
        {
            if(!(curapis&DISCORD) || (lastframe && totalmillis-lastframe < 100)) return;
            if(!lastpresence || totalmillis-lastpresence >= 15000)  // 15s rate limit
            {
                if(discordpresence&(curpeer ? 1 : 2))
                {
                    DiscordRichPresence discordPresence;
                    memset(&discordPresence, 0, sizeof(discordPresence));

                    if(connected()) formatstring(details, "%s on %s", game::gametitle(), mapctitle(mapname));
                    else copystring(details, "Main Menu");
                    discordPresence.details = details;

                    if(curpeer && *connectname) formatstring(state, "%s (%s:[%d])", game::gamestatename(), connectname, connectport);
                    else formatstring(state, "%s (offline)", game::gamestatename());
                    discordPresence.state = state;

                    discordPresence.startTimestamp = 0;
                    int g = game::gettimeremain();
                    discordPresence.endTimestamp = g ? (currenttime + g/1000) : 0;
                    discordPresence.largeImageKey = "emblem";
                    discordPresence.largeImageText = versionfname;
                    discordPresence.smallImageKey = hud::modeimage();
                    discordPresence.smallImageText = details;

                    //discordPresence.partyId = "party1234";
                    //discordPresence.partySize = 1;
                    //discordPresence.partyMax = 6;
                    //discordPresence.matchSecret = "xyzzy";
                    //discordPresence.joinSecret = "join";
                    //discordPresence.spectateSecret = "look";
                    //discordPresence.instance = 0;

                    Discord_UpdatePresence(&discordPresence);
                }
                else Discord_ClearPresence();
                lastpresence = totalmillis;
            }
            Discord_RunCallbacks();
            lastframe = totalmillis;
        }
    }
#endif

    void cleanup()
    {
#ifdef HAS_STEAM
        steam::cleanup();
#endif
#ifdef HAS_DISCORD
        discord::cleanup();
#endif
    }

    bool init()
    {
        curapis = NONE;
#ifdef HAS_STEAM
#ifndef STANDALONE
        if(servertype < 3) if(!steam::initclient()) return false; // steam says die
#endif
        if(servertype >= 2) steam::initserver();
#endif
#ifdef HAS_DISCORD
        discord::init();
#endif
        return true;
    }

    void runframe()
    {
#ifdef HAS_STEAM
        steam::runframe();
#endif
#ifdef HAS_DISCORD
        discord::runframe();
#endif
    }

    int getoverlay()
    {
#ifdef HAS_STEAM
        if(steam::curoverlay) return steam::curoverlay;
#endif
        return 0;
    }

    void clientconnect()
    {
#ifdef HAS_STEAM
        steam::clientconnect();
#endif
    }

    void clientdisconnect()
    {
#ifdef HAS_STEAM
        steam::clientdisconnect();
#endif
    }
}