fix(medusa): adds fulfillment_created event in order service (#101)

lerna.json

@@ -4,5 +4,5 @@
     "packages/*"
   ],
   "registry": "https://registry.npmjs.org/",
-  "version": "1.0.1-beta.0"
+  "version": "1.0.1-beta.2"
 }

packages/medusa/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@medusajs/medusa",
-  "version": "1.0.1-beta.0",
+  "version": "1.0.1-beta.2",
   "description": "E-commerce for JAMstack",
   "main": "dist/app.js",
   "repository": {

packages/medusa/src/models/schemas/fulfillment.js

@@ -6,5 +6,6 @@ export default new mongoose.Schema({
   items: { type: [mongoose.Schema.Types.Mixed], required: true },
   data: { type: [mongoose.Schema.Types.Mixed], default: {} },
   tracking_numbers: { type: [String], default: [] },
+  shipped_at: { type: String },
   metadata: { type: mongoose.Schema.Types.Mixed, default: {} },
 })

packages/medusa/src/services/order.js

@@ -408,6 +408,7 @@ class OrderService extends BaseService {
         shipment = {
           ...f,
           tracking_numbers: trackingNumbers,
+          shipped_at: Date.now(),
           metadata: {
             ...f.metadata,
             ...metadata,
@@ -712,8 +713,12 @@ class OrderService extends BaseService {
         }
       )
       .then(result => {
-        // Notify subscribers
-        this.eventBus_.emit(OrderService.Events.UPDATED, result)
+        for (const fulfillment of results) {
+          this.eventBus_.emit(OrderService.Events.FULFILLMENT_CREATED, {
+            order_id: orderId,
+            fulfillment,
+          })
+        }
         return result
       })
       .catch(err => {