feat: snowpipe streaming

src/v0/destinations/snowpipe_streaming/transform.js

@@ -0,0 +1,34 @@
+const { processWarehouseMessage } = require('../../../warehouse');
+
+const provider = 'snowflake';
+
+function getDataTypeOverride(key, val, options, jsonKey = false) {
+  if (key === 'violationErrors' || jsonKey) {
+    return 'json';
+  }
+  return 'string';
+}
+
+function process(event) {
+  const whSchemaVersion = event.request.query.whSchemaVersion || 'v1';
+  const whIDResolve = event.request.query.whIDResolve === 'true' || false;
+  const whStoreEvent = event.destination.Config.storeFullEvent === true;
+  const destJsonPaths = event.destination?.Config?.jsonPaths || '';
+  return processWarehouseMessage(event.message, {
+    metadata: event.metadata,
+    whSchemaVersion,
+    whStoreEvent,
+    whIDResolve,
+    getDataTypeOverride,
+    provider,
+    sourceCategory: event.metadata ? event.metadata.sourceCategory : null,
+    destJsonPaths,
+    destConfig: event.destination?.Config,
+  });
+}
+
+module.exports = {
+  provider,
+  process,
+  getDataTypeOverride,
+};