chore: wip

Author: glennmichael123

pkgx.yaml

@@ -20,3 +20,4 @@ dependencies:
   rust-lang.org: ^1.74.1
   sqlite.org: ^3.42.0
   stedolan.github.io/jq: ^1.7 # can be removed when publishing works without npm
+  redis.io: ^7.2.5

storage/framework/core/cache/tests/Redis.test.ts

@@ -1,70 +1,66 @@
-import { beforeEach, describe, expect, it } from 'bun:test'
+import { afterAll, beforeAll, beforeEach, describe, expect, it } from 'bun:test'
 import { redis } from '../src/drivers/redis'
+import { startRedisServer, stopRedisServer } from './scripts/redis-server'
+
+beforeAll(async () => {
+  await startRedisServer()
+})
 
 beforeEach(async () => {
   await redis.clear()
 })
 
+afterAll(() => {
+  stopRedisServer()
+})
+
 describe('@stacksjs/cache - Redis', () => {
   it('should set and get a redis cache value', async () => {
     await redis.set('key1', 'value1')
     expect(await redis.get('key1')).toBe('value1')
   })
-
   it('should set a redis cache value with no TTL and get it', async () => {
     await redis.setForever('key2', 'value2')
     expect(await redis.get('key2')).toBe('value2')
   })
-
   it('should get or set a redis cache value if not set', async () => {
     expect(await redis.get('key3')).toBeUndefined()
-
     await redis.getOrSet('key3', 'value3')
     expect(await redis.get('key3')).toBe('value3')
   })
-
   it('should delete a redis cache value', async () => {
     await redis.set('key4', 'value4')
     await redis.del('key4')
     expect(await redis.get('key4')).toBeUndefined()
   })
-
   it('should delete multiple redis cache values', async () => {
     await redis.set('key5', 'value5')
     await redis.set('key6', 'value6')
     await redis.deleteMany(['key5', 'key6'])
-
     expect(await redis.get('key5')).toBeUndefined()
     expect(await redis.get('key6')).toBeUndefined()
   })
-
   it('should check if a key exists in redis cache', async () => {
     await redis.set('key7', 'value7')
     expect(await redis.has('key7')).toBe(true)
   })
-
   it('should return false if a key is missing in redis cache', async () => {
     expect(await redis.missing('nonExistentKey')).toBe(true)
     await redis.set('key8', 'value8')
     expect(await redis.missing('key8')).toBe(false)
   })
-
   it('should clear all redis cache values', async () => {
     await redis.set('key9', 'value9')
     await redis.set('key10', 'value10')
     await redis.clear()
-
     expect(await redis.get('key9')).toBeUndefined()
     expect(await redis.get('key10')).toBeUndefined()
   })
-
   it('should remove a specific redis cache value', async () => {
     await redis.set('key11', 'value11')
     await redis.remove('key11')
-
     expect(await redis.get('key11')).toBeUndefined()
   })
-
   it('should disconnect from redis', async () => {
     await redis.set('key12', 'value12')
     await redis.disconnect()

storage/framework/core/cache/tests/scripts/redis-server.ts

@@ -0,0 +1,46 @@
+import { spawn } from 'node:child_process'
+
+// Define the redisProcess variable to hold the Redis process
+let redisProcess: any | null = null
+
+// Function to start the Redis server using Node's spawn
+export async function startRedisServer(): Promise<void> {
+  return new Promise((resolve, reject) => {
+    redisProcess = spawn('redis-server', {
+      stdio: 'pipe',
+    })
+
+    redisProcess.stdout.on('data', (data) => {
+      console.log(`Redis server output: ${data}`)
+      // Optionally resolve if you detect the server is ready
+      if (data.toString().includes('Ready to accept connections')) {
+        resolve()
+      }
+    })
+
+    redisProcess.stderr.on('data', (data) => {
+      console.error(`Redis server error: ${data}`)
+      reject(new Error(`Redis server error: ${data}`))
+    })
+
+    redisProcess.on('exit', (code) => {
+      console.log(`Redis server process exited with code ${code}`)
+      if (code !== 0) {
+        reject(new Error(`Redis server exited with code ${code}`))
+      }
+    })
+
+    console.log('Starting Redis server...')
+  })
+}
+
+// Function to stop Redis by killing the process
+export function stopRedisServer(): void {
+  if (redisProcess) {
+    redisProcess.kill() // Kills the Redis process
+    console.log('Redis server process killed.')
+    redisProcess = null // Reset the process variable
+  } else {
+    console.log('Redis server is not running.')
+  }
+}