Compare commits
13
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
d7182820f5 | ||
|
|
cb1bd31de6 | ||
|
|
8d51fbff7a | ||
|
|
4c1cff160d | ||
|
|
73bac01b4e | ||
|
|
43fd99c808 | ||
|
|
41149fe709 | ||
|
|
af1a6c8165 | ||
|
|
2a94acddf3 | ||
|
|
0c11869af8 | ||
|
|
b3f7e6006e | ||
|
|
86433afe1f | ||
|
|
30194463b5 |
@@ -0,0 +1,16 @@
|
||||
{
|
||||
"$schema": "https://anthropic.com/claude-code/marketplace.schema.json",
|
||||
"name": "dnspegasus",
|
||||
"description": "Self-hosted Claude Code plugins for the dnspegasus.net infrastructure.",
|
||||
"owner": {
|
||||
"name": "jknapp",
|
||||
"url": "https://repo.anhonesthost.net/jknapp/shared-memory"
|
||||
},
|
||||
"plugins": [
|
||||
{
|
||||
"name": "shared-memory",
|
||||
"source": "./plugin",
|
||||
"description": "Shared persistent memory and snippet library for Claude Code sessions, backed by memory.dnspegasus.net and authenticated with Authentik OIDC."
|
||||
}
|
||||
]
|
||||
}
|
||||
@@ -0,0 +1,25 @@
|
||||
# CLAUDE.md — shared-memory
|
||||
|
||||
Project key (for the shared-memory MCP): `shared-memory` (set by the `.shared-memory-project` marker at the repo root).
|
||||
|
||||
## Consulting memory before substantive work
|
||||
|
||||
There are TWO memory stores. The file-based memory (`MEMORY.md` + topic files) is auto-loaded into context every session. The **shared-memory MCP** (`mcp__shared-memory__*`) is NOT auto-loaded — you must query it. Query on demand when you need detail; do not bulk-load everything (that wastes context).
|
||||
|
||||
When a request draws on accumulated project knowledge — an architecture/development overview, debugging, planning, reviewing, or implementing a feature, or any question about how the system works — do this BEFORE answering or acting:
|
||||
|
||||
1. Use what's already in the auto-loaded `MEMORY.md` index.
|
||||
2. ALSO check the shared-memory MCP: call `project_identify` once per session (resolves the key from `.shared-memory-project`), then `memory_search` with the task topic in natural language (a couple of queries if the task spans areas). Fetch full bodies with `memory_get` when a hit looks relevant.
|
||||
3. Fold both sources into your answer; note when something came from saved memory.
|
||||
|
||||
## Reusing saved snippets (boilerplate / templates) before recreating work
|
||||
|
||||
Snippets (`mcp__shared-memory__snippet_*`) hold reusable artifacts — boilerplate, standard formats, checklists, established workflows. They are pull-only and, unlike memory, **NOT searchable**: `snippet_get` fetches by EXACT name, and the `description` shown by `snippet_list` is the ONLY discovery surface (tags are just for human browsing).
|
||||
|
||||
Before hand-writing standard/boilerplate code or re-deriving a known workflow, check whether a template already exists:
|
||||
|
||||
1. Call `snippet_list` once — it's cheap: it returns names + descriptions + tags, **no bodies**. Scan the descriptions for a match.
|
||||
2. If one fits, `snippet_get <name>` to pull just that body and apply it, instead of recreating it from scratch.
|
||||
3. When you produce a reusable artifact worth keeping, save it with `snippet_put` under a stable, predictable name (e.g. `boilerplate/<area>/<thing>`) and a concrete "when to use" `description` so a future agent can find it by scanning `snippet_list`.
|
||||
|
||||
Skip both checks only for trivial, self-contained requests (a quick edit, a one-off shell command, casual conversation) where prior project context can't matter. If the MCP server isn't connected in this session, proceed with file memory and say so.
|
||||
@@ -0,0 +1,151 @@
|
||||
"use client";
|
||||
|
||||
import { useEffect, useId, useRef, useState } from "react";
|
||||
|
||||
const field =
|
||||
"block w-full rounded-md bg-surface-1 border border-border " +
|
||||
"text-fg placeholder:text-fg-subtle " +
|
||||
"focus:border-accent-400 focus:outline-none " +
|
||||
"disabled:opacity-50 transition-colors h-9 px-3 text-sm";
|
||||
|
||||
/**
|
||||
* Type-ahead project filter. A text input whose value submits as `name`
|
||||
* (default "project") via the enclosing GET form, plus a dropdown of the
|
||||
* projects the user can read that narrows as they type. Selecting a
|
||||
* suggestion fills the box and submits the form so the filter applies
|
||||
* immediately; free text is still allowed (the input value is what
|
||||
* submits), so an arbitrary key keeps working even if it isn't listed.
|
||||
*/
|
||||
export function ProjectCombobox({
|
||||
name = "project",
|
||||
defaultValue = "",
|
||||
options,
|
||||
className = "",
|
||||
}: {
|
||||
name?: string;
|
||||
defaultValue?: string;
|
||||
options: string[];
|
||||
className?: string;
|
||||
}) {
|
||||
const [value, setValue] = useState(defaultValue);
|
||||
const [open, setOpen] = useState(false);
|
||||
const [active, setActive] = useState(0);
|
||||
const rootRef = useRef<HTMLDivElement>(null);
|
||||
const inputRef = useRef<HTMLInputElement>(null);
|
||||
const listId = useId();
|
||||
|
||||
// Case-insensitive substring match. An empty box shows the full list so
|
||||
// the control doubles as a "browse my projects" dropdown.
|
||||
const q = value.trim().toLowerCase();
|
||||
const matches = q
|
||||
? options.filter((o) => o.toLowerCase().includes(q))
|
||||
: options;
|
||||
|
||||
// Close when focus/click leaves the widget.
|
||||
useEffect(() => {
|
||||
if (!open) return;
|
||||
function onPointerDown(e: PointerEvent) {
|
||||
if (!rootRef.current?.contains(e.target as Node)) setOpen(false);
|
||||
}
|
||||
document.addEventListener("pointerdown", onPointerDown);
|
||||
return () => document.removeEventListener("pointerdown", onPointerDown);
|
||||
}, [open]);
|
||||
|
||||
function commit(next: string) {
|
||||
setValue(next);
|
||||
setOpen(false);
|
||||
// Write the DOM value synchronously before submitting: setValue only
|
||||
// schedules a re-render (React batches it), so the input's serialized
|
||||
// value would still be the pre-selection text when requestSubmit reads
|
||||
// it. The upcoming render sets the same value, so there's no flicker.
|
||||
if (inputRef.current) inputRef.current.value = next;
|
||||
// requestSubmit fires a real submit (unlike form.submit()).
|
||||
inputRef.current?.form?.requestSubmit();
|
||||
}
|
||||
|
||||
function onKeyDown(e: React.KeyboardEvent<HTMLInputElement>) {
|
||||
if (e.key === "ArrowDown") {
|
||||
e.preventDefault();
|
||||
if (!open) {
|
||||
setOpen(true);
|
||||
setActive(0);
|
||||
} else {
|
||||
setActive((i) => Math.min(i + 1, matches.length - 1));
|
||||
}
|
||||
} else if (e.key === "ArrowUp") {
|
||||
e.preventDefault();
|
||||
setActive((i) => Math.max(i - 1, 0));
|
||||
} else if (e.key === "Enter") {
|
||||
// Only intercept Enter to pick a highlighted suggestion; otherwise
|
||||
// let it fall through and submit the form with the typed value.
|
||||
if (open && matches[active]) {
|
||||
e.preventDefault();
|
||||
commit(matches[active]);
|
||||
}
|
||||
} else if (e.key === "Escape") {
|
||||
if (open) {
|
||||
e.preventDefault();
|
||||
setOpen(false);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
const showList = open && matches.length > 0;
|
||||
|
||||
return (
|
||||
<div ref={rootRef} className={`relative ${className}`}>
|
||||
<input
|
||||
ref={inputRef}
|
||||
type="text"
|
||||
name={name}
|
||||
value={value}
|
||||
placeholder="Project key…"
|
||||
autoComplete="off"
|
||||
spellCheck={false}
|
||||
role="combobox"
|
||||
aria-expanded={showList}
|
||||
aria-controls={listId}
|
||||
aria-autocomplete="list"
|
||||
aria-activedescendant={
|
||||
showList ? `${listId}-opt-${active}` : undefined
|
||||
}
|
||||
className={field}
|
||||
onChange={(e) => {
|
||||
setValue(e.target.value);
|
||||
setOpen(true);
|
||||
setActive(0);
|
||||
}}
|
||||
onFocus={() => setOpen(true)}
|
||||
onKeyDown={onKeyDown}
|
||||
/>
|
||||
{showList ? (
|
||||
<ul
|
||||
id={listId}
|
||||
role="listbox"
|
||||
className="absolute z-20 mt-1 max-h-60 w-full overflow-auto rounded-md border border-border bg-surface-1 py-1 shadow-lg"
|
||||
>
|
||||
{matches.map((opt, i) => (
|
||||
<li
|
||||
key={opt}
|
||||
id={`${listId}-opt-${i}`}
|
||||
role="option"
|
||||
aria-selected={i === active}
|
||||
className={`cursor-pointer px-3 py-1.5 font-mono text-sm text-fg ${
|
||||
i === active ? "bg-surface-2" : ""
|
||||
}`}
|
||||
// pointerdown (not click) so the choice registers before the
|
||||
// input's blur/outside-pointerdown handler closes the list.
|
||||
onPointerDown={(e) => {
|
||||
e.preventDefault();
|
||||
commit(opt);
|
||||
}}
|
||||
onMouseEnter={() => setActive(i)}
|
||||
>
|
||||
{opt}
|
||||
</li>
|
||||
))}
|
||||
</ul>
|
||||
) : null}
|
||||
</div>
|
||||
);
|
||||
}
|
||||
@@ -1,10 +1,15 @@
|
||||
import Link from "next/link";
|
||||
import { and, desc, eq, isNull, inArray, or, sql } from "drizzle-orm";
|
||||
import { and, desc, eq, isNull, inArray, or } from "drizzle-orm";
|
||||
import { auth } from "@/auth";
|
||||
import { db } from "@/lib/db/client";
|
||||
import { memories, projects, projectShares } from "@/lib/db/schema";
|
||||
import { searchMemories } from "@/lib/memories";
|
||||
import { getUserGroupNames, readableProjectIds } from "@/lib/access";
|
||||
import {
|
||||
getAccessibleProjects,
|
||||
getUserGroupNames,
|
||||
type AccessibleProject,
|
||||
} from "@/lib/access";
|
||||
import { ProjectCombobox } from "./_project-combobox";
|
||||
import { Container, PageHeader } from "@/app/_components/ui/container";
|
||||
import { Card, CardBody } from "@/app/_components/ui/card";
|
||||
import { Badge } from "@/app/_components/ui/badge";
|
||||
@@ -50,12 +55,12 @@ async function fetchMemoriesByIds(
|
||||
|
||||
async function listRecent(
|
||||
userId: string,
|
||||
groupNames: string[],
|
||||
accessible: AccessibleProject[],
|
||||
scope?: Scope,
|
||||
project?: string,
|
||||
): Promise<MemoryRow[]> {
|
||||
// Visibility: own rows OR rows in an accessible project.
|
||||
const accessibleIds = await readableProjectIds(userId, groupNames);
|
||||
const accessibleIds = accessible.map((p) => p.projectId);
|
||||
const visibility =
|
||||
accessibleIds.length > 0
|
||||
? or(eq(memories.userId, userId), inArray(memories.projectId, accessibleIds))
|
||||
@@ -63,17 +68,18 @@ async function listRecent(
|
||||
const filters = [visibility!, isNull(memories.deletedAt)];
|
||||
if (scope) filters.push(eq(memories.scope, scope));
|
||||
if (project) {
|
||||
// Project filter — match the project key against any project the
|
||||
// user can read (owned or shared). When the key matches none of
|
||||
// those, return empty.
|
||||
filters.push(
|
||||
sql`${memories.projectId} IN (
|
||||
SELECT id FROM ${projects}
|
||||
WHERE ${projects.key} = ${project}
|
||||
AND (${projects.userId} = ${userId}
|
||||
OR ${projects.id} = ANY(${accessibleIds}::uuid[]))
|
||||
)`,
|
||||
);
|
||||
// Project filter — resolve the typed key against the projects the
|
||||
// user can read (owned or shared), owned winning on a key collision
|
||||
// to match project.identify / the search path. Filtering by the
|
||||
// resolved id keeps the WHERE clause a plain equality — no raw-SQL
|
||||
// array binding (the source of the earlier memory.list crash). When
|
||||
// the key matches no accessible project, return empty.
|
||||
const matches = accessible.filter((p) => p.projectKey === project);
|
||||
const resolvedId =
|
||||
matches.find((p) => p.access === "owner")?.projectId ??
|
||||
matches[0]?.projectId;
|
||||
if (!resolvedId) return [];
|
||||
filters.push(eq(memories.projectId, resolvedId));
|
||||
}
|
||||
const rows = await db
|
||||
.select({
|
||||
@@ -120,6 +126,15 @@ export default async function MemoriesPage({
|
||||
const scope = params.scope === "user" || params.scope === "project" ? params.scope : undefined;
|
||||
const project = params.project?.trim() || undefined;
|
||||
|
||||
// Projects the user can read (owned ∪ shared). Reused both to build the
|
||||
// list-path WHERE clause and to populate the project filter's type-ahead
|
||||
// suggestions. Keys are deduped (a key can appear once per owned/shared
|
||||
// project) and sorted for a stable dropdown order.
|
||||
const accessible = await getAccessibleProjects(userId, groupNames);
|
||||
const projectKeys = [...new Set(accessible.map((p) => p.projectKey))].sort(
|
||||
(a, b) => a.localeCompare(b),
|
||||
);
|
||||
|
||||
let rows: MemoryRow[] = [];
|
||||
let debug: { vec: number; fts: number; tag: number } | null = null;
|
||||
|
||||
@@ -138,7 +153,7 @@ export default async function MemoriesPage({
|
||||
});
|
||||
debug = result.debug;
|
||||
} else {
|
||||
rows = await listRecent(userId, groupNames, scope, project);
|
||||
rows = await listRecent(userId, accessible, scope, project);
|
||||
}
|
||||
|
||||
// Annotate which rows belong to projects that have any active share.
|
||||
@@ -182,10 +197,10 @@ export default async function MemoriesPage({
|
||||
className="flex-1 min-w-[200px]"
|
||||
/>
|
||||
<FilterSelect name="scope" value={scope} options={["", "project", "user"]} placeholder="Any scope" />
|
||||
<Input
|
||||
<ProjectCombobox
|
||||
name="project"
|
||||
placeholder="Project key…"
|
||||
defaultValue={project ?? ""}
|
||||
options={projectKeys}
|
||||
className="w-44"
|
||||
/>
|
||||
<Button type="submit" variant="secondary">Apply</Button>
|
||||
|
||||
@@ -1,8 +1,9 @@
|
||||
import Link from "next/link";
|
||||
import { and, desc, eq, isNull, sql } from "drizzle-orm";
|
||||
import { and, desc, eq, inArray, isNull, sql } from "drizzle-orm";
|
||||
import { auth } from "@/auth";
|
||||
import { db } from "@/lib/db/client";
|
||||
import { memories, projects } from "@/lib/db/schema";
|
||||
import { getAccessibleProjects, getUserGroupNames } from "@/lib/access";
|
||||
import { Container, PageHeader } from "@/app/_components/ui/container";
|
||||
import { Card } from "@/app/_components/ui/card";
|
||||
import { Badge } from "@/app/_components/ui/badge";
|
||||
@@ -13,24 +14,37 @@ export const dynamic = "force-dynamic";
|
||||
export default async function ProjectsPage() {
|
||||
const session = await auth();
|
||||
const userId = session!.user.id;
|
||||
const groupNames = await getUserGroupNames(userId);
|
||||
|
||||
const rows = await db
|
||||
.select({
|
||||
id: projects.id,
|
||||
key: projects.key,
|
||||
displayName: projects.displayName,
|
||||
createdAt: projects.createdAt,
|
||||
memoryCount: sql<number>`count(${memories.id})::int`,
|
||||
lastActivity: sql<Date | null>`max(${memories.createdAt})`,
|
||||
})
|
||||
.from(projects)
|
||||
.leftJoin(
|
||||
memories,
|
||||
and(eq(memories.projectId, projects.id), isNull(memories.deletedAt)),
|
||||
)
|
||||
.where(eq(projects.userId, userId))
|
||||
.groupBy(projects.id)
|
||||
.orderBy(desc(sql`max(${memories.createdAt})`));
|
||||
// The project list is owned ∪ shared: projects the user owns PLUS
|
||||
// projects shared with one of their groups (any access). Visibility was
|
||||
// previously owner-only (`eq(projects.userId, userId)`), which hid
|
||||
// projects another user shared in via project_shares even though
|
||||
// project.identify already reported them as {shared, access}.
|
||||
const accessible = await getAccessibleProjects(userId, groupNames);
|
||||
const accessById = new Map(accessible.map((p) => [p.projectId, p.access]));
|
||||
const accessibleIds = accessible.map((p) => p.projectId);
|
||||
|
||||
const rows =
|
||||
accessibleIds.length === 0
|
||||
? []
|
||||
: await db
|
||||
.select({
|
||||
id: projects.id,
|
||||
key: projects.key,
|
||||
displayName: projects.displayName,
|
||||
createdAt: projects.createdAt,
|
||||
memoryCount: sql<number>`count(${memories.id})::int`,
|
||||
lastActivity: sql<Date | null>`max(${memories.createdAt})`,
|
||||
})
|
||||
.from(projects)
|
||||
.leftJoin(
|
||||
memories,
|
||||
and(eq(memories.projectId, projects.id), isNull(memories.deletedAt)),
|
||||
)
|
||||
.where(inArray(projects.id, accessibleIds))
|
||||
.groupBy(projects.id)
|
||||
.orderBy(desc(sql`max(${memories.createdAt})`));
|
||||
|
||||
return (
|
||||
<Container className="pt-6">
|
||||
@@ -57,6 +71,9 @@ export default async function ProjectsPage() {
|
||||
<div className="flex items-center gap-2">
|
||||
<span className="font-mono text-sm text-fg truncate">{p.key}</span>
|
||||
<Badge>{p.memoryCount}</Badge>
|
||||
{accessById.get(p.id) !== "owner" ? (
|
||||
<Badge tone="accent">shared · {accessById.get(p.id)}</Badge>
|
||||
) : null}
|
||||
</div>
|
||||
{p.displayName && p.displayName !== p.key ? (
|
||||
<div className="text-xs text-fg-muted truncate mt-0.5">{p.displayName}</div>
|
||||
|
||||
@@ -1,4 +1,4 @@
|
||||
import { and, desc, eq, inArray, isNull, or, sql } from "drizzle-orm";
|
||||
import { and, arrayContains, desc, eq, inArray, isNull, or } from "drizzle-orm";
|
||||
import { db } from "@/lib/db/client";
|
||||
import {
|
||||
memories,
|
||||
@@ -465,7 +465,13 @@ const memoryList: ToolDef = {
|
||||
}
|
||||
|
||||
if (parsed.data.tags && parsed.data.tags.length > 0) {
|
||||
where.push(sql`${memories.tags} @> ${parsed.data.tags}::text[]`);
|
||||
// Require ALL listed tags (array containment). Use Drizzle's
|
||||
// arrayContains so the JS array binds as a single text[] param
|
||||
// (via the column's toDriver) rather than being expanded into
|
||||
// positional params — a raw `${tags}::text[]` template expands to
|
||||
// `($1)::text[]` / `($1,$2)::text[]`, which Postgres rejects as a
|
||||
// malformed array literal / record cast.
|
||||
where.push(arrayContains(memories.tags, parsed.data.tags));
|
||||
}
|
||||
|
||||
const rows = await db
|
||||
|
||||
@@ -1,4 +1,4 @@
|
||||
import { and, desc, eq, inArray, isNull, or, sql } from "drizzle-orm";
|
||||
import { and, arrayContains, desc, eq, inArray, isNull, or } from "drizzle-orm";
|
||||
import { db } from "@/lib/db/client";
|
||||
import { snippets, projects } from "@/lib/db/schema";
|
||||
import type { Snippet } from "@/lib/db/schema";
|
||||
@@ -349,7 +349,13 @@ export async function listSnippets(
|
||||
}
|
||||
|
||||
if (tags && tags.length > 0) {
|
||||
where.push(sql`${snippets.tags} @> ${tags}::text[]`);
|
||||
// Require ALL listed tags (array containment). Use Drizzle's
|
||||
// arrayContains so the JS array binds as a single text[] param
|
||||
// (via the column's toDriver) rather than being expanded into
|
||||
// positional params — a raw `${tags}::text[]` template expands to
|
||||
// `($1)::text[]` / `($1,$2)::text[]`, which Postgres rejects as a
|
||||
// malformed array literal / record cast.
|
||||
where.push(arrayContains(snippets.tags, tags));
|
||||
}
|
||||
|
||||
const rows = await db
|
||||
|
||||
+5
-1
@@ -129,7 +129,11 @@ services:
|
||||
# but you can bind to 127.0.0.1 only by setting APP_BIND=127.0.0.1.
|
||||
- "${APP_BIND:-0.0.0.0}:${APP_PORT:-3000}:3000"
|
||||
healthcheck:
|
||||
test: ["CMD-SHELL", "wget -q -O /dev/null http://localhost:3000/api/health || exit 1"]
|
||||
# Use 127.0.0.1, not localhost: inside the container localhost resolves
|
||||
# to ::1 (IPv6) first, but the Next.js standalone server listens only on
|
||||
# 0.0.0.0 (IPv4), so a localhost probe gets "Connection refused" and the
|
||||
# container is reported unhealthy even though the app serves fine.
|
||||
test: ["CMD-SHELL", "wget -q -O /dev/null http://127.0.0.1:3000/api/health || exit 1"]
|
||||
interval: 15s
|
||||
timeout: 5s
|
||||
retries: 5
|
||||
|
||||
@@ -0,0 +1,10 @@
|
||||
{
|
||||
"$schema": "https://anthropic.com/claude-code/plugin.schema.json",
|
||||
"name": "shared-memory",
|
||||
"version": "0.1.0",
|
||||
"description": "Shared persistent memory and snippet library for Claude Code sessions, backed by memory.dnspegasus.net and authenticated with Authentik OIDC.",
|
||||
"author": {
|
||||
"name": "jknapp"
|
||||
},
|
||||
"homepage": "https://memory.dnspegasus.net"
|
||||
}
|
||||
@@ -0,0 +1,12 @@
|
||||
{
|
||||
"mcpServers": {
|
||||
"shared-memory": {
|
||||
"type": "http",
|
||||
"url": "https://memory.dnspegasus.net/api/mcp",
|
||||
"oauth": {
|
||||
"clientId": "5rkRS3rJhn3Ci9swWkxYMIrZ9OggsjOGy3cIOhYY",
|
||||
"callbackPort": 33418
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user