use strict;

use Getopt::Std;

use lib '/app/tools/common/lib';
use Common::RSDB;
use Common::DB::Item::TableChangeLog;

use lib '/app/tools/rps/lib';
use RPS::DB::Item::Artist;
use RPS::DB::Item::Album;
use RPS::DB::Item::Song;
use RPS::DB::Item::Master;
use RPS::DB::Item::Track;
use RPS::DB::Item::Composer;
use RPS::DB::Item::Product;
use RPS::DB::Item::Label;
use RPS::DB::Item::ProductTrack;

use lib '/app/tools/mediaserve/lib';

use MediaServe::DB::Item::AlbumFile;
use MediaServe::DB::Item::ProductTrackFile;


my $gClientID;
my $gVerbosityLevel = 1;

_parseCommandLine();

print "start: " . localtime() . "\n";
_syncMetadata($gClientID);
print "end  : " . localtime() . "\n";


sub _syncMetadata
{
    my ($clientID) = @_;

    my $app = Common::RSApp->new(clientID => $clientID);

    
    # !!! So... what is the best way to do this?
    # I would like to try and let the change log process handle most of 
    # the work.  But that means that I need to 'forge' a bunch of inserts.
    #
#+--------------------+
#| table_name         |
#+--------------------+
#| artist             |
#| album              |
#| song               |
#| master             |
#| track              |
#| composer           |
#| product            |
#| label              |
#| album_file         |
#| product_track_file |
#| product_track      |
#+--------------------+

   # Shouldn't be too terribly difficult - need to do it in the correct order.
   #
   # composer
   # artist
   # label
   # song
   # master   (song_id, artist_id)
   # album      (artist_id, label_id)
   # track  (album_id, master_id)
   # product (album_id,track_id)
   # product_track  (product_id, track_id)
   # album_file  (album_id)
   # product_track_file (product_track_id)

    foreach my $dbPkg (
        'RPS::DB::Item::Artist',
        'RPS::DB::Item::Album',
        'RPS::DB::Item::Song',
        'RPS::DB::Item::Master',
        'RPS::DB::Item::Track',
        'RPS::DB::Item::Composer',
        'RPS::DB::Item::Product',
        'RPS::DB::Item::Label',
        'RPS::DB::Item::ProductTrack',
        'MediaServe::DB::Item::AlbumFile',
        'MediaServe::DB::Item::ProductTrackFile'
    )
    {
        _syncTable($dbPkg);
    }
}


sub _syncTable
{
    my ($pkg) = @_;

    my $collection = $pkg->GetAll();
    while (my $dbItem = $collection->next())
    {
        _createInsertLog($dbItem);
    }
}


sub _createInsertLog
{
    my ($dbItem) = @_;

    my $dbo = Common::RSApp->GetClientDB();
    my @setPairs;

    # !!! This violates encapsulation...
    #
	my $config = $dbItem->_config();
    my $tableName = $dbItem->_tableName();

	foreach my $fieldName (keys %$config)
    {
        my $value = $dbItem->$fieldName;
        if (defined $value)
        {
            push @setPairs, "$fieldName=".$dbo->DBQuote($value);
        }
    }

    my $setString = join(",", @setPairs);
    my $logEntry = Common::DB::Item::TableChangeLog->Create
    (
        client_id => Common::RSApp::GetClientID(),
        table_name => $tableName,
        action => Common::DB::Item::TableChangeLog::kActionInsert,
        set_pairs => $setString,
    );
    $logEntry->save();

}

sub _parseCommandLine
{
    my %opt;
    getopts('c:V:', \%opt);

    if (! $opt{c})
    {
        _usage();
        exit(1);
    }
    $gClientID = $opt{c};

    if (defined $opt{V})
    {
        $gVerbosityLevel = $opt{V};
    }
}