/* Metro module 4257; source: modules/gateway/GatewayConnectionStore.tsx; dependencies: [6, 7, 15, 17, 18, 5, 1348, 1226, 4258, 1379, 4259, 4294, 4402, 1934, 6876, 4395, 661, 670, 12490, 12532, 3, 587, 6944, 4796, 477, 12524, 22, 4285, 12503, 566, 694, 2] */
import Module00005 from '../../by-id/module-00005.js'; /* Metro dependency 5 */
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 AuthenticationStore from '../../stores/AuthenticationStore.tsx'; /* Metro dependency 1226 */
import UserSettingsProtoStore from '../user_settings/UserSettingsProtoStore.tsx'; /* Metro dependency 1348 */
import ChannelStore from '../../stores/ChannelStore.tsx'; /* Metro dependency 1379 */
import SelectedChannelStore from '../../stores/SelectedChannelStore.tsx'; /* Metro dependency 1934 */
import CallStore from '../../stores/CallStore.tsx'; /* Metro dependency 4258 */
import MediaEngineStore from '../../stores/MediaEngineStore.tsx'; /* Metro dependency 4259 */
import RTCConnectionStore from '../../stores/RTCConnectionStore.tsx'; /* Metro dependency 4294 */
import StreamRTCConnectionStore from '../../stores/StreamRTCConnectionStore.tsx'; /* Metro dependency 4395 */
import RTCRegionStore from '../../stores/RTCRegionStore.tsx'; /* Metro dependency 4402 */
import SelfPresenceStore from '../../stores/SelfPresenceStore.tsx'; /* Metro dependency 6876 */
import * as FileImportTrackerModule from '../../by-id/module-00002-FileImportTracker.js'; /* Metro dependency 2 */
import * as PlatformUtilsModule from '../../utils/PlatformUtils.tsx'; /* Metro dependency 477 */
import * as ConstantsModule from '../../Constants.tsx'; /* Metro dependency 661 */
import * as UserSettingsConstantsModule from '../user_settings/UserSettingsConstants.tsx'; /* Metro dependency 670 */
import * as GatewaySocketSingletonModule from './GatewaySocketSingleton.tsx'; /* Metro dependency 12490 */

function _fun35388(global, require, importDefault, importAll, module, exports, dependencyMap) { // fn#35388, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:4429:6, offset: 0x01071406, size: 985 bytes, params: 8, frame: 22
    const env0_0 = require;
    const closure = function() {
        require(dependencyMap[18]).localVoiceState.update();
    };
    const handleMediaEngineChange = function() {
        require(dependencyMap[18]).localVoiceState.update();
        return false;
    };
    const handleLocalPresenceChange = function() {
        require(dependencyMap[18]).localPresenceState.update();
        return false;
    };
    const deleteStream = function(a0) {
        var socket = require(dependencyMap[18]).socket;
        if (socket.isSessionEstablished()) {
            socket.streamDelete(a0);
        }
    };
    const Object = global.Object;
    Object.defineProperty(exports, '__esModule', {value: true});
    let value = ConstantsModule;
    const env0_20 = value.RTCConnectionStates;
    const env0_21 = value.AppStates;
    const env0_23 = global.window.DiscordNative;
    (require(12490) /* metro dependency 12490: GatewaySocketSingleton */).socket.dispatcher.getDispatchHandler = importDefault(12532) /* metro dependency 12532: dispatchSocketMessage */;
    value = importDefault(3) /* metro dependency 3: Logger */;
    value = new value('ConnectionStore');
    const Store = (Flux).Store;
    _fun35404(Store).displayName = 'GatewayConnectionStore';
    value = new value(importDefault(694) /* metro dependency 694: Dispatcher */, {START_SESSION: START_SESSION,
        LOGIN_SUCCESS: LOGIN_SUCCESS_35413, LOGOUT: LOGOUT_35414, CLEAR_CACHES: CLEAR_CACHES_35415,
        CONNECTION_OPEN: function(a0) {
        _fun35417(a0);
    }, CONNECTION_RESUMED: function() {
        env0_29 = null;
    }, CONNECTION_CLOSED: CONNECTION_CLOSED_35419, RTC_CONNECTION_STATE: RTC_CONNECTION_STATE,
        VOICE_CHANNEL_SELECT: VOICE_CHANNEL_SELECT_35421, VOICE_STATE_UPDATES: function({voiceStates}) {
        return voiceStates.reduce(_fun35423, false);
    }, GUILD_DELETE: function(a0) {
        if (a0.guild.id === require(dependencyMap[18]).localVoiceState.guildId) {
            require(dependencyMap[18]).localVoiceState.setState({'guildId': null, 'channelId': null});
        }
    }, CHANNEL_DELETE: function(a0) {
        if (a0.channel.id === require(dependencyMap[18]).localVoiceState.channelId) {
            require(dependencyMap[18]).localVoiceState.setState({'guildId': null, 'channelId': null});
        }
    }, CALL_DELETE: CALL_DELETE, APP_STATE_UPDATE: APP_STATE_UPDATE, GUILD_MEMBERS_REQUEST: GUILD_MEMBERS_REQUEST,
        GUILD_SEARCH_RECENT_MEMBERS: function({guildId, query, continuationToken}) {
        if (require(dependencyMap[18]).socket.isSessionEstablished()) {
            require(dependencyMap[18]).socket.searchRecentMembers(guildId, {query: query,
                continuationToken: continuationToken});
        }
    }, GUILD_SUBSCRIPTIONS_FLUSH: function({subscriptions}) {
        if (require(dependencyMap[18]).socket.isSessionEstablished()) {
            require(dependencyMap[18]).socket.updateGuildSubscriptions(subscriptions);
        }
        return false;
    }, CALL_CONNECT: function({channelId}) {
        if (require(dependencyMap[18]).socket.isSessionEstablished()) {
            require(dependencyMap[18]).socket.callConnect(channelId);
        }
        return false;
    }, CALL_CONNECT_MULTIPLE: function({channelIds}) {
        if (require(dependencyMap[18]).socket.isSessionEstablished()) {
            channelIds.forEach(_fun35434);
        }
        return false;
    }, STREAM_CREATE: closure, STREAM_START: STREAM_START, STREAM_WATCH: function({streamKey, allowMultiple}) {
        if (require(dependencyMap[18]).socket.isSessionEstablished()) {
            if (!allowMultiple) {
                cleanupAllStreamsExceptSelf();
            }
            require(dependencyMap[18]).socket.streamWatch(streamKey);
        }
        return false;
    }, STREAM_STOP: function({streamKey}) {
        deleteStream(streamKey);
        STREAM_CREATE();
        return false;
    }, STREAM_SET_PAUSED: function({streamKey, paused}) {
        if (require(dependencyMap[18]).socket.isSessionEstablished()) {
            require(dependencyMap[18]).socket.streamSetPaused(streamKey, paused);
        }
    }, PUSH_NOTIFICATION_CLICK: function() {
        require(dependencyMap[18]).socket.expeditedHeartbeat(5000, 'user clicked on notification', true);
        return false;
    }, REQUEST_FORUM_UNREADS: function({guildId, channelId, threads}) {
        require(dependencyMap[18]).socket.requestForumUnreads(guildId, channelId, threads);
    }, REQUEST_SOUNDBOARD_SOUNDS: function({guildIds}) {
        require(dependencyMap[18]).socket.requestSoundboardSounds(guildIds);
    }, REMOTE_COMMAND: function({sessionId, payload}) {
        if (require(dependencyMap[18]).socket.isSessionEstablished()) {
            require(dependencyMap[18]).socket.remoteCommand(sessionId, payload);
        }
        return false;
    }, RESET_SOCKET: function(a0) {
        if (require(dependencyMap[18]).socket.connectionState !== importDefault(dependencyMap[28]).WILL_RECONNECT) {
            require(dependencyMap[18]).socket.resetSocketAndClearCacheOnError(a0.args);
        }
    }, CLIPS_SETTINGS_UPDATE: closure, RUNNING_GAMES_CHANGE: closure, USER_SETTINGS_PROTO_UPDATE: function(a0) {
        if (a0.settings.type === UserSettingsTypes.PRELOADED_USER_SETTINGS && a0.settings.proto.clips?.allowVoiceRecording != null) {
            STREAM_CREATE();
        }
    }});
    (FileImportTrackerModule).fileFinishedImporting('modules/gateway/GatewayConnectionStore.tsx');
    exports.default = value;
    function _isNativeReflectConstruct_35389() { // fn#35389, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:4429:342, offset: 0x010717df, size: 94 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_35389_isNativeReflectConstruct = function() {
            return !!result;
        })();
    }

    function _handleConnectionOpen() { // fn#35392, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:4429:686, offset: 0x0107183d, size: 48 bytes, params: 1, frame: 14
        return Module00005(_fun35394).apply(this, arguments);
        function* _fun35394({sessionId}) { // fn#35394, original name: ?anon_0_, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:4429:751, offset: 0x01071876, size: 637 bytes, params: 2, frame: 25
            var r5;
            var type;
            var r7;
            var performance;
            var entriesByType;
            var channel;
            if (false) {
                return undefined;
            }
            const Date = global.Date;
            value = Date.now();
            let binding = env2_0;
            value = undefined;
            binding(env2_3[18]).localPresenceState.handleConnectionOpen();
            let object = {};
            const voiceChannelId = env2_17.getVoiceChannelId();
            if (voiceChannelId == null) {
                env2_0(env2_3[18]).localVoiceState.update(object, true);
                env2_27 = false;
            } else {
                var Storage = env2_0(env2_3[21]).Storage;
                var value6 = Storage.get('discord_watchdog_restart_timestamp');
                r5 = value6 != null && global.Date.now() - global.parseInt(value6, 10) < 60000;
                Storage = env2_0(env2_3[21]).Storage;
                Storage.remove('discord_watchdog_restart_timestamp');
                var window = global.window;
                if (window == null) {
                    type = value;
                } else {
                    performance = window.performance;
                    if (performance == null) {
                        type = value;
                    } else if (performance.getEntriesByType == null) {
                        type = value;
                    } else {
                        entriesByType = performance.getEntriesByType('navigation');
                        type = entriesByType == null || entriesByType[0] == null ? value : entriesByType[0].type;
                    }
                }
                if (type === 'reload') {
                    binding = env2_13;
                    channel = binding.getChannel(voiceChannelId);
                    if (channel == null) {
                        r7 = object;
                    } else {
                        object = {};
                        object.guildId = channel.getGuildId();
                        object.channelId = voiceChannelId;
                        env2_0(env2_3[22]).muteCustomJoinSound(voiceChannelId);
                        r7 = object;
                    }
                    binding = env2_0;
                    binding(env2_3[18]).localVoiceState.update(r7, true);
                    env2_27 = false;
                    return value;
                }
                if (r5) {
                    binding = env2_13;
                    channel = binding.getChannel(voiceChannelId);
                    if (channel == null) {
                        r7 = object;
                    } else {
                        object = {};
                        object.guildId = channel.getGuildId();
                        object.channelId = voiceChannelId;
                        env2_0(env2_3[22]).muteCustomJoinSound(voiceChannelId);
                        r7 = object;
                    }
                    binding = env2_0;
                    binding(env2_3[18]).localVoiceState.update(r7, true);
                    env2_27 = false;
                    return value;
                }
                r5 = env2_23 == null || env2_23.processUtils == null || env2_23.processUtils.getLastCrash == null ? value : env2_23.processUtils.getLastCrash();
                yield r5;
                if (false) {
                    return undefined;
                }
                if ((null == undefined ? value : undefined.rendererCrashReason) != null) {
                    channel = env2_13.getChannel(voiceChannelId);
                    if (channel == null) {
                        r7 = object;
                    } else {
                        object = {};
                        object.guildId = channel.getGuildId();
                        object.channelId = voiceChannelId;
                        env2_0(env2_3[22]).muteCustomJoinSound(voiceChannelId);
                        r7 = object;
                    }
                } else if (env2_27) {
                    binding = env2_15;
                    binding.setLastSessionVoiceChannelId(voiceChannelId ?? null);
                    binding = env2_1;
                    binding(env2_3[23]).selectVoiceChannel(null);
                    r7 = object;
                } else {
                    channel = env2_13.getChannel(voiceChannelId);
                    if (channel == null) {
                        r7 = object;
                    } else {
                        object = {};
                        object.guildId = channel.getGuildId();
                        object.channelId = voiceChannelId;
                        env2_0(env2_3[22]).muteCustomJoinSound(voiceChannelId);
                        r7 = object;
                    }
                }
                env2_0(env2_3[18]).localVoiceState.update(r7, true);
            }
            return value;
        }

    }

    function cleanupAllStreamsExceptSelf() { // fn#35399, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:4429:1949, offset: 0x01071bcd, size: 66 bytes, params: 1, frame: 13
        const env0_0 = getSelfStreamKey();
        let value = StreamRTCConnectionStore.getAllActiveStreamKeys();
        value = value.filter(_fun35402);
        value.forEach(function(a0) {
            deleteStream(a0);
        });
        function getSelfStreamKey() { // fn#35400, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:4429:1994, owner: cleanupAllStreamsExceptSelf.getSelfStreamKey, offset: 0x01071c0f, size: 37 bytes, params: 1, frame: 11
            var environment;
            const value = environment.__proto__;
            return StreamRTCConnectionStore.getAllActiveStreamKeys().find(function(a0) {
                return require(dependencyMap[27]).decodeStreamKey(a0).ownerId === AuthenticationStore.getId();
            });
        }

        function _fun35402(a0) { // fn#35402, offset: 0x00ce1772, size: 16 bytes, params: 2, frame: 2
            return a0 !== env0_0;
        }

    }

    function _fun35404(a0) { // fn#35404, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:4429:2200, offset: 0x01071c88, size: 185 bytes, params: 2, frame: 16
        const GatewayConnectionStore2 = GatewayConnectionStore;
        Inherits(GatewayConnectionStore2, a0);
        return CreateClass(GatewayConnectionStore2, [{key: 'initialize', value: function() {
            var authenticationStoreBinding = AuthenticationStore;
            var callStoreBinding = CallStore;
            var channelStoreBinding = ChannelStore;
            var mediaEngineStoreBinding = MediaEngineStore;
            var rtcConnectionStoreBinding = RTCConnectionStore;
            var rtcRegionStoreBinding = RTCRegionStore;
            var selectedChannelStoreBinding = SelectedChannelStore;
            var selfPresenceStoreBinding = SelfPresenceStore;
            this.waitFor(authenticationStoreBinding, callStoreBinding, channelStoreBinding, mediaEngineStoreBinding,
                rtcConnectionStoreBinding, rtcRegionStoreBinding, selectedChannelStoreBinding, selfPresenceStoreBinding,
                StreamRTCConnectionStore, UserSettingsProtoStore);
            this.syncWith([mediaEngineStoreBinding], handleMediaEngineChange);
            this.syncWith([selfPresenceStoreBinding], handleLocalPresenceChange);
        }}, {key: 'getSocket', value: function() {
            return require(dependencyMap[18]).socket;
        }}, {key: 'isTryingToConnect', value: function() {
            return !require(dependencyMap[18]).socket.isClosed();
        }}, {key: 'isConnected', value: function() {
            return require(dependencyMap[18]).socket.isSessionEstablished();
        }}, {key: 'isConnectedOrOverlay', value: value_35410}, {key: 'lastTimeConnectedChanged', value: value_35411}]);
        function GatewayConnectionStore() { // fn#35405, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:4429:2212, offset: 0x01071d41, size: 113 bytes, params: 1, frame: 20
            const value = environment.__proto__;
            env1_4(this, GatewayConnectionStore);
            const value3 = env1_7(GatewayConnectionStore);
            return env1_6(this, _isNativeReflectConstruct_35389() ? global.Reflect.construct(value3, arguments,
                env1_7(this).constructor) : value3.apply(this, arguments));
        }

        function value_35410() { // fn#35410, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:4429:2930, offset: 0x01071ea1, size: 48 bytes, params: 1, frame: 11
            const value = environment.__proto__;
            return (require(12490) /* metro dependency 12490: GatewaySocketSingleton */).socket.isSessionEstablished() || false;
        }

        function value_35411() { // fn#35411, offset: 0x00df3ad6, size: 9 bytes, params: 1, frame: 1
            return env1_25;
        }

    }

    function START_SESSION() { // fn#35412, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:4429:3147, offset: 0x01071ed1, size: 115 bytes, params: 1, frame: 15
        var r0;
        const socket = (GatewaySocketSingletonModule).socket;
        const isClosed2 = socket.isClosed();
        const binding = env0_24;
        const verbose = binding.verbose;
        if (isClosed2) {
            Reflect.apply(verbose, binding, ['Socket is reconnecting because of starting new session']);
            r0 = socket.connect();
        } else {
            Reflect.apply(verbose, binding, ['Socket is not reconnecting during a new session because it is not closed']);
            r0 = false;
        }
        return r0;
    }

    function LOGIN_SUCCESS_35413() { // fn#35413, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:4429:3413, offset: 0x01071f44, size: 166 bytes, params: 1, frame: 19
        var r0;
        const binding = env0_24;
        const verbose = binding.verbose;
        const object = {};
        const socket = (GatewaySocketSingletonModule).socket;
        object.isEstablished = socket.isSessionEstablished();
        Reflect.apply(verbose, binding, ['session refresh dispatched', object]);
        const isSessionEstablished2 = socket.isSessionEstablished();
        if (isSessionEstablished2) {
            socket.close();
            r0 = socket.connect();
        } else {
            r0 = !!isSessionEstablished2;
        }
        return r0;
    }

    function LOGOUT_35414(a0) { // fn#35414, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:4429:3649, offset: 0x01071fea, size: 119 bytes, params: 2, frame: 12
        if (a0.isSwitchingAccount) {
            (require(12490) /* metro dependency 12490: GatewaySocketSingleton */).localPresenceState.handleAccountSwitch();
        }
        env0_24.verbose('Closing socket because of logout');
        (require(12490) /* metro dependency 12490: GatewaySocketSingleton */).socket.close();
    }

    function CLEAR_CACHES_35415(a0) { // fn#35415, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:4429:3830, offset: 0x01072061, size: 113 bytes, params: 2, frame: 14
        const socket = (GatewaySocketSingletonModule).socket;
        if (a0.resetSocket) {
            socket.close();
            socket.dispatcher.clear();
            socket.connect();
        }
        return false;
    }

    function CONNECTION_OPEN_35416(a0) { // fn#35416, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:4429:3989, offset: 0x010720d2, size: 22 bytes, params: 2, frame: 11
        (function() {
            return _handleConnectionOpen.apply(this, arguments);
        })(a0);
        function CONNECTION_OPEN_35416HandleConnectionOpen() { // fn#35417, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:4429:3994, owner: CONNECTION_OPEN_35416.handleConnectionOpen, offset: 0x010720e8, size: 30 bytes, params: 1, frame: 13
            return _handleConnectionOpen.apply(this, arguments);
        }

    }

    function CONNECTION_CLOSED_35419() { // fn#35419, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:4429:4162, offset: 0x01072113, size: 49 bytes, params: 1, frame: 12
        env0_24.verbose('connection closed dispatched');
        const Date = global.Date;
        env0_25 = Date.now();
    }

    function RTC_CONNECTION_STATE(a0) { // fn#35420, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:4429:4273, offset: 0x01072144, size: 143 bytes, params: 2, frame: 13
        const socket = (GatewaySocketSingletonModule).socket;
        const state = a0.state;
        const DISCONNECTED = RTCConnectionStates.DISCONNECTED;
        if (state !== DISCONNECTED) {
            return false;
        }
        if (a0.willReconnect) {
            if (a0.streamKey != null) {
                socket.streamPing(a0.streamKey);
            } else {
                socket.voiceServerPing();
            }
        }
    }

    function VOICE_CHANNEL_SELECT_35421(a0) { // fn#35421, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:4429:4480, offset: 0x010721d3, size: 307 bytes, params: 2, frame: 16
        const socket = (GatewaySocketSingletonModule).socket;
        const localVoiceState = (GatewaySocketSingletonModule).localVoiceState;
        const update = localVoiceState.update;
        let channelId = a0.channelId;
        Reflect.apply(update, localVoiceState, [{guildId: a0.guildId, channelId: channelId}]);
        const lockVoiceStateForResume = a0.lockVoiceStateForResume;
        const value2 = null;
        if (lockVoiceStateForResume) {
            channelId = a0.channelId;
            channelId = value2 != channelId ? a0.channelId : value2;
        }
        if ((require(477) /* metro dependency 477: PlatformUtils */).isIOS() && env0_28 === AppStates.BACKGROUND) {
            if (value2 == a0.channelId) {
                socket.close(true);
            } else if (socket.isClosed()) {
                (importAll(12524) /* metro dependency 12524: PauseGatewaySocket */).setIsPaused(false);
                socket.connect();
            }
        }
        return false;
    }

    function VOICE_STATE_UPDATES_35422({voiceStates}) { // fn#35422, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:4429:4850, offset: 0x01072306, size: 32 bytes, params: 2, frame: 13
        return voiceStates.reduce(_fun35423, false);
        function _fun35423(a0, a1) { // fn#35423, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:4429:4917, offset: 0x01072326, size: 246 bytes, params: 3, frame: 17
            const localVoiceState = (GatewaySocketSingletonModule).localVoiceState;
            const id = AuthenticationStore.getId();
            const userId = a1.userId;
            if (id !== userId) {
                return a0;
            }
            if (a1.sessionId === env1_26) {
                if (env1_29 != null) {
                    env1_24.verbose('Ignoring voice state for own session due to VSU lock on channel:', env1_29);
                    return a0;
                }
                localVoiceState.setState({guildId: a1.guildId, channelId: a1.channelId});
            } else {
                if (a1.guildId !== localVoiceState.guildId) {
                    return a0;
                }
                localVoiceState.setState({'guildId': null, 'channelId': null});
            }
            return true;
        }

    }

    function CALL_DELETE({channelId}) { // fn#35426, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:4429:5632, offset: 0x010724ea, size: 110 bytes, params: 2, frame: 14
        const localVoiceState = (GatewaySocketSingletonModule).localVoiceState;
        if (channelId === localVoiceState.channelId) {
            if (env0_29 === channelId) {
                return false;
            }
            localVoiceState.setState({'guildId': null, 'channelId': null});
        }
    }

    function APP_STATE_UPDATE(a0) { // fn#35427, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:4429:5818, offset: 0x01072558, size: 462 bytes, params: 2, frame: 16
        var r2;
        var state;
        var authenticationStoreBinding;
        const socket = (require(12490) /* metro dependency 12490: GatewaySocketSingleton */).socket;
        if (PlatformUtilsModule.isIOS()) {
            authenticationStoreBinding = AuthenticationStore;
            if (authenticationStoreBinding.isAuthenticated()) {
                if (env0_28 !== AppStates.INACTIVE) {
                    r2 = env0_28 === AppStates.BACKGROUND && a0.state === AppStates.ACTIVE;
                    r2 = r2 && socket.isClosed();
                    if (r2) {
                        (importAll(12524) /* metro dependency 12524: PauseGatewaySocket */).setIsPaused(false);
                        socket.connect();
                    }
                } else if (a0.state !== AppStates.BACKGROUND) {
                    r2 = env0_28 === AppStates.BACKGROUND && a0.state === AppStates.ACTIVE;
                    r2 = r2 && socket.isClosed();
                    if (r2) {
                        (importAll(12524) /* metro dependency 12524: PauseGatewaySocket */).setIsPaused(false);
                        socket.connect();
                    }
                } else if ((require(12490) /* metro dependency 12490: GatewaySocketSingleton */).localVoiceState.channelId == null) {
                    socket.close(true);
                } else {
                    r2 = env0_28 === AppStates.BACKGROUND && a0.state === AppStates.ACTIVE;
                    r2 = r2 && socket.isClosed();
                    if (r2) {
                        (importAll(12524) /* metro dependency 12524: PauseGatewaySocket */).setIsPaused(false);
                        socket.connect();
                    }
                }
            }
            state = a0.state;
        } else if (a0.state === AppStates.ACTIVE) {
            (importAll(12524) /* metro dependency 12524: PauseGatewaySocket */).setIsPaused(false);
            authenticationStoreBinding = AuthenticationStore;
            if (authenticationStoreBinding.isAuthenticated()) {
                socket.resetBackoff('App state is active');
            }
        }
        return false;
    }

    function GUILD_MEMBERS_REQUEST(a0) { // fn#35428, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:4429:6273, offset: 0x01072726, size: 213 bytes, params: 2, frame: 18
        const env0_0 = a0;
        var value;
        const socket = (GatewaySocketSingletonModule).socket;
        if (socket.isSessionEstablished()) {
            if ('userIds' in a0) {
                value = importDefault(22) /* metro dependency 22 */;
                value = value(a0.userIds);
                value = value.chunk(100);
                value.forEach(_fun35429);
            } else {
                socket.requestGuildMembers(a0.guildIds, {query: a0.query, limit: a0.limit, presences: !!a0.presences});
            }
        }
        return false;
        function _fun35429(a0) { // fn#35429, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:4429:6413, offset: 0x010727fb, size: 85 bytes, params: 2, frame: 16
            const socket = (GatewaySocketSingletonModule).socket;
            const requestGuildMembers = socket.requestGuildMembers;
            const binding = env0_0;
            Reflect.apply(requestGuildMembers, socket, [binding.guildIds, {userIds: a0, presences: !!binding.presences}]);
        }

    }

    function CALL_CONNECT_MULTIPLE({channelIds}) { // fn#35433, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:4429:7168, offset: 0x01072978, size: 74 bytes, params: 2, frame: 12
        const socket = (GatewaySocketSingletonModule).socket;
        if (socket.isSessionEstablished()) {
            channelIds.forEach(function(a0) {
                require(dependencyMap[18]).socket.callConnect(a0);
            });
        }
        return false;
        function _fun35434(a0) { // fn#35434, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:4429:7277, offset: 0x010729c2, size: 47 bytes, params: 2, frame: 12
            (GatewaySocketSingletonModule).socket.callConnect(a0);
        }

    }

    function STREAM_START({streamType, guildId, channelId}) { // fn#35435, source: /ci/build/discord/discord/discord_android_rn/android/app/src/main/assets/index.android.bundle:4429:7363, offset: 0x010729f1, size: 208 bytes, params: 2, frame: 22
        var r2;
        var streamCreate;
        const socket = (GatewaySocketSingletonModule).socket;
        if (socket.isSessionEstablished()) {
            r2 = guildId != null ? ChannelStore.getChannel(channelId)?.rtcRegion : CallStore.getCall(channelId)?.region;
            streamCreate = socket.streamCreate;
            r2 = r2 ?? RTCRegionStore.getPreferredRegion();
            Reflect.apply(streamCreate, socket, [streamType, guildId, channelId, r2]);
        }
        return false;
    }

}

global.__d(_fun35388, 4257, [6, 7, 15, 17, 18, 5, 1348, 1226, 4258, 1379, 4259, 4294, 4402, 1934, 6876, 4395, 661,
        670, 12490, 12532, 3, 587, 6944, 4796, 477, 12524, 22, 4285, 12503, 566, 694,
        2]) /* metro module 4257, dependencies: [6, 7, 15, 17, 18, 5, 1348, 1226, 4258, 1379, 4259, 4294, 4402, 1934, 6876, 4395, 661, 670, 12490, 12532, 3, 587, 6944, 4796, 477, 12524, 22, 4285, 12503, 566, 694, 2] */;