#include "msguirouter.h"
#include "dialogs/forgedcertdialog.h"
#include "history.h"
#include "mainwindow.h"
#include "picasystray.h"
#include "globals.h"
#include "sound.h"

/*
  этот класс должен обеспечивать связь между приёмом-отправкой сообщений и их отображением в пользовательском интерфейсе.
  Класс SkyNet отвечает только за прием и отправку сообщений, пересылку через сеть и работу с протоколом, ему пофиг,
  как они показываются юзеру. Данный класс должен работать с GUI, например, по приходу нового сообщения (через сигнал от
  класса SkyNet) либо помигать иконкой в трее, либо создать новое окно чата, либо развернуть уже имеющееся, либо помигать
  свернутым окном на таскбаре. Это поведение может настраиваться, настройки хранить в базе и загружать в конструкторе из
  базы sqlite. Например, данный класс должен управлять экземплярами ChatWindow, создавать новые при необходимости либо
  активировать имеющиеся.
 */
MsgUIRouter::MsgUIRouter(QObject *parent) :
    QObject(parent)
{
    connect(skynet, SIGNAL(MessageReceived(QByteArray,QString)), this, SLOT(msg_from_peer(QByteArray,QString)));
    connect(skynet, SIGNAL(UnableToDeliver(QByteArray,QString)), this, SLOT(delivery_failed(QByteArray,QString)));
    connect(skynet, SIGNAL(Delivered(QByteArray)), this, SLOT(delivered(QByteArray)));
    connect(skynet, SIGNAL(CertificateForged(QByteArray,QString,QString)), this, SLOT(scary_cert_message(QByteArray,QString,QString)));
    connect(skynet, SIGNAL(ErrMsgFromNode(QString)), this, SLOT(notification(QString)));
    connect(systray, SIGNAL(doubleclicked()), this, SLOT(trayicon_dclick()));

}

void MsgUIRouter::trayicon_dclick()
{
    if (blinkqueue.isEmpty())
    {
        mainwindow->showNormal();
        mainwindow->activateWindow();
        mainwindow->raise();
    }
    else
    {
        QByteArray blinker_id = blinkqueue.takeFirst();

        if (chatwindows.contains(blinker_id))
        {
            chatwindows[blinker_id]->showNormal();
            chatwindows[blinker_id]->activateWindow();
            chatwindows[blinker_id]->raise();
        }

        if (blinkqueue.isEmpty())
        {
            systray->StopBlinking();
        }
    }
}

void MsgUIRouter::create_chatwindow(QByteArray peer_id)
{
    ChatWindow *cw;

    cw = new ChatWindow(peer_id);

    chatwindows[peer_id] = cw;

    connect(cw, SIGNAL(msg_input(QString,ChatWindow*)), this, SLOT(msg_to_peer(QString,ChatWindow*)));
    connect(cw, SIGNAL(chatwindow_close(ChatWindow*)), this, SLOT(chatwindow_closed(ChatWindow*)));

    cw->show();
}

void MsgUIRouter::msg_from_peer(QByteArray from, QString msg)
{
    Sound::play(snd_newmessage);

    if ( ! chatwindows.contains(from))
    {
        create_chatwindow(from);
    }

    chatwindows[from]->msg_from_peer(msg);

    if (!chatwindows[from]->isActiveWindow())
        {
            if (blinkqueue.isEmpty())
            {
                systray->StartBlinking();
                blinkqueue.append(from);
            }
            else if (blinkqueue.last() != from)
            {
                blinkqueue.append(from);
            }

        }
}

void MsgUIRouter::msg_to_peer(QString msg, ChatWindow *sender_window)
{
    skynet->SendMessage(sender_window->getPeerId(), msg);
}

void MsgUIRouter::start_chat(QByteArray peer_id)
{
    if ( ! chatwindows.contains(peer_id))
    {
        create_chatwindow(peer_id);
    }
    else
    {
        chatwindows[peer_id]->showNormal();
        chatwindows[peer_id]->activateWindow();
        chatwindows[peer_id]->raise();
    }
}

void MsgUIRouter::chatwindow_closed(ChatWindow *sender_window)
{
    chatwindows.remove(sender_window->getPeerId());
}

void MsgUIRouter::delivery_failed(QByteArray to, QString msg)
{
//  if (chatwindows.contains(to))
//  {
//    chatwindows[to]->msg_informational(tr("failed to deliver"));
//  }
}

void MsgUIRouter::delivered(QByteArray to)
{
  if (chatwindows.contains(to))
  {
    chatwindows[to]->msg_delivered();
  }
  else
  {
      History h(config_dbname, Accounts::GetCurrentAccount().id);

      h.SetDelivered(to);
  }
}

void MsgUIRouter::scary_cert_message(QByteArray peer_id, QString received_cert, QString stored_cert)
{
    ForgedCertDialog fcd(peer_id, received_cert, stored_cert);
    fcd.exec();
}

void MsgUIRouter::notification(QString text)
{
    if (mainwindow)
        mainwindow->AddNotification(text);
}