feat: Added a Lite bundle excluding Data file manager and Event Processor packages. (#699)

## Summary
Some platforms (such as edge providers), do not need extended functionality offered by data file manager and event processor. This PR creates a lite bundle which uses a `NoOpDatafileManager` and a `ForwardingEventProcessor` which immediately dispatches events when a custom event dispatcher is provided. This results in up to 20% reduction in bundle size. This also fixes the errors that SDK was throwing on edge platforms.

### Usage
To use the lite bundle, user needs to explicitly import from it.
`import { createInstance } from '@optimizely/optimizely-sdk/dist/optimizely.lite.es.mins.js'`

## Test plan
1. All the Full stack compatibility suite tests pass for the existing bundles.
2. Fixed all the failing unit tests.
3. Added new unit tests to `lite` entry point.

Author: zashraf1985

packages/optimizely-sdk/lib/core/decision_service/index.tests.js

@@ -24,6 +24,8 @@ import {
   DECISION_SOURCES,
 } from '../../utils/enums';
 import { createLogger } from '../../plugins/logger';
+import { createForwardingEventProcessor } from '../../plugins/event_processor/forwarding_event_processor';
+import { createNotificationCenter } from '../notification_center';
 import Optimizely from '../../optimizely';
 import projectConfig from '../project_config';
 import AudienceEvaluator from '../audience_evaluator';
@@ -980,7 +982,8 @@ describe('lib/core/decision_service', function() {
         jsonSchemaValidator: jsonSchemaValidator,
         isValidInstance: true,
         logger: createdLogger,
-        eventDispatcher: eventDispatcher,
+        eventProcessor: createForwardingEventProcessor(eventDispatcher),
+        notificationCenter: createNotificationCenter(createdLogger, errorHandler),
         errorHandler: errorHandler,
       });
 

packages/optimizely-sdk/lib/core/event_builder/build_event_v1.ts

@@ -0,0 +1,267 @@
+/**
+ * Copyright 2021 Optimizely
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+import {
+  EventTags,
+  ConversionEvent,
+  ImpressionEvent,
+} from '@optimizely/js-sdk-event-processor';
+
+import { Event } from '../../shared_types';
+
+type ProcessableEvent = ConversionEvent | ImpressionEvent
+
+const ACTIVATE_EVENT_KEY = 'campaign_activated'
+const CUSTOM_ATTRIBUTE_FEATURE_TYPE = 'custom'
+const BOT_FILTERING_KEY = '$opt_bot_filtering'
+
+export type EventV1 = {
+  account_id: string
+  project_id: string
+  revision: string
+  client_name: string
+  client_version: string
+  anonymize_ip: boolean
+  enrich_decisions: boolean
+  visitors: Visitor[]
+}
+
+type Visitor = {
+  snapshots: Snapshot[]
+  visitor_id: string
+  attributes: Attribute[]
+}
+
+type AttributeType = 'custom'
+
+export type Attribute = {
+  // attribute id
+  entity_id: string
+  // attribute key
+  key: string
+  type: AttributeType
+  value: string | number | boolean
+}
+
+export type Snapshot = {
+  decisions?: Decision[]
+  events: SnapshotEvent[]
+}
+
+type Decision = {
+  campaign_id: string | null
+  experiment_id: string | null
+  variation_id: string | null
+  metadata: Metadata
+}
+
+type Metadata = {
+  flag_key: string;
+  rule_key: string;
+  rule_type: string;
+  variation_key: string;
+  enabled: boolean;
+}
+
+export type SnapshotEvent = {
+  entity_id: string | null
+  timestamp: number
+  uuid: string
+  key: string
+  revenue?: number
+  value?: number
+  tags?: EventTags
+}
+
+/**
+ * Given an array of batchable Decision or ConversionEvent events it returns
+ * a single EventV1 with proper batching
+ *
+ * @param {ProcessableEvent[]} events
+ * @returns {EventV1}
+ */
+export function makeBatchedEventV1(events: ProcessableEvent[]): EventV1 {
+  const visitors: Visitor[] = []
+  const data = events[0]
+
+  events.forEach(event => {
+    if (event.type === 'conversion' || event.type === 'impression') {
+      const visitor = makeVisitor(event)
+
+      if (event.type === 'impression') {
+        visitor.snapshots.push(makeDecisionSnapshot(event))
+      } else if (event.type === 'conversion') {
+        visitor.snapshots.push(makeConversionSnapshot(event))
+      }
+
+      visitors.push(visitor)
+    }
+  })
+
+  return {
+    client_name: data.context.clientName,
+    client_version: data.context.clientVersion,
+
+    account_id: data.context.accountId,
+    project_id: data.context.projectId,
+    revision: data.context.revision,
+    anonymize_ip: data.context.anonymizeIP,
+    enrich_decisions: true,
+
+    visitors,
+  }
+}
+
+function makeConversionSnapshot(conversion: ConversionEvent): Snapshot {
+  const tags: EventTags = {
+    ...conversion.tags,
+  }
+
+  delete tags['revenue']
+  delete tags['value']
+
+  const event: SnapshotEvent = {
+    entity_id: conversion.event.id,
+    key: conversion.event.key,
+    timestamp: conversion.timestamp,
+    uuid: conversion.uuid,
+  }
+
+  if (conversion.tags) {
+    event.tags = conversion.tags
+  }
+
+  if (conversion.value != null) {
+    event.value = conversion.value
+  }
+
+  if (conversion.revenue != null) {
+    event.revenue = conversion.revenue
+  }
+
+  return {
+    events: [event],
+  }
+}
+
+function makeDecisionSnapshot(event: ImpressionEvent): Snapshot {
+  const { layer, experiment, variation, ruleKey, flagKey, ruleType, enabled } = event
+  const layerId = layer ? layer.id : null
+  const experimentId = experiment ? experiment.id : null
+  const variationId = variation ? variation.id : null
+  const variationKey = variation ? variation.key : ''
+
+  return {
+    decisions: [
+      {
+        campaign_id: layerId,
+        experiment_id: experimentId,
+        variation_id: variationId,
+        metadata: {
+          flag_key: flagKey,
+          rule_key: ruleKey,
+          rule_type: ruleType,
+          variation_key: variationKey,
+          enabled: enabled,
+        },
+      },
+    ],
+    events: [
+      {
+        entity_id: layerId,
+        timestamp: event.timestamp,
+        key: ACTIVATE_EVENT_KEY,
+        uuid: event.uuid,
+      },
+    ],
+  }
+}
+
+function makeVisitor(data: ImpressionEvent | ConversionEvent): Visitor {
+  const visitor: Visitor = {
+    snapshots: [],
+    visitor_id: data.user.id,
+    attributes: [],
+  }
+
+  data.user.attributes.forEach(attr => {
+    visitor.attributes.push({
+      entity_id: attr.entityId,
+      key: attr.key,
+      type: 'custom' as const, // tell the compiler this is always string "custom"
+      value: attr.value,
+    })
+  })
+
+  if (typeof data.context.botFiltering === 'boolean') {
+    visitor.attributes.push({
+      entity_id: BOT_FILTERING_KEY,
+      key: BOT_FILTERING_KEY,
+      type: CUSTOM_ATTRIBUTE_FEATURE_TYPE,
+      value: data.context.botFiltering,
+    })
+  }
+  return visitor
+}
+
+/**
+ * Event for usage with v1 logtier
+ *
+ * @export
+ * @interface EventBuilderV1
+ */
+export function buildImpressionEventV1(data: ImpressionEvent): EventV1 {
+  const visitor = makeVisitor(data)
+  visitor.snapshots.push(makeDecisionSnapshot(data))
+
+  return {
+    client_name: data.context.clientName,
+    client_version: data.context.clientVersion,
+
+    account_id: data.context.accountId,
+    project_id: data.context.projectId,
+    revision: data.context.revision,
+    anonymize_ip: data.context.anonymizeIP,
+    enrich_decisions: true,
+
+    visitors: [visitor],
+  }
+}
+
+export function buildConversionEventV1(data: ConversionEvent): EventV1 {
+  const visitor = makeVisitor(data)
+  visitor.snapshots.push(makeConversionSnapshot(data))
+
+  return {
+    client_name: data.context.clientName,
+    client_version: data.context.clientVersion,
+
+    account_id: data.context.accountId,
+    project_id: data.context.projectId,
+    revision: data.context.revision,
+    anonymize_ip: data.context.anonymizeIP,
+    enrich_decisions: true,
+
+    visitors: [visitor],
+  }
+}
+
+export function formatEvents(events: ProcessableEvent[]): Event {
+  return {
+    url: 'https://logx.optimizely.com/v1/events',
+    httpVerb: 'POST',
+    params: makeBatchedEventV1(events),
+  }
+}