feat: implement task comments functionality
- Added a new Contributor License Agreement (CLA) document to clarify contribution terms. - Updated the license from MIT to GNU Affero General Public License v3.0 (AGPL-3.0). - Introduced task comments feature, allowing users to add comments to tasks with validation for input length and content. - Enhanced the TeamDataService to handle adding comments and sending notifications to task owners. - Updated UI components to display comments and allow users to submit comments via a text area. - Integrated task comments into the task detail dialog for better user interaction. These changes aim to improve task management and enhance collaboration within teams.
This commit is contained in:
iliya
Илия
parent
42e4b0f4aa
commit
5f2bd36aca
23 changed files with 1225 additions and 142 deletions
24
CLA.md
Normal file
24
CLA.md
Normal file
|
|
@ -0,0 +1,24 @@
|
||||||
|
# Contributor License Agreement (CLA)
|
||||||
|
|
||||||
|
**Project:** Claude Agent Teams UI (claude-agent-teams-ui)
|
||||||
|
**License:** GNU Affero General Public License v3.0 (AGPL-3.0)
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
By contributing to this project, you agree that your contributions will be licensed under the same terms as the project: the GNU Affero General Public License v3.0 (AGPL-3.0).
|
||||||
|
|
||||||
|
You grant the project maintainers and all recipients of the software a perpetual, worldwide, non-exclusive, no-charge, royalty-free, irrevocable license to use, reproduce, prepare derivative works of, publicly display, publicly perform, sublicense, and distribute your contributions and any derivative works based on them, under the AGPL-3.0.
|
||||||
|
|
||||||
|
You represent that you have the right to grant the above license and that your contributions do not violate any third party’s rights.
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## Signed contributors
|
||||||
|
|
||||||
|
| Name | Email | Date |
|
||||||
|
|------|-------|------|
|
||||||
|
| Илия (777genius) | quantjumppro@gmail.com | 2026-02-22 |
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
*To add yourself: submit a pull request that adds your name, email, and the current date to the table above. By merging the PR you confirm your agreement with this CLA.*
|
||||||
624
LICENSE
624
LICENSE
|
|
@ -1,21 +1,611 @@
|
||||||
MIT License
|
GNU AFFERO GENERAL PUBLIC LICENSE
|
||||||
|
Version 3, 19 November 2007
|
||||||
|
|
||||||
Copyright (c) 2026 Claude Agent Teams UI contributors
|
Copyright (C) 2026 Илия (777genius) <quantjumppro@gmail.com>
|
||||||
|
|
||||||
Permission is hereby granted, free of charge, to any person obtaining a copy
|
Copyright (C) 2007 Free Software Foundation, Inc. <https://fsf.org/>
|
||||||
of this software and associated documentation files (the "Software"), to deal
|
Everyone is permitted to copy and distribute verbatim copies
|
||||||
in the Software without restriction, including without limitation the rights
|
of this license document, but changing it is not allowed.
|
||||||
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
|
||||||
copies of the Software, and to permit persons to whom the Software is
|
|
||||||
furnished to do so, subject to the following conditions:
|
|
||||||
|
|
||||||
The above copyright notice and this permission notice shall be included in all
|
Preamble
|
||||||
copies or substantial portions of the Software.
|
|
||||||
|
|
||||||
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
The GNU Affero General Public License is a free, copyleft license for
|
||||||
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
software and other kinds of works, specifically designed to ensure
|
||||||
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
cooperation with the community in the case of network server software.
|
||||||
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
|
||||||
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
|
The licenses for most software and other practical works are designed
|
||||||
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
|
to take away your freedom to share and change the works. By contrast,
|
||||||
SOFTWARE.
|
our General Public Licenses are intended to guarantee your freedom to
|
||||||
|
share and change all versions of a program--to make sure it remains free
|
||||||
|
software for all its users.
|
||||||
|
|
||||||
|
When we speak of free software, we are referring to freedom, not price.
|
||||||
|
Our General Public Licenses are designed to make sure that you have the
|
||||||
|
freedom to distribute copies of free software (and charge for them if you
|
||||||
|
wish), that you receive source code or can get it if you want it, that you
|
||||||
|
can change the software or use pieces of it in new free programs, and that
|
||||||
|
you know you can do these things.
|
||||||
|
|
||||||
|
Developers that use our General Public Licenses protect your rights with
|
||||||
|
two steps: (1) assert copyright on the software, and (2) offer you this
|
||||||
|
License which gives you legal permission to copy, distribute and/or modify
|
||||||
|
the software.
|
||||||
|
|
||||||
|
A secondary benefit of defending all users' freedom is that
|
||||||
|
improvements made in alternate versions of the program, if they receive
|
||||||
|
widespread use, become available for other developers to incorporate.
|
||||||
|
Many developers of free software are heartened and encouraged by the
|
||||||
|
resulting cooperation. However, in the case of software used on network
|
||||||
|
servers, this result may fail to come about. The GNU General Public
|
||||||
|
License permits making a modified version and letting the public access it
|
||||||
|
on a server without ever releasing its source code to the public.
|
||||||
|
|
||||||
|
The GNU Affero General Public License is designed specifically to ensure
|
||||||
|
that, in such cases, the modified source code becomes available to the
|
||||||
|
community. It requires the operator of a network server to provide the
|
||||||
|
source code of the modified version running there to the users of that
|
||||||
|
server. Therefore, public use of a modified version, on a publicly
|
||||||
|
accessible server, gives the public access to the source code of the
|
||||||
|
modified version.
|
||||||
|
|
||||||
|
An older license, called the Affero General Public License and published
|
||||||
|
by Affero, was designed to accomplish similar goals. This is a different
|
||||||
|
license, not a version of the Affero GPL, but Affero has released a new
|
||||||
|
version of the Affero GPL which permits relicensing under this license.
|
||||||
|
|
||||||
|
The precise terms and conditions for copying, distribution and
|
||||||
|
modification follow.
|
||||||
|
|
||||||
|
TERMS AND CONDITIONS
|
||||||
|
|
||||||
|
0. Definitions.
|
||||||
|
|
||||||
|
"This License" refers to version 3 of the GNU Affero General Public
|
||||||
|
License.
|
||||||
|
|
||||||
|
"Copyright" also means copyright-like laws that apply to other kinds of
|
||||||
|
works, such as semiconductor masks.
|
||||||
|
|
||||||
|
"The Program" refers to any copyrightable work licensed under this
|
||||||
|
License. Each licensee is addressed as "you". "Licensees" and
|
||||||
|
"recipients" may be individuals or organizations.
|
||||||
|
|
||||||
|
To "modify" a work means to copy from or adapt all or part of the work
|
||||||
|
in a fashion requiring copyright permission, other than making an exact
|
||||||
|
copy. The resulting work is called a "modified version" of the earlier
|
||||||
|
work or a work "based on" the earlier work.
|
||||||
|
|
||||||
|
A "covered work" means either the unmodified Program or a work based on
|
||||||
|
the Program.
|
||||||
|
|
||||||
|
To "propagate" a work means to do anything with it that, without
|
||||||
|
permission, would make you directly or secondarily liable for
|
||||||
|
infringement under applicable copyright law, except executing it on a
|
||||||
|
computer or modifying a private copy. Propagation includes copying,
|
||||||
|
distribution (with or without modification), making available to the
|
||||||
|
public, and in some countries other activities as well.
|
||||||
|
|
||||||
|
To "convey" a work means any kind of propagation that enables other
|
||||||
|
parties to make or receive copies. Mere interaction with a user through
|
||||||
|
a computer network, with no transfer of a copy, is not conveying.
|
||||||
|
|
||||||
|
An interactive user interface displays "Appropriate Legal Notices" to
|
||||||
|
the extent that it includes a convenient and prominently visible feature
|
||||||
|
that (1) displays an appropriate copyright notice, and (2) tells the user
|
||||||
|
that there is no warranty for the work (except to the extent that
|
||||||
|
warranties are provided), that licensees may convey the work under this
|
||||||
|
License, and how to view a copy of this License. If the interface
|
||||||
|
presents a list of user commands or options, such as a menu, a prominent
|
||||||
|
item in the list meets this criterion.
|
||||||
|
|
||||||
|
1. Source Code.
|
||||||
|
|
||||||
|
The "source code" for a work means the preferred form of the work for
|
||||||
|
making modifications to it. "Object code" means any non-source form of a
|
||||||
|
work.
|
||||||
|
|
||||||
|
A "Standard Interface" means an interface that either is an official
|
||||||
|
standard defined by a recognized standards body, or, in the case of
|
||||||
|
interfaces specified for a particular programming language, one that is
|
||||||
|
widely used among developers working in that language.
|
||||||
|
|
||||||
|
The "System Libraries" of an executable work include anything, other than
|
||||||
|
the work as a whole, that (a) is included in the normal form of packaging
|
||||||
|
a Major Component, but which is not part of that Major Component, and
|
||||||
|
(b) serves only to enable use of the work with that Major Component, or to
|
||||||
|
implement a Standard Interface for which an implementation is available to
|
||||||
|
the public in source code form. A "Major Component", in this context,
|
||||||
|
means a major essential component (kernel, window system, and so on) of
|
||||||
|
the specific operating system (if any) on which the executable work runs,
|
||||||
|
or a compiler used to produce the work, or an object code interpreter used
|
||||||
|
to run it.
|
||||||
|
|
||||||
|
The "Corresponding Source" for a work in object code form means all the
|
||||||
|
source code needed to generate, install, and (for an executable work) run
|
||||||
|
the object code and to modify the work, including scripts to control those
|
||||||
|
activities. However, it does not include the work's System Libraries, or
|
||||||
|
general-purpose tools or generally available free programs which are used
|
||||||
|
unmodified in performing those activities but which are not part of the
|
||||||
|
work. For example, Corresponding Source includes interface definition
|
||||||
|
files associated with source files for the work, and the source code for
|
||||||
|
shared libraries and dynamically linked subprograms that the work is
|
||||||
|
specifically designed to require, such as by intimate data communication
|
||||||
|
or control flow between those subprograms and other parts of the work.
|
||||||
|
|
||||||
|
The Corresponding Source need not include anything that users can
|
||||||
|
regenerate automatically from other parts of the Corresponding Source.
|
||||||
|
|
||||||
|
The Corresponding Source for a work in source code form is that same
|
||||||
|
work.
|
||||||
|
|
||||||
|
2. Basic Permissions.
|
||||||
|
|
||||||
|
All rights granted under this License are granted for the term of
|
||||||
|
copyright on the Program, and are irrevocable provided the stated
|
||||||
|
conditions are met. This License explicitly affirms your unlimited
|
||||||
|
permission to run the unmodified Program. The output from running a
|
||||||
|
covered work is covered by this License only if the output, given its
|
||||||
|
content, constitutes a covered work. This License acknowledges your
|
||||||
|
rights of fair use or other equivalent, as provided by copyright law.
|
||||||
|
|
||||||
|
You may make, run and propagate covered works that you do not convey,
|
||||||
|
without conditions so long as your license otherwise remains in force.
|
||||||
|
You may convey covered works to others for the sole purpose of having them
|
||||||
|
make modifications exclusively for you, or provide you with facilities for
|
||||||
|
running those works, provided that you comply with the terms of this
|
||||||
|
License in conveying all material for which you do not control copyright.
|
||||||
|
Those thus making or running the covered works for you must do so
|
||||||
|
exclusively on your behalf, under your direction and control, on terms
|
||||||
|
that prohibit them from making any copies of your copyrighted material
|
||||||
|
outside their relationship with you.
|
||||||
|
|
||||||
|
Conveying under any other circumstances is permitted solely under the
|
||||||
|
conditions stated below. Sublicensing is not allowed; section 10 makes it
|
||||||
|
unnecessary.
|
||||||
|
|
||||||
|
3. Protecting Users' Legal Rights From Anti-Circumvention Law.
|
||||||
|
|
||||||
|
No covered work shall be deemed part of an effective technological
|
||||||
|
measure under any applicable law fulfilling obligations under article 11
|
||||||
|
of the WIPO copyright treaty adopted on 20 December 1996, or similar
|
||||||
|
laws prohibiting or restricting circumvention of such measures.
|
||||||
|
|
||||||
|
When you convey a covered work, you waive any legal power to forbid
|
||||||
|
circumvention of technological measures to the extent such circumvention
|
||||||
|
is effected by exercising rights under this License with respect to the
|
||||||
|
covered work, and you disclaim any intention to limit operation or
|
||||||
|
modification of the work as a means of enforcing, against the work's users,
|
||||||
|
your or third parties' legal rights to forbid circumvention of
|
||||||
|
technological measures.
|
||||||
|
|
||||||
|
4. Conveying Verbatim Copies.
|
||||||
|
|
||||||
|
You may convey verbatim copies of the Program's source code as you
|
||||||
|
receive it, in any medium, provided that you conspicuously and
|
||||||
|
appropriately publish on each copy an appropriate copyright notice; keep
|
||||||
|
intact all notices stating that this License and any non-permissive terms
|
||||||
|
added in accord with section 7 apply to the code; keep intact all notices
|
||||||
|
of the absence of any warranty; and give all recipients a copy of this
|
||||||
|
License along with the Program.
|
||||||
|
|
||||||
|
You may charge any price or no price for each copy that you convey, and
|
||||||
|
you may offer support or warranty protection for a fee.
|
||||||
|
|
||||||
|
5. Conveying Modified Source Versions.
|
||||||
|
|
||||||
|
You may convey a work based on the Program, or the modifications to
|
||||||
|
produce it from the Program, in the form of source code under the terms
|
||||||
|
of section 4, provided that you also meet all of these conditions:
|
||||||
|
|
||||||
|
a) The work must carry prominent notices stating that you modified
|
||||||
|
it, and giving a relevant date.
|
||||||
|
|
||||||
|
b) The work must carry prominent notices stating that it is released
|
||||||
|
under this License and any conditions added under section 7. This
|
||||||
|
requirement modifies the requirement in section 4 to "keep intact all
|
||||||
|
notices".
|
||||||
|
|
||||||
|
c) You must license the entire work, as a whole, under this License
|
||||||
|
to anyone who comes into possession of a copy. This License will
|
||||||
|
therefore apply, along with any applicable section 7 additional terms,
|
||||||
|
to the whole of the work, and all its parts, regardless of how they
|
||||||
|
are packaged. This License gives no permission to license the work in
|
||||||
|
any other way, but it does not invalidate such permission if you have
|
||||||
|
separately received it.
|
||||||
|
|
||||||
|
d) If the work has interactive user interfaces, each must display
|
||||||
|
Appropriate Legal Notices; however, if the Program has interactive
|
||||||
|
interfaces that do not display Appropriate Legal Notices, your work
|
||||||
|
need not make them do so.
|
||||||
|
|
||||||
|
A compilation of a covered work with other separate and independent
|
||||||
|
works, which are not by their nature extensions of the covered work and
|
||||||
|
which are not combined with it such as to form a larger program, in or on
|
||||||
|
a volume of a storage or distribution medium, is called an "aggregate" if
|
||||||
|
the compilation and its resulting copyright are not used to limit the
|
||||||
|
access or legal rights of the compilation's users beyond what the
|
||||||
|
individual works permit. Inclusion of a covered work in an aggregate
|
||||||
|
does not cause this License to apply to the other parts of the aggregate.
|
||||||
|
|
||||||
|
6. Conveying Non-Source Forms.
|
||||||
|
|
||||||
|
You may convey a covered work in object code form under the terms of
|
||||||
|
sections 4 and 5, provided that you also convey the machine-readable
|
||||||
|
Corresponding Source under the terms of this License, in one of these
|
||||||
|
ways:
|
||||||
|
|
||||||
|
a) Convey the object code in, or embodied in, a physical product
|
||||||
|
(including a physical distribution medium), accompanied by the
|
||||||
|
Corresponding Source fixed on a durable physical medium customarily
|
||||||
|
used for software interchange.
|
||||||
|
|
||||||
|
b) Convey the object code in, or embodied in, a physical product
|
||||||
|
(including a physical distribution medium), accompanied by a
|
||||||
|
written offer, valid for at least three years and valid for as long
|
||||||
|
as you offer spare parts or customer support for that product model,
|
||||||
|
to give anyone who possesses the object code either (1) a copy of the
|
||||||
|
Corresponding Source for all the software in the product that is
|
||||||
|
covered by this License, on a durable physical medium customarily
|
||||||
|
used for software interchange, for a price no more than your
|
||||||
|
reasonable cost of physically performing this conveying of source, or
|
||||||
|
(2) access to copy the Corresponding Source from a network server at
|
||||||
|
no charge.
|
||||||
|
|
||||||
|
c) Convey individual copies of the object code with a copy of the
|
||||||
|
written offer to provide the Corresponding Source. This alternative
|
||||||
|
is allowed only occasionally and noncommercially, and only if you
|
||||||
|
received the object code with such an offer, in accord with
|
||||||
|
subsection 6b.
|
||||||
|
|
||||||
|
d) Convey the object code by offering access from a designated place
|
||||||
|
(gratis or for a charge), and offer equivalent access to the
|
||||||
|
Corresponding Source in the same way through the same place at no
|
||||||
|
further charge. You need not require recipients to copy the
|
||||||
|
Corresponding Source along with the object code. If the place to copy
|
||||||
|
the object code is a network server, the Corresponding Source may be
|
||||||
|
on a different server (operated by you or a third party) that supports
|
||||||
|
equivalent copying facilities, provided you maintain clear directions
|
||||||
|
next to the object code saying where to find the Corresponding Source.
|
||||||
|
Regardless of what server hosts the Corresponding Source, you remain
|
||||||
|
obligated to ensure that it is available for as long as needed to
|
||||||
|
satisfy these requirements.
|
||||||
|
|
||||||
|
e) Convey the object code using peer-to-peer transmission, provided
|
||||||
|
you inform other peers where the object code and Corresponding Source
|
||||||
|
of the work are being offered to the general public at no charge under
|
||||||
|
subsection 6d.
|
||||||
|
|
||||||
|
A separable portion of the object code, whose source code is excluded
|
||||||
|
from the Corresponding Source as a System Library, need not be included
|
||||||
|
in conveying the object code work.
|
||||||
|
|
||||||
|
A "User Product" is either (1) a "consumer product", which means any
|
||||||
|
tangible personal property which is normally used for personal, family, or
|
||||||
|
household purposes, or (2) anything designed or sold for incorporation into
|
||||||
|
a dwelling. In determining whether a product is a consumer product,
|
||||||
|
doubtful cases shall be resolved in favor of coverage. For a particular
|
||||||
|
product received by a particular user, "normally used" refers to a typical
|
||||||
|
or common use of that class of product, regardless of the status of the
|
||||||
|
particular user or of the way in which the particular user actually uses,
|
||||||
|
or expects or is expected to use, the product. A product is a consumer
|
||||||
|
product regardless of whether the product has substantial commercial,
|
||||||
|
industrial or non-consumer uses, unless such uses represent the only
|
||||||
|
significant mode of use of the product.
|
||||||
|
|
||||||
|
"Installation Information" for a User Product means any methods,
|
||||||
|
procedures, authorization keys, or other information required to install
|
||||||
|
and execute modified versions of a covered work in that User Product from
|
||||||
|
a modified version of its Corresponding Source. The information must
|
||||||
|
suffice to ensure that the continued functioning of the modified object
|
||||||
|
code is in no case prevented or interfered with solely because
|
||||||
|
modification has been made.
|
||||||
|
|
||||||
|
If you convey an object code work under this section in, or with, or
|
||||||
|
specifically for use in, a User Product, and the conveying occurs as part of
|
||||||
|
a transaction in which the right of possession and use of the User Product
|
||||||
|
is transferred to the recipient in perpetuity or for a fixed term (regardless
|
||||||
|
of how the transaction is characterized), the Corresponding Source conveyed
|
||||||
|
under this section must be accompanied by the Installation Information.
|
||||||
|
But this requirement does not apply if neither you nor any third party
|
||||||
|
retains the ability to install modified object code on the User Product
|
||||||
|
(for example, the work has been installed in ROM).
|
||||||
|
|
||||||
|
The requirement to provide Installation Information does not include a
|
||||||
|
requirement to continue to provide support service, warranty, or updates
|
||||||
|
for a work that has been modified or installed by the recipient, or for
|
||||||
|
the User Product in which it has been modified or installed. Access to a
|
||||||
|
network may be denied when the modification itself materially and
|
||||||
|
adversely affects the operation of the network or violates the rules and
|
||||||
|
protocols for communication across the network.
|
||||||
|
|
||||||
|
Corresponding Source conveyed, and Installation Information provided,
|
||||||
|
in accord with this section must be in a format that is publicly
|
||||||
|
documented (and with an implementation available to the public in source
|
||||||
|
code form), and must require no special password or key for unpacking,
|
||||||
|
reading or copying.
|
||||||
|
|
||||||
|
7. Additional Terms.
|
||||||
|
|
||||||
|
"Additional permissions" are terms that supplement the terms of this
|
||||||
|
License by making exceptions from one or more of its conditions.
|
||||||
|
Additional permissions that are applicable to the entire Program shall
|
||||||
|
be treated as though they were included in this License, to the extent
|
||||||
|
that they are valid under applicable law. If additional permissions
|
||||||
|
apply only to part of the Program, that part may be used separately under
|
||||||
|
those permissions, but the entire Program remains governed by this
|
||||||
|
License without regard to the additional permissions.
|
||||||
|
|
||||||
|
When you convey a copy of a covered work, you may at your option remove
|
||||||
|
any additional permissions from that copy, or from any part of it.
|
||||||
|
(Additional permissions may be written to require their own removal in
|
||||||
|
certain cases when you modify the work.) You may place additional
|
||||||
|
permissions on material, added by you to a covered work, for which you
|
||||||
|
have or can give appropriate copyright permission.
|
||||||
|
|
||||||
|
Notwithstanding any other provision of this License, for material you
|
||||||
|
add to a covered work, you may (if authorized by the copyright holders of
|
||||||
|
that material) supplement the terms of this License with terms:
|
||||||
|
|
||||||
|
a) Disclaiming warranty or limiting liability differently from the
|
||||||
|
terms of sections 15 and 16 of this License; or
|
||||||
|
|
||||||
|
b) Requiring preservation of specified reasonable legal notices or
|
||||||
|
author attributions in that material or in the Appropriate Legal
|
||||||
|
Notices displayed by works containing it; or
|
||||||
|
|
||||||
|
c) Prohibiting misrepresentation of the origin of that material, or
|
||||||
|
requiring that modified versions of such material be marked in
|
||||||
|
reasonable ways as different from the original version; or
|
||||||
|
|
||||||
|
d) Limiting the use for publicity purposes of names of licensors or
|
||||||
|
authors of the material; or
|
||||||
|
|
||||||
|
e) Declining to grant rights under trademark law for use of some
|
||||||
|
trade names, trademarks, or service marks; or
|
||||||
|
|
||||||
|
f) Requiring indemnification of licensors and authors of that material
|
||||||
|
by anyone who conveys the material (or modified versions of it) with
|
||||||
|
contractual assumptions of liability to the recipient, for any
|
||||||
|
liability that these contractual assumptions directly impose on those
|
||||||
|
licensors and authors.
|
||||||
|
|
||||||
|
All other non-permissive additional terms are considered "further
|
||||||
|
restrictions" within the meaning of section 10. If the Program as you
|
||||||
|
received it, or any part of it, contains a notice stating that it is
|
||||||
|
governed by this License along with a term that is a further restriction,
|
||||||
|
you may remove that term. If a license document contains a further
|
||||||
|
restriction but permits relicensing or conveying under this License, you
|
||||||
|
may add to a covered work material governed by the terms of that license
|
||||||
|
document, provided that the further restriction does not survive such
|
||||||
|
relicensing or conveying.
|
||||||
|
|
||||||
|
If you add terms to a covered work in accord with this section, you must
|
||||||
|
place, in the relevant source files, a statement of the additional terms
|
||||||
|
that apply to those files, or a notice indicating where to find the
|
||||||
|
applicable terms.
|
||||||
|
|
||||||
|
Additional terms, permissive or non-permissive, may be stated in the
|
||||||
|
form of a separately written license, or stated as exceptions; the above
|
||||||
|
requirements apply either way.
|
||||||
|
|
||||||
|
8. Termination.
|
||||||
|
|
||||||
|
You may not propagate or modify a covered work except as expressly
|
||||||
|
provided under this License. Any attempt otherwise to propagate or
|
||||||
|
modify it is void, and will automatically terminate your rights under this
|
||||||
|
License (including any patent licenses granted under the third paragraph
|
||||||
|
of section 11).
|
||||||
|
|
||||||
|
However, if you cease all violation of this License, then your license
|
||||||
|
from a particular copyright holder is reinstated (a) provisionally,
|
||||||
|
unless and until the copyright holder explicitly and finally terminates
|
||||||
|
your license, and (b) permanently, if the copyright holder fails to
|
||||||
|
notify you of the violation by some reasonable means prior to 60 days
|
||||||
|
after the cessation.
|
||||||
|
|
||||||
|
Moreover, your license from a particular copyright holder is reinstated
|
||||||
|
permanently if the copyright holder notifies you of the violation by some
|
||||||
|
reasonable means, this is the first time you have received notice of
|
||||||
|
violation of this License (for any work) from that copyright holder, and
|
||||||
|
you cure the violation prior to 30 days after your receipt of the notice.
|
||||||
|
|
||||||
|
Termination of your rights under this section does not terminate the
|
||||||
|
licenses of parties who have received copies or rights from you under
|
||||||
|
this License. If your rights have been terminated and not permanently
|
||||||
|
reinstated, you do not qualify to receive new licenses for the same material
|
||||||
|
under section 10.
|
||||||
|
|
||||||
|
9. Acceptance Not Required for Having Copies.
|
||||||
|
|
||||||
|
You are not required to accept this License in order to receive or run
|
||||||
|
a copy of the Program. Ancillary propagation of a covered work occurring
|
||||||
|
solely as a consequence of using peer-to-peer transmission to receive a
|
||||||
|
copy likewise does not require acceptance. However, nothing other than
|
||||||
|
this License grants you permission to propagate or modify any covered work.
|
||||||
|
These actions infringe copyright if you do not accept this License.
|
||||||
|
Therefore, by modifying or propagating a covered work, you indicate your
|
||||||
|
acceptance of this License to do so.
|
||||||
|
|
||||||
|
10. Automatic Licensing of Downstream Recipients.
|
||||||
|
|
||||||
|
Each time you convey a covered work, the recipient automatically
|
||||||
|
receives a license from the original licensors, to run, modify and
|
||||||
|
propagate that work, subject to this License. You are not responsible
|
||||||
|
for enforcing compliance by third parties with this License.
|
||||||
|
|
||||||
|
An "entity transaction" is a transaction transferring control of an
|
||||||
|
organization, or substantially all assets of one, or subdividing an
|
||||||
|
organization, or merging organizations. If propagation of a covered work
|
||||||
|
results from an entity transaction, each party to that transaction who
|
||||||
|
receives a copy of the work also receives whatever licenses to the work
|
||||||
|
the party's predecessor in interest had or could give under the previous
|
||||||
|
paragraph, plus a right to possession of the Corresponding Source of the
|
||||||
|
work from the predecessor in interest, if the predecessor has it or can
|
||||||
|
get it with reasonable efforts.
|
||||||
|
|
||||||
|
You may not impose any further restrictions on the exercise of the rights
|
||||||
|
granted or affirmed under this License. For example, you may not impose
|
||||||
|
a license fee, royalty, or other charge for exercise of rights granted
|
||||||
|
under this License, and you may not initiate litigation (including a
|
||||||
|
cross-claim or counterclaim in a lawsuit) alleging that any patent claim
|
||||||
|
is infringed by making, using, selling, offering for sale, or importing
|
||||||
|
the Program or any portion of it.
|
||||||
|
|
||||||
|
11. Patents.
|
||||||
|
|
||||||
|
A "contributor" is a copyright holder who authorizes use under this
|
||||||
|
License of the Program or a work on which the Program is based. The work
|
||||||
|
thus licensed is called the contributor's "contributor version".
|
||||||
|
|
||||||
|
A contributor's "essential patent claims" are all patent claims owned
|
||||||
|
or controlled by the contributor, whether already acquired or hereafter
|
||||||
|
acquired, that would be infringed by some manner, permitted by this
|
||||||
|
License, of making, using, or selling its contributor version, but do not
|
||||||
|
include claims that would be infringed only as a consequence of further
|
||||||
|
modification of the contributor version. For purposes of this definition,
|
||||||
|
"control" includes the right to grant patent sublicenses in a manner
|
||||||
|
consistent with the requirements of this License.
|
||||||
|
|
||||||
|
Each contributor grants you a non-exclusive, worldwide, royalty-free
|
||||||
|
patent license under the contributor's essential patent claims, to make,
|
||||||
|
use, sell, offer for sale, import and otherwise run, modify and propagate
|
||||||
|
the contents of its contributor version.
|
||||||
|
|
||||||
|
In the following three paragraphs, a "patent license" is any express
|
||||||
|
agreement or commitment, however denominated, not to enforce a patent
|
||||||
|
(such as an express permission to practice a patent or covenant not to
|
||||||
|
sue for patent infringement). To "grant" such a patent license to a
|
||||||
|
party means to make such an agreement or commitment not to enforce a
|
||||||
|
patent against the party.
|
||||||
|
|
||||||
|
If you convey a covered work, knowingly relying on a patent license, and
|
||||||
|
the Corresponding Source of the work is not available for anyone to copy,
|
||||||
|
free of charge and under the terms of this License, through a publicly
|
||||||
|
available network server or other readily accessible means, then you must
|
||||||
|
either (1) cause the Corresponding Source to be so available, or (2)
|
||||||
|
arrange to deprive yourself of the benefit of the patent license for this
|
||||||
|
particular work, or (3) arrange, in a manner consistent with the
|
||||||
|
requirements of this License, to extend the patent license to downstream
|
||||||
|
recipients. "Knowingly relying" means you have actual knowledge that, but
|
||||||
|
for the patent license, your conveying the covered work in a country, or
|
||||||
|
your recipient's use of the covered work in a country, would infringe one
|
||||||
|
or more identifiable patents in that country that you have reason to
|
||||||
|
believe are valid.
|
||||||
|
|
||||||
|
If, pursuant to or in connection with a single transaction or
|
||||||
|
arrangement, you convey, or propagate by procuring conveyance of, a covered
|
||||||
|
work, and grant a patent license to some of the parties receiving the
|
||||||
|
covered work authorizing them to use, propagate, modify or convey a
|
||||||
|
specific copy of the covered work, then the patent license you grant is
|
||||||
|
automatically extended to all recipients of the covered work and works
|
||||||
|
based on it.
|
||||||
|
|
||||||
|
A patent license is "discriminatory" if it does not include within the
|
||||||
|
scope of its coverage, prohibits the exercise of, or is conditioned on the
|
||||||
|
non-exercise of one or more of the rights that are specifically granted
|
||||||
|
under this License. You may not convey a covered work if you are a party
|
||||||
|
to an arrangement with a third party that is in the business of
|
||||||
|
distributing software, under which you make payment to the third party
|
||||||
|
based on the extent of your activity of conveying the work, and under
|
||||||
|
which the third party grants, to any of the parties who would receive the
|
||||||
|
covered work from you, a discriminatory patent license (a) in connection
|
||||||
|
with copies of the covered work conveyed by you (or copies made from those
|
||||||
|
copies), or (b) primarily for and in connection with specific products or
|
||||||
|
compilations that contain the covered work, unless you entered into that
|
||||||
|
arrangement, or that patent license was granted, prior to 28 March 2007.
|
||||||
|
|
||||||
|
Nothing in this License shall be construed as excluding or limiting any
|
||||||
|
implied license or other defenses to infringement that may otherwise be
|
||||||
|
available to you under applicable patent law.
|
||||||
|
|
||||||
|
12. No Surrender of Others' Freedom.
|
||||||
|
|
||||||
|
If conditions are imposed on you (whether by court order, agreement or
|
||||||
|
otherwise) that contradict the conditions of this License, they do not
|
||||||
|
excuse you from the conditions of this License. If you cannot convey a
|
||||||
|
covered work so as to satisfy simultaneously your obligations under this
|
||||||
|
License and any other pertinent obligations, then as a consequence you may
|
||||||
|
not convey it at all. For example, if you agree to terms that obligate you
|
||||||
|
to collect a royalty for further conveying from those to whom you convey
|
||||||
|
the Program, the only way you could satisfy both those terms and this
|
||||||
|
License would be to refrain entirely from conveying the Program.
|
||||||
|
|
||||||
|
13. Remote Network Interaction; Use with the GNU General Public License.
|
||||||
|
|
||||||
|
Notwithstanding any other provision of this License, if you modify the
|
||||||
|
Program, your modified version must prominently offer all users
|
||||||
|
interacting with it remotely through a computer network (if your version
|
||||||
|
supports such interaction) an opportunity to receive the Corresponding
|
||||||
|
Source of your version by providing access to the Corresponding Source
|
||||||
|
from a network server at no charge, through some standard or customary
|
||||||
|
means of facilitating copying of software. This Corresponding Source
|
||||||
|
shall include the Corresponding Source for any work covered by version 3
|
||||||
|
of the GNU General Public License that is incorporated pursuant to the
|
||||||
|
following paragraph.
|
||||||
|
|
||||||
|
Notwithstanding any other provision of this License, you have permission
|
||||||
|
to link or combine any covered work with a work licensed under version 3
|
||||||
|
of the GNU General Public License into a single combined work, and to
|
||||||
|
convey the resulting work. The terms of this License will continue to
|
||||||
|
apply to the part which is the covered work, but the work with which it is
|
||||||
|
combined will remain governed by version 3 of the GNU General Public
|
||||||
|
License.
|
||||||
|
|
||||||
|
14. Revised Versions of this License.
|
||||||
|
|
||||||
|
The Free Software Foundation may publish revised and/or new versions of
|
||||||
|
the GNU Affero General Public License from time to time. Such new
|
||||||
|
versions will be similar in spirit to the present version, but may differ
|
||||||
|
in detail to address new problems or concerns.
|
||||||
|
|
||||||
|
Each version is given a distinguishing version number. If the Program
|
||||||
|
specifies that a certain numbered version of the GNU Affero General Public
|
||||||
|
License "or any later version" applies to it, you have the option of
|
||||||
|
following the terms and conditions either of that numbered version or of
|
||||||
|
any later version published by the Free Software Foundation. If the
|
||||||
|
Program does not specify a version number of the GNU Affero General Public
|
||||||
|
License, you may choose any version ever published by the Free Software
|
||||||
|
Foundation.
|
||||||
|
|
||||||
|
If the Program specifies that a proxy can decide which future versions
|
||||||
|
of the GNU Affero General Public License can be used, that proxy's public
|
||||||
|
statement of acceptance of a version permanently authorizes you to choose
|
||||||
|
that version for the Program.
|
||||||
|
|
||||||
|
Later license versions may give you additional or different permissions.
|
||||||
|
However, no additional obligations are imposed on any author or copyright
|
||||||
|
holder as a result of your choosing to follow a later version.
|
||||||
|
|
||||||
|
15. Disclaimer of Warranty.
|
||||||
|
|
||||||
|
THERE IS NO WARRANTY FOR THE PROGRAM, TO THE EXTENT PERMITTED BY
|
||||||
|
APPLICABLE LAW. EXCEPT WHEN OTHERWISE STATED IN WRITING THE COPYRIGHT
|
||||||
|
HOLDERS AND/OR OTHER PARTIES PROVIDE THE PROGRAM "AS IS" WITHOUT WARRANTY
|
||||||
|
OF ANY KIND, EITHER EXPRESSED OR IMPLIED, INCLUDING, BUT NOT LIMITED TO,
|
||||||
|
THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
|
||||||
|
PURPOSE. THE ENTIRE RISK AS TO THE QUALITY AND PERFORMANCE OF THE PROGRAM
|
||||||
|
IS WITH YOU. SHOULD THE PROGRAM PROVE DEFECTIVE, YOU ASSUME THE COST OF
|
||||||
|
ALL NECESSARY SERVICING, REPAIR OR CORRECTION.
|
||||||
|
|
||||||
|
16. Limitation of Liability.
|
||||||
|
|
||||||
|
IN NO EVENT UNLESS REQUIRED BY APPLICABLE LAW OR AGREED TO IN WRITING
|
||||||
|
WILL ANY COPYRIGHT HOLDER, OR ANY OTHER PARTY WHO MODIFIES AND/OR CONVEYS
|
||||||
|
THE PROGRAM AS PERMITTED ABOVE, BE LIABLE TO YOU FOR DAMAGES, INCLUDING ANY
|
||||||
|
GENERAL, SPECIAL, INCIDENTAL OR CONSEQUENTIAL DAMAGES ARISING OUT OF THE
|
||||||
|
USE OR INABILITY TO USE THE PROGRAM (INCLUDING BUT NOT LIMITED TO LOSS OF
|
||||||
|
DATA OR DATA BEING RENDERED INACCURATE OR LOSSES SUSTAINED BY YOU OR THIRD
|
||||||
|
PARTIES OR A FAILURE OF THE PROGRAM TO OPERATE WITH ANY OTHER PROGRAMS),
|
||||||
|
EVEN IF SUCH HOLDER OR OTHER PARTY HAS BEEN ADVISED OF THE POSSIBILITY OF
|
||||||
|
SUCH DAMAGES.
|
||||||
|
|
||||||
|
17. Interpretation of Sections 15 and 16.
|
||||||
|
|
||||||
|
If the disclaimer of warranty and limitation of liability provided above
|
||||||
|
cannot be given local legal effect according to their terms, reviewing
|
||||||
|
courts shall apply local law that most closely approximates an absolute
|
||||||
|
waiver of all civil liability in connection with the Program, unless a
|
||||||
|
warranty or assumption of liability accompanies a copy of the Program in
|
||||||
|
return for a fee.
|
||||||
|
|
||||||
|
END OF TERMS AND CONDITIONS
|
||||||
|
|
|
||||||
|
|
@ -3,9 +3,10 @@
|
||||||
"type": "module",
|
"type": "module",
|
||||||
"version": "0.1.0",
|
"version": "0.1.0",
|
||||||
"description": "Desktop app that visualizes Claude Code session execution — explore conversations, track context usage, and analyze tool calls",
|
"description": "Desktop app that visualizes Claude Code session execution — explore conversations, track context usage, and analyze tool calls",
|
||||||
"license": "MIT",
|
"license": "AGPL-3.0",
|
||||||
"author": {
|
"author": {
|
||||||
"name": "Claude Agent Teams UI contributors"
|
"name": "Илия (777genius)",
|
||||||
|
"email": "quantjumppro@gmail.com"
|
||||||
},
|
},
|
||||||
"homepage": "https://github.com/777genius/claude_agent_teams_ui",
|
"homepage": "https://github.com/777genius/claude_agent_teams_ui",
|
||||||
"repository": {
|
"repository": {
|
||||||
|
|
|
||||||
|
|
@ -1,4 +1,5 @@
|
||||||
import {
|
import {
|
||||||
|
TEAM_ADD_TASK_COMMENT,
|
||||||
TEAM_ALIVE_LIST,
|
TEAM_ALIVE_LIST,
|
||||||
TEAM_CANCEL_PROVISIONING,
|
TEAM_CANCEL_PROVISIONING,
|
||||||
TEAM_CREATE,
|
TEAM_CREATE,
|
||||||
|
|
@ -45,6 +46,7 @@ import type {
|
||||||
MemberLogSummary,
|
MemberLogSummary,
|
||||||
SendMessageRequest,
|
SendMessageRequest,
|
||||||
SendMessageResult,
|
SendMessageResult,
|
||||||
|
TaskComment,
|
||||||
TeamConfig,
|
TeamConfig,
|
||||||
TeamCreateConfigRequest,
|
TeamCreateConfigRequest,
|
||||||
TeamCreateRequest,
|
TeamCreateRequest,
|
||||||
|
|
@ -103,6 +105,7 @@ export function registerTeamHandlers(ipcMain: IpcMain): void {
|
||||||
ipcMain.handle(TEAM_UPDATE_CONFIG, handleUpdateConfig);
|
ipcMain.handle(TEAM_UPDATE_CONFIG, handleUpdateConfig);
|
||||||
ipcMain.handle(TEAM_START_TASK, handleStartTask);
|
ipcMain.handle(TEAM_START_TASK, handleStartTask);
|
||||||
ipcMain.handle(TEAM_GET_ALL_TASKS, handleGetAllTasks);
|
ipcMain.handle(TEAM_GET_ALL_TASKS, handleGetAllTasks);
|
||||||
|
ipcMain.handle(TEAM_ADD_TASK_COMMENT, handleAddTaskComment);
|
||||||
logger.info('Team handlers registered');
|
logger.info('Team handlers registered');
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -129,6 +132,7 @@ export function removeTeamHandlers(ipcMain: IpcMain): void {
|
||||||
ipcMain.removeHandler(TEAM_UPDATE_CONFIG);
|
ipcMain.removeHandler(TEAM_UPDATE_CONFIG);
|
||||||
ipcMain.removeHandler(TEAM_START_TASK);
|
ipcMain.removeHandler(TEAM_START_TASK);
|
||||||
ipcMain.removeHandler(TEAM_GET_ALL_TASKS);
|
ipcMain.removeHandler(TEAM_GET_ALL_TASKS);
|
||||||
|
ipcMain.removeHandler(TEAM_ADD_TASK_COMMENT);
|
||||||
}
|
}
|
||||||
|
|
||||||
function getTeamDataService(): TeamDataService {
|
function getTeamDataService(): TeamDataService {
|
||||||
|
|
@ -809,3 +813,23 @@ async function handleStartTask(
|
||||||
async function handleGetAllTasks(_event: IpcMainInvokeEvent): Promise<IpcResult<GlobalTask[]>> {
|
async function handleGetAllTasks(_event: IpcMainInvokeEvent): Promise<IpcResult<GlobalTask[]>> {
|
||||||
return wrapTeamHandler('getAllTasks', () => getTeamDataService().getAllTasks());
|
return wrapTeamHandler('getAllTasks', () => getTeamDataService().getAllTasks());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
async function handleAddTaskComment(
|
||||||
|
_event: IpcMainInvokeEvent,
|
||||||
|
teamName: unknown,
|
||||||
|
taskId: unknown,
|
||||||
|
text: unknown
|
||||||
|
): Promise<IpcResult<TaskComment>> {
|
||||||
|
const vTeam = validateTeamName(teamName);
|
||||||
|
if (!vTeam.valid) return { success: false, error: vTeam.error ?? 'Invalid teamName' };
|
||||||
|
const vTask = validateTaskId(taskId);
|
||||||
|
if (!vTask.valid) return { success: false, error: vTask.error ?? 'Invalid taskId' };
|
||||||
|
if (typeof text !== 'string' || text.trim().length === 0)
|
||||||
|
return { success: false, error: 'Comment text must be non-empty' };
|
||||||
|
if (text.trim().length > 2000)
|
||||||
|
return { success: false, error: 'Comment exceeds 2000 characters' };
|
||||||
|
|
||||||
|
return wrapTeamHandler('addTaskComment', () =>
|
||||||
|
getTeamDataService().addTaskComment(vTeam.value!, vTask.value!, text.trim())
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
|
||||||
|
|
@ -31,6 +31,7 @@ import type {
|
||||||
KanbanTaskState,
|
KanbanTaskState,
|
||||||
SendMessageRequest,
|
SendMessageRequest,
|
||||||
SendMessageResult,
|
SendMessageResult,
|
||||||
|
TaskComment,
|
||||||
TeamConfig,
|
TeamConfig,
|
||||||
TeamCreateConfigRequest,
|
TeamCreateConfigRequest,
|
||||||
TeamData,
|
TeamData,
|
||||||
|
|
@ -314,6 +315,26 @@ export class TeamDataService {
|
||||||
await this.taskWriter.updateStatus(teamName, taskId, status);
|
await this.taskWriter.updateStatus(teamName, taskId, status);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
async addTaskComment(teamName: string, taskId: string, text: string): Promise<TaskComment> {
|
||||||
|
const comment = await this.taskWriter.addComment(teamName, taskId, text);
|
||||||
|
|
||||||
|
try {
|
||||||
|
const tasks = await this.taskReader.getTasks(teamName);
|
||||||
|
const task = tasks.find((t) => t.id === taskId);
|
||||||
|
if (task?.owner) {
|
||||||
|
await this.sendMessage(teamName, {
|
||||||
|
member: task.owner,
|
||||||
|
text: `Comment on task #${taskId} "${task.subject}":\n\n${text}`,
|
||||||
|
summary: `Comment on #${taskId}`,
|
||||||
|
});
|
||||||
|
}
|
||||||
|
} catch {
|
||||||
|
// Notification is best-effort — don't fail comment save
|
||||||
|
}
|
||||||
|
|
||||||
|
return comment;
|
||||||
|
}
|
||||||
|
|
||||||
async sendMessage(teamName: string, request: SendMessageRequest): Promise<SendMessageResult> {
|
async sendMessage(teamName: string, request: SendMessageRequest): Promise<SendMessageResult> {
|
||||||
return this.inboxWriter.sendMessage(teamName, request);
|
return this.inboxWriter.sendMessage(teamName, request);
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -3,7 +3,7 @@ import { createLogger } from '@shared/utils/logger';
|
||||||
import * as fs from 'fs';
|
import * as fs from 'fs';
|
||||||
import * as path from 'path';
|
import * as path from 'path';
|
||||||
|
|
||||||
import type { TeamTask } from '@shared/types';
|
import type { TaskComment, TeamTask } from '@shared/types';
|
||||||
|
|
||||||
const logger = createLogger('Service:TeamTaskReader');
|
const logger = createLogger('Service:TeamTaskReader');
|
||||||
|
|
||||||
|
|
@ -107,6 +107,16 @@ export class TeamTaskReader {
|
||||||
blockedBy: Array.isArray(parsed.blockedBy) ? (parsed.blockedBy as string[]) : undefined,
|
blockedBy: Array.isArray(parsed.blockedBy) ? (parsed.blockedBy as string[]) : undefined,
|
||||||
createdAt,
|
createdAt,
|
||||||
projectPath: typeof parsed.projectPath === 'string' ? parsed.projectPath : undefined,
|
projectPath: typeof parsed.projectPath === 'string' ? parsed.projectPath : undefined,
|
||||||
|
comments: Array.isArray(parsed.comments)
|
||||||
|
? (parsed.comments as TaskComment[]).filter(
|
||||||
|
(c) =>
|
||||||
|
c &&
|
||||||
|
typeof c === 'object' &&
|
||||||
|
typeof c.id === 'string' &&
|
||||||
|
typeof c.text === 'string' &&
|
||||||
|
typeof c.createdAt === 'string'
|
||||||
|
)
|
||||||
|
: undefined,
|
||||||
};
|
};
|
||||||
if (task.status === 'deleted') {
|
if (task.status === 'deleted') {
|
||||||
continue;
|
continue;
|
||||||
|
|
|
||||||
|
|
@ -1,10 +1,31 @@
|
||||||
import { getTasksBasePath } from '@main/utils/pathDecoder';
|
import { getTasksBasePath } from '@main/utils/pathDecoder';
|
||||||
|
import { randomUUID } from 'crypto';
|
||||||
import * as fs from 'fs';
|
import * as fs from 'fs';
|
||||||
import * as path from 'path';
|
import * as path from 'path';
|
||||||
|
|
||||||
import { atomicWriteAsync } from './atomicWrite';
|
import { atomicWriteAsync } from './atomicWrite';
|
||||||
|
|
||||||
import type { TeamTask, TeamTaskStatus } from '@shared/types';
|
import type { TaskComment, TeamTask, TeamTaskStatus } from '@shared/types';
|
||||||
|
|
||||||
|
const taskWriteLocks = new Map<string, Promise<void>>();
|
||||||
|
|
||||||
|
async function withTaskLock<T>(taskPath: string, fn: () => Promise<T>): Promise<T> {
|
||||||
|
const prev = taskWriteLocks.get(taskPath) ?? Promise.resolve();
|
||||||
|
let release!: () => void;
|
||||||
|
const mine = new Promise<void>((resolve) => {
|
||||||
|
release = resolve;
|
||||||
|
});
|
||||||
|
taskWriteLocks.set(taskPath, mine);
|
||||||
|
await prev;
|
||||||
|
try {
|
||||||
|
return await fn();
|
||||||
|
} finally {
|
||||||
|
release();
|
||||||
|
if (taskWriteLocks.get(taskPath) === mine) {
|
||||||
|
taskWriteLocks.delete(taskPath);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
export class TeamTaskWriter {
|
export class TeamTaskWriter {
|
||||||
async createTask(teamName: string, task: TeamTask): Promise<void> {
|
async createTask(teamName: string, task: TeamTask): Promise<void> {
|
||||||
|
|
@ -12,32 +33,35 @@ export class TeamTaskWriter {
|
||||||
await fs.promises.mkdir(tasksDir, { recursive: true });
|
await fs.promises.mkdir(tasksDir, { recursive: true });
|
||||||
|
|
||||||
const taskPath = path.join(tasksDir, `${task.id}.json`);
|
const taskPath = path.join(tasksDir, `${task.id}.json`);
|
||||||
try {
|
|
||||||
await fs.promises.access(taskPath, fs.constants.F_OK);
|
await withTaskLock(taskPath, async () => {
|
||||||
throw new Error(`Task already exists: ${task.id}`);
|
try {
|
||||||
} catch (error) {
|
await fs.promises.access(taskPath, fs.constants.F_OK);
|
||||||
if ((error as NodeJS.ErrnoException).code !== 'ENOENT') {
|
throw new Error(`Task already exists: ${task.id}`);
|
||||||
throw error;
|
} catch (error) {
|
||||||
|
if ((error as NodeJS.ErrnoException).code !== 'ENOENT') {
|
||||||
|
throw error;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
// Ensure CLI-compatible format: description, blocks, blockedBy are required
|
// Ensure CLI-compatible format: description, blocks, blockedBy are required
|
||||||
// by Claude Code CLI's Zod schema validation (safeParse fails without them)
|
// by Claude Code CLI's Zod schema validation (safeParse fails without them)
|
||||||
const cliCompatibleTask: TeamTask = {
|
const cliCompatibleTask: TeamTask = {
|
||||||
...task,
|
...task,
|
||||||
description: task.description ?? '',
|
description: task.description ?? '',
|
||||||
blocks: task.blocks ?? [],
|
blocks: task.blocks ?? [],
|
||||||
blockedBy: task.blockedBy ?? [],
|
blockedBy: task.blockedBy ?? [],
|
||||||
createdAt: task.createdAt ?? new Date().toISOString(),
|
createdAt: task.createdAt ?? new Date().toISOString(),
|
||||||
};
|
};
|
||||||
|
|
||||||
await atomicWriteAsync(taskPath, JSON.stringify(cliCompatibleTask, null, 2));
|
await atomicWriteAsync(taskPath, JSON.stringify(cliCompatibleTask, null, 2));
|
||||||
|
|
||||||
const verifyRaw = await fs.promises.readFile(taskPath, 'utf8');
|
const verifyRaw = await fs.promises.readFile(taskPath, 'utf8');
|
||||||
const verifyTask = JSON.parse(verifyRaw) as TeamTask;
|
const verifyTask = JSON.parse(verifyRaw) as TeamTask;
|
||||||
if (verifyTask.id !== task.id) {
|
if (verifyTask.id !== task.id) {
|
||||||
throw new Error(`Task create verification failed: ${task.id}`);
|
throw new Error(`Task create verification failed: ${task.id}`);
|
||||||
}
|
}
|
||||||
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
async addBlocksEntry(
|
async addBlocksEntry(
|
||||||
|
|
@ -47,45 +71,78 @@ export class TeamTaskWriter {
|
||||||
): Promise<void> {
|
): Promise<void> {
|
||||||
const taskPath = path.join(getTasksBasePath(), teamName, `${targetTaskId}.json`);
|
const taskPath = path.join(getTasksBasePath(), teamName, `${targetTaskId}.json`);
|
||||||
|
|
||||||
let raw: string;
|
await withTaskLock(taskPath, async () => {
|
||||||
try {
|
let raw: string;
|
||||||
raw = await fs.promises.readFile(taskPath, 'utf8');
|
try {
|
||||||
} catch (error) {
|
raw = await fs.promises.readFile(taskPath, 'utf8');
|
||||||
if ((error as NodeJS.ErrnoException).code === 'ENOENT') {
|
} catch (error) {
|
||||||
return; // Target task doesn't exist — skip silently
|
if ((error as NodeJS.ErrnoException).code === 'ENOENT') {
|
||||||
|
return; // Target task doesn't exist — skip silently
|
||||||
|
}
|
||||||
|
throw error;
|
||||||
}
|
}
|
||||||
throw error;
|
|
||||||
}
|
|
||||||
|
|
||||||
const task = JSON.parse(raw) as TeamTask;
|
const task = JSON.parse(raw) as TeamTask;
|
||||||
const blocks = task.blocks ?? [];
|
const blocks = task.blocks ?? [];
|
||||||
if (!blocks.includes(blockedTaskId)) {
|
if (!blocks.includes(blockedTaskId)) {
|
||||||
task.blocks = [...blocks, blockedTaskId];
|
task.blocks = [...blocks, blockedTaskId];
|
||||||
await atomicWriteAsync(taskPath, JSON.stringify(task, null, 2));
|
await atomicWriteAsync(taskPath, JSON.stringify(task, null, 2));
|
||||||
}
|
}
|
||||||
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
async updateStatus(teamName: string, taskId: string, status: TeamTaskStatus): Promise<void> {
|
async updateStatus(teamName: string, taskId: string, status: TeamTaskStatus): Promise<void> {
|
||||||
const taskPath = path.join(getTasksBasePath(), teamName, `${taskId}.json`);
|
const taskPath = path.join(getTasksBasePath(), teamName, `${taskId}.json`);
|
||||||
|
|
||||||
let raw: string;
|
await withTaskLock(taskPath, async () => {
|
||||||
try {
|
let raw: string;
|
||||||
raw = await fs.promises.readFile(taskPath, 'utf8');
|
try {
|
||||||
} catch (error) {
|
raw = await fs.promises.readFile(taskPath, 'utf8');
|
||||||
if ((error as NodeJS.ErrnoException).code === 'ENOENT') {
|
} catch (error) {
|
||||||
throw new Error(`Task not found: ${taskId}`);
|
if ((error as NodeJS.ErrnoException).code === 'ENOENT') {
|
||||||
|
throw new Error(`Task not found: ${taskId}`);
|
||||||
|
}
|
||||||
|
throw error;
|
||||||
}
|
}
|
||||||
throw error;
|
|
||||||
}
|
|
||||||
|
|
||||||
const task = JSON.parse(raw) as TeamTask;
|
const task = JSON.parse(raw) as TeamTask;
|
||||||
task.status = status;
|
task.status = status;
|
||||||
await atomicWriteAsync(taskPath, JSON.stringify(task, null, 2));
|
await atomicWriteAsync(taskPath, JSON.stringify(task, null, 2));
|
||||||
|
|
||||||
const verifyRaw = await fs.promises.readFile(taskPath, 'utf8');
|
const verifyRaw = await fs.promises.readFile(taskPath, 'utf8');
|
||||||
const verifyTask = JSON.parse(verifyRaw) as TeamTask;
|
const verifyTask = JSON.parse(verifyRaw) as TeamTask;
|
||||||
if (verifyTask.status !== status) {
|
if (verifyTask.status !== status) {
|
||||||
throw new Error(`Task status update verification failed: ${taskId}`);
|
throw new Error(`Task status update verification failed: ${taskId}`);
|
||||||
}
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
async addComment(teamName: string, taskId: string, text: string): Promise<TaskComment> {
|
||||||
|
const taskPath = path.join(getTasksBasePath(), teamName, `${taskId}.json`);
|
||||||
|
const comment: TaskComment = {
|
||||||
|
id: randomUUID(),
|
||||||
|
author: 'user',
|
||||||
|
text,
|
||||||
|
createdAt: new Date().toISOString(),
|
||||||
|
};
|
||||||
|
|
||||||
|
await withTaskLock(taskPath, async () => {
|
||||||
|
const raw = await fs.promises.readFile(taskPath, 'utf8');
|
||||||
|
const task = JSON.parse(raw) as Record<string, unknown>;
|
||||||
|
const existing = Array.isArray(task.comments) ? (task.comments as TaskComment[]) : [];
|
||||||
|
task.comments = [...existing, comment];
|
||||||
|
await atomicWriteAsync(taskPath, JSON.stringify(task, null, 2));
|
||||||
|
|
||||||
|
const verifyRaw = await fs.promises.readFile(taskPath, 'utf8');
|
||||||
|
const verified = JSON.parse(verifyRaw) as Record<string, unknown>;
|
||||||
|
const verifiedComments = Array.isArray(verified.comments)
|
||||||
|
? (verified.comments as TaskComment[])
|
||||||
|
: [];
|
||||||
|
if (!verifiedComments.some((c) => c.id === comment.id)) {
|
||||||
|
throw new Error(`Comment write verification failed for task: ${taskId}`);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
return comment;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -247,3 +247,6 @@ export const TEAM_START_TASK = 'team:startTask';
|
||||||
|
|
||||||
/** Get all tasks across all teams */
|
/** Get all tasks across all teams */
|
||||||
export const TEAM_GET_ALL_TASKS = 'team:getAllTasks';
|
export const TEAM_GET_ALL_TASKS = 'team:getAllTasks';
|
||||||
|
|
||||||
|
/** Add a comment to a task */
|
||||||
|
export const TEAM_ADD_TASK_COMMENT = 'team:addTaskComment';
|
||||||
|
|
|
||||||
|
|
@ -18,6 +18,7 @@ import {
|
||||||
SSH_SAVE_LAST_CONNECTION,
|
SSH_SAVE_LAST_CONNECTION,
|
||||||
SSH_STATUS,
|
SSH_STATUS,
|
||||||
SSH_TEST,
|
SSH_TEST,
|
||||||
|
TEAM_ADD_TASK_COMMENT,
|
||||||
TEAM_ALIVE_LIST,
|
TEAM_ALIVE_LIST,
|
||||||
TEAM_CANCEL_PROVISIONING,
|
TEAM_CANCEL_PROVISIONING,
|
||||||
TEAM_CHANGE,
|
TEAM_CHANGE,
|
||||||
|
|
@ -99,6 +100,7 @@ import type {
|
||||||
SshConnectionConfig,
|
SshConnectionConfig,
|
||||||
SshConnectionStatus,
|
SshConnectionStatus,
|
||||||
SshLastConnection,
|
SshLastConnection,
|
||||||
|
TaskComment,
|
||||||
TeamChangeEvent,
|
TeamChangeEvent,
|
||||||
TeamConfig,
|
TeamConfig,
|
||||||
TeamCreateConfigRequest,
|
TeamCreateConfigRequest,
|
||||||
|
|
@ -567,6 +569,9 @@ const electronAPI: ElectronAPI = {
|
||||||
updateConfig: async (teamName: string, updates: TeamUpdateConfigRequest) => {
|
updateConfig: async (teamName: string, updates: TeamUpdateConfigRequest) => {
|
||||||
return invokeIpcWithResult<TeamConfig>(TEAM_UPDATE_CONFIG, teamName, updates);
|
return invokeIpcWithResult<TeamConfig>(TEAM_UPDATE_CONFIG, teamName, updates);
|
||||||
},
|
},
|
||||||
|
addTaskComment: async (teamName: string, taskId: string, text: string) => {
|
||||||
|
return invokeIpcWithResult<TaskComment>(TEAM_ADD_TASK_COMMENT, teamName, taskId, text);
|
||||||
|
},
|
||||||
onTeamChange: (callback: (event: unknown, data: TeamChangeEvent) => void): (() => void) => {
|
onTeamChange: (callback: (event: unknown, data: TeamChangeEvent) => void): (() => void) => {
|
||||||
ipcRenderer.on(
|
ipcRenderer.on(
|
||||||
TEAM_CHANGE,
|
TEAM_CHANGE,
|
||||||
|
|
|
||||||
|
|
@ -712,6 +712,9 @@ export class HttpAPIClient implements ElectronAPI {
|
||||||
updateConfig: async () => {
|
updateConfig: async () => {
|
||||||
throw new Error('Team config update is not available in browser mode');
|
throw new Error('Team config update is not available in browser mode');
|
||||||
},
|
},
|
||||||
|
addTaskComment: async () => {
|
||||||
|
throw new Error('Task comments are not available in browser mode');
|
||||||
|
},
|
||||||
onTeamChange: (callback: (event: unknown, data: TeamChangeEvent) => void): (() => void) => {
|
onTeamChange: (callback: (event: unknown, data: TeamChangeEvent) => void): (() => void) => {
|
||||||
return this.addEventListener('team-change', (data: unknown) =>
|
return this.addEventListener('team-change', (data: unknown) =>
|
||||||
callback(null, data as TeamChangeEvent)
|
callback(null, data as TeamChangeEvent)
|
||||||
|
|
|
||||||
|
|
@ -11,6 +11,11 @@ import React, { useEffect, useMemo, useState } from 'react';
|
||||||
|
|
||||||
import { api } from '@renderer/api';
|
import { api } from '@renderer/api';
|
||||||
import { useStore } from '@renderer/store';
|
import { useStore } from '@renderer/store';
|
||||||
|
import {
|
||||||
|
buildTaskCountsByProject,
|
||||||
|
normalizePath,
|
||||||
|
type TaskStatusCounts,
|
||||||
|
} from '@renderer/utils/pathNormalize';
|
||||||
import { createLogger } from '@shared/utils/logger';
|
import { createLogger } from '@shared/utils/logger';
|
||||||
import { useShallow } from 'zustand/react/shallow';
|
import { useShallow } from 'zustand/react/shallow';
|
||||||
|
|
||||||
|
|
@ -97,6 +102,7 @@ interface RepositoryCardProps {
|
||||||
repo: RepositoryGroup;
|
repo: RepositoryGroup;
|
||||||
onClick: () => void;
|
onClick: () => void;
|
||||||
isHighlighted?: boolean;
|
isHighlighted?: boolean;
|
||||||
|
taskCounts?: TaskStatusCounts;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
@ -140,6 +146,7 @@ const RepositoryCard = ({
|
||||||
repo,
|
repo,
|
||||||
onClick,
|
onClick,
|
||||||
isHighlighted,
|
isHighlighted,
|
||||||
|
taskCounts,
|
||||||
}: Readonly<RepositoryCardProps>): React.JSX.Element => {
|
}: Readonly<RepositoryCardProps>): React.JSX.Element => {
|
||||||
const lastActivity = repo.mostRecentSession
|
const lastActivity = repo.mostRecentSession
|
||||||
? formatDistanceToNow(new Date(repo.mostRecentSession), { addSuffix: true })
|
? formatDistanceToNow(new Date(repo.mostRecentSession), { addSuffix: true })
|
||||||
|
|
@ -155,14 +162,14 @@ const RepositoryCard = ({
|
||||||
return (
|
return (
|
||||||
<button
|
<button
|
||||||
onClick={onClick}
|
onClick={onClick}
|
||||||
className={`group relative flex min-h-[120px] flex-col overflow-hidden rounded-sm border p-4 text-left transition-all duration-300 ${
|
className={`group relative flex min-h-[120px] flex-col overflow-hidden rounded-lg border p-4 text-left transition-all duration-300 ${
|
||||||
isHighlighted
|
isHighlighted
|
||||||
? 'border-border-emphasis bg-surface-raised'
|
? 'border-border-emphasis bg-surface-raised'
|
||||||
: 'bg-surface/50 border-border hover:border-border-emphasis hover:bg-surface-raised'
|
: 'bg-surface/50 border-border hover:border-border-emphasis hover:bg-surface-raised'
|
||||||
} `}
|
} `}
|
||||||
>
|
>
|
||||||
{/* Icon with subtle border */}
|
{/* Icon with subtle border */}
|
||||||
<div className="mb-3 flex size-8 items-center justify-center rounded-sm border border-border bg-surface-overlay transition-colors duration-300 group-hover:border-border-emphasis">
|
<div className="mb-3 flex size-8 items-center justify-center rounded-md border border-border bg-surface-overlay transition-colors duration-300 group-hover:border-border-emphasis">
|
||||||
<FolderGit2 className="size-4 text-text-secondary transition-colors group-hover:text-text" />
|
<FolderGit2 className="size-4 text-text-secondary transition-colors group-hover:text-text" />
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
|
|
@ -183,6 +190,27 @@ const RepositoryCard = ({
|
||||||
</span>
|
</span>
|
||||||
)}
|
)}
|
||||||
<span className="text-[10px] text-text-secondary">{repo.totalSessions} sessions</span>
|
<span className="text-[10px] text-text-secondary">{repo.totalSessions} sessions</span>
|
||||||
|
{taskCounts &&
|
||||||
|
(taskCounts.pending > 0 || taskCounts.inProgress > 0 || taskCounts.completed > 0) && (
|
||||||
|
<>
|
||||||
|
<span className="text-text-muted">·</span>
|
||||||
|
{taskCounts.inProgress > 0 && (
|
||||||
|
<span className="inline-flex items-center rounded-full bg-blue-500/15 px-1.5 py-0.5 text-[10px] font-medium text-blue-400">
|
||||||
|
{taskCounts.inProgress} active
|
||||||
|
</span>
|
||||||
|
)}
|
||||||
|
{taskCounts.pending > 0 && (
|
||||||
|
<span className="inline-flex items-center rounded-full bg-yellow-500/15 px-1.5 py-0.5 text-[10px] font-medium text-yellow-400">
|
||||||
|
{taskCounts.pending} pending
|
||||||
|
</span>
|
||||||
|
)}
|
||||||
|
{taskCounts.completed > 0 && (
|
||||||
|
<span className="inline-flex items-center rounded-full bg-green-500/15 px-1.5 py-0.5 text-[10px] font-medium text-green-400">
|
||||||
|
{taskCounts.completed} done
|
||||||
|
</span>
|
||||||
|
)}
|
||||||
|
</>
|
||||||
|
)}
|
||||||
<span className="text-text-muted">·</span>
|
<span className="text-text-muted">·</span>
|
||||||
<span className="text-[10px] text-text-muted">{lastActivity}</span>
|
<span className="text-[10px] text-text-muted">{lastActivity}</span>
|
||||||
</div>
|
</div>
|
||||||
|
|
@ -233,11 +261,11 @@ const NewProjectCard = (): React.JSX.Element => {
|
||||||
|
|
||||||
return (
|
return (
|
||||||
<button
|
<button
|
||||||
className="hover:bg-surface/30 group relative flex min-h-[120px] flex-col items-center justify-center rounded-sm border border-dashed border-border bg-transparent p-4 transition-all duration-300 hover:border-border-emphasis"
|
className="hover:bg-surface/30 group relative flex min-h-[120px] flex-col items-center justify-center rounded-lg border border-dashed border-border bg-transparent p-4 transition-all duration-300 hover:border-border-emphasis"
|
||||||
onClick={handleClick}
|
onClick={handleClick}
|
||||||
title="Select a project folder"
|
title="Select a project folder"
|
||||||
>
|
>
|
||||||
<div className="mb-2 flex size-8 items-center justify-center rounded-sm border border-dashed border-border transition-colors duration-300 group-hover:border-border-emphasis">
|
<div className="mb-2 flex size-8 items-center justify-center rounded-md border border-dashed border-border transition-colors duration-300 group-hover:border-border-emphasis">
|
||||||
<FolderOpen className="size-4 text-text-muted transition-colors group-hover:text-text-secondary" />
|
<FolderOpen className="size-4 text-text-muted transition-colors group-hover:text-text-secondary" />
|
||||||
</div>
|
</div>
|
||||||
<span className="text-xs text-text-muted transition-colors group-hover:text-text-secondary">
|
<span className="text-xs text-text-muted transition-colors group-hover:text-text-secondary">
|
||||||
|
|
@ -260,21 +288,34 @@ const ProjectsGrid = ({
|
||||||
searchQuery,
|
searchQuery,
|
||||||
maxProjects = 12,
|
maxProjects = 12,
|
||||||
}: Readonly<ProjectsGridProps>): React.JSX.Element => {
|
}: Readonly<ProjectsGridProps>): React.JSX.Element => {
|
||||||
const { repositoryGroups, repositoryGroupsLoading, fetchRepositoryGroups, selectRepository } =
|
const {
|
||||||
useStore(
|
repositoryGroups,
|
||||||
useShallow((s) => ({
|
repositoryGroupsLoading,
|
||||||
repositoryGroups: s.repositoryGroups,
|
fetchRepositoryGroups,
|
||||||
repositoryGroupsLoading: s.repositoryGroupsLoading,
|
selectRepository,
|
||||||
fetchRepositoryGroups: s.fetchRepositoryGroups,
|
globalTasks,
|
||||||
selectRepository: s.selectRepository,
|
fetchAllTasks,
|
||||||
}))
|
openTeamsTab,
|
||||||
);
|
} = useStore(
|
||||||
|
useShallow((s) => ({
|
||||||
|
repositoryGroups: s.repositoryGroups,
|
||||||
|
repositoryGroupsLoading: s.repositoryGroupsLoading,
|
||||||
|
fetchRepositoryGroups: s.fetchRepositoryGroups,
|
||||||
|
selectRepository: s.selectRepository,
|
||||||
|
globalTasks: s.globalTasks,
|
||||||
|
fetchAllTasks: s.fetchAllTasks,
|
||||||
|
openTeamsTab: s.openTeamsTab,
|
||||||
|
}))
|
||||||
|
);
|
||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
if (repositoryGroups.length === 0) {
|
if (repositoryGroups.length === 0) {
|
||||||
void fetchRepositoryGroups();
|
void fetchRepositoryGroups();
|
||||||
}
|
}
|
||||||
}, [repositoryGroups.length, fetchRepositoryGroups]);
|
void fetchAllTasks();
|
||||||
|
}, [repositoryGroups.length, fetchRepositoryGroups, fetchAllTasks]);
|
||||||
|
|
||||||
|
const taskCountsMap = useMemo(() => buildTaskCountsByProject(globalTasks), [globalTasks]);
|
||||||
|
|
||||||
// Filter projects based on search query
|
// Filter projects based on search query
|
||||||
const filteredRepos = useMemo(() => {
|
const filteredRepos = useMemo(() => {
|
||||||
|
|
@ -375,14 +416,32 @@ const ProjectsGrid = ({
|
||||||
|
|
||||||
return (
|
return (
|
||||||
<div className="grid grid-cols-2 gap-3 lg:grid-cols-3 xl:grid-cols-4">
|
<div className="grid grid-cols-2 gap-3 lg:grid-cols-3 xl:grid-cols-4">
|
||||||
{filteredRepos.map((repo) => (
|
{filteredRepos.map((repo) => {
|
||||||
<RepositoryCard
|
const counts = repo.worktrees.reduce(
|
||||||
key={repo.id}
|
(acc, wt) => {
|
||||||
repo={repo}
|
const c = taskCountsMap.get(normalizePath(wt.path));
|
||||||
onClick={() => selectRepository(repo.id)}
|
if (c) {
|
||||||
isHighlighted={!!searchQuery.trim()}
|
acc.pending += c.pending;
|
||||||
/>
|
acc.inProgress += c.inProgress;
|
||||||
))}
|
acc.completed += c.completed;
|
||||||
|
}
|
||||||
|
return acc;
|
||||||
|
},
|
||||||
|
{ pending: 0, inProgress: 0, completed: 0 }
|
||||||
|
);
|
||||||
|
return (
|
||||||
|
<RepositoryCard
|
||||||
|
key={repo.id}
|
||||||
|
repo={repo}
|
||||||
|
onClick={() => {
|
||||||
|
selectRepository(repo.id);
|
||||||
|
openTeamsTab();
|
||||||
|
}}
|
||||||
|
isHighlighted={!!searchQuery.trim()}
|
||||||
|
taskCounts={counts}
|
||||||
|
/>
|
||||||
|
);
|
||||||
|
})}
|
||||||
{!searchQuery.trim() && <NewProjectCard />}
|
{!searchQuery.trim() && <NewProjectCard />}
|
||||||
</div>
|
</div>
|
||||||
);
|
);
|
||||||
|
|
|
||||||
|
|
@ -1,6 +1,7 @@
|
||||||
import { useEffect, useMemo, useRef, useState } from 'react';
|
import { useEffect, useMemo, useRef, useState } from 'react';
|
||||||
|
|
||||||
import { useStore } from '@renderer/store';
|
import { useStore } from '@renderer/store';
|
||||||
|
import { normalizePath } from '@renderer/utils/pathNormalize';
|
||||||
import { getNonEmptyTaskCategories, groupTasksByDate } from '@renderer/utils/taskGrouping';
|
import { getNonEmptyTaskCategories, groupTasksByDate } from '@renderer/utils/taskGrouping';
|
||||||
import { ListTodo, Search, X } from 'lucide-react';
|
import { ListTodo, Search, X } from 'lucide-react';
|
||||||
import { useShallow } from 'zustand/react/shallow';
|
import { useShallow } from 'zustand/react/shallow';
|
||||||
|
|
@ -22,10 +23,6 @@ const dateCategoryLabels: Record<string, string> = {
|
||||||
Older: 'Earlier',
|
Older: 'Earlier',
|
||||||
};
|
};
|
||||||
|
|
||||||
function normalizePath(p: string): string {
|
|
||||||
return p.endsWith('/') ? p.slice(0, -1) : p;
|
|
||||||
}
|
|
||||||
|
|
||||||
function applyFilter(tasks: GlobalTask[], filter: StatusFilter): GlobalTask[] {
|
function applyFilter(tasks: GlobalTask[], filter: StatusFilter): GlobalTask[] {
|
||||||
if (filter === 'all') return tasks;
|
if (filter === 'all') return tasks;
|
||||||
if (filter === 'active')
|
if (filter === 'active')
|
||||||
|
|
|
||||||
|
|
@ -655,6 +655,7 @@ export const TeamDetailView = ({ teamName }: TeamDetailViewProps): React.JSX.Ele
|
||||||
teamName={teamName}
|
teamName={teamName}
|
||||||
members={data.members}
|
members={data.members}
|
||||||
tasks={data.tasks}
|
tasks={data.tasks}
|
||||||
|
isTeamAlive={data.isAlive}
|
||||||
defaultSubject={createTaskDialog.defaultSubject}
|
defaultSubject={createTaskDialog.defaultSubject}
|
||||||
defaultDescription={createTaskDialog.defaultDescription}
|
defaultDescription={createTaskDialog.defaultDescription}
|
||||||
defaultOwner={createTaskDialog.defaultOwner}
|
defaultOwner={createTaskDialog.defaultOwner}
|
||||||
|
|
|
||||||
|
|
@ -6,6 +6,7 @@ import { Button } from '@renderer/components/ui/button';
|
||||||
import { Input } from '@renderer/components/ui/input';
|
import { Input } from '@renderer/components/ui/input';
|
||||||
import { getTeamColorSet } from '@renderer/constants/teamColors';
|
import { getTeamColorSet } from '@renderer/constants/teamColors';
|
||||||
import { useStore } from '@renderer/store';
|
import { useStore } from '@renderer/store';
|
||||||
|
import { buildTaskCountsByTeam, normalizePath } from '@renderer/utils/pathNormalize';
|
||||||
import { Copy, FolderOpen, Search, Trash2 } from 'lucide-react';
|
import { Copy, FolderOpen, Search, Trash2 } from 'lucide-react';
|
||||||
import { useShallow } from 'zustand/react/shallow';
|
import { useShallow } from 'zustand/react/shallow';
|
||||||
|
|
||||||
|
|
@ -91,7 +92,18 @@ export const TeamListView = (): React.JSX.Element => {
|
||||||
const [copyData, setCopyData] = useState<TeamCopyData | null>(null);
|
const [copyData, setCopyData] = useState<TeamCopyData | null>(null);
|
||||||
const [searchQuery, setSearchQuery] = useState('');
|
const [searchQuery, setSearchQuery] = useState('');
|
||||||
const [aliveTeams, setAliveTeams] = useState<string[]>([]);
|
const [aliveTeams, setAliveTeams] = useState<string[]>([]);
|
||||||
const { teams, teamsLoading, teamsError, fetchTeams, openTeamTab, deleteTeam } = useStore(
|
const {
|
||||||
|
teams,
|
||||||
|
teamsLoading,
|
||||||
|
teamsError,
|
||||||
|
fetchTeams,
|
||||||
|
openTeamTab,
|
||||||
|
deleteTeam,
|
||||||
|
selectedProjectId,
|
||||||
|
projects,
|
||||||
|
globalTasks,
|
||||||
|
fetchAllTasks,
|
||||||
|
} = useStore(
|
||||||
useShallow((s) => ({
|
useShallow((s) => ({
|
||||||
teams: s.teams,
|
teams: s.teams,
|
||||||
teamsLoading: s.teamsLoading,
|
teamsLoading: s.teamsLoading,
|
||||||
|
|
@ -99,6 +111,10 @@ export const TeamListView = (): React.JSX.Element => {
|
||||||
fetchTeams: s.fetchTeams,
|
fetchTeams: s.fetchTeams,
|
||||||
openTeamTab: s.openTeamTab,
|
openTeamTab: s.openTeamTab,
|
||||||
deleteTeam: s.deleteTeam,
|
deleteTeam: s.deleteTeam,
|
||||||
|
selectedProjectId: s.selectedProjectId,
|
||||||
|
projects: s.projects,
|
||||||
|
globalTasks: s.globalTasks,
|
||||||
|
fetchAllTasks: s.fetchAllTasks,
|
||||||
}))
|
}))
|
||||||
);
|
);
|
||||||
const { connectionMode, createTeam, provisioningError, provisioningRuns } = useStore(
|
const { connectionMode, createTeam, provisioningError, provisioningRuns } = useStore(
|
||||||
|
|
@ -129,16 +145,39 @@ export const TeamListView = (): React.JSX.Element => {
|
||||||
};
|
};
|
||||||
}, [electronMode, teams]);
|
}, [electronMode, teams]);
|
||||||
|
|
||||||
|
const selectedProjectPath = useMemo(() => {
|
||||||
|
if (!selectedProjectId) return null;
|
||||||
|
const project = projects.find((p) => p.id === selectedProjectId);
|
||||||
|
return project ? normalizePath(project.path) : null;
|
||||||
|
}, [selectedProjectId, projects]);
|
||||||
|
|
||||||
const filteredTeams = useMemo<TeamSummary[]>(() => {
|
const filteredTeams = useMemo<TeamSummary[]>(() => {
|
||||||
|
let result = teams;
|
||||||
|
|
||||||
const q = searchQuery.trim().toLowerCase();
|
const q = searchQuery.trim().toLowerCase();
|
||||||
if (!q) return teams;
|
if (q) {
|
||||||
return teams.filter(
|
result = result.filter(
|
||||||
(t) =>
|
(t) =>
|
||||||
t.teamName.toLowerCase().includes(q) ||
|
t.teamName.toLowerCase().includes(q) ||
|
||||||
t.displayName.toLowerCase().includes(q) ||
|
t.displayName.toLowerCase().includes(q) ||
|
||||||
t.description.toLowerCase().includes(q)
|
t.description.toLowerCase().includes(q)
|
||||||
);
|
);
|
||||||
}, [teams, searchQuery]);
|
}
|
||||||
|
|
||||||
|
if (selectedProjectPath) {
|
||||||
|
const matches = (t: TeamSummary): boolean => {
|
||||||
|
if (t.projectPath && normalizePath(t.projectPath) === selectedProjectPath) return true;
|
||||||
|
return t.projectPathHistory?.some((p) => normalizePath(p) === selectedProjectPath) ?? false;
|
||||||
|
};
|
||||||
|
result = [...result].sort((a, b) => {
|
||||||
|
const aMatch = matches(a) ? 0 : 1;
|
||||||
|
const bMatch = matches(b) ? 0 : 1;
|
||||||
|
return aMatch - bMatch;
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
return result;
|
||||||
|
}, [teams, searchQuery, selectedProjectPath]);
|
||||||
|
|
||||||
const handleDeleteTeam = useCallback(
|
const handleDeleteTeam = useCallback(
|
||||||
(teamName: string, e: React.MouseEvent) => {
|
(teamName: string, e: React.MouseEvent) => {
|
||||||
|
|
@ -184,7 +223,10 @@ export const TeamListView = (): React.JSX.Element => {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
void fetchTeams();
|
void fetchTeams();
|
||||||
}, [electronMode, fetchTeams]);
|
void fetchAllTasks();
|
||||||
|
}, [electronMode, fetchTeams, fetchAllTasks]);
|
||||||
|
|
||||||
|
const taskCountsByTeam = useMemo(() => buildTaskCountsByTeam(globalTasks), [globalTasks]);
|
||||||
|
|
||||||
if (!electronMode) {
|
if (!electronMode) {
|
||||||
return (
|
return (
|
||||||
|
|
@ -338,11 +380,11 @@ export const TeamListView = (): React.JSX.Element => {
|
||||||
? { borderLeftWidth: '3px', borderLeftColor: teamColorSet.border }
|
? { borderLeftWidth: '3px', borderLeftColor: teamColorSet.border }
|
||||||
: undefined
|
: undefined
|
||||||
}
|
}
|
||||||
onClick={() => openTeamTab(team.teamName)}
|
onClick={() => openTeamTab(team.teamName, team.projectPath)}
|
||||||
onKeyDown={(e) => {
|
onKeyDown={(e) => {
|
||||||
if (e.key === 'Enter' || e.key === ' ') {
|
if (e.key === 'Enter' || e.key === ' ') {
|
||||||
e.preventDefault();
|
e.preventDefault();
|
||||||
openTeamTab(team.teamName);
|
openTeamTab(team.teamName, team.projectPath);
|
||||||
}
|
}
|
||||||
}}
|
}}
|
||||||
>
|
>
|
||||||
|
|
@ -415,25 +457,51 @@ export const TeamListView = (): React.JSX.Element => {
|
||||||
Members: {team.memberCount}
|
Members: {team.memberCount}
|
||||||
</Badge>
|
</Badge>
|
||||||
)}
|
)}
|
||||||
<Badge variant="secondary" className="text-[10px] font-normal">
|
{(() => {
|
||||||
Tasks: {team.taskCount}
|
const tc = taskCountsByTeam.get(team.teamName);
|
||||||
</Badge>
|
if (!tc || (tc.pending === 0 && tc.inProgress === 0 && tc.completed === 0)) {
|
||||||
|
return (
|
||||||
|
<Badge variant="secondary" className="text-[10px] font-normal">
|
||||||
|
Tasks: 0
|
||||||
|
</Badge>
|
||||||
|
);
|
||||||
|
}
|
||||||
|
return (
|
||||||
|
<>
|
||||||
|
{tc.inProgress > 0 && (
|
||||||
|
<span className="inline-flex items-center rounded-full bg-blue-500/15 px-1.5 py-0.5 text-[10px] font-medium text-blue-400">
|
||||||
|
{tc.inProgress} active
|
||||||
|
</span>
|
||||||
|
)}
|
||||||
|
{tc.pending > 0 && (
|
||||||
|
<span className="inline-flex items-center rounded-full bg-yellow-500/15 px-1.5 py-0.5 text-[10px] font-medium text-yellow-400">
|
||||||
|
{tc.pending} pending
|
||||||
|
</span>
|
||||||
|
)}
|
||||||
|
{tc.completed > 0 && (
|
||||||
|
<span className="inline-flex items-center rounded-full bg-green-500/15 px-1.5 py-0.5 text-[10px] font-medium text-green-400">
|
||||||
|
{tc.completed} done
|
||||||
|
</span>
|
||||||
|
)}
|
||||||
|
</>
|
||||||
|
);
|
||||||
|
})()}
|
||||||
</div>
|
</div>
|
||||||
{(() => {
|
{(() => {
|
||||||
const projects = getRecentProjects(team);
|
const recentPaths = getRecentProjects(team);
|
||||||
if (projects.length === 0) return null;
|
if (recentPaths.length === 0) return null;
|
||||||
return (
|
return (
|
||||||
<div className="mt-2 flex items-center gap-1 text-[10px] text-[var(--color-text-muted)]">
|
<div className="mt-2 flex items-center gap-1 text-[10px] text-[var(--color-text-muted)]">
|
||||||
<FolderOpen size={10} className="shrink-0" />
|
<FolderOpen size={10} className="shrink-0" />
|
||||||
<span className="truncate">
|
<span className="truncate">
|
||||||
{projects.map((p, i) => (
|
{recentPaths.map((p, i) => (
|
||||||
<span key={p} title={p}>
|
<span key={p} title={p}>
|
||||||
{i === 0 && status === 'running' ? (
|
{i === 0 && status === 'running' ? (
|
||||||
<span className="text-emerald-400">{folderName(p)}</span>
|
<span className="text-emerald-400">{folderName(p)}</span>
|
||||||
) : (
|
) : (
|
||||||
folderName(p)
|
folderName(p)
|
||||||
)}
|
)}
|
||||||
{i < projects.length - 1 ? ', ' : ''}
|
{i < recentPaths.length - 1 ? ', ' : ''}
|
||||||
</span>
|
</span>
|
||||||
))}
|
))}
|
||||||
</span>
|
</span>
|
||||||
|
|
|
||||||
|
|
@ -33,6 +33,7 @@ interface CreateTaskDialogProps {
|
||||||
teamName: string;
|
teamName: string;
|
||||||
members: ResolvedTeamMember[];
|
members: ResolvedTeamMember[];
|
||||||
tasks: TeamTask[];
|
tasks: TeamTask[];
|
||||||
|
isTeamAlive?: boolean;
|
||||||
defaultSubject?: string;
|
defaultSubject?: string;
|
||||||
defaultDescription?: string;
|
defaultDescription?: string;
|
||||||
defaultOwner?: string;
|
defaultOwner?: string;
|
||||||
|
|
@ -53,6 +54,7 @@ export const CreateTaskDialog = ({
|
||||||
teamName,
|
teamName,
|
||||||
members,
|
members,
|
||||||
tasks,
|
tasks,
|
||||||
|
isTeamAlive = false,
|
||||||
defaultSubject = '',
|
defaultSubject = '',
|
||||||
defaultDescription = '',
|
defaultDescription = '',
|
||||||
defaultOwner = '',
|
defaultOwner = '',
|
||||||
|
|
@ -78,7 +80,7 @@ export const CreateTaskDialog = ({
|
||||||
}
|
}
|
||||||
setOwner(defaultOwner);
|
setOwner(defaultOwner);
|
||||||
setBlockedBy([]);
|
setBlockedBy([]);
|
||||||
setStartImmediately(true);
|
setStartImmediately(isTeamAlive);
|
||||||
promptDraft.clearDraft();
|
promptDraft.clearDraft();
|
||||||
}
|
}
|
||||||
if (open !== prevOpen) {
|
if (open !== prevOpen) {
|
||||||
|
|
@ -227,15 +229,26 @@ export const CreateTaskDialog = ({
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
{owner ? (
|
{owner ? (
|
||||||
<div className="flex items-center gap-2">
|
<div className="grid gap-1">
|
||||||
<Checkbox
|
<div className="flex items-center gap-2">
|
||||||
id="task-start-immediately"
|
<Checkbox
|
||||||
checked={startImmediately}
|
id="task-start-immediately"
|
||||||
onCheckedChange={(v) => setStartImmediately(v === true)}
|
checked={isTeamAlive ? startImmediately : false}
|
||||||
/>
|
onCheckedChange={(v) => setStartImmediately(v === true)}
|
||||||
<Label htmlFor="task-start-immediately" className="text-xs font-normal">
|
disabled={!isTeamAlive}
|
||||||
Start immediately
|
/>
|
||||||
</Label>
|
<Label
|
||||||
|
htmlFor="task-start-immediately"
|
||||||
|
className={`text-xs font-normal ${!isTeamAlive ? 'text-[var(--color-text-muted)]' : ''}`}
|
||||||
|
>
|
||||||
|
Start immediately
|
||||||
|
</Label>
|
||||||
|
</div>
|
||||||
|
{!isTeamAlive ? (
|
||||||
|
<p className="text-[10px] text-[var(--color-text-muted)]">
|
||||||
|
Team is offline. Launch the team first to start tasks immediately.
|
||||||
|
</p>
|
||||||
|
) : null}
|
||||||
</div>
|
</div>
|
||||||
) : null}
|
) : null}
|
||||||
|
|
||||||
|
|
|
||||||
119
src/renderer/components/team/dialogs/TaskCommentsSection.tsx
Normal file
119
src/renderer/components/team/dialogs/TaskCommentsSection.tsx
Normal file
|
|
@ -0,0 +1,119 @@
|
||||||
|
import { useCallback, useRef, useState } from 'react';
|
||||||
|
|
||||||
|
import { MarkdownViewer } from '@renderer/components/chat/viewers/MarkdownViewer';
|
||||||
|
import { useStore } from '@renderer/store';
|
||||||
|
import { formatDistanceToNow } from 'date-fns';
|
||||||
|
import { MessageSquare, Send } from 'lucide-react';
|
||||||
|
|
||||||
|
import type { TaskComment } from '@shared/types';
|
||||||
|
|
||||||
|
const MAX_COMMENT_LENGTH = 2000;
|
||||||
|
|
||||||
|
interface TaskCommentsSectionProps {
|
||||||
|
teamName: string;
|
||||||
|
taskId: string;
|
||||||
|
comments: TaskComment[];
|
||||||
|
}
|
||||||
|
|
||||||
|
export const TaskCommentsSection = ({
|
||||||
|
teamName,
|
||||||
|
taskId,
|
||||||
|
comments,
|
||||||
|
}: TaskCommentsSectionProps): React.JSX.Element => {
|
||||||
|
const addTaskComment = useStore((s) => s.addTaskComment);
|
||||||
|
const addingComment = useStore((s) => s.addingComment);
|
||||||
|
|
||||||
|
const [text, setText] = useState('');
|
||||||
|
const textareaRef = useRef<HTMLTextAreaElement>(null);
|
||||||
|
|
||||||
|
const trimmed = text.trim();
|
||||||
|
const remaining = MAX_COMMENT_LENGTH - trimmed.length;
|
||||||
|
const canSubmit = trimmed.length > 0 && trimmed.length <= MAX_COMMENT_LENGTH && !addingComment;
|
||||||
|
|
||||||
|
const handleSubmit = useCallback(async () => {
|
||||||
|
if (!canSubmit) return;
|
||||||
|
try {
|
||||||
|
await addTaskComment(teamName, taskId, trimmed);
|
||||||
|
setText('');
|
||||||
|
} catch {
|
||||||
|
// Error is stored in addCommentError via store
|
||||||
|
}
|
||||||
|
}, [canSubmit, addTaskComment, teamName, taskId, trimmed]);
|
||||||
|
|
||||||
|
const handleKeyDown = useCallback(
|
||||||
|
(e: React.KeyboardEvent<HTMLTextAreaElement>) => {
|
||||||
|
if ((e.metaKey || e.ctrlKey) && e.key === 'Enter') {
|
||||||
|
e.preventDefault();
|
||||||
|
void handleSubmit();
|
||||||
|
}
|
||||||
|
},
|
||||||
|
[handleSubmit]
|
||||||
|
);
|
||||||
|
|
||||||
|
return (
|
||||||
|
<div>
|
||||||
|
<div className="mb-2 flex items-center gap-1.5 text-xs font-medium text-[var(--color-text-muted)]">
|
||||||
|
<MessageSquare size={12} />
|
||||||
|
Comments
|
||||||
|
{comments.length > 0 ? (
|
||||||
|
<span className="rounded-full bg-[var(--color-surface-raised)] px-1.5 py-0 text-[10px]">
|
||||||
|
{comments.length}
|
||||||
|
</span>
|
||||||
|
) : null}
|
||||||
|
</div>
|
||||||
|
|
||||||
|
{comments.length > 0 ? (
|
||||||
|
<div className="mb-3 space-y-2">
|
||||||
|
{comments.map((comment) => (
|
||||||
|
<div
|
||||||
|
key={comment.id}
|
||||||
|
className="rounded-md border border-[var(--color-border)] bg-[var(--color-surface)] p-2.5"
|
||||||
|
>
|
||||||
|
<div className="mb-1 flex items-center gap-2 text-[10px] text-[var(--color-text-muted)]">
|
||||||
|
<span className="font-medium text-[var(--color-text-secondary)]">
|
||||||
|
{comment.author}
|
||||||
|
</span>
|
||||||
|
<span>{formatDistanceToNow(new Date(comment.createdAt), { addSuffix: true })}</span>
|
||||||
|
</div>
|
||||||
|
<div className="text-xs">
|
||||||
|
<MarkdownViewer content={comment.text} maxHeight="max-h-[120px]" />
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
))}
|
||||||
|
</div>
|
||||||
|
) : null}
|
||||||
|
|
||||||
|
<div className="space-y-1.5">
|
||||||
|
<textarea
|
||||||
|
ref={textareaRef}
|
||||||
|
className="w-full resize-none rounded-md border border-[var(--color-border)] bg-[var(--color-surface)] p-2 text-xs text-[var(--color-text)] placeholder:text-zinc-500 focus:border-[var(--color-border-emphasis)] focus:outline-none"
|
||||||
|
placeholder="Add a comment... (Cmd+Enter to send)"
|
||||||
|
rows={3}
|
||||||
|
maxLength={MAX_COMMENT_LENGTH}
|
||||||
|
value={text}
|
||||||
|
onChange={(e) => setText(e.target.value)}
|
||||||
|
onKeyDown={handleKeyDown}
|
||||||
|
disabled={addingComment}
|
||||||
|
/>
|
||||||
|
<div className="flex items-center justify-between">
|
||||||
|
<span
|
||||||
|
className={`text-[10px] ${
|
||||||
|
remaining < 100 ? 'text-yellow-400' : 'text-[var(--color-text-muted)]'
|
||||||
|
}`}
|
||||||
|
>
|
||||||
|
{remaining < 200 ? `${remaining} chars remaining` : ''}
|
||||||
|
</span>
|
||||||
|
<button
|
||||||
|
type="button"
|
||||||
|
className="inline-flex items-center gap-1 rounded-md bg-blue-600 px-2.5 py-1 text-[11px] font-medium text-white transition-colors hover:bg-blue-500 disabled:cursor-not-allowed disabled:opacity-50"
|
||||||
|
disabled={!canSubmit}
|
||||||
|
onClick={() => void handleSubmit()}
|
||||||
|
>
|
||||||
|
<Send size={12} />
|
||||||
|
Comment
|
||||||
|
</button>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
);
|
||||||
|
};
|
||||||
|
|
@ -15,6 +15,8 @@ import { TASK_STATUS_LABELS, TASK_STATUS_STYLES } from '@renderer/utils/memberHe
|
||||||
import { formatDistanceToNow } from 'date-fns';
|
import { formatDistanceToNow } from 'date-fns';
|
||||||
import { ArrowLeftFromLine, ArrowRightFromLine, Clock, FileText, User } from 'lucide-react';
|
import { ArrowLeftFromLine, ArrowRightFromLine, Clock, FileText, User } from 'lucide-react';
|
||||||
|
|
||||||
|
import { TaskCommentsSection } from './TaskCommentsSection';
|
||||||
|
|
||||||
import type { KanbanTaskState, TeamTask } from '@shared/types';
|
import type { KanbanTaskState, TeamTask } from '@shared/types';
|
||||||
|
|
||||||
interface TaskDetailDialogProps {
|
interface TaskDetailDialogProps {
|
||||||
|
|
@ -186,6 +188,13 @@ export const TaskDetailDialog = ({
|
||||||
</div>
|
</div>
|
||||||
) : null}
|
) : null}
|
||||||
|
|
||||||
|
{/* Comments */}
|
||||||
|
<TaskCommentsSection
|
||||||
|
teamName={teamName}
|
||||||
|
taskId={currentTask.id}
|
||||||
|
comments={currentTask.comments ?? []}
|
||||||
|
/>
|
||||||
|
|
||||||
{/* Separator */}
|
{/* Separator */}
|
||||||
<div className="border-t border-[var(--color-border)]" />
|
<div className="border-t border-[var(--color-border)]" />
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -12,6 +12,7 @@ import {
|
||||||
findTabBySessionAndProject,
|
findTabBySessionAndProject,
|
||||||
truncateLabel,
|
truncateLabel,
|
||||||
} from '@renderer/types/tabs';
|
} from '@renderer/types/tabs';
|
||||||
|
import { normalizePath } from '@renderer/utils/pathNormalize';
|
||||||
|
|
||||||
import {
|
import {
|
||||||
findPane,
|
findPane,
|
||||||
|
|
@ -371,10 +372,7 @@ export const createTabSlice: StateCreator<AppState, [], [], TabSlice> = (set, ge
|
||||||
const teamData = state.selectedTeamData;
|
const teamData = state.selectedTeamData;
|
||||||
const projectPath = teamData?.config.projectPath;
|
const projectPath = teamData?.config.projectPath;
|
||||||
if (projectPath) {
|
if (projectPath) {
|
||||||
const normalizedTeamPath = projectPath.endsWith('/')
|
const normalizedTeamPath = normalizePath(projectPath);
|
||||||
? projectPath.slice(0, -1)
|
|
||||||
: projectPath;
|
|
||||||
const normalizePath = (p: string): string => (p.endsWith('/') ? p.slice(0, -1) : p);
|
|
||||||
const matchingProject = state.projects.find(
|
const matchingProject = state.projects.find(
|
||||||
(p) => normalizePath(p.path) === normalizedTeamPath
|
(p) => normalizePath(p.path) === normalizedTeamPath
|
||||||
);
|
);
|
||||||
|
|
|
||||||
|
|
@ -1,4 +1,5 @@
|
||||||
import { api } from '@renderer/api';
|
import { api } from '@renderer/api';
|
||||||
|
import { normalizePath } from '@renderer/utils/pathNormalize';
|
||||||
import { IpcError, unwrapIpc } from '@renderer/utils/unwrapIpc';
|
import { IpcError, unwrapIpc } from '@renderer/utils/unwrapIpc';
|
||||||
|
|
||||||
import type { AppState } from '../types';
|
import type { AppState } from '../types';
|
||||||
|
|
@ -7,6 +8,7 @@ import type {
|
||||||
GlobalTask,
|
GlobalTask,
|
||||||
SendMessageRequest,
|
SendMessageRequest,
|
||||||
SendMessageResult,
|
SendMessageResult,
|
||||||
|
TaskComment,
|
||||||
TeamCreateRequest,
|
TeamCreateRequest,
|
||||||
TeamData,
|
TeamData,
|
||||||
TeamLaunchRequest,
|
TeamLaunchRequest,
|
||||||
|
|
@ -69,6 +71,9 @@ export interface TeamSlice {
|
||||||
createTeamTask: (teamName: string, request: CreateTaskRequest) => Promise<TeamTask>;
|
createTeamTask: (teamName: string, request: CreateTaskRequest) => Promise<TeamTask>;
|
||||||
startTask: (teamName: string, taskId: string) => Promise<void>;
|
startTask: (teamName: string, taskId: string) => Promise<void>;
|
||||||
updateTaskStatus: (teamName: string, taskId: string, status: TeamTaskStatus) => Promise<void>;
|
updateTaskStatus: (teamName: string, taskId: string, status: TeamTaskStatus) => Promise<void>;
|
||||||
|
addingComment: boolean;
|
||||||
|
addCommentError: string | null;
|
||||||
|
addTaskComment: (teamName: string, taskId: string, text: string) => Promise<TaskComment>;
|
||||||
deleteTeam: (teamName: string) => Promise<void>;
|
deleteTeam: (teamName: string) => Promise<void>;
|
||||||
createTeam: (request: TeamCreateRequest) => Promise<string>;
|
createTeam: (request: TeamCreateRequest) => Promise<string>;
|
||||||
launchTeam: (request: TeamLaunchRequest) => Promise<string>;
|
launchTeam: (request: TeamLaunchRequest) => Promise<string>;
|
||||||
|
|
@ -98,6 +103,8 @@ export const createTeamSlice: StateCreator<AppState, [], [], TeamSlice> = (set,
|
||||||
activeProvisioningRunId: null,
|
activeProvisioningRunId: null,
|
||||||
provisioningError: null,
|
provisioningError: null,
|
||||||
kanbanFilterQuery: null,
|
kanbanFilterQuery: null,
|
||||||
|
addingComment: false,
|
||||||
|
addCommentError: null,
|
||||||
provisioningProgressUnsubscribe: null,
|
provisioningProgressUnsubscribe: null,
|
||||||
|
|
||||||
fetchTeams: async () => {
|
fetchTeams: async () => {
|
||||||
|
|
@ -159,12 +166,13 @@ export const createTeamSlice: StateCreator<AppState, [], [], TeamSlice> = (set,
|
||||||
// If projectPath is provided, immediately select the matching project in the sidebar.
|
// If projectPath is provided, immediately select the matching project in the sidebar.
|
||||||
// This avoids a race condition where config.json hasn't been updated with projectPath yet.
|
// This avoids a race condition where config.json hasn't been updated with projectPath yet.
|
||||||
if (projectPath) {
|
if (projectPath) {
|
||||||
const state = get();
|
const stateForProject = get();
|
||||||
const normalizePath = (p: string): string => (p.endsWith('/') ? p.slice(0, -1) : p);
|
|
||||||
const normalizedPath = normalizePath(projectPath);
|
const normalizedPath = normalizePath(projectPath);
|
||||||
const matchingProject = state.projects.find((p) => normalizePath(p.path) === normalizedPath);
|
const matchingProject = stateForProject.projects.find(
|
||||||
if (matchingProject && state.selectedProjectId !== matchingProject.id) {
|
(p) => normalizePath(p.path) === normalizedPath
|
||||||
state.selectProject(matchingProject.id);
|
);
|
||||||
|
if (matchingProject && stateForProject.selectedProjectId !== matchingProject.id) {
|
||||||
|
stateForProject.selectProject(matchingProject.id);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -217,11 +225,7 @@ export const createTeamSlice: StateCreator<AppState, [], [], TeamSlice> = (set,
|
||||||
const projectPath = data.config.projectPath;
|
const projectPath = data.config.projectPath;
|
||||||
if (projectPath) {
|
if (projectPath) {
|
||||||
const state = get();
|
const state = get();
|
||||||
const normalizedTeamPath = projectPath.endsWith('/')
|
const normalizedTeamPath = normalizePath(projectPath);
|
||||||
? projectPath.slice(0, -1)
|
|
||||||
: projectPath;
|
|
||||||
|
|
||||||
const normalizePath = (p: string): string => (p.endsWith('/') ? p.slice(0, -1) : p);
|
|
||||||
|
|
||||||
// 1. Try flat projects list
|
// 1. Try flat projects list
|
||||||
const matchingProject = state.projects.find(
|
const matchingProject = state.projects.find(
|
||||||
|
|
@ -374,6 +378,22 @@ export const createTeamSlice: StateCreator<AppState, [], [], TeamSlice> = (set,
|
||||||
await get().refreshTeamData(teamName);
|
await get().refreshTeamData(teamName);
|
||||||
},
|
},
|
||||||
|
|
||||||
|
addTaskComment: async (teamName, taskId, text) => {
|
||||||
|
set({ addingComment: true, addCommentError: null });
|
||||||
|
try {
|
||||||
|
const comment = await unwrapIpc('team:addTaskComment', () =>
|
||||||
|
api.teams.addTaskComment(teamName, taskId, text)
|
||||||
|
);
|
||||||
|
set({ addingComment: false });
|
||||||
|
await get().refreshTeamData(teamName);
|
||||||
|
return comment;
|
||||||
|
} catch (error) {
|
||||||
|
const msg = error instanceof Error ? error.message : 'Failed to add comment';
|
||||||
|
set({ addingComment: false, addCommentError: msg });
|
||||||
|
throw error;
|
||||||
|
}
|
||||||
|
},
|
||||||
|
|
||||||
deleteTeam: async (teamName: string) => {
|
deleteTeam: async (teamName: string) => {
|
||||||
await unwrapIpc('team:deleteTeam', () => api.teams.deleteTeam(teamName));
|
await unwrapIpc('team:deleteTeam', () => api.teams.deleteTeam(teamName));
|
||||||
const state = get();
|
const state = get();
|
||||||
|
|
|
||||||
41
src/renderer/utils/pathNormalize.ts
Normal file
41
src/renderer/utils/pathNormalize.ts
Normal file
|
|
@ -0,0 +1,41 @@
|
||||||
|
import type { GlobalTask } from '@shared/types';
|
||||||
|
|
||||||
|
export function normalizePath(p: string): string {
|
||||||
|
return p.endsWith('/') ? p.slice(0, -1) : p;
|
||||||
|
}
|
||||||
|
|
||||||
|
export interface TaskStatusCounts {
|
||||||
|
pending: number;
|
||||||
|
inProgress: number;
|
||||||
|
completed: number;
|
||||||
|
}
|
||||||
|
|
||||||
|
function incrementStatus(counts: TaskStatusCounts, status: string): TaskStatusCounts {
|
||||||
|
if (status === 'pending') return { ...counts, pending: counts.pending + 1 };
|
||||||
|
if (status === 'in_progress') return { ...counts, inProgress: counts.inProgress + 1 };
|
||||||
|
if (status === 'completed') return { ...counts, completed: counts.completed + 1 };
|
||||||
|
return counts;
|
||||||
|
}
|
||||||
|
|
||||||
|
/** Build a map of normalized project path -> task status counts */
|
||||||
|
export function buildTaskCountsByProject(tasks: GlobalTask[]): Map<string, TaskStatusCounts> {
|
||||||
|
const map = new Map<string, TaskStatusCounts>();
|
||||||
|
for (const task of tasks) {
|
||||||
|
if (!task.projectPath) continue;
|
||||||
|
const key = normalizePath(task.projectPath);
|
||||||
|
const counts = map.get(key) ?? { pending: 0, inProgress: 0, completed: 0 };
|
||||||
|
map.set(key, incrementStatus(counts, task.status));
|
||||||
|
}
|
||||||
|
return map;
|
||||||
|
}
|
||||||
|
|
||||||
|
/** Build a map of team name -> task status counts */
|
||||||
|
export function buildTaskCountsByTeam(tasks: GlobalTask[]): Map<string, TaskStatusCounts> {
|
||||||
|
const map = new Map<string, TaskStatusCounts>();
|
||||||
|
for (const task of tasks) {
|
||||||
|
const key = task.teamName;
|
||||||
|
const counts = map.get(key) ?? { pending: 0, inProgress: 0, completed: 0 };
|
||||||
|
map.set(key, incrementStatus(counts, task.status));
|
||||||
|
}
|
||||||
|
return map;
|
||||||
|
}
|
||||||
|
|
@ -20,6 +20,7 @@ import type {
|
||||||
MemberLogSummary,
|
MemberLogSummary,
|
||||||
SendMessageRequest,
|
SendMessageRequest,
|
||||||
SendMessageResult,
|
SendMessageResult,
|
||||||
|
TaskComment,
|
||||||
TeamChangeEvent,
|
TeamChangeEvent,
|
||||||
TeamConfig,
|
TeamConfig,
|
||||||
TeamCreateConfigRequest,
|
TeamCreateConfigRequest,
|
||||||
|
|
@ -364,6 +365,7 @@ export interface TeamsAPI {
|
||||||
launchTeam: (request: TeamLaunchRequest) => Promise<TeamLaunchResponse>;
|
launchTeam: (request: TeamLaunchRequest) => Promise<TeamLaunchResponse>;
|
||||||
getAllTasks: () => Promise<GlobalTask[]>;
|
getAllTasks: () => Promise<GlobalTask[]>;
|
||||||
updateConfig: (teamName: string, updates: TeamUpdateConfigRequest) => Promise<TeamConfig>;
|
updateConfig: (teamName: string, updates: TeamUpdateConfigRequest) => Promise<TeamConfig>;
|
||||||
|
addTaskComment: (teamName: string, taskId: string, text: string) => Promise<TaskComment>;
|
||||||
onTeamChange: (callback: (event: unknown, data: TeamChangeEvent) => void) => () => void;
|
onTeamChange: (callback: (event: unknown, data: TeamChangeEvent) => void) => () => void;
|
||||||
onProvisioningProgress: (
|
onProvisioningProgress: (
|
||||||
callback: (event: unknown, data: TeamProvisioningProgress) => void
|
callback: (event: unknown, data: TeamProvisioningProgress) => void
|
||||||
|
|
|
||||||
|
|
@ -47,6 +47,13 @@ export interface TeamSummary {
|
||||||
|
|
||||||
export type TeamTaskStatus = 'pending' | 'in_progress' | 'completed' | 'deleted';
|
export type TeamTaskStatus = 'pending' | 'in_progress' | 'completed' | 'deleted';
|
||||||
|
|
||||||
|
export interface TaskComment {
|
||||||
|
id: string;
|
||||||
|
author: string;
|
||||||
|
text: string;
|
||||||
|
createdAt: string;
|
||||||
|
}
|
||||||
|
|
||||||
export interface TeamTask {
|
export interface TeamTask {
|
||||||
id: string;
|
id: string;
|
||||||
subject: string;
|
subject: string;
|
||||||
|
|
@ -58,6 +65,7 @@ export interface TeamTask {
|
||||||
blockedBy?: string[];
|
blockedBy?: string[];
|
||||||
createdAt?: string;
|
createdAt?: string;
|
||||||
projectPath?: string;
|
projectPath?: string;
|
||||||
|
comments?: TaskComment[];
|
||||||
}
|
}
|
||||||
|
|
||||||
export interface InboxMessage {
|
export interface InboxMessage {
|
||||||
|
|
|
||||||
|
|
@ -25,6 +25,7 @@ vi.mock('@preload/constants/ipcChannels', () => ({
|
||||||
TEAM_UPDATE_CONFIG: 'team:updateConfig',
|
TEAM_UPDATE_CONFIG: 'team:updateConfig',
|
||||||
TEAM_START_TASK: 'team:startTask',
|
TEAM_START_TASK: 'team:startTask',
|
||||||
TEAM_GET_ALL_TASKS: 'team:getAllTasks',
|
TEAM_GET_ALL_TASKS: 'team:getAllTasks',
|
||||||
|
TEAM_ADD_TASK_COMMENT: 'team:addTaskComment',
|
||||||
}));
|
}));
|
||||||
|
|
||||||
import {
|
import {
|
||||||
|
|
@ -50,6 +51,7 @@ import {
|
||||||
TEAM_UPDATE_CONFIG,
|
TEAM_UPDATE_CONFIG,
|
||||||
TEAM_UPDATE_KANBAN,
|
TEAM_UPDATE_KANBAN,
|
||||||
TEAM_UPDATE_TASK_STATUS,
|
TEAM_UPDATE_TASK_STATUS,
|
||||||
|
TEAM_ADD_TASK_COMMENT,
|
||||||
} from '../../../src/preload/constants/ipcChannels';
|
} from '../../../src/preload/constants/ipcChannels';
|
||||||
import {
|
import {
|
||||||
initializeTeamHandlers,
|
initializeTeamHandlers,
|
||||||
|
|
@ -78,6 +80,12 @@ describe('ipc teams handlers', () => {
|
||||||
updateKanban: vi.fn(async () => undefined),
|
updateKanban: vi.fn(async () => undefined),
|
||||||
updateTaskStatus: vi.fn(async () => undefined),
|
updateTaskStatus: vi.fn(async () => undefined),
|
||||||
startTask: vi.fn(async () => undefined),
|
startTask: vi.fn(async () => undefined),
|
||||||
|
addTaskComment: vi.fn(async () => ({
|
||||||
|
id: 'c1',
|
||||||
|
author: 'user',
|
||||||
|
text: 'test comment',
|
||||||
|
createdAt: new Date().toISOString(),
|
||||||
|
})),
|
||||||
};
|
};
|
||||||
const provisioningService = {
|
const provisioningService = {
|
||||||
prepareForProvisioning: vi.fn(async () => ({
|
prepareForProvisioning: vi.fn(async () => ({
|
||||||
|
|
@ -130,6 +138,7 @@ describe('ipc teams handlers', () => {
|
||||||
expect(handlers.has(TEAM_GET_MEMBER_STATS)).toBe(true);
|
expect(handlers.has(TEAM_GET_MEMBER_STATS)).toBe(true);
|
||||||
expect(handlers.has(TEAM_UPDATE_CONFIG)).toBe(true);
|
expect(handlers.has(TEAM_UPDATE_CONFIG)).toBe(true);
|
||||||
expect(handlers.has(TEAM_GET_ALL_TASKS)).toBe(true);
|
expect(handlers.has(TEAM_GET_ALL_TASKS)).toBe(true);
|
||||||
|
expect(handlers.has(TEAM_ADD_TASK_COMMENT)).toBe(true);
|
||||||
});
|
});
|
||||||
|
|
||||||
it('returns success false on invalid sendMessage args', async () => {
|
it('returns success false on invalid sendMessage args', async () => {
|
||||||
|
|
@ -297,5 +306,6 @@ describe('ipc teams handlers', () => {
|
||||||
expect(handlers.has(TEAM_GET_MEMBER_STATS)).toBe(false);
|
expect(handlers.has(TEAM_GET_MEMBER_STATS)).toBe(false);
|
||||||
expect(handlers.has(TEAM_UPDATE_CONFIG)).toBe(false);
|
expect(handlers.has(TEAM_UPDATE_CONFIG)).toBe(false);
|
||||||
expect(handlers.has(TEAM_GET_ALL_TASKS)).toBe(false);
|
expect(handlers.has(TEAM_GET_ALL_TASKS)).toBe(false);
|
||||||
|
expect(handlers.has(TEAM_ADD_TASK_COMMENT)).toBe(false);
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue