Remove unnecessary incoming channel

License: MIT
Signed-off-by: Michael Avila <davidmichaelavila@gmail.com>

provider/provider.go

@@ -24,8 +24,6 @@ type Provider struct {
 	ctx context.Context
 	lock sync.Mutex
 
-	// CIDs to provide
-	incoming chan cid.Cid
 	// CIDs we are working on providing now
 	outgoing chan cid.Cid
 	// strategy for deciding which CIDs, given a CID, should be provided
@@ -47,13 +45,11 @@ func NewProvider(ctx context.Context, strategy Strategy, tracker *Tracker, queue
 		contentRouting: contentRouting,
 		lock:           sync.Mutex{},
 		outgoing:       make(chan cid.Cid),
-		incoming:       make(chan cid.Cid),
 	}
 }
 
 // Start workers to handle provide requests.
 func (p *Provider) Run() {
-	go p.handleIncoming()
 	go p.handlePopulateOutgoing()
 	go p.handleOutgoing()
 }
@@ -63,7 +59,17 @@ func (p *Provider) Provide(root cid.Cid) {
 	cids := p.strategy(p.ctx, root)
 	go func() {
 		for cid := range cids {
-			p.incoming <- cid
+			isTracking, err := p.tracker.IsTracking(cid)
+			if err != nil {
+				log.Warning("Unable to check provider tracking on incoming: %s", err)
+				continue
+			}
+
+			if !isTracking {
+				p.lock.Lock()
+				p.queue.Enqueue(cid)
+				p.lock.Unlock()
+			}
 		}
 	}()
 }
@@ -83,28 +89,6 @@ func (p *Provider) announce(cid cid.Cid) error {
 	return nil
 }
 
-// Move CIDs from the incoming channel to the providing queue
-func (p *Provider) handleIncoming() {
-	for {
-		select {
-		case key := <-p.incoming:
-			isTracking, err := p.tracker.IsTracking(key)
-			if err != nil {
-				log.Warning("Unable to check provider tracking on incoming: %s", err)
-				continue
-			}
-
-			if !isTracking {
-				p.lock.Lock()
-				p.queue.Enqueue(key)
-				p.lock.Unlock()
-			}
-		case <-p.ctx.Done():
-			return
-		}
-	}
-}
-
 // Move CIDs from the providing queue to the outgoing channel
 func (p *Provider) handlePopulateOutgoing() {
 	for {