`gj_(UdZddlmZddlZddlZddlZddlZddlZddlZddl m Z m Z ddl m Z ddlmZmZmZddlmZmZddlmZd:d Zd Zej4d Zd;d ZddZd?dZ e!Z"de#d<d@dAdZ$ejJd@dBdZ&dZ'dCdZ(e GddZ)e GddZ*dDdZ+dEdZ,dFdZ-dGdZ.dddddddd dHd Z/d!d" dId#Z0 dJd$Z1dddddd% dKd&Z2dd!d' dLd(Z3dMd)Z4 dNd*Z5dMd+Z6dOd,Z7dOd-Z8dOd.Z9d/Z:dPd0Z;dQd1Zd!d" dTd5Z?ej4d6Z@d7d8dUd9ZAy)VuPer-profile first-class Project store. A **Project** is a human-named, multi-folder workspace. Unlike the desktop's old inferred "workspaces" (derived from each session's ``cwd`` + a git probe) and unlike kanban's self-generated worktrees, a Project is an explicit, persisted entity the user creates and names. It anchors: - **Desktop session grouping** — a session belongs to a project when its ``cwd`` lives under one of the project's folders (longest-prefix match). - **Kanban task worktrees** — a task linked to a project creates its worktree under the project's primary repo with a deterministic branch name, instead of the random ``wt/`` fallback. Scope: **per-profile**, stored at ``$HERMES_HOME/projects.db`` (resolved via ``get_hermes_home()``), mirroring sessions / config / cron. This deliberately differs from kanban, whose board DB is root-anchored and shared across profiles. A Project may *bind* a kanban board (``board_slug``) so the two systems agree on the repo + branch convention without merging their stores. The schema is intentionally small and additive: column additions go through :func:`_add_column_if_missing` so opening an old DB is always safe. ) annotationsN) dataclassfield)Path)IterableListOptional)add_column_if_missing write_txnget_hermes_homectdz S)zThe per-profile projects DB path (``$HERMES_HOME/projects.db``). Profile-aware: ``get_hermes_home()`` already points at the active profile's home. Tests pass an explicit ``db_path`` to :func:`connect`. projects.dbr I/root/.hermes/venv/lib/python3.12/site-packages/hermes_cli/projects_db.pyprojects_db_pathr,s  } ,,ra CREATE TABLE IF NOT EXISTS projects ( id TEXT PRIMARY KEY, slug TEXT NOT NULL UNIQUE, name TEXT NOT NULL, description TEXT, icon TEXT, color TEXT, board_slug TEXT, primary_path TEXT, created_at INTEGER NOT NULL, archived INTEGER NOT NULL DEFAULT 0 ); CREATE TABLE IF NOT EXISTS project_folders ( project_id TEXT NOT NULL REFERENCES projects(id) ON DELETE CASCADE, path TEXT NOT NULL, label TEXT, is_primary INTEGER NOT NULL DEFAULT 0, added_at INTEGER NOT NULL, PRIMARY KEY (project_id, path) ); CREATE INDEX IF NOT EXISTS idx_project_folders_path ON project_folders(path); CREATE TABLE IF NOT EXISTS project_meta ( key TEXT PRIMARY KEY, value TEXT ); -- Git repos found by scanning the filesystem (desktop "repo-first" discovery). -- Cached here so the overview is instant after the first scan instead of -- re-walking the disk every time the Projects view opens. CREATE TABLE IF NOT EXISTS discovered_repos ( root TEXT PRIMARY KEY, label TEXT, last_seen INTEGER NOT NULL ); z^[a-z0-9][a-z0-9\-_]{0,63}$ct|xsdjj}tjdd|jd}|ddjd}|xsdS)z8Derive a slug candidate from a human name (best-effort).z [^a-z0-9]+--_N@project)strstriplowerresub)namess r_slugifyr!ns\ DJB%%'A }c1%++D1A #2 TA > rc|yt|jj}|sytj |st d|d|S)z>Lowercase + strip a slug; validate; return ``None`` for empty.Nzinvalid project slug zc: must be 1-64 chars, lowercase alphanumerics / hyphens / underscores, not starting with '-' or '_')rrr_SLUG_REmatch ValueError)slugr s rnormalize_slugr'vsZ | D !A  >>! #D8,   Hrc2dtjdzS)Np_)secrets token_hexrrr_new_project_idr-s '##A& &&rc<ttjSN)inttimerrr_nowr2s tyy{ rctjjtjjt |j }|j dxs|S)zEAbsolute, user-expanded, separator-normalized path (no trailing sep)./\)ospathabspath expanduserrrrstrip)r6ps r_normalize_pathr;sA **3t9??+<=>A 88E? arzset[str]_INITIALIZED_PATHSc||n t}|jjddt|j }t j t|} t j|_ddl m }||d|jd|tvr5|jtt|tj!||S#t"$r|j%wxYw)aOpen (and initialize if needed) the per-profile projects DB. WAL with DELETE fallback for network filesystems (shared helper from ``hermes_state``). Schema init is idempotent (``CREATE TABLE IF NOT EXISTS`` + additive migrations) and cached per-path per-process. T)parentsexist_okr)apply_wal_with_fallbackr)db_labelzPRAGMA foreign_keys=ON)rparentmkdirrresolvesqlite3connectRow row_factory hermes_stater@executer< executescript SCHEMA_SQL_migrate_add_optional_columnsadd Exceptionclose)db_pathr6resolvedconnr@s rrFrFs)7/?/ADKKdT24<<>"H ??3t9 %D ";;8}= -. - -   z * )$ /  " "8 , K   s $A3CC4c#Kt|} | |jy#t$rYywxYw# |jw#t$rYwwxYwxYww)auOpen a projects DB connection and guarantee it is closed on exit. sqlite3's connection context manager only commits/rollbacks; it does NOT close the file descriptor. Long-lived processes (gateway, dashboard) route many project operations through ``connect()``; without closing, FDs to ``projects.db`` accumulate. Mirrors ``kanban_db.connect_closing``. )rQN)rFrPrO)rQrSs rconnect_closingrUs[ 7 #D   JJL     JJL   sR A5&A 2A2AAAA AAAAA) board_slug primary_pathiconcolorc|jdDchc]}|d }}tD]}||vst|d||dycc}w)zCAdd columns introduced after v1 to legacy DBs (safe on every open).zPRAGMA table_info(projects)rprojectsz TEXTN)rJ_OPTIONAL_PROJECT_COLUMNS_add_column_if_missing)rSrowcolscols rrMrMsU#'<<0M#N OCCK OD O(I d? "4SSE- HI Ps AcJeZdZUded<dZded<dZded<d Zd ed <d d Zy) ProjectFolderrr6N Optional[str]labelFbool is_primaryrr0added_atcr|j|jt|j|jdS)Nr6rdrfrg)r6rdrerfrg)selfs rto_dictzProjectFolder.to_dicts-IIZZt/   rreturndict)__name__ __module__ __qualname____annotations__rdrfrgrkrrrrbrbs* IE=JHc rrbceZdZUded<ded<ded<ded<dZded <dZded <dZded <dZded <dZded <dZ ded<e e Z ded<ddZ y)Projectridr&rr0 created_atNrc descriptionrXrYrVrWFrearchived)default_factoryList[ProjectFolder]folderscN|j|j|j|j|j|j |j |jt|j|j|jDcgc]}|jc}d Scc}w)N) rur&rrwrXrYrVrWrxrvr{) rur&rrwrXrYrVrWrerxrvr{rk)rjfs rrkzProject.to_dictsx''IIII++IIZZ// --T]]+//-1\\: :  ;sB"rl)rorprqrrrwrXrYrVrWrxrlistr{rkrrrrtrtsg G I IO!%K%D-E= $J $"&L-&Hd#(#>G >  rrtc|j}t|d|d|d|dd|vr|dndd|vr|dndd|vr|dndd|vr|dndd |vr|d ndd |vrt|d  Sd S) Nrur&rrvrwrXrYrVrWrxF) rur&rrvrwrXrYrVrWrx)keysrtre)r^rs r_project_from_rowr s 88:D  t9 [ [|$*74*?C &T"dNS[%oc'l4(4(<3|$$,:d,BS(*4*<c*o&  CH  rc |jd|fj}|Dcgc]&}t|d|dt|d|d(c}Scc}w)NzySELECT path, label, is_primary, added_at FROM project_folders WHERE project_id = ? ORDER BY is_primary DESC, added_at ASCr6rdrfrgri)rJfetchallrbre)rS project_idrowsrs r _load_foldersrsq << F   hj     6G*AlO,z]    s+Ac<t||j|_|Sr/)rrur{)rSrs r_attach_foldersr*s#D'**5GO Nrc|}d}|}|jd|fjO|dz }d|}|ddt|z jd|z}|jd|fjO|S)z=Return ``candidate`` or ``candidate-2``, ``-3`` ... if taken.z%SELECT 1 FROM projects WHERE slug = ?Nrrr)rJfetchonelenr9)rS candidatebasenr&suffixs r _unique_slugr4s D A D ,,/$ hj  QQC'rCK'(006? ,,/$ hj  Kr)r&r{rWrwrXrYrVc jt|xsdj}|s td|r t|n t |} t } t } g} |xsgD]&} t| }|s|| vs| j|(|r t|nd}|r|| vr| jd||| r| d}t|5t|| }|jd| ||||||r t|nd|| f | D] }|jd| |d||k(rdnd| f" ddd| S#1swY| SxYw)zCreate a project and return its id. ``folders`` are normalized to absolute paths. If ``primary_path`` is given it is added to the folder set (if not already present) and marked primary; otherwise the first folder becomes primary. rproject name must not be emptyNrzINSERT INTO projects (id, slug, name, description, icon, color, board_slug, primary_path, created_at, archived) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, 0)zbINSERT INTO project_folders (project_id, path, label, is_primary, added_at) VALUES (?, ?, ?, ?, ?)r) rrr%r'r!r-r2r;appendinsertr rrJ)rSrr&r{rWrwrXrYrVslug_candidatepidnow folder_pathsr}normprimaryuniquer6s rcreate_projectrBse$ tzr? "D 9::-1^D)x~N  C &C L ]&q! D ,    %& 0 > J a %& k"  J dld#  K  emt$ $% J4D4D4FnZ0DQ  MM* 4 ll"499T?"3= A6   <UPDATE project_folders SET is_primary = 0 WHERE project_id = ?zKUPDATE project_folders SET is_primary = 1 WHERE project_id = ? AND path = ?z1UPDATE projects SET primary_path = ? WHERE id = ?N)rJ)rSrr6s rrrsL LLH   LL , T  LL; zrct|}t|5|jd||fj}| dddyt |||dddy#1swYyxYw)Nz?SELECT 1 FROM project_folders WHERE project_id = ? AND path = ?FT)r;r rJrr)rSrr6rexistss r set_primaryr-st 4 D 44 M    (*  > 44 D*d34 4 s&A AA%ct|5|jd|f}dddjdkDS#1swYxYw)Nz-UPDATE projects SET archived = 1 WHERE id = ?rr rJrrSrrs rarchive_projectr:D 4 ll ;j]   < NO </`` (optionally ``-``). Stable and human-meaningful, replacing the random ``wt/`` fallback. rrN()r&r!r_BRANCH_SAFE_RErrrr)rtask_idrr&rtslugs rbranch_name_forrs << 18GLL1DV1WI D ##CU)9)9);)A)A)CDJJ3Ocr   % V1UG$D Kr)rmr)rrrmr)r&rcrmrc)rmr)rmr0)r6rrmrr/)rQOptional[Path]rmsqlite3.Connection)rQr)rSrrmNone)r^z sqlite3.Rowrmrt)rSrrrrmrz)rSrrrtrmrt)rSrrrrmr)rSrrrr&rcr{zOptional[Iterable[str]]rWrcrwrcrXrcrYrcrVrcrmr)rSrrrermz List[Project])rSrrrrmOptional[Project])rSrrrrrcrwrcrXrcrYrcrVrcrmre) rSrrrr6rrdrcrfrermr)rSrrrr6rrmre)rSrrrr6rrmr)rSrrrrmre)rSrrrcrmr)rSrrmrc)rSrrz#Iterable[tuple[str, Optional[str]]]rrermr0)rSrrmz List[dict])rSrr6rrrermr)rrtrrrrrmr)B__doc__ __future__r contextlibr5rr+rEr1 dataclassesrrpathlibrtypingrrr hermes_cli.sqlite_utilr r]r hermes_constantsr rrLcompiler#r!r'r-r2r;setr<rrrFcontextmanagerrUr\rMrbrtrrrrrrrrrrrrrrrrrrrrrrrrrrrs6.#  (++],-' d 2::4 5  '  #uH$6 (LI            :  " $'+"&!% $@ @ @  @ % @  @@ @ @@ @H;@G G37GG 9  9*- 9 9(!% $+ ++  +  +  + ++ +f  + ++ +  +  + +\< *-58 &  )  ! ! .! !  !H"FK' '$''>B''B"**-.EG r