(self, project: str, message: dict)
| 45 | session.commit() |
| 46 | |
| 47 | def add_message_to_project(self, project: str, message: dict): |
| 48 | with Session(self.engine) as session: |
| 49 | project_state = session.query(Projects).filter(Projects.project == project).first() |
| 50 | if project_state: |
| 51 | message_stack = json.loads(project_state.message_stack_json) |
| 52 | message_stack.append(message) |
| 53 | project_state.message_stack_json = json.dumps(message_stack) |
| 54 | session.commit() |
| 55 | else: |
| 56 | message_stack = [message] |
| 57 | project_state = Projects(project=project, message_stack_json=json.dumps(message_stack)) |
| 58 | session.add(project_state) |
| 59 | session.commit() |
| 60 | |
| 61 | def add_message_from_devika(self, project: str, message: str): |
| 62 | new_message = self.new_message() |
no test coverage detected