Internal API

import { useRest } from '@dnax/core';

const rest = new useRest({
  tenant_id: 'v1',
  useHook: true,
});

new useRest({
  tenant_id?: string;
  database?: { uri: string; options?: MongoClientOptions };
  session?: ClientSession;
  useHook?: boolean;
  useCustomApi?: boolean;
})

const users = await rest.find('users', {
  $match: { status: 'active' },
  $limit: 20,
  $skip: 0,
  $sort: { createdAt: -1 },
  $project: { name: 1, email: 1 },
});

const user = await rest.findOne('users', '64f1a2b3c4d5e6f7a8b9c0d1');

const result = await rest.aggregate('orders', [
  { $match: { status: 'completed' } },
  { $group: { _id: '$category', total: { $sum: '$amount' } } },
]);

const count = await rest.countDocuments('users', { status: 'active' });

const updated = await rest.findOneAndUpdate(
  'users',
  { email: '[email protected]' },
  { $set: { name: 'John Doe' } },
  { upsert: true }
);

const user = await rest.insertOne('users', {
  name: 'John',
  email: '[email protected]',
});

const users = await rest.insertMany('users', [
  { name: 'Alice' },
  { name: 'Bob' },
]);

const result = await rest.updateOne(
  'users',
  '64f1a2b3c4d5e6f7a8b9c0d1',
  { $set: { name: 'Jane Doe' } }
);

const result = await rest.updateMany(
  'users',
  ['64f1...', '64f2...'],
  { $set: { status: 'inactive' } }
);

const result = await rest.deleteOne('users', '64f1a2b3c4d5e6f7a8b9c0d1');

const result = await rest.deleteMany('users', ['64f1...', '64f2...']);

const result = await rest.bulkWrite('users', [
  { insertOne: { document: { name: 'Alice' } } },
  { updateOne: { filter: { _id: '64f1...' }, update: { $set: { name: 'Bob' } } } },
  { deleteOne: { filter: { _id: '64f2...' } } },
]);

const result = await rest.bulkUpdate('users', [
  { updateOne: { filter: { _id: '64f1...' }, update: { $set: { name: 'Alice' } } },
  { updateMany: { filter: { status: 'old' }, update: { $set: { status: 'archived' } } },
]);

const result = await rest.runAction('users', 'getPublicProfile', {
  userId: '64f1a2b3c4d5e6f7a8b9c0d1',
});

{
  rest: this,      // Rest instance
  data: any,       // The data argument
  error: fn.error, // Error helper
  jwt: func.jwt,   // JWT utilities
  token,           // Current token from request context
}

// File: invoices.model.ts (collection)
import { define } from '@dnax/core';

export default define.Collection({
  slug: 'invoices',
  fields: [
    { name: 'total', type: 'number' },
    { name: 'status', type: 'string' },
  ],
  actions: {
    markAsPaid: async ({ rest, data, error }) => {
      const invoice = await rest.findOne('invoices', data.id);
      if (!invoice) throw error('Invoice not found', { status: 404 });
      return await rest.updateOne('invoices', data.id, {
        $set: { status: 'paid', paidAt: new Date() },
      });
    },

    processPayment: async ({ rest, data }) => {
      // Reuse markAsPaid action from the same collection
      return await rest.runAction('invoices', 'markAsPaid', {
        id: data.invoiceId,
      });
    },
  },
});

// File: billing.service.ts (service)
import { define } from '@dnax/core';

export default define.Service({
  name: 'billing',
  enabled: true,
  actions: {
    generate: async ({ rest, data }) => {
      return await rest.insertOne('invoices', {
        client: data.clientId,
        total: data.total,
        status: 'draft',
      });
    },
  },
});

// File: orders.model.ts (collection)
actions: {
  checkout: async ({ rest, data, error }) => {
    const cart = await rest.findOne('carts', data.cartId);
    if (!cart) throw error('Cart not found', { status: 404 });

    // Call the billing service to generate an invoice
    const invoice = await rest.runService('billing', 'generate', {
      clientId: cart.userId,
      total: cart.items.reduce((s, i) => s + i.price * i.qty, 0),
    });

    // Call the notification service to send confirmation
    await rest.runService('notifications', 'send', {
      userId: cart.userId,
      type: 'order_confirmation',
      invoiceId: invoice._id,
    });

    return { invoice };
  },
}

{
  data: any,       // The data argument
  error: fn.error, // Error helper
  io,              // Socket.IO server instance
  jwt: func.jwt,   // JWT utilities
  token,           // Current token from request context
  rest: this,      // Rest instance
}

await rest.dropIndex('users', 'email_index');

await rest.dropIndexes('users');

await rest.dropCollection('users');

rest.startTransaction();

await rest.commitTransaction();

await rest.abortTransaction();

const session = rest.startSession();

const stream = await rest.watch('users', [
  { $match: { operationType: 'insert' } }
], { fullDocument: 'updateLookup' });