Merge pull request #274 from CambrianTech/feature/bevy-avatars

Bevy avatar rendering + LiveKit video pipeline

Author: joelteply

.gitignore

@@ -179,3 +179,4 @@ src/commands/**/*.d.ts
 !test*output.txt
 _archive/
 src/.continuum/sessions/validation/
+/src/widgets/live/public/live-widget.css

src/.gitignore

@@ -51,6 +51,14 @@ system/genome/python/venv/
 # Generated TypeScript from Rust via ts-rs (regenerated by: npx tsx generator/generate-rust-bindings.ts)
 shared/generated/
 
+# Generated from SCSS by compile-sass.ts (regenerated by npm start)
+widgets/**/public/*.styles.ts
+widgets/**/public/*.css
+widgets/**/public/*.css.map
+# Legacy locations (some widgets have styles in non-public dirs)
+widgets/**/*.styles.ts
+!widgets/shared/styles/
+
 # Rust build artifacts
 # Compiled files
 *.o

src/commands/adapter/adopt/server/AdapterAdoptServerCommand.ts

@@ -105,6 +105,7 @@ export class AdapterAdoptServerCommand extends CommandBase<AdapterAdoptParams, A
 
       // Find the persona
       const personaResult = await DataRead.execute<UserEntity>({
+          dbHandle: 'default',
           collection: COLLECTIONS.USERS,
           id: targetPersonaId,
         }
@@ -153,6 +154,7 @@ export class AdapterAdoptServerCommand extends CommandBase<AdapterAdoptParams, A
       };
 
       const createLayerResult = await DataCreate.execute<GenomeLayerEntity>({
+          dbHandle: 'default',
           collection: 'genome_layers',
           data: layer,
         }
@@ -171,6 +173,7 @@ export class AdapterAdoptServerCommand extends CommandBase<AdapterAdoptParams, A
       if (targetPersona.genomeId) {
         // Load existing genome
         const genomeResult = await DataRead.execute<GenomeEntity>({
+            dbHandle: 'default',
             collection: 'genomes',
             id: targetPersona.genomeId,
           }
@@ -213,6 +216,7 @@ export class AdapterAdoptServerCommand extends CommandBase<AdapterAdoptParams, A
       if (!isNewGenome) {
         // Update existing genome
         const updateResult = await DataUpdate.execute<GenomeEntity>({
+            dbHandle: 'default',
             collection: 'genomes',
             id: genome.id,
             data: { layers: genome.layers, metadata: genome.metadata, updatedAt: genome.updatedAt },
@@ -223,6 +227,7 @@ export class AdapterAdoptServerCommand extends CommandBase<AdapterAdoptParams, A
         }
       } else {
         const createGenomeResult = await DataCreate.execute<GenomeEntity>({
+            dbHandle: 'default',
             collection: 'genomes',
             data: genome,
           }
@@ -233,6 +238,7 @@ export class AdapterAdoptServerCommand extends CommandBase<AdapterAdoptParams, A
 
         // Update persona with genome ID
         await DataUpdate.execute<UserEntity>({
+            dbHandle: 'default',
             collection: COLLECTIONS.USERS,
             id: targetPersonaId_resolved,
             data: { genomeId: genome.id },

src/commands/ai/adapter/test/server/AdapterTestServerCommand.ts

@@ -77,6 +77,7 @@ export class AdapterTestServerCommand extends CommandBase<AdapterTestParams, Asy
 
     // Save to database using data/create command
     const createResult = await DataCreate.execute({
+      dbHandle: 'default',
       collection: TestExecutionEntity.collection,
       data: { ...execution, id: testId },
     });
@@ -175,6 +176,7 @@ export class AdapterTestServerCommand extends CommandBase<AdapterTestParams, Asy
    */
   private async updateTestStatus(testId: string, updates: Partial<TestExecutionEntity>): Promise<void> {
     await DataUpdate.execute({
+      dbHandle: 'default',
       collection: TestExecutionEntity.collection,
       id: testId,
       data: {

src/commands/ai/context/slice/server/AiContextSliceServerCommand.ts

@@ -41,6 +41,7 @@ export class AiContextSliceServerCommand extends CommandBase<AiContextSliceParam
     try {
       // Read the entity
       const result = await DataRead.execute({
+        dbHandle: 'default',
         collection,
         id: params.id
       });
@@ -142,6 +143,7 @@ export class AiContextSliceServerCommand extends CommandBase<AiContextSliceParam
       // Thread context (replyTo field)
       if (data.replyTo) {
         const parentResult = await DataRead.execute({
+          dbHandle: 'default',
           collection,
           id: data.replyTo
         });
@@ -157,6 +159,7 @@ export class AiContextSliceServerCommand extends CommandBase<AiContextSliceParam
       if (relatedIdsField && data[relatedIdsField].length > 0) {
         for (const relatedId of data[relatedIdsField].slice(0, limit)) {
           const relatedResult = await DataRead.execute({
+            dbHandle: 'default',
             collection,
             id: relatedId
           });

src/commands/ai/cost/server/AICostServerCommand.ts

@@ -47,6 +47,7 @@ export class AICostServerCommand extends AICostCommand {
         params.context,
         params.sessionId,
         {
+          dbHandle: 'default' as const,
           collection: 'ai_generations',
           filter,
           orderBy: [{ field: 'timestamp', direction: 'desc' }]

src/commands/ai/dataset/create/server/DatasetCreateServerCommand.ts

@@ -61,6 +61,7 @@ export class DatasetCreateServerCommand {
 
     // Save to database
     const createResult = await DataCreate.execute({
+      dbHandle: 'default',
       collection: DatasetExecutionEntity.collection,
       data: { ...execution, id: jobId },
     });
@@ -195,6 +196,7 @@ export class DatasetCreateServerCommand {
    */
   private async updateJobStatus(jobId: string, updates: Partial<DatasetExecutionEntity>): Promise<void> {
     await DataUpdate.execute({
+      dbHandle: 'default',
       collection: DatasetExecutionEntity.collection,
       id: jobId,
       data: updates,

src/commands/ai/detect-semantic-loop/server/AiDetectSemanticLoopServerCommand.ts

@@ -174,6 +174,7 @@ export class AiDetectSemanticLoopServerCommand extends CommandBase<AiDetectSeman
     let recentMessages: RawChatMessage[];
     try {
       const result = await DataList.execute({
+        dbHandle: 'default',
         collection: 'chat_messages',
         filter,
         limit: lookbackCount,

src/commands/ai/generate/server/AIGenerateServerCommand.ts

@@ -47,7 +47,7 @@ export class AIGenerateServerCommand extends AIGenerateCommand {
             collection: UserEntity.collection,
             filter: { type: 'persona' },
             limit: 1
-          });
+          }, 'default');
 
           if (!usersResult.success || !usersResult.data || usersResult.data.length === 0) {
             return createErrorResult(params, 'No personas found in system');

src/commands/ai/rag/index/create/server/IndexCreateServerCommand.ts

@@ -89,6 +89,7 @@ export class IndexCreateServerCommand extends IndexCreateCommand {
 
       // Store in database using Commands.execute
       const result = await DataCreate.execute({
+        dbHandle: 'default',
         collection: CodeIndexEntity.collection,
         data: entry,
         context: this.context,