chore: rework (#194)

* chore: rework

* chore: updated events

Author: hmbanan666

apps/atrium-telegram/package.json

@@ -17,7 +17,7 @@
     "@neoconfetti/vue": "catalog:",
     "@pinia/nuxt": "catalog:",
     "@roll-stack/database": "workspace:*",
-    "@roll-stack/queue": "workspace:*",
+    "@roll-stack/essence": "workspace:*",
     "@roll-stack/ui": "workspace:*",
     "@telegram-apps/init-data-node": "catalog:",
     "@telegram-apps/sdk-vue": "catalog:",

apps/atrium-telegram/server/api/auth/me.get.ts

@@ -1,5 +1,5 @@
-import { repository } from '@roll-stack/database'
+import { db } from '@roll-stack/database'
 
 export default defineEventHandler(async (event) => {
-  return repository.user.find(event.context.user.id)
+  return db.user.find(event.context.user.id)
 })

apps/atrium-telegram/server/api/auth/online.post.ts

@@ -1,8 +1,8 @@
-import { repository } from '@roll-stack/database'
+import { db } from '@roll-stack/database'
 
 export default defineEventHandler(async (event) => {
   try {
-    await repository.user.updateOnline(event.context.user.id)
+    await db.user.updateOnline(event.context.user.id)
 
     return {
       ok: true,

apps/atrium-telegram/server/api/epic/comment/id/[commentId]/index.delete.ts

@@ -1,4 +1,4 @@
-import { repository } from '@roll-stack/database'
+import { db } from '@roll-stack/database'
 
 export default defineEventHandler(async (event) => {
   try {
@@ -11,7 +11,7 @@ export default defineEventHandler(async (event) => {
     }
 
     // Guard: not this user
-    const commentInDB = await repository.epic.findComment(commentId)
+    const commentInDB = await db.epic.findComment(commentId)
     if (!commentInDB) {
       throw createError({
         statusCode: 404,
@@ -25,7 +25,7 @@ export default defineEventHandler(async (event) => {
       })
     }
 
-    await repository.epic.deleteComment(commentInDB.id)
+    await db.epic.deleteComment(commentInDB.id)
 
     return {
       ok: true,

apps/atrium-telegram/server/api/epic/id/[epicId]/comment.post.ts

@@ -1,5 +1,5 @@
 import { createEpicCommentSchema } from '#shared/services/epic'
-import { repository } from '@roll-stack/database'
+import { db } from '@roll-stack/database'
 import { type } from 'arktype'
 
 export default defineEventHandler(async (event) => {
@@ -18,7 +18,7 @@ export default defineEventHandler(async (event) => {
       throw data
     }
 
-    const comment = await repository.epic.createComment({
+    const comment = await db.epic.createComment({
       text: data.text.trim(),
       userId: event.context.user.id,
       epicId,

apps/atrium-telegram/server/api/epic/id/[epicId]/index.patch.ts

@@ -1,5 +1,5 @@
 import { updateEpicSchema } from '#shared/services/epic'
-import { repository } from '@roll-stack/database'
+import { db } from '@roll-stack/database'
 import { type } from 'arktype'
 
 export default defineEventHandler(async (event) => {
@@ -18,7 +18,7 @@ export default defineEventHandler(async (event) => {
       throw data
     }
 
-    const epic = await repository.epic.update(epicId, data)
+    const epic = await db.epic.update(epicId, data)
 
     return {
       ok: true,

apps/atrium-telegram/server/api/epic/index.post.ts

@@ -1,5 +1,5 @@
 import { createEpicSchema } from '#shared/services/epic'
-import { repository } from '@roll-stack/database'
+import { db } from '@roll-stack/database'
 import { type } from 'arktype'
 
 export default defineEventHandler(async (event) => {
@@ -10,7 +10,7 @@ export default defineEventHandler(async (event) => {
       throw data
     }
 
-    const epic = await repository.epic.create({
+    const epic = await db.epic.create({
       ...data,
       userId: event.context.user.id,
     })
@@ -23,11 +23,11 @@ export default defineEventHandler(async (event) => {
 
     // Notify all staff
     if (event.context.user.type === 'staff') {
-      const users = await repository.user.list()
+      const users = await db.user.list()
       const allStaffExceptUser = users.filter((u) => u.type === 'staff' && u.id !== event.context.user.id)
 
       for (const staff of allStaffExceptUser) {
-        await repository.notification.create({
+        await db.notification.create({
           authorId: event.context.user.id,
           userId: staff.id,
           epicId: epic.id,

apps/atrium-telegram/server/api/epic/list.get.ts

@@ -1,5 +1,5 @@
-import { repository } from '@roll-stack/database'
+import { db } from '@roll-stack/database'
 
 export default defineEventHandler(async () => {
-  return repository.epic.list()
+  return db.epic.list()
 })

apps/atrium-telegram/server/api/flow/id/[itemId]/comment.post.ts

@@ -1,5 +1,5 @@
 import { createFlowItemCommentSchema } from '#shared/services/flow'
-import { repository } from '@roll-stack/database'
+import { db } from '@roll-stack/database'
 import { type } from 'arktype'
 
 export default defineEventHandler(async (event) => {
@@ -20,15 +20,15 @@ export default defineEventHandler(async (event) => {
 
     // Guards:
     // If not exist
-    const item = await repository.flow.findItem(itemId)
+    const item = await db.flow.findItem(itemId)
     if (!item) {
       throw createError({
         statusCode: 404,
         message: 'Item not found',
       })
     }
 
-    await repository.flow.createItemComment({
+    await db.flow.createItemComment({
       text: data.text,
       itemId,
       userId: event.context.user.id,

apps/atrium-telegram/server/api/flow/id/[itemId]/view.post.ts

@@ -1,4 +1,4 @@
-import { repository } from '@roll-stack/database'
+import { db } from '@roll-stack/database'
 
 export default defineEventHandler(async (event) => {
   try {
@@ -13,7 +13,7 @@ export default defineEventHandler(async (event) => {
     // Guards:
     // If not exist
     // If already viewed
-    const item = await repository.flow.findItem(itemId)
+    const item = await db.flow.findItem(itemId)
     if (!item) {
       throw createError({
         statusCode: 404,
@@ -27,7 +27,7 @@ export default defineEventHandler(async (event) => {
       })
     }
 
-    await repository.flow.createItemView({
+    await db.flow.createItemView({
       itemId,
       userId: event.context.user.id,
     })