Core

const { Core } = require('@orbito/api-lib');

Core.getCompanyId();   // 'string' – firma obsługiwana przez ten kontener
Core.getInstanceId();  // 'string' – identyfikator TEJ instalacji modułu
Core.getModuleInfo();  // { instanceId, companyId, code, version }

Core.registerMethod(name, handler)

Core.registerMethod(name, {
  params: { /* schemat fastest-validator */ },
  returns: { /* schemat fastest-validator */ },
  handler: async (params, ctx) => { ... }
})

async (params, ctx) => { ... }

const { Core } = require('@orbito/api-lib');

Core.registerMethod('config.get', async (params, ctx) => {
  const config = await ConfigSchema.findOne({});
  return config ?? {};
});

const { Core } = require('@orbito/api-lib');

Core.registerMethod('search', {
  params: {
    query: { type: 'string', min: 1 },
    page:  { type: 'number', integer: true, optional: true, default: 1 },
  },
  returns: {
    items: { type: 'array' },
    total: { type: 'number' },
  },
  handler: async (params, ctx) => {
    const results = await ProductsSchema.find({
      name: new RegExp(params.query, 'i'),
    });

    return { items: results, total: results.length };
  },
});

Core.registerHook(hookName, handler)

Core.registerHook('core.shipping.getCarrier', async (order) => {
  const config = await ShippingConfig.findOne({});

  if (!config?.enabled) return null;

  return {
    carrierId: 'dpd',
    label: 'DPD',
    price: config.flatRate
  };
});

Core.registerHook('event:order:created', async function (order) {
  // this.caller = { instanceId, moduleCode, instanceName } albo null (odpaliła platforma)
  await saveOrder(order, { sourceInstanceId: this.caller?.instanceId });
});

await Core.callModule(moduleId, methodName, params)

const { Core } = require('@orbito/api-lib');

Core.registerMethod('getOrderStatus', async (params, ctx) => {
  // Wywołanie metody w module core/orders
  const result = await Core.callModule(
    'core/orders',
    'status.search',
    { orderId: params.orderId }
  );

  return result;
});

await Core.callInstanceMethod(targetInstanceId, methodName, params)

const { Core } = require('@orbito/api-lib');

try {
  await Core.callModule('core/prestashop', 'syncOrders', {});
} catch (err) {
  if (err.code !== 'AMBIGUOUS_MODULE_TARGET') throw err;

  await Core.callInstanceMethod(shopInstanceId, 'syncOrders', {});
}

const user = await Core.getUser(userId)

{
  id: '64a...',          // identyfikator użytkownika
  firstname: 'Jan',
  lastname: 'Kowalski',
  email: 'jan@firma.pl',
  isDisabled: false,     // czy konto jest zablokowane
  isOwner: false,        // czy użytkownik jest właścicielem firmy
  profile: {             // profil użytkownika W TEJ firmie, `null` gdy nie przypisano
    id: '64c...',
    name: 'sprzedawca',
    isAdmin: false
  }
}

const { Core } = require('@orbito/api-lib');

Core.registerMethod('describeOrder', async (params, ctx) => {
  const author = await Core.getUser(ctx.userId);

  return {
    ...params.order,
    authorName: author ? `${author.firstname} ${author.lastname}` : null
  };
});

const company = await Core.getCompany()

const { Core } = require('@orbito/api-lib');

Core.registerMethod('company.header', async () => {
  const company = await Core.getCompany();

  return {
    title: company.name,
    taxNo: company.taxNo,
    phone: company.contactPhone ?? '-',
    timezone: company.timezone   // np. 'Europe/Warsaw'
  };
});

const response = await Core.fetch(url, options)

const { Core } = require('@orbito/api-lib');

// GET
const res = await Core.fetch('https://api.example.com/products');
const data = res.json();

// POST z JSON
const res = await Core.fetch('https://api.example.com/orders', {
  method: 'POST',
  headers: {
    'Content-Type': 'application/json',
    'Authorization': `Bearer ${token}`
  },
  body: JSON.stringify({ orderId: '123' })
});

if (res.status < 200 || res.status >= 300) {
  throw new Error(`HTTP ${res.status}: ${res.text()}`);
}

const result = res.json();

// PUT z binarną treścią (np. PDF) – od SDK 3.11.0
const pdf = require('fs').readFileSync('faktura.pdf');
const upload = await Core.fetch('https://api.example.com/documents/123', {
  method: 'PUT',
  headers: { 'Content-Type': 'application/pdf' },
  body: pdf
});