newtx/scanner/async_scanner.h

#pragma once
#include <stdint.h>
#include <thread>
#include <functional>
#include <algorithm>
#include <memory>
#include <vector>
#include <base/utils.h>
#include <base/data.h>



class async_usb_gadget;
class device_option;
class image_capture;
class img_processor;
class gb_json;
class scanner_const_opts;
class scanner_hw;
class user_priv;
class imgproc_mgr;
class resource_mgr;

enum must_cond
{
    MUST_COND_ROLLER_CNT = 1 << 0,
    MUST_COND_HISTORY_CNT = 1 << 1,
};

class async_scanner : public refer
{
    async_usb_gadget    *usb_ = nullptr;
    device_option       *cfg_mgr_ = nullptr;
    scanner_const_opts  *const_opts_ = nullptr;
    scanner_hw          *cis_ = nullptr;
    user_priv           *user_ = nullptr;
    imgproc_mgr         *img_prcr_ = nullptr;
    uint32_t            must_ready_ = 0;

    MUTEX               locker_;
    volatile bool       connected_ = false;
    uint32_t            img_cnt_;
    uint32_t            scan_id_;
    uint32_t            scan_err_;
    volatile bool       reply_start_;
    int                 last_err_ = 0;
    std::unique_ptr<resource_mgr>   res_mgr_;

    MUTEX               fsender_;
    std::vector<file_reader*>   send_files_;


    static bool resource_check(RES_CHK_PROTO);
    static void image_sender(SENDER_PROTO);
    static dyn_mem_ptr option_changed_packet(const char* name, void* val, size_t val_len, int pkid = 0, int err = 0);

    dyn_mem_ptr handle_bulk_cmd(LPPACK_BASE pack, uint32_t* used, packet_data_base_ptr* required, uint32_t session);
    void init(void);
    void init_usb(void);
    void add_option_to_ui_menu(const char* name, int pos = -1);
    bool on_energy_conservation(bool normal/*true - working status; false - go to sleep*/); // return true to enable get into 'normal' status

    dyn_mem_ptr handle_simple_roger(LPPACK_BASE pack, uint32_t* used, packet_data_base_ptr* required, uint32_t session);
    dyn_mem_ptr handle_get_opt_value(LPPACK_BASE pack, uint32_t* used, packet_data_base_ptr* required, uint32_t session);
    dyn_mem_ptr handle_get_opt_all(LPPACK_BASE pack, uint32_t* used, packet_data_base_ptr* required, uint32_t session);
    dyn_mem_ptr handle_set_opt(LPPACK_BASE pack, uint32_t* used, packet_data_base_ptr* required, uint32_t session);
    dyn_mem_ptr handle_file_receive(LPPACK_BASE pack, uint32_t* used, packet_data_base_ptr* required, uint32_t session);
    dyn_mem_ptr handle_file_send(LPPACK_BASE pack, uint32_t* used, packet_data_base_ptr* required, uint32_t session);
    dyn_mem_ptr handle_file_send_roger(LPPACK_BASE pack, uint32_t* used, packet_data_base_ptr* required, uint32_t session);
    dyn_mem_ptr handle_scan_start(LPPACK_BASE pack, uint32_t* used, packet_data_base_ptr* required, uint32_t session);
    dyn_mem_ptr handle_scan_stop(LPPACK_BASE pack, uint32_t* used, packet_data_base_ptr* required, uint32_t session);
    dyn_mem_ptr handle_process_cmd(LPPACK_BASE pack, uint32_t* used, packet_data_base_ptr* required, uint32_t session);

public:
    async_scanner();

protected:
    ~async_scanner();

public:
    uint32_t stop(void);
    int last_error(void);

    // console command ...
public:
    void print_usb_status(void);
};