neko/internal/session/database/object/adapter.go

package object

import (
	"fmt"
	"sync"

	"demodesk/neko/internal/types"
)

func New() types.MembersDatabase {
	return &MembersDatabaseCtx{
		profiles: make(map[string]types.MemberProfile),
		mu:       sync.Mutex{},
	}
}

type MembersDatabaseCtx struct {
	profiles map[string]types.MemberProfile
	mu       sync.Mutex
}

func (manager *MembersDatabaseCtx) Connect() error {
	return nil
}

func (manager *MembersDatabaseCtx) Disconnect() error {
	return nil
}

func (manager *MembersDatabaseCtx) Insert(id string, profile types.MemberProfile) error {
	manager.mu.Lock()
	defer manager.mu.Unlock()

	_, ok := manager.profiles[id]
	if ok {
		return fmt.Errorf("Member ID already exists.")
	}

	manager.profiles[id] = profile
	return nil
}

func (manager *MembersDatabaseCtx) Update(id string, profile types.MemberProfile) error {
	manager.mu.Lock()
	defer manager.mu.Unlock()

	_, ok := manager.profiles[id]
	if !ok {
		return fmt.Errorf("Member ID does not exist.")
	}

	manager.profiles[id] = profile
	return nil
}

func (manager *MembersDatabaseCtx) Delete(id string) error {
	manager.mu.Lock()
	defer manager.mu.Unlock()

	_, ok := manager.profiles[id]
	if !ok {
		return fmt.Errorf("Member ID does not exist.")
	}

	delete(manager.profiles, id)
	return nil
}

func (manager *MembersDatabaseCtx) Select() (map[string]types.MemberProfile, error) {
	manager.mu.Lock()
	defer manager.mu.Unlock()

	return manager.profiles, nil
}