Function TestIPCSocketResponseHasNoUAPIErrnoTrailer

integration/ipc_test.go:215–255

(t *testing.T)

}

func TestIPCSocketResponseHasNoUAPIErrnoTrailer(t *testing.T) {
	defer goleak.VerifyNone(t)
	vh, errs := setupTwoNodeHarness(t)
	defer vh.Stop()

	time.Sleep(1 * time.Second)

	a := vh.Nylons[vh.IndexOf("a")].Load()
	client, server := net.Pipe()
	defer client.Close()
	go a.Device.IpcHandle(server)

	m := protojson.MarshalOptions{EmitUnpopulated: true}
	data, err := m.Marshal(&protocol.IpcRequest{
		Request: &protocol.IpcRequest_Status{Status: &protocol.StatusRequest{}},
	})
	require.NoError(t, err)

	_, err = client.Write(append(append([]byte("get=nylon\n"), data...), '\n'))
	require.NoError(t, err)

	reader := bufio.NewReader(client)
	line, err := reader.ReadBytes('\n')
	require.NoError(t, err)

	resp := &protocol.IpcResponse{}
	um := protojson.UnmarshalOptions{DiscardUnknown: true}
	require.NoError(t, um.Unmarshal(line, resp))
	require.True(t, resp.Ok)

	require.NoError(t, client.SetReadDeadline(time.Now().Add(100*time.Millisecond)))
	extra, err := reader.ReadString('\n')
	require.Error(t, err)
	require.NotContains(t, extra, "errno=")

	select {
	case err := <-errs:
		t.Fatal(err)
	default:
	}
}