gosmsc

type MessageStatusMgoStorage ¶

type MessageStatusMgoStorage struct {
	// contains filtered or unexported fields
}

MessageStatusMgoStorage is a default mgo implementation of the MessageStatusStorageInterface.

func NewMessageStatusMgoStorage(dbHelper *mgohelper.DbHelper) (*MessageStatusMgoStorage, error)

func (ms *MessageStatusMgoStorage) Get(messageId int64) (*MessageStatus, error)

func (ms *MessageStatusMgoStorage) GetPending() ([]MessageStatus, error)

func (ms *MessageStatusMgoStorage) Put(message *MessageStatus) error

type MessageTracker ¶

type MessageTracker struct {
	// contains filtered or unexported fields
}

MessageTracker represents a running goroutine that polls SMSC service to track status of sent messages which status is pending. This object is created when a goroutine is started by StartTracking and can be used to stop the goroutine using Close func. After goroutine is stopped by Close() this object cannot be used anymore.

func StartTracking(storage StatusContainer, statusFetcher StatusFetcher, updateInterval time.Duration) (tracker *MessageTracker, e error)

func (t *MessageTracker) IsStopped() bool

func (t *MessageTracker) Stop() error

type SenderCheckerImpl ¶

type SenderCheckerImpl struct {
	// contains filtered or unexported fields
}

HttpSenderChecker provides the functionality to send sms and track its status.

It consists of a sender, status getter, message storage, and a tracker goroutine. When sms is sent using 'Send', SenderChecker implementation adds a 'pending' entry to the storage. Then the tracker goroutine starts polling the smsc gateway using the status getter. It polls it until message is delivered and updates the message status in the storage each time.

It can be also used without tracking functionality. See 'track' flag in the Send func.

func NewSenderCheckerImpl(opts *SmscClientOptions, storage StatusContainer, updateInterval time.Duration) (*SenderCheckerImpl, error)

func (c *SenderCheckerImpl) GetActualStatus(id int64) (*MessageStatus, error)

func (c *SenderCheckerImpl) Send(phone string, text string, track bool) (int64, error)

type SenderFetcherImpl ¶

type SenderFetcherImpl struct {
	// contains filtered or unexported fields
}

SenderFetcherImpl is a plain implementation of Sender and StatusFetcher interfaces that interacts with SMSC web gateway. Unlike SenderCheckerImpl, SenderFetcherImpl doesn't track or store anything, it is just a gateway caller without any side-effects.

func NewSenderFetcherImpl(opts *SmscClientOptions) (*SenderFetcherImpl, error)

func (c *SenderFetcherImpl) FetchStatus(id int64, phone string) (*CheckStatusResponse, error)

func (c *SenderFetcherImpl) Send(phone string, text string) (*SendSMSResponse, error)

type SmscClientOptions ¶

type SmscClientOptions struct {
	User     string `json:"user"`
	Password string `json:"pwd"`
}

SmscClientOptions encapsulates configuration used to send sms messages using smsc.ru