/*
 * Copyright (C) 2007-2012 Siemens AG
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Lesser General Public License as published
 * by the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Lesser General Public License for more details.
 * GNU Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public License
 * along with this program. If not, see <http://www.gnu.org/licenses/>.
 */

/*******************************************************************
 *
 * @author Daniel.Peintner.EXT@siemens.com
 * @version 0.7
 * @contact Joerg.Heuer@siemens.com
 *
 * <p>Code generated by EXIdizer.com</p>
 ********************************************************************/



#include "EncoderChannel.h"
#include "CoderChannel.h"
#include "BitOutputStream.h"
#include "EXIOptions.h"
#include "EXITypes.h"
#include "ErrorCodes.h"
#include "MethodsBag.h"
#include "EXICoder.h"

#ifndef ABSTRACT_ENCODER_CHANNEL_C
#define ABSTRACT_ENCODER_CHANNEL_C

int encodeUnsignedInteger(bitstream_t* stream, exi_integer_t* iv) {
	int errn = 0;
	switch (iv->type) {
	/* Unsigned Integer */
	case EXI_UNSIGNED_INTEGER_8:
		errn = encodeUnsignedInteger32(stream, iv->val.uint8);
		break;
	case EXI_UNSIGNED_INTEGER_16:
		errn = encodeUnsignedInteger32(stream, iv->val.uint16);
		break;
	case EXI_UNSIGNED_INTEGER_32:
		errn = encodeUnsignedInteger32(stream, iv->val.uint32);
		break;
	case EXI_UNSIGNED_INTEGER_64:
		errn = encodeUnsignedInteger64(stream, iv->val.uint64);
		break;
		/* (Signed) Integer */
	case EXI_INTEGER_8:
		if (iv->val.int8 < 0) {
			return EXI_NEGATIVE_UNSIGNED_INTEGER_VALUE;
		}
		errn = encodeUnsignedInteger32(stream, iv->val.int8);
		break;
	case EXI_INTEGER_16:
		if (iv->val.int16 < 0) {
			return EXI_NEGATIVE_UNSIGNED_INTEGER_VALUE;
		}
		errn = encodeUnsignedInteger32(stream, iv->val.int16);
		break;
	case EXI_INTEGER_32:
		if (iv->val.int32 < 0) {
			return EXI_NEGATIVE_UNSIGNED_INTEGER_VALUE;
		}
		errn = encodeUnsignedInteger32(stream, iv->val.int32);
		break;
	case EXI_INTEGER_64:
		if (iv->val.int64 < 0) {
			return EXI_NEGATIVE_UNSIGNED_INTEGER_VALUE;
		}
		errn = encodeUnsignedInteger64(stream, iv->val.int64);
		break;
	default:
		errn = EXI_UNSUPPORTED_INTEGER_VALUE_TYPE;
		break;
	}

	return errn;
}

/**
 * Encode an arbitrary precision non negative integer using a sequence of
 * octets. The most significant bit of the last octet is set to zero to
 * indicate sequence termination. Only seven bits per octet are used to
 * store the integer's value.
 */
int encodeUnsignedInteger32(bitstream_t* stream, uint32_t n) {
	int errn = 0;
	if (n < 128) {
		/* write byte as is */
		errn = encode(stream, (uint8_t) n);
	} else {
		uint8_t n7BitBlocks = numberOf7BitBlocksToRepresent(n);

		switch (n7BitBlocks) {
		case 5:
			errn = encode(stream, (uint8_t) (128 | n));
			n = n >> 7;
			if (errn < 0) {
				break;
			}
			/* no break */
		case 4:
			errn = encode(stream, (uint8_t) (128 | n));
			n = n >> 7;
			if (errn < 0) {
				break;
			}
			/* no break */
		case 3:
			errn = encode(stream, (uint8_t) (128 | n));
			n = n >> 7;
			if (errn < 0) {
				break;
			}
			/* no break */
		case 2:
			errn = encode(stream, (uint8_t) (128 | n));
			n = n >> 7;
			if (errn < 0) {
				break;
			}
			/* no break */
		case 1:
			/* 0 .. 7 (last byte) */
			errn = encode(stream, (uint8_t) (0 | n));
			/* no break */
		}
	}

	return errn;
}

/**
 * Encode an arbitrary precision non negative integer using a sequence of
 * octets. The most significant bit of the last octet is set to zero to
 * indicate sequence termination. Only seven bits per octet are used to
 * store the integer's value.
 */
int encodeUnsignedInteger64(bitstream_t* stream, uint64_t n) {
	int errn = 0;
	uint8_t lastEncode = (uint8_t) n;
	n >>= 7;

	while (n != 0) {
		errn = encode(stream, lastEncode | 128);
		if (errn < 0) {
			return errn;
		}
		lastEncode = (uint8_t) n;
		n >>= 7;
	}

	return encode(stream, lastEncode);
}

int encodeInteger(bitstream_t* stream, exi_integer_t* iv) {
	int errn = 0;
	switch (iv->type) {
	/* Unsigned Integer */
	case EXI_UNSIGNED_INTEGER_8:
		errn = encodeInteger32(stream, iv->val.uint8);
		break;
	case EXI_UNSIGNED_INTEGER_16:
		errn = encodeInteger32(stream, iv->val.uint16);
		break;
	case EXI_UNSIGNED_INTEGER_32:
		errn = encodeInteger64(stream, iv->val.uint32);
		break;
	case EXI_UNSIGNED_INTEGER_64:
		errn = encodeInteger64(stream, iv->val.uint64);
		break;
		/* (Signed) Integer */
	case EXI_INTEGER_8:
		errn = encodeInteger32(stream, iv->val.int8);
		break;
	case EXI_INTEGER_16:
		errn = encodeInteger32(stream, iv->val.int16);
		break;
	case EXI_INTEGER_32:
		errn = encodeInteger32(stream, iv->val.int32);
		break;
	case EXI_INTEGER_64:
		errn = encodeInteger64(stream, iv->val.int64);
		break;
	default:
		errn = EXI_UNSUPPORTED_INTEGER_VALUE_TYPE;
		break;
	}

	return errn;
}

/**
 * Encode an arbitrary precision integer using a sign bit followed by a
 * sequence of octets. The most significant bit of the last octet is set to
 * zero to indicate sequence termination. Only seven bits per octet are used
 * to store the integer's value.
 */
int encodeInteger32(bitstream_t* stream, int32_t n) {
	int errn;
	/* signalize sign */
	if (n < 0) {
		errn = encodeBoolean(stream, 1);
		/* For negative values, the Unsigned Integer holds the
		 * magnitude of the value minus 1 */
		n = (-n) - 1;
	} else {
		errn = encodeBoolean(stream, 0);
	}
	if (errn < 0) {
		return errn;
	}
	return encodeUnsignedInteger32(stream, n);
}

/**
 * Encode an arbitrary precision integer using a sign bit followed by a
 * sequence of octets. The most significant bit of the last octet is set to
 * zero to indicate sequence termination. Only seven bits per octet are used
 * to store the integer's value.
 */
int encodeInteger64(bitstream_t* stream, int64_t n) {
	int errn;
	/* signalize sign */
	if (n < 0) {
		errn = encodeBoolean(stream, 1);
		/* For negative values, the Unsigned Integer holds the
		 * magnitude of the value minus 1 */
		n = (-n) - 1;
	} else {
		errn = encodeBoolean(stream, 0);
	}
	if (errn < 0) {
		return errn;
	}
	return encodeUnsignedInteger64(stream, n);
}

/**
 * The Float datatype representation is two consecutive Integers.
 * The first Integer represents the mantissa of the floating point
 * number and the second Integer represents the base-10 exponent
 * of the floating point number.
 */
int encodeFloat(bitstream_t* stream, exi_float_me_t* f) {
	int errn = encodeInteger64(stream, f->mantissa);
	if (errn >= 0) {
		errn = encodeInteger32(stream, f->exponent);
	}
	return errn;
}

/**
 * Encode a decimal represented as a Boolean sign followed by two Unsigned
 * Integers. A sign value of zero (0) is used to represent positive Decimal
 * values and a sign value of one (1) is used to represent negative Decimal
 * values The first Integer represents the integral portion of the Decimal
 * value. The second positive integer represents the fractional portion of
 * the decimal with the digits in reverse order to preserve leading zeros.
 */
int encodeDecimal(bitstream_t* stream, exi_decimal_t* d) {
	/* sign, integral, reverse fractional */
	int errn = encodeBoolean(stream, d->negative);
	if (errn < 0) {
		return errn;
	}
	errn = encodeUnsignedInteger(stream, &d->integral);
	if (errn < 0) {
		return errn;
	}
	errn = encodeUnsignedInteger(stream, &d->reverseFraction);

	return errn;
}

/**
 * Encode a length prefixed sequence of characters.
 */
/*int encodeASCII(bitstream_t* stream, const char* ascii) {
 int errn;
 uint32_t slen = (uint32_t) strlen(ascii);
 errn = encodeUnsignedInteger32(stream, slen);
 if (errn >= 0) {
 errn = encodeASCIICharacters(stream, ascii, slen);
 }
 return errn;
 }*/

int encodeString(bitstream_t* stream, exi_string_ucs_t* string) {
	int errn = encodeUnsignedInteger32(stream, string->len);
	if (errn >= 0) {
		errn = encodeUCSCharacters(stream, string->codepoints, string->len);
	}
	return errn;
}

static int _writeStringValueLocalHit(bitstream_t* stream, exi_state_t* state,
		uint16_t qnameID, uint32_t localID) {
	int errn;
	uint16_t codingLength;

	if(!(state->stringTable.sizeLocalStrings > qnameID)) {
		return EXI_ERROR_OUT_OF_BOUNDS;
	}

	errn = exiGetCodingLength(state->stringTable.numberOfLocalStrings[qnameID],
			&codingLength);
	if (errn) {
		return errn;
	}
	errn = encodeNBitUnsignedInteger(stream, codingLength, localID);

	return errn;
}

static int _writeStringValueGlobalHit(bitstream_t* stream, exi_state_t* state,
		uint32_t globalID) {
	int errn;
	uint16_t codingLength;

	errn = exiGetCodingLength(state->stringTable.numberOfGlobalStrings, &codingLength);
	if (errn) {
		return errn;
	}
	errn = encodeNBitUnsignedInteger(stream, codingLength, globalID);

	return errn;
}

int encodeStringValue(bitstream_t* stream, exi_state_t* state, uint16_t qnameID,
		exi_string_value_t* string) {
	int errn;

	switch (string->type) {
	case EXI_STRING_VALUE_LOCAL_HIT:
		errn = encodeUnsignedInteger32(stream, 0);
		if (errn) {
			return errn;
		}
		errn = _writeStringValueLocalHit(stream, state, qnameID,
				string->localID);
		break;
	case EXI_STRING_VALUE_GLOBAL_HIT:
		errn = encodeUnsignedInteger32(stream, 1);
		if (errn) {
			return errn;
		}
		errn = _writeStringValueGlobalHit(stream, state, string->globalID);
		break;
	case EXI_STRING_VALUE_MISS:
		/* encode string as string table miss */
		errn = encodeUnsignedInteger32(stream, string->miss.len + 2);
		if (errn >= 0) {
			errn = encodeUCSCharacters(stream, string->miss.codepoints,
					string->miss.len);
		}
#if EXI_VALUE_PARTITION_CAPACITY != 0
#if EXI_VALUE_MAX_LENGTH != 0
		/* If length L is greater than zero the string S is added */
		if (string->miss.len > 0) {
			/* After encoding the string value, it is added to both the
			 * associated "local" value string table partition and the global
			 * value string table partition */
#if EXI_VALUE_MAX_LENGTH < 0
			errn = exi__IncrementStringValueCount(state, qnameID);
# else /* EXI_VALUE_MAX_LENGTH < 0  */
			if (string->miss.len <= EXI_VALUE_MAX_LENGTH) {
				errn = exi__IncrementStringValueCount(state,
						qnameID);
			}
#endif /* EXI_VALUE_MAX_LENGTH < 0  */
		}
#endif /* EXI_VALUE_MAX_LENGTH != 0 */
#endif /* EXI_VALUE_PARTITION_CAPACITY != 0 */
		break;
	default:
		errn = EXI_UNSUPPORTED_STRING_VALUE_TYPE;
		break;
	}

	return errn;
}

int encodeRCSStringValue(bitstream_t* stream, exi_state_t* state,
		uint16_t qnameID, exi_rcs_t* rcs, exi_string_value_t* string) {
	unsigned int i;
	int errn;
	uint32_t k;

	switch (string->type) {
	case EXI_STRING_VALUE_LOCAL_HIT:
		errn = encodeUnsignedInteger32(stream, 0);
		if (errn) {
			return errn;
		}
		errn = _writeStringValueLocalHit(stream, state, qnameID,
				string->localID);
		break;
	case EXI_STRING_VALUE_GLOBAL_HIT:
		errn = encodeUnsignedInteger32(stream, 1);
		if (errn) {
			return errn;
		}
		errn = _writeStringValueGlobalHit(stream, state, string->globalID);
		break;
	case EXI_STRING_VALUE_MISS:
		/* encode string as string table miss */
		errn = encodeUnsignedInteger32(stream, string->miss.len + 2);
		if (errn) {
			return errn;
		}

		for (i = 0; i < string->miss.len; i++) {
			for (k = 0; k < rcs->size; k++) {
				if (rcs->codepoints[k] == string->miss.codepoints[i]) {
					errn = encodeNBitUnsignedInteger(stream, rcs->codingLength,
							k);
					if (errn) {
						return errn;
					}
					break; /* break inner for loop */
				}
			}
		}
#if EXI_VALUE_PARTITION_CAPACITY != 0
#if EXI_VALUE_MAX_LENGTH != 0
		/* If length L is greater than zero the string S is added */
		if (string->miss.len > 0) {
			/* After encoding the string value, it is added to both the
			 * associated "local" value string table partition and the global
			 * value string table partition */
#if EXI_VALUE_MAX_LENGTH < 0
			errn = exi__IncrementStringValueCount(state, qnameID);
#else /* EXI_VALUE_MAX_LENGTH < 0 */
			if (string->miss.len <= EXI_VALUE_MAX_LENGTH) {
				errn = exi__IncrementStringValueCount(state,
						qnameID);
			}
#endif /* EXI_VALUE_MAX_LENGTH < 0 */
		}
#endif /* EXI_VALUE_MAX_LENGTH != 0 */
#endif /* EXI_VALUE_PARTITION_CAPACITY != 0 */
		break;
	default:
		errn = EXI_UNSUPPORTED_STRING_VALUE_TYPE;
		break;
	}

	return errn;
}

/**
 * Encode a sequence of characters according to a given length.
 * Each character is represented by its UCS [ISO/IEC 10646]
 * code point encoded as an Unsigned Integer
 */
int encodeUCSCharacters(bitstream_t* stream, uint32_t* chars, uint16_t len) {
	unsigned int i;
	int errn = 0;
	for (i = 0; i < len && errn >= 0; i++) {
		errn = encodeUnsignedInteger32(stream, chars[i]);
	}
	return errn;
}

/*int encodeASCIICharacters(bitstream_t* stream, const char* chars, uint16_t len) {
 unsigned int i;
 int errn = 0;
 for (i = 0; i < len && errn >= 0; i++) {
 errn = encode(stream, chars[i]);
 }
 return errn;
 }*/

/**
 * Encode a binary value as a length-prefixed sequence of octets.
 */
int encodeBinary(bitstream_t* stream, exi_bytes_t* bytes) {
	unsigned int i;
	int errn = encodeUnsignedInteger32(stream, bytes->len);

	for (i = 0; i < bytes->len && errn >= 0; i++) {
		errn = encode(stream, bytes->data[i]);
	}
	return errn;
}

/**
 * Encode a datetime representation which is a sequence of values
 * representing the individual components of the Date-Time
 */
int encodeDateTime(bitstream_t* stream, exi_datetime_t* datetime) {
	int errn = 0;
	switch (datetime->type) {
	case EXI_DATETIME_GYEAR: /* Year, [Time-Zone] */
		errn = encodeInteger32(stream, datetime->year - DATETIME_YEAR_OFFSET);
		break;
	case EXI_DATETIME_GYEARMONTH: /* Year, MonthDay, [TimeZone] */
	case EXI_DATETIME_DATE: /* Year, MonthDay, [TimeZone] */
		errn = encodeInteger32(stream, datetime->year - DATETIME_YEAR_OFFSET);
		if (errn < 0) {
			return errn;
		}
		errn = encodeNBitUnsignedInteger(stream, DATETIME_NUMBER_BITS_MONTHDAY,
				datetime->monthDay);
		break;
	case EXI_DATETIME_DATETIME: /* Year, MonthDay, Time, [FractionalSecs], [TimeZone] */
		errn = encodeInteger32(stream, datetime->year - DATETIME_YEAR_OFFSET);
		if (errn < 0) {
			return errn;
		}
		errn = encodeNBitUnsignedInteger(stream, DATETIME_NUMBER_BITS_MONTHDAY,
				datetime->monthDay);
		if (errn < 0) {
			return errn;
		}
		/* no break */
	case EXI_DATETIME_TIME: /* Time, [FractionalSecs], [TimeZone] */
		errn = encodeNBitUnsignedInteger(stream, DATETIME_NUMBER_BITS_TIME,
				datetime->time);
		if (errn < 0) {
			return errn;
		}
		if (datetime->presenceFractionalSecs) {
			encodeBoolean(stream, 1);
			if (errn < 0) {
				return errn;
			}
			encodeUnsignedInteger32(stream, datetime->fractionalSecs);
		} else {
			encodeBoolean(stream, 0);
		}
		break;
	case EXI_DATETIME_GMONTH: /* MonthDay, [TimeZone] */
	case EXI_DATETIME_GMONTHDAY: /* MonthDay, [TimeZone] */
	case EXI_DATETIME_GDAY: /* MonthDay, [TimeZone] */
		errn = encodeNBitUnsignedInteger(stream, DATETIME_NUMBER_BITS_MONTHDAY,
				datetime->monthDay);
		break;
	default:
		return EXI_UNSUPPORTED_DATETIME_TYPE;
	}
	if (errn < 0) {
		return errn;
	}
	/* [TimeZone] */
	if (datetime->presenceTimezone) {
		errn = encodeBoolean(stream, 1);
		if (errn < 0) {
			return errn;
		}
		encodeNBitUnsignedInteger(stream, DATETIME_NUMBER_BITS_TIMEZONE,
				datetime->timezone + DATETIME_TIMEZONE_OFFSET_IN_MINUTES);
	} else {
		encodeBoolean(stream, 0);
	}

	return errn;
}

#endif