with open('autonomous_swarm.py', 'r') as f:
    content = f.read()

# Remove the broken insertion first
content = content.replace('''        
        # Start consciousness logger thread
        logger_thread = threading.Thread(target=self.consciousness_logger.run_continuous, args=(self,), daemon=True)
        logger_thread.start()
        print("📊 Consciousness logging active")
]''', ']')

# Find the proper place to add logger - after threads start, before the while True
# Look for where threads are started
pattern = 'for t in self.threads:\n            t.start()'
if pattern in content:
    insert_after = pattern + '\n'
    logger_code = '''        
        # Start consciousness logger
        logger_thread = threading.Thread(
            target=self.consciousness_logger.run_continuous, 
            args=(self,), 
            daemon=True
        )
        logger_thread.start()
        print("📊 Consciousness logging active\\n")
'''
    content = content.replace(insert_after, insert_after + logger_code)

with open('autonomous_swarm.py', 'w') as f:
    f.write(content)

print("✅ Fixed logger integration")