Skip to content

Instantly share code, notes, and snippets.

View idontcalculate's full-sized avatar
🫘
magic

Sirius1389 idontcalculate

🫘
magic
View GitHub Profile
from fastembed.embedding import TextEmbedding
def get_book_vector(book_data):
embedder = TextEmbedding(model_name="BAAI/bge-base-en")
text = f"{book_data['title']} {book_data['description']}"
vector = list(embedder.embed(text))
return vector[0] # Since embed returns a generator, we convert it to a list and take the first item.
def get_query_vector(query_text):
embedder = TextEmbedding(model_name="BAAI/bge-base-en")
from config import COLLECTION_NAME
import os
import csv
from qdrant_client.http.models import VectorParams, PointStruct
from dotenv import load_dotenv
from generate_embedding import get_book_vector
from connect_qdrant import get_qdrant_client
load_dotenv()
qdrant_client = get_qdrant_client()
import os
import csv
from concurrent.futures import ThreadPoolExecutor
from qdrant_client import QdrantClient
from qdrant_client.http.models import PointStruct
from fastembed import TextEmbedding
from dotenv import load_dotenv
# Load environment variables from a .env file
load_dotenv()
import os
from qdrant_client import QdrantClient
from fastembed import TextEmbedding
from dotenv import load_dotenv
from qdrant_client.http.models import Distance, VectorParams
# Load environment variables from a .env file
load_dotenv()
# Access the environment variables
from query import search_books
def main():
query_text = "carl sagan, cosmos"
results = search_books(query_text)
if not results:
print("No results found")
else:
for point in results:
[package]
name = "io_server"
version = "0.1.0"
edition = "2021"
[dependencies]
tokio = { version = "1", features = ["full"] }
io-uring = "0.5"
[[bin]]
#[tokio::main]
async fn main() -> Result<()> {
let addr = "127.0.0.1:8080".parse::<SocketAddr>().unwrap();
let listener = TcpListener::bind(addr).await.unwrap();
let mut ring = IoUring::new(256)?;
loop {
let (stream, _) = listener.accept().await?;
handle_client(stream, &mut ring).await?;
}
use io_uring::{IoUring, opcode, types::Fd};
use std::net::SocketAddr;
use std::os::fd::AsRawFd;
use tokio::net::{TcpListener, TcpStream};
use std::io::Result;
async fn handle_client(stream: TcpStream, ring: &mut IoUring) -> Result<()> {
let mut buf = [0; 1024];
// Prepare a read operation
// Load user settings and apply them to the page
chrome.storage.sync.get(['fontSize', 'bgColor'], (settings) => {
if (settings.fontSize) {
document.body.style.fontSize = `${settings.fontSize}px`;
}
if (settings.bgColor) {
document.body.style.backgroundColor = settings.bgColor;
}
});
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<title>Hyperfocus</title>
<style>
body {
font-family: Arial, sans-serif;
width: 200px;
padding: 10px;