daymoondevelopment/post-for-me/add-platform

export interface SnapchatConfiguration {
  caption?: string;
  media?: PostMedia[];
  // platform-specific options…
  placement?: "spotlight" | "story";
  allow_resharing?: boolean;
}

export type PlatformConfiguration =
  | PinterestConfiguration
  | InstagramConfiguration
  // … existing entries …
  | SnapchatConfiguration; // <- append

async post({
  postId,
  account,
  caption,
  media,
  platformConfig,
}: {
  postId: string;
  account: SocialAccount;
  caption: string;
  media: PostMedia[];
  platformConfig:
    | PinterestConfiguration
    // … existing entries …
    | SnapchatConfiguration; // <- append
}): Promise<PostResult> {

import { SupabaseClient } from "@supabase/supabase-js";
import { logger } from "@trigger.dev/sdk/v3";
import { PostClient } from "../post-client";
import {
  PlatformAppCredentials,
  PostMedia,
  PostResult,
  RefreshTokenResult,
  SocialAccount,
  SnapchatConfiguration, // your new type
} from "../post.types";
export class SnapchatPostClient extends PostClient {
  // ── platform constants ──────────────────────────────────────────────
  readonly #MAX_IMAGES = 10;
  readonly #CHAR_LIMIT  = 250;
  // ── state (reset per call — initialise in constructor or at top of post()) ─
  #requests:  any[] = [];
  #responses: any[] = [];
  // ── credentials ─────────────────────────────────────────────────────
  #clientId:     string;
  #clientSecret: string;
  constructor(
    supabaseClient: SupabaseClient,
    appCredentials: PlatformAppCredentials,
  ) {
    super(supabaseClient, appCredentials);
    this.#clientId     = appCredentials.app_id;
    this.#clientSecret = appCredentials.app_secret;
  }

async refreshAccessToken(account: SocialAccount): Promise<RefreshTokenResult> {
  const url = "https://accounts.snapchat.com/login/oauth2/access_token";
  this.#requests.push({ refreshRequest: url });
  const res = await fetch(url, {
    method: "POST",
    headers: { "Content-Type": "application/x-www-form-urlencoded" },
    body: new URLSearchParams({
      grant_type:    "refresh_token",
      refresh_token: account.refresh_token!,
      client_id:     this.#clientId,
      client_secret: this.#clientSecret,
    }),
  });
  const data = await res.json();
  this.#responses.push({ refreshResponse: data });
  if (!res.ok) {
    throw new Error(`Failed to refresh Snapchat token: ${data.error_description ?? data.error}`);
  }
  return {
    access_token:  data.access_token,
    refresh_token: data.refresh_token ?? account.refresh_token,
    expires_at:    new Date(Date.now() + data.expires_in * 1000).toISOString(),
  };
}

async post({
  postId,
  account,
  caption,
  media,
  platformConfig,
}: {
  postId: string;
  account: SocialAccount;
  caption: string;
  media: PostMedia[];
  platformConfig: SnapchatConfiguration;
}): Promise<PostResult> {
  try {
    logger.log("Starting Snapchat post", { postId, accountId: account.id });
    const sanitizedCaption = this.#sanitizeCaption(caption);
    // Branch by media type — keep each path in a separate method
    const mediaId =
      media.length === 0      ? null
      : media[0].type === "video" ? await this.#processVideo(media[0], account, platformConfig)
      :                             await this.#processImages(media, account, platformConfig);
    // Build the publish payload (logic that applies regardless of media type)
    const payload = {
      caption:    sanitizedCaption,
      placement:  platformConfig?.placement ?? "story",
      media_id:   mediaId,
      access_token: account.access_token,
    };
    this.#requests.push({ postRequest: payload });
    const res  = await fetch("https://adsapi.snapchat.com/v1/media/publish", {
      method: "POST",
      headers: { "Content-Type": "application/json" },
      body: JSON.stringify(payload),
    });
    const data = await res.json();
    this.#responses.push({ postResponse: data });
    if (!res.ok) {
      throw new Error(data.error_message ?? `HTTP ${res.status}`);
    }
    const postId_   = data.id as string;
    const postUrl   = `https://www.snapchat.com/p/${postId_}`;
    logger.log("Snapchat post published", { platformPostId: postId_, postUrl });
    return {
      success:               true,
      post_id:               postId,
      provider_connection_id: account.id,
      provider_post_id:      postId_,
      provider_post_url:     postUrl,
      details: {
        requests:  this.#requests,
        responses: this.#responses,
      },
    };
  } catch (error: any) {
    console.error("Error posting to Snapchat:", error);
    return {
      success:               false,
      post_id:               postId,
      provider_connection_id: account.id,
      error_message: this.#humanError(error),
      details: {
        error:     error?.response?.data ?? error?.message ?? error,
        requests:  this.#requests,
        responses: this.#responses,
      },
    };
  }
}

async #processVideo(
  medium: PostMedia,
  account: SocialAccount,
  config: SnapchatConfiguration,
): Promise<string> {
  logger.log("Uploading video to Snapchat", { mediaId: medium.id });
  const url = await this.getSignedUrlForFile(medium);
  this.#requests.push({ videoUploadRequest: { url } });
  const res  = await fetch("https://adsapi.snapchat.com/v1/media/upload/video", {
    method: "POST",
    headers: { Authorization: `Bearer ${account.access_token}` },
    body: JSON.stringify({ source_url: url }),
  });
  const data = await res.json();
  this.#responses.push({ videoUploadResponse: data });
  if (!res.ok) throw new Error(data.error_message ?? `Video upload failed: HTTP ${res.status}`);
  return data.media_id as string;
}
async #processImages(
  media: PostMedia[],
  account: SocialAccount,
  config: SnapchatConfiguration,
): Promise<string> {
  logger.log("Uploading images to Snapchat", { count: media.length });
  const allowed = media.filter(m => m.type !== "video").slice(0, this.#MAX_IMAGES);
  const ids: string[] = [];
  for (const medium of allowed) {
    this.#requests.push({ imageUploadRequest: { mediaId: medium.id } });
    const file = await this.getFile(medium);
    // … upload …
    this.#responses.push({ imageUploadResponse: { uploaded: medium.id } });
    ids.push(medium.id);
  }
  return ids.join(",");
}

#sanitizeCaption(caption: string): string {
  return caption.trim().slice(0, this.#CHAR_LIMIT);
}

#humanError(error: any): string {
  const apiMsg = error?.response?.data?.error_message
    ?? error?.response?.data?.message
    ?? error?.message;
  if (error?.response?.status === 401) {
    return "Your Snapchat account needs to be reconnected — the access token has expired.";
  }
  if (error?.response?.status === 403) {
    return "Permission denied by Snapchat. Check that the account has the required scopes.";
  }
  if (apiMsg?.toLowerCase().includes("rate limit")) {
    return "Snapchat rate limit reached. Please wait a few minutes and try again.";
  }
  return `Failed to post to Snapchat: ${apiMsg ?? "unknown error"}. Check the details for more information.`;
}

details: {
  requests:  this.#requests,   // array of request snapshots
  responses: this.#responses,  // array of response snapshots
  // optional extras:
  warning?:    string,         // non-fatal caveats (e.g. "only first 10 items posted")
  addedMedia?: { key: string; bucket: string }[], // temp files written to Supabase Storage
  // additional error context not suitable for error_message:
  error?:      any,            // raw error object on failure paths
}