Upload 2 files

previously uploaded wrong files, this correct for logs and dates

app.py

@@ -1,33 +1,48 @@
-
-import openai
-import gradio as gr
-from full_chain import get_response
-import os
-
-api_key = os.getenv("OPENAI_API_KEY")
-client = openai.OpenAI(api_key=api_key)
-
-
-def create_hyperlink(url, title, domain):
-    return f"<a href='{url}'>{title}</a>" + " (" + domain + ")"
-
-
-def predict(message, history):
-    print("get_responses: ")
-    # print(get_response(message, rerank_type="crossencoder"))
-    responder, links, titles, domains = get_response(message, rerank_type="crossencoder")
-    for i in range(len(links)):
-        links[i] = create_hyperlink(links[i], titles[i], domains[i])
-
-    out = responder + "\n" + "\n".join(links)
-
-    return out
-
-
-gr.ChatInterface(predict,
-                examples = [
-                    "How many Americans Smoke?",
-                    "What are some measures taken by the Indian Government to reduce the smoking population?",
-                    "Does smoking negatively affect my health?"
-                ]
-                ).launch()
+import openai
+import gradio as gr
+from full_chain import get_response
+import os
+
+api_key = os.getenv("OPENAI_API_KEY")
+client = openai.OpenAI(api_key=api_key)
+
+def create_hyperlink(url, title, domain):
+    """Create HTML hyperlink with domain information."""
+    return f"<a href='{url}' target='_blank'>{title}</a> ({domain})"
+
+def predict(message, history):
+    """Process user message and return response with hyperlinked sources."""
+    # Get response and source information
+    responder, links, titles, domains, published_dates = get_response(message, rerank_type="crossencoder")
+    
+    # The responder already contains the formatted response with numbered citations
+    # We just need to add the hyperlinked references at the bottom
+    hyperlinks = []
+    for i, (link, title, domain, published_date) in enumerate(zip(links, titles, domains, published_dates), 1):
+        hyperlink = f"[{i}] {create_hyperlink(link, title, domain)} {published_date}"
+        hyperlinks.append(hyperlink)
+
+    # Split the responder to separate the response from its references
+    response_parts = responder.split("References:")
+    main_response = response_parts[0].strip()
+    
+    # Combine the response with hyperlinked references
+    final_response = (
+        f"{main_response}\n\n"
+        f"References:\n"
+        f"{chr(10).join(hyperlinks)}"
+    )
+    
+    return final_response
+
+# Initialize and launch Gradio interface
+gr.ChatInterface(
+    predict,
+    examples=[
+        "How many Americans Smoke?",
+        "What are some measures taken by the Indian Government to reduce the smoking population?",
+        "Does smoking negatively affect my health?"
+    ],
+    title="Tobacco Information Assistant",
+    description="Ask questions about tobacco-related topics and get answers with reliable sources."
+).launch()

feed_to_llm_v2.py

@@ -1,85 +1,138 @@
-from langchain_openai import OpenAI
-
-from langchain.schema import (
-    HumanMessage,
-    SystemMessage
-)
-import tiktoken
-import re
-
-from get_articles import save_solr_articles_full
-from rerank import crossencoder_rerank_answer
-
-
-def num_tokens_from_string(string: str, encoder) -> int:
-    num_tokens = len(encoder.encode(string))
-    return num_tokens
-
-
-def feed_articles_to_gpt_with_links(information, question):
-    prompt = """
-    You are a Question Answering machine specialized in providing information on tobacco-related queries. You have access to a curated list of articles that span various aspects of tobacco use, health effects, legislation, and quitting resources. When responding to questions, follow these guidelines:
-
-    1. Use information from the articles to formulate your answers. Indicate the article number you're referencing at the end of your response.
-    2. If the question's answer is not covered by your articles, clearly state that you do not know the answer. Do not attempt to infer or make up information.
-    3. Avoid using time-relative terms like 'last year,' 'recently,' etc., as the articles' publication dates and the current date may not align. Instead, use absolute terms (e.g., 'In 2022,' 'As of the article's 2020 publication,').
-    4. Aim for concise, informative responses that directly address the question asked.
-
-    Remember, your goal is to provide accurate, helpful information on tobacco-related topics, aiding in education and informed decision-making.
-    """
-    end_prompt = "\n----------------\n"
-    prompt += end_prompt
-    content = ""
-    seperator = "<<<<>>>>"
-
-    token_count = 0
-    encoder = tiktoken.encoding_for_model("gpt-3.5-turbo")
-    token_count += num_tokens_from_string(prompt, encoder)
-
-    articles = [contents for score, contents, uuids, titles, domains in information]
-    uuids = [uuids for score, contents, uuids, titles, domains in information]
-    domains = [domains for score, contents, uuids, titles, domains in information]
-
-    for i in range(len(articles)):
-        addition = "Article " + str(i + 1) + ": " + articles[i] + seperator
-        addition += articles[i] + seperator
-        token_count += num_tokens_from_string(addition, encoder)
-        if token_count > 3500:
-            print(i)
-            break
-
-        content += addition
-
-    prompt += content
-    llm = OpenAI(model_name="gpt-4o-mini", temperature=0.0)
-    message = [
-        SystemMessage(content=prompt),
-        HumanMessage(content=question)
-    ]
-
-    response = llm.invoke(message)
-    print(response)
-    print("response length:", len(response))
-    source = re.findall('\((.*?)\)', response)[-1]
-
-    # get integers from source
-    source = re.findall(r'\d+', source)
-    used_article_num = [int(i) - 1 for i in source]
-
-    links = [f"https://tobaccowatcher.globaltobaccocontrol.org/articles/{uuid}/" for uuid in uuids]
-    titles = [titles for score, contents, uuids, titles, domains in information]
-
-    links = [links[i] for i in used_article_num]
-    titles = [titles[i] for i in used_article_num]
-    domains = [domains[i] for i in used_article_num]
-
-    response_without_source = re.sub("""\(Article.*\)""", "", response)
-    return response_without_source, links, titles, domains
-
-if __name__ == "__main__":
-    question = "How is United States fighting against tobacco addiction?"
-    rerank_type = "crossencoder"
-    llm_type = "chat"
-    csv_path = save_solr_articles_full(question, keyword_type="rake")
-    reranked_out = crossencoder_rerank_answer(csv_path, question)
-    feed_articles_to_gpt_with_links(reranked_out, question)
+from langchain_openai import ChatOpenAI
+
+from langchain.schema import (
+    HumanMessage,
+    SystemMessage
+)
+import tiktoken
+import re
+
+from get_articles import save_solr_articles_full
+from rerank import crossencoder_rerank_answer
+import logging
+from logging.handlers import RotatingFileHandler
+
+# Configure logging
+logger = logging.getLogger("TobaccoInfoAssistant")
+logger.setLevel(logging.INFO)
+
+handler = RotatingFileHandler(
+    "tobacco_info_assistant.log", maxBytes=10 * 1024 * 1024, backupCount=3
+)
+formatter = logging.Formatter("%(asctime)s - %(levelname)s - %(message)s")
+handler.setFormatter(formatter)
+logger.addHandler(handler)
+
+def num_tokens_from_string(string: str, encoder) -> int:
+    num_tokens = len(encoder.encode(string))
+    return num_tokens
+
+
+def feed_articles_to_gpt_with_links(information, question):
+    prompt = """
+    You are a Question Answering system specializing in tobacco-related topics. You have access to several curated articles, each numbered (e.g., Article 1, Article 2). These articles cover various aspects of tobacco use, health effects, legislation, and quitting resources.
+
+    When formulating your response, adhere to the following guidelines:
+    
+    1. Use information from the provided articles to directly answer the question. Explicitly reference the article(s) used in your response by stating the article number(s) (e.g., "According to Article 1, ..." or "Articles 2 and 3 mention that...").
+    2. If the answer is not covered by any of the articles, clearly state that the information is unavailable. Do not guess or fabricate information.
+    3. Avoid using ambiguous time references like 'recently' or 'last year.' Instead, use absolute terms based on the article's content (e.g., 'In 2021' or 'As per Article 2, published in 2020').
+    4. Keep responses concise, accurate, and helpful while maintaining a professional tone.
+
+    Below is a list of articles you can reference. Each article is identified by its number and content:
+    """
+    end_prompt = "\n----------------\n"
+    prompt += end_prompt
+
+    content = ""
+    separator = "<<<<>>>>"
+    token_count = 0
+
+    # Encoder setup for token count tracking
+    encoder = tiktoken.encoding_for_model("gpt-3.5-turbo")
+    token_count += num_tokens_from_string(prompt, encoder)
+
+    # Add articles to the prompt
+    articles = [contents for score, contents, uuids, titles, domains, published_dates in information]
+    uuids = [uuids for score, contents, uuids, titles, domains, published_dates in information]
+    titles_list = [titles for score, contents, uuids, titles, domains, published_dates in information]
+    domains_list = [domains for score, contents, uuids, titles, domains, published_dates in information]
+    published_dates = [published_dates for score, contents, uuids, titles, domains, published_dates in information]
+    logger.info(f"Article retrieved: {len(articles)}")
+    logger.info(f"Article titles: {titles_list}")
+    for i in range(len(articles)):
+        addition = f"Article {i + 1}: {articles[i]} {separator}"
+        token_count += num_tokens_from_string(addition, encoder)
+        if token_count > 3500:
+            break
+        content += addition
+
+    prompt += content
+    logger.info(f"Prompt: {prompt}")
+    llm = ChatOpenAI(model="gpt-4o-mini", temperature=0.0)
+    message = [
+        SystemMessage(content=prompt),
+        HumanMessage(content=question)
+    ]
+
+    response = llm.invoke(message)
+    response_content = response.content  # Access the content of the AIMessage
+    logger.info(f"LLM Response Content: {response_content}")
+
+    # Extract sources from the response content
+    inline_matches = re.findall(r'Article \d+', response_content)
+    parenthetical_matches = re.findall(r'\(Article \d+\)', response_content)
+    
+    if not (inline_matches or parenthetical_matches):
+        return response_content, [], [], []
+
+    # Combine and get unique article numbers
+    all_matches = inline_matches + [m.strip('()') for m in parenthetical_matches]
+    unique_articles = list(set(all_matches))
+    used_article_nums = [int(re.findall(r'\d+', match)[0]) - 1 for match in unique_articles]
+
+    # Create citation mapping
+    citation_map = {}
+    citations = []
+    for idx, article_num in enumerate(used_article_nums, start=1):
+        original = f"Article {article_num + 1}"
+        citation_map[original] = f"[{idx}]"
+        publication_date = published_dates[article_num] if published_dates[article_num] else "Unknown Date"
+        citation = f"[{idx}] {titles_list[article_num]} ({domains_list[article_num]}) {publication_date}"
+        citations.append(citation)
+
+    # Replace all article references with citation numbers
+    modified_response = response_content
+    for original, citation_num in citation_map.items():
+        # Replace both inline and parenthetical references
+        modified_response = modified_response.replace(f"({original})", citation_num)
+        modified_response = modified_response.replace(original, citation_num)
+
+    # Format final response with citations
+    response_with_citations = (
+        f"{modified_response}\n\n"
+        f"References:\n"
+        f"{chr(10).join(citations)}"
+    )
+
+    # Prepare links only for cited articles
+    cited_links = []
+    cited_titles = []
+    cited_domains = []
+    cited_published_dates = []
+    for article_num in used_article_nums:
+        uuid = uuids[article_num]
+        link = f"https://tobaccowatcher.globaltobaccocontrol.org/articles/{uuid}/"
+        cited_links.append(link)
+        cited_titles.append(titles_list[article_num])
+        cited_domains.append(domains_list[article_num])
+        cited_published_dates.append(published_dates[article_num])
+    return response_with_citations, cited_links, cited_titles, cited_domains, cited_published_dates
+
+if __name__ == "__main__":
+    question = "How is United States fighting against tobacco addiction?"
+    rerank_type = "crossencoder"
+    llm_type = "chat"
+    csv_path = save_solr_articles_full(question, keyword_type="rake")
+    reranked_out = crossencoder_rerank_answer(csv_path, question)
+    feed_articles_to_gpt_with_links(reranked_out, question)