mirror of https://github.com/vbatts/sl-feeds.git
74 lines
1.9 KiB
Go
74 lines
1.9 KiB
Go
package fetch
|
|
|
|
import (
|
|
"fmt"
|
|
"net/http"
|
|
"time"
|
|
|
|
"github.com/vbatts/sl-feeds/changelog"
|
|
)
|
|
|
|
// Repo represents a remote slackware software repo
|
|
type Repo struct {
|
|
URL string
|
|
Release string
|
|
}
|
|
|
|
func (r Repo) head(file string) (*http.Response, error) {
|
|
return http.Head(r.URL + "/" + r.Release + "/" + file)
|
|
}
|
|
func (r Repo) get(file string) (*http.Response, error) {
|
|
return http.Get(r.URL + "/" + r.Release + "/" + file)
|
|
}
|
|
|
|
// NewerChangeLog checks the last-modified time of the remote ChangeLog.txt and
|
|
// only fetches it if the remote is newer than the provided time.
|
|
func (r Repo) NewerChangeLog(than time.Time) (e []changelog.Entry, mtime time.Time, err error) {
|
|
resp, err := r.head("ChangeLog.txt")
|
|
if err != nil {
|
|
return nil, time.Unix(0, 0), err
|
|
}
|
|
defer resp.Body.Close()
|
|
|
|
if resp.StatusCode != http.StatusOK {
|
|
return nil, time.Unix(0, 0), fmt.Errorf("%d status from %s", resp.StatusCode, resp.Request.URL)
|
|
}
|
|
|
|
mtime, err = http.ParseTime(resp.Header.Get("last-modified"))
|
|
if err != nil {
|
|
return nil, time.Unix(0, 0), err
|
|
}
|
|
|
|
if mtime.After(than) {
|
|
return r.ChangeLog()
|
|
}
|
|
return nil, time.Unix(0, 0), ErrNotNewer
|
|
}
|
|
|
|
// ErrNotNewer is a status error usage to indicate that the remote file is not newer
|
|
var ErrNotNewer = fmt.Errorf("Remote file is not newer than provided time")
|
|
|
|
// ChangeLog fetches the ChangeLog.txt for this remote Repo, along with the
|
|
// last-modified (for comparisons).
|
|
func (r Repo) ChangeLog() (e []changelog.Entry, mtime time.Time, err error) {
|
|
resp, err := r.get("ChangeLog.txt")
|
|
if err != nil {
|
|
return nil, time.Unix(0, 0), err
|
|
}
|
|
defer resp.Body.Close()
|
|
if resp.StatusCode != http.StatusOK {
|
|
return nil, time.Unix(0, 0), fmt.Errorf("%d status from %s", resp.StatusCode, resp.Request.URL)
|
|
}
|
|
|
|
mtime, err = http.ParseTime(resp.Header.Get("last-modified"))
|
|
if err != nil {
|
|
return nil, time.Unix(0, 0), err
|
|
}
|
|
|
|
e, err = changelog.Parse(resp.Body)
|
|
if err != nil {
|
|
return nil, mtime, err
|
|
}
|
|
return e, mtime, nil
|
|
}
|