mirror of
https://github.com/hanzoai/forge.git
synced 2026-10-30 15:00:39 +00:00
zeekayandHanzo Dev
9a07b4d089
2978 files. The fork is 2026-07-15 (rebrand: gitea.dev -> github.com/hanzoai/git), so 2026 is the year, and "Copyright 2026 Hanzo AI, Inc." was already the form used by the handful of files that had ours. Shape is now: // Copyright 2026 Hanzo AI, Inc. All rights reserved. // Copyright 2015 The Gogs Authors. All rights reserved. // Copyright 2019 The Gitea Authors. All rights reserved. // SPDX-License-Identifier: MIT Ours on top, theirs retained verbatim. Retained because MIT requires it, and separately because they are true — those authors did write that code. Not renamed to "The Git Authors": Git is a different project under a different license, and putting its name here would attribute this code to people who have nothing to do with it. Adding our line is the fix; overwriting theirs would have been both a licence violation and a false statement. gofmt still reports import-order drift in some of these files. It predates this change (verified against a stash) and is left alone rather than burying a one-line-per-file legal change under 3000 files of unrelated reordering. Build clean. Co-authored-by: Hanzo Dev <[email protected]>
84 lines
2.9 KiB
Go
84 lines
2.9 KiB
Go
// Copyright 2026 Hanzo AI, Inc. All rights reserved.
|
|
// Copyright 2024 The Gitea Authors. All rights reserved.
|
|
// SPDX-License-Identifier: MIT
|
|
|
|
package integration
|
|
|
|
import (
|
|
"net/url"
|
|
"os"
|
|
"path/filepath"
|
|
"slices"
|
|
"strings"
|
|
"sync"
|
|
"testing"
|
|
|
|
auth_model "github.com/hanzoai/git/models/auth"
|
|
"github.com/hanzoai/git/modules/git/gitcmd"
|
|
"github.com/hanzoai/git/modules/setting"
|
|
"github.com/hanzoai/git/modules/test"
|
|
"github.com/hanzoai/git/modules/web"
|
|
"github.com/hanzoai/git/routers/common"
|
|
"github.com/hanzoai/git/services/context"
|
|
|
|
"github.com/stretchr/testify/assert"
|
|
"github.com/stretchr/testify/require"
|
|
)
|
|
|
|
func TestGitLFSSSH(t *testing.T) {
|
|
onGitRun(t, func(t *testing.T, u *url.URL) {
|
|
localRepoForUpload := filepath.Join(t.TempDir(), "test-upload")
|
|
localRepoForDownload := filepath.Join(t.TempDir(), "test-download")
|
|
apiTestContext := NewAPITestContext(t, "user2", "repo1", auth_model.AccessTokenScopeWriteRepository, auth_model.AccessTokenScopeWriteUser)
|
|
|
|
var mu sync.Mutex
|
|
var routerCalls []string
|
|
web.RouteMock(common.RouterMockPointCommonLFS, func(ctx *context.Base) {
|
|
mu.Lock()
|
|
routerCalls = append(routerCalls, ctx.Req.Method+" "+ctx.Req.URL.Path)
|
|
mu.Unlock()
|
|
})
|
|
|
|
withKeyFile(t, "my-testing-key", func(keyFile string) {
|
|
t.Run("CreateUserKey", doAPICreateUserKey(apiTestContext, "test-key", keyFile))
|
|
cloneURL := createSSHUrl(apiTestContext.GitPath(), u)
|
|
t.Run("CloneOrigin", doGitClone(localRepoForUpload, cloneURL))
|
|
|
|
cfg, err := setting.CfgProvider.PrepareSaving()
|
|
require.NoError(t, err)
|
|
cfg.Section("server").Key("LFS_ALLOW_PURE_SSH").SetValue("true")
|
|
defer test.MockVariableValue(&setting.LFS.AllowPureSSH, true)()
|
|
require.NoError(t, cfg.Save())
|
|
|
|
_, _, cmdErr := gitcmd.NewCommand("config", "lfs.sshtransfer", "always").
|
|
WithDir(localRepoForUpload).
|
|
RunStdString(t.Context())
|
|
assert.NoError(t, cmdErr)
|
|
pushedFiles := lfsCommitAndPushTest(t, localRepoForUpload, 10)
|
|
|
|
t.Run("CloneLFS", doGitClone(localRepoForDownload, cloneURL))
|
|
content, err := os.ReadFile(filepath.Join(localRepoForDownload, pushedFiles[0]))
|
|
assert.NoError(t, err)
|
|
assert.Len(t, content, 10)
|
|
})
|
|
|
|
countBatch := slices.ContainsFunc(routerCalls, func(s string) bool {
|
|
return strings.Contains(s, "POST /v1/internal/repo/user2/repo1.git/info/lfs/objects/batch")
|
|
})
|
|
countUpload := slices.ContainsFunc(routerCalls, func(s string) bool {
|
|
return strings.Contains(s, "PUT /v1/internal/repo/user2/repo1.git/info/lfs/objects/")
|
|
})
|
|
countDownload := slices.ContainsFunc(routerCalls, func(s string) bool {
|
|
return strings.Contains(s, "GET /v1/internal/repo/user2/repo1.git/info/lfs/objects/")
|
|
})
|
|
nonAPIRequests := slices.ContainsFunc(routerCalls, func(s string) bool {
|
|
fields := strings.Fields(s)
|
|
return !strings.HasPrefix(fields[1], "/api/")
|
|
})
|
|
assert.NotZero(t, countBatch)
|
|
assert.NotZero(t, countUpload)
|
|
assert.NotZero(t, countDownload)
|
|
assert.Zero(t, nonAPIRequests)
|
|
})
|
|
}
|