feat(channel): add zip/delta package modes

cli/README.md

@@ -948,6 +948,7 @@ npx @capgo/cli@latest channel set production com.example.app --bundle 1.0.0 --st
 | **--self-assign** | <code>boolean</code> | Allow device to self-assign to this channel |
 | **--no-self-assign** | <code>boolean</code> | Disable devices to self-assign to this channel |
 | **--disable-auto-update** | <code>string</code> | Block updates by type: major, minor, metadata, patch, or none (allows all) |
+| **--update-package** | <code>string</code> | Serve zip, delta, or both: all, zip, delta, zip_from_builtin, or delta_from_builtin |
 | **--rollout-bundle** | <code>string</code> | Bundle version to release gradually on this channel |
 | **--rollout-percentage** | <code>string</code> | Rollout percentage from 0 to 100 |
 | **--rollout-percentage-bps** | <code>string</code> | Rollout percentage in basis points from 0 to 10000 |

cli/src/bundle/upload.ts

@@ -25,7 +25,7 @@ import { showReplicationProgress } from '../replicationProgress'
 import { CliUserError } from '../shared/cli-user-error'
 import { formatTable } from '../terminal-table'
 import { usesAlwaysDirectUpdate } from '../updaterConfig'
-import { baseKeyV2, BROTLI_MIN_UPDATER_VERSION_V5, BROTLI_MIN_UPDATER_VERSION_V6, BROTLI_MIN_UPDATER_VERSION_V7, canPromptInteractively, checkCompatibilityCloud, checkPlanValidUpload, checkRemoteCliMessages, createSupabaseClient, deletedFailedVersion, deltaManifestTooLargeMessage, findRoot, findSavedKey, formatError, getAppId, getBundleVersion, getCompatibilityDetails, getConfig, getInstalledVersion, getLocalConfig, getLocalDependencies, getOrganizationId, getPMAndCommand, getRemoteChecksums, getRemoteFileConfig, hasCliPermission, invokeCapgoCliApi, isCompatible, isDeprecatedPluginVersion, MAX_MANIFEST_ENTRIES, regexSemver, resolveUserIdFromApiKey, sendEvent, setVersionManifest, updateConfigUpdater, updateOrCreateChannel, updateOrCreateVersion, UPLOAD_TIMEOUT, UPLOAD_TIMEOUT_ERROR_NAME, uploadTimeoutMessage, uploadTUS, uploadUrl, zipFile } from '../utils'
+import { baseKeyV2, BROTLI_MIN_UPDATER_VERSION_V5, BROTLI_MIN_UPDATER_VERSION_V6, BROTLI_MIN_UPDATER_VERSION_V7, canPromptInteractively, channelUpdatePackageCliError, checkCompatibilityCloud, checkPlanValidUpload, checkRemoteCliMessages, createSupabaseClient, deletedFailedVersion, deltaManifestTooLargeMessage, findRoot, findSavedKey, formatError, getAppId, getBundleVersion, getCompatibilityDetails, getConfig, getInstalledVersion, getLocalConfig, getLocalDependencies, getOrganizationId, getPMAndCommand, getRemoteChecksums, getRemoteFileConfig, hasCliPermission, invokeCapgoCliApi, isCompatible, isDeprecatedPluginVersion, MAX_MANIFEST_ENTRIES, regexSemver, resolveUserIdFromApiKey, sendEvent, setVersionManifest, updateConfigUpdater, updateOrCreateChannel, updateOrCreateVersion, UPLOAD_TIMEOUT, UPLOAD_TIMEOUT_ERROR_NAME, uploadTimeoutMessage, uploadTUS, uploadUrl, zipFile } from '../utils'
 import type { AutoBumpLevel } from '../versionHelpers'
 import { autoBumpVersionBy, getVersionSuggestions, interactiveVersionBump, normalizeAutoBumpInput } from '../versionHelpers'
 import { resolveAutoBumpLevelFromAi } from './auto-bump-ai'
@@ -65,6 +65,11 @@ function uploadFail(message: string): never {
   throw new CliUserError(message)
 }
 
+async function uploadFailIfChannelError(error: unknown, fallback: () => string | Promise<string>): Promise<never> {
+  const packageError = await channelUpdatePackageCliError(error)
+  uploadFail(packageError || await fallback())
+}
+
 // A user-initiated cancel is an expected exit, not a crash: warn instead of
 // error, and throw `CliUserError` so error tracking skips it.
 function uploadCancel(): never {
@@ -1025,8 +1030,9 @@ async function promoteExistingChannel(
     supaAnon: options?.supaAnon,
   })
 
-  if (error)
-    uploadFail(`Cannot set channel because this API key does not have the required RBAC permission. ${await formatFunctionInvokeError(error)}`)
+  if (error) {
+    await uploadFailIfChannelError(error, async () => `Cannot set channel because this API key does not have the required RBAC permission. ${await formatFunctionInvokeError(error)}`)
+  }
 
   const bundleUrl = `${localConfig.hostWeb}/app/${appid}/channel/${targetChannel.id}`
   if (targetChannel.public)
@@ -1088,16 +1094,18 @@ async function setVersionInChannel(
       owner_org: orgId,
       ...(selfAssign ? { allow_device_self_set: true } : {}),
     })
-    if (dbError3)
-      uploadFail(`Cannot set channel because this API key does not have the required RBAC permission. ${formatError(dbError3)}`)
-    const bundleUrl = `${localConfig.hostWeb}/app/${appid}/channel/${data.id}`
-    if (data?.public)
-      log.info('Your update is now available in your public channel 🎉')
-    else if (data?.id)
-      log.info(`Link device to this bundle to try it: ${bundleUrl}`)
-
-    if (displayBundleUrl)
-      log.info(`Bundle url: ${bundleUrl}`)
+    if (dbError3) {
+      await uploadFailIfChannelError(dbError3, () => `Cannot set channel because this API key does not have the required RBAC permission. ${formatError(dbError3)}`)
+    }
+    if (data?.id) {
+      const bundleUrl = `${localConfig.hostWeb}/app/${appid}/channel/${data.id}`
+      if (data.public)
+        log.info('Your update is now available in your public channel 🎉')
+      else
+        log.info(`Link device to this bundle to try it: ${bundleUrl}`)
+      if (displayBundleUrl)
+        log.info(`Bundle url: ${bundleUrl}`)
+    }
     return true
   }
 
@@ -1117,7 +1125,7 @@ async function setVersionInChannel(
       supaAnon: cliHost?.supaAnon,
     })
     if (error) {
-      uploadFail(`Cannot create channel and set its bundle because this API key does not have the required RBAC permission. ${await formatFunctionInvokeError(error)}`)
+      await uploadFailIfChannelError(error, async () => `Cannot create channel and set its bundle because this API key does not have the required RBAC permission. ${await formatFunctionInvokeError(error)}`)
     }
 
     const createdChannel = data as { id?: unknown, public?: unknown } | null
@@ -1204,8 +1212,9 @@ async function setRolloutVersionInChannel(
     supaAnon: cliHost?.supaAnon,
   })
 
-  if (rolloutError)
-    uploadFail(`Cannot set rollout in channel ${await formatFunctionInvokeError(rolloutError)}`)
+  if (rolloutError) {
+    await uploadFailIfChannelError(rolloutError, async () => `Cannot set rollout in channel ${await formatFunctionInvokeError(rolloutError)}`)
+  }
 
   const bundleUrl = `${localConfig.hostWeb}/app/${appid}/channel/${targetChannel.id}`
   log.info(`Set ${appid} channel ${channel} rollout target to @${bundle} (${formatRolloutPercentage(rolloutPercentageBps)})`)

cli/src/channel/set.ts

@@ -8,7 +8,7 @@ import { getActiveAppVersions, getVersionData } from '../api/versions'
 import { sendUpdateNotificationsForChannels } from '../notifications/send-update'
 import { printPreviewQrForResolvedTarget, resolveChannelPreviewTarget } from '../preview/qr'
 import { formatTable } from '../terminal-table'
-import { checkCompatibilityNativePackages, checkPlanValid, createSupabaseClient, findSavedKey, getAppId, getBundleVersion, getCompatibilityDetails, getConfig, getOrganizationId, invokeCapgoCliApi, isCompatible, resolveUserIdFromApiKey, sendEvent } from '../utils'
+import { channelUpdatePackageCliError, checkCompatibilityNativePackages, checkPlanValid, createSupabaseClient, findSavedKey, getAppId, getBundleVersion, getCompatibilityDetails, getConfig, getOrganizationId, invokeCapgoCliApi, isCompatible, resolveUserIdFromApiKey, sendEvent } from '../utils'
 
 /**
  * Display a compatibility table for the given packages
@@ -34,6 +34,7 @@ function displayCompatibilityTable(packages: Compatibility[]) {
 export type { OptionsSetChannel } from '../schemas/channel'
 
 const disableAutoUpdatesPossibleOptions = ['major', 'minor', 'metadata', 'patch', 'none']
+const updatePackagePossibleOptions = ['all', 'zip', 'delta', 'zip_from_builtin', 'delta_from_builtin'] as const
 
 function assertIntegerInRange(value: number, label: string, min: number, max: number) {
   if (!Number.isFinite(value) || !Number.isInteger(value) || value < min || value > max)
@@ -93,6 +94,7 @@ export async function setChannelInternal(channel: string, appId: string, options
     android,
     selfAssign,
     disableAutoUpdate,
+    updatePackage,
     dev,
     emulator,
     device,
@@ -152,6 +154,7 @@ export async function setChannelInternal(channel: string, appId: string, options
     && device == null
     && prod == null
     && disableAutoUpdate == null
+    && updatePackage == null
     && rolloutBundle == null
     && rolloutPercentage == null
     && rolloutPercentageBps == null
@@ -201,6 +204,7 @@ export async function setChannelInternal(channel: string, appId: string, options
     || android != null
     || selfAssign != null
     || disableAutoUpdate != null
+    || updatePackage != null
     || dev != null
     || emulator != null
     || device != null
@@ -577,6 +581,17 @@ export async function setChannelInternal(channel: string, appId: string, options
       log.info(`Set ${appId} channel: ${channel} to ${finalDisableAutoUpdate} disable update strategy to this channel`)
   }
 
+  if (updatePackage != null) {
+    if (!updatePackagePossibleOptions.includes(updatePackage)) {
+      if (!silent)
+        log.error(`Update package ${updatePackage} is not known. The possible values are: ${updatePackagePossibleOptions.join(', ')}.`)
+      throw new Error(`Unknown update package ${updatePackage}`)
+    }
+    channelPayload.update_package = updatePackage
+    if (!silent)
+      log.info(`Set ${appId} channel: ${channel} update package to ${updatePackage}`)
+  }
+
   if (hasStableBundlePromotion && !hasSettingsUpdate) {
     const { error } = await invokeCapgoCliApi('bundle', {
       apikey: options.apikey!,
@@ -590,6 +605,12 @@ export async function setChannelInternal(channel: string, appId: string, options
       supaAnon: options.supaAnon,
     })
     if (error) {
+      const packageError = await channelUpdatePackageCliError(error)
+      if (packageError) {
+        if (!silent)
+          log.error(packageError)
+        throw new Error(packageError)
+      }
       if (!silent)
         log.error('Cannot set channel because this API key does not have the required RBAC permission.')
       throw new Error('API key is not allowed to set this channel')
@@ -627,6 +648,8 @@ export async function setChannelInternal(channel: string, appId: string, options
       channelBody.disableAutoUpdateUnderNative = channelPayload.disable_auto_update_under_native
     if (channelPayload.disable_auto_update !== undefined)
       channelBody.disableAutoUpdate = channelPayload.disable_auto_update
+    if (channelPayload.update_package !== undefined)
+      channelBody.updatePackage = channelPayload.update_package
     if (channelPayload.ios !== undefined)
       channelBody.ios = channelPayload.ios
     if (channelPayload.android !== undefined)
@@ -696,6 +719,12 @@ export async function setChannelInternal(channel: string, appId: string, options
       supaAnon: options.supaAnon,
     })
     if (dbError) {
+      const packageError = await channelUpdatePackageCliError(dbError)
+      if (packageError) {
+        if (!silent)
+          log.error(packageError)
+        throw new Error(packageError)
+      }
       if (!silent)
         log.error('Cannot set channel because this API key does not have the required RBAC permission.')
       throw new Error('API key is not allowed to set this channel')

cli/src/index.ts

@@ -592,6 +592,7 @@ Example: npx @capgo/cli@latest channel set production com.example.app --bundle 1
   .option('--self-assign', `Allow device to self-assign to this channel`)
   .option('--no-self-assign', `Disable devices to self-assign to this channel`)
   .option('--disable-auto-update <disableAutoUpdate>', `Block updates by type: major, minor, metadata, patch, or none (allows all)`)
+  .option('--update-package <updatePackage>', `Serve zip, delta, or both: all, zip, delta, zip_from_builtin, or delta_from_builtin`)
   .option('--rollout-bundle <rolloutBundle>', `Bundle version to release gradually on this channel`)
   .option('--rollout-percentage <rolloutPercentage>', `Rollout percentage from 0 to 100`, value => Number.parseFloat(value))
   .option('--rollout-percentage-bps <rolloutPercentageBps>', `Rollout percentage in basis points from 0 to 10000`, value => Number.parseInt(value, 10))

cli/src/schemas/channel.ts

@@ -61,6 +61,7 @@ export const optionsSetChannelSchema = optionsBaseSchema.extend({
   android: z.boolean().optional(),
   selfAssign: z.boolean().optional(),
   disableAutoUpdate: z.string().optional(),
+  updatePackage: z.enum(['all', 'zip', 'delta', 'zip_from_builtin', 'delta_from_builtin']).optional(),
   dev: z.boolean().optional(),
   emulator: z.boolean().optional(),
   device: z.boolean().optional(),

cli/src/schemas/sdk.ts

@@ -203,6 +203,7 @@ export const updateChannelOptionsBaseSchema = z.object({
   android: z.boolean().optional(),
   selfAssign: z.boolean().optional(),
   disableAutoUpdate: z.string().optional(),
+  updatePackage: z.enum(['all', 'zip', 'delta', 'zip_from_builtin', 'delta_from_builtin']).optional(),
   dev: z.boolean().optional(),
   emulator: z.boolean().optional(),
   device: z.boolean().optional(),

cli/src/sdk.ts

@@ -44,6 +44,7 @@ import type {
   ZipBundleOptions,
 } from './schemas/sdk'
 import type { Organization } from './utils'
+import { buildCliRequestHeaders } from './analytics/cli-headers'
 import { checkAppExistsAndHasPermissionOrgErr } from './api/app'
 import { getActiveAppVersions } from './api/versions'
 import { addAppInternal } from './app/add'
@@ -74,7 +75,6 @@ import { deleteOrganizationInternal } from './organization/delete'
 import { listOrganizationsInternal } from './organization/list'
 import { setOrganizationInternal } from './organization/set'
 import { getUserIdInternal } from './user/account'
-import { buildCliRequestHeaders } from './analytics/cli-headers'
 import { createSupabaseClient, findSavedKey, getConfig, getLocalConfig } from './utils'
 import { parseSecurityPolicyError } from './utils/security_policy_errors'
 import { normalizeAutoBumpInput } from './versionHelpers'
@@ -873,6 +873,7 @@ export class CapgoSDK {
         android: options.android,
         selfAssign: options.selfAssign,
         disableAutoUpdate: options.disableAutoUpdate ?? undefined,
+        updatePackage: options.updatePackage,
         dev: options.dev,
         emulator: options.emulator,
         device: options.device,
@@ -1209,7 +1210,7 @@ export class CapgoSDK {
 
       const response = await fetch(`${localConfig.hostApi}/private/stats`, {
         method: 'POST',
-headers: buildCliRequestHeaders({ 'Content-Type': 'application/json', capgkey: apikey }),
+        headers: buildCliRequestHeaders({ 'Content-Type': 'application/json', 'capgkey': apikey }),
         body: JSON.stringify(query),
       })
 

cli/src/types/supabase.types.ts

@@ -840,6 +840,7 @@ export type Database = {
           rollout_percentage_bps: number
           rollout_version: number | null
           rbac_id: string
+          update_package: Database["public"]["Enums"]["channel_update_package"]
           updated_at: string
           version: number | null
         }
@@ -879,6 +880,7 @@ export type Database = {
           rollout_percentage_bps?: number
           rollout_version?: number | null
           rbac_id?: string
+          update_package?: Database["public"]["Enums"]["channel_update_package"]
           updated_at?: string
           version?: number | null
         }
@@ -918,6 +920,7 @@ export type Database = {
           rollout_percentage_bps?: number
           rollout_version?: number | null
           rbac_id?: string
+          update_package?: Database["public"]["Enums"]["channel_update_package"]
           updated_at?: string
           version?: number | null
         }
@@ -4775,6 +4778,12 @@ export type Database = {
     }
     Enums: {
       action_type: "mau" | "storage" | "bandwidth" | "build_time"
+      channel_update_package:
+        | "all"
+        | "zip"
+        | "delta"
+        | "zip_from_builtin"
+        | "delta_from_builtin"
       credit_metric_type: "mau" | "bandwidth" | "storage" | "build_time"
       credit_transaction_type:
         | "grant"
@@ -5036,6 +5045,13 @@ export const Constants = {
   public: {
     Enums: {
       action_type: ["mau", "storage", "bandwidth", "build_time"],
+      channel_update_package: [
+        "all",
+        "zip",
+        "delta",
+        "zip_from_builtin",
+        "delta_from_builtin",
+      ],
       credit_metric_type: ["mau", "bandwidth", "storage", "build_time"],
       credit_transaction_type: [
         "grant",

cli/src/utils.ts

@@ -816,6 +816,25 @@ export function formatCapgoApiErrorBody(body: unknown): string {
   return [record.error, record.message, record.status].filter(Boolean).join(' | ')
 }
 
+function messageAfterPrefix(text: string, prefix: string): string {
+  const index = text.indexOf(prefix)
+  if (index < 0)
+    return text
+  return text.slice(index + prefix.length).replace(/^:\s*/, '').split('\n')[0]!.trim()
+}
+
+export async function channelUpdatePackageCliError(error: unknown): Promise<string | null> {
+  const payload = await readCapgoCliApiErrorPayload(error)
+  if (payload?.error === 'channel_zip_required' || payload?.error === 'channel_delta_required')
+    return payload.message || payload.error
+  const text = error instanceof Error ? error.message : String(error ?? '')
+  if (text.includes('CHANNEL_ZIP_REQUIRED'))
+    return messageAfterPrefix(text, 'CHANNEL_ZIP_REQUIRED')
+  if (text.includes('CHANNEL_DELTA_REQUIRED'))
+    return messageAfterPrefix(text, 'CHANNEL_DELTA_REQUIRED')
+  return null
+}
+
 /** Capgo-managed Supabase hosts (cloud). Match hostname exactly. */
 export function isCapgoManagedSupabaseHost(supaHost?: string): boolean {
   if (!supaHost)