365 lines
13 KiB
TypeScript
365 lines
13 KiB
TypeScript
// Module ID: 5719
|
|
// Function ID: 5720
|
|
// Name: ConnectedAccountsActionCreators
|
|
// Dependencies: [5, 5594, 1086, 3, 1283, 585, 1253, 5720, 5030, 1261, 2]
|
|
|
|
// Module 5719 (ConnectedAccountsActionCreators)
|
|
import LoggerDefault from "Logger" /* 3 */;
|
|
import DispatcherDefault from "Dispatcher" /* 585 */;
|
|
import discord_common_AnalyticsUtils from "discord_common/AnalyticsUtils" /* 1261 */;
|
|
import HTTPUtils from "HTTPUtils" /* 1283 */;
|
|
import TrackedHTTPUtilsDefault from "TrackedHTTPUtils" /* 5030 */;
|
|
import _asyncToGenerator_mod from "_asyncToGenerator" /* 5 */;
|
|
import ConnectedAccountsStore from "ConnectedAccountsStore" /* 5594 */;
|
|
import Constants from "Constants" /* 1086 */;
|
|
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;
|
|
function callback(arg0, arg1) {
|
|
let obj;
|
|
let obj3;
|
|
let flag = arg2;
|
|
if (arg2 === undefined) {
|
|
flag = false;
|
|
}
|
|
const HTTP = HTTPUtils.HTTP;
|
|
const request = { url: metroRequire.CONNECTIONS_CALLBACK(arg0), body: obj, oldFormErrors: true, rejectWithError: obj3.rejectWithMigratedError() };
|
|
const post = HTTP.post;
|
|
obj = { insecure: flag, friend_sync: metroImportDefault.has(arg0) };
|
|
const merged = Object.assign(arg1);
|
|
obj3 = HTTPUtils;
|
|
return post(request);
|
|
}
|
|
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() {
|
|
const HTTP = HTTPUtils.HTTP;
|
|
let obj = { url: metroRequire.CONNECTIONS, oldFormErrors: true, rejectWithError: true };
|
|
const value = HTTP.get(obj);
|
|
return value.then((accounts) => {
|
|
const obj = DispatcherDefault;
|
|
const obj2 = { type: "USER_CONNECTIONS_UPDATE", local: true, accounts: accounts.body };
|
|
return obj.dispatch(obj2);
|
|
}, () => {
|
|
const obj = DispatcherDefault;
|
|
return obj.dispatch({ type: "USER_CONNECTIONS_UPDATE", local: true, accounts: [] });
|
|
});
|
|
},
|
|
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,
|
|
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 obj = { show_activity };
|
|
return this.update(type, id, obj);
|
|
},
|
|
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(585).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[5]);
|
|
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[5]);
|
|
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 v3;
|
|
if (null != closure_1) {
|
|
const obj3 = c0(code[7]);
|
|
const callbackParamsFromURL = obj3.getCallbackParamsFromURL(tmp22);
|
|
const error = callbackParamsFromURL.error;
|
|
if (null == error) {
|
|
const obj5 = { code, state, two_way_link_code: tmp9, token_redirect_uri };
|
|
let c1 = 1;
|
|
c0 = 1;
|
|
const obj6 = { value: callback(closure_0, obj5), done: false };
|
|
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;
|