/**
 * @file lv_indev_proc.c
 * 
 */

/*********************
 *      INCLUDES
 ********************/
#include "lv_indev.h"
#include "../../lv_conf.h"

#include "../lv_hal/lv_hal_tick.h"
#include "../lv_core/lv_group.h"
#include "../lv_misc/lv_task.h"
#include "../lv_misc/lv_math.h"
#include "../lv_draw/lv_draw_rbasic.h"
#include "lv_obj.h"

/*********************
 *      DEFINES
 *********************/

/**********************
 *      TYPEDEFS
 **********************/

/**********************
 *  STATIC PROTOTYPES
 **********************/
static void indev_proc_task(void * param);
static void indev_proc_point(lv_indev_proc_t * indev);
static void indev_proc_press(lv_indev_proc_t * info);
static void indev_proc_release(lv_indev_proc_t * state);
static lv_obj_t * indev_search_obj(const lv_indev_proc_t * indev, lv_obj_t * obj);
static void indev_drag(lv_indev_proc_t * state);
static void indev_drag_throw(lv_indev_proc_t * state);

/**********************
 *  STATIC VARIABLES
 **********************/
static lv_task_t *indev_proc_task_p;
static lv_indev_t *indev_act;

/**********************
 *      MACROS
 **********************/

/**********************
 *   GLOBAL FUNCTIONS
 **********************/

/**
 * Initialize the display input device subsystem
 */
void lv_indev_init(void)
{
#if LV_INDEV_READ_PERIOD != 0
    indev_proc_task_p = lv_task_create(indev_proc_task, LV_INDEV_READ_PERIOD, LV_TASK_PRIO_MID, NULL);
#else
    indev_proc_task_p = lv_task_create(indev_proc_task, 1, LV_TASK_PRIO_OFF); /*Not use lv_indev_proc*/
#endif

    lv_indev_reset(NULL);   /*Reset all input devices*/
}

/**
 * Get the currently processed input device. Can be used in action functions too.
 * @return pointer to the currently processed input device or NULL if no input device processing right now
 */
lv_indev_t * lv_indev_get_act(void)
{
    return indev_act;
}

/**
 * Reset one or all input devices
 * @param indev
 */
void lv_indev_reset(lv_indev_t * indev)
{
    if(indev) indev->proc.reset_query = 1;
    else {
        lv_indev_t * i = lv_indev_next(NULL);
        while(i) {
            i->proc.reset_query = 1;
            i = lv_indev_next(i);
        }
    }
}

/**
 * Reset the long press state of an input device
 * @param indev_proc pointer to an input device
 */
void lv_indev_reset_lpr(lv_indev_t * indev_proc)
{
    indev_proc->proc.long_pr_sent = 0;
    indev_proc->proc.longpr_rep_timestamp = lv_tick_get();
    indev_proc->proc.pr_timestamp = lv_tick_get();
}

/**
 * Enable input devices device by type
 * @param type Input device type
 * @param enable true: enable this type; false: disable this type
 */
void lv_indev_enable(lv_hal_indev_type_t type, bool enable)
{
    lv_indev_t *i = lv_indev_next(NULL);

    while (i) {
        if (i->driver.type == type) i->proc.disabled = enable == false ? 1 : 0;
        i = lv_indev_next(i);
    }
}

/**
 * Set a cursor for a mouse input device
 * @param indev pointer to an input device (type: 'LV_INDEV_TYPE_MOUSE')
 * @param cur_obj pointer to an object to be used as cursor
 */
void lv_indev_set_cursor(lv_indev_t *indev, lv_obj_t *cur_obj)
{
    if(indev->driver.type != LV_INDEV_TYPE_POINTER) return;

    indev->cursor = cur_obj;
    lv_obj_set_parent(indev->cursor, lv_layer_sys());
    lv_obj_set_pos(indev->cursor, indev->proc.act_point.x,  indev->proc.act_point.y);
}

#if USE_LV_GROUP
/**
 * Set a destination group for a keypad input device
 * @param indev pointer to an input device (type: 'LV_INDEV_TYPE_KEYPAD')
 * @param group point to a group
 */
void lv_indev_set_group(lv_indev_t *indev, lv_group_t *group)
{
    indev->group = group;
}
#endif

/**
 * Get the last point of an input device
 * @param indev pointer to an input device
 * @param point pointer to a point to store the result
 */
void lv_indev_get_point(lv_indev_t * indev, lv_point_t * point)
{
    point->x = indev->proc.act_point.x;
    point->y = indev->proc.act_point.y;
}

/**
 * Check if there is dragging with an input device or not
 * @param indev pointer to an input device
 * @return true: drag is in progress
 */
bool lv_indev_is_dragging(lv_indev_t * indev)
{
    if(indev == NULL) return false;
    return indev->proc.drag_in_prog == 0 ? false : true;
}

/**
 * Get the vector of dragging of an input device
 * @param indev pointer to an input device
 * @param point pointer to a point to store the vector
 */
void lv_indev_get_vect(lv_indev_t * indev, lv_point_t * point)
{
    point->x = indev->proc.vect.x;
    point->y = indev->proc.vect.y;
}

/**
 * Get elapsed time since last press
 * @param indev pointer to an input device
 * @return Elapsed ticks (milliseconds) since last press
 */
uint32_t lv_indev_get_inactive_time(lv_indev_t * indev)
{
    return indev->proc.pr_timestamp;
}

/**
 * Do nothing until the next release
 * @param indev pointer to an input device
 */
void lv_indev_wait_release(lv_indev_t * indev)
{
    indev->proc.wait_unil_release = 1;
}

/**********************
 *   STATIC FUNCTIONS
 **********************/

/**
 * Called periodically to handle the input devices
 * @param param unused
 */
static void indev_proc_task(void * param)
{
    (void)param;

    lv_indev_data_t data;
    lv_indev_t * i;
    i = lv_indev_next(NULL);

    /*Read and process all indevs*/
    while(i) {
        indev_act = i;

        /*Handle reset query before processing the point*/
        if(i->proc.reset_query) {
            i->proc.act_obj = NULL;
            i->proc.last_obj = NULL;
            i->proc.drag_range_out = 0;
            i->proc.drag_in_prog = 0;
            i->proc.long_pr_sent = 0;
            i->proc.pr_timestamp = 0;
            i->proc.longpr_rep_timestamp = 0;
            i->proc.drag_sum.x = 0;
            i->proc.drag_sum.y = 0;
            i->proc.reset_query = 0;
        }

        if(i->proc.disabled == 0) {
            /*Read the data*/
            lv_indev_read(i, &data);
            i->proc.event = data.state;

            /*Move the cursor if set and moved*/
            if(i->driver.type == LV_INDEV_TYPE_POINTER &&
               i->cursor != NULL &&
               (i->proc.last_point.x != data.point.x ||
                i->proc.last_point.y != data.point.y))
            {
                lv_obj_set_pos(i->cursor, data.point.x, data.point.y);
            }

            if(i->driver.type == LV_INDEV_TYPE_POINTER)
            {
                i->proc.act_point.x = data.point.x;
                i->proc.act_point.y = data.point.y;;

                /*Process the current point*/
                indev_proc_point(&i->proc);
            }
            else if (i->driver.type == LV_INDEV_TYPE_KEYPAD) {
#if USE_LV_GROUP
                if(i->group != NULL && data.key != 0 &&
                   data.state == LV_INDEV_STATE_PR && i->proc.last_state == LV_INDEV_STATE_REL)
                {
                    if(data.key == LV_GROUP_KEY_NEXT) {
                        lv_group_focus_next(i->group);
                    }
                    else if(data.key == LV_GROUP_KEY_PREV) {
                        lv_group_focus_prev(i->group);
                    }
                    else {
                        lv_group_send_data(i->group, data.key);
                    }
                }
                i->proc.last_state = data.state;
#endif
            }
        }

        /*Handle reset query if it happened in during processing*/
        if(i->proc.reset_query) {
            i->proc.act_obj = NULL;
            i->proc.last_obj = NULL;
            i->proc.drag_range_out = 0;
            i->proc.drag_in_prog = 0;
            i->proc.long_pr_sent = 0;
            i->proc.pr_timestamp = 0;
            i->proc.longpr_rep_timestamp = 0;
            i->proc.drag_sum.x = 0;
            i->proc.drag_sum.y = 0;
            i->proc.reset_query = 0;
        }

        i = lv_indev_next(i);    /*Go to the next indev*/
    }

    indev_act = NULL;   /*End of indev processing, so no act indev*/
}

/**
 * Process new points from a input device. indev->state.pressed has to be set
 * @param indev pointer to an input device state
 * @param x x coordinate of the next point
 * @param y y coordinate of the next point
 */
static void indev_proc_point(lv_indev_proc_t * indev)
{
    if(indev->event == LV_INDEV_STATE_PR){
#if LV_INDEV_POINT_MARKER != 0
        area_t area;
        area.x1 = indev->act_point.x - (LV_INDEV_POINT_MARKER >> 1);
        area.y1 = indev->act_point.y - (LV_INDEV_POINT_MARKER >> 1);
        area.x2 = indev->act_point.x + ((LV_INDEV_POINT_MARKER >> 1) | 0x1);
        area.y2 = indev->act_point.y + ((LV_INDEV_POINT_MARKER >> 1) | 0x1);
        lv_rfill(&area, NULL, LV_COLOR_MAKE(0xFF, 0, 0), LV_OPA_COVER);
#endif
        indev_proc_press(indev);
    } else {
        indev_proc_release(indev);
    }
    
    indev->last_point.x = indev->act_point.x;
    indev->last_point.y = indev->act_point.y;
}   

/**
 * Process the pressed state
 * @param indev pointer to an input device state
 */
static void indev_proc_press(lv_indev_proc_t * info)
{
    lv_obj_t * pr_obj = info->act_obj;
    
    if(info->wait_unil_release != 0) return;

    /*If there is no last object then search*/
    if(info->act_obj == NULL) {
        pr_obj = indev_search_obj(info, lv_layer_top());
        if(pr_obj == NULL) pr_obj = indev_search_obj(info, lv_scr_act());
    }
    /*If there is last object but it is not dragged also search*/
    else if(info->drag_in_prog == 0) {/*Now act_obj != NULL*/
        pr_obj = indev_search_obj(info, lv_layer_top());
        if(pr_obj == NULL) pr_obj = indev_search_obj(info, lv_scr_act());
    }
    /*If a dragable object was the last then keep it*/
    else {
        
    }
    
    /*If a new object was found reset some variables and send a pressed signal*/
    if(pr_obj != info->act_obj) {

        info->last_point.x = info->act_point.x;
        info->last_point.y = info->act_point.y;
        
        /*If a new object found the previous was lost, so send a signal*/
        if(info->act_obj != NULL) {
            info->act_obj->signal_func(info->act_obj, LV_SIGNAL_PRESS_LOST, indev_act);
            if(info->reset_query != 0) return;
        }
        
        if(pr_obj != NULL) {
            /* Save the time when the obj pressed. 
             * It is necessary to count the long press time.*/
            info->pr_timestamp = lv_tick_get();
            info->long_pr_sent = 0;
            info->drag_range_out = 0;
            info->drag_in_prog = 0;
            info->drag_sum.x = 0;
            info->drag_sum.y = 0;

            /*Search for 'top' attribute*/
            lv_obj_t * i = pr_obj;
            lv_obj_t * last_top = NULL;
            while(i != NULL){
				if(i->top != 0) last_top = i;
				i = lv_obj_get_parent(i);
            }

            if(last_top != NULL) {
            	/*Move the last_top object to the foreground*/
            	lv_obj_t * par = lv_obj_get_parent(last_top);
            	/*After list change it will be the new head*/
                lv_ll_chg_list(&par->child_ll, &par->child_ll, last_top);
                lv_obj_invalidate(last_top);
            }

            /*Send a signal about the press*/
            pr_obj->signal_func(pr_obj, LV_SIGNAL_PRESSED, indev_act);
            if(info->reset_query != 0) return;
        }
    }
    
    info->act_obj = pr_obj;            /*Save the pressed object*/
    info->last_obj = info->act_obj;   /*Refresh the last_obj*/

    /*Calculate the vector*/
    info->vect.x = info->act_point.x - info->last_point.x;
    info->vect.y = info->act_point.y - info->last_point.y;

    /*If there is active object and it can be dragged run the drag*/
    if(info->act_obj != NULL) {
        info->act_obj->signal_func(info->act_obj, LV_SIGNAL_PRESSING, indev_act);
        if(info->reset_query != 0) return;

        indev_drag(info);
        if(info->reset_query != 0) return;

        /*If there is no drag then check for long press time*/
        if(info->drag_in_prog == 0 && info->long_pr_sent == 0) {
            /*Send a signal about the long press if enough time elapsed*/
            if(lv_tick_elaps(info->pr_timestamp) > LV_INDEV_LONG_PRESS_TIME) {
                pr_obj->signal_func(pr_obj, LV_SIGNAL_LONG_PRESS, indev_act);
                if(info->reset_query != 0) return;

                /*Mark the signal sending to do not send it again*/
                info->long_pr_sent = 1;

                /*Save the long press time stamp for the long press repeat handler*/
                info->longpr_rep_timestamp = lv_tick_get();
            }
        }
        /*Send long press repeated signal*/
        if(info->drag_in_prog == 0 && info->long_pr_sent == 1) {
            /*Send a signal about the long press repeate if enough time elapsed*/
            if(lv_tick_elaps(info->longpr_rep_timestamp) > LV_INDEV_LONG_PRESS_REP_TIME) {
                pr_obj->signal_func(pr_obj, LV_SIGNAL_LONG_PRESS_REP, indev_act);
                if(info->reset_query != 0) return;
                info->longpr_rep_timestamp = lv_tick_get();

            }
        }
    }
}

/**
 * Process the released state
 * @param indev_proc_p pointer to an input device state
 */
static void indev_proc_release(lv_indev_proc_t * state)
{
    if(state->wait_unil_release != 0) {
        state->act_obj = NULL;
        state->last_obj = NULL;
        state->pr_timestamp = 0;
        state->longpr_rep_timestamp = 0;
        state->wait_unil_release = 0;
    }

    /*Forgot the act obj and send a released signal */
    if(state->act_obj != NULL) {
        state->act_obj->signal_func(state->act_obj, LV_SIGNAL_RELEASED, indev_act);
        if(state->reset_query != 0) return;
        state->act_obj = NULL;
        state->pr_timestamp = 0;
        state->longpr_rep_timestamp = 0;
    }
    
    /*The reset can be set in the signal function. 
     * In case of reset query ignore the remaining parts.*/
    if(state->last_obj != NULL && state->reset_query == 0) {
        indev_drag_throw(state);
        if(state->reset_query != 0) return;
    }
}

/**
 * Search the most top, clickable object on the last point of an input device
 * @param indev pointer to  an input device
 * @param obj pointer to a start object, typically the screen
 * @return pointer to the found object or NULL if there was no suitable object 
 */
static lv_obj_t * indev_search_obj(const lv_indev_proc_t * indev, lv_obj_t * obj)
{
    lv_obj_t * found_p = NULL;
    
    /*If the point is on this object*/
    /*Check its children too*/
    if(lv_area_is_point_on(&obj->coords, &indev->act_point)) {
        lv_obj_t * i;
    
        LL_READ(obj->child_ll, i) {
            found_p = indev_search_obj(indev, i);
            
            /*If a child was found then break*/
            if(found_p != NULL) {
                break;
            }
        }
        
        /*If then the children was not ok, and this obj is clickable
         * and it or its parent is not hidden then save this object*/
        if(found_p == NULL && lv_obj_get_click(obj) != false) {
        	lv_obj_t * hidden_i = obj;
        	while(hidden_i != NULL) {
        		if(lv_obj_get_hidden(hidden_i) == true) break;
        		hidden_i = lv_obj_get_parent(hidden_i);
        	}
        	/*No parent found with hidden == true*/
        	if(hidden_i == NULL) found_p = obj;
        }
        
    }
    
    return found_p;    
}

/**
 * Handle the dragging of indev_proc_p->act_obj
 * @param indev pointer to a input device state
 */
static void indev_drag(lv_indev_proc_t * state)
{
    lv_obj_t * drag_obj = state->act_obj;
    
    /*If drag parent is active check recursively the drag_parent attribute*/
	while(lv_obj_get_drag_parent(drag_obj) != false &&
		  drag_obj != NULL) {
		drag_obj = lv_obj_get_parent(drag_obj);
	}

	if(drag_obj == NULL) return;
    
    if(lv_obj_get_drag(drag_obj) == false) return;

    /*If still there is no drag then count the movement*/
    if(state->drag_range_out == 0) {
        state->drag_sum.x += state->vect.x;
        state->drag_sum.y += state->vect.y;
        
        /*If a move is greater then LV_DRAG_LIMIT then begin the drag*/
        if(LV_MATH_ABS(state->drag_sum.x) >= LV_INDEV_DRAG_LIMIT ||
           LV_MATH_ABS(state->drag_sum.y) >= LV_INDEV_DRAG_LIMIT)
           {
                state->drag_range_out = 1;
           }
    }
    
    /*If the drag limit is stepped over then handle the dragging*/
    if(state->drag_range_out != 0) {
        /*Set new position if the vector is not zero*/
        if(state->vect.x != 0 ||
           state->vect.y != 0) {
            /*Get the coordinates of the object end modify them*/
            lv_coord_t act_x = lv_obj_get_x(drag_obj);
            lv_coord_t act_y = lv_obj_get_y(drag_obj);

            lv_obj_set_pos(drag_obj, act_x + state->vect.x, act_y + state->vect.y);

            /*Set the drag in progress flag if the object is really moved*/
            if(lv_obj_get_x(drag_obj) != act_x || lv_obj_get_y(drag_obj) != act_y) {
                if(state->drag_range_out != 0) { /*Send the drag begin signal on first move*/
                    drag_obj->signal_func(drag_obj,  LV_SIGNAL_DRAG_BEGIN, indev_act);
                    if(state->reset_query != 0) return;
                }
                state->drag_in_prog = 1;
            }

        }
    }
}

/**
 * Handle throwing by drag if the drag is ended
 * @param indev pointer to an input device state
 */
static void indev_drag_throw(lv_indev_proc_t * state)
{
	if(state->drag_in_prog == 0) return;

    /*Set new position if the vector is not zero*/
    lv_obj_t * drag_obj = state->last_obj;
    
    /*If drag parent is active check recursively the drag_parent attribute*/
	while(lv_obj_get_drag_parent(drag_obj) != false &&
		  drag_obj != NULL) {
		drag_obj = lv_obj_get_parent(drag_obj);
	}

	if(drag_obj == NULL) return;
    
    /*Return if the drag throw is not enabled*/
    if(lv_obj_get_drag_throw(drag_obj) == false ){
    	state->drag_in_prog = 0;
        drag_obj->signal_func(drag_obj, LV_SIGNAL_DRAG_END, indev_act);
        return;
    }
    
    /*Reduce the vectors*/
    state->vect.x = state->vect.x * (100 -LV_INDEV_DRAG_THROW) / 100;
    state->vect.y = state->vect.y * (100 -LV_INDEV_DRAG_THROW) / 100;
    
    if(state->vect.x != 0 ||
       state->vect.y != 0)
    {
        /*Get the coordinates  and modify them*/
        lv_coord_t act_x = lv_obj_get_x(drag_obj) + state->vect.x;
        lv_coord_t act_y = lv_obj_get_y(drag_obj) + state->vect.y;
        lv_obj_set_pos(drag_obj, act_x, act_y);

        /*If non of the coordinates are changed then do not continue throwing*/
        if((lv_obj_get_x(drag_obj) != act_x || state->vect.x == 0) &&
           (lv_obj_get_y(drag_obj) != act_y || state->vect.y == 0)) {
            state->drag_in_prog = 0;
            state->vect.x = 0;
            state->vect.y = 0;
            drag_obj->signal_func(drag_obj, LV_SIGNAL_DRAG_END, indev_act);

        }
    }
    /*If the vectors become 0 -> drag_in_prog = 0 and send a drag end signal*/
    else {
        state->drag_in_prog = 0;
        drag_obj->signal_func(drag_obj, LV_SIGNAL_DRAG_END, indev_act);
    }
}