@@ -26,7 +26,10 @@ def __init__(self, api_key: str | None = None, base_url: str | None = None):
2626 if not api_key :
2727 raise ValueError ("MemOS API key is required" )
2828
29- self .headers = {"Content-Type" : "application/json" , "Authorization" : f"Token { api_key } " }
29+ self .headers = {
30+ "Content-Type" : "application/json" ,
31+ "Authorization" : f"Token { api_key } "
32+ }
3033
3134 def _validate_required_params (self , ** params ):
3235 """Validate required parameters - if passed, they must not be empty"""
@@ -42,14 +45,15 @@ def get_message(
4245 self ._validate_required_params (user_id = user_id )
4346
4447 url = f"{ self .base_url } /get/message"
45- payload = {"user_id" : user_id , "conversation_id" : conversation_id }
48+ payload = { "user_id" : user_id , "conversation_id" : conversation_id }
4649 for retry in range (MAX_RETRY_COUNT ):
4750 try :
4851 response = requests .post (
4952 url , data = json .dumps (payload ), headers = self .headers , timeout = 30
5053 )
5154 response .raise_for_status ()
5255 response_data = response .json ()
56+
5357 return MemOSGetMessagesResponse (** response_data )
5458 except Exception as e :
5559 logger .error (f"Failed to get messages (retry { retry + 1 } /3): { e } " )
@@ -66,14 +70,15 @@ def add_message(
6670 )
6771
6872 url = f"{ self .base_url } /add/message"
69- payload = {"messages" : messages , "user_id" : user_id , "conversation_id" : conversation_id }
73+ payload = { "messages" : messages , "user_id" : user_id , "conversation_id" : conversation_id }
7074 for retry in range (MAX_RETRY_COUNT ):
7175 try :
7276 response = requests .post (
7377 url , data = json .dumps (payload ), headers = self .headers , timeout = 30
7478 )
7579 response .raise_for_status ()
7680 response_data = response .json ()
81+
7782 return MemOSAddResponse (** response_data )
7883 except Exception as e :
7984 logger .error (f"Failed to add memory (retry { retry + 1 } /3): { e } " )
@@ -102,6 +107,7 @@ def search_memory(
102107 )
103108 response .raise_for_status ()
104109 response_data = response .json ()
110+
105111 return MemOSSearchResponse (** response_data )
106112 except Exception as e :
107113 logger .error (f"Failed to search memory (retry { retry + 1 } /3): { e } " )
0 commit comments