fix(docker/container): use nodeName to build links to networks used by containers (#12004)

pull/12045/head
LP B 2024-07-17 14:40:10 +02:00 committed by GitHub
parent 20de243299
commit e2830019d7
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
11 changed files with 133 additions and 172 deletions

View File

@ -70,22 +70,6 @@ angular.module('portainer.docker').factory('NetworkService', [
return Network.remove({ id: id }).$promise; return Network.remove({ id: id }).$promise;
}; };
service.disconnectContainer = function (networkId, containerId, force) {
return Network.disconnect({ id: networkId }, { Container: containerId, Force: force }).$promise;
};
service.connectContainer = function (networkId, containerId, aliases) {
var payload = {
Container: containerId,
};
if (aliases) {
payload.EndpointConfig = {
Aliases: aliases,
};
}
return Network.connect({ id: networkId }, payload).$promise;
};
return service; return service;
}, },
]); ]);

View File

@ -349,15 +349,5 @@
</div> </div>
</div> </div>
<docker-container-networks-datatable <docker-container-networks-datatable ng-if="container.NetworkSettings.Networks" dataset="container.NetworkSettings.Networks" container="container" node-name="nodeName">
ng-if="container.NetworkSettings.Networks"
dataset="container.NetworkSettings.Networks"
container="container"
available-networks="availableNetworks"
on-join="(containerJoinNetwork)"
join-in-progress="state.joinNetworkInProgress"
on-leave="(containerLeaveNetwork)"
leave-in-progress="state.leaveNetworkInProgress"
node-name="nodeName"
>
</docker-container-networks-datatable> </docker-container-networks-datatable>

View File

@ -14,37 +14,13 @@ angular.module('portainer.docker').controller('ContainerController', [
'$filter', '$filter',
'$async', '$async',
'Commit', 'Commit',
'ContainerHelper',
'ContainerService', 'ContainerService',
'ImageHelper', 'ImageHelper',
'NetworkService',
'Notifications', 'Notifications',
'ResourceControlService',
'RegistryService',
'ImageService',
'HttpRequestHelper', 'HttpRequestHelper',
'Authentication', 'Authentication',
'endpoint', 'endpoint',
function ( function ($q, $scope, $state, $transition$, $filter, $async, Commit, ContainerService, ImageHelper, Notifications, HttpRequestHelper, Authentication, endpoint) {
$q,
$scope,
$state,
$transition$,
$filter,
$async,
Commit,
ContainerHelper,
ContainerService,
ImageHelper,
NetworkService,
Notifications,
ResourceControlService,
RegistryService,
ImageService,
HttpRequestHelper,
Authentication,
endpoint
) {
$scope.resourceType = ResourceControlType.Container; $scope.resourceType = ResourceControlType.Container;
$scope.endpoint = endpoint; $scope.endpoint = endpoint;
$scope.isAdmin = Authentication.isAdmin(); $scope.isAdmin = Authentication.isAdmin();
@ -61,8 +37,6 @@ angular.module('portainer.docker').controller('ContainerController', [
$scope.state = { $scope.state = {
recreateContainerInProgress: false, recreateContainerInProgress: false,
joinNetworkInProgress: false,
leaveNetworkInProgress: false,
pullImageValidity: false, pullImageValidity: false,
}; };
@ -225,36 +199,6 @@ angular.module('portainer.docker').controller('ContainerController', [
}); });
}; };
$scope.containerLeaveNetwork = function containerLeaveNetwork(container, networkId) {
$scope.state.leaveNetworkInProgress = true;
NetworkService.disconnectContainer(networkId, container.Id, false)
.then(function success() {
Notifications.success('Container left network', container.Id);
$state.reload();
})
.catch(function error(err) {
Notifications.error('Failure', err, 'Unable to disconnect container from network');
})
.finally(function final() {
$scope.state.leaveNetworkInProgress = false;
});
};
$scope.containerJoinNetwork = function containerJoinNetwork(container, networkId) {
$scope.state.joinNetworkInProgress = true;
NetworkService.connectContainer(networkId, container.Id)
.then(function success() {
Notifications.success('Container joined network', container.Id);
$state.reload();
})
.catch(function error(err) {
Notifications.error('Failure', err, 'Unable to connect container to network');
})
.finally(function final() {
$scope.state.joinNetworkInProgress = false;
});
};
async function commitContainerAsync() { async function commitContainerAsync() {
$scope.config.commitInProgress = true; $scope.config.commitInProgress = true;
const registryModel = $scope.config.RegistryModel; const registryModel = $scope.config.RegistryModel;
@ -349,17 +293,6 @@ angular.module('portainer.docker').controller('ContainerController', [
} }
} }
var provider = $scope.applicationState.endpoint.mode.provider;
var apiVersion = $scope.applicationState.endpoint.apiVersion;
NetworkService.networks(provider === 'DOCKER_STANDALONE' || provider === 'DOCKER_SWARM_MODE', false, provider === 'DOCKER_SWARM_MODE' && apiVersion >= 1.25)
.then(function success(data) {
var networks = data;
$scope.availableNetworks = networks;
})
.catch(function error(err) {
Notifications.error('Failure', err, 'Unable to retrieve networks');
});
update(); update();
}, },
]); ]);

View File

@ -1,16 +1,42 @@
import { ColumnDef, CellContext } from '@tanstack/react-table'; import { ColumnDef, CellContext } from '@tanstack/react-table';
import { UISrefProps } from '@uirouter/react';
import { Link } from '@@/Link'; import { Link } from '@@/Link';
import { DefaultType } from './types'; import { DefaultType } from './types';
import { defaultGetRowId } from './defaultGetRowId'; import { defaultGetRowId } from './defaultGetRowId';
/**
* @deprecated Use `buildNameColumnFromObject` instead
* @todo Replace `buildNameColumnFromObject` and rename to `buildNameColumn`
*/
export function buildNameColumn<T extends DefaultType>( export function buildNameColumn<T extends DefaultType>(
nameKey: keyof T, nameKey: keyof T,
path: string, path: string,
idParam = 'id', idParam = 'id',
idGetter: (row: T) => string = defaultGetRowId<T> idGetter: (row: T) => string = defaultGetRowId<T>
): ColumnDef<T> { ): ColumnDef<T> {
return buildNameColumnFromObject({
nameKey,
path,
idParam,
idGetter,
});
}
export function buildNameColumnFromObject<T extends DefaultType>({
nameKey,
path,
idParam = 'id',
idGetter = defaultGetRowId<T>,
linkParamsBuilder = () => ({}),
}: {
nameKey: keyof T;
path: string;
idParam?: string;
idGetter?: (row: T) => string;
linkParamsBuilder?: (row: T) => UISrefProps['params'];
}): ColumnDef<T> {
const cell = createCell(); const cell = createCell();
return { return {
@ -33,7 +59,10 @@ export function buildNameColumn<T extends DefaultType>(
return ( return (
<Link <Link
to={path} to={path}
params={{ [idParam]: idGetter(row.original) }} params={{
...linkParamsBuilder(row.original),
[idParam]: idGetter(row.original),
}}
title={name} title={name}
> >
{name} {name}

View File

@ -1,3 +1,4 @@
import { useMemo } from 'react';
import { Network } from 'lucide-react'; import { Network } from 'lucide-react';
import { EndpointSettings, NetworkSettings } from 'docker-types/generated/1.41'; import { EndpointSettings, NetworkSettings } from 'docker-types/generated/1.41';
@ -9,7 +10,7 @@ import { withMeta } from '@@/datatables/extend-options/withMeta';
import { DockerContainer } from '../../types'; import { DockerContainer } from '../../types';
import { TableNetwork } from './types'; import { TableNetwork } from './types';
import { columns } from './columns'; import { buildColumns } from './columns';
import { ConnectNetworkForm } from './ConnectNetworkForm'; import { ConnectNetworkForm } from './ConnectNetworkForm';
const storageKey = 'container-networks'; const storageKey = 'container-networks';
@ -25,6 +26,7 @@ export function ContainerNetworksDatatable({
nodeName?: string; nodeName?: string;
}) { }) {
const tableState = useTableState(store, storageKey); const tableState = useTableState(store, storageKey);
const columns = useMemo(() => buildColumns({ nodeName }), [nodeName]);
const networks: Array<TableNetwork> = Object.entries(dataset || {}) const networks: Array<TableNetwork> = Object.entries(dataset || {})
.filter(isNetworkDefined) .filter(isNetworkDefined)

View File

@ -10,51 +10,54 @@ import { LoadingButton } from '@@/buttons';
import { TableNetwork, isContainerNetworkTableMeta } from './types'; import { TableNetwork, isContainerNetworkTableMeta } from './types';
import { columnHelper } from './helper'; import { columnHelper } from './helper';
export const actions = columnHelper.display({ export function buildActions({ nodeName }: { nodeName?: string } = {}) {
header: 'Actions', return columnHelper.display({
cell: Cell, header: 'Actions',
}); cell: Cell,
});
function Cell({ function Cell({
row, row,
table: { table: {
options: { meta }, options: { meta },
}, },
}: CellContext<TableNetwork, unknown>) { }: CellContext<TableNetwork, unknown>) {
const router = useRouter(); const router = useRouter();
const environmentId = useEnvironmentId(); const environmentId = useEnvironmentId();
const disconnectMutation = useDisconnectContainer(); const disconnectMutation = useDisconnectContainer();
return ( return (
<Authorized authorizations="DockerNetworkDisconnect"> <Authorized authorizations="DockerNetworkDisconnect">
<LoadingButton <LoadingButton
color="dangerlight" color="dangerlight"
isLoading={disconnectMutation.isLoading} isLoading={disconnectMutation.isLoading}
loadingText="Leaving network..." loadingText="Leaving network..."
type="button" type="button"
onClick={handleSubmit} onClick={handleSubmit}
> >
Leave network Leave network
</LoadingButton> </LoadingButton>
</Authorized> </Authorized>
);
function handleSubmit() {
if (!isContainerNetworkTableMeta(meta)) {
throw new Error('Invalid row meta');
}
disconnectMutation.mutate(
{
environmentId,
networkId: row.original.id,
containerId: meta.containerId,
},
{
onSuccess() {
router.stateService.reload();
},
}
); );
function handleSubmit() {
if (!isContainerNetworkTableMeta(meta)) {
throw new Error('Invalid row meta');
}
disconnectMutation.mutate(
{
environmentId,
networkId: row.original.id,
containerId: meta.containerId,
nodeName,
},
{
onSuccess() {
router.stateService.reload();
},
}
);
}
} }
} }

View File

@ -1,30 +1,36 @@
import { buildExpandColumn } from '@@/datatables/expand-column'; import { buildExpandColumn } from '@@/datatables/expand-column';
import { buildNameColumn } from '@@/datatables/buildNameColumn'; import { buildNameColumnFromObject } from '@@/datatables/buildNameColumn';
import { TableNetwork } from './types'; import { TableNetwork } from './types';
import { columnHelper } from './helper'; import { columnHelper } from './helper';
import { actions } from './actions'; import { buildActions } from './actions';
export const columns = [ export function buildColumns({ nodeName }: { nodeName?: string } = {}) {
buildExpandColumn<TableNetwork>(), return [
{ buildExpandColumn<TableNetwork>(),
...buildNameColumn<TableNetwork>('name', 'docker.networks.network'), {
header: 'Network', ...buildNameColumnFromObject<TableNetwork>({
}, nameKey: 'name',
columnHelper.accessor((item) => item.IPAddress || '-', { path: 'docker.networks.network',
header: 'IP Address', linkParamsBuilder: () => ({ nodeName }),
id: 'ip', }),
enableSorting: false, header: 'Network',
}), },
columnHelper.accessor((item) => item.Gateway || '-', { columnHelper.accessor((item) => item.IPAddress || '-', {
header: 'Gateway', header: 'IP Address',
id: 'gateway', id: 'ip',
enableSorting: false, enableSorting: false,
}), }),
columnHelper.accessor((item) => item.MacAddress || '-', { columnHelper.accessor((item) => item.Gateway || '-', {
header: 'MAC Address', header: 'Gateway',
id: 'macAddress', id: 'gateway',
enableSorting: false, enableSorting: false,
}), }),
actions, columnHelper.accessor((item) => item.MacAddress || '-', {
]; header: 'MAC Address',
id: 'macAddress',
enableSorting: false,
}),
buildActions({ nodeName }),
];
}

View File

@ -75,6 +75,7 @@ export function NetworkContainersTable({
containerId: container.Id, containerId: container.Id,
environmentId, environmentId,
networkId, networkId,
nodeName,
}); });
} }
}} }}

View File

@ -56,13 +56,24 @@ export async function deleteNetwork(
export async function disconnectContainer( export async function disconnectContainer(
environmentId: EnvironmentId, environmentId: EnvironmentId,
networkId: NetworkId, networkId: NetworkId,
containerId: ContainerId containerId: ContainerId,
nodeName?: string
) { ) {
try { try {
await axios.post(buildUrl(environmentId, networkId, 'disconnect'), { await axios.post(
Container: containerId, buildUrl(environmentId, networkId, 'disconnect'),
Force: false, {
}); Container: containerId,
Force: false,
},
nodeName
? {
headers: {
[agentTargetHeader]: nodeName,
},
}
: undefined
);
return { networkId, environmentId }; return { networkId, environmentId };
} catch (e) { } catch (e) {
throw parseAxiosError( throw parseAxiosError(

View File

@ -67,11 +67,13 @@ export function useDisconnectContainer() {
containerId, containerId,
environmentId, environmentId,
networkId, networkId,
nodeName,
}: { }: {
containerId: ContainerId; containerId: ContainerId;
environmentId: EnvironmentId; environmentId: EnvironmentId;
networkId: NetworkId; networkId: NetworkId;
}) => disconnectContainer(environmentId, networkId, containerId), nodeName?: string;
}) => disconnectContainer(environmentId, networkId, containerId, nodeName),
{ {
onSuccess: ({ networkId, environmentId }) => { onSuccess: ({ networkId, environmentId }) => {
notifySuccess('Container successfully disconnected', networkId); notifySuccess('Container successfully disconnected', networkId);

View File

@ -8,7 +8,7 @@ mkdir -p dist
BUILDNUMBER=${BUILDNUMBER:-"N/A"} BUILDNUMBER=${BUILDNUMBER:-"N/A"}
CONTAINER_IMAGE_TAG=${CONTAINER_IMAGE_TAG:-"N/A"} CONTAINER_IMAGE_TAG=${CONTAINER_IMAGE_TAG:-"N/A"}
NODE_VERSION=${NODE_VERSION:-$(node -v)} NODE_VERSION=${NODE_VERSION:-$(node -v)}
YARN_VERSION=${YARN_VERSION:-$(yarn --version))} YARN_VERSION=${YARN_VERSION:-$(yarn --version)}
WEBPACK_VERSION=${WEBPACK_VERSION:-$(yarn list webpack --depth=0 | grep webpack | awk -F@ '{print $2}')} WEBPACK_VERSION=${WEBPACK_VERSION:-$(yarn list webpack --depth=0 | grep webpack | awk -F@ '{print $2}')}
GO_VERSION=${GO_VERSION:-$(go version | awk '{print $3}')} GO_VERSION=${GO_VERSION:-$(go version | awk '{print $3}')}
GIT_COMMIT_HASH=${GIT_COMMIT_HASH:-$(git rev-parse --short HEAD)} GIT_COMMIT_HASH=${GIT_COMMIT_HASH:-$(git rev-parse --short HEAD)}