mirror of
https://github.com/FlipsideCrypto/livequery-base.git
synced 2026-02-06 11:16:44 +00:00
LiveQuery udf_api support for arrays in data arg (#83)
This commit is contained in:
parent
3f8b47aa5b
commit
a000ce04ad
@ -5,7 +5,7 @@
|
||||
- [method, STRING]
|
||||
- [url, STRING]
|
||||
- [headers, OBJECT]
|
||||
- [DATA, OBJECT]
|
||||
- [DATA, VARIANT]
|
||||
- [user_id, STRING]
|
||||
- [SECRET, STRING]
|
||||
return_type: VARIANT
|
||||
|
||||
@ -5,7 +5,7 @@
|
||||
- [method, STRING]
|
||||
- [url, STRING]
|
||||
- [headers, OBJECT]
|
||||
- [data, OBJECT]
|
||||
- [data, VARIANT]
|
||||
- [secret_name, STRING]
|
||||
return_type: VARIANT
|
||||
options: |
|
||||
@ -27,7 +27,7 @@
|
||||
- [method, STRING]
|
||||
- [url, STRING]
|
||||
- [headers, OBJECT]
|
||||
- [data, OBJECT]
|
||||
- [data, VARIANT]
|
||||
return_type: VARIANT
|
||||
options: |
|
||||
NOT NULL
|
||||
@ -46,7 +46,7 @@
|
||||
- name: {{ schema }}.udf_api
|
||||
signature:
|
||||
- [url, STRING]
|
||||
- [data, OBJECT]
|
||||
- [data, VARIANT]
|
||||
return_type: VARIANT
|
||||
options: |
|
||||
NOT NULL
|
||||
@ -65,7 +65,7 @@
|
||||
- name: {{ schema }}.udf_api
|
||||
signature:
|
||||
- [url, STRING]
|
||||
- [data, OBJECT]
|
||||
- [data, VARIANT]
|
||||
- [secret_name, STRING]
|
||||
return_type: VARIANT
|
||||
options: |
|
||||
|
||||
@ -28,7 +28,7 @@ test AS
|
||||
$${{ context ~ "\n" }}SELECT {{ call ~ "\n" }};$$ AS sql
|
||||
FROM test
|
||||
WHERE NOT {{ assertion }}
|
||||
{%- if not loop.last -%}
|
||||
{%- if not loop.last %}
|
||||
UNION ALL
|
||||
{%- endif -%}
|
||||
{%- endfor -%}
|
||||
|
||||
27
models/deploy/core/live.yml
Normal file
27
models/deploy/core/live.yml
Normal file
@ -0,0 +1,27 @@
|
||||
version: 2
|
||||
models:
|
||||
- name: live
|
||||
columns:
|
||||
- name: udf_api
|
||||
tests:
|
||||
- test_udf:
|
||||
name: test__live_udf_api_post_data_object
|
||||
args: |
|
||||
'https://httpbin.org/post', {'foo': 'bar'}
|
||||
assertions:
|
||||
- result:data.json is not null
|
||||
- result:data.json = OBJECT_CONSTRUCT('foo', 'bar')
|
||||
- test_udf:
|
||||
name: test__live_udf_api_post_data_array
|
||||
args: |
|
||||
'https://httpbin.org/post', ['foo', 'bar']
|
||||
assertions:
|
||||
- result:data.json is not null
|
||||
- result:data.json = ARRAY_CONSTRUCT('foo', 'bar')
|
||||
- test_udf:
|
||||
name: test__live_udf_api_post_data_string
|
||||
args: |
|
||||
'https://httpbin.org/post', 'foo'::VARIANT
|
||||
assertions:
|
||||
- result:data.json is not null
|
||||
- result:data.json = 'foo'
|
||||
@ -1,8 +1,8 @@
|
||||
-- depends_on: {{ ref('live') }}
|
||||
{{ config(
|
||||
materialized = 'view',
|
||||
grants = {'+select': fromyaml(var('ROLES'))}
|
||||
) }}
|
||||
|
||||
SELECT '*.' || t.value AS allowed_domains
|
||||
FROM table(flatten(input => {{ this.database }}.live.udf_allow_list())) AS t
|
||||
ORDER BY
|
||||
|
||||
Loading…
Reference in New Issue
Block a user