Spaces:
Sleeping
Sleeping
Update app.py
Browse files
app.py
CHANGED
|
@@ -101,100 +101,6 @@ class SmartResearchAgent:
|
|
| 101 |
logging.error(f"Image processing error: {e}")
|
| 102 |
return "Unable to process the image."
|
| 103 |
|
| 104 |
-
def __call__(self, question: str, image: Image.Image = None) -> str:
|
| 105 |
-
logging.info(f"Received question: {question}")
|
| 106 |
-
q_lower = question.lower().strip()
|
| 107 |
-
|
| 108 |
-
try:
|
| 109 |
-
# 🔍 Handle image-based chess questions
|
| 110 |
-
if image is not None:
|
| 111 |
-
logging.info("Image input detected")
|
| 112 |
-
temp_path = "/tmp/input_image.jpg"
|
| 113 |
-
image.save(temp_path)
|
| 114 |
-
return self.caption_image(temp_path)
|
| 115 |
-
|
| 116 |
-
# 🔍 Handle text-based tasks
|
| 117 |
-
if q_lower.startswith("search:"):
|
| 118 |
-
query = question.split(":", 1)[1].strip()
|
| 119 |
-
return self.search_web(query)
|
| 120 |
-
elif q_lower.startswith("summarize:"):
|
| 121 |
-
target = question.split(":", 1)[1].strip()
|
| 122 |
-
return self.summarize(target)
|
| 123 |
-
elif q_lower.startswith("generate citation:") or q_lower.startswith("cite:"):
|
| 124 |
-
url = question.split(":", 1)[1].strip()
|
| 125 |
-
return self.generate_citation(url)
|
| 126 |
-
else:
|
| 127 |
-
# Default: search + summarize
|
| 128 |
-
search_result = self.search_web(question)
|
| 129 |
-
first_url = next((line.split(": ", 1)[-1] for line in search_result.splitlines() if "http" in line), None)
|
| 130 |
-
if first_url:
|
| 131 |
-
summary = self.summarize(first_url)
|
| 132 |
-
return f"{summary}\n\nSource: {first_url}"
|
| 133 |
-
else:
|
| 134 |
-
return "Sorry, I couldn't find relevant information."
|
| 135 |
-
except Exception as e:
|
| 136 |
-
logging.exception("Unhandled error in agent call")
|
| 137 |
-
return f"Agent error: {e}"class SmartResearchAgent:
|
| 138 |
-
def __init__(self):
|
| 139 |
-
logging.info("Initializing SmartResearchAgent")
|
| 140 |
-
self.summarizer = pipeline("summarization", model="facebook/bart-large-cnn")
|
| 141 |
-
self.blip_processor = BlipProcessor.from_pretrained("Salesforce/blip-image-captioning-base")
|
| 142 |
-
self.blip_model = BlipForConditionalGeneration.from_pretrained("Salesforce/blip-image-captioning-base")
|
| 143 |
-
|
| 144 |
-
def search_web(self, query: str) -> str:
|
| 145 |
-
try:
|
| 146 |
-
with DDGS() as ddgs:
|
| 147 |
-
results = ddgs.text(query, max_results=3)
|
| 148 |
-
top = [f"{i+1}. {r['title']}: {r['href']}" for i, r in enumerate(results)]
|
| 149 |
-
return "\n".join(top) if top else "No results found."
|
| 150 |
-
except Exception as e:
|
| 151 |
-
logging.error(f"Search error: {e}")
|
| 152 |
-
return "Error during web search."
|
| 153 |
-
|
| 154 |
-
def summarize(self, input_text_or_url: str) -> str:
|
| 155 |
-
try:
|
| 156 |
-
if input_text_or_url.startswith("http"):
|
| 157 |
-
article = Article(input_text_or_url)
|
| 158 |
-
article.download()
|
| 159 |
-
article.parse()
|
| 160 |
-
input_text_or_url = article.text
|
| 161 |
-
if not input_text_or_url.strip():
|
| 162 |
-
return "No content to summarize."
|
| 163 |
-
summary = self.summarizer(input_text_or_url, max_length=160, min_length=40, do_sample=False)
|
| 164 |
-
return summary[0]['summary_text'].strip()
|
| 165 |
-
except Exception as e:
|
| 166 |
-
logging.error(f"Summarization error: {e}")
|
| 167 |
-
return "Error during summarization."
|
| 168 |
-
|
| 169 |
-
def generate_citation(self, url: str) -> str:
|
| 170 |
-
try:
|
| 171 |
-
citation_id = hashlib.md5(url.encode()).hexdigest()[:6]
|
| 172 |
-
year = datetime.datetime.now().year
|
| 173 |
-
citation = (
|
| 174 |
-
f"@article{{cite{citation_id},\n"
|
| 175 |
-
f" title={{Generated Reference}},\n"
|
| 176 |
-
f" author={{Unknown}},\n"
|
| 177 |
-
f" journal={{Online}},\n"
|
| 178 |
-
f" year={{ {year} }},\n"
|
| 179 |
-
f" url={{ {url} }}\n"
|
| 180 |
-
f"}}"
|
| 181 |
-
)
|
| 182 |
-
return citation
|
| 183 |
-
except Exception as e:
|
| 184 |
-
logging.error(f"Citation error: {e}")
|
| 185 |
-
return "Error during citation generation."
|
| 186 |
-
|
| 187 |
-
def caption_image(self, image_path: str) -> str:
|
| 188 |
-
try:
|
| 189 |
-
image = Image.open(image_path).convert("RGB")
|
| 190 |
-
inputs = self.blip_processor(image, return_tensors="pt")
|
| 191 |
-
out = self.blip_model.generate(**inputs)
|
| 192 |
-
caption = self.blip_processor.decode(out[0], skip_special_tokens=True)
|
| 193 |
-
return f"Image analysis: {caption}"
|
| 194 |
-
except Exception as e:
|
| 195 |
-
logging.error(f"Image processing error: {e}")
|
| 196 |
-
return "Unable to process the image."
|
| 197 |
-
|
| 198 |
def __call__(self, question: str, image: Image.Image = None) -> str:
|
| 199 |
logging.info(f"Received question: {question}")
|
| 200 |
q_lower = question.lower().strip()
|
|
@@ -229,9 +135,9 @@ class SmartResearchAgent:
|
|
| 229 |
except Exception as e:
|
| 230 |
logging.exception("Unhandled error in agent call")
|
| 231 |
return f"Agent error: {e}"
|
| 232 |
-
|
| 233 |
|
| 234 |
|
|
|
|
| 235 |
def run_and_submit_all( profile: gr.OAuthProfile | None):
|
| 236 |
"""
|
| 237 |
Fetches all questions, runs the BasicAgent on them, submits all answers,
|
|
|
|
| 101 |
logging.error(f"Image processing error: {e}")
|
| 102 |
return "Unable to process the image."
|
| 103 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 104 |
def __call__(self, question: str, image: Image.Image = None) -> str:
|
| 105 |
logging.info(f"Received question: {question}")
|
| 106 |
q_lower = question.lower().strip()
|
|
|
|
| 135 |
except Exception as e:
|
| 136 |
logging.exception("Unhandled error in agent call")
|
| 137 |
return f"Agent error: {e}"
|
|
|
|
| 138 |
|
| 139 |
|
| 140 |
+
|
| 141 |
def run_and_submit_all( profile: gr.OAuthProfile | None):
|
| 142 |
"""
|
| 143 |
Fetches all questions, runs the BasicAgent on them, submits all answers,
|