mastermanager.cpp

//------------------------------------------------------------------------------
// mastermanager.cpp
//------------------------------------------------------------------------------
//
// This library is free software; you can redistribute it and/or
// modify it under the terms of the GNU Lesser General Public
// License as published by the Free Software Foundation; either
// version 2.1 of the License, or (at your option) any later version.
//
// This library 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
// Lesser General Public License for more details.
//
// You should have received a copy of the GNU Lesser General Public
// License along with this library; if not, write to the Free Software
// Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
// 02110-1301  USA
//
//------------------------------------------------------------------------------
// Copyright (C) 2009 Braden "Blzut3" Obrzut <admin@maniacsvault.net>
//------------------------------------------------------------------------------
#include <cassert>

#include "mastermanager.h"

#include "customservers.h"
#include "serverapi/broadcastmanager.h"
#include "serverapi/message.h"
#include "serverapi/server.h"

// TODO: I don't think that MasterManager should store a duplicate of each
// server (~Zalewa).

MasterManager::MasterManager() : MasterClient()
{
        customServers = new CustomServers();
}

MasterManager::~MasterManager()
{
        clearServers();

        qDeleteAll(masters);

        delete customServers;
}

void MasterManager::addMaster(MasterClient *master)
{
        if (master == nullptr)
                return;

        masters.append(master);
        master->setEnabled(true);

        this->connect(master, SIGNAL(listUpdated()), SLOT(masterListUpdated()));
        this->connect(master, SIGNAL(message(QString,QString,bool)),
                SLOT(forwardMasterMessage(QString,QString,bool)));
        this->connect(master, SIGNAL(messageImportant(Message)),
                SLOT(forwardMasterMessageImportant(Message)));
}

QList<ServerPtr> MasterManager::allServers() const
{
        QSet<ServerPtr> result;
        for (MasterClient *master : masters)
        {
                for (ServerPtr server : master->servers())
                        result.insert(server);
        }
        for (ServerPtr server : customServers->servers())
                result.insert(server);
        if (broadcastManager != nullptr)
        {
                for (ServerPtr server : broadcastManager->servers())
                        result.insert(server);
        }
        return result.values();
}

void MasterManager::masterListUpdated()
{
        auto master = static_cast<MasterClient *>(sender());
        for (ServerPtr pServer : master->servers())
        {
                registerNewServer(pServer);
        }

        emit listUpdatedForMaster(master);
        mastersBeingRefreshed.remove(master);
        if (mastersBeingRefreshed.isEmpty())
        {
                emit listUpdated();
        }
}

MasterManager::Response MasterManager::readMasterResponse(const QByteArray &data)
{
        Q_UNUSED(data);
        assert(0 && "MasterManager::readMasterResponse should not get called.");
        return RESPONSE_BAD;
}

void MasterManager::refreshStarts()
{
        setTimeouted(false);

        clearServers();

        for (auto *master : masters)
        {
                if (!master->isEnabled())
                {
                        continue;
                }

                mastersBeingRefreshed.insert(master);
                master->refreshStarts();
        }
}

void MasterManager::timeoutRefreshEx()
{
        for (MasterClient *pMaster : mastersBeingRefreshed)
        {
                pMaster->timeoutRefresh();
        }

        mastersBeingRefreshed.clear();
}

void MasterManager::setBroadcastManager(BroadcastManager *broadcastManagerPtr)
{
        broadcastManager = broadcastManagerPtr;
}