Compare commits
3 Commits
dev
...
dev-nomock
| Author | SHA1 | Date | |
|---|---|---|---|
| 6ecc158268 | |||
| 864640a15e | |||
| 9b1eaf168f |
Generated
+5062
File diff suppressed because it is too large
Load Diff
@@ -26,6 +26,9 @@ return(
|
|||||||
<button onClick={() => navigate('/servers')} className="nav-link">
|
<button onClick={() => navigate('/servers')} className="nav-link">
|
||||||
Servers
|
Servers
|
||||||
</button>
|
</button>
|
||||||
|
<button onClick={() => navigate('/recipes')} className="nav-link">
|
||||||
|
Recipes
|
||||||
|
</button>
|
||||||
</nav>
|
</nav>
|
||||||
</div>
|
</div>
|
||||||
</header>
|
</header>
|
||||||
|
|||||||
@@ -10,26 +10,25 @@ interface TerminalProps {
|
|||||||
|
|
||||||
export const Terminal: React.FC<TerminalProps> = ({ logs, isActive, onClose }) => {
|
export const Terminal: React.FC<TerminalProps> = ({ logs, isActive, onClose }) => {
|
||||||
const terminalRef = useRef<HTMLDivElement>(null);
|
const terminalRef = useRef<HTMLDivElement>(null);
|
||||||
|
const indexRef = useRef(0);
|
||||||
const [displayedLogs, setDisplayedLogs] = useState<LogEntry[]>([]);
|
const [displayedLogs, setDisplayedLogs] = useState<LogEntry[]>([]);
|
||||||
|
|
||||||
// Stream logs in with delays for realistic effect
|
// Stream logs in with delays for realistic effect
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
if (!isActive || logs.length === 0) {
|
if (!isActive || logs.length === 0) {
|
||||||
|
indexRef.current = 0;
|
||||||
setDisplayedLogs([]);
|
setDisplayedLogs([]);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
setDisplayedLogs([]);
|
|
||||||
let currentIndex = 0;
|
|
||||||
|
|
||||||
const streamLogs = () => {
|
const streamLogs = () => {
|
||||||
if (currentIndex < logs.length) {
|
if (indexRef.current < logs.length) {
|
||||||
setDisplayedLogs(prev => [...prev, logs[currentIndex]]);
|
setDisplayedLogs(prev => [...prev, logs[indexRef.current]]);
|
||||||
currentIndex++;
|
indexRef.current++;
|
||||||
|
|
||||||
// Variable delay based on log type
|
// Variable delay based on log type
|
||||||
const delay = logs[currentIndex - 1]?.type === 'command' ? 200 :
|
const delay = logs[indexRef.current - 1]?.type === 'command' ? 200 :
|
||||||
logs[currentIndex - 1]?.type === 'output' ? 100 : 300;
|
logs[indexRef.current - 1]?.type === 'output' ? 100 : 300;
|
||||||
|
|
||||||
setTimeout(streamLogs, delay);
|
setTimeout(streamLogs, delay);
|
||||||
}
|
}
|
||||||
@@ -37,7 +36,6 @@ export const Terminal: React.FC<TerminalProps> = ({ logs, isActive, onClose }) =
|
|||||||
|
|
||||||
streamLogs();
|
streamLogs();
|
||||||
}, [logs, isActive]);
|
}, [logs, isActive]);
|
||||||
|
|
||||||
// Auto-scroll to bottom
|
// Auto-scroll to bottom
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
if (terminalRef.current) {
|
if (terminalRef.current) {
|
||||||
@@ -73,7 +71,6 @@ export const Terminal: React.FC<TerminalProps> = ({ logs, isActive, onClose }) =
|
|||||||
<div className="terminal-content" ref={terminalRef}>
|
<div className="terminal-content" ref={terminalRef}>
|
||||||
{displayedLogs.filter(log => log && log.type).map((log, index) => (
|
{displayedLogs.filter(log => log && log.type).map((log, index) => (
|
||||||
<div key={index} className={`terminal-line terminal-${log.type}`}>
|
<div key={index} className={`terminal-line terminal-${log.type}`}>
|
||||||
<span className="terminal-timestamp">[{formatTime(log.timestamp)}]</span>
|
|
||||||
<span className="terminal-text">{log.text}</span>
|
<span className="terminal-text">{log.text}</span>
|
||||||
</div>
|
</div>
|
||||||
))}
|
))}
|
||||||
|
|||||||
@@ -77,7 +77,12 @@
|
|||||||
border-color: $primary-light;
|
border-color: $primary-light;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
&.service {
|
||||||
|
&:hover:not(:disabled) {
|
||||||
|
background: #3fff5c9d;
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
&.secondary {
|
&.secondary {
|
||||||
background: $bg-secondary;
|
background: $bg-secondary;
|
||||||
color: $text-primary;
|
color: $text-primary;
|
||||||
@@ -132,6 +137,49 @@
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// service grid
|
||||||
|
.service-grid {
|
||||||
|
display: grid;
|
||||||
|
grid-template-columns: repeat(auto-fill, minmax(200px, 2fr));
|
||||||
|
gap: $spacing-md;
|
||||||
|
}
|
||||||
|
|
||||||
|
.service-card {
|
||||||
|
@include card;
|
||||||
|
transition: transform $transition-base, box-shadow $transition-base;
|
||||||
|
position: relative;
|
||||||
|
overflow: hidden;
|
||||||
|
padding: $spacing-md;
|
||||||
|
.service-name {
|
||||||
|
h3 {
|
||||||
|
font-size: $font-size-lg;
|
||||||
|
color: $text-primary;
|
||||||
|
font-weight: $font-weight-bold;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
.service-row {
|
||||||
|
flex-grow: 1;
|
||||||
|
flex: 1;
|
||||||
|
|
||||||
|
.service-value {
|
||||||
|
font-size: $font-size-sm;
|
||||||
|
display: -webkit-box;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
&.dark-green {
|
||||||
|
background-color: #3fff5c;
|
||||||
|
}
|
||||||
|
&.green {
|
||||||
|
background-color: #3fff5c9d;
|
||||||
|
}
|
||||||
|
&.red {
|
||||||
|
background-color: #ff1313;
|
||||||
|
}
|
||||||
|
&.gray {
|
||||||
|
background-color: rgb(187, 187, 187)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
// Info grid
|
// Info grid
|
||||||
.info-grid {
|
.info-grid {
|
||||||
display: grid;
|
display: grid;
|
||||||
@@ -347,7 +395,6 @@
|
|||||||
background: rgba($error, 0.05);
|
background: rgba($error, 0.05);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
.action-text {
|
.action-text {
|
||||||
flex: 1;
|
flex: 1;
|
||||||
font-weight: $font-weight-medium;
|
font-weight: $font-weight-medium;
|
||||||
|
|||||||
+177
-10
@@ -1,9 +1,9 @@
|
|||||||
import React, { useEffect, useState } from 'react';
|
import React, { useEffect, useState, useRef } from 'react';
|
||||||
import { useParams, useNavigate } from 'react-router-dom';
|
import { useParams, useNavigate } from 'react-router-dom';
|
||||||
import { Header } from '../../components/Header/Header';
|
import { Header } from '../../components/Header/Header';
|
||||||
import { Terminal } from '../../components/Terminal/Terminal';
|
import { Terminal } from '../../components/Terminal/Terminal';
|
||||||
import { apiService } from '../../services/api';
|
import { apiService } from '../../services/api';
|
||||||
import type { AbraApp } from '../../types';
|
import type { AbraApp, AbraAppService, AbraServiceState } from '../../types';
|
||||||
import type { LogEntry } from '../../services/mockApi';
|
import type { LogEntry } from '../../services/mockApi';
|
||||||
import './App.scss';
|
import './App.scss';
|
||||||
|
|
||||||
@@ -12,6 +12,9 @@ export const AppDetail: React.FC = () => {
|
|||||||
const navigate = useNavigate();
|
const navigate = useNavigate();
|
||||||
|
|
||||||
const [app, setApp] = useState<AbraApp | null>(null);
|
const [app, setApp] = useState<AbraApp | null>(null);
|
||||||
|
const [deployState, setDeployState] = useState("undeployed | deploying | deployed | failed");
|
||||||
|
const [serviceState, setServiceState] = useState<Record<string, AbraServiceState>>({});
|
||||||
|
const [services, setServices] = useState<AbraAppService[]>();
|
||||||
const [loading, setLoading] = useState(true);
|
const [loading, setLoading] = useState(true);
|
||||||
const [error, setError] = useState('');
|
const [error, setError] = useState('');
|
||||||
const [actionLoading, setActionLoading] = useState<string | null>(null);
|
const [actionLoading, setActionLoading] = useState<string | null>(null);
|
||||||
@@ -20,8 +23,26 @@ export const AppDetail: React.FC = () => {
|
|||||||
const [terminalLogs, setTerminalLogs] = useState<LogEntry[]>([]);
|
const [terminalLogs, setTerminalLogs] = useState<LogEntry[]>([]);
|
||||||
const [terminalActive, setTerminalActive] = useState(false);
|
const [terminalActive, setTerminalActive] = useState(false);
|
||||||
|
|
||||||
const isMockMode = import.meta.env.VITE_MOCK_AUTH === 'true';
|
// Stream state
|
||||||
|
const stopRef = useRef<null | (() => void)>(null);
|
||||||
|
const deployRef = useRef<null | (() => void)>(null);
|
||||||
|
|
||||||
|
// Use to refresh page
|
||||||
|
const [refreshKey, setRefreshKey] = useState(0);
|
||||||
|
|
||||||
|
const isMockMode = false;
|
||||||
|
const getServiceClass = (state: string, status: string) => {
|
||||||
|
if (state === "running" && status.includes("\(healthy\)")) return "service-card dark-green";
|
||||||
|
if (status.includes("unhealthy")) return "service-card red"
|
||||||
|
if (state === "running") return "service-card green";
|
||||||
|
return "service-card gray";
|
||||||
|
};
|
||||||
|
const getServiceClassDeploying = (state: string, status: string) => {
|
||||||
|
if (state.includes("converged") && status.includes("\(healthy\)")) return "service-card dark-green";
|
||||||
|
if (status.includes("unhealthy")) return "service-card red"
|
||||||
|
if (state.includes("converged")) return "service-card green";
|
||||||
|
return "service-card gray";
|
||||||
|
};
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
const fetchApp = async () => {
|
const fetchApp = async () => {
|
||||||
try {
|
try {
|
||||||
@@ -38,12 +59,17 @@ export const AppDetail: React.FC = () => {
|
|||||||
setError('App not found');
|
setError('App not found');
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
|
console.log('fetching app...');
|
||||||
const appsData = await apiService.getAppsGrouped();
|
const appsData = await apiService.getAppsGrouped();
|
||||||
const serverApps = appsData[server || ''];
|
const serverApps = appsData[server || ''];
|
||||||
const foundApp = serverApps?.apps.find(a => a.appName === appName);
|
const foundApp = serverApps?.apps.find(a => a.appName === appName);
|
||||||
|
|
||||||
if (foundApp) {
|
if (foundApp) {
|
||||||
setApp(foundApp);
|
setApp(foundApp);
|
||||||
|
// when the app is deploying it should handle setting the deploy state itself after success/failure.
|
||||||
|
if (deployState !== "deploying") {
|
||||||
|
setDeployState(foundApp.status === "deployed" ? "deployed" : "undeployed");
|
||||||
|
}
|
||||||
} else {
|
} else {
|
||||||
setError('App not found');
|
setError('App not found');
|
||||||
}
|
}
|
||||||
@@ -56,15 +82,33 @@ export const AppDetail: React.FC = () => {
|
|||||||
};
|
};
|
||||||
|
|
||||||
fetchApp();
|
fetchApp();
|
||||||
}, [server, appName, isMockMode]);
|
}, [server, appName, isMockMode, refreshKey]);
|
||||||
|
// checks status of app containers
|
||||||
|
useEffect(() => {
|
||||||
|
let isMounted = true;
|
||||||
|
const heartbeat = async () => {
|
||||||
|
while (isMounted) {
|
||||||
|
if (deployState === "deployed" && appName) {
|
||||||
|
const services = await apiService.getServices(appName);
|
||||||
|
if (services) {
|
||||||
|
setServices(services);
|
||||||
|
} else {
|
||||||
|
setServices([]);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
await new Promise(resolve => setTimeout(resolve, 10000));
|
||||||
|
}
|
||||||
|
};
|
||||||
|
heartbeat();
|
||||||
|
return () => {
|
||||||
|
isMounted = false;
|
||||||
|
};
|
||||||
|
}, [deployState, appName]);
|
||||||
const handleAction = async (action: string, version?: string) => {
|
const handleAction = async (action: string, version?: string) => {
|
||||||
if (!app) return;
|
if (!app) return;
|
||||||
|
|
||||||
setActionLoading(action);
|
setActionLoading(action);
|
||||||
setTerminalActive(true);
|
|
||||||
setTerminalLogs([]);
|
|
||||||
|
|
||||||
try {
|
try {
|
||||||
if (isMockMode) {
|
if (isMockMode) {
|
||||||
const { mockApiService } = await import('../../services/mockApi');
|
const { mockApiService } = await import('../../services/mockApi');
|
||||||
@@ -94,10 +138,54 @@ export const AppDetail: React.FC = () => {
|
|||||||
switch (action) {
|
switch (action) {
|
||||||
case 'stop':
|
case 'stop':
|
||||||
await apiService.stopApp(app.appName);
|
await apiService.stopApp(app.appName);
|
||||||
|
setRefreshKey(prev => prev + 1);
|
||||||
break;
|
break;
|
||||||
case 'deploy':
|
case 'deploy':
|
||||||
await apiService.deployApp(app.appName);
|
await apiService.deployApp(app.appName);
|
||||||
|
setDeployState("deploying");
|
||||||
|
console.log("deploying");
|
||||||
|
deployRef.current = apiService.deployLogs(app.appName,
|
||||||
|
(update) => {
|
||||||
|
if (update.type === "service") {
|
||||||
|
console.log(update.data.name)
|
||||||
|
const serviceName = update.data.name.slice(app.appName.length+1)
|
||||||
|
setServiceState(prev => ({
|
||||||
|
...prev,
|
||||||
|
[serviceName]: {
|
||||||
|
...prev[serviceName] ?? {},
|
||||||
|
...update.data
|
||||||
|
}
|
||||||
|
}))
|
||||||
|
}
|
||||||
|
if (update.type === "done") {
|
||||||
|
console.log("done?");
|
||||||
|
console.log(update.data.failed, update.data.count);
|
||||||
|
if (update.data.failed) {
|
||||||
|
setDeployState('failed');
|
||||||
|
console.log("Deploy failed?");
|
||||||
|
} else {
|
||||||
|
setDeployState("deployed");
|
||||||
|
}
|
||||||
|
setRefreshKey(prev => prev + 1);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
)
|
||||||
break;
|
break;
|
||||||
|
case 'logs':
|
||||||
|
setTerminalActive(true);
|
||||||
|
setTerminalLogs([]);
|
||||||
|
if (version) {
|
||||||
|
stopRef.current = apiService.getLogs(app.appName, version,
|
||||||
|
(line) => {
|
||||||
|
console.log(line);
|
||||||
|
setTerminalLogs(prev => [...prev, {
|
||||||
|
type: 'info',
|
||||||
|
text: `${line}`,
|
||||||
|
timestamp: new Date()
|
||||||
|
}]);
|
||||||
|
}
|
||||||
|
)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
@@ -136,8 +224,8 @@ export const AppDetail: React.FC = () => {
|
|||||||
</div>
|
</div>
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
// TODO: make sure this makes sense when app.upgrade is unknown
|
||||||
const upgradeVersions = app.upgrade !== 'latest' ? app.upgrade.split('\n') : [];
|
const upgradeVersions = (app.upgrade !== 'latest' && app.upgrade !== 'unknown') ? app.upgrade.split('\n') : [];
|
||||||
|
|
||||||
return (
|
return (
|
||||||
<div className="app-detail-page">
|
<div className="app-detail-page">
|
||||||
@@ -185,7 +273,11 @@ export const AppDetail: React.FC = () => {
|
|||||||
<Terminal
|
<Terminal
|
||||||
logs={terminalLogs}
|
logs={terminalLogs}
|
||||||
isActive={terminalActive}
|
isActive={terminalActive}
|
||||||
onClose={() => setTerminalActive(false)}
|
onClose={() => {
|
||||||
|
stopRef.current?.();
|
||||||
|
stopRef.current = null;
|
||||||
|
setTerminalActive(false)
|
||||||
|
}}
|
||||||
/>
|
/>
|
||||||
|
|
||||||
<div className="content-grid">
|
<div className="content-grid">
|
||||||
@@ -241,7 +333,70 @@ export const AppDetail: React.FC = () => {
|
|||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
</section>
|
</section>
|
||||||
|
{(deployState === "deployed" || deployState === "failed") && (
|
||||||
|
<section className="info-card">
|
||||||
|
<h2> Service Information </h2>
|
||||||
|
<div className="service-grid">
|
||||||
|
{services === undefined || services?.length === 0 ? (
|
||||||
|
<div className="no-services"> Loading services... </div>
|
||||||
|
) : (
|
||||||
|
services.map((service) => (
|
||||||
|
<div
|
||||||
|
key={service.service}
|
||||||
|
className={getServiceClass(service.state, service.status)}
|
||||||
|
>
|
||||||
|
<div className="service-name">
|
||||||
|
<h3> {service.service} </h3>
|
||||||
|
</div>
|
||||||
|
<div className="service-row">
|
||||||
|
<span className="service-value">{service.state}</span>
|
||||||
|
<span className="service-value">{service.status}</span>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<button
|
||||||
|
className="action-btn"
|
||||||
|
onClick={() => handleAction('logs', service.service)}
|
||||||
|
disabled={!!actionLoading}
|
||||||
|
>
|
||||||
|
Logs
|
||||||
|
</button>
|
||||||
|
</div>
|
||||||
|
))
|
||||||
|
)}
|
||||||
|
</div>
|
||||||
|
</section>)}
|
||||||
|
{(deployState === "deploying") && (
|
||||||
|
<section className="info-card">
|
||||||
|
<h2> Service Information </h2>
|
||||||
|
<div className="service-grid">
|
||||||
|
{serviceState === undefined || Object.keys(serviceState).length === 0 ? (
|
||||||
|
<div className="no-services"> Preparing services... </div>
|
||||||
|
) : (
|
||||||
|
Object.keys(serviceState).map((name) => (
|
||||||
|
<div
|
||||||
|
key={name}
|
||||||
|
className={getServiceClass(serviceState[name].status, serviceState[name].health)}
|
||||||
|
>
|
||||||
|
<div className="service-name">
|
||||||
|
<h3> {name} </h3>
|
||||||
|
</div>
|
||||||
|
<div className="service-row">
|
||||||
|
<span className="service-value">{serviceState[name].status}</span>
|
||||||
|
<span className="service-value">{serviceState[name].health}</span>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<button
|
||||||
|
className="action-btn"
|
||||||
|
onClick={() => handleAction('logs', appName)}
|
||||||
|
disabled={!!actionLoading}
|
||||||
|
>
|
||||||
|
Logs
|
||||||
|
</button>
|
||||||
|
</div>
|
||||||
|
))
|
||||||
|
)}
|
||||||
|
</div>
|
||||||
|
</section>)}
|
||||||
<section className="info-card">
|
<section className="info-card">
|
||||||
<h2>Version Information</h2>
|
<h2>Version Information</h2>
|
||||||
|
|
||||||
@@ -281,6 +436,18 @@ export const AppDetail: React.FC = () => {
|
|||||||
</div>
|
</div>
|
||||||
)}
|
)}
|
||||||
|
|
||||||
|
{app.upgrade === 'unknown' && (
|
||||||
|
<div className="version-upgrades">
|
||||||
|
<label>
|
||||||
|
Available Upgrades
|
||||||
|
</label>
|
||||||
|
<div className="upgrade-list">
|
||||||
|
<div className="upgrade-item">
|
||||||
|
<code>None</code>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
)}
|
||||||
{app.upgrade === 'latest' && (
|
{app.upgrade === 'latest' && (
|
||||||
<div className="version-latest">
|
<div className="version-latest">
|
||||||
✓ Running latest version
|
✓ Running latest version
|
||||||
|
|||||||
@@ -15,7 +15,7 @@ export const Apps: React.FC = () => {
|
|||||||
const [filterStatus, setFilterStatus] = useState<string>('all');
|
const [filterStatus, setFilterStatus] = useState<string>('all');
|
||||||
const [showUpgradesOnly, setShowUpgradesOnly] = useState(false);
|
const [showUpgradesOnly, setShowUpgradesOnly] = useState(false);
|
||||||
|
|
||||||
const isMockMode = import.meta.env.VITE_MOCK_AUTH === 'true';
|
const isMockMode = false;
|
||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
const fetchData = async () => {
|
const fetchData = async () => {
|
||||||
|
|||||||
@@ -12,7 +12,7 @@ export const Dashboard: React.FC = () => {
|
|||||||
const [error, setError] = useState('');
|
const [error, setError] = useState('');
|
||||||
const navigate = useNavigate();
|
const navigate = useNavigate();
|
||||||
|
|
||||||
const isMockMode = import.meta.env.VITE_MOCK_AUTH === 'true';
|
const isMockMode = false;
|
||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
const fetchData = async () => {
|
const fetchData = async () => {
|
||||||
|
|||||||
@@ -7,19 +7,18 @@ import type { AbraServer } from '../../types';
|
|||||||
function RecipeForm({ recipe, onClose }) {
|
function RecipeForm({ recipe, onClose }) {
|
||||||
const [loading, setLoading] = useState(true);
|
const [loading, setLoading] = useState(true);
|
||||||
const [servers, setServers] = useState<AbraServer[]>([]);
|
const [servers, setServers] = useState<AbraServer[]>([]);
|
||||||
const [selectedServer, setSelectedServer] = useState(""); // ❌ only one value
|
|
||||||
const [chaos, setChaos] = useState(false);
|
|
||||||
const [secrets, setSecrets] = useState(false);
|
|
||||||
const [error, setError] = useState('');
|
const [error, setError] = useState('');
|
||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
const fetchData = async () => {
|
const fetchData = async () => {
|
||||||
try {
|
try {
|
||||||
const [serversData] = await Promise.all([
|
if (servers.length === 0) {
|
||||||
apiService.getServers(),
|
const [serversData] = await Promise.all([
|
||||||
]);
|
apiService.getServers(),
|
||||||
|
]);
|
||||||
setServers(serversData);
|
|
||||||
|
setServers(serversData);
|
||||||
|
}
|
||||||
|
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
setError(err instanceof Error ? err.message : 'Failed to load servers');
|
setError(err instanceof Error ? err.message : 'Failed to load servers');
|
||||||
@@ -31,21 +30,25 @@ function RecipeForm({ recipe, onClose }) {
|
|||||||
fetchData();
|
fetchData();
|
||||||
});
|
});
|
||||||
const [formData, setFormData] = useState({
|
const [formData, setFormData] = useState({
|
||||||
|
server: "",
|
||||||
domain: "",
|
domain: "",
|
||||||
chaos: false,
|
chaos: false,
|
||||||
secrets: true,
|
secrets: false,
|
||||||
});
|
});
|
||||||
|
|
||||||
const handleChange = (e) => {
|
const handleChange = (e) => {
|
||||||
setFormData({
|
const {name, type, value, checked} = e.target;
|
||||||
...formData,
|
setFormData((prev) => ({
|
||||||
[e.target.name]: e.target.value,
|
...prev,
|
||||||
});
|
[name]: type === "checkbox" ? checked : value,
|
||||||
|
}));
|
||||||
|
console.log(formData);
|
||||||
};
|
};
|
||||||
|
|
||||||
const handleSubmit = (e) => {
|
const handleSubmit = (e) => {
|
||||||
e.preventDefault();
|
e.preventDefault();
|
||||||
console.log("Submitting:", formData);
|
console.log("Submitting:", formData);
|
||||||
|
apiService.newApp(recipe.name, formData);
|
||||||
onClose();
|
onClose();
|
||||||
};
|
};
|
||||||
|
|
||||||
@@ -58,8 +61,9 @@ function RecipeForm({ recipe, onClose }) {
|
|||||||
<label>
|
<label>
|
||||||
Choose a server to deploy to:
|
Choose a server to deploy to:
|
||||||
<select
|
<select
|
||||||
value={selectedServer}
|
name="server"
|
||||||
onChange={(e) => setSelectedServer(e.target.value)}
|
value={formData.server || ""}
|
||||||
|
onChange={handleChange}
|
||||||
>
|
>
|
||||||
<option value="">None</option>
|
<option value="">None</option>
|
||||||
{servers.map((server) => (
|
{servers.map((server) => (
|
||||||
@@ -75,8 +79,8 @@ function RecipeForm({ recipe, onClose }) {
|
|||||||
<label>
|
<label>
|
||||||
Domain:
|
Domain:
|
||||||
<input
|
<input
|
||||||
name="Domain"
|
name="domain"
|
||||||
value={formData.name}
|
value={formData.domain}
|
||||||
onChange={handleChange}
|
onChange={handleChange}
|
||||||
/>
|
/>
|
||||||
</label>
|
</label>
|
||||||
|
|||||||
@@ -19,7 +19,7 @@ export const Recipes: React.FC = () => {
|
|||||||
|
|
||||||
|
|
||||||
|
|
||||||
const isMockMode = import.meta.env.VITE_MOCK_AUTH === 'true';
|
const isMockMode = false;
|
||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
const fetchData = async () => {
|
const fetchData = async () => {
|
||||||
@@ -72,7 +72,7 @@ export const Recipes: React.FC = () => {
|
|||||||
<div className="apps-page">
|
<div className="apps-page">
|
||||||
<Header />
|
<Header />
|
||||||
<main className="recipes-content">
|
<main className="recipes-content">
|
||||||
<div className="loading">Loading applications...</div>
|
<div className="loading">Loading recipes...</div>
|
||||||
</main>
|
</main>
|
||||||
</div>
|
</div>
|
||||||
);
|
);
|
||||||
|
|||||||
@@ -29,7 +29,7 @@ export const Server: React.FC = () => {
|
|||||||
const [terminalLogs, setTerminalLogs] = useState<LogEntry[]>([]);
|
const [terminalLogs, setTerminalLogs] = useState<LogEntry[]>([]);
|
||||||
const [terminalActive, setTerminalActive] = useState(false);
|
const [terminalActive, setTerminalActive] = useState(false);
|
||||||
|
|
||||||
const isMockMode = import.meta.env.VITE_MOCK_AUTH === 'true';
|
const isMockMode = false;
|
||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
const fetchServer = async () => {
|
const fetchServer = async () => {
|
||||||
|
|||||||
@@ -21,7 +21,7 @@ export const Servers: React.FC = () => {
|
|||||||
const [searchTerm, setSearchTerm] = useState('');
|
const [searchTerm, setSearchTerm] = useState('');
|
||||||
const [sortBy, setSortBy] = useState<'name' | 'apps' | 'upgrades'>('name');
|
const [sortBy, setSortBy] = useState<'name' | 'apps' | 'upgrades'>('name');
|
||||||
|
|
||||||
const isMockMode = import.meta.env.VITE_MOCK_AUTH === 'true';
|
const isMockMode = false;
|
||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
const fetchData = async () => {
|
const fetchData = async () => {
|
||||||
|
|||||||
+73
-16
@@ -1,4 +1,4 @@
|
|||||||
import type { AbraServer, AbraRecipe, ServerAppsResponse } from '../types';
|
import type { AbraServer, AbraRecipe, ServerAppsResponse, AbraAppService, DeployEvent } from '../types';
|
||||||
|
|
||||||
// Log entry type
|
// Log entry type
|
||||||
export type LogEntry = {
|
export type LogEntry = {
|
||||||
@@ -37,8 +37,52 @@ class ApiService {
|
|||||||
const error = await response.json().catch(() => ({ message: 'An error occurred' }));
|
const error = await response.json().catch(() => ({ message: 'An error occurred' }));
|
||||||
throw new Error(error.message || `HTTP ${response.status}`);
|
throw new Error(error.message || `HTTP ${response.status}`);
|
||||||
}
|
}
|
||||||
|
if (response.status === 204) {
|
||||||
|
return undefined as T;
|
||||||
|
}
|
||||||
|
|
||||||
return response.json();
|
const contentType = response.headers.get('content-type');
|
||||||
|
|
||||||
|
if (contentType?.includes('application/json')) {
|
||||||
|
return response.json();
|
||||||
|
}
|
||||||
|
return response.text() as unknown as T;
|
||||||
|
}
|
||||||
|
|
||||||
|
private stream<T>(
|
||||||
|
endpoint: string,
|
||||||
|
handlers: {
|
||||||
|
onMessage: (data: T) => void;
|
||||||
|
onError?: (err: any) => void;
|
||||||
|
onOpen?: () => void;
|
||||||
|
parser?: (raw: string) => T;
|
||||||
|
}
|
||||||
|
) {
|
||||||
|
const es = new EventSource(`${API_BASE_URL}${endpoint}`);
|
||||||
|
|
||||||
|
es.onopen = () => {
|
||||||
|
handlers.onOpen?.();
|
||||||
|
};
|
||||||
|
es.onmessage = (event) => {
|
||||||
|
try {
|
||||||
|
const data = handlers.parser
|
||||||
|
? handlers.parser(event.data)
|
||||||
|
: (event.data as unknown as T);
|
||||||
|
|
||||||
|
handlers.onMessage(data);
|
||||||
|
} catch (err) {
|
||||||
|
handlers.onError?.(err);
|
||||||
|
}
|
||||||
|
};
|
||||||
|
es.onerror = (err) => {
|
||||||
|
handlers.onError?.(err);
|
||||||
|
es.close();
|
||||||
|
};
|
||||||
|
return () => es.close();
|
||||||
|
}
|
||||||
|
// Get Logs for service
|
||||||
|
getLogs(appName: string, serviceName: string, msgHandler: (data: String) => void) {
|
||||||
|
return this.stream(`/apps/${appName}/${serviceName}/logs`, {onMessage: msgHandler})
|
||||||
}
|
}
|
||||||
|
|
||||||
// Get all apps grouped by server
|
// Get all apps grouped by server
|
||||||
@@ -50,21 +94,24 @@ class ApiService {
|
|||||||
async getServers(): Promise<AbraServer[]> {
|
async getServers(): Promise<AbraServer[]> {
|
||||||
return this.request<AbraServer[]>('/servers');
|
return this.request<AbraServer[]>('/servers');
|
||||||
}
|
}
|
||||||
|
// Get services for app
|
||||||
// App actions with log streaming (websocket future)
|
async getServices(appName: string): Promise<AbraAppService[]> {
|
||||||
async deployApp(appName: string, onLog?: (log: LogEntry) => void): Promise<void> {
|
return this.request<AbraAppService[]>(`/apps/${appName}/services`);
|
||||||
const response = await this.request<{ logs: any[] }>(`/apps/${appName}/deploy`, {
|
|
||||||
method: 'POST',
|
|
||||||
});
|
|
||||||
|
|
||||||
if (onLog && response.logs) {
|
|
||||||
const logs = processLogResponse(response.logs);
|
|
||||||
logs.forEach(log => onLog(log));
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
async undeployApp(appName: string, onLog?: (log: LogEntry) => void): Promise<void> {
|
// App actions with log streaming (websocket future)
|
||||||
const response = await this.request<{ logs: any[] }>(`/apps/${appName}/undeploy`, {
|
async deployApp(appName: string): Promise<void> {
|
||||||
|
return this.request<void>(`/apps/${appName}/deploy`, {
|
||||||
|
method: 'POST',
|
||||||
|
});
|
||||||
|
}
|
||||||
|
deployLogs(appName: string, msgHandler: (data: DeployEvent) => void) {
|
||||||
|
return this.stream(`/apps/${appName}/deploy`, {parser: JSON.parse, onMessage: msgHandler})
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
async stopApp(appName: string, onLog?: (log: LogEntry) => void): Promise<void> {
|
||||||
|
const response = await this.request<{ logs: any[] }>(`/apps/${appName}/stop`, {
|
||||||
method: 'POST',
|
method: 'POST',
|
||||||
});
|
});
|
||||||
|
|
||||||
@@ -96,6 +143,16 @@ class ApiService {
|
|||||||
logs.forEach(log => onLog(log));
|
logs.forEach(log => onLog(log));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
async newApp(appName: string, formData: Object): Promise<void> {
|
||||||
|
const response = await this.request<void>(`/apps/${appName}/new`, {
|
||||||
|
method: 'POST',
|
||||||
|
headers: {
|
||||||
|
'Accept': 'application/json'
|
||||||
|
},
|
||||||
|
body: JSON.stringify(formData)
|
||||||
|
});
|
||||||
|
return response
|
||||||
|
}
|
||||||
|
|
||||||
// Server actions with log streaming
|
// Server actions with log streaming
|
||||||
async refreshServer(serverName: string, onLog?: (log: LogEntry) => void): Promise<void> {
|
async refreshServer(serverName: string, onLog?: (log: LogEntry) => void): Promise<void> {
|
||||||
@@ -132,7 +189,7 @@ class ApiService {
|
|||||||
}
|
}
|
||||||
// recipe catalog imports
|
// recipe catalog imports
|
||||||
async getRecipes(): Promise<AbraRecipe[]> {
|
async getRecipes(): Promise<AbraRecipe[]> {
|
||||||
return this.request<AbraRecipe[]>('/abra/catalogue');
|
return this.request<AbraRecipe[]>('/catalogue');
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
+38
-1
@@ -37,6 +37,43 @@ export interface AppWithServer extends AbraApp {
|
|||||||
upgradeCount: number;
|
upgradeCount: number;
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
|
export interface AbraAppService {
|
||||||
|
service: string;
|
||||||
|
chaos: boolean;
|
||||||
|
created: string;
|
||||||
|
image: string;
|
||||||
|
ports: string;
|
||||||
|
state: string;
|
||||||
|
status: string;
|
||||||
|
version: string;
|
||||||
|
}
|
||||||
|
export interface AbraServiceState {
|
||||||
|
name: string;
|
||||||
|
err: string;
|
||||||
|
id: string;
|
||||||
|
status: string;
|
||||||
|
retries: number;
|
||||||
|
health: string;
|
||||||
|
rollback: boolean;
|
||||||
|
failed: boolean;
|
||||||
|
}
|
||||||
|
export interface DeployState {
|
||||||
|
count: number;
|
||||||
|
total: number;
|
||||||
|
failed: boolean;
|
||||||
|
quit: boolean;
|
||||||
|
}
|
||||||
|
|
||||||
|
export type DeployEvent =
|
||||||
|
| {
|
||||||
|
type: "service";
|
||||||
|
data: AbraServiceState;
|
||||||
|
}
|
||||||
|
| {
|
||||||
|
type: "done";
|
||||||
|
data: DeployState;
|
||||||
|
}
|
||||||
export interface Image {
|
export interface Image {
|
||||||
image: string;
|
image: string;
|
||||||
rating: string
|
rating: string
|
||||||
@@ -68,4 +105,4 @@ export interface AbraRecipe {
|
|||||||
ssh_url: string;
|
ssh_url: string;
|
||||||
versions: RecipeVersions;
|
versions: RecipeVersions;
|
||||||
website: string;
|
website: string;
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user