@d1testflare/scheduler
Advanced tools
@@ -1,9 +0,9 @@ | ||
| import { CorePluginSignatures } from '@d1testflare/core'; | ||
| import { CorePluginSignatures } from '@miniflare/core'; | ||
| import type { Cron } from 'cron-schedule'; | ||
| import type { ITimerHandle } from 'cron-schedule'; | ||
| import { MiniflareCore } from '@d1testflare/core'; | ||
| import { MiniflareError } from '@d1testflare/shared'; | ||
| import { Plugin } from '@d1testflare/shared'; | ||
| import { PluginContext } from '@d1testflare/shared'; | ||
| import { ReloadEvent } from '@d1testflare/core'; | ||
| import { MiniflareCore } from '@miniflare/core'; | ||
| import { MiniflareError } from '@miniflare/shared'; | ||
| import { Plugin } from '@miniflare/shared'; | ||
| import { PluginContext } from '@miniflare/shared'; | ||
| import { ReloadEvent } from '@miniflare/core'; | ||
@@ -15,2 +15,3 @@ export declare class CronScheduler<Plugins extends SchedulerPluginSignatures> { | ||
| private scheduledHandles?; | ||
| private inaccurateCpu?; | ||
| constructor(mf: MiniflareCore<Plugins>, cronScheduler?: Promise<CronSchedulerImpl>); | ||
@@ -17,0 +18,0 @@ [kReload]: (event: ReloadEvent<Plugins>) => Promise<void>; |
@@ -99,4 +99,6 @@ var __create = Object.create; | ||
| scheduledHandles; | ||
| inaccurateCpu; | ||
| [kReload] = async (event) => { | ||
| const validatedCrons = event.plugins.SchedulerPlugin.validatedCrons; | ||
| this.inaccurateCpu = event.plugins.CorePlugin.inaccurateCpu; | ||
| if (this.previousValidatedCrons === validatedCrons) | ||
@@ -113,5 +115,7 @@ return; | ||
| const start = process.hrtime(); | ||
| const startCpu = this.inaccurateCpu ? process.cpuUsage() : void 0; | ||
| const waitUntil = this.mf.dispatchScheduled(void 0, spec); | ||
| await (0, import_core.logResponse)(this.mf.log, { | ||
| start, | ||
| startCpu, | ||
| method: "SCHD", | ||
@@ -118,0 +122,0 @@ url: spec, |
| { | ||
| "version": 3, | ||
| "sources": ["../../src/index.ts", "../../src/plugin.ts"], | ||
| "mappings": ";;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA,kBAKO;;;ACLP,oBAMO;AAKA,mCAA6B,6BAAmC;AAAA;AAMhE,oCACG,qBAEV;AAAA,EAQE;AAAA,oBAE0B;AAAA,EAE1B,YAAY,KAAoB,SAA4B;AAC1D,UAAM;AACN,SAAK,cAAc;AAAA;AAAA,MAGjB,iBAAyB;AAC3B,WAAO;AAAA;AAAA,QAGH,QAAuB;AAC3B,QAAI,CAAC,KAAK,OAAO,QAAQ;AACvB,6BAAuB;AACvB;AAAA;AAEF,UAAM;AAAA,MACJ;AAAA,QACkC,QAAQ;AAC5C,UAAM,iBAAiB,MAAM,KAAK,MAAM;AACxC,aAAS,IAAI,GAAG,IAAI,KAAK,MAAM,QAAQ,KAAK;AAC1C,YAAM,OAAO,KAAK,MAAM;AACxB,UAAI;AACF,cAAM,OAAO,oBAAoB;AACjC,aAAK,WAAW,MAAM;AACtB,uBAAe,KAAK;AAAA,eACb,GAAP;AACA,cAAM,IAAI,eACR,oBACA,yBAAyB,UAAU,EAAE;AAAA;AAAA;AAI3C,2BAAuB;AAAA;AAAA;AAnCzB;AAAA,EAPC,0BAAO;AAAA,IACN,MAAM,yBAAW;AAAA,IACjB,OAAO;AAAA,IACP,aAAa;AAAA,IACb,SAAS;AAAA,IACT,cAAc,CAAC,EAAE,eAAe,UAAU;AAAA;AAAA,GAE5C,AAXK,gBAWL;;;ADRF,IAAM,UAAU,OAAO;AAEhB,0BAA+D;AAAA,EAKpE,YACmB,IACA,gBAA4C,QAAQ,UAAU,KAC7E,MAAM,QAAQ,iBAAiB,0BAEjC;AAJiB;AACA;AAIjB,OAAG,iBAAiB,UAAU,KAAK;AAAA;AAAA,EAT7B;AAAA,EACA;AAAA,GAWP,WAAW,OAAO,UAA+C;AAChE,UAAM,iBAAiB,MAAM,QAAQ,gBAAgB;AAGrD,QAAI,KAAK,2BAA2B;AAAgB;AACpD,SAAK,yBAAyB;AAE9B,UAAM,gBAAgB,MAAM,KAAK;AAGjC,SAAK,kBAAkB,QAAQ,CAAC,WAC9B,cAAc,uBAAuB;AAEvC,QAAI,CAAC,eAAe;AAAQ;AAE5B,SAAK,mBAAmB,gBAAgB,IAAI,CAAC,SAAS;AACpD,YAAM,OAAO,KAAK;AAClB,aAAO,cAAc,YAAY,MAAM,YAAY;AACjD,cAAM,QAAQ,QAAQ;AAEtB,cAAM,YAAY,KAAK,GAAG,kBAAkB,QAAW;AACvD,cAAM,6BAAY,KAAK,GAAG,KAAK;AAAA,UAC7B;AAAA,UACA,QAAQ;AAAA,UACR,KAAK;AAAA,UACL;AAAA;AAAA;AAAA;AAAA;AAAA,QAMF,UAAyB;AAC7B,SAAK,GAAG,oBAAoB,UAAU,KAAK;AAC3C,UAAM,gBAAgB,MAAM,KAAK;AACjC,SAAK,kBAAkB,QAAQ,CAAC,WAC9B,cAAc,uBAAuB;AAAA;AAAA;AAK3C,8BACE,IACA,eACiC;AACjC,QAAM,YAAY,IAAI,cAAc,IAAI;AACxC,QAAM,cAAc,IAAI,wBAAY,UAAU;AAAA,IAC5C,SAAS,MAAM,GAAG;AAAA,IAClB,SAAS;AAAA;AAEX,QAAM,UAAU,SAAS;AACzB,SAAO;AAAA;", | ||
| "mappings": ";;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA,kBAKO;;;ACLP,oBAMO;AAKA,mCAA6B,6BAAmC;AAAA;AAMhE,oCACG,qBAEV;AAAA,EAQE;AAAA,oBAE0B;AAAA,EAE1B,YAAY,KAAoB,SAA4B;AAC1D,UAAM;AACN,SAAK,cAAc;AAAA;AAAA,MAGjB,iBAAyB;AAC3B,WAAO;AAAA;AAAA,QAGH,QAAuB;AAC3B,QAAI,CAAC,KAAK,OAAO,QAAQ;AACvB,6BAAuB;AACvB;AAAA;AAEF,UAAM;AAAA,MACJ;AAAA,QACkC,QAAQ;AAC5C,UAAM,iBAAiB,MAAM,KAAK,MAAM;AACxC,aAAS,IAAI,GAAG,IAAI,KAAK,MAAM,QAAQ,KAAK;AAC1C,YAAM,OAAO,KAAK,MAAM;AACxB,UAAI;AACF,cAAM,OAAO,oBAAoB;AACjC,aAAK,WAAW,MAAM;AACtB,uBAAe,KAAK;AAAA,eACb,GAAP;AACA,cAAM,IAAI,eACR,oBACA,yBAAyB,UAAU,EAAE;AAAA;AAAA;AAI3C,2BAAuB;AAAA;AAAA;AAnCzB;AAAA,EAPC,0BAAO;AAAA,IACN,MAAM,yBAAW;AAAA,IACjB,OAAO;AAAA,IACP,aAAa;AAAA,IACb,SAAS;AAAA,IACT,cAAc,CAAC,EAAE,eAAe,UAAU;AAAA;AAAA,GAE5C,AAXK,gBAWL;;;ADRF,IAAM,UAAU,OAAO;AAEhB,0BAA+D;AAAA,EAMpE,YACmB,IACA,gBAA4C,QAAQ,UAAU,KAC7E,MAAM,QAAQ,iBAAiB,0BAEjC;AAJiB;AACA;AAIjB,OAAG,iBAAiB,UAAU,KAAK;AAAA;AAAA,EAV7B;AAAA,EACA;AAAA,EACA;AAAA,GAWP,WAAW,OAAO,UAA+C;AAChE,UAAM,iBAAiB,MAAM,QAAQ,gBAAgB;AACrD,SAAK,gBAAgB,MAAM,QAAQ,WAAW;AAG9C,QAAI,KAAK,2BAA2B;AAAgB;AACpD,SAAK,yBAAyB;AAE9B,UAAM,gBAAgB,MAAM,KAAK;AAGjC,SAAK,kBAAkB,QAAQ,CAAC,WAC9B,cAAc,uBAAuB;AAEvC,QAAI,CAAC,eAAe;AAAQ;AAE5B,SAAK,mBAAmB,gBAAgB,IAAI,CAAC,SAAS;AACpD,YAAM,OAAO,KAAK;AAClB,aAAO,cAAc,YAAY,MAAM,YAAY;AACjD,cAAM,QAAQ,QAAQ;AACtB,cAAM,WAAW,KAAK,gBAAgB,QAAQ,aAAa;AAE3D,cAAM,YAAY,KAAK,GAAG,kBAAkB,QAAW;AACvD,cAAM,6BAAY,KAAK,GAAG,KAAK;AAAA,UAC7B;AAAA,UACA;AAAA,UACA,QAAQ;AAAA,UACR,KAAK;AAAA,UACL;AAAA;AAAA;AAAA;AAAA;AAAA,QAMF,UAAyB;AAC7B,SAAK,GAAG,oBAAoB,UAAU,KAAK;AAC3C,UAAM,gBAAgB,MAAM,KAAK;AACjC,SAAK,kBAAkB,QAAQ,CAAC,WAC9B,cAAc,uBAAuB;AAAA;AAAA;AAK3C,8BACE,IACA,eACiC;AACjC,QAAM,YAAY,IAAI,cAAc,IAAI;AACxC,QAAM,cAAc,IAAI,wBAAY,UAAU;AAAA,IAC5C,SAAS,MAAM,GAAG;AAAA,IAClB,SAAS;AAAA;AAEX,QAAM,UAAU,SAAS;AACzB,SAAO;AAAA;", | ||
| "names": [] | ||
| } |
+4
-4
| { | ||
| "name": "@d1testflare/scheduler", | ||
| "version": "2.7.1", | ||
| "version": "2.9.0", | ||
| "description": "Scheduler module for Miniflare: a fun, full-featured, fully-local simulator for Cloudflare Workers", | ||
@@ -38,9 +38,9 @@ "keywords": [ | ||
| "dependencies": { | ||
| "@d1testflare/core": "2.7.1", | ||
| "@d1testflare/shared": "2.7.1", | ||
| "@d1testflare/core": "2.9.0", | ||
| "@d1testflare/shared": "2.9.0", | ||
| "cron-schedule": "^3.0.4" | ||
| }, | ||
| "devDependencies": { | ||
| "@d1testflare/shared-test": "2.7.1" | ||
| "@d1testflare/shared-test": "2.9.0" | ||
| } | ||
| } |
11392
2.57%186
2.76%+ Added
+ Added
+ Added
+ Added
+ Added
+ Added
+ Added
+ Added
+ Added
+ Added
+ Added
+ Added
+ Added
+ Added
+ Added
+ Added
+ Added
+ Added
+ Added
+ Added
+ Added
+ Added
+ Added
+ Added
+ Added
+ Added
+ Added
+ Added
- Removed
- Removed
- Removed
Updated
Updated