@@ -20,8 +20,8 @@ class ModerationRepositoryMongo(ModerationRepository):
|
|||||||
def _initialize_db(self):
|
def _initialize_db(self):
|
||||||
"""Inicializa conexión a MongoDB"""
|
"""Inicializa conexión a MongoDB"""
|
||||||
try:
|
try:
|
||||||
from infrastructure.adapters.persistence.mongodb import mongo_db
|
from infrastructure.adapters.persistence.mongodb import mongodb
|
||||||
self.db = mongo_db
|
self.db = mongodb
|
||||||
|
|
||||||
# Obtener o crear colecciones
|
# Obtener o crear colecciones
|
||||||
self.moderation_actions_collection = self.db['moderation_actions']
|
self.moderation_actions_collection = self.db['moderation_actions']
|
||||||
|
|||||||
@@ -20,7 +20,7 @@ class MetricModel(Base):
|
|||||||
entity_id = Column(String, nullable=False)
|
entity_id = Column(String, nullable=False)
|
||||||
entity_type = Column(String, nullable=False)
|
entity_type = Column(String, nullable=False)
|
||||||
timestamp = Column(DateTime, nullable=False, default=datetime.now, index=True)
|
timestamp = Column(DateTime, nullable=False, default=datetime.now, index=True)
|
||||||
metadata = Column(JSON, default={})
|
event_metadata = Column(JSON, default={})
|
||||||
user_id = Column(Integer, nullable=True)
|
user_id = Column(Integer, nullable=True)
|
||||||
|
|
||||||
|
|
||||||
@@ -42,7 +42,7 @@ class MetricsRepositoryPostgres(MetricsRepository):
|
|||||||
entity_id=metric.entity_id,
|
entity_id=metric.entity_id,
|
||||||
entity_type=metric.entity_type,
|
entity_type=metric.entity_type,
|
||||||
timestamp=metric.timestamp,
|
timestamp=metric.timestamp,
|
||||||
metadata=metric.metadata,
|
event_metadata=metric.metadata,
|
||||||
user_id=metric.user_id
|
user_id=metric.user_id
|
||||||
)
|
)
|
||||||
session.add(db_metric)
|
session.add(db_metric)
|
||||||
@@ -68,7 +68,7 @@ class MetricsRepositoryPostgres(MetricsRepository):
|
|||||||
entity_id=m.entity_id,
|
entity_id=m.entity_id,
|
||||||
entity_type=m.entity_type,
|
entity_type=m.entity_type,
|
||||||
timestamp=m.timestamp,
|
timestamp=m.timestamp,
|
||||||
metadata=m.metadata or {},
|
metadata=m.event_metadata or {},
|
||||||
user_id=m.user_id
|
user_id=m.user_id
|
||||||
)
|
)
|
||||||
for m in db_metrics
|
for m in db_metrics
|
||||||
|
|||||||
@@ -16,7 +16,7 @@ from application.services.moderation_services import (
|
|||||||
WarnUserUseCase,
|
WarnUserUseCase,
|
||||||
ReviewContentUseCase
|
ReviewContentUseCase
|
||||||
)
|
)
|
||||||
from infrastructure.adapters.persistence.mongodb import mongo_db
|
from infrastructure.adapters.persistence.mongodb import mongodb
|
||||||
from infrastructure.adapters.persistence.db import get_db
|
from infrastructure.adapters.persistence.db import get_db
|
||||||
from infrastructure.adapters.moderation_repository_mongo import ModerationRepositoryMongo
|
from infrastructure.adapters.moderation_repository_mongo import ModerationRepositoryMongo
|
||||||
from sqlalchemy.orm import Session
|
from sqlalchemy.orm import Session
|
||||||
|
|||||||
Reference in New Issue
Block a user