Signalling refactor (#701)

* v2 WIP

* add attributes

* WIP

* envelope as one of

* WIP

* starting signalling interfaces

* signal interface

* clean up

* clean up

* clean up

* deps

* delete unused

* staticheck config

Author: boks1971

.github/workflows/buildtest.yaml

@@ -68,6 +68,7 @@ jobs:
       - name: Static Check
         uses: dominikh/staticcheck-action@master
         with:
+          checks: '["all", "-ST1000", "-ST1003", "-ST1020", "-ST1021", "-ST1022", "-SA1019"]'
           install-go: false
 
       - name: Mage Test

agent_client.go

@@ -9,6 +9,7 @@ import (
 	"github.com/twitchtv/twirp"
 
 	"github.com/livekit/protocol/livekit"
+	"github.com/livekit/server-sdk-go/v2/signalling"
 )
 
 type AgentClient struct {
@@ -19,7 +20,7 @@ type AgentClient struct {
 func NewAgentClient(url string, apiKey string, apiSecret string, opts ...twirp.ClientOption) (*AgentClient, error) {
 	serverUrl := os.Getenv("LK_AGENTS_URL")
 	if serverUrl == "" {
-		url = ToHttpURL(url)
+		url = signalling.ToHttpURL(url)
 		pattern := `^https?://[^.]+\.`
 		re := regexp.MustCompile(pattern)
 		serverUrl = re.ReplaceAllString(url, "https://agents.")

agent_dispatch_client.go

@@ -21,6 +21,7 @@ import (
 	"github.com/twitchtv/twirp"
 
 	"github.com/livekit/protocol/livekit"
+	"github.com/livekit/server-sdk-go/v2/signalling"
 )
 
 type AgentDispatchClient struct {
@@ -29,7 +30,7 @@ type AgentDispatchClient struct {
 }
 
 func NewAgentDispatchServiceClient(url string, apiKey string, secretKey string, opts ...twirp.ClientOption) *AgentDispatchClient {
-	url = ToHttpURL(url)
+	url = signalling.ToHttpURL(url)
 	client := livekit.NewAgentDispatchServiceProtobufClient(url, &http.Client{}, opts...)
 
 	return &AgentDispatchClient{

auth.go

@@ -16,11 +16,11 @@ package lksdk
 
 import (
 	"context"
-	"net/http"
 
 	"github.com/twitchtv/twirp"
 
 	"github.com/livekit/protocol/auth"
+	"github.com/livekit/server-sdk-go/v2/signalling"
 )
 
 type authBase struct {
@@ -61,11 +61,5 @@ func (b authBase) withAuth(ctx context.Context, opt authOption, options ...authO
 		return nil, err
 	}
 
-	return twirp.WithHTTPRequestHeaders(ctx, newHeaderWithToken(token))
-}
-
-func newHeaderWithToken(token string) http.Header {
-	header := make(http.Header)
-	header.Set("Authorization", "Bearer "+token)
-	return header
+	return twirp.WithHTTPRequestHeaders(ctx, signalling.NewHeaderWithToken(token))
 }

egressclient.go

@@ -22,6 +22,7 @@ import (
 
 	"github.com/livekit/protocol/livekit"
 	"github.com/livekit/protocol/utils/xtwirp"
+	"github.com/livekit/server-sdk-go/v2/signalling"
 )
 
 type EgressClient struct {
@@ -31,7 +32,7 @@ type EgressClient struct {
 
 func NewEgressClient(url string, apiKey string, secretKey string, opts ...twirp.ClientOption) *EgressClient {
 	opts = append(opts, xtwirp.DefaultClientOptions()...)
-	url = ToHttpURL(url)
+	url = signalling.ToHttpURL(url)
 	client := livekit.NewEgressProtobufClient(url, &http.Client{}, opts...)
 	return &EgressClient{
 		egressClient: client,