This commit is contained in:
Skip R
2025-12-11 19:55:00 -08:00
parent ab82f8b131
commit 60171b4fca
7 changed files with 17 additions and 12 deletions

View File

@@ -27,8 +27,9 @@ import (
"strconv"
"github.com/bwmarrin/discordgo"
"go.mau.fi/mautrix-discord/pkg/attachment"
"maunium.net/go/mautrix/bridgev2"
"go.mau.fi/mautrix-discord/pkg/attachment"
)
func downloadDiscordAttachment(cli *http.Client, url string, maxSize int64) ([]byte, error) {

View File

@@ -27,12 +27,13 @@ import (
"github.com/bwmarrin/discordgo"
"github.com/rs/zerolog"
"go.mau.fi/mautrix-discord/pkg/discordid"
"go.mau.fi/mautrix-discord/pkg/msgconv"
"maunium.net/go/mautrix/bridgev2"
"maunium.net/go/mautrix/bridgev2/database"
"maunium.net/go/mautrix/bridgev2/networkid"
"maunium.net/go/mautrix/bridgev2/status"
"go.mau.fi/mautrix-discord/pkg/discordid"
"go.mau.fi/mautrix-discord/pkg/msgconv"
)
type DiscordClient struct {
@@ -109,9 +110,7 @@ func (cl *DiscordClient) connect(ctx context.Context) error {
log := zerolog.Ctx(ctx)
log.Info().Msg("Opening session")
cl.Session.EventHandler = func(event any) {
go cl.handleDiscordEvent(event)
}
cl.Session.EventHandler = cl.handleDiscordEventSync
err := cl.Session.Open()
for attempts := 0; errors.Is(err, discordgo.ErrImmediateDisconnect) && attempts < 2; attempts += 1 {

View File

@@ -19,8 +19,9 @@ package connector
import (
"context"
"go.mau.fi/mautrix-discord/pkg/msgconv"
"maunium.net/go/mautrix/bridgev2"
"go.mau.fi/mautrix-discord/pkg/msgconv"
)
type DiscordConnector struct {