Skip to content

Commit

Permalink
add store to connector
Browse files Browse the repository at this point in the history
  • Loading branch information
JJTech0130 committed Jul 1, 2024
1 parent be724b8 commit bfb826a
Showing 1 changed file with 10 additions and 5 deletions.
15 changes: 10 additions & 5 deletions pkg/connector/connector.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,12 +3,17 @@ package connector
import (
"context"

"go.mau.fi/util/dbutil"
"maunium.net/go/mautrix/bridgev2"

"go.mau.fi/mautrix-meta/pkg/store"
)

type MetaConnector struct {
Bridge *bridgev2.Bridge
Config *MetaConfig

store *store.Container
}

func NewConnector() *MetaConnector {
Expand Down Expand Up @@ -68,13 +73,13 @@ func (s *MetaConnector) GetName() bridgev2.BridgeName {
}
}

func (m *MetaConnector) Init(*bridgev2.Bridge) {
println("Connector Init unimplemented")
func (m *MetaConnector) Init(bridge *bridgev2.Bridge) {
m.store = store.NewStore(bridge.DB.Database, dbutil.ZeroLogger(bridge.Log.With().Str("db_section", "meta").Logger()))
m.Bridge = bridge
}

func (m *MetaConnector) Start(context.Context) error {
println("Connector Start unimplemented")
return nil
func (m *MetaConnector) Start(ctx context.Context) error {
return m.store.Upgrade(ctx)
}

func (m *MetaConnector) LoadUserLogin(ctx context.Context, login *bridgev2.UserLogin) error {
Expand Down

0 comments on commit bfb826a

Please sign in to comment.