node

package
v0.5.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 13, 2023 License: AGPL-3.0 Imports: 62 Imported by: 0

Documentation

Index

Constants

View Source 
const StatusDone = "done"
View Source 
const StatusFailed = "failed"
View Source 
const StatusInProgress = "in progress"

Variables

This section is empty.

Functions

func IsValidActivityType added in v0.4.0 

func IsValidActivityType(t string) bool

Types

type GeneratedImage added in v0.5.0 

type GeneratedImage struct {
	URL  string `json:"url"`
	NSFW bool   `json:"nsfw"`
	ID   string `json:"id"`
}

type GenerationResponse added in v0.5.0 

type GenerationResponse struct {
	GenerationsByPK struct {
		GeneratedImages []GeneratedImage `json:"generated_images"`
		Prompt          string           `json:"prompt"`
		Status          string           `json:"status"`
		ID              string           `json:"id"`
		CreatedAt       string           `json:"createdAt"`
	} `json:"generations_by_pk"`
}

type LeonardoResponse added in v0.5.0 

type LeonardoResponse struct {
	SdGenerationJob struct {
		GenerationId string `json:"generationId"`
	} `json:"sdGenerationJob"`
}

type NFTMeta 

type NFTMeta struct {
	Name  string `json:"name" binding:"required"`
	Image string `json:"image"`
}

type Node 

type Node struct {
	*object.Object
	// contains filtered or unexported fields
}

func NewNode 

func NewNode(
	id umid.UMID,
	db database.DB,
	worlds universe.Worlds,
	assets2D universe.Assets2d,
	assets3D universe.Assets3d,
	activities universe.Activities,
	plugins universe.Plugins,
	objectTypes universe.ObjectTypes,
	userTypes universe.UserTypes,
	attributeTypes universe.AttributeTypes,
) *Node

func (*Node) AddAPIRegister 

func (n *Node) AddAPIRegister(register universe.APIRegister)

func (*Node) AddObjectToAllObjects added in v0.4.0 

func (n *Node) AddObjectToAllObjects(object universe.Object) error

func (*Node) AddStakeActivities added in v0.5.0 

func (n *Node) AddStakeActivities(stakeEvents []*harvester.StakeEvent) error

func (*Node) AddStakeActivity added in v0.5.0 

func (n *Node) AddStakeActivity(stakeEvent *harvester.StakeEvent) error

func (*Node) CreateObject added in v0.4.0 

func (n *Node) CreateObject(objectID umid.UMID) (universe.Object, error)

func (*Node) CreateUsers added in v0.4.0 

func (n *Node) CreateUsers(ctx context.Context, users ...*entry.User) error

Create new users on this node.

func (*Node) Filter added in v0.4.0 

func (n *Node) Filter(predicateFn func(userID umid.UMID, user universe.User) bool) (
	map[umid.UMID]universe.User, error,
)

func (*Node) FilterAllObjects added in v0.4.0 

func (n *Node) FilterAllObjects(predicateFn universe.ObjectsFilterPredicateFn) map[umid.UMID]universe.Object

func (*Node) GetActivities added in v0.4.0 

func (n *Node) GetActivities() universe.Activities

func (*Node) GetAllObjects added in v0.4.0 

func (n *Node) GetAllObjects() map[umid.UMID]universe.Object

func (*Node) GetAssets2d 

func (n *Node) GetAssets2d() universe.Assets2d

func (*Node) GetAssets3d 

func (n *Node) GetAssets3d() universe.Assets3d

func (*Node) GetAttributeTypes 

func (n *Node) GetAttributeTypes() universe.AttributeTypes

func (*Node) GetConfig added in v0.4.0 

func (n *Node) GetConfig() *config.Config

func (*Node) GetLogger added in v0.4.0 

func (n *Node) GetLogger() *zap.SugaredLogger

func (*Node) GetNodeAttributes 

func (n *Node) GetNodeAttributes() universe.NodeAttributes

func (*Node) GetObjectFromAllObjects added in v0.4.0 

func (n *Node) GetObjectFromAllObjects(objectID umid.UMID) (universe.Object, bool)

func (*Node) GetObjectTypes added in v0.4.0 

func (n *Node) GetObjectTypes() universe.ObjectTypes

func (*Node) GetObjectUserAttributes added in v0.4.0 

func (n *Node) GetObjectUserAttributes() universe.ObjectUserAttributes

func (*Node) GetPlugins 

func (n *Node) GetPlugins() universe.Plugins

func (*Node) GetUserAttributes 

func (n *Node) GetUserAttributes() universe.UserAttributes

func (*Node) GetUserObjects added in v0.4.0 

func (n *Node) GetUserObjects() universe.UserObjects

func (*Node) GetUserTypes 

func (n *Node) GetUserTypes() universe.UserTypes

func (*Node) GetUserUserAttributes 

func (n *Node) GetUserUserAttributes() universe.UserUserAttributes

func (*Node) GetWorlds 

func (n *Node) GetWorlds() universe.Worlds

func (*Node) GetWorldsByOwnerID added in v0.4.0 

func (n *Node) GetWorldsByOwnerID(userID umid.UMID) map[umid.UMID]universe.World

func (*Node) Initialize 

func (n *Node) Initialize(ctx types.NodeContext) error

func (*Node) Listener added in v0.4.0 

func (n *Node) Listener(bcName string, events []*harvester.UpdateEvent, stakeEvents []*harvester.StakeEvent, nftEvent []*harvester.NftEvent) error

func (*Node) Load 

func (n *Node) Load() error

TODO: investigate how to load with limited database connection pool

func (*Node) LoadUser 

func (n *Node) LoadUser(userID umid.UMID) (universe.User, error)

func (*Node) RegisterAPI 

func (n *Node) RegisterAPI(r *gin.Engine)

func (*Node) RemoveObjectFromAllObjects added in v0.4.0 

func (n *Node) RemoveObjectFromAllObjects(object universe.Object) (bool, error)

func (*Node) Run 

func (n *Node) Run() error

func (*Node) Save 

func (n *Node) Save() error

func (*Node) SetParent 

func (n *Node) SetParent(parent universe.Object, updateDB bool) error

func (*Node) Stop 

func (n *Node) Stop() error

func (*Node) ToObject added in v0.4.0 

func (n *Node) ToObject() universe.Object

func (*Node) WriteInfluxPoint 

func (n *Node) WriteInfluxPoint(point *influxWrite.Point) error

type NodeJSOut 

type NodeJSOut struct {
	Data  any      `json:"data"`
	Logs  []string `json:"logs"`
	Error *string  `json:"error"`
}

type NodeJSOutData 

type NodeJSOutData struct {
	UserID umid.UMID `json:"userID"`
	Name   string    `json:"name"`
	Image  string    `json:"image"`
}

type SkyboxStatus added in v0.5.0 

type SkyboxStatus struct {
	Id            int         `json:"id"`
	Message       *string     `json:"message"`
	Status        string      `json:"status"`
	FileUrl       string      `json:"file_url"`
	ThumbUrl      string      `json:"thumb_url"`
	CreatedAt     time.Time   `json:"created_at"`
	UpdatedAt     time.Time   `json:"updated_at"`
	ErrorMessage  interface{} `json:"error_message"`
	SkyboxStyleId int         `json:"skybox_style_id"`
}

func (*SkyboxStatus) ToMap added in v0.5.0 

func (s *SkyboxStatus) ToMap() map[string]any

type StoreItem 

type StoreItem struct {
	Status    string
	NodeJSOut *NodeJSOut
	Error     error
}

type StyleItem added in v0.4.0 

type StyleItem struct {
	Id                  int    `json:"id"`
	Name                string `json:"name"`
	MaxChar             int    `json:"max-char"`
	NegativeTextMaxChar int    `json:"negative-text-max-char"`
	Image               any    `json:"image"`
	SortOrder           int    `json:"sort_order"`
	Premium             int    `json:"premium"`
	SkyboxStyleFamilies []any  `json:"skybox_style_families"`
}

type StylesCache added in v0.4.0 

type StylesCache struct {
	// contains filtered or unexported fields
}

type UpdateProfileStoreItem added in v0.2.0 

type UpdateProfileStoreItem struct {
	Status      string
	NodeJSOut   *NodeJSOut
	UserID      umid.UMID
	UserProfile *entry.UserProfile
	Error       error
}

type WalletMeta 

type WalletMeta struct {
	Wallet   string
	UserID   umid.UMID
	Username string
	Avatar   string
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.