deliversm.java

Logica lastest SMPP API

/*
 * Copyright (c) 1996-2001
 * Logica Mobile Networks Limited
 * All rights reserved.
 *
 * This software is distributed under Logica Open Source License Version 1.0
 * ("Licence Agreement"). You shall use it and distribute only in accordance
 * with the terms of the License Agreement.
 *
 */
package com.logica.smpp.pdu;

import java.io.UnsupportedEncodingException;

import com.logica.smpp.Data;
import com.logica.smpp.pdu.tlv.TLVByte;
import com.logica.smpp.pdu.tlv.TLVOctets;
import com.logica.smpp.pdu.tlv.TLVShort;
import com.logica.smpp.pdu.tlv.TLVString;
import com.logica.smpp.pdu.tlv.TLVUByte;
import com.logica.smpp.pdu.tlv.WrongLengthException;
import com.logica.smpp.util.ByteBuffer;
import com.logica.smpp.util.NotEnoughDataInByteBufferException;
import com.logica.smpp.util.TerminatingZeroNotFoundException;

/**
 * @author Logica Mobile Networks SMPP Open Source Team
 * @version 1.1, 20 Nov 2001
 */

/*
  31-10-01 [e-mail] message length now stored and returned as short to
                           accomodate the lengths > 127 (they're stored as
                           negative values in byte vars)
  31-10-01 [e-mail] SAR fields now correctly return values > 127
  20-11-01 [e-mail] added support for multibyte string encoding
                           for short message
*/

public class DeliverSM extends Request
{
    // mandatory parameters
    private String serviceType              = Data.DFLT_SRVTYPE;
    private Address sourceAddr              = new Address();
    private Address destAddr                = new Address();
    private byte esmClass                   = Data.DFLT_ESM_CLASS;
    private byte protocolId                 = Data.DFLT_PROTOCOLID;
    private byte priorityFlag               = Data.DFLT_PRIORITY_FLAG;
    private String scheduleDeliveryTime     = Data.DFLT_SCHEDULE; // not used
    private String validityPeriod           = Data.DFLT_VALIDITY; // not used
    private byte registeredDelivery         = Data.DFLT_REG_DELIVERY;
    private byte replaceIfPresentFlag       = Data.DFTL_REPLACE_IFP; // not used
    private byte dataCoding                 = Data.DFLT_DATA_CODING;
    private byte smDefaultMsgId             = Data.DFLT_DFLTMSGID; // not used
    private short smLength                  = Data.DFLT_MSG_LEN;
    private ShortMessage shortMessage       = new ShortMessage(Data.SM_MSG_LEN);

    // optional parameters
    private TLVShort  userMessageReference  = new TLVShort(Data.OPT_PAR_USER_MSG_REF);
    private TLVShort  sourcePort            = new TLVShort(Data.OPT_PAR_SRC_PORT);
    //private TLVByte   sourceAddrSubunit     = new TLVByte(Data.OPT_PAR_SRC_ADDR_SUBUNIT);
    private TLVShort  destinationPort       = new TLVShort(Data.OPT_PAR_DST_PORT);
    //private TLVByte   destAddrSubunit       = new TLVByte(Data.OPT_PAR_DST_ADDR_SUBUNIT);
    private TLVShort  sarMsgRefNum          = new TLVShort(Data.OPT_PAR_SAR_MSG_REF_NUM);
    private TLVUByte  sarTotalSegments      = new TLVUByte(Data.OPT_PAR_SAR_TOT_SEG);
    private TLVUByte  sarSegmentSeqnum      = new TLVUByte(Data.OPT_PAR_SAR_SEG_SNUM);
    //private TLVByte   moreMsgsToSend        = new TLVByte(Data.OPT_PAR_MORE_MSGS);
    private TLVByte   payloadType           = new TLVByte(Data.OPT_PAR_PAYLOAD_TYPE);
    private TLVOctets messagePayload        = new TLVOctets(Data.OPT_PAR_MSG_PAYLOAD,Data.OPT_PAR_MSG_PAYLOAD_MIN,Data.OPT_PAR_MSG_PAYLOAD_MAX);
    private TLVByte   privacyIndicator      = new TLVByte(Data.OPT_PAR_PRIV_IND);
    private TLVOctets callbackNum           = new TLVOctets(Data.OPT_PAR_CALLBACK_NUM,Data.OPT_PAR_CALLBACK_NUM_MIN,Data.OPT_PAR_CALLBACK_NUM_MAX); // 4-19
    //private TLVByte   callbackNumPresInd    = new TLVByte(Data.OPT_PAR_CALLBACK_NUM_PRES_IND);
    //private TLVOctets callbackNumAtag       = new TLVOctets(Data.OPT_PAR_CALLBACK_NUM_ATAG,Data.OPT_PAR_CALLBACK_NUM_ATAG_MIN,Data.OPT_PAR_CALLBACK_NUM_ATAG_MAX); // 1-65
    private TLVOctets sourceSubaddress      = new TLVOctets(Data.OPT_PAR_SRC_SUBADDR,Data.OPT_PAR_SRC_SUBADDR_MIN,Data.OPT_PAR_SRC_SUBADDR_MAX); // 2-23 
    private TLVOctets destSubaddress        = new TLVOctets(Data.OPT_PAR_DEST_SUBADDR,Data.OPT_PAR_DEST_SUBADDR_MIN,Data.OPT_PAR_DEST_SUBADDR_MAX);
    private TLVByte   userResponseCode      = new TLVByte(Data.OPT_PAR_USER_RESP_CODE);
    //private TLVByte   displayTime           = new TLVByte(Data.OPT_PAR_DISPLAY_TIME);
    //private TLVShort  smsSignal             = new TLVShort(Data.OPT_PAR_SMS_SIGNAL);
    //private TLVByte   msValidity            = new TLVByte(Data.OPT_PAR_MS_VALIDITY);
    //private TLVByte   msMsgWaitFacilities   = new TLVByte(Data.OPT_PAR_MSG_WAIT); // bit mask
    //private TLVByte   numberOfMessages      = new TLVByte(Data.OPT_PAR_NUM_MSGS);
    //private TLVEmpty  alertOnMsgDelivery    = new TLVEmpty(Data.OPT_PAR_ALERT_ON_MSG_DELIVERY);
    private TLVByte   languageIndicator     = new TLVByte(Data.OPT_PAR_LANG_IND);
    //private TLVByte   itsReplyType          = new TLVByte(Data.OPT_PAR_ITS_REPLY_TYPE);
    private TLVShort  itsSessionInfo        = new TLVShort(Data.OPT_PAR_ITS_SESSION_INFO);
    //private TLVByte   ussdServiceOp         = new TLVByte(Data.OPT_PAR_USSD_SER_OP);

    private TLVOctets networkErrorCode      = new TLVOctets(Data.OPT_PAR_NW_ERR_CODE, Data.OPT_PAR_NW_ERR_CODE_MIN, Data.OPT_PAR_NW_ERR_CODE_MAX); // exactly 3
    private TLVByte messageState            = new TLVByte(Data.OPT_PAR_MSG_STATE);
    private TLVString receiptedMessageId    = new TLVString(Data.OPT_PAR_RECP_MSG_ID, Data.OPT_PAR_RECP_MSG_ID_MIN, Data.OPT_PAR_RECP_MSG_ID_MAX); // 1-
    

    public DeliverSM()
    {
        super(Data.DELIVER_SM);
        
        registerOptional(userMessageReference);
        registerOptional(sourcePort);
        registerOptional(destinationPort);
        registerOptional(sarMsgRefNum);
        registerOptional(sarTotalSegments);
        registerOptional(sarSegmentSeqnum);
        registerOptional(payloadType);
        registerOptional(messagePayload);
        registerOptional(privacyIndicator);
        registerOptional(callbackNum);
        registerOptional(sourceSubaddress);
        registerOptional(destSubaddress);
        registerOptional(userResponseCode);
        registerOptional(languageIndicator);
        registerOptional(itsSessionInfo);
        registerOptional(networkErrorCode);
        registerOptional(messageState);
        registerOptional(receiptedMessageId);
    }

    protected Response createResponse()
    {
        return new DeliverSMResp();
    }

    public void setBody(ByteBuffer buffer)
    throws NotEnoughDataInByteBufferException,
           TerminatingZeroNotFoundException,
           PDUException
    {
        String dummyStr;
        byte dummyByte;
        setServiceType(buffer.removeCString());
        sourceAddr.setData(buffer);
        destAddr.setData(buffer);
        setEsmClass(buffer.removeByte());
        setProtocolId(buffer.removeByte());
        setPriorityFlag(buffer.removeByte());
        dummyStr = buffer.removeCString(); // default scheduleDeliveryTime
        dummyStr = buffer.removeCString(); // default validityPeriod
        setRegisteredDelivery(buffer.removeByte());
        dummyByte = buffer.removeByte(); // default replaceIfPresentFlag
        setDataCoding(buffer.removeByte());
        dummyByte = buffer.removeByte(); // default smDefaultMsgId
        setSmLength(decodeUnsigned(buffer.removeByte()));
        shortMessage.setData(buffer.removeBuffer(getSmLength()));
    }

    public ByteBuffer getBody()
    {
        ByteBuffer buffer = new ByteBuffer();
        buffer.appendCString(getServiceType());
        buffer.appendBuffer(getSourceAddr().getData());
        buffer.appendBuffer(getDestAddr().getData());
        buffer.appendByte(getEsmClass());
        buffer.appendByte(getProtocolId());
        buffer.appendByte(getPriorityFlag());
        buffer.appendCString(getScheduleDeliveryTime());
        buffer.appendCString(getValidityPeriod());
        buffer.appendByte(getRegisteredDelivery());
        buffer.appendByte(getReplaceIfPresentFlag());
        buffer.appendByte(getDataCoding());
        buffer.appendByte(getSmDefaultMsgId());
        buffer.appendByte(encodeUnsigned(getSmLength()));
        buffer.appendBuffer(shortMessage.getData());
        return buffer;
    }


    public void setServiceType(String value)
    throws WrongLengthOfStringException {
        checkCString(value, Data.SM_SRVTYPE_LEN);
        serviceType = value;
    }
    
    //not used in deliver_sm
    //public void setScheduleDeliveryTime(String value)
    //throws WrongDateFormatException {
    //    checkDate(value);
    //    scheduleDeliveryTime = value;
    //}
    
    //not used in deliver_sm
    //public void setValidityPeriod(String value)
    //throws WrongDateFormatException {