Function refreshFeedbackStatus

packages/core/src/feedback/feedback-service.ts:568–621

(issueNumbers: number[])

// ─── Status Refresh ────────────────────────────────────────────────────────

export async function refreshFeedbackStatus(issueNumbers: number[]): Promise<FeedbackStatusItem[]> {
  if (!_workerBaseUrl || issueNumbers.length === 0) return [];

  const params = issueNumbers.join(",");
  let response: Response;
  try {
    response = await fetch(`${_workerBaseUrl}/api/feedback/status?issues=${params}`);
  } catch (error) {
    appendStructuredLog("feedback.status_refresh.failed", { error: formatLogArg(error) }, "warn");
    return [];
  }

  if (!response.ok) {
    appendStructuredLog("feedback.status_refresh.failed", { status: response.status }, "warn");
    return [];
  }

  const items = (await response.json()) as FeedbackStatusItem[];
  appendStructuredLog("feedback.status_refresh.success", { count: items.length });

  // Update local DB
  const db = await getDB();
  const returnedNumbers = new Set(items.map((i) => i.number));

  for (const item of items) {
    const existingRows = await db.select<{
      comment_count?: number | null;
      has_new_reply?: number | null;
    }>("SELECT comment_count, has_new_reply FROM feedback WHERE issue_number = ?", [item.number]);
    const existing = existingRows[0];
    const previousCommentCount = existing?.comment_count ?? 0;
    const commentCount = item.commentCount ?? (item.hasNewComment ? 1 : 0);
    const hasNewReply = Boolean(existing?.has_new_reply) || commentCount > previousCommentCount;

    await db.execute(
      "UPDATE feedback SET status = ?, has_new_reply = ?, comment_count = ?, updated_at = ? WHERE issue_number = ?",
      [item.state, hasNewReply ? 1 : 0, commentCount, Date.now(), item.number],
    );
  }

  // Remove issues not returned by the API (likely deleted on GitHub)
  // Only delete records older than 5 minutes to avoid race condition with newly submitted feedback
  const safeDeleteThreshold = Date.now() - 5 * 60 * 1000;
  for (const num of issueNumbers) {
    if (!returnedNumbers.has(num)) {
      await db.execute("DELETE FROM feedback WHERE issue_number = ? AND created_at < ?", [
        num,
        safeDeleteThreshold,
      ]);
    }
  }

  return items;
}

// ─── Device Info Collection ────────────────────────────────────────────────