feat(endpoint): add extensions to new endpoints

Extensions may now be assigned to a given endpoint during its creation.

db/migrations/20240730051335_ery_extension.sql

@@ -0,0 +1,12 @@
+-- migrate:up
+ALTER TABLE ps_endpoints ADD COLUMN sid SERIAL PRIMARY KEY;
+
+CREATE TABLE ery_extension (
+    id SERIAL PRIMARY KEY,
+    endpoint_id SERIAL NOT NULL,
+    extension varchar UNIQUE,
+    FOREIGN KEY (endpoint_id) REFERENCES ps_endpoints(sid)
+)
+
+-- migrate:down
+

docs/swagger.yaml

@@ -7,6 +7,8 @@ definitions:
         type: array
       context:
         type: string
+      extension:
+        type: string
       id:
         type: string
       max_contacts:

internal/handler/endpoint.go

@@ -22,10 +22,11 @@ type createEndpointRequest struct {
 	ID          string   `json:"id"`
 	Password    string   `json:"password"`
 	Realm       string   `json:"realm,omitempty"`
-	Transport   string   `json:"transport"`
+	Transport   string   `json:"transport,omitempty"`
 	Context     string   `json:"context"`
 	Codecs      []string `json:"codecs"`
 	MaxContacts int32    `json:"max_contacts,omitempty"`
+	Extension   string   `json:"extension,omitempty"`
 }
 
 func (e *Endpoint) Router() chi.Router {
@@ -63,6 +64,9 @@ func (e *Endpoint) list(w http.ResponseWriter, r *http.Request) {
 		w.WriteHeader(http.StatusInternalServerError)
 		return
 	}
+	if endpoints == nil {
+		endpoints = []sqlc.ListEndpointsRow{}
+	}
 
 	content, err := json.Marshal(endpoints)
 	if err != nil {
@@ -120,7 +124,7 @@ func (e *Endpoint) create(w http.ResponseWriter, r *http.Request) {
 		return
 	}
 
-	err = queries.NewEndpoint(r.Context(), sqlc.NewEndpointParams{
+	sid, err := queries.NewEndpoint(r.Context(), sqlc.NewEndpointParams{
 		ID:        payload.ID,
 		Transport: db.Text(payload.Transport),
 		Context:   db.Text(payload.Context),
@@ -140,6 +144,13 @@ func (e *Endpoint) create(w http.ResponseWriter, r *http.Request) {
 		return
 	}
 
+	if payload.Extension != "" {
+		err = queries.NewExtension(r.Context(), sqlc.NewExtensionParams{
+			EndpointID: sid,
+			Extension:  db.Text(payload.Extension),
+		})
+	}
+
 	err = tx.Commit(r.Context())
 	if err != nil {
 		w.WriteHeader(http.StatusInternalServerError)

queries.sql

@@ -10,11 +10,12 @@ INSERT INTO ps_aors
 VALUES
     ($1, $2);
 
--- name: NewEndpoint :exec
+-- name: NewEndpoint :one
 INSERT INTO ps_endpoints
     (id, transport, aors, auth, context, disallow, allow)
 VALUES
-    ($1, $2, $1, $1, $3, 'all', $4);
+    ($1, $2, $1, $1, $3, 'all', $4)
+RETURNING sid;
 
 -- name: DeleteEndpoint :exec
 DELETE FROM ps_endpoints WHERE id = $1;
@@ -31,3 +32,9 @@ SELECT
 FROM
     ps_endpoints
 LIMIT $1;
+
+-- name: NewExtension :exec
+INSERT INTO ery_extension
+    (endpoint_id, extension)
+VALUES
+    ($1, $2);