Example about eufy-node-client HOT 5 CLOSED

import { HttpService } from './http/http.service';
import { CommandTypes } from './p2p/command.model';
import { DeviceClientService } from './p2p/device-client.service';
import { LocalLookupService } from './p2p/local-lookup.service';
import { PushMessage } from './push/push.model';
import { PushService } from './push/push.service';

(async () => {
  const httpService = new HttpService(USERNAME, PASSWORD);
  const hubs = await httpService.listHubs();

  if (hubs && hubs.length > 0) {
    const hub = hubs[0];
    const lookupService = new LocalLookupService();
    const address = await lookupService.lookup(HOMEBASE_IP);

    const service = new DeviceClientService(address, hub.p2p_did, hub.member.action_user_id);
    const connected = await service.connect().catch((error) => {
      console.log('error trying to connected:', error);
      return false;
    });

    if (connected) {
      console.log('p2p connected, start listening for push messages');

      const pushService = new PushService();
      const credentials = await pushService.createPushCredentials();

      pushService.listen(credentials, async (msg: PushMessage) => {
        const event = msg.data;
        const payload = event.payload;
        if (payload && payload.event_type === 3103 && payload.channel === 2 && payload.push_count === 1) {
          console.log('doorbell pressed');

          if (!streaming) {
            service.sendCommandWithIntString(CommandTypes.CMD_NAS_TEST, 1, 2);
            streaming = true;

            setTimeout(() => {
              if (streaming) {
                service.sendCommandWithIntString(CommandTypes.CMD_NAS_TEST, 0, 2);
              }
              streaming = false;
            }, 6000);
          }
          await got.get('url_to_a_webhook');
        }
      });

      // Register generated token

      const fcmToken = credentials.fcm.token;

      await httpService.registerPushToken(fcmToken);
      await httpService.pushTokenCheck();
    }
  } else {
    console.warn('no hub found');
  }
})();