X-Git-Url: https://apps.delaporte.us/gitweb/matrix-goal-bot.git/blobdiff_plain/3fbc817001f4e0bd0590b2bf3509e4bfc286919f..d56541ea72dcddf4f67fdfe5d2627533265bc657:/goals/db.py diff --git a/goals/db.py b/goals/db.py index 0a1d16c..8a7aff4 100644 --- a/goals/db.py +++ b/goals/db.py @@ -2,7 +2,7 @@ import logging import os from datetime import datetime as dt -from sqlmodel import Field, Session, SQLModel, create_engine, select, text +from sqlmodel import Field, Session, SQLModel, create_engine, select, text, Relationship ## Todo List # - [ ] goal / vision / task @@ -33,6 +33,7 @@ class Goal(SQLModel, table=True): complete_date: dt | None = Field(default=None) vision_id: int | None = Field(default=None, foreign_key="vision.id") notes: str | None = Field(default=None) + tasks: list["Task"] = Relationship(back_populates="goal") def __str__(self): return f'{self.name} ({self.id})' @@ -41,12 +42,28 @@ class Task(SQLModel, table=True): name: str = Field(default=None, unique=True) goal_id: int | None = Field(default=None, foreign_key="goal.id") complete_date: dt | None = Field(default=None) + goal: Goal = Relationship(back_populates="tasks") + def __str__(self): + return f'{self.name} ({self.id})' + + +def pretty_print(goal, tasks): + results = [] + results.append(f' ## {goal}') + for task in tasks: + if(task.complete_date): + results.append(f' - [x] {task}') + else: + results.append(f' - [ ] {task}') + return results + class Data(): def __init__(self, db_file = DB_FILE): self.file = db_file self.engine = self.get_engine() + def get_engine(self): return create_engine(f"sqlite:///{self.file}") @@ -58,31 +75,40 @@ class Data(): def print_all_visions(self): pass - def print_all_goals(self): - pass - def print_ophan_tasks(self): pass - def list_goals(self): + def get_all_goals(self): '''List all goals''' with Session(self.engine) as session: cmd = select(Goal).where(Goal.complete_date == None) return session.exec(cmd).all() - def print_goal(self, id, include_finished=False): - '''Includes tasks''' - pass + def get_goal(self, id): + with Session(self.engine) as session: + cmd = select(Goal).where(Goal.id == id) + goal = session.exec(cmd).first() + return (goal, goal.tasks) def complete_vision(self, id): pass def complete_goal(self, id): - pass + with Session(self.engine) as session: + cmd = select(Goal).where(Goal.id == id) + goal = session.exec(cmd).first() + goal.complete_date = dt.today() + session.commit() def complete_task(self, id): - pass + with Session(self.engine) as session: + cmd = select(Task).where(Task.id == id) + task = session.exec(cmd).first() + task.complete_date = dt.today() + goal_id = task.goal_id + session.commit() + return goal_id def add_with_name(self, cls, name): id = -1