netbird/management-integrations
0
0
Fork 0
mirror of https://github.com/netbirdio/management-integrations.git synced 2026-05-22 17:09:23 -07:00
Code Issues Packages Projects Releases Wiki Activity

Add postgres support for activity event store (#26)

Browse Source
This commit is contained in:
Bethuel Mmbaga
2025-06-04 17:38:08 +03:00
committed by GitHub
parent 7901e0a822
commit 492a54c945
3 changed files with 97 additions and 178 deletions
Download Patch File Download Diff File Expand all files Collapse all files
integrations/integrations.go
+4 -4
View File
@@ -4,18 +4,18 @@ import (
"context"
"github.com/gorilla/mux"
"github.com/netbirdio/netbird/management/server/store"
log "github.com/sirupsen/logrus"
"go.opentelemetry.io/otel/metric"
"github.com/netbirdio/netbird/management/server/account"
"github.com/netbirdio/netbird/management/server/activity"
"github.com/netbirdio/netbird/management/server/activity/sqlite"
activitystore "github.com/netbirdio/netbird/management/server/activity/store"
"github.com/netbirdio/netbird/management/server/integrations/integrated_validator"
"github.com/netbirdio/netbird/management/server/integrations/port_forwarding"
"github.com/netbirdio/netbird/management/server/peers"
"github.com/netbirdio/netbird/management/server/permissions"
"github.com/netbirdio/netbird/management/server/settings"
"github.com/netbirdio/netbird/management/server/store"
)
func RegisterHandlers(
@@ -37,12 +37,12 @@ func InitEventStore(ctx context.Context, dataDir string, key string) (activity.S
var err error
if key == "" {
log.Debugf("generate new activity store encryption key")
key, err = sqlite.GenerateKey()
key, err = activitystore.GenerateKey()
if err != nil {
return nil, "", err
}
}
store, err := sqlite.NewSQLiteStore(ctx, dataDir, key)
store, err := activitystore.NewSqlStore(ctx, dataDir, key)
return store, key, err
}