StreamInOut silently ignores invalid RequestInterface messages

[nickpokhilko]

Hi there!

When using

api.streamInOut<RequestInterface, ResponseInterface>(...)

there is an issue with how incoming messages are handled.
If the client sends a message that does not fully match the declared RequestInterface, it never reaches the polling loop:

for await (const message of this.#stream) {
  ...
}

For example, given:

interface RequestInterface {
  prop1: string;
  prop2: string;
}

and the client sends:

await stream.send({ prop1: "test" });

the message is successfully sent to the socket, but Encore silently ignores it. No warnings or errors are triggered, making the issue hard to debug.
This results in the server never receiving the message in the stream loop, even though it was transmitted.

[fredr]

Hi!

The parsing and validation of the messages run on the server side, and are logged as warnings, but the default level is set to error when you run via encore run. You can override that by setting the env variable ENCORE_RUNTIME_LOG, e.g:

$ ENCORE_RUNTIME_LOG=warn encore run