bomberstudent/Serveur/handler.c

/* 
 * File:   handler.c
 * Author: Arthur Brandao
 *
 * Created on 23 novembre 2018
 */

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include "error.h"
#include "bomberstudent_server.h"
#include "client.h"
#include "player.h"
#include "handler.h"

/* --- Extern --- */
extern Game game[MAXGAME];
extern int nbGame;

/* --- Fonctions privées --- */
/**
 * Cherche dans quel partie est un client
 * @param int L'id du client
 * @return int L'index de la partie
 */
int search_client_game(int cliId){
    int index = ERR;
    for(int i = 0; i < MAXGAME; i++){
        //Regarde si la game est active et avec des joueurs
        if(game[i].active && game[i].nbPlayer > 0){
            //Parcours les joueurs
            for(int j = 0; j < MAXPLAYER; j++){
                //Si le joueur est actif
                if(game[i].player[j]->ini){
                    //Si l'id est le bon
                    if(game[i].player[j]->id == cliId){
                        index = i;
                        break;
                    }
                }
            }
        }
        //Si on a un resultat
        if(index != ERR){
            break;
        }
    }
    //Retour
    return index;
}

/**
 * Cherche une partie par son nom
 * @param char* Le nom de la partie
 * @return int L'index dans le tableau
 */
int search_game(char* name){
    int index = ERR;
    for(int i = 0; i < MAXGAME; i++){
        //Regarde si la game est active et le nom
        if(game[i].active && strncmp(game[i].name, name, strlen(game[i].name)) == 0){
            index = i;
            break;
        }
    }
    return index;
}

/* --- Fonctions publiques --- */
void ini_handler(){
    //Get
    add_handler("GET", "client/end", handler_client_end);
    add_handler("GET", "game/list", handler_game_list);
    //Post
    add_handler("POST", "game/create", handler_game_create);
    add_handler("POST", "game/join", handler_game_join);
}

int handler_client_end(int cliId, JsonParser* json){
    boolean find = false;
    JsonEncoder* notif;
    printf("Deconnexion du client %d\n", cliId);
    //Cherche le client dans les parties
    for(int i = 0; i < MAXGAME; i++){
        if(game[i].active){
            for(int j = 0; j < MAXPLAYER; j++){
                if(game[i].player[j]->ini && game[i].player[j]->id == cliId){
                    find = true;
                    remove_player(&game[i], j);
                    //Avertit les autres joueurs
                    notif = malloc(sizeof(JsonEncoder));
                    ini_encoder(notif);
                    add_integer(notif, "player", cliId);
                    notify_player(&game[i], "POST", "game/quit", notif, cliId);
                    clean_json_encoder(notif);
                    free(notif);
                    break;
                }
            }
            if(find){
                break;
            }
        }
    }
    remove_client(cliId);
    return SUCCESS;
}

int handler_game_list(int cliId, JsonParser* json){
    JsonEncoder reponse;
    JsonArray* game;
    JsonArray* map;
    //Recup la liste des parties et des cartes
    game = list_game();
    map = list_map();
    //Creation reponse
    ini_encoder(&reponse);
    add_string(&reponse, "action", "game/list");
    add_string(&reponse, "status", "200");
    add_string(&reponse, "message", "ok");
    if(game == NULL){
        add_integer(&reponse, "numberGameList", 0);
    } else {
        add_integer(&reponse, "numberGameList", nbGame);
        add_array(&reponse, "games", game);
        clean_json_array(game);
        free(game);
    }
    add_array(&reponse, "maps", map);
    //Envoi reponse au client
    if(!send_client(cliId, &reponse)){
        adderror("Impossible de répondre au client");
        return FAIL;
    }
    //Nettoyage
    clean_json_encoder(&reponse);
    clean_json_array(map);
    free(map);
    return SUCCESS;
}

int handler_game_create(int cliId, JsonParser* json){
    char* map, * name, * msg;
    int index, joueur;
    JsonEncoder* reponse;
    //Verification arguments
    if(get_pos(json, "name") == JSON_ERROR){
        send_err_client(cliId, EREQUEST);
        adderror("Le json du client est incorrect");
        return FAIL;
    }
    if(get_pos(json, "map") == JSON_ERROR){
        send_err_client(cliId, EREQUEST);
        adderror("Le json du client est incorrect");
        return FAIL;
    }
    //Recup valeur
    map = get_string(json, "map");
    name = get_string(json, "name");
    //Verif nom non existant
    if(search_game(name) != ERR){
        reponse = malloc(sizeof(JsonEncoder));
        ini_encoder(reponse);
        add_string(reponse, "action", "game/create");
        add_string(reponse, "status", "501");
        add_string(reponse, "message", "Cannot create game");
        if(!send_client(cliId, reponse)){
            adderror("Impossible de répondre au client");
        }
        clean_json_encoder(reponse);
        free(reponse);
        return FAIL;
    }
    //Creation
    index = create_game(name, map);
    if(index == ERR){
        reponse = malloc(sizeof(JsonEncoder));
        ini_encoder(reponse);
        add_string(reponse, "action", "game/create");
        add_string(reponse, "status", "501");
        add_string(reponse, "message", "Cannot create game");
        if(!send_client(cliId, reponse)){
            adderror("Impossible de répondre au client");
        }
        clean_json_encoder(reponse);
        free(reponse);
        return FAIL;
    }
    //Ajout du joueur dans la partie
    joueur = add_player(&game[index], cliId);
    if(joueur == ERR){
        stop_game(&game[index]);
        reponse = malloc(sizeof(JsonEncoder));
        ini_encoder(reponse);
        add_string(reponse, "action", "game/create");
        add_string(reponse, "status", "501");
        add_string(reponse, "message", "Cannot create game");
        if(!send_client(cliId, reponse)){
            adderror("Impossible de répondre au client");
        }
        clean_json_encoder(reponse);
        free(reponse);
        return FAIL;
    }
    //Recup info
    reponse = describe_game(&game[index], joueur);
    //Ajout infos
    msg = new_string(25 + strlen(map));
    sprintf(msg, "Game created with %s", map);
    add_string(reponse, "action", "game/create");
    add_string(reponse, "status", "201");
    add_string(reponse, "message", msg);
    add_string(reponse, "startPos", "0,0");
    free(msg);
    //Envoi
    if(!send_client(cliId, reponse)){
        adderror("Impossible de répondre au client");
        clean_json_encoder(reponse);
        free(reponse);
        return FAIL;
    }
    //Nettoyage
    clean_json_encoder(reponse);
    free(reponse);
    free(map);
    free(name);
    return SUCCESS;
}

int handler_game_join(int cliId, JsonParser* json){
    char* name;
    int index, joueur;
    JsonEncoder* reponse;
    //Verification arguments
    if(get_pos(json, "name") == JSON_ERROR){
        send_err_client(cliId, EREQUEST);
        adderror("Le json du client est incorrect");
        return FAIL;
    }
    //Recup valeur
    name = get_string(json, "name");
    //Verif nom non existant
    index = search_game(name);
    if(index == ERR){
        reponse = malloc(sizeof(JsonEncoder));
        ini_encoder(reponse);
        add_string(reponse, "action", "game/join");
        add_string(reponse, "status", "501");
        add_string(reponse, "message", "Cannot join the game game");
        if(!send_client(cliId, reponse)){
            adderror("Impossible de répondre au client");
        }
        clean_json_encoder(reponse);
        free(reponse);
        return FAIL;
    }
    //Ajout du joueur dans la partie
    joueur = add_player(&game[index], cliId);
    if(joueur == ERR){
        reponse = malloc(sizeof(JsonEncoder));
        ini_encoder(reponse);
        add_string(reponse, "action", "game/join");
        add_string(reponse, "status", "501");
        add_string(reponse, "message", "Cannot join the game");
        if(!send_client(cliId, reponse)){
            adderror("Impossible de répondre au client");
        }
        clean_json_encoder(reponse);
        free(reponse);
        return FAIL;
    }
    //Recup info
    reponse = describe_game(&game[index], joueur);
    //Ajout infos
    add_string(reponse, "action", "game/join");
    add_string(reponse, "status", "201");
    add_string(reponse, "startPos", "0,0");
    //Envoi
    if(!send_client(cliId, reponse)){
        adderror("Impossible de répondre au client");
        clean_json_encoder(reponse);
        free(reponse);
        return FAIL;
    }
    //Nettoyage
    clean_json_encoder(reponse);
    free(reponse);
    free(name);
    //Avertit les autres joueurs
    reponse = malloc(sizeof(JsonEncoder));
    ini_encoder(reponse);
    add_integer(reponse, "id", cliId);
    add_string(reponse, "pos", "0,0");
    notify_player(&game[index], "POST", "game/newplayer", reponse, cliId);
    //Nettoyage
    clean_json_encoder(reponse);
    free(reponse);
    return SUCCESS;
}