/*
    *  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.Charset;
  import java.nio.charset.CharsetEncoder;
  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.HttpRequest;
  import org.slf4j.Logger;
  import org.slf4j.LoggerFactory;
  
  /**
   * An encoder for the HTTP client
   * @author <a href="http://mina.apache.org">Apache MINA Project</a>
   */
  public class HttpClientEncoder implements ProtocolEncoder {
      private static final Logger LOG = LoggerFactory.getLogger(HttpClientCodec.class);
      private static final CharsetEncoder ENCODER = Charset.forName("UTF-8").newEncoder();
  
      /**
       * {@inheritDoc}
       */
      @Override
      public void encode(IoSession session, Object message, ProtocolEncoderOutput out) throws Exception {
          LOG.debug("encode {}", message.getClass().getCanonicalName());
          
          if (message instanceof HttpRequest) {
              LOG.debug("HttpRequest");
              HttpRequest msg = (HttpRequest)message;
              StringBuilder sb = new StringBuilder(msg.getMethod().toString());
              sb.append(" ");
              sb.append(msg.getRequestPath());
              
              if (!"".equals(msg.getQueryString())) {
                  sb.append("?");
                  sb.append(msg.getQueryString());
              }
              
              sb.append(" ");
              sb.append(msg.getProtocolVersion());
              sb.append("\r\n");
  
              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) {
              LOG.debug("Body");
              out.write(message);
          } else if (message instanceof HttpEndOfContent) {
              LOG.debug("End of Content");
              // end of HTTP content
              // keep alive ?
          }
      }
  
      /**
       * {@inheritDoc}
       */
      @Override
      public void dispose(IoSession arg0) throws Exception {
          // TODO Auto-generated method stub
      }
  }