Compare commits
4 commits
Author | SHA1 | Date | |
---|---|---|---|
|
6e9d4e7f7b | ||
|
57cb4626e4 | ||
|
1ed67e7c10 | ||
|
095483ef9d |
11 changed files with 5438 additions and 41 deletions
5347
package-lock.json
generated
5347
package-lock.json
generated
File diff suppressed because it is too large
Load diff
34
package.json
34
package.json
|
@ -335,10 +335,28 @@
|
||||||
"icon": "$(link-external)",
|
"icon": "$(link-external)",
|
||||||
"category": "Appwrite"
|
"category": "Appwrite"
|
||||||
},
|
},
|
||||||
|
{
|
||||||
|
"command": "vscode-appwrite.openCollectionInBrowser",
|
||||||
|
"title": "Open collection in browser",
|
||||||
|
"icon": "$(link-external)",
|
||||||
|
"category": "Appwrite"
|
||||||
|
},
|
||||||
{
|
{
|
||||||
"command": "vscode-appwrite.viewMore",
|
"command": "vscode-appwrite.viewMore",
|
||||||
"title": "View more",
|
"title": "View more",
|
||||||
"category": "Appwrite"
|
"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": {
|
"views": {
|
||||||
|
@ -450,6 +468,11 @@
|
||||||
"command": "vscode-appwrite.createFunction",
|
"command": "vscode-appwrite.createFunction",
|
||||||
"when": "view == Functions",
|
"when": "view == Functions",
|
||||||
"group": "navigation"
|
"group": "navigation"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"command": "vscode-appwrite.uploadFile",
|
||||||
|
"when": "view == Storage",
|
||||||
|
"group": "navigation"
|
||||||
}
|
}
|
||||||
],
|
],
|
||||||
"view/item/context": [
|
"view/item/context": [
|
||||||
|
@ -488,6 +511,11 @@
|
||||||
"command": "vscode-appwrite.viewCollectionAsJson",
|
"command": "vscode-appwrite.viewCollectionAsJson",
|
||||||
"when": "viewItem == collection"
|
"when": "viewItem == collection"
|
||||||
},
|
},
|
||||||
|
{
|
||||||
|
"command": "vscode-appwrite.openCollectionInBrowser",
|
||||||
|
"when": "viewItem == collection",
|
||||||
|
"group": "inline"
|
||||||
|
},
|
||||||
{
|
{
|
||||||
"command": "vscode-appwrite.deleteCollection",
|
"command": "vscode-appwrite.deleteCollection",
|
||||||
"when": "viewItem == collection"
|
"when": "viewItem == collection"
|
||||||
|
@ -620,6 +648,11 @@
|
||||||
"command": "vscode-appwrite.CreateTag",
|
"command": "vscode-appwrite.CreateTag",
|
||||||
"when": "viewItem =~ /^tags$/",
|
"when": "viewItem =~ /^tags$/",
|
||||||
"group": "inline"
|
"group": "inline"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"command": "vscode-appwrite.downloadFile",
|
||||||
|
"when": "viewItem =~ /^file$/",
|
||||||
|
"group": "inline"
|
||||||
}
|
}
|
||||||
],
|
],
|
||||||
"explorer/context": [
|
"explorer/context": [
|
||||||
|
@ -764,6 +797,7 @@
|
||||||
"cron-validate": "^1.4.3",
|
"cron-validate": "^1.4.3",
|
||||||
"cronstrue": "^1.113.0",
|
"cronstrue": "^1.113.0",
|
||||||
"dayjs": "^1.10.4",
|
"dayjs": "^1.10.4",
|
||||||
|
"downloads-folder": "^3.0.1",
|
||||||
"fs-extra": "^9.1.0",
|
"fs-extra": "^9.1.0",
|
||||||
"node-appwrite": "^2.2.3",
|
"node-appwrite": "^2.2.3",
|
||||||
"tar": "^6.1.0"
|
"tar": "^6.1.0"
|
||||||
|
|
3
src/appwrite.d.ts
vendored
3
src/appwrite.d.ts
vendored
|
@ -362,6 +362,9 @@ export type StorageClient = {
|
||||||
createFile: (file: any, read?: string[], write?: string[]) => Promise<any>;
|
createFile: (file: any, read?: string[], write?: string[]) => Promise<any>;
|
||||||
listFiles: () => Promise<any>;
|
listFiles: () => Promise<any>;
|
||||||
getFile: (fileId: string) => 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>;
|
type Vars = Record<string, any>;
|
||||||
|
|
|
@ -14,6 +14,14 @@ export class Storage {
|
||||||
return await AppwriteCall(this.storage.listFiles());
|
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> {
|
public async createFile(file: ReadStream): Promise<void> {
|
||||||
return await AppwriteCall(this.storage.createFile(file));
|
return await AppwriteCall(this.storage.createFile(file));
|
||||||
}
|
}
|
||||||
|
|
6
src/commands/database/openCollectionInBrowser.ts
Normal file
6
src/commands/database/openCollectionInBrowser.ts
Normal file
|
@ -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());
|
||||||
|
}
|
|
@ -8,6 +8,9 @@ import { selectWorkspaceFolder } from "../../utils/workspace";
|
||||||
import { ProgressMessage } from "../../utils/types";
|
import { ProgressMessage } from "../../utils/types";
|
||||||
import { Tag } from "../../appwrite";
|
import { Tag } from "../../appwrite";
|
||||||
import { activateTag } from "./activateTag";
|
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> {
|
export async function createTag(item?: TagsTreeItem | Uri): Promise<void> {
|
||||||
if (item instanceof Uri) {
|
if (item instanceof Uri) {
|
||||||
|
@ -136,7 +139,8 @@ async function createTagFromUri(functionId: string, command: string, uri: Uri, p
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
// somehow makes the upload work
|
// 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 });
|
progress.report({ message: "Uploading tag", increment: 60 });
|
||||||
try {
|
try {
|
||||||
return await functionsClient.createTag(functionId, command, fs.createReadStream(tarFilePath));
|
return await functionsClient.createTag(functionId, command, fs.createReadStream(tarFilePath));
|
||||||
|
@ -155,9 +159,17 @@ async function tagNotification(tag: Tag): Promise<void> {
|
||||||
);
|
);
|
||||||
if (action === "Activate tag") {
|
if (action === "Activate tag") {
|
||||||
await activateTag(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") {
|
if (action === "View in console") {
|
||||||
//
|
//
|
||||||
|
await openFunctionTagsInBrowser(tag.functionId);
|
||||||
}
|
}
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
|
@ -3,11 +3,13 @@ import { ExecutionsTreeItem } from '../../tree/functions/executions/ExecutionsTr
|
||||||
import { openUrl } from '../../utils/openUrl';
|
import { openUrl } from '../../utils/openUrl';
|
||||||
import { getConsoleUrlFromEndpoint } from '../users/openUserInConsole';
|
import { getConsoleUrlFromEndpoint } from '../users/openUserInConsole';
|
||||||
|
|
||||||
export async function openFunctionTagsInBrowser(treeItem: ExecutionsTreeItem): Promise<void> {
|
export async function openFunctionTagsInBrowser(treeItem: ExecutionsTreeItem | string): Promise<void> {
|
||||||
const func = treeItem.parent.func;
|
|
||||||
|
const funcId = treeItem instanceof ExecutionsTreeItem ? treeItem.parent.func.$id : treeItem;
|
||||||
|
|
||||||
|
|
||||||
const consoleUrl = getConsoleUrlFromEndpoint(clientConfig.endpoint);
|
const consoleUrl = getConsoleUrlFromEndpoint(clientConfig.endpoint);
|
||||||
// https://console.streamlux.com/console/functions/function?id=60b1836a8e5d9&project=605ce39a30c01
|
// 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);
|
openUrl(url);
|
||||||
}
|
}
|
||||||
|
|
|
@ -43,6 +43,9 @@ import { openFunctionSettingsInBrowser } from './functions/openFunctionSettingsI
|
||||||
import { openFunctionTagsInBrowser } from './functions/openFunctionTagsInBrowser';
|
import { openFunctionTagsInBrowser } from './functions/openFunctionTagsInBrowser';
|
||||||
|
|
||||||
import { viewMore } from './common/viewMore';
|
import { viewMore } from './common/viewMore';
|
||||||
|
import { openCollectionInBrowser } from './database/openCollectionInBrowser';
|
||||||
|
import { uploadFile } from './storage/uploadFile';
|
||||||
|
import { downloadFile } from './storage/downloadFile';
|
||||||
|
|
||||||
class CommandRegistrar {
|
class CommandRegistrar {
|
||||||
constructor(private readonly context: ExtensionContext) {}
|
constructor(private readonly context: ExtensionContext) {}
|
||||||
|
@ -106,6 +109,7 @@ export function registerCommands(context: ExtensionContext): void {
|
||||||
registerCommand("createPermission", createPermission, "database");
|
registerCommand("createPermission", createPermission, "database");
|
||||||
registerCommand("deletePermission", deletePermission, "database");
|
registerCommand("deletePermission", deletePermission, "database");
|
||||||
registerCommand("editPermission", editPermission, "database");
|
registerCommand("editPermission", editPermission, "database");
|
||||||
|
registerCommand("openCollectionInBrowser", openCollectionInBrowser);
|
||||||
|
|
||||||
/** Health **/
|
/** Health **/
|
||||||
registerCommand("refreshHealth", undefined, "health");
|
registerCommand("refreshHealth", undefined, "health");
|
||||||
|
@ -113,6 +117,9 @@ export function registerCommands(context: ExtensionContext): void {
|
||||||
|
|
||||||
/** Storage **/
|
/** Storage **/
|
||||||
registerCommand("refreshStorage", undefined, "storage");
|
registerCommand("refreshStorage", undefined, "storage");
|
||||||
|
registerCommand("uploadFile", uploadFile, "storage");
|
||||||
|
registerCommand("downloadFile", downloadFile);
|
||||||
|
|
||||||
registerCommand("openStorageDocumentation", () => openDocumentation("storage"));
|
registerCommand("openStorageDocumentation", () => openDocumentation("storage"));
|
||||||
|
|
||||||
/** Projects **/
|
/** Projects **/
|
||||||
|
|
29
src/commands/storage/downloadFile.ts
Normal file
29
src/commands/storage/downloadFile.ts
Normal file
|
@ -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);
|
||||||
|
}
|
||||||
|
}
|
14
src/commands/storage/uploadFile.ts
Normal file
14
src/commands/storage/uploadFile.ts
Normal file
|
@ -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.");
|
||||||
|
}
|
||||||
|
}
|
|
@ -1,6 +1,7 @@
|
||||||
import { ThemeIcon, TreeItem, TreeItemCollapsibleState } from "vscode";
|
import { ThemeIcon, TreeItem, TreeItemCollapsibleState } from "vscode";
|
||||||
import { Collection } from "../../appwrite";
|
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 { AppwriteTreeItemBase } from "../../ui/AppwriteTreeItemBase";
|
||||||
import { DatabaseTreeItemProvider } from "./DatabaseTreeItemProvider";
|
import { DatabaseTreeItemProvider } from "./DatabaseTreeItemProvider";
|
||||||
import { DocumentsTreeItem } from "./DocumentsTreeItem";
|
import { DocumentsTreeItem } from "./DocumentsTreeItem";
|
||||||
|
@ -12,6 +13,12 @@ export class CollectionTreeItem extends AppwriteTreeItemBase {
|
||||||
super(undefined, collection.name);
|
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[]> {
|
public async getChildren(): Promise<TreeItem[]> {
|
||||||
return [new RulesTreeItem(this), new PermissionsTreeItem(this), new DocumentsTreeItem(this)];
|
return [new RulesTreeItem(this), new PermissionsTreeItem(this), new DocumentsTreeItem(this)];
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue