Loopp/src/diskreader.cxx

#include "diskreader.hxx"

#include <sstream>
#include <fstream>
#include <iostream>
#include <cstring>
#include <cstdlib>
#include <sys/stat.h>

#include "event.hxx"
#include "eventhandler.hxx"

#include "audiobuffer.hxx"

#include <sndfile.hh>

using namespace std;

DiskReader::DiskReader()
{
};

AudioBuffer* DiskReader::loadSample( string path )
{
  SndfileHandle infile( path, SFM_READ );
  
  AudioBuffer* ab = new AudioBuffer();
  
  std::vector<float> buf( infile.frames(), 0.f );
  
  infile.read( &buf[0] , infile.frames() );
  
  // read data from file
  ab->setBeats(4);
  ab->nonRtSetSample( buf );
  
  cout << "Worker: loadSample() " << path << " size: " << infile.frames() << endl;
  
  if ( infile.frames() > 0 )
    return ab;
  
  return 0;
}

void DiskReader::readSession( std::string path )
{
  cout << "DiskReader::readSession() " << path << endl;
  sessionPath = path;
  
  stringstream s;
  s << path << "/session.luppp";
  
  stringstream samplePath;
  samplePath << path << "/samples/sample.cfg";
  
  cout << "session path: " << s.str() << endl;
  cout << "sample path:  " << samplePath.str() << endl;
  
  // open session, read all
  std::ifstream file( s.str().c_str(), std::ios_base::in|std::ios_base::ate);
  long file_length = file.tellg();
  file.seekg(0, std::ios_base::beg);
  file.clear();
  char *sessionString = new char[file_length];
  file.read(sessionString, file_length);
  
  // open sample, read all
  std::ifstream sampleFile( samplePath.str().c_str(), std::ios_base::in|std::ios_base::ate);
  file_length = sampleFile.tellg();
  sampleFile.seekg(0, std::ios_base::beg);
  sampleFile.clear();
  char *sampleString = new char[file_length];
  sampleFile.read(sampleString, file_length);
  
  // create cJSON nodes from strings
  session = cJSON_Parse( sessionString );
  if (!session) {
    printf("Error in Session JSON before: [%s]\n",cJSON_GetErrorPtr());
    return;
  }
  sample  = cJSON_Parse( sampleString );
  if (!sample) {
    printf("Error in Sample JSON before: [%s]\n",cJSON_GetErrorPtr());
    return;
  }
  
  //cout << "session: " << cJSON_Print( session ) << endl;
  //cout << "sample:  " << cJSON_Print( sample  ) << endl;
  
  
  readGrid();
  readMaster();
  
  // cleanup
  cJSON_Delete( session );
  cJSON_Delete( sample  );
  
  free ( sessionString );
  free ( sampleString  );
  
}

void DiskReader::readMaster()
{
  cJSON* master = cJSON_GetObjectItem( session, "master");
  if ( master )
  {
    
    // fader
    { 
      cJSON* fader = cJSON_GetObjectItem( master, "fader");
      EventTrackVol e( -1, fader->valuedouble );
      writeToDspRingbuffer( &e );
    }
    // reverb
    {
      cJSON* reverb = cJSON_GetObjectItem( master, "reverb");
      
      cJSON* active  = cJSON_GetObjectItem( reverb, "active");
      cJSON* size    = cJSON_GetObjectItem( reverb, "size");
      cJSON* wet     = cJSON_GetObjectItem( reverb, "wet");
      cJSON* damping = cJSON_GetObjectItem( reverb, "damping");
      
      if ( active && size && wet && damping )
      {
        EventFxReverb e(  active->valuedouble, size->valuedouble,
                          wet->valuedouble, damping->valuedouble );
        writeToDspRingbuffer( &e );
      }
    }
    
    
  }
  
  
}

void DiskReader::readGrid()
{
  cJSON* tracks = cJSON_GetObjectItem( session, "tracks");
  if ( tracks )
  {
    int nTracks = cJSON_GetArraySize( tracks );
    for(int t = 0; t < nTracks; t++ )
    {
      cJSON* track = cJSON_GetArrayItem( tracks, t );
      
      cJSON* clips = cJSON_GetObjectItem( track, "clips");
      if ( clips )
      {
        
        int nClips = cJSON_GetArraySize( clips );
        for(int s = 0; s < nClips; s++ )
        {
          // get metadata for Clip
          cJSON* clip = cJSON_GetArrayItem( clips, s );
          
          if ( !strcmp(clip->valuestring, "") == 0 )
          {
            stringstream sampleFilePath;
            sampleFilePath << sessionPath << "/samples/" << clip->valuestring;
#ifdef DEBUG_LOAD
        cout << "clip " << sampleFilePath.str() << endl;
#endif
            
            // load it
            AudioBuffer* ab = loadSample( sampleFilePath.str() );
            EventLooperLoad e = EventLooperLoad( t, s, ab );
            writeToDspRingbuffer( &e );
            
            // retrieve sample metadata from sample.cfg using filename as key
            cJSON* sampleFile = cJSON_GetObjectItem( sample, clip->valuestring );
            if ( sampleFile )
            {
              cJSON* beats = cJSON_GetObjectItem( sampleFile, "beats" );
              
              cout << "Clip @ " << t << " " << s << " gets " << beats->valuedouble << " beats."<< endl;
              EventLooperLoopLength e = EventLooperLoopLength( t, s, beats->valueint );
              writeToDspRingbuffer( &e );
            }
            else {
              cout << "Wanring: Sample " << clip->valuestring << " has no entry for beats." << endl;
            }
          }
        
        } // nClips loop
      
      } 
    } // nTracks loop
    
  }
  else
  {
    cout << "DiskReader: Error getting clip" << endl;
  }
}