diff --git a/.github/workflows/dart.yml b/.github/workflows/dart.yml index de6bf1291fe..820c4608b94 100644 --- a/.github/workflows/dart.yml +++ b/.github/workflows/dart.yml @@ -325,6 +325,38 @@ jobs: needs: - job_001 job_011: + name: "all; PKG: packages/neon/neon_spreed; `dart format --output=none --set-exit-if-changed --line-length 120 .`" + runs-on: ubuntu-latest + steps: + - name: Cache Pub hosted dependencies + uses: actions/cache@88522ab9f39a2ea568f7027eddc7d8d8bc9d59c8 + with: + path: "~/.pub-cache/hosted" + key: "os:ubuntu-latest;pub-cache-hosted;sdk:stable;packages:packages/neon/neon_spreed;commands:format" + restore-keys: | + os:ubuntu-latest;pub-cache-hosted;sdk:stable;packages:packages/neon/neon_spreed + os:ubuntu-latest;pub-cache-hosted;sdk:stable + os:ubuntu-latest;pub-cache-hosted + os:ubuntu-latest + - name: Setup Flutter SDK + uses: subosito/flutter-action@48cafc24713cca54bbe03cdc3a423187d413aafa + with: + channel: stable + - id: checkout + name: Checkout repository + uses: actions/checkout@8e5e7e5ab8b370d6c329ec480221332ada57f0ab + - id: packages_neon_neon_spreed_pub_upgrade + name: packages/neon/neon_spreed; flutter pub upgrade + run: flutter pub upgrade + if: "always() && steps.checkout.conclusion == 'success'" + working-directory: packages/neon/neon_spreed + - name: "packages/neon/neon_spreed; dart format --output=none --set-exit-if-changed --line-length 120 ." + run: "dart format --output=none --set-exit-if-changed --line-length 120 ." + if: "always() && steps.packages_neon_neon_spreed_pub_upgrade.conclusion == 'success'" + working-directory: packages/neon/neon_spreed + needs: + - job_001 + job_012: name: "all; PKG: packages/nextcloud; `dart format --output=none --set-exit-if-changed --line-length 120 .`" runs-on: ubuntu-latest steps: @@ -356,7 +388,7 @@ jobs: working-directory: packages/nextcloud needs: - job_001 - job_012: + job_013: name: "all; PKG: packages/settings; `dart format --output=none --set-exit-if-changed --line-length 120 .`" runs-on: ubuntu-latest steps: @@ -388,7 +420,7 @@ jobs: working-directory: packages/settings needs: - job_001 - job_013: + job_014: name: "all; PKG: packages/sort_box; `dart format --output=none --set-exit-if-changed --line-length 120 .`" runs-on: ubuntu-latest steps: @@ -420,7 +452,7 @@ jobs: working-directory: packages/sort_box needs: - job_001 - job_014: + job_015: name: "all; PKG: packages/spec_templates; `dart format --output=none --set-exit-if-changed --line-length 120 .`" runs-on: ubuntu-latest steps: @@ -452,7 +484,7 @@ jobs: working-directory: packages/spec_templates needs: - job_001 - job_015: + job_016: name: "all; PKG: packages/app; `flutter analyze --fatal-infos .`" runs-on: ubuntu-latest steps: @@ -484,7 +516,7 @@ jobs: working-directory: packages/app needs: - job_001 - job_016: + job_017: name: "all; PKG: packages/file_icons; `flutter analyze --fatal-infos .`" runs-on: ubuntu-latest steps: @@ -516,7 +548,7 @@ jobs: working-directory: packages/file_icons needs: - job_001 - job_017: + job_018: name: "all; PKG: packages/neon/neon; `flutter analyze --fatal-infos .`" runs-on: ubuntu-latest steps: @@ -548,7 +580,7 @@ jobs: working-directory: packages/neon/neon needs: - job_001 - job_018: + job_019: name: "all; PKG: packages/neon/neon_files; `flutter analyze --fatal-infos .`" runs-on: ubuntu-latest steps: @@ -580,7 +612,7 @@ jobs: working-directory: packages/neon/neon_files needs: - job_001 - job_019: + job_020: name: "all; PKG: packages/neon/neon_news; `flutter analyze --fatal-infos .`" runs-on: ubuntu-latest steps: @@ -612,7 +644,7 @@ jobs: working-directory: packages/neon/neon_news needs: - job_001 - job_020: + job_021: name: "all; PKG: packages/neon/neon_notes; `flutter analyze --fatal-infos .`" runs-on: ubuntu-latest steps: @@ -644,7 +676,7 @@ jobs: working-directory: packages/neon/neon_notes needs: - job_001 - job_021: + job_022: name: "all; PKG: packages/neon/neon_notifications; `flutter analyze --fatal-infos .`" runs-on: ubuntu-latest steps: @@ -676,7 +708,39 @@ jobs: working-directory: packages/neon/neon_notifications needs: - job_001 - job_022: + job_023: + name: "all; PKG: packages/neon/neon_spreed; `flutter analyze --fatal-infos .`" + runs-on: ubuntu-latest + steps: + - name: Cache Pub hosted dependencies + uses: actions/cache@88522ab9f39a2ea568f7027eddc7d8d8bc9d59c8 + with: + path: "~/.pub-cache/hosted" + key: "os:ubuntu-latest;pub-cache-hosted;sdk:stable;packages:packages/neon/neon_spreed;commands:analyze_0" + restore-keys: | + os:ubuntu-latest;pub-cache-hosted;sdk:stable;packages:packages/neon/neon_spreed + os:ubuntu-latest;pub-cache-hosted;sdk:stable + os:ubuntu-latest;pub-cache-hosted + os:ubuntu-latest + - name: Setup Flutter SDK + uses: subosito/flutter-action@48cafc24713cca54bbe03cdc3a423187d413aafa + with: + channel: stable + - id: checkout + name: Checkout repository + uses: actions/checkout@8e5e7e5ab8b370d6c329ec480221332ada57f0ab + - id: packages_neon_neon_spreed_pub_upgrade + name: packages/neon/neon_spreed; flutter pub upgrade + run: flutter pub upgrade + if: "always() && steps.checkout.conclusion == 'success'" + working-directory: packages/neon/neon_spreed + - name: "packages/neon/neon_spreed; flutter analyze --fatal-infos ." + run: flutter analyze --fatal-infos . + if: "always() && steps.packages_neon_neon_spreed_pub_upgrade.conclusion == 'success'" + working-directory: packages/neon/neon_spreed + needs: + - job_001 + job_024: name: "all; PKG: packages/settings; `flutter analyze --fatal-infos .`" runs-on: ubuntu-latest steps: @@ -708,7 +772,7 @@ jobs: working-directory: packages/settings needs: - job_001 - job_023: + job_025: name: "all; PKG: packages/dynamite/dynamite; `dart analyze --fatal-infos .`" runs-on: ubuntu-latest steps: @@ -740,7 +804,7 @@ jobs: working-directory: packages/dynamite/dynamite needs: - job_001 - job_024: + job_026: name: "all; PKG: packages/dynamite/dynamite_runtime; `dart analyze --fatal-infos .`" runs-on: ubuntu-latest steps: @@ -772,7 +836,7 @@ jobs: working-directory: packages/dynamite/dynamite_runtime needs: - job_001 - job_025: + job_027: name: "all; PKG: packages/nextcloud; `dart analyze --fatal-infos .`" runs-on: ubuntu-latest steps: @@ -804,7 +868,7 @@ jobs: working-directory: packages/nextcloud needs: - job_001 - job_026: + job_028: name: "all; PKG: packages/sort_box; `dart analyze --fatal-infos .`" runs-on: ubuntu-latest steps: @@ -836,7 +900,7 @@ jobs: working-directory: packages/sort_box needs: - job_001 - job_027: + job_029: name: "all; PKG: packages/spec_templates; `dart analyze --fatal-infos .`" runs-on: ubuntu-latest steps: @@ -868,7 +932,7 @@ jobs: working-directory: packages/spec_templates needs: - job_001 - job_028: + job_030: name: "all; PKG: packages/neon/neon; `flutter test`" runs-on: ubuntu-latest steps: @@ -900,7 +964,7 @@ jobs: working-directory: packages/neon/neon needs: - job_001 - job_029: + job_031: name: "all; PKG: packages/nextcloud; `dart test`" runs-on: ubuntu-latest steps: @@ -932,7 +996,7 @@ jobs: working-directory: packages/nextcloud needs: - job_001 - job_030: + job_032: name: "all; PKG: packages/sort_box; `dart test`" runs-on: ubuntu-latest steps: diff --git a/README.md b/README.md index 5c467305129..20b04821bec 100644 --- a/README.md +++ b/README.md @@ -17,13 +17,13 @@ See [here](packages/app/README.md) for screenshots. | News | :heavy_check_mark: | | Notes | :heavy_check_mark: | | Notifications | :heavy_check_mark: | +| Talk | :heavy_check_mark: | | Activity | :rocket: | | Calendar | :rocket: | | Contacts | :rocket: | | Cookbook | :rocket: | | Dashboard | :rocket: | | Photos | :rocket: | -| Talk | :rocket: | | Tasks | :rocket: | ## Problems with other clients and how this project tries to solve them diff --git a/docs/architecture.puml b/docs/architecture.puml index c059b2c537d..460bde9c356 100644 --- a/docs/architecture.puml +++ b/docs/architecture.puml @@ -13,6 +13,7 @@ package "App implementations" { component neon_news component neon_notes component neon_notifications + component neon_spreed } package "OpenAPI" { @@ -26,11 +27,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 @@ -41,4 +44,4 @@ neon --> file_icons dynamite --> nextcloud specs --> nextcloud -@enduml \ No newline at end of file +@enduml diff --git a/docs/architecture.svg b/docs/architecture.svg index 17f6d5a4c99..23bb250ac51 100644 --- a/docs/architecture.svg +++ b/docs/architecture.svg @@ -1 +1 @@ -neon frameworkApp implementationsOpenAPIneonnextcloudsettingssort_boxfile_iconsneon_filesneon_newsneon_notesneon_notificationsdynamitespecsapp \ No newline at end of file +neon frameworkApp implementationsOpenAPIneonnextcloudsettingssort_boxfile_iconsneon_filesneon_newsneon_notesneon_notificationsneon_spreeddynamitespecsapp \ 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 7e0d1c06806..ba428891da7 100644 --- a/packages/neon/neon/lib/l10n/en.arb +++ b/packages/neon/neon/lib/l10n/en.arb @@ -1,6 +1,6 @@ { "@@locale": "en", - "appImplementationName": "{app, select, nextcloud{Nextcloud} core{Server} files{Files} news{News} notes{Notes} notifications{Notifications} other{}}", + "appImplementationName": "{app, select, nextcloud{Nextcloud} core{Server} 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 a93ace95118..0689d37fce7 100644 --- a/packages/neon/neon/lib/l10n/localizations.dart +++ b/packages/neon/neon/lib/l10n/localizations.dart @@ -92,7 +92,7 @@ abstract class AppLocalizations { /// No description provided for @appImplementationName. /// /// In en, this message translates to: - /// **'{app, select, nextcloud{Nextcloud} core{Server} files{Files} news{News} notes{Notes} notifications{Notifications} other{}}'** + /// **'{app, select, nextcloud{Nextcloud} core{Server} 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 4e8f59fc4bd..be55cca6964 100644 --- a/packages/neon/neon/lib/l10n/localizations_en.dart +++ b/packages/neon/neon/lib/l10n/localizations_en.dart @@ -17,6 +17,7 @@ class AppLocalizationsEn extends AppLocalizations { 'news': 'News', 'notes': 'Notes', 'notifications': 'Notifications', + 'spreed': 'Talk', 'other': '', }, ); diff --git a/packages/neon/neon_spreed/.gitignore b/packages/neon/neon_spreed/.gitignore new file mode 100644 index 00000000000..7944852f9fa --- /dev/null +++ b/packages/neon/neon_spreed/.gitignore @@ -0,0 +1,48 @@ +# Miscellaneous +*.class +*.log +*.pyc +*.swp +.DS_Store +.atom/ +.buildlog/ +.history +.svn/ + +# IntelliJ related +*.iml +*.ipr +*.iws +.idea/ + +# The .vscode folder contains launch configuration and tasks you configure in +# VS Code which you may wish to be included in version control, so this line +# is commented out by default. +#.vscode/ + +# Flutter/Dart/Pub related +# Libraries should not include pubspec.lock, per https://dart.dev/guides/libraries/private-files#pubspeclock. +/pubspec.lock +**/doc/api/ +**/ios/Flutter/.last_build_id +.dart_tool/ +.flutter-plugins +.flutter-plugins-dependencies +.packages +.pub-cache/ +.pub/ +/build/ + +# Web related +lib/generated_plugin_registrant.dart + +# Symbolication related +app.*.symbols + +# Obfuscation related +app.*.map.json + +# Android Studio will place build artifacts here +/android/app/debug +/android/app/profile +/android/app/release diff --git a/packages/neon/neon_spreed/.metadata b/packages/neon/neon_spreed/.metadata new file mode 100644 index 00000000000..8cef0eadcfb --- /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: 62bd79521d8d007524e351747471ba66696fc2d4 + channel: stable + +project_type: package diff --git a/packages/neon/neon_spreed/LICENSE b/packages/neon/neon_spreed/LICENSE new file mode 100644 index 00000000000..f288702d2fa --- /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 00000000000..b5cc8bc5418 --- /dev/null +++ b/packages/neon/neon_spreed/analysis_options.yaml @@ -0,0 +1,5 @@ +include: package:nit_picking/flutter.yaml + +analyzer: + exclude: + - lib/l10n/** diff --git a/packages/neon/neon_spreed/assets/app.svg b/packages/neon/neon_spreed/assets/app.svg new file mode 100644 index 00000000000..01f1ec6a9a5 --- /dev/null +++ b/packages/neon/neon_spreed/assets/app.svg @@ -0,0 +1 @@ + diff --git a/packages/neon/neon_spreed/l10n.yaml b/packages/neon/neon_spreed/l10n.yaml new file mode 120000 index 00000000000..fe3fb3e0dab --- /dev/null +++ b/packages/neon/neon_spreed/l10n.yaml @@ -0,0 +1 @@ +../neon/l10n.yaml \ No newline at end of file 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 00000000000..6e00eabc687 --- /dev/null +++ b/packages/neon/neon_spreed/lib/blocs/call.dart @@ -0,0 +1,478 @@ +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 NextcloudSpreedSignalingSettings _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.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.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.sendSignalingMessages( + token: _roomToken, + messages: ContentString( + (final b) => b + ..content = BuiltList([ + NextcloudSendSignalingMessagesMessages( + (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.pullSignalingMessages(token: _roomToken)).ocs.data.toList(); + } on Exception catch (e, s) { + if (e is NextcloudApiException && 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; + break; + case 'audio': + track.enabled = audioEnabled.value; + break; + 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 { + NextcloudSpreedSignalingMuteMessage_Payload_Name.audio: audioEnabled.value, + NextcloudSpreedSignalingMuteMessage_Payload_Name.video: videoEnabled.value, + }.entries) ...[ + NextcloudSpreedSignalingMessage( + (final b) => b + ..spreedSignalingMuteMessage = NextcloudSpreedSignalingMuteMessage( + (final b) => b + ..from = _sessionID + ..to = remoteParticipant.sessionID + ..type = entry.value + ? NextcloudSpreedSignalingMessageType.unmute + : NextcloudSpreedSignalingMessageType.mute + ..payload = NextcloudSpreedSignalingMuteMessage_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([ + NextcloudSpreedSignalingMessage( + (final b) => b + ..spreedSignalingSessionDescriptionMessage = NextcloudSpreedSignalingSessionDescriptionMessage( + (final b) => b + ..from = _sessionID + ..to = remoteParticipant.sessionID + ..type = NextcloudSpreedSignalingMessageType.offer + ..payload = NextcloudSpreedSignalingSessionDescriptionMessage_Payload( + (final b) => b + ..type = NextcloudSpreedSignalingSessionDescriptionMessage_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([ + NextcloudSpreedSignalingMessage( + (final b) => b + ..spreedSignalingICECandidateMessage = NextcloudSpreedSignalingICECandidateMessage( + (final b) => b + ..from = _sessionID + ..to = remoteParticipant.sessionID + ..type = NextcloudSpreedSignalingMessageType.answer + ..payload = NextcloudSpreedSignalingICECandidateMessage_Payload( + (final b) => b + ..candidate = NextcloudSpreedSignalingICECandidateMessage_Payload_Candidate( + (final b) => b + ..candidate = candidate.candidate + ..sdpMid = candidate.sdpMid + ..sdpMLineIndex = candidate.sdpMLineIndex, + ).toBuilder(), + ).toBuilder(), + ).toBuilder(), + ), + ]); + } + ..onIceGatheringState = (final state) { + print(state); + } + ..onIceConnectionState = (final state) { + print(state); + } + ..onConnectionState = (final state) { + print(state); + }; + 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.spreedSignalingUsersInRoom != null) { + final users = message.spreedSignalingUsersInRoom!.data + .where((final user) => user.inCallFlags.contains(SpreedInCallFlag.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.spreedSignalingMessageWrapper != null) { + final signalingMessage = message.spreedSignalingMessageWrapper!.data.content; + + if (signalingMessage.spreedSignalingSessionDescriptionMessage != null) { + final remoteSDP = signalingMessage.spreedSignalingSessionDescriptionMessage!; + + await _updateRemoteParticipant(remoteSDP.from, (final remoteParticipant) async { + switch (remoteSDP.payload.type) { + case NextcloudSpreedSignalingSessionDescriptionMessage_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([ + NextcloudSpreedSignalingMessage( + (final b) => b + ..spreedSignalingSessionDescriptionMessage = NextcloudSpreedSignalingSessionDescriptionMessage( + (final b) => b + ..from = _sessionID + ..to = remoteParticipant.sessionID + ..type = NextcloudSpreedSignalingMessageType.answer + ..payload = NextcloudSpreedSignalingSessionDescriptionMessage_Payload( + (final b) => b + ..type = NextcloudSpreedSignalingSessionDescriptionMessage_Payload_Type.answer + ..sdp = localSDP.sdp + ..nick = '', + ).toBuilder(), + ).toBuilder(), + ), + ..._generateMuteMessages([remoteParticipant]), + ]); + break; + case NextcloudSpreedSignalingSessionDescriptionMessage_Payload_Type.answer: + debugPrint('Received answer from ${remoteParticipant.userID} ${remoteParticipant.sessionID}'); + } + + return remoteParticipant; + }); + + continue; + } + + if (signalingMessage.spreedSignalingICECandidateMessage != null) { + final iceCandidateMessage = signalingMessage.spreedSignalingICECandidateMessage!; + 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.spreedSignalingMuteMessage != null) { + final muteMessage = signalingMessage.spreedSignalingMuteMessage!; + + await _updateRemoteParticipant(muteMessage.from, (final remoteParticipant) async { + final isUnmute = muteMessage.type == NextcloudSpreedSignalingMessageType.unmute; + switch (muteMessage.payload.name) { + case NextcloudSpreedSignalingMuteMessage_Payload_Name.audio: + remoteParticipant.audioEnabled = isUnmute; + break; + case NextcloudSpreedSignalingMuteMessage_Payload_Name.video: + remoteParticipant.videoEnabled = isUnmute; + break; + } + 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 00000000000..5752456e589 --- /dev/null +++ b/packages/neon/neon_spreed/lib/blocs/room.dart @@ -0,0 +1,175 @@ +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._requestManager, + this.client, + final NextcloudSpreedRoom r, + ) { + roomToken = r.token; + room.add(Result.success(r)); + + unawaited(refresh()); + } + + final SpreedAppSpecificOptions options; + final RequestManager _requestManager; + final NextcloudClient client; + 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.wrapNextcloud( + client.id, + 'spreed-room-$roomToken', + room, + () async => client.spreed.joinRoom(token: roomToken), + (final response) => response.ocs.data, + ); + await _loadMessages(force: true); + } + + @override + // ignore: avoid_void_async + void sendMessage(final String message) async { + try { + sendingMessage.add(message); + await client.spreed.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 client.spreed.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, + loading: true, + cached: true, + ), + ); + final data = await client.spreed.getMessages( + token: roomToken, + lookIntoFuture: 0, + includeLastKnown: 1, + limit: _limit, + lastKnownMessageId: (force ? null : _lastKnownMessageId) ?? 0, + lastCommonReadId: lastCommonReadMessageId.valueOrNull ?? 0, + ); + + _lastKnownMessageId = data.headers.xChatLastGiven; + lastCommonReadMessageId.add(data.headers.xChatLastCommonRead); + + if (data.data.ocs.data.length < _limit) { + allLoaded.add(true); + } + + messages.add( + Result.success( + { + if (previousData != null) ..._messagesToUniqueMap(previousData), + ..._messagesToUniqueMap(data.data.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, + loading: false, + cached: 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 00000000000..7a4a8773420 --- /dev/null +++ b/packages/neon/neon_spreed/lib/blocs/spreed.dart @@ -0,0 +1,77 @@ +part of '../neon_spreed.dart'; + +abstract class SpreedBlocEvents { + void createRoom( + final SpreedRoomType type, + final String? roomName, + final NextcloudCoreAutocompleteResult_Ocs_Data? invite, + ); +} + +abstract class SpreedBlocStates { + BehaviorSubject>> get rooms; + + BehaviorSubject get unreadCounter; +} + +class SpreedBloc extends InteractiveBloc implements SpreedBlocEvents, SpreedBlocStates { + SpreedBloc( + this.options, + this._requestManager, + this.client, + ) { + rooms.listen((final result) { + if (result.data != null) { + unreadCounter.add( + [0, ...result.data!.map((final room) => room.unreadMessages)].reduce((final a, final b) => a + b), + ); + } + }); + + unawaited(refresh()); + } + + final SpreedAppSpecificOptions options; + final RequestManager _requestManager; + final NextcloudClient client; + + @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.wrapNextcloud, NextcloudSpreedGetRooms>( + client.id, + 'spreed-rooms', + rooms, + () async => client.spreed.getRooms(), + (final response) => response.ocs.data.toList(), + ); + } + + @override + void createRoom( + final SpreedRoomType type, + final String? roomName, + final NextcloudCoreAutocompleteResult_Ocs_Data? invite, + ) { + wrapAction( + () async => client.spreed.createRoom( + roomType: type.code, + 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 00000000000..1a2061fa583 --- /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 = { + SpreedRoomType.oneToOne: AppLocalizations.of(context).roomTypeOneToOne, + SpreedRoomType.group: AppLocalizations.of(context).roomTypeGroup, + SpreedRoomType.public: AppLocalizations.of(context).roomTypePublic, + }; + + final formKey = GlobalKey(); + final controller = TextEditingController(); + final focusNode = FocusNode(); + + SpreedRoomType? selectedType; + NextcloudCoreAutocompleteResult_Ocs_Data? selectedAutocompleteEntry; + + void changeType(final SpreedRoomType? type) { + controller.clear(); + setState(() { + selectedType = type; + }); + } + + void submit() { + if (formKey.currentState!.validate()) { + Navigator.of(context).pop( + SpreedCreateRoomDetails( + selectedType!, + selectedType! == SpreedRoomType.public ? controller.text : null, + selectedType! != SpreedRoomType.public ? selectedAutocompleteEntry : null, + ), + ); + } + } + + @override + Widget build(final BuildContext context) => NeonDialog( + title: Text(AppLocalizations.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 == SpreedRoomType.oneToOne + ? Icons.person + : type == SpreedRoomType.group + ? Icons.group + : Icons.public, + ), + trailing: Radio( + value: type, + groupValue: selectedType, + onChanged: changeType, + ), + onTap: () { + changeType(type); + }, + ), + ], + if (selectedType == SpreedRoomType.oneToOne || selectedType == SpreedRoomType.group) ...[ + NeonAutocomplete( + key: Key(selectedType!.code.toString()), + account: Provider.of(context, listen: false).activeAccount.value!, + itemType: 'call', + itemId: 'new', + shareTypes: [ + if (selectedType == SpreedRoomType.oneToOne) ...[ + ShareType.user.code, + ] else if (selectedType == SpreedRoomType.group) ...[ + ShareType.group.code, + ], + ], + validator: (final input) => validateNotEmpty(context, input), + decoration: InputDecoration( + hintText: selectedType == SpreedRoomType.oneToOne + ? AppLocalizations.of(context).roomCreateUserName + : AppLocalizations.of(context).roomCreateGroupName, + ), + onSelected: (final entry) { + setState(() { + selectedAutocompleteEntry = entry; + }); + }, + onFieldSubmitted: (final _) { + submit(); + }, + ), + ], + if (selectedType == SpreedRoomType.public) ...[ + TextFormField( + controller: controller, + focusNode: focusNode, + validator: (final input) => validateNotEmpty(context, input), + decoration: InputDecoration( + hintText: AppLocalizations.of(context).roomCreateRoomName, + ), + onFieldSubmitted: (final _) { + submit(); + }, + ), + ], + const SizedBox( + height: 10, + ), + ElevatedButton( + onPressed: selectedType == null ? null : submit, + child: Text(AppLocalizations.of(context).roomCreate), + ), + ], + ), + ), + ], + ); +} + +class SpreedCreateRoomDetails { + SpreedCreateRoomDetails( + this.type, + this.roomName, + this.invite, + ); + + final SpreedRoomType type; + + final String? roomName; + + final NextcloudCoreAutocompleteResult_Ocs_Data? 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 00000000000..3d3584b03fc --- /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(AppLocalizations.of(context).screenSharingSelectScreen), + children: [ + if (sources != null) ...[ + for (final sourceType in SourceType.values.reversed) ...[ + Text( + sourceType == SourceType.Screen + ? AppLocalizations.of(context).screenSharingSelectScreenScreens + : AppLocalizations.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(AppLocalizations.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 00000000000..9f6fbda13fb --- /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 00000000000..348ee2b46e7 --- /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 AppLocalizations +/// returned by `AppLocalizations.of(context)`. +/// +/// Applications need to include `AppLocalizations.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: AppLocalizations.localizationsDelegates, +/// supportedLocales: AppLocalizations.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 AppLocalizations.supportedLocales +/// property. +abstract class AppLocalizations { + AppLocalizations(String locale) : localeName = intl.Intl.canonicalizedLocale(locale.toString()); + + final String localeName; + + static AppLocalizations of(BuildContext context) { + return Localizations.of(context, AppLocalizations)!; + } + + static const LocalizationsDelegate delegate = _AppLocalizationsDelegate(); + + /// 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 _AppLocalizationsDelegate extends LocalizationsDelegate { + const _AppLocalizationsDelegate(); + + @override + Future load(Locale locale) { + return SynchronousFuture(lookupAppLocalizations(locale)); + } + + @override + bool isSupported(Locale locale) => ['en'].contains(locale.languageCode); + + @override + bool shouldReload(_AppLocalizationsDelegate old) => false; +} + +AppLocalizations lookupAppLocalizations(Locale locale) { + // Lookup logic when only language code is specified. + switch (locale.languageCode) { + case 'en': + return AppLocalizationsEn(); + } + + throw FlutterError('AppLocalizations.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 00000000000..7f2aca7f578 --- /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 AppLocalizationsEn extends AppLocalizations { + AppLocalizationsEn([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 00000000000..ca8ca6fd072 --- /dev/null +++ b/packages/neon/neon_spreed/lib/neon_spreed.dart @@ -0,0 +1,68 @@ +library files; + +import 'dart:async'; +import 'dart:math'; + +import 'package:built_collection/built_collection.dart'; +import 'package:collection/collection.dart'; +import 'package:dynamite_runtime/content_string.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_svg/flutter_svg.dart'; +import 'package:flutter_webrtc/flutter_webrtc.dart'; +import 'package:intersperse/intersperse.dart'; +import 'package:material_design_icons_flutter/material_design_icons_flutter.dart'; +import 'package:neon/neon.dart'; +import 'package:neon_spreed/l10n/localizations.dart'; +import 'package:nextcloud/nextcloud.dart'; +import 'package:provider/provider.dart'; +import 'package:rxdart/rxdart.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'; + +class SpreedApp extends AppImplementation { + SpreedApp(super.sharedPreferences, super.requestManager, super.platform); + + @override + String id = 'spreed'; + + @override + LocalizationsDelegate localizationsDelegate = AppLocalizations.delegate; + + @override + List supportedLocales = AppLocalizations.supportedLocales; + + @override + SpreedAppSpecificOptions buildOptions(final AppStorage storage) => SpreedAppSpecificOptions(storage); + + @override + SpreedBloc buildBloc(final NextcloudClient client) => SpreedBloc( + options, + requestManager, + client, + ); + + @override + Widget buildPage(final BuildContext context, final AppsBloc appsBloc) => SpreedMainPage( + bloc: appsBloc.getAppBloc(this), + ); + + @override + BehaviorSubject? getUnreadCounter(final AppsBloc appsBloc) => + appsBloc.getAppBloc(this).unreadCounter; +} diff --git a/packages/neon/neon_spreed/lib/options.dart b/packages/neon/neon_spreed/lib/options.dart new file mode 100644 index 00000000000..4e0c1e1c18a --- /dev/null +++ b/packages/neon/neon_spreed/lib/options.dart @@ -0,0 +1,8 @@ +part of 'neon_spreed.dart'; + +class SpreedAppSpecificOptions extends NextcloudAppSpecificOptions { + 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 00000000000..4ccb1cbc922 --- /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; + } + NeonException.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.data!, + 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 00000000000..77498bf6934 --- /dev/null +++ b/packages/neon/neon_spreed/lib/pages/main.dart @@ -0,0 +1,111 @@ +part of '../neon_spreed.dart'; + +class SpreedMainPage extends StatefulWidget { + const SpreedMainPage({ + required this.bloc, + super.key, + }); + + final SpreedBloc bloc; + + @override + State createState() => _SpreedMainPageState(); +} + +class _SpreedMainPageState extends State { + @override + void initState() { + super.initState(); + + widget.bloc.errors.listen((final error) { + NeonException.showSnackbar(context, error); + }); + } + + @override + Widget build(final BuildContext context) => ResultBuilder>( + stream: widget.bloc.rooms, + builder: (final context, final rooms) => Scaffold( + resizeToAvoidBottomInset: false, + body: NeonListView( + scrollKey: 'spreed-rooms', + withFloatingActionButton: true, + items: rooms.data?.sorted((final a, final b) => b.lastActivity.compareTo(a.lastActivity)), + isLoading: rooms.loading, + error: rooms.error, + onRefresh: widget.bloc.refresh, + builder: _buildRoom, + ), + floatingActionButton: FloatingActionButton( + child: const Icon(Icons.add), + onPressed: () async { + final result = await showDialog( + context: context, + builder: (final context) => const SpreedCreateRoomDialog(), + ); + if (result == null) { + return; + } + widget.bloc.createRoom( + result.type, + result.roomName, + result.invite, + ); + }, + ), + ), + ); + + Widget _buildRoom( + final BuildContext context, + final NextcloudSpreedRoom room, + ) => + ListTile( + title: Text(room.displayName), + subtitle: Text( + room.lastMessage != null + ? (room.type == SpreedRoomType.changelog.code || + (room.type == SpreedRoomType.oneToOne.code && + room.lastMessage!.actorId != widget.bloc.client.username) + ? room.lastMessage!.message + : '${room.lastMessage!.actorId == widget.bloc.client.username ? AppLocalizations.of(context).messageYou : room.lastMessage!.actorDisplayName}: ${room.lastMessage!.message}') + : '', + overflow: TextOverflow.ellipsis, + maxLines: 1, + ), + leading: SpreedRoomIcon( + roomType: SpreedRoomType.fromValue(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 bloc = SpreedRoomBloc( + widget.bloc.options, + Provider.of(context, listen: false), + widget.bloc.client, + room, + ); + await Navigator.of(context).push( + MaterialPageRoute( + builder: (final context) => SpreedRoomPage( + bloc: bloc, + ), + ), + ); + await bloc.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 00000000000..e2dd7412c48 --- /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 { + late final platform = Provider.of(context, listen: false); + + 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.client.username!, + ); + + void onSendPressed(final chat_types.PartialText partialText) { + widget.bloc.sendMessage(partialText.text); + } + + Future openCall(final NextcloudSpreedRoom room) async { + try { + final client = Provider.of(context, listen: false).activeAccount.value!.client; + final settings = (await client.spreed.getSignalingSettings(token: widget.bloc.roomToken)).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()); + NeonException.showSnackbar(context, e); + } + } + + @override + void initState() { + super.initState(); + + widget.bloc.errors.listen((final error) { + NeonException.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.data != null ? SpreedRoomType.fromValue(room.data!.type) : null; + return Scaffold( + resizeToAvoidBottomInset: false, + appBar: AppBar( + titleSpacing: 0, + title: Row( + children: [ + if (room.data != null) ...[ + if (roomType!.isSingleUser) ...[ + SpreedRoomIcon( + roomType: roomType, + roomName: room.data!.name, + backgroundColor: Theme.of(context).colorScheme.onPrimary, + foregroundColor: Theme.of(context).colorScheme.primary, + ), + const SizedBox( + width: 10, + ), + ], + Flexible( + child: Text(room.data!.displayName), + ), + ], + if (room.error != null) ...[ + const SizedBox( + width: 8, + ), + Icon( + Icons.error_outline, + size: 30, + color: Theme.of(context).colorScheme.onPrimary, + ), + ], + if (room.loading) ...[ + const SizedBox( + width: 8, + ), + Expanded( + child: NeonLinearProgressIndicator( + color: Theme.of(context).appBarTheme.foregroundColor, + ), + ), + ], + ], + ), + actions: [ + if (room.data != null && room.data!.readOnly == 0) ...[ + if (room.data!.hasCall) ...[ + SpreedCallButton( + type: SpreedCallButtonType.joinCall, + onPressed: () async { + await openCall(room.data!); + }, + ), + ] else if (room.data!.canStartCall) ...[ + SpreedCallButton( + type: SpreedCallButtonType.startCall, + onPressed: () async { + await openCall(room.data!); + }, + ), + ], + ], + ], + ), + 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: Provider.of(context, listen: false).activeAccount.value!, + ), + textMessageBuilder: ( + final message, { + required final messageWidth, + required final showName, + }) { + final matchers = [ + if (message.metadata != null) ...[ + matchNextcloudRichObject( + context, + 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) ...[ + matchNextcloudRichObject( + context, + message.metadata!, + ), + ], + ]; + + return chat_ui.SystemMessage( + message: message.text, + options: chat_ui.TextMessageOptions( + matchers: matchers, + ), + ); + }, + customBottomWidget: Column( + children: [ + NeonException( + messages.error, + onRetry: () async { + await widget.bloc.refresh(); + }, + ), + if (messages.loading) ...[ + 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.data != null) ...[ + chat_types.TextMessage( + id: 'sending', + author: user, + text: sendingMessageSnapshot.data!, + showStatus: true, + status: chat_types.Status.sending, + ), + ], + if (messages.data != null) ...[ + ...messages.data! + .map( + (final message) => _spreedMessageToChatMessage( + message, + lastCommonReadMessageId: lastCommonReadMessageIdSnapshot.data, + ), + ) + .whereNotNull(), + ], + ], + ), + ); + }, + ), + ), + ), + ), + ); + + chat_types.Message? _spreedMessageToChatMessage( + final NextcloudSpreedMessage 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.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 (message.messageType) { + case NextcloudSpreedMessageType.comment: + return chat_types.TextMessage( + id: id, + author: author, + createdAt: createdAt, + repliedMessage: repliedMessage, + text: message.message, + showStatus: true, + status: status, + metadata: metadata, + ); + case NextcloudSpreedMessageType.command: + case NextcloudSpreedMessageType.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/utils/participants.dart b/packages/neon/neon_spreed/lib/utils/participants.dart new file mode 100644 index 00000000000..f7f6318593e --- /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 00000000000..d069a894d94 --- /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 00000000000..535ea9c9219 --- /dev/null +++ b/packages/neon/neon_spreed/lib/widgets/call_button.dart @@ -0,0 +1,57 @@ +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 = AppLocalizations.of(context).callStart; + backgroundColor = null; + break; + case SpreedCallButtonType.joinCall: + icon = Icons.phone; + label = AppLocalizations.of(context).callJoin; + backgroundColor = Colors.green; + break; + case SpreedCallButtonType.leaveCall: + icon = Icons.videocam_off; + label = AppLocalizations.of(context).callLeave; + backgroundColor = Colors.red; + break; + } + 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 00000000000..75224b43f88 --- /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: Provider.of(context, listen: false).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 00000000000..17d1ab0b208 --- /dev/null +++ b/packages/neon/neon_spreed/lib/widgets/room_icon.dart @@ -0,0 +1,55 @@ +part of '../neon_spreed.dart'; + +class SpreedRoomIcon extends StatelessWidget { + const SpreedRoomIcon({ + required this.roomType, + this.roomName, + this.backgroundColor, + this.foregroundColor, + super.key, + }) : assert( + roomType != SpreedRoomType.oneToOne || roomName != null, + 'roomName has to be set when roomType is oneToOne', + ); + + final SpreedRoomType roomType; + final String? roomName; + final Color? backgroundColor; + final Color? foregroundColor; + + @override + Widget build(final BuildContext context) { + if (roomType == SpreedRoomType.oneToOne) { + return NeonUserAvatar( + username: roomType == SpreedRoomType.oneToOne ? roomName : null, + account: Provider.of(context, listen: false).activeAccount.value!, + backgroundColor: backgroundColor, + foregroundColor: foregroundColor, + ); + } + + if (roomType == SpreedRoomType.changelog) { + return CircleAvatar( + radius: kAvatarSize / 2, + backgroundColor: backgroundColor ?? Theme.of(context).colorScheme.primary, + child: SvgPicture.asset( + 'assets/app.svg', + package: 'neon_spreed', + width: kAvatarSize / 2, + height: kAvatarSize / 2, + colorFilter: ColorFilter.mode(foregroundColor ?? Theme.of(context).colorScheme.onPrimary, BlendMode.srcIn), + ), + ); + } + + if (roomType == SpreedRoomType.group || roomType == SpreedRoomType.public) { + return NeonGroupAvatar( + icon: roomType == SpreedRoomType.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 00000000000..b526d5e07ac --- /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 00000000000..60bc3bfd00a --- /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 00000000000..6495c91e2ae --- /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: '>=2.19.0 <3.0.0' + flutter: '>=3.7.9' + +dependencies: + built_collection: ^5.1.1 + collection: ^1.17.1 + dynamite_runtime: + path: ../../dynamite/dynamite_runtime + flutter: + sdk: flutter + flutter_chat_types: 3.6.0 + flutter_chat_ui: + git: + url: https://github.com/provokateurin/flutter_chat_ui + ref: feature/reusable-text-matchers + flutter_svg: ^2.0.5 + flutter_webrtc: ^0.9.29 + intersperse: ^2.0.0 + material_design_icons_flutter: ^6.0.7096 + neon: + git: + url: https://github.com/provokateurin/nextcloud-neon + path: packages/neon/neon + nextcloud: + git: + url: https://github.com/provokateurin/nextcloud-neon + path: packages/nextcloud + provider: ^6.0.5 + rxdart: ^0.27.7 + +dev_dependencies: + nit_picking: + git: + url: https://github.com/stack11/dart_nit_picking + ref: 0b2ee0d + +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 00000000000..7b4559d54d8 --- /dev/null +++ b/packages/neon/neon_spreed/pubspec_overrides.yaml @@ -0,0 +1,12 @@ +# melos_managed_dependency_overrides: dynamite_runtime,neon,nextcloud,settings,sort_box +dependency_overrides: + dynamite_runtime: + path: ../../dynamite/dynamite_runtime + neon: + path: ../neon + nextcloud: + path: ../../nextcloud + settings: + path: ../../settings + sort_box: + path: ../../sort_box