casbin-pgx-adapter

package main

import (
    "log"
    
    "github.com/casbin/casbin/v3"
    pgxadapter "github.com/noho-digital/casbin-pgx-adapter"
)

func main() {
    // Database connection string
    connStr := "postgres://postgres:postgres@localhost:5432/casbin?sslmode=disable"
    
    // Create the adapter with optional configuration
    adapter, err := pgxadapter.NewAdapter(connStr,
        pgxadapter.WithTableName("my_casbin_rules"), // Optional: custom table name
        pgxadapter.WithDatabaseName("my_casbin_db"), // Optional: custom database name
    )
    if err != nil {
        log.Fatal("Failed to create adapter:", err)
    }
    
    // Create Casbin enforcer with model file and adapter
    enforcer, err := casbin.NewEnforcer("path/to/model.conf", adapter)
    if err != nil {
        log.Fatal("Failed to create enforcer:", err)
    }
    
    // Add some policies
    enforcer.AddPolicy("alice", "data1", "read")
    enforcer.AddPolicy("bob", "data2", "write")
    enforcer.AddGroupingPolicy("alice", "admin")
    
    // Save policies to database
    if err := enforcer.SavePolicy(); err != nil {
        log.Fatal("Failed to save policy:", err)
    }
    
    // Check permissions
    if allowed, _ := enforcer.Enforce("alice", "data1", "read"); allowed {
        log.Println("Alice can read data1")
    }
    
    if allowed, _ := enforcer.Enforce("bob", "data1", "read"); !allowed {
        log.Println("Bob cannot read data1")
    }
}