perf: All fs is done async (#540)

Author: JohnstonCode

src/commands/command.ts

@@ -1,4 +1,3 @@
-import * as fs from "original-fs";
 import * as path from "path";
 import {
   commands,
@@ -16,6 +15,7 @@ import {
   WorkspaceEdit
 } from "vscode";
 import { ICommandOptions, Status, SvnUriAction } from "../common/types";
+import { exists, readFile, stat, unlink } from "../fs";
 import { inputIgnoreList } from "../ignoreitems";
 import { applyLineChanges } from "../lineChanges";
 import { Model } from "../model";
@@ -194,7 +194,7 @@ export abstract class Command implements Disposable {
     preserveFocus?: boolean,
     preserveSelection?: boolean
   ): Promise<void> {
-    let left = this.getLeftResource(resource, against);
+    let left = await this.getLeftResource(resource, against);
     let right = this.getRightResource(resource, against);
     const title = this.getTitle(resource, against);
 
@@ -209,8 +209,8 @@ export abstract class Command implements Disposable {
     }
 
     if (
-      fs.existsSync(right.fsPath) &&
-      fs.statSync(right.fsPath).isDirectory()
+      (await exists(right.fsPath)) &&
+      (await stat(right.fsPath)).isDirectory()
     ) {
       return;
     }
@@ -244,10 +244,10 @@ export abstract class Command implements Disposable {
     );
   }
 
-  protected getLeftResource(
+  protected async getLeftResource(
     resource: Resource,
     against: string = ""
-  ): Uri | undefined {
+  ): Promise<Uri | undefined> {
     if (resource.remote) {
       if (resource.type !== Status.DELETED) {
         return toSvnUri(resource.resourceUri, SvnUriAction.SHOW, {
@@ -266,11 +266,11 @@ export abstract class Command implements Disposable {
     // Show file if has conflicts marks
     if (
       resource.type === Status.CONFLICTED &&
-      fs.existsSync(resource.resourceUri.fsPath)
+      (await exists(resource.resourceUri.fsPath))
     ) {
-      const text = fs.readFileSync(resource.resourceUri.fsPath, {
+      const text = (await readFile(resource.resourceUri.fsPath, {
         encoding: "utf8"
-      });
+      })) as string;
 
       // Check for lines begin with "<<<<<<", "=======", ">>>>>>>"
       if (/^<{7}[^]+^={7}[^]+^>{7}/m.test(text)) {
@@ -394,8 +394,12 @@ export abstract class Command implements Disposable {
     try {
       const tempFile = path.join(repository.root, ".svn", "tmp", "svn.patch");
 
-      if (fs.existsSync(tempFile)) {
-        fs.unlinkSync(tempFile);
+      if (await exists(tempFile)) {
+        try {
+          await unlink(tempFile);
+        } catch (err) {
+          // TODO(cjohnston)//log error
+        }
       }
 
       const uri = Uri.file(tempFile).with({

src/commands/deleteUnversioned.ts

@@ -1,5 +1,5 @@
-import * as fs from "original-fs";
 import { SourceControlResourceState, window } from "vscode";
+import { exists, lstat, unlink } from "../fs";
 import { deleteDirectory } from "../util";
 import { Command } from "./command";
 
@@ -24,16 +24,20 @@ export class DeleteUnversioned extends Command {
       for (const uri of uris) {
         const fsPath = uri.fsPath;
 
-        if (!fs.existsSync(fsPath)) {
-          continue;
-        }
+        try {
+          if (!(await exists(fsPath))) {
+            continue;
+          }
 
-        const stat = fs.lstatSync(fsPath);
+          const stat = await lstat(fsPath);
 
-        if (stat.isDirectory()) {
-          deleteDirectory(fsPath);
-        } else {
-          fs.unlinkSync(fsPath);
+          if (stat.isDirectory()) {
+            deleteDirectory(fsPath);
+          } else {
+            await unlink(fsPath);
+          }
+        } catch (err) {
+          // TODO(cjohnston) Show meaningful error to user
         }
       }
     }

src/commands/openFile.ts

@@ -1,4 +1,3 @@
-import * as fs from "original-fs";
 import {
   SourceControlResourceState,
   TextDocumentShowOptions,
@@ -7,6 +6,7 @@ import {
   window,
   workspace
 } from "vscode";
+import { exists, stat } from "../fs";
 import { Resource } from "../resource";
 import IncomingChangeNode from "../treeView/nodes/incomingChangeNode";
 import { fromSvnUri } from "../uri";
@@ -65,7 +65,10 @@ export class OpenFile extends Command {
     const preview = uris.length === 1 ? true : false;
     const activeTextEditor = window.activeTextEditor;
     for (const uri of uris) {
-      if (fs.existsSync(uri.fsPath) && fs.statSync(uri.fsPath).isDirectory()) {
+      if (
+        (await exists(uri.fsPath)) &&
+        (await stat(uri.fsPath)).isDirectory()
+      ) {
         continue;
       }
 

src/commands/openHeadFile.ts

@@ -26,7 +26,7 @@ export class OpenHeadFile extends Command {
       return;
     }
 
-    const HEAD = this.getLeftResource(resource, "HEAD");
+    const HEAD = await this.getLeftResource(resource, "HEAD");
 
     const basename = path.basename(resource.resourceUri.fsPath);
     if (!HEAD) {

src/fs/exists.ts

@@ -2,6 +2,6 @@ import { access } from "original-fs";
 
 export function exists(path: string): Promise<boolean> {
   return new Promise((resolve, reject) => {
-    access(path, err => (err ? reject(err) : resolve(true)));
+    access(path, err => (err ? resolve(false) : resolve(true)));
   });
 }

src/fs/index.ts

@@ -0,0 +1,9 @@
+export { exists } from "./exists";
+export { lstat } from "./lstat";
+export { mkdir } from "./mkdir";
+export { readFile } from "./read_file";
+export { readdir } from "./readdir";
+export { rmdir } from "./rmdir";
+export { stat } from "./stat";
+export { unlink } from "./unlink";
+export { writeFile } from "./write_file";

src/fs/lstat.ts

@@ -0,0 +1,4 @@
+import { lstat as fsLstat } from "original-fs";
+import { promisify } from "util";
+
+export const lstat = promisify(fsLstat);

src/fs/mkdir.ts

@@ -0,0 +1,4 @@
+import { mkdir as fsMkdir } from "original-fs";
+import { promisify } from "util";
+
+export const mkdir = promisify(fsMkdir);

src/fs/read_file.ts

@@ -0,0 +1,4 @@
+import { readFile as fsReadFile } from "original-fs";
+import { promisify } from "util";
+
+export const readFile = promisify(fsReadFile);

src/fs/readdir.ts

@@ -1,13 +1,4 @@
 import { readdir as fsReaddir } from "original-fs";
+import { promisify } from "util";
 
-export function readdir(path: string): Promise<string[]> {
-  return new Promise((resolve, reject) => {
-    fsReaddir(path, (err, files) => {
-      if (err) {
-        reject(err);
-      }
-
-      resolve(files);
-    });
-  });
-}
+export const readdir = promisify(fsReaddir);