BlueWallet/WatchConnectivity.ios.js

import * as Watch from 'react-native-watch-connectivity';
import { InteractionManager } from 'react-native';
import { Chain } from './models/bitcoinUnits';
import loc, { formatBalance, transactionTimeToReadable } from './loc';
const notifications = require('./blue_modules/notifications');

export default class WatchConnectivity {
  isAppInstalled = false;
  static shared = new WatchConnectivity();
  wallets;
  fetchTransactionsFunction = () => {};

  constructor() {
    this.getIsWatchAppInstalled();
  }

  getIsWatchAppInstalled() {
    Watch.getIsWatchAppInstalled((err, isAppInstalled) => {
      if (!err) {
        WatchConnectivity.shared.isAppInstalled = isAppInstalled;
        Watch.subscribeToWatchState((err, watchState) => {
          if (!err) {
            if (watchState === 'Activated') {
              WatchConnectivity.shared.sendWalletsToWatch();
            }
          }
        });
        Watch.subscribeToMessages(async (err, message, reply) => {
          if (!err) {
            if (message.request === 'createInvoice') {
              const createInvoiceRequest = await this.handleLightningInvoiceCreateRequest(
                message.walletIndex,
                message.amount,
                message.description,
              );
              reply({ invoicePaymentRequest: createInvoiceRequest });
            } else if (message.message === 'sendApplicationContext') {
              await WatchConnectivity.shared.sendWalletsToWatch();
            } else if (message.message === 'fetchTransactions') {
              await WatchConnectivity.shared.fetchTransactionsFunction();
            }
          } else {
            reply(err);
          }
        });
      }
    });
  }

  async handleLightningInvoiceCreateRequest(walletIndex, amount, description) {
    const wallet = WatchConnectivity.shared.wallets[walletIndex];
    if (wallet.allowReceive() && amount > 0 && description.trim().length > 0) {
      try {
        const invoiceRequest = await wallet.addInvoice(amount, description);

        // lets decode payreq and subscribe groundcontrol so we can receive push notification when our invoice is paid
        const decoded = await wallet.decodeInvoice(invoiceRequest);
        await notifications.tryToObtainPermissions();
        notifications.majorTomToGroundControl([], [decoded.payment_hash], []);
        return invoiceRequest;
      } catch (error) {
        return error;
      }
    }
  }

  async sendWalletsToWatch() {
    const allWallets = WatchConnectivity.shared.wallets;
    if (!Array.isArray(allWallets)) {
      console.log('No Wallets set to sync with Watch app. Exiting...');
      return;
    } else if (allWallets.length === 0) {
      console.log('Wallets array is set. No Wallets set to sync with Watch app. Exiting...');
      return;
    }

    return InteractionManager.runAfterInteractions(async () => {
      if (WatchConnectivity.shared.isAppInstalled) {
        const wallets = [];

        for (const wallet of allWallets) {
          let receiveAddress;
          if (wallet.getAddressAsync) {
            if (wallet.chain === Chain.ONCHAIN) {
              try {
                receiveAddress = await wallet.getAddressAsync();
              } catch (_) {}
              if (!receiveAddress) {
                // either sleep expired or getAddressAsync threw an exception
                receiveAddress = wallet._getExternalAddressByIndex(wallet.next_free_address_index);
              }
            } else if (wallet.chain === Chain.OFFCHAIN) {
              try {
                await wallet.getAddressAsync();
                receiveAddress = wallet.getAddress();
              } catch (_) {}
              if (!receiveAddress) {
                // either sleep expired or getAddressAsync threw an exception
                receiveAddress = wallet.getAddress();
              }
            }
          }
          const transactions = wallet.getTransactions(10);
          const watchTransactions = [];
          for (const transaction of transactions) {
            let type = 'pendingConfirmation';
            let memo = '';
            let amount = 0;

            if ('confirmations' in transaction && !(transaction.confirmations > 0)) {
              type = 'pendingConfirmation';
            } else if (transaction.type === 'user_invoice' || transaction.type === 'payment_request') {
              const currentDate = new Date();
              const now = (currentDate.getTime() / 1000) | 0;
              const invoiceExpiration = transaction.timestamp + transaction.expire_time;

              if (invoiceExpiration > now) {
                type = 'pendingConfirmation';
              } else if (invoiceExpiration < now) {
                if (transaction.ispaid) {
                  type = 'received';
                } else {
                  type = 'sent';
                }
              }
            } else if (transaction.value / 100000000 < 0) {
              type = 'sent';
            } else {
              type = 'received';
            }
            if (transaction.type === 'user_invoice' || transaction.type === 'payment_request') {
              amount = isNaN(transaction.value) ? '0' : amount;
              const currentDate = new Date();
              const now = (currentDate.getTime() / 1000) | 0;
              const invoiceExpiration = transaction.timestamp + transaction.expire_time;

              if (invoiceExpiration > now) {
                amount = formatBalance(transaction.value, wallet.getPreferredBalanceUnit(), true).toString();
              } else if (invoiceExpiration < now) {
                if (transaction.ispaid) {
                  amount = formatBalance(transaction.value, wallet.getPreferredBalanceUnit(), true).toString();
                } else {
                  amount = loc.lnd.expired;
                }
              } else {
                amount = formatBalance(transaction.value, wallet.getPreferredBalanceUnit(), true).toString();
              }
            } else {
              amount = formatBalance(transaction.value, wallet.getPreferredBalanceUnit(), true).toString();
            }
            if (WatchConnectivity.shared.tx_metadata[transaction.hash] && WatchConnectivity.shared.tx_metadata[transaction.hash].memo) {
              memo = WatchConnectivity.shared.tx_metadata[transaction.hash].memo;
            } else if (transaction.memo) {
              memo = transaction.memo;
            }
            const watchTX = { type, amount, memo, time: transactionTimeToReadable(transaction.received) };
            watchTransactions.push(watchTX);
          }
          wallets.push({
            label: wallet.getLabel(),
            balance: formatBalance(Number(wallet.getBalance()), wallet.getPreferredBalanceUnit(), true),
            type: wallet.type,
            preferredBalanceUnit: wallet.getPreferredBalanceUnit(),
            receiveAddress: receiveAddress,
            transactions: watchTransactions,
            xpub: wallet.getXpub() ? wallet.getXpub() : wallet.getSecret(),
          });
        }
        Watch.updateApplicationContext({ wallets, randomID: Math.floor(Math.random() * 11) });
        return { wallets };
      }
    });
  }
}