-
Notifications
You must be signed in to change notification settings - Fork 448
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #11334 from nextcloud/ref/noid/migrate-get-partici…
…pants-mixin Refactor(Mixins): Change getParticipants mixin to composable
- Loading branch information
Showing
7 changed files
with
182 additions
and
165 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,136 @@ | ||
| /** | ||
| * @copyright Copyright (c) 2024 Dorra Jaouad <[email protected]> | ||
| * | ||
| * @author Dorra Jaouad <[email protected]> | ||
| * @author Marco Ambrosini <[email protected]> | ||
| * | ||
| * @license AGPL-3.0-or-later | ||
| * | ||
| * This program is free software: you can redistribute it and/or modify | ||
| * it under the terms of the GNU Affero 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 Affero General Public License for more details. | ||
| * | ||
| * You should have received a copy of the GNU Affero General Public License | ||
| * along with this program. If not, see <http://www.gnu.org/licenses/>. | ||
| * | ||
| */ | ||
| import debounce from 'debounce' | ||
| import { ref, nextTick, computed, watch, onBeforeUnmount, onMounted } from 'vue' | ||
|
|
||
| import { subscribe, unsubscribe } from '@nextcloud/event-bus' | ||
|
|
||
| import { useIsInCall } from './useIsInCall.js' | ||
| import { useStore } from './useStore.js' | ||
| import { CONVERSATION } from '../constants.js' | ||
| import { EventBus } from '../services/EventBus.js' | ||
|
|
||
| /** | ||
| * @param {import('vue').Ref} isActive whether the participants tab is active | ||
| * @param {boolean} isTopBar whether the component is the top bar | ||
| */ | ||
| export function useGetParticipants(isActive = ref(true), isTopBar = true) { | ||
|
|
||
| // Encapsulation | ||
| const store = useStore() | ||
| const token = computed(() => store.getters.getToken()) | ||
| const conversation = computed(() => store.getters.conversation(token.value)) | ||
| const isInCall = useIsInCall() | ||
| const isOneToOneConversation = computed(() => conversation.value?.type === CONVERSATION.TYPE.ONE_TO_ONE) | ||
| let fetchingParticipants = false | ||
| let pendingChanges = true | ||
|
|
||
| /** | ||
| * Initialise the get participants listeners | ||
| * | ||
| */ | ||
| function initialiseGetParticipants() { | ||
| EventBus.$on('joined-conversation', onJoinedConversation) | ||
|
|
||
| // FIXME this works only temporary until signaling is fixed to be only on the calls | ||
| // Then we have to search for another solution. Maybe the room list which we update | ||
| // periodically gets a hash of all online sessions? | ||
| EventBus.$on('signaling-participant-list-changed', debounceUpdateParticipants) | ||
| subscribe('guest-promoted', onJoinedConversation) | ||
| } | ||
|
|
||
| /** | ||
| * Stop the get participants listeners | ||
| * | ||
| */ | ||
| function stopGetParticipants() { | ||
| EventBus.$off('joined-conversation', onJoinedConversation) | ||
| EventBus.$off('signaling-participant-list-changed', debounceUpdateParticipants) | ||
| unsubscribe('guest-promoted', onJoinedConversation) | ||
| } | ||
|
|
||
| const onJoinedConversation = () => { | ||
| if (isOneToOneConversation.value) { | ||
| cancelableGetParticipants() | ||
| } else { | ||
| nextTick(() => debounceUpdateParticipants()) | ||
| } | ||
| } | ||
|
|
||
| const debounceUpdateParticipants = () => { | ||
| if (!isActive.value && !isInCall.value) { | ||
| // Update is ignored but there is a flag to force the participants update | ||
| pendingChanges = true | ||
| return | ||
| } | ||
|
|
||
| if (store.getters.windowIsVisible() && (isInCall.value || !conversation.value?.hasCall)) { | ||
| debounceFastUpdateParticipants() | ||
| } else { | ||
| debounceSlowUpdateParticipants() | ||
| } | ||
| pendingChanges = false | ||
| } | ||
|
|
||
| const cancelableGetParticipants = async () => { | ||
| const isInLobby = store.getters.isInLobby | ||
| const isModeratorOrUser = store.getters.isModeratorOrUser | ||
| if (fetchingParticipants || token.value === '' || isInLobby || !isModeratorOrUser) { | ||
| return | ||
| } | ||
|
|
||
| fetchingParticipants = true | ||
| debounceFastUpdateParticipants.clear() | ||
| debounceSlowUpdateParticipants.clear() | ||
|
|
||
| await store.dispatch('fetchParticipants', { token: token.value }) | ||
| fetchingParticipants = false | ||
| } | ||
|
|
||
| const debounceFastUpdateParticipants = debounce( | ||
| cancelableGetParticipants, 3000) | ||
| const debounceSlowUpdateParticipants = debounce( | ||
| cancelableGetParticipants, 15000) | ||
|
|
||
| onMounted(() => { | ||
| if (isTopBar) { | ||
| initialiseGetParticipants() | ||
| } | ||
| }) | ||
|
|
||
| watch(isActive, (newValue) => { | ||
| if (newValue && pendingChanges) { | ||
| debounceUpdateParticipants() | ||
| } | ||
| }) | ||
|
|
||
| onBeforeUnmount(() => { | ||
| if (isTopBar) { | ||
| stopGetParticipants() | ||
| } | ||
| }) | ||
|
|
||
| return { | ||
| cancelableGetParticipants, | ||
| } | ||
| } |
Oops, something went wrong.