#! /usr/bin/env python3

import os, sys, sqlite3, functools, configparser, textwrap
import os.path as op
from datetime import datetime, timezone

from . import cli_parser, utils, data_access, core
from .rainbow import ColoredStr, cstr
from .data_access import DataAccess
from .utils import (
	DATA_DIR, DB_PATH, VERSION_PATH, DATAFILE_PATH, NOW,
	CannotOpenEditorError
)


__version__ = '3.2.1'


# Icons used to print tasks' properties in the terminal.
# True is the ASCII version for challenged terminals.
# False is the Unicode version.
CONTEXT_ICON = {True: '#', False: '#'}
TIME_ICON = {True: '~', False: '⌛'}
PRIORITY_ICON = {True: '!', False: '★'}

WIDE_HIST_THRESHOLD = 120

TASK_MUTATORS = {
	'deadline': datetime.max,
	'start': None,
	'priority': 1,
	'title': None,
	'created': data_access.DATETIME_MIN
}

CONTEXT_MUTATORS = {
	'priority': 1,
	'visibility': 'normal'
}


CONFIG_FILE = op.expanduser(op.join('~', '.toduhrc'))

if os.name == 'posix':
	COLORS = 'on'
else:
	COLORS = 'off'

DEFAULT_CONFIG = configparser.ConfigParser()
DEFAULT_CONFIG['App'] = {
	'layout': 'basic',
	'todo_fashion': 'tidy',
	'show_empty_contexts': True
}
DEFAULT_CONFIG['Colors'] = {
	'colors': COLORS,
	'palette': '8',
	'id': 'yellow',
	'content': 'default',
	'context': 'cyan',
	'overtime': 'red',
	'deadline': 'cyan',
	'priority': 'green',
	'done': 'green'
}
DEFAULT_CONFIG['Word-wrapping'] = {
	'title': True,
	'content': True,
	'smart': False,
	'width': -1
}

CONFIG = configparser.ConfigParser(
	allow_no_value=True,
	strict=True
	)
# Loading the config with the default config
CONFIG.read_dict(DEFAULT_CONFIG)
# Loading the user config. Will complete/overwrite the default config
# but will keep default config entries that the user might have removed
CONFIG.read(CONFIG_FILE)

# Editor election: in config file? No -> in OS EDITOR variable? No -> vim
EDITOR = CONFIG.get('App', 'editor', fallback=None)
if EDITOR is None:
	EDITOR = os.environ.get('EDITOR', 'vim')

if CONFIG.getboolean('Colors', 'colors'):
	cstr = functools.partial(
		cstr,
		palette=CONFIG.get('Colors', 'palette')
	)
else:
	cstr = functools.partial(
		cstr,
		no_color=True
	)


DONE_STR = '[DONE]'


def main():
	argv = sys.argv[1:]
	if len(argv) == 1 and argv[0] == 'doduh':
		print('Beethoven - Symphony No. 5')
		sys.exit(0)
	args = cli_parser.parse_cli()

	if args['version']:
		print(__version__)
	elif args['location']:
		print(DATA_DIR)
	else:
		report = cli_parser.parse_args(args)
		if len(report) > 0:
			for error in report:
				print(error)
			sys.exit(1)

		current_version = get_installed_version()
		if not op.exists(DATA_DIR):
			os.mkdir(DATA_DIR)
		if current_version != __version__:
			with open(VERSION_PATH, 'w') as version_file:
				version_file.write(__version__)

		daccess = get_data_access(current_version)
		result = dispatch(args, daccess)
		if result is not None:
			feedback_code, *data = result
			globals()['feedback_'+feedback_code](*data)
		daccess.exit()


def get_installed_version():
	if op.exists(VERSION_PATH):
		with open(VERSION_PATH) as version_file:
			return version_file.read()
	else:
		if op.exists(DB_PATH):
			return '3.0.1'
		elif op.exists(DATAFILE_PATH):
			return '2.1'
		else:
			return None


def get_data_access(current_version):
	data_access.setup_data_access(current_version)
	connection = sqlite3.connect(DB_PATH)
	return DataAccess(connection)


# HANDLERS

# Do something with the args dictionary and the data access object then return
# a feedback code as well as some data about how things went. Feedback
# functions (whose names are feedback_<feedback_code>) will then be passed the
# data and should print some feedback based on the data. A handler can also
# return nothing (or None) if no feedback is intended.

def add_task(args, daccess):
	context = args.get('context')
	options = get_options(args, TASK_MUTATORS, {'deadline': {'None': None}})
	if context is None:
		context = ''

	if args['edit']:
		title, content = core.editor_edit_task(args['title'], None, EDITOR)
	else:
		title, content = args['title'], None

	id_ = daccess.add_task(title, content, context, options)
	return 'add_task', id_


def manage_task(args, daccess):
	tid = args['id'][0]
	context = args.get('context')
	options = get_options(args, TASK_MUTATORS, {'deadline': {'None': None}})

	if len(options) == 0 and context is None:
		return show_task(tid, daccess)
	else:
		upt_count = daccess.update_task(tid, context, options)
		if upt_count == 0:
			return 'task_not_found', tid


def show_task(tid, daccess):
	task = daccess.get_task(tid)
	if task is None:
		return 'task_not_found', tid
	# w3 = word-wrap width
	w3 = CONFIG.getboolean('Word-wrapping', 'content')
	if w3:
		w3 = CONFIG.getint('Word-wrapping', 'width')
		if w3 == -1:
			w3 = utils.get_terminal_width()
	else:
		w3 = None

	full_content = core.get_task_full_content(
		task['title'],
		task['content'],
		wrap_width=w3,
		smart_wrap=CONFIG.getboolean('Word-wrapping', 'smart')
	)

	return 'show_task', task, full_content


def edit_task(args, daccess):
	tid = args['id'][0]
	task = daccess.get_task(tid)
	if task is None:
		return 'task_not_found', tid
	can_edit = daccess.take_editing_lock(tid)
	if not can_edit:
		return 'cannot_edit', tid
	try:
		try:
			new_title, new_content = core.editor_edit_task(
				task['title'],
				task['content'],
				EDITOR
			)
		except CannotOpenEditorError as err:
			return 'cannot_open_editor', err.editor
		daccess.update_task(tid, options=[
			('title', new_title),
			('content', new_content)
		])
	finally:
		daccess.release_editing_lock(tid)


def do_task(args, daccess):
	not_found = daccess.set_done_many(args['id'])
	return 'multiple_tasks_done', not_found


def remove_task(args, daccess):
	not_found = daccess.remove_many(args['id'])
	return 'multiple_tasks_update', not_found


def manage_context(args, daccess):
	path = args['context']
	name = args.get('name')
	options = get_options(args, CONTEXT_MUTATORS)
	exists = True
	if len(options) == 0 and name is None:
		return todo(args, daccess)
	else:
		if name is not None:
			renamed = data_access.rename_context(args['context'], name)
			rcount = daccess.rename_context(args['context'], name)
			if rcount is None:
				return 'target_name_exists', renamed
			else:
				if rcount > 0:
					path = renamed
				else:
					exists = False
		if len(options) > 0:
			daccess.set_context(path, options)
		elif not exists:
			return 'not_exists', path


def move(args, daccess):
	ctx1 = args['ctx1']
	ctx2 = args['ctx2']
	source_exists = daccess.context_exists(ctx1)
	if not source_exists:
		return 'not_exists', ctx1
	else:
		daccess.move_all(ctx1, ctx2)


def remove_context(args, daccess):
	ctx = args['context']
	if not daccess.context_exists(ctx):
		return 'not_exists', ctx

	force = args['force']
	go_ahead = False
	if not force:
		nb_tasks, nb_subctx = daccess.get_basic_context_tally(ctx)
		ans = input('This context contains {} direct undone task(s) and '
			'{} subcontext(s). Continue? y/* '.format(nb_tasks, nb_subctx))
		go_ahead = ans == 'y'
	else:
		go_ahead = True
	if go_ahead:
		daccess.remove_context(ctx)


def todo(args, daccess):
	fashion = 'flat' if args['flat'] else None
	if fashion is None:
		fashion = 'tidy' if args['tidy'] else None
	if fashion is None:
		fashion = CONFIG.get('App', 'todo_fashion')
	ctx = args.get('context', '')
	if ctx is None:
		ctx = ''
	tasks = daccess.todo(ctx, recursive=(fashion == 'flat'))
	if fashion == 'tidy':
		get_empty = CONFIG.getboolean('App', 'show_empty_contexts')
		subcontexts = daccess.get_subcontexts(ctx, get_empty)
	else:
		subcontexts = []
	return 'todo', ctx, tasks, subcontexts


def get_contexts(args, daccess):
	path = args['context']
	if path is None:
		path = ''
	contexts = daccess.get_descendants(path)
	return 'contexts', contexts


def get_history(args, daccess):
	tasks = daccess.history()
	gid = daccess.get_greatest_id()
	return 'history', tasks, gid


def purge(args, daccess):
	force = args['force']
	before = args['before']
	go_ahead = False
	if force:
		go_ahead = True
	else:
		if before is None:
			q = "This will delete all done tasks. "
		else:
			q = "This will delete all done tasks created before "+\
			"{}. ".format(before)
		q += "This operation is irreversible. Continue? y/* "
		ans = input(q)
		if ans == 'y':
			go_ahead = True
	if go_ahead:
		count = daccess.purge(before)
		return 'purge', count


def search(args, daccess):
	term = args['term']
	done = None
	if args['done']:
		done = True
	elif args['undone']:
		done = False
	if args['context'] is None:
		ctx = ''
	else:
		ctx = args['context']
	tasks = daccess.search(
		term,
		ctx=ctx,
		done=done,
		before=args.get('before'),
		after=args.get('after'),
		case=args['case']
	)
	return 'todo', '', tasks, [], (term, args['case'])

## DISPATCHING

# Map of the names of the commands to handlers defined above.

DISPATCHER = {
	'add': add_task,
	'task': manage_task,
	'edit': edit_task,
	'done': do_task,
	'rm': remove_task,
	'ctx': manage_context,
	'rmctx': remove_context,
	'mv': move,
	'contexts': get_contexts,
	'history': get_history,
	'purge': purge,
	'search': search
}


def dispatch(args, daccess):
	if 'command' in args:
		return DISPATCHER[args['command']](args, daccess)
	# If no command, fallback to the todo handler
	return todo(args, daccess)


def get_options(args, mutators, converters={}):
	"""
	Returns a list of 2-tuple in the form (option, value) for all options
	contained in the `mutators` collection if they're also keys of the `args`
	and have a non-None value. If the option (non- prefixed) is also a key of
	the `converters` dictionary then the associated value should be another
	dictionary indicating convertions to be done on the value found in `args`.
	e.g.
	args = {'deadline': 'none'}
	mutators = {'deadline'}
	converters = {'deadline': {'none': None}}
	=> [('deadline', None)]
	"""
	options = []
	for mutator in mutators:
		if mutator in args and args[mutator] is not None:
			val = args[mutator]
			convertions = converters.get(mutator)
			if convertions is not None and val in convertions:
				val = convertions[val]
			options.append((mutator, val))
	return options


## FEEDBACK FUNCTIONS

TASK_SUBCTX_SEP = '-'*40


def feedback_add_task(id_):
	pass


def feedback_task_not_found(tid):
	print('Task {} not found'.format(utils.to_hex(tid)))


def feedback_cannot_edit(tid):
	print('Task {} is already being edited'.format(utils.to_hex(tid)))


def feedback_cannot_open_editor(editor):
	print('Cannot open editor: {}'.format(editor))


def feedback_multiple_tasks_update(not_found):
	if len(not_found) > 0:
		s = 's' if len(not_found) > 1 else ''
		string = ', '.join(utils.to_hex(tid) for tid in not_found)
		print('Task{} not found: {}'.format(s, string))


def feedback_multiple_tasks_done(not_found):
	if len(not_found) > 0:
		string = ', '.join(utils.to_hex(tid) for tid in not_found)
		print('Not found or already done: {}'.format(string))


def feedback_todo(context, tasks, subcontexts, highlight=None):
	layout = CONFIG.get('App', 'layout')
	if layout == 'multiline':
		stringyfier = get_multiline_task_string
	else:
		stringyfier = get_basic_task_string

	if len(tasks) != 0:
		id_width = max(len(utils.to_hex(task['id'])) for task in tasks)
	else:
		id_width = 1

	for task in tasks:
		partial = functools.partial(stringyfier, context, id_width, task,
			highlight=highlight)
		safe_print(partial)
	if len(subcontexts) > 0:
		print(TASK_SUBCTX_SEP)
	for ctx in subcontexts:
		partial = functools.partial(get_context_string, context, id_width, ctx)
		safe_print(partial)


def feedback_target_name_exists(renamed):
	print('Context already exists: {}'.format(
		utils.get_relative_path('', renamed)
		)
	)


def feedback_not_exists(ctx):
	print("Context does not exist: {}".format(
		utils.get_relative_path('', ctx)
		)
	)


def feedback_contexts(contexts):
	def get_tally(ctx):
		return '{} ({})'.format(ctx['total_tasks'], ctx['own_tasks'])
	struct = [
		('context', lambda a: a, '<', 'path', lambda a: a[1:]),
		('visibility', 10, '<', 'visibility', None),
		('priority', 8, '<', 'priority', None),
		('undone tasks', 12, '<', None, get_tally)
	]
	utils.print_table(struct, contexts, is_context_default)


def feedback_history(tasks, gid):
	if gid is None:
		print('No history.')
	else:
		struct = get_history_struct(gid)
		utils.print_table(struct, tasks, is_task_default)


def feedback_purge(count):
	s = 's' if count > 1 else ''
	print('{} task{} deleted'.format(count, s))


def feedback_show_task(task, full_content):
	print(cstr("     ID:", '6'), utils.to_hex(task['id']))
	print(cstr("Created:", '6'), utils.sqlite_date_to_local(task['created']))
	if task['start'] == task['created']:
		print(cstr("  Start:", '6'), "@created")
	else:
		print(cstr("  Start:", '6'), utils.sqlite_date_to_local(task['start']))
	print(
		cstr(" Status:", '6'),
		"DONE" if task['done'] is not None else "TODO"
	)

	def print_metaline(ascii_):
		c = get_task_string_components(task, '', ascii_, highlight=None)
		if task['done'] is None:
			stuff = ['deadline', 'priority', 'context']
		else:
			stuff = ['priority', 'context']
		metaline = ' '.join(c[a] for a in stuff if c[a] != '')
		if len(metaline) > 0:
			return ' ' + metaline
		else:
			return None

	safe_print(print_metaline)

	print(cstr('-'*utils.get_terminal_width(), '3'))
	print(full_content)


# String building for todo feedback

# Those functions return a string. They accept a boolean `ascii_` argument
# that indicates whether to build the returned string with ASCII characters
# only (True) or whether non-ASCII characters are allowed (False). Those
# functions will then be partially called with all arguments set except the
# `ascii_` one and the resulting partial will be passed to `safe_print` which
# will take care of trying to print the non-ASCII version and then fallback to
# the ASCII version in case of error from the terminal.

def get_basic_task_string(context, id_width, task, highlight=None, ascii_=False):
	c = get_task_string_components(task, context, ascii_, highlight=highlight)

	if isinstance(c['id'], ColoredStr):
		ansi_offset = c['id'].lenesc
	else:
		ansi_offset = 0
	result = ' {id:>{width}} | '.format(width=id_width + ansi_offset, **c)
	left_width = id_width + 4
	init_indent = left_width

	if len(c['done']):
		adding = c['done'] + ' '
		result += adding
		init_indent += len(DONE_STR) + 1 # [DONE] followed by space

	wrap_width = CONFIG.getint('Word-wrapping', 'width')
	if wrap_width == -1:
		wrap_width = utils.get_terminal_width()

	if CONFIG.getboolean('Word-wrapping', 'title'):
		title_subindent = ' '*left_width

		# The correct way to wrap would be to order textwrap to wrap the whole
		# ` {id} | {title}` with the subsequent indent being the length of `
		# {id} | `. However, {id} containing ANSI escape characters for
		# coloring will mess up textwrap character counting, so what we do
		# instead is wrapping only {title} prefixed with the length of ` {id}
		# | `, and we remove the prefix afterwards, ` {id} | ` taking its
		# place.

		lines = textwrap.wrap(
			' '*init_indent + c['title'],
			width=wrap_width,
			subsequent_indent=' '*left_width
		)
		lines[0] = lines[0][init_indent:]
	else:
		lines = [c['title']]

	len_last_line = len(lines[-1])
	title = '\n'.join(lines)

	start_title = len(result)
	result += title
	end_title = len(result)

	metadata = [c['deadline'], c['priority'], c['context']]
	metatext = ' '.join(stuff for stuff in metadata if stuff != '')

	if len(metatext) > 0:
		wrap_title = CONFIG.getboolean('Word-wrapping', 'title')
		not_enough_space = wrap_width - len_last_line <= 0
		if wrap_title and not_enough_space:
			result += '\n' + ' '*left_width
		else:
			result += ' '
		result += metatext

	return result


def get_multiline_task_string(context, id_width, task, highlight=None, ascii_=False):
	c = get_task_string_components(task, context, ascii_, highlight=highlight)
	template = ' {id} {done} / {deadline} {priority} {context}\n'
	result =  template.format(**c)

	wrap_width = CONFIG.getint('Word-wrapping', 'width')
	if wrap_width == -1:
		wrap_width = utils.get_terminal_width()
	title = c['title']
	if CONFIG.getboolean('Word-wrapping', 'title'):
		title = '\n'.join(textwrap.wrap(c['title'], width=wrap_width))
	result += title + '\n'
	return result


def get_task_string_components(task, ctx, ascii_=False, highlight=None):
	id_str = cstr(utils.to_hex(task['id']), clr('id'))

	if highlight is not None and CONFIG.getboolean('Colors', 'colors'):
		term, case = highlight
		content_str = utils.get_highlights_term(
			task['title'],
			term,
			(clr('content'), CONFIG.get('Colors', 'palette')),
			case=case
		)
	else:
		content_str = cstr(task['title'], clr('content'))

	remaining_str = ''
	deadline = get_datetime(task['deadline'])
	if deadline is not None:
		remaining = deadline - NOW
		user_friendly , isOvertime = utils.parse_remaining(remaining)
		remaining_str = '{} {} remaining'.format(
			TIME_ICON[ascii_],
			user_friendly
		)
		remaining_str = cstr(remaining_str, clr('overtime')) if isOvertime else cstr(remaining_str, clr('deadline'))

	prio_str = ''
	priority = task['priority']
	if not is_task_default(task, 'priority'):
		prio_str = '{}{}'.format(PRIORITY_ICON[ascii_], priority)
		prio_str = cstr(prio_str, clr('priority'))

	ctx_path = utils.get_relative_path(ctx, task['ctx_path'])
	if ctx_path == '':
		ctx_str = ''
	else:
		ctx_str = '{}{}'.format(CONTEXT_ICON[ascii_], ctx_path)
		ctx_str = cstr(ctx_str, clr('context'))

	done_str = ''
	if task['done'] is not None:
		done_str = DONE_STR
	if done_str != '':
		done_str = cstr(done_str, clr('done'))

	return {
		'id': id_str,
		'title': content_str,
		'deadline': remaining_str,
		'priority': prio_str,
		'context': ctx_str,
		'done': done_str
	}


def get_context_string(context, id_width, ctx, ascii_=False):
	hash_str = cstr('#', clr('id'))
	if isinstance(hash_str, ColoredStr):
		ansi_offset = hash_str.lenesc
	else:
		ansi_offset = 0
	path = utils.get_relative_path(context, ctx['path'])
	string = '{hash:>{width}} | {path} ({nbr})'.format(
		hash=hash_str,
		width=id_width + ansi_offset + 1,
		path=path,
		nbr=ctx['total_tasks']
	)
	priority = ctx['priority']
	if not is_task_default(ctx, 'priority'):
		prio_str = ' {}{}'.format(PRIORITY_ICON[ascii_], priority)
		string += cstr(prio_str, clr('priority'))
	return string


def safe_print(partial):
	try:
		result = partial(ascii_=False)
		if result is not None:
			print(result)
	except UnicodeEncodeError:
		result = partial(ascii_=True)
		if result is not None:
			print(result)


def get_datetime(db_dt):
	""" Get a datetime object from the string retrieved from the database."""
	if db_dt is None:
		return None
	return datetime\
		.strptime(db_dt, utils.SQLITE_DT_FORMAT)\
		.replace(tzinfo=timezone.utc)


def is_task_default(task, prop):
	if prop == 'start':
		return task['start'] == task['created']
	return is_default(task, prop, TASK_MUTATORS)


def is_context_default(ctx, prop):
	return is_default(ctx, prop, CONTEXT_MUTATORS)


def is_default(dico, prop, defaults):
	default = defaults.get(prop, None)
	if default is None:
		return False
	else:
		return dico[prop] == default


def get_history_struct(gid):
	gid_len = len(utils.to_hex(gid))
	struct = [
		('id', gid_len + 1, '>', 'id', utils.to_hex),
		('title', lambda a: 3 * (a//4), '<', 'title', None),
		('created', 19, '<', 'created', utils.sqlite_date_to_local),
	]
	if utils.get_terminal_width() > WIDE_HIST_THRESHOLD:
		struct += [
			('start', 19, '<', 'start', utils.sqlite_date_to_local),
			('deadline', 19, '<', 'deadline', utils.sqlite_date_to_local),
			('priority', 8, '>', 'priority', None)
		]
	struct += [
		('context', lambda a: a//4 + a%4, '<', 'ctx_path', lambda a: a[1:]),
		('status', 7, '<', 'done', lambda a: 'DONE' if a is not None else '')
	]
	return struct


def clr(component):
	return CONFIG.get('Colors', component)

#! /usr/bin/env python3

import os, sys, sqlite3, functools, configparser, textwrap
import os.path as op
from datetime import datetime, timezone

from . import cli_parser, utils, data_access, core
from .rainbow import ColoredStr, cstr
from .data_access import DataAccess
from .utils import (
	DATA_DIR, DB_PATH, VERSION_PATH, DATAFILE_PATH, NOW,
	CannotOpenEditorError
)


__version__ = '3.2.1'


# Icons used to print tasks' properties in the terminal.
# True is the ASCII version for challenged terminals.
# False is the Unicode version.
CONTEXT_ICON = {True: '#', False: '#'}
TIME_ICON = {True: '~', False: '⌛'}
PRIORITY_ICON = {True: '!', False: '★'}

WIDE_HIST_THRESHOLD = 120

TASK_MUTATORS = {
	'deadline': datetime.max,
	'start': None,
	'priority': 1,
	'title': None,
	'created': data_access.DATETIME_MIN
}

CONTEXT_MUTATORS = {
	'priority': 1,
	'visibility': 'normal'
}


CONFIG_FILE = op.expanduser(op.join('~', '.toduhrc'))

if os.name == 'posix':
	COLORS = 'on'
else:
	COLORS = 'off'

DEFAULT_CONFIG = configparser.ConfigParser()
DEFAULT_CONFIG['App'] = {
	'layout': 'basic',
	'todo_fashion': 'tidy',
	'show_empty_contexts': True
}
DEFAULT_CONFIG['Colors'] = {
	'colors': COLORS,
	'palette': '8',
	'id': 'yellow',
	'content': 'default',
	'context': 'cyan',
	'overtime': 'red',
	'deadline': 'cyan',
	'priority': 'green',
	'done': 'green'
}
DEFAULT_CONFIG['Word-wrapping'] = {
	'title': True,
	'content': True,
	'smart': False,
	'width': -1
}

CONFIG = configparser.ConfigParser(
	allow_no_value=True,
	strict=True
	)
# Loading the config with the default config
CONFIG.read_dict(DEFAULT_CONFIG)
# Loading the user config. Will complete/overwrite the default config
# but will keep default config entries that the user might have removed
CONFIG.read(CONFIG_FILE)

# Editor election: in config file? No -> in OS EDITOR variable? No -> vim
EDITOR = CONFIG.get('App', 'editor', fallback=None)
if EDITOR is None:
	EDITOR = os.environ.get('EDITOR', 'vim')

if CONFIG.getboolean('Colors', 'colors'):
	cstr = functools.partial(
		cstr,
		palette=CONFIG.get('Colors', 'palette')
	)
else:
	cstr = functools.partial(
		cstr,
		no_color=True
	)


DONE_STR = '[DONE]'


def main():
	argv = sys.argv[1:]
	if len(argv) == 1 and argv[0] == 'doduh':
		print('Beethoven - Symphony No. 5')
		sys.exit(0)
	args = cli_parser.parse_cli()

	if args['version']:
		print(__version__)
	elif args['location']:
		print(DATA_DIR)
	else:
		report = cli_parser.parse_args(args)
		if len(report) > 0:
			for error in report:
				print(error)
			sys.exit(1)

		current_version = get_installed_version()
		if not op.exists(DATA_DIR):
			os.mkdir(DATA_DIR)
		if current_version != __version__:
			with open(VERSION_PATH, 'w') as version_file:
				version_file.write(__version__)

		daccess = get_data_access(current_version)
		result = dispatch(args, daccess)
		if result is not None:
			feedback_code, *data = result
			globals()['feedback_'+feedback_code](*data)
		daccess.exit()


def get_installed_version():
	if op.exists(VERSION_PATH):
		with open(VERSION_PATH) as version_file:
			return version_file.read()
	else:
		if op.exists(DB_PATH):
			return '3.0.1'
		elif op.exists(DATAFILE_PATH):
			return '2.1'
		else:
			return None


def get_data_access(current_version):
	data_access.setup_data_access(current_version)
	connection = sqlite3.connect(DB_PATH)
	return DataAccess(connection)


# HANDLERS

# Do something with the args dictionary and the data access object then return
# a feedback code as well as some data about how things went. Feedback
# functions (whose names are feedback_<feedback_code>) will then be passed the
# data and should print some feedback based on the data. A handler can also
# return nothing (or None) if no feedback is intended.

def add_task(args, daccess):
	context = args.get('context')
	options = get_options(args, TASK_MUTATORS, {'deadline': {'None': None}})
	if context is None:
		context = ''

	if args['edit']:
		title, content = core.editor_edit_task(args['title'], None, EDITOR)
	else:
		title, content = args['title'], None

	id_ = daccess.add_task(title, content, context, options)
	return 'add_task', id_


def manage_task(args, daccess):
	tid = args['id'][0]
	context = args.get('context')
	options = get_options(args, TASK_MUTATORS, {'deadline': {'None': None}})

	if len(options) == 0 and context is None:
		return show_task(tid, daccess)
	else:
		upt_count = daccess.update_task(tid, context, options)
		if upt_count == 0:
			return 'task_not_found', tid


def show_task(tid, daccess):
	task = daccess.get_task(tid)
	if task is None:
		return 'task_not_found', tid
	# w3 = word-wrap width
	w3 = CONFIG.getboolean('Word-wrapping', 'content')
	if w3:
		w3 = CONFIG.getint('Word-wrapping', 'width')
		if w3 == -1:
			w3 = utils.get_terminal_width()
	else:
		w3 = None

	full_content = core.get_task_full_content(
		task['title'],
		task['content'],
		wrap_width=w3,
		smart_wrap=CONFIG.getboolean('Word-wrapping', 'smart')
	)

	return 'show_task', task, full_content


def edit_task(args, daccess):
	tid = args['id'][0]
	task = daccess.get_task(tid)
	if task is None:
		return 'task_not_found', tid
	can_edit = daccess.take_editing_lock(tid)
	if not can_edit:
		return 'cannot_edit', tid
	try:
		try:
			new_title, new_content = core.editor_edit_task(
				task['title'],
				task['content'],
				EDITOR
			)
		except CannotOpenEditorError as err:
			return 'cannot_open_editor', err.editor
		daccess.update_task(tid, options=[
			('title', new_title),
			('content', new_content)
		])
	finally:
		daccess.release_editing_lock(tid)


def do_task(args, daccess):
	not_found = daccess.set_done_many(args['id'])
	return 'multiple_tasks_done', not_found


def remove_task(args, daccess):
	not_found = daccess.remove_many(args['id'])
	return 'multiple_tasks_update', not_found


def manage_context(args, daccess):
	path = args['context']
	name = args.get('name')
	options = get_options(args, CONTEXT_MUTATORS)
	exists = True
	if len(options) == 0 and name is None:
		return todo(args, daccess)
	else:
		if name is not None:
			renamed = data_access.rename_context(args['context'], name)
			rcount = daccess.rename_context(args['context'], name)
			if rcount is None:
				return 'target_name_exists', renamed
			else:
				if rcount > 0:
					path = renamed
				else:
					exists = False
		if len(options) > 0:
			daccess.set_context(path, options)
		elif not exists:
			return 'not_exists', path


def move(args, daccess):
	ctx1 = args['ctx1']
	ctx2 = args['ctx2']
	source_exists = daccess.context_exists(ctx1)
	if not source_exists:
		return 'not_exists', ctx1
	else:
		daccess.move_all(ctx1, ctx2)


def remove_context(args, daccess):
	ctx = args['context']
	if not daccess.context_exists(ctx):
		return 'not_exists', ctx

	force = args['force']
	go_ahead = False
	if not force:
		nb_tasks, nb_subctx = daccess.get_basic_context_tally(ctx)
		ans = input('This context contains {} direct undone task(s) and '
			'{} subcontext(s). Continue? y/* '.format(nb_tasks, nb_subctx))
		go_ahead = ans == 'y'
	else:
		go_ahead = True
	if go_ahead:
		daccess.remove_context(ctx)


def todo(args, daccess):
	fashion = 'flat' if args['flat'] else None
	if fashion is None:
		fashion = 'tidy' if args['tidy'] else None
	if fashion is None:
		fashion = CONFIG.get('App', 'todo_fashion')
	ctx = args.get('context', '')
	if ctx is None:
		ctx = ''
	tasks = daccess.todo(ctx, recursive=(fashion == 'flat'))
	if fashion == 'tidy':
		get_empty = CONFIG.getboolean('App', 'show_empty_contexts')
		subcontexts = daccess.get_subcontexts(ctx, get_empty)
	else:
		subcontexts = []
	return 'todo', ctx, tasks, subcontexts


def get_contexts(args, daccess):
	path = args['context']
	if path is None:
		path = ''
	contexts = daccess.get_descendants(path)
	return 'contexts', contexts


def get_history(args, daccess):
	tasks = daccess.history()
	gid = daccess.get_greatest_id()
	return 'history', tasks, gid


def purge(args, daccess):
	force = args['force']
	before = args['before']
	go_ahead = False
	if force:
		go_ahead = True
	else:
		if before is None:
			q = "This will delete all done tasks. "
		else:
			q = "This will delete all done tasks created before "+\
			"{}. ".format(before)
		q += "This operation is irreversible. Continue? y/* "
		ans = input(q)
		if ans == 'y':
			go_ahead = True
	if go_ahead:
		count = daccess.purge(before)
		return 'purge', count


def search(args, daccess):
	term = args['term']
	done = None
	if args['done']:
		done = True
	elif args['undone']:
		done = False
	if args['context'] is None:
		ctx = ''
	else:
		ctx = args['context']
	tasks = daccess.search(
		term,
		ctx=ctx,
		done=done,
		before=args.get('before'),
		after=args.get('after'),
		case=args['case']
	)
	return 'todo', '', tasks, [], (term, args['case'])

## DISPATCHING

# Map of the names of the commands to handlers defined above.

DISPATCHER = {
	'add': add_task,
	'task': manage_task,
	'edit': edit_task,
	'done': do_task,
	'rm': remove_task,
	'ctx': manage_context,
	'rmctx': remove_context,
	'mv': move,
	'contexts': get_contexts,
	'history': get_history,
	'purge': purge,
	'search': search
}


def dispatch(args, daccess):
	if 'command' in args:
		return DISPATCHER[args['command']](args, daccess)
	# If no command, fallback to the todo handler
	return todo(args, daccess)


def get_options(args, mutators, converters={}):
	"""
	Returns a list of 2-tuple in the form (option, value) for all options
	contained in the `mutators` collection if they're also keys of the `args`
	and have a non-None value. If the option (non- prefixed) is also a key of
	the `converters` dictionary then the associated value should be another
	dictionary indicating convertions to be done on the value found in `args`.
	e.g.
	args = {'deadline': 'none'}
	mutators = {'deadline'}
	converters = {'deadline': {'none': None}}
	=> [('deadline', None)]
	"""
	options = []
	for mutator in mutators:
		if mutator in args and args[mutator] is not None:
			val = args[mutator]
			convertions = converters.get(mutator)
			if convertions is not None and val in convertions:
				val = convertions[val]
			options.append((mutator, val))
	return options


## FEEDBACK FUNCTIONS

TASK_SUBCTX_SEP = '-'*40


def feedback_add_task(id_):
	pass


def feedback_task_not_found(tid):
	print('Task {} not found'.format(utils.to_hex(tid)))


def feedback_cannot_edit(tid):
	print('Task {} is already being edited'.format(utils.to_hex(tid)))


def feedback_cannot_open_editor(editor):
	print('Cannot open editor: {}'.format(editor))


def feedback_multiple_tasks_update(not_found):
	if len(not_found) > 0:
		s = 's' if len(not_found) > 1 else ''
		string = ', '.join(utils.to_hex(tid) for tid in not_found)
		print('Task{} not found: {}'.format(s, string))


def feedback_multiple_tasks_done(not_found):
	if len(not_found) > 0:
		string = ', '.join(utils.to_hex(tid) for tid in not_found)
		print('Not found or already done: {}'.format(string))


def feedback_todo(context, tasks, subcontexts, highlight=None):
	layout = CONFIG.get('App', 'layout')
	if layout == 'multiline':
		stringyfier = get_multiline_task_string
	else:
		stringyfier = get_basic_task_string

	if len(tasks) != 0:
		id_width = max(len(utils.to_hex(task['id'])) for task in tasks)
	else:
		id_width = 1

	for task in tasks:
		partial = functools.partial(stringyfier, context, id_width, task,
			highlight=highlight)
		safe_print(partial)
	if len(subcontexts) > 0:
		print(TASK_SUBCTX_SEP)
	for ctx in subcontexts:
		partial = functools.partial(get_context_string, context, id_width, ctx)
		safe_print(partial)


def feedback_target_name_exists(renamed):
	print('Context already exists: {}'.format(
		utils.get_relative_path('', renamed)
		)
	)


def feedback_not_exists(ctx):
	print("Context does not exist: {}".format(
		utils.get_relative_path('', ctx)
		)
	)


def feedback_contexts(contexts):
	def get_tally(ctx):
		return '{} ({})'.format(ctx['total_tasks'], ctx['own_tasks'])
	struct = [
		('context', lambda a: a, '<', 'path', lambda a: a[1:]),
		('visibility', 10, '<', 'visibility', None),
		('priority', 8, '<', 'priority', None),
		('undone tasks', 12, '<', None, get_tally)
	]
	utils.print_table(struct, contexts, is_context_default)


def feedback_history(tasks, gid):
	if gid is None:
		print('No history.')
	else:
		struct = get_history_struct(gid)
		utils.print_table(struct, tasks, is_task_default)


def feedback_purge(count):
	s = 's' if count > 1 else ''
	print('{} task{} deleted'.format(count, s))


def feedback_show_task(task, full_content):
	print(cstr("     ID:", '6'), utils.to_hex(task['id']))
	print(cstr("Created:", '6'), utils.sqlite_date_to_local(task['created']))
	if task['start'] == task['created']:
		print(cstr("  Start:", '6'), "@created")
	else:
		print(cstr("  Start:", '6'), utils.sqlite_date_to_local(task['start']))
	print(
		cstr(" Status:", '6'),
		"DONE" if task['done'] is not None else "TODO"
	)

	def print_metaline(ascii_):
		c = get_task_string_components(task, '', ascii_, highlight=None)
		if task['done'] is None:
			stuff = ['deadline', 'priority', 'context']
		else:
			stuff = ['priority', 'context']
		metaline = ' '.join(c[a] for a in stuff if c[a] != '')
		if len(metaline) > 0:
			return ' ' + metaline
		else:
			return None

	safe_print(print_metaline)

	print(cstr('-'*utils.get_terminal_width(), '3'))
	print(full_content)


# String building for todo feedback

# Those functions return a string. They accept a boolean `ascii_` argument
# that indicates whether to build the returned string with ASCII characters
# only (True) or whether non-ASCII characters are allowed (False). Those
# functions will then be partially called with all arguments set except the
# `ascii_` one and the resulting partial will be passed to `safe_print` which
# will take care of trying to print the non-ASCII version and then fallback to
# the ASCII version in case of error from the terminal.

def get_basic_task_string(context, id_width, task, highlight=None, ascii_=False):
	c = get_task_string_components(task, context, ascii_, highlight=highlight)

	if isinstance(c['id'], ColoredStr):
		ansi_offset = c['id'].lenesc
	else:
		ansi_offset = 0
	result = ' {id:>{width}} | '.format(width=id_width + ansi_offset, **c)
	left_width = id_width + 4
	init_indent = left_width

	if len(c['done']):
		adding = c['done'] + ' '
		result += adding
		init_indent += len(DONE_STR) + 1 # [DONE] followed by space

	wrap_width = CONFIG.getint('Word-wrapping', 'width')
	if wrap_width == -1:
		wrap_width = utils.get_terminal_width()

	if CONFIG.getboolean('Word-wrapping', 'title'):
		title_subindent = ' '*left_width

		# The correct way to wrap would be to order textwrap to wrap the whole
		# ` {id} | {title}` with the subsequent indent being the length of `
		# {id} | `. However, {id} containing ANSI escape characters for
		# coloring will mess up textwrap character counting, so what we do
		# instead is wrapping only {title} prefixed with the length of ` {id}
		# | `, and we remove the prefix afterwards, ` {id} | ` taking its
		# place.

		lines = textwrap.wrap(
			' '*init_indent + c['title'],
			width=wrap_width,
			subsequent_indent=' '*left_width
		)
		lines[0] = lines[0][init_indent:]
	else:
		lines = [c['title']]

	len_last_line = len(lines[-1])
	title = '\n'.join(lines)

	start_title = len(result)
	result += title
	end_title = len(result)

	metadata = [c['deadline'], c['priority'], c['context']]
	metatext = ' '.join(stuff for stuff in metadata if stuff != '')

	if len(metatext) > 0:
		wrap_title = CONFIG.getboolean('Word-wrapping', 'title')
		not_enough_space = wrap_width - len_last_line <= 0
		if wrap_title and not_enough_space:
			result += '\n' + ' '*left_width
		else:
			result += ' '
		result += metatext

	return result


def get_multiline_task_string(context, id_width, task, highlight=None, ascii_=False):
	c = get_task_string_components(task, context, ascii_, highlight=highlight)
	template = ' {id} {done} / {deadline} {priority} {context}\n'
	result =  template.format(**c)

	wrap_width = CONFIG.getint('Word-wrapping', 'width')
	if wrap_width == -1:
		wrap_width = utils.get_terminal_width()
	title = c['title']
	if CONFIG.getboolean('Word-wrapping', 'title'):
		title = '\n'.join(textwrap.wrap(c['title'], width=wrap_width))
	result += title + '\n'
	return result


def get_task_string_components(task, ctx, ascii_=False, highlight=None):
	id_str = cstr(utils.to_hex(task['id']), clr('id'))

	if highlight is not None and CONFIG.getboolean('Colors', 'colors'):
		term, case = highlight
		content_str = utils.get_highlights_term(
			task['title'],
			term,
			(clr('content'), CONFIG.get('Colors', 'palette')),
			case=case
		)
	else:
		content_str = cstr(task['title'], clr('content'))

	remaining_str = ''
	deadline = get_datetime(task['deadline'])
	if deadline is not None:
		remaining = deadline - NOW
		user_friendly , isOvertime = utils.parse_remaining(remaining)
		remaining_str = '{} {} remaining'.format(
			TIME_ICON[ascii_],
			user_friendly
		)
		remaining_str = cstr(remaining_str, clr('overtime')) if isOvertime else cstr(remaining_str, clr('deadline'))

	prio_str = ''
	priority = task['priority']
	if not is_task_default(task, 'priority'):
		prio_str = '{}{}'.format(PRIORITY_ICON[ascii_], priority)
		prio_str = cstr(prio_str, clr('priority'))

	ctx_path = utils.get_relative_path(ctx, task['ctx_path'])
	if ctx_path == '':
		ctx_str = ''
	else:
		ctx_str = '{}{}'.format(CONTEXT_ICON[ascii_], ctx_path)
		ctx_str = cstr(ctx_str, clr('context'))

	done_str = ''
	if task['done'] is not None:
		done_str = DONE_STR
	if done_str != '':
		done_str = cstr(done_str, clr('done'))

	return {
		'id': id_str,
		'title': content_str,
		'deadline': remaining_str,
		'priority': prio_str,
		'context': ctx_str,
		'done': done_str
	}


def get_context_string(context, id_width, ctx, ascii_=False):
	hash_str = cstr('#', clr('id'))
	if isinstance(hash_str, ColoredStr):
		ansi_offset = hash_str.lenesc
	else:
		ansi_offset = 0
	path = utils.get_relative_path(context, ctx['path'])
	string = '{hash:>{width}} | {path} ({nbr})'.format(
		hash=hash_str,
		width=id_width + ansi_offset + 1,
		path=path,
		nbr=ctx['total_tasks']
	)
	priority = ctx['priority']
	if not is_task_default(ctx, 'priority'):
		prio_str = ' {}{}'.format(PRIORITY_ICON[ascii_], priority)
		string += cstr(prio_str, clr('priority'))
	return string


def safe_print(partial):
	try:
		result = partial(ascii_=False)
		if result is not None:
			print(result)
	except UnicodeEncodeError:
		result = partial(ascii_=True)
		if result is not None:
			print(result)


def get_datetime(db_dt):
	""" Get a datetime object from the string retrieved from the database."""
	if db_dt is None:
		return None
	return datetime\
		.strptime(db_dt, utils.SQLITE_DT_FORMAT)\
		.replace(tzinfo=timezone.utc)


def is_task_default(task, prop):
	if prop == 'start':
		return task['start'] == task['created']
	return is_default(task, prop, TASK_MUTATORS)


def is_context_default(ctx, prop):
	return is_default(ctx, prop, CONTEXT_MUTATORS)


def is_default(dico, prop, defaults):
	default = defaults.get(prop, None)
	if default is None:
		return False
	else:
		return dico[prop] == default


def get_history_struct(gid):
	gid_len = len(utils.to_hex(gid))
	struct = [
		('id', gid_len + 1, '>', 'id', utils.to_hex),
		('title', lambda a: 3 * (a//4), '<', 'title', None),
		('created', 19, '<', 'created', utils.sqlite_date_to_local),
	]
	if utils.get_terminal_width() > WIDE_HIST_THRESHOLD:
		struct += [
			('start', 19, '<', 'start', utils.sqlite_date_to_local),
			('deadline', 19, '<', 'deadline', utils.sqlite_date_to_local),
			('priority', 8, '>', 'priority', None)
		]
	struct += [
		('context', lambda a: a//4 + a%4, '<', 'ctx_path', lambda a: a[1:]),
		('status', 7, '<', 'done', lambda a: 'DONE' if a is not None else '')
	]
	return struct


def clr(component):
	return CONFIG.get('Colors', component)

#! /usr/bin/env python3 # Icons used to print tasks' properties in the terminal. # True is the ASCII version for challenged terminals. # False is the Unicode version. # Loading the config with the default config # Loading the user config. Will complete/overwrite the default config # but will keep default config entries that the user might have removed # Editor election: in config file? No -> in OS EDITOR variable? No -> vim # HANDLERS # Do something with the args dictionary and the data access object then return # a feedback code as well as some data about how things went. Feedback # functions (whose names are feedback_<feedback_code>) will then be passed the # data and should print some feedback based on the data. A handler can also # return nothing (or None) if no feedback is intended. # w3 = word-wrap width ## DISPATCHING # Map of the names of the commands to handlers defined above. # If no command, fallback to the todo handler Returns a list of 2-tuple in the form (option, value) for all options 	contained in the `mutators` collection if they're also keys of the `args` 	and have a non-None value. If the option (non- prefixed) is also a key of 	the `converters` dictionary then the associated value should be another 	dictionary indicating convertions to be done on the value found in `args`. 	e.g. 	args = {'deadline': 'none'} 	mutators = {'deadline'} 	converters = {'deadline': {'none': None}} 	=> [('deadline', None)] ## FEEDBACK FUNCTIONS # String building for todo feedback # Those functions return a string. They accept a boolean `ascii_` argument # that indicates whether to build the returned string with ASCII characters # only (True) or whether non-ASCII characters are allowed (False). Those # functions will then be partially called with all arguments set except the # `ascii_` one and the resulting partial will be passed to `safe_print` which # will take care of trying to print the non-ASCII version and then fallback to # the ASCII version in case of error from the terminal. # [DONE] followed by space # The correct way to wrap would be to order textwrap to wrap the whole # ` {id} | {title}` with the subsequent indent being the length of ` # {id} | `. However, {id} containing ANSI escape characters for # coloring will mess up textwrap character counting, so what we do # instead is wrapping only {title} prefixed with the length of ` {id} # | `, and we remove the prefix afterwards, ` {id} | ` taking its # place. Get a datetime object from the string retrieved from the database.