适配器与持久化

// 基础接口：所有 adapter 必须实现
type Adapter interface {
	LoadPolicy(model model.Model) error   // 全量加载
	SavePolicy(model model.Model) error   // 全量保存（删全部+写全部）
	AddPolicy(sec, ptype string, rule []string) error      // 增量加（AutoSave 用）
	RemovePolicy(sec, ptype string, rule []string) error   // 增量删
	RemoveFilteredPolicy(sec, ptype string, fieldIndex int, fieldValues ...string) error
}

// 可选扩展接口
type BatchAdapter interface {        // AddPolicies / RemovePolicies 批量增量
	AddPolicies(sec, ptype string, rules [][]string) error
	RemovePolicies(sec, ptype string, rules [][]string) error
}
type FilteredAdapter interface {     // LoadFilteredPolicy 部分加载
	LoadFilteredPolicy(model model.Model, filter interface{}) error
	IsFiltered() bool
}
type UpdatableAdapter interface {    // UpdatePolicy 原子更新
	UpdatePolicy(sec, ptype string, oldRule, newRule []string) error
}

// 隐式：直接传文件路径
e, _ := casbin.NewEnforcer("model.conf", "policy.csv")

// 显式等价写法
import fileadapter "github.com/casbin/casbin/v3/persist/file-adapter"
a := fileadapter.NewAdapter("policy.csv")
e, _ := casbin.NewEnforcer("model.conf", a)

go get github.com/casbin/gorm-adapter/v3

import (
	"github.com/casbin/casbin/v3"
	gormadapter "github.com/casbin/gorm-adapter/v3"
	"gorm.io/driver/mysql"
	"gorm.io/gorm"
)

// 方式一：DSN 不带库名 → 自动创建名为 casbin 的数据库
a, _ := gormadapter.NewAdapter("mysql", "user:pass@tcp(127.0.0.1:3306)/")

// 方式二：DSN 带库名 + 第三个参数 true → 使用已有库 abc，自动建表 casbin_rule
a, _ = gormadapter.NewAdapter("mysql", "user:pass@tcp(127.0.0.1:3306)/abc", true)

// 方式三（推荐）：复用业务已有的 *gorm.DB 连接池
db, _ := gorm.Open(mysql.Open(dsn), &gorm.Config{})
a, _ = gormadapter.NewAdapterByDB(db)

e, _ := casbin.NewSyncedEnforcer("model.conf", a)
e.LoadPolicy() // NewEnforcer 传入 adapter 时已自动加载，重复调用是幂等的

CREATE TABLE casbin_rule (
  id    BIGINT UNSIGNED AUTO_INCREMENT PRIMARY KEY,
  ptype VARCHAR(100),   -- "p" / "g" / "g2"...
  v0    VARCHAR(100),   -- p: sub    g: user
  v1    VARCHAR(100),   -- p: obj    g: role
  v2    VARCHAR(100),   -- p: act    g: domain(如有)
  v3    VARCHAR(100), v4 VARCHAR(100), v5 VARCHAR(100),
  UNIQUE KEY unique_index (ptype, v0, v1, v2, v3, v4, v5)
);

p, admin, /api/*, GET      →  ptype=p, v0=admin, v1=/api/*, v2=GET
g, alice, admin            →  ptype=g, v0=alice, v1=admin

// 自定义表名（多个系统共库时隔离）
a, _ := gormadapter.NewAdapterByDBUseTableName(db, "myapp", "auth_rule")
// → 表名 myapp_auth_rule

// 自定义列宽（默认 100 不够放长 URL 时）
type CasbinRule struct {
	ID    uint   `gorm:"primaryKey;autoIncrement"`
	Ptype string `gorm:"size:512;uniqueIndex:unique_index"`
	V0    string `gorm:"size:512;uniqueIndex:unique_index"`
	V1    string `gorm:"size:512;uniqueIndex:unique_index"`
	V2    string `gorm:"size:512;uniqueIndex:unique_index"`
	V3    string `gorm:"size:512;uniqueIndex:unique_index"`
	V4    string `gorm:"size:512;uniqueIndex:unique_index"`
	V5    string `gorm:"size:512;uniqueIndex:unique_index"`
}
a, _ := gormadapter.NewAdapterByDBWithCustomTable(db, &CasbinRule{})

// gorm-adapter 的过滤器：按 ptype 和 v0~v5 过滤
e.LoadFilteredPolicy(gormadapter.Filter{
	V1: []string{"tenant1"},        // 只加载 domain 为 tenant1 的 p/g 行
})

// 也可以按多字段
e.LoadFilteredPolicy(gormadapter.Filter{
	Ptype: []string{"p"},
	V0:    []string{"admin", "editor"},
})

e.IsFiltered() // true：当前内存是部分策略

err := db.Transaction(func(tx *gorm.DB) error {
	// 1. 业务写入
	if err := tx.Create(&project).Error; err != nil {
		return err
	}
	// 2. 用同一个 tx 建临时 adapter + enforcer 写策略
	a, err := gormadapter.NewAdapterByDB(tx)
	if err != nil {
		return err
	}
	te, err := casbin.NewEnforcer(m, a) // m 为共享的 model
	if err != nil {
		return err
	}
	if _, err := te.AddPolicy(userID, "/projects/"+project.ID, ".*"); err != nil {
		return err
	}
	return nil
})
// 提交成功后，让常驻 enforcer 重载（或通过 Watcher 通知，见 08 章）
if err == nil {
	e.LoadPolicy()
}

import (
	"github.com/casbin/casbin/v3/model"
	"github.com/casbin/casbin/v3/persist"
)

type MyAdapter struct{ /* 存储客户端 */ }

func (a *MyAdapter) LoadPolicy(m model.Model) error {
	// 从存储读出每行 → persist.LoadPolicyLine(line, m)
	// line 形如 "p, alice, data1, read"
	for _, line := range a.readAllLines() {
		if err := persist.LoadPolicyLine(line, m); err != nil {
			return err
		}
	}
	return nil
}

func (a *MyAdapter) SavePolicy(m model.Model) error {
	// 遍历 m["p"] 与 m["g"] 写回存储
	return nil
}

// 不想支持增量时直接返回错误，Enforcer 会提示不支持 AutoSave
func (a *MyAdapter) AddPolicy(sec, ptype string, rule []string) error {
	return errors.New("not implemented")
}
func (a *MyAdapter) RemovePolicy(sec, ptype string, rule []string) error {
	return errors.New("not implemented")
}
func (a *MyAdapter) RemoveFilteredPolicy(sec, ptype string, fi int, fv ...string) error {
	return errors.New("not implemented")
}