feat: incident.io connector

client/src/app/api/connected-accounts/[provider]/route.ts

@@ -24,7 +24,7 @@ export async function DELETE(
     const { provider } = await context.params
 
     // Validate provider
-    if (!['gcp', 'azure', 'aws', 'github', 'grafana', 'datadog', 'netdata', 'ovh', 'scaleway', 'tailscale', 'slack', 'google_chat', 'splunk', 'dynatrace', 'confluence', 'jira', 'sharepoint', 'coroot', 'thousandeyes', 'jenkins', 'cloudbees', 'bigpanda', 'spinnaker', 'newrelic', 'opsgenie'].includes(provider)) {
+    if (!['gcp', 'azure', 'aws', 'github', 'grafana', 'datadog', 'netdata', 'ovh', 'scaleway', 'tailscale', 'slack', 'google_chat', 'splunk', 'dynatrace', 'confluence', 'jira', 'sharepoint', 'coroot', 'thousandeyes', 'jenkins', 'cloudbees', 'bigpanda', 'spinnaker', 'newrelic', 'opsgenie', 'incidentio'].includes(provider)) {
       return NextResponse.json(
         { error: 'Invalid provider' },
         { status: 400 }
@@ -442,6 +442,26 @@ export async function DELETE(
       return NextResponse.json({ success: true })
     }
 
+    // Special handling for incident.io
+    if (provider === 'incidentio') {
+      const response = await fetch(`${API_BASE_URL}/incidentio/disconnect`, {
+        method: 'DELETE',
+        headers: authHeaders,
+      })
+
+      if (!response.ok) {
+        const errorText = await response.text()
+        console.error('Backend error disconnecting incident.io:', errorText)
+        return NextResponse.json(
+          { error: 'Failed to disconnect incident.io' },
+          { status: response.status }
+        )
+      }
+
+      const data = await response.json()
+      return NextResponse.json(data)
+    }
+
     // Special handling for BigPanda
     if (provider === 'bigpanda') {
       const response = await fetch(`${API_BASE_URL}/bigpanda/disconnect`, {

client/src/app/api/incident-io/alerts/route.ts

@@ -0,0 +1,54 @@
+import { NextRequest, NextResponse } from 'next/server';
+import { getAuthenticatedUser } from '@/lib/auth-helper';
+
+const API_BASE_URL = process.env.BACKEND_URL;
+const FETCH_TIMEOUT_MS = 15000;
+
+export async function GET(request: NextRequest) {
+  try {
+    const authResult = await getAuthenticatedUser();
+
+    if (authResult instanceof NextResponse) {
+      return authResult;
+    }
+
+    const { headers: authHeaders } = authResult;
+    const { searchParams } = new URL(request.url);
+    const limit = searchParams.get('limit') || '50';
+    const offset = searchParams.get('offset') || '0';
+    const severity = searchParams.get('severity');
+
+    const params = new URLSearchParams({ limit, offset });
+    if (severity) params.append('severity', severity);
+
+    const controller = new AbortController();
+    const timeoutId = setTimeout(() => controller.abort(), FETCH_TIMEOUT_MS);
+
+    let response: Response;
+    try {
+      response = await fetch(`${API_BASE_URL}/incidentio/alerts?${params}`, {
+        method: 'GET',
+        headers: authHeaders,
+        credentials: 'include',
+        signal: controller.signal,
+      });
+    } finally {
+      clearTimeout(timeoutId);
+    }
+
+    if (!response.ok) {
+      const text = await response.text();
+      console.error('[api/incident-io/alerts] Backend error:', text);
+      return NextResponse.json({ error: 'Failed to get incidents' }, { status: response.status });
+    }
+
+    const data = await response.json();
+    return NextResponse.json(data);
+  } catch (error) {
+    if (error instanceof Error && error.name === 'AbortError') {
+      return NextResponse.json({ error: 'Request timeout' }, { status: 504 });
+    }
+    console.error('[api/incident-io/alerts] Error:', error instanceof Error ? error.message : 'Unknown error');
+    return NextResponse.json({ error: 'Failed to get incidents' }, { status: 500 });
+  }
+}

client/src/app/api/incident-io/alerts/webhook-url/route.ts

@@ -0,0 +1,47 @@
+import { NextResponse } from 'next/server';
+import { getAuthenticatedUser } from '@/lib/auth-helper';
+
+const API_BASE_URL = process.env.BACKEND_URL;
+const FETCH_TIMEOUT_MS = 15000;
+
+export async function GET() {
+  try {
+    const authResult = await getAuthenticatedUser();
+
+    if (authResult instanceof NextResponse) {
+      return authResult;
+    }
+
+    const { headers: authHeaders } = authResult;
+
+    const controller = new AbortController();
+    const timeoutId = setTimeout(() => controller.abort(), FETCH_TIMEOUT_MS);
+
+    let response: Response;
+    try {
+      response = await fetch(`${API_BASE_URL}/incidentio/alerts/webhook-url`, {
+        method: 'GET',
+        headers: authHeaders,
+        credentials: 'include',
+        signal: controller.signal,
+      });
+    } finally {
+      clearTimeout(timeoutId);
+    }
+
+    if (!response.ok) {
+      const text = await response.text();
+      console.error('[api/incident-io/alerts/webhook-url] Backend error:', text);
+      return NextResponse.json({ error: 'Failed to get webhook URL' }, { status: response.status });
+    }
+
+    const data = await response.json();
+    return NextResponse.json(data);
+  } catch (error) {
+    if (error instanceof Error && error.name === 'AbortError') {
+      return NextResponse.json({ error: 'Request timeout' }, { status: 504 });
+    }
+    console.error('[api/incident-io/alerts/webhook-url] Error:', error instanceof Error ? error.message : 'Unknown error');
+    return NextResponse.json({ error: 'Failed to get webhook URL' }, { status: 500 });
+  }
+}

client/src/app/api/incident-io/connect/route.ts

@@ -0,0 +1,52 @@
+import { NextRequest, NextResponse } from 'next/server';
+import { getAuthenticatedUser } from '@/lib/auth-helper';
+
+const API_BASE_URL = process.env.BACKEND_URL;
+const FETCH_TIMEOUT_MS = 15000;
+
+export async function POST(request: NextRequest) {
+  try {
+    const authResult = await getAuthenticatedUser();
+
+    if (authResult instanceof NextResponse) {
+      return authResult;
+    }
+
+    const { headers: authHeaders } = authResult;
+    const payload = await request.json();
+
+    const controller = new AbortController();
+    const timeoutId = setTimeout(() => controller.abort(), FETCH_TIMEOUT_MS);
+
+    let response: Response;
+    try {
+      response = await fetch(`${API_BASE_URL}/incidentio/connect`, {
+        method: 'POST',
+        headers: {
+          ...authHeaders,
+          'Content-Type': 'application/json',
+        },
+        body: JSON.stringify(payload),
+        credentials: 'include',
+        signal: controller.signal,
+      });
+    } finally {
+      clearTimeout(timeoutId);
+    }
+
+    if (!response.ok) {
+      const text = await response.text();
+      console.error('[api/incident-io/connect] Backend error:', text);
+      return NextResponse.json({ error: 'Failed to connect to incident.io' }, { status: response.status });
+    }
+
+    const data = await response.json();
+    return NextResponse.json(data);
+  } catch (error) {
+    if (error instanceof Error && error.name === 'AbortError') {
+      return NextResponse.json({ error: 'Connection timeout' }, { status: 504 });
+    }
+    console.error('[api/incident-io/connect] Error:', error instanceof Error ? error.message : 'Unknown error');
+    return NextResponse.json({ error: 'Failed to connect to incident.io' }, { status: 500 });
+  }
+}

client/src/app/api/incident-io/rca-settings/route.ts

@@ -0,0 +1,94 @@
+import { NextResponse } from 'next/server';
+import { getAuthenticatedUser } from '@/lib/auth-helper';
+
+const API_BASE_URL = process.env.BACKEND_URL;
+const FETCH_TIMEOUT_MS = 15000;
+
+export async function GET() {
+  try {
+    const authResult = await getAuthenticatedUser();
+
+    if (authResult instanceof NextResponse) {
+      return authResult;
+    }
+
+    const { headers: authHeaders } = authResult;
+
+    const controller = new AbortController();
+    const timeoutId = setTimeout(() => controller.abort(), FETCH_TIMEOUT_MS);
+
+    let response: Response;
+    try {
+      response = await fetch(`${API_BASE_URL}/incidentio/rca-settings`, {
+        method: 'GET',
+        headers: authHeaders,
+        credentials: 'include',
+        signal: controller.signal,
+      });
+    } finally {
+      clearTimeout(timeoutId);
+    }
+
+    if (!response.ok) {
+      const text = await response.text();
+      console.error('[api/incident-io/rca-settings] Backend error:', text);
+      return NextResponse.json({ error: 'Failed to get RCA settings' }, { status: response.status });
+    }
+
+    const data = await response.json();
+    return NextResponse.json(data);
+  } catch (error) {
+    if (error instanceof Error && error.name === 'AbortError') {
+      return NextResponse.json({ error: 'Request timeout' }, { status: 504 });
+    }
+    console.error('[api/incident-io/rca-settings] Error:', error instanceof Error ? error.message : 'Unknown error');
+    return NextResponse.json({ error: 'Failed to get RCA settings' }, { status: 500 });
+  }
+}
+
+export async function PUT(request: Request) {
+  try {
+    const authResult = await getAuthenticatedUser();
+
+    if (authResult instanceof NextResponse) {
+      return authResult;
+    }
+
+    const { headers: authHeaders } = authResult;
+    const body = await request.json();
+
+    const controller = new AbortController();
+    const timeoutId = setTimeout(() => controller.abort(), FETCH_TIMEOUT_MS);
+
+    let response: Response;
+    try {
+      response = await fetch(`${API_BASE_URL}/incidentio/rca-settings`, {
+        method: 'PUT',
+        headers: {
+          ...authHeaders,
+          'Content-Type': 'application/json',
+        },
+        credentials: 'include',
+        body: JSON.stringify(body),
+        signal: controller.signal,
+      });
+    } finally {
+      clearTimeout(timeoutId);
+    }
+
+    if (!response.ok) {
+      const text = await response.text();
+      console.error('[api/incident-io/rca-settings] Backend error:', text);
+      return NextResponse.json({ error: 'Failed to update RCA settings' }, { status: response.status });
+    }
+
+    const data = await response.json();
+    return NextResponse.json(data);
+  } catch (error) {
+    if (error instanceof Error && error.name === 'AbortError') {
+      return NextResponse.json({ error: 'Request timeout' }, { status: 504 });
+    }
+    console.error('[api/incident-io/rca-settings] Error:', error instanceof Error ? error.message : 'Unknown error');
+    return NextResponse.json({ error: 'Failed to update RCA settings' }, { status: 500 });
+  }
+}

client/src/app/api/incident-io/status/route.ts

@@ -0,0 +1,47 @@
+import { NextResponse } from 'next/server';
+import { getAuthenticatedUser } from '@/lib/auth-helper';
+
+const API_BASE_URL = process.env.BACKEND_URL;
+const FETCH_TIMEOUT_MS = 15000;
+
+export async function GET() {
+  try {
+    const authResult = await getAuthenticatedUser();
+
+    if (authResult instanceof NextResponse) {
+      return authResult;
+    }
+
+    const { headers: authHeaders } = authResult;
+
+    const controller = new AbortController();
+    const timeoutId = setTimeout(() => controller.abort(), FETCH_TIMEOUT_MS);
+
+    let response: Response;
+    try {
+      response = await fetch(`${API_BASE_URL}/incidentio/status`, {
+        method: 'GET',
+        headers: authHeaders,
+        credentials: 'include',
+        signal: controller.signal,
+      });
+    } finally {
+      clearTimeout(timeoutId);
+    }
+
+    if (!response.ok) {
+      const text = await response.text();
+      console.error('[api/incident-io/status] Backend error:', text);
+      return NextResponse.json({ error: 'Failed to get incident.io status' }, { status: response.status });
+    }
+
+    const data = await response.json();
+    return NextResponse.json(data);
+  } catch (error) {
+    if (error instanceof Error && error.name === 'AbortError') {
+      return NextResponse.json({ error: 'Request timeout' }, { status: 504 });
+    }
+    console.error('[api/incident-io/status] Error:', error instanceof Error ? error.message : 'Unknown error');
+    return NextResponse.json({ error: 'Failed to get incident.io status' }, { status: 500 });
+  }
+}