Update core/true_arf_oss.py

core/true_arf_oss.py

@@ -918,4 +918,37 @@ async def get_mock_true_arf_oss(config: Optional[Dict[str, Any]] = None) -> True
                 }
             }
     
-    return MockTrue
+    return MockTrueARFOSS(config)
+
+# ============================================================================
+# MAIN ENTRY POINT
+# ============================================================================
+
+if __name__ == "__main__":
+    # Test the implementation
+    import asyncio
+    
+    async def test():
+        # Create test scenario
+        scenario = {
+            "component": "redis_cache",
+            "telemetry": [
+                {"timestamp": time.time() - 60, "metric": "latency_p99", "value": 100},
+                {"timestamp": time.time() - 50, "metric": "latency_p99", "value": 120},
+                {"timestamp": time.time() - 40, "metric": "latency_p99", "value": 150},
+                {"timestamp": time.time() - 30, "metric": "latency_p99", "value": 300},
+                {"timestamp": time.time() - 20, "metric": "latency_p99", "value": 450},
+                {"timestamp": time.time() - 10, "metric": "latency_p99", "value": 520},
+            ],
+            "context": {
+                "environment": "production",
+                "severity": "high",
+                "error_rate": 0.08,
+            }
+        }
+        
+        arf = await get_true_arf_oss()
+        result = await arf.analyze_scenario("Test Cache Latency", scenario)
+        print("Test Result:", json.dumps(result, indent=2, default=str))
+    
+    asyncio.run(test())