mirror of
https://github.com/42wim/matterbridge.git
synced 2024-11-22 02:32:02 -08:00
1bb39eba87
TengoModifyMessage allows you to specify the location of a tengo (https://github.com/d5/tengo/) script. This script will receive every incoming message and can be used to modify the Username and the Text of that message. The script will have the following global variables: to modify: msgUsername and msgText to read: msgChannel and msgAccount The script is reloaded on every message, so you can modify the script on the fly. Example script can be found in https://github.com/42wim/matterbridge/tree/master/gateway/bench.tengo and https://github.com/42wim/matterbridge/tree/master/contrib/example.tengo The example below will check if the text contains blah and if so, it'll replace the text and the username of that message. text := import("text") if text.re_match("blah",msgText) { msgText="replaced by this" msgUsername="fakeuser" } More information about tengo on: https://github.com/d5/tengo/blob/master/docs/tutorial.md and https://github.com/d5/tengo/blob/master/docs/stdlib.md
438 lines
15 KiB
Go
438 lines
15 KiB
Go
package stdlib
|
|
|
|
import (
|
|
"fmt"
|
|
"io"
|
|
"io/ioutil"
|
|
"os"
|
|
"os/exec"
|
|
|
|
"github.com/d5/tengo/objects"
|
|
)
|
|
|
|
var osModule = map[string]objects.Object{
|
|
"o_rdonly": &objects.Int{Value: int64(os.O_RDONLY)},
|
|
"o_wronly": &objects.Int{Value: int64(os.O_WRONLY)},
|
|
"o_rdwr": &objects.Int{Value: int64(os.O_RDWR)},
|
|
"o_append": &objects.Int{Value: int64(os.O_APPEND)},
|
|
"o_create": &objects.Int{Value: int64(os.O_CREATE)},
|
|
"o_excl": &objects.Int{Value: int64(os.O_EXCL)},
|
|
"o_sync": &objects.Int{Value: int64(os.O_SYNC)},
|
|
"o_trunc": &objects.Int{Value: int64(os.O_TRUNC)},
|
|
"mode_dir": &objects.Int{Value: int64(os.ModeDir)},
|
|
"mode_append": &objects.Int{Value: int64(os.ModeAppend)},
|
|
"mode_exclusive": &objects.Int{Value: int64(os.ModeExclusive)},
|
|
"mode_temporary": &objects.Int{Value: int64(os.ModeTemporary)},
|
|
"mode_symlink": &objects.Int{Value: int64(os.ModeSymlink)},
|
|
"mode_device": &objects.Int{Value: int64(os.ModeDevice)},
|
|
"mode_named_pipe": &objects.Int{Value: int64(os.ModeNamedPipe)},
|
|
"mode_socket": &objects.Int{Value: int64(os.ModeSocket)},
|
|
"mode_setuid": &objects.Int{Value: int64(os.ModeSetuid)},
|
|
"mode_setgui": &objects.Int{Value: int64(os.ModeSetgid)},
|
|
"mode_char_device": &objects.Int{Value: int64(os.ModeCharDevice)},
|
|
"mode_sticky": &objects.Int{Value: int64(os.ModeSticky)},
|
|
"mode_type": &objects.Int{Value: int64(os.ModeType)},
|
|
"mode_perm": &objects.Int{Value: int64(os.ModePerm)},
|
|
"path_separator": &objects.Char{Value: os.PathSeparator},
|
|
"path_list_separator": &objects.Char{Value: os.PathListSeparator},
|
|
"dev_null": &objects.String{Value: os.DevNull},
|
|
"seek_set": &objects.Int{Value: int64(io.SeekStart)},
|
|
"seek_cur": &objects.Int{Value: int64(io.SeekCurrent)},
|
|
"seek_end": &objects.Int{Value: int64(io.SeekEnd)},
|
|
"args": &objects.UserFunction{Value: osArgs}, // args() => array(string)
|
|
"chdir": &objects.UserFunction{Name: "chdir", Value: FuncASRE(os.Chdir)}, // chdir(dir string) => error
|
|
"chmod": osFuncASFmRE(os.Chmod), // chmod(name string, mode int) => error
|
|
"chown": &objects.UserFunction{Name: "chown", Value: FuncASIIRE(os.Chown)}, // chown(name string, uid int, gid int) => error
|
|
"clearenv": &objects.UserFunction{Name: "clearenv", Value: FuncAR(os.Clearenv)}, // clearenv()
|
|
"environ": &objects.UserFunction{Name: "environ", Value: FuncARSs(os.Environ)}, // environ() => array(string)
|
|
"exit": &objects.UserFunction{Name: "exit", Value: FuncAIR(os.Exit)}, // exit(code int)
|
|
"expand_env": &objects.UserFunction{Name: "expand_env", Value: FuncASRS(os.ExpandEnv)}, // expand_env(s string) => string
|
|
"getegid": &objects.UserFunction{Name: "getegid", Value: FuncARI(os.Getegid)}, // getegid() => int
|
|
"getenv": &objects.UserFunction{Name: "getenv", Value: FuncASRS(os.Getenv)}, // getenv(s string) => string
|
|
"geteuid": &objects.UserFunction{Name: "geteuid", Value: FuncARI(os.Geteuid)}, // geteuid() => int
|
|
"getgid": &objects.UserFunction{Name: "getgid", Value: FuncARI(os.Getgid)}, // getgid() => int
|
|
"getgroups": &objects.UserFunction{Name: "getgroups", Value: FuncARIsE(os.Getgroups)}, // getgroups() => array(string)/error
|
|
"getpagesize": &objects.UserFunction{Name: "getpagesize", Value: FuncARI(os.Getpagesize)}, // getpagesize() => int
|
|
"getpid": &objects.UserFunction{Name: "getpid", Value: FuncARI(os.Getpid)}, // getpid() => int
|
|
"getppid": &objects.UserFunction{Name: "getppid", Value: FuncARI(os.Getppid)}, // getppid() => int
|
|
"getuid": &objects.UserFunction{Name: "getuid", Value: FuncARI(os.Getuid)}, // getuid() => int
|
|
"getwd": &objects.UserFunction{Name: "getwd", Value: FuncARSE(os.Getwd)}, // getwd() => string/error
|
|
"hostname": &objects.UserFunction{Name: "hostname", Value: FuncARSE(os.Hostname)}, // hostname() => string/error
|
|
"lchown": &objects.UserFunction{Name: "lchown", Value: FuncASIIRE(os.Lchown)}, // lchown(name string, uid int, gid int) => error
|
|
"link": &objects.UserFunction{Name: "link", Value: FuncASSRE(os.Link)}, // link(oldname string, newname string) => error
|
|
"lookup_env": &objects.UserFunction{Value: osLookupEnv}, // lookup_env(key string) => string/false
|
|
"mkdir": osFuncASFmRE(os.Mkdir), // mkdir(name string, perm int) => error
|
|
"mkdir_all": osFuncASFmRE(os.MkdirAll), // mkdir_all(name string, perm int) => error
|
|
"readlink": &objects.UserFunction{Name: "readlink", Value: FuncASRSE(os.Readlink)}, // readlink(name string) => string/error
|
|
"remove": &objects.UserFunction{Name: "remove", Value: FuncASRE(os.Remove)}, // remove(name string) => error
|
|
"remove_all": &objects.UserFunction{Name: "remove_all", Value: FuncASRE(os.RemoveAll)}, // remove_all(name string) => error
|
|
"rename": &objects.UserFunction{Name: "rename", Value: FuncASSRE(os.Rename)}, // rename(oldpath string, newpath string) => error
|
|
"setenv": &objects.UserFunction{Name: "setenv", Value: FuncASSRE(os.Setenv)}, // setenv(key string, value string) => error
|
|
"symlink": &objects.UserFunction{Name: "symlink", Value: FuncASSRE(os.Symlink)}, // symlink(oldname string newname string) => error
|
|
"temp_dir": &objects.UserFunction{Name: "temp_dir", Value: FuncARS(os.TempDir)}, // temp_dir() => string
|
|
"truncate": &objects.UserFunction{Name: "truncate", Value: FuncASI64RE(os.Truncate)}, // truncate(name string, size int) => error
|
|
"unsetenv": &objects.UserFunction{Name: "unsetenv", Value: FuncASRE(os.Unsetenv)}, // unsetenv(key string) => error
|
|
"create": &objects.UserFunction{Value: osCreate}, // create(name string) => imap(file)/error
|
|
"open": &objects.UserFunction{Value: osOpen}, // open(name string) => imap(file)/error
|
|
"open_file": &objects.UserFunction{Value: osOpenFile}, // open_file(name string, flag int, perm int) => imap(file)/error
|
|
"find_process": &objects.UserFunction{Value: osFindProcess}, // find_process(pid int) => imap(process)/error
|
|
"start_process": &objects.UserFunction{Value: osStartProcess}, // start_process(name string, argv array(string), dir string, env array(string)) => imap(process)/error
|
|
"exec_look_path": &objects.UserFunction{Name: "exec_look_path", Value: FuncASRSE(exec.LookPath)}, // exec_look_path(file) => string/error
|
|
"exec": &objects.UserFunction{Value: osExec}, // exec(name, args...) => command
|
|
"stat": &objects.UserFunction{Value: osStat}, // stat(name) => imap(fileinfo)/error
|
|
"read_file": &objects.UserFunction{Value: osReadFile}, // readfile(name) => array(byte)/error
|
|
}
|
|
|
|
func osReadFile(args ...objects.Object) (ret objects.Object, err error) {
|
|
if len(args) != 1 {
|
|
return nil, objects.ErrWrongNumArguments
|
|
}
|
|
|
|
fname, ok := objects.ToString(args[0])
|
|
if !ok {
|
|
return nil, objects.ErrInvalidArgumentType{
|
|
Name: "first",
|
|
Expected: "string(compatible)",
|
|
Found: args[0].TypeName(),
|
|
}
|
|
}
|
|
|
|
bytes, err := ioutil.ReadFile(fname)
|
|
if err != nil {
|
|
return wrapError(err), nil
|
|
}
|
|
|
|
return &objects.Bytes{Value: bytes}, nil
|
|
}
|
|
|
|
func osStat(args ...objects.Object) (ret objects.Object, err error) {
|
|
if len(args) != 1 {
|
|
return nil, objects.ErrWrongNumArguments
|
|
}
|
|
|
|
fname, ok := objects.ToString(args[0])
|
|
if !ok {
|
|
return nil, objects.ErrInvalidArgumentType{
|
|
Name: "first",
|
|
Expected: "string(compatible)",
|
|
Found: args[0].TypeName(),
|
|
}
|
|
}
|
|
|
|
stat, err := os.Stat(fname)
|
|
if err != nil {
|
|
return wrapError(err), nil
|
|
}
|
|
|
|
fstat := &objects.ImmutableMap{
|
|
Value: map[string]objects.Object{
|
|
"name": &objects.String{Value: stat.Name()},
|
|
"mtime": &objects.Time{Value: stat.ModTime()},
|
|
"size": &objects.Int{Value: stat.Size()},
|
|
"mode": &objects.Int{Value: int64(stat.Mode())},
|
|
},
|
|
}
|
|
|
|
if stat.IsDir() {
|
|
fstat.Value["directory"] = objects.TrueValue
|
|
} else {
|
|
fstat.Value["directory"] = objects.FalseValue
|
|
}
|
|
|
|
return fstat, nil
|
|
}
|
|
|
|
func osCreate(args ...objects.Object) (objects.Object, error) {
|
|
if len(args) != 1 {
|
|
return nil, objects.ErrWrongNumArguments
|
|
}
|
|
|
|
s1, ok := objects.ToString(args[0])
|
|
if !ok {
|
|
return nil, objects.ErrInvalidArgumentType{
|
|
Name: "first",
|
|
Expected: "string(compatible)",
|
|
Found: args[0].TypeName(),
|
|
}
|
|
}
|
|
|
|
res, err := os.Create(s1)
|
|
if err != nil {
|
|
return wrapError(err), nil
|
|
}
|
|
|
|
return makeOSFile(res), nil
|
|
}
|
|
|
|
func osOpen(args ...objects.Object) (objects.Object, error) {
|
|
if len(args) != 1 {
|
|
return nil, objects.ErrWrongNumArguments
|
|
}
|
|
|
|
s1, ok := objects.ToString(args[0])
|
|
if !ok {
|
|
return nil, objects.ErrInvalidArgumentType{
|
|
Name: "first",
|
|
Expected: "string(compatible)",
|
|
Found: args[0].TypeName(),
|
|
}
|
|
}
|
|
|
|
res, err := os.Open(s1)
|
|
if err != nil {
|
|
return wrapError(err), nil
|
|
}
|
|
|
|
return makeOSFile(res), nil
|
|
}
|
|
|
|
func osOpenFile(args ...objects.Object) (objects.Object, error) {
|
|
if len(args) != 3 {
|
|
return nil, objects.ErrWrongNumArguments
|
|
}
|
|
|
|
s1, ok := objects.ToString(args[0])
|
|
if !ok {
|
|
return nil, objects.ErrInvalidArgumentType{
|
|
Name: "first",
|
|
Expected: "string(compatible)",
|
|
Found: args[0].TypeName(),
|
|
}
|
|
}
|
|
|
|
i2, ok := objects.ToInt(args[1])
|
|
if !ok {
|
|
return nil, objects.ErrInvalidArgumentType{
|
|
Name: "second",
|
|
Expected: "int(compatible)",
|
|
Found: args[1].TypeName(),
|
|
}
|
|
}
|
|
|
|
i3, ok := objects.ToInt(args[2])
|
|
if !ok {
|
|
return nil, objects.ErrInvalidArgumentType{
|
|
Name: "third",
|
|
Expected: "int(compatible)",
|
|
Found: args[2].TypeName(),
|
|
}
|
|
}
|
|
|
|
res, err := os.OpenFile(s1, i2, os.FileMode(i3))
|
|
if err != nil {
|
|
return wrapError(err), nil
|
|
}
|
|
|
|
return makeOSFile(res), nil
|
|
}
|
|
|
|
func osArgs(args ...objects.Object) (objects.Object, error) {
|
|
if len(args) != 0 {
|
|
return nil, objects.ErrWrongNumArguments
|
|
}
|
|
|
|
arr := &objects.Array{}
|
|
for _, osArg := range os.Args {
|
|
arr.Value = append(arr.Value, &objects.String{Value: osArg})
|
|
}
|
|
|
|
return arr, nil
|
|
}
|
|
|
|
func osFuncASFmRE(fn func(string, os.FileMode) error) *objects.UserFunction {
|
|
return &objects.UserFunction{
|
|
Value: func(args ...objects.Object) (objects.Object, error) {
|
|
if len(args) != 2 {
|
|
return nil, objects.ErrWrongNumArguments
|
|
}
|
|
|
|
s1, ok := objects.ToString(args[0])
|
|
if !ok {
|
|
return nil, objects.ErrInvalidArgumentType{
|
|
Name: "first",
|
|
Expected: "string(compatible)",
|
|
Found: args[0].TypeName(),
|
|
}
|
|
}
|
|
i2, ok := objects.ToInt64(args[1])
|
|
if !ok {
|
|
return nil, objects.ErrInvalidArgumentType{
|
|
Name: "second",
|
|
Expected: "int(compatible)",
|
|
Found: args[1].TypeName(),
|
|
}
|
|
}
|
|
|
|
return wrapError(fn(s1, os.FileMode(i2))), nil
|
|
},
|
|
}
|
|
}
|
|
|
|
func osLookupEnv(args ...objects.Object) (objects.Object, error) {
|
|
if len(args) != 1 {
|
|
return nil, objects.ErrWrongNumArguments
|
|
}
|
|
|
|
s1, ok := objects.ToString(args[0])
|
|
if !ok {
|
|
return nil, objects.ErrInvalidArgumentType{
|
|
Name: "first",
|
|
Expected: "string(compatible)",
|
|
Found: args[0].TypeName(),
|
|
}
|
|
}
|
|
|
|
res, ok := os.LookupEnv(s1)
|
|
if !ok {
|
|
return objects.FalseValue, nil
|
|
}
|
|
|
|
return &objects.String{Value: res}, nil
|
|
}
|
|
|
|
func osExec(args ...objects.Object) (objects.Object, error) {
|
|
if len(args) == 0 {
|
|
return nil, objects.ErrWrongNumArguments
|
|
}
|
|
|
|
name, ok := objects.ToString(args[0])
|
|
if !ok {
|
|
return nil, objects.ErrInvalidArgumentType{
|
|
Name: "first",
|
|
Expected: "string(compatible)",
|
|
Found: args[0].TypeName(),
|
|
}
|
|
}
|
|
|
|
var execArgs []string
|
|
for idx, arg := range args[1:] {
|
|
execArg, ok := objects.ToString(arg)
|
|
if !ok {
|
|
return nil, objects.ErrInvalidArgumentType{
|
|
Name: fmt.Sprintf("args[%d]", idx),
|
|
Expected: "string(compatible)",
|
|
Found: args[1+idx].TypeName(),
|
|
}
|
|
}
|
|
|
|
execArgs = append(execArgs, execArg)
|
|
}
|
|
|
|
return makeOSExecCommand(exec.Command(name, execArgs...)), nil
|
|
}
|
|
|
|
func osFindProcess(args ...objects.Object) (objects.Object, error) {
|
|
if len(args) != 1 {
|
|
return nil, objects.ErrWrongNumArguments
|
|
}
|
|
|
|
i1, ok := objects.ToInt(args[0])
|
|
if !ok {
|
|
return nil, objects.ErrInvalidArgumentType{
|
|
Name: "first",
|
|
Expected: "int(compatible)",
|
|
Found: args[0].TypeName(),
|
|
}
|
|
}
|
|
|
|
proc, err := os.FindProcess(i1)
|
|
if err != nil {
|
|
return wrapError(err), nil
|
|
}
|
|
|
|
return makeOSProcess(proc), nil
|
|
}
|
|
|
|
func osStartProcess(args ...objects.Object) (objects.Object, error) {
|
|
if len(args) != 4 {
|
|
return nil, objects.ErrWrongNumArguments
|
|
}
|
|
|
|
name, ok := objects.ToString(args[0])
|
|
if !ok {
|
|
return nil, objects.ErrInvalidArgumentType{
|
|
Name: "first",
|
|
Expected: "string(compatible)",
|
|
Found: args[0].TypeName(),
|
|
}
|
|
}
|
|
|
|
var argv []string
|
|
var err error
|
|
switch arg1 := args[1].(type) {
|
|
case *objects.Array:
|
|
argv, err = stringArray(arg1.Value, "second")
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
case *objects.ImmutableArray:
|
|
argv, err = stringArray(arg1.Value, "second")
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
default:
|
|
return nil, objects.ErrInvalidArgumentType{
|
|
Name: "second",
|
|
Expected: "array",
|
|
Found: arg1.TypeName(),
|
|
}
|
|
}
|
|
|
|
dir, ok := objects.ToString(args[2])
|
|
if !ok {
|
|
return nil, objects.ErrInvalidArgumentType{
|
|
Name: "third",
|
|
Expected: "string(compatible)",
|
|
Found: args[2].TypeName(),
|
|
}
|
|
}
|
|
|
|
var env []string
|
|
switch arg3 := args[3].(type) {
|
|
case *objects.Array:
|
|
env, err = stringArray(arg3.Value, "fourth")
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
case *objects.ImmutableArray:
|
|
env, err = stringArray(arg3.Value, "fourth")
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
default:
|
|
return nil, objects.ErrInvalidArgumentType{
|
|
Name: "fourth",
|
|
Expected: "array",
|
|
Found: arg3.TypeName(),
|
|
}
|
|
}
|
|
|
|
proc, err := os.StartProcess(name, argv, &os.ProcAttr{
|
|
Dir: dir,
|
|
Env: env,
|
|
})
|
|
if err != nil {
|
|
return wrapError(err), nil
|
|
}
|
|
|
|
return makeOSProcess(proc), nil
|
|
}
|
|
|
|
func stringArray(arr []objects.Object, argName string) ([]string, error) {
|
|
var sarr []string
|
|
for idx, elem := range arr {
|
|
str, ok := elem.(*objects.String)
|
|
if !ok {
|
|
return nil, objects.ErrInvalidArgumentType{
|
|
Name: fmt.Sprintf("%s[%d]", argName, idx),
|
|
Expected: "string",
|
|
Found: elem.TypeName(),
|
|
}
|
|
}
|
|
|
|
sarr = append(sarr, str.Value)
|
|
}
|
|
|
|
return sarr, nil
|
|
}
|