Add condition 5 and openai model

app.py

@@ -47,7 +47,7 @@ if 'inserted' not in st.session_state:
     st.session_state.gotit = False
     st.session_state.submitted = False
     st.session_state.inserted = 0
-    st.session_state["model"] = "deepseek/deepseek-chat-v3-0324"
+    st.session_state["model"] = "openai/gpt-5.2-chat"
     st.session_state.max_messages = 50
     st.session_state.messages = []
     st.session_state.user_data = {}
@@ -69,10 +69,10 @@ if 'inserted' not in st.session_state:
     st.session_state.convo_start_time = ''
 
 if 'p' not in st.query_params or st.query_params['p'] == '':
-    st.query_params['p'] = '4'
-    #st.query_params['p'] = st.radio("Select a condition for the conversation",
-    #            ['', '1', '2', '3', '4'],
-    #            help="1 = base, 2 = bridging, 3 = personalization, 4 = bridging + personalization")
+    #st.query_params['p'] = '1'
+    st.query_params['p'] = st.radio("Select a condition for the conversation",
+                ['', '1', '2', '3', '4', '5'],
+                help="1 = base, 2 = bridging, 3 = personalization, 4 = bridging + personalization, 5 = true control")
 
 if 'id' not in st.query_params:
     st.query_params['id'] = st.session_state.random_pid
@@ -86,6 +86,7 @@ def setup_messages():
     # 2 = bridging,
     # 3 = personalization,
     # 4 = bridging + personalization
+    # 5 = true control 
 
     if st.query_params["p"] == "1":
         st.session_state.system_message = st.session_state.base_text 
@@ -95,6 +96,8 @@ def setup_messages():
         st.session_state.system_message = format_personalization(st.session_state.personalization_text)
     elif st.query_params["p"] == "4":
         st.session_state.system_message = format_personalization(st.session_state.both_text)
+    elif st.query_params["p"] == "5":
+        st.session_state.system_message = st.session_state.base_text 
 
     st.session_state.messages = [{ "role": "system", "content": st.session_state.system_message}]
     st.session_state.convo_start_time = datetime.now()
@@ -217,31 +220,42 @@ elif prompt := st.chat_input("Type to ask a question or respond..."):
     with st.chat_message("user"):
         st.markdown(prompt)
 
-    with st.chat_message("assistant"):
-        try:
-            stream = client.chat.completions.create(
-                model=st.session_state["model"],
-                messages=[
-                    {"role": m["role"], "content": m["content"]}
-                    for m in st.session_state.messages
-                ],
-                stream=True
-            )
-            
-            response = st.write_stream(stream)
+    if st.query_params["p"] = "5":
+        rate_limit_message = """
+                    An error has occured with the chatbot. Please submit the conversation. Do not worry, this will not influence your compensation.
+                """
+        st.session_state.messages.append(
+                    {"role": "assistant", "content": rate_limit_message}
+                )
+        st.session_state.max_messages = len(st.session_state.messages)
+        st.rerun()
 
-            st.session_state.messages.append(
-                {"role": "assistant", "content": response}
-            )
-        except:
-            rate_limit_message = """
-                An error has occured or you've reached the maximum conversation length. Please submit the conversation.
-            """
-            st.session_state.messages.append(
-                {"role": "assistant", "content": rate_limit_message}
-            )
-            st.session_state.max_messages = len(st.session_state.messages)
-            st.rerun()
+    else:
+        with st.chat_message("assistant"):
+            try:
+                stream = client.chat.completions.create(
+                    model=st.session_state["model"],
+                    messages=[
+                        {"role": m["role"], "content": m["content"]}
+                        for m in st.session_state.messages
+                    ],
+                    stream=True
+                )
+                
+                response = st.write_stream(stream)
+    
+                st.session_state.messages.append(
+                    {"role": "assistant", "content": response}
+                )
+            except:
+                rate_limit_message = """
+                    An error has occured or you've reached the maximum conversation length. Please submit the conversation.
+                """
+                st.session_state.messages.append(
+                    {"role": "assistant", "content": rate_limit_message}
+                )
+                st.session_state.max_messages = len(st.session_state.messages)
+                st.rerun()
 
 if len(st.session_state.messages) > 10 or st.session_state.max_messages == len(st.session_state.messages):
     columns = st.columns((1,1,1))
@@ -255,7 +269,7 @@ if len(st.session_state.messages) > 10 or st.session_state.max_messages == len(s
 
             with MongoClient(st.secrets["mongo"],server_api=ServerApi('1')) as client:
                     db = client.bridge
-                    collection = db.app
+                    collection = db.app2
                     user_data = st.session_state.user_data
 
                     collection.insert_one(user_data)