computed view endpoint for api client

packages/api-client-core/src/GadgetFunctions.ts

@@ -1,3 +1,4 @@
+import type { FieldSelection } from "tiny-graphql-query-compiler";
 import type { GadgetRecord, RecordShape } from "./GadgetRecord.js";
 import type { GadgetRecordList } from "./GadgetRecordList.js";
 import type { LimitToKnownKeys, VariablesOptions } from "./types.js";
@@ -206,3 +207,13 @@ export interface GlobalActionFunction<VariablesT> {
 
 export type AnyActionFunction = ActionFunctionMetadata<any, any, any, any, any, any> | GlobalActionFunction<any>;
 export type AnyBulkActionFunction = ActionFunctionMetadata<any, any, any, any, any, true>;
+
+export interface ComputedViewFunction<VariablesT, ResultT> {
+  (variables: VariablesT): Promise<ResultT>;
+  type: "computedView";
+  operationName: string;
+  namespace: string | string[] | null;
+  variables: VariablesOptions;
+  variablesType: VariablesT;
+  selections: FieldSelection;
+}

packages/api-client-core/src/operationBuilders.ts

@@ -286,6 +286,27 @@ export const globalActionOperation = (
   });
 };
 
+export const computedViewOperation = (
+  operation: string,
+  variables: VariablesOptions,
+  selections: FieldSelection,
+  namespace?: string | string[] | null
+) => {
+  let fields = {
+    [operation]: Call(variableOptionsToVariables(variables), fieldSelectionToQueryCompilerFields(selections, true)),
+  };
+
+  if (namespace) {
+    fields = namespacify(namespace, fields);
+  }
+
+  return compileWithVariableValues({
+    type: "query",
+    name: operation,
+    fields,
+  });
+};
+
 export interface GraphQLBackgroundActionOptions {
   retries?: { retryCount: number };
   queue?: { name: string; maxConcurrency?: number };

packages/api-client-core/src/operationRunners.ts

@@ -19,6 +19,7 @@ import type { AnyModelManager } from "./ModelManager.js";
 import {
   actionOperation,
   backgroundActionResultOperation,
+  computedViewOperation,
   enqueueActionOperation,
   findManyOperation,
   findOneByFieldOperation,
@@ -384,6 +385,19 @@ export const globalActionRunner = async (
   return assertMutationSuccess(response, dataPath).result;
 };
 
+export const computedViewRunner = async (
+  connection: GadgetConnection,
+  operation: string,
+  variables: VariablesOptions,
+  selections: FieldSelection,
+  namespace?: string | string[] | null
+) => {
+  const plan = computedViewOperation(operation, variables, selections, namespace);
+  const response = await connection.currentClient.query(plan.query, plan.variables);
+  const dataPath = namespaceDataPath([operation], namespace);
+  return assertOperationSuccess(response, dataPath);
+};
+
 export async function enqueueActionRunner<SchemaT, Action extends AnyBulkActionFunction, Result = BackgroundActionHandle<SchemaT, Action>>(
   connection: GadgetConnection,
   action: Action,