api.go

package api

import (
	"context"
	"time"

	"github.com/spaceuptech/space-api-go/eventing"
	"github.com/spaceuptech/space-api-go/realtime"
	"github.com/spaceuptech/space-api-go/transport"
	"github.com/spaceuptech/space-api-go/transport/websocket"

	"github.com/spaceuptech/space-api-go/config"
	"github.com/spaceuptech/space-api-go/db"
	"github.com/spaceuptech/space-api-go/filestore"
	"github.com/spaceuptech/space-api-go/types"
)

// API is the main API object to communicate with space cloud
type API struct {
	config   *config.Config
	socket   *websocket.Socket
	realtime *realtime.Realtime
}

// New initialised a new instance of the API object
func New(project, url string, sslEnabled bool) *API {
	c := &config.Config{Project: project, Transport: transport.New(url, sslEnabled)}
	w := websocket.Init(url, c)
	r := realtime.Init(project, w)
	return &API{config: c, socket: w, realtime: r}
}

// Ping check if connection is established with space cloud
func (api *API) Ping() error {
	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
	defer cancel()
	return api.config.Transport.Ping(ctx, api.config.Token)
}

// SetToken sets the JWT token to be used in each request
func (api *API) SetToken(token string) {
	api.config.Token = token
}

// SetProjectID sets the project id to be used by the API
func (api *API) SetProjectID(project string) {
	api.config.Project = project
}

// DB creates a db client instance
func (api *API) DB(dbAlias string) *db.DB {
	return db.New(dbAlias, api.config, api.realtime)
}

// Call invokes the specified function on the backend
func (api *API) Call(service, endpoint string, params interface{}, timeout int) (*types.Response, error) {
	ctx, cancel := context.WithTimeout(context.Background(), time.Duration(timeout)*time.Second)
	defer cancel()

	return api.config.Transport.Call(ctx, api.config.Token, api.config.Project, service, endpoint, params, timeout)
}

// FileStore creates a FileStore instance
func (api *API) Filestore() *filestore.Filestore {
	return filestore.New(api.config)
}

// QueueEvent creates a Eventing instance
func (api *API) QueueEvent(eventType string, payload map[string]interface{}) *eventing.Eventing {
	if payload == nil {
		payload = map[string]interface{}{}
	}
	return eventing.New(eventType, payload, api.config)
}