Map participant attributes to SIP headers.

livekit/sip.go

@@ -101,11 +101,27 @@ func (p *SIPOutboundTrunkInfo) AsTrunkInfo() *SIPTrunkInfo {
 	}
 }
 
-func validateHeaders(headers map[string]string) error {
+func validateHeader(header string) error {
+	v := strings.ToLower(header)
+	if !strings.HasPrefix(v, "x-") {
+		return fmt.Errorf("only X-* headers are allowed: %s", header)
+	}
+	return nil
+}
+
+func validateHeaderKeys(headers map[string]string) error {
 	for k := range headers {
-		k = strings.ToLower(k)
-		if !strings.HasPrefix(k, "x-") {
-			return fmt.Errorf("only X-* headers are allowed: %s", k)
+		if err := validateHeader(k); err != nil {
+			return err
+		}
+	}
+	return nil
+}
+
+func validateHeaderValues(headers map[string]string) error {
+	for _, v := range headers {
+		if err := validateHeader(v); err != nil {
+			return err
 		}
 	}
 	return nil
@@ -142,10 +158,13 @@ func (p *SIPInboundTrunkInfo) Validate() error {
 	if len(p.Numbers) == 0 {
 		return errors.New("no trunk numbers specified")
 	}
-	if err := validateHeaders(p.Headers); err != nil {
+	if err := validateHeaderKeys(p.Headers); err != nil {
+		return err
+	}
+	if err := validateHeaderKeys(p.HeadersToAttributes); err != nil {
 		return err
 	}
-	if err := validateHeaders(p.HeadersToAttributes); err != nil {
+	if err := validateHeaderValues(p.AttributesToHeaders); err != nil {
 		return err
 	}
 	return nil
@@ -160,10 +179,13 @@ func (p *SIPOutboundTrunkInfo) Validate() error {
 	} else if strings.Contains(p.Address, "@") {
 		return errors.New("trunk address should be a hostname or IP, not SIP URI")
 	}
-	if err := validateHeaders(p.Headers); err != nil {
+	if err := validateHeaderKeys(p.Headers); err != nil {
+		return err
+	}
+	if err := validateHeaderKeys(p.HeadersToAttributes); err != nil {
 		return err
 	}
-	if err := validateHeaders(p.HeadersToAttributes); err != nil {
+	if err := validateHeaderValues(p.AttributesToHeaders); err != nil {
 		return err
 	}
 	return nil

protobufs/livekit_sip.proto

@@ -190,6 +190,9 @@ message SIPInboundTrunkInfo {
   map<string, string> headers = 9;
   // Map SIP X-* headers from INVITE to SIP participant attributes.
   map<string, string> headers_to_attributes = 10;
+  // Map LiveKit attributes to SIP X-* headers when sending BYE or REFER requests.
+  // Keys are the names of attributes and values are the names of X-* headers they will be mapped to.
+  map<string, string> attributes_to_headers = 14;
 
   // Max time for the caller to wait for track subscription.
   google.protobuf.Duration ringing_timeout = 11;
@@ -232,6 +235,9 @@ message SIPOutboundTrunkInfo {
   // Map SIP X-* headers from 200 OK to SIP participant attributes.
   // Keys are the names of X-* headers and values are the names of attributes they will be mapped to.
   map<string, string> headers_to_attributes = 10;
+  // Map LiveKit attributes to SIP X-* headers when sending BYE or REFER requests.
+  // Keys are the names of attributes and values are the names of X-* headers they will be mapped to.
+  map<string, string> attributes_to_headers = 11;
 }
 
 message GetSIPInboundTrunkRequest {

protobufs/rpc/io.proto

@@ -169,6 +169,9 @@ message EvaluateSIPDispatchRulesResponse {
   // Map SIP X-* headers from INVITE to SIP participant attributes.
   // Keys are the names of X-* headers and values are the names of attributes they will be mapped to.
   map<string, string> headers_to_attributes = 14;
+  // Map LiveKit attributes to SIP X-* headers when sending BYE or REFER requests.
+  // Keys are the names of attributes and values are the names of X-* headers they will be mapped to.
+  map<string, string> attributes_to_headers = 18;
 
   repeated SIPFeature enabled_features = 15;
 
@@ -177,7 +180,7 @@ message EvaluateSIPDispatchRulesResponse {
   // Max call duration.
   google.protobuf.Duration max_call_duration = 17;
 
-  // NEXT ID: 18
+  // NEXT ID: 19
 }
 
 message UpdateSIPCallStateRequest {

protobufs/rpc/sip.proto

@@ -81,6 +81,9 @@ message InternalCreateSIPParticipantRequest {
 
   map<string, string> headers = 21;
   map<string, string> headers_to_attributes = 22;
+  // Map LiveKit attributes to SIP X-* headers when sending BYE or REFER requests.
+  // Keys are the names of attributes and values are the names of X-* headers they will be mapped to.
+  map<string, string> attributes_to_headers = 26;
 
   repeated SIPFeature enabled_features = 25;
 

rpc/sip.go

@@ -73,6 +73,7 @@ func NewCreateSIPParticipantRequest(
 		PlayDialtone:          req.PlayRingtone || req.PlayDialtone,
 		Headers:               trunk.Headers,
 		HeadersToAttributes:   trunk.HeadersToAttributes,
+		AttributesToHeaders:   trunk.AttributesToHeaders,
 		EnabledFeatures:       features,
 		RingingTimeout:        req.RingingTimeout,
 		MaxCallDuration:       req.MaxCallDuration,