Setup & Quick Start

npm i kalam-link

import { createClient, Auth } from 'kalam-link';
 
const client = createClient({
  url: 'http://localhost:8080',
  auth: Auth.basic('root', ''),
});

await client.connect();
 
const result = await client.query('SELECT CURRENT_USER()');
console.log(result.status, result.results[0]);

const filtered = await client.query(
  'SELECT * FROM app.messages WHERE conversation_id = $1 AND is_deleted = $2',
  ['conv_42', false],
);

const unsubscribe = await client.subscribe('app.messages', (event) => {
  if (event.type === 'change') {
    console.log(event.change_type, event.rows);
  }
});
 
// Later
await unsubscribe();
await client.disconnect();

const client = createClient({
  url: 'http://localhost:8080',
  auth: Auth.basic('root', ''),
  wasmUrl: '/wasm/kalam_link_bg.wasm',
});