example.ts

import { PushNotificationAction, RingApi } from 'ring-client-api'
import { skip } from 'rxjs/operators'
import { readFile, writeFile } from 'node:fs/promises'

async function example() {
  const { env } = process,
    ringApi = new RingApi({
      // Replace with your refresh token
      refreshToken: env.RING_REFRESH_TOKEN!,
      debug: true,
    }),
    locations = await ringApi.getLocations(),
    allCameras = await ringApi.getCameras()

  console.log(
    `Found ${locations.length} location(s) with ${allCameras.length} camera(s).`,
  )

  ringApi.onRefreshTokenUpdated.subscribe(
    async ({ newRefreshToken, oldRefreshToken }) => {
      // If you are implementing a project that use `ring-client-api`, you should subscribe to onRefreshTokenUpdated and update your config each time it fires an event
      // Here is an example using a .env file for configuration
      if (!oldRefreshToken) {
        return
      }

      const envFile = process.env.RING_ENV_FILE ?? '.env',
        currentConfig = await readFile(envFile, 'utf8'),
        updatedConfig = currentConfig.replace(oldRefreshToken, newRefreshToken)

      await writeFile(envFile, updatedConfig)
    },
  )

  for (const location of locations) {
    location.onConnected.pipe(skip(1)).subscribe((connected) => {
      const status = connected ? 'Connected to' : 'Disconnected from'
      console.log(`**** ${status} location ${location.name} - ${location.id}`)
    })
  }

  for (const location of locations) {
    const cameras = location.cameras,
      devices = await location.getDevices()

    console.log(
      `\nLocation ${location.name} (${location.id}) has the following ${cameras.length} camera(s):`,
    )

    for (const camera of cameras) {
      console.log(`- ${camera.id}: ${camera.name} (${camera.deviceType})`)
    }

    console.log(
      `\nLocation ${location.name} (${location.id}) has the following ${devices.length} device(s):`,
    )

    for (const device of devices) {
      console.log(`- ${device.zid}: ${device.name} (${device.deviceType})`)
    }
  }

  if (allCameras.length) {
    allCameras.forEach((camera) => {
      camera.onNewNotification.subscribe((notification) => {
        const action = notification.android_config.category,
          event =
            action === PushNotificationAction.Motion
              ? 'Motion detected'
              : action === PushNotificationAction.Ding
              ? 'Doorbell pressed'
              : `Video started (${action})`

        console.log(
          `${event} on ${camera.name} camera. Ding id ${
            notification.data.event.ding.id
          }.  Received at ${new Date()}`,
        )
      })
    })

    console.log('Listening for motion and doorbell presses on your cameras.')
  }
}

example().catch((e: any) => {
  console.error('Example threw an error:', e)
})