@@ -117,13 +117,10 @@ async def on_message(
117
117
ctx = context .fastmcp_context
118
118
assert isinstance (ctx , Context ), f'Expecting Context, got { type (ctx )} .'
119
119
120
- import uuid
121
-
122
- if not hasattr (ctx .session , 'uuid' ):
123
- ctx .session .uuid = str (uuid .uuid4 ())
124
120
LOG .info (
125
- f'[SessionStateMiddleware] Before creating session state | '
126
- f'| existing keys={ list (ctx .session .state .keys ()) if hasattr (ctx .session , "state" ) else []} '
121
+ f'[SessionStateMiddleware] Start | '
122
+ f'session_id={ ctx .session_id } | '
123
+ f'existing_keys={ list (getattr (ctx .session , "state" , {}).keys ())} '
127
124
)
128
125
129
126
if not isinstance (ctx .session , MagicMock ):
@@ -169,17 +166,20 @@ async def on_message(
169
166
170
167
LOG .info (
171
168
f'[SessionStateMiddleware] After creating session state | '
172
- f'session_uuid={ ctx .session .uuid } | keys={ list (ctx .session .state .keys ())} '
169
+ f'session_id={ ctx .session_id } | '
170
+ f'keys={ list (ctx .session .state .keys ())} '
173
171
)
174
172
175
173
try :
176
174
return await call_next (context )
177
175
finally :
178
- LOG .info (
179
- f'[SessionStateMiddleware] Clearing session state | '
180
- f'session_uuid={ ctx .session .uuid } | keys_before_clear={ list (ctx .session .state .keys ())} '
181
- )
182
- ctx .session .state = {}
176
+ # LOG.info(
177
+ # f'[SessionStateMiddleware] Clearing session state | '
178
+ # f'session_id={ctx.session_id} | '
179
+ # f'keys={list(ctx.session.state.keys())}'
180
+ # )
181
+ # ctx.session.state = {}
182
+ pass
183
183
184
184
@staticmethod
185
185
def _create_session_state (config : Config ) -> dict [str , Any ]:
0 commit comments