Method getSendDelay

api/pkg/services/message_service.go:579–597

(ctxLogger telemetry.Logger, eventPayload events.MessageAPISentPayload, params MessageSendParams, messagesPerMinute uint)

}

func (service *MessageService) getSendDelay(ctxLogger telemetry.Logger, eventPayload events.MessageAPISentPayload, params MessageSendParams, messagesPerMinute uint) time.Duration {
	if params.SendAt != nil {
		delay := params.SendAt.Sub(time.Now().UTC())
		if delay < 0 {
			ctxLogger.Info(fmt.Sprintf("message [%s] has send time [%s] in the past. sending immediately", eventPayload.MessageID, params.SendAt.String()))
			return time.Duration(0)
		}
		return delay
	}

	if params.Index > 0 && messagesPerMinute > 0 {
		interval := time.Minute / time.Duration(messagesPerMinute)
		delay := time.Duration(params.Index) * interval
		ctxLogger.Info(fmt.Sprintf("message [%s] bulk index [%d] rate-based delay [%s]", eventPayload.MessageID, params.Index, delay))
		return delay
	}

	return time.Duration(0)
}

// StoreReceivedMessage a new message
func (service *MessageService) storeReceivedMessage(ctx context.Context, params events.MessagePhoneReceivedPayload) (*entities.Message, error) {