107 lines
2.9 KiB
Go
107 lines
2.9 KiB
Go
// Copyright 2015 Tony Bai.
|
|
//
|
|
// Licensed 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,
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
package cmpp
|
|
|
|
import (
|
|
"encoding/binary"
|
|
"fmt"
|
|
)
|
|
|
|
// Packet length const for cmpp receipt packet.
|
|
const (
|
|
Cmpp3ReceiptPktLen uint32 = 71
|
|
CmppReceiptPktLen uint32 = 60 //60d, 0x3c
|
|
)
|
|
|
|
type CmppReceiptPkt struct {
|
|
MsgId uint64
|
|
Stat string
|
|
SubmitTime string // YYMMDDHHMM
|
|
DoneTime string // YYMMDDHHMM
|
|
DestTerminalId string
|
|
SmscSequence uint32
|
|
}
|
|
|
|
// Pack packs the CmppReceiptPkt to bytes stream for client side.
|
|
func (p *CmppReceiptPkt) Pack() ([]byte, error) {
|
|
return p.PackVersion(V20)
|
|
}
|
|
|
|
// PackVersion uses the negotiated connection version, never a body-length guess.
|
|
func (p *CmppReceiptPkt) PackVersion(version Type) ([]byte, error) {
|
|
pktLen, width, err := receiptLayout(version)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
if len(p.Stat) > 7 || len(p.SubmitTime) > 10 || len(p.DoneTime) > 10 || len(p.DestTerminalId) > width {
|
|
return nil, fmt.Errorf("receipt field exceeds protocol width")
|
|
}
|
|
|
|
var w = newPacketWriter(pktLen)
|
|
|
|
w.WriteInt(binary.BigEndian, p.MsgId)
|
|
w.WriteFixedSizeString(p.Stat, 7)
|
|
w.WriteFixedSizeString(p.SubmitTime, 10)
|
|
w.WriteFixedSizeString(p.DoneTime, 10)
|
|
w.WriteFixedSizeString(p.DestTerminalId, width)
|
|
w.WriteInt(binary.BigEndian, p.SmscSequence)
|
|
|
|
return w.Bytes()
|
|
}
|
|
|
|
// Unpack unpack the binary byte stream to a CmppReceiptPkt variable.
|
|
// After unpack, you will get all value of fields in
|
|
// CmppReceiptPkt struct.
|
|
func (p *CmppReceiptPkt) Unpack(data []byte) error {
|
|
return p.UnpackVersion(data, V20)
|
|
}
|
|
|
|
func receiptLayout(version Type) (uint32, int, error) {
|
|
switch version {
|
|
case V20, V21:
|
|
return CmppReceiptPktLen, 21, nil
|
|
case V30:
|
|
return Cmpp3ReceiptPktLen, 32, nil
|
|
}
|
|
return 0, 0, fmt.Errorf("unsupported receipt version: %v", version)
|
|
}
|
|
|
|
func (p *CmppReceiptPkt) UnpackVersion(data []byte, version Type) error {
|
|
size, width, err := receiptLayout(version)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if len(data) != int(size) {
|
|
return fmt.Errorf("invalid receipt length %d for version %v (expected %d)", len(data), version, size)
|
|
}
|
|
var r = newPacketReader(data)
|
|
|
|
r.ReadInt(binary.BigEndian, &p.MsgId)
|
|
|
|
stat := r.ReadCString(7)
|
|
p.Stat = string(stat)
|
|
|
|
submitTime := r.ReadCString(10)
|
|
p.SubmitTime = string(submitTime)
|
|
|
|
doneTime := r.ReadCString(10)
|
|
p.DoneTime = string(doneTime)
|
|
|
|
destTerminalId := r.ReadCString(width)
|
|
p.DestTerminalId = string(destTerminalId)
|
|
|
|
r.ReadInt(binary.BigEndian, &p.SmscSequence)
|
|
return r.Error()
|
|
}
|