Add Transaction to list after saving

.drone.yml

@@ -8,7 +8,7 @@ steps:
   image: hub.javil.eu/budgeteer:dev
   pull: true
   commands:
-    - task ci
+    - task
 
 - name: docker  
   image: plugins/docker

.golangci.yml

@@ -1,26 +0,0 @@
-linters:
-  enable-all: true
-  disable:
-    - golint
-    - scopelint
-    - maligned
-    - interfacer
-    - wsl
-    - forbidigo
-    - nlreturn
-    - testpackage
-    - ifshort
-    - exhaustivestruct
-    - gci # not working, shows errors on freshly formatted file
-    - varnamelen
-linters-settings:
-  errcheck:
-    exclude-functions:
-      - io/ioutil.ReadFile
-      - io.Copy(*bytes.Buffer)
-      - (*github.com/gin-gonic/gin.Context).AbortWithError
-      - (*github.com/gin-gonic/gin.Context).AbortWithError
-      - io.Copy(os.Stdout)
-  varnamelen:
-    ignore-decls:
-      - c *gin.Context

.vscode/settings.json

@@ -2,8 +2,5 @@
         "files.exclude": {
                 "**/node_modules": true,
                 "**/vendor": true
-        },
-        "gopls": {
-                "formatting.gofumpt": true,
         }
 }

.woodpecker.yml

@@ -4,7 +4,7 @@ pipeline:
     image: hub.javil.eu/budgeteer:dev
     pull: true
     commands:
-      - task ci
+      - task
 
   docker:
     image: plugins/docker

Taskfile.yml

@@ -33,7 +33,12 @@ tasks:
     sources:
       - ./go.mod
       - ./go.sum
-      - ./**/*.go
+      - ./cmd/budgeteer/*.go
+      - ./*.go
+      - ./config/*.go
+      - ./http/*.go
+      - ./jwt/*.go
+      - ./postgres/*.go
       - ./web/dist/**/*
       - ./postgres/schema/*
     generates:
@@ -47,25 +52,14 @@ tasks:
     desc: Build budgeteer in dev mode
     deps: [gomod, sqlc]
     cmds:
-      - go vet
-      - go fmt
-      - golangci-lint run
       - task: build
 
   build-prod:
     desc: Build budgeteer in prod mode
     deps: [gomod, sqlc, frontend]
     cmds:
-      - go vet
-      - go fmt
-      - golangci-lint run
       - task: build
 
-  ci:
-    desc: Run CI build
-    cmds:
-      - task: build-prod
-
   frontend:
     desc: Build vue frontend
     dir: web
@@ -91,8 +85,6 @@ tasks:
     desc: Build budgeeter:dev
     sources:
       - ./docker/Dockerfile
-      - ./docker/build.sh
-      - ./web/package.json
     cmds:
       - docker build -t {{.IMAGE_NAME}}:dev . -f docker/Dockerfile
       - docker push {{.IMAGE_NAME}}:dev

bcrypt/verifier.go

@@ -1,30 +1,23 @@
-package bcrypt
-
-import (
-	"fmt"
-
-	"golang.org/x/crypto/bcrypt"
-)
-
-// Verifier verifys passwords using Bcrypt.
-type Verifier struct{}
-
-// Verify verifys a Password.
-func (bv *Verifier) Verify(password string, hashOnDB string) error {
-	err := bcrypt.CompareHashAndPassword([]byte(hashOnDB), []byte(password))
-	if err != nil {
-		return fmt.Errorf("verify password: %w", err)
-	}
-
-	return nil
-}
-
-// Hash calculates a hash to be stored on the database.
-func (bv *Verifier) Hash(password string) (string, error) {
-	hash, err := bcrypt.GenerateFromPassword([]byte(password), bcrypt.DefaultCost)
-	if err != nil {
-		return "", fmt.Errorf("hash password: %w", err)
-	}
-
-	return string(hash), nil
-}
+package bcrypt
+
+import "golang.org/x/crypto/bcrypt"
+
+// Verifier verifys passwords using Bcrypt
+type Verifier struct {
+	cost int
+}
+
+// Verify verifys a Password
+func (bv *Verifier) Verify(password string, hashOnDb string) error {
+	return bcrypt.CompareHashAndPassword([]byte(hashOnDb), []byte(password))
+}
+
+// Hash calculates a hash to be stored on the database
+func (bv *Verifier) Hash(password string) (string, error) {
+	hash, err := bcrypt.GenerateFromPassword([]byte(password), bv.cost)
+	if err != nil {
+		return "", err
+	}
+
+	return string(hash[:]), nil
+}

cmd/budgeteer/main.go

@@ -1,16 +1,13 @@
 package main
 
 import (
-	"io/fs"
 	"log"
-	"net/http"
 
 	"git.javil.eu/jacob1123/budgeteer/bcrypt"
 	"git.javil.eu/jacob1123/budgeteer/config"
+	"git.javil.eu/jacob1123/budgeteer/http"
 	"git.javil.eu/jacob1123/budgeteer/jwt"
 	"git.javil.eu/jacob1123/budgeteer/postgres"
-	"git.javil.eu/jacob1123/budgeteer/server"
-	"git.javil.eu/jacob1123/budgeteer/web"
 )
 
 func main() {
@@ -19,24 +16,16 @@ func main() {
 		log.Fatalf("Could not load config: %v", err)
 	}
 
-	queries, err := postgres.Connect("pgx", cfg.DatabaseConnection)
+	q, err := postgres.Connect("pgx", cfg.DatabaseConnection)
 	if err != nil {
 		log.Fatalf("Failed connecting to DB: %v", err)
 	}
 
-	static, err := fs.Sub(web.Static, "dist")
-	if err != nil {
-		panic("couldn't open static files")
-	}
-
-	handler := &server.Handler{
-		Service: queries,
-		TokenVerifier: &jwt.TokenVerifier{
-			Secret: cfg.SessionSecret,
-		},
+	h := &http.Handler{
+		Service:             q,
+		TokenVerifier:       &jwt.TokenVerifier{},
 		CredentialsVerifier: &bcrypt.Verifier{},
-		StaticFS:            http.FS(static),
 	}
 
-	handler.Serve()
+	h.Serve()
 }

config/config.go

@@ -1,21 +1,19 @@
-package config
-
-import (
-	"os"
-)
-
-// Config contains all needed configurations.
-type Config struct {
-	DatabaseConnection string
-	SessionSecret      string
-}
-
-// LoadConfig from path.
-func LoadConfig() (*Config, error) {
-	configuration := Config{
-		DatabaseConnection: os.Getenv("BUDGETEER_DB"),
-		SessionSecret:      os.Getenv("BUDGETEER_SESSION_SECRET"),
-	}
-
-	return &configuration, nil
-}
+package config
+
+import (
+	"os"
+)
+
+// Config contains all needed configurations
+type Config struct {
+	DatabaseConnection string
+}
+
+// LoadConfig from path
+func LoadConfig() (*Config, error) {
+	configuration := Config{
+		DatabaseConnection: os.Getenv("BUDGETEER_DB"),
+	}
+
+	return &configuration, nil
+}

docker-compose.dev.yml

@@ -17,7 +17,6 @@ services:
                         - ~/.cache:/.cache
                 environment:
                         BUDGETEER_DB: postgres://budgeteer:budgeteer@db:5432/budgeteer
-                        BUDGETEER_SESSION_SECRET: random string for JWT authorization
                 depends_on:
                         - db
 

docker/Dockerfile

@@ -2,16 +2,15 @@ FROM alpine as godeps
 RUN apk add go
 RUN go install github.com/kyleconroy/sqlc/cmd/sqlc@latest
 RUN go install github.com/go-task/task/v3/cmd/task@latest
-RUN go install github.com/golangci/golangci-lint/cmd/golangci-lint@latest
 
 FROM alpine
 RUN apk add go
 RUN apk add nodejs yarn bash curl git git-perl tmux
 ADD docker/build.sh /
+COPY --from=godeps /root/go/bin/task /root/go/bin/sqlc /usr/local/bin/
 RUN yarn global add @vue/cli
 ENV PATH="/root/.yarn/bin/:${PATH}"
 WORKDIR /src
 ADD web/package.json /src/web/
 RUN yarn
-COPY --from=godeps /root/go/bin/task /root/go/bin/sqlc /root/go/bin/golangci-lint /usr/local/bin/
 CMD /build.sh

http/account.go

@@ -1,4 +1,4 @@
-package server
+package http
 
 import (
 	"net/http"

http/account_test.go

@@ -1,4 +1,4 @@
-package server
+package http
 
 import (
 	"encoding/json"
@@ -10,53 +10,47 @@ import (
 	"git.javil.eu/jacob1123/budgeteer/bcrypt"
 	"git.javil.eu/jacob1123/budgeteer/jwt"
 	"git.javil.eu/jacob1123/budgeteer/postgres"
-	txdb "github.com/DATA-DOG/go-txdb"
 	"github.com/gin-gonic/gin"
+
+	txdb "github.com/DATA-DOG/go-txdb"
 )
 
-func init() { //nolint:gochecknoinits
+func init() {
 	txdb.Register("pgtx", "pgx", "postgres://budgeteer_test:budgeteer_test@localhost:5432/budgeteer_test")
 }
 
-func TestRegisterUser(t *testing.T) { //nolint:funlen
-	t.Parallel()
-	database, err := postgres.Connect("pgtx", "example")
+func TestListTimezonesHandler(t *testing.T) {
+	db, err := postgres.Connect("pgtx", "example")
 	if err != nil {
 		t.Errorf("could not connect to db: %s", err)
 		return
 	}
 
 	h := Handler{
-		Service: database,
-		TokenVerifier: &jwt.TokenVerifier{
-			Secret: "this_is_my_demo_secret_for_unit_tests",
-		},
+		Service:             db,
+		TokenVerifier:       &jwt.TokenVerifier{},
 		CredentialsVerifier: &bcrypt.Verifier{},
 	}
 
-	recorder := httptest.NewRecorder()
-	context, engine := gin.CreateTestContext(recorder)
+	rr := httptest.NewRecorder()
+	c, engine := gin.CreateTestContext(rr)
 	h.LoadRoutes(engine)
 
 	t.Run("RegisterUser", func(t *testing.T) {
-		t.Parallel()
-		context.Request, err = http.NewRequest(
-			http.MethodPost,
-			"/api/v1/user/register",
-			strings.NewReader(`{"password":"pass","email":"info@example.com","name":"Test"}`))
+		c.Request, err = http.NewRequest(http.MethodPost, "/api/v1/user/register", strings.NewReader(`{"password":"pass","email":"info@example.com","name":"Test"}`))
 		if err != nil {
 			t.Errorf("error creating request: %s", err)
 			return
 		}
 
-		h.registerPost(context)
+		h.registerPost(c)
 
-		if recorder.Code != http.StatusOK {
-			t.Errorf("handler returned wrong status code: got %v want %v", recorder.Code, http.StatusOK)
+		if rr.Code != http.StatusOK {
+			t.Errorf("handler returned wrong status code: got %v want %v", rr.Code, http.StatusOK)
 		}
 
 		var response LoginResponse
-		err = json.NewDecoder(recorder.Body).Decode(&response)
+		err = json.NewDecoder(rr.Body).Decode(&response)
 		if err != nil {
 			t.Error(err.Error())
 			t.Error("Error registering")
@@ -67,14 +61,13 @@ func TestRegisterUser(t *testing.T) { //nolint:funlen
 	})
 
 	t.Run("GetTransactions", func(t *testing.T) {
-		t.Parallel()
-		context.Request, err = http.NewRequest(http.MethodGet, "/account/accountid/transactions", nil)
-		if recorder.Code != http.StatusOK {
-			t.Errorf("handler returned wrong status code: got %v want %v", recorder.Code, http.StatusOK)
+		c.Request, err = http.NewRequest(http.MethodGet, "/account/accountid/transactions", nil)
+		if rr.Code != http.StatusOK {
+			t.Errorf("handler returned wrong status code: got %v want %v", rr.Code, http.StatusOK)
 		}
 
 		var response TransactionsResponse
-		err = json.NewDecoder(recorder.Body).Decode(&response)
+		err = json.NewDecoder(rr.Body).Decode(&response)
 		if err != nil {
 			t.Error(err.Error())
 			t.Error("Error retreiving list of transactions.")

http/admin.go

@@ -1,4 +1,4 @@
-package server
+package http
 
 import (
 	"fmt"

http/autocomplete.go

@@ -1,6 +1,7 @@
-package server
+package http
 
 import (
+	"fmt"
 	"net/http"
 
 	"git.javil.eu/jacob1123/budgeteer/postgres"
@@ -12,7 +13,7 @@ func (h *Handler) autocompleteCategories(c *gin.Context) {
 	budgetID := c.Param("budgetid")
 	budgetUUID, err := uuid.Parse(budgetID)
 	if err != nil {
-		c.AbortWithStatusJSON(http.StatusBadRequest, ErrorResponse{"budgetid missing from URL"})
+		c.AbortWithError(http.StatusBadRequest, fmt.Errorf("budgetid missing from URL"))
 		return
 	}
 
@@ -34,7 +35,7 @@ func (h *Handler) autocompletePayee(c *gin.Context) {
 	budgetID := c.Param("budgetid")
 	budgetUUID, err := uuid.Parse(budgetID)
 	if err != nil {
-		c.AbortWithStatusJSON(http.StatusBadRequest, ErrorResponse{"budgetid missing from URL"})
+		c.AbortWithError(http.StatusBadRequest, fmt.Errorf("budgetid missing from URL"))
 		return
 	}
 

http/budget.go

@@ -1,8 +1,10 @@
-package server
+package http
 
 import (
+	"fmt"
 	"net/http"
 
+	"git.javil.eu/jacob1123/budgeteer"
 	"github.com/gin-gonic/gin"
 )
 
@@ -12,17 +14,18 @@ type newBudgetInformation struct {
 
 func (h *Handler) newBudget(c *gin.Context) {
 	var newBudget newBudgetInformation
-	if err := c.BindJSON(&newBudget); err != nil {
+	err := c.BindJSON(&newBudget)
+	if err != nil {
 		c.AbortWithError(http.StatusNotAcceptable, err)
 		return
 	}
 
 	if newBudget.Name == "" {
-		c.AbortWithStatusJSON(http.StatusBadRequest, ErrorResponse{"budget name is required"})
+		c.AbortWithError(http.StatusNotAcceptable, fmt.Errorf("Budget name is needed"))
 		return
 	}
 
-	userID := MustGetToken(c).GetID()
+	userID := c.MustGet("token").(budgeteer.Token).GetID()
 	budget, err := h.Service.NewBudget(c.Request.Context(), newBudget.Name, userID)
 	if err != nil {
 		c.AbortWithError(http.StatusInternalServerError, err)

http/budgeting.go

@@ -1,4 +1,4 @@
-package server
+package http
 
 import (
 	"fmt"
@@ -55,7 +55,7 @@ func (h *Handler) budgetingForMonth(c *gin.Context) {
 	budgetID := c.Param("budgetid")
 	budgetUUID, err := uuid.Parse(budgetID)
 	if err != nil {
-		c.AbortWithStatusJSON(http.StatusBadRequest, ErrorResponse{"budgetid missing from URL"})
+		c.AbortWithError(http.StatusBadRequest, fmt.Errorf("budgetid missing from URL"))
 		return
 	}
 
@@ -80,25 +80,16 @@ func (h *Handler) budgetingForMonth(c *gin.Context) {
 	firstOfNextMonth := firstOfMonth.AddDate(0, 1, 0)
 	cumultativeBalances, err := h.Service.GetCumultativeBalances(c.Request.Context(), budgetUUID)
 	if err != nil {
-		c.AbortWithStatusJSON(http.StatusInternalServerError, ErrorResponse{fmt.Sprintf("error loading balances: %s", err)})
+		c.AbortWithError(http.StatusInternalServerError, fmt.Errorf("load balances: %w", err))
 		return
 	}
 
-	categoriesWithBalance, moneyUsed := h.calculateBalances(
-		budget, firstOfNextMonth, firstOfMonth, categories, cumultativeBalances)
+	// skip everything in the future
+	categoriesWithBalance, moneyUsed, err := h.calculateBalances(c, budget, firstOfNextMonth, firstOfMonth, categories, cumultativeBalances)
+	if err != nil {
+		return
+	}
 
-	availableBalance := h.getAvailableBalance(categories, budget, moneyUsed, cumultativeBalances, firstOfNextMonth)
-
-	data := struct {
-		Categories       []CategoryWithBalance
-		AvailableBalance postgres.Numeric
-	}{categoriesWithBalance, availableBalance}
-	c.JSON(http.StatusOK, data)
-}
-
-func (*Handler) getAvailableBalance(categories []postgres.GetCategoriesRow, budget postgres.Budget,
-	moneyUsed postgres.Numeric, cumultativeBalances []postgres.GetCumultativeBalancesRow,
-	firstOfNextMonth time.Time) postgres.Numeric {
 	availableBalance := postgres.NewZeroNumeric()
 	for _, cat := range categories {
 		if cat.ID != budget.IncomeCategoryID {
@@ -118,14 +109,20 @@ func (*Handler) getAvailableBalance(categories []postgres.GetCategoriesRow, budg
 			availableBalance = availableBalance.Add(bal.Transactions)
 		}
 	}
-	return availableBalance
+
+	data := struct {
+		Categories       []CategoryWithBalance
+		AvailableBalance postgres.Numeric
+	}{categoriesWithBalance, availableBalance}
+	c.JSON(http.StatusOK, data)
+
 }
 
 func (h *Handler) budgeting(c *gin.Context) {
 	budgetID := c.Param("budgetid")
 	budgetUUID, err := uuid.Parse(budgetID)
 	if err != nil {
-		c.AbortWithStatusJSON(http.StatusBadRequest, ErrorResponse{"budgetid missing from URL"})
+		c.AbortWithError(http.StatusBadRequest, fmt.Errorf("budgetid missing from URL"))
 		return
 	}
 
@@ -149,9 +146,7 @@ func (h *Handler) budgeting(c *gin.Context) {
 	c.JSON(http.StatusOK, data)
 }
 
-func (h *Handler) calculateBalances(budget postgres.Budget,
-	firstOfNextMonth time.Time, firstOfMonth time.Time, categories []postgres.GetCategoriesRow,
-	cumultativeBalances []postgres.GetCumultativeBalancesRow) ([]CategoryWithBalance, postgres.Numeric) {
+func (h *Handler) calculateBalances(c *gin.Context, budget postgres.Budget, firstOfNextMonth time.Time, firstOfMonth time.Time, categories []postgres.GetCategoriesRow, cumultativeBalances []postgres.GetCumultativeBalancesRow) ([]CategoryWithBalance, postgres.Numeric, error) {
 	categoriesWithBalance := []CategoryWithBalance{}
 	hiddenCategory := CategoryWithBalance{
 		GetCategoriesRow: &postgres.GetCategoriesRow{
@@ -167,9 +162,39 @@ func (h *Handler) calculateBalances(budget postgres.Budget,
 	moneyUsed := postgres.NewZeroNumeric()
 	for i := range categories {
 		cat := &categories[i]
+		categoryWithBalance := CategoryWithBalance{
+			GetCategoriesRow:   cat,
+			Available:          postgres.NewZeroNumeric(),
+			AvailableLastMonth: postgres.NewZeroNumeric(),
+			Activity:           postgres.NewZeroNumeric(),
+			Assigned:           postgres.NewZeroNumeric(),
+		}
+		for _, bal := range cumultativeBalances {
+			if bal.CategoryID != cat.ID {
+				continue
+			}
+
+			if !bal.Date.Before(firstOfNextMonth) {
+				continue
+			}
+
+			moneyUsed = moneyUsed.Sub(bal.Assignments)
+			categoryWithBalance.Available = categoryWithBalance.Available.Add(bal.Assignments)
+			categoryWithBalance.Available = categoryWithBalance.Available.Add(bal.Transactions)
+			if !categoryWithBalance.Available.IsPositive() && bal.Date.Before(firstOfMonth) {
+				moneyUsed = moneyUsed.Add(categoryWithBalance.Available)
+				categoryWithBalance.Available = postgres.NewZeroNumeric()
+			}
+
+			if bal.Date.Before(firstOfMonth) {
+				categoryWithBalance.AvailableLastMonth = categoryWithBalance.Available
+			} else if bal.Date.Before(firstOfNextMonth) {
+				categoryWithBalance.Activity = bal.Transactions
+				categoryWithBalance.Assigned = bal.Assignments
+			}
+		}
+
 		// do not show hidden categories
-		categoryWithBalance := h.CalculateCategoryBalances(cat, cumultativeBalances,
-			firstOfNextMonth, &moneyUsed, firstOfMonth, hiddenCategory, budget)
 		if cat.Group == "Hidden Categories" {
 			hiddenCategory.Available = hiddenCategory.Available.Add(categoryWithBalance.Available)
 			hiddenCategory.AvailableLastMonth = hiddenCategory.AvailableLastMonth.Add(categoryWithBalance.AvailableLastMonth)
@@ -187,45 +212,5 @@ func (h *Handler) calculateBalances(budget postgres.Budget,
 
 	categoriesWithBalance = append(categoriesWithBalance, hiddenCategory)
 
-	return categoriesWithBalance, moneyUsed
-}
-
-func (*Handler) CalculateCategoryBalances(cat *postgres.GetCategoriesRow,
-	cumultativeBalances []postgres.GetCumultativeBalancesRow, firstOfNextMonth time.Time,
-	moneyUsed *postgres.Numeric, firstOfMonth time.Time, hiddenCategory CategoryWithBalance,
-	budget postgres.Budget) CategoryWithBalance {
-	categoryWithBalance := CategoryWithBalance{
-		GetCategoriesRow:   cat,
-		Available:          postgres.NewZeroNumeric(),
-		AvailableLastMonth: postgres.NewZeroNumeric(),
-		Activity:           postgres.NewZeroNumeric(),
-		Assigned:           postgres.NewZeroNumeric(),
-	}
-	for _, bal := range cumultativeBalances {
-		if bal.CategoryID != cat.ID {
-			continue
-		}
-
-		// skip everything in the future
-		if !bal.Date.Before(firstOfNextMonth) {
-			continue
-		}
-
-		*moneyUsed = moneyUsed.Sub(bal.Assignments)
-		categoryWithBalance.Available = categoryWithBalance.Available.Add(bal.Assignments)
-		categoryWithBalance.Available = categoryWithBalance.Available.Add(bal.Transactions)
-		if !categoryWithBalance.Available.IsPositive() && bal.Date.Before(firstOfMonth) {
-			*moneyUsed = moneyUsed.Add(categoryWithBalance.Available)
-			categoryWithBalance.Available = postgres.NewZeroNumeric()
-		}
-
-		if bal.Date.Before(firstOfMonth) {
-			categoryWithBalance.AvailableLastMonth = categoryWithBalance.Available
-		} else if bal.Date.Before(firstOfNextMonth) {
-			categoryWithBalance.Activity = bal.Transactions
-			categoryWithBalance.Assigned = bal.Assignments
-		}
-	}
-
-	return categoryWithBalance
+	return categoriesWithBalance, moneyUsed, nil
 }

http/dashboard.go

@@ -1,14 +1,15 @@
-package server
+package http
 
 import (
 	"net/http"
 
+	"git.javil.eu/jacob1123/budgeteer"
 	"git.javil.eu/jacob1123/budgeteer/postgres"
 	"github.com/gin-gonic/gin"
 )
 
 func (h *Handler) dashboard(c *gin.Context) {
-	userID := MustGetToken(c).GetID()
+	userID := c.MustGet("token").(budgeteer.Token).GetID()
 	budgets, err := h.Service.GetBudgetsForUser(c.Request.Context(), userID)
 	if err != nil {
 		return

http/http.go

@@ -1,4 +1,4 @@
-package server
+package http
 
 import (
 	"errors"
@@ -11,10 +11,12 @@ import (
 	"git.javil.eu/jacob1123/budgeteer"
 	"git.javil.eu/jacob1123/budgeteer/bcrypt"
 	"git.javil.eu/jacob1123/budgeteer/postgres"
+	"git.javil.eu/jacob1123/budgeteer/web"
+
 	"github.com/gin-gonic/gin"
 )
 
-// Handler handles incoming requests.
+// Handler handles incoming requests
 type Handler struct {
 	Service             *postgres.Database
 	TokenVerifier       budgeteer.TokenVerifier
@@ -22,22 +24,25 @@ type Handler struct {
 	StaticFS            http.FileSystem
 }
 
-// Serve starts the http server.
+const (
+	expiration = 72
+)
+
+// Serve starts the http server
 func (h *Handler) Serve() {
 	router := gin.Default()
 	h.LoadRoutes(router)
-
-	if err := router.Run(":1323"); err != nil {
-		panic(err)
-	}
+	router.Run(":1323")
 }
 
-type ErrorResponse struct {
-	Message string
-}
-
-// LoadRoutes initializes all the routes.
+// LoadRoutes initializes all the routes
 func (h *Handler) LoadRoutes(router *gin.Engine) {
+	static, err := fs.Sub(web.Static, "dist")
+	if err != nil {
+		panic("couldn't open static files")
+	}
+	h.StaticFS = http.FS(static)
+
 	router.Use(enableCachingForStaticFiles())
 	router.NoRoute(h.ServeStatic)
 
@@ -76,7 +81,6 @@ func (h *Handler) LoadRoutes(router *gin.Engine) {
 	transaction.POST("/new", h.newTransaction)
 	transaction.POST("/:transactionid", h.newTransaction)
 }
-
 func (h *Handler) ServeStatic(c *gin.Context) {
 	h.ServeStaticFile(c, c.Request.URL.Path)
 }
@@ -104,11 +108,7 @@ func (h *Handler) ServeStaticFile(c *gin.Context, fullPath string) {
 		return
 	}
 
-	if file, ok := file.(io.ReadSeeker); ok {
-		http.ServeContent(c.Writer, c.Request, stat.Name(), stat.ModTime(), file)
-	} else {
-		panic("File does not implement ReadSeeker")
-	}
+	http.ServeContent(c.Writer, c.Request, stat.Name(), stat.ModTime(), file.(io.ReadSeeker))
 }
 
 func enableCachingForStaticFiles() gin.HandlerFunc {

http/json-date.go

@@ -1,36 +1,29 @@
-package server
+package http
 
 import (
 	"encoding/json"
-	"fmt"
 	"strings"
 	"time"
 )
 
 type JSONDate time.Time
 
-// UnmarshalJSON parses the JSONDate from a JSON input.
+// Implement Marshaler and Unmarshaler interface
 func (j *JSONDate) UnmarshalJSON(b []byte) error {
 	s := strings.Trim(string(b), "\"")
 	t, err := time.Parse("2006-01-02", s)
 	if err != nil {
-		return fmt.Errorf("parse date: %w", err)
+		return err
 	}
 	*j = JSONDate(t)
 	return nil
 }
 
-// MarshalJSON converts the JSONDate to a JSON in ISO format.
 func (j JSONDate) MarshalJSON() ([]byte, error) {
-	result, err := json.Marshal(time.Time(j))
-	if err != nil {
-		return nil, fmt.Errorf("marshal date: %w", err)
-	}
-
-	return result, nil
+	return json.Marshal(time.Time(j))
 }
 
-// Format formats the time using the regular time.Time mechanics..
+// Maybe a Format function for printing your date
 func (j JSONDate) Format(s string) string {
 	t := time.Time(j)
 	return t.Format(s)

http/session.go

@@ -1,4 +1,4 @@
-package server
+package http
 
 import (
 	"context"
@@ -8,34 +8,18 @@ import (
 	"git.javil.eu/jacob1123/budgeteer"
 	"git.javil.eu/jacob1123/budgeteer/postgres"
 	"github.com/gin-gonic/gin"
-	"github.com/google/uuid"
 )
 
-const (
-	HeaderName = "Authorization"
-	Bearer     = "Bearer "
-	ParamName  = "token"
-)
-
-func MustGetToken(c *gin.Context) budgeteer.Token { //nolint:ireturn
-	token := c.MustGet(ParamName)
-	if token, ok := token.(budgeteer.Token); !ok {
-		return token
-	}
-
-	panic("Token is not a valid Token")
-}
-
-func (h *Handler) verifyLogin(c *gin.Context) (budgeteer.Token, *ErrorResponse) { //nolint:ireturn
-	tokenString := c.GetHeader(HeaderName)
-	if len(tokenString) <= len(Bearer) {
-		return nil, &ErrorResponse{"no authorization header supplied"}
+func (h *Handler) verifyLogin(c *gin.Context) (budgeteer.Token, error) {
+	tokenString := c.GetHeader("Authorization")
+	if len(tokenString) < 8 {
+		return nil, fmt.Errorf("no authorization header supplied")
 	}
 
 	tokenString = tokenString[7:]
 	token, err := h.TokenVerifier.VerifyToken(tokenString)
 	if err != nil {
-		return nil, &ErrorResponse{fmt.Sprintf("verify token '%s': %s", tokenString, err)}
+		return nil, fmt.Errorf("verify token '%s': %w", tokenString, err)
 	}
 
 	return token, nil
@@ -44,12 +28,12 @@ func (h *Handler) verifyLogin(c *gin.Context) (budgeteer.Token, *ErrorResponse)
 func (h *Handler) verifyLoginWithForbidden(c *gin.Context) {
 	token, err := h.verifyLogin(c)
 	if err != nil {
-		// c.Header("WWW-Authenticate", "Bearer")
-		c.AbortWithStatusJSON(http.StatusForbidden, err)
+		//c.Header("WWW-Authenticate", "Bearer")
+		c.AbortWithError(http.StatusForbidden, err)
 		return
 	}
 
-	c.Set(ParamName, token)
+	c.Set("token", token)
 	c.Next()
 }
 
@@ -61,7 +45,7 @@ func (h *Handler) verifyLoginWithRedirect(c *gin.Context) {
 		return
 	}
 
-	c.Set(ParamName, token)
+	c.Set("token", token)
 	c.Next()
 }
 
@@ -88,19 +72,19 @@ func (h *Handler) loginPost(c *gin.Context) {
 		return
 	}
 
-	token, err := h.TokenVerifier.CreateToken(&user)
+	t, err := h.TokenVerifier.CreateToken(&user)
 	if err != nil {
 		c.AbortWithError(http.StatusUnauthorized, err)
 	}
 
-	go h.UpdateLastLogin(user.ID)
+	go h.Service.UpdateLastLogin(context.Background(), user.ID)
 
 	budgets, err := h.Service.GetBudgetsForUser(c.Request.Context(), user.ID)
 	if err != nil {
 		return
 	}
 
-	c.JSON(http.StatusOK, LoginResponse{token, user, budgets})
+	c.JSON(http.StatusOK, LoginResponse{t, user, budgets})
 }
 
 type LoginResponse struct {
@@ -117,20 +101,16 @@ type registerInformation struct {
 
 func (h *Handler) registerPost(c *gin.Context) {
 	var register registerInformation
-	err := c.BindJSON(&register)
-	if err != nil {
-		c.AbortWithStatusJSON(http.StatusBadRequest, ErrorResponse{"error parsing body"})
-		return
-	}
+	c.BindJSON(&register)
 
 	if register.Email == "" || register.Password == "" || register.Name == "" {
-		c.AbortWithStatusJSON(http.StatusBadRequest, ErrorResponse{"e-mail, password and name are required"})
+		c.AbortWithError(http.StatusBadRequest, fmt.Errorf("e-mail, password and name are required"))
 		return
 	}
 
-	_, err = h.Service.GetUserByUsername(c.Request.Context(), register.Email)
+	_, err := h.Service.GetUserByUsername(c.Request.Context(), register.Email)
 	if err == nil {
-		c.AbortWithStatusJSON(http.StatusBadRequest, ErrorResponse{"email is already taken"})
+		c.AbortWithError(http.StatusBadRequest, fmt.Errorf("email is already taken"))
 		return
 	}
 
@@ -150,24 +130,17 @@ func (h *Handler) registerPost(c *gin.Context) {
 		c.AbortWithError(http.StatusInternalServerError, err)
 	}
 
-	token, err := h.TokenVerifier.CreateToken(&user)
+	t, err := h.TokenVerifier.CreateToken(&user)
 	if err != nil {
 		c.AbortWithError(http.StatusUnauthorized, err)
 	}
 
-	go h.UpdateLastLogin(user.ID)
+	go h.Service.UpdateLastLogin(context.Background(), user.ID)
 
 	budgets, err := h.Service.GetBudgetsForUser(c.Request.Context(), user.ID)
 	if err != nil {
 		return
 	}
 
-	c.JSON(http.StatusOK, LoginResponse{token, user, budgets})
-}
-
-func (h *Handler) UpdateLastLogin(userID uuid.UUID) {
-	_, err := h.Service.UpdateLastLogin(context.Background(), userID)
-	if err != nil {
-		fmt.Printf("Error updating last login: %s", err)
-	}
+	c.JSON(http.StatusOK, LoginResponse{t, user, budgets})
 }

http/transaction.go

@@ -1,4 +1,4 @@
-package server
+package http
 
 import (
 	"fmt"
@@ -22,8 +22,8 @@ type NewTransactionPayload struct {
 	} `json:"category"`
 	Memo      string    `json:"memo"`
 	Amount    string    `json:"amount"`
-	BudgetID  uuid.UUID `json:"budgetId"`
-	AccountID uuid.UUID `json:"accountId"`
+	BudgetID  uuid.UUID `json:"budget_id"`
+	AccountID uuid.UUID `json:"account_id"`
 	State     string    `json:"state"`
 }
 
@@ -31,16 +31,18 @@ func (h *Handler) newTransaction(c *gin.Context) {
 	var payload NewTransactionPayload
 	err := c.BindJSON(&payload)
 	if err != nil {
-		c.AbortWithError(http.StatusBadRequest, err)
+		c.AbortWithError(http.StatusInternalServerError, err)
 		return
 	}
 
 	amount := postgres.Numeric{}
-	err = amount.Set(payload.Amount)
+	amount.Set(payload.Amount)
+
+	/*transactionUUID, err := getNullUUIDFromParam(c, "transactionid")
 	if err != nil {
-		c.AbortWithError(http.StatusBadRequest, fmt.Errorf("amount: %w", err))
+		c.AbortWithError(http.StatusInternalServerError, fmt.Errorf("parse transaction id: %w", err))
 		return
-	}
+	}*/
 
 	payeeID := payload.Payee.ID
 	if !payeeID.Valid && payload.Payee.Name != "" {
@@ -59,20 +61,45 @@ func (h *Handler) newTransaction(c *gin.Context) {
 		}
 	}
 
-	newTransaction := postgres.CreateTransactionParams{
+	//if !transactionUUID.Valid {
+	new := postgres.CreateTransactionParams{
 		Memo:       payload.Memo,
 		Date:       time.Time(payload.Date),
 		Amount:     amount,
 		AccountID:  payload.AccountID,
-		PayeeID:    payeeID,
-		CategoryID: payload.Category.ID,
+		PayeeID:    payeeID,             //TODO handle new payee
+		CategoryID: payload.Category.ID, //TODO handle new category
 		Status:     postgres.TransactionStatus(payload.State),
 	}
-	transaction, err := h.Service.CreateTransaction(c.Request.Context(), newTransaction)
+	transaction, err := h.Service.CreateTransaction(c.Request.Context(), new)
 	if err != nil {
 		c.AbortWithError(http.StatusInternalServerError, fmt.Errorf("create transaction: %w", err))
 		return
 	}
 
 	c.JSON(http.StatusOK, transaction)
+	//	}
+	/*
+		_, delete := c.GetPostForm("delete")
+		if delete {
+			err = h.Service.DeleteTransaction(c.Request.Context(), transactionUUID.UUID)
+			if err != nil {
+				c.AbortWithError(http.StatusInternalServerError, fmt.Errorf("delete transaction: %w", err))
+			}
+			return
+		}
+
+		update := postgres.UpdateTransactionParams{
+			ID:         transactionUUID.UUID,
+			Memo:       payload.Memo,
+			Date:       time.Time(payload.Date),
+			Amount:     amount,
+			AccountID:  transactionAccountID,
+			PayeeID:    payload.Payee.ID,    //TODO handle new payee
+			CategoryID: payload.Category.ID, //TODO handle new category
+		}
+		err = h.Service.UpdateTransaction(c.Request.Context(), update)
+		if err != nil {
+			c.AbortWithError(http.StatusInternalServerError, fmt.Errorf("update transaction: %w", err))
+		}*/
 }

http/util.go

@@ -0,0 +1,56 @@
+package http
+
+import (
+	"fmt"
+
+	"github.com/gin-gonic/gin"
+	"github.com/google/uuid"
+)
+
+func getUUID(c *gin.Context, name string) (uuid.UUID, error) {
+	value, succ := c.GetPostForm(name)
+	if !succ {
+		return uuid.UUID{}, fmt.Errorf("not set")
+	}
+
+	id, err := uuid.Parse(value)
+	if err != nil {
+		return uuid.UUID{}, fmt.Errorf("not a valid uuid: %w", err)
+	}
+
+	return id, nil
+}
+
+func getNullUUIDFromParam(c *gin.Context, name string) (uuid.NullUUID, error) {
+	value := c.Param(name)
+	if value == "" {
+		return uuid.NullUUID{}, nil
+	}
+
+	id, err := uuid.Parse(value)
+	if err != nil {
+		return uuid.NullUUID{}, fmt.Errorf("not a valid uuid: %w", err)
+	}
+
+	return uuid.NullUUID{
+		UUID:  id,
+		Valid: true,
+	}, nil
+}
+
+func getNullUUIDFromForm(c *gin.Context, name string) (uuid.NullUUID, error) {
+	value, succ := c.GetPostForm(name)
+	if !succ || value == "" {
+		return uuid.NullUUID{}, nil
+	}
+
+	id, err := uuid.Parse(value)
+	if err != nil {
+		return uuid.NullUUID{}, fmt.Errorf("not a valid uuid: %w", err)
+	}
+
+	return uuid.NullUUID{
+		UUID:  id,
+		Valid: true,
+	}, nil
+}

http/ynab-import.go

@@ -1,6 +1,7 @@
-package server
+package http
 
 import (
+	"fmt"
 	"net/http"
 
 	"git.javil.eu/jacob1123/budgeteer/postgres"
@@ -11,7 +12,7 @@ import (
 func (h *Handler) importYNAB(c *gin.Context) {
 	budgetID, succ := c.Params.Get("budgetid")
 	if !succ {
-		c.AbortWithStatusJSON(http.StatusBadRequest, ErrorResponse{"no budget_id specified"})
+		c.AbortWithError(http.StatusBadRequest, fmt.Errorf("no budget_id specified"))
 		return
 	}
 
@@ -39,7 +40,7 @@ func (h *Handler) importYNAB(c *gin.Context) {
 		return
 	}
 
-	err = ynab.ImportTransactions(c.Request.Context(), transactions)
+	err = ynab.ImportTransactions(transactions)
 	if err != nil {
 		c.AbortWithError(http.StatusInternalServerError, err)
 		return
@@ -57,7 +58,7 @@ func (h *Handler) importYNAB(c *gin.Context) {
 		return
 	}
 
-	err = ynab.ImportAssignments(c.Request.Context(), assignments)
+	err = ynab.ImportAssignments(assignments)
 	if err != nil {
 		c.AbortWithError(http.StatusInternalServerError, err)
 		return

jwt/login.go

@@ -10,12 +10,11 @@ import (
 	"github.com/google/uuid"
 )
 
-// TokenVerifier verifies Tokens.
+// TokenVerifier verifies Tokens
 type TokenVerifier struct {
-	Secret string
 }
 
-// Token contains everything to authenticate a user.
+// Token contains everything to authenticate a user
 type Token struct {
 	username string
 	name     string
@@ -25,9 +24,10 @@ type Token struct {
 
 const (
 	expiration = 72
+	secret     = "uditapbzuditagscwxuqdflgzpbu´ßiaefnlmzeßtrubiadern"
 )
 
-// CreateToken creates a new token from username and name.
+// CreateToken creates a new token from username and name
 func (tv *TokenVerifier) CreateToken(user *postgres.User) (string, error) {
 	token := jwt.NewWithClaims(jwt.SigningMethodHS256, jwt.MapClaims{
 		"usr":  user.Email,
@@ -37,27 +37,21 @@ func (tv *TokenVerifier) CreateToken(user *postgres.User) (string, error) {
 	})
 
 	// Generate encoded token and send it as response.
-	t, err := token.SignedString([]byte(tv.Secret))
+	t, err := token.SignedString([]byte(secret))
 	if err != nil {
-		return "", fmt.Errorf("create token: %w", err)
+		return "", err
 	}
 
 	return t, nil
 }
 
-var (
-	ErrUnexpectedSigningMethod = fmt.Errorf("unexpected signing method")
-	ErrInvalidToken            = fmt.Errorf("token is invalid")
-	ErrTokenExpired            = fmt.Errorf("token has expired")
-)
-
-// VerifyToken verifys a given string-token.
-func (tv *TokenVerifier) VerifyToken(tokenString string) (budgeteer.Token, error) { //nolint:ireturn
+// VerifyToken verifys a given string-token
+func (tv *TokenVerifier) VerifyToken(tokenString string) (budgeteer.Token, error) {
 	token, err := jwt.Parse(tokenString, func(token *jwt.Token) (interface{}, error) {
 		if _, ok := token.Method.(*jwt.SigningMethodHMAC); !ok {
-			return nil, fmt.Errorf("method '%v': %w", token.Header["alg"], ErrUnexpectedSigningMethod)
+			return nil, fmt.Errorf("Unexpected signing method: %v", token.Header["alg"])
 		}
-		return []byte(tv.Secret), nil
+		return []byte(secret), nil
 	})
 	if err != nil {
 		return nil, fmt.Errorf("parse jwt: %w", err)
@@ -68,7 +62,7 @@ func (tv *TokenVerifier) VerifyToken(tokenString string) (budgeteer.Token, error
 		return nil, fmt.Errorf("verify jwt: %w", err)
 	}
 
-	tkn := &Token{ //nolint:forcetypeassert
+	tkn := &Token{
 		username: claims["usr"].(string),
 		name:     claims["name"].(string),
 		expiry:   claims["exp"].(float64),
@@ -79,16 +73,16 @@ func (tv *TokenVerifier) VerifyToken(tokenString string) (budgeteer.Token, error
 
 func verifyToken(token *jwt.Token) (jwt.MapClaims, error) {
 	if !token.Valid {
-		return nil, ErrInvalidToken
+		return nil, fmt.Errorf("Token is not valid")
 	}
 
 	claims, ok := token.Claims.(jwt.MapClaims)
 	if !ok {
-		return nil, ErrInvalidToken
+		return nil, fmt.Errorf("Claims are not of Type MapClaims")
 	}
 
 	if !claims.VerifyExpiresAt(time.Now().Unix(), true) {
-		return nil, ErrTokenExpired
+		return nil, fmt.Errorf("Claims have expired")
 	}
 
 	return claims, nil

postgres/budgetservice.go

@@ -8,15 +8,11 @@ import (
 	"github.com/google/uuid"
 )
 
-// NewBudget creates a budget and adds it to the current user.
+// NewBudget creates a budget and adds it to the current user
 func (s *Database) NewBudget(context context.Context, name string, userID uuid.UUID) (*Budget, error) {
 	tx, err := s.BeginTx(context, &sql.TxOptions{})
-	if err != nil {
-		return nil, fmt.Errorf("begin transaction: %w", err)
-	}
-
-	transaction := s.WithTx(tx)
-	budget, err := transaction.CreateBudget(context, CreateBudgetParams{
+	q := s.WithTx(tx)
+	budget, err := q.CreateBudget(context, CreateBudgetParams{
 		Name:             name,
 		IncomeCategoryID: uuid.New(),
 	})
@@ -25,12 +21,12 @@ func (s *Database) NewBudget(context context.Context, name string, userID uuid.U
 	}
 
 	ub := LinkBudgetToUserParams{UserID: userID, BudgetID: budget.ID}
-	_, err = transaction.LinkBudgetToUser(context, ub)
+	_, err = q.LinkBudgetToUser(context, ub)
 	if err != nil {
 		return nil, fmt.Errorf("link budget to user: %w", err)
 	}
 
-	group, err := transaction.CreateCategoryGroup(context, CreateCategoryGroupParams{
+	group, err := q.CreateCategoryGroup(context, CreateCategoryGroupParams{
 		Name:     "Inflow",
 		BudgetID: budget.ID,
 	})
@@ -38,7 +34,7 @@ func (s *Database) NewBudget(context context.Context, name string, userID uuid.U
 		return nil, fmt.Errorf("create inflow category_group: %w", err)
 	}
 
-	cat, err := transaction.CreateCategory(context, CreateCategoryParams{
+	cat, err := q.CreateCategory(context, CreateCategoryParams{
 		Name:            "Ready to Assign",
 		CategoryGroupID: group.ID,
 	})
@@ -46,7 +42,7 @@ func (s *Database) NewBudget(context context.Context, name string, userID uuid.U
 		return nil, fmt.Errorf("create ready to assign category: %w", err)
 	}
 
-	err = transaction.SetInflowCategory(context, SetInflowCategoryParams{
+	err = q.SetInflowCategory(context, SetInflowCategoryParams{
 		IncomeCategoryID: cat.ID,
 		ID:               budget.ID,
 	})
@@ -54,10 +50,7 @@ func (s *Database) NewBudget(context context.Context, name string, userID uuid.U
 		return nil, fmt.Errorf("set inflow category: %w", err)
 	}
 
-	err = tx.Commit()
-	if err != nil {
-		return nil, fmt.Errorf("commit: %w", err)
-	}
+	tx.Commit()
 
 	return &budget, nil
 }

postgres/conn.go

@@ -5,7 +5,7 @@ import (
 	"embed"
 	"fmt"
 
-	_ "github.com/jackc/pgx/v4/stdlib" // needed for pg connection
+	_ "github.com/jackc/pgx/v4/stdlib"
 	"github.com/pressly/goose/v3"
 )
 
@@ -17,7 +17,7 @@ type Database struct {
 	*sql.DB
 }
 
-// Connect connects to a database.
+// Connect to a database
 func Connect(typ string, connString string) (*Database, error) {
 	conn, err := sql.Open(typ, connString)
 	if err != nil {

postgres/numeric.go

@@ -45,7 +45,7 @@ func (n Numeric) IsZero() bool {
 
 func (n Numeric) MatchExp(exp int32) Numeric {
 	diffExp := n.Exp - exp
-	factor := big.NewInt(0).Exp(big.NewInt(10), big.NewInt(int64(diffExp)), nil) //nolint:gomnd
+	factor := big.NewInt(0).Exp(big.NewInt(10), big.NewInt(int64(diffExp)), nil)
 	return Numeric{pgtype.Numeric{
 		Exp:    exp,
 		Int:    big.NewInt(0).Mul(n.Int, factor),
@@ -54,13 +54,13 @@ func (n Numeric) MatchExp(exp int32) Numeric {
 	}}
 }
 
-func (n Numeric) Sub(other Numeric) Numeric {
+func (n Numeric) Sub(o Numeric) Numeric {
 	left := n
-	right := other
-	if n.Exp < other.Exp {
-		right = other.MatchExp(n.Exp)
-	} else if n.Exp > other.Exp {
-		left = n.MatchExp(other.Exp)
+	right := o
+	if n.Exp < o.Exp {
+		right = o.MatchExp(n.Exp)
+	} else if n.Exp > o.Exp {
+		left = n.MatchExp(o.Exp)
 	}
 
 	if left.Exp == right.Exp {
@@ -72,14 +72,13 @@ func (n Numeric) Sub(other Numeric) Numeric {
 
 	panic("Cannot subtract with different exponents")
 }
-
-func (n Numeric) Add(other Numeric) Numeric {
+func (n Numeric) Add(o Numeric) Numeric {
 	left := n
-	right := other
-	if n.Exp < other.Exp {
-		right = other.MatchExp(n.Exp)
-	} else if n.Exp > other.Exp {
-		left = n.MatchExp(other.Exp)
+	right := o
+	if n.Exp < o.Exp {
+		right = o.MatchExp(n.Exp)
+	} else if n.Exp > o.Exp {
+		left = n.MatchExp(o.Exp)
 	}
 
 	if left.Exp == right.Exp {

postgres/ynab-import.go

@@ -13,6 +13,7 @@ import (
 )
 
 type YNABImport struct {
+	Context        context.Context
 	accounts       []Account
 	payees         []Payee
 	categories     []GetCategoriesRow
@@ -21,70 +22,73 @@ type YNABImport struct {
 	budgetID       uuid.UUID
 }
 
-func NewYNABImport(context context.Context, queries *Queries, budgetID uuid.UUID) (*YNABImport, error) {
-	accounts, err := queries.GetAccounts(context, budgetID)
+func NewYNABImport(context context.Context, q *Queries, budgetID uuid.UUID) (*YNABImport, error) {
+	accounts, err := q.GetAccounts(context, budgetID)
 	if err != nil {
 		return nil, err
 	}
 
-	payees, err := queries.GetPayees(context, budgetID)
+	payees, err := q.GetPayees(context, budgetID)
 	if err != nil {
 		return nil, err
 	}
 
-	categories, err := queries.GetCategories(context, budgetID)
+	categories, err := q.GetCategories(context, budgetID)
 	if err != nil {
 		return nil, err
 	}
 
-	categoryGroups, err := queries.GetCategoryGroups(context, budgetID)
+	categoryGroups, err := q.GetCategoryGroups(context, budgetID)
 	if err != nil {
 		return nil, err
 	}
 
 	return &YNABImport{
+		Context:        context,
 		accounts:       accounts,
 		payees:         payees,
 		categories:     categories,
 		categoryGroups: categoryGroups,
-		queries:        queries,
+		queries:        q,
 		budgetID:       budgetID,
 	}, nil
+
 }
 
 // ImportAssignments expects a TSV-file as exported by YNAB in the following format:
-// "Month"	"Category Group/Category"	"Category Group"	"Category"	"Budgeted"	"Activity"	"Available"
-// "Apr 2019"	"Income: Next Month"	"Income"	"Next Month"	0,00€	0,00€	0,00€
+//"Month"	"Category Group/Category"	"Category Group"	"Category"	"Budgeted"	"Activity"	"Available"
+//"Apr 2019"	"Income: Next Month"	"Income"	"Next Month"	0,00€	0,00€	0,00€
 //
-// Activity and Available are not imported, since they are determined by the transactions and historic assignments.
-func (ynab *YNABImport) ImportAssignments(context context.Context, r io.Reader) error {
+// Activity and Available are not imported, since they are determined by the transactions and historic assignments
+func (ynab *YNABImport) ImportAssignments(r io.Reader) error {
 	csv := csv.NewReader(r)
 	csv.Comma = '\t'
 	csv.LazyQuotes = true
 
 	csvData, err := csv.ReadAll()
 	if err != nil {
-		return fmt.Errorf("read from tsv: %w", err)
+		return fmt.Errorf("could not read from tsv: %w", err)
 	}
 
 	count := 0
 	for _, record := range csvData[1:] {
+
 		dateString := record[0]
 		date, err := time.Parse("Jan 2006", dateString)
 		if err != nil {
-			return fmt.Errorf("parse date %s: %w", dateString, err)
+			return fmt.Errorf("could not parse date %s: %w", dateString, err)
 		}
 
-		categoryGroup, categoryName := record[2], record[3] // also in 1 joined by :
-		category, err := ynab.GetCategory(context, categoryGroup, categoryName)
+		categoryGroup, categoryName := record[2], record[3] //also in 1 joined by :
+		category, err := ynab.GetCategory(categoryGroup, categoryName)
 		if err != nil {
-			return fmt.Errorf("get category %s/%s: %w", categoryGroup, categoryName, err)
+			return fmt.Errorf("could not get category %s/%s: %w", categoryGroup, categoryName, err)
 		}
 
 		amountString := record[4]
 		amount, err := GetAmount(amountString, "0,00€")
 		if err != nil {
-			return fmt.Errorf("parse amount %s: %w", amountString, err)
+			return fmt.Errorf("could not parse amount %s: %w", amountString, err)
 		}
 
 		if amount.Int.Int64() == 0 {
@@ -96,9 +100,9 @@ func (ynab *YNABImport) ImportAssignments(context context.Context, r io.Reader)
 			CategoryID: category.UUID,
 			Amount:     amount,
 		}
-		_, err = ynab.queries.CreateAssignment(context, assignment)
+		_, err = ynab.queries.CreateAssignment(ynab.Context, assignment)
 		if err != nil {
-			return fmt.Errorf("save assignment %v: %w", assignment, err)
+			return fmt.Errorf("could not save assignment %v: %w", assignment, err)
 		}
 
 		count++
@@ -116,180 +120,147 @@ type Transfer struct {
 	ToAccount         string
 }
 
-// ImportTransactions expects a TSV-file as exported by YNAB.
-func (ynab *YNABImport) ImportTransactions(context context.Context, r io.Reader) error {
+// ImportTransactions expects a TSV-file as exported by YNAB in the following format:
+
+func (ynab *YNABImport) ImportTransactions(r io.Reader) error {
 	csv := csv.NewReader(r)
 	csv.Comma = '\t'
 	csv.LazyQuotes = true
 
 	csvData, err := csv.ReadAll()
 	if err != nil {
-		return fmt.Errorf("read from tsv: %w", err)
+		return fmt.Errorf("could not read from tsv: %w", err)
 	}
 
 	var openTransfers []Transfer
 
 	count := 0
 	for _, record := range csvData[1:] {
-		transaction, err := ynab.GetTransaction(context, record)
+		accountName := record[0]
+		account, err := ynab.GetAccount(accountName)
 		if err != nil {
-			return err
+			return fmt.Errorf("could not get account %s: %w", accountName, err)
 		}
 
-		payeeName := record[3]
-		// Transaction is a transfer
-		if strings.HasPrefix(payeeName, "Transfer : ") {
-			err = ynab.ImportTransferTransaction(context, payeeName, transaction.CreateTransactionParams,
-				&openTransfers, transaction.Account, transaction.Amount)
-		} else {
-			err = ynab.ImportRegularTransaction(context, payeeName, transaction.CreateTransactionParams)
-		}
+		//flag := record[1]
+
+		dateString := record[2]
+		date, err := time.Parse("02.01.2006", dateString)
 		if err != nil {
-			return err
+			return fmt.Errorf("could not parse date %s: %w", dateString, err)
 		}
 
-		count++
-	}
-
-	for _, openTransfer := range openTransfers {
-		fmt.Printf("Saving unmatched transfer from %s to %s on %s over %f as regular transaction\n",
-			openTransfer.FromAccount, openTransfer.ToAccount, openTransfer.Date, openTransfer.Amount.GetFloat64())
-		_, err = ynab.queries.CreateTransaction(context, openTransfer.CreateTransactionParams)
+		categoryGroup, categoryName := record[5], record[6] //also in 4 joined by :
+		category, err := ynab.GetCategory(categoryGroup, categoryName)
 		if err != nil {
-			return fmt.Errorf("save transaction %v: %w", openTransfer.CreateTransactionParams, err)
+			return fmt.Errorf("could not get category %s/%s: %w", categoryGroup, categoryName, err)
 		}
-	}
 
-	fmt.Printf("Imported %d transactions\n", count)
+		memo := record[7]
 
-	return nil
-}
+		outflow := record[8]
+		inflow := record[9]
+		amount, err := GetAmount(inflow, outflow)
+		if err != nil {
+			return fmt.Errorf("could not parse amount from (%s/%s): %w", inflow, outflow, err)
+		}
 
-type NewTransaction struct {
-	CreateTransactionParams
-	Account *Account
-}
+		statusEnum := TransactionStatusUncleared
+		status := record[10]
+		switch status {
+		case "Cleared":
+			statusEnum = TransactionStatusCleared
+		case "Reconciled":
+			statusEnum = TransactionStatusReconciled
+		case "Uncleared":
+		}
 
-func (ynab *YNABImport) GetTransaction(context context.Context, record []string) (NewTransaction, error) {
-	accountName := record[0]
-	account, err := ynab.GetAccount(context, accountName)
-	if err != nil {
-		return NewTransaction{}, fmt.Errorf("get account %s: %w", accountName, err)
-	}
-
-	// flag := record[1]
-
-	dateString := record[2]
-	date, err := time.Parse("02.01.2006", dateString)
-	if err != nil {
-		return NewTransaction{}, fmt.Errorf("parse date %s: %w", dateString, err)
-	}
-
-	categoryGroup, categoryName := record[5], record[6] // also in 4 joined by :
-	category, err := ynab.GetCategory(context, categoryGroup, categoryName)
-	if err != nil {
-		return NewTransaction{}, fmt.Errorf("get category %s/%s: %w", categoryGroup, categoryName, err)
-	}
-
-	memo := record[7]
-
-	outflow := record[8]
-	inflow := record[9]
-	amount, err := GetAmount(inflow, outflow)
-	if err != nil {
-		return NewTransaction{}, fmt.Errorf("parse amount from (%s/%s): %w", inflow, outflow, err)
-	}
-
-	statusEnum := TransactionStatusUncleared
-	status := record[10]
-	switch status {
-	case "Cleared":
-		statusEnum = TransactionStatusCleared
-	case "Reconciled":
-		statusEnum = TransactionStatusReconciled
-	case "Uncleared":
-	}
-
-	return NewTransaction{
-		CreateTransactionParams: CreateTransactionParams{
+		transaction := CreateTransactionParams{
 			Date:       date,
 			Memo:       memo,
 			AccountID:  account.ID,
 			CategoryID: category,
 			Amount:     amount,
 			Status:     statusEnum,
-		},
-		Account: account,
-	}, nil
-}
-
-func (ynab *YNABImport) ImportRegularTransaction(context context.Context, payeeName string,
-	transaction CreateTransactionParams) error {
-	payeeID, err := ynab.GetPayee(context, payeeName)
-	if err != nil {
-		return fmt.Errorf("get payee %s: %w", payeeName, err)
-	}
-	transaction.PayeeID = payeeID
-
-	_, err = ynab.queries.CreateTransaction(context, transaction)
-	if err != nil {
-		return fmt.Errorf("save transaction %v: %w", transaction, err)
-	}
-	return nil
-}
-
-func (ynab *YNABImport) ImportTransferTransaction(context context.Context, payeeName string,
-	transaction CreateTransactionParams, openTransfers *[]Transfer,
-	account *Account, amount Numeric) error {
-	transferToAccountName := payeeName[11:]
-	transferToAccount, err := ynab.GetAccount(context, transferToAccountName)
-	if err != nil {
-		return fmt.Errorf("get transfer account %s: %w", transferToAccountName, err)
-	}
-
-	transfer := Transfer{
-		transaction,
-		transferToAccount,
-		account.Name,
-		transferToAccountName,
-	}
-
-	found := false
-	for i, openTransfer := range *openTransfers {
-		if openTransfer.TransferToAccount.ID != transfer.AccountID {
-			continue
-		}
-		if openTransfer.AccountID != transfer.TransferToAccount.ID {
-			continue
-		}
-		if openTransfer.Amount.GetFloat64() != -1*transfer.Amount.GetFloat64() {
-			continue
 		}
 
-		fmt.Printf("Matched transfers from %s to %s over %f\n", account.Name, transferToAccount.Name, amount.GetFloat64())
-		transfers := *openTransfers
-		transfers[i] = transfers[len(transfers)-1]
-		*openTransfers = transfers[:len(transfers)-1]
-		found = true
+		payeeName := record[3]
+		if strings.HasPrefix(payeeName, "Transfer : ") {
+			// Transaction is a transfer to
+			transferToAccountName := payeeName[11:]
+			transferToAccount, err := ynab.GetAccount(transferToAccountName)
+			if err != nil {
+				return fmt.Errorf("Could not get transfer account %s: %w", transferToAccountName, err)
+			}
 
-		groupID := uuid.New()
-		transfer.GroupID = uuid.NullUUID{UUID: groupID, Valid: true}
-		openTransfer.GroupID = uuid.NullUUID{UUID: groupID, Valid: true}
+			transfer := Transfer{
+				transaction,
+				transferToAccount,
+				accountName,
+				transferToAccountName,
+			}
 
-		_, err = ynab.queries.CreateTransaction(context, transfer.CreateTransactionParams)
+			found := false
+			for i, openTransfer := range openTransfers {
+				if openTransfer.TransferToAccount.ID != transfer.AccountID {
+					continue
+				}
+				if openTransfer.AccountID != transfer.TransferToAccount.ID {
+					continue
+				}
+				if openTransfer.Amount.GetFloat64() != -1*transfer.Amount.GetFloat64() {
+					continue
+				}
+
+				fmt.Printf("Matched transfers from %s to %s over %f\n", account.Name, transferToAccount.Name, amount.GetFloat64())
+				openTransfers[i] = openTransfers[len(openTransfers)-1]
+				openTransfers = openTransfers[:len(openTransfers)-1]
+				found = true
+
+				groupID := uuid.New()
+				transfer.GroupID = uuid.NullUUID{UUID: groupID, Valid: true}
+				openTransfer.GroupID = uuid.NullUUID{UUID: groupID, Valid: true}
+
+				_, err = ynab.queries.CreateTransaction(ynab.Context, transfer.CreateTransactionParams)
+				if err != nil {
+					return fmt.Errorf("could not save transaction %v: %w", transfer.CreateTransactionParams, err)
+				}
+				_, err = ynab.queries.CreateTransaction(ynab.Context, openTransfer.CreateTransactionParams)
+				if err != nil {
+					return fmt.Errorf("could not save transaction %v: %w", openTransfer.CreateTransactionParams, err)
+				}
+				break
+			}
+
+			if !found {
+				openTransfers = append(openTransfers, transfer)
+			}
+		} else {
+			payeeID, err := ynab.GetPayee(payeeName)
+			if err != nil {
+				return fmt.Errorf("could not get payee %s: %w", payeeName, err)
+			}
+			transaction.PayeeID = payeeID
+
+			_, err = ynab.queries.CreateTransaction(ynab.Context, transaction)
+			if err != nil {
+				return fmt.Errorf("could not save transaction %v: %w", transaction, err)
+			}
+		}
+
+		count++
+	}
+
+	for _, openTransfer := range openTransfers {
+		fmt.Printf("Saving unmatched transfer from %s to %s on %s over %f as regular transaction\n", openTransfer.FromAccount, openTransfer.ToAccount, openTransfer.Date, openTransfer.Amount.GetFloat64())
+		_, err = ynab.queries.CreateTransaction(ynab.Context, openTransfer.CreateTransactionParams)
 		if err != nil {
-			return fmt.Errorf("save transaction %v: %w", transfer.CreateTransactionParams, err)
+			return fmt.Errorf("could not save transaction %v: %w", openTransfer.CreateTransactionParams, err)
 		}
-		_, err = ynab.queries.CreateTransaction(context, openTransfer.CreateTransactionParams)
-		if err != nil {
-			return fmt.Errorf("save transaction %v: %w", openTransfer.CreateTransactionParams, err)
-		}
-		break
-	}
 
-	if !found {
-		*openTransfers = append(*openTransfers, transfer)
 	}
+	fmt.Printf("Imported %d transactions\n", count)
+
 	return nil
 }
 
@@ -309,7 +280,7 @@ func GetAmount(inflow string, outflow string) (Numeric, error) {
 	num := Numeric{}
 	err := num.Set(inflow)
 	if err != nil {
-		return num, fmt.Errorf("parse inflow %s: %w", inflow, err)
+		return num, fmt.Errorf("Could not parse inflow %s: %w", inflow, err)
 	}
 
 	// if inflow is zero, use outflow
@@ -319,19 +290,19 @@ func GetAmount(inflow string, outflow string) (Numeric, error) {
 
 	err = num.Set("-" + outflow)
 	if err != nil {
-		return num, fmt.Errorf("parse outflow %s: %w", inflow, err)
+		return num, fmt.Errorf("Could not parse outflow %s: %w", inflow, err)
 	}
 	return num, nil
 }
 
-func (ynab *YNABImport) GetAccount(context context.Context, name string) (*Account, error) {
+func (ynab *YNABImport) GetAccount(name string) (*Account, error) {
 	for _, acc := range ynab.accounts {
 		if acc.Name == name {
 			return &acc, nil
 		}
 	}
 
-	account, err := ynab.queries.CreateAccount(context, CreateAccountParams{Name: name, BudgetID: ynab.budgetID})
+	account, err := ynab.queries.CreateAccount(ynab.Context, CreateAccountParams{Name: name, BudgetID: ynab.budgetID})
 	if err != nil {
 		return nil, err
 	}
@@ -340,7 +311,7 @@ func (ynab *YNABImport) GetAccount(context context.Context, name string) (*Accou
 	return &account, nil
 }
 
-func (ynab *YNABImport) GetPayee(context context.Context, name string) (uuid.NullUUID, error) {
+func (ynab *YNABImport) GetPayee(name string) (uuid.NullUUID, error) {
 	if name == "" {
 		return uuid.NullUUID{}, nil
 	}
@@ -351,7 +322,7 @@ func (ynab *YNABImport) GetPayee(context context.Context, name string) (uuid.Nul
 		}
 	}
 
-	payee, err := ynab.queries.CreatePayee(context, CreatePayeeParams{Name: name, BudgetID: ynab.budgetID})
+	payee, err := ynab.queries.CreatePayee(ynab.Context, CreatePayeeParams{Name: name, BudgetID: ynab.budgetID})
 	if err != nil {
 		return uuid.NullUUID{}, err
 	}
@@ -360,7 +331,7 @@ func (ynab *YNABImport) GetPayee(context context.Context, name string) (uuid.Nul
 	return uuid.NullUUID{UUID: payee.ID, Valid: true}, nil
 }
 
-func (ynab *YNABImport) GetCategory(context context.Context, group string, name string) (uuid.NullUUID, error) { //nolint
+func (ynab *YNABImport) GetCategory(group string, name string) (uuid.NullUUID, error) {
 	if group == "" || name == "" {
 		return uuid.NullUUID{}, nil
 	}
@@ -371,25 +342,32 @@ func (ynab *YNABImport) GetCategory(context context.Context, group string, name
 		}
 	}
 
-	var categoryGroup CategoryGroup
-	for _, existingGroup := range ynab.categoryGroups {
-		if existingGroup.Name == group {
-			categoryGroup = existingGroup
+	for _, categoryGroup := range ynab.categoryGroups {
+		if categoryGroup.Name == group {
+			createCategory := CreateCategoryParams{Name: name, CategoryGroupID: categoryGroup.ID}
+			category, err := ynab.queries.CreateCategory(ynab.Context, createCategory)
+			if err != nil {
+				return uuid.NullUUID{}, err
+			}
+
+			getCategory := GetCategoriesRow{
+				ID:              category.ID,
+				CategoryGroupID: category.CategoryGroupID,
+				Name:            category.Name,
+				Group:           categoryGroup.Name,
+			}
+			ynab.categories = append(ynab.categories, getCategory)
+			return uuid.NullUUID{UUID: category.ID, Valid: true}, nil
 		}
 	}
 
-	if categoryGroup.Name == "" {
-		newGroup := CreateCategoryGroupParams{Name: group, BudgetID: ynab.budgetID}
-		var err error
-		categoryGroup, err = ynab.queries.CreateCategoryGroup(context, newGroup)
-		if err != nil {
-			return uuid.NullUUID{}, err
-		}
-		ynab.categoryGroups = append(ynab.categoryGroups, categoryGroup)
+	categoryGroup, err := ynab.queries.CreateCategoryGroup(ynab.Context, CreateCategoryGroupParams{Name: group, BudgetID: ynab.budgetID})
+	if err != nil {
+		return uuid.NullUUID{}, err
 	}
+	ynab.categoryGroups = append(ynab.categoryGroups, categoryGroup)
 
-	newCategory := CreateCategoryParams{Name: name, CategoryGroupID: categoryGroup.ID}
-	category, err := ynab.queries.CreateCategory(context, newCategory)
+	category, err := ynab.queries.CreateCategory(ynab.Context, CreateCategoryParams{Name: name, CategoryGroupID: categoryGroup.ID})
 	if err != nil {
 		return uuid.NullUUID{}, err
 	}

token.go

@@ -5,7 +5,7 @@ import (
 	"github.com/google/uuid"
 )
 
-// Token contains data that authenticates a user.
+// Token contains data that authenticates a user
 type Token interface {
 	GetUsername() string
 	GetName() string
@@ -13,7 +13,7 @@ type Token interface {
 	GetID() uuid.UUID
 }
 
-// TokenVerifier verifies a Token.
+// TokenVerifier verifies a Token
 type TokenVerifier interface {
 	VerifyToken(string) (Token, error)
 	CreateToken(*postgres.User) (string, error)

web/src/pages/Login.vue

@@ -12,7 +12,7 @@ onMounted(() => {
 
 function formSubmit(e: MouseEvent) {
     e.preventDefault();
-    useSessionStore().login(login.value)
+    useSessionStore().login(login)
         .then(x => {
             error.value = "";
             useRouter().replace("/dashboard");