class InputConnector @Inject() (
    nodeMap: NodeMap,
    complexNeedRepo: ComplexNeedRepo,
    articleGenerator: ArticleGenerator,
    doerRepo: DoerRepo
  ) extends Actor with ActorLogging {

  /**
   * Forward messages from transport to destination actor
   * @since 27.06.12 15:26
   * @author kulikov
   */
  def receive = {
    case msg: AddNode ⇒ nodeMap ! msg
    case msg: AddRouteTemplate ⇒ nodeMap ! msg
    case msg: AddComplexNeed ⇒ complexNeedRepo ! msg
    case msg: GenerateArticle ⇒ articleGenerator ! msg
    case msg: AddDoer ⇒ doerRepo ! msg
    case msg: ForwardToDoer ⇒ doerRepo ! msg

    case x ⇒ log.error("Unknown message {} in InputConnector", x)
  }
}



/********************* - **** - **** - *************************/


trait InputConnectorComponent {
  this: IActorSystemComponent
    with INodeMapComponent
    with ComplexNeedRepoComponent
    with DoerRepoComponent
    with ArticleGeneratorComponent ⇒

  lazy val inputConnector = actorSystem.actorOf(Props(new ActorInputConnector), name = "input-connector")

  class ActorInputConnector extends Actor with ActorLogging {

    /**
     * Forward messages from transport to destination actor
     * @since 27.06.12 15:26
     * @author kulikov
     */
    def receive = {
      case msg: AddNode ⇒ nodeMap ! msg
      case msg: AddRouteTemplate ⇒ nodeMap ! msg
      case msg: AddComplexNeed ⇒ complexNeedRepo ! msg
      case msg: GenerateArticle ⇒ articleGenerator ! msg
      case msg: AddDoer ⇒ doerRepo ! msg
      case msg: ForwardToDoer ⇒ doerRepo ! msg

      case x ⇒ log.error("Unknown message {} in InputConnector", x)
    }
  }
}