notesnook/apps/mobile/App.js

import * as NetInfo from '@react-native-community/netinfo';
import {CHECK_IDS, EV} from 'notes-core/common';
import React, {useEffect, useState} from 'react';
import {
  Appearance,
  AppState,
  Linking,
  NativeModules,
  Platform,
  StatusBar,
} from 'react-native';
import * as RNIap from 'react-native-iap';
import {enabled} from 'react-native-privacy-snapshot';
import {SafeAreaProvider} from 'react-native-safe-area-context';
import SplashScreen from 'react-native-splash-screen';
import {useTracked} from './src/provider';
import {Actions} from './src/provider/Actions';
import {DDS} from './src/services/DeviceDetection';
import {
  eSendEvent,
  eSubscribeEvent,
  eUnSubscribeEvent,
} from './src/services/EventManager';
import IntentService from './src/services/IntentService';
import {
  clearMessage,
  setEmailVerifyMessage,
  setLoginMessage,
} from './src/services/Message';
import Navigation from './src/services/Navigation';
import PremiumService from './src/services/PremiumService';
import {editing} from './src/utils';
import {COLOR_SCHEME} from './src/utils/Colors';
import {db} from './src/utils/DB';
import {
  eClosePremiumDialog,
  eDispatchAction,
  eOnLoadNote,
  eOpenLoginDialog,
  eOpenPendingDialog,
  eOpenPremiumDialog,
  eOpenProgressDialog,
  eOpenSideMenu,
  eShowGetPremium,
  eStartSyncer,
  refreshNotesPage,
} from './src/utils/Events';
import {MMKV} from './src/utils/mmkv';
import {tabBarRef} from './src/utils/Refs';
import {sleep} from './src/utils/TimeUtils';
import {getNote} from './src/views/Editor/Functions';
const {ReceiveSharingIntent} = NativeModules;

let AppRootView = require('./initializer.root').RootView;
let SettingsService = null;
let Sentry = null;
let appInit = false;
let intentInit = false;
let hasPurchased = false;
const onAppStateChanged = async (state) => {
  console.log('app state', state);
  if (state === 'active') {
    StatusBar.setBarStyle(
      COLOR_SCHEME.night ? 'light-content' : 'dark-content',
      true,
    );
    if (Platform.OS === 'android') {
      StatusBar.setBackgroundColor('transparent', true);
      StatusBar.setTranslucent(true, true);
    }
    if (SettingsService.get().privacyScreen) {
      enabled(false);
    }
    console.log('clearing state', await MMKV.getItem('appState'));
    if (appInit) {
      await MMKV.removeItem('appState');
    }
    try {
      if (intentInit) {
        if (Platform.OS === 'android') {
          _data = await ReceiveSharingIntent.getFileNames();
          if (_data) {
            IntentService.setIntent(_data);
            IntentService.check((event) => {
              console.log(event);
              if (event) {
                eSendEvent(eOnLoadNote, event);
                tabBarRef.current?.goToPage(1);
                Navigation.closeDrawer();
              } else {
                eSendEvent('nointent');
                SplashScreen.hide();

                sleep(300).then(() => eSendEvent(eOpenSideMenu));
              }
            });
          }
        }
      }
    } catch (e) {
      console.log(e);
    }
  } else {
    if (editing.currentlyEditing && appInit) {
      let state = JSON.stringify({
        editing: editing.currentlyEditing,
        note: getNote(),
      });
      console.log('putting items in state', state);
      await MMKV.setItem('appState', state);
    }

    if (SettingsService.get().privacyScreen) {
      enabled(true);
    }
  }
};

const onNetworkStateChanged = (netInfo) => {
  /*  let message = 'Internet connection restored';
  let type = 'success';
  if (!netInfo.isConnected || !netInfo.isInternetReachable) {
    message = 'No internet connection';
    type = 'error';
  }
  db.user?.get().then((user) => {
    if (user && intentInit) {
      ToastEvent.show(message, type);
    }
  }); */
};

const App = () => {
  const [, dispatch] = useTracked(),
    [init, setInit] = useState(true),
    [intent, setIntent] = useState(false);

  const syncChanges = async () => {
    console.log('dispatching sync changes');
    dispatch({type: Actions.ALL});
  };
  const startSyncer = async () => {
    try {
      let user = await db.user.getUser();
      if (user) {
        EV.subscribe('db:refresh', syncChanges);
      }
    } catch (e) {
      console.log(e, 'SYNC ERROR');
    }
  };

  const onSystemThemeChanged = async () => {
    await SettingsService.setTheme();
  };

  const _handleIntent = async (res) => {
    if (intentInit) {
      let url = res ? res.url : '';

      try {
        if (Platform.OS === 'ios' && url.startsWith('ShareMedia://dataUrl')) {
          _data = await ReceiveSharingIntent.getFileNames(url);
          _data = IntentService.iosSortedData(_data);

          if (_data) {
            IntentService.setIntent(_data);
            IntentService.check((event) => {
              eSendEvent(eOnLoadNote, event);
              tabBarRef.current?.goToPage(1);
              Navigation.closeDrawer();
            });
          }
        } else if (url.startsWith('https://notesnook.com/verify')) {
          let user = await db.user.fetchUser();
          dispatch({type: Actions.USER, user: user});
          if (user.isEmailConfirmed) {
            clearMessage(dispatch);
          }
        }
      } catch (e) {
        console.log(e, 'ERROR HERE');
      }
    }
  };

  const handlePremiumAccess = async (type) => {
    let status = PremiumService.get();
    let message = null;

    if (!status) {
      switch (type) {
        case CHECK_IDS.noteColor:
          message = {
            context: 'sheet',
            title: 'Get Notesnook Pro',
            desc: 'To assign colors to a note get Notesnook Pro today.',
          };
          break;
        case CHECK_IDS.noteExport:
          message = {
            context: 'export',
            title: 'Export in PDF, MD & HTML',
            desc:
              'Get Notesnook Pro to export your notes in PDF, Markdown and HTML formats!',
          };
          break;
        case CHECK_IDS.noteTag:
          message = {
            context: 'sheet',
            title: 'Get Notesnook Pro',
            desc: 'To create more tags for your notes become a Pro user today.',
          };
          break;
        case CHECK_IDS.notebookAdd:
          eSendEvent(eOpenPremiumDialog);
          break;
        case CHECK_IDS.vaultAdd:
          message = {
            context: 'sheet',
            title: 'Add Notes to Vault',
            desc:
              'With Notesnook Pro you can add notes to your vault and do so much more! Get it now.',
          };
          break;
      }
      if (message) {
        eSendEvent(eShowGetPremium, message);
      }
    }

    return {type, result: status};
  };

  let subsriptionSuccessListerner;
  let subsriptionErrorListener;

  const attachIAPListeners = () => {
    if (Platform.OS === 'ios') {
      RNIap.getReceiptIOS()
        .then((r) => {
          hasPurchased = true;
          processReceipt(r);
        })
        .catch(console.log)
        .finally(() => {
          subsriptionSuccessListerner = RNIap.purchaseUpdatedListener(
            onSuccessfulSubscription,
          );
          subsriptionErrorListener = RNIap.purchaseErrorListener(
            onSubscriptionError,
          );
        });
    } else {
      subsriptionSuccessListerner = RNIap.purchaseUpdatedListener(
        onSuccessfulSubscription,
      );
      subsriptionErrorListener = RNIap.purchaseErrorListener(
        onSubscriptionError,
      );
    }
  };

  const dbSync = async () => {
    try {
      dispatch({type: Actions.SYNCING, syncing: true});
      await db.sync(false);
      dispatch({type: Actions.LAST_SYNC, lastSync: await db.lastSynced()});
    } catch (e) {
    } finally {
      dispatch({type: Actions.SYNCING, syncing: false});
    }
  };

  const onLogout = (reason) => {
    eSendEvent(eOpenProgressDialog, {
      title: 'User Logged Out',
      paragraph: reason,
      action: () => {
        eSendEvent(eOpenLoginDialog);
      },
      actionText: 'Login Again',
      noProgress: true,
    });
  };

  useEffect(() => {
    eSubscribeEvent(eStartSyncer, startSyncer);
    eSubscribeEvent(eDispatchAction, (type) => {
      dispatch(type);
    });

    attachIAPListeners();

    AppState.addEventListener('change', onAppStateChanged);
    eSubscribeEvent('nointent', loadMainApp);
    Appearance.addChangeListener(onSystemThemeChanged);
    let unsub = NetInfo.addEventListener(onNetworkStateChanged);
    Linking.addEventListener('url', _handleIntent);
    EV.subscribe('db:sync', dbSync);
    EV.subscribe('user:loggedOut', onLogout);
    EV.subscribe('user:checkStatus', handlePremiumAccess);
    return () => {
      EV.unsubscribe('db:refresh', syncChanges);
      EV.unsubscribe('user:loggedOut', onLogout);
      EV.unsubscribe('db:sync', dbSync);
      eUnSubscribeEvent(eStartSyncer, startSyncer);
      eUnSubscribeEvent(eDispatchAction, (type) => {
        dispatch(type);
      });
      eUnSubscribeEvent('nointent', loadMainApp);
      AppState.removeEventListener('change', onAppStateChanged);
      Appearance.removeChangeListener(onSystemThemeChanged);
      Linking.removeEventListener('url', _handleIntent);
      unsub();
      unsubIAP();
    };
  }, []);

  unsubIAP = () => {
    if (subsriptionSuccessListerner) {
      subsriptionSuccessListerner?.remove();
      subsriptionSuccessListerner = null;
    }
    if (subsriptionErrorListener) {
      subsriptionErrorListener?.remove();
      subsriptionErrorListener = null;
    }
  };

  const loadMainApp = () => {
    dispatch({type: Actions.ALL});
    AppRootView = require('./initializer.root').RootView;
    getUser().then(console.log).catch(console.log);
    backupData().then((r) => r);
    sleep(500).then(() => (appInit = true));
    db.notes.init().then(() => {
      dispatch({type: Actions.NOTES});
      dispatch({type: Actions.FAVORITES});
      eSendEvent(refreshNotesPage);
      dispatch({type: Actions.LOADING, loading: false});
      SettingsService.setAppLoaded();
    });
    SplashScreen.hide();
    sleep(300).then(() => eSendEvent(eOpenSideMenu));
    //Sentry = require('@sentry/react-native');
    // Sentry.init({
    //   dsn:
    //     'https://317a5c31caf64d1e9b27abf15eb1a554@o477952.ingest.sentry.io/5519681',
    // });
  };

  const getUser = async () => {
    try {
      let user = await db.user.fetchUser();
      if (user) {
        clearMessage(dispatch);
        if (!user.isEmailConfirmed) {
          setEmailVerifyMessage(dispatch);
        }
        dispatch({type: Actions.SYNCING, syncing: true});
        dispatch({type: Actions.USER, user: user});
        await db.sync();
        dispatch({type: Actions.LAST_SYNC, lastSync: await db.lastSynced()});
        dispatch({type: Actions.ALL});
        await startSyncer();
      } else {
        setLoginMessage(dispatch);
      }
    } catch (e) {
      console.log(e, 'SYNC ERROR');
    }
    dispatch({type: Actions.SYNCING, syncing: false});
  };

  useEffect(() => {
    SettingsService = require('./src/services/SettingsService').default;
    SettingsService.init();
    dispatch({
      type: Actions.DEVICE_MODE,
      state: DDS.isLargeTablet()
        ? 'tablet'
        : DDS.isSmallTab
        ? 'smallTablet'
        : 'mobile',
    });
    db.init().catch(console.log).finally(runAfterInit);
  }, []);

  const runAfterInit = () => {
    let isIntent = false;
    IntentService.getIntent()
      .then(() => {
        AppRootView = require('./initializer.intent').IntentView;
        setInit(false);
        intentInit = true;
        dispatch({type: Actions.ALL});
        setIntent(true);
        isIntent = true;
        ReceiveSharingIntent.clearFileNames();
      })
      .catch((e) => console.log)
      .finally(() => {
        if (!isIntent) {
          ReceiveSharingIntent.clearFileNames();
          intentInit = true;
          loadMainApp();
        }
      });
  };

  async function backupData() {
    let settings = SettingsService.get();
    let Backup = require('./src/services/Backup').default;
    if (await Backup.checkBackupRequired(settings.reminder)) {
      try {
        await Backup.run();
      } catch (e) {
        console.log(e);
      }
    }
  }

  const onSuccessfulSubscription = (subscription) => {
    if (hasPurchased) {
      return;
    }
    const receipt = subscription.transactionReceipt;
    processReceipt(receipt);

    setTimeout(() => {
      eSendEvent(eClosePremiumDialog);
      eSendEvent(eOpenPendingDialog);
    }, 500);
  };

  const onSubscriptionError = (error) => {
    console.log(error.message, 'Error');
    //ToastEvent.show(error.message);
  };

  const processReceipt = (receipt) => {
    return;
    if (receipt) {
      if (Platform.OS === 'ios') {
        fetch('http://192.168.10.5:8100/webhooks/assn', {
          method: 'POST',
          body: JSON.stringify({
            receipt_data: receipt,
          }),
          headers: {
            'Content-Type': 'application/json',
          },
        })
          .then((r) => {
            console.log(r.status, 'STATUS');
          })
          .catch((e) => {
            console.log(e, 'ERROR');
          });
      }
    }
  };

  return (
    <SafeAreaProvider>
      {intent ? <AppRootView /> : null}
      {init && !intent ? <AppRootView /> : null}
    </SafeAreaProvider>
  );
};

export default App;