node

package
v0.5.6 Latest Latest
Warning

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

Go to latest
Published: Oct 30, 2023 License: AGPL-3.0 Imports: 66 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetSignature added in v0.5.6

func GetSignature(privateKey string, nodeID string, odysseyID string) ([]byte, error)

func IsValidActivityType added in v0.4.0

func IsValidActivityType(t string) bool

Types

type AIProvidersFlags added in v0.5.6

type AIProvidersFlags struct {
	Leonardo     bool `json:"leonardo"`
	Blockadelabs bool `json:"blockadelabs"`
	Chatgpt      bool `json:"chatgpt"`
}

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 Info added in v0.5.4

type Info struct {
	ID                  umid.UMID           `json:"id"`
	Name                string              `json:"name"`
	ObjectTypeID        umid.UMID           `json:"object_type_id"`
	ObjectTypeName      string              `json:"object_type_name"`
	TotalDirectChildren int                 `json:"total_direct_children"`
	CreatedAt           time.Time           `json:"created_at"`
	Children            map[umid.UMID]*Info `json:"children"`

	MaxDepth *int `json:"max_depth,omitempty"`
}

type LeonardoResponse added in v0.5.0

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

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,
	media *media.Media,
	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 []*contracter.StakeEvent) error

func (*Node) AddStakeActivity added in v0.5.0

func (n *Node) AddStakeActivity(stakeEvent *contracter.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) GetMedia added in v0.5.6

func (n *Node) GetMedia() *media.Media

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) IsLocalWorld added in v0.5.6

func (n *Node) IsLocalWorld(world universe.Object) bool

func (*Node) Listener added in v0.4.0

func (n *Node) Listener(bcName string,
	events []*contracter.UpdateEvent,
	stakeEvents []*contracter.StakeEvent,
	nftEvent []*contracter.NftEvent,
	transferEvents []*contracter.TransferOdysseyEvent) 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 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 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 WalletMeta

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL