require 'action_view'

##
##                 When I receive one.
## 2023-12-28 _vp_ Continue.
##
class WcoEmail::Message
  include Mongoid::Document
  include Mongoid::Timestamps
  include Mongoid::Paranoia
  store_in collection: 'wco_email_message'

  field :message_id # MESSAGE-ID
  validates :message_id, presence: true, uniqueness: true
  index({ message_id: 1 }, { unique: true, name: "message_id_idx" })

  field :in_reply_to_id, type: :string

  field     :bucket, default: 'ish-ses'

  field     :object_key ## aka 'filename', use with bucket name + prefix. I need this!
  validates :object_key, presence: true, uniqueness: true
  index({ object_key: 1 }, { unique: true, name: "object_key_idx" })

  field :subject

  field :part_html

  field :read_at, type: DateTime
  index({ read_at: -1 })
  def self.unread
    where( read_at: nil )
  end
  # scope :unread, ->() { where( read_at: nil ) }

  def part_html_sanitized
    doc = Nokogiri::HTML part_html
    images = doc.search('img')
    images.each do |img|
      img['src'] = 'missing'
    end
    doc.search('script').remove
    doc.search('meta').remove
    # doc.xpath('//@style').remove
    doc.to_s.gsub('http', '').gsub('href="s://', 'href="https://')
  end

  def part_html_fully_sanitized
    ActionView::Base.full_sanitizer.sanitize( part_html||'' ).squish
  end

  def preview_str
    part_html_fully_sanitized[0..200]
  end

  field :part_txt

  field :from,   type: :string
  field :froms,  type: Array, default: []
  belongs_to :lead, class_name: 'Wco::Lead', inverse_of: :email_messages

  field :to,     type: :string
  field :tos,    type: Array, default: []
  field :cc,     type: :string
  field :ccs,    type: Array, default: []
  def all_ccs; (tos||[]) + (ccs||[]) + (froms||[]); end
  field :bcc,    type: :string
  field :bccs,   type: Array, default: []

  field :logs, type: Array, default: []

  field :date, type: DateTime
  def received_at ; date ; end

  belongs_to :conversation, class_name: 'WcoEmail::Conversation', index: true
  def conv ; conversation ; end

  belongs_to :stub, class_name: 'WcoEmail::MessageStub'

  has_many :assets,  class_name: '::Wco::Asset'
  has_many :photos,  class_name: '::Wco::Photo'
  has_many :replies, class_name: '::WcoEmail::Context', inverse_of: :reply_to_message

  def apply_filter filter
    puts! filter, 'WcoEmail::Message#apply_filter' if DEBUG
    conv.filter = filter

    case filter.kind

    when WcoEmail::EmailFilter::KIND_DESTROY_SCHS
      conv.tags.push   Wco::Tag.trash
      conv.tags -= [ Wco::Tag.inbox ]
      lead.schs.each do |sch|
        sch.update_attributes!({ state: ::Sch::STATE_TRASH })
      end

    when WcoEmail::EmailFilter::KIND_ADD_TAG
      conv.tags.push filter.tag
      if filter.tag == Wco::Tag.trash || filter.tag == Wco::Tag.spam
        conv.tags -= [ Wco::Tag.inbox ]
      end

    when WcoEmail::EmailFilter::KIND_REMOVE_TAG
      conv.tags -= [ filter.tag ]

    when WcoEmail::EmailFilter::KIND_AUTORESPOND_TMPL
      WcoEmail::Context.create!({
        email_template: filter.email_template,
        lead_id:        lead.id,
        send_at:        Time.now,
      })

    when WcoEmail::EmailFilter::KIND_AUTORESPOND_EACT
      ##
      ## This error is normal:
      ## Mongoid::Errors::Validations `Email action template is already taken`
      ##
      out = Sch.create({
        email_action_template: filter.email_action_template,
        status:                Sch::STATUS_ACTIVE,
        lead_id:               lead.id,
        perform_at:            Time.now,
      })

    else
      raise "unknown filter kind: #{filter.kind}"
    end

    conv.save!
  end

  ## From: https://stackoverflow.com/questions/24672834/how-do-i-remove-emoji-from-string/24673322
  def self.strip_emoji(text)
    text = '' if text.blank?
    text = text.force_encoding('utf-8').encode
    clean = ""

    # symbols & pics
    regex = /[\u{1f300}-\u{1f5ff}]/
    clean = text.gsub regex, ""

    # enclosed chars
    regex = /[\u{2500}-\u{2BEF}]/ # I changed this to exclude chinese char
    clean = clean.gsub regex, ""

    # emoticons
    regex = /[\u{1f600}-\u{1f64f}]/
    clean = clean.gsub regex, ""

    #dingbats
    regex = /[\u{2702}-\u{27b0}]/
    clean = clean.gsub regex, ""
  end
  def strip_emoji text
    WcoEmail::Message.strip_emoji text
  end

  ## For recursive parts of type `related`.
  ## Content dispositions:
  # "inline; creation-date=\"Tue, 11 Apr 2023 19:39:42 GMT\"; filename=image005.png; modification-date=\"Tue, 11 Apr 2023 19:47:53 GMT\"; size=14916",
  #
  ## Content Types:
  # "application/pdf; name=\"Securities Forward Agreement -- HaulHub Inc -- Victor Pudeyev -- 2021-10-26.docx.pdf\""
  # "image/jpeg; name=TX_DL_2.jpg"
  # "image/png; name=image005.png"
  # "multipart/alternative; boundary=_000_BL0PR10MB2913C560ADE059F0AB3A6D11829A9BL0PR10MB2913namp_",
  # "text/html; charset=utf-8"
  # "text/plain; charset=UTF-8"
  # "text/calendar; charset=utf-8; method=REQUEST"
  def churn_subpart part
    if part.content_disposition&.include?('attachment')
      save_attachment( part, filename: "subpart-attachment" )
    else
      if part.content_type.include?("multipart")
        part.parts.each do |subpart|
          churn_subpart( subpart )
        end
      else
        if part.content_type.include?('text/html')
          self.part_html = strip_emoji( part.decoded )

        elsif part.content_type.include?("text/plain")
          self.part_txt = part.decoded

        elsif part.content_type.include?("text/calendar")
          save_attachment( part, filename: 'subpart-calendar.ics' )

        elsif part.content_type.include?("application/pdf")
          save_attachment( part, filename: 'subpart.pdf' )

        elsif part.content_type.include?("image/jpeg")
          save_attachment( part, filename: 'subpart.jpg' )

        elsif part.content_type.include?("image/png")
          save_attachment( part, filename: 'subpart.png' )

        else
          save_attachment( part, filename: 'subpart-unspecified' )
          self.logs.push "444 No action for a part with content_type #{part.content_type}"

        end
      end
    end
  end

  def save_attachment att, filename: "no-filename-specified"
    config = JSON.parse(stub.config)
    if defined?( config['process_images'] ) &&
      false == config['process_images']
      return
    end

    content_type = att.content_type.split(';')[0]
    if content_type.include? 'image'
      photo = ::Wco::Photo.new({
        content_type:      content_type,
        email_message_id:  self.id,
        image_data:        att.body.encoded,
        original_filename: att.content_type_parameters[:name],
      })
      photo.decode_base64_image
      photo.save

    else
      filename   = CGI.escape( att.filename || filename )
      sio = StringIO.new att.body.decoded
      File.open("/tmp/#{filename}", 'w:UTF-8:ASCII-8BIT') do |f|
        f.puts(sio.read)
      end
      asset = ::Wco::Asset.new({
        email_message: self,
        filename:      filename,
        object:        File.open("/tmp/#{filename}"),
      })
      if !asset.save
        self.logs.push "Could not save a wco asset: #{asset.errors.full_messages.join(", ")}"
        self.save
      end
    end
  end



end
::Msg = WcoEmail::Message