4801130633

Committed 25 Apr 2023 06:54PM UTC coverage: 90.273% (-0.2%) from 90.484%

Build Type

push

github

Committed by Bartłomiej Święcki

Commit Message

Fix validation of release docker images

Run Details

1717 of 1902 relevant lines covered (90.27%)

1.0 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

89.83

/pkg/datastore/storage_raw_filesystem.go

/*
Copyright © 2023 Bartłomiej Święcki (byo)

Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

    http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/

package datastore

import (
        "context"
        "fmt"
        "io"
        "os"
        "path/filepath"
        "sync/atomic"

        "github.com/cinode/go/pkg/common"
)

type rawFileSystem struct {
        path        string
        tempFileNum uint64
}

var _ storage = (*rawFileSystem)(nil)

func newStorageRawFilesystem(path string) (*rawFileSystem, error) {
        err := os.MkdirAll(path, 0755)
        if err != nil {
                return nil, err
        }
        return &rawFileSystem{path: path}, nil
}

func (fs *rawFileSystem) kind() string {
        return "RawFileSystem"
}

func (fs *rawFileSystem) address() string {
        return rawFilePrefix + fs.path
}

func (fs *rawFileSystem) openReadStream(ctx context.Context, name common.BlobName) (io.ReadCloser, error) {
        rc, err := os.Open(filepath.Join(fs.path, name.String()))
        if os.IsNotExist(err) {
                return nil, ErrNotFound
        }
        return rc, err
}

type rawFilesystemWriter struct {
        file         *os.File
        destFileName string
}

func (w *rawFilesystemWriter) Write(b []byte) (int, error) {
        return w.file.Write(b)
}

func (w *rawFilesystemWriter) Close() error {
        err := w.file.Close()
        if err != nil {
                return err
        }

        return os.Rename(w.file.Name(), w.destFileName)
}

func (w *rawFilesystemWriter) Cancel() {
        w.file.Close()
        os.Remove(w.file.Name())
}

func (fs *rawFileSystem) openWriteStream(ctx context.Context, name common.BlobName) (WriteCloseCanceller, error) {
        tempNum := atomic.AddUint64(&fs.tempFileNum, 1)

        tempFileName := filepath.Join(fs.path, fmt.Sprintf("tempfile_%d", tempNum))

        fl, err := os.Create(tempFileName)
        if err != nil {
                return nil, err
        }

        return &rawFilesystemWriter{
                file:         fl,
                destFileName: filepath.Join(fs.path, name.String()),
        }, nil
}

func (fs *rawFileSystem) exists(ctx context.Context, name common.BlobName) (bool, error) {
        _, err := os.Stat(filepath.Join(fs.path, name.String()))
        if os.IsNotExist(err) {
                return false, nil
        }
        if err != nil {
                return false, err
        }
        return true, nil
}

func (fs *rawFileSystem) delete(ctx context.Context, name common.BlobName) error {
        err := os.Remove(filepath.Join(fs.path, name.String()))
        if os.IsNotExist(err) {
                return ErrNotFound
        }
        return err
}

1	/*
2	Copyright © 2023 Bartłomiej Święcki (byo)
3
4	Licensed under the Apache License, Version 2.0 (the "License");
5	you may not use this file except in compliance with the License.
6	You may obtain a copy of the License at
7
8	http://www.apache.org/licenses/LICENSE-2.0
9
10	Unless required by applicable law or agreed to in writing, software
11	distributed under the License is distributed on an "AS IS" BASIS,
12	WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13	See the License for the specific language governing permissions and
14	limitations under the License.
15	*/
16
17	package datastore
18
19	import (
20	"context"
21	"fmt"
22	"io"
23	"os"
24	"path/filepath"
25	"sync/atomic"
26
27	"github.com/cinode/go/pkg/common"
28	)
29
30	type rawFileSystem struct {
31	path string
32	tempFileNum uint64
33	}
34
35	var _ storage = (*rawFileSystem)(nil)
36
37	func newStorageRawFilesystem(path string) (*rawFileSystem, error) {	1✔
38	err := os.MkdirAll(path, 0755)	1✔
39	if err != nil {	2✔
40	return nil, err	1✔
41	}	1✔
42	return &rawFileSystem{path: path}, nil	1✔
43	}
44
45	func (fs *rawFileSystem) kind() string {	1✔
46	return "RawFileSystem"	1✔
47	}	1✔
48
49	func (fs *rawFileSystem) address() string {	1✔
50	return rawFilePrefix + fs.path	1✔
51	}	1✔
52
53	func (fs *rawFileSystem) openReadStream(ctx context.Context, name common.BlobName) (io.ReadCloser, error) {	1✔
54	rc, err := os.Open(filepath.Join(fs.path, name.String()))	1✔
55	if os.IsNotExist(err) {	2✔
56	return nil, ErrNotFound	1✔
57	}	1✔
58	return rc, err	1✔
59	}
60
61	type rawFilesystemWriter struct {
62	file *os.File
63	destFileName string
64	}
65
66	func (w *rawFilesystemWriter) Write(b []byte) (int, error) {	1✔
67	return w.file.Write(b)	1✔
68	}	1✔
69
70	func (w *rawFilesystemWriter) Close() error {	1✔
71	err := w.file.Close()	1✔
72	if err != nil {	1✔
73	return err	×
74	}	×
75
76	return os.Rename(w.file.Name(), w.destFileName)	1✔
77	}
78
79	func (w *rawFilesystemWriter) Cancel() {	1✔
80	w.file.Close()	1✔
81	os.Remove(w.file.Name())	1✔
82	}	1✔
83
84	func (fs *rawFileSystem) openWriteStream(ctx context.Context, name common.BlobName) (WriteCloseCanceller, error) {	1✔
85	tempNum := atomic.AddUint64(&fs.tempFileNum, 1)	1✔
86		1✔
87	tempFileName := filepath.Join(fs.path, fmt.Sprintf("tempfile_%d", tempNum))	1✔
88		1✔
89	fl, err := os.Create(tempFileName)	1✔
90	if err != nil {	1✔
91	return nil, err	×
92	}	×
93
94	return &rawFilesystemWriter{	1✔
95	file: fl,	1✔
96	destFileName: filepath.Join(fs.path, name.String()),	1✔
97	}, nil	1✔
98	}
99
100	func (fs *rawFileSystem) exists(ctx context.Context, name common.BlobName) (bool, error) {	1✔
101	_, err := os.Stat(filepath.Join(fs.path, name.String()))	1✔
102	if os.IsNotExist(err) {	2✔
103	return false, nil	1✔
104	}	1✔
105	if err != nil {	1✔
106	return false, err	×
107	}	×
108	return true, nil	1✔
109	}
110
111	func (fs *rawFileSystem) delete(ctx context.Context, name common.BlobName) error {	1✔
112	err := os.Remove(filepath.Join(fs.path, name.String()))	1✔
113	if os.IsNotExist(err) {	2✔
114	return ErrNotFound	1✔
115	}	1✔
116	return err	1✔
117	}

cinode / go / 4801130633

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous