/**

  * Program POSIXové Fronty

  * @autor František Kučera <franta-hg@frantovo.cz>

  */

 #include <program.h>

 #include <stdlib.h>

 #include <iostream>

 #include <readline/readline.h>

 #include <signal.h>

 #include <strings.h>

 #include "fronta.h"

 using namespace std;

 /**

  * Spuštění programu „POSIXovéFronty“

  */

 int main() {

     cout << "Vítejte v programu POSIXovéFronty" << endl;

     /** Nastavíme reakci na signál SIGTERM */

     signal(SIGTERM, zpracujSignal);

     signal(SIGINT, zpracujSignal);

     /** TODO: zeptat se na název fronty – readline */

     //strcpy(nazevFronty, VYCHOZI_NAZEV_FRONTY);

     nazevFronty = "/mojeFronta";

     /** Program pracuje buď v režimu přijímání nebo odesílání */

     if (isOdesilaciRezim()) {

         odesilej();

     } else {

         prijimej();

     }

     /** Sem se nedostaneme, pokud metody poběží v cyklu – program končí, až když dostane patřičný signál. */

     fronta.zavriFrontu(false);

     return (EXIT_SUCCESS);

 }

 bool isOdesilaciRezim() {

     cout << "Zvolte režim: (p)řijímací / (o)desílací" << endl;

     char odpoved = cin.get();

     cin.get();

     if (odpoved == 'o') {

         return true;

     } else if (odpoved == 'p') {

         return false;

     } else {

         return isOdesilaciRezim();

     }

 }

 void odesilej() {

     cout << "Odesíláme…" << endl;

     fronta = Fronta(nazevFronty, false, true);

     while (true) {

         /** TODO: načítat pomocí readline */

         char zprava[100];

         cout << "Zadejte zprávu: \033[22;32m";

         cin.getline(zprava, 100);

         cout << "\033[0m\n";

         if (fronta.odesliZpravu(zprava) == 0) {

             cout << "Zpráva odeslána." << endl;

         } else {

             cout << "Při odesílání zprávy došlo k chybě." << endl;

         }

     }

 }

 void prijimej() {

     cout << "Přijímáme…" << endl;

     fronta = Fronta(nazevFronty, true, false);

     while (true) {

         char* zprava = fronta.prijmiZpravu();

         if (zprava == NULL) {

             cout << "Nepodařilo se přijmout zprávu." << endl;

         } else {

             printf("Přijatá zpráva: \033[22;32m%s\033[0m\n", zprava); // zelená

         }

     }

 }

 void zpracujSignal(int signal) {

     if (signal == SIGTERM || signal == SIGINT) {

         fronta.zavriFrontu(false);

         cout << endl << "\033[22;31m" << "Končím program na základě signálu " << signal << "." << "\033[0m" << endl; // červená

         exit(1);

     }

 }