decord/alpha/source/actions/ConnectedAccountsActionCreators.tsx

// Module ID: 6875
// Function ID: 6876
// Name: ConnectedAccountsActionCreators
// Dependencies: [5, 5761, 1085, 3, 1295, 5886, 1265, 6876, 5887, 5938, 1273, 584, 2]

// Module 6875 (ConnectedAccountsActionCreators)
import LoggerDefault from "Logger" /* 3 */;
import DispatcherDefault from "Dispatcher" /* 584 */;
import discord_common_AnalyticsUtils from "discord_common/AnalyticsUtils" /* 1273 */;
import HTTPUtils from "HTTPUtils" /* 1295 */;
import fetchConnectedAccounts from "fetchConnectedAccounts" /* 5886 */;
import postConnectionCallback from "postConnectionCallback" /* 5887 */;
import TrackedHTTPUtilsDefault from "TrackedHTTPUtils" /* 5938 */;
import _asyncToGenerator_mod from "_asyncToGenerator" /* 5 */;
import ConnectedAccountsStore from "ConnectedAccountsStore" /* 5761 */;
import Constants from "Constants" /* 1085 */;
import size from "module_2" /* 2 */;

const require = globalThis.__r;
let _require, c0, c4, constants, dependencyMap, importDefault;

let hasOwnProperty;
let metroImportAll;
let metroImportDefault;
let metroRequire;
let _asyncToGenerator = _asyncToGenerator_mod;
({ AbortCodes: hasOwnProperty, Endpoints: metroRequire, FRIEND_SYNC_PLATFORM_TYPES: metroImportDefault, AnalyticEvents: metroImportAll } = Constants);
let tmp3 = new LoggerDefault("ConnectedAccounts");
let closure_9 = tmp3;
let obj = {
  fetch: fetchConnectedAccounts.fetchConnectedAccounts,
  authorize(arg0) {
    let _location;
    let closure_5;
    let closure_6;
    let closure_0 = arg0;
    let obj = arg1;
    if (arg1 === undefined) {
      obj = {};
    }
    ({ location: importDefault, twoWayLinkType: dependencyMap, userCode: _asyncToGenerator, twoWayLink: ConnectedAccountsStore, successRedirect: closure_5, handle: closure_6 } = obj);
    return (async function() {
      let _var;
      let c3;
      let closure_1;
      let closure_2;
      let obj4;
      dependencyMap = tmp;
      const obj5 = { platform_type: _var, location: importDefault };
      const obj8 = tmp4(dependencyMap[6]);
      obj8.track(constants.CONNECTED_ACCOUNT_INITIATED, obj5);
      const _URLSearchParams = URLSearchParams;
      const self = this;
      const self2 = this;
      const result = closure_1_6.CONNECTIONS_AUTHORIZE(_var);
      const str11 = new URLSearchParams();
      if (null != _asyncToGenerator) {
        str11.append("two_way_user_code", tmp51);
      }
      if (null != closure_5) {
        str11.append("success_redirect", tmp15);
      }
      if (null != dependencyMap) {
        str11.append("two_way_link_type", tmp17);
        str11.append("two_way_link", "true");
      } else if (null != ConnectedAccountsStore) {
        const _String = String;
        str11.append("two_way_link", String(tmp18));
      }
      if (null != closure_6) {
        str11.append("handle", tmp22);
      }
      const text = `${tmp48}?`;
      const text1 = `${tmp48}?${str11.toString()}`;
      const HTTP = _var(dependencyMap[4]).HTTP;
      const obj6 = { url: text1, oldFormErrors: true, rejectWithError: obj4.rejectWithMigratedError() };
      const get = HTTP.get;
      obj4 = _var(dependencyMap[4]);
      _var = await get(obj6);
      const url = _var.body.url;
      const tmp38 = _var(dependencyMap[7]);
      _var = url;
      const getCallbackParamsFromURL = tmp38.getCallbackParamsFromURL;
      if (url == null) {
        _var = "";
      }
      const state = getCallbackParamsFromURL(_var).state;
      if (null != state) {
        const result1 = c4.addPendingAuthorizedState(state);
      }
      return _var;
    })();
  },
  callback: postConnectionCallback.postConnectionCallback,
  connect(arg0, arg1, name, location, friend_sync) {
    let obj;
    let obj2;
    let obj5;
    const tmp2 = TrackedHTTPUtilsDefault;
    const request = { url: metroRequire.CONNECTION(arg0, arg1), body: obj, context: { location }, oldFormErrors: true, trackedActionData: obj2, rejectWithError: obj5.rejectWithMigratedError() };
    const put = tmp2.put;
    obj = { name, friend_sync };
    friend_sync = undefined;
    if (friend_sync != null) {
      friend_sync = friend_sync.friend_sync;
    }
    if (friend_sync == null) {
      friend_sync = metroImportDefault.has(arg0);
    }
    obj2 = { event: discord_common_AnalyticsUtils.NetworkActionNames.USER_CONNECTIONS_UPDATE, properties: { name, friend_sync: metroImportDefault.has(arg0) } };
    ({ name, friend_sync: metroImportDefault.has(arg0) });
    obj5 = HTTPUtils;
    return put(request);
  },
  disconnect(arg0, arg1) {
    let obj2;
    const HTTP = HTTPUtils.HTTP;
    const del = HTTP.del;
    const obj = { url: metroRequire.CONNECTION(arg0, arg1), oldFormErrors: true, rejectWithError: obj2.rejectWithMigratedError() };
    obj2 = HTTPUtils;
    return del(obj);
  },
  refresh(arg0, arg1) {
    let obj2;
    const HTTP = HTTPUtils.HTTP;
    const post = HTTP.post;
    const obj = { url: metroRequire.CONNECTION_REFRESH(arg0, arg1), oldFormErrors: true, rejectWithError: obj2.rejectWithMigratedError() };
    obj2 = HTTPUtils;
    return post(obj);
  },
  setVisibility(type, id, inProgressVisibility) {
    const obj = { visibility: 1 === inProgressVisibility };
    return this.update(type, id, obj);
  },
  setMetadataVisibility(type, id, inProgressMetadataVisibility) {
    const obj = { metadata_visibility: 1 === inProgressMetadataVisibility };
    return this.update(type, id, obj);
  },
  setFriendSync(type, id, enabled) {
    const obj = { friend_sync: enabled };
    return this.update(type, id, obj);
  },
  setShowActivity(type, id, show_activity) {
    const platformType = type;
    const showActivity = show_activity;
    let obj = { show_activity };
    const updateResult = this.update(type, id, obj);
    return updateResult.then((result) => {
      const obj = DispatcherDefault;
      const obj2 = { type: "USER_CONNECTION_UPDATE", platformType, id, showActivity };
      obj.dispatch(obj2);
      return result;
    });
  },
  update(arg0, arg1, body) {
    let obj;
    let obj2;
    let obj4;
    const tmp = TrackedHTTPUtilsDefault;
    const request = { url: metroRequire.CONNECTION(arg0, arg1), body, oldFormErrors: true, trackedActionData: obj, rejectWithError: obj4.rejectWithMigratedError() };
    const patch = tmp.patch;
    obj = { event: discord_common_AnalyticsUtils.NetworkActionNames.USER_CONNECTIONS_UPDATE, properties: obj2 };
    obj2 = {};
    const merged = Object.assign(body);
    obj4 = HTTPUtils;
    return patch(request);
  },
  joinServer(id, arg1) {
    let closure_1;
    let integrationId;
    let obj4;
    _require = id;
    importDefault = arg1;
    let obj = DispatcherDefault;
    let obj2 = { type: "USER_CONNECTIONS_INTEGRATION_JOINING", integrationId: id, joining: true };
    obj.dispatch(obj2);
    const HTTP = require("HTTPUtils").HTTP;
    let obj3 = { url: closure_6.INTEGRATION_JOIN(id), oldFormErrors: true, rejectWithError: obj4.rejectWithMigratedError() };
    const post = HTTP.post;
    obj4 = require("HTTPUtils");
    post(obj3, (ok) => {
      let message;
      const obj = DispatcherDefault;
      const obj2 = { type: "USER_CONNECTIONS_INTEGRATION_JOINING", integrationId, joining: false };
      obj.dispatch(obj2);
      const tmp3 = integrationId;
      if (!ok.ok) {
        const obj3 = { type: "USER_CONNECTIONS_INTEGRATION_JOINING_ERROR", integrationId: tmp3, error: message };
        message = undefined;
        const dispatch = tmp(584).dispatch;
        DispatcherDefault;
        if (!ok.hasErr) {
          message = ok.body.message;
        }
        dispatch(obj3);
        if (closure_1 != null) {
          closure_1();
        }
      }
    });
  },
  refreshAccessToken(type, id) {
    let closure_1 = id;
    return (async (arg0, value) => {
      let closure_0;
      let closure_1;
      let obj11;
      let tmp;
      if (constants === 2) {
        constants = 3;
        throw new TypeError("Generator functions may not be called on executing generators");
      } else if (tmp3 === 3) {
        if (arg0 === 1) {
          throw value;
        } else if (arg0 === 2) {
          const obj2 = { value, done: true };
          return obj2;
        } else {
          return { value: "IconComponent", done: null };
        }
      } else {
        let c3;
        try {
          let access_token;
          constants = 2;
          if (0 === c4) {
            if (arg0 === 1) {
              constants = 3;
              throw value;
            } else if (arg0 === 2) {
              constants = 3;
              const obj3 = { value, done: true };
              return obj3;
            } else {
              type = tmp4;
              access_token = undefined;
              c3 = 1;
              const HTTP = type(closure_2[4]).HTTP;
              const obj4 = { url: closure_1_6.CONNECTION_ACCESS_TOKEN(type, tmp), oldFormErrors: true, rejectWithError: obj11.rejectWithMigratedError() };
              const get = HTTP.get;
              obj11 = type(closure_2[4]);
              c4 = 2;
              constants = 1;
              const obj6 = { value: get(obj4), done: false };
              return obj6;
            }
          } else if (1 === c4) {
            c3 = 0;
            tmp = closure_2;
            if (tmp.body.code === constants.CONNECTION_REVOKED) {
              const obj7 = { type: "USER_CONNECTION_UPDATE", platformType: closure_129_0, id: closure_129_1, revoked: true };
              const obj5 = tmp(closure_2[11]);
              obj5.dispatch(obj7);
            }
            throw tmp;
          } else if (arg0 === 1) {
            constants = 3;
            throw value;
          } else if (arg0 === 2) {
            c3 = 0;
            constants = 3;
            const obj8 = { value, done: true };
            return obj8;
          } else {
            access_token = value.body.access_token;
            const obj9 = { type: "USER_CONNECTION_UPDATE", platformType: closure_129_0, id: closure_129_1, accessToken: access_token };
            const obj = tmp(closure_2[11]);
            obj.dispatch(obj9);
            c3 = 0;
            constants = 3;
            const obj10 = { value: access_token, done: true };
            return obj10;
          }
        } catch (tmp27) {
          closure_2 = tmp27;
          if (0 === c3) {
            constants = 3;
            throw tmp27;
          } else {
            c4 = 1;
          }
        }
      }
    })();
  },
  linkDispatchAuthCallback(arg0, arg1) {
    let obj;
    let obj3;
    const HTTP = HTTPUtils.HTTP;
    const request = { url: metroRequire.CONNECTIONS_LINK_DISPATCH_AUTH_CALLBACK(arg0), body: obj, oldFormErrors: true, rejectWithError: obj3.rejectWithMigratedError() };
    const post = HTTP.post;
    obj = {};
    const merged = Object.assign(arg1);
    obj3 = HTTPUtils;
    return post(request);
  },
  completeTwoWayLink(arg0, _location, arg2, body, arg4) {
    let closure_0 = arg0;
    let closure_1 = _location;
    let closure_2 = arg2;
    _asyncToGenerator = body;
    let closure_4 = arg4;
    return (async () => {
      let tmp6Result;
      let v3;
      if (null != closure_1) {
        const obj3 = c0(code[7]);
        const callbackParamsFromURL = obj3.getCallbackParamsFromURL(tmp21);
        const error = callbackParamsFromURL.error;
        const tmp6 = c0;
        const tmp7 = code;
        if (null == error) {
          const obj5 = { code, state, two_way_link_code: tmp9, token_redirect_uri };
          let c1 = 1;
          c0 = 1;
          const obj6 = { value: tmp6Result.postConnectionCallback(closure_0, obj5), done: false };
          tmp6Result = tmp6(tmp7[8]);
          return obj6;
        } else {
          const obj7 = { error, errorDescription: tmp10 };
          logger.error("Two-way link: missing authorize code", obj7);
        }
      } else {
        logger.error("Two-way link: missing authorize location");
      }
      await "IconComponent";
      return arg1;
    })();
  },
  sessionHandoff(arg0, state, code, openid_params, iss) {
    let obj;
    let obj3;
    const HTTP = HTTPUtils.HTTP;
    const request = { url: metroRequire.CONNECTIONS_SESSION_HANDOFF(arg0), body: obj, oldFormErrors: true, rejectWithError: obj3.rejectWithMigratedError() };
    const post = HTTP.post;
    obj = { state, code, openid_params, iss };
    obj3 = HTTPUtils;
    return post(request);
  },
  getHandoffStatus(arg0, state) {
    const str = new URLSearchParams();
    str.append("state", state);
    const result = metroRequire.CONNECTIONS_SESSION_HANDOFF(arg0);
    const combined = "" + result + "?" + str.toString();
    const HTTP = HTTPUtils.HTTP;
    const request = { url: combined, body: { state }, rejectWithError: true };
    return HTTP.get(request);
  }
};
let result = size.fileFinishedImporting("actions/ConnectedAccountsActionCreators.tsx");

export default obj;