kygui/client.cpp

#include <client.hpp>
#include <arpa/inet.h>
#include <netdb.h>
#include <string.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <unistd.h>

#include <thread>
#include <cstring>
#include <QDebug>
#include <string>
#include <iostream>

void input_loop(char buffer[]) {
    qDebug() << "Enter message: ";
    for (;;) {
        std::cin >> buffer;
        if (buffer[0] != 0) {
            return;
        }
    }
}
//hostCombo(new QComboBox),
//    portLineEdit(new QLineEdit),
//    getFortuneButton(new QPushButton(tr("Get Fortune"))),
//    tcpSocket(new QTcpSocket(this)) {
//    setWindowFlags(windowFlags() & ~Qt::WindowContextHelpButtonHint);

//    in.setDevice(tcpSocket);
//    in.setVersion(QDataStream::Qt_4_0);

//    QPushButton *button = new QPushButton("Push");
//    parent->layout()->addWidget(button);
//    connect(button, &QPushButton::clicked, this, &Client::clicked);
//    connect(tcpSocket, &QIODevice::readyRead, this, &Client::readFortune);
//}


Client::Client(QWidget *parent, int count, char** arguments) : QDialog(parent), argc(count), argv(arguments) {}

    int Client::start() {
        int client_socket_fd = socket(AF_INET, SOCK_STREAM, 0);
        if (client_socket_fd != -1) {
            sockaddr_in server_socket;
            char* end;
            server_socket.sin_family = AF_INET;
            auto port_value = strtol(argv[2], &end, 10);
            if (port_value < 0 || end == argv[2]) {
                return 1;
            }

            int socket_option = 1;
            // Free up the port to begin listening again
            setsockopt(client_socket_fd, SOL_SOCKET, SO_REUSEADDR, &socket_option,
                       sizeof(socket_option));

            server_socket.sin_port = htons(port_value);
            inet_pton(AF_INET, argv[1], &server_socket.sin_addr.s_addr);

            if (::connect(client_socket_fd, (sockaddr*)&server_socket,
                        sizeof(server_socket)) != -1) {
                char send_buffer[2048];
                char receive_buffer[2048];
                for (;;) {
                    memset(send_buffer, 0, 2048);
                    memset(receive_buffer, 0, 2048);
                    int bytes_received = 0;
                    std::thread user_input_loop(input_loop, send_buffer);

                    if (user_input_loop.joinable()) {
                        user_input_loop.join();
                        send(client_socket_fd, send_buffer, 2048, 0);
                        bytes_received = recv(client_socket_fd, receive_buffer, 2048 - 2, 0);
                        receive_buffer[2047] = 0;
                        if (bytes_received == 0) {
                            break;
                        }
                    }
                }
                memset(send_buffer, 0, 2048);
                memset(receive_buffer, 0, 2048);
            }
            qDebug() << errno;
            ::close(client_socket_fd);
            return 0;
        }
    }

void Client::requestNewFortune() {
    QMessageBox::information(this, tr("Jigga Client"),
                             tr("Gibs me dat fortune, punk!"));
}