Reacting to Changes

import { Rovenue } from '@rovenue/react-native-sdk';

// addChangeListener returns an unsubscribe function — call it to clean up
const unsub = Rovenue.addChangeListener((event) => {
  switch (event) {
    case 'ENTITLEMENTS_CHANGED':
      console.log('Entitlements updated — re-check access');
      break;
    case 'IDENTITY_CHANGED':
      console.log('Identity changed — re-read current user');
      break;
    case 'VIRTUAL_CURRENCIES_CHANGED':
      console.log('Virtual-currency balances changed — re-read balances');
      break;
    case 'REMOTE_CONFIG_CHANGED':
      console.log('Remote config changed — re-read values');
      break;
  }
});

import {
  useEntitlement,
  useEntitlements,
  useCurrentUser,
  useVirtualCurrencies,
  useVirtualCurrency,
} from '@rovenue/react-native-sdk';

function ProBadge() {
  const pro = useEntitlement('pro'); // re-renders on ENTITLEMENTS_CHANGED
  return pro?.isActive ? <Crown /> : null;
}

import Rovenue

// Rovenue.shared.changes is an AsyncStream<ChangeEvent>
// Consume it inside a Task that you own so you can cancel it later
let task = Task {
  for await event in Rovenue.shared.changes {
    switch event {
    case .entitlementsChanged:
      print("Entitlements updated — re-check access")
    case .identityChanged:
      print("Identity changed — re-read current user")
    case .virtualCurrenciesChanged:
      print("Virtual-currency balances changed — re-read balances")
    case .remoteConfigChanged:
      print("Remote config changed — re-read values")
    }
  }
}

import dev.rovenue.sdk.Rovenue
import dev.rovenue.sdk.ChangeEvent

// Rovenue.shared.changes is a SharedFlow<ChangeEvent>
// Collect from a scope you own — see the warning below
viewModelScope.launch {
  Rovenue.shared.changes.collect { event ->
    when (event) {
      ChangeEvent.ENTITLEMENTS_CHANGED       -> println("Entitlements updated")
      ChangeEvent.IDENTITY_CHANGED           -> println("Identity changed")
      ChangeEvent.VIRTUAL_CURRENCIES_CHANGED -> println("Virtual-currency balances changed")
      ChangeEvent.REMOTE_CONFIG_CHANGED      -> println("Remote config changed")
    }
  }
}

// Call the function returned by addChangeListener
unsub();

// In a React effect:
useEffect(() => {
  const unsub = Rovenue.addChangeListener((event) => {
    // handle event
  });
  return () => unsub(); // cleanup on unmount
}, []);

// Cancel the Task you created in Step 1
task.cancel()

// In a SwiftUI view model, store the task and cancel on deinit:
deinit {
  task.cancel()
}

// If you collected with launchIn, cancel the resulting Job:
val job = Rovenue.shared.changes
  .onEach { event -> /* handle */ }
  .launchIn(viewModelScope)

// Cancel explicitly if needed (viewModelScope cancels automatically on ViewModel cleared):
job.cancel()

import { Rovenue } from '@rovenue/react-native-sdk';

const unsub = Rovenue.addChangeListener(async (event) => {
  switch (event) {
    case 'ENTITLEMENTS_CHANGED': {
      const all = await Rovenue.entitlementsAll();
      console.log('Active entitlements:', all.filter(e => e.isActive));
      break;
    }
    case 'IDENTITY_CHANGED': {
      const user = await Rovenue.currentUser();
      console.log('Current user:', user.rovenueId, user.appUserId);
      break;
    }
    case 'VIRTUAL_CURRENCIES_CHANGED': {
      const balances = Rovenue.virtualCurrencies();
      console.log('New balances:', balances);
      break;
    }
    case 'REMOTE_CONFIG_CHANGED': {
      const config = await Rovenue.getRemoteConfig();
      console.log('Remote config:', config);
      break;
    }
  }
});

let task = Task {
  for await event in Rovenue.shared.changes {
    switch event {
    case .entitlementsChanged:
      let all = await Rovenue.shared.entitlementsAll()
      print("Active entitlements:", all.filter { $0.isActive })
    case .identityChanged:
      let user = await Rovenue.shared.currentUser()
      print("Current user:", user.rovenueId, user.appUserId ?? "anonymous")
    case .virtualCurrenciesChanged:
      let balances = await Rovenue.shared.virtualCurrencyBalances()
      print("New balances:", balances)
    case .remoteConfigChanged:
      let config = await Rovenue.shared.remoteConfigAllJSON()
      print("Remote config:", config)
    }
  }
}

viewModelScope.launch {
  Rovenue.shared.changes.collect { event ->
    when (event) {
      ChangeEvent.ENTITLEMENTS_CHANGED -> {
        val all = Rovenue.shared.entitlementsAll()
        println("Active: ${all.filter { it.isActive }}")
      }
      ChangeEvent.IDENTITY_CHANGED -> {
        val user = Rovenue.shared.currentUser()
        println("Current user: ${user.rovenueId} / ${user.appUserId}")
      }
      ChangeEvent.VIRTUAL_CURRENCIES_CHANGED -> {
        val balances = Rovenue.shared.virtualCurrencyBalances()
        println("New balances: $balances")
      }
      ChangeEvent.REMOTE_CONFIG_CHANGED -> {
        val config = Rovenue.shared.remoteConfigAllJson()
        println("Remote config: $config")
      }
    }
  }
}