chore: add DB definitions for new DB structure

This uses the soon to be deprecated database
definitions in the 'db/' directory and puts
them within the module that mainly uses
the definitions and queries.

The chainobsdb is broken down into more fine-grained
sub-definitions, since not all shutter commands are
using all schemas.

Author: ezdac

rolling-shutter/chainobserver/db/collator/collator.sqlc.gen.go

@@ -0,0 +1,28 @@
+package database
+
+import (
+	"embed"
+
+	"github.com/rs/zerolog/log"
+
+	sync "github.com/shutter-network/rolling-shutter/rolling-shutter/chainobserver/db/sync"
+	"github.com/shutter-network/rolling-shutter/rolling-shutter/medley/db"
+)
+
+//go:generate sqlc generate --file sql/sqlc.yaml
+
+//go:embed sql
+var files embed.FS
+var Definition db.Definition
+
+func init() {
+	def, err := db.NewSQLCDefinition(files, "sql/", "chainobscollator", 1)
+	if err != nil {
+		log.Fatal().Err(err).Msg("failed to initialize DB metadata")
+	}
+	Definition = db.NewAggregateDefinition(
+		"chainobscollator",
+		def,
+		sync.Definition,
+	)
+}

rolling-shutter/chainobserver/db/collator/db.sqlc.gen.go

@@ -0,0 +1,8 @@
+-- name: InsertChainCollator :exec
+INSERT INTO chain_collator (activation_block_number, collator)
+VALUES ($1, $2);
+
+-- name: GetChainCollator :one
+SELECT * FROM chain_collator
+WHERE activation_block_number <= $1
+ORDER BY activation_block_number DESC LIMIT 1;

rolling-shutter/chainobserver/db/collator/definition.go

@@ -0,0 +1,4 @@
+CREATE TABLE chain_collator(
+       activation_block_number bigint PRIMARY KEY,
+       collator text NOT NULL
+);

rolling-shutter/chainobserver/db/collator/models.sqlc.gen.go

@@ -0,0 +1,13 @@
+version: "2"
+sql:
+  - schema: "schemas"
+    queries: "queries"
+    engine: "postgresql"
+    gen:
+      go:
+        package: "database"
+        out: "../"
+        sql_package: "pgx/v4"
+        output_db_file_name: "db.sqlc.gen.go"
+        output_models_file_name: "models.sqlc.gen.go"
+        output_files_suffix: "c.gen"

rolling-shutter/chainobserver/db/collator/sql/queries/collator.sql

@@ -0,0 +1,12 @@
+package database
+
+import (
+	collatordb "github.com/shutter-network/rolling-shutter/rolling-shutter/chainobserver/db/collator"
+	keyperdb "github.com/shutter-network/rolling-shutter/rolling-shutter/chainobserver/db/keyper"
+	"github.com/shutter-network/rolling-shutter/rolling-shutter/medley/db"
+)
+
+var (
+	KeyperDefinition   db.Definition = keyperdb.Definition
+	CollatorDefinition db.Definition = collatordb.Definition
+)

rolling-shutter/chainobserver/db/collator/sql/schemas/collator.sql

@@ -0,0 +1,28 @@
+package database
+
+import (
+	"embed"
+
+	"github.com/rs/zerolog/log"
+
+	sync "github.com/shutter-network/rolling-shutter/rolling-shutter/chainobserver/db/sync"
+	"github.com/shutter-network/rolling-shutter/rolling-shutter/medley/db"
+)
+
+//go:generate sqlc generate --file sql/sqlc.yaml
+
+//go:embed sql
+var files embed.FS
+var Definition db.Definition
+
+func init() {
+	def, err := db.NewSQLCDefinition(files, "sql/", "chainobskeyper", 1)
+	if err != nil {
+		log.Fatal().Err(err).Msg("failed to initialize DB metadata")
+	}
+	Definition = db.NewAggregateDefinition(
+		"chainobskeyper",
+		def,
+		sync.Definition,
+	)
+}