console: sync: "Add meta information" option

jitsucom · Dec 17, 2024 · 3761e55 · 3761e55
1 parent 1016c3a
commit 3761e55
Show file tree

Hide file tree

Showing 3 changed files with 19 additions and 0 deletions.
diff --git a/webapps/console/components/SyncEditorPage/SyncEditorPage.tsx b/webapps/console/components/SyncEditorPage/SyncEditorPage.tsx
@@ -523,6 +523,23 @@ function SyncEditor({
           ),
         }
       : undefined,
+    destinationType.usesBulker
+      ? {
+          name: "Add meta information",
+          documentation: (
+            <>
+              Add additional fields with meta information to each record. Meta information includes:
+              <br />
+              <code>_jitsu_timestamp</code> - time when the record was updated
+            </>
+          ),
+          component: (
+            <div className={"w-80"}>
+              <SwitchComponent value={syncOptions?.addMeta} onChange={e => updateOptions({ addMeta: e })} />
+            </div>
+          ),
+        }
+      : undefined,
   ].filter(Boolean) as EditorItem[];
   if (appConfig.syncs.scheduler.enabled) {
     const disableScheduling =

diff --git a/webapps/console/lib/schema/index.ts b/webapps/console/lib/schema/index.ts
@@ -241,6 +241,7 @@ export const SyncOptionsType = z.object({
   namespace: z.string().optional(),
   tableNamePrefix: z.string().optional(),
   toSameCase: z.boolean().optional(),
+  addMeta: z.boolean().optional(),
   schedule: z.union([z.string(), z.enum(["0 0 * * *", "0 * * * *", "*/15 * * * *", "*/5 * * * *", "* * * * *"])]),
   timezone: z.string().optional(),
 });

diff --git a/webapps/console/lib/server/sync.ts b/webapps/console/lib/server/sync.ts
@@ -628,6 +628,7 @@ export async function scheduleSync({
         startedBy: JSON.stringify(startedBy),
         namespace: typeof sync.data?.["namespace"] !== "undefined" ? sync.data?.["namespace"] : "${LEGACY}",
         toSameCase: sync.data?.["toSameCase"] ? "true" : "false",
+        addMeta: sync.data?.["addMeta"] ? "true" : "false",
         tableNamePrefix: sync.data?.["tableNamePrefix"] ?? "",
       },
       body: {