✨ Support stream controller event emit

pkg/internal/grpc/server.go

@@ -1,20 +1,22 @@
 package grpc
 
 import (
-	"google.golang.org/grpc/reflection"
 	"net"
 
+	"google.golang.org/grpc/reflection"
+
 	"git.solsynth.dev/hydrogen/dealer/pkg/proto"
 	"github.com/spf13/viper"
 	"google.golang.org/grpc"
-)
 
-import health "google.golang.org/grpc/health/grpc_health_v1"
+	health "google.golang.org/grpc/health/grpc_health_v1"
+)
 
 type Server struct {
 	proto.UnimplementedAuthServer
 	proto.UnimplementedNotifierServer
 	proto.UnimplementedRealmServer
+	proto.UnimplementedStreamControllerServer
 	health.UnimplementedHealthServer
 
 	srv *grpc.Server
@@ -28,6 +30,7 @@ func NewServer() *Server {
 	proto.RegisterAuthServer(server.srv, server)
 	proto.RegisterNotifierServer(server.srv, server)
 	proto.RegisterRealmServer(server.srv, server)
+	proto.RegisterStreamControllerServer(server.srv, server)
 	health.RegisterHealthServer(server.srv, server)
 
 	reflection.Register(server.srv)

pkg/internal/grpc/stream.go

@@ -0,0 +1,21 @@
+package grpc
+
+import (
+	"context"
+	"git.solsynth.dev/hydrogen/dealer/pkg/proto"
+	"git.solsynth.dev/hydrogen/passport/pkg/internal/services"
+)
+
+func (v *Server) EmitStreamEvent(ctx context.Context, request *proto.StreamEventRequest) (*proto.StreamEventResponse, error) {
+	switch request.GetEvent() {
+	case "ClientRegister":
+		// No longer need update user online status
+		// Based on realtime sever connection status
+		break
+	case "ClientUnregister":
+		// Update user last seen at
+		_ = services.SetAccountLastSeen(uint(request.GetUserId()))
+	}
+
+	return &proto.StreamEventResponse{}, nil
+}