Lines Matching refs:kvp
64 if 'sections' in self.parent.kvp:
68 for section in self.parent.kvp['sections'].split(','):
80 self.parent.profiles['loaded'][prof].check_parameters(self.parent.kvp)
97 if 'updatesequence' in self.parent.kvp:
98 if int(self.parent.kvp['updatesequence']) == updatesequence:
100 elif int(self.parent.kvp['updatesequence']) > updatesequence:
428 if 'typename' not in self.parent.kvp or \
429 len(self.parent.kvp['typename']) == 0: # missing typename
431 self.parent.kvp['typename'] = ['csw:Record']
435 self.parent.kvp['typename'].append(
439 self.parent.kvp['typename'] = self.parent.kvp['typename'].split(',')
441 if ('outputformat' in self.parent.kvp and
442 self.parent.kvp['outputformat'] not in
447 self.parent.kvp['outputformat'])
449 if ('schemalanguage' in self.parent.kvp and
450 self.parent.kvp['schemalanguage'] not in
455 self.parent.kvp['schemalanguage'])
465 for typename in self.parent.kvp['typename']:
495 if ('parametername' not in self.parent.kvp and
496 'propertyname' not in self.parent.kvp):
509 if 'parametername' in self.parent.kvp:
510 for pname in self.parent.kvp['parametername'].split(','):
534 if 'propertyname' in self.parent.kvp:
535 for pname in self.parent.kvp['propertyname'].split(','):
618 if ('elementsetname' not in self.parent.kvp and
619 'elementname' not in self.parent.kvp):
625 if 'outputschema' not in self.parent.kvp:
626 self.parent.kvp['outputschema'] = self.parent.context.namespaces['csw']
628 if (self.parent.kvp['outputschema'] not in self.parent.context.model['operations']
632 self.parent.kvp['outputschema'])
634 if 'outputformat' not in self.parent.kvp:
635 self.parent.kvp['outputformat'] = 'application/xml'
637 if (self.parent.kvp['outputformat'] not in self.parent.context.model['operations']
641 self.parent.kvp['outputformat'])
643 if 'resulttype' not in self.parent.kvp:
644 self.parent.kvp['resulttype'] = 'hits'
646 if self.parent.kvp['resulttype'] is not None:
647 if (self.parent.kvp['resulttype'] not in self.parent.context.model['operations']
651 self.parent.kvp['resulttype'])
653 if (('elementname' not in self.parent.kvp or
654 len(self.parent.kvp['elementname']) == 0) and
655 self.parent.kvp['elementsetname'] not in
660 self.parent.kvp['elementsetname'])
662 if ('elementname' in self.parent.kvp and
664 self.parent.kvp['elementname'] = self.parent.kvp['elementname'].split(',')
665 self.parent.kvp['elementsetname'] = 'summary'
667 if 'typenames' not in self.parent.kvp:
671 if ('typenames' in self.parent.kvp and
673 self.parent.kvp['typenames'] = self.parent.kvp['typenames'].split(',')
675 if 'typenames' in self.parent.kvp:
676 for tname in self.parent.kvp['typenames']:
684 if 'elementname' in self.parent.kvp:
685 for ename in self.parent.kvp['elementname']:
692 if self.parent.kvp['resulttype'] == 'validate':
700 if 'maxrecords' not in self.parent.kvp: # not specified by client
702 self.parent.kvp['maxrecords'] = maxrecords_cfg
704 self.parent.kvp['maxrecords'] = 10
706 if self.parent.kvp['maxrecords'] == '':
707 self.parent.kvp['maxrecords'] = 10
709 if int(self.parent.kvp['maxrecords']) > maxrecords_cfg:
710 self.parent.kvp['maxrecords'] = maxrecords_cfg
712 if any(x in ['bbox', 'q', 'time'] for x in self.parent.kvp):
714 self.parent.kvp['constraintlanguage'] = 'FILTER'
715 tmp_filter = opensearch.kvp2filterxml(self.parent.kvp, self.parent.context,
718 self.parent.kvp['constraint'] = tmp_filter
719 … LOGGER.debug('OpenSearch Geo/Time parameters to Filter: %s.', self.parent.kvp['constraint'])
722 if 'constraint' in self.parent.kvp:
725 if 'constraintlanguage' not in self.parent.kvp:
729 if (self.parent.kvp['constraintlanguage'] not in
734 % self.parent.kvp['constraintlanguage'])
735 if self.parent.kvp['constraintlanguage'] == 'CQL_TEXT':
736 tmp = self.parent.kvp['constraint']
740 self.parent.kvp['constraint'] = {}
741 self.parent.kvp['constraint']['type'] = 'filter'
743 … self.parent.kvp['constraint']['where'], self.parent.kvp['constraint']['values'] = fes1.parse(cql,
746 …self.parent.kvp['constraint']['_dict'] = xml2dict(etree.tostring(cql), self.parent.context.namespa…
751 elif self.parent.kvp['constraintlanguage'] == 'FILTER':
756 LOGGER.info('Validating Filter %s', self.parent.kvp['constraint'])
759 doc = etree.fromstring(self.parent.kvp['constraint'], parser)
761 self.parent.kvp['constraint'] = {}
762 self.parent.kvp['constraint']['type'] = 'filter'
763 … self.parent.kvp['constraint']['where'], self.parent.kvp['constraint']['values'] = \
768 …self.parent.kvp['constraint']['_dict'] = xml2dict(etree.tostring(doc), self.parent.context.namespa…
776 self.parent.kvp['constraint'] = {}
778 if 'sortby' not in self.parent.kvp:
779 self.parent.kvp['sortby'] = None
780 elif 'sortby' in self.parent.kvp and self.parent.requesttype == 'GET':
782 tmp = self.parent.kvp['sortby']
783 self.parent.kvp['sortby'] = {}
793 self.parent.kvp['sortby']['propertyname'] = \
797 self.parent.kvp['sortby']['spatial'] = True
807 self.parent.kvp['sortby']['order'] = 'DESC'
809 self.parent.kvp['sortby']['order'] = 'ASC'
811 if 'startposition' not in self.parent.kvp or not self.parent.kvp['startposition']:
812 self.parent.kvp['startposition'] = 1
817 self.parent.kvp['constraint'], self.parent.kvp['sortby'], self.parent.kvp['typenames'],
818 self.parent.kvp['maxrecords'], self.parent.kvp['startposition'])
822 constraint=self.parent.kvp['constraint'],
823 sortby=self.parent.kvp['sortby'], typenames=self.parent.kvp['typenames'],
824 maxrecords=self.parent.kvp['maxrecords'],
825 startposition=int(self.parent.kvp['startposition'])-1)
827 LOGGER.exception('Invalid query syntax. Query: %s', self.parent.kvp['constraint'])
835 'distributedsearch' in self.parent.kvp and
836 self.parent.kvp['distributedsearch'] and self.parent.kvp['hopcount'] > 0):
840 self.parent.kvp['hopcount'])
851 esn=self.parent.kvp['elementsetname'],
852 outputschema=self.parent.kvp['outputschema'])
880 elif int(self.parent.kvp['maxrecords']) == 0:
883 elif int(matched) < int(self.parent.kvp['startposition']):
886 …elif int(matched) <= int(self.parent.kvp['startposition']) + int(self.parent.kvp['maxrecords']) - …
887 returned = str(int(matched) - int(self.parent.kvp['startposition']) + 1)
890 returned = str(self.parent.kvp['maxrecords'])
891 … nextrecord = str(int(self.parent.kvp['startposition']) + int(self.parent.kvp['maxrecords']))
905 if 'requestid' in self.parent.kvp and self.parent.kvp['requestid'] is not None:
907 self.parent.context.namespaces)).text = self.parent.kvp['requestid']
912 if 'where' not in self.parent.kvp['constraint'] and \
913 self.parent.kvp['resulttype'] is None:
919 nextRecord=nextrecord, recordSchema=self.parent.kvp['outputschema'])
921 if self.parent.kvp['elementsetname'] is not None:
922 searchresults.attrib['elementSet'] = self.parent.kvp['elementsetname']
924 if 'where' not in self.parent.kvp['constraint'] \
925 and self.parent.kvp['resulttype'] is None:
929 if self.parent.kvp['resulttype'] == 'hits':
934 if len(results) < int(self.parent.kvp['maxrecords']):
937 … max1 = int(self.parent.kvp['startposition']) + (int(self.parent.kvp['maxrecords'])-1)
939 self.parent.kvp['startposition'], max1)
943 if (self.parent.kvp['outputschema'] ==
945 'csw:Record' in self.parent.kvp['typenames']):
949 elif (self.parent.kvp['outputschema'] ==
951 'csw:Record' not in self.parent.kvp['typenames']):
957 self.parent.kvp['typenames']:
969 …elif self.parent.kvp['outputschema'] in self.parent.outputschemas.keys(): # use outputschema seri…
970 …lts.append(self.parent.outputschemas[self.parent.kvp['outputschema']].write_record(res, self.paren…
973 self.parent.profiles['loaded'][self.parent.kvp['outputschema']].\
974 write_record(res, self.parent.kvp['elementsetname'],
975 self.parent.kvp['outputschema'],
990 if 'responsehandler' in self.parent.kvp: # process the handler
999 if 'id' not in self.parent.kvp:
1002 if len(self.parent.kvp['id']) < 1:
1005 if 'outputschema' not in self.parent.kvp:
1006 self.parent.kvp['outputschema'] = self.parent.context.namespaces['csw']
1009 self.parent.kvp['id'] = self.parent.kvp['id'].split(',')
1011 if ('outputformat' in self.parent.kvp and
1012 self.parent.kvp['outputformat'] not in
1017 self.parent.kvp['outputformat'])
1019 if ('outputschema' in self.parent.kvp and self.parent.kvp['outputschema'] not in
1024 self.parent.kvp['outputschema'])
1026 if 'elementsetname' not in self.parent.kvp:
1027 self.parent.kvp['elementsetname'] = 'summary'
1029 if (self.parent.kvp['elementsetname'] not in
1034 self.parent.kvp['elementsetname'])
1044 LOGGER.info('Querying repository with ids: %s', self.parent.kvp['id'][0])
1045 results = self.parent.repository.query_ids(self.parent.kvp['id'])
1056 and self.parent.kvp['outputschema'] ==
1061 elif (self.parent.kvp['outputschema'] ==
1081 …elif self.parent.kvp['outputschema'] in self.parent.outputschemas.keys(): # use outputschema seri…
1082 …de.append(self.parent.outputschemas[self.parent.kvp['outputschema']].write_record(result, self.par…
1085 self.parent.profiles['loaded'][self.parent.kvp['outputschema']].write_record(
1086 result, self.parent.kvp['elementsetname'],
1087 self.parent.kvp['outputschema'], self.parent.repository.queryables['_all']))
1101 'No repository item found for \'%s\'' % self.parent.kvp['id'])
1120 LOGGER.debug('Transaction list: %s', self.parent.kvp['transactions'])
1122 for ttype in self.parent.kvp['transactions']:
1228 if (len(insertresults) > 0 and self.parent.kvp['verboseresponse']):
1247 if 'resourcetype' not in self.parent.kvp:
1250 if 'source' not in self.parent.kvp:
1255 if (self.parent.kvp['resourcetype'] not in
1264 if (self.parent.kvp['resourcetype'].find('opengis.net') == -1 and
1265 self.parent.kvp['resourcetype'].find('urn:geoss:waf') == -1):
1267 LOGGER.debug('Fetching resource %s', self.parent.kvp['source'])
1269 content = util.http_request('GET', self.parent.kvp['source'])
1272 (self.parent.kvp['source'], str(err))
1277 content = self.parent.kvp['source']
1295 … ir = self.parent.repository.insert(self.parent.kvp['resourcetype'], self.parent.kvp['source'])
1305 content, self.parent.repository, self.parent.kvp['resourcetype'],
1318 if self.parent.kvp['resourcetype'] == 'urn:geoss:waf':
1321 src = self.parent.kvp['source']
1424 if 'responsehandler' in self.parent.kvp: # process the handler
1432 if self.parent.kvp['elementsetname'] == 'brief':
1434 elif self.parent.kvp['elementsetname'] == 'summary':
1442 if ('elementname' in self.parent.kvp and
1443 len(self.parent.kvp['elementname']) > 0):
1444 for elemname in self.parent.kvp['elementname']:
1458 elif 'elementsetname' in self.parent.kvp:
1459 if (self.parent.kvp['elementsetname'] == 'full' and
1482 if self.parent.kvp['elementsetname'] in ['summary', 'full']:
1522 if self.parent.kvp['elementsetname'] == 'full': # add full elements
1901 if 'requestid' in self.parent.kvp and self.parent.kvp['requestid'] is not None:
1902 node.attrib['requestId'] = self.parent.kvp['requestid']
1939 self.parent.context.namespaces)).text = self.kvp['requestid']