Compare commits

...

3 commits

View file

@ -11,7 +11,7 @@ from sass import CompileError
from sassutils.builder import Manifest from sassutils.builder import Manifest
from importlib.metadata import version as _get_version from importlib.metadata import version as _get_version
from .codecs import quote_css_string from .codecs import quote_css_string, want_bytes, want_bytes
from .validators import must_be from .validators import must_be
from .asgi import _MiddlewareFactory, ASGIApp, ASGIReceive, ASGIScope, ASGISend from .asgi import _MiddlewareFactory, ASGIApp, ASGIReceive, ASGIScope, ASGISend
from . import __version__ as _suou_version from . import __version__ as _suou_version
@ -83,16 +83,7 @@ class SassAsyncMiddleware(_MiddlewareFactory):
break break
except CompileError as e: except CompileError as e:
logger.error(str(e)) logger.error(str(e))
await send({ resp_body = '\n'.join([
'type': 'http.response.start',
'status': self.error_status,
'headers': [
(b'Content-Type', b'text/css; charset=utf-8'),
]
})
await send({
'type': 'http.response.body',
'body': '\n'.join([
'/*', '/*',
str(e), str(e),
'***', '***',
@ -109,6 +100,25 @@ class SassAsyncMiddleware(_MiddlewareFactory):
' user-select: text;' ' user-select: text;'
'}' '}'
]).encode('utf-8') ]).encode('utf-8')
await send({
'type': 'http.response.start',
'status': self.error_status,
'headers': [
(b'Content-Type', b'text/css; charset=utf-8'),
(b'Content-Length', want_bytes(f'{len(resp_body)}'))
]
})
await send({
'type': 'http.response.body',
'body': resp_body
})
await send({
'type': 'http.response.start',
'status': self.error_status,
'headers': [
(b'Content-Type', b'text/css; charset=utf-8'),
]
}) })
async def _read_file(path): async def _read_file(path):
@ -120,23 +130,21 @@ class SassAsyncMiddleware(_MiddlewareFactory):
else: else:
break break
resp_body = b''
async for chunk in _read_file(os.path.join(package_dir, result)): async for chunk in _read_file(os.path.join(package_dir, result)):
resp_body += chunk await send({
'type': 'http.response.body',
'body': chunk
})
await send({ await send({
'type': 'http.response.start', 'type': 'http.response.start',
'status': 200, 'status': 200,
'headers': [ 'headers': [
(b'Content-Type', b'text/css; charset=utf-8'), (b'Content-Type', b'text/css; charset=utf-8'),
(b'Content-Length', want_bytes(f'{len(resp_body)}'))
] ]
}) })
await send({
'type': 'http.response.body',
'body': resp_body
})
await self.app(scope, receive, send) await self.app(scope, receive, send)