From a4a139c56ece276537ac386a7d4fd85c9aa3e4b9 Mon Sep 17 00:00:00 2001
From: LittleSheep <littlesheep.code@hotmail.com>
Date: Mon, 14 Oct 2024 22:09:45 +0800
Subject: [PATCH] :sparkles: Implement event recorder grpc

---
 .idea/workspace.xml         | 10 +++++-----
 pkg/internal/grpc/events.go | 20 ++++++++++++++++++++
 pkg/internal/grpc/server.go |  2 ++
 3 files changed, 27 insertions(+), 5 deletions(-)
 create mode 100644 pkg/internal/grpc/events.go

diff --git a/.idea/workspace.xml b/.idea/workspace.xml
index 05c9be3..f001504 100644
--- a/.idea/workspace.xml
+++ b/.idea/workspace.xml
@@ -4,10 +4,10 @@
     <option name="autoReloadType" value="ALL" />
   </component>
   <component name="ChangeListManager">
-    <list default="true" id="3fefb2c4-b6f9-466b-a523-53352e8d6f95" name="更改" comment=":bug: Bug fixes on multi-factors based authentication">
+    <list default="true" id="3fefb2c4-b6f9-466b-a523-53352e8d6f95" name="更改" comment=":bug: Bug fixes on settings auth preferences">
+      <change afterPath="$PROJECT_DIR$/pkg/internal/grpc/events.go" afterDir="false" />
       <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/pkg/internal/models/auth.go" beforeDir="false" afterPath="$PROJECT_DIR$/pkg/internal/models/auth.go" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/pkg/internal/server/api/preferences_api.go" beforeDir="false" afterPath="$PROJECT_DIR$/pkg/internal/server/api/preferences_api.go" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/pkg/internal/grpc/server.go" beforeDir="false" afterPath="$PROJECT_DIR$/pkg/internal/grpc/server.go" afterDir="false" />
     </list>
     <option name="SHOW_DIALOG" value="false" />
     <option name="HIGHLIGHT_CONFLICTS" value="true" />
@@ -154,7 +154,6 @@
     </option>
   </component>
   <component name="VcsManagerConfiguration">
-    <MESSAGE value=":bug: Fix compare perm node function" />
     <MESSAGE value=":sparkles: Bot related bot key apis" />
     <MESSAGE value=":bug: Fix bot related bot key apis path error" />
     <MESSAGE value=":bug: Fix path parameters misplaced" />
@@ -179,7 +178,8 @@
     <MESSAGE value=":sparkles: Allow user view and remove notification subscriptions" />
     <MESSAGE value=":recycle: Improve notifications mark read system" />
     <MESSAGE value=":bug: Bug fixes on multi-factors based authentication" />
-    <option name="LAST_COMMIT_MESSAGE" value=":bug: Bug fixes on multi-factors based authentication" />
+    <MESSAGE value=":bug: Bug fixes on settings auth preferences" />
+    <option name="LAST_COMMIT_MESSAGE" value=":bug: Bug fixes on settings auth preferences" />
   </component>
   <component name="VgoProject">
     <settings-migrated>true</settings-migrated>
diff --git a/pkg/internal/grpc/events.go b/pkg/internal/grpc/events.go
new file mode 100644
index 0000000..a9ca492
--- /dev/null
+++ b/pkg/internal/grpc/events.go
@@ -0,0 +1,20 @@
+package grpc
+
+import (
+	"context"
+	"git.solsynth.dev/hydrogen/dealer/pkg/proto"
+	"git.solsynth.dev/hydrogen/passport/pkg/internal/models"
+	"git.solsynth.dev/hydrogen/passport/pkg/internal/services"
+)
+
+func (v *Server) RecordEvent(ctx context.Context, request *proto.RecordEventRequest) (*proto.RecordEventResponse, error) {
+	var user models.Account
+	var err error
+	if user, err = services.GetAccount(uint(request.GetUserId())); err != nil {
+		return nil, err
+	}
+
+	services.AddEvent(user, request.GetAction(), request.GetTarget(), request.GetIp(), request.GetUserAgent())
+
+	return &proto.RecordEventResponse{IsSuccess: true}, nil
+}
diff --git a/pkg/internal/grpc/server.go b/pkg/internal/grpc/server.go
index f1509e1..40d3fe8 100644
--- a/pkg/internal/grpc/server.go
+++ b/pkg/internal/grpc/server.go
@@ -17,6 +17,7 @@ type Server struct {
 	proto.UnimplementedNotifierServer
 	proto.UnimplementedRealmServer
 	proto.UnimplementedStreamControllerServer
+	proto.UnimplementedEventRecorderServer
 	health.UnimplementedHealthServer
 
 	srv *grpc.Server
@@ -31,6 +32,7 @@ func NewServer() *Server {
 	proto.RegisterNotifierServer(server.srv, server)
 	proto.RegisterRealmServer(server.srv, server)
 	proto.RegisterStreamControllerServer(server.srv, server)
+	proto.RegisterEventRecorderServer(server.srv, server)
 	health.RegisterHealthServer(server.srv, server)
 
 	reflection.Register(server.srv)