ReefFlow Hub: Killing the Developer Context-Switching Tax with a Unified Local-First Workspace 🌊

graph TD
    UI[Vite + React Frontend] <-->|JSON REST API| Server[Node.js Express Backend]
    Server <-->|execFile CLI Wrapper| Coral[Coral SQL Engine]
    Coral <-->|Reads Source Specs| Specs[coral_sources.yaml]
    Specs <-->|Queries Local Datasets| Data[JSON Files: Calendar, Tasks, GitHub, Gmail]

name: local_hub
version: 0.1.0
dsl_version: 3
description: Query local developer workspace agenda, tasks, GitHub repositories, and Gmail.
backend: file
tables:
  - name: calendar
    description: Daily developer agenda and events
    format: json
    source:
      location: file:///c:/Users/Rushabh Mahajan/Documents/VS Code/WeMakeDevs/workspace_data/local_calendar.json
    columns:
      - name: id
        type: Int64
        description: Unique event identifier
      - name: summary
        type: Utf8
        description: Title or summary of the event
      - name: start_time
        type: Utf8
        description: Event start date and time
      - name: end_time
        type: Utf8
        description: Event end date and time
      - name: location
        type: Utf8
        description: Meeting room or link
      - name: description
        type: Utf8
        description: Brief details about the agenda

  - name: tasks
    description: Notion tasks and development backlog
    format: json
    source:
      location: file:///c:/Users/Rushabh Mahajan/Documents/VS Code/WeMakeDevs/workspace_data/local_tasks.json
    columns:
      - name: id
        type: Int64
        description: Task identifier
      - name: title
        type: Utf8
        description: Title of the task
      - name: status
        type: Utf8
        description: Status (Todo, In Progress, Done)
      - name: priority
        type: Utf8
        description: Priority (High, Medium, Low)
      - name: due_date
        type: Utf8
        description: Due date for completion
      - name: project
        type: Utf8
        description: Associated workspace project name

  - name: github
    description: GitHub repository issues and pull requests
    format: json
    source:
      location: file:///c:/Users/Rushabh Mahajan/Documents/VS Code/WeMakeDevs/workspace_data/local_github.json
    columns:
      - name: id
        type: Int64
        description: GitHub issue/PR ID
      - name: title
        type: Utf8
        description: Title of the issue or PR
      - name: repo
        type: Utf8
        description: Repository name
      - name: type
        type: Utf8
        description: Type (Issue or Pull Request)
      - name: state
        type: Utf8
        description: State (open or closed)
      - name: author
        type: Utf8
        description: GitHub username of author
      - name: assigned_to
        type: Utf8
        description: Developer assigned to work on it

  - name: gmail
    description: Developer email inbox and communications
    format: json
    source:
      location: file:///c:/Users/Rushabh Mahajan/Documents/VS Code/WeMakeDevs/workspace_data/local_gmail.json
    columns:
      - name: id
        type: Int64
        description: Email message identifier
      - name: sender
        type: Utf8
        description: Email sender address
      - name: subject
        type: Utf8
        description: Subject line
      - name: body
        type: Utf8
        description: Content body of the email
      - name: is_unread
        type: Boolean
        description: Unread status (true if unread)

import { execFile } from 'child_process';

function runCoralSql(sql) {
  return new Promise((resolve, reject) => {
    // Execute: coral sql "<QUERY>" --format json
    execFile('coral', ['sql', sql, '--format', 'json'], (error, stdout, stderr) => {
      if (error) {
        return reject({ error: error.message, stderr });
      }
      try {
        const parsed = JSON.parse(stdout);
        resolve(parsed);
      } catch (parseError) {
        // Fallback for empty sets or non-JSON responses
        if (stdout.trim() === '++\n++') {
          resolve([]);
        } else {
          resolve({ raw: stdout });
        }
      }
    });
  });
}

function registerCoralSources() {
  return new Promise((resolve, reject) => {
    console.log(`Registering Coral source manifest: ${manifestPath}`);
    execFile('coral', ['source', 'add', '--file', manifestPath], (error, stdout, stderr) => {
      if (error) {
        console.error('Failed to register Coral sources:', error.message);
        return reject(error);
      }
      console.log('Coral sources registered successfully:', stdout.trim());
      resolve(stdout);
    });
  });
}

// Automatically invoke on boot
registerCoralSources().catch(err => {
  console.warn('Startup source registration warning:', err.message);
});

function getOfflineQuery(prompt) {
  const p = prompt.toLowerCase();

  if (p.includes('today') && (p.includes('work') || p.includes('priority') || p.includes('agenda'))) {
    return {
      sql: `SELECT 'calendar' as source, summary as title, start_time as detail FROM local_hub.calendar WHERE start_time LIKE '2026-05-29%' UNION SELECT 'tasks' as source, title, status as detail FROM local_hub.tasks WHERE status != 'Done' AND priority = 'High'`,
      summaryTemplate: "Here is your integrated agenda and high-priority tasks for today..."
    };
  }
  // Standard fallbacks for github, gmail, and calendar tables...
}

[User Natural Prompt] 
       │
       ▼
1. Fetch Metadata (from coral.tables & coral.columns)
       │
       ▼
2. Schema-Grounded Prompt -> [Gemini Model] -> Output: Clean SQL
       │
       ▼
3. Execute SQL Query via Coral CLI -> Output: Tabular Data
       │
       ▼
4. Raw Data + Prompt -> [Gemini Model] -> Output: Conversational Summary
       │
       ▼
[Render SQL + Table + Summary in Chat]

// Grounding pipeline code snippet in server.js
const tables = await runCoralSql("SELECT schema_name, table_name, description FROM coral.tables");
const columns = await runCoralSql("SELECT schema_name, table_name, column_name, data_type, description FROM coral.columns");

const schemaDescription = {
  tables: tables.map(t => ({ name: `${t.schema_name}.${t.table_name}`, description: t.description })),
  columns: columns.map(c => ({ table: `${c.schema_name}.${c.table_name}`, column: c.column_name, type: c.data_type, description: c.description }))
};

const sqlSystemPrompt = `You are a SQLite/SQL expert translating natural language requests into SQL queries.
Available schemas, tables, and columns:
${JSON.stringify(schemaDescription, null, 2)}
Rules:
1. Output ONLY the raw SQL query. Do not wrap in markdown code blocks.
2. Only write SELECT queries.
3. Be precise with table names (always prefix with schema like 'local_hub.tasks').

User Prompt: "${prompt}"`;

// Call Gemini API and execute result...

:root {
  --font-sans: 'Inter', sans-serif;
  --font-display: 'Outfit', sans-serif;

  /* Deep space HSL colors */
  --bg-base: 224 25% 6%;
  --bg-surface: 224 25% 10%;
  --bg-glass: 224 25% 12% / 0.45;
  --border-glass: 224 25% 20% / 0.5;

  --primary: 161 93% 42%; /* Emerald Glow */
  --accent-violet: 263 90% 64%; /* Purple Glow */

  --text-primary: 0 0% 98%;
  --text-secondary: 224 15% 70%;
  --text-muted: 224 10% 50%;

  --transition-smooth: 0.3s cubic-bezier(0.4, 0, 0.2, 1);
}

/* Glassmorphism Panel styles */
.glass-panel {
  background: hsl(var(--bg-glass));
  backdrop-filter: blur(16px);
  -webkit-backdrop-filter: blur(16px);
  border: 1px solid hsl(var(--border-glass));
  border-radius: 16px;
  box-shadow: 0 8px 32px 0 rgba(0, 0, 0, 0.37);
  transition: var(--transition-smooth);
}

.glass-panel:hover {
  border-color: hsl(var(--primary) / 0.25);
  box-shadow: 0 12px 40px 0 rgba(0, 0, 0, 0.45), 0 0 15px 0 hsl(var(--primary-glow));
}

// Toggle task execution in React
const toggleTaskStatus = async (taskId) => {
  try {
    const res = await fetch('http://localhost:5000/api/tasks/toggle', {
      method: 'POST',
      headers: { 'Content-Type': 'application/json' },
      body: JSON.stringify({ id: taskId })
    });
    if (res.ok) {
      fetchDashboardData(); // Refetches all tables via SQL to update UI state
    }
  } catch (err) {
    console.error('Failed to toggle task status:', err);
  }
};

┌────────────────────────────────────────────────────────────────────────┐
│                              REEFFLOW HUB                              │
├───────────────┬────────────────────────────────────────────────────────┤
│               │  [ Dashboard Widgets ]                                  │
│  [Sidebar]    │  • Calendar Events Table      • Notion Backlog list    │
│  - Dashboard  │  • GitHub Triaged Issues      • Gmail Inbox Card       │
│  - AI Copilot ├────────────────────────────────────────────────────────┤
│  - SQL Console│  [ SQL Console ]                                       │
│  - Schema Exp │  [ SELECT * FROM local_hub.tasks LIMIT 5            ]  │
│  - Settings   │  [ Run Query ] ➔ [ Results Table + Execution Time ]     │
│               ├────────────────────────────────────────────────────────┤
│               │  [ Schema Explorer ]                                   │
│               │  • Columns Schema  • System Inputs  • Native Filters   │
└───────────────┴────────────────────────────────────────────────────────┘

npm run dev

npm install --legacy-peer-deps