First stable version

.github/workflows/actions.yaml

@@ -0,0 +1,43 @@
+name: Build tss-wrapper-svc docker image
+on:
+  push:
+    branches:
+      - "main"
+      - "dev"
+      - "**"
+
+env:
+  CI_ACCESS_TOKEN: ${{ secrets.CI_ACCESS_TOKEN }}
+  GITHUB_REPOSITORY: ghcr.io/bridgeless-project/tss-wrapper
+
+jobs:
+  converge-github:
+    name: Build To Github
+    runs-on: ubuntu-24.04
+    steps:
+      - name: Checkout code
+        uses: actions/checkout@v3
+        with:
+          fetch-depth: 0
+
+      - name: Log in to registry
+        run: echo "${{ secrets.GITHUB_TOKEN }}" | docker login ghcr.io -u $ --password-stdin
+
+      - name: Build and Push Image
+        env:
+          IMAGE: ${{ env.GITHUB_REPOSITORY }}:${{ github.sha }}
+          CACHE_REPO: ${{ env.GITHUB_REPOSITORY }}/cache
+        run: |
+          buildah build \
+            -f build/Dockerfile \
+            --layers \
+            --cache-from $CACHE_REPO \
+            --cache-to $CACHE_REPO \
+            -t $IMAGE \
+            --build-arg CI_ACCESS_TOKEN=$CI_ACCESS_TOKEN \
+            .
+
+      - name: Push Image
+        env:
+          IMAGE: ${{ env.GITHUB_REPOSITORY }}:${{ github.sha }}
+        run: buildah push $IMAGE

.gitignore

@@ -0,0 +1,5 @@
+config.yaml
+.idea
+binary
+vendor
+.DS_Store

Makefile

@@ -0,0 +1,8 @@
+.PHONY: install
+
+gen-proto:
+	cd proto && buf generate
+
+docker-up:
+	@echo "Starting Docker Compose..."
+	docker-compose up

README.md

@@ -1 +1,7 @@
 # TSS wrapper
+
+
+The service is responsible for managing the TSS daemon:
+- starting the TSS daemon 
+- listen for update events from the Bridgeless-core
+- schedule the TSS update when we need it

assets/assets.go

@@ -0,0 +1,8 @@
+package assets
+
+import (
+	"embed"
+)
+
+//go:embed migrations/*.sql
+var Migrations embed.FS

assets/migrations/00_initial.sql

@@ -0,0 +1,34 @@
+-- +migrate Up
+CREATE TABLE epochs(
+    id          serial      primary key,
+    start_time  timestamp   not null,
+    end_time    timestamp   not null  -- update when new epoch started
+);
+
+CREATE TABLE IF NOT EXISTS latest_block
+(
+    id INT NOT NULL UNIQUE,
+    latest_block_id INT NOT NULL
+);
+
+CREATE TABLE IF NOT EXISTS tasks
+(
+    id          SERIAL PRIMARY KEY,
+    task_type   VARCHAR(64) NOT NULL,
+    status      INT NOT NULL,
+    data        TEXT NOT NULL,
+    error       TEXT,
+    created_at  TIMESTAMP NOT NULL DEFAULT NOW(),
+    updated_at  TIMESTAMP NOT NULL DEFAULT NOW()
+);
+
+CREATE INDEX idx_tasks_status ON tasks(status);
+CREATE INDEX idx_tasks_created_at ON tasks(created_at);
+
+-- +migrate Down
+DROP TABLE IF EXISTS tasks;
+DROP TABLE IF EXISTS latest_block;
+DROP TABLE IF EXISTS epochs;
+
+DROP INDEX IF EXISTS idx_tasks_status;
+DROP INDEX IF EXISTS idx_tasks_created_at;

build/Dockerfile

@@ -0,0 +1,28 @@
+FROM golang:1.25-alpine as buildbase
+
+RUN apk add git build-base
+
+WORKDIR /go/src/github.com/Bridgeless-Project/tss-wrapper-svc
+
+ENV GO111MODULE="on"
+ENV CGO_ENABLED=1
+ENV GOOS="linux"
+ENV GOPRIVATE=github.com/*
+ENV GONOSUMDB=github.com/*
+ENV GONOPROXY=github.com/*
+
+COPY ./go.mod ./go.sum ./
+RUN go mod download
+
+COPY . .
+
+RUN go build  -o /usr/local/bin/tss-wrapper-svc /go/src/github.com/Bridgeless-Project/tss-wrapper-svc
+
+
+FROM alpine:3.9
+
+COPY --from=buildbase /usr/local/bin/tss-wrapper-svc /usr/local/bin/tss-wrapper-svc
+
+RUN apk add --no-cache ca-certificates
+
+ENTRYPOINT ["tss-wrapper-svc"]

build/docker-compose.yaml

@@ -0,0 +1,37 @@
+services:
+  db:
+    container_name: db
+    image: postgres
+    restart: unless-stopped
+    ports:
+      - "5435:5432"
+    environment:
+      - POSTGRES_USER=tss-wrapper
+      - POSTGRES_PASSWORD=tss-wrapper
+      - POSTGRES_DB=db
+      - PGDATA=/pgdata
+    volumes:
+      - pg-data:/pgdata
+    healthcheck:
+      test: [ "CMD-SHELL", "pg_isready -U tss-wrapper -d db" ]
+      interval: 5s
+      timeout: 5s
+      retries: 5
+      start_period: 5s
+
+#  tss-wrapper-svc:
+#    build:
+#      context: ../
+#      dockerfile: build/Dockerfile
+#    ports:
+#      - "8080:8080"
+#    container_name: tss-wrapper-svc
+#    entrypoint: sh -c "tss-wrapper-svc service migrate up && tss-wrapper-svc service run"
+#    depends_on:
+#      db:
+#         condition: service_healthy
+#    volumes:
+#      - ./configs/config.local.yaml:/config.yaml
+
+volumes:
+  pg-data:

cmd/root.go

@@ -0,0 +1,21 @@
+package cmd
+
+import (
+	"os"
+
+	"github.com/Bridgeless-Project/tss-wrapper-svc/cmd/service"
+	"github.com/spf13/cobra"
+)
+
+func Execute() {
+	root := &cobra.Command{
+		Use:   "tss-wrapper-svc",
+		Short: "TSS wrapper service",
+	}
+
+	root.AddCommand(service.Cmd)
+
+	if err := root.Execute(); err != nil {
+		os.Exit(1)
+	}
+}

cmd/service/migrate/down.go

@@ -0,0 +1,21 @@
+package migrate
+
+import (
+	"github.com/Bridgeless-Project/tss-wrapper-svc/cmd/utils"
+	"github.com/pkg/errors"
+	migrate "github.com/rubenv/sql-migrate"
+	"github.com/spf13/cobra"
+)
+
+var downCmd = &cobra.Command{
+	Use:   "down",
+	Short: "Downgrades the database migrations",
+	RunE: func(cmd *cobra.Command, args []string) error {
+		cfg, err := utils.ConfigFromFlags(cmd)
+		if err != nil {
+			return errors.Wrap(err, "failed to get config from flags")
+		}
+
+		return execute(cfg, migrate.Down)
+	},
+}

cmd/service/migrate/migrate.go

@@ -0,0 +1,40 @@
+package migrate
+
+import (
+	"github.com/Bridgeless-Project/tss-wrapper-svc/assets"
+	"github.com/Bridgeless-Project/tss-wrapper-svc/internal/config"
+
+	"github.com/pkg/errors"
+	migrate "github.com/rubenv/sql-migrate"
+	"github.com/spf13/cobra"
+)
+
+func init() {
+	registerCommands(Cmd)
+}
+
+var Cmd = &cobra.Command{
+	Use:   "migrate",
+	Short: "Command for running database migrations",
+}
+
+func registerCommands(cmd *cobra.Command) {
+	cmd.AddCommand(upCmd)
+	cmd.AddCommand(downCmd)
+}
+
+func execute(cfg config.Config, direction migrate.MigrationDirection) error {
+	migrationsFs := &migrate.EmbedFileSystemMigrationSource{
+		FileSystem: assets.Migrations,
+		Root:       "migrations",
+	}
+
+	applied, err := migrate.Exec(cfg.DB().RawDB(), "postgres", migrationsFs, direction)
+	if err != nil {
+		return errors.Wrap(err, "failed to apply migrations")
+	}
+
+	cfg.Log().WithField("applied", applied).Debug("migrations applied")
+
+	return nil
+}

cmd/service/migrate/up.go

@@ -0,0 +1,21 @@
+package migrate
+
+import (
+	"github.com/Bridgeless-Project/tss-wrapper-svc/cmd/utils"
+	"github.com/pkg/errors"
+	migrate "github.com/rubenv/sql-migrate"
+	"github.com/spf13/cobra"
+)
+
+var upCmd = &cobra.Command{
+	Use:   "up",
+	Short: "Upgrades the database with migrations",
+	RunE: func(cmd *cobra.Command, args []string) error {
+		cfg, err := utils.ConfigFromFlags(cmd)
+		if err != nil {
+			return errors.Wrap(err, "failed to get config from flags")
+		}
+
+		return execute(cfg, migrate.Up)
+	},
+}