@@ -10,4 +10,7 @@ gopkg.in/irc.v3 v3.1.4
 	gopkg.in/yaml.v3 v3.0.0-20210107192922-496545a6307b
 )
 
-require github.com/zsefvlol/timezonemapper v1.0.0
+require (
+	github.com/joho/godotenv v1.4.0
+	github.com/zsefvlol/timezonemapper v1.0.0
+)

@@ -42,6 +42,8 @@ github.com/google/go-cmp v0.3.0/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU=
 github.com/google/go-cmp v0.5.4/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
 github.com/hashicorp/hcl v1.0.0/go.mod h1:E5yfLk+7swimpb2L/Alb/PJmXilQ/rhwaUYs4T20WEQ=
 github.com/inconshreveable/mousetrap v1.0.0/go.mod h1:PxqpIevigyE2G7u3NXJIT2ANytuPF1OarO4DADm73n8=
+github.com/joho/godotenv v1.4.0 h1:3l4+N6zfMWnkbPEXKng2o2/MR5mSwTrBih4ZEkkz1lg=
+github.com/joho/godotenv v1.4.0/go.mod h1:f4LDr5Voq0i2e/R5DDNOoa2zzDfwtkZa6DnEwAbqwq4=
 github.com/kisielk/errcheck v1.5.0/go.mod h1:pFxgyoBC7bSaBwPgfKdkLd5X25qrDl4LWUI2bnpBCr8=
 github.com/kisielk/gotool v1.0.0/go.mod h1:XhKaO+MFFWcvkIS/tQcRk01m1F5IRFswLeQ+oQHNcck=
 github.com/klauspost/compress v1.12.3 h1:G5AfA94pHPysR56qqrkO2pxEexdDzrpFJ6yt/VqWxVU=

@@ -0,0 +1,56 @@
+package plugins
+
+import (
+	"strings"
+
+	"git.icyphox.sh/paprika/plugins/lastfm"
+	"github.com/dgraph-io/badger/v3"
+	"gopkg.in/irc.v3"
+)
+
+func init() {
+	Register(LastFM{})
+}
+
+type LastFM struct{}
+
+func (LastFM) Triggers() []string {
+	return []string{
+		".lfm",
+		".np",
+	}
+}
+
+func (LastFM) Execute(m *irc.Message) (string, error) {
+	parts := strings.SplitN(m.Trailing(), " ", 2)
+	trigger := parts[0]
+
+	switch trigger {
+	case ".lfm":
+		if len(parts) == 2 {
+			arg := parts[1]
+			err := lastfm.Setup(arg, m.Prefix.Name)
+			if err != nil {
+				return "Database error", err
+			}
+			return "Successfully set Last.fm username", nil
+		} else {
+			return "usage: .lfm <username>", nil
+		}
+	case ".np":
+		user, err := lastfm.GetUser(m.Prefix.Name)
+		if err == badger.ErrKeyNotFound {
+			return "User not found. Set it using '.lfm <username>'", nil
+		} else if err != nil {
+			return "Database error", err
+		}
+
+		np, err := lastfm.NowPlaying(user)
+		if err != nil {
+			return "Listenbrainz error", err
+		}
+		return np, nil
+	}
+
+	panic("Unreachable!")
+}

@@ -0,0 +1,26 @@
+package lastfm
+
+import (
+	"fmt"
+
+	"git.icyphox.sh/paprika/database"
+)
+
+// Store the Last.fm username against the nick.
+func Setup(lfmUser, nick string) error {
+	err := database.DB.Set(
+		[]byte(fmt.Sprintf("lfm/%s", nick)),
+		[]byte(lfmUser),
+	)
+	return err
+}
+
+// Gets the Last.fm username from the DB.
+func GetUser(nick string) (string, error) {
+	nick = fmt.Sprintf("lfm/%s", nick)
+	user, err := database.DB.Get([]byte(nick))
+	if err != nil {
+		return "", err
+	}
+	return string(user), nil
+}

@@ -0,0 +1,81 @@
+package lastfm
+
+import (
+	"encoding/json"
+	"fmt"
+	"net/http"
+	"time"
+
+	"git.icyphox.sh/paprika/config"
+	"github.com/dustin/go-humanize"
+)
+
+type ListenInfo struct {
+	RecentTracks struct {
+		Track []struct {
+			Artist struct {
+				Text string `json:"#text"`
+			} `json:"artist"`
+			Album struct {
+				Text string `json:"#text"`
+			} `json:"album"`
+			Name string `json:"name"`
+			Date struct {
+				UnixTimestamp int `json:"uts"`
+			} `json:"date"`
+			Attr struct {
+				NowPlaying string `json:"nowplaying"`
+			} `json:"@attr"`
+		} `json:"track"`
+	} `json:"recenttracks"`
+}
+
+func getRecentTracks(url string) (*ListenInfo, error) {
+	li := ListenInfo{}
+	fmt.Println(url)
+	r, err := http.Get(url)
+	if err != nil {
+		return nil, err
+	} else if r.StatusCode != 200 {
+		return nil, fmt.Errorf("non-200 response from Last.fm")
+	}
+
+	json.NewDecoder(r.Body).Decode(&li)
+	defer r.Body.Close()
+
+	return &li, err
+}
+
+func NowPlaying(user string) (string, error) {
+	key := config.C.ApiKeys["lastfm-key"]
+	url := fmt.Sprintf(
+		"https://ws.audioscrobbler.com/2.0/?method=user.getrecenttracks&user=%s&api_key=%s&format=json",
+		user,
+		key,
+	)
+
+	rt, err := getRecentTracks(url)
+	if err != nil {
+		return "", err
+	}
+
+	track := rt.RecentTracks.Track[0]
+	if rt.RecentTracks.Track[0].Attr.NowPlaying == "true" {
+		return fmt.Sprintf(
+			"%s is currently listening to \"%s\" by \x02%s\x02, from the album \x02%s\x02",
+			user,
+			track.Name,
+			track.Artist.Text,
+			track.Album.Text,
+		), nil
+	} else {
+		return fmt.Sprintf(
+			"%s listened to \"%s\" by \x02%s\x02, from the album \x02%s\x02, %s",
+			user,
+			track.Name,
+			track.Artist.Text,
+			track.Album.Text,
+			humanize.Time(time.Unix(int64(track.Date.UnixTimestamp), 0)),
+		), nil
+	}
+}

@@ -16,7 +16,9 @@
 type Listenbrainz struct{}
 
 func (Listenbrainz) Triggers() []string {
-	return []string{".np", ".lbz"}
+	// TODO: removing .np from here until we figure out how
+	// it can co-exist with Last.fm
+	return []string{".lbz"}
 }
 
 func (Listenbrainz) Execute(m *irc.Message) (string, error) {