Got optimized some behaviour.

This commit is contained in:
Jackhead 2025-04-10 16:27:13 +02:00
parent 90bf87306d
commit 63595abd35
2 changed files with 14 additions and 5 deletions

Binary file not shown.

View file

@ -53,6 +53,7 @@ func main() {
panic(err) panic(err)
} }
defer rl.Close() defer rl.Close()
log := zerolog.New(zerolog.NewConsoleWriter(func(w *zerolog.ConsoleWriter) { log := zerolog.New(zerolog.NewConsoleWriter(func(w *zerolog.ConsoleWriter) {
w.Out = rl.Stdout() w.Out = rl.Stdout()
w.TimeFormat = time.Stamp w.TimeFormat = time.Stamp
@ -65,7 +66,16 @@ func main() {
var lastRoomID id.RoomID var lastRoomID id.RoomID
// Syncer Setup
syncer := client.Syncer.(*mautrix.DefaultSyncer) syncer := client.Syncer.(*mautrix.DefaultSyncer)
// log all event-Types coming in
syncer.OnEvent(func(ctx context.Context, evt *event.Event) {
log.Info().
Str("TYPE", evt.Type.Type).
Msg("Event")
})
syncer.OnEventType(event.EventMessage, func(ctx context.Context, evt *event.Event) { syncer.OnEventType(event.EventMessage, func(ctx context.Context, evt *event.Event) {
lastRoomID = evt.RoomID lastRoomID = evt.RoomID
rl.SetPrompt(fmt.Sprintf("%s> ", lastRoomID)) rl.SetPrompt(fmt.Sprintf("%s> ", lastRoomID))
@ -76,6 +86,7 @@ func main() {
Str("body", evt.Content.AsMessage().Body). Str("body", evt.Content.AsMessage().Body).
Msg("Received message") Msg("Received message")
}) })
syncer.OnEventType(event.StateMember, func(ctx context.Context, evt *event.Event) { syncer.OnEventType(event.StateMember, func(ctx context.Context, evt *event.Event) {
if evt.GetStateKey() == client.UserID.String() && evt.Content.AsMember().Membership == event.MembershipInvite { if evt.GetStateKey() == client.UserID.String() && evt.Content.AsMember().Membership == event.MembershipInvite {
_, err := client.JoinRoomByID(ctx, evt.RoomID) _, err := client.JoinRoomByID(ctx, evt.RoomID)
@ -94,9 +105,7 @@ func main() {
} }
} }
}) })
// req = mautrix.ReqLogin()
// resp, err := client.Login(context.Background(), req*mautrix.ReqLogin)
// fmt.Println(resp, err)
cryptoHelper, err := cryptohelper.NewCryptoHelper(client, []byte("meow"), *database) cryptoHelper, err := cryptohelper.NewCryptoHelper(client, []byte("meow"), *database)
if err != nil { if err != nil {
panic(err) panic(err)
@ -121,6 +130,7 @@ func main() {
// Set the client crypto helper in order to automatically encrypt outgoing messages // Set the client crypto helper in order to automatically encrypt outgoing messages
client.Crypto = cryptoHelper client.Crypto = cryptoHelper
log.Info().Msg("Now running") log.Info().Msg("Now running")
// Setting up the context for syncing the server
syncCtx, cancelSync := context.WithCancel(context.Background()) syncCtx, cancelSync := context.WithCancel(context.Background())
var syncStopWait sync.WaitGroup var syncStopWait sync.WaitGroup
syncStopWait.Add(1) syncStopWait.Add(1)
@ -150,8 +160,7 @@ func main() {
} }
} }
cancelSync() cancelSync()
// mautrix.SyncEventsListncStopWait.Wait() err = cryptoHelper.Close()
// err = cryptoHelper.Close()
if err != nil { if err != nil {
log.Error().Err(err).Msg("Error closing database") log.Error().Err(err).Msg("Error closing database")
} }