from klar import App

app = App()

@app.get('/hello/<name>')
def hello(name: str, times: int = 1):
	return "hello " * times + name

product = {
	"type": "object"
	"properties": {
		"name": {
			"type": "string"
		},
		"price": {
			"type": "number"
		},
	},
	"additionalProperties": False,
}

@app.post('/product')
def create(body: product, db):
	db.products.insert(body)
	return {"ok": True}

from schemas import product

@app.post('/product')
def create(body: product):
	pass

@app.provide('db')
def get_db_connection():
	conn = SomeDB(url="localhost:3349")
	return conn

import redis
app.provide('cache', (redis.Redis, {'host': 'localhost'}))

@get('/article/<article_id>')
def get_article(article_id:int, db, cache):
    pass

from resource import product, catalog

app = App()

app.resources(product, catalog, prefix="/v1")

if __name__ == '__main__':
	app.run()

from schema import product

# curl -X POST $host/v1/product -d @body
def create(body: product, db):
	return db.products.insert(body)

# curl $host/v1/product/$id
def show(product_id: str):
	item = db.products.find_one({_id: product_id})
	return item if item else 404

# curl $host/v1/product?shift=10&limit=10
def query(shift: int, limit: int, db):
	return db.products.find().skip(shift).limit(shift)

# curl -X PATCH $host/v1/product/$id -d @body
def modify(body: product, product_id: str):
	return db.products.update({_id: product_id}, {'$set': body})

# curl -X PUT $host/v1/product/$id -d @body
def replace(body: product, product_id: str):
	return db.products.update({_id: product_id}, body)

# curl -X DELETE $host/v1/product/$id
def destroy(product_id: str):
	return db.products.delete({_id: product_id})

from klar import method

@method('patch')
def like(product_id):
	return db.products.update({_id: product_id}, {'$inc': {'likes': 1}})

# curl -X PATCH $host/v1/product/$id/like

@on(404)
def not_found(req, res):
	print('%s not found' % req.path)
    res.body = "%s not found on this server" % req.path

@on('user-login')
def onlogin(userid, db):
	print('user: %s logged in' % userid)
	db.users.update({_id:userid}, {'$inc': {'logincount': 1}})

def login(emitter):
	emitter.emit('user-login', userid=id)

def jsonp(req, res):
    callback = req.query.get('callback')
    if callback:
        res.body = "%s(%s)" % (callback, json.dumps(body))
        res.headers["Content-Type"] = "application/javascript"

@app.get('/resource') -> jsonp:
	return {"key": "value"}

@app.get('/resource') -> (jsonp, etag):
	return {"key": "value"}

import templates.home

@app.get('/') -> templates.home:
	return {"key": "value"}

@app.get('/'):
	return templates.home({"key": "value"})

import templates.home

import redis

@app.provide('cache')
def cache():
	return redis.Redis(host='localhost', port=6379, db=0)

app.privide('cache', (redis.Redis, {'host': 'localhost'}))

@app.post('/login')
def login(body, session):
	# check body.username and body.password
	if founduser:
		session.set('userid', userid)

@app.post('/login')
def logout(session):
	session.destroy()

@app.get('/admin')
def admin(session):
	if session.get('userid'):
		pass

cookies.get(key, default)
cookies.set(key, value)
cookies.delete(key)

cookies.set(key, value, httponly=True)
cookies.set_for_30_days(key, value)

mongo = {
    "host": "127.0.0.1"
    "port": 27017
}

from pymongo import MongoClient

@app.provide('db')
def db(config):
    return MongoClient(**config.mongo)

@app.get('user/<id>')
def user(id:str):
    pass

from bson.objectid import ObjectId

@app.json_encode(ObjectId)
def encode_objectid(obj):
    return str(obj)