behaviour.h

Go to the documentation of this file.

/*
 * Copyright Paul Reimer, 2018
 *
 * This work is licensed under the Creative Commons Attribution-NonCommercial-ShareAlike 4.0 Unported License.
 * To view a copy of this license, visit
 * https://creativecommons.org/licenses/by-nc-sa/4.0/
 * or send a letter to
 * Creative Commons, 444 Castro Street, Suite 900, Mountain View, California, 94041, USA.
 */

#pragma once

#include "mailbox.h"
#include "pid.h"
#include "uuid.h"

#include "actor_model_generated.h"

#include "delegate.hpp"

#include <memory>
#include <string>
#include <vector>

namespace ActorModel {

using State = void;
using StatePtr = std::shared_ptr<State>;

struct ResultUnion
{
  ResultUnion(
    const Result& _type = Result::Unhandled,
    const EventTerminationAction& _action = EventTerminationAction::ContinueProcessing,
    const std::string& _reason = "normal"
  )
  : type(_type)
  , action(_action)
  , reason(_reason)
  {}

  ResultUnion(
    const Result& _type,
    const std::string& _reason
  )
  : ResultUnion{
    _type,
    EventTerminationAction::StopProcessing,
    _reason
  }
  {}

  ResultUnion(
    const Result& _type,
    const UUID::UUID& _id,
    const EventTerminationAction& _action = EventTerminationAction::ContinueProcessing
  )
  : type(_type)
  , action(_action)
  , id(_id)
  {}

  Result type;
  EventTerminationAction action;
  std::string reason;
  UUID::UUID id = UUID::NullUUID;
};

using ActorBehaviour = delegate<ResultUnion(
  const Pid&,
  StatePtr& state,
  const Message&
)>;

using ActorBehaviours = std::vector<ActorBehaviour>;

using Behaviour = delegate<ResultUnion(
  const Pid&,
  Mailbox&
)>;

} // namespace ActorModel