/*

  * 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

 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 = javax.mail.Session.getDefaultInstance(props, null)

     val notify = new Notify() {

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

         val u = new URL(api, "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;

       }

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

         var ret : List[String] = Nil;

         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 = res(0).text :: ret;

           }

         }

         return ret

       }

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

         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)

       }

     }

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

   }

 }