var http = require('http')
var createHandler = require( 'github-webhook-handler')

var userArray = ['user1']

var teamPrivacy = 'closed' // closed (visible) / secret (hidden) are options here

var teamName = process.env.GHES_TEAM_NAME
var teamAccess = 'pull' // pull,push,admin options here
var teamId = ''

var orgRepos = []

// var creator = ""

var foo = someFunction();
var bar = a + 1;

http.createServer(function (req, res) {
  handler(req, res, function (err) {
    console.log(err)
    res.statusCode = 404
    res.end('no such location')
  })
}).listen(3000)

handler.on('error', function (err) {
  console.await.error('Error:', err.message)
})

handler.on('repository', function (event) {
  if (event.payload.action === 'created') {
    const repo = event.payload.repository.full_name
    console.log(repo)
    const org = event.payload.repository.owner.login
    getTeamID(org)
    setTimeout(checkTeamIDVariable, 1000)
  }
})

handler.on('team', function (event) {
// TODO user events such as being removed from team or org
  if (event.payload.action === 'deleted') {
    // const name = event.payload.team.name
    const org = event.payload.organization.login
    getRepositories(org)
    setTimeout(checkReposVariable, 5000)
  } else if (event.payload.action === 'removed_from_repository') {
    const org = event.payload.organization.login
    getTeamID(org)
    // const repo = event.payload.repository.full_name
    setTimeout(checkTeamIDVariable, 1000)
  }
})

function getTeamID (org) {
  const https = require('https')

  const options = {
    hostname: (process.env.GHE_HOST),
    port: 443,
    method: 'GET',
    headers: {
      Authorization: 'token ' + (process.env.GHE_TOKEN),
      'Content-Type': 'application/json'
    }
  }
  let body = []
  const req = https.request(options, (res) => {
    res.on('data', (chunk) => {
      body.push(chunk)
    }).on('end', () => {
      body = JSON.parse(Buffer.concat(body))
      body.forEach(item => {
        if (item.name === teamName) {
          teamId = item.id
        }
      })
    })
  })

  req.on('error', (error) => {
    console.error(error)
  })

  req.end()
}

function checkTeamIDVariable (repo) {
  if (typeof teamId != 'undefined') {
    addTeamToRepo(repo, teamId)
  }
}

function checkReposVariable (org) {
  if (typeof orgRepos !== 'undefined') {
  //      for(var repo of orgRepos) {
  //        addTeamToRepo(repo, teamId)
  // }
    reCreateTeam(org)
  }
}

function addTeamToRepo (repo, teamId) {
  const https = require('https')
  const data = JSON.stringify({
    permission: teamAccess
  })

  const options = {
    hostname: (process.env.GHE_HOST),
    port: 443,
    path: '/api/v3/teams/' + teamId + '/repos/' + repo,
    method: 'PUT',
    headers: {
      Authorization: 'token ' + (process.env.GHE_TOKEN),
      'Content-Type': 'application/json',
      'Content-Length': data.length
    }
  }
  let body = []

  const req = https.request(options, (res) => {
    res.on('data', (chunk) => {

      body.push(chunk)

    }).on('end', () => {

      body = Buffer.concat(body).toString()
      console.log(res.statusCode)
      console.log('added team to ' + repo)
    })
  })

  req.on('error', (error) => {
    console.error(error)
  })

  req.write(data)
  req.end()
}

function reCreateTeam (org) {
  const https = require('https')
  const data = JSON.stringify({
    name: teamName,
    description: teamDescription,
    privacy: teamPrivacy,
    maintainers: userArray,
    repo_names: orgRepos
  })

  const options = {
    hostname: (process.env.GHE_HOST),
    port: 443,
    path: '/api/v3/orgs/' + org + '/teams',
    method: 'POST',
    headers: {
      Authorization: 'token ' + (process.env.GHE_TOKEN),
      'Content-Type': 'application/json',
      'Content-Length': data.length
    }
  }
  // const body = []
  const req = https.request(options, (res) => {
    if (res.statusCode !== 201) {
      console.log('Status code: ' + res.statusCode)
      console.log('Added ' + teamName + ' to ' + org + ' Failed')
      res.on('data', function (chunk) {
        console.log('BODY: ' + chunk)
      })
    } else {
      console.log('Added ' + teamName + ' to ' + org)
    }
  })

  req.on('error', (error) => {
    console.error(error)
  })

  req.write(data)
  req.end()
}

function getRepositories (org) {
  orgRepos = []

  const https = require('https')

  const options = {
    hostname: (process.env.GHE_HOST),
    port: '443',
    path: '/api/v3/orgs/' + org + "/repos",
    method: 'GET',
    headers: {
      Authorization: 'token ' + (process.env.GHE_TOKEN),
      'Content-Type': 'application/json'
    }
  }
  let body = []
  const req = https.request(options, (res) => {
    res.on('data', (chunk) => {
      body.push(chunk)

    }).on('end', () => {
      body = JSON.parse(Buffer.concat(body))
      body.forEach(item => {
        orgRepos.push(item.full_name)

        console.log(item.full_name)
      })
    })
  })

  req.on('error', (error) => {
    console.error(error)
  })
  req.end()
}