{"version":3,"file":"check-statement-status.cjs","names":["z","action"],"sources":["../../src/actions/check-statement-status.ts"],"sourcesContent":["import type { AppAction } from \"@keystrokehq/keystroke/app\";\nimport { z } from \"zod\";\n\nimport { action } from \"../action\";\nimport { snowflake } from \"../app\";\n\nexport const SnowflakeCheckStatementStatusInput = z.object({\n  partition: z.number().int().describe(\"The partition number to return. The size of each partition is determined by Snowflake.\").optional(),\n  requestId: z.string().describe(\"Unique ID (UUID) of the API request for idempotency.\").optional(),\n  statementHandle: z.string().describe(\"The handle of the statement to be checked.\"),\n});\nconst SnowflakeCheckStatementStatus_RowTypeInfoSchema = z.object({\n  name: z.string().describe(\"Name of the column.\").nullable(),\n  type: z.string().describe(\"Data type of the column (e.g., 'text', 'fixed', 'timestamp_ltz').\").nullable(),\n  scale: z.number().int().describe(\"Scale for numeric types.\").nullable().optional(),\n  table: z.string().describe(\"Table name.\").nullable(),\n  length: z.number().int().describe(\"Length for text types.\").nullable().optional(),\n  schema: z.string().describe(\"Schema name.\").nullable(),\n  database: z.string().describe(\"Database name.\").nullable(),\n  nullable: z.boolean().describe(\"Whether the column is nullable.\").nullable(),\n  collation: z.string().describe(\"Collation for text types.\").nullable().optional(),\n  precision: z.number().int().describe(\"Precision for numeric types.\").nullable().optional(),\n  byteLength: z.number().int().describe(\"Byte length for text types.\").nullable().optional(),\n}).passthrough();\nconst SnowflakeCheckStatementStatus_PartitionInfoSchema = z.object({\n  rowCount: z.number().int().describe(\"Number of rows in this partition.\").nullable(),\n  uncompressedSize: z.number().int().describe(\"Uncompressed size of the partition in bytes.\").nullable(),\n}).passthrough();\nconst SnowflakeCheckStatementStatus_ResultSetMetadataSchema = z.object({\n  format: z.string().describe(\"Format of the result set (e.g., 'jsonv2').\").nullable(),\n  numRows: z.number().int().describe(\"Total number of rows in the result set.\").nullable(),\n  rowType: z.array(SnowflakeCheckStatementStatus_RowTypeInfoSchema).describe(\"Metadata describing each column in the result set.\"),\n  partitionInfo: z.array(SnowflakeCheckStatementStatus_PartitionInfoSchema).describe(\"Information about result set partitions.\"),\n}).passthrough();\nexport const SnowflakeCheckStatementStatusOutput = z.object({\n  code: z.string().describe(\"Response code (e.g., '090001' for success).\").nullable().optional(),\n  data: z.array(z.array(z.union([z.string(), z.number().int(), z.number(), z.boolean()]).nullable())).describe(\"The result set data as a 2D array, where each inner array represents a row.\").nullable().optional(),\n  message: z.string().describe(\"Human-readable message describing the statement execution status.\").nullable().optional(),\n  sqlState: z.string().describe(\"SQL state code (e.g., '00000' for success).\").nullable().optional(),\n  createdOn: z.number().int().describe(\"Unix timestamp (in milliseconds) when the statement execution started.\").nullable().optional(),\n  requestId: z.string().describe(\"Unique ID (UUID) of the API request.\").nullable().optional(),\n  statementHandle: z.string().describe(\"Unique identifier (UUID) for the statement being executed.\").nullable().optional(),\n  resultSetMetaData: SnowflakeCheckStatementStatus_ResultSetMetadataSchema.nullable().optional(),\n  statementStatusUrl: z.string().describe(\"URL path to retrieve the statement status and result set.\").nullable().optional(),\n}).passthrough();\n\nexport const snowflakeCheckStatementStatus: AppAction<\n  typeof SnowflakeCheckStatementStatusInput,\n  typeof SnowflakeCheckStatementStatusOutput,\n  typeof snowflake.credential\n> = action(\"SNOWFLAKE_CHECK_STATEMENT_STATUS\", {\n  slug: \"snowflake-check-statement-status\",\n  name: \"Check Statement Status\",\n  description: \"Retrieves the status and results of a previously submitted SQL statement using its statement handle. Use this to poll async queries submitted via SNOWFLAKE_SUBMIT_SQL_STATEMENT; call repeatedly until status is no longer pending. Use SNOWFLAKE_CANCEL_STATEMENT to abort a hanging query.\",\n  input: SnowflakeCheckStatementStatusInput,\n  output: SnowflakeCheckStatementStatusOutput,\n});\n"],"mappings":";;;;AAMA,MAAa,qCAAqCA,IAAAA,EAAE,OAAO;CACzD,WAAWA,IAAAA,EAAE,OAAO,CAAC,CAAC,IAAI,CAAC,CAAC,SAAS,wFAAwF,CAAC,CAAC,SAAS;CACxI,WAAWA,IAAAA,EAAE,OAAO,CAAC,CAAC,SAAS,sDAAsD,CAAC,CAAC,SAAS;CAChG,iBAAiBA,IAAAA,EAAE,OAAO,CAAC,CAAC,SAAS,4CAA4C;AACnF,CAAC;AACD,MAAM,kDAAkDA,IAAAA,EAAE,OAAO;CAC/D,MAAMA,IAAAA,EAAE,OAAO,CAAC,CAAC,SAAS,qBAAqB,CAAC,CAAC,SAAS;CAC1D,MAAMA,IAAAA,EAAE,OAAO,CAAC,CAAC,SAAS,mEAAmE,CAAC,CAAC,SAAS;CACxG,OAAOA,IAAAA,EAAE,OAAO,CAAC,CAAC,IAAI,CAAC,CAAC,SAAS,0BAA0B,CAAC,CAAC,SAAS,CAAC,CAAC,SAAS;CACjF,OAAOA,IAAAA,EAAE,OAAO,CAAC,CAAC,SAAS,aAAa,CAAC,CAAC,SAAS;CACnD,QAAQA,IAAAA,EAAE,OAAO,CAAC,CAAC,IAAI,CAAC,CAAC,SAAS,wBAAwB,CAAC,CAAC,SAAS,CAAC,CAAC,SAAS;CAChF,QAAQA,IAAAA,EAAE,OAAO,CAAC,CAAC,SAAS,cAAc,CAAC,CAAC,SAAS;CACrD,UAAUA,IAAAA,EAAE,OAAO,CAAC,CAAC,SAAS,gBAAgB,CAAC,CAAC,SAAS;CACzD,UAAUA,IAAAA,EAAE,QAAQ,CAAC,CAAC,SAAS,iCAAiC,CAAC,CAAC,SAAS;CAC3E,WAAWA,IAAAA,EAAE,OAAO,CAAC,CAAC,SAAS,2BAA2B,CAAC,CAAC,SAAS,CAAC,CAAC,SAAS;CAChF,WAAWA,IAAAA,EAAE,OAAO,CAAC,CAAC,IAAI,CAAC,CAAC,SAAS,8BAA8B,CAAC,CAAC,SAAS,CAAC,CAAC,SAAS;CACzF,YAAYA,IAAAA,EAAE,OAAO,CAAC,CAAC,IAAI,CAAC,CAAC,SAAS,6BAA6B,CAAC,CAAC,SAAS,CAAC,CAAC,SAAS;AAC3F,CAAC,CAAC,CAAC,YAAY;AACf,MAAM,oDAAoDA,IAAAA,EAAE,OAAO;CACjE,UAAUA,IAAAA,EAAE,OAAO,CAAC,CAAC,IAAI,CAAC,CAAC,SAAS,mCAAmC,CAAC,CAAC,SAAS;CAClF,kBAAkBA,IAAAA,EAAE,OAAO,CAAC,CAAC,IAAI,CAAC,CAAC,SAAS,8CAA8C,CAAC,CAAC,SAAS;AACvG,CAAC,CAAC,CAAC,YAAY;AACf,MAAM,wDAAwDA,IAAAA,EAAE,OAAO;CACrE,QAAQA,IAAAA,EAAE,OAAO,CAAC,CAAC,SAAS,4CAA4C,CAAC,CAAC,SAAS;CACnF,SAASA,IAAAA,EAAE,OAAO,CAAC,CAAC,IAAI,CAAC,CAAC,SAAS,yCAAyC,CAAC,CAAC,SAAS;CACvF,SAASA,IAAAA,EAAE,MAAM,+CAA+C,CAAC,CAAC,SAAS,oDAAoD;CAC/H,eAAeA,IAAAA,EAAE,MAAM,iDAAiD,CAAC,CAAC,SAAS,0CAA0C;AAC/H,CAAC,CAAC,CAAC,YAAY;AACf,MAAa,sCAAsCA,IAAAA,EAAE,OAAO;CAC1D,MAAMA,IAAAA,EAAE,OAAO,CAAC,CAAC,SAAS,6CAA6C,CAAC,CAAC,SAAS,CAAC,CAAC,SAAS;CAC7F,MAAMA,IAAAA,EAAE,MAAMA,IAAAA,EAAE,MAAMA,IAAAA,EAAE,MAAM;EAACA,IAAAA,EAAE,OAAO;EAAGA,IAAAA,EAAE,OAAO,CAAC,CAAC,IAAI;EAAGA,IAAAA,EAAE,OAAO;EAAGA,IAAAA,EAAE,QAAQ;CAAC,CAAC,CAAC,CAAC,SAAS,CAAC,CAAC,CAAC,CAAC,SAAS,6EAA6E,CAAC,CAAC,SAAS,CAAC,CAAC,SAAS;CAChN,SAASA,IAAAA,EAAE,OAAO,CAAC,CAAC,SAAS,mEAAmE,CAAC,CAAC,SAAS,CAAC,CAAC,SAAS;CACtH,UAAUA,IAAAA,EAAE,OAAO,CAAC,CAAC,SAAS,6CAA6C,CAAC,CAAC,SAAS,CAAC,CAAC,SAAS;CACjG,WAAWA,IAAAA,EAAE,OAAO,CAAC,CAAC,IAAI,CAAC,CAAC,SAAS,wEAAwE,CAAC,CAAC,SAAS,CAAC,CAAC,SAAS;CACnI,WAAWA,IAAAA,EAAE,OAAO,CAAC,CAAC,SAAS,sCAAsC,CAAC,CAAC,SAAS,CAAC,CAAC,SAAS;CAC3F,iBAAiBA,IAAAA,EAAE,OAAO,CAAC,CAAC,SAAS,4DAA4D,CAAC,CAAC,SAAS,CAAC,CAAC,SAAS;CACvH,mBAAmB,sDAAsD,SAAS,CAAC,CAAC,SAAS;CAC7F,oBAAoBA,IAAAA,EAAE,OAAO,CAAC,CAAC,SAAS,2DAA2D,CAAC,CAAC,SAAS,CAAC,CAAC,SAAS;AAC3H,CAAC,CAAC,CAAC,YAAY;AAEf,MAAa,gCAITC,eAAAA,OAAO,oCAAoC;CAC7C,MAAM;CACN,MAAM;CACN,aAAa;CACb,OAAO;CACP,QAAQ;AACV,CAAC"}