feat: allow non-https when CHANNEL_URL_ALLOW_NON_HTTPS is true (close #153)
This commit is contained in:
+5
-3
@@ -3,15 +3,17 @@ package channel
|
|||||||
import (
|
import (
|
||||||
"bytes"
|
"bytes"
|
||||||
"errors"
|
"errors"
|
||||||
|
"net/http"
|
||||||
|
"os"
|
||||||
|
"strings"
|
||||||
|
|
||||||
"message-pusher/common"
|
"message-pusher/common"
|
||||||
"message-pusher/model"
|
"message-pusher/model"
|
||||||
"net/http"
|
|
||||||
"strings"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
func SendCustomMessage(message *model.Message, user *model.User, channel_ *model.Channel) error {
|
func SendCustomMessage(message *model.Message, user *model.User, channel_ *model.Channel) error {
|
||||||
url := channel_.URL
|
url := channel_.URL
|
||||||
if strings.HasPrefix(url, "http:") {
|
if strings.HasPrefix(url, "http:") && os.Getenv("CHANNEL_URL_ALLOW_NON_HTTPS") != "true" {
|
||||||
return errors.New("自定义通道必须使用 HTTPS 协议")
|
return errors.New("自定义通道必须使用 HTTPS 协议")
|
||||||
}
|
}
|
||||||
if strings.HasPrefix(url, common.ServerAddress) {
|
if strings.HasPrefix(url, common.ServerAddress) {
|
||||||
|
|||||||
Reference in New Issue
Block a user