Function useStreamerbot

packages/vue/src/composables/useStreamerbot.ts:21–141

(options: UseStreamerbotOptions)

export type UseStreamerbotOptions = MaybeRefOrGetter<Partial<StreamerbotClientOptions>>;

export type UseStreamerbotReturn = {
  data: Ref<any>;
  status: Ref<WebSocketStatus>;
  error: Ref<string | undefined>;
  connect: () => void;
  disconnect: () => void;
  client: Ref<StreamerbotClient | undefined>;
};

export function useStreamerbot(options: UseStreamerbotOptions): UseStreamerbotReturn {
  const _options = computed<Partial<StreamerbotClientOptions>>(() =>
    typeof options === 'function' ? options() : toValue(options),
  );
  const _optionsChanged = ref(false);
  watch(_options, () => (_optionsChanged.value = true), { deep: true, immediate: true });

  const data = ref();
  const status = ref<WebSocketStatus>('CLOSED');
  const error = ref<string>();
  const clientRef = ref<StreamerbotClient>();

  function onConnect(data: StreamerbotInfo) {
    status.value = 'OPEN';
    error.value = undefined;
    let cb = toValue(_options.value).onConnect;
    cb?.(data);
  }

  function onDisconnect() {
    status.value = 'CLOSED';
    let cb = toValue(_options.value).onDisconnect;
    cb?.();
  }

  function onError(err: Error) {
    error.value = err?.message ?? 'Unkown Error';
    status.value = 'CLOSED';
    let cb = toValue(_options.value).onError;
    cb?.(err);
  }

  function onData(payload: any) {
    data.value = payload;
    let cb = toValue(_options.value).onData;
    cb?.(payload);
  }

  async function connect() {
    await disconnect();
    status.value = 'CONNECTING';
    if (_optionsChanged.value) {
      await _init(true);
    } else {
      await clientRef.value?.connect();
    }
  }