cloud

package

Go to main page

Versions in this module

v0

v0.11.2

Jul 23, 2026

Changes in this version

+ const CloudProviderPrefix

+ var ErrConfigSyncApprovalPending = errors.New("this Desktop is waiting for configuration sync approval")

+ var ErrConfigSyncDenied = errors.New("configuration sync approval was denied")

+ var ErrConfigSyncDisabled = errors.New("desktop configuration sync is disabled")

+ var ErrProviderSyncConflict = errors.New("local and Cloud provider configurations conflict")

+ func CloudProviderRef(providerID string) string

+ func GenerateAccountSyncKey() ([]byte, error)

+ func ParseCloudProviderRef(ref string) (string, bool)

+ func UnwrapAccountSyncKey(privateKey string, wrap AccountSyncKeyWrap) ([]byte, int, error)

+ type AccountPreferences struct

+ DefaultMode string

+ Language string

+ Model string

+ SchemaVersion int

+ SmallModel string

+ Theme string

+ UpdatedAt time.Time

+ type AccountProviderConfigRemote struct

+ Deleted bool

+ Envelope json.RawMessage

+ ProviderID string

+ UpdatedAt string

+ Version int64

+ type AccountSettingsRemote struct

+ Envelope json.RawMessage

+ UpdatedAt *time.Time

+ Version int64

+ type AccountSyncKeyRequest struct

+ ApprovedByDeviceID string

+ CreatedAt string

+ DeviceID string

+ DeviceName string

+ KeyGen int

+ Pubkey string

+ ResolvedAt string

+ Status string

+ Wrap json.RawMessage

+ type AccountSyncKeyState struct

+ KeyGen int

+ State string

+ Status string

+ UpdatedAt string

+ Wrap json.RawMessage

+ type AccountSyncKeyWrap struct

+ CT string

+ EphemeralPubKey string

+ Nonce string

+ func WrapAccountSyncKey(targetPublicKey string, ask []byte, keyGen int) (*AccountSyncKeyWrap, error)

type CapabilityModel

+ ImageSupport bool

+ Kind string

+ ProviderName string

+ Reasoning bool

+ Scope string

+ ScopeName string

+ Source string

+ ToolCall bool

type Client

+ func (c *Client) GetAccountSettings(ctx context.Context, token string) (*AccountSettingsRemote, error)

+ func (c *Client) GetAccountSyncKey(ctx context.Context, token string) (*AccountSyncKeyState, error)

+ func (c *Client) InitializeAccountSyncKey(ctx context.Context, token string, keyGen int, wrap *AccountSyncKeyWrap) error

+ func (c *Client) ListAccountProviderConfigs(ctx context.Context, token string) ([]AccountProviderConfigRemote, error)

+ func (c *Client) ListAccountSyncKeyRequests(ctx context.Context, token, status string) ([]AccountSyncKeyRequest, error)

+ func (c *Client) ListCloudModels(ctx context.Context, token string) ([]CloudModel, error)

+ func (c *Client) PutAccountProviderConfig(ctx context.Context, token, providerID string, baseVersion int64, ...) (*AccountProviderConfigRemote, error)

+ func (c *Client) PutAccountSettings(ctx context.Context, token string, baseVersion int64, envelope json.RawMessage) (*AccountSettingsRemote, error)

+ func (c *Client) RekeyPairings(ctx context.Context, token, revokedID string, keyGen int, ...) error

+ func (c *Client) RequestAccountSyncKey(ctx context.Context, token string) (*AccountSyncKeyRequest, error)

+ func (c *Client) RespondAccountSyncKeyRequest(ctx context.Context, token, deviceID string, approve bool, keyGen int, ...) error

+ func (c *Client) RevokeAccountSyncKeyDevice(ctx context.Context, token, deviceID string) error

+ type CloudModel struct

+ Capabilities struct{ ... }

+ ContextWindow int

+ Kind string

+ ModelID string

+ ModelName string

+ ProviderID string

+ ProviderName string

+ Scope string

+ ScopeID string

+ ScopeName string

+ UpstreamModelID string

+ func ListConfiguredCloudModels(ctx context.Context, cfg *config.Config) ([]CloudModel, error)

+ func ResolveCloudModel(ctx context.Context, cfg *config.Config, providerRef, modelID string) (CloudModel, string, string, error)

type Connector

+ func (c *Connector) AccountSyncKeyStatus(ctx context.Context) (*AccountSyncKeyState, error)

+ func (c *Connector) ApproveAccountSyncDevice(ctx context.Context, deviceID string) error

+ func (c *Connector) ApprovedAccountSyncDevices(ctx context.Context) ([]AccountSyncKeyRequest, error)

+ func (c *Connector) DenyAccountSyncDevice(ctx context.Context, deviceID string) error

+ func (c *Connector) PairingRecords(ctx context.Context) ([]Pairing, error)

+ func (c *Connector) PendingAccountSyncDevices(ctx context.Context) ([]AccountSyncKeyRequest, error)

+ func (c *Connector) PushAccountSettings(ctx context.Context) error

+ func (c *Connector) ReconcileAccountSettings(ctx context.Context) error

+ func (c *Connector) ReconcileProviderConfigs(ctx context.Context) error

+ func (c *Connector) RevokeAccountSyncDevice(ctx context.Context, deviceID string) error

+ func (c *Connector) RevokePairing(ctx context.Context, id string) error

type ConnectorConfig

+ AppConfig *config.Config

+ ProviderSyncStatePath string

type Credentials

+ ASK string

+ ASKKeyGen int

type Pairing

+ KeyGen int

+ ResolvedAt string

+ type PairingRekeyWrap struct

+ PairingID string

+ Wrap *CEKWrap

type Status

+ ConfigSync bool

+ DeviceID string

type Supervisor

+ func (s *Supervisor) AccountSyncKeyStatus(ctx context.Context) (*AccountSyncKeyState, error)

+ func (s *Supervisor) ApproveAccountSyncDevice(ctx context.Context, deviceID string) error

+ func (s *Supervisor) ApprovedAccountSyncDevices(ctx context.Context) ([]AccountSyncKeyRequest, error)

+ func (s *Supervisor) DenyAccountSyncDevice(ctx context.Context, deviceID string) error

+ func (s *Supervisor) PairingRecords(ctx context.Context) ([]Pairing, error)

+ func (s *Supervisor) PendingAccountSyncDevices(ctx context.Context) ([]AccountSyncKeyRequest, error)

+ func (s *Supervisor) RevokeAccountSyncDevice(ctx context.Context, deviceID string) error

+ func (s *Supervisor) RevokePairing(ctx context.Context, id string) error

+ func (s *Supervisor) SetConfigSync(enabled bool) error

+ func (s *Supervisor) SyncAccountSettings(ctx context.Context) error

+ func (s *Supervisor) SyncProviderConfigs(ctx context.Context) error

+ func (s *Supervisor) Wait()

v0.11.1

Jul 22, 2026

Changes in this version

+ const DefaultCloudURL

+ const StateConnecting

+ const StateError

+ const StateOffline

+ const StateOnline

+ var ErrAuthorizationDenied = errors.New("authorization denied by user")

+ var ErrDeviceCodeExpired = errors.New("device code expired")

+ var ErrUnknownPairing = errors.New("no such pending pairing")

+ func CEKFromPhrase(phrase string) ([]byte, error)

+ func CEKToPhrase(cek []byte) (string, error)

+ func CredentialsPath() (string, error)

+ func DeleteCredentials() error

+ func FingerprintHash(source string) string

+ func Forget(ctx context.Context, warnf func(format string, args ...any)) error

+ func GenerateCEK() ([]byte, error)

+ func GenerateIdentityKeyPair() (publicKey, privateKey string, err error)

+ func HardwareFingerprintSource() string

+ func IsEnvelope(raw json.RawMessage) bool

+ func Logout(ctx context.Context, warnf func(format string, args ...any)) error

+ func ResetCEKCache()

+ func ResolveFingerprintSource() (string, error)

+ func SaveCredentials(creds *Credentials) error

+ func ShouldConnect(autoConnect bool, creds *Credentials) bool

+ func SyncStorePath() (string, error)

+ func UnwrapCEK(wrap *CEKWrap, requesterPriv *ecdh.PrivateKey) (cek []byte, keyGen int, err error)

+ func UpdateConfigCloud(url string, enabled bool) error

+ func ValidateCloudURL(raw string) (string, error)

+ type APIError struct

+ Code string

+ Message string

+ StatusCode int

+ func (e *APIError) Error() string

+ type Backoff struct

+ Max time.Duration

+ Min time.Duration

+ func NewBackoff(min, max time.Duration) *Backoff

+ func (b *Backoff) Next() time.Duration

+ func (b *Backoff) Reset()

+ func (b *Backoff) Wait(ctx context.Context) error

+ type CEKWrap struct

+ CT string

+ EphemeralPubKey string

+ Nonce string

+ func WrapCEK(requesterPubKeyB64 string, cek []byte, keyGen int) (*CEKWrap, error)

+ type CapabilityModel struct

+ ID string

+ Label string

+ Provider string

+ type CapabilityProject struct

+ Name string

+ Path string

+ type CapabilitySlashCommand struct

+ Description string

+ Slash string

+ Type string

+ type Client struct

+ BaseURL string

+ HTTPClient *http.Client

+ func NewClient(baseURL string) *Client

+ func (c *Client) AckCommand(ctx context.Context, token, id string, ack CommandAck) error

+ func (c *Client) GetPairing(ctx context.Context, token, id string) (*Pairing, error)

+ func (c *Client) Heartbeat(ctx context.Context, token string) error

+ func (c *Client) ListPairings(ctx context.Context, token, status string) ([]Pairing, error)

+ func (c *Client) PollCommands(ctx context.Context, token string, wait time.Duration) (cmds []DeviceCommand, ok bool, err error)

+ func (c *Client) PollDeviceToken(ctx context.Context, deviceCode, fingerprint string) (*DeviceTokenResponse, error)

+ func (c *Client) PollForToken(ctx context.Context, deviceCode, fingerprint string, ...) (*DeviceTokenResponse, error)

+ func (c *Client) RegisterDevice(ctx context.Context, token string, req RegisterDeviceRequest) error

+ func (c *Client) RequestDeviceCode(ctx context.Context, clientName string) (*DeviceCodeResponse, error)

+ func (c *Client) RespondPairing(ctx context.Context, token, id string, approve bool, wrap *CEKWrap) error

+ func (c *Client) RevokeDevice(ctx context.Context, token string) error

+ func (c *Client) SendEphemeral(ctx context.Context, token, sid, kind string, payload json.RawMessage) error

+ func (c *Client) UploadEvents(ctx context.Context, token, sid string, events []EventUpload) (*EventsUploadResponse, error)

+ func (c *Client) UpsertSessions(ctx context.Context, token string, sessions []SessionUpsert, ...) (*SessionsUpsertResponse, error)

+ type CommandAck struct

+ Result any

+ Status string

+ type Connector struct

+ func NewConnector(cfg ConnectorConfig) *Connector

+ func (c *Connector) ApprovePairing(ctx context.Context, id string) error

+ func (c *Connector) DenyPairing(ctx context.Context, id string) error

+ func (c *Connector) LastPaired() (PairedInfo, bool)

+ func (c *Connector) PendingPairings() []PendingPairing

+ func (c *Connector) Run(ctx context.Context)

+ func (c *Connector) Status() (state string, lastErr string)

+ type ConnectorConfig struct

+ Backoff *Backoff

+ BatchMax int

+ BatchWindow time.Duration

+ Cipher *EnvelopeCipher

+ CipherDisabled bool

+ CloudURL string

+ Credentials *Credentials

+ HTTPClient *http.Client

+ HeartbeatInterval time.Duration

+ Hostname string

+ InboxDir string

+ IndexPathFn func() (string, error)

+ IndexPollInterval time.Duration

+ ListSessionsFn func() (map[string][]session.SessionMeta, error)

+ LocalBase string

+ LocalToken string

+ ModelCapabilitiesFn func() ([]CapabilityModel, []string, error)

+ PollWait time.Duration

+ SlashCommandsFn func() ([]CapabilitySlashCommand, error)

+ SyncStore *SyncStore

+ Version string

+ type Credentials struct

+ CEK string

+ CloudURL string

+ DeviceID string

+ DeviceName string

+ DeviceToken string

+ Fingerprint string

+ KeyGen int

+ PrivateKey string

+ PublicKey string

+ func LoadCredentials() (*Credentials, error)

+ type DeviceCapabilities struct

+ CurrentModel *CapabilityModel

+ Efforts []string

+ Models []CapabilityModel

+ Projects []CapabilityProject

+ SlashCommands []CapabilitySlashCommand

+ type DeviceCodeResponse struct

+ DeviceCode string

+ ExpiresIn int

+ Interval int

+ UserCode string

+ VerificationURI string

+ type DeviceCommand struct

+ ID string

+ Kind string

+ Payload json.RawMessage

+ SessionID string

+ type DeviceTokenResponse struct

+ AccessToken string

+ Deduped bool

+ DeviceID string

+ TokenType string

+ type Envelope struct

+ CT string

+ Enc string

+ KeyGen int

+ Nonce string

+ type EnvelopeCipher struct

+ func EnsureCEK() (*EnvelopeCipher, error)

+ func NewEnvelopeCipher(cek []byte, keyGen int) (*EnvelopeCipher, error)

+ func RecoverCEK(phrase string) (*EnvelopeCipher, error)

+ func RotateCEK() (*EnvelopeCipher, error)

+ func (e *EnvelopeCipher) CEK() []byte

+ func (e *EnvelopeCipher) KeyGen() int

+ func (e *EnvelopeCipher) Open(raw json.RawMessage) ([]byte, error)

+ func (e *EnvelopeCipher) OpenMaybe(raw json.RawMessage) ([]byte, bool, error)

+ func (e *EnvelopeCipher) Seal(plaintext []byte) (json.RawMessage, error)

+ type EventUpload struct

+ Kind string

+ Payload json.RawMessage

+ Seq int64

+ type EventsUploadResponse struct

+ Accepted []int64

+ Conflicted []int64

+ MaxSeq int64

+ type PairedInfo struct

+ Auto bool

+ Label string

+ PairedAt time.Time

+ PairingID string

+ type Pairing struct

+ CreatedAt string

+ ID string

+ Label string

+ PubKey string

+ Status string

+ type PendingPairing struct

+ Label string

+ PairingID string

+ PubKey string

+ ReceivedAt time.Time

+ type RegisterDeviceRequest struct

+ E2EE bool

+ Fingerprint string

+ Hostname string

+ JcodeVersion string

+ Name string

+ Platform string

+ PubKey string

+ type SessionSeqInfo struct

+ LastSeq int64

+ SessionID string

+ type SessionUpsert struct

+ Meta json.RawMessage

+ SessionID string

+ Status string

+ type SessionsUpsertResponse struct

+ Sessions []SessionSeqInfo

+ type Status struct

+ AutoConnect bool

+ CloudURL string

+ DeviceName string

+ Error string

+ LoggedIn bool

+ State string

+ type Supervisor struct

+ Version string

+ func NewSupervisor(cfg *config.Config, port int, webToken string) *Supervisor

+ func (s *Supervisor) ApprovePairing(ctx context.Context, id string) error

+ func (s *Supervisor) BuildConnector(creds *Credentials) *Connector

+ func (s *Supervisor) DenyPairing(ctx context.Context, id string) error

+ func (s *Supervisor) LastPaired() (PairedInfo, bool)

+ func (s *Supervisor) PendingPairings() []PendingPairing

+ func (s *Supervisor) SetAutoConnect(enabled bool) error

+ func (s *Supervisor) Start(ctx context.Context)

+ func (s *Supervisor) Status() Status

+ func (s *Supervisor) SyncCredentials()

+ type SyncStore struct

+ func LoadSyncStore(path string) (*SyncStore, error)

+ func (s *SyncStore) Delete(sessionID string) error

+ func (s *SyncStore) Enabled(sessionID string) bool

+ func (s *SyncStore) Has(sessionID string) bool

+ func (s *SyncStore) Path() string

+ func (s *SyncStore) Set(sessionID string, enabled bool) error

+ func (s *SyncStore) SetIfAbsent(sessionID string, enabled bool) (bool, error)

+ func (s *SyncStore) Snapshot() map[string]bool

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