1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
|
package com.intellij.updater;
import ie.wombat.jbdiff.JBDiff;
import ie.wombat.jbdiff.JBPatch;
import java.io.*;
import java.util.zip.ZipOutputStream;
public abstract class BaseUpdateAction extends PatchAction {
public BaseUpdateAction(String path, long checksum) {
super(path, checksum);
}
public BaseUpdateAction(DataInputStream in) throws IOException {
super(in);
}
@Override
protected ValidationResult doValidate(File toFile) throws IOException {
ValidationResult result = doValidateAccess(toFile, ValidationResult.Action.UPDATE);
if (result != null) return result;
return doValidateNotChanged(toFile, ValidationResult.Kind.ERROR, ValidationResult.Action.UPDATE);
}
@Override
protected boolean shouldApplyOn(File toFile) {
// if the file is optional in may not exist
return toFile.exists();
}
@Override
protected void doBackup(File toFile, File backupFile) throws IOException {
Utils.copy(toFile, backupFile);
}
protected void replaceUpdated(File from, File dest) throws IOException {
// on OS X code signing caches seem to be associated with specific file ids, so we need to remove the original file.
if (!dest.delete()) {
if (Utils.isWindows()) {
throw new RetryException("Cannot delete file " + dest);
} else {
throw new IOException("Cannot delete file " + dest);
}
}
Utils.copy(from, dest);
}
@Override
protected void doRevert(File toFile, File backupFile) throws IOException {
if (!toFile.exists() || isModified(toFile)) {
Utils.copy(backupFile, toFile);
}
}
protected void writeDiff(File olderFile, File newerFile, ZipOutputStream patchOutput) throws IOException {
BufferedInputStream olderFileIn = new BufferedInputStream(new FileInputStream(olderFile));
BufferedInputStream newerFileIn = new BufferedInputStream(new FileInputStream(newerFile));
try {
writeDiff(olderFileIn, newerFileIn, patchOutput);
}
finally {
olderFileIn.close();
newerFileIn.close();
}
}
protected void writeDiff(InputStream olderFileIn, InputStream newerFileIn, ZipOutputStream patchOutput)
throws IOException {
Runner.logger.info("writing diff");
ByteArrayOutputStream diffOutput = new ByteArrayOutputStream();
byte[] newerFileBuffer = JBDiff.bsdiff(olderFileIn, newerFileIn, diffOutput);
diffOutput.close();
if (diffOutput.size() < newerFileBuffer.length) {
patchOutput.write(1);
Utils.copyBytesToStream(diffOutput, patchOutput);
}
else {
patchOutput.write(0);
Utils.copyBytesToStream(newerFileBuffer, patchOutput);
}
}
protected void applyDiff(InputStream patchInput, InputStream oldFileIn, OutputStream toFileOut) throws IOException {
if (patchInput.read() == 1) {
JBPatch.bspatch(oldFileIn, toFileOut, patchInput);
}
else {
Utils.copyStream(patchInput, toFileOut);
}
}
}
|
