Put docker rm in finally block

matrix-org · Apr 14, 2022 · dd0ff8e · dd0ff8e
1 parent d5d9aa7
commit dd0ff8e
Showing 1 changed file with 35 additions and 33 deletions.
diff --git a/cypress/plugins/synapsedocker/index.ts b/cypress/plugins/synapsedocker/index.ts
@@ -135,41 +135,43 @@ async function synapseStop(id) {
 
     if (!synCfg) throw new Error("Unknown synapse ID");
 
-    const synapseLogsPath = path.join("cypress", "synapselogs", id);
-    await fse.ensureDir(synapseLogsPath);
-
-    const stdoutFile = await fse.open(path.join(synapseLogsPath, "stdout.log"), "w");
-    const stderrFile = await fse.open(path.join(synapseLogsPath, "stderr.log"), "w");
-    await new Promise<void>((resolve, reject) => {
-        childProcess.spawn('docker', [
-            "logs",
-            id,
-        ], {
-            stdio: ["ignore", stdoutFile, stderrFile],
-        }).once('close', resolve);
-    });
-    await fse.close(stdoutFile);
-    await fse.close(stderrFile);
-
-    await new Promise<void>((resolve, reject) => {
-        childProcess.execFile('docker', [
-            "stop",
-            id,
-        ], err => {
-            if (err) reject(err);
-            resolve();
+    try {
+        const synapseLogsPath = path.join("cypress", "synapselogs", id);
+        await fse.ensureDir(synapseLogsPath);
+
+        const stdoutFile = await fse.open(path.join(synapseLogsPath, "stdout.log"), "w");
+        const stderrFile = await fse.open(path.join(synapseLogsPath, "stderr.log"), "w");
+        await new Promise<void>((resolve, reject) => {
+            childProcess.spawn('docker', [
+                "logs",
+                id,
+            ], {
+                stdio: ["ignore", stdoutFile, stderrFile],
+            }).once('close', resolve);
         });
-    });
-
-    await new Promise<void>((resolve, reject) => {
-        childProcess.execFile('docker', [
-            "rm",
-            id,
-        ], err => {
-            if (err) reject(err);
-            resolve();
+        await fse.close(stdoutFile);
+        await fse.close(stderrFile);
+
+        await new Promise<void>((resolve, reject) => {
+            childProcess.execFile('docker', [
+                "stop",
+                id,
+            ], err => {
+                if (err) reject(err);
+                resolve();
+            });
         });
-    });
+    } finally {
+        await new Promise<void>((resolve, reject) => {
+            childProcess.execFile('docker', [
+                "rm",
+                id,
+            ], err => {
+                if (err) reject(err);
+                resolve();
+            });
+        });
+    }
 
     await fse.remove(synCfg.configDir);