#ifndef WIDGET_H
#define WIDGET_H

#include <QWidget>
#include<kademlia/session.hpp>
#include<future>

QT_BEGIN_NAMESPACE
namespace Ui { class Widget; }
QT_END_NAMESPACE

class Widget : public QWidget
{
    Q_OBJECT

public:
    Widget(QWidget *parent = nullptr);
    ~Widget();

private slots:
    void on_searchButton_clicked();

    void on_saveButton_clicked();

private:
    Ui::Widget *ui;
kademlia::session *s;
std::future<std::error_code> *main_loop_result;
};
#endif // WIDGET_H

#include "widget.h"
#include "ui_widget.h"
#include<kademlia/session.hpp>
#include<future>
#include<QDebug>
#include<iostream>
#include<kademlia/error.hpp>
#include<QHostInfo>
#include<QFile>

Widget::Widget(QWidget *parent)
    : QWidget(parent)
    , ui(new Ui::Widget)
{
    kademlia::endpoint const initial_peer{"192.168.1.4",34567};
    s = new kademlia::session {initial_peer};
    main_loop_result = new std::future<std::error_code>(std::async(std::launch::async,
                                       &kademlia::session::run,s));

    //qDebug()<<"type: "<<typeid (main_loop_result).name();
    ui->setupUi(this);
}

Widget::~Widget()
{
    s->abort();
    auto failure = main_loop_result->get();
    if(failure!=kademlia::RUN_ABORTED)
        qDebug()<<QString::fromStdString(failure.message());
    delete s;
    s=0;
    delete ui;
}


void Widget::on_searchButton_clicked()
{
    QByteArray bytes("key");
    std::vector<uint8_t> key(bytes.begin(),bytes.end());
    auto on_load = [](std::error_code const& failure
            ,kademlia::session::data_type const& data)
    {
        qDebug()<<"data: "<<data.data();
        if(failure)
            qDebug()<<QString::fromStdString(failure.message());
        else

            std::copy(data.begin(),data.end()
                      ,std::ostream_iterator<std::uint32_t>{std::cout," "});
    };

    s->async_load(key,on_load);
}

void Widget::on_saveButton_clicked()
{
    QFile file("D:/qt_code/222.txt");
    if(!file.open(QFile::ReadOnly)){
        qDebug()<<"open file error!";
        return;
    }
    QByteArray block;
    block = file.readAll();
    file.close();
    std::vector<uint8_t> txt(block.begin(),block.end());

    kademlia::session::data_type const data{txt.begin(),txt.end()};

    auto on_save = [](std::error_code const& failure){
        if(failure)
            qDebug()<<QString::fromStdString(failure.message());
    };
    QByteArray bytes("key");
    std::vector<uint8_t> key(bytes.begin(),bytes.end());
    s->async_save(key,data,on_save);
}