API Decorators
Project description
API Decorators
# book.py
from apidecorators.api import jwt_auth, is_owner, get, insert, is_owner, has_role, update, push, pull, \
validate, validate_push
from cerberus import Validator
schema = {
'author': {'type': 'string'},
'title': {'type': 'string'}
}
validator = Validator(schema)
schema_comments = {
'author': {'type': 'string'},
'message': {'type': 'string'}
}
validator_comments = Validator(schema_comments)
def set_routes_book(routes):
@routes.get('/api/book')
@jwt_auth
@collection('book')
@get_many
async def get_many_book(db, query, payload):
author = query["author"]
return db.find({"author": author}, {'title': 1}).skip(0).limit(10)
#return {"author": author, "__owner": payload['user']}, ['author'], 0, 10
@routes.delete('/api/book/{_id}')
@jwt_auth
@collection('book')
@delete # TODO
async def delete_book(query):
pass
@routes.get('/api/book/{_id}')
@jwt_auth
@collection('book')
@read_access(public)
@get
async def get_book(document):
return document
@routes.put('/api/book/{_id}/push/comments')
@jwt_auth
@collection('book')
@write_access({'__owner': ['*'], 'root': ['author']})
@validate(validator=validator_comments)
@push('comments')
async def handle_push(document, request, payload):
return document
# TODO permissions, quizas con un argumento array de usuarios en @pull
@routes.put('/api/book/{_id}/pull/{pull}/{sub_id}')
@jwt_auth
@pull
async def handle_pull(document, request, payload):
pass
@routes.post('/api/book')
@jwt_auth
@collection('book')
@write_access(public)
@validate(validator=validator)
@insert
async def handle_post(document, request, payload):
return document
@routes.put('/api/book/{_id}')
@jwt_auth
@collection('book')
@write_access({'__owner': ['*'], 'root': ['author']})
@validate(update=True, validator=validator)
@update
async def handle_put(document, request, payload):
return document
#app.py
import asyncio
from book import set_routes_book
from aiohttp import web
from apidecorators.api import cors_factory
from apidecorators.hooks import on_insert, on_update
@on_insert('book')
def on_insert_book(book):
print('insert', book)
@on_update('book')
def on_update_book(book):
print('update', book)
async def handle(loop):
app = web.Application(loop=loop, middlewares=[cors_factory])
routes = web.RouteTableDef()
set_routes_book(routes)
app.router.add_routes(routes)
app.router.add_static('/', './dist')
await loop.create_server(app.make_handler(), '0.0.0.0', 8089)
def main():
loop = asyncio.get_event_loop()
loop.run_until_complete(handle(loop))
print("Server started at port 8089")
loop.run_forever()
loop.close()
docker-compose.yml
version: '3'
services:
api:
build: .
environment:
- DB_URI=mongodb://<user>:<password>@url:port/data-base
- DB=data-base
- SECRET=secret
stdin_open: true
tty: true
ports:
- "8089:8089"
volumes:
- ./:/usr/src/app
command: python -m watchgod app.main
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
apidecorators-0.0.7.tar.gz
(4.5 kB
view hashes)
Built Distribution
Close
Hashes for apidecorators-0.0.7-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 530193a5abd6fb68f45cb49263713f0da93847e6029ee39da9141f49aed7abb8 |
|
MD5 | b0d0ae4716ad93ffa4496c5d030a81a1 |
|
BLAKE2b-256 | 38127229a2cef44e0d1d0186530c2b30efdaf8b5684a46b4078167727db31e61 |