1*753557f6STomasz Sapeta #include "JSIStoreValueUser.h"
2*753557f6STomasz Sapeta #include "RuntimeManager.h"
3*753557f6STomasz Sapeta #ifdef ANDROID
4*753557f6STomasz Sapeta #include <AndroidScheduler.h>
5*753557f6STomasz Sapeta #endif
6*753557f6STomasz Sapeta 
7*753557f6STomasz Sapeta namespace ABI47_0_0reanimated {
8*753557f6STomasz Sapeta 
getWeakRef(jsi::Runtime & rt)9*753557f6STomasz Sapeta std::weak_ptr<jsi::Value> StoreUser::getWeakRef(jsi::Runtime &rt) {
10*753557f6STomasz Sapeta   const std::lock_guard<std::recursive_mutex> lock(storeUserData->storeMutex);
11*753557f6STomasz Sapeta   if (storeUserData->store.count(identifier) == 0) {
12*753557f6STomasz Sapeta     storeUserData->store[identifier] =
13*753557f6STomasz Sapeta         std::vector<std::shared_ptr<jsi::Value>>();
14*753557f6STomasz Sapeta   }
15*753557f6STomasz Sapeta   std::shared_ptr<jsi::Value> sv =
16*753557f6STomasz Sapeta       std::make_shared<jsi::Value>(rt, jsi::Value::undefined());
17*753557f6STomasz Sapeta   storeUserData->store[identifier].push_back(sv);
18*753557f6STomasz Sapeta 
19*753557f6STomasz Sapeta   return sv;
20*753557f6STomasz Sapeta }
21*753557f6STomasz Sapeta 
StoreUser(std::shared_ptr<Scheduler> s,const RuntimeManager & runtimeManager)22*753557f6STomasz Sapeta StoreUser::StoreUser(
23*753557f6STomasz Sapeta     std::shared_ptr<Scheduler> s,
24*753557f6STomasz Sapeta     const RuntimeManager &runtimeManager)
25*753557f6STomasz Sapeta     : scheduler(s) {
26*753557f6STomasz Sapeta   storeUserData = runtimeManager.storeUserData;
27*753557f6STomasz Sapeta   identifier = storeUserData->ctr++;
28*753557f6STomasz Sapeta }
29*753557f6STomasz Sapeta 
~StoreUser()30*753557f6STomasz Sapeta StoreUser::~StoreUser() {
31*753557f6STomasz Sapeta   int id = identifier;
32*753557f6STomasz Sapeta   std::shared_ptr<Scheduler> strongScheduler = scheduler.lock();
33*753557f6STomasz Sapeta   if (strongScheduler != nullptr) {
34*753557f6STomasz Sapeta     std::shared_ptr<StaticStoreUser> sud = storeUserData;
35*753557f6STomasz Sapeta #ifdef ANDROID
36*753557f6STomasz Sapeta     jni::ThreadScope::WithClassLoader([&] {
37*753557f6STomasz Sapeta       strongScheduler->scheduleOnUI([id, sud]() {
38*753557f6STomasz Sapeta         const std::lock_guard<std::recursive_mutex> lock(sud->storeMutex);
39*753557f6STomasz Sapeta         if (sud->store.count(id) > 0) {
40*753557f6STomasz Sapeta           sud->store.erase(id);
41*753557f6STomasz Sapeta         }
42*753557f6STomasz Sapeta       });
43*753557f6STomasz Sapeta     });
44*753557f6STomasz Sapeta #else
45*753557f6STomasz Sapeta     strongScheduler->scheduleOnUI([id, sud]() {
46*753557f6STomasz Sapeta       const std::lock_guard<std::recursive_mutex> lock(sud->storeMutex);
47*753557f6STomasz Sapeta       if (sud->store.count(id) > 0) {
48*753557f6STomasz Sapeta         sud->store.erase(id);
49*753557f6STomasz Sapeta       }
50*753557f6STomasz Sapeta     });
51*753557f6STomasz Sapeta #endif
52*753557f6STomasz Sapeta   }
53*753557f6STomasz Sapeta }
54*753557f6STomasz Sapeta 
55*753557f6STomasz Sapeta } // namespace reanimated
56