discount_special.js

import { writeFileSync } from "bun:fs";
import { postToDiscord } from "./post_to_discord.js";
import { config } from "./config.js";
import {
  generateDiscountCode,
  addMinutesToIsoTime,
  expiresIn,
} from "./functions.js";

// Function to fetch all product IDs from Creem API
async function getAllCreemProductIds() {
  try {
    let allProductIds = [];
    let currentPage = 1;
    let hasMorePages = true;

    while (hasMorePages) {
      const response = await fetch(
        `https://api.creem.io/v1/products/search?page_number=${currentPage}&page_size=50`,
        {
          method: "GET",
          headers: {
            "x-api-key": process.env.CREEM_API_KEY,
          },
        }
      );

      if (!response.ok) {
        throw new Error(
          `Failed to fetch products: ${response.status} ${response.statusText}`
        );
      }

      const data = await response.json();

      // Extract product IDs from the current page
      const productIds = data.items.map((product) => product.id);
      allProductIds.push(...productIds);

      // Check if there are more pages
      hasMorePages = data.pagination.next_page !== null;
      currentPage = data.pagination.next_page || currentPage + 1;
    }

    console.log(`Fetched ${allProductIds.length} product IDs from Creem API`);
    return allProductIds;
  } catch (error) {
    console.error("Error fetching Creem products:", error);
  }
}

const args = process.argv.slice(2);

const data = {
  data: {
    type: "discounts",
    attributes: {
      name: args[2],
      code: args[3] || `SPC${generateDiscountCode(9)}`,
      amount: Number.parseInt(args[0]),
      amount_type: "percent",
      expires_at: addMinutesToIsoTime(Number.parseInt(args[1]) * 60 * 24),
    },
    relationships: {
      store: {
        data: {
          type: "stores",
          id: config.storeId,
        },
      },
    },
  },
};

fetch("https://api.lemonsqueezy.com/v1/discounts", {
  method: "POST",
  headers: {
    Accept: "application/vnd.api+json",
    "Content-Type": "application/vnd.api+json",
    Authorization: `Bearer ${process.env.LEMONSQUEEZY_API_KEY}`,
  },
  body: JSON.stringify(data),
})
  .then((response) => response.json())
  .then(async (json) => {
    if (json.data?.id) {
      writeFileSync(
        "docs/api/discount_special.json",
        JSON.stringify(json, null, 2)
      );
      console.log("LemonSqueezy discount code created successfully");

      // Fetch all product IDs from Creem API
      const productIds = await getAllCreemProductIds();

      // Create the same discount on Creem
      const creemData = {
        name: json.data.attributes.name,
        code: json.data.attributes.code,
        type: "percentage",
        percentage: json.data.attributes.amount,
        expiry_date: json.data.attributes.expires_at,
        duration: "once",
        applies_to_products: productIds,
      };

      fetch("https://api.creem.io/v1/discounts", {
        method: "POST",
        headers: {
          "Content-Type": "application/json",
          "x-api-key": process.env.CREEM_API_KEY,
        },
        body: JSON.stringify(creemData),
      })
        .then((response) => {
          return response.json();
        })
        .then((creemResult) => {
          if (creemResult.id) {
            console.log("Creem discount code created successfully");
          } else {
            console.error("Failed to create Creem discount:", creemResult);
            if (creemResult.status === 403) {
              console.error("403 Forbidden - Check:");
              console.error(
                "- CREEM_API_KEY is set:",
                !!process.env.CREEM_API_KEY
              );
              console.error("- Product IDs count:", productIds.length);
              console.error(
                "- Try test endpoint: https://test-api.creem.io/v1/discounts"
              );
            }
          }
        })
        .catch((error) => {
          console.error("Error creating Creem discount:", error);
        });

      postToDiscord(
        config.channelId,
        `🎁 daisyUI Store: ${args[2]}
Use code \`${json.data.attributes.code}\` at checkout to get ${
          json.data.attributes.amount
        }% discount on all products
${expiresIn(json.data.attributes.expires_at)}
https://daisyui.com/store`
      );
    } else {
      console.error("Failed to create LemonSqueezy discount code:", json);
    }
  })
  .catch((error) => {
    console.error("Error:", error);
  });