pkg/client/client.go

@@ -194,15 +194,3 @@ func (c *Client) addToCache(longURL, shortID string) {
 		})
 	}()
 }
-
-func (c *Client) remFromCache(longURL string) {
-	c.cacheMap.Remove(longURL)
-
-	// Async write to BoltDB
-	go func() {
-		_ = c.db.Update(func(tx *bolt.Tx) error {
-			b := tx.Bucket([]byte("url_cache"))
-			return b.Delete([]byte(longURL))
-		})
-	}()
-}

pkg/client/store.go

@@ -96,8 +96,7 @@ func (c *Client) enqueueJob(job shortenJob) {
 	select {
 	case c.retryQueue <- job:
 	default:
-		log.Println("Retry queue full, dropping job and removing from caches:", job.ID, job.URL)
-		go c.remFromCache(job.URL)
+		log.Println("Retry queue full, dropping job:", job.ID)
 	}
 }