progress on connecting db

app/models/__init__.py

@@ -0,0 +1 @@
+from .transactions import Transaction

app/models/transactions.py

@@ -0,0 +1,25 @@
+from app.extensions import db
+from datetime import datetime, timezone
+
+class Transaction(db.Model):
+    __tablename__ = "transactions"
+
+    id = db.Column(
+        db.Integer,
+        primary_key=True,
+        autoincrement=True,
+    )
+    transaction_id = db.Column(db.String(50), nullable=False)
+    account_id = db.Column(db.String(50), nullable=True)
+    customer_id = db.Column(db.String(50), nullable=True)
+    type = db.Column(db.String(50), nullable=False)
+    channel = db.Column(db.String(50), nullable=False)
+    created_at = db.Column(db.DateTime, default=datetime.now(timezone.utc))
+    updated_at = db.Column(db.DateTime, default=datetime.now(timezone.utc), onupdate=datetime.now(timezone.utc))
+
+    def __repr__(self):
+        return f'<Transaction {self.id}>'
+
+    @classmethod
+    def get_transaction_by_id(cls, transaction_id):
+        return cls.query.get(transaction_id)

wsgi.py

@@ -32,4 +32,4 @@ if __name__ != "__main__":
     wsgi_app = app
 
     # Start kafka in a thread
-    # threading.Thread(target=start_kafka_consumer, daemon=True).start()
+    threading.Thread(target=start_kafka_consumer, daemon=True).start()