UA-Fediland/UA-Bot
2
0
Fork 0
Code Issues Pull requests Projects Releases 1 Packages Wiki Activity

add send text to matrix when started

Browse source
This commit is contained in:
Andriy Cherniy 2024-01-04 22:01:06 +02:00
parent 71b3ac18fa
commit 8b875882e9
1 changed files with 10 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
main.go
View file

@ -55,6 +55,7 @@ func parseRegexFile(path string) ([]regexp.Regexp, error) {
func main() { func main() {
ctx := context.Background() ctx := context.Background()
err := godotenv.Load() err := godotenv.Load()
ROOM_ID := os.Getenv("MATRIX_ROOM_ID")
if err != nil { if err != nil {
log.Fatal(err) log.Fatal(err)
@ -115,14 +116,15 @@ func main() {
log.Fatal(err) log.Fatal(err)
} }
log.Info("starting...") log.Info("starting...")
matrix_client.SendText(m_id.RoomID(ROOM_ID), "Бот запущений!")
syncer.OnEventType(m_event.EventReaction, func(source mautrix.EventSource, ev *m_event.Event) { syncer.OnEventType(m_event.EventReaction, func(source mautrix.EventSource, ev *m_event.Event) {
log.Info("reactions") log.Info("reactions")
// if ev.RoomID == os.Getenv("MATRIX_ROOM_ID") && ev.Content != nil && // if ev.RoomID == ROOM_ID && ev.Content != nil &&
content := ev.Content.AsReaction() content := ev.Content.AsReaction()
key := []rune(content.RelatesTo.Key) key := []rune(content.RelatesTo.Key)
log.Info(content.RelatesTo.Key) log.Info(content.RelatesTo.Key)
if ev.RoomID.String() == os.Getenv("MATRIX_ROOM_ID") && (key[0] == '👍' || key[0] == '👎') { if ev.RoomID.String() == ROOM_ID && (key[0] == '👍' || key[0] == '👎') {
log.Info("reacted well") log.Info("reacted well")
var post Post var post Post
if err := db.First(&post, "message_id = ?", content.RelatesTo.EventID.String()).Error; err != nil { if err := db.First(&post, "message_id = ?", content.RelatesTo.EventID.String()).Error; err != nil {
@ -142,12 +144,12 @@ func main() {
log.Error(err) log.Error(err)
return return
} }
// matrix_client.SendMessageEvent(os.Getenv("MATRIX_ROOM_ID"), "m.room.message", interface{}) // matrix_client.SendMessageEvent(ROOM_ID, "m.room.message", interface{})
body := fmt.Sprintf(`#%d: Схвалено body := fmt.Sprintf(`#%d: Схвалено
%s %s
`, post.ID, status.URL) `, post.ID, status.URL)
_, err := matrix_client.SendMessageEvent(m_id.RoomID(os.Getenv("MATRIX_ROOM_ID")), m_event.EventMessage, &m_event.MessageEventContent{ _, err := matrix_client.SendMessageEvent(m_id.RoomID(ROOM_ID), m_event.EventMessage, &m_event.MessageEventContent{
Body: body, Body: body,
MsgType: m_event.MsgText, MsgType: m_event.MsgText,
NewContent: &m_event.MessageEventContent{ NewContent: &m_event.MessageEventContent{
@ -167,7 +169,7 @@ func main() {
body := fmt.Sprintf(`#%d: Відмовлено body := fmt.Sprintf(`#%d: Відмовлено
%s %s
`, post.ID, status.URL) `, post.ID, status.URL)
_, err := matrix_client.SendMessageEvent(m_id.RoomID(os.Getenv("MATRIX_ROOM_ID")), m_event.EventMessage, &m_event.MessageEventContent{ _, err := matrix_client.SendMessageEvent(m_id.RoomID(ROOM_ID), m_event.EventMessage, &m_event.MessageEventContent{
Body: body, Body: body,
MsgType: m_event.MsgText, MsgType: m_event.MsgText,
NewContent: &m_event.MessageEventContent{ NewContent: &m_event.MessageEventContent{
@ -217,7 +219,7 @@ notif_loop:
if len(acct_parsed) == 2 && regex.MatchString(acct_parsed[1]) { if len(acct_parsed) == 2 && regex.MatchString(acct_parsed[1]) {
_, err := masto_client.AccountBlock(ctx, notif.Account.ID) _, err := masto_client.AccountBlock(ctx, notif.Account.ID)
if err == nil { if err == nil {
matrix_client.SendText(m_id.RoomID(os.Getenv("MATRIX_ROOM_ID")), fmt.Sprintf("%s заблокований автоматично регексом доменів: %s", notif.Account.Acct, regex.String())) matrix_client.SendText(m_id.RoomID(ROOM_ID), fmt.Sprintf("%s заблокований автоматично регексом доменів: %s", notif.Account.Acct, regex.String()))
} }
continue notif_loop continue notif_loop
} }
@ -227,7 +229,7 @@ notif_loop:
if regex.MatchString(acct_parsed[0]) { if regex.MatchString(acct_parsed[0]) {
_, err := masto_client.AccountBlock(ctx, notif.Account.ID) _, err := masto_client.AccountBlock(ctx, notif.Account.ID)
if err == nil { if err == nil {
matrix_client.SendText(m_id.RoomID(os.Getenv("MATRIX_ROOM_ID")), fmt.Sprintf("%s заблокований автоматично регексом нікнеймів: %s", notif.Account.Acct, regex.String())) matrix_client.SendText(m_id.RoomID(ROOM_ID), fmt.Sprintf("%s заблокований автоматично регексом нікнеймів: %s", notif.Account.Acct, regex.String()))
} }
continue notif_loop continue notif_loop
} }
@ -275,7 +277,7 @@ actor: %v`, notif.Status.ID, notif.Status.Content, notif.Account.Acct)
log.Error(err) log.Error(err)
continue continue
} }
message, err := matrix_client.SendText(m_id.RoomID(os.Getenv("MATRIX_ROOM_ID")), fmt.Sprintf(`#%d: На модерації message, err := matrix_client.SendText(m_id.RoomID(ROOM_ID), fmt.Sprintf(`#%d: На модерації
%s %s
👍 - Так 👍 - Так
👎 - Ні 👎 - Ні