posthog_adapter.dart

import 'dart:async';

import 'package:posthog_flutter/posthog_flutter.dart';

import 'package:omi/utils/analytics/analytics_adapter.dart';

class PostHogAnalyticsAdapter implements AnalyticsAdapter {
  PostHogAnalyticsAdapter({
    required this.apiKey,
    this.host = 'https://us.i.posthog.com',
    // SDK default is `true`; we track lifecycle ourselves at meaningful boundaries.
    this.captureLifecycleEvents = false,
    this.debug = false,
  });

  final String apiKey;
  final String host;
  final bool captureLifecycleEvents;
  final bool debug;

  bool _initialized = false;
  Timer? _targetExpiry;

  @override
  bool get isInitialized => _initialized;

  @override
  Future<void> init() async {
    if (_initialized) return;
    final config = PostHogConfig(apiKey);
    config.host = host;
    config.captureApplicationLifecycleEvents = captureLifecycleEvents;
    config.debug = debug;
    await Posthog().setup(config);
    _initialized = true;
  }

  @override
  void identify({required String userId, Map<String, Object>? userProperties}) {
    if (!_initialized) return;
    if (userProperties == null) {
      Posthog().identify(userId: userId);
    } else {
      Posthog().identify(userId: userId, userProperties: userProperties);
    }
  }

  @override
  void alias({required String newUserId}) {
    if (!_initialized) return;
    Posthog().alias(alias: newUserId);
  }

  @override
  void track({required String eventName, Map<String, Object>? properties}) {
    if (!_initialized) return;
    Posthog().capture(eventName: eventName, properties: properties);
  }

  @override
  void setInteractionContext({String? screenName, required String target}) {
    if (!_initialized) return;

    // Native iOS rage-click capture runs before Flutter receives the current
    // pointer. Registering every pointer's context means a qualifying third
    // tap inherits the matching context recorded by the first two taps.
    if (screenName != null && screenName.isNotEmpty) {
      unawaited(Posthog().register(r'$screen_name', screenName));
      unawaited(Posthog().register('screen', screenName));
    }
    unawaited(Posthog().register('target', target));
    _targetExpiry?.cancel();
    _targetExpiry = Timer(const Duration(seconds: 2), () {
      if (_initialized) unawaited(Posthog().unregister('target'));
    });
  }

  @override
  void enable() {
    if (!_initialized) return;
    Posthog().enable();
  }

  @override
  void disable() {
    if (!_initialized) return;
    Posthog().disable();
  }

  @override
  void reset() {
    if (!_initialized) return;
    _targetExpiry?.cancel();
    _targetExpiry = null;
    Posthog().reset();
  }
}