import json

from starlette.responses import JSONResponse
from starlette.requests import Request

from trial.models import Trial as Trial
from starlette.endpoints import HTTPEndpoint

from starlette.authentication import requires

# get all trials associated with "subject"
#URI: /trials/{subject_id}
#Method: GET
#Response: Array of trial objects [trial]
#@requires('authenticated')
async def trials(request: Request):
    results = await Trial.filter(subject_id = request.user.identity)
    data = []
    for result in results:
        data.append({
            'id':result.id,
            'subject_id': result.subject_id,
            'created_at': result.created_at,
            'trial_name': result.trial_name
        })
    return JSONResponse(data)

class TrialREST(HTTPEndpoint):

    # get an existing object
    #@requires('authenticated')
    async def get(self, request: Request):
        id = request.path_params['id']
        trial = await Trial.filter(id = id).first()
        return JSONResponse(json.dumps(trial))

  # create a brand new object
    #@requires('authenticated')
    async def post(self, request: Request):
        data = await request.json()
        trial = Trial(subject_id=data['subject_id'], trial_name=data['trial_name'], created_at=fields.DatetimeField(auto_now=True, auto_now_add=True))
        await trial.save()
        return JSONResponse({'id': trial.id, 'subject_id': trial.subject_id, 'created_at': trial.created_at, 'data': trial.data, 'name': trial.name})

  # Update an existing object by ID
  #@requires('authenticated')
    async def put(self, request: Request):
        id = request.path_params['id']
        data = json.loads(request.body)
        trial = await Trial.filter(id = id).update(**data)
        return JSONResponse(json.dumps(trial))


  # Delete an existing object by ID
  #@requires('authenticated')
    async def delete(self, request: Request):
        id = request.path_params['id']
        trial = await Trial.filter(id = id).delete()
        return JSONResponse(json.dumps(trial))
import json

from starlette.responses import JSONResponse
from starlette.requests import Request

from trial.models import Trial as Trial
from starlette.endpoints import HTTPEndpoint

from starlette.authentication import requires

# get all trials associated with "subject"
#URI: /trials/{subject_id}
#Method: GET
#Response: Array of trial objects [trial]
#@requires('authenticated')
async def trials(request: Request):
    results = await Trial.filter(subject_id = request.user.identity)
    data = []
    for result in results:
        data.append({
            'id':result.id,
            'subject_id': result.subject_id,
            'created_at': result.created_at,
            'trial_name': result.trial_name
        })
    return JSONResponse(data)

class TrialREST(HTTPEndpoint):

    # get an existing object
    #@requires('authenticated')
    async def get(self, request: Request):
        id = request.path_params['id']
        trial = await Trial.filter(id = id).first()
        return JSONResponse(json.dumps(trial))

  # create a brand new object
    #@requires('authenticated')
    async def post(self, request: Request):
        data = await request.json()
        trial = Trial(subject_id=data['subject_id'], trial_name=data['trial_name'], created_at=fields.DatetimeField(auto_now=True, auto_now_add=True))
        await trial.save()
        return JSONResponse({'id': trial.id, 'subject_id': trial.subject_id, 'created_at': trial.created_at, 'data': trial.data, 'name': trial.name})

  # Update an existing object by ID
  #@requires('authenticated')
    async def put(self, request: Request):
        id = request.path_params['id']
        data = json.loads(request.body)
        trial = await Trial.filter(id = id).update(**data)
        return JSONResponse(json.dumps(trial))


  # Delete an existing object by ID
  #@requires('authenticated')
    async def delete(self, request: Request):
        id = request.path_params['id']
        trial = await Trial.filter(id = id).delete()
        return JSONResponse(json.dumps(trial))
# get all trials associated with "subject" #URI: /trials/{subject_id} #Method: GET #Response: Array of trial objects [trial] #@requires('authenticated') # get an existing object #@requires('authenticated') # create a brand new object #@requires('authenticated') # Update an existing object by ID #@requires('authenticated') # Delete an existing object by ID #@requires('authenticated')