Vrachka.eu

// Single source of truth for Stripe period fields.
// Handles both pre-clover (root) and post-clover (item) shapes.
export function getSubscriptionPeriod(
  sub: Stripe.Subscription
): { start: number; end: number } {
  const item = sub.items?.data?.[0] as
    | (Stripe.SubscriptionItem & {
        current_period_start?: number;
        current_period_end?: number;
      })
    | undefined;
  const rootLike = sub as unknown as {
    current_period_start?: number;
    current_period_end?: number;
  };
  const start = item?.current_period_start ?? rootLike.current_period_start;
  const end = item?.current_period_end ?? rootLike.current_period_end;
  if (typeof start !== 'number' || typeof end !== 'number') {
    throw new Error(`Subscription ${sub.id} missing current_period fields`);
  }
  return { start, end };
}

'use workflow';

import { generateForSign } from './generate-for-sign';
import { getDailyEphemeris } from '@/lib/astrology/ephemeris-astronomy-engine';

const ZODIAC_SIGNS = [
  'aries', 'taurus', 'gemini', 'cancer', 'leo', 'virgo',
  'libra', 'scorpio', 'sagittarius', 'capricorn', 'aquarius', 'pisces',
];

export async function generateHoroscopesWorkflow() {
  const now = new Date();
  const languages: Array<'bg' | 'en'> = ['bg', 'en'];
  const periods = ['daily'];
  if (now.getDay() === 1) periods.push('weekly');
  if (now.getDate() === 1) periods.push('monthly');

  const ephemeris = getDailyEphemeris(now);

  for (const period of periods) {
    for (const sign of ZODIAC_SIGNS) {
      // Each call is a durable step. Retries independently.
      await generateForSign({ sign, period, languages, ephemeris });
    }
  }
}

// 5-min TTL cache; stale fallback on DB error (zero downtime).
let redirectsCache: Map<string, {
  destination: string;
  statusCode: number;
}> | null = null;
let redirectsCacheTime = 0;
const CACHE_TTL = 5 * 60 * 1000;

async function getRedirects() {
  const now = Date.now();
  if (redirectsCache && now - redirectsCacheTime < CACHE_TTL) {
    return redirectsCache;
  }
  try {
    const { data } = await supabase
      .from('redirects')
      .select('source_path, destination_path, status_code')
      .eq('is_active', true);
    const fresh = new Map();
    for (const r of data || []) {
      fresh.set(r.source_path, {
        destination: r.destination_path,
        statusCode: r.status_code,
      });
    }
    redirectsCache = fresh;
    redirectsCacheTime = now;
    return fresh;
  } catch {
    return redirectsCache || new Map(); // stale but not broken
  }
}

// Декларативна карта: функция → [основен, резервен 1, резервен 2].
// Кодът пише callAI({ feature: 'daily_short' }) — без да знае моделите.
export const FEATURE_MODEL_MAP: Record<AIFeature, string[]> = {
  daily_short:  ['gemini_flash_lite', 'gemini_flash',    'deepseek'],
  long_form:    ['gemini_pro',        'gemini_flash',    'deepseek'],
  // ... още функции, routing layer-ът се грижи за останалото
};