No ice

agent.go

@@ -53,6 +53,7 @@ type Agent struct {
 
 	tieBreaker uint64
 	lite       bool
+	iceNone    bool
 
 	connectionState ConnectionState
 	gatheringState  GatheringState
@@ -283,6 +284,7 @@ func NewAgent(config *AgentConfig) (*Agent, error) { //nolint:gocognit
 		chanCandidatePair: make(chan *CandidatePair),
 		tieBreaker:        globalMathRandomGenerator.Uint64(),
 		lite:              config.Lite,
+		iceNone:           config.ICENone,
 		gatheringState:    GatheringStateNew,
 		connectionState:   ConnectionStateNew,
 		localCandidates:   make(map[NetworkType][]Candidate),
@@ -390,8 +392,11 @@ func (a *Agent) startConnectivityChecks(isControlling bool, remoteUfrag, remoteP
 		return ErrMultipleStart
 	default:
 	}
-	if err := a.SetRemoteCredentials(remoteUfrag, remotePwd); err != nil { //nolint:contextcheck
-		return err
+
+	if !a.iceNone {
+		if err := a.SetRemoteCredentials(remoteUfrag, remotePwd); err != nil { //nolint:contextcheck
+			return err
+		}
 	}
 
 	a.log.Debugf("Started agent: isControlling? %t, remoteUfrag: %q, remotePwd: %q", isControlling, remoteUfrag, remotePwd)
@@ -401,14 +406,18 @@ func (a *Agent) startConnectivityChecks(isControlling bool, remoteUfrag, remoteP
 		agent.remoteUfrag = remoteUfrag
 		agent.remotePwd = remotePwd
 
-		if isControlling {
-			a.selector = &controllingSelector{agent: a, log: a.log}
+		if a.iceNone {
+			a.selector = &iceNoneSelector{agent: a, log: a.log}
 		} else {
-			a.selector = &controlledSelector{agent: a, log: a.log}
-		}
+			if isControlling {
+				a.selector = &controllingSelector{agent: a, log: a.log}
+			} else {
+				a.selector = &controlledSelector{agent: a, log: a.log}
+			}
 
-		if a.lite {
-			a.selector = &liteSelector{pairCandidateSelector: a.selector}
+			if a.lite {
+				a.selector = &liteSelector{pairCandidateSelector: a.selector}
+			}
 		}
 
 		a.selector.Start()

agent_config.go

@@ -113,6 +113,7 @@ type AgentConfig struct {
 
 	// Lite agents do not perform connectivity check and only provide host candidates.
 	Lite bool
+	ICENone bool
 
 	// NAT1To1IPCandidateType is used along with NAT1To1IPs to specify which candidate type
 	// the 1:1 NAT IP addresses should be mapped to.

selection.go

@@ -297,3 +297,37 @@ func (s *liteSelector) ContactCandidates() {
 		v.agent.validateSelectedPair()
 	}
 }
+
+
+type iceNoneSelector struct {
+	agent *Agent
+	log   logging.LeveledLogger
+}
+
+func (s *iceNoneSelector) Start() {
+}
+
+func (s *iceNoneSelector) ContactCandidates() {
+	if s.agent.getSelectedPair() == nil {
+		p := s.agent.getBestAvailableCandidatePair()
+		if p != nil {
+			p.state = CandidatePairStateSucceeded
+			s.agent.setSelectedPair(p)
+		} else {
+			s.log.Debug("Not found best available candidate pair")
+		}
+	}
+}
+
+func (s *iceNoneSelector) PingCandidate(local, remote Candidate) {
+	s.log.Info("ICENone selector does not support ice stun")
+}
+
+func (s *iceNoneSelector) HandleSuccessResponse(m *stun.Message, local, remote Candidate, remoteAddr net.Addr) {
+	s.log.Info("ICENone selector does not support ice stun")
+}
+
+func (s *iceNoneSelector) HandleBindingRequest(m *stun.Message, local, remote Candidate) {
+	s.log.Info("ICENone selector does not support ice stun")
+}
+