db.ts

import * as AWS from 'aws-sdk'
import dayjs = require('dayjs')
import {
  fetchFreshAccessToken,
  PartialUserRecord,
  UserRecord,
} from './Authorization'
import { Device } from './Device'
import { Plan, PlanName } from './Plan'

AWS.config.update({ region: process.env.VSH_IOT_REGION })

export const docClient = new AWS.DynamoDB.DocumentClient({
  apiVersion: '2012-08-10',
})

export function upsertTokens(
  { userId, accessToken, refreshToken, email, skillRegion }: UserRecord,
  expiryInSec
): Promise<any> {
  let UpdateExpression =
    'set updatedAt = :c, accessTokenExpiry = :e, accessToken = :a, refreshToken = :r, deleteAtUnixTime = :ttl'
  let ExpressionAttributeValues = {
    ':c': dayjs().toISOString(),
    ':e': dayjs().add(expiryInSec, 'second').toISOString(),
    ':a': accessToken,
    ':r': refreshToken,
    ':ttl': dayjs().add(60, 'day').unix(),
  }

  if (email) {
    UpdateExpression = UpdateExpression + ', email = :m'
    ExpressionAttributeValues[':m'] = email
  }

  if (skillRegion) {
    UpdateExpression = UpdateExpression + ', skillRegion = :sr'
    ExpressionAttributeValues[':sr'] = skillRegion
  }

  let params = {
    TableName: 'VSH',
    Key: {
      PK: `USER#${userId}`,
      SK: 'TOKEN',
    },
    UpdateExpression,
    ExpressionAttributeValues,
  }

  return new Promise((resolve, reject) => {
    docClient.update(params, function (err, data) {
      if (err) {
        return reject(err)
      } else {
        return resolve(data)
      }
    })
  })
}

export function updateUserRecord(partialUser: PartialUserRecord): Promise<any> {
  const updateRec = { ...partialUser }

  delete updateRec.userId

  updateRec.updatedAt = dayjs().toISOString()

  const UpdateExpression =
    'set ' +
    Object.keys(updateRec)
      .map((_field, idx) => `#n${idx} = :v${idx}`)
      .join(', ')

  const ExpressionAttributeNames = Object.keys(updateRec).reduce(
    (acc, attrName, idx) => {
      acc[`#n${idx}`] = attrName
      return acc
    },
    {}
  )

  const ExpressionAttributeValues = Object.keys(updateRec).reduce(
    (acc, attrName, idx) => {
      acc[`:v${idx}`] = updateRec[attrName]
      return acc
    },
    {}
  )

  const params = {
    TableName: 'VSH',
    Key: {
      PK: `USER#${partialUser.userId}`,
      SK: 'TOKEN',
    },
    UpdateExpression,
    ExpressionAttributeNames,
    ExpressionAttributeValues,
  }

  return new Promise((resolve, reject) => {
    docClient.update(params, function (err, data) {
      if (err) {
        return reject(err)
      } else {
        return resolve(data)
      }
    })
  })
}

export async function getUserRecord(
  userId: string,
  refreshAccessToken: boolean = true
): Promise<UserRecord> {
  let params = {
    TableName: 'VSH',
    Key: {
      PK: `USER#${userId}`,
      SK: 'TOKEN',
    },
  }

  let data: any = await new Promise((resolve, reject) => {
    docClient.get(params, function (err, data) {
      if (err) {
        return reject(err)
      } else {
        if (data.Item) {
          return resolve(data.Item)
        } else {
          return reject(`no token record found for user ${userId}`)
        }
      }
    })
  })

  if (refreshAccessToken) {
    const now = dayjs()
    const tokenExpiry = dayjs(data.accessTokenExpiry).subtract(15, 'second')

    if (tokenExpiry.isBefore(now)) {
      const newTokens = await fetchFreshAccessToken(data.refreshToken)

      await upsertTokens(
        {
          userId,
          accessToken: newTokens.access_token,
          refreshToken: newTokens.refresh_token,
        },
        newTokens.expires_in
      )

      data.accessToken = newTokens.access_token
    }
  }

  if (!data.skillRegion) {
    data.skillRegion = process.env.VSH_IOT_REGION
  }

  data.isBlocked = !data.isBlocked ? false : true

  data.plan = data.plan ?? PlanName.FREE

  if (!data.allowedDeviceCount) {
    const plan = new Plan(data.plan as PlanName)
    data.allowedDeviceCount = plan.allowedDeviceCount
  }

  return data
}

export function upsertDevice({
  userId,
  deviceId,
  friendlyName,
  template,
  retrievable,
  thingId,
}): Promise<any> {
  let params = {
    TableName: 'VSH',
    Key: {
      PK: `USER#${userId}`,
      SK: `THING#${thingId}#DEVICE#${deviceId}`,
    },
    UpdateExpression:
      'set friendlyName = :fn, template = :te, retrievable = :rt, thingId = :th, deviceId = :de, updatedAt = :ua',
    ExpressionAttributeValues: {
      ':fn': friendlyName,
      ':te': template,
      ':rt': retrievable ? true : false,
      ':th': thingId,
      ':de': deviceId,
      ':ua': dayjs().toISOString(),
    },
  }

  return new Promise((resolve, reject) => {
    docClient.update(params, function (err, data) {
      if (err) {
        return reject(err)
      } else {
        return resolve(data)
      }
    })
  })
}

export function deleteDevice({ userId, deviceId, thingId }): Promise<any> {
  let params = {
    TableName: 'VSH',
    Key: {
      PK: `USER#${userId}`,
      SK: `THING#${thingId}#DEVICE#${deviceId}`,
    },
    ConditionExpression: 'thingId = :th',
    ExpressionAttributeValues: {
      ':th': thingId,
    },
    ReturnValues: 'ALL_OLD',
  }

  return new Promise((resolve, reject) => {
    docClient.delete(params, function (err, data) {
      if (err) {
        return reject(err)
      } else {
        return resolve(data)
      }
    })
  })
}

export async function getDevicesOfUser(userId: string): Promise<Device[]> {
  let params = {
    TableName: 'VSH',
    KeyConditionExpression: 'PK = :pk and begins_with(SK, :sk)',
    ExpressionAttributeValues: {
      ':pk': `USER#${userId}`,
      ':sk': 'THING',
    },
  }

  let devices: any = await new Promise((resolve, reject) => {
    docClient.query(params, function (err, data) {
      if (err) {
        return reject(err)
      } else {
        return resolve(data.Items)
      }
    })
  })

  // ensure 'retrievable' attribute is present (old records in DB might not have it yet):
  devices = devices.map((device) => {
    device.retrievable = device.retrievable ?? false
    return device
  })

  return devices as Device[]
}

export async function getDeviceCountOfUser({
  userId,
  excludeThingId,
}: {
  userId: string
  excludeThingId: string
}): Promise<number> {
  return (await getDevicesOfUser(userId)).filter(
    (device) => device.thingId !== excludeThingId
  ).length
}

export async function getDevicesOfThing(
  userId: string,
  thingId: string
): Promise<Device[]> {
  let params = {
    TableName: 'VSH',
    KeyConditionExpression: 'PK = :pk and begins_with(SK, :sk)',
    ExpressionAttributeValues: {
      ':pk': `USER#${userId}`,
      ':sk': `THING#${thingId}`,
    },
  }

  let devices: any = await new Promise((resolve, reject) => {
    docClient.query(params, function (err, data) {
      if (err) {
        return reject(err)
      } else {
        return resolve(data.Items)
      }
    })
  })

  // ensure 'retrievable' attribute is present (old records in DB might not have it yet):
  devices = devices.map((device) => {
    device.retrievable = device.retrievable ?? false
    return device
  })

  return devices as Device[]
}

export async function getThingsOfUser(userId: string) {
  const things: Set<string> = new Set()
  const devices = await getDevicesOfUser(userId)

  return [...devices.reduce((acc, curr) => acc.add(curr.thingId), things)]
}