/*
    *  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.mina.http;
  
  import java.nio.ByteBuffer;
  import java.nio.charset.CharsetEncoder;
  import java.nio.charset.StandardCharsets;
  import java.util.Map;
  
  import org.apache.mina.core.buffer.IoBuffer;
  import org.apache.mina.core.session.IoSession;
  import org.apache.mina.filter.codec.ProtocolEncoder;
  import org.apache.mina.filter.codec.ProtocolEncoderOutput;
  import org.apache.mina.http.api.HttpEndOfContent;
  import org.apache.mina.http.api.HttpResponse;
  import org.slf4j.Logger;
  import org.slf4j.LoggerFactory;
  
  /**
   * An encoder for the HTTP server
   * 
   * @author <a href="http://mina.apache.org">Apache MINA Project</a>
   */
  public class HttpServerEncoder implements ProtocolEncoder {
      private static final Logger LOGGER = LoggerFactory.getLogger(HttpServerCodec.class);
      private static final CharsetEncoder ENCODER = StandardCharsets.UTF_8.newEncoder();
  
      /**
       * {@inheritDoc}
       */
      @Override
      public void encode(IoSession session, Object message, ProtocolEncoderOutput out) throws Exception {
          if (LOGGER.isDebugEnabled()) {
              LOGGER.debug("encode {}", message.getClass().getCanonicalName());
          }
      
          if (message instanceof HttpResponse) {
              if (LOGGER.isDebugEnabled()) {
                  LOGGER.debug("HttpResponse");
              }
              
              HttpResponse../../../org/apache/mina/http/api/HttpResponse.html#HttpResponse">HttpResponse msg = (HttpResponse) message;
              StringBuilder sb = new StringBuilder(msg.getStatus().line());
  
              for (Map.Entry<String, String> header : msg.getHeaders().entrySet()) {
                  sb.append(header.getKey());
                  sb.append(": ");
                  sb.append(header.getValue());
                  sb.append("\r\n");
              }
              
              sb.append("\r\n");
              IoBuffer buf = IoBuffer.allocate(sb.length()).setAutoExpand(true);
              buf.putString(sb.toString(), ENCODER);
              buf.flip();
              out.write(buf);
          } else if (message instanceof ByteBuffer) {
              if (LOGGER.isDebugEnabled()) {
                  LOGGER.debug("Body {}", message);
              }
              
              out.write(message);
          } else if (message instanceof HttpEndOfContent) {
              if (LOGGER.isDebugEnabled()) {
                  LOGGER.debug("End of Content");
              }
              // end of HTTP content
              // keep alive ?
          }
      }
  
      /**
       * {@inheritDoc}
       */
      @Override
      public void dispose(IoSession session) throws Exception {
          // TODO Auto-generated method stub
      }
  }