Frameworks & Chat

import { Elysia } from 'elysia';
import { anthropic } from '@absolutejs/ai/anthropic';
import {
  createRAGCollection,
  openaiEmbeddings,
  ragChat
} from '@absolutejs/rag';
import { createPostgresRAGStore } from '@absolutejs/rag-postgres';

const collection = createRAGCollection({
  embedding: openaiEmbeddings({
    apiKey: process.env.OPENAI_API_KEY ?? '',
    defaultModel: 'text-embedding-3-small',
    dimensions: 1536
  }),
  store: createPostgresRAGStore({ dimensions: 1536 })
});

new Elysia()
  .use(
    ragChat({
      collection,
      path: '/rag', // default
      provider: () => anthropic({ apiKey: process.env.ANTHROPIC_API_KEY }),
      systemPrompt: 'Answer from the retrieved context and cite sources.',
      topK: 6 // default
    })
  )
  .listen(3000);

import { createRAGClient, createRAGWorkflow } from '@absolutejs/rag/client';

// Framework-free browser client : typed fetch over every route the
// plugin mounts. Pass the same path you gave ragChat.
const client = createRAGClient({ path: '/rag' });

const results = await client.search({ query: 'How do deploys work?' });
const detailed = await client.searchWithTrace({
  query: 'How do deploys work?'
});

await client.ingestDocuments({
  documents: [{ id: 'deploys', text: 'Deploys run on every push to main.' }]
});

const status = await client.status();
const operations = await client.ops();
await client.syncAllSources();

// WebSocket answer workflow over the same path : send a query, then
// read retrieval stage, streamed answer, sources, and citations.
const workflow = createRAGWorkflow('/rag');
workflow.query('How do deploys work?');
workflow.isRetrieving;
workflow.sources;
workflow.citations;
workflow.groundedAnswer;

import { useRAG } from '@absolutejs/rag/react';

export const DocsAssistant = () => {
  // One hook composes search, ingest, status, ops, documents, chunk
  // preview, evaluate, index admin, and the streaming answer workflow.
  const rag = useRAG('/rag');

  return (
    <section>
      <button
        onClick={() => rag.search.search({ query: 'What is hybrid search?' })}
      >
        Search
      </button>
      {rag.search.results.map((hit) => (
        <article key={hit.chunkId}>
          <h3>{hit.title}</h3>
          <p>{hit.text}</p>
        </article>
      ))}

      <button onClick={() => rag.stream.query('Explain hybrid search')}>
        Ask
      </button>
      {rag.stream.isRunning ? (
        <p>{rag.stream.sources.length} sources retrieved...</p>
      ) : null}
      {rag.stream.groundedAnswer ? <p>Grounded answer ready.</p> : null}
    </section>
  );
};

// Svelte : store-backed factories from @absolutejs/rag/svelte
import { createRAG } from '@absolutejs/rag/svelte';

const rag = createRAG('/rag');
// createRAGSearch, createRAGIngest, createRAGStream, createRAGStatus,
// createRAGOps, ... mirror the React hooks one-for-one.

// Vue : composables from @absolutejs/rag/vue with computed()/ref() state
import { useRAG } from '@absolutejs/rag/vue';

const vueRag = useRAG('/rag', { autoLoadStatus: true });

// Angular : injectable services from @absolutejs/rag/angular
import { inject } from '@angular/core';
import { RAGClientService, RAGStreamService } from '@absolutejs/rag/angular';

class DocsAssistant {
  private readonly client = inject(RAGClientService);
  private readonly stream = inject(RAGStreamService).connect('/rag');

  async run(query: string) {
    // Every RAGClientService method takes the base path first.
    const hits = await this.client.search('/rag', { query });
    // connect() returns Angular signals: sources(), stage(), progress()...
    this.stream.query(query);

    return hits;
  }
}