rename memories to conversations

app/lib/backend/http/api/conversations.dart

@@ -43,7 +43,7 @@ Future<List<ServerConversation>> getConversations(
     bool includeDiscarded = true}) async {
   var response = await makeApiCall(
       url:
-          '${Env.apiBaseUrl}v1/memories?include_discarded=$includeDiscarded&limit=$limit&offset=$offset&statuses=${statuses.map((val) => val.toString().split(".").last).join(",")}',
+          '${Env.apiBaseUrl}v1/conversations?include_discarded=$includeDiscarded&limit=$limit&offset=$offset&statuses=${statuses.map((val) => val.toString().split(".").last).join(",")}',
       headers: {},
       method: 'GET',
       body: '');
@@ -53,17 +53,17 @@ Future<List<ServerConversation>> getConversations(
     var body = utf8.decode(response.bodyBytes);
     var memories =
         (jsonDecode(body) as List<dynamic>).map((conversation) => ServerConversation.fromJson(conversation)).toList();
-    debugPrint('getMemories length: ${memories.length}');
+    debugPrint('getConversations length: ${memories.length}');
     return memories;
   } else {
-    debugPrint('getMemories error ${response.statusCode}');
+    debugPrint('getConversations error ${response.statusCode}');
   }
   return [];
 }
 
 Future<ServerConversation?> reProcessConversationServer(String conversationId) async {
   var response = await makeApiCall(
-    url: '${Env.apiBaseUrl}v1/memories/$conversationId/reprocess',
+    url: '${Env.apiBaseUrl}v1/conversations/$conversationId/reprocess',
     headers: {},
     method: 'POST',
     body: '',
@@ -78,7 +78,7 @@ Future<ServerConversation?> reProcessConversationServer(String conversationId) a
 
 Future<bool> deleteConversationServer(String conversationId) async {
   var response = await makeApiCall(
-    url: '${Env.apiBaseUrl}v1/memories/$conversationId',
+    url: '${Env.apiBaseUrl}v1/conversations/$conversationId',
     headers: {},
     method: 'DELETE',
     body: '',
@@ -90,7 +90,7 @@ Future<bool> deleteConversationServer(String conversationId) async {
 
 Future<ServerConversation?> getConversationById(String conversationId) async {
   var response = await makeApiCall(
-    url: '${Env.apiBaseUrl}v1/memories/$conversationId',
+    url: '${Env.apiBaseUrl}v1/conversations/$conversationId',
     headers: {},
     method: 'GET',
     body: '',
@@ -105,7 +105,7 @@ Future<ServerConversation?> getConversationById(String conversationId) async {
 
 Future<bool> updateConversationTitle(String conversationId, String title) async {
   var response = await makeApiCall(
-    url: '${Env.apiBaseUrl}v1/memories/$conversationId/title?title=$title',
+    url: '${Env.apiBaseUrl}v1/conversations/$conversationId/title?title=$title',
     headers: {},
     method: 'PATCH',
     body: '',
@@ -117,7 +117,7 @@ Future<bool> updateConversationTitle(String conversationId, String title) async
 
 Future<List<ConversationPhoto>> getConversationPhotos(String conversationId) async {
   var response = await makeApiCall(
-    url: '${Env.apiBaseUrl}v1/memories/$conversationId/photos',
+    url: '${Env.apiBaseUrl}v1/conversations/$conversationId/photos',
     headers: {},
     method: 'GET',
     body: '',
@@ -156,7 +156,7 @@ class TranscriptsResponse {
 
 Future<TranscriptsResponse> getConversationTranscripts(String conversationId) async {
   var response = await makeApiCall(
-    url: '${Env.apiBaseUrl}v1/memories/$conversationId/transcripts',
+    url: '${Env.apiBaseUrl}v1/conversations/$conversationId/transcripts',
     headers: {},
     method: 'GET',
     body: '',
@@ -172,7 +172,7 @@ Future<TranscriptsResponse> getConversationTranscripts(String conversationId) as
 
 Future<bool> hasConversationRecording(String conversationId) async {
   var response = await makeApiCall(
-    url: '${Env.apiBaseUrl}v1/memories/$conversationId/recording',
+    url: '${Env.apiBaseUrl}v1/conversations/$conversationId/recording',
     headers: {},
     method: 'GET',
     body: '',
@@ -194,7 +194,7 @@ Future<bool> assignConversationTranscriptSegment(
 }) async {
   String assignType = isUser != null ? 'is_user' : 'person_id';
   var response = await makeApiCall(
-    url: '${Env.apiBaseUrl}v1/memories/$conversationId/segments/$segmentIdx/assign?value=${isUser ?? personId}'
+    url: '${Env.apiBaseUrl}v1/conversations/$conversationId/segments/$segmentIdx/assign?value=${isUser ?? personId}'
         '&assign_type=$assignType&use_for_speech_training=$useForSpeechTraining',
     headers: {},
     method: 'PATCH',
@@ -214,7 +214,8 @@ Future<bool> assignConversationSpeaker(
 }) async {
   String assignType = isUser ? 'is_user' : 'person_id';
   var response = await makeApiCall(
-    url: '${Env.apiBaseUrl}v1/memories/$conversationId/assign-speaker/$speakerId?value=${isUser ? 'true' : personId}'
+    url:
+        '${Env.apiBaseUrl}v1/conversations/$conversationId/assign-speaker/$speakerId?value=${isUser ? 'true' : personId}'
         '&assign_type=$assignType&use_for_speech_training=$useForSpeechTraining',
     headers: {},
     method: 'PATCH',
@@ -227,7 +228,7 @@ Future<bool> assignConversationSpeaker(
 
 Future<bool> setConversationVisibility(String conversationId, {String visibility = 'shared'}) async {
   var response = await makeApiCall(
-    url: '${Env.apiBaseUrl}v1/memories/$conversationId/visibility?value=$visibility&visibility=$visibility',
+    url: '${Env.apiBaseUrl}v1/conversations/$conversationId/visibility?value=$visibility&visibility=$visibility',
     headers: {},
     method: 'PATCH',
     body: '',
@@ -247,7 +248,7 @@ Future<bool> setConversationEventsState(
     'values': values,
   }));
   var response = await makeApiCall(
-    url: '${Env.apiBaseUrl}v1/memories/$conversationId/events',
+    url: '${Env.apiBaseUrl}v1/conversations/$conversationId/events',
     headers: {},
     method: 'PATCH',
     body: jsonEncode({
@@ -270,7 +271,7 @@ Future<bool> setConversationActionItemState(
     'values': values,
   }));
   var response = await makeApiCall(
-    url: '${Env.apiBaseUrl}v1/memories/$conversationId/action-items',
+    url: '${Env.apiBaseUrl}v1/conversations/$conversationId/action-items',
     headers: {},
     method: 'PATCH',
     body: jsonEncode({
@@ -285,7 +286,7 @@ Future<bool> setConversationActionItemState(
 
 Future<bool> deleteConversationActionItem(String conversationId, ActionItem item) async {
   var response = await makeApiCall(
-    url: '${Env.apiBaseUrl}v1/memories/$conversationId/action-items',
+    url: '${Env.apiBaseUrl}v1/conversations/$conversationId/action-items',
     headers: {},
     method: 'DELETE',
     body: jsonEncode({
@@ -364,7 +365,7 @@ Future<(List<ServerConversation>, int, int)> searchConversationsServer(
 }) async {
   debugPrint(Env.apiBaseUrl);
   var response = await makeApiCall(
-    url: '${Env.apiBaseUrl}v1/memories/search',
+    url: '${Env.apiBaseUrl}v1/conversations/search',
     headers: {},
     method: 'POST',
     body:

app/lib/pages/apps/providers/add_app_provider.dart

@@ -434,7 +434,7 @@ class AddAppProvider extends ChangeNotifier {
         }
         if (capability.title == 'memories') {
           if (conversationPromptController.text.isEmpty) {
-            AppSnackbar.showSnackbarError('Please enter a memory prompt for your app');
+            AppSnackbar.showSnackbarError('Please enter a conversation prompt for your app');
             return false;
           }
         }

app/lib/pages/settings/privacy.dart

@@ -59,7 +59,7 @@ class PrivacyInfoPage extends StatelessWidget {
             _buildBulletPoint('Manual Memories: We track when you add or create manual memories.'),
             _buildBulletPoint(
                 'User Properties: We track user properties such as occupation, usage location, and age range.'),
-            _buildBulletPoint('Memory Re-processing: We track when you re-process a memory.'),
+            _buildBulletPoint('Conversation Re-processing: We track when you re-process a conversation.'),
             _buildBulletPoint(
                 'Backups: We track when backups are enabled or disabled, and when a backups password is set.'),
             _buildBulletPoint('Support: We track when you contact support.'),

app/lib/providers/capture_provider.dart

@@ -517,7 +517,7 @@ class CaptureProvider extends ChangeNotifier
   void onMessageEventReceived(ServerMessageEvent event) {
     if (event.type == MessageEventType.conversationProcessingStarted) {
       if (event.conversation == null) {
-        debugPrint("Memory data not received in event. Content is: $event");
+        debugPrint("Conversation data not received in event. Content is: $event");
         return;
       }
       conversationProvider!.addProcessingConversation(event.conversation!);
@@ -538,7 +538,7 @@ class CaptureProvider extends ChangeNotifier
 
     if (event.type == MessageEventType.lastConversation) {
       if (event.memoryId == null) {
-        debugPrint("Memory ID not received in last_memory event. Content is: $event");
+        debugPrint("Conversation ID not received in last_memory event. Content is: $event");
         return;
       }
       _handleLastConvoEvent(event.memoryId!);

app/lib/providers/developer_mode_provider.dart

@@ -154,7 +154,7 @@ class DeveloperModeProvider extends BaseProvider {
       return;
     }
     if (webhookOnConversationCreated.text.isNotEmpty && !isValidUrl(webhookOnConversationCreated.text)) {
-      AppSnackbar.showSnackbarError('Invalid memory created webhook URL');
+      AppSnackbar.showSnackbarError('Invalid conversation created webhook URL');
       setIsLoading(false);
       return;
     }

backend/database/apps.py

@@ -226,21 +226,21 @@ def is_tester_db(uid: str) -> bool:
 # ********************************
 
 def record_app_usage(
-        uid: str, app_id: str, usage_type: UsageHistoryType, memory_id: str = None, message_id: str = None,
+        uid: str, app_id: str, usage_type: UsageHistoryType, conversation_id: str = None, message_id: str = None,
         timestamp: datetime = None
 ):
-    if not memory_id and not message_id:
+    if not conversation_id and not message_id:
         raise ValueError('memory_id or message_id must be provided')
 
     data = {
         'uid': uid,
-        'memory_id': memory_id,
+        'memory_id': conversation_id,
         'message_id': message_id,
         'timestamp': datetime.now(timezone.utc) if timestamp is None else timestamp,
         'type': usage_type,
     }
 
-    db.collection('plugins').document(app_id).collection('usage_history').document(memory_id or message_id).set(data)
+    db.collection('plugins').document(app_id).collection('usage_history').document(conversation_id or message_id).set(data)
     return data
 
 

backend/database/chat.py

@@ -19,7 +19,7 @@ def add_message(uid: str, message_data: dict):
     return message_data
 
 
-def add_plugin_message(text: str, plugin_id: str, uid: str, memory_id: Optional[str] = None) -> Message:
+def add_plugin_message(text: str, plugin_id: str, uid: str, conversation_id: Optional[str] = None) -> Message:
     ai_message = Message(
         id=str(uuid.uuid4()),
         text=text,
@@ -28,7 +28,7 @@ def add_plugin_message(text: str, plugin_id: str, uid: str, memory_id: Optional[
         plugin_id=plugin_id,
         from_external_integration=False,
         type='text',
-        memories_id=[memory_id] if memory_id else [],
+        memories_id=[conversation_id] if conversation_id else [],
     )
     add_message(uid, ai_message.dict())
     return ai_message
@@ -49,7 +49,7 @@ def add_summary_message(text: str, uid: str) -> Message:
     return ai_message
 
 
-def get_plugin_messages(uid: str, plugin_id: str, limit: int = 20, offset: int = 0, include_memories: bool = False):
+def get_plugin_messages(uid: str, plugin_id: str, limit: int = 20, offset: int = 0, include_conversations: bool = False):
     user_ref = db.collection('users').document(uid)
     messages_ref = (
         user_ref.collection('messages')
@@ -59,46 +59,46 @@ def get_plugin_messages(uid: str, plugin_id: str, limit: int = 20, offset: int =
         .offset(offset)
     )
     messages = []
-    memories_id = set()
+    conversations_id = set()
 
-    # Fetch messages and collect memory IDs
+    # Fetch messages and collect conversation IDs
     for doc in messages_ref.stream():
         message = doc.to_dict()
 
         if message.get('deleted') is True:
             continue
 
         messages.append(message)
-        memories_id.update(message.get('memories_id', []))
+        conversations_id.update(message.get('memories_id', []))
 
-    if not include_memories:
+    if not include_conversations:
         return messages
 
-    # Fetch all memories at once
-    memories = {}
-    memories_ref = user_ref.collection('memories')
-    doc_refs = [memories_ref.document(str(memory_id)) for memory_id in memories_id]
+    # Fetch all conversations at once
+    conversations = {}
+    conversations_ref = user_ref.collection('memories')
+    doc_refs = [conversations_ref.document(str(conversation_id)) for conversation_id in conversations_id]
     docs = db.get_all(doc_refs)
     for doc in docs:
         if doc.exists:
-            memory = doc.to_dict()
-            memories[memory['id']] = memory
+            conversation = doc.to_dict()
+            conversations[conversation['id']] = conversation
 
-    # Attach memories to messages
+    # Attach conversations to messages
     for message in messages:
         message['memories'] = [
-            memories[memory_id] for memory_id in message.get('memories_id', []) if memory_id in memories
+            conversations[conversation_id] for conversation_id in message.get('memories_id', []) if conversation_id in conversations
         ]
 
     return messages
 
 
 @timeit
 def get_messages(
-        uid: str, limit: int = 20, offset: int = 0, include_memories: bool = False, plugin_id: Optional[str] = None, chat_session_id: Optional[str] = None
+        uid: str, limit: int = 20, offset: int = 0, include_conversations: bool = False, plugin_id: Optional[str] = None, chat_session_id: Optional[str] = None
         # include_plugin_id_filter: bool = True,
 ):
-    print('get_messages', uid, limit, offset, plugin_id, include_memories)
+    print('get_messages', uid, limit, offset, plugin_id, include_conversations)
     user_ref = db.collection('users').document(uid)
     messages_ref = (
         user_ref.collection('messages')
@@ -112,35 +112,35 @@ def get_messages(
     messages_ref = messages_ref.order_by('created_at', direction=firestore.Query.DESCENDING).limit(limit).offset(offset)
 
     messages = []
-    memories_id = set()
+    conversations_id = set()
     files_id = set()
 
-    # Fetch messages and collect memory IDs
+    # Fetch messages and collect conversation IDs
     for doc in messages_ref.stream():
         message = doc.to_dict()
         # if message.get('deleted') is True:
         #     continue
         messages.append(message)
-        memories_id.update(message.get('memories_id', []))
+        conversations_id.update(message.get('memories_id', []))
         files_id.update(message.get('files_id', []))
 
-    if not include_memories:
+    if not include_conversations:
         return messages
 
-    # Fetch all memories at once
-    memories = {}
-    memories_ref = user_ref.collection('memories')
-    doc_refs = [memories_ref.document(str(memory_id)) for memory_id in memories_id]
+    # Fetch all conversations at once
+    conversations = {}
+    conversations_ref = user_ref.collection('memories')
+    doc_refs = [conversations_ref.document(str(conversation_id)) for conversation_id in conversations_id]
     docs = db.get_all(doc_refs)
     for doc in docs:
         if doc.exists:
-            memory = doc.to_dict()
-            memories[memory['id']] = memory
+            conversation = doc.to_dict()
+            conversations[conversation['id']] = conversation
 
-    # Attach memories to messages
+    # Attach conversations to messages
     for message in messages:
         message['memories'] = [
-            memories[memory_id] for memory_id in message.get('memories_id', []) if memory_id in memories
+            conversations[conversation_id] for conversation_id in message.get('memories_id', []) if conversation_id in conversations
         ]
 
     # Fetch file chat