Help us shape the future of Go! Take the 2026 Go Developer Survey

spacewave_chat

package
v0.57.13 Latest Latest
Warning

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

 Go to latest Published: Sep 27, 2026 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source 
const ChatChannelTypeID = "spacewave-chat/channel"

ChatChannelTypeID is the type identifier for chat channel objects.

View Source 
const ChatMessagePageTypeID = "spacewave-chat/message-page"

ChatMessagePageTypeID is the type identifier for channel message pages.

View Source 
const ChatMessageTypeID = "spacewave-chat/message"

ChatMessageTypeID is the type identifier for chat message objects.

View Source 
const ChatThreadTypeID = "spacewave-chat/thread"

ChatThreadTypeID is the type identifier for thread summary objects.

View Source 
const GeneralChannelKey = "chat/channel/general"

GeneralChannelKey is the default channel object key.

Variables

View Source 
var CreateChatChannelOpId = "spacewave-chat/channel/create"

CreateChatChannelOpId is the operation id for CreateChatChannelOp.

View Source 
var ErrChatAuthorIdentityRequired = errors.New("chat author identity required")

ErrChatAuthorIdentityRequired is returned when a message has no authenticated author.

View Source 
var ErrChatStateConflict = errors.New("chat state write condition conflicts with current state")

ErrChatStateConflict indicates that current state no longer matches a write condition.

View Source 
var ErrChatThreadIndexBuilding = errors.New("chat thread index is still building")

ErrChatThreadIndexBuilding asks a caller to retry after bounded legacy backfill.

View Source 
var InitChatDemoOpId = "chat/init-chat-demo"

InitChatDemoOpId is the operation type ID.

View Source 
var PredChannelMessage = quad.IRI("spacewave-chat/channel-message")

PredChannelMessage is the graph predicate linking a channel to its messages.

View Source 
var PredChannelState = quad.IRI("spacewave-chat/channel-state")

PredChannelState links a channel to the latest event for each state identity.

View Source 
var PredMessageSender = quad.IRI("spacewave-chat/message-sender")

PredMessageSender is the graph predicate linking a message to its sender.

View Source 
var PredThreadParticipant = quad.IRI("spacewave-chat/thread-participant")

PredThreadParticipant marks a thread summary with an attributed person label.

Functions

func LookupCreateChatChannelOp 

func LookupCreateChatChannelOp(ctx context.Context, operationTypeID string) (world.Operation, error)

LookupCreateChatChannelOp looks up a CreateChatChannelOp operation type.

func LookupInitChatDemoOp 

func LookupInitChatDemoOp(ctx context.Context, opTypeID string) (world.Operation, error)

LookupInitChatDemoOp looks up the init chat demo operation.

func NewChatChannelBlock added in v0.52.0 

func NewChatChannelBlock() block.Block

NewChatChannelBlock constructs a new ChatChannel block.

func NewChatMessageBlock added in v0.52.0 

func NewChatMessageBlock() block.Block

NewChatMessageBlock constructs a new ChatMessage block.

func NewChatMessagePageBlock added in v0.52.0 

func NewChatMessagePageBlock() block.Block

NewChatMessagePageBlock constructs a new ChatMessagePage block.

func NewChatStateQuad 

func NewChatStateQuad(channelKey, messageKey, stateType, stateKey string) world.GraphQuad

NewChatStateQuad links a channel state identity to its retained message. Empty messageKey selects the current event for this identity in a graph query.

func NewChatThreadBlock 

func NewChatThreadBlock() block.Block

NewChatThreadBlock constructs a new ChatThread block.

func NewChatThreadParticipantQuad 

func NewChatThreadParticipantQuad(threadKey, personPeerID string) world.GraphQuad

NewChatThreadParticipantQuad records a verified person who authored a canonical thread reply.

func NewCreateChatChannelOpBlock 

func NewCreateChatChannelOpBlock() block.Block

NewCreateChatChannelOpBlock constructs a new CreateChatChannelOp block.

func NewInitChatDemoOpBlock 

func NewInitChatDemoOpBlock() block.Block

NewInitChatDemoOpBlock creates an empty block for deserialization.

func TransactionMessageKey 

func TransactionMessageKey(channelKey, senderPeerID, transactionID string) (string, error)

TransactionMessageKey identifies a retryable send within its channel World. It neither creates a message nor grants access. Callers supply the authenticated sender.

Types

type ChatAnnotation 

type ChatAnnotation = spacewave_chat_content.ChatAnnotation

ChatAnnotation is an attributed public reaction to a channel message.

type ChatChannel 

type ChatChannel struct {

	// Name is the channel display name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Topic is an optional channel topic description.
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// CreatedAt is the creation timestamp.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"createdAt,omitempty"`
	// MessageCount is the number of messages appended to the channel.
	MessageCount uint64 `protobuf:"varint,4,opt,name=message_count,json=messageCount,proto3" json:"messageCount,omitempty"`
	// ReadPositions maps verified person peer identities to their shared read positions.
	// Keys are external cryptographic identities, not World object references.
	ReadPositions map[string]*state.ChatReadPosition `` /* 187-byte string literal not displayed */
	// CreatorPeerId is the peer identity that created the channel.
	CreatorPeerId string `protobuf:"bytes,6,opt,name=creator_peer_id,json=creatorPeerId,proto3" json:"creatorPeerId,omitempty"`
	// EncryptionAlgorithm is the channel encryption policy. Empty allows plaintext;
	// once enabled it cannot change. Annotations and state changes remain public.
	EncryptionAlgorithm string `protobuf:"bytes,7,opt,name=encryption_algorithm,json=encryptionAlgorithm,proto3" json:"encryptionAlgorithm,omitempty"`
	// ThreadHeadKey starts the activity-ordered thread-summary list.
	ThreadHeadKey string `protobuf:"bytes,8,opt,name=thread_head_key,json=threadHeadKey,proto3" json:"threadHeadKey,omitempty"`
	// ThreadIndexedMessageCount is the history prefix represented by the thread index.
	// Presence distinguishes an initialized empty index from legacy channel state.
	ThreadIndexedMessageCount *uint64 `` /* 144-byte string literal not displayed */
	// contains filtered or unexported fields
}

ChatChannel is a chat channel world object. All channels are visible to Space participants (no visibility field).

func (*ChatChannel) CloneMessageVT 

func (m *ChatChannel) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*ChatChannel) CloneVT 

func (m *ChatChannel) CloneVT() *ChatChannel

func (*ChatChannel) EqualMessageVT 

func (this *ChatChannel) EqualMessageVT(thatMsg any) bool

func (*ChatChannel) EqualVT 

func (this *ChatChannel) EqualVT(that *ChatChannel) bool

func (*ChatChannel) GetCreatedAt 

func (x *ChatChannel) GetCreatedAt() *timestamppb.Timestamp

func (*ChatChannel) GetCreatorPeerId added in v0.57.4 

func (x *ChatChannel) GetCreatorPeerId() string

func (*ChatChannel) GetEncryptionAlgorithm added in v0.57.4 

func (x *ChatChannel) GetEncryptionAlgorithm() string

func (*ChatChannel) GetMessageCount added in v0.52.0 

func (x *ChatChannel) GetMessageCount() uint64

func (*ChatChannel) GetName 

func (x *ChatChannel) GetName() string

func (*ChatChannel) GetReadPositions added in v0.57.4 

func (x *ChatChannel) GetReadPositions() map[string]*state.ChatReadPosition

func (*ChatChannel) GetThreadHeadKey 

func (x *ChatChannel) GetThreadHeadKey() string

func (*ChatChannel) GetThreadIndexedMessageCount 

func (x *ChatChannel) GetThreadIndexedMessageCount() uint64

func (*ChatChannel) GetTopic 

func (x *ChatChannel) GetTopic() string

func (*ChatChannel) MarshalBlock 

func (c *ChatChannel) MarshalBlock() ([]byte, error)

MarshalBlock marshals the ChatChannel to bytes.

func (*ChatChannel) MarshalJSON 

func (x *ChatChannel) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ChatChannel to JSON.

func (*ChatChannel) MarshalProtoJSON 

func (x *ChatChannel) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ChatChannel message to JSON.

func (*ChatChannel) MarshalProtoText 

func (x *ChatChannel) MarshalProtoText() string

func (*ChatChannel) MarshalToSizedBufferVT 

func (m *ChatChannel) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ChatChannel) MarshalToVT 

func (m *ChatChannel) MarshalToVT(dAtA []byte) (int, error)

func (*ChatChannel) MarshalVT 

func (m *ChatChannel) MarshalVT() (dAtA []byte, err error)

func (*ChatChannel) ProtoMessage 

func (*ChatChannel) ProtoMessage()

func (*ChatChannel) Reset 

func (x *ChatChannel) Reset()

func (*ChatChannel) SizeVT 

func (m *ChatChannel) SizeVT() (n int)

func (*ChatChannel) String 

func (x *ChatChannel) String() string

func (*ChatChannel) UnmarshalBlock 

func (c *ChatChannel) UnmarshalBlock(data []byte) error

UnmarshalBlock unmarshals the ChatChannel from bytes.

func (*ChatChannel) UnmarshalJSON 

func (x *ChatChannel) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ChatChannel from JSON.

func (*ChatChannel) UnmarshalProtoJSON 

func (x *ChatChannel) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ChatChannel message from JSON.

func (*ChatChannel) UnmarshalVT 

func (m *ChatChannel) UnmarshalVT(dAtA []byte) error

func (*ChatChannel) Validate 

func (c *ChatChannel) Validate() error

Validate performs cursory checks on the ChatChannel.

type ChatChannel_ReadPositionsEntry added in v0.57.4 

type ChatChannel_ReadPositionsEntry struct {
	Key   string                  `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value *state.ChatReadPosition `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*ChatChannel_ReadPositionsEntry) GetKey added in v0.57.4 

func (x *ChatChannel_ReadPositionsEntry) GetKey() string

func (*ChatChannel_ReadPositionsEntry) GetValue added in v0.57.4 

func (x *ChatChannel_ReadPositionsEntry) GetValue() *state.ChatReadPosition

func (*ChatChannel_ReadPositionsEntry) MarshalJSON added in v0.57.4 

func (x *ChatChannel_ReadPositionsEntry) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ChatChannel_ReadPositionsEntry to JSON.

func (*ChatChannel_ReadPositionsEntry) MarshalProtoJSON added in v0.57.4 

func (x *ChatChannel_ReadPositionsEntry) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ChatChannel_ReadPositionsEntry message to JSON.

func (*ChatChannel_ReadPositionsEntry) MarshalProtoText added in v0.57.4 

func (x *ChatChannel_ReadPositionsEntry) MarshalProtoText() string

func (*ChatChannel_ReadPositionsEntry) ProtoMessage added in v0.57.4 

func (*ChatChannel_ReadPositionsEntry) ProtoMessage()

func (*ChatChannel_ReadPositionsEntry) Reset added in v0.57.4 

func (x *ChatChannel_ReadPositionsEntry) Reset()

func (*ChatChannel_ReadPositionsEntry) String added in v0.57.4 

func (x *ChatChannel_ReadPositionsEntry) String() string

func (*ChatChannel_ReadPositionsEntry) UnmarshalJSON added in v0.57.4 

func (x *ChatChannel_ReadPositionsEntry) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ChatChannel_ReadPositionsEntry from JSON.

func (*ChatChannel_ReadPositionsEntry) UnmarshalProtoJSON added in v0.57.4 

func (x *ChatChannel_ReadPositionsEntry) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ChatChannel_ReadPositionsEntry message from JSON.

type ChatCiphertext added in v0.57.4 

type ChatCiphertext = spacewave_chat_content.ChatCiphertext

ChatCiphertext is the shared encrypted envelope used by storage and RPC.

type ChatEvent 

type ChatEvent = spacewave_chat_content.ChatEvent

ChatEvent retains an external protocol message body.

type ChatMessage 

type ChatMessage struct {

	// SenderPeerId is the peer ID of the message sender.
	SenderPeerId string `protobuf:"bytes,1,opt,name=sender_peer_id,json=senderPeerId,proto3" json:"senderPeerId,omitempty"`
	// Content is the message content.
	Content *content.ChatMessageContent `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	// CreatedAt is the message creation timestamp.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"createdAt,omitempty"`
	// ReplyToKey is the object key of the message being replied to.
	ReplyToKey string `protobuf:"bytes,4,opt,name=reply_to_key,json=replyToKey,proto3" json:"replyToKey,omitempty"`
	// Index is the zero-based message index within the channel.
	Index uint64 `protobuf:"varint,5,opt,name=index,proto3" json:"index,omitempty"`
	// PersonPeerId is the verified person identity supplied by the authenticated host.
	// Empty historical values identify the person by SenderPeerId.
	PersonPeerId string `protobuf:"bytes,6,opt,name=person_peer_id,json=personPeerId,proto3" json:"personPeerId,omitempty"`
	// contains filtered or unexported fields
}

ChatMessage is a chat message world object linked to a channel.

func (*ChatMessage) CloneMessageVT 

func (m *ChatMessage) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*ChatMessage) CloneVT 

func (m *ChatMessage) CloneVT() *ChatMessage

func (*ChatMessage) EqualMessageVT 

func (this *ChatMessage) EqualMessageVT(thatMsg any) bool

func (*ChatMessage) EqualVT 

func (this *ChatMessage) EqualVT(that *ChatMessage) bool

func (*ChatMessage) GetContent 

func (x *ChatMessage) GetContent() *content.ChatMessageContent

func (*ChatMessage) GetCreatedAt 

func (x *ChatMessage) GetCreatedAt() *timestamppb.Timestamp

func (*ChatMessage) GetIndex added in v0.52.0 

func (x *ChatMessage) GetIndex() uint64

func (*ChatMessage) GetPersonPeerId added in v0.57.4 

func (x *ChatMessage) GetPersonPeerId() string

func (*ChatMessage) GetReplyToKey 

func (x *ChatMessage) GetReplyToKey() string

func (*ChatMessage) GetSenderPeerId 

func (x *ChatMessage) GetSenderPeerId() string

func (*ChatMessage) MarshalBlock 

func (m *ChatMessage) MarshalBlock() ([]byte, error)

MarshalBlock marshals the ChatMessage to bytes.

func (*ChatMessage) MarshalJSON 

func (x *ChatMessage) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ChatMessage to JSON.

func (*ChatMessage) MarshalProtoJSON 

func (x *ChatMessage) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ChatMessage message to JSON.

func (*ChatMessage) MarshalProtoText 

func (x *ChatMessage) MarshalProtoText() string

func (*ChatMessage) MarshalToSizedBufferVT 

func (m *ChatMessage) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ChatMessage) MarshalToVT 

func (m *ChatMessage) MarshalToVT(dAtA []byte) (int, error)

func (*ChatMessage) MarshalVT 

func (m *ChatMessage) MarshalVT() (dAtA []byte, err error)

func (*ChatMessage) ProtoMessage 

func (*ChatMessage) ProtoMessage()

func (*ChatMessage) Reset 

func (x *ChatMessage) Reset()

func (*ChatMessage) SizeVT 

func (m *ChatMessage) SizeVT() (n int)

func (*ChatMessage) String 

func (x *ChatMessage) String() string

func (*ChatMessage) UnmarshalBlock 

func (m *ChatMessage) UnmarshalBlock(data []byte) error

UnmarshalBlock unmarshals the ChatMessage from bytes.

func (*ChatMessage) UnmarshalJSON 

func (x *ChatMessage) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ChatMessage from JSON.

func (*ChatMessage) UnmarshalProtoJSON 

func (x *ChatMessage) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ChatMessage message from JSON.

func (*ChatMessage) UnmarshalVT 

func (m *ChatMessage) UnmarshalVT(dAtA []byte) error

func (*ChatMessage) Validate 

func (m *ChatMessage) Validate() error

Validate performs cursory checks on the ChatMessage.

type ChatMessageContent 

type ChatMessageContent = spacewave_chat_content.ChatMessageContent

ChatMessageContent is the shared generated content type used by storage and RPC.

type ChatMessageContent_Annotation 

type ChatMessageContent_Annotation = spacewave_chat_content.ChatMessageContent_Annotation

ChatMessageContent_Annotation carries a public reaction independently of message encryption.

type ChatMessageContent_Ciphertext added in v0.57.4 

type ChatMessageContent_Ciphertext = spacewave_chat_content.ChatMessageContent_Ciphertext

ChatMessageContent_Ciphertext carries an endpoint-encrypted message envelope.

type ChatMessageContent_Event 

type ChatMessageContent_Event = spacewave_chat_content.ChatMessageContent_Event

ChatMessageContent_Event carries a protocol message in channel history.

type ChatMessageContent_StateChange 

type ChatMessageContent_StateChange = spacewave_chat_content.ChatMessageContent_StateChange

ChatMessageContent_StateChange carries a retained channel state event.

type ChatMessageContent_Text 

type ChatMessageContent_Text = spacewave_chat_content.ChatMessageContent_Text

ChatMessageContent_Text retains the public text-content constructor.

type ChatMessagePage added in v0.52.0 

type ChatMessagePage struct {

	// MessageKeys are page-local message object keys in creation order.
	MessageKeys []string `protobuf:"bytes,1,rep,name=message_keys,json=messageKeys,proto3" json:"messageKeys,omitempty"`
	// contains filtered or unexported fields
}

ChatMessagePage stores a bounded page of channel message keys.

func (*ChatMessagePage) CloneMessageVT added in v0.52.0 

func (m *ChatMessagePage) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*ChatMessagePage) CloneVT added in v0.52.0 

func (m *ChatMessagePage) CloneVT() *ChatMessagePage

func (*ChatMessagePage) EqualMessageVT added in v0.52.0 

func (this *ChatMessagePage) EqualMessageVT(thatMsg any) bool

func (*ChatMessagePage) EqualVT added in v0.52.0 

func (this *ChatMessagePage) EqualVT(that *ChatMessagePage) bool

func (*ChatMessagePage) GetMessageKeys added in v0.52.0 

func (x *ChatMessagePage) GetMessageKeys() []string

func (*ChatMessagePage) MarshalBlock added in v0.52.0 

func (m *ChatMessagePage) MarshalBlock() ([]byte, error)

MarshalBlock marshals the ChatMessagePage to bytes.

func (*ChatMessagePage) MarshalJSON added in v0.52.0 

func (x *ChatMessagePage) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ChatMessagePage to JSON.

func (*ChatMessagePage) MarshalProtoJSON added in v0.52.0 

func (x *ChatMessagePage) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ChatMessagePage message to JSON.

func (*ChatMessagePage) MarshalProtoText added in v0.52.0 

func (x *ChatMessagePage) MarshalProtoText() string

func (*ChatMessagePage) MarshalToSizedBufferVT added in v0.52.0 

func (m *ChatMessagePage) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ChatMessagePage) MarshalToVT added in v0.52.0 

func (m *ChatMessagePage) MarshalToVT(dAtA []byte) (int, error)

func (*ChatMessagePage) MarshalVT added in v0.52.0 

func (m *ChatMessagePage) MarshalVT() (dAtA []byte, err error)

func (*ChatMessagePage) ProtoMessage added in v0.52.0 

func (*ChatMessagePage) ProtoMessage()

func (*ChatMessagePage) Reset added in v0.52.0 

func (x *ChatMessagePage) Reset()

func (*ChatMessagePage) SizeVT added in v0.52.0 

func (m *ChatMessagePage) SizeVT() (n int)

func (*ChatMessagePage) String added in v0.52.0 

func (x *ChatMessagePage) String() string

func (*ChatMessagePage) UnmarshalBlock added in v0.52.0 

func (m *ChatMessagePage) UnmarshalBlock(data []byte) error

UnmarshalBlock unmarshals the ChatMessagePage from bytes.

func (*ChatMessagePage) UnmarshalJSON added in v0.52.0 

func (x *ChatMessagePage) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ChatMessagePage from JSON.

func (*ChatMessagePage) UnmarshalProtoJSON added in v0.52.0 

func (x *ChatMessagePage) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ChatMessagePage message from JSON.

func (*ChatMessagePage) UnmarshalVT added in v0.52.0 

func (m *ChatMessagePage) UnmarshalVT(dAtA []byte) error

func (*ChatMessagePage) Validate added in v0.52.0 

func (m *ChatMessagePage) Validate() error

Validate performs cursory checks on the ChatMessagePage.

type ChatRelation 

type ChatRelation = spacewave_chat_content.ChatRelation

ChatRelation is shared relationship metadata stored beside supported message bodies.

type ChatResource added in v0.52.0 

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

ChatResource serves ChatResourceService for a single chat channel object.

func NewChatResource added in v0.52.0 

func NewChatResource(
	ws world.WorldState,
	engine world.Engine,
	objectKey string,
	localPeerID string,
) *ChatResource

NewChatResource constructs a ChatResource.

func NewChatResourceForPerson added in v0.57.4 

func NewChatResourceForPerson(
	ws world.WorldState,
	engine world.Engine,
	objectKey string,
	localPeerID string,
	personPeerID string,
) *ChatResource

NewChatResourceForPerson binds a verified person and signing device to a channel. The embedding Session host verifies this association; RPC requests cannot select it. World access remains constrained by the supplied authorized state and engine.

func (*ChatResource) Close added in v0.52.0 

func (r *ChatResource) Close()

Close releases the chat resource lifecycle.

func (*ChatResource) GetChannelInfo added in v0.52.0 

func (r *ChatResource) GetChannelInfo(
	ctx context.Context,
	_ *spacewave_chat_rpc.GetChannelInfoRequest,
) (*spacewave_chat_rpc.GetChannelInfoResponse, error)

GetChannelInfo reads the channel block and returns metadata.

func (*ChatResource) GetMessage added in v0.57.4 

func (r *ChatResource) GetMessage(
	ctx context.Context,
	req *spacewave_chat_rpc.GetMessageRequest,
) (*spacewave_chat_rpc.GetMessageResponse, error)

GetMessage reads one channel message by its channel-scoped object key.

func (*ChatResource) GetMux added in v0.52.0 

func (r *ChatResource) GetMux() srpc.Mux

GetMux returns the SRPC mux for this resource.

func (*ChatResource) GetReadPositions added in v0.57.4 

func (r *ChatResource) GetReadPositions(ctx context.Context, _ *spacewave_chat_rpc.GetReadPositionsRequest) (*spacewave_chat_rpc.GetReadPositionsResponse, error)

GetReadPositions reads shared receipt state without transferring mutable channel state.

func (*ChatResource) GetState 

func (r *ChatResource) GetState(ctx context.Context, _ *spacewave_chat_rpc.GetStateRequest) (*spacewave_chat_rpc.GetStateResponse, error)

GetState returns the latest retained event for each channel state identity.

func (*ChatResource) ListMessages added in v0.52.0 

func (r *ChatResource) ListMessages(
	ctx context.Context,
	req *spacewave_chat_rpc.ListMessagesRequest,
) (*spacewave_chat_rpc.ListMessagesResponse, error)

ListMessages returns a page of channel messages.

func (*ChatResource) ListThreads 

func (r *ChatResource) ListThreads(
	ctx context.Context,
	req *spacewave_chat_rpc.ListThreadsRequest,
) (*spacewave_chat_rpc.ListThreadsResponse, error)

ListThreads returns native thread summaries in descending activity order.

func (*ChatResource) SendMessage added in v0.52.0 

func (r *ChatResource) SendMessage(
	ctx context.Context,
	req *spacewave_chat_rpc.SendMessageRequest,
) (*spacewave_chat_rpc.SendMessageResponse, error)

SendMessage durably appends a message or resolves an identical sender-scoped retry.

func (*ChatResource) UpdateReadPosition added in v0.57.4 

func (r *ChatResource) UpdateReadPosition(ctx context.Context, req *spacewave_chat_rpc.UpdateReadPositionRequest) (*spacewave_chat_rpc.UpdateReadPositionResponse, error)

UpdateReadPosition advances the authenticated person's position durably across devices. Repeated or older positions return the current value without a World mutation.

func (*ChatResource) WatchMessages added in v0.52.0 

func (r *ChatResource) WatchMessages(
	_ *spacewave_chat_rpc.WatchMessagesRequest,
	strm spacewave_chat_rpc.SRPCChatResourceService_WatchMessagesStream,
) error

WatchMessages streams new message batches after each world change.

type ChatStateChange 

type ChatStateChange = spacewave_chat_content.ChatStateChange

ChatStateChange is a public channel state event.

type ChatThread 

type ChatThread struct {

	// RootMessageKey is the immutable root identity summarized by this snapshot.
	RootMessageKey string `protobuf:"bytes,1,opt,name=root_message_key,json=rootMessageKey,proto3" json:"rootMessageKey,omitempty"`
	// LatestMessageKey is the newest canonical reply captured by this snapshot.
	LatestMessageKey string `protobuf:"bytes,2,opt,name=latest_message_key,json=latestMessageKey,proto3" json:"latestMessageKey,omitempty"`
	// LatestMessageIndex orders threads by their newest canonical reply.
	LatestMessageIndex uint64 `protobuf:"varint,3,opt,name=latest_message_index,json=latestMessageIndex,proto3" json:"latestMessageIndex,omitempty"`
	// ReplyCount is the number of canonical thread replies.
	ReplyCount uint64 `protobuf:"varint,4,opt,name=reply_count,json=replyCount,proto3" json:"replyCount,omitempty"`
	// NewerThreadKey establishes the preceding entry in activity order.
	NewerThreadKey string `protobuf:"bytes,5,opt,name=newer_thread_key,json=newerThreadKey,proto3" json:"newerThreadKey,omitempty"`
	// OlderThreadKey establishes the following entry in activity order.
	OlderThreadKey string `protobuf:"bytes,6,opt,name=older_thread_key,json=olderThreadKey,proto3" json:"olderThreadKey,omitempty"`
	// contains filtered or unexported fields
}

ChatThread stores one bounded summary in the channel's activity-ordered thread index.

func (*ChatThread) CloneMessageVT 

func (m *ChatThread) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*ChatThread) CloneVT 

func (m *ChatThread) CloneVT() *ChatThread

func (*ChatThread) EqualMessageVT 

func (this *ChatThread) EqualMessageVT(thatMsg any) bool

func (*ChatThread) EqualVT 

func (this *ChatThread) EqualVT(that *ChatThread) bool

func (*ChatThread) GetLatestMessageIndex 

func (x *ChatThread) GetLatestMessageIndex() uint64

func (*ChatThread) GetLatestMessageKey 

func (x *ChatThread) GetLatestMessageKey() string

func (*ChatThread) GetNewerThreadKey 

func (x *ChatThread) GetNewerThreadKey() string

func (*ChatThread) GetOlderThreadKey 

func (x *ChatThread) GetOlderThreadKey() string

func (*ChatThread) GetReplyCount 

func (x *ChatThread) GetReplyCount() uint64

func (*ChatThread) GetRootMessageKey 

func (x *ChatThread) GetRootMessageKey() string

func (*ChatThread) MarshalBlock 

func (t *ChatThread) MarshalBlock() ([]byte, error)

MarshalBlock marshals the ChatThread to bytes.

func (*ChatThread) MarshalJSON 

func (x *ChatThread) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ChatThread to JSON.

func (*ChatThread) MarshalProtoJSON 

func (x *ChatThread) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ChatThread message to JSON.

func (*ChatThread) MarshalProtoText 

func (x *ChatThread) MarshalProtoText() string

func (*ChatThread) MarshalToSizedBufferVT 

func (m *ChatThread) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ChatThread) MarshalToVT 

func (m *ChatThread) MarshalToVT(dAtA []byte) (int, error)

func (*ChatThread) MarshalVT 

func (m *ChatThread) MarshalVT() (dAtA []byte, err error)

func (*ChatThread) ProtoMessage 

func (*ChatThread) ProtoMessage()

func (*ChatThread) Reset 

func (x *ChatThread) Reset()

func (*ChatThread) SizeVT 

func (m *ChatThread) SizeVT() (n int)

func (*ChatThread) String 

func (x *ChatThread) String() string

func (*ChatThread) UnmarshalBlock 

func (t *ChatThread) UnmarshalBlock(data []byte) error

UnmarshalBlock unmarshals the ChatThread from bytes.

func (*ChatThread) UnmarshalJSON 

func (x *ChatThread) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ChatThread from JSON.

func (*ChatThread) UnmarshalProtoJSON 

func (x *ChatThread) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ChatThread message from JSON.

func (*ChatThread) UnmarshalVT 

func (m *ChatThread) UnmarshalVT(dAtA []byte) error

func (*ChatThread) Validate 

func (t *ChatThread) Validate() error

Validate performs cursory checks on the ChatThread.

type CreateChatChannelOp 

type CreateChatChannelOp struct {

	// ObjectKey is the key to create the channel at.
	ObjectKey string `protobuf:"bytes,1,opt,name=object_key,json=objectKey,proto3" json:"objectKey,omitempty"`
	// Name is the channel name.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Topic is the optional channel topic.
	Topic string `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	// Timestamp is the creation timestamp.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// EncryptionAlgorithm initializes the channel encryption policy. Empty allows plaintext;
	// once enabled it cannot change. Annotations and state changes remain public.
	EncryptionAlgorithm string `protobuf:"bytes,5,opt,name=encryption_algorithm,json=encryptionAlgorithm,proto3" json:"encryptionAlgorithm,omitempty"`
	// InitialState is appended atomically in order with the channel creation timestamp.
	InitialState []*content.ChatStateChange `protobuf:"bytes,6,rep,name=initial_state,json=initialState,proto3" json:"initialState,omitempty"`
	// contains filtered or unexported fields
}

CreateChatChannelOp creates a new chat channel.

func (*CreateChatChannelOp) ApplyWorldObjectOp 

func (o *CreateChatChannelOp) ApplyWorldObjectOp(
	ctx context.Context,
	le *logrus.Entry,
	os world.ObjectState,
	sender peer.ID,
) (sysErr bool, err error)

ApplyWorldObjectOp applies the operation to a world object.

func (*CreateChatChannelOp) ApplyWorldOp 

func (o *CreateChatChannelOp) ApplyWorldOp(
	ctx context.Context,
	le *logrus.Entry,
	ws world.WorldState,
	sender peer.ID,
) (sysErr bool, err error)

ApplyWorldOp applies the operation as a world operation.

func (*CreateChatChannelOp) CloneMessageVT 

func (m *CreateChatChannelOp) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*CreateChatChannelOp) CloneVT 

func (m *CreateChatChannelOp) CloneVT() *CreateChatChannelOp

func (*CreateChatChannelOp) EqualMessageVT 

func (this *CreateChatChannelOp) EqualMessageVT(thatMsg any) bool

func (*CreateChatChannelOp) EqualVT 

func (this *CreateChatChannelOp) EqualVT(that *CreateChatChannelOp) bool

func (*CreateChatChannelOp) GetEncryptionAlgorithm added in v0.57.4 

func (x *CreateChatChannelOp) GetEncryptionAlgorithm() string

func (*CreateChatChannelOp) GetInitialState 

func (x *CreateChatChannelOp) GetInitialState() []*content.ChatStateChange

func (*CreateChatChannelOp) GetName 

func (x *CreateChatChannelOp) GetName() string

func (*CreateChatChannelOp) GetObjectKey 

func (x *CreateChatChannelOp) GetObjectKey() string

func (*CreateChatChannelOp) GetOperationTypeId 

func (o *CreateChatChannelOp) GetOperationTypeId() string

GetOperationTypeId returns the operation type identifier.

func (*CreateChatChannelOp) GetTimestamp 

func (x *CreateChatChannelOp) GetTimestamp() *timestamppb.Timestamp

func (*CreateChatChannelOp) GetTopic 

func (x *CreateChatChannelOp) GetTopic() string

func (*CreateChatChannelOp) MarshalBlock 

func (o *CreateChatChannelOp) MarshalBlock() ([]byte, error)

MarshalBlock marshals the block to binary.

func (*CreateChatChannelOp) MarshalJSON 

func (x *CreateChatChannelOp) MarshalJSON() ([]byte, error)

MarshalJSON marshals the CreateChatChannelOp to JSON.

func (*CreateChatChannelOp) MarshalProtoJSON 

func (x *CreateChatChannelOp) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the CreateChatChannelOp message to JSON.

func (*CreateChatChannelOp) MarshalProtoText 

func (x *CreateChatChannelOp) MarshalProtoText() string

func (*CreateChatChannelOp) MarshalToSizedBufferVT 

func (m *CreateChatChannelOp) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CreateChatChannelOp) MarshalToVT 

func (m *CreateChatChannelOp) MarshalToVT(dAtA []byte) (int, error)

func (*CreateChatChannelOp) MarshalVT 

func (m *CreateChatChannelOp) MarshalVT() (dAtA []byte, err error)

func (*CreateChatChannelOp) ProtoMessage 

func (*CreateChatChannelOp) ProtoMessage()

func (*CreateChatChannelOp) Reset 

func (x *CreateChatChannelOp) Reset()

func (*CreateChatChannelOp) SizeVT 

func (m *CreateChatChannelOp) SizeVT() (n int)

func (*CreateChatChannelOp) String 

func (x *CreateChatChannelOp) String() string

func (*CreateChatChannelOp) UnmarshalBlock 

func (o *CreateChatChannelOp) UnmarshalBlock(data []byte) error

UnmarshalBlock unmarshals the block to the object.

func (*CreateChatChannelOp) UnmarshalJSON 

func (x *CreateChatChannelOp) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the CreateChatChannelOp from JSON.

func (*CreateChatChannelOp) UnmarshalProtoJSON 

func (x *CreateChatChannelOp) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the CreateChatChannelOp message from JSON.

func (*CreateChatChannelOp) UnmarshalVT 

func (m *CreateChatChannelOp) UnmarshalVT(dAtA []byte) error

func (*CreateChatChannelOp) Validate 

func (o *CreateChatChannelOp) Validate() error

Validate performs cursory checks on the op.

type InitChatDemoOp 

type InitChatDemoOp struct {

	// ChannelObjectKey is the key for the channel object.
	ChannelObjectKey string `protobuf:"bytes,1,opt,name=channel_object_key,json=channelObjectKey,proto3" json:"channelObjectKey,omitempty"`
	// Timestamp is the creation timestamp.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

InitChatDemoOp creates a "General" channel on space quickstart.

func (*InitChatDemoOp) ApplyWorldObjectOp 

func (o *InitChatDemoOp) ApplyWorldObjectOp(
	ctx context.Context,
	le *logrus.Entry,
	os world.ObjectState,
	sender peer.ID,
) (bool, error)

ApplyWorldObjectOp is not supported for this operation.

func (*InitChatDemoOp) ApplyWorldOp 

func (o *InitChatDemoOp) ApplyWorldOp(
	ctx context.Context,
	le *logrus.Entry,
	ws world.WorldState,
	sender peer.ID,
) (bool, error)

ApplyWorldOp applies the init chat demo operation.

func (*InitChatDemoOp) CloneMessageVT 

func (m *InitChatDemoOp) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*InitChatDemoOp) CloneVT 

func (m *InitChatDemoOp) CloneVT() *InitChatDemoOp

func (*InitChatDemoOp) EqualMessageVT 

func (this *InitChatDemoOp) EqualMessageVT(thatMsg any) bool

func (*InitChatDemoOp) EqualVT 

func (this *InitChatDemoOp) EqualVT(that *InitChatDemoOp) bool

func (*InitChatDemoOp) GetChannelObjectKey 

func (x *InitChatDemoOp) GetChannelObjectKey() string

func (*InitChatDemoOp) GetOperationTypeId 

func (o *InitChatDemoOp) GetOperationTypeId() string

GetOperationTypeId returns the operation type ID.

func (*InitChatDemoOp) GetTimestamp 

func (x *InitChatDemoOp) GetTimestamp() *timestamppb.Timestamp

func (*InitChatDemoOp) MarshalBlock 

func (o *InitChatDemoOp) MarshalBlock() ([]byte, error)

MarshalBlock marshals the operation to bytes.

func (*InitChatDemoOp) MarshalJSON 

func (x *InitChatDemoOp) MarshalJSON() ([]byte, error)

MarshalJSON marshals the InitChatDemoOp to JSON.

func (*InitChatDemoOp) MarshalProtoJSON 

func (x *InitChatDemoOp) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the InitChatDemoOp message to JSON.

func (*InitChatDemoOp) MarshalProtoText 

func (x *InitChatDemoOp) MarshalProtoText() string

func (*InitChatDemoOp) MarshalToSizedBufferVT 

func (m *InitChatDemoOp) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*InitChatDemoOp) MarshalToVT 

func (m *InitChatDemoOp) MarshalToVT(dAtA []byte) (int, error)

func (*InitChatDemoOp) MarshalVT 

func (m *InitChatDemoOp) MarshalVT() (dAtA []byte, err error)

func (*InitChatDemoOp) ProtoMessage 

func (*InitChatDemoOp) ProtoMessage()

func (*InitChatDemoOp) Reset 

func (x *InitChatDemoOp) Reset()

func (*InitChatDemoOp) SizeVT 

func (m *InitChatDemoOp) SizeVT() (n int)

func (*InitChatDemoOp) String 

func (x *InitChatDemoOp) String() string

func (*InitChatDemoOp) UnmarshalBlock 

func (o *InitChatDemoOp) UnmarshalBlock(data []byte) error

UnmarshalBlock unmarshals the operation from bytes.

func (*InitChatDemoOp) UnmarshalJSON 

func (x *InitChatDemoOp) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the InitChatDemoOp from JSON.

func (*InitChatDemoOp) UnmarshalProtoJSON 

func (x *InitChatDemoOp) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the InitChatDemoOp message from JSON.

func (*InitChatDemoOp) UnmarshalVT 

func (m *InitChatDemoOp) UnmarshalVT(dAtA []byte) error

func (*InitChatDemoOp) Validate 

func (o *InitChatDemoOp) Validate() error

Validate validates the operation.

Source Files

View all Source files

Directories

Path Synopsis

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.