Perplexica/db/init.sql

-- Enable required extensions
create extension if not exists "uuid-ossp";      -- For UUID generation
create extension if not exists pg_cron;          -- For scheduled jobs

-- Create the search_cache table
create table public.search_cache (
  id uuid default uuid_generate_v4() primary key,
  query text not null,
  results jsonb not null,
  location text not null,
  category text not null,
  created_at timestamp with time zone default timezone('utc'::text, now()) not null,
  updated_at timestamp with time zone default timezone('utc'::text, now()) not null,
  expires_at timestamp with time zone default timezone('utc'::text, now() + interval '7 days') not null
);

-- Create indexes
create index search_cache_query_idx on public.search_cache (query);
create index search_cache_location_category_idx on public.search_cache (location, category);
create index search_cache_expires_at_idx on public.search_cache (expires_at);

-- Enable RLS
alter table public.search_cache enable row level security;

-- Create policies
create policy "Allow public read access"
  on public.search_cache for select
  using (true);

create policy "Allow service write access"
  on public.search_cache for insert
  with check (true);

create policy "Allow service update access"
  on public.search_cache for update
  using (true)
  with check (true);

create policy "Allow delete expired records"
  on public.search_cache for delete
  using (expires_at < now());

-- Create function to clean up expired records
create or replace function cleanup_expired_cache()
returns void
language plpgsql
security definer
as $$
begin
  delete from public.search_cache
  where expires_at < now();
end;
$$;

-- Create a manual cleanup function since pg_cron might not be available
create or replace function manual_cleanup()
returns void
language plpgsql
security definer
as $$
begin
  delete from public.search_cache
  where expires_at < now();
end;
$$;

-- Create a view for cache statistics
create or replace view cache_stats as
select
  count(*) as total_entries,
  count(*) filter (where expires_at < now()) as expired_entries,
  count(*) filter (where expires_at >= now()) as valid_entries,
  min(created_at) as oldest_entry,
  max(created_at) as newest_entry,
  count(distinct category) as unique_categories,
  count(distinct location) as unique_locations
from public.search_cache;

-- Grant permissions to access the view
grant select on cache_stats to postgres;

-- Create table if not exists businesses
create table if not exists businesses (
  id text primary key,
  name text not null,
  phone text,
  email text,
  address text,
  rating numeric,
  website text,
  logo text,
  source text,
  description text,
  latitude numeric,
  longitude numeric,
  last_updated timestamp with time zone default timezone('utc'::text, now()),
  search_count integer default 1,
  created_at timestamp with time zone default timezone('utc'::text, now())
);

-- Create indexes for common queries
create index if not exists businesses_name_idx on businesses (name);
create index if not exists businesses_rating_idx on businesses (rating desc);
create index if not exists businesses_search_count_idx on businesses (search_count desc);
create index if not exists businesses_last_updated_idx on businesses (last_updated desc);

-- Create tables if they don't exist
CREATE TABLE IF NOT EXISTS businesses (
    id TEXT PRIMARY KEY,
    name TEXT NOT NULL,
    phone TEXT,
    email TEXT,
    address TEXT,
    rating INTEGER,
    website TEXT,
    logo TEXT,
    source TEXT,
    description TEXT,
    location JSONB,
    place_id TEXT,
    photos TEXT[],
    opening_hours TEXT[],
    distance JSONB,
    last_updated TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP,
    search_count INTEGER DEFAULT 0
);

CREATE TABLE IF NOT EXISTS searches (
    id SERIAL PRIMARY KEY,
    query TEXT NOT NULL,
    location TEXT NOT NULL,
    timestamp TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP,
    results_count INTEGER
);

CREATE TABLE IF NOT EXISTS cache (
    key TEXT PRIMARY KEY,
    value JSONB NOT NULL,
    created_at TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP,
    expires_at TIMESTAMP WITH TIME ZONE NOT NULL
);

-- Create indexes
CREATE INDEX IF NOT EXISTS idx_businesses_location ON businesses USING GIN (location);
CREATE INDEX IF NOT EXISTS idx_businesses_search ON businesses USING GIN (to_tsvector('english', name || ' ' || COALESCE(description, '')));
CREATE INDEX IF NOT EXISTS idx_cache_expires ON cache (expires_at);

-- Set up RLS (Row Level Security)
ALTER TABLE businesses ENABLE ROW LEVEL SECURITY;
ALTER TABLE searches ENABLE ROW LEVEL SECURITY;
ALTER TABLE cache ENABLE ROW LEVEL SECURITY;

-- Create policies
CREATE POLICY "Allow anonymous select" ON businesses FOR SELECT USING (true);
CREATE POLICY "Allow service role insert" ON businesses FOR INSERT WITH CHECK (true);
CREATE POLICY "Allow service role update" ON businesses FOR UPDATE USING (true);

CREATE POLICY "Allow anonymous select" ON searches FOR SELECT USING (true);
CREATE POLICY "Allow service role insert" ON searches FOR INSERT WITH CHECK (true);

CREATE POLICY "Allow anonymous select" ON cache FOR SELECT USING (true);
CREATE POLICY "Allow service role all" ON cache USING (true);

-- Add place_id column to businesses table if it doesn't exist
ALTER TABLE businesses ADD COLUMN IF NOT EXISTS place_id TEXT;
CREATE INDEX IF NOT EXISTS idx_businesses_place_id ON businesses(place_id);

-- Create a unique constraint on place_id (excluding nulls)
CREATE UNIQUE INDEX IF NOT EXISTS idx_businesses_place_id_unique 
ON businesses(place_id) 
WHERE place_id IS NOT NULL;