import { useQuery } from '@tanstack/react-query';
import { SKATE_SHOP_KIND, parseSkateShop, type SkateShop } from '@/lib/types';
import { useSkateRelays } from '@/hooks/useSkateRelays';

/**
 * Hook to fetch skate shops using the skate relay logic
 */
export function useSkateShops(limit: number = 100) {
  const { querySkateContent, getQueryKeySuffix } = useSkateRelays();

  return useQuery<SkateShop[]>({
    queryKey: ['skate-shops', limit, getQueryKeySuffix()],
    queryFn: async () => {
      const signal = AbortSignal.timeout(10000);

      const events = await querySkateContent(
        [{ 
          kinds: [SKATE_SHOP_KIND], 
          '#t': ['skateshop'],
          limit 
        }],
        { signal }
      );

      // Parse events into SkateShop objects
      const shops: SkateShop[] = [];
      for (const event of events) {
        const shop = parseSkateShop(event);
        if (shop) shops.push(shop);
      }

      // Sort by created_at descending
      return shops.sort((a, b) => b.createdAt - a.createdAt);
    },
    staleTime: 60000, // 1 minute
  });
}

/**
 * Hook to fetch a single skate shop by pubkey and identifier
 */
export function useSkateShop(pubkey: string | undefined, identifier: string | undefined) {
  const { querySkateContent, getQueryKeySuffix } = useSkateRelays();

  return useQuery<SkateShop | null>({
    queryKey: ['skate-shop', pubkey, identifier, getQueryKeySuffix()],
    queryFn: async () => {
      if (!pubkey || !identifier) return null;

      const signal = AbortSignal.timeout(10000);

      const events = await querySkateContent(
        [{
          kinds: [SKATE_SHOP_KIND],
          authors: [pubkey],
          '#d': [identifier],
          limit: 1,
        }],
        { signal }
      );

      if (events.length > 0) {
        return parseSkateShop(events[0]);
      }

      return null;
    },
    enabled: !!pubkey && !!identifier,
    staleTime: 30000,
  });
}