Function TestSubsUpdate

server/db/rethinkdb/tests/rethink_test.go:928–970

(t *testing.T)

}

func TestSubsUpdate(t *testing.T) {
	update := map[string]any{
		"UpdatedAt": testData.Now.Add(22 * time.Minute),
	}
	err := adp.SubsUpdate(testData.Topics[0].Id, types.ParseUserId("usr"+testData.Users[0].Id), update)
	if err != nil {
		t.Fatal(err)
	}

	cursor, err := rdb.Table("subscriptions").Get(testData.Topics[0].Id + ":" + testData.Users[0].Id).
		Field("UpdatedAt").Run(conn)
	if err != nil {
		t.Fatal(err)
	}
	defer cursor.Close()

	var got time.Time
	if err = cursor.One(&got); err != nil {
		t.Fatal(err)
	}
	if !got.Equal(update["UpdatedAt"].(time.Time)) {
		t.Error(mismatchErrorString("UpdatedAt", got, update["UpdatedAt"]))
	}

	err = adp.SubsUpdate(testData.Topics[1].Id, types.ZeroUid, update)
	if err != nil {
		t.Fatal(err)
	}

	cursor2, err := rdb.Table("subscriptions").GetAllByIndex("Topic", testData.Topics[1].Id).
		Field("UpdatedAt").Limit(1).Run(conn)
	if err != nil {
		t.Fatal(err)
	}
	defer cursor2.Close()

	if err = cursor2.One(&got); err != nil {
		t.Fatal(err)
	}
	if !got.Equal(update["UpdatedAt"].(time.Time)) {
		t.Error(mismatchErrorString("UpdatedAt", got, update["UpdatedAt"]))
	}
}

func TestSubsDelete(t *testing.T) {
	err := adp.SubsDelete(testData.Topics[1].Id, types.ParseUserId("usr"+testData.Users[0].Id))