整合性署名

DD は HMAC ベースのログ整合性署名メカニズムを提供し、ログエントリが改ざんされていないことを検証できます。

IntegritySigner

ログエントリ署名器。HMAC 署名と単調シーケンス追跡をサポート（各エントリは独立、前方リンクなし。事後的にエントリの消失/リプレイを検出するため、呼び出し元がシーケンス番号を自前で比較する必要があります）。

作成

func NewIntegritySigner(cfg IntegrityConfig) (*IntegritySigner, error)

渡された IntegrityConfig で署名器を作成します。DefaultIntegrityConfigSafe() で暗号論的に安全なランダムキーを生成できます。

エラーを返すケース：SecretKey が 32 バイト未満、または HashAlgorithm が未サポート。

キーセキュリティ

NewIntegritySigner は渡された SecretKey をコピーし、直ちに元の cfg.SecretKey をゼロクリアします（鍵素材が 2 箇所のメモリに残留するのを防止）。呼び出し側でもログやシリアライズで元のキーを露出しないようにしてください。

// 安全に作成（本番環境推奨）
cfg, err := dd.DefaultIntegrityConfigSafe()
if err != nil {
    log.Fatal(err)
}
signer, err := dd.NewIntegritySigner(cfg)
if err != nil {
    log.Fatal(err)
}

// カスタム設定
cfg := dd.IntegrityConfig{
    SecretKey:      []byte("my-secret-key-that-is-at-least-32b!"),
    HashAlgorithm:  dd.HashAlgorithmSHA256,
    IncludeTimestamp: true,
    IncludeSequence:  true,
}
signer, err = dd.NewIntegritySigner(cfg)
if err != nil {
    log.Fatal(err)
}

署名メソッド

Sign

func (s *IntegritySigner) Sign(message string) string

ログメッセージに HMAC 署名を生成します。スレッドセーフで並行呼び出し可能。

sig := signer.Sign("ユーザーログイン admin 192.168.1.1")
// → "[SIG:1713456789000000000:1:base64signature...]"

SignFields

func (s *IntegritySigner) SignFields(message string, fields []Field) string

フィールド付きメッセージの署名を生成します。署名にはメッセージと全フィールド値が含まれます。スレッドセーフで並行呼び出し可能。

sig := signer.SignFields("ユーザーログイン", []dd.Field{
    dd.String("user", "admin"),
    dd.String("ip", "192.168.1.1"),
})

検証メソッド

Verify

func (s *IntegritySigner) Verify(entry string) (*LogIntegrity, error)

ログエントリの整合性を検証します。スレッドセーフで並行呼び出し可能。

integrity, err := signer.Verify(signedEntry)
if err != nil {
    // 検証エラー（signer が nil など）
}
if !integrity.Valid {
    // 署名が無効：署名の不一致またはフォーマットエラー
}
if integrity.Sequence != expectedSeq {
    // シリアル番号が不連続：エントリが削除された可能性
}

その他のメソッド

メソッド	シグネチャ	説明
GetSequence	() uint64	現在のシリアル番号
ResetSequence	()	シリアル番号をリセット
Stats	() IntegrityStats	署名統計

IntegrityConfig

署名設定。

type IntegrityConfig struct {
    SecretKey        []byte        // HMAC キー（SHA-256 は ≥ 32 バイト必須；厳重に保管し定期ローテーション）
    HashAlgorithm    HashAlgorithm // ハッシュアルゴリズム（デフォルト SHA256）
    IncludeTimestamp bool          // 署名にタイムスタンプを含む
    IncludeSequence  bool          // 単調増加するシーケンス番号を署名に含む（Verify 結果がこのシーケンス番号を返すため、リプレイ/並び替え検出のためには呼び出し元が自前で追跡する必要があります）
    SignaturePrefix  string        // 署名プレフィックス（デフォルト "[SIG:"；空の場合 NewIntegritySigner がデフォルト値を設定）
}

安全な作成

func DefaultIntegrityConfigSafe() (IntegrityConfig, error)

デフォルト設定を安全に作成（キーを自動生成）。本番環境での使用を推奨。

メソッド

メソッド	シグネチャ	説明
Validate	() error	設定の妥当性を検証（SecretKey は ≥ 32 バイト必須；HashAlgorithm はサポート対象アルゴリズム必須）
Clone	() IntegrityConfig	設定をディープコピー（SecretKey は新規スライスとしてコピー）
MarshalJSON	() ([]byte, error)	JSON シリアライズ（キー自体はシリアライズに参加せず、secretKeyLength のみ出力）

cfg, err := dd.DefaultIntegrityConfigSafe()
if err != nil {
    log.Fatal(err)
}
signer, err := dd.NewIntegritySigner(cfg)
if err != nil {
    log.Fatal(err)
}

LogIntegrity

ログ整合性検証結果。

type LogIntegrity struct {
    Valid     bool       // 署名が有効か
    Timestamp time.Time  // 署名タイムスタンプ
    Sequence  uint64     // シリアル番号
    Message   string     // 元のメッセージ
}

IntegrityStats

署名統計データ。

type IntegrityStats struct {
    Sequence         uint64 // 現在のシリアル番号
    Algorithm        string // アルゴリズム名
    IncludeTimestamp bool   // タイムスタンプを含むか
    IncludeSequence  bool   // シリアル番号を含むか
}

HashAlgorithm

定数	説明
HashAlgorithmSHA256	SHA-256 アルゴリズム

String() メソッドを実装し、アルゴリズム名を返します。

完全な例

ログ署名フロー

cfg, err := dd.DefaultIntegrityConfigSafe()
if err != nil {
    log.Fatal(err)
}
signer, err := dd.NewIntegritySigner(cfg)
if err != nil {
    log.Fatal(err)
}

// ログに署名
message := "ユーザーログイン"
signature := signer.Sign(message)

// 署名付きログエントリを保存
logEntry := message + signature

// ログを検証
result, err := signer.Verify(logEntry)
if err != nil {
    fmt.Println("整合性検証失敗：", err)
} else if result.Valid {
    fmt.Printf("検証成功 - シリアル番号：%d\n", result.Sequence)
}

監査統合

cfg, err := dd.DefaultIntegrityConfigSafe()
if err != nil {
    log.Fatal(err)
}
signer, err := dd.NewIntegritySigner(cfg)
if err != nil {
    log.Fatal(err)
}

auditCfg := dd.DefaultAuditConfig()
auditCfg.IntegritySigner = signer
audit, _ := dd.NewAuditLogger(auditCfg)
defer audit.Close()

// 監査ログは自動的に署名される
audit.Log(dd.AuditEvent{
    Type:     dd.AuditEventSecurityViolation,
    Message:  "SQL インジェクションの試行",
    Severity: dd.AuditSeverityCritical,
    Metadata: map[string]any{"input": "' OR 1=1"},
})

// 監査ログの検証
stats := signer.Stats()
fmt.Printf("アルゴリズム: %s, シリアル番号: %d\n", stats.Algorithm, stats.Sequence)

次のステップ

• 監査ログ -- AuditLogger 詳解
• セキュリティフィルタ -- 機密データフィルタリング
• 定数とエラー -- エラーコード