added caching responses into worker;

.gitignore

@@ -2,5 +2,7 @@
 /go.sum
 /main
 
+/cache/*.*
+!/cache/.gitkeep
 /storage/*.json
 !/storage/*.dist.json

pkg/storage/cache.go

@@ -1,6 +1,11 @@
 package storage
 
-import "github.com/pkg/errors"
+import (
+	"path"
+
+	"github.com/jacekk/dead-simple-proxy-server/pkg/helpers"
+	"github.com/pkg/errors"
+)
 
 // GetCached -
 func GetCached() (Items, error) {
@@ -18,3 +23,10 @@ func GetCached() (Items, error) {
 
 	return cached, nil
 }
+
+// SlugCachePath -
+func SlugCachePath(slug string) string {
+	baseDir := helpers.GetProjectDir()
+
+	return path.Join(baseDir, "cache", slug+".txt")
+}

pkg/worker/cache.go

@@ -2,6 +2,8 @@ package worker
 
 import (
 	"math/rand"
+	"net/http"
+	"os"
 	"time"
 
 	"github.com/jacekk/dead-simple-proxy-server/pkg/storage"
@@ -35,7 +37,26 @@ func refreshRandomCache(loggr *loggerImpl) error {
 }
 
 func refreshConfigItem(loggr *loggerImpl, item storage.Item) error {
-	loggr.Info("Refreshing '%s'", item.ID)
+	loggr.Info("Refreshing '%s' ...", item.ID)
+	resp, err := http.Get(item.URL)
+	if err != nil {
+		return errors.Wrap(err, "failed making get request")
+	}
+	defer resp.Body.Close()
+
+	cachePath := storage.SlugCachePath(item.ID)
+	cache, err := os.Create(cachePath)
+	if err != nil {
+		return errors.Wrap(err, "failed creating cache")
+	}
+	defer cache.Close()
+
+	err = resp.Write(cache)
+	if err != nil {
+		return errors.Wrap(err, "failed writing to cache")
+	}
+
+	loggr.Info("Refreshed '%s'", item.ID)
 
 	return nil
 }