Ethics: Integrate Tone-Damping into the background worker and database

Author: darestack

src/core/database.py

@@ -27,22 +27,23 @@ async def init_db():
         await conn.run_sync(SQLModel.metadata.create_all)
     logger.info("database_initialized", url=settings.DATABASE_URL)
 
-async def get_user_reliability(user_id: str) -> tuple[float, str | None]:
+async def get_user_reliability(user_id: str) -> tuple[float, str | None, int]:
     """
-    Fetch the reliability score and slack_id for a given user using SQLModel.
+    Fetch the reliability score, slack_id, and consecutive firm intervetions.
     """
     async with AsyncSessionLocal() as session:
         statement = select(UserHistory).where(UserHistory.user_id == user_id)
         results = await session.execute(statement)
         user = results.scalar_one_or_none()
 
         if user:
-            return user.reliability_score, user.slack_id
-        return 100.0, None
+            return user.reliability_score, user.slack_id, user.consecutive_firm_interventions
+        return 100.0, None, 0
 
-async def update_user_reliability(user_id: str, was_failure: bool):
+
+async def update_user_reliability(user_id: str, was_failure: bool, tone_used: str = "supportive"):
     """
-    Update historical stats using SQLModel/SQLAlchemy.
+    Update historical stats and track ethical Tone-Damping status.
     """
     async with AsyncSessionLocal() as session:
         statement = select(UserHistory).where(UserHistory.user_id == user_id)
@@ -61,11 +62,20 @@ async def update_user_reliability(user_id: str, was_failure: bool):
             if was_failure:
                 user.failed_commitments += 1
 
+        # Ethical Counter Management
+        if tone_used in ["firm", "confrontational"]:
+            user.consecutive_firm_interventions += 1
+            user.last_intervention_at = datetime.now().isoformat()
+        else:
+            # Cooling-off logic: Reset counter if a supportive/neutral tone is successfuly used
+            user.consecutive_firm_interventions = 0
+        
         # Calculate new score
         user.reliability_score = ((user.total_commitments - user.failed_commitments) / user.total_commitments) * 100
 
         await session.commit()
-        logger.info("reliability_updated", user_id=user_id, new_score=user.reliability_score)
+    logger.info("reliability_updated", user_id=user_id, new_score=user.reliability_score, consecutive_strict=user.consecutive_firm_interventions)
+
 
 async def set_slack_id(user_id: str, slack_id: str):
     """

src/worker.py

@@ -52,13 +52,18 @@ async def process_commitment_eval(
     burnout = await brain.detect_burnout(check_in)
     logger.info("burnout_detected", user_id=user_id, risk=burnout.is_at_risk)
 
-    # 4. Fetch Historical Reliability (State-aware context)
-    reliability, slack_id = await get_user_reliability(user_id)
+    # 4. Fetch Historical Reliability & Ethical Tracking status
+    reliability, slack_id, consecutive_firm = await get_user_reliability(user_id)
 
-    # 5. Final Decision & Tone Adaptation (Behavioral calibration)
+    # 5. Final Decision & Tone Adaptation (Behavioral + Ethical calibration)
     decision = await brain.adapt_tone(
-        excuse, risk, burnout, reliability_score=reliability
+        excuse, 
+        risk, 
+        burnout, 
+        reliability_score=reliability,
+        consecutive_firm_calls=consecutive_firm
     )
+
     logger.info(
         "agent_decision",
         user_id=user_id,
@@ -67,9 +72,10 @@ async def process_commitment_eval(
         message=decision.message,
     )
 
-    # 6. Persist results for Heatmap tracking
+    # 6. Persist results for Heatmap tracking & Ethical Cooling-off state
     is_failure = excuse.category != ExcuseCategory.LEGITIMATE
-    await update_user_reliability(user_id, was_failure=is_failure)
+    await update_user_reliability(user_id, was_failure=is_failure, tone_used=decision.tone)
+
 
     # 7. Accountability Logic: Proactive Follow-up
     # Triggered based on calculated risk thresholds