/*
    * #%L
    * bitrepository-access-client
    * *
    * $Id$
    * $HeadURL$
    * %%
    * Copyright (C) 2010 - 2011 The State and University Library, The Royal Library and The State Archives, Denmark
    * %%
   * This program is free software: you can redistribute it and/or modify
   * it under the terms of the GNU Lesser General Public License as 
   * published by the Free Software Foundation, either version 2.1 of the 
   * License, or (at your option) any later version.
   * 
   * This program is distributed in the hope that it will be useful,
   * but WITHOUT ANY WARRANTY; without even the implied warranty of
   * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
   * GNU General Lesser Public License for more details.
   * 
   * You should have received a copy of the GNU General Lesser Public 
   * License along with this program.  If not, see
   * <http://www.gnu.org/licenses/lgpl-2.1.html>.
   * #L%
   */
  package org.bitrepository.pillar.referencepillar.messagehandler;
  
  import java.util.ArrayList;
  import java.util.List;
  
  import org.bitrepository.common.filestore.FileStore;
  import org.bitrepository.pillar.common.MessageHandlerContext;
  import org.bitrepository.pillar.common.PillarMediator;
  import org.bitrepository.pillar.referencepillar.archive.ReferenceChecksumManager;
  import org.bitrepository.protocol.messagebus.MessageBus;
  import org.bitrepository.service.contributor.handler.GetAuditTrailsRequestHandler;
  import org.bitrepository.service.contributor.handler.GetStatusRequestHandler;
  import org.bitrepository.service.contributor.handler.IdentifyContributorsForGetAuditTrailsRequestHandler;
  import org.bitrepository.service.contributor.handler.IdentifyContributorsForGetStatusRequestHandler;
  import org.bitrepository.service.contributor.handler.RequestHandler;
  
  /**
   * This instance handles the conversations for the reference pillar.
   * It only responds to requests. It does not it self start conversations, though it might send Alarms when something 
   * is not right.
   * All other messages than requests are considered garbage.
   * Every message (even garbage) is put into the audit trails.
   */
  public class ReferencePillarMediator extends PillarMediator {
      /**
       * The archive for this pillar mediator.
       */
      private final FileStore archives;
      /** The manager of the checksums.*/
      private final ReferenceChecksumManager csManager;
      
      /**
       * Constructor.
       * @param messageBus The message bus to listen to.
       * @param context The context for the pillar.
       * @param archives The manager of the archives with regards to the collection ids.
       * @param manager The manager of checksums.
       */
      public ReferencePillarMediator(MessageBus messageBus, MessageHandlerContext context, 
              FileStore archives, ReferenceChecksumManager manager) {
          super(messageBus, context);
          this.archives = archives;
          this.csManager = manager;
      }
  
      @SuppressWarnings("rawtypes")
      @Override
      protected RequestHandler[] createListOfHandlers() {
          List<RequestHandler> handlers = new ArrayList<RequestHandler>();
          
          handlers.add(new IdentifyPillarsForGetFileRequestHandler(context, archives, csManager));
          handlers.add(new GetFileRequestHandler(context, archives, csManager));
          handlers.add(new IdentifyPillarsForGetFileIDsRequestHandler(context, archives, csManager));
          handlers.add(new GetFileIDsRequestHandler(context, archives, csManager));
          handlers.add(new IdentifyPillarsForGetChecksumsRequestHandler(context, archives, csManager));
          handlers.add(new GetChecksumsRequestHandler(context, archives, csManager));
          
          handlers.add(new IdentifyContributorsForGetStatusRequestHandler(getContext()));
          handlers.add(new GetStatusRequestHandler(getContext()));
          handlers.add(new IdentifyContributorsForGetAuditTrailsRequestHandler(getContext()));
          handlers.add(new GetAuditTrailsRequestHandler(getContext(), context.getAuditTrailManager()));
          
          handlers.add(new IdentifyPillarsForPutFileRequestHandler(context, archives, csManager));
          handlers.add(new PutFileRequestHandler(context, archives, csManager));
          handlers.add(new IdentifyPillarsForDeleteFileRequestHandler(context, archives, csManager));
          handlers.add(new DeleteFileRequestHandler(context, archives, csManager));
          handlers.add(new IdentifyPillarsForReplaceFileRequestHandler(context, archives, csManager));
          handlers.add(new ReplaceFileRequestHandler(context, archives, csManager));
          
          return handlers.toArray(new RequestHandler[handlers.size()]);
      }    
  }