pluginmessagemanager.c

Go to the documentation of this file.

class PluginMessageManager extends PluginBase
{
    int channelsUsed = 0;
    ref array<ref MessageReceiverBase>  channelList[NUM_OF_CHANNELS];
    
    void PluginMessageManager()
    {
        for (int i = 0; i < NUM_OF_CHANNELS; i++)
        {
            channelList[i] = new array<ref MessageReceiverBase>;
        }
    }

    void Broadcast(int index)
    {
        //Debug.Log("Broadcasting message on a channel: "+ ToString(index), "Messaging System");
        array<ref MessageReceiverBase> x = channelList[index];
        //int test = channelList[index].Count();
        for(int i = 0; i < x.Count(); i++)
        {
            MessageReceiverBase mrb = x.Get(i);
            
            if( mrb != NULL )
            {
                //string s = "Broadcasting message to: "+ToString(mrb);
                //Log(s, LogTemplates.TEMPLATE_BROADCAST);
                mrb.OnReceive(index);
            }
        }
    }

    void BroadcastInt(int index, int value)
    {
        //Debug.Log("Broadcasting message on a channel: "+ ToString(index), "Messaging System");
        array<ref MessageReceiverBase> x = channelList[index];
        //int test = channelList[index].Count();
        for(int i = 0; i < x.Count(); i++)
        {
            MessageReceiverBase mrb = x.Get(i);
            
            if( mrb )
            {
                //string s = "Broadcasting message to: "+ToString(mrb);
                //Log(s, LogTemplates.TEMPLATE_BROADCAST);
                mrb.OnReceiveInt(index, value);
            }
            
        }
    }
 
    void BroadcastFloat(int index, float value)
    {
        //Debug.Log("Broadcasting message on a channel: "+ ToString(index), "Messaging System");
        array<ref MessageReceiverBase> x = channelList[index];
        //int test = channelList[index].Count();
        for(int i = 0; i < x.Count(); i++)
        {
            MessageReceiverBase mrb = x.Get(i);
            
            if( mrb )
            {
                //string s = "Broadcasting message to: "+ToString(mrb);
                //Log(s, LogTemplates.TEMPLATE_BROADCAST);
                mrb.OnReceiveFloat(index, value);
            }
            
        }
    }
 
    void BroadcastString(int index, string value)
    {
        //Debug.Log("Broadcasting message on a channel: "+ ToString(index), "Messaging System");
        array<ref MessageReceiverBase> x = channelList[index];
        //int test = channelList[index].Count();
        for(int i = 0; i < x.Count(); i++)
        {
            if( x.Get(i) )
            {
                Print("broadcasting message to: ");
                Print(x.Get(i));
                x.Get(i).OnReceiveString(index, value);
            }
        }
    }

    void BroadcastParam(int index, Param params)
    {
        //Debug.Log("Broadcasting message on a channel: "+ ToString(index), "Messaging System");
        array<ref MessageReceiverBase> x = channelList[index];
        //int test = channelList[index].Count();
        for(int i = 0; i < x.Count(); i++)
        {
        
            if( x.Get(i) )
            {
                x.Get(i).OnReceiveParam(index, params);
            }
            
        }
    }
    
    void Subscribe(MessageReceiverBase receiver, int index)
    {
        if(index > channelsUsed) //this is used to speed up the unsubscribeAll method, instead of all channels, we sweep just those in usage
        {
            channelsUsed = index;
        }
        array<ref MessageReceiverBase> chan = channelList[index];
        if( chan.Find(receiver) >= 0 ) return;
        chan.Insert(receiver);
    }
 
    void Unsubscribe(MessageReceiverBase receiver, int index)
    {
        array<ref MessageReceiverBase> chan = channelList[index];
        int i = chan.Find(receiver);
        if( i >= 0 )
        {
            chan.Remove(i);
        }
    }
    
    void UnsubscribeAll(MessageReceiverBase receiver)//REWORK.V: this is slow, should be made quicker(by registering all subscribers in a separate array upon their subscription and then going through this array instead)
    {
        //g_Game.ProfilerStart("UnsubscribeAll");
        for (int i = 0; i <= channelsUsed; i++)
        {
            array<ref MessageReceiverBase> chan = channelList[i];
            int c = chan.Find(receiver);
            if( c >= 0 )
            {
                chan.Remove(c);
            }
        }
        //g_Game.ProfilerStop("UnsubscribeAll");
    }
}