Skip to content

Commit

Permalink
77133: fix path with leading slash
Browse files Browse the repository at this point in the history
  • Loading branch information
nnamdifrankie committed Sep 16, 2020
1 parent aeade44 commit 52a972c
Show file tree
Hide file tree
Showing 3 changed files with 17 additions and 17 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -157,14 +157,14 @@ async function installTransform({
// defer validation on put if the source index is not available
await callCluster('transport.request', {
method: 'PUT',
path: `_transform/${transform.installationName}`,
path: `/_transform/${transform.installationName}`,
query: 'defer_validation=true',
body: transform.content,
});

await callCluster('transport.request', {
method: 'POST',
path: `_transform/${transform.installationName}/_start`,
path: `/_transform/${transform.installationName}/_start`,
});

return { id: transform.installationName, type: ElasticsearchAssetType.transform };
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@ export const stopTransforms = async (transformIds: string[], callCluster: CallES
for (const transformId of transformIds) {
await callCluster('transport.request', {
method: 'POST',
path: `_transform/${transformId}/_stop`,
path: `/_transform/${transformId}/_stop`,
query: 'force=true',
ignore: [404],
});
Expand All @@ -27,15 +27,15 @@ export const deleteTransforms = async (
transformIds.map(async (transformId) => {
const response = await callCluster('transport.request', {
method: 'GET',
path: `_transform/${transformId}`,
path: `/_transform/${transformId}`,
ignore: [404],
});
if (response && response.count > 0) {
await stopTransforms([transformId], callCluster);
await callCluster('transport.request', {
method: 'DELETE',
query: 'force=true',
path: `_transform/${transformId}`,
path: `/_transform/${transformId}`,
ignore: [404],
});
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -150,15 +150,15 @@ describe('test transform install', () => {
'transport.request',
{
method: 'GET',
path: '_transform/metrics-endpoint.metadata_current-default-0.15.0-dev.0',
path: '/_transform/metrics-endpoint.metadata_current-default-0.15.0-dev.0',
ignore: [404],
},
],
[
'transport.request',
{
method: 'POST',
path: '_transform/metrics-endpoint.metadata_current-default-0.15.0-dev.0/_stop',
path: '/_transform/metrics-endpoint.metadata_current-default-0.15.0-dev.0/_stop',
query: 'force=true',
ignore: [404],
},
Expand All @@ -168,15 +168,15 @@ describe('test transform install', () => {
{
method: 'DELETE',
query: 'force=true',
path: '_transform/metrics-endpoint.metadata_current-default-0.15.0-dev.0',
path: '/_transform/metrics-endpoint.metadata_current-default-0.15.0-dev.0',
ignore: [404],
},
],
[
'transport.request',
{
method: 'PUT',
path: '_transform/metrics-endpoint.metadata-default-0.16.0-dev.0',
path: '/_transform/metrics-endpoint.metadata-default-0.16.0-dev.0',
query: 'defer_validation=true',
body: '{"content": "data"}',
},
Expand All @@ -185,7 +185,7 @@ describe('test transform install', () => {
'transport.request',
{
method: 'PUT',
path: '_transform/metrics-endpoint.metadata_current-default-0.16.0-dev.0',
path: '/_transform/metrics-endpoint.metadata_current-default-0.16.0-dev.0',
query: 'defer_validation=true',
body: '{"content": "data"}',
},
Expand All @@ -194,14 +194,14 @@ describe('test transform install', () => {
'transport.request',
{
method: 'POST',
path: '_transform/metrics-endpoint.metadata-default-0.16.0-dev.0/_start',
path: '/_transform/metrics-endpoint.metadata-default-0.16.0-dev.0/_start',
},
],
[
'transport.request',
{
method: 'POST',
path: '_transform/metrics-endpoint.metadata_current-default-0.16.0-dev.0/_start',
path: '/_transform/metrics-endpoint.metadata_current-default-0.16.0-dev.0/_start',
},
],
]);
Expand Down Expand Up @@ -314,7 +314,7 @@ describe('test transform install', () => {
'transport.request',
{
method: 'PUT',
path: '_transform/metrics-endpoint.metadata_current-default-0.16.0-dev.0',
path: '/_transform/metrics-endpoint.metadata_current-default-0.16.0-dev.0',
query: 'defer_validation=true',
body: '{"content": "data"}',
},
Expand All @@ -323,7 +323,7 @@ describe('test transform install', () => {
'transport.request',
{
method: 'POST',
path: '_transform/metrics-endpoint.metadata_current-default-0.16.0-dev.0/_start',
path: '/_transform/metrics-endpoint.metadata_current-default-0.16.0-dev.0/_start',
},
],
]);
Expand Down Expand Up @@ -412,15 +412,15 @@ describe('test transform install', () => {
'transport.request',
{
method: 'GET',
path: '_transform/metrics-endpoint.metadata-current-default-0.15.0-dev.0',
path: '/_transform/metrics-endpoint.metadata-current-default-0.15.0-dev.0',
ignore: [404],
},
],
[
'transport.request',
{
method: 'POST',
path: '_transform/metrics-endpoint.metadata-current-default-0.15.0-dev.0/_stop',
path: '/_transform/metrics-endpoint.metadata-current-default-0.15.0-dev.0/_stop',
query: 'force=true',
ignore: [404],
},
Expand All @@ -430,7 +430,7 @@ describe('test transform install', () => {
{
method: 'DELETE',
query: 'force=true',
path: '_transform/metrics-endpoint.metadata-current-default-0.15.0-dev.0',
path: '/_transform/metrics-endpoint.metadata-current-default-0.15.0-dev.0',
ignore: [404],
},
],
Expand Down

0 comments on commit 52a972c

Please sign in to comment.