Merge pull request #45 from HugoRCD/feat/44

apps/formatter/nitro.config.ts

@@ -1,7 +1,14 @@
 //https://nitro.unjs.io/config
 export default defineNitroConfig({
   srcDir: 'server',
+
   experimental: {
     tasks: true
-  }
+  },
+
+  scheduledTasks: {
+    '* * * * *': ['sync:mongo']
+  },
+
+  compatibilityDate: '2024-12-29'
 })

apps/formatter/package.json

@@ -5,7 +5,8 @@
     "build": "nitro build",
     "dev": "nitro dev",
     "prepare": "nitro prepare",
-    "preview": "node .output/server/index.mjs"
+    "preview": "node .output/server/index.mjs",
+    "sync:mongo": "nitro task run sync:mongo"
   },
   "devDependencies": {
     "nitropack": "latest",

apps/formatter/server/tasks/sync/mongo.ts

@@ -0,0 +1,16 @@
+import { MongoDBClient } from '@currencia/mongo'
+
+export default defineTask({
+  meta: {
+    name: 'sync:mongo',
+    description: 'Send MongoID to RabbitMQ',
+  },
+  async run() {
+    const client = await MongoDBClient.create()
+    console.log('Syncing MongoID to RabbitMQ')
+    const price = await client.getLatestPrices()
+    console.log('Price:', price)
+    console.log('Ids to sync:', price?._id)
+    return { result: 'Success' }
+  },
+})

packages/mongo/index.ts

@@ -9,6 +9,7 @@ type MongoConfig = {
 }
 
 type PriceDocument = {
+  _id?: string
   timestamp: Date
   prices: Record<string, number>
 }