Method SyncUsersChunked

controller/rest/user.go:82–147

(w http.ResponseWriter, r *http.Request)

}

func (s *Service) SyncUsersChunked(w http.ResponseWriter, r *http.Request) {
	reader := bufio.NewReader(r.Body)
	defer r.Body.Close()

	chunks := make(map[uint64][]*common.User)
	var (
		lastIndex uint64
		sawLast   bool
	)

	for {
		size, err := binary.ReadUvarint(reader)
		if errors.Is(err, io.EOF) {
			break
		}
		if err != nil {
			http.Error(w, fmt.Sprintf("failed to read chunk length: %v", err), http.StatusBadRequest)
			return
		}
		if size == 0 {
			continue
		}

		payload := make([]byte, size)
		if _, err = io.ReadFull(reader, payload); err != nil {
			http.Error(w, fmt.Sprintf("failed to read chunk payload: %v", err), http.StatusBadRequest)
			return
		}

		chunk := &common.UsersChunk{}
		if err = proto.Unmarshal(payload, chunk); err != nil {
			http.Error(w, fmt.Sprintf("failed to decode chunk: %v", err), http.StatusBadRequest)
			return
		}

		chunks[chunk.GetIndex()] = append(chunks[chunk.GetIndex()], chunk.GetUsers()...)

		if chunk.GetLast() {
			sawLast = true
			lastIndex = chunk.GetIndex()
			break
		}
	}

	users, err := controller.BuildUsersFromChunks(chunks, lastIndex, sawLast)
	if err != nil {
		http.Error(w, err.Error(), http.StatusBadRequest)
		return
	}

	// Large chunk: update in-memory then restart (no API calls).
	if len(users) > 100 {
		if err := s.Backend().UpdateUsersAndRestart(r.Context(), users); err != nil {
			http.Error(w, err.Error(), http.StatusInternalServerError)
			return
		}
	} else {
		// Small chunk: update via API without restart.