[wip] MapperNode: support liquid

Author: SIMULATAN

Diff for: build.gradle.kts

@@ -184,14 +184,17 @@ dependencies {
         }
 }
 
+if (isDevelopment) {
+    tasks.run.configure {
+        classpath += devSourceSet.output
+    }
+}
+
 application {
     mainClass.set("me.snoty.backend.ApplicationKt")
 
     if (isDevelopment) {
         applicationDefaultJvmArgs += "-Dio.ktor.development=$isDevelopment"
-        tasks.run.configure {
-            classpath += devSourceSet.output
-        }
     }
 }
 

Diff for: integrations/api/build.gradle.kts

@@ -1,38 +1,41 @@
 plugins {
-    alias(libs.plugins.kotlin.jvm)
-    alias(libs.plugins.kotlin.serialization)
-    alias(libs.plugins.kotlin.kover)
+	alias(libs.plugins.kotlin.jvm)
+	alias(libs.plugins.kotlin.serialization)
+	alias(libs.plugins.kotlin.kover)
 }
 
 dependencies {
-    api(projects.api)
+	api(projects.api)
 
-    implementation(database.mongodb)
+	implementation(database.mongodb)
 
-    api(ktor.client.core)
-    api(ktor.client.apache)
-    api(ktor.client.contentNegotiation)
-    api(ktor.serialization.kotlinx.json)
-    api(ktor.server.core)
-    api(ktor.server.auth)
+	api(ktor.client.core)
+	api(ktor.client.apache)
+	api(ktor.client.contentNegotiation)
+	api(ktor.serialization.kotlinx.json)
+	api(ktor.server.core)
+	api(ktor.server.auth)
 
-    api(monitoring.micrometer)
-    api(monitoring.ktor.opentelemetry)
+	api(monitoring.micrometer)
+	api(monitoring.ktor.opentelemetry)
 
-    api(libraries.jackson.core)
-    api(libraries.jackson.kotlin)
-    api(libraries.bson.kotlinx)
+	api(libraries.jackson.core)
+	api(libraries.jackson.kotlin)
+	api(libraries.bson.kotlinx)
+
+	// liquid for java
+	implementation("nl.big-o:liqp:0.9.0.3")
 
 	testImplementation(kotlin("test"))
-    testImplementation(tests.mockk)
+	testImplementation(tests.mockk)
 }
 
 base.archivesName = "integration-api"
 
 subprojects {
-    base.archivesName = "integration-${this.name}"
+	base.archivesName = "integration-${this.name}"
 }
 
 tasks.test {
-    useJUnitPlatform()
-}
+	useJUnitPlatform()
+}

Diff for: integrations/api/src/main/kotlin/me/snoty/integration/common/wiring/node/impl/mapper/MapperEngines.kt

@@ -0,0 +1,43 @@
+package me.snoty.integration.common.wiring.node.impl.mapper
+
+import liqp.TemplateParser
+import org.bson.Document
+
+object MapperEngines {
+	private val engines = mutableMapOf<String, Templater>()
+
+	private fun engine(name: String, templater: Templater) {
+		engines[name] = templater
+	}
+
+	init {
+		engine("replace") { settings, data ->
+			val mappedData = Document()
+			settings.fields.forEach { (key, value) ->
+				var result = value
+				for (field in data) {
+					result = result.replace("%${field.key}%", field.value.toString())
+				}
+				mappedData[key] = result
+			}
+
+			mappedData
+		}
+
+		engine("liquid") { settings, data ->
+			val mappedData = Document()
+			settings.fields.forEach { (key, value) ->
+				val template = TemplateParser.DEFAULT.parse(value)
+				val rendered = template.render(data as Map<String, Any>)
+
+				mappedData[key] = rendered
+			}
+
+			mappedData
+		}
+	}
+
+	fun get(settings: MapperSettings): Templater? {
+		return engines[settings.engine]
+	}
+}

Diff for: integrations/api/src/main/kotlin/me/snoty/integration/common/wiring/node/impl/MapperNode.kt renamed to integrations/api/src/main/kotlin/me/snoty/integration/common/wiring/node/impl/mapper/MapperNode.kt

@@ -1,4 +1,4 @@
-package me.snoty.integration.common.wiring.node.impl
+package me.snoty.integration.common.wiring.node.impl.mapper
 
 import kotlinx.serialization.Serializable
 import me.snoty.integration.common.wiring.*
@@ -21,18 +21,12 @@ class MapperNodeHandler(override val nodeHandlerContext: NodeHandlerContext) : N
 
 	context(NodeHandlerContext, EmitNodeOutputContext)
 	override suspend fun process(logger: Logger, node: IFlowNode, input: IntermediateData) {
-		val config: MapperSettings = node.getConfig()
+		val settings: MapperSettings = node.getConfig()
 		val data: Document = input.get()
+		val engine = MapperEngines.get(settings)
+			?: throw IllegalStateException("Engine not found!")
 
-		val mappedData = Document()
-		// TODO: templating engine
-		config.fields.forEach { (key, value) ->
-			var result = value
-			for (field in data) {
-				result = result.replace("%${field.key}%", field.value.toString())
-			}
-			mappedData[key] = result
-		}
+		val mappedData = engine(settings, data)
 
 		structOutput {
 			mappedData

Diff for: integrations/api/src/main/kotlin/me/snoty/integration/common/wiring/node/impl/mapper/Templater.kt

@@ -0,0 +1,5 @@
+package me.snoty.integration.common.wiring.node.impl.mapper
+
+import org.bson.Document
+
+typealias Templater = (settings: MapperSettings, data: Document) -> Document

Diff for: integrations/api/src/main/resources/META-INF/services/me.snoty.integration.common.wiring.node.NodeHandlerContributor

@@ -1 +1 @@
-me.snoty.integration.common.wiring.node.impl.MapperNodeHandlerContributor
+me.snoty.integration.common.wiring.node.impl.mapper.MapperNodeHandlerContributor