45:["$","title",null,{"children":"Flow Helper Library Version 2 | Emu Analytics | Observable"}] 4d:T73c,/** Initialize Flo.w * * apiKey: string - a valid Flo.w API key (uuid) * version: string (optional) - Flo.w RDF version number (e.g. '0.4.10'). If omitted, the latest version * is used. * host: string (optional) - Flo.w host URL (defaults to https://flow.emu-analytics.net) * * Returns the Flo.w context */ initializeFlow = async function ( apiKeyOrConfig, version, host = "https://flow.emu-analytics.net", initialState = {} ) { let config; // Wrangle argument for backwards compatibility if (typeof apiKeyOrConfig === "string") { config = { apiKey: apiKeyOrConfig, host, initialState, version }; } else { config = apiKeyOrConfig; } // Apply defaults config = { host: "https://flow.emu-analytics.net", enableDebug: true, initialState: {}, ...config }; version = version ? "@" + version : ""; // Add Flo.w RDF script tag to register custom web components const script = document.createElement("script"); script.type = "module"; script.src = `https://cdn.jsdelivr.net/npm/@emuanalytics/flow-rdf${version}/dist/flow-rdf/flow-rdf.esm.js`; document.getElementsByTagName("head")[0].appendChild(script); // Inject Flow core CSS const coreStyles = document.createElement("link"); coreStyles.rel = "stylesheet"; coreStyles.href = `https://cdn.jsdelivr.net/npm/@emuanalytics/flow-rdf${version}/dist/flow-rdf/css/core.css`; document.getElementsByTagName("head")[0].appendChild(coreStyles); const flowLib = await import( `https://cdn.jsdelivr.net/npm/@emuanalytics/flow-rdf${version}/dist/flow-rdf/index.esm.js` ); // Initialize the context const ctx = flowLib.flow.initializeContext(config); // Wait for custom elements to be registered await customElements.whenDefined("flow-context"); ctx[contextSymbol] = true; return ctx; }4e:T69a,/** * Display full summary of supplied dataset */ datasetSummary = async function (datasetIdOrObj, options, context) { // Wrangle arguments for backwards compatibility if (!context || !context[contextSymbol]) { context = globalContext; } options = { headingLevel: 2, ...options }; const paramRegex = /{{([a-zA-Z_\-\d]+)}}/gm; const dataset = await getDataset(datasetIdOrObj, context); if (dataset) { const heading = md`${"#".repeat(options.headingLevel)} Dataset \`${ dataset.id }\``; const description = md`${dataset.description || "No description"}`; const propertyTable = table( [ { property: "Name", value: dataset.name }, { property: "Type", value: dataset.type }, { property: "Created", value: humanDate.prettyPrint(dataset.createdAt) }, { property: "Updated", value: humanDate.relativeTime(dataset.updatedAt) } ], { header: false } ); const params = Array.from( new Set( dataset.type === "sql" ? ((dataset.source || "").match(paramRegex) || []).map((p) => p.replace(/[{}]/g, "") ) : [] ) ); const parameterTable = params.length ? table(params.map((p) => ({ Parameters: p }))) : ""; const source = await datasetSource(dataset, context); const attributeTable = await datasetAttributes(dataset, context); return htl.html` ${heading} ${description} ${propertyTable} ${parameterTable}

SOURCE

${source} ${attributeTable} `; } else { return md`Dataset not found`; } }4f:[] 49:{"id":"f5189903845913b9","slug":"flow-helper-library-v2","title":"Flow Helper Library Version 2","thumbnail":"49e3b8e7b5c25c76853ac31b4ed41e895e2facb91573182f4e68e995d0ccb899","access_level":"public","create_time":"$D2021-11-03T07:14:54.044Z","update_time":"$D2024-10-10T07:10:00.735Z","view_time":null,"first_public_time":"$D2021-11-03T12:54:11.509Z","has_unpublished_edits":null,"fork":{"id":"a92c7c03d47f94a3","slug":"flow-helper-library","title":"Flow Helper Library","owner":{"id":"374dcc63ddd06df5","login":"emuanalytics","name":"Emu Analytics"}},"stars":0,"starred":false,"owner":{"type":"team","id":"374dcc63ddd06df5","login":"emuanalytics","name":"Emu Analytics","avatar_url":"https://avatars-next.observableusercontent.com/be971faab0532b04c1173a4e3af506aaf7228fe01f5d68db47f0459eff95d96d","tier":"pro","bio":"","followed_by_you":false,"follows_you":false},"version":860,"publish_version":null,"role":null,"authored":false,"authors":[{"type":"individual","id":"bdf516c467dde4e8","login":"robinsummerhill","name":"Robin Summerhill","avatar_url":"https://avatars-next.observableusercontent.com/a9ff6855f02eecd3b45d5c8360553ae7dde7a80f4b79d56742af72792b79ad58","tier":null,"bio":"Head of Technology at Emu Analytics. Geospatial visualisation wizardry.","followed_by_you":false,"follows_you":false}],"members":[{"type":"team","id":"374dcc63ddd06df5","login":"emuanalytics","name":"Emu Analytics","avatar_url":"https://avatars-next.observableusercontent.com/be971faab0532b04c1173a4e3af506aaf7228fe01f5d68db47f0459eff95d96d","tier":"pro","role":"editor"},{"type":"individual","id":"bdf516c467dde4e8","login":"robinsummerhill","name":"Robin Summerhill","avatar_url":"https://avatars-next.observableusercontent.com/a9ff6855f02eecd3b45d5c8360553ae7dde7a80f4b79d56742af72792b79ad58","tier":null,"role":"viewer"}],"comments":[],"custom_thumbnail":false,"trashed":false,"lapsed":null,"subscribed":null,"forks":2,"collection":null,"type":"notebook","body":{"titling":"auto","title":"Flow Helper Library Version 2","cells":[{"id":0,"value":"md`# Flow Helper Library Version 2`","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":449,"value":"toc(\"h2,h3\")","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":452,"value":"## Introduction","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":27,"value":"\nTo use Flo.w in an Observable notebook define your Flo.w configuration in a cell as follows:\n\n~~~js\nconfig = ({\n apiKey: 'xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx',\n\n // optional properties with defaults\n host: \"https://flow.emu-analytics.net\",\n version: \"2.0\",\n enableDebug: true,\n initialState: {}\n})\n~~~\n\n\nThen import the Flow library as follows:\n\n~~~js\nimport { Flow } with {config as config} from '@emuanalytics/flow-helper-library-v2';\n~~~\n\nFunctions in the Flow Helper Library are exposed via the `Flow` object and can be called as follows:\n\n~~~js\n// Display a table of available datasets\nFlow.datasetTable()\n~~~\n\nSee [Flow Helper Library Examples](https://observablehq.com/@emuanalytics/flow-helper-library-examples) for examples of using the library.\n","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":43,"value":"md`---`","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":462,"value":"## Library Entry Point","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":567,"value":"The functions provided by the library can be imported into a notebook using a single entry point for convenience:\n\n\n","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":355,"value":"Flow = {\n dayjs.extend(dayjsUtcPlugin);\n dayjs.extend(dayjsTzPlugin);\n dayjs.extend(dayjsCustomParseFormatPlugin);\n\n return {\n // The Flo.w RDF context\n context: globalContext,\n\n // Dataset functions\n datasetTable,\n datasetAttributes,\n datasetSource,\n datasetSummary,\n datasetQuery,\n datasetQueryTable,\n queryBuilder: flowQueryBuilder,\n\n // Tilesource functions\n tileSourceTable,\n\n // Map functions\n mapStyleTable,\n mapClickedFeature,\n mapSelectedFeatureId,\n mapSelectedFeature,\n\n // Reactive state functions\n stateGet,\n stateSet,\n stateMerge,\n stateTransaction,\n\n // Misc functions\n fullscreen,\n\n // Misc 3rd-party library added for convenience\n toc,\n vega,\n turf,\n dayjs\n };\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":464,"value":"### Injectable Library Configuration","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":571,"value":"Library configuration is designed to be injected by a notebook using the `import with` syntax. The injected configuration will replace the default configuration defined below:","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":361,"value":"config = ({\n apiKey: \"b6b77cc4-904a-46d1-aa0f-3bf3848ce4c7\",\n host: \"https://flow.emu-analytics.net\",\n version: \"3.0.5\"\n})","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":467,"value":"### Global Flo.w RDF Context\n\nThe Flo.w RDF context below is initialised using the injected configuration and used as the default context by other functions in the library unless an explicit context is provided as a function argument.","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":364,"value":"globalContext = initializeFlow(\n config.apiKey,\n config.version,\n config.host,\n config.initialState\n)","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":579,"value":"The `contextSymbol` is used to identify a Flo.w context passed as an argument and is used to support backwards-compatibility with function signatures from previous versions of the library.","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":370,"value":"contextSymbol = \"__FLOW_CONTEXT__\"","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":459,"value":"## Functions","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":478,"value":"### `initializeFlow`\n\nThis function is called internally to initialise the global context. It can be called directly if required.\n","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":6,"value":"$4d","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":485,"value":"-----\n\n### `datasetTable`","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":96,"value":"The **datasetTable** function creates a table of available datasets.\n\n#### Parameters\n|||\n|----------|------------------------------|\n|`context` | Flo.w RDF context (optional) |\n|`options` | Options object (optional} | \n\n#### Example","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":585,"value":"datasetTable()","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":82,"value":"/**\n * Display a table of datasets defined in supplied context\n */\ndatasetTable = async function (context, options) {\n // Wrangle arguments for backwards compatibility\n if (!context || !context[contextSymbol]) {\n console.log(\"using global context\");\n options = context;\n context = globalContext;\n }\n\n const datasets = await context.flowClient.datasets.list({ sort: \"id\" });\n\n if (datasets.length) {\n const idFilter = options?.ignoreUnderscores\n ? (ds) => !ds.id.startsWith(\"_\")\n : (ds) => true;\n\n const dsInfo = datasets.filter(idFilter).map((ds) => ({\n \"Dataset ID\": ds.id,\n Name: ds.name,\n Description: ds.description,\n Type: ds.type\n }));\n\n return Inputs.table(dsInfo, { layout: \"auto\" });\n } else {\n return md`No datasets`;\n }\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":489,"value":"-----\n\n### `tileSourceTable`","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":101,"value":"The **tileSourceTable** function creates a table of available tile sources.\n\n#### Parameters\n|||\n|----------|------------------------------|\n|`context` | Flo.w RDF context (optional) |\n|`options` | Options object (optional) |\n\n#### Example","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":592,"value":"tileSourceTable()","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":91,"value":"/**\n * Display a table of tile sources defined in the current context\n */\ntileSourceTable = async function(context, options) {\n \n // Wrangle arguments for backwards compatibility\n if (!context || !context[contextSymbol]) {\n options = context;\n context = globalContext;\n }\n \n const tileSources = await context.flowClient.tileSources.list();\n\n if (tileSources.length) {\n const tsInfo = tileSources.map(ts => ({\n 'TileSource ID': ts.id,\n Type: ts.type,\n Source: ts.source\n }));\n\n return Inputs.table(tsInfo, {layout: 'auto'});\n } else {\n return md`No tile sources`;\n }\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":761,"value":"-----\n\n### `mapStyleTable`","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":765,"value":"The **mapStyleTable** function creates a table of available base map styles.\n\n#### Parameters\n|||\n|----------|------------------------------|\n|`context` | Flo.w RDF context (optional) |\n|`options` | Options object (optional) |\n\n#### Example","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":771,"value":"mapStyleTable()","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":757,"value":"/**\n * Display a table of basemap styles defined in the current context\n */\nmapStyleTable = async function (context, options) {\n // Wrangle arguments for backwards compatibility\n if (!context || !context[contextSymbol]) {\n options = context;\n context = globalContext;\n }\n\n const styles = await context.flowClient.styles.list();\n\n if (styles.length) {\n const info = styles.map((s) => ({\n \"Style ID\": s.id,\n Name: s.name,\n Description: s.description,\n Type: s.type,\n }));\n\n return Inputs.table(info, { layout: \"auto\" });\n } else {\n return md`No map styles`;\n }\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":493,"value":"-----\n\n### `datasetSource`","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":145,"value":"The **datasetSource()** function returns the formatted SQL source of the specified dataset.\n\n\n#### Parameters\n|||\n|----------|------------------------------|\n|datasetIdOrObj| Dataset ID (string) or dataset object |\n|`context` | Flo.w RDF context (optional) |\n\n#### Example","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":621,"value":"datasetSource(\"airquality_with_params\")","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":111,"value":"/**\n * Display dataset source with SQL syntax highlighting\n */\ndatasetSource = async function (datasetIdOrObj, context) {\n // Wrangle arguments for backwards compatibility\n if (!context || !context[contextSymbol]) {\n context = globalContext;\n }\n\n const dataset = await getDataset(datasetIdOrObj, context);\n\n if (dataset) {\n return md`\n~~~sql\n${dataset.source}\n~~~\n`;\n } else {\n return md`Dataset not found`;\n }\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":496,"value":"-----\n\n### `datasetAttributes`","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":148,"value":"The **datasetAttributes()** function returns a table of attributes for the specified dataset in the supplied context.\n\n#### Parameters\n|||\n|----------|------------------------------|\n|datasetIdOrObj| Dataset ID (string) or dataset object |\n|`context` | Flo.w RDF context (optional) |\n\n#### Example","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":624,"value":"datasetAttributes(\"airquality\")","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":140,"value":"/**\n * Display table of dataset attributes\n */\ndatasetAttributes = async function (datasetIdOrObj, tableOptions, context) {\n // Wrangle arguments for backwards compatibility\n if (!context || !context[contextSymbol]) {\n context = globalContext;\n }\n\n const dataset = await getDataset(datasetIdOrObj, context);\n\n if (dataset) {\n const attrs = dataset.attributes;\n\n return Inputs.table(\n attrs.map((a) => ({\n attribute: a.attribute,\n type: a.type,\n \"DB Type\": a.dbType,\n description: a.description || \"-\"\n })),\n { layout: \"auto\", ...tableOptions }\n );\n } else {\n return md`Dataset not found`;\n }\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":498,"value":"-----\n\n### `datasetSummary`","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":612,"value":"The **datasetSummary()** function returns a complete summary of the specified dataset.\n\n#### Parameters\n|||\n|----------|------------------------------|\n|datasetIdOrObj| Dataset ID (string) or dataset object |\n|options| Options object (optional) |\n|`context` | Flo.w RDF context (optional) |\n","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":218,"value":"$4e","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":502,"value":"-----\n\n### `datasetQuery`\n\nThe **datasetQuery** function runs a Flo.w query using the supplied [Flo.w Query Definition](https://developer.emu-analytics.net/docs/flow-engine/datasets/dataset-queries.html#flo-w-query-definitions) and returns the results as a Promise.\n\n#### Parameters\n|||\n|----------|------------------------------|\n|query| Flo.w query definition |\n|`context` | Flo.w RDF context (optional) |\n\n#### Example\n","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":657,"value":"datasetQuery({\n datasetId: \"airquality\",\n limit: 10\n})","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":389,"value":"datasetQuery = function(query, context) {\n // Wrangle arguments for backwards compatibility\n if (!context || !context[contextSymbol]) {\n context = globalContext;\n }\n\n return context.flowClient.datasets.query(query);\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":504,"value":"-----\n\n### `datasetQueryTable`","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":660,"value":"\nThe **datasetQueryTable** function runs a Flo.w query using the supplied [Flo.w Query Definition](https://developer.emu-analytics.net/docs/flow-engine/datasets/dataset-queries.html#flo-w-query-definitions) and returns a table of results. \n\nThe function is designed to be used with Observable's `viewof` operator: the results are displayed as a table but the cell's value is set to the result array and can be referenced by other cells as usual.\n\nThe cell's value also responds to the selection state of rows in the table.\n\n\n#### Parameters\n|||\n|----------|------------------------------|\n|query| Flo.w query definition |\n|tableOptions| Options object (see [Inputs.table](https://github.com/observablehq/inputs/blob/main/README.md#table))\n|`context` | Flo.w RDF context (optional) |\n\n#### Example\n","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":664,"value":"// Display query results as a table\nviewof queryResults = datasetQueryTable(\n {\n datasetId: \"airquality\",\n limit: 10\n },\n { layout: \"auto\" }\n)","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":671,"value":"// Use queryResults in another cell\nqueryResults","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":393,"value":"datasetQueryTable = async function (query, tableOptions, context) {\n // Wrangle arguments for backwards compatibility\n if (!context || !context[contextSymbol]) {\n context = globalContext;\n }\n\n const results = await context.flowClient.datasets.query(query);\n const table = Inputs.table(results, { ...tableOptions });\n //table.value = results;\n\n return table;\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":507,"value":"-----\n\n### `mapClickedFeature`","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":676,"value":"Use the **mapClickedFeature** function to receive information about features clicked on the specified map. \n\nThis function returns a [generator](https://observablehq.com/@observablehq/introduction-to-generators) that updates as features are clicked.\n\n#### Parameters\n|||\n|----------|------------------------------|\n|map| Flo.w Map element |\n\n\n","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":417,"value":"mapClickedFeature = function (map) {\n return Generators.observe((notify) => {\n\n notify(undefined);\n \n const clicked = (ev) => {\n notify(ev.detail.features[0]);\n };\n\n map.addEventListener(\"flowMapClick\", clicked);\n\n return () => map.removeEventListener(\"flowMapClick\", clicked);\n });\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":511,"value":"-----\n\n### `mapSelectedFeatureId`","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":681,"value":"Use the **mapSelectedFeatureId** function to receive the IDs of selected features on the specified map. \n\nThis function returns a [generator](https://observablehq.com/@observablehq/introduction-to-generators) that updates as features are selected and deselected.\n\n#### Parameters\n|||\n|----------|------------------------------|\n|map| Flo.w Map element |\n\n","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":431,"value":"mapSelectedFeatureId = function (map, dataSourceId) {\n return Generators.observe((notify) => {\n\n notify(undefined);\n \n const stateChanged = (ev) => {\n if (dataSourceId === ev.detail.dataSourceId) {\n notify(ev.detail.selection);\n }\n };\n\n map.addEventListener(\"flowMapSelectionStateChanged\", stateChanged);\n\n return () =>\n map.removeEventListener(\"flowMapSelectionStateChanged\", stateChanged);\n });\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":513,"value":"-----\n\n### `mapSelectedFeature`","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":691,"value":"Use the **mapSelectedFeature** function to receive selected features for the specified map. \n\nThis function returns a [generator](https://observablehq.com/@observablehq/introduction-to-generators) that updates as features are clicked.\n\n#### Parameters\n|||\n|----------|------------------------------|\n|map| Flo.w Map element |\n\n","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":435,"value":"mapSelectedFeature = function (map, dataSourceId) {\n return Generators.observe((notify) => {\n\n notify(undefined);\n \n const stateChanged = (ev) => {\n if (dataSourceId === ev.detail.dataSourceId) {\n notify(ev.detail.selection);\n }\n };\n\n map.addEventListener(\"flowMapSelectionFeatureStateChanged\", stateChanged);\n\n return () =>\n map.removeEventListener(\"flowMapSelectionFeatureStateChanged\", stateChanged);\n });\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":516,"value":"-----\n\n### `stateGet`\n\nThe **stateGet** function reads the specified Flo.w RDF reactive state property. \n\nThis function returns a [generator](https://observablehq.com/@observablehq/introduction-to-generators) that updates as the property changes.\n\n#### Parameters\n|||\n|----------|------------------------------|\n|`prop`| Flo.w RDF state property |\n|`context` | Flo.w RDF context (optional) |\n","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":420,"value":"stateGet = function (prop, context) {\n // Wrangle arguments for backwards compatibility\n if (!context || !context[contextSymbol]) {\n context = globalContext;\n }\n\n return Generators.observe((notify) => {\n const subscription = context.state.toStream(prop).subscribe(notify);\n\n return () => subscription.unsubscribe();\n });\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":519,"value":"-----\n\n### `stateSet`\n\nThe **stateSet** function sets the specified Flo.w RDF reactive state property.\n\n#### Parameters\n|||\n|----------|------------------------------|\n|`prop`| Flo.w RDF state property |\n|`value`| Value to set |\n|`context` | Flo.w RDF context (optional) |\n","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":424,"value":"stateSet = function (prop, val, context) {\n // Wrangle arguments for backwards compatibility\n if (!context || !context[contextSymbol]) {\n context = globalContext;\n }\n context.state.set(prop, val);\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":522,"value":"-----\n\n### `stateMerge (deprecated)`\n\n**Deprecated** Use `stateTransaction` instead.\n\nThe **stateMerge** function sets multiple Flo.w RDF reactive state properties atomically. Supply a single object containing all the properties/value pairs to set.\n\n#### Parameters\n|||\n|----------|------------------------------|\n|`prop`| Flo.w RDF state property |\n|`value`| Object with properties to set |\n|`context` | Flo.w RDF context (optional) |\n\n","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":427,"value":"stateMerge = function (prop, val, context) {\n // Wrangle arguments for backwards compatibility\n if (!context || !context[contextSymbol]) {\n context = globalContext;\n }\n context.state.merge(prop, val);\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":815,"value":"-----\n\n### `stateTransaction`\n\n\nThe **stateTransaction** function is designed to wrap multiple calls to `stateSet` into a single reactive update.\n\n#### Parameters\n|||\n|----------|------------------------------|\n|`fn`| inline arrow function that calls `stateSet` as required |\n|`context` | Flo.w RDF context (optional) |\n\n","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"","database":"$undefined"},{"id":817,"value":"stateTransaction = function (fn, context) {\n // Wrangle arguments for backwards compatibility\n if (!context || !context[contextSymbol]) {\n context = globalContext;\n }\n context.state.transaction(fn);\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":729,"value":"fullscreen = function (cell, options) {\n if (\n !document.body.requestFullscreen &&\n !document.body.webkitRequestFullscreen\n ) {\n return false;\n }\n if (document.body.className === \"fullscreen\") {\n return false;\n }\n\n if (cell.fullscreenicon) {\n cell.fullscreenicon.remove();\n }\n\n cell.fullscreenicon = fullScreenButton();\n cell.fullscreenicon.onclick = () => {\n const container = cell.parentNode;\n if (container.requestFullscreen) {\n container.requestFullscreen();\n } else if (container.webkitRequestFullscreen) {\n container.webkitRequestFullscreen();\n }\n };\n if (cell.parentNode) {\n cell.parentNode.appendChild(cell.fullscreenicon, cell);\n console.log(\"adding fullscreen button\");\n if (options?.center) cell.parentNode.className += \" center\";\n }\n\n if (!fullScreenStyle.attached) {\n fullScreenStyle.attached = true;\n document.getElementsByTagName(\"head\")[0].appendChild(fullScreenStyle());\n }\n\n return true;\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":525,"value":"-----\n\n### Internal functions","pinned":false,"hidden":false,"mode":"md","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":308,"value":"getDataset = async function (datasetIdOrObject, context) {\n return typeof datasetIdOrObject === \"string\"\n ? context.flowClient.datasets.get(datasetIdOrObject)\n : datasetIdOrObject;\n}","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":734,"value":"fullScreenButton = () =>\n html`

`","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":736,"value":"fullScreenStyle = () => html`\n`","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":738,"value":"fullScreenIcon = encodeURI(\n ``\n).replace(/'/g, '\"')","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":48,"value":"md`---`","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":87,"value":"md`## Appendix`","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":457,"value":"import { table } from \"@tmcw/tables\"","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":201,"value":"import { textcolor } from \"@observablehq/text-color-annotations-in-markdown\"","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":235,"value":"humanDate = require(\"human-date\")","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":444,"value":"import { toc } from \"@nebrius/indented-toc\"","pinned":false,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":713,"value":"vega = require(\"vega-embed@6.25\")","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":722,"value":"turf = require(\"@turf/turf@prerelease\")","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":725,"value":"dayjs = require(\"dayjs\")","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":779,"value":"dayjsUtcPlugin = require(\"dayjs/plugin/utc\")","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":785,"value":"dayjsTzPlugin = require(\"dayjs/plugin/timezone\")","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":789,"value":"dayjsCustomParseFormatPlugin = require(\"dayjs/plugin/customParseFormat\")","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"},{"id":749,"value":"import { flowQueryBuilder } from \"@emuanalytics/flow-query-builder\"","pinned":true,"hidden":false,"mode":"ojs","author":"$undefined","summary":"$undefined","tool":"$undefined","providerMetadata":"$undefined","attachments":"$undefined","output":"$undefined","database":"$undefined"}],"files":"$W4f","stdlib":"1"}} 44:null