forked from tsai/budibase
Martin McKeaveney
5 years ago
48 changed files with 490 additions and 202 deletions
@ -0,0 +1,19 @@ |
|||||
|
import { get } from "svelte/store" |
||||
|
import { getContext } from "svelte" |
||||
|
|
||||
|
/** |
||||
|
* Gets a component action. |
||||
|
* @param id The component ID that provides the action |
||||
|
* @param type The action type to get |
||||
|
* @returns {null|*} The action function |
||||
|
*/ |
||||
|
export const getAction = (id, type) => { |
||||
|
if (!id || !type) { |
||||
|
return null |
||||
|
} |
||||
|
const context = getContext("context") |
||||
|
if (!context) { |
||||
|
return null |
||||
|
} |
||||
|
return get(context)?.[`${id}_${type}`] |
||||
|
} |
||||
@ -0,0 +1,77 @@ |
|||||
|
<script> |
||||
|
import { Select } from "@budibase/bbui" |
||||
|
import { getContext } from "svelte" |
||||
|
import dayjs from "dayjs" |
||||
|
import utc from "dayjs/plugin/utc" |
||||
|
import { onMount } from "svelte" |
||||
|
|
||||
|
dayjs.extend(utc) |
||||
|
|
||||
|
export let dataProvider |
||||
|
export let field |
||||
|
export let defaultValue |
||||
|
|
||||
|
const dataContext = getContext("context") |
||||
|
const component = getContext("component") |
||||
|
const { styleable, builderStore, ActionTypes, getAction } = getContext("sdk") |
||||
|
|
||||
|
const setQuery = getAction(dataProvider?.id, ActionTypes.SetDataProviderQuery) |
||||
|
const options = [ |
||||
|
"Last 1 day", |
||||
|
"Last 7 days", |
||||
|
"Last 30 days", |
||||
|
"Last 3 months", |
||||
|
"Last 6 months", |
||||
|
"Last 1 year", |
||||
|
] |
||||
|
let value = options.includes(defaultValue) ? defaultValue : "Last 30 days" |
||||
|
|
||||
|
const updateDateRange = option => { |
||||
|
const query = dataProvider?.state?.query |
||||
|
if (!query || !setQuery) { |
||||
|
return |
||||
|
} |
||||
|
|
||||
|
value = option |
||||
|
let low = dayjs.utc().subtract(1, "year") |
||||
|
let high = dayjs.utc().add(1, "day") |
||||
|
|
||||
|
if (option === "Last 1 day") { |
||||
|
low = dayjs.utc().subtract(1, "day") |
||||
|
} else if (option === "Last 7 days") { |
||||
|
low = dayjs.utc().subtract(7, "days") |
||||
|
} else if (option === "Last 30 days") { |
||||
|
low = dayjs.utc().subtract(30, "days") |
||||
|
} else if (option === "Last 3 months") { |
||||
|
low = dayjs.utc().subtract(3, "months") |
||||
|
} else if (option === "Last 6 months") { |
||||
|
low = dayjs.utc().subtract(6, "months") |
||||
|
} |
||||
|
|
||||
|
// Update data provider query with the new filter |
||||
|
setQuery({ |
||||
|
...query, |
||||
|
range: { |
||||
|
...query.range, |
||||
|
[field]: { |
||||
|
high: high.format(), |
||||
|
low: low.format(), |
||||
|
}, |
||||
|
}, |
||||
|
}) |
||||
|
} |
||||
|
|
||||
|
// Update the range on mount to the initial value |
||||
|
onMount(() => { |
||||
|
updateDateRange(value) |
||||
|
}) |
||||
|
</script> |
||||
|
|
||||
|
<div use:styleable={$component.styles}> |
||||
|
<Select |
||||
|
placeholder={null} |
||||
|
{options} |
||||
|
{value} |
||||
|
on:change={e => updateDateRange(e.detail)} |
||||
|
/> |
||||
|
</div> |
||||
@ -0,0 +1,146 @@ |
|||||
|
/** |
||||
|
* Builds a lucene JSON query from the filter structure generated in the builder |
||||
|
* @param filter the builder filter structure |
||||
|
*/ |
||||
|
export const buildLuceneQuery = filter => { |
||||
|
let query = { |
||||
|
string: {}, |
||||
|
fuzzy: {}, |
||||
|
range: {}, |
||||
|
equal: {}, |
||||
|
notEqual: {}, |
||||
|
empty: {}, |
||||
|
notEmpty: {}, |
||||
|
} |
||||
|
if (Array.isArray(filter)) { |
||||
|
filter.forEach(({ operator, field, type, value }) => { |
||||
|
if (operator.startsWith("range")) { |
||||
|
if (!query.range[field]) { |
||||
|
query.range[field] = { |
||||
|
low: |
||||
|
type === "number" |
||||
|
? Number.MIN_SAFE_INTEGER |
||||
|
: "0000-00-00T00:00:00.000Z", |
||||
|
high: |
||||
|
type === "number" |
||||
|
? Number.MAX_SAFE_INTEGER |
||||
|
: "9999-00-00T00:00:00.000Z", |
||||
|
} |
||||
|
} |
||||
|
if (operator === "rangeLow" && value != null && value !== "") { |
||||
|
query.range[field].low = value |
||||
|
} else if (operator === "rangeHigh" && value != null && value !== "") { |
||||
|
query.range[field].high = value |
||||
|
} |
||||
|
} else if (query[operator]) { |
||||
|
query[operator][field] = value |
||||
|
} |
||||
|
}) |
||||
|
} |
||||
|
return query |
||||
|
} |
||||
|
|
||||
|
/** |
||||
|
* Performs a client-side lucene search on an array of data |
||||
|
* @param docs the data |
||||
|
* @param query the JSON lucene query |
||||
|
*/ |
||||
|
export const luceneQuery = (docs, query) => { |
||||
|
if (!query) { |
||||
|
return docs |
||||
|
} |
||||
|
|
||||
|
// Iterates over a set of filters and evaluates a fail function against a doc
|
||||
|
const match = (type, failFn) => doc => { |
||||
|
const filters = Object.entries(query[type] || {}) |
||||
|
for (let i = 0; i < filters.length; i++) { |
||||
|
if (failFn(filters[i][0], filters[i][1], doc)) { |
||||
|
return false |
||||
|
} |
||||
|
} |
||||
|
return true |
||||
|
} |
||||
|
|
||||
|
// Process a string match (fails if the value does not start with the string)
|
||||
|
const stringMatch = match("string", (key, value, doc) => { |
||||
|
return !doc[key] || !doc[key].startsWith(value) |
||||
|
}) |
||||
|
|
||||
|
// Process a range match
|
||||
|
const rangeMatch = match("range", (key, value, doc) => { |
||||
|
return !doc[key] || doc[key] < value.low || doc[key] > value.high |
||||
|
}) |
||||
|
|
||||
|
// Process an equal match (fails if the value is different)
|
||||
|
const equalMatch = match("equal", (key, value, doc) => { |
||||
|
return doc[key] !== value |
||||
|
}) |
||||
|
|
||||
|
// Process a not-equal match (fails if the value is the same)
|
||||
|
const notEqualMatch = match("notEqual", (key, value, doc) => { |
||||
|
return doc[key] === value |
||||
|
}) |
||||
|
|
||||
|
// Process an empty match (fails if the value is not empty)
|
||||
|
const emptyMatch = match("empty", (key, value, doc) => { |
||||
|
return doc[key] != null && doc[key] !== "" |
||||
|
}) |
||||
|
|
||||
|
// Process a not-empty match (fails is the value is empty)
|
||||
|
const notEmptyMatch = match("notEmpty", (key, value, doc) => { |
||||
|
return doc[key] == null || doc[key] === "" |
||||
|
}) |
||||
|
|
||||
|
// Match a document against all criteria
|
||||
|
const docMatch = doc => { |
||||
|
return ( |
||||
|
stringMatch(doc) && |
||||
|
rangeMatch(doc) && |
||||
|
equalMatch(doc) && |
||||
|
notEqualMatch(doc) && |
||||
|
emptyMatch(doc) && |
||||
|
notEmptyMatch(doc) |
||||
|
) |
||||
|
} |
||||
|
|
||||
|
// Process all docs
|
||||
|
return docs.filter(docMatch) |
||||
|
} |
||||
|
|
||||
|
/** |
||||
|
* Performs a client-side sort from the equivalent server-side lucene sort |
||||
|
* parameters. |
||||
|
* @param docs the data |
||||
|
* @param sort the sort column |
||||
|
* @param sortOrder the sort order ("ascending" or "descending") |
||||
|
* @param sortType the type of sort ("string" or "number") |
||||
|
*/ |
||||
|
export const luceneSort = (docs, sort, sortOrder, sortType = "string") => { |
||||
|
if (!sort || !sortOrder || !sortType) { |
||||
|
return docs |
||||
|
} |
||||
|
const parse = sortType === "string" ? x => `${x}` : x => parseFloat(x) |
||||
|
return docs.slice().sort((a, b) => { |
||||
|
const colA = parse(a[sort]) |
||||
|
const colB = parse(b[sort]) |
||||
|
if (sortOrder === "Descending") { |
||||
|
return colA > colB ? -1 : 1 |
||||
|
} else { |
||||
|
return colA > colB ? 1 : -1 |
||||
|
} |
||||
|
}) |
||||
|
} |
||||
|
|
||||
|
/** |
||||
|
* Limits the specified docs to the specified number of rows from the equivalent |
||||
|
* server-side lucene limit parameters. |
||||
|
* @param docs the data |
||||
|
* @param limit the number of docs to limit to |
||||
|
*/ |
||||
|
export const luceneLimit = (docs, limit) => { |
||||
|
const numLimit = parseFloat(limit) |
||||
|
if (isNaN(numLimit)) { |
||||
|
return docs |
||||
|
} |
||||
|
return docs.slice(0, numLimit) |
||||
|
} |
||||
Loading…
Reference in new issue