(self)
| 113 | self.processSearches() |
| 114 | |
| 115 | def processSearches(self): |
| 116 | cv = self.cv |
| 117 | |
| 118 | while True: |
| 119 | if not self.running: |
| 120 | break |
| 121 | cv.acquire() |
| 122 | while self.searchRequest is None: |
| 123 | cv.wait() |
| 124 | |
| 125 | request, callback, filterName = self.searchRequest |
| 126 | self.searchRequest = None |
| 127 | cv.release() |
| 128 | sMkt = Market.getInstance() |
| 129 | if filterName == 'market': |
| 130 | # Rely on category data provided by eos as we don't hardcode them much in service |
| 131 | filters = [or_( |
| 132 | types_Category.name.in_(sMkt.SEARCH_CATEGORIES), |
| 133 | types_Group.name.in_(sMkt.SEARCH_GROUPS))] |
| 134 | # Used in implant editor |
| 135 | elif filterName == 'implants': |
| 136 | filters = [types_Category.name == 'Implant'] |
| 137 | # Actually not everything, just market search + ships |
| 138 | elif filterName == 'everything': |
| 139 | filters = [ |
| 140 | or_( |
| 141 | types_Category.name.in_(sMkt.FIT_CATEGORIES), |
| 142 | types_Group.name.in_(sMkt.FIT_GROUPS)), |
| 143 | or_( |
| 144 | types_Category.name.in_(sMkt.SEARCH_CATEGORIES), |
| 145 | types_Group.name.in_(sMkt.SEARCH_GROUPS))] |
| 146 | else: |
| 147 | filters = [None] |
| 148 | |
| 149 | if request.strip().lower().startswith('re:'): |
| 150 | requestTokens = self._prepareRequestRegex(request[3:]) |
| 151 | else: |
| 152 | requestTokens = self._prepareRequestNormal(request) |
| 153 | requestTokens = self.jargonLoader.get_jargon().apply(requestTokens) |
| 154 | |
| 155 | all_results = set() |
| 156 | joinedTokens = ' '.join(requestTokens) |
| 157 | if ( |
| 158 | (isStringCjk(joinedTokens) and len(joinedTokens) >= config.minItemSearchLengthCjk) |
| 159 | or len(joinedTokens) >= config.minItemSearchLength |
| 160 | ): |
| 161 | for filter_ in filters: |
| 162 | filtered_results = eos.db.searchItemsRegex( |
| 163 | requestTokens, where=filter_, |
| 164 | join=(types_Item.group, types_Group.category), |
| 165 | eager=("group.category", "metaGroup")) |
| 166 | all_results.update(filtered_results) |
| 167 | |
| 168 | item_IDs = set() |
| 169 | # Return only published items, consult with Market service this time |
| 170 | for item in all_results: |
| 171 | if sMkt.getPublicityByItem(item): |
| 172 | item_IDs.add(item.ID) |
no test coverage detected