import { getConfig } from './cli/config';

import { Logger } from './logger';
import type { CliRunOptions } from './types';
import { adbLaunch, adbTerminate } from './utils/adb';
import { waitFor } from './utils/wait-for';
import { xcrunLaunch, xcrunTerminate, xcrunUi } from './utils/xcrun';
import { createWebSocketClient } from './websocket';
import type {
  SOCKET_TEST_REQUEST,
  SOCKET_SCROLL_TO_VALUE,
  SOCKET_CLIENT_RESPONSE,
} from './websocketTypes';

const logger = new Logger(process.env.OWL_DEBUG === 'true');

const sendEvent = async (event: SOCKET_TEST_REQUEST) =>
  new Promise(async (resolve, reject) => {
    // Create a websocket client just for this event request/response cycle.
    const actionsWebSocketClient = await createWebSocketClient(
      logger,
      (message) => {
        // Close this connection
        actionsWebSocketClient.close();

        // The message received here indicates the outcome of the action we sent to the app client
        const event = JSON.parse(message) as SOCKET_CLIENT_RESPONSE;

        switch (event.type) {
          case 'DONE':
            resolve(true);
            break;
          case 'NOT_FOUND':
            reject(`Element not found: ${event.testID}`);
            break;
          case 'ERROR':
            reject(`Element error: ${event.testID} - ${event.message}`);
            break;
          default:
            reject('Unknown onMessage event type');
            break;
        }
      }
    );

    actionsWebSocketClient.send(JSON.stringify(event));
  });

export const press = (testID: string) =>
  sendEvent({ type: 'ACTION', action: 'PRESS', testID });

export const longPress = (testID: string) =>
  sendEvent({ type: 'ACTION', action: 'LONG_PRESS', testID });

export const changeText = (testID: string, value: string) =>
  sendEvent({ type: 'ACTION', action: 'CHANGE_TEXT', testID, value });

export const scrollTo = (testID: string, value: SOCKET_SCROLL_TO_VALUE) =>
  sendEvent({ type: 'ACTION', action: 'SCROLL_TO', testID, value });

export const scrollToEnd = (testID: string) =>
  sendEvent({ type: 'ACTION', action: 'SCROLL_TO_END', testID });

export const toExist = (testID: string) =>
  sendEvent({ type: 'LAYOUT', action: 'EXISTS', testID });

export const reload = async () => {
  const args = (global as any).OWL_CLI_ARGS as CliRunOptions;

  if (!args) {
    return;
  }

  const config = await getConfig(args.config);

  if (args.platform === 'ios') {
    if (!config.ios?.device) {
      return Promise.reject('Missing device name');
    }

    await xcrunTerminate({
      debug: config.debug,
      binaryPath: config.ios?.binaryPath,
      device: config.ios.device,
      scheme: config.ios?.scheme,
      configuration: config.ios?.configuration,
    });

    await xcrunLaunch({
      debug: config.debug,
      binaryPath: config.ios?.binaryPath,
      device: config.ios.device,
      scheme: config.ios?.scheme,
      configuration: config.ios?.configuration,
    });

    await waitFor(1000);

    await xcrunUi({
      debug: config.debug,
      device: config.ios.device,
      configuration: config.ios.configuration,
      binaryPath: config.ios.binaryPath,
    });
  }

  if (args.platform === 'android') {
    if (!config.android?.packageName) {
      return Promise.reject('Missing package name');
    }

    await adbTerminate({
      debug: config.debug,
      packageName: config.android.packageName,
    });

    await adbLaunch({
      debug: config.debug,
      packageName: config.android.packageName,
    });

    await waitFor(1000);
  }
};