package com.trendmicro.grid.acl.ds.dummy;
   
   import com.trendmicro.grid.acl.commons.Paths;
   import com.trendmicro.grid.acl.commons.XmlSerializer;
   import com.trendmicro.grid.acl.ds.ProcessingInitiator;
   import com.trendmicro.grid.acl.ds.ProcessingResultReceiver;
   import com.trendmicro.grid.acl.l0.datatypes.ProcessPackageDataSet;
   import org.springframework.stereotype.Service;
   
  import javax.annotation.PostConstruct;
  import javax.xml.bind.annotation.XmlType;
  import java.io.File;
  import java.util.Collection;
  
  /**
   * Implements initiator and receiver as dummy services storing everything inside the file path.
   *
   * @author juergen_kellerer, 2010-05-18
   * @version 1.0
   */
  @Service
  public class DummyProcessingImplementation implements ProcessingResultReceiver, ProcessingInitiator {
  
  	private static final XmlSerializer<ProcessPackageDataSet> xmlSerializer =
  			new XmlSerializer<ProcessPackageDataSet>(
  					ProcessPackageDataSet.class,
  					ProcessPackageDataSet.class.getAnnotation(XmlType.class).namespace(),
  					"process-dataset");
  
  	File storagePath;
  
  	@PostConstruct
  	private void init() {
  		storagePath = new File(Paths.getResourcePath(), "dummy-processing-store");
  		if (!storagePath.isDirectory())
  			storagePath.mkdir();
  	}
  
  	/**
  	 * {@inheritDoc}
  	 */
  	public void receive(Collection<ProcessPackageDataSet> dataSets) {
  		try {
  			for (ProcessPackageDataSet dataSet : dataSets) {
  				xmlSerializer.save(dataSet,
  						new File(storagePath, "received-" + dataSet.getReferringJob() + ".xml"), false, 4);
  			}
  		} catch (Exception e) {
  			throw new RuntimeException(e);
  		}
  	}
  
  	/**
  	 * {@inheritDoc}
  	 */
  	public void checkpoint() {
  		// not required here
  	}
  
  	/**
  	 * {@inheritDoc}
  	 */
  	public void initiate(ProcessPackageDataSet dataSet) {
  		try {
  			xmlSerializer.save(dataSet,
  					new File(storagePath, "initiated-" + dataSet.getReferringJob() + ".xml"), false, 4);
  		} catch (Exception e) {
  			throw new RuntimeException(e);
  		}
  	}
  }