From 44aae391a887393a2808ebc7cc248b484a2b883c Mon Sep 17 00:00:00 2001
From: Ian Gulliver <github@flamingcow.io>
Date: Mon, 15 May 2023 21:13:00 -0700
Subject: [PATCH] sync

---
 cover.html | 272 +++++++++++++++++++++++++++++++++++++++++++++++++++++
 cover.out  |  44 +++++++++
 2 files changed, 316 insertions(+)
 create mode 100644 cover.html
 create mode 100644 cover.out
diff --git a/cover.html b/cover.html
new file mode 100644
index 0000000..3d68bf1
--- /dev/null
+++ b/cover.html
@@ -0,0 +1,272 @@
+
+<!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 &amp;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(&amp;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(&amp;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>
diff --git a/cover.out b/cover.out
new file mode 100644
index 0000000..b68cb9a
--- /dev/null
+++ b/cover.out
@@ -0,0 +1,44 @@
+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
