Update imports to import portage.os (with unicode wrappers), and use

_unicode_encode() and _unicode_decode() where appropriate.

svn path=/main/trunk/; revision=13994

11 files changed, 27 insertions, 71 deletions

diff --git a/pym/_emerge/Package.py b/pym/_emerge/Package.py
index c2eaf0ee..96d5176e 100644
--- a/pym/_emerge/Package.py
+++ b/pym/_emerge/Package.py
@@ -4,15 +4,7 @@
 
 import re
 from itertools import chain
-
-try:
-	import portage
-except ImportError:
-	from os import path as osp
-	import sys
-	sys.path.insert(0, osp.join(osp.dirname(osp.dirname(osp.realpath(__file__))), "pym"))
-	import portage
-
+import portage
 from portage.cache.mappings import slot_dict_class
 from portage.dep import paren_reduce, use_reduce, \
 	paren_normalize, paren_enclose
diff --git a/pym/_emerge/PackageArg.py b/pym/_emerge/PackageArg.py
index 0813442f..f64430e1 100644
--- a/pym/_emerge/PackageArg.py
+++ b/pym/_emerge/PackageArg.py
@@ -3,17 +3,11 @@
 # $Id$
 
 from _emerge.DependencyArg import DependencyArg
-try:
-	import portage
-except ImportError:
-	from os import path as osp
-	import sys
-	sys.path.insert(0, osp.join(osp.dirname(osp.dirname(osp.realpath(__file__))), "pym"))
-	import portage
+import portage
+
 class PackageArg(DependencyArg):
 	def __init__(self, package=None, **kwargs):
 		DependencyArg.__init__(self, **kwargs)
 		self.package = package
 		self.atom = portage.dep.Atom("=" + package.cpv)
 		self.set = (self.atom, )
-
diff --git a/pym/_emerge/PackageUninstall.py b/pym/_emerge/PackageUninstall.py
index 948bae82..ff1b5e18 100644
--- a/pym/_emerge/PackageUninstall.py
+++ b/pym/_emerge/PackageUninstall.py
@@ -4,16 +4,8 @@
 
 import codecs
 import logging
-import os
-
-try:
-	import portage
-except ImportError:
-	from os import path as osp
-	import sys
-	sys.path.insert(0, osp.join(osp.dirname(osp.dirname(osp.realpath(__file__))), "pym"))
-	import portage
-
+import portage
+from portage import os
 from _emerge.AsynchronousTask import AsynchronousTask
 from _emerge.unmerge import unmerge
 from _emerge.UninstallFailure import UninstallFailure
diff --git a/pym/_emerge/PackageVirtualDbapi.py b/pym/_emerge/PackageVirtualDbapi.py
index 86d150fa..f041e1d8 100644
--- a/pym/_emerge/PackageVirtualDbapi.py
+++ b/pym/_emerge/PackageVirtualDbapi.py
@@ -2,13 +2,8 @@
 # Distributed under the terms of the GNU General Public License v2
 # $Id$
 
-try:
-	import portage
-except ImportError:
-	from os import path as osp
-	import sys
-	sys.path.insert(0, osp.join(osp.dirname(osp.dirname(osp.realpath(__file__))), "pym"))
-	import portage
+import portage
+
 class PackageVirtualDbapi(portage.dbapi):
 	"""
 	A dbapi-like interface class that represents the state of the installed
diff --git a/pym/_emerge/PipeReader.py b/pym/_emerge/PipeReader.py
index d3cc1842..5b64306e 100644
--- a/pym/_emerge/PipeReader.py
+++ b/pym/_emerge/PipeReader.py
@@ -2,12 +2,13 @@
 # Distributed under the terms of the GNU General Public License v2
 # $Id$
 
+from portage import os
 from _emerge.AbstractPollTask import AbstractPollTask
 from _emerge.PollConstants import PollConstants
 import sys
-import os
 import fcntl
 import array
+
 class PipeReader(AbstractPollTask):
 
 	"""
diff --git a/pym/_emerge/RepoDisplay.py b/pym/_emerge/RepoDisplay.py
index 42056977..a954aebf 100644
--- a/pym/_emerge/RepoDisplay.py
+++ b/pym/_emerge/RepoDisplay.py
@@ -3,7 +3,8 @@
 # $Id$
 
 from portage.output import teal
-import os
+from portage import os
+
 class RepoDisplay(object):
 	def __init__(self, roots):
 		self._shown_repos = {}
diff --git a/pym/_emerge/Scheduler.py b/pym/_emerge/Scheduler.py
index ec6135d3..cef4ee6c 100644
--- a/pym/_emerge/Scheduler.py
+++ b/pym/_emerge/Scheduler.py
@@ -4,20 +4,13 @@
 
 import codecs
 import logging
-import os
 import sys
 import textwrap
 import time
 import weakref
 from itertools import izip
-
-try:
-	import portage
-except ImportError:
-	from os import path as osp
-	sys.path.insert(0, osp.join(osp.dirname(osp.dirname(osp.realpath(__file__))), "pym"))
-	import portage
-
+import portage
+from portage import os
 from portage.cache.mappings import slot_dict_class
 from portage.elog.messages import eerror
 from portage.output import colorize, create_color_func, darkgreen, red
@@ -478,13 +471,10 @@ class Scheduler(PollScheduler):
 
 	def _append_to_log_path(self, log_path, msg):
 
-		if not isinstance(msg, unicode):
-			msg = unicode(msg, encoding='utf_8', errors='replace')
-
-		f = codecs.open(log_path, mode='a',
+		f = codecs.open(portage._unicode_encode(log_path), mode='a',
 			encoding='utf_8', errors='replace')
 		try:
-			f.write(msg)
+			f.write(portage._unicode_decode(msg))
 		finally:
 			f.close()
 
@@ -496,7 +486,7 @@ class Scheduler(PollScheduler):
 		background = self._background
 
 		if background and log_path is not None:
-			log_file = codecs.open(log_path, mode='a',
+			log_file = codecs.open(portage._unicode_encode(log_path), mode='a',
 				encoding='utf_8', errors='replace')
 			out = log_file
 
@@ -872,8 +862,8 @@ class Scheduler(PollScheduler):
 			log_path = self._locate_failure_log(failed_pkg)
 			if log_path is not None:
 				try:
-					log_file = codecs.open(log_path, mode='r',
-						encoding='utf_8', errors='replace')
+					log_file = codecs.open(portage._unicode_encode(log_path),
+						mode='r', encoding='utf_8', errors='replace')
 				except IOError:
 					pass
 
diff --git a/pym/_emerge/SpawnProcess.py b/pym/_emerge/SpawnProcess.py
index 4c6065ed..e6b3cc7a 100644
--- a/pym/_emerge/SpawnProcess.py
+++ b/pym/_emerge/SpawnProcess.py
@@ -6,17 +6,12 @@ from _emerge.SubProcess import SubProcess
 from _emerge.PollConstants import PollConstants
 import sys
 from portage.cache.mappings import slot_dict_class
-try:
-	import portage
-except ImportError:
-	from os import path as osp
-	import sys
-	sys.path.insert(0, osp.join(osp.dirname(osp.dirname(osp.realpath(__file__))), "pym"))
-	import portage
-import os
+import portage
+from portage import os
 import fcntl
 import errno
 import array
+
 class SpawnProcess(SubProcess):
 
 	"""
diff --git a/pym/_emerge/SubProcess.py b/pym/_emerge/SubProcess.py
index 37957c39..6bd4562d 100644
--- a/pym/_emerge/SubProcess.py
+++ b/pym/_emerge/SubProcess.py
@@ -2,10 +2,11 @@
 # Distributed under the terms of the GNU General Public License v2
 # $Id$
 
+from portage import os
 from _emerge.AbstractPollTask import AbstractPollTask
 import signal
-import os
 import errno
+
 class SubProcess(AbstractPollTask):
 
 	__slots__ = ("pid",) + \
diff --git a/pym/_emerge/TaskSequence.py b/pym/_emerge/TaskSequence.py
index 3d54d90a..44eaa332 100644
--- a/pym/_emerge/TaskSequence.py
+++ b/pym/_emerge/TaskSequence.py
@@ -2,10 +2,11 @@
 # Distributed under the terms of the GNU General Public License v2
 # $Id$
 
+from portage import os
 from _emerge.CompositeTask import CompositeTask
 from _emerge.AsynchronousTask import AsynchronousTask
-import os
 from collections import deque
+
 class TaskSequence(CompositeTask):
 	"""
 	A collection of tasks that executes sequentially. Each task
diff --git a/pym/_emerge/UninstallFailure.py b/pym/_emerge/UninstallFailure.py
index 7dbf1c1c..ceb5a58e 100644
--- a/pym/_emerge/UninstallFailure.py
+++ b/pym/_emerge/UninstallFailure.py
@@ -2,14 +2,8 @@
 # Distributed under the terms of the GNU General Public License v2
 # $Id$
 
-try:
-	import portage
-except ImportError:
-	from os import path as osp
-	import sys
-	sys.path.insert(0, osp.join(osp.dirname(osp.dirname(osp.realpath(__file__))), "pym"))
-	import portage
-	
+import portage
+
 class UninstallFailure(portage.exception.PortageException):
 	"""
 	An instance of this class is raised by unmerge() when