htdocs/js/selfserve.js

/*
 Licensed to the Apache Software Foundation (ASF) under one or more
 contributor license agreements.  See the NOTICE file distributed with
 this work for additional information regarding copyright ownership.
 The ASF licenses this file to You under the Apache License, Version 2.0
 (the "License"); you may not use this file except in compliance with
 the License.  You may obtain a copy of the License at

     http://www.apache.org/licenses/LICENSE-2.0

 Unless required by applicable law or agreed to in writing, software
 distributed under the License is distributed on an "AS IS" BASIS,
 WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 See the License for the specific language governing permissions and
 limitations under the License.
*/

/*
Main script library for the web-based user interface for selfserve.apache.org
*/

const LIB_NAME = '[Selfserve Platform]';

// Standard console logging for debugging purposes
/* eslint no-console: ["error", { allow: ["debug", "info", "warn", "error"] }] */
function log(msg, level = 'info') {
  if (level === 'info') console.info(LIB_NAME, msg);
}

// Simple UUID generator for debugging and oauth requests
function uuid() {
  return Math.random().toString(20).substring(2, 8)
      + Math.random().toString(20).substring(2, 8)
      + Math.random().toString(20).substring(2, 8);
}

// Converts dictionaries to FormData
function toFormData(params) {
  if (!params) return null; // No form data? Return null then.
  if (params instanceof FormData) return params; // Already a FormData object? Just return it then.
  if (params instanceof File) return params; // A File object will also suffice for Fetch.
  // Otherwise, construct from dictionary and return.
  const fd = new FormData();
  Object.entries(params).forEach(([key, value]) => fd.append(key, value));
  return fd;
}

// Basic check for whether sessionStorage is supported or not
function sessionStorageSupported() {
  try {
    const storage = window.sessionStorage;
    storage.setItem('test', 'test');
    storage.removeItem('test');
    return true;
  } catch (e) {
    return false;
  }
}

// Basic GET HTTP call
async function GET(url, params, method = 'GET') {
  const xhrID = uuid();
  const parameters = params || {}; // We want a dict here
  const headers = new Headers();
  headers.append('X-Selfserve-WebUI', 'yes'); // Inform the backend that we will not accept a Realm response
  if (parameters.json) headers.append('Content-Type', 'application/json');

  const data = parameters.json ? JSON.stringify(parameters.json) : toFormData(parameters.data);
  log(`[${xhrID}] Sending ${method} XHR to URL ${url}`);
  const response = await fetch(url, {
    method,
    headers,
    body: data,
  });
  log(`[${xhrID}] Server responded to ${method} ${url} with status: ${response.status} ${response.statusText}`);
  if (response.status >= 502) { // Proxy error??
      // convert error response to JSON for easier handling
      return Response.json({"success": false, "message": response.statusText});
  }
  return response;
}

// Wrappers for all other HTTP methods that are used by this service
const DELETE = (url, options) => GET(url, options, 'DELETE');
const MKCOL = (url, options) => GET(url, options, 'MKCOL');
const PATCH = (url, options) => GET(url, options, 'PATCH');
const POST = (url, options) => GET(url, options, 'POST');
const PROMOTE = (url, options) => GET(url, options, 'PROMOTE');
const PUT = (url, options) => GET(url, options, 'PUT');
const VERIFY = (url, options) => GET(url, options, 'VERIFY');

// OAuth gateway. Ensures OAuth is set up in the client before proceeding
// If/when OAuth is set up, this calls the original callback with the session data
// and any URL query string args
async function OAuthGate(callback) {
  const QSDict = new URLSearchParams(document.location.search);
  if (QSDict.get('action') === 'oauth') { // OAuth callback?
    const OAuthResponse = await GET(`/api/auth?${QSDict.toString()}`);
    if (OAuthResponse.status === 200) {
      if (sessionStorageSupported()) {
        const OriginURL = window.sessionStorage.getItem('asp_origin');
        // Do we have a stored URL to redirect back to, now that OAuth worked?
        if (OriginURL) {
          window.sessionStorage.removeItem('asp_origin');
          document.location.href = OriginURL;
        }
        return;
      }
    } else {
      // Something went wrong. For now, just spit out the response as an alert.
      toast(await OAuthResponse.text());
    }
  }
  const session = await GET('/api/auth');
  if (session.status === 404) { // No session set for this client yet, run the oauth process
    if (sessionStorageSupported()) {
      window.sessionStorage.setItem('asp_origin', document.location.href); // Store where we came from
    }
    // Construct OAuth URL and redirect to it
    let origin = encodeURIComponent(document.location.href);
    document.location.href = `https://${document.location.hostname}/api/auth?login=${origin}`;
  } else if (session.status === 200) { // Found a working session
    const preferences = await session.json();
    if (callback) callback(preferences, QSDict);
  } else { // Something went wrong on the backend, spit out the error msg
    toast(await session.text());
  }
}


function blur_bg(blur= true) {
  const ctx = document.getElementById('contents');
  if (blur) {
    ctx.style.filter = "blur(5px)";
    ctx.style.userSelect = "none";
  } else {
    ctx.style.filter = "";
    ctx.style.userSelect = "auto";
  }
}

function toast(message, type="danger", redirect_on_close=null) {
  // Displays a message/alert as a toast if possible, falling back to alert() otherwise
  const toastdiv = document.getElementById('liveToast');
  if (toastdiv) {
    const toastobj = new bootstrap.Toast(toastdiv);
    toastdiv.querySelector('.toast-header').setAttribute('class', `toast-header text-white bg-${type}`);
    toastdiv.querySelector('.toast-body').innerText = message;
    toastobj.show();
    toastdiv.addEventListener('hide.bs.toast', () => {
      blur_bg(false);
      if (redirect_on_close) {
        location.href = redirect_on_close;
      }
    });
    blur_bg();
  } else {
    alert(message);
  }
}

/********* JIRA ACCOUNT FUNCTIONS *********/
async function jira_seed_project_list() {
  // get project name from url parameters
  const qsProject = new URLSearchParams(document.location.search).get('project')
  // Seeds the dropdown with current projects
  const projectlist = document.getElementById('project');
  const pubresp = await GET("/api/public");
  const pubdata = await pubresp.json();
  for (project of pubdata.projects) {
    const opt = document.createElement("option");
    opt.text = project;
    opt.value = project;
    opt.selected = project == qsProject;
    projectlist.appendChild(opt);
  }
}

async function jira_check_project(project_name) {
  const apiresp = await POST("/api/jira-project-blocked", {json: {"project": project_name}});
  const apidata = await apiresp.json();
  if (apidata.blocked === true) {
    toast(`The project you have selected does not use Jira for issue tracking. Please contact the project at dev@${project_name}.apache.org to find out where to submit issues.`);
    jira_account_inputs_state("disabled");
  } else {
    jira_account_inputs_state("enabled");
  }
}

function jira_account_inputs_state(desiredState) {
  const form_elements = document.getElementsByClassName("project-dependent");
  for (e of form_elements) {
    if (desiredState === "disabled") {
      e.disabled = true;
    } else {
      e.disabled = false;
    }
  }
}

async function jira_account_request_submit(form) {
  const formdata = new FormData(form);
  if (formdata.get("verify") !== "agree") {
    toast("Please agree to sharing your data before submitting your request.");
    return false
  }
  const resp = await POST("/api/jira-account", {data: formdata});
  const result = await resp.json();
  if (!result.success) {
    toast(result.message);
    return false
  }
  const container = document.getElementById('contents');
  container.innerText = "Your request to create a Jira account has been submitted. Please check your email inbox for further information, as you will need to verify your email address."
  return false
}

async function jira_verify_email(token) {
  const resp = await GET(`/api/jira-account?token=${token}`);
  const result = await resp.json();
  const container = document.getElementById('verify_response');
  if (result.success) {
    container.innerText = `Your Jira account request has been successfully verified, and will be reviewed by the project you indicated. \
                           Please allow up to a few days for the project to review this request.\
                           If you do not receive a reply from the project within seven days, you can contact the project management committee \
                           privately at ${result.ppl}. If the project is still unable to respond, you can then escalate the matter to the \
                           ASF Infrastructure team at users@infra.apache.org`;
  } else {
    container.innerText = "We were unable to verify your account token. If you feel this is in error, please let us know at: users@infra.apache.org."
    toast(result.message);
  }
}

async function jira_account_review(prefs, qs) {
  const token = qs.get("token");
  const resp = await GET(`/api/jira-account-review?token=${token}`);
  const result = await resp.json();
  if (!result.success) {
    toast(result.message);
  } else {
    const username = document.getElementById('username');
    username.value = result.entry.userid;
    const realname = document.getElementById('realname');
    realname.value = result.entry.realname;
    const why = document.getElementById('why');
    why.value = result.entry.why;
    const toktxt = document.getElementById('token');
    toktxt.value = token;
    const projecttxt = document.getElementById('project');
    projecttxt.value = result.entry.project;
  }
}

async function jira_account_approve(form, verdict = "deny") {
  // Approve or deny a jira account request
  const data = new FormData(form)
  data.set("action", verdict);
  // Hide deny details panel and buttons
  const deny_details = document.getElementById('deny_details');
  deny_details.style.display = "none";
  const btns = document.getElementById('buttons_real');
  btns.style.display = "none";
  // Show spinner
  const spin = document.getElementById('buttons_spin');
  spin.style.display = "block";
  const resp = await POST("/api/jira-account-review", {data: data})
  const result = await resp.json();
  if (result.success) {
    const container = document.getElementById('contents');
    container.innerText = result.message;
  } else {
    toast(result.message);
    // Put back buttons, hide spinner
    btns.style.display = "block";
    spin.style.display = "none";
  }
}

function jira_account_deny_details() {
  const real_buttons = document.getElementById('buttons_real');
  real_buttons.style.display = "none";
  const deny_details = document.getElementById('deny_details');
  deny_details.style.display = "block";
}

async function jira_account_reactivate_submit(form) {
  const formdata = new FormData(form);
  const resp = await POST("/api/jira-account-activate", {data: formdata});
  const result = await resp.json();
  if (!result.success) {
    toast(result.message);
    return false
  }
  const container = document.getElementById('form_submit');
  container.innerText = "Your request to re-activate your Jira account has been logged. Please check your email addresss for a confirmation email, and confirm your identity by clicking on the link provided in the email."
  return false
}

async function jira_account_reactivate_verify_email(token) {
  const jform = document.getElementById('form_submit');
  jform.style.display = "none";
  const spinner = document.getElementById('process_spin');
  spinner.style.display = "block";
  const resp = await GET(`/api/jira-account-activate-confirm?token=${token}`);
  const result = await resp.json();
  if (result.success) {
    spinner.innerText = "Your Jira account has been successfully re-activated, enjoy!";
  } else {
    if (result.error) {
      spinner.innerText = result.error;
    } else {
      spinner.innerText = "We were unable to verify your account token. If you feel this is in error, please let us know at: users@infra.apache.org."
    }
    toast(result.error);
  }
}

/********* END OF JIRA ACCOUNT FUNCTIONS *********/
/********* CONFLUENCE ACCOUNT FUNCTIONS *********/

async function confluence_seed_project_list() {
  // get project name from url parameters
  const qsProject = new URLSearchParams(document.location.search).get('project')
  // Seeds the dropdown with current projects
  const projectlist = document.getElementById('project');
  const pubresp = await GET("/api/public");
  const pubdata = await pubresp.json();
  for (project of pubdata.projects) {
    const opt = document.createElement("option");
    opt.text = project;
    opt.value = project;
    opt.selected = project == qsProject;
    projectlist.appendChild(opt);
  }
}

async function confluence_check_project(project_name) {
  const apiresp = await POST("/api/confluence-project-blocked", {json: {"project": project_name}});
  const apidata = await apiresp.json();
  if (apidata.blocked === true) {
    toast(`The project you have selected does not use Confluence. Please contact the project at dev@${project_name}.apache.org to find out where thy use a wiki.`);
    confluence_account_inputs_state("disabled");
  } else {
    confluence_account_inputs_state("enabled");
  }
}

function confluence_account_inputs_state(desiredState) {
  const form_elements = document.getElementsByClassName("project-dependent");
  for (e of form_elements) {
    if (desiredState === "disabled") {
      e.disabled = true;
    } else {
      e.disabled = false;
    }
  }
}

async function confluence_account_request_submit(form) {
  const formdata = new FormData(form);
  if (formdata.get("verify") !== "agree") {
    toast("Please agree to sharing your data before submitting your request.");
    return false
  }
  const resp = await POST("/api/confluence-account", {data: formdata});
  const result = await resp.json();
  if (!result.success) {
    toast(result.message);
    return false
  }
  const container = document.getElementById('contents');
  container.innerText = "Your request to create a Confluence account has been submitted. Please check your email inbox for further information, as you will need to verify your email address."
  return false
}

async function confluence_verify_email(token) {
  const resp = await GET(`/api/confluence-account?token=${token}`);
  const result = await resp.json();
  const container = document.getElementById('verify_response');
  if (result.success) {
    container.innerText = `Your Confluence account request has been successfully verified, and will be reviewed by the project you indicated. \
                           Please allow up to a few days for the project to review this request.\
                           If you do not receive a reply from the project within seven days, you can contact the project management committee \
                           privately at ${result.ppl}. If the project is still unable to respond, you can then escalate the matter to the \
                           ASF Infrastructure team at users@infra.apache.org`;
  } else {
    container.innerText = "We were unable to verify your account token. If you feel this is in error, please let us know at: users@infra.apache.org."
    toast(result.message);
  } 
}   
    
async function confluence_account_review(prefs, qs) {
  const token = qs.get("token");
  const resp = await GET(`/api/confluence-account-review?token=${token}`);
  const result = await resp.json();
  if (!result.success) {
    toast(result.message);
  } else {
    const username = document.getElementById('username');
    username.value = result.entry.userid;
    const realname = document.getElementById('realname');
    realname.value = result.entry.realname;    
    const why = document.getElementById('why');
    why.value = result.entry.why;
    const toktxt = document.getElementById('token');
    toktxt.value = token;
    const projecttxt = document.getElementById('project');
    projecttxt.value = result.entry.project;
  } 
}     
    
async function confluence_account_approve(form, verdict = "deny") {
  // Approve or deny a confluence account request
  const data = new FormData(form)
  data.set("action", verdict);
  // Hide deny details panel and buttons
  const deny_details = document.getElementById('deny_details');
  deny_details.style.display = "none";
  const btns = document.getElementById('buttons_real');
  btns.style.display = "none";
  // Show spinner
  const spin = document.getElementById('buttons_spin');
  spin.style.display = "block";
  const resp = await POST("/api/confluence-account-review", {data: data})
  const result = await resp.json();
  if (result.success) {
    const container = document.getElementById('contents');
    container.innerText = result.message;
  } else {
    toast(result.message);
    // Put back buttons, hide spinner
    btns.style.display = "block";
    spin.style.display = "none";
  }
}

function confluence_account_deny_details() {
  const real_buttons = document.getElementById('buttons_real');
  real_buttons.style.display = "none";
  const deny_details = document.getElementById('deny_details');
  deny_details.style.display = "block";
}

async function confluence_account_reactivate_submit(form) {
  const formdata = new FormData(form);
  const resp = await POST("/api/confluence-account-activate", {data: formdata});
  const result = await resp.json();
  if (!result.success) {
    toast(result.message);
    return false
  }
  const container = document.getElementById('form_submit');
  container.innerText = "Your request to re-activate your Confluence account has been logged. Please check your email addresss for a confirmation email, and confirm your identity by clicking on the link provided in the email."
  return false
}

async function confluence_account_reactivate_verify_email(token) {
  const jform = document.getElementById('form_submit');
  jform.style.display = "none";
  const spinner = document.getElementById('process_spin');
  spinner.style.display = "block";
  const resp = await GET(`/api/confluence-account-activate-confirm?token=${token}`);
  const result = await resp.json();
  if (result.success) {
    spinner.innerText = "Your Confluence account has been successfully re-activated, enjoy!";
  } else {
    if (result.error) {
      spinner.innerText = result.error;
    } else {
      spinner.innerText = "We were unable to verify your account token. If you feel this is in error, please let us know at: users@infra.apache.org."
    }
    toast(result.error);
  }
}

/********* END OF CONFLUENCE ACCOUNT FUNCTIONS *********/

async function mailinglist_seed_domain_list(prefs) {
  // Seeds the dropdown with current mailing list domains
  const domainlist = document.getElementById('domainpart');
  const pubresp = await GET("/api/public");
  const pubdata = await pubresp.json();
  for (const [project, domain] of Object.entries(pubdata.mail_domains)) {
    // Only add domain if user can request lists for it. Either by being root, or by being on a PMC
    if (prefs.isRoot || prefs.committees.includes(project)) {
      const opt = document.createElement("option");
      opt.text = domain;
      opt.value = domain;
      domainlist.appendChild(opt);
    }
  }
}


function mailinglist_update_privacy(listpart, privatetick = false) {
  const span = document.getElementById('privacy_note');
  if (listpart == "private" || listpart == "security" || privatetick === true) {
    span.innerText = "This list will be PRIVATE";
    span.style.color = "maroon";
  } else {
    span.innerText = "This list will be PUBLIC.";
    span.style.color = "darkgreen";
  }
}


async function mailinglist_new(prefs) {
  await mailinglist_seed_domain_list(prefs);
  if (prefs.isRoot) {
    const admindiv = document.getElementById('admin_div');
    admindiv.style.display = "block";
  }
}

async function mailinglist_new_submit(form) {
  const data = new FormData(form);
  const moderators = new Array();
  for (const modemail of data.get("moderators").split("\n")) {
    const email_trimmed = modemail.trim();
    if (email_trimmed.length > 4) {
      moderators.push(email_trimmed);
    }
  }
  const listpart = data.get("listpart");
  let is_private = data.get("private") === "yes";
  if (listpart == "private" || listpart == "security") {
    is_private = true;
  }
  const resp = await POST("/api/mailinglist", {
    json: {
      listpart: listpart,
      domainpart: data.get("domainpart"),
      moderators: moderators,
      muopts: data.get("muopts"),
      private: is_private,
      trailer: data.get("trailer") === "yes",
      expedited: data.get("expedited") === "yes"
    }
  });
  const result = await resp.json();
  if (result.success) {
    toast(result.message, type="success", redirect_on_close="/");
  } else {
    toast(result.message);
  }
}

async function confluence_archive(form) {
  // Archive a confluence space
  const data = new FormData(form);
  const spacename = data.get("spacename");
  if (!spacename.match(/^[A-Z0-9][A-Z0-9]+$/)) {
    toast("Please enter a valid confluence space name");
    return
  }

  // Set spinner, hide real button
  const buttons = document.getElementById('buttons_real');
  buttons.style.display = "none";
  const spin = document.getElementById('buttons_spin');
  spin.style.display = "block";

  // Send off request
  const resp = await POST("/api/confluence-archive", {
    json: {
      space: spacename
    }
  });
  const result = await resp.json();
  if (result.success) {
    toast(result.message, type="success", redirect_on_close="/");
  } else {
    toast(result.message);
    // hide spinner, put button back
    buttons.style.display = "block";
    spin.style.display = "none";
  }
}


async function confluence_create(form) {
  // Archive a confluence space
  const data = new FormData(form);
  const spacename = data.get("spacename");
  const description = data.get("description");
  const admin = data.get("admin");
  if (!spacename.match(/^[A-Z0-9][A-Z0-9]+$/)) {
    toast("Please enter a valid confluence space name");
    return
  }

  // Set spinner, hide real button
  const buttons = document.getElementById('buttons_real');
  buttons.style.display = "none";
  const spin = document.getElementById('buttons_spin');
  spin.style.display = "block";

  // Send off request
  const resp = await POST("/api/confluence-create", {
    json: {
      space: spacename,
      description: description,
      admin: admin
    }
  });
  const result = await resp.json();
  if (result.success) {
    toast(result.message, type="success", redirect_on_close="/");
  } else {
    toast(result.message);
    // hide spinner, put button back
    buttons.style.display = "block";
    spin.style.display = "none";
  }
}


async function jira_seed_schemes() {
  // Seeds the appropriate dropdowns with current schemes
  const pubresp = await GET("/api/jira-project-schemes");
  const pubdata = await pubresp.json();

  for (const [schemename, schemelist] of Object.entries(pubdata)) {
    const scheme_obj = document.getElementById(`${schemename}_scheme`);
    if (scheme_obj) {
      for (const entry of schemelist) {
        const opt = document.createElement("option");
        opt.text = entry;
        opt.value = entry;
        scheme_obj.appendChild(opt);
      }
    }
  }
}

async function jira_create(form) {
  // Create a new jira project
  const data = new FormData(form);

  // Set spinner, hide real button
  const buttons = document.getElementById('buttons_real');
  buttons.style.display = "none";
  const spin = document.getElementById('buttons_spin');
  spin.style.display = "block";

  // Send off request
  const resp = await POST("/api/jira-project-create", {
    data: data
  });
  const result = await resp.json();
  if (result.success) {
    toast(result.message, type="success", redirect_on_close="/");
  } else {
    toast(result.message);
    // hide spinner, put button back
    buttons.style.display = "block";
    spin.style.display = "none";
  }
}

async function jira_create_prime() {
  await jira_seed_project_list();
  await jira_seed_schemes();
}