Skip to content

Commit

Permalink
[Fleet] Improve default port experience in the settings UI
Browse files Browse the repository at this point in the history
  • Loading branch information
nchaulet committed Jun 22, 2021
1 parent b9f64b7 commit 8d852d1
Show file tree
Hide file tree
Showing 6 changed files with 42 additions and 17 deletions.
2 changes: 2 additions & 0 deletions x-pack/plugins/fleet/common/services/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -30,3 +30,5 @@ export {
validationHasErrors,
countValidationErrors,
} from './validate_package_policy';

export { normalizeHostsForAgents } from './hosts_utils';
47 changes: 34 additions & 13 deletions x-pack/plugins/fleet/public/components/settings_flyout/index.tsx
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@ import {
useGetOutputs,
sendPutOutput,
} from '../../hooks';
import { isDiffPathProtocol } from '../../../common';
import { isDiffPathProtocol, normalizeHostsForAgents } from '../../../common';

import { SettingsConfirmModal } from './confirm_modal';
import type { SettingsConfirmModalProps } from './confirm_modal';
Expand All @@ -53,8 +53,20 @@ interface Props {
onClose: () => void;
}

function isSameArrayValue(arrayA: string[] = [], arrayB: string[] = []) {
return arrayA.length === arrayB.length && arrayA.every((val, index) => val === arrayB[index]);
function normalizeHosts(hostsInput: string[]) {
return hostsInput.map((host) => {
try {
return normalizeHostsForAgents(host);
} catch (err) {
return host;
}
});
}

function isSameArrayValueWithNormalizedHosts(arrayA: string[] = [], arrayB: string[] = []) {
const hostsA = normalizeHosts(arrayA);
const hostsB = normalizeHosts(arrayB);
return hostsA.length === hostsB.length && hostsA.every((val, index) => val === hostsB[index]);
}

function useSettingsForm(outputId: string | undefined, onSuccess: () => void) {
Expand Down Expand Up @@ -232,8 +244,11 @@ export const SettingFlyout: React.FunctionComponent<Props> = ({ onClose }) => {
return false;
}
return (
!isSameArrayValue(settings.fleet_server_hosts, inputs.fleetServerHosts.value) ||
!isSameArrayValue(output.hosts, inputs.elasticsearchUrl.value) ||
!isSameArrayValueWithNormalizedHosts(
settings.fleet_server_hosts,
inputs.fleetServerHosts.value
) ||
!isSameArrayValueWithNormalizedHosts(output.hosts, inputs.elasticsearchUrl.value) ||
(output.config_yaml || '') !== inputs.additionalYamlConfig.value
);
}, [settings, inputs, output]);
Expand All @@ -244,32 +259,37 @@ export const SettingFlyout: React.FunctionComponent<Props> = ({ onClose }) => {
}

const tmpChanges: SettingsConfirmModalProps['changes'] = [];
if (!isSameArrayValue(output.hosts, inputs.elasticsearchUrl.value)) {
if (!isSameArrayValueWithNormalizedHosts(output.hosts, inputs.elasticsearchUrl.value)) {
tmpChanges.push(
{
type: 'elasticsearch',
direction: 'removed',
urls: output.hosts || [],
urls: normalizeHosts(output.hosts || []),
},
{
type: 'elasticsearch',
direction: 'added',
urls: inputs.elasticsearchUrl.value,
urls: normalizeHosts(inputs.elasticsearchUrl.value),
}
);
}

if (!isSameArrayValue(settings.fleet_server_hosts, inputs.fleetServerHosts.value)) {
if (
!isSameArrayValueWithNormalizedHosts(
settings.fleet_server_hosts,
inputs.fleetServerHosts.value
)
) {
tmpChanges.push(
{
type: 'fleet_server',
direction: 'removed',
urls: settings.fleet_server_hosts,
urls: normalizeHosts(settings.fleet_server_hosts || []),
},
{
type: 'fleet_server',
direction: 'added',
urls: inputs.fleetServerHosts.value,
urls: normalizeHosts(inputs.fleetServerHosts.value),
}
);
}
Expand Down Expand Up @@ -298,7 +318,7 @@ export const SettingFlyout: React.FunctionComponent<Props> = ({ onClose }) => {
helpText={
<FormattedMessage
id="xpack.fleet.settings.fleetServerHostsHelpTect"
defaultMessage="Specify the URLs that your agents will use to connect to a Fleet Server. If multiple URLs exist, Fleet shows the first provided URL for enrollment purposes. Refer to the {link}."
defaultMessage="Specify the URLs that your agents will use to connect to a Fleet Server. If multiple URLs exist, Fleet shows the first provided URL for enrollment purposes. Fleet Server uses port 8220 by default. Refer to the {link}."
values={{
link: (
<EuiLink
Expand All @@ -325,7 +345,8 @@ export const SettingFlyout: React.FunctionComponent<Props> = ({ onClose }) => {
defaultMessage: 'Elasticsearch hosts',
})}
helpText={i18n.translate('xpack.fleet.settings.elasticsearchUrlsHelpTect', {
defaultMessage: 'Specify the Elasticsearch URLs where agents send data.',
defaultMessage:
'Specify the Elasticsearch URLs where agents send data. Elasticsearch uses port 9200 by default.',
})}
/>
</EuiPanel>
Expand Down
3 changes: 1 addition & 2 deletions x-pack/plugins/fleet/server/services/output.ts
Original file line number Diff line number Diff line change
Expand Up @@ -9,10 +9,9 @@ import type { SavedObjectsClientContract } from 'src/core/server';

import type { NewOutput, Output, OutputSOAttributes } from '../types';
import { DEFAULT_OUTPUT, OUTPUT_SAVED_OBJECT_TYPE } from '../constants';
import { decodeCloudId } from '../../common';
import { decodeCloudId, normalizeHostsForAgents } from '../../common';

import { appContextService } from './app_context';
import { normalizeHostsForAgents } from './hosts_utils';

const SAVED_OBJECT_TYPE = OUTPUT_SAVED_OBJECT_TYPE;

Expand Down
7 changes: 5 additions & 2 deletions x-pack/plugins/fleet/server/services/settings.ts
Original file line number Diff line number Diff line change
Expand Up @@ -8,11 +8,14 @@
import Boom from '@hapi/boom';
import type { SavedObjectsClientContract } from 'kibana/server';

import { decodeCloudId, GLOBAL_SETTINGS_SAVED_OBJECT_TYPE } from '../../common';
import {
decodeCloudId,
GLOBAL_SETTINGS_SAVED_OBJECT_TYPE,
normalizeHostsForAgents,
} from '../../common';
import type { SettingsSOAttributes, Settings, BaseSettings } from '../../common';

import { appContextService } from './app_context';
import { normalizeHostsForAgents } from './hosts_utils';

export async function getSettings(soClient: SavedObjectsClientContract): Promise<Settings> {
const res = await soClient.find<SettingsSOAttributes>({
Expand Down

0 comments on commit 8d852d1

Please sign in to comment.