mirror of
https://github.com/bbernhard/signal-cli-rest-api.git
synced 2026-08-10 03:06:03 +00:00
0023ebaf83
* only look for registered numbers in the signal-cli-config/data folder and do NOT traverse the whole signal-cli-config folder (as there might be other files starting with '+...'
102 lines
3.2 KiB
Go
102 lines
3.2 KiB
Go
package main
|
|
|
|
import (
|
|
"flag"
|
|
"fmt"
|
|
"github.com/bbernhard/signal-cli-rest-api/utils"
|
|
log "github.com/sirupsen/logrus"
|
|
"io/ioutil"
|
|
"os"
|
|
"os/exec"
|
|
"path/filepath"
|
|
"strconv"
|
|
"strings"
|
|
)
|
|
|
|
const supervisorctlConfigTemplate = `
|
|
[program:%s]
|
|
environment=JAVA_HOME=/opt/java/openjdk
|
|
process_name=%s
|
|
command=bash -c "nc -l -p %d <%s | signal-cli --output=json -u %s --config /home/.local/share/signal-cli/ jsonRpc >%s"
|
|
autostart=true
|
|
autorestart=true
|
|
startretries=10
|
|
user=signal-api
|
|
directory=/usr/bin/
|
|
redirect_stderr=true
|
|
stdout_logfile=/var/log/%s/out.log
|
|
stderr_logfile=/var/log/%s/err.log
|
|
stdout_logfile_maxbytes=50MB
|
|
stdout_logfile_backups=10
|
|
numprocs=1
|
|
`
|
|
|
|
func main() {
|
|
signalCliConfigDir := flag.String("signal-cli-config-dir", "/home/.local/share/signal-cli/", "Path to signal-cli config directory")
|
|
signalCliConfigDataDir := *signalCliConfigDir + "data"
|
|
|
|
jsonRpc2ClientConfig := utils.NewJsonRpc2ClientConfig()
|
|
|
|
var tcpBasePort int64 = 6000
|
|
fifoBasePathName := "/tmp/sigsocket"
|
|
var ctr int64 = 0
|
|
|
|
items, err := ioutil.ReadDir(signalCliConfigDataDir)
|
|
if err != nil {
|
|
log.Fatal("Couldn't read contents of ", signalCliConfigDataDir)
|
|
}
|
|
for _, item := range items {
|
|
if item.IsDir() {
|
|
continue
|
|
}
|
|
filename := filepath.Base(item.Name())
|
|
if strings.HasPrefix(filename, "+") {
|
|
if utils.IsPhoneNumber(filename) {
|
|
number := filename
|
|
fifoPathname := fifoBasePathName + strconv.FormatInt(ctr, 10)
|
|
tcpPort := tcpBasePort + ctr
|
|
jsonRpc2ClientConfig.AddEntry(number, utils.ConfigEntry{TcpPort: tcpPort, FifoPathname: fifoPathname})
|
|
ctr += 1
|
|
|
|
os.Remove(fifoPathname) //remove any existing named pipe
|
|
|
|
_, err = exec.Command("mkfifo", fifoPathname).Output()
|
|
if err != nil {
|
|
log.Fatal("Couldn't create fifo with name ", fifoPathname, ": ", err.Error())
|
|
}
|
|
|
|
_, err = exec.Command("chown", "1000:1000", fifoPathname).Output()
|
|
if err != nil {
|
|
log.Fatal("Couldn't change permissions of fifo with name ", fifoPathname, ": ", err.Error())
|
|
}
|
|
|
|
supervisorctlProgramName := "signal-cli-json-rpc-" + strconv.FormatInt(ctr, 10)
|
|
supervisorctlLogFolder := "/var/log/" + supervisorctlProgramName
|
|
_, err = exec.Command("mkdir", "-p", supervisorctlLogFolder).Output()
|
|
if err != nil {
|
|
log.Fatal("Couldn't create log folder ", supervisorctlLogFolder, ": ", err.Error())
|
|
}
|
|
|
|
log.Info("Found number ", number, " and added it to jsonrpc2.yml")
|
|
|
|
//write supervisorctl config
|
|
supervisorctlConfigFilename := "/etc/supervisor/conf.d/" + "signal-cli-json-rpc-" + strconv.FormatInt(ctr, 10) + ".conf"
|
|
supervisorctlConfig := fmt.Sprintf(supervisorctlConfigTemplate, supervisorctlProgramName, supervisorctlProgramName,
|
|
tcpPort, fifoPathname, number, fifoPathname, supervisorctlProgramName, supervisorctlProgramName)
|
|
err = ioutil.WriteFile(supervisorctlConfigFilename, []byte(supervisorctlConfig), 0644)
|
|
if err != nil {
|
|
log.Fatal("Couldn't write ", supervisorctlConfigFilename, ": ", err.Error())
|
|
}
|
|
} else {
|
|
log.Error("Skipping ", filename, " as it is not a valid phone number!")
|
|
}
|
|
}
|
|
}
|
|
|
|
// write jsonrpc.yml config file
|
|
err = jsonRpc2ClientConfig.Persist(*signalCliConfigDir + "jsonrpc2.yml")
|
|
if err != nil {
|
|
log.Fatal("Couldn't persist jsonrpc2.yaml: ", err.Error())
|
|
}
|
|
}
|