/*

 * Quoridor server and related libraries

 * Copyright (C) 2009-2010 Jaroslav Tulach <jaroslav.tulach@apidesign.org>

 *

 * This program is free software: you can redistribute it and/or modify

 * it under the terms of the GNU General Public License as published by

 * the Free Software Foundation, either version 3 of the License.

 *

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

 * along with this program. Look for COPYING file in the top folder.

 * If not, see http://www.gnu.org/licenses/.

 */

package cz.xelfi.quoridor.emailer

import scala.xml._

import java.net.URL

import java.net.HttpURLConnection

import java.io.BufferedReader

import java.io.InputStreamReader

import scala.io._

import scala.collection.Map

import scala.collection.mutable.HashMap

import javax.mail.internet._

import javax.mail.Message

import javax.mail.Transport

object Main {

  def main(args: Array[String]) {

    if (args == null || args.size != 4) {

      Console.println("Usage: emailer.jar <quoridor API URL> <login name> <password> <smtp server IP>")

      return

    }

    val api = new URL(args(0));

    val loginID = login(api, args(1), args(2))

    val okDelay = 3600 * 1000 * 24

    val props = java.lang.System.getProperties

    props.put("mail.smtp.host", args(3));

    val session = if (args(3).equals("print")) null else javax.mail.Session.getDefaultInstance(props, null)

    val notify = new Notify() {

      protected def allPlayers(): Map[String,List[Info]] = {

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

        val conn = u.openConnection

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

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

        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 id = (g \\ "@id").text

              val info = new Info(modified, id, name)

              val next = info :: prev

              ret.put(name, next);

            }

          }

        }

        return ret;

      }

      protected def emails(ids : Collection[String]): Map[String,String] = {

        var ret = new HashMap[String,String]

        for (val p <- ids) {

          val u = new URL(api, "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.put(p, res(0).text)

          }

        }

        return ret

      }

      protected def sendEmail(address : String, subject : String, text : String) : Unit = {

        Console.println("Sending message to")

        Console.println("  email: " + address.split('@')(0) + "@... ")

        Console.println("  subject: " + subject)

        Console.println("  " + text)

        if (session == null) {

          return;

        }

        val message = new MimeMessage(session)

        message.setFrom(new InternetAddress("quoridor@xelfi.cz"))

        message.addRecipient(Message.RecipientType.TO, new InternetAddress(address))

        message.setSubject(subject)

        message.setText(text)

        Transport.send(message)

      }

      protected def resignGame(id : Info): Unit = {

        val u = new URL(api, "games/" + id.gameId + "?loginID=" + loginID + "&player=" + id.toMove + "&move=RESIGN")

        val c = u.openConnection.asInstanceOf[HttpURLConnection]

        c.setRequestMethod("PUT")

        c.connect

        val is = c.getInputStream

        val r = new BufferedReader(new InputStreamReader(is))

        var goOn = true;

        while (goOn) {

          val s = r.readLine()

          if (s == null) {

            goOn = false;

          } else {

            Console.println(s);

          }

        }

      }

    }

    notify.process()

  }

  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("")

  }

}