feat: support concurrent chunk uploads

README.md

@@ -1,7 +1,7 @@
 # Appwrite Command Line SDK
 
 ![License](https://img.shields.io/github/license/appwrite/sdk-for-cli.svg?style=flat-square)
-![Version](https://img.shields.io/badge/api%20version-1.9.4-blue.svg?style=flat-square)
+![Version](https://img.shields.io/badge/api%20version-1.9.5-blue.svg?style=flat-square)
 [![Build Status](https://img.shields.io/travis/com/appwrite/sdk-generator?style=flat-square)](https://travis-ci.com/appwrite/sdk-generator)
 [![Twitter Account](https://img.shields.io/twitter/follow/appwrite?color=00acee&label=twitter&style=flat-square)](https://twitter.com/appwrite)
 [![Discord](https://img.shields.io/discord/564160730845151244?label=discord&style=flat-square)](https://appwrite.io/discord)
@@ -29,7 +29,7 @@ Once the installation is complete, you can verify the install using
 
 ```sh
 $ appwrite -v
-21.0.0
+21.1.0
 ```
 
 ### Install using prebuilt binaries
@@ -83,7 +83,7 @@ $ scoop install https://raw.githubusercontent.com/appwrite/sdk-for-cli/master/sc
 Once the installation completes, you can verify your install using
 ```
 $ appwrite -v
-21.0.0
+21.1.0
 ```
 
 ## Getting Started 

cli.ts

@@ -45,14 +45,17 @@ import { locale } from './lib/commands/services/locale.js';
 import { messaging } from './lib/commands/services/messaging.js';
 import { migrations } from './lib/commands/services/migrations.js';
 import { organizations } from './lib/commands/services/organizations.js';
+import { presences } from './lib/commands/services/presences.js';
 import { project } from './lib/commands/services/project.js';
 import { projects } from './lib/commands/services/projects.js';
 import { proxy } from './lib/commands/services/proxy.js';
+import { advisor } from './lib/commands/services/advisor.js';
 import { sites } from './lib/commands/services/sites.js';
 import { storage } from './lib/commands/services/storage.js';
 import { tablesDB } from './lib/commands/services/tables-db.js';
 import { teams } from './lib/commands/services/teams.js';
 import { tokens } from './lib/commands/services/tokens.js';
+import { usage } from './lib/commands/services/usage.js';
 import { users } from './lib/commands/services/users.js';
 import { vcs } from './lib/commands/services/vcs.js';
 import { webhooks } from './lib/commands/services/webhooks.js';
@@ -215,14 +218,17 @@ if (process.argv.includes('-v') || process.argv.includes('--version')) {
             .addCommand(messaging)
             .addCommand(migrations)
             .addCommand(organizations)
+            .addCommand(presences)
             .addCommand(project)
             .addCommand(projects)
             .addCommand(proxy)
+            .addCommand(advisor)
             .addCommand(sites)
             .addCommand(storage)
             .addCommand(tablesDB)
             .addCommand(teams)
             .addCommand(tokens)
+            .addCommand(usage)
             .addCommand(users)
             .addCommand(vcs)
             .addCommand(webhooks)

docs/examples/advisor/delete-report.md

@@ -0,0 +1,4 @@
+```bash
+appwrite advisor delete-report \
+    --report-id <REPORT_ID>
+```

docs/examples/advisor/get-insight.md

@@ -0,0 +1,5 @@
+```bash
+appwrite advisor get-insight \
+    --report-id <REPORT_ID> \
+    --insight-id <INSIGHT_ID>
+```

docs/examples/advisor/get-report.md

@@ -0,0 +1,4 @@
+```bash
+appwrite advisor get-report \
+    --report-id <REPORT_ID>
+```

docs/examples/advisor/list-insights.md

@@ -0,0 +1,5 @@
+```bash
+appwrite advisor list-insights \
+    --report-id <REPORT_ID> \
+    --limit 25
+```

docs/examples/advisor/list-reports.md

@@ -0,0 +1,4 @@
+```bash
+appwrite advisor list-reports \
+    --limit 25
+```

docs/examples/presences/delete.md

@@ -0,0 +1,4 @@
+```bash
+appwrite presences delete \
+    --presence-id <PRESENCE_ID>
+```

docs/examples/presences/get-usage.md

@@ -0,0 +1,3 @@
+```bash
+appwrite presences get-usage
+```

docs/examples/presences/get.md

@@ -0,0 +1,4 @@
+```bash
+appwrite presences get \
+    --presence-id <PRESENCE_ID>
+```

docs/examples/presences/list.md

@@ -0,0 +1,4 @@
+```bash
+appwrite presences list \
+    --limit 25
+```

docs/examples/presences/update-presence.md

@@ -0,0 +1,5 @@
+```bash
+appwrite presences update-presence \
+    --presence-id <PRESENCE_ID> \
+    --user-id <USER_ID>
+```

docs/examples/presences/upsert.md

@@ -0,0 +1,6 @@
+```bash
+appwrite presences upsert \
+    --presence-id <PRESENCE_ID> \
+    --user-id <USER_ID> \
+    --status <STATUS>
+```

docs/examples/project/get.md

@@ -0,0 +1,3 @@
+```bash
+appwrite project get
+```

docs/examples/project/update-deny-aliased-email-policy.md

@@ -0,0 +1,4 @@
+```bash
+appwrite project update-deny-aliased-email-policy \
+    --enabled false
+```

docs/examples/usage/list-events.md

@@ -0,0 +1,4 @@
+```bash
+appwrite usage list-events \
+    --limit 25
+```

docs/examples/usage/list-gauges.md

@@ -0,0 +1,4 @@
+```bash
+appwrite usage list-gauges \
+    --limit 25
+```

install.ps1

@@ -13,8 +13,8 @@
 # You can use "View source" of this page to see the full script.
 
 # REPO
-$GITHUB_x64_URL = "https://github.com/appwrite/sdk-for-cli/releases/download/21.0.0/appwrite-cli-win-x64.exe"
-$GITHUB_arm64_URL = "https://github.com/appwrite/sdk-for-cli/releases/download/21.0.0/appwrite-cli-win-arm64.exe"
+$GITHUB_x64_URL = "https://github.com/appwrite/sdk-for-cli/releases/download/21.1.0/appwrite-cli-win-x64.exe"
+$GITHUB_arm64_URL = "https://github.com/appwrite/sdk-for-cli/releases/download/21.1.0/appwrite-cli-win-arm64.exe"
 
 $APPWRITE_BINARY_NAME = "appwrite.exe"
 

install.sh

@@ -120,7 +120,7 @@ verifyMacOSCodeSignature() {
 downloadBinary() {
     echo "[2/5] Downloading executable for $OS ($ARCH) ..."
 
-    GITHUB_LATEST_VERSION="21.0.0"
+    GITHUB_LATEST_VERSION="21.1.0"
     GITHUB_FILE="appwrite-cli-${OS}-${ARCH}"
     GITHUB_URL="https://github.com/$GITHUB_REPOSITORY_NAME/releases/download/$GITHUB_LATEST_VERSION/$GITHUB_FILE"
 

lib/commands/services/advisor.ts

@@ -0,0 +1,129 @@
+import { Command } from "commander";
+import {
+  buildQueries,
+  collectQueryValue,
+  parseDeprecatedWhereQuery,
+  parseFilterQuery,
+} from "../utils/query.js";
+import { sdkForProject } from "../../sdks.js";
+import {
+  actionRunner,
+  commandDescriptions,
+  success,
+  parse,
+  parseBool,
+  parseInteger,
+} from "../../parser.js";
+import { Advisor } from "@appwrite.io/console";
+
+let advisorClient: Advisor | null = null;
+
+const getAdvisorClient = async (): Promise<Advisor> => {
+  if (!advisorClient) {
+    const sdkClient = await sdkForProject();
+    advisorClient = new Advisor(sdkClient);
+  }
+  return advisorClient;
+};
+
+export const advisor = new Command("advisor")
+  .description(commandDescriptions["advisor"] ?? "")
+  .configureHelp({
+    helpWidth: process.stdout.columns || 80,
+  });
+
+const advisorListReportsCommand = advisor
+  .command(`list-reports`)
+  .description(`Get a list of all the project's analyzer reports. You can use the query params to filter your results.
+`)
+  .option(`--queries [queries...]`, `Raw Appwrite JSON query strings (legacy). Use this for advanced queries or automation; for common filtering, sorting, and pagination prefer --filter, --sort-asc, --sort-desc, --limit, and --offset. When mixed, raw --queries are sent before generated flag queries. Array of query strings generated using the Query class provided by the SDK. Learn more about queries (https://appwrite.io/docs/queries). Maximum of 100 queries are allowed, each 4096 characters long. You may filter on the following attributes: appId, type, targetType, target, analyzedAt`)
+  .option(
+    `--total [value]`,
+    `When set to false, the total count returned will be 0 and will not be calculated.`,
+    (value: string | undefined) =>
+      value === undefined ? true : parseBool(value),
+  )
+  .option(`--filter <expression>`, `Filter using a simple comparison expression. Repeat for multiple filters. Supports field=value, field!=value, field>value, field>=value, field<value, and field<=value.`, (value: string, previous: string[] | undefined) => collectQueryValue(parseFilterQuery(value), previous))
+  .option(`--where <expression>`, `Deprecated. Use --filter instead. Filter using a simple comparison expression. Repeat for multiple filters.`, (value: string, previous: string[] | undefined) => collectQueryValue(parseDeprecatedWhereQuery(value), previous))
+  .option(`--sort-asc <attribute>`, `Sort results by an attribute in ascending order. Repeat for multiple sort fields.`, (value: string, previous: string[] | undefined) => collectQueryValue(value, previous))
+  .option(`--sort-desc <attribute>`, `Sort results by an attribute in descending order. Repeat for multiple sort fields.`, (value: string, previous: string[] | undefined) => collectQueryValue(value, previous))
+  .option(`--limit <limit>`, `Maximum number of results to return.`, parseInteger)
+  .option(`--offset <offset>`, `Number of results to skip.`, parseInteger)
+  .option(`--cursor-after <id>`, `Return results after this cursor ID.`)
+  .option(`--cursor-before <id>`, `Return results before this cursor ID.`)
+  .action(
+    actionRunner(
+      async ({ queries, total, filter, where, sortAsc, sortDesc, cursorAfter, cursorBefore, limit, offset }) =>
+        parse(await (await getAdvisorClient()).listReports(buildQueries({ queries, filter, where, sortAsc, sortDesc, cursorAfter, cursorBefore, limit, offset }), total)),
+    ),
+  );
+
+
+const advisorGetReportCommand = advisor
+  .command(`get-report`)
+  .description(`Get an analyzer report by its unique ID. The response includes the report's metadata and the nested insights it produced.
+`)
+  .requiredOption(`--report-id <report-id>`, `Report ID.`)
+  .action(
+    actionRunner(
+      async ({ reportId }) =>
+        parse(await (await getAdvisorClient()).getReport(reportId)),
+    ),
+  );
+
+
+const advisorDeleteReportCommand = advisor
+  .command(`delete-report`)
+  .description(`Delete an analyzer report by its unique ID. Nested insights and CTA metadata are removed asynchronously by the deletes worker.
+`)
+  .requiredOption(`--report-id <report-id>`, `Report ID.`)
+  .action(
+    actionRunner(
+      async ({ reportId }) =>
+        parse(await (await getAdvisorClient()).deleteReport(reportId)),
+    ),
+  );
+
+
+const advisorListInsightsCommand = advisor
+  .command(`list-insights`)
+  .description(`List the insights produced under a single analyzer report. You can use the query params to filter your results further.
+`)
+  .requiredOption(`--report-id <report-id>`, `Parent report ID.`)
+  .option(`--queries [queries...]`, `Raw Appwrite JSON query strings (legacy). Use this for advanced queries or automation; for common filtering, sorting, and pagination prefer --filter, --sort-asc, --sort-desc, --limit, and --offset. When mixed, raw --queries are sent before generated flag queries. Array of query strings generated using the Query class provided by the SDK. Learn more about queries (https://appwrite.io/docs/queries). Maximum of 100 queries are allowed, each 4096 characters long. You may filter on the following attributes: type, severity, status, resourceType, resourceId, parentResourceType, parentResourceId, analyzedAt, dismissedAt, dismissedBy`)
+  .option(
+    `--total [value]`,
+    `When set to false, the total count returned will be 0 and will not be calculated.`,
+    (value: string | undefined) =>
+      value === undefined ? true : parseBool(value),
+  )
+  .option(`--filter <expression>`, `Filter using a simple comparison expression. Repeat for multiple filters. Supports field=value, field!=value, field>value, field>=value, field<value, and field<=value.`, (value: string, previous: string[] | undefined) => collectQueryValue(parseFilterQuery(value), previous))
+  .option(`--where <expression>`, `Deprecated. Use --filter instead. Filter using a simple comparison expression. Repeat for multiple filters.`, (value: string, previous: string[] | undefined) => collectQueryValue(parseDeprecatedWhereQuery(value), previous))
+  .option(`--sort-asc <attribute>`, `Sort results by an attribute in ascending order. Repeat for multiple sort fields.`, (value: string, previous: string[] | undefined) => collectQueryValue(value, previous))
+  .option(`--sort-desc <attribute>`, `Sort results by an attribute in descending order. Repeat for multiple sort fields.`, (value: string, previous: string[] | undefined) => collectQueryValue(value, previous))
+  .option(`--limit <limit>`, `Maximum number of results to return.`, parseInteger)
+  .option(`--offset <offset>`, `Number of results to skip.`, parseInteger)
+  .option(`--cursor-after <id>`, `Return results after this cursor ID.`)
+  .option(`--cursor-before <id>`, `Return results before this cursor ID.`)
+  .action(
+    actionRunner(
+      async ({ reportId, queries, total, filter, where, sortAsc, sortDesc, cursorAfter, cursorBefore, limit, offset }) =>
+        parse(await (await getAdvisorClient()).listInsights(reportId, buildQueries({ queries, filter, where, sortAsc, sortDesc, cursorAfter, cursorBefore, limit, offset }), total)),
+    ),
+  );
+
+
+const advisorGetInsightCommand = advisor
+  .command(`get-insight`)
+  .description(`Get an insight by its unique ID, scoped to its parent report.
+`)
+  .requiredOption(`--report-id <report-id>`, `Parent report ID.`)
+  .requiredOption(`--insight-id <insight-id>`, `Insight ID.`)
+  .action(
+    actionRunner(
+      async ({ reportId, insightId }) =>
+        parse(await (await getAdvisorClient()).getInsight(reportId, insightId)),
+    ),
+  );
+
+