multicast_server.h

Go to the documentation of this file.

// Copyright (C) 2013-2020 iFunFactory Inc. All Rights Reserved.
//
// This work is confidential and proprietary to iFunFactory Inc. and
// must not be used, disclosed, copied, or distributed without the prior
// consent of iFunFactory Inc.

#ifndef INCLUDE_FUNAPI_SERVICE_MULTICAST_SERVER_H_
#define INCLUDE_FUNAPI_SERVICE_MULTICAST_SERVER_H_

#include <boost/unordered_map.hpp>
#include <funapi/common/json.h>
#include <funapi/types.h>


namespace fun {

typedef Uuid SessionId;
class Session;


class FUNAPI_DLL_VISIBILITY MulticastServer {
 public:
  typedef function<
      bool(const string & /*channel*/,
           const string & /*sender*/,
           const Ptr<Session> & /*session*/,
           Json * /*message*/)> JsonMessageChecker;
  typedef function<
      bool(const string & /*channel*/,
           const string & /*sender*/,
           const Ptr<Session> & /*session*/,
           const Ptr<FunMessage> & /*message*/)> ProtobufMessageChecker;

  typedef function<
      void(const string & /*channel*/,
           const string & /*sender*/,
           const SessionId & /*session_id*/,
           const Json & /*message*/)> JsonMessageHook;
  typedef function<
      void(const string & /*channel*/,
           const string & /*sender*/,
           const SessionId & /*session_id*/,
           const Ptr<const FunMessage> & /*message*/)> ProtobufMessageHook;

  static void InstallJsonMessageChecker(
      const JsonMessageChecker &json_message_checker);

  static void InstallProtobufMessageChecker(
      const ProtobufMessageChecker &protobuf_message_checker);

  static void InstallJsonMessageHook(const JsonMessageHook &hook);

  static void InstallProtobufMessageHook(const ProtobufMessageHook &hook);
};


typedef boost::unordered_map<string /*channel*/,
                             string /*token*/> MulticastChannelTokenMap;

struct MulticastChannelInfo {
  MulticastChannelInfo(const string &name_in, size_t member_count_in) {
    name = name_in;
    member_count = member_count_in;
  }

  string name;
  size_t member_count;
};

typedef std::vector<MulticastChannelInfo> MulticastChannelInfoVector;

// Creates a server-side multicast channel.
// This function must be called on both the game server and the multicast server.
FUNAPI_DLL_VISIBILITY
void CreateMulticastChannel(const string &channel, const string &token);

// Gets a server-side multicast channel.
FUNAPI_DLL_VISIBILITY
bool GetMulticastChannel(const string &channel, string *out_token);

// Gets the server-side multicast channels.
FUNAPI_DLL_VISIBILITY
size_t GetMulticastChannelTokenMap(MulticastChannelTokenMap *out);

// Disallows to create a client-side multicast channel.
FUNAPI_DLL_VISIBILITY
void DisallowToCreateClientsideMulticastChannel();

FUNAPI_DLL_VISIBILITY
void GetGlobalMulticastChannels(MulticastChannelInfoVector *out);

}  // namespace fun

#endif  // INCLUDE_FUNAPI_SERVICE_MULTICAST_SERVER_H_