Method newFragment

pkg/server/controllers/sync.go:133–212

(userID, userMaxUSN, afterUSN, limit int)

}

func (s *Sync) newFragment(userID, userMaxUSN, afterUSN, limit int) (SyncFragment, error) {
	var notes []database.Note
	if err := s.app.DB.Where("user_id = ? AND usn > ? AND usn <= ?", userID, afterUSN, userMaxUSN).Order("usn ASC").Limit(limit).Find(&notes).Error; err != nil {
		return SyncFragment{}, nil
	}
	var books []database.Book
	if err := s.app.DB.Where("user_id = ? AND usn > ? AND usn <= ?", userID, afterUSN, userMaxUSN).Order("usn ASC").Limit(limit).Find(&books).Error; err != nil {
		return SyncFragment{}, nil
	}

	var items []usnItem
	for _, note := range notes {
		i := usnItem{
			usn: note.USN,
			val: note,
		}
		items = append(items, i)
	}
	for _, book := range books {
		i := usnItem{
			usn: book.USN,
			val: book,
		}
		items = append(items, i)
	}

	// order by usn in ascending order
	sort.Slice(items, func(i, j int) bool {
		return items[i].usn < items[j].usn
	})

	fragNotes := []SyncFragNote{}
	fragBooks := []SyncFragBook{}
	fragExpungedNotes := []string{}
	fragExpungedBooks := []string{}

	fragMaxUSN := 0
	for i := 0; i < limit; i++ {
		if i > len(items)-1 {
			break
		}

		item := items[i]

		fragMaxUSN = item.usn

		switch v := item.val.(type) {
		case database.Note:
			note := item.val.(database.Note)

			if note.Deleted {
				fragExpungedNotes = append(fragExpungedNotes, note.UUID)
			} else {
				fragNotes = append(fragNotes, NewFragNote(note))
			}
		case database.Book:
			book := item.val.(database.Book)