/*

 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.

 *

 * The contents of this file are subject to the terms of either the GNU

 * General Public License Version 2 only ("GPL") or the Common

 * Development and Distribution License("CDDL") (collectively, the

 * "License"). You may not use this file except in compliance with the

 * License. You can obtain a copy of the License at

 * http://www.netbeans.org/cddl-gplv2.html

 * or nbbuild/licenses/CDDL-GPL-2-CP. See the License for the

 * specific language governing permissions and limitations under the

 * License.  When distributing the software, include this License Header

 * Notice in each file and include the License file at

 * nbbuild/licenses/CDDL-GPL-2-CP.  Sun designates this

 * particular file as subject to the "Classpath" exception as provided

 * by Sun in the GPL Version 2 section of the License file that

 * accompanied this code. If applicable, add the following below the

 * License Header, with the fields enclosed by brackets [] replaced by

 * your own identifying information:

 * "Portions Copyrighted [year] [name of copyright owner]"

 *

 * Contributor(s):

 *

 * Portions Copyrighted 2009 Jaroslav Tulach

 */

package cz.xelfi.quoridor.emailer

import scala.xml._

import java.net.URL

import scala.io._

import scala.collection.Map

import scala.collection.mutable.HashMap

object Main {

  def main(args: Array[String]) {

    val api = new URL("http://quoridor.xelfi.cz/api/");

    val id = login(api, "emailer", "otravuj")

    Console.println("id: " + id)

    val ret = allPlayers(

      api,

      3600 * 1000 * 24

    )

    for (val address <- emails(api, id, ret.keySet)) {

        Console.println(address)

    }

  }

  def login(url : URL, name : String, password : String) : String = {

    val u = new URL(url, "login?name=" + name + "&password=" + password);

    val conn = u.openConnection.asInstanceOf[java.net.HttpURLConnection]

    conn.setRequestMethod("PUT")

    conn.setDoInput(true)

    conn.connect

    val reply = Source.fromInputStream(conn.getInputStream)

    return reply.mkString("")

  }

  def allPlayers(url : URL, okDelay : Long): Map[String,List[Node]] = {

    val u = new URL(url, "games");

    val conn = u.openConnection

    conn.setRequestProperty("Accept", "text/xml")

    val ret = new HashMap[String,List[Node]]

    val before = System.currentTimeMillis - okDelay

    val games = XML.load(conn.getInputStream)

    for (val g : Node <- games \\ "gameId") {

      val modified = (g \\ "@modified").text.toLong

      if (modified < before) {

        val status = (g \\ "@status").text;

        val name =

          if (status == "blackMove") {

            (g \\ "@black").text

          } else if (status == "whiteMove") {

            (g \\ "@white").text

          } else {

            null

          }

        if (name != null) {

          val prev = ret.getOrElse(name, Nil)

          val next = g :: prev

          ret.put(name, next);

        }

      }

    }

    return ret;

  }

  def emails(url : URL, loginID : String, ids : Collection[String]): List[String] = {

    var ret : List[String] = Nil;

    for (val p <- ids) {

      val u = new URL(url, "users/" + p + "?loginID=" + loginID)

      val conn = u.openConnection

      conn.setRequestProperty("Accept", "text/xml")

      val xml = XML.load(conn.getInputStream)

      val res = (xml \\ "property").filter({

          n => n.attribute("name") match {

            case Some(attr) => attr.text == "email"

            case _ => false

          }

      })

      if (!res.isEmpty) {

        ret = res(0).text :: ret;

      }

    }

    return ret

  }

}