⌘
@@ -63,22 +75,56 @@
Recent Activity
-Track latest agent executions across all directives.
+Perspective
+Overview of recent agent directives and live communication.
+ +
+
+
+
-
-
-
+
+
@@ -98,6 +144,9 @@
+
| Directive | -Status | -Date | -
|---|
+
+
+
+
+
+
+
+ Neural Link
+ +
+
+
+
+
+
+ Establish connection with the neural assistant.
+
+
+
+
+
+
+ | Directive | +Status | +Date | +
|---|
+
+ `;
+ return;
+ }
+
+ chatMessagesEl.innerHTML = state.chatMessages
+ .map(msg => `
+ Start a conversation with the assistant.
+
+ ${DOMPurify.sanitize(marked.parse(msg.content || ''))}
+
+ `)
+ .join('');
+
+ chatMessagesEl.scrollTop = chatMessagesEl.scrollHeight;
+}
+
+async function sendChatMessage(text) {
+ const userMessage = { role: 'user', content: text };
+ state.chatMessages.push(userMessage);
+ renderChat();
+
+ chatInput.value = '';
+ chatInput.disabled = true;
+ chatSendBtn.disabled = true;
+
+ try {
+ const response = await fetchWithAuth(`${API_URL}/chat`, {
+ method: 'POST',
+ headers: { 'Content-Type': 'application/json' },
+ body: JSON.stringify({ messages: state.chatMessages })
+ });
+
+ if (!response.ok) throw new Error('Chat API failed');
+
+ const result = await response.json();
+ state.chatMessages.push(result.message);
+ renderChat();
+ } catch (error) {
+ console.error('Chat error:', error);
+ showToast('Failed to get chat response.', 'error');
+ state.chatMessages.push({ role: 'assistant', content: 'Sorry, I encountered an error. Please try again.' });
+ renderChat();
+ } finally {
+ chatInput.disabled = false;
+ chatSendBtn.disabled = false;
+ chatInput.focus();
+ }
+}
+
// Event Listeners
rerunBtn.addEventListener('click', async () => {
if (!state.selectedTaskId) return;
@@ -447,6 +572,19 @@ toggleCustomCronBtn.addEventListener('click', () => {
customCronContainer.classList.toggle('hidden');
});
+chatForm.addEventListener('submit', (e) => {
+ e.preventDefault();
+ const text = chatInput.value.trim();
+ if (text) {
+ sendChatMessage(text);
+ }
+});
+
+clearChatBtn.addEventListener('click', () => {
+ state.chatMessages = [];
+ renderChat();
+});
+
cronInput.addEventListener('input', () => {
// If user types manually, update presets active state
updateScheduleUI(cronInput.value);
@@ -511,17 +649,86 @@ async function checkSession() {
return false;
}
-let isPolling = false;
-async function startAutoRefresh() {
- setInterval(async () => {
- if (isPolling) return;
- isPolling = true;
+let socket = null;
+let reconnectDelay = 1000;
+
+function connectWebSocket() {
+ const protocol = window.location.protocol === 'https:' ? 'wss:' : 'ws:';
+ const wsUrl = `${protocol}//${window.location.host}/api/ws`;
+
+ console.log('Connecting to WebSocket:', wsUrl);
+ socket = new WebSocket(wsUrl);
+
+ socket.onopen = () => {
+ console.log('WebSocket connected');
+ reconnectDelay = 1000;
+ // Initial fetch to sync state
+ fetchTasks();
+ };
+
+ socket.onmessage = (event) => {
try {
- await fetchTasks();
- } finally {
- isPolling = false;
+ const { type, data } = JSON.parse(event.data);
+ console.log('WebSocket event:', type, data);
+
+ switch (type) {
+ case 'TaskCreated':
+ state.tasks.unshift(data);
+ renderApp();
+ showToast('New task created', 'success');
+ break;
+ case 'TaskUpdated':
+ case 'RunFinished':
+ const index = state.tasks.findIndex(t => t.id === data.id);
+ if (index !== -1) {
+ const wasSelected = state.selectedTaskId === data.id;
+ state.tasks[index] = data;
+ if (wasSelected) {
+ // Update selected run if we were following latest
+ const wasFollowingLatest = state.selectedRunId === state.tasks[index].runs?.[1]?.id || !state.selectedRunId;
+ if (wasFollowingLatest && data.runs && data.runs.length > 0) {
+ state.selectedRunId = data.runs[0].id;
+ }
+ }
+ } else {
+ state.tasks.unshift(data);
+ }
+ renderApp();
+ if (type === 'RunFinished') {
+ showToast(`Task run completed: ${data.goal}`, 'info');
+ }
+ break;
+ case 'RunStarted':
+ const taskIndex = state.tasks.findIndex(t => t.id === data.task_id);
+ if (taskIndex !== -1) {
+ // We don't have the full task update here, but we can update status
+ // For simplicity, we just trigger a fetch or wait for RunFinished
+ // But let's at least show it's running in the UI if selected
+ if (state.tasks[taskIndex].runs) {
+ // Prepend a dummy run or just fetch
+ fetchTasks();
+ }
+ }
+ showToast(`Task started: ${data.goal}`, 'info');
+ break;
+ }
+ } catch (e) {
+ console.error('Error handling WebSocket message:', e);
}
- }, 3000);
+ };
+
+ socket.onclose = () => {
+ console.log('WebSocket disconnected. Reconnecting...');
+ setTimeout(() => {
+ reconnectDelay = Math.min(reconnectDelay * 1.5, 30000);
+ connectWebSocket();
+ }, reconnectDelay);
+ };
+
+ socket.onerror = (error) => {
+ console.error('WebSocket error:', error);
+ socket.close();
+ };
}
async function showLogin() {
@@ -552,7 +759,14 @@ async function handleCallback() {
const response = await fetch(`${API_URL}/auth/callback?code=${code}&redirect_uri=${encodeURIComponent(AUTH_CONFIG.redirectUri)}`, {
credentials: 'include'
});
- const data = await response.json();
+ const contentType = response.headers.get("content-type");
+ let data;
+ if (contentType && contentType.includes("application/json")) {
+ data = await response.json();
+ } else {
+ const text = await response.text();
+ throw new Error(`Expected JSON but got ${contentType}. Body: ${text.substring(0, 100)}`);
+ }
if (response.ok) {
state.isAuthenticated = true;
@@ -578,14 +792,48 @@ logoutBtn.addEventListener('click', () => {
logout();
});
+document.querySelectorAll('.tab-btn').forEach(btn => {
+ btn.addEventListener('click', () => {
+ state.activeDashboardTab = btn.dataset.tab;
+ renderDashboardTabs();
+ });
+});
+
+function toggleMobileMenu() {
+ sidebarEl.classList.toggle('open');
+ menuToggle.classList.toggle('active');
+ sidebarOverlay.classList.toggle('hidden');
+ document.body.style.overflow = sidebarEl.classList.contains('open') ? 'hidden' : '';
+}
+
+function closeMobileMenu() {
+ sidebarEl.classList.remove('open');
+ menuToggle.classList.remove('active');
+ sidebarOverlay.classList.add('hidden');
+ document.body.style.overflow = '';
+}
+
+menuToggle.addEventListener('click', toggleMobileMenu);
+sidebarOverlay.addEventListener('click', closeMobileMenu);
+
async function initializeApp() {
const hasSession = await checkSession();
if (hasSession) {
appEl.classList.remove('hidden');
loginOverlay.classList.add('hidden');
+
+ // Handle deep links from notifications
+ const params = new URLSearchParams(window.location.search);
+ const taskId = params.get('taskId');
+ const runId = params.get('runId');
+ if (taskId) {
+ state.selectedTaskId = taskId;
+ state.selectedRunId = runId;
+ }
+
await fetchTasks();
- startAutoRefresh();
+ connectWebSocket();
} else {
showLogin();
}
@@ -597,3 +845,116 @@ if (window.location.pathname === '/callback' || window.location.search.includes(
} else {
initializeApp();
}
+
+// Register Service Worker for PWA
+if ('serviceWorker' in navigator) {
+ window.addEventListener('load', () => {
+ navigator.serviceWorker.register('/sw.js')
+ .then(reg => {
+ console.log('SW registered', reg);
+ state.swRegistration = reg;
+ })
+ .catch(err => {
+ console.error('SW registration failed:', err);
+ if (window.isSecureContext === false) {
+ console.error('Context is NOT secure. Service Workers require HTTPS or localhost.');
+ }
+ });
+ });
+}
+
+async function setupPush() {
+ if (!state.swRegistration) {
+ console.warn('SW registration not available');
+ return false;
+ }
+
+ try {
+ const vapidResponse = await fetch(`${API_URL}/notifications/vapid-key`);
+ const { publicKey } = await vapidResponse.json();
+
+ // Always clear existing subscription to ensure we use latest VAPID key
+ const existingSub = await state.swRegistration.pushManager.getSubscription();
+ if (existingSub) {
+ await existingSub.unsubscribe();
+ console.log('Unsubscribed existing push subscription');
+ }
+
+ const subscription = await state.swRegistration.pushManager.subscribe({
+ userVisibleOnly: true,
+ applicationServerKey: urlBase64ToUint8Array(publicKey)
+ });
+
+ await fetch(`${API_URL}/notifications/register`, {
+ method: 'POST',
+ headers: { 'Content-Type': 'application/json' },
+ body: JSON.stringify({
+ endpoint: subscription.endpoint,
+ p256dh: b64(subscription.getKey('p256dh')),
+ auth: b64(subscription.getKey('auth'))
+ })
+ });
+ console.log('Push registered');
+ return true;
+ } catch (err) {
+ console.warn('Push registration failed:', err);
+ return false;
+ }
+}
+
+function b64(buffer) {
+ const binary = String.fromCharCode.apply(null, new Uint8Array(buffer));
+ return btoa(binary)
+ .replace(/\+/g, '-')
+ .replace(/\//g, '_')
+ .replace(/=/g, '');
+}
+
+function urlBase64ToUint8Array(base64String) {
+ const padding = '='.repeat((4 - base64String.length % 4) % 4);
+ const base64 = (base64String + padding).replace(/\-/g, '+').replace(/_/g, '/');
+ const rawData = window.atob(base64);
+ const outputArray = new Uint8Array(rawData.length);
+ for (let i = 0; i < rawData.length; ++i) {
+ outputArray[i] = rawData.charCodeAt(i);
+ }
+ return outputArray;
+}
+
+async function toggleTaskSubscription(taskId) {
+ const btn = document.getElementById('notify-task-btn');
+ const isNotified = btn.classList.contains('notified');
+ const method = isNotified ? 'DELETE' : 'POST';
+
+ // If trying to enable but no push subscription, try setting it up first (user gesture here)
+ if (!isNotified && 'Notification' in window) {
+ if (Notification.permission !== 'granted') {
+ const permission = await Notification.requestPermission();
+ if (permission !== 'granted') {
+ showToast('Notification permission denied', 'error');
+ return;
+ }
+ }
+
+ const sub = await state.swRegistration.pushManager.getSubscription();
+ if (!sub) {
+ const success = await setupPush();
+ if (!success) {
+ showToast('Failed to initialize push notifications', 'error');
+ return;
+ }
+ }
+ }
+
+ try {
+ await fetch(`${API_URL}/tasks/${taskId}/subscribe`, { method });
+ btn.classList.toggle('notified');
+ showToast(isNotified ? 'Notifications disabled' : 'Notifications enabled');
+ } catch (err) {
+ showToast('Failed to update notifications');
+ }
+}
+
+document.getElementById('notify-task-btn').addEventListener('click', () => {
+ if (state.selectedTaskId) toggleTaskSubscription(state.selectedTaskId);
+});
diff --git a/frontend/src/style.css b/frontend/src/style.css
index 0761f29..c2c08b6 100644
--- a/frontend/src/style.css
+++ b/frontend/src/style.css
@@ -25,6 +25,7 @@ body {
color: var(--text-main);
line-height: 1.5;
height: 100vh;
+ height: 100dvh;
overflow: hidden;
}
@@ -88,9 +89,15 @@ body {
.dashboard-content {
flex: 1;
overflow-y: auto;
- border-radius: 12px;
+ border-radius: 16px;
display: flex;
flex-direction: column;
+ width: 100%;
+ max-width: 900px;
+ background: rgba(255, 255, 255, 0.02);
+ box-shadow: 0 10px 40px rgba(0, 0, 0, 0.3);
+ border: 1px solid var(--glass-border);
+ min-height: 0;
}
.activity-table {
@@ -124,6 +131,158 @@ body {
background: rgba(255, 255, 255, 0.03);
}
+.dashboard-content-grid {
+ display: flex;
+ flex-direction: column;
+ align-items: center;
+ gap: 32px;
+ flex: 1;
+ min-height: 0;
+ width: 100%;
+}
+
+.dashboard-tabs {
+ display: flex;
+ gap: 12px;
+ margin-top: 24px;
+}
+
+.tab-btn {
+ background: rgba(255, 255, 255, 0.03);
+ border: 1px solid var(--glass-border);
+ color: var(--text-dim);
+ padding: 10px 20px;
+ border-radius: 100px;
+ font-size: 14px;
+ font-weight: 600;
+ cursor: pointer;
+ transition: var(--transition);
+ display: flex;
+ align-items: center;
+ gap: 8px;
+}
+
+.tab-btn:hover {
+ background: rgba(255, 255, 255, 0.08);
+ color: var(--text-main);
+}
+
+.tab-btn.active {
+ background: var(--primary);
+ color: white;
+ border-color: var(--primary);
+ box-shadow: 0 4px 15px var(--primary-glow);
+}
+
+.tab-panel {
+ display: none;
+ width: 100%;
+ flex-direction: column;
+ align-items: center;
+ flex: 1;
+ min-height: 0;
+}
+
+.tab-panel.active {
+ display: flex;
+}
+
+.chat-container {
+ display: flex;
+ flex-direction: column;
+ border-radius: 16px;
+ overflow: hidden;
+ background: rgba(255, 255, 255, 0.02);
+ width: 100%;
+ max-width: 900px;
+ flex: 1;
+ min-height: 0;
+ box-shadow: 0 10px 40px rgba(0, 0, 0, 0.3);
+ border: 1px solid var(--glass-border);
+}
+
+.chat-header {
+ padding: 16px 20px;
+ background: rgba(255, 255, 255, 0.03);
+ border-bottom: 1px solid var(--glass-border);
+ display: flex;
+ justify-content: space-between;
+ align-items: center;
+}
+
+.chat-header h3 {
+ font-size: 14px;
+ font-weight: 600;
+ color: var(--text-dim);
+ text-transform: uppercase;
+ letter-spacing: 0.5px;
+}
+
+.chat-messages {
+ flex: 1;
+ padding: 20px;
+ overflow-y: auto;
+ display: flex;
+ flex-direction: column;
+ gap: 12px;
+}
+
+.chat-empty-state {
+ margin: auto;
+ text-align: center;
+ color: var(--text-dim);
+ font-style: italic;
+ font-size: 13px;
+ opacity: 0.6;
+}
+
+.chat-message {
+ max-width: 80%;
+ padding: 12px 18px;
+ border-radius: 16px;
+ font-size: 15px;
+ line-height: 1.5;
+ word-wrap: break-word;
+}
+
+.chat-message.user {
+ align-self: flex-end;
+ background: var(--primary);
+ color: white;
+ border-bottom-right-radius: 4px;
+}
+
+.chat-message.assistant {
+ align-self: flex-start;
+ background: rgba(255, 255, 255, 0.08);
+ color: var(--text-main);
+ border-bottom-left-radius: 4px;
+}
+
+.chat-form {
+ padding: 16px;
+ background: rgba(255, 255, 255, 0.02);
+ border-top: 1px solid var(--glass-border);
+ display: flex;
+ gap: 10px;
+}
+
+.chat-form input {
+ flex: 1;
+ background: rgba(0, 0, 0, 0.2);
+ border: 1px solid var(--glass-border);
+ border-radius: 12px;
+ padding: 12px 20px;
+ color: var(--text-main);
+ font-size: 15px;
+ outline: none;
+ transition: var(--transition);
+}
+
+.chat-form input:focus {
+ border-color: var(--primary);
+}
+
.activity-table .status-badge {
display: inline-block;
}
@@ -796,9 +955,9 @@ textarea:focus {
}
.btn-sm {
- padding: 6px 12px;
+ padding: 6px 16px;
font-size: 12px;
- width: 100%;
+ width: auto;
justify-content: center;
}
@@ -885,4 +1044,242 @@ textarea:focus {
.logout-btn:hover {
color: var(--primary);
+}
+
+/* Mobile Menu Toggle */
+.menu-toggle {
+ display: none;
+ position: fixed;
+ top: calc(16px + env(safe-area-inset-top));
+ right: calc(16px + env(safe-area-inset-right));
+ z-index: 1100;
+ background: var(--primary);
+ border: none;
+ width: 44px;
+ height: 44px;
+ border-radius: 10px;
+ cursor: pointer;
+ flex-direction: column;
+ justify-content: center;
+ align-items: center;
+ gap: 5px;
+ box-shadow: 0 4px 15px var(--primary-glow);
+ transition: var(--transition);
+}
+
+.menu-toggle .bar {
+ display: block;
+ width: 20px;
+ height: 2px;
+ background: white;
+ border-radius: 2px;
+ transition: var(--transition);
+}
+
+.menu-toggle.active .bar:nth-child(1) {
+ transform: translateY(7px) rotate(45deg);
+}
+
+.menu-toggle.active .bar:nth-child(2) {
+ opacity: 0;
+}
+
+.menu-toggle.active .bar:nth-child(3) {
+ transform: translateY(-7px) rotate(-45deg);
+}
+
+.sidebar-overlay {
+ position: fixed;
+ top: 0;
+ left: 0;
+ width: 100%;
+ height: 100%;
+ background: rgba(0, 0, 0, 0.5);
+ backdrop-filter: blur(4px);
+ z-index: 1000;
+ transition: opacity 0.3s ease;
+}
+
+/* Responsive Styles */
+#notify-task-btn.notified {
+ color: var(--primary);
+ background: var(--primary-glow);
+}
+
+#notify-task-btn.notified .notify-icon {
+ animation: ring 0.5s ease;
+}
+
+@keyframes ring {
+ 0% {
+ transform: rotate(0);
+ }
+
+ 25% {
+ transform: rotate(15deg);
+ }
+
+ 50% {
+ transform: rotate(-15deg);
+ }
+
+ 75% {
+ transform: rotate(10deg);
+ }
+
+ 100% {
+ transform: rotate(0);
+ }
+}
+
+@media (max-width: 768px) {
+ .menu-toggle {
+ display: flex;
+ }
+
+ .sidebar {
+ position: fixed;
+ left: -320px;
+ top: 0;
+ height: 100%;
+ z-index: 1050;
+ transition: left 0.3s cubic-bezier(0.4, 0, 0.2, 1);
+ box-shadow: 10px 0 30px rgba(0, 0, 0, 0.5);
+ padding-top: env(safe-area-inset-top);
+ padding-bottom: env(safe-area-inset-bottom);
+ }
+
+ .sidebar.open {
+ left: 0;
+ }
+
+ .dashboard-view,
+ .task-view {
+ padding: 20px;
+ padding-top: calc(80px + env(safe-area-inset-top));
+ padding-left: max(20px, env(safe-area-inset-left));
+ padding-right: max(20px, env(safe-area-inset-right));
+ padding-bottom: max(20px, env(safe-area-inset-bottom));
+ height: auto;
+ min-height: 100%;
+ overflow-y: auto;
+ overflow-x: hidden;
+ width: 100%;
+ max-width: 100vw;
+ }
+
+ .dashboard-header h2 {
+ font-size: 24px;
+ }
+
+ .task-content {
+ flex-direction: column;
+ height: auto;
+ overflow: visible;
+ width: 100%;
+ gap: 16px;
+ }
+
+ .run-history {
+ width: 100%;
+ max-height: 200px;
+ flex-shrink: 0;
+ margin-bottom: 8px;
+ }
+
+ .run-details {
+ flex-direction: column;
+ height: auto;
+ overflow: visible;
+ gap: 16px;
+ width: 100%;
+ }
+
+ .answer-container {
+ width: 100%;
+ margin-bottom: 8px;
+ border-left: none;
+ border-top: 4px solid var(--primary);
+ }
+
+ .logs-container {
+ width: 100%;
+ height: 400px;
+ flex-shrink: 0;
+ }
+
+ .view-header {
+ flex-direction: column;
+ align-items: flex-start;
+ gap: 16px;
+ }
+
+ .header-main {
+ flex-direction: column;
+ align-items: flex-start;
+ gap: 12px;
+ width: 100%;
+ }
+
+ .header-main h2 {
+ font-size: 20px;
+ line-height: 1.3;
+ }
+
+ .header-actions {
+ width: 100%;
+ display: flex;
+ flex-wrap: wrap;
+ gap: 8px;
+ }
+
+ .header-actions .btn {
+ flex: 1 1 auto;
+ justify-content: center;
+ }
+
+ .modal {
+ width: 95%;
+ padding: 20px;
+ max-height: 90%;
+ overflow-y: auto;
+ }
+
+ .preset-group {
+ grid-template-columns: 1fr;
+ }
+
+ .chat-container {
+ height: 500px;
+ }
+
+ .chat-form input,
+ textarea {
+ font-size: 16px !important;
+ }
+
+ /* Force word break for long text in containers */
+ .answer-output,
+ .activity-table td {
+ word-break: break-word;
+ }
+
+ .activity-table td {
+ padding: 12px 10px;
+ }
+
+ /* Hide Date on very small mobile to prevent table overflow */
+ @media (max-width: 480px) {
+
+ .activity-table th:last-child,
+ .activity-table td:last-child {
+ display: none;
+ }
+ }
+
+ /* Prevent horizontal scroll on the entire app */
+ #app {
+ width: 100vw;
+ overflow-x: hidden;
+ }
}
\ No newline at end of file
diff --git a/frontend/vite.config.js b/frontend/vite.config.js
index 7ce721b..a06ef36 100644
--- a/frontend/vite.config.js
+++ b/frontend/vite.config.js
@@ -4,8 +4,9 @@ export default defineConfig({
server: {
proxy: {
'/api': {
- target: 'http://localhost:3000',
+ target: 'http://localhost:3001',
changeOrigin: true,
+ ws: true,
}
}
}
diff --git a/migration/src/lib.rs b/migration/src/lib.rs
index e206140..cad08e0 100644
--- a/migration/src/lib.rs
+++ b/migration/src/lib.rs
@@ -4,6 +4,7 @@ mod m20220101_000001_create_table;
mod m20260210_000002_add_answer_column;
mod m20260210_000003_separate_runs;
mod m20260210_000004_add_cron_column;
+mod m20260212_000005_notifications;
pub struct Migrator;
@@ -15,6 +16,7 @@ impl MigratorTrait for Migrator {
Box::new(m20260210_000002_add_answer_column::Migration),
Box::new(m20260210_000003_separate_runs::Migration),
Box::new(m20260210_000004_add_cron_column::Migration),
+ Box::new(m20260212_000005_notifications::Migration),
]
}
}
diff --git a/migration/src/m20260212_000005_notifications.rs b/migration/src/m20260212_000005_notifications.rs
new file mode 100644
index 0000000..fdfdaac
--- /dev/null
+++ b/migration/src/m20260212_000005_notifications.rs
@@ -0,0 +1,115 @@
+use sea_orm_migration::prelude::*;
+
+#[derive(DeriveMigrationName)]
+pub struct Migration;
+
+#[async_trait::async_trait]
+impl MigrationTrait for Migration {
+ async fn up(&self, manager: &SchemaManager) -> Result<(), DbErr> {
+ // Push Subscriptions table
+ manager
+ .create_table(
+ Table::create()
+ .table(PushSubscriptions::Table)
+ .if_not_exists()
+ .col(
+ ColumnDef::new(PushSubscriptions::Id)
+ .uuid()
+ .not_null()
+ .primary_key(),
+ )
+ .col(
+ ColumnDef::new(PushSubscriptions::UserSub)
+ .string()
+ .not_null(),
+ )
+ .col(
+ ColumnDef::new(PushSubscriptions::Endpoint)
+ .string()
+ .not_null(),
+ )
+ .col(
+ ColumnDef::new(PushSubscriptions::P256dh)
+ .string()
+ .not_null(),
+ )
+ .col(ColumnDef::new(PushSubscriptions::Auth).string().not_null())
+ .col(
+ ColumnDef::new(PushSubscriptions::CreatedAt)
+ .timestamp_with_time_zone()
+ .not_null(),
+ )
+ .to_owned(),
+ )
+ .await?;
+
+ // Task Subscriptions table
+ manager
+ .create_table(
+ Table::create()
+ .table(TaskSubscriptions::Table)
+ .if_not_exists()
+ .col(
+ ColumnDef::new(TaskSubscriptions::Id)
+ .uuid()
+ .not_null()
+ .primary_key(),
+ )
+ .col(
+ ColumnDef::new(TaskSubscriptions::UserSub)
+ .string()
+ .not_null(),
+ )
+ .col(ColumnDef::new(TaskSubscriptions::TaskId).uuid().not_null())
+ .col(
+ ColumnDef::new(TaskSubscriptions::CreatedAt)
+ .timestamp_with_time_zone()
+ .not_null(),
+ )
+ .foreign_key(
+ ForeignKey::create()
+ .name("fk-task-subscription-task-id")
+ .from(TaskSubscriptions::Table, TaskSubscriptions::TaskId)
+ .to(Tasks::Table, Tasks::Id)
+ .on_delete(ForeignKeyAction::Cascade),
+ )
+ .to_owned(),
+ )
+ .await
+ }
+
+ async fn down(&self, manager: &SchemaManager) -> Result<(), DbErr> {
+ manager
+ .drop_table(Table::drop().table(TaskSubscriptions::Table).to_owned())
+ .await?;
+ manager
+ .drop_table(Table::drop().table(PushSubscriptions::Table).to_owned())
+ .await
+ }
+}
+
+#[derive(DeriveIden)]
+enum PushSubscriptions {
+ Table,
+ Id,
+ UserSub,
+ Endpoint,
+ P256dh,
+ Auth,
+ CreatedAt,
+}
+
+#[derive(DeriveIden)]
+enum TaskSubscriptions {
+ Table,
+ Id,
+ UserSub,
+ TaskId,
+ CreatedAt,
+}
+
+#[derive(DeriveIden)]
+enum Tasks {
+ Table,
+ Id,
+}
diff --git a/openapi/calendar/openapi.json b/openapi/calendar/openapi.json
new file mode 100644
index 0000000..8c8908c
--- /dev/null
+++ b/openapi/calendar/openapi.json
@@ -0,0 +1,593 @@
+{
+ "openapi": "3.1.0",
+ "info": {
+ "title": "calendar",
+ "description": "",
+ "license": {
+ "name": ""
+ },
+ "version": "0.1.0"
+ },
+ "paths": {
+ "/auth/me": {
+ "get": {
+ "tags": [
+ "crate::handlers::auth"
+ ],
+ "operationId": "me",
+ "responses": {
+ "200": {
+ "description": "Current user profile",
+ "content": {
+ "application/json": {
+ "schema": {
+ "$ref": "#/components/schemas/CurrentUser"
+ }
+ }
+ }
+ },
+ "401": {
+ "description": "Unauthorized"
+ }
+ },
+ "security": [
+ {
+ "oidc": []
+ }
+ ]
+ }
+ },
+ "/events": {
+ "get": {
+ "tags": [
+ "crate::handlers::event"
+ ],
+ "operationId": "list_events",
+ "parameters": [
+ {
+ "name": "upcoming",
+ "in": "query",
+ "required": false,
+ "schema": {
+ "type": [
+ "boolean",
+ "null"
+ ]
+ }
+ }
+ ],
+ "responses": {
+ "200": {
+ "description": "List of events",
+ "content": {
+ "application/json": {
+ "schema": {
+ "type": "array",
+ "items": {
+ "$ref": "#/components/schemas/Model"
+ }
+ }
+ }
+ }
+ },
+ "401": {
+ "description": "Unauthorized"
+ }
+ },
+ "security": [
+ {
+ "oidc": []
+ }
+ ]
+ },
+ "post": {
+ "tags": [
+ "crate::handlers::event"
+ ],
+ "operationId": "create_event",
+ "requestBody": {
+ "content": {
+ "application/json": {
+ "schema": {
+ "$ref": "#/components/schemas/CreateEventRequest"
+ }
+ }
+ },
+ "required": true
+ },
+ "responses": {
+ "200": {
+ "description": "Event created successfully",
+ "content": {
+ "application/json": {
+ "schema": {
+ "$ref": "#/components/schemas/Model"
+ }
+ }
+ }
+ },
+ "400": {
+ "description": "Invalid request payload"
+ },
+ "401": {
+ "description": "Unauthorized"
+ }
+ },
+ "security": [
+ {
+ "oidc": []
+ }
+ ]
+ }
+ },
+ "/events/{id}": {
+ "get": {
+ "tags": [
+ "crate::handlers::event"
+ ],
+ "operationId": "get_event",
+ "parameters": [
+ {
+ "name": "id",
+ "in": "path",
+ "description": "Event database id",
+ "required": true,
+ "schema": {
+ "type": "integer",
+ "format": "int32"
+ }
+ }
+ ],
+ "responses": {
+ "200": {
+ "description": "Event details",
+ "content": {
+ "application/json": {
+ "schema": {
+ "$ref": "#/components/schemas/Model"
+ }
+ }
+ }
+ },
+ "401": {
+ "description": "Unauthorized"
+ },
+ "404": {
+ "description": "Event not found"
+ }
+ },
+ "security": [
+ {
+ "oidc": []
+ }
+ ]
+ },
+ "put": {
+ "tags": [
+ "crate::handlers::event"
+ ],
+ "operationId": "update_event",
+ "parameters": [
+ {
+ "name": "id",
+ "in": "path",
+ "description": "Event database id",
+ "required": true,
+ "schema": {
+ "type": "integer",
+ "format": "int32"
+ }
+ }
+ ],
+ "requestBody": {
+ "content": {
+ "application/json": {
+ "schema": {
+ "$ref": "#/components/schemas/CreateEventRequest"
+ }
+ }
+ },
+ "required": true
+ },
+ "responses": {
+ "200": {
+ "description": "Event updated successfully",
+ "content": {
+ "application/json": {
+ "schema": {
+ "$ref": "#/components/schemas/Model"
+ }
+ }
+ }
+ },
+ "400": {
+ "description": "Invalid request payload"
+ },
+ "401": {
+ "description": "Unauthorized"
+ },
+ "404": {
+ "description": "Event not found"
+ }
+ },
+ "security": [
+ {
+ "oidc": []
+ }
+ ]
+ },
+ "delete": {
+ "tags": [
+ "crate::handlers::event"
+ ],
+ "operationId": "delete_event",
+ "parameters": [
+ {
+ "name": "id",
+ "in": "path",
+ "description": "Event database id",
+ "required": true,
+ "schema": {
+ "type": "integer",
+ "format": "int32"
+ }
+ }
+ ],
+ "responses": {
+ "204": {
+ "description": "Event deleted successfully"
+ },
+ "401": {
+ "description": "Unauthorized"
+ },
+ "404": {
+ "description": "Event not found"
+ }
+ },
+ "security": [
+ {
+ "oidc": []
+ }
+ ]
+ }
+ },
+ "/service/v1/events": {
+ "get": {
+ "tags": [
+ "crate::handlers::service"
+ ],
+ "operationId": "service_list_events",
+ "parameters": [
+ {
+ "name": "user_id",
+ "in": "query",
+ "required": false,
+ "schema": {
+ "type": [
+ "integer",
+ "null"
+ ],
+ "format": "int32"
+ }
+ },
+ {
+ "name": "upcoming",
+ "in": "query",
+ "required": false,
+ "schema": {
+ "type": [
+ "boolean",
+ "null"
+ ]
+ }
+ }
+ ],
+ "responses": {
+ "200": {
+ "description": "List of events",
+ "content": {
+ "application/json": {
+ "schema": {
+ "type": "array",
+ "items": {
+ "$ref": "#/components/schemas/Model"
+ }
+ }
+ }
+ }
+ },
+ "401": {
+ "description": "Unauthorized"
+ }
+ },
+ "security": [
+ {
+ "oidc": []
+ }
+ ]
+ },
+ "post": {
+ "tags": [
+ "crate::handlers::service"
+ ],
+ "operationId": "service_create_event",
+ "requestBody": {
+ "content": {
+ "application/json": {
+ "schema": {
+ "$ref": "#/components/schemas/ServiceCreateEventRequest"
+ }
+ }
+ },
+ "required": true
+ },
+ "responses": {
+ "200": {
+ "description": "Event created successfully",
+ "content": {
+ "application/json": {
+ "schema": {
+ "$ref": "#/components/schemas/Model"
+ }
+ }
+ }
+ },
+ "400": {
+ "description": "Invalid request payload"
+ },
+ "401": {
+ "description": "Unauthorized"
+ }
+ },
+ "security": [
+ {
+ "oidc": []
+ }
+ ]
+ }
+ },
+ "/service/v1/events/{id}": {
+ "get": {
+ "tags": [
+ "crate::handlers::service"
+ ],
+ "operationId": "service_get_event",
+ "parameters": [
+ {
+ "name": "id",
+ "in": "path",
+ "description": "Event database id",
+ "required": true,
+ "schema": {
+ "type": "integer",
+ "format": "int32"
+ }
+ }
+ ],
+ "responses": {
+ "200": {
+ "description": "Event details",
+ "content": {
+ "application/json": {
+ "schema": {
+ "$ref": "#/components/schemas/Model"
+ }
+ }
+ }
+ },
+ "401": {
+ "description": "Unauthorized"
+ },
+ "404": {
+ "description": "Event not found"
+ }
+ },
+ "security": [
+ {
+ "oidc": []
+ }
+ ]
+ },
+ "put": {
+ "tags": [
+ "crate::handlers::service"
+ ],
+ "operationId": "service_update_event",
+ "parameters": [
+ {
+ "name": "id",
+ "in": "path",
+ "description": "Event database id",
+ "required": true,
+ "schema": {
+ "type": "integer",
+ "format": "int32"
+ }
+ }
+ ],
+ "requestBody": {
+ "content": {
+ "application/json": {
+ "schema": {
+ "$ref": "#/components/schemas/ServiceCreateEventRequest"
+ }
+ }
+ },
+ "required": true
+ },
+ "responses": {
+ "200": {
+ "description": "Event updated successfully",
+ "content": {
+ "application/json": {
+ "schema": {
+ "$ref": "#/components/schemas/Model"
+ }
+ }
+ }
+ },
+ "400": {
+ "description": "Invalid request payload"
+ },
+ "401": {
+ "description": "Unauthorized"
+ },
+ "404": {
+ "description": "Event not found"
+ }
+ },
+ "security": [
+ {
+ "oidc": []
+ }
+ ]
+ },
+ "delete": {
+ "tags": [
+ "crate::handlers::service"
+ ],
+ "operationId": "service_delete_event",
+ "parameters": [
+ {
+ "name": "id",
+ "in": "path",
+ "description": "Event database id",
+ "required": true,
+ "schema": {
+ "type": "integer",
+ "format": "int32"
+ }
+ }
+ ],
+ "responses": {
+ "204": {
+ "description": "Event deleted successfully"
+ },
+ "401": {
+ "description": "Unauthorized"
+ },
+ "404": {
+ "description": "Event not found"
+ }
+ },
+ "security": [
+ {
+ "oidc": []
+ }
+ ]
+ }
+ }
+ },
+ "components": {
+ "schemas": {
+ "CreateEventRequest": {
+ "type": "object",
+ "required": [
+ "name",
+ "from",
+ "to"
+ ],
+ "properties": {
+ "from": {
+ "type": "string"
+ },
+ "name": {
+ "type": "string"
+ },
+ "to": {
+ "type": "string"
+ }
+ }
+ },
+ "CurrentUser": {
+ "type": "object",
+ "required": [
+ "id",
+ "sub",
+ "email",
+ "name"
+ ],
+ "properties": {
+ "email": {
+ "type": "string"
+ },
+ "id": {
+ "type": "integer",
+ "format": "int32"
+ },
+ "name": {
+ "type": "string"
+ },
+ "sub": {
+ "type": "string"
+ }
+ }
+ },
+ "Model": {
+ "type": "object",
+ "required": [
+ "id",
+ "name",
+ "from",
+ "to"
+ ],
+ "properties": {
+ "from": {
+ "type": "string",
+ "format": "date-time"
+ },
+ "id": {
+ "type": "integer",
+ "format": "int64"
+ },
+ "name": {
+ "type": "string"
+ },
+ "to": {
+ "type": "string",
+ "format": "date-time"
+ },
+ "user_id": {
+ "type": [
+ "integer",
+ "null"
+ ],
+ "format": "int32"
+ }
+ }
+ },
+ "ServiceCreateEventRequest": {
+ "type": "object",
+ "required": [
+ "name",
+ "from",
+ "to"
+ ],
+ "properties": {
+ "from": {
+ "type": "string"
+ },
+ "name": {
+ "type": "string"
+ },
+ "to": {
+ "type": "string"
+ },
+ "user_id": {
+ "type": [
+ "integer",
+ "null"
+ ],
+ "format": "int32"
+ }
+ }
+ }
+ }
+ },
+ "tags": [
+ {
+ "name": "calendar",
+ "description": "Calendar Management API"
+ }
+ ]
+}
\ No newline at end of file
diff --git a/src/config.rs b/src/config.rs
index c7a714e..b81a727 100644
--- a/src/config.rs
+++ b/src/config.rs
@@ -14,6 +14,8 @@ pub struct Config {
pub cookie_secure: bool,
pub agent_max_turns: u32,
pub agent_max_duration_secs: u64,
+ pub vapid_private_key: String,
+ pub calendar_api_url: String,
}
impl Config {
@@ -54,6 +56,12 @@ impl Config {
.and_then(|s| s.parse().ok())
.unwrap_or(120);
+ let vapid_private_key = env::var("VAPID_PRIVATE_KEY")
+ .map_err(|_| AppError::Config("VAPID_PRIVATE_KEY must be set".into()))?;
+
+ let calendar_api_url =
+ env::var("CALENDAR_API_URL").unwrap_or_else(|_| "http://localhost:8000".to_string());
+
Ok(Config {
database_url,
port,
@@ -66,6 +74,8 @@ impl Config {
cookie_secure,
agent_max_turns,
agent_max_duration_secs,
+ vapid_private_key,
+ calendar_api_url,
})
}
}
diff --git a/src/domain/agent/api.rs b/src/domain/agent/api.rs
index 2d2ae37..cbd93a8 100644
--- a/src/domain/agent/api.rs
+++ b/src/domain/agent/api.rs
@@ -3,7 +3,6 @@ use serde::{Deserialize, Serialize};
#[derive(Serialize, Deserialize, Debug, Clone)]
pub struct Message {
pub role: String,
- #[serde(skip_serializing_if = "Option::is_none")]
pub content: Option