add feature: IntrospectDMMF & IntrospectSDL & migrate push SDK

binaries/binaries.go

@@ -15,11 +15,13 @@ import (
 )
 
 // PrismaVersion is a hardcoded version of the Prisma CLI.
-const PrismaVersion = "3.13.0"
+//const PrismaVersion = "3.13.0"
+var PrismaVersion = "3.13.0"
 
 // EngineVersion is a hardcoded version of the Prisma Engine.
 // The versions can be found under https://github.com/prisma/prisma-engines/commits/master
-const EngineVersion = "efdf9b1183dddfd4258cd181a72125755215ab7b"
+//const EngineVersion = "694eea289a8462c80264df36757e4fdc129b1b32"
+var EngineVersion = "694eea289a8462c80264df36757e4fdc129b1b32"
 
 // PrismaURL points to an S3 bucket URL where the CLI binaries are stored.
 var PrismaURL = "https://prisma-photongo.s3-eu-west-1.amazonaws.com/%s-%s-%s-x64.gz"
@@ -63,19 +65,19 @@ func PrismaCLIName() string {
 	return fmt.Sprintf("prisma-cli-%s-x64", variation)
 }
 
-var baseDirName = path.Join("prisma", "binaries")
+var baseDirName = filepath.Join("prisma", "binaries")
 
 // GlobalTempDir returns the path of where the engines live
 // internally, this is the global temp dir
 func GlobalTempDir(version string) string {
 	temp := os.TempDir()
 	logger.Debug.Printf("temp dir: %s", temp)
 
-	return path.Join(temp, baseDirName, "engines", version)
+	return filepath.ToSlash(filepath.Join(temp, baseDirName, "engines", version))
 }
 
 func GlobalUnpackDir(version string) string {
-	return path.Join(GlobalTempDir(version), "unpacked", "v2")
+	return filepath.ToSlash(filepath.Join(GlobalTempDir(version), "unpacked", "v2"))
 }
 
 // GlobalCacheDir returns the path of where the CLI lives
@@ -88,13 +90,13 @@ func GlobalCacheDir() string {
 
 	logger.Debug.Printf("global cache dir: %s", cache)
 
-	return path.Join(cache, baseDirName, "cli", PrismaVersion)
+	return filepath.ToSlash(filepath.Join(cache, baseDirName, "cli", PrismaVersion))
 }
 
 func FetchEngine(toDir string, engineName string, binaryPlatformName string) error {
 	logger.Debug.Printf("checking %s...", engineName)
 
-	to := platform.CheckForExtension(binaryPlatformName, path.Join(toDir, EngineVersion, fmt.Sprintf("prisma-%s-%s", engineName, binaryPlatformName)))
+	to := platform.CheckForExtension(binaryPlatformName, filepath.ToSlash(filepath.Join(toDir, EngineVersion, fmt.Sprintf("prisma-%s-%s", engineName, binaryPlatformName))))
 
 	binaryPlatformRemoteName := binaryPlatformName
 	if binaryPlatformRemoteName == "linux" {
@@ -145,7 +147,7 @@ func FetchNative(toDir string) error {
 
 func DownloadCLI(toDir string) error {
 	cli := PrismaCLIName()
-	to := platform.CheckForExtension(platform.Name(), path.Join(toDir, cli))
+	to := platform.CheckForExtension(platform.Name(), filepath.ToSlash(filepath.Join(toDir, cli)))
 	url := platform.CheckForExtension(platform.Name(), fmt.Sprintf(PrismaURL, "prisma-cli", PrismaVersion, platform.Name()))
 
 	logger.Debug.Printf("ensuring CLI %s from %s to %s", cli, to, url)
@@ -166,15 +168,15 @@ func DownloadCLI(toDir string) error {
 }
 
 func GetEnginePath(dir, engine, binaryName string) string {
-	return platform.CheckForExtension(binaryName, path.Join(dir, EngineVersion, fmt.Sprintf("prisma-%s-%s", engine, binaryName)))
+	return platform.CheckForExtension(binaryName, filepath.ToSlash(filepath.Join(dir, EngineVersion, fmt.Sprintf("prisma-%s-%s", engine, binaryName))))
 }
 
 func DownloadEngine(name string, toDir string) (file string, err error) {
 	binaryName := platform.BinaryPlatformName()
 
 	logger.Debug.Printf("checking %s...", name)
 
-	to := platform.CheckForExtension(binaryName, path.Join(toDir, EngineVersion, fmt.Sprintf("prisma-%s-%s", name, binaryName)))
+	to := platform.CheckForExtension(binaryName, filepath.ToSlash(filepath.Join(toDir, EngineVersion, fmt.Sprintf("prisma-%s-%s", name, binaryName))))
 
 	url := platform.CheckForExtension(binaryName, fmt.Sprintf(EngineURL, EngineVersion, binaryName, name))
 

binaries/platform/platform.go

@@ -19,8 +19,16 @@ func BinaryPlatformName() string {
 	}
 
 	platform := Name()
+	// Refer to https://github.dev/prisma/prisma/tree/main/packages/cli/src/utils
+	// Not well test for !win & !mac
+	arch := Arch()
 
 	if platform != "linux" {
+		if platform == "darwin" {
+			if arch == "arm64" {
+				return fmt.Sprintf("%s-%s", platform, arch)
+			}
+		}
 		return platform
 	}
 
@@ -33,6 +41,11 @@ func BinaryPlatformName() string {
 	ssl := getOpenSSL()
 
 	name := fmt.Sprintf("%s-openssl-%s", distro, ssl)
+	if arch == "arm64" {
+		name = fmt.Sprintf("%s--arm64-openssl-%s", distro, ssl)
+	} else if arch == "arm" {
+		name = fmt.Sprintf("%s-arm-openssl-%s", distro, ssl)
+	}
 
 	binaryNameWithSSLCache = name
 
@@ -44,6 +57,10 @@ func Name() string {
 	return runtime.GOOS
 }
 
+func Arch() string {
+	return runtime.GOARCH
+}
+
 // CheckForExtension adds a .exe extension on windows (e.g. .gz -> .exe.gz)
 func CheckForExtension(platform, path string) string {
 	if platform == "windows" {

binaries/unpack/unpack.go

@@ -3,7 +3,7 @@ package unpack
 import (
 	"fmt"
 	"os"
-	"path"
+	"path/filepath"
 	"time"
 
 	"github.com/prisma/prisma-client-go/binaries"
@@ -24,7 +24,7 @@ func Unpack(data []byte, name string, version string) {
 
 	tempDir := binaries.GlobalUnpackDir(version)
 
-	dir := platform.CheckForExtension(platform.Name(), path.Join(tempDir, file))
+	dir := platform.CheckForExtension(platform.Name(), filepath.ToSlash(filepath.ToSlash(filepath.Join(tempDir, file))))
 
 	if err := os.MkdirAll(tempDir, os.ModePerm); err != nil {
 		panic(fmt.Errorf("mkdirall failed: %w", err))

cli/cli.go

@@ -2,13 +2,12 @@ package cli
 
 import (
 	"fmt"
-	"os"
-	"os/exec"
-	"path"
-
 	"github.com/prisma/prisma-client-go/binaries"
 	"github.com/prisma/prisma-client-go/binaries/platform"
 	"github.com/prisma/prisma-client-go/logger"
+	"os"
+	"os/exec"
+	"path/filepath"
 )
 
 // Run the prisma CLI with given arguments
@@ -25,9 +24,9 @@ func Run(arguments []string, output bool) error {
 
 	prisma := binaries.PrismaCLIName()
 
-	logger.Debug.Printf("running %s %+v", path.Join(dir, prisma), arguments)
+	logger.Debug.Printf("running %s %+v", filepath.ToSlash(filepath.Join(dir, prisma)), arguments)
 
-	cmd := exec.Command(path.Join(dir, prisma), arguments...) //nolint:gosec
+	cmd := exec.Command(filepath.ToSlash(filepath.Join(dir, prisma)), arguments...) //nolint:gosec
 	binaryName := platform.CheckForExtension(platform.Name(), platform.BinaryPlatformName())
 
 	cmd.Env = os.Environ()
@@ -41,7 +40,7 @@ func Run(arguments []string, output bool) error {
 			logger.Debug.Printf("overriding %s to %s", engine.Name, env)
 			value = env
 		} else {
-			value = path.Join(dir, binaries.EngineVersion, fmt.Sprintf("prisma-%s-%s", engine.Name, binaryName))
+			value = filepath.ToSlash(filepath.Join(dir, binaries.EngineVersion, fmt.Sprintf("prisma-%s-%s", engine.Name, binaryName)))
 		}
 
 		cmd.Env = append(cmd.Env, fmt.Sprintf("%s=%s", engine.Env, value))