import { ajax } from "discourse/lib/ajax"; import { popupAjaxError } from "discourse/lib/ajax-error"; import CustomWizardApi from "../models/custom-wizard-api"; import { default as discourseComputed } from "discourse-common/utils/decorators"; import { and, equal, not } from "@ember/object/computed"; import { selectKitContent } from "../lib/wizard"; import { underscore } from "@ember/string"; import Controller from "@ember/controller"; import I18n from "I18n"; import { inject as service } from "@ember/service"; export default Controller.extend({ router: service(), queryParams: ["refresh_list"], loadingSubscriptions: false, notAuthorized: not("api.authorized"), endpointMethods: selectKitContent(["PUT", "POST", "PATCH", "DELETE"]), showRemove: not("isNew"), showRedirectUri: and("threeLeggedOauth", "api.name"), responseIcon: null, contentTypes: selectKitContent([ "application/json", "application/x-www-form-urlencoded", ]), successCodes: selectKitContent([ 100, 101, 102, 200, 201, 202, 203, 204, 205, 206, 207, 208, 226, 300, 301, 302, 303, 303, 304, 305, 306, 307, 308, ]), @discourseComputed( "saveDisabled", "api.authType", "api.authUrl", "api.tokenUrl", "api.clientId", "api.clientSecret", "threeLeggedOauth" ) authDisabled( saveDisabled, authType, authUrl, tokenUrl, clientId, clientSecret, threeLeggedOauth ) { if (saveDisabled || !authType || !tokenUrl || !clientId || !clientSecret) { return true; } if (threeLeggedOauth) { return !authUrl; } return false; }, @discourseComputed("api.name", "api.authType") saveDisabled(name, authType) { return !name || !authType; }, authorizationTypes: selectKitContent(["none", "basic", "oauth_2", "oauth_3"]), isBasicAuth: equal("api.authType", "basic"), @discourseComputed("api.authType") isOauth(authType) { return authType && authType.indexOf("oauth") > -1; }, twoLeggedOauth: equal("api.authType", "oauth_2"), threeLeggedOauth: equal("api.authType", "oauth_3"), @discourseComputed("api.isNew") nameClass(isNew) { return isNew ? "new" : "saved"; }, actions: { addParam() { this.get("api.authParams").pushObject({}); }, removeParam(param) { this.get("api.authParams").removeObject(param); }, addEndpoint() { this.get("api.endpoints").pushObject({}); }, removeEndpoint(endpoint) { this.get("api.endpoints").removeObject(endpoint); }, authorize() { const api = this.get("api"); const { name, authType, authUrl, authParams } = api; this.set("authErrorMessage", ""); if (authType === "oauth_2") { this.set("authorizing", true); ajax(`/admin/wizards/apis/${underscore(name)}/authorize`) .catch(popupAjaxError) .then((result) => { if (result.success) { this.set("api", CustomWizardApi.create(result.api)); } else if (result.failed && result.message) { this.set("authErrorMessage", result.message); } else { this.set("authErrorMessage", "Authorization Failed"); } setTimeout(() => { this.set("authErrorMessage", ""); }, 6000); }) .finally(() => this.set("authorizing", false)); } else if (authType === "oauth_3") { let query = "?"; query += `client_id=${api.clientId}`; query += `&redirect_uri=${encodeURIComponent(api.redirectUri)}`; query += `&response_type=code`; if (authParams) { authParams.forEach((p) => { query += `&${p.key}=${encodeURIComponent(p.value)}`; }); } window.location.href = authUrl + query; } }, save() { const api = this.get("api"); const name = api.name; const authType = api.authType; let error; if (!name || !authType) { return; } let data = { auth_type: authType, }; if (api.title) { data["title"] = api.title; } if (api.get("isNew")) { data["new"] = true; } let requiredParams; if (authType === "basic") { requiredParams = ["username", "password"]; } else if (authType === "oauth_2") { requiredParams = ["tokenUrl", "clientId", "clientSecret"]; } else if (authType === "oauth_3") { requiredParams = ["authUrl", "tokenUrl", "clientId", "clientSecret"]; } if (requiredParams) { for (let rp of requiredParams) { if (!api[rp]) { let key = rp.replace("auth", ""); error = `${I18n.t( `admin.wizard.api.auth.${underscore(key)}` )} is required for ${authType}`; break; } data[underscore(rp)] = api[rp]; } } const params = api.authParams; if (params.length) { data["auth_params"] = JSON.stringify(params); } const endpoints = api.endpoints; if (endpoints.length) { for (let e of endpoints) { if (!e.name) { error = "Every endpoint must have a name"; break; } } data["endpoints"] = JSON.stringify(endpoints); } if (error) { this.set("error", error); setTimeout(() => { this.set("error", ""); }, 6000); return; } this.set("updating", true); ajax(`/admin/wizards/api/${underscore(name)}`, { type: "PUT", data, }) .catch(popupAjaxError) .then((result) => { if (result.success) { this.send("afterSave", result.api.name); } else { this.set("responseIcon", "times"); } }) .finally(() => this.set("updating", false)); }, remove() { const name = this.get("api.name"); if (!name) { return; } this.set("updating", true); ajax(`/admin/wizards/api/${underscore(name)}`, { type: "DELETE", }) .catch(popupAjaxError) .then((result) => { if (result.success) { this.send("afterDestroy"); } }) .finally(() => this.set("updating", false)); }, clearLogs() { const name = this.get("api.name"); if (!name) { return; } ajax(`/admin/wizards/api/${underscore(name)}/logs`, { type: "DELETE", }) .catch(popupAjaxError) .then((result) => { if (result.success) { this.router.transitionToRoute("adminWizardsApis").then(() => { this.send("refreshModel"); }); } }) .finally(() => this.set("updating", false)); }, }, });