bitjoe - MutellaProxy - SOURCE CODE

#!/usr/bin/perl	-I/server/mutella/MutellaProxy

#########################################
##### Author:		Sebastian Enger / B.Sc
##### CopyRight:	BitJoe GmbH
##### LastModified	26.07.2006
##### Function:		Installiere automatisch ultrapeers zum Mutella
##### Todo:			
########################################


use MutellaProxy::Ultrapeers;
use MutellaProxy::Parser;
use MutellaProxy::IO;

while(1){
	eval {

		# MutellaProxy::Ultrapeers->GetAndInstallUltraPeerHostListFromGwebCache();
		MutellaProxy::Ultrapeers->GetAndInstallUltraPeerHostList();
		# MutellaProxy::Ultrapeers->InstallKnowHostsFromFile();
		# my $MutellaSocket = MutellaProxy::IO->CreateMutellaSocket();
		# MutellaProxy::Parser->CheckSharingRatio($MutellaSocket);
		close $MutellaSocket;
	};

	sleep 100;
};

#!/usr/bin/perl	-I/server/mutella/MutellaProxy

#########################################
##### Author:		Sebastian Enger / B.Sc
##### CopyRight:	BitJoe GmbH
##### LastModified	26.07.2006
##### Function:		Teste, ob alle Programm richtig laufen, sonst Fehleremail
##### Todo:			
########################################

use MutellaProxy::Mail;
use MutellaProxy::Time;
use strict;


$SIG{CHLD} = sub { wait };

my $pid;

my %ToCheckProgramms = (
	"AddUltraPeer"			=> "/usr/bin/perl /server/mutella/AddUltraPeers.pl",
	"MutellaProxy"			=> "/usr/bin/perl /server/mutella/MutellaProxy.pl",
	"mutella-0.4.6"			=> "/server/mutella/mutella-0.4.6-bin --config=/server/mutella/.mutellarc",
	"DeleteOldEntries.pl"	=> "/usr/bin/perl /server/mutella/DeleteOldEntries.pl",
);


while(1){
	CheckAndRestart();
	sleep 60;	# fr firmenversion dann auf 5 sec stellen!!!
};


sub CheckAndRestart(){

	while ( my ($prog, $startpath) = each(%ToCheckProgramms) ) {
	
		my @ps1		= `ps aux`;

		my @found1	= grep { /$prog/i } @ps1;
		my @c1		= split("\n", @ps1 );

		# print $#found1; # error if -1

		if ( $#found1 == -1 ) {
		
			print MutellaProxy::Time->MySQLDateTime() . "ERROR: Programm $prog luft nicht!\n";

			my $MailConfig = {
				'TO1'		=> 'thecerial@gmail.com',

... [truncated, 29 more lines] ...

#!/usr/bin/perl	-I/root/.mutella/MutellaProxy

#########################################
##### Author:		Sebastian Enger / B.Sc
##### CopyRight:	BitJoe GmbH
##### LastModified	27.07.2006
##### Function:		Parsing von Daten
##### Todo:			
########################################

use MutellaProxy::Parser;
use MutellaProxy::IO;

my $MutellaSocket = MutellaProxy::IO->CreateMutellaSocket();
MutellaProxy::Parser->CheckSharingRatio($MutellaSocket);

#!/usr/bin/perl	-I/server/mutella/MutellaProxy

#########################################
##### Author:		Sebastian Enger / B.Sc
##### CopyRight:	BitJoe GmbH
##### LastModified	4.08.2006
##### Function:		Lsche zu alte Suchanfragen aus dem Mutella
##### Todo:			
########################################


use MutellaProxy::ResultCleaner;

# MutellaProxy::ResultCleaner->DeleteEntryRange();
MutellaProxy::ResultCleaner->DeleteOldEntries();

#!/usr/bin/perl	-I/server/mutella/MutellaProxy

#########################################
##### Author:		Sebastian Enger / B.Sc
##### CopyRight:	BitJoe GmbH
##### LastModified	4.08.2006
##### Function:		Lsche zu alte Suchanfragen aus dem Mutella
##### Todo:			
########################################


use MutellaProxy::ResultCleaner;

MutellaProxy::ResultCleaner->DeleteEntryRange();
# MutellaProxy::ResultCleaner->DeleteOldEntries();

#!/usr/bin/perl	-I/server/mutella/MutellaProxy

#########################################
##### Author:		Sebastian Enger / B.Sc
##### CopyRight:	BitJoe GmbH
##### LastModified	11.07.2006
##### Function:		Lizenzen generieren
##### Todo:			
########################################

use MutellaProxy::LicenceGenerator;
use MutellaProxy::LicenceTransfer;


# MutellaProxy::LicenceGenerator->AddLicenceToSQL();
MutellaProxy::LicenceTransfer->TestInstalledLicence();

#!/usr/bin/perl -I/server/mutella/MutellaProxy

#!!!!!!!!!! hinweise: $IO->writeSocket( $HandyClientSocket, GzipString("FC 908") . CRLF ); 
# gibt eventuell fehler beim auslesen

#########################################
##### Author:		Sebastian Enger / B.Sc
##### CopyRight:	BitJoe GmbH
##### LastModified	13.07.2006
##### Function:		Hauptdatei fr MutellaProxy
##### Todo:			for statt foreach: ist schneller
##### MileStones:	IPBlocker.pm->IPBlocker() funktioniert
#####				Status.pm->readStatus() funktioniert
#####				SortRank.pm->SortRank() funktioniert
########################################

# Mail.pm ->SendMail funktioniert erstmal nicht, habe gleich am anfang der funktion ein return 1; gesetzt
# add ultrapeer anpassen!  /server/wwwroot/gwebcache/data da liegen die gwebcaches drinne
# bestimmung der dateiendung funzt nich nicht richtig: bei suche nach "test jpeg" wird auch "adsfadsf.jpeg.jpg" gefunden


# perl -MCPAN -e 'install "Crypt::Rijndael"'
# perl -MCPAN -e 'install "Crypt::CBC"'
# perl -MCPAN -e 'install "LWP::Simple"'
# perl -MCPAN -e 'install "String::Approx"' 
# perl -MCPAN -e 'install "Net::SCP::Expect"' 
# perl -MCPAN -e 'install "MIME::Lite"' 
# perl -MCPAN -e 'install "Sort::Array"' 
# perl -MCPAN -e 'install "File::Basename"' 
# perl -MCPAN -e 'install "Net::Nslookup"' 
# perl -MCPAN -e 'install "Digest::MD4"' 
# perl -MCPAN -e 'install "Digest::MD5"'
# perl -MCPAN -e 'install "IO::Socket::SSL"'
# perl -MCPAN -e 'install "CPAN"'
# perl -MCPAN -e 'install "Scalar::Util"'
# perl -MCPAN -e 'install "Net::SSLeay"'
# perl -MCPAN -e 'install "Crypt::SSLeay"'
# perl -MCPAN -e 'install "Crypt::IDEA"'
# perl -MCPAN -e 'install "Digest::SHA"'
# perl -MCPAN -e 'install "Crypt::RSA"'
# perl -MCPAN -e 'install "Crypt::Blowfish"'
# perl -MCPAN -e 'install "Crypt::GPG"'
# perl -MCPAN -e 'install "XML::Parser"'
# perl -MCPAN -e 'install "XMLRPC::Lite"'
# perl -MCPAN -e 'force install "IO::Compress::Gzip"'

##########
#### Merke: $FileTypeHashRef->{ 0 } = FORMATBILD|FORMATMP3 usw
#### Merke: $FileTypeHashRef->{ 1 } = 'jpg|mp3' usw
##########

... [truncated, 624 more lines] ...

#!/usr/bin/perl -I/server/mutella/MutellaProxy

#!!!!!!!!!! hinweise: $IO->writeSocket( $HandyClientSocket, GzipString("FC 908") . CRLF ); 
# gibt eventuell fehler beim auslesen

#########################################
##### Author:		Sebastian Enger / B.Sc
##### CopyRight:	BitJoe GmbH
##### LastModified	13.07.2006
##### Function:		Hauptdatei fr MutellaProxy
##### Todo:			for statt foreach: ist schneller
##### MileStones:	IPBlocker.pm->IPBlocker() funktioniert
#####				Status.pm->readStatus() funktioniert
#####				SortRank.pm->SortRank() funktioniert
########################################

# Mail.pm ->SendMail funktioniert erstmal nicht, habe gleich am anfang der funktion ein return 1; gesetzt
# add ultrapeer anpassen!  /server/wwwroot/gwebcache/data da liegen die gwebcaches drinne
# bestimmung der dateiendung funzt nich nicht richtig: bei suche nach "test jpeg" wird auch "adsfadsf.jpeg.jpg" gefunden


# perl -MCPAN -e 'install "Crypt::Rijndael"'
# perl -MCPAN -e 'install "Crypt::CBC"'
# perl -MCPAN -e 'install "LWP::Simple"'
# perl -MCPAN -e 'install "String::Approx"' 
# perl -MCPAN -e 'install "Net::SCP::Expect"' 
# perl -MCPAN -e 'install "MIME::Lite"' 
# perl -MCPAN -e 'install "Sort::Array"' 
# perl -MCPAN -e 'install "File::Basename"' 
# perl -MCPAN -e 'install "Net::Nslookup"' 
# perl -MCPAN -e 'install "Digest::MD4"' 
# perl -MCPAN -e 'install "Digest::MD5"'
# perl -MCPAN -e 'install "IO::Socket::SSL"'
# perl -MCPAN -e 'install "CPAN"'
# perl -MCPAN -e 'install "Scalar::Util"'
# perl -MCPAN -e 'install "Net::SSLeay"'
# perl -MCPAN -e 'install "Crypt::SSLeay"'
# perl -MCPAN -e 'install "Crypt::IDEA"'
# perl -MCPAN -e 'install "Digest::SHA"'
# perl -MCPAN -e 'install "Crypt::RSA"'
# perl -MCPAN -e 'install "Crypt::Blowfish"'
# perl -MCPAN -e 'install "Crypt::GPG"'
# perl -MCPAN -e 'install "XML::Parser"'
# perl -MCPAN -e 'install "XMLRPC::Lite"'
# perl -MCPAN -e 'force install "IO::Compress::Gzip"'

##########
#### Merke: $FileTypeHashRef->{ 0 } = FORMATBILD|FORMATMP3 usw
#### Merke: $FileTypeHashRef->{ 1 } = 'jpg|mp3' usw
##########

... [truncated, 672 more lines] ...

#!/usr/bin/perl -I/server/mutella/MutellaProxy


use IO::Socket;
use Data::Dumper;
use MutellaProxy::IO;

use constant CRLF => "\r\n";

my $IO	= MutellaProxy::IO->new();


$socket = IO::Socket::INET->new(PeerAddr => '85.214.39.76',
                                PeerPort => '3381',
                                Proto    => "tcp",
                                Type     => SOCK_STREAM)
    or die "Couldn't connect to 85.214.39.76:3381 : $@\n";


$IO->writeSocket( $socket, "find 1 paris" . CRLF );

sleep 12;

if (!$socket) {
	print "connection to socket lost!\n";
};

my $ReadFromClient = $IO->readSocket( $socket );

print Dumper($ReadFromClient);

#!/usr/bin/perl	-I/server/mutella/MutellaProxy

#########################################
##### Author:		Sebastian Enger / B.Sc
##### CopyRight:	BitJoe GmbH
##### LastModified	14.07.2006
##### Function:		LicenceTransfer
##### Todo:			
########################################

use MutellaProxy::LicenceTransfer;

MutellaProxy::LicenceTransfer->TransferEncryptedContent();
MutellaProxy::LicenceTransfer->CheckIfEncryptedFileExists( );
MutellaProxy::LicenceTransfer->DecryptLicence();
MutellaProxy::LicenceTransfer->SendCheckSumOfFiles();
MutellaProxy::LicenceTransfer->InstallLicenceToDataBase();
MutellaProxy::LicenceTransfer->TestInstalledLicence();

#!/usr/bin/perl -I/server/mutella/MutellaProxy


# gzip: http://search.cpan.org/~pmqs/IO-Compress-Zlib-2.001/lib/IO/Compress/Gzip.pm


#########################################
##### Author:		Sebastian Enger / B.Sc
##### CopyRight:	BitJoe GmbH
##### LastModified	13.07.2006
##### Function:		Hauptdatei fr MutellaProxy
##### Todo:			for statt foreach: ist schneller
##### MileStones:	IPBlocker.pm->IPBlocker() funktioniert
#####				Status.pm->readStatus() funktioniert
#####				SortRank.pm->SortRank() funktioniert
########################################

# perl -MCPAN -e 'install "Crypt::Rijndael"'
# perl -MCPAN -e 'install "Crypt::CBC"'
# perl -MCPAN -e 'install "LWP::Simple"'
# perl -MCPAN -e 'install "String::Approx"' 
# perl -MCPAN -e 'install "Net::SCP::Expect"' 
# perl -MCPAN -e 'install "MIME::Lite"' 
# perl -MCPAN -e 'install "Sort::Array"' 
# perl -MCPAN -e 'install "File::Basename"' 
# perl -MCPAN -e 'install "Net::Nslookup"' 
# perl -MCPAN -e 'install "Digest::MD4"' 
# perl -MCPAN -e 'install "Digest::MD5"'
# perl -MCPAN -e 'install "IO::Socket::SSL"'
# perl -MCPAN -e 'install "CPAN"'
# perl -MCPAN -e 'install "Scalar::Util"'
# perl -MCPAN -e 'install "Net::SSLeay"'
# perl -MCPAN -e 'install "Crypt::SSLeay"'
# perl -MCPAN -e 'install "Crypt::IDEA"'
# perl -MCPAN -e 'install "Digest::SHA"'
# perl -MCPAN -e 'install "Crypt::RSA"'
# perl -MCPAN -e 'install "Crypt::Blowfish"'
# perl -MCPAN -e 'install "Crypt::GPG"'
# perl -MCPAN -e 'install "XML::Parser"'
# perl -MCPAN -e 'install "XMLRPC::Lite"'


##########
#### Merke: $FileTypeHashRef->{ 0 } = FORMATBILD|FORMATMP3 usw
#### Merke: $FileTypeHashRef->{ 1 } = 'jpg|mp3' usw
##########


system("clear");


... [truncated, 555 more lines] ...

#!/usr/bin/perl -I/server/mutella/MutellaProxy


# gzip: http://search.cpan.org/~pmqs/IO-Compress-Zlib-2.001/lib/IO/Compress/Gzip.pm


#########################################
##### Author:		Sebastian Enger / B.Sc
##### CopyRight:	BitJoe GmbH
##### LastModified	13.07.2006
##### Function:		Hauptdatei fr MutellaProxy
##### Todo:			for statt foreach: ist schneller
##### MileStones:	IPBlocker.pm->IPBlocker() funktioniert
#####				Status.pm->readStatus() funktioniert
#####				SortRank.pm->SortRank() funktioniert
########################################

# perl -MCPAN -e 'install "Crypt::Rijndael"'
# perl -MCPAN -e 'install "Crypt::CBC"'
# perl -MCPAN -e 'install "LWP::Simple"'
# perl -MCPAN -e 'install "String::Approx"' 
# perl -MCPAN -e 'install "Net::SCP::Expect"' 
# perl -MCPAN -e 'install "MIME::Lite"' 
# perl -MCPAN -e 'install "Sort::Array"' 
# perl -MCPAN -e 'install "File::Basename"' 
# perl -MCPAN -e 'install "Net::Nslookup"' 
# perl -MCPAN -e 'install "Digest::MD4"' 
# perl -MCPAN -e 'install "Digest::MD5"'
# perl -MCPAN -e 'install "IO::Socket::SSL"'
# perl -MCPAN -e 'install "CPAN"'
# perl -MCPAN -e 'install "Scalar::Util"'
# perl -MCPAN -e 'install "Net::SSLeay"'
# perl -MCPAN -e 'install "Crypt::SSLeay"'
# perl -MCPAN -e 'install "Crypt::IDEA"'
# perl -MCPAN -e 'install "Digest::SHA"'
# perl -MCPAN -e 'install "Crypt::RSA"'
# perl -MCPAN -e 'install "Crypt::Blowfish"'
# perl -MCPAN -e 'install "Crypt::GPG"'
# perl -MCPAN -e 'install "XML::Parser"'
# perl -MCPAN -e 'install "XMLRPC::Lite"'


##########
#### Merke: $FileTypeHashRef->{ 0 } = FORMATBILD|FORMATMP3 usw
#### Merke: $FileTypeHashRef->{ 1 } = 'jpg|mp3' usw
##########


system("clear");


... [truncated, 555 more lines] ...

#!/usr/bin/perl	-I/server/mutella/MutellaProxy

#########################################
##### Author:		Sebastian Enger / B.Sc
##### CopyRight:	BitJoe GmbH
##### LastModified	26.07.2006
##### Function:		Installiere automatisch ultrapeers zum Mutella
##### Todo:			
########################################


use MutellaProxy::Ultrapeers;

 MutellaProxy::Ultrapeers->GetAndInstallUltraPeerHostList();
 MutellaProxy::Ultrapeers->GetAndInstallUltraPeerHostListFromGwebCache();

#!/usr/bin/perl -I/server/mutella/MutellaProxy

use MutellaProxy::Gzip;
my $GZIP = MutellaProxy::Gzip->new();

#gzip_compress
#gzip_decompress

$file_to_compress		= "test.txt";







sub DoStingCompress(){

	my $string_to_compress = shift;

	my $compressed_string;
	my $LoopCount = 0;

	do {
		
		return 0 if ( $LoopCount >= 10 );
		$compressed_string = $GZIP->gzip_compress_string( $string_to_compress );
		$LoopCount++;

	} until ( $compressed_string != -1 );

	return $compressed_string;

}; # sub DoFileCompress(){





sub DoFileDeCompress(){

	my $decompressed_filename;
	my $LoopCount = 0;

	my $compressed_filename = shift;

	do {
		
		return 0 if ( $LoopCount >= 10 );
		$decompressed_filename = $GZIP->gzip_decompress( $compressed_filename );

... [truncated, 31 more lines] ...

use IO::Compress::Gzip qw(gzip $GzipError) ;

$input = "TESTSTRING";
print "comprimiere: $input \n";

#my $status = gzip $input => $output [	-BinModeIn	=> 1,
#										-Level		=> Z_BEST_COMPRESSION,
#									 ] 
#       or die "gzip failed: $GzipError\n";

 my $z = new IO::Compress::Gzip $output [,OPTS]
        or die "gzip failed: $GzipError\n";
		

print "compressed= |$output| \n";
print "Status=$status\n";

use IO::Socket::SSL;

$sock= new IO::Socket::SSL (
	PeerAddr => "localhost",
	PeerPort => 3382,
	Proto => 'tcp',
	Timeout => '5',
	SSL_verify_mode			=> 0x00,
	SSL_use_cert			=> 0,
	SSL_ca_file => '/server/mutella/certs/ca.key') or die;

print $sock "\r\n\r\n\r\n\r\n\r\nPariser Nchte\r\n";
$string = "find\r\n\r\n\r\n\r\n\r\nPariser\r\n";
#syswrite($sock, $string, length $string);
$back = <$sock>;
print "i got back: $back " . length $back;

$back = <$sock>;
print "i got back: $back\n";

#!/usr/bin/perl -I/server/mutella/MutellaProxy

#!!!!!!!!!! hinweise: $IO->writeSocket( $HandyClientSocket, GzipString("FC 908") . CRLF ); 
# gibt eventuell fehler beim auslesen

#########################################
##### Author:		Sebastian Enger / B.Sc
##### CopyRight:	BitJoe GmbH
##### LastModified	13.07.2006
##### Function:		Hauptdatei fr MutellaProxy
##### Todo:			for statt foreach: ist schneller
##### MileStones:	IPBlocker.pm->IPBlocker() funktioniert
#####				Status.pm->readStatus() funktioniert
#####				SortRank.pm->SortRank() funktioniert
########################################

# Mail.pm ->SendMail funktioniert erstmal nicht, habe gleich am anfang der funktion ein return 1; gesetzt
# add ultrapeer anpassen!  /server/wwwroot/gwebcache/data da liegen die gwebcaches drinne
# bestimmung der dateiendung funzt nich nicht richtig: bei suche nach "test jpeg" wird auch "adsfadsf.jpeg.jpg" gefunden


# perl -MCPAN -e 'install "Crypt::Rijndael"'
# perl -MCPAN -e 'install "Crypt::CBC"'
# perl -MCPAN -e 'install "LWP::Simple"'
# perl -MCPAN -e 'install "String::Approx"' 
# perl -MCPAN -e 'install "Net::SCP::Expect"' 
# perl -MCPAN -e 'install "MIME::Lite"' 
# perl -MCPAN -e 'install "Sort::Array"' 
# perl -MCPAN -e 'install "File::Basename"' 
# perl -MCPAN -e 'install "Net::Nslookup"' 
# perl -MCPAN -e 'install "Digest::MD4"' 
# perl -MCPAN -e 'install "Digest::MD5"'
# perl -MCPAN -e 'install "IO::Socket::SSL"'
# perl -MCPAN -e 'install "CPAN"'
# perl -MCPAN -e 'install "Scalar::Util"'
# perl -MCPAN -e 'install "Net::SSLeay"'
# perl -MCPAN -e 'install "Crypt::SSLeay"'
# perl -MCPAN -e 'install "Crypt::IDEA"'
# perl -MCPAN -e 'install "Digest::SHA"'
# perl -MCPAN -e 'install "Crypt::RSA"'
# perl -MCPAN -e 'install "Crypt::Blowfish"'
# perl -MCPAN -e 'install "Crypt::GPG"'
# perl -MCPAN -e 'install "XML::Parser"'
# perl -MCPAN -e 'install "XMLRPC::Lite"'
# perl -MCPAN -e 'force install "IO::Compress::Gzip"'

##########
#### Merke: $FileTypeHashRef->{ 0 } = FORMATBILD|FORMATMP3 usw
#### Merke: $FileTypeHashRef->{ 1 } = 'jpg|mp3' usw
##########

... [truncated, 671 more lines] ...

#!/usr/bin/perl

#########################################
##### Author:		Sebastian Enger / B.Sc
##### CopyRight:	BitJoe GmbH
##### LastModified	16.07.2006
##### Function:		MD5 Checksum erstellen		
##### Todo:			
########################################

package MutellaProxy::CheckSum;

# use Digest::MD5 qw(md5 md5_hex md5_base64);

use Digest::MD5 qw( md5_hex );
use Digest::MD4 qw( md4_hex );
use Digest::SHA1 qw( sha1_hex );

use strict;

my $VERSION = '0.18';


sub new(){
	
	my $self = bless {}, shift;
	return $self;
		
}; # sub new() {}


sub MD5ToHEX(){

	my $self	= shift;
	my $String	= shift;
	
	if ( ref($String) eq 'SCALAR' ) {
		return md5_hex( ${$String} );
	} elsif ( ref($String) eq '' ) {
		return md5_hex( $String );
	};

}; # sub md5_hex(){}


sub MD4ToHEX(){

	my $self	= shift;
	my $String	= shift;
	

... [truncated, 24 more lines] ...

#!/usr/bin/perl -I/server/mutella/MutellaProxy

#########################################
##### Author:		Sebastian Enger / B.Sc
##### CopyRight:	BitJoe GmbH
##### LastModified	13.07.2006
##### Function:		
##### Todo:			DEFAULT in encrypt und decrypt lschen!!
########################################

package MutellaProxy::CryptoLibrary;

use MutellaProxy::CheckSum;
use MutellaProxy::Time;
use MutellaProxy::SQL;
use Crypt::Rijndael;
use Crypt::CBC;
use strict;

my $VERSION			= '0.22.1';

sub new(){
	
	my $self = bless {}, shift;
	return $self;
		
}; # new(){}


sub GetPrivateCryptoKeyFromDatabase(){

	my $self		= shift;
	my $PublicKey	= shift;

	RESTART:

	$@ ='';
	undef $@;

	my $sth;
	my $sth2;
	my $DBHandle;
	my $ResultHashRef;
	
	eval {

		$DBHandle = MutellaProxy::SQL->SQLConnect();

		$sth = $DBHandle->prepare( qq { SELECT * FROM `Crypto` WHERE `PUBLICKEY` = "$PublicKey" AND `VALIDUNTIL` >= CURDATE() LIMIT 1; } );
		$sth->execute;

... [truncated, 182 more lines] ...

package MutellaProxy::Daemon;

#########################################
##### Author:		Lincoln Stein
##### CopyRight:	GPL
##### LastModified	11.07.2006
##### Function:		Daemon Fhigkeiten des Servers		
##### Todo:			
########################################

use strict;
use vars qw(@EXPORT @ISA @EXPORT_OK $VERSION);

use POSIX qw(:signal_h setsid WNOHANG);
use Carp 'croak','cluck';
use Carp::Heavy;
use File::Basename;
use IO::File;
use Cwd;
use Sys::Syslog qw(:DEFAULT setlogsock);
require Exporter;

@EXPORT_OK = qw(init_server prepare_child kill_children 
                launch_child do_relaunch
                log_debug log_notice log_warn 
                log_die %CHILDREN);
@EXPORT = @EXPORT_OK;
@ISA = qw(Exporter);
my $VERSION = '1.00';

use constant PIDPATH  => '/var/run';
use constant FACILITY => 'local0';
use vars qw(%CHILDREN);
my ($pid,$pidfile,$saved_dir,$CWD);

sub init_server {
  my ($user,$group);
  ($pidfile,$user,$group) = @_;
  $pidfile ||= getpidfilename();
  my $fh = open_pid_file($pidfile);
  become_daemon();
  print $fh $$;
  close $fh;
  init_log();
  change_privileges($user,$group) if defined $user && defined $group;
  return $pid = $$;
};

sub become_daemon {
  croak "Can't fork" unless defined (my $child = fork);

... [truncated, 121 more lines] ...

#!/usr/bin/perl	-I/server/mutella/MutellaProxy

#########################################
##### Author:		Sebastian Enger / B.Sc
##### CopyRight:	BitJoe GmbH
##### LastModified	11.07.2006
##### Function:		Debuggin Infomationen sammeln		
##### Todo:			
########################################

package MutellaProxy::Debug;

my $VERSION = '0.17';

use MutellaProxy::Time;
use Data::Dumper;
use strict;


my $DEBUGFILE	= '/server/mutella/DEBUG/DebugMessages.txt';


sub new() {
	
	my $self = bless {}, shift;
	return $self;
		
}; # new()


sub Debugging(){

	my $self				= shift;
	my $RefObj				= shift || 'MutellaProxy::Object';
	my $Dumper				= shift;
	my $ManualEditedText	= shift || '';
	my $Typ					= shift;

	if ( $Typ ne 'SCREEN' ) {
	
		my $MySQLDateTime = MutellaProxy::Time->MySQLDateTime();
		open(DEBUG,"+>>$DEBUGFILE") or sub { warn "MutellaProxy::Debug->Debugging(): IO ERROR: $!\n"; return -1; };
			flock (DEBUG, 2);
				print DEBUG "########## Entry from $MySQLDateTime ### RefObj $RefObj ##########\n";
				print DEBUG "########## Manual Text: $ManualEditedText ########################\n";
				print DEBUG Dumper( $Dumper );
				print DEBUG "##################################################################\n";
		close DEBUG;

	}; 

... [truncated, 7 more lines] ...

#!/usr/bin/perl -I/server/mutella/MutellaProxy

#########################################
##### Author:		Sebastian | modified 27.07.06 Torsten
##### CopyRight:	BitJoe GmbH
##### LastModified	27.07.06
##### Function:		Dateitypen definieren
##### Todo:			
########################################

package MutellaProxy::FileTypes;

use strict;

my $VERSION = '0.18';


sub new(){
	
	my $self = bless {}, shift;
	return $self;
		
}; # new()
  

sub BilderFileTypes(){

	my %BilderFileTypes = (
		1 => 'jpg', # first is default
		2 => 'jpeg',
		3 => 'png',
		4 => 'gif',
		5 => 'bmp',
		6 => 'tiff',
		7 => 'svg',
		8 => 'jpa',
		9 => 'tif',		
	);

	return \%BilderFileTypes;

};	# sub BilderFileTypes(){}


sub MP3FileTypes(){

	my %MP3FileTypes = (
		1 => 'mp3', # first is default
		2 => 'wma',
		3 => 'mp2',

... [truncated, 84 more lines] ...

#!/usr/bin/perl	-I/server/mutella/MutellaProxy

#########################################
##### Author:		Sebastian Enger / B.Sc
##### CopyRight:	BitJoe GmbH
##### LastModified	27.07.2006
##### Function:		verschiede Filter fr die Results
##### Todo:			
########################################

package MutellaProxy::Filter;

# use String::Approx 'amatch';
use MutellaProxy::IO;
use strict;


#	FORMATBILD=200K
#	FORMATMP3=6M
#	FORMATRING=200K
#	FORMATVIDEO=15M
#	FORMATJAVA=350K
#	FORMATDOC=500K


my $SIZEFILTER	= '/server/mutella/FILTER/sizefilter.dat';


sub new(){
	
	my $self = bless {}, shift;
	return $self;
		
}; # sub new(){}


sub SizeFilter(){

	my $self				= shift;
	my $type				= shift;
	my $GivenSizeInBytes	= shift;

	my $ContentArrayRef		= MutellaProxy::IO->ReadFileIntoArray( $SIZEFILTER );

	my $multiply;

	foreach my $entry ( @{$ContentArrayRef} ) {
		
		next if ( $entry =~ /^#/ );


... [truncated, 46 more lines] ...

#!/usr/bin/perl -I/server/mutella/MutellaProxy

#########################################
##### Author:		Patrick Canterino / Sebastian Enger / B.Sc
##### CopyRight:	2003 Patrick Canterino / since 2006 BitJoe GmbH
##### LastModified	11.07.2006
##### Function:		Gzip (De)Compression of Files/Strings
##### Todo:			Testing
########################################

package MutellaProxy::Gzip;


use MutellaProxy::CryptoLibrary;
use MutellaProxy::CheckSum;
use base qw(Exporter);
use MutellaProxy::IO;
use strict;


my $VERSION = '0.10';

use vars qw( @EXPORT
            $gzippath);

### Export ###
@EXPORT = qw(
			gzip_compress
            gzip_decompress
			gzip_compress_string
			gzip_decompress_string
			);


# Constructor
sub new(){
	
	my $self = bless {}, shift;
	return $self;
		
}; # new()


# Pfad zum GZip-Programm (erreichbar ueber $GZip::gzippath)
my $gzippath = '/bin/gzip';
my $temppath = '/server/mutella/tmp';


# ============================
#  Zugriff mit Compress::Zlib

... [truncated, 323 more lines] ...

#!/usr/bin/perl	-I/server/mutella/MutellaProxy

#########################################
##### Author:		Sebastian Enger / B.Sc
##### CopyRight:	BitJoe GmbH
##### LastModified	16.07.2006
##### Function:		IO spezifisches Modul
##### Todo:			
########################################

package MutellaProxy::IO;

my $VERSION = '0.19.1';

# use IO::Socket::SSL qw(debug4);

use MutellaProxy::CryptoLibrary;
use MutellaProxy::CheckSum;
use IO::Socket;
use strict;


use constant UNIXSOCKET		=> '/server/mutella/socket';
use constant RANDOM_DEVICE	=> '/dev/urandom';
use constant MAXINCBYTES	=> 50 * 1024 * 1024;	# 10 mbytes


sub new(){
	
	my $self = bless {}, shift;
	return $self;
		
}; # new()


sub readSocket() {
	
	my $self	= shift;
	my $socket	= shift;
	
	my $IO;
	my $STREAM;
	my $StreamCount = 0;

	binmode($socket);

	while (sysread($socket , $IO, 1) == 1) {
		
		if ( $StreamCount == MAXINCBYTES ) {
			# breche ab, wenn mehr als MAXINCBYTES Bytes in einer Session an den Server gesendet wurden

... [truncated, 228 more lines] ...

#!/usr/bin/perl	-I/server/mutella/MutellaProxy

#########################################
##### Author:		Sebastian Enger / B.Sc
##### CopyRight:	BitJoe GmbH
##### LastModified	16.07.2006
##### Function:		IO spezifisches Modul
##### Todo:			
########################################

package MutellaProxy::IOSSL;

my $VERSION = '0.19.1';

use IO::Socket::SSL;
use IO::Socket;
use strict;


use constant UNIXSOCKET		=> '/server/mutella/socket';
use constant RANDOM_DEVICE	=> '/dev/urandom';
use constant MAXINCBYTES	=> 50 * 1024 * 1024;	# 10 mbytes


sub new(){
	
	my $self = bless {}, shift;
	return $self;
		
}; # new()


sub readSocket() {
	
	my $self	= shift;
	my $socket	= shift;
	
	my $IO;
	my $STREAM;
	my $StreamCount = 0;

	while (sysread($socket , $IO, 1) == 1) {
		
		if ( $StreamCount == MAXINCBYTES ) {
			# breche ab, wenn mehr als MAXINCBYTES Bytes in einer Session an den Server gesendet wurden
			print "WARNING: Possible Denial of Service Attack - more than " .MAXINCBYTES. " Bytes of incoming Traffic!\n";
			$STREAM = '';
			exit(0);
		};
		

... [truncated, 222 more lines] ...

#!/usr/bin/perl	-I/server/mutella/MutellaProxy

#########################################
##### Author:		Sebastian Enger / B.Sc
##### CopyRight:	BitJoe GmbH
##### LastModified	16.07.2006
##### Function:		IP Filter fr die Results
##### Todo:			
########################################

package MutellaProxy::IPFilter;
use strict;

my $VERSION		= '0.18.1';

my $REALOADFILE = '/server/mutella/IPFILTER/reload.txt';
my $IPFILTER	= '/server/mutella/IPFILTER/ipfilter.dat';
my $TMPFILTER	= '/server/mutella/IPFILTER/tempfilter.txt';
my $IPBLOCKER	= '/server/mutella/IPFILTER/ipblocker.txt';	# eine IP pro Zeile


sub new(){
	
	my $self = bless {}, shift;
	return $self;
		
}; # sub new(){}


sub IPBlocker(){

	my $self	= shift;
	my $GivenIP	= shift;

	open(BLOCKER, "<$IPBLOCKER") or sub { warn "MutellaProxy::IPFilter->IPBlocker(): Blocking not possible: IO ERROR: $!\n"; return -1; };
		flock (BLOCKER, 2);
		while( defined( my $IPperLine = <BLOCKER> ) ){
			$IPperLine =~ s/[\s]//g;
			if ( $IPperLine eq $GivenIP || $IPperLine == $GivenIP ) {
				close BLOCKER;
				return -1; # sind equal
			}; # if ( $IPperLine eq
		}; # while 
	close BLOCKER;

	return 0;	# nicht gleich, wenn kein Match

}; # sub IPBlocker(){}



... [truncated, 188 more lines] ...

#!/usr/bin/perl	-I/server/mutella/MutellaProxy

#########################################
##### Author:		Sebastian Enger / B.Sc
##### CopyRight:	BitJoe GmbH
##### LastModified	16.07.2006
##### Function:		Lizenzen generieren
##### Todo:			
########################################

package MutellaProxy::LicenceGenerator;
  
use MutellaProxy::CryptoLibrary;
use MutellaProxy::CheckSum;
use MutellaProxy::Mutella;
use MutellaProxy::Debug;
use MutellaProxy::Time;
use MutellaProxy::SQL;
use strict;


my $VERSION				= '0.21.0';
my $LICENCESTOREPATH	= '/server/mutella/LICENCE';	  # later Config

# diese werte mssen ensprechend gendert werden
my $ClientCurrentMin	= "1.0";
my $ClientCurrentMax	= "1.1";


sub new(){
	
	my $self = bless {}, shift;
	return $self;
		
}; # new(){}


sub GenerateALLLicenceForToday(){

	my $self			= shift;
	my $Licence			= $self->GenerateLicence();		
	my $PUBLICKEY		= $self->GenerateLicence();		
	my $PRIVATEKEY		= $self->GenerateLicence();	
	my $ValidUntil		= MutellaProxy::Time->GetValid8DayDateForLicence();
	my $MySQLDateTime	= MutellaProxy::Time->MySQLDateTime();

	my $LICENCE=<<END_OF_SQL;
INSERT DELAYED INTO `Licence` ( `UNID` , `LICENCE` , `CMIN` , `CMAX` , `VALIDUNTIL` , `FORMATBILD` , `FORMATMP3` , `FORMATRING` , `FORMATVIDEO` , `FORMATJAVA` , `FORMATDOC` , `ADDED` , `HITS` ) VALUES ( "", "$Licence", "$ClientCurrentMin", "$ClientCurrentMax", "$ValidUntil", "1", "1", "1", "1", "1", "1", "$MySQLDateTime", "0");
END_OF_SQL


... [truncated, 647 more lines] ...

#!/usr/bin/perl	-I/server/mutella/MutellaProxy

#########################################
##### Author:		Sebastian Enger / B.Sc
##### CopyRight:	BitJoe GmbH
##### LastModified	12.07.2006
##### Function:		LicenceManagement
##### Todo:			
########################################

package MutellaProxy::LicenceManagement;

use MutellaProxy::FileTypes;
use MutellaProxy::SQL;
use strict;


my $VERSION = '0.17.1';

sub new() {
	
	my $self = bless {}, shift;
	return $self;
		
}; # new()


sub CheckLicence(){
	
	my $self				= shift;
	my $ArrayRef			= shift;
		
	my $WishedFileType		= $ArrayRef->[1];
	my $Licence				= $ArrayRef->[3];
	my $ClientVersion		= $ArrayRef->[4];
	
	my $AllowedLicenceFlag	= 0;
	my $AllowedClientFlag	= 0;
	my $AllowedFileTypeFlag = 0;

	my $CurrentFileType		= {};
	my $FileTypeHashRef		= {};
	my $ResultHashRef;		# wird beim sql query dann mit werten gefllt
	my $DBHandle;
	my $FileType;
	my $sth;

	RESTARTONE:
	$@ ='';
	undef $@;

... [truncated, 148 more lines] ...

#!/usr/bin/perl	-I/server/mutella/MutellaProxy

#########################################
##### Author:		Sebastian Enger / B.Sc
##### CopyRight:	BitJoe GmbH
##### LastModified	16.07.2006
##### Function:		LicenceTransfer
##### Todo:			
########################################


# my $scpe = Net::SCP::Expect->new(host=>'85.214.59.105', user=>'root', password=>'PQdfqZHr');
# $scpe->auto_yes(1);
# $scpe->scp('/server/mutella/MutellaProxy_V0.1.9.pl','root@85.214.59.105:/root/');

package MutellaProxy::LicenceTransfer;

use MutellaProxy::CryptoLibrary;
use MutellaProxy::CheckSum;
use MutellaProxy::Mail;
use MutellaProxy::Time;
use MutellaProxy::SQL;
use MutellaProxy::IO;
use Net::SCP::Expect;		#  perl -MCPAN -e 'install "Net::SCP::Expect"' 
use strict;

my $VERSION				= '0.20.1';
my $LICENCEPATH			= '/server/mutella/LICENCE';				# todo: config auslesen
my $CRYPTOLICENCEPATH	= '/server/mutella/LICENCE/ENCRYPTED';	# todo: config auslesen
my $DECRYPTEDLICENCEPATH= '/server/mutella/LICENCE/DECRYPTED';

my $CRYPTOKEY			= '12341234123412341234123412342341';	# todo: config auslesen


# Definiere einen Config Hash - hier stehen alle Username,Passwords u. Hostnames drinne, zu denen die verschlsselten Daten bertragen werden sollen
my %ConfigHash =(
	"1"	=> my $CfG1 = { 
			"HOST"	=> "85.214.59.105",
			"USER"	=> "root",
			"PASS"	=> "PQdfqZHr",
			"PATH"	=> "/server/mutella/"
			},
#	"2"	=> my $CfG2 = { 
#			"HOST"	=> "HOSTIP",
#			"USER"	=> "USERNAME",
#			"PASS"	=> "PASSWORD",
#			"PATH"	=> "/root/.mutella"	 # wo soll es gespeichert werden
#			}, 
);


... [truncated, 367 more lines] ...

#!/usr/bin/perl -I/server/mutella/MutellaProxy

#########################################
##### Author:		Sebastian Enger / B.Sc
##### CopyRight:	BitJoe GmbH
##### LastModified	11.07.2006
##### Function:		Logging
##### Todo:			logging ^^
########################################

package MutellaProxy::Logging;

my $VERSION = '0.17';

use MutellaProxy::Time;
use strict;

my $LOGINIT		= '/server/mutella/LOGS/INITLOG.txt';
my $LOGRESULTS	= '/server/mutella/LOGS/GETRESULTSLOG.txt';
my $LOGSTARTDL	= '/server/mutella/LOGS/STARTDOWNLOADLOG.txt';
my $LOGENDDL	= '/server/mutella/LOGS/FINISHDOWNLOADLOG.txt';
my $LOGLICENCE	= '/server/mutella/LOGS/INVALIDLICENCELOG.txt';

#use IO::Handle;

sub new() {
	
	my $self = bless {}, shift;
	return $self;
		
}; # new();


sub LogToFileInit(){
	
	my $self			= shift;
	my $LogScalarRef	= shift;
	my $Hostname		= shift;
	my $IpAdress		= shift;

	#	$hostinfo->name || $client->peerhost;

	my ( $type, $flag, $IMEI, $LicenceKey, $ClientVersion, $SearchQuery , $FileType , $JavaVersion, $HandyModel , $MobilePhoneProvider, $ResultID ) = split("\r\n", ${$LogScalarRef}); 
	my $UnixTimeStamp = time();
	my $MySQLDateTime = MutellaProxy::Time->MySQLDateTime();

	# later: open(LOG,"+>>/logs/log") or doSQLLogs()

	open(LOG,"+>>$LOGINIT") or sub { warn "MutellaProxy::Logging->LogToFileInit(): IO ERROR: $!\n"; return -1; };
		flock (LOG, 2);

... [truncated, 197 more lines] ...