GetFeature.js 2.8 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586
  1. // @require WFS_URL
  2. if (!WFS_URL) throw "Missing WFS_URL"
  3. function p5WFS_ParseFeatureMember(featureMember) { // @returns object from xml element <gml:featureMemeber>
  4. if (!featureMember) return null
  5. if (!featureMember.children.length) return null
  6. var featureNode = featureMember.children[0]
  7. if (!featureNode) return null
  8. if (!featureNode.children.length) return null
  9. var item = {}
  10. var i = 0
  11. for (i = 0; i < featureNode.children.length; i++) {
  12. var field = featureNode.children[i]
  13. item[ field.localName ] = field.textContent
  14. }
  15. return item
  16. }
  17. /**
  18. * @usage
  19. p5WFS_GetFeature('p5_default_db:CRM_PROCES', {
  20. 'featureID': 'CRM_PROCES.' + id,
  21. }).then(function (features) {
  22. // ...
  23. }).catch(function (e) {
  24. // ...
  25. })
  26. * @usage
  27. p5WFS_GetFeature('p5_default_db:CRM_PROCES', {
  28. 'featureID': 'CRM_PROCES.' + id,
  29. }).then(function (features) {
  30. if (!features) throw "Nie odnaleziono rekordu id = " + id
  31. if (!features.length) throw "Nie odnaleziono rekordu id = " + id
  32. if (1 !== features.length) throw "Bład: API zwróciło za dużo rekordów"
  33. return features[0]
  34. console.log('fetched features', features)
  35. }).then(function (feature) {
  36. // ...
  37. }).catch(function (e) {
  38. // ...
  39. })
  40. */
  41. function p5WFS_GetFeature(typeName, query) { // @returns Promise
  42. var link = WFS_URL + '?SERVICE=WFS&VERSION=1.0.0' +
  43. '&REQUEST=GetFeature' +
  44. '&TYPENAME=' + typeName +
  45. '&SRSNAME=EPSG:3003'
  46. // '&Filter=<ogc:Filter><ogc:Or><ogc:PropertyIsEqualTo><ogc:PropertyName>ID</ogc:PropertyName><ogc:Literal>' + id + '</ogc:Literal></ogc:PropertyIsEqualTo></ogc:Or></ogc:Filter>'
  47. var query = query || {}
  48. if ('featureID' in query) link += '&featureID=' + query['featureID']
  49. if ('Filter' in query && 'string' === typeof query['Filter']) {
  50. var ogcFilter = ('<ogc:Filter>' !== query['Filter'].substr(0, '<ogc:Filter>'.length))
  51. ? '<ogc:Filter>' + query['Filter'] + '</ogc:Filter>'
  52. : query['Filter']
  53. ;
  54. link += '&Filter=' + ogcFilter
  55. }
  56. if ('sortBy' in query) link += '&sortBy=' + query['sortBy']
  57. var method = 'GET' // TODO: if long 'ogc:Filter' then POST
  58. return window.fetch(link, {
  59. method: method,
  60. credentials: 'same-origin',
  61. }).then(function (response) {
  62. return response.text()
  63. }).then(function (responseText) {
  64. return (new DOMParser()).parseFromString(responseText, "text/xml");
  65. }).then(function (xmlResponse) {
  66. if (!xmlResponse.children.length) throw "Missing response xml root element"
  67. return xmlResponse.children[0]
  68. }).then(function (xmlRoot) {
  69. if ('FeatureCollection' !== xmlRoot.localName) throw "Missing FeatureCollection as root element in wfs response"
  70. var features = []
  71. for (var i = 0; i < xmlRoot.children.length; i++) {
  72. features.push(p5WFS_ParseFeatureMember(xmlRoot.children[i]))
  73. }
  74. return features.filter(function (item) { return !!item; })
  75. })
  76. }
  77. global.p5WFS_ParseFeatureMember = p5WFS_ParseFeatureMember
  78. global.p5WFS_GetFeature = p5WFS_GetFeature