product.event.service.js

const AWS = require("aws-sdk");
const { productFromJson } = require("./product");
const { createEvent } = require("./product.event")

const TOPIC_ARN =
  process.env.TOPIC_ARN || "arn:aws:sns:ap-southeast-2:000000000000:products";

class ProductEventService {
  async create(event) {
    const product = productFromJson(event);
    await this.publish(createEvent(product, "CREATED"));
  }

  async update(event) {
    const product = productFromJson(event);
    await this.publish(createEvent(product, "UPDATED"));
  }

  async delete(event) {
    const product = productFromJson(event);
    await this.publish(createEvent(product, "DELETED"));
  }

  async publish(message) {
    const SNS = new AWS.SNS({
      endpoint: process.env.AWS_SNS_ENDPOINT,
      region: process.env.AWS_REGION
    });

    const params = {
      Message: JSON.stringify(message),
      TopicArn: TOPIC_ARN,
    };

    console.log("ProductEventService - sending message:", message);

    return SNS.publish(params).promise();
  }
}

module.exports = {
  ProductEventService,
  createEvent,
};