Your Data. Your Keys. Your Control.

import { BaseMindooTenantFactory, InMemoryContentAddressedStoreFactory } from "mindoodb";

// 1) One-time setup
const factory = new BaseMindooTenantFactory(new InMemoryContentAddressedStoreFactory());
const { tenant } = await factory.createTenant({
  tenantId: "acme",
  adminName: "cn=admin/o=acme",
  adminPassword: "admin-pw",
  userName: "cn=alice/o=acme",
  userPassword: "alice-pw",
});

// 2) Create a document and start working
const db = await tenant.openDB("todos");
const doc = await db.createDocument();
await db.changeDoc(doc, (d) => {
  const data = d.getData();
  data.title = "Buy milk";
  data.done = false;
});

// 3) Read it back
const loaded = await db.getDocument(doc.getId());
console.log(loaded.getData()); // { title: "Buy milk", done: false }

// Create a document locally
const doc = await contactsDB1.createDocument();
await contactsDB1.changeDoc(doc, (d) => {
  const data = d.getData();
  data.name = "John Doe";
  data.email = "john.doe@example.com";
});

// Sync between any two stores — client-server, peer-to-peer, or local
await contactsDB2.pullChangesFrom(contactsDB1.getStore());

// Edit on the second device, then push back
await contactsDB2.changeDoc(await contactsDB2.getDocument(doc.getId()), (d) => {
  d.getData().name = "John Smith";
});
await contactsDB2.pushChangesTo(contactsDB1.getStore());
await contactsDB1.syncStoreChanges();
// Both stores converge automatically (CRDTs — no conflict resolution needed)

const doc = await db.createDocument();

// Attach a text file
const content = new TextEncoder().encode("Quarterly earnings report…");
await db.changeDoc(doc, async (d) => {
  await d.addAttachment(content, "report.txt", "text/plain");
});

// Or stream a large file — memory efficient, encrypted chunk by chunk
await db.changeDoc(doc, async (d) => {
  const response = await fetch("/datasets/sensor-log.csv");
  await d.addAttachmentStream(response.body, "sensor-log.csv", "text/csv");
});

// Stream the CSV back — decrypted chunk by chunk, constant memory
const reloaded = await db.getDocument(doc.getId());
const attachments = reloaded.getAttachments();
const csv = attachments.find((a) => a.fileName === "sensor-log.csv");
for await (const chunk of reloaded.streamAttachment(csv.attachmentId)) {
  process.stdout.write(chunk);
}

const view = await VirtualViewFactory.createView()
  .addCategoryColumn("department")
  .addSortedColumn("lastName")
  .addTotalColumn("salary", TotalMode.SUM)
  .withDB("employees", employeeDB, (doc) => doc.getData().type === "employee")
  .buildAndUpdate();

const nav = VirtualViewFactory.createNavigator(view).expandAll().build();
for await (const entry of nav.entriesForward()) {
  // categories + documents in a single, sorted tree
}