Function handleActivity

src/embed/activity.ts:369–673

(
  c: Context,
  snowcode: string,
  provider: DataProvider
)

};

export const handleActivity = async (
  c: Context,
  snowcode: string,
  provider: DataProvider
): Promise<Response> => {
  let language: string | null = null;
  let authorHandle: string | null = null;
  let mediaNumber: number | null = null;
  let textOnly = false;
  let forceMosaic = false;
  const decoded = decodeSnowcode(snowcode);
  const statusId = decoded.i;
  if (decoded.l) {
    language = decoded.l;
  }
  if (decoded.h) {
    authorHandle = decoded.h;
  }
  if (decoded.t) {
    textOnly = true;
  }
  if (decoded.m) {
    forceMosaic = true;
  }
  if (decoded.n) {
    mediaNumber = decoded.n;
  }

  const preferredProxyServiceHost =
    typeof decoded.p === 'string' && decoded.p.length > 0 ? decoded.p : undefined;

  console.log('snowcode params', JSON.stringify(decoded));

  let thread: SocialThread;
  if (provider === DataProvider.Twitter) {
    thread = await constructTwitterThread(
      statusId,
      false,
      twitterBuildHostFromContext(c),
      language ?? undefined,
      false
    );
  } else if (provider === DataProvider.Bluesky) {
    thread = await constructBlueskyThread(
      statusId,
      authorHandle ?? '',
      false,
      blueskyBuildHostFromContext(c),
      language ?? undefined,
      preferredProxyServiceHost ? { preferredProxyServiceHost } : undefined
    );
  } else if (provider === DataProvider.TikTok) {
    // Get proxy base URL from the current request for TikTok video proxy
    const requestUrl = new URL(c.req.url);
    const proxyBase = `${requestUrl.protocol}//${requestUrl.host}`;
    thread = await constructTikTokVideo(statusId, proxyBase);
  } else {
    return returnError(c, Strings.ERROR_API_FAIL);