/* viper 12/11/2003 last edited: viper 20/11/2003;
*  Получение данных с сервера
* (in) market  - номер маркета
* (in)  com    - команда указывающая необходимые данные
* (out) size  - кол-во строк выходного массива
*/ 
char** getdata(int market, const char* com, int* size)
{
    char buff[BUFFSZ];          //Переменная для хранения ответа от сервера
    char *tmprs = NULL;         //Переменная в которую копируется ответ + \ 0 

    char** res = NULL;          //Переменная для хранения результата (массив 2х2)
    const char* sep =  "\n\r" ;   //Разделитель использующийся для разделения строк в ответе
    char *back, *col;           //Переменные для разбиения строки на массив строк
    long arsize= 0 ;              //Общий размер памяти выделенной под результат
    int stnum =  0 ;              //Кол-во елементов (строк) в результате
    int j= 0 ;                    //Счетчик для цикла

    //Переменные для работы с сокетами
    int s, sz, rz;
    struct sockaddr_in sin;
    struct sockaddr *sp;
    struct in_addr sip;

    sp = (struct sockaddr *)&sin;
    sz = sizeof(sin);

    // Создаём сокет
    s = socket(AF_INET, SOCK_STREAM,  0 );
    if (s == - 1 )
    {
        interr( "Невозможно создать сокет.\n" ,  1 );
        return NULL;
    }

    //Конектимся к определенному серверу
    if (inet_aton(getserver(market), &sip) !=  1 )
    {
        interr( "Неправильно задан адрес сервера.\n" ,  1 );
        return NULL;
    }
    // Задаем адрес сервера и порт
    sin.sin_family = AF_INET;
    sin.sin_port = htons( 1701 );
    sin.sin_addr = sip;

    // Устанавливаем соединение
    if (connect(s, sp, sz) == - 1 )
    {
        interr( "Connection Error\n" ,  1 );
        return NULL;
    }

    // Передаем комманду получения кол. денег в кассах
    if (DEBUG)
        printf( "Передаем комманду: %s\n" , com);
    sendCommand(s, com);

    // Читаем результат
    if (DEBUG)
        printf( "Ожидаем ответа сервера...\n" );

    while( 1 )
    {
        rz = recv(s, buff, BUFFSZ,  0 ); //Получаем ответ

        if (DEBUG)
            printf( "Получено %d байт(ов)\n" , rz);

        buff[rz] = '\0'; //Добавляем симвой конца строки к полученной строке
        tmprs = (char*)malloc(rz+ 1 ); //Выделяем память необходимую для хранения строки + \ 0 
        strncpy(tmprs, buff, rz+ 1 );

        //Печатаем содержимое полученной строки
        if(DEBUG)
            printf( "Buffer: %s\n" , tmprs);

        //Разбиваем полученую строку на массив строк (разделитель '\n\r')
        for(col = strtok_r(tmprs, sep, &back); col; col = strtok_r(NULL, sep, &back))
        {
            if(res == NULL)
            {
                res = (char**)malloc(sizeof(char*));
                arsize += sizeof(char*);
                if(DEBUG)
                    printf( "malloc %d bytes allocated, %d bytes total\n" , sizeof(char*), arsize);
            }
            else
            {
                res = (char**)realloc(res, arsize + (sizeof(char*)));
                arsize += sizeof(char*);
//              if(DEBUG)
//                      printf( "%d bytes allocated, %d bytes total\n" , sizeof(char*), arsize);
            }

            res[stnum] = col;
            stnum++;
        }

        if(!strcmp(res[stnum- 1 ],  "+END" )) //Если нам вернули +END прекращаем считывать...
            break;

    }

    //Выводим на экран полученный массив строк
    if(DEBUG)
    {
        for(j= 0 ; j<stnum; j++)
            printf( "Line %d returned %s\n" , j+ 1 , res[j]);
    }

    *size =  --stnum; //Передать по ссылке кол-во строчек
 

    if(DEBUG)
        printf( "Lines = %d, Actual = %d\n" , *size, stnum);

    if(DEBUG)
        printf( "Total size = %d\n" , arsize); //Выводим на экран общее кол-во выделенной памяти

    // Передаем комманду завершения соединения
    if (DEBUG)
        printf( "Передаем комманду: %s\n" , QUIT);
    sendCommand(s, QUIT);

    if(DEBUG)
        printf( "closing connection\n" );
    // Закрываем соединение
    close(s);

    // Освобождаем выделену память
    free(tmprs);

    if(DEBUG)
        printf( "getdata() done!\n" , *size);

    return res;
}