reactioncommerce · brent-hoover · Oct 7, 2022 · Oct 3, 2022 · Oct 3, 2022 · Oct 3, 2022
diff --git a/.changeset/beige-doors-poke.md b/.changeset/beige-doors-poke.md
@@ -0,0 +1,6 @@
+---
+"@reactioncommerce/api-plugin-products": minor
+"@reactioncommerce/api-plugin-tags": minor
+---
+
+Added afterAddTagsToProducts, afterTagDelete, afterRemoveTagsFromProducts events when respective mutations are called.
diff --git a/packages/api-plugin-products/src/mutations/addTagsToProducts.js b/packages/api-plugin-products/src/mutations/addTagsToProducts.js
@@ -13,7 +13,7 @@ import executeBulkOperation from "../utils/executeBulkOperation.js";
  */
 export default async function addTagsToProducts(context, input) {
   const { productIds, shopId, tagIds } = input;
-  const { collections: { Products } } = context;
+  const { appEvents, collections: { Products } } = context;
   const totalProducts = productIds.length;
 
   for (const _id of productIds) {
@@ -39,5 +39,7 @@ export default async function addTagsToProducts(context, input) {
 
   const results = await executeBulkOperation(Products, operations, totalProducts);
 
+  await Promise.all(tagIds.map((tagId) => appEvents.emit("afterAddTagsToProducts", { tagId, productIds })));
+
   return results;
 }
diff --git a/packages/api-plugin-products/src/mutations/removeTagsFromProducts.js b/packages/api-plugin-products/src/mutations/removeTagsFromProducts.js
@@ -13,7 +13,7 @@ import executeBulkOperation from "../utils/executeBulkOperation.js";
  */
 export default async function removeTagsFromProducts(context, input) {
   const { productIds, shopId, tagIds } = input;
-  const { collections: { Products } } = context;
+  const { appEvents, collections: { Products } } = context;
   const totalProducts = productIds.length;
 
   for (const _id of productIds) {
@@ -40,5 +40,7 @@ export default async function removeTagsFromProducts(context, input) {
 
   const results = await executeBulkOperation(Products, operations, totalProducts);
 
+  await Promise.all(tagIds.map((tagId) => appEvents.emit("afterRemoveTagsFromProducts", { tagId, productIds })));
+
   return results;
 }
diff --git a/packages/api-plugin-tags/src/mutations/removeTag.js b/packages/api-plugin-tags/src/mutations/removeTag.js
@@ -11,7 +11,7 @@ import ReactionError from "@reactioncommerce/reaction-error";
  */
 export default async function removeTag(context, input) {
   const { shopId, tagId } = input;
-  const { Tags } = context.collections;
+  const { appEvents, collections: { Tags } } = context;
 
   await context.validatePermissions(`reaction:legacy:tags:${tagId}`, "delete", { shopId });
 
@@ -22,5 +22,7 @@ export default async function removeTag(context, input) {
     throw new ReactionError("not-found", "Tag not found");
   }
 
+  await appEvents.emit("afterTagDelete", tag);
+
   return tag;
 }