feat: fetch summary

Author: polarhive

Dockerfile

@@ -16,6 +16,13 @@ ENV GOARCH=amd64
 # Set working directory
 WORKDIR /app
 
+# Copy go mod files first for better caching
+COPY go.mod go.sum ./
+
+# Download dependencies (cached if go.mod/go.sum unchanged)
+RUN go mod download
+
+# Copy source code
 COPY . .
 
 # Build the application

README.md

@@ -7,10 +7,20 @@
 You can configure HTTP-backed bot commands in `bot.json`. Example commands included:
 
 - `/bot joke` — uses icanhazdadjoke (returns the `joke` field)
-- `/bot quote` — uses quotable.io (returns the `content` field)
 - `/bot catfact` — uses catfact.ninja (returns the `fact` field)
+- `/bot summary` — fetches daily link summaries from linkstash API
 
-Add or change commands in `bot.json` and set `BOT_CONFIG_PATH` in `config.json` if you place it elsewhere. The bot will prefix responses using `BOT_REPLY_LABEL` in `config.json` (defaults to `> `).
+Add or change commands in `bot.json` and set `BOT_CONFIG_PATH` in `config.json` if you place it elsewhere. The bot will prefix responses using `BOT_REPLY_LABEL` in `config.json` (defaults to `[BOT]\n`).
+
+### Room-specific bot configuration
+
+Bot commands are enabled per room via the `allowedCommands` array in `config.json`:
+
+- `"allowedCommands": []` — Enable bot with all commands allowed
+- `"allowedCommands": ["summary", "joke"]` — Enable bot with only specific commands
+- Omit `allowedCommands` — Bot disabled in that room
+
+This allows fine-grained control over which commands are available in each room.
 
 pairs nicely with [lava](https://polarhive.net/lava)
 
@@ -38,7 +48,15 @@ Edit `config.json`:
 - `MATRIX_USER`: Your Matrix user ID
 - `MATRIX_PASSWORD`: Password
 - `MATRIX_RECOVERY_KEY`: For E2EE verification
-- `MATRIX_ROOM_ID`: Array of rooms to watch
+- `MATRIX_ROOM_ID`: Array of rooms to watch, each with:
+  - `id`: Room ID
+  - `comment`: Human-readable name
+  - `hook`: Optional webhook URL for link processing
+  - `key`: Webhook auth key
+  - `sendUser`/`sendTopic`: Whether to include user/topic in webhooks
+  - `allowedCommands`: Array of allowed bot commands (empty = all, omit = disabled)
+- `BOT_REPLY_LABEL`: Bot response prefix (default: `[BOT]\n`)
+- `LINKSTASH_URL`: Base URL for linkstash service (used in summary bot)
 - `MATRIX_DEVICE_NAME`: Device name
 - `DEBUG`: Enable debug logging
 

ash.go

@@ -72,13 +72,13 @@ func (s *MetaSyncStore) SaveRoomAccountData(ctx context.Context, userID id.UserI
 }
 
 type RoomIDEntry struct {
-	ID         string `json:"id"`
-	Comment    string `json:"comment"`
-	Hook       string `json:"hook,omitempty"`
-	Key        string `json:"key,omitempty"`
-	SendUser   bool   `json:"sendUser,omitempty"`
-	SendTopic  bool   `json:"sendTopic,omitempty"`
-	BotEnabled bool   `json:"botEnabled,omitempty"`
+	ID              string   `json:"id"`
+	Comment         string   `json:"comment"`
+	Hook            string   `json:"hook,omitempty"`
+	Key             string   `json:"key,omitempty"`
+	SendUser        bool     `json:"sendUser,omitempty"`
+	SendTopic       bool     `json:"sendTopic,omitempty"`
+	AllowedCommands []string `json:"allowedCommands,omitempty"`
 }
 
 type Config struct {
@@ -92,6 +92,7 @@ type Config struct {
 	LinksPath     string        `json:"LINKS_JSON_PATH"`
 	BotConfigPath string        `json:"BOT_CONFIG_PATH"`
 	BotReplyLabel string        `json:"BOT_REPLY_LABEL,omitempty"`
+	LinkstashURL  string        `json:"LINKSTASH_URL,omitempty"`
 	SyncTimeoutMS int           `json:"SYNC_TIMEOUT_MS"`
 	Debug         bool          `json:"DEBUG"`
 	DeviceName    string        `json:"MATRIX_DEVICE_NAME"`
@@ -669,7 +670,11 @@ func run(ctx context.Context, metaDB *sql.DB, messagesDB *sql.DB, cfg *Config) e
 			return
 		}
 		log.Info().Str("sender", string(ev.Sender)).Str("room", currentRoom.Comment).Msg(truncate(msgData.Msg.Body, 100))
-		if currentRoom.BotEnabled && strings.HasPrefix(msgData.Msg.Body, "/bot") {
+		if cfg.BotReplyLabel != "" && strings.Contains(msgData.Msg.Body, cfg.BotReplyLabel) {
+			log.Debug().Str("label", cfg.BotReplyLabel).Msg("skipped bot processing due to bot reply label")
+			return
+		}
+		if currentRoom.AllowedCommands != nil && strings.HasPrefix(msgData.Msg.Body, "/bot") {
 			select {
 			case <-readyChan:
 			case <-evCtx.Done():
@@ -683,10 +688,12 @@ func run(ctx context.Context, metaDB *sql.DB, messagesDB *sql.DB, cfg *Config) e
 			var body string
 			if cmd == "" || cmd == "hi" {
 				body = "hello"
+			} else if len(currentRoom.AllowedCommands) > 0 && !inSlice(currentRoom.AllowedCommands, cmd) {
+				body = "command not allowed in this room"
 			} else {
 				if botCfg != nil {
 					if cmdCfg, ok := botCfg.Commands[cmd]; ok {
-						resp, err := FetchBotCommand(evCtx, &cmdCfg)
+						resp, err := FetchBotCommand(evCtx, &cmdCfg, cfg.LinkstashURL)
 						if err != nil {
 							log.Error().Err(err).Str("cmd", cmd).Msg("failed to fetch bot command")
 							body = fmt.Sprintf("sorry, couldn't fetch %s right now", cmd)
@@ -813,6 +820,15 @@ func run(ctx context.Context, metaDB *sql.DB, messagesDB *sql.DB, cfg *Config) e
 	return ctx.Err()
 }
 
+func inSlice(slice []string, item string) bool {
+	for _, s := range slice {
+		if s == item {
+			return true
+		}
+	}
+	return false
+}
+
 func truncate(s string, maxLen int) string {
 	if len(s) <= maxLen {
 		return s

bot.go

@@ -42,7 +42,7 @@ func LoadBotConfig(path string) (*BotConfig, error) {
 }
 
 // FetchBotCommand executes the configured command and returns a string to post.
-func FetchBotCommand(ctx context.Context, c *BotCommand) (string, error) {
+func FetchBotCommand(ctx context.Context, c *BotCommand, linkstashURL string) (string, error) {
 	method := c.Method
 	if method == "" {
 		method = "GET"
@@ -82,6 +82,10 @@ func FetchBotCommand(ctx context.Context, c *BotCommand) (string, error) {
 		if s, ok := v.(string); ok {
 			return strings.TrimSpace(s), nil
 		}
+		// Check if it's an array of posts (for summary)
+		if arr, ok := v.([]interface{}); ok {
+			return formatPosts(arr, linkstashURL), nil
+		}
 		// try to marshal the value to string
 		if v != nil {
 			b, _ := json.Marshal(v)
@@ -110,3 +114,24 @@ func extractJSONPath(root interface{}, path string) interface{} {
 	}
 	return cur
 }
+
+// formatPosts formats an array of post objects into a readable string.
+func formatPosts(posts []interface{}, linkstashURL string) string {
+	var sb strings.Builder
+	limit := 5
+	if len(posts) < limit {
+		limit = len(posts)
+	}
+	for i := 0; i < limit; i++ {
+		p := posts[i]
+		if m, ok := p.(map[string]interface{}); ok {
+			title, _ := m["title"].(string)
+			url, _ := m["url"].(string)
+			if title != "" && url != "" {
+				sb.WriteString(fmt.Sprintf("- %s (%s)\n", title, url))
+			}
+		}
+	}
+	sb.WriteString(fmt.Sprintf("\nSee full list: %s", linkstashURL))
+	return sb.String()
+}

bot.json

@@ -13,6 +13,11 @@
             "method": "GET",
             "url": "https://catfact.ninja/fact",
             "json_path": "fact"
+        },
+        "summary": {
+            "method": "GET",
+            "url": "https://linkstash.hsp-ec.xyz/api/summary",
+            "json_path": "summary"
         }
     }
 }

config.json.example

@@ -0,0 +1,26 @@
+{
+    "MATRIX_HOMESERVER": "https://matrix.homeserver.tld",
+    "MATRIX_USER": "@username:homeserver.tld",
+    "MATRIX_PASSWORD": "xxxxx",
+    "MATRIX_RECOVERY_KEY": "xxxxx xxxxx xxxxx xxxxx xxxxx xxxxx xxxxx xxxxx xxxxx xxxxx xxxxx xxxxx",
+    "MATRIX_ROOM_ID": [
+        {
+            "id": "!id:beeper.local",
+            "comment": "room_1",
+            "hook": "https://linkstash.your-domain.tld/api/add",
+            "key": "mentor-here",
+            "sendUser": true,
+            "sendTopic": true,
+            "allowedCommands": []
+        }
+    ],
+    "BOT_REPLY_LABEL": "[BOT] ",
+    "LINKSTASH_URL": "https://linkstash.your-domain.tld",
+    "MATRIX_DEVICE_NAME": "ash",
+    "META_DB_PATH": "./data/meta.db",
+    "DB_PATH": "./data/messages.db",
+    "LINKS_JSON_PATH": "./data/links.json",
+    "BOT_CONFIG_PATH": "./bot.json",
+    "DEBUG": false,
+    "OPT_OUT_TAG": "#private"
+}