Navigation Menu

Skip to content

Commit

Permalink
Support DescribeDomains Action on the configuration API
Browse files Browse the repository at this point in the history
  • Loading branch information
piroor committed Aug 3, 2012
1 parent 780861f commit 125c03a
Show file tree
Hide file tree
Showing 2 changed files with 114 additions and 7 deletions.
58 changes: 51 additions & 7 deletions lib/api/2011-02-01/configuration.js
Expand Up @@ -77,12 +77,10 @@ handlers.CreateDomain = function(context, request, response) {
var domain = new Domain(request.query.DomainName, context);
try {
domain.createSync();
var host = getBaseDomain(request.headers.host);
host = host ? '.' + host : '';
response.contentType('application/xml');
response.send(createCreateDomainResponse({
domain: domain,
hostname: host,
hostname: getBaseDomain(request.headers.host),
created: true
}));
} catch (error) {
Expand All @@ -109,12 +107,10 @@ handlers.DeleteDomain = function(context, request, response) {
var domain = new Domain(request.query.DomainName, context);
try {
domain.deleteSync();
var host = getBaseDomain(request.headers.host);
host = host ? '.' + host : '';
response.contentType('application/xml');
response.send(createDeleteDomainResponse({
domain: domain,
hostname: host,
hostname: getBaseDomain(request.headers.host),
deleted: true
}));
} catch (error) {
Expand All @@ -124,6 +120,55 @@ handlers.DeleteDomain = function(context, request, response) {
}
};

function createDomainStatusList(options) {
var doc = xmlbuilder.create();
var domainStatusList = doc.begin('DomainStatusList', {version: '1.0'});
options.domains.forEach(function(domain) {
domainStatusList.element('member')
.importXMLBuilder(createDomainStatus({
domain: domain,
hostname: options.hostname
}));
});
return domainStatusList;
}

function createDescribeDomainsResponse(options) {
var doc = xmlbuilder.create();
doc.begin('DescribeDomainsResponse', { version: '1.0' })
.attribute('xmlns', XMLNS)
.element('DescribeDomainsResult')
.importXMLBuilder(createDomainStatusList(options))
.up()
.element('ResponseMetadata')
.element('RequestId').text(options.requestId || '').up()
.up();
return doc.toString();
}

handlers.DescribeDomains = function(context, request, response) {
try {
var keys = Object.keys(request.query).filter(function(key) {
return /^DomainNames\.member\.\d+$/.test(key);
});
var domainNames = keys.sort().map(function(key) {
return request.query[key];
});
var domains = domainNames.map(function(name) {
return new Domain(name, context);
});
response.contentType('application/xml');
response.send(createDescribeDomainsResponse({
domains: domains,
hostname: getBaseDomain(request.headers.host)
}));
} catch (error) {
var body = createCommonErrorResponse('InternalFailure', error.message);
response.contentType('application/xml');
response.send(body, 400);
}
};

function createIndexFieldOptionStatus(options) {
switch (options.field.type) {
case 'text':
Expand Down Expand Up @@ -328,7 +373,6 @@ function getClientIp(request) {
return request.connection.remoteAddress;
};


exports.createHandler = function(context, config) {
var privilegedRanges = config &&
config.privilegedRanges &&
Expand Down
63 changes: 63 additions & 0 deletions test/api-configuration.test.js
Expand Up @@ -46,6 +46,24 @@ var PATTERN_DeleteDomainResponse = {
}
};

function PATTERN_DescribeDomainsResponse(members) {
return {
DescribeDomainsResponse: {
'@': { xmlns: '' },
DescribeDomainsResult: {
DomainStatusList: (function() {
var pattern = {};
members.forEach(function(member, index) {
pattern[index] = PATTERN_DomainStatus;
});
return { member: pattern };
})()
},
ResponseMetadata: PATTERN_ResponseMetadata
}
};
}

var PATTERN_OptionStatus = {
CreationDate: '',
State: '',
Expand Down Expand Up @@ -312,6 +330,51 @@ suite('Configuration API', function() {
});
});

test('Get, Action=DescribeDomains', function(done) {
var domain;
utils
.get('/?DomainName=domain3&Action=CreateDomain&Version=2011-02-01', {
'Host': 'cloudsearch.localhost'
})
.get('/?DomainName=domain1&Action=CreateDomain&Version=2011-02-01', {
'Host': 'cloudsearch.localhost'
})
.get('/?DomainName=domain2&Action=CreateDomain&Version=2011-02-01', {
'Host': 'cloudsearch.localhost'
})
.get('/?Action=DescribeDomains&Version=2011-02-01' +
'&DomainNames.member.1=domain2' +
'&DomainNames.member.2=domain1', {
'Host': 'cloudsearch.localhost'
})
.next(function(response) {
response = toParsedResponse(response);
var expectedDomains = ['domain2', 'domain1'];
assert.deepEqual(response.pattern,
{ statusCode: 200,
body: PATTERN_DescribeDomainsResponse(expectedDomains) });

var actualDomains = response.body.DescribeDomainsResponse
.DescribeDomainsResult
.DomainStatus
.member;
actualDomains = (function() {
var domains = [];
for (var i in actualDomains) {
if (actualDomains.hasOwnProperty(i))
domains.push(actualDomains[i]).name;
}
return domains;
})();
assert.deepEqual(actualDomains, expectedDomains);

done();
})
.error(function(error) {
done(error);
});
});

test('Get, Action=DefineIndexField (text)', function(done) {
utils
.get('/?DomainName=companies&Action=CreateDomain&Version=2011-02-01', {
Expand Down

0 comments on commit 125c03a

Please sign in to comment.