const sleep = wait => new Promise(resolve => setTimeout(resolve, wait))

let vm = new Vue({
  el: '#app',
  data: {
    i: {
      accessToken: '',
      csv: '',
      msg: '',
      proxy: '',
      to: '',
    },
    ready: false,
    status: '',
    error: ''
  },
  async mounted () {
    try {
      let saved = JSON.parse(localStorage.getItem('zYYMrLb'))
      if (saved) this.$set(this, 'i', {...this.i, ...saved})
    } catch (err) {}
    this.$watch('i', (newVal, oldVal) => {
      localStorage.setItem('zYYMrLb', JSON.stringify(this.i))
    }, { deep: true })
    this.ready = true
  },
  methods: {
    async linePush () {
      const errors = []
      try {
        // 取得 csv
        this.status = '正在從 csv 取得資料'
        const rows = await this.getCsv(this.i.csv)
        console.log(`成功從 csv 中取得 ${rows.length} 筆資料`)
        if (rows.length <= 0) throw new Error('csv 中沒有任何記錄')

        // 推送確認
        this.status = '等候使用者確認推送'
        await sleep(100)
        if (!confirm(`即將推送 ${rows.length} 則訊息！`)) throw new Error('使用者自行取消推送')

        // compile tpl
        this.status = '正在解析訊息內容 JSON'
        const tplTo = _.template(this.i.to)
        const tplMsg = _.template(this.i.msg)
        
        let sendCnt = 0
        for (const item of rows) {
          try {
            this.status = `正在傳送訊息 (${++sendCnt} / ${rows.length})`
            const to = tplTo({...item, _})
            const msg = JSON.parse(tplMsg({...item, _}))
            await this.pushMessage(to, msg)
          } catch (err) {
            err.message = `${this.status} ${err.message}`
            errors.push(err)
          }
        }
      } catch (err) {
        errors.push(err)
      }
      console.log(errors)
      this.error = _.map(errors, err => err.message).join('\n')
      this.status = ''
    },
    async getCsv (url) {
      url = new URL(url)
      url.searchParams.set('cachebust', +new Date())
      const csv = _.trim(_.get(await axios.get(url.href), 'data'))
      return _.get(Papa.parse(csv, {
        encoding: 'utf8',
        header: true,
      }), 'data', [])
    },
    async pushMessage (to, messages, notificationDisabled = false) {
      try {
        if (!_.isArray(messages)) messages = [messages]
        await axios.post(this.i.proxy, {
          to,
          messages,
          notificationDisabled
        }, {
          headers: {
            Authorization: `Bearer ${this.i.accessToken}`
          }
        })
      } catch (err) {
        if (_.hasIn(err, 'response')) {
          const res = err.response
          const debugObj = {status: res.status, headers: res.headers, data: res.data, to, messages}
          console.log(debugObj)
          err.stack = `${err.name}: LINE pushMessage failed with status code ${res.status}\n${JSON.stringify(debugObj, null, 2)}`
        }
        throw err
      }
    }
  },
})