File upload/download without settings

package.json

@@ -335,10 +335,28 @@
                 "icon": "$(link-external)",
                 "category": "Appwrite"
             },
+            {
+                "command": "vscode-appwrite.openCollectionInBrowser",
+                "title": "Open collection in browser",
+                "icon": "$(link-external)",
+                "category": "Appwrite"
+            },
             {
                 "command": "vscode-appwrite.viewMore",
                 "title": "View more",
                 "category": "Appwrite"
+            },
+            {
+                "command": "vscode-appwrite.uploadFile",
+                "title": "Upload file to storage",
+                "icon": "$(cloud-upload)",
+                "category": "Appwrite"
+            },
+            {
+                "command": "vscode-appwrite.downloadFile",
+                "title": "Download file",
+                "icon": "$(cloud-download)",
+                "category": "Appwrite"
             }
         ],
         "views": {
@@ -450,6 +468,11 @@
                     "command": "vscode-appwrite.createFunction",
                     "when": "view == Functions",
                     "group": "navigation"
+                },
+                {
+                    "command": "vscode-appwrite.uploadFile",
+                    "when": "view == Storage",
+                    "group": "navigation"
                 }
             ],
             "view/item/context": [
@@ -488,6 +511,11 @@
                     "command": "vscode-appwrite.viewCollectionAsJson",
                     "when": "viewItem == collection"
                 },
+                {
+                    "command": "vscode-appwrite.openCollectionInBrowser",
+                    "when": "viewItem == collection",
+                    "group": "inline"
+                },
                 {
                     "command": "vscode-appwrite.deleteCollection",
                     "when": "viewItem == collection"
@@ -620,6 +648,11 @@
                     "command": "vscode-appwrite.CreateTag",
                     "when": "viewItem =~ /^tags$/",
                     "group": "inline"
+                },
+                {
+                    "command": "vscode-appwrite.downloadFile",
+                    "when": "viewItem =~ /^file$/",
+                    "group": "inline"
                 }
             ],
             "explorer/context": [
@@ -764,6 +797,7 @@
         "cron-validate": "^1.4.3",
         "cronstrue": "^1.113.0",
         "dayjs": "^1.10.4",
+        "downloads-folder": "^3.0.1",
         "fs-extra": "^9.1.0",
         "node-appwrite": "^2.2.3",
         "tar": "^6.1.0"

src/appwrite.d.ts

@@ -362,6 +362,9 @@ export type StorageClient = {
     createFile: (file: any, read?: string[], write?: string[]) => Promise<any>;
     listFiles: () => Promise<any>;
     getFile: (fileId: string) => Promise<any>;
+    getFileDownload: (fileId: string) => Promise<any>;
+    getFileView: (fileId: string) => Promise<any>;
+    deleteFile: (fileId: string) => Promise<any>;
 };
 
 type Vars = Record<string, any>;

src/appwrite/Storage.ts

@@ -14,6 +14,14 @@ export class Storage {
         return await AppwriteCall(this.storage.listFiles());
     }
 
+    public async getFileDownload(fileId: string): Promise<any> {
+        return await AppwriteCall(this.storage.getFileDownload(fileId));
+    }
+
+    public async getFileView(fileId: string): Promise<any> {
+        return await AppwriteCall(this.storage.getFileView(fileId));
+    }
+
     public async createFile(file: ReadStream): Promise<void> {
         return await AppwriteCall(this.storage.createFile(file));
     }

src/commands/database/openCollectionInBrowser.ts

@@ -0,0 +1,6 @@
+import { CollectionTreeItem } from '../../tree/database/CollectionTreeItem';
+import { openUrl } from '../../utils/openUrl';
+
+export async function openCollectionInBrowser(treeItem: CollectionTreeItem): Promise<void> {
+    openUrl(treeItem.getUrl());
+}

src/commands/functions/createTag.ts

@@ -8,6 +8,9 @@ import { selectWorkspaceFolder } from "../../utils/workspace";
 import { ProgressMessage } from "../../utils/types";
 import { Tag } from "../../appwrite";
 import { activateTag } from "./activateTag";
+import { sleep } from '../../utils/sleep';
+import { openFunctionTagsInBrowser } from './openFunctionTagsInBrowser';
+import { executeFunction } from './createExecution';
 
 export async function createTag(item?: TagsTreeItem | Uri): Promise<void> {
     if (item instanceof Uri) {
@@ -136,7 +139,8 @@ async function createTagFromUri(functionId: string, command: string, uri: Uri, p
         return;
     }
     // somehow makes the upload work
-    await workspace.fs.readFile(Uri.file(tarFilePath));
+    // await workspace.fs.readFile(Uri.file(tarFilePath));
+    await sleep(1000);
     progress.report({ message: "Uploading tag", increment: 60 });
     try {
         return await functionsClient.createTag(functionId, command, fs.createReadStream(tarFilePath));
@@ -155,9 +159,17 @@ async function tagNotification(tag: Tag): Promise<void> {
         );
         if (action === "Activate tag") {
             await activateTag(tag);
+            const action = await window.showInformationMessage(
+                `Successfully activated tag.`,
+                "Execute function",
+            );
+            if (action === 'Execute function') {
+                await executeFunction(tag.functionId);
+            }
         }
         if (action === "View in console") {
             //
+            await openFunctionTagsInBrowser(tag.functionId);
         }
         return;
     }

src/commands/functions/openFunctionTagsInBrowser.ts

@@ -3,11 +3,13 @@ import { ExecutionsTreeItem } from '../../tree/functions/executions/ExecutionsTr
 import { openUrl } from '../../utils/openUrl';
 import { getConsoleUrlFromEndpoint } from '../users/openUserInConsole';
 
-export async function openFunctionTagsInBrowser(treeItem: ExecutionsTreeItem): Promise<void> {
-    const func = treeItem.parent.func;
+export async function openFunctionTagsInBrowser(treeItem: ExecutionsTreeItem | string): Promise<void> {
+
+    const funcId = treeItem instanceof ExecutionsTreeItem ? treeItem.parent.func.$id : treeItem;
+
 
     const consoleUrl = getConsoleUrlFromEndpoint(clientConfig.endpoint);
     // https://console.streamlux.com/console/functions/function?id=60b1836a8e5d9&project=605ce39a30c01
-    const url = `${consoleUrl}/functions/function?id=${func.$id}&project=${clientConfig.projectId}`;
+    const url = `${consoleUrl}/functions/function?id=${funcId}&project=${clientConfig.projectId}`;
     openUrl(url);
 }

src/commands/registerCommands.ts

@@ -43,6 +43,9 @@ import { openFunctionSettingsInBrowser } from './functions/openFunctionSettingsI
 import { openFunctionTagsInBrowser } from './functions/openFunctionTagsInBrowser';
 
 import { viewMore } from './common/viewMore';
+import { openCollectionInBrowser } from './database/openCollectionInBrowser';
+import { uploadFile } from './storage/uploadFile';
+import { downloadFile } from './storage/downloadFile';
 
 class CommandRegistrar {
     constructor(private readonly context: ExtensionContext) {}
@@ -106,6 +109,7 @@ export function registerCommands(context: ExtensionContext): void {
     registerCommand("createPermission", createPermission, "database");
     registerCommand("deletePermission", deletePermission, "database");
     registerCommand("editPermission", editPermission, "database");
+    registerCommand("openCollectionInBrowser", openCollectionInBrowser);
 
     /** Health **/
     registerCommand("refreshHealth", undefined, "health");
@@ -113,6 +117,9 @@ export function registerCommands(context: ExtensionContext): void {
 
     /** Storage **/
     registerCommand("refreshStorage", undefined, "storage");
+    registerCommand("uploadFile", uploadFile, "storage");
+    registerCommand("downloadFile", downloadFile);
+
     registerCommand("openStorageDocumentation", () => openDocumentation("storage"));
 
     /** Projects **/

src/commands/storage/downloadFile.ts

@@ -0,0 +1,29 @@
+import { ProgressLocation, Uri, window, workspace } from "vscode";
+import { storageClient } from "../../client";
+import * as fs from "fs";
+import { FileTreeItem } from "../../tree/storage/FileTreeItem";
+import downloadsFolder = require("downloads-folder");
+import { File } from "../../appwrite";
+import { ProgressMessage } from "../../utils/types";
+import { CancellationToken } from "vscode";
+
+export async function downloadFile(item: FileTreeItem | File): Promise<void> {
+    const file = item instanceof FileTreeItem ? item.file : item;
+
+    const data = await window.withProgress(
+        { location: ProgressLocation.Notification, title: `Downloading ${file.name}`, cancellable: false },
+        async (progress: ProgressMessage, _token: CancellationToken): Promise<Buffer> => {
+            const data = await storageClient?.getFileDownload(file.$id);
+            progress.report({ message: "Download finished" });
+            return data;
+        }
+    );
+
+    const defaultUriBase = workspace.workspaceFolders?.[0].uri ?? Uri.parse(downloadsFolder());
+    const defaultUri = Uri.joinPath(defaultUriBase, file.name);
+
+    const destination = await window.showSaveDialog({ saveLabel: "Save", title: file.name, defaultUri });
+    if (data && destination) {
+        await fs.promises.writeFile(destination.fsPath, data);
+    }
+}

src/commands/storage/uploadFile.ts

@@ -0,0 +1,14 @@
+import { window } from "vscode";
+import { storageClient } from "../../client";
+import * as fs from "fs";
+
+export async function uploadFile(): Promise<void> {
+    try {
+        const file = await window.showOpenDialog({ canSelectFiles: true, canSelectFolders: false, canSelectMany: false });
+        if (file) {
+            await storageClient?.createFile(fs.createReadStream(file[0].fsPath));
+        }
+    } catch (e) {
+        window.showErrorMessage("Failed to upload file.");
+    }
+}

src/tree/database/CollectionTreeItem.ts

@@ -1,6 +1,7 @@
 import { ThemeIcon, TreeItem, TreeItemCollapsibleState } from "vscode";
 import { Collection } from "../../appwrite";
-import { databaseClient } from "../../client";
+import { clientConfig, databaseClient } from "../../client";
+import { getConsoleUrlFromEndpoint } from '../../commands/users/openUserInConsole';
 import { AppwriteTreeItemBase } from "../../ui/AppwriteTreeItemBase";
 import { DatabaseTreeItemProvider } from "./DatabaseTreeItemProvider";
 import { DocumentsTreeItem } from "./DocumentsTreeItem";
@@ -12,6 +13,12 @@ export class CollectionTreeItem extends AppwriteTreeItemBase {
         super(undefined, collection.name);
     }
 
+    // https://console.streamlux.com/console/database/collection?id=607cb2d6a21a8&project=605ce39a30c01
+    public getUrl(): string {
+        const consoleUrl = getConsoleUrlFromEndpoint(clientConfig.endpoint);
+        return `${consoleUrl}/database/collection?id=${this.collection.$id}&project=${clientConfig.projectId}`;
+    }
+
     public async getChildren(): Promise<TreeItem[]> {
         return [new RulesTreeItem(this), new PermissionsTreeItem(this), new DocumentsTreeItem(this)];
     }