/*
    * To change this template, choose Tools | Templates
    * and open the template in the editor.
    */
   package net.sf.atmodem4j.core.gsm;
   
   /*
    * #%L
    * ATModem4J Core
   * %%
   * Copyright (C) 2009 - 2014 atmodem4j
   * %%
   * atmodem4j - Drivers for the AT modem - http://atmodem4j.sourceforge.net/
   * Copyright (C) 2009-2014, atmodem4j.sf.net, and individual contributors as indicated
   * by the @authors tag. See the copyright.txt in the distribution for a
   * full listing of individual contributors.
   * 
   * This is free software; you can redistribute it and/or modify it
   * under the terms of the GNU General Public License as
   * published by the Free Software Foundation; either version 3 of
   * the License, or (at your option) any later version.
   * 
   * This software 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.
   * 
   * You should have received a copy of the GNU Lesser General Public
   * License along with this software; if not, write to the Free
   * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
   * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
   * #L%
   */
  
  import java.util.ArrayList;
  import java.util.List;
  import net.sf.atmodem4j.core.gsm.Pdu.Encoding;
  import net.sf.atmodem4j.core.gsm.Pdu.TimeToLife;
  
  /**
   *
   * @author aploese
   */
  public class PduEncoder {
  
      private final static int USER_DATA_HEADER_LENGTH = 6;
      public static final int MAX_USER_PDU_SIZE = 140;
  
      private List<UserData> data = new ArrayList<UserData>();
  
      private String receiverPhonenumber;
      private Encoding encoding;
      private TimeToLife timeToLife;
      private int refnumber;
  
      public PduEncoder() {
          super();
      }
  
      private String getSmscInformationOctet() {
          return "00";
      }
  
      public boolean isMultiSMS() {
          return data.size() > 1;
      }
  
      private String getSmsSubmittOctet() {
          short result = 0x11;
          result |= isMultiSMS() ? 0x40 : 0;
          return UserData.formatOctet(result);
      }
  
      private String getTpMessageReferenceOctet() {
          return "00";
      }
  
      private String getAdressOctets() {
          StringBuilder sb = new StringBuilder();
          String number = receiverPhonenumber.charAt(0) == '+' ? receiverPhonenumber.substring(1, receiverPhonenumber.length())
                  : receiverPhonenumber;
          sb.append(UserData.formatOctet(number.length()));
          if (receiverPhonenumber.charAt(0) == '+') {
              sb.append("91"); //  International address;
          } else {
              sb.append("91"); //  TODO address;
          }
          for (int i = 0; i < number.length() - 1; i += 2) {
              sb.append(number.charAt(i + 1));
              sb.append(number.charAt(i));
          }
          if (number.length() % 2 != 0) {
              sb.append("F");
              sb.append(number.charAt(number.length() - 1));
          }
          return sb.toString();
      }
  
      private String getTpPidOctet() {
         return "00";
     }
 
     private String getTpDcsOctet() {
         switch (encoding) {
             case TEXT_7BIT:
                 return "00";
             case TEXT_16BIT:
                 return "08";
             case DATA_8BIT:
                 return "04";
             default:
                 return "00";
         }
     }
 
     private String getTpValidityPeriodOctet() {
         return "AA";
     }
 
     private String getMultiSMSUserHeader(int length, int index) {
         StringBuilder sb = new StringBuilder();
         sb.append("05"); //Length of user data header
         sb.append("00"); //Inicator: Concatentiated short message 8 Bit ref number
         sb.append("03"); //length alway 3
         sb.append(UserData.formatOctet(refnumber++)); // Concatenated short message reference number
         if (refnumber > 255) {
             refnumber = 0;
         }
         sb.append(UserData.formatOctet(length));
         sb.append(UserData.formatOctet(index));
         return sb.toString();
     }
 
     public String[] encodePdus() {
         StringBuilder sb = new StringBuilder();
         if (isMultiSMS()) {
 //Multi SMS
             String[] result = new String[data.size()]; // subtract user header
             for (int i = 0; i < result.length; i++) {
                 sb.append(getSmscInformationOctet());
                 sb.append(getSmsSubmittOctet());
                 sb.append(getTpMessageReferenceOctet());
                 sb.append(getAdressOctets());
                 sb.append(getTpPidOctet());
                 sb.append(getTpDcsOctet());
                 sb.append(getTpValidityPeriodOctet());
                 sb.append(UserData.formatOctet(data.get(i).getUserDataLength(USER_DATA_HEADER_LENGTH)));
                 sb.append(getMultiSMSUserHeader(data.size(), i +1));
                 sb.append(data.get(i).encodePduData(USER_DATA_HEADER_LENGTH));
                 result[i] = sb.toString();
                 sb.delete(0, sb.length());
             }
             return result;
         } else {
 //Single SMS
             sb.append(getSmscInformationOctet());
             sb.append(getSmsSubmittOctet());
             sb.append(getTpMessageReferenceOctet());
             sb.append(getAdressOctets());
             sb.append(getTpPidOctet());
             sb.append(getTpDcsOctet());
             sb.append(getTpValidityPeriodOctet());
             sb.append(UserData.formatOctet(data.get(0).getUserDataLength(0)));
             sb.append(data.get(0).encodePduData(0));
             return new String[]{sb.toString()};
         }
     }
 
     /**
      * @return the messageText
      */
     public String getMessageText() {
         return null;
     }
 
     /**
      * @param messageText the messageText to set
      */
     public void setMessageText(Encoding enc, String messageText) throws
             Pdu.EncodingException {
         this.encoding = enc;
         switch (encoding) {
             case TEXT_7BIT:
                 int lastPos = 0;
                 for (int pos : UserData.Text7Bit.getSplitPos(messageText)) {
                     UserData.Text7Bit ud = new UserData.Text7Bit();
                     ud.setText(messageText.substring(lastPos, pos));
                     lastPos = pos;
                     data.add(ud);
                 }
                 break;
             case TEXT_16BIT:
                 for (UserData ud : UserData.Text16Bit.split(messageText)) {
                     data.add(ud);
                 }
                 break;
             default:
                 DATA_8BIT:
                 throw new RuntimeException("Cant encode Data as String");
         }
     }
 
     /**
      * @param messageText the messageText to set
      */
     public void setMessageText(String messageText) {
         try {
             setMessageText(Encoding.TEXT_7BIT, messageText);
         } catch (Pdu.EncodingException ex) {
             try {
                 setMessageText(Encoding.TEXT_16BIT, messageText);
             } catch (Pdu.EncodingException ex16) {
                 throw new RuntimeException(ex16);
             }
         }
     }
 
     /**
      * @return the receiverPhonenumber
      */
     public String getReceiverPhonenumber() {
         return receiverPhonenumber;
     }
 
     /**
      * @param receiverPhonenumber the receiverPhonenumber to set
      */
     public void setReceiverPhonenumber(String receiverPhonenumber) {
         this.receiverPhonenumber = receiverPhonenumber;
     }
 
     /**
      * @return the refnumber
      */
     public int getRefnumber() {
         return refnumber;
     }
 
     /**
      * @param refnumber the refnumber to set
      */
     public void setRefnumber(int refnumber) {
         this.refnumber = refnumber;
     }
 }