#!/usr/bin/python
# -*- coding: utf-8 -*-

'''
Search Architecture:
 - Have a list of accounts
 - Create an "overseer" thread
 - Search Overseer:
   - Tracks incoming new location values
   - Tracks "paused state"
   - During pause or new location will clears current search queue
   - Starts search_worker threads
 - Search Worker Threads each:
   - Have a unique API login
   - Listens to the same Queue for areas to scan
   - Can re-login as needed
   - Shares a global lock for map parsing
'''

import os
import logging
import time
import math
import threading
import json
import geojson
from threading import Thread, Lock
from queue import Queue, Empty
from operator import itemgetter
from pgoapi import PGoApi
from pgoapi.utilities import f2i
from pgoapi import utilities as util
from pgoapi.exceptions import AuthException

from . import config
from .models import parse_map

log = logging.getLogger(__name__)

TIMESTAMP = '\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000\000'

def get_new_coords(init_loc, distance, bearing):
    """ Given an initial lat/lng, a distance(in kms), and a bearing (degrees),
    this will calculate the resulting lat/lng coordinates.
    """
    R = 6378.1 #km radius of the earth
    bearing = math.radians(bearing)

    init_coords = [math.radians(init_loc[0]), math.radians(init_loc[1])] # convert lat/lng to radians

    new_lat = math.asin( math.sin(init_coords[0])*math.cos(distance/R) +
        math.cos(init_coords[0])*math.sin(distance/R)*math.cos(bearing))

    new_lon = init_coords[1] + math.atan2(math.sin(bearing)*math.sin(distance/R)*math.cos(init_coords[0]),
        math.cos(distance/R)-math.sin(init_coords[0])*math.sin(new_lat))

    return [math.degrees(new_lat), math.degrees(new_lon)]

def generate_location_steps(initial_loc, step_count):
    #Bearing (degrees)
    NORTH = 0
    EAST = 90
    SOUTH = 180
    WEST = 270

    pulse_radius = 0.07                 # km - radius of players heartbeat is 70m
    xdist = math.sqrt(3)*pulse_radius   # dist between column centers
    ydist = 3*(pulse_radius/2)          # dist between row centers

    yield (initial_loc[0], initial_loc[1], 0) #insert initial location

    ring = 1
    loc = initial_loc
    while ring < step_count:
        #Set loc to start at top left
        loc = get_new_coords(loc, ydist, NORTH)
        loc = get_new_coords(loc, xdist/2, WEST)
        for direction in range(6):
            for i in range(ring):
                if direction == 0: # RIGHT
                    loc = get_new_coords(loc, xdist, EAST)
                if direction == 1: # DOWN + RIGHT
                    loc = get_new_coords(loc, ydist, SOUTH)
                    loc = get_new_coords(loc, xdist/2, EAST)
                if direction == 2: # DOWN + LEFT
                    loc = get_new_coords(loc, ydist, SOUTH)
                    loc = get_new_coords(loc, xdist/2, WEST)
                if direction == 3: # LEFT
                    loc = get_new_coords(loc, xdist, WEST)
                if direction == 4: # UP + LEFT
                    loc = get_new_coords(loc, ydist, NORTH)
                    loc = get_new_coords(loc, xdist/2, WEST)
                if direction == 5: # UP + RIGHT
                    loc = get_new_coords(loc, ydist, NORTH)
                    loc = get_new_coords(loc, xdist/2, EAST)
                yield (loc[0], loc[1], 0)
        ring += 1


#
# A fake search loop which does....nothing!
#
def fake_search_loop():
    while True:
        log.info('Fake search loop running')
        time.sleep(10)

def curSec():
    return (60 * time.gmtime().tm_min) + time.gmtime().tm_sec

def timeDif(a,b):#timeDif of -1800 to +1800 secs
    dif = a-b
    if (dif < -1800):
        dif += 3600
    if (dif > 1800):
        dif -= 3600
    return dif

def SbSearch(Slist, T):
    #binary search to find the lowest index with the required value or the index with the next value update
    first = 0
    last = len(Slist)-1
    while first < last:
        mp = (first+last)//2
        if Slist[mp]['time'] < T:
            first = mp + 1
        else:
            last = mp
    return first
Shash = {}
    # The main search loop that keeps an eye on the over all process
def search_overseer_thread(args, new_location_queue, pause_bit, encryption_lib_path):
    global spawns, Shash, going
    log.info('Search overseer starting')
    search_items_queue = Queue()
    parse_lock = Lock()

    # Create a search_worker_thread per account
    log.info('Starting search worker threads')
    for i, account in enumerate(args.accounts):
        log.debug('Starting search worker thread %d for user %s', i, account['username'])
        t = Thread(target=search_worker_thread,
                   name='search_worker_{}'.format(i),
                   args=(args, account, search_items_queue, parse_lock,
                       encryption_lib_path))
        t.daemon = True
        t.start()

    # A place to track the current location
    current_location = False;


    #FIXME add arg for switching
    #load spawn points
    with open('spawns.json') as file:
        spawns = json.load(file)
        file.close()
    for spawn in spawns:
        hash = '{},{}'.format(spawn['time'],spawn['lng'])
        Shash[spawn['lng']] = spawn['time']
    #sort spawn points
    spawns.sort(key=itemgetter('time'))
    log.info('total of %d spawns to track',len(spawns))
    #find start position
    pos = SbSearch(spawns, (curSec()+3540)%3600)
    while True:
        while timeDif(curSec(),spawns[pos]['time']) < 60:
            time.sleep(1)
        location = []
        location.append(spawns[pos]['lat'])
        location.append(spawns[pos]['lng'])
        location.append(0)
        for step, step_location in enumerate(generate_location_steps(location, args.step_limit), 1):
                log.debug('Queueing step %d @ %f/%f/%f', pos, step_location[0], step_location[1], step_location[2])
                search_args = (step, step_location, spawns[pos]['time'])
                search_items_queue.put(search_args)
        pos = (pos+1) % len(spawns)
        if pos == 0:
            while not(search_items_queue.empty()):
                log.info('search_items_queue not empty. waiting 10 secrestarting at top of hour')
                time.sleep(10)
            log.info('restarting from top of list and finding current time')
            pos = SbSearch(spawns, (curSec()+3540)%3600)

def search_worker_thread(args, account, search_items_queue, parse_lock, encryption_lib_path):

    log.debug('Search worker thread starting')

    # The forever loop for the thread
    while True:
        try:
            log.debug('Entering search loop')

            # Create the API instance this will use
            api = PGoApi()

            # The forever loop for the searches
            while True:

                # Grab the next thing to search (when available)
                step, step_location, spawntime = search_items_queue.get()

                log.info('Searching step %d, remaining %d', step, search_items_queue.qsize())
                if timeDif(curSec(),spawntime) < 840:#if we arnt 14mins too late
                    # Let the api know where we intend to be for this loop
                    api.set_position(*step_location)

                    # The loop to try very hard to scan this step
                    failed_total = 0
                    while True:

                        # After so many attempts, let's get out of here
                        if failed_total >= args.scan_retries:
                            # I am choosing to NOT place this item back in the queue
                            # otherwise we could get a "bad scan" area and be stuck
                            # on this overall loop forever. Better to lose one cell
                            # than have the scanner, essentially, halt.
                            log.error('Search step %d went over max scan_retires; abandoning', step)
                            break

                        # Increase sleep delay between each failed scan
                        # By default scan_dela=5, scan_retries=5 so
                        # We'd see timeouts of 5, 10, 15, 20, 25
                        sleep_time = args.scan_delay * (1+failed_total)

                        # Ok, let's get started -- check our login status
                        check_login(args, account, api, step_location)

                        api.activate_signature(encryption_lib_path)

                        # Make the actual request (finally!)
                        response_dict = map_request(api, step_location)

                        # G'damnit, nothing back. Mark it up, sleep, carry on
                        if not response_dict:
                            log.error('Search step %d area download failed, retyring request in %g seconds', step, sleep_time)
                            failed_total += 1
                            time.sleep(sleep_time)
                            continue

                        # Got the response, lock for parsing and do so (or fail, whatever)
                        with parse_lock:
                            try:
                                parsed = parse_map(response_dict, step_location)
                                log.debug('Search step %s completed', step)
                                search_items_queue.task_done()
                                break # All done, get out of the request-retry loop
                            except KeyError:
                                log.error('Search step %s map parsing failed, retyring request in %g seconds', step, sleep_time)
                                failed_total += 1
                                time.sleep(sleep_time)

                    time.sleep(args.scan_delay)
                else:
                    log.info('cant keep up. skipping')

        # catch any process exceptions, log them, and continue the thread
        except Exception as e:
            log.exception('Exception in search_worker: %s', e)


def check_login(args, account, api, position):

    # Logged in? Enough time left? Cool!
    if api._auth_provider and api._auth_provider._ticket_expire:
        remaining_time = api._auth_provider._ticket_expire/1000 - time.time()
        if remaining_time > 60:
            log.debug('Credentials remain valid for another %f seconds', remaining_time)
            return

    # Try to login (a few times, but don't get stuck here)
    i = 0
    api.set_position(position[0], position[1], position[2])
    while i < args.login_retries:
        try:
            api.set_authentication(provider = account['auth_service'], username = account['username'], password = account['password'])
            break
        except AuthException:
            if i >= args.login_retries:
                raise TooManyLoginAttempts('Exceeded login attempts')
            else:
                i += 1
                log.error('Failed to login to Pokemon Go with account %s. Trying again in %g seconds', account['username'], args.login_delay)
                time.sleep(args.login_delay)

    log.debug('Login for account %s successful', account['username'])

def map_request(api, position):
    try:
        cell_ids = util.get_cell_ids(position[0], position[1])
        timestamps = [0,] * len(cell_ids)
        return api.get_map_objects(latitude=f2i(position[0]),
                            longitude=f2i(position[1]),
                            since_timestamp_ms=timestamps,
                            cell_id=cell_ids)
    except Exception as e:
        log.warning('Exception while downloading map: %s', e)
        return False

class TooManyLoginAttempts(Exception):
    pass