Merge branch 'feature-global-state' into 'feature-wormhole'

Update the conversation manager's inputs from and outputs to Turn.io

See merge request tangibleai/community/mathtext-fastapi!15

mathtext_fastapi/v2_conversation_manager.py

@@ -153,21 +153,53 @@ def lookup_local_state(next_state):
     return microlesson
 
 
+def create_text_message(message_text, whatsapp_id):
+    """ Fills a template with input values to send a text message to Whatsapp
+
+    Inputs
+    - message_text: str - the content that the message should display
+    - whatsapp_id: str - the message recipient's phone number
+
+    Outputs
+    - message_data: dict - a preformatted template filled with inputs
+    """
+    message_data = {
+        "preview_url": False,
+        "recipient_type": "individual",
+        "to": whatsapp_id,
+        "type": "text",
+        "text": {
+            "body": message_text
+        }
+    }
+    return message_data
+
+
 def manage_conversation_response(data_json):
     """ Calls functions necessary to determine message and context data """
     print("V2 ENDPOINT")
 
     user_message = ''
+    # whatsapp_id = data_json['author_id']
+    message_data = data_json['message_data']
+    context_data = data_json['context_data']
+    whatsapp_id = message_data['author_id']
+    print("MESSAGE DATA")
+    print(message_data)
+    print("CONTEXT DATA")
+    print(context_data)
+    print("=================")
 
     # nlu_response = evaluate_message_with_nlu(message_data)
 
-    context_data = {
-        'contact_uuid': 'abcdefg',
-        'current_state': 'N1.1.1_G2',
-        'user_message': '1',
-        'local_state': ''
-    }
+    # context_data = {
+    #     'contact_uuid': 'abcdefg',
+    #     'current_state': 'N1.1.1_G2',
+    #     'user_message': '1',
+    #     'local_state': ''
+    # }
     print("STEP 1")
+    print(data_json)
     if not context_data['current_state']:
         context_data['current_state'] = 'N1.1.1_G1'
 
@@ -191,6 +223,35 @@ def manage_conversation_response(data_json):
 
     microlesson_content = retrieve_microlesson_content(context_data, context_data['user_message'], microlesson, context_data['contact_uuid'])
 
+    headers = {
+        'Authorization': f"Bearer {os.environ.get('TURN_AUTHENTICATION_TOKEN')}",
+        'Content-Type': 'application/json'
+    }
+
+    # Send all messages for the current state before a user input prompt (text/button input request)
+    for message in microlesson_content['messages']:
+        data = create_text_message(message, whatsapp_id)
+
+        print("data")
+        print(data)
+
+        r = requests.post(
+            f'https://whatsapp.turn.io/v1/messages',
+            data=json.dumps(data),
+            headers=headers
+        )
+
     print("STEP 4")
     # combine microlesson content and context_data object
-    return context_data
+
+    updated_context = {
+        "context": {
+            "contact_id": whatsapp_id,
+            "contact_uuid": context_data['contact_uuid'],
+            "state": microlesson_content['state'],
+            "bot_message": microlesson_content['input_prompt'],
+            "user_message": user_message,
+            "type": 'ask'
+        }
+    }
+    return updated_context

scripts/make_request.py

@@ -22,7 +22,11 @@ def add_message_text_to_sample_object(message_text):
     message_data = '{' + f'"author_id": "+57787919091", "author_type": "OWNER", "contact_uuid": "j43hk26-2hjl-43jk-hnk2-k4ljl46j0ds09", "message_body": "{message_text}", "message_direction": "inbound", "message_id": "4kl209sd0-a7b8-2hj3-8563-3hu4a89b32", "message_inserted_at": "2023-01-10T02:37:28.477940Z", "message_updated_at": "2023-01-10T02:37:28.487319Z"' + '}'
     # context_data = '{' + '"user":"", "state":"addition-question-sequence", "bot_message":"", "user_message":"{message_text}"' + '}'
 
-    context_data = '{' + '"user":"", "state":"start-conversation", "bot_message":"", "user_message":"{message_text}"' + '}'
+    # V1
+    # context_data = '{' + '"user":"", "state":"start-conversation", "bot_message":"", "user_message":"{message_text}"' + '}'
+
+    #V2
+    context_data = '{' + '"contact_uuid": "j43hk26-2hjl-43jk-hnk2-k4ljl46j0ds09", "current_state":"", "local_state": "", "user_message":""' + '}'
 
     # context_data = '{' + '"user":"", "state":"addition-question-sequence", "bot_message":"", "user_message":"{message_text}","text": "What is 2+3?","question_numbers": [4,3],"right_answer": 7,"number_correct": 2, "number_incorrect": 0, "hints_used": 0, "level": "easy"' + '}'
 
@@ -76,6 +80,7 @@ def run_simulated_request(endpoint, sample_answer, context=None):
 # run_simulated_request('nlu', 'Today is a wonderful day')
 # run_simulated_request('nlu', 'IDK 5?')
 run_simulated_request('v2/manager', '')
+run_simulated_request('v2/manager', '5')
 # run_simulated_request('manager', '')
 # run_simulated_request('manager', 'add')
 # run_simulated_request('manager', 'subtract')