2 files changed, 32 insertions(+), 13 deletions(-)

M TODO
M x/mux/commits.go

@@ 4,4 4,4 @@
 * Server greeting
 * 9front/plan9 source searching
 * various cat-v fetches (harmful, page search [get lucky])
-
+* Auto-propaganda processing for images (Black and White -> (9)-ify)

@@ 11,18 11,16 @@ import (
 
 // Listen on the rss feed
 func Listener() {
-	feed, err := rss.Fetch("http://code.9front.org/hg/plan9front/rss-log")
-	if err != nil {
-		fmt.Println("Error in reading RSS feed, see: x/mux/commits.go")
-		fmt.Printf("%s\n\n", err)
-	}
-
-	time.Sleep(1000 * time.Second)
-
-	err = feed.Update()
-	if err != nil {
-		fmt.Println("Error in updating RSS feed, see: x/mux/commits.go")
-		fmt.Printf("%s\n\n", err)
+	for {
+		for _, feed := range Config.Feeds {
+			err := feed.Update()
+
+			if err != nil {
+				fmt.Println("Error in updating RSS feed, see: x/mux/commits.go")
+				fmt.Printf("%s\n\n", err)
+			}
+			time.Sleep(1000 * time.Second)
+		}
 	}
 }
 


@@ 41,3 39,24 @@ func (m *Mux) Commits(ds *discordgo.Session, dm *discordgo.Message, ctx *Context
 	return
 }
 
+// Subscribe to a feed
+func (m *Mux) Subscribe(ds *discordgo.Session, dm *discordgo.Message, ctx *Context) {
+	//http://code.9front.org/hg/plan9front/rss-log
+	// TODO -- check if feed is already subscribed to
+	resp := "```\n"
+	
+	feed, err := rss.Fetch("")
+
+	if err != nil {
+		fmt.Println("Error in reading RSS feed, see: x/mux/commits.go")
+		fmt.Printf("%s\n\n", err)
+	}
+	
+	// Might not be thread safe
+	Config.Feeds = append(Config.Feeds, *feed)
+	
+	resp += "```\n"
+	ds.ChannelMessageSend(dm.ChannelID, resp)
+
+	return
+}