SYNCT-327:Enable disabling of Manual Sync to Parent and Manual Pull t…

…o Parent

api/src/main/java/org/openmrs/module/sync2/client/reader/atomfeed/impl/LocalAtomfeedFeedReaderImpl.java

@@ -4,13 +4,21 @@
 import org.openmrs.module.sync2.api.exceptions.SyncException;
 import org.openmrs.module.sync2.api.model.SyncCategory;
 import org.openmrs.module.sync2.api.model.configuration.SyncMethodConfiguration;
+import org.openmrs.module.sync2.api.service.SyncConfigurationService;
 import org.openmrs.module.sync2.client.reader.LocalFeedReader;
 import org.openmrs.module.sync2.client.reader.atomfeed.LocalAtomfeedFeedWorker;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
 @Component("sync2.localFeedReader." + SyncConstants.ATOMFEED_EVENT_HANDLER)
 public class LocalAtomfeedFeedReaderImpl extends AbstractAtomfeedFeedReader implements LocalFeedReader {
-
+	@Autowired
+	private SyncConfigurationService syncConfigurationService;
+
+    private boolean enabled() {
+        return syncConfigurationService.getSyncConfiguration().getWhitelist().isEnabled();
+    }
+
 	public LocalAtomfeedFeedReaderImpl() {
 		super(new LocalAtomfeedFeedWorker());
 	}
@@ -27,11 +35,17 @@ protected String getBaseUri() {
 
 	@Override
 	public void readAndPushAllFeeds() {
-		readAndProcessAllFeeds();
+		if(enabled()==true) {
+			readAndProcessAllFeeds();
+			}
+			else throw new SyncException("Sync is disabled to push Child data to parent");
 	}
 
 	@Override
 	public void readAndPushAllFeeds(SyncCategory category) throws SyncException {
-		readAndProcessFeedsForCategory(category.getCategory());
-	}
+		if(enabled()==true) {
+			readAndProcessFeedByCategory(category.getCategory());
+			}
+			else throw new SyncException("Sync is disabled to push Child data to parent");
+		}	
 }

api/src/main/java/org/openmrs/module/sync2/client/reader/atomfeed/impl/ParentAtomfeedFeedReaderImpl.java

@@ -4,13 +4,21 @@
 import org.openmrs.module.sync2.api.exceptions.SyncException;
 import org.openmrs.module.sync2.api.model.SyncCategory;
 import org.openmrs.module.sync2.api.model.configuration.SyncMethodConfiguration;
+import org.openmrs.module.sync2.api.service.SyncConfigurationService;
 import org.openmrs.module.sync2.client.reader.ParentFeedReader;
 import org.openmrs.module.sync2.client.reader.atomfeed.ParentAtomfeedFeedWorker;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 @Service("sync2.parentFeedReader." + SyncConstants.ATOMFEED_EVENT_HANDLER)
 public class ParentAtomfeedFeedReaderImpl extends AbstractAtomfeedFeedReader implements ParentFeedReader {
-
+	@Autowired
+	private SyncConfigurationService syncConfigurationService;
+
+    public boolean enabled() {
+        return syncConfigurationService.getSyncConfiguration().getWhitelist().isEnabled();
+    }
+
 	public ParentAtomfeedFeedReaderImpl() {
 		super(new ParentAtomfeedFeedWorker());
 	}
@@ -27,11 +35,19 @@ protected String getBaseUri() {
 
 	@Override
 	public void pullAndProcessAllFeeds() {
+
+		if(enabled()==true) {
 		readAndProcessAllFeeds();
+		}	
+		else throw new SyncException("Sync is disabled to pull parent data to Child");
+
 	}
 
 	@Override
 	public void pullAndProcessFeeds(SyncCategory category) throws SyncException {
+		if(enabled()==true) {
 		readAndProcessFeedByCategory(category.getCategory());
+		}
+		else throw new SyncException("Sync is disabled to pull parent data to Child");
 	}
 }

api/src/test/java/org/openmrs/module/sync2/api/service/impl/atomfeed/LocalAtomfeedFeedReaderTest.java

@@ -0,0 +1,9 @@
+package org.openmrs.module.sync2.api.service.impl.atomfeed;
+
+
+public class LocalAtomfeedFeedReaderTest {
+
+public void LocalAtomfeedFeedReader_shouldNotSyncIfPushIsDisabled() {
+
+	}
+}

api/src/test/java/org/openmrs/module/sync2/api/service/impl/atomfeed/ParentAtomfeedFeedReaderTest.java

@@ -0,0 +1,37 @@
+package org.openmrs.module.sync2.api.service.impl.atomfeed;
+
+import static org.powermock.api.mockito.PowerMockito.doReturn;
+
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.MockitoAnnotations;
+import org.mockito.runners.MockitoJUnitRunner;
+import org.openmrs.module.sync2.api.exceptions.SyncException;
+import org.openmrs.module.sync2.api.service.SyncConfigurationService;
+import org.openmrs.module.sync2.api.service.impl.SyncConfigurationServiceImpl;
+import org.openmrs.module.sync2.client.reader.atomfeed.impl.ParentAtomfeedFeedReaderImpl;
+
+@RunWith(MockitoJUnitRunner.class)
+public class ParentAtomfeedFeedReaderTest {
+
+	@InjectMocks
+	private ParentAtomfeedFeedReaderImpl parentAtomfeedFeedReaderImpl;
+
+	@Mock
+	private SyncConfigurationService sync2ConfigurationService;
+
+	@Before
+	public void setUp() throws SyncException {
+		sync2ConfigurationService = new SyncConfigurationServiceImpl();
+		MockitoAnnotations.initMocks(this);
+		doReturn("false").when(sync2ConfigurationService).getSyncConfiguration().getWhitelist().isEnabled();
+	}
+
+	@Test
+	public void ParentAtomfeedFeedReader_shouldNotSyncIfPullIsDisabled() throws SyncException {
+		parentAtomfeedFeedReaderImpl.pullAndProcessAllFeeds();
+	}
+}