import { urlPathAudio as settings } from '@/settings';
import { REST, RESTError } from './rest';

// запросы на AzuraCast

export default class extends REST {
  connection = {};

  static get settings() {
    return settings;
  }

  init() {
    const sseBaseUri = `${settings}/api/live/nowplaying/sse`;
    // console.log('sseBaseUri', sseBaseUri);
    const sseUriParams = new URLSearchParams({
      cf_connect: JSON.stringify({
        subs: {
          'station:it-radio': { recover: true },
        },
      }),
    });
    // console.log('sseUriParams', sseUriParams.toString());
    this.connection = new EventSource(
      sseBaseUri + '?' + sseUriParams.toString(),
    );
    // window.connection = this.connection;
    // this.connection.onopen = (e) => console.log('connected', e);
  }

  removePlay() {
    this.connection.close();
  }
  songs() {
    this.connection.onmessage = (e) => {
      const jsonData = JSON.parse(e.data);
      // if ("connect" in jsonData) {
      //     const connectData = jsonData.connect;
      //
      //     if ("data" in connectData) {
      //         // Legacy SSE data
      //         connectData.data.forEach((initialRow) => handleSseData(initialRow));
      //     } else {
      //         // New Centrifugo time format
      //         if ("time" in connectData) {
      //         }
      //
      //         // New Centrifugo cached NowPlaying initial push.
      //         for (const subName in connectData.subs) {
      //             const sub = connectData.subs[subName];
      //             if ("publications" in sub && sub.publications.length > 0) {
      //                 sub.publications.forEach((initialRow) => handleSseData(initialRow, false));
      //             }
      //         }
      //     }
      // } else if ("pub" in jsonData) {
      //     handleSseData(jsonData.pub);
      // }
    };
  }

  onHandler(callback) {
    this.connection.onmessage = callback;
  }
  static getPlayList(station, params) {
    // return this._get(`station/${station}/playlists`, params, {}).then((data) => {
    return this._get(`radio.mp3`, params, {})
      .then((data) => {
        return data;
      })
      .catch((error) => {
        throw new RESTError(error, 'Ошибка при получении плейлистов');
      });
  }
}