package net.brutex.xservices.ws.rs;

import java.io.File;
import java.util.ArrayList;
import java.util.List;
import java.util.StringTokenizer;

import javax.ws.rs.core.GenericEntity;
import javax.ws.rs.core.HttpHeaders;
import javax.ws.rs.core.Response;

import org.apache.commons.configuration.ConfigurationException;
import org.apache.jcs.JCS;
import org.apache.jcs.access.exception.CacheException;
import org.apache.log4j.Logger;
import org.netbeans.lib.cvsclient.Client;
import org.netbeans.lib.cvsclient.command.CommandAbortedException;
import org.netbeans.lib.cvsclient.command.CommandException;
import org.netbeans.lib.cvsclient.command.checkout.CheckoutCommand;
import org.netbeans.lib.cvsclient.command.checkout.ModuleListInformation;
import org.netbeans.lib.cvsclient.command.log.LogInformation;
import org.netbeans.lib.cvsclient.command.log.RlogCommand;
import org.netbeans.lib.cvsclient.connection.AuthenticationException;
import org.netbeans.lib.cvsclient.event.FileInfoEvent;

import net.brutex.xservices.types.scm.ModuleType;
import net.brutex.xservices.types.scm.FileType;
import net.brutex.xservices.types.scm.Revision;
import net.brutex.xservices.util.BasicCVSListener;
import net.brutex.xservices.util.CVSClient;

/**
 * @author Brian Rosenberger
 * @since 0.5.0-20120824
 * 
 */
public class CVSInfoImpl implements CVSInfo {
	
	final Logger logger = Logger.getLogger(CVSInfoImpl.class);

	public Response getRepositoryFiles(HttpHeaders h, File f, String modules,
			boolean showRevisions,
			boolean forceNoCache) {

		final List<FileType> list = new ArrayList<FileType>();

		String cachekey = "getFiles" + f.toURI().toString();
		logger.debug("forceNoCache="+forceNoCache);
		List<FileType> cacheresult = (List<FileType>) getCacheInstance().get(
				cachekey);

		if (!forceNoCache && cacheresult != null) {
			// Cache hit
			list.addAll(cacheresult);
		} else {
			// Cache miss
			try {
				CVSClient cvsclient = new CVSClient(f);
				Client client = cvsclient.client;

				client.getEventManager().addCVSListener(new BasicCVSListener() {
					@Override
					public void fileInfoGenerated(FileInfoEvent arg0) {
						LogInformation info = (LogInformation) arg0
								.getInfoContainer();
						FileType cvsfile = new FileType(info.getFile(), info
								.getRepositoryFilename(), info.getDescription());
						cvsfile.setHeadRevision(info.getHeadRevision());
						cvsfile.setBranch(info.getBranch());
						cvsfile.setTotalRevisions(info.getTotalRevisions());
						for (LogInformation.Revision r : info.getRevisionList()) {
							cvsfile.addRevision(new Revision(r.getNumber(), r
									.getMessage()));
						}
						list.add(cvsfile);
					}
				});

				RlogCommand rlog = new RlogCommand();
				StringTokenizer tk = new StringTokenizer(modules, ",");
				while (tk.hasMoreTokens()) {
					rlog.setModule(tk.nextToken());
				}
				if (rlog.getModules().length == 0)
					rlog.setModule("");

				rlog.setDefaultBranch(true); // -b Print information about the
												// revisions on the default
												// branch,
												// normally the highest branch
												// on
												// the trunk.
				rlog.setNoTags(true); // -N Do not print the list of tags for
										// this
										// file. This option can be very useful
										// when
										// your site uses a lot of tags, so
										// rather
										// than "more"'ing over 3 pages of tag
										// information, the log information is
										// presented without tags at all.
				rlog.setHeaderAndDescOnly(false); // -t Print only the name of
													// the
													// rcs file, name of the
													// file in
													// the working directory,
													// head,
													// default branch, access
													// list,
													// locks, symbolic names,
													// and
													// suffix. + description
				// rlog.setRevisionFilter("1.1.");
				// rlog.setSuppressHeader(true); // -S Supress log output when
				// no
				// revisions are selected within a file.
				client.executeCommand(rlog, cvsclient.getGlobalOptions());
				logger.info("Execute CVS command '" + rlog.getCVSCommand() + "' against '"+cvsclient.getRoot().host+"@" + cvsclient.getRoot().repository+"'");
				//need to put a new list into cache as we will filter the result 
				//afterwards
				getCacheInstance().put(cachekey, new ArrayList<FileType>(list));
				
				
			} catch (ConfigurationException e) {
				logger.error("CVS Configuration File '"
						+ f.getAbsolutePath() + f.getName() + "'not found.", e);
				
			} catch (CommandAbortedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			} catch (AuthenticationException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			} catch (CommandException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			} catch (CacheException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}

		}
		
		
		// prepare output after everything is cached
		if (!showRevisions) {
			for (FileType t : list) {
				t.clearRevisionList();
			}
		}
		
		GenericEntity entity = new GenericEntity<List<FileType>>(list) {};
		return Response.ok(entity).build();
	}

	@Override
	public Response getModules(HttpHeaders h, File f, boolean forceNoCache) {

		// Try to deliver from Cache
		String cachekey = "Modules" + f.toURI().toString();
		logger.debug("forceNoCache="+forceNoCache);
		List<ModuleType> response = (List<ModuleType>) getCacheInstance().get(
				cachekey);
		if (!forceNoCache && response != null) {
			GenericEntity entity = new GenericEntity<List<ModuleType>>(response) {
			};
			return Response.ok(entity).build();
		}
		// -------------------------

		try {
			CVSClient cvsclient = new CVSClient(f);
			Client client = cvsclient.client;

			final List<ModuleType> list = new ArrayList<ModuleType>();

			client.getEventManager().addCVSListener(new BasicCVSListener() {
				public void fileInfoGenerated(FileInfoEvent e) {
					ModuleListInformation info = (ModuleListInformation) e
							.getInfoContainer();

					list.add(new ModuleType(info.getModuleName(), info
							.getModuleStatus(), info.getPaths(), info.getType()));
				}
			});

			CheckoutCommand co = new CheckoutCommand();
			co.setShowModulesWithStatus(true);

			client.executeCommand(co, cvsclient.getGlobalOptions());
			logger.info("Execute CVS command '" + co.getCVSCommand() + "' against '"+cvsclient.getRoot().host+"@" + cvsclient.getRoot().repository+"'");
			if(list.size()==0) {
				logger.warn("Repository '" + cvsclient.getRoot().repository + "' does not have modules");
				list.add(new ModuleType("","","",""));
			}
			
			GenericEntity entity = new GenericEntity<List<ModuleType>>(list) {
			};
			getCacheInstance().put(cachekey, list);
			return Response.ok(entity).build();
		} catch (Exception e) {
			e.printStackTrace();
		}
		return Response.serverError().build();
	}

	/**
	 * Get the caching manager for CVS objects
	 * 
	 * @return The CVSCaching JCS region
	 */
	public JCS getCacheInstance() {
		JCS jcs = null;
		final String cacheinstance = "CVSCache";
		try {
			logger.debug("Getting cache instance named '"+cacheinstance+"'" );
			jcs = JCS.getInstance(cacheinstance);
		} catch (CacheException e) {
			logger.error("Failed to get cache instance", e);
			e.printStackTrace();
		}
		return jcs;
	}

}