Operations

// Find a single document
const user = await this.users.findOne({_id: userId})

// Find multiple documents
const activeUsers = await this.users.find({status: 'active'})
  .sort({createdAt: -1})
  .limit(10)
  .toArray()

// Insert a single document (returns the generated ID)
const userId = await this.users.insertOne({
  name: 'John Doe',
  email: 'john@example.com'
})

// Insert and return the document
const user = await this.users.insertAndFind({
  name: 'Jane Doe',
  email: 'jane@example.com'
})

// Insert multiple documents (returns array of IDs)
const userIds = await this.users.insertMany([
  {name: 'User 1', email: 'user1@example.com'},
  {name: 'User 2', email: 'user2@example.com'}
])

// Update a document
const result = await this.users.updateOne(
  {_id: userId},
  {$set: {lastLogin: new Date()}}
)

// Update and return the updated document
const updatedUser = await this.users.updateAndFind(
  {_id: userId},
  {$set: {status: 'active'}}
)

// Find one document and update it (same as updateAndFind)
const user = await this.users.findOneAndUpdate(
  {_id: userId},
  {$set: {status: 'active'}}
)

// Update multiple documents
const result = await this.users.updateMany(
  {status: 'pending'},
  {$set: {reminded: true}}
)

// Update a specific field in a document by path
await this.users.updateItem(
  userDocument, // pass the actual document object
  'addresses.0.isPrimary', // field path to update
  true // new value
)

// Upsert (insert if not exists)
const result = await this.users.upsert(
  {email: 'user@example.com'},
  {
    $set: {lastSeen: new Date()},
    $setOnInsert: {createdAt: new Date()}
  }
)

// Delete a document
const result = await this.users.deleteOne({_id: userId})

// Delete multiple documents
const result = await this.users.deleteMany({
  lastLogin: {$lt: new Date('2022-01-01')}
})

// Count with filter
const activeCount = await this.users.countDocuments({status: 'active'})

// Fast estimation for large collections
const totalCount = await this.users.estimatedDocumentCount()

// Run an aggregation pipeline
const stats = await this.users.aggregate([
  {$match: {status: 'active'}},
  {$group: {_id: '$role', count: {$sum: 1}}}
]).toArray()

// Load a document by ID
const user = await this.users.loadById(userId)

// Watch for changes to a collection
const changeStream = this.users.watch()
changeStream.on('change', change => {
  console.log('Document changed:', change)
})

// Access the raw MongoDB collection for operations
// not directly exposed by Orionjs
const rawCollection = this.users.rawCollection