/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

#include "compare.h"
#include <log4cxx/helpers/pool.h>
#include <log4cxx/file.h>
#include <log4cxx/helpers/stringhelper.h>
#include <log4cxx/helpers/fileinputstream.h>
#include <log4cxx/helpers/inputstreamreader.h>
#include <log4cxx/helpers/systemoutwriter.h>

using namespace log4cxx;
using namespace log4cxx::helpers;

bool Compare::compare(const File& file1, const File& file2)
{
	Pool pool;
	InputStreamPtr fileIn1 = new FileInputStream(file1);
	InputStreamReaderPtr reader1 = new InputStreamReader(fileIn1);
	LogString in1(reader1->read(pool));

	Pool pool2;
	InputStreamPtr fileIn2 = new FileInputStream(file2);
	InputStreamReaderPtr reader2 = new InputStreamReader(fileIn2);
	LogString in2(reader2->read(pool2));

	LogString back1(in1);
	LogString back2(in2);

	LogString s1;
	LogString s2;
	int lineCounter = 0;

	while (getline(in1, s1))
	{
		lineCounter++;

		if (!getline(in2, s2))
		{
			s2.erase(s2.begin(), s2.end());
		}

		if (s1 != s2)
		{
			LogString msg(LOG4CXX_STR("Files ["));
			msg += file1.getPath();
			msg += LOG4CXX_STR("] and [");
			msg += file2.getPath();
			msg += LOG4CXX_STR("] differ on line ");
			StringHelper::toString(lineCounter, pool, msg);
			msg += LOG4CXX_EOL;
			msg += LOG4CXX_STR("One reads:  [");
			msg += s1;
			msg += LOG4CXX_STR("].");
			msg += LOG4CXX_EOL;
			msg += LOG4CXX_STR("Other reads:[");
			msg += s2;
			msg += LOG4CXX_STR("].");
			msg += LOG4CXX_EOL;
			emit(msg);

			outputFile(file1, back1, pool);
			outputFile(file2, back2, pool);

			return false;
		}
	}

	// the second file is longer
	if (getline(in2, s2))
	{
		LogString msg(LOG4CXX_STR("File ["));
		msg += file2.getPath();
		msg += LOG4CXX_STR("] longer than file [");
		msg += file1.getPath();
		msg += LOG4CXX_STR("].");
		msg += LOG4CXX_EOL;
		emit(msg);
		outputFile(file1, back1, pool);
		outputFile(file2, back2, pool);

		return false;
	}

	return true;
}

void Compare::outputFile(const File& file,
	const LogString& contents,
	log4cxx::helpers::Pool& pool)
{
	int lineCounter = 0;
	emit(LOG4CXX_STR("--------------------------------"));
	emit(LOG4CXX_EOL);
	LogString msg(LOG4CXX_STR("Contents of "));
	msg += file.getPath();
	msg += LOG4CXX_STR(":");
	msg += LOG4CXX_EOL;
	emit(msg);
	LogString in1(contents);
	LogString s1;

	while (getline(in1, s1))
	{
		lineCounter++;
		LogString line;
		StringHelper::toString(lineCounter, pool, line);
		emit(line);

		if (lineCounter < 10)
		{
			emit(LOG4CXX_STR("   : "));
		}
		else if (lineCounter < 100)
		{
			emit(LOG4CXX_STR("  : "));
		}
		else if (lineCounter < 1000)
		{
			emit(LOG4CXX_STR(" : "));
		}
		else
		{
			emit(LOG4CXX_STR(": "));
		}

		emit(s1);
		emit(LOG4CXX_EOL);
	}
}

void Compare::emit(const LogString& s1)
{
	SystemOutWriter::write(s1);
}


bool Compare::getline(LogString& in, LogString& line)
{
	if (in.empty())
	{
		return false;
	}

	size_t nl = in.find(0x0A);

	if (nl == std::string::npos)
	{
		line = in;
		in.erase(in.begin(), in.end());
	}
	else
	{
		//
		//  if the file has CR-LF then
		//    drop the carriage return alse
		//
		if (nl > 0 && in[nl - 1] ==  0x0D)
		{
			line.assign(in, 0, nl - 1);
		}
		else
		{
			line.assign(in, 0, nl);
		}

		in.erase(in.begin(), in.begin() + nl + 1);
	}

	return true;
}