Librarian API

const client = new NdxClient({
  apiKey: process.env.NEURADEX_API_KEY,
  projectId: 'your-project-id',
});

// Access Librarian API
const sessions = await client.librarian.listSessions();
const session = await client.librarian.getSession('session-id');

interface LibrarianSession {
  id: string;
  title: string;
  messageCount: number;
  createdAt: string;
  updatedAt: string;
}

const sessions = await client.librarian.listSessions();

for (const session of sessions) {
  console.log(`${session.title} (${session.messageCount} messages)`);
  console.log(`  Created: ${session.createdAt}`);
}

interface LibrarianSessionWithMessages {
  id: string;
  title: string;
  messages: LibrarianMessage[];
  metadata: object;
  createdAt: string;
  updatedAt: string;
}

interface LibrarianMessage {
  role: 'user' | 'assistant';
  content: string;
  sources?: KnowledgeSource[];
  timestamp: string;
}

const session = await client.librarian.getSession('session-id');

console.log(`Session: ${session.title}`);

for (const message of session.messages) {
  const prefix = message.role === 'user' ? 'User' : 'Librarian';
  console.log(`${prefix}: ${message.content}`);

  // Display referenced knowledge
  if (message.sources) {
    for (const source of message.sources) {
      console.log(`  Source: ${source.title}`);
    }
  }
}

// Get in YAML format (human-readable)
const yamlData = await client.librarian.getSessionAsYaml('session-id');
console.log(yamlData);

// Get in JSON format (easy to process programmatically)
const jsonData = await client.librarian.getSessionAsJson('session-id');
const parsed = JSON.parse(jsonData);

await client.librarian.deleteSession('session-id');
console.log('Session deleted');

async function analyzeLibrarianUsage() {
  const sessions = await client.librarian.listSessions();

  let totalMessages = 0;
  const topicsMap = new Map<string, number>();

  for (const session of sessions) {
    totalMessages += session.messageCount;

    // Get session details to analyze topics
    const detail = await client.librarian.getSession(session.id);
    for (const message of detail.messages) {
      if (message.role === 'user') {
        // Extract keywords from questions (simplified example)
        const keywords = extractKeywords(message.content);
        for (const keyword of keywords) {
          topicsMap.set(keyword, (topicsMap.get(keyword) || 0) + 1);
        }
      }
    }
  }

  console.log(`Total messages: ${totalMessages}`);
  console.log('Frequently asked topics:');
  for (const [topic, count] of topicsMap) {
    console.log(`  ${topic}: ${count} times`);
  }
}

import fs from 'fs';

async function exportSessions() {
  const sessions = await client.librarian.listSessions();

  const exportData = [];
  for (const session of sessions) {
    const detail = await client.librarian.getSession(session.id);
    exportData.push(detail);
  }

  fs.writeFileSync(
    'librarian-sessions-backup.json',
    JSON.stringify(exportData, null, 2)
  );

  console.log(`Exported ${sessions.length} sessions`);
}