Phase 3: merge junimos branch — heuristic snippets, noscript stripping, junimo theme, browse 50

This commit is contained in:
lichenblankie 2026-06-05 04:48:15 +00:00
commit e65a91d039
5 changed files with 1714 additions and 86 deletions

2
app.py
View file

@ -4,7 +4,7 @@ import threading
import RNS import RNS
from http.server import HTTPServer from http.server import HTTPServer
from db import init_db, set_setting from db import init_db, get_setting, set_setting
from handlers import dispatch_request from handlers import dispatch_request
from gateway import GatewayState, GatewayHandler, GATEWAY_PORT from gateway import GatewayState, GatewayHandler, GATEWAY_PORT

129
db.py
View file

@ -317,88 +317,97 @@ def fetch_page(url):
label = a.get_text(strip=True) or href label = a.get_text(strip=True) or href
links.append((href, label[:200])) links.append((href, label[:200]))
# Extract meta description before stripping tags # Extract meta description before stripping tags (case-insensitive)
meta_desc = "" meta_desc = ""
meta_tag = soup.find("meta", attrs={"name": "description"}) for m in soup.find_all("meta"):
if meta_tag and meta_tag.get("content"): name = (m.get("name") or "").lower()
meta_desc = meta_tag["content"].strip() prop = (m.get("property") or "").lower()
if not meta_desc: content = (m.get("content") or "").strip()
# Try og:description as fallback if not content:
og_tag = soup.find("meta", attrs={"property": "og:description"}) continue
if og_tag and og_tag.get("content"): if name == "description" and len(content) > len(meta_desc):
meta_desc = og_tag["content"].strip() meta_desc = content
elif prop == "og:description" and not meta_desc:
meta_desc = content
for tag in soup(["script", "style", "nav", "footer", "header"]): for tag in soup(["script", "style", "nav", "footer", "header", "noscript", "aside"]):
tag.decompose() tag.decompose()
title = soup.title.string.strip() if soup.title and soup.title.string else url title = soup.title.string.strip() if soup.title and soup.title.string else url
# Extract paragraph text for better summary generation
paragraphs = []
for p in soup.find_all("p"):
text = p.get_text(strip=True)
if len(text) >= 40:
paragraphs.append(text)
body = soup.get_text(separator=" ", strip=True) body = soup.get_text(separator=" ", strip=True)
return title, body, links, meta_desc return title, body, links, meta_desc, paragraphs
def _generate_summary(title, body): def _generate_summary(title, body, paragraphs=None):
"""Generate a summary from body text using centroid extractive method. """Generate a summary by extracting the best sentence from the page.
Filters out UI debris, embeds remaining sentences, finds the one Priority: sentence mentioning the site name > first paragraph sentence
closest to the centroid (most representative of the page). > first body sentence > title.
""" """
import re import re
# Split on sentence boundaries
raw = re.split(r'(?<=[.!?])\s+', body)
sentences = []
noise_patterns = re.compile( noise_patterns = re.compile(
r'arrow-|fedilink|message-square|link-external|' r'arrow-|fedilink|message-square|link-external|'
r'skip to|cookie|subscribe|sign up|log in|' r'skip to|cookie|subscribe|sign up|log in|'
r'privacy policy|terms of|©|\bads?\b', r'privacy policy|terms of|©|\bads?\b',
re.IGNORECASE re.IGNORECASE
) )
for s in raw:
s = s.strip() def _filter_sentences(raw):
if len(s) < 40: result = []
continue for s in raw:
words = s.split() s = s.strip()
if len(words) < 7: if len(s) < 40 or len(s.split()) < 7:
continue continue
# Skip if mostly non-alpha (icons, arrows, encoded chars) alpha_chars = sum(1 for c in s if c.isalpha() or c == ' ')
alpha_chars = sum(1 for c in s if c.isalpha() or c == ' ') if alpha_chars < len(s) * 0.6:
if alpha_chars < len(s) * 0.6: continue
continue if s.count('|') > 2 or s.count('·') > 2 or s.count('') > 0:
# Skip nav/menu patterns continue
if s.count('|') > 2 or s.count('·') > 2 or s.count('') > 0: if noise_patterns.search(s):
continue continue
# Skip UI debris result.append(s)
if noise_patterns.search(s): return result
continue
sentences.append(s) # Prefer sentences from <p> tags (actual content, not UI)
sentences = []
if paragraphs:
raw = []
for p in paragraphs:
raw.extend(re.split(r'(?<=[.!?])\s+', p))
sentences = _filter_sentences(raw)
# Fall back to full body text
if not sentences:
raw = re.split(r'(?<=[.!?])\s+', body)
sentences = _filter_sentences(raw)
if not sentences: if not sentences:
# Last resort: take the first chunk of body that looks like prose return title[:200] if title else ""
clean = re.sub(r'\s+', ' ', body).strip()
return clean[:160] + "..." if len(clean) > 160 else clean # Prefer a sentence that mentions the site name
if len(sentences) == 1: if title:
s = sentences[0] title_words = [w.lower() for w in re.split(r'\W+', title) if len(w) >= 3]
return s[:200] if len(s) > 200 else s for s in sentences:
try: s_lower = s.lower()
from embeddings import embed if sum(1 for w in title_words if w in s_lower) >= max(1, len(title_words) // 2):
import numpy as np return s[:200]
embs = embed(sentences[:50]) # cap to avoid embedding too many
centroid = embs.mean(axis=0, keepdims=True) # Otherwise use the first quality sentence
centroid = centroid / max(np.linalg.norm(centroid), 1e-12) return sentences[0][:200]
scores = (embs @ centroid.T).flatten()
best_idx = int(np.argmax(scores))
result = sentences[best_idx]
# Try to add a second sentence if it fits
if best_idx + 1 < len(sentences) and len(result) + len(sentences[best_idx + 1]) + 1 <= 200:
result += " " + sentences[best_idx + 1]
return result[:200] if len(result) > 200 else result
except Exception:
return sentences[0][:200]
def index_url(url, note=""): def index_url(url, note=""):
url = clean_url(url) url = clean_url(url)
title, body, links, meta_desc = fetch_page(url) title, body, links, meta_desc, paragraphs = fetch_page(url)
# Use meta description if available, otherwise generate from body # Use meta description if available and meaningful, otherwise generate from body
summary = meta_desc if meta_desc else _generate_summary(title, body) summary = meta_desc if meta_desc and len(meta_desc) > 20 else _generate_summary(title, body, paragraphs)
db = get_db() db = get_db()
try: try:
now = __import__("datetime").datetime.now().strftime("%Y-%m-%dT%H:%M:%S") now = __import__("datetime").datetime.now().strftime("%Y-%m-%dT%H:%M:%S")

View file

@ -506,21 +506,24 @@ def hybrid_search(query_text, bm25_ranked_ids, limit=10, db=None, use_reranker=F
# --------------------------------------------------------------------------- # ---------------------------------------------------------------------------
def reindex_all(db=None, progress_callback=None): def reindex_all(db=None, progress_callback=None):
"""Embed all pages that don't yet have chunks. Also generates missing summaries. Rebuilds HNSW index.""" """Re-embed all pages and regenerate all summaries. Rebuilds HNSW index."""
from db import get_db, return_db, _generate_summary from db import get_db, return_db, _generate_summary
own_db = db is None own_db = db is None
if own_db: if own_db:
db = get_db() db = get_db()
try: try:
# Clear existing chunks so everything is regenerated
db.execute("DELETE FROM chunks")
db.commit()
rows = db.execute( rows = db.execute(
"SELECT p.id, p.title, p.body, p.summary FROM pages p " "SELECT p.id, p.title, p.body, p.summary FROM pages p"
"WHERE p.id NOT IN (SELECT DISTINCT page_id FROM chunks WHERE page_id IS NOT NULL)"
).fetchall() ).fetchall()
total = len(rows) total = len(rows)
for i, row in enumerate(rows): for i, row in enumerate(rows):
store_embeddings(row["id"], row["title"], row["body"], db) store_embeddings(row["id"], row["title"], row["body"], db)
# Generate summary if missing # Only regenerate summary if missing
if not row["summary"]: if not row["summary"]:
summary = _generate_summary(row["title"], row["body"]) summary = _generate_summary(row["title"], row["body"])
db.execute("UPDATE pages SET summary = ? WHERE id = ?", (summary, row["id"])) db.execute("UPDATE pages SET summary = ? WHERE id = ?", (summary, row["id"]))
@ -528,20 +531,9 @@ def reindex_all(db=None, progress_callback=None):
if progress_callback: if progress_callback:
progress_callback(i + 1, total) progress_callback(i + 1, total)
# Generate summaries for pages that already have chunks but no summary
no_summary = db.execute(
"SELECT id, title, body FROM pages WHERE summary = '' OR summary IS NULL"
).fetchall()
for row in no_summary:
summary = _generate_summary(row["title"], row["body"])
db.execute("UPDATE pages SET summary = ? WHERE id = ?", (summary, row["id"]))
if no_summary:
db.commit()
# Also handle remote pages # Also handle remote pages
remote_rows = db.execute( remote_rows = db.execute(
"SELECT rp.id, rp.title, rp.note FROM remote_pages rp " "SELECT rp.id, rp.title, rp.note FROM remote_pages rp"
"WHERE rp.id NOT IN (SELECT DISTINCT remote_page_id FROM chunks WHERE remote_page_id IS NOT NULL)"
).fetchall() ).fetchall()
for rp in remote_rows: for rp in remote_rows:

View file

@ -116,6 +116,7 @@ def _error(status):
PER_PAGE = 10 PER_PAGE = 10
BROWSE_PER_PAGE = 50
def _paginate(query, key="p"): def _paginate(query, key="p"):
@ -126,10 +127,11 @@ def _paginate(query, key="p"):
return max(1, page) return max(1, page)
def _page_nav(page, total, base_url): def _page_nav(page, total, base_url, per_page=None):
if total <= PER_PAGE: per_page = per_page or PER_PAGE
if total <= per_page:
return "" return ""
total_pages = (total + PER_PAGE - 1) // PER_PAGE total_pages = (total + per_page - 1) // per_page
sep = "&" if "?" in base_url else "?" sep = "&" if "?" in base_url else "?"
parts = [] parts = []
if page > 1: if page > 1:
@ -377,13 +379,13 @@ def handle_add_submit(body):
def handle_pages(query=None): def handle_pages(query=None):
page = _paginate(query or {}) page = _paginate(query or {})
offset = (page - 1) * PER_PAGE offset = (page - 1) * BROWSE_PER_PAGE
db = get_db() db = get_db()
try: try:
total = db.execute("SELECT count(*) FROM pages").fetchone()[0] total = db.execute("SELECT count(*) FROM pages").fetchone()[0]
rows = db.execute( rows = db.execute(
"SELECT id, url, title, note FROM pages ORDER BY id DESC LIMIT ? OFFSET ?", "SELECT id, url, title, note FROM pages ORDER BY id DESC LIMIT ? OFFSET ?",
(PER_PAGE, offset), (BROWSE_PER_PAGE, offset),
).fetchall() ).fetchall()
items = "" items = ""
for r in rows: for r in rows:
@ -404,7 +406,7 @@ def handle_pages(query=None):
return _respond( return _respond(
f"<h1>indexed pages ({total})</h1>" f"<h1>indexed pages ({total})</h1>"
f"<ul>{items}</ul>" f"<ul>{items}</ul>"
f'{_page_nav(page, total, "/pages")}' f'{_page_nav(page, total, "/pages", BROWSE_PER_PAGE)}'
f'<p><a href="/export">export</a> | <a href="/import">import</a></p>' f'<p><a href="/export">export</a> | <a href="/import">import</a></p>'
f'<a href="/">back</a>' f'<a href="/">back</a>'
) )
@ -678,7 +680,7 @@ def handle_tags():
def handle_tag_browse(tag_name, query=None): def handle_tag_browse(tag_name, query=None):
page = _paginate(query or {}) page = _paginate(query or {})
offset = (page - 1) * PER_PAGE offset = (page - 1) * BROWSE_PER_PAGE
db = get_db() db = get_db()
try: try:
total = db.execute( total = db.execute(
@ -690,7 +692,7 @@ def handle_tag_browse(tag_name, query=None):
"JOIN page_tags pt ON p.id = pt.page_id " "JOIN page_tags pt ON p.id = pt.page_id "
"JOIN tags t ON t.id = pt.tag_id " "JOIN tags t ON t.id = pt.tag_id "
"WHERE t.name = ? ORDER BY p.id DESC LIMIT ? OFFSET ?", "WHERE t.name = ? ORDER BY p.id DESC LIMIT ? OFFSET ?",
(tag_name, PER_PAGE, offset), (tag_name, BROWSE_PER_PAGE, offset),
).fetchall() ).fetchall()
items = "" items = ""
for r in rows: for r in rows:
@ -707,7 +709,7 @@ def handle_tag_browse(tag_name, query=None):
f'<h1>tag: {esc(tag_name)}</h1>' f'<h1>tag: {esc(tag_name)}</h1>'
f'<p>{total} page(s)</p>' f'<p>{total} page(s)</p>'
f'<ul>{items}</ul>' f'<ul>{items}</ul>'
f'{_page_nav(page, total, f"/tags/{esc(tag_name)}")}' f'{_page_nav(page, total, f"/tags/{esc(tag_name)}", BROWSE_PER_PAGE)}'
f'<a href="/tags">all tags</a> | <a href="/">back</a>' f'<a href="/tags">all tags</a> | <a href="/">back</a>'
) )

1625
themes/junimo.html Normal file

File diff suppressed because it is too large Load diff