diff --git a/.cspell/dart_flutter.txt b/.cspell/dart_flutter.txt index 15af3041..0f805067 100644 --- a/.cspell/dart_flutter.txt +++ b/.cspell/dart_flutter.txt @@ -10,4 +10,5 @@ sublist todos unawaited unfocus +videocam writeln diff --git a/.cspell/nextcloud.txt b/.cspell/nextcloud.txt index 0328ec99..7c0d3665 100644 --- a/.cspell/nextcloud.txt +++ b/.cspell/nextcloud.txt @@ -67,6 +67,7 @@ trashbin turnservers undelete unifiedpush +unmute unsharing unstar updatenotification diff --git a/.cspell/tools.txt b/.cspell/tools.txt index 42c7fde6..0854cbd3 100644 --- a/.cspell/tools.txt +++ b/.cspell/tools.txt @@ -66,6 +66,7 @@ strfreev subprojects sysroot tsvg +webrtc werror workdir xxxh diff --git a/README.md b/README.md index c1735349..6eafda2b 100644 --- a/README.md +++ b/README.md @@ -54,12 +54,12 @@ See [here](packages/app/README.md) for screenshots. | [News](packages/neon/neon_news) | :heavy_check_mark: | | [Notes](packages/neon/neon_notes) | :heavy_check_mark: | | [Notifications](packages/neon/neon_notifications) | :heavy_check_mark: | +| [Talk](packages/neon/neon_spreed) | :heavy_check_mark: | | Activity | :rocket: | | Calendar | :rocket: | | Contacts | :rocket: | | Cookbook | :rocket: | | Photos | :rocket: | -| Talk | :rocket: | | Tasks | :rocket: | ## Platform support diff --git a/commitlint.yaml b/commitlint.yaml index ee82dc00..f974fd16 100644 --- a/commitlint.yaml +++ b/commitlint.yaml @@ -23,6 +23,7 @@ rules: - neon_news - neon_notes - neon_notifications + - neon_spreed - neon_lints - nextcloud - sort_box diff --git a/docs/architecture.puml b/docs/architecture.puml index 67be1d48..eaa024fe 100644 --- a/docs/architecture.puml +++ b/docs/architecture.puml @@ -13,6 +13,7 @@ package "Clients" { component neon_news component neon_notes component neon_notifications + component neon_spreed } package "OpenAPI" { @@ -27,11 +28,13 @@ app ..> neon_files app ..> neon_news app ..> neon_notes app ..> neon_notifications +app ..> neon_spreed neon_files --> neon neon_news --> neon neon_notes --> neon neon_notifications --> neon +neon_spreed --> neon neon --> nextcloud diff --git a/docs/architecture.svg b/docs/architecture.svg index acf5dffd..e3966745 100644 --- a/docs/architecture.svg +++ b/docs/architecture.svg @@ -1 +1 @@ -Neon frameworkClientsOpenAPIneonnextcloudsort_boxfile_iconsneon_dashboardneon_filesneon_newsneon_notesneon_notificationsdynamitespecificationsapp \ No newline at end of file +Neon frameworkClientsOpenAPIneonnextcloudsort_boxfile_iconsneon_dashboardneon_filesneon_newsneon_notesneon_notificationsneon_spreeddynamitespecificationsapp \ No newline at end of file diff --git a/packages/neon/neon/lib/l10n/en.arb b/packages/neon/neon/lib/l10n/en.arb index cfc0f28e..4b73e259 100644 --- a/packages/neon/neon/lib/l10n/en.arb +++ b/packages/neon/neon/lib/l10n/en.arb @@ -2,7 +2,7 @@ "@@locale": "en", "nextcloud": "Nextcloud", "nextcloudLogo": "Nextcloud logo", - "appImplementationName": "{app, select, nextcloud{Nextcloud} core{Server} dashboard{Dashboard} files{Files} news{News} notes{Notes} notifications{Notifications} other{}}", + "appImplementationName": "{app, select, nextcloud{Nextcloud} core{Server} dashboard{Dashboard} files{Files} news{News} notes{Notes} notifications{Notifications} spreed{Talk} other{}}", "@appImplementationName": { "placeholders": { "app": {} diff --git a/packages/neon/neon/lib/l10n/localizations.dart b/packages/neon/neon/lib/l10n/localizations.dart index b588aaf2..f7b0ac5b 100644 --- a/packages/neon/neon/lib/l10n/localizations.dart +++ b/packages/neon/neon/lib/l10n/localizations.dart @@ -104,7 +104,7 @@ abstract class NeonLocalizations { /// No description provided for @appImplementationName. /// /// In en, this message translates to: - /// **'{app, select, nextcloud{Nextcloud} core{Server} dashboard{Dashboard} files{Files} news{News} notes{Notes} notifications{Notifications} other{}}'** + /// **'{app, select, nextcloud{Nextcloud} core{Server} dashboard{Dashboard} files{Files} news{News} notes{Notes} notifications{Notifications} spreed{Talk} other{}}'** String appImplementationName(String app); /// No description provided for @loginAgain. diff --git a/packages/neon/neon/lib/l10n/localizations_en.dart b/packages/neon/neon/lib/l10n/localizations_en.dart index e8df967a..8e2c2bc1 100644 --- a/packages/neon/neon/lib/l10n/localizations_en.dart +++ b/packages/neon/neon/lib/l10n/localizations_en.dart @@ -24,6 +24,7 @@ class NeonLocalizationsEn extends NeonLocalizations { 'news': 'News', 'notes': 'Notes', 'notifications': 'Notifications', + 'spreed': 'Talk', 'other': '', }, ); diff --git a/packages/neon/neon_spreed/.metadata b/packages/neon/neon_spreed/.metadata new file mode 100644 index 00000000..9d75c7ec --- /dev/null +++ b/packages/neon/neon_spreed/.metadata @@ -0,0 +1,10 @@ +# This file tracks properties of this Flutter project. +# Used by Flutter tool to assess capabilities and perform upgrades etc. +# +# This file should be version controlled and should not be manually edited. + +version: + revision: "ead455963c12b453cdb2358cad34969c76daf180" + channel: "stable" + +project_type: package diff --git a/packages/neon/neon_spreed/LICENSE b/packages/neon/neon_spreed/LICENSE new file mode 100644 index 00000000..f288702d --- /dev/null +++ b/packages/neon/neon_spreed/LICENSE @@ -0,0 +1,674 @@ + GNU GENERAL PUBLIC LICENSE + Version 3, 29 June 2007 + + Copyright (C) 2007 Free Software Foundation, Inc. + Everyone is permitted to copy and distribute verbatim copies + of this license document, but changing it is not allowed. + + Preamble + + The GNU General Public License is a free, copyleft license for +software and other kinds of works. + + The licenses for most software and other practical works are designed +to take away your freedom to share and change the works. By contrast, +the GNU General Public License is 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. We, the Free Software Foundation, use the +GNU General Public License for most of our software; it applies also to +any other work released this way by its authors. You can apply it to +your programs, too. + + 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. + + To protect your rights, we need to prevent others from denying you +these rights or asking you to surrender the rights. Therefore, you have +certain responsibilities if you distribute copies of the software, or if +you modify it: responsibilities to respect the freedom of others. + + For example, if you distribute copies of such a program, whether +gratis or for a fee, you must pass on to the recipients the same +freedoms that you received. You must make sure that they, too, receive +or can get the source code. And you must show them these terms so they +know their rights. + + Developers that use the GNU GPL protect your rights with two steps: +(1) assert copyright on the software, and (2) offer you this License +giving you legal permission to copy, distribute and/or modify it. + + For the developers' and authors' protection, the GPL clearly explains +that there is no warranty for this free software. For both users' and +authors' sake, the GPL requires that modified versions be marked as +changed, so that their problems will not be attributed erroneously to +authors of previous versions. + + Some devices are designed to deny users access to install or run +modified versions of the software inside them, although the manufacturer +can do so. This is fundamentally incompatible with the aim of +protecting users' freedom to change the software. The systematic +pattern of such abuse occurs in the area of products for individuals to +use, which is precisely where it is most unacceptable. Therefore, we +have designed this version of the GPL to prohibit the practice for those +products. If such problems arise substantially in other domains, we +stand ready to extend this provision to those domains in future versions +of the GPL, as needed to protect the freedom of users. + + Finally, every program is threatened constantly by software patents. +States should not allow patents to restrict development and use of +software on general-purpose computers, but in those that do, we wish to +avoid the special danger that patents applied to a free program could +make it effectively proprietary. To prevent this, the GPL assures that +patents cannot be used to render the program non-free. + + 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 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 the making of 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. Use with the GNU Affero General Public License. + + 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 Affero 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 special requirements of the GNU Affero General Public License, +section 13, concerning interaction through a network will apply to the +combination as such. + + 14. Revised Versions of this License. + + The Free Software Foundation may publish revised and/or new versions of +the GNU 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 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 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 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 + + How to Apply These Terms to Your New Programs + + If you develop a new program, and you want it to be of the greatest +possible use to the public, the best way to achieve this is to make it +free software which everyone can redistribute and change under these terms. + + To do so, attach the following notices to the program. It is safest +to attach them to the start of each source file to most effectively +state the exclusion of warranty; and each file should have at least +the "copyright" line and a pointer to where the full notice is found. + + + Copyright (C) + + This program is free software: you can redistribute it and/or modify + it under the terms of the GNU General Public License as published by + the Free Software Foundation, either version 3 of the License, or + (at your option) any later version. + + This program is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + GNU General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program. If not, see . + +Also add information on how to contact you by electronic and paper mail. + + If the program does terminal interaction, make it output a short +notice like this when it starts in an interactive mode: + + Copyright (C) + This program comes with ABSOLUTELY NO WARRANTY; for details type `show w'. + This is free software, and you are welcome to redistribute it + under certain conditions; type `show c' for details. + +The hypothetical commands `show w' and `show c' should show the appropriate +parts of the General Public License. Of course, your program's commands +might be different; for a GUI interface, you would use an "about box". + + You should also get your employer (if you work as a programmer) or school, +if any, to sign a "copyright disclaimer" for the program, if necessary. +For more information on this, and how to apply and follow the GNU GPL, see +. + + The GNU General Public License does not permit incorporating your program +into proprietary programs. If your program is a subroutine library, you +may consider it more useful to permit linking proprietary applications with +the library. If this is what you want to do, use the GNU Lesser General +Public License instead of this License. But first, please read +. diff --git a/packages/neon/neon_spreed/analysis_options.yaml b/packages/neon/neon_spreed/analysis_options.yaml new file mode 100644 index 00000000..6c0ada98 --- /dev/null +++ b/packages/neon/neon_spreed/analysis_options.yaml @@ -0,0 +1,10 @@ +include: package:neon_lints/flutter.yaml + +linter: + rules: + # TODO + public_member_api_docs: false + +analyzer: + exclude: + - lib/l10n/** diff --git a/packages/neon/neon_spreed/assets/app.svg.vec b/packages/neon/neon_spreed/assets/app.svg.vec new file mode 100644 index 00000000..5e441a9f Binary files /dev/null and b/packages/neon/neon_spreed/assets/app.svg.vec differ diff --git a/packages/neon/neon_spreed/build.yaml b/packages/neon/neon_spreed/build.yaml new file mode 100644 index 00000000..e69de29b diff --git a/packages/neon/neon_spreed/l10n.yaml b/packages/neon/neon_spreed/l10n.yaml new file mode 100644 index 00000000..ce199896 --- /dev/null +++ b/packages/neon/neon_spreed/l10n.yaml @@ -0,0 +1,7 @@ +arb-dir: lib/l10n +template-arb-file: en.arb +output-localization-file: localizations.dart +synthetic-package: false +output-class: SpreedLocalizations +output-dir: lib/l10n +nullable-getter: false diff --git a/packages/neon/neon_spreed/lib/blocs/call.dart b/packages/neon/neon_spreed/lib/blocs/call.dart new file mode 100644 index 00000000..b91414cb --- /dev/null +++ b/packages/neon/neon_spreed/lib/blocs/call.dart @@ -0,0 +1,466 @@ +part of '../../neon_spreed.dart'; + +abstract class SpreedCallBlocEvents { + Future leaveCall(); + + // ignore: avoid_positional_boolean_parameters + void changeAudio(final bool enabled); + + // ignore: avoid_positional_boolean_parameters + void changeVideo(final bool enabled); + + // ignore: avoid_positional_boolean_parameters + void changeScreen(final bool enabled); +} + +abstract class SpreedCallBlocStates { + BehaviorSubject> get remoteParticipants; + + BehaviorSubject get audioEnabled; + + BehaviorSubject get videoEnabled; + + BehaviorSubject get screenEnabled; +} + +class SpreedCallBloc extends InteractiveBloc implements SpreedCallBlocEvents, SpreedCallBlocStates { + SpreedCallBloc( + this._settings, + this._client, + this._roomToken, + this._sessionID, + ) { + unawaited(_setupLocalParticipant().then((final _) => refresh())); + } + + final spreed.SignalingSettings _settings; + final NextcloudClient _client; + final String _roomToken; + final String _sessionID; + + var _listeningSignalingMessages = false; + late SpreedLocalCallParticipant localParticipant; + + @override + void dispose() { + _listeningSignalingMessages = false; + remoteParticipants.valueOrNull?.forEach((final participant) => participant.dispose()); + unawaited(remoteParticipants.close()); + unawaited(audioEnabled.close()); + unawaited(videoEnabled.close()); + unawaited(screenEnabled.close()); + super.dispose(); + } + + @override + BehaviorSubject> remoteParticipants = BehaviorSubject(); + + @override + BehaviorSubject audioEnabled = BehaviorSubject.seeded(false); + + @override + BehaviorSubject videoEnabled = BehaviorSubject.seeded(false); + + @override + BehaviorSubject screenEnabled = BehaviorSubject.seeded(false); + + @override + Future refresh() async { + try { + await _client.spreed.call.joinCall(token: _roomToken); + _listenForSignalingMessages(); + } on Exception catch (e, s) { + debugPrint(e.toString()); + debugPrint(s.toString()); + addError(e); + } + } + + @override + Future leaveCall() async { + try { + await _client.spreed.call.leaveCall(token: _roomToken); + } on Exception catch (e, s) { + debugPrint(e.toString()); + debugPrint(s.toString()); + addError(e); + } + } + + @override + // ignore: avoid_void_async + void changeAudio(final bool enabled) async { + audioEnabled.add(enabled); + await _updateLocalParticipant(); + } + + @override + // ignore: avoid_void_async + void changeVideo(final bool enabled) async { + videoEnabled.add(enabled); + await _updateLocalParticipant(); + } + + @override + void changeScreen(final bool enabled) { + screenEnabled.add(enabled); + } + + Future _setupLocalParticipant() async { + final stream = await navigator.mediaDevices.getUserMedia({ + 'audio': true, + 'video': true, + }); + for (final track in stream.getTracks()) { + track.enabled = false; + } + final renderer = await _getInitializedRenderer(); + renderer.srcObject = stream; + localParticipant = SpreedLocalCallParticipant( + _settings.userId!, + _sessionID, + renderer, + stream, + ); + } + + Future _sendSignalingMessages(final List messages) async { + for (final message in messages) { + // TODO: Send all messages at once, needs to send it over the body and not the URL, because that gets too long + try { + await _client.spreed.signaling.sendMessages( + token: _roomToken, + messages: ContentString( + (final b) => b + ..content = BuiltList([ + spreed.SignalingSendMessagesMessages( + (final b) => b + ..fn = ContentString( + (final b) => b..content = message, + ).toBuilder() + ..sessionId = _sessionID, + ), + ]), + ), + ); + } on Exception catch (e, s) { + debugPrint(e.toString()); + debugPrint(s.toString()); + addError(e); + } + } + } + + SpreedRemoteCallParticipant? _getRemoteParticipant(final String sessionID) { + final remoteParticipantMatches = + remoteParticipants.value.where((final participant) => participant.sessionID == sessionID); + if (remoteParticipantMatches.length == 1) { + return remoteParticipantMatches.single; + } + return null; + } + + Future _updateRemoteParticipant( + final String sessionID, + final Future Function(SpreedRemoteCallParticipant) call, + ) async { + final updatedRemoteParticipants = []; + for (final remoteParticipant in remoteParticipants.value) { + if (remoteParticipant.sessionID == sessionID) { + updatedRemoteParticipants.add(await call(remoteParticipant)); + } else { + updatedRemoteParticipants.add(remoteParticipant); + } + } + remoteParticipants.add(updatedRemoteParticipants); + } + + Stream> _pullSignalingMessages() async* { + while (_listeningSignalingMessages) { + try { + yield (await _client.spreed.signaling.pullMessages(token: _roomToken)).body.ocs.data.toList(); + } on Exception catch (e, s) { + if (e is DynamiteApiException && e.statusCode >= 500) { + continue; + } + debugPrint(e.toString()); + debugPrint(s.toString()); + addError(e); + } + } + } + + Future _updateLocalParticipant() async { + if (localParticipant.stream != null) { + for (final track in localParticipant.stream!.getTracks()) { + switch (track.kind) { + case 'video': + track.enabled = videoEnabled.value; + case 'audio': + track.enabled = audioEnabled.value; + default: + debugPrint('Unknown track kind ${track.kind}'); + } + } + } + + await _sendSignalingMessages(_generateMuteMessages(remoteParticipants.value)); + } + + List _generateMuteMessages(final List participants) => [ + for (final remoteParticipant in participants) ...[ + for (final entry in { + spreed.SignalingMuteMessage_Payload_Name.audio: audioEnabled.value, + spreed.SignalingMuteMessage_Payload_Name.video: videoEnabled.value, + }.entries) ...[ + spreed.SignalingMessage( + (final b) => b + ..signalingMuteMessage = spreed.SignalingMuteMessage( + (final b) => b + ..from = _sessionID + ..to = remoteParticipant.sessionID + ..type = entry.value ? spreed.SignalingMessageType.unmute : spreed.SignalingMessageType.mute + ..payload = spreed.SignalingMuteMessage_Payload( + (final b) => b.name = entry.key, + ).toBuilder(), + ).toBuilder(), + ), + ], + ], + ]; + + bool _isWeakerParticipant(final SpreedRemoteCallParticipant remoteParticipant) => + _sessionID.compareTo(remoteParticipant.sessionID) > 0; + + Future _sendOffer(final SpreedRemoteCallParticipant remoteParticipant) async { + debugPrint('Sending offer to ${remoteParticipant.userID} ${remoteParticipant.sessionID}'); + // TODO: For now this is disabled, because sending long or many signaling messages is broken. + //return; + final connection = await _setupConnection(remoteParticipant); + final localSDP = await connection.createOffer(); + await connection.setLocalDescription(localSDP); + await _sendSignalingMessages([ + spreed.SignalingMessage( + (final b) => b + ..signalingSessionDescriptionMessage = spreed.SignalingSessionDescriptionMessage( + (final b) => b + ..from = _sessionID + ..to = remoteParticipant.sessionID + ..type = spreed.SignalingMessageType.offer + ..payload = spreed.SignalingSessionDescriptionMessage_Payload( + (final b) => b + ..type = spreed.SignalingSessionDescriptionMessage_Payload_Type.offer + ..sdp = localSDP.sdp + ..nick = '', + ).toBuilder(), + ).toBuilder(), + ), + ..._generateMuteMessages([remoteParticipant]), + ]); + } + + Future _setupConnection(final SpreedRemoteCallParticipant remoteParticipant) async { + final connection = await createPeerConnection( + { + 'sdpSemantics': 'unified-plan', + 'iceServers': [ + ..._settings.stunservers.map((final s) => s.toJson()), + ..._settings.turnservers.map((final s) => s.toJson()), + ], + }, + ); + connection + ..onTrack = (final event) async { + if (event.track.kind == 'video') { + final stream = event.streams.first; + final renderer = await _getInitializedRenderer(); + renderer.srcObject = stream; + await _updateRemoteParticipant( + remoteParticipant.sessionID, + (final remoteParticipant) async => remoteParticipant + ..renderer = renderer + ..stream = stream, + ); + } + } + ..onIceCandidate = (final candidate) async { + await _sendSignalingMessages([ + spreed.SignalingMessage( + (final b) => b + ..signalingICECandidateMessage = spreed.SignalingICECandidateMessage( + (final b) => b + ..from = _sessionID + ..to = remoteParticipant.sessionID + ..type = spreed.SignalingMessageType.answer + ..payload = spreed.SignalingICECandidateMessage_Payload( + (final b) => b + ..candidate = spreed.SignalingICECandidateMessage_Payload_Candidate( + (final b) => b + ..candidate = candidate.candidate + ..sdpMid = candidate.sdpMid + ..sdpMLineIndex = candidate.sdpMLineIndex, + ).toBuilder(), + ).toBuilder(), + ).toBuilder(), + ), + ]); + } + ..onIceGatheringState = print + ..onIceConnectionState = print + ..onConnectionState = print; + await remoteParticipant.acceptNewConnection(connection); + await remoteParticipant.acceptNewLocalStream(localParticipant.stream); + + return connection; + } + + void _listenForSignalingMessages() { + if (_listeningSignalingMessages) { + return; + } + _listeningSignalingMessages = true; + _pullSignalingMessages().listen((final messages) async { + for (final message in messages) { + if (!_listeningSignalingMessages) { + return; + } + if (message.signalingSessions != null) { + final users = message.signalingSessions!.data.where( + (final user) => + spreed.ParticipantInCallFlag.values.byBinary(user.inCall).contains(spreed.ParticipantInCallFlag.inCall), + ); + + final currentParticipants = remoteParticipants.valueOrNull ?? []; + final updatedParticipants = []; + + for (final currentParticipant in currentParticipants) { + if (users.where((final user) => user.userId == currentParticipant.userID).isNotEmpty) { + updatedParticipants.add(currentParticipant); + } else { + currentParticipant.dispose(); + } + } + + for (final user in users) { + if (currentParticipants + .where((final currentParticipant) => user.userId == currentParticipant.userID) + .isEmpty && + user.sessionId != _sessionID) { + final remoteParticipant = SpreedRemoteCallParticipant( + user.userId, + user.sessionId, + null, + null, + null, + null, + ); + if (_isWeakerParticipant(remoteParticipant)) { + await _sendOffer(remoteParticipant); + } + updatedParticipants.add(remoteParticipant); + } + } + remoteParticipants.add(updatedParticipants); + + continue; + } + + if (message.signalingMessageWrapper != null) { + final signalingMessage = message.signalingMessageWrapper!.data.content; + + if (signalingMessage.signalingSessionDescriptionMessage != null) { + final remoteSDP = signalingMessage.signalingSessionDescriptionMessage!; + + await _updateRemoteParticipant(remoteSDP.from, (final remoteParticipant) async { + switch (remoteSDP.payload.type) { + case spreed.SignalingSessionDescriptionMessage_Payload_Type.offer: + debugPrint('Received offer from ${remoteParticipant.userID} ${remoteParticipant.sessionID}'); + final connection = await _setupConnection(remoteParticipant); + await connection.setRemoteDescription( + RTCSessionDescription( + remoteSDP.payload.sdp, + 'offer', + ), + ); + final localSDP = await connection.createAnswer(); + await connection.setLocalDescription(localSDP); + await _sendSignalingMessages([ + spreed.SignalingMessage( + (final b) => b + ..signalingSessionDescriptionMessage = spreed.SignalingSessionDescriptionMessage( + (final b) => b + ..from = _sessionID + ..to = remoteParticipant.sessionID + ..type = spreed.SignalingMessageType.answer + ..payload = spreed.SignalingSessionDescriptionMessage_Payload( + (final b) => b + ..type = spreed.SignalingSessionDescriptionMessage_Payload_Type.answer + ..sdp = localSDP.sdp + ..nick = '', + ).toBuilder(), + ).toBuilder(), + ), + ..._generateMuteMessages([remoteParticipant]), + ]); + case spreed.SignalingSessionDescriptionMessage_Payload_Type.answer: + debugPrint('Received answer from ${remoteParticipant.userID} ${remoteParticipant.sessionID}'); + } + + return remoteParticipant; + }); + + continue; + } + + if (signalingMessage.signalingICECandidateMessage != null) { + final iceCandidateMessage = signalingMessage.signalingICECandidateMessage!; + final remoteParticipant = _getRemoteParticipant(iceCandidateMessage.from); + if (remoteParticipant == null) { + continue; + } + + if (iceCandidateMessage.payload.candidate.candidate.isEmpty) { + // TODO: Handle end-of-candidates properly + continue; + } + + await remoteParticipant.addCandidate( + RTCIceCandidate( + iceCandidateMessage.payload.candidate.candidate, + iceCandidateMessage.payload.candidate.sdpMid, + iceCandidateMessage.payload.candidate.sdpMLineIndex, + ), + ); + + continue; + } + + if (signalingMessage.signalingMuteMessage != null) { + final muteMessage = signalingMessage.signalingMuteMessage!; + + await _updateRemoteParticipant(muteMessage.from, (final remoteParticipant) async { + final isUnmute = muteMessage.type == spreed.SignalingMessageType.unmute; + switch (muteMessage.payload.name) { + case spreed.SignalingMuteMessage_Payload_Name.audio: + remoteParticipant.audioEnabled = isUnmute; + case spreed.SignalingMuteMessage_Payload_Name.video: + remoteParticipant.videoEnabled = isUnmute; + } + return remoteParticipant; + }); + + continue; + } + } + + debugPrint('Unknown signaling message ${message.toJson()}'); + } + }); + } +} + +Future _getInitializedRenderer() async { + final renderer = RTCVideoRenderer(); + await renderer.initialize(); + return renderer; +} diff --git a/packages/neon/neon_spreed/lib/blocs/room.dart b/packages/neon/neon_spreed/lib/blocs/room.dart new file mode 100644 index 00000000..b19cbd37 --- /dev/null +++ b/packages/neon/neon_spreed/lib/blocs/room.dart @@ -0,0 +1,174 @@ +part of '../neon_spreed.dart'; + +abstract class SpreedRoomBlocEvents { + void loadMoreMessages(); + + void sendMessage(final String message); + + Future leaveRoom(); +} + +abstract class SpreedRoomBlocStates { + BehaviorSubject> get room; + + BehaviorSubject>> get messages; + + BehaviorSubject get allLoaded; + + BehaviorSubject get sendingMessage; + + BehaviorSubject get lastCommonReadMessageId; +} + +class SpreedRoomBloc extends InteractiveBloc implements SpreedRoomBlocEvents, SpreedRoomBlocStates { + SpreedRoomBloc( + this.options, + this.account, + final spreed.Room r, + ) { + roomToken = r.token; + room.add(Result.success(r)); + + unawaited(refresh()); + } + + final SpreedAppSpecificOptions options; + final Account account; + late final String roomToken; + final _limit = 100; + + int? _lastKnownMessageId; + + @override + void dispose() { + unawaited(room.close()); + unawaited(messages.close()); + unawaited(allLoaded.close()); + unawaited(sendingMessage.close()); + unawaited(lastCommonReadMessageId.close()); + super.dispose(); + } + + @override + BehaviorSubject allLoaded = BehaviorSubject.seeded(false); + + @override + BehaviorSubject lastCommonReadMessageId = BehaviorSubject.seeded(null); + + @override + BehaviorSubject>> messages = BehaviorSubject(); + + @override + BehaviorSubject> room = BehaviorSubject(); + + @override + BehaviorSubject sendingMessage = BehaviorSubject.seeded(null); + + @override + Future refresh() async { + await RequestManager.instance.wrapNextcloud( + account.id, + 'spreed-room-$roomToken', + room, + account.client.spreed.room.joinRoomRaw(token: roomToken), + (final response) => response.body.ocs.data, + ); + await _loadMessages(force: true); + } + + @override + // ignore: avoid_void_async + void sendMessage(final String message) async { + try { + sendingMessage.add(message); + await account.client.spreed.chat.sendMessage( + token: roomToken, + message: message, + ); + await _loadMessages(force: true); + } catch (e, s) { + debugPrint(e.toString()); + debugPrint(s.toString()); + addError(e); + } finally { + sendingMessage.add(null); + } + } + + @override + Future loadMoreMessages() async { + await _loadMessages(force: false); + } + + @override + Future leaveRoom() async { + try { + await account.client.spreed.room.leaveRoom(token: roomToken); + } catch (e, s) { + debugPrint(e.toString()); + debugPrint(s.toString()); + addError(e); + } + } + + Future _loadMessages({required final bool force}) async { + if (!force && (allLoaded.valueOrNull ?? false)) { + return; + } + + final previousData = messages.valueOrNull?.data; + try { + messages.add( + Result( + previousData, + null, + isLoading: true, + isCached: true, + ), + ); + final data = await account.client.spreed.chat.receiveMessages( + token: roomToken, + lookIntoFuture: 0, + includeLastKnown: 1, + limit: _limit, + lastKnownMessageId: (force ? null : _lastKnownMessageId) ?? 0, + lastCommonReadId: lastCommonReadMessageId.valueOrNull ?? 0, + ); + + _lastKnownMessageId = data.headers.xChatLastGiven != null ? int.parse(data.headers.xChatLastGiven!) : null; + lastCommonReadMessageId.add( + data.headers.xChatLastCommonRead != null ? int.parse(data.headers.xChatLastCommonRead!) : null, + ); + + if (data.body.ocs.data.length < _limit) { + allLoaded.add(true); + } + + messages.add( + Result.success( + { + if (previousData != null) ..._messagesToUniqueMap(previousData), + ..._messagesToUniqueMap(data.body.ocs.data.toList()), + }.values.sorted((final a, final b) => b.id.compareTo(a.id)).toList(), + ), + ); + } catch (e, s) { + debugPrint(e.toString()); + debugPrint(s.toString()); + messages.add( + Result( + previousData, + e, + isLoading: false, + isCached: true, + ), + ); + } + } + + Map _messagesToUniqueMap(final List messages) => { + for (final message in messages) ...{ + message.id: message, + }, + }; +} diff --git a/packages/neon/neon_spreed/lib/blocs/spreed.dart b/packages/neon/neon_spreed/lib/blocs/spreed.dart new file mode 100644 index 00000000..98c89306 --- /dev/null +++ b/packages/neon/neon_spreed/lib/blocs/spreed.dart @@ -0,0 +1,75 @@ +part of '../neon_spreed.dart'; + +abstract class SpreedBlocEvents { + void createRoom( + final spreed.RoomType type, + final String? roomName, + final core.AutocompleteResult? invite, + ); +} + +abstract class SpreedBlocStates { + BehaviorSubject>> get rooms; + + BehaviorSubject get unreadCounter; +} + +class SpreedBloc extends InteractiveBloc implements SpreedBlocEvents, SpreedBlocStates { + SpreedBloc( + this.options, + this.account, + ) { + rooms.listen((final result) { + if (result.hasData) { + unreadCounter.add( + [0, ...result.requireData.map((final room) => room.unreadMessages)].reduce((final a, final b) => a + b), + ); + } + }); + + unawaited(refresh()); + } + + final SpreedAppSpecificOptions options; + final Account account; + + @override + void dispose() { + unawaited(rooms.close()); + unawaited(unreadCounter.close()); + super.dispose(); + } + + @override + BehaviorSubject>> rooms = BehaviorSubject(); + + @override + BehaviorSubject unreadCounter = BehaviorSubject(); + + @override + Future refresh() async { + await RequestManager.instance.wrapNextcloud( + account.id, + 'spreed-rooms', + rooms, + account.client.spreed.room.getRoomsRaw(), + (final response) => response.body.ocs.data.toList(), + ); + } + + @override + void createRoom( + final spreed.RoomType type, + final String? roomName, + final core.AutocompleteResult? invite, + ) { + wrapAction( + () async => account.client.spreed.room.createRoom( + roomType: type.value, + roomName: roomName ?? '', + invite: invite?.id ?? '', + source: invite?.source ?? '', + ), + ); + } +} diff --git a/packages/neon/neon_spreed/lib/dialogs/create_room.dart b/packages/neon/neon_spreed/lib/dialogs/create_room.dart new file mode 100644 index 00000000..125a6fb3 --- /dev/null +++ b/packages/neon/neon_spreed/lib/dialogs/create_room.dart @@ -0,0 +1,142 @@ +part of '../neon_spreed.dart'; + +class SpreedCreateRoomDialog extends StatefulWidget { + const SpreedCreateRoomDialog({ + super.key, + }); + + @override + State createState() => _SpreedCreateRoomDialogState(); +} + +class _SpreedCreateRoomDialogState extends State { + late final values = { + spreed.RoomType.oneToOne: SpreedLocalizations.of(context).roomTypeOneToOne, + spreed.RoomType.group: SpreedLocalizations.of(context).roomTypeGroup, + spreed.RoomType.public: SpreedLocalizations.of(context).roomTypePublic, + }; + + final formKey = GlobalKey(); + final controller = TextEditingController(); + final focusNode = FocusNode(); + + spreed.RoomType? selectedType; + core.AutocompleteResult? selectedAutocompleteEntry; + + void changeType(final spreed.RoomType? type) { + controller.clear(); + setState(() { + selectedType = type; + }); + } + + void submit() { + if (formKey.currentState!.validate()) { + Navigator.of(context).pop( + SpreedCreateRoomDetails( + selectedType!, + selectedType! == spreed.RoomType.public ? controller.text : null, + selectedType! != spreed.RoomType.public ? selectedAutocompleteEntry : null, + ), + ); + } + } + + @override + Widget build(final BuildContext context) => NeonDialog( + title: Text(SpreedLocalizations.of(context).roomCreate), + children: [ + Form( + key: formKey, + child: Column( + crossAxisAlignment: CrossAxisAlignment.end, + children: [ + for (final type in values.keys) ...[ + ListTile( + title: Text(values[type]!), + leading: Icon( + type == spreed.RoomType.oneToOne + ? Icons.person + : type == spreed.RoomType.group + ? Icons.group + : Icons.public, + ), + trailing: Radio( + value: type, + groupValue: selectedType, + onChanged: changeType, + ), + onTap: () { + changeType(type); + }, + ), + ], + if (selectedType == spreed.RoomType.oneToOne || selectedType == spreed.RoomType.group) ...[ + NeonAutocomplete( + key: Key(selectedType!.index.toString()), + account: NeonProvider.of(context).activeAccount.value!, + itemType: 'call', + itemId: 'new', + shareTypes: [ + if (selectedType == spreed.RoomType.oneToOne) ...[ + core.ShareType.user.index, + ] else if (selectedType == spreed.RoomType.group) ...[ + core.ShareType.group.index, + ], + ], + validator: (final input) => validateNotEmpty(context, input), + decoration: InputDecoration( + hintText: selectedType == spreed.RoomType.oneToOne + ? SpreedLocalizations.of(context).roomCreateUserName + : SpreedLocalizations.of(context).roomCreateGroupName, + ), + onSelected: (final entry) { + setState(() { + selectedAutocompleteEntry = entry; + }); + }, + onFieldSubmitted: (final _) { + submit(); + }, + ), + ], + if (selectedType == spreed.RoomType.public) ...[ + TextFormField( + controller: controller, + focusNode: focusNode, + validator: (final input) => validateNotEmpty(context, input), + decoration: InputDecoration( + hintText: SpreedLocalizations.of(context).roomCreateRoomName, + ), + onFieldSubmitted: (final _) { + submit(); + }, + ), + ], + const SizedBox( + height: 10, + ), + ElevatedButton( + onPressed: selectedType == null ? null : submit, + child: Text(SpreedLocalizations.of(context).roomCreate), + ), + ], + ), + ), + ], + ); +} + +class SpreedCreateRoomDetails { + SpreedCreateRoomDetails( + this.type, + this.roomName, + this.invite, + ); + + final spreed.RoomType type; + + final String? roomName; + + final core.AutocompleteResult? invite; +} diff --git a/packages/neon/neon_spreed/lib/dialogs/select_screen.dart b/packages/neon/neon_spreed/lib/dialogs/select_screen.dart new file mode 100644 index 00000000..cdb0736c --- /dev/null +++ b/packages/neon/neon_spreed/lib/dialogs/select_screen.dart @@ -0,0 +1,97 @@ +part of '../neon_spreed.dart'; + +class SpreedSelectScreenDialog extends StatefulWidget { + const SpreedSelectScreenDialog({ + super.key, + }); + + @override + State createState() => _SpreedSelectScreenDialogState(); +} + +class _SpreedSelectScreenDialogState extends State { + List? sources; + DesktopCapturerSource? selectedSource; + late Timer timer; + + @override + void initState() { + super.initState(); + + unawaited( + desktopCapturer.getSources(types: SourceType.values).then((final sources) { + setState(() { + this.sources = sources; + }); + }), + ); + timer = Timer.periodic(const Duration(seconds: 1), (final _) async { + await desktopCapturer.updateSources(types: SourceType.values); + }); + } + + @override + void dispose() { + timer.cancel(); + + super.dispose(); + } + + @override + Widget build(final BuildContext context) => NeonDialog( + title: Text(SpreedLocalizations.of(context).screenSharingSelectScreen), + children: [ + if (sources != null) ...[ + for (final sourceType in SourceType.values.reversed) ...[ + Text( + sourceType == SourceType.Screen + ? SpreedLocalizations.of(context).screenSharingSelectScreenScreens + : SpreedLocalizations.of(context).screenSharingSelectScreenWindows, + ), + Wrap( + spacing: 10, + runSpacing: 10, + children: [ + for (final source in sources!.where((final source) => source.type == sourceType)) ...[ + InkWell( + onTap: () { + setState(() { + selectedSource = source; + }); + }, + child: Container( + padding: const EdgeInsets.all(5), + decoration: BoxDecoration( + border: Border.all( + // Transparent to prevent the image from jumping around when changing the selected source + color: + selectedSource == source ? Theme.of(context).colorScheme.primary : Colors.transparent, + width: 2, + ), + ), + width: max(MediaQuery.of(context).size.width, MediaQuery.of(context).size.height) / 5, + child: SpreedScreenPreview( + source: source, + ), + ), + ), + ], + ], + ), + const Divider(), + ], + ], + const SizedBox( + height: 10, + ), + ElevatedButton( + onPressed: selectedSource == null + ? null + : () { + Navigator.of(context).pop(selectedSource); + }, + child: Text(SpreedLocalizations.of(context).screenSharingSelectScreen), + ), + ], + ); +} diff --git a/packages/neon/neon_spreed/lib/l10n/en.arb b/packages/neon/neon_spreed/lib/l10n/en.arb new file mode 100644 index 00000000..9f6fbda1 --- /dev/null +++ b/packages/neon/neon_spreed/lib/l10n/en.arb @@ -0,0 +1,17 @@ +{ + "@@locale": "en", + "roomCreate": "Create room", + "roomCreateUserName": "User name", + "roomCreateGroupName": "Group name", + "roomCreateRoomName": "Room name", + "roomTypeOneToOne": "Private", + "roomTypeGroup": "Group", + "roomTypePublic": "Public", + "messageYou": "You", + "callStart": "Start call", + "callJoin": "Join call", + "callLeave": "Leave call", + "screenSharingSelectScreen": "Select screen", + "screenSharingSelectScreenScreens": "Screens", + "screenSharingSelectScreenWindows": "Windows" +} diff --git a/packages/neon/neon_spreed/lib/l10n/localizations.dart b/packages/neon/neon_spreed/lib/l10n/localizations.dart new file mode 100644 index 00000000..52c93b4a --- /dev/null +++ b/packages/neon/neon_spreed/lib/l10n/localizations.dart @@ -0,0 +1,203 @@ +import 'dart:async'; + +import 'package:flutter/foundation.dart'; +import 'package:flutter/widgets.dart'; +import 'package:flutter_localizations/flutter_localizations.dart'; +import 'package:intl/intl.dart' as intl; + +import 'localizations_en.dart'; + +/// Callers can lookup localized strings with an instance of SpreedLocalizations +/// returned by `SpreedLocalizations.of(context)`. +/// +/// Applications need to include `SpreedLocalizations.delegate()` in their app's +/// `localizationDelegates` list, and the locales they support in the app's +/// `supportedLocales` list. For example: +/// +/// ```dart +/// import 'l10n/localizations.dart'; +/// +/// return MaterialApp( +/// localizationsDelegates: SpreedLocalizations.localizationsDelegates, +/// supportedLocales: SpreedLocalizations.supportedLocales, +/// home: MyApplicationHome(), +/// ); +/// ``` +/// +/// ## Update pubspec.yaml +/// +/// Please make sure to update your pubspec.yaml to include the following +/// packages: +/// +/// ```yaml +/// dependencies: +/// # Internationalization support. +/// flutter_localizations: +/// sdk: flutter +/// intl: any # Use the pinned version from flutter_localizations +/// +/// # Rest of dependencies +/// ``` +/// +/// ## iOS Applications +/// +/// iOS applications define key application metadata, including supported +/// locales, in an Info.plist file that is built into the application bundle. +/// To configure the locales supported by your app, you’ll need to edit this +/// file. +/// +/// First, open your project’s ios/Runner.xcworkspace Xcode workspace file. +/// Then, in the Project Navigator, open the Info.plist file under the Runner +/// project’s Runner folder. +/// +/// Next, select the Information Property List item, select Add Item from the +/// Editor menu, then select Localizations from the pop-up menu. +/// +/// Select and expand the newly-created Localizations item then, for each +/// locale your application supports, add a new item and select the locale +/// you wish to add from the pop-up menu in the Value field. This list should +/// be consistent with the languages listed in the SpreedLocalizations.supportedLocales +/// property. +abstract class SpreedLocalizations { + SpreedLocalizations(String locale) : localeName = intl.Intl.canonicalizedLocale(locale.toString()); + + final String localeName; + + static SpreedLocalizations of(BuildContext context) { + return Localizations.of(context, SpreedLocalizations)!; + } + + static const LocalizationsDelegate delegate = _SpreedLocalizationsDelegate(); + + /// A list of this localizations delegate along with the default localizations + /// delegates. + /// + /// Returns a list of localizations delegates containing this delegate along with + /// GlobalMaterialLocalizations.delegate, GlobalCupertinoLocalizations.delegate, + /// and GlobalWidgetsLocalizations.delegate. + /// + /// Additional delegates can be added by appending to this list in + /// MaterialApp. This list does not have to be used at all if a custom list + /// of delegates is preferred or required. + static const List> localizationsDelegates = >[ + delegate, + GlobalMaterialLocalizations.delegate, + GlobalCupertinoLocalizations.delegate, + GlobalWidgetsLocalizations.delegate, + ]; + + /// A list of this localizations delegate's supported locales. + static const List supportedLocales = [Locale('en')]; + + /// No description provided for @roomCreate. + /// + /// In en, this message translates to: + /// **'Create room'** + String get roomCreate; + + /// No description provided for @roomCreateUserName. + /// + /// In en, this message translates to: + /// **'User name'** + String get roomCreateUserName; + + /// No description provided for @roomCreateGroupName. + /// + /// In en, this message translates to: + /// **'Group name'** + String get roomCreateGroupName; + + /// No description provided for @roomCreateRoomName. + /// + /// In en, this message translates to: + /// **'Room name'** + String get roomCreateRoomName; + + /// No description provided for @roomTypeOneToOne. + /// + /// In en, this message translates to: + /// **'Private'** + String get roomTypeOneToOne; + + /// No description provided for @roomTypeGroup. + /// + /// In en, this message translates to: + /// **'Group'** + String get roomTypeGroup; + + /// No description provided for @roomTypePublic. + /// + /// In en, this message translates to: + /// **'Public'** + String get roomTypePublic; + + /// No description provided for @messageYou. + /// + /// In en, this message translates to: + /// **'You'** + String get messageYou; + + /// No description provided for @callStart. + /// + /// In en, this message translates to: + /// **'Start call'** + String get callStart; + + /// No description provided for @callJoin. + /// + /// In en, this message translates to: + /// **'Join call'** + String get callJoin; + + /// No description provided for @callLeave. + /// + /// In en, this message translates to: + /// **'Leave call'** + String get callLeave; + + /// No description provided for @screenSharingSelectScreen. + /// + /// In en, this message translates to: + /// **'Select screen'** + String get screenSharingSelectScreen; + + /// No description provided for @screenSharingSelectScreenScreens. + /// + /// In en, this message translates to: + /// **'Screens'** + String get screenSharingSelectScreenScreens; + + /// No description provided for @screenSharingSelectScreenWindows. + /// + /// In en, this message translates to: + /// **'Windows'** + String get screenSharingSelectScreenWindows; +} + +class _SpreedLocalizationsDelegate extends LocalizationsDelegate { + const _SpreedLocalizationsDelegate(); + + @override + Future load(Locale locale) { + return SynchronousFuture(lookupSpreedLocalizations(locale)); + } + + @override + bool isSupported(Locale locale) => ['en'].contains(locale.languageCode); + + @override + bool shouldReload(_SpreedLocalizationsDelegate old) => false; +} + +SpreedLocalizations lookupSpreedLocalizations(Locale locale) { + // Lookup logic when only language code is specified. + switch (locale.languageCode) { + case 'en': + return SpreedLocalizationsEn(); + } + + throw FlutterError('SpreedLocalizations.delegate failed to load unsupported locale "$locale". This is likely ' + 'an issue with the localizations generation tool. Please file an issue ' + 'on GitHub with a reproducible sample app and the gen-l10n configuration ' + 'that was used.'); +} diff --git a/packages/neon/neon_spreed/lib/l10n/localizations_en.dart b/packages/neon/neon_spreed/lib/l10n/localizations_en.dart new file mode 100644 index 00000000..e3a07b95 --- /dev/null +++ b/packages/neon/neon_spreed/lib/l10n/localizations_en.dart @@ -0,0 +1,48 @@ +import 'localizations.dart'; + +/// The translations for English (`en`). +class SpreedLocalizationsEn extends SpreedLocalizations { + SpreedLocalizationsEn([String locale = 'en']) : super(locale); + + @override + String get roomCreate => 'Create room'; + + @override + String get roomCreateUserName => 'User name'; + + @override + String get roomCreateGroupName => 'Group name'; + + @override + String get roomCreateRoomName => 'Room name'; + + @override + String get roomTypeOneToOne => 'Private'; + + @override + String get roomTypeGroup => 'Group'; + + @override + String get roomTypePublic => 'Public'; + + @override + String get messageYou => 'You'; + + @override + String get callStart => 'Start call'; + + @override + String get callJoin => 'Join call'; + + @override + String get callLeave => 'Leave call'; + + @override + String get screenSharingSelectScreen => 'Select screen'; + + @override + String get screenSharingSelectScreenScreens => 'Screens'; + + @override + String get screenSharingSelectScreenWindows => 'Windows'; +} diff --git a/packages/neon/neon_spreed/lib/neon_spreed.dart b/packages/neon/neon_spreed/lib/neon_spreed.dart new file mode 100644 index 00000000..a8509af7 --- /dev/null +++ b/packages/neon/neon_spreed/lib/neon_spreed.dart @@ -0,0 +1,84 @@ +library files; + +import 'dart:async'; +import 'dart:math'; + +import 'package:built_collection/built_collection.dart'; +import 'package:collection/collection.dart'; +import 'package:flutter/material.dart'; +import 'package:flutter_chat_types/flutter_chat_types.dart' as chat_types; +import 'package:flutter_chat_ui/flutter_chat_ui.dart' as chat_ui; +import 'package:flutter_material_design_icons/flutter_material_design_icons.dart'; +import 'package:flutter_webrtc/flutter_webrtc.dart'; +import 'package:go_router/go_router.dart'; +import 'package:intersperse/intersperse.dart'; +import 'package:neon/blocs.dart'; +import 'package:neon/models.dart'; +import 'package:neon/settings.dart'; +import 'package:neon/theme.dart'; +import 'package:neon/utils.dart'; +import 'package:neon/widgets.dart'; +import 'package:neon_spreed/l10n/localizations.dart'; +import 'package:neon_spreed/routes.dart'; +import 'package:nextcloud/core.dart' as core; +import 'package:nextcloud/nextcloud.dart'; +import 'package:nextcloud/spreed.dart' as spreed; +import 'package:rxdart/rxdart.dart'; +import 'package:vector_graphics/vector_graphics.dart'; + +part 'blocs/call.dart'; +part 'blocs/room.dart'; +part 'blocs/spreed.dart'; +part 'dialogs/create_room.dart'; +part 'dialogs/select_screen.dart'; +part 'options.dart'; +part 'pages/call.dart'; +part 'pages/main.dart'; +part 'pages/room.dart'; +part 'utils/participants.dart'; +part 'utils/view_size.dart'; +part 'widgets/call_button.dart'; +part 'widgets/call_participant_view.dart'; +part 'widgets/room_icon.dart'; +part 'widgets/screen_preview.dart'; + +@immutable +class SpreedApp extends AppImplementation { + SpreedApp(); + + @override + final String id = appId; + + static const String appId = 'spreed'; + + @override + final LocalizationsDelegate localizationsDelegate = SpreedLocalizations.delegate; + + @override + final List supportedLocales = SpreedLocalizations.supportedLocales; + + @override + late final SpreedAppSpecificOptions options = SpreedAppSpecificOptions(storage); + + @override + SpreedBloc buildBloc(final Account account) => SpreedBloc( + options, + account, + ); + + @override + final Widget page = const SpreedMainPage(); + + @override + final RouteBase route = $spreedAppRoute; + + @override + BehaviorSubject? getUnreadCounter(final SpreedBloc bloc) => bloc.unreadCounter; + + @override + VersionCheck getVersionCheck( + final Account account, + final core.OcsGetCapabilitiesResponseApplicationJson_Ocs_Data capabilities, + ) => + account.client.spreed.getVersionCheck(capabilities); +} diff --git a/packages/neon/neon_spreed/lib/options.dart b/packages/neon/neon_spreed/lib/options.dart new file mode 100644 index 00000000..3c56446b --- /dev/null +++ b/packages/neon/neon_spreed/lib/options.dart @@ -0,0 +1,8 @@ +part of 'neon_spreed.dart'; + +class SpreedAppSpecificOptions extends NextcloudAppOptions { + SpreedAppSpecificOptions(super.storage) { + super.categories = []; + super.options = []; + } +} diff --git a/packages/neon/neon_spreed/lib/pages/call.dart b/packages/neon/neon_spreed/lib/pages/call.dart new file mode 100644 index 00000000..eef90639 --- /dev/null +++ b/packages/neon/neon_spreed/lib/pages/call.dart @@ -0,0 +1,145 @@ +part of '../../neon_spreed.dart'; + +class SpreedCallPage extends StatefulWidget { + const SpreedCallPage({ + required this.bloc, + super.key, + }); + + final SpreedCallBloc bloc; + + @override + State createState() => _SpreedCallPageState(); +} + +class _SpreedCallPageState extends State { + @override + void initState() { + widget.bloc.errors.listen((final error) { + if (!mounted) { + return; + } + NeonError.showSnackbar(context, error); + }); + + super.initState(); + } + + @override + Widget build(final BuildContext context) => StreamBuilder( + stream: widget.bloc.audioEnabled, + builder: (final context, final audioEnabledSnapshot) => StreamBuilder( + stream: widget.bloc.videoEnabled, + builder: (final context, final videoEnabledSnapshot) => StreamBuilder( + stream: widget.bloc.screenEnabled, + builder: (final context, final screenEnabledSnapshot) { + final audioEnabled = audioEnabledSnapshot.data ?? false; + final videoEnabled = videoEnabledSnapshot.data ?? false; + final screenEnabled = screenEnabledSnapshot.data ?? false; + return Scaffold( + appBar: AppBar( + automaticallyImplyLeading: false, + actions: [ + IconButton( + icon: Icon( + audioEnabled ? MdiIcons.microphone : MdiIcons.microphoneOff, + color: !audioEnabled ? Colors.red : null, + ), + onPressed: () { + widget.bloc.changeAudio(!audioEnabled); + }, + ), + IconButton( + icon: Icon( + videoEnabled ? MdiIcons.video : MdiIcons.videoOff, + color: !videoEnabled ? Colors.red : null, + ), + onPressed: () { + widget.bloc.changeVideo(!videoEnabled); + }, + ), + IconButton( + icon: Icon( + screenEnabled ? MdiIcons.monitorShare : MdiIcons.monitorOff, + color: !screenEnabled ? Colors.red : null, + ), + onPressed: () async { + if (!screenEnabled) { + final result = await showDialog( + context: context, + builder: (final context) => const SpreedSelectScreenDialog(), + ); + if (result == null) { + return; + } + } + widget.bloc.changeScreen(!screenEnabled); + }, + ), + SpreedCallButton( + type: SpreedCallButtonType.leaveCall, + onPressed: () { + Navigator.of(context).pop(); + }, + ), + ] + .intersperse( + const SizedBox( + width: 20, + ), + ) + .toList(), + ), + body: StreamBuilder( + stream: widget.bloc.remoteParticipants, + builder: (final context, final remoteParticipantsSnapshot) { + if (remoteParticipantsSnapshot.data == null) { + return Center( + child: LayoutBuilder( + builder: (final context, final constraints) => SizedBox( + width: constraints.maxWidth / 2, + child: const NeonLinearProgressIndicator(), + ), + ), + ); + } + + final participants = [ + ...remoteParticipantsSnapshot.requireData, + widget.bloc.localParticipant, + ]; + + return Center( + child: LayoutBuilder( + builder: (final context, final constraints) { + final viewSize = calculateViewSize(participants.length, constraints.biggest); + return Wrap( + alignment: WrapAlignment.center, + children: [ + for (final participant in participants) ...[ + Container( + constraints: BoxConstraints( + maxWidth: viewSize.width, + maxHeight: viewSize.height, + ), + child: SpreedCallParticipantView( + participant: participant, + localAudioEnabled: audioEnabled, + localVideoEnabled: videoEnabled, + localScreenEnabled: screenEnabled, + ), + ), + ], + ], + ); + }, + ), + ); + }, + ), + ); + }, + ), + ), + ); +} diff --git a/packages/neon/neon_spreed/lib/pages/main.dart b/packages/neon/neon_spreed/lib/pages/main.dart new file mode 100644 index 00000000..e4febc55 --- /dev/null +++ b/packages/neon/neon_spreed/lib/pages/main.dart @@ -0,0 +1,113 @@ +part of '../neon_spreed.dart'; + +class SpreedMainPage extends StatefulWidget { + const SpreedMainPage({ + super.key, + }); + + @override + State createState() => _SpreedMainPageState(); +} + +class _SpreedMainPageState extends State { + late final SpreedBloc bloc; + + @override + void initState() { + super.initState(); + + bloc = NeonProvider.of(context); + + bloc.errors.listen((final error) { + NeonError.showSnackbar(context, error); + }); + } + + @override + Widget build(final BuildContext context) => Scaffold( + resizeToAvoidBottomInset: false, + body: ResultBuilder( + stream: bloc.rooms, + builder: (final context, final rooms) { + final sorted = rooms.data?.sorted((final a, final b) => b.lastActivity.compareTo(a.lastActivity)) ?? []; + return NeonListView( + scrollKey: 'spreed-rooms', + isLoading: rooms.isLoading, + error: rooms.error, + onRefresh: bloc.refresh, + itemCount: sorted.length, + itemBuilder: (final context, final index) => _buildRoom(context, sorted[index]), + ); + }, + ), + floatingActionButton: FloatingActionButton( + child: const Icon(Icons.add), + onPressed: () async { + final result = await showDialog( + context: context, + builder: (final context) => const SpreedCreateRoomDialog(), + ); + if (result == null) { + return; + } + bloc.createRoom( + result.type, + result.roomName, + result.invite, + ); + }, + ), + ); + + Widget _buildRoom( + final BuildContext context, + final spreed.Room room, + ) => + ListTile( + title: Text(room.displayName), + subtitle: Text( + room.lastMessage.chatMessage != null + ? (room.type == spreed.RoomType.changelog.value || + (room.type == spreed.RoomType.oneToOne.value && + room.lastMessage.chatMessage!.actorId != bloc.account.username) + ? room.lastMessage.chatMessage!.message + : '${room.lastMessage.chatMessage!.actorId == bloc.account.username ? SpreedLocalizations.of(context).messageYou : room.lastMessage.chatMessage!.actorDisplayName}: ${room.lastMessage.chatMessage!.message}') + : '', + overflow: TextOverflow.ellipsis, + maxLines: 1, + ), + leading: SpreedRoomIcon( + roomType: spreed.RoomType.values[room.type], + roomName: room.name, + ), + trailing: room.unreadMessages > 0 + ? Chip( + backgroundColor: room.unreadMention ? Theme.of(context).colorScheme.primary : null, + label: Text( + room.unreadMessages.toString(), + style: TextStyle( + color: room.unreadMention + ? Theme.of(context).colorScheme.onPrimary + : Theme.of(context).colorScheme.primary, + ), + ), + ) + : null, + onTap: () async { + final roomBloc = SpreedRoomBloc( + bloc.options, + bloc.account, + room, + ); + await Navigator.of(context).push( + MaterialPageRoute( + builder: (final context) => SpreedRoomPage( + bloc: roomBloc, + ), + ), + ); + await roomBloc.leaveRoom(); + bloc.dispose(); + }, + ); +} diff --git a/packages/neon/neon_spreed/lib/pages/room.dart b/packages/neon/neon_spreed/lib/pages/room.dart new file mode 100644 index 00000000..66237305 --- /dev/null +++ b/packages/neon/neon_spreed/lib/pages/room.dart @@ -0,0 +1,324 @@ +part of '../neon_spreed.dart'; + +class SpreedRoomPage extends StatefulWidget { + const SpreedRoomPage({ + required this.bloc, + super.key, + }); + + final SpreedRoomBloc bloc; + + @override + State createState() => _SpreedRoomPageState(); +} + +class _SpreedRoomPageState extends State { + final defaultChatTheme = const chat_ui.DefaultChatTheme(); + + late final chatTheme = chat_ui.DefaultChatTheme( + backgroundColor: Theme.of(context).colorScheme.background, + primaryColor: Theme.of(context).colorScheme.onBackground, + inputBackgroundColor: Theme.of(context).colorScheme.primary, + inputTextColor: Theme.of(context).colorScheme.onPrimary, + inputTextCursorColor: Theme.of(context).colorScheme.onPrimary, + receivedMessageBodyTextStyle: defaultChatTheme.receivedMessageBodyTextStyle.copyWith( + color: Theme.of(context).colorScheme.onPrimary, + ), + sentMessageBodyTextStyle: defaultChatTheme.sentMessageBodyTextStyle.copyWith( + color: Theme.of(context).colorScheme.onPrimary, + ), + unreadHeaderTheme: chat_ui.UnreadHeaderTheme( + color: Theme.of(context).colorScheme.background, + textStyle: TextStyle( + color: Theme.of(context).colorScheme.primary, + fontWeight: FontWeight.bold, + ), + ), + ); + + final inputOptions = const chat_ui.InputOptions( + sendButtonVisibilityMode: chat_ui.SendButtonVisibilityMode.always, + ); + + late final user = chat_types.User( + id: widget.bloc.account.username, + ); + + void onSendPressed(final chat_types.PartialText partialText) { + widget.bloc.sendMessage(partialText.text); + } + + Future openCall(final spreed.Room room) async { + try { + final client = NeonProvider.of(context).activeAccount.value!.client; + final settings = (await client.spreed.signaling.getSettings(token: widget.bloc.roomToken)).body.ocs.data; + final bloc = SpreedCallBloc( + settings, + client, + widget.bloc.roomToken, + room.sessionId, + ); + if (!mounted) { + return; + } + await Navigator.of(context).push( + MaterialPageRoute( + builder: (final context) => SpreedCallPage( + bloc: bloc, + ), + ), + ); + await bloc.leaveCall(); + bloc.dispose(); + } catch (e, s) { + debugPrint(e.toString()); + debugPrint(s.toString()); + if (mounted) { + NeonError.showSnackbar(context, e); + } + } + } + + @override + void initState() { + super.initState(); + + widget.bloc.errors.listen((final error) { + NeonError.showSnackbar(context, error); + }); + } + + @override + Widget build(final BuildContext context) => StreamBuilder( + stream: widget.bloc.allLoaded, + builder: (final context, final allLoadedSnapshot) => ResultBuilder( + stream: widget.bloc.room, + builder: (final context, final room) => StreamBuilder( + stream: widget.bloc.lastCommonReadMessageId, + builder: (final context, final lastCommonReadMessageIdSnapshot) => StreamBuilder( + stream: widget.bloc.sendingMessage, + builder: (final context, final sendingMessageSnapshot) => ResultBuilder( + stream: widget.bloc.messages, + builder: (final context, final messages) { + final roomType = room.hasData ? spreed.RoomType.fromValue(room.requireData.type) : null; + return Scaffold( + resizeToAvoidBottomInset: false, + appBar: AppBar( + titleSpacing: 0, + title: Row( + children: [ + if (room.hasData) ...[ + if (roomType!.isSingleUser) ...[ + SpreedRoomIcon( + roomType: roomType, + roomName: room.requireData.name, + backgroundColor: Theme.of(context).colorScheme.onPrimary, + foregroundColor: Theme.of(context).colorScheme.primary, + ), + const SizedBox( + width: 10, + ), + ], + Flexible( + child: Text(room.requireData.displayName), + ), + ], + if (room.error != null) ...[ + const SizedBox( + width: 8, + ), + Icon( + Icons.error_outline, + size: 30, + color: Theme.of(context).colorScheme.onPrimary, + ), + ], + if (room.isLoading) ...[ + const SizedBox( + width: 8, + ), + Expanded( + child: NeonLinearProgressIndicator( + color: Theme.of(context).appBarTheme.foregroundColor, + ), + ), + ], + ], + ), + actions: [ + if (room.hasData && room.requireData.readOnly == 0) ...[ + if (room.requireData.hasCall) ...[ + SpreedCallButton( + type: SpreedCallButtonType.joinCall, + onPressed: () async { + await openCall(room.requireData); + }, + ), + ] else if (room.requireData.canStartCall) ...[ + SpreedCallButton( + type: SpreedCallButtonType.startCall, + onPressed: () async { + await openCall(room.requireData); + }, + ), + ], + ], + ], + ), + body: chat_ui.Chat( + useTopSafeAreaInset: false, + showUserNames: true, + showUserAvatars: !(roomType?.isSingleUser ?? true), + theme: chatTheme, + inputOptions: inputOptions, + scrollToUnreadOptions: chat_ui.ScrollToUnreadOptions( + lastReadMessageId: room.data?.lastReadMessage.toString(), + scrollOnOpen: true, + scrollDelay: Duration.zero, + ), + avatarBuilder: (final username) => NeonUserAvatar( + username: username, + account: NeonProvider.of(context).activeAccount.value!, + ), + textMessageBuilder: ( + final message, { + required final messageWidth, + required final showName, + }) { + final matchers = [ + if (message.metadata != null) ...[ + NeonRichObject( + parameters: message.metadata!, + ), + ], + ]; + + return chat_ui.TextMessage( + emojiEnlargementBehavior: chat_ui.EmojiEnlargementBehavior.multi, + hideBackgroundOnEmojiMessages: true, + message: message, + showName: showName, + usePreviewData: true, + options: chat_ui.TextMessageOptions( + matchers: matchers, + ), + ); + }, + systemMessageBuilder: (final message) { + final matchers = [ + if (message.metadata != null) ...[ + NeonRichObject( + parameters: message.metadata!, + ), + ], + ]; + + return chat_ui.SystemMessage( + message: message.text, + options: chat_ui.TextMessageOptions( + matchers: matchers, + ), + ); + }, + customBottomWidget: Column( + children: [ + NeonError( + messages.error, + onRetry: () async { + await widget.bloc.refresh(); + }, + ), + if (messages.isLoading) ...[ + const NeonLinearProgressIndicator( + margin: EdgeInsets.symmetric(horizontal: 10, vertical: 5), + ), + ], + if ((room.data?.readOnly ?? 0) == 0) ...[ + chat_ui.Input( + onSendPressed: onSendPressed, + options: inputOptions, + ), + ], + ], + ), + user: user, + onEndReached: () async { + await widget.bloc.loadMoreMessages(); + }, + onSendPressed: onSendPressed, + isLastPage: allLoadedSnapshot.data ?? false, + messages: [ + if (sendingMessageSnapshot.hasData) ...[ + chat_types.TextMessage( + id: 'sending', + author: user, + text: sendingMessageSnapshot.data!, + showStatus: true, + status: chat_types.Status.sending, + ), + ], + if (messages.hasData) ...[ + ...messages.requireData + .map( + (final message) => _spreedMessageToChatMessage( + message, + lastCommonReadMessageId: lastCommonReadMessageIdSnapshot.data, + ), + ) + .whereNotNull(), + ], + ], + ), + ); + }, + ), + ), + ), + ), + ); + + chat_types.Message? _spreedMessageToChatMessage( + final spreed.ChatMessageInterface message, { + final int? lastCommonReadMessageId, + }) { + final id = message.id.toString(); + final author = chat_types.User( + id: message.actorId, + firstName: message.actorDisplayName, + imageUrl: message.actorId, + ); + final createdAt = message.timestamp * 1000; + // TODO: Doesn't work yet in the UI. See https://github.com/flyerhq/flutter_chat_ui/pull/256 + final repliedMessage = message is spreed.ChatMessageWithParent && message.parent != null + ? _spreedMessageToChatMessage(message.parent!) + : null; + final status = lastCommonReadMessageId != null && lastCommonReadMessageId >= message.id + ? chat_types.Status.seen + : chat_types.Status.sent; + final metadata = message.messageParameters is Map ? message.messageParameters as Map : null; + + switch (spreed.MessageType.values.byName(message.messageType)) { + case spreed.MessageType.comment: + return chat_types.TextMessage( + id: id, + author: author, + createdAt: createdAt, + repliedMessage: repliedMessage, + text: message.message, + showStatus: true, + status: status, + metadata: metadata, + ); + case spreed.MessageType.command: + case spreed.MessageType.system: + return chat_types.SystemMessage( + id: id, + createdAt: createdAt, + text: message.message, + metadata: metadata, + ); + default: + return null; + } + } +} diff --git a/packages/neon/neon_spreed/lib/routes.dart b/packages/neon/neon_spreed/lib/routes.dart new file mode 100644 index 00000000..1b6ecf2a --- /dev/null +++ b/packages/neon/neon_spreed/lib/routes.dart @@ -0,0 +1,18 @@ +import 'package:flutter/widgets.dart'; +import 'package:go_router/go_router.dart'; +import 'package:neon/utils.dart'; +import 'package:neon_spreed/neon_spreed.dart'; + +part 'routes.g.dart'; + +@TypedGoRoute( + path: '$appsBaseRoutePrefix${SpreedApp.appId}', + name: SpreedApp.appId, +) +@immutable +class SpreedAppRoute extends NeonBaseAppRoute { + const SpreedAppRoute(); + + @override + Widget build(final BuildContext context, final GoRouterState state) => const SpreedMainPage(); +} diff --git a/packages/neon/neon_spreed/lib/routes.g.dart b/packages/neon/neon_spreed/lib/routes.g.dart new file mode 100644 index 00000000..8d652de9 --- /dev/null +++ b/packages/neon/neon_spreed/lib/routes.g.dart @@ -0,0 +1,33 @@ +// GENERATED CODE - DO NOT MODIFY BY HAND + +part of 'routes.dart'; + +// ************************************************************************** +// GoRouterGenerator +// ************************************************************************** + +List get $appRoutes => [ + $spreedAppRoute, + ]; + +RouteBase get $spreedAppRoute => GoRouteData.$route( + path: '/apps/spreed', + name: 'spreed', + factory: $SpreedAppRouteExtension._fromState, + ); + +extension $SpreedAppRouteExtension on SpreedAppRoute { + static SpreedAppRoute _fromState(GoRouterState state) => const SpreedAppRoute(); + + String get location => GoRouteData.$location( + '/apps/spreed', + ); + + void go(BuildContext context) => context.go(location); + + Future push(BuildContext context) => context.push(location); + + void pushReplacement(BuildContext context) => context.pushReplacement(location); + + void replace(BuildContext context) => context.replace(location); +} diff --git a/packages/neon/neon_spreed/lib/utils/participants.dart b/packages/neon/neon_spreed/lib/utils/participants.dart new file mode 100644 index 00000000..62e71058 --- /dev/null +++ b/packages/neon/neon_spreed/lib/utils/participants.dart @@ -0,0 +1,110 @@ +part of '../neon_spreed.dart'; + +abstract class SpreedCallParticipant { + SpreedCallParticipant( + this.userID, + this.sessionID, + this.renderer, + this.stream, + ); + + final String userID; + final String sessionID; + RTCVideoRenderer? renderer; + MediaStream? stream; + + void dispose() { + stream?.getTracks().forEach((final track) => unawaited(track.stop())); + unawaited(stream?.dispose()); + renderer?.srcObject = null; + unawaited(renderer?.dispose()); + } +} + +class SpreedLocalCallParticipant extends SpreedCallParticipant { + SpreedLocalCallParticipant( + super.userID, + super.sessionID, + super.renderer, + super.stream, + ); +} + +class SpreedRemoteCallParticipant extends SpreedCallParticipant { + SpreedRemoteCallParticipant( + super.userID, + super.sessionID, + super.renderer, + super.stream, + this._connection, + this._senders, { + this.audioEnabled = false, + this.videoEnabled = false, + }); + + RTCPeerConnection? _connection; + List? _senders; + final List _candidates = []; + bool audioEnabled; + bool videoEnabled; + + RTCPeerConnection? get connection => _connection; + List? get senders => _senders; + + Future _clearSenders() async { + if (_senders != null && _connection != null) { + for (final sender in _senders!) { + await _connection!.removeTrack(sender); + } + } + if (_senders != null) { + for (final sender in _senders!) { + try { + await sender.dispose(); + } catch (_) { + // TODO: Somehow peerConnection is null when calling this on disposing the participant + } + } + _senders = null; + } + } + + Future acceptNewConnection(final RTCPeerConnection? connection) async { + await _clearSenders(); + await _connection?.close(); + _connection = connection; + if (_connection != null) { + for (final candidate in _candidates) { + debugPrint('Loading candidate'); + await _connection!.addCandidate(candidate); + } + _candidates.clear(); + } + } + + Future acceptNewLocalStream(final MediaStream? stream) async { + await _clearSenders(); + if (_connection != null && stream != null) { + _senders = []; + for (final track in stream.getTracks()) { + _senders!.add(await _connection!.addTrack(track, stream)); + } + } + } + + Future addCandidate(final RTCIceCandidate candidate) async { + if (connection != null) { + await connection!.addCandidate(candidate); + } else { + _candidates.add(candidate); + debugPrint('Storing candidate for later use'); + } + } + + @override + void dispose() { + unawaited(_clearSenders()); + unawaited(_connection?.close()); + super.dispose(); + } +} diff --git a/packages/neon/neon_spreed/lib/utils/view_size.dart b/packages/neon/neon_spreed/lib/utils/view_size.dart new file mode 100644 index 00000000..d069a894 --- /dev/null +++ b/packages/neon/neon_spreed/lib/utils/view_size.dart @@ -0,0 +1,21 @@ +part of '../neon_spreed.dart'; + +Size calculateViewSize(final int count, final Size constraints) { + const aspectRatio = 2 / 3; + Size? bestSize; + + for (var i = 1.0; i < min(constraints.width, constraints.height / aspectRatio) + 1; i++) { + final width = i; + final height = i * aspectRatio; + if ((constraints.width ~/ width) * (constraints.height ~/ height) >= count) { + bestSize = Size( + width, + height, + ); + } else { + break; + } + } + + return bestSize ?? Size.zero; +} diff --git a/packages/neon/neon_spreed/lib/widgets/call_button.dart b/packages/neon/neon_spreed/lib/widgets/call_button.dart new file mode 100644 index 00000000..1750e4bb --- /dev/null +++ b/packages/neon/neon_spreed/lib/widgets/call_button.dart @@ -0,0 +1,54 @@ +part of '../neon_spreed.dart'; + +class SpreedCallButton extends StatelessWidget { + const SpreedCallButton({ + required this.type, + required this.onPressed, + super.key, + }); + + final SpreedCallButtonType type; + + final VoidCallback? onPressed; + + @override + Widget build(final BuildContext context) { + late final String label; + late final IconData icon; + late final Color? backgroundColor; + switch (type) { + case SpreedCallButtonType.startCall: + icon = Icons.videocam; + label = SpreedLocalizations.of(context).callStart; + backgroundColor = null; + case SpreedCallButtonType.joinCall: + icon = Icons.phone; + label = SpreedLocalizations.of(context).callJoin; + backgroundColor = Colors.green; + case SpreedCallButtonType.leaveCall: + icon = Icons.videocam_off; + label = SpreedLocalizations.of(context).callLeave; + backgroundColor = Colors.red; + } + return Container( + margin: const EdgeInsets.all(5), + child: ElevatedButton.icon( + onPressed: onPressed, + icon: Icon(icon), + label: Text(label), + style: backgroundColor != null + ? ElevatedButton.styleFrom( + backgroundColor: backgroundColor, + foregroundColor: Theme.of(context).colorScheme.background, + ) + : null, + ), + ); + } +} + +enum SpreedCallButtonType { + startCall, + joinCall, + leaveCall, +} diff --git a/packages/neon/neon_spreed/lib/widgets/call_participant_view.dart b/packages/neon/neon_spreed/lib/widgets/call_participant_view.dart new file mode 100644 index 00000000..28efd7d9 --- /dev/null +++ b/packages/neon/neon_spreed/lib/widgets/call_participant_view.dart @@ -0,0 +1,69 @@ +part of '../neon_spreed.dart'; + +class SpreedCallParticipantView extends StatelessWidget { + const SpreedCallParticipantView({ + required this.participant, + required this.localAudioEnabled, + required this.localVideoEnabled, + required this.localScreenEnabled, + super.key, + }); + + final SpreedCallParticipant participant; + final bool localAudioEnabled; + final bool localVideoEnabled; + final bool localScreenEnabled; + + @override + Widget build(final BuildContext context) { + final hasEnabledVideoTracks = + participant.renderer?.srcObject?.getVideoTracks().where((final track) => track.enabled).isNotEmpty ?? false; + final audioEnabled = participant is SpreedLocalCallParticipant + ? localAudioEnabled + : (participant as SpreedRemoteCallParticipant).audioEnabled; + final videoEnabled = participant is SpreedLocalCallParticipant + ? localVideoEnabled + : (participant as SpreedRemoteCallParticipant).videoEnabled; + return LayoutBuilder( + builder: (final context, final constraints) => Container( + margin: const EdgeInsets.all(5), + child: ClipRRect( + borderRadius: BorderRadius.circular(10), + child: ColoredBox( + color: Theme.of(context).colorScheme.primary, + child: Stack( + children: [ + Center( + child: hasEnabledVideoTracks && videoEnabled + ? RTCVideoView( + participant.renderer!, + objectFit: RTCVideoViewObjectFit.RTCVideoViewObjectFitCover, + ) + : NeonUserAvatar( + account: NeonProvider.of(context).activeAccount.value!, + username: participant.userID, + showStatus: false, + size: min(constraints.maxHeight, constraints.maxWidth) / 2, + ), + ), + if (!audioEnabled) ...[ + Align( + alignment: Alignment.bottomRight, + child: Container( + margin: const EdgeInsets.all(5), + child: Icon( + MdiIcons.microphoneOff, + size: 28, + color: Theme.of(context).colorScheme.onPrimary, + ), + ), + ), + ], + ], + ), + ), + ), + ), + ); + } +} diff --git a/packages/neon/neon_spreed/lib/widgets/room_icon.dart b/packages/neon/neon_spreed/lib/widgets/room_icon.dart new file mode 100644 index 00000000..d7bf23c3 --- /dev/null +++ b/packages/neon/neon_spreed/lib/widgets/room_icon.dart @@ -0,0 +1,58 @@ +part of '../neon_spreed.dart'; + +class SpreedRoomIcon extends StatelessWidget { + const SpreedRoomIcon({ + required this.roomType, + this.roomName, + this.backgroundColor, + this.foregroundColor, + super.key, + }) : assert( + (roomType != spreed.RoomType.oneToOne && roomType != spreed.RoomType.oneToOneFormer) || roomName != null, + 'roomName has to be set when roomType is oneToOne', + ); + + final spreed.RoomType roomType; + final String? roomName; + final Color? backgroundColor; + final Color? foregroundColor; + + @override + Widget build(final BuildContext context) { + if (roomType == spreed.RoomType.oneToOne || roomType == spreed.RoomType.oneToOneFormer) { + return NeonUserAvatar( + username: roomName, + account: NeonProvider.of(context).activeAccount.value!, + backgroundColor: backgroundColor, + foregroundColor: foregroundColor, + ); + } + + if (roomType == spreed.RoomType.changelog) { + return CircleAvatar( + radius: smallIconSize, + backgroundColor: backgroundColor ?? Theme.of(context).colorScheme.primary, + child: VectorGraphic( + width: smallIconSize, + height: smallIconSize, + colorFilter: ColorFilter.mode(foregroundColor ?? Theme.of(context).colorScheme.onPrimary, BlendMode.srcIn), + loader: const AssetBytesLoader( + 'assets/app.svg.vec', + packageName: 'neon_spreed', + ), + semanticsLabel: NeonLocalizations.of(context).nextcloudLogo, + ), + ); + } + + if (roomType == spreed.RoomType.group || roomType == spreed.RoomType.public) { + return NeonGroupAvatar( + icon: roomType == spreed.RoomType.group ? Icons.group : Icons.public, + backgroundColor: backgroundColor, + foregroundColor: foregroundColor, + ); + } + + throw UnimplementedError('Room type $roomType has no implemented icon'); + } +} diff --git a/packages/neon/neon_spreed/lib/widgets/screen_preview.dart b/packages/neon/neon_spreed/lib/widgets/screen_preview.dart new file mode 100644 index 00000000..67a35fbf --- /dev/null +++ b/packages/neon/neon_spreed/lib/widgets/screen_preview.dart @@ -0,0 +1,60 @@ +part of '../neon_spreed.dart'; + +class SpreedScreenPreview extends StatefulWidget { + const SpreedScreenPreview({ + required this.source, + super.key, + }); + + final DesktopCapturerSource source; + + @override + State createState() => _SpreedScreenPreviewState(); +} + +class _SpreedScreenPreviewState extends State { + late final List> subscriptions = []; + + @override + void initState() { + super.initState(); + subscriptions.addAll([ + widget.source.onThumbnailChanged.stream.listen((final _) => setState(() {})), + widget.source.onNameChanged.stream.listen((final _) => setState(() {})), + ]); + } + + @override + void dispose() { + for (final subscription in subscriptions) { + unawaited(subscription.cancel()); + } + + super.dispose(); + } + + @override + Widget build(final BuildContext context) => Column( + children: [ + if (widget.source.thumbnail != null) ...[ + AspectRatio( + aspectRatio: 3 / 2, + child: Image.memory( + widget.source.thumbnail!, + gaplessPlayback: true, + fit: BoxFit.contain, + ), + ), + ], + Text( + widget.source.name, + maxLines: 2, + overflow: TextOverflow.ellipsis, + textAlign: TextAlign.center, + style: const TextStyle( + fontWeight: FontWeight.bold, + ), + ), + ], + ); +} diff --git a/packages/neon/neon_spreed/mono_pkg.yaml b/packages/neon/neon_spreed/mono_pkg.yaml new file mode 100644 index 00000000..60bc3bfd --- /dev/null +++ b/packages/neon/neon_spreed/mono_pkg.yaml @@ -0,0 +1,7 @@ +sdk: + - stable + +stages: + - all: + - analyze: --fatal-infos . + - format: --output=none --set-exit-if-changed --line-length 120 . diff --git a/packages/neon/neon_spreed/pubspec.yaml b/packages/neon/neon_spreed/pubspec.yaml new file mode 100644 index 00000000..f48bc633 --- /dev/null +++ b/packages/neon/neon_spreed/pubspec.yaml @@ -0,0 +1,45 @@ +name: neon_spreed +version: 1.0.0 +publish_to: 'none' + +environment: + sdk: '>=3.1.3 <4.0.0' + flutter: '>=3.13.6' + +dependencies: + built_collection: ^5.0.0 + collection: ^1.0.0 + flutter: + sdk: flutter + flutter_chat_types: ^3.6.2 + flutter_chat_ui: + git: + url: https://github.com/flyerhq/flutter_chat_ui + ref: ab50f411da781a078fc3c5197f14bbf9614d001c + flutter_material_design_icons: ^1.0.0 + flutter_webrtc: ^0.9.3 + go_router: ^12.0.0 + intersperse: ^2.0.0 + neon: + git: + url: https://github.com/nextcloud/neon + path: packages/neon/neon + nextcloud: + git: + url: https://github.com/nextcloud/neon + path: packages/nextcloud + rxdart: ^0.27.0 + vector_graphics: ^1.0.0 + +dev_dependencies: + build_runner: ^2.4.6 + go_router_builder: ^2.3.4 + neon_lints: + git: + url: https://github.com/nextcloud/neon + path: packages/neon_lints + +flutter: + uses-material-design: true + assets: + - assets/ diff --git a/packages/neon/neon_spreed/pubspec_overrides.yaml b/packages/neon/neon_spreed/pubspec_overrides.yaml new file mode 100644 index 00000000..3bec69c6 --- /dev/null +++ b/packages/neon/neon_spreed/pubspec_overrides.yaml @@ -0,0 +1,12 @@ +# melos_managed_dependency_overrides: dynamite_runtime,neon,nextcloud,sort_box,neon_lints +dependency_overrides: + dynamite_runtime: + path: ../../dynamite/dynamite_runtime + neon: + path: ../neon + neon_lints: + path: ../../neon_lints + nextcloud: + path: ../../nextcloud + sort_box: + path: ../../sort_box