2 * Quoridor server and related libraries
3 * Copyright (C) 2009-2010 Martin Rexa
5 * This program is free software: you can redistribute it and/or modify
6 * it under the terms of the GNU General Public License as published by
7 * the Free Software Foundation, either version 3 of the License.
9 * This program is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 * GNU General Public License for more details.
14 * You should have received a copy of the GNU General Public License
15 * along with this program. Look for COPYING file in the top folder.
16 * If not, see http://www.gnu.org/licenses/.
19 package cz.xelfi.quoridor.statistics.resources;
21 import com.sun.jersey.api.container.httpserver.HttpServerFactory;
22 import com.sun.jersey.api.core.PackagesResourceConfig;
23 import com.sun.jersey.api.core.ResourceConfig;
24 import com.sun.jersey.spi.resource.Singleton;
25 import com.sun.net.httpserver.HttpServer;
27 import java.io.IOException;
28 import java.util.Comparator;
29 import java.util.List;
30 import java.util.Collections;
31 import java.net.ServerSocket;
32 import javax.ws.rs.Path;
33 import cz.xelfi.quoridor.webidor.resources.Games;
34 import cz.xelfi.quoridor.webidor.Game;
42 public class Statistics {
43 static final Comparator<Game> OLDEST_FIRST = new OldestFirst();
45 static Openings openings;
53 public Openings getOpenings() {
57 public static void main( String[] args ) throws IOException, InterruptedException
60 // timeout between reprocessing games in miliseconds
61 long timeout = 1000 * 60 * 60 * 24;
62 // long timeout = 1000 * 10;
65 port = Integer.parseInt(args[0]);
66 } catch (Exception ex) {
70 if (System.getProperty("quoridor.dir") == null) {
71 File home = new File(System.getProperty("user.home"));
72 File quoridor = new File(home, ".quoridor");
73 System.setProperty("quoridor.dir", quoridor.getPath());
76 long lastExec = System.currentTimeMillis();
78 HttpServer s = start(port);
79 System.out.println("Statistics started at port " + port);
80 Object monitor = new Object();
81 // Wait until begining of next period. If timeout is one day, then next
82 // processing will be done after midnight
83 synchronized (monitor) {
84 monitor.wait(timeout - (lastExec % timeout));
88 synchronized (monitor) {
89 monitor.wait(timeout);
94 public static HttpServer start(int port) throws IOException {
96 ServerSocket ss = new ServerSocket(0);
97 port =ss.getLocalPort();
100 final String baseUri = "http://localhost:" + port + "/";
102 if (System.getProperty("quoridor.dir") == null) {
103 File home = new File(System.getProperty("user.home"));
104 File quoridor = new File(home, ".quoridor");
105 System.setProperty("quoridor.dir", quoridor.getPath());
108 ResourceConfig rc = new PackagesResourceConfig("cz.xelfi.quoridor.statistics");
109 HttpServer server = HttpServerFactory.create(baseUri, rc);
114 public static void processGames(){
115 Elo eloTmp = new Elo();
116 Openings openingsTmp = new Openings();
118 final String prop = System.getProperty("quoridor.dir"); // NOI18N
120 throw new IllegalStateException("quoridor.dir property must be specified"); // NOI18N
122 File path = new File(prop);
124 File fGames = new File(path, "games");
126 Games games = new Games(fGames, null);
127 List<Game> lGames = games.getGames();
128 Collections.sort(lGames, OLDEST_FIRST);
132 if(g.getId().isFinished()){
133 eloTmp.processGame(g.getId());
134 openingsTmp.processGame(g);
139 openings = openingsTmp;
142 private static final class OldestFirst implements Comparator<Game> {
143 public int compare(Game g1, Game g2) {
144 if(g1.getId() == g2.getId())
146 long diff = g2.getId().getModified() - g1.getId().getModified();
148 return diff < 0 ? 1 : -1;
150 return g1.getId().getId().compareTo(g2.getId().getId());