sawine@0: import csv
sawine@0: 
sawine@0: dflow_fields={"log_time": 0, "call_sign": 1, "adep": 2,
sawine@0: 		"rwy": 3, "ades": 4, "etot": 5, "atot": 6, "flow_point": 7, 
sawine@0: 		"flow_time": 8, "atd": 9}
sawine@0: 
sawine@0: def parse_files(args):
sawine@0: 	plans = []
sawine@0: 	for file in args:
sawine@0: 		reader = csv.reader(open(file, "rb"), delimiter=",", quoting=csv.QUOTE_NONE, quotechar="'")
sawine@0: 		for row in reader:
sawine@0: 			plans.append(row)
sawine@0: 	return plans
sawine@0: 
sawine@0: def parse_pipe(args):
sawine@0: 	plans = []
sawine@0: 	row = []
sawine@0: 	input_str = "".join(args)
sawine@0: 	values = input_str.split(",")
sawine@0: 	for v in values:
sawine@0: 		row.append(v)
sawine@0: 		if len(row) == len(dflow_fields):
sawine@0: 			plans.append(row)
sawine@0: 			row = []
sawine@0: 	return plans
sawine@0: 
sawine@0: def print_logs(plans):
sawine@0: 	plan_str = str()
sawine@0: 	for plan in plans:
sawine@0: 		if len(plan_str) > 0:
sawine@0: 			plan_str += "\n"
sawine@0: 		plan_str += ",".join(plan)
sawine@0: 	print plan_str