diff --git a/pkg/coredata/common_third_party_domain.go b/pkg/coredata/common_third_party_domain.go
new file mode 100644
index 000000000..a1056dcc1
--- /dev/null
+++ b/pkg/coredata/common_third_party_domain.go
@@ -0,0 +1,239 @@
+// 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"
+	"time"
+
+	"github.com/jackc/pgx/v5"
+	"github.com/jackc/pgx/v5/pgconn"
+	"go.gearno.de/kit/pg"
+	"go.probo.inc/probo/pkg/gid"
+)
+
+type (
+	CommonThirdPartyDomain struct {
+		ID                 gid.GID   `db:"id"`
+		CommonThirdPartyID gid.GID   `db:"common_third_party_id"`
+		Domain             string    `db:"domain"`
+		CreatedAt          time.Time `db:"created_at"`
+		UpdatedAt          time.Time `db:"updated_at"`
+	}
+
+	CommonThirdPartyDomains []*CommonThirdPartyDomain
+)
+
+func (d *CommonThirdPartyDomain) LoadByDomain(
+	ctx context.Context,
+	conn pg.Querier,
+	domain string,
+) error {
+	q := `
+SELECT
+    id,
+    common_third_party_id,
+    domain,
+    created_at,
+    updated_at
+FROM
+    common_third_party_domains
+WHERE
+    domain = @domain
+LIMIT 1;
+`
+
+	args := pgx.StrictNamedArgs{"domain": domain}
+
+	rows, err := conn.Query(ctx, q, args)
+	if err != nil {
+		return fmt.Errorf("cannot query common third party domain: %w", err)
+	}
+
+	row, err := pgx.CollectExactlyOneRow(rows, pgx.RowToStructByName[CommonThirdPartyDomain])
+	if err != nil {
+		if errors.Is(err, pgx.ErrNoRows) {
+			return ErrResourceNotFound
+		}
+		return fmt.Errorf("cannot collect common third party domain: %w", err)
+	}
+
+	*d = row
+
+	return nil
+}
+
+func (d CommonThirdPartyDomain) Insert(
+	ctx context.Context,
+	conn pg.Tx,
+) error {
+	q := `
+INSERT INTO common_third_party_domains (
+    id,
+    common_third_party_id,
+    domain,
+    created_at,
+    updated_at
+) VALUES (
+    @id,
+    @common_third_party_id,
+    @domain,
+    @created_at,
+    @updated_at
+)
+`
+
+	args := pgx.StrictNamedArgs{
+		"id":                    d.ID,
+		"common_third_party_id": d.CommonThirdPartyID,
+		"domain":                d.Domain,
+		"created_at":            d.CreatedAt,
+		"updated_at":            d.UpdatedAt,
+	}
+
+	_, err := conn.Exec(ctx, q, args)
+	if err != nil {
+		if pgErr, ok := errors.AsType[*pgconn.PgError](err); ok {
+			if pgErr.Code == "23505" {
+				return ErrResourceAlreadyExists
+			}
+		}
+		return fmt.Errorf("cannot insert common third party domain: %w", err)
+	}
+
+	return nil
+}
+
+func (d CommonThirdPartyDomain) Upsert(
+	ctx context.Context,
+	conn pg.Tx,
+) (inserted bool, err error) {
+	q := `
+INSERT INTO common_third_party_domains (
+    id,
+    common_third_party_id,
+    domain,
+    created_at,
+    updated_at
+) VALUES (
+    @id,
+    @common_third_party_id,
+    @domain,
+    @created_at,
+    @updated_at
+)
+ON CONFLICT (domain) DO UPDATE
+SET
+    common_third_party_id = EXCLUDED.common_third_party_id,
+    updated_at            = EXCLUDED.updated_at
+RETURNING (xmax = 0) AS inserted
+`
+
+	args := pgx.StrictNamedArgs{
+		"id":                    d.ID,
+		"common_third_party_id": d.CommonThirdPartyID,
+		"domain":                d.Domain,
+		"created_at":            d.CreatedAt,
+		"updated_at":            d.UpdatedAt,
+	}
+
+	rows, err := conn.Query(ctx, q, args)
+	if err != nil {
+		return false, fmt.Errorf("cannot upsert common third party domain: %w", err)
+	}
+	defer rows.Close()
+
+	inserted, err = pgx.CollectExactlyOneRow(rows, pgx.RowTo[bool])
+	if err != nil {
+		return false, fmt.Errorf("cannot collect upsert result: %w", err)
+	}
+
+	return inserted, nil
+}
+
+func (d CommonThirdPartyDomain) Delete(
+	ctx context.Context,
+	conn pg.Tx,
+) error {
+	q := `DELETE FROM common_third_party_domains WHERE id = @id`
+
+	args := pgx.StrictNamedArgs{"id": d.ID}
+
+	result, err := conn.Exec(ctx, q, args)
+	if err != nil {
+		return fmt.Errorf("cannot delete common third party domain: %w", err)
+	}
+
+	if result.RowsAffected() == 0 {
+		return ErrResourceNotFound
+	}
+
+	return nil
+}
+
+func (ds *CommonThirdPartyDomains) LoadByCommonThirdPartyID(
+	ctx context.Context,
+	conn pg.Querier,
+	commonThirdPartyID gid.GID,
+) error {
+	q := `
+SELECT
+    id,
+    common_third_party_id,
+    domain,
+    created_at,
+    updated_at
+FROM
+    common_third_party_domains
+WHERE
+    common_third_party_id = @common_third_party_id
+ORDER BY domain ASC;
+`
+
+	args := pgx.StrictNamedArgs{"common_third_party_id": commonThirdPartyID}
+
+	rows, err := conn.Query(ctx, q, args)
+	if err != nil {
+		return fmt.Errorf("cannot query common third party domains: %w", err)
+	}
+
+	domains, err := pgx.CollectRows(rows, pgx.RowToAddrOfStructByName[CommonThirdPartyDomain])
+	if err != nil {
+		return fmt.Errorf("cannot collect common third party domains: %w", err)
+	}
+
+	*ds = domains
+
+	return nil
+}
+
+func (ds *CommonThirdPartyDomains) DeleteByCommonThirdPartyID(
+	ctx context.Context,
+	conn pg.Tx,
+	commonThirdPartyID gid.GID,
+) error {
+	q := `DELETE FROM common_third_party_domains WHERE common_third_party_id = @common_third_party_id`
+
+	args := pgx.StrictNamedArgs{"common_third_party_id": commonThirdPartyID}
+
+	_, err := conn.Exec(ctx, q, args)
+	if err != nil {
+		return fmt.Errorf("cannot delete common third party domains: %w", err)
+	}
+
+	return nil
+}
diff --git a/pkg/coredata/common_tracker_pattern.go b/pkg/coredata/common_tracker_pattern.go
new file mode 100644
index 000000000..7d622d93f
--- /dev/null
+++ b/pkg/coredata/common_tracker_pattern.go
@@ -0,0 +1,378 @@
+// 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"
+	"time"
+
+	"github.com/jackc/pgx/v5"
+	"go.gearno.de/kit/pg"
+	"go.probo.inc/probo/pkg/gid"
+)
+
+type (
+	CommonTrackerPattern struct {
+		ID                 gid.GID                 `db:"id"`
+		CommonThirdPartyID *gid.GID                `db:"common_third_party_id"`
+		TrackerType        TrackerType             `db:"tracker_type"`
+		Pattern            string                  `db:"pattern"`
+		MatchType          TrackerPatternMatchType `db:"match_type"`
+		Description        string                  `db:"description"`
+		MaxAgeSeconds      *int                    `db:"max_age_seconds"`
+		Confidence         float32                 `db:"confidence"`
+		CreatedAt          time.Time               `db:"created_at"`
+		UpdatedAt          time.Time               `db:"updated_at"`
+	}
+
+	CommonTrackerPatterns []*CommonTrackerPattern
+)
+
+func (p *CommonTrackerPattern) LoadByID(
+	ctx context.Context,
+	conn pg.Querier,
+	id gid.GID,
+) error {
+	q := `
+SELECT
+    id,
+    common_third_party_id,
+    tracker_type,
+    pattern,
+    match_type,
+    description,
+    max_age_seconds,
+    confidence,
+    created_at,
+    updated_at
+FROM
+    common_tracker_patterns
+WHERE
+    id = @id
+LIMIT 1;
+`
+
+	args := pgx.StrictNamedArgs{"id": id}
+
+	rows, err := conn.Query(ctx, q, args)
+	if err != nil {
+		return fmt.Errorf("cannot query common tracker pattern: %w", err)
+	}
+
+	row, err := pgx.CollectExactlyOneRow(rows, pgx.RowToStructByName[CommonTrackerPattern])
+	if err != nil {
+		if errors.Is(err, pgx.ErrNoRows) {
+			return ErrResourceNotFound
+		}
+		return fmt.Errorf("cannot collect common tracker pattern: %w", err)
+	}
+
+	*p = row
+
+	return nil
+}
+
+func (p *CommonTrackerPattern) LoadByPattern(
+	ctx context.Context,
+	conn pg.Querier,
+	trackerType TrackerType,
+	pattern string,
+	maxAgeSeconds *int,
+) error {
+	q := `
+SELECT
+    id,
+    common_third_party_id,
+    tracker_type,
+    pattern,
+    match_type,
+    description,
+    max_age_seconds,
+    confidence,
+    created_at,
+    updated_at
+FROM
+    common_tracker_patterns
+WHERE
+    tracker_type = @tracker_type
+    AND pattern = @pattern
+    AND COALESCE(max_age_seconds, -1) = COALESCE(@max_age_seconds, -1)
+LIMIT 1;
+`
+
+	args := pgx.StrictNamedArgs{
+		"tracker_type":    trackerType,
+		"pattern":         pattern,
+		"max_age_seconds": maxAgeSeconds,
+	}
+
+	rows, err := conn.Query(ctx, q, args)
+	if err != nil {
+		return fmt.Errorf("cannot query common tracker pattern: %w", err)
+	}
+
+	row, err := pgx.CollectExactlyOneRow(rows, pgx.RowToStructByName[CommonTrackerPattern])
+	if err != nil {
+		if errors.Is(err, pgx.ErrNoRows) {
+			return ErrResourceNotFound
+		}
+		return fmt.Errorf("cannot collect common tracker pattern: %w", err)
+	}
+
+	*p = row
+
+	return nil
+}
+
+func (p CommonTrackerPattern) Insert(
+	ctx context.Context,
+	conn pg.Tx,
+) error {
+	q := `
+INSERT INTO common_tracker_patterns (
+    id,
+    common_third_party_id,
+    tracker_type,
+    pattern,
+    match_type,
+    description,
+    max_age_seconds,
+    confidence,
+    created_at,
+    updated_at
+) VALUES (
+    @id,
+    @common_third_party_id,
+    @tracker_type,
+    @pattern,
+    @match_type,
+    @description,
+    @max_age_seconds,
+    @confidence,
+    @created_at,
+    @updated_at
+)
+`
+
+	args := pgx.StrictNamedArgs{
+		"id":                    p.ID,
+		"common_third_party_id": p.CommonThirdPartyID,
+		"tracker_type":          p.TrackerType,
+		"pattern":               p.Pattern,
+		"match_type":            p.MatchType,
+		"description":           p.Description,
+		"max_age_seconds":       p.MaxAgeSeconds,
+		"confidence":            p.Confidence,
+		"created_at":            p.CreatedAt,
+		"updated_at":            p.UpdatedAt,
+	}
+
+	_, err := conn.Exec(ctx, q, args)
+	if err != nil {
+		return fmt.Errorf("cannot insert common tracker pattern: %w", err)
+	}
+
+	return nil
+}
+
+func (p CommonTrackerPattern) Upsert(
+	ctx context.Context,
+	conn pg.Tx,
+) (inserted bool, err error) {
+	q := `
+INSERT INTO common_tracker_patterns (
+    id,
+    common_third_party_id,
+    tracker_type,
+    pattern,
+    match_type,
+    description,
+    max_age_seconds,
+    confidence,
+    created_at,
+    updated_at
+) VALUES (
+    @id,
+    @common_third_party_id,
+    @tracker_type,
+    @pattern,
+    @match_type,
+    @description,
+    @max_age_seconds,
+    @confidence,
+    @created_at,
+    @updated_at
+)
+ON CONFLICT (tracker_type, pattern, COALESCE(max_age_seconds, -1)) DO UPDATE
+SET
+    common_third_party_id = EXCLUDED.common_third_party_id,
+    match_type            = EXCLUDED.match_type,
+    description           = EXCLUDED.description,
+    confidence            = EXCLUDED.confidence,
+    updated_at            = EXCLUDED.updated_at
+RETURNING (xmax = 0) AS inserted
+`
+
+	args := pgx.StrictNamedArgs{
+		"id":                    p.ID,
+		"common_third_party_id": p.CommonThirdPartyID,
+		"tracker_type":          p.TrackerType,
+		"pattern":               p.Pattern,
+		"match_type":            p.MatchType,
+		"description":           p.Description,
+		"max_age_seconds":       p.MaxAgeSeconds,
+		"confidence":            p.Confidence,
+		"created_at":            p.CreatedAt,
+		"updated_at":            p.UpdatedAt,
+	}
+
+	rows, err := conn.Query(ctx, q, args)
+	if err != nil {
+		return false, fmt.Errorf("cannot upsert common tracker pattern: %w", err)
+	}
+	defer rows.Close()
+
+	inserted, err = pgx.CollectExactlyOneRow(rows, pgx.RowTo[bool])
+	if err != nil {
+		return false, fmt.Errorf("cannot collect upsert result: %w", err)
+	}
+
+	return inserted, nil
+}
+
+func (p CommonTrackerPattern) Delete(
+	ctx context.Context,
+	conn pg.Tx,
+	id gid.GID,
+) error {
+	q := `DELETE FROM common_tracker_patterns WHERE id = @id`
+
+	args := pgx.StrictNamedArgs{"id": id}
+
+	result, err := conn.Exec(ctx, q, args)
+	if err != nil {
+		return fmt.Errorf("cannot delete common tracker pattern: %w", err)
+	}
+
+	if result.RowsAffected() == 0 {
+		return ErrResourceNotFound
+	}
+
+	return nil
+}
+
+func (ps *CommonTrackerPatterns) FindMatchingPattern(
+	ctx context.Context,
+	conn pg.Querier,
+	trackerType TrackerType,
+	identifier string,
+) (*CommonTrackerPattern, error) {
+	q := `
+SELECT
+    id,
+    common_third_party_id,
+    tracker_type,
+    pattern,
+    match_type,
+    description,
+    max_age_seconds,
+    confidence,
+    created_at,
+    updated_at
+FROM
+    common_tracker_patterns
+WHERE
+    tracker_type = @tracker_type
+    AND (
+        (match_type = @match_type_glob
+         AND @identifier LIKE
+             replace(replace(replace(replace(
+                 pattern, E'\\', E'\\\\'), '%%', E'\\%%'), '_', E'\\_'), '*', '%%')
+             ESCAPE E'\\')
+        OR (match_type = @match_type_exact AND pattern = @identifier)
+    )
+ORDER BY
+    CASE WHEN match_type = @match_type_exact AND pattern = @identifier THEN 0
+         ELSE 1
+    END,
+    length(replace(pattern, '*', '')) DESC
+LIMIT 1;
+`
+
+	args := pgx.StrictNamedArgs{
+		"tracker_type":     trackerType,
+		"identifier":       identifier,
+		"match_type_glob":  TrackerPatternMatchTypeGlob,
+		"match_type_exact": TrackerPatternMatchTypeExact,
+	}
+
+	rows, err := conn.Query(ctx, q, args)
+	if err != nil {
+		return nil, fmt.Errorf("cannot query common tracker patterns: %w", err)
+	}
+
+	pattern, err := pgx.CollectExactlyOneRow(rows, pgx.RowToStructByName[CommonTrackerPattern])
+	if err != nil {
+		if errors.Is(err, pgx.ErrNoRows) {
+			return nil, nil
+		}
+		return nil, fmt.Errorf("cannot collect common tracker pattern: %w", err)
+	}
+
+	return &pattern, nil
+}
+
+func (ps *CommonTrackerPatterns) LoadByCommonThirdPartyID(
+	ctx context.Context,
+	conn pg.Querier,
+	commonThirdPartyID gid.GID,
+) error {
+	q := `
+SELECT
+    id,
+    common_third_party_id,
+    tracker_type,
+    pattern,
+    match_type,
+    description,
+    max_age_seconds,
+    confidence,
+    created_at,
+    updated_at
+FROM
+    common_tracker_patterns
+WHERE
+    common_third_party_id = @common_third_party_id
+ORDER BY pattern ASC;
+`
+
+	args := pgx.StrictNamedArgs{"common_third_party_id": commonThirdPartyID}
+
+	rows, err := conn.Query(ctx, q, args)
+	if err != nil {
+		return fmt.Errorf("cannot query common tracker patterns: %w", err)
+	}
+
+	patterns, err := pgx.CollectRows(rows, pgx.RowToAddrOfStructByName[CommonTrackerPattern])
+	if err != nil {
+		return fmt.Errorf("cannot collect common tracker patterns: %w", err)
+	}
+
+	*ps = patterns
+
+	return nil
+}