110 lines
4.1 KiB
Go
110 lines
4.1 KiB
Go
package serve
|
|
|
|
import (
|
|
"context"
|
|
"net/http"
|
|
"os"
|
|
"path/filepath"
|
|
"testing"
|
|
|
|
"github.com/docker/docker/api/types"
|
|
"github.com/h2non/gock"
|
|
"github.com/spf13/afero"
|
|
"github.com/stretchr/testify/assert"
|
|
"github.com/stretchr/testify/require"
|
|
"github.com/supabase/cli/internal/testing/apitest"
|
|
"github.com/supabase/cli/internal/utils"
|
|
"github.com/supabase/cli/pkg/cast"
|
|
)
|
|
|
|
func TestServeCommand(t *testing.T) {
|
|
t.Run("serves all functions", func(t *testing.T) {
|
|
// Setup in-memory fs
|
|
fsys := afero.NewMemMapFs()
|
|
require.NoError(t, utils.InitConfig(utils.InitParams{ProjectId: "test"}, fsys))
|
|
require.NoError(t, afero.WriteFile(fsys, utils.FallbackEnvFilePath, []byte{}, 0644))
|
|
require.NoError(t, afero.WriteFile(fsys, utils.FallbackImportMapPath, []byte{}, 0644))
|
|
// Setup mock docker
|
|
require.NoError(t, apitest.MockDocker(utils.Docker))
|
|
defer gock.OffAll()
|
|
gock.New(utils.Docker.DaemonHost()).
|
|
Get("/v" + utils.Docker.ClientVersion() + "/containers/supabase_db_test/json").
|
|
Reply(http.StatusOK).
|
|
JSON(types.ContainerJSON{})
|
|
containerId := "supabase_edge_runtime_test"
|
|
gock.New(utils.Docker.DaemonHost()).
|
|
Delete("/v" + utils.Docker.ClientVersion() + "/containers/" + containerId).
|
|
Reply(http.StatusOK)
|
|
apitest.MockDockerStart(utils.Docker, utils.GetRegistryImageUrl(utils.Config.EdgeRuntime.Image), containerId)
|
|
require.NoError(t, apitest.MockDockerLogs(utils.Docker, containerId, "success"))
|
|
// Run test
|
|
err := Run(context.Background(), "", nil, "", RuntimeOption{}, fsys)
|
|
// Check error
|
|
assert.NoError(t, err)
|
|
assert.Empty(t, apitest.ListUnmatchedRequests())
|
|
})
|
|
|
|
t.Run("throws error on malformed config", func(t *testing.T) {
|
|
// Setup in-memory fs
|
|
fsys := afero.NewMemMapFs()
|
|
require.NoError(t, afero.WriteFile(fsys, utils.ConfigPath, []byte("malformed"), 0644))
|
|
// Run test
|
|
err := Run(context.Background(), "", nil, "", RuntimeOption{}, fsys)
|
|
// Check error
|
|
assert.ErrorContains(t, err, "toml: expected = after a key, but the document ends there")
|
|
})
|
|
|
|
t.Run("throws error on missing db", func(t *testing.T) {
|
|
// Setup in-memory fs
|
|
fsys := afero.NewMemMapFs()
|
|
require.NoError(t, utils.InitConfig(utils.InitParams{ProjectId: "test"}, fsys))
|
|
// Setup mock docker
|
|
require.NoError(t, apitest.MockDocker(utils.Docker))
|
|
defer gock.OffAll()
|
|
gock.New(utils.Docker.DaemonHost()).
|
|
Get("/v" + utils.Docker.ClientVersion() + "/containers/supabase_db_test/json").
|
|
Reply(http.StatusNotFound)
|
|
// Run test
|
|
err := Run(context.Background(), "", nil, "", RuntimeOption{}, fsys)
|
|
// Check error
|
|
assert.ErrorIs(t, err, utils.ErrNotRunning)
|
|
})
|
|
|
|
t.Run("throws error on missing env file", func(t *testing.T) {
|
|
// Setup in-memory fs
|
|
fsys := afero.NewMemMapFs()
|
|
require.NoError(t, utils.InitConfig(utils.InitParams{ProjectId: "test"}, fsys))
|
|
// Setup mock docker
|
|
require.NoError(t, apitest.MockDocker(utils.Docker))
|
|
defer gock.OffAll()
|
|
gock.New(utils.Docker.DaemonHost()).
|
|
Get("/v" + utils.Docker.ClientVersion() + "/containers/supabase_db_test/json").
|
|
Reply(http.StatusOK).
|
|
JSON(types.ContainerJSON{})
|
|
// Run test
|
|
err := Run(context.Background(), ".env", nil, "", RuntimeOption{}, fsys)
|
|
// Check error
|
|
assert.ErrorContains(t, err, "open .env: file does not exist")
|
|
})
|
|
|
|
t.Run("throws error on missing import map", func(t *testing.T) {
|
|
// Setup in-memory fs
|
|
fsys := afero.NewMemMapFs()
|
|
require.NoError(t, utils.InitConfig(utils.InitParams{ProjectId: "test"}, fsys))
|
|
require.NoError(t, afero.WriteFile(fsys, ".env", []byte{}, 0644))
|
|
entrypoint := filepath.Join(utils.FunctionsDir, "hello", "index.ts")
|
|
require.NoError(t, afero.WriteFile(fsys, entrypoint, []byte{}, 0644))
|
|
// Setup mock docker
|
|
require.NoError(t, apitest.MockDocker(utils.Docker))
|
|
defer gock.OffAll()
|
|
gock.New(utils.Docker.DaemonHost()).
|
|
Get("/v" + utils.Docker.ClientVersion() + "/containers/supabase_db_test/json").
|
|
Reply(http.StatusOK).
|
|
JSON(types.ContainerJSON{})
|
|
// Run test
|
|
err := Run(context.Background(), ".env", cast.Ptr(true), "import_map.json", RuntimeOption{}, fsys)
|
|
// Check error
|
|
assert.ErrorIs(t, err, os.ErrNotExist)
|
|
})
|
|
}
|