def search_response_to_message()

in python/src/tablestore_for_agent_memory/util/tablestore_helper.py [0:0]


    def search_response_to_message(search_response: tablestore.SearchResponse) -> (List[Message], Optional[str]):
        messages = []
        next_token = search_response.next_token
        if next_token:
            next_token = base64.b64encode(next_token).decode('utf-8')
        else:
            next_token = None
        for hit in search_response.search_hits:
            row = hit.row
            session_id = row[0][0][1]
            create_time = row[0][1][1]
            message_id = row[0][2][1]
            meta_data = {}
            content = None
            for col in row[1]:
                key = col[0]
                val = col[1]
                if key == "content":
                    content = val
                    continue
                meta_data[key] = val
            message = Message(session_id=session_id, message_id=message_id, create_time=create_time, content=content, metadata=meta_data)
            messages.append(message)
        return messages, next_token