#

# Copyright (c) 2008-2010 Nokia Corporation and/or its subsidiary(-ies).

# All rights reserved.

# This component and the accompanying materials are made available

# under the terms of the License "Eclipse Public License v1.0"

# which accompanies this distribution, and is available

# at the URL "http://www.eclipse.org/legal/epl-v10.html".

#

# Initial Contributors:

# Nokia Corporation - initial contribution.

#

# Contributors:

#

# Description: 

# Filter class for copying files in serial in python. This

# is important in cluster builds where file copying is 

# very inefficient.  

# The one-to-many <finalcopy> tag is searched for and copy

# instructions are built up in a hash table.

# <finalcopy source='sourcefilename'>destfilename1 destfilename2 . . . .destfilenameN</copy>

# destinations must be full filenames not directories.

#

# This filter monitors build progress

# via the <progress> tags and flushes copies as build 

# stages end (e.g. after resource so resources are ready for the next stage)

# 

import os

import sys

import tempfile

import filter_interface

import shutil

import generic_path

import stat

from raptor_utilities import copyfile

class FilterCopyFile(filter_interface.Filter):

	def open(self, params):

		"initialise"

		self.ok = True

		self.files = {}

		return self.ok

	def write(self, text):

		"process some log text"

		for line in text.splitlines():

			if line.startswith("<finalcopy"):

				source_start = line.find("source='")

				source = line[source_start+8:line.find("'", source_start+8)]

				destinations = line[line.find(">",source_start)+1:line.find("</finalcopy>")].split(" ")

				if source in self.files:

					self.files[source].update(destinations)

				else:

					self.files[source] = set(destinations)

			elif line.startswith("<progress:end object_type='makefile' task='build'"):

				self.flushcopies() # perform copies at end of each invocation of the make engine

						   # to ensure dependencies are in place for the next one.

		return self.ok

	def summary(self):

		"finish off"

		self.flushcopies()

		return self.ok

	def flushcopies(self):

		for source in self.files.keys():

			for dest in self.files[source]:

				try:

					copyfile(source, dest)

				except IOError, e:

					print "<error>%s</error>" % str(e)

		self.files = {}

	def close(self):

		"nop"

		return self.ok

# the end