notifme/notifme-sdk

/* @flow */
import PushNotifications from 'node-pushnotifications'
// Types
import type { PushRequestType } from '../../models/notification-request'

export default class PushWnsProvider {
  id: string = 'push-wns-provider'
  transporter: Object

  constructor (config: Object) {
    this.transporter = new PushNotifications({
      wns: {
        ...config,
        client_id: config.clientId,
        client_secret: config.clientSecret
      }
    })
  }

  async send (request: PushRequestType): Promise<string> {
    const { registrationToken, ...rest } =
      request.customize ? (await request.customize(this.id, request)) : request
    const result = await this.transporter.send([registrationToken], rest)
    if (result[0].failure > 0) {
      throw new Error(result[0].message[0].error)
    } else {
      return result[0].message[0].messageId
    }
  }
}