Zabbix Matrix integration script

matrixcli.go

package main

import (
	"bytes"
	"encoding/json"
	"flag"
	"fmt"
	"io/ioutil"
	"net/http"
	"os"
)

const MATRIX_USER = "user name of zabbixbot on your matrix server without domain name"
const MATRIX_PASS = "password for zabbixbot user"
const MATRIX_URL = "https://your.matrix.server/"
const ACCESS_TOKEN = "access token (will be returned by login command, paste here and recompile to use other commands)"

func main() {
	flag.Parse()

	command := flag.Arg(0)
	switch command {
	case "login":
		login(flag.Arg(1), flag.Arg(2))
	case "invite":
		invite(flag.Arg(1), flag.Arg(2), ACCESS_TOKEN)
	case "createroom":
		createRoom(flag.Arg(1), ACCESS_TOKEN)
	case "notify":
		notify(flag.Arg(1), flag.Arg(2), ACCESS_TOKEN)
	default:
		fmt.Println("Unrecognized command " + command)
		os.Exit(1)
	}

}

func login(username string, password string) {

	type Login struct {
		Type     string `json:"type"`
		Username string `json:"user"`
		Password string `json:"password"`
	}

	request, err := json.Marshal(Login{"m.login.password", username, password})
	panicif(err)

	resp, err := http.Post(MATRIX_URL+"_matrix/client/r0/login",
		"application/json",
		bytes.NewBuffer(request))
	panicif(err)

	printBody(resp)
}

func invite(userid string, roomid string, accessToken string) {
	type Invite struct {
		UserId string `json:"user_id"`
	}

	request, err := json.Marshal(Invite{userid})
	panicif(err)

	os.Stdout.Write(request)

	resp, err := http.Post(MATRIX_URL+"_matrix/client/r0/rooms/"+roomid+"/invite?access_token="+accessToken,
		"application/json",
		bytes.NewBuffer(request))
	panicif(err)
	printBody(resp)
}

func createRoom(name string, accessToken string) {
	type CreateRoom struct {
		RoomAlias string `json:"room_alias_name"`
	}

	request, err := json.Marshal(CreateRoom{name})
	panicif(err)

	resp, err := http.Post(MATRIX_URL+"_matrix/client/r0/createRoom?access_token="+accessToken,
		"application/json",
		bytes.NewBuffer(request))
	panicif(err)

	printBody(resp)
}

func notify(roomid string, message string, accessToken string) {
	type SendMessage struct {
		MsgType string `json:"msgtype"`
		Body    string `json:"body"`
	}

	request, err := json.Marshal(SendMessage{"m.text", message})
	panicif(err)

	url := MATRIX_URL + "_matrix/client/r0/rooms/" + roomid + "/send/m.room.message?access_token=" + accessToken

	resp, err := http.Post(url,
		"application/json",
		bytes.NewBuffer(request))
	panicif(err)

	printBody(resp)
}

func printBody(resp *http.Response) {
	defer resp.Body.Close()

	body, err := ioutil.ReadAll(resp.Body)
	panicif(err)

	os.Stdout.Write(body)
}

func panicif(err error) {
	if err != nil {
		panic(err)
	}
}