ТЕСТИРУЕМ ЧАТИК ДА

// ScorpioT1000 (c) 2013
library scmessaging uses scnetwork, sclogichandler


hashtable mesCurrentMessage
string mesPendingKey = null
bool mesIsPending = true
string mesOutgoingK[]
string mesOutgoingV[]
int mesOutgoingN = 0

string GetClientToServerFilename() {
    return coreDomainCurrent+"\\warcraft-server\\sessions\\c2s_"+accountName+sesssionDelim+sessionId+​".j";
}

string GetServerToClientFilename() {
    return coreDomainCurrent+"\\warcraft-server\\sessions\\s2c_"+accountName+sesssionDelim+sessionId+​".j";
}

// executed by Preloader
void PushMessageKey() {
    mesPendingKey = GetPlayerName(Player(15));
}

// executed by Preloader
void PushMessageValue() {
    if(mesPendingKey != null) {
        SaveStr(mesCurrentMessage,0,StringHash(mesPendingKey),GetPlayerName(Player(15)));
        mesPendingKey = null
    }
}

// executed by Preloader
void FinishMessage() {
    mesIsPending = false
}

// get received message value by key as a string 
string GetMessageValue(string byKey) { 
    return LoadStr(mesCurrentMessage,0,StringHash(byKey));
}
// get received message value by key as an int
int GetMessageValueInt(string byKey) {
    return S2I(LoadStr(mesCurrentMessage,0,StringHash(byKey)));
}
// get received message value by key as a float
float GetMessageValueFloat(string byKey) {
    return S2R(LoadStr(mesCurrentMessage,0,StringHash(byKey)));
}

// add key and value to the outgoing message
void PushOutgoingField(string k, string v) {
    if(mesOutgoingN > 8190) { return; }
    mesOutgoingK[mesOutgoingN] = k;
    mesOutgoingV[mesOutgoingN] = v;
    mesOutgoingN++;
}

// sender - receiver

timer mesReceiverTimer = null
timer mesSenderTimer = null
float mesReceiverTimerPeriod = 2
float mesSenderTimerPeriod = 2.2

// clear incoming message cache
void ClearMessage() {
    FlushChildHashtable(mesCurrentMessage,0);
    mesIsPending = true;
}

// reveive incoming message if it's ready (pending) and load into cache
bool ReceiveMessage() {
    if(mesIsPending) { return false; }
    Preloader(coreDomainCurrent+coreDestinationAddress);
    return true;
}

// clear outgoing message cache
void ClearOutgoing() { mesOutgoingN = 0; }

// send outgoing message from cache
void SendMessage() {
    int i=0;
    if(mesOutgoingN > 0) {
        PreloadGenClear();
        PreloadGenStart();
        Preload("\" ScCommunicatorServer {");
        while(i < mesOutgoingN) {
            Preload("\";"+mesOutgoingK[i]+" = "+mesOutgoingV[i]+";");
        }
        Preload("\"}");
        PreloadGenEnd(GetServerToClientFilename());
    }
}

// periodically recieves messages
void ReceiveHandler() {
    if(ReceiveMessage()) { // receive only if finished
        HandleLogic(mesCurrentMessage);
        ClearMessage();
    }
}

// periodically sends messages
void SendHandler() {
    SendMessage();  // send only if finished
    ClearOutgoing();
}

// start (or restart) messaging system
void StartSenderReceiver() {
    if(mesReceiverTimer == null) { 
        LocalMsg("StartSenderReceiver: error, messaging is not initialized"); 
        return; 
    }
    PauseTimer(mesReceiverTimer);
    PauseTimer(mesSenderTimer);
    ClearMessage();
    ClearOutgoing();
    TimerStart(mesReceiverTimer, mesReceiverTimerPeriod, true, function ReceiveHandler);
    TimerStart(mesSenderTimer, mesSenderTimerPeriod, true, function SendHandler);
}



void InitMessaging() {
    mesCurrentMessage = InitHashtable();
    mesReceiverTimer = CreateTimer();
    mesSenderTimer = CreateTimer();
    StartSenderReceiver();
    LocalMsg("Messaging system initialized");
}

endlibrary // ScorpioT1000 (c) 2013

    static bool SaveFileForWarcraft(const Options & src, const std::wstring & dst) {
        ptrdiff_t f = Environment::CreateUtf8File(dst);
        if(!f) { 
            Environment::Warning(L"Cannot create, check the folder rights: "+dst);
            return false; 
        }
        Environment::WriteStringToUtf8File(f,L"function PreloadFiles takes nothing returns nothing");
        for(OptionsConstIterator it = src.GetRawData().begin(); it != src.GetRawData().end(); ++it) {
            Environment::WriteStringToUtf8File(f,L"call SetPlayerName(Player(15),\""+it->first+L"\")");
            Environment::WriteStringToUtf8File(f,L"call ExecuteFunc(\"PushMessageKey\"");
            Environment::WriteStringToUtf8File(f,L"call SetPlayerName(Player(15),\""+it->second+L"\")");
            Environment::WriteStringToUtf8File(f,L"call ExecuteFunc(\"PushMessageValue\"");
        }
        Environment::WriteStringToUtf8File(f,L"call ExecuteFunc(\"FinishMessage\"");
        Environment::WriteStringToUtf8File(f,L"endfunction");
    }