add jest testings

packages/jest-environment-miniflare/test/fixtures/analyticsEngine.worker.spec.js

@@ -0,0 +1,25 @@
+async function get() {
+ // return fetch("http:https://localhost/cdn-cgi/mf/analytics_engine/sql", {
+ // method: "POST",
+ // body: "SELECT value FROM entries LIMIT 1;",
+ // }).then(async (b) => await b.json());
+ return queryMiniflareAnalyticsEngine(
+ "SELECT dataset, blob1, blob2, blob3, double1, double2, double3 FROM AE_TEST_DB LIMIT 1;"
+ );
+}
+
+test("AE test 1", async () => {
+ await AE_TEST_DB.writeDataPoint({
+ blobs: ["a", "b", "c"],
+ doubles: [0, 1, 2],
+ });
+ expect(await get()).toMatchObject({
+ dataset: "AE_TEST_DB",
+ blob1: "a",
+ blob2: "b",
+ blob3: "c",
+ double1: 0,
+ double2: 1,
+ double3: 2,
+ });
+});

packages/jest-environment-miniflare/test/index.spec.ts

@@ -52,6 +52,9 @@ test.serial(
  "MiniflareEnvironment: runs Jest tests with Service Worker format workers",
  async (t) => {
  const [exitCode, output] = await runJest(".worker.spec.js", {
+ analyticsEngines: {
+ AE_TEST_DB: "AE_TEST_DB",
+ },
  kvNamespaces: ["TEST_NAMESPACE"],
  d1Databases: ["__D1_BETA__DB_1"],
  sitePath: fixturesPath,

packages/shared-test-environment/src/globals.ts

@@ -43,6 +43,7 @@ declare global {
  function flushMiniflareDurableObjectAlarms(
  ids: DurableObjectId[]
  ): Promise<void>;
+ function queryMiniflareAnalyticsEngine(query: string): Promise<any>;
 }
 
 export interface MiniflareEnvironmentUtilities {
@@ -62,6 +63,7 @@ export interface MiniflareEnvironmentUtilities {
  event: FetchEvent | ScheduledEvent | ExecutionContext
  ): Promise<WaitUntil>;
  flushMiniflareDurableObjectAlarms(ids: DurableObjectId[]): Promise<void>;
+ queryMiniflareAnalyticsEngine(query: string): Promise<any>;
 }
 
 export async function createMiniflareEnvironmentUtilities(
@@ -106,5 +108,11 @@ export async function createMiniflareEnvironmentUtilities(
  const factory = mf.getPluginStorage("DurableObjectsPlugin");
  return plugin.flushAlarms(factory, ids);
  },
+ async queryMiniflareAnalyticsEngine(query: string): Promise<any> {
+ const plugin = (await mf.getPlugins()).AnalyticsEnginePlugin;
+ const storage = mf.getPluginStorage("AnalyticsEnginePlugin");
+ const aeDB = await plugin.getStorage(storage);
+ return aeDB.prepare(query).get();
+ },
  };
 }