github-mirrors/kibana
1
0
Fork 0
mirror of https://github.com/elastic/kibana.git synced 2025-04-24 09:48:58 -04:00
Code Issues Projects Releases Packages Wiki Activity

[7.x] Add API integration test for deleting data streams. (#70020) (#70102)

Browse source
This commit is contained in:
CJ Cenizal 2020-06-26 13:30:02 -07:00 • committed by GitHub
parent 936af29841
commit 0a901a82f1
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 106 additions and 54 deletions
Download patch file Download diff file Expand all files Collapse all files

160
x-pack/test/api_integration/apis/management/index_management/data_streams.ts
View file

@ -19,79 +19,131 @@ export default function ({ getService }: FtrProviderContext) {
const supertest = getService('supertest');
const es = getService('legacyEs');
const createDataStream = (name: string) => {
const createDataStream = async (name: string) => {
// A data stream requires an index template before it can be created.
return es.dataManagement
.saveComposableIndexTemplate({
name,
body: {
// We need to match the names of backing indices with this template
index_patterns: [name + '*'],
template: {
mappings: {
properties: {
'@timestamp': {
type: 'date',
},
await es.dataManagement.saveComposableIndexTemplate({
name,
body: {
// We need to match the names of backing indices with this template.
index_patterns: [name + '*'],
template: {
mappings: {
properties: {
'@timestamp': {
type: 'date',
},
},
},
data_stream: {
timestamp_field: '@timestamp',
},
},
})
.then(() =>
es.dataManagement.createDataStream({
name,
})
);
data_stream: {
timestamp_field: '@timestamp',
},
},
});
await es.dataManagement.createDataStream({ name });
};
const deleteDataStream = (name: string) => {
return es.dataManagement
.deleteDataStream({
name,
})
.then(() =>
es.dataManagement.deleteComposableIndexTemplate({
name,
})
);
const deleteComposableIndexTemplate = async (name: string) => {
await es.dataManagement.deleteComposableIndexTemplate({ name });
};
// Unskip once ES snapshot has been promoted that updates the data stream response
describe.skip('Data streams', function () {
const testDataStreamName = 'test-data-stream';
const deleteDataStream = async (name: string) => {
await es.dataManagement.deleteDataStream({ name });
await deleteComposableIndexTemplate(name);
};
describe('Data streams', function () {
describe('Get', () => {
const testDataStreamName = 'test-data-stream';
before(async () => await createDataStream(testDataStreamName));
after(async () => await deleteDataStream(testDataStreamName));
describe('all data streams', () => {
it('returns an array of data streams', async () => {
const { body: dataStreams } = await supertest
.get(`${API_BASE_PATH}/data_streams`)
.set('kbn-xsrf', 'xxx')
.expect(200);
it('returns an array of all data streams', async () => {
const { body: dataStreams } = await supertest
.get(`${API_BASE_PATH}/data_streams`)
.set('kbn-xsrf', 'xxx')
.expect(200);
// ES determines these values so we'll just echo them back.
const { name: indexName, uuid } = dataStreams[0].indices[0];
expect(dataStreams).to.eql([
// ES determines these values so we'll just echo them back.
const { name: indexName, uuid } = dataStreams[0].indices[0];
expect(dataStreams).to.eql([
{
name: testDataStreamName,
timeStampField: { name: '@timestamp', mapping: { type: 'date' } },
indices: [
{
name: indexName,
uuid,
},
],
generation: 1,
},
]);
});
it('returns a single data stream by ID', async () => {
const { body: dataStream } = await supertest
.get(`${API_BASE_PATH}/data_streams/${testDataStreamName}`)
.set('kbn-xsrf', 'xxx')
.expect(200);
// ES determines these values so we'll just echo them back.
const { name: indexName, uuid } = dataStream.indices[0];
expect(dataStream).to.eql({
name: testDataStreamName,
timeStampField: { name: '@timestamp', mapping: { type: 'date' } },
indices: [
{
name: testDataStreamName,
timeStampField: { name: '@timestamp', mapping: { type: 'date' } },
indices: [
{
name: indexName,
uuid,
},
],
generation: 1,
name: indexName,
uuid,
},
]);
],
generation: 1,
});
});
});
describe('Delete', () => {
const testDataStreamName1 = 'test-data-stream1';
const testDataStreamName2 = 'test-data-stream2';
before(async () => {
await Promise.all([
createDataStream(testDataStreamName1),
createDataStream(testDataStreamName2),
]);
});
after(async () => {
// The Delete API only deletes the data streams, so we still need to manually delete their
// related index patterns to clean up.
await Promise.all([
deleteComposableIndexTemplate(testDataStreamName1),
deleteComposableIndexTemplate(testDataStreamName2),
]);
});
it('deletes multiple data streams', async () => {
await supertest
.post(`${API_BASE_PATH}/delete_data_streams`)
.set('kbn-xsrf', 'xxx')
.send({
dataStreams: [testDataStreamName1, testDataStreamName2],
})
.expect(200);
await supertest
.get(`${API_BASE_PATH}/data_streams/${testDataStreamName1}`)
.set('kbn-xsrf', 'xxx')
.expect(404);
await supertest
.get(`${API_BASE_PATH}/data_streams/${testDataStreamName2}`)
.set('kbn-xsrf', 'xxx')
.expect(404);
});
});
});
}