Feature/setup

.gitignore

@@ -1,5 +1,7 @@
 __pycache__/
+node_modules/
 .cache
 *.egg-info/
 *.egg
 .installed.cfg
+db.sqlite3

Makefile

@@ -0,0 +1,8 @@
+test-run:
+	cd tests/interface; mitama run
+
+watch-css:
+	npm run watch-css
+
+build-css:
+	npm run build-css

mitama/app/__init__.py

@@ -1,3 +1,97 @@
 from jinja2 import *
 from .app import App
-from .meta import BaseMetadata
+from .router import Router
+from .builder import Builder
+from .registry import AppRegistry
+from mitama.http import Request, Response
+from pathlib import Path
+from mimetypes import add_type, guess_type
+from abc import ABCMeta, abstractmethod
+import os
+
+add_type('application/json', '.map')
+
+class Controller():
+    '''MVCのControllerの基底クラス
+
+    メソッドを記述すると、それをリクエスト処理に利用できる。
+    ルーティング時にメソッドを特に指定しない場合はhandleメソッドが実行される。
+    非同期関数として定義すること。非同期なので、別プロセスを中継するとかもやりやすい（かもしれない）。
+    :param app: Controllerを起動するAppのインスタンスの参照
+    :param view: Controllerが利用するJinja2のEnvironmentインスタンス
+    '''
+    app = None
+    view = None
+    async def handle(self, request: Request):
+        '''リクエストハンドラ
+
+        ルーティング時に特にメソッド名を指定しない場合にはこのメソッドが起動する。
+        独自にメソッドを定義する場合にも、このメソッドと同じインターフェースを実装しなければならない。
+        :param request: mitama.http.Requestのインスタンス
+        :return: mitama.http.Responseのインスタンス
+        '''
+        pass
+
+class Middleware(metaclass = ABCMeta):
+    '''Requestを加工するMiddlewareの抽象クラス
+
+    processメソッドによって受け取ったRequestを変更し、handler（次のMiddleware、またはControllerのメソッド）に受け渡す。
+    :param app: Middlewareを起動するAppのインスタンスの参照
+    :param view: Middlewareが利用するJinja2のEnvironmentインスタンス
+    '''
+    app = None
+    view = None
+    @abstractmethod
+    async def process(self, request: Request, handler):
+        '''Middlewareのメイン処理
+
+        Middlewareは必ずこのメソッドを実装しなければならない。
+        :param request: mitama.http.Requestのインスタンス
+        :param handler: requestを引数に受け取る関数（Middleware.process、またはControllerのリクエストハンドラ）
+        '''
+        pass
+
+class StaticFileController(Controller):
+    '''静的ファイルを配信するController
+
+    デフォルトではアプリのパッケージ内の :file:`static/` の中身を配信する。
+    '''
+    def __init__(self, *paths):
+        '''初期化処理
+
+        初期化するとき、引数にディレクトリのパスを列挙すると、そのディレクトリが配信される。
+        何も指定されなかった場合、アプリ内の :file:`static/` が配信される。
+        :param *paths: 配信するディレクトリ
+        '''
+        super().__init__()
+        self.paths = list(paths)
+    def __connected__(self):
+        app_mod_dir = Path(os.path.dirname(__file__))
+        self.view = Environment(
+            enable_async=True,
+            loader = FileSystemLoader([
+                self.app.project_dir,
+                app_mod_dir / 'templates',
+                app_mod_dir / '../http/templates'
+            ])
+        )
+        if len(self.paths) == 0:
+            self.paths.append(self.app.install_dir / 'static')
+    async def handle(self, req: Request):
+        for path in self.paths:
+            filename = path / req.params['path']
+            if filename.is_file():
+                mime = guess_type(str(filename)) or 'application/octet-stream'
+                with open(filename) as f:
+                    return Response(body = f.read(), headers={
+                        'content-type': mime[0]
+                    })
+        for path in self.paths:
+            filename = path / '404.html'
+            if filename.is_file():
+                with open(filename) as f:
+                    return await Response(text = f.read(), status = 404, headers = {
+                        'content-type': 'text/html'
+                    })
+        template = self.view.get_template('404.html')
+        return await Response.render(template, req, status = 404)

mitama/app/app.py

@@ -1,14 +1,114 @@
 #!/usr/bin/python
 from aiohttp import web
+from yarl import URL
+from jinja2 import Environment, FileSystemLoader
+from pathlib import Path
+import magic
+import os
+from base64 import b64encode
+from mitama.app.noimage import load_noimage_app
+from mitama.hook import HookRegistry
+from mitama.http import Request, Response
+
+def dataurl(blob):
+    f = magic.Magic(mime = True, uncompress = True)
+    mime = f.from_buffer(blob)
+    return 'data:'+mime+';base64,'+b64encode(blob).decode()
 
 class App:
-    def __init__(self, meta):
-        self.app = web.Application(
-            middlewares = [
-                web.normalize_path_middleware(append_slash = True)
-            ]
-        )
-        self.meta = meta
-        self.name = meta.name
+    template_dir = 'templates'
+    instances = list()
+    description = ""
+    name = ""
+    @property
+    def icon(self):
+        return load_noimage_app()
+    def __init__(self, **kwargs):
+        self.app = web.Application(client_max_size = kwargs["client_max_size"] if "client_max_size" in kwargs else 100*1024*1024)
+        self.screen_name = kwargs['name']
+        self.path = kwargs['path']
+        self.project_dir = Path(kwargs['project_dir']) if 'project_dir' in kwargs else None
+        self.project_root_dir = Path(kwargs['project_root_dir']) if 'project_dir' in kwargs else None
+        self.install_dir = Path(kwargs['install_dir']) if 'project_dir' in kwargs else Path(os.path.dirname(__file__)) / '../http/'
+        for instance in self.instances:
+            instance.app = self
+            instance.view = self.view
+            if hasattr(instance,  '__connected__'):
+                instance.__connected__()
+        hook_registry = HookRegistry()
+        if hasattr(self, 'create_user'):
+            hook_registry.add_create_user_hook(self.create_user)
+        if hasattr(self, 'create_group'):
+            hook_registry.add_create_group_hook(self.create_group)
+        if hasattr(self, 'update_user'):
+            hook_registry.add_update_user_hook(self.update_user)
+        if hasattr(self, 'update_group'):
+            hook_registry.add_update_group_hook(self.update_group)
+        if hasattr(self, 'delete_user'):
+            hook_registry.add_delete_user_hook(self.delete_user)
+        if hasattr(self, 'delete_group'):
+            hook_registry.add_delete_group_hook(self.delete_group)
+        async def handle(request):
+            if not isinstance(request, Request):
+                request = Request.from_request(request)
+            result = await self.router.match(request)
+            if result:
+                request, handle = result
+                return await handle(request)
+            else:
+                return await self.error(request, 404)
+        self.app.router.add_route('*', '/{tail:.*}', handle)
     def __getattr__(self, name):
         return getattr(self.app, name)
+    def set_middleware(self, middlewares):
+        self.app.middlewares.extend(middlewares)
+    def convert_fullurl(self, req, url):
+        scheme= req.scheme
+        hostname = req.host
+        path = self.path
+        if path[0] != '/':
+            path = '/' + path
+        if path[-1] == '/':
+            path = path[0:-2]
+        if url[0] != '/':
+            url = '/' + url
+        return scheme + "://" + hostname + path + url
+    def convert_url(self, url):
+        path = self.path
+        if path[0] != '/':
+            path = '/' + path
+        if path[-1] == '/':
+            path = path[0:-2]
+        if url[0] != '/':
+            url = '/' + url
+        return path + url
+    def revert_url(self, url):
+        path = self.path
+        if path[0] != '/':
+            path = '/' + path
+        if path[-1] == '/':
+            path = path[0:-2]
+        url = str(url.path)
+        url = URL(url[len(path):])
+        return url
+    @property
+    def view(self):
+        self._view= Environment(
+            enable_async = True,
+            loader = FileSystemLoader(self.install_dir / self.template_dir)
+        )
+        def filter_user(arg):
+            return [user for user in arg if user.__class__.__name__ == "User"]
+        def filter_group(arg):
+            return [group for group in arg if group.__class__.__name__ == "Group"]
+        self._view.filters["user"] = filter_user
+        self._view.filters["group"] = filter_group
+        self._view.globals.update(
+            url = self.convert_url,
+            fullurl = self.convert_fullurl,
+            dataurl = dataurl
+        )
+        return self._view
+    async def error(self, request, code):
+        template = self.view.get_template(str(code) + '.html')
+        return await Response.render(template, request)

mitama/app/builder.py

@@ -0,0 +1,26 @@
+import inspect
+import os
+
+class Builder(object):
+    '''Appにメタ情報を入力して生成するビルダー
+
+    プロジェクトディレクトリのパスやインストール先、プロジェクト内のアプリ用ディレクトリのパスをAppに設定し、インスタンスを返却します。
+    特にこれを弄るケースは想定していませんが、独自の挙動を付けたかったら継承して作っても良いかもしれません。
+    アプリのパッケージ直下のAppBuilderが起動されるので、:file:`__init__.py` に :samp:`class AppBuilder(Builder)` を定義してください。
+    '''
+    app = None
+    def __init__(self):
+        self.data = {}
+        pass
+    def set_path(self, path):
+        self.data['path'] = path
+    def set_name(self, name):
+        self.data['name'] = name
+    def set_project_dir(self, path):
+        self.data['project_dir'] = path
+    def set_project_root_dir(self, path):
+        self.data['project_root_dir'] = path
+    def build(self):
+        install_dir = os.path.dirname(inspect.getfile(self.__class__))
+        self.data['install_dir'] = install_dir
+        return self.app(**self.data)

mitama/app/method.py

@@ -0,0 +1,92 @@
+from mitama.app.router import Route
+
+def view(path, handler):
+    '''GET, POSTのルーティング先を指定
+
+    ブラウザで見れる一般的なルーティング先を作成します。
+    :param path: マッチするパス
+    :param handler: リクエストハンドラ
+    :return: Routeインスタンス
+    '''
+    return Route(['GET', 'POST'], path, handler)
+
+def any(path, handler):
+    '''メソッドを考慮しないルーティング先を指定
+
+    メソッドに関係なくマッチするルーティング先を作成します。
+    :param path: マッチするパス
+    :param handler: リクエストハンドラ
+    :return: Routeインスタンス
+    '''
+    return Route(['GET', 'POST', 'PATCH', 'PUT', 'DELETE', 'OPTION', 'HEAD'], path, handler)
+
+def post(path, handler):
+    '''POSTのルーティング先を指定
+
+    POSTメソッドのルーティング先を作成します。
+    :param path: マッチするパス
+    :param handler: リクエストハンドラ
+    :return: Routeインスタンス
+    '''
+    return Route(['POST'], path, handler)
+
+def patch(path, handler):
+    '''PATCHのルーティング先を指定
+
+    PATCHメソッドのルーティング先を作成します。
+    :param path: マッチするパス
+    :param handler: リクエストハンドラ
+    :return: Routeインスタンス
+    '''
+    return Route(['PATCH'], path, handler)
+
+def head(path, handler):
+    '''HEADのルーティング先を指定
+
+    HEADメソッドのルーティング先を作成します。
+    :param path: マッチするパス
+    :param handler: リクエストハンドラ
+    :return: Routeインスタンス
+    '''
+    return Route(['HEAD'], path, handler)
+
+def option(path, handler):
+    '''OPTIONのルーティング先を指定
+
+    OPTIONメソッドのルーティング先を作成します。
+    :param path: マッチするパス
+    :param handler: リクエストハンドラ
+    :return: Routeインスタンス
+    '''
+    return Route(['OPTION'], path, handler)
+
+def put(path, handler):
+    '''PUTのルーティング先を指定
+
+    PUTメソッドのルーティング先を作成します。
+    :param path: マッチするパス
+    :param handler: リクエストハンドラ
+    :return: Routeインスタンス
+    '''
+    return Route(['PUT'], path, handler)
+
+def get(path, handler):
+    '''GETのルーティング先を指定
+
+    GETメソッドのルーティング先を作成します。
+    :param path: マッチするパス
+    :param handler: リクエストハンドラ
+    :return: Routeインスタンス
+    '''
+    return Route(['GET'], path, handler)
+
+def delete(path, handler):
+    '''DELETEのルーティング先を指定
+
+    DELETEメソッドのルーティング先を作成します。
+    :param path: マッチするパス
+    :param handler: リクエストハンドラ
+    :return: Routeインスタンス
+    '''
+    return Route(['DELETE'], path, handler)
+

mitama/app/middlewares.py

@@ -0,0 +1,21 @@
+from mitama.http import Response
+from mitama.auth import AuthorizationError, check_jwt
+from mitama.app import Middleware
+import urllib
+
+class SessionMiddleware(Middleware):
+    '''ログイン判定ミドルウェア
+
+    ログインしていないユーザーがアクセスした場合、/login?redirect_to=<URL>にリダイレクトします。
+    '''
+    async def process(self, request, handler):
+        sess = await request.session()
+        try:
+            if 'jwt_token' in sess:
+                request.user = check_jwt(sess['jwt_token'])
+            else:
+                return Response.redirect('/login?redirect_to='+urllib.parse.quote(str(request.url), safe=''))
+        except Exception as err:
+            return Response.redirect('/login?redirect_to='+urllib.parse.quote(str(request.url), safe=''))
+        return await handler(request)
+