// gomuks - A terminal Matrix client written in Go. // Copyright (C) 2019 Tulir Asokan // // This program is free software: you can redistribute it and/or modify // it under the terms of the GNU Affero General Public License as published by // the Free Software Foundation, either version 3 of the License, or // (at your option) any later version. // // This program is distributed in the hope that it will be useful, // but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // GNU Affero General Public License for more details. // // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see . package ui import ( "encoding/json" "fmt" "io" "math" "os" "regexp" "runtime" dbg "runtime/debug" "runtime/pprof" "runtime/trace" "strconv" "strings" "time" "github.com/lucasb-eyer/go-colorful" "github.com/russross/blackfriday/v2" "maunium.net/go/mautrix" "maunium.net/go/mautrix/format" "maunium.net/go/gomuks/debug" ) func cmdMe(cmd *Command) { text := strings.Join(cmd.Args, " ") go cmd.Room.SendMessage(mautrix.MsgEmote, text) } // GradientTable from https://github.com/lucasb-eyer/go-colorful/blob/master/doc/gradientgen/gradientgen.go type GradientTable []struct { Col colorful.Color Pos float64 } func (gt GradientTable) GetInterpolatedColorFor(t float64) colorful.Color { for i := 0; i < len(gt)-1; i++ { c1 := gt[i] c2 := gt[i+1] if c1.Pos <= t && t <= c2.Pos { t := (t - c1.Pos) / (c2.Pos - c1.Pos) return c1.Col.BlendHcl(c2.Col, t).Clamped() } } return gt[len(gt)-1].Col } var rainbow = GradientTable{ {colorful.LinearRgb(1, 0, 0), 0 / 11.0}, {colorful.LinearRgb(1, 0.5, 0), 1 / 11.0}, {colorful.LinearRgb(1, 1, 0), 2 / 11.0}, {colorful.LinearRgb(0.5, 1, 0), 3 / 11.0}, {colorful.LinearRgb(0, 1, 0), 4 / 11.0}, {colorful.LinearRgb(0, 1, 0.5), 5 / 11.0}, {colorful.LinearRgb(0, 1, 1), 6 / 11.0}, {colorful.LinearRgb(0, 0.5, 1), 7 / 11.0}, {colorful.LinearRgb(0, 0, 1), 8 / 11.0}, {colorful.LinearRgb(0.5, 0, 1), 9 / 11.0}, {colorful.LinearRgb(1, 0, 1), 10 / 11.0}, {colorful.LinearRgb(1, 0, 0.5), 11 / 11.0}, } // TODO this command definitely belongs in a plugin once we have a plugin system. func makeRainbow(cmd *Command, msgtype mautrix.MessageType) { text := strings.Join(cmd.Args, " ") render := NewRainbowRenderer(blackfriday.NewHTMLRenderer(blackfriday.HTMLRendererParameters{ Flags: blackfriday.UseXHTML, })) htmlBodyBytes := blackfriday.Run([]byte(text), format.Extensions, blackfriday.WithRenderer(render)) htmlBody := strings.TrimRight(string(htmlBodyBytes), "\n") htmlBody = format.AntiParagraphRegex.ReplaceAllString(htmlBody, "$1") text = format.HTMLToText(htmlBody) count := strings.Count(htmlBody, render.ColorID) i := -1 htmlBody = regexp.MustCompile(render.ColorID).ReplaceAllStringFunc(htmlBody, func(match string) string { i++ return rainbow.GetInterpolatedColorFor(float64(i) / float64(count)).Hex() }) go cmd.Room.SendMessageHTML(msgtype, text, htmlBody) } func cmdRainbow(cmd *Command) { makeRainbow(cmd, mautrix.MsgText) } func cmdRainbowMe(cmd *Command) { makeRainbow(cmd, mautrix.MsgEmote) } func cmdNotice(cmd *Command) { go cmd.Room.SendMessage(mautrix.MsgNotice, strings.Join(cmd.Args, " ")) } func cmdAccept(cmd *Command) { room := cmd.Room.MxRoom() if room.SessionMember.Membership != "invite" { cmd.Reply("/accept can only be used in rooms you're invited to") return } _, server, _ := mautrix.ParseUserID(room.SessionMember.Sender) _, err := cmd.Matrix.JoinRoom(room.ID, server) if err != nil { cmd.Reply("Failed to accept invite:", err) } else { cmd.Reply("Successfully accepted invite") } cmd.MainView.UpdateTags(room) go cmd.MainView.LoadHistory(room.ID) } func cmdReject(cmd *Command) { room := cmd.Room.MxRoom() if room.SessionMember.Membership != "invite" { cmd.Reply("/reject can only be used in rooms you're invited to") return } err := cmd.Matrix.LeaveRoom(room.ID) if err != nil { cmd.Reply("Failed to reject invite: %v", err) } else { cmd.Reply("Successfully accepted invite") } } func cmdID(cmd *Command) { cmd.Reply("The internal ID of this room is %s", cmd.Room.MxRoom().ID) } type SelectReason string const ( SelectReply SelectReason = "reply to" SelectReact = "react to" SelectRedact = "redact" SelectDownload = "download" SelectOpen = "open" ) func cmdReply(cmd *Command) { cmd.Room.StartSelecting(SelectReply, strings.Join(cmd.Args, " ")) } func cmdRedact(cmd *Command) { cmd.Room.StartSelecting(SelectRedact, strings.Join(cmd.Args, " ")) } func cmdDownload(cmd *Command) { cmd.Room.StartSelecting(SelectDownload, strings.Join(cmd.Args, " ")) } func cmdOpen(cmd *Command) { cmd.Room.StartSelecting(SelectOpen, strings.Join(cmd.Args, " ")) } func cmdReact(cmd *Command) { if len(cmd.Args) == 0 { cmd.Reply("Usage: /react ") return } cmd.Room.StartSelecting(SelectReact, strings.Join(cmd.Args, " ")) } func cmdTags(cmd *Command) { tags := cmd.Room.MxRoom().RawTags if len(cmd.Args) > 0 && cmd.Args[0] == "--internal" { tags = cmd.Room.MxRoom().Tags() } if len(tags) == 0 { if cmd.Room.MxRoom().IsDirect { cmd.Reply("This room has no tags, but it's marked as a direct chat.") } else { cmd.Reply("This room has no tags.") } return } var resp strings.Builder resp.WriteString("Tags in this room:\n") for _, tag := range tags { if tag.Order != "" { _, _ = fmt.Fprintf(&resp, "%s (order: %s)\n", tag.Tag, tag.Order) } else { _, _ = fmt.Fprintf(&resp, "%s (no order)\n", tag.Tag) } } cmd.Reply(strings.TrimSpace(resp.String())) } func cmdTag(cmd *Command) { if len(cmd.Args) == 0 { cmd.Reply("Usage: /tag [order]") return } order := math.NaN() if len(cmd.Args) > 1 { var err error order, err = strconv.ParseFloat(cmd.Args[1], 64) if err != nil { cmd.Reply("%s is not a valid order: %v", cmd.Args[1], err) return } } var err error if len(cmd.Args) > 2 && cmd.Args[2] == "--reset" { tags := mautrix.Tags{ cmd.Args[0]: {Order: json.Number(fmt.Sprintf("%f", order))}, } for _, tag := range cmd.Room.MxRoom().RawTags { tags[tag.Tag] = mautrix.Tag{Order: tag.Order} } err = cmd.Matrix.Client().SetTags(cmd.Room.MxRoom().ID, tags) } else { err = cmd.Matrix.Client().AddTag(cmd.Room.MxRoom().ID, cmd.Args[0], order) } if err != nil { cmd.Reply("Failed to add tag:", err) } } func cmdUntag(cmd *Command) { if len(cmd.Args) == 0 { cmd.Reply("Usage: /untag ") return } err := cmd.Matrix.Client().RemoveTag(cmd.Room.MxRoom().ID, cmd.Args[0]) if err != nil { cmd.Reply("Failed to remove tag:", err) } } func cmdRoomNick(cmd *Command) { room := cmd.Room.MxRoom() member := room.GetMember(room.SessionUserID) member.Displayname = strings.Join(cmd.Args, " ") _, err := cmd.Matrix.Client().SendStateEvent(room.ID, mautrix.StateMember, room.SessionUserID, member) if err != nil { cmd.Reply("Failed to set room nick:", err) } } func cmdHeapProfile(cmd *Command) { runtime.GC() dbg.FreeOSMemory() memProfile, err := os.Create("gomuks.heap.prof") if err != nil { debug.Print("Failed to open gomuks.heap.prof:", err) return } defer func() { err := memProfile.Close() if err != nil { debug.Print("Failed to close gomuks.heap.prof:", err) } }() if err := pprof.WriteHeapProfile(memProfile); err != nil { debug.Print("Heap profile error:", err) } } func runTimedProfile(cmd *Command, start func(writer io.Writer) error, stop func(), task, file string) { if len(cmd.Args) == 0 { cmd.Reply("Usage: /%s ", cmd.Command) } else if dur, err := strconv.Atoi(cmd.Args[0]); err != nil || dur < 0 { cmd.Reply("Usage: /%s ", cmd.Command) } else if cpuProfile, err := os.Create(file); err != nil { debug.Printf("Failed to open %s: %v", file, err) } else if err = start(cpuProfile); err != nil { _ = cpuProfile.Close() debug.Print(task, "error:", err) } else { cmd.Reply("Started %s for %d seconds", task, dur) go func() { time.Sleep(time.Duration(dur) * time.Second) stop() cmd.Reply("%s finished.", task) err := cpuProfile.Close() if err != nil { debug.Print("Failed to close gomuks.cpu.prof:", err) } }() } } func cmdCPUProfile(cmd *Command) { runTimedProfile(cmd, pprof.StartCPUProfile, pprof.StopCPUProfile, "CPU profiling", "gomuks.cpu.prof") } func cmdTrace(cmd *Command) { runTimedProfile(cmd, trace.Start, trace.Stop, "Call tracing", "gomuks.trace") } func cmdQuit(cmd *Command) { cmd.Gomuks.Stop(true) } func cmdClearCache(cmd *Command) { cmd.Config.Clear() cmd.Gomuks.Stop(false) } func cmdUnknownCommand(cmd *Command) { cmd.Reply("Unknown command \"%s\". Try \"/help\" for help.", cmd.Command) } func cmdHelp(cmd *Command) { cmd.Reply(`# General /help - Show this "temporary" help message. /quit - Quit gomuks. /clearcache - Clear cache and quit gomuks. /logout - Log out of Matrix. /toggle - Temporary command to toggle various UI features. Things: rooms, users, baremessages, images, typingnotif # Sending special messages /me - Send an emote message. /notice - Send a notice (generally used for bot messages). /rainbow - Send rainbow text (markdown not supported). /rainbowme - Send rainbow text in an emote. /reply [text] - Reply to the selected message. /react - React to the selected message. /redact [reason] - Redact the selected message. # Rooms /pm <...> - Create a private chat with the given user(s). /create [room name] - Create a room. /join [server] - Join a room. /accept - Accept the invite. /reject - Reject the invite. /invite - Invite the given user to the room. /roomnick - Change your per-room displayname. /tag - Add the room to . /untag - Remove the room from . /tags - List the tags the room is in. /leave - Leave the current room. /kick [reason] - Kick a user. /ban [reason] - Ban a user. /unban - Unban a user.`) } func cmdLeave(cmd *Command) { err := cmd.Matrix.LeaveRoom(cmd.Room.MxRoom().ID) debug.Print("Leave room error:", err) if err == nil { cmd.MainView.RemoveRoom(cmd.Room.MxRoom()) } } func cmdInvite(cmd *Command) { if len(cmd.Args) != 1 { cmd.Reply("Usage: /invite ") return } _, err := cmd.Matrix.Client().InviteUser(cmd.Room.MxRoom().ID, &mautrix.ReqInviteUser{UserID: cmd.Args[0]}) if err != nil { debug.Print("Error in invite call:", err) cmd.Reply("Failed to invite user: %v", err) } } func cmdBan(cmd *Command) { if len(cmd.Args) < 1 { cmd.Reply("Usage: /ban [reason]") return } reason := "you are the weakest link, goodbye!" if len(cmd.Args) >= 2 { reason = strings.Join(cmd.Args[1:], " ") } _, err := cmd.Matrix.Client().BanUser(cmd.Room.MxRoom().ID, &mautrix.ReqBanUser{Reason: reason, UserID: cmd.Args[0]}) if err != nil { debug.Print("Error in ban call:", err) cmd.Reply("Failed to ban user: %v", err) } } func cmdUnban(cmd *Command) { if len(cmd.Args) != 1 { cmd.Reply("Usage: /unban ") return } _, err := cmd.Matrix.Client().UnbanUser(cmd.Room.MxRoom().ID, &mautrix.ReqUnbanUser{UserID: cmd.Args[0]}) if err != nil { debug.Print("Error in unban call:", err) cmd.Reply("Failed to unban user: %v", err) } } func cmdKick(cmd *Command) { if len(cmd.Args) < 1 { cmd.Reply("Usage: /kick [reason]") return } reason := "you are the weakest link, goodbye!" if len(cmd.Args) >= 2 { reason = strings.Join(cmd.Args[1:], " ") } _, err := cmd.Matrix.Client().KickUser(cmd.Room.MxRoom().ID, &mautrix.ReqKickUser{Reason: reason, UserID: cmd.Args[0]}) if err != nil { debug.Print("Error in kick call:", err) debug.Print("Failed to kick user:", err) } } func cmdCreateRoom(cmd *Command) { req := &mautrix.ReqCreateRoom{} if len(cmd.Args) > 0 { req.Name = strings.Join(cmd.Args, " ") } room, err := cmd.Matrix.CreateRoom(req) if err != nil { cmd.Reply("Failed to create room:", err) return } cmd.MainView.SwitchRoom("", room) } func cmdPrivateMessage(cmd *Command) { if len(cmd.Args) == 0 { cmd.Reply("Usage: /pm [more user ids...]") } req := &mautrix.ReqCreateRoom{ Preset: "trusted_private_chat", Invite: cmd.Args, } room, err := cmd.Matrix.CreateRoom(req) if err != nil { cmd.Reply("Failed to create room:", err) return } cmd.MainView.SwitchRoom("", room) } func cmdJoin(cmd *Command) { if len(cmd.Args) == 0 { cmd.Reply("Usage: /join ") return } identifer := cmd.Args[0] server := "" if len(cmd.Args) > 1 { server = cmd.Args[1] } room, err := cmd.Matrix.JoinRoom(identifer, server) debug.Print("Join room error:", err) if err == nil { cmd.MainView.AddRoom(room) } } func cmdMSendEvent(cmd *Command) { if len(cmd.Args) < 2 { cmd.Reply("Usage: /msend ") return } cmd.Args = append([]string{cmd.Room.MxRoom().ID}, cmd.Args...) cmdSendEvent(cmd) } func cmdSendEvent(cmd *Command) { if len(cmd.Args) < 3 { cmd.Reply("Usage: /send ") return } roomID := cmd.Args[0] eventType := mautrix.NewEventType(cmd.Args[1]) rawContent := strings.Join(cmd.Args[2:], " ") var content interface{} err := json.Unmarshal([]byte(rawContent), &content) debug.Print(err) if err != nil { cmd.Reply("Failed to parse content: %v", err) return } debug.Print("Sending event to", roomID, eventType, content) resp, err := cmd.Matrix.Client().SendMessageEvent(roomID, eventType, content) debug.Print(resp, err) if err != nil { cmd.Reply("Error from server: %v", err) } else { cmd.Reply("Event sent, ID: %s", resp.EventID) } } func cmdMSetState(cmd *Command) { if len(cmd.Args) < 2 { cmd.Reply("Usage: /msetstate ") return } cmd.Args = append([]string{cmd.Room.MxRoom().ID}, cmd.Args...) cmdSetState(cmd) } func cmdSetState(cmd *Command) { if len(cmd.Args) < 4 { cmd.Reply("Usage: /setstate ") return } roomID := cmd.Args[0] eventType := mautrix.NewEventType(cmd.Args[1]) stateKey := cmd.Args[2] if stateKey == "-" { stateKey = "" } rawContent := strings.Join(cmd.Args[3:], " ") var content interface{} err := json.Unmarshal([]byte(rawContent), &content) if err != nil { cmd.Reply("Failed to parse content: %v", err) return } debug.Print("Sending state event to", roomID, eventType, stateKey, content) resp, err := cmd.Matrix.Client().SendStateEvent(roomID, eventType, stateKey, content) if err != nil { cmd.Reply("Error from server: %v", err) } else { cmd.Reply("State event sent, ID: %s", resp.EventID) } } func cmdToggle(cmd *Command) { if len(cmd.Args) == 0 { cmd.Reply("Usage: /toggle ") return } switch cmd.Args[0] { case "rooms": cmd.Config.Preferences.HideRoomList = !cmd.Config.Preferences.HideRoomList case "users": cmd.Config.Preferences.HideUserList = !cmd.Config.Preferences.HideUserList case "baremessages": cmd.Config.Preferences.BareMessageView = !cmd.Config.Preferences.BareMessageView case "images": cmd.Config.Preferences.DisableImages = !cmd.Config.Preferences.DisableImages case "typingnotif": cmd.Config.Preferences.DisableTypingNotifs = !cmd.Config.Preferences.DisableTypingNotifs case "emojis": cmd.Config.Preferences.DisableEmojis = !cmd.Config.Preferences.DisableEmojis case "html": cmd.Config.Preferences.DisableHTML = !cmd.Config.Preferences.DisableHTML if cmd.Config.Preferences.DisableHTML { cmd.Reply("Disabled HTML input") } else { cmd.Reply("Enabled HTML input") } case "markdown": cmd.Config.Preferences.DisableMarkdown = !cmd.Config.Preferences.DisableMarkdown if cmd.Config.Preferences.DisableMarkdown { cmd.Reply("Disabled Markdown input") } else { cmd.Reply("Enabled Markdown input") } case "downloads": cmd.Config.Preferences.DisableDownloads = !cmd.Config.Preferences.DisableDownloads if cmd.Config.Preferences.DisableDownloads { cmd.Reply("Disabled Downloads input") } else { cmd.Reply("Enabled Downloads input") } default: cmd.Reply("Usage: /toggle ") return } // is there a reason this is called twice? // cmd.UI.Render() cmd.UI.Render() go cmd.Matrix.SendPreferencesToMatrix() } func cmdLogout(cmd *Command) { cmd.Matrix.Logout() }