import { startListening, stopListening } from '../../domain/mqttService';
import { openGenerator } from '../../API/exam/generatorAPI';
import {
  openDetector,
  prepareForAcquisition,
} from '../../API/exam/detectorAPI';
import {
  startListening as startListeningForDeviceOfGenerator,
  stopListening as stopListeningForDeviceOfGenerator,
} from '../../domain/mqttServiceForDevice';

const prepare = async () => {
  try {
    console.log('[prepare] Preparing for inspection...');
    // Start listening for MQTT messages
    startListening();
    startListeningForDeviceOfGenerator();
    console.log('[prepare] Started listening to MQTT messages.');
    // Open the generator device
    await openGenerator();
    console.log('[prepare] Generator device opened.');
    // Open the detector device
    await openDetector();
    console.log('[prepare] Detector device opened.');
    prepareForAcquisition('PrepareAcquisition', '', '', '');
    console.log('[prepare] Preparation for inspection completed.');
  } catch (error) {
    console.error('[prepare] Failed to prepare for inspection:', error);
  }
};

const unprepare = () => {
  console.log('[unprepare] Unpreparing for inspection...');
  // Stop listening to MQTT messages
  stopListening();
  stopListeningForDeviceOfGenerator();
  console.log('[unprepare] Stopped listening to MQTT messages.');
};
export { unprepare };
export default prepare;