/*

 * 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.webidor.resources;

import com.sun.jersey.api.json.JSONWithPadding;

import cz.xelfi.quoridor.IllegalPositionException;

import cz.xelfi.quoridor.webidor.*;

import cz.xelfi.quoridor.Move;

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.File;

import java.io.FileInputStream;

import java.io.FileOutputStream;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.io.PrintWriter;

import java.io.Writer;

import java.util.ArrayList;

import java.util.Collections;

import java.util.Date;

import java.util.List;

import java.util.logging.Level;

import java.util.logging.Logger;

import java.util.regex.Matcher;

import java.util.regex.Pattern;

import javax.ws.rs.DefaultValue;

import javax.ws.rs.GET;

import javax.ws.rs.POST;

import javax.ws.rs.PUT;

import javax.ws.rs.Path;

import javax.ws.rs.PathParam;

import javax.ws.rs.Produces;

import javax.ws.rs.QueryParam;

import javax.ws.rs.WebApplicationException;

import javax.ws.rs.core.GenericEntity;

import javax.ws.rs.core.MediaType;

import javax.ws.rs.core.Response.Status;

/**

 *

 * @author Jaroslav Tulach <jtulach@netbeans.org>

 */

public final class Games {

    private final Quoridor quoridor;

    private final List<Game> games = new ArrayList<Game>();

    private final File dir;

    private static final Logger LOG = Logger.getLogger(Games.class.getName());

    public Games(File dir, Quoridor quoridor) {

        this.dir = dir;

        this.quoridor = quoridor;

        File[] arr = dir.listFiles();

        if (arr != null) {

            for (File f : arr) {

                try {

                    Game g = readGame(f);

                    games.add(g);

                } catch (IOException ex) {

                    LOG.log(Level.WARNING, "Wrong game in " + f, ex);

                }

            }

        }

    }

    @POST

    @Produces({ MediaType.APPLICATION_JSON, MediaType.TEXT_XML })

    public GameId createGame(

        @QueryParam("loginID") String id,

        @QueryParam("white") String white,

        @QueryParam("black") String black

    ) throws IOException {

        String logUser = quoridor.isLoggedIn(id);

        if (logUser == null) {

            throw new WebApplicationException(Status.UNAUTHORIZED);

        }

        if (white == null) {

            throw new WebApplicationException(Status.PRECONDITION_FAILED);

        }

        if (black == null) {

            throw new WebApplicationException(Status.PRECONDITION_FAILED);

        }

        if (!logUser.equals(white) && !logUser.equals(black)) {

            throw new WebApplicationException(Status.PRECONDITION_FAILED);

        }

        Game g = new Game(white, black);

        storeGame(g);

        games.add(g);

        return g.getId();

    }

    @GET

    @Path("{id}")

    @Produces(MediaType.TEXT_PLAIN)

    public String getBoard(

        @PathParam("id") String id,

        @QueryParam("move") @DefaultValue("-1") int move

    ) {

        Game g = findGame(id, move);

        if (g == null) {

            throw new IllegalArgumentException("Unknown game " + id);

        }

        return g.getBoard().toString();

    }

    public Game getBoardInfo(

        @QueryParam("loginID") @DefaultValue("") String loginId,

        @PathParam("id") String id,

        @QueryParam("move") @DefaultValue("-1") int move

    ) throws IOException {

        Game g = findGame(id, move);

        if (canSee(g.getId(), loginId)) {

            return g;

        }

        throw new WebApplicationException(Status.UNAUTHORIZED);

    }

    @GET

    @Path("{id}")

    @Produces({ "application/x-javascript", MediaType.APPLICATION_JSON, MediaType.TEXT_XML })

    public JSONWithPadding getBoardInfo(

        @QueryParam("callback") String callback,

        @QueryParam("loginID") @DefaultValue("") String loginId,

        @PathParam("id") String id,

        @QueryParam("move") @DefaultValue("-1") int move

    ) throws IOException {

        return new JSONWithPadding(getBoardInfo(loginId, id, move), callback);

    }

    private boolean canSee(GameId id, String loginId) throws IOException {

        if (!id.isFinished()) {

            return true;

        }

        String logUser = quoridor.isLoggedIn(loginId);

        if (logUser == null) {

            return false;

        }

        if (logUser.equals(id.getWhite())) {

            return true;

        }

        if (logUser.equals(id.getBlack())) {

            return true;

        }

        User info = quoridor.getUsers().getUserInfo(loginId, logUser);

        if (info != null && info.hasPermission("games")) {

            return true;

        }

        return false;

    }

    @PUT

    @Path("{id}")

    @Produces({ MediaType.APPLICATION_JSON, MediaType.TEXT_XML })

    public GameId applyMove(

        @QueryParam("loginID") String loginId,

        @PathParam("id") String id,

        @QueryParam("player") String player,

        @QueryParam("move") String move,

        @QueryParam("comment") String comment

    ) throws IllegalPositionException, IOException {

        String logUser = quoridor.isLoggedIn(loginId);

        if (logUser == null) {

            throw new WebApplicationException(Status.UNAUTHORIZED);

        }

        if (!logUser.equals(player)) {

            User info = quoridor.getUsers().getUserInfo(loginId, logUser);

            if (info == null || !info.hasPermission("resign")) {

                throw new WebApplicationException(Status.UNAUTHORIZED);

            }

        }

        if (comment == null && move == null) {

            throw new WebApplicationException(Status.BAD_REQUEST);

        }

        Game g = findGame(id);

        if (g == null) {

            throw new IllegalArgumentException("Unknown game " + id);

        }

        if (move != null) {

            Move m = Move.valueOf(move);

            g.apply(player, m, new Date());

        }

        if (comment != null) {

            g.comment(player, comment, new Date());

        }

        try {

            storeGame(g);

        } catch (IOException ex) {

            LOG.log(Level.WARNING, "Cannot store game " + id, ex);

        }

        return g.getId();

    }

    @GET

    @Produces({ "application/x-javascript", MediaType.APPLICATION_JSON, MediaType.TEXT_XML })

    public JSONWithPadding listGames(

        @QueryParam("callback") String callback,

        @DefaultValue("") @QueryParam("loginID") String loginId,

        @DefaultValue("") @QueryParam("status") String status

    ) throws IOException {

        List<GameId> arr = new ArrayList<GameId>(games.size());

        for (Game g : games) {

            if (!canSee(g.getId(), loginId)) {

                continue;

            }

            if (status.length() == 0 || g.getId().getStatus().toString().equals(status)) {

                arr.add(g.getId());

            }

        }

        Collections.sort(arr, GameId.NEWEST_FIRST);

        return new JSONWithPadding(new GenericEntity<List<GameId>>(arr) {}, callback);

    }

    public List<Game> getGames() {

        return games;

    }

    private Game findGame(String id) {

        for (Game g : games) {

            if (g.getId().getId().equals(id)) {

                return g;

            }

        }

        return null;

    }

    private Game findGame(String id, int move) {

        Game g = findGame(id);

        if (g == null) {

            throw new IllegalArgumentException("Unknown game " + id);

        }

        try {

            return move == -1 ? g : g.snapshot(move);

        } catch (IllegalPositionException ex) {

            Logger.getLogger(Games.class.getName()).log(Level.SEVERE, null, ex);

            return null;

        }

    }

    private static final Pattern saidWho = Pattern.compile("# *([^ ]*) *@(.*):$");

    private Game readGame(File f) throws IOException {

        InputStream is = new FileInputStream(f);

        BufferedReader r = new BufferedReader(new InputStreamReader(is, "UTF-8"));

        String white = null;

        String black = null;

        Game g = null;

        String who = null;

        String when = null;

        for (;;) {

            String line = r.readLine();

            if (line == null) {

                line = "finish";

            }

            line = line.trim();

            if (line.length() == 0) {

                continue;

            }

            if (line.startsWith("# white: ")) {

                white = line.substring(9);

                continue;

            }

            if (line.startsWith("# black: ")) {

                black = line.substring(9);

                continue;

            }

            if (line.startsWith("#")) {

                Matcher m =saidWho.matcher(line);

                if (m.matches()) {

                    who = m.group(1);

                    when = m.group(2);

                    continue;

                }

                if (g == null) {

                    continue;

                }

                if (line.startsWith("# ")) {

                    line = line.substring(2);

                } else {

                    line = line.substring(1);

                }

                Date d = new Date();

                try {

                    if (when != null) {

                        d = new Date(Date.parse(when));

                    }

                } catch (IllegalArgumentException ex) {

                    LOG.warning("Unparseable date " + when + " in " + f);

                }

                g.comment(who, line, d);

                who = null;

                when = null;

                continue;

            }

            if (white == null || black == null) {

                throw new IOException("Missing white and black identification in " + f);

            }

            if (g == null) {

                GameId id = new GameId(f.getName(), white, black, new Date(f.lastModified()), new Date(f.lastModified()), GameStatus.whiteMove, 0, false);

                g = new Game(id);

            }

            int hash = line.indexOf('#');

            if (hash >= 0) {

                line = line.substring(0, hash);

            }

            if (line.equals("finish")) {

                break;

            }

            String[] moves = line.split(" ");

            if (moves.length == 0) {

                continue;

            }

            if (moves.length > 2) {

                throw new IOException("Too much moves on line: " + line);

            }

            try {

                if (!"...".equals(moves[0])) {

                    g.apply(white, Move.valueOf(moves[0]), null);

                }

                if (moves.length == 2) {

                    g.apply(black, Move.valueOf(moves[1]), null);

                }

            } catch (IllegalPositionException ex) {

                throw new IOException("Wrong move: " + ex.getMessage());

            }

        }

        if (g == null) {

            throw new IOException("No moves in " + f);

        }

        return g;

    }

    private void storeGame(Game g) throws IOException {

        dir.mkdirs();

        File f = new File(dir, g.getId().getId());

        storeGame(g, f);

    }

    final void storeGame(Game g, File f) throws IOException {

        FileOutputStream os = new FileOutputStream(f);

        Writer w = new BufferedWriter(new OutputStreamWriter(os, "UTF-8"));

        PrintWriter pw = new PrintWriter(w);

        pw.println("# white: " + g.getId().getWhite());

        pw.println("# black: " + g.getId().getBlack());

        pw.println("# status: " + g.getId().getStatus());

        int cnt = 0;

        boolean separate = true;

        for (CommentedMove m : g.getMoves()) {

            if (!separate && cnt % 2 == 1) {

                pw.print("... ");

            }

            separate = true;

            pw.print(m.getMove().toString());

            List<Note> notes = m.getComments();

            if (notes != null) {

                separate = false;

                pw.println();

                for (Note n : notes) {

                    pw.print ("# ");

                    pw.print(n.getWho());

                    pw.print("@");

                    pw.print(n.getWhen());

                    pw.println(":");

                    for (String l : n.getComment().split("\n")) {

                        pw.print("# ");

                        pw.println(l);

                    }

                }

            }

            cnt++;

            if (separate) {

                if (cnt % 2 == 0) {

                    pw.println();

                } else {

                    pw.print(' ');

                }

            }

        }

        pw.println();

        pw.println();

        pw.flush();

        pw.close();

        w.close();

    }

}