+++ /dev/null
-// mmc -- Mattermost client
-// Copyright (C) 2023 Sergey Matveev <stargrave@stargrave.org>
-//
-// 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.
-//
-// 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 <http://www.gnu.org/licenses/>.
-
-package mmc
-
-import (
- "os"
- "strings"
- "time"
-
- "github.com/davecgh/go-spew/spew"
- "github.com/mattermost/mattermost-server/v6/model"
- "go.cypherpunks.ru/recfile"
-)
-
-const (
- PerPage = 100
- OutRec = "out.rec"
- OutRecLock = "out.rec.lock"
- Last = "last"
-)
-
-var SleepTime = 250 * time.Millisecond
-
-type Post struct {
- P *model.Post
- E string
-}
-
-func PostToRec(w *recfile.Writer, users map[string]*model.User, post Post) error {
- _, err := w.RecordStart()
- if err != nil {
- return err
- }
- created := time.Unix(post.P.CreateAt/1000, 0)
- user := users[post.P.UserId]
- sender := "unknown"
- if user != nil {
- sender = user.Username
- }
- fields := []recfile.Field{
- {Name: "Id", Value: post.P.Id},
- {Name: "Created", Value: created.Format("2006-01-02 15:04:05")},
- {Name: "Sender", Value: sender},
- }
- if post.E != model.WebsocketEventPosted {
- fields = append(fields, recfile.Field{Name: "Event", Value: post.E})
- }
- if post.P.RootId != "" {
- fields = append(fields, recfile.Field{Name: "RootId", Value: post.P.RootId})
- }
- if post.P.Metadata != nil {
- for _, fi := range post.P.Metadata.Files {
- fields = append(
- fields,
- recfile.Field{Name: "File", Value: fi.Id},
- recfile.Field{Name: "FileName", Value: fi.Name},
- )
- }
- }
- if _, err = w.WriteFields(fields...); err != nil {
- return err
- }
- _, err = w.WriteFieldMultiline("Text", strings.Split(post.P.Message, "\n"))
- return err
-}
-
-func GetUsers(c *model.Client4, debugFd *os.File) (map[string]*model.User, error) {
- users := make(map[string]*model.User)
- for n := 0; ; n++ {
- time.Sleep(SleepTime)
- page, resp, err := c.GetUsers(n, PerPage, "")
- if err != nil {
- if debugFd != nil {
- spew.Fdump(debugFd, resp)
- }
- return nil, err
- }
- if debugFd != nil {
- spew.Fdump(debugFd, page)
- }
- for _, u := range page {
- users[u.Id] = u
- }
- if len(page) < PerPage {
- break
- }
- }
- return users, nil
-}
-
-func GetEntrypoint() string {
- s := os.Getenv("MMC_ENTRYPOINT")
- if s == "" {
- return "mm.invalid"
- }
- return s
-}