HTSPData.h

#pragma once

/*
 *      Copyright (C) 2005-2011 Team XBMC
 *      http://www.xbmc.org
 *
 *  This Program is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation; either version 2, or (at your option)
 *  any later version.
 *
 *  This Program is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
 *  GNU General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with XBMC; see the file COPYING.  If not, write to
 *  the Free Software Foundation, 675 Mass Ave, Cambridge, MA 02139, USA.
 *  http://www.gnu.org/copyleft/gpl.html
 *
 */

#include "client.h"
#include "platform/threads/threads.h"
#include "HTSPConnection.h"
#include "CircBuffer.h"

class CHTSPDemux;

class CHTSPData : CHTSPConnectionCallback
{
public:
  CHTSPData();
  ~CHTSPData();

  bool Open();
  void Close();
  bool IsConnected(void) const { return m_session->IsConnected(); }

  /*!
   * @brief Send a message to the backend and read the result.
   * @param message The message to send.
   * @return The returned message or NULL if an error occured or nothing was received.
   */
  void         ReadResult(htsmsg_t *message, CHTSResult &result);
  int          GetProtocol(void) const   { return m_session->GetProtocol(); }
  const char * GetServerName(void) const { return m_session->GetServerName(); }
  const char * GetVersion(void) const    { return m_session->GetVersion(); }
  bool         CanTimeshift(void) const  { return m_session->CanTimeshift(); }
  bool         CanSeekLiveStream(void) const  { return m_session->CanSeekLiveStream(); }

  bool         CanTranscode(void) const  { return m_session->CanTranscode(); }
  CodecVector  GetTranscodingCodecs(void);

  bool         GetDriveSpace(long long *total, long long *used);
  bool         GetBackendTime(time_t *utcTime, int *gmtOffset);
  unsigned int GetNumChannels(void);
  PVR_ERROR    GetChannels(ADDON_HANDLE handle, bool bRadio);
  PVR_ERROR    GetEpg(ADDON_HANDLE handle, const PVR_CHANNEL &channel, time_t iStart, time_t iEnd);
  unsigned int GetNumRecordings();
  PVR_ERROR    GetRecordings(ADDON_HANDLE handle);
  PVR_ERROR    DeleteRecording(const PVR_RECORDING &recinfo);
  PVR_ERROR    AddTimer(const PVR_TIMER &timerinfo);
  PVR_ERROR    UpdateTimer(const PVR_TIMER &timerinfo);
  PVR_ERROR    RenameRecording(const PVR_RECORDING &recinfo, const char* newname);
  unsigned int GetNumTimers();
  PVR_ERROR    GetTimers(ADDON_HANDLE handle);
  PVR_ERROR    DeleteTimer(const PVR_TIMER &timerinfo, bool force);
  unsigned int GetNumChannelGroups(void);
  PVR_ERROR    GetChannelGroups(ADDON_HANDLE handle);
  PVR_ERROR    GetChannelGroupMembers(ADDON_HANDLE handle, const PVR_CHANNEL_GROUP &group);
  bool         OpenRecordedStream(const PVR_RECORDING &recording);
  void         CloseRecordedStream(void);
  int          ReadRecordedStream(unsigned char *pBuffer, unsigned int iBufferSize);
  long long    SeekRecordedStream(long long iPosition, int iWhence /* = SEEK_SET */);
  long long    PositionRecordedStream(void);
  long long    LengthRecordedStream(void);

  bool         OnConnectionDropped(void);
  bool         OnConnectionRestored(void);
  bool         ProcessMessage(htsmsg* msg);

  bool         OpenLiveStream(const PVR_CHANNEL &channel);
  void         CloseLiveStream(void);
  int          GetCurrentClientChannel(void);
  bool         SwitchChannel(const PVR_CHANNEL &channel);
  PVR_ERROR    GetStreamProperties(PVR_STREAM_PROPERTIES* pProperties);
  PVR_ERROR    SignalStatus(PVR_SIGNAL_STATUS &signalStatus);
  void         DemuxAbort(void);
  void         DemuxFlush(void);
  DemuxPacket* DemuxRead(void);
  bool         SeekTime(int time,bool backward,double *startpts);
  void         SetSpeed(int speed);
  PVR_ERROR    GetEdl(const PVR_RECORDING &recinfo, PVR_EDL_ENTRY entries[], int *size);
private:
  SChannels GetChannels();
  SChannels GetChannels(int tag);
  SChannels GetChannels(STag &tag);
  STags GetTags();
  PVR_ERROR GetEvent(ADDON_HANDLE handle, uint32_t *id, time_t stop);
  PVR_ERROR GetEvents(ADDON_HANDLE handle, uint32_t cid, time_t stop);
  bool SendEnableAsync();
  SRecordings GetDVREntries(bool recorded, bool scheduled);

  void ParseChannelRemove(htsmsg_t* msg);
  void ParseChannelUpdate(htsmsg_t* msg);
  void ParseDVREntryDelete(htsmsg_t* msg);
  void ParseDVREntryUpdate(htsmsg_t* msg);
  bool ParseEvent(ADDON_HANDLE handle, htsmsg_t* msg, uint32_t *id, time_t end);
  void ParseTagRemove(htsmsg_t* msg);
  void ParseTagUpdate(htsmsg_t* msg);

  CHTSPConnection *          m_session;
  bool                       m_bIsStarted;
  PLATFORM::CCondition<bool> m_started;
  PLATFORM::CMutex           m_mutex;
  SChannels                  m_channels;
  STags                      m_tags;
  SRecordings                m_recordings;
  int                        m_iReconnectRetries;
  bool                       m_bDisconnectWarningDisplayed;
  uint32_t                   m_recordingId;
  int64_t                    m_recordingOff;
  CCircBuffer                m_recordingBuf;
  CHTSPDemux*                m_demux;
  PLATFORM::CTimeout         m_connectionWarningTimeout;
};