/*******************************************************************************
 *
 * Pentaho Big Data
 *
 * Copyright (C) 2002-2016 by Pentaho : http://www.pentaho.com
 *
 *******************************************************************************
 *
 * Licensed 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.
 *
 ******************************************************************************/

package org.pentaho.big.data.impl.shim.sqoop;

import org.junit.Before;
import org.junit.Test;
import org.pentaho.big.data.api.cluster.NamedCluster;
import org.pentaho.bigdata.api.sqoop.SqoopService;
import org.pentaho.hadoop.shim.ConfigurationException;
import org.pentaho.hadoop.shim.HadoopConfiguration;

import static org.junit.Assert.*;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;

/**
 * Created by bryan on 2/26/16.
 */
public class SqoopServiceFactoryImplTest {
  private boolean isActiveConfiguration;
  private HadoopConfiguration hadoopConfiguration;
  private SqoopServiceFactoryImpl sqoopServiceFactory;
  private NamedCluster namedCluster;

  @Before
  public void setup() {
    isActiveConfiguration = true;
    hadoopConfiguration = mock( HadoopConfiguration.class );
    sqoopServiceFactory = new SqoopServiceFactoryImpl( isActiveConfiguration, hadoopConfiguration );
    namedCluster = mock( NamedCluster.class );
  }

  @Test
  public void testCanHandle() {
    assertTrue( sqoopServiceFactory.canHandle( namedCluster ) );
    sqoopServiceFactory = new SqoopServiceFactoryImpl( false, hadoopConfiguration );
    assertFalse( sqoopServiceFactory.canHandle( namedCluster ) );
  }

  @Test
  public void testGetServiceClass() {
    assertEquals( SqoopService.class, sqoopServiceFactory.getServiceClass() );
  }

  @Test
  public void testCreateSuccess() {
    assertNotNull( sqoopServiceFactory.create( namedCluster ) );
  }

  @Test
  public void testCreateFailure() throws ConfigurationException {
    when( hadoopConfiguration.getSqoopShim() ).thenThrow( new ConfigurationException( null ) );
    assertNull( sqoopServiceFactory.create( namedCluster ) );
  }
}

@@ -125,17 +125,17 @@
 2002-201
-6
+7
  by Pent
@@ -2115,32 +2115,230 @@
 uster ) );%0A  %7D%0A%0A
+  @Test%0A  public void testCannotHandleGateway() throws Exception %7B%0A    when( namedCluster.isUseGateway() ).thenReturn( true );%0A    assertFalse( sqoopServiceFactory.canHandle( namedCluster ) );%0A  %7D%0A%0A
   @Test%0A  public

Implement the support for sqoop using HDP Knox