mcchunkie/chats/sms.go
2024-07-18 21:44:05 -06:00

177 lines
3.9 KiB
Go

package chats
import (
"fmt"
"io"
"log"
"net/http"
"net/url"
"strings"
"golang.org/x/crypto/bcrypt"
"suah.dev/mcchunkie/plugins"
)
func smsCanSend(number string, numbers []string) bool {
for _, s := range numbers {
if number == s {
return true
}
}
return false
}
type voipms struct {
did string
dst string
message string
method string
apiUser string
apiPassword string
}
func (v voipms) UrlStr() string {
base, _ := url.Parse("https://voip.ms/api/v1/rest.php")
params := url.Values{}
params.Add("did", v.did)
params.Add("dst", v.dst)
params.Add("method", v.method)
params.Add("api_username", v.apiUser)
params.Add("api_password", v.apiPassword)
params.Add("message", v.message)
base.RawQuery = params.Encode()
return base.String()
}
func sendVoipmsResp(v voipms) error {
resp, err := http.Get(v.UrlStr())
if err != nil {
return err
}
defer resp.Body.Close()
str, err := io.ReadAll(resp.Body)
if err != nil {
return err
}
log.Println(string(str))
return nil
}
// SMSListen listens for our incoming sms
func SMSListen(store ChatStore, plugins *plugins.Plugins) {
var (
smsPort, _ = store.Get("sms_listen")
smsAllowed, _ = store.Get("sms_users")
smsUsers = strings.Split(smsAllowed, ",")
voipmsUser, _ = store.Get("voipms_user")
voipmsPass, _ = store.Get("voipms_api_pass")
)
if smsPort != "" {
var htpass, _ = store.Get("sms_htpass")
log.Printf("SMS: listening on %q\n", smsPort)
http.HandleFunc("/_sms", func(w http.ResponseWriter, r *http.Request) {
var msg, from string
user, pass, ok := r.BasicAuth()
if !ok {
log.Println("SMS: basic auth no ok")
w.Header().Set("WWW-Authenticate", `Basic realm="sms notify"`)
http.Error(w, "auth error", http.StatusUnauthorized)
return
}
if user != "sms" {
log.Printf("SMS: failed auth for invalid user: %q, %q\n", user, pass)
w.Header().Set("WWW-Authenticate", `Basic realm="sms notify"`)
http.Error(w, "Unauthorized", http.StatusUnauthorized)
return
}
err := bcrypt.CompareHashAndPassword([]byte(htpass), []byte(pass))
if err != nil {
log.Printf("SMS: failed auth %q %q\n", user, pass)
w.Header().Set("WWW-Authenticate", `Basic realm="sms notify"`)
http.Error(w, "Unauthorized", http.StatusUnauthorized)
return
}
switch r.Method {
case http.MethodPost:
err = r.ParseForm()
if err != nil {
http.Error(w, "invalid request", http.StatusBadRequest)
return
}
msg = r.Form.Get("Body")
from = r.Form.Get("From")
case http.MethodGet:
// voip.ms
// to={TO}&from={FROM}&message={MESSAGE}&id={ID}&date={TIMESTAMP}
msg = r.URL.Query().Get("message")
from = r.URL.Query().Get("from")
to := r.URL.Query().Get("to")
for _, p := range *plugins {
if p.Match(from, msg) {
log.Printf("%s: responding to '%s'", p.Name(), from)
p.SetStore(store)
resp := p.Process(from, msg)
err := sendVoipmsResp(voipms{
did: to,
dst: from,
message: resp,
method: "sendSMS",
apiUser: voipmsUser,
apiPassword: voipmsPass,
})
if err != nil {
log.Println(err)
}
}
}
return
default:
http.Error(
w,
fmt.Sprintf("method %q not implemented", r.Method),
http.StatusMethodNotAllowed,
)
return
}
if smsCanSend(from, smsUsers) {
msg = strings.TrimSuffix(msg, "\n")
if msg == "" {
fmt.Fprintf(w, "empty message")
return
}
for _, p := range *plugins {
if p.Match(from, msg) {
log.Printf("%s: responding to '%s'", p.Name(), from)
p.SetStore(store)
resp := p.Process(from, msg)
fmt.Fprint(w, resp)
}
}
} else {
log.Printf("number not allowed (%q)", from)
http.Error(
w,
fmt.Sprintf("number not allowed (%q)", from),
http.StatusMethodNotAllowed,
)
return
}
})
log.Fatal(http.ListenAndServe(smsPort, nil))
}
}