Skip to content

Commit

Permalink
Functional tests legacy
Browse files Browse the repository at this point in the history
  • Loading branch information
@rolljee
rolljee committed Sep 20, 2023
1 parent fadf567 commit 7953f58
Show file tree
Hide file tree
Showing 12 changed files with 2,009 additions and 1,810 deletions.
321 changes: 187 additions & 134 deletions features-legacy/step_definitions/collections.js
View file
Original file line number Diff line number Diff line change
@@ -1,173 +1,226 @@
'use strict';

const
{
When,
Then
} = require('cucumber'),
should = require('should'),
stepUtils = require('../support/stepUtils');

When(/^I list "([^"]*)" data collections(?: in index "([^"]*)")?$/, function (type, index, callback) {
this.api.listCollections(index, type)
.then(response => {
if (response.error) {
callback(new Error(response.error.message));
return false;
}

if (! response.result) {
return callback(new Error('No result provided'));
}

this.result = response.result;
callback();
})
.catch(error => callback(error));
});
"use strict";

const { When, Then } = require("cucumber"),
should = require("should"),
stepUtils = require("../support/stepUtils");

When(
/^I list "([^"]*)" data collections(?: in index "([^"]*)")?$/,
function (type, index, callback) {
this.api
.listCollections(index, type)
.then((response) => {
if (response.error) {
callback(new Error(response.error.message));
return false;
}

if (!response.result) {
return callback(new Error("No result provided"));
}

this.result = response.result;
callback();
})
.catch((error) => callback(error));
}
);

When('I try to create the collection {string}', async function (collection) {
When("I try to create the collection {string}", async function (collection) {
try {
const response = await this.api.createCollection(null, collection);

this.result = response;
}
catch (error) {
} catch (error) {
this.result = { error };
}
});

When('I create a collection named {string} in index {string}', async function (collection, index) {
await this.api.createCollection(index, collection);
});

Then(/^I can ?(not)* find a ?(.*?) collection ?(.*)$/, function (not, type, collection, callback) {
if (! this.result.collections) {
return callback('Expected a collections list result, got: ' + this.result);
When(
"I create a collection named {string} in index {string}",
async function (collection, index) {
await this.api.createCollection(index, collection);
}

if (! collection) {
if (this.result.collections.length === 0) {
if (not) {
return callback();
}

return callback('Collection list is empty, expected collections to be listed');
);

Then(
/^I can ?(not)* find a ?(.*?) collection ?(.*)$/,
function (not, type, collection, callback) {
if (!this.result.collections) {
return callback(
"Expected a collections list result, got: " + this.result
);
}
}

if (this.result.collections.filter(item => item.type === type && item.name === collection).length !== 0) {
if (not) {
return callback('Expected collection ' + collection + ' not to appear in the collection list');
}

return callback();
}
if (!collection) {
if (this.result.collections.length === 0) {
if (not) {
return callback();
}

callback('Expected to find the collection <' + collection + '> in this collections list: ' + JSON.stringify(this.result.collections));
});

Then(/^I change the mapping(?: in index "([^"]*)")?$/, function (index, callback) {
this.api.updateMapping()
.then(body => {
if (body.error !== null) {
callback(new Error(body.error.message));
return false;
return callback(
"Collection list is empty, expected collections to be listed"
);
}
}

callback();
})
.catch(function (error) {
callback(new Error(error));
});
});

Then(/^I truncate the collection(?: "(.*?)")?(?: in index "([^"]*)")?$/, function (collection, index, callback) {
this.api.truncateCollection(index, collection)
.then(body => {
if (body.error !== null) {
return callback(body.error);
if (
this.result.collections.filter(
(item) => item.type === type && item.name === collection
).length !== 0
) {
if (not) {
return callback(
"Expected collection " +
collection +
" not to appear in the collection list"
);
}

callback();
})
.catch(error => callback(error));
});
return callback();
}

callback(
"Expected to find the collection <" +
collection +
"> in this collections list: " +
JSON.stringify(this.result.collections)
);
}
);

Then(
/^I change the mapping(?: in index "([^"]*)")?$/,
function (index, callback) {
this.api
.updateMapping()
.then((body) => {
if (body.error !== null) {
callback(new Error(body.error.message));
return false;
}

callback();
})
.catch(function (error) {
callback(new Error(error));
});
}
);

Then(
/^I truncate the collection(?: "(.*?)")?(?: in index "([^"]*)")?$/,
function (collection, index, callback) {
this.api
.truncateCollection(index, collection)
.then((body) => {
if (body.error !== null) {
return callback(body.error);
}

callback();
})
.catch((error) => callback(error));
}
);

Then(/I refresh the collection( "(.*?)")?/, function (indexCollection) {
indexCollection = indexCollection
? indexCollection
: this.fakeIndex + ':' + this.fakeCollection;
: this.fakeIndex + ":" + this.fakeCollection;

const [index, collection] = indexCollection.split(':');
const [index, collection] = indexCollection.split(":");

return this.api.refreshCollection(index, collection);
});

When(/^I check if index "(.*?)" exists$/, function (index, cb) {
return stepUtils.getReturn.call(this, 'indexExists', index, cb);
return stepUtils.getReturn.call(this, "indexExists", index, cb);
});

When(/I check if collection "(.*?)" exists on index "(.*?)"$/, function (collection, index, cb) {
return stepUtils.getReturn.call(this, 'collectionExists', index, collection, cb);
});
When(
/I check if collection "(.*?)" exists on index "(.*?)"$/,
function (collection, index, cb) {
return stepUtils.getReturn.call(
this,
"collectionExists",
index,
collection,
cb
);
}
);

When(/I create a collection "([\w-]+)":"([\w-]+)"( with "([\d]+)" documents)?/, function (index, collection, countRaw) {
return this.api.createCollection(index, collection)
.then(() => {
const
promises = [],
When(
/I create a collection "([\w-]+)":"([\w-]+)"( with "([\d]+)" documents)?/,
function (index, collection, countRaw) {
return this.api.createCollection(index, collection).then(() => {
const promises = [],
count = parseInt(countRaw);

for (let i = 0; i < count; ++i) {
promises.push(this.api.create({ number: `doc-${i}` }, index, collection));
promises.push(
this.api.create({ number: `doc-${i}` }, index, collection)
);
}

return Promise.all(promises);
});
});

Then('The mapping dynamic field of {string}:{string} is {string}', function (index, collection, dynamicValue) {
return this.api.getCollectionMapping(index, collection)
.then(({ result }) => {
const expectedValue = dynamicValue === 'the default value'
? 'true' // we set the default value to true in the environment for tests
: dynamicValue;

should(result.dynamic)
.not.be.undefined()
.be.eql(expectedValue);
});
});

When('I update the mapping of {string}:{string} with {string}', function (index, collection, rawMapping) {
const mapping = JSON.parse(rawMapping);

return this.api.updateMapping(index, collection, mapping);
});

Then('The mapping properties field of {string}:{string} is {string}', function (index, collection, rawMapping) {
const includeKuzzleMeta = rawMapping === 'the default value';

return this.api.getCollectionMapping(index, collection, includeKuzzleMeta)
.then(({ result }) => {
const expectedValue = rawMapping === 'the default value'
? this.kuzzleConfig.services.storageEngine.commonMapping.properties
: JSON.parse(rawMapping);

should(result.properties)
.be.eql(expectedValue);
});
});

Then('The mapping _meta field of {string}:{string} is {string}', function (index, collection, rawMapping) {
const mapping = JSON.parse(rawMapping);
}
);

Then(
"The mapping dynamic field of {string}:{string} is {string}",
function (index, collection, dynamicValue) {
return this.api
.getCollectionMapping(index, collection)
.then(({ result }) => {
const expectedValue =
dynamicValue === "the default value"
? "true" // we set the default value to true in the environment for tests
: dynamicValue;

should(result.dynamic).not.be.undefined().be.eql(expectedValue);
});
}
);

return this.api.getCollectionMapping(index, collection)
.then(({ result }) => {
When(
"I update the mapping of {string}:{string} with {string}",
function (index, collection, rawMapping) {
const mapping = JSON.parse(rawMapping);

should(result._meta)
.not.be.undefined()
.be.eql(mapping._meta);
});
});
return this.api.updateMapping(index, collection, mapping);
}
);

Then(
"The mapping properties field of {string}:{string} is {string}",
function (index, collection, rawMapping) {
const includeKuzzleMeta = rawMapping === "the default value";

return this.api
.getCollectionMapping(index, collection, includeKuzzleMeta)
.then(({ result }) => {
const expectedValue =
rawMapping === "the default value"
? this.kuzzleConfig.services.storageEngine.commonMapping.properties
: JSON.parse(rawMapping);

should(result.properties).be.eql(expectedValue);
});
}
);

Then(
"The mapping _meta field of {string}:{string} is {string}",
function (index, collection, rawMapping) {
const mapping = JSON.parse(rawMapping);

return this.api
.getCollectionMapping(index, collection)
.then(({ result }) => {
should(result._meta).not.be.undefined().be.eql(mapping._meta);
});
}
);
6 changes: 4 additions & 2 deletions features-legacy/step_definitions/profiles.js
View file
Original file line number Diff line number Diff line change
Expand Up @@ -352,15 +352,17 @@ Given(/^A scrolled search on profiles$/, function () {
this.scrollId = null;

return this.api.searchProfiles([], { scroll: "2s" }).then((response) => {
console.log("response", response);

if (response.error) {
throw new Error(response.error.message);
}

if (!response.result.scroll_id) {
if (!response.result.scrollId) {
throw new Error("No scrollId returned by the searchProfile query");
}

this.scrollId = response.result.scroll_id;
this.scrollId = response.result.scrollId;
});
});

Expand Down
Loading

0 comments on commit 7953f58

Please sign in to comment.