wip: initial functionality

Author: syntaxsdev

cmd/mercury/main.go

@@ -0,0 +1,11 @@
+package main
+
+import (
+	"fmt"
+	// "log"
+	// "net/http"
+)
+
+func main() {
+	fmt.Println("Starting Mercury Core...")
+}

go.mod

@@ -0,0 +1,10 @@
+module github.com/syntaxsdev/mercury
+
+go 1.22.7
+
+require (
+	github.com/cespare/xxhash/v2 v2.2.0 // indirect
+	github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f // indirect
+	github.com/go-chi/chi/v5 v5.2.0 // indirect
+	github.com/redis/go-redis/v9 v9.7.0 // indirect
+)

go.sum

@@ -0,0 +1,8 @@
+github.com/cespare/xxhash/v2 v2.2.0 h1:DC2CZ1Ep5Y4k3ZQ899DldepgrayRUGE6BBZ/cd9Cj44=
+github.com/cespare/xxhash/v2 v2.2.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
+github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f h1:lO4WD4F/rVNCu3HqELle0jiPLLBs70cWOduZpkS1E78=
+github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f/go.mod h1:cuUVRXasLTGF7a8hSLbxyZXjz+1KgoB3wDUb6vlszIc=
+github.com/go-chi/chi/v5 v5.2.0 h1:Aj1EtB0qR2Rdo2dG4O94RIU35w2lvQSj6BRA4+qwFL0=
+github.com/go-chi/chi/v5 v5.2.0/go.mod h1:DslCQbL2OYiznFReuXYUmQ2hGd1aDpCnlMNITLSKoi8=
+github.com/redis/go-redis/v9 v9.7.0 h1:HhLSs+B6O021gwzl+locl0zEDnyNkxMtf/Z3NNBMa9E=
+github.com/redis/go-redis/v9 v9.7.0/go.mod h1:f6zhXITC7JUJIlPEiBOTXxJgPLdZcA93GewI7inzyWw=

internal/repositories/redis.go

@@ -0,0 +1,19 @@
+package repositories
+
+import (
+	"github.com/redis/go-redis/v9"
+)
+
+type RedisClient struct {
+	Client *redis.Client
+}
+
+func NewRedisClient(addr, password string) *RedisClient {
+	return &RedisClient{
+		Client: redis.NewClient(&redis.Options{
+			Addr:     addr,
+			Password: password,
+			DB:       0,
+		}),
+	}
+}

internal/services/redis.go

@@ -0,0 +1,31 @@
+package services
+
+import (
+	"context"
+
+	"github.com/syntaxsdev/mercury/internal/repositories"
+)
+
+type RedisService struct {
+	Repo *repositories.RedisClient
+}
+
+func (s *RedisService) Set(ctx context.Context, key string, value interface{}) error {
+	return s.Repo.Client.Set(ctx, key, value, 0).Err()
+}
+
+func (s *RedisService) Get(ctx context.Context, key string) (string, error) {
+	return s.Repo.Client.Get(ctx, key).Result()
+}
+
+func (s *RedisService) Add(ctx context.Context, key string, value interface{}) error {
+	return s.Repo.Client.RPush(ctx, key, value, 0).Err()
+}
+
+func (s *RedisService) GetList(ctx context.Context, key string) ([]string, error) {
+	return s.Repo.Client.LRange(ctx, key, 0, -1).Result()
+}
+
+func (s *RedisService) Pop(ctx context.Context, key string) (string, error) {
+	return s.Repo.Client.RPop(ctx, key).Result()
+}