go/kbfs/kbfsgit/start.go - master - githubmirror/client

go/kbfs/kbfsgit/start.go
93 строки3 KB
zoom-ua
gofumpt (#28710)
17 дек 2025, 17:16
17 дек 2025, 17:16cda510b
// Copyright 2017 Keybase Inc. All rights reserved.
// Use of this source code is governed by a BSD
// license that can be found in the LICENSE file.

package kbfsgit

import (
	"context"
	"io"

	"github.com/keybase/client/go/kbfs/libfs"
	"github.com/keybase/client/go/kbfs/libgit"
	"github.com/keybase/client/go/kbfs/libkbfs"
)

// StartOptions are options for starting up.
type StartOptions struct {
	KbfsParams libkbfs.InitParams
	// Remote is the name that the caller's repo (on local disk) has
	// assigned to the KBFS-based repo.
	Remote string
	// Repo is the URL the caller's repo (on local disk) is trying to
	// access, in the form "keybase://private/user/reponame".
	Repo string
	// GitDir is the filepath leading to the .git directory of the
	// caller's local on-disk repo.
	GitDir string
	// LFS indicates whether we should listen for LFS commands instead
	// of normal git commands.
	LFS bool
}

// Start starts the kbfsgit logic, and begins listening for git
// commands from `input` and responding to them via `output`.
func Start(ctx context.Context, options StartOptions,
	kbCtx libkbfs.Context, defaultLogPath string,
	input io.Reader, output io.Writer, errput io.Writer) (
	retErr *libfs.Error,
) {
	// Ideally we wouldn't print this if the verbosity is 0, but we
	// don't know that until we start parsing options.  TODO: get rid
	// of this once we integrate with the kbfs daemon.
	_, err := errput.Write([]byte("Initializing Keybase... "))
	if err != nil {
		return libfs.InitError(err.Error())
	}
	ctx, config, err := libgit.Init(
		ctx, options.KbfsParams, kbCtx, nil, defaultLogPath,
		kbCtx.GetVDebugSetting())
	if err != nil {
		return libfs.InitError(err.Error())
	}
	defer func() {
		shutdownErr := config.Shutdown(ctx)
		if retErr == nil && shutdownErr != nil {
			retErr = libfs.InitError(shutdownErr.Error())
		}
	}()

	config.MakeLogger("").CDebugf(
		ctx, "Running Git remote helper: remote=%s, repo=%s, storageRoot=%s",
		options.Remote, options.Repo, options.KbfsParams.StorageRoot)
	_, err = errput.Write([]byte("done.\n"))
	if err != nil {
		return libfs.InitError(err.Error())
	}

	t := processGit
	if options.LFS {
		t = processLFS
	}
	r, err := newRunnerWithType(
		ctx, config, options.Remote, options.Repo, options.GitDir,
		input, output, errput, t)
	if err != nil {
		return libfs.InitError(err.Error())
	}

	errCh := make(chan error, 1)
	go func() {
		errCh <- r.processCommands(ctx)
	}()

	select {
	case err := <-errCh:
		if err != nil {
			return libfs.InitError(err.Error())
		}
		return nil
	case <-ctx.Done():
		return libfs.InitError(ctx.Err().Error())
	}
}