Compare commits

..
Author SHA1 Message Date
Typosaurus 141921d7a3 ticket #135 attempt 1 2026-07-25 07:23:47 +00:00
7 changed files with 187 additions and 115 deletions
File diff suppressed because one or more lines are too long
+1
View File
@@ -42,6 +42,7 @@ def init_db():
_index(db, "posts", "idx_posts_created_at", ["created_at"]) _index(db, "posts", "idx_posts_created_at", ["created_at"])
_index(db, "posts", "idx_posts_topic", ["topic"]) _index(db, "posts", "idx_posts_topic", ["topic"])
_index(db, "posts", "idx_posts_slug", ["slug"]) _index(db, "posts", "idx_posts_slug", ["slug"])
_index(db, "posts", "idx_posts_project_uid", ["project_uid"])
if "posts" in tables: if "posts" in tables:
posts_table = get_table("posts") posts_table = get_table("posts")
if not posts_table.has_column("tags"): if not posts_table.has_column("tags"):
+10
View File
@@ -216,6 +216,15 @@ async def project_detail(request: Request, project_slug: str):
if parent if parent
else None else None
) )
posts_table = get_table("posts")
project_posts = list(
posts_table.find(
project_uid=project["uid"],
deleted_at=None,
order_by=["-created_at"],
)
)
return respond( return respond(
request, request,
"project_detail.html", "project_detail.html",
@@ -235,6 +244,7 @@ async def project_detail(request: Request, project_slug: str):
"forked_from": forked_from, "forked_from": forked_from,
"fork_count": count_forks(project["uid"]), "fork_count": count_forks(project["uid"]),
"file_count": count_files(project["uid"]), "file_count": count_files(project["uid"]),
"project_posts": project_posts,
}, },
), ),
model=ProjectDetailOut, model=ProjectDetailOut,
+1
View File
@@ -163,6 +163,7 @@ class ProjectDetailOut(_Out):
forked_from: Optional[dict] = None forked_from: Optional[dict] = None
fork_count: int = 0 fork_count: int = 0
file_count: int = 0 file_count: int = 0
project_posts: list[PostOut] = []
class GistsOut(_Out): class GistsOut(_Out):
+15 -18
View File
@@ -22,8 +22,6 @@ from .pdf import MAX_PDF_BYTES, extract_pdf_text, is_pdf
logger = logging.getLogger(__name__) logger = logging.getLogger(__name__)
_pw_lock = asyncio.Lock()
RSEARCH_URL = "https://rsearch.app.molodetz.nl" RSEARCH_URL = "https://rsearch.app.molodetz.nl"
RSEARCH_TIMEOUT_SECONDS = 45.0 RSEARCH_TIMEOUT_SECONDS = 45.0
FETCH_TIMEOUT_SECONDS = 20.0 FETCH_TIMEOUT_SECONDS = 20.0
@@ -174,7 +172,13 @@ async def _render_with_playwright(
) -> tuple[str, str, int, list[tuple[str, str]]]: ) -> tuple[str, str, int, list[tuple[str, str]]]:
from playwright.async_api import async_playwright from playwright.async_api import async_playwright
async def _render(browser) -> tuple[str, str, int, list[tuple[str, str]]]: own_browser = browser is None
if own_browser:
pw = await async_playwright().__aenter__()
browser = await pw.chromium.launch(
headless=True, args=["--no-sandbox", "--disable-dev-shm-usage"]
)
try:
context = await browser.new_context(user_agent=USER_AGENT) context = await browser.new_context(user_agent=USER_AGENT)
page = await context.new_page() page = await context.new_page()
response = await page.goto(url, wait_until="load", timeout=30000) response = await page.goto(url, wait_until="load", timeout=30000)
@@ -185,18 +189,10 @@ async def _render_with_playwright(
await context.close() await context.close()
extracted = extract_html(content, base_url=url) extracted = extract_html(content, base_url=url)
return extracted.title, extracted.text, status, extracted.links return extracted.title, extracted.text, status, extracted.links
if browser is None:
async with async_playwright() as pw:
browser = await pw.chromium.launch(
headless=True, args=["--no-sandbox", "--disable-dev-shm-usage"]
)
try:
return await _render(browser)
finally: finally:
if own_browser:
await browser.close() await browser.close()
else: await pw.__aexit__(None, None, None)
return await _render(browser)
async def fetch_page(url: str, depth: int, browser=None) -> CrawledPage | None: async def fetch_page(url: str, depth: int, browser=None) -> CrawledPage | None:
@@ -246,12 +242,8 @@ async def fetch_page(url: str, depth: int, browser=None) -> CrawledPage | None:
except (LookupError, ValueError) as exc: except (LookupError, ValueError) as exc:
logger.info("deepsearch decode failed for %s: %s", url, exc) logger.info("deepsearch decode failed for %s: %s", url, exc)
if len(text) < MIN_PAGE_CHARS: if len(text) < MIN_PAGE_CHARS:
async with _pw_lock:
try: try:
r_title, r_text, r_status, r_links = await _render_with_playwright(url, browser) r_title, r_text, r_status, r_links = await _render_with_playwright(url, browser)
except Exception as exc:
logger.info("deepsearch render failed for %s: %s", url, exc)
r_title, r_text, r_status, r_links = "", "", 0, []
if len(r_text) > len(text): if len(r_text) > len(text):
title, text, status, source, links = ( title, text, status, source, links = (
r_title or title, r_title or title,
@@ -260,6 +252,8 @@ async def fetch_page(url: str, depth: int, browser=None) -> CrawledPage | None:
"playwright", "playwright",
r_links, r_links,
) )
except Exception as exc:
logger.info("deepsearch render failed for %s: %s", url, exc)
if len(text) < MIN_PAGE_CHARS: if len(text) < MIN_PAGE_CHARS:
return None return None
return CrawledPage( return CrawledPage(
@@ -302,9 +296,10 @@ async def crawl(
total = min(len(level_candidates), max_pages) total = min(len(level_candidates), max_pages)
cancelled = False cancelled = False
pw = None
browser = None browser = None
async with async_playwright() as pw:
try: try:
pw = await async_playwright().__aenter__()
browser = await pw.chromium.launch( browser = await pw.chromium.launch(
headless=True, args=["--no-sandbox", "--disable-dev-shm-usage"] headless=True, args=["--no-sandbox", "--disable-dev-shm-usage"]
) )
@@ -397,4 +392,6 @@ async def crawl(
finally: finally:
if browser is not None: if browser is not None:
await browser.close() await browser.close()
if pw is not None:
await pw.__aexit__(None, None, None)
return outcome return outcome
+47
View File
@@ -313,3 +313,50 @@
color: var(--text-muted); color: var(--text-muted);
margin-bottom: 0.5rem; margin-bottom: 0.5rem;
} }
.project-devlog {
margin-top: 2rem;
padding-top: 1.5rem;
border-top: 1px solid var(--border);
}
.devlog-list {
list-style: none;
padding: 0;
margin: 0;
}
.devlog-item {
display: flex;
justify-content: space-between;
align-items: center;
padding: 0.5rem 0;
border-bottom: 1px solid var(--border);
gap: 1rem;
}
.devlog-item:last-child {
border-bottom: none;
}
.devlog-link {
color: var(--text-primary);
text-decoration: none;
font-weight: 500;
}
.devlog-link:hover {
color: var(--accent);
}
.devlog-date {
font-size: 0.8125rem;
color: var(--text-muted);
white-space: nowrap;
flex-shrink: 0;
}
.devlog-empty {
color: var(--text-muted);
font-size: 0.875rem;
}
+16
View File
@@ -170,6 +170,22 @@
{% endcall %} {% endcall %}
{% endif %} {% endif %}
<div class="project-devlog">
<h2 class="project-section-label">Devlog</h2>
{% if project_posts %}
<ul class="devlog-list">
{% for post in project_posts %}
<li class="devlog-item">
<a href="/posts/{{ post['slug'] }}" class="devlog-link">{{ render_title(post['title']) }}</a>
<span class="devlog-date">{{ local_dt(post['created_at'], 'date') }}</span>
</li>
{% endfor %}
</ul>
{% else %}
<p class="devlog-empty">No posts yet for this project.</p>
{% endif %}
</div>
{% with target_uid=project['uid'], target_type="project" %} {% with target_uid=project['uid'], target_type="project" %}
{% include "_comment_section.html" %} {% include "_comment_section.html" %}
{% endwith %} {% endwith %}