Files
wehub-resource-sync bf9395e022
CI / license-header (push) Has been skipped
CI / e2e-dry-run (push) Has been skipped
CI / fast-gate (push) Failing after 0s
Test PR Label Logic / test-pr-labels (push) Failing after 1s
Skill Format Check / check-format (push) Failing after 2s
CI / security (push) Failing after 5s
CI / unit-test (push) Has been skipped
CI / lint (push) Has been skipped
CI / script-test (push) Has been skipped
CI / deterministic-gate (push) Has been skipped
CI / coverage (push) Has been skipped
CI / results (push) Has been cancelled
CI / deadcode (push) Has been cancelled
CI / e2e-live (push) Has been cancelled
chore: import upstream snapshot with attribution
2026-07-13 12:22:54 +08:00

41 lines
937 B
Go

// Copyright (c) 2026 Lark Technologies Pte. Ltd.
// SPDX-License-Identifier: MIT
package bus
import (
"log"
"os"
"path/filepath"
"github.com/larksuite/cli/internal/vfs"
)
const (
maxLogSize = 5 * 1024 * 1024 // 5 MB
logFileName = "bus.log"
logBackupName = "bus.log.1"
)
// SetupBusLogger writes to eventsDir/bus.log with one-shot size-based rotation at startup only.
func SetupBusLogger(eventsDir string) (*log.Logger, error) {
if err := vfs.MkdirAll(eventsDir, 0700); err != nil {
return nil, err
}
logPath := filepath.Join(eventsDir, logFileName)
backupPath := filepath.Join(eventsDir, logBackupName)
if info, err := vfs.Stat(logPath); err == nil && info.Size() > maxLogSize {
_ = vfs.Remove(backupPath)
_ = vfs.Rename(logPath, backupPath)
}
f, err := vfs.OpenFile(logPath, os.O_APPEND|os.O_CREATE|os.O_WRONLY, 0600)
if err != nil {
return nil, err
}
return log.New(f, "", log.LstdFlags), nil
}