@probitas/client-mongodb

Basic usage with connection string

import { createMongoClient } from "@probitas/client-mongodb";

const mongo = await createMongoClient({
  url: "mongodb://localhost:27017",
  database: "testdb",
});

const users = mongo.collection<{ name: string; age: number }>("users");
const result = await users.find({ age: { $gte: 18 } });

if (result.ok) {
  console.log(result.docs[0]);
} else {
  console.error("Error:", result.error.message);
}

await mongo.close();

Using connection config object

import { createMongoClient } from "@probitas/client-mongodb";

const mongo = await createMongoClient({
  url: {
    host: "localhost",
    port: 27017,
    username: "admin",
    password: "secret",
    authSource: "admin",
  },
  database: "testdb",
});

await mongo.close();

Insert and query documents

import { createMongoClient } from "@probitas/client-mongodb";

interface User { name: string; age: number }

const mongo = await createMongoClient({
  url: "mongodb://localhost:27017",
  database: "testdb",
});
const users = mongo.collection<User>("users");

// Insert a document
const insertResult = await users.insertOne({ name: "Alice", age: 30 });
if (insertResult.ok) {
  console.log("Inserted ID:", insertResult.insertedId);
}

// Find documents with projection and sorting
const findResult = await users.find(
  { age: { $gte: 25 } },
  { sort: { name: 1 }, limit: 10 }
);
if (findResult.ok) {
  console.log("Found:", findResult.docs.length);
}

await mongo.close();

Transaction with auto-commit/rollback

import { createMongoClient } from "@probitas/client-mongodb";

interface User { _id?: unknown; name: string; age: number }

const mongo = await createMongoClient({
  url: "mongodb://localhost:27017",
  database: "testdb",
});

await mongo.transaction(async (session) => {
  const users = session.collection<User>("users");
  const insertResult = await users.insertOne({ name: "Bob", age: 25 });
  if (!insertResult.ok) throw insertResult.error;

  const updateResult = await users.updateOne(
    { name: "Alice" },
    { $inc: { age: 1 } }
  );
  if (!updateResult.ok) throw updateResult.error;
});

await mongo.close();

Aggregation pipeline

import { createMongoClient } from "@probitas/client-mongodb";

interface User { name: string; age: number; department: string }

const mongo = await createMongoClient({
  url: "mongodb://localhost:27017",
  database: "testdb",
});
const users = mongo.collection<User>("users");

const result = await users.aggregate<{ _id: string; avgAge: number }>([
  { $group: { _id: "$department", avgAge: { $avg: "$age" } } },
  { $sort: { avgAge: -1 } },
]);
if (result.ok) {
  console.log(result.docs);
}

await mongo.close();

Using await using for automatic cleanup

import { createMongoClient } from "@probitas/client-mongodb";

await using mongo = await createMongoClient({
  url: "mongodb://localhost:27017",
  database: "testdb",
});

const result = await mongo.collection("users").find({});
if (result.ok) {
  console.log(result.docs);
}
// Client automatically closed when scope exits