feat(endpoint): support accountcode

Account code may be set during endpoint creation. At the moment it
behaves in a similar fashion as the endpoint ID, meaning it is static
and can only be set during creation.

Closes #13.

docs/swagger.yaml

@@ -17,6 +17,8 @@ definitions:
     type: object
   model.Endpoint:
     properties:
+      accountCode:
+        type: string
       codecs:
         items:
           type: string
@@ -62,6 +64,8 @@ definitions:
     type: object
   model.NewEndpoint:
     properties:
+      accountCode:
+        type: string
       codecs:
         items:
           type: string

internal/handler/endpoint_test.go

@@ -119,6 +119,7 @@ func MustCreate(handler http.Handler) func(*testing.T) {
 
 		want := model.Endpoint{
 			Sid:         got.Sid,
+			AccountCode: "zinniaelegans",
 			ID:          endpoint.ID,
 			DisplayName: endpoint.DisplayName,
 			Transport:   endpoint.Transport,

internal/model/endpoint.go

@@ -3,6 +3,7 @@ package model
 type Endpoint struct {
 	Sid         int32    `json:"sid"`
 	ID          string   `json:"id"`
+	AccountCode string   `json:"accountCode"`
 	DisplayName string   `json:"displayName"`
 	Transport   string   `json:"transport"`
 	Context     string   `json:"context"`
@@ -13,6 +14,7 @@ type Endpoint struct {
 
 type NewEndpoint struct {
 	ID          string   `json:"id"`
+	AccountCode string   `json:"accountCode"`
 	Password    string   `json:"password"`
 	Transport   string   `json:"transport,omitempty"`
 	Context     string   `json:"context"`

internal/service/endpoint.go

@@ -1,6 +1,7 @@
 package service
 
 import (
+	"cmp"
 	"context"
 	"crypto/md5"
 	"encoding/hex"
@@ -62,11 +63,12 @@ func (e *EndpointService) Create(ctx context.Context, payload model.NewEndpoint)
 	}
 
 	sid, err := queries.NewEndpoint(ctx, sqlc.NewEndpointParams{
-		ID:        payload.ID,
-		Transport: db.Text(payload.Transport),
-		Context:   db.Text(payload.Context),
-		Allow:     db.Text(strings.Join(payload.Codecs, ",")),
-		Callerid:  db.Text(fmt.Sprintf(`"%s" <%s>`, payload.DisplayName, payload.ID)),
+		ID:          payload.ID,
+		Accountcode: db.Text(cmp.Or(payload.AccountCode, payload.ID)),
+		Transport:   db.Text(payload.Transport),
+		Context:     db.Text(payload.Context),
+		Allow:       db.Text(strings.Join(payload.Codecs, ",")),
+		Callerid:    db.Text(fmt.Sprintf(`"%s" <%s>`, payload.DisplayName, payload.ID)),
 	})
 	if err != nil {
 		return model.Endpoint{}, err
@@ -108,6 +110,7 @@ func (e *EndpointService) Read(ctx context.Context, sid int32) (model.Endpoint,
 	endpoint := model.Endpoint{
 		Sid:         sid,
 		ID:          row.ID,
+		AccountCode: row.Accountcode.String,
 		DisplayName: displayNameFromClid(row.Callerid.String),
 		Transport:   row.Transport.String,
 		Context:     row.Context.String,

queries.sql

@@ -12,9 +12,9 @@ VALUES
 
 -- name: NewEndpoint :one
 INSERT INTO ps_endpoints
-    (id, transport, aors, auth, context, disallow, allow, callerid)
+    (id, transport, aors, auth, context, disallow, allow, callerid, accountcode)
 VALUES
-    ($1, $2, $1, $1, $3, 'all', $4, $5)
+    ($1, $2, $1, $1, $3, 'all', $4, $5, $6)
 RETURNING sid;
 
 -- name: DeleteEndpoint :one
@@ -56,7 +56,7 @@ WHERE
 
 -- name: GetEndpointByID :one
 SELECT
-    pe.id, pe.callerid, pe.context, ee.extension, pe.transport, aor.max_contacts, pe.allow
+    pe.id, pe.accountcode, pe.callerid, pe.context, ee.extension, pe.transport, aor.max_contacts, pe.allow
 FROM
     ps_endpoints pe
 INNER JOIN