fix: CI/CD + server bugs
This commit is contained in:
@@ -258,3 +258,91 @@ jobs:
|
|||||||
core.warning(`Failed to delete artifact ${artifact.id}: ${error.message}`);
|
core.warning(`Failed to delete artifact ${artifact.id}: ${error.message}`);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
prune-docker-images:
|
||||||
|
name: Prune old Docker images
|
||||||
|
runs-on: ubuntu-latest
|
||||||
|
needs: merge
|
||||||
|
permissions:
|
||||||
|
packages: write
|
||||||
|
steps:
|
||||||
|
- name: Delete untagged images
|
||||||
|
uses: actions/github-script@v7
|
||||||
|
with:
|
||||||
|
github-token: ${{ secrets.RELEASES_TOKEN || secrets.GITHUB_TOKEN }}
|
||||||
|
script: |
|
||||||
|
const keepCount = 5;
|
||||||
|
const { owner, repo } = context.repo;
|
||||||
|
const packageName = repo.toLowerCase();
|
||||||
|
|
||||||
|
core.info(`Cleaning Docker images for repository: ${owner}/${repo}`);
|
||||||
|
core.info(`Package name in registry: ${packageName}`);
|
||||||
|
|
||||||
|
try {
|
||||||
|
// Get all package versions for THIS repository's container package only
|
||||||
|
const versions = await github.paginate(
|
||||||
|
github.rest.packages.getAllPackageVersionsForPackageOwnedByOrg,
|
||||||
|
{
|
||||||
|
package_type: 'container',
|
||||||
|
package_name: packageName, // This filters to only this repo's images
|
||||||
|
org: owner,
|
||||||
|
per_page: 100,
|
||||||
|
state: 'active',
|
||||||
|
}
|
||||||
|
);
|
||||||
|
|
||||||
|
core.info(`Found ${versions.length} package versions`);
|
||||||
|
|
||||||
|
// Separate tagged and untagged versions
|
||||||
|
const taggedVersions = versions.filter(v => v.metadata?.container?.tags?.length > 0);
|
||||||
|
const untaggedVersions = versions.filter(v => !v.metadata?.container?.tags || v.metadata.container.tags.length === 0);
|
||||||
|
|
||||||
|
core.info(`Tagged versions: ${taggedVersions.length}, Untagged versions: ${untaggedVersions.length}`);
|
||||||
|
|
||||||
|
// Delete all untagged versions
|
||||||
|
for (const version of untaggedVersions) {
|
||||||
|
core.info(`Deleting untagged version ${version.id} (created: ${version.created_at})`);
|
||||||
|
try {
|
||||||
|
await github.rest.packages.deletePackageVersionForOrg({
|
||||||
|
package_type: 'container',
|
||||||
|
package_name: packageName,
|
||||||
|
org: owner,
|
||||||
|
package_version_id: version.id,
|
||||||
|
});
|
||||||
|
} catch (error) {
|
||||||
|
core.warning(`Failed to delete untagged version ${version.id}: ${error.message}`);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Sort tagged versions by creation date (newest first)
|
||||||
|
const sortedTagged = taggedVersions.sort((a, b) =>
|
||||||
|
new Date(b.created_at) - new Date(a.created_at)
|
||||||
|
);
|
||||||
|
|
||||||
|
// Keep the newest versions, delete the rest
|
||||||
|
const versionsToDelete = sortedTagged.slice(keepCount);
|
||||||
|
|
||||||
|
core.info(`Keeping ${keepCount} newest tagged versions, deleting ${versionsToDelete.length} older ones...`);
|
||||||
|
for (const version of versionsToDelete) {
|
||||||
|
const tags = version.metadata?.container?.tags?.join(', ') || 'unknown';
|
||||||
|
core.info(`Deleting version ${version.id} with tags: ${tags} (created: ${version.created_at})`);
|
||||||
|
try {
|
||||||
|
await github.rest.packages.deletePackageVersionForOrg({
|
||||||
|
package_type: 'container',
|
||||||
|
package_name: packageName,
|
||||||
|
org: owner,
|
||||||
|
package_version_id: version.id,
|
||||||
|
});
|
||||||
|
} catch (error) {
|
||||||
|
core.warning(`Failed to delete version ${version.id}: ${error.message}`);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
} catch (error) {
|
||||||
|
if (error.status === 404) {
|
||||||
|
core.info('No package found - this might be the first build');
|
||||||
|
} else {
|
||||||
|
core.setFailed(`Error managing package versions: ${error.message}`);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|||||||
+20
-11
@@ -17,6 +17,7 @@ from aiohttp import WSMsgType, web
|
|||||||
|
|
||||||
from . import constants
|
from . import constants
|
||||||
from .docker_stats import DockerStatsCollector, render_sparkline_svg
|
from .docker_stats import DockerStatsCollector, render_sparkline_svg
|
||||||
|
from .docker_watcher import AUTO_COMMAND_SENTINEL
|
||||||
from .exit_poller import ExitPoller
|
from .exit_poller import ExitPoller
|
||||||
from .identity import generate
|
from .identity import generate
|
||||||
from .poller import Poller
|
from .poller import Poller
|
||||||
@@ -34,7 +35,7 @@ DEFAULT_TERMINAL_SIZE = (132, 45)
|
|||||||
|
|
||||||
SCREENSHOT_CACHE_SECONDS = 0.3
|
SCREENSHOT_CACHE_SECONDS = 0.3
|
||||||
SCREENSHOT_MAX_CACHE_SECONDS = 20.0
|
SCREENSHOT_MAX_CACHE_SECONDS = 20.0
|
||||||
CLEAR_AND_REDRAW_SEQ = "\x0c" # Ctrl+L: clear and redraw
|
CLEAR_AND_REDRAW_SEQ = "\x1b[2J\x1b[H\x1b[3J" # Clear screen and scrollback, move to home
|
||||||
|
|
||||||
|
|
||||||
WEBTERM_STATIC_PATH = Path(__file__).parent / "static"
|
WEBTERM_STATIC_PATH = Path(__file__).parent / "static"
|
||||||
@@ -83,6 +84,13 @@ class LocalClientConnector(SessionConnector):
|
|||||||
await self.server.handle_session_close(self.session_id, self.route_key)
|
await self.server.handle_session_close(self.session_id, self.route_key)
|
||||||
|
|
||||||
|
|
||||||
|
def _format_command_label(command: str) -> str:
|
||||||
|
"""Format command for display in UI, replacing sentinel with readable label."""
|
||||||
|
if command == AUTO_COMMAND_SENTINEL:
|
||||||
|
return "(tmux persistent session)"
|
||||||
|
return command
|
||||||
|
|
||||||
|
|
||||||
class LocalServer:
|
class LocalServer:
|
||||||
def mark_route_activity(self, route_key: str) -> None:
|
def mark_route_activity(self, route_key: str) -> None:
|
||||||
try:
|
try:
|
||||||
@@ -312,15 +320,15 @@ class LocalServer:
|
|||||||
await runner.setup()
|
await runner.setup()
|
||||||
stack.push_async_callback(runner.cleanup)
|
stack.push_async_callback(runner.cleanup)
|
||||||
|
|
||||||
# Start Docker stats collector in compose mode
|
# Start Docker stats collector in compose mode or docker watch mode
|
||||||
if self._compose_mode and self._landing_apps:
|
if (self._compose_mode and self._landing_apps) or self._docker_watch_mode:
|
||||||
self._docker_stats = DockerStatsCollector(compose_project=self._compose_project)
|
self._docker_stats = DockerStatsCollector(compose_project=self._compose_project)
|
||||||
if self._docker_stats.available:
|
if self._docker_stats.available:
|
||||||
# Pass service names (not slugs) for Docker matching
|
# Pass service names (not slugs) for Docker matching
|
||||||
service_names = [app.name for app in self._landing_apps]
|
service_names = [app.name for app in (self._landing_apps if self._compose_mode else self.session_manager.apps)]
|
||||||
self._docker_stats.start(service_names)
|
self._docker_stats.start(service_names)
|
||||||
# Create slug->name mapping for lookups
|
# Create slug->name mapping for lookups
|
||||||
self._slug_to_service = {app.slug: app.name for app in self._landing_apps}
|
self._slug_to_service = {app.slug: app.name for app in (self._landing_apps if self._compose_mode else self.session_manager.apps)}
|
||||||
log.info("Slug to service mapping: %s", self._slug_to_service)
|
log.info("Slug to service mapping: %s", self._slug_to_service)
|
||||||
stack.push_async_callback(self._docker_stats.stop)
|
stack.push_async_callback(self._docker_stats.stop)
|
||||||
|
|
||||||
@@ -538,7 +546,7 @@ class LocalServer:
|
|||||||
if session_process is not None:
|
if session_process is not None:
|
||||||
await asyncio.sleep(0.5)
|
await asyncio.sleep(0.5)
|
||||||
|
|
||||||
if session_process is None or not hasattr(session_process, "get_screen_state"):
|
if session_process is None or not hasattr(session_process, "get_screen_snapshot"):
|
||||||
raise web.HTTPNotFound(text="Session not found")
|
raise web.HTTPNotFound(text="Session not found")
|
||||||
|
|
||||||
# Get the actual screen state from the terminal session's pyte screen
|
# Get the actual screen state from the terminal session's pyte screen
|
||||||
@@ -707,7 +715,7 @@ class LocalServer:
|
|||||||
apps_for_dashboard = self._landing_apps
|
apps_for_dashboard = self._landing_apps
|
||||||
|
|
||||||
tiles = [
|
tiles = [
|
||||||
{"slug": app.slug, "name": app.name, "command": app.command}
|
{"slug": app.slug, "name": app.name, "command": _format_command_label(app.command)}
|
||||||
for app in apps_for_dashboard
|
for app in apps_for_dashboard
|
||||||
]
|
]
|
||||||
return web.json_response(tiles)
|
return web.json_response(tiles)
|
||||||
@@ -727,18 +735,19 @@ class LocalServer:
|
|||||||
apps_for_dashboard = self._landing_apps
|
apps_for_dashboard = self._landing_apps
|
||||||
|
|
||||||
tiles = [
|
tiles = [
|
||||||
{"slug": app.slug, "name": app.name, "command": app.command}
|
{"slug": app.slug, "name": app.name, "command": _format_command_label(app.command)}
|
||||||
for app in apps_for_dashboard
|
for app in apps_for_dashboard
|
||||||
]
|
]
|
||||||
tiles_json = json.dumps(tiles)
|
tiles_json = json.dumps(tiles)
|
||||||
compose_mode_js = "true" if self._compose_mode else "false"
|
# Show CPU sparklines in both compose mode and docker watch mode
|
||||||
|
compose_mode_js = "true" if (self._compose_mode or self._docker_watch_mode) else "false"
|
||||||
docker_watch_js = "true" if self._docker_watch_mode else "false"
|
docker_watch_js = "true" if self._docker_watch_mode else "false"
|
||||||
html_content = f"""<!DOCTYPE html>
|
html_content = f"""<!DOCTYPE html>
|
||||||
<html>
|
<html>
|
||||||
<head>
|
<head>
|
||||||
<title>Session Dashboard</title>
|
<title>Session Dashboard</title>
|
||||||
<style>
|
<style>
|
||||||
body {{ font-family: Arial, sans-serif; margin: 16px; background: #0f172a; color: #e2e8f0; }}
|
body {{ font-family: -apple-system, BlinkMacSystemFont, "Segoe UI", Roboto, "Helvetica Neue", Arial, sans-serif; margin: 16px; background: #0f172a; color: #e2e8f0; }}
|
||||||
h1 {{ margin-bottom: 8px; }}
|
h1 {{ margin-bottom: 8px; }}
|
||||||
.subtitle {{ color: #64748b; font-size: 14px; margin-bottom: 16px; }}
|
.subtitle {{ color: #64748b; font-size: 14px; margin-bottom: 16px; }}
|
||||||
.grid {{ display: grid; grid-template-columns: repeat(auto-fill, minmax(280px, 1fr)); gap: 12px; }}
|
.grid {{ display: grid; grid-template-columns: repeat(auto-fill, minmax(280px, 1fr)); gap: 12px; }}
|
||||||
@@ -1202,7 +1211,7 @@ class LocalServer:
|
|||||||
<link rel=\"stylesheet\" href=\"/static/monospace.css\">
|
<link rel=\"stylesheet\" href=\"/static/monospace.css\">
|
||||||
<style>
|
<style>
|
||||||
html, body {{ width: 100%; height: 100%; }}
|
html, body {{ width: 100%; height: 100%; }}
|
||||||
body {{ background: {theme_bg}; margin: 0; padding: 0; overflow: hidden; }}
|
body {{ background: {theme_bg}; margin: 0; padding: 0; overflow: hidden; font-family: var(--webterm-mono); }}
|
||||||
.webterm-terminal {{ width: 100%; height: 100%; display: block; overflow: hidden; }}
|
.webterm-terminal {{ width: 100%; height: 100%; display: block; overflow: hidden; }}
|
||||||
</style>
|
</style>
|
||||||
</head>
|
</head>
|
||||||
|
|||||||
Reference in New Issue
Block a user