Search chats by latinize map

Fix contacts load on folder included chats

src/components/appSearch.ts

@@ -10,6 +10,7 @@ import SearchInput from "./searchInput";
 import { Peer } from "../layer";
 import rootScope from "../lib/rootScope";
 import { escapeRegExp } from "../helpers/string";
+import searchIndexManager from "../lib/searchIndexManager";
 
 export class SearchGroup {
   container: HTMLDivElement;
@@ -143,13 +144,6 @@ export default class AppSearch {
     this.searchInput.input.focus();
   }
 
-  private renderSaved() {
-    const group = this.searchGroups.contacts;
-    let {dialog, dom} = appDialogsManager.addDialog(rootScope.myID, group.list, false);
-    dom.lastMessageSpan.innerHTML = 'chat with yourself';
-    group.setActive();
-  }
-  
   public searchMore() {
     if(this.searchPromise) return this.searchPromise;
     
@@ -167,85 +161,79 @@ export default class AppSearch {
     const maxID = appMessagesIDsManager.getMessageIDInfo(this.minMsgID)[0] || 0;
 
     if(!this.peerID && !maxID && !this.loadedContacts) {
-      let renderedSaved = false;
+      const renderedPeerIDs: Set<number> = new Set();
-      if('saved messages'.includes(query.toLowerCase()) 
-        || appUsersManager.getUser(rootScope.myID).sortName.includes(query.toLowerCase())/*  && this.searchGroups.hasOwnProperty('saved') */) {
-        this.renderSaved();
-        renderedSaved = true;
-      }
 
-      appUsersManager.searchContacts(query, 20).then((contacts) => {
+      const setResults = (results: number[], group: SearchGroup, showMembersCount = false) => {
+        results.forEach((peerID) => {
+          if(renderedPeerIDs.has(peerID)) {
+            return;
+          }
+
+          renderedPeerIDs.add(peerID);
+
+          const peer = appPeersManager.getPeer(peerID);
+
+          //////////this.log('contacts peer', peer);
+
+          const {dom} = appDialogsManager.addDialog(peerID, group.list, false);
+
+          if(showMembersCount && (peer.participants_count || peer.participants)) {
+            const regExp = new RegExp(`(${escapeRegExp(query)}|${escapeRegExp(searchIndexManager.cleanSearchText(query))})`, 'gi');
+            dom.titleSpan.innerHTML = dom.titleSpan.innerHTML.replace(regExp, '<i>$1</i>');
+            dom.lastMessageSpan.innerText = appChatsManager.getChatMembersString(-peerID);
+          } else if(peerID == rootScope.myID) {
+            dom.lastMessageSpan.innerHTML = 'chat with yourself';
+          } else {
+            let username = appPeersManager.getPeerUsername(peerID);
+            if(!username) {
+              const user = appUsersManager.getUser(peerID);
+              if(user && user.phone) {
+                username = '+' + formatPhoneNumber(user.phone).formatted;
+              }
+            } else {
+              username = '@' + username;
+            }
+
+            dom.lastMessageSpan.innerHTML = '<i>' + username + '</i>';
+          }
+        });
+
+        group.toggle();
+      };
+
+      const onLoad = <T>(arg: T) => {
         if(this.searchInput.value != query) {
           return;
         }
 
         this.loadedContacts = true;
 
-        // set saved message as first peer to render
+        return arg;
-        const peer = contacts.my_results.findAndSplice(p => (p as Peer.peerUser).user_id == rootScope.myID);
+      };
-        if(peer) {
+
-          contacts.my_results.unshift(peer);
+      appUsersManager.getContacts(query, true)
+      .then(onLoad)
+      .then((contacts) => {
+        if(contacts) {
+          setResults(contacts, this.searchGroups.contacts, true);
         }
+      });
 
-        //console.log('input search contacts result:', contacts);
+      appUsersManager.searchContacts(query, 20)
+      .then(onLoad)
+      .then((contacts) => {
+        if(contacts) {
+          setResults(contacts.my_results, this.searchGroups.contacts, true);
+          setResults(contacts.results, this.searchGroups.globalContacts);
+        }
+      });
 
-        let setResults = (results: Peer[], group: SearchGroup, showMembersCount = false) => {
+      appMessagesManager.getConversations(query, 0, 20, 0)
-          // ! because contacts.search returns duplicates in my_results
+      .then(onLoad)
-          new Set(results.map(peer => appPeersManager.getPeerID(peer))).forEach((peerID) => {
+      .then(value => {
-            if(peerID == rootScope.myID) {
+        if(value) {
-              if(!renderedSaved) {
+          setResults(value.dialogs.map(d => d.peerID), this.searchGroups.contacts, true);
-                this.renderSaved();
+        }
-              }
-
-              return;
-            }
-
-            let peer = appPeersManager.getPeer(peerID);
-            let originalDialog = appMessagesManager.getDialogByPeerID(peerID)[0];
-
-            //////////this.log('contacts peer', peer);
-          
-            if(!originalDialog) {
-              /////////this.log('no original dialog by peerID:', peerID);
-              
-              originalDialog = {
-                peerID: peerID,
-                pFlags: {},
-                peer: peer
-              } as any;
-            }
-            
-            let {dialog, dom} = appDialogsManager.addDialog(originalDialog, group.list, false);
-
-            if(showMembersCount && (peer.participants_count || peer.participants)) {
-              let regExp = new RegExp(`(${escapeRegExp(query)})`, 'gi');
-              dom.titleSpan.innerHTML = dom.titleSpan.innerHTML.replace(regExp, '<i>$1</i>');
-              dom.lastMessageSpan.innerText = appChatsManager.getChatMembersString(-peerID);
-            } else {
-              let username = appPeersManager.getPeerUsername(peerID);
-              if(!username) {
-                let user = appUsersManager.getUser(peerID);
-                if(user && user.phone) {
-                  username = '+' + formatPhoneNumber(user.phone).formatted;
-                }
-              } else {
-                username = '@' + username;
-              }
-
-              dom.lastMessageSpan.innerHTML = '<i>' + username + '</i>';
-            }
-          });
-
-          if(results.length) group.setActive();
-          else if(renderedSaved) { // удалить все пункты снизу
-            Array.from(group.list.children).slice(1).forEach(c => c.remove());
-          } else {
-            group.clear();
-          }
-        };
-
-        setResults(contacts.my_results, this.searchGroups.contacts, true);
-        setResults(contacts.results, this.searchGroups.globalContacts);
       });
     }
     
@@ -265,25 +253,15 @@ export default class AppSearch {
       }
       
       const searchGroup = this.searchGroups.messages;
-      searchGroup.setActive();
 
       history.forEach((msgID: number) => {
         const message = appMessagesManager.getMessage(msgID);
-        let originalDialog = appMessagesManager.getDialogByPeerID(message.peerID)[0];
+
-        
+        const {dialog, dom} = appDialogsManager.addDialog(message.peerID, this.scrollable/* searchGroup.list */, false);
-        if(!originalDialog) {
-          ////////this.log('no original dialog by message:', message);
-          
-          originalDialog = {
-            peerID: message.peerID,
-            pFlags: {},
-            peer: message.peer_id
-          } as any;
-        }
-        
-        const {dialog, dom} = appDialogsManager.addDialog(originalDialog, this.scrollable/* searchGroup.list */, false);
         appDialogsManager.setLastMessage(dialog, message, dom, query);
       });
+
+      searchGroup.toggle();
       
       this.minMsgID = history[history.length - 1];
       this.offsetRate = next_rate;

src/components/sidebarLeft/tabs/includedChats.ts

@@ -94,9 +94,10 @@ export default class AppIncludedChatsTab implements SliderTab {
     return `<div class="checkbox"><label><input type="checkbox" ${selected ? 'checked' : ''}><span></span></label></div>`;
   }
 
-  renderResults = (peerIDs: number[]) => {
+  renderResults = async(peerIDs: number[]) => {
     //const other = this.type == 'included' ? this.filter.exclude_peers : this.filter.include_peers;
 
+    await appUsersManager.getContacts();
     peerIDs.forEach(peerID => {
       //if(other.includes(peerID)) return;
 

src/lib/appManagers/appChatsManager.ts

@@ -392,8 +392,8 @@ export class AppChatsManager {
   public createChannel(title: string, about: string): Promise<number> {
     return apiManager.invokeApi('channels.createChannel', {
       broadcast: true,
-      title: title,
+      title,
-      about: about
+      about
     }).then((updates: any) => {
       apiUpdatesManager.processUpdateMessage(updates);
 
@@ -416,7 +416,7 @@ export class AppChatsManager {
   public createChat(title: string, userIDs: number[]): Promise<number> {
     return apiManager.invokeApi('messages.createChat', {
       users: userIDs.map(u => appUsersManager.getUserInput(u)),
-      title: title
+      title
     }).then(updates => {
       apiUpdatesManager.processUpdateMessage(updates);
 
@@ -489,7 +489,7 @@ export class AppChatsManager {
   }
 
   private onChatUpdated = (chatID: number, updates: any) => {
-    console.log('onChatUpdated', chatID, updates);
+    //console.log('onChatUpdated', chatID, updates);
 
     apiUpdatesManager.processUpdateMessage(updates);
     if(updates &&

src/lib/appManagers/appDialogsManager.ts

@@ -1104,6 +1104,7 @@ export class AppDialogsManager {
       if(!originalDialog) {
         originalDialog = {
           peerID: _dialog,
+          peer: appPeersManager.getOutputPeer(_dialog),
           pFlags: {}
         } as any;
       }

src/lib/appManagers/appUsersManager.ts

@@ -19,16 +19,16 @@ import appStateManager from "./appStateManager";
 export type User = MTUser.user;
 
 export class AppUsersManager {
-  public users: {[userID: number]: User} = {};
+  private users: {[userID: number]: User} = {};
-  public usernames: {[username: string]: number} = {};
+  private usernames: {[username: string]: number} = {};
   //public userAccess: {[userID: number]: string} = {};
-  public cachedPhotoLocations: any = {};
+  private cachedPhotoLocations: any = {};
-  public contactsIndex = searchIndexManager.createIndex();
+  private contactsIndex = searchIndexManager.createIndex();
-  public contactsFillPromise: Promise<Set<number>>;
+  private contactsFillPromise: Promise<Set<number>>;
   public contactsList: Set<number> = new Set();
   private updatedContactsList = false;
 
-  public getTopPeersPromise: Promise<number[]>;
+  private getTopPeersPromise: Promise<number[]>;
 
   constructor() {
     setInterval(this.updateUsersStatuses, 60000);
@@ -110,6 +110,8 @@ export class AppUsersManager {
     });
 
     appStateManager.getState().then((state) => {
+      this.users = state.users;
+
       const contactsList = state.contactsList;
       if(contactsList && Array.isArray(contactsList)) {
         contactsList.forEach(userID => {
@@ -118,8 +120,6 @@ export class AppUsersManager {
 
         this.contactsFillPromise = Promise.resolve(this.contactsList);
       }
-
-      this.users = state.users;
     });
   }
 
@@ -179,7 +179,7 @@ export class AppUsersManager {
             ' ' + serviceText;
   }
 
-  public getContacts(query?: string) {
+  public getContacts(query?: string, includeSaved = false) {
     return this.fillContacts().then(_contactsList => {
       let contactsList = [..._contactsList];
       if(query) {
@@ -196,6 +196,16 @@ export class AppUsersManager {
         return sortName1.localeCompare(sortName2);
       });
 
+      if(includeSaved) {
+        const isSearchingSaved = 'saved messages'.includes(query.toLowerCase()) 
+          || appUsersManager.getUser(rootScope.myID).sortName.includes(query.toLowerCase());
+
+        if(isSearchingSaved) {
+          contactsList.findAndSplice(p => p == rootScope.myID);
+          contactsList.unshift(rootScope.myID);
+        }
+      }
+
       /* contactsList.sort((userID1: number, userID2: number) => {
         const sortName1 = (this.users[userID1] || {}).sortName || '';
         const sortName2 = (this.users[userID2] || {}).sortName || '';
@@ -222,15 +232,14 @@ export class AppUsersManager {
       return;
     }
 
-    var userID = user.id;
+    const userID = user.id;
-    var result = this.users[userID];
 
     if(user.pFlags === undefined) {
       user.pFlags = {};
     }
 
     if(user.pFlags.min) {
-      if(result !== undefined) {
+      if(this.users[userID] !== undefined) {
         return;
       }
     }
@@ -252,7 +261,7 @@ export class AppUsersManager {
     }
 
     if(user.username) {
-      var searchUsername = searchIndexManager.cleanUsername(user.username);
+      const searchUsername = searchIndexManager.cleanUsername(user.username);
       this.usernames[searchUsername] = userID;
     }
 
@@ -276,11 +285,11 @@ export class AppUsersManager {
       user.sortStatus = this.getUserStatusForSort(user.status);
     }
 
-    var result = this.users[userID];
+    const oldUser = this.users[userID];
-    if(result === undefined) {
+    if(oldUser === undefined) {
-      result = this.users[userID] = user;
+      this.users[userID] = user;
     } else {
-      safeReplaceObject(result, user);
+      safeReplaceObject(oldUser, user);
     }
 
     rootScope.broadcast('user_update', userID);
@@ -599,16 +608,44 @@ export class AppUsersManager {
     });
   }
 
+  /* public searchContacts(query: string, limit = 20) {
+    return Promise.all([
+      this.getContacts(query),
+      apiManager.invokeApi('contacts.search', {
+        q: query,
+        limit
+      })
+    ]).then(results => {
+      const [myContacts, peers] = results;
+
+      this.saveApiUsers(peers.users);
+      appChatsManager.saveApiChats(peers.chats);
+
+      // * contacts.search returns duplicates in my_results
+      const myResults = new Set(myContacts.concat(peers.my_results.map(p => appPeersManager.getPeerID(p))));
+
+      const out = {
+        my_results: [...myResults].slice(0, limit),
+        results: peers.results.map(p => appPeersManager.getPeerID(p))
+      };
+
+      return out;
+    });
+  } */
   public searchContacts(query: string, limit = 20) {
     return apiManager.invokeApi('contacts.search', {
       q: query,
       limit
-    }).then((peers) => {
+    }).then(peers => {
-      //console.log('search contacts result:', peers);
       this.saveApiUsers(peers.users);
       appChatsManager.saveApiChats(peers.chats);
 
-      return peers;
+      const out = {
+        my_results: [...new Set(peers.my_results.map(p => appPeersManager.getPeerID(p)))], // ! contacts.search returns duplicates in my_results
+        results: peers.results.map(p => appPeersManager.getPeerID(p))
+      };
+
+      return out;
     });
   }