//
// Created by zx on 2020/7/3.
//
#include <unistd.h>
#include <iostream>
#include <nnxx/message>
#include <nnxx/socket.h>
#include <nnxx/bus.h>

#include "measure_message.pb.h"
#include <thread>
int main()
{
    nnxx::socket socket{ nnxx::SP, nnxx::BUS };
    socket.bind("tcp://127.0.0.1:9006");

    int n=0;

    while(1)
    {
        std::string t_receive_string = socket.recv<std::string>(0);
        if(t_receive_string.length()>0) {

            message::Base_info base_msg;
            message::Measure_response_msg response;
            message::Measure_request_msg request;

            message::Error_manager error_code;
            request.ParseFromString(t_receive_string);

            base_msg.set_msg_type(message::eLocate_response_msg);
            base_msg.set_sender(message::eMeasurer);
            base_msg.set_receiver(message::eMain);


            response.set_command_id(request.command_id());
            response.set_terminal_id(request.terminal_id());
            response.mutable_base_info()->CopyFrom(base_msg);


            int succ=int((rand()%1000)/999);
            error_code.set_error_code(succ);
            response.mutable_error_manager()->CopyFrom(error_code);

            std::cout<<request.DebugString()<<std::endl;

            socket.send(response.SerializeAsString());

            usleep(1000);
            std::this_thread::yield();
        }


    }

}