williamp/chatservice_concept
1
0
Fork 0
Code Issues 1 Pull Requests Actions Packages Projects Releases Wiki Activity

change fake db package name to make way for db being split out

Browse Source
This commit is contained in:
William P
2025-04-07 16:38:32 -04:00
parent 3ac7e488af
commit a578beea0d
2 changed files with 15 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
api/db.go
View File

@@ -5,11 +5,11 @@ import (
"fmt" "fmt"
"time" "time"
"git.dubyatp.xyz/chat-api-server/db" "git.dubyatp.xyz/chat-api-server/fake_db"
) )
func dbGetUser(id string) (*User, error) { func dbGetUser(id string) (*User, error) {
data := db.ExecDB("users") data := fake_db.ExecDB("users")
if data == nil { if data == nil {
return nil, errors.New("failed to load users database") return nil, errors.New("failed to load users database")
} }
@@ -29,7 +29,7 @@ func dbGetUser(id string) (*User, error) {
} }
func dbGetUserByName(username string) (*User, error) { func dbGetUserByName(username string) (*User, error) {
data := db.ExecDB("users") data := fake_db.ExecDB("users")
if data == nil { if data == nil {
return nil, errors.New("failed to load users database") return nil, errors.New("failed to load users database")
} }
@@ -49,7 +49,7 @@ func dbGetUserByName(username string) (*User, error) {
} }
func dbGetAllUsers() ([]*User, error) { func dbGetAllUsers() ([]*User, error) {
data := db.ExecDB("users") data := fake_db.ExecDB("users")
if data == nil { if data == nil {
return nil, errors.New("failed to load users database") return nil, errors.New("failed to load users database")
} }
@@ -70,7 +70,7 @@ func dbGetAllUsers() ([]*User, error) {
} }
func dbGetMessage(id string) (*Message, error) { func dbGetMessage(id string) (*Message, error) {
data := db.ExecDB("messages") data := fake_db.ExecDB("messages")
if data == nil { if data == nil {
return nil, errors.New("failed to load messages database") return nil, errors.New("failed to load messages database")
} }
@@ -105,7 +105,7 @@ func dbGetMessage(id string) (*Message, error) {
} }
func dbGetAllMessages() ([]*Message, error) { func dbGetAllMessages() ([]*Message, error) {
data := db.ExecDB("messages") data := fake_db.ExecDB("messages")
//println(data) //println(data)
if data == nil { if data == nil {
return nil, errors.New("failed to load messages database") return nil, errors.New("failed to load messages database")
@@ -143,7 +143,7 @@ func dbGetAllMessages() ([]*Message, error) {
} }
func dbAddUser(user *User) error { func dbAddUser(user *User) error {
currentData := db.ExecDB("users") currentData := fake_db.ExecDB("users")
if currentData == nil { if currentData == nil {
return fmt.Errorf("error reading users database") return fmt.Errorf("error reading users database")
} }
@@ -160,11 +160,11 @@ func dbAddUser(user *User) error {
} }
users = append(users, dbUser) users = append(users, dbUser)
return db.WriteDB("users", users) return fake_db.WriteDB("users", users)
} }
func dbAddMessage(message *Message) error { func dbAddMessage(message *Message) error {
currentData := db.ExecDB("messages") currentData := fake_db.ExecDB("messages")
if currentData == nil { if currentData == nil {
return fmt.Errorf("error reading messages database") return fmt.Errorf("error reading messages database")
} }
@@ -190,11 +190,11 @@ func dbAddMessage(message *Message) error {
} }
messages = append(messages, dbMessage) messages = append(messages, dbMessage)
return db.WriteDB("messages", messages) return fake_db.WriteDB("messages", messages)
} }
func dbUpdateMessage(updatedMessage *Message) error { func dbUpdateMessage(updatedMessage *Message) error {
currentData := db.ExecDB("messages") currentData := fake_db.ExecDB("messages")
if currentData == nil { if currentData == nil {
return fmt.Errorf("error reading messages database") return fmt.Errorf("error reading messages database")
} }
@@ -238,11 +238,11 @@ func dbUpdateMessage(updatedMessage *Message) error {
return fmt.Errorf("message with ID %s not found", updatedMessage.ID) return fmt.Errorf("message with ID %s not found", updatedMessage.ID)
} }
return db.WriteDB("messages", updatedMessages) return fake_db.WriteDB("messages", updatedMessages)
} }
func dbDeleteMessage(id string) error { func dbDeleteMessage(id string) error {
currentData := db.ExecDB("messages") currentData := fake_db.ExecDB("messages")
if currentData == nil { if currentData == nil {
return fmt.Errorf("error reading messages database") return fmt.Errorf("error reading messages database")
} }
@@ -273,5 +273,5 @@ func dbDeleteMessage(id string) error {
return fmt.Errorf("message with ID %s not found", id) return fmt.Errorf("message with ID %s not found", id)
} }
return db.WriteDB("messages", updatedMessages) return fake_db.WriteDB("messages", updatedMessages)
} }

2
db/fake_db.go → fake_db/fake_db.go
View File

@@ -1,4 +1,4 @@
package db package fake_db
import ( import (
"encoding/json" "encoding/json"