resource_session

package
v0.51.3 Latest Latest
Warning

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

 Go to latest Published: May 9, 2026 License: Apache-2.0 Imports: 56 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BuildSyncStatusSnapshot added in v0.51.2 

func BuildSyncStatusSnapshot(
	sess session.Session,
	now time.Time,
) (*s4wave_session.WatchSyncStatusResponse, []<-chan struct{})

BuildSyncStatusSnapshot returns the session sync snapshot and change channels.

Types

type LocalSessionResource 

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

LocalSessionResource implements LocalSessionResourceService.

func NewLocalSessionResource 

func NewLocalSessionResource(b bus.Bus, sess session.Session) *LocalSessionResource

NewLocalSessionResource creates a new LocalSessionResource.

func (*LocalSessionResource) AddEntityKeypair 

func (r *LocalSessionResource) AddEntityKeypair(
	ctx context.Context,
	req *s4wave_session.AddLocalEntityKeypairRequest,
) (*s4wave_session.AddLocalEntityKeypairResponse, error)

AddEntityKeypair derives an entity key from an EntityCredential and adds it to the AccountSettings SharedObject.

func (*LocalSessionResource) ExportBackupKey 

func (r *LocalSessionResource) ExportBackupKey(
	ctx context.Context,
	req *s4wave_session.ExportBackupKeyRequest,
) (*s4wave_session.ExportBackupKeyResponse, error)

ExportBackupKey generates a backup Ed25519 keypair, adds both the password-derived entity keypair and the backup keypair to the AccountSettings SharedObject, and returns the backup private key as PEM. The envelope watcher will automatically rewrap with the new keypairs.

func (*LocalSessionResource) RemoveEntityKeypair 

func (r *LocalSessionResource) RemoveEntityKeypair(
	ctx context.Context,
	req *s4wave_session.RemoveLocalEntityKeypairRequest,
) (*s4wave_session.RemoveLocalEntityKeypairResponse, error)

RemoveEntityKeypair removes an entity keypair from the AccountSettings SharedObject.

func (*LocalSessionResource) SetDisplayName 

func (r *LocalSessionResource) SetDisplayName(
	ctx context.Context,
	req *s4wave_session.SetLocalDisplayNameRequest,
) (*s4wave_session.SetLocalDisplayNameResponse, error)

SetDisplayName updates the local provider account display name.

func (*LocalSessionResource) WatchDisplayName 

func (r *LocalSessionResource) WatchDisplayName(
	req *s4wave_session.WatchLocalDisplayNameRequest,
	strm s4wave_session.SRPCLocalSessionResourceService_WatchDisplayNameStream,
) error

WatchDisplayName streams the local provider account display name.

func (*LocalSessionResource) WatchEntityKeypairs 

func (r *LocalSessionResource) WatchEntityKeypairs(
	req *s4wave_session.WatchLocalEntityKeypairsRequest,
	strm s4wave_session.SRPCLocalSessionResourceService_WatchEntityKeypairsStream,
) error

WatchEntityKeypairs streams entity keypairs from the AccountSettings SO.

type SessionResource 

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

SessionResource wraps a core session for resource access.

The lifecycle context ctx scopes any background work owned by this resource. It is canceled by Close when the mount is released.

func NewSessionResource 

func NewSessionResource(le *logrus.Entry, b bus.Bus, sess session.Session) *SessionResource

NewSessionResource creates a new SessionResource.

func NewSessionResourceWithHostPluginID added in v0.51.3 

func NewSessionResourceWithHostPluginID(
	le *logrus.Entry,
	b bus.Bus,
	sess session.Session,
	hostPluginID string,
) *SessionResource

NewSessionResourceWithHostPluginID creates a new SessionResource with the plugin id that owns the resource root.

func (*SessionResource) AcceptLocalPairingAnswer 

func (r *SessionResource) AcceptLocalPairingAnswer(ctx context.Context, req *s4wave_session.AcceptLocalPairingAnswerRequest) (*s4wave_session.AcceptLocalPairingAnswerResponse, error)

AcceptLocalPairingAnswer accepts a remote SDP answer to complete the connection.

func (*SessionResource) AcceptLocalPairingOffer 

func (r *SessionResource) AcceptLocalPairingOffer(ctx context.Context, req *s4wave_session.AcceptLocalPairingOfferRequest) (*s4wave_session.AcceptLocalPairingOfferResponse, error)

AcceptLocalPairingOffer accepts a remote SDP offer and returns an answer.

func (*SessionResource) AccessStateAtom 

func (r *SessionResource) AccessStateAtom(
	ctx context.Context,
	req *s4wave_session.AccessSessionStateAtomRequest,
) (*s4wave_session.AccessSessionStateAtomResponse, error)

AccessStateAtom accesses a session-scoped state atom resource.

func (*SessionResource) CancelTransfer 

func (r *SessionResource) CancelTransfer(
	ctx context.Context,
	req *s4wave_session.CancelTransferRequest,
) (*s4wave_session.CancelTransferResponse, error)

CancelTransfer stops an in-progress transfer.

func (*SessionResource) Close 

func (r *SessionResource) Close()

Close releases resources owned by this SessionResource. Callers that wrap a SessionResource via resource_server.AddResource should invoke Close from the release callback so the lifecycle context is canceled and any provider-level subscriptions are released.

func (*SessionResource) CompletePairing 

func (r *SessionResource) CompletePairing(ctx context.Context, req *s4wave_session.CompletePairingRequest) (*s4wave_session.CompletePairingResponse, error)

CompletePairing resolves a pairing code to link a remote session.

func (*SessionResource) ConfirmPairing 

func (r *SessionResource) ConfirmPairing(ctx context.Context, req *s4wave_session.ConfirmPairingRequest) (*s4wave_session.ConfirmPairingResponse, error)

ConfirmPairing confirms a verified pairing, adds the remote peer as OWNER on all SharedObjects, persists the device, and starts P2P sync.

func (*SessionResource) ConfirmSASMatch 

func (r *SessionResource) ConfirmSASMatch(ctx context.Context, req *s4wave_session.ConfirmSASMatchRequest) (*s4wave_session.ConfirmSASMatchResponse, error)

ConfirmSASMatch sends the user's SAS emoji verification decision to the bilateral confirmation exchange running over the bifrost link.

func (*SessionResource) CreateLocalPairingOffer 

func (r *SessionResource) CreateLocalPairingOffer(ctx context.Context, _ *s4wave_session.CreateLocalPairingOfferRequest) (*s4wave_session.CreateLocalPairingOfferResponse, error)

CreateLocalPairingOffer generates a WebRTC SDP offer for no-cloud pairing.

func (*SessionResource) CreateSpace 

func (r *SessionResource) CreateSpace(ctx context.Context, req *s4wave_session.CreateSpaceRequest) (*s4wave_session.CreateSpaceResponse, error)

CreateSpace creates a new space within the ProviderAccount with the Session.

func (*SessionResource) CreateSpaceInvite 

func (r *SessionResource) CreateSpaceInvite(
	ctx context.Context,
	req *s4wave_session.CreateSpaceInviteRequest,
) (*s4wave_session.CreateSpaceInviteResponse, error)

CreateSpaceInvite creates an invite for a space shared object.

func (*SessionResource) DeleteAccount 

func (r *SessionResource) DeleteAccount(ctx context.Context, req *s4wave_session.DeleteAccountRequest) (*s4wave_session.DeleteAccountResponse, error)

DeleteAccount deletes the entire account associated with this session. Cleans all session keys, removes GC edges, runs volume GC, deletes the volume backing store, and removes all sessions from the list.

func (*SessionResource) DeleteSpace 

func (r *SessionResource) DeleteSpace(ctx context.Context, req *s4wave_session.DeleteSpaceRequest) (*s4wave_session.DeleteSpaceResponse, error)

DeleteSpace deletes a space within the ProviderAccount.

func (*SessionResource) GeneratePairingCode 

func (r *SessionResource) GeneratePairingCode(ctx context.Context, _ *s4wave_session.GeneratePairingCodeRequest) (*s4wave_session.GeneratePairingCodeResponse, error)

GeneratePairingCode creates an 8-char pairing code for P2P device linking.

func (*SessionResource) GetActiveTransfer 

func (r *SessionResource) GetActiveTransfer() *provider_transfer.Transfer

GetActiveTransfer returns the currently active transfer, or nil if none.

func (*SessionResource) GetMux 

func (r *SessionResource) GetMux() srpc.Invoker

GetMux returns the rpc mux.

func (*SessionResource) GetSASEmoji 

func (r *SessionResource) GetSASEmoji(ctx context.Context, req *s4wave_session.GetSASEmojiRequest) (*s4wave_session.GetSASEmojiResponse, error)

GetSASEmoji derives SAS emoji for verifying a P2P link with a remote peer.

func (*SessionResource) GetSessionInfo 

func (r *SessionResource) GetSessionInfo(ctx context.Context, req *s4wave_session.GetSessionInfoRequest) (*s4wave_session.GetSessionInfoResponse, error)

GetSessionInfo returns information about this session.

func (*SessionResource) GetTransferInventory 

func (r *SessionResource) GetTransferInventory(
	ctx context.Context,
	req *s4wave_session.GetTransferInventoryRequest,
) (*s4wave_session.GetTransferInventoryResponse, error)

GetTransferInventory returns the list of spaces on a session for transfer planning.

func (*SessionResource) GetTransferStatus 

func (r *SessionResource) GetTransferStatus(
	ctx context.Context,
	req *s4wave_session.GetTransferStatusRequest,
) (*s4wave_session.GetTransferStatusResponse, error)

GetTransferStatus returns whether a transfer is active or a checkpoint exists.

func (*SessionResource) JoinSpaceViaInvite 

func (r *SessionResource) JoinSpaceViaInvite(
	ctx context.Context,
	req *s4wave_session.JoinSpaceViaInviteRequest,
) (*s4wave_session.JoinSpaceViaInviteResponse, error)

JoinSpaceViaInvite joins a space using an out-of-band invite message.

func (*SessionResource) ListSpaceInvites 

func (r *SessionResource) ListSpaceInvites(
	ctx context.Context,
	req *s4wave_session.ListSpaceInvitesRequest,
) (*s4wave_session.ListSpaceInvitesResponse, error)

ListSpaceInvites lists invites on a space shared object.

func (*SessionResource) ListSpaceParticipants 

func (r *SessionResource) ListSpaceParticipants(
	ctx context.Context,
	req *s4wave_session.ListSpaceParticipantsRequest,
) (*s4wave_session.ListSpaceParticipantsResponse, error)

ListSpaceParticipants lists participants on a space shared object.

func (*SessionResource) LockSession 

func (r *SessionResource) LockSession(ctx context.Context, req *s4wave_session.LockSessionRequest) (*s4wave_session.LockSessionResponse, error)

LockSession locks a running session.

func (*SessionResource) MountSharedObject 

func (r *SessionResource) MountSharedObject(
	ctx context.Context,
	req *s4wave_session.MountSharedObjectRequest,
) (*s4wave_session.MountSharedObjectResponse, error)

MountSharedObject mounts a shared object within the session by ID.

func (*SessionResource) RemoveSpaceParticipant 

func (r *SessionResource) RemoveSpaceParticipant(
	ctx context.Context,
	req *s4wave_session.RemoveSpaceParticipantRequest,
) (*s4wave_session.RemoveSpaceParticipantResponse, error)

RemoveSpaceParticipant removes a participant from a space shared object by peer ID.

func (*SessionResource) RenameSpace 

func (r *SessionResource) RenameSpace(ctx context.Context, req *s4wave_session.RenameSpaceRequest) (*s4wave_session.RenameSpaceResponse, error)

RenameSpace updates the display name metadata for a space.

func (*SessionResource) RevokeSpaceInvite 

func (r *SessionResource) RevokeSpaceInvite(
	ctx context.Context,
	req *s4wave_session.RevokeSpaceInviteRequest,
) (*s4wave_session.RevokeSpaceInviteResponse, error)

RevokeSpaceInvite revokes an invite on a space shared object.

func (*SessionResource) SetCdnLookup 

func (r *SessionResource) SetCdnLookup(
	lookup func(sharedObjectID string) (sobject.SharedObject, *sobject.SharedObjectMeta),
)

SetCdnLookup wires a lookup from shared object id to the process-scoped CDN-backed SharedObject and its synthesized metadata. Consulted by MountSharedObject before falling back to the per-session SO list so CDN Spaces (which are filtered out of that list) remain mountable by ULID.

The lookup must return (nil, nil) for ids that are not CDN Spaces. Safe to call once per SessionResource; subsequent calls replace the previous lookup.

func (*SessionResource) SetCdnRootChangedHook 

func (r *SessionResource) SetCdnRootChangedHook(hook func(spaceID string))

SetCdnRootChangedHook wires a callback that fires when the session's provider account delivers a cdn-root-changed WS frame. Wired by the enclosing mount path to the root CdnInstance.Refresh() so pushes on the upstream CDN root wake up the process-scoped singleton.

No-op when the session's provider is not spacewave (local-only never receives cdn-root-changed). Safe to call once per SessionResource; a second call releases the second subscription to preserve single ownership.

func (*SessionResource) SetLockMode 

func (r *SessionResource) SetLockMode(ctx context.Context, req *s4wave_session.SetLockModeRequest) (*s4wave_session.SetLockModeResponse, error)

SetLockMode changes the session lock mode.

func (*SessionResource) StartTransfer 

func (r *SessionResource) StartTransfer(
	ctx context.Context,
	req *s4wave_session.StartTransferRequest,
) (*s4wave_session.StartTransferResponse, error)

StartTransfer starts a transfer operation between two sessions.

func (*SessionResource) UnlinkDevice 

func (r *SessionResource) UnlinkDevice(ctx context.Context, req *s4wave_session.UnlinkDeviceRequest) (*s4wave_session.UnlinkDeviceResponse, error)

UnlinkDevice removes a paired device from the account settings SO and revokes its SO participant access.

func (*SessionResource) UnlockSession 

func (r *SessionResource) UnlockSession(ctx context.Context, req *s4wave_session.UnlockSessionRequest) (*s4wave_session.UnlockSessionResponse, error)

UnlockSession unlocks a PIN-locked session.

func (*SessionResource) WatchLockState 

func (r *SessionResource) WatchLockState(
	req *s4wave_session.WatchLockStateRequest,
	strm s4wave_session.SRPCSessionResourceService_WatchLockStateStream,
) error

WatchLockState streams the current lock state and updates on changes.

func (*SessionResource) WatchPairedDevices 

func (r *SessionResource) WatchPairedDevices(
	req *s4wave_session.WatchPairedDevicesRequest,
	strm s4wave_session.SRPCSessionResourceService_WatchPairedDevicesStream,
) error

WatchPairedDevices streams the list of paired devices from the account settings SharedObject.

func (*SessionResource) WatchPairingStatus 

func (r *SessionResource) WatchPairingStatus(
	req *s4wave_session.WatchPairingStatusRequest,
	strm s4wave_session.SRPCSessionResourceService_WatchPairingStatusStream,
) error

WatchPairingStatus streams pairing state changes during a device linking flow.

func (*SessionResource) WatchResourcesList 

func (r *SessionResource) WatchResourcesList(
	req *s4wave_session.WatchResourcesListRequest,
	strm s4wave_session.SRPCSessionResourceService_WatchResourcesListStream,
) error

WatchResourcesList returns the list of resources the session has access to.

func (*SessionResource) WatchSharedObjectHealth 

func (r *SessionResource) WatchSharedObjectHealth(
	req *s4wave_session.WatchSharedObjectHealthRequest,
	strm s4wave_session.SRPCSessionResourceService_WatchSharedObjectHealthStream,
) error

WatchSharedObjectHealth streams SharedObject health by SharedObject ID.

func (*SessionResource) WatchStateAtoms 

func (r *SessionResource) WatchStateAtoms(
	_ *s4wave_session.WatchSessionStateAtomsRequest,
	strm s4wave_session.SRPCSessionResourceService_WatchStateAtomsStream,
) error

WatchStateAtoms streams the known session state atom store ids on change.

func (*SessionResource) WatchSyncStatus 

func (r *SessionResource) WatchSyncStatus(
	req *s4wave_session.WatchSyncStatusRequest,
	strm s4wave_session.SRPCSessionResourceService_WatchSyncStatusStream,
) error

WatchSyncStatus streams the session sync and network activity snapshot.

func (*SessionResource) WatchTransferProgress 

func (r *SessionResource) WatchTransferProgress(
	req *s4wave_session.WatchTransferProgressRequest,
	strm s4wave_session.SRPCSessionResourceService_WatchTransferProgressStream,
) error

WatchTransferProgress streams transfer state updates for an active transfer.

type SharedObjectSelfEnrollmentResource 

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

SharedObjectSelfEnrollmentResource wraps post-sign-in self-enrollment state.

func NewSharedObjectSelfEnrollmentResource 

func NewSharedObjectSelfEnrollmentResource(
	swAcc *provider_spacewave.ProviderAccount,
) *SharedObjectSelfEnrollmentResource

NewSharedObjectSelfEnrollmentResource creates a new SharedObjectSelfEnrollmentResource.

func (*SharedObjectSelfEnrollmentResource) GetMux 

func (r *SharedObjectSelfEnrollmentResource) GetMux() srpc.Invoker

GetMux returns the rpc mux.

func (*SharedObjectSelfEnrollmentResource) Skip 

func (r *SharedObjectSelfEnrollmentResource) Skip(
	ctx context.Context,
	req *s4wave_session.SkipSharedObjectSelfEnrollmentRequest,
) (*s4wave_session.SkipSharedObjectSelfEnrollmentResponse, error)

Skip records the user's skip choice for the current generation.

func (*SharedObjectSelfEnrollmentResource) Start 

func (r *SharedObjectSelfEnrollmentResource) Start(
	ctx context.Context,
	req *s4wave_session.StartSharedObjectSelfEnrollmentRequest,
) (*s4wave_session.StartSharedObjectSelfEnrollmentResponse, error)

Start runs self-enrollment for the current pending set.

func (*SharedObjectSelfEnrollmentResource) WatchState 

func (r *SharedObjectSelfEnrollmentResource) WatchState(
	req *s4wave_session.WatchSharedObjectSelfEnrollmentStateRequest,
	strm s4wave_session.SRPCSharedObjectSelfEnrollmentResourceService_WatchStateStream,
) error

WatchState streams self-enrollment state changes.

type SpacewaveSessionResource 

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

SpacewaveSessionResource implements SpacewaveSessionResourceService. It wraps a session-scoped spacewave ProviderAccount, resolving it directly from the session without scanning.

func NewSpacewaveSessionResource 

func NewSpacewaveSessionResource(
	sr *SessionResource,
	le *logrus.Entry,
	b bus.Bus,
	sess session.Session,
	swAcc *provider_spacewave.ProviderAccount,
) *SpacewaveSessionResource

NewSpacewaveSessionResource creates a new SpacewaveSessionResource.

func (*SpacewaveSessionResource) AcceptOrganizationTargetedInvitation added in v0.51.2 

func (r *SpacewaveSessionResource) AcceptOrganizationTargetedInvitation(
	ctx context.Context,
	req *s4wave_provider_spacewave.AcceptOrganizationTargetedInvitationRequest,
) (*s4wave_provider_spacewave.AcceptOrganizationTargetedInvitationResponse, error)

AcceptOrganizationTargetedInvitation accepts a pending organization targeted invitation and mirrors the membership into local org state.

func (*SpacewaveSessionResource) AcceptSpaceTargetedInvitation added in v0.51.2 

func (r *SpacewaveSessionResource) AcceptSpaceTargetedInvitation(
	ctx context.Context,
	req *s4wave_provider_spacewave.AcceptSpaceTargetedInvitationRequest,
) (*s4wave_provider_spacewave.AcceptSpaceTargetedInvitationResponse, error)

AcceptSpaceTargetedInvitation accepts a pending Space targeted invitation through the existing mailbox-backed join path.

func (*SpacewaveSessionResource) AddEmail 

func (r *SpacewaveSessionResource) AddEmail(
	ctx context.Context,
	req *s4wave_provider_spacewave.AddEmailRequest,
) (*s4wave_provider_spacewave.AddEmailResponse, error)

AddEmail adds an email address and sends verification. 

func (r *SpacewaveSessionResource) ApproveSpaceLink(
	ctx context.Context,
	req *s4wave_provider_spacewave.ApproveSpaceLinkRequest,
) (*s4wave_provider_spacewave.ApproveSpaceLinkResponse, error)

ApproveSpaceLink approves a SpaceLink ticket for a target Space.

func (*SpacewaveSessionResource) AssignBillingAccount 

func (r *SpacewaveSessionResource) AssignBillingAccount(
	ctx context.Context,
	req *s4wave_provider_spacewave.AssignBillingAccountRequest,
) (*s4wave_provider_spacewave.AssignBillingAccountResponse, error)

AssignBillingAccount binds a billing account to a principal.

func (*SpacewaveSessionResource) CancelCheckoutSession 

func (r *SpacewaveSessionResource) CancelCheckoutSession(
	ctx context.Context,
	req *s4wave_provider_spacewave.CancelCheckoutSessionRequest,
) (*s4wave_provider_spacewave.CancelCheckoutSessionResponse, error)

CancelCheckoutSession cancels pending checkout attempts.

func (*SpacewaveSessionResource) CancelSubscription 

func (r *SpacewaveSessionResource) CancelSubscription(
	ctx context.Context,
	req *s4wave_provider_spacewave.CancelSubscriptionRequest,
) (*s4wave_provider_spacewave.CancelSubscriptionResponse, error)

CancelSubscription cancels the active subscription.

func (*SpacewaveSessionResource) ConfirmDeleteNowCode 

func (r *SpacewaveSessionResource) ConfirmDeleteNowCode(
	ctx context.Context,
	req *s4wave_provider_spacewave.ConfirmDeleteNowCodeRequest,
) (*s4wave_provider_spacewave.ConfirmDeleteNowCodeResponse, error)

ConfirmDeleteNowCode finalizes delete-now using the 6-digit code from email.

func (*SpacewaveSessionResource) CreateBillingAccount 

func (r *SpacewaveSessionResource) CreateBillingAccount(
	ctx context.Context,
	req *s4wave_provider_spacewave.CreateBillingAccountRequest,
) (*s4wave_provider_spacewave.CreateBillingAccountResponse, error)

CreateBillingAccount creates a new unassigned billing account managed by the caller.

func (*SpacewaveSessionResource) CreateBillingPortal 

func (r *SpacewaveSessionResource) CreateBillingPortal(
	ctx context.Context,
	req *s4wave_provider_spacewave.CreateBillingPortalRequest,
) (*s4wave_provider_spacewave.CreateBillingPortalResponse, error)

CreateBillingPortal creates a Stripe billing portal session URL.

func (*SpacewaveSessionResource) CreateCheckoutSession 

func (r *SpacewaveSessionResource) CreateCheckoutSession(
	ctx context.Context,
	req *s4wave_provider_spacewave.CreateCheckoutSessionRequest,
) (*s4wave_provider_spacewave.CreateCheckoutSessionResponse, error)

CreateCheckoutSession creates or resumes a Stripe Checkout Session.

func (*SpacewaveSessionResource) CreateLinkedLocalSession 

func (r *SpacewaveSessionResource) CreateLinkedLocalSession(
	ctx context.Context,
	req *s4wave_provider_spacewave.CreateLinkedLocalSessionRequest,
) (*s4wave_provider_spacewave.CreateLinkedLocalSessionResponse, error)

CreateLinkedLocalSession creates a local provider session with cloud identity metadata.

func (*SpacewaveSessionResource) CreateOrgInvite 

func (r *SpacewaveSessionResource) CreateOrgInvite(
	ctx context.Context,
	req *s4wave_provider_spacewave.CreateOrgInviteRequest,
) (*s4wave_provider_spacewave.CreateOrgInviteResponse, error)

CreateOrgInvite creates an invite for an organization.

func (*SpacewaveSessionResource) CreateOrganization 

func (r *SpacewaveSessionResource) CreateOrganization(
	ctx context.Context,
	req *s4wave_provider_spacewave.CreateOrganizationRequest,
) (*s4wave_provider_spacewave.CreateOrganizationResponse, error)

CreateOrganization creates a new organization.

func (*SpacewaveSessionResource) CreateOrganizationTargetedInvitationByUsername added in v0.51.2 

func (r *SpacewaveSessionResource) CreateOrganizationTargetedInvitationByUsername(
	ctx context.Context,
	req *s4wave_provider_spacewave.CreateOrganizationTargetedInvitationByUsernameRequest,
) (*s4wave_provider_spacewave.CreateOrganizationTargetedInvitationByUsernameResponse, error)

CreateOrganizationTargetedInvitationByUsername creates an organization targeted invitation by exact username and stores it in the recipient inbox.

func (*SpacewaveSessionResource) CreateSpaceTargetedInvitationByUsername added in v0.51.2 

func (r *SpacewaveSessionResource) CreateSpaceTargetedInvitationByUsername(
	ctx context.Context,
	req *s4wave_provider_spacewave.CreateSpaceTargetedInvitationByUsernameRequest,
) (*s4wave_provider_spacewave.CreateSpaceTargetedInvitationByUsernameResponse, error)

CreateSpaceTargetedInvitationByUsername creates a Space targeted invitation by exact username and stores it in the recipient inbox.

func (*SpacewaveSessionResource) CreateTargetedInvitation added in v0.51.2 

func (r *SpacewaveSessionResource) CreateTargetedInvitation(
	ctx context.Context,
	req *s4wave_provider_spacewave.CreateTargetedInvitationRequest,
) (*s4wave_provider_spacewave.CreateTargetedInvitationResponse, error)

CreateTargetedInvitation creates a signed pending targeted invitation.

func (*SpacewaveSessionResource) CreateTargetedInviteDraftByUsername added in v0.51.2 

func (r *SpacewaveSessionResource) CreateTargetedInviteDraftByUsername(
	ctx context.Context,
	req *s4wave_provider_spacewave.CreateTargetedInviteDraftByUsernameRequest,
) (*s4wave_provider_spacewave.CreateTargetedInviteDraftByUsernameResponse, error)

CreateTargetedInviteDraftByUsername creates an opaque targeted invite draft.

func (*SpacewaveSessionResource) DeleteBillingAccount 

func (r *SpacewaveSessionResource) DeleteBillingAccount(
	ctx context.Context,
	req *s4wave_provider_spacewave.DeleteBillingAccountRequest,
) (*s4wave_provider_spacewave.DeleteBillingAccountResponse, error)

DeleteBillingAccount permanently removes a managed billing account.

func (*SpacewaveSessionResource) DeleteOrganization 

func (r *SpacewaveSessionResource) DeleteOrganization(
	ctx context.Context,
	req *s4wave_provider_spacewave.DeleteOrganizationRequest,
) (*s4wave_provider_spacewave.DeleteOrganizationResponse, error)

DeleteOrganization deletes an organization.

func (*SpacewaveSessionResource) DetachBillingAccount 

func (r *SpacewaveSessionResource) DetachBillingAccount(
	ctx context.Context,
	req *s4wave_provider_spacewave.DetachBillingAccountRequest,
) (*s4wave_provider_spacewave.DetachBillingAccountResponse, error)

DetachBillingAccount clears a principal's billing account assignment.

func (*SpacewaveSessionResource) EncryptForHandoff 

func (r *SpacewaveSessionResource) EncryptForHandoff(
	ctx context.Context,
	req *s4wave_provider_spacewave.EncryptForHandoffRequest,
) (*s4wave_provider_spacewave.EncryptForHandoffResponse, error)

EncryptForHandoff encrypts the active session privkey to a device pubkey.

func (*SpacewaveSessionResource) EnrollSpaceMember 

func (r *SpacewaveSessionResource) EnrollSpaceMember(
	ctx context.Context,
	req *s4wave_provider_spacewave.EnrollSpaceMemberRequest,
) (*s4wave_provider_spacewave.EnrollSpaceMemberResponse, error)

EnrollSpaceMember enrolls an org member into a space by adding them as a participant.

func (*SpacewaveSessionResource) GetLinkedLocalSession 

func (r *SpacewaveSessionResource) GetLinkedLocalSession(
	ctx context.Context,
	req *s4wave_provider_spacewave.GetLinkedLocalSessionRequest,
) (*s4wave_provider_spacewave.GetLinkedLocalSessionResponse, error)

GetLinkedLocalSession returns the session index of the linked local session.

func (*SpacewaveSessionResource) GetTargetedInvitation added in v0.51.2 

func (r *SpacewaveSessionResource) GetTargetedInvitation(
	ctx context.Context,
	req *s4wave_provider_spacewave.GetTargetedInvitationRequest,
) (*s4wave_provider_spacewave.GetTargetedInvitationResponse, error)

GetTargetedInvitation reads one targeted invitation.

func (*SpacewaveSessionResource) JoinOrganization 

func (r *SpacewaveSessionResource) JoinOrganization(
	ctx context.Context,
	req *s4wave_provider_spacewave.JoinOrganizationRequest,
) (*s4wave_provider_spacewave.JoinOrganizationResponse, error)

JoinOrganization joins an organization via invite token.

func (*SpacewaveSessionResource) LeaveOrganization 

func (r *SpacewaveSessionResource) LeaveOrganization(
	ctx context.Context,
	req *s4wave_provider_spacewave.LeaveOrganizationRequest,
) (*s4wave_provider_spacewave.LeaveOrganizationResponse, error)

LeaveOrganization leaves an organization.

func (*SpacewaveSessionResource) ListManagedBillingAccounts 

func (r *SpacewaveSessionResource) ListManagedBillingAccounts(
	ctx context.Context,
	_ *s4wave_provider_spacewave.ListManagedBillingAccountsRequest,
) (*s4wave_provider_spacewave.ListManagedBillingAccountsResponse, error)

ListManagedBillingAccounts lists billing accounts the caller manages.

func (*SpacewaveSessionResource) ListTargetedInvitations added in v0.51.2 

func (r *SpacewaveSessionResource) ListTargetedInvitations(
	ctx context.Context,
	req *s4wave_provider_spacewave.ListTargetedInvitationsRequest,
) (*s4wave_provider_spacewave.ListTargetedInvitationsResponse, error)

ListTargetedInvitations lists the caller's targeted invitation inbox.

func (*SpacewaveSessionResource) LookupInviteCode 

func (r *SpacewaveSessionResource) LookupInviteCode(
	ctx context.Context,
	req *s4wave_provider_spacewave.LookupInviteCodeRequest,
) (*s4wave_provider_spacewave.LookupInviteCodeResponse, error)

LookupInviteCode resolves a short invite code to the full SOInviteMessage.

func (*SpacewaveSessionResource) MountSharedObjectSelfEnrollment 

func (r *SpacewaveSessionResource) MountSharedObjectSelfEnrollment(
	ctx context.Context,
	req *s4wave_session.MountSharedObjectSelfEnrollmentRequest,
) (*s4wave_session.MountSharedObjectSelfEnrollmentResponse, error)

MountSharedObjectSelfEnrollment mounts the self-enrollment resource. 

func (r *SpacewaveSessionResource) PreviewSpaceLink(
	ctx context.Context,
	req *s4wave_provider_spacewave.PreviewSpaceLinkRequest,
) (*s4wave_provider_spacewave.PreviewSpaceLinkResponse, error)

PreviewSpaceLink verifies a SpaceLink ticket for trusted UI display.

func (*SpacewaveSessionResource) ProcessMailboxEntry 

func (r *SpacewaveSessionResource) ProcessMailboxEntry(
	ctx context.Context,
	req *s4wave_provider_spacewave.ProcessMailboxEntryRequest,
) (*s4wave_provider_spacewave.ProcessMailboxEntryResponse, error)

ProcessMailboxEntry accepts or rejects a mailbox entry.

func (*SpacewaveSessionResource) ProcessTargetedInvitation added in v0.51.2 

func (r *SpacewaveSessionResource) ProcessTargetedInvitation(
	ctx context.Context,
	req *s4wave_provider_spacewave.ProcessTargetedInvitationRequest,
) (*s4wave_provider_spacewave.ProcessTargetedInvitationResponse, error)

ProcessTargetedInvitation applies a recipient lifecycle action.

func (*SpacewaveSessionResource) ReactivateSubscription 

func (r *SpacewaveSessionResource) ReactivateSubscription(
	ctx context.Context,
	req *s4wave_provider_spacewave.ReactivateSubscriptionRequest,
) (*s4wave_provider_spacewave.ReactivateSubscriptionResponse, error)

ReactivateSubscription reactivates a canceled subscription.

func (*SpacewaveSessionResource) RefreshBillingState 

func (r *SpacewaveSessionResource) RefreshBillingState(
	ctx context.Context,
	req *s4wave_provider_spacewave.RefreshBillingStateRequest,
) (*s4wave_provider_spacewave.RefreshBillingStateResponse, error)

RefreshBillingState invalidates the cached billing snapshot so watches reload.

func (*SpacewaveSessionResource) ReinitializeSharedObject 

func (r *SpacewaveSessionResource) ReinitializeSharedObject(
	ctx context.Context,
	req *s4wave_provider_spacewave.ReinitializeSharedObjectRequest,
) (*s4wave_provider_spacewave.ReinitializeSharedObjectResponse, error)

ReinitializeSharedObject destructively rewrites a broken shared object in place.

func (*SpacewaveSessionResource) RemoveEmail 

func (r *SpacewaveSessionResource) RemoveEmail(
	ctx context.Context,
	req *s4wave_provider_spacewave.RemoveEmailRequest,
) (*s4wave_provider_spacewave.RemoveEmailResponse, error)

RemoveEmail removes an email address from the account.

func (*SpacewaveSessionResource) RemoveOrgMember 

func (r *SpacewaveSessionResource) RemoveOrgMember(
	ctx context.Context,
	req *s4wave_provider_spacewave.RemoveOrgMemberRequest,
) (*s4wave_provider_spacewave.RemoveOrgMemberResponse, error)

RemoveOrgMember removes a member from an organization.

func (*SpacewaveSessionResource) RemoveSpaceMember 

func (r *SpacewaveSessionResource) RemoveSpaceMember(
	ctx context.Context,
	req *s4wave_provider_spacewave.RemoveSpaceMemberRequest,
) (*s4wave_provider_spacewave.RemoveSpaceMemberResponse, error)

RemoveSpaceMember removes an org member from a space by removing them as a participant.

func (*SpacewaveSessionResource) RenameBillingAccount 

func (r *SpacewaveSessionResource) RenameBillingAccount(
	ctx context.Context,
	req *s4wave_provider_spacewave.RenameBillingAccountRequest,
) (*s4wave_provider_spacewave.RenameBillingAccountResponse, error)

RenameBillingAccount updates the display name on a BA the caller manages.

func (*SpacewaveSessionResource) RepairSharedObject 

func (r *SpacewaveSessionResource) RepairSharedObject(
	ctx context.Context,
	req *s4wave_provider_spacewave.RepairSharedObjectRequest,
) (*s4wave_provider_spacewave.RepairSharedObjectResponse, error)

RepairSharedObject retries owner-side repair for a broken shared object.

func (*SpacewaveSessionResource) RequestDeleteNowEmail 

func (r *SpacewaveSessionResource) RequestDeleteNowEmail(
	ctx context.Context,
	_ *s4wave_provider_spacewave.RequestDeleteNowEmailRequest,
) (*s4wave_provider_spacewave.RequestDeleteNowEmailResponse, error)

RequestDeleteNowEmail sends a delete-now confirmation email with a code and link.

func (*SpacewaveSessionResource) ResetSession 

func (r *SpacewaveSessionResource) ResetSession(
	ctx context.Context,
	req *s4wave_provider_spacewave.ResetSessionRequest,
) (*s4wave_provider_spacewave.ResetSessionResponse, error)

ResetSession resets a PIN-locked session.

func (*SpacewaveSessionResource) ResolveUsername added in v0.51.2 

func (r *SpacewaveSessionResource) ResolveUsername(
	ctx context.Context,
	req *s4wave_provider_spacewave.ResolveUsernameRequest,
) (*s4wave_provider_spacewave.ResolveUsernameResponse, error)

ResolveUsername resolves an exact username for an allowed invite context.

func (*SpacewaveSessionResource) RevokeOrgInvite 

func (r *SpacewaveSessionResource) RevokeOrgInvite(
	ctx context.Context,
	req *s4wave_provider_spacewave.RevokeOrgInviteRequest,
) (*s4wave_provider_spacewave.RevokeOrgInviteResponse, error)

RevokeOrgInvite revokes an invite by ID.

func (*SpacewaveSessionResource) RevokeTargetedInvitation added in v0.51.2 

func (r *SpacewaveSessionResource) RevokeTargetedInvitation(
	ctx context.Context,
	req *s4wave_provider_spacewave.RevokeTargetedInvitationRequest,
) (*s4wave_provider_spacewave.RevokeTargetedInvitationResponse, error)

RevokeTargetedInvitation revokes one pending targeted invitation.

func (*SpacewaveSessionResource) SendVerificationEmail 

func (r *SpacewaveSessionResource) SendVerificationEmail(
	ctx context.Context,
	req *s4wave_provider_spacewave.SendVerificationEmailRequest,
) (*s4wave_provider_spacewave.SendVerificationEmailResponse, error)

SendVerificationEmail sends a verification email to the given address.

func (*SpacewaveSessionResource) SetPrimaryEmail 

func (r *SpacewaveSessionResource) SetPrimaryEmail(
	ctx context.Context,
	req *s4wave_provider_spacewave.SetPrimaryEmailRequest,
) (*s4wave_provider_spacewave.SetPrimaryEmailResponse, error)

SetPrimaryEmail promotes a verified email to primary.

func (*SpacewaveSessionResource) StartDesktopPasskeyReauth 

func (r *SpacewaveSessionResource) StartDesktopPasskeyReauth(
	ctx context.Context,
	req *s4wave_provider_spacewave.StartDesktopPasskeyReauthRequest,
) (*s4wave_provider_spacewave.StartDesktopPasskeyReauthResponse, error)

StartDesktopPasskeyReauth runs the native-owned desktop passkey reauth flow for one specific entity keypair. The handler calls the authenticated cloud start endpoint, opens the system browser to the account-hosted ceremony, waits for the browser-authenticated result on the auth-session WebSocket, and returns the unwrap artifacts for the existing unlock path. 

func (r *SpacewaveSessionResource) StartDesktopSSOLink(
	ctx context.Context,
	req *s4wave_provider_spacewave.StartDesktopSSOLinkRequest,
) (*s4wave_provider_spacewave.StartDesktopSSOLinkResponse, error)

StartDesktopSSOLink runs the native-owned desktop SessionDetails SSO-link flow. The handler calls the authenticated cloud start endpoint for the waiting auth-session relay material, opens the system browser to the provider authorize URL, waits for the OAuth result on the auth-session WebSocket, and returns the { provider, code } pair so the UI can complete account linking through the existing Account.LinkSSO mutation.

func (*SpacewaveSessionResource) SwitchBillingInterval 

func (r *SpacewaveSessionResource) SwitchBillingInterval(
	ctx context.Context,
	req *s4wave_provider_spacewave.SwitchBillingIntervalRequest,
) (*s4wave_provider_spacewave.SwitchBillingIntervalResponse, error)

SwitchBillingInterval switches between monthly and annual billing.

func (*SpacewaveSessionResource) TransferResource 

func (r *SpacewaveSessionResource) TransferResource(
	ctx context.Context,
	req *s4wave_provider_spacewave.TransferResourceRequest,
) (*s4wave_provider_spacewave.TransferResourceResponse, error)

TransferResource transfers a resource to a typed principal owner.

func (*SpacewaveSessionResource) UndoDeleteNow 

func (r *SpacewaveSessionResource) UndoDeleteNow(
	ctx context.Context,
	_ *s4wave_provider_spacewave.UndoDeleteNowRequest,
) (*s4wave_provider_spacewave.UndoDeleteNowResponse, error)

UndoDeleteNow cancels a pending delete-now countdown.

func (*SpacewaveSessionResource) UnlinkLocalSession 

func (r *SpacewaveSessionResource) UnlinkLocalSession(
	ctx context.Context,
	req *s4wave_provider_spacewave.UnlinkLocalSessionRequest,
) (*s4wave_provider_spacewave.UnlinkLocalSessionResponse, error)

UnlinkLocalSession removes the linked-local session cross-reference.

func (*SpacewaveSessionResource) UpdateOrganization 

func (r *SpacewaveSessionResource) UpdateOrganization(
	ctx context.Context,
	req *s4wave_provider_spacewave.UpdateOrganizationRequest,
) (*s4wave_provider_spacewave.UpdateOrganizationResponse, error)

UpdateOrganization updates an organization's display name.

func (*SpacewaveSessionResource) VerifyEmailCode 

func (r *SpacewaveSessionResource) VerifyEmailCode(
	ctx context.Context,
	req *s4wave_provider_spacewave.VerifyEmailCodeRequest,
) (*s4wave_provider_spacewave.VerifyEmailCodeResponse, error)

VerifyEmailCode verifies a 6-digit code for in-app email verification.

func (*SpacewaveSessionResource) WatchBillingState 

func (r *SpacewaveSessionResource) WatchBillingState(
	req *s4wave_provider_spacewave.WatchBillingStateRequest,
	strm s4wave_session.SRPCSpacewaveSessionResourceService_WatchBillingStateStream,
) error

WatchBillingState streams combined billing account state and usage.

func (*SpacewaveSessionResource) WatchCheckoutStatus 

func (r *SpacewaveSessionResource) WatchCheckoutStatus(
	req *s4wave_provider_spacewave.WatchCheckoutStatusRequest,
	strm s4wave_session.SRPCSpacewaveSessionResourceService_WatchCheckoutStatusStream,
) error

WatchCheckoutStatus streams checkout status changes via the checkout WS.

func (*SpacewaveSessionResource) WatchEmails 

func (r *SpacewaveSessionResource) WatchEmails(
	req *s4wave_provider_spacewave.WatchEmailsRequest,
	strm s4wave_session.SRPCSpacewaveSessionResourceService_WatchEmailsStream,
) error

WatchEmails streams the account's email list, emitting on changes.

func (*SpacewaveSessionResource) WatchOnboardingStatus 

func (r *SpacewaveSessionResource) WatchOnboardingStatus(
	req *s4wave_provider_spacewave.WatchOnboardingStatusRequest,
	strm s4wave_session.SRPCSpacewaveSessionResourceService_WatchOnboardingStatusStream,
) error

WatchOnboardingStatus streams Onboarding Status, the Spacewave cloud session route-status projection used by root, plan, billing, and lifecycle routers.

func (*SpacewaveSessionResource) WatchOrganizationState 

func (r *SpacewaveSessionResource) WatchOrganizationState(
	req *s4wave_provider_spacewave.WatchOrganizationStateRequest,
	strm s4wave_session.SRPCSpacewaveSessionResourceService_WatchOrganizationStateStream,
) error

WatchOrganizationState streams one organization's combined mutable state.

func (*SpacewaveSessionResource) WatchOrganizations 

func (r *SpacewaveSessionResource) WatchOrganizations(
	req *s4wave_provider_spacewave.WatchOrganizationsRequest,
	strm s4wave_session.SRPCSpacewaveSessionResourceService_WatchOrganizationsStream,
) error

WatchOrganizations streams the user's org list, emitting on membership changes.

func (*SpacewaveSessionResource) WatchSubscriptionStatus 

func (r *SpacewaveSessionResource) WatchSubscriptionStatus(
	req *s4wave_provider_spacewave.WatchSubscriptionStatusRequest,
	strm s4wave_session.SRPCSpacewaveSessionResourceService_WatchSubscriptionStatusStream,
) error

WatchSubscriptionStatus streams billing account state changes.

func (*SpacewaveSessionResource) WatchTargetedInvitations added in v0.51.2 

func (r *SpacewaveSessionResource) WatchTargetedInvitations(
	req *s4wave_provider_spacewave.ListTargetedInvitationsRequest,
	strm s4wave_session.SRPCSpacewaveSessionResourceService_WatchTargetedInvitationsStream,
) error

WatchTargetedInvitations streams recipient targeted invitation inbox snapshots.

type StatusResource 

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

StatusResource implements the SystemStatusService for a session.

func NewStatusResource 

func NewStatusResource(b bus.Bus) *StatusResource

NewStatusResource creates a new StatusResource.

func (*StatusResource) WatchControllers 

func (r *StatusResource) WatchControllers(
	_ *s4wave_status.WatchControllersRequest,
	strm s4wave_status.SRPCSystemStatusService_WatchControllersStream,
) error

WatchControllers streams the list of active controllers on change.

func (*StatusResource) WatchDirectives 

func (r *StatusResource) WatchDirectives(
	_ *s4wave_status.WatchDirectivesRequest,
	strm s4wave_status.SRPCSystemStatusService_WatchDirectivesStream,
) error

WatchDirectives streams the list of active directives on change.

func (*StatusResource) WatchPlugins added in v0.51.0 

func (r *StatusResource) WatchPlugins(
	_ *s4wave_status.WatchPluginsRequest,
	strm s4wave_status.SRPCSystemStatusService_WatchPluginsStream,
) error

WatchPlugins streams the plugin host scheduler's live plugin instances.

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.