Compare commits
No commits in common. "f6595d74632dcb8ffc06ffda097237c08eddcd57" and "4eddd7d1df106fa84236118414c899e78ca8d9c6" have entirely different histories.
f6595d7463
...
4eddd7d1df
14 changed files with 347 additions and 870 deletions
3
.gitignore
vendored
3
.gitignore
vendored
|
@ -1,6 +1,5 @@
|
||||||
config.yaml
|
config.yaml
|
||||||
config.*.yaml
|
config.test.yaml
|
||||||
!config.sample.yaml
|
|
||||||
/*.sql
|
/*.sql
|
||||||
client/calls/
|
client/calls/
|
||||||
!client/calls/.gitkeep
|
!client/calls/.gitkeep
|
||||||
|
|
|
@ -41,11 +41,3 @@ notify:
|
||||||
# {{ end -}}
|
# {{ end -}}
|
||||||
config:
|
config:
|
||||||
webhookURL: "http://somewhere"
|
webhookURL: "http://somewhere"
|
||||||
# configure upstream relays here
|
|
||||||
relay:
|
|
||||||
# `url` is the root of the instance
|
|
||||||
# - url: 'http://some.host:3051/'
|
|
||||||
# apiKey: aaaabbbb-cccc-dddd-eeee-ffff11112222
|
|
||||||
# `required` specifies whether we should report failure (i.e. HTTP 500 for rdio-http) to the source
|
|
||||||
# if the relay call submission fails
|
|
||||||
# required: false
|
|
||||||
|
|
|
@ -1,8 +1,19 @@
|
||||||
package forms
|
package forms
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"encoding/json"
|
||||||
"errors"
|
"errors"
|
||||||
|
"fmt"
|
||||||
|
"io"
|
||||||
|
"net/http"
|
||||||
|
"reflect"
|
||||||
|
"strconv"
|
||||||
|
"strings"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
|
"dynatron.me/x/stillbox/internal/jsontypes"
|
||||||
|
|
||||||
|
"github.com/araddon/dateparse"
|
||||||
)
|
)
|
||||||
|
|
||||||
var (
|
var (
|
||||||
|
@ -69,3 +80,293 @@ func (o *options) Tag() string {
|
||||||
|
|
||||||
return "form"
|
return "form"
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (o *options) parseTime(s string, dpo ...dateparse.ParserOption) (t time.Time, set bool, err error) {
|
||||||
|
if o.acceptBlank && s == "" {
|
||||||
|
set = false
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
if iv, err := strconv.Atoi(s); err == nil {
|
||||||
|
return time.Unix(int64(iv), 0), true, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
switch {
|
||||||
|
case o.parseTimeIn != nil:
|
||||||
|
t, err = dateparse.ParseIn(s, o.parseTimeIn, dpo...)
|
||||||
|
case o.parseLocal:
|
||||||
|
t, err = dateparse.ParseLocal(s, dpo...)
|
||||||
|
default:
|
||||||
|
t, err = dateparse.ParseAny(s, dpo...)
|
||||||
|
}
|
||||||
|
|
||||||
|
set = true
|
||||||
|
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
func (o *options) parseBool(s string) (v bool, set bool, err error) {
|
||||||
|
if o.acceptBlank && s == "" {
|
||||||
|
set = false
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
set = true
|
||||||
|
|
||||||
|
v, err = strconv.ParseBool(s)
|
||||||
|
if err != nil {
|
||||||
|
return v, set, fmt.Errorf("parsebool('%s'): %w", s, err)
|
||||||
|
}
|
||||||
|
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
func (o *options) parseInt(s string) (v int, set bool, err error) {
|
||||||
|
if o.acceptBlank && s == "" {
|
||||||
|
set = false
|
||||||
|
return
|
||||||
|
}
|
||||||
|
set = true
|
||||||
|
|
||||||
|
v, err = strconv.Atoi(s)
|
||||||
|
if err != nil {
|
||||||
|
return v, set, fmt.Errorf("atoi('%s'): %w", s, err)
|
||||||
|
}
|
||||||
|
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
func (o *options) parseFloat64(s string) (v float64, set bool, err error) {
|
||||||
|
if o.acceptBlank && s == "" {
|
||||||
|
set = false
|
||||||
|
return
|
||||||
|
}
|
||||||
|
set = true
|
||||||
|
|
||||||
|
v, err = strconv.ParseFloat(s, 64)
|
||||||
|
if err != nil {
|
||||||
|
return v, set, fmt.Errorf("ParseFloat('%s'): %w", s, err)
|
||||||
|
}
|
||||||
|
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
func (o *options) parseDuration(s string) (v time.Duration, set bool, err error) {
|
||||||
|
if o.acceptBlank && s == "" {
|
||||||
|
set = false
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
set = true
|
||||||
|
|
||||||
|
v, err = time.ParseDuration(s)
|
||||||
|
if err != nil {
|
||||||
|
return v, set, fmt.Errorf("ParseDuration('%s'): %w", s, err)
|
||||||
|
}
|
||||||
|
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
var typeOfByteSlice = reflect.TypeOf([]byte(nil))
|
||||||
|
|
||||||
|
func (o *options) iterFields(r *http.Request, destStruct reflect.Value) error {
|
||||||
|
structType := destStruct.Type()
|
||||||
|
for i := 0; i < destStruct.NumField(); i++ {
|
||||||
|
destFieldVal := destStruct.Field(i)
|
||||||
|
fieldType := structType.Field(i)
|
||||||
|
if !fieldType.IsExported() && !fieldType.Anonymous {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
|
||||||
|
if destFieldVal.Kind() == reflect.Struct && fieldType.Anonymous {
|
||||||
|
err := o.iterFields(r, destFieldVal)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
var tAr []string
|
||||||
|
var formField string
|
||||||
|
var omitEmpty bool
|
||||||
|
if o.defaultOmitEmpty {
|
||||||
|
omitEmpty = true
|
||||||
|
}
|
||||||
|
|
||||||
|
formTag, has := structType.Field(i).Tag.Lookup(o.Tag())
|
||||||
|
if has {
|
||||||
|
tAr = strings.Split(formTag, ",")
|
||||||
|
formField = tAr[0]
|
||||||
|
for _, v := range tAr[1:] {
|
||||||
|
if v == "omitempty" {
|
||||||
|
omitEmpty = true
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if !has || formField == "-" {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
|
||||||
|
destFieldIntf := destFieldVal.Interface()
|
||||||
|
|
||||||
|
if destFieldVal.Kind() == reflect.Slice && destFieldVal.Type() == typeOfByteSlice {
|
||||||
|
file, hdr, err := r.FormFile(formField)
|
||||||
|
if err != nil {
|
||||||
|
return fmt.Errorf("get form file: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
nameField, hasFilename := structType.Field(i).Tag.Lookup("filenameField")
|
||||||
|
if hasFilename {
|
||||||
|
fnf := destStruct.FieldByName(nameField)
|
||||||
|
if fnf == (reflect.Value{}) {
|
||||||
|
panic(fmt.Errorf("filenameField '%s' does not exist", nameField))
|
||||||
|
}
|
||||||
|
|
||||||
|
fnf.SetString(hdr.Filename)
|
||||||
|
}
|
||||||
|
audioBytes, err := io.ReadAll(file)
|
||||||
|
if err != nil {
|
||||||
|
return fmt.Errorf("file read: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
destFieldVal.SetBytes(audioBytes)
|
||||||
|
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
|
||||||
|
if !r.Form.Has(formField) && omitEmpty {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
|
||||||
|
ff := r.Form.Get(formField)
|
||||||
|
|
||||||
|
switch v := destFieldIntf.(type) {
|
||||||
|
case string, *string:
|
||||||
|
setVal(destFieldVal, ff != "" || o.acceptBlank, ff)
|
||||||
|
case int, uint, *int, *uint:
|
||||||
|
val, set, err := o.parseInt(ff)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
setVal(destFieldVal, set, val)
|
||||||
|
case float64:
|
||||||
|
val, set, err := o.parseFloat64(ff)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
setVal(destFieldVal, set, val)
|
||||||
|
case bool, *bool:
|
||||||
|
val, set, err := o.parseBool(ff)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
setVal(destFieldVal, set, val)
|
||||||
|
case time.Time, *time.Time, jsontypes.Time, *jsontypes.Time:
|
||||||
|
t, set, err := o.parseTime(ff)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
setVal(destFieldVal, set, t)
|
||||||
|
case time.Duration, *time.Duration, jsontypes.Duration, *jsontypes.Duration:
|
||||||
|
d, set, err := o.parseDuration(ff)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
setVal(destFieldVal, set, d)
|
||||||
|
case []int:
|
||||||
|
val := strings.Trim(ff, "[]")
|
||||||
|
if val == "" && o.acceptBlank {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
vals := strings.Split(val, ",")
|
||||||
|
ar := make([]int, 0, len(vals))
|
||||||
|
for _, v := range vals {
|
||||||
|
i, err := strconv.Atoi(v)
|
||||||
|
if err == nil {
|
||||||
|
ar = append(ar, i)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
destFieldVal.Set(reflect.ValueOf(ar))
|
||||||
|
default:
|
||||||
|
panic(fmt.Errorf("unsupported type %T", v))
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func setVal(destFieldVal reflect.Value, set bool, src any) {
|
||||||
|
if !set {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
destType := destFieldVal.Type()
|
||||||
|
srcVal := reflect.ValueOf(src)
|
||||||
|
|
||||||
|
if srcVal.Kind() == reflect.Ptr {
|
||||||
|
srcVal = srcVal.Elem()
|
||||||
|
}
|
||||||
|
|
||||||
|
if destType.Kind() == reflect.Ptr {
|
||||||
|
if !srcVal.CanAddr() {
|
||||||
|
if srcVal.CanConvert(destType.Elem()) {
|
||||||
|
srcVal = srcVal.Convert(destType.Elem())
|
||||||
|
}
|
||||||
|
copy := reflect.New(srcVal.Type())
|
||||||
|
copy.Elem().Set(srcVal)
|
||||||
|
srcVal = copy
|
||||||
|
}
|
||||||
|
} else if srcVal.CanConvert(destFieldVal.Type()) {
|
||||||
|
srcVal = srcVal.Convert(destFieldVal.Type())
|
||||||
|
}
|
||||||
|
|
||||||
|
destFieldVal.Set(srcVal)
|
||||||
|
}
|
||||||
|
|
||||||
|
func Unmarshal(r *http.Request, dest any, opt ...Option) error {
|
||||||
|
o := options{
|
||||||
|
maxMultipartMemory: MaxMultipartMemory,
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, opt := range opt {
|
||||||
|
opt(&o)
|
||||||
|
}
|
||||||
|
|
||||||
|
contentType := strings.Split(r.Header.Get("Content-Type"), ";")[0]
|
||||||
|
|
||||||
|
switch contentType {
|
||||||
|
case "multipart/form-data":
|
||||||
|
err := r.ParseMultipartForm(o.maxMultipartMemory)
|
||||||
|
if err != nil {
|
||||||
|
return fmt.Errorf("ParseForm: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
return o.unmarshalForm(r, dest)
|
||||||
|
case "application/x-www-form-urlencoded":
|
||||||
|
err := r.ParseForm()
|
||||||
|
if err != nil {
|
||||||
|
return fmt.Errorf("ParseForm: %w", err)
|
||||||
|
}
|
||||||
|
return o.unmarshalForm(r, dest)
|
||||||
|
case "application/json":
|
||||||
|
return json.NewDecoder(r.Body).Decode(dest)
|
||||||
|
}
|
||||||
|
|
||||||
|
return ErrContentType
|
||||||
|
}
|
||||||
|
|
||||||
|
func (o *options) unmarshalForm(r *http.Request, dest any) error {
|
||||||
|
destVal := reflect.ValueOf(dest)
|
||||||
|
if k := destVal.Kind(); k == reflect.Ptr {
|
||||||
|
destVal = destVal.Elem()
|
||||||
|
} else {
|
||||||
|
return ErrNotPointer
|
||||||
|
}
|
||||||
|
|
||||||
|
if destVal.Kind() != reflect.Struct {
|
||||||
|
return ErrNotStruct
|
||||||
|
}
|
||||||
|
|
||||||
|
return o.iterFields(r, destVal)
|
||||||
|
}
|
||||||
|
|
|
@ -1,139 +0,0 @@
|
||||||
package forms
|
|
||||||
|
|
||||||
import (
|
|
||||||
"fmt"
|
|
||||||
"mime/multipart"
|
|
||||||
"reflect"
|
|
||||||
"strconv"
|
|
||||||
"strings"
|
|
||||||
"time"
|
|
||||||
)
|
|
||||||
|
|
||||||
func Marshal(src any, dest *multipart.Writer, opts ...Option) error {
|
|
||||||
o := options{}
|
|
||||||
|
|
||||||
for _, opt := range opts {
|
|
||||||
opt(&o)
|
|
||||||
}
|
|
||||||
|
|
||||||
return o.marshalMultipartForm(src, dest)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (o *options) marshalMultipartForm(src any, dest *multipart.Writer) error {
|
|
||||||
srcVal := reflect.ValueOf(src)
|
|
||||||
if k := srcVal.Kind(); k == reflect.Ptr {
|
|
||||||
srcVal = srcVal.Elem()
|
|
||||||
}
|
|
||||||
|
|
||||||
if srcVal.Kind() != reflect.Struct {
|
|
||||||
return ErrNotStruct
|
|
||||||
}
|
|
||||||
|
|
||||||
return o.marIterFields(srcVal, dest)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (o *options) marIterFields(srcVal reflect.Value, dest *multipart.Writer) error {
|
|
||||||
structType := srcVal.Type()
|
|
||||||
for i := 0; i < structType.NumField(); i++ {
|
|
||||||
srcFieldVal := srcVal.Field(i)
|
|
||||||
fieldType := structType.Field(i)
|
|
||||||
if !fieldType.IsExported() && !fieldType.Anonymous {
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
|
|
||||||
if srcFieldVal.Kind() == reflect.Struct && fieldType.Anonymous {
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
|
|
||||||
var tAr []string
|
|
||||||
var formField string
|
|
||||||
var omitEmpty bool
|
|
||||||
if o.defaultOmitEmpty {
|
|
||||||
omitEmpty = true
|
|
||||||
}
|
|
||||||
|
|
||||||
formTag, has := structType.Field(i).Tag.Lookup(o.Tag())
|
|
||||||
if has {
|
|
||||||
tAr = strings.Split(formTag, ",")
|
|
||||||
formField = tAr[0]
|
|
||||||
for _, v := range tAr[1:] {
|
|
||||||
if v == "omitempty" {
|
|
||||||
omitEmpty = true
|
|
||||||
break
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if !has || formField == "-" {
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
|
|
||||||
if srcFieldVal.Kind() == reflect.Ptr {
|
|
||||||
srcFieldVal = srcFieldVal.Elem()
|
|
||||||
if srcFieldVal == (reflect.Value{}) || srcFieldVal.IsZero() {
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
srcFieldIntf := srcFieldVal.Interface()
|
|
||||||
if srcFieldVal.Kind() == reflect.Slice && srcFieldVal.Type() == typeOfByteSlice {
|
|
||||||
nameField, hasFilename := structType.Field(i).Tag.Lookup("filenameField")
|
|
||||||
fileName := ""
|
|
||||||
if hasFilename {
|
|
||||||
fnf := srcVal.FieldByName(nameField)
|
|
||||||
if fnf == (reflect.Value{}) {
|
|
||||||
panic(fmt.Errorf("filenameField '%s' does not exist", nameField))
|
|
||||||
}
|
|
||||||
|
|
||||||
fileName = fnf.String()
|
|
||||||
}
|
|
||||||
|
|
||||||
fw, err := dest.CreateFormFile(formField, fileName)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("form marshal: createFormFile: %w", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
_, err = fw.Write(srcFieldVal.Bytes())
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("form marshal: write file: %w", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
|
|
||||||
if srcFieldVal.IsZero() && omitEmpty {
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
|
|
||||||
var val string
|
|
||||||
switch v := srcFieldIntf.(type) {
|
|
||||||
case []string:
|
|
||||||
if omitEmpty && len(v) == 0 {
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
val = "[" + strings.Join(v, ",") + "]"
|
|
||||||
case []int:
|
|
||||||
if omitEmpty && len(v) == 0 {
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
|
|
||||||
sl := make([]string, len(v))
|
|
||||||
for i := range v {
|
|
||||||
sl[i] = strconv.Itoa(v[i])
|
|
||||||
}
|
|
||||||
|
|
||||||
val = "[" + strings.Join(sl, ",") + "]"
|
|
||||||
case time.Time:
|
|
||||||
val = strconv.Itoa(int(v.Unix()))
|
|
||||||
default:
|
|
||||||
val = fmt.Sprint(v)
|
|
||||||
}
|
|
||||||
|
|
||||||
err := dest.WriteField(formField, val)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("marshal field '%s': %w", formField, err)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
|
@ -1,121 +0,0 @@
|
||||||
package forms_test
|
|
||||||
|
|
||||||
import (
|
|
||||||
"bytes"
|
|
||||||
"fmt"
|
|
||||||
"math/rand"
|
|
||||||
"mime/multipart"
|
|
||||||
"net/http"
|
|
||||||
"net/http/httptest"
|
|
||||||
"testing"
|
|
||||||
"time"
|
|
||||||
|
|
||||||
"github.com/stretchr/testify/assert"
|
|
||||||
"github.com/stretchr/testify/require"
|
|
||||||
|
|
||||||
"dynatron.me/x/stillbox/internal/common"
|
|
||||||
"dynatron.me/x/stillbox/internal/forms"
|
|
||||||
"dynatron.me/x/stillbox/pkg/auth"
|
|
||||||
"dynatron.me/x/stillbox/pkg/calls"
|
|
||||||
"dynatron.me/x/stillbox/pkg/sources"
|
|
||||||
|
|
||||||
"github.com/google/uuid"
|
|
||||||
)
|
|
||||||
|
|
||||||
type hand func(w http.ResponseWriter, r *http.Request)
|
|
||||||
|
|
||||||
func (h hand) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
|
||||||
h(w, r)
|
|
||||||
}
|
|
||||||
|
|
||||||
func call(url string, call *calls.Call) error {
|
|
||||||
var buf bytes.Buffer
|
|
||||||
body := multipart.NewWriter(&buf)
|
|
||||||
|
|
||||||
err := forms.Marshal(call, body)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("relay form parse: %w", err)
|
|
||||||
}
|
|
||||||
body.Close()
|
|
||||||
|
|
||||||
r, err := http.NewRequest(http.MethodPost, url, &buf)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("relay newrequest: %w", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
r.Header.Set("Content-Type", body.FormDataContentType())
|
|
||||||
|
|
||||||
resp, err := http.DefaultClient.Do(r)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("relay: %w", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
if resp.StatusCode != http.StatusOK {
|
|
||||||
return fmt.Errorf("relay: received HTTP %d", resp.StatusCode)
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestMarshal(t *testing.T) {
|
|
||||||
uuid.SetRand(rand.New(rand.NewSource(1)))
|
|
||||||
|
|
||||||
tests := []struct {
|
|
||||||
name string
|
|
||||||
submitter auth.UserID
|
|
||||||
apiKey string
|
|
||||||
call calls.Call
|
|
||||||
}{
|
|
||||||
{
|
|
||||||
name: "base",
|
|
||||||
submitter: auth.UserID(1),
|
|
||||||
call: calls.Call{
|
|
||||||
ID: uuid.UUID([16]byte{0x52, 0xfd, 0xfc, 0x07, 0x21, 0x82, 0x45, 0x4f, 0x96, 0x3f, 0x5f, 0x0f, 0x9a, 0x62, 0x1d, 0x72}),
|
|
||||||
Submitter: common.PtrTo(auth.UserID(1)),
|
|
||||||
System: 197,
|
|
||||||
Talkgroup: 10101,
|
|
||||||
DateTime: time.Date(2024, 11, 10, 23, 33, 02, 0, time.Local),
|
|
||||||
AudioName: "rightnow.mp3",
|
|
||||||
Audio: []byte{0xFF, 0xF3, 0x14, 0xC4, 0x00, 0x00, 0x00, 0x03, 0x48, 0x01, 0x40, 0x00, 0x00, 0x4C, 0x41, 0x4D, 0x45, 0x33, 0x2E, 0x39, 0x36, 0x2E, 0x31, 0x55},
|
|
||||||
AudioType: "audio/mpeg",
|
|
||||||
Duration: calls.CallDuration(24000000),
|
|
||||||
TalkgroupLabel: common.PtrTo("Some TG"),
|
|
||||||
},
|
|
||||||
},
|
|
||||||
}
|
|
||||||
|
|
||||||
for _, tc := range tests {
|
|
||||||
t.Run(tc.name, func(t *testing.T) {
|
|
||||||
var serr error
|
|
||||||
var called bool
|
|
||||||
h := hand(func(w http.ResponseWriter, r *http.Request) {
|
|
||||||
called = true
|
|
||||||
serr = r.ParseMultipartForm(1024 * 1024 * 2)
|
|
||||||
if serr != nil {
|
|
||||||
t.Log("parsemultipart", serr)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
cur := new(sources.CallUploadRequest)
|
|
||||||
serr = forms.Unmarshal(r, cur, forms.WithAcceptBlank())
|
|
||||||
cur.DontStore = true
|
|
||||||
if serr != nil {
|
|
||||||
t.Log("unmarshal", serr)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
assert.Equal(t, tc.apiKey, cur.Key)
|
|
||||||
|
|
||||||
toC, tcerr := cur.ToCall(tc.submitter)
|
|
||||||
require.NoError(t, tcerr)
|
|
||||||
assert.Equal(t, &tc.call, toC)
|
|
||||||
})
|
|
||||||
svr := httptest.NewServer(h)
|
|
||||||
|
|
||||||
err := call(svr.URL, &tc.call)
|
|
||||||
assert.True(t, called)
|
|
||||||
assert.NoError(t, err)
|
|
||||||
assert.NoError(t, serr)
|
|
||||||
})
|
|
||||||
}
|
|
||||||
}
|
|
|
@ -1,306 +0,0 @@
|
||||||
package forms
|
|
||||||
|
|
||||||
import (
|
|
||||||
"encoding/json"
|
|
||||||
"fmt"
|
|
||||||
"io"
|
|
||||||
"net/http"
|
|
||||||
"reflect"
|
|
||||||
"strconv"
|
|
||||||
"strings"
|
|
||||||
"time"
|
|
||||||
|
|
||||||
"dynatron.me/x/stillbox/internal/jsontypes"
|
|
||||||
|
|
||||||
"github.com/araddon/dateparse"
|
|
||||||
)
|
|
||||||
|
|
||||||
func (o *options) parseTime(s string, dpo ...dateparse.ParserOption) (t time.Time, set bool, err error) {
|
|
||||||
if o.acceptBlank && s == "" {
|
|
||||||
set = false
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
if iv, err := strconv.Atoi(s); err == nil {
|
|
||||||
return time.Unix(int64(iv), 0), true, nil
|
|
||||||
}
|
|
||||||
|
|
||||||
switch {
|
|
||||||
case o.parseTimeIn != nil:
|
|
||||||
t, err = dateparse.ParseIn(s, o.parseTimeIn, dpo...)
|
|
||||||
case o.parseLocal:
|
|
||||||
t, err = dateparse.ParseLocal(s, dpo...)
|
|
||||||
default:
|
|
||||||
t, err = dateparse.ParseAny(s, dpo...)
|
|
||||||
}
|
|
||||||
|
|
||||||
set = true
|
|
||||||
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
func (o *options) parseBool(s string) (v bool, set bool, err error) {
|
|
||||||
if o.acceptBlank && s == "" {
|
|
||||||
set = false
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
set = true
|
|
||||||
|
|
||||||
v, err = strconv.ParseBool(s)
|
|
||||||
if err != nil {
|
|
||||||
return v, set, fmt.Errorf("parsebool('%s'): %w", s, err)
|
|
||||||
}
|
|
||||||
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
func (o *options) parseInt(s string) (v int, set bool, err error) {
|
|
||||||
if o.acceptBlank && s == "" {
|
|
||||||
set = false
|
|
||||||
return
|
|
||||||
}
|
|
||||||
set = true
|
|
||||||
|
|
||||||
v, err = strconv.Atoi(s)
|
|
||||||
if err != nil {
|
|
||||||
return v, set, fmt.Errorf("atoi('%s'): %w", s, err)
|
|
||||||
}
|
|
||||||
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
func (o *options) parseFloat64(s string) (v float64, set bool, err error) {
|
|
||||||
if o.acceptBlank && s == "" {
|
|
||||||
set = false
|
|
||||||
return
|
|
||||||
}
|
|
||||||
set = true
|
|
||||||
|
|
||||||
v, err = strconv.ParseFloat(s, 64)
|
|
||||||
if err != nil {
|
|
||||||
return v, set, fmt.Errorf("ParseFloat('%s'): %w", s, err)
|
|
||||||
}
|
|
||||||
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
func (o *options) parseDuration(s string) (v time.Duration, set bool, err error) {
|
|
||||||
if o.acceptBlank && s == "" {
|
|
||||||
set = false
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
set = true
|
|
||||||
|
|
||||||
v, err = time.ParseDuration(s)
|
|
||||||
if err != nil {
|
|
||||||
return v, set, fmt.Errorf("ParseDuration('%s'): %w", s, err)
|
|
||||||
}
|
|
||||||
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
var typeOfByteSlice = reflect.TypeOf([]byte(nil))
|
|
||||||
|
|
||||||
func (o *options) unmIterFields(r *http.Request, destStruct reflect.Value) error {
|
|
||||||
structType := destStruct.Type()
|
|
||||||
for i := 0; i < destStruct.NumField(); i++ {
|
|
||||||
destFieldVal := destStruct.Field(i)
|
|
||||||
fieldType := structType.Field(i)
|
|
||||||
if !fieldType.IsExported() && !fieldType.Anonymous {
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
|
|
||||||
if destFieldVal.Kind() == reflect.Struct && fieldType.Anonymous {
|
|
||||||
err := o.unmIterFields(r, destFieldVal)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
var tAr []string
|
|
||||||
var formField string
|
|
||||||
var omitEmpty bool
|
|
||||||
if o.defaultOmitEmpty {
|
|
||||||
omitEmpty = true
|
|
||||||
}
|
|
||||||
|
|
||||||
formTag, has := structType.Field(i).Tag.Lookup(o.Tag())
|
|
||||||
if has {
|
|
||||||
tAr = strings.Split(formTag, ",")
|
|
||||||
formField = tAr[0]
|
|
||||||
for _, v := range tAr[1:] {
|
|
||||||
if v == "omitempty" {
|
|
||||||
omitEmpty = true
|
|
||||||
break
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if !has || formField == "-" {
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
|
|
||||||
destFieldIntf := destFieldVal.Interface()
|
|
||||||
|
|
||||||
if destFieldVal.Kind() == reflect.Slice && destFieldVal.Type() == typeOfByteSlice {
|
|
||||||
file, hdr, err := r.FormFile(formField)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("get form file: %w", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
nameField, hasFilename := structType.Field(i).Tag.Lookup("filenameField")
|
|
||||||
if hasFilename {
|
|
||||||
fnf := destStruct.FieldByName(nameField)
|
|
||||||
if fnf == (reflect.Value{}) {
|
|
||||||
panic(fmt.Errorf("filenameField '%s' does not exist", nameField))
|
|
||||||
}
|
|
||||||
|
|
||||||
fnf.SetString(hdr.Filename)
|
|
||||||
}
|
|
||||||
audioBytes, err := io.ReadAll(file)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("file read: %w", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
destFieldVal.SetBytes(audioBytes)
|
|
||||||
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
|
|
||||||
if !r.Form.Has(formField) && omitEmpty {
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
|
|
||||||
ff := r.Form.Get(formField)
|
|
||||||
|
|
||||||
switch v := destFieldIntf.(type) {
|
|
||||||
case string, *string:
|
|
||||||
setVal(destFieldVal, ff != "" || o.acceptBlank, ff)
|
|
||||||
case int, uint, *int, *uint:
|
|
||||||
val, set, err := o.parseInt(ff)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
setVal(destFieldVal, set, val)
|
|
||||||
case float64:
|
|
||||||
val, set, err := o.parseFloat64(ff)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
setVal(destFieldVal, set, val)
|
|
||||||
case bool, *bool:
|
|
||||||
val, set, err := o.parseBool(ff)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
setVal(destFieldVal, set, val)
|
|
||||||
case time.Time, *time.Time, jsontypes.Time, *jsontypes.Time:
|
|
||||||
t, set, err := o.parseTime(ff)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
setVal(destFieldVal, set, t)
|
|
||||||
case time.Duration, *time.Duration, jsontypes.Duration, *jsontypes.Duration:
|
|
||||||
d, set, err := o.parseDuration(ff)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
setVal(destFieldVal, set, d)
|
|
||||||
case []int:
|
|
||||||
val := strings.Trim(ff, "[]")
|
|
||||||
if val == "" && o.acceptBlank {
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
vals := strings.Split(val, ",")
|
|
||||||
ar := make([]int, 0, len(vals))
|
|
||||||
for _, v := range vals {
|
|
||||||
i, err := strconv.Atoi(v)
|
|
||||||
if err == nil {
|
|
||||||
ar = append(ar, i)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
destFieldVal.Set(reflect.ValueOf(ar))
|
|
||||||
default:
|
|
||||||
panic(fmt.Errorf("unsupported type %T", v))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func setVal(destFieldVal reflect.Value, set bool, src any) {
|
|
||||||
if !set {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
destType := destFieldVal.Type()
|
|
||||||
srcVal := reflect.ValueOf(src)
|
|
||||||
|
|
||||||
if srcVal.Kind() == reflect.Ptr {
|
|
||||||
srcVal = srcVal.Elem()
|
|
||||||
}
|
|
||||||
|
|
||||||
if destType.Kind() == reflect.Ptr {
|
|
||||||
if !srcVal.CanAddr() {
|
|
||||||
if srcVal.CanConvert(destType.Elem()) {
|
|
||||||
srcVal = srcVal.Convert(destType.Elem())
|
|
||||||
}
|
|
||||||
copy := reflect.New(srcVal.Type())
|
|
||||||
copy.Elem().Set(srcVal)
|
|
||||||
srcVal = copy
|
|
||||||
}
|
|
||||||
} else if srcVal.CanConvert(destFieldVal.Type()) {
|
|
||||||
srcVal = srcVal.Convert(destFieldVal.Type())
|
|
||||||
}
|
|
||||||
|
|
||||||
destFieldVal.Set(srcVal)
|
|
||||||
}
|
|
||||||
|
|
||||||
func Unmarshal(r *http.Request, dest any, opts ...Option) error {
|
|
||||||
o := options{
|
|
||||||
maxMultipartMemory: MaxMultipartMemory,
|
|
||||||
}
|
|
||||||
|
|
||||||
for _, opt := range opts {
|
|
||||||
opt(&o)
|
|
||||||
}
|
|
||||||
|
|
||||||
contentType := strings.Split(r.Header.Get("Content-Type"), ";")[0]
|
|
||||||
|
|
||||||
switch contentType {
|
|
||||||
case "multipart/form-data":
|
|
||||||
err := r.ParseMultipartForm(o.maxMultipartMemory)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("ParseForm: %w", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
return o.unmarshalForm(r, dest)
|
|
||||||
case "application/x-www-form-urlencoded":
|
|
||||||
err := r.ParseForm()
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("ParseForm: %w", err)
|
|
||||||
}
|
|
||||||
return o.unmarshalForm(r, dest)
|
|
||||||
case "application/json":
|
|
||||||
return json.NewDecoder(r.Body).Decode(dest)
|
|
||||||
}
|
|
||||||
|
|
||||||
return ErrContentType
|
|
||||||
}
|
|
||||||
|
|
||||||
func (o *options) unmarshalForm(r *http.Request, dest any) error {
|
|
||||||
destVal := reflect.ValueOf(dest)
|
|
||||||
if k := destVal.Kind(); k == reflect.Ptr {
|
|
||||||
destVal = destVal.Elem()
|
|
||||||
} else {
|
|
||||||
return ErrNotPointer
|
|
||||||
}
|
|
||||||
|
|
||||||
if destVal.Kind() != reflect.Struct {
|
|
||||||
return ErrNotStruct
|
|
||||||
}
|
|
||||||
|
|
||||||
return o.unmIterFields(r, destVal)
|
|
||||||
}
|
|
|
@ -33,26 +33,26 @@ func (d CallDuration) Seconds() int32 {
|
||||||
}
|
}
|
||||||
|
|
||||||
type Call struct {
|
type Call struct {
|
||||||
ID uuid.UUID `form:"-"`
|
ID uuid.UUID
|
||||||
Audio []byte `form:"audio" filenameField:"AudioName"`
|
Audio []byte
|
||||||
AudioName string `form:"audioName"`
|
AudioName string
|
||||||
AudioType string `form:"audioType"`
|
AudioType string
|
||||||
Duration CallDuration `form:"-"`
|
Duration CallDuration
|
||||||
DateTime time.Time `form:"dateTime"`
|
DateTime time.Time
|
||||||
Frequencies []int `form:"frequencies"`
|
Frequencies []int
|
||||||
Frequency int `form:"frequency"`
|
Frequency int
|
||||||
Patches []int `form:"patches"`
|
Patches []int
|
||||||
Source int `form:"source"`
|
Source int
|
||||||
Sources []int `form:"sources"`
|
Sources []int
|
||||||
System int `form:"system"`
|
System int
|
||||||
Submitter *auth.UserID `form:"-"`
|
Submitter *auth.UserID
|
||||||
SystemLabel string `form:"systemLabel"`
|
SystemLabel string
|
||||||
Talkgroup int `form:"talkgroup"`
|
Talkgroup int
|
||||||
TalkgroupGroup *string `form:"talkgroupGroup"`
|
TalkgroupGroup *string
|
||||||
TalkgroupLabel *string `form:"talkgroupLabel"`
|
TalkgroupLabel *string
|
||||||
TGAlphaTag *string `form:"talkgroupTag"` // not 1:1
|
TGAlphaTag *string
|
||||||
|
|
||||||
shouldStore bool `form:"-"`
|
shouldStore bool
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *Call) String() string {
|
func (c *Call) String() string {
|
||||||
|
|
|
@ -22,7 +22,6 @@ type Config struct {
|
||||||
Public bool `yaml:"public"`
|
Public bool `yaml:"public"`
|
||||||
RateLimit RateLimit `yaml:"rateLimit"`
|
RateLimit RateLimit `yaml:"rateLimit"`
|
||||||
Notify Notify `yaml:"notify"`
|
Notify Notify `yaml:"notify"`
|
||||||
Relay []Relay `yaml:"relay"`
|
|
||||||
|
|
||||||
configPath string
|
configPath string
|
||||||
}
|
}
|
||||||
|
@ -64,12 +63,6 @@ type Alerting struct {
|
||||||
Renotify *jsontypes.Duration `yaml:"renotify,omitempty" form:"renotify,omitempty"`
|
Renotify *jsontypes.Duration `yaml:"renotify,omitempty" form:"renotify,omitempty"`
|
||||||
}
|
}
|
||||||
|
|
||||||
type Relay struct {
|
|
||||||
URL string `yaml:"url"`
|
|
||||||
APIKey string `yaml:"apiKey"`
|
|
||||||
Required bool `yaml:"required"`
|
|
||||||
}
|
|
||||||
|
|
||||||
type Notify []NotifyService
|
type Notify []NotifyService
|
||||||
|
|
||||||
type NotifyService struct {
|
type NotifyService struct {
|
||||||
|
@ -79,6 +72,17 @@ type NotifyService struct {
|
||||||
Config map[string]interface{} `yaml:"config" json:"config"`
|
Config map[string]interface{} `yaml:"config" json:"config"`
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (n *NotifyService) GetS(k, defaultVal string) string {
|
||||||
|
if v, has := n.Config[k]; has {
|
||||||
|
if v, isString := v.(string); isString {
|
||||||
|
return v
|
||||||
|
}
|
||||||
|
log.Error().Str("configKey", k).Str("provider", n.Provider).Str("default", defaultVal).Msg("notify config value is not a string! using default")
|
||||||
|
}
|
||||||
|
|
||||||
|
return defaultVal
|
||||||
|
}
|
||||||
|
|
||||||
func (rl *RateLimit) Verify() bool {
|
func (rl *RateLimit) Verify() bool {
|
||||||
if rl.Enable {
|
if rl.Enable {
|
||||||
if rl.Requests > 0 && rl.Over > 0 {
|
if rl.Requests > 0 && rl.Over > 0 {
|
||||||
|
|
|
@ -31,7 +31,6 @@ type Server struct {
|
||||||
r *chi.Mux
|
r *chi.Mux
|
||||||
sources sources.Sources
|
sources sources.Sources
|
||||||
sinks sinks.Sinks
|
sinks sinks.Sinks
|
||||||
relayer *sinks.RelayManager
|
|
||||||
nex *nexus.Nexus
|
nex *nexus.Nexus
|
||||||
logger *Logger
|
logger *Logger
|
||||||
alerter alerting.Alerter
|
alerter alerting.Alerter
|
||||||
|
@ -74,7 +73,6 @@ func New(ctx context.Context, cfg *config.Config) (*Server, error) {
|
||||||
alerter: alerting.New(cfg.Alerting, tgCache, alerting.WithNotifier(notifier)),
|
alerter: alerting.New(cfg.Alerting, tgCache, alerting.WithNotifier(notifier)),
|
||||||
notifier: notifier,
|
notifier: notifier,
|
||||||
tgs: tgCache,
|
tgs: tgCache,
|
||||||
sinks: sinks.NewSinkManager(),
|
|
||||||
rest: api,
|
rest: api,
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -87,13 +85,6 @@ func New(ctx context.Context, cfg *config.Config) (*Server, error) {
|
||||||
|
|
||||||
srv.sources.Register("rdio-http", sources.NewRdioHTTP(authenticator, srv))
|
srv.sources.Register("rdio-http", sources.NewRdioHTTP(authenticator, srv))
|
||||||
|
|
||||||
relayer, err := sinks.NewRelayManager(srv.sinks, cfg.Relay)
|
|
||||||
if err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
|
|
||||||
srv.relayer = relayer
|
|
||||||
|
|
||||||
r.Use(middleware.RequestID)
|
r.Use(middleware.RequestID)
|
||||||
r.Use(middleware.RealIP)
|
r.Use(middleware.RealIP)
|
||||||
r.Use(RequestLogger())
|
r.Use(RequestLogger())
|
||||||
|
|
|
@ -1,118 +0,0 @@
|
||||||
package sinks
|
|
||||||
|
|
||||||
import (
|
|
||||||
"bytes"
|
|
||||||
"context"
|
|
||||||
"fmt"
|
|
||||||
"mime/multipart"
|
|
||||||
"net/http"
|
|
||||||
"net/url"
|
|
||||||
|
|
||||||
"dynatron.me/x/stillbox/internal/forms"
|
|
||||||
"dynatron.me/x/stillbox/internal/version"
|
|
||||||
"dynatron.me/x/stillbox/pkg/calls"
|
|
||||||
"dynatron.me/x/stillbox/pkg/config"
|
|
||||||
)
|
|
||||||
|
|
||||||
type RelayManager struct {
|
|
||||||
xp *http.Transport
|
|
||||||
client *http.Client
|
|
||||||
|
|
||||||
relays []*Relay
|
|
||||||
}
|
|
||||||
|
|
||||||
type Relay struct {
|
|
||||||
config.Relay
|
|
||||||
mgr *RelayManager
|
|
||||||
Name string
|
|
||||||
|
|
||||||
url *url.URL
|
|
||||||
}
|
|
||||||
|
|
||||||
func NewRelayManager(s Sinks, cfgs []config.Relay) (*RelayManager, error) {
|
|
||||||
xp := http.DefaultTransport.(*http.Transport).Clone()
|
|
||||||
xp.MaxIdleConnsPerHost = 10
|
|
||||||
|
|
||||||
client := &http.Client{
|
|
||||||
Transport: xp,
|
|
||||||
}
|
|
||||||
|
|
||||||
rm := &RelayManager{
|
|
||||||
xp: xp,
|
|
||||||
client: client,
|
|
||||||
relays: make([]*Relay, 0, len(cfgs)),
|
|
||||||
}
|
|
||||||
|
|
||||||
for i, cfg := range cfgs {
|
|
||||||
rs, err := rm.newRelay(cfg)
|
|
||||||
if err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
|
|
||||||
rm.relays = append(rm.relays, rs)
|
|
||||||
|
|
||||||
sinkName := fmt.Sprintf("relay%d:%s", i, rs.url.Host)
|
|
||||||
s.Register(sinkName, rs, cfg.Required)
|
|
||||||
}
|
|
||||||
|
|
||||||
return rm, nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (rs *RelayManager) newRelay(cfg config.Relay) (*Relay, error) {
|
|
||||||
u, err := url.Parse(cfg.URL)
|
|
||||||
if err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
|
|
||||||
if u.Path != "" && u.Path != "/" {
|
|
||||||
return nil, fmt.Errorf("relay path in %s must be instance root", cfg.URL)
|
|
||||||
}
|
|
||||||
|
|
||||||
u = u.JoinPath("/api/call-upload")
|
|
||||||
|
|
||||||
return &Relay{
|
|
||||||
Relay: cfg,
|
|
||||||
url: u,
|
|
||||||
mgr: rs,
|
|
||||||
}, nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (s *Relay) Call(ctx context.Context, call *calls.Call) error {
|
|
||||||
var buf bytes.Buffer
|
|
||||||
body := multipart.NewWriter(&buf)
|
|
||||||
|
|
||||||
err := forms.Marshal(call, body)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("relay form parse: %w", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
err = body.WriteField("key", s.APIKey)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("relay set API key: %w", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
body.Close()
|
|
||||||
|
|
||||||
r, err := http.NewRequestWithContext(ctx, http.MethodPost, s.url.String(), &buf)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("relay newrequest: %w", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
r.Header.Set("Content-Type", body.FormDataContentType())
|
|
||||||
r.Header.Set("User-Agent", version.HttpString("call-relay"))
|
|
||||||
|
|
||||||
resp, err := s.mgr.client.Do(r)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("relay %s: %w", s.Name, err)
|
|
||||||
}
|
|
||||||
|
|
||||||
if resp.StatusCode != http.StatusOK {
|
|
||||||
return fmt.Errorf("relay %s: received HTTP %d", s.Name, resp.StatusCode)
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (s *Relay) SinkType() string {
|
|
||||||
return "relay"
|
|
||||||
}
|
|
|
@ -1,107 +0,0 @@
|
||||||
package sinks
|
|
||||||
|
|
||||||
import (
|
|
||||||
"context"
|
|
||||||
"math/rand"
|
|
||||||
"net/http"
|
|
||||||
"net/http/httptest"
|
|
||||||
"testing"
|
|
||||||
"time"
|
|
||||||
|
|
||||||
"github.com/stretchr/testify/assert"
|
|
||||||
"github.com/stretchr/testify/require"
|
|
||||||
|
|
||||||
"dynatron.me/x/stillbox/internal/common"
|
|
||||||
"dynatron.me/x/stillbox/internal/forms"
|
|
||||||
"dynatron.me/x/stillbox/pkg/auth"
|
|
||||||
"dynatron.me/x/stillbox/pkg/calls"
|
|
||||||
"dynatron.me/x/stillbox/pkg/config"
|
|
||||||
"dynatron.me/x/stillbox/pkg/sources"
|
|
||||||
|
|
||||||
"github.com/google/uuid"
|
|
||||||
)
|
|
||||||
|
|
||||||
type hand func(w http.ResponseWriter, r *http.Request)
|
|
||||||
|
|
||||||
func (h hand) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
|
||||||
h(w, r)
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestRelay(t *testing.T) {
|
|
||||||
uuid.SetRand(rand.New(rand.NewSource(1)))
|
|
||||||
|
|
||||||
tests := []struct {
|
|
||||||
name string
|
|
||||||
submitter auth.UserID
|
|
||||||
apiKey string
|
|
||||||
call calls.Call
|
|
||||||
}{
|
|
||||||
{
|
|
||||||
name: "base",
|
|
||||||
submitter: auth.UserID(1),
|
|
||||||
call: calls.Call{
|
|
||||||
ID: uuid.UUID([16]byte{0x52, 0xfd, 0xfc, 0x07, 0x21, 0x82, 0x45, 0x4f, 0x96, 0x3f, 0x5f, 0x0f, 0x9a, 0x62, 0x1d, 0x72}),
|
|
||||||
Submitter: common.PtrTo(auth.UserID(1)),
|
|
||||||
System: 197,
|
|
||||||
Talkgroup: 10101,
|
|
||||||
DateTime: time.Date(2024, 11, 10, 23, 33, 02, 0, time.Local),
|
|
||||||
AudioName: "rightnow.mp3",
|
|
||||||
Audio: []byte{0xFF, 0xF3, 0x14, 0xC4, 0x00, 0x00, 0x00, 0x03, 0x48, 0x01, 0x40, 0x00, 0x00, 0x4C, 0x41, 0x4D, 0x45, 0x33, 0x2E, 0x39, 0x36, 0x2E, 0x31, 0x55},
|
|
||||||
AudioType: "audio/mpeg",
|
|
||||||
Duration: calls.CallDuration(24000000),
|
|
||||||
TalkgroupLabel: common.PtrTo("Some TG"),
|
|
||||||
},
|
|
||||||
},
|
|
||||||
}
|
|
||||||
|
|
||||||
for _, tc := range tests {
|
|
||||||
t.Run(tc.name, func(t *testing.T) {
|
|
||||||
var serr error
|
|
||||||
var called bool
|
|
||||||
h := hand(func(w http.ResponseWriter, r *http.Request) {
|
|
||||||
called = true
|
|
||||||
assert.Equal(t, "/api/call-upload", r.URL.Path)
|
|
||||||
serr = r.ParseMultipartForm(1024 * 1024 * 2)
|
|
||||||
if serr != nil {
|
|
||||||
t.Log("parsemultipart", serr)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
cur := new(sources.CallUploadRequest)
|
|
||||||
serr = forms.Unmarshal(r, cur, forms.WithAcceptBlank())
|
|
||||||
cur.DontStore = true
|
|
||||||
if serr != nil {
|
|
||||||
t.Log("unmarshal", serr)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
assert.Equal(t, tc.apiKey, cur.Key)
|
|
||||||
|
|
||||||
toC, tcerr := cur.ToCall(tc.submitter)
|
|
||||||
require.NoError(t, tcerr)
|
|
||||||
assert.Equal(t, &tc.call, toC)
|
|
||||||
})
|
|
||||||
svr := httptest.NewServer(h)
|
|
||||||
|
|
||||||
cfg := config.Relay{
|
|
||||||
URL: svr.URL,
|
|
||||||
APIKey: tc.apiKey,
|
|
||||||
}
|
|
||||||
ns := &nullSinks{}
|
|
||||||
|
|
||||||
rm, err := NewRelayManager(ns, []config.Relay{cfg})
|
|
||||||
require.NoError(t, err)
|
|
||||||
err = rm.relays[0].Call(context.Background(), &tc.call)
|
|
||||||
assert.True(t, called)
|
|
||||||
assert.NoError(t, err)
|
|
||||||
assert.NoError(t, serr)
|
|
||||||
})
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
type nullSinks struct{}
|
|
||||||
|
|
||||||
func (*nullSinks) Register(name string, toAdd Sink, required bool) {}
|
|
||||||
func (*nullSinks) Unregister(name string) {}
|
|
||||||
func (*nullSinks) Shutdown() {}
|
|
||||||
func (*nullSinks) EmitCall(ctx context.Context, call *calls.Call) error { return nil }
|
|
|
@ -24,55 +24,36 @@ type sinkInstance struct {
|
||||||
Required bool
|
Required bool
|
||||||
}
|
}
|
||||||
|
|
||||||
type Sinks interface {
|
type Sinks struct {
|
||||||
Register(name string, toAdd Sink, required bool)
|
|
||||||
Unregister(name string)
|
|
||||||
Shutdown()
|
|
||||||
EmitCall(ctx context.Context, call *calls.Call) error
|
|
||||||
}
|
|
||||||
|
|
||||||
type sinks struct {
|
|
||||||
sync.RWMutex
|
sync.RWMutex
|
||||||
sinks map[string]sinkInstance
|
sinks []sinkInstance
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewSinkManager() Sinks {
|
func (s *Sinks) Register(name string, toAdd Sink, required bool) {
|
||||||
return &sinks{
|
|
||||||
sinks: make(map[string]sinkInstance),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func (s *sinks) Register(name string, toAdd Sink, required bool) {
|
|
||||||
s.Lock()
|
s.Lock()
|
||||||
defer s.Unlock()
|
defer s.Unlock()
|
||||||
|
|
||||||
s.sinks[name] = sinkInstance{
|
s.sinks = append(s.sinks, sinkInstance{
|
||||||
Name: name,
|
Name: name,
|
||||||
Sink: toAdd,
|
Sink: toAdd,
|
||||||
Required: required,
|
Required: required,
|
||||||
}
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *sinks) Unregister(name string) {
|
func (s *Sinks) Shutdown() {
|
||||||
s.Lock()
|
s.Lock()
|
||||||
defer s.Unlock()
|
defer s.Unlock()
|
||||||
|
|
||||||
delete(s.sinks, name)
|
s.sinks = nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *sinks) Shutdown() {
|
func (s *Sinks) EmitCall(ctx context.Context, call *calls.Call) error {
|
||||||
s.Lock()
|
|
||||||
defer s.Unlock()
|
|
||||||
|
|
||||||
clear(s.sinks)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (s *sinks) EmitCall(ctx context.Context, call *calls.Call) error {
|
|
||||||
s.Lock()
|
s.Lock()
|
||||||
defer s.Unlock()
|
defer s.Unlock()
|
||||||
|
|
||||||
g, ctx := errgroup.WithContext(ctx)
|
g, ctx := errgroup.WithContext(ctx)
|
||||||
for _, sink := range s.sinks {
|
for i := range s.sinks {
|
||||||
|
sink := s.sinks[i]
|
||||||
g.Go(sink.callEmitter(ctx, call))
|
g.Go(sink.callEmitter(ctx, call))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -36,7 +36,7 @@ func (h *RdioHTTP) InstallPublicRoutes(r chi.Router) {
|
||||||
r.Post("/api/call-upload", h.routeCallUpload)
|
r.Post("/api/call-upload", h.routeCallUpload)
|
||||||
}
|
}
|
||||||
|
|
||||||
type CallUploadRequest struct {
|
type callUploadRequest struct {
|
||||||
Audio []byte `form:"audio" filenameField:"AudioName"`
|
Audio []byte `form:"audio" filenameField:"AudioName"`
|
||||||
AudioName string
|
AudioName string
|
||||||
AudioType string `form:"audioType"`
|
AudioType string `form:"audioType"`
|
||||||
|
@ -56,7 +56,7 @@ type CallUploadRequest struct {
|
||||||
DontStore bool `form:"dontStore"`
|
DontStore bool `form:"dontStore"`
|
||||||
}
|
}
|
||||||
|
|
||||||
func (car *CallUploadRequest) mimeType() string {
|
func (car *callUploadRequest) mimeType() string {
|
||||||
// this is super naïve
|
// this is super naïve
|
||||||
fn := car.AudioName
|
fn := car.AudioName
|
||||||
switch {
|
switch {
|
||||||
|
@ -71,7 +71,7 @@ func (car *CallUploadRequest) mimeType() string {
|
||||||
return ""
|
return ""
|
||||||
}
|
}
|
||||||
|
|
||||||
func (car *CallUploadRequest) ToCall(submitter auth.UserID) (*calls.Call, error) {
|
func (car *callUploadRequest) toCall(submitter auth.UserID) (*calls.Call, error) {
|
||||||
return calls.Make(&calls.Call{
|
return calls.Make(&calls.Call{
|
||||||
Submitter: &submitter,
|
Submitter: &submitter,
|
||||||
System: car.System,
|
System: car.System,
|
||||||
|
@ -111,14 +111,14 @@ func (h *RdioHTTP) routeCallUpload(w http.ResponseWriter, r *http.Request) {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
cur := new(CallUploadRequest)
|
cur := new(callUploadRequest)
|
||||||
err = forms.Unmarshal(r, cur, forms.WithAcceptBlank())
|
err = forms.Unmarshal(r, cur, forms.WithAcceptBlank())
|
||||||
if err != nil {
|
if err != nil {
|
||||||
http.Error(w, "cannot bind upload "+err.Error(), http.StatusExpectationFailed)
|
http.Error(w, "cannot bind upload "+err.Error(), http.StatusExpectationFailed)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
call, err := cur.ToCall(*submitter)
|
call, err := cur.toCall(*submitter)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Error().Err(err).Msg("toCall failed")
|
log.Error().Err(err).Msg("toCall failed")
|
||||||
http.Error(w, err.Error(), http.StatusBadRequest)
|
http.Error(w, err.Error(), http.StatusBadRequest)
|
||||||
|
|
Loading…
Reference in a new issue