package org.openecomp.dcae.apod.analytics.cdap.tca.worker;
+import co.cask.cdap.api.app.ApplicationSpecification;
import co.cask.cdap.api.worker.WorkerConfigurer;
import co.cask.cdap.api.worker.WorkerContext;
import org.junit.Before;
import org.junit.Test;
+import org.mockito.Mockito;
import org.openecomp.dcae.apod.analytics.cdap.common.CDAPComponentsConstants;
import org.openecomp.dcae.apod.analytics.cdap.common.exception.CDAPSettingsException;
import org.openecomp.dcae.apod.analytics.cdap.tca.BaseAnalyticsCDAPTCAUnitTest;
private WorkerConfigurer workerConfigurer;
private WorkerContext workerContext;
private TCADMaaPPublisherWorker publisherWorker;
+ private ApplicationSpecification mockApplicationSpecification;
@Before
public void before() throws Exception {
workerContext = mock(WorkerContext.class);
doNothing().when(workerConfigurer).setName(anyString());
doNothing().when(workerConfigurer).setDescription(anyString());
+ mockApplicationSpecification = Mockito.mock(ApplicationSpecification.class);
+ when(workerContext.getApplicationSpecification()).thenReturn(mockApplicationSpecification);
publisherWorker = new TCADMaaPPublisherWorker(VES_ALERTS_TABLE_NAME);
}
@Test(expected = CDAPSettingsException.class)
public void testInitializeWhenSettingsHaveErrors() throws Exception {
+ when(mockApplicationSpecification.getConfiguration()).thenReturn("{}");
publisherWorker.initialize(workerContext);
}
@Test
public void testInitializeWhenSettingsAreValid() throws Exception {
when(workerContext.getRuntimeArguments()).thenReturn(getPreferenceMap());
+ when(mockApplicationSpecification.getConfiguration()).thenReturn(fromStream(TCA_APP_CONFIG_FILE_LOCATION));
publisherWorker.initialize(workerContext);
}