feat: implement chunked user synchronization with gRPC and REST APIs (#23)

* feat: implement chunked user synchronization with gRPC and REST APIs

* try to fix tests

Author: ImMohammad20000

backend/xray/user.go

@@ -168,5 +168,8 @@ func (x *Xray) SyncUsers(_ context.Context, users []*common.User) error {
 	if err := x.Restart(); err != nil {
 		return err
 	}
+	if err := x.checkXrayStatus(); err != nil {
+		return err
+	}
 	return nil
 }

common/service.pb.go

@@ -125,6 +125,12 @@ message Users {
   repeated User users = 1;
 }
 
+message UsersChunk {
+  repeated User users = 1;
+  uint64 index = 2;
+  bool last = 3;
+}
+
 // Service for node management and connection
 service NodeService {
   rpc Start (Backend) returns (BaseInfoResponse) {}
@@ -143,4 +149,5 @@ service NodeService {
 
   rpc SyncUser (stream User) returns (Empty) {}
   rpc SyncUsers (Users) returns (Empty) {}
+  rpc SyncUsersChunked (stream UsersChunk) returns (Empty) {}
 }