Update app.py
Browse files
app.py
CHANGED
@@ -79,26 +79,22 @@ async def init():
|
|
79 |
)
|
80 |
|
81 |
markdown_table = """
|
82 |
-
|
83 |
-
|
84 |
-
|
85 |
-
|
86 |
-
|
87 |
-
| Personvernspolicy | Hva er mine rettigheter? |
|
88 |
"""
|
89 |
|
90 |
-
|
91 |
-
msg.content = f"Index built! Bare spør ivei..🤓\n\n{markdown_table}"
|
92 |
await msg.send()
|
93 |
|
94 |
cl.user_session.set("chain", chain)
|
95 |
|
96 |
-
last_response = None
|
97 |
-
|
98 |
@cl.on_message
|
99 |
async def main(message):
|
100 |
global last_response
|
101 |
-
|
102 |
chain = cl.user_session.get("chain")
|
103 |
cb = cl.AsyncLangchainCallbackHandler(
|
104 |
stream_final_answer=True,
|
@@ -108,12 +104,7 @@ async def main(message):
|
|
108 |
cb.answer_reached = True
|
109 |
res = await chain.acall(message, callbacks=[cb])
|
110 |
|
111 |
-
|
112 |
answer = res["result"]
|
113 |
-
if answer != last_response:
|
114 |
-
await cl.Message(content=answer).send()
|
115 |
-
last_response = answer
|
116 |
-
|
117 |
source_elements = []
|
118 |
visited_sources = set()
|
119 |
|
@@ -124,16 +115,17 @@ async def main(message):
|
|
124 |
row_index = metadata.get("row_index", -1)
|
125 |
source = metadata.get("source", "")
|
126 |
|
127 |
-
|
128 |
-
|
129 |
-
|
130 |
-
|
131 |
-
|
132 |
|
133 |
if source_elements:
|
134 |
answer += f"\nSources: {', '.join([e.content for e in source_elements])}"
|
135 |
-
|
136 |
-
|
|
|
|
|
137 |
else:
|
138 |
-
|
139 |
-
await cl.Message(content=f"No sources found").send()
|
|
|
79 |
)
|
80 |
|
81 |
markdown_table = """
|
82 |
+
> **Eksempler på spørsmål:**
|
83 |
+
> - Hvordan registrerer jeg meg som bruker?
|
84 |
+
> - Kan jeg ha med kjæledyr på hytta?
|
85 |
+
> - Adferdsmessig annonsering?
|
86 |
+
> - Hvordan blir dataene mine beskyttet?
|
|
|
87 |
"""
|
88 |
|
89 |
+
msg.content = f"FAISS ready. Bare spør ivei..🤓\n\n{markdown_table}"
|
|
|
90 |
await msg.send()
|
91 |
|
92 |
cl.user_session.set("chain", chain)
|
93 |
|
|
|
|
|
94 |
@cl.on_message
|
95 |
async def main(message):
|
96 |
global last_response
|
97 |
+
|
98 |
chain = cl.user_session.get("chain")
|
99 |
cb = cl.AsyncLangchainCallbackHandler(
|
100 |
stream_final_answer=True,
|
|
|
104 |
cb.answer_reached = True
|
105 |
res = await chain.acall(message, callbacks=[cb])
|
106 |
|
|
|
107 |
answer = res["result"]
|
|
|
|
|
|
|
|
|
108 |
source_elements = []
|
109 |
visited_sources = set()
|
110 |
|
|
|
115 |
row_index = metadata.get("row_index", -1)
|
116 |
source = metadata.get("source", "")
|
117 |
|
118 |
+
if row_index in [2, 8, 14] and source and source not in visited_sources:
|
119 |
+
visited_sources.add(source)
|
120 |
+
source_elements.append(
|
121 |
+
cl.Text(content="https://www.daysoff.no" + source, name="Info_Url")
|
122 |
+
)
|
123 |
|
124 |
if source_elements:
|
125 |
answer += f"\nSources: {', '.join([e.content for e in source_elements])}"
|
126 |
+
|
127 |
+
if answer != last_response:
|
128 |
+
await cl.Message(content=answer, elements=source_elements if source_elements else None).send()
|
129 |
+
last_response = answer
|
130 |
else:
|
131 |
+
await cl.Message(content="No new information available.").send()
|
|