Merge pull request #1486 from cdr/update-backup
Back up old directory when updating
This commit is contained in:
commit
d2a31477c7
@ -512,10 +512,10 @@ index eab8591492..26668701f7 100644
|
|||||||
options.logService.error(`${logPrefix} socketFactory.connect() failed. Error:`);
|
options.logService.error(`${logPrefix} socketFactory.connect() failed. Error:`);
|
||||||
diff --git a/src/vs/server/browser/client.ts b/src/vs/server/browser/client.ts
|
diff --git a/src/vs/server/browser/client.ts b/src/vs/server/browser/client.ts
|
||||||
new file mode 100644
|
new file mode 100644
|
||||||
index 0000000000..96fbd4b0bb
|
index 0000000000..4f8543d975
|
||||||
--- /dev/null
|
--- /dev/null
|
||||||
+++ b/src/vs/server/browser/client.ts
|
+++ b/src/vs/server/browser/client.ts
|
||||||
@@ -0,0 +1,270 @@
|
@@ -0,0 +1,266 @@
|
||||||
+import { Emitter } from 'vs/base/common/event';
|
+import { Emitter } from 'vs/base/common/event';
|
||||||
+import { URI } from 'vs/base/common/uri';
|
+import { URI } from 'vs/base/common/uri';
|
||||||
+import { localize } from 'vs/nls';
|
+import { localize } from 'vs/nls';
|
||||||
@ -692,14 +692,10 @@ index 0000000000..96fbd4b0bb
|
|||||||
+ headers: { "content-type": "application/json" },
|
+ headers: { "content-type": "application/json" },
|
||||||
+ });
|
+ });
|
||||||
+ if (response.status !== 200) {
|
+ if (response.status !== 200) {
|
||||||
+ throw new Error("Unexpected response");
|
+ throw new Error(response.statusText);
|
||||||
+ }
|
+ }
|
||||||
+
|
+
|
||||||
+ const json = await response.json();
|
+ const json = await response.json();
|
||||||
+ if (!json.isLatest) {
|
|
||||||
+ throw new Error("Update failed");
|
|
||||||
+ }
|
|
||||||
+
|
|
||||||
+ (services.get(INotificationService) as INotificationService).info(`Updated to ${json.version}`);
|
+ (services.get(INotificationService) as INotificationService).info(`Updated to ${json.version}`);
|
||||||
+ };
|
+ };
|
||||||
+
|
+
|
||||||
|
@ -221,8 +221,13 @@ export class UpdateHttpProvider extends HttpProvider {
|
|||||||
targetPath = path.resolve(__dirname, "../../../")
|
targetPath = path.resolve(__dirname, "../../../")
|
||||||
}
|
}
|
||||||
|
|
||||||
logger.debug("Replacing files", field("target", targetPath))
|
// Move the old directory to prevent potential data loss.
|
||||||
await fs.move(directoryPath, targetPath, { overwrite: true })
|
const backupPath = path.resolve(targetPath, `../${path.basename(targetPath)}.${Date.now().toString()}`)
|
||||||
|
logger.debug("Replacing files", field("target", targetPath), field("backup", backupPath))
|
||||||
|
await fs.move(targetPath, backupPath)
|
||||||
|
|
||||||
|
// Move the new directory.
|
||||||
|
await fs.move(directoryPath, targetPath)
|
||||||
|
|
||||||
await fs.remove(downloadPath)
|
await fs.remove(downloadPath)
|
||||||
|
|
||||||
|
@ -214,13 +214,18 @@ describe("update", () => {
|
|||||||
await p.downloadAndApplyUpdate(update, destination)
|
await p.downloadAndApplyUpdate(update, destination)
|
||||||
assert.equal(`console.log("UPDATED")`, await fs.readFile(entry, "utf8"))
|
assert.equal(`console.log("UPDATED")`, await fs.readFile(entry, "utf8"))
|
||||||
|
|
||||||
// Should still work if there is no existing version somehow.
|
// There should be a backup.
|
||||||
await fs.remove(destination)
|
const dir = (await fs.readdir(path.join(tmpdir, "tests/updates"))).filter((dir) => {
|
||||||
await p.downloadAndApplyUpdate(update, destination)
|
return dir.startsWith("code-server.")
|
||||||
assert.equal(`console.log("UPDATED")`, await fs.readFile(entry, "utf8"))
|
})
|
||||||
|
assert.equal(dir.length, 1)
|
||||||
|
assert.equal(
|
||||||
|
`console.log("OLD")`,
|
||||||
|
await fs.readFile(path.join(tmpdir, "tests/updates", dir[0], "code-server"), "utf8"),
|
||||||
|
)
|
||||||
|
|
||||||
const archiveName = await p.getReleaseName(update)
|
const archiveName = await p.getReleaseName(update)
|
||||||
assert.deepEqual(spy, ["/latest", `/download/${version}/${archiveName}`, `/download/${version}/${archiveName}`])
|
assert.deepEqual(spy, ["/latest", `/download/${version}/${archiveName}`])
|
||||||
})
|
})
|
||||||
|
|
||||||
it("should not reject if unable to fetch", async () => {
|
it("should not reject if unable to fetch", async () => {
|
||||||
|
Reference in New Issue
Block a user