update list

This commit is contained in:
Toki 2024-12-25 15:58:53 +09:00
parent e0b377fc02
commit 3d1bac26be
3 changed files with 14 additions and 9 deletions

View file

@ -1,7 +1,7 @@
---
scheduler:
alias: test
cron: '*/5 * * * *'
cron: '* * * * *'
enableLog: false # (Optional) default: false
property:

View file

@ -22,7 +22,7 @@ class CommandScheduler extends CommandBase {
for (var i = 0; i < parameters.length; ++i) {
var item = parameters[i];
if (item.startsWith('-l')) {
_scheduler.showList();
await _scheduler.showList();
break;
} else if (item.startsWith('-r')) {
var file = '';

View file

@ -47,6 +47,10 @@ class SchedulerManager {
return hash;
}
String get startupID {
return isDebug ? '$appIdendifier.debug' : appIdendifier;
}
SchedulerManager();
factory SchedulerManager.create() {
@ -111,7 +115,7 @@ class SchedulerManager {
}
}
void showList() {
Future showList() async {
print('');
var scheduleList = schedulers;
if(scheduleList.isEmpty) {
@ -126,6 +130,8 @@ class SchedulerManager {
}
print('');
}
checkProcess();
return simpleFuture;
}
Future terminate() async {
@ -158,11 +164,10 @@ class SchedulerManager {
//process check
var processes = await findProcess('scheduler -s');
for(var process in processes) {
print(process.name);
var processName = process.name;
if(processName.contains('main.dart scheduler -s') || processName.contains('$appName scheduler -s')) {
currentScheduler = process;
print('Scheduler is running on pid ${currentScheduler!.pid}.');
print('Scheduler is running on pid [${currentScheduler!.pid}].');
break;
}
}
@ -170,21 +175,21 @@ class SchedulerManager {
}
Future checkStartup() async {
if(!await OSStartup.isRegistedStartup(appIdendifier)) {
if(!await OSStartup.isRegistedStartup(startupID)) {
List<String> param = [];
if(isDebug) {
param.add(scriptPath);
}
param.add('scheduler');
param.add('-s');
await OSStartup.registStartup(executablePath, appIdendifier, arguments: param);
await OSStartup.registStartup(executablePath, startupID, arguments: param);
}
return simpleFuture;
}
Future unregistStartup() async {
if(await OSStartup.isRegistedStartup(appIdendifier)) {
await OSStartup.unregistStartup(appIdendifier);
if(await OSStartup.isRegistedStartup(startupID)) {
await OSStartup.unregistStartup(startupID);
}
return simpleFuture;
}