@happyvertical/smrt-manufacturing

pnpm add @happyvertical/smrt-manufacturing

import {
  BillOfMaterialsCollection,
  BomLineCollection,
} from '@happyvertical/smrt-manufacturing';

const db = { type: 'sqlite', url: 'app.db' };
const boms = await BillOfMaterialsCollection.create({ db });
const lines = await BomLineCollection.create({ db });

const bom = await boms.create({
  productId: shirt.id, // upstream Product or any STI subtype
  version: 1,
  status: 'active',
  currency: 'USD',
});
await bom.save();

const fabric = await lines.create({
  bomId: bom.id,
  componentSkuId: fabricSku.id,
  qtyPerUnit: 2.0,
  uom: 'yards',
  wastePercent: 10, // 10% cutting waste
});
await fabric.save();

const buttons = await lines.create({
  bomId: bom.id,
  componentSkuId: buttonSku.id,
  qtyPerUnit: 4,
  uom: 'each',
});
await buttons.save();

import { BomService } from '@happyvertical/smrt-manufacturing';

const service = await BomService.create({
  db,
  // Plug in any cost source: smrt-products Material.costPerUnit, a
  // purchase-order rolling average, a vendor price book, anything.
  // Returning null/undefined marks the line costUnavailable.
  costResolver: async (componentSkuId) => {
    const sku = await skus.get(componentSkuId);
    return sku ? Number(JSON.parse(sku.attributes ?? '{}').cost ?? 0) : null;
  },
});

const rollup = await service.computeMaterialCost(bom.id);
console.log(rollup.totalCost, rollup.currency);
// rollup also carries lineBreakdown[] (per-line cost incl. waste) and
// hasMissingCosts so a UI can warn when totalCost is a lower bound.

// Shopping list to build 100 units (waste included, duplicate SKUs summed).
const requirements = await service.explodeRequirements(bom.id, 100);
// [{ componentSkuId: fabricSku.id, totalQty: 220, uom: 'yards' },
//  { componentSkuId: buttonSku.id, totalQty: 400, uom: 'each' }]

// Do we have enough available stock right now (summed across locations)?
const check = await service.canProduce(bom.id, 100);
if (!check.ok) {
  for (const shortage of check.shortages) {
    console.log(
      `Need ${shortage.requested} of ${shortage.componentSkuId}, have ${shortage.available}`,
    );
  }
}

import { ProductionService } from '@happyvertical/smrt-manufacturing';

const production = await ProductionService.create({ db });

// Pull materials from the factory (consume -> wip / out of available).
const consumed = await production.consumeMaterials(
  { id: order.id, productId: order.productId }, // ProductionOrder
  { locationId: factory.id, qty: 100 },         // explicit location
);

// Receive finished goods (+qty available for the finished SKU).
const produced = await production.produceFinishedGoods(
  { id: order.id, productId: order.productId },
  {
    locationId: factory.id,
    qty: 100,
    finishedSkuId: finishedVariant.id, // one productId can have many SKUs
  },
);

// Every emitted StockMovement is stamped sourceType: 'ProductionOrder'
// + sourceId: order.id, so you can reconstruct it later via
// StockMovementCollection.findBySource('ProductionOrder', order.id).

import { createDispatchBus } from '@happyvertical/smrt-core';
import { installInventoryDispatchHandlers } from '@happyvertical/smrt-inventory';
import { installManufacturingDispatchHandlers } from '@happyvertical/smrt-manufacturing';

const bus = await createDispatchBus({ db });

// Inventory handlers bridge contract:created and fulfillment:shipped.
await installInventoryDispatchHandlers({ dispatchBus: bus, db });

// Manufacturing handlers bridge production_order:posted (and optionally
// production_order:completed) to consume / produce.
await installManufacturingDispatchHandlers({
  dispatchBus: bus,
  db,
  // Consume AND produce in one shot when posted (make-to-stock).
  producedOnPosted: true,
  // Per-leg toggles: installProductionPosted, installProductionCompleted.
});

// Later, when a production order is posted:
await bus.emit('production_order:posted', {
  productionOrderId: order.id,
  productId: order.productId,
  locationId: factory.id,
  qty: 100,
  finishedSkuId: finishedVariant.id, // only when producedOnPosted: true
});