package org.apache.continuum.distributed.transport.master;
   
   /*
    * Licensed to the Apache Software Foundation (ASF) under one
    * or more contributor license agreements.  See the NOTICE file
    * distributed with this work for additional information
    * regarding copyright ownership.  The ASF licenses this file
    * to you under the Apache License, Version 2.0 (the
    * "License"); you may not use this file except in compliance
   * with the License.  You may obtain a copy of the License at
   *
   *   http://www.apache.org/licenses/LICENSE-2.0
   *
   * Unless required by applicable law or agreed to in writing,
   * software distributed under the License is distributed on an
   * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
   * KIND, either express or implied.  See the License for the
   * specific language governing permissions and limitations
   * under the License.
   */
  
  import org.apache.continuum.builder.distributed.DistributedBuildService;
  import org.apache.continuum.distributed.commons.utils.ContinuumDistributedUtil;
  import org.slf4j.Logger;
  import org.slf4j.LoggerFactory;
  
  import java.util.Map;
  
  /**
   * MasterBuildAgentTransportServer
   */
  public class MasterBuildAgentTransportServer
      implements MasterBuildAgentTransportService
  {
      private static final Logger log = LoggerFactory.getLogger( MasterBuildAgentTransportServer.class );
  
      private final DistributedBuildService distributedBuildService;
  
      public MasterBuildAgentTransportServer( DistributedBuildService distributedBuildService )
      {
          this.distributedBuildService = distributedBuildService;
      }
  
      public Boolean returnBuildResult( Map<String, Object> buildResult, String buildAgentUrl )
          throws Exception
      {
          distributedBuildService.updateBuildResult( buildResult );
          log.info( "Project {} build finished in build agent {}. Returned build result.",
                    ContinuumDistributedUtil.getProjectNameAndId( buildResult ), buildAgentUrl );
          return Boolean.TRUE;
      }
  
      public Boolean ping()
          throws Exception
      {
          log.debug( "Ping master ok" );
  
          return Boolean.TRUE;
      }
  
      public Boolean prepareBuildFinished( Map<String, Object> prepareBuildResult, String buildAgentUrl )
          throws Exception
      {
          distributedBuildService.prepareBuildFinished( prepareBuildResult );
          log.info( "Prepare build finished for project {} in build agent {}",
                    ContinuumDistributedUtil.getProjectNameAndId( prepareBuildResult ), buildAgentUrl );
          return Boolean.TRUE;
      }
  
      public Boolean startProjectBuild( Integer projectId, String buildAgentUrl )
          throws Exception
      {
          distributedBuildService.startProjectBuild( projectId );
          log.info( "Start building project (projectId={}) in build agent {}.", projectId, buildAgentUrl );
          return Boolean.TRUE;
      }
  
      public Boolean startPrepareBuild( Map<String, Object> prepareBuildResult, String buildAgentUrl )
          throws Exception
      {
          distributedBuildService.startPrepareBuild( prepareBuildResult );
          log.info( "Start preparing build of project {} in build agent {}", ContinuumDistributedUtil.getProjectNameAndId(
              prepareBuildResult ), buildAgentUrl );
          return Boolean.TRUE;
      }
  
      public Map<String, String> getEnvironments( Integer buildDefinitionId, String installationType )
          throws Exception
      {
          Map<String, String> envs = distributedBuildService.getEnvironments( buildDefinitionId, installationType );
          log.debug( "Retrieving environments buildDefinitionId={}, installationType={}",
                     new Object[]{buildDefinitionId, installationType} );
          return envs;
      }
  
      public Boolean updateProject( Map<String, Object> project )
          throws Exception
      {
          distributedBuildService.updateProject( project );
         log.debug( "Start updating project {}", ContinuumDistributedUtil.getProjectNameAndId( project ) );
         return Boolean.TRUE;
     }
 
     public Boolean shouldBuild( Map<String, Object> context, String buildAgentUrl )
         throws Exception
     {
         log.debug( "Checking if project {} should build in build agent {}",
                    ContinuumDistributedUtil.getProjectNameAndId( context ), buildAgentUrl );
         return distributedBuildService.shouldBuild( context );
     }
 }