/*

 * MP3/MPlayer plugin to VDR (C++)

 *

 * (C) 2001-2006 Stefan Huelswitt <s.huelswitt@gmx.de>

 *

 * This code 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

 * of the License, or (at your option) any later version.

 *

 * This code 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 this program; if not, write to the Free Software

 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.

 * Or, point your browser to http://www.gnu.org/copyleft/gpl.html

 */

#include <stdlib.h>

#include <stdio.h>

#include <unistd.h>

#include "common.h"

#include "data-mp3.h"

#include "data.h"

#include "decoder.h"

#define DEBUG_IMAGE

#ifdef DEBUG_IMAGE

#define di(x) { (x); }

#else

#define di(x) ; 

#endif

const char *imagecache = "/var/cache/images/mp3";

const char *imageconv  = "image_convert.sh";

const char *def_usr_img = 0;

// image suffixes to search

const char *img_suff[] = { "jpg","png","gif",0 };

// exclude list for instant playlist creation

const char *excl_pl[] = { "*"PLAYLISTEXT,"*.jpg","*.gif","*.png",0 };

// exclude list for song browser

const char *excl_br[] = { ".*","*.jpg","*.gif","*.png",0 };

// --- cImageConvert -----------------------------------------------------------

class cImageConvert : private cThread {

private:

  char *image;

  enum eStatus { stNone, stRun, stFin };

  eStatus status;

protected:

  virtual void Action(void);

public:

  cImageConvert(void);

  ~cImageConvert();

  bool Convert(const char *Image);

  bool Status(void);

  };

cImageConvert::cImageConvert(void)

{

  image=0; status=stNone;

}

cImageConvert::~cImageConvert()

{

  if(status==stRun) Cancel(10);

  free(image);

}

bool cImageConvert::Convert(const char *Image)

{

  if(status==stNone) {

    image=strdup(Image);

    status=stRun;

    Start();

    return true;

    }

  return false;

}

bool cImageConvert::Status(void)

{

  if(status==stRun && !Active()) status=stFin;

  return status==stFin;

}

void cImageConvert::Action(void)

{

  nice(3);

  char *m, *cmd, *qp, *qm;

  asprintf(&m,"%s%s.mpg",imagecache,image);

  di(printf("image: convert started %s -> %s\n",image,m))

  asprintf(&cmd,"%s \"%s\" \"%s\"",imageconv,qp=Quote(image),qm=Quote(m));

  int r=system(cmd);

  if(r!=0) di(printf("image: convert returned with code %d. Failed?\n",r))

  free(cmd); free(qp); free(qm); free(m);

  di(printf("image: convert finished\n"))

  status=stFin;

}

// --- cSong -------------------------------------------------------------------

cSong::cSong(cFileObj *Obj)

{

  obj=new cFileObj(Obj);

  Init();

}

cSong::cSong(cFileSource *Source, const char *Subdir, const char *Name)

{

  obj=new cFileObj(Source,Subdir,Name,otFile);

  Init();

}

cSong::cSong(cSong *Song)

{

  obj=new cFileObj(Song->obj);

  Init();

}

cSong::~cSong()

{

  delete conv;

  delete decoder;

  obj->Source()->Unblock();

  delete obj;

  free((char *)image);

}

void cSong::Init(void)

{

  decoder=0; user=0; image=0; conv=0; queueStat=0;

  fromDOS=decoderFailed=false;

  obj->Source()->Block();

}

#if APIVERSNUM >= 10315

int cSong::Compare(const cListObject &ListObject) const

#else

bool cSong::operator<(const cListObject &ListObject)

#endif

{

  cSong *song=(cSong *)&ListObject;

#if APIVERSNUM >= 10315

  return strcasecmp(obj->Path(),song->obj->Path());

#else

  return strcasecmp(obj->Path(),song->obj->Path())<0;

#endif

}

cSongInfo *cSong::Info(bool get)

{

  Decoder();

  cSongInfo *si=0;

  if(decoder) si=decoder->SongInfo(get);

  return si;

}

cDecoder *cSong::Decoder(void)

{

  decLock.Lock();

  if(!decoder && !decoderFailed) {

    decoder=cDecoders::FindDecoder(obj);

    if(!decoder) decoderFailed=true;

    }

  decLock.Unlock();

  return decoder;

}

void cSong::Convert(void)

{

  char *Name=Convert2Unix(obj->Name());

  obj->SetName(Name);

  fromDOS=true;

  free(Name);

}

char *cSong::Convert2Unix(const char *name) const

{

  char *Name=strdup(name);

  char *p=Name;

  while(*p) {

    if(*p=='/') *p='?';

    if(*p=='\\') *p='/';

    p++;

    }

  return Name;

}

/*

char *cSong::Convert2Dos(const char *name)

{

  char *Name=strdup(name);

  char *p=Name;

  while(*p) {

    if(*p=='\\') *p='?';

    if(*p=='/') *p='\\';

    p++;

    }

  return Name;

}

*/

bool cSong::Parse(char *s, const char *reldir) const

{

  s=skipspace(stripspace(s));

  if(*s) {

    if(s[0]=='/' || !reldir)

      obj->SplitAndSet(s);

    else {

      s=AddPath(reldir,s);

      obj->SplitAndSet(s);

      free(s);

      }

    return true;

    }

  return false;

}

bool cSong::Save(FILE *f, const char *reldir) const

{

  const char *path=obj->Path();

  if(reldir) {

    int l=strlen(reldir);

    if(!strncasecmp(path,reldir,l)) path+=l+1;

    }

  return fprintf(f,"%s\n",path)>0;

}

bool cSong::FindImage(void)

{

  if(image) return true;

  char base[strlen(obj->Path())+32];

  strcpy(base,obj->Path());

  di(printf("image: checking image for %s\n",obj->Path()))

  // song specific image

  char *m=rindex(base,'.');

  if(m) *m=0;

  if((image=CheckImage(base))) return true;

  // album specific image in song directory

  if(!(m=rindex(base,'/'))) m=base-1;

  strcpy(m+1,"cover");

  if((image=CheckImage(base))) return true;

  // artist specific image in parent directory

  if((m=rindex(base,'/'))) {

    *m=0;

    if(!(m=rindex(base,'/'))) m=base-1;

    strcpy(m+1,"artist");

    if((image=CheckImage(base))) return true;

    }

  // default image in source basedir

  if((image=CheckImage("background"))) return true;

  // default user supplied image

  if(def_usr_img && (image=strdup(def_usr_img))) return true;

  di(printf("image: no image for %s\n",obj->Path()))

  return false;

}

const char *cSong::CheckImage(const char *base) const

{

  char *p;

  int n;

  asprintf(&p,"%s/%s.%n     ",obj->Source()->BaseDir(),base,&n);

  for(const char **s=img_suff; *s; s++) {

#ifdef DEBUG

    if(strlen(*s)>5) printf("ERROR: buffer overflow in CheckImage ext=%s\n",*s);

#endif

    strcpy(&p[n],*s);

    di(printf("image: check %s\n",p))

    if(!access(p,R_OK)) {

      di(printf("image: found\n"))

      return p;

      }

    }

  free(p);

  return 0;

}

#include "data-mp3-image.c"

extern void PropagateImage(const char *image);

bool cSong::Image(unsigned char * &mem, int &len)

{

  mem=0;

  if(queueStat>0) {

    if(!conv->Status()) {

      di(printf("image: still queued\n"))

      return false;

      }

    queueStat=-1;

    delete conv; conv=0;

    }

  int res=0;

  if(image || FindImage()) {

    di(printf("image: loading image %s\n",image))

    char *m;

    asprintf(&m,"%s%s.mpg",imagecache,image);

    if(access(m,R_OK)) {

      di(printf("image: not cached\n"))

      if(queueStat<0) {

        di(printf("image: obviously convert failed...\n"))

        }

      else {

        if(!conv) conv=new cImageConvert;

        if(conv && conv->Convert(image)) {

          di(printf("image: convert queued\n"))

          queueStat=1;

          res=-1;

          }

        else {

          di(printf("image: queueing failed\n"))

          queueStat=-1;

          }

        }

      }

    else {

      di(printf("image: cached\n"))

      int f=open(m,O_RDONLY);

      if(f>=0) {

        struct stat64 st;

        fstat64(f,&st);

        len=st.st_size;

        mem=MALLOC(unsigned char,len);

        if(mem) {

          if(read(f,mem,len)==len) res=1;

          else free(mem);

          }

        close(f);

        }

      }

    free(m);

    }

  PropagateImage(res==1 ? image : 0);

  if(res<=0) {

    di(printf("image: using static default image\n"))

    len=sizeof(defaultImage);

    mem=MALLOC(unsigned char,len);

    if(mem) {

      memcpy(mem,defaultImage,len);

      }

    }

  return res>=0;

}

// -- cPlayList --------------------------------------------------------------

cPlayList::cPlayList(cFileObj *Obj)

{

  obj=new cFileObj(Obj);

  Init();

}

cPlayList::cPlayList(cFileSource *Source, const char *Subdir, const char *Name)

{

  obj=new cFileObj(Source,Subdir,Name,otFile);

  Init();

}

cPlayList::cPlayList(cPlayList *List)

{

  obj=new cFileObj(List->obj);

  Init();

}

cPlayList::~cPlayList()

{

  free(basename);

  free(extbuffer);

  obj->Source()->Unblock();

  delete obj;

}

void cPlayList::Init(void)

{

  extbuffer=basename=0;

  isWinAmp=false;

  obj->Source()->Block();

  Set();

}

void cPlayList::Set(void)

{

  free(basename); basename=0;

  if(obj->Name()) {

    basename=strdup(obj->Name());

    int l=strlen(basename)-strlen(PLAYLISTEXT);

    if(l>0 && !strcasecmp(basename+l,PLAYLISTEXT)) basename[l]=0;

    }

}

#if APIVERSNUM >= 10315

int cPlayList::Compare(const cListObject &ListObject) const

#else

bool cPlayList::operator<(const cListObject &ListObject)

#endif

{

  cPlayList *list=(cPlayList *)&ListObject;

#if APIVERSNUM >= 10315

  return strcasecmp(obj->Name(),list->obj->Name());

#else

  return strcasecmp(obj->Name(),list->obj->Name())<0;

#endif

}

bool cPlayList::Load(void)

{

  Clear();

  bool result=false;

  FILE *f=fopen(obj->FullPath(),"r");

  if(f) {

    char buffer[512];

    result=true;

    while(fgets(buffer,sizeof(buffer),f)>0) {

      if(buffer[0]=='#') {

        if(!strncmp(buffer,WINAMPEXT,strlen(WINAMPEXT))) {

          d(printf("mp3: detected WinAmp style playlist\n"))

          isWinAmp=true;

          }

        continue;

        }

      if(!isempty(buffer)) {

        cSong *song=new cSong(obj->Source(),0,0);

        if(song->Parse(buffer,obj->Subdir())) Add(song);

        else {

          esyslog("error loading playlist %s\n",obj->FullPath());

          delete song;

          result=false;

          break;

          }

        }

      }

    fclose(f);

    }

  else LOG_ERROR_STR(obj->FullPath());

  if(result && isWinAmp) {

    cSong *song=First();

    while(song) {   // if this is a WinAmp playlist, convert \ to /

      song->Convert();

      song=cList<cSong>::Next(song);

      }

    }

  return result;

}

bool cPlayList::Save(void)

{

  bool result=true;

  cSafeFile f(obj->FullPath());

  if(f.Open()) {

    cSong *song=First();

    while(song) {

      if(!song->Save(f,obj->Subdir())) {

         result=false;

         break;

         }

      song=cList<cSong>::Next(song);

      }

    if(!f.Close()) result=false;

    }

  else result=false;

  return result;

}

bool cPlayList::Exists(void)

{

  return obj->Exists();

}

bool cPlayList::TestName(const char *newName)

{

  return obj->TestName(AddExt(newName,PLAYLISTEXT));

}

bool cPlayList::Rename(const char *newName)

{

  bool r=obj->Rename(AddExt(newName,PLAYLISTEXT));

  if(r) Set();

  return r;

}

bool cPlayList::Create(const char *newName)

{

  bool r=obj->Create(AddExt(newName,PLAYLISTEXT));

  if(r) {

    Set();

    r=Load();

    }

  return r;

}

bool cPlayList::Delete(void)

{

  return obj->Delete();

}

const char *cPlayList::AddExt(const char *FileName, const char *Ext)

{

  free(extbuffer); extbuffer=0;

  asprintf(&extbuffer,"%s%s",FileName,Ext);

  return extbuffer;

}

// -- cInstantPlayList ------------------------------------------------------

cInstantPlayList::cInstantPlayList(cFileObj *Obj)

:cPlayList(Obj)

{

  if(!Obj->Name()) Obj->SetName("instant");

}

bool cInstantPlayList::Load(void)

{

  bool res=false;

  Clear();

  switch(obj->Type()) {

    case otFile:

      d(printf("instant: file %s\n",obj->Name()))

      if(strcasecmp(obj->Name(),basename)) {

        d(printf("instant: detected as playlist\n"))

        res=cPlayList::Load();

        }

      else {

        Add(new cSong(obj));

        res=true;

        }

      break;

    case otDir:

      {

      d(printf("instant: dir %s\n",obj->Name()))

      res=ScanDir(obj->Source(),obj->Path(),stFile,obj->Source()->Include(),excl_pl,true);

      Sort();

      break;

      }

    case otBase:

      d(printf("instant: base\n"))

      res=ScanDir(obj->Source(),0,stFile,obj->Source()->Include(),excl_pl,true);

      Sort();

      break;

    default: break;

    }

  return res;

}

void cInstantPlayList::DoItem(cFileSource *src, const char *subdir, const char *name)

{

  Add(new cSong(src,subdir,name));

}

// -- cPlayLists --------------------------------------------------------------

bool cPlayLists::Load(cFileSource *Source)

{

  static const char *spec[] = { "*"PLAYLISTEXT,0 };

  Clear();

  bool res=ScanDir(Source,0,stFile,spec,0,false);

  Sort();

  return res;

}

void cPlayLists::DoItem(cFileSource *src, const char *subdir, const char *name)

{

  Add(new cPlayList(src,subdir,name));

}