added redis provider and queueService

Author: Rykuno

README.md

@@ -6,7 +6,7 @@ If you forked this repository before May 27th, you'll want to view commit `653e2
 
 ## ❔ What
 
-A scalable, testable, extensible, template for Sveltekit. 
+A scalable, testable, extensible, template for Sveltekit.
 
 Sveltekit is awesome, but sometimes you need a bit more capability in the backend than what frameworks like
 NextJS & Sveltekit can deliver.
@@ -25,25 +25,35 @@ export const DELETE: RequestHandler = ({ request }) => app.fetch(request);
 export const POST: RequestHandler = ({ request }) => app.fetch(request);
 ```
 
+## Local Setup
+
+1. Make sure Docker is running
+2. Copy the `.env.example` file and rename to `.env`
+3. `pnpm install`
+4. `pnpm initialize`(this will start the docker-compose and run the initial database migration.)
+5. `pnpm dev`
+
+No additional setup is required, zero api keys, zero services to signup for, zero cost.
+
 ## How to Use
 
-This is **not** supposed to serve as an all batteries included ["production boilerplate"](https://github.com/ixartz/Next-js-Boilerplate) with 200 useless sponsored features that get in your way. Templates that do this are ANYTHING but "production" and "quick start". 
+This is **not** supposed to serve as an all batteries included ["production boilerplate"](https://github.com/ixartz/Next-js-Boilerplate) with 200 useless sponsored features that get in your way. Templates that do this are ANYTHING but "production" and "quick start".
 
 This is stack is designed to be library agnostic. The philosophy here is to boostrap the concrete, repetitive, and time consuming tasks that every application will need reguardless of what you're building.
 
-**So - fork this repo, add your favorite libraries, and build out your own "more opinionated" personal template tailored to you**! 
+**So - fork this repo, add your favorite libraries, and build out your own "more opinionated" personal template tailored to you**!
 
 ## Features
 
 - 🟢 Full E2E typesafety
 - 🟢 RPC Client for API Requests
 - 🟢 Custom Fetch Wrapper
-- 🔴 Deployment Template
+- 🟢 Deployment Template
 - 🟠 Authentication
   - 🟢 Email/Passkey
   - 🔴 OAuth
   - 🟢 Email Update/Verifiaction
-  - 🔴 Rate limiter 
+  - 🟢 Rate limiter
 
 ## Technologies
 

package.json

@@ -36,6 +36,7 @@
 		"@typescript-eslint/parser": "^7.13.1",
 		"arctic": "^1.9.1",
 		"autoprefixer": "^10.4.19",
+		"bullmq": "^5.8.3",
 		"dayjs": "^1.11.11",
 		"dotenv-cli": "^7.4.2",
 		"drizzle-kit": "^0.21.4",

pnpm-lock.yaml

@@ -19,6 +19,6 @@ ensure that the correct data is being passed around.
 /* -------------------------------------------------------------------------- */
 
 export const updateEmailDto = z.object({
-	email: z.string()
+	email: z.string().email()
 });
 export type UpdateEmailDto = z.infer<typeof updateEmailDto>;

src/lib/dtos/update-email.dto.ts

@@ -1,2 +1,3 @@
 export * from './database.provider';
 export * from './lucia.provider';
+export * from './redis.provider';

src/lib/server/api/providers/index.ts

@@ -0,0 +1,14 @@
+import { container } from 'tsyringe';
+import RedisClient from 'ioredis'
+import { config } from '../common/config';
+
+// Symbol
+export const RedisProvider = Symbol('REDIS_TOKEN');
+
+// Type
+export type RedisProvider = RedisClient;
+
+// Register
+container.register<RedisProvider>(RedisProvider, {
+  useValue: new RedisClient(config.REDIS_URL)
+});

src/lib/server/api/providers/redis.provider.ts

@@ -0,0 +1,19 @@
+import { injectable } from "tsyringe";
+import RedisClient from 'ioredis'
+import { config } from "../common/config";
+import { Queue, Worker, type Processor } from 'bullmq';
+
+@injectable()
+export class QueuesServices {
+  connection = new RedisClient(config.REDIS_URL);
+
+  constructor() { }
+
+  createQueue(name: string) {
+    return new Queue(name, { connection: this.connection })
+  }
+
+  createWorker(name: string, prcoessor: Processor) {
+    return new Worker(name, prcoessor, { connection: this.connection })
+  }
+}

src/lib/server/api/services/queues.service.ts

@@ -3,24 +3,6 @@ import { generateRandomString } from "oslo/crypto";
 import { TimeSpan, createDate, type TimeSpanUnit } from 'oslo';
 import { HashingService } from './hashing.service';
 
-/* -------------------------------------------------------------------------- */
-/*                                   Service                                  */
-/* -------------------------------------------------------------------------- */
-/* -------------------------------------------------------------------------- */
-/* ---------------------------------- About --------------------------------- */
-/*
-Services are responsible for handling business logic and data manipulation. 
-They genreally call on repositories or other services to complete a use-case.
-*/
-/* ---------------------------------- Notes --------------------------------- */
-/*
-Services should be kept as clean and simple as possible. 
-
-Create private functions to handle complex logic and keep the public methods as 
-simple as possible. This makes the service easier to read, test and understand.
-*/
-/* -------------------------------------------------------------------------- */
-
 @injectable()
 export class TokensService {
 	constructor(@inject(HashingService) private readonly hashingService: HashingService) { }

src/lib/server/api/services/tokens.service.ts

@@ -1,6 +1,6 @@
 import 'reflect-metadata';
 import { LoginRequestsService } from '../services/login-requests.service';
-import { afterAll, afterEach, beforeAll, describe, expect, it, vi } from 'vitest';
+import { afterAll, beforeAll, describe, expect, it, vi } from 'vitest';
 import { TokensService } from '../services/tokens.service';
 import { MailerService } from '../services/mailer.service';
 import { UsersRepository } from '../repositories/users.repository';