mirror of
https://github.com/anomalyco/opencode.git
synced 2026-07-13 15:08:32 +00:00
46 lines
1.5 KiB
TypeScript
46 lines
1.5 KiB
TypeScript
export * as Policy from "./policy"
|
|
|
|
import { Context, Effect as EffectRuntime, Layer, Schema } from "effect"
|
|
import { Wildcard } from "./util/wildcard"
|
|
import { Location } from "./location"
|
|
|
|
export const Effect = Schema.Literals(["allow", "deny"]).annotate({ identifier: "Policy.Effect" })
|
|
export type Effect = typeof Effect.Type
|
|
|
|
export class Info extends Schema.Class<Info>("Policy.Info")({
|
|
action: Schema.String,
|
|
effect: Effect,
|
|
resource: Schema.String,
|
|
}) {}
|
|
|
|
export interface Interface {
|
|
readonly load: (statements: Info[]) => EffectRuntime.Effect<void>
|
|
readonly evaluate: (action: string, resource: string, fallback: Effect) => EffectRuntime.Effect<Effect>
|
|
readonly hasStatements: () => boolean
|
|
}
|
|
|
|
export class Service extends Context.Service<Service, Interface>()("@opencode/v2/Policy") {}
|
|
|
|
export const layer = Layer.effect(
|
|
Service,
|
|
EffectRuntime.gen(function* () {
|
|
let statements: Info[] = []
|
|
yield* Location.Service
|
|
|
|
return Service.of({
|
|
load: EffectRuntime.fn("Policy.load")(function* (input) {
|
|
statements = input
|
|
}),
|
|
hasStatements: () => statements.length > 0,
|
|
evaluate: EffectRuntime.fn("Policy.evaluate")(function* (action, resource, fallback) {
|
|
return (
|
|
statements.findLast(
|
|
(statement) => Wildcard.match(action, statement.action) && Wildcard.match(resource, statement.resource),
|
|
)?.effect ?? fallback
|
|
)
|
|
}),
|
|
})
|
|
}),
|
|
)
|
|
|
|
export const locationLayer = layer
|