feat: jsr migration

.github/workflows/publish.yml

@@ -0,0 +1,22 @@
+name: Publish
+on:
+  workflow_dispatch:
+
+jobs:
+  publish:
+    runs-on: ubuntu-latest
+
+    permissions:
+      contents: read
+      id-token: write
+
+    steps:
+      - uses: actions/checkout@v4
+
+      - name: Setup Deno
+        uses: denoland/setup-deno@v1
+        with:
+          deno-version: canary
+
+      - name: Publish package
+        run: deno publish --allow-slow-types

deno.json

@@ -1,4 +1,21 @@
 {
+  "name": "@danet/database",
+  "version": "0.0.1",
+  "exports": {
+    "./mongodb/module.ts": "./mongodb/module.ts",
+    "./mongodb/repository.ts": "./mongodb/repository.ts",
+    "./mongodb/service.ts": "./mongodb/service.ts",
+    "./repository.ts": "./repository.ts",
+    "./kv/module.ts": "./kv/module.ts",
+    "./kv/repository.ts": "./kv/repository.ts",
+    "./kv/service.ts": "./kv/service.ts",
+    "./import_map.json": "./import_map.json",
+    "./deno.json": "./deno.json"
+  },
+  "compilerOptions": {
+    "emitDecoratorMetadata": true,
+    "experimentalDecorators": true
+  },
   "lock": false,
   "importMap": "./import_map.json"
 }

import_map.json

@@ -1,5 +1,6 @@
 {
   "imports": {
-    "danet/": "https://deno.land/x/danet/"
+    "@danet/core": "jsr:@danet/core@2",
+    "@db/mongo": "jsr:@db/mongo"
   }
 }

kv/module.ts

@@ -1,4 +1,4 @@
-import { Module } from 'danet/mod.ts';
+import { Module } from '@danet/core';
 import { KvService } from "./service.ts";
 
 @Module({

kv/repository.ts

@@ -1,6 +1,6 @@
 
-import { KvService } from "./service.ts";
-import { Repository } from "../repository.ts";
+import type { KvService } from "./service.ts";
+import type { Repository } from "../repository.ts";
 
 export abstract class KvRepository<T extends { _id: string }>
   implements Repository<T> {
@@ -19,7 +19,7 @@ export abstract class KvRepository<T extends { _id: string }>
     return items;
   }
 
-  async getById(id: string) {
+  async getById(id: string): Promise<T|undefined> {
     if (!id) {
       return undefined;
     }
@@ -60,7 +60,7 @@ export abstract class KvRepository<T extends { _id: string }>
     await transaction
       .commit();
   }
-  async updateOne(itemId: string, item: T) {
+  async updateOne(itemId: string, item: T): Promise<T> {
     const itemInDb = await this.kv.client().get([this.collectionName, itemId]);
     const itemToInsert = {
       ...itemInDb,
@@ -76,7 +76,7 @@ export abstract class KvRepository<T extends { _id: string }>
     if (!transactionResult.ok) {
       throw new Error("Could update entity");
     }
-    return item;
+    return itemToInsert;
   }
 
   async deleteAll() {

kv/service.ts

@@ -1,5 +1,5 @@
-import { Injectable } from 'danet/mod.ts';
-import { OnAppBootstrap, OnAppClose } from 'danet/src/hook/interfaces.ts';
+import { Injectable } from '@danet/core';
+import type { OnAppBootstrap, OnAppClose } from '@danet/core/hook';
 
 @Injectable()
 export class KvService implements OnAppBootstrap, OnAppClose {
@@ -11,7 +11,7 @@ export class KvService implements OnAppBootstrap, OnAppClose {
     this.kvClient = await Deno.openKv();
   }
 
-  client() {
+  client(): Deno.Kv {
     return this.kvClient;
   }
 

mongodb/module.ts

@@ -1,4 +1,4 @@
-import { Module } from 'danet/mod.ts';
+import { Module } from '@danet/core';
 import { MongodbService } from './service.ts';
 
 @Module({

mongodb/repository.ts

@@ -1,12 +1,9 @@
-import { Repository } from '../repository.ts';
-import { Filter, ObjectId } from 'mongo/mod.ts';
-import { MongodbService } from './service.ts';
+import type { Repository } from '../repository.ts';
+import { type Filter, ObjectId, type Document, type Collection } from '@db/mongo';
+import type { MongodbService } from './service.ts';
 
-interface Document {
-  _id: string | ObjectId;
-}
 
-export abstract class MongodbRepository<T extends Document>
+export abstract class MongodbRepository<T extends Document & { _id: string | ObjectId}>
   implements Repository<T> {
   constructor(
     protected dbService: MongodbService,
@@ -20,7 +17,7 @@ export abstract class MongodbRepository<T extends Document>
       .toArray()).map((obj) => ({ ...obj, _id: obj._id.toString() }));
   }
 
-  async getOne(filter: Filter<T>) {
+  async getOne(filter: Filter<T>): Promise<T> {
     const obj = await this.dbService.getCollection<T>(this.collectionName)
       .findOne(filter);
     if (!obj) return undefined;
@@ -30,7 +27,7 @@ export abstract class MongodbRepository<T extends Document>
     };
   }
 
-  async getById(id: string) {
+  async getById(id: string): Promise<T> {
     const obj = await this.dbService.getCollection<T>(this.collectionName)
       .findOne({
         _id: new ObjectId(id),
@@ -42,15 +39,15 @@ export abstract class MongodbRepository<T extends Document>
     };
   }
 
-  async create(obj: T) {
+  async create(obj: T): Promise<T> {
     obj._id = new ObjectId();
     await this.dbService.getCollection<T>(
       this.collectionName,
     ).insertOne(obj);
     return obj;
   }
 
-  async updateOne(objId: string, obj: Partial<T>) {
+  async updateOne(objId: string, obj: Partial<T>): Promise<ReturnType<Collection<T>["updateOne"]>> {
     const _id = new ObjectId(objId);
     const updated = await this.dbService.getCollection<T>(this.collectionName)
       .updateOne(
@@ -62,13 +59,13 @@ export abstract class MongodbRepository<T extends Document>
     return updated;
   }
 
-  async deleteOne(objId: string) {
+  deleteOne(objId: string): Promise<number> {
     return this.dbService.getCollection<T>(this.collectionName).deleteOne({
       _id: new ObjectId(objId),
     });
   }
 
-  async deleteAll() {
+  deleteAll(): Promise<number> {
     return this.dbService.getCollection<T>(this.collectionName).deleteMany({});
   }
 }

mongodb/service.ts

@@ -1,6 +1,6 @@
-import { Injectable } from 'danet/mod.ts';
-import { OnAppBootstrap, OnAppClose } from 'danet/src/hook/interfaces.ts';
-import { Collection, Database, Document, MongoClient } from 'mongo/mod.ts';
+import { Injectable } from '@danet/core';
+import type { OnAppBootstrap, OnAppClose } from '@danet/core/hook';
+import { type Collection, type Database, type Document, MongoClient } from '@db/mongo';
 
 @Injectable()
 export class MongodbService implements OnAppBootstrap, OnAppClose {