utils

Documentation

Index

• Constants
• Variables
• func AssertDockerIsRunning() error
• func AssertPortIsAvailable(port string) error
• func AssertSupabaseStartIsRunning()
• func DockerExec(ctx context.Context, container string, cmd []string) (io.Reader, error)
• func DockerRemoveAll()
• func DockerRun(ctx context.Context, name string, config *container.Config, ...) (io.Reader, error)
• func GetCurrentBranch() (string, error)
• func GetCurrentTimestamp() string
• func GetGitRoot() (*string, error)
• func IsBranchNameReserved(branch string) bool
• func LoadConfig()
• func ProcessDiffOutput(p *tea.Program, out io.Reader) ([]byte, error)
• func ProcessPsqlOutput(out io.Reader, p *tea.Program) error
• func ProcessPullOutput(out io.ReadCloser, p *tea.Program) error
• type DiffDependencies
• type DiffEntry
• type ProgressMsg
• type PsqlMsg
• type StatusMsg

Constants

const (
	ShadowDbName   = "supabase_shadow"
	PgbouncerImage = "edoburu/pgbouncer:1.15.0"
	KongImage      = "library/kong:2.1"
	GotrueImage    = "supabase/gotrue:v2.2.6"
	InbucketImage  = "inbucket/inbucket:stable"
	RealtimeImage  = "supabase/realtime:v0.19.0"
	PostgrestImage = "postgrest/postgrest:v8.0.0"
	StorageImage   = "supabase/storage-api:v0.9.3"
	DifferImage    = "supabase/pgadmin-schema-diff:cli-0.0.4"
	PgmetaImage    = "supabase/postgres-meta:v0.28.0"
	// TODO: Hardcode version once provided upstream.
	StudioImage = "supabase/studio:latest"

	// Args: dbname
	TerminateDbSqlFmt = `ALTER DATABASE "%[1]s" CONNECTION LIMIT 0;
SELECT pg_terminate_backend(pid) FROM pg_stat_activity WHERE datname = '%[1]s';
`
)

Variables

var (
	Docker = func() *client.Client {
		docker, err := client.NewClientWithOpts(client.WithAPIVersionNegotiation())
		if err != nil {
			fmt.Fprintln(os.Stderr, "❌ Failed to initialize Docker client.")
			os.Exit(1)
		}
		return docker
	}()

	ApiPort      string
	InbucketPort string
	DbPort       string
	StudioPort   string
	DbVersion    string
	DbImage      string
	ProjectId    string
	NetId        string
	DbId         string
	PgbouncerId  string
	KongId       string
	GotrueId     string
	InbucketId   string
	RealtimeId   string
	RestId       string
	StorageId    string
	DifferId     string
	PgmetaId     string
	StudioId     string
)

Functions

func AssertDockerIsRunning

func AssertDockerIsRunning() error

func AssertPortIsAvailable

func AssertPortIsAvailable(port string) error

func AssertSupabaseStartIsRunning

func AssertSupabaseStartIsRunning()

func DockerExec

func DockerExec(ctx context.Context, container string, cmd []string) (io.Reader, error)

func DockerRemoveAll

func DockerRemoveAll()

func DockerRun

func DockerRun(
	ctx context.Context,
	name string,
	config *container.Config,
	hostConfig *container.HostConfig,
) (io.Reader, error)

func GetCurrentBranch

func GetCurrentBranch() (string, error)

func GetCurrentTimestamp

func GetCurrentTimestamp() string

func GetGitRoot

func GetGitRoot() (*string, error)

func IsBranchNameReserved

func IsBranchNameReserved(branch string) bool

func LoadConfig

func LoadConfig()

func ProcessDiffOutput

func ProcessDiffOutput(p *tea.Program, out io.Reader) ([]byte, error)

func ProcessPsqlOutput

func ProcessPsqlOutput(out io.Reader, p *tea.Program) error

func ProcessPullOutput

func ProcessPullOutput(out io.ReadCloser, p *tea.Program) error

Types

type DiffDependencies

type DiffDependencies struct {
	Type string `json:"type"`
}

type DiffEntry

type DiffEntry struct {
	Type             string             `json:"type"`
	Status           string             `json:"status"`
	DiffDdl          string             `json:"diff_ddl"`
	GroupName        string             `json:"group_name"`
	Dependencies     []DiffDependencies `json:"dependencies"`
	SourceSchemaName *string            `json:"source_schema_name"`
}

type ProgressMsg

type ProgressMsg *float64

type PsqlMsg

type PsqlMsg *string

type StatusMsg

type StatusMsg string