understand SSE session

[cometta]

Could you please clarify the typical duration of an SSE session after it is initiated by the client LLM?

Also, if a client goes offline for a day and the MCP server has messages queued for that client, will these messages be received by the client once it comes back online?

[4t145]

There seems no regulations on it at present. So it depends on how you implment it. In this crate's axum sse server, we didn't support it.

[erenatas]

What I find weird is, if server dies, inspectors logs that connection closed on the other side, however when you want to take any action on inspector, it does not try to establish a new session, until manually a new session is created by the client, all the messages that are sent to the server are count as client side error on the server side.

I've been testing the axum sse server implementation on Cline extension for a while, and in my opinion the server should send some sort of message to ask client to re establish a session during shutdown. Each deployment on our kubernetes cluster for example breaks ongoing sessions, leading to manual intervention.

[4t145]

@erenatas I think if client send get sse stream request with a session id, the server should response it with an error telling session not found if they cannot find it. We haven't done this so far.

I'll fix this with or after #167

And I think there could be a SessionManager trait in the future to allow server to store sessions in database or cache middleware like redis. But it need more time to redesign the whole http server side transport.

[erenatas]

And I think there could be a SessionManager trait in the future to allow server to store sessions in database or cache middleware like redis. But it need more time to redesign the whole http server side transport.

I agree

[4t145]

@erenatas Do you have a detailed process to reproduce this? It's better to give some code. I am not sure it's about the session. Because I just checked ts-sdk, it did nothing with get request with session id.

[erenatas]

Sure. Reproduction steps

1. Start MCP inspector
2. Start RMCP server with SSE
3. Connect to RMCP server via MCP inspector, and try fetching a resource
4. Stop the server and start it again
5. Try to fetch the same resource (without manually pressing reconnect button)

Logs of the errors:

2025-05-18T19:11:18.159680Z  INFO mcp_server: Starting SSE server
2025-05-18T19:11:20.519101Z DEBUG http_request{method=GET path=/sse request_id=1840b4d4936913e0 kind="server"}: mcp_server::utils::observability: Request started
2025-05-18T19:11:20.519266Z  INFO http_request{method=GET path=/sse request_id=1840b4d4936913e0 kind="server"}: rmcp::transport::sse_server: sse connection session=43e10f55-fde3-4c16-ac7c-c3264143c7cd
2025-05-18T19:11:20.519632Z DEBUG http_request{method=GET path=/sse request_id=1840b4d49372f720 kind="server"}: mcp_server::utils::observability: Request started
2025-05-18T19:11:20.519668Z  INFO http_request{method=GET path=/sse request_id=1840b4d49372f720 kind="server"}: rmcp::transport::sse_server: sse connection session=8fce701d-aa6d-41cd-9aa3-27b9e7e613a9
2025-05-18T19:11:20.519768Z DEBUG http_request{method=GET path=/sse request_id=1840b4d4937481a8 kind="server"}: mcp_server::utils::observability: Request started
2025-05-18T19:11:20.519839Z  INFO http_request{method=GET path=/sse request_id=1840b4d4937481a8 kind="server"}: rmcp::transport::sse_server: sse connection session=aa22d57d-cc68-4639-80f2-1b7b7ce77613
2025-05-18T19:11:20.519922Z DEBUG http_request{method=GET path=/sse request_id=1840b4d4936913e0 kind="server"}: mcp_server::utils::observability: Request completed successfully status=200 duration_ms=0
2025-05-18T19:11:20.519940Z DEBUG http_request{method=GET path=/sse request_id=1840b4d49372f720 kind="server"}: mcp_server::utils::observability: Request completed successfully status=200 duration_ms=0
2025-05-18T19:11:20.519955Z DEBUG http_request{method=GET path=/sse request_id=1840b4d4937481a8 kind="server"}: mcp_server::utils::observability: Request completed successfully status=200 duration_ms=0
2025-05-18T19:11:30.064416Z DEBUG http_request{method=POST path=/message request_id=1840b4d6cc5c0480 kind="server"}: mcp_server::utils::observability: Request started
2025-05-18T19:11:30.065058Z DEBUG http_request{method=POST path=/message request_id=1840b4d6cc5c0480 kind="server"}: rmcp::transport::sse_server: new client message session_id="8fce701d-aa6d-41cd-9aa3-27b9e7e613a9" Request(JsonRpcRequest { jsonrpc: JsonRpcVersion2_0, id: Number(3), request: ReadResourceRequest(Request { method: ReadResourceRequestMethod, params: ReadResourceRequestParam { uri: "service_a://by-id/5000" }, extensions: Extensions }) })
2025-05-18T19:11:30.065221Z DEBUG http_request{method=POST path=/message request_id=1840b4d6cc5c0480 kind="server"}: mcp_server::utils::observability: Request completed successfully status=202 duration_ms=0
2025-05-18T19:11:38.954368Z DEBUG http_request{method=POST path=/message request_id=1840b4d8de3ddfc8 kind="server"}: mcp_server::utils::observability: Request started
2025-05-18T19:11:38.954800Z DEBUG http_request{method=POST path=/message request_id=1840b4d8de3ddfc8 kind="server"}: rmcp::transport::sse_server: new client message session_id="8fce701d-aa6d-41cd-9aa3-27b9e7e613a9" Request(JsonRpcRequest { jsonrpc: JsonRpcVersion2_0, id: Number(4), request: ReadResourceRequest(Request { method: ReadResourceRequestMethod, params: ReadResourceRequestParam { uri: "service_a://by-owner/eatas" }, extensions: Extensions }) })
2025-05-18T19:11:38.954901Z ERROR http_request{method=POST path=/message request_id=1840b4d8de3ddfc8 kind="server"}: rmcp::transport::sse_server: send message error
2025-05-18T19:11:38.955908Z  WARN http_request{method=POST path=/message request_id=1840b4d8de3ddfc8 kind="server"}: mcp_server::utils::observability: Request completed with client error status=410 duration_ms=1
2025-05-18T19:11:50.908929Z DEBUG http_request{method=POST path=/message request_id=1840b4dba6ca6540 kind="server"}: mcp_server::utils::observability: Request started
2025-05-18T19:11:50.909155Z DEBUG http_request{method=POST path=/message request_id=1840b4dba6ca6540 kind="server"}: rmcp::transport::sse_server: new client message session_id="8fce701d-aa6d-41cd-9aa3-27b9e7e613a9" Request(JsonRpcRequest { jsonrpc: JsonRpcVersion2_0, id: Number(5), request: ReadResourceRequest(Request { method: ReadResourceRequestMethod, params: ReadResourceRequestParam { uri: "service_a://search/5000" }, extensions: Extensions }) })
2025-05-18T19:11:50.909214Z ERROR http_request{method=POST path=/message request_id=1840b4dba6ca6540 kind="server"}: rmcp::transport::sse_server: send message error
2025-05-18T19:11:50.909326Z  WARN http_request{method=POST path=/message request_id=1840b4dba6ca6540 kind="server"}: mcp_server::utils::observability: Request completed with client error status=410 duration_ms=0
2025-05-18T19:11:55.067021Z DEBUG http_request{method=POST path=/message request_id=1840b4dc9ea00f18 kind="server"}: mcp_server::utils::observability: Request started
2025-05-18T19:11:55.067369Z DEBUG http_request{method=POST path=/message request_id=1840b4dc9ea00f18 kind="server"}: rmcp::transport::sse_server: new client message session_id="8fce701d-aa6d-41cd-9aa3-27b9e7e613a9" Notification(JsonRpcNotification { jsonrpc: JsonRpcVersion2_0, notification: CancelledNotification(Notification { method: CancelledNotificationMethod, params: CancelledNotificationParam { request_id: Number(3), reason: Some("McpError: MCP error -32001: Request timed out") }, extensions: Extensions }) })
2025-05-18T19:11:55.067468Z ERROR http_request{method=POST path=/message request_id=1840b4dc9ea00f18 kind="server"}: rmcp::transport::sse_server: send message error
2025-05-18T19:11:55.068043Z  WARN http_request{method=POST path=/message request_id=1840b4dc9ea00f18 kind="server"}: mcp_server::utils::observability: Request completed with client error status=410 duration_ms=0
2025-05-18T19:12:03.980786Z DEBUG http_request{method=POST path=/message request_id=1840b4deb1ef0720 kind="server"}: mcp_server::utils::observability: Request started
2025-05-18T19:12:03.981050Z DEBUG http_request{method=POST path=/message request_id=1840b4deb1ef0720 kind="server"}: rmcp::transport::sse_server: new client message session_id="8fce701d-aa6d-41cd-9aa3-27b9e7e613a9" Notification(JsonRpcNotification { jsonrpc: JsonRpcVersion2_0, notification: CancelledNotification(Notification { method: CancelledNotificationMethod, params: CancelledNotificationParam { request_id: Number(4), reason: Some("McpError: MCP error -32001: Request timed out") }, extensions: Extensions }) })
2025-05-18T19:12:03.981154Z ERROR http_request{method=POST path=/message request_id=1840b4deb1ef0720 kind="server"}: rmcp::transport::sse_server: send message error
2025-05-18T19:12:03.981272Z  WARN http_request{method=POST path=/message request_id=1840b4deb1ef0720 kind="server"}: mcp_server::utils::observability: Request completed with client error status=410 duration_ms=0
2025-05-18T19:12:15.937913Z DEBUG http_request{method=POST path=/message request_id=1840b4e17aa0f6b8 kind="server"}: mcp_server::utils::observability: Request started
2025-05-18T19:12:15.939404Z DEBUG http_request{method=POST path=/message request_id=1840b4e17aa0f6b8 kind="server"}: rmcp::transport::sse_server: new client message session_id="8fce701d-aa6d-41cd-9aa3-27b9e7e613a9" Notification(JsonRpcNotification { jsonrpc: JsonRpcVersion2_0, notification: CancelledNotification(Notification { method: CancelledNotificationMethod, params: CancelledNotificationParam { request_id: Number(5), reason: Some("McpError: MCP error -32001: Request timed out") }, extensions: Extensions }) })
2025-05-18T19:12:15.940074Z ERROR http_request{method=POST path=/message request_id=1840b4e17aa0f6b8 kind="server"}: rmcp::transport::sse_server: send message error
2025-05-18T19:12:15.940287Z  WARN http_request{method=POST path=/message request_id=1840b4e17aa0f6b8 kind="server"}: mcp_server::utils::observability: Request completed with client error status=410 duration_ms=2

Tried to strip my project to calculator:

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    // ...
    let calculator = Calculator::new();
    let service_ct = sse_server.with_service(move || calculator.clone());

    // Wait for Ctrl+C signal
    tokio::signal::ctrl_c().await?;
    debug!("Received shutdown signal");

    // Cancel the service
    service_ct.cancel();

    Ok(())

➜  mcp-server git:(main) cargo run                         
2025-05-18T19:22:58.598625Z  INFO mcp_server: Starting SSE server
2025-05-18T19:23:00.735827Z DEBUG http_request{method=GET path=/sse request_id=1840b5779b920c40 kind="server"}: mcp_server::utils::observability: Request started
2025-05-18T19:23:00.736558Z  INFO http_request{method=GET path=/sse request_id=1840b5779b920c40 kind="server"}: rmcp::transport::sse_server: sse connection session=b123655e-e2c1-48bd-9138-014933b85659
2025-05-18T19:23:00.737822Z DEBUG http_request{method=GET path=/sse request_id=1840b5779b920c40 kind="server"}: mcp_server::utils::observability: Request completed successfully status=200 duration_ms=1
2025-05-18T19:23:00.801981Z DEBUG http_request{method=GET path=/sse request_id=1840b5779f859178 kind="server"}: mcp_server::utils::observability: Request started
2025-05-18T19:23:00.802137Z  INFO http_request{method=GET path=/sse request_id=1840b5779f859178 kind="server"}: rmcp::transport::sse_server: sse connection session=14decadb-fc9f-4e97-8690-3101fcb3bfa0
2025-05-18T19:23:00.802438Z DEBUG http_request{method=GET path=/sse request_id=1840b5779f859178 kind="server"}: mcp_server::utils::observability: Request completed successfully status=200 duration_ms=0
2025-05-18T19:23:00.856266Z DEBUG http_request{method=GET path=/sse request_id=1840b577a2c372b0 kind="server"}: mcp_server::utils::observability: Request started
2025-05-18T19:23:00.856354Z  INFO http_request{method=GET path=/sse request_id=1840b577a2c372b0 kind="server"}: rmcp::transport::sse_server: sse connection session=bca1eff7-67a1-47c7-8b9b-1db054b585a3
2025-05-18T19:23:00.856556Z DEBUG http_request{method=GET path=/sse request_id=1840b577a2c372b0 kind="server"}: mcp_server::utils::observability: Request completed successfully status=200 duration_ms=0
2025-05-18T19:23:06.421468Z DEBUG rmcp::transport::sse_server: Closed session and cleaned up resources session_id=b123655e-e2c1-48bd-9138-014933b85659
2025-05-18T19:23:06.435511Z DEBUG http_request{method=GET path=/sse request_id=1840b578ef4fa288 kind="server"}: mcp_server::utils::observability: Request started
2025-05-18T19:23:06.435625Z  INFO http_request{method=GET path=/sse request_id=1840b578ef4fa288 kind="server"}: rmcp::transport::sse_server: sse connection session=e8607298-095b-4a1f-bd16-a6b5710a22b6
2025-05-18T19:23:06.435843Z DEBUG http_request{method=GET path=/sse request_id=1840b578ef4fa288 kind="server"}: mcp_server::utils::observability: Request completed successfully status=200 duration_ms=0
2025-05-18T19:23:06.458158Z DEBUG http_request{method=POST path=/message request_id=1840b578f0a8e928 kind="server"}: mcp_server::utils::observability: Request started
2025-05-18T19:23:06.458795Z DEBUG http_request{method=POST path=/message request_id=1840b578f0a8e928 kind="server"}: rmcp::transport::sse_server: new client message session_id="e8607298-095b-4a1f-bd16-a6b5710a22b6" Request(JsonRpcRequest { jsonrpc: JsonRpcVersion2_0, id: Number(0), request: InitializeRequest(Request { method: InitializeResultMethod, params: InitializeRequestParam { protocol_version: ProtocolVersion("2025-03-26"), capabilities: ClientCapabilities { experimental: None, roots: Some(RootsCapabilities { list_changed: Some(true) }), sampling: Some({}) }, client_info: Implementation { name: "mcp-inspector", version: "0.12.0" } }, extensions: Extensions }) })
2025-05-18T19:23:06.459175Z DEBUG http_request{method=POST path=/message request_id=1840b578f0a8e928 kind="server"}: mcp_server::utils::observability: Request completed successfully status=202 duration_ms=0
2025-05-18T19:23:06.468790Z DEBUG http_request{method=POST path=/message request_id=1840b578f14bf370 kind="server"}: mcp_server::utils::observability: Request started
2025-05-18T19:23:06.468970Z DEBUG http_request{method=POST path=/message request_id=1840b578f14bf370 kind="server"}: rmcp::transport::sse_server: new client message session_id="e8607298-095b-4a1f-bd16-a6b5710a22b6" Notification(JsonRpcNotification { jsonrpc: JsonRpcVersion2_0, notification: InitializedNotification(NotificationNoParam { method: InitializedNotificationMethod, extensions: Extensions }) })
2025-05-18T19:23:06.469099Z DEBUG http_request{method=POST path=/message request_id=1840b578f14bf370 kind="server"}: mcp_server::utils::observability: Request completed successfully status=202 duration_ms=0
2025-05-18T19:23:06.469296Z  INFO rmcp::handler::server: client initialized
2025-05-18T19:23:06.469374Z  INFO serve_inner: rmcp::service: Service initialized as server peer_info=InitializeRequestParam { protocol_version: ProtocolVersion("2025-03-26"), capabilities: ClientCapabilities { experimental: None, roots: Some(RootsCapabilities { list_changed: Some(true) }), sampling: Some({}) }, client_info: Implementation { name: "mcp-inspector", version: "0.12.0" } }
2025-05-18T19:23:07.515503Z DEBUG http_request{method=POST path=/message request_id=1840b5792fae93e8 kind="server"}: mcp_server::utils::observability: Request started
2025-05-18T19:23:07.516156Z DEBUG http_request{method=POST path=/message request_id=1840b5792fae93e8 kind="server"}: rmcp::transport::sse_server: new client message session_id="e8607298-095b-4a1f-bd16-a6b5710a22b6" Request(JsonRpcRequest { jsonrpc: JsonRpcVersion2_0, id: Number(1), request: ListToolsRequest(RequestOptionalParam { method: ListToolsRequestMethod, params: Some(PaginatedRequestParam { cursor: None }), extensions: Extensions }) })
2025-05-18T19:23:07.516397Z DEBUG http_request{method=POST path=/message request_id=1840b5792fae93e8 kind="server"}: mcp_server::utils::observability: Request completed successfully status=202 duration_ms=0
2025-05-18T19:23:07.516735Z DEBUG rmcp::service: received request id=1 request=ListToolsRequest(RequestOptionalParam { method: ListToolsRequestMethod, params: Some(PaginatedRequestParam { cursor: None }), extensions: Extensions })
2025-05-18T19:23:07.517649Z DEBUG rmcp::service: response message id=1 result=ListToolsResult(ListToolsResult { next_cursor: None, tools: [Tool { name: "sum", description: Some("Calculate the sum of two numbers"), input_schema: {"properties": Object {"a": Object {"description": String("the left hand side number"), "format": String("int32"), "type": String("integer")}, "b": Object {"format": String("int32"), "type": String("integer")}}, "required": Array [String("a"), String("b")], "title": String("SumRequest"), "type": String("object")}, annotations: None }, Tool { name: "sub", description: Some("Calculate the difference of two numbers"), input_schema: {"properties": Object {"a": Object {"description": String("the left hand side number"), "format": String("int32"), "type": String("integer")}, "b": Object {"description": String("the right hand side number"), "format": String("int32"), "type": String("integer")}}, "required": Array [String("a"), String("b")], "title": String("__SUBToolCallParam"), "type": String("object")}, annotations: None }] })
2025-05-18T19:23:10.851524Z DEBUG http_request{method=POST path=/message request_id=1840b579f6856500 kind="server"}: mcp_server::utils::observability: Request started
2025-05-18T19:23:10.852092Z DEBUG http_request{method=POST path=/message request_id=1840b579f6856500 kind="server"}: rmcp::transport::sse_server: new client message session_id="e8607298-095b-4a1f-bd16-a6b5710a22b6" Request(JsonRpcRequest { jsonrpc: JsonRpcVersion2_0, id: Number(2), request: CallToolRequest(Request { method: CallToolRequestMethod, params: CallToolRequestParam { name: "sum", arguments: Some({"a": Number(1), "b": Number(2)}) }, extensions: Extensions }) })
2025-05-18T19:23:10.852326Z DEBUG http_request{method=POST path=/message request_id=1840b579f6856500 kind="server"}: mcp_server::utils::observability: Request completed successfully status=202 duration_ms=0
2025-05-18T19:23:10.852618Z DEBUG rmcp::service: received request id=2 request=CallToolRequest(Request { method: CallToolRequestMethod, params: CallToolRequestParam { name: "sum", arguments: Some({"a": Number(1), "b": Number(2)}) }, extensions: Extensions })
2025-05-18T19:23:10.852879Z DEBUG rmcp::service: response message id=2 result=CallToolResult(CallToolResult { content: [Annotated { raw: Text(RawTextContent { text: "3" }), annotations: None }], is_error: Some(false) })
^C2025-05-18T19:23:14.411983Z DEBUG mcp_server: Received shutdown signal
2025-05-18T19:23:14.412203Z  INFO rmcp::service: task cancelled
2025-05-18T19:23:14.412279Z  INFO rmcp::service: serve finished quit_reason=Cancelled

➜  mcp-server git:(main) ✗ cargo run
2025-05-18T19:23:17.374067Z  INFO mcp_server: Starting SSE server
2025-05-18T19:23:17.416837Z DEBUG http_request{method=GET path=/sse request_id=1840b57b7dd8e620 kind="server"}: mcp_server::utils::observability: Request started
2025-05-18T19:23:17.416937Z  INFO http_request{method=GET path=/sse request_id=1840b57b7dd8e620 kind="server"}: rmcp::transport::sse_server: sse connection session=6d657cff-dd0f-4a00-a966-f469596bb459
2025-05-18T19:23:17.417411Z DEBUG http_request{method=GET path=/sse request_id=1840b57b7dd8e620 kind="server"}: mcp_server::utils::observability: Request completed successfully status=200 duration_ms=0
2025-05-18T19:23:17.420248Z DEBUG http_request{method=GET path=/sse request_id=1840b57b7e0e4630 kind="server"}: mcp_server::utils::observability: Request started
2025-05-18T19:23:17.420262Z DEBUG http_request{method=GET path=/sse request_id=1840b57b7e0e55d0 kind="server"}: mcp_server::utils::observability: Request started
2025-05-18T19:23:17.420291Z  INFO http_request{method=GET path=/sse request_id=1840b57b7e0e4630 kind="server"}: rmcp::transport::sse_server: sse connection session=5cdc28ca-3b3a-4ed0-9c99-a606e279f4e1
2025-05-18T19:23:17.420311Z  INFO http_request{method=GET path=/sse request_id=1840b57b7e0e55d0 kind="server"}: rmcp::transport::sse_server: sse connection session=74f69467-e15c-4b0e-8c12-67172d7738fa
2025-05-18T19:23:17.420402Z DEBUG http_request{method=GET path=/sse request_id=1840b57b7e0e4630 kind="server"}: mcp_server::utils::observability: Request completed successfully status=200 duration_ms=0
2025-05-18T19:23:17.420407Z DEBUG http_request{method=GET path=/sse request_id=1840b57b7e0e55d0 kind="server"}: mcp_server::utils::observability: Request completed successfully status=200 duration_ms=0
2025-05-18T19:23:21.794335Z DEBUG http_request{method=POST path=/message request_id=1840b57c82c3ddd8 kind="server"}: mcp_server::utils::observability: Request started
2025-05-18T19:23:21.795534Z DEBUG http_request{method=POST path=/message request_id=1840b57c82c3ddd8 kind="server"}: rmcp::transport::sse_server: new client message session_id="6d657cff-dd0f-4a00-a966-f469596bb459" Request(JsonRpcRequest { jsonrpc: JsonRpcVersion2_0, id: Number(3), request: CallToolRequest(Request { method: CallToolRequestMethod, params: CallToolRequestParam { name: "sum", arguments: Some({"a": Number(1), "b": Number(2)}) }, extensions: Extensions }) })
2025-05-18T19:23:21.795993Z DEBUG http_request{method=POST path=/message request_id=1840b57c82c3ddd8 kind="server"}: mcp_server::utils::observability: Request completed successfully status=202 duration_ms=1
2025-05-18T19:23:46.808902Z DEBUG http_request{method=POST path=/message request_id=1840b58255bb88d0 kind="server"}: mcp_server::utils::observability: Request started
2025-05-18T19:23:46.809732Z DEBUG http_request{method=POST path=/message request_id=1840b58255bb88d0 kind="server"}: rmcp::transport::sse_server: new client message session_id="6d657cff-dd0f-4a00-a966-f469596bb459" Notification(JsonRpcNotification { jsonrpc: JsonRpcVersion2_0, notification: CancelledNotification(Notification { method: CancelledNotificationMethod, params: CancelledNotificationParam { request_id: Number(3), reason: Some("McpError: MCP error -32001: Request timed out") }, extensions: Extensions }) })
2025-05-18T19:23:46.809904Z ERROR http_request{method=POST path=/message request_id=1840b58255bb88d0 kind="server"}: rmcp::transport::sse_server: send message error
2025-05-18T19:23:46.810251Z  WARN http_request{method=POST path=/message request_id=1840b58255bb88d0 kind="server"}: mcp_server::utils::observability: Request completed with client error status=410 duration_ms=1

[4t145]

I just checked js implementation, it seems in js sdk, sse post handler doesn't request it have a session. So the rust server still waiting for connection to be established when it received list resource request.

To do this, I think we can add a method like this for SseServer

pub fn with_service_directly<S, F>(mut self, service_provider: F) -> CancellationToken
    where
        S: Service<RoleServer>,
        F: Fn() -> S + Send + 'static,
    {
        let ct = self.config.ct.clone();
        tokio::spawn(async move {
            while let Some(transport) = self.next_transport().await {
                let service = service_provider();
                let ct = self.config.ct.child_token();
                tokio::spawn(async move {
                    let server =
                        serve_directly_with_ct(service, transport, Default::default(), ct).await;
                    server.waiting().await?;
                    tokio::io::Result::Ok(())
                });
            }
        });
        ct
    }

And I tried this with inspector, it works.

And may also need to make peer_info in peer wrapped in OnceLock, so it can be settled when directly served service handling the initialize request

[erenatas]

You are fast 😄 thanks for having a look!