/* Metro module 12603; source: stores/RTCConnectionDesyncStore.tsx; dependencies: [6, 7, 15, 17, 18, 4298, 1379, 4294, 1878, 4297, 4300, 661, 4299, 4268, 4617, 4618, 4406, 566, 694, 2] */
import ClassCallCheck from '../by-id/module-00006-ClassCallCheck.js'; /* Metro dependency 6 */
import CreateClass from '../by-id/module-00007-CreateClass.js'; /* Metro dependency 7 */
import PossibleConstructorReturn from '../by-id/module-00015-PossibleConstructorReturn.js'; /* Metro dependency 15 */
import Module00017 from '../by-id/module-00017.js'; /* Metro dependency 17 */
import Inherits from '../by-id/module-00018-Inherits.js'; /* Metro dependency 18 */
import Flux from '../external/discord_common/js/packages/flux/index.tsx'; /* Metro dependency 566 */
import ChannelStore from './ChannelStore.tsx'; /* Metro dependency 1379 */
import UserStore from './UserStore.tsx'; /* Metro dependency 1878 */
import RTCConnectionStore from './RTCConnectionStore.tsx'; /* Metro dependency 4294 */
import VoiceStateStore from './VoiceStateStore.tsx'; /* Metro dependency 4297 */
import VoiceStateRecord from '../records/VoiceStateRecord.tsx'; /* Metro dependency 4298 */
import * as FileImportTrackerModule from '../by-id/module-00002-FileImportTracker.js'; /* Metro dependency 2 */
import * as ConstantsModule from '../Constants.tsx'; /* Metro dependency 661 */
import * as CallConstantsModule from '../modules/calls/CallConstants.tsx'; /* Metro dependency 4299 */
import * as SortedVoiceStateStoreModule from './views/SortedVoiceStateStore.tsx'; /* Metro dependency 4300 */
import * as MediaEngineModule from '../external/discord_common/js/packages/media-engine/index.tsx'; /* Metro dependency 4406 */

function _fun96668(global, require, importDefault, importAll, module, exports, dependencyMap) { // fn#96668, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:12793:6, offset: 0x02163050, size: 629 bytes, params: 8, frame: 21
    const env0_0 = require;
    const VOICE_CHANNEL_SELECT_966762 = VOICE_CHANNEL_SELECT_96676;
    const Object = global.Object;
    Object.defineProperty(exports, '__esModule', {value: true});
    let value = ConstantsModule;
    const env0_14 = value.ME;
    const env0_15 = value.RTCConnectionStates;
    value = importDefault(4268) /* metro dependency 4268: CachedEntriesMap */;
    value = new value();
    value = importDefault(4268) /* metro dependency 4268: CachedEntriesMap */;
    value = new value();
    const Set = global.Set;
    let set = new Set();
    const Store = (Flux).Store;
    _fun96677(Store).displayName = 'RTCConnectionDesyncStore';
    set = new set(importDefault(694) /* metro dependency 694: Dispatcher */, {CONNECTION_OPEN: function() {
        VOICE_CHANNEL_SELECT_96676();
    }, VOICE_CHANNEL_SELECT: VOICE_CHANNEL_SELECT_966762, RTC_CONNECTION_STATE: function({state, context}) {
        var r1;
        var r0;
        var value4;
        var value2 = undefined;
        var value3 = context === require(dependencyMap[16]).MediaEngineContextTypes.DEFAULT;
        if (value3) {
            value4 = state === RTCConnectionStates.DISCONNECTED;
            if (value4) {
                VOICE_CHANNEL_SELECT_96676();
                r1 = value2;
            } else {
                r1 = value4;
            }
            r0 = r1;
        } else {
            r0 = value3;
        }
        return r0;
    }, VOICE_STATE_UPDATES: VOICE_STATE_UPDATES_96686,
        RTC_CONNECTION_CLIENT_CONNECT: RTC_CONNECTION_CLIENT_CONNECT_96688,
        RTC_CONNECTION_CLIENT_DISCONNECT: RTC_CONNECTION_CLIENT_DISCONNECT});
    (FileImportTrackerModule).fileFinishedImporting('stores/RTCConnectionDesyncStore.tsx');
    exports.default = set;
    function _isNativeReflectConstruct_96669() { // fn#96669, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:12793:300, offset: 0x021632c5, size: 98 bytes, params: 1, frame: 18
        var Boolean;
        var prototype;
        var valueOf;
        var call;
        var Reflect;
        var construct;
        var closure;
        var value;
        var error;
        try {
            Boolean = global.Boolean;
            prototype = Boolean.prototype;
            valueOf = prototype.valueOf;
            call = valueOf.call;
            Reflect = global.Reflect;
            construct = Reflect.construct;
            Boolean = global.Boolean;
            closure = function() {
            };
            value = Reflect.apply(construct, Reflect, [Boolean, [], closure]);
            value = Reflect.apply(call, valueOf, [value]);
            var result = !value;
        } catch (error) {
        }
        return (_isNativeReflectConstruct_96669_isNativeReflectConstruct = function() {
            return !!result;
        })();
    }

    function upsert_96672(a0, a1, a2) { // fn#96672, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:12793:539, offset: 0x02163327, size: 276 bytes, params: 4, frame: 21
        const value = a1;
        const voiceStateRecord2 = new VoiceStateRecord({userId: a0.id, channelId: a2});
        const sortedVoiceState = makeSortedVoiceState(voiceStateRecord2, value ?? ME, a0.id);
        let binding = env0_17;
        binding.set(a0.id, sortedVoiceState);
        object = {};
        const USER = ParticipantTypes.USER;
        object.type = USER;
        object.user = a0;
        object.id = a0.id;
        object.streamId = null;
        object.voiceState = voiceStateRecord2;
        object.voicePlatform = null;
        object.speaking = false;
        object.lastSpoke = 0;
        object.soundsharing = false;
        object.ringing = false;
        object.userNick = (importDefault(4617) /* metro dependency 4617: NicknameUtils */).getName(value, a2, a0);
        object.userAvatarDecoration = (require(4618) /* metro dependency 4618: useAvatarDecoration */).getAvatarDecoration(a0,
            value);
        object.localVideoDisabled = false;
        object.isPoppedOut = false;
        binding = env0_18;
        binding.set(a0.id, object);
    }

    function deleteUserDesyncData(a0) { // fn#96673, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:12793:910, offset: 0x0216343b, size: 62 bytes, params: 2, frame: 13
        const value2 = env0_17.delete(a0);
        const value3 = env0_18.delete(a0);
        const value = env0_19.delete(a0);
        let r0 = value2 || value3;
        r0 = !r0 ? value : r0;
        return r0;
    }

    function retryFailedUsers() { // fn#96674, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:12793:1004, offset: 0x02163479, size: 103 bytes, params: 1, frame: 14
        var value5;
        const channelId = RTCConnectionStore.getChannelId();
        if (channelId == null) {
            return false;
        }
        const channel = ChannelStore.getChannel(channelId);
        if (channel != null) {
            value5 = channel.getGuildId();
        }
        const env0_2 = false;
        env0_19.forEach(_fun96675);
        return env0_2;
        function _fun96675(a0) { // fn#96675, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:12793:1154, offset: 0x021634e0, size: 115 bytes, params: 2, frame: 16
            var binding;
            var user;
            var upsert_96672Binding;
            if (VoiceStateStore.getVoiceStateForChannel(env0_0, a0) == null) {
                user = UserStore.getUser(a0);
                if (user != null) {
                    binding = env1_19;
                    binding.delete(a0);
                    upsert_96672Binding = upsert_96672;
                    binding = env0_1;
                    upsert_96672Binding(user, binding, env0_0);
                }
            } else {
                env1_19.delete(a0);
            }
        }

    }

    function VOICE_CHANNEL_SELECT_96676() { // fn#96676, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:12793:1282, offset: 0x02163553, size: 49 bytes, params: 1, frame: 10
        env0_17.clear();
        env0_18.clear();
        env0_19.clear();
    }

    function _fun96677(a0) { // fn#96677, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:12793:1341, offset: 0x02163584, size: 180 bytes, params: 2, frame: 16
        const RTCConnectionDesyncStore2 = RTCConnectionDesyncStore;
        Inherits(RTCConnectionDesyncStore2, a0);
        return CreateClass(RTCConnectionDesyncStore2, [{key: 'initialize', value: function() {
            this.waitFor(VoiceStateStore, UserStore, ChannelStore, RTCConnectionStore);
            this.syncWith([UserStore], retryFailedUsers);
        }}, {key: 'desyncedVoiceStatesCount', get: get_96680}, {key: 'getDesyncedUserIds', value: value_96681},
            {key: 'getDesyncedVoiceStates', value: value_96682}, {key: 'getDesyncedParticipants', value: value_96683}]);
        function RTCConnectionDesyncStore() { // fn#96678, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:12793:1353, offset: 0x01121ae9, size: 113 bytes, params: 1, frame: 20
            const value = environment.__proto__;
            env1_3(this, RTCConnectionDesyncStore);
            const value3 = env1_6(RTCConnectionDesyncStore);
            return env1_5(this, _isNativeReflectConstruct_96669() ? global.Reflect.construct(value3, arguments,
                env1_6(this).constructor) : value3.apply(this, arguments));
        }

        function get_96680() { // fn#96680, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:12793:1798, offset: 0x0216367b, size: 18 bytes, params: 1, frame: 9
            return env1_17.size();
        }

        function value_96681() { // fn#96681, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:12793:1859, offset: 0x0216368d, size: 18 bytes, params: 1, frame: 9
            return env1_17.keys();
        }

        function value_96682() { // fn#96682, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:12793:1924, offset: 0x0216369f, size: 18 bytes, params: 1, frame: 9
            return env1_17.values();
        }

        function value_96683() { // fn#96683, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:12793:1992, offset: 0x021636b1, size: 18 bytes, params: 1, frame: 9
            return env1_18.values();
        }

    }

    function VOICE_STATE_UPDATES_96686({voiceStates}) { // fn#96686, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:12793:2392, offset: 0x0216372b, size: 64 bytes, params: 2, frame: 14
        let value = RTCConnectionStore.getChannelId();
        value = value != null;
        return value && voiceStates.reduce(_fun96687, false);
        function _fun96687(a0, {userId, channelId}) { // fn#96687, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:12793:2491, offset: 0x0216376b, size: 58 bytes, params: 3, frame: 13
            const value = a0;
            let r0 = channelId === env0_0 && !!deleteUserDesyncData(userId);
            r0 = !r0 ? value : r0;
            return r0;
        }

    }

    function RTC_CONNECTION_CLIENT_CONNECT_96688({userIds, guildId, channelId, context}) { // fn#96688, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:12793:2591, offset: 0x021637a5, size: 101 bytes, params: 2, frame: 15
        const MediaEngineContextTypes = (MediaEngineModule).MediaEngineContextTypes;
        const DEFAULT = MediaEngineContextTypes.DEFAULT;
        return context === DEFAULT && userIds.reduce(_fun96689, false);
        function _fun96689(a0, a1) { // fn#96689, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:12793:2741, offset: 0x0216380a, size: 103 bytes, params: 3, frame: 18
            var r1;
            const value = a0;
            const voiceStateStoreBinding = VoiceStateStore;
            const getVoiceStateForChannel = voiceStateStoreBinding.getVoiceStateForChannel;
            if (Reflect.apply(getVoiceStateForChannel, voiceStateStoreBinding, [channelId, a1]) != null) {
                return value;
            }
            const user = UserStore.getUser(a1);
            if (user == null) {
                env1_19.add(a1);
                r1 = value;
            } else {
                upsert_96672(user, guildId, channelId);
                r1 = true;
            }
            return r1;
        }

    }

    function RTC_CONNECTION_CLIENT_DISCONNECT({userId, context}) { // fn#96690, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:12793:2904, offset: 0x02163871, size: 68 bytes, params: 2, frame: 14
        const MediaEngineContextTypes = (MediaEngineModule).MediaEngineContextTypes;
        const DEFAULT = MediaEngineContextTypes.DEFAULT;
        return context === DEFAULT && deleteUserDesyncData(userId);
    }

}

global.__d(_fun96668, 12603, [6, 7, 15, 17, 18, 4298, 1379, 4294, 1878, 4297, 4300, 661, 4299, 4268, 4617, 4618,
        4406, 566, 694,
        2]) /* metro module 12603, dependencies: [6, 7, 15, 17, 18, 4298, 1379, 4294, 1878, 4297, 4300, 661, 4299, 4268, 4617, 4618, 4406, 566, 694, 2] */;