Spaces:
Sleeping
Sleeping
File size: 3,897 Bytes
831e906 d1b26fd ebbf860 350a755 ebbf860 831e906 a9fbba5 831e906 a9fbba5 831e906 ebbf860 831e906 ebbf860 831e906 |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 |
import streamlit as st
from middlewares.utils import gen_augmented_prompt_via_websearch
from middlewares.chat_client import chat
import json
from pprint import pformat
from notion_client import Client
def safe_get(data, dot_chained_keys):
'''
{'a': {'b': [{'c': 1}]}}
safe_get(data, 'a.b.0.c') -> 1
'''
keys = dot_chained_keys.split('.')
for key in keys:
try:
if isinstance(data, list):
data = data[int(key)]
else:
data = data[key]
except (KeyError, TypeError, IndexError):
return None
return data
def get_notion_data() :
integration_token = "secret_lTOe0q9dqqKQLRRb2KJwi7QFSl0vqoztroRFHW6MeQE"
notion_database_id = "6c0d877b823a4e3699016fa7083f3006"
client = Client(auth=integration_token)
first_db_rows = client.databases.query(notion_database_id)
rows = []
for row in first_db_rows['results']:
price = safe_get(row, 'properties.($) Per Unit.number')
store_link = safe_get(row, 'properties.Store Link.url')
supplier_email = safe_get(row, 'properties.Supplier Email.email')
exp_del = safe_get(row, 'properties.Expected Delivery.date')
collections = safe_get(row, 'properties.Collection.multi_select')
collection_names = []
for collection in collections :
collection_names.append(collection['name'])
status = safe_get(row, 'properties.Status.select.name')
sup_phone = safe_get(row, 'properties.Supplier Phone.phone_number')
stock_alert = safe_get(row, 'properties.Stock Alert.status.name')
prod_name = safe_get(row, 'properties.Product .title.0.text.content')
sku = safe_get(row, 'properties.SKU.number')
shipped_date = safe_get(row, 'properties.Shipped On.date')
on_order = safe_get(row, 'properties.On Order.number')
on_hand = safe_get(row, 'properties.On Hand.number')
size_names = []
sizes = safe_get(row, 'properties.Size.multi_select')
for size in sizes :
size_names.append(size['name'])
rows.append({
'Price Per unit': price,
'Store Link' : store_link,
'Supplier Email' : supplier_email,
'Expected Delivery' : exp_del,
'Collection' : collection_names,
'Status' : status,
'Supplier Phone' : sup_phone,
'Stock Alert' : stock_alert,
'Product Name' : prod_name,
'SKU' : sku,
'Sizes' : size_names,
'Shipped Date' : shipped_date,
'On Order' : on_order,
"On Hand" : on_hand,
})
notion_data_string = pformat(rows)
return notion_data_string
def generate_chat_stream(session_state, query, config):
# 1. augments prompt according to the template
# 2. returns chat_stream and source links
# 3. chat_stream and source links are used by stream_handler and show_source
chat_bot_dict = config["CHAT_BOTS"]
links = []
if session_state.rag_enabled:
with st.spinner("Fetching relevent documents from Web...."):
query, links = gen_augmented_prompt_via_websearch(
prompt=query,
pre_context=session_state.pre_context,
post_context=session_state.post_context,
pre_prompt=session_state.pre_prompt,
post_prompt=session_state.post_prompt,
search_vendor=session_state.search_vendor,
top_k=session_state.top_k,
n_crawl=session_state.n_crawl,
pass_prev=session_state.pass_prev,
prev_output=session_state.history[-1][1],
)
notion_data = get_notion_data()
with st.spinner("Generating response..."):
chat_stream = chat(session_state, notion_data + " " + query , config)
return chat_stream, links
|