// mautrix-whatsapp - A Matrix-WhatsApp puppeting bridge. // 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 config import ( "bytes" "strconv" "strings" "text/template" "github.com/Rhymen/go-whatsapp" "maunium.net/go/mautrix-appservice" "maunium.net/go/mautrix-whatsapp/types" ) type BridgeConfig struct { UsernameTemplate string `yaml:"username_template"` DisplaynameTemplate string `yaml:"displayname_template"` ConnectionTimeout int `yaml:"connection_timeout"` MaxConnectionAttempts int `yaml:"max_connection_attempts"` ConnectionRetryDelay int `yaml:"connection_retry_delay"` ReportConnectionRetry bool `yaml:"report_connection_retry"` ContactWaitDelay int `yaml:"contact_wait_delay"` InitialChatSync int `yaml:"initial_chat_sync_count"` InitialHistoryFill int `yaml:"initial_history_fill_count"` RecoverChatSync int `yaml:"recovery_chat_sync_count"` RecoverHistory bool `yaml:"recovery_history_backfill"` SyncChatMaxAge uint64 `yaml:"sync_max_chat_age"` SyncWithCustomPuppets bool `yaml:"sync_with_custom_puppets"` InviteOwnPuppetForBackfilling bool `yaml:"invite_own_puppet_for_backfilling"` PrivateChatPortalMeta bool `yaml:"private_chat_portal_meta"` CommandPrefix string `yaml:"command_prefix"` Permissions PermissionConfig `yaml:"permissions"` usernameTemplate *template.Template `yaml:"-"` displaynameTemplate *template.Template `yaml:"-"` } func (bc *BridgeConfig) setDefaults() { bc.ConnectionTimeout = 20 bc.MaxConnectionAttempts = 3 bc.ConnectionRetryDelay = -1 bc.ReportConnectionRetry = true bc.ContactWaitDelay = 1 bc.InitialChatSync = 10 bc.InitialHistoryFill = 20 bc.RecoverChatSync = -1 bc.RecoverHistory = true bc.SyncChatMaxAge = 259200 bc.SyncWithCustomPuppets = true bc.InviteOwnPuppetForBackfilling = true bc.PrivateChatPortalMeta = false } type umBridgeConfig BridgeConfig func (bc *BridgeConfig) UnmarshalYAML(unmarshal func(interface{}) error) error { err := unmarshal((*umBridgeConfig)(bc)) if err != nil { return err } bc.usernameTemplate, err = template.New("username").Parse(bc.UsernameTemplate) if err != nil { return err } bc.displaynameTemplate, err = template.New("displayname").Parse(bc.DisplaynameTemplate) return err } type UsernameTemplateArgs struct { UserID string } func (bc BridgeConfig) FormatDisplayname(contact whatsapp.Contact) (string, int8) { var buf bytes.Buffer if index := strings.IndexRune(contact.Jid, '@'); index > 0 { contact.Jid = "+" + contact.Jid[:index] } bc.displaynameTemplate.Execute(&buf, contact) var quality int8 switch { case len(contact.Notify) > 0: quality = 3 case len(contact.Name) > 0 || len(contact.Short) > 0: quality = 2 case len(contact.Jid) > 0: quality = 1 default: quality = 0 } return buf.String(), quality } func (bc BridgeConfig) FormatUsername(userID types.WhatsAppID) string { var buf bytes.Buffer bc.usernameTemplate.Execute(&buf, userID) return buf.String() } type PermissionConfig map[string]PermissionLevel type PermissionLevel int const ( PermissionLevelDefault PermissionLevel = 0 PermissionLevelUser PermissionLevel = 10 PermissionLevelAdmin PermissionLevel = 100 ) func (pc *PermissionConfig) UnmarshalYAML(unmarshal func(interface{}) error) error { rawPC := make(map[string]string) err := unmarshal(&rawPC) if err != nil { return err } if *pc == nil { *pc = make(map[string]PermissionLevel) } for key, value := range rawPC { switch strings.ToLower(value) { case "user": (*pc)[key] = PermissionLevelUser case "admin": (*pc)[key] = PermissionLevelAdmin default: val, err := strconv.Atoi(value) if err != nil { (*pc)[key] = PermissionLevelDefault } else { (*pc)[key] = PermissionLevel(val) } } } return nil } func (pc *PermissionConfig) MarshalYAML() (interface{}, error) { if *pc == nil { return nil, nil } rawPC := make(map[string]string) for key, value := range *pc { switch value { case PermissionLevelUser: rawPC[key] = "user" case PermissionLevelAdmin: rawPC[key] = "admin" default: rawPC[key] = strconv.Itoa(int(value)) } } return rawPC, nil } func (pc PermissionConfig) IsWhitelisted(userID string) bool { return pc.GetPermissionLevel(userID) >= 10 } func (pc PermissionConfig) IsAdmin(userID string) bool { return pc.GetPermissionLevel(userID) >= 100 } func (pc PermissionConfig) GetPermissionLevel(userID string) PermissionLevel { permissions, ok := pc[userID] if ok { return permissions } _, homeserver := appservice.ParseUserID(userID) permissions, ok = pc[homeserver] if len(homeserver) > 0 && ok { return permissions } permissions, ok = pc["*"] if ok { return permissions } return PermissionLevelDefault }