16 Commits

Author SHA1 Message Date
ac24680bd4 chore(release): v0.0.6 2023-05-16 13:46:26 +03:00
d381058591 fix: remove useMongoose composable 2023-05-16 13:44:13 +03:00
cfc7ea59b8 chore(release): v0.0.5 2023-05-12 09:15:08 +03:00
b4fa9f5617 fix: update icon link 2023-04-28 15:40:55 +03:00
c967d0bb16 fix: update icon link 2023-04-28 15:40:19 +03:00
c8bcc9c488 fix: update logo 2023-04-27 15:39:09 +03:00
f00819768e fix: add brackets 2023-04-27 00:05:13 +03:00
e0f56dfa38 fix: update readme 2023-04-26 23:44:57 +03:00
ecac456a4a chore: update dependencies 2023-04-26 23:39:39 +03:00
3d4d959422 chore(release): v0.0.4 2023-04-26 23:34:44 +03:00
d6a524f5f5 chore(release): v0.0.3 2023-04-26 22:51:02 +03:00
e9b764b72f fix: handle errors 2023-04-26 22:45:40 +03:00
260eadd837 chore: move readyState 2023-04-26 22:44:45 +03:00
ad0c5b2d40 fix: initial pagination 2023-04-26 18:34:51 +03:00
3ac731c5ee feat: initial pagination 2023-04-26 18:31:25 +03:00
f40c48370c feat: duplicate document 2023-04-26 17:45:11 +03:00
13 changed files with 1188 additions and 1039 deletions

View File

@ -1,6 +1,68 @@
# Changelog # Changelog
## v0.0.6
[compare changes](https://github.com/arashsheyda/nuxt-mongoose/compare/v0.0.5...v0.0.6)
### 🩹 Fixes
- Remove useMongoose composable ([d381058](https://github.com/arashsheyda/nuxt-mongoose/commit/d381058))
### ❤️ Contributors
- Arashsheyda <sheidaeearash1999@gmail.com>
## v0.0.5
[compare changes](https://github.com/arashsheyda/nuxt-mongoose/compare/v0.0.4...v0.0.5)
### 🩹 Fixes
- Update readme ([e0f56df](https://github.com/arashsheyda/nuxt-mongoose/commit/e0f56df))
- Add brackets ([f008197](https://github.com/arashsheyda/nuxt-mongoose/commit/f008197))
- Update logo ([c8bcc9c](https://github.com/arashsheyda/nuxt-mongoose/commit/c8bcc9c))
- Update icon link ([c967d0b](https://github.com/arashsheyda/nuxt-mongoose/commit/c967d0b))
- Update icon link ([b4fa9f5](https://github.com/arashsheyda/nuxt-mongoose/commit/b4fa9f5))
### 🏡 Chore
- Update dependencies ([ecac456](https://github.com/arashsheyda/nuxt-mongoose/commit/ecac456))
### ❤️ Contributors
- Arashsheyda <sheidaeearash1999@gmail.com>
- Arash
## v0.0.4
[compare changes](https://github.com/arashsheyda/nuxt-mongoose/compare/v0.0.3...v0.0.4)
## v0.0.3
[compare changes](https://github.com/arashsheyda/nuxt-mongoose/compare/v0.0.2...v0.0.3)
### 🚀 Enhancements
- Duplicate document ([f40c483](https://github.com/arashsheyda/nuxt-mongoose/commit/f40c483))
- Initial pagination ([3ac731c](https://github.com/arashsheyda/nuxt-mongoose/commit/3ac731c))
### 🩹 Fixes
- Initial pagination ([ad0c5b2](https://github.com/arashsheyda/nuxt-mongoose/commit/ad0c5b2))
- Handle errors ([e9b764b](https://github.com/arashsheyda/nuxt-mongoose/commit/e9b764b))
### 🏡 Chore
- Move readyState ([260eadd](https://github.com/arashsheyda/nuxt-mongoose/commit/260eadd))
### ❤️ Contributors
- Arashsheyda <sheidaeearash1999@gmail.com>
## v0.0.2 ## v0.0.2
[compare changes](https://github.com/arashsheyda/nuxt-mongoose/compare/v0.0.1...v0.0.2) [compare changes](https://github.com/arashsheyda/nuxt-mongoose/compare/v0.0.1...v0.0.2)

View File

@ -1,4 +1,4 @@
![nuxt-mongoose](./docs/public/nuxt-mongoose.svg) ![nuxt-mongoose](https://raw.githubusercontent.com/arashsheyda/nuxt-mongoose/c967d0bb162dddc27fa510ba3b49e4f9b6b2db61/docs/public/nuxt-mongoose.svg)
<div align="center"> <div align="center">
<h1>Nuxt Mongoose</h1> <h1>Nuxt Mongoose</h1>
@ -10,7 +10,7 @@
## Installation ## Installation
```bash ```bash
pnpm add nuxt-mongoose mongoose pnpm add nuxt-mongoose
``` ```
## Usage ## Usage
@ -83,17 +83,6 @@ export const User = defineMongooseModel({
}) })
``` ```
### useMongoose
This composable returns the Mongoose DB instance. Example usage:
```vue
<script lang="ts" setup>
const mongoose = useMongoose()
const user = await mongoose.db.collection('users').findOne()
</script>
```
## License ## License
[MIT License](./LICENSE) [MIT License](./LICENSE)

View File

@ -1,16 +1,13 @@
<script lang="ts" setup> <script lang="ts" setup>
import './styles/global.css' import './styles/global.css'
const readyState = computedAsync(async () => await rpc.readyState())
</script> </script>
<template> <template>
<Html> <Html>
<Body h-screen> <Body h-screen>
<NuxtLayout v-if="readyState === 1"> <NuxtLayout>
<NuxtPage /> <NuxtPage />
</NuxtLayout> </NuxtLayout>
<Connection v-else :connection="readyState" />
</Body> </Body>
</Html> </Html>
</template> </template>

View File

@ -1,4 +1,3 @@
<!-- eslint-disable no-console -->
<script lang="ts" setup> <script lang="ts" setup>
const props = defineProps({ const props = defineProps({
collection: { collection: {
@ -7,8 +6,19 @@ const props = defineProps({
}, },
}) })
// TODO: save in local storage
const pagination = reactive({ limit: 20, page: 1 })
const countDocuments = computedAsync(async () => {
return await rpc.countDocuments(props.collection)
})
const documents = computedAsync(async () => { const documents = computedAsync(async () => {
return await rpc.listDocuments(props.collection) return await rpc.listDocuments(props.collection, pagination)
})
watch(pagination, async () => {
documents.value = await rpc.listDocuments(props.collection, pagination)
}) })
const schema = computedAsync<any>(async () => { const schema = computedAsync<any>(async () => {
@ -68,19 +78,24 @@ function editDocument(document: any) {
selectedDocument.value = { ...document } selectedDocument.value = { ...document }
} }
async function saveDocument() { async function saveDocument(document: any, create = true) {
await rpc.createDocument(props.collection, selectedDocument.value) const method = create ? rpc.createDocument : rpc.updateDocument
editing.value = false const newDocument = await method(props.collection, document)
selectedDocument.value = undefined if (newDocument?.error)
documents.value = await rpc.listDocuments(props.collection) return alert(newDocument.error.message)
}
async function updateDocument() { if (create) {
// TODO: validate & show errors if (!documents.value.length) {
await rpc.updateDocument(props.collection, selectedDocument.value) documents.value = await rpc.listDocuments(props.collection, pagination)
editing.value = false return discardEditing()
selectedDocument.value = undefined }
documents.value = await rpc.listDocuments(props.collection) documents.value.push({ _id: newDocument.insertedId, ...document })
}
else {
const index = documents.value.findIndex((doc: any) => doc._id === newDocument.value._id)
documents.value[index] = document
}
discardEditing()
} }
function discardEditing() { function discardEditing() {
@ -89,9 +104,14 @@ function discardEditing() {
} }
async function deleteDocument(document: any) { async function deleteDocument(document: any) {
rpc.deleteDocument(props.collection, document._id) const newDocument = await rpc.deleteDocument(props.collection, document._id)
documents.value = await rpc.listDocuments(props.collection) if (newDocument.deletedCount === 0)
return alert('Failed to delete document')
documents.value = documents.value.filter((doc: any) => doc._id !== document._id)
} }
const copy = useCopy()
</script> </script>
<template> <template>
@ -102,9 +122,29 @@ async function deleteDocument(document: any) {
Add Document Add Document
</NButton> </NButton>
</template> </template>
<div op50> <div v-if="countDocuments" flex items-center>
<span v-if="search">{{ filtered.length }} matched · </span> <div op50>
<span>{{ documents?.length }} documents in total</span> <span v-if="search">{{ filtered.length }} matched · </span>
<span>{{ documents?.length }} of {{ countDocuments }} documents in total</span>
</div>
<div flex-auto />
<div flex gap-2>
<NSelect v-if="pagination.limit !== 0" v-model="pagination.page">
<option v-for="i in Math.ceil(countDocuments / pagination.limit)" :key="i" :value="i">
page:
{{ i }}
</option>
</NSelect>
<NSelect v-model="pagination.limit">
<option v-for="i in [1, 2, 3, 4, 5]" :key="i" :value="i * 10">
show:
{{ i * 10 }}
</option>
<option :value="0">
show all
</option>
</NSelect>
</div>
</div> </div>
</Navbar> </Navbar>
<table v-if="documents?.length || selectedDocument" w-full mb10 :class="{ 'editing-mode': editing }"> <table v-if="documents?.length || selectedDocument" w-full mb10 :class="{ 'editing-mode': editing }">
@ -119,7 +159,6 @@ async function deleteDocument(document: any) {
</tr> </tr>
</thead> </thead>
<tbody> <tbody>
<!-- hover-bg-green hover-bg-opacity-5 hover-text-green cursor-pointer -->
<tr v-for="document in filtered" :key="document._id" :class="{ isEditing: editing && selectedDocument._id === document._id }"> <tr v-for="document in filtered" :key="document._id" :class="{ isEditing: editing && selectedDocument._id === document._id }">
<td v-for="field of fields" :key="field" @dblclick="editDocument(document)"> <td v-for="field of fields" :key="field" @dblclick="editDocument(document)">
<template v-if="editing && selectedDocument._id === document._id"> <template v-if="editing && selectedDocument._id === document._id">
@ -130,14 +169,16 @@ async function deleteDocument(document: any) {
</span> </span>
</td> </td>
<td class="actions"> <td class="actions">
<div flex justify-center gap2> <div flex justify-center gap2 class="group">
<template v-if="editing && selectedDocument._id === document._id"> <template v-if="editing && selectedDocument._id === document._id">
<NIconButton icon="carbon-save" @click="updateDocument" /> <NIconButton icon="carbon-save" @click="saveDocument(selectedDocument, false)" />
<NIconButton icon="carbon-close" @click="discardEditing" /> <NIconButton icon="carbon-close" @click="discardEditing" />
</template> </template>
<template v-else> <template v-else>
<NIconButton icon="carbon-edit" @click="editDocument(document)" /> <NIconButton icon="carbon-edit" @click="editDocument(document)" />
<NIconButton icon="carbon-delete" @click="deleteDocument(document)" /> <NIconButton icon="carbon-delete" @click="deleteDocument(document)" />
<NIconButton icon="carbon-document-multiple-02" @click="saveDocument(document)" />
<NIconButton absolute right-4 opacity-0 group-hover="opacity-100" transition-all icon="carbon-copy" @click="copy(JSON.stringify(document))" />
</template> </template>
</div> </div>
</td> </td>
@ -148,7 +189,7 @@ async function deleteDocument(document: any) {
<input v-else placeholder="ObjectId(_id)" disabled> <input v-else placeholder="ObjectId(_id)" disabled>
</td> </td>
<td flex justify-center gap2 class="actions"> <td flex justify-center gap2 class="actions">
<NIconButton icon="carbon-save" @click="saveDocument" /> <NIconButton icon="carbon-save" @click="saveDocument(selectedDocument)" />
<NIconButton icon="carbon-close" @click="discardEditing" /> <NIconButton icon="carbon-close" @click="discardEditing" />
</td> </td>
</tr> </tr>

View File

@ -0,0 +1,10 @@
import { useClipboard } from '@vueuse/core'
export function useCopy() {
const clipboard = useClipboard()
return (text: string) => {
clipboard.copy(text)
// TODO: show toast
}
}

View File

@ -1,5 +1,10 @@
<script lang="ts" setup>
const readyState = computedAsync(async () => await rpc.readyState())
</script>
<template> <template>
<div h-full of-auto> <div h-full of-auto>
<slot /> <slot v-if="readyState === 1" />
<Connection v-else :connection="readyState" />
</div> </div>
</template> </template>

View File

@ -1,26 +1,26 @@
<?xml version="1.0" encoding="utf-8"?> <?xml version="1.0" encoding="utf-8"?>
<!-- Generator: Adobe Illustrator 25.0.0, SVG Export Plug-In . SVG Version: 6.00 Build 0) --> <!-- Generator: Adobe Illustrator 25.0.0, SVG Export Plug-In . SVG Version: 6.00 Build 0) -->
<svg version="1.1" id="Layer_1" xmlns="http://www.w3.org/2000/svg" xmlns:xlink="http://www.w3.org/1999/xlink" x="0px" y="0px" <svg version="1.1" id="Layer_1" xmlns="http://www.w3.org/2000/svg" xmlns:xlink="http://www.w3.org/1999/xlink" x="0px" y="0px"
viewBox="0 0 914.6 296.6" style="enable-background:new 0 0 914.6 296.6;" xml:space="preserve"> viewBox="0 0 520.1 232.7" style="enable-background:new 0 0 520.1 232.7;" xml:space="preserve">
<style type="text/css"> <style type="text/css">
.st0{fill:#880000;} .st0{fill:#880000;}
.st1{fill:#00DC82;} .st1{fill:#00DC82;}
</style> </style>
<path class="st0" d="M620,225.4c-47.8-6.5-96.2,6.6-134.1,36.4c-9.7-24.4-21.2-48-34.1-70.8c-10.8-19.1-18.1-29.1-28.6-29.9 <path class="st0" d="M323.9,193.5c-47.8-6.5-96.2,6.6-134.1,36.4c-9.7-24.3-21.1-48-34.1-70.8c-10.8-19.1-18.1-29.1-28.6-29.9
c-10.5-0.8-21.3,9.9-25.3,15c-2.4-6.3-11.1-27-25.7-28.6c-14.6-1.6-26.7,16.2-41.7,38c-12.2,17.8-22,37.1-29.3,57.4 s-21.3,9.9-25.3,15C94,126,82.2,113.3,71.2,114.3c-6.5,0.6-12,7.6-22.6,21.5C38.3,149.5,31,161.7,25,172.5
c-4.9-14.1-18.2-46.7-51.4-69.3c-42.6-28.9-100.8-29.7-151.2-3.2c82.8-70,172.3-122.4,284.9-120c10.8,56.5,46.3,100.5,79.8,105.9 c-5.4,9.7-12.4,22.7-19.9,38.5C5.3,133.1,6,75,5.8,49.3c0-4.6-0.1-15.1,6.8-22.9c7.3-8.2,18.6-9.1,34.2-10.2
c-14.4-13.7-33.3-29-48.6-47.3c-13.2-15.6-21.3-34.8-21-56.6c0.2-12.6,5.8-19.8,17.5-18.2c23.3,3.5,46.3,8.9,69.3,13.6 c9.6-0.7,23.6-0.8,40.5,2.3c1.2,12,8.2,42,31.4,72.1c14.4,18.7,31.7,31.1,48.4,33.8c-14.4-13.7-33.3-29-48.6-47.3
c2.5,0.5,4.9,1.7,8.4,0.5l-23.2-11.5c0.4-1.4,0.7-2.8,1.1-4.2c114.6-5.8,221.8,26,328.4,65.5c-1.4,7.4-2.5,12.9-3.6,18.4l1.5,0.6 c-13.2-15.6-21.3-34.8-21-56.6c0.2-12.6,5.8-19.8,17.5-18.2c23.3,3.5,46.3,8.9,69.3,13.6c2.5,0.5,4.9,1.7,8.4,0.5L169.6,4.9
l7.1-14c16.3,2.2,18.3,6.4,14.1,20.7c-7.4,25.7-24.1,39.2-50,44.1c-41.3,7.9-82.2,17.2-123.5,25.3 c0.4-1.4,0.7-2.8,1.1-4.2c114.6-5.8,221.8,26,328.4,65.5c-1.4,7.4-2.5,12.9-3.6,18.4l1.5,0.6l7.1-14c16.3,2.2,18.3,6.4,14.1,20.7
C614.3,198.5,613.4,199.4,620,225.4z M481.1,94.6c-16.8-20-51.7-37.3-67.5-34.9c-2.3,22.4,34.4,68.2,57.8,71.7 c-7.4,25.7-24.1,39.2-50,44.1c-41.3,7.9-82.2,17.2-123.5,25.3C318.2,166.6,317.3,167.5,323.9,193.5z M185,62.7
c-2.7-4.4-5.3-8.4-7.8-12.6l6.4-3.5c-4.6-6-8.8-11.4-15.2-19.8l18.7,7.9l-6.6-13.7L481.1,94.6z M672,98.1l0.2-4.8l-90.4-17.4 c-16.8-20-51.7-37.3-67.5-34.9c-2.3,22.4,34.4,68.2,57.8,71.7c-2.7-4.4-5.3-8.4-7.8-12.6l6.4-3.5l-15.2-19.8l18.7,7.9l-6.6-13.7
l-1.3,4.5c14.2,7,27.8,16.7,42.8,20.2C639.4,104.2,656.2,103.4,672,98.1L672,98.1z M659.4,162.1l-1.6-4.3 L185,62.7z M375.9,66.2l0.2-4.8L285.7,44l-1.3,4.5c14.2,7,27.8,16.7,42.8,20.2C343.4,72.3,360.2,71.5,375.9,66.2L375.9,66.2z
c-20.4,8.3-41.2,15.8-61,25.3c-11.1,5.3-10.9,14-3,22.5C601.6,170.5,636.4,174.7,659.4,162.1L659.4,162.1z"/> M363.3,130.2l-1.6-4.3c-20.4,8.3-41.2,15.8-61,25.3c-11.1,5.3-10.9,14-3,22.5C305.5,138.6,340.3,142.8,363.3,130.2z"/>
<path class="st1" d="M399.5,264.6H459c1.9,0,3.8-0.5,5.4-1.4c3.3-1.9,5.3-5.4,5.3-9.3c0-1.9-0.5-3.7-1.4-5.3l-40-68.7 <path class="st1" d="M103.4,232.7h59.5c1.9,0,3.7-0.5,5.4-1.4c3.3-1.9,5.3-5.5,5.3-9.3c0-1.9-0.5-3.7-1.4-5.3l-40-68.7
c-0.9-1.6-2.3-2.9-3.9-3.8c-3.4-2-7.5-2-10.8,0c-1.6,0.9-3,2.3-3.9,3.8l-10.2,17.6l-20-34.4c-1-1.6-2.4-2.9-4-3.8 c-0.9-1.6-2.3-2.9-3.9-3.8c-3.3-2-7.5-2-10.8,0c-1.6,0.9-2.9,2.2-3.9,3.8l-10.2,17.6l-20-34.4c-1-1.6-2.4-2.9-4-3.8
c-3.3-2-7.5-2-10.7,0c-1.6,0.9-3,2.3-3.9,3.8L311,248.6c-0.9,1.6-1.5,3.5-1.5,5.3c0.1,3.8,2.1,7.3,5.4,9.3c1.6,0.9,3.5,1.4,5.4,1.4 c-3.3-2-7.4-2-10.7,0c-1.6,0.9-2.9,2.2-3.9,3.8l-49.9,85.5c-3,5-1.3,11.5,3.7,14.5c1.7,1,3.6,1.5,5.6,1.5h37.4
h37.4c14.7,0,25.7-6.4,33.3-19l18.2-31.4l9.8-16.7l29.3,50.4h-39.1L399.5,264.6z M357.1,247.8H331l39.1-67.1l19.5,33.6l-13.1,22.4 c14.7,0,25.7-6.4,33.3-19l18.2-31.4l9.8-16.7l29.3,50.4h-39.1L103.4,232.7z M61,215.9H34.9L74,148.8l19.5,33.6l-13.1,22.4
C371.6,244.9,365.9,247.8,357.1,247.8z"/> C75.5,213,69.8,215.9,61,215.9L61,215.9z"/>
<path class="st1" d="M672,98.1l0.2-4.8l-90.4-17.4l-1.3,4.5c14.2,7,27.8,16.7,42.8,20.2C639.4,104.2,656.2,103.4,672,98.1L672,98.1z <path class="st1" d="M375.9,66.2l0.2-4.8L285.7,44l-1.3,4.5c14.2,7,27.8,16.7,42.8,20.2C343.4,72.3,360.2,71.5,375.9,66.2
"/> L375.9,66.2z"/>
</svg> </svg>

Before

Width:  |  Height:  |  Size: 2.2 KiB

After

Width:  |  Height:  |  Size: 2.2 KiB

View File

@ -1,7 +1,7 @@
{ {
"name": "nuxt-mongoose", "name": "nuxt-mongoose",
"type": "module", "type": "module",
"version": "0.0.2", "version": "0.0.6",
"description": "Nuxt 3 module for MongoDB with Mongoose", "description": "Nuxt 3 module for MongoDB with Mongoose",
"license": "MIT", "license": "MIT",
"repository": { "repository": {
@ -37,37 +37,33 @@
"test": "vitest run", "test": "vitest run",
"test:watch": "vitest watch" "test:watch": "vitest watch"
}, },
"peerDependencies": {
"mongoose": "^7.0.3",
"nuxt": "^3.4.1"
},
"dependencies": { "dependencies": {
"@nuxt/devtools-kit": "^0.4.1", "@nuxt/devtools-kit": "^0.4.2",
"@nuxt/kit": "^3.4.1", "@nuxt/kit": "^3.4.2",
"@types/fs-extra": "^11.0.1", "@types/fs-extra": "^11.0.1",
"birpc": "^0.2.11", "birpc": "^0.2.11",
"defu": "^6.1.2", "defu": "^6.1.2",
"flatted": "^3.2.7", "flatted": "^3.2.7",
"fs-extra": "^11.1.1", "fs-extra": "^11.1.1",
"mongoose": "^7.0.5",
"pluralize": "^8.0.0", "pluralize": "^8.0.0",
"sirv": "^2.0.2", "sirv": "^2.0.3",
"tinyws": "^0.1.0", "tinyws": "^0.1.0",
"ws": "^8.13.0" "ws": "^8.13.0"
}, },
"devDependencies": { "devDependencies": {
"@antfu/eslint-config": "^0.38.4", "@antfu/eslint-config": "^0.38.5",
"@nuxt/devtools": "^0.4.1", "@nuxt/devtools": "^0.4.2",
"@nuxt/devtools-ui-kit": "^0.4.1", "@nuxt/devtools-ui-kit": "^0.4.2",
"@nuxt/module-builder": "^0.3.0", "@nuxt/module-builder": "^0.3.0",
"@nuxt/schema": "^3.4.1", "@nuxt/schema": "^3.4.2",
"@nuxt/test-utils": "^3.4.1", "@nuxt/test-utils": "^3.4.2",
"@types/pluralize": "^0.0.29", "@types/pluralize": "^0.0.29",
"@types/ws": "^8.5.4", "@types/ws": "^8.5.4",
"changelogen": "^0.5.3", "changelogen": "^0.5.3",
"eslint": "^8.38.0", "eslint": "^8.39.0",
"mongoose": "^7.0.4", "nuxt": "^3.4.2",
"nuxt": "^3.4.1", "sass": "^1.62.1",
"sass": "^1.62.0",
"sass-loader": "^13.2.2", "sass-loader": "^13.2.2",
"splitpanes": "^3.1.5", "splitpanes": "^3.1.5",
"vitest": "^0.30.1" "vitest": "^0.30.1"

1869
pnpm-lock.yaml generated

File diff suppressed because it is too large Load Diff

View File

@ -1,8 +0,0 @@
import type { mongo } from 'mongoose'
import { connection } from 'mongoose'
export function useMongoose(): { db: mongo.Db } {
return {
db: connection?.db,
}
}

View File

@ -1,4 +1,3 @@
import { logger } from '@nuxt/kit'
import mongoose from 'mongoose' import mongoose from 'mongoose'
import type { NuxtDevtoolsServerContext, ServerFunctions } from '../types' import type { NuxtDevtoolsServerContext, ServerFunctions } from '../types'
@ -10,26 +9,69 @@ export function setupDatabaseRPC({ options }: NuxtDevtoolsServerContext): any {
return mongoose.connection.readyState return mongoose.connection.readyState
}, },
async createCollection(name: string) { async createCollection(name: string) {
return await mongoose.connection.db.createCollection(name) try {
return await mongoose.connection.db.createCollection(name)
}
catch (error) {
return ErrorIT(error)
}
}, },
async listCollections() { async listCollections() {
return await mongoose.connection.db.listCollections().toArray() try {
return await mongoose.connection.db.listCollections().toArray()
}
catch (error) {
return ErrorIT(error)
}
}, },
async getCollection(name: string) { async getCollection(name: string) {
return mongoose.connection.db.collection(name) try {
return await mongoose.connection.db.collection(name).findOne()
}
catch (error) {
return ErrorIT(error)
}
}, },
async dropCollection(name: string) { async dropCollection(name: string) {
return await mongoose.connection.db.collection(name).drop() try {
return await mongoose.connection.db.dropCollection(name)
}
catch (error) {
return ErrorIT(error)
}
}, },
async createDocument(collection: string, data: any) { async createDocument(collection: string, data: any) {
return await mongoose.connection.db.collection(collection).insertOne(data) const { _id, ...rest } = data
try {
return await mongoose.connection.db.collection(collection).insertOne(rest)
}
catch (error: any) {
return ErrorIT(error)
}
}, },
async listDocuments(collection: string) { async countDocuments(collection: string) {
return await mongoose.connection.db.collection(collection).find().toArray() try {
return await mongoose.connection.db.collection(collection).countDocuments()
}
catch (error) {
return ErrorIT(error)
}
}, },
async getDocument(collection: string, document: {}) { async listDocuments(collection: string, options: { page: number; limit: number } = { page: 1, limit: 10 }) {
return await mongoose.connection.db.collection(collection).findOne({ document }) const skip = (options.page - 1) * options.limit
const cursor = mongoose.connection.db.collection(collection).find().skip(skip)
if (options.limit !== 0)
cursor.limit(options.limit)
return await cursor.toArray()
},
async getDocument(collection: string, document: any) {
try {
return await mongoose.connection.db.collection(collection).findOne({ document })
}
catch (error) {
return ErrorIT(error)
}
}, },
async updateDocument(collection: string, data: any) { async updateDocument(collection: string, data: any) {
const { _id, ...rest } = data const { _id, ...rest } = data
@ -37,12 +79,25 @@ export function setupDatabaseRPC({ options }: NuxtDevtoolsServerContext): any {
return await mongoose.connection.db.collection(collection).findOneAndUpdate({ _id: new mongoose.Types.ObjectId(_id) }, { $set: rest }) return await mongoose.connection.db.collection(collection).findOneAndUpdate({ _id: new mongoose.Types.ObjectId(_id) }, { $set: rest })
} }
catch (error) { catch (error) {
logger.log(error) return ErrorIT(error)
return error
} }
}, },
async deleteDocument(collection: string, id: string) { async deleteDocument(collection: string, id: string) {
return await mongoose.connection.db.collection(collection).deleteOne({ _id: new mongoose.Types.ObjectId(id) }) try {
return await mongoose.connection.db.collection(collection).deleteOne({ _id: new mongoose.Types.ObjectId(id) })
}
catch (error) {
return ErrorIT(error)
}
}, },
} satisfies Partial<ServerFunctions> } satisfies Partial<ServerFunctions>
} }
function ErrorIT(error: any) {
return {
error: {
message: error?.message,
code: error?.code,
},
}
}

View File

@ -1,11 +1,10 @@
import fs from 'fs-extra' import fs from 'fs-extra'
import { resolve } from 'pathe' import { resolve } from 'pathe'
import mongoose from 'mongoose'
import type { Collection, NuxtDevtoolsServerContext, Resource, ServerFunctions } from '../types' import type { Collection, NuxtDevtoolsServerContext, Resource, ServerFunctions } from '../types'
import { generateApiRoute, generateSchemaFile } from '../utils/schematics' import { generateApiRoute, generateSchemaFile } from '../utils/schematics'
import { capitalize, pluralize, singularize } from '../utils/formatting' import { capitalize, pluralize, singularize } from '../utils/formatting'
export function setupResourceRPC({ nuxt }: NuxtDevtoolsServerContext): any { export function setupResourceRPC({ nuxt, rpc }: NuxtDevtoolsServerContext): any {
return { return {
// TODO: maybe separate functions // TODO: maybe separate functions
async generateResource(collection: Collection, resources: Resource[]) { async generateResource(collection: Collection, resources: Resource[]) {
@ -26,9 +25,9 @@ export function setupResourceRPC({ nuxt }: NuxtDevtoolsServerContext): any {
const routeTypes = { const routeTypes = {
index: 'index.get.ts', index: 'index.get.ts',
create: 'create.post.ts', create: 'create.post.ts',
show: (by: string) => `${by}.get.ts`, show: (by: string) => `[${by}].get.ts`,
put: (by: string) => `${by}.put.ts`, put: (by: string) => `[${by}].put.ts`,
delete: (by: string) => `${by}.delete.ts`, delete: (by: string) => `[${by}].delete.ts`,
} }
resources.forEach((route: Resource) => { resources.forEach((route: Resource) => {
const fileName = typeof routeTypes[route.type] === 'function' const fileName = typeof routeTypes[route.type] === 'function'
@ -45,8 +44,9 @@ export function setupResourceRPC({ nuxt }: NuxtDevtoolsServerContext): any {
} }
// create collection if not exists // create collection if not exists
if (!mongoose.connection.modelNames().includes(dbName)) const collections = await rpc.functions.listCollections()
await mongoose.connection.db.createCollection(plural) if (!collections.find((c: any) => c.name === plural))
await rpc.functions.createCollection(plural)
}, },
async resourceSchema(collection: string) { async resourceSchema(collection: string) {
// TODO: use magicast // TODO: use magicast

View File

@ -8,7 +8,8 @@ export interface ServerFunctions {
// Database - documents // Database - documents
createDocument(collection: string, data: any): Promise<any> createDocument(collection: string, data: any): Promise<any>
listDocuments(collection: string): Promise<any> countDocuments(collection: string): Promise<any>
listDocuments(collection: string, options: any): Promise<any>
getDocument(collection: string, id: string): Promise<any> getDocument(collection: string, id: string): Promise<any>
updateDocument(collection: string, data: any): Promise<any> updateDocument(collection: string, data: any): Promise<any>
deleteDocument(collection: string, id: string): Promise<any> deleteDocument(collection: string, id: string): Promise<any>