|
from src.extensions import db |
|
import datetime |
|
|
|
class MonitoringSource(db.Model): |
|
__tablename__ = 'monitoring_sources' |
|
id = db.Column(db.Integer, primary_key=True) |
|
name = db.Column(db.String, nullable=False) |
|
url = db.Column(db.String, unique=True, nullable=False) |
|
type = db.Column(db.String, nullable=False) |
|
frequency_minutes = db.Column(db.Integer, default=1440) |
|
last_checked = db.Column(db.DateTime) |
|
is_active = db.Column(db.Boolean, default=True) |
|
created_at = db.Column(db.DateTime, default=datetime.datetime.utcnow) |
|
|
|
|
|
events = db.relationship('MonitoredEvent', backref='source', lazy=True) |
|
|
|
def __repr__(self): |
|
return f'<MonitoringSource {self.id}: {self.name}>' |
|
|
|
class MonitoredEvent(db.Model): |
|
__tablename__ = 'monitored_events' |
|
id = db.Column(db.Integer, primary_key=True) |
|
source_id = db.Column(db.Integer, db.ForeignKey('monitoring_sources.id'), nullable=False) |
|
detected_at = db.Column(db.DateTime, default=datetime.datetime.utcnow) |
|
event_summary = db.Column(db.Text, nullable=False) |
|
event_details = db.Column(db.Text) |
|
relevance_score = db.Column(db.Float) |
|
related_legislation_id = db.Column(db.Integer, db.ForeignKey('legislation.id')) |
|
status = db.Column(db.String, default='New') |
|
|
|
|
|
recommendations = db.relationship('Recommendation', backref='source_event', lazy=True) |
|
|
|
def __repr__(self): |
|
return f'<MonitoredEvent {self.id} from Source {self.source_id}>' |
|
|
|
|