api.js

const { createClient } = require("@supabase/supabase-js");
require("dotenv").config();
const supaUrl = process.env.REACT_APP_SUPABASE_URL;
const supaAdminKey = process.env.SUPABASE_SECRET_KEY;

const supabase = createClient(supaUrl, supaAdminKey);

const setStatus = async (id, status = "sent") => {
  const { data, error } = await supabase
    .from("digest")
    .update({ status: status, updated_at: "NOW()" })
    .eq("id", id);

  return true;
};
const getDigestsSummary = async (campaign) => {
  let query = supabase
    .from("digests")
    .select("*")
    .eq("campaign", campaign)
    .order("created_at", { ascending: false });

  const { data, error } = await query;

  if (error) throw error;

  return data;
};

const getDigests = async (campaign, status = "pending", created_at = null) => {
  let query = supabase
    .from("digest")
    .select("*")
    .eq("status", status)
    .eq("campaign", campaign)
    .order("id");

  if (created_at) query = query.eq("created_at", created_at);

  const { data, error } = await query;
  if (error) throw error;

  return data;
};

const makeUrl = (campaign, hash) => {
  return (
    process.env.REACT_APP_SUPABASE_URL +
    "/storage/v1/object/public/picture/" +
    campaign +
    "/" +
    hash +
    ".jpg"
  );
};

const getTargets = async (campaign, status = "pending") => {
  const { data, error } = await supabase
    .from("digest_targets")
    .select("*")
    .eq("status", status)
    .eq("campaign", campaign);
  if (error) throw error;

  return data;
};

// TO DO: For the next digests, check if pics/comments are already sent
// mark stars and comment if included in digests??

const getTopPics = async (campaign, area = null) => {
  //console.log("getting top pics for ", campaign, area)
  let q = supabase
    .from("pictures")
    .select("*")
    .eq("campaign", campaign)
    .is("star", true)
    .order("created_at", { ascending: false })
    .limit(3);
  if (area) q = q.eq("area", area);
  const { data, error } = await q;

  if (error) console.error("error getting top pics", error);

  if (data.length === 0) {
    console.error("  no top pics for", campaign, area);
    return "";
  }

  let topPics = "";

  data.map((pic) => {
    const style = `height:${pic.height}px;width:${pic.width}px`;
    topPics += `<p><b>${pic.legend}: </b></p><img src="${makeUrl(
      campaign,
      pic.hash
    )}" style=${style} alt="${pic.id}" />`;
  });

  return { data: data, html: topPics };
};
const getTopComments = async (campaign, area = null) => {
  let q = supabase
    .from("comments")
    .select("*")
    .eq("campaign", campaign)
    .is("star", true)
    .order("created_at", { ascending: false })
    .limit(3);

  if (area) q = q.eq("area", area);

  const { data, error } = await q;
  if (error) console.log("error getting top comments", error);

  if (data.length === 0) {
    console.log("  no top comments for", campaign, area);
    return "";
  }

  let topComments = "";

  data.map((comment) => {
    topComments += `<p><b>${comment.name}: </b>${comment.comment}</p>`;
  });

  return {
    data: data,
    html: `<div style="background-color: #d3d3d3; padding: 1%">${topComments}</div>`,
  };
};

const getLastCount = async (campaign, email) => {
  const q = supabase
    .from("digest")
    .select("variables")
    .eq("campaign", campaign)
    .eq("email", email)
    .order("id", { ascending: false })
    .limit(1)
    .maybeSingle();

  const { data, error } = await q;

  if (error) console.log("error getting last count for" + email, error);
  if (!data) return { lastTotal: 0, lastCountryTotal: 0 };

  return {
    lastTotal: data.variables?.total || 0,
    lastCountryTotal: data.variables?.country?.total || 0,
  };
};

module.exports = {
  supabase,
  getDigests,
  getDigestsSummary,
  getTopPics,
  getTopComments,
  setStatus,
  getLastCount,
};