+
-
+
setName(e.target.value)}
- className="w-full rounded-xl border border-stone-200 bg-stone-50 px-4 py-2 outline-none transition-all focus:border-emerald-500 focus:ring-2 focus:ring-emerald-500"
+ type="number"
+ min="1"
+ max="50"
+ value={radius}
+ onChange={(e) => setRadius(Number.parseInt(e.target.value, 10) || 1)}
+ className="w-full rounded-xl border border-stone-200 bg-stone-50 px-4 py-3 outline-none transition-all focus:border-emerald-500 focus:ring-2 focus:ring-emerald-500"
/>
-
- Searches now run through a Supabase Edge Function, so the browser no longer writes leads directly into the database.
+
+
+ setBusinessType(e.target.value)}
+ className="w-full rounded-xl border border-stone-200 bg-stone-50 px-4 py-3 outline-none transition-all focus:border-emerald-500 focus:ring-2 focus:ring-emerald-500"
+ />
- {error && (
-
- )}
+
+
+ setKeywords(e.target.value)}
+ className="w-full rounded-xl border border-stone-200 bg-stone-50 px-4 py-3 outline-none transition-all focus:border-emerald-500 focus:ring-2 focus:ring-emerald-500"
+ />
+
-
-
-
-
-
-
-
-
Recent Searches
+
+
+ setName(e.target.value)}
+ className="w-full rounded-xl border border-stone-200 bg-stone-50 px-4 py-3 outline-none transition-all focus:border-emerald-500 focus:ring-2 focus:ring-emerald-500"
+ />
+
- {isLoadingHistory ? (
-
-
- Loading history...
+
+ Research runs now go through the local API, so the browser no longer writes leads directly into the database.
+
+
+ {error && (
+
- ) : jobs.length === 0 ? (
-
No search history yet.
- ) : (
-
- {jobs.map((job) => (
+ )}
+
+
+
+
+
+
+
+
+
Research Jobs
+
All research runs
+
+ Filter the grid to find specific runs, select the ones you want, then send the full selection to the map.
+
+
+
+ {filteredJobs.length} shown of {jobs.length}
+
+
+
+
+
+
+
+
+
+
+ {selectedJobCount > 0 && (
+
+
+
+ {selectedJobCount === 1 ? '1 research job selected' : `${selectedJobCount} research jobs selected`}
+
+
Use the selection action to open all selected jobs together on the map.
+
+
- ))}
+
+
)}
+
+ {isLoadingHistory ? (
+
+
+ Loading research jobs...
+
+ ) : filteredJobs.length === 0 ? (
+
+
No research jobs match the current filters.
+
Try adjusting the search term, status filter, or sort order.
+
+ ) : (
+
+ {filteredJobs.map((job) => {
+ const statusMeta = getStatusMeta(job.status);
+ const isSelected = selectedJobIds.includes(job.id);
+
+ return (
+
+ );
+ })}
+
+ )}
+
);
}
+
+function formatLocation(job: SearchJob) {
+ const primaryLocation = job.address || job.city || 'Location not available';
+ return `${primaryLocation} (${job.radiusKm} km radius)`;
+}
+
+function getStatusMeta(status: SearchJobStatus) {
+ switch (status) {
+ case 'completed':
+ return {
+ label: 'Completed',
+ icon: CheckCircle2,
+ badgeClass:
+ 'inline-flex items-center gap-1 rounded-full border border-emerald-200 bg-emerald-50 px-3 py-1 text-xs font-semibold text-emerald-700',
+ };
+ case 'running':
+ return {
+ label: 'Running',
+ icon: Loader2,
+ badgeClass:
+ 'inline-flex items-center gap-1 rounded-full border border-sky-200 bg-sky-50 px-3 py-1 text-xs font-semibold text-sky-700',
+ };
+ case 'failed':
+ return {
+ label: 'Failed',
+ icon: AlertCircle,
+ badgeClass:
+ 'inline-flex items-center gap-1 rounded-full border border-red-200 bg-red-50 px-3 py-1 text-xs font-semibold text-red-700',
+ };
+ case 'stopped':
+ return {
+ label: 'Stopped',
+ icon: CircleOff,
+ badgeClass:
+ 'inline-flex items-center gap-1 rounded-full border border-stone-200 bg-stone-100 px-3 py-1 text-xs font-semibold text-stone-700',
+ };
+ case 'pending':
+ default:
+ return {
+ label: 'Pending',
+ icon: Clock3,
+ badgeClass:
+ 'inline-flex items-center gap-1 rounded-full border border-amber-200 bg-amber-50 px-3 py-1 text-xs font-semibold text-amber-700',
+ };
+ }
+}
diff --git a/src/lib/api.ts b/src/lib/api.ts
new file mode 100644
index 0000000..2b88cea
--- /dev/null
+++ b/src/lib/api.ts
@@ -0,0 +1,28 @@
+const apiBaseUrl = import.meta.env.VITE_API_BASE_URL ?? '';
+
+export const hasApiConfig = Boolean(apiBaseUrl);
+
+export async function apiRequest
(path: string, init?: RequestInit): Promise {
+ if (!apiBaseUrl) {
+ throw new Error('VITE_API_BASE_URL is not configured.');
+ }
+
+ const response = await fetch(`${apiBaseUrl}${path}`, {
+ credentials: 'include',
+ headers: {
+ 'Content-Type': 'application/json',
+ ...(init?.headers ?? {}),
+ },
+ ...init,
+ });
+
+ const contentType = response.headers.get('content-type') || '';
+ const payload = contentType.includes('application/json') ? ((await response.json()) as unknown) : null;
+
+ if (!response.ok) {
+ const message = payload && typeof payload === 'object' && 'error' in payload ? String(payload.error) : 'Request failed.';
+ throw new Error(message);
+ }
+
+ return payload as T;
+}
diff --git a/src/lib/auth.ts b/src/lib/auth.ts
new file mode 100644
index 0000000..a8cf04c
--- /dev/null
+++ b/src/lib/auth.ts
@@ -0,0 +1,39 @@
+import type { AppUser, SessionUser } from '../../shared/types';
+import { apiRequest } from './api';
+
+export function getUserDisplayName(user: AppUser | SessionUser | null): string {
+ return user?.displayName || user?.email || 'User';
+}
+
+export function getUserAvatarUrl(user: AppUser | SessionUser | null): string | null {
+ return user?.avatarUrl || null;
+}
+
+export async function getLocalSessionUser() {
+ const response = await apiRequest<{ user: SessionUser | null }>('/auth/me');
+ return response.user;
+}
+
+export async function signUpWithLocalAuth(payload: { email: string; password: string; displayName?: string }) {
+ const response = await apiRequest<{ user: SessionUser }>('/auth/signup', {
+ method: 'POST',
+ body: JSON.stringify(payload),
+ });
+
+ return response.user;
+}
+
+export async function signInWithLocalAuth(payload: { email: string; password: string }) {
+ const response = await apiRequest<{ user: SessionUser }>('/auth/login', {
+ method: 'POST',
+ body: JSON.stringify(payload),
+ });
+
+ return response.user;
+}
+
+export async function signOutWithLocalAuth() {
+ await apiRequest<{ success: boolean }>('/auth/logout', {
+ method: 'POST',
+ });
+}
diff --git a/src/lib/database.ts b/src/lib/database.ts
index a5e9dc0..8a72326 100644
--- a/src/lib/database.ts
+++ b/src/lib/database.ts
@@ -1,51 +1,6 @@
-import { supabase } from './supabase';
+import { apiRequest } from './api';
import type { Business, SearchJob } from '../types';
-type SearchJobRow = {
- id: string;
- user_id: string;
- name: string;
- city: string | null;
- address: string | null;
- postal_code: string | null;
- radius_km: number;
- business_type: string;
- keywords: string | null;
- status: SearchJob['status'];
- total_results: number;
- started_at: string | null;
- completed_at: string | null;
- created_at: string;
- updated_at: string;
-};
-
-type BusinessRow = {
- id: string;
- user_id: string;
- external_source_id: string | null;
- source: string;
- name: string;
- address: string | null;
- city: string | null;
- state_province: string | null;
- postal_code: string | null;
- country: string | null;
- phone: string | null;
- website: string | null;
- rating: number | null;
- review_count: number | null;
- category: string | null;
- hours_json: Record | null;
- latitude: number | null;
- longitude: number | null;
- general_info: string | null;
- metadata_json: Record | null;
- first_seen_at: string | null;
- last_seen_at: string | null;
- created_at: string;
- updated_at: string;
-};
-
export type SearchJobResultLink = {
businessId: string;
searchJobId: string;
@@ -64,133 +19,42 @@ export type RunSearchResponse = {
totalResults: number;
};
-function mapSearchJob(row: SearchJobRow): SearchJob {
- return {
- id: row.id,
- userId: row.user_id,
- name: row.name,
- city: row.city ?? undefined,
- address: row.address ?? undefined,
- postalCode: row.postal_code ?? undefined,
- radiusKm: row.radius_km,
- businessType: row.business_type,
- keywords: row.keywords ?? undefined,
- status: row.status,
- totalResults: row.total_results,
- startedAt: row.started_at ?? undefined,
- completedAt: row.completed_at ?? undefined,
- createdAt: row.created_at,
- updatedAt: row.updated_at,
- };
+export async function listSearchJobs(userIdOrMax?: string | number, max = 10): Promise {
+ const limit = typeof userIdOrMax === 'number' ? userIdOrMax : max;
+ const response = await apiRequest<{ jobs: SearchJob[] }>(`/search-jobs?limit=${limit}`);
+ return response.jobs;
}
-function mapBusiness(row: BusinessRow): Business {
- return {
- id: row.id,
- userId: row.user_id,
- externalSourceId: row.external_source_id ?? undefined,
- source: row.source,
- name: row.name,
- address: row.address ?? undefined,
- city: row.city ?? undefined,
- stateProvince: row.state_province ?? undefined,
- postalCode: row.postal_code ?? undefined,
- country: row.country ?? undefined,
- phone: row.phone ?? undefined,
- website: row.website ?? undefined,
- rating: row.rating ?? undefined,
- reviewCount: row.review_count ?? undefined,
- category: row.category ?? undefined,
- hoursJson: row.hours_json ? JSON.stringify(row.hours_json) : undefined,
- latitude: row.latitude ?? undefined,
- longitude: row.longitude ?? undefined,
- generalInfo: row.general_info ?? undefined,
- metadataJson: row.metadata_json ? JSON.stringify(row.metadata_json) : undefined,
- firstSeenAt: row.first_seen_at ?? undefined,
- lastSeenAt: row.last_seen_at ?? undefined,
- createdAt: row.created_at,
- updatedAt: row.updated_at,
- };
+export async function listBusinesses(_userId?: string): Promise {
+ const response = await apiRequest<{ businesses: Business[] }>('/businesses');
+ return response.businesses;
}
-function ensureData(data: T | null, error: { message: string } | null, context: string): T {
- if (error) {
- throw new Error(`${context}: ${error.message}`);
+export async function listJobResultLinks(_userId?: string): Promise {
+ const response = await apiRequest<{ links: SearchJobResultLink[] }>('/search-job-results/links');
+ return response.links;
+}
+
+export async function listBusinessesForJob(userIdOrJobId: string, maybeJobId?: string): Promise {
+ const jobId = maybeJobId ?? userIdOrJobId;
+ const response = await apiRequest<{ businesses: Business[] }>(`/search-jobs/${jobId}/businesses`);
+ return response.businesses;
+}
+
+export async function listBusinessesForJobs(userIdOrJobIds: string | string[], maybeJobIds?: string[]): Promise {
+ const jobIds = Array.isArray(userIdOrJobIds) ? userIdOrJobIds : maybeJobIds ?? [];
+
+ if (jobIds.length === 0) {
+ return [];
}
- if (data === null) {
- throw new Error(`${context}: no data returned`);
- }
-
- return data;
-}
-
-export async function listSearchJobs(userId: string, max = 10): Promise {
- const { data, error } = await supabase
- .from('search_jobs')
- .select('*')
- .eq('user_id', userId)
- .order('created_at', { ascending: false })
- .limit(max);
-
- const rows = ensureData(data as SearchJobRow[] | null, error, 'Failed to load search jobs');
- return rows.map(mapSearchJob);
-}
-
-export async function listBusinesses(userId: string): Promise {
- const { data, error } = await supabase
- .from('businesses')
- .select('*')
- .eq('user_id', userId)
- .order('created_at', { ascending: false });
-
- const rows = ensureData(data as BusinessRow[] | null, error, 'Failed to load businesses');
- return rows.map(mapBusiness);
-}
-
-export async function listJobResultLinks(userId: string): Promise {
- const { data, error } = await supabase
- .from('search_job_results')
- .select('business_id, search_job_id')
- .eq('user_id', userId);
-
- const rows = ensureData(data as Array<{ business_id: string; search_job_id: string }> | null, error, 'Failed to load job links');
- return rows.map((row) => ({ businessId: row.business_id, searchJobId: row.search_job_id }));
-}
-
-export async function listBusinessesForJob(userId: string, jobId: string): Promise {
- const { data, error } = await supabase
- .from('search_job_results')
- .select('business:businesses(*)')
- .eq('user_id', userId)
- .eq('search_job_id', jobId);
-
- const rows = ensureData(
- data as Array<{ business: BusinessRow[] | null }> | null,
- error,
- 'Failed to load businesses for job',
- );
-
- return rows.flatMap((row) => {
- const business = row.business?.[0];
-
- if (!business) {
- return [];
- }
-
- return [mapBusiness(business)];
- });
+ const response = await apiRequest<{ businesses: Business[] }>(`/businesses?jobIds=${encodeURIComponent(jobIds.join(','))}`);
+ return response.businesses;
}
export async function runSearch(payload: RunSearchPayload): Promise {
- const { data, error } = await supabase.functions.invoke('run-search', {
- body: payload,
+ return apiRequest('/search-jobs', {
+ method: 'POST',
+ body: JSON.stringify(payload),
});
-
- const response = ensureData(data as { job: SearchJobRow; totalResults: number } | null, error, 'Search failed');
-
- return {
- job: mapSearchJob(response.job),
- totalResults: response.totalResults,
- };
}
diff --git a/src/lib/supabase.ts b/src/lib/supabase.ts
deleted file mode 100644
index 47c9b44..0000000
--- a/src/lib/supabase.ts
+++ /dev/null
@@ -1,34 +0,0 @@
-import { createClient, type User } from '@supabase/supabase-js';
-
-const supabaseUrl = import.meta.env.VITE_SUPABASE_URL ?? '';
-const supabaseAnonKey = import.meta.env.VITE_SUPABASE_ANON_KEY ?? '';
-
-export const hasSupabaseConfig = Boolean(supabaseUrl && supabaseAnonKey);
-
-export const supabase = createClient(supabaseUrl, supabaseAnonKey, {
- auth: {
- persistSession: true,
- autoRefreshToken: true,
- detectSessionInUrl: true,
- },
-});
-
-export function getUserDisplayName(user: User | null): string {
- if (!user) {
- return 'User';
- }
-
- const fullName = typeof user.user_metadata?.full_name === 'string' ? user.user_metadata.full_name : null;
- const name = typeof user.user_metadata?.name === 'string' ? user.user_metadata.name : null;
- const emailName = user.email ? user.email.split('@')[0] : null;
-
- return fullName || name || emailName || user.email || 'User';
-}
-
-export function getUserAvatarUrl(user: User | null): string | null {
- if (!user) {
- return null;
- }
-
- return typeof user.user_metadata?.avatar_url === 'string' ? user.user_metadata.avatar_url : null;
-}
diff --git a/src/vite-env.d.ts b/src/vite-env.d.ts
index 86409ef..e444c4e 100644
--- a/src/vite-env.d.ts
+++ b/src/vite-env.d.ts
@@ -1,8 +1,7 @@
///
interface ImportMetaEnv {
- readonly VITE_SUPABASE_URL: string;
- readonly VITE_SUPABASE_ANON_KEY: string;
+ readonly VITE_API_BASE_URL: string;
readonly VITE_GOOGLE_MAPS_PLATFORM_KEY: string;
}
diff --git a/supabase/functions/run-search/index.ts b/supabase/functions/run-search/index.ts
deleted file mode 100644
index f14c168..0000000
--- a/supabase/functions/run-search/index.ts
+++ /dev/null
@@ -1,367 +0,0 @@
-import { createClient } from 'https://esm.sh/@supabase/supabase-js@2.57.4';
-
-const corsHeaders = {
- 'Access-Control-Allow-Origin': '*',
- 'Access-Control-Allow-Headers': 'authorization, x-client-info, apikey, content-type',
-};
-
-type SearchRequest = {
- name?: string;
- location: string;
- radiusKm: number;
- businessType: string;
- keywords?: string;
-};
-
-type AddressComponent = {
- longText?: string;
- shortText?: string;
- types?: string[];
-};
-
-type Place = {
- id?: string;
- displayName?: { text?: string };
- formattedAddress?: string;
- location?: { latitude?: number; longitude?: number };
- rating?: number;
- userRatingCount?: number;
- websiteUri?: string;
- nationalPhoneNumber?: string;
- types?: string[];
- addressComponents?: AddressComponent[];
-};
-
-function jsonResponse(body: unknown, status = 200) {
- return new Response(JSON.stringify(body), {
- status,
- headers: {
- ...corsHeaders,
- 'Content-Type': 'application/json',
- },
- });
-}
-
-function assertEnv(name: string): string {
- const value = Deno.env.get(name);
-
- if (!value) {
- throw new Error(`Missing required environment variable: ${name}`);
- }
-
- return value;
-}
-
-function parseRequest(body: unknown): SearchRequest {
- if (!body || typeof body !== 'object') {
- throw new Error('Invalid request body');
- }
-
- const payload = body as Record;
- const location = typeof payload.location === 'string' ? payload.location.trim() : '';
- const businessType = typeof payload.businessType === 'string' ? payload.businessType.trim() : '';
- const radiusKm = typeof payload.radiusKm === 'number' ? payload.radiusKm : Number(payload.radiusKm);
- const name = typeof payload.name === 'string' ? payload.name.trim() : undefined;
- const keywords = typeof payload.keywords === 'string' ? payload.keywords.trim() : undefined;
-
- if (!location || !businessType || Number.isNaN(radiusKm) || radiusKm <= 0) {
- throw new Error('location, radiusKm, and businessType are required');
- }
-
- return {
- name,
- location,
- radiusKm,
- businessType,
- keywords,
- };
-}
-
-async function geocodeLocation(location: string, apiKey: string) {
- const url = new URL('https://maps.googleapis.com/maps/api/geocode/json');
- url.searchParams.set('address', location);
- url.searchParams.set('key', apiKey);
-
- const response = await fetch(url);
- const payload = await response.json();
-
- if (!response.ok || payload.status !== 'OK' || !payload.results?.[0]?.geometry?.location) {
- throw new Error('Unable to geocode the requested location');
- }
-
- return payload.results[0].geometry.location as { lat: number; lng: number };
-}
-
-async function searchPlaces(params: {
- apiKey: string;
- textQuery: string;
- lat: number;
- lng: number;
- radiusKm: number;
-}) {
- const response = await fetch('https://places.googleapis.com/v1/places:searchText', {
- method: 'POST',
- headers: {
- 'Content-Type': 'application/json',
- 'X-Goog-Api-Key': params.apiKey,
- 'X-Goog-FieldMask': [
- 'places.id',
- 'places.displayName',
- 'places.formattedAddress',
- 'places.location',
- 'places.rating',
- 'places.userRatingCount',
- 'places.websiteUri',
- 'places.nationalPhoneNumber',
- 'places.types',
- 'places.addressComponents',
- ].join(','),
- },
- body: JSON.stringify({
- textQuery: params.textQuery,
- pageSize: 20,
- locationBias: {
- circle: {
- center: {
- latitude: params.lat,
- longitude: params.lng,
- },
- radius: Math.min(params.radiusKm * 1000, 50000),
- },
- },
- }),
- });
-
- const payload = await response.json();
-
- if (!response.ok) {
- throw new Error(payload.error?.message || 'Places search failed');
- }
-
- return (payload.places || []) as Place[];
-}
-
-function getAddressComponent(components: AddressComponent[] | undefined, type: string, useShort = false) {
- if (!components) {
- return null;
- }
-
- const match = components.find((component) => component.types?.includes(type));
-
- if (!match) {
- return null;
- }
-
- return useShort ? match.shortText || match.longText || null : match.longText || match.shortText || null;
-}
-
-function buildBusinessPayload(place: Place, userId: string, businessType: string) {
- const city = getAddressComponent(place.addressComponents, 'locality');
- const stateProvince = getAddressComponent(place.addressComponents, 'administrative_area_level_1', true);
- const postalCode = getAddressComponent(place.addressComponents, 'postal_code');
- const country = getAddressComponent(place.addressComponents, 'country', true);
- const now = new Date().toISOString();
-
- return {
- user_id: userId,
- external_source_id: place.id ?? null,
- source: 'google_places',
- name: place.displayName?.text || 'Unknown business',
- address: place.formattedAddress ?? null,
- city,
- state_province: stateProvince,
- postal_code: postalCode,
- country,
- phone: place.nationalPhoneNumber ?? null,
- website: place.websiteUri ?? null,
- rating: place.rating ?? null,
- review_count: place.userRatingCount ?? null,
- category: businessType,
- latitude: place.location?.latitude ?? null,
- longitude: place.location?.longitude ?? null,
- metadata_json: {
- google_types: place.types ?? [],
- },
- first_seen_at: now,
- last_seen_at: now,
- updated_at: now,
- };
-}
-
-Deno.serve(async (req) => {
- if (req.method === 'OPTIONS') {
- return new Response('ok', { headers: corsHeaders });
- }
-
- let jobId: string | null = null;
-
- try {
- const supabaseUrl = assertEnv('SUPABASE_URL');
- const supabaseAnonKey = assertEnv('SUPABASE_ANON_KEY');
- const supabaseServiceRoleKey = assertEnv('SUPABASE_SERVICE_ROLE_KEY');
- const googleMapsServerKey = assertEnv('GOOGLE_MAPS_SERVER_KEY');
- const authHeader = req.headers.get('Authorization');
-
- if (!authHeader) {
- return jsonResponse({ error: 'Missing Authorization header' }, 401);
- }
-
- const authClient = createClient(supabaseUrl, supabaseAnonKey, {
- global: {
- headers: {
- Authorization: authHeader,
- },
- },
- });
-
- const {
- data: { user },
- error: authError,
- } = await authClient.auth.getUser();
-
- if (authError || !user) {
- return jsonResponse({ error: authError?.message || 'Unauthorized' }, 401);
- }
-
- const serviceClient = createClient(supabaseUrl, supabaseServiceRoleKey, {
- auth: {
- persistSession: false,
- autoRefreshToken: false,
- },
- });
-
- const payload = parseRequest(await req.json());
- const now = new Date().toISOString();
- const jobName = payload.name || `${payload.businessType} in ${payload.location}`;
-
- const { data: createdJob, error: createJobError } = await serviceClient
- .from('search_jobs')
- .insert({
- user_id: user.id,
- name: jobName,
- city: payload.location,
- radius_km: payload.radiusKm,
- business_type: payload.businessType,
- keywords: payload.keywords ?? null,
- status: 'running',
- total_results: 0,
- started_at: now,
- created_at: now,
- updated_at: now,
- })
- .select('*')
- .single();
-
- if (createJobError || !createdJob) {
- throw new Error(createJobError?.message || 'Failed to create search job');
- }
-
- jobId = createdJob.id;
-
- const geocoded = await geocodeLocation(payload.location, googleMapsServerKey);
- const places = await searchPlaces({
- apiKey: googleMapsServerKey,
- textQuery: [payload.businessType, payload.keywords].filter(Boolean).join(' '),
- lat: geocoded.lat,
- lng: geocoded.lng,
- radiusKm: payload.radiusKm,
- });
-
- const matchedKeywords = payload.keywords
- ? payload.keywords
- .split(',')
- .map((keyword) => keyword.trim())
- .filter(Boolean)
- : [];
-
- let totalResults = 0;
-
- for (const [index, place] of places.entries()) {
- if (!place.id || !place.displayName?.text) {
- continue;
- }
-
- const businessPayload = buildBusinessPayload(place, user.id, payload.businessType);
-
- const { data: business, error: businessError } = await serviceClient
- .from('businesses')
- .upsert(businessPayload, {
- onConflict: 'user_id,source,external_source_id',
- })
- .select('id')
- .single();
-
- if (businessError || !business) {
- throw new Error(businessError?.message || 'Failed to upsert business');
- }
-
- const { error: resultError } = await serviceClient.from('search_job_results').upsert(
- {
- user_id: user.id,
- search_job_id: jobId,
- business_id: business.id,
- matched_keywords: matchedKeywords.length > 0 ? matchedKeywords : null,
- rank: index + 1,
- captured_at: new Date().toISOString(),
- },
- {
- onConflict: 'search_job_id,business_id',
- },
- );
-
- if (resultError) {
- throw new Error(resultError.message);
- }
-
- totalResults += 1;
- }
-
- const completedAt = new Date().toISOString();
- const { data: completedJob, error: completeJobError } = await serviceClient
- .from('search_jobs')
- .update({
- total_results: totalResults,
- status: 'completed',
- completed_at: completedAt,
- updated_at: completedAt,
- })
- .eq('id', jobId)
- .select('*')
- .single();
-
- if (completeJobError || !completedJob) {
- throw new Error(completeJobError?.message || 'Failed to finalize search job');
- }
-
- return jsonResponse({
- job: completedJob,
- totalResults,
- });
- } catch (error) {
- if (jobId) {
- try {
- const supabaseUrl = assertEnv('SUPABASE_URL');
- const supabaseServiceRoleKey = assertEnv('SUPABASE_SERVICE_ROLE_KEY');
- const serviceClient = createClient(supabaseUrl, supabaseServiceRoleKey, {
- auth: {
- persistSession: false,
- autoRefreshToken: false,
- },
- });
-
- await serviceClient
- .from('search_jobs')
- .update({
- status: 'failed',
- updated_at: new Date().toISOString(),
- })
- .eq('id', jobId);
- } catch (_updateError) {
- // Ignore secondary failure while surfacing the primary error.
- }
- }
-
- const message = error instanceof Error ? error.message : 'Unexpected error';
- return jsonResponse({ error: message }, 500);
- }
-});
diff --git a/supabase/migrations/20260322120000_init.sql b/supabase/migrations/20260322120000_init.sql
deleted file mode 100644
index 7e8d2fb..0000000
--- a/supabase/migrations/20260322120000_init.sql
+++ /dev/null
@@ -1,165 +0,0 @@
-create extension if not exists pgcrypto;
-
-create or replace function public.set_updated_at()
-returns trigger
-language plpgsql
-as $$
-begin
- new.updated_at = now();
- return new;
-end;
-$$;
-
-create table if not exists public.search_jobs (
- id uuid primary key default gen_random_uuid(),
- user_id uuid not null references auth.users (id) on delete cascade,
- name text not null,
- city text,
- address text,
- postal_code text,
- radius_km numeric not null,
- business_type text not null,
- keywords text,
- status text not null check (status in ('pending', 'running', 'completed', 'failed', 'stopped')),
- total_results integer not null default 0,
- cancel_requested boolean not null default false,
- started_at timestamptz,
- completed_at timestamptz,
- created_at timestamptz not null default now(),
- updated_at timestamptz not null default now()
-);
-
-create table if not exists public.businesses (
- id uuid primary key default gen_random_uuid(),
- user_id uuid not null references auth.users (id) on delete cascade,
- external_source_id text,
- source text not null,
- name text not null,
- address text,
- city text,
- state_province text,
- postal_code text,
- country text,
- phone text,
- website text,
- rating numeric,
- review_count integer,
- category text,
- hours_json jsonb,
- latitude double precision,
- longitude double precision,
- general_info text,
- metadata_json jsonb,
- first_seen_at timestamptz,
- last_seen_at timestamptz,
- created_at timestamptz not null default now(),
- updated_at timestamptz not null default now(),
- constraint businesses_user_source_external_source_key unique (user_id, source, external_source_id)
-);
-
-create table if not exists public.search_job_results (
- id uuid primary key default gen_random_uuid(),
- user_id uuid not null references auth.users (id) on delete cascade,
- search_job_id uuid not null references public.search_jobs (id) on delete cascade,
- business_id uuid not null references public.businesses (id) on delete cascade,
- matched_keywords text[],
- rank integer,
- captured_at timestamptz not null default now(),
- constraint search_job_results_job_business_key unique (search_job_id, business_id)
-);
-
-create index if not exists search_jobs_user_created_at_idx on public.search_jobs (user_id, created_at desc);
-create index if not exists businesses_user_created_at_idx on public.businesses (user_id, created_at desc);
-create index if not exists search_job_results_user_job_idx on public.search_job_results (user_id, search_job_id);
-
-drop trigger if exists set_search_jobs_updated_at on public.search_jobs;
-create trigger set_search_jobs_updated_at
-before update on public.search_jobs
-for each row
-execute function public.set_updated_at();
-
-drop trigger if exists set_businesses_updated_at on public.businesses;
-create trigger set_businesses_updated_at
-before update on public.businesses
-for each row
-execute function public.set_updated_at();
-
-alter table public.search_jobs enable row level security;
-alter table public.businesses enable row level security;
-alter table public.search_job_results enable row level security;
-
-drop policy if exists "Users can read their search jobs" on public.search_jobs;
-drop policy if exists "Users can insert their search jobs" on public.search_jobs;
-drop policy if exists "Users can update their search jobs" on public.search_jobs;
-drop policy if exists "Users can delete their search jobs" on public.search_jobs;
-drop policy if exists "Users can read their businesses" on public.businesses;
-drop policy if exists "Users can insert their businesses" on public.businesses;
-drop policy if exists "Users can update their businesses" on public.businesses;
-drop policy if exists "Users can delete their businesses" on public.businesses;
-drop policy if exists "Users can read their search job results" on public.search_job_results;
-drop policy if exists "Users can insert their search job results" on public.search_job_results;
-drop policy if exists "Users can update their search job results" on public.search_job_results;
-drop policy if exists "Users can delete their search job results" on public.search_job_results;
-
-create policy "Users can read their search jobs"
-on public.search_jobs
-for select
-using (auth.uid() = user_id);
-
-create policy "Users can insert their search jobs"
-on public.search_jobs
-for insert
-with check (auth.uid() = user_id);
-
-create policy "Users can update their search jobs"
-on public.search_jobs
-for update
-using (auth.uid() = user_id)
-with check (auth.uid() = user_id);
-
-create policy "Users can delete their search jobs"
-on public.search_jobs
-for delete
-using (auth.uid() = user_id);
-
-create policy "Users can read their businesses"
-on public.businesses
-for select
-using (auth.uid() = user_id);
-
-create policy "Users can insert their businesses"
-on public.businesses
-for insert
-with check (auth.uid() = user_id);
-
-create policy "Users can update their businesses"
-on public.businesses
-for update
-using (auth.uid() = user_id)
-with check (auth.uid() = user_id);
-
-create policy "Users can delete their businesses"
-on public.businesses
-for delete
-using (auth.uid() = user_id);
-
-create policy "Users can read their search job results"
-on public.search_job_results
-for select
-using (auth.uid() = user_id);
-
-create policy "Users can insert their search job results"
-on public.search_job_results
-for insert
-with check (auth.uid() = user_id);
-
-create policy "Users can update their search job results"
-on public.search_job_results
-for update
-using (auth.uid() = user_id)
-with check (auth.uid() = user_id);
-
-create policy "Users can delete their search job results"
-on public.search_job_results
-for delete
-using (auth.uid() = user_id);
diff --git a/tsconfig.json b/tsconfig.json
index 99a21b1..136a2da 100644
--- a/tsconfig.json
+++ b/tsconfig.json
@@ -23,5 +23,5 @@
"allowImportingTsExtensions": true,
"noEmit": true
},
- "include": ["src", "vite.config.ts"]
+ "include": ["src", "shared", "vite.config.ts"]
}
diff --git a/tsconfig.server.json b/tsconfig.server.json
new file mode 100644
index 0000000..7dcbd4f
--- /dev/null
+++ b/tsconfig.server.json
@@ -0,0 +1,16 @@
+{
+ "compilerOptions": {
+ "target": "ES2022",
+ "module": "NodeNext",
+ "moduleResolution": "NodeNext",
+ "lib": ["ES2022"],
+ "strict": true,
+ "skipLibCheck": true,
+ "esModuleInterop": true,
+ "resolveJsonModule": true,
+ "types": ["node"],
+ "rootDir": ".",
+ "outDir": "dist-server"
+ },
+ "include": ["server/**/*.ts", "db/scripts/**/*.ts", "shared/**/*.ts"]
+}