craftbeerpi4-pione/cbpi/http_endpoints/http_upload.py

from cbpi.controller.upload_controller import UploadController
from cbpi.api.dataclasses import Props, Step
from aiohttp import web
from cbpi.api import *
import logging

class UploadHttpEndpoints():

    def __init__(self, cbpi):
        self.cbpi = cbpi
        self.controller : UploadController = cbpi.upload
        self.cbpi.register(self, "/upload")


    @request_mapping(path='/', method="POST", auth_required=False)
    async def FileUpload(self, request):
        data = await request.post()
        await self.controller.FileUpload(data)
        return web.Response(status=200)




    @request_mapping(path='/kbh', method="GET", auth_required=False)
    async def get_kbh_list(self, request):
        """

        ---
        description: Get Recipe list from Kleiner Brauhelfer 
        tags:
        - Upload
        responses:
            "200":
                description: successful operation
        """

        kbh_list = await self.controller.get_kbh_recipes()
        return web.json_response(kbh_list)

    @request_mapping(path='/kbh', method="POST", auth_required=False)
    async def create_kbh_recipe(self, request):
        """

        ---
        description: Create Recipe from KBH database with selected ID
        tags:
        - Upload
        parameters:
        - name: "id"
          in: "body"
          description: "Recipe ID: {'id': ID}"
          required: true
          type: "string"
        responses:
            "200":
                description: successful operation
        """

        kbh_id = await request.json()
        await self.controller.kbh_recipe_creation(kbh_id['id'])
        return web.Response(status=200)

    @request_mapping(path='/xml', method="GET", auth_required=False)
    async def get_xml_list(self, request):
        """

        ---
        description: Get recipe list from xml file
        tags:
        - Upload
        responses:
            "200":
                description: successful operation
        """

        xml_list = await self.controller.get_xml_recipes()

        return web.json_response(xml_list)

    @request_mapping(path='/xml', method="POST", auth_required=False)
    async def create_xml_recipe(self, request):
        """

        ---
        description: Create recipe from xml file with selected id
        tags:
        - Upload
        parameters:
        - name: "id"
          in: "body"
          description: "Recipe ID: {'id': ID}"
          required: true
          type: "string"

        responses:
            "200":
                description: successful operation
        """

        xml_id = await request.json()
        await self.controller.xml_recipe_creation(xml_id['id'])
        return web.Response(status=200)

    @request_mapping(path='/json', method="GET", auth_required=False)
    async def get_json_list(self, request):
        """

        ---
        description: Get recipe list from json file
        tags:
        - Upload
        responses:
            "200":
                description: successful operation
        """

        json_list = await self.controller.get_json_recipes()

        return web.json_response(json_list)

    @request_mapping(path='/json', method="POST", auth_required=False)
    async def create_json_recipe(self, request):
        """

        ---
        description: Create recipe from json file with selected id
        tags:
        - Upload
        parameters:
        - name: "id"
          in: "body"
          description: "Recipe ID: {'id': ID}"
          required: true
          type: "string"

        responses:
            "200":
                description: successful operation
        """

        json_id = await request.json()
        await self.controller.json_recipe_creation(json_id['id'])
        return web.Response(status=200)

    @request_mapping(path='/bf/{offset}/', method="POST", auth_required=False)
    async def get_bf_list(self, request):
        """

        ---
        description: Get recipe list from Brewfather App
        tags:
        - Upload
        responses:
            "200":
                description: successful operation
        """
        offset = request.match_info['offset']
        bf_list = await self.controller.get_brewfather_recipes(offset)

        return web.json_response(bf_list)

    @request_mapping(path='/bfupdate/', method="GET", auth_required=False)
    async def get_bf_update(self, request):
        """

        ---
        description: Get recipe list update from Brewfather App
        tags:
        - Upload
        responses:
            "200":
                description: successful operation
        """
        #offset = request.match_info['offset']
        bf_list = await self.controller.get_brewfather_recipes()
        self.cbpi.ws.send(dict(topic="bfupdate", data=bf_list))
        return web.Response(status=200)

    @request_mapping(path='/bf', method="POST", auth_required=False)
    async def create_bf_recipe(self, request):
        """

        ---
        description: Create recipe from Brewfather Web App with selected id
        tags:
        - Upload
        parameters:
        - name: "id"
          in: "body"
          description: "Recipe ID: {'id': ID}"
          required: true
          type: "string"

        responses:
            "200":
                description: successful operation
        """

        bf_id = await request.json()
        await self.controller.bf_recipe_creation(bf_id['id'])
        return web.Response(status=200)

    @request_mapping(path="/getpath", auth_required=False)
    async def http_getpath(self, request):
        
        """

        ---
        description: get path for recipe creation
        tags:
        - Upload
        responses:
            "200":
                description: successful operation
        """
        return  web.json_response(data=self.controller.get_creation_path())