Compare commits

..

3 commits

Author SHA1 Message Date
Alex Weininger
c908162b7d
Merge branch 'main' into alex/couldNotConnectMessage 2021-05-08 01:16:30 -07:00
alexweininger
7dabd65d9f fix lint errors 2021-05-07 18:24:24 -07:00
alexweininger
83ceb42acf Show nicer message when Appwrite project can't be found 2021-05-07 18:21:47 -07:00
74 changed files with 4717 additions and 2445 deletions

View file

@ -0,0 +1,36 @@
# Starter pipeline
# Start with a minimal pipeline that you can customize to build and deploy your code.
# Add steps that build, run tests, deploy, and more:
# https://aka.ms/yaml
trigger:
- main
pool:
vmImage: ubuntu-latest
steps:
- task: NodeTool@0
displayName: 'Use Node 12.x'
inputs:
versionSpec: 12.x
- task: Npm@1
displayName: 'npm ci'
inputs:
command: ci
- script: npm run package
displayName: package
- script: npx vsce package
- task: CopyFiles@2
displayName: 'Copy vsix to staging directory'
inputs:
Contents: '**/*.vsix'
TargetFolder: '$(build.artifactstagingdirectory)'
- task: PublishBuildArtifacts@1
displayName: 'Publish artifacts: vsix'
inputs:
PathtoPublish: '$(build.artifactstagingdirectory)'
ArtifactName: vsix

View file

@ -1,48 +0,0 @@
name: Bug Report
description: File a bug report
title: "[Bug] "
labels: [bug]
body:
- type: markdown
attributes:
value: |
Thanks for taking the time to fill out this bug report!
- type: textarea
id: repro
attributes:
label: Reproduction steps
description: "How do you trigger this bug? Please walk us through it step by step."
value: |
1.
2.
3.
...
render: bash
validations:
required: true
- type: dropdown
id: version
attributes:
label: Version
description: What version of VS Code are you using?
options:
- Stable (Default)
- Insiders
validations:
required: true
- type: dropdown
id: os
attributes:
label: What operating system are you seeing the problem on?
multiple: true
options:
- All
- Windows
- macOS
- Linux
- type: textarea
id: logs
attributes:
label: Relevant log output
description: Please copy and paste any relevant log output. This will be automatically formatted into code, so no need for backticks.
render: shell

View file

@ -26,10 +26,4 @@ jobs:
with: with:
node-version: ${{ matrix.node-version }} node-version: ${{ matrix.node-version }}
- run: npm ci - run: npm ci
- run: npx vsce package - run: npm run package
- uses: actions/upload-artifact@v2
with:
name: vsix
path: '*.vsix'
if-no-files-found: error # 'warn' or 'ignore' are also available, defaults to `warn`

View file

@ -5,42 +5,8 @@ All notable changes to the "vscode-appwrite" extension will be documented in thi
Check [Keep a Changelog](http://keepachangelog.com/) for recommendations on how to structure this file. Check [Keep a Changelog](http://keepachangelog.com/) for recommendations on how to structure this file.
## [Unreleased] ## [Unreleased]
## [0.1.3] - 2021-6-17
## Added
- New feature! JSON strings inside documents will now be automatically formatted as JSON when viewing documents. You can turn this feature off via the `appwrite.formatJsonStrings` setting.
## [0.1.2] - 2021-6-03
## Added
- Ability to set the `list`, `default` and `array` properties when creating a new collection. | [Issue #20](https://github.com/streamlux/vscode-appwrite/issues/20) | [PR #21](https://github.com/streamlux/vscode-appwrite/pull/21) | Thanks [@Maatteogekko](https://github.com/Maatteogekko)!
## [0.1.1] - 2021-5-31
## Added
- You can now easily create function tags from multiple places in the extension. [PR #19](https://github.com/streamlux/vscode-appwrite/pull/19)
## Fixed
- Fixed an error when deleting a user. [Issue #17](https://github.com/streamlux/vscode-appwrite/issues/17) [PR #18](https://github.com/streamlux/vscode-appwrite/pull/18) Thanks [@aadarshadhakalg](https://github.com/aadarshadhakalg)!
## [0.1.0] - 2021-5-29
## Functions!
### Added
- Ability to create and delete Appwrite functions
- Edit function settings
- View, and delete tags (creating tags is broken currently)
- Create and view function executions
- View execution output and errors
## [0.0.9] - 2021-5-21
- Remove temporary fix for Appwrite https://github.com/appwrite/appwrite/issues/1171. Upstream issue was resolved.
## [0.0.8] - 2021-5-21
- Temp fix for Appwrite https://github.com/appwrite/appwrite/issues/1171
## [0.0.7] - 2021-5-14
### Fixed ### Fixed
- Fixed a bug where the password validation for creating a new user did not follow the Appwrite spec. [Issue](https://github.com/streamlux/vscode-appwrite/issues/11) - Fixed a bug where the password validation for creating a new user did not follow the Appwrite spec. [Issue](https://github.com/streamlux/vscode-appwrite/issues/11)
- Show nicer message when Appwrite project can't be found. [Issue](https://github.com/streamlux/vscode-appwrite/pull/14)
## [0.0.6] - 2021-4-30 ## [0.0.6] - 2021-4-30
### Fixed ### Fixed

View file

@ -1,11 +1,13 @@
![Cover image](media/readmeCoverImage.png)
# Appwrite for Visual Studio Code # Appwrite for Visual Studio Code
Use the Appwrite extension to quickly monitor, manage, and interact with your Appwrite instance directly from VS Code. <!-- region exclude-from-marketplace -->
[![Version](https://vsmarketplacebadge.apphb.com/version/streamlux.vscode-appwrite.svg)](https://marketplace.visualstudio.com/items?itemName=streamlux.vscode-appwrite) [![Installs](https://vsmarketplacebadge.apphb.com/installs-short/streamlux.vscode-appwrite.svg)](https://marketplace.visualstudio.com/items?itemName=streamlux.vscode-appwrite) [![Version](https://vsmarketplacebadge.apphb.com/version/streamlux.vscode-appwrite.svg)](https://marketplace.visualstudio.com/items?itemName=streamlux.vscode-appwrite) [![Installs](https://vsmarketplacebadge.apphb.com/installs-short/streamlux.vscode-appwrite.svg)](https://marketplace.visualstudio.com/items?itemName=streamlux.vscode-appwrite)
<!-- endregion exclude-from-marketplace -->
Use the Appwrite extension to quickly monitor, manage, and interact with your Appwrite instance directly from VS Code.
## What is Appwrite? ## What is Appwrite?
From [appwrite.io](https://appwrite.io) From [appwrite.io](https://appwrite.io)
@ -18,15 +20,7 @@ From [appwrite.io](https://appwrite.io)
### Connect to multiple Appwrite projects ### Connect to multiple Appwrite projects
<img src="media/features/projects/projectsView1.gif" height="600"> ![Mutliple projects](media/features/projects/projectsView1.gif)
### Creating function tags with ease!
![Functions feature](media/features/functions/CreateTag.gif)
### Create and manage Appwrite cloud functions, upload tags, and view function output
<img src="media/features/functions/functionsOverview.png" height="500">
### View database documents right inside VS Code. ### View database documents right inside VS Code.

Binary file not shown.

Before

Width:  |  Height:  |  Size: 1.9 MiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 470 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 22 KiB

4760
package-lock.json generated

File diff suppressed because it is too large Load diff

View file

@ -2,7 +2,7 @@
"name": "vscode-appwrite", "name": "vscode-appwrite",
"displayName": "Appwrite", "displayName": "Appwrite",
"description": "Manage your Appwrite resources right from VS Code!", "description": "Manage your Appwrite resources right from VS Code!",
"version": "0.1.3", "version": "0.0.6",
"engines": { "engines": {
"vscode": "^1.55.0" "vscode": "^1.55.0"
}, },
@ -30,9 +30,7 @@
"onView:Users", "onView:Users",
"onView:Database", "onView:Database",
"onView:Health", "onView:Health",
"onView:Functions", "onCommand:vscode-appwrite.AddProject"
"onCommand:vscode-appwrite.AddProject",
"onCommand:vscode-appwrite.CreateTag"
], ],
"main": "./dist/extension.js", "main": "./dist/extension.js",
"contributes": { "contributes": {
@ -40,305 +38,156 @@
{ {
"command": "vscode-appwrite.Connect", "command": "vscode-appwrite.Connect",
"title": "Connect to Appwrite", "title": "Connect to Appwrite",
"category": "Appwrite" "category": ""
}, },
{ {
"command": "vscode-appwrite.CreateUser", "command": "vscode-appwrite.CreateUser",
"title": "Create user", "title": "Create user",
"icon": "$(add)", "icon": "$(add)"
"category": "Appwrite"
}, },
{ {
"command": "vscode-appwrite.DeleteUser", "command": "vscode-appwrite.DeleteUser",
"title": "Delete user", "title": "Delete user",
"icon": "$(trash)", "icon": "$(trash)"
"category": "Appwrite"
}, },
{ {
"command": "vscode-appwrite.GetUserLogs", "command": "vscode-appwrite.GetUserLogs",
"title": "Get user logs", "title": "Get user logs",
"icon": "$(output)", "icon": "$(output)"
"category": "Appwrite"
}, },
{ {
"command": "vscode-appwrite.openUserInConsole", "command": "vscode-appwrite.openUserInConsole",
"title": "View user in Appwrite console", "title": "View user in Appwrite console",
"icon": "$(link-external)", "icon": "$(link-external)"
"category": "Appwrite"
}, },
{ {
"command": "vscode-appwrite.viewUserPrefs", "command": "vscode-appwrite.viewUserPrefs",
"title": "View user preferences", "title": "View user preferences",
"icon": "$(json)", "icon": "$(json)"
"category": "Appwrite"
}, },
{ {
"command": "vscode-appwrite.refreshEntry", "command": "vscode-appwrite.refreshEntry",
"title": "Refresh", "title": "Refresh",
"icon": "$(refresh)", "icon": "$(refresh)"
"category": "Appwrite"
}, },
{ {
"command": "vscode-appwrite.copyUserId", "command": "vscode-appwrite.copyUserId",
"title": "Copy user ID", "title": "Copy user ID",
"icon": "$(clippy)", "icon": "$(clippy)"
"category": "Appwrite"
}, },
{ {
"command": "vscode-appwrite.copyUserEmail", "command": "vscode-appwrite.copyUserEmail",
"title": "Copy user email", "title": "Copy user email",
"icon": "$(clippy)", "icon": "$(clippy)"
"category": "Appwrite"
}, },
{ {
"command": "vscode-appwrite.refreshUsersList", "command": "vscode-appwrite.refreshUsersList",
"title": "Refresh users list", "title": "Refresh users list",
"icon": "$(refresh)", "icon": "$(refresh)"
"category": "Appwrite"
}, },
{ {
"command": "vscode-appwrite.OpenUsersDocumentation", "command": "vscode-appwrite.OpenUsersDocumentation",
"title": "Open documentation", "title": "Open documentation",
"icon": "$(book)", "icon": "$(book)"
"category": "Appwrite"
}, },
{ {
"command": "vscode-appwrite.OpenDatabaseDocumentation", "command": "vscode-appwrite.OpenDatabaseDocumentation",
"title": "Open documentation", "title": "Open documentation",
"icon": "$(book)", "icon": "$(book)"
"category": "Appwrite"
}, },
{ {
"command": "vscode-appwrite.viewDocumentAsJson", "command": "vscode-appwrite.viewDocumentAsJson",
"title": "View as JSON", "title": "View as JSON"
"category": "Appwrite"
}, },
{ {
"command": "vscode-appwrite.viewCollectionAsJson", "command": "vscode-appwrite.viewCollectionAsJson",
"title": "View collection as JSON", "title": "View collection as JSON"
"category": "Appwrite"
}, },
{ {
"command": "vscode-appwrite.refreshCollection", "command": "vscode-appwrite.refreshCollection",
"title": "Refresh", "title": "Refresh",
"icon": "$(refresh)", "icon": "$(refresh)"
"category": "Appwrite"
}, },
{ {
"command": "vscode-appwrite.createRule", "command": "vscode-appwrite.createRule",
"title": "Create collection rule", "title": "Create collection rule",
"icon": "$(add)", "icon": "$(add)"
"category": "Appwrite"
}, },
{ {
"command": "vscode-appwrite.removeRule", "command": "vscode-appwrite.removeRule",
"title": "Remove collection rule", "title": "Remove collection rule"
"category": "Appwrite"
}, },
{ {
"command": "vscode-appwrite.deleteDocument", "command": "vscode-appwrite.deleteDocument",
"title": "Delete document", "title": "Delete document"
"category": "Appwrite"
}, },
{ {
"command": "vscode-appwrite.deleteCollection", "command": "vscode-appwrite.deleteCollection",
"title": "Delete collection", "title": "Delete collection"
"category": "Appwrite"
}, },
{ {
"command": "vscode-appwrite.refreshCollectionsList", "command": "vscode-appwrite.refreshCollectionsList",
"title": "Refresh", "title": "Refresh",
"icon": "$(refresh)", "icon": "$(refresh)"
"category": "Appwrite"
}, },
{ {
"command": "vscode-appwrite.createCollection", "command": "vscode-appwrite.createCollection",
"title": "Create collection", "title": "Create collection",
"icon": "$(add)", "icon": "$(add)"
"category": "Appwrite"
}, },
{ {
"command": "vscode-appwrite.createPermission", "command": "vscode-appwrite.createPermission",
"title": "Create permission", "title": "Create permission",
"icon": "$(add)", "icon": "$(add)"
"category": "Appwrite"
}, },
{ {
"command": "vscode-appwrite.deletePermission", "command": "vscode-appwrite.deletePermission",
"title": "Delete permission", "title": "Delete permission",
"icon": "$(trash)", "icon": "$(trash)"
"category": "Appwrite"
}, },
{ {
"command": "vscode-appwrite.editPermission", "command": "vscode-appwrite.editPermission",
"title": "Edit permission", "title": "Edit permission",
"icon": "$(edit)", "icon": "$(edit)"
"category": "Appwrite"
}, },
{ {
"command": "vscode-appwrite.refreshHealth", "command": "vscode-appwrite.refreshHealth",
"title": "Refresh health", "title": "Refresh health",
"icon": "$(refresh)", "icon": "$(refresh)"
"category": "Appwrite"
}, },
{ {
"command": "vscode-appwrite.openHealthDocumentation", "command": "vscode-appwrite.openHealthDocumentation",
"title": "Open health documentation", "title": "Open health documentation",
"icon": "$(book)", "icon": "$(book)"
"category": "Appwrite"
}, },
{ {
"command": "vscode-appwrite.refreshStorage", "command": "vscode-appwrite.refreshStorage",
"title": "Refresh storage", "title": "Refresh storage",
"icon": "$(refresh)", "icon": "$(refresh)"
"category": "Appwrite"
}, },
{ {
"command": "vscode-appwrite.openStorageDocumentation", "command": "vscode-appwrite.openStorageDocumentation",
"title": "Open storage documentation", "title": "Open storage documentation",
"icon": "$(book)", "icon": "$(book)"
"category": "Appwrite"
}, },
{ {
"command": "vscode-appwrite.addProject", "command": "vscode-appwrite.addProject",
"title": "Add Appwrite project", "title": "Add Appwrite project",
"icon": "$(plus)", "icon": "$(plus)"
"category": "Appwrite"
}, },
{ {
"command": "vscode-appwrite.setActiveProject", "command": "vscode-appwrite.setActiveProject",
"title": "Set as active", "title": "Set as active"
"category": "Appwrite"
}, },
{ {
"command": "vscode-appwrite.refreshProjects", "command": "vscode-appwrite.refreshProjects",
"title": "Refresh projects", "title": "Refresh projects",
"icon": "$(refresh)",
"category": "Appwrite"
},
{
"command": "vscode-appwrite.refreshFunctions",
"title": "Refresh functions",
"icon": "$(refresh)",
"category": "Appwrite"
},
{
"command": "vscode-appwrite.refreshFunctions",
"title": "Refresh functions",
"icon": "$(refresh)" "icon": "$(refresh)"
}, },
{ {
"command": "vscode-appwrite.removeProject", "command": "vscode-appwrite.removeProject",
"title": "Remove project", "title": "Remove project",
"icon": "$(trash)", "icon": "$(trash)"
"category": "Appwrite"
},
{
"command": "vscode-appwrite.CreateTag",
"title": "Create function tag",
"icon": "$(cloud-upload)",
"shortTitle": "Create function tag",
"category": "Appwrite"
},
{
"command": "vscode-appwrite.deleteTag",
"title": "Delete tag",
"icon": "$(trash)",
"category": "Appwrite"
},
{
"command": "vscode-appwrite.CreateExecution",
"title": "Execute",
"category": "Appwrite"
},
{
"command": "vscode-appwrite.activateTag",
"title": "Activate",
"category": "Appwrite"
},
{
"command": "vscode-appwrite.editValue",
"title": "Edit",
"icon": "$(edit)",
"category": "Appwrite"
},
{
"command": "vscode-appwrite.deleteFunction",
"title": "Delete",
"icon": "$(trash)",
"category": "Appwrite"
},
{
"command": "vscode-appwrite.openFunctionsDocumentation",
"title": "Open functions documentation",
"icon": "$(book)",
"category": "Appwrite"
},
{
"command": "vscode-appwrite.createFunction",
"title": "Create function",
"icon": "$(add)",
"category": "Appwrite"
},
{
"command": "vscode-appwrite.createFunctionVar",
"title": "Create variable",
"icon": "$(add)",
"category": "Appwrite"
},
{
"command": "vscode-appwrite.deleteFunctionVar",
"title": "Delete variable",
"icon": "$(trash)",
"category": "Appwrite"
},
{
"command": "vscode-appwrite.viewExecutionOutput",
"title": "View execution stdout",
"enablement": "viewItem =~ /^((execution|execution_outputOnly))$/",
"category": "Appwrite"
},
{
"command": "vscode-appwrite.viewExecutionErrors",
"title": "View execution stderr",
"enablement": "viewItem =~ /^((execution|execution_errorOnly))$/",
"category": "Appwrite"
},
{
"command": "vscode-appwrite.copyExecutionOutput",
"title": "Copy execution stdout",
"enablement": "viewItem =~ /^((execution|execution_outputOnly))$/",
"category": "Appwrite"
},
{
"command": "vscode-appwrite.copyExecutionErrors",
"title": "Copy execution stderr",
"enablement": "viewItem =~ /^((execution|execution_errorOnly))$/",
"category": "Appwrite"
},
{
"command": "vscode-appwrite.openExecutionsInBrowser",
"title": "View executions in browser",
"enablement": "viewItem =~ /^(executions)$/",
"icon": "$(link-external)",
"category": "Appwrite"
},
{
"command": "vscode-appwrite.openFunctionTagsInBrowser",
"title": "Open function tags in browser",
"icon": "$(link-external)",
"category": "Appwrite"
},
{
"command": "vscode-appwrite.openFunctionSettingsInBrowser",
"title": "Open function settings in browser",
"icon": "$(link-external)",
"category": "Appwrite"
},
{
"command": "vscode-appwrite.viewMore",
"title": "View more",
"category": "Appwrite"
} }
], ],
"views": { "views": {
@ -362,10 +211,6 @@
{ {
"id": "Projects", "id": "Projects",
"name": "Projects" "name": "Projects"
},
{
"id": "Functions",
"name": "Functions (Preview)"
} }
] ]
}, },
@ -431,24 +276,14 @@
"when": "view == Storage", "when": "view == Storage",
"group": "navigation" "group": "navigation"
}, },
{
"command": "vscode-appwrite.openFunctionsDocumentation",
"when": "view == Functions",
"group": "navigation"
},
{ {
"command": "vscode-appwrite.refreshProjects", "command": "vscode-appwrite.refreshProjects",
"when": "view == Projects", "when": "view == Projects",
"group": "navigation" "group": "navigation"
}, },
{ {
"command": "vscode-appwrite.refreshFunctions", "command": "vscode-appwrite.addProject",
"when": "view == Functions", "when": "view == Projects",
"group": "navigation"
},
{
"command": "vscode-appwrite.createFunction",
"when": "view == Functions",
"group": "navigation" "group": "navigation"
} }
], ],
@ -548,91 +383,9 @@
{ {
"command": "vscode-appwrite.removeProject", "command": "vscode-appwrite.removeProject",
"when": "viewItem =~ /(appwriteProject)/" "when": "viewItem =~ /(appwriteProject)/"
},
{
"command": "vscode-appwrite.CreateExecution",
"when": "viewItem =~ /^(function)$/",
"group": "inline"
},
{
"command": "vscode-appwrite.activateTag",
"when": "viewItem =~ /^(tag)$/",
"group": "inline"
},
{
"command": "vscode-appwrite.editValue",
"when": "viewItem =~ /^(editable)/",
"group": "inline"
},
{
"command": "vscode-appwrite.deleteFunction",
"when": "viewItem =~ /^(function)$/"
},
{
"command": "vscode-appwrite.deleteFunctionVar",
"when": "viewItem =~ /(var)$/"
},
{
"command": "vscode-appwrite.createFunctionVar",
"when": "viewItem =~ /^(vars)$/",
"group": "inline"
},
{
"command": "vscode-appwrite.deleteTag",
"when": "viewItem =~ /^(tag)$/"
},
{
"command": "vscode-appwrite.viewExecutionErrors",
"when": "viewItem =~ /^execution[^s]*$/",
"group": "view@1"
},
{
"command": "vscode-appwrite.viewExecutionOutput",
"when": "viewItem =~ /^execution[^s]*$/",
"group": "view@1"
},
{
"command": "vscode-appwrite.copyExecutionErrors",
"when": "viewItem =~ /^execution[^s]*$/",
"group": "copy@2"
},
{
"command": "vscode-appwrite.copyExecutionOutput",
"when": "viewItem =~ /^execution[^s]*$/",
"group": "copy@2"
},
{
"command": "vscode-appwrite.openExecutionsInBrowser",
"when": "viewItem =~ /^executions$/",
"group": "inline"
},
{
"command": "vscode-appwrite.openFunctionTagsInBrowser",
"when": "viewItem =~ /^tags$/",
"group": "inline"
},
{
"command": "vscode-appwrite.openFunctionSettingsInBrowser",
"when": "viewItem =~ /^functionSettings$/",
"group": "inline"
},
{
"command": "vscode-appwrite.CreateTag",
"when": "viewItem =~ /^tags$/",
"group": "inline"
}
],
"explorer/context": [
{
"command": "vscode-appwrite.CreateTag",
"when": "explorerResourceIsFolder == true",
"group": "appwrite@1"
} }
], ],
"commandPalette": [ "commandPalette": [
{
"command": "vscode-appwrite.CreateTag"
},
{ {
"command": "vscode-appwrite.Connect" "command": "vscode-appwrite.Connect"
}, },
@ -726,11 +479,6 @@
"type": "string", "type": "string",
"default": "", "default": "",
"markdownDescription": "Project id of the active project, see [docs](https://github.com/streamlux/vscode-appwrite/) for more information." "markdownDescription": "Project id of the active project, see [docs](https://github.com/streamlux/vscode-appwrite/) for more information."
},
"appwrite.formatJsonStrings": {
"type": "boolean",
"default": true,
"markdownDescription": "Format JSON strings when viewing documents"
} }
} }
} }
@ -751,7 +499,6 @@
"@types/glob": "^7.1.3", "@types/glob": "^7.1.3",
"@types/mocha": "^8.0.4", "@types/mocha": "^8.0.4",
"@types/node": "^12.11.7", "@types/node": "^12.11.7",
"@types/tar": "^4.0.4",
"@types/vscode": "^1.55.0", "@types/vscode": "^1.55.0",
"@typescript-eslint/eslint-plugin": "^4.14.1", "@typescript-eslint/eslint-plugin": "^4.14.1",
"@typescript-eslint/parser": "^4.14.1", "@typescript-eslint/parser": "^4.14.1",
@ -766,11 +513,8 @@
"webpack-cli": "^4.4.0" "webpack-cli": "^4.4.0"
}, },
"dependencies": { "dependencies": {
"cron-validate": "^1.4.3",
"cronstrue": "^1.113.0",
"dayjs": "^1.10.4", "dayjs": "^1.10.4",
"fs-extra": "^9.1.0", "fs-extra": "^9.1.0",
"node-appwrite": "^2.2.3", "node-appwrite": "^2.1.0"
"tar": "^6.1.0"
} }
} }

97
src/appwrite.d.ts vendored
View file

@ -1,6 +1,3 @@
import { ReadStream } from 'fs';
import { Stream } from 'node:stream';
export type Token = { export type Token = {
/** /**
* Token ID. * Token ID.
@ -276,7 +273,7 @@ export type CollectionsList = {
collections: Collection[]; collections: Collection[];
}; };
export type CreatedRule = Omit<Rule, "$id" | "$collection">; export type CreatedRule = Omit<Rule, "$id" | "$collection" | "default" | "list">;
export type Rule = { export type Rule = {
$id: string; $id: string;
@ -284,13 +281,13 @@ export type Rule = {
type: string; type: string;
key: string; key: string;
label: string; label: string;
default?: any; default: string;
required: boolean;
array: boolean; array: boolean;
list?: string[]; required: boolean;
list: string[];
}; };
export type Permissions = { interface Permissions {
read: string[]; read: string[];
write: string[]; write: string[];
} }
@ -305,7 +302,7 @@ export type Client = {
setSelfSigned: (value: boolean) => void; setSelfSigned: (value: boolean) => void;
}; };
export type UsersClient = { export type UsersClient = {
delete: (id: string) => Promise<any>; deleteUser: (id: string) => Promise<any>;
deleteSessions: (id: string) => Promise<any>; deleteSessions: (id: string) => Promise<any>;
create: (email: string, password: string, name?: string) => Promise<any>; create: (email: string, password: string, name?: string) => Promise<any>;
getLogs: (id: string) => Promise<Log[]>; getLogs: (id: string) => Promise<Log[]>;
@ -359,90 +356,11 @@ export type AppwriteHealth = {
}; };
export type StorageClient = { 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>;
}; };
type Vars = Record<string, any>;
export type Function = {
'$id': string;
'$permissions': Permissions;
name: string;
dateCreated: number;
dateUpdated: number;
status: string;
env: string;
tag: string;
vars: Vars;
events: string[];
schedule: string;
scheduleNext: number;
schedulePrevious: number;
timeout: number;
}
export type FunctionsList = {
sum: number;
functions: Function[];
}
export type Tag = {
'$id': string;
functionId: string;
dateCreated: number;
command: string;
size: string;
};
export type TagList = {
sum: number;
tags: Tag[];
}
export type ExecutionStatus = "waiting" | "processing" | "completed" | "failed";
export type Execution = {
'$id': string;
functionId: string;
dateCreated: number;
trigger: string;
status: ExecutionStatus;
exitCode: number;
stdout: string;
stderr: string;
time: number;
};
export type ExecutionList = {
sum: number;
executions: Execution[];
};
export type Search = {
search?: string;
limit?: number;
offset?: number;
orderType?: 'ASC' | 'DESC';
};
export type FunctionsClient = {
create: (name: string, execute: string[], env: string, vars?: Vars, events?: string[], schedule?: string, timeout?: number) => Promise<any>;
list: (search?: string, offset?: number, limit?: number, orderType?: 'ASC' | 'DESC') => Promise<any>;
get: (functionId: string) => Promise<any>;
update: (functionId: string, name: string, execute: string[], vars?: Vars, events?: string[], schedule?: string, timeout?: number) => Promise<any>;
updateTag: (functionId: string, tagId: string) => Promise<any>;
delete: (functionId: string) => Promise<any>;
createTag: (id: string, command: string, code: ReadStream) => Promise<any>;
listTags: (id: string, search?: string, limit?: number, offset?: number, orderType?: 'ASC' | 'DESC') => Promise<any>;
getTag: (functionId: string, tagId: string) => Promise<any>;
deleteTag: (functionId: string, tagId: string) => Promise<any>;
createExecution: (functionId: string, data?: string) => Promise<any>;
listExecutions: (functionId: string, search?: string, limit?: number, offset?: number, orderType?: 'ASC' | 'DESC') => Promise<any>;
getExecution: (functionId: string, executionId: string) => Promise<any>;
}
export type SDK = { export type SDK = {
Client: new () => Client; Client: new () => Client;
@ -450,5 +368,4 @@ export type SDK = {
Health: new (client: Client) => HealthClient; Health: new (client: Client) => HealthClient;
Database: new (client: Client) => DatabaseClient; Database: new (client: Client) => DatabaseClient;
Storage: new (client: Client) => StorageClient; Storage: new (client: Client) => StorageClient;
Functions: new (client: Client) => FunctionsClient;
}; };

View file

@ -1,52 +0,0 @@
import { Client, Execution, ExecutionList, FunctionsClient, FunctionsList, Tag, TagList, Vars } from "../appwrite";
import { AppwriteSDK } from '../constants';
import AppwriteCall from '../utils/AppwriteCall';
import { ReadStream } from 'node:fs';
export class Functions {
public readonly functions: FunctionsClient;
constructor(client: Client) {
this.functions = new AppwriteSDK.Functions(client);
}
public async create(name: string, execute: string[], env: string, vars?: Vars, events?: string[], schedule?: string, timeout?: number): Promise<any> {
return await AppwriteCall(this.functions.create(name, execute, env, vars, events, schedule, timeout));
}
public async list(search?: string, offset?: number, limit?: number, orderType?: 'ASC' | 'DESC'): Promise<FunctionsList | undefined> {
return await AppwriteCall(this.functions.list(search, offset, limit, orderType));
}
public async get(functionId: string): Promise<any> {
return await AppwriteCall(this.functions.get(functionId));
}
public async update(functionId: string, name: string, execute: string[], vars?: Vars, events?: string[], schedule?: string, timeout?: number): Promise<any> {
return await AppwriteCall(this.functions.update(functionId, name, execute, vars, events, schedule, timeout));
}
public async updateTag(functionId: string, tagId: string): Promise<any> {
return await AppwriteCall(this.functions.updateTag(functionId, tagId));
}
public async delete(functionId: string): Promise<void> {
return await AppwriteCall(this.functions.delete(functionId));
}
public async createTag(functionId: string, command: string, code: ReadStream): Promise<Tag | undefined> {
return await AppwriteCall(this.functions.createTag(functionId, command, code));
}
public async listTags(id: string, search?: string, limit?: number, offset?: number, orderType?: 'ASC' | 'DESC'): Promise<TagList | undefined> {
return await AppwriteCall<TagList>(this.functions.listTags(id, search, offset, limit, orderType));
}
public async getTag(functionId: string, tagId: string): Promise<any> {
return await AppwriteCall(this.functions.getTag(functionId, tagId));
}
public async deleteTag(functionId: string, tagId: string): Promise<void> {
return await AppwriteCall(this.functions.deleteTag(functionId, tagId));
}
public async createExecution(functionId: string, data?: string): Promise<Execution | undefined> {
return await AppwriteCall(this.functions.createExecution(functionId, data));
}
public async listExecutions(functionId: string, search?: string, limit?: number, offset?: number, orderType?: 'ASC' | 'DESC'): Promise<ExecutionList | undefined> {
return await AppwriteCall(this.functions.listExecutions(functionId, search, limit, offset, orderType));
}
public async getExecution(functionId: string, executionId: string): Promise<Execution | undefined> {
return await AppwriteCall(this.functions.getExecution(functionId, executionId));
}
}

View file

@ -11,7 +11,7 @@ export class Health {
/** /**
* @returns The health of all Appwrite services. * @returns The health of all Appwrite services.
*/ */
public async checkup(): Promise<Partial<AppwriteHealth>> { public async checkup(): Promise<AppwriteHealth> {
return { return {
HTTP: await this.health.get(), HTTP: await this.health.get(),
DB: await this.health.getDB(), DB: await this.health.getDB(),

View file

@ -1,4 +1,3 @@
import { ReadStream } from 'node:fs';
import { Client, FilesList, StorageClient } from "../appwrite"; import { Client, FilesList, StorageClient } from "../appwrite";
import { AppwriteSDK } from '../constants'; import { AppwriteSDK } from '../constants';
import AppwriteCall from "../utils/AppwriteCall"; import AppwriteCall from "../utils/AppwriteCall";
@ -13,8 +12,4 @@ export class Storage {
public async listFiles(): Promise<FilesList | undefined> { public async listFiles(): Promise<FilesList | undefined> {
return await AppwriteCall(this.storage.listFiles()); return await AppwriteCall(this.storage.listFiles());
} }
public async createFile(file: ReadStream): Promise<void> {
return await AppwriteCall(this.storage.createFile(file));
}
} }

View file

@ -16,7 +16,7 @@ export class Users {
} }
public async delete(userId: string): Promise<void> { public async delete(userId: string): Promise<void> {
await AppwriteCall(this.users.delete(userId), () => { await AppwriteCall(this.users.deleteUser(userId), () => {
window.showInformationMessage(`Deleted user with id: ${userId}.`); window.showInformationMessage(`Deleted user with id: ${userId}.`);
}); });
} }

View file

@ -1,6 +1,5 @@
import { Client } from "./appwrite"; import { Client } from "./appwrite";
import { Database } from "./appwrite/Database"; import { Database } from "./appwrite/Database";
import { Functions } from './appwrite/Functions';
import { Health } from "./appwrite/Health"; import { Health } from "./appwrite/Health";
import { Storage } from "./appwrite/Storage"; import { Storage } from "./appwrite/Storage";
import { Users } from "./appwrite/Users"; import { Users } from "./appwrite/Users";
@ -13,8 +12,6 @@ export let usersClient: Users | undefined;
export let healthClient: Health | undefined; export let healthClient: Health | undefined;
export let databaseClient: Database | undefined; export let databaseClient: Database | undefined;
export let storageClient: Storage | undefined; export let storageClient: Storage | undefined;
export let functionsClient: Functions | undefined;
function initAppwriteClient({ endpoint, projectId, secret, selfSigned }: AppwriteProjectConfiguration) { function initAppwriteClient({ endpoint, projectId, secret, selfSigned }: AppwriteProjectConfiguration) {
client = new AppwriteSDK.Client(); client = new AppwriteSDK.Client();
@ -25,7 +22,6 @@ function initAppwriteClient({ endpoint, projectId, secret, selfSigned }: Appwrit
healthClient = new Health(client); healthClient = new Health(client);
databaseClient = new Database(client); databaseClient = new Database(client);
storageClient = new Storage(client); storageClient = new Storage(client);
functionsClient = new Functions(client);
return client; return client;
} }
@ -40,5 +36,4 @@ export function createAppwriteClient(config?: AppwriteProjectConfiguration): voi
healthClient = undefined; healthClient = undefined;
databaseClient = undefined; databaseClient = undefined;
storageClient = undefined; storageClient = undefined;
functionsClient = undefined;
} }

View file

@ -1,9 +0,0 @@
import { EditableTreeItem } from '../../tree/common/editable/SimpleEditableTreeItem';
export async function editValue(treeItem: EditableTreeItem): Promise<void> {
if (treeItem === undefined) {
return;
}
await treeItem.prompt();
}

View file

@ -1,5 +0,0 @@
import { AppwriteTreeItemBase } from '../../ui/AppwriteTreeItemBase';
export async function viewMore(treeItem: AppwriteTreeItemBase<any>): Promise<void> {
await treeItem.viewMore();
}

View file

@ -10,13 +10,15 @@ export async function createRule(rulesTreeItem: RulesTreeItem): Promise<void> {
return; return;
} }
const ruleContext = await createRuleWizard();
const collection = rulesTreeItem.parent.collection; const collection = rulesTreeItem.parent.collection;
const ruleContext = await createRuleWizard(collection);
if (ruleContext) { if (ruleContext) {
const newRule: CreatedRule = { const newRule: CreatedRule = {
...ruleContext, ...ruleContext,
type: ruleContext.type, type: ruleContext.type,
required: true,
array: false,
}; };
databaseClient.createRule(collection, newRule); databaseClient.createRule(collection, newRule);

View file

@ -1,30 +1,8 @@
import { workspace } from "vscode";
import { DocumentTreeItem } from "../../tree/database/DocumentTreeItem"; import { DocumentTreeItem } from "../../tree/database/DocumentTreeItem";
import { openReadOnlyJson } from "../../ui/openReadonlyContent"; import { openReadOnlyJson } from "../../ui/openReadonlyContent";
function parseJSONString(str: string): { valid: boolean; value: any } {
try {
return { value: JSON.parse(str), valid: true };
} catch (e) {
return { value: str, valid: false };
}
}
export async function viewDocumentAsJson(documentTreeItem: DocumentTreeItem): Promise<void> { export async function viewDocumentAsJson(documentTreeItem: DocumentTreeItem): Promise<void> {
const document = documentTreeItem.document; const documentId = documentTreeItem.document["$id"];
const documentId = document["$id"];
const formatJsonStrings = workspace.getConfiguration("appwrite").get<Boolean>("formatJsonStrings");
if (formatJsonStrings) {
Object.entries(document).forEach(([key, value]) => {
if (typeof value === "string") {
const result = parseJSONString(value);
document[key] = result.value;
}
});
}
await openReadOnlyJson( await openReadOnlyJson(
{ {
label: documentId, label: documentId,

View file

@ -1,8 +0,0 @@
import { Tag } from '../../appwrite';
import { functionsClient } from '../../client';
import { TagTreeItem } from '../../tree/functions/tags/TagTreeItem';
export async function activateTag(tagItem: TagTreeItem | Tag): Promise<void> {
const tag = tagItem instanceof TagTreeItem ? tagItem.tag : tagItem;
await functionsClient?.updateTag(tag.functionId, tag.$id);
}

View file

@ -1,11 +0,0 @@
import { env } from 'vscode';
import { ExecutionTreeItem } from "../../tree/functions/executions/ExecutionTreeItem";
export async function copyExecutionErrors(executionItem: ExecutionTreeItem): Promise<void> {
if (executionItem === undefined) {
return;
}
const execution = executionItem.execution;
env.clipboard.writeText(execution.stderr);
}

View file

@ -1,11 +0,0 @@
import { env } from 'vscode';
import { ExecutionTreeItem } from "../../tree/functions/executions/ExecutionTreeItem";
export async function copyExecutionOutput(executionItem: ExecutionTreeItem): Promise<void> {
if (executionItem === undefined) {
return;
}
const execution = executionItem.execution;
env.clipboard.writeText(execution.stdout);
}

View file

@ -1,57 +0,0 @@
import { window } from 'vscode';
import { Execution } from '../../appwrite';
import { functionsClient } from '../../client';
import { ext } from '../../extensionVariables';
import { FunctionTreeItem } from '../../tree/functions/FunctionTreeItem';
import { sleep } from '../../utils/sleep';
import { viewExecutionErrors } from './viewExecutionErrors';
import { viewExecutionOutput } from './viewExecutionOutput';
export async function createExecution(functionTreeItem: FunctionTreeItem): Promise<void> {
const func = functionTreeItem.func;
await executeFunction(func.$id);
}
export async function executeFunction(functionId: string): Promise<void> {
ext.outputChannel.appendLog(`Creating execution for function with ID: ${functionId}`);
let execution = await functionsClient?.createExecution(functionId);
ext.outputChannel.appendLog(JSON.stringify(execution, null, 2));
await ext.tree?.functions?.refresh();
if (execution === undefined) {
return;
}
execution = await waitForExecution(execution);
ext.tree?.functions?.refresh();
if (execution === undefined) {
return;
}
const failed = execution.status === "failed";
const item = !failed ? "View output" : "View errors";
const action = await window.showInformationMessage(`Execution ${failed ? "failed" : "completed"} in ${execution.time.toFixed(2)}s.`, item);
if (action === item) {
if (item === "View output") {
await viewExecutionOutput(execution);
return;
}
await viewExecutionErrors(execution);
return;
}
}
async function waitForExecution(execution: Execution | undefined): Promise<Execution | undefined> {
if (execution === undefined) {
return;
}
if (execution.status === "processing" || execution.status === "waiting") {
await sleep(5000);
ext.outputChannel.appendLog("Execution still ...");
return await waitForExecution(await functionsClient?.getExecution(execution.functionId, execution.$id));
}
return execution;
}

View file

@ -1,19 +0,0 @@
import { window } from 'vscode';
import { functionsClient } from '../../client';
import { appwriteFunctionRuntimes } from '../../constants';
import { validateFunctionName } from '../../tree/functions/settings/NameTreeItem';
export async function createFunction(): Promise<void> {
const name = await window.showInputBox({ prompt: 'Function name', validateInput: validateFunctionName });
if (name === undefined) {
return;
}
const env: string | undefined = await window.showQuickPick(appwriteFunctionRuntimes);
if (env === undefined) {
return;
}
await functionsClient?.create(name, [], env);
}

View file

@ -1,16 +0,0 @@
import { functionsClient } from '../../client';
import { VarsTreeItem } from '../../tree/functions/settings/VarsTreeItem';
import { keyValuePrompt } from '../../tree/functions/settings/VarTreeItem';
export async function createFunctionVar(treeItem: VarsTreeItem): Promise<void> {
if (treeItem === undefined) {
return;
}
const func = treeItem.parent.func;
const keyval = await keyValuePrompt();
if (keyval) {
const newVars = {...func.vars};
newVars[keyval.key] = keyval.value;
await functionsClient?.update(func.$id, func.name, [], newVars, func.events, func.schedule, func.timeout);
}
}

View file

@ -1,164 +0,0 @@
import { ProgressLocation, QuickPickItem, Uri, window, workspace } from "vscode";
import { functionsClient } from "../../client";
import { getTarReadStream } from "../../utils/tar";
import { ext } from "../../extensionVariables";
import * as fs from "fs";
import { TagsTreeItem } from "../../tree/functions/tags/TagsTreeItem";
import { selectWorkspaceFolder } from "../../utils/workspace";
import { ProgressMessage } from "../../utils/types";
import { Tag } from "../../appwrite";
import { activateTag } from "./activateTag";
export async function createTag(item?: TagsTreeItem | Uri): Promise<void> {
if (item instanceof Uri) {
const functions = await functionsClient?.list();
if (functions === undefined) {
return;
}
const pick = await window.showQuickPick(
functions.functions.map<QuickPickItem>(
(func): QuickPickItem => ({ label: func.name, description: func.env, detail: func.$id })
),
{ placeHolder: "Select a function to create tag" }
);
if (pick === undefined || pick.detail === undefined) {
return;
}
const tags = await functionsClient?.listTags(pick.detail);
let value;
if (tags && tags.tags.length > 0) {
value = tags.tags[tags.tags.length - 1].command;
}
const command = await window.showInputBox({ value, prompt: "Command to run your code" });
if (command === undefined) {
return;
}
const tag = await window.withProgress(
{ location: ProgressLocation.Notification, title: "Creating tag..." },
async (progress, _token) => {
if (pick.detail === undefined) {
return;
}
return await createTagFromUri(pick.detail, command, item, progress);
}
);
if (tag) {
await tagNotification(tag);
}
return;
}
if (item instanceof TagsTreeItem) {
const func = item.parent.func;
const folder = await selectWorkspaceFolder("Select folder of your function code.");
if (folder === undefined || folder === "") {
return;
}
const tags = await functionsClient?.listTags(func.$id);
let value;
if (tags && tags.tags.length > 0) {
value = tags.tags[tags.tags.length - 1].command;
}
const command = await window.showInputBox({ value, prompt: "Command to run your code" });
if (command === undefined) {
return;
}
const tag = await window.withProgress(
{ location: ProgressLocation.Notification, title: "Creating tag..." },
async (progress, _token) => {
return await createTagFromUri(func.$id, command, Uri.parse(folder), progress);
}
);
if (tag) {
await tagNotification(tag);
return;
}
}
if (item === undefined) {
const functions = await functionsClient?.list();
if (functions === undefined) {
return;
}
const pick = await window.showQuickPick(
functions.functions.map<QuickPickItem>(
(func): QuickPickItem => ({ label: func.name, description: func.env, detail: func.$id })
),
{ placeHolder: "Select a function to create tag" }
);
if (pick === undefined || pick.detail === undefined) {
return;
}
const funcId = pick.detail;
const folder = await selectWorkspaceFolder("Select folder of your function code.");
const tags = await functionsClient?.listTags(funcId);
let value;
if (tags && tags.tags.length > 0) {
value = tags.tags[tags.tags.length - 1].command;
}
const command = await window.showInputBox({ value, prompt: "Command to run your code" });
if (command === undefined) {
return;
}
const tag = await window.withProgress(
{ location: ProgressLocation.Notification, title: "Creating tag..." },
async (progress, _token) => {
return await createTagFromUri(funcId, command, Uri.parse(folder), progress);
}
);
if (tag) {
await tagNotification(tag);
return;
}
}
}
async function createTagFromUri(functionId: string, command: string, uri: Uri, progress: ProgressMessage): Promise<Tag | undefined> {
progress.report({ message: "Creating tarball", increment: 10 });
if (functionsClient === undefined) {
return;
}
let tarFilePath;
try {
tarFilePath = await getTarReadStream(uri);
} catch (e) {
window.showErrorMessage("Error creating tar file.\n" + e);
return;
}
if (tarFilePath === undefined) {
window.showErrorMessage("Failed to create tar file.");
ext.outputChannel.appendLog("Failed to create tar file.");
return;
}
// somehow makes the upload work
await workspace.fs.readFile(Uri.file(tarFilePath));
progress.report({ message: "Uploading tag", increment: 60 });
try {
return await functionsClient.createTag(functionId, command, fs.createReadStream(tarFilePath));
} catch (e) {
ext.outputChannel.appendLog("Creating tag error: " + e);
}
}
async function tagNotification(tag: Tag): Promise<void> {
ext.tree?.functions?.refresh();
if (tag) {
const action = await window.showInformationMessage(
`Successfully created tag with size ${tag.size}B.`,
"Activate tag",
"View in console"
);
if (action === "Activate tag") {
await activateTag(tag);
}
if (action === "View in console") {
//
}
return;
}
}

View file

@ -1,9 +0,0 @@
import { functionsClient } from '../../client';
import { FunctionTreeItem } from '../../tree/functions/FunctionTreeItem';
export async function deleteFunction(treeItem: FunctionTreeItem): Promise<void> {
if (!treeItem) {
return;
}
await functionsClient?.delete(treeItem.func.$id);
}

View file

@ -1,13 +0,0 @@
import { functionsClient } from '../../client';
import { VarTreeItem } from '../../tree/functions/settings/VarTreeItem';
export async function deleteFunctionVar(treeItem: VarTreeItem): Promise<void> {
if (treeItem === undefined) {
return;
}
const func = treeItem.func;
const newVars = {...func.vars};
delete newVars[treeItem.key];
await functionsClient?.update(func.$id, func.name, [], newVars, func.events, func.schedule, func.timeout);
}

View file

@ -1,11 +0,0 @@
import { functionsClient } from "../../client";
import { TagTreeItem } from "../../tree/functions/tags/TagTreeItem";
export async function deleteTag(tagItem: TagTreeItem): Promise<void> {
if (tagItem === undefined) {
return;
}
const func = tagItem.parent.parent.func;
await functionsClient?.deleteTag(func.$id, tagItem.tag.$id);
}

View file

@ -1,15 +0,0 @@
import { clientConfig } from '../../client';
import { ExecutionsTreeItem } from '../../tree/functions/executions/ExecutionsTreeItem';
import { openUrl } from '../../utils/openUrl';
import { getConsoleUrlFromEndpoint } from '../users/openUserInConsole';
export async function openExecutionsInBrowser(treeItem: ExecutionsTreeItem): Promise<void> {
const func = treeItem.parent.func;
const consoleUrl = getConsoleUrlFromEndpoint(clientConfig.endpoint);
// https://console.streamlux.com/console/functions/function/logs?id=60b1836a8e5d9&project=605ce39a30c01
const url = `${consoleUrl}/functions/function/logs?id=${func.$id}&project=${clientConfig.projectId}`;
openUrl(url);
}

View file

@ -1,15 +0,0 @@
import { clientConfig } from '../../client';
import { ExecutionsTreeItem } from '../../tree/functions/executions/ExecutionsTreeItem';
import { openUrl } from '../../utils/openUrl';
import { getConsoleUrlFromEndpoint } from '../users/openUserInConsole';
export async function openFunctionSettingsInBrowser(treeItem: ExecutionsTreeItem): Promise<void> {
const func = treeItem.parent.func;
const consoleUrl = getConsoleUrlFromEndpoint(clientConfig.endpoint);
// https://console.streamlux.com/console/functions/function/settings?id=60b1836a8e5d9&project=605ce39a30c01
const url = `${consoleUrl}/functions/function/settings?id=${func.$id}&project=${clientConfig.projectId}`;
openUrl(url);
}

View file

@ -1,13 +0,0 @@
import { clientConfig } from '../../client';
import { ExecutionsTreeItem } from '../../tree/functions/executions/ExecutionsTreeItem';
import { openUrl } from '../../utils/openUrl';
import { getConsoleUrlFromEndpoint } from '../users/openUserInConsole';
export async function openFunctionTagsInBrowser(treeItem: ExecutionsTreeItem): Promise<void> {
const func = treeItem.parent.func;
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}`;
openUrl(url);
}

View file

@ -1,16 +0,0 @@
import { Execution } from '../../appwrite';
import { ExecutionTreeItem } from "../../tree/functions/executions/ExecutionTreeItem";
import { openReadOnlyContent } from "../../ui/openReadonlyContent";
export async function viewExecutionErrors(executionItem: ExecutionTreeItem | Execution): Promise<void> {
if (executionItem === undefined) {
return;
}
let execution = executionItem as Execution;
if (executionItem instanceof ExecutionTreeItem) {
execution = executionItem.execution;
}
await openReadOnlyContent({ label: `Execution stderr`, fullId: `${execution.$id}-errors.txt` }, execution.stderr, '.txt');
}

View file

@ -1,19 +0,0 @@
import { Execution } from '../../appwrite';
import { ExecutionTreeItem } from "../../tree/functions/executions/ExecutionTreeItem";
import { openReadOnlyContent } from "../../ui/openReadonlyContent";
export async function viewExecutionOutput(executionItem: ExecutionTreeItem | Execution): Promise<void> {
if (executionItem === undefined) {
return;
}
let execution = executionItem as Execution;
if (executionItem instanceof ExecutionTreeItem) {
execution = executionItem.execution;
}
console.log(execution.dateCreated);
await openReadOnlyContent({ label: `Execution stdout`, fullId: `${execution.$id}-output.txt` }, execution.stdout, '.txt');
}

View file

@ -5,8 +5,7 @@ const documentationLinks = {
users: 'https://appwrite.io/docs/server/users', users: 'https://appwrite.io/docs/server/users',
database: 'https://appwrite.io/docs/client/database', database: 'https://appwrite.io/docs/client/database',
health: 'https://appwrite.io/docs/server/health', health: 'https://appwrite.io/docs/server/health',
storage: 'https://appwrite.io/docs/client/storage', storage: 'https://appwrite.io/docs/client/storage'
functions: 'https://appwrite.io/docs/server/functions'
}; };
type DocsPage = keyof typeof documentationLinks; type DocsPage = keyof typeof documentationLinks;

View file

@ -25,24 +25,6 @@ import { viewUserPrefs } from "./users/viewUserPrefs";
import { editPermission } from "./database/permissions/editPermission"; import { editPermission } from "./database/permissions/editPermission";
import { setActiveProject } from "./project/setActiveProject"; import { setActiveProject } from "./project/setActiveProject";
import { removeProject } from "./project/removeProject"; import { removeProject } from "./project/removeProject";
import { createTag } from './functions/createTag';
import { createExecution } from './functions/createExecution';
import { activateTag } from './functions/activateTag';
import { editValue } from './common/editValue';
import { deleteFunction } from './functions/deleteFunction';
import { createFunction } from './functions/createFunction';
import { createFunctionVar } from './functions/createFunctionVar';
import { deleteFunctionVar } from './functions/deleteFunctionVar';
import { deleteTag } from './functions/deleteTag';
import { viewExecutionErrors } from './functions/viewExecutionErrors';
import { viewExecutionOutput } from './functions/viewExecutionOutput';
import { copyExecutionErrors } from './functions/copyExecutionErrors';
import { copyExecutionOutput } from './functions/copyExecutionOutput';
import { openExecutionsInBrowser } from './functions/openExecutionsInBrowser';
import { openFunctionSettingsInBrowser } from './functions/openFunctionSettingsInBrowser';
import { openFunctionTagsInBrowser } from './functions/openFunctionTagsInBrowser';
import { viewMore } from './common/viewMore';
class CommandRegistrar { class CommandRegistrar {
constructor(private readonly context: ExtensionContext) {} constructor(private readonly context: ExtensionContext) {}
@ -74,10 +56,6 @@ export function registerCommands(context: ExtensionContext): void {
}); });
}; };
/** Common **/
registerCommand("editValue", editValue);
registerCommand("viewMore", viewMore);
/** General **/ /** General **/
registerCommand("Connect", connectAppwrite, "all"); registerCommand("Connect", connectAppwrite, "all");
@ -120,23 +98,4 @@ export function registerCommands(context: ExtensionContext): void {
registerCommand("setActiveProject", setActiveProject, "all"); registerCommand("setActiveProject", setActiveProject, "all");
registerCommand("refreshProjects", undefined, "projects"); registerCommand("refreshProjects", undefined, "projects");
registerCommand("removeProject", removeProject, "all"); registerCommand("removeProject", removeProject, "all");
/** Functions **/
registerCommand("refreshFunctions", undefined, "functions");
registerCommand("CreateExecution", createExecution, "functions");
registerCommand("CreateTag", createTag, "functions");
registerCommand("activateTag", activateTag, "functions");
registerCommand("deleteTag", deleteTag, "functions");
registerCommand("deleteFunction", deleteFunction, "functions");
registerCommand("openFunctionsDocumentation", () => openDocumentation("functions"));
registerCommand("createFunction", createFunction, "functions");
registerCommand("createFunctionVar", createFunctionVar, "functions");
registerCommand("deleteFunctionVar", deleteFunctionVar, "functions");
registerCommand("viewExecutionErrors", viewExecutionErrors);
registerCommand("viewExecutionOutput", viewExecutionOutput);
registerCommand("copyExecutionOutput", copyExecutionOutput);
registerCommand("copyExecutionErrors", copyExecutionErrors);
registerCommand("openExecutionsInBrowser", openExecutionsInBrowser);
registerCommand("openFunctionTagsInBrowser", openFunctionTagsInBrowser);
registerCommand("openFunctionSettingsInBrowser", openFunctionSettingsInBrowser);
} }

View file

@ -20,7 +20,7 @@ export async function deleteUser(userTreeItem: UserTreeItem): Promise<void> {
); );
if (shouldDeleteUser === DialogResponses.yes) { if (shouldDeleteUser === DialogResponses.yes) {
await usersClient.delete(userId); await usersClient.delete(userId);
refreshTree("users"); refreshTree("users");
} }
} }

View file

@ -3,7 +3,7 @@ import { commands, Uri } from "vscode";
import { clientConfig } from "../../client"; import { clientConfig } from "../../client";
import { UserTreeItem } from "../../tree/users/UserTreeItem"; import { UserTreeItem } from "../../tree/users/UserTreeItem";
export function getConsoleUrlFromEndpoint(endpoint: string): string { function getConsoleUrlFromEndpoint(endpoint: string): string {
const url = new URL(endpoint); const url = new URL(endpoint);
return `${url.origin}/console`; return `${url.origin}/console`;
} }

View file

@ -1,197 +1,4 @@
import type { SDK } from "./appwrite"; import type { SDK } from './appwrite';
// eslint-disable-next-line @typescript-eslint/no-var-requires // eslint-disable-next-line @typescript-eslint/no-var-requires
export const AppwriteSDK: SDK = require("node-appwrite") as SDK; export const AppwriteSDK: SDK = require('node-appwrite') as SDK;
export const appwriteSystemEvents = [
{
name: "account.create",
description: "This event triggers when the account is created.",
},
{
name: "account.update.email",
description: "This event triggers when the account email address is updated.",
},
{
name: "account.update.name",
description: "This event triggers when the account name is updated.",
},
{
name: "account.update.password",
description: "This event triggers when the account password is updated.",
},
{
name: "account.update.prefs",
description: "This event triggers when the account preferences are updated.",
},
{
name: "account.recovery.create",
description: "This event triggers when the account recovery token is created.",
},
{
name: "account.recovery.update",
description: "This event triggers when the account recovery token is validated.",
},
{
name: "account.verification.create",
description: "This event triggers when the account verification token is created.",
},
{
name: "account.verification.update",
description: "This event triggers when the account verification token is validated.",
},
{
name: "account.delete",
description: "This event triggers when the account is deleted.",
},
{
name: "account.sessions.create",
description: "This event triggers when the account session is created.",
},
{
name: "account.delete",
description: "This event triggers when the account is deleted.",
},
{
name: "account.sessions.create",
description: "This event triggers when the account session is created.",
},
{
name: "account.sessions.delete",
description: "This event triggers when the account session is deleted.",
},
{
name: "database.collections.create",
description: "This event triggers when a database collection is created.",
},
{
name: "database.collections.update",
description: "This event triggers when a database collection is updated.",
},
{
name: "database.collections.delete",
description: "This event triggers when a database collection is deleted.",
},
{
name: "database.documents.create",
description: "This event triggers when a database document is created.",
},
{
name: "database.documents.update",
description: "This event triggers when a database document is updated.",
},
{
name: "database.documents.delete",
description: "This event triggers when a database document is deleted.",
},
{
name: "functions.create",
description: "This event triggers when a function is created.",
},
{
name: "functions.update",
description: "This event triggers when a function is updated.",
},
{
name: "functions.delete",
description: "This event triggers when a function is deleted.",
},
{
name: "functions.tags.create",
description: "This event triggers when a function tag is created.",
},
{
name: "functions.tags.update",
description: "This event triggers when a function tag is updated.",
},
{
name: "functions.tags.delete",
description: "This event triggers when a function tag is deleted.",
},
{
name: "functions.executions.create",
description: "This event triggers when a function execution is created.",
},
{
name: "functions.executions.update",
description: "This event triggers when a function execution is updated.",
},
{
name: "storage.files.create",
description: "This event triggers when a storage file is created.",
},
{
name: "storage.files.update",
description: "This event triggers when a storage file is updated.",
},
{
name: "storage.files.delete",
description: "This event triggers when a storage file is deleted.",
},
{
name: "users.create",
description: "This event triggers when a user is created from the users API.",
},
{
name: "users.update.prefs",
description: "This event triggers when a user preference is updated from the users API.",
},
{
name: "users.update.status",
description: "This event triggers when a user status is updated from the users API.",
},
{
name: "users.delete",
description: "This event triggers when a user is deleted from users API.",
},
{
name: "users.sessions.delete",
description: "This event triggers when a user session is deleted from users API.",
},
{
name: "teams.create",
description: "This event triggers when a team is created.",
},
{
name: "teams.update",
description: "This event triggers when a team is updated.",
},
{
name: "teams.delete",
description: "This event triggers when a team is deleted.",
},
{
name: "teams.memberships.create",
description: "This event triggers when a team memberships is created.",
},
{
name: "teams.memberships.update",
description: "This event triggers when a team membership is updated.",
},
{
name: "teams.memberships.update.status",
description: "This event triggers when a team memberships status is updated.",
},
{
name: "teams.memberships.delete",
description: "This event triggers when a team memberships is deleted.",
},
];
export const appwriteFunctionRuntimes = [
"dotnet-3.1",
"dotnet-5.0",
"dart-2.10",
"dart-2.12",
"deno-1.5",
"deno-1.6",
"deno-1.8",
"python-3.8",
"python-3.9",
"ruby-2.7",
"ruby-3.0",
"php-7.4",
"php-8.0",
"node-14.5",
"node-15.5",
];

View file

@ -4,7 +4,6 @@ import { registerCommands } from "./commands/registerCommands";
import { ext } from "./extensionVariables"; import { ext } from "./extensionVariables";
import { getActiveProjectConfiguration } from "./settings"; import { getActiveProjectConfiguration } from "./settings";
import { DatabaseTreeItemProvider } from "./tree/database/DatabaseTreeItemProvider"; import { DatabaseTreeItemProvider } from "./tree/database/DatabaseTreeItemProvider";
import { FunctionsTreeItemProvider } from './tree/functions/FunctionsTreeItemProvider';
import { HealthTreeItemProvider } from "./tree/health/HealthTreeItemProvider"; import { HealthTreeItemProvider } from "./tree/health/HealthTreeItemProvider";
import { ProjectsTreeItemProvider } from "./tree/projects/ProjectsTreeItemProvider"; import { ProjectsTreeItemProvider } from "./tree/projects/ProjectsTreeItemProvider";
import { StorageTreeItemProvider } from "./tree/storage/StorageTreeItemProvider"; import { StorageTreeItemProvider } from "./tree/storage/StorageTreeItemProvider";
@ -17,14 +16,12 @@ export async function activate(context: vscode.ExtensionContext): Promise<void>
const databaseTreeItemProvider = new DatabaseTreeItemProvider(); const databaseTreeItemProvider = new DatabaseTreeItemProvider();
const storageTreeItemProvider = new StorageTreeItemProvider(); const storageTreeItemProvider = new StorageTreeItemProvider();
const projectsTreeItemProvider = new ProjectsTreeItemProvider(); const projectsTreeItemProvider = new ProjectsTreeItemProvider();
const functionsTreeItemProvider = new FunctionsTreeItemProvider();
vscode.window.registerTreeDataProvider("Users", userTreeItemProvider); vscode.window.registerTreeDataProvider("Users", userTreeItemProvider);
vscode.window.registerTreeDataProvider("Health", healthTreeItemProvider); vscode.window.registerTreeDataProvider("Health", healthTreeItemProvider);
vscode.window.registerTreeDataProvider("Database", databaseTreeItemProvider); vscode.window.registerTreeDataProvider("Database", databaseTreeItemProvider);
vscode.window.registerTreeDataProvider("Storage", storageTreeItemProvider); vscode.window.registerTreeDataProvider("Storage", storageTreeItemProvider);
vscode.window.registerTreeDataProvider("Projects", projectsTreeItemProvider); vscode.window.registerTreeDataProvider("Projects", projectsTreeItemProvider);
vscode.window.registerTreeDataProvider("Functions", functionsTreeItemProvider);
const activeProject = await getActiveProjectConfiguration(); const activeProject = await getActiveProjectConfiguration();
createAppwriteClient(activeProject); createAppwriteClient(activeProject);
@ -38,7 +35,6 @@ export async function activate(context: vscode.ExtensionContext): Promise<void>
database: databaseTreeItemProvider, database: databaseTreeItemProvider,
storage: storageTreeItemProvider, storage: storageTreeItemProvider,
projects: projectsTreeItemProvider, projects: projectsTreeItemProvider,
functions: functionsTreeItemProvider
}; };
registerCommands(context); registerCommands(context);

View file

@ -1,6 +1,5 @@
import { ExtensionContext } from "vscode"; import { ExtensionContext } from "vscode";
import { DatabaseTreeItemProvider } from './tree/database/DatabaseTreeItemProvider'; import { DatabaseTreeItemProvider } from './tree/database/DatabaseTreeItemProvider';
import { FunctionsTreeItemProvider } from './tree/functions/FunctionsTreeItemProvider';
import { HealthTreeItemProvider } from './tree/health/HealthTreeItemProvider'; import { HealthTreeItemProvider } from './tree/health/HealthTreeItemProvider';
import { ProjectsTreeItemProvider } from './tree/projects/ProjectsTreeItemProvider'; import { ProjectsTreeItemProvider } from './tree/projects/ProjectsTreeItemProvider';
import { StorageTreeItemProvider } from './tree/storage/StorageTreeItemProvider'; import { StorageTreeItemProvider } from './tree/storage/StorageTreeItemProvider';
@ -13,13 +12,12 @@ export type AppwriteTree = {
database?: DatabaseTreeItemProvider; database?: DatabaseTreeItemProvider;
storage?: StorageTreeItemProvider; storage?: StorageTreeItemProvider;
projects?: ProjectsTreeItemProvider; projects?: ProjectsTreeItemProvider;
functions?: FunctionsTreeItemProvider;
}; };
export type Ext = { export type Ext = {
context: ExtensionContext; context?: ExtensionContext;
outputChannel: AppwriteOutputChannel; outputChannel?: AppwriteOutputChannel;
tree?: AppwriteTree; tree?: AppwriteTree;
}; };
export const ext: Ext = {} as Ext; export const ext: Ext = {};

View file

@ -1,13 +0,0 @@
import { TreeItem } from "vscode";
export abstract class EditableTreeItemBase<T> extends TreeItem {
public abstract setValue(value: T): Promise<void>;
constructor(contextValuePrefix: string, public readonly value: T, description?: string) {
super(typeof value === "string" ? value : "No label");
this.contextValue = `editable_${contextValuePrefix}`;
this.description = description ?? contextValuePrefix;
}
public abstract prompt(): Promise<void>;
}

View file

@ -1,38 +0,0 @@
import { QuickPickItem, QuickPickOptions, window } from "vscode";
import { EditableTreeItemBase } from "./EditableTreeItemBase";
export abstract class EnumEditableTreeItemBase extends EditableTreeItemBase<string[]> {
public abstract options: string[] | QuickPickItem[];
public quickPickOptions: QuickPickOptions;
constructor(contextValuePrefix: string, public readonly value: string[], description?: string) {
super(contextValuePrefix, value, description);
this.quickPickOptions = {};
}
public async prompt(): Promise<void> {
const value = await window.showQuickPick(
this.options.map<QuickPickItem>((option: QuickPickItem | string): QuickPickItem => {
if (typeof option === "string") {
return { label: option, picked: this.value.includes(option) };
}
const picked = this.value.includes(option.label);
return { ...option, picked, alwaysShow: picked };
}).sort((a, b) => {
if (a.picked) {
return -1;
}
if (b.picked) {
return 1;
}
return 0;
}),
{ ...this.quickPickOptions, canPickMany: true }
);
if (value !== undefined) {
this.setValue(value.map((item) => item.label));
}
}
}

View file

@ -1,18 +0,0 @@
import { TreeItem, window } from "vscode";
export class EditableTreeItem extends TreeItem {
public readonly setValue: (value: string) => Promise<void>;
constructor(label: string, contextValuePrefix: string, public readonly value: string, setValue: (value: string) => Promise<void>) {
super(label);
this.setValue = setValue;
this.contextValue = `editable_${contextValuePrefix}`;
}
public async prompt(): Promise<void> {
const value = await window.showInputBox({ value: this.value });
if (value !== undefined) {
this.setValue(value);
}
}
}

View file

@ -1,22 +0,0 @@
import { InputBoxOptions, window } from "vscode";
import { EditableTreeItemBase } from "./EditableTreeItemBase";
export abstract class StringEditableTreeItemBase extends EditableTreeItemBase<string> {
public abstract setValue(value: string): Promise<void>;
public inputBoxOptions: InputBoxOptions;
constructor(contextValuePrefix: string, public readonly value: string, description?: string) {
super(contextValuePrefix, value, description);
this.inputBoxOptions = {
prompt: description,
};
}
public async prompt(): Promise<void> {
const value = await window.showInputBox({ value: this.value, ...this.inputBoxOptions });
if (value !== undefined) {
this.setValue(value);
}
}
}

View file

@ -1,13 +0,0 @@
import { TreeItem } from "vscode";
export abstract class EditableTreeItemBase<T> extends TreeItem {
public abstract setValue(value: T): Promise<void>;
constructor(contextValuePrefix: string, public readonly value: T, description?: string) {
super(typeof value === "string" ? value : "No label");
this.contextValue = `editable_${contextValuePrefix}`;
this.description = description ?? contextValuePrefix;
}
public abstract prompt(): Promise<void>;
}

View file

@ -1,38 +0,0 @@
import { QuickPickItem, QuickPickOptions, window } from "vscode";
import { EditableTreeItemBase } from "./EditableTreeItemBase";
export abstract class EnumEditableTreeItemBase extends EditableTreeItemBase<string[]> {
public abstract options: string[] | QuickPickItem[];
public quickPickOptions: QuickPickOptions;
constructor(contextValuePrefix: string, public readonly value: string[], description?: string) {
super(contextValuePrefix, value, description);
this.quickPickOptions = {};
}
public async prompt(): Promise<void> {
const value = await window.showQuickPick(
this.options.map<QuickPickItem>((option: QuickPickItem | string): QuickPickItem => {
if (typeof option === "string") {
return { label: option, picked: this.value.includes(option) };
}
const picked = this.value.includes(option.label);
return { ...option, picked, alwaysShow: picked };
}).sort((a, b) => {
if (a.picked) {
return -1;
}
if (b.picked) {
return 1;
}
return 0;
}),
{ ...this.quickPickOptions, canPickMany: true }
);
if (value !== undefined) {
this.setValue(value.map((item) => item.label));
}
}
}

View file

@ -1,18 +0,0 @@
import { TreeItem, window } from "vscode";
export class EditableTreeItem extends TreeItem {
public readonly setValue: (value: string) => Promise<void>;
constructor(label: string, contextValuePrefix: string, public readonly value: string, setValue: (value: string) => Promise<void>) {
super(label);
this.setValue = setValue;
this.contextValue = `editable_${contextValuePrefix}`;
}
public async prompt(): Promise<void> {
const value = await window.showInputBox({ value: this.value });
if (value !== undefined) {
this.setValue(value);
}
}
}

View file

@ -1,22 +0,0 @@
import { InputBoxOptions, window } from "vscode";
import { EditableTreeItemBase } from "./EditableTreeItemBase";
export abstract class StringEditableTreeItemBase extends EditableTreeItemBase<string> {
public abstract setValue(value: string): Promise<void>;
public inputBoxOptions: InputBoxOptions;
constructor(contextValuePrefix: string, public readonly value: string, description?: string) {
super(contextValuePrefix, value, description);
this.inputBoxOptions = {
prompt: description,
};
}
public async prompt(): Promise<void> {
const value = await window.showInputBox({ value: this.value, ...this.inputBoxOptions });
if (value !== undefined) {
this.setValue(value);
}
}
}

View file

@ -4,8 +4,8 @@ import AppwriteCall from "../../utils/AppwriteCall";
import { Collection, CollectionsList } from "../../appwrite"; import { Collection, CollectionsList } from "../../appwrite";
import { CollectionTreeItem } from "./CollectionTreeItem"; import { CollectionTreeItem } from "./CollectionTreeItem";
import { AppwriteSDK } from "../../constants"; import { AppwriteSDK } from "../../constants";
import { AppwriteTreeItemBase } from "../../ui/AppwriteTreeItemBase";
import { ext } from '../../extensionVariables'; import { ext } from '../../extensionVariables';
import { AppwriteTreeItemBase } from '../../ui/AppwriteTreeItemBase';
export class DatabaseTreeItemProvider implements vscode.TreeDataProvider<vscode.TreeItem> { export class DatabaseTreeItemProvider implements vscode.TreeDataProvider<vscode.TreeItem> {
private _onDidChangeTreeData: vscode.EventEmitter<vscode.TreeItem | undefined | void> = new vscode.EventEmitter< private _onDidChangeTreeData: vscode.EventEmitter<vscode.TreeItem | undefined | void> = new vscode.EventEmitter<
@ -34,18 +34,18 @@ export class DatabaseTreeItemProvider implements vscode.TreeDataProvider<vscode.
} }
if (parent instanceof AppwriteTreeItemBase) { if (parent instanceof AppwriteTreeItemBase) {
return await parent.getChildren?.() ?? []; return parent.getChildren?.() ?? [];
} }
const databaseSdk = new AppwriteSDK.Database(client); const databaseSdk = new AppwriteSDK.Database(client);
const collectionsList = await AppwriteCall<CollectionsList, CollectionsList>(databaseSdk.listCollections()); const collectionsList = await AppwriteCall<CollectionsList, CollectionsList>(databaseSdk.listCollections());
if (collectionsList) { if (collectionsList) {
const collectionTreeItems = collectionsList.collections.map((collection: Collection) => new CollectionTreeItem(collection, this)) ?? []; const userTreeItems = collectionsList.collections.map((collection: Collection) => new CollectionTreeItem(collection, this)) ?? [];
const headerItem: vscode.TreeItem = { const headerItem: vscode.TreeItem = {
label: `Total collections: ${collectionsList.sum}`, label: `Total collections: ${collectionsList.sum}`,
}; };
return [headerItem, ...collectionTreeItems]; return [headerItem, ...userTreeItems];
} }
return [{ label: "No collections found" }]; return [{ label: "No collections found" }];

View file

@ -1,30 +0,0 @@
import { MarkdownString, ThemeIcon, TreeItem, TreeItemCollapsibleState } from "vscode";
import { Function } from "../../appwrite";
import { AppwriteTreeItemBase } from "../../ui/AppwriteTreeItemBase";
import { msToDate } from '../../utils/date';
import { ExecutionsTreeItem } from './executions/ExecutionsTreeItem';
import { FunctionsTreeItemProvider } from './FunctionsTreeItemProvider';
import { FunctionSettingsTreeItem } from './settings/FunctionSettingsTreeItem';
import { TagsTreeItem } from './tags/TagsTreeItem';
export class FunctionTreeItem extends AppwriteTreeItemBase {
constructor(public func: Function, public readonly provider: FunctionsTreeItemProvider) {
super(undefined, func.name);
this.tooltip = new MarkdownString(`ID: ${func.$id} \nLast updated: ${msToDate(func.dateUpdated)} \nCreated: ${msToDate(func.dateCreated)}`);
this.description = func.env;
}
public async getChildren(): Promise<TreeItem[]> {
return [new FunctionSettingsTreeItem(this), new TagsTreeItem(this), new ExecutionsTreeItem(this)];
}
public async refresh(): Promise<void> {
this.provider.refreshChild(this);
}
collapsibleState = TreeItemCollapsibleState.Collapsed;
contextValue = "function";
iconPath = new ThemeIcon("symbol-event");
}

View file

@ -1,52 +0,0 @@
import * as vscode from "vscode";
import { client } from "../../client";
import { Function, FunctionsList } from "../../appwrite";
import { AppwriteSDK } from "../../constants";
import { AppwriteTreeItemBase } from "../../ui/AppwriteTreeItemBase";
import { ext } from "../../extensionVariables";
import { EventEmitter, TreeItem } from "vscode";
import { FunctionTreeItem } from "./FunctionTreeItem";
export class FunctionsTreeItemProvider implements vscode.TreeDataProvider<vscode.TreeItem> {
private _onDidChangeTreeData: EventEmitter<TreeItem | undefined | void> = new EventEmitter<TreeItem | undefined | void>();
readonly onDidChangeTreeData: vscode.Event<vscode.TreeItem | undefined | void> = this._onDidChangeTreeData.event;
refresh(): void {
ext.outputChannel?.appendLine("Refreshing functions tree provider...");
this._onDidChangeTreeData.fire();
}
refreshChild(child: vscode.TreeItem): void {
this._onDidChangeTreeData.fire(child);
}
getTreeItem(element: vscode.TreeItem): vscode.TreeItem {
return element;
}
async getChildren(parent?: AppwriteTreeItemBase | TreeItem): Promise<vscode.TreeItem[]> {
if (client === undefined) {
return Promise.resolve([]);
}
if (parent === undefined) {
const functionsSdk = new AppwriteSDK.Functions(client);
const list: FunctionsList = await functionsSdk.list();
if (list) {
const functionTreeItems = list.functions.map((func: Function) => new FunctionTreeItem(func, this)) ?? [];
return functionTreeItems;
}
return [{ label: "No functions found" }];
}
if (parent instanceof AppwriteTreeItemBase) {
return await parent.getChildren?.() ?? [];
}
return [];
}
}

View file

@ -1,83 +0,0 @@
import { MarkdownString, ThemeColor, ThemeIcon, TreeItem } from "vscode";
import { Execution, ExecutionStatus } from "../../../appwrite";
import { msToDate } from "../../../utils/date";
import { ExecutionsTreeItem } from "./ExecutionsTreeItem";
const executionStatusIcons: Record<ExecutionStatus, ThemeIcon> = {
processing: new ThemeIcon("loading"),
waiting: new ThemeIcon("circle-outline"),
completed: new ThemeIcon("circle-filled", new ThemeColor("testing.iconPassed")),
failed: new ThemeIcon("circle-filled", new ThemeColor("testing.iconFailed")),
};
export class ExecutionTreeItem extends TreeItem {
public isAutoRefreshing: boolean = false;
private refreshCount: number = 0;
constructor(public readonly parent: ExecutionsTreeItem, public execution: Execution) {
super(execution.$id);
this.label = this.getLabel(execution);
this.iconPath = executionStatusIcons[execution.status];
const md = `Id: ${execution.$id} \nCreated: ${this.getCreated(execution)} \nTrigger: ${execution.trigger}`;
this.tooltip = new MarkdownString(md);
this.description = execution.trigger;
this.contextValue = this.getContextValue(execution);
this.isAutoRefreshing = execution.status === "processing" || execution.status === "waiting";
// if (this.isAutoRefreshing) {
// this.autoRefresh();
// }
}
// async autoRefresh(): Promise<void> {
// if (!this.isAutoRefreshing && this.refreshCount < 5) {
// return;
// }
// this.refreshCount++;
// ext.outputChannel.appendLog("Refreshing execution.");
// const execution = await functionsClient?.getExecution(this.parent.parent.func.$id, this.execution.$id);
// if (!execution) {
// ext.outputChannel.appendLog("Execution is undefined");
// this.isAutoRefreshing = false;
// return;
// }
// this.execution = execution;
// this.contextValue = this.getContextValue(execution);
// this.iconPath = executionStatusIcons[execution.status];
// this.label = this.getLabel(execution);
// this.isAutoRefreshing = execution.status === "processing" || execution.status === "waiting";
// ext.tree?.functions?.refreshChild(this);
// await sleep(1000);
// this.autoRefresh();
// }
getLabel(execution: Execution): string {
if (execution.status === "completed" || execution.status === "failed") {
return `${this.getCreated(execution)} (${this.getExecutionTime(execution)}s)`;
}
return `${this.getCreated(execution)} (${execution.status})`;
}
getExecutionTime(execution: Execution): string {
return execution.time.toPrecision(2);
}
getContextValue(execution: Execution): string {
if (execution.status === "completed" || execution.status === "failed") {
if (execution.stderr === "" && execution.stdout === "") {
return "execution_noErrorOrOutput";
}
if (execution.stderr === "") {
return "execution_outputOnly";
}
if (execution.stdout === "") {
return "execution_errorOnly";
}
}
return "execution";
}
getCreated(execution: Execution): string {
return msToDate(execution.dateCreated);
}
}

View file

@ -1,61 +0,0 @@
import { ThemeIcon, TreeItem, TreeItemCollapsibleState } from "vscode";
import { Execution, ExecutionList } from "../../../appwrite";
import { functionsClient } from "../../../client";
import { ExecutionTreeItem } from "./ExecutionTreeItem";
import { FunctionTreeItem } from "../FunctionTreeItem";
import { ext } from "../../../extensionVariables";
import { AppwriteTreeItemBase } from "../../../ui/AppwriteTreeItemBase";
export class ExecutionsTreeItem extends AppwriteTreeItemBase<FunctionTreeItem> {
constructor(public readonly parent: FunctionTreeItem) {
super(parent, "Executions");
}
private executionsToShow = 10;
public async getChildren(): Promise<TreeItem[]> {
if (!functionsClient) {
return [];
}
const executions: ExecutionList | undefined = await functionsClient.listExecutions(
this.parent.func.$id,
undefined,
this.executionsToShow,
undefined,
"DESC"
);
const children = executions?.executions.map((execution: Execution) => new ExecutionTreeItem(this, execution)) ?? [
new TreeItem("No executions."),
];
if (children.length === 0) {
children.push(new TreeItem("No executions."));
}
ext.outputChannel.appendLog(`Found ${executions?.sum} executions`);
if (executions?.sum ?? (0 > this.executionsToShow && this.executionsToShow !== 100)) {
const viewMoreItem: TreeItem = {
command: {
command: "vscode-appwrite.viewMore",
arguments: [this],
title: "View more",
},
label: "View more...",
};
children.push(viewMoreItem);
}
return children;
}
collapsibleState = TreeItemCollapsibleState.Collapsed;
contextValue = "executions";
iconPath = new ThemeIcon("history");
async viewMore(): Promise<void> {
this.executionsToShow += 10;
if (this.executionsToShow > 100) {
this.executionsToShow = 100;
}
ext.tree?.functions?.refreshChild(this);
}
}

View file

@ -1,31 +0,0 @@
import { QuickPickItem, QuickPickOptions } from "vscode";
import { Function } from "../../../appwrite";
import { functionsClient } from "../../../client";
import { appwriteSystemEvents } from "../../../constants";
import { ext } from "../../../extensionVariables";
import { EnumEditableTreeItemBase } from "../../common/editable/EnumEditableTreeItem";
import { FunctionSettingsTreeItem } from "./FunctionSettingsTreeItem";
export class EventsTreeItem extends EnumEditableTreeItemBase {
public quickPickOptions: QuickPickOptions = {
placeHolder: "Select which system events should trigger this function.",
matchOnDescription: true
};
public options: string[] | QuickPickItem[] = appwriteSystemEvents.map((event) => ({
label: event.name,
description: event.description.replace("This event t", "T")
}));
public readonly func: Function;
constructor(public readonly parent: FunctionSettingsTreeItem) {
super("System events", parent.func.events);
this.func = parent.func;
this.label = parent.func.events.length === 0 ? 'None' : `${parent.func.events.length} active`;
}
public async setValue(value: string[]): Promise<void> {
await functionsClient?.update(this.func.$id, this.func.name, [], this.func.vars, value, this.func.schedule, this.func.timeout);
ext.tree?.functions?.refresh();
}
}

View file

@ -1,45 +0,0 @@
import { ThemeIcon, TreeItem, TreeItemCollapsibleState } from "vscode";
import { Function } from "../../../appwrite";
import { functionsClient } from "../../../client";
import { AppwriteTreeItemBase } from '../../../ui/AppwriteTreeItemBase';
import { ChildTreeItem } from "../../ChildTreeItem";
import { FunctionTreeItem } from "../FunctionTreeItem";
import { EventsTreeItem } from "./EventsTreeItem";
import { NameTreeItem } from "./NameTreeItem";
import { ScheduleTreeItem } from "./ScheduleTreeItem";
import { TimeoutTreeItem } from "./TimeoutTreeItem";
import { VarsTreeItem } from "./VarsTreeItem";
export class FunctionSettingsTreeItem extends AppwriteTreeItemBase<FunctionTreeItem> {
public readonly func: Function;
constructor(public readonly parent: FunctionTreeItem) {
super(parent, "Settings");
this.func = parent.func;
}
public async getChildren(): Promise<TreeItem[]> {
if (!functionsClient) {
return [];
}
const children = [
new NameTreeItem(this),
new ScheduleTreeItem(this),
new TimeoutTreeItem(this.func),
new EventsTreeItem(this),
new VarsTreeItem(this),
];
return children;
}
labelItem(label: string, value: string): TreeItem {
return new ChildTreeItem(this, { label: value === "" ? "None" : value, description: label });
}
collapsibleState = TreeItemCollapsibleState.Collapsed;
contextValue = "functionSettings";
iconPath = new ThemeIcon("settings");
}

View file

@ -1,43 +0,0 @@
import { InputBoxOptions, MarkdownString } from "vscode";
import { Function } from "../../../appwrite";
import { functionsClient } from "../../../client";
import { ext } from "../../../extensionVariables";
import { StringEditableTreeItemBase } from '../../common/editable/StringEditableTreeItem';
import { FunctionSettingsTreeItem } from "./FunctionSettingsTreeItem";
const tooltip = "Function name";
const description = "Function name. Max length: 128 chars.";
const tooLongInvalid = "Value exceeds maximum length of 128 characters.";
export function validateFunctionName(value: string): string | undefined {
if (value.length > 128) {
return tooLongInvalid;
}
}
export class NameTreeItem extends StringEditableTreeItemBase {
public readonly func: Function;
inputBoxOptions: InputBoxOptions = {
validateInput: (value) => {
if (value.length > 128) {
return tooLongInvalid;
}
},
prompt: description,
};
public async setValue(value: string): Promise<void> {
if (value.length === 0) {
return;
}
await functionsClient?.update(this.func.$id, value, [], this.func.vars, this.func.events, this.func.schedule, this.func.timeout);
ext.tree?.functions?.refresh();
}
constructor(private readonly parent: FunctionSettingsTreeItem) {
super("Name", parent.func.name);
this.func = parent.func;
this.tooltip = new MarkdownString(tooltip);
}
}

View file

@ -1,44 +0,0 @@
import { InputBoxOptions, MarkdownString } from "vscode";
import { Function } from "../../../appwrite";
import { functionsClient } from "../../../client";
import { ext } from "../../../extensionVariables";
import cron from "cron-validate";
import { FunctionSettingsTreeItem } from "./FunctionSettingsTreeItem";
import cronstrue from "cronstrue";
import { StringEditableTreeItemBase } from '../../common/editable/StringEditableTreeItem';
export class ScheduleTreeItem extends StringEditableTreeItemBase {
private readonly func: Function;
inputBoxOptions: InputBoxOptions = {
validateInput: (value) => {
if (value === "") {
return;
}
const cronResult = cron(value);
if (!cronResult.isValid()) {
return cronResult.getError().join(", ");
}
},
value: this.value === "" ? "0 0 * * *" : this.value,
prompt: "Function execution schedule in CRON format. Leave blank for no schedule. https://crontab.guru/examples.html",
};
public async setValue(value: string): Promise<void> {
await functionsClient?.update(this.func.$id, this.func.name, [], this.func.vars, this.func.events, value === "" ? undefined : value, this.func.timeout);
ext.tree?.functions?.refresh();
}
constructor(private readonly parent: FunctionSettingsTreeItem) {
super("Schedule", parent.func.schedule);
this.func = parent.func;
this.tooltip = new MarkdownString(`Function execution schedule in CRON format`);
this.label = `${this.value}`;
const cronResult = cron(parent.func.schedule);
if (cronResult.isValid()) {
this.label = cronstrue.toString(this.value, { verbose: true });
} else {
this.label = this.value === "" ? "None" : "Invalid CRON";
}
}
}

View file

@ -1,48 +0,0 @@
import { InputBoxOptions, MarkdownString } from "vscode";
import { Function } from "../../../appwrite";
import { functionsClient } from "../../../client";
import { ext } from "../../../extensionVariables";
import { StringEditableTreeItemBase } from "../../common/editable/StringEditableTreeItem";
function isNumeric(str: string) {
console.log("here");
return !isNaN(+str);
}
export class TimeoutTreeItem extends StringEditableTreeItemBase {
inputBoxOptions: InputBoxOptions = {
validateInput: (value) => {
if (!isNumeric(value)) {
return "Input must be an integer.";
}
if (+value > 900) {
return "Value exceeds the maximum of 900 seconds (15 minutes)";
}
if (+value < 0) {
return "Value cannot be negative";
}
},
prompt: "Function maximum execution time in seconds. Maximum of 900 seconds (15 minutes).",
};
public async setValue(value: string): Promise<void> {
await functionsClient?.update(
this.func.$id,
this.func.name,
[],
this.func.vars,
this.func.events,
this.func.schedule,
parseInt(value)
);
ext.tree?.functions?.refresh();
}
constructor(private readonly func: Function) {
super("Timeout", func.timeout.toString());
this.tooltip = new MarkdownString(`Function maximum execution time in seconds.`);
this.label = `${this.value}s`;
}
}

View file

@ -1,64 +0,0 @@
import { InputBoxOptions, MarkdownString, window } from "vscode";
import { Function } from "../../../appwrite";
import { functionsClient } from "../../../client";
import { ext } from "../../../extensionVariables";
import { StringEditableTreeItemBase } from "../../common/editable/StringEditableTreeItem";
import { VarsTreeItem } from "./VarsTreeItem";
const tooltip = "Environment var";
const description = "Function name. Max length: 128 chars.";
const tooLongInvalid = "Value exceeds maximum length of 128 characters.";
export async function keyValuePrompt(keyInit?: string, valueInit?: string): Promise<{ key: string; value: string } | undefined> {
const key = await window.showInputBox({ value: keyInit, prompt: "Environment variable name" });
if (key === undefined) {
return;
}
const value = await window.showInputBox({ value: valueInit, prompt: "Environment variable value" });
if (value === undefined) {
return;
}
return { key, value };
}
export class VarTreeItem extends StringEditableTreeItemBase {
public readonly func: Function;
inputBoxOptions: InputBoxOptions = {
validateInput: (value) => {
if (value.length > 128) {
return tooLongInvalid;
}
},
prompt: description,
};
public async setValue(value: string, key?: string): Promise<void> {
if (value.length === 0) {
return;
}
const newVars = { ...this.func.vars };
newVars[this.key] = value;
if (key) {
delete newVars[this.key];
newVars[key] = value;
}
await functionsClient?.update(this.func.$id, this.func.name, [], newVars, this.func.events, this.func.schedule, this.func.timeout);
ext.tree?.functions?.refresh();
}
constructor(public readonly parent: VarsTreeItem, public readonly key: string, value: string) {
super("var", value);
this.func = parent.parent.func;
this.tooltip = new MarkdownString(tooltip);
this.label = `${key}=${value}`;
this.description = undefined;
}
public async prompt(): Promise<void> {
const keyval = await keyValuePrompt(this.key, this.value);
if (keyval) {
this.setValue(keyval.value, keyval.key);
}
}
}

View file

@ -1,21 +0,0 @@
import { TreeItem, TreeItemCollapsibleState } from "vscode";
import { Vars } from "../../../appwrite";
import { AppwriteTreeItemBase } from '../../../ui/AppwriteTreeItemBase';
import { FunctionSettingsTreeItem } from "./FunctionSettingsTreeItem";
import { VarTreeItem } from "./VarTreeItem";
export class VarsTreeItem extends AppwriteTreeItemBase<FunctionSettingsTreeItem> {
public readonly vars: Vars;
constructor(parent: FunctionSettingsTreeItem) {
super(parent, "Environment variables");
this.vars = parent.func.vars;
this.description = undefined;
}
public async getChildren(): Promise<TreeItem[]> {
return Object.keys(this.vars).map((key) => new VarTreeItem(this, key, this.vars[key]));
}
contextValue = "vars";
collapsibleState = TreeItemCollapsibleState.Collapsed;
}

View file

@ -1,17 +0,0 @@
import { MarkdownString, ThemeIcon, TreeItem } from "vscode";
import { Tag } from '../../../appwrite';
import { msToDate } from '../../../utils/date';
import { TagsTreeItem } from './TagsTreeItem';
export class TagTreeItem extends TreeItem {
constructor(public readonly parent: TagsTreeItem, public readonly tag: Tag) {
super(tag.$id);
const func = parent.parent.func;
const active = func.tag === tag.$id;
this.label = `${msToDate(tag.dateCreated)}${active ? ' (Active)' : ''}`;
this.description = tag.$id;
this.iconPath = new ThemeIcon(active ? 'circle-large-filled' : 'circle-large-outline');
this.contextValue = `tag${active ? '_active' : ''}`;
this.tooltip = new MarkdownString(`ID: ${tag.$id} \nCreated: ${msToDate(tag.dateCreated)} \nCommand: ${tag.command} \nSize: ${tag.size}B`);
}
}

View file

@ -1,40 +0,0 @@
import { ThemeIcon, TreeItem, TreeItemCollapsibleState } from "vscode";
import { functionsClient } from "../../../client";
import { AppwriteTreeItemBase } from '../../../ui/AppwriteTreeItemBase';
import { FunctionTreeItem } from '../FunctionTreeItem';
import { TagTreeItem } from './TagTreeItem';
export class TagsTreeItem extends AppwriteTreeItemBase<FunctionTreeItem> {
constructor(public readonly parent: FunctionTreeItem) {
super(parent, "Tags");
}
public async getChildren(): Promise<TreeItem[]> {
if (!functionsClient) {
return [];
}
const tags = await functionsClient.listTags(this.parent.func.$id);
const children = tags?.tags.sort((a, b) => b.dateCreated - a.dateCreated).map((tag) => new TagTreeItem(this, tag)) ?? [new TreeItem('No tags.')];
if (children.length === 0) {
const noTagsItem: TreeItem = {
command: {
command: "vscode-appwrite.CreateTag",
title: "Create tag",
arguments: [this],
tooltip: "Create a tag"
},
label: "Create a tag",
iconPath: new ThemeIcon("cloud-upload"),
};
children.push(noTagsItem);
}
return children;
}
collapsibleState = TreeItemCollapsibleState.Collapsed;
contextValue = "tags";
iconPath = new ThemeIcon("tag");
}

View file

@ -35,13 +35,12 @@ export class HealthTreeItemProvider implements vscode.TreeDataProvider<vscode.Tr
// get children for root // get children for root
if (element === undefined) { if (element === undefined) {
try { try {
const health = await promiseWithTimeout<Partial<AppwriteHealth> | undefined>( const health = await promiseWithTimeout<AppwriteHealth | undefined>(
10000, 10000,
async () => { async () => {
try { try {
return await healthClient?.checkup(); return await healthClient?.checkup();
} catch (e) { } catch (e) {
ext.outputChannel?.append('Error: ' + e.message);
vscode.window.showErrorMessage('Could not connect to Appwrite project'); vscode.window.showErrorMessage('Could not connect to Appwrite project');
} }
}, },

View file

@ -7,7 +7,4 @@ export abstract class AppwriteTreeItemBase<Parent = void> extends TreeItem {
abstract getChildren?(): Promise<TreeItem[]>; abstract getChildren?(): Promise<TreeItem[]>;
viewMore(): Promise<void> {
return Promise.resolve();
}
} }

View file

@ -1,19 +1,42 @@
import { QuickPickItem, window } from "vscode"; import { QuickPickItem, window } from "vscode";
import { Collection, CollectionsList } from "../appwrite";
import { client } from "../client";
import { AppwriteSDK } from "../constants";
import AppwriteCall from "../utils/AppwriteCall";
export type CreateRuleWizardContext = { export type CreateRuleWizardContext = {
label: string; label: string;
key: string; key: string;
type: keyof typeof ruleTypes; type: keyof typeof ruleTypes;
default: any;
required: boolean;
array: boolean;
list?: string[];
}; };
export async function createRuleWizard(): Promise<CreateRuleWizardContext | undefined> {
const label = await window.showInputBox({
placeHolder: "Label",
prompt: "Attribute internal display name",
});
if (label === undefined) {
return;
}
const key = await window.showInputBox({
placeHolder: "Key",
prompt: "Attribute key name. Used as the document JSON key in the Database API.",
});
if (key === undefined) {
return;
}
const ruleTypeItems: QuickPickItem[] = Object.entries(ruleTypes).map(([label, description]) => ({
label,
description,
}));
const type = await window.showQuickPick(ruleTypeItems);
if (type === undefined) {
return;
}
if (label && key && type) {
return { label, key, type: (type.label as unknown) as keyof typeof ruleTypes };
}
return undefined;
}
const ruleTypes = { const ruleTypes = {
text: "Any string value.", text: "Any string value.",
numeric: "Any integer or float value.", numeric: "Any integer or float value.",
@ -22,119 +45,6 @@ const ruleTypes = {
url: "Any valid URL.", url: "Any valid URL.",
email: "Any valid email address.", email: "Any valid email address.",
ip: "Any valid IP v4 or v6 address.", ip: "Any valid IP v4 or v6 address.",
document: "Accept a valid child document from specified collection(s).", document:
"Accept a valid child document. When using this type you are also required to pass the 'list' parameter with an array of the collections UID values of the document types you want to accept.",
}; };
type RuleType = keyof typeof ruleTypes;
export async function createRuleWizard(collection: Collection): Promise<CreateRuleWizardContext | undefined> {
const label = await window.showInputBox({
placeHolder: "Attribute label",
prompt: "Attribute internal display name",
validateInput: (value) => {
if (value === "") {
return "Label cannot be empty.";
}
},
});
if (label === undefined) {
return;
}
const key = await window.showInputBox({
placeHolder: "Attribute key name",
prompt: "Attribute key name. Used as the document JSON key in the Database API.",
ignoreFocusOut: true,
validateInput: (value) => {
if (value === "") {
return "Key name cannot be empty.";
}
},
});
if (key === undefined) {
return;
}
const ruleTypeItems: QuickPickItem[] = Object.entries(ruleTypes).map(([label, description]) => ({
label,
detail: description,
}));
const typeItem = await window.showQuickPick(ruleTypeItems, { placeHolder: "Rule value type." });
const type: RuleType | undefined = (typeItem?.label as RuleType) ?? undefined;
if (typeItem === undefined || type === undefined) {
return;
}
let list: string[] | undefined = undefined;
if (type === "document") {
const databaseSdk = new AppwriteSDK.Database(client);
const collectionsList = await AppwriteCall<CollectionsList, CollectionsList>(databaseSdk.listCollections());
if (collectionsList === undefined) {
window.showErrorMessage("Could not get collections list.");
return;
}
if (collectionsList) {
const collections = collectionsList.collections.filter((c) => c.$id !== collection.$id);
const qpItems: QuickPickItem[] = collections.map((collection) => ({
label: collection.name,
description: collection.$id,
}));
const listInput = await window.showQuickPick(qpItems, {
canPickMany: true,
placeHolder: "Collections which contain valid child documents for this document attribute.",
ignoreFocusOut: true,
});
list = listInput?.map((item) => item.description as string) ?? [];
}
}
if (label === "document" && list === undefined) {
return;
}
const array = await window.showQuickPick(["Primitive", "Array"], {
placeHolder: "Decide if this rule is a primitive or an array of values.",
ignoreFocusOut: true,
});
if (array === undefined) {
return;
}
const required = await window.showQuickPick(["Required", "Optional"], {
placeHolder: "Decide if this rule value is required in order to pass document validation.",
ignoreFocusOut: true,
});
if (required === undefined) {
return;
}
const defaultValue = await window.showInputBox({
placeHolder: "Default value (press Enter to skip)",
prompt: "Default value for this rule type. Make sure that the default value is able to pass validation in order to avoid errors when skipping optional values.",
ignoreFocusOut: true,
});
if (defaultValue === undefined) {
return;
}
if (label && key && type) {
return {
label,
key,
type,
default: defaultValue,
array: array === "Array",
required: required === "Required",
list,
};
}
return undefined;
}

View file

@ -10,7 +10,7 @@ export default function AppwriteCall<T, R = T>(
): Promise<R | undefined> { ): Promise<R | undefined> {
return promise.then( return promise.then(
(successResp) => { (successResp) => {
ext.outputChannel?.appendLog(`Appwrite call success:`); ext.outputChannel?.appendLog("Appwrite call success");
if (onSuccess) { if (onSuccess) {
return onSuccess((successResp as unknown) as T); return onSuccess((successResp as unknown) as T);
} }

View file

@ -1,9 +0,0 @@
import dayjs = require("dayjs");
import utc = require("dayjs/plugin/utc");
import timezone = require("dayjs/plugin/timezone"); // dependent on utc plugin
dayjs.extend(utc);
dayjs.extend(timezone);
export function msToDate(ms: number): string {
return dayjs(ms * 1000).tz(dayjs.tz.guess()).format("LTS");
}

View file

@ -1,5 +0,0 @@
export function sleep(ms: number): Promise<void> {
return new Promise((resolve) => {
setTimeout(resolve, ms);
});
}

View file

@ -1,34 +0,0 @@
import tar = require("tar");
import { Uri, window, workspace } from "vscode";
import { ext } from "../extensionVariables";
import * as path from "path";
import * as fs from "fs";
import { sleep } from './sleep';
export async function getTarReadStream(folder: Uri): Promise<string | undefined> {
try {
const folderName = path.basename(folder.path);
const tarName = `${folderName}.tar.gz`;
const cwd = path.resolve(folder.fsPath, '..');
if (cwd === undefined) {
window.showErrorMessage("No workspace open.");
return;
}
ext.outputChannel.appendLog(`Creating '${tarName}' in '${workspace.workspaceFolders?.[0].uri.fsPath}'...`);
const tarFilePath = path.join(ext.context?.globalStorageUri.fsPath ?? '', tarName);
await workspace.fs.createDirectory(ext.context.globalStorageUri);
tar.create({ gzip: true, cwd: cwd, mode: 1777 }, [path.relative(cwd, folder.fsPath)]).pipe(fs.createWriteStream(tarFilePath));
await sleep(500);
ext.outputChannel.appendLog(`Created ${tarFilePath}`);
return tarFilePath;
} catch (e) {
ext.outputChannel?.appendLog("Error creating tar.gz: " + e);
}
}

View file

@ -1,6 +0,0 @@
import { Progress } from 'vscode';
export type ProgressMessage = Progress<{
message?: string | undefined;
increment?: number | undefined;
}>;

View file

@ -1,84 +0,0 @@
/*---------------------------------------------------------------------------------------------
* Copyright (c) Microsoft Corporation. All rights reserved.
* Licensed under the MIT License. See License.txt in the project root for license information.
*--------------------------------------------------------------------------------------------*/
import * as path from "path";
import * as vscode from "vscode";
import { QuickPickItem } from 'vscode';
export interface IAzureQuickPickItem<T = undefined> extends QuickPickItem {
/**
* An optional id to uniquely identify this item across sessions, used in persisting previous selections
* If not specified, a hash of the label will be used
*/
id?: string;
data: T;
/**
* Callback to use when this item is picked, instead of returning the pick
* Only applies when used as part of an `AzureWizard`
* This is not compatible with `canPickMany`
*/
onPicked?: () => void | Promise<void>;
/**
* The group that this pick belongs to. Set `IAzureQuickPickOptions.enableGrouping` for this property to take effect
* Only applies when used as part of an `AzureWizard`
*/
group?: string;
/**
* Optionally used to suppress persistence for this item, defaults to `false`
*/
suppressPersistence?: boolean;
}
export async function selectWorkspaceFolder(placeHolder: string): Promise<string> {
return await selectWorkspaceItem(placeHolder, {
canSelectFiles: false,
canSelectFolders: true,
canSelectMany: false,
defaultUri:
vscode.workspace.workspaceFolders && vscode.workspace.workspaceFolders.length > 0
? vscode.workspace.workspaceFolders[0].uri
: undefined,
openLabel: "Select",
});
}
export async function selectWorkspaceFile(placeHolder: string, fileExtensions?: string[]): Promise<string> {
const filters: { [name: string]: string[] } = {};
if (fileExtensions) {
filters.Artifacts = fileExtensions;
}
return await selectWorkspaceItem(placeHolder, {
canSelectFiles: true,
canSelectFolders: false,
canSelectMany: false,
openLabel: "Select",
filters: filters,
});
}
export async function selectWorkspaceItem(placeHolder: string, options: vscode.OpenDialogOptions): Promise<string> {
let folder: IAzureQuickPickItem<string | undefined> | undefined;
if (vscode.workspace.workspaceFolders) {
const folderPicks: IAzureQuickPickItem<string | undefined>[] = await Promise.all(
vscode.workspace.workspaceFolders.map((f: vscode.WorkspaceFolder) => {
return { label: path.basename(f.uri.fsPath), description: f.uri.fsPath, data: f.uri.fsPath };
})
);
folderPicks.push({ label: "$(file-directory) Browse...", description: "", data: undefined });
folder = await vscode.window.showQuickPick(folderPicks, { placeHolder });
}
if (folder?.data) {
return folder.data;
} else {
return (await vscode.window.showOpenDialog(options))?.[0].fsPath ?? '';
}
}