feat: data structure and core (#27)

TODO.md

@@ -0,0 +1,26 @@
+### Todo
+- [ ] Get Sets Name
+- [ ] Drop Set
+- [ ] Clean Set
+- [ ] Get Elements of a set
+- [ ] Count elements of a set
+- [ ] Remove Element from a set
+- [ ] Update Element from a set
+- [ ] Get All Keys
+- [ ] Get All Values
+- [ ] Create Snapshot
+- [ ] Create schedule Snapshot
+- [ ] End Snapshot
+- [ ] Find List of Elements from a set
+- [ ] Sort With Limit And Offset
+- [ ] regex search
+- [ ] Update list of elements from a set
+- [ ] Remove list of elements from a set
+- [ ] handles foreach operation on a set
+- [ ] HAVE QUERY => T/F
+
+
+### In Progress
+
+
+### ✓ Done

cmd/main.go

@@ -3,11 +3,11 @@ package main
 import (
 	"os"
 
-	"github.com/zurvan-lab/TimeTraceDB/src"
+	"github.com/zurvan-lab/TimeTraceDB/core/database"
 )
 
 func main() {
-	database := src.CreateDataBase(os.Args[1])
+	database := database.CreateDataBase(os.Args[0])
 	database.InitSocket()
 	database.InitUsers()
 }

src/config.go → config/config.go

@@ -1,4 +1,4 @@
-package src
+package config
 
 import (
 	"os"
@@ -40,7 +40,11 @@ func createConfig() *Config {
 	return &Config{}
 }
 
-func ReadConfigFile(path string) *Config {
+func (c Config) BasicCheck() error {
+	return nil
+}
+
+func LoadFromFile(path string) *Config {
 	file, err := os.Open(path)
 	if err != nil {
 		log.Error("Can not open the config file", "error: ", err)

src/database.go → core/database/database.go

@@ -1,21 +1,24 @@
-package src
+package database
 
 import (
 	"net"
 	"os"
+
+	"github.com/zurvan-lab/TimeTraceDB/config"
+	"github.com/zurvan-lab/TimeTraceDB/core"
 )
 
 type Database struct {
 	Sets   Sets
-	Config Config
+	Config config.Config
 	socket net.Listener
-	Users  Users
+	Users  core.Users
 }
 
 func CreateDataBase(path string) *Database {
 	return &Database{
 		Sets:   *NewSets(),
-		Config: *ReadConfigFile(path),
+		Config: *config.LoadFromFile(path),
 	}
 }
 
@@ -28,7 +31,7 @@ func (db *Database) InitSocket() {
 }
 
 func (db *Database) InitUsers() {
-	users := CreateUsers()
+	users := core.CreateUsers()
 	db.Users = *users
 	cmds := []string{"all"}
 	users.NewUser(db.Config.FirstUser.Name, db.Config.FirstUser.Token, cmds)

core/database/element.go

@@ -0,0 +1,12 @@
+package database
+
+import "time"
+
+type Element struct {
+	value string
+	time  time.Time
+}
+
+func NewElement(v string) Element {
+	return Element{value: v, time: time.Now()}
+}

core/database/set.go

@@ -0,0 +1,21 @@
+package database
+
+type set map[string]SubSet
+
+type Sets map[string]set
+
+func NewSets() *Sets {
+	return &Sets{}
+}
+
+func newSet() *set {
+	return &set{}
+}
+
+func (s *Sets) AddSet(name string) {
+	(*s)[name] = *newSet()
+}
+
+func (s set) AddSubSet(name string) {
+	(s)[name] = *NewSubSet()
+}

core/database/subSets.go

@@ -0,0 +1,17 @@
+package database
+
+type SubSets map[string]SubSet
+type SubSet []Element
+
+func NewSubSets() SubSets {
+	return SubSets{}
+}
+
+func NewSubSet() *SubSet {
+	return &SubSet{}
+}
+
+func (db *Database) PushElement(s string, sb string, e Element) {
+	r := db.Sets[s][sb]
+	db.Sets[s][sb] = append(r, e)
+}

core/execution.go

@@ -0,0 +1 @@
+package core

src/user.go → core/user.go

@@ -1,4 +1,4 @@
-package src
+package core
 
 import (
 	"github.com/zurvan-lab/TimeTraceDB/utils"

log/logger.go

@@ -23,6 +23,8 @@ func addFields(event *zerolog.Event, keyvals ...interface{}) *zerolog.Event {
 			event.Stringer(key, v)
 		case []byte:
 			event.Str(key, fmt.Sprintf("%v", hex.EncodeToString(v)))
+		case error:
+			event.AnErr(key, v)
 		default:
 			event.Any(key, v)
 		}

utils/random.go

@@ -13,3 +13,11 @@ func GenerateRandomNumber(min, max int) (int, error) {
 
 	return int(n.Int64()) + min, nil
 }
+
+func BytesToString(data []byte) string {
+	return string(data)
+}
+
+func StringToBytes(s string) []byte {
+	return []byte(s)
+}