Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
459fac2
commit 982fa61
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,8 +1,12 @@ | ||
| -- +goose Up | ||
| CREATE TABLE IF NOT EXISTS notifiers ( | ||
| chain TEXT NOT NULL, | ||
| reporter TEXT NOT NULL, | ||
| operator_address TEXT NOT NULL, | ||
| user_name TEXT NOT NULL, | ||
| user_id TEXT NOT NULL, | ||
| PRIMARY KEY (chain, reporter, operator_address, user_id) | ||
| ); | ||
|
|
||
| -- +goose Down | ||
| DROP TABLE notifiers; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,6 +1,10 @@ | ||
| -- +goose Up | ||
| CREATE TABLE IF NOT EXISTS data ( | ||
| chain TEXT NOT NULL, | ||
| key TEXT NOT NULL, | ||
| value TEXT NOT NULL, | ||
| PRIMARY KEY (chain, key) | ||
| ); | ||
|
|
||
| -- +goose Down | ||
| DROP TABLE data; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,6 @@ | ||
| package postgres | ||
|
|
||
| import "embed" | ||
|
|
||
| //go:embed **.sql | ||
| var EmbedFS embed.FS |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,13 @@ | ||
| -- +goose Up | ||
| CREATE TABLE IF NOT EXISTS blocks ( | ||
| chain TEXT not null, | ||
| height BIGINT NOT NULL, | ||
| time BIGINT NOT NULL, | ||
| proposer TEXT NOT NULL, | ||
| signatures TEXT NOT NULL, | ||
| validators TEXT NOT NULL, | ||
| PRIMARY KEY (chain, height) | ||
| ); | ||
|
|
||
| -- +goose Down | ||
| DROP TABLE blocks; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,12 @@ | ||
| -- +goose Up | ||
| CREATE TABLE IF NOT EXISTS notifiers ( | ||
| chain TEXT NOT NULL, | ||
| reporter TEXT NOT NULL, | ||
| operator_address TEXT NOT NULL, | ||
| user_name TEXT NOT NULL, | ||
| user_id TEXT NOT NULL, | ||
| PRIMARY KEY (chain, reporter, operator_address, user_id) | ||
| ); | ||
|
|
||
| -- +goose Down | ||
| DROP TABLE notifiers; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,10 @@ | ||
| -- +goose Up | ||
| CREATE TABLE IF NOT EXISTS data ( | ||
| chain TEXT NOT NULL, | ||
| key TEXT NOT NULL, | ||
| value TEXT NOT NULL, | ||
| PRIMARY KEY (chain, key) | ||
| ); | ||
|
|
||
| -- +goose Down | ||
| DROP TABLE data; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,13 @@ | ||
| -- +goose Up | ||
| CREATE TABLE IF NOT EXISTS events ( | ||
| id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL, | ||
| chain TEXT NOT NULL, | ||
| height BIGINT NOT NULL, | ||
| event TEXT NOT NULL, | ||
| validator TEXT NOT NULL, | ||
| payload TEXT NOT NULL, | ||
| time TEXT NOT NULL | ||
| ); | ||
|
|
||
| -- +goose Down | ||
| DROP TABLE events; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,6 @@ | ||
| package postgres | ||
|
|
||
| import "embed" | ||
|
|
||
| //go:embed **.sql | ||
| var EmbedFS embed.FS |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,10 +1,33 @@ | ||
| package database | ||
|
|
||
| import ( | ||
| "database/sql" | ||
| "strings" | ||
|
|
||
| "github.com/rs/zerolog" | ||
| ) | ||
|
|
||
| type DatabaseLogger struct { | ||
| Logger zerolog.Logger | ||
| } | ||
|
|
||
| func NewDatabaseLogger(logger zerolog.Logger) *DatabaseLogger { | ||
| return &DatabaseLogger{ | ||
| Logger: logger.With().Str("component", "database_migrations").Logger(), | ||
| } | ||
| } | ||
|
|
||
| func (l *DatabaseLogger) Printf(format string, v ...interface{}) { | ||
| l.Logger.Info().Msgf(strings.TrimSpace(format), v...) | ||
| } | ||
|
|
||
| func (l *DatabaseLogger) Fatalf(format string, v ...interface{}) { | ||
| l.Logger.Panic().Msgf(strings.TrimSpace(format), v...) | ||
| } | ||
|
|
||
| type DatabaseClient interface { | ||
| Exec(query string, args ...any) (sql.Result, error) | ||
| Query(query string, args ...any) (*sql.Rows, error) | ||
| QueryRow(query string, args ...any) *sql.Row | ||
| Migrate() error | ||
| } | ||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.