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)
  {
    //GetGame().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);
    }
    //GetGame().ProfilerStop("UnsubscribeAll");
  }
}