Function TestPriorityQueueUpdateObjectAsJSON

priority_queue_test.go:798–896

(t *testing.T)

}

func TestPriorityQueueUpdateObjectAsJSON(t *testing.T) {
	file := fmt.Sprintf("test_db_%d", time.Now().UnixNano())
	pq, err := OpenPriorityQueue(file, ASC)
	if err != nil {
		t.Error(err)
	}
	defer pq.Drop()

	type subObject struct {
		Value *int
	}

	type object struct {
		Priority  uint8
		Value     int
		SubObject subObject
	}

	for p := 0; p <= 4; p++ {
		for i := 1; i <= 10; i++ {
			obj := object{
				Priority: uint8(p),
				Value:    i,
				SubObject: subObject{
					Value: &i,
				},
			}

			if _, err = pq.EnqueueObjectAsJSON(uint8(p), obj); err != nil {
				t.Error(err)
			}
		}
	}

	item, err := pq.PeekByPriorityID(0, 3)
	if err != nil {
		t.Error(err)
	}

	oldCompObjVal := 3
	oldCompObj := object{
		Priority: 0,
		Value:    3,
		SubObject: subObject{
			Value: &oldCompObjVal,
		},
	}
	newCompObjVal := 33
	newCompObj := object{
		Priority: 0,
		Value:    33,
		SubObject: subObject{
			Value: &newCompObjVal,
		},
	}

	var obj object
	if err := item.ToObjectFromJSON(&obj); err != nil {