index.ts

import dotenv from 'dotenv';
import FileSync from 'lowdb/adapters/FileSync'
import low from 'lowdb';
import { from, timer } from 'rxjs';
import { delay, filter, mergeMap, retryWhen, switchMap, take, tap } from 'rxjs/operators';
import { isNotAlreadyChecked, isValidCheckTime, updateCheckedDate } from './utils/utils';
import { User } from './models/Database';
import { coronaCheckEpic } from './epics/coronaCheckEpic';

const TEN_MINUTES = 1000 * 60 * 10

dotenv.config();

const adapter = new FileSync('db.json')
const db = low(adapter)

timer(0, TEN_MINUTES).pipe(
  filter(isValidCheckTime),
  switchMap(() => from<Array<User>>(db.get('users').value())),
  filter(isNotAlreadyChecked),
  mergeMap(coronaCheckEpic, 10),
  tap(({ user }) => updateCheckedDate(db, user)),
  tap(({ browser }) => browser.close()),
  retryWhen(error$ => {
    return error$.pipe(
      tap(err => console.log(err)),
      delay(TEN_MINUTES),
      take(100)
    )
  })
).subscribe(({ user }) => {
  /**TODO: notify successful check*/
  console.log('success', user?.name)
}, () => {
  /**TODO: notify failed check*/
  throw Error(`Let PM2 restart`)
})