diff --git a/.gitignore b/.gitignore index 98e6ef6..d94ab38 100644 --- a/.gitignore +++ b/.gitignore @@ -1 +1,2 @@ *.db +beretta* diff --git a/Justfile b/Justfile deleted file mode 100644 index 6d36b41..0000000 --- a/Justfile +++ /dev/null @@ -1,2 +0,0 @@ -run: - go run src/*.go diff --git a/Makefile b/Makefile new file mode 100644 index 0000000..54bdd5e --- /dev/null +++ b/Makefile @@ -0,0 +1,8 @@ +run: + go run src/*.go + +build: + go build -o beretta src/*.go + +clean: + rm beretta diff --git a/config.json b/beretta.json similarity index 100% rename from config.json rename to beretta.json diff --git a/src/db.go b/src/db.go index dab5118..6c4bf7d 100644 --- a/src/db.go +++ b/src/db.go @@ -1,9 +1,10 @@ package main import ( + "database/sql" _ "embed" _ "github.com/mattn/go-sqlite3" - "database/sql" + "sync" ) //go:embed init.sql @@ -15,11 +16,16 @@ type Db interface { } type SQLiteDb struct { - DB *sql.DB + DB *sql.DB + db_mtx sync.Mutex } -func (s SQLiteDb) CheckAndStore(repo, tag string) (bool, error) { +func (s *SQLiteDb) CheckAndStore(repo, tag string) (bool, error) { var count int + + s.db_mtx.Lock() + defer s.db_mtx.Unlock() + err := s.DB.QueryRow("SELECT COUNT(*) FROM tags WHERE repo = ? AND tag = ?", repo, tag).Scan(&count) if err != nil { return false, err diff --git a/src/main.go b/src/main.go index 1ea0b1f..fa55a33 100644 --- a/src/main.go +++ b/src/main.go @@ -1,34 +1,35 @@ package main import ( + "flag" "log" "math/rand" "time" ) type RepoUpdate struct { - repo RepoConfig + repo Repo Tag string } func notifierThread(c chan RepoUpdate, n Notifier) { update := <-c - log.Printf("New tag stored for %s: %s", update.repo.Repo, update.Tag) + log.Printf("New tag stored for %s: %s", update.repo.IdTuple(), update.Tag) if n.Notify(update.repo, update.Tag) { - log.Printf("Notified for %s/%s: %s", update.repo.Owner, update.repo.Repo, update.Tag) + log.Printf("Notified for %s: %s", update.repo.IdTuple(), update.Tag) } notifierThread(c, n) } -func repoThread(c chan RepoUpdate, repo RepoConfig, avgInterval int, db Db) { - log.Println("Checking", repo.Repo) +func repoThread(c chan RepoUpdate, repo Repo, avgInterval int, db Db) { + log.Println("Checking", repo.IdTuple()) tag, err := repo.GetLatestTag() - isNewVersion, err_2 := db.CheckAndStore(repo.Owner, repo.Repo) + isNewVersion, err_2 := db.CheckAndStore(repo.IdTuple(), tag.Name) if err != nil { - log.Printf("Failed to fetch latest tag for %s: %v", repo.Repo, err) + log.Printf("Failed to fetch latest tag for %s: %v", repo.IdTuple(), err) } else if err_2 != nil { - log.Printf("Failed to store latest tag for %s: %v", repo.Repo, err_2) + log.Printf("Failed to store latest tag for %s: %v", repo.IdTuple(), err_2) } else if isNewVersion { c <- RepoUpdate{repo, tag.Name} } @@ -40,8 +41,14 @@ func repoThread(c chan RepoUpdate, repo RepoConfig, avgInterval int, db Db) { } func main() { + + conf := flag.String("config", "./beretta.json", "The path to the config file") + flag.Parse() + + log.Printf("Using config path: %s", *conf) + // Load configuration - config, err := loadConfig("config.json") + config, err := loadConfig(*conf) if err != nil { log.Fatalf("Failed to load configuration: %v", err) } @@ -58,7 +65,7 @@ func main() { // Spawn a goroutine for each repository for _, repo := range config.Repos { - go repoThread(c, repo, config.Interval, db) + go repoThread(c, repo, config.Interval, &db) } notifierThread(c, notifier) diff --git a/src/repo.go b/src/repo.go index a9d8c6c..8dd4f1f 100644 --- a/src/repo.go +++ b/src/repo.go @@ -9,38 +9,58 @@ import ( type Repo interface { GetLatestTag() (Tag, error) + TagsUrl() string + Owner() string + Name() string + IdTuple() string } // Description of a repository (owner and name) type RepoConfig struct { - Owner string `json:"owner"` - Repo string `json:"repo"` + OwnerName string `json:"owner"` + RepoName string `json:"repo"` } func (r RepoConfig) GetLatestTag() (Tag, error) { - url := fmt.Sprintf("https://api.github.com/repos/%s/%s/tags", r.Owner, r.Repo) + // url := fmt.Sprintf("https://api.github.com/repos/%s/%s/tags", r.Owner, r.Url) - resp, err := http.Get(url) + resp, err := http.Get(r.TagsUrl()) if err != nil { - log.Printf("Failed to fetch releases for %s/%s: %v", r.Owner, r.Repo, err) + log.Printf("Failed to fetch releases for %s: %v", r.TagsUrl(), err) return Tag{}, err } defer resp.Body.Close() if resp.StatusCode != http.StatusOK { - log.Printf("Unexpected response status for %s/%s: %d", r.Owner, r.Repo, resp.StatusCode) + log.Printf("Unexpected response status for %s: %d", r.TagsUrl(), resp.StatusCode) return Tag{}, fmt.Errorf("unexpected response status: %d", resp.StatusCode) } var tags = []Tag{} if err := json.NewDecoder(resp.Body).Decode(&tags); err != nil { - log.Printf("Failed to decode response for %s/%s: %v", r.Owner, r.Repo, err) + log.Printf("Failed to decode response for %s: %v", r.TagsUrl(), err) return Tag{}, err } return tags[0], nil } +func (r RepoConfig) TagsUrl() string { + return fmt.Sprintf("https://api.github.com/repos/%s/%s/tags", r.OwnerName, r.RepoName) +} + +func (r RepoConfig) Owner() string { + return r.OwnerName +} + +func (r RepoConfig) Name() string { + return r.RepoName +} + +func (r RepoConfig) IdTuple() string { + return fmt.Sprintf("%s/%s", r.OwnerName, r.RepoName) +} + type Commit struct { Sha string `json:"sha"` URL string `json:"url"` diff --git a/src/types.go b/src/types.go index 42fefe7..59074f2 100644 --- a/src/types.go +++ b/src/types.go @@ -38,16 +38,16 @@ func loadConfig(file string) (Config, error) { } type Notifier interface { - Notify(repo RepoConfig, tag string) bool + Notify(repo Repo, tag string) bool } type NtfyNotifier struct { Topic string } -func (n NtfyNotifier) Notify(repo RepoConfig, tag string) bool { +func (n NtfyNotifier) Notify(repo Repo, tag string) bool { ntfyURL := fmt.Sprintf("https://ntfy.sh/%s", n.Topic) - message := fmt.Sprintf("New release for %s/%s: %s", repo.Owner, repo.Repo, tag) + message := fmt.Sprintf("New release for %s/%s: %s", repo.Owner(), repo.Name(), tag) _, err := http.Post(ntfyURL, "text/plain", bytes.NewBuffer([]byte(message))) if err != nil {