Database

import { createClient } from '@supabase/supabase-js';

const supabaseUrl = process.env.NEXT_PUBLIC_SUPABASE_URL!;
const supabaseAnonKey = process.env.NEXT_PUBLIC_SUPABASE_ANON_KEY!;

export const supabase = createClient(supabaseUrl, supabaseAnonKey);

CREATE TABLE user_wallets (
  id UUID PRIMARY KEY DEFAULT gen_random_uuid(),
  wallet_address TEXT UNIQUE NOT NULL,
  network TEXT NOT NULL,
  wallet_provider TEXT NOT NULL DEFAULT 'manual',
  connection_method TEXT NOT NULL DEFAULT 'manual',
  last_synced_at TIMESTAMPTZ,
  created_at TIMESTAMPTZ NOT NULL DEFAULT NOW(),
  updated_at TIMESTAMPTZ NOT NULL DEFAULT NOW()
);

-- Indexes for performance
CREATE INDEX idx_user_wallets_address ON user_wallets(wallet_address);
CREATE INDEX idx_user_wallets_last_synced ON user_wallets(last_synced_at DESC);

CREATE TABLE trades (
  id TEXT PRIMARY KEY,
  wallet_address TEXT NOT NULL REFERENCES user_wallets(wallet_address) ON DELETE CASCADE,
  symbol TEXT NOT NULL,
  quote_currency TEXT NOT NULL,
  side TEXT NOT NULL,
  order_type TEXT NOT NULL,
  quantity NUMERIC NOT NULL,
  price NUMERIC NOT NULL,
  notional NUMERIC NOT NULL,
  pnl NUMERIC NOT NULL,
  fee NUMERIC NOT NULL,
  fee_currency TEXT NOT NULL,
  opened_at TIMESTAMPTZ NOT NULL,
  closed_at TIMESTAMPTZ NOT NULL,
  duration_seconds INTEGER NOT NULL,
  is_win BOOLEAN NOT NULL,
  tx_signature TEXT NOT NULL,
  is_maker BOOLEAN,
  leverage NUMERIC,
  liquidation_price NUMERIC,
  margin_used NUMERIC,
  fee_breakdown JSONB,
  created_at TIMESTAMPTZ NOT NULL DEFAULT NOW()
);

-- Indexes
CREATE INDEX idx_trades_wallet ON trades(wallet_address);
CREATE INDEX idx_trades_opened_at ON trades(opened_at DESC);
CREATE INDEX idx_trades_symbol ON trades(symbol);

CREATE TABLE trade_annotations (
  id UUID PRIMARY KEY DEFAULT gen_random_uuid(),
  wallet_address TEXT NOT NULL REFERENCES user_wallets(wallet_address) ON DELETE CASCADE,
  trade_id TEXT NOT NULL REFERENCES trades(id) ON DELETE CASCADE,
  note TEXT,
  tags TEXT[],
  lessons_learned TEXT,
  emotional_state TEXT,
  created_at TIMESTAMPTZ NOT NULL DEFAULT NOW(),
  updated_at TIMESTAMPTZ NOT NULL DEFAULT NOW(),
  UNIQUE(wallet_address, trade_id)
);

-- Policy: Users can read their own wallet data
CREATE POLICY "Users can view their own wallets"
ON user_wallets
FOR SELECT
USING (wallet_address = current_setting('request.jwt.claim.wallet_address'));

-- Policy: Users can update their own wallet sync time
CREATE POLICY "Users can update their own wallets"
ON user_wallets
FOR UPDATE
USING (wallet_address = current_setting('request.jwt.claim.wallet_address'));

-- Policy: Users can read their own trades
CREATE POLICY "Users can view their own trades"
ON trades
FOR SELECT
USING (wallet_address = current_setting('request.jwt.claim.wallet_address'));