Zapier Alternative:
Migrate to Self-Hosted n8n

version: '3.8'

services:
  postgres:
    image: postgres:16-alpine
    container_name: n8n_db_postgres
    restart: always
    environment:
      - POSTGRES_USER=${DB_USER:-n8n_admin}
      - POSTGRES_PASSWORD=${DB_PASSWORD:-MustChangeThisPassword123!}
      - POSTGRES_DB=${DB_NAME:-n8n_workflows}
    volumes:
      - postgres_data:/var/lib/postgresql/data
    healthcheck:
      test: ["CMD-SHELL", "pg_isready -U n8n_admin -d n8n_workflows"]
      interval: 10s
      timeout: 5s
      retries: 5

  n8n:
    image: docker.n8n.io/n8nio/n8n:latest
    container_name: n8n_engine_core
    restart: always
    ports:
      - "5678:5678"
    environment:
      - DB_TYPE=postgresdb
      - DB_POSTGRESDB_HOST=postgres
      - DB_POSTGRESDB_PORT=5432
      - DB_POSTGRESDB_DATABASE=${DB_NAME:-n8n_workflows}
      - DB_POSTGRESDB_USER=${DB_USER:-n8n_admin}
      - DB_POSTGRESDB_PASSWORD=${DB_PASSWORD:-MustChangeThisPassword123!}
      - N8N_HOST=${N8N_DOMAIN:-automation.mehvar.store}
      - N8N_PORT=5678
      - N8N_PROTOCOL=https
      - NODE_ENV=production
      - WEBHOOK_URL=https://${N8N_DOMAIN:-automation.mehvar.store}/
    volumes:
      - n8n_data:/home/node/.n8n
    depends_on:
      postgres:
        condition: service_healthy

volumes:
  postgres_data:
  n8n_data:

-- Create tracking schema for unified marketing clickstream data
CREATE SCHEMA IF NOT EXISTS tracking;

-- Base clickstream event table mimicking Segment payload structures
CREATE TABLE IF NOT EXISTS tracking.events (
    id UUID PRIMARY KEY DEFAULT gen_random_uuid(),
    anonymous_id VARCHAR(255) NOT NULL,
    user_id VARCHAR(255) NULL,
    event_type VARCHAR(100) NOT NULL, -- 'page', 'track', 'identify', 'screen'
    event_name VARCHAR(150) NOT NULL,
    page_url TEXT NULL,
    referrer TEXT NULL,
    user_agent TEXT NULL,
    ip_address INET NULL,
    payload JSONB NOT NULL,
    created_at TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP NOT NULL
);

-- Optimize JSONB search operations via GIN indexing on common payloads
CREATE INDEX IF NOT EXISTS idx_events_payload ON tracking.events USING gin (payload);
CREATE INDEX IF NOT EXISTS idx_events_name_type ON tracking.events (event_name, event_type);
CREATE INDEX IF NOT EXISTS idx_events_anonymous_id ON tracking.events (anonymous_id);