emailAddresses = require 'email-addresses'
_              = require 'lodash'
moment         = require 'moment'
url            = require 'url'
cheerio        = require 'cheerio'
urlregexp      = require 'urlregexp'

debug = require('debug')('bourse:exchange-service')

AuthenticatedRequest = require './authenticated-request'
ExchangeStream       = require '../streams/exchange-stream'

createItemRequest                      = require '../templates/createItemRequest'
deleteItemRequest                      = require '../templates/deleteItemRequest'
getCalendarItemsInRangeRequest         = require '../templates/getCalendarItemsInRangeRequest'
getIdAndKey                            = require '../templates/getIdAndKey'
getInboxRequest                        = require '../templates/getInboxRequest'
getItemRequest                         = require '../templates/getItemRequest'
findItemsByExtendedPropertyRequest     = require '../templates/findItemsByExtendedPropertyRequest'
getItemsByItemIdsRequest               = require '../templates/getItemsByItemIdsRequest'
getItems                               = require '../templates/getItems'
getStreamingEventsRequest              = require '../templates/getStreamingEventsRequest'
getSubscriptionRequest                 = require '../templates/getSubscriptionRequest'
getUserCalendarConfigurationRequest    = require '../templates/getUserCalendarConfigurationRequest'
getUserSettingsRequest                 = require '../templates/getUserSettingsRequest'
updateItemRequest                      = require '../templates/updateItemRequest'
forwardItemRequest                     = require '../templates/forwardItemRequest'
updateUserCalendarConfigurationRequest = require '../templates/updateUserCalendarConfigurationRequest'

SUBSCRIPTION_ID_PATH = 'Envelope.Body.SubscribeResponse.ResponseMessages.SubscribeResponseMessage.SubscriptionId'

class Exchange
  constructor: ({protocol, hostname, port, @username, @password, authHostname, timeout}) ->
    throw new Error 'Missing required parameter: hostname' unless hostname?
    throw new Error 'Missing required parameter: username' unless @username?
    throw new Error 'Missing required parameter: password' unless @password?

    protocol ?= 'https'
    port ?= 443
    timeout ?= 120 * 1000
    @connectionOptions = {protocol, hostname, port, @username, @password, authHostname, timeout}
    @authenticatedRequest = new AuthenticatedRequest @connectionOptions

  authenticate: (callback) =>
    @authenticatedRequest.doEws body: getInboxRequest(), (error, response, extra) =>
      return callback error if error?
      {statusCode} = extra
      return callback null, true if statusCode == 200
      return callback null, false if statusCode == 401
      return callback @_errorWithCode(statusCode, "Error received: #{statusCode}")

  _prepareExtendedProperties: (extendedProperties) =>
    _.mapKeys extendedProperties, (value, key) =>
      _.kebabCase key

  createItem: ({ timeZone, sendTo, subject, body, reminder, start, end, location, attendees, extendedProperties }, callback) =>
    attendees = _.filter attendees, @_isEmailAddress
    extendedProperties = @_prepareExtendedProperties extendedProperties
    body = createItemRequest({ timeZone, sendTo, subject, body, reminder, start, end, location, attendees, extendedProperties })
    @authenticatedRequest.doEws { body }, (error, response, extra) =>
      return callback error if error?
      return callback new Error("Non 200 status code: #{extra.statusCode}") if extra.statusCode != 200
      return callback @_parseCreateItemErrorResponse response if @_isCreateItemError response
      return callback null, @_parseCreateItemResponse response

  deleteItem: ({Id, changeKey, cancelReason}, callback) =>
    @authenticatedRequest.doEws body: deleteItemRequest({Id, changeKey, cancelReason}), (error, response) =>
      return callback error if error?
      return callback null, @_parseDeleteItemResponse response

  findItemsByExtendedProperty: ({Id, key, value, extendedProperties}, callback) =>
    extendedProperties = @_prepareExtendedProperties extendedProperties
    @authenticatedRequest.doEws body: findItemsByExtendedPropertyRequest({ Id, key, value, extendedProperties }), (error, response, extra) =>
      return callback error if error?
      return callback new Error("Non 200 status code: #{extra.statusCode}") if extra.statusCode != 200
      return callback @_parseFindItemsErrorResponse response if @_isFindItemsError response
      return callback null, @_parseFindItemsResponse response

  getCalendarItemsInRange: ({ start, end, extendedProperties }, callback) =>
    start = moment.utc start
    end   = moment.utc end
    body = getCalendarItemsInRangeRequest({ start, end })
    @authenticatedRequest.doEws { body }, (error, response, extra) =>
      return callback error if error?
      debug(JSON.stringify(extra, null, 2)) if extra.statusCode != 200
      return callback new Error("Non 200 status code: #{extra.statusCode}") if extra.statusCode != 200
      return callback @_parseCalendarItemsInRangeErrorResponse response if @_isCalendarItemsInRangeError response
      itemIds = @_parseCalendarItemsInRangeResponse response
      return callback null, [], extra if _.isEmpty itemIds
      @_getItemsByItemIds {itemIds, extendedProperties}, callback

  getIDandKey: ({distinguishedFolderId}, callback) =>
    @authenticatedRequest.doEws body: getIdAndKey({ distinguishedFolderId }), (error, response) =>
      return callback error if error?
      return callback null, response

  getItem: ({itemId}, callback) =>
    @authenticatedRequest.doEws body: getItemRequest({itemId}), (error, response, extra) =>
      return callback error if error?
      return callback new Error("Non 200 status code: #{extra.statusCode}") if extra.statusCode != 200
      return callback new Error('Empty Response') unless response?
      return callback new Error('Item Not Found') if @_isItemNotFound response
      return callback null, @_parseGetItemResponse response

  getItemByItemId: (itemId, callback) =>
    @getItem {itemId}, callback

  getItems: (Id, changeKey, maxEntries, startDate, endDate, callback) =>
    @authenticatedRequest.doEws body: getItems({ Id, changeKey, maxEntries, startDate, endDate }), (error, response) =>
      return callback error if error?
      return callback null, response

  getStreamingEvents: ({distinguishedFolderId}, callback) =>
    @_getSubscriptionId {distinguishedFolderId}, (error, subscriptionId) =>
      return callback error if error?

      @authenticatedRequest.getOpenEwsRequest body: getStreamingEventsRequest({ subscriptionId }), (error, request) =>
        return callback error if error?
        return callback null, new ExchangeStream {@connectionOptions, request}

  getStreamingEventsRequest: ({subscriptionId}, callback) =>
    @authenticatedRequest.getOpenEwsRequest body: getStreamingEventsRequest({ subscriptionId }), (error, response) =>
      return callback error if error?
      return callback null, response

  getUserCalendarConfiguration: (callback) =>
    @authenticatedRequest.doEws body: getUserCalendarConfigurationRequest(), (error, response) =>
      return callback error if error?
      @_parseUserCalendarConfigurationResponse response, callback

  getUserSettingsRequest: ({username}, callback) =>
    @authenticatedRequest.doAutodiscover body: getUserSettingsRequest({ username }), (error, response) =>
      return callback error if error?
      @_parseUserSettingsResponse response, callback

  updateItem: (options, callback) =>
    # they must exist
    options.subject ?= null
    options.end ?= null
    options.start ?= null
    options.location ?= null
    options.attendees ?= null
    options.sendMeetingInvitationsOrCancellations ?= 'SendToAllAndSaveCopy'
    debug 'updateItem-options', options
    debug 'updateItem', updateItemRequest(options)
    @authenticatedRequest.doEws body: updateItemRequest(options), (error, response, extra) =>
      return callback error if error?
      return callback new Error("Non 200 status code: #{extra.statusCode}") if extra.statusCode != 200
      return callback @_parseUpdateItemErrorResponse response if @_isUpdateItemError response
      return callback null, @_parseUpdateItemResponse response

  forwardItem: (options, callback) =>
    # they must exist
    debug 'forwardItem-options', options
    debug 'forwardItem', forwardItemRequest(options)
    @authenticatedRequest.doEws body: forwardItemRequest(options), (error, response, extra) =>
      return callback error if error?
      return callback new Error("Non 200 status code: #{extra.statusCode}") if extra.statusCode != 200
      return callback @_parseForwardItemErrorResponse response if @_isForwardItemError response
      return callback null, @_parseForwardItemResponse response

  updateUserCalendarConfiguration: ({piAutoProcess}, callback) =>
    @authenticatedRequest.doEws body: updateUserCalendarConfigurationRequest({piAutoProcess}), (error, response) =>
      return callback error if error?
      @_parseUserCalendarConfigurationUpdateResponse response, callback

  whoami: (callback) =>
    @authenticatedRequest.doAutodiscover body: getUserSettingsRequest({@username}), (error, response, extra) =>
      return callback error if error?
      return callback @_errorWithCode(401, 'Unauthorized'), null, extra if extra.statusCode == 401
      @_parseUserSettingsResponse response, (error, userSettings) =>
        return callback error, null, extra if error?
        return callback null, userSettings, extra

  _errorWithCode: (code, message) =>
    error = new Error message
    error.code = code
    return error

  _getItemsByItemIds: ({ itemIds, extendedProperties }, callback) =>
    extendedProperties = @_prepareExtendedProperties extendedProperties
    @authenticatedRequest.doEws body: getItemsByItemIdsRequest({itemIds, extendedProperties}), (error, response, extra) =>
      return callback error if error?
      return callback new Error("Non 200 status code: #{extra.statusCode}") if extra.statusCode != 200
      return callback @_parseGetItemsErrorResponse response if @_isGetItemsError response
      return callback null, @_parseGetItemsResponse response

  _getSubscriptionId: ({distinguishedFolderId}, callback) =>
    @authenticatedRequest.doEws body: getSubscriptionRequest({distinguishedFolderId}), (error, response) =>
      return callback error if error
      return callback null, _.get(response, SUBSCRIPTION_ID_PATH)

  _isCalendarItemsInRangeError: (response) =>
    responseMessage = _.get response, 'Envelope.Body.FindItemResponse.ResponseMessages.FindItemResponseMessage'
    responseClass   = _.get responseMessage, '$.ResponseClass'

    return responseClass == 'Error'

  _isCreateItemError: (response) =>
    responseMessage = _.get response, 'Envelope.Body.CreateItemResponse.ResponseMessages.CreateItemResponseMessage'
    return 'Error' == _.get responseMessage, '$.ResponseClass'

  _isEmailAddress: (str) =>
    return emailAddresses(str)?

  _isGetItemsError: (response) =>
    responseMessage = _.get response, 'Envelope.Body.GetItemResponse.ResponseMessages.GetItemResponseMessage'
    return 'Error' == _.get responseMessage, '$.ResponseClass'

  _isFindItemsError: (response) =>
    responseMessage = _.get response, 'Envelope.Body.FindItemResponse.ResponseMessages.FindItemResponseMessage'
    return 'Error' == _.get responseMessage, '$.ResponseClass'

  _isItemNotFound: (response) =>
    responseCode = _.get response, 'Envelope.Body.GetItemResponse.ResponseMessages.GetItemResponseMessage.ResponseCode'
    return responseCode == 'ErrorItemNotFound'

  _isUpdateItemError: (response) =>
    responseMessage = _.get response, 'Envelope.Body.UpdateItemResponse.ResponseMessages.UpdateItemResponseMessage'
    return 'Error' == _.get responseMessage, '$.ResponseClass'

  _isForwardItemError: (response) =>
    responseMessage = _.get response, 'Envelope.Body.CreateItemResponse.ResponseMessages.CreateItemResponseMessage'
    return 'Error' == _.get responseMessage, '$.ResponseClass'

  _normalizeDatetime: (datetime) =>
    moment(datetime).utc().format()

  _parseAttendee: (attendee) =>
    {
      name: _.get attendee, 'Mailbox.Name'
      email: _.get attendee, 'Mailbox.EmailAddress'
    }

  _parseAttendees: (meetingRequest) =>
    requiredAttendees = _.castArray _.get(meetingRequest, 'RequiredAttendees.Attendee')
    optionalAttendees = _.castArray _.get(meetingRequest, 'OptionalAttendees.Attendee')
    attendees = _.union requiredAttendees, optionalAttendees
    _.map attendees, @_parseAttendee

  _parseCreateItemErrorResponse: (response) =>
    responseMessage = _.get response, 'Envelope.Body.CreateItemResponse.ResponseMessages.CreateItemResponseMessage'
    message = _.get responseMessage, 'MessageText'

    error = new Error "Unprocessable Entity: #{message}"
    error.code = 422
    return error

  _parseCreateItemResponse: (response) =>
    ResponseMessage = _.get response, 'Envelope.Body.CreateItemResponse.ResponseMessages.CreateItemResponseMessage'
    Item = _.get ResponseMessage, 'Items.CalendarItem'
    {
      itemId:       _.get Item, 'ItemId.$.Id'
      changeKey:    _.get Item, 'ItemId.$.ChangeKey'
      UID:          _.get Item, 'UID'
      recurrenceId: _.get Item, 'RecurrenceId'
    }

  _parseDeleteItemResponse: (response) =>
    ResponseMessage = _.get response, 'Envelope.Body.CreateItemResponse.ResponseMessages.CreateItemResponseMessage'
    Item = _.get ResponseMessage, 'Items.CalendarItem'
    {
      itemId:       _.get Item, 'ItemId.$.Id'
      changeKey:    _.get Item, 'ItemId.$.ChangeKey'
      UID:          _.get Item, 'UID'
      recurrenceId: _.get Item, 'RecurrenceId'
    }

  _parseCalendarItemsInRangeErrorResponse: (response) =>
    responseMessage = _.get response, 'Envelope.Body.FindItemResponse.ResponseMessages.FindItemResponseMessage'
    error = new Error _.get(responseMessage, 'MessageText')
    error.code = 422
    return error

  _parseCalendarItemsInRangeResponse: (response) =>
    responseMessages = _.get response, 'Envelope.Body.FindItemResponse.ResponseMessages'
    items = _.castArray _.get responseMessages, 'FindItemResponseMessage.RootFolder.Items.CalendarItem'
    _.compact _.map(items, 'ItemId.$.Id')

  _parseFindItemsErrorResponse: (response) =>
    responseMessage = _.get response, 'Envelope.Body.FindItemResponse.ResponseMessages.FindItemResponseMessage'
    error = new Error _.get(responseMessage, 'MessageText')
    error.code = 422
    return error

  _parseGetItemsErrorResponse: (response) =>
    responseMessage = _.get response, 'Envelope.Body.GetItemResponse.ResponseMessages.GetItemResponseMessage'
    error = new Error _.get(responseMessage, 'MessageText')
    error.code = 422
    return error

  _parseGetItemResponse: (response) =>
    items = _.get response, 'Envelope.Body.GetItemResponse.ResponseMessages.GetItemResponseMessage.Items'
    meetingRequest = _.first _.values items
    @_parseMeetingRequest meetingRequest

  _parseMeetingRequest: (meetingRequest) =>
    return {
      subject: _.get meetingRequest, 'Subject'
      startTime: @_normalizeDatetime _.get(meetingRequest, 'StartWallClock')
      endTime:   @_normalizeDatetime _.get(meetingRequest, 'EndWallClock')
      accepted: "Accept" == _.get(meetingRequest, 'ResponseType')
      eventType: 'modified'
      itemId: _.get meetingRequest, 'ItemId.$.Id'
      changeKey: _.get meetingRequest, 'ItemId.$.ChangeKey', null
      UID: _.get meetingRequest, 'UID'
      recurrenceId: _.get meetingRequest, 'RecurrenceId'
      location: _.get meetingRequest, 'Location'
      recipient:
        name: _.get meetingRequest, 'ReceivedBy.Mailbox.Name'
        email: _.get meetingRequest, 'ReceivedBy.Mailbox.EmailAddress'
      organizer:
        name: _.get meetingRequest, 'Organizer.Mailbox.Name'
        email: _.get meetingRequest, 'Organizer.Mailbox.EmailAddress'
      attendees: @_parseAttendees(meetingRequest)
      urls: @_parseUrls(meetingRequest)
      joinOnlineMeetingUrl: _.get(meetingRequest, 'JoinOnlineMeetingUrl')
      extendedProperties: @_parseExtendedProperties(meetingRequest)
    }

  _parseExtendedProperties: (response) =>
    extendedProperties = _.castArray _.get response, 'ExtendedProperty'
    result = {}
    _.each extendedProperties, (extendedFieldURI) =>
      propertyName = _.get extendedFieldURI, 'ExtendedFieldURI.$.PropertyName'
      name = _.camelCase propertyName?.replace /X-/, ''
      value = _.get extendedFieldURI, 'Value'
      result[name] = value
    return result

  _parseGetItemsResponse: (response) =>
    ResponseMessages = _.get response, 'Envelope.Body.GetItemResponse.ResponseMessages'
    GetItemResponseMessages = _.castArray _.get(ResponseMessages, 'GetItemResponseMessage')
    meetingRequests = _.compact _.map GetItemResponseMessages, 'Items.CalendarItem'
    meetingRequests = _.reject meetingRequests, {'IsCancelled': 'true'}

    _.map meetingRequests, @_parseMeetingRequest

  _parseFindItemsResponse: (response) =>
    ResponseMessages = _.get response, 'Envelope.Body.FindItemResponse.ResponseMessages'
    GetItemResponseMessages = _.castArray _.get(ResponseMessages, 'FindItemResponseMessage')
    meetingRequests = _.compact _.flatten _.map GetItemResponseMessages, 'RootFolder.Items.CalendarItem'
    meetingRequests = _.reject meetingRequests, {'IsCancelled': 'true'}

    _.map meetingRequests, @_parseMeetingRequest

  _parseForwardItemErrorResponse: (response) =>
    responseMessage = _.get response, 'Envelope.Body.CreateItemResponse.ResponseMessages.CreateItemResponseMessage'
    message = _.get responseMessage, 'MessageText'

    error = new Error "Unprocessable Entity: #{message}"
    error.code = 422
    return error

  _parseUpdateItemErrorResponse: (response) =>
    responseMessage = _.get response, 'Envelope.Body.UpdateItemResponse.ResponseMessages.UpdateItemResponseMessage'
    message = _.get responseMessage, 'MessageText'

    error = new Error "Unprocessable Entity: #{message}"
    error.code = 422
    return error

  _parseUpdateItemResponse: (response) =>
    ResponseMessage = _.get response, 'Envelope.Body.UpdateItemResponse.ResponseMessages.UpdateItemResponseMessage'
    Item = _.get ResponseMessage, 'Items.CalendarItem'
    {
      itemId:       _.get Item, 'ItemId.$.Id'
      changeKey:    _.get Item, 'ItemId.$.ChangeKey'
      UID:          _.get Item, 'UID'
      recurrenceId: _.get Item, 'RecurrenceId'
    }

  _parseForwardItemResponse: (response) =>
    ResponseMessage = _.get response, 'Envelope.Body.CreateItemResponse.ResponseMessages.CreateItemResponseMessage'
    ResponseCode = _.get ResponseMessage, 'ResponseCode'
    return {} if ResponseCode == 'NoError'
    {
      error: 'Unknown error'
    }

  _parseUrls: (meetingRequest) =>
    body = _.get meetingRequest, 'Body._', ''
    location = _.get meetingRequest, 'Location', ''
    locationUrls = location.match urlregexp
    joinMeetingUrls = [ _.get(meetingRequest, 'JoinOnlineMeetingUrl') ]
    entityExtraction = _.castArray _.get(meetingRequest, 'EntityExtractionResult.Urls.UrlEntity')
    entityUrls = _.map entityExtraction, 'Url'

    $ = cheerio.load body
    bodyUrls = $('a').map (index, element) =>
      $(element).attr 'href'

    matches = _.compact _.union(bodyUrls, locationUrls, entityUrls, joinMeetingUrls)

    _.map matches, (match) =>
      parsed = url.parse match
      return {
        url: match
        hostname: parsed.hostname
      }

  _parseUserCalendarConfigurationResponse: (response, callback) =>
    ResponseMessage = _.get response, 'Envelope.Body.GetUserConfigurationResponse.ResponseMessages.GetUserConfigurationResponseMessage'
    ResponseCode    = _.get ResponseMessage, 'ResponseCode'
    DictionaryEntry = _.castArray _.get(ResponseMessage, 'UserConfiguration.Dictionary.DictionaryEntry')
    return callback new Error "Unexpected ResponseCode #{ResponseCode}" unless ResponseCode == 'NoError'

    piAutoProcess = _.find(DictionaryEntry, (entry) => 'piAutoProcess' == _.get(entry, 'DictionaryKey.Value'))

    callback null, {
      piAutoProcess: 'true' == _.get(piAutoProcess, 'DictionaryValue.Value')
    }

  _parseUserCalendarConfigurationUpdateResponse: (response, callback) =>
    ResponseMessage = _.get response, 'Envelope.Body.UpdateUserConfigurationResponse.ResponseMessages.UpdateUserConfigurationResponseMessage'
    ResponseCode    = _.get ResponseMessage, 'ResponseCode'
    return callback new Error "Unexpected ResponseCode #{ResponseCode}" unless ResponseCode == 'NoError'
    return callback null

  _parseUserSettingsResponse: (response, callback) =>
    UserResponse = _.get response, 'Envelope.Body.GetUserSettingsResponseMessage.Response.UserResponses.UserResponse'
    UserSettings = _.get UserResponse, 'UserSettings.UserSetting'

    name = _.get _.find(UserSettings, Name: 'UserDisplayName'), 'Value'

    return callback null, { name }

  _reverseHostname: (hostname) => # meet.citrix.com => com.citrix.meet
    levels = _.reverse _.split(hostname, '.')
    return _.join levels, '.'

module.exports = Exchange