@miniflare/core - npm Package Compare versions

Comparing version 2.7.1 to 2.8.0

dist/src/index.d.ts

@@ -15,2 +15,3 @@ /// <reference types="node" />
 import { Log } from '@miniflare/shared';
+import { MessageBatch } from '@miniflare/shared';
 import { MiniflareError } from '@miniflare/shared';
@@ -25,2 +26,3 @@ import { MockAgent } from 'undici';
 import { ProcessedModuleRule } from '@miniflare/shared';
+import { QueueBroker } from '@miniflare/queues';
 import { ReadableStream } from 'stream/web';
@@ -46,2 +48,3 @@ import { ReferrerPolicy } from 'undici';
 import { TransformStream } from 'stream/web';
+import { TransformStreamDefaultController } from 'stream/web';
 import { TypedEventListener } from '@miniflare/shared';
@@ -51,3 +54,2 @@ import { TypedEventTarget } from '@miniflare/shared';
 import { UsageModel } from '@miniflare/shared';
-import { ValueOf } from '@miniflare/shared';
 import { webcrypto } from 'crypto';
@@ -187,2 +189,3 @@ import type { WebSocket } from '@miniflare/web-sockets';
     actualTime?: boolean;
+    inaccurateCpu?: boolean;
 }
@@ -218,2 +221,3 @@
     actualTime?: boolean;
+    inaccurateCpu?: boolean;
     readonly processedModuleRules: ProcessedModuleRule[];
@@ -311,3 +315,3 @@ readonly upstreamURL?: URL_2;
     #private;
-    constructor(event: FetchEvent | ScheduledEvent);
+    constructor(event: FetchEvent | ScheduledEvent | QueueEvent);
     passThroughOnException(): void;
@@ -341,3 +345,3 @@ waitUntil(promise: Awaitable<any>): void;
     [kPassThrough]: boolean;
-    readonly [kWaitUntil_2]: Promise<unknown>[];
+    readonly [kWaitUntil]: Promise<unknown>[];
     [kSent]: boolean;
@@ -352,4 +356,7 @@ constructor(type: "fetch", init: {
 
-export declare class FixedLengthStream extends TransformStream<Uint8Array, Uint8Array> {
+export declare class FixedLengthStream extends IdentityTransformStream {
+    #private;
     constructor(expectedLength: number);
+    [kTransformHook]: (chunk: Uint8Array, controller: TransformStreamDefaultController<Uint8Array>) => boolean;
+    [kFlushHook]: (controller: TransformStreamDefaultController<Uint8Array>) => void;
 }
@@ -367,2 +374,10 @@
 
+export declare class IdentityTransformStream extends TransformStream<Uint8Array, Uint8Array> {
+    #private;
+    [kTransformHook]?: (chunk: Uint8Array, controller: TransformStreamDefaultController<Uint8Array>) => boolean;
+    [kFlushHook]?: (controller: TransformStreamDefaultController<Uint8Array>) => void;
+    constructor();
+    get readable(): ReadableStream<Uint8Array>;
+}
+
 export declare interface IncomingRequestCfProperties {
@@ -417,2 +432,4 @@ asn: number;
 
+export declare const kAddModuleQueueListener: unique symbol;
+
 export declare const kAddModuleScheduledListener: unique symbol;
@@ -424,2 +441,4 @@
 
+export declare const kDispatchQueue: unique symbol;
+
 export declare const kDispatchScheduled: unique symbol;
@@ -429,2 +448,4 @@
 
+declare const kFlushHook: unique symbol;
+
 declare const kFormDataFiles: unique symbol;
@@ -444,4 +465,6 @@
 
-declare const kWaitUntil: unique symbol;
+declare const kTransformHook: unique symbol;
 
+export declare const kWaitUntil: unique symbol;
+
 declare const kWaitUntil_2: unique symbol;
@@ -451,4 +474,5 @@
 
-export declare function logResponse(log: Log, { start, method, url, status, waitUntil, }: {
+export declare function logResponse(log: Log, { start, startCpu, method, url, status, waitUntil, }: {
     start: HRTime;
+    startCpu?: NodeJS.CpuUsage;
     method: string;
@@ -475,2 +499,3 @@ url: string;
     dispatchScheduled<WaitUntil extends any[] = unknown[]>(scheduledTime?: number, cron?: string, url?: string | URL_2): Promise<WaitUntil>;
+    dispatchQueue<WaitUntil extends any[] = unknown[]>(batch: MessageBatch): Promise<WaitUntil>;
     dispose(): Promise<void>;
@@ -482,2 +507,3 @@ }
     storageFactory: StorageFactory;
+    queueBroker: QueueBroker;
     scriptRunner?: ScriptRunner;
@@ -504,2 +530,4 @@ scriptRequired?: boolean;
 
+export declare type ModuleQueueListener = (batch: MessageBatch, env: Context, ctx: ExecutionContext) => any;
+
 export declare type ModuleScheduledListener = (controller: ScheduledController, env: Context, ctx: ExecutionContext) => any;
@@ -535,2 +563,11 @@
 
+export declare class QueueEvent extends Event {
+    readonly batch: MessageBatch;
+    readonly [kWaitUntil]: Promise<unknown>[];
+    constructor(type: "queue", init: {
+        batch: MessageBatch;
+    });
+    waitUntil(promise: Promise<any>): void;
+}
+
 export declare class ReloadEvent<Plugins extends PluginSignatures> extends Event {
@@ -620,6 +657,6 @@ readonly plugins: PluginInstances<Plugins>;
     static json(data: any, init?: ResponseInit): Response;
-    [kWaitUntil]?: Promise<WaitUntil>;
+    [kWaitUntil_2]?: Promise<WaitUntil>;
     constructor(body?: BodyInit, init?: ResponseInit | Response | Response_2);
     clone(): Response;
-    get encodeBody(): "auto" | "manual";
+    get encodeBody(): "automatic" | "manual";
     get webSocket(): WebSocket | undefined;
@@ -636,3 +673,3 @@ waitUntil(): Promise<WaitUntil>;
 export declare interface ResponseInit extends ResponseInit_2 {
-    readonly encodeBody?: "auto" | "manual";
+    readonly encodeBody?: "automatic" | "manual";
     readonly webSocket?: WebSocket;
@@ -675,3 +712,3 @@ }
     readonly cron: string;
-    readonly [kWaitUntil_2]: Promise<unknown>[];
+    readonly [kWaitUntil]: Promise<unknown>[];
     constructor(type: "scheduled", init: {
@@ -706,7 +743,8 @@ scheduledTime: number;
     removeEventListener: <Type extends keyof WorkerGlobalScopeEventMap>(type: Type, listener: TypedEventListener<WorkerGlobalScopeEventMap[Type]> | null, options?: boolean | EventListenerOptions | undefined) => void;
-    dispatchEvent: (event: ValueOf<WorkerGlobalScopeEventMap>) => boolean;
     [kAddModuleFetchListener](listener: ModuleFetchListener): void;
     [kAddModuleScheduledListener](listener: ModuleScheduledListener): void;
+    [kAddModuleQueueListener](listener: ModuleQueueListener): void;
     [kDispatchFetch]<WaitUntil extends any[] = unknown[]>(request: Request, proxy?: boolean): Promise<Response<WaitUntil>>;
     [kDispatchScheduled]<WaitUntil extends any[] = any[]>(scheduledTime?: number, cron?: string): Promise<WaitUntil>;
+    [kDispatchQueue]<WaitUntil extends any[] = any[]>(batch: MessageBatch): Promise<WaitUntil>;
     [kDispose](): void;
@@ -719,3 +757,3 @@ }
 
-export declare function withImmutableHeaders(req: Request): Request;
+export declare function withImmutableHeaders<Body extends Request | Response>(body: Body): Body;
 
@@ -738,2 +776,3 @@ export declare function withInputGating<Inner extends Body<Request_2 | Response_2>>(body: Inner): Inner;
     scheduled: ScheduledEvent;
+    queue: QueueEvent;
     unhandledrejection: PromiseRejectionEvent;
@@ -740,0 +779,0 @@ rejectionhandled: PromiseRejectionEvent;

package.json

 {
   "name": "@miniflare/core",
-  "version": "2.7.1",
+  "version": "2.8.0",
   "description": "Core module for Miniflare: a fun, full-featured, fully-local simulator for Cloudflare Workers",
@@ -42,4 +42,4 @@ "keywords": [
     "@iarna/toml": "^2.2.5",
-    "@miniflare/shared": "2.7.1",
-    "@miniflare/watcher": "2.7.1",
+    "@miniflare/shared": "2.8.0",
+    "@miniflare/watcher": "2.8.0",
     "busboy": "^1.6.0",
@@ -53,6 +53,6 @@ "dotenv": "^10.0.0",
   "devDependencies": {
-    "@miniflare/durable-objects": "2.7.1",
-    "@miniflare/shared-test": "2.7.1",
-    "@miniflare/watcher": "2.7.1",
-    "@miniflare/web-sockets": "2.7.1",
+    "@miniflare/durable-objects": "2.8.0",
+    "@miniflare/shared-test": "2.8.0",
+    "@miniflare/watcher": "2.8.0",
+    "@miniflare/web-sockets": "2.8.0",
     "@types/busboy": "^1.5.0",
@@ -59,0 +59,0 @@ "@types/set-cookie-parser": "^2.4.1",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Debug access

Supply chain risk

Uses debug, reflection and dynamic code execution features.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

205774

increased by6.36%

Lines of code

3944

increased by6.28%

Number of low supply chain risk alerts

6

decreased by-14.29%

Dependency changes

• + Added@miniflare/shared@2.8.0(transitive)

• + Added@miniflare/watcher@2.8.0(transitive)

• - Removed@miniflare/shared@2.7.1(transitive)

• - Removed@miniflare/watcher@2.7.1(transitive)

• Updated@miniflare/shared@2.8.0

• Updated@miniflare/watcher@2.8.0