Add risk assessment system

Introduce a hierarchical risk assessment model with six entity types:

- Risk Assessment: top-level container scoped to an organization
- Risk Assessment Scope: sub-container for scoping threat modeling
  exercises within an assessment
- Risk Assessment Node: DFD elements typed as ENTITY, BOUNDARY,
  ASSET, or DATA within a scope
- Risk Assessment Process: directed data flows between two nodes
- Risk Assessment Threat: descriptive threats attached to a process
  with a free-text category (e.g. Confidentiality, Integrity)
- Risk Scenario: thin join linking a threat to a risk from the
  register, carrying only a name and description

Risk scoring (likelihood, impact, treatment) remains on the existing
Risk entity. Threats are purely descriptive. Risk Scenarios connect
the threat model to the risk register without duplicating scores.

Backend: migration with PG enum for node types, coredata structs,
service layer with full CRUD and validation, GraphQL schema with
18 mutations and paginated connections, authorization actions and
policies, and base_resolvers.go Node dispatch for all entity types.

Frontend: Risk Assessments list page with create dialog, detail page
showing scopes as cards with nodes/processes/threats tables, inline
create/edit/delete actions on all entities, and a Scenarios tab on
the Risk detail page linking threats to risks. Existing RiskGraph.ts
hook file removed in favor of colocated queries in page files.

E2E tests cover CRUD for all entity types, RBAC, and tenant
isolation.

Signed-off-by: Sacha Al Himdani <sacha@getprobo.com>

pkg/coredata/entity_type_reg.go

@@ -118,6 +118,12 @@ const (
 	CommonThirdPartyEntityType                     uint16 = 92
 	CommonThirdPartyDomainEntityType               uint16 = 93
 	CommonTrackerPatternEntityType                 uint16 = 94
+	RiskAssessmentEntityType                       uint16 = 95
+	RiskAssessmentNodeEntityType                   uint16 = 96
+	RiskAssessmentProcessEntityType                uint16 = 97
+	RiskAssessmentThreatEntityType                 uint16 = 98
+	RiskAssessmentScopeEntityType                  uint16 = 99
+	RiskAssessmentScenarioEntityType               uint16 = 100
 )
 
 func NewEntityFromID(id gid.GID) (any, bool) {
@@ -296,6 +302,18 @@ func NewEntityFromID(id gid.GID) (any, bool) {
 		return &CommonThirdPartyDomain{ID: id}, true
 	case CommonTrackerPatternEntityType:
 		return &CommonTrackerPattern{ID: id}, true
+	case RiskAssessmentEntityType:
+		return &RiskAssessment{ID: id}, true
+	case RiskAssessmentNodeEntityType:
+		return &RiskAssessmentNode{ID: id}, true
+	case RiskAssessmentProcessEntityType:
+		return &RiskAssessmentProcess{ID: id}, true
+	case RiskAssessmentThreatEntityType:
+		return &RiskAssessmentThreat{ID: id}, true
+	case RiskAssessmentScopeEntityType:
+		return &RiskAssessmentScope{ID: id}, true
+	case RiskAssessmentScenarioEntityType:
+		return &RiskAssessmentScenario{ID: id}, true
 	default:
 		return nil, false
 	}

pkg/coredata/migrations/20260421T140001Z.sql

@@ -0,0 +1,100 @@
+-- Copyright (c) 2025-2026 Probo Inc <hello@getprobo.com>.
+--
+-- Permission to use, copy, modify, and/or distribute this software for any
+-- purpose with or without fee is hereby granted, provided that the above
+-- copyright notice and this permission notice appear in all copies.
+--
+-- THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES WITH
+-- REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
+-- AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY SPECIAL, DIRECT,
+-- INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM
+-- LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR
+-- OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
+-- PERFORMANCE OF THIS SOFTWARE.
+
+CREATE TABLE risk_assessments (
+    id TEXT PRIMARY KEY,
+    tenant_id TEXT NOT NULL,
+    organization_id TEXT NOT NULL REFERENCES organizations(id) ON DELETE CASCADE,
+    name TEXT NOT NULL,
+    description TEXT,
+    created_at TIMESTAMP WITH TIME ZONE NOT NULL,
+    updated_at TIMESTAMP WITH TIME ZONE NOT NULL
+);
+
+CREATE TABLE risk_assessment_scopes (
+    id TEXT PRIMARY KEY,
+    tenant_id TEXT NOT NULL,
+    organization_id TEXT NOT NULL,
+    risk_assessment_id TEXT NOT NULL REFERENCES risk_assessments(id) ON DELETE CASCADE,
+    name TEXT NOT NULL,
+    created_at TIMESTAMP WITH TIME ZONE NOT NULL,
+    updated_at TIMESTAMP WITH TIME ZONE NOT NULL
+);
+
+CREATE TYPE risk_assessment_node_type AS ENUM ('ENTITY', 'BOUNDARY', 'ASSET', 'DATA');
+
+CREATE TABLE risk_assessment_nodes (
+    id TEXT PRIMARY KEY,
+    tenant_id TEXT NOT NULL,
+    organization_id TEXT NOT NULL,
+    risk_assessment_scope_id TEXT NOT NULL REFERENCES risk_assessment_scopes(id) ON DELETE CASCADE,
+    node_type risk_assessment_node_type NOT NULL,
+    name TEXT NOT NULL,
+    created_at TIMESTAMP WITH TIME ZONE NOT NULL,
+    updated_at TIMESTAMP WITH TIME ZONE NOT NULL,
+    CONSTRAINT risk_assessment_nodes_unique_name UNIQUE (risk_assessment_scope_id, name)
+);
+
+CREATE TABLE risk_assessment_processes (
+    id TEXT PRIMARY KEY,
+    tenant_id TEXT NOT NULL,
+    organization_id TEXT NOT NULL,
+    risk_assessment_scope_id TEXT NOT NULL REFERENCES risk_assessment_scopes(id) ON DELETE CASCADE,
+    source_node_id TEXT NOT NULL REFERENCES risk_assessment_nodes(id) ON DELETE CASCADE,
+    target_node_id TEXT NOT NULL REFERENCES risk_assessment_nodes(id) ON DELETE CASCADE,
+    name TEXT NOT NULL,
+    created_at TIMESTAMP WITH TIME ZONE NOT NULL,
+    updated_at TIMESTAMP WITH TIME ZONE NOT NULL,
+    CONSTRAINT risk_assessment_processes_unique_name UNIQUE (risk_assessment_scope_id, name)
+);
+
+CREATE TABLE risk_assessment_threats (
+    id TEXT PRIMARY KEY,
+    tenant_id TEXT NOT NULL,
+    organization_id TEXT NOT NULL,
+    risk_assessment_scope_id TEXT NOT NULL REFERENCES risk_assessment_scopes(id) ON DELETE CASCADE,
+    process_id TEXT NOT NULL REFERENCES risk_assessment_processes(id) ON DELETE CASCADE,
+    name TEXT NOT NULL,
+    category TEXT NOT NULL,
+    created_at TIMESTAMP WITH TIME ZONE NOT NULL,
+    updated_at TIMESTAMP WITH TIME ZONE NOT NULL,
+    CONSTRAINT risk_assessment_threats_unique_name UNIQUE (risk_assessment_scope_id, name)
+);
+
+CREATE TABLE risk_assessment_scenarios (
+    id TEXT PRIMARY KEY,
+    tenant_id TEXT NOT NULL,
+    organization_id TEXT NOT NULL,
+    risk_assessment_scope_id TEXT NOT NULL REFERENCES risk_assessment_scopes(id) ON DELETE CASCADE,
+    name TEXT NOT NULL,
+    description TEXT,
+    created_at TIMESTAMP WITH TIME ZONE NOT NULL,
+    updated_at TIMESTAMP WITH TIME ZONE NOT NULL
+);
+
+CREATE TABLE risk_assessment_scenario_threats (
+    tenant_id TEXT NOT NULL,
+    risk_assessment_scenario_id TEXT NOT NULL REFERENCES risk_assessment_scenarios(id) ON DELETE CASCADE,
+    risk_assessment_threat_id TEXT NOT NULL REFERENCES risk_assessment_threats(id) ON DELETE CASCADE,
+    created_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW(),
+    PRIMARY KEY (risk_assessment_scenario_id, risk_assessment_threat_id)
+);
+
+CREATE TABLE risk_assessment_scenario_risks (
+    tenant_id TEXT NOT NULL,
+    risk_assessment_scenario_id TEXT NOT NULL REFERENCES risk_assessment_scenarios(id) ON DELETE CASCADE,
+    risk_id TEXT NOT NULL REFERENCES risks(id) ON DELETE CASCADE,
+    created_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT NOW(),
+    PRIMARY KEY (risk_assessment_scenario_id, risk_id)
+);

pkg/coredata/risk_assessment.go

@@ -0,0 +1,254 @@
+// Copyright (c) 2026 Probo Inc <hello@getprobo.com>.
+//
+// Permission to use, copy, modify, and/or distribute this software for any
+// purpose with or without fee is hereby granted, provided that the above
+// copyright notice and this permission notice appear in all copies.
+//
+// THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES WITH
+// REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
+// AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY SPECIAL, DIRECT,
+// INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM
+// LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR
+// OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
+// PERFORMANCE OF THIS SOFTWARE.
+
+package coredata
+
+import (
+	"context"
+	"errors"
+	"fmt"
+	"maps"
+	"time"
+
+	"github.com/jackc/pgx/v5"
+	"github.com/jackc/pgx/v5/pgconn"
+	"go.gearno.de/kit/pg"
+	"go.probo.inc/probo/pkg/gid"
+	"go.probo.inc/probo/pkg/page"
+)
+
+type (
+	RiskAssessment struct {
+		ID             gid.GID   `db:"id"`
+		OrganizationID gid.GID   `db:"organization_id"`
+		Name           string    `db:"name"`
+		Description    *string   `db:"description"`
+		CreatedAt      time.Time `db:"created_at"`
+		UpdatedAt      time.Time `db:"updated_at"`
+	}
+
+	RiskAssessments []*RiskAssessment
+)
+
+func (ra *RiskAssessment) CursorKey(orderBy RiskAssessmentOrderField) page.CursorKey {
+	switch orderBy {
+	case RiskAssessmentOrderFieldCreatedAt:
+		return page.CursorKey{ID: ra.ID, Value: ra.CreatedAt}
+	case RiskAssessmentOrderFieldName:
+		return page.CursorKey{ID: ra.ID, Value: ra.Name}
+	}
+
+	panic(fmt.Sprintf("unsupported order by: %s", orderBy))
+}
+
+func (ra *RiskAssessment) AuthorizationAttributes(ctx context.Context, conn pg.Querier) (map[string]string, error) {
+	q := `SELECT organization_id FROM risk_assessments WHERE id = $1 LIMIT 1;`
+
+	var organizationID gid.GID
+	if err := conn.QueryRow(ctx, q, ra.ID).Scan(&organizationID); err != nil {
+		if errors.Is(err, pgx.ErrNoRows) {
+			return nil, ErrResourceNotFound
+		}
+		return nil, fmt.Errorf("cannot query risk assessment authorization attributes: %w", err)
+	}
+
+	return map[string]string{"organization_id": organizationID.String()}, nil
+}
+
+func (ra *RiskAssessments) CountByOrganizationID(
+	ctx context.Context,
+	conn pg.Querier,
+	scope Scoper,
+	organizationID gid.GID,
+) (int, error) {
+	q := `
+SELECT COUNT(id)
+FROM risk_assessments
+WHERE %s
+	AND organization_id = @organization_id
+`
+	q = fmt.Sprintf(q, scope.SQLFragment())
+
+	args := pgx.NamedArgs{"organization_id": organizationID}
+	maps.Copy(args, scope.SQLArguments())
+
+	var count int
+	if err := conn.QueryRow(ctx, q, args).Scan(&count); err != nil {
+		return 0, fmt.Errorf("cannot count risk assessments: %w", err)
+	}
+
+	return count, nil
+}
+
+func (ra *RiskAssessments) LoadByOrganizationID(
+	ctx context.Context,
+	conn pg.Querier,
+	scope Scoper,
+	organizationID gid.GID,
+	cursor *page.Cursor[RiskAssessmentOrderField],
+) error {
+	q := `
+SELECT id, organization_id, name, description, created_at, updated_at
+FROM risk_assessments
+WHERE %s
+	AND organization_id = @organization_id
+	AND %s
+`
+	q = fmt.Sprintf(q, scope.SQLFragment(), cursor.SQLFragment())
+
+	args := pgx.NamedArgs{"organization_id": organizationID}
+	maps.Copy(args, scope.SQLArguments())
+	maps.Copy(args, cursor.SQLArguments())
+
+	rows, err := conn.Query(ctx, q, args)
+	if err != nil {
+		return fmt.Errorf("cannot query risk assessments: %w", err)
+	}
+
+	results, err := pgx.CollectRows(rows, pgx.RowToAddrOfStructByName[RiskAssessment])
+	if err != nil {
+		return fmt.Errorf("cannot collect risk assessments: %w", err)
+	}
+
+	*ra = results
+
+	return nil
+}
+
+func (ra *RiskAssessment) LoadByID(
+	ctx context.Context,
+	conn pg.Querier,
+	scope Scoper,
+	id gid.GID,
+) error {
+	q := `
+SELECT
+	id,
+	organization_id,
+	name,
+	description,
+	created_at,
+	updated_at
+FROM risk_assessments
+WHERE %s
+	AND id = @id
+LIMIT 1;
+`
+	q = fmt.Sprintf(q, scope.SQLFragment())
+
+	args := pgx.StrictNamedArgs{"id": id}
+	maps.Copy(args, scope.SQLArguments())
+
+	rows, err := conn.Query(ctx, q, args)
+	if err != nil {
+		return fmt.Errorf("cannot query risk assessment: %w", err)
+	}
+
+	result, err := pgx.CollectExactlyOneRow(rows, pgx.RowToStructByName[RiskAssessment])
+	if err != nil {
+		if errors.Is(err, pgx.ErrNoRows) {
+			return ErrResourceNotFound
+		}
+
+		return fmt.Errorf("cannot collect risk assessment: %w", err)
+	}
+
+	*ra = result
+
+	return nil
+}
+
+func (ra *RiskAssessment) Insert(
+	ctx context.Context,
+	conn pg.Tx,
+	scope Scoper,
+) error {
+	q := `
+INSERT INTO risk_assessments (id, tenant_id, organization_id, name, description, created_at, updated_at)
+VALUES (@id, @tenant_id, @organization_id, @name, @description, @created_at, @updated_at)
+`
+
+	args := pgx.StrictNamedArgs{
+		"id":              ra.ID,
+		"tenant_id":       scope.GetTenantID(),
+		"organization_id": ra.OrganizationID,
+		"name":            ra.Name,
+		"description":     ra.Description,
+		"created_at":      ra.CreatedAt,
+		"updated_at":      ra.UpdatedAt,
+	}
+
+	_, err := conn.Exec(ctx, q, args)
+	if err != nil {
+		if pgErr, ok := errors.AsType[*pgconn.PgError](err); ok && pgErr.Code == "23505" {
+			return ErrResourceAlreadyExists
+		}
+		return fmt.Errorf("cannot insert risk assessment: %w", err)
+	}
+	return nil
+}
+
+func (ra *RiskAssessment) Update(
+	ctx context.Context,
+	conn pg.Tx,
+	scope Scoper,
+) error {
+	q := `
+UPDATE risk_assessments
+SET
+	name = @name,
+	description = @description,
+	updated_at = @updated_at
+WHERE %s
+	AND id = @id
+`
+	q = fmt.Sprintf(q, scope.SQLFragment())
+
+	args := pgx.StrictNamedArgs{
+		"id":          ra.ID,
+		"name":        ra.Name,
+		"description": ra.Description,
+		"updated_at":  ra.UpdatedAt,
+	}
+	maps.Copy(args, scope.SQLArguments())
+
+	result, err := conn.Exec(ctx, q, args)
+	if err != nil {
+		return fmt.Errorf("cannot update risk assessment: %w", err)
+	}
+
+	if result.RowsAffected() == 0 {
+		return ErrResourceNotFound
+	}
+
+	return nil
+}
+
+func (ra *RiskAssessment) Delete(
+	ctx context.Context,
+	conn pg.Tx,
+	scope Scoper,
+	id gid.GID,
+) error {
+	q := `
+DELETE FROM risk_assessments WHERE %s AND id = @id
+`
+	q = fmt.Sprintf(q, scope.SQLFragment())
+
+	args := pgx.StrictNamedArgs{"id": id}
+	maps.Copy(args, scope.SQLArguments())
+
+	_, err := conn.Exec(ctx, q, args)
+	return err
+}

pkg/coredata/risk_assessment_node.go

@@ -0,0 +1,257 @@
+// Copyright (c) 2026 Probo Inc <hello@getprobo.com>.
+//
+// Permission to use, copy, modify, and/or distribute this software for any
+// purpose with or without fee is hereby granted, provided that the above
+// copyright notice and this permission notice appear in all copies.
+//
+// THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES WITH
+// REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
+// AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY SPECIAL, DIRECT,
+// INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM
+// LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR
+// OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
+// PERFORMANCE OF THIS SOFTWARE.
+
+package coredata
+
+import (
+	"context"
+	"errors"
+	"fmt"
+	"maps"
+	"time"
+
+	"github.com/jackc/pgx/v5"
+	"github.com/jackc/pgx/v5/pgconn"
+	"go.gearno.de/kit/pg"
+	"go.probo.inc/probo/pkg/gid"
+	"go.probo.inc/probo/pkg/page"
+)
+
+type (
+	RiskAssessmentNode struct {
+		ID                    gid.GID                `db:"id"`
+		OrganizationID        gid.GID                `db:"organization_id"`
+		RiskAssessmentScopeID gid.GID                `db:"risk_assessment_scope_id"`
+		NodeType              RiskAssessmentNodeType `db:"node_type"`
+		Name                  string                 `db:"name"`
+		CreatedAt             time.Time              `db:"created_at"`
+		UpdatedAt             time.Time              `db:"updated_at"`
+	}
+
+	RiskAssessmentNodes []*RiskAssessmentNode
+)
+
+func (n *RiskAssessmentNode) CursorKey(orderBy RiskAssessmentNodeOrderField) page.CursorKey {
+	switch orderBy {
+	case RiskAssessmentNodeOrderFieldCreatedAt:
+		return page.CursorKey{ID: n.ID, Value: n.CreatedAt}
+	case RiskAssessmentNodeOrderFieldName:
+		return page.CursorKey{ID: n.ID, Value: n.Name}
+	}
+	panic(fmt.Sprintf("unsupported order by: %s", orderBy))
+}
+
+func (n *RiskAssessmentNode) AuthorizationAttributes(ctx context.Context, conn pg.Querier) (map[string]string, error) {
+	q := `SELECT organization_id FROM risk_assessment_nodes WHERE id = $1 LIMIT 1;`
+
+	var organizationID gid.GID
+	if err := conn.QueryRow(ctx, q, n.ID).Scan(&organizationID); err != nil {
+		if errors.Is(err, pgx.ErrNoRows) {
+			return nil, ErrResourceNotFound
+		}
+		return nil, fmt.Errorf("cannot query risk assessment node authorization attributes: %w", err)
+	}
+
+	return map[string]string{"organization_id": organizationID.String()}, nil
+}
+
+func (ns *RiskAssessmentNodes) LoadByRiskAssessmentScopeID(
+	ctx context.Context,
+	conn pg.Querier,
+	scope Scoper,
+	riskAssessmentScopeID gid.GID,
+	cursor *page.Cursor[RiskAssessmentNodeOrderField],
+) error {
+	q := `
+SELECT
+	id,
+	organization_id,
+	risk_assessment_scope_id,
+	node_type,
+	name,
+	created_at,
+	updated_at
+FROM
+	risk_assessment_nodes
+WHERE
+	%s
+	AND risk_assessment_scope_id = @risk_assessment_scope_id
+	AND %s
+`
+	q = fmt.Sprintf(q, scope.SQLFragment(), cursor.SQLFragment())
+	args := pgx.NamedArgs{"risk_assessment_scope_id": riskAssessmentScopeID}
+	maps.Copy(args, scope.SQLArguments())
+	maps.Copy(args, cursor.SQLArguments())
+
+	rows, err := conn.Query(ctx, q, args)
+	if err != nil {
+		return fmt.Errorf("cannot query risk assessment nodes: %w", err)
+	}
+	results, err := pgx.CollectRows(rows, pgx.RowToAddrOfStructByName[RiskAssessmentNode])
+	if err != nil {
+		return fmt.Errorf("cannot collect risk assessment nodes: %w", err)
+	}
+	*ns = results
+	return nil
+}
+
+func (ns *RiskAssessmentNodes) CountByRiskAssessmentScopeID(
+	ctx context.Context,
+	conn pg.Querier,
+	scope Scoper,
+	riskAssessmentScopeID gid.GID,
+) (int, error) {
+	q := `
+SELECT
+	COUNT(id)
+FROM
+	risk_assessment_nodes
+WHERE
+	%s
+	AND risk_assessment_scope_id = @risk_assessment_scope_id
+`
+
+	q = fmt.Sprintf(q, scope.SQLFragment())
+	args := pgx.NamedArgs{"risk_assessment_scope_id": riskAssessmentScopeID}
+	maps.Copy(args, scope.SQLArguments())
+
+	var count int
+	if err := conn.QueryRow(ctx, q, args).Scan(&count); err != nil {
+		return 0, fmt.Errorf("cannot count risk assessment nodes: %w", err)
+	}
+	return count, nil
+}
+
+func (n *RiskAssessmentNode) LoadByID(ctx context.Context, conn pg.Querier, scope Scoper, id gid.GID) error {
+	q := `
+SELECT
+	id,
+	organization_id,
+	risk_assessment_scope_id,
+	node_type,
+	name,
+	created_at,
+	updated_at
+FROM
+	risk_assessment_nodes
+WHERE
+	%s
+	AND id = @id
+LIMIT 1;
+`
+	q = fmt.Sprintf(q, scope.SQLFragment())
+	args := pgx.StrictNamedArgs{"id": id}
+	maps.Copy(args, scope.SQLArguments())
+
+	rows, err := conn.Query(ctx, q, args)
+	if err != nil {
+		return fmt.Errorf("cannot query risk assessment node: %w", err)
+	}
+	result, err := pgx.CollectExactlyOneRow(rows, pgx.RowToStructByName[RiskAssessmentNode])
+	if err != nil {
+		if errors.Is(err, pgx.ErrNoRows) {
+			return ErrResourceNotFound
+		}
+		return fmt.Errorf("cannot collect risk assessment node: %w", err)
+	}
+	*n = result
+	return nil
+}
+
+func (n *RiskAssessmentNode) Insert(ctx context.Context, conn pg.Tx, scope Scoper) error {
+	q := `
+INSERT INTO risk_assessment_nodes (
+	id,
+	tenant_id,
+	organization_id,
+	risk_assessment_scope_id,
+	node_type,
+	name,
+	created_at,
+	updated_at
+) VALUES (
+	@id,
+	@tenant_id,
+	@organization_id,
+	@risk_assessment_scope_id,
+	@node_type,
+	@name,
+	@created_at,
+	@updated_at
+)
+`
+	args := pgx.StrictNamedArgs{
+		"id":                       n.ID,
+		"tenant_id":                scope.GetTenantID(),
+		"organization_id":          n.OrganizationID,
+		"risk_assessment_scope_id": n.RiskAssessmentScopeID,
+		"node_type":                n.NodeType,
+		"name":                     n.Name,
+		"created_at":               n.CreatedAt,
+		"updated_at":               n.UpdatedAt,
+	}
+	_, err := conn.Exec(ctx, q, args)
+	if err != nil {
+		if pgErr, ok := errors.AsType[*pgconn.PgError](err); ok && pgErr.Code == "23505" {
+			return ErrResourceAlreadyExists
+		}
+		return fmt.Errorf("cannot insert risk assessment node: %w", err)
+	}
+	return nil
+}
+
+func (n *RiskAssessmentNode) Update(ctx context.Context, conn pg.Tx, scope Scoper) error {
+	q := `
+UPDATE risk_assessment_nodes
+SET
+	node_type = @node_type,
+	name = @name,
+	updated_at = @updated_at
+WHERE
+	%s
+	AND id = @id
+`
+	q = fmt.Sprintf(q, scope.SQLFragment())
+	args := pgx.StrictNamedArgs{
+		"id":         n.ID,
+		"node_type":  n.NodeType,
+		"name":       n.Name,
+		"updated_at": n.UpdatedAt,
+	}
+	maps.Copy(args, scope.SQLArguments())
+
+	result, err := conn.Exec(ctx, q, args)
+	if err != nil {
+		return fmt.Errorf("cannot update risk assessment node: %w", err)
+	}
+	if result.RowsAffected() == 0 {
+		return ErrResourceNotFound
+	}
+	return nil
+}
+
+func (n *RiskAssessmentNode) Delete(ctx context.Context, conn pg.Tx, scope Scoper, id gid.GID) error {
+	q := `
+DELETE FROM risk_assessment_nodes
+WHERE
+	%s
+	AND id = @id
+`
+	q = fmt.Sprintf(q, scope.SQLFragment())
+	args := pgx.StrictNamedArgs{"id": id}
+	maps.Copy(args, scope.SQLArguments())
+
+	_, err := conn.Exec(ctx, q, args)
+	return err
+}

pkg/coredata/risk_assessment_node_order_field.go

@@ -0,0 +1,34 @@
+// Copyright (c) 2026 Probo Inc <hello@getprobo.com>.
+//
+// Permission to use, copy, modify, and/or distribute this software for any
+// purpose with or without fee is hereby granted, provided that the above
+// copyright notice and this permission notice appear in all copies.
+//
+// THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES WITH
+// REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
+// AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY SPECIAL, DIRECT,
+// INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM
+// LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR
+// OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
+// PERFORMANCE OF THIS SOFTWARE.
+
+package coredata
+
+type RiskAssessmentNodeOrderField string
+
+const (
+	RiskAssessmentNodeOrderFieldCreatedAt RiskAssessmentNodeOrderField = "CREATED_AT"
+	RiskAssessmentNodeOrderFieldName      RiskAssessmentNodeOrderField = "NAME"
+)
+
+func (p RiskAssessmentNodeOrderField) Column() string { return string(p) }
+func (p RiskAssessmentNodeOrderField) String() string { return string(p) }
+
+func (p RiskAssessmentNodeOrderField) MarshalText() ([]byte, error) {
+	return []byte(p.String()), nil
+}
+
+func (p *RiskAssessmentNodeOrderField) UnmarshalText(text []byte) error {
+	*p = RiskAssessmentNodeOrderField(text)
+	return nil
+}

pkg/coredata/risk_assessment_node_type.go

@@ -0,0 +1,78 @@
+// Copyright (c) 2026 Probo Inc <hello@getprobo.com>.
+//
+// Permission to use, copy, modify, and/or distribute this software for any
+// purpose with or without fee is hereby granted, provided that the above
+// copyright notice and this permission notice appear in all copies.
+//
+// THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES WITH
+// REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
+// AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY SPECIAL, DIRECT,
+// INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM
+// LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR
+// OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
+// PERFORMANCE OF THIS SOFTWARE.
+
+package coredata
+
+import (
+	"database/sql/driver"
+	"fmt"
+)
+
+type RiskAssessmentNodeType string
+
+const (
+	RiskAssessmentNodeTypeEntity   RiskAssessmentNodeType = "ENTITY"
+	RiskAssessmentNodeTypeBoundary RiskAssessmentNodeType = "BOUNDARY"
+	RiskAssessmentNodeTypeAsset    RiskAssessmentNodeType = "ASSET"
+	RiskAssessmentNodeTypeData     RiskAssessmentNodeType = "DATA"
+)
+
+func RiskAssessmentNodeTypes() []RiskAssessmentNodeType {
+	return []RiskAssessmentNodeType{
+		RiskAssessmentNodeTypeEntity,
+		RiskAssessmentNodeTypeBoundary,
+		RiskAssessmentNodeTypeAsset,
+		RiskAssessmentNodeTypeData,
+	}
+}
+
+func (t RiskAssessmentNodeType) MarshalText() ([]byte, error) {
+	return []byte(t.String()), nil
+}
+
+func (t *RiskAssessmentNodeType) UnmarshalText(data []byte) error {
+	val := string(data)
+
+	switch val {
+	case RiskAssessmentNodeTypeEntity.String():
+		*t = RiskAssessmentNodeTypeEntity
+	case RiskAssessmentNodeTypeBoundary.String():
+		*t = RiskAssessmentNodeTypeBoundary
+	case RiskAssessmentNodeTypeAsset.String():
+		*t = RiskAssessmentNodeTypeAsset
+	case RiskAssessmentNodeTypeData.String():
+		*t = RiskAssessmentNodeTypeData
+	default:
+		return fmt.Errorf("invalid RiskAssessmentNodeType value: %q", val)
+	}
+
+	return nil
+}
+
+func (t RiskAssessmentNodeType) String() string {
+	return string(t)
+}
+
+func (t *RiskAssessmentNodeType) Scan(value any) error {
+	val, ok := value.(string)
+	if !ok {
+		return fmt.Errorf("invalid scan source for RiskAssessmentNodeType, expected string got %T", value)
+	}
+
+	return t.UnmarshalText([]byte(val))
+}
+
+func (t RiskAssessmentNodeType) Value() (driver.Value, error) {
+	return t.String(), nil
+}

pkg/coredata/risk_assessment_order_field.go

@@ -0,0 +1,39 @@
+// Copyright (c) 2026 Probo Inc <hello@getprobo.com>.
+//
+// Permission to use, copy, modify, and/or distribute this software for any
+// purpose with or without fee is hereby granted, provided that the above
+// copyright notice and this permission notice appear in all copies.
+//
+// THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES WITH
+// REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
+// AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY SPECIAL, DIRECT,
+// INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM
+// LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR
+// OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
+// PERFORMANCE OF THIS SOFTWARE.
+
+package coredata
+
+type RiskAssessmentOrderField string
+
+const (
+	RiskAssessmentOrderFieldCreatedAt RiskAssessmentOrderField = "CREATED_AT"
+	RiskAssessmentOrderFieldName      RiskAssessmentOrderField = "NAME"
+)
+
+func (p RiskAssessmentOrderField) Column() string {
+	return string(p)
+}
+
+func (p RiskAssessmentOrderField) String() string {
+	return string(p)
+}
+
+func (p RiskAssessmentOrderField) MarshalText() ([]byte, error) {
+	return []byte(p.String()), nil
+}
+
+func (p *RiskAssessmentOrderField) UnmarshalText(text []byte) error {
+	*p = RiskAssessmentOrderField(text)
+	return nil
+}

pkg/coredata/risk_assessment_process.go

@@ -0,0 +1,262 @@
+// Copyright (c) 2026 Probo Inc <hello@getprobo.com>.
+//
+// Permission to use, copy, modify, and/or distribute this software for any
+// purpose with or without fee is hereby granted, provided that the above
+// copyright notice and this permission notice appear in all copies.
+//
+// THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES WITH
+// REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
+// AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY SPECIAL, DIRECT,
+// INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM
+// LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR
+// OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
+// PERFORMANCE OF THIS SOFTWARE.
+
+package coredata
+
+import (
+	"context"
+	"errors"
+	"fmt"
+	"maps"
+	"time"
+
+	"github.com/jackc/pgx/v5"
+	"github.com/jackc/pgx/v5/pgconn"
+	"go.gearno.de/kit/pg"
+	"go.probo.inc/probo/pkg/gid"
+	"go.probo.inc/probo/pkg/page"
+)
+
+type (
+	RiskAssessmentProcess struct {
+		ID                    gid.GID   `db:"id"`
+		OrganizationID        gid.GID   `db:"organization_id"`
+		RiskAssessmentScopeID gid.GID   `db:"risk_assessment_scope_id"`
+		SourceNodeID          gid.GID   `db:"source_node_id"`
+		TargetNodeID          gid.GID   `db:"target_node_id"`
+		Name                  string    `db:"name"`
+		CreatedAt             time.Time `db:"created_at"`
+		UpdatedAt             time.Time `db:"updated_at"`
+	}
+
+	RiskAssessmentProcesses []*RiskAssessmentProcess
+)
+
+func (p *RiskAssessmentProcess) CursorKey(orderBy RiskAssessmentProcessOrderField) page.CursorKey {
+	switch orderBy {
+	case RiskAssessmentProcessOrderFieldCreatedAt:
+		return page.CursorKey{ID: p.ID, Value: p.CreatedAt}
+	case RiskAssessmentProcessOrderFieldName:
+		return page.CursorKey{ID: p.ID, Value: p.Name}
+	}
+	panic(fmt.Sprintf("unsupported order by: %s", orderBy))
+}
+
+func (p *RiskAssessmentProcess) AuthorizationAttributes(ctx context.Context, conn pg.Querier) (map[string]string, error) {
+	q := `SELECT organization_id FROM risk_assessment_processes WHERE id = $1 LIMIT 1;`
+
+	var organizationID gid.GID
+	if err := conn.QueryRow(ctx, q, p.ID).Scan(&organizationID); err != nil {
+		if errors.Is(err, pgx.ErrNoRows) {
+			return nil, ErrResourceNotFound
+		}
+		return nil, fmt.Errorf("cannot query risk assessment process authorization attributes: %w", err)
+	}
+
+	return map[string]string{"organization_id": organizationID.String()}, nil
+}
+
+func (ps *RiskAssessmentProcesses) LoadByRiskAssessmentScopeID(
+	ctx context.Context,
+	conn pg.Querier,
+	scope Scoper,
+	riskAssessmentScopeID gid.GID,
+	cursor *page.Cursor[RiskAssessmentProcessOrderField],
+) error {
+	q := `
+SELECT
+	id,
+	organization_id,
+	risk_assessment_scope_id,
+	source_node_id,
+	target_node_id,
+	name,
+	created_at,
+	updated_at
+FROM
+	risk_assessment_processes
+WHERE
+	%s
+	AND risk_assessment_scope_id = @risk_assessment_scope_id
+	AND %s
+`
+	q = fmt.Sprintf(q, scope.SQLFragment(), cursor.SQLFragment())
+	args := pgx.NamedArgs{"risk_assessment_scope_id": riskAssessmentScopeID}
+	maps.Copy(args, scope.SQLArguments())
+	maps.Copy(args, cursor.SQLArguments())
+
+	rows, err := conn.Query(ctx, q, args)
+	if err != nil {
+		return fmt.Errorf("cannot query risk assessment processes: %w", err)
+	}
+	results, err := pgx.CollectRows(rows, pgx.RowToAddrOfStructByName[RiskAssessmentProcess])
+	if err != nil {
+		return fmt.Errorf("cannot collect risk assessment processes: %w", err)
+	}
+	*ps = results
+	return nil
+}
+
+func (ps *RiskAssessmentProcesses) CountByRiskAssessmentScopeID(
+	ctx context.Context,
+	conn pg.Querier,
+	scope Scoper,
+	riskAssessmentScopeID gid.GID,
+) (int, error) {
+	q := `
+SELECT
+	COUNT(id)
+FROM
+	risk_assessment_processes
+WHERE
+	%s
+	AND risk_assessment_scope_id = @risk_assessment_scope_id
+`
+
+	q = fmt.Sprintf(q, scope.SQLFragment())
+	args := pgx.NamedArgs{"risk_assessment_scope_id": riskAssessmentScopeID}
+	maps.Copy(args, scope.SQLArguments())
+
+	var count int
+	if err := conn.QueryRow(ctx, q, args).Scan(&count); err != nil {
+		return 0, fmt.Errorf("cannot count risk assessment processes: %w", err)
+	}
+	return count, nil
+}
+
+func (p *RiskAssessmentProcess) LoadByID(ctx context.Context, conn pg.Querier, scope Scoper, id gid.GID) error {
+	q := `
+SELECT
+	id,
+	organization_id,
+	risk_assessment_scope_id,
+	source_node_id,
+	target_node_id,
+	name,
+	created_at,
+	updated_at
+FROM
+	risk_assessment_processes
+WHERE
+	%s
+	AND id = @id
+LIMIT 1;
+`
+	q = fmt.Sprintf(q, scope.SQLFragment())
+	args := pgx.StrictNamedArgs{"id": id}
+	maps.Copy(args, scope.SQLArguments())
+	rows, err := conn.Query(ctx, q, args)
+	if err != nil {
+		return fmt.Errorf("cannot query risk assessment process: %w", err)
+	}
+	result, err := pgx.CollectExactlyOneRow(rows, pgx.RowToStructByName[RiskAssessmentProcess])
+	if err != nil {
+		if errors.Is(err, pgx.ErrNoRows) {
+			return ErrResourceNotFound
+		}
+		return fmt.Errorf("cannot collect risk assessment process: %w", err)
+	}
+	*p = result
+	return nil
+}
+
+func (p *RiskAssessmentProcess) Insert(ctx context.Context, conn pg.Tx, scope Scoper) error {
+	q := `
+INSERT INTO risk_assessment_processes (
+	id,
+	tenant_id,
+	organization_id,
+	risk_assessment_scope_id,
+	source_node_id,
+	target_node_id,
+	name,
+	created_at,
+	updated_at
+) VALUES (
+	@id,
+	@tenant_id,
+	@organization_id,
+	@risk_assessment_scope_id,
+	@source_node_id,
+	@target_node_id,
+	@name,
+	@created_at,
+	@updated_at
+)
+`
+	args := pgx.StrictNamedArgs{
+		"id":                       p.ID,
+		"tenant_id":                scope.GetTenantID(),
+		"organization_id":          p.OrganizationID,
+		"risk_assessment_scope_id": p.RiskAssessmentScopeID,
+		"source_node_id":           p.SourceNodeID,
+		"target_node_id":           p.TargetNodeID,
+		"name":                     p.Name,
+		"created_at":               p.CreatedAt,
+		"updated_at":               p.UpdatedAt,
+	}
+	_, err := conn.Exec(ctx, q, args)
+	if err != nil {
+		if pgErr, ok := errors.AsType[*pgconn.PgError](err); ok && pgErr.Code == "23505" {
+			return ErrResourceAlreadyExists
+		}
+		return fmt.Errorf("cannot insert risk assessment process: %w", err)
+	}
+	return nil
+}
+
+func (p *RiskAssessmentProcess) Update(ctx context.Context, conn pg.Tx, scope Scoper) error {
+	q := `
+UPDATE risk_assessment_processes
+SET
+	source_node_id = @source_node_id,
+	target_node_id = @target_node_id,
+	name = @name,
+	updated_at = @updated_at
+WHERE
+	%s
+	AND id = @id
+`
+	q = fmt.Sprintf(q, scope.SQLFragment())
+	args := pgx.StrictNamedArgs{
+		"id":             p.ID,
+		"source_node_id": p.SourceNodeID,
+		"target_node_id": p.TargetNodeID,
+		"name":           p.Name,
+		"updated_at":     p.UpdatedAt,
+	}
+	maps.Copy(args, scope.SQLArguments())
+	result, err := conn.Exec(ctx, q, args)
+	if err != nil {
+		return fmt.Errorf("cannot update risk assessment process: %w", err)
+	}
+	if result.RowsAffected() == 0 {
+		return ErrResourceNotFound
+	}
+	return nil
+}
+
+func (p *RiskAssessmentProcess) Delete(ctx context.Context, conn pg.Tx, scope Scoper, id gid.GID) error {
+	q := `
+DELETE FROM risk_assessment_processes
+WHERE
+	%s
+	AND id = @id
+`
+	q = fmt.Sprintf(q, scope.SQLFragment())
+	args := pgx.StrictNamedArgs{"id": id}
+	maps.Copy(args, scope.SQLArguments())
+	_, err := conn.Exec(ctx, q, args)
+	return err
+}

pkg/coredata/risk_assessment_process_order_field.go

@@ -0,0 +1,34 @@
+// Copyright (c) 2026 Probo Inc <hello@getprobo.com>.
+//
+// Permission to use, copy, modify, and/or distribute this software for any
+// purpose with or without fee is hereby granted, provided that the above
+// copyright notice and this permission notice appear in all copies.
+//
+// THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES WITH
+// REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
+// AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY SPECIAL, DIRECT,
+// INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM
+// LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR
+// OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
+// PERFORMANCE OF THIS SOFTWARE.
+
+package coredata
+
+type RiskAssessmentProcessOrderField string
+
+const (
+	RiskAssessmentProcessOrderFieldCreatedAt RiskAssessmentProcessOrderField = "CREATED_AT"
+	RiskAssessmentProcessOrderFieldName      RiskAssessmentProcessOrderField = "NAME"
+)
+
+func (p RiskAssessmentProcessOrderField) Column() string { return string(p) }
+func (p RiskAssessmentProcessOrderField) String() string { return string(p) }
+
+func (p RiskAssessmentProcessOrderField) MarshalText() ([]byte, error) {
+	return []byte(p.String()), nil
+}
+
+func (p *RiskAssessmentProcessOrderField) UnmarshalText(text []byte) error {
+	*p = RiskAssessmentProcessOrderField(text)
+	return nil
+}

pkg/coredata/risk_assessment_scenario.go

@@ -0,0 +1,398 @@
+// Copyright (c) 2026 Probo Inc <hello@getprobo.com>.
+//
+// Permission to use, copy, modify, and/or distribute this software for any
+// purpose with or without fee is hereby granted, provided that the above
+// copyright notice and this permission notice appear in all copies.
+//
+// THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES WITH
+// REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
+// AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY SPECIAL, DIRECT,
+// INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM
+// LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR
+// OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
+// PERFORMANCE OF THIS SOFTWARE.
+
+package coredata
+
+import (
+	"context"
+	"errors"
+	"fmt"
+	"maps"
+	"time"
+
+	"github.com/jackc/pgx/v5"
+	"github.com/jackc/pgx/v5/pgconn"
+	"go.gearno.de/kit/pg"
+	"go.probo.inc/probo/pkg/gid"
+	"go.probo.inc/probo/pkg/page"
+)
+
+type (
+	RiskAssessmentScenario struct {
+		ID                    gid.GID   `db:"id"`
+		OrganizationID        gid.GID   `db:"organization_id"`
+		RiskAssessmentScopeID gid.GID   `db:"risk_assessment_scope_id"`
+		Name                  string    `db:"name"`
+		Description           *string   `db:"description"`
+		CreatedAt             time.Time `db:"created_at"`
+		UpdatedAt             time.Time `db:"updated_at"`
+	}
+
+	RiskAssessmentScenarios []*RiskAssessmentScenario
+)
+
+func (s *RiskAssessmentScenario) CursorKey(orderBy RiskAssessmentScenarioOrderField) page.CursorKey {
+	switch orderBy {
+	case RiskAssessmentScenarioOrderFieldCreatedAt:
+		return page.CursorKey{ID: s.ID, Value: s.CreatedAt}
+	case RiskAssessmentScenarioOrderFieldName:
+		return page.CursorKey{ID: s.ID, Value: s.Name}
+	}
+	panic(fmt.Sprintf("unsupported order by: %s", orderBy))
+}
+
+func (s *RiskAssessmentScenario) AuthorizationAttributes(ctx context.Context, conn pg.Querier) (map[string]string, error) {
+	q := `SELECT organization_id FROM risk_assessment_scenarios WHERE id = $1 LIMIT 1;`
+
+	var organizationID gid.GID
+	if err := conn.QueryRow(ctx, q, s.ID).Scan(&organizationID); err != nil {
+		if errors.Is(err, pgx.ErrNoRows) {
+			return nil, ErrResourceNotFound
+		}
+		return nil, fmt.Errorf("cannot query risk scenario authorization attributes: %w", err)
+	}
+
+	return map[string]string{"organization_id": organizationID.String()}, nil
+}
+
+func (ss *RiskAssessmentScenarios) LoadByOrganizationID(
+	ctx context.Context,
+	conn pg.Querier,
+	scope Scoper,
+	organizationID gid.GID,
+	cursor *page.Cursor[RiskAssessmentScenarioOrderField],
+) error {
+	q := `
+SELECT
+	id,
+	organization_id,
+	risk_assessment_scope_id,
+	name,
+	description,
+	created_at,
+	updated_at
+FROM
+	risk_assessment_scenarios
+WHERE
+	%s
+	AND organization_id = @organization_id
+	AND %s
+`
+	q = fmt.Sprintf(q, scope.SQLFragment(), cursor.SQLFragment())
+	args := pgx.NamedArgs{"organization_id": organizationID}
+	maps.Copy(args, scope.SQLArguments())
+	maps.Copy(args, cursor.SQLArguments())
+
+	rows, err := conn.Query(ctx, q, args)
+	if err != nil {
+		return fmt.Errorf("cannot query risk scenarios: %w", err)
+	}
+	results, err := pgx.CollectRows(rows, pgx.RowToAddrOfStructByName[RiskAssessmentScenario])
+	if err != nil {
+		return fmt.Errorf("cannot collect risk scenarios: %w", err)
+	}
+	*ss = results
+	return nil
+}
+
+func (ss *RiskAssessmentScenarios) CountByOrganizationID(
+	ctx context.Context,
+	conn pg.Querier,
+	scope Scoper,
+	organizationID gid.GID,
+) (int, error) {
+	q := `
+SELECT
+	COUNT(id)
+FROM
+	risk_assessment_scenarios
+WHERE
+	%s
+	AND organization_id = @organization_id
+`
+	q = fmt.Sprintf(q, scope.SQLFragment())
+	args := pgx.NamedArgs{"organization_id": organizationID}
+	maps.Copy(args, scope.SQLArguments())
+
+	var count int
+	if err := conn.QueryRow(ctx, q, args).Scan(&count); err != nil {
+		return 0, fmt.Errorf("cannot count risk scenarios: %w", err)
+	}
+	return count, nil
+}
+
+func (ss *RiskAssessmentScenarios) LoadByRiskID(
+	ctx context.Context,
+	conn pg.Querier,
+	scope Scoper,
+	riskID gid.GID,
+	cursor *page.Cursor[RiskAssessmentScenarioOrderField],
+) error {
+	q := `
+WITH linked_scenarios AS (
+	SELECT
+		risk_assessment_scenario_id
+	FROM
+		risk_assessment_scenario_risks
+	WHERE
+		%s
+		AND risk_id = @risk_id
+)
+SELECT
+	id,
+	organization_id,
+	risk_assessment_scope_id,
+	name,
+	description,
+	created_at,
+	updated_at
+FROM
+	risk_assessment_scenarios
+WHERE
+	%s
+	AND id IN (SELECT risk_assessment_scenario_id FROM linked_scenarios)
+	AND %s
+`
+	q = fmt.Sprintf(q, scope.SQLFragment(), scope.SQLFragment(), cursor.SQLFragment())
+	args := pgx.NamedArgs{"risk_id": riskID}
+	maps.Copy(args, scope.SQLArguments())
+	maps.Copy(args, cursor.SQLArguments())
+
+	rows, err := conn.Query(ctx, q, args)
+	if err != nil {
+		return fmt.Errorf("cannot query risk scenarios: %w", err)
+	}
+	results, err := pgx.CollectRows(rows, pgx.RowToAddrOfStructByName[RiskAssessmentScenario])
+	if err != nil {
+		return fmt.Errorf("cannot collect risk scenarios: %w", err)
+	}
+	*ss = results
+	return nil
+}
+
+func (ss *RiskAssessmentScenarios) CountByRiskID(
+	ctx context.Context,
+	conn pg.Querier,
+	scope Scoper,
+	riskID gid.GID,
+) (int, error) {
+	q := `
+WITH linked_scenarios AS (
+	SELECT
+		risk_assessment_scenario_id
+	FROM
+		risk_assessment_scenario_risks
+	WHERE
+		%s
+		AND risk_id = @risk_id
+)
+SELECT
+	COUNT(id)
+FROM
+	risk_assessment_scenarios
+WHERE
+	%s
+	AND id IN (SELECT risk_assessment_scenario_id FROM linked_scenarios)
+`
+	q = fmt.Sprintf(q, scope.SQLFragment(), scope.SQLFragment())
+	args := pgx.NamedArgs{"risk_id": riskID}
+	maps.Copy(args, scope.SQLArguments())
+
+	var count int
+	if err := conn.QueryRow(ctx, q, args).Scan(&count); err != nil {
+		return 0, fmt.Errorf("cannot count risk scenarios: %w", err)
+	}
+	return count, nil
+}
+
+func (ss *RiskAssessmentScenarios) LoadByRiskAssessmentScopeID(
+	ctx context.Context,
+	conn pg.Querier,
+	scope Scoper,
+	riskAssessmentScopeID gid.GID,
+	cursor *page.Cursor[RiskAssessmentScenarioOrderField],
+) error {
+	q := `
+SELECT
+	id,
+	organization_id,
+	risk_assessment_scope_id,
+	name,
+	description,
+	created_at,
+	updated_at
+FROM
+	risk_assessment_scenarios
+WHERE
+	%s
+	AND risk_assessment_scope_id = @risk_assessment_scope_id
+	AND %s
+`
+	q = fmt.Sprintf(q, scope.SQLFragment(), cursor.SQLFragment())
+	args := pgx.NamedArgs{"risk_assessment_scope_id": riskAssessmentScopeID}
+	maps.Copy(args, scope.SQLArguments())
+	maps.Copy(args, cursor.SQLArguments())
+
+	rows, err := conn.Query(ctx, q, args)
+	if err != nil {
+		return fmt.Errorf("cannot query risk scenarios: %w", err)
+	}
+	results, err := pgx.CollectRows(rows, pgx.RowToAddrOfStructByName[RiskAssessmentScenario])
+	if err != nil {
+		return fmt.Errorf("cannot collect risk scenarios: %w", err)
+	}
+	*ss = results
+	return nil
+}
+
+func (ss *RiskAssessmentScenarios) CountByRiskAssessmentScopeID(
+	ctx context.Context,
+	conn pg.Querier,
+	scope Scoper,
+	riskAssessmentScopeID gid.GID,
+) (int, error) {
+	q := `
+SELECT
+	COUNT(id)
+FROM
+	risk_assessment_scenarios
+WHERE
+	%s
+	AND risk_assessment_scope_id = @risk_assessment_scope_id
+`
+	q = fmt.Sprintf(q, scope.SQLFragment())
+	args := pgx.NamedArgs{"risk_assessment_scope_id": riskAssessmentScopeID}
+	maps.Copy(args, scope.SQLArguments())
+
+	var count int
+	if err := conn.QueryRow(ctx, q, args).Scan(&count); err != nil {
+		return 0, fmt.Errorf("cannot count risk scenarios: %w", err)
+	}
+	return count, nil
+}
+
+func (s *RiskAssessmentScenario) LoadByID(ctx context.Context, conn pg.Querier, scope Scoper, id gid.GID) error {
+	q := `
+SELECT
+	id,
+	organization_id,
+	risk_assessment_scope_id,
+	name,
+	description,
+	created_at,
+	updated_at
+FROM
+	risk_assessment_scenarios
+WHERE
+	%s
+	AND id = @id
+LIMIT 1
+`
+	q = fmt.Sprintf(q, scope.SQLFragment())
+	args := pgx.StrictNamedArgs{"id": id}
+	maps.Copy(args, scope.SQLArguments())
+	rows, err := conn.Query(ctx, q, args)
+	if err != nil {
+		return fmt.Errorf("cannot query risk scenario: %w", err)
+	}
+	result, err := pgx.CollectExactlyOneRow(rows, pgx.RowToStructByName[RiskAssessmentScenario])
+	if err != nil {
+		if errors.Is(err, pgx.ErrNoRows) {
+			return ErrResourceNotFound
+		}
+		return fmt.Errorf("cannot collect risk scenario: %w", err)
+	}
+	*s = result
+	return nil
+}
+
+func (s *RiskAssessmentScenario) Insert(ctx context.Context, conn pg.Tx, scope Scoper) error {
+	q := `
+INSERT INTO risk_assessment_scenarios (
+	id,
+	tenant_id,
+	organization_id,
+	risk_assessment_scope_id,
+	name,
+	description,
+	created_at,
+	updated_at
+) VALUES (
+	@id,
+	@tenant_id,
+	@organization_id,
+	@risk_assessment_scope_id,
+	@name,
+	@description,
+	@created_at,
+	@updated_at
+)
+`
+	args := pgx.StrictNamedArgs{
+		"id":                       s.ID,
+		"tenant_id":                scope.GetTenantID(),
+		"organization_id":          s.OrganizationID,
+		"risk_assessment_scope_id": s.RiskAssessmentScopeID,
+		"name":                     s.Name,
+		"description":              s.Description,
+		"created_at":               s.CreatedAt,
+		"updated_at":               s.UpdatedAt,
+	}
+	_, err := conn.Exec(ctx, q, args)
+	if err != nil {
+		if pgErr, ok := errors.AsType[*pgconn.PgError](err); ok && pgErr.Code == "23505" {
+			return ErrResourceAlreadyExists
+		}
+		return fmt.Errorf("cannot insert risk scenario: %w", err)
+	}
+	return nil
+}
+
+func (s *RiskAssessmentScenario) Update(ctx context.Context, conn pg.Tx, scope Scoper) error {
+	q := `
+UPDATE risk_assessment_scenarios
+SET
+	name = @name,
+	description = @description,
+	updated_at = @updated_at
+WHERE
+	%s
+	AND id = @id
+`
+	q = fmt.Sprintf(q, scope.SQLFragment())
+	args := pgx.StrictNamedArgs{"id": s.ID, "name": s.Name, "description": s.Description, "updated_at": s.UpdatedAt}
+	maps.Copy(args, scope.SQLArguments())
+	result, err := conn.Exec(ctx, q, args)
+	if err != nil {
+		return fmt.Errorf("cannot update risk scenario: %w", err)
+	}
+	if result.RowsAffected() == 0 {
+		return ErrResourceNotFound
+	}
+	return nil
+}
+
+func (s *RiskAssessmentScenario) Delete(ctx context.Context, conn pg.Tx, scope Scoper, id gid.GID) error {
+	q := `
+DELETE FROM risk_assessment_scenarios
+WHERE
+	%s
+	AND id = @id
+`
+	q = fmt.Sprintf(q, scope.SQLFragment())
+	args := pgx.StrictNamedArgs{"id": id}
+	maps.Copy(args, scope.SQLArguments())
+	_, err := conn.Exec(ctx, q, args)
+	return err
+}

pkg/coredata/risk_assessment_scenario_order_field.go

@@ -0,0 +1,34 @@
+// Copyright (c) 2026 Probo Inc <hello@getprobo.com>.
+//
+// Permission to use, copy, modify, and/or distribute this software for any
+// purpose with or without fee is hereby granted, provided that the above
+// copyright notice and this permission notice appear in all copies.
+//
+// THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES WITH
+// REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
+// AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY SPECIAL, DIRECT,
+// INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM
+// LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR
+// OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
+// PERFORMANCE OF THIS SOFTWARE.
+
+package coredata
+
+type RiskAssessmentScenarioOrderField string
+
+const (
+	RiskAssessmentScenarioOrderFieldCreatedAt RiskAssessmentScenarioOrderField = "CREATED_AT"
+	RiskAssessmentScenarioOrderFieldName      RiskAssessmentScenarioOrderField = "NAME"
+)
+
+func (p RiskAssessmentScenarioOrderField) Column() string { return string(p) }
+func (p RiskAssessmentScenarioOrderField) String() string { return string(p) }
+
+func (p RiskAssessmentScenarioOrderField) MarshalText() ([]byte, error) {
+	return []byte(p.String()), nil
+}
+
+func (p *RiskAssessmentScenarioOrderField) UnmarshalText(text []byte) error {
+	*p = RiskAssessmentScenarioOrderField(text)
+	return nil
+}

pkg/coredata/risk_assessment_scenario_risk.go

@@ -0,0 +1,181 @@
+// Copyright (c) 2026 Probo Inc <hello@getprobo.com>.
+//
+// Permission to use, copy, modify, and/or distribute this software for any
+// purpose with or without fee is hereby granted, provided that the above
+// copyright notice and this permission notice appear in all copies.
+//
+// THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES WITH
+// REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
+// AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY SPECIAL, DIRECT,
+// INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM
+// LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR
+// OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
+// PERFORMANCE OF THIS SOFTWARE.
+
+package coredata
+
+import (
+	"context"
+	"errors"
+	"fmt"
+	"maps"
+	"time"
+
+	"github.com/jackc/pgx/v5"
+	"github.com/jackc/pgx/v5/pgconn"
+	"go.gearno.de/kit/pg"
+	"go.probo.inc/probo/pkg/gid"
+	"go.probo.inc/probo/pkg/page"
+)
+
+type (
+	RiskAssessmentScenarioRisk struct {
+		RiskAssessmentScenarioID gid.GID   `db:"risk_assessment_scenario_id"`
+		RiskID                   gid.GID   `db:"risk_id"`
+		CreatedAt                time.Time `db:"created_at"`
+	}
+
+	RiskAssessmentScenarioRisks []*RiskAssessmentScenarioRisk
+)
+
+func (sr *RiskAssessmentScenarioRisk) Insert(ctx context.Context, conn pg.Tx, scope Scoper) error {
+	q := `
+INSERT INTO risk_assessment_scenario_risks (
+	tenant_id,
+	risk_assessment_scenario_id,
+	risk_id,
+	created_at
+) VALUES (
+	@tenant_id,
+	@risk_assessment_scenario_id,
+	@risk_id,
+	@created_at
+)
+`
+	args := pgx.StrictNamedArgs{
+		"tenant_id":                   scope.GetTenantID(),
+		"risk_assessment_scenario_id": sr.RiskAssessmentScenarioID,
+		"risk_id":                     sr.RiskID,
+		"created_at":                  sr.CreatedAt,
+	}
+	_, err := conn.Exec(ctx, q, args)
+	if err != nil {
+		if pgErr, ok := errors.AsType[*pgconn.PgError](err); ok && pgErr.Code == "23505" {
+			return ErrResourceAlreadyExists
+		}
+		return fmt.Errorf("cannot insert risk scenario risk: %w", err)
+	}
+	return nil
+}
+
+func (sr *RiskAssessmentScenarioRisk) Delete(ctx context.Context, conn pg.Tx, scope Scoper) error {
+	q := `
+DELETE FROM risk_assessment_scenario_risks
+WHERE
+	%s
+	AND risk_assessment_scenario_id = @risk_assessment_scenario_id
+	AND risk_id = @risk_id
+`
+	q = fmt.Sprintf(q, scope.SQLFragment())
+	args := pgx.StrictNamedArgs{
+		"risk_assessment_scenario_id": sr.RiskAssessmentScenarioID,
+		"risk_id":                     sr.RiskID,
+	}
+	maps.Copy(args, scope.SQLArguments())
+	_, err := conn.Exec(ctx, q, args)
+	return err
+}
+
+func (rs *Risks) LoadByScenarioID(
+	ctx context.Context,
+	conn pg.Querier,
+	scope Scoper,
+	scenarioID gid.GID,
+	cursor *page.Cursor[RiskOrderField],
+) error {
+	q := `
+WITH linked_risks AS (
+	SELECT
+		risk_id
+	FROM
+		risk_assessment_scenario_risks
+	WHERE
+		%s
+		AND risk_assessment_scenario_id = @scenario_id
+)
+SELECT
+	id,
+	organization_id,
+	name,
+	description,
+	category,
+	treatment,
+	inherent_likelihood,
+	inherent_impact,
+	inherent_risk_score,
+	residual_likelihood,
+	residual_impact,
+	residual_risk_score,
+	owner_profile_id,
+	NULL AS owner_full_name,
+	note,
+	created_at,
+	updated_at
+FROM
+	risks
+WHERE
+	%s
+	AND id IN (SELECT risk_id FROM linked_risks)
+	AND %s
+`
+	q = fmt.Sprintf(q, scope.SQLFragment(), scope.SQLFragment(), cursor.SQLFragment())
+	args := pgx.NamedArgs{"scenario_id": scenarioID}
+	maps.Copy(args, scope.SQLArguments())
+	maps.Copy(args, cursor.SQLArguments())
+
+	rows, err := conn.Query(ctx, q, args)
+	if err != nil {
+		return fmt.Errorf("cannot query risk scenario risks: %w", err)
+	}
+	results, err := pgx.CollectRows(rows, pgx.RowToAddrOfStructByName[Risk])
+	if err != nil {
+		return fmt.Errorf("cannot collect risk scenario risks: %w", err)
+	}
+	*rs = results
+	return nil
+}
+
+func (rs *Risks) CountByScenarioID(
+	ctx context.Context,
+	conn pg.Querier,
+	scope Scoper,
+	scenarioID gid.GID,
+) (int, error) {
+	q := `
+WITH linked_risks AS (
+	SELECT
+		risk_id
+	FROM
+		risk_assessment_scenario_risks
+	WHERE
+		%s
+		AND risk_assessment_scenario_id = @scenario_id
+)
+SELECT
+	COUNT(id)
+FROM
+	risks
+WHERE
+	%s
+	AND id IN (SELECT risk_id FROM linked_risks)
+`
+	q = fmt.Sprintf(q, scope.SQLFragment(), scope.SQLFragment())
+	args := pgx.NamedArgs{"scenario_id": scenarioID}
+	maps.Copy(args, scope.SQLArguments())
+
+	var count int
+	if err := conn.QueryRow(ctx, q, args).Scan(&count); err != nil {
+		return 0, fmt.Errorf("cannot count risk scenario risks: %w", err)
+	}
+	return count, nil
+}

pkg/coredata/risk_assessment_scenario_threat.go

@@ -0,0 +1,172 @@
+// Copyright (c) 2026 Probo Inc <hello@getprobo.com>.
+//
+// Permission to use, copy, modify, and/or distribute this software for any
+// purpose with or without fee is hereby granted, provided that the above
+// copyright notice and this permission notice appear in all copies.
+//
+// THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES WITH
+// REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
+// AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY SPECIAL, DIRECT,
+// INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM
+// LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR
+// OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
+// PERFORMANCE OF THIS SOFTWARE.
+
+package coredata
+
+import (
+	"context"
+	"errors"
+	"fmt"
+	"maps"
+	"time"
+
+	"github.com/jackc/pgx/v5"
+	"github.com/jackc/pgx/v5/pgconn"
+	"go.gearno.de/kit/pg"
+	"go.probo.inc/probo/pkg/gid"
+	"go.probo.inc/probo/pkg/page"
+)
+
+type (
+	RiskAssessmentScenarioThreat struct {
+		RiskAssessmentScenarioID gid.GID   `db:"risk_assessment_scenario_id"`
+		RiskAssessmentThreatID   gid.GID   `db:"risk_assessment_threat_id"`
+		CreatedAt                time.Time `db:"created_at"`
+	}
+
+	RiskAssessmentScenarioThreats []*RiskAssessmentScenarioThreat
+)
+
+func (st *RiskAssessmentScenarioThreat) Insert(ctx context.Context, conn pg.Tx, scope Scoper) error {
+	q := `
+INSERT INTO risk_assessment_scenario_threats (
+	tenant_id,
+	risk_assessment_scenario_id,
+	risk_assessment_threat_id,
+	created_at
+) VALUES (
+	@tenant_id,
+	@risk_assessment_scenario_id,
+	@risk_assessment_threat_id,
+	@created_at
+)
+`
+	args := pgx.StrictNamedArgs{
+		"tenant_id":                   scope.GetTenantID(),
+		"risk_assessment_scenario_id": st.RiskAssessmentScenarioID,
+		"risk_assessment_threat_id":   st.RiskAssessmentThreatID,
+		"created_at":                  st.CreatedAt,
+	}
+	_, err := conn.Exec(ctx, q, args)
+	if err != nil {
+		if pgErr, ok := errors.AsType[*pgconn.PgError](err); ok && pgErr.Code == "23505" {
+			return ErrResourceAlreadyExists
+		}
+		return fmt.Errorf("cannot insert risk scenario threat: %w", err)
+	}
+	return nil
+}
+
+func (st *RiskAssessmentScenarioThreat) Delete(ctx context.Context, conn pg.Tx, scope Scoper) error {
+	q := `
+DELETE FROM risk_assessment_scenario_threats
+WHERE
+	%s
+	AND risk_assessment_scenario_id = @risk_assessment_scenario_id
+	AND risk_assessment_threat_id = @risk_assessment_threat_id
+`
+	q = fmt.Sprintf(q, scope.SQLFragment())
+	args := pgx.StrictNamedArgs{
+		"risk_assessment_scenario_id": st.RiskAssessmentScenarioID,
+		"risk_assessment_threat_id":   st.RiskAssessmentThreatID,
+	}
+	maps.Copy(args, scope.SQLArguments())
+	_, err := conn.Exec(ctx, q, args)
+	return err
+}
+
+func (ts *RiskAssessmentThreats) LoadByScenarioID(
+	ctx context.Context,
+	conn pg.Querier,
+	scope Scoper,
+	scenarioID gid.GID,
+	cursor *page.Cursor[RiskAssessmentThreatOrderField],
+) error {
+	q := `
+WITH linked_threats AS (
+	SELECT
+		risk_assessment_threat_id
+	FROM
+		risk_assessment_scenario_threats
+	WHERE
+		%s
+		AND risk_assessment_scenario_id = @scenario_id
+)
+SELECT
+	id,
+	organization_id,
+	risk_assessment_scope_id,
+	process_id,
+	name,
+	category,
+	created_at,
+	updated_at
+FROM
+	risk_assessment_threats
+WHERE
+	%s
+	AND id IN (SELECT risk_assessment_threat_id FROM linked_threats)
+	AND %s
+`
+	q = fmt.Sprintf(q, scope.SQLFragment(), scope.SQLFragment(), cursor.SQLFragment())
+	args := pgx.NamedArgs{"scenario_id": scenarioID}
+	maps.Copy(args, scope.SQLArguments())
+	maps.Copy(args, cursor.SQLArguments())
+
+	rows, err := conn.Query(ctx, q, args)
+	if err != nil {
+		return fmt.Errorf("cannot query risk scenario threats: %w", err)
+	}
+	results, err := pgx.CollectRows(rows, pgx.RowToAddrOfStructByName[RiskAssessmentThreat])
+	if err != nil {
+		return fmt.Errorf("cannot collect risk scenario threats: %w", err)
+	}
+	*ts = results
+	return nil
+}
+
+func (ts *RiskAssessmentThreats) CountByScenarioID(
+	ctx context.Context,
+	conn pg.Querier,
+	scope Scoper,
+	scenarioID gid.GID,
+) (int, error) {
+	q := `
+WITH linked_threats AS (
+	SELECT
+		risk_assessment_threat_id
+	FROM
+		risk_assessment_scenario_threats
+	WHERE
+		%s
+		AND risk_assessment_scenario_id = @scenario_id
+)
+SELECT
+	COUNT(id)
+FROM
+	risk_assessment_threats
+WHERE
+	%s
+	AND id IN (SELECT risk_assessment_threat_id FROM linked_threats)
+`
+	q = fmt.Sprintf(q, scope.SQLFragment(), scope.SQLFragment())
+	args := pgx.NamedArgs{"scenario_id": scenarioID}
+	maps.Copy(args, scope.SQLArguments())
+
+	var count int
+	if err := conn.QueryRow(ctx, q, args).Scan(&count); err != nil {
+		return 0, fmt.Errorf("cannot count risk scenario threats: %w", err)
+	}
+	return count, nil
+}

pkg/coredata/risk_assessment_scope.go

@@ -0,0 +1,242 @@
+// Copyright (c) 2026 Probo Inc <hello@getprobo.com>.
+//
+// Permission to use, copy, modify, and/or distribute this software for any
+// purpose with or without fee is hereby granted, provided that the above
+// copyright notice and this permission notice appear in all copies.
+//
+// THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES WITH
+// REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
+// AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY SPECIAL, DIRECT,
+// INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM
+// LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR
+// OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
+// PERFORMANCE OF THIS SOFTWARE.
+
+package coredata
+
+import (
+	"context"
+	"errors"
+	"fmt"
+	"maps"
+	"time"
+
+	"github.com/jackc/pgx/v5"
+	"github.com/jackc/pgx/v5/pgconn"
+	"go.gearno.de/kit/pg"
+	"go.probo.inc/probo/pkg/gid"
+	"go.probo.inc/probo/pkg/page"
+)
+
+type (
+	RiskAssessmentScope struct {
+		ID               gid.GID   `db:"id"`
+		OrganizationID   gid.GID   `db:"organization_id"`
+		RiskAssessmentID gid.GID   `db:"risk_assessment_id"`
+		Name             string    `db:"name"`
+		CreatedAt        time.Time `db:"created_at"`
+		UpdatedAt        time.Time `db:"updated_at"`
+	}
+
+	RiskAssessmentScopes []*RiskAssessmentScope
+)
+
+func (s *RiskAssessmentScope) CursorKey(orderBy RiskAssessmentScopeOrderField) page.CursorKey {
+	switch orderBy {
+	case RiskAssessmentScopeOrderFieldCreatedAt:
+		return page.CursorKey{ID: s.ID, Value: s.CreatedAt}
+	case RiskAssessmentScopeOrderFieldName:
+		return page.CursorKey{ID: s.ID, Value: s.Name}
+	}
+	panic(fmt.Sprintf("unsupported order by: %s", orderBy))
+}
+
+func (s *RiskAssessmentScope) AuthorizationAttributes(ctx context.Context, conn pg.Querier) (map[string]string, error) {
+	q := `SELECT organization_id FROM risk_assessment_scopes WHERE id = $1 LIMIT 1;`
+
+	var organizationID gid.GID
+	if err := conn.QueryRow(ctx, q, s.ID).Scan(&organizationID); err != nil {
+		if errors.Is(err, pgx.ErrNoRows) {
+			return nil, ErrResourceNotFound
+		}
+		return nil, fmt.Errorf("cannot query risk assessment scope authorization attributes: %w", err)
+	}
+
+	return map[string]string{"organization_id": organizationID.String()}, nil
+}
+
+func (ss *RiskAssessmentScopes) LoadByRiskAssessmentID(
+	ctx context.Context,
+	conn pg.Querier,
+	scope Scoper,
+	riskAssessmentID gid.GID,
+	cursor *page.Cursor[RiskAssessmentScopeOrderField],
+) error {
+	q := `
+SELECT
+	id,
+	organization_id,
+	risk_assessment_id,
+	name,
+	created_at,
+	updated_at
+FROM
+	risk_assessment_scopes
+WHERE
+	%s
+	AND risk_assessment_id = @risk_assessment_id
+	AND %s
+`
+	q = fmt.Sprintf(q, scope.SQLFragment(), cursor.SQLFragment())
+	args := pgx.NamedArgs{"risk_assessment_id": riskAssessmentID}
+	maps.Copy(args, scope.SQLArguments())
+	maps.Copy(args, cursor.SQLArguments())
+
+	rows, err := conn.Query(ctx, q, args)
+	if err != nil {
+		return fmt.Errorf("cannot query risk assessment scopes: %w", err)
+	}
+	results, err := pgx.CollectRows(rows, pgx.RowToAddrOfStructByName[RiskAssessmentScope])
+	if err != nil {
+		return fmt.Errorf("cannot collect risk assessment scopes: %w", err)
+	}
+	*ss = results
+	return nil
+}
+
+func (ss *RiskAssessmentScopes) CountByRiskAssessmentID(
+	ctx context.Context,
+	conn pg.Querier,
+	scope Scoper,
+	riskAssessmentID gid.GID,
+) (int, error) {
+	q := `
+SELECT
+	COUNT(id)
+FROM
+	risk_assessment_scopes
+WHERE
+	%s
+	AND risk_assessment_id = @risk_assessment_id
+`
+
+	q = fmt.Sprintf(q, scope.SQLFragment())
+	args := pgx.NamedArgs{"risk_assessment_id": riskAssessmentID}
+	maps.Copy(args, scope.SQLArguments())
+
+	var count int
+	if err := conn.QueryRow(ctx, q, args).Scan(&count); err != nil {
+		return 0, fmt.Errorf("cannot count risk assessment scopes: %w", err)
+	}
+	return count, nil
+}
+
+func (s *RiskAssessmentScope) LoadByID(ctx context.Context, conn pg.Querier, scope Scoper, id gid.GID) error {
+	q := `
+SELECT
+	id,
+	organization_id,
+	risk_assessment_id,
+	name,
+	created_at,
+	updated_at
+FROM
+	risk_assessment_scopes
+WHERE
+	%s
+	AND id = @id
+LIMIT 1
+`
+	q = fmt.Sprintf(q, scope.SQLFragment())
+	args := pgx.StrictNamedArgs{"id": id}
+	maps.Copy(args, scope.SQLArguments())
+	rows, err := conn.Query(ctx, q, args)
+	if err != nil {
+		return fmt.Errorf("cannot query risk assessment scope: %w", err)
+	}
+	result, err := pgx.CollectExactlyOneRow(rows, pgx.RowToStructByName[RiskAssessmentScope])
+	if err != nil {
+		if errors.Is(err, pgx.ErrNoRows) {
+			return ErrResourceNotFound
+		}
+		return fmt.Errorf("cannot collect risk assessment scope: %w", err)
+	}
+	*s = result
+	return nil
+}
+
+func (s *RiskAssessmentScope) Insert(ctx context.Context, conn pg.Tx, scope Scoper) error {
+	q := `
+INSERT INTO risk_assessment_scopes (
+	id,
+	tenant_id,
+	organization_id,
+	risk_assessment_id,
+	name,
+	created_at,
+	updated_at
+) VALUES (
+	@id,
+	@tenant_id,
+	@organization_id,
+	@risk_assessment_id,
+	@name,
+	@created_at,
+	@updated_at
+)
+`
+	args := pgx.StrictNamedArgs{
+		"id":                 s.ID,
+		"tenant_id":          scope.GetTenantID(),
+		"organization_id":    s.OrganizationID,
+		"risk_assessment_id": s.RiskAssessmentID,
+		"name":               s.Name,
+		"created_at":         s.CreatedAt,
+		"updated_at":         s.UpdatedAt,
+	}
+	_, err := conn.Exec(ctx, q, args)
+	if err != nil {
+		if pgErr, ok := errors.AsType[*pgconn.PgError](err); ok && pgErr.Code == "23505" {
+			return ErrResourceAlreadyExists
+		}
+		return fmt.Errorf("cannot insert risk assessment scope: %w", err)
+	}
+	return nil
+}
+
+func (s *RiskAssessmentScope) Update(ctx context.Context, conn pg.Tx, scope Scoper) error {
+	q := `
+UPDATE risk_assessment_scopes
+SET
+	name = @name,
+	updated_at = @updated_at
+WHERE
+	%s
+	AND id = @id
+`
+	q = fmt.Sprintf(q, scope.SQLFragment())
+	args := pgx.StrictNamedArgs{"id": s.ID, "name": s.Name, "updated_at": s.UpdatedAt}
+	maps.Copy(args, scope.SQLArguments())
+	result, err := conn.Exec(ctx, q, args)
+	if err != nil {
+		return fmt.Errorf("cannot update risk assessment scope: %w", err)
+	}
+	if result.RowsAffected() == 0 {
+		return ErrResourceNotFound
+	}
+	return nil
+}
+
+func (s *RiskAssessmentScope) Delete(ctx context.Context, conn pg.Tx, scope Scoper, id gid.GID) error {
+	q := `
+DELETE FROM risk_assessment_scopes
+WHERE
+	%s
+	AND id = @id
+`
+	q = fmt.Sprintf(q, scope.SQLFragment())
+	args := pgx.StrictNamedArgs{"id": id}
+	maps.Copy(args, scope.SQLArguments())
+	_, err := conn.Exec(ctx, q, args)
+	return err
+}

pkg/coredata/risk_assessment_scope_order_field.go

@@ -0,0 +1,34 @@
+// Copyright (c) 2026 Probo Inc <hello@getprobo.com>.
+//
+// Permission to use, copy, modify, and/or distribute this software for any
+// purpose with or without fee is hereby granted, provided that the above
+// copyright notice and this permission notice appear in all copies.
+//
+// THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES WITH
+// REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
+// AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY SPECIAL, DIRECT,
+// INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM
+// LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR
+// OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
+// PERFORMANCE OF THIS SOFTWARE.
+
+package coredata
+
+type RiskAssessmentScopeOrderField string
+
+const (
+	RiskAssessmentScopeOrderFieldCreatedAt RiskAssessmentScopeOrderField = "CREATED_AT"
+	RiskAssessmentScopeOrderFieldName      RiskAssessmentScopeOrderField = "NAME"
+)
+
+func (p RiskAssessmentScopeOrderField) Column() string { return string(p) }
+func (p RiskAssessmentScopeOrderField) String() string { return string(p) }
+
+func (p RiskAssessmentScopeOrderField) MarshalText() ([]byte, error) {
+	return []byte(p.String()), nil
+}
+
+func (p *RiskAssessmentScopeOrderField) UnmarshalText(text []byte) error {
+	*p = RiskAssessmentScopeOrderField(text)
+	return nil
+}

pkg/coredata/risk_assessment_threat.go

@@ -0,0 +1,262 @@
+// Copyright (c) 2026 Probo Inc <hello@getprobo.com>.
+//
+// Permission to use, copy, modify, and/or distribute this software for any
+// purpose with or without fee is hereby granted, provided that the above
+// copyright notice and this permission notice appear in all copies.
+//
+// THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES WITH
+// REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
+// AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY SPECIAL, DIRECT,
+// INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM
+// LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR
+// OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
+// PERFORMANCE OF THIS SOFTWARE.
+
+package coredata
+
+import (
+	"context"
+	"errors"
+	"fmt"
+	"maps"
+	"time"
+
+	"github.com/jackc/pgx/v5"
+	"github.com/jackc/pgx/v5/pgconn"
+	"go.gearno.de/kit/pg"
+	"go.probo.inc/probo/pkg/gid"
+	"go.probo.inc/probo/pkg/page"
+)
+
+type (
+	RiskAssessmentThreat struct {
+		ID                    gid.GID   `db:"id"`
+		OrganizationID        gid.GID   `db:"organization_id"`
+		RiskAssessmentScopeID gid.GID   `db:"risk_assessment_scope_id"`
+		ProcessID             gid.GID   `db:"process_id"`
+		Name                  string    `db:"name"`
+		Category              string    `db:"category"`
+		CreatedAt             time.Time `db:"created_at"`
+		UpdatedAt             time.Time `db:"updated_at"`
+	}
+
+	RiskAssessmentThreats []*RiskAssessmentThreat
+)
+
+func (t *RiskAssessmentThreat) CursorKey(orderBy RiskAssessmentThreatOrderField) page.CursorKey {
+	switch orderBy {
+	case RiskAssessmentThreatOrderFieldCreatedAt:
+		return page.CursorKey{ID: t.ID, Value: t.CreatedAt}
+	case RiskAssessmentThreatOrderFieldName:
+		return page.CursorKey{ID: t.ID, Value: t.Name}
+	}
+	panic(fmt.Sprintf("unsupported order by: %s", orderBy))
+}
+
+func (t *RiskAssessmentThreat) AuthorizationAttributes(ctx context.Context, conn pg.Querier) (map[string]string, error) {
+	q := `SELECT organization_id FROM risk_assessment_threats WHERE id = $1 LIMIT 1;`
+
+	var organizationID gid.GID
+	if err := conn.QueryRow(ctx, q, t.ID).Scan(&organizationID); err != nil {
+		if errors.Is(err, pgx.ErrNoRows) {
+			return nil, ErrResourceNotFound
+		}
+		return nil, fmt.Errorf("cannot query risk assessment threat authorization attributes: %w", err)
+	}
+
+	return map[string]string{"organization_id": organizationID.String()}, nil
+}
+
+func (ts *RiskAssessmentThreats) LoadByRiskAssessmentScopeID(
+	ctx context.Context,
+	conn pg.Querier,
+	scope Scoper,
+	riskAssessmentScopeID gid.GID,
+	cursor *page.Cursor[RiskAssessmentThreatOrderField],
+) error {
+	q := `
+SELECT
+	id,
+	organization_id,
+	risk_assessment_scope_id,
+	process_id,
+	name,
+	category,
+	created_at,
+	updated_at
+FROM
+	risk_assessment_threats
+WHERE
+	%s
+	AND risk_assessment_scope_id = @risk_assessment_scope_id
+	AND %s
+`
+	q = fmt.Sprintf(q, scope.SQLFragment(), cursor.SQLFragment())
+	args := pgx.NamedArgs{"risk_assessment_scope_id": riskAssessmentScopeID}
+	maps.Copy(args, scope.SQLArguments())
+	maps.Copy(args, cursor.SQLArguments())
+
+	rows, err := conn.Query(ctx, q, args)
+	if err != nil {
+		return fmt.Errorf("cannot query risk threats: %w", err)
+	}
+	results, err := pgx.CollectRows(rows, pgx.RowToAddrOfStructByName[RiskAssessmentThreat])
+	if err != nil {
+		return fmt.Errorf("cannot collect risk threats: %w", err)
+	}
+	*ts = results
+	return nil
+}
+
+func (ts *RiskAssessmentThreats) CountByRiskAssessmentScopeID(
+	ctx context.Context,
+	conn pg.Querier,
+	scope Scoper,
+	riskAssessmentScopeID gid.GID,
+) (int, error) {
+	q := `
+SELECT
+	COUNT(id)
+FROM
+	risk_assessment_threats
+WHERE
+	%s
+	AND risk_assessment_scope_id = @risk_assessment_scope_id
+`
+
+	q = fmt.Sprintf(q, scope.SQLFragment())
+	args := pgx.NamedArgs{"risk_assessment_scope_id": riskAssessmentScopeID}
+	maps.Copy(args, scope.SQLArguments())
+
+	var count int
+	if err := conn.QueryRow(ctx, q, args).Scan(&count); err != nil {
+		return 0, fmt.Errorf("cannot count risk threats: %w", err)
+	}
+	return count, nil
+}
+
+func (t *RiskAssessmentThreat) LoadByID(ctx context.Context, conn pg.Querier, scope Scoper, id gid.GID) error {
+	q := `
+SELECT
+	id,
+	organization_id,
+	risk_assessment_scope_id,
+	process_id,
+	name,
+	category,
+	created_at,
+	updated_at
+FROM
+	risk_assessment_threats
+WHERE
+	%s
+	AND id = @id
+LIMIT 1;
+`
+	q = fmt.Sprintf(q, scope.SQLFragment())
+	args := pgx.StrictNamedArgs{"id": id}
+	maps.Copy(args, scope.SQLArguments())
+	rows, err := conn.Query(ctx, q, args)
+	if err != nil {
+		return fmt.Errorf("cannot query risk threat: %w", err)
+	}
+	result, err := pgx.CollectExactlyOneRow(rows, pgx.RowToStructByName[RiskAssessmentThreat])
+	if err != nil {
+		if errors.Is(err, pgx.ErrNoRows) {
+			return ErrResourceNotFound
+		}
+		return fmt.Errorf("cannot collect risk threat: %w", err)
+	}
+	*t = result
+	return nil
+}
+
+func (t *RiskAssessmentThreat) Insert(ctx context.Context, conn pg.Tx, scope Scoper) error {
+	q := `
+INSERT INTO risk_assessment_threats (
+	id,
+	tenant_id,
+	organization_id,
+	risk_assessment_scope_id,
+	process_id,
+	name,
+	category,
+	created_at,
+	updated_at
+) VALUES (
+	@id,
+	@tenant_id,
+	@organization_id,
+	@risk_assessment_scope_id,
+	@process_id,
+	@name,
+	@category,
+	@created_at,
+	@updated_at
+)
+`
+	args := pgx.StrictNamedArgs{
+		"id":                       t.ID,
+		"tenant_id":                scope.GetTenantID(),
+		"organization_id":          t.OrganizationID,
+		"risk_assessment_scope_id": t.RiskAssessmentScopeID,
+		"process_id":               t.ProcessID,
+		"name":                     t.Name,
+		"category":                 t.Category,
+		"created_at":               t.CreatedAt,
+		"updated_at":               t.UpdatedAt,
+	}
+	_, err := conn.Exec(ctx, q, args)
+	if err != nil {
+		if pgErr, ok := errors.AsType[*pgconn.PgError](err); ok && pgErr.Code == "23505" {
+			return ErrResourceAlreadyExists
+		}
+		return fmt.Errorf("cannot insert risk threat: %w", err)
+	}
+	return nil
+}
+
+func (t *RiskAssessmentThreat) Update(ctx context.Context, conn pg.Tx, scope Scoper) error {
+	q := `
+UPDATE risk_assessment_threats
+SET
+	process_id = @process_id,
+	name = @name,
+	category = @category,
+	updated_at = @updated_at
+WHERE
+	%s
+	AND id = @id
+`
+	q = fmt.Sprintf(q, scope.SQLFragment())
+	args := pgx.StrictNamedArgs{
+		"id":         t.ID,
+		"process_id": t.ProcessID,
+		"name":       t.Name,
+		"category":   t.Category,
+		"updated_at": t.UpdatedAt,
+	}
+	maps.Copy(args, scope.SQLArguments())
+	result, err := conn.Exec(ctx, q, args)
+	if err != nil {
+		return fmt.Errorf("cannot update risk threat: %w", err)
+	}
+	if result.RowsAffected() == 0 {
+		return ErrResourceNotFound
+	}
+	return nil
+}
+
+func (t *RiskAssessmentThreat) Delete(ctx context.Context, conn pg.Tx, scope Scoper, id gid.GID) error {
+	q := `
+DELETE FROM risk_assessment_threats
+WHERE
+	%s
+	AND id = @id
+`
+	q = fmt.Sprintf(q, scope.SQLFragment())
+	args := pgx.StrictNamedArgs{"id": id}
+	maps.Copy(args, scope.SQLArguments())
+	_, err := conn.Exec(ctx, q, args)
+	return err
+}

pkg/coredata/risk_assessment_threat_order_field.go

@@ -0,0 +1,34 @@
+// Copyright (c) 2026 Probo Inc <hello@getprobo.com>.
+//
+// Permission to use, copy, modify, and/or distribute this software for any
+// purpose with or without fee is hereby granted, provided that the above
+// copyright notice and this permission notice appear in all copies.
+//
+// THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES WITH
+// REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
+// AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY SPECIAL, DIRECT,
+// INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM
+// LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR
+// OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
+// PERFORMANCE OF THIS SOFTWARE.
+
+package coredata
+
+type RiskAssessmentThreatOrderField string
+
+const (
+	RiskAssessmentThreatOrderFieldCreatedAt RiskAssessmentThreatOrderField = "CREATED_AT"
+	RiskAssessmentThreatOrderFieldName      RiskAssessmentThreatOrderField = "NAME"
+)
+
+func (p RiskAssessmentThreatOrderField) Column() string { return string(p) }
+func (p RiskAssessmentThreatOrderField) String() string { return string(p) }
+
+func (p RiskAssessmentThreatOrderField) MarshalText() ([]byte, error) {
+	return []byte(p.String()), nil
+}
+
+func (p *RiskAssessmentThreatOrderField) UnmarshalText(text []byte) error {
+	*p = RiskAssessmentThreatOrderField(text)
+	return nil
+}