Jeroen SchweitzerandClaude Opus 4.6
0485a36091
test / unit + widget + golden + a11y (push) Failing after 33s
test / integration_test (xvfb) (push) Has been skipped
test / bundle smoke (xvfb 5s) (push) Has been skipped
test / daemon subprocess + web WASM smoke (push) Has been skipped
Firing all tier ticks simultaneously on project open causes multiple IPC calls (pql, git, files) to run in parallel, their responses triggering rapid setState rebuilds that beachball the merged thread. Stagger 500ms apart so each panel refreshes sequentially. Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
105 lines
2.8 KiB
Dart
105 lines
2.8 KiB
Dart
import 'dart:async';
|
|
import 'dart:isolate';
|
|
|
|
import 'package:clide/kernel/src/events/bus.dart';
|
|
import 'package:clide/kernel/src/events/types.dart';
|
|
import 'package:flutter/foundation.dart';
|
|
|
|
enum SchedulerTier {
|
|
oneMinute(Duration(minutes: 1)),
|
|
tenMinutes(Duration(minutes: 10)),
|
|
fifteenMinutes(Duration(minutes: 15)),
|
|
oneHour(Duration(hours: 1)),
|
|
midnight(Duration(minutes: 1));
|
|
|
|
const SchedulerTier(this.interval);
|
|
final Duration interval;
|
|
}
|
|
|
|
@immutable
|
|
class SchedulerTick extends ClideEvent {
|
|
const SchedulerTick({required this.tier});
|
|
final SchedulerTier tier;
|
|
|
|
@override
|
|
String get subsystem => 'scheduler';
|
|
@override
|
|
String get kind => 'tick';
|
|
@override
|
|
Map<String, Object?> payload() => {'tier': tier.name};
|
|
}
|
|
|
|
class SchedulerService {
|
|
SchedulerService(this._events);
|
|
final DaemonBus _events;
|
|
|
|
Isolate? _isolate;
|
|
ReceivePort? _port;
|
|
StreamSubscription<dynamic>? _sub;
|
|
StreamSubscription<dynamic>? _projectSub;
|
|
|
|
/// Listen for project lifecycle events. The periodic ticker only runs
|
|
/// while a project is open — no wasted cycles on the welcome screen.
|
|
void start() {
|
|
_projectSub = _events.on<ProjectOpened>().listen((_) => _startTicker());
|
|
_events.on<ProjectClosed>().listen((_) => _stopTicker());
|
|
}
|
|
|
|
/// Start the periodic ticker and fire an immediate first cycle so
|
|
/// all panels refresh without waiting for the first interval.
|
|
void _startTicker() {
|
|
_stopTicker();
|
|
|
|
// Stagger the initial ticks to avoid a rebuild storm on project open.
|
|
var delay = 0;
|
|
for (final tier in SchedulerTier.values) {
|
|
if (tier == SchedulerTier.midnight) continue;
|
|
Timer(Duration(milliseconds: delay), () {
|
|
_events.emit(SchedulerTick(tier: tier));
|
|
});
|
|
delay += 500;
|
|
}
|
|
|
|
// Then start the periodic isolate.
|
|
_port = ReceivePort();
|
|
_sub = _port!.listen((msg) {
|
|
if (msg is String) {
|
|
final tier = SchedulerTier.values.firstWhere((t) => t.name == msg);
|
|
_events.emit(SchedulerTick(tier: tier));
|
|
}
|
|
});
|
|
Isolate.spawn(_isolateEntry, _port!.sendPort).then((iso) => _isolate = iso);
|
|
}
|
|
|
|
void _stopTicker() {
|
|
_sub?.cancel();
|
|
_port?.close();
|
|
_isolate?.kill(priority: Isolate.immediate);
|
|
_isolate = null;
|
|
_port = null;
|
|
_sub = null;
|
|
}
|
|
|
|
static void _isolateEntry(SendPort send) {
|
|
int lastDay = DateTime.now().day;
|
|
for (final tier in SchedulerTier.values) {
|
|
if (tier == SchedulerTier.midnight) {
|
|
Timer.periodic(const Duration(minutes: 1), (_) {
|
|
final day = DateTime.now().day;
|
|
if (day != lastDay) {
|
|
lastDay = day;
|
|
send.send(tier.name);
|
|
}
|
|
});
|
|
continue;
|
|
}
|
|
Timer.periodic(tier.interval, (_) => send.send(tier.name));
|
|
}
|
|
}
|
|
|
|
void dispose() {
|
|
_projectSub?.cancel();
|
|
_stopTicker();
|
|
}
|
|
}
|