Core 高度な組み込み

このページは integration パッケージが直接提供する機能のみを扱います。

integration が提供する機能

• integration.DefaultConfig() / integration.Config.Set(...)
• integration.New(cfg)
• rt.NewRegistry()
• rt.NewRunEngine(...)
• rt.NewRunEngineWithRegistry(...)
• rt.RunTask(...)
• rt.RequestTimeout()
• rt.NewTelegramBot(...)
• rt.NewSlackBot(...)

設定レイヤ（integration.Config）

• Overrides + Set(key, value): Viper キーを上書き。
• Features: ランタイム機能注入の切り替え（PlanTool / Guard / Skills）。
• BuiltinToolNames: 組み込みツールのホワイトリスト（空で全有効）。
• Inspect: Prompt/Request のダンプ制御。

cfg := integration.DefaultConfig()
cfg.Set("llm.provider", "openai")
cfg.Set("llm.model", "gpt-5.4")
cfg.Set("llm.api_key", os.Getenv("OPENAI_API_KEY"))
cfg.Features.Skills = true
cfg.BuiltinToolNames = []string{"read_file", "url_fetch", "todo_update"}

レジストリとカスタムツール

エンジン作成前にツールレジストリを拡張できます。

実行可能な例（カスタムツール + integration）

package main

import (
  "context"
  "encoding/json"
  "fmt"
  "os"
  "strings"

  "github.com/quailyquaily/mistermorph/agent"
  "github.com/quailyquaily/mistermorph/integration"
)

type EchoTool struct{}

func (t *EchoTool) Name() string { return "echo_text" }

func (t *EchoTool) Description() string {
  return "Echoes input text as JSON."
}

func (t *EchoTool) ParameterSchema() string {
  return `{
  "type": "object",
  "properties": {
    "text": {"type": "string", "description": "Text to echo."}
  },
  "required": ["text"]
}`
}

func (t *EchoTool) Execute(_ context.Context, params map[string]any) (string, error) {
  text, _ := params["text"].(string)
  text = strings.TrimSpace(text)
  if text == "" {
    return "", fmt.Errorf("text is required")
  }
  b, _ := json.Marshal(map[string]any{"text": text})
  return string(b), nil
}

func main() {
  cfg := integration.DefaultConfig()
  cfg.Set("llm.provider", "openai")
  cfg.Set("llm.model", "gpt-5.4")
  cfg.Set("llm.api_key", os.Getenv("OPENAI_API_KEY"))

  rt := integration.New(cfg)
  reg := rt.NewRegistry()
  reg.Register(&EchoTool{})

  task := "Call tool echo_text with text 'hello from tool', then answer with that text."

  prepared, err := rt.NewRunEngineWithRegistry(context.Background(), task, reg)
  if err != nil {
    panic(err)
  }
  defer prepared.Cleanup()

  final, _, err := prepared.Engine.Run(context.Background(), task, agent.RunOptions{Model: prepared.Model})
  if err != nil {
    panic(err)
  }

  fmt.Println(final.Output)
}

実行 API

Prepared Engine API

prepared, err := rt.NewRunEngine(context.Background(), task)
if err != nil {
  panic(err)
}
defer prepared.Cleanup()

final, _, err := prepared.Engine.Run(context.Background(), task, agent.RunOptions{
  Model: prepared.Model,
})

Prepared Engine API を選ぶ理由

• ライフサイクル制御: Cleanup() のタイミングを明示的に管理できる。
• 再利用性: 同じ prepared.Engine を複数回 Run(...) できる。
• 実行ごとの柔軟性: 各 Run で異なる RunOptions を渡せる。
• 編成しやすさ: prepared.Model と Engine を直接扱えるため、上位のセッション層に統合しやすい。

省略 API

final, runCtx, err := rt.RunTask(context.Background(), task, agent.RunOptions{})
_ = final
_ = runCtx
_ = err

デバッグと診断

cfg.Inspect.Prompt = true
cfg.Inspect.Request = true
cfg.Inspect.DumpDir = "./dump"

Telegram チャネル接続（上級）

tg, _ := rt.NewTelegramBot(integration.TelegramOptions{BotToken: os.Getenv("MISTER_MORPH_TELEGRAM_BOT_TOKEN")})
_ = tg

Slack チャネル接続（任意）

sl, _ := rt.NewSlackBot(integration.SlackOptions{
  BotToken: os.Getenv("MISTER_MORPH_SLACK_BOT_TOKEN"),
  AppToken: os.Getenv("MISTER_MORPH_SLACK_APP_TOKEN"),
})
_ = sl

このページの範囲外

より低レベルな内容は Agent レイヤ拡張 を参照してください。