sync
This commit is contained in:
Ian Gulliver
272
cover.html
272
cover.html
@@ -1,272 +0,0 @@
|
|||||||
|
|
||||||
<!DOCTYPE html>
|
|
||||||
<html>
|
|
||||||
<head>
|
|
||||||
<meta http-equiv="Content-Type" content="text/html; charset=utf-8">
|
|
||||||
<title>store: Go Coverage Report</title>
|
|
||||||
<style>
|
|
||||||
body {
|
|
||||||
background: black;
|
|
||||||
color: rgb(80, 80, 80);
|
|
||||||
}
|
|
||||||
body, pre, #legend span {
|
|
||||||
font-family: Menlo, monospace;
|
|
||||||
font-weight: bold;
|
|
||||||
}
|
|
||||||
#topbar {
|
|
||||||
background: black;
|
|
||||||
position: fixed;
|
|
||||||
top: 0; left: 0; right: 0;
|
|
||||||
height: 42px;
|
|
||||||
border-bottom: 1px solid rgb(80, 80, 80);
|
|
||||||
}
|
|
||||||
#content {
|
|
||||||
margin-top: 50px;
|
|
||||||
}
|
|
||||||
#nav, #legend {
|
|
||||||
float: left;
|
|
||||||
margin-left: 10px;
|
|
||||||
}
|
|
||||||
#legend {
|
|
||||||
margin-top: 12px;
|
|
||||||
}
|
|
||||||
#nav {
|
|
||||||
margin-top: 10px;
|
|
||||||
}
|
|
||||||
#legend span {
|
|
||||||
margin: 0 5px;
|
|
||||||
}
|
|
||||||
.cov0 { color: rgb(192, 0, 0) }
|
|
||||||
.cov1 { color: rgb(128, 128, 128) }
|
|
||||||
.cov2 { color: rgb(116, 140, 131) }
|
|
||||||
.cov3 { color: rgb(104, 152, 134) }
|
|
||||||
.cov4 { color: rgb(92, 164, 137) }
|
|
||||||
.cov5 { color: rgb(80, 176, 140) }
|
|
||||||
.cov6 { color: rgb(68, 188, 143) }
|
|
||||||
.cov7 { color: rgb(56, 200, 146) }
|
|
||||||
.cov8 { color: rgb(44, 212, 149) }
|
|
||||||
.cov9 { color: rgb(32, 224, 152) }
|
|
||||||
.cov10 { color: rgb(20, 236, 155) }
|
|
||||||
|
|
||||||
</style>
|
|
||||||
</head>
|
|
||||||
<body>
|
|
||||||
<div id="topbar">
|
|
||||||
<div id="nav">
|
|
||||||
<select id="files">
|
|
||||||
|
|
||||||
<option value="file0">github.com/gopatchy/store/store.go (80.9%)</option>
|
|
||||||
|
|
||||||
</select>
|
|
||||||
</div>
|
|
||||||
<div id="legend">
|
|
||||||
<span>not tracked</span>
|
|
||||||
|
|
||||||
<span class="cov0">no coverage</span>
|
|
||||||
<span class="cov1">low coverage</span>
|
|
||||||
<span class="cov2">*</span>
|
|
||||||
<span class="cov3">*</span>
|
|
||||||
<span class="cov4">*</span>
|
|
||||||
<span class="cov5">*</span>
|
|
||||||
<span class="cov6">*</span>
|
|
||||||
<span class="cov7">*</span>
|
|
||||||
<span class="cov8">*</span>
|
|
||||||
<span class="cov9">*</span>
|
|
||||||
<span class="cov10">high coverage</span>
|
|
||||||
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
<div id="content">
|
|
||||||
|
|
||||||
<pre class="file" id="file0" style="display: none">package store
|
|
||||||
|
|
||||||
import (
|
|
||||||
"context"
|
|
||||||
"database/sql"
|
|
||||||
"encoding/json"
|
|
||||||
"fmt"
|
|
||||||
|
|
||||||
"github.com/gopatchy/metadata"
|
|
||||||
// Register sqlite3 db handler.
|
|
||||||
_ "github.com/mattn/go-sqlite3"
|
|
||||||
)
|
|
||||||
|
|
||||||
type Store struct {
|
|
||||||
db *sql.DB
|
|
||||||
}
|
|
||||||
|
|
||||||
func NewStore(conn string) (*Store, error) <span class="cov6" title="3">{
|
|
||||||
db, err := sql.Open("sqlite3", conn)
|
|
||||||
if err != nil </span><span class="cov0" title="0">{
|
|
||||||
return nil, err
|
|
||||||
}</span>
|
|
||||||
|
|
||||||
// TODO: Keep a set of prepared statements with PrepareContext()
|
|
||||||
// TODO: Consider tuning per https://phiresky.github.io/blog/2020/sqlite-performance-tuning/
|
|
||||||
|
|
||||||
<span class="cov6" title="3">return &Store{
|
|
||||||
db: db,
|
|
||||||
}, nil</span>
|
|
||||||
}
|
|
||||||
|
|
||||||
func (s *Store) Close() <span class="cov6" title="3">{
|
|
||||||
s.db.Close()
|
|
||||||
}</span>
|
|
||||||
|
|
||||||
func (s *Store) Write(ctx context.Context, t string, obj any) error <span class="cov9" title="6">{
|
|
||||||
id := metadata.GetMetadata(obj).ID
|
|
||||||
|
|
||||||
js, err := json.Marshal(obj)
|
|
||||||
if err != nil </span><span class="cov0" title="0">{
|
|
||||||
return err
|
|
||||||
}</span>
|
|
||||||
|
|
||||||
<span class="cov9" title="6">err = s.exec(ctx, "INSERT INTO `%s` (id, obj) VALUES (?,?) ON CONFLICT(id) DO UPDATE SET obj=?;", t, id, js, js)
|
|
||||||
if err != nil </span><span class="cov0" title="0">{
|
|
||||||
return err
|
|
||||||
}</span>
|
|
||||||
|
|
||||||
<span class="cov9" title="6">return nil</span>
|
|
||||||
}
|
|
||||||
|
|
||||||
func (s *Store) Delete(ctx context.Context, t, id string) error <span class="cov1" title="1">{
|
|
||||||
err := s.exec(ctx, "DELETE FROM `%s` WHERE id=?", t, id)
|
|
||||||
if err != nil </span><span class="cov0" title="0">{
|
|
||||||
return err
|
|
||||||
}</span>
|
|
||||||
|
|
||||||
<span class="cov1" title="1">return nil</span>
|
|
||||||
}
|
|
||||||
|
|
||||||
func (s *Store) Read(ctx context.Context, t, id string, factory func() any) (any, error) <span class="cov7" title="4">{
|
|
||||||
rows, err := s.query(ctx, "SELECT obj FROM `%s` WHERE id=?;", t, id)
|
|
||||||
if err != nil </span><span class="cov0" title="0">{
|
|
||||||
return nil, err
|
|
||||||
}</span>
|
|
||||||
|
|
||||||
<span class="cov7" title="4">defer rows.Close()
|
|
||||||
|
|
||||||
if !rows.Next() </span><span class="cov1" title="1">{
|
|
||||||
return nil, nil
|
|
||||||
}</span>
|
|
||||||
|
|
||||||
<span class="cov6" title="3">var js []byte
|
|
||||||
|
|
||||||
err = rows.Scan(&js)
|
|
||||||
if err != nil </span><span class="cov0" title="0">{
|
|
||||||
return nil, err
|
|
||||||
}</span>
|
|
||||||
|
|
||||||
<span class="cov6" title="3">obj := factory()
|
|
||||||
|
|
||||||
err = json.Unmarshal(js, obj)
|
|
||||||
if err != nil </span><span class="cov0" title="0">{
|
|
||||||
return nil, err
|
|
||||||
}</span>
|
|
||||||
|
|
||||||
<span class="cov6" title="3">return obj, nil</span>
|
|
||||||
}
|
|
||||||
|
|
||||||
func (s *Store) List(ctx context.Context, t string, factory func() any) ([]any, error) <span class="cov4" title="2">{
|
|
||||||
rows, err := s.query(ctx, "SELECT obj FROM `%s`;", t)
|
|
||||||
if err != nil </span><span class="cov0" title="0">{
|
|
||||||
return nil, err
|
|
||||||
}</span>
|
|
||||||
|
|
||||||
<span class="cov4" title="2">defer rows.Close()
|
|
||||||
|
|
||||||
ret := []any{}
|
|
||||||
|
|
||||||
for rows.Next() </span><span class="cov4" title="2">{
|
|
||||||
var js []byte
|
|
||||||
|
|
||||||
err = rows.Scan(&js)
|
|
||||||
if err != nil </span><span class="cov0" title="0">{
|
|
||||||
return nil, err
|
|
||||||
}</span>
|
|
||||||
|
|
||||||
<span class="cov4" title="2">obj := factory()
|
|
||||||
|
|
||||||
err = json.Unmarshal(js, obj)
|
|
||||||
if err != nil </span><span class="cov0" title="0">{
|
|
||||||
return nil, err
|
|
||||||
}</span>
|
|
||||||
|
|
||||||
<span class="cov4" title="2">ret = append(ret, obj)</span>
|
|
||||||
}
|
|
||||||
|
|
||||||
<span class="cov4" title="2">return ret, nil</span>
|
|
||||||
}
|
|
||||||
|
|
||||||
func (s *Store) exec(ctx context.Context, query, t string, args ...any) error <span class="cov10" title="7">{
|
|
||||||
query = fmt.Sprintf(query, t)
|
|
||||||
|
|
||||||
_, err := s.db.ExecContext(ctx, query, args...)
|
|
||||||
if err == nil </span><span class="cov8" title="5">{
|
|
||||||
return nil
|
|
||||||
}</span>
|
|
||||||
|
|
||||||
<span class="cov4" title="2">_, err = s.db.ExecContext(ctx, s.tableSQL(t))
|
|
||||||
if err != nil </span><span class="cov0" title="0">{
|
|
||||||
return err
|
|
||||||
}</span>
|
|
||||||
|
|
||||||
<span class="cov4" title="2">_, err = s.db.ExecContext(ctx, query, args...)
|
|
||||||
if err != nil </span><span class="cov0" title="0">{
|
|
||||||
return err
|
|
||||||
}</span>
|
|
||||||
|
|
||||||
<span class="cov4" title="2">return nil</span>
|
|
||||||
}
|
|
||||||
|
|
||||||
func (s *Store) query(ctx context.Context, query, t string, args ...any) (*sql.Rows, error) <span class="cov9" title="6">{
|
|
||||||
query = fmt.Sprintf(query, t)
|
|
||||||
|
|
||||||
rows, err := s.db.QueryContext(ctx, query, args...)
|
|
||||||
if err == nil </span><span class="cov8" title="5">{
|
|
||||||
return rows, nil
|
|
||||||
}</span>
|
|
||||||
|
|
||||||
<span class="cov1" title="1">_, err = s.db.ExecContext(ctx, s.tableSQL(t))
|
|
||||||
if err != nil </span><span class="cov0" title="0">{
|
|
||||||
return nil, err
|
|
||||||
}</span>
|
|
||||||
|
|
||||||
<span class="cov1" title="1">return s.db.QueryContext(ctx, query, args...)</span>
|
|
||||||
}
|
|
||||||
|
|
||||||
func (s *Store) tableSQL(t string) string <span class="cov6" title="3">{
|
|
||||||
return fmt.Sprintf("CREATE TABLE IF NOT EXISTS `%s` (id TEXT NOT NULL PRIMARY KEY, obj TEXT NOT NULL);", t)
|
|
||||||
}</span>
|
|
||||||
</pre>
|
|
||||||
|
|
||||||
</div>
|
|
||||||
</body>
|
|
||||||
<script>
|
|
||||||
(function() {
|
|
||||||
var files = document.getElementById('files');
|
|
||||||
var visible;
|
|
||||||
files.addEventListener('change', onChange, false);
|
|
||||||
function select(part) {
|
|
||||||
if (visible)
|
|
||||||
visible.style.display = 'none';
|
|
||||||
visible = document.getElementById(part);
|
|
||||||
if (!visible)
|
|
||||||
return;
|
|
||||||
files.value = part;
|
|
||||||
visible.style.display = 'block';
|
|
||||||
location.hash = part;
|
|
||||||
}
|
|
||||||
function onChange() {
|
|
||||||
select(files.value);
|
|
||||||
window.scrollTo(0, 0);
|
|
||||||
}
|
|
||||||
if (location.hash != "") {
|
|
||||||
select(location.hash.substr(1));
|
|
||||||
}
|
|
||||||
if (!visible) {
|
|
||||||
select("file0");
|
|
||||||
}
|
|
||||||
})();
|
|
||||||
</script>
|
|
||||||
</html>
|
|
||||||
44
cover.out
44
cover.out
@@ -1,44 +0,0 @@
|
|||||||
mode: atomic
|
|
||||||
github.com/gopatchy/store/store.go:18.44,20.16 2 3
|
|
||||||
github.com/gopatchy/store/store.go:20.16,22.3 1 0
|
|
||||||
github.com/gopatchy/store/store.go:27.2,29.8 1 3
|
|
||||||
github.com/gopatchy/store/store.go:32.25,34.2 1 3
|
|
||||||
github.com/gopatchy/store/store.go:36.69,40.16 3 6
|
|
||||||
github.com/gopatchy/store/store.go:40.16,42.3 1 0
|
|
||||||
github.com/gopatchy/store/store.go:44.2,45.16 2 6
|
|
||||||
github.com/gopatchy/store/store.go:45.16,47.3 1 0
|
|
||||||
github.com/gopatchy/store/store.go:49.2,49.12 1 6
|
|
||||||
github.com/gopatchy/store/store.go:52.65,54.16 2 1
|
|
||||||
github.com/gopatchy/store/store.go:54.16,56.3 1 0
|
|
||||||
github.com/gopatchy/store/store.go:58.2,58.12 1 1
|
|
||||||
github.com/gopatchy/store/store.go:61.90,63.16 2 4
|
|
||||||
github.com/gopatchy/store/store.go:63.16,65.3 1 0
|
|
||||||
github.com/gopatchy/store/store.go:67.2,69.18 2 4
|
|
||||||
github.com/gopatchy/store/store.go:69.18,71.3 1 1
|
|
||||||
github.com/gopatchy/store/store.go:73.2,76.16 3 3
|
|
||||||
github.com/gopatchy/store/store.go:76.16,78.3 1 0
|
|
||||||
github.com/gopatchy/store/store.go:80.2,83.16 3 3
|
|
||||||
github.com/gopatchy/store/store.go:83.16,85.3 1 0
|
|
||||||
github.com/gopatchy/store/store.go:87.2,87.17 1 3
|
|
||||||
github.com/gopatchy/store/store.go:90.88,92.16 2 2
|
|
||||||
github.com/gopatchy/store/store.go:92.16,94.3 1 0
|
|
||||||
github.com/gopatchy/store/store.go:96.2,100.18 3 2
|
|
||||||
github.com/gopatchy/store/store.go:100.18,104.17 3 2
|
|
||||||
github.com/gopatchy/store/store.go:104.17,106.4 1 0
|
|
||||||
github.com/gopatchy/store/store.go:108.3,111.17 3 2
|
|
||||||
github.com/gopatchy/store/store.go:111.17,113.4 1 0
|
|
||||||
github.com/gopatchy/store/store.go:115.3,115.25 1 2
|
|
||||||
github.com/gopatchy/store/store.go:118.2,118.17 1 2
|
|
||||||
github.com/gopatchy/store/store.go:121.79,125.16 3 7
|
|
||||||
github.com/gopatchy/store/store.go:125.16,127.3 1 5
|
|
||||||
github.com/gopatchy/store/store.go:129.2,130.16 2 2
|
|
||||||
github.com/gopatchy/store/store.go:130.16,132.3 1 0
|
|
||||||
github.com/gopatchy/store/store.go:134.2,135.16 2 2
|
|
||||||
github.com/gopatchy/store/store.go:135.16,137.3 1 0
|
|
||||||
github.com/gopatchy/store/store.go:139.2,139.12 1 2
|
|
||||||
github.com/gopatchy/store/store.go:142.93,146.16 3 6
|
|
||||||
github.com/gopatchy/store/store.go:146.16,148.3 1 5
|
|
||||||
github.com/gopatchy/store/store.go:150.2,151.16 2 1
|
|
||||||
github.com/gopatchy/store/store.go:151.16,153.3 1 0
|
|
||||||
github.com/gopatchy/store/store.go:155.2,155.47 1 1
|
|
||||||
github.com/gopatchy/store/store.go:158.43,160.2 1 3
|
|
||||||
2
go.mod
2
go.mod
@@ -4,7 +4,7 @@ go 1.19
|
|||||||
|
|
||||||
require (
|
require (
|
||||||
github.com/dchest/uniuri v1.2.0
|
github.com/dchest/uniuri v1.2.0
|
||||||
github.com/gopatchy/metadata v0.0.0-20230516041300-fc49e5f775fe
|
github.com/gopatchy/metadata v0.0.0-20230516044939-eed23a0903d5
|
||||||
github.com/mattn/go-sqlite3 v1.14.16
|
github.com/mattn/go-sqlite3 v1.14.16
|
||||||
github.com/stretchr/testify v1.8.2
|
github.com/stretchr/testify v1.8.2
|
||||||
go.uber.org/goleak v1.2.1
|
go.uber.org/goleak v1.2.1
|
||||||
|
|||||||
2
go.sum
2
go.sum
@@ -8,6 +8,8 @@ github.com/gopatchy/metadata v0.0.0-20230424223338-33e58fee42bf h1:HKCbhVEpC3++y
|
|||||||
github.com/gopatchy/metadata v0.0.0-20230424223338-33e58fee42bf/go.mod h1:VgD33raUShjDePCDBo55aj+eSXFtUEpMzs+Ie39g2zo=
|
github.com/gopatchy/metadata v0.0.0-20230424223338-33e58fee42bf/go.mod h1:VgD33raUShjDePCDBo55aj+eSXFtUEpMzs+Ie39g2zo=
|
||||||
github.com/gopatchy/metadata v0.0.0-20230516041300-fc49e5f775fe h1:xPnlis/qCAYoxHx9tow1P4pO17c8JH/Hs/lHDmZej/Q=
|
github.com/gopatchy/metadata v0.0.0-20230516041300-fc49e5f775fe h1:xPnlis/qCAYoxHx9tow1P4pO17c8JH/Hs/lHDmZej/Q=
|
||||||
github.com/gopatchy/metadata v0.0.0-20230516041300-fc49e5f775fe/go.mod h1:VgD33raUShjDePCDBo55aj+eSXFtUEpMzs+Ie39g2zo=
|
github.com/gopatchy/metadata v0.0.0-20230516041300-fc49e5f775fe/go.mod h1:VgD33raUShjDePCDBo55aj+eSXFtUEpMzs+Ie39g2zo=
|
||||||
|
github.com/gopatchy/metadata v0.0.0-20230516044939-eed23a0903d5 h1:b66b4DOGTqDuw4hbxHSp0WbhXr/xAMaiFkU6iCi4nDg=
|
||||||
|
github.com/gopatchy/metadata v0.0.0-20230516044939-eed23a0903d5/go.mod h1:VgD33raUShjDePCDBo55aj+eSXFtUEpMzs+Ie39g2zo=
|
||||||
github.com/kr/pretty v0.3.0 h1:WgNl7dwNpEZ6jJ9k1snq4pZsg7DOEN8hP9Xw0Tsjwk0=
|
github.com/kr/pretty v0.3.0 h1:WgNl7dwNpEZ6jJ9k1snq4pZsg7DOEN8hP9Xw0Tsjwk0=
|
||||||
github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
|
github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
|
||||||
github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
|
github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
|
||||||
|
|||||||
Reference in New Issue
Block a user