Refactor event polling by removing legacy implementation and updating…

… event repository initialization
PRYVT · Nov 29, 2024 · bfc1de2 · bfc1de2
1 parent 6b932f8
commit bfc1de2
Show file tree

Hide file tree

Showing 6 changed files with 6 additions and 142 deletions.
diff --git a/cmd/queryer/main.go b/cmd/queryer/main.go
@@ -5,12 +5,13 @@ import (
 
 	"github.com/L4B0MB4/EVTSRC/pkg/client"
 	"github.com/L4B0MB4/PRYVT/identification/pkg/query/eventhandling"
-	"github.com/L4B0MB4/PRYVT/identification/pkg/query/eventpolling"
 	"github.com/L4B0MB4/PRYVT/identification/pkg/query/httphandler"
 	"github.com/L4B0MB4/PRYVT/identification/pkg/query/httphandler/controller"
 	"github.com/L4B0MB4/PRYVT/identification/pkg/query/store"
 	"github.com/L4B0MB4/PRYVT/identification/pkg/query/store/repository"
 	"github.com/PRYVT/utils/pkg/auth"
+	"github.com/PRYVT/utils/pkg/eventpolling"
+	utilsRepo "github.com/PRYVT/utils/pkg/store/repository"
 	"github.com/rs/zerolog"
 	"github.com/rs/zerolog/log"
 )
@@ -36,7 +37,7 @@ func main() {
 		log.Error().Err(err).Msg("Unsuccessful initialization of token manager")
 		return
 	}
-	eventRepo := repository.NewEventRepository(conn)
+	eventRepo := utilsRepo.NewEventRepository(conn)
 	userRepo := repository.NewUserRepository(conn)
 	uc := controller.NewUserController(userRepo, tokenManager)
 	aut := auth.NewAuthMiddleware(tokenManager)

diff --git a/go.mod b/go.mod
@@ -6,7 +6,7 @@ require github.com/mattn/go-sqlite3 v1.14.24
 
 require (
 	github.com/L4B0MB4/EVTSRC v0.4.5 // indirect
-	github.com/PRYVT/utils v0.1.2 // indirect
+	github.com/PRYVT/utils v0.2.0 // indirect
 	github.com/bytedance/sonic v1.12.2 // indirect
 	github.com/bytedance/sonic/loader v0.2.0 // indirect
 	github.com/cloudwego/base64x v0.1.4 // indirect

diff --git a/go.sum b/go.sum
@@ -22,6 +22,8 @@ github.com/PRYVT/utils v0.1.1 h1:Y/WHkTHID0T40O2XfzlLM1QsDyQWE8FtH8ncaU4ags8=
 github.com/PRYVT/utils v0.1.1/go.mod h1:b7zk2FAGwJ8BPJx2JQ8qd+bA59g5EY7Y1vZQPWZHK3s=
 github.com/PRYVT/utils v0.1.2 h1:U9qhq+18iIblQDrM4I0fmJkvlZ+BCY+DIjjKI4ebtlk=
 github.com/PRYVT/utils v0.1.2/go.mod h1:b7zk2FAGwJ8BPJx2JQ8qd+bA59g5EY7Y1vZQPWZHK3s=
+github.com/PRYVT/utils v0.2.0 h1:hWdHchXlGOYlJ1nfMmGffq/EjFn3ncvzTgsGCLUpiEE=
+github.com/PRYVT/utils v0.2.0/go.mod h1:j61GmoyWWXgnCq/laZTIJm4yhD0PreLDMZnYQqjSv7w=
 github.com/bytedance/sonic v1.11.6 h1:oUp34TzMlL+OY1OUWxHqsdkgC/Zfc85zGqw9siXjrc0=
 github.com/bytedance/sonic v1.11.6/go.mod h1:LysEHSvpvDySVdC2f87zGWf6CIKJcAvqab1ZaiQtds4=
 github.com/bytedance/sonic v1.12.2 h1:oaMFuRTpMHYLpCntGca65YWt5ny+wAceDERTkT2L9lg=

diff --git a/pkg/query/eventpolling/event_handler.go b/pkg/query/eventpolling/event_handler.go
diff --git a/pkg/query/eventpolling/polling.go b/pkg/query/eventpolling/polling.go
diff --git a/pkg/query/store/repository/event_repository.go b/pkg/query/store/repository/event_repository.go