Compare commits

..
Author SHA1 Message Date
Typosaurus 6970f8a270 ticket #74 attempt 1 2026-07-19 20:39:20 +00:00
13 changed files with 38 additions and 134 deletions
File diff suppressed because one or more lines are too long
+1 -13
View File
@@ -1,6 +1,5 @@
# retoor <retoor@molodetz.nl> # retoor <retoor@molodetz.nl>
import logging import logging
import re
from typing import Any from typing import Any
from datetime import datetime, timezone from datetime import datetime, timezone
from fastapi.responses import RedirectResponse from fastapi.responses import RedirectResponse
@@ -56,12 +55,6 @@ CREATE_METADATA_KEYS = ("project_type", "is_private", "language", "topic", "stat
BOOKMARKABLE_TYPES = {"post", "gist", "project", "news"} BOOKMARKABLE_TYPES = {"post", "gist", "project", "news"}
REACTABLE_TYPES = {"post", "comment", "gist", "project"} REACTABLE_TYPES = {"post", "comment", "gist", "project"}
NOTE_PATTERN = re.compile(r"(^|\s)@note(\s|$)")
def has_note(text: str) -> bool:
return bool(text and NOTE_PATTERN.search(text))
logger = logging.getLogger(__name__) logger = logging.getLogger(__name__)
@@ -205,8 +198,6 @@ def create_content_item(
schedule_correction(user, table_name, uid, request) schedule_correction(user, table_name, uid, request)
schedule_modification(user, table_name, uid, request) schedule_modification(user, table_name, uid, request)
schedule_seo_meta_for_table(table_name, uid) schedule_seo_meta_for_table(table_name, uid)
if request and has_note(mention_text):
set_bookmark(request, user, target_type, uid, saved=True, source="note")
return uid, slug return uid, slug
@@ -388,8 +379,6 @@ def create_comment_record(
summary=f"{user['username']} commented on {target_type} {target_uid}: {content}", summary=f"{user['username']} commented on {target_type} {target_uid}: {content}",
links=comment_links, links=comment_links,
) )
if request and target_type in BOOKMARKABLE_TYPES and has_note(content):
set_bookmark(request, user, target_type, target_uid, saved=True, source="note")
return comment_uid, comment_url return comment_uid, comment_url
@@ -446,7 +435,7 @@ def delete_comment_record(request, user: dict, comment: dict) -> tuple[str, str]
def set_bookmark( def set_bookmark(
request, user: dict, target_type: str, target_uid: str, saved: bool, source: str = "manual" request, user: dict, target_type: str, target_uid: str, saved: bool
) -> bool: ) -> bool:
bookmarks = get_table("bookmarks") bookmarks = get_table("bookmarks")
existing = bookmarks.find_one( existing = bookmarks.find_one(
@@ -469,7 +458,6 @@ def set_bookmark(
"created_at": datetime.now(timezone.utc).isoformat(), "created_at": datetime.now(timezone.utc).isoformat(),
"deleted_at": None, "deleted_at": None,
"deleted_by": None, "deleted_by": None,
"source": source,
} }
) )
changed = True changed = True
+1
View File
@@ -18,6 +18,7 @@ NOTIFICATION_TYPES = [
{"key": "reminder", "label": "Reminders", "description": "A reminder or scheduled task you asked Devii to run fires"}, {"key": "reminder", "label": "Reminders", "description": "A reminder or scheduled task you asked Devii to run fires"},
{"key": "harvest_stolen", "label": "Farm raids", "description": "Someone steals a ready build from your Code Farm"}, {"key": "harvest_stolen", "label": "Farm raids", "description": "Someone steals a ready build from your Code Farm"},
{"key": "award", "label": "Awards", "description": "Someone gives you an award on your profile"}, {"key": "award", "label": "Awards", "description": "Someone gives you an award on your profile"},
{"key": "admin_alert", "label": "Admin alerts", "description": "System alerts requiring admin attention"},
] ]
-6
View File
@@ -243,12 +243,6 @@ def init_db():
) )
_index(db, "bookmarks", "idx_bookmarks_user", ["user_uid"]) _index(db, "bookmarks", "idx_bookmarks_user", ["user_uid"])
_index(db, "bookmarks", "idx_bookmarks_target", ["target_type", "target_uid"]) _index(db, "bookmarks", "idx_bookmarks_target", ["target_type", "target_uid"])
if "bookmarks" in tables:
bookmarks_table = get_table("bookmarks")
if not bookmarks_table.has_column("source"):
bookmarks_table.create_column_by_example("source", "manual")
_index(db, "bookmarks", "idx_bookmarks_source", ["source"])
_index(db, "bookmarks", "idx_bookmarks_user_source", ["user_uid", "source"])
_index(db, "polls", "idx_polls_post", ["post_uid"]) _index(db, "polls", "idx_polls_post", ["post_uid"])
_index(db, "poll_options", "idx_poll_options_poll", ["poll_uid"]) _index(db, "poll_options", "idx_poll_options_poll", ["poll_uid"])
_index(db, "poll_votes", "idx_poll_votes_poll", ["poll_uid"]) _index(db, "poll_votes", "idx_poll_votes_poll", ["poll_uid"])
@@ -152,28 +152,6 @@ four ways to sign requests.
"Bookmarks target posts, projects, gists, and news; see [Posts, Comments, Projects, Gists & News](/docs/content.html)." "Bookmarks target posts, projects, gists, and news; see [Posts, Comments, Projects, Gists & News](/docs/content.html)."
], ],
), ),
endpoint(
id="notes-listing",
method="GET",
path="/bookmarks/saved?source=note",
title="View personal notes",
summary="Render your personal notes (items tagged with @note). Returns an HTML page.",
auth="user",
interactive=True,
params=[
field(
"before",
"query",
"string",
False,
"",
"Pagination cursor (created_at of the last item).",
)
],
notes=[
"Notes are auto-created when you include @note in a post or comment body."
],
),
endpoint( endpoint(
id="polls-vote", id="polls-vote",
method="POST", method="POST",
+2 -6
View File
@@ -31,13 +31,10 @@ LABEL_BY_TYPE: dict[str, str] = {
@router.get("/saved", response_class=HTMLResponse) @router.get("/saved", response_class=HTMLResponse)
async def saved_page(request: Request, before: str = None, source: str = None): async def saved_page(request: Request, before: str = None):
user = require_user(request) user = require_user(request)
bookmarks = get_table("bookmarks") bookmarks = get_table("bookmarks")
filters: dict = {"user_uid": user["uid"]} rows, next_cursor = paginate(bookmarks, before=before, user_uid=user["uid"])
if source:
filters["source"] = source
rows, next_cursor = paginate(bookmarks, before=before, **filters)
uids_by_type: dict[str, list] = {} uids_by_type: dict[str, list] = {}
for row in rows: for row in rows:
@@ -88,7 +85,6 @@ async def saved_page(request: Request, before: str = None, source: str = None):
"user": user, "user": user,
"items": items, "items": items,
"next_cursor": next_cursor, "next_cursor": next_cursor,
"current_source": source or "",
}, },
model=SavedOut, model=SavedOut,
) )
+2
View File
@@ -23,6 +23,7 @@ from devplacepy.utils import (
require_user, require_user,
) )
from devplacepy.services.audit import record as audit from devplacepy.services.audit import record as audit
from devplacepy.services.devii.quota import notify_admins_quota_blocked
logger = logging.getLogger("devii.router") logger = logging.getLogger("devii.router")
@@ -279,6 +280,7 @@ async def devii_ws(websocket: WebSocket):
summary=f"AI request by {username or owner_id} blocked - 24h quota reached", summary=f"AI request by {username or owner_id} blocked - 24h quota reached",
metadata={"limit_usd": limit, "owner_kind": owner_kind}, metadata={"limit_usd": limit, "owner_kind": owner_kind},
) )
notify_admins_quota_blocked(owner_kind, owner_id, username)
await websocket.send_json( await websocket.send_json(
{ {
"type": "error", "type": "error",
+1 -1
View File
@@ -211,7 +211,7 @@ async def _set_favorite(request: Request, rant_id: str, saved: bool):
post = post_by_id(rant_id) post = post_by_id(rant_id)
if not post: if not post:
return dr_error("This rant does not exist.") return dr_error("This rant does not exist.")
set_bookmark(request, user, "post", post["uid"], saved, source="manual") set_bookmark(request, user, "post", post["uid"], saved)
return dr_ok() return dr_ok()
@@ -65,13 +65,6 @@ ENGAGEMENT_ACTIONS: tuple[Action, ...] = (
), ),
), ),
), ),
Action(
name="list_notes",
method="GET",
path="/bookmarks/saved?source=note",
summary="List personal notes (items tagged with @note)",
params=(query("before", "Pagination cursor."),),
),
Action( Action(
name="vote_poll", name="vote_poll",
method="POST", method="POST",
+26
View File
@@ -0,0 +1,26 @@
# retoor <retoor@molodetz.nl>
import logging
from devplacepy.database import get_table
from devplacepy.utils.notifications import create_notification
logger = logging.getLogger("devii.quota")
ADMIN_ALERT_TYPE = "admin_alert"
def notify_admins_quota_blocked(owner_kind: str, owner_id: str, username: str) -> None:
if owner_kind != "user":
return
admins = get_table("users").find(role="Admin")
for admin in admins:
if admin["uid"] == owner_id:
continue
create_notification(
admin["uid"],
ADMIN_ALERT_TYPE,
f"User {username} blocked - 24h AI quota reached",
owner_id,
"/admin/users",
)
+2
View File
@@ -10,6 +10,7 @@ from typing import Any
from devplacepy.database import get_table from devplacepy.database import get_table
from devplacepy.services.audit import record as audit from devplacepy.services.audit import record as audit
from devplacepy.services.devii.quota import notify_admins_quota_blocked
from devplacepy.services.manager import service_manager from devplacepy.services.manager import service_manager
from devplacepy.utils import is_admin, is_primary_admin from devplacepy.utils import is_admin, is_primary_admin
@@ -400,6 +401,7 @@ class TelegramBridge:
summary=f"Telegram AI request by {user.get('username', owner_id)} blocked - 24h quota reached", summary=f"Telegram AI request by {user.get('username', owner_id)} blocked - 24h quota reached",
metadata={"limit_usd": limit}, metadata={"limit_usd": limit},
) )
notify_admins_quota_blocked("user", owner_id, user.get("username", ""))
await self._service.send( await self._service.send(
chat_id, "Your daily AI quota is reached (100%). Please try again later." chat_id, "Your daily AI quota is reached (100%). Please try again later."
) )
+2 -32
View File
@@ -2,40 +2,10 @@
{% block extra_head %} {% block extra_head %}
<link rel="stylesheet" href="{{ static_url('/static/css/feed.css') }}"> <link rel="stylesheet" href="{{ static_url('/static/css/feed.css') }}">
<link rel="stylesheet" href="{{ static_url('/static/css/post.css') }}"> <link rel="stylesheet" href="{{ static_url('/static/css/post.css') }}">
<style>
.tab-bar {
display: flex;
gap: 0;
margin-bottom: 1rem;
border-bottom: 2px solid var(--border-color, #ddd);
}
.tab-btn {
padding: 0.5rem 1.25rem;
text-decoration: none;
color: var(--text-muted, #666);
border-bottom: 2px solid transparent;
margin-bottom: -2px;
transition: color 0.15s, border-color 0.15s;
font-weight: 500;
}
.tab-btn:hover {
color: var(--text-color, #333);
}
.tab-btn.active {
color: var(--accent-color, #0066cc);
border-bottom-color: var(--accent-color, #0066cc);
}
</style>
{% endblock %} {% endblock %}
{% block content %} {% block content %}
<div class="saved-page"> <div class="saved-page">
<h1 class="saved-title">Saved</h1> <h1 class="saved-title">Saved</h1>
<div class="tab-bar">
<a href="/bookmarks/saved" class="tab-btn {% if not current_source %}active{% endif %}">All</a>
<a href="/bookmarks/saved?source=note" class="tab-btn {% if current_source == 'note' %}active{% endif %}">Notes</a>
</div>
<div class="saved-list"> <div class="saved-list">
{% for item in items %} {% for item in items %}
<a href="{{ item.url }}" class="saved-item"> <a href="{{ item.url }}" class="saved-item">
@@ -44,13 +14,13 @@
<span class="saved-item-time">{{ dt_ago(item.created_at) if item.created_at else item.time_ago }}</span> <span class="saved-item-time">{{ dt_ago(item.created_at) if item.created_at else item.time_ago }}</span>
</a> </a>
{% else %} {% else %}
<div class="empty-state">Nothing saved yet. Use the Save button on posts, gists, projects and news, or add <code>@note</code> to your post or comment to auto-save it.</div> <div class="empty-state">Nothing saved yet. Use the Save button on posts, gists, projects and news.</div>
{% endfor %} {% endfor %}
</div> </div>
{% if next_cursor %} {% if next_cursor %}
<div class="load-more-wrap"> <div class="load-more-wrap">
<a href="/bookmarks/saved?before={{ next_cursor }}{% if current_source %}&source={{ current_source }}{% endif %}" class="btn btn-secondary">Load more</a> <a href="/bookmarks/saved?before={{ next_cursor }}" class="btn btn-secondary">Load more</a>
</div> </div>
{% endif %} {% endif %}
</div> </div>
-47
View File
@@ -76,50 +76,3 @@ def test_saved_page_lists_post_and_gist(app_server):
html = s.get(f"{BASE_URL}/bookmarks/saved").text html = s.get(f"{BASE_URL}/bookmarks/saved").text
assert post_title in html assert post_title in html
assert gist_title in html assert gist_title in html
def test_saved_page_source_filter_notes(app_server):
s, name = _session_bookmarks()
owner_uid = _uid_bookmarks(name)
post_title = f"Note post {int(time.time() * 1000)}"
manual_title = f"Manual bookmark {int(time.time() * 1000)}"
post_uid = _make_post_bookmarks(owner_uid, post_title)
manual_uid = _make_post_bookmarks(owner_uid, manual_title)
# Create a note bookmark (source=note) directly via DB
bookmarks = get_table("bookmarks")
note_uid = generate_uid()
bookmarks.insert(
{
"uid": note_uid,
"user_uid": owner_uid,
"target_uid": post_uid,
"target_type": "post",
"created_at": datetime.now(timezone.utc).isoformat(),
"deleted_at": None,
"deleted_by": None,
"source": "note",
}
)
# Create a manual bookmark (source=manual)
bookmarks.insert(
{
"uid": generate_uid(),
"user_uid": owner_uid,
"target_uid": manual_uid,
"target_type": "post",
"created_at": datetime.now(timezone.utc).isoformat(),
"deleted_at": None,
"deleted_by": None,
"source": "manual",
}
)
html = s.get(f"{BASE_URL}/bookmarks/saved?source=note").text
assert post_title in html
assert manual_title not in html
html_all = s.get(f"{BASE_URL}/bookmarks/saved").text
assert post_title in html_all
assert manual_title in html_all