Function TestRequestInvalidFilename

lib/protocol/protocol_test.go:623–650

(t *testing.T)

}

func TestRequestInvalidFilename(t *testing.T) {
	m := newTestModel()
	rw := testutil.NewBlockingRW()
	c := getRawConnection(NewConnection(c0ID, rw, &testutil.NoopRW{}, testutil.NoopCloser{}, m, new(mockedConnectionInfo), CompressionAlways, testKeyGen))
	c.Start()
	defer closeAndWait(c, rw)

	c.inbox <- &bep.ClusterConfig{}
	c.inbox <- &bep.Request{
		Id:   1,
		Name: "../escape",
		Size: 1024,
	}

	select {
	case <-c.dispatcherLoopStopped:
	case <-time.After(time.Second):
		t.Fatal("timed out before dispatcher loop terminated")
	}

	err := m.closedError()
	if err == nil {
		t.Fatal("expected connection to be closed with an error")
	}
	if !strings.Contains(err.Error(), "protocol error") {
		t.Errorf("expected a protocol error, got %v", err)
	}
}

func TestIndexIDString(t *testing.T) {
	// Index ID is a 64 bit, zero padded hex integer.