mpd-stats: pass database path to the scrobbler

When creating a scrobbler, we provide the path to the database. The
scrobbler then get a handler to the database.

When a new record is created, we persist it to the database using the
`save` function.

1 files changed, 27 insertions, 4 deletions

diff --git a/internal/scrobbler/scrobbler.go b/internal/scrobbler/scrobbler.go
index 061b909..a31569e 100644
--- a/internal/scrobbler/scrobbler.go
+++ b/internal/scrobbler/scrobbler.go
@@ -1,6 +1,7 @@
 package scrobbler
 
 import (
+	"database/sql"
 	"log"
 
 	"golang.fcuny.net/mpd-stats/internal/mpd"
@@ -8,17 +9,25 @@ import (
 
 type Scrobbler struct {
 	player *mpd.Player
+	db     *sql.DB
 }
 
-func NewScrobbler(net string, addr string) (*Scrobbler, error) {
-	var s Scrobbler
-
+func NewScrobbler(net string, addr string, dbpath string) (*Scrobbler, error) {
 	p, err := mpd.NewPlayer(net, addr)
 	if err != nil {
 		return nil, err
 	}
 
-	s.player = p
+	db, err := opendatabase(dbpath)
+	if err != nil {
+		return nil, err
+	}
+
+	s := Scrobbler{
+		player: p,
+		db:     db,
+	}
+
 	return &s, nil
 }
 
@@ -47,6 +56,7 @@ func (s *Scrobbler) Run() error {
 				}
 				log.Printf("we're playing %s/%s/%s [%s]\n", currentRecord.Artist, currentRecord.Album, currentRecord.Title, currentRecord.Duration)
 				previousRecord = currentRecord
+				s.save(currentRecord)
 				continue
 			}
 
@@ -60,7 +70,20 @@ func (s *Scrobbler) Run() error {
 			if currentRecord.Id != previousRecord.Id {
 				log.Printf("we're playing %s/%s/%s [%s]\n", currentRecord.Artist, currentRecord.Album, currentRecord.Title, currentRecord.Duration)
 				previousRecord = currentRecord
+				s.save(currentRecord)
 			}
 		}
 	}
 }
+
+func (s *Scrobbler) save(record *Record) error {
+	_, err := s.db.Exec("insert into records(id, title, artist, album, duration, time) values(?, ?, ?, ?, ?, ?)",
+		record.Id,
+		record.Title,
+		record.Artist,
+		record.Album,
+		int(record.Duration.Seconds()),
+		record.Timestamp,
+	)
+	return err
+}