Function saveVoiceAspects

apps/webapp/app/services/aspectStore.server.ts:48–93

(
  aspects: Array<{
    fact: string;
    aspect: VoiceAspect;
    episodeUuid: string;
    userId: string;
    workspaceId: string;
  }>,
)

 * Save voice aspects from extraction and store their embeddings
 */
export async function saveVoiceAspects(
  aspects: Array<{
    fact: string;
    aspect: VoiceAspect;
    episodeUuid: string;
    userId: string;
    workspaceId: string;
  }>,
): Promise<VoiceAspectNode[]> {
  if (aspects.length === 0) return [];

  const saved: VoiceAspectNode[] = [];

  for (const a of aspects) {
    const record = await prisma.voiceAspect.create({
      data: {
        fact: a.fact,
        aspect: a.aspect,
        episodeUuids: [a.episodeUuid],
        userId: a.userId,
        workspaceId: a.workspaceId,
        validAt: new Date(),
      },
    });
    saved.push(toNode(record));
  }

  // Generate and store embeddings in vector provider
  const embeddings = await Promise.all(saved.map((s) => getEmbedding(s.fact)));

  const items = saved.map((s, i) => ({
    id: s.uuid,
    vector: embeddings[i],
    content: s.fact,
    metadata: {
      userId: s.userId,
      workspaceId: s.workspaceId,
      aspect: s.aspect,
      type: "voice_aspect",
    },
  }));

  await vectorProvider().batchUpsert(items, VECTOR_NAMESPACES.ASPECT);

  return saved;
}

/**
 * Find similar voice aspects by vector similarity (for dedup in aspect-resolution)