Support aggregationExp for Table/Query Sources

src/sources/types.ts

@@ -149,6 +149,15 @@ export type QuerySourceOptions = {
    *     ```
    */
   queryParameters?: QueryParameters;
+
+  /**
+   * Comma separated expressions that, in case of containing any, the source will be aggregated by geometry automatically.
+   *
+   * Example:
+   *
+   *     1 as value, avg(rev) as average_revenue
+   */
+  aggregationExp?: string;
 };
 
 export type TableSourceOptions = {
@@ -178,6 +187,15 @@ export type TableSourceOptions = {
    * - 4: 4096x4096
    */
   tileResolution?: TileResolution;
+
+  /**
+   * Comma separated expressions that, in case of containing any, the source will be aggregated by geometry automatically.
+   *
+   * Example:
+   *
+   *     1 as value, avg(rev) as average_revenue
+   */
+  aggregationExp?: string;
 };
 
 export type TilesetSourceOptions = {

src/sources/vector-query-source.ts

@@ -31,6 +31,7 @@ type UrlParameters = {
   tileResolution?: string;
   q: string;
   queryParameters?: Record<string, unknown> | unknown[];
+  aggregationExp?: string;
 };
 
 export type VectorQuerySourceResponse = TilejsonResult &
@@ -46,6 +47,7 @@ export const vectorQuerySource = async function (
     sqlQuery,
     tileResolution = DEFAULT_TILE_RESOLUTION,
     queryParameters,
+    aggregationExp,
   } = options;
 
   const urlParameters: UrlParameters = {
@@ -64,6 +66,9 @@ export const vectorQuerySource = async function (
   if (queryParameters) {
     urlParameters.queryParameters = queryParameters;
   }
+  if (aggregationExp) {
+    urlParameters.aggregationExp = aggregationExp;
+  }
   return baseSource<UrlParameters>('query', options, urlParameters).then(
     (result) => ({
       ...(result as TilejsonResult),

src/sources/vector-table-source.ts

@@ -22,13 +22,15 @@ export type VectorTableSourceOptions = SourceOptions &
   TableSourceOptions &
   FilterOptions &
   ColumnsOption;
+
 type UrlParameters = {
   columns?: string;
   filters?: Record<string, unknown>;
   spatialDataType: SpatialDataType;
   spatialDataColumn?: string;
   tileResolution?: string;
   name: string;
+  aggregationExp?: string;
 };
 
 export type VectorTableSourceResponse = TilejsonResult &
@@ -43,6 +45,7 @@ export const vectorTableSource = async function (
     spatialDataColumn = 'geom',
     tableName,
     tileResolution = DEFAULT_TILE_RESOLUTION,
+    aggregationExp,
   } = options;
 
   const urlParameters: UrlParameters = {
@@ -58,6 +61,9 @@ export const vectorTableSource = async function (
   if (filters) {
     urlParameters.filters = filters;
   }
+  if (aggregationExp) {
+    urlParameters.aggregationExp = aggregationExp;
+  }
   return baseSource<UrlParameters>('table', options, urlParameters).then(
     (result) => ({
       ...(result as TilejsonResult),

test/sources/vector-query-source.test.ts

@@ -40,6 +40,7 @@ describe('vectorQuerySource', () => {
       columns: ['a', 'b'],
       spatialDataColumn: 'mygeom',
       queryParameters: {type: 'Supermarket', minRevenue: 1000000},
+      aggregationExp: 'SUM(revenue)',
     });
 
     expect(vi.mocked(fetch)).toHaveBeenCalledTimes(2);
@@ -51,6 +52,7 @@ describe('vectorQuerySource', () => {
     expect(initURL).toMatch(/columns=a%2Cb/);
     expect(initURL).toMatch(/spatialDataColumn=mygeom/);
     expect(initURL).toMatch(/spatialDataType=geo/);
+    expect(initURL).toMatch(/aggregationExp=SUM%28revenue%29/);
     expect(initURL).toMatch(
       /queryParameters=%7B%22type%22%3A%22Supermarket%22%2C%22minRevenue%22%3A1000000%7D/
     );
@@ -66,6 +68,20 @@ describe('vectorQuerySource', () => {
     expect(tilejson.accessToken).toBe('<token>');
   });
 
+  test('when aggregationExp is not provided', async () => {
+    await vectorQuerySource({
+      connectionName: 'carto_dw',
+      accessToken: '<token>',
+      sqlQuery: 'SELECT * FROM a.b.vector_table',
+      columns: ['a', 'b'],
+      spatialDataColumn: 'mygeom',
+      queryParameters: {type: 'Supermarket', minRevenue: 1000000},
+    });
+
+    const [[initURL]] = vi.mocked(fetch).mock.calls;
+    expect(initURL).not.toContain('aggregationExp');
+  });
+
   test('widgetSource', async () => {
     const {widgetSource} = await vectorQuerySource({
       accessToken: '<token>',

test/sources/vector-table-source.test.ts

@@ -39,6 +39,7 @@ describe('vectorTableSource', () => {
       tableName: 'a.b.vector_table',
       columns: ['a', 'b'],
       spatialDataColumn: 'mygeom',
+      aggregationExp: 'SUM(revenue)',
     });
 
     expect(vi.mocked(fetch)).toHaveBeenCalledTimes(2);
@@ -50,7 +51,7 @@ describe('vectorTableSource', () => {
     expect(initURL).toMatch(/columns=a%2Cb/);
     expect(initURL).toMatch(/spatialDataColumn=mygeom/);
     expect(initURL).toMatch(/spatialDataType=geo/);
-
+    expect(initURL).toMatch(/aggregationExp=SUM%28revenue%29/);
     expect(tilesetURL).toMatch(
       /^https:\/\/xyz\.com\/\?format\=tilejson\&cache\=/
     );
@@ -62,6 +63,19 @@ describe('vectorTableSource', () => {
     expect(tilejson.accessToken).toBe('<token>');
   });
 
+  test('when aggregationExp is not provided', async () => {
+    await vectorTableSource({
+      connectionName: 'carto_dw',
+      accessToken: '<token>',
+      tableName: 'a.b.vector_table',
+      columns: ['a', 'b'],
+      spatialDataColumn: 'mygeom',
+    });
+
+    const [[initURL]] = vi.mocked(fetch).mock.calls;
+    expect(initURL).not.toContain('aggregationExp');
+  });
+
   test('widgetSource', async () => {
     const {widgetSource} = await vectorTableSource({
       accessToken: '<token>',