hg4j: src/org/tmatesoft/hg/core/HgCloneCommand.java comparison

comparison src/org/tmatesoft/hg/core/HgCloneCommand.java @ 423:9c9c442b5f2e

Major refactoring of exception handling. Low-level API uses RuntimeExceptions, while checked are left for higher level

author	Artem Tikhomirov <tikhomirov.artem@gmail.com>
date	Fri, 23 Mar 2012 22:51:18 +0100
parents	528b6780a8bd
children	12f668401613

comparison

equal deleted inserted replaced

-:5d1cc7366d04
+:9c9c442b5f2e
 /*
-* Copyright (c) 2011 TMate Software Ltd
+* Copyright (c) 2011-2012 TMate Software Ltd
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; version 2 of the License.
 *
 import org.tmatesoft.hg.internal.DataAccess;
 import org.tmatesoft.hg.internal.DigestHelper;
 import org.tmatesoft.hg.internal.Internals;
 import org.tmatesoft.hg.repo.HgBundle;
 import org.tmatesoft.hg.repo.HgBundle.GroupElement;
+import org.tmatesoft.hg.repo.HgInvalidControlFileException;
+import org.tmatesoft.hg.repo.HgInvalidFileException;
+import org.tmatesoft.hg.repo.HgInvalidStateException;
 import org.tmatesoft.hg.repo.HgLookup;
 import org.tmatesoft.hg.repo.HgRemoteRepository;
 import org.tmatesoft.hg.repo.HgRepository;
+import org.tmatesoft.hg.repo.HgRuntimeException;
 import org.tmatesoft.hg.util.CancelledException;
 import org.tmatesoft.hg.util.PathRewrite;
 /**
 * WORK IN PROGRESS, DO NOT USE
 *
 * @author Artem Tikhomirov
 * @author TMate Software Ltd.
 */
-public class HgCloneCommand {
+public class HgCloneCommand extends HgAbstractCommand<HgCloneCommand> {
 	private File destination;
 	private HgRemoteRepository srcRepo;
 	public HgCloneCommand() {
 	public HgCloneCommand source(HgRemoteRepository hgRemote) {
 		srcRepo = hgRemote;
 		return this;
 	}
-	public HgRepository execute() throws HgBadArgumentException, HgRemoteConnectionException, HgInvalidFileException, CancelledException {
+	/**
+	 *
+	 * @return
+	 * @throws HgBadArgumentException
+	 * @throws HgRemoteConnectionException
+	 * @throws HgRepositoryNotFoundException
+	 * @throws HgException
+	 * @throws CancelledException
+	 * @throws HgRuntimeException subclass thereof to indicate issues with the library. <em>Runtime exception</em>
+	 */
+	public HgRepository execute() throws HgException, CancelledException {
 		if (destination == null) {
 			throw new IllegalArgumentException("Destination not set", null);
 		}
 		if (srcRepo == null || srcRepo.isInvalid()) {
 			throw new HgBadArgumentException("Bad source repository", null);
 				offset = 0;
 				revisionSequence.clear();
 				indexFile = new FileOutputStream(new File(hgDir, filename = "store/00changelog.i"));
 				collectChangelogIndexes = true;
 			} catch (IOException ex) {
-				throw new HgBadStateException(ex);
+				throw new HgInvalidControlFileException("Failed to write changelog", ex, new File(filename));
 			}
 		}
 		public void changelogEnd() {
 			try {
 				collectChangelogIndexes = false;
 				indexFile.close();
 				indexFile = null;
 				filename = null;
 			} catch (IOException ex) {
-				throw new HgBadStateException(ex);
+				throw new HgInvalidControlFileException("Failed to write changelog", ex, new File(filename));
 			}
 		}
 		public void manifestStart() {
 			try {
 				base = -1;
 				offset = 0;
 				revisionSequence.clear();
 				indexFile = new FileOutputStream(new File(hgDir, filename = "store/00manifest.i"));
 			} catch (IOException ex) {
-				throw new HgBadStateException(ex);
+				throw new HgInvalidControlFileException("Failed to write manifest", ex, new File(filename));
 			}
 		}
 		public void manifestEnd() {
 			try {
 				}
 				indexFile.close();
 				indexFile = null;
 				filename = null;
 			} catch (IOException ex) {
-				throw new HgBadStateException(ex);
+				throw new HgInvalidControlFileException("Failed to write changelog", ex, new File(filename));
 			}
 		}
 		public void fileStart(String name) {
 			try {
 				// need to investigate more how filenames are kept in fncache
 				File file = new File(hgDir, filename = storagePathHelper.rewrite(name).toString());
 				file.getParentFile().mkdirs();
 				indexFile = new FileOutputStream(file);
 			} catch (IOException ex) {
-				throw new HgBadStateException(ex);
+				String m = String.format("Failed to write file %s", filename);
+				throw new HgInvalidControlFileException(m, ex, new File(filename));
 			}
 		}
 		public void fileEnd(String name) {
 			try {
 				}
 				indexFile.close();
 				indexFile = null;
 				filename = null;
 			} catch (IOException ex) {
-				throw new HgBadStateException(ex);
+				String m = String.format("Failed to write file %s", filename);
+				throw new HgInvalidControlFileException(m, ex, new File(filename));
 			}
 		}
 		private int knownRevision(Nodeid p) {
 			if (p.isNull()) {
 					if (revisionSequence.get(i).equals(p)) {
 						return i;
 					}
 				}
 			}
-			throw new HgBadStateException(String.format("Can't find index of %s for file %s", p.shortNotation(), filename));
+			String m = String.format("Can't find index of %s for file %s", p.shortNotation(), filename);
+			throw new HgInvalidControlFileException(m, null, null).setRevision(p);
 		}
 		public boolean element(GroupElement ge) {
 			try {
 				assert indexFile != null;
 				}
 				byte[] content = ge.apply(prevRevContent.byteArray());
 				byte[] calculated = dh.sha1(p1, p2, content).asBinary();
 				final Nodeid node = ge.node();
 				if (!node.equalsTo(calculated)) {
-					throw new HgBadStateException(String.format("Checksum failed: expected %s, calculated %s. File %s", node, calculated, filename));
+					// TODO post-1.0 custom exception ChecksumCalculationFailed?
+					throw new HgInvalidStateException(String.format("Checksum failed: expected %s, calculated %s. File %s", node, calculated, filename));
 				}
 				final int link;
 				if (collectChangelogIndexes) {
 					changelogIndexes.put(node, revisionSequence.size());
 					link = revisionSequence.size();
 				} else {
 					Integer csRev = changelogIndexes.get(ge.cset());
 					if (csRev == null) {
-						throw new HgBadStateException(String.format("Changelog doesn't contain revision %s of %s", ge.cset().shortNotation(), filename));
+						throw new HgInvalidStateException(String.format("Changelog doesn't contain revision %s of %s", ge.cset().shortNotation(), filename));
 					}
 					link = csRev.intValue();
 				}
 				final int p1Rev = knownRevision(p1), p2Rev = knownRevision(p2);
 				byte[] patchContent = ge.rawDataByteArray();
 				offset += compressedLen;
 				revisionSequence.add(node);
 				prevRevContent.done();
 				prevRevContent = new ByteArrayDataAccess(content);
 			} catch (IOException ex) {
-				throw new HgBadStateException(ex);
+				String m = String.format("Failed to write revision %s of file %s", ge.node().shortNotation(), filename);
+				throw new HgInvalidControlFileException(m, ex, new File(filename));
 			}
 			return true;
 		}
 	}

Mercurial > hg4j

comparison src/org/tmatesoft/hg/core/HgCloneCommand.java @ 423:9c9c442b5f2e