Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (c Client) GetRepoChannelReleaseDir(repoName, group, optionalChannel string) (string, error) {
    channel, err := c.processRepoOptionalChannel(repoName, optionalChannel)
    if err != nil {
        return "", err
    }

• Read up
  Read up

Method TufRepoRotator.Rotate has 65 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (rotator *TufRepoRotator) Rotate(logger hclog.Logger, now time.Time) error {
    var changedRoot, changedTargets, changedSnapshot, changedTimestamp bool

    logger.Debug("start rotating expiration timestamps and versions of TUF repository roles")

Function updateCmd has 63 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func updateCmd() *cobra.Command {
    var noSelfUpdate bool
    var autoclean bool
    var inBackground bool
    var backgroundStdoutFile string

Function NewMethodTemplateData has 63 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func NewMethodTemplateData(name, path string, urlParameters []framework.OASParameter, methodDesc *framework.OASOperation, pathComponentSchema *framework.OASSchema) *MethodTemplateData {
    method := &MethodTemplateData{
        Name: name,
        Path: path,
    }

Function Paths has 63 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func Paths() []*framework.Path {
    return []*framework.Path{
        {
            Pattern:         "configure/trusted_pgp_public_key/?",
            HelpSynopsis:    "Configure trusted PGP public keys",

Method Manager.pathTaskLogRead has 61 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (m *Manager) pathTaskLogRead(ctx context.Context, req *logical.Request, fields *framework.FieldData) (*logical.Response, error) {
    offset := fields.Get(fieldNameOffset).(int)
    limit := fields.Get(fieldNameLimit).(int)
    uuid := fields.Get(fieldNameUUID).(string)

Method NonAtomicTufStore.WalkStagedTargets has a Cognitive Complexity of 27 (exceeds 20 allowed). Consider refactoring.

Open

func (store *NonAtomicTufStore) WalkStagedTargets(targetPathList []string, targetsFn tuf.TargetsWalkFunc) error {
    store.logger.Debug(fmt.Sprintf("-- NonAtomicTufStore.WalkStagedTargets %v", targetPathList))

    ctx := context.Background()

• Read up
  Read up

Function ValidatePublishConfig has 59 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func ValidatePublishConfig(ctx context.Context, publisher publisher.Interface, publisherRepository publisher.RepositoryInterface, config *config.TrdlChannels, logger hclog.Logger) error {
    existingReleases, err := publisher.GetExistingReleases(ctx, publisherRepository)
    if err != nil {
        return fmt.Errorf("error getting existing targets: %w", err)
    }

Function buildReleaseArtifacts has 58 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func buildReleaseArtifacts(ctx context.Context, tarWriter *nio.PipeWriter, gitRepo *git.Repository, fromImage string, runCommands []string, logger hclog.Logger) (error, func() error) {
    cli, err := client.NewClientWithOpts(client.FromEnv, client.WithAPIVersionNegotiation())
    if err != nil {
        return fmt.Errorf("unable to create docker client: %w", err), nil
    }

Function useCmd has 58 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func useCmd() *cobra.Command {
    var noSelfUpdate bool
    var shell string

    cmd := &cobra.Command{

Method Backend.Periodic has 56 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (b *Backend) Periodic(ctx context.Context, req *logical.Request) error {
    entry, err := req.Storage.Get(ctx, lastPeriodicRunTimestampKey)
    if err != nil {
        return fmt.Errorf("unable to get key %q from storage: %w", lastPeriodicRunTimestampKey, err)
    }

Method Client.doSelfUpdate has 12 return statements (exceeds 4 allowed).

Open

func (c Client) doSelfUpdate(autocleanReleases bool) error {
    channel, err := c.processRepoOptionalChannel(trdl.SelfUpdateDefaultRepo, "")
    if err != nil {
        if _, ok := err.(*RepositoryNotInitializedError); !ok {
            return err

Method Manager.pathTaskLogRead has 12 return statements (exceeds 4 allowed).

Open

func (m *Manager) pathTaskLogRead(ctx context.Context, req *logical.Request, fields *framework.FieldData) (*logical.Response, error) {
    offset := fields.Get(fieldNameOffset).(int)
    limit := fields.Get(fieldNameLimit).(int)
    uuid := fields.Get(fieldNameUUID).(string)

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func cloneGitRepositoryBranch(url, gitBranch, username, password string) (*git.Repository, error) {
    cloneGitOptions := trdlGit.CloneOptions{
        BranchName:        gitBranch,
        RecurseSubmodules: git.DefaultSubmoduleRecursionDepth,
    }

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func cloneGitRepositoryTag(url, gitTag, username, password string) (*git.Repository, error) {
    cloneGitOptions := trdlGit.CloneOptions{
        TagName:           gitTag,
        RecurseSubmodules: git.DefaultSubmoduleRecursionDepth,
    }

• Read up
  Read up

Method Backend.Periodic has 11 return statements (exceeds 4 allowed).

Open

func (b *Backend) Periodic(ctx context.Context, req *logical.Request) error {
    entry, err := req.Storage.Get(ctx, lastPeriodicRunTimestampKey)
    if err != nil {
        return fmt.Errorf("unable to get key %q from storage: %w", lastPeriodicRunTimestampKey, err)
    }

Function ForEachWorktreeFile has 11 return statements (exceeds 4 allowed).

Open

func ForEachWorktreeFile(gitRepo *git.Repository, fileFunc func(path, link string, fileReader io.Reader, info os.FileInfo) error) error {
    w, err := gitRepo.Worktree()
    if err != nil {
        return fmt.Errorf("unable to get git repository worktree: %w", err)
    }

Method TufRepoRotator.Rotate has 10 return statements (exceeds 4 allowed).

Open

func (rotator *TufRepoRotator) Rotate(logger hclog.Logger, now time.Time) error {
    var changedRoot, changedTargets, changedSnapshot, changedTimestamp bool

    logger.Debug("start rotating expiration timestamps and versions of TUF repository roles")

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (c Client) GetChannelReleaseBinDir(group, channel string) (dir string, err error) {
    err = lockgate.WithAcquire(c.locker, c.channelLockName(group, channel), lockgate.AcquireOptions{Shared: true, Timeout: trdl.DefaultLockerTimeout}, func(_ bool) error {
        dir, _, err = c.findChannelReleaseBinDir(group, channel)
        return err
    })

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (c Client) GetChannelReleaseDir(group, channel string) (dir string, err error) {
    err = lockgate.WithAcquire(c.locker, c.channelLockName(group, channel), lockgate.AcquireOptions{Shared: true, Timeout: trdl.DefaultLockerTimeout}, func(_ bool) error {
        dir, _, err = c.findChannelReleaseDir(group, channel)
        return err
    })

• Read up
  Read up