diff options
| author | Maximilian Möhring | 2022-11-15 22:18:54 +0100 |
|---|---|---|
| committer | Maximilian Möhring | 2022-11-15 22:18:54 +0100 |
| commit | 6d03d2dc5f1dd913d247f3d88377cddad6dcd7a7 (patch) | |
| tree | 297260e60d42a6adc0597e1fb68c624569a3bc50 /crawler/post_process.go | |
| parent | c7d1c01fba4c8e622412cc026392684031134207 (diff) | |
| download | alkobote-6d03d2dc5f1dd913d247f3d88377cddad6dcd7a7.tar.gz | |
No external link shorter anymore.
Diffstat (limited to 'crawler/post_process.go')
| -rw-r--r-- | crawler/post_process.go | 39 |
1 files changed, 16 insertions, 23 deletions
diff --git a/crawler/post_process.go b/crawler/post_process.go index 76fc70f..c0c433d 100644 --- a/crawler/post_process.go +++ b/crawler/post_process.go @@ -2,9 +2,6 @@ package main import ( "fmt" - "io/ioutil" - "net/http" - "net/url" log "github.com/sirupsen/logrus" ) @@ -36,6 +33,14 @@ func (app *App) short_url() error { } defer rows.Close() + query = `SELECT DISTINCT url FROM all_view ORDER BY URL ASC` + short_urls := []string{} + + err = app.DB.Select(&short_urls, query) + if err != nil { + return err + } + for rows.Next() { var offer_db Angebot err = rows.StructScan(&offer_db) @@ -43,28 +48,16 @@ func (app *App) short_url() error { return err } - v := url.Values{} - v.Set("key", app.Config.Polr_API_Key) - v.Add("url", offer_db.Url) - polr_url := app.Config.Polr_URL + "?" + v.Encode() - - log.Debug("polr_url: " + polr_url + " ( " + offer_db.Url + " )") - - resp, err := http.Get(polr_url) - if err != nil { - return err - } - defer resp.Body.Close() - - short_url, err := ioutil.ReadAll(resp.Body) - if err != nil { - return err + for { + generated_short_url := getRandomString(5) + if !stringInSlice(generated_short_url, short_urls) { + offer_db.Short_url = generated_short_url + log.Debug("short_url: " + string(generated_short_url) + " ( " + offer_db.Url + " )") + Angebote = append(Angebote, offer_db) + break + } } - offer_db.Short_url = string(short_url) - log.Debug("short_url: " + string(short_url) + " ( " + offer_db.Url + " )") - - Angebote = append(Angebote, offer_db) } for _, offer := range Angebote { |
