chore: wip

Author: chrisbbreuer

packages/ts-cloud/bin/cli.ts

@@ -23,6 +23,26 @@ import {
   registerStackCommands,
   registerUtilsCommands,
   registerAnalyticsCommands,
+  // New infrastructure commands
+  registerCdnCommands,
+  registerStorageCommands,
+  registerCacheCommands,
+  registerQueueCommands,
+  registerNetworkCommands,
+  // Scheduling & Events
+  registerSchedulerCommands,
+  registerEventsCommands,
+  // Communication
+  registerEmailCommands,
+  registerNotifyCommands,
+  // Security & Access
+  registerIamCommands,
+  registerAuditCommands,
+  // Operations
+  registerStatusCommands,
+  registerBackupCommands,
+  registerApiCommands,
+  registerTunnelCommands,
 } from './commands'
 
 const app = new CLI('cloud')
@@ -40,27 +60,70 @@ app
 // ============================================
 // Register All Commands
 // ============================================
+
+// Core commands
 registerInitCommands(app)
 registerConfigCommands(app)
 registerGenerateCommands(app)
+registerDeployCommands(app)
+registerStackCommands(app)
+
+// Infrastructure Management
 registerServerCommands(app)
 registerFunctionCommands(app)
 registerContainerCommands(app)
+registerCdnCommands(app)
+registerStorageCommands(app)
+registerCacheCommands(app)
+registerQueueCommands(app)
+registerNetworkCommands(app)
+
+// Domain & DNS
 registerDomainCommands(app)
+registerSslCommands(app)
+
+// Database & Data
 registerDatabaseCommands(app)
+
+// Monitoring & Logs
 registerLogsCommands(app)
+registerStatusCommands(app)
+
+// Scheduling & Events
+registerSchedulerCommands(app)
+registerEventsCommands(app)
+
+// Communication
+registerEmailCommands(app)
+registerNotifyCommands(app)
+
+// Security & Access
 registerSecretsCommands(app)
 registerFirewallCommands(app)
-registerSslCommands(app)
+registerIamCommands(app)
+registerAuditCommands(app)
+
+// Operations & Backup
+registerBackupCommands(app)
+registerApiCommands(app)
+
+// Cost & Resources
 registerCostCommands(app)
+
+// Git & Environment
 registerGitCommands(app)
 registerEnvironmentCommands(app)
+
+// Assets & Team
 registerAssetsCommands(app)
 registerTeamCommands(app)
-registerDeployCommands(app)
-registerStackCommands(app)
-registerUtilsCommands(app, version)
+
+// Analytics & Tunnel
 registerAnalyticsCommands(app)
+registerTunnelCommands(app)
+
+// Utilities
+registerUtilsCommands(app, version)
 
 // ============================================
 // Help & Version

packages/ts-cloud/bin/commands/analytics.ts

@@ -204,4 +204,125 @@ export function registerAnalyticsCommands(app: CLI): void {
         process.exit(1)
       }
     })
+
+  app
+    .command('analytics:query <siteId>', 'Query analytics data for a site')
+    .option('--table <name>', 'DynamoDB table name', { default: 'ts-analytics' })
+    .option('--region <region>', 'AWS region', { default: 'us-east-1' })
+    .option('--limit <n>', 'Max items to return', { default: '10' })
+    .option('--type <type>', 'Filter by type (pageview, event, etc.)')
+    .action(async (siteId: string, options: { table: string; region: string; limit: string; type?: string }) => {
+      cli.header(`Analytics Data: ${siteId}`)
+
+      try {
+        const dynamodb = new DynamoDBClient(options.region)
+
+        const spinner = new cli.Spinner('Querying data...')
+        spinner.start()
+
+        const result = await dynamodb.query({
+          TableName: options.table,
+          KeyConditionExpression: 'pk = :pk',
+          ExpressionAttributeValues: {
+            ':pk': { S: `SITE#${siteId}` },
+          },
+          ScanIndexForward: false,
+          Limit: parseInt(options.limit, 10),
+        })
+
+        spinner.succeed(`Found ${result.Items?.length || 0} items`)
+
+        if (!result.Items || result.Items.length === 0) {
+          cli.info('No data found for this site')
+          return
+        }
+
+        const items = result.Items.map(item => DynamoDBClient.unmarshal(item))
+
+        for (const item of items) {
+          cli.info('')
+          cli.info(`SK: ${item.sk}`)
+          if (item.path) cli.info(`  Path: ${item.path}`)
+          if (item.timestamp) cli.info(`  Time: ${item.timestamp}`)
+          if (item.visitorId) cli.info(`  Visitor: ${item.visitorId}`)
+          if (item.browser) cli.info(`  Browser: ${item.browser}`)
+          if (item.country) cli.info(`  Country: ${item.country}`)
+        }
+      }
+      catch (error: any) {
+        cli.error(`Failed to query data: ${error.message}`)
+        process.exit(1)
+      }
+    })
+
+  app
+    .command('analytics:realtime <siteId>', 'Check realtime visitors for a site')
+    .option('--table <name>', 'DynamoDB table name', { default: 'ts-analytics' })
+    .option('--region <region>', 'AWS region', { default: 'us-east-1' })
+    .option('--minutes <n>', 'Minutes to look back', { default: '5' })
+    .action(async (siteId: string, options: { table: string; region: string; minutes: string }) => {
+      cli.header(`Realtime: ${siteId}`)
+
+      try {
+        const dynamodb = new DynamoDBClient(options.region)
+
+        const spinner = new cli.Spinner('Checking realtime...')
+        spinner.start()
+
+        const minutesAgo = parseInt(options.minutes, 10)
+        const cutoff = new Date(Date.now() - minutesAgo * 60 * 1000)
+
+        const result = await dynamodb.query({
+          TableName: options.table,
+          KeyConditionExpression: 'pk = :pk AND sk BETWEEN :start AND :end',
+          ExpressionAttributeValues: {
+            ':pk': { S: `SITE#${siteId}` },
+            ':start': { S: `PAGEVIEW#${cutoff.toISOString()}` },
+            ':end': { S: 'PAGEVIEW#Z' },
+          },
+          ScanIndexForward: false,
+        })
+
+        spinner.succeed(`Found ${result.Items?.length || 0} pageviews in last ${minutesAgo} minutes`)
+
+        if (!result.Items || result.Items.length === 0) {
+          cli.warn('No recent pageviews found')
+          cli.info('')
+          cli.info('Possible issues:')
+          cli.info('  1. Tracking script not installed correctly')
+          cli.info('  2. Site ID mismatch')
+          cli.info('  3. CORS or network issues')
+          return
+        }
+
+        const items = result.Items.map(item => DynamoDBClient.unmarshal(item))
+        const uniqueVisitors = new Set(items.map(i => i.visitorId)).size
+
+        cli.info('')
+        cli.success(`${uniqueVisitors} unique visitor(s) online`)
+        cli.info('')
+
+        // Group by path
+        const byPath: Record<string, number> = {}
+        for (const item of items) {
+          const path = item.path || '/'
+          byPath[path] = (byPath[path] || 0) + 1
+        }
+
+        cli.info('Active pages:')
+        for (const [path, count] of Object.entries(byPath).sort((a, b) => b[1] - a[1]).slice(0, 5)) {
+          cli.info(`  ${path}: ${count} view(s)`)
+        }
+
+        cli.info('')
+        cli.info('Recent pageviews:')
+        for (const item of items.slice(0, 5)) {
+          cli.info(`  ${item.timestamp} - ${item.path} (${item.browser || 'Unknown'})`)
+        }
+      }
+      catch (error: any) {
+        cli.error(`Failed to check realtime: ${error.message}`)
+        process.exit(1)
+      }
+    })
 }