Commit c9609c6

committed

JOS-08 - Logic to insert task into DB added

1 parent bf2beda commit c9609c6Copy full SHA for c9609c6

File tree

+36

-11

lines changed

+36

-11

lines changed

Lines changed: 23 additions & 5 deletions

Original file line number	Diff line number	Diff line change
`@@ -1,9 +1,27 @@`
	`1`	`+from database.conecctions import SingletonConnection`
	`2`	`+from sqlalchemy import MetaData`
	`3`	`+import logging`
	`4`	`+import json`
	`5`	`+from models.task_model import Task`
	`6`	`+`
	`7`	`+`
`1`	`8`	`class TaskManagement:`
`2`	`9`	`def __init__(self):`
`3`		`- pass`
`4`		`-`
`5`		`- def create_tasks(self):`
`6`		`- return f"hello from create task controller"`
	`10`	`+ self.connection = SingletonConnection()`
	`11`	`+ self.session = self.connection.get_session()`
	`12`	`+ self.metadata = MetaData()`
	`13`	`+ self.logger = logging.getLogger(__name__)`
	`14`	`+`
	`15`	`+ def create_tasks(self, params):`
	`16`	`+ try:`
	`17`	`+ task = Task(name=params.get("name"), description=params.get(`
	`18`	`+ "description"), priority=params.get("priority"), status=params.get("priority"))`
	`19`	`+ self.session.add(task)`
	`20`	`+ self.session.commit()`
	`21`	`+ except Exception as error:`
	`22`	`+ self.logger.info("Error - %s", str(error))`
	`23`	`+`
	`24`	`+ return f"created task success!!"`
`7`	`25`
`8`	`26`	`def update_task(self):`
`9`	`27`	`pass`
`@@ -12,4 +30,4 @@ def update_status_task(self):`
`12`	`30`	`pass`
`13`	`31`
`14`	`32`	`def get_tasks(self):`
`15`		`- pass`
	`33`	`+ pass`

Lines changed: 13 additions & 6 deletions

Original file line number	Diff line number	Diff line change
`@@ -3,14 +3,16 @@`
`3`	`3`
`4`	`4`
`5`	`5`	`task_routes = Blueprint('routes', __name__)`
	`6`	`+`
	`7`	`+`
`6`	`8`	`class TaskRoutes:`
`7`	`9`
`8`	`10`	`def __init__(self) -> None:`
`9`	`11`	`self.controller = TaskManagement()`
`10`	`12`
`11`	`13`	`def create(self):`
`12`		`-`
`13`		`- return self.controller.create_tasks()`
	`14`	`+ params=request.get_json()`
	`15`	`+ return self.controller.create_tasks(params)`
`14`	`16`
`15`	`17`	`def list_task(self):`
`16`	`18`	`return self.controller.get_tasks()`
`@@ -21,7 +23,12 @@ def update_task(self):`
`21`	`23`	`def update_status_status(self):`
`22`	`24`	`return self.controller.update_status_task()`
`23`	`25`
`24`		`-task_routes.add_url_rule('/create', view_func=TaskRoutes().create, methods=['GET'])`
`25`		`-task_routes.add_url_rule('/list', view_func=TaskRoutes().list_task, methods=['GET'])`
`26`		`-task_routes.add_url_rule('/update', view_func=TaskRoutes().update_task, methods=['PUT'])`
`27`		`-task_routes.add_url_rule('/update/status', view_func=TaskRoutes().update_status_status, methods=['PUT'])`
	`26`	`+`
	`27`	`+task_routes.add_url_rule(`
	`28`	`+ '/create', view_func=TaskRoutes().create, methods=['GET'])`
	`29`	`+task_routes.add_url_rule(`
	`30`	`+ '/list', view_func=TaskRoutes().list_task, methods=['GET'])`
	`31`	`+task_routes.add_url_rule(`
	`32`	`+ '/update', view_func=TaskRoutes().update_task, methods=['PUT'])`
	`33`	`+task_routes.add_url_rule(`
	`34`	`+ '/update/status', view_func=TaskRoutes().update_status_status, methods=['PUT'])`

Comments

(0)