@@ -54,6 +54,7 @@
     "ioredis": "^5.4.1",
     "is-plain-object": "^5.0.0",
     "joi": "^18.0.1",
+    "liquidjs": "^10.25.0",
     "loglevel": "^1.9.1",
     "lru-cache": "^11.0.2",
     "microdiff": "^1.5.0",
 
@@ -0,0 +1,109 @@
+import dayjs from 'dayjs'
+import { Liquid } from 'liquidjs'
+
+const liquidEngine = new Liquid({
+  strictVariables: false,
+  strictFilters: false,
+})
+
+function normalizeDate(value: unknown): dayjs.Dayjs {
+  if (value instanceof Date) {
+    return dayjs(value)
+  }
+  if (typeof value === 'number' || typeof value === 'string') {
+    return dayjs(value)
+  }
+  return dayjs()
+}
+
+liquidEngine.registerFilter('dateFormat', (value: unknown, format: string = 'YYYY-MM-DD HH:mm:ss') => {
+  return normalizeDate(value).format(format)
+})
+
+liquidEngine.registerFilter('unixMs', (value: unknown) => {
+  return normalizeDate(value).valueOf()
+})
+
+liquidEngine.registerFilter('unixSeconds', (value: unknown) => {
+  return normalizeDate(value).unix()
+})
+
+function buildTemplateContext(): Record<string, unknown> {
+  const now = dayjs()
+  return {
+    date: {
+      now: now.valueOf(),
+      isoNow: now.toISOString(),
+      nowDate: now.toDate(),
+      unix: now.valueOf(),
+      unixSeconds: now.unix(),
+      today: now.format('YYYY-MM-DD'),
+      yesterday: now.subtract(1, 'day').format('YYYY-MM-DD'),
+      tomorrow: now.add(1, 'day').format('YYYY-MM-DD'),
+    },
+  }
+}
+
+function getValueFromPath(context: Record<string, unknown>, path: string): unknown {
+  const segments = path.split('.').filter(Boolean)
+  let current: unknown = context
+
+  for (const segment of segments) {
+    if (!current || typeof current !== 'object') {
+      return undefined
+    }
+    current = (current as Record<string, unknown>)[segment]
+  }
+
+  return current
+}
+
+export async function resolveConfigVariables<T>(input: T): Promise<T> {
+  if (input === null || input === undefined) {
+    return input
+  }
+
+  if (Array.isArray(input)) {
+    const resolved = await Promise.all(input.map((item) => resolveConfigVariables(item)))
+    return resolved as T
+  }
+
+  if (typeof input === 'object') {
+    const entries = await Promise.all(
+      Object.entries(input as Record<string, unknown>).map(async ([key, value]) => {
+        return [key, await resolveConfigVariables(value)] as const
+      }),
+    )
+
+    return Object.fromEntries(entries) as T
+  }
+
+  if (typeof input === 'string') {
+    if (!input.includes('{{')) {
+      return input
+    }
+
+    const context = buildTemplateContext()
+    const exactTemplate = input.match(/^\{\{\s*([a-zA-Z0-9._-]+)\s*\}\}$/)
+    if (exactTemplate) {
+      try {
+        await liquidEngine.parseAndRender(input, context)
+        const fromContext = getValueFromPath(context, exactTemplate[1])
+        if (fromContext !== undefined) {
+          return fromContext as T
+        }
+      } catch {
+        return input
+      }
+    }
+
+    try {
+      const rendered = await liquidEngine.parseAndRender(input, context)
+      return rendered as T
+    } catch {
+      return input
+    }
+  }
+
+  return input
+}
@@ -8,6 +8,7 @@ import { CronTaskDTO } from './_dto/config-task.dto'
 import { loadcronTasks } from './_functions/load-cron-tasks.function'
 import { ConfigService } from '@nestjs/config'
 import { createHandlerLogger } from '~/_common/functions/handler-logger'
+import { resolveConfigVariables } from '~/_common/functions/resolve-config-variables.function'
 
 @Injectable()
 export class CronHooksService {
@@ -293,9 +294,10 @@ export class CronHooksService {
 
   private async executeHandlerCommand(name: string, handler: string, options?: Record<string, any>): Promise<void> {
     const args: string[] = []
+    const resolvedOptions = await resolveConfigVariables(options)
 
-    if (options && typeof options === 'object') {
-      for (const [k, v] of Object.entries(options)) {
+    if (resolvedOptions && typeof resolvedOptions === 'object') {
+      for (const [k, v] of Object.entries(resolvedOptions)) {
         if (typeof v === 'boolean') {
           if (v) args.push(`--${k}`)
         } else if (v === null || v === undefined) {
 
@@ -9,6 +9,7 @@ import { AbstractLifecycleService } from './_abstracts/abstract.lifecycle.servic
 import { ConfigRulesObjectSchemaDTO } from './_dto/config-rules.dto'
 import { loadCustomStates } from './_functions/load-custom-states.function'
 import { loadLifecycleRules } from './_functions/load-lifecycle-rules.function'
+import { resolveConfigVariables } from '~/_common/functions/resolve-config-variables.function'
 
 @Injectable()
 export class LifecycleHooksService extends AbstractLifecycleService {
@@ -278,14 +279,16 @@ export class LifecycleHooksService extends AbstractLifecycleService {
       for (const idRule of lfr.identities) {
         if (typeof idRule.trigger === 'number' && (idRule.trigger > 0 || ignoreTrigger)) {
           const dateKey = idRule.dateKey || 'lastSync'
+          const resolvedRules = await resolveConfigVariables(idRule.rules ?? {})
+          const resolvedMutation = await resolveConfigVariables(idRule.mutation ?? {})
 
           try {
             const checkDate = new Date(Date.now() - (idRule.trigger * 1000))
             const filterDate = {}
             filterDate[dateKey] = { $lte: checkDate }
 
             const req = {
-              ...idRule.rules,
+              ...resolvedRules,
               lifecycle: {
                 $in: idRule.sources,
               },
@@ -306,7 +309,7 @@ export class LifecycleHooksService extends AbstractLifecycleService {
                 { _id: identity._id },
                 {
                   $set: {
-                    ...idRule.mutation,
+                    ...resolvedMutation,
                     lifecycle: idRule.target,
                     lastLifecycleUpdate: new Date(),
                   },
@@ -450,6 +453,8 @@ export class LifecycleHooksService extends AbstractLifecycleService {
 
       for (const lcs of this.lifecycleSources[after.lifecycle]) {
         this.logger.verbose(`Processing lifecycle source <${after.lifecycle}> with rules: ${JSON.stringify(lcs.rules)}`)
+        const resolvedRules = await resolveConfigVariables(lcs.rules ?? {})
+        const resolvedMutation = await resolveConfigVariables(lcs.mutation ?? {})
 
         if (lcs.trigger) {
           this.logger.debug(`Skipping lifecycle source <${after.lifecycle}> with trigger: ${lcs.trigger}`)
@@ -458,13 +463,13 @@ export class LifecycleHooksService extends AbstractLifecycleService {
 
         const res = await this.identitiesService.model.findOneAndUpdate(
           {
-            ...lcs.rules,
+            ...resolvedRules,
             _id: after._id,
             ignoreLifecycle: { $ne: true },
           },
           {
             $set: {
-              ...lcs.mutation,
+              ...resolvedMutation,
               lifecycle: lcs.target,
               lastLifecycleUpdate: new Date(),
             },
 
@@ -8586,6 +8586,11 @@ duplexer@^0.1.2:
   resolved "https://registry.yarnpkg.com/duplexer/-/duplexer-0.1.2.tgz#3abe43aef3835f8ae077d136ddce0f276b0400e6"
   integrity sha512-jtD6YG370ZCIi/9GTaJKQxWTZD045+4R4hTk/x1UyoqadyJ9x9CgSi1RlVDQF8U2sxLLSnFkCaMihqljHIWgMg==
 
+eastasianwidth@^0.2.0:
+  version "0.2.0"
+  resolved "https://registry.yarnpkg.com/eastasianwidth/-/eastasianwidth-0.2.0.tgz#696ce2ec0aa0e6ea93a397ffcf24aa7840c827cb"
+  integrity sha512-I88TYZWc9XiYHRQ4/3c5rjjfgkjhLyW2luGIheGERbNQ6OY7yTybanSpDXZa8y7VUP9YmDcYa+eyq4ca7iLqWA==
+
 ecdsa-sig-formatter@1.0.11:
   version "1.0.11"
   resolved "https://registry.yarnpkg.com/ecdsa-sig-formatter/-/ecdsa-sig-formatter-1.0.11.tgz#ae0f0fa2d85045ef14a817daa3ce9acd0489e5bf"
@@ -8633,11 +8638,21 @@ emittery@^0.13.1:
   resolved "https://registry.yarnpkg.com/emittery/-/emittery-0.13.1.tgz#c04b8c3457490e0847ae51fced3af52d338e3dad"
   integrity sha512-DeWwawk6r5yR9jFgnDKYt4sLS0LmHJJi3ZOnb5/JdbYwj3nW+FxQnHIjhBKz8YLC7oRNPVM9NQ47I3CVx34eqQ==
 
+emoji-regex@^10.3.0:
+  version "10.6.0"
+  resolved "https://registry.yarnpkg.com/emoji-regex/-/emoji-regex-10.6.0.tgz#bf3d6e8f7f8fd22a65d9703475bc0147357a6b0d"
+  integrity sha512-toUI84YS5YmxW219erniWD0CIVOo46xGKColeNQRgOzDorgBi1v4D71/OFzgD9GO2UGKIv1C3Sp8DAn0+j5w7A==
+
 emoji-regex@^8.0.0:
   version "8.0.0"
   resolved "https://registry.yarnpkg.com/emoji-regex/-/emoji-regex-8.0.0.tgz#e818fd69ce5ccfcb404594f842963bf53164cc37"
   integrity sha512-MSjYzcWNOA0ewAHpz0MxpYFvwg6yjy1NG3xteoqz644VCo/RPgnr1/GGt+ic3iJTzQ8Eu3TdM14SawnVUmGE6A==
 
+emoji-regex@^9.2.2:
+  version "9.2.2"
+  resolved "https://registry.yarnpkg.com/emoji-regex/-/emoji-regex-9.2.2.tgz#840c8803b0d8047f4ff0cf963176b32d4ef3ed72"
+  integrity sha512-L18DaJsXSUk2+42pv8mLs5jJT2hqFkFE4j21wOmgbUqsZ2hL72NsUU785g9RXgo3s0ZNgVl42TiHp3ZtOv/Vyg==
+
 enabled@2.0.x:
   version "2.0.0"
   resolved "https://registry.yarnpkg.com/enabled/-/enabled-2.0.0.tgz#f9dd92ec2d6f4bbc0d5d1e64e21d61cd4665e7c2"
@@ -9732,6 +9747,11 @@ get-caller-file@^2.0.5:
   resolved "https://registry.yarnpkg.com/get-caller-file/-/get-caller-file-2.0.5.tgz#4f94412a82db32f36e3b0b9741f8a97feb031f7e"
   integrity sha512-DyFP3BM/3YHTQOCUL/w0OZHR0lpKeGrxotcHWcqNEdnltqFwXVfhEBQ94eIo34AfQpo0rGki4cyIiftY06h2Fg==
 
+get-east-asian-width@^1.0.0:
+  version "1.5.0"
+  resolved "https://registry.yarnpkg.com/get-east-asian-width/-/get-east-asian-width-1.5.0.tgz#ce7008fe345edcf5497a6f557cfa54bc318a9ce7"
+  integrity sha512-CQ+bEO+Tva/qlmw24dCejulK5pMzVnUOFOijVogd3KQs07HnRIgp8TGipvCCRT06xeYEbpbgwaCxglFyiuIcmA==
+
 get-intrinsic@^1.2.4, get-intrinsic@^1.2.5, get-intrinsic@^1.2.6, get-intrinsic@^1.3.0:
   version "1.3.0"
   resolved "https://registry.yarnpkg.com/get-intrinsic/-/get-intrinsic-1.3.0.tgz#743f0e3b6964a93a5491ed1bffaae054d7f98d01"
@@ -11495,6 +11515,13 @@ liquidjs@^10.11.1:
   dependencies:
     commander "^10.0.0"
 
+liquidjs@^10.25.0:
+  version "10.25.0"
+  resolved "https://registry.yarnpkg.com/liquidjs/-/liquidjs-10.25.0.tgz#a5ec7063c3202348dc5988343502ad27072f4997"
+  integrity sha512-XpO7AiGULTG4xcTlwkcTI5JreFG7b6esLCLp+aUSh7YuQErJZEoUXre9u9rbdb0057pfWG4l0VursvLd5Q/eAw==
+  dependencies:
+    commander "^10.0.0"
+
 listhen@^1.9.0:
   version "1.9.0"
   resolved "https://registry.yarnpkg.com/listhen/-/listhen-1.9.0.tgz#59355f7e4fc1eefda6bc494ae7e9ed13aa7658ef"
@@ -15302,7 +15329,7 @@ string-length@^4.0.1:
     is-fullwidth-code-point "^3.0.0"
     strip-ansi "^6.0.1"
 
-"string-width@^1.0.2 || 2 || 3 || 4", string-width@^4.0.0, string-width@^4.1.0, string-width@^4.2.0, string-width@^4.2.2, string-width@^4.2.3, string-width@^5.0.1, string-width@^5.1.2, string-width@^7.2.0:
+string-width@^4.0.0, string-width@^4.1.0, string-width@^4.2.0, string-width@^4.2.2, string-width@^4.2.3:
   version "4.2.3"
   resolved "https://registry.yarnpkg.com/string-width/-/string-width-4.2.3.tgz#269c7117d27b05ad2e536830a8ec895ef9c6d010"
   integrity sha512-wKyQRQpjJ0sIp62ErSZdGsjMJWsap5oRNihHhu6G7JVO/9jIB6UyevL+tXuOqrng8j/cxKTWyWUwvSTriiZz/g==
@@ -15311,6 +15338,24 @@ string-length@^4.0.1:
     is-fullwidth-code-point "^3.0.0"
     strip-ansi "^6.0.1"
 
+string-width@^5.0.1, string-width@^5.1.2:
+  version "5.1.2"
+  resolved "https://registry.yarnpkg.com/string-width/-/string-width-5.1.2.tgz#14f8daec6d81e7221d2a357e668cab73bdbca794"
+  integrity sha512-HnLOCR3vjcY8beoNLtcjZ5/nxn2afmME6lhrDrebokqMap+XbeW8n9TXpPDOqdGK5qcI3oT0GKTW6wC7EMiVqA==
+  dependencies:
+    eastasianwidth "^0.2.0"
+    emoji-regex "^9.2.2"
+    strip-ansi "^7.0.1"
+
+string-width@^7.2.0:
+  version "7.2.0"
+  resolved "https://registry.yarnpkg.com/string-width/-/string-width-7.2.0.tgz#b5bb8e2165ce275d4d43476dd2700ad9091db6dc"
+  integrity sha512-tsaTIkKW9b4N+AEj+SVA+WhJzV7/zMhcSu78mLKWSk7cXMOSHsBKFWUs0fWwq8QyK3MgJBQRX6Gbi4kYbdvGkQ==
+  dependencies:
+    emoji-regex "^10.3.0"
+    get-east-asian-width "^1.0.0"
+    strip-ansi "^7.1.0"
+
 string_decoder@^1.1.1, string_decoder@^1.3.0:
   version "1.3.0"
   resolved "https://registry.yarnpkg.com/string_decoder/-/string_decoder-1.3.0.tgz#42f114594a46cf1a8e30b0a84f56c78c3edac21e"