PlanTempusApp/Database/Tenants/TenantSetupService.cs

using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Text.RegularExpressions;
using System.Threading.Tasks;
using Insight.Database;
namespace Database.Tenants
{

    public class TenantSetupService
    {
        private readonly IDbConnection _db;

        public TenantSetupService(IDbConnection db)
        {
            _db = db;
        }

        public async Task CreateTenant(string schema)
        {
            if (!Regex.IsMatch(schema, "^[a-zA-Z0-9_]+$"))
            {
                throw new ArgumentException("Invalid schema name");
            }

            await CreateSchema(schema);
            await CreateRolesTable(schema);
            await CreatePermissionsTable(schema);
            await CreateRolePermissionsTable(schema);
            await CreateNavigationLinkTemplatesTable(schema);
            await CreateNavigationLinkTemplateTranslationsTable(schema);
        }

        private async Task CreateSchema(string schema)
        {
            var sql = $"CREATE SCHEMA IF NOT EXISTS {schema}";
            await _db.ExecuteAsync(sql);
        }
        private async Task CreateUser(string user, string password)
        {
            var sql = $"CREATE USER {user} WITH PASSWORD '{password}';";
            await _db.ExecuteAsync(sql);
        }

        private async Task GrantSchemaRights(string schema, string user)
        {
            var sql = $"GRANT USAGE ON SCHEMA {schema} TO {user};";
            await _db.ExecuteAsync(sql);

            var sql1 = $"ALTER DEFAULT PRIVILEGES IN SCHEMA {schema} " +
                    $"GRANT ALL PRIVILEGES ON TABLES TO {user};";
            await _db.ExecuteAsync(sql1);


            var sql2 = $"GRANT ALL PRIVILEGES ON ALL SEQUENCES IN SCHEMA {schema} TO {user};";
            await _db.ExecuteAsync(sql2);



        }
        private async Task CreatePermissionTypesTable(string schema)
        {
            var sql = $@"
           CREATE TABLE IF NOT EXISTS {schema}.permission_types (
               id SERIAL PRIMARY KEY,
               name VARCHAR(100) NOT NULL UNIQUE
           )";
            await _db.ExecuteAsync(sql);
        }

        private async Task CreatePermissionsTable(string schema)
        {
            var sql = $@"
           CREATE TABLE IF NOT EXISTS {schema}.permissions (
               id SERIAL PRIMARY KEY,
               name VARCHAR(100) NOT NULL UNIQUE,
               type_id INTEGER NOT NULL,
               FOREIGN KEY (type_id) REFERENCES {schema}.permission_types(id)
           )";
            await _db.ExecuteAsync(sql);
        }

        private async Task CreateRolesTable(string schema)
        {
            var sql = $@"
           CREATE TABLE IF NOT EXISTS {schema}.roles (
               id SERIAL PRIMARY KEY,
               name VARCHAR(100) NOT NULL UNIQUE
           )";
            await _db.ExecuteAsync(sql);
        }

        private async Task CreateRolePermissionsTable(string schema)
        {
            var sql = $@"
           CREATE TABLE IF NOT EXISTS {schema}.role_permissions (
               role_id INTEGER NOT NULL,
               permission_id INTEGER NOT NULL,
               PRIMARY KEY (role_id, permission_id),
               FOREIGN KEY (role_id) REFERENCES {schema}.roles(id),
               FOREIGN KEY (permission_id) REFERENCES {schema}.permissions(id)
           )";
            await _db.ExecuteAsync(sql);
        }

        private async Task CreateNavigationLinkTemplatesTable(string schema)
        {
            var sql = $@"
           CREATE TABLE IF NOT EXISTS {schema}.navigation_link_templates (
               id SERIAL PRIMARY KEY,
               parent_id INTEGER NULL,
               url VARCHAR(500) NOT NULL,
               permission_id INTEGER NULL,
               icon VARCHAR(100) NULL,
               default_order INTEGER NOT NULL,
               FOREIGN KEY (permission_id) REFERENCES {schema}.permissions(id),
               FOREIGN KEY (parent_id) REFERENCES {schema}.navigation_link_templates(id)
           )";
            await _db.ExecuteAsync(sql);
        }

        private async Task CreateNavigationLinkTemplateTranslationsTable(string schema)
        {
            var sql = $@"
           CREATE TABLE IF NOT EXISTS {schema}.navigation_link_template_translations (
               id SERIAL PRIMARY KEY,
               template_id INTEGER NOT NULL,
               language VARCHAR(10) NOT NULL,
               display_name VARCHAR(100) NOT NULL,
               FOREIGN KEY (template_id) REFERENCES {schema}.navigation_link_templates(id)
           )";
            await _db.ExecuteAsync(sql);
        }
    }


}