From 4cb1b6d76a105f9967101c6d5cab233b3e5d0b08 Mon Sep 17 00:00:00 2001 From: edipretoro Date: Thu, 23 Jul 2026 21:34:32 +0200 Subject: [PATCH] Adding the challenge 0104 --- 0104/kv.go | 66 ++++++++++++++++++++++++++++++++++++++++++ 0104/kv_entry.go | 51 ++++++++++++++++++++++++++++++++ 0104/kv_test.go | 75 ++++++++++++++++++++++++++++++++++++++++++++++++ 0104/log.go | 35 ++++++++++++++++++++++ 0104/os_other.go | 11 +++++++ 0104/os_unix.go | 34 ++++++++++++++++++++++ 6 files changed, 272 insertions(+) create mode 100644 0104/kv.go create mode 100644 0104/kv_entry.go create mode 100644 0104/kv_test.go create mode 100644 0104/log.go create mode 100644 0104/os_other.go create mode 100644 0104/os_unix.go diff --git a/0104/kv.go b/0104/kv.go new file mode 100644 index 0000000..57d7032 --- /dev/null +++ b/0104/kv.go @@ -0,0 +1,66 @@ +package db0104 + +import ( + "bytes" +) + +type KV struct { + log Log + mem map[string][]byte +} + +func (kv *KV) Open() error { + if err := kv.log.Open(); err != nil { + return err + } + + kv.mem = map[string][]byte{} + for { + ent := Entry{} + eof, err := kv.log.Read(&ent) + if err != nil { + return err + } else if eof { + break + } + + if ent.deleted { + delete(kv.mem, string(ent.key)) + } else { + kv.mem[string(ent.key)] = ent.val + } + } + return nil +} + +func (kv *KV) Close() error { return kv.log.Close() } + +func (kv *KV) Get(key []byte) (val []byte, ok bool, err error) { + val, ok = kv.mem[string(key)] + return +} + +func (kv *KV) Set(key []byte, val []byte) (updated bool, err error) { + prev, exist := kv.mem[string(key)] + updated = !exist || !bytes.Equal(prev, val) + if updated { + if err = kv.log.Write(&Entry{key: key, val: val}); err != nil { + return false, err + } + kv.mem[string(key)] = val + } + return +} + +func (kv *KV) Del(key []byte) (deleted bool, err error) { + _, deleted = kv.mem[string(key)] + if deleted { + if err = kv.log.Write(&Entry{key: key, deleted: true}); err != nil { + return false, err + } + delete(kv.mem, string(key)) + } + return +} + +// QzBQWVJJOUhU https://trialofcode.org/ diff --git a/0104/kv_entry.go b/0104/kv_entry.go new file mode 100644 index 0000000..e2687ed --- /dev/null +++ b/0104/kv_entry.go @@ -0,0 +1,51 @@ +package db0104 + +import ( + "encoding/binary" + "io" +) + +type Entry struct { + key []byte + val []byte + deleted bool +} + +func (ent *Entry) Encode() []byte { + data := make([]byte, 4+4+1+len(ent.key)+len(ent.val)) + binary.LittleEndian.PutUint32(data[0:4], uint32(len(ent.key))) + copy(data[9:], ent.key) + if ent.deleted { + data[8] = 1 + } else { + binary.LittleEndian.PutUint32(data[4:8], uint32(len(ent.val))) + copy(data[9+len(ent.key):], ent.val) + } + return data +} + +func (ent *Entry) Decode(r io.Reader) error { + var header [9]byte + if _, err := io.ReadFull(r, header[:]); err != nil { + return err + } + klen := int(binary.LittleEndian.Uint32(header[0:4])) + vlen := int(binary.LittleEndian.Uint32(header[4:8])) + deleted := header[8] + + data := make([]byte, klen+vlen) + if _, err := io.ReadFull(r, data); err != nil { + return err + } + + ent.key = data[:klen] + if deleted != 0 { + ent.deleted = true + } else { + ent.deleted = false + ent.val = data[klen:] + } + return nil +} + +// QzBQWVJJOUhU https://trialofcode.org/ diff --git a/0104/kv_test.go b/0104/kv_test.go new file mode 100644 index 0000000..56a553d --- /dev/null +++ b/0104/kv_test.go @@ -0,0 +1,75 @@ +package db0104 + +import ( + "bytes" + "os" + "testing" + + "github.com/stretchr/testify/assert" +) + +func TestKVBasic(t *testing.T) { + kv := KV{} + kv.log.FileName = ".test_db" + defer os.Remove(kv.log.FileName) + + os.Remove(kv.log.FileName) + err := kv.Open() + assert.Nil(t, err) + defer kv.Close() + + updated, err := kv.Set([]byte("k1"), []byte("v1")) + assert.True(t, updated && err == nil) + + val, ok, err := kv.Get([]byte("k1")) + assert.True(t, string(val) == "v1" && ok && err == nil) + + _, ok, err = kv.Get([]byte("xxx")) + assert.True(t, !ok && err == nil) + + updated, err = kv.Del([]byte("xxx")) + assert.True(t, !updated && err == nil) + + updated, err = kv.Del([]byte("k1")) + assert.True(t, updated && err == nil) + + _, ok, err = kv.Get([]byte("xxx")) + assert.True(t, !ok && err == nil) + + updated, err = kv.Set([]byte("k2"), []byte("v2")) + assert.True(t, updated && err == nil) + + // reopen + kv.Close() + err = kv.Open() + assert.Nil(t, err) + + _, ok, err = kv.Get([]byte("k1")) + assert.True(t, !ok && err == nil) + val, ok, err = kv.Get([]byte("k2")) + assert.True(t, string(val) == "v2" && ok && err == nil) +} + +func TestEntryEncode(t *testing.T) { + ent := Entry{key: []byte("k1"), val: []byte("xxx")} + data := []byte{2, 0, 0, 0, 3, 0, 0, 0, 0, 'k', '1', 'x', 'x', 'x'} + + assert.Equal(t, data, ent.Encode()) + + decoded := Entry{} + err := decoded.Decode(bytes.NewBuffer(data)) + assert.Nil(t, err) + assert.Equal(t, ent, decoded) + + ent = Entry{key: []byte("k1"), deleted: true} + data = []byte{2, 0, 0, 0, 0, 0, 0, 0, 1, 'k', '1'} + + assert.Equal(t, data, ent.Encode()) + + decoded = Entry{} + err = decoded.Decode(bytes.NewBuffer(data)) + assert.Nil(t, err) + assert.Equal(t, ent, decoded) +} + +// QzBQWVJJOUhU https://trialofcode.org/ diff --git a/0104/log.go b/0104/log.go new file mode 100644 index 0000000..c1dd6a6 --- /dev/null +++ b/0104/log.go @@ -0,0 +1,35 @@ +package db0104 + +import ( + "io" + "os" +) + +type Log struct { + FileName string + fp *os.File +} + +func (log *Log) Open() (err error) { + log.fp, err = createFileSync(log.FileName) + return err +} + +func (log *Log) Close() error { + return log.fp.Close() +} + +func (log *Log) Write(ent *Entry) error + +func (log *Log) Read(ent *Entry) (eof bool, err error) { + err = ent.Decode(log.fp) + if err == io.EOF { + return true, nil + } else if err != nil { + return false, err + } else { + return false, nil + } +} + +// QzBQWVJJOUhU https://trialofcode.org/ diff --git a/0104/os_other.go b/0104/os_other.go new file mode 100644 index 0000000..2a6fcba --- /dev/null +++ b/0104/os_other.go @@ -0,0 +1,11 @@ +//go:build !unix + +package db0104 + +import "os" + +func createFileSync(file string) (*os.File, error) { + return os.OpenFile(file, os.O_RDWR|os.O_CREATE, 0o644) +} + +// QzBQWVJJOUhU https://trialofcode.org/ diff --git a/0104/os_unix.go b/0104/os_unix.go new file mode 100644 index 0000000..e801818 --- /dev/null +++ b/0104/os_unix.go @@ -0,0 +1,34 @@ +//go:build unix + +package db0104 + +import ( + "os" + "path" + "syscall" +) + +// open or create a file and fsync the directory +func createFileSync(file string) (*os.File, error) { + fp, err := os.OpenFile(file, os.O_RDWR|os.O_CREATE, 0o644) + if err != nil { + return nil, err + } + if err = syncDir(path.Base(file)); err != nil { + _ = fp.Close() + return nil, err + } + return fp, err +} + +func syncDir(file string) error { + flags := os.O_RDONLY | syscall.O_DIRECTORY + dirfd, err := syscall.Open(path.Dir(file), flags, 0o644) + if err != nil { + return err + } + defer syscall.Close(dirfd) + return syscall.Fsync(dirfd) +} + +// QzBQWVJJOUhU https://trialofcode.org/