Multitenancy

cmd/seed/main.go

@@ -7,13 +7,15 @@ import (
 	"runtime/debug"
 	"time"
 
+	"github.com/google/uuid"
 	"github.com/iota-uz/iota-sdk/modules"
 	"github.com/iota-uz/iota-sdk/modules/core/domain/aggregates/user"
 	"github.com/iota-uz/iota-sdk/modules/core/domain/value_objects/internet"
 	coreseed "github.com/iota-uz/iota-sdk/modules/core/seed"
 	"github.com/iota-uz/iota-sdk/pkg/application"
 	"github.com/iota-uz/iota-sdk/pkg/composables"
 	"github.com/iota-uz/iota-sdk/pkg/configuration"
+	"github.com/iota-uz/iota-sdk/pkg/constants"
 	"github.com/iota-uz/iota-sdk/pkg/eventbus"
 
 	"github.com/jackc/pgx/v5/pgxpool"
@@ -67,14 +69,28 @@ func main() {
 		panicWithStack(err)
 	}
 	seeder.Register(
+		coreseed.CreateDefaultTenant,
 		coreseed.CreateCurrencies,
 		coreseed.CreatePermissions,
 		coreseed.UserSeedFunc(usr),
 	)
-	if err := seeder.Seed(composables.WithTx(ctx, tx), app); err != nil {
+
+	// Add default tenant to context
+	defaultTenant := &composables.Tenant{
+		ID:     uuid.MustParse("00000000-0000-0000-0000-000000000001"),
+		Name:   "Default",
+		Domain: "default.localhost",
+	}
+	ctxWithTenant := context.WithValue(
+		composables.WithTx(ctx, tx),
+		constants.TenantKey,
+		defaultTenant,
+	)
+
+	if err := seeder.Seed(ctxWithTenant, app); err != nil {
 		panicWithStack(err)
 	}
-	if err := tx.Commit(ctx); err != nil {
+	if err := tx.Commit(ctxWithTenant); err != nil {
 		panicWithStack(err)
 	}
 }

go.mod

@@ -57,6 +57,7 @@ require (
 	cloud.google.com/go/auth v0.11.0 // indirect
 	cloud.google.com/go/auth/oauth2adapt v0.2.6 // indirect
 	cloud.google.com/go/compute/metadata v0.6.0 // indirect
+	github.com/PuerkitoBio/goquery v1.10.1 // indirect
 	github.com/agnivade/levenshtein v1.2.1 // indirect
 	github.com/cenkalti/backoff/v4 v4.3.0 // indirect
 	github.com/certifi/gocertifi v0.0.0-20200922220541-2c3bb06c6054 // indirect

go.sum

@@ -24,8 +24,8 @@ github.com/Oudwins/tailwind-merge-go v0.2.1 h1:jxRaEqGtwwwF48UuFIQ8g8XT7YSualNuG
 github.com/Oudwins/tailwind-merge-go v0.2.1/go.mod h1:kkZodgOPvZQ8f7SIrlWkG/w1g9JTbtnptnePIh3V72U=
 github.com/PaulSonOfLars/gotgbot/v2 v2.0.0-rc.31 h1:SIkzqC6Nv+znY4NGbWlJceWdns8QVmf9cwAYXd7Cg8k=
 github.com/PaulSonOfLars/gotgbot/v2 v2.0.0-rc.31/go.mod h1:kL1v4iIjlalwm3gCYGvF4NLa3hs+aKEfRkNJvj4aoDU=
-github.com/PuerkitoBio/goquery v1.9.3 h1:mpJr/ikUA9/GNJB/DBZcGeFDXUtosHRyRrwh7KGdTG0=
-github.com/PuerkitoBio/goquery v1.9.3/go.mod h1:1ndLHPdTz+DyQPICCWYlYQMPl0oXZj0G6D4LCYA6u4U=
+github.com/PuerkitoBio/goquery v1.10.1 h1:Y8JGYUkXWTGRB6Ars3+j3kN0xg1YqqlwvdTV8WTFQcU=
+github.com/PuerkitoBio/goquery v1.10.1/go.mod h1:IYiHrOMps66ag56LEH7QYDDupKXyo5A8qrjIx3ZtujY=
 github.com/Shopify/goreferrer v0.0.0-20181106222321-ec9c9a553398/go.mod h1:a1uqRtAwp2Xwc6WNPJEufxJ7fx3npB4UV/JOLmbu5I0=
 github.com/a-h/templ v0.3.857 h1:6EqcJuGZW4OL+2iZ3MD+NnIcG7nGkaQeF2Zq5kf9ZGg=
 github.com/a-h/templ v0.3.857/go.mod h1:qhrhAkRFubE7khxLZHsBFHfX+gWwVNKbzKeF9GlPV4M=
@@ -34,8 +34,8 @@ github.com/agnivade/levenshtein v1.2.1/go.mod h1:QVVI16kDrtSuwcpd0p1+xMC6Z/VfhtC
 github.com/ajg/form v1.5.1/go.mod h1:uL1WgH+h2mgNtvBq0339dVnzXdBETtL2LeUXaIv25UY=
 github.com/andreyvit/diff v0.0.0-20170406064948-c7f18ee00883 h1:bvNMNQO63//z+xNgfBlViaCIJKLlCJ6/fmUseuG0wVQ=
 github.com/andreyvit/diff v0.0.0-20170406064948-c7f18ee00883/go.mod h1:rCTlJbsFo29Kk6CurOXKm700vrz8f0KW0JNfpkRJY/8=
-github.com/andybalholm/cascadia v1.3.2 h1:3Xi6Dw5lHF15JtdcmAHD3i1+T8plmv7BQ/nsViSLyss=
-github.com/andybalholm/cascadia v1.3.2/go.mod h1:7gtRlve5FxPPgIgX36uWBX58OdBsSS6lUvCFb+h7KvU=
+github.com/andybalholm/cascadia v1.3.3 h1:AG2YHrzJIm4BZ19iwJ/DAua6Btl3IwJX+VI4kktS1LM=
+github.com/andybalholm/cascadia v1.3.3/go.mod h1:xNd9bqTn98Ln4DwST8/nG+H0yuB8Hmgu1YHNnWw0GeA=
 github.com/antihax/optional v1.0.0/go.mod h1:uupD/76wgC+ih3iEmQUL+0Ugr19nfwCT1kdvxnR2qWY=
 github.com/arbovm/levenshtein v0.0.0-20160628152529-48b4e1c0c4d0 h1:jfIu9sQUG6Ig+0+Ap1h4unLjW6YQJpKZVmUzxsD4E/Q=
 github.com/arbovm/levenshtein v0.0.0-20160628152529-48b4e1c0c4d0/go.mod h1:t2tdKJDJF9BV14lnkjHmOQgcvEKgtqs5a1N3LNdJhGE=

migrations/changes-1740741698.sql

@@ -4,13 +4,14 @@
 CREATE TABLE uploads (
 	id         SERIAL8 PRIMARY KEY,
 	name       VARCHAR(255) NOT NULL,
-	hash       VARCHAR(255) NOT NULL UNIQUE,
+	hash       VARCHAR(255) NOT NULL,
 	path       VARCHAR(1024) DEFAULT '' NOT NULL,
 	size       INT8 DEFAULT 0 NOT NULL,
 	mimetype   VARCHAR(255) NOT NULL,
 	type       VARCHAR(255) NOT NULL,
 	created_at TIMESTAMPTZ DEFAULT now(),
-	updated_at TIMESTAMPTZ DEFAULT now()
+	updated_at TIMESTAMPTZ DEFAULT now(),
+  CONSTRAINT uploads_hash_key UNIQUE (hash)
 );
 
 -- Change CREATE_TABLE: clients
@@ -61,20 +62,22 @@ CREATE TABLE positions (
 -- Change CREATE_TABLE: permissions
 CREATE TABLE permissions (
 	id          UUID DEFAULT gen_random_uuid() NOT NULL PRIMARY KEY,
-	name        VARCHAR(255) NOT NULL UNIQUE,
+	name        VARCHAR(255) NOT NULL,
 	resource    VARCHAR(255) NOT NULL,
 	action      VARCHAR(255) NOT NULL,
 	modifier    VARCHAR(255) NOT NULL,
-	description TEXT
+	description TEXT,
+  CONSTRAINT permissions_name_key UNIQUE (name)
 );
 
 -- Change CREATE_TABLE: roles
 CREATE TABLE roles (
 	id          SERIAL8 PRIMARY KEY,
-	name        VARCHAR(255) NOT NULL UNIQUE,
+	name        VARCHAR(255) NOT NULL,
 	description TEXT,
 	created_at  TIMESTAMPTZ DEFAULT now(),
-	updated_at  TIMESTAMPTZ DEFAULT now()
+	updated_at  TIMESTAMPTZ DEFAULT now(),
+  CONSTRAINT roles_name_key UNIQUE (name)
 );
 
 -- Change CREATE_TABLE: warehouse_orders
@@ -122,11 +125,12 @@ CREATE TABLE inventory (
 CREATE TABLE warehouse_positions (
 	id          SERIAL8 PRIMARY KEY,
 	title       VARCHAR(255) NOT NULL,
-	barcode     VARCHAR(255) NOT NULL UNIQUE,
+	barcode     VARCHAR(255) NOT NULL,
 	description TEXT,
 	unit_id     INT8 REFERENCES warehouse_units (id) ON DELETE SET NULL,
 	created_at  TIMESTAMPTZ DEFAULT now(),
-	updated_at  TIMESTAMPTZ DEFAULT now()
+	updated_at  TIMESTAMPTZ DEFAULT now(),
+  CONSTRAINT warehouse_positions_barcode_key UNIQUE (barcode)
 );
 
 -- Change CREATE_TABLE: employees
@@ -135,15 +139,16 @@ CREATE TABLE employees (
 	first_name         VARCHAR(255) NOT NULL,
 	last_name          VARCHAR(255) NOT NULL,
 	middle_name        VARCHAR(255),
-	email              VARCHAR(255) NOT NULL UNIQUE,
+	email              VARCHAR(255) NOT NULL,
 	phone              VARCHAR(255),
 	salary             DECIMAL(9,2) NOT NULL,
 	salary_currency_id VARCHAR(3) REFERENCES currencies (code) ON DELETE SET NULL,
 	hourly_rate        DECIMAL(9,2) NOT NULL,
 	coefficient        FLOAT8 NOT NULL,
 	avatar_id          INT8 REFERENCES uploads (id) ON DELETE SET NULL,
 	created_at         TIMESTAMPTZ DEFAULT now(),
-	updated_at         TIMESTAMPTZ DEFAULT now()
+	updated_at         TIMESTAMPTZ DEFAULT now(),
+  CONSTRAINT employees_email_key UNIQUE (email)
 );
 
 -- Change CREATE_TABLE: warehouse_position_images
@@ -159,15 +164,16 @@ CREATE TABLE users (
 	first_name  VARCHAR(255) NOT NULL,
 	last_name   VARCHAR(255) NOT NULL,
 	middle_name VARCHAR(255),
-	email       VARCHAR(255) NOT NULL UNIQUE,
+	email       VARCHAR(255) NOT NULL,
 	password    VARCHAR(255),
 	ui_language VARCHAR(3) NOT NULL,
 	avatar_id   INT8 REFERENCES uploads (id) ON DELETE SET NULL,
 	last_login  TIMESTAMP NULL,
 	last_ip     VARCHAR(255) NULL,
 	last_action TIMESTAMPTZ NULL,
 	created_at  TIMESTAMPTZ DEFAULT now() NOT NULL,
-	updated_at  TIMESTAMPTZ DEFAULT now() NOT NULL
+	updated_at  TIMESTAMPTZ DEFAULT now() NOT NULL,
+  CONSTRAINT users_email_key UNIQUE (email)
 );
 
 -- Change CREATE_TABLE: role_permissions
@@ -229,10 +235,11 @@ CREATE TABLE employee_meta (
 CREATE TABLE warehouse_products (
 	id          SERIAL8 PRIMARY KEY,
 	position_id INT8 NOT NULL REFERENCES warehouse_positions (id) ON DELETE CASCADE,
-	rfid        VARCHAR(255) NULL UNIQUE,
+	rfid        VARCHAR(255) NULL,
 	status      VARCHAR(255) NOT NULL,
 	created_at  TIMESTAMPTZ DEFAULT now(),
-	updated_at  TIMESTAMPTZ DEFAULT now()
+	updated_at  TIMESTAMPTZ DEFAULT now(),
+  CONSTRAINT warehouse_products_rfid UNIQUE (rfid)
 );
 
 -- Change CREATE_TABLE: authentication_logs
@@ -292,7 +299,7 @@ CREATE TABLE tabs (
 	href       VARCHAR(255) NOT NULL,
 	user_id    INT8 NOT NULL REFERENCES users (id) ON DELETE CASCADE,
 	"position" INT8 DEFAULT 0 NOT NULL,
-	UNIQUE (href, user_id)
+	CONSTRAINT tabs_href_user_id_key UNIQUE (href, user_id)
 );
 
 -- Change CREATE_TABLE: counterparty_contacts

migrations/changes-1740935243.sql

@@ -35,7 +35,10 @@ ALTER TABLE clients
 
 -- Change ADD_COLUMN: phone
 ALTER TABLE users
-    ADD COLUMN phone VARCHAR(255) UNIQUE;
+    ADD COLUMN phone VARCHAR(255);
+
+ALTER TABLE users
+    ADD CONSTRAINT users_phone_key UNIQUE (phone);
 
 -- Change CREATE_TABLE: client_contacts
 CREATE TABLE client_contacts (

migrations/changes-1741630199.sql

@@ -2,10 +2,11 @@
 -- Change CREATE_TABLE: user_groups
 CREATE TABLE user_groups (
     id uuid DEFAULT gen_random_uuid () PRIMARY KEY,
-    name varchar(255) NOT NULL UNIQUE,
+    name varchar(255) NOT NULL,
     description text,
     created_at timestamp DEFAULT now(),
-    updated_at timestamp DEFAULT now()
+    updated_at timestamp DEFAULT now(),
+    CONSTRAINT user_groups_name_key UNIQUE (name)
 );
 
 -- Change CREATE_TABLE: group_roles