refactor: remove "evaluate" and "evaluate-config" events.

- Eliminated the emitEvaluationEvents configuration option and related logic.
- Cleaned up tests to reflect the removal of evaluation event handling.

Author: Swiftwork

packages/node-sdk/src/client.ts

@@ -78,7 +78,7 @@ type BulkEvent =
     }
   | {
       type: "feature-flag-event";
-      action: "check" | "evaluate" | "check-config" | "evaluate-config";
+      action: "check" | "check-config";
       key: string;
       targetingVersion?: number;
       evalResult:
@@ -126,7 +126,6 @@ export class ReflagClient {
     fallbackFlags?: Record<TypedFlagKey, RawFlag>;
     flagOverrides: FlagOverridesFn;
     offline: boolean;
-    emitEvaluationEvents: boolean;
     configFile?: string;
     flagsFetchRetries: number;
     fetchTimeoutMs: number;
@@ -302,7 +301,6 @@ export class ReflagClient {
 
     this._config = {
       offline,
-      emitEvaluationEvents: config.emitEvaluationEvents ?? true,
       apiBaseUrl: (config.apiBaseUrl ?? config.host) || API_BASE_URL,
       headers: {
         "Content-Type": "application/json",
@@ -841,10 +839,7 @@ export class ReflagClient {
     ok(typeof event === "object", "event must be an object");
     ok(
       typeof event.action === "string" &&
-        (event.action === "evaluate" ||
-          event.action === "evaluate-config" ||
-          event.action === "check" ||
-          event.action === "check-config"),
+        (event.action === "check" || event.action === "check-config"),
       "event must have an action",
     );
     ok(
@@ -883,13 +878,6 @@ export class ReflagClient {
       return;
     }
 
-    if (
-      !this._config.emitEvaluationEvents &&
-      (event.action === "evaluate" || event.action === "evaluate-config")
-    ) {
-      return;
-    }
-
     if (
       !this.rateLimiter.isAllowed(
         hashObject({
@@ -1056,7 +1044,7 @@ export class ReflagClient {
       flagDefinitions = flagDefs;
     }
 
-    const { enableTracking = true, meta: _, ...context } = options;
+    const { enableTracking: _, meta: __, ...context } = options;
 
     const evaluated = flagDefinitions
       .filter(({ key: flagKey }) => (key ? key === flagKey : true))
@@ -1076,55 +1064,6 @@ export class ReflagClient {
           } satisfies EvaluationResult<any>),
       }));
 
-    if (enableTracking) {
-      const promises = evaluated
-        .map((res) => {
-          const outPromises: Promise<void>[] = [];
-          outPromises.push(
-            this.sendFlagEvent({
-              action: "evaluate",
-              key: res.flagKey,
-              targetingVersion: res.targetingVersion,
-              evalResult: res.enabledResult.value ?? false,
-              evalContext: res.enabledResult.context,
-              evalRuleResults: res.enabledResult.ruleEvaluationResults,
-              evalMissingFields: res.enabledResult.missingContextFields,
-            }),
-          );
-
-          const config = res.configResult;
-          if (config.value) {
-            outPromises.push(
-              this.sendFlagEvent({
-                action: "evaluate-config",
-                key: res.flagKey,
-                targetingVersion: res.configVersion,
-                evalResult: config.value,
-                evalContext: config.context,
-                evalRuleResults: config.ruleEvaluationResults,
-                evalMissingFields: config.missingContextFields,
-              }),
-            );
-          }
-
-          return outPromises;
-        })
-        .flat();
-
-      void Promise.allSettled(promises).then((results) => {
-        const failed = results
-          .map((result) =>
-            result.status === "rejected" ? result.reason : undefined,
-          )
-          .filter(Boolean);
-        if (failed.length > 0) {
-          this.logger.error(`failed to queue some evaluate events.`, {
-            errors: failed,
-          });
-        }
-      });
-    }
-
     let evaluatedFlags = evaluated.reduce(
       (acc, res) => {
         acc[res.flagKey as TypedFlagKey] = {

packages/node-sdk/src/types.ts

@@ -18,13 +18,13 @@ export type TrackingMeta = {
 export type Attributes = Record<string, any>;
 
 /**
- * Describes a feature event. Can be "check" or "evaluate".
+ * Describes a feature event. Can be "check" .
  **/
 export type FlagEvent = {
   /**
    * The action that was performed.
    **/
-  action: "evaluate" | "evaluate-config" | "check" | "check-config";
+  action: "check" | "check-config";
 
   /**
    * The feature key.

packages/node-sdk/test/client.test.ts

@@ -10,8 +10,6 @@ import {
   vi,
 } from "vitest";
 
-import { flattenJSON } from "@reflag/flag-evaluation";
-
 import { BoundReflagClient, ReflagClient } from "../src";
 import {
   API_BASE_URL,
@@ -1082,95 +1080,6 @@ describe("ReflagClient", () => {
             type: "user",
             userId: "user123",
           },
-          {
-            type: "feature-flag-event",
-            action: "evaluate",
-            key: "flag1",
-            targetingVersion: 1,
-            evalContext: flattenJSON(context),
-            evalResult: true,
-            evalRuleResults: [true],
-            evalMissingFields: [],
-          },
-          {
-            type: "feature-flag-event",
-            action: "evaluate-config",
-            key: "flag1",
-            targetingVersion: 1,
-            evalContext: flattenJSON(context),
-            evalResult: {
-              key: "config-1",
-              payload: {
-                something: "else",
-              },
-            },
-            evalRuleResults: [true],
-            evalMissingFields: [],
-          },
-          {
-            type: "event",
-            event: "flag1",
-            userId: user.id,
-            companyId: company.id,
-          },
-        ],
-      );
-    });
-
-    it("`track` does not send evaluation events when `emitEvaluationEvents` is `false`", async () => {
-      client = new ReflagClient({
-        ...validOptions,
-        emitEvaluationEvents: false,
-      });
-
-      const context = {
-        company,
-        user,
-        other: otherContext,
-      };
-
-      // test that the flag is returned
-      await client.initialize();
-      const flag = client.getFlag(
-        {
-          ...context,
-          meta: {
-            active: true,
-          },
-          enableTracking: true,
-        },
-        "flag1",
-      );
-
-      await flag.track();
-      await client.flush();
-
-      expect(httpClient.post).toHaveBeenCalledWith(
-        BULK_ENDPOINT,
-        expectedHeaders,
-        [
-          {
-            attributes: {
-              employees: 100,
-              name: "Acme Inc.",
-            },
-            companyId: "company123",
-            context: {
-              active: true,
-            },
-            type: "company",
-          },
-          {
-            attributes: {
-              age: 1,
-              name: "John",
-            },
-            context: {
-              active: true,
-            },
-            type: "user",
-            userId: "user123",
-          },
           {
             type: "event",
             event: "flag1",
@@ -1560,8 +1469,6 @@ describe("ReflagClient", () => {
       });
 
       await client.flush();
-
-      expect(httpClient.post).toHaveBeenCalledTimes(1);
     });
 
     it("should send `track` with user and company if provided", async () => {
@@ -1775,41 +1682,6 @@ describe("ReflagClient", () => {
       );
     });
 
-    it("should not fail if sendFlagEvent fails to send evaluate event", async () => {
-      httpClient.post.mockRejectedValueOnce(new Error("Network error"));
-      const context = { user, company, other: otherContext };
-
-      await client.initialize();
-      const flags = client.getFlags(context);
-
-      await client.flush();
-
-      expect(logger.error).toHaveBeenCalledWith(
-        expect.stringMatching("post request .* failed with error"),
-        expect.any(Error),
-      );
-
-      expect(flags).toStrictEqual({
-        flag1: {
-          key: "flag1",
-          isEnabled: true,
-          config: {
-            key: "config-1",
-            payload: {
-              something: "else",
-            },
-          },
-          track: expect.any(Function),
-        },
-        flag2: {
-          key: "flag2",
-          isEnabled: false,
-          config: { key: undefined, payload: undefined },
-          track: expect.any(Function),
-        },
-      });
-    });
-
     it("should not fail if sendFlagEvent fails to send check event", async () => {
       httpClient.post.mockResolvedValue({
         status: 200,