supabase

type Dialer interface {
	Dial(url string) (WebSocketConn, error)
}

type ListenHandler struct {
	Name        string
	Topic       string
	ChannelType RealtimeChannelType
	Table       string
	Schema      string
	EventFilter string
	ConsumeFn   func(ctx context.Context, event string, payload json.RawMessage) error
}

type PhoenixMessage struct {
	Topic   string          `json:"topic"`
	Event   string          `json:"event"`
	Payload json.RawMessage `json:"payload"`
	Ref     string          `json:"ref,omitempty"`
	JoinRef string          `json:"join_ref,omitempty"`
}

type Provider struct {
	Config *ProviderConfig
	Dialer Dialer
	// contains filtered or unexported fields
}

type ProviderConfig struct {
	SupabasePublicUrl string
	SupabaseApiUrl    string
	AnonKey           string
	ServiceKey        string
	ProjectId         string
}

type RealtimeChannelType string

type WebSocketConn interface {
	WriteJSON(v any) error
	ReadJSON(v any) error
	Close() error
}