feat: Expose block selector config from rrweb to SR plugin/SDK.

examples/plugins/react-native-get-location-plugin/LocationPlugin.ts

@@ -0,0 +1,39 @@
+import { Types } from '@amplitude/analytics-react-native';
+import GetLocation, { Location } from 'react-native-get-location';
+
+// https://github.com/douglasjunior/react-native-get-location#install - install steps, usage.
+export default class LocationPlugin implements Types.BeforePlugin {
+  name = 'getLocation';
+  type = Types.PluginType.BEFORE as any;
+  config: Types.Config | undefined;
+  location: Location | undefined;
+
+  async setup(config: Types.Config): Promise<undefined> {
+    this.config = config;
+    GetLocation.getCurrentPosition({
+      enableHighAccuracy: true,
+      timeout: 30000,
+      rationale: {
+        title: 'Location permission',
+        message: 'The app needs the permission to request your location.',
+        buttonPositive: 'Ok',
+      },
+    })
+      .then((location) => {
+        this.location = location;
+      })
+      .catch((e) => {
+        config?.loggerProvider?.error(e);
+      });
+
+    return undefined;
+  }
+
+  async execute(context: Types.Event): Promise<Types.Event> {
+    if (this.location) {
+      context.location_lat = this.location.latitude;
+      context.location_lng = this.location.longitude;
+    }
+    return context;
+  }
+}

examples/plugins/react-native-idfa-plugin/idfaPlugin.ts

@@ -0,0 +1,27 @@
+import { Types } from '@amplitude/analytics-react-native';
+import ReactNativeIdfaAaid from '@sparkfabrik/react-native-idfa-aaid';
+
+export default class IdfaPlugin implements Types.BeforePlugin {
+  name = 'idfa';
+  type = Types.PluginType.BEFORE as any;
+  config: Types.Config | undefined;
+  idfa: string | null = null;
+
+  async setup(config: Types.Config): Promise<undefined> {
+    this.config = config;
+    try {
+      const info = await ReactNativeIdfaAaid.getAdvertisingInfo();
+      this.idfa = info.id;
+    } catch (e) {
+      config?.loggerProvider?.error(e);
+    }
+    return undefined;
+  }
+
+  async execute(context: Types.Event): Promise<Types.Event> {
+    if (this.idfa) {
+      context.idfa = this.idfa;
+    }
+    return context;
+  }
+}

examples/react-native/legacyDataMigration/.bundle/config

@@ -0,0 +1,2 @@
+BUNDLE_PATH: "vendor/bundle"
+BUNDLE_FORCE_RUBY_PLATFORM: 1

examples/react-native/legacyDataMigration/.eslintrc.js

@@ -0,0 +1,4 @@
+module.exports = {
+  root: true,
+  extends: '@react-native',
+};

examples/react-native/legacyDataMigration/.gitignore

@@ -0,0 +1,66 @@
+# OSX
+#
+.DS_Store
+
+# Xcode
+#
+build/
+*.pbxuser
+!default.pbxuser
+*.mode1v3
+!default.mode1v3
+*.mode2v3
+!default.mode2v3
+*.perspectivev3
+!default.perspectivev3
+xcuserdata
+*.xccheckout
+*.moved-aside
+DerivedData
+*.hmap
+*.ipa
+*.xcuserstate
+ios/.xcode.env.local
+
+# Android/IntelliJ
+#
+build/
+.idea
+.gradle
+local.properties
+*.iml
+*.hprof
+.cxx/
+*.keystore
+!debug.keystore
+
+# node.js
+#
+node_modules/
+npm-debug.log
+yarn-error.log
+
+# fastlane
+#
+# It is recommended to not store the screenshots in the git repo. Instead, use fastlane to re-generate the
+# screenshots whenever they are needed.
+# For more information about the recommended setup visit:
+# https://docs.fastlane.tools/best-practices/source-control/
+
+**/fastlane/report.xml
+**/fastlane/Preview.html
+**/fastlane/screenshots
+**/fastlane/test_output
+
+# Bundle artifact
+*.jsbundle
+
+# Ruby / CocoaPods
+/ios/Pods/
+/vendor/bundle/
+
+# Temporary files created by Metro to check the health of the file watcher
+.metro-health-check*
+
+# testing
+/coverage

examples/react-native/legacyDataMigration/.prettierrc.js

@@ -0,0 +1,7 @@
+module.exports = {
+  arrowParens: 'avoid',
+  bracketSameLine: true,
+  bracketSpacing: false,
+  singleQuote: true,
+  trailingComma: 'all',
+};

examples/react-native/legacyDataMigration/.watchmanconfig

@@ -0,0 +1 @@
+{}

examples/react-native/legacyDataMigration/App.tsx

@@ -0,0 +1,99 @@
+import React from 'react';
+import {Alert, NativeModules} from 'react-native';
+import {Button, SafeAreaView, StyleSheet} from 'react-native';
+import {createInstance} from '@amplitude/analytics-react-native';
+import {getCookieName} from '@amplitude/analytics-client-common';
+import {UUID, MemoryStorage, STORAGE_PREFIX} from '@amplitude/analytics-core';
+import {Event, UserSession} from '@amplitude/analytics-types';
+import MigrationChecker from './MigrationChecker';
+
+interface MigrationModule {
+  prepareLegacyDatabase(
+    instanceName: string | undefined,
+    version: string,
+  ): Promise<void>;
+}
+
+const migrationModule = NativeModules.MigrationModule as MigrationModule;
+
+const styles = StyleSheet.create({
+  container: {
+    flex: 1,
+    backgroundColor: '#fff',
+    alignItems: 'center',
+    justifyContent: 'center',
+    gap: 10,
+  },
+});
+
+function App(): JSX.Element {
+  return (
+    <SafeAreaView style={styles.container}>
+      <Button
+        title="Migrate Legacy V4"
+        onPress={() => migrateLegacyData('v4')}
+      />
+      <Button
+        title="Migrate Legacy V3"
+        onPress={() => migrateLegacyData('v3')}
+      />
+      <Button
+        title="Migrate Legacy Missing"
+        onPress={() => migrateLegacyData('vMissing')}
+      />
+    </SafeAreaView>
+  );
+}
+
+async function migrateLegacyData(version: 'v4' | 'v3' | 'vMissing') {
+  let instanceName = UUID();
+  let apiKey = UUID();
+  let cookieName = getCookieName(apiKey);
+  let eventsKey = `${STORAGE_PREFIX}_${apiKey.substring(0, 10)}`;
+  await migrationModule.prepareLegacyDatabase(instanceName, version);
+
+  const cookieStorage1 = new MemoryStorage<UserSession>();
+  const storageProvider1 = new MemoryStorage<Event[]>();
+  const amplitude1 = createInstance();
+  await amplitude1.init(apiKey, undefined, {
+    instanceName,
+    cookieStorage: cookieStorage1,
+    storageProvider: storageProvider1,
+    optOut: true,
+    trackingSessionEvents: false,
+  }).promise;
+
+  let checker1 = new MigrationChecker(version);
+  let userSession1 = await cookieStorage1.get(cookieName);
+  const events1 = await storageProvider1.get(eventsKey);
+  checker1.checkUserSession(userSession1);
+  checker1.checkEvents(events1);
+
+  const cookieStorage2 = new MemoryStorage<UserSession>();
+  const storageProvider2 = new MemoryStorage<Event[]>();
+  const amplitude2 = createInstance();
+  await amplitude2.init(apiKey, undefined, {
+    instanceName,
+    cookieStorage: cookieStorage2,
+    storageProvider: storageProvider2,
+    optOut: true,
+    trackingSessionEvents: false,
+  }).promise;
+
+  let checker2 = new MigrationChecker(version);
+  let userSession2 = await cookieStorage2.get(cookieName);
+  const events2 = await storageProvider2.get(eventsKey);
+  checker2.checkUserSession(userSession2);
+  checker2.check(events2?.length === 0, 'events');
+
+  Alert.alert(`\
+First migration: ${
+    checker1.errors.length === 0 ? 'Success' : checker1.errors.join(', ')
+  }
+Second migration: ${
+    checker2.errors.length === 0 ? 'Success' : checker2.errors.join(', ')
+  }
+`);
+}
+
+export default App;

examples/react-native/legacyDataMigration/Gemfile

@@ -0,0 +1,6 @@
+source 'https://rubygems.org'
+
+# You may use http://rbenv.org/ or https://rvm.io/ to install and use this version
+ruby ">= 2.6.10"
+
+gem 'cocoapods', '~> 1.12'

examples/react-native/legacyDataMigration/MigrationChecker.ts

@@ -0,0 +1,133 @@
+import {Event, UserSession} from '@amplitude/analytics-types';
+
+type LegacyEvent = {
+  event_id: number;
+  event_type: string;
+  time: number;
+  insert_id: string;
+};
+
+const legacyDeviceId = '22833898-c487-4536-b213-40f207abdce0R';
+const legacyUserId = 'react-native-user-legacy';
+const legacySessionId = 3684219150343;
+const legacyEvents: LegacyEvent[] = [
+  {
+    event_id: 1,
+    event_type: '$identify',
+    time: 1684219150343,
+    insert_id: 'be09ecba-83f7-444a-aba0-fe1f529a3716',
+  },
+  {
+    event_id: 2,
+    event_type: '$identify',
+    time: 1684219150344,
+    insert_id: '0894387e-e923-423b-9feb-086ba8cb2cfa',
+  },
+  {
+    event_id: 1,
+    event_type: '$identify',
+    time: 1684219150358,
+    insert_id: '1a14d057-8a12-40bb-8217-2d62dd08a525',
+  },
+  {
+    event_id: 2,
+    event_type: '$identify',
+    time: 1684219150359,
+    insert_id: 'b115a299-4cc6-495b-8e4e-c2ce6f244be9',
+  },
+  {
+    event_id: 1,
+    event_type: 'legacy event 1',
+    time: 1684219150354,
+    insert_id: 'd6eff10b-9cd4-45d7-85cb-c81cb6cb8b2e',
+  },
+  {
+    event_id: 2,
+    event_type: 'legacy event 2',
+    time: 1684219150355,
+    insert_id: '7b4c5c13-6fdc-4931-9ba1-e4efdf346ee0',
+  },
+];
+
+export default class MigrationChecker {
+  errors: string[] = [];
+
+  constructor(private readonly version: 'v4' | 'v3' | 'vMissing') {}
+
+  checkUserSession(userSession: UserSession | undefined) {
+    if (userSession === undefined) {
+      this.check(false, 'userSession');
+      return;
+    }
+
+    if (this.version === 'v4' || this.version === 'v3') {
+      this.check(userSession.deviceId === legacyDeviceId, 'deviceId');
+      this.check(userSession.userId === legacyUserId, 'userId');
+      this.check(userSession.sessionId === legacySessionId, 'sessionId');
+      this.check(userSession.lastEventId === 2, 'lastEventId');
+    } else {
+      this.check(userSession.deviceId !== legacyDeviceId, 'deviceId');
+      this.check(userSession.userId === undefined, 'userId');
+      this.check(userSession.sessionId !== legacySessionId, 'sessionId');
+      this.check(userSession.lastEventId === undefined, 'lastEventId');
+    }
+  }
+
+  checkEvents(events: Event[] | undefined) {
+    if (events === undefined) {
+      this.check(false, 'events');
+      return;
+    }
+
+    if (this.version === 'v4') {
+      this.compareEvents(events, legacyEvents);
+    } else if (this.version === 'v3') {
+      this.compareEvents(events, [
+        ...legacyEvents.slice(0, 2),
+        ...legacyEvents.slice(4),
+      ]);
+    } else {
+      this.compareEvents(events, []);
+    }
+  }
+
+  private compareEvents(events: Event[], expectedEvents: LegacyEvent[]) {
+    if (events.length !== expectedEvents.length) {
+      this.check(false, 'events.length');
+      return;
+    }
+
+    events.forEach((event, i) => {
+      const eventPrefix = `events[${i}]`;
+
+      this.check(
+        event.event_id === expectedEvents[i].event_id,
+        `${eventPrefix}.event_id`,
+      );
+      this.check(
+        event.event_type === expectedEvents[i].event_type,
+        `${eventPrefix}.event_type`,
+      );
+      this.check(event.time === expectedEvents[i].time, `${eventPrefix}.time`);
+      this.check(
+        event.insert_id === expectedEvents[i].insert_id,
+        `${eventPrefix}.insert_id`,
+      );
+      this.check(
+        event.library === 'amplitude-react-native/2.17.1',
+        `${eventPrefix}.library`,
+      );
+      this.check(
+        event.device_id === legacyDeviceId,
+        `${eventPrefix}.device_id`,
+      );
+      this.check(event.user_id === legacyUserId, `${eventPrefix}.user_id`);
+    });
+  }
+
+  check(assert: boolean, error: string) {
+    if (!assert) {
+      this.errors.push(error);
+    }
+  }
+}