plexwatch

Nov 5, 2026

Changes in this version

+ var ErrPMSAddress = errors.New("plexwatch: enter the server address, like http://192.168.1.10:32400")

+ var ErrPMSDifferentServer = errors.New("plexwatch: that address is a different Plex Media Server")

+ var ErrPMSDuplicate = errors.New("plexwatch: this Plex Media Server is already added")

+ var ErrPMSInvalid = errors.New("plexwatch: invalid server settings")

+ var ErrPMSLimit = errors.New("plexwatch: limit reached")

+ var ErrPMSNeedsToken = errors.New("plexwatch: sending to Plex for this person needs their token for this server")

+ var ErrPMSNotOwner = errors.New("plexwatch: this token is not the server owner's")

+ var ErrPMSToken = errors.New("plexwatch: the Plex Media Server refused this token")

+ var ErrPMSUnreachable = errors.New("plexwatch: the Plex Media Server could not be reached")

+ type PMSAccount struct

+ ID int64

+ Name string

+ Owner bool

+ UserID int64

+ type PMSCatalog interface

+ ByExternalIDForType func(ctx context.Context, source, id string, typ core.MediaType) (*core.Title, error)

+ Get func(ctx context.Context, key core.RatingKey) (*core.Title, error)

+ type PMSMapping struct

+ AccountID int64

+ AccountName string

+ CanSend bool

+ Direction int

+ Interval int

+ LastImport int64

+ LastSend int64

+ NextSync int64

+ Owner bool

+ Problem string

+ Unmatched int

+ UserID int64

+ type PMSMappingInput struct

+ Direction int

+ Interval int

+ Token *string

+ UserID int64

+ type PMSServer struct

+ CheckedAt int64

+ ID int64

+ MachineID string

+ Name string

+ Owner string

+ Problem string

+ URL string

+ Version string

+ Viewers []PMSMapping

+ type PMSUnmatched struct

+ Direction string

+ Reason string

+ Ref string

+ SeenAt int64

+ Title string

+ type Servers struct

+ func NewServers(o ServersOptions) (*Servers, error)

+ func (s *Servers) Accounts(ctx context.Context, id int64) ([]PMSAccount, error)

+ func (s *Servers) Add(ctx context.Context, name, baseURL, token string) (PMSServer, error)

+ func (s *Servers) Close() error

+ func (s *Servers) List(ctx context.Context) ([]PMSServer, error)

+ func (s *Servers) MapAccount(ctx context.Context, id, accountID int64, in PMSMappingInput) (PMSServer, error)

+ func (s *Servers) Remove(ctx context.Context, id int64) error

+ func (s *Servers) Run(ctx context.Context)

+ func (s *Servers) RunOnce(ctx context.Context)

+ func (s *Servers) Server(ctx context.Context, id int64) (PMSServer, error)

+ func (s *Servers) SyncNow(ctx context.Context, id int64) (PMSServer, error)

+ func (s *Servers) Unmatched(ctx context.Context, id, userID int64, after string) ([]PMSUnmatched, error)

+ func (s *Servers) Update(ctx context.Context, id int64, name, baseURL, token string) (PMSServer, error)

+ type ServersOptions struct

+ Catalog PMSCatalog

+ ClientID string

+ DB *sql.DB

+ GUID GUIDMap

+ HTTP *http.Client

+ Logger *slog.Logger

+ Now func() time.Time

+ Sealer config.FieldSealer

+ State *state.State

+ ViewerExists func(context.Context, int64) (bool, error)

Nov 4, 2026

Changes in this version

+ const AccountSyncSupported

+ var ErrCredentialForbidden = errors.New("plexwatch: credential is not allowed to access watch state")

+ var ErrUnsupported = errors.New("plexwatch: Plex accepts watch-state sync only from its own servers")

type Options

+ ServerIdentity func() (string, string)

type Service

+ func (s *Service) RunImports(ctx context.Context)

+ func (s *Service) SetDirection(ctx context.Context, userID, plexID int64, direction, interval int) (Status, error)

+ func (s *Service) Supported() bool

+ func (s *Service) Unmatched(ctx context.Context, userID, plexID int64, after string) ([]string, error)

type Status

+ Direction int

+ ImportInterval int

+ LastImport int64

+ LastSend int64

+ NextImport int64

+ Problem string

+ ProblemCode int

type StatusError

+ PlexCode int

Nov 1, 2026

Changes in this version

type Service

+ func (s *Service) ReconcileOnce(ctx context.Context) (bool, error)

+ func (s *Service) Resolve(ctx context.Context, userID, plexID int64) (Status, error)

type Status

+ Held int

+ HeldLegacy int

Oct 31, 2026

Changes in this version

+ var ErrAccountMismatch = errors.New("plexwatch: plex account does not belong to this viewer")

+ var ErrNotEligible = errors.New("plexwatch: account has not allowed watch-state sync")

+ var ErrRevoked = errors.New("plexwatch: account token rejected")

+ type Client struct

+ type GUIDMap interface

+ ExactKey func(ctx context.Context, guid string) (core.RatingKey, error)

+ Resolve func(ctx context.Context, key core.RatingKey) (string, error)

+ type Options struct

+ BaseURL string

+ ClientID string

+ DB *sql.DB

+ GUID GUIDMap

+ HTTP *http.Client

+ Logger *slog.Logger

+ NodeID string

+ Now func() time.Time

+ Sealer config.FieldSealer

+ State *state.State

+ type Service struct

+ func New(opts Options) (*Service, error)

+ func (s *Service) BeginPIN(ctx context.Context, userID, plexID int64) (Status, error)

+ func (s *Service) Close() error

+ func (s *Service) DeliverOnce(ctx context.Context) (bool, error)

+ func (s *Service) Disconnect(ctx context.Context, userID, plexID int64) (Status, error)

+ func (s *Service) ExportCurrent(ctx context.Context, userID, plexID int64) (Status, error)

+ func (s *Service) FinishPIN(ctx context.Context, userID, plexID int64) (Status, error)

+ func (s *Service) ImportCurrent(ctx context.Context, userID, plexID int64) (Status, error)

+ func (s *Service) ProbeToken(ctx context.Context, token string, plexID int64) (remoteAccount, error)

+ func (s *Service) Retry(ctx context.Context, userID, plexID int64) (Status, error)

+ func (s *Service) Run(ctx context.Context)

+ func (s *Service) SetEnabled(ctx context.Context, userID, plexID int64, on bool) (Status, error)

+ func (s *Service) Status(ctx context.Context, userID, plexID int64) (Status, error)

+ type Status struct

+ AccountMatch bool

+ Connected bool

+ Dead int

+ Eligibility string

+ Enabled bool

+ InFlight bool

+ PINCode string

+ PINExpires string

+ PINURL string

+ Pending int

+ PlexID int64

+ Restricted bool

+ Revoked bool

+ Skipped int

+ Username string

+ type StatusError struct

+ Op string

+ RetryAfter time.Duration

+ Status int

+ func (e *StatusError) Error() string

+ func (e *StatusError) Is(target error) bool