Updated sample to 0.16.1 version

README.md

@@ -21,8 +21,7 @@ Read also [introduction article on my blog](https://event-driven.io/en/introduct
 You can use Pongo syntax with explicit typing about supported syntax:
 
 ```ts
-import { pongoClient } from "@event-driven-io/pongo";
-import { v7 as uuid } from "uuid";
+import { pongoClient, ObjectId } from "@event-driven-io/pongo";
 
 type User = { name: string; age: number };
 
@@ -35,7 +34,7 @@ const pongoDb = pongo.db();
 const users = pongoDb.collection<User>("users");
 const roger = { name: "Roger", age: 30 };
 const anita = { name: "Anita", age: 25 };
-const cruella = { _id: uuid(), name: "Cruella", age: 40 };
+const cruella = { _id: ObjectId(), name: "Cruella", age: 40 };
 
 // Inserting
 await users.insertOne(roger);
@@ -60,8 +59,7 @@ const usersFromDb = await users.find({ age: { $lt: 40 } });
 Or use MongoDB compliant shim:
 
 ```ts
-import { MongoClient } from "@event-driven-io/pongo/shim";
-import { v7 as uuid } from "uuid";
+import { MongoClient, ObjectId } from "@event-driven-io/pongo/shim";
 
 type User = { name: string; age: number };
 
@@ -74,7 +72,7 @@ const pongoDb = pongoClient.db();
 const users = pongoDb.collection<User>("users");
 const roger = { name: "Roger", age: 30 };
 const anita = { name: "Anita", age: 25 };
-const cruella = { _id: uuid(), name: "Cruella", age: 40 };
+const cruella = { _id: ObjectId(), name: "Cruella", age: 40 };
 
 // Inserting
 await users.insertOne(roger);

samples/simple-ts/package.json

@@ -63,6 +63,6 @@
     "dist"
   ],
   "dependencies": {
-    "@event-driven-io/pongo": "0.15.0"
+    "@event-driven-io/pongo": "0.16.1"
   }
 }

samples/simple-ts/src/index.ts

@@ -1,5 +1,5 @@
-import { pongoClient } from '@event-driven-io/pongo';
-import { v7 as uuid } from 'uuid';
+import { prettyJson } from '@event-driven-io/dumbo';
+import { ObjectId, pongoClient } from '@event-driven-io/pongo';
 
 type User = { _id?: string; name: string; age: number };
 
@@ -13,7 +13,7 @@ const pongoDb = pongo.db();
 const users = pongoDb.collection<User>('users');
 const roger = { name: 'Roger', age: 30 };
 const anita = { name: 'Anita', age: 25 };
-const cruella = { _id: uuid(), name: 'Cruella', age: 40 };
+const cruella = { _id: ObjectId(), name: 'Cruella', age: 40 };
 
 // Inserting
 await users.insertOne(roger);
@@ -30,10 +30,10 @@ await users.deleteOne({ _id: cruella._id });
 
 // Finding by Id
 const anitaFromDb = await users.findOne({ _id: anitaId });
-console.log(JSON.stringify(anitaFromDb));
+console.log(prettyJson(anitaFromDb));
 
 // Finding more
 const usersFromDB = await users.find({ age: { $lt: 40 } });
-console.log(JSON.stringify(usersFromDB));
+console.log(prettyJson(usersFromDB));
 
 await pongo.close();

samples/simple-ts/src/shim.ts

@@ -1,3 +1,4 @@
+import { prettyJson } from '@event-driven-io/dumbo';
 import { MongoClient } from '@event-driven-io/pongo/shim';
 
 type User = { name: string; age: number };
@@ -12,7 +13,7 @@ const pongoDb = pongoClient.db('postgres');
 const users = pongoDb.collection<User>('users');
 const roger = { name: 'Roger', age: 30 };
 const anita = { name: 'Anita', age: 25 };
-//const cruella = { _id: uuid(), name: 'Cruella', age: 40 };
+//const cruella = { _id: ObjectId(), name: 'Cruella', age: 40 };
 
 // Inserting
 await users.insertOne(roger);
@@ -29,10 +30,10 @@ await users.updateOne({ _id: anitaId }, { $set: { age: 31 } });
 
 // Finding by Id
 const anitaFromDb = await users.findOne({ _id: anitaId });
-console.log(anitaFromDb);
+console.log(prettyJson(anitaFromDb));
 
 // Finding more
 const usersFromDB = await users.find({ age: { $lt: 40 } }).toArray();
-console.log(usersFromDB);
+console.log(prettyJson(usersFromDB));
 
 await pongoClient.close();

samples/simple-ts/src/typedClient.ts

@@ -1,5 +1,5 @@
-import { pongoClient } from '@event-driven-io/pongo';
-import { v7 as uuid } from 'uuid';
+import { prettyJson } from '@event-driven-io/dumbo';
+import { ObjectId, pongoClient } from '@event-driven-io/pongo';
 import config from './pongo.config';
 
 const connectionString =
@@ -14,7 +14,7 @@ const pongoDb = pongo.database;
 const users = pongoDb.users;
 const roger = { name: 'Roger', age: 30 };
 const anita = { name: 'Anita', age: 25 };
-const cruella = { _id: uuid(), name: 'Cruella', age: 40 };
+const cruella = { _id: ObjectId(), name: 'Cruella', age: 40 };
 
 // Inserting
 await users.insertOne(roger);
@@ -31,10 +31,10 @@ await users.deleteOne({ _id: cruella._id });
 
 // Finding by Id
 const anitaFromDb = await users.findOne({ _id: anitaId });
-console.log(anitaFromDb);
+console.log(prettyJson(anitaFromDb));
 
 // Finding more
 const usersFromDB = await users.find({ age: { $lt: 40 } });
-console.log(usersFromDB);
+console.log(prettyJson(usersFromDB));
 
 await pongo.close();

src/docs/getting-started.md

@@ -19,8 +19,7 @@ Read also [introduction article on my blog](https://event-driven.io/en/introduct
 You can use Pongo syntax with explicit typing about supported syntax:
 
 ```ts
-import { pongoClient } from '@event-driven-io/pongo';
-import { v7 as uuid } from 'uuid';
+import { pongoClient, ObjectId } from '@event-driven-io/pongo';
 
 type User = { name: string; age: number };
 
@@ -33,7 +32,7 @@ const pongoDb = pongo.db();
 const users = pongoDb.collection<User>('users');
 const roger = { name: 'Roger', age: 30 };
 const anita = { name: 'Anita', age: 25 };
-const cruella = { _id: uuid(), name: 'Cruella', age: 40 };
+const cruella = { _id: ObjectId(), name: 'Cruella', age: 40 };
 
 // Inserting
 await users.insertOne(roger);
@@ -58,8 +57,7 @@ const usersFromDb = await users.find({ age: { $lt: 40 } });
 Or use MongoDB compliant shim:
 
 ```ts
-import { MongoClient } from '@event-driven-io/pongo/shim';
-import { v7 as uuid } from 'uuid';
+import { MongoClient, ObjectId } from '@event-driven-io/pongo/shim';
 
 type User = { name: string; age: number };
 
@@ -72,7 +70,7 @@ const pongoDb = pongoClient.db();
 const users = pongoDb.collection<User>('users');
 const roger = { name: 'Roger', age: 30 };
 const anita = { name: 'Anita', age: 25 };
-const cruella = { _id: uuid(), name: 'Cruella', age: 40 };
+const cruella = { _id: ObjectId(), name: 'Cruella', age: 40 };
 
 // Inserting
 await users.insertOne(roger);

src/packages/pongo/src/e2e/postgres.optimistic-concurrency.spec.ts

@@ -5,11 +5,10 @@ import {
 import assert from 'assert';
 import console from 'console';
 import { after, before, beforeEach, describe, it } from 'node:test';
-import { v7 as uuid } from 'uuid';
 import {
+  ObjectId,
   pongoClient,
   pongoSchema,
-  type ObjectId,
   type PongoClient,
   type PongoCollection,
   type PongoDb,
@@ -67,7 +66,7 @@ void describe('MongoDB Compatibility Tests', () => {
 
   beforeEach(() => {
     user = {
-      _id: uuid(),
+      _id: ObjectId(),
       name: 'Anita',
       age: 25,
     };
@@ -156,7 +155,7 @@ void describe('MongoDB Compatibility Tests', () => {
     void describe('insertMany', () => {
       void it('inserts a document with id', async () => {
         // Given
-        const otherUser = { ...user, _id: uuid() };
+        const otherUser = { ...user, _id: ObjectId() };
 
         // When
         const pongoInsertResult = await users.insertMany([user, otherUser]);
@@ -185,7 +184,7 @@ void describe('MongoDB Compatibility Tests', () => {
         const nonDefaultVersion = 495n;
         const otherUser = {
           ...user,
-          _id: uuid(),
+          _id: ObjectId(),
           _version: nonDefaultVersion,
         };
         // When
@@ -225,7 +224,7 @@ void describe('MongoDB Compatibility Tests', () => {
           name: 'Cruella',
           age: 40,
         };
-        const otherUser = { ...user, _id: uuid() };
+        const otherUser = { ...user, _id: ObjectId() };
         // When
         const pongoInsertResult = await users.insertMany([
           userWithTheSameId,
@@ -369,8 +368,8 @@ void describe('MongoDB Compatibility Tests', () => {
 
     void describe('updateMany', () => {
       void it('updates documents and expected version', async () => {
-        const otherUser = { ...user, _id: uuid() };
-        await users.insertMany([user, otherUser, { ...user, _id: uuid() }]);
+        const otherUser = { ...user, _id: ObjectId() };
+        await users.insertMany([user, otherUser, { ...user, _id: ObjectId() }]);
 
         // When
         const updateResult = await users.updateMany(
@@ -403,7 +402,7 @@ void describe('MongoDB Compatibility Tests', () => {
     });
 
     void it('overrides documents version with autoincremented document version', async () => {
-      const otherUser = { ...user, _id: uuid() };
+      const otherUser = { ...user, _id: ObjectId() };
       await users.insertMany([{ ...user }, otherUser]);
 
       // When
@@ -594,8 +593,8 @@ void describe('MongoDB Compatibility Tests', () => {
 
     void describe('deleteMany', () => {
       void it('deletes documents and expected version', async () => {
-        const otherUser = { ...user, _id: uuid() };
-        await users.insertMany([user, otherUser, { ...user, _id: uuid() }]);
+        const otherUser = { ...user, _id: ObjectId() };
+        await users.insertMany([user, otherUser, { ...user, _id: ObjectId() }]);
 
         // When
         const deleteResult = await users.deleteMany({
@@ -616,7 +615,7 @@ void describe('MongoDB Compatibility Tests', () => {
     });
 
     void it('overrides documents version with autoincremented document version', async () => {
-      const otherUser = { ...user, _id: uuid() };
+      const otherUser = { ...user, _id: ObjectId() };
       await users.insertMany([{ ...user }, otherUser]);
 
       // When
@@ -639,7 +638,7 @@ void describe('MongoDB Compatibility Tests', () => {
 
   void describe('Handle Operations', () => {
     void it('should NOT insert a new document if it does not exist and expected DOCUMENT_EXISTS', async () => {
-      const nonExistingId = uuid() as unknown as ObjectId;
+      const nonExistingId = ObjectId() as unknown as ObjectId;
 
       const newDoc: User = { name: 'John', age: 25 };
 
@@ -659,7 +658,7 @@ void describe('MongoDB Compatibility Tests', () => {
     });
 
     void it('should NOT insert a new document if it does not exist and expected is numeric value', async () => {
-      const nonExistingId = uuid() as unknown as ObjectId;
+      const nonExistingId = ObjectId() as unknown as ObjectId;
 
       const newDoc: User = { name: 'John', age: 25 };
 
@@ -679,7 +678,7 @@ void describe('MongoDB Compatibility Tests', () => {
     });
 
     void it('should replace an existing document when expected version matches', async () => {
-      const existingDoc: User = { _id: uuid(), name: 'John', age: 25 };
+      const existingDoc: User = { _id: ObjectId(), name: 'John', age: 25 };
       const updatedDoc: User = { _id: existingDoc._id!, name: 'John', age: 30 };
 
       const pongoInsertResult = await users.insertOne(existingDoc);
@@ -712,7 +711,7 @@ void describe('MongoDB Compatibility Tests', () => {
     });
 
     void it('should NOT replace an existing document when expected DOCUMENT_DOES_NOT_EXIST', async () => {
-      const existingDoc: User = { _id: uuid(), name: 'John', age: 25 };
+      const existingDoc: User = { _id: ObjectId(), name: 'John', age: 25 };
       const updatedDoc: User = { _id: existingDoc._id!, name: 'John', age: 30 };
 
       const pongoInsertResult = await users.insertOne(existingDoc);
@@ -745,7 +744,7 @@ void describe('MongoDB Compatibility Tests', () => {
     });
 
     void it('should NOT replace an existing document when expected version is mismatched ', async () => {
-      const existingDoc: User = { _id: uuid(), name: 'John', age: 25 };
+      const existingDoc: User = { _id: ObjectId(), name: 'John', age: 25 };
       const updatedDoc: User = { _id: existingDoc._id!, name: 'John', age: 30 };
 
       const pongoInsertResult = await users.insertOne(existingDoc);