stk_peer.hpp

Go to the documentation of this file.

//
//  SuperTuxKart - a fun racing game with go-kart
//  Copyright (C) 2013-2015 SuperTuxKart-Team
//
//  This program is free software; you can redistribute it and/or
//  modify it under the terms of the GNU General Public License
//  as published by the Free Software Foundation; either version 3
//  of the License, or (at your option) any later version.
//
//  This program is distributed in the hope that it will be useful,
//  but WITHOUT ANY WARRANTY; without even the implied warranty of
//  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
//  GNU General Public License for more details.
//
//  You should have received a copy of the GNU General Public License
//  along with this program; if not, write to the Free Software
//  Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
 
#ifndef STK_PEER_HPP
#define STK_PEER_HPP
 
#include "utils/no_copy.hpp"
#include "utils/time.hpp"
#include "utils/types.hpp"
 
#include <enet/enet.h>
 
#include <array>
#include <atomic>
#include <deque>
#include <memory>
#include <numeric>
#include <set>
#include <string>
#include <vector>
 
class Crypto;
class NetworkPlayerProfile;
class NetworkString;
class STKHost;
class SocketAddress;
 
enum PeerDisconnectInfo : unsigned int
{
    PDI_TIMEOUT = 0, 
    PDI_NORMAL = 1, 
    PDI_KICK = 2, 
    PDI_KICK_HIGH_PING = 3, 
};   // PeerDisconnectInfo
 
enum AddonScore : int
{
    AS_KART = 0,
    AS_TRACK = 1,
    AS_ARENA = 2,
    AS_SOCCER = 3,
    AS_TOTAL = 4,
};   // AddonScore
 
enum AlwaysSpectateMode : uint8_t
{
    ASM_NONE = 0, 
    ASM_COMMAND = 1, 
    ASM_FULL = 2, 
};   // AlwaysSpectateMode
 
class STKPeer : public NoCopy
{
protected:
    ENetPeer* m_enet_peer;
 
    ENetAddress m_address;
 
    std::atomic_bool m_validated;
 
    std::atomic_bool m_waiting_for_game;
 
    std::atomic_bool m_spectator;
 
    std::atomic_bool m_disconnected;
 
    std::atomic_bool m_warned_for_high_ping;
 
    std::atomic<uint8_t> m_always_spectate;
 
    uint32_t m_host_id;
 
    std::unique_ptr<SocketAddress> m_socket_address;
 
    STKHost* m_host;
 
    std::vector<std::shared_ptr<NetworkPlayerProfile> > m_players;
 
    uint64_t m_connected_time;
 
    std::atomic<int64_t> m_last_activity;
 
    std::atomic<int64_t> m_last_message;
 
    int m_consecutive_messages;
 
    std::pair<std::set<std::string>, std::set<std::string> > m_available_kts;
 
    std::unique_ptr<Crypto> m_crypto;
 
    std::deque<uint32_t> m_previous_pings;
 
    std::atomic<uint32_t> m_average_ping;
 
    std::atomic<int> m_packet_loss;
 
    std::set<unsigned> m_available_kart_ids;
 
    std::string m_user_version;
 
    std::set<std::string> m_client_capabilities;
 
    std::array<int, AS_TOTAL> m_addons_scores;
public:
    STKPeer(ENetPeer *enet_peer, STKHost* host, uint32_t host_id);
    // ------------------------------------------------------------------------
    ~STKPeer();
    // ------------------------------------------------------------------------
    void sendPacket(NetworkString *data, bool reliable = true,
                    bool encrypted = true);
    // ------------------------------------------------------------------------
    void disconnect();
    // ------------------------------------------------------------------------
    void kick();
    // ------------------------------------------------------------------------
    void reset();
    // ------------------------------------------------------------------------
    bool isConnected() const;
    // ------------------------------------------------------------------------
    bool isSamePeer(const STKPeer* peer) const;
    bool isSamePeer(const ENetPeer* peer) const;
    // ------------------------------------------------------------------------
    std::vector<std::shared_ptr<NetworkPlayerProfile> >& getPlayerProfiles()
                                                          { return m_players; }
    // ------------------------------------------------------------------------
    bool hasPlayerProfiles() const               { return !m_players.empty(); }
    // ------------------------------------------------------------------------
    void cleanPlayerProfiles()                           { m_players.clear(); }
    // ------------------------------------------------------------------------
    void addPlayer(std::shared_ptr<NetworkPlayerProfile> p)
                                                    { m_players.push_back(p); }
    // ------------------------------------------------------------------------
    void setValidated(bool val)                     { m_validated.store(val); }
    // ------------------------------------------------------------------------
    bool isValidated() const                     { return m_validated.load(); }
    // ------------------------------------------------------------------------
    uint32_t getHostId() const                            { return m_host_id; }
    // ------------------------------------------------------------------------
    float getConnectedTime() const
       { return float(StkTime::getMonoTimeMs() - m_connected_time) / 1000.0f; }
    // ------------------------------------------------------------------------
    void setAvailableKartsTracks(std::set<std::string>& k,
                                 std::set<std::string>& t)
              { m_available_kts = std::make_pair(std::move(k), std::move(t)); }
    // ------------------------------------------------------------------------
    void eraseServerKarts(const std::set<std::string>& server_karts,
                          std::set<std::string>& karts_erase) const
    {
        if (m_available_kts.first.empty())
            return;
        for (const std::string& server_kart : server_karts)
        {
            if (m_available_kts.first.find(server_kart) ==
                m_available_kts.first.end())
            {
                karts_erase.insert(server_kart);
            }
        }
    }
    // ------------------------------------------------------------------------
    void eraseServerTracks(const std::set<std::string>& server_tracks,
                           std::set<std::string>& tracks_erase) const
    {
        if (m_available_kts.second.empty())
            return;
        for (const std::string& server_track : server_tracks)
        {
            if (m_available_kts.second.find(server_track) ==
                m_available_kts.second.end())
            {
                tracks_erase.insert(server_track);
            }
        }
    }
    // ------------------------------------------------------------------------
    std::pair<std::set<std::string>, std::set<std::string> >
                            getClientAssets() const { return m_available_kts; }
    // ------------------------------------------------------------------------
    void setPingInterval(uint32_t interval)
                            { enet_peer_ping_interval(m_enet_peer, interval); }
    // ------------------------------------------------------------------------
    uint32_t getPing();
    // ------------------------------------------------------------------------
    Crypto* getCrypto() const                        { return m_crypto.get(); }
    // ------------------------------------------------------------------------
    void setCrypto(std::unique_ptr<Crypto>&& c);
    // ------------------------------------------------------------------------
    uint32_t getAveragePing() const           { return m_average_ping.load(); }
    // ------------------------------------------------------------------------
    ENetPeer* getENetPeer() const                       { return m_enet_peer; }
    // ------------------------------------------------------------------------
    void setWaitingForGame(bool val)         { m_waiting_for_game.store(val); }
    // ------------------------------------------------------------------------
    bool isWaitingForGame() const         { return m_waiting_for_game.load(); }
    // ------------------------------------------------------------------------
    void setSpectator(bool val)                     { m_spectator.store(val); }
    // ------------------------------------------------------------------------
    bool isSpectator() const                     { return m_spectator.load(); }
    // ------------------------------------------------------------------------
    bool isDisconnected() const               { return m_disconnected.load(); }
    // ------------------------------------------------------------------------
    void setDisconnected(bool val)        { return m_disconnected.store(val); }
    // ------------------------------------------------------------------------
    bool hasWarnedForHighPing() const { return m_warned_for_high_ping.load(); }
    // ------------------------------------------------------------------------
    void setWarnedForHighPing(bool val)  { m_warned_for_high_ping.store(val); }
    // ------------------------------------------------------------------------
    void clearAvailableKartIDs()              { m_available_kart_ids.clear(); }
    // ------------------------------------------------------------------------
    void addAvailableKartID(unsigned id)   { m_available_kart_ids.insert(id); }
    // ------------------------------------------------------------------------
    bool availableKartID(unsigned id)
        { return m_available_kart_ids.find(id) != m_available_kart_ids.end(); }
    // ------------------------------------------------------------------------
    const std::set<unsigned>& getAvailableKartIDs() const
                                               { return m_available_kart_ids; }
    // ------------------------------------------------------------------------
    void setUserVersion(const std::string& uv)         { m_user_version = uv; }
    // ------------------------------------------------------------------------
    const std::string& getUserVersion() const        { return m_user_version; }
    // ------------------------------------------------------------------------
    void updateLastActivity()
                  { m_last_activity.store((int64_t)StkTime::getMonoTimeMs()); }
    // ------------------------------------------------------------------------
    int idleForSeconds() const
    {
        int64_t diff =
            (int64_t)StkTime::getMonoTimeMs() - m_last_activity.load();
        if (diff < 0)
            return 0;
        return (int)(diff / 1000);
    }
    // ------------------------------------------------------------------------
    void setClientCapabilities(std::set<std::string>& caps)
                                   { m_client_capabilities = std::move(caps); }
    // ------------------------------------------------------------------------
    const std::set<std::string>& getClientCapabilities() const
                                              { return m_client_capabilities; }
    // ------------------------------------------------------------------------
    bool isAIPeer() const                    { return m_user_version == "AI"; }
    // ------------------------------------------------------------------------
    void setPacketLoss(int loss)                 { m_packet_loss.store(loss); }
    // ------------------------------------------------------------------------
    int getPacketLoss() const                  { return m_packet_loss.load(); }
    // ------------------------------------------------------------------------
    const std::array<int, AS_TOTAL>& getAddonsScores() const
                                                    { return m_addons_scores; }
    // ------------------------------------------------------------------------
    void setAddonsScores(const std::array<int, AS_TOTAL>& scores)
                                                  { m_addons_scores = scores; }
    // ------------------------------------------------------------------------
    void updateLastMessage()
                   { m_last_message.store((int64_t)StkTime::getMonoTimeMs()); }
    // ------------------------------------------------------------------------
    int64_t getLastMessage() const
                                                     { return m_last_message; }
    // ------------------------------------------------------------------------
    void updateConsecutiveMessages(bool too_fast)
    {
        if (too_fast)
            m_consecutive_messages++;
        else
            m_consecutive_messages = 0;
    }
    // ------------------------------------------------------------------------
    int getConsecutiveMessages() const       { return m_consecutive_messages; }
    // ------------------------------------------------------------------------
    const SocketAddress& getAddress() const { return *m_socket_address.get(); }
    // ------------------------------------------------------------------------
    void setAlwaysSpectate(AlwaysSpectateMode mode)
                                             { m_always_spectate.store(mode); }
    // ------------------------------------------------------------------------
    bool alwaysSpectate() const
                               { return m_always_spectate.load() != ASM_NONE; }
    // ------------------------------------------------------------------------
    void resetAlwaysSpectateFull()
    {
        if (m_always_spectate.load() == ASM_FULL)
            m_always_spectate.store(ASM_NONE);
    }
};   // STKPeer
 
#endif // STK_PEER_HPP