tikhomirov@463: /*
tikhomirov@463:  * Copyright (c) 2012 TMate Software Ltd
tikhomirov@463:  *  
tikhomirov@463:  * This program is free software; you can redistribute it and/or modify
tikhomirov@463:  * it under the terms of the GNU General Public License as published by
tikhomirov@463:  * the Free Software Foundation; version 2 of the License.
tikhomirov@463:  *
tikhomirov@463:  * This program is distributed in the hope that it will be useful,
tikhomirov@463:  * but WITHOUT ANY WARRANTY; without even the implied warranty of
tikhomirov@463:  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
tikhomirov@463:  * GNU General Public License for more details.
tikhomirov@463:  *
tikhomirov@463:  * For information on how to redistribute this software under
tikhomirov@463:  * the terms of a license other than GNU General Public License
tikhomirov@463:  * contact TMate Software at support@hg4j.com
tikhomirov@463:  */
tikhomirov@463: package org.tmatesoft.hg.repo.ext;
tikhomirov@463: 
tikhomirov@463: import java.io.BufferedReader;
tikhomirov@463: import java.io.File;
tikhomirov@463: import java.io.FileReader;
tikhomirov@463: import java.io.IOException;
tikhomirov@463: import java.util.Collections;
tikhomirov@463: import java.util.LinkedList;
tikhomirov@463: import java.util.List;
tikhomirov@463: 
tikhomirov@463: import org.tmatesoft.hg.core.HgInvalidControlFileException;
tikhomirov@463: import org.tmatesoft.hg.core.HgInvalidFileException;
tikhomirov@463: import org.tmatesoft.hg.core.Nodeid;
tikhomirov@463: import org.tmatesoft.hg.repo.HgInternals;
tikhomirov@463: import org.tmatesoft.hg.repo.HgRepository;
tikhomirov@463: import org.tmatesoft.hg.util.LogFacility;
tikhomirov@463: import org.tmatesoft.hg.util.Path;
tikhomirov@463: 
tikhomirov@463: /**
tikhomirov@463:  * Mercurial Queues Support. 
tikhomirov@463:  * Access to MqExtension functionality.
tikhomirov@463:  * 
tikhomirov@463:  * @author Artem Tikhomirov
tikhomirov@463:  * @author TMate Software Ltd.
tikhomirov@463:  */
tikhomirov@463: public class MqManager {
tikhomirov@463: 	
tikhomirov@463: 	private final HgRepository repo;
tikhomirov@463: 	private List<PatchRecord> applied = Collections.emptyList();
tikhomirov@463: 	private List<PatchRecord> allKnown = Collections.emptyList();
tikhomirov@463: 
tikhomirov@463: 	public MqManager(HgRepository hgRepo) {
tikhomirov@463: 		repo = hgRepo;
tikhomirov@463: 	}
tikhomirov@463: 	
tikhomirov@463: 	/**
tikhomirov@463: 	 * Updates manager with up-to-date state of the mercurial queues.
tikhomirov@463: 	 */
tikhomirov@463: 	public void refresh() throws HgInvalidControlFileException {
tikhomirov@463: 		File repoDir = HgInternals.getRepositoryDir(repo);
tikhomirov@463: 		final LogFacility log = HgInternals.getContext(repo).getLog();
tikhomirov@463: 		final File fileStatus = new File(repoDir, "patches/status");
tikhomirov@463: 		final File fileSeries = new File(repoDir, "patches/series");
tikhomirov@463: 		try {
tikhomirov@463: 			if (fileStatus.isFile()) {
tikhomirov@463: 				new LineReader(fileStatus, log).read(new LineConsumer<List<PatchRecord>>() {
tikhomirov@463: 	
tikhomirov@463: 					public boolean consume(String line, List<PatchRecord> result) throws IOException {
tikhomirov@463: 						int sep = line.indexOf(':');
tikhomirov@463: 						if (sep == -1) {
tikhomirov@463: 							log.warn(MqManager.class, "Bad line in %s:%s", fileStatus.getPath(), line);
tikhomirov@463: 							return true;
tikhomirov@463: 						}
tikhomirov@463: 						Nodeid nid = Nodeid.fromAscii(line.substring(0, sep));
tikhomirov@463: 						String name = new String(line.substring(sep+1));
tikhomirov@463: 						result.add(new PatchRecord(nid, name, Path.create(".hg/patches/" + name)));
tikhomirov@463: 						return true;
tikhomirov@463: 					}
tikhomirov@463: 				}, applied = new LinkedList<PatchRecord>());
tikhomirov@463: 			}
tikhomirov@463: 			if (fileSeries.isFile()) {
tikhomirov@463: 				new LineReader(fileSeries, log).read(new LineConsumer<List<PatchRecord>>() {
tikhomirov@463: 
tikhomirov@463: 					public boolean consume(String line, List<PatchRecord> result) throws IOException {
tikhomirov@463: 						result.add(new PatchRecord(null, line, Path.create(".hg/patches/" + line)));
tikhomirov@463: 						return true;
tikhomirov@463: 					}
tikhomirov@463: 				}, allKnown = new LinkedList<PatchRecord>());
tikhomirov@463: 			}
tikhomirov@463: 		} catch (HgInvalidFileException ex) {
tikhomirov@463: 			HgInvalidControlFileException th = new HgInvalidControlFileException(ex.getMessage(), ex.getCause(), ex.getFile());
tikhomirov@463: 			th.setStackTrace(ex.getStackTrace());
tikhomirov@463: 			throw th;
tikhomirov@463: 		}
tikhomirov@463: 	}
tikhomirov@463: 
tikhomirov@463: 	/**
tikhomirov@463: 	 * Subset of the patches from the queue that were already applied to the repository
tikhomirov@463: 	 * 
tikhomirov@463: 	 * <p>Clients shall call {@link #refresh()} prior to first use
tikhomirov@463: 	 * @return collection of records in no particular order, may be empty if none applied
tikhomirov@463: 	 */
tikhomirov@463: 	public List<PatchRecord> getAppliedPatches() {
tikhomirov@463: 		return Collections.unmodifiableList(applied);
tikhomirov@463: 	}
tikhomirov@463: 	
tikhomirov@463: 	/**
tikhomirov@463: 	 * All of the patches that MQ knows about for this repository
tikhomirov@463: 	 * 
tikhomirov@463: 	 * <p>Clients shall call {@link #refresh()} prior to first use
tikhomirov@463: 	 * @return collection of records in no particular order, may be empty if there are no patches in the queue
tikhomirov@463: 	 */
tikhomirov@463: 	public List<PatchRecord> getAllKnownPatches() {
tikhomirov@463: 		return Collections.unmodifiableList(allKnown);
tikhomirov@463: 	}
tikhomirov@463: 	
tikhomirov@463: 	public class PatchRecord {
tikhomirov@463: 		private final Nodeid nodeid;
tikhomirov@463: 		private final String name;
tikhomirov@463: 		private final Path location;
tikhomirov@463: 
tikhomirov@463: 		PatchRecord(Nodeid revision, String name, Path diffLocation) {
tikhomirov@463: 			nodeid = revision;
tikhomirov@463: 			this.name = name;
tikhomirov@463: 			this.location = diffLocation;
tikhomirov@463: 		}
tikhomirov@463: 
tikhomirov@463: 		/**
tikhomirov@463: 		 * Identifies changeset of the patch that has been applied to the repository
tikhomirov@463: 		 * 
tikhomirov@463: 		 * @return changeset revision or <code>null</code> if this patch is not yet applied
tikhomirov@463: 		 */
tikhomirov@463: 		public Nodeid getRevision() {
tikhomirov@463: 			return nodeid;
tikhomirov@463: 		}
tikhomirov@463: 
tikhomirov@463: 		/**
tikhomirov@463: 		 * Identifies patch, either based on a user-supplied name (<code>hg qnew <i>patch-name</i></code>) or 
tikhomirov@463: 		 * an automatically generated name (like <code><i>revisionIndex</i>.diff</code> for imported changesets).
tikhomirov@463: 		 * Clients shall not rely on this naming scheme, though.
tikhomirov@463: 		 * 
tikhomirov@463: 		 * @return never <code>null</code>
tikhomirov@463: 		 */
tikhomirov@463: 		public String getName() {
tikhomirov@463: 			return name;
tikhomirov@463: 		}
tikhomirov@463: 		
tikhomirov@463: 		/**
tikhomirov@463: 		 * Location of diff file with the patch, relative to repository root
tikhomirov@463: 		 * @return path to the patch, never <code>null</code>
tikhomirov@463: 		 */
tikhomirov@463: 		public Path getPatchLocation() {
tikhomirov@463: 			return location;
tikhomirov@463: 		}
tikhomirov@463: 	}
tikhomirov@463: 
tikhomirov@463: 	// TODO refine API and extract into separate classes
tikhomirov@463: 
tikhomirov@463: 	interface LineConsumer<T> {
tikhomirov@463: //		boolean begin(File f, T paramObj) throws IOException;
tikhomirov@463: 		boolean consume(String line, T paramObj) throws IOException;
tikhomirov@463: //		boolean end(File f, T paramObj) throws IOException;
tikhomirov@463: 	}
tikhomirov@463: 	
tikhomirov@463: 	class LineReader {
tikhomirov@463: 		
tikhomirov@463: 		private final File file;
tikhomirov@463: 		private final LogFacility log;
tikhomirov@463: 
tikhomirov@463: 		LineReader(File f, LogFacility logFacility) {
tikhomirov@463: 			file = f;
tikhomirov@463: 			log = logFacility;
tikhomirov@463: 		}
tikhomirov@463: 
tikhomirov@463: 		<T> void read(LineConsumer<T> consumer, T paramObj) throws HgInvalidFileException {
tikhomirov@463: 			BufferedReader statusFileReader = null;
tikhomirov@463: 			try {
tikhomirov@463: //				consumer.begin(file, paramObj);
tikhomirov@463: 				statusFileReader = new BufferedReader(new FileReader(file));
tikhomirov@463: 				String line;
tikhomirov@463: 				boolean ok = true;
tikhomirov@463: 				while (ok && (line = statusFileReader.readLine()) != null) {
tikhomirov@463: 					line = line.trim();
tikhomirov@463: 					if (line.length() > 0) {
tikhomirov@463: 						ok = consumer.consume(line, paramObj);
tikhomirov@463: 					}
tikhomirov@463: 				}
tikhomirov@463: 			} catch (IOException ex) {
tikhomirov@463: 				throw new HgInvalidFileException(ex.getMessage(), ex, file);
tikhomirov@463: 			} finally {
tikhomirov@463: 				try {
tikhomirov@463: 					statusFileReader.close();
tikhomirov@463: 				} catch (IOException ex) {
tikhomirov@463: 					log.warn(MqManager.class, ex, null);
tikhomirov@463: 				}
tikhomirov@463: //				try {
tikhomirov@463: //					consumer.end(file, paramObj);
tikhomirov@463: //				} catch (IOException ex) {
tikhomirov@463: //					log.warn(MqManager.class, ex, null);
tikhomirov@463: //				}
tikhomirov@463: 			}
tikhomirov@463: 		}
tikhomirov@463: 	}
tikhomirov@463: }