/**
 * 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.
 */
package org.apache.activemq.openwire.tool.commands;

import java.io.PrintWriter;
import java.util.Set;

public class MessageSourceGenerator extends CommandSourceGenerator {

    protected void populateIncludeFilesSet() {
        super.populateIncludeFilesSet();
        Set<String> includes = getIncludeFiles();
        includes.add("<activemq/wireformat/openwire/marshal/BaseDataStreamMarshaller.h>");
        includes.add("<activemq/wireformat/openwire/marshal/PrimitiveTypesMarshaller.h>");
        includes.add("<decaf/lang/System.h>");
    }

    protected void generateDefaultConstructorBody( PrintWriter out ) {

        out.println("    this->readOnlyBody = false;");
        out.println("    this->readOnlyProperties = false;");

        super.generateDefaultConstructorBody(out);
    }

    protected void generateCopyDataStructureBody( PrintWriter out ) {
        super.generateCopyDataStructureBody(out);

        out.println("    this->properties.copy( srcPtr->properties );");
        out.println("    this->setAckHandler( srcPtr->getAckHandler() );");
        out.println("    this->setReadOnlyBody( srcPtr->isReadOnlyBody() );");
        out.println("    this->setReadOnlyProperties( srcPtr->isReadOnlyProperties() );");
    }

    protected void generateToStringBody( PrintWriter out ) {
        super.generateToStringBody(out);

        out.println("    stream << \" Value of ackHandler = \" << ackHandler.get() << std::endl;");
        out.println("    stream << \" Value of properties = \" << this->properties.toString() << std::endl;");
        out.println("    stream << \" Value of readOnlyBody = \" << this->readOnlyBody << std::endl;");
        out.println("    stream << \" Value of readOnlyProperties = \" << this->readOnlyBody << std::endl;");
    }

    protected void generateEqualsBody( PrintWriter out ) {
        super.generateEqualsBody(out);

        out.println("    if( ackHandler != valuePtr->getAckHandler() ){");
        out.println("        return false;");
        out.println("    }");
        out.println("");
        out.println("    if( !properties.equals( valuePtr->properties ) ) {");
        out.println("        return false;");
        out.println("    }");
        out.println("");
        out.println("    if( readOnlyBody != valuePtr->isReadOnlyBody() ){");
        out.println("        return false;");
        out.println("    }");
        out.println("");
        out.println("    if( readOnlyProperties != valuePtr->isReadOnlyProperties() ){");
        out.println("        return false;");
        out.println("    }");
        out.println("");
    }

    protected void generateCompareToBody( PrintWriter out ) {
        super.generateCompareToBody(out);
    }

    protected void generateAdditionalMethods( PrintWriter out ) {
        super.generateAdditionalMethods(out);

        out.println("");
        out.println("////////////////////////////////////////////////////////////////////////////////");
        out.println("bool Message::isExpired() const {");
        out.println("    long long expireTime = this->getExpiration();");
        out.println("    long long currentTime = decaf::lang::System::currentTimeMillis();");
        out.println("    if( expireTime > 0 && currentTime > expireTime ) {");
        out.println("        return true;");
        out.println("    }");
        out.println("    return false;");
        out.println("}");
        out.println("");
        out.println("////////////////////////////////////////////////////////////////////////////////");
        out.println("unsigned int Message::getSize() const {");
        out.println("");
        out.println("    unsigned int size = DEFAULT_MESSAGE_SIZE;");
        out.println("");
        out.println("    size += (unsigned int)this->getContent().size();");
        out.println("    size += (unsigned int)this->getMarshalledProperties().size();");
        out.println("");
        out.println("    return size;");
        out.println("}");
        out.println("");
        out.println("////////////////////////////////////////////////////////////////////////////////");
        out.println("void Message::beforeMarshal( wireformat::WireFormat* wireFormat AMQCPP_UNUSED )");
        out.println("    throw ( decaf::io::IOException ) {");
        out.println("");
        out.println("    try{");
        out.println("");
        out.println("        marshalledProperties.clear();");
        out.println("        if( !properties.isEmpty() ) {");
        out.println("            wireformat::openwire::marshal::PrimitiveTypesMarshaller::marshal(");
        out.println("                &properties, marshalledProperties );");
        out.println("        }");
        out.println("    }");
        out.println("    AMQ_CATCH_RETHROW( decaf::io::IOException )");
        out.println("    AMQ_CATCH_EXCEPTION_CONVERT( decaf::lang::Exception, decaf::io::IOException )");
        out.println("    AMQ_CATCHALL_THROW( decaf::io::IOException )");
        out.println("}");
        out.println("");
        out.println("////////////////////////////////////////////////////////////////////////////////");
        out.println("void Message::afterUnmarshal( wireformat::WireFormat* wireFormat AMQCPP_UNUSED )");
        out.println("    throw ( decaf::io::IOException ) {");
        out.println("");
        out.println("    try{");
        out.println("");
        out.println("        wireformat::openwire::marshal::PrimitiveTypesMarshaller::unmarshal(");
        out.println("            &properties, marshalledProperties );");
        out.println("    }");
        out.println("    AMQ_CATCH_RETHROW( decaf::io::IOException )");
        out.println("    AMQ_CATCH_EXCEPTION_CONVERT( decaf::lang::Exception, decaf::io::IOException )");
        out.println("    AMQ_CATCHALL_THROW( decaf::io::IOException )");
        out.println("}");
        out.println("");
    }

}