Skip to content

try to show activity in status page #228

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
emanuelef wants to merge 1 commit into
base: main
Choose a base branch
from
Open

try to show activity in status page #228

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
22 changes: 22 additions & 0 deletions handlers/cache.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -93,6 +93,28 @@ func StatusHandler(
}
}

// ActiveOperationsHandler returns all currently active/ongoing operations
func ActiveOperationsHandler(onGoingStars map[string]bool) fiber.Handler {
return func(c *fiber.Ctx) error {
// Get ongoing stars operations
ongoingRepos := make([]string, 0, len(onGoingStars))
for repo := range onGoingStars {
ongoingRepos = append(ongoingRepos, repo)
}

// Get busy clients from the client selector
busyClients := GetBusyClients()

data := map[string]any{
"ongoingStars": ongoingRepos,
"busyClients": busyClients,
"totalActive": len(ongoingRepos),
}

return c.JSON(data)
}
}

func DeleteRecentStarsCacheHandler(cacheStars *cache.Cache[string, types.StarsWithStatsResponse]) fiber.Handler {
return func(c *fiber.Ctx) error {
param := c.Query("repo")
Expand Down
1 change: 1 addition & 0 deletions routes/routes.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -82,6 +82,7 @@ func RegisterCacheRoutes(app *fiber.App, caches *Caches, onGoingStars map[string
app.Get("/allStarsCsv", handlers.AllStarsCSVHandler(caches.Stars))
app.Get("/status", handlers.StatusHandler(caches.Stars, onGoingStars))
app.Get("/deleteRecentStarsCache", handlers.DeleteRecentStarsCacheHandler(caches.Stars))
app.Get("/activeOps", handlers.ActiveOperationsHandler(onGoingStars))
}

// RegisterRequestStatsRoutes registers request statistics routes
Expand Down
110 changes: 110 additions & 0 deletions website/src/MainPage.jsx
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -102,6 +102,17 @@ const MainPage = () => {
const [resetLimitsTime, setResetLimitsTime] = useState(0);
const [loading, setLoading] = useState(false);
const [lastUpdated, setLastUpdated] = useState(null);
const [activeOps, setActiveOps] = useState({ ongoingStars: [], busyClients: {}, totalActive: 0 });

const fetchActiveOps = async () => {
try {
const response = await fetch(`${HOST}/activeOps`);
const data = await response.json();
setActiveOps(data);
} catch (error) {
console.error("Error fetching active operations:", error);
}
};

const fetchLimits = async () => {
try {
Expand Down Expand Up @@ -137,6 +148,13 @@ const MainPage = () => {
return () => clearInterval(intervalId);
}, []);

// Poll active operations every 5 seconds
useEffect(() => {
fetchActiveOps();
const intervalId = setInterval(fetchActiveOps, 5000);
return () => clearInterval(intervalId);
}, []);

const usedRequests = totalRequests - remainingRequests;
const usagePercentage = totalRequests > 0 ? ((usedRequests / totalRequests) * 100).toFixed(1) : 0;

Expand Down Expand Up @@ -232,6 +250,7 @@ const MainPage = () => {
background: 'linear-gradient(135deg, #1a1a2e 0%, #16213e 100%)',
borderRadius: '16px',
padding: '24px',
marginBottom: '24px',
border: '1px solid rgba(59, 130, 246, 0.2)',
}}>
<h3 style={{ margin: '0 0 16px 0', color: '#fff', fontSize: '16px', fontWeight: '600' }}>
Expand All @@ -256,6 +275,97 @@ const MainPage = () => {
</div>
</div>
</div>

{/* Active Operations Card */}
<div style={{
background: 'linear-gradient(135deg, #1a1a2e 0%, #16213e 100%)',
borderRadius: '16px',
padding: '24px',
border: '1px solid rgba(59, 130, 246, 0.2)',
}}>
<div style={{ display: 'flex', alignItems: 'center', justifyContent: 'space-between', marginBottom: '16px' }}>
<h3 style={{ margin: 0, color: '#fff', fontSize: '16px', fontWeight: '600' }}>
🔄 Active Operations
</h3>
<span style={{
background: activeOps.totalActive > 0 ? '#10b981' : '#6b7280',
color: '#fff',
padding: '4px 12px',
borderRadius: '12px',
fontSize: '12px',
fontWeight: '600',
}}>
{activeOps.totalActive} active
</span>
</div>

{activeOps.totalActive === 0 ? (
<div style={{
padding: '24px',
textAlign: 'center',
color: '#6b7280',
fontSize: '14px',
}}>
No active operations
</div>
) : (
<div style={{ display: 'flex', flexDirection: 'column', gap: '8px' }}>
{activeOps.ongoingStars.map((repo, index) => {
// Find which client is processing this repo
const clientKey = Object.entries(activeOps.busyClients || {})
.find(([_, r]) => r === repo)?.[0];

return (
<div
key={index}
style={{
display: 'flex',
alignItems: 'center',
justifyContent: 'space-between',
padding: '12px 16px',
background: 'rgba(16, 185, 129, 0.1)',
borderRadius: '8px',
border: '1px solid rgba(16, 185, 129, 0.2)',
}}
>
<div style={{ display: 'flex', alignItems: 'center', gap: '12px' }}>
<div style={{
width: '8px',
height: '8px',
borderRadius: '50%',
background: '#10b981',
animation: 'pulse 2s infinite',
}} />
<span style={{ color: '#fff', fontSize: '14px', fontFamily: 'monospace' }}>
{repo}
</span>
</div>
{clientKey && (
<span style={{
color: '#9ca3af',
fontSize: '12px',
background: 'rgba(255,255,255,0.1)',
padding: '2px 8px',
borderRadius: '4px',
}}>
{clientKey}
</span>
)}
</div>
);
})}
</div>
)}

<div style={{
marginTop: '16px',
fontSize: '11px',
color: '#6b7280',
textAlign: 'right',
}}>
Updates every 5 seconds
</div>
</div>
</div>
);
};
Expand Down