});
            saveInfo(messages -> messages.addSuccessSendTestmail(GLOBAL));
            updateProperty(Constants.NOTIFICATION_TO_PROPERTY, form.notificationTo);
            systemProperties.store();
        } catch (final Exception e) {
            logger.warn("Failed to send a test mail.", e);
            saveError(messages -> messages.addErrorsFailedToSendTestmail(GLOBAL));
        }

                                    if (values.length != 2) {
                                        throw new InvalidQueryException(
                                                messages -> messages.addErrorsInvalidQueryUnknown(UserMessages.GLOBAL_PROPERTY_KEY),
                                                "Invalid geo point: " + pt);
                                    }
                                    try {

        return factory.getSchema(jsonMapper.readTree(jsonSchemaOnDisk), config);
    }

    private void maybeLogAndCollectError(Set<ValidationMessage> messages, Map<File, Set<String>> errors, File file) {
        final String fileType = getFileType();
        for (ValidationMessage message : messages) {
            getLogger().error("[validate {}][ERROR][{}][{}]", fileType, file.getName(), message.toString());

                logger.warn("Failed to delete temporary file: {}", tempFile.getAbsolutePath());
            }
            throwValidationError(messages -> messages.addErrorsFileIsNotSupported(GLOBAL, fileName), this::asListHtml);
        }
        saveInfo(messages -> messages.addSuccessBulkProcessStarted(GLOBAL));
        return redirect(getClass()); // no-op
    }

    /**
     * Import the file asynchronously.

        this(messageCode, new Object[0], null);
    }

    /**
     * Creates {@link ClRuntimeException}.
     *
     * @param messageCode message code
     * @param args arguments for messages
     */
    public ClRuntimeException(final String messageCode, final Object[] args) {
        this(messageCode, args, null);
    }

    /**
     * Creates {@link ClRuntimeException}.
     *

.progress-message {
    text-align: center;
    font-size: 0.8125rem;
    color: #0052cc;
    font-weight: 500;
}

/* ============================================
   Chat messages area
   ============================================ */
.chat-messages {
    flex: 1;
    overflow-y: auto;
    padding: 1rem;
    scroll-behavior: smooth;
    min-height: 200px;
}

     * @return JSON response indicating success or failure
     */
    // POST /api/admin/plugin
    @Execute
    public JsonResponse<ApiResult> post$index(final InstallBody body) {
        validateApi(body, messages -> {});
        final Artifact artifact = ComponentUtil.getPluginHelper().getArtifact(body.name, body.version);
        if (artifact == null) {
            return asJson(

		}
		if m.Op != OpMerged {
			c.inMessages.Add(1)
			c.handleMsg(ctx, m, subID)
			continue
		}
		// Handle merged messages.
		messages := int(m.Seq)
		c.inMessages.Add(int64(messages))
		for range messages {
			if atomic.LoadUint32((*uint32)(&c.state)) != StateConnected {
				return
			}
			var next []byte
			next, remain, err = msgp.ReadBytesZC(remain)

            if (ssoManager.available()) {
                if (logger.isDebugEnabled()) {
                    logger.debug("SSO is available but no user found.");
                }
                saveError(messages -> messages.addErrorsSsoLoginError(GLOBAL));
            }
            if (logger.isDebugEnabled()) {
                logger.debug("Redirecting to login page.");
            }
            return redirect(LoginAction.class);

  }

  fun assertFailure(
    cls: Class<out IOException?>?,
    vararg messages: String,
  ) {
    val event = nextEvent() as Failure
    assertThat(event.response).isNull()
    assertThat(event.t.javaClass).isEqualTo(cls)
    if (messages.isNotEmpty()) {
      assertThat(messages).contains(event.t.message)
    }
  }

  fun assertFailure() {
    nextEvent() as Failure
  }