const express = require('express')
const fetch = require('node-fetch')

const config = require('./config.js')

const server = express();

server.use((req, res, next) => {
    console.log(req.method, req.path)
    next()
})

const credentials = Buffer.from(`${config.user}:${config.pass}`).toString('base64')
const authorization = `Basic ${credentials}`

var cached_sounds = []

function headers(){
  return {
      "Content-Type": "application/x-www-form-urlencoded; charset=UTF-8",
      "Authorization": authorization,
  }
}

function fetch_library(page, tags=""){
  return fetch(`${config.baseURL}/library`, {
      "credentials": "include",
      "headers": headers(),
      "body": `type=file,url&dir=.&tags=${tags}&keywords=&page=${page}&action=query`,
      "method": "POST",
  }).then(response => {
    try {
      return response.json()
    } catch (error) {
      return {}
    }
  })
}

async function fetch_total_pages(){
    return fetch_library(1).then(data => data.total_pages)
}

async function fetch_page(page){
    return fetch_library(page).then(data => data.items)
}

function enqueue(id){
  fetch(`${config.baseURL}/post`, {
    "credentials": "include",
    "headers": headers(),
    "body": `add_item_next=${id}`,
    "method": "POST",
  }).then(response => {
    try {
      return response.json()
    } catch (error) {
      return {}
    }
  })
  .then(data => console.log(`Added ${id} to queue`));
}

function playlist(){
  return fetch(`${config.baseURL}/playlist`, {
    "credentials": "include",
    "headers": headers(),
    "method": "GET",
  }).then(response => {
    try {
      return response.json()
    } catch (error) {
      return {}
    }
  })
}

async function get_all_sounds(){
  let sounds = []
  total_pages = await fetch_total_pages()
  let i = 1
  while(i <= total_pages){
    let items = await fetch_page(i)
    items.forEach(item => {
      let tags = item.tags.map( i => {return i[0]} )
      if(item.type =="File"){
        let parts = item.path.split("-", 2)
        let name = item.path
        if(parts.length > 1){
          name = parts[1]
        }
        let parts2 = name.split("/", 2)
        if(parts2.length > 1){
            name = parts2[1]
        }
        // NOTE: tags is index here to unpack the list it comes in...
        // [ [tag1, tag2] ]
        sounds.push({
          "id": item.id,
          "name": name,
          "path": item.path,
          "tags": tags,
          "type": "file",
        })
      } else if (item.type == "URL") {
        sounds.push({
          "id": item.id,
          "name": item.title,
          "type": "url",
          "tags": tags,
        })
      }
    })
    i++
  }
  cached_sounds = sounds
  return sounds
}

async function organize_sounds(){
  let sounds = {}
  config.names.forEach(name => {
    sounds[name] = []
  })
  let other = []
  let tags = {}
  all_sounds = await get_all_sounds()
  all_sounds.forEach(item => {
    if (item.tags){
        item.tags.forEach(tag => {
          if(!tags.hasOwnProperty(tag)){
            tags[tag] = []
          }
          tags[tag].push(item)
        })
    }
    let matched = false
    Object.keys(sounds).forEach(name => {
      if(item.type == "file"){
        path = item.path.split("-")[0]
        if(path.toLowerCase().indexOf(name) != -1){
          sounds[name].push(item)
          matched = true
        }
      }
    })
    if(!matched){
      other.push(item)
    }
  })
  sounds["other"] = other
  return {"sounds": sounds, "tags": tags}
}

server.get('/', async (req, res) => {
  var html = `
  <style>
    div.btn {
        cursor: pointer;
        background-color: #ddd;
        border: 1px solid black;
        padding: 0.25em;
        margin: 0.25em;
    }
    div.tags {
        margin-left: 2em;
        font-style: italic;
    }
    span.time {
        font-style: italic;
    }
    div.container {
        display: flex;
        flex-wrap: wrap;
    }
    h2 {
        margin: 0;
        font-size: 16px;
        display: inline;
        margin-right: 1em;
    }
    li {
        border: 1px solid gray;
        margin: 0.5em;
    }
    li button {
        float: right;
    }
  </style>
  <script src="/main.js"></script>
  <div>
    <h1>Now playling</h1>
    <ol id="playlist"><ol>
  </div>
  <button onclick="random()">random</button>
  <body>
   `
  try {
    let soundObj = await organize_sounds()
    let sounds = soundObj["sounds"]
    let tags = soundObj["tags"]
    Object.keys(sounds).forEach(title => {
      html += `<h1>${title.toUpperCase()}</h1><div class="container">`
      sounds[title].forEach(item => {
        let tags = ""
        if(item.tags){
          tags = `<div class="tags">${item.tags.join(", ")}</div>`
        }
          try {
            html += `<div class="btn" onclick="enqueue(['${item.id}'])"><div>${item.name}</div>${tags}</div>\n`
          } catch (error) {
              console.log(error)
          }
      })
      html += `</div>`
    })
    html += `<h1>Tags</h1><div class="container">`
    Object.keys(tags).forEach(tagName => {
      let idsForTag = tags[tagName].map( item => {return item.id})
      let idsString = idsForTag.join("', '")
      html += `<div class="btn" onclick="enqueue(['${idsString}'])">Add all '${tagName}'</div>\n`
    })
    html += `</div>`
    html += "</body>"
    res.send(html);
  } catch (error){
    console.log(error)
  }
})

server.get('/random', async (req, res, next) => {
  let all_sounds = cached_sounds
  let filtered_sounds = all_sounds.filter(item => {
    return item.type == "file" && !item.path.startsWith("uploads/")
  })
  let rand_sound = filtered_sounds[Math.floor(Math.random() * filtered_sounds.length)]
  enqueue(rand_sound.id)
  res.send("ok")
})

server.get('/playlist', async (req, res, next) => {
  let playlist_items = await playlist()
  res.send(playlist_items)
})

server.get('/main.js', async (req, res, next) => {
  res.sendFile(__dirname + "/main.js")
})

server.get('/delete/:id', async (req, res, next) => {
  fetch(`${config.baseURL}/post`, {
      "credentials": "include",
      "headers": headers(),
      "body": `delete_music=${req.params.id}`,
      "method": "POST",
  })
  res.send("ok")
})

server.get('/:id', async (req, res, next) => {
  enqueue(req.params.id)
  res.send("ok")
})

console.log("listening...")
server.listen(config.port)