sliding-sync/state/typing_table_test.go

package state

import (
	"reflect"
	"testing"
)

func TestTypingTable(t *testing.T) {
	db, close := connectToDB(t)
	defer close()
	userIDs := []string{
		"@alice:localhost",
		"@bob:localhost",
	}
	roomID := "!foo:localhost"
	table := NewTypingTable(db)
	lastStreamID := int64(-1)

	setAndCheck := func() {
		streamID, err := table.SetTyping(roomID, userIDs)
		if err != nil {
			t.Fatalf("failed to SetTyping: %s", err)
		}
		if streamID == 0 {
			t.Errorf("SetTyping: streamID was not returned")
		}
		if lastStreamID >= streamID {
			t.Errorf("SetTyping: streamID returned should always be increasing but it wasn't, got %d, last %d", streamID, lastStreamID)
		}
		lastStreamID = streamID
		gotUserIDs, _, err := table.Typing(roomID, streamID-1, lastStreamID)
		if err != nil {
			t.Fatalf("failed to Typing: %s", err)
		}
		if !reflect.DeepEqual(gotUserIDs, userIDs) {
			t.Errorf("got typing users %v want %v", gotUserIDs, userIDs)
		}
	}
	setAndCheck()
	userIDs = userIDs[1:]
	userIDs = append(userIDs, "@charlie:localhost")
	setAndCheck()
	userIDs = []string{}
	setAndCheck()
	highest, err := table.SelectHighestID()
	if err != nil {
		t.Fatalf("SelectHighestID: %s", err)
	}
	if highest != lastStreamID {
		t.Fatalf("SelectHighestID: got %d want %d", highest, lastStreamID)
	}
}