#!/usr/bin/perl

$DEBUG = 1;

use lib "../cgi-bin";
use localbucky;

$dbh = DBI->connect ($dsn);

# get keyword + threads

if (@ARGV > 0)
	{
	export_users(@ARGV);
	}

$dbh->disconnect();

sub export_users
	{
	print "Exporting users @_\n";
	my $threads = get_full_threads_by_username(@_);

	print "Got " . @$threads . " threads";

	# mkdir username, chdir
	mkdir ($_[0]);
	chdir ($_[0]);

	# foreach thread:
	foreach my $thread (@$threads)
		{
		export_thread($thread);
		}

	chdir("..");
	}

sub export_thread
	{
	my ($thread) = @_;

	# get all comments & files
	my $comments = get_comments($thread->{id});
	my $files = get_files($thread->{id});

	mkdir ("$thread->{id}");
	chdir ("$thread->{id}");

	print "thread $thread->{id} -- $thread->{title}\n";
	print "comments: $thread->{comments}\n";
	print "files: $thread->{files}\n";

	open THREAD, ">thread" or die $!;
	foreach my $key (keys %$thread)
		{
		print THREAD "$key:".$thread->{$key}."\n";
		}
	print THREAD "\n";
	close THREAD;

	# cat each comment & file to text files based on id
	foreach my $comment (keys %$comments)
		{
		my $c = $comments->{$comment};
		open COMMENT, ">comment.".$c->{id} or die $!;
		foreach my $key (keys %$c)
			{
			next if ($key eq "comment");
			print COMMENT "$key:".$c->{$key}."\n";
			}
		print COMMENT "\n";
		print COMMENT $c->{comment};
		close COMMENT;
		}

	foreach my $f (@$files)
		{
		open FILE, ">file.".$f->{id} or die $!;
		foreach my $key (keys %$f)
			{
			print FILE "$key:".$f->{$key}."\n";
			}
		close FILE;
		}

	if (-e "$data_path/$thread->{id}")
		{
		print "Copying ...\n";
		mkdir ("data/");
		system ("/bin/cp -r $data_path/$thread->{id}/* data/")
		}

	chdir ("..");
	print "\n";
	}

sub get_full_threads_by_username
	{
	my @usernames = @_;
	my @rows;
	my $query;
	my @keys = qw(id title username keyword createdate lastmodified size private allowed flagged color);
	my $rc = 0;

	my $threadz = {};
	for my $username (@usernames) {
		print $username . "\n";
 	 	my $quser = $dbh->quote($username);
	
		$query = "SELECT thread FROM comments WHERE username=$quser GROUP BY thread";
		print $query . "\n";
		$sth = $dbh->prepare($query);
		$sth->execute();
		while (my (@row) = $sth->fetchrow_array()) {
			$threadz->{$row[0]} = 1;
		}
		
		$query = "SELECT thread FROM files WHERE username=$quser GROUP BY thread";
		print $query . "\n";
		$sth = $dbh->prepare($query);
		$sth->execute();
		while (my (@row) = $sth->fetchrow_array()) {
			$threadz->{$row[0]} = 1;
		}
	}
	my $values = join ",", sort keys %$threadz;

	$query = "SELECT id,title,username,keyword,createdate,lastmodified,size,private,allowed,flagged,color FROM threads WHERE id IN ($values)";
#	if (defined($private) && $private)
#		{
#		$query .= " AND (ISNULL(private) OR private = '')";
#		}

	print $query."<br>" if ($DEBUG);
	$sth = $dbh->prepare($query);
	$sth->execute();
	while (my (@row) = $sth->fetchrow_array())
		{
		my %temphash;
		for (my $i = 0; $i < @row; $i++)
			{
			$temphash{$keys[$i]} = $row[$i];
			}
		$rows[$rc] = \%temphash;
		$rc++;
		}
	$sth->finish();

	if ($rc == 0)
		{
		print "No threads!\n" if ($DEBUG);
		return -1;
		}

	for (my $i = 0; $i < @rows; $i++)
		{
		$rows[$i]{comments} = count_comments($rows[$i]{id});
		$rows[$i]{files} = count_files($rows[$i]{id});
		}

	return \@rows;
	}