mirror of
https://github.com/J3vb/OwnCord.git
synced 2026-09-03 03:50:00 +03:00
* fix(ws): 2 defect(s) (OC-0013, OC-0140) * fix(voice): 1 defect(s) (OC-0044) * fix(ws): 1 defect(s) (OC-0024) * fix(server): 1 defect(s) (OC-0027) * fix(ws): 1 defect(s) (OC-0028) * fix(server): 7 defect(s) (OC-0033, OC-0066, OC-0067, OC-0068, OC-0074, OC-0077, OC-0106) * fix(ws): 1 defect(s) (OC-0051) * fix(client): 1 defect(s) (OC-0053) * fix(client): 1 defect(s) (OC-0055) * fix(service): 1 defect(s) (OC-0069) * fix(voice): 1 defect(s) (OC-0072) * fix(service): 1 defect(s) (OC-0082) * fix(client): 1 defect(s) (OC-0083) * fix(plugin): 1 defect(s) (OC-0088) * fix(plugin): 4 defect(s) (OC-0104, OC-0126, OC-0127, OC-0133) * fix(admin): 1 defect(s) (OC-0110) * fix(client): 1 defect(s) (OC-0114) * fix(api): 1 defect(s) (OC-0139) * fix(client): 1 defect(s) (OC-0149) * test(server): adapt existing tests to updated OpenDM and IncrementMentionCounts signatures * style(plugin): modernize loops and goroutine spawns in race test * fix(ws): mirror the focus admission gate in the post-subscribe revalidation * fix(service): detach DM post-commit side effects from the request ctx, fail delete closed, add empty-fan-out fallback * fix(plugin): preserve enabled intent when upgrade reactivation hits a runtime-less build * chore(skills): harden bughunt-fix workflow and fold review lessons into bughunt-run/db-change * Add comprehensive documentation for task-observer skill - Introduced environments.md to outline activation setup, compaction behavior, and handoff-doc mode. - Created skill-authoring.md detailing taxonomy, licensing, confidentiality, and editing rules for skill creation. - Added weekly-review.md for a structured review process of OPEN observations, including scheduled and in-session fallback modes. * chore(go): pin toolchain go1.26.6 (stdlib CVE fixes flagged by govulncheck)
79 lines
3.0 KiB
Go
79 lines
3.0 KiB
Go
// Phase C Step 9 — `commands` host capability.
|
|
//
|
|
// Plugins that declare the "commands" capability register one or more slash
|
|
// commands at activation time. The WS command dispatcher (Server/ws/command.go)
|
|
// calls Registry.DispatchCommand after exhausting its built-in command table.
|
|
|
|
package plugin
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"strings"
|
|
)
|
|
|
|
// CommandResult is what a plugin returns from a command invocation.
|
|
type CommandResult struct {
|
|
// Reply is sent back to the invoking user as an ephemeral message.
|
|
Reply string
|
|
// Broadcast, when set, is also broadcast to the channel.
|
|
Broadcast string
|
|
}
|
|
|
|
// RegisterCommand binds cmd to inst. Called from the activation path in the
|
|
// wazero-tagged build once the module exports its `register_commands` table.
|
|
// Default build can call it directly from tests.
|
|
func (r *Registry) RegisterCommand(cmd string, inst *Instance) error {
|
|
cmd = strings.ToLower(strings.TrimPrefix(cmd, "/"))
|
|
if cmd == "" {
|
|
return fmt.Errorf("plugin: cannot register empty command")
|
|
}
|
|
if !inst.Manifest.HasCapability(CapCommands) {
|
|
return ErrCapabilityNotGranted
|
|
}
|
|
// Per-command ACL. The `commands` capability alone used to bind whatever
|
|
// the guest module returned from list_commands, so an admin enabling a
|
|
// plugin could not know which commands it would claim. The manifest is now
|
|
// the authority: only declared names bind, and this is the single choke
|
|
// point both auto-registration and direct registration route through.
|
|
if !inst.Manifest.DeclaresCommand(cmd) {
|
|
return fmt.Errorf("%w: %s/%s", ErrCommandNotDeclared, inst.Manifest.Name, cmd)
|
|
}
|
|
r.mu.Lock()
|
|
defer r.mu.Unlock()
|
|
// Ownership is compared by plugin identity (manifest name — unique per
|
|
// registry), not instance pointer: an in-place upgrade replaces the
|
|
// *Instance, and the same plugin must be able to re-bind its own
|
|
// commands. A *different* plugin claiming an owned command is still
|
|
// refused (cross-plugin command-hijack protection).
|
|
if existing, ok := r.commands[cmd]; ok && existing.Manifest.Name != inst.Manifest.Name {
|
|
return fmt.Errorf("plugin: command %q already registered by %q", cmd, existing.Manifest.Name)
|
|
}
|
|
r.commands[cmd] = inst
|
|
return nil
|
|
}
|
|
|
|
// DispatchCommand routes a slash command to the owning plugin. Returns
|
|
// (nil, false) when no plugin owns the command, letting the WS dispatcher
|
|
// fall back to the not-found response. Returns (nil, true) when the runtime
|
|
// is unavailable so the dispatcher can show a helpful error message.
|
|
func (r *Registry) DispatchCommand(ctx context.Context, userID int64, channelID int64, cmd string, args []string) (*CommandResult, bool) {
|
|
if r == nil {
|
|
return nil, false
|
|
}
|
|
cmd = strings.ToLower(strings.TrimPrefix(cmd, "/"))
|
|
r.mu.RLock()
|
|
inst, ok := r.commands[cmd]
|
|
platform := r.runtimePlatform
|
|
r.mu.RUnlock()
|
|
if !ok {
|
|
return nil, false
|
|
}
|
|
if platform == nil {
|
|
return &CommandResult{
|
|
Reply: fmt.Sprintf("plugin %q owns /%s but the wazero runtime is not built (run with -tags wazero)", inst.Manifest.Name, cmd),
|
|
}, true
|
|
}
|
|
return r.invokeCommand(ctx, inst, userID, channelID, cmd, args)
|
|
}
|