1.1 --- /dev/null	Thu Jan 01 00:00:00 1970 +0000
     1.2 +++ b/data/dflowlog.py	Fri Jun 04 13:48:28 2010 +0200
     1.3 @@ -0,0 +1,33 @@
     1.4 +import csv
     1.5 +
     1.6 +dflow_fields={"log_time": 0, "call_sign": 1, "adep": 2,
     1.7 +		"rwy": 3, "ades": 4, "etot": 5, "atot": 6, "flow_point": 7, 
     1.8 +		"flow_time": 8, "atd": 9}
     1.9 +
    1.10 +def parse_files(args):
    1.11 +	plans = []
    1.12 +	for file in args:
    1.13 +		reader = csv.reader(open(file, "rb"), delimiter=",", quoting=csv.QUOTE_NONE, quotechar="'")
    1.14 +		for row in reader:
    1.15 +			plans.append(row)
    1.16 +	return plans
    1.17 +
    1.18 +def parse_pipe(args):
    1.19 +	plans = []
    1.20 +	row = []
    1.21 +	input_str = "".join(args)
    1.22 +	values = input_str.split(",")
    1.23 +	for v in values:
    1.24 +		row.append(v)
    1.25 +		if len(row) == len(dflow_fields):
    1.26 +			plans.append(row)
    1.27 +			row = []
    1.28 +	return plans
    1.29 +
    1.30 +def print_logs(plans):
    1.31 +	plan_str = str()
    1.32 +	for plan in plans:
    1.33 +		if len(plan_str) > 0:
    1.34 +			plan_str += "\n"
    1.35 +		plan_str += ",".join(plan)
    1.36 +	print plan_str