import { applicationDefault, initializeApp } from 'firebase-admin/app'
import {
  BatchResponse,
  getMessaging,
  Message,
  MulticastMessage,
} from 'firebase-admin/messaging'
import { env } from '../env'
import { analytics } from './analytics'
import { logger } from './logger'

export type PushNotificationType = 'newsletter' | 'reminder' | 'rule'

// getting credentials from App Engine
initializeApp({
  credential: applicationDefault(),
})

export const sendPushNotification = async (
  userId: string,
  message: Message,
  type: PushNotificationType
): Promise<string | undefined> => {
  try {
    analytics.track({
      userId,
      event: 'notification_sent',
      properties: {
        type,
        multicast: false,
        env: env.server.apiEnv,
      },
    })

    const res = await getMessaging().send(message)
    logger.info(res)

    return res
  } catch (err) {
    logger.error('firebase cloud message error: ', err)

    return undefined
  }
}

export const sendMulticastPushNotifications = async (
  userId: string,
  message: MulticastMessage,
  type: PushNotificationType
): Promise<BatchResponse | undefined> => {
  try {
    analytics.track({
      userId,
      event: 'notification_sent',
      properties: {
        type,
        multicast: true,
        env: env.server.apiEnv,
      },
    })

    logger.info('sending multicast message: ', message)
    const res = await getMessaging().sendMulticast(message)
    logger.info('send notification result: ', res.responses)

    return res
  } catch (err) {
    logger.error('firebase cloud message error: ', err)

    return undefined
  }
}

export const sendBatchPushNotifications = async (
  messages: Message[]
): Promise<BatchResponse | undefined> => {
  try {
    const res = await getMessaging().sendAll(messages)
    logger.info(`success count: ${res.successCount}`)

    return res
  } catch (err) {
    logger.error('firebase cloud message error: ', err)

    return undefined
  }
}