gitea/conjurer
1
0
Fork 0
mirror of https://github.com/migatu/conjurer.git synced 2026-07-14 13:34:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

Almost deployment versio - for full deployment change parameteres in search_bot

Browse Source
This commit is contained in:
Michal Tuszowski
2024-04-10 19:06:48 +02:00
parent 6589b73329
commit 8b1950823b
4 changed files with 14 additions and 161663 deletions
Download Patch File Download Diff File Expand all files Collapse all files
conjurer_librarian/conjurer_librarian.py
+14 -7
View File
@@ -170,6 +170,10 @@ class Librarian(object):
for item in database.keys():
if item in self.uuid:
self.result = await self.refine_query(database)
temp = {}
for item in self.result:
temp[item['DOI']] = {"Title" : item['title'], "type": item['type']}
self.result = temp
return self.result
answer = await self.search_crossref(query=query)
database.update(answer)
@@ -177,7 +181,6 @@ class Librarian(object):
cr_file.seek(0)
json.dump(database,cr_file)
self.result = await self.refine_query(answer)
return self.result
else:
answer = await self.search_crossref(query=query)
database = answer
@@ -187,7 +190,11 @@ class Librarian(object):
self.result = await self.refine_query(answer)
self.app.logger.info("Refined")
self.done = True
return self.result
temp = {}
for item in self.result:
temp[item['DOI']] = {"Title" : item['title'], "type": item['type']}
self.result = temp
return self.result
#============================= FLASK INTERNALS===============================
def flask_debug():
@@ -225,7 +232,9 @@ class BackgroundTaskSearch(threading.Thread):
except JSONDecodeError:
pass
if database:
database.extend(result)
self.app.logger.info(database)
self.app.logger.info(result)
database.update(result)
else:
database = result
self.app.logger.info("DUMPING DATA")
@@ -242,7 +251,8 @@ class BackgroundTaskSearch(threading.Thread):
timeout=360,
)
self.app.logger.info("SENT")
_ = await coroutine
result = await coroutine
self.app.logger.info(result.status_code)
self.app.logger.info("SEND CONFIRMED")
time.sleep(1)
@@ -254,9 +264,6 @@ async def query_database():
app.logger.info(record["query"])
app.logger.info(record["UUID"])
uuid = record["UUID"]
#TODO: TESTING ONLY======================
uuid = UUID('{12345678-1234-5678-1234-567812345678}')
cl = Librarian(app, record["query"], uuid)
librarian_queue.put(cl)
librarian_list.append(cl)