feat(anonymisation): add activity_anonymized, activity_version_anonym…

…ized table and query

app/commands.py

@@ -357,14 +357,19 @@ def sync_brevo_command(pipeline_names, verbose):
     app.logger.info("Process sync companies with Brevo done")
 
 
-@app.cli.command("migrate_anonymize_mission", with_appcontext=True)
+@app.cli.command("migrate_anonymize_data", with_appcontext=True)
 @click.argument("time_interval")
-def migrate_anonymize_mission(time_interval):
+@click.option(
+    "--verbose",
+    is_flag=True,
+    help="Enable verbose mode for more detailed output",
+)
+def migrate_anonymize_mission(time_interval, verbose):
     """
     Migrate data to anonymized tables.
     You can specify time interval as arguments.
     """
-    from app.services.anonymize_tables import migrate_anonymize_mission
+    from app.services.anonymize_tables import migrate_anonymized_data
 
     if not time_interval:
         print(
@@ -374,6 +379,6 @@ def migrate_anonymize_mission(time_interval):
 
     app.logger.info("Process with data migration and anonymization began")
 
-    migrate_anonymize_mission(time_interval)
+    migrate_anonymized_data(time_interval, verbose=verbose)
 
     app.logger.info("Process with data migration and anonymization done")

app/models/__init__.py

@@ -31,3 +31,5 @@
 from .user_survey_actions import UserSurveyActions
 from .user_agreement import UserAgreement
 from .anonymized.mission import MissionAnonymized
+from .anonymized.activity import ActivityAnonymized
+from .anonymized.activity_version import ActivityVersionAnonymized

app/models/anonymized/activity.py

@@ -0,0 +1,25 @@
+from app import db
+from app.models.activity import Activity
+
+
+class ActivityAnonymized(Activity):
+    backref_base_name = "activity_anonymized"
+    __mapper_args__ = {"concrete": True}
+
+    id = db.Column(db.Integer, primary_key=True)
+    type = db.Column(db.String(8), nullable=True)
+    user_id = db.Column(db.Integer, nullable=True)
+    submitter_id = db.Column(db.Integer, nullable=True)
+    mission_id = db.Column(db.Integer, nullable=True)
+    dismiss_author_id = db.Column(db.Integer, nullable=True)
+    dismissed_at = db.Column(db.DateTime, nullable=True)
+    creation_time = db.Column(db.DateTime, nullable=True)
+    reception_time = db.Column(db.DateTime, nullable=True)
+    start_time = db.Column(db.DateTime, nullable=True)
+    end_time = db.Column(db.DateTime, nullable=True)
+    last_update_time = db.Column(db.DateTime, nullable=True)
+    last_submitter_id = db.Column(db.Integer, nullable=True)
+    dismiss_context = db.Column(db.JSON, nullable=True)
+
+    def __repr__(self):
+        return f"<ActivityAnonymized(id={self.id}, type={self.type}, creation_time={self.creation_time})>"

app/models/anonymized/activity_version.py

@@ -0,0 +1,20 @@
+from app import db
+from app.models.activity_version import ActivityVersion
+
+
+class ActivityVersionAnonymized(ActivityVersion):
+    backref_base_name = "activity_version_anonymized"
+    __mapper_args__ = {"concrete": True}
+
+    id = db.Column(db.Integer, primary_key=True)
+    activity_id = db.Column(db.Integer, nullable=True)
+    version_number = db.Column(db.Integer, nullable=True)
+    submitter_id = db.Column(db.Integer, nullable=True)
+    creation_time = db.Column(db.DateTime, nullable=True)
+    reception_time = db.Column(db.DateTime, nullable=True)
+    start_time = db.Column(db.DateTime, nullable=True)
+    end_time = db.Column(db.DateTime, nullable=True)
+    context = db.Column(db.JSON, nullable=True)
+
+    def __repr__(self):
+        return f"<ActivityVersionAnonymized(id={self.id}, activity_id={self.activity_id}, version_number={self.version_number})>"