#!/usr/bin/python2.4

#

# Univention Thin Client Flash status

#

# Copyright (C) 2011 Univention GmbH

#

# http://www.univention.de/

#

# All rights reserved.

#

# This program is free software; you can redistribute it and/or modify

# it under the terms of the GNU General Public License version 2 as

# published by the Free Software Foundation.

#

# Binary versions of this file provided by Univention to you as

# well as other copyrighted, protected or trademarked materials like

# Logos, graphics, fonts, specific documentations and configurations,

# cryptographic keys etc. are subject to a license agreement between

# you and Univention.

#

# This program is distributed in the hope that it will be useful,

# but WITHOUT ANY WARRANTY; without even the implied warranty of

# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.	See the

# GNU General Public License for more details.

#

# You should have received a copy of the GNU General Public License

# along with this program; if not, write to the Free Software

# Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA	 02110-1301	 USA

LOG_DIR = '/var/log/univention-thin-client-flash-status/'

DATE_FORMAT = '%Y-%m-%d %H:%M'

FORMAT = 'hostname,mac,ip,image,version,status,time'

import sys

import univention.config_registry

import csv

import time

import optparse

import gzip

import glob

# usage

usage = "usage: %prog [options]\n\n"

usage += "This program reads the thin-client status logs from\n"

usage += "%s*\n" % LOG_DIR

usage += "and prints the newest status line for each thin-client \n"

usage += "to stdout or into a tab separated csv file."

# options

parser = optparse.OptionParser(usage=usage)

parser.add_option("-o", "--output-file", dest="outFile", help="write status to csv file")

parser.add_option("-f", "--format", dest="format", help="output format, ,-separated list of elements time, hostname, mac, ip, domainname, nameserver, ldapserver, image, version, newversion, url, partition, rootpart, bootpart, status (default: %s)" % FORMAT)

parser.add_option("-d", "--date-format", dest="dateFormat", help="date format in output (default: %s)" % DATE_FORMAT)

parser.add_option("-i", "--input-directory", dest="directory", help="directory to look for *.log and *.gz log files (default: %s)" % LOG_DIR)

parser.add_option("-n", "--host-history", dest="hostname", help="show all log messages for HOSTNAME")

parser.set_defaults(format = FORMAT, dateFormat = DATE_FORMAT, directory = LOG_DIR)

options, args = parser.parse_args()

# output format

format = options.format.split(",")

# get files in log dir

files = glob.glob(options.directory + "/*.gz") + glob.glob(options.directory + "/*.log")

# open log and read data into data dict

data = {}

lineCounter = 0

for file in files:

	# open the log or gzip file

	try:

		if file.endswith(".gz"):

			fh = gzip.open(file, "rb")

		else:

			fh = open(file, "rb")

	except IOError, e:

		print e

		sys.exit(1)

	# read csv file line per line

	reader = csv.reader(fh, delimiter='\t', quotechar='|', quoting=csv.QUOTE_MINIMAL)

	for row in reader:

		# get key=value elements

		tmp = {}

		for element in row:

			keyValue = element.split("=", 1)

			if len(keyValue) >= 2:

				tmp[keyValue[0]] = keyValue[1]

		tmp["logfile"] = file

		hostname = tmp.get("hostname", "")

		if options.hostname:

			if options.hostname == hostname:

				hostname = hostname + str(lineCounter)

			else:

				continue

		# convert time

		if tmp.get("time", ""):

			tmp["time"] = time.strftime(options.dateFormat, time.localtime(float(tmp["time"])))

		# ignore entries without hostname and store data in data dict

		if hostname:

			data[hostname] = tmp

		lineCounter += 1

	fh.close()

if options.hostname:

	# sort entries by time (if time is not present ==> order is untouched)

	clients = data.items()

	clients.sort(lambda x,y: cmp(x[1].get('time'), y[1].get('time')))

	clients = [ x[0] for x in clients ]

else:

	# sort entries by hostname

	clients = sorted(data.keys())

# print output to csv file

if options.outFile:

	try:

		header = {}

		for e in format:

			header[e] = 1

		out = csv.DictWriter(open(options.outFile, 'wb'), 

				delimiter="\t", quotechar='|', 

				quoting=csv.QUOTE_MINIMAL, fieldnames=format)

	except IOError, e:

		print e

		sys.exit(1)

	# write header

	header = {}

	for i in format:

		header[i] = i

	out.writerow(header)

	# write data

	for client in clients:

		row = {}

		for element in format:

			row[element] = data[client].get(element, "None")

		out.writerow(row)

# print output to stdout

else:

	for client in clients:

		print "Hostname: " + data[client].get("hostname", "None")

		for element in format:

			print "\t" + element + ": " + data[client].get(element, "None")

/var/log/univention-thin-client-flash-status/*.log {

	weekly

	rotate 12

	create 640 www-data adm

	compress

	missingok

}

var/log/univention-thin-client-flash-status

etc/logrotate.d

touch /var/log/univention-thin-client-flash-status/thin-client-flash-status.log

chown www-data:adm /var/log/univention-thin-client-flash-status/thin-client-flash-status.log

univention-thin-client-flash (6.1.14-1) unstable; urgency=low

  * respect pxe/loglevel in tc's extlinux.conf Ticket: #2011030910000975 

 -- Felix Botner <botner@univention.de>  Thu, 18 Aug 2011 09:42:09 +0200

univention-thin-client-flash (6.1.13-1) unstable; urgency=low

  * fixed flashupdate script in initrd Ticket: #2011030710000906

 -- Felix Botner <botner@univention.de>  Wed, 17 Aug 2011 09:10:51 +0200

univention-thin-client-flash (6.1.12-1) unstable; urgency=low

  * stop usplash on flashupdate Ticket: #2011041210005499 

 -- Felix Botner <botner@univention.de>  Tue, 16 Aug 2011 11:32:04 +0200

univention-thin-client-flash (6.1.11-1) unstable; urgency=low

  * merged changes from customer scope Ticket: #2011041210005499

 -- Felix Botner <botner@univention.de>  Mon, 15 Aug 2011 16:09:40 +0200

univention-thin-client-flash (6.1.10-1) unstable; urgency=low

  * fixed flashupdate Ticket #2011030710000906 

 -- Felix Botner <botner@univention.de>  Thu, 14 Apr 2011 09:06:50 +0200

univention-thin-client-flash (6.1.9-1) unstable; urgency=low

  * fixed flashupdate.py Ticket #2011030710000906

 -- Felix Botner <botner@univention.de>  Wed, 13 Apr 2011 13:55:43 +0200

univention-thin-client-flash (6.1.8-1) unstable; urgency=low

  * fixed flashupdate.py and thin-client-flash-update Ticket

    #2011030710000906 

 -- Felix Botner <botner@univention.de>  Mon, 11 Apr 2011 14:49:32 +0200

univention-thin-client-flash (6.1.7-1) unstable; urgency=low

  * support multiple ldap server for thin clients 

    Ticket #2011030710000906

 -- Felix Botner <botner@univention.de>  Tue, 05 Apr 2011 15:12:09 +0200

univention-thin-client-flash (6.1.6-2) unstable; urgency=low

  * fixed last commit Ticket #2011030710000899

 -- Felix Botner <botner@univention.de>  Tue, 29 Mar 2011 10:55:08 +0200

univention-thin-client-flash (6.1.5-1) unstable; urgency=low

  * sort output in univention-thin-client-flash-status by time 

    Ticket #2011030710000899

 -- Felix Botner <botner@univention.de>  Tue, 29 Mar 2011 10:01:02 +0200

univention-thin-client-flash (6.1.4-1) unstable; urgency=low

  * added throtteling to flashstatus.py Ticket #2011030710000899

 -- Felix Botner <botner@univention.de>  Fri, 25 Mar 2011 09:36:26 +0100

univention-thin-client-flash (6.1.3-1) unstable; urgency=low

  * minor fix in thin-client-flash-update 

  * process all log files (*.gz and *.log) in

    log directory in univention-thin-client-flash-status

    Ticket #2011030710000899

 -- Felix Botner <botner@univention.de>  Wed, 23 Mar 2011 10:12:58 +0100

univention-thin-client-flash (6.1.2-1) unstable; urgency=low

  * minor fixes in thin-client-flash-update

  * removed redundant missingok from logrotate config

  * fixed element mapping in univention-thin-client-flash-status

    and flashstatus.py Ticket #2011030710000899

 -- Felix Botner <botner@univention.de>  Tue, 22 Mar 2011 15:24:16 +0100

univention-thin-client-flash (6.1.1-1) unstable; urgency=low

  * added -n|--host-history to univention-thin-client-flash-status 

    Ticket #2011030710000899

 -- Felix Botner <botner@univention.de>  Wed, 16 Mar 2011 15:31:08 +0100

univention-thin-client-flash (6.1.0-1) unstable; urgency=low

  * added thin client flash status log Ticket #2011030710000899

 -- Felix Botner <botner@univention.de>  Wed, 16 Mar 2011 14:16:41 +0100

	install -m 755 var/www/univention-thin-client-flash/flashstatus.py debian/univention-thin-client-flash/var/www/univention-thin-client-flash/

	install -m 755 univention-thin-client-flash-status debian/univention-thin-client-flash/usr/bin/

	chown root:adm debian/univention-thin-client-flash/var/log/univention-thin-client-flash-status

	cp debian/logrotate debian/univention-thin-client-flash/etc/logrotate.d/univention-thin-client-flash-status

elif [ -n "$oldLdapServer" -a "$oldLdapServer" != "$CMDLINE" ]; then

	server="$oldLdapServer"

	wget -O /tmp/flashupdate.sh http://$server_ip/univention-thin-client-flash/flashupdate.py?mac=$mac >>/dev/tty9 2>&1

	if [ -s /tmp/flashupdate.sh ]; then

		break

	fi

done

#!/bin/sh

encode_url ()

{

	echo "$1" | sed \

		-e 's/%/%25/g' \

		-e 's/ /%20/g' \

		-e 's/!/%21/g' \

		-e 's/"/%22/g' \

		-e 's/#/%23/g' \

		-e 's/\$/%24/g' \

		-e 's/\&/%26/g' \

		-e 's/'\''/%27/g' \

		-e 's/(/%28/g' \

		-e 's/)/%29/g' \

		-e 's/\*/%2a/g' \

		-e 's/+/%2b/g' \

		-e 's/,/%2c/g' \

		-e 's/-/%2d/g' \

		-e 's/\./%2e/g' \

		-e 's/\//%2f/g' \

		-e 's/:/%3a/g' \

		-e 's/;/%3b/g' \

		-e 's//%3e/g' \

		-e 's/?/%3f/g' \

		-e 's/@/%40/g' \

		-e 's/\[/%5b/g' \

		-e 's/\\/%5c/g' \

		-e 's/\]/%5d/g' \

		-e 's/\^/%5e/g' \

		-e 's/_/%5f/g' \

		-e 's/`/%60/g' \

		-e 's/{/%7b/g' \

		-e 's/|/%7c/g' \

		-e 's/}/%7d/g' \

		-e 's/~/%7e/g'

}

append_to_url ()

{

	local url="$1"

	local item="$2"

	local value="$3"

	local delim="$4"

	if [ -z "$delim" ]; then

		delim="&"

	fi

	if [ -z "$value" ]; then

		value=None

	fi

	if [ -n "$item" ]; then

		value=$(encode_url "$value")

		url="$url$delim$item=$value"

	fi

	echo "$url"

}

ALREADY_LOGGED=0

flash_status ()

{

	# to log or not to log ...

	case "$thinclient_flash_status_log" in

		0|no|off|false|disable|disabled) return 0;;

	esac

	# check if we already logged the status

	if [ $ALREADY_LOGGED -ne 0 ]; then

		return

	fi

	# $1 is the status of the thin client (up-to-dat, updated, installation failed, ...)

	local status=$1

	if [ -z "$status" ]; then

		status=unknown

	fi

	# collect data

	local mac=$(LC_ALL=C ifconfig eth0 | sed -n 's|.*HWaddr \([^ ]*\) .*|\1|p')

	local ip=$(LC_ALL=C ifconfig eth0|sed -n 's| *inet addr:\([^ ]*\) .*|\1|p')

	local uri="$url/flashstatus.py"

	# setup url

	uri=$(append_to_url "$uri" "mac" "$mac" "?")

	uri=$(append_to_url "$uri" "ip" "$ip")

	uri=$(append_to_url "$uri" "hostname" "$hostname")

	uri=$(append_to_url "$uri" "domainname" "$domainname")

	uri=$(append_to_url "$uri" "nameserver" "$nameserver")

	uri=$(append_to_url "$uri" "ldapserver" "$ldapserver")

	uri=$(append_to_url "$uri" "image" "$image")

	uri=$(append_to_url "$uri" "version" "$version")

	uri=$(append_to_url "$uri" "newversion" "$new_version")

	uri=$(append_to_url "$uri" "url" "$url")

	uri=$(append_to_url "$uri" "partition" "$partition")

	uri=$(append_to_url "$uri" "rootpart" "$rootpart")

	uri=$(append_to_url "$uri" "bootpart" "$bootpart")

	uri=$(append_to_url "$uri" "status" "$status")

	# do it

	wget -q -O - "$uri"

	ALREADY_LOGGED=1

}

	# log status

	flash_status "$1"

	usplash_write QUIT

	# is name a ip?

	ip="$(echo $thinclient_flash_server | sed -n 's|[0-9]*\.[0-9]*\.[0-9]*\.[0-9]*|'$thinclient_flash_server'|p')"

	if [ -n "$ip" ]; then

		thinclient_flash_server_ip="$thinclient_flash_server"

	else

		thinclient_flash_server_ip=$(host ${thinclient_flash_server} | sed -n "s|.* has address ||p")

	fi

			thinclient_flash_server_ip="$name"

	flash_status "image version not found"

	flash_status "up-to-date"

#!/usr/bin/python2.4

#

# Univention Thin Client Flash status logging

#

# Copyright (C) 2011 Univention GmbH

#

# http://www.univention.de/

#

# All rights reserved.

#

# This program is free software; you can redistribute it and/or modify

# it under the terms of the GNU General Public License version 2 as

# published by the Free Software Foundation.

#

# Binary versions of this file provided by Univention to you as

# well as other copyrighted, protected or trademarked materials like

# Logos, graphics, fonts, specific documentations and configurations,

# cryptographic keys etc. are subject to a license agreement between

# you and Univention.

#

# This program is distributed in the hope that it will be useful,

# but WITHOUT ANY WARRANTY; without even the implied warranty of

# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.	See the

# GNU General Public License for more details.

#

# You should have received a copy of the GNU General Public License

# along with this program; if not, write to the Free Software

# Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA	 02110-1301	 USA

LOG_FILENAME = '/var/log/univention-thin-client-flash-status/thin-client-flash-status.log'

ACCESS_DB = '/var/tmp/thin-client-flash-status.pickle'

ACCESS_DB_LOCK = '/var/tmp/thin-client-flash-status.pickle.lock'

LAST_SEEN_DIFF = 2

import sys

import cgi

import univention.config_registry

import csv

import time

import pickle

import os

import time

import fcntl

def updateAccessDb (access):

	# save access db

	output = open(ACCESS_DB, 'wb')

	pickle.dump(access, output)

	output.close()

print 'Content-type: text/plain'

print 

myTime = time.time()

myIp = os.environ.get("REMOTE_ADDR", "")

# do nothing if no remote address can be found

if not myIp:

	sys.exit(0)

# get lock

lockFile = open(ACCESS_DB_LOCK, 'wb')

fcntl.flock(lockFile.fileno(), fcntl.LOCK_EX)

# read access db into access dict

access = {}

try:

	input = open(ACCESS_DB, 'rb')

	access = pickle.load(input)

	input.close()

except Exception, e:

	pass

# check clients last access time

lastSeen = access.get(myIp, 0)

# ignore clients which accessed us in the last LAST_SEEN_DIFF seconds

# save timestamp for others

if lastSeen:

	if (myTime - lastSeen) <= LAST_SEEN_DIFF:

		sys.exit(0)

access[myIp] = myTime

# clean up access db

for client in access.keys():

	if (myTime - access[client]) > LAST_SEEN_DIFF:

		del access[client]

# get data

form = cgi.FieldStorage()

data = []

size = 0

for key in form.keys():

	tmp = key + "=" +form.getvalue(key)

	size += len(tmp)

	data.append(tmp)

# simple test to restrict the size of post

if size > 4096:

	updateAccessDb(access)

	sys.exit(0)

data.append("time=" + str(time.time()))

# write to log

log = csv.writer(open(LOG_FILENAME, 'ab'), delimiter="\t", quotechar='|', quoting=csv.QUOTE_MINIMAL)

log.writerow(data)

# update access db

updateAccessDb(access)

# release lock

lockFile.close()

			# hostname and domain

			# add flash script