import type { WatchEvent, WatchEventCallbacks } from './definitions';
import {
  _subscribeNativeApplicationContextEvent,
  _subscribeNativeFileEvents,
  _subscribeNativeMessageEvent,
  _subscribeNativeUserInfoEvent,
  _subscribeToNativeInstalledEvent,
  _subscribeToNativePairedEvent,
  _subscribeToNativeReachabilityEvent,
  _subscribeNativeApplicationContextErrorEvent,
  _subscribeNativeUserInfoErrorEvent,
  _subscribeNativeFileReceivedEvent,
  _subscribeNativeFileReceivedErrorEvent,
  _subscribeNativeActivationErrorEvent,
  _subscribeNativeSesssionBecameInactiveErrorEvent,
  _subscribeNativeSessionDidDeactivateErrorEvent,
  _subscribeNativeApplicationContextReceivedErrorEvent,
} from './subscriptions';
import type { AddListenerFn } from './subscriptions';
import { _addListener, _once } from '../native-module';
import type { WatchPayload, QueuedFile } from '../native-module';

export type UnsubscribeFn = () => void;

function listen<E extends WatchEvent>(
  event: E,
  cb: any,
  listener?: AddListenerFn
): UnsubscribeFn {
  switch (event) {
    case 'reachability':
      return _subscribeToNativeReachabilityEvent(cb, listener);
    case 'file':
      return _subscribeNativeFileEvents(cb, listener);
    case 'application-context':
      return _subscribeNativeApplicationContextEvent(cb, listener);
    case 'user-info':
      return _subscribeNativeUserInfoEvent(cb, listener);
    case 'file-received':
      return _subscribeNativeFileReceivedEvent(cb, listener);
    case 'message':
      return _subscribeNativeMessageEvent(cb, listener);
    case 'paired':
      return _subscribeToNativePairedEvent(cb, listener);
    case 'installed':
      return _subscribeToNativeInstalledEvent(cb, listener);
    case 'application-context-error':
      return _subscribeNativeApplicationContextErrorEvent(cb, listener);
    case 'application-context-received-error':
      return _subscribeNativeApplicationContextReceivedErrorEvent(cb, listener);
    case 'user-info-error':
      return _subscribeNativeUserInfoErrorEvent(cb, listener);
    case 'file-received-error':
      return _subscribeNativeFileReceivedErrorEvent(cb, listener);
    case 'activation-error':
      return _subscribeNativeActivationErrorEvent(cb, listener);
    case 'session-became-inactive':
      return _subscribeNativeSesssionBecameInactiveErrorEvent(cb, listener);
    case 'session-did-deactivate':
      return _subscribeNativeSessionDidDeactivateErrorEvent(cb, listener);
    default:
      throw new Error(`Unknown watch event "${event}"`);
  }
}

function addListener(
  event: 'reachability',
  cb: WatchEventCallbacks['reachability']
): UnsubscribeFn;

function addListener(
  event: 'file',
  cb: WatchEventCallbacks['file']
): UnsubscribeFn;

function addListener<Context extends WatchPayload = WatchPayload>(
  event: 'application-context',
  cb: WatchEventCallbacks<Context>['application-context']
): UnsubscribeFn;

function addListener<UserInfo extends WatchPayload = WatchPayload>(
  event: 'user-info',
  cb: WatchEventCallbacks<UserInfo>['user-info']
): UnsubscribeFn;

function addListener(
  event: 'file-received',
  cb: WatchEventCallbacks<QueuedFile>['file-received']
): UnsubscribeFn;

function addListener<
  MessageFromWatch extends WatchPayload = WatchPayload,
  ReplyMessage extends WatchPayload = WatchPayload
>(
  event: 'message',
  cb: WatchEventCallbacks<MessageFromWatch, ReplyMessage>['message']
): UnsubscribeFn;

function addListener(
  event: 'paired',
  cb: WatchEventCallbacks['paired']
): UnsubscribeFn;

function addListener(
  event: 'installed',
  cb: WatchEventCallbacks['installed']
): UnsubscribeFn;

function addListener<Context extends WatchPayload = WatchPayload>(
  event: 'application-context-error',
  cb: WatchEventCallbacks<Context>['application-context-error']
): UnsubscribeFn;

function addListener<Context extends WatchPayload = WatchPayload>(
  event: 'application-context-received-error',
  cb: WatchEventCallbacks<Context>['application-context-received-error']
): UnsubscribeFn;

function addListener<Context extends WatchPayload = WatchPayload>(
  event: 'activation-error',
  cb: WatchEventCallbacks<Context>['activation-error']
): UnsubscribeFn;

function addListener<Context extends WatchPayload = WatchPayload>(
  event: 'session-became-inactive',
  cb: WatchEventCallbacks<Context>['session-became-inactive']
): UnsubscribeFn;

function addListener<Context extends WatchPayload = WatchPayload>(
  event: 'session-did-deactivate',
  cb: WatchEventCallbacks<Context>['session-did-deactivate']
): UnsubscribeFn;

function addListener<Context extends WatchPayload = WatchPayload>(
  event: 'user-info-error',
  cb: WatchEventCallbacks<Context>['user-info-error']
): UnsubscribeFn;

function addListener<Context extends WatchPayload = WatchPayload>(
  event: 'file-received-error',
  cb: WatchEventCallbacks<Context>['file-received-error']
): UnsubscribeFn;

function addListener(event: WatchEvent, cb: any): UnsubscribeFn {
  return listen(event, cb, _addListener);
}

function once(
  event: 'reachability',
  cb: WatchEventCallbacks['reachability']
): UnsubscribeFn;

function once(
  event: 'reachability'
): Promise<Parameters<WatchEventCallbacks['reachability']>[0]>;

function once(event: 'file', cb: WatchEventCallbacks['file']): UnsubscribeFn;

function once(
  event: 'file'
): Promise<Parameters<WatchEventCallbacks['file']>[0]>;

function once<Context extends WatchPayload = WatchPayload>(
  event: 'application-context',
  cb: WatchEventCallbacks<Context>['application-context']
): UnsubscribeFn;

function once<Context extends WatchPayload = WatchPayload>(
  event: 'application-context'
): Promise<Parameters<WatchEventCallbacks<Context>['application-context']>[0]>;

function once<UserInfo extends WatchPayload = WatchPayload>(
  event: 'user-info',
  cb: WatchEventCallbacks<UserInfo>['user-info']
): UnsubscribeFn;

function once<UserInfo extends WatchPayload = WatchPayload>(
  event: 'user-info'
): Promise<Parameters<WatchEventCallbacks<UserInfo>['user-info']>[0]>;

function once(
  event: 'file-received',
  cb: WatchEventCallbacks['file-received']
): UnsubscribeFn;

function once(
  event: 'file-received'
): Promise<Parameters<WatchEventCallbacks['file-received']>[0]>;

function once<
  MessageFromWatch extends WatchPayload = WatchPayload,
  ReplyMessage extends WatchPayload = WatchPayload
>(
  event: 'message',
  cb: WatchEventCallbacks<MessageFromWatch, ReplyMessage>['message']
): UnsubscribeFn;

function once<
  MessageFromWatch extends WatchPayload = WatchPayload,
  ReplyMessage extends WatchPayload = WatchPayload
>(
  event: 'message'
): Promise<
  Parameters<WatchEventCallbacks<MessageFromWatch, ReplyMessage>['message']>
>;

function once(
  event: 'paired',
  cb: WatchEventCallbacks['paired']
): UnsubscribeFn;

function once(
  event: 'paired'
): Promise<Parameters<WatchEventCallbacks['paired']>[0]>;

function once(
  event: 'installed',
  cb: WatchEventCallbacks['installed']
): UnsubscribeFn;

function once(
  event: 'installed'
): Promise<Parameters<WatchEventCallbacks['installed']>[0]>;

function once<Context extends WatchPayload = WatchPayload>(
  event: 'application-context-error',
  cb: WatchEventCallbacks<Context>['application-context-error']
): UnsubscribeFn;

function once<Context extends WatchPayload = WatchPayload>(
  event: 'application-context-error'
): Promise<
  Parameters<WatchEventCallbacks<Context>['application-context-error']>[0]
>;

function once<Context extends WatchPayload = WatchPayload>(
  event: 'application-context-received-error',
  cb: WatchEventCallbacks<Context>['application-context-received-error']
): UnsubscribeFn;

function once<Context extends WatchPayload = WatchPayload>(
  event: 'application-context-received-error'
): Promise<
  Parameters<
    WatchEventCallbacks<Context>['application-context-received-error']
  >[0]
>;

function once<Context extends WatchPayload = WatchPayload>(
  event: 'activation-error',
  cb: WatchEventCallbacks<Context>['activation-error']
): UnsubscribeFn;

function once<Context extends WatchPayload = WatchPayload>(
  event: 'activation-error'
): Promise<Parameters<WatchEventCallbacks<Context>['activation-error']>[0]>;

function once<Context extends WatchPayload = WatchPayload>(
  event: 'session-became-inactive',
  cb: WatchEventCallbacks<Context>['session-became-inactive']
): UnsubscribeFn;

function once<Context extends WatchPayload = WatchPayload>(
  event: 'session-became-inactive'
): Promise<
  Parameters<WatchEventCallbacks<Context>['session-became-inactive']>[0]
>;

function once<Context extends WatchPayload = WatchPayload>(
  event: 'session-did-deactivate',
  cb: WatchEventCallbacks<Context>['session-did-deactivate']
): UnsubscribeFn;

function once<Context extends WatchPayload = WatchPayload>(
  event: 'session-did-deactivate'
): Promise<
  Parameters<WatchEventCallbacks<Context>['session-did-deactivate']>[0]
>;

function once<Context extends WatchPayload = WatchPayload>(
  event: 'user-info-error',
  cb: WatchEventCallbacks<Context>['user-info-error']
): UnsubscribeFn;

function once<Context extends WatchPayload = WatchPayload>(
  event: 'user-info-error'
): Promise<Parameters<WatchEventCallbacks<Context>['user-info-error']>[0]>;

function once<Context extends WatchPayload = WatchPayload>(
  event: 'file-received-error',
  cb: WatchEventCallbacks<Context>['file-received-error']
): UnsubscribeFn;

function once<Context extends WatchPayload = WatchPayload>(
  event: 'file-received-error'
): Promise<Parameters<WatchEventCallbacks<Context>['file-received-error']>[0]>;

function once(event: WatchEvent, cb?: any): UnsubscribeFn | Promise<any> {
  if (cb) {
    return listen(event, cb, _once);
  } else {
    return new Promise((resolve) => {
      listen(
        event,
        (...args: any[]) => {
          if (args.length === 1) {
            resolve(args[0]);
          } else {
            resolve(args);
          }
        },
        _once
      );
    });
  }
}

const watchEvents = {
  addListener,
  on: addListener,
  once,
};

export default watchEvents;