cn-lab4-client

// cn-lab4-client.cpp: определяет точку входа для консольного приложения.
//

#include "stdafx.h"
#define _WINSOCK_DEPRECATED_NO_WARNINGS
#include <condition_variable>
#include <iostream>
#include <regex>
#include <string>
#include <thread>
#include <winsock2.h>

#pragma comment(lib, "ws2_32.lib")

using namespace std;

mutex m;
condition_variable cvar;
bool cvar_backup;

int user_input(const SOCKET main_sock) {
    string s;
    while (true) {
        getline(cin, s);
        if (s == "exit") {
            send(main_sock, "&close", sizeof("&close"), 0);
            cvar.notify_one();
            cvar_backup = true;
            return 1;
        }
        send(main_sock, s.c_str(), s.length(), 0);
    }
    return 0;
}

int answer_display(string ans) {
    for (; ans != "|||";) {
        regex pattern(R"(\|{0,3}(.+?)\^{3}(.+?)\^{3}(.+?)\^{3}(.+?)\^{3}(.+?)\^{3}(.+?)\^{3}(.+)\r?)");
        smatch match_results;
        regex_match(ans, match_results, pattern);
        cout << match_results[2] << " \"" << match_results[3] << "\" - " << match_results[5] << ", " << match_results[4] << endl;
        ans = match_results.str(7);
    }
    return 0;
}

int network_receiver(const SOCKET main_sock) {
    thread *answer_display_thread = nullptr;
    while (true) {
        char recv_buff[1024];
        int len = recv(main_sock, &recv_buff[0], sizeof(recv_buff), 0);
        if (len == -1)
            break;
        recv_buff[len] = 0;
        string ans = recv_buff;
        if (ans == "&stop") {
            cout << "Server was stopped. Type \"exit\" to exit." << endl;
            break;
        }
        if (answer_display_thread != nullptr)
            answer_display_thread->join();
        answer_display_thread = new thread(answer_display, ans);
    }
    return 0;
}

int main() {
    WSAData wsadata;
    WSAStartup(0x0202, &wsadata);
    SOCKET main_sock;
    main_sock = socket(AF_INET, SOCK_STREAM, 0);
    sockaddr_in server_addr;
    server_addr.sin_family = AF_INET;
    server_addr.sin_addr.S_un.S_addr = inet_addr("127.0.0.1");
    server_addr.sin_port = htons(5004);
    connect(main_sock, (sockaddr *)&server_addr, sizeof(server_addr));
    thread listen(network_receiver, main_sock);
    thread input(user_input, main_sock);
    unique_lock<mutex> locked(m);
    cvar.wait(locked, [] {return cvar_backup; });
    closesocket(main_sock);
    if (input.joinable())
        input.join();
    if (listen.joinable())
        listen.join();
    WSACleanup();
    return 0;
}