#include "global.h"
#include "CryptHelpers.h"
#include "RageFile.h"
#include "RageUtil.h"
#include "RageLog.h"

// crypt headers
#include "crypto51/files.h"
#include "crypto51/filters.h"
#include "crypto51/cryptlib.h"
#include "crypto51/files.h"
#include "crypto51/sha.h"
#include "crypto51/rsa.h"
#include "crypto51/osrng.h"

using namespace CryptoPP;

class RageFileStore : public Store, private FilterPutSpaceHelper
{
public:
	class Err : public Exception
	{
	public:
		Err(const std::string &s) : Exception(IO_ERROR, s) {}
	};
	class OpenErr : public Err {public: OpenErr(const std::string &filename) : Err("FileStore: error opening file for reading: " + filename) {}};
	struct ReadErr : public Err { ReadErr( const RageFileBasic &f ); };

	RageFileStore( RageFileBasic *pFile ); /* pFile will be deleted */
	~RageFileStore();
	RageFileStore( const RageFileStore &cpy );
	RageFileStore(const char *filename)
		{StoreInitialize(MakeParameters("InputFileName", filename));}

	unsigned long MaxRetrievable() const;
	unsigned int TransferTo2(BufferedTransformation &target, unsigned long &transferBytes, const std::string &channel=NULL_CHANNEL, bool blocking=true);
	unsigned int CopyRangeTo2(BufferedTransformation &target, unsigned long &begin, unsigned long end=ULONG_MAX, const std::string &channel=NULL_CHANNEL, bool blocking=true) const;

private:
	void StoreInitialize(const NameValuePairs &parameters);
	
	mutable RageFileBasic *m_pFile;	// mutable because reading from a file is not a const operation
	byte *m_space;
	int m_len;
	bool m_waiting;
};

class RageFileSource : public SourceTemplate<RageFileStore>
{
public:
	typedef FileStore::Err Err;
	typedef FileStore::OpenErr OpenErr;
	typedef FileStore::ReadErr ReadErr;

	RageFileSource( RageFileBasic *pFile, bool pumpAll, BufferedTransformation *attachment = NULL, bool binary=true )
		: SourceTemplate<RageFileStore>(attachment,RageFileStore(pFile)) {SourceInitialize(pumpAll, MakeParameters("InputBinaryMode", binary));}
};

RageFileStore::ReadErr::ReadErr( const RageFileBasic &f ):
	Err( "RageFileStore read error: " + f.GetError() )
{
}

RageFileStore::RageFileStore( RageFileBasic *pFile )
{
	m_pFile = pFile;
	m_waiting = false;
}

RageFileStore::~RageFileStore()
{
	delete m_pFile;
}

RageFileStore::RageFileStore( const RageFileStore &cpy ):
	Store(cpy),
	FilterPutSpaceHelper(cpy)
{
	if( cpy.m_pFile != NULL )
		m_pFile = cpy.m_pFile->Copy();
	else
		m_pFile = NULL;

	ASSERT( !cpy.m_waiting );
	m_waiting = false;
}


void RageFileStore::StoreInitialize(const NameValuePairs &parameters)
{
	ASSERT( m_pFile != NULL );
	m_waiting = false;
}

unsigned long RageFileStore::MaxRetrievable() const
{
	if( m_pFile == NULL || m_pFile->AtEOF() || !m_pFile->GetError().empty() )
		return 0;
	
	return m_pFile->GetFileSize() - m_pFile->Tell();
}

unsigned int RageFileStore::TransferTo2(BufferedTransformation &target, unsigned long &transferBytes, const std::string &channel, bool blocking)
{
	if( m_pFile == NULL || m_pFile->AtEOF() || !m_pFile->GetError().empty() )
	{
		transferBytes = 0;
		return 0;
	}
	
	unsigned long size=transferBytes;
	transferBytes = 0;
	
	if( m_waiting )
		goto output;
	
	while( size && !m_pFile->AtEOF() )
	{
		{
			unsigned int spaceSize = 1024;
			m_space = HelpCreatePutSpace(target, channel, 1, (unsigned int)STDMIN(size, (unsigned long)UINT_MAX), spaceSize);
			
			m_len = m_pFile->Read( (char *)m_space, STDMIN(size, (unsigned long)spaceSize));
			if( m_len == -1 )
				throw ReadErr( *m_pFile );
		}
		unsigned int blockedBytes;
output:
		blockedBytes = target.ChannelPutModifiable2(channel, m_space, m_len, 0, blocking);
		m_waiting = blockedBytes > 0;
		if( m_waiting )
			return blockedBytes;
		size -= m_len;
		transferBytes += m_len;
	}
	
	return 0;
}


unsigned int RageFileStore::CopyRangeTo2(BufferedTransformation &target, unsigned long &begin, unsigned long end, const std::string &channel, bool blocking) const
{
	if( m_pFile == NULL || m_pFile->AtEOF() || !m_pFile->GetError().empty() )
		return 0;
	
	if( begin == 0 && end == 1 )
	{
		int current = m_pFile->Tell();
		byte result;
		m_pFile->Read( &result, 1 );
		m_pFile->Seek( current );
		if( m_pFile->AtEOF() )
			return 0;

		unsigned int blockedBytes = target.ChannelPut( channel, byte(result), blocking );
		begin += 1-blockedBytes;
		return blockedBytes;
	}
	
	// TODO: figure out what happens on cin
	// (What does that mean?)
	int current = m_pFile->Tell();
	int newPosition = current + (streamoff)begin;
	
	if( newPosition >= m_pFile->GetFileSize() )
		return 0;	// don't try to seek beyond the end of file

	m_pFile->Seek( newPosition );
	try
	{
		ASSERT( !m_waiting );
		unsigned long copyMax = end-begin;
		unsigned int blockedBytes = const_cast<RageFileStore *>(this)->TransferTo2( target, copyMax, channel, blocking );
		begin += copyMax;
		if( blockedBytes )
		{
			const_cast<RageFileStore *>(this)->m_waiting = false;
			return blockedBytes;
		}
	}
	catch(...)
	{
		m_pFile->ClearError();
		m_pFile->Seek( current );
		throw;
	}
	m_pFile->ClearError();
	m_pFile->Seek( current );
	
	return 0;
}

bool CryptHelpers::GenerateRSAKey( unsigned int keyLength, CString sSeed, CString &sPublicKey, CString &sPrivateKey )
{
#ifdef _XBOX
	return false;
#else
	try
	{
		NonblockingRng rng;

		RSASSA_PKCS1v15_SHA_Signer priv(rng, keyLength);
		StringSink privFile( sPrivateKey );
		priv.DEREncode(privFile);
		privFile.MessageEnd();

		RSASSA_PKCS1v15_SHA_Verifier pub(priv);
		StringSink pubFile( sPublicKey );
		pub.DEREncode(pubFile);
		pubFile.MessageEnd();
	} catch( const CryptoPP::Exception &s ) {
		LOG->Warn( "GenerateRSAKey failed: %s", s.what() );
		return false;
	}

	return true;
#endif
}

bool CryptHelpers::SignFile( RageFileBasic &file, CString sPrivKey, CString &sSignatureOut, CString &sError )
{
#ifdef _XBOX
	return false;
#else
	try {
		StringSource privFile( sPrivKey, true );
		RSASSA_PKCS1v15_SHA_Signer priv(privFile);
		NonblockingRng rng;

		/* RageFileSource will delete the file we give to it, so make a copy. */
		RageFileSource f( file.Copy(), true, new SignerFilter(rng, priv, new StringSink(sSignatureOut)) );
	} catch( const CryptoPP::Exception &s ) {
		LOG->Warn( "SignFileToFile failed: %s", s.what() );
		return false;
	}

	return true;
#endif
}

bool CryptHelpers::VerifyFile( RageFileBasic &file, CString sSignature, CString sPublicKey, CString &sError )
{
	try {
		StringSource pubFile( sPublicKey, true );
		RSASSA_PKCS1v15_SHA_Verifier pub(pubFile);

		if( sSignature.size() != pub.SignatureLength() )
		{
			sError = ssprintf( "Invalid signature length: got %i, expected %i", int(sSignature.size()), pub.SignatureLength() );
			return false;
		}

		VerifierFilter *verifierFilter = new VerifierFilter(pub);
		verifierFilter->Put( (byte *) sSignature.data(), sSignature.size() );

		/* RageFileSource will delete the file we give to it, so make a copy. */
		RageFileSource f( file.Copy(), true, verifierFilter );

		if( !verifierFilter->GetLastResult() )
		{
			sError = ssprintf( "Signature mismatch" );
			return false;
		}
		
		return true;
	} catch( const CryptoPP::Exception &s ) {
		sError = s.what();
		return false;
	}
}

/*
 * (c) 2001-2004 Chris Danford
 * All rights reserved.
 * 
 * Permission is hereby granted, free of charge, to any person obtaining a
 * copy of this software and associated documentation files (the
 * "Software"), to deal in the Software without restriction, including
 * without limitation the rights to use, copy, modify, merge, publish,
 * distribute, and/or sell copies of the Software, and to permit persons to
 * whom the Software is furnished to do so, provided that the above
 * copyright notice(s) and this permission notice appear in all copies of
 * the Software and that both the above copyright notice(s) and this
 * permission notice appear in supporting documentation.
 * 
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
 * OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
 * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT OF
 * THIRD PARTY RIGHTS. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR HOLDERS
 * INCLUDED IN THIS NOTICE BE LIABLE FOR ANY CLAIM, OR ANY SPECIAL INDIRECT
 * OR CONSEQUENTIAL DAMAGES, OR ANY DAMAGES WHATSOEVER RESULTING FROM LOSS
 * OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR
 * OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
 * PERFORMANCE OF THIS SOFTWARE.
 */