(Gj_UdZddlmZddlZddlZddlZddlZddlZddlZddl m Z m Z ddl m Z ddlmZmZmZddlmZmZddlmZdad Zd Zejd ZdbdZdcdZdddZdedZdfdZ e!Z"de#d<dgdhdZ$ej%dgdidZ&d Z'djd#Z(e Gd$d%Z)e Gd&d'Z*dkd*Z+dld-Z,dmd/Z-dnd1Z.dddddddd2dod:Z/d;d<dpd@Z0dqdCZ1ddddddDdrdEZ2dd;dFdsdIZ3dtdJZ4dudKZ5dtdLZ6dvdMZ7dvdNZ8dvdOZ9dPZ:dwdQZ;dxdRZd;d<d{dZZ?ejd[Z@d\d]d|d`ZAdS)}uPer-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_homereturnrc$tdz 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 rslug Optional[str]c|dSt|}|sdSt|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)r#r!s rnormalize_slugr)vs} |t D !!A t >>!    D      Hrc0dtjdzS)Np_)secrets token_hexrrr_new_project_idr/s '#A&& &&rintcBttjSN)r0timerrr_nowr4s ty{{  rpathctjtjt |}|dp|S)zEAbsolute, user-expanded, separator-normalized path (no trailing sep)./\)osr5abspath expanduserrrrstrip)r5ps r_normalize_pathr=sJ **3t99??+<+<==>>A 88E?? arzset[str]_INITIALIZED_PATHSdb_pathOptional[Path]sqlite3.Connectionc:||n t}|jddt|}t jt|} t j|_ddl m }||d| d|tvrC| tt|t|n##t"$r|wxYw|S) 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. NT)parentsexist_okr)apply_wal_with_fallbackr)db_labelzPRAGMA foreign_keys=ON)rparentmkdirrresolvesqlite3connectRow row_factory hermes_staterEexecuter> executescript SCHEMA_SQL_migrate_add_optional_columnsadd Exceptionclose)r?r5resolvedconnrEs rrKrKs)77/?/A/ADKdT2224<<>>""H ?3t99 % %D ";888888}==== -... - - -   z * * * )$ / / /  " "8 , , ,    Ks 2BC88 Dc#Kt|} |V |dS#t$rYdSwxYw# |w#t$rYwwxYwxYw)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``. )r?N)rKrUrT)r?rWs rconnect_closingrYs 7 # # #D   JJLLLLL    DD   JJLLLL    D s;A/ ==A'AA' A$!A'#A$$A') board_slug primary_pathiconcolorrWNonecd|dD}tD]}||vrt|d||ddS)zCAdd columns introduced after v1 to legacy DBs (safe on every open).ch|] }|d S)rr).0rows r z0_migrate_add_optional_columns..s O O OCCK O O OrzPRAGMA table_info(projects)projectsz TEXTN)rO_OPTIONAL_PROJECT_COLUMNS_add_column_if_missing)rWcolscols rrRrRsc O O4<<0M#N#N O O OD(II d?? "4SS--- H H HIIrcLeZdZUded<dZded<dZded<d Zd ed <ddZdS) ProjectFolderrr5Nr$labelFbool is_primaryrr0added_atrdictcR|j|jt|j|jdS)Nr5rkrmrn)r5rkrlrmrnselfs rto_dictzProjectFolder.to_dicts-IZt//    rrro)__name__ __module__ __qualname____annotations__rkrmrnrtrrrrjrjsf IIIEJH      rrjceZdZUded<ded<ded<ded<dZded <dZded <dZded <dZded <dZded <dZ ded<e e Z ded<ddZ dS)Projectridr#rr0 created_atNr$ descriptionr\r]rZr[Frlarchived)default_factoryList[ProjectFolder]foldersrroc |j|j|j|j|j|j|j|jt|j |j d|j Dd S)Nc6g|]}|Sr)rt)rafs r z#Project.to_dict..s ::: :::r) r|r#rr~r\r]rZr[rr}r) r|r#rr~r\r]rZr[rlrr}rrrs rrtzProject.to_dicts`'II+IZ/ -T]++/::T\:::   rru)rvrwrxryr~r\r]rZr[rrlistrrtrrrr{r{s GGG III IIIOOO!%K%%%%DE $J$$$$"&L&&&&H#(5#>#>#>G>>>>       rr{rb sqlite3.Rowc6|}t|d|d|d|dd|vr|dndd|vr|dndd|vr|dndd|vr|dndd |vr|d ndd |vrt|d nd S) Nr|r#rr}r~r\r]rZr[rF) r|r#rr}r~r\r]rZr[r)keysr{rl)rbrs r_project_from_rowr s 88::D  t9 [ [|$*74*?*?C &&T"dNNS[[%ooc'll4(4(<(<3|$$$,:d,B,BS((*4*<*<c*o&&&%    r project_idrcl|d|f}d|DS)NzySELECT path, label, is_primary, added_at FROM project_folders WHERE project_id = ? ORDER BY is_primary DESC, added_at ASCc ~g|]:}t|d|dt|d|d;S)r5rkrmrnrq)rjrlrars rrz!_load_folders..s]     6G*AlO,,z]       rrOfetchall)rWrrowss r _load_foldersrsQ << F    hjj       rrc:t||j|_|Sr2)rr|r)rWrs r_attach_foldersr*s#D'*55GO Nr candidatec*|}d}|}|d|fc|dz }d|}|ddt|z d|z}|d|fc|S)z=Return ``candidate`` or ``candidate-2``, ``-3`` ... if taken.z%SELECT 1 FROM projects WHERE slug = ?Nrrr)rOfetchonelenr;)rWrbasenr#suffixs r _unique_slugr4s D A D ,,/$  hjj  QQ'rCKK''(0066? ,,/$  hjj  Kr)r#rr[r~r\r]rZrOptional[Iterable[str]]r[r~r\r]rZc t|pd}|std|rt|nt |} t } t } g} |pgD],} t| }|r|| vr| |-|rt|nd}|r|| vr| d|| | r| d}t|5t|| }| d| ||||||rt|nd|| f | D]%}| d| |d||krdnd| f& dddn #1swxYwY| S)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/r4r=appendinsertr rrO)rWrr#rr[r~r\r]rZslug_candidatepidnow folder_pathsrnormprimaryuniquer5s rcreate_projectrBs$ tzr?? " "D ;9:::-1E^D)))x~~N   C &&C L ]&&q!!  &D ,,    % % %/;Eol+++G(7,..Aw'''<q/ 4dN33  4 .8Bz***d     "!  D LL)dDtw!!AsC      '4 Js.A)E$$E(+E(F)include_archivedrrl List[Project]cd}|s|dz }|dz }|}fd|DS)NzSELECT * FROM projectsz WHERE archived = 0z ORDER BY created_at ASCcJg|]}tt| Sr)rr)rarrWs rrz!list_projects..s, F F FAOD"3A"6"6 7 7 F F Frr)rWrsqlrs` r list_projectsrs_ #C % $$ %%C <<   % % ' 'D F F F F F F FFr id_or_slugOptional[Project]c*|d|f}|H|dt|f}|dSt |t |S)z,Look up a project by id first, then by slug.z#SELECT * FROM projects WHERE id = ?Nz%SELECT * FROM projects WHERE slug = ?)rOrrrrr)rWrrbs r get_projectrs ,,- }  hjj {ll 3c*oo6K6K6M6M5O  (**  {t 4!23!7!7 8 88r)rr~r\r]rZcdg}g}|\t|} | std|d|| |*|d|||,|d||pd|,|d||pd|M|d||rt |nd|sdS||t |5|d d |d |} dddn #1swxYwY| jd kS) uPatch top-level project fields. Only provided fields change. ``icon``, ``color``, and ``board_slug`` accept an empty string to clear (store NULL) — passing ``None`` leaves the field untouched, so callers that want to clear must send ``""``. Nrzname = ?zdescription = ?zicon = ?z color = ?zboard_slug = ?FzUPDATE projects SET z, z WHERE id = ?r) rrr(rr)r rOjoinrowcount) rWrrr~r\r]rZsetsparamsrcurs rupdate_projectrs DF  IIOO   ?=>> > J a %&&& k"""  J dld###  K    emt$$$ $%%% J4D4D4F4FPnZ000DQQQ u MM* 4  ll A499T?? A A 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)rO)rWrr5s rrrst LLH   LL , T  LL; zrct|}t|5|d||f}| ddddSt |||dddn #1swxYwYdS)Nz?SELECT 1 FROM project_folders WHERE project_id = ? AND path = ?FT)r=r rOrr)rWrr5rexistss r set_primaryr-s 4 D 444 M     (**  > 44444444 D*d333444444444444444 4s.A7A77A;>A;ct|5|d|f}dddn #1swxYwY|jdkS)Nz-UPDATE projects SET archived = 1 WHERE id = ?rr rOrrWrrs rarchive_projectr: 4  ll ;j]                   NNOOOOOOOOOOOOOOO g|]}|d|d|ddS)rrk last_seen)rrkrrrs rrz)list_discovered_repos..s>    6QwZa nMM   rr)rWrs rlist_discovered_reposrsE <<U  hjj      rc0t|pdsdSt|}d}|s|dz }d}d}||D]}|d}||ks`||dtjzs+||ddzr*t||krt|}|d }|dSt||S) zReturn the project owning ``path`` (longest-prefix folder match). A folder owns ``path`` when ``path`` equals the folder or is nested under it. The most specific (longest) folder wins, so nested projects resolve to the innermost one. rNznSELECT pf.project_id AS pid, pf.path AS folder FROM project_folders pf JOIN projects p ON p.id = pf.project_idz WHERE p.archived = 0folderr7/r) rrr=rOr startswithr;r8seprr) rWr5rtargetrbest_pidbest_lenrbrs rproject_for_pathrs' tzr?? " "t T " "F J ' &&"HH||C  ))++&&X V  v00u1E1E1NOO !!&--"6"6"<== 6{{X%%v;;u:t tX & &&rz [^a-z0-9._-]+r)titletask_idrcX|jpt|j}|d|}|rtdt |d}|ddd}|r|d|}|S)zDeterministic branch name for a project-linked kanban task. Shape: ``/`` (optionally ``-``). Stable and human-meaningful, replacing the random ``wt/`` fallback. rrN()r#r"r_BRANCH_SAFE_REr rrr)rrrr#rtslugs rbranch_name_forrs < 18GL11D  W  D %##CU)9)9););)A)A)C)CDDJJ3OOcrc   %%  %$$U$$D Kr)rr)rrrr)r#r$rr$)rr)rr0)r5rrrr2)r?r@rrA)r?r@)rWrArr^)rbrrr{)rWrArrrr)rWrArr{rr{)rWrArrrr)rWrArrr#r$rrr[r$r~r$r\r$r]r$rZr$rr)rWrArrlrr)rWrArrrr)rWrArrrr$r~r$r\r$r]r$rZr$rrl) rWrArrr5rrkr$rmrlrr)rWrArrr5rrrl)rWrArrr5rrr^)rWrArrrrl)rWrArr$rr^)rWrArr$)rWrArrrrlrr0)rWrArr)rWrAr5rrrlrr)rr{rrrrrr)B__doc__ __future__r contextlibr8rr-rJr3 dataclassesrrpathlibrtypingrrr hermes_cli.sqlite_utilr rfr hermes_constantsr rrQcompiler&r"r)r/r4r=setr>ryrKcontextmanagerrYrerRrjr{rrrrrrrrrrrrrrrrrrrrrrrrrrrs.#"""""  ((((((((++++++++++]]]]]]]],,,,,,----' d 2:4 5 5     ''''     #suu$$$$6 (LIIII                      :     "    $'+"&!% $@@@@@@H;@GGGGGG 9 9 9 9(!% $++++++f  ++++++\<&        ))))  !!!!!!H"FK''''''B"*-..EG        r