Getting real tests working.

Author: elliotcourant

.development.env

@@ -1,4 +1,5 @@
 POSTGRES_PASSWORD=
 POSTGRES_USER=postgres
 POSTGRES_DB=postgres
-POSTGRES_HOST_AUTH_METHOD=trust
+POSTGRES_HOST_AUTH_METHOD=trust
+POSTGRES_HOST=localhost

pkg/models/registration.go

@@ -22,7 +22,7 @@ type Registration struct {
 	RegistrationId string    `json:"-" pg:"registration_id,notnull,pk,type:'uuid',default:uuid_generate_v4()"`
 	LoginId        uint64    `json:"loginId" pg:"login_id,notnull,on_delete:CASCADE"`
 	Login          *Login    `json:"login,omitempty" pg:"rel:has-one"`
-	IsComplete     bool      `json:"isComplete" pg:"is_complete,notnull,use-zero"`
+	IsComplete     bool      `json:"isComplete" pg:"is_complete,notnull,use_zero"`
 	DateCreated    time.Time `json:"-" pg:"date_created,notnull"`
 	DateExpires    time.Time `json:"-" pg:"date_expires,notnull"`
 }

pkg/repository/unauthenticated_test.go

@@ -0,0 +1,22 @@
+package repository
+
+import (
+	"github.com/harderthanitneedstobe/rest-api/v0/pkg/testutils"
+	"github.com/stretchr/testify/assert"
+	"testing"
+	"time"
+)
+
+func GetTestUnauthenticatedRepository(t *testing.T) UnauthenticatedRepository {
+	txn := testutils.GetPgDatabaseTxn(t)
+	return NewUnauthenticatedRepository(txn)
+}
+
+func TestUnauthenticatedRepo_CreateAccount(t *testing.T) {
+	t.Run("simple", func(t *testing.T) {
+		repo := GetTestUnauthenticatedRepository(t)
+		account, err := repo.CreateAccount(time.UTC)
+		assert.NoError(t, err, "should successfully create account")
+		assert.NotEmpty(t, account, "new account should not be empty")
+	})
+}

pkg/testutils/database.go

@@ -0,0 +1,33 @@
+package testutils
+
+import (
+	"context"
+	"github.com/go-pg/pg/v10"
+	"github.com/stretchr/testify/require"
+	"os"
+	"testing"
+)
+
+func GetPgDatabaseTxn(t *testing.T) *pg.Tx {
+	options := &pg.Options{
+		Network:         "tcp",
+		Addr:            os.Getenv("POSTGRES_HOST") + ":5432",
+		User:            os.Getenv("POSTGRES_USER"),
+		Password:        os.Getenv("POSTGRES_PASSWORD"),
+		Database:        os.Getenv("POSTGRES_DB"),
+		ApplicationName: "harder - api - " + t.Name(),
+	}
+	db := pg.Connect(options)
+
+	require.NoError(t, db.Ping(context.Background()), "must ping database")
+
+	txn, err := db.Begin()
+	require.NoError(t, err, "must begin transaction")
+
+	t.Cleanup(func() {
+		require.NoError(t, txn.Rollback(), "must rollback database transaction")
+		require.NoError(t, db.Close(), "must close database connection")
+	})
+
+	return txn
+}

schema/00000000_Initial.up.sql

@@ -4,17 +4,17 @@ CREATE EXTENSION IF NOT EXISTS "citext";
 
 CREATE TABLE IF NOT EXISTS "logins" ("login_id" bigserial NOT NULL, "email" text NOT NULL UNIQUE, "password_hash" text NOT NULL, "phone_number" text, "is_enabled" boolean NOT NULL, "is_email_verified" boolean NOT NULL, "is_phone_verified" boolean NOT NULL, PRIMARY KEY ("login_id"), UNIQUE ("email"));
 
-CREATE TABLE IF NOT EXISTS "registrations" ("registration_id" uuid NOT NULL DEFAULT 'uuid_generate_v4()', "login_id" bigint NOT NULL, "date_created" timestamptz NOT NULL, "date_expires" timestamptz NOT NULL, PRIMARY KEY ("registration_id"), FOREIGN KEY ("login_id") REFERENCES "logins" ("login_id") ON DELETE CASCADE);
+CREATE TABLE IF NOT EXISTS "registrations" ("registration_id" uuid NOT NULL DEFAULT uuid_generate_v4(), "login_id" bigint NOT NULL, "is_complete" boolean NOT NULL, "date_created" timestamptz NOT NULL, "date_expires" timestamptz NOT NULL, PRIMARY KEY ("registration_id"), FOREIGN KEY ("login_id") REFERENCES "logins" ("login_id") ON DELETE CASCADE);
 
 CREATE TABLE IF NOT EXISTS "email_verifications" ("email_verification_id" bigserial NOT NULL, "login_id" bigint NOT NULL, "email_address" text NOT NULL, "is_verified" boolean NOT NULL, "created_at" timestamptz NOT NULL DEFAULT now(), "expires_at" timestamptz NOT NULL, "verified_at" timestamptz, PRIMARY KEY ("email_verification_id"), UNIQUE ("login_id", "email_address"), FOREIGN KEY ("login_id") REFERENCES "logins" ("login_id") ON DELETE CASCADE);
 
 CREATE TABLE IF NOT EXISTS "phone_verifications" ("phone_verification_id" bigserial NOT NULL, "login_id" bigint NOT NULL, "code" text NOT NULL, "phone_number" text NOT NULL, "is_verified" boolean NOT NULL, "created_at" timestamptz NOT NULL DEFAULT now(), "expires_at" timestamptz NOT NULL, "verified_at" timestamptz, PRIMARY KEY ("phone_verification_id"), UNIQUE ("login_id", "code"), UNIQUE ("login_id", "phone_number"), FOREIGN KEY ("login_id") REFERENCES "logins" ("login_id") ON DELETE CASCADE);
 
 CREATE TABLE IF NOT EXISTS "accounts" ("account_id" bigserial NOT NULL, "timezone" text NOT NULL DEFAULT 'UTC', PRIMARY KEY ("account_id"));
 
-CREATE TABLE IF NOT EXISTS "users" ("user_id" bigserial NOT NULL, "login_id" bigint NOT NULL, "account_id" bigint NOT NULL, "stripe_customer_id" text, "first_name" text NOT NULL, "last_name" text, PRIMARY KEY ("user_id"), FOREIGN KEY ("login_id") REFERENCES "logins" ("login_id") ON DELETE CASCADE, FOREIGN KEY ("account_id") REFERENCES "accounts" ("account_id") ON DELETE CASCADE);
+CREATE TABLE IF NOT EXISTS "users" ("user_id" bigserial NOT NULL, "login_id" bigint NOT NULL, "account_id" bigint NOT NULL, "stripe_customer_id" text, "first_name" text NOT NULL, "last_name" text, PRIMARY KEY ("user_id"), FOREIGN KEY ("account_id") REFERENCES "accounts" ("account_id") ON DELETE CASCADE, FOREIGN KEY ("login_id") REFERENCES "logins" ("login_id") ON DELETE CASCADE);
 
-CREATE TABLE IF NOT EXISTS "links" ("link_id" bigserial NOT NULL, "account_id" bigint NOT NULL, "plaid_item_id" text NOT NULL, "plaid_access_token" text NOT NULL, "plaid_products" text[] NOT NULL, "webhook_url" text, "institution_id" text NOT NULL, "institution_name" text NOT NULL, "custom_institution_name" text, "created_by_user_id" bigint NOT NULL, PRIMARY KEY ("link_id", "account_id"), FOREIGN KEY ("created_by_user_id") REFERENCES "users" ("user_id") ON DELETE CASCADE, FOREIGN KEY ("account_id") REFERENCES "accounts" ("account_id") ON DELETE CASCADE);
+CREATE TABLE IF NOT EXISTS "links" ("link_id" bigserial NOT NULL, "account_id" bigint NOT NULL, "plaid_item_id" text NOT NULL, "plaid_access_token" text NOT NULL, "plaid_products" text[] NOT NULL, "webhook_url" text, "institution_id" text NOT NULL, "institution_name" text NOT NULL, "custom_institution_name" text, "created_by_user_id" bigint NOT NULL, PRIMARY KEY ("link_id", "account_id"), FOREIGN KEY ("account_id") REFERENCES "accounts" ("account_id") ON DELETE CASCADE, FOREIGN KEY ("created_by_user_id") REFERENCES "users" ("user_id") ON DELETE CASCADE);
 
 CREATE TABLE IF NOT EXISTS "bank_accounts" ("bank_account_id" bigserial NOT NULL, "account_id" bigserial NOT NULL, "link_id" bigint NOT NULL, "plaid_account_id" text NOT NULL, "available_balance" bigint NOT NULL, "current_balance" bigint NOT NULL, "mask" text NOT NULL, "name" text, "original_name" text NOT NULL, "official_name" text NOT NULL, "account_type" text NOT NULL, "account_sub_type" text NOT NULL, PRIMARY KEY ("bank_account_id", "account_id"), FOREIGN KEY ("account_id") REFERENCES "accounts" ("account_id") ON DELETE CASCADE, FOREIGN KEY ("link_id", "account_id") REFERENCES "links" ("link_id", "account_id") ON DELETE CASCADE);