mirror of
https://github.com/hanzoai/deploy.git
synced 2026-10-07 08:44:50 +00:00
zeekayandHanzo Dev
1ab6e799c1
go.mod still declared `module github.com/hanzoai/deploy` after the repo was renamed. A Go module path is not cosmetic — it is the resolvable location. So `go get github.com/hanzoai/cd` could not work, and anything importing this module had to spell a name that no longer exists at that address. The build log of v3.6.0 is where it surfaced: the compiler was still emitting github.com/hanzoai/deploy/cmd/cd/commands. 3541 import paths across 690 .go, 19 .proto, 4 .yaml, 3 .sh, 2 .mod, Procfile and Makefile. Plus the 62 ghcr.io/hanzoai/deploy image references, moved to ghcr.io/hanzoai/cd to match hanzo.yml's build target — a distinct string from the module path, replaced separately so neither could clobber the other. go mod tidy clean, CGO_ENABLED=0 GOOS=linux GOARCH=amd64 go build ./... clean. Co-authored-by: Hanzo Dev <[email protected]>
102 lines
2.5 KiB
Go
102 lines
2.5 KiB
Go
package cmp_test
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
"io"
|
|
"os"
|
|
"path/filepath"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/stretchr/testify/assert"
|
|
"github.com/stretchr/testify/require"
|
|
|
|
pluginclient "github.com/hanzoai/cd/cmpserver/apiclient"
|
|
"github.com/hanzoai/cd/test"
|
|
"github.com/hanzoai/cd/util/cmp"
|
|
"github.com/hanzoai/cd/util/io/files"
|
|
)
|
|
|
|
type streamMock struct {
|
|
messages chan *pluginclient.AppStreamRequest
|
|
done chan bool
|
|
}
|
|
|
|
func (m *streamMock) Recv() (*pluginclient.AppStreamRequest, error) {
|
|
select {
|
|
case message := <-m.messages:
|
|
return message, nil
|
|
case <-m.done:
|
|
return nil, io.EOF
|
|
case <-time.After(500 * time.Millisecond):
|
|
return nil, errors.New("timeout receiving message mock")
|
|
}
|
|
}
|
|
|
|
func (m *streamMock) Send(message *pluginclient.AppStreamRequest) error {
|
|
m.messages <- message
|
|
return nil
|
|
}
|
|
|
|
func newStreamMock() *streamMock {
|
|
messagesCh := make(chan *pluginclient.AppStreamRequest)
|
|
doneCh := make(chan bool)
|
|
return &streamMock{
|
|
messages: messagesCh,
|
|
done: doneCh,
|
|
}
|
|
}
|
|
|
|
func TestReceiveApplicationStream(t *testing.T) {
|
|
t.Parallel()
|
|
t.Run("will receive the application stream successfully", func(t *testing.T) {
|
|
// given
|
|
t.Parallel()
|
|
streamMock := newStreamMock()
|
|
appDir := filepath.Join(getTestDataDir(t), "app")
|
|
workdir, err := files.CreateTempDir("")
|
|
require.NoError(t, err)
|
|
defer func() {
|
|
close(streamMock.messages)
|
|
os.RemoveAll(workdir)
|
|
}()
|
|
go streamMock.sendFile(t.Context(), t, appDir, streamMock, []string{"env1", "env2"}, []string{"DUMMY.md", "dum*"})
|
|
|
|
// when
|
|
env, err := cmp.ReceiveRepoStream(t.Context(), streamMock, workdir, false)
|
|
|
|
// then
|
|
require.NoError(t, err)
|
|
assert.NotEmpty(t, workdir)
|
|
files, err := os.ReadDir(workdir)
|
|
require.NoError(t, err)
|
|
require.Len(t, files, 2)
|
|
names := []string{}
|
|
for _, f := range files {
|
|
names = append(names, f.Name())
|
|
}
|
|
assert.Contains(t, names, "README.md")
|
|
assert.Contains(t, names, "applicationset")
|
|
assert.NotContains(t, names, "DUMMY.md")
|
|
assert.NotContains(t, names, "dummy")
|
|
assert.NotNil(t, env)
|
|
})
|
|
}
|
|
|
|
func (m *streamMock) sendFile(ctx context.Context, t *testing.T, basedir string, sender cmp.StreamSender, env []string, excludedGlobs []string) {
|
|
t.Helper()
|
|
defer func() {
|
|
m.done <- true
|
|
}()
|
|
err := cmp.SendRepoStream(ctx, basedir, basedir, sender, env, excludedGlobs)
|
|
require.NoError(t, err)
|
|
}
|
|
|
|
// getTestDataDir will return the full path of the testdata dir
|
|
// under the running test folder.
|
|
func getTestDataDir(t *testing.T) string {
|
|
t.Helper()
|
|
return filepath.Join(test.GetTestDir(t), "testdata")
|
|
}
|