Merge pull request #1076 from mwhudson/core20-cleanups
remove stdlib backports from Python 3.8
This commit is contained in:
commit
3c32cb773c
2
Makefile
2
Makefile
|
@ -66,7 +66,7 @@ lint: flake8
|
||||||
|
|
||||||
flake8:
|
flake8:
|
||||||
@echo 'tox -e flake8' is preferred to 'make flake8'
|
@echo 'tox -e flake8' is preferred to 'make flake8'
|
||||||
$(PYTHON) -m flake8 $(CHECK_DIRS) --exclude gettext38.py,contextlib38.py
|
$(PYTHON) -m flake8 $(CHECK_DIRS)
|
||||||
|
|
||||||
unit: gitdeps
|
unit: gitdeps
|
||||||
python3 -m pytest --ignore curtin --ignore probert \
|
python3 -m pytest --ignore curtin --ignore probert \
|
||||||
|
|
|
@ -48,7 +48,6 @@ subiquity/common/tests/__init__.py
|
||||||
subiquity/common/tests/test_serialization.py
|
subiquity/common/tests/test_serialization.py
|
||||||
subiquity/common/types.py
|
subiquity/common/types.py
|
||||||
subiquitycore/async_helpers.py
|
subiquitycore/async_helpers.py
|
||||||
subiquitycore/contextlib38.py
|
|
||||||
subiquitycore/context.py
|
subiquitycore/context.py
|
||||||
subiquitycore/controller.py
|
subiquitycore/controller.py
|
||||||
subiquitycore/controllerset.py
|
subiquitycore/controllerset.py
|
||||||
|
@ -56,7 +55,6 @@ subiquitycore/controllers/__init__.py
|
||||||
subiquitycore/controllers/network.py
|
subiquitycore/controllers/network.py
|
||||||
subiquitycore/core.py
|
subiquitycore/core.py
|
||||||
subiquitycore/file_util.py
|
subiquitycore/file_util.py
|
||||||
subiquitycore/gettext38.py
|
|
||||||
subiquitycore/i18n.py
|
subiquitycore/i18n.py
|
||||||
subiquitycore/__init__.py
|
subiquitycore/__init__.py
|
||||||
subiquitycore/log.py
|
subiquitycore/log.py
|
||||||
|
|
|
@ -13,12 +13,11 @@
|
||||||
# You should have received a copy of the GNU Affero General Public License
|
# You should have received a copy of the GNU Affero General Public License
|
||||||
# along with this program. If not, see <http://www.gnu.org/licenses/>.
|
# along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||||
|
|
||||||
|
import contextlib
|
||||||
import inspect
|
import inspect
|
||||||
|
|
||||||
import aiohttp
|
import aiohttp
|
||||||
|
|
||||||
from subiquitycore import contextlib38
|
|
||||||
|
|
||||||
from subiquity.common.serialize import Serializer
|
from subiquity.common.serialize import Serializer
|
||||||
from .defs import Payload
|
from .defs import Payload
|
||||||
|
|
||||||
|
@ -72,7 +71,7 @@ def make_client_for_conn(
|
||||||
session = aiohttp.ClientSession(
|
session = aiohttp.ClientSession(
|
||||||
connector=conn, connector_owner=False)
|
connector=conn, connector_owner=False)
|
||||||
|
|
||||||
@contextlib38.asynccontextmanager
|
@contextlib.asynccontextmanager
|
||||||
async def make_request(method, path, *, params, json):
|
async def make_request(method, path, *, params, json):
|
||||||
# session.request needs a full URL with scheme and host even though
|
# session.request needs a full URL with scheme and host even though
|
||||||
# that's in some ways a bit silly with a unix socket, so we just
|
# that's in some ways a bit silly with a unix socket, so we just
|
||||||
|
|
|
@ -13,10 +13,9 @@
|
||||||
# You should have received a copy of the GNU Affero General Public License
|
# You should have received a copy of the GNU Affero General Public License
|
||||||
# along with this program. If not, see <http://www.gnu.org/licenses/>.
|
# along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||||
|
|
||||||
|
import contextlib
|
||||||
import unittest
|
import unittest
|
||||||
|
|
||||||
from subiquitycore import contextlib38
|
|
||||||
|
|
||||||
from subiquity.common.api.client import make_client
|
from subiquity.common.api.client import make_client
|
||||||
from subiquity.common.api.defs import api, Payload
|
from subiquity.common.api.defs import api, Payload
|
||||||
|
|
||||||
|
@ -51,7 +50,7 @@ class TestClient(unittest.TestCase):
|
||||||
def GET() -> str: ...
|
def GET() -> str: ...
|
||||||
def POST(data: Payload[str]) -> None: ...
|
def POST(data: Payload[str]) -> None: ...
|
||||||
|
|
||||||
@contextlib38.asynccontextmanager
|
@contextlib.asynccontextmanager
|
||||||
async def make_request(method, path, *, params, json):
|
async def make_request(method, path, *, params, json):
|
||||||
requests.append((method, path, params, json))
|
requests.append((method, path, params, json))
|
||||||
if method == "GET":
|
if method == "GET":
|
||||||
|
@ -79,7 +78,7 @@ class TestClient(unittest.TestCase):
|
||||||
class API:
|
class API:
|
||||||
def GET(arg: str) -> str: ...
|
def GET(arg: str) -> str: ...
|
||||||
|
|
||||||
@contextlib38.asynccontextmanager
|
@contextlib.asynccontextmanager
|
||||||
async def make_request(method, path, *, params, json):
|
async def make_request(method, path, *, params, json):
|
||||||
requests.append((method, path, params, json))
|
requests.append((method, path, params, json))
|
||||||
yield FakeResponse(params['arg'])
|
yield FakeResponse(params['arg'])
|
||||||
|
|
|
@ -14,13 +14,13 @@
|
||||||
# along with this program. If not, see <http://www.gnu.org/licenses/>.
|
# along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||||
|
|
||||||
import attr
|
import attr
|
||||||
|
import contextlib
|
||||||
import functools
|
import functools
|
||||||
import unittest
|
import unittest
|
||||||
|
|
||||||
import aiohttp
|
import aiohttp
|
||||||
from aiohttp import web
|
from aiohttp import web
|
||||||
|
|
||||||
from subiquitycore import contextlib38
|
|
||||||
from subiquitycore.tests.util import run_coro
|
from subiquitycore.tests.util import run_coro
|
||||||
|
|
||||||
from subiquity.common.api.client import make_client
|
from subiquity.common.api.client import make_client
|
||||||
|
@ -37,7 +37,7 @@ def make_request(client, method, path, *, params, json):
|
||||||
method, path, params=params, json=json)
|
method, path, params=params, json=json)
|
||||||
|
|
||||||
|
|
||||||
@contextlib38.asynccontextmanager
|
@contextlib.asynccontextmanager
|
||||||
async def makeE2EClient(api, impl,
|
async def makeE2EClient(api, impl,
|
||||||
*, middlewares=(), make_request=make_request):
|
*, middlewares=(), make_request=make_request):
|
||||||
async with makeTestClient(
|
async with makeTestClient(
|
||||||
|
@ -174,7 +174,7 @@ class TestEndToEnd(unittest.TestCase):
|
||||||
class Skip(Exception):
|
class Skip(Exception):
|
||||||
pass
|
pass
|
||||||
|
|
||||||
@contextlib38.asynccontextmanager
|
@contextlib.asynccontextmanager
|
||||||
async def custom_make_request(client, method, path, *, params, json):
|
async def custom_make_request(client, method, path, *, params, json):
|
||||||
async with make_request(
|
async with make_request(
|
||||||
client, method, path, params=params, json=json) as resp:
|
client, method, path, params=params, json=json) as resp:
|
||||||
|
@ -243,7 +243,7 @@ class TestEndToEnd(unittest.TestCase):
|
||||||
class Abort(Exception):
|
class Abort(Exception):
|
||||||
pass
|
pass
|
||||||
|
|
||||||
@contextlib38.asynccontextmanager
|
@contextlib.asynccontextmanager
|
||||||
async def custom_make_request(client, method, path, *, params, json):
|
async def custom_make_request(client, method, path, *, params, json):
|
||||||
async with make_request(
|
async with make_request(
|
||||||
client, method, path, params=params, json=json) as resp:
|
client, method, path, params=params, json=json) as resp:
|
||||||
|
|
|
@ -13,6 +13,7 @@
|
||||||
# You should have received a copy of the GNU Affero General Public License
|
# You should have received a copy of the GNU Affero General Public License
|
||||||
# along with this program. If not, see <http://www.gnu.org/licenses/>.
|
# along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||||
|
|
||||||
|
import contextlib
|
||||||
import unittest
|
import unittest
|
||||||
|
|
||||||
from aiohttp.test_utils import TestClient, TestServer
|
from aiohttp.test_utils import TestClient, TestServer
|
||||||
|
@ -20,7 +21,6 @@ from aiohttp import web
|
||||||
|
|
||||||
from subiquitycore.context import Context
|
from subiquitycore.context import Context
|
||||||
from subiquitycore.tests.util import run_coro
|
from subiquitycore.tests.util import run_coro
|
||||||
from subiquitycore import contextlib38
|
|
||||||
|
|
||||||
from subiquity.common.api.defs import api, Payload
|
from subiquity.common.api.defs import api, Payload
|
||||||
from subiquity.common.api.server import (
|
from subiquity.common.api.server import (
|
||||||
|
@ -48,7 +48,7 @@ class TestControllerBase:
|
||||||
self.context = Context.new(TestApp())
|
self.context = Context.new(TestApp())
|
||||||
|
|
||||||
|
|
||||||
@contextlib38.asynccontextmanager
|
@contextlib.asynccontextmanager
|
||||||
async def makeTestClient(api, impl, middlewares=()):
|
async def makeTestClient(api, impl, middlewares=()):
|
||||||
app = web.Application(middlewares=middlewares)
|
app = web.Application(middlewares=middlewares)
|
||||||
bind(app.router, api, impl)
|
bind(app.router, api, impl)
|
||||||
|
|
|
@ -15,8 +15,7 @@
|
||||||
|
|
||||||
import enum
|
import enum
|
||||||
import functools
|
import functools
|
||||||
|
from gettext import pgettext
|
||||||
from subiquitycore.gettext38 import pgettext
|
|
||||||
|
|
||||||
from subiquity.common.filesystem import boot, labels
|
from subiquity.common.filesystem import boot, labels
|
||||||
from subiquity.models.filesystem import (
|
from subiquity.models.filesystem import (
|
||||||
|
|
|
@ -13,9 +13,9 @@
|
||||||
# You should have received a copy of the GNU Affero General Public License
|
# You should have received a copy of the GNU Affero General Public License
|
||||||
# along with this program. If not, see <http://www.gnu.org/licenses/>.
|
# along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||||
|
|
||||||
from systemd import journal
|
import contextlib
|
||||||
|
|
||||||
from subiquitycore import contextlib38
|
from systemd import journal
|
||||||
|
|
||||||
|
|
||||||
def journald_listen(loop, identifiers, callback, seek=False):
|
def journald_listen(loop, identifiers, callback, seek=False):
|
||||||
|
@ -37,7 +37,7 @@ def journald_listen(loop, identifiers, callback, seek=False):
|
||||||
return reader.fileno()
|
return reader.fileno()
|
||||||
|
|
||||||
|
|
||||||
@contextlib38.contextmanager
|
@contextlib.contextmanager
|
||||||
def journald_subscriptions(loop, ids_callbacks):
|
def journald_subscriptions(loop, ids_callbacks):
|
||||||
fds = set()
|
fds = set()
|
||||||
for id, callback in ids_callbacks:
|
for id, callback in ids_callbacks:
|
||||||
|
|
|
@ -13,10 +13,11 @@
|
||||||
# You should have received a copy of the GNU Affero General Public License
|
# You should have received a copy of the GNU Affero General Public License
|
||||||
# along with this program. If not, see <http://www.gnu.org/licenses/>.
|
# along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||||
|
|
||||||
|
from gettext import ngettext
|
||||||
import logging
|
import logging
|
||||||
|
|
||||||
from urwid import Text
|
from urwid import Text
|
||||||
|
|
||||||
from subiquitycore.gettext38 import ngettext
|
|
||||||
from subiquitycore.ui.buttons import danger_btn, other_btn
|
from subiquitycore.ui.buttons import danger_btn, other_btn
|
||||||
from subiquitycore.ui.table import (
|
from subiquitycore.ui.table import (
|
||||||
TablePile,
|
TablePile,
|
||||||
|
|
|
@ -1,704 +0,0 @@
|
||||||
"""Utilities for with-statement contexts. See PEP 343."""
|
|
||||||
import abc
|
|
||||||
import sys
|
|
||||||
import _collections_abc
|
|
||||||
from collections import deque
|
|
||||||
from functools import wraps
|
|
||||||
from types import MethodType
|
|
||||||
|
|
||||||
__all__ = ["asynccontextmanager", "contextmanager", "closing", "nullcontext",
|
|
||||||
"AbstractContextManager", "AbstractAsyncContextManager",
|
|
||||||
"AsyncExitStack", "ContextDecorator", "ExitStack",
|
|
||||||
"redirect_stdout", "redirect_stderr", "suppress"]
|
|
||||||
|
|
||||||
|
|
||||||
class AbstractContextManager(abc.ABC):
|
|
||||||
|
|
||||||
"""An abstract base class for context managers."""
|
|
||||||
|
|
||||||
def __enter__(self):
|
|
||||||
"""Return `self` upon entering the runtime context."""
|
|
||||||
return self
|
|
||||||
|
|
||||||
@abc.abstractmethod
|
|
||||||
def __exit__(self, exc_type, exc_value, traceback):
|
|
||||||
"""Raise any exception triggered within the runtime context."""
|
|
||||||
return None
|
|
||||||
|
|
||||||
@classmethod
|
|
||||||
def __subclasshook__(cls, C):
|
|
||||||
if cls is AbstractContextManager:
|
|
||||||
return _collections_abc._check_methods(C, "__enter__", "__exit__")
|
|
||||||
return NotImplemented
|
|
||||||
|
|
||||||
|
|
||||||
class AbstractAsyncContextManager(abc.ABC):
|
|
||||||
|
|
||||||
"""An abstract base class for asynchronous context managers."""
|
|
||||||
|
|
||||||
async def __aenter__(self):
|
|
||||||
"""Return `self` upon entering the runtime context."""
|
|
||||||
return self
|
|
||||||
|
|
||||||
@abc.abstractmethod
|
|
||||||
async def __aexit__(self, exc_type, exc_value, traceback):
|
|
||||||
"""Raise any exception triggered within the runtime context."""
|
|
||||||
return None
|
|
||||||
|
|
||||||
@classmethod
|
|
||||||
def __subclasshook__(cls, C):
|
|
||||||
if cls is AbstractAsyncContextManager:
|
|
||||||
return _collections_abc._check_methods(C, "__aenter__",
|
|
||||||
"__aexit__")
|
|
||||||
return NotImplemented
|
|
||||||
|
|
||||||
|
|
||||||
class ContextDecorator(object):
|
|
||||||
"A base class or mixin that enables context managers to work as decorators."
|
|
||||||
|
|
||||||
def _recreate_cm(self):
|
|
||||||
"""Return a recreated instance of self.
|
|
||||||
|
|
||||||
Allows an otherwise one-shot context manager like
|
|
||||||
_GeneratorContextManager to support use as
|
|
||||||
a decorator via implicit recreation.
|
|
||||||
|
|
||||||
This is a private interface just for _GeneratorContextManager.
|
|
||||||
See issue #11647 for details.
|
|
||||||
"""
|
|
||||||
return self
|
|
||||||
|
|
||||||
def __call__(self, func):
|
|
||||||
@wraps(func)
|
|
||||||
def inner(*args, **kwds):
|
|
||||||
with self._recreate_cm():
|
|
||||||
return func(*args, **kwds)
|
|
||||||
return inner
|
|
||||||
|
|
||||||
|
|
||||||
class _GeneratorContextManagerBase:
|
|
||||||
"""Shared functionality for @contextmanager and @asynccontextmanager."""
|
|
||||||
|
|
||||||
def __init__(self, func, args, kwds):
|
|
||||||
self.gen = func(*args, **kwds)
|
|
||||||
self.func, self.args, self.kwds = func, args, kwds
|
|
||||||
# Issue 19330: ensure context manager instances have good docstrings
|
|
||||||
doc = getattr(func, "__doc__", None)
|
|
||||||
if doc is None:
|
|
||||||
doc = type(self).__doc__
|
|
||||||
self.__doc__ = doc
|
|
||||||
# Unfortunately, this still doesn't provide good help output when
|
|
||||||
# inspecting the created context manager instances, since pydoc
|
|
||||||
# currently bypasses the instance docstring and shows the docstring
|
|
||||||
# for the class instead.
|
|
||||||
# See http://bugs.python.org/issue19404 for more details.
|
|
||||||
|
|
||||||
|
|
||||||
class _GeneratorContextManager(_GeneratorContextManagerBase,
|
|
||||||
AbstractContextManager,
|
|
||||||
ContextDecorator):
|
|
||||||
"""Helper for @contextmanager decorator."""
|
|
||||||
|
|
||||||
def _recreate_cm(self):
|
|
||||||
# _GCM instances are one-shot context managers, so the
|
|
||||||
# CM must be recreated each time a decorated function is
|
|
||||||
# called
|
|
||||||
return self.__class__(self.func, self.args, self.kwds)
|
|
||||||
|
|
||||||
def __enter__(self):
|
|
||||||
# do not keep args and kwds alive unnecessarily
|
|
||||||
# they are only needed for recreation, which is not possible anymore
|
|
||||||
del self.args, self.kwds, self.func
|
|
||||||
try:
|
|
||||||
return next(self.gen)
|
|
||||||
except StopIteration:
|
|
||||||
raise RuntimeError("generator didn't yield") from None
|
|
||||||
|
|
||||||
def __exit__(self, type, value, traceback):
|
|
||||||
if type is None:
|
|
||||||
try:
|
|
||||||
next(self.gen)
|
|
||||||
except StopIteration:
|
|
||||||
return False
|
|
||||||
else:
|
|
||||||
raise RuntimeError("generator didn't stop")
|
|
||||||
else:
|
|
||||||
if value is None:
|
|
||||||
# Need to force instantiation so we can reliably
|
|
||||||
# tell if we get the same exception back
|
|
||||||
value = type()
|
|
||||||
try:
|
|
||||||
self.gen.throw(type, value, traceback)
|
|
||||||
except StopIteration as exc:
|
|
||||||
# Suppress StopIteration *unless* it's the same exception that
|
|
||||||
# was passed to throw(). This prevents a StopIteration
|
|
||||||
# raised inside the "with" statement from being suppressed.
|
|
||||||
return exc is not value
|
|
||||||
except RuntimeError as exc:
|
|
||||||
# Don't re-raise the passed in exception. (issue27122)
|
|
||||||
if exc is value:
|
|
||||||
return False
|
|
||||||
# Likewise, avoid suppressing if a StopIteration exception
|
|
||||||
# was passed to throw() and later wrapped into a RuntimeError
|
|
||||||
# (see PEP 479).
|
|
||||||
if type is StopIteration and exc.__cause__ is value:
|
|
||||||
return False
|
|
||||||
raise
|
|
||||||
except:
|
|
||||||
# only re-raise if it's *not* the exception that was
|
|
||||||
# passed to throw(), because __exit__() must not raise
|
|
||||||
# an exception unless __exit__() itself failed. But throw()
|
|
||||||
# has to raise the exception to signal propagation, so this
|
|
||||||
# fixes the impedance mismatch between the throw() protocol
|
|
||||||
# and the __exit__() protocol.
|
|
||||||
#
|
|
||||||
# This cannot use 'except BaseException as exc' (as in the
|
|
||||||
# async implementation) to maintain compatibility with
|
|
||||||
# Python 2, where old-style class exceptions are not caught
|
|
||||||
# by 'except BaseException'.
|
|
||||||
if sys.exc_info()[1] is value:
|
|
||||||
return False
|
|
||||||
raise
|
|
||||||
raise RuntimeError("generator didn't stop after throw()")
|
|
||||||
|
|
||||||
|
|
||||||
class _AsyncGeneratorContextManager(_GeneratorContextManagerBase,
|
|
||||||
AbstractAsyncContextManager):
|
|
||||||
"""Helper for @asynccontextmanager."""
|
|
||||||
|
|
||||||
async def __aenter__(self):
|
|
||||||
try:
|
|
||||||
return await self.gen.__anext__()
|
|
||||||
except StopAsyncIteration:
|
|
||||||
raise RuntimeError("generator didn't yield") from None
|
|
||||||
|
|
||||||
async def __aexit__(self, typ, value, traceback):
|
|
||||||
if typ is None:
|
|
||||||
try:
|
|
||||||
await self.gen.__anext__()
|
|
||||||
except StopAsyncIteration:
|
|
||||||
return
|
|
||||||
else:
|
|
||||||
raise RuntimeError("generator didn't stop")
|
|
||||||
else:
|
|
||||||
if value is None:
|
|
||||||
value = typ()
|
|
||||||
# See _GeneratorContextManager.__exit__ for comments on subtleties
|
|
||||||
# in this implementation
|
|
||||||
try:
|
|
||||||
await self.gen.athrow(typ, value, traceback)
|
|
||||||
raise RuntimeError("generator didn't stop after athrow()")
|
|
||||||
except StopAsyncIteration as exc:
|
|
||||||
return exc is not value
|
|
||||||
except RuntimeError as exc:
|
|
||||||
if exc is value:
|
|
||||||
return False
|
|
||||||
# Avoid suppressing if a StopIteration exception
|
|
||||||
# was passed to throw() and later wrapped into a RuntimeError
|
|
||||||
# (see PEP 479 for sync generators; async generators also
|
|
||||||
# have this behavior). But do this only if the exception wrapped
|
|
||||||
# by the RuntimeError is actully Stop(Async)Iteration (see
|
|
||||||
# issue29692).
|
|
||||||
if isinstance(value, (StopIteration, StopAsyncIteration)):
|
|
||||||
if exc.__cause__ is value:
|
|
||||||
return False
|
|
||||||
raise
|
|
||||||
except BaseException as exc:
|
|
||||||
if exc is not value:
|
|
||||||
raise
|
|
||||||
|
|
||||||
|
|
||||||
def contextmanager(func):
|
|
||||||
"""@contextmanager decorator.
|
|
||||||
|
|
||||||
Typical usage:
|
|
||||||
|
|
||||||
@contextmanager
|
|
||||||
def some_generator(<arguments>):
|
|
||||||
<setup>
|
|
||||||
try:
|
|
||||||
yield <value>
|
|
||||||
finally:
|
|
||||||
<cleanup>
|
|
||||||
|
|
||||||
This makes this:
|
|
||||||
|
|
||||||
with some_generator(<arguments>) as <variable>:
|
|
||||||
<body>
|
|
||||||
|
|
||||||
equivalent to this:
|
|
||||||
|
|
||||||
<setup>
|
|
||||||
try:
|
|
||||||
<variable> = <value>
|
|
||||||
<body>
|
|
||||||
finally:
|
|
||||||
<cleanup>
|
|
||||||
"""
|
|
||||||
@wraps(func)
|
|
||||||
def helper(*args, **kwds):
|
|
||||||
return _GeneratorContextManager(func, args, kwds)
|
|
||||||
return helper
|
|
||||||
|
|
||||||
|
|
||||||
def asynccontextmanager(func):
|
|
||||||
"""@asynccontextmanager decorator.
|
|
||||||
|
|
||||||
Typical usage:
|
|
||||||
|
|
||||||
@asynccontextmanager
|
|
||||||
async def some_async_generator(<arguments>):
|
|
||||||
<setup>
|
|
||||||
try:
|
|
||||||
yield <value>
|
|
||||||
finally:
|
|
||||||
<cleanup>
|
|
||||||
|
|
||||||
This makes this:
|
|
||||||
|
|
||||||
async with some_async_generator(<arguments>) as <variable>:
|
|
||||||
<body>
|
|
||||||
|
|
||||||
equivalent to this:
|
|
||||||
|
|
||||||
<setup>
|
|
||||||
try:
|
|
||||||
<variable> = <value>
|
|
||||||
<body>
|
|
||||||
finally:
|
|
||||||
<cleanup>
|
|
||||||
"""
|
|
||||||
@wraps(func)
|
|
||||||
def helper(*args, **kwds):
|
|
||||||
return _AsyncGeneratorContextManager(func, args, kwds)
|
|
||||||
return helper
|
|
||||||
|
|
||||||
|
|
||||||
class closing(AbstractContextManager):
|
|
||||||
"""Context to automatically close something at the end of a block.
|
|
||||||
|
|
||||||
Code like this:
|
|
||||||
|
|
||||||
with closing(<module>.open(<arguments>)) as f:
|
|
||||||
<block>
|
|
||||||
|
|
||||||
is equivalent to this:
|
|
||||||
|
|
||||||
f = <module>.open(<arguments>)
|
|
||||||
try:
|
|
||||||
<block>
|
|
||||||
finally:
|
|
||||||
f.close()
|
|
||||||
|
|
||||||
"""
|
|
||||||
def __init__(self, thing):
|
|
||||||
self.thing = thing
|
|
||||||
def __enter__(self):
|
|
||||||
return self.thing
|
|
||||||
def __exit__(self, *exc_info):
|
|
||||||
self.thing.close()
|
|
||||||
|
|
||||||
|
|
||||||
class _RedirectStream(AbstractContextManager):
|
|
||||||
|
|
||||||
_stream = None
|
|
||||||
|
|
||||||
def __init__(self, new_target):
|
|
||||||
self._new_target = new_target
|
|
||||||
# We use a list of old targets to make this CM re-entrant
|
|
||||||
self._old_targets = []
|
|
||||||
|
|
||||||
def __enter__(self):
|
|
||||||
self._old_targets.append(getattr(sys, self._stream))
|
|
||||||
setattr(sys, self._stream, self._new_target)
|
|
||||||
return self._new_target
|
|
||||||
|
|
||||||
def __exit__(self, exctype, excinst, exctb):
|
|
||||||
setattr(sys, self._stream, self._old_targets.pop())
|
|
||||||
|
|
||||||
|
|
||||||
class redirect_stdout(_RedirectStream):
|
|
||||||
"""Context manager for temporarily redirecting stdout to another file.
|
|
||||||
|
|
||||||
# How to send help() to stderr
|
|
||||||
with redirect_stdout(sys.stderr):
|
|
||||||
help(dir)
|
|
||||||
|
|
||||||
# How to write help() to a file
|
|
||||||
with open('help.txt', 'w') as f:
|
|
||||||
with redirect_stdout(f):
|
|
||||||
help(pow)
|
|
||||||
"""
|
|
||||||
|
|
||||||
_stream = "stdout"
|
|
||||||
|
|
||||||
|
|
||||||
class redirect_stderr(_RedirectStream):
|
|
||||||
"""Context manager for temporarily redirecting stderr to another file."""
|
|
||||||
|
|
||||||
_stream = "stderr"
|
|
||||||
|
|
||||||
|
|
||||||
class suppress(AbstractContextManager):
|
|
||||||
"""Context manager to suppress specified exceptions
|
|
||||||
|
|
||||||
After the exception is suppressed, execution proceeds with the next
|
|
||||||
statement following the with statement.
|
|
||||||
|
|
||||||
with suppress(FileNotFoundError):
|
|
||||||
os.remove(somefile)
|
|
||||||
# Execution still resumes here if the file was already removed
|
|
||||||
"""
|
|
||||||
|
|
||||||
def __init__(self, *exceptions):
|
|
||||||
self._exceptions = exceptions
|
|
||||||
|
|
||||||
def __enter__(self):
|
|
||||||
pass
|
|
||||||
|
|
||||||
def __exit__(self, exctype, excinst, exctb):
|
|
||||||
# Unlike isinstance and issubclass, CPython exception handling
|
|
||||||
# currently only looks at the concrete type hierarchy (ignoring
|
|
||||||
# the instance and subclass checking hooks). While Guido considers
|
|
||||||
# that a bug rather than a feature, it's a fairly hard one to fix
|
|
||||||
# due to various internal implementation details. suppress provides
|
|
||||||
# the simpler issubclass based semantics, rather than trying to
|
|
||||||
# exactly reproduce the limitations of the CPython interpreter.
|
|
||||||
#
|
|
||||||
# See http://bugs.python.org/issue12029 for more details
|
|
||||||
return exctype is not None and issubclass(exctype, self._exceptions)
|
|
||||||
|
|
||||||
|
|
||||||
class _BaseExitStack:
|
|
||||||
"""A base class for ExitStack and AsyncExitStack."""
|
|
||||||
|
|
||||||
@staticmethod
|
|
||||||
def _create_exit_wrapper(cm, cm_exit):
|
|
||||||
return MethodType(cm_exit, cm)
|
|
||||||
|
|
||||||
@staticmethod
|
|
||||||
def _create_cb_wrapper(callback, *args, **kwds):
|
|
||||||
def _exit_wrapper(exc_type, exc, tb):
|
|
||||||
callback(*args, **kwds)
|
|
||||||
return _exit_wrapper
|
|
||||||
|
|
||||||
def __init__(self):
|
|
||||||
self._exit_callbacks = deque()
|
|
||||||
|
|
||||||
def pop_all(self):
|
|
||||||
"""Preserve the context stack by transferring it to a new instance."""
|
|
||||||
new_stack = type(self)()
|
|
||||||
new_stack._exit_callbacks = self._exit_callbacks
|
|
||||||
self._exit_callbacks = deque()
|
|
||||||
return new_stack
|
|
||||||
|
|
||||||
def push(self, exit):
|
|
||||||
"""Registers a callback with the standard __exit__ method signature.
|
|
||||||
|
|
||||||
Can suppress exceptions the same way __exit__ method can.
|
|
||||||
Also accepts any object with an __exit__ method (registering a call
|
|
||||||
to the method instead of the object itself).
|
|
||||||
"""
|
|
||||||
# We use an unbound method rather than a bound method to follow
|
|
||||||
# the standard lookup behaviour for special methods.
|
|
||||||
_cb_type = type(exit)
|
|
||||||
|
|
||||||
try:
|
|
||||||
exit_method = _cb_type.__exit__
|
|
||||||
except AttributeError:
|
|
||||||
# Not a context manager, so assume it's a callable.
|
|
||||||
self._push_exit_callback(exit)
|
|
||||||
else:
|
|
||||||
self._push_cm_exit(exit, exit_method)
|
|
||||||
return exit # Allow use as a decorator.
|
|
||||||
|
|
||||||
def enter_context(self, cm):
|
|
||||||
"""Enters the supplied context manager.
|
|
||||||
|
|
||||||
If successful, also pushes its __exit__ method as a callback and
|
|
||||||
returns the result of the __enter__ method.
|
|
||||||
"""
|
|
||||||
# We look up the special methods on the type to match the with
|
|
||||||
# statement.
|
|
||||||
_cm_type = type(cm)
|
|
||||||
_exit = _cm_type.__exit__
|
|
||||||
result = _cm_type.__enter__(cm)
|
|
||||||
self._push_cm_exit(cm, _exit)
|
|
||||||
return result
|
|
||||||
|
|
||||||
def callback(*args, **kwds):
|
|
||||||
"""Registers an arbitrary callback and arguments.
|
|
||||||
|
|
||||||
Cannot suppress exceptions.
|
|
||||||
"""
|
|
||||||
if len(args) >= 2:
|
|
||||||
self, callback, *args = args
|
|
||||||
elif not args:
|
|
||||||
raise TypeError("descriptor 'callback' of '_BaseExitStack' object "
|
|
||||||
"needs an argument")
|
|
||||||
elif 'callback' in kwds:
|
|
||||||
callback = kwds.pop('callback')
|
|
||||||
self, *args = args
|
|
||||||
import warnings
|
|
||||||
warnings.warn("Passing 'callback' as keyword argument is deprecated",
|
|
||||||
DeprecationWarning, stacklevel=2)
|
|
||||||
else:
|
|
||||||
raise TypeError('callback expected at least 1 positional argument, '
|
|
||||||
'got %d' % (len(args)-1))
|
|
||||||
|
|
||||||
_exit_wrapper = self._create_cb_wrapper(callback, *args, **kwds)
|
|
||||||
|
|
||||||
# We changed the signature, so using @wraps is not appropriate, but
|
|
||||||
# setting __wrapped__ may still help with introspection.
|
|
||||||
_exit_wrapper.__wrapped__ = callback
|
|
||||||
self._push_exit_callback(_exit_wrapper)
|
|
||||||
return callback # Allow use as a decorator
|
|
||||||
callback.__text_signature__ = '($self, callback, /, *args, **kwds)'
|
|
||||||
|
|
||||||
def _push_cm_exit(self, cm, cm_exit):
|
|
||||||
"""Helper to correctly register callbacks to __exit__ methods."""
|
|
||||||
_exit_wrapper = self._create_exit_wrapper(cm, cm_exit)
|
|
||||||
self._push_exit_callback(_exit_wrapper, True)
|
|
||||||
|
|
||||||
def _push_exit_callback(self, callback, is_sync=True):
|
|
||||||
self._exit_callbacks.append((is_sync, callback))
|
|
||||||
|
|
||||||
|
|
||||||
# Inspired by discussions on http://bugs.python.org/issue13585
|
|
||||||
class ExitStack(_BaseExitStack, AbstractContextManager):
|
|
||||||
"""Context manager for dynamic management of a stack of exit callbacks.
|
|
||||||
|
|
||||||
For example:
|
|
||||||
with ExitStack() as stack:
|
|
||||||
files = [stack.enter_context(open(fname)) for fname in filenames]
|
|
||||||
# All opened files will automatically be closed at the end of
|
|
||||||
# the with statement, even if attempts to open files later
|
|
||||||
# in the list raise an exception.
|
|
||||||
"""
|
|
||||||
|
|
||||||
def __enter__(self):
|
|
||||||
return self
|
|
||||||
|
|
||||||
def __exit__(self, *exc_details):
|
|
||||||
received_exc = exc_details[0] is not None
|
|
||||||
|
|
||||||
# We manipulate the exception state so it behaves as though
|
|
||||||
# we were actually nesting multiple with statements
|
|
||||||
frame_exc = sys.exc_info()[1]
|
|
||||||
def _fix_exception_context(new_exc, old_exc):
|
|
||||||
# Context may not be correct, so find the end of the chain
|
|
||||||
while 1:
|
|
||||||
exc_context = new_exc.__context__
|
|
||||||
if exc_context is old_exc:
|
|
||||||
# Context is already set correctly (see issue 20317)
|
|
||||||
return
|
|
||||||
if exc_context is None or exc_context is frame_exc:
|
|
||||||
break
|
|
||||||
new_exc = exc_context
|
|
||||||
# Change the end of the chain to point to the exception
|
|
||||||
# we expect it to reference
|
|
||||||
new_exc.__context__ = old_exc
|
|
||||||
|
|
||||||
# Callbacks are invoked in LIFO order to match the behaviour of
|
|
||||||
# nested context managers
|
|
||||||
suppressed_exc = False
|
|
||||||
pending_raise = False
|
|
||||||
while self._exit_callbacks:
|
|
||||||
is_sync, cb = self._exit_callbacks.pop()
|
|
||||||
assert is_sync
|
|
||||||
try:
|
|
||||||
if cb(*exc_details):
|
|
||||||
suppressed_exc = True
|
|
||||||
pending_raise = False
|
|
||||||
exc_details = (None, None, None)
|
|
||||||
except:
|
|
||||||
new_exc_details = sys.exc_info()
|
|
||||||
# simulate the stack of exceptions by setting the context
|
|
||||||
_fix_exception_context(new_exc_details[1], exc_details[1])
|
|
||||||
pending_raise = True
|
|
||||||
exc_details = new_exc_details
|
|
||||||
if pending_raise:
|
|
||||||
try:
|
|
||||||
# bare "raise exc_details[1]" replaces our carefully
|
|
||||||
# set-up context
|
|
||||||
fixed_ctx = exc_details[1].__context__
|
|
||||||
raise exc_details[1]
|
|
||||||
except BaseException:
|
|
||||||
exc_details[1].__context__ = fixed_ctx
|
|
||||||
raise
|
|
||||||
return received_exc and suppressed_exc
|
|
||||||
|
|
||||||
def close(self):
|
|
||||||
"""Immediately unwind the context stack."""
|
|
||||||
self.__exit__(None, None, None)
|
|
||||||
|
|
||||||
|
|
||||||
# Inspired by discussions on https://bugs.python.org/issue29302
|
|
||||||
class AsyncExitStack(_BaseExitStack, AbstractAsyncContextManager):
|
|
||||||
"""Async context manager for dynamic management of a stack of exit
|
|
||||||
callbacks.
|
|
||||||
|
|
||||||
For example:
|
|
||||||
async with AsyncExitStack() as stack:
|
|
||||||
connections = [await stack.enter_async_context(get_connection())
|
|
||||||
for i in range(5)]
|
|
||||||
# All opened connections will automatically be released at the
|
|
||||||
# end of the async with statement, even if attempts to open a
|
|
||||||
# connection later in the list raise an exception.
|
|
||||||
"""
|
|
||||||
|
|
||||||
@staticmethod
|
|
||||||
def _create_async_exit_wrapper(cm, cm_exit):
|
|
||||||
return MethodType(cm_exit, cm)
|
|
||||||
|
|
||||||
@staticmethod
|
|
||||||
def _create_async_cb_wrapper(callback, *args, **kwds):
|
|
||||||
async def _exit_wrapper(exc_type, exc, tb):
|
|
||||||
await callback(*args, **kwds)
|
|
||||||
return _exit_wrapper
|
|
||||||
|
|
||||||
async def enter_async_context(self, cm):
|
|
||||||
"""Enters the supplied async context manager.
|
|
||||||
|
|
||||||
If successful, also pushes its __aexit__ method as a callback and
|
|
||||||
returns the result of the __aenter__ method.
|
|
||||||
"""
|
|
||||||
_cm_type = type(cm)
|
|
||||||
_exit = _cm_type.__aexit__
|
|
||||||
result = await _cm_type.__aenter__(cm)
|
|
||||||
self._push_async_cm_exit(cm, _exit)
|
|
||||||
return result
|
|
||||||
|
|
||||||
def push_async_exit(self, exit):
|
|
||||||
"""Registers a coroutine function with the standard __aexit__ method
|
|
||||||
signature.
|
|
||||||
|
|
||||||
Can suppress exceptions the same way __aexit__ method can.
|
|
||||||
Also accepts any object with an __aexit__ method (registering a call
|
|
||||||
to the method instead of the object itself).
|
|
||||||
"""
|
|
||||||
_cb_type = type(exit)
|
|
||||||
try:
|
|
||||||
exit_method = _cb_type.__aexit__
|
|
||||||
except AttributeError:
|
|
||||||
# Not an async context manager, so assume it's a coroutine function
|
|
||||||
self._push_exit_callback(exit, False)
|
|
||||||
else:
|
|
||||||
self._push_async_cm_exit(exit, exit_method)
|
|
||||||
return exit # Allow use as a decorator
|
|
||||||
|
|
||||||
def push_async_callback(*args, **kwds):
|
|
||||||
"""Registers an arbitrary coroutine function and arguments.
|
|
||||||
|
|
||||||
Cannot suppress exceptions.
|
|
||||||
"""
|
|
||||||
if len(args) >= 2:
|
|
||||||
self, callback, *args = args
|
|
||||||
elif not args:
|
|
||||||
raise TypeError("descriptor 'push_async_callback' of "
|
|
||||||
"'AsyncExitStack' object needs an argument")
|
|
||||||
elif 'callback' in kwds:
|
|
||||||
callback = kwds.pop('callback')
|
|
||||||
self, *args = args
|
|
||||||
import warnings
|
|
||||||
warnings.warn("Passing 'callback' as keyword argument is deprecated",
|
|
||||||
DeprecationWarning, stacklevel=2)
|
|
||||||
else:
|
|
||||||
raise TypeError('push_async_callback expected at least 1 '
|
|
||||||
'positional argument, got %d' % (len(args)-1))
|
|
||||||
|
|
||||||
_exit_wrapper = self._create_async_cb_wrapper(callback, *args, **kwds)
|
|
||||||
|
|
||||||
# We changed the signature, so using @wraps is not appropriate, but
|
|
||||||
# setting __wrapped__ may still help with introspection.
|
|
||||||
_exit_wrapper.__wrapped__ = callback
|
|
||||||
self._push_exit_callback(_exit_wrapper, False)
|
|
||||||
return callback # Allow use as a decorator
|
|
||||||
push_async_callback.__text_signature__ = '($self, callback, /, *args, **kwds)'
|
|
||||||
|
|
||||||
async def aclose(self):
|
|
||||||
"""Immediately unwind the context stack."""
|
|
||||||
await self.__aexit__(None, None, None)
|
|
||||||
|
|
||||||
def _push_async_cm_exit(self, cm, cm_exit):
|
|
||||||
"""Helper to correctly register coroutine function to __aexit__
|
|
||||||
method."""
|
|
||||||
_exit_wrapper = self._create_async_exit_wrapper(cm, cm_exit)
|
|
||||||
self._push_exit_callback(_exit_wrapper, False)
|
|
||||||
|
|
||||||
async def __aenter__(self):
|
|
||||||
return self
|
|
||||||
|
|
||||||
async def __aexit__(self, *exc_details):
|
|
||||||
received_exc = exc_details[0] is not None
|
|
||||||
|
|
||||||
# We manipulate the exception state so it behaves as though
|
|
||||||
# we were actually nesting multiple with statements
|
|
||||||
frame_exc = sys.exc_info()[1]
|
|
||||||
def _fix_exception_context(new_exc, old_exc):
|
|
||||||
# Context may not be correct, so find the end of the chain
|
|
||||||
while 1:
|
|
||||||
exc_context = new_exc.__context__
|
|
||||||
if exc_context is old_exc:
|
|
||||||
# Context is already set correctly (see issue 20317)
|
|
||||||
return
|
|
||||||
if exc_context is None or exc_context is frame_exc:
|
|
||||||
break
|
|
||||||
new_exc = exc_context
|
|
||||||
# Change the end of the chain to point to the exception
|
|
||||||
# we expect it to reference
|
|
||||||
new_exc.__context__ = old_exc
|
|
||||||
|
|
||||||
# Callbacks are invoked in LIFO order to match the behaviour of
|
|
||||||
# nested context managers
|
|
||||||
suppressed_exc = False
|
|
||||||
pending_raise = False
|
|
||||||
while self._exit_callbacks:
|
|
||||||
is_sync, cb = self._exit_callbacks.pop()
|
|
||||||
try:
|
|
||||||
if is_sync:
|
|
||||||
cb_suppress = cb(*exc_details)
|
|
||||||
else:
|
|
||||||
cb_suppress = await cb(*exc_details)
|
|
||||||
|
|
||||||
if cb_suppress:
|
|
||||||
suppressed_exc = True
|
|
||||||
pending_raise = False
|
|
||||||
exc_details = (None, None, None)
|
|
||||||
except:
|
|
||||||
new_exc_details = sys.exc_info()
|
|
||||||
# simulate the stack of exceptions by setting the context
|
|
||||||
_fix_exception_context(new_exc_details[1], exc_details[1])
|
|
||||||
pending_raise = True
|
|
||||||
exc_details = new_exc_details
|
|
||||||
if pending_raise:
|
|
||||||
try:
|
|
||||||
# bare "raise exc_details[1]" replaces our carefully
|
|
||||||
# set-up context
|
|
||||||
fixed_ctx = exc_details[1].__context__
|
|
||||||
raise exc_details[1]
|
|
||||||
except BaseException:
|
|
||||||
exc_details[1].__context__ = fixed_ctx
|
|
||||||
raise
|
|
||||||
return received_exc and suppressed_exc
|
|
||||||
|
|
||||||
|
|
||||||
class nullcontext(AbstractContextManager):
|
|
||||||
"""Context manager that does no additional processing.
|
|
||||||
|
|
||||||
Used as a stand-in for a normal context manager, when a particular
|
|
||||||
block of code is only sometimes used with a normal context manager:
|
|
||||||
|
|
||||||
cm = optional_cm if condition else nullcontext()
|
|
||||||
with cm:
|
|
||||||
# Perform operation, using optional_cm if condition is True
|
|
||||||
"""
|
|
||||||
|
|
||||||
def __init__(self, enter_result=None):
|
|
||||||
self.enter_result = enter_result
|
|
||||||
|
|
||||||
def __enter__(self):
|
|
||||||
return self.enter_result
|
|
||||||
|
|
||||||
def __exit__(self, *excinfo):
|
|
||||||
pass
|
|
|
@ -1,797 +0,0 @@
|
||||||
"""Internationalization and localization support.
|
|
||||||
|
|
||||||
This module provides internationalization (I18N) and localization (L10N)
|
|
||||||
support for your Python programs by providing an interface to the GNU gettext
|
|
||||||
message catalog library.
|
|
||||||
|
|
||||||
I18N refers to the operation by which a program is made aware of multiple
|
|
||||||
languages. L10N refers to the adaptation of your program, once
|
|
||||||
internationalized, to the local language and cultural habits.
|
|
||||||
|
|
||||||
"""
|
|
||||||
|
|
||||||
# This module represents the integration of work, contributions, feedback, and
|
|
||||||
# suggestions from the following people:
|
|
||||||
#
|
|
||||||
# Martin von Loewis, who wrote the initial implementation of the underlying
|
|
||||||
# C-based libintlmodule (later renamed _gettext), along with a skeletal
|
|
||||||
# gettext.py implementation.
|
|
||||||
#
|
|
||||||
# Peter Funk, who wrote fintl.py, a fairly complete wrapper around intlmodule,
|
|
||||||
# which also included a pure-Python implementation to read .mo files if
|
|
||||||
# intlmodule wasn't available.
|
|
||||||
#
|
|
||||||
# James Henstridge, who also wrote a gettext.py module, which has some
|
|
||||||
# interesting, but currently unsupported experimental features: the notion of
|
|
||||||
# a Catalog class and instances, and the ability to add to a catalog file via
|
|
||||||
# a Python API.
|
|
||||||
#
|
|
||||||
# Barry Warsaw integrated these modules, wrote the .install() API and code,
|
|
||||||
# and conformed all C and Python code to Python's coding standards.
|
|
||||||
#
|
|
||||||
# Francois Pinard and Marc-Andre Lemburg also contributed valuably to this
|
|
||||||
# module.
|
|
||||||
#
|
|
||||||
# J. David Ibanez implemented plural forms. Bruno Haible fixed some bugs.
|
|
||||||
#
|
|
||||||
# TODO:
|
|
||||||
# - Lazy loading of .mo files. Currently the entire catalog is loaded into
|
|
||||||
# memory, but that's probably bad for large translated programs. Instead,
|
|
||||||
# the lexical sort of original strings in GNU .mo files should be exploited
|
|
||||||
# to do binary searches and lazy initializations. Or you might want to use
|
|
||||||
# the undocumented double-hash algorithm for .mo files with hash tables, but
|
|
||||||
# you'll need to study the GNU gettext code to do this.
|
|
||||||
#
|
|
||||||
# - Support Solaris .mo file formats. Unfortunately, we've been unable to
|
|
||||||
# find this format documented anywhere.
|
|
||||||
|
|
||||||
|
|
||||||
import locale
|
|
||||||
import os
|
|
||||||
import re
|
|
||||||
import sys
|
|
||||||
|
|
||||||
|
|
||||||
__all__ = ['NullTranslations', 'GNUTranslations', 'Catalog',
|
|
||||||
'find', 'translation', 'install', 'textdomain', 'bindtextdomain',
|
|
||||||
'bind_textdomain_codeset',
|
|
||||||
'dgettext', 'dngettext', 'gettext', 'lgettext', 'ldgettext',
|
|
||||||
'ldngettext', 'lngettext', 'ngettext',
|
|
||||||
'pgettext', 'dpgettext', 'npgettext', 'dnpgettext',
|
|
||||||
]
|
|
||||||
|
|
||||||
_default_localedir = os.path.join(sys.base_prefix, 'share', 'locale')
|
|
||||||
|
|
||||||
# Expression parsing for plural form selection.
|
|
||||||
#
|
|
||||||
# The gettext library supports a small subset of C syntax. The only
|
|
||||||
# incompatible difference is that integer literals starting with zero are
|
|
||||||
# decimal.
|
|
||||||
#
|
|
||||||
# https://www.gnu.org/software/gettext/manual/gettext.html#Plural-forms
|
|
||||||
# http://git.savannah.gnu.org/cgit/gettext.git/tree/gettext-runtime/intl/plural.y
|
|
||||||
|
|
||||||
_token_pattern = re.compile(r"""
|
|
||||||
(?P<WHITESPACES>[ \t]+) | # spaces and horizontal tabs
|
|
||||||
(?P<NUMBER>[0-9]+\b) | # decimal integer
|
|
||||||
(?P<NAME>n\b) | # only n is allowed
|
|
||||||
(?P<PARENTHESIS>[()]) |
|
|
||||||
(?P<OPERATOR>[-*/%+?:]|[><!]=?|==|&&|\|\|) | # !, *, /, %, +, -, <, >,
|
|
||||||
# <=, >=, ==, !=, &&, ||,
|
|
||||||
# ? :
|
|
||||||
# unary and bitwise ops
|
|
||||||
# not allowed
|
|
||||||
(?P<INVALID>\w+|.) # invalid token
|
|
||||||
""", re.VERBOSE|re.DOTALL)
|
|
||||||
|
|
||||||
def _tokenize(plural):
|
|
||||||
for mo in re.finditer(_token_pattern, plural):
|
|
||||||
kind = mo.lastgroup
|
|
||||||
if kind == 'WHITESPACES':
|
|
||||||
continue
|
|
||||||
value = mo.group(kind)
|
|
||||||
if kind == 'INVALID':
|
|
||||||
raise ValueError('invalid token in plural form: %s' % value)
|
|
||||||
yield value
|
|
||||||
yield ''
|
|
||||||
|
|
||||||
def _error(value):
|
|
||||||
if value:
|
|
||||||
return ValueError('unexpected token in plural form: %s' % value)
|
|
||||||
else:
|
|
||||||
return ValueError('unexpected end of plural form')
|
|
||||||
|
|
||||||
_binary_ops = (
|
|
||||||
('||',),
|
|
||||||
('&&',),
|
|
||||||
('==', '!='),
|
|
||||||
('<', '>', '<=', '>='),
|
|
||||||
('+', '-'),
|
|
||||||
('*', '/', '%'),
|
|
||||||
)
|
|
||||||
_binary_ops = {op: i for i, ops in enumerate(_binary_ops, 1) for op in ops}
|
|
||||||
_c2py_ops = {'||': 'or', '&&': 'and', '/': '//'}
|
|
||||||
|
|
||||||
def _parse(tokens, priority=-1):
|
|
||||||
result = ''
|
|
||||||
nexttok = next(tokens)
|
|
||||||
while nexttok == '!':
|
|
||||||
result += 'not '
|
|
||||||
nexttok = next(tokens)
|
|
||||||
|
|
||||||
if nexttok == '(':
|
|
||||||
sub, nexttok = _parse(tokens)
|
|
||||||
result = '%s(%s)' % (result, sub)
|
|
||||||
if nexttok != ')':
|
|
||||||
raise ValueError('unbalanced parenthesis in plural form')
|
|
||||||
elif nexttok == 'n':
|
|
||||||
result = '%s%s' % (result, nexttok)
|
|
||||||
else:
|
|
||||||
try:
|
|
||||||
value = int(nexttok, 10)
|
|
||||||
except ValueError:
|
|
||||||
raise _error(nexttok) from None
|
|
||||||
result = '%s%d' % (result, value)
|
|
||||||
nexttok = next(tokens)
|
|
||||||
|
|
||||||
j = 100
|
|
||||||
while nexttok in _binary_ops:
|
|
||||||
i = _binary_ops[nexttok]
|
|
||||||
if i < priority:
|
|
||||||
break
|
|
||||||
# Break chained comparisons
|
|
||||||
if i in (3, 4) and j in (3, 4): # '==', '!=', '<', '>', '<=', '>='
|
|
||||||
result = '(%s)' % result
|
|
||||||
# Replace some C operators by their Python equivalents
|
|
||||||
op = _c2py_ops.get(nexttok, nexttok)
|
|
||||||
right, nexttok = _parse(tokens, i + 1)
|
|
||||||
result = '%s %s %s' % (result, op, right)
|
|
||||||
j = i
|
|
||||||
if j == priority == 4: # '<', '>', '<=', '>='
|
|
||||||
result = '(%s)' % result
|
|
||||||
|
|
||||||
if nexttok == '?' and priority <= 0:
|
|
||||||
if_true, nexttok = _parse(tokens, 0)
|
|
||||||
if nexttok != ':':
|
|
||||||
raise _error(nexttok)
|
|
||||||
if_false, nexttok = _parse(tokens)
|
|
||||||
result = '%s if %s else %s' % (if_true, result, if_false)
|
|
||||||
if priority == 0:
|
|
||||||
result = '(%s)' % result
|
|
||||||
|
|
||||||
return result, nexttok
|
|
||||||
|
|
||||||
def _as_int(n):
|
|
||||||
try:
|
|
||||||
i = round(n)
|
|
||||||
except TypeError:
|
|
||||||
raise TypeError('Plural value must be an integer, got %s' %
|
|
||||||
(n.__class__.__name__,)) from None
|
|
||||||
import warnings
|
|
||||||
warnings.warn('Plural value must be an integer, got %s' %
|
|
||||||
(n.__class__.__name__,),
|
|
||||||
DeprecationWarning, 4)
|
|
||||||
return n
|
|
||||||
|
|
||||||
def c2py(plural):
|
|
||||||
"""Gets a C expression as used in PO files for plural forms and returns a
|
|
||||||
Python function that implements an equivalent expression.
|
|
||||||
"""
|
|
||||||
|
|
||||||
if len(plural) > 1000:
|
|
||||||
raise ValueError('plural form expression is too long')
|
|
||||||
try:
|
|
||||||
result, nexttok = _parse(_tokenize(plural))
|
|
||||||
if nexttok:
|
|
||||||
raise _error(nexttok)
|
|
||||||
|
|
||||||
depth = 0
|
|
||||||
for c in result:
|
|
||||||
if c == '(':
|
|
||||||
depth += 1
|
|
||||||
if depth > 20:
|
|
||||||
# Python compiler limit is about 90.
|
|
||||||
# The most complex example has 2.
|
|
||||||
raise ValueError('plural form expression is too complex')
|
|
||||||
elif c == ')':
|
|
||||||
depth -= 1
|
|
||||||
|
|
||||||
ns = {'_as_int': _as_int}
|
|
||||||
exec('''if True:
|
|
||||||
def func(n):
|
|
||||||
if not isinstance(n, int):
|
|
||||||
n = _as_int(n)
|
|
||||||
return int(%s)
|
|
||||||
''' % result, ns)
|
|
||||||
return ns['func']
|
|
||||||
except RecursionError:
|
|
||||||
# Recursion error can be raised in _parse() or exec().
|
|
||||||
raise ValueError('plural form expression is too complex')
|
|
||||||
|
|
||||||
|
|
||||||
def _expand_lang(loc):
|
|
||||||
loc = locale.normalize(loc)
|
|
||||||
COMPONENT_CODESET = 1 << 0
|
|
||||||
COMPONENT_TERRITORY = 1 << 1
|
|
||||||
COMPONENT_MODIFIER = 1 << 2
|
|
||||||
# split up the locale into its base components
|
|
||||||
mask = 0
|
|
||||||
pos = loc.find('@')
|
|
||||||
if pos >= 0:
|
|
||||||
modifier = loc[pos:]
|
|
||||||
loc = loc[:pos]
|
|
||||||
mask |= COMPONENT_MODIFIER
|
|
||||||
else:
|
|
||||||
modifier = ''
|
|
||||||
pos = loc.find('.')
|
|
||||||
if pos >= 0:
|
|
||||||
codeset = loc[pos:]
|
|
||||||
loc = loc[:pos]
|
|
||||||
mask |= COMPONENT_CODESET
|
|
||||||
else:
|
|
||||||
codeset = ''
|
|
||||||
pos = loc.find('_')
|
|
||||||
if pos >= 0:
|
|
||||||
territory = loc[pos:]
|
|
||||||
loc = loc[:pos]
|
|
||||||
mask |= COMPONENT_TERRITORY
|
|
||||||
else:
|
|
||||||
territory = ''
|
|
||||||
language = loc
|
|
||||||
ret = []
|
|
||||||
for i in range(mask+1):
|
|
||||||
if not (i & ~mask): # if all components for this combo exist ...
|
|
||||||
val = language
|
|
||||||
if i & COMPONENT_TERRITORY: val += territory
|
|
||||||
if i & COMPONENT_CODESET: val += codeset
|
|
||||||
if i & COMPONENT_MODIFIER: val += modifier
|
|
||||||
ret.append(val)
|
|
||||||
ret.reverse()
|
|
||||||
return ret
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
class NullTranslations:
|
|
||||||
def __init__(self, fp=None):
|
|
||||||
self._info = {}
|
|
||||||
self._charset = None
|
|
||||||
self._output_charset = None
|
|
||||||
self._fallback = None
|
|
||||||
if fp is not None:
|
|
||||||
self._parse(fp)
|
|
||||||
|
|
||||||
def _parse(self, fp):
|
|
||||||
pass
|
|
||||||
|
|
||||||
def add_fallback(self, fallback):
|
|
||||||
if self._fallback:
|
|
||||||
self._fallback.add_fallback(fallback)
|
|
||||||
else:
|
|
||||||
self._fallback = fallback
|
|
||||||
|
|
||||||
def gettext(self, message):
|
|
||||||
if self._fallback:
|
|
||||||
return self._fallback.gettext(message)
|
|
||||||
return message
|
|
||||||
|
|
||||||
def lgettext(self, message):
|
|
||||||
import warnings
|
|
||||||
warnings.warn('lgettext() is deprecated, use gettext() instead',
|
|
||||||
DeprecationWarning, 2)
|
|
||||||
if self._fallback:
|
|
||||||
with warnings.catch_warnings():
|
|
||||||
warnings.filterwarnings('ignore', r'.*\blgettext\b.*',
|
|
||||||
DeprecationWarning)
|
|
||||||
return self._fallback.lgettext(message)
|
|
||||||
if self._output_charset:
|
|
||||||
return message.encode(self._output_charset)
|
|
||||||
return message.encode(locale.getpreferredencoding())
|
|
||||||
|
|
||||||
def ngettext(self, msgid1, msgid2, n):
|
|
||||||
if self._fallback:
|
|
||||||
return self._fallback.ngettext(msgid1, msgid2, n)
|
|
||||||
if n == 1:
|
|
||||||
return msgid1
|
|
||||||
else:
|
|
||||||
return msgid2
|
|
||||||
|
|
||||||
def lngettext(self, msgid1, msgid2, n):
|
|
||||||
import warnings
|
|
||||||
warnings.warn('lngettext() is deprecated, use ngettext() instead',
|
|
||||||
DeprecationWarning, 2)
|
|
||||||
if self._fallback:
|
|
||||||
with warnings.catch_warnings():
|
|
||||||
warnings.filterwarnings('ignore', r'.*\blngettext\b.*',
|
|
||||||
DeprecationWarning)
|
|
||||||
return self._fallback.lngettext(msgid1, msgid2, n)
|
|
||||||
if n == 1:
|
|
||||||
tmsg = msgid1
|
|
||||||
else:
|
|
||||||
tmsg = msgid2
|
|
||||||
if self._output_charset:
|
|
||||||
return tmsg.encode(self._output_charset)
|
|
||||||
return tmsg.encode(locale.getpreferredencoding())
|
|
||||||
|
|
||||||
def pgettext(self, context, message):
|
|
||||||
if self._fallback:
|
|
||||||
return self._fallback.pgettext(context, message)
|
|
||||||
return message
|
|
||||||
|
|
||||||
def npgettext(self, context, msgid1, msgid2, n):
|
|
||||||
if self._fallback:
|
|
||||||
return self._fallback.npgettext(context, msgid1, msgid2, n)
|
|
||||||
if n == 1:
|
|
||||||
return msgid1
|
|
||||||
else:
|
|
||||||
return msgid2
|
|
||||||
|
|
||||||
def info(self):
|
|
||||||
return self._info
|
|
||||||
|
|
||||||
def charset(self):
|
|
||||||
return self._charset
|
|
||||||
|
|
||||||
def output_charset(self):
|
|
||||||
import warnings
|
|
||||||
warnings.warn('output_charset() is deprecated',
|
|
||||||
DeprecationWarning, 2)
|
|
||||||
return self._output_charset
|
|
||||||
|
|
||||||
def set_output_charset(self, charset):
|
|
||||||
import warnings
|
|
||||||
warnings.warn('set_output_charset() is deprecated',
|
|
||||||
DeprecationWarning, 2)
|
|
||||||
self._output_charset = charset
|
|
||||||
|
|
||||||
def install(self, names=None):
|
|
||||||
import builtins
|
|
||||||
builtins.__dict__['_'] = self.gettext
|
|
||||||
if names is not None:
|
|
||||||
allowed = {'gettext', 'lgettext', 'lngettext',
|
|
||||||
'ngettext', 'npgettext', 'pgettext'}
|
|
||||||
for name in allowed & set(names):
|
|
||||||
builtins.__dict__[name] = getattr(self, name)
|
|
||||||
|
|
||||||
|
|
||||||
class GNUTranslations(NullTranslations):
|
|
||||||
# Magic number of .mo files
|
|
||||||
LE_MAGIC = 0x950412de
|
|
||||||
BE_MAGIC = 0xde120495
|
|
||||||
|
|
||||||
# The encoding of a msgctxt and a msgid in a .mo file is
|
|
||||||
# msgctxt + "\x04" + msgid (gettext version >= 0.15)
|
|
||||||
CONTEXT = "%s\x04%s"
|
|
||||||
|
|
||||||
# Acceptable .mo versions
|
|
||||||
VERSIONS = (0, 1)
|
|
||||||
|
|
||||||
def _get_versions(self, version):
|
|
||||||
"""Returns a tuple of major version, minor version"""
|
|
||||||
return (version >> 16, version & 0xffff)
|
|
||||||
|
|
||||||
def _parse(self, fp):
|
|
||||||
"""Override this method to support alternative .mo formats."""
|
|
||||||
# Delay struct import for speeding up gettext import when .mo files
|
|
||||||
# are not used.
|
|
||||||
from struct import unpack
|
|
||||||
filename = getattr(fp, 'name', '')
|
|
||||||
# Parse the .mo file header, which consists of 5 little endian 32
|
|
||||||
# bit words.
|
|
||||||
self._catalog = catalog = {}
|
|
||||||
self.plural = lambda n: int(n != 1) # germanic plural by default
|
|
||||||
buf = fp.read()
|
|
||||||
buflen = len(buf)
|
|
||||||
# Are we big endian or little endian?
|
|
||||||
magic = unpack('<I', buf[:4])[0]
|
|
||||||
if magic == self.LE_MAGIC:
|
|
||||||
version, msgcount, masteridx, transidx = unpack('<4I', buf[4:20])
|
|
||||||
ii = '<II'
|
|
||||||
elif magic == self.BE_MAGIC:
|
|
||||||
version, msgcount, masteridx, transidx = unpack('>4I', buf[4:20])
|
|
||||||
ii = '>II'
|
|
||||||
else:
|
|
||||||
raise OSError(0, 'Bad magic number', filename)
|
|
||||||
|
|
||||||
major_version, minor_version = self._get_versions(version)
|
|
||||||
|
|
||||||
if major_version not in self.VERSIONS:
|
|
||||||
raise OSError(0, 'Bad version number ' + str(major_version), filename)
|
|
||||||
|
|
||||||
# Now put all messages from the .mo file buffer into the catalog
|
|
||||||
# dictionary.
|
|
||||||
for i in range(0, msgcount):
|
|
||||||
mlen, moff = unpack(ii, buf[masteridx:masteridx+8])
|
|
||||||
mend = moff + mlen
|
|
||||||
tlen, toff = unpack(ii, buf[transidx:transidx+8])
|
|
||||||
tend = toff + tlen
|
|
||||||
if mend < buflen and tend < buflen:
|
|
||||||
msg = buf[moff:mend]
|
|
||||||
tmsg = buf[toff:tend]
|
|
||||||
else:
|
|
||||||
raise OSError(0, 'File is corrupt', filename)
|
|
||||||
# See if we're looking at GNU .mo conventions for metadata
|
|
||||||
if mlen == 0:
|
|
||||||
# Catalog description
|
|
||||||
lastk = None
|
|
||||||
for b_item in tmsg.split(b'\n'):
|
|
||||||
item = b_item.decode().strip()
|
|
||||||
if not item:
|
|
||||||
continue
|
|
||||||
# Skip over comment lines:
|
|
||||||
if item.startswith('#-#-#-#-#') and item.endswith('#-#-#-#-#'):
|
|
||||||
continue
|
|
||||||
k = v = None
|
|
||||||
if ':' in item:
|
|
||||||
k, v = item.split(':', 1)
|
|
||||||
k = k.strip().lower()
|
|
||||||
v = v.strip()
|
|
||||||
self._info[k] = v
|
|
||||||
lastk = k
|
|
||||||
elif lastk:
|
|
||||||
self._info[lastk] += '\n' + item
|
|
||||||
if k == 'content-type':
|
|
||||||
self._charset = v.split('charset=')[1]
|
|
||||||
elif k == 'plural-forms':
|
|
||||||
v = v.split(';')
|
|
||||||
plural = v[1].split('plural=')[1]
|
|
||||||
self.plural = c2py(plural)
|
|
||||||
# Note: we unconditionally convert both msgids and msgstrs to
|
|
||||||
# Unicode using the character encoding specified in the charset
|
|
||||||
# parameter of the Content-Type header. The gettext documentation
|
|
||||||
# strongly encourages msgids to be us-ascii, but some applications
|
|
||||||
# require alternative encodings (e.g. Zope's ZCML and ZPT). For
|
|
||||||
# traditional gettext applications, the msgid conversion will
|
|
||||||
# cause no problems since us-ascii should always be a subset of
|
|
||||||
# the charset encoding. We may want to fall back to 8-bit msgids
|
|
||||||
# if the Unicode conversion fails.
|
|
||||||
charset = self._charset or 'ascii'
|
|
||||||
if b'\x00' in msg:
|
|
||||||
# Plural forms
|
|
||||||
msgid1, msgid2 = msg.split(b'\x00')
|
|
||||||
tmsg = tmsg.split(b'\x00')
|
|
||||||
msgid1 = str(msgid1, charset)
|
|
||||||
for i, x in enumerate(tmsg):
|
|
||||||
catalog[(msgid1, i)] = str(x, charset)
|
|
||||||
else:
|
|
||||||
catalog[str(msg, charset)] = str(tmsg, charset)
|
|
||||||
# advance to next entry in the seek tables
|
|
||||||
masteridx += 8
|
|
||||||
transidx += 8
|
|
||||||
|
|
||||||
def lgettext(self, message):
|
|
||||||
import warnings
|
|
||||||
warnings.warn('lgettext() is deprecated, use gettext() instead',
|
|
||||||
DeprecationWarning, 2)
|
|
||||||
missing = object()
|
|
||||||
tmsg = self._catalog.get(message, missing)
|
|
||||||
if tmsg is missing:
|
|
||||||
if self._fallback:
|
|
||||||
return self._fallback.lgettext(message)
|
|
||||||
tmsg = message
|
|
||||||
if self._output_charset:
|
|
||||||
return tmsg.encode(self._output_charset)
|
|
||||||
return tmsg.encode(locale.getpreferredencoding())
|
|
||||||
|
|
||||||
def lngettext(self, msgid1, msgid2, n):
|
|
||||||
import warnings
|
|
||||||
warnings.warn('lngettext() is deprecated, use ngettext() instead',
|
|
||||||
DeprecationWarning, 2)
|
|
||||||
try:
|
|
||||||
tmsg = self._catalog[(msgid1, self.plural(n))]
|
|
||||||
except KeyError:
|
|
||||||
if self._fallback:
|
|
||||||
return self._fallback.lngettext(msgid1, msgid2, n)
|
|
||||||
if n == 1:
|
|
||||||
tmsg = msgid1
|
|
||||||
else:
|
|
||||||
tmsg = msgid2
|
|
||||||
if self._output_charset:
|
|
||||||
return tmsg.encode(self._output_charset)
|
|
||||||
return tmsg.encode(locale.getpreferredencoding())
|
|
||||||
|
|
||||||
def gettext(self, message):
|
|
||||||
missing = object()
|
|
||||||
tmsg = self._catalog.get(message, missing)
|
|
||||||
if tmsg is missing:
|
|
||||||
if self._fallback:
|
|
||||||
return self._fallback.gettext(message)
|
|
||||||
return message
|
|
||||||
return tmsg
|
|
||||||
|
|
||||||
def ngettext(self, msgid1, msgid2, n):
|
|
||||||
try:
|
|
||||||
tmsg = self._catalog[(msgid1, self.plural(n))]
|
|
||||||
except KeyError:
|
|
||||||
if self._fallback:
|
|
||||||
return self._fallback.ngettext(msgid1, msgid2, n)
|
|
||||||
if n == 1:
|
|
||||||
tmsg = msgid1
|
|
||||||
else:
|
|
||||||
tmsg = msgid2
|
|
||||||
return tmsg
|
|
||||||
|
|
||||||
def pgettext(self, context, message):
|
|
||||||
ctxt_msg_id = self.CONTEXT % (context, message)
|
|
||||||
missing = object()
|
|
||||||
tmsg = self._catalog.get(ctxt_msg_id, missing)
|
|
||||||
if tmsg is missing:
|
|
||||||
if self._fallback:
|
|
||||||
return self._fallback.pgettext(context, message)
|
|
||||||
return message
|
|
||||||
return tmsg
|
|
||||||
|
|
||||||
def npgettext(self, context, msgid1, msgid2, n):
|
|
||||||
ctxt_msg_id = self.CONTEXT % (context, msgid1)
|
|
||||||
try:
|
|
||||||
tmsg = self._catalog[ctxt_msg_id, self.plural(n)]
|
|
||||||
except KeyError:
|
|
||||||
if self._fallback:
|
|
||||||
return self._fallback.npgettext(context, msgid1, msgid2, n)
|
|
||||||
if n == 1:
|
|
||||||
tmsg = msgid1
|
|
||||||
else:
|
|
||||||
tmsg = msgid2
|
|
||||||
return tmsg
|
|
||||||
|
|
||||||
|
|
||||||
# Locate a .mo file using the gettext strategy
|
|
||||||
def find(domain, localedir=None, languages=None, all=False):
|
|
||||||
# Get some reasonable defaults for arguments that were not supplied
|
|
||||||
if localedir is None:
|
|
||||||
localedir = _default_localedir
|
|
||||||
if languages is None:
|
|
||||||
languages = []
|
|
||||||
for envar in ('LANGUAGE', 'LC_ALL', 'LC_MESSAGES', 'LANG'):
|
|
||||||
val = os.environ.get(envar)
|
|
||||||
if val:
|
|
||||||
languages = val.split(':')
|
|
||||||
break
|
|
||||||
if 'C' not in languages:
|
|
||||||
languages.append('C')
|
|
||||||
# now normalize and expand the languages
|
|
||||||
nelangs = []
|
|
||||||
for lang in languages:
|
|
||||||
for nelang in _expand_lang(lang):
|
|
||||||
if nelang not in nelangs:
|
|
||||||
nelangs.append(nelang)
|
|
||||||
# select a language
|
|
||||||
if all:
|
|
||||||
result = []
|
|
||||||
else:
|
|
||||||
result = None
|
|
||||||
for lang in nelangs:
|
|
||||||
if lang == 'C':
|
|
||||||
break
|
|
||||||
mofile = os.path.join(localedir, lang, 'LC_MESSAGES', '%s.mo' % domain)
|
|
||||||
mofile_lp = os.path.join("/usr/share/locale-langpack", lang,
|
|
||||||
'LC_MESSAGES', '%s.mo' % domain)
|
|
||||||
|
|
||||||
# first look into the standard locale dir, then into the
|
|
||||||
# langpack locale dir
|
|
||||||
|
|
||||||
# standard mo file
|
|
||||||
if os.path.exists(mofile):
|
|
||||||
if all:
|
|
||||||
result.append(mofile)
|
|
||||||
else:
|
|
||||||
return mofile
|
|
||||||
|
|
||||||
# langpack mofile -> use it
|
|
||||||
if os.path.exists(mofile_lp):
|
|
||||||
if all:
|
|
||||||
result.append(mofile_lp)
|
|
||||||
else:
|
|
||||||
return mofile_lp
|
|
||||||
|
|
||||||
return result
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
# a mapping between absolute .mo file path and Translation object
|
|
||||||
_translations = {}
|
|
||||||
_unspecified = ['unspecified']
|
|
||||||
|
|
||||||
def translation(domain, localedir=None, languages=None,
|
|
||||||
class_=None, fallback=False, codeset=_unspecified):
|
|
||||||
if class_ is None:
|
|
||||||
class_ = GNUTranslations
|
|
||||||
mofiles = find(domain, localedir, languages, all=True)
|
|
||||||
if not mofiles:
|
|
||||||
if fallback:
|
|
||||||
return NullTranslations()
|
|
||||||
from errno import ENOENT
|
|
||||||
raise FileNotFoundError(ENOENT,
|
|
||||||
'No translation file found for domain', domain)
|
|
||||||
# Avoid opening, reading, and parsing the .mo file after it's been done
|
|
||||||
# once.
|
|
||||||
result = None
|
|
||||||
for mofile in mofiles:
|
|
||||||
key = (class_, os.path.abspath(mofile))
|
|
||||||
t = _translations.get(key)
|
|
||||||
if t is None:
|
|
||||||
with open(mofile, 'rb') as fp:
|
|
||||||
t = _translations.setdefault(key, class_(fp))
|
|
||||||
# Copy the translation object to allow setting fallbacks and
|
|
||||||
# output charset. All other instance data is shared with the
|
|
||||||
# cached object.
|
|
||||||
# Delay copy import for speeding up gettext import when .mo files
|
|
||||||
# are not used.
|
|
||||||
import copy
|
|
||||||
t = copy.copy(t)
|
|
||||||
if codeset is not _unspecified:
|
|
||||||
import warnings
|
|
||||||
warnings.warn('parameter codeset is deprecated',
|
|
||||||
DeprecationWarning, 2)
|
|
||||||
if codeset:
|
|
||||||
with warnings.catch_warnings():
|
|
||||||
warnings.filterwarnings('ignore', r'.*\bset_output_charset\b.*',
|
|
||||||
DeprecationWarning)
|
|
||||||
t.set_output_charset(codeset)
|
|
||||||
if result is None:
|
|
||||||
result = t
|
|
||||||
else:
|
|
||||||
result.add_fallback(t)
|
|
||||||
return result
|
|
||||||
|
|
||||||
|
|
||||||
def install(domain, localedir=None, codeset=_unspecified, names=None):
|
|
||||||
t = translation(domain, localedir, fallback=True, codeset=codeset)
|
|
||||||
t.install(names)
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
# a mapping b/w domains and locale directories
|
|
||||||
_localedirs = {}
|
|
||||||
# a mapping b/w domains and codesets
|
|
||||||
_localecodesets = {}
|
|
||||||
# current global domain, `messages' used for compatibility w/ GNU gettext
|
|
||||||
_current_domain = 'messages'
|
|
||||||
|
|
||||||
|
|
||||||
def textdomain(domain=None):
|
|
||||||
global _current_domain
|
|
||||||
if domain is not None:
|
|
||||||
_current_domain = domain
|
|
||||||
return _current_domain
|
|
||||||
|
|
||||||
|
|
||||||
def bindtextdomain(domain, localedir=None):
|
|
||||||
global _localedirs
|
|
||||||
if localedir is not None:
|
|
||||||
_localedirs[domain] = localedir
|
|
||||||
return _localedirs.get(domain, _default_localedir)
|
|
||||||
|
|
||||||
|
|
||||||
def bind_textdomain_codeset(domain, codeset=None):
|
|
||||||
import warnings
|
|
||||||
warnings.warn('bind_textdomain_codeset() is deprecated',
|
|
||||||
DeprecationWarning, 2)
|
|
||||||
global _localecodesets
|
|
||||||
if codeset is not None:
|
|
||||||
_localecodesets[domain] = codeset
|
|
||||||
return _localecodesets.get(domain)
|
|
||||||
|
|
||||||
|
|
||||||
def dgettext(domain, message):
|
|
||||||
try:
|
|
||||||
t = translation(domain, _localedirs.get(domain, None))
|
|
||||||
except OSError:
|
|
||||||
return message
|
|
||||||
return t.gettext(message)
|
|
||||||
|
|
||||||
def ldgettext(domain, message):
|
|
||||||
import warnings
|
|
||||||
warnings.warn('ldgettext() is deprecated, use dgettext() instead',
|
|
||||||
DeprecationWarning, 2)
|
|
||||||
codeset = _localecodesets.get(domain)
|
|
||||||
try:
|
|
||||||
with warnings.catch_warnings():
|
|
||||||
warnings.filterwarnings('ignore', r'.*\bparameter codeset\b.*',
|
|
||||||
DeprecationWarning)
|
|
||||||
t = translation(domain, _localedirs.get(domain, None), codeset=codeset)
|
|
||||||
except OSError:
|
|
||||||
return message.encode(codeset or locale.getpreferredencoding())
|
|
||||||
with warnings.catch_warnings():
|
|
||||||
warnings.filterwarnings('ignore', r'.*\blgettext\b.*',
|
|
||||||
DeprecationWarning)
|
|
||||||
return t.lgettext(message)
|
|
||||||
|
|
||||||
def dngettext(domain, msgid1, msgid2, n):
|
|
||||||
try:
|
|
||||||
t = translation(domain, _localedirs.get(domain, None))
|
|
||||||
except OSError:
|
|
||||||
if n == 1:
|
|
||||||
return msgid1
|
|
||||||
else:
|
|
||||||
return msgid2
|
|
||||||
return t.ngettext(msgid1, msgid2, n)
|
|
||||||
|
|
||||||
def ldngettext(domain, msgid1, msgid2, n):
|
|
||||||
import warnings
|
|
||||||
warnings.warn('ldngettext() is deprecated, use dngettext() instead',
|
|
||||||
DeprecationWarning, 2)
|
|
||||||
codeset = _localecodesets.get(domain)
|
|
||||||
try:
|
|
||||||
with warnings.catch_warnings():
|
|
||||||
warnings.filterwarnings('ignore', r'.*\bparameter codeset\b.*',
|
|
||||||
DeprecationWarning)
|
|
||||||
t = translation(domain, _localedirs.get(domain, None), codeset=codeset)
|
|
||||||
except OSError:
|
|
||||||
if n == 1:
|
|
||||||
tmsg = msgid1
|
|
||||||
else:
|
|
||||||
tmsg = msgid2
|
|
||||||
return tmsg.encode(codeset or locale.getpreferredencoding())
|
|
||||||
with warnings.catch_warnings():
|
|
||||||
warnings.filterwarnings('ignore', r'.*\blngettext\b.*',
|
|
||||||
DeprecationWarning)
|
|
||||||
return t.lngettext(msgid1, msgid2, n)
|
|
||||||
|
|
||||||
|
|
||||||
def dpgettext(domain, context, message):
|
|
||||||
try:
|
|
||||||
t = translation(domain, _localedirs.get(domain, None))
|
|
||||||
except OSError:
|
|
||||||
return message
|
|
||||||
return t.pgettext(context, message)
|
|
||||||
|
|
||||||
|
|
||||||
def dnpgettext(domain, context, msgid1, msgid2, n):
|
|
||||||
try:
|
|
||||||
t = translation(domain, _localedirs.get(domain, None))
|
|
||||||
except OSError:
|
|
||||||
if n == 1:
|
|
||||||
return msgid1
|
|
||||||
else:
|
|
||||||
return msgid2
|
|
||||||
return t.npgettext(context, msgid1, msgid2, n)
|
|
||||||
|
|
||||||
|
|
||||||
def gettext(message):
|
|
||||||
return dgettext(_current_domain, message)
|
|
||||||
|
|
||||||
def lgettext(message):
|
|
||||||
import warnings
|
|
||||||
warnings.warn('lgettext() is deprecated, use gettext() instead',
|
|
||||||
DeprecationWarning, 2)
|
|
||||||
with warnings.catch_warnings():
|
|
||||||
warnings.filterwarnings('ignore', r'.*\bldgettext\b.*',
|
|
||||||
DeprecationWarning)
|
|
||||||
return ldgettext(_current_domain, message)
|
|
||||||
|
|
||||||
def ngettext(msgid1, msgid2, n):
|
|
||||||
return dngettext(_current_domain, msgid1, msgid2, n)
|
|
||||||
|
|
||||||
def lngettext(msgid1, msgid2, n):
|
|
||||||
import warnings
|
|
||||||
warnings.warn('lngettext() is deprecated, use ngettext() instead',
|
|
||||||
DeprecationWarning, 2)
|
|
||||||
with warnings.catch_warnings():
|
|
||||||
warnings.filterwarnings('ignore', r'.*\bldngettext\b.*',
|
|
||||||
DeprecationWarning)
|
|
||||||
return ldngettext(_current_domain, msgid1, msgid2, n)
|
|
||||||
|
|
||||||
|
|
||||||
def pgettext(context, message):
|
|
||||||
return dpgettext(_current_domain, context, message)
|
|
||||||
|
|
||||||
|
|
||||||
def npgettext(context, msgid1, msgid2, n):
|
|
||||||
return dnpgettext(_current_domain, context, msgid1, msgid2, n)
|
|
||||||
|
|
||||||
|
|
||||||
# dcgettext() has been deemed unnecessary and is not implemented.
|
|
||||||
|
|
||||||
# James Henstridge's Catalog constructor from GNOME gettext. Documented usage
|
|
||||||
# was:
|
|
||||||
#
|
|
||||||
# import gettext
|
|
||||||
# cat = gettext.Catalog(PACKAGE, localedir=LOCALEDIR)
|
|
||||||
# _ = cat.gettext
|
|
||||||
# print _('Hello World')
|
|
||||||
|
|
||||||
# The resulting catalog object currently don't support access through a
|
|
||||||
# dictionary API, which was supported (but apparently unused) in GNOME
|
|
||||||
# gettext.
|
|
||||||
|
|
||||||
Catalog = translation
|
|
|
@ -14,7 +14,7 @@
|
||||||
# along with this program. If not, see <http://www.gnu.org/licenses/>.
|
# along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||||
|
|
||||||
|
|
||||||
from . import gettext38
|
import gettext
|
||||||
import os
|
import os
|
||||||
import syslog
|
import syslog
|
||||||
|
|
||||||
|
@ -38,8 +38,8 @@ def switch_language(code='en_US'):
|
||||||
def my_gettext(message):
|
def my_gettext(message):
|
||||||
return message
|
return message
|
||||||
elif code:
|
elif code:
|
||||||
translation = gettext38.translation('subiquity', localedir=localedir,
|
translation = gettext.translation(
|
||||||
languages=[code], fallback=True)
|
'subiquity', localedir=localedir, languages=[code], fallback=True)
|
||||||
|
|
||||||
def my_gettext(message):
|
def my_gettext(message):
|
||||||
if not message:
|
if not message:
|
||||||
|
|
|
@ -14,6 +14,7 @@
|
||||||
# along with this program. If not, see <http://www.gnu.org/licenses/>.
|
# along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||||
|
|
||||||
import enum
|
import enum
|
||||||
|
from gettext import pgettext
|
||||||
import ipaddress
|
import ipaddress
|
||||||
import logging
|
import logging
|
||||||
import yaml
|
import yaml
|
||||||
|
@ -21,7 +22,6 @@ from socket import AF_INET, AF_INET6
|
||||||
import attr
|
import attr
|
||||||
from typing import List, Optional
|
from typing import List, Optional
|
||||||
|
|
||||||
from subiquitycore.gettext38 import pgettext
|
|
||||||
from subiquitycore import netplan
|
from subiquitycore import netplan
|
||||||
|
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue