main.py 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933
  1. from fastapi import (
  2. FastAPI,
  3. Depends,
  4. HTTPException,
  5. status,
  6. UploadFile,
  7. File,
  8. Form,
  9. )
  10. from fastapi.middleware.cors import CORSMiddleware
  11. import os, shutil, logging, re
  12. from pathlib import Path
  13. from typing import List
  14. from chromadb.utils.batch_utils import create_batches
  15. from langchain_community.document_loaders import (
  16. WebBaseLoader,
  17. TextLoader,
  18. PyPDFLoader,
  19. CSVLoader,
  20. BSHTMLLoader,
  21. Docx2txtLoader,
  22. UnstructuredEPubLoader,
  23. UnstructuredWordDocumentLoader,
  24. UnstructuredMarkdownLoader,
  25. UnstructuredXMLLoader,
  26. UnstructuredRSTLoader,
  27. UnstructuredExcelLoader,
  28. YoutubeLoader,
  29. )
  30. from langchain.text_splitter import RecursiveCharacterTextSplitter
  31. import validators
  32. import urllib.parse
  33. import socket
  34. from pydantic import BaseModel
  35. from typing import Optional
  36. import mimetypes
  37. import uuid
  38. import json
  39. import sentence_transformers
  40. from apps.web.models.documents import (
  41. Documents,
  42. DocumentForm,
  43. DocumentResponse,
  44. )
  45. from apps.rag.utils import (
  46. get_model_path,
  47. get_embedding_function,
  48. query_doc,
  49. query_doc_with_hybrid_search,
  50. query_collection,
  51. query_collection_with_hybrid_search,
  52. )
  53. from utils.misc import (
  54. calculate_sha256,
  55. calculate_sha256_string,
  56. sanitize_filename,
  57. extract_folders_after_data_docs,
  58. )
  59. from utils.utils import get_current_user, get_admin_user
  60. from config import (
  61. SRC_LOG_LEVELS,
  62. UPLOAD_DIR,
  63. DOCS_DIR,
  64. RAG_TOP_K,
  65. RAG_RELEVANCE_THRESHOLD,
  66. RAG_EMBEDDING_ENGINE,
  67. RAG_EMBEDDING_MODEL,
  68. RAG_EMBEDDING_MODEL_AUTO_UPDATE,
  69. RAG_EMBEDDING_MODEL_TRUST_REMOTE_CODE,
  70. ENABLE_RAG_HYBRID_SEARCH,
  71. ENABLE_RAG_WEB_LOADER_SSL_VERIFICATION,
  72. RAG_RERANKING_MODEL,
  73. PDF_EXTRACT_IMAGES,
  74. RAG_RERANKING_MODEL_AUTO_UPDATE,
  75. RAG_RERANKING_MODEL_TRUST_REMOTE_CODE,
  76. RAG_OPENAI_API_BASE_URL,
  77. RAG_OPENAI_API_KEY,
  78. DEVICE_TYPE,
  79. CHROMA_CLIENT,
  80. CHUNK_SIZE,
  81. CHUNK_OVERLAP,
  82. RAG_TEMPLATE,
  83. ENABLE_RAG_LOCAL_WEB_FETCH,
  84. )
  85. from constants import ERROR_MESSAGES
  86. log = logging.getLogger(__name__)
  87. log.setLevel(SRC_LOG_LEVELS["RAG"])
  88. app = FastAPI()
  89. app.state.TOP_K = RAG_TOP_K
  90. app.state.RELEVANCE_THRESHOLD = RAG_RELEVANCE_THRESHOLD
  91. app.state.ENABLE_RAG_HYBRID_SEARCH = ENABLE_RAG_HYBRID_SEARCH
  92. app.state.ENABLE_RAG_WEB_LOADER_SSL_VERIFICATION = (
  93. ENABLE_RAG_WEB_LOADER_SSL_VERIFICATION
  94. )
  95. app.state.CHUNK_SIZE = CHUNK_SIZE
  96. app.state.CHUNK_OVERLAP = CHUNK_OVERLAP
  97. app.state.RAG_EMBEDDING_ENGINE = RAG_EMBEDDING_ENGINE
  98. app.state.RAG_EMBEDDING_MODEL = RAG_EMBEDDING_MODEL
  99. app.state.RAG_RERANKING_MODEL = RAG_RERANKING_MODEL
  100. app.state.RAG_TEMPLATE = RAG_TEMPLATE
  101. app.state.OPENAI_API_BASE_URL = RAG_OPENAI_API_BASE_URL
  102. app.state.OPENAI_API_KEY = RAG_OPENAI_API_KEY
  103. app.state.PDF_EXTRACT_IMAGES = PDF_EXTRACT_IMAGES
  104. app.state.YOUTUBE_LOADER_LANGUAGE = ["en"]
  105. app.state.YOUTUBE_LOADER_TRANSLATION = None
  106. def update_embedding_model(
  107. embedding_model: str,
  108. update_model: bool = False,
  109. ):
  110. if embedding_model and app.state.RAG_EMBEDDING_ENGINE == "":
  111. app.state.sentence_transformer_ef = sentence_transformers.SentenceTransformer(
  112. get_model_path(embedding_model, update_model),
  113. device=DEVICE_TYPE,
  114. trust_remote_code=RAG_EMBEDDING_MODEL_TRUST_REMOTE_CODE,
  115. )
  116. else:
  117. app.state.sentence_transformer_ef = None
  118. def update_reranking_model(
  119. reranking_model: str,
  120. update_model: bool = False,
  121. ):
  122. if reranking_model:
  123. app.state.sentence_transformer_rf = sentence_transformers.CrossEncoder(
  124. get_model_path(reranking_model, update_model),
  125. device=DEVICE_TYPE,
  126. trust_remote_code=RAG_RERANKING_MODEL_TRUST_REMOTE_CODE,
  127. )
  128. else:
  129. app.state.sentence_transformer_rf = None
  130. update_embedding_model(
  131. app.state.RAG_EMBEDDING_MODEL,
  132. RAG_EMBEDDING_MODEL_AUTO_UPDATE,
  133. )
  134. update_reranking_model(
  135. app.state.RAG_RERANKING_MODEL,
  136. RAG_RERANKING_MODEL_AUTO_UPDATE,
  137. )
  138. app.state.EMBEDDING_FUNCTION = get_embedding_function(
  139. app.state.RAG_EMBEDDING_ENGINE,
  140. app.state.RAG_EMBEDDING_MODEL,
  141. app.state.sentence_transformer_ef,
  142. app.state.OPENAI_API_KEY,
  143. app.state.OPENAI_API_BASE_URL,
  144. )
  145. origins = ["*"]
  146. app.add_middleware(
  147. CORSMiddleware,
  148. allow_origins=origins,
  149. allow_credentials=True,
  150. allow_methods=["*"],
  151. allow_headers=["*"],
  152. )
  153. class CollectionNameForm(BaseModel):
  154. collection_name: Optional[str] = "test"
  155. class UrlForm(CollectionNameForm):
  156. url: str
  157. @app.get("/")
  158. async def get_status():
  159. return {
  160. "status": True,
  161. "chunk_size": app.state.CHUNK_SIZE,
  162. "chunk_overlap": app.state.CHUNK_OVERLAP,
  163. "template": app.state.RAG_TEMPLATE,
  164. "embedding_engine": app.state.RAG_EMBEDDING_ENGINE,
  165. "embedding_model": app.state.RAG_EMBEDDING_MODEL,
  166. "reranking_model": app.state.RAG_RERANKING_MODEL,
  167. }
  168. @app.get("/embedding")
  169. async def get_embedding_config(user=Depends(get_admin_user)):
  170. return {
  171. "status": True,
  172. "embedding_engine": app.state.RAG_EMBEDDING_ENGINE,
  173. "embedding_model": app.state.RAG_EMBEDDING_MODEL,
  174. "openai_config": {
  175. "url": app.state.OPENAI_API_BASE_URL,
  176. "key": app.state.OPENAI_API_KEY,
  177. },
  178. }
  179. @app.get("/reranking")
  180. async def get_reraanking_config(user=Depends(get_admin_user)):
  181. return {"status": True, "reranking_model": app.state.RAG_RERANKING_MODEL}
  182. class OpenAIConfigForm(BaseModel):
  183. url: str
  184. key: str
  185. class EmbeddingModelUpdateForm(BaseModel):
  186. openai_config: Optional[OpenAIConfigForm] = None
  187. embedding_engine: str
  188. embedding_model: str
  189. @app.post("/embedding/update")
  190. async def update_embedding_config(
  191. form_data: EmbeddingModelUpdateForm, user=Depends(get_admin_user)
  192. ):
  193. log.info(
  194. f"Updating embedding model: {app.state.RAG_EMBEDDING_MODEL} to {form_data.embedding_model}"
  195. )
  196. try:
  197. app.state.RAG_EMBEDDING_ENGINE = form_data.embedding_engine
  198. app.state.RAG_EMBEDDING_MODEL = form_data.embedding_model
  199. if app.state.RAG_EMBEDDING_ENGINE in ["ollama", "openai"]:
  200. if form_data.openai_config != None:
  201. app.state.OPENAI_API_BASE_URL = form_data.openai_config.url
  202. app.state.OPENAI_API_KEY = form_data.openai_config.key
  203. update_embedding_model(app.state.RAG_EMBEDDING_MODEL, True)
  204. app.state.EMBEDDING_FUNCTION = get_embedding_function(
  205. app.state.RAG_EMBEDDING_ENGINE,
  206. app.state.RAG_EMBEDDING_MODEL,
  207. app.state.sentence_transformer_ef,
  208. app.state.OPENAI_API_KEY,
  209. app.state.OPENAI_API_BASE_URL,
  210. )
  211. return {
  212. "status": True,
  213. "embedding_engine": app.state.RAG_EMBEDDING_ENGINE,
  214. "embedding_model": app.state.RAG_EMBEDDING_MODEL,
  215. "openai_config": {
  216. "url": app.state.OPENAI_API_BASE_URL,
  217. "key": app.state.OPENAI_API_KEY,
  218. },
  219. }
  220. except Exception as e:
  221. log.exception(f"Problem updating embedding model: {e}")
  222. raise HTTPException(
  223. status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
  224. detail=ERROR_MESSAGES.DEFAULT(e),
  225. )
  226. class RerankingModelUpdateForm(BaseModel):
  227. reranking_model: str
  228. @app.post("/reranking/update")
  229. async def update_reranking_config(
  230. form_data: RerankingModelUpdateForm, user=Depends(get_admin_user)
  231. ):
  232. log.info(
  233. f"Updating reranking model: {app.state.RAG_RERANKING_MODEL} to {form_data.reranking_model}"
  234. )
  235. try:
  236. app.state.RAG_RERANKING_MODEL = form_data.reranking_model
  237. update_reranking_model(app.state.RAG_RERANKING_MODEL, True)
  238. return {
  239. "status": True,
  240. "reranking_model": app.state.RAG_RERANKING_MODEL,
  241. }
  242. except Exception as e:
  243. log.exception(f"Problem updating reranking model: {e}")
  244. raise HTTPException(
  245. status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
  246. detail=ERROR_MESSAGES.DEFAULT(e),
  247. )
  248. @app.get("/config")
  249. async def get_rag_config(user=Depends(get_admin_user)):
  250. return {
  251. "status": True,
  252. "pdf_extract_images": app.state.PDF_EXTRACT_IMAGES,
  253. "chunk": {
  254. "chunk_size": app.state.CHUNK_SIZE,
  255. "chunk_overlap": app.state.CHUNK_OVERLAP,
  256. },
  257. "web_loader_ssl_verification": app.state.ENABLE_RAG_WEB_LOADER_SSL_VERIFICATION,
  258. "youtube": {
  259. "language": app.state.YOUTUBE_LOADER_LANGUAGE,
  260. "translation": app.state.YOUTUBE_LOADER_TRANSLATION,
  261. },
  262. }
  263. class ChunkParamUpdateForm(BaseModel):
  264. chunk_size: int
  265. chunk_overlap: int
  266. class YoutubeLoaderConfig(BaseModel):
  267. language: List[str]
  268. translation: Optional[str] = None
  269. class ConfigUpdateForm(BaseModel):
  270. pdf_extract_images: Optional[bool] = None
  271. chunk: Optional[ChunkParamUpdateForm] = None
  272. web_loader_ssl_verification: Optional[bool] = None
  273. youtube: Optional[YoutubeLoaderConfig] = None
  274. @app.post("/config/update")
  275. async def update_rag_config(form_data: ConfigUpdateForm, user=Depends(get_admin_user)):
  276. app.state.PDF_EXTRACT_IMAGES = (
  277. form_data.pdf_extract_images
  278. if form_data.pdf_extract_images != None
  279. else app.state.PDF_EXTRACT_IMAGES
  280. )
  281. app.state.CHUNK_SIZE = (
  282. form_data.chunk.chunk_size if form_data.chunk != None else app.state.CHUNK_SIZE
  283. )
  284. app.state.CHUNK_OVERLAP = (
  285. form_data.chunk.chunk_overlap
  286. if form_data.chunk != None
  287. else app.state.CHUNK_OVERLAP
  288. )
  289. app.state.ENABLE_RAG_WEB_LOADER_SSL_VERIFICATION = (
  290. form_data.web_loader_ssl_verification
  291. if form_data.web_loader_ssl_verification != None
  292. else app.state.ENABLE_RAG_WEB_LOADER_SSL_VERIFICATION
  293. )
  294. app.state.YOUTUBE_LOADER_LANGUAGE = (
  295. form_data.youtube.language
  296. if form_data.youtube != None
  297. else app.state.YOUTUBE_LOADER_LANGUAGE
  298. )
  299. app.state.YOUTUBE_LOADER_TRANSLATION = (
  300. form_data.youtube.translation
  301. if form_data.youtube != None
  302. else app.state.YOUTUBE_LOADER_TRANSLATION
  303. )
  304. return {
  305. "status": True,
  306. "pdf_extract_images": app.state.PDF_EXTRACT_IMAGES,
  307. "chunk": {
  308. "chunk_size": app.state.CHUNK_SIZE,
  309. "chunk_overlap": app.state.CHUNK_OVERLAP,
  310. },
  311. "web_loader_ssl_verification": app.state.ENABLE_RAG_WEB_LOADER_SSL_VERIFICATION,
  312. "youtube": {
  313. "language": app.state.YOUTUBE_LOADER_LANGUAGE,
  314. "translation": app.state.YOUTUBE_LOADER_TRANSLATION,
  315. },
  316. }
  317. @app.get("/template")
  318. async def get_rag_template(user=Depends(get_current_user)):
  319. return {
  320. "status": True,
  321. "template": app.state.RAG_TEMPLATE,
  322. }
  323. @app.get("/query/settings")
  324. async def get_query_settings(user=Depends(get_admin_user)):
  325. return {
  326. "status": True,
  327. "template": app.state.RAG_TEMPLATE,
  328. "k": app.state.TOP_K,
  329. "r": app.state.RELEVANCE_THRESHOLD,
  330. "hybrid": app.state.ENABLE_RAG_HYBRID_SEARCH,
  331. }
  332. class QuerySettingsForm(BaseModel):
  333. k: Optional[int] = None
  334. r: Optional[float] = None
  335. template: Optional[str] = None
  336. hybrid: Optional[bool] = None
  337. @app.post("/query/settings/update")
  338. async def update_query_settings(
  339. form_data: QuerySettingsForm, user=Depends(get_admin_user)
  340. ):
  341. app.state.RAG_TEMPLATE = form_data.template if form_data.template else RAG_TEMPLATE
  342. app.state.TOP_K = form_data.k if form_data.k else 4
  343. app.state.RELEVANCE_THRESHOLD = form_data.r if form_data.r else 0.0
  344. app.state.ENABLE_RAG_HYBRID_SEARCH = form_data.hybrid if form_data.hybrid else False
  345. return {
  346. "status": True,
  347. "template": app.state.RAG_TEMPLATE,
  348. "k": app.state.TOP_K,
  349. "r": app.state.RELEVANCE_THRESHOLD,
  350. "hybrid": app.state.ENABLE_RAG_HYBRID_SEARCH,
  351. }
  352. class QueryDocForm(BaseModel):
  353. collection_name: str
  354. query: str
  355. k: Optional[int] = None
  356. r: Optional[float] = None
  357. hybrid: Optional[bool] = None
  358. @app.post("/query/doc")
  359. def query_doc_handler(
  360. form_data: QueryDocForm,
  361. user=Depends(get_current_user),
  362. ):
  363. try:
  364. if app.state.ENABLE_RAG_HYBRID_SEARCH:
  365. return query_doc_with_hybrid_search(
  366. collection_name=form_data.collection_name,
  367. query=form_data.query,
  368. embedding_function=app.state.EMBEDDING_FUNCTION,
  369. k=form_data.k if form_data.k else app.state.TOP_K,
  370. reranking_function=app.state.sentence_transformer_rf,
  371. r=form_data.r if form_data.r else app.state.RELEVANCE_THRESHOLD,
  372. )
  373. else:
  374. return query_doc(
  375. collection_name=form_data.collection_name,
  376. query=form_data.query,
  377. embedding_function=app.state.EMBEDDING_FUNCTION,
  378. k=form_data.k if form_data.k else app.state.TOP_K,
  379. )
  380. except Exception as e:
  381. log.exception(e)
  382. raise HTTPException(
  383. status_code=status.HTTP_400_BAD_REQUEST,
  384. detail=ERROR_MESSAGES.DEFAULT(e),
  385. )
  386. class QueryCollectionsForm(BaseModel):
  387. collection_names: List[str]
  388. query: str
  389. k: Optional[int] = None
  390. r: Optional[float] = None
  391. hybrid: Optional[bool] = None
  392. @app.post("/query/collection")
  393. def query_collection_handler(
  394. form_data: QueryCollectionsForm,
  395. user=Depends(get_current_user),
  396. ):
  397. try:
  398. if app.state.ENABLE_RAG_HYBRID_SEARCH:
  399. return query_collection_with_hybrid_search(
  400. collection_names=form_data.collection_names,
  401. query=form_data.query,
  402. embedding_function=app.state.EMBEDDING_FUNCTION,
  403. k=form_data.k if form_data.k else app.state.TOP_K,
  404. reranking_function=app.state.sentence_transformer_rf,
  405. r=form_data.r if form_data.r else app.state.RELEVANCE_THRESHOLD,
  406. )
  407. else:
  408. return query_collection(
  409. collection_names=form_data.collection_names,
  410. query=form_data.query,
  411. embedding_function=app.state.EMBEDDING_FUNCTION,
  412. k=form_data.k if form_data.k else app.state.TOP_K,
  413. )
  414. except Exception as e:
  415. log.exception(e)
  416. raise HTTPException(
  417. status_code=status.HTTP_400_BAD_REQUEST,
  418. detail=ERROR_MESSAGES.DEFAULT(e),
  419. )
  420. @app.post("/youtube")
  421. def store_youtube_video(form_data: UrlForm, user=Depends(get_current_user)):
  422. try:
  423. loader = YoutubeLoader.from_youtube_url(
  424. form_data.url,
  425. add_video_info=True,
  426. language=app.state.YOUTUBE_LOADER_LANGUAGE,
  427. translation=app.state.YOUTUBE_LOADER_TRANSLATION,
  428. )
  429. data = loader.load()
  430. collection_name = form_data.collection_name
  431. if collection_name == "":
  432. collection_name = calculate_sha256_string(form_data.url)[:63]
  433. store_data_in_vector_db(data, collection_name, overwrite=True)
  434. return {
  435. "status": True,
  436. "collection_name": collection_name,
  437. "filename": form_data.url,
  438. }
  439. except Exception as e:
  440. log.exception(e)
  441. raise HTTPException(
  442. status_code=status.HTTP_400_BAD_REQUEST,
  443. detail=ERROR_MESSAGES.DEFAULT(e),
  444. )
  445. @app.post("/web")
  446. def store_web(form_data: UrlForm, user=Depends(get_current_user)):
  447. # "https://www.gutenberg.org/files/1727/1727-h/1727-h.htm"
  448. try:
  449. loader = get_web_loader(
  450. form_data.url, verify_ssl=app.state.ENABLE_RAG_WEB_LOADER_SSL_VERIFICATION
  451. )
  452. data = loader.load()
  453. collection_name = form_data.collection_name
  454. if collection_name == "":
  455. collection_name = calculate_sha256_string(form_data.url)[:63]
  456. store_data_in_vector_db(data, collection_name, overwrite=True)
  457. return {
  458. "status": True,
  459. "collection_name": collection_name,
  460. "filename": form_data.url,
  461. }
  462. except Exception as e:
  463. log.exception(e)
  464. raise HTTPException(
  465. status_code=status.HTTP_400_BAD_REQUEST,
  466. detail=ERROR_MESSAGES.DEFAULT(e),
  467. )
  468. def get_web_loader(url: str, verify_ssl: bool = True):
  469. # Check if the URL is valid
  470. if isinstance(validators.url(url), validators.ValidationError):
  471. raise ValueError(ERROR_MESSAGES.INVALID_URL)
  472. if not ENABLE_RAG_LOCAL_WEB_FETCH:
  473. # Local web fetch is disabled, filter out any URLs that resolve to private IP addresses
  474. parsed_url = urllib.parse.urlparse(url)
  475. # Get IPv4 and IPv6 addresses
  476. ipv4_addresses, ipv6_addresses = resolve_hostname(parsed_url.hostname)
  477. # Check if any of the resolved addresses are private
  478. # This is technically still vulnerable to DNS rebinding attacks, as we don't control WebBaseLoader
  479. for ip in ipv4_addresses:
  480. if validators.ipv4(ip, private=True):
  481. raise ValueError(ERROR_MESSAGES.INVALID_URL)
  482. for ip in ipv6_addresses:
  483. if validators.ipv6(ip, private=True):
  484. raise ValueError(ERROR_MESSAGES.INVALID_URL)
  485. return WebBaseLoader(url, verify_ssl=verify_ssl)
  486. def resolve_hostname(hostname):
  487. # Get address information
  488. addr_info = socket.getaddrinfo(hostname, None)
  489. # Extract IP addresses from address information
  490. ipv4_addresses = [info[4][0] for info in addr_info if info[0] == socket.AF_INET]
  491. ipv6_addresses = [info[4][0] for info in addr_info if info[0] == socket.AF_INET6]
  492. return ipv4_addresses, ipv6_addresses
  493. def store_data_in_vector_db(data, collection_name, overwrite: bool = False) -> bool:
  494. text_splitter = RecursiveCharacterTextSplitter(
  495. chunk_size=app.state.CHUNK_SIZE,
  496. chunk_overlap=app.state.CHUNK_OVERLAP,
  497. add_start_index=True,
  498. )
  499. docs = text_splitter.split_documents(data)
  500. if len(docs) > 0:
  501. log.info(f"store_data_in_vector_db {docs}")
  502. return store_docs_in_vector_db(docs, collection_name, overwrite), None
  503. else:
  504. raise ValueError(ERROR_MESSAGES.EMPTY_CONTENT)
  505. def store_text_in_vector_db(
  506. text, metadata, collection_name, overwrite: bool = False
  507. ) -> bool:
  508. text_splitter = RecursiveCharacterTextSplitter(
  509. chunk_size=app.state.CHUNK_SIZE,
  510. chunk_overlap=app.state.CHUNK_OVERLAP,
  511. add_start_index=True,
  512. )
  513. docs = text_splitter.create_documents([text], metadatas=[metadata])
  514. return store_docs_in_vector_db(docs, collection_name, overwrite)
  515. def store_docs_in_vector_db(docs, collection_name, overwrite: bool = False) -> bool:
  516. log.info(f"store_docs_in_vector_db {docs} {collection_name}")
  517. texts = [doc.page_content for doc in docs]
  518. metadatas = [doc.metadata for doc in docs]
  519. try:
  520. if overwrite:
  521. for collection in CHROMA_CLIENT.list_collections():
  522. if collection_name == collection.name:
  523. log.info(f"deleting existing collection {collection_name}")
  524. CHROMA_CLIENT.delete_collection(name=collection_name)
  525. collection = CHROMA_CLIENT.create_collection(name=collection_name)
  526. embedding_func = get_embedding_function(
  527. app.state.RAG_EMBEDDING_ENGINE,
  528. app.state.RAG_EMBEDDING_MODEL,
  529. app.state.sentence_transformer_ef,
  530. app.state.OPENAI_API_KEY,
  531. app.state.OPENAI_API_BASE_URL,
  532. )
  533. embedding_texts = list(map(lambda x: x.replace("\n", " "), texts))
  534. embeddings = embedding_func(embedding_texts)
  535. for batch in create_batches(
  536. api=CHROMA_CLIENT,
  537. ids=[str(uuid.uuid4()) for _ in texts],
  538. metadatas=metadatas,
  539. embeddings=embeddings,
  540. documents=texts,
  541. ):
  542. collection.add(*batch)
  543. return True
  544. except Exception as e:
  545. log.exception(e)
  546. if e.__class__.__name__ == "UniqueConstraintError":
  547. return True
  548. return False
  549. def get_loader(filename: str, file_content_type: str, file_path: str):
  550. file_ext = filename.split(".")[-1].lower()
  551. known_type = True
  552. known_source_ext = [
  553. "go",
  554. "py",
  555. "java",
  556. "sh",
  557. "bat",
  558. "ps1",
  559. "cmd",
  560. "js",
  561. "ts",
  562. "css",
  563. "cpp",
  564. "hpp",
  565. "h",
  566. "c",
  567. "cs",
  568. "sql",
  569. "log",
  570. "ini",
  571. "pl",
  572. "pm",
  573. "r",
  574. "dart",
  575. "dockerfile",
  576. "env",
  577. "php",
  578. "hs",
  579. "hsc",
  580. "lua",
  581. "nginxconf",
  582. "conf",
  583. "m",
  584. "mm",
  585. "plsql",
  586. "perl",
  587. "rb",
  588. "rs",
  589. "db2",
  590. "scala",
  591. "bash",
  592. "swift",
  593. "vue",
  594. "svelte",
  595. ]
  596. if file_ext == "pdf":
  597. loader = PyPDFLoader(file_path, extract_images=app.state.PDF_EXTRACT_IMAGES)
  598. elif file_ext == "csv":
  599. loader = CSVLoader(file_path)
  600. elif file_ext == "rst":
  601. loader = UnstructuredRSTLoader(file_path, mode="elements")
  602. elif file_ext == "xml":
  603. loader = UnstructuredXMLLoader(file_path)
  604. elif file_ext in ["htm", "html"]:
  605. loader = BSHTMLLoader(file_path, open_encoding="unicode_escape")
  606. elif file_ext == "md":
  607. loader = UnstructuredMarkdownLoader(file_path)
  608. elif file_content_type == "application/epub+zip":
  609. loader = UnstructuredEPubLoader(file_path)
  610. elif (
  611. file_content_type
  612. == "application/vnd.openxmlformats-officedocument.wordprocessingml.document"
  613. or file_ext in ["doc", "docx"]
  614. ):
  615. loader = Docx2txtLoader(file_path)
  616. elif file_content_type in [
  617. "application/vnd.ms-excel",
  618. "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet",
  619. ] or file_ext in ["xls", "xlsx"]:
  620. loader = UnstructuredExcelLoader(file_path)
  621. elif file_ext in known_source_ext or (
  622. file_content_type and file_content_type.find("text/") >= 0
  623. ):
  624. loader = TextLoader(file_path, autodetect_encoding=True)
  625. else:
  626. loader = TextLoader(file_path, autodetect_encoding=True)
  627. known_type = False
  628. return loader, known_type
  629. @app.post("/doc")
  630. def store_doc(
  631. collection_name: Optional[str] = Form(None),
  632. file: UploadFile = File(...),
  633. user=Depends(get_current_user),
  634. ):
  635. # "https://www.gutenberg.org/files/1727/1727-h/1727-h.htm"
  636. log.info(f"file.content_type: {file.content_type}")
  637. try:
  638. unsanitized_filename = file.filename
  639. filename = os.path.basename(unsanitized_filename)
  640. file_path = f"{UPLOAD_DIR}/{filename}"
  641. contents = file.file.read()
  642. with open(file_path, "wb") as f:
  643. f.write(contents)
  644. f.close()
  645. f = open(file_path, "rb")
  646. if collection_name == None:
  647. collection_name = calculate_sha256(f)[:63]
  648. f.close()
  649. loader, known_type = get_loader(filename, file.content_type, file_path)
  650. data = loader.load()
  651. try:
  652. result = store_data_in_vector_db(data, collection_name)
  653. if result:
  654. return {
  655. "status": True,
  656. "collection_name": collection_name,
  657. "filename": filename,
  658. "known_type": known_type,
  659. }
  660. except Exception as e:
  661. raise HTTPException(
  662. status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
  663. detail=e,
  664. )
  665. except Exception as e:
  666. log.exception(e)
  667. if "No pandoc was found" in str(e):
  668. raise HTTPException(
  669. status_code=status.HTTP_400_BAD_REQUEST,
  670. detail=ERROR_MESSAGES.PANDOC_NOT_INSTALLED,
  671. )
  672. else:
  673. raise HTTPException(
  674. status_code=status.HTTP_400_BAD_REQUEST,
  675. detail=ERROR_MESSAGES.DEFAULT(e),
  676. )
  677. class TextRAGForm(BaseModel):
  678. name: str
  679. content: str
  680. collection_name: Optional[str] = None
  681. @app.post("/text")
  682. def store_text(
  683. form_data: TextRAGForm,
  684. user=Depends(get_current_user),
  685. ):
  686. collection_name = form_data.collection_name
  687. if collection_name == None:
  688. collection_name = calculate_sha256_string(form_data.content)
  689. result = store_text_in_vector_db(
  690. form_data.content,
  691. metadata={"name": form_data.name, "created_by": user.id},
  692. collection_name=collection_name,
  693. )
  694. if result:
  695. return {"status": True, "collection_name": collection_name}
  696. else:
  697. raise HTTPException(
  698. status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
  699. detail=ERROR_MESSAGES.DEFAULT(),
  700. )
  701. @app.get("/scan")
  702. def scan_docs_dir(user=Depends(get_admin_user)):
  703. for path in Path(DOCS_DIR).rglob("./**/*"):
  704. try:
  705. if path.is_file() and not path.name.startswith("."):
  706. tags = extract_folders_after_data_docs(path)
  707. filename = path.name
  708. file_content_type = mimetypes.guess_type(path)
  709. f = open(path, "rb")
  710. collection_name = calculate_sha256(f)[:63]
  711. f.close()
  712. loader, known_type = get_loader(
  713. filename, file_content_type[0], str(path)
  714. )
  715. data = loader.load()
  716. try:
  717. result = store_data_in_vector_db(data, collection_name)
  718. if result:
  719. sanitized_filename = sanitize_filename(filename)
  720. doc = Documents.get_doc_by_name(sanitized_filename)
  721. if doc == None:
  722. doc = Documents.insert_new_doc(
  723. user.id,
  724. DocumentForm(
  725. **{
  726. "name": sanitized_filename,
  727. "title": filename,
  728. "collection_name": collection_name,
  729. "filename": filename,
  730. "content": (
  731. json.dumps(
  732. {
  733. "tags": list(
  734. map(
  735. lambda name: {"name": name},
  736. tags,
  737. )
  738. )
  739. }
  740. )
  741. if len(tags)
  742. else "{}"
  743. ),
  744. }
  745. ),
  746. )
  747. except Exception as e:
  748. log.exception(e)
  749. pass
  750. except Exception as e:
  751. log.exception(e)
  752. return True
  753. @app.get("/reset/db")
  754. def reset_vector_db(user=Depends(get_admin_user)):
  755. CHROMA_CLIENT.reset()
  756. @app.get("/reset")
  757. def reset(user=Depends(get_admin_user)) -> bool:
  758. folder = f"{UPLOAD_DIR}"
  759. for filename in os.listdir(folder):
  760. file_path = os.path.join(folder, filename)
  761. try:
  762. if os.path.isfile(file_path) or os.path.islink(file_path):
  763. os.unlink(file_path)
  764. elif os.path.isdir(file_path):
  765. shutil.rmtree(file_path)
  766. except Exception as e:
  767. log.error("Failed to delete %s. Reason: %s" % (file_path, e))
  768. try:
  769. CHROMA_CLIENT.reset()
  770. except Exception as e:
  771. log.exception(e)
  772. return True