leaplib

type Anarchy struct {
}

type Binder struct {
	ID            string
	SubscribeChan chan (chan<- *BinderPortal)
	// contains filtered or unexported fields
}

type BinderConfig struct {
	FlushPeriod      int64 `json:"flush_period_ms"`
	RetentionPeriod  int64 `json:"retention_period_s"`
	ClientKickPeriod int64 `json:"kick_period_ms"`
}

type BinderError struct {
	ID  string
	Err error
}

type BinderPortal struct {
	Document         *Document
	Version          int
	Error            error
	TransformRcvChan <-chan []interface{}
	RequestSndChan   chan<- BinderRequest
}

type BinderRequest struct {
	Transform   interface{}
	VersionChan chan<- int
	ErrorChan   chan<- error
}

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

type CuratorConfig struct {
	StoreConfig         DocumentStoreConfig      `json:"storage"`
	BinderConfig        BinderConfig             `json:"binder"`
	LoggerConfig        LoggerConfig             `json:"logger"`
	AuthenticatorConfig TokenAuthenticatorConfig `json:"authenticator"`
}

type Document struct {
	ID          string      `json:"id"`
	Title       string      `json:"title"`
	Description string      `json:"description"`
	Type        string      `json:"type"`
	Content     interface{} `json:"content"`
}

type DocumentStore interface {
	Store(string, *Document) error
	Fetch(string) (*Document, error)
}

type DocumentStoreConfig struct {
	Type           string `json:"type"`
	Name           string `json:"name"`
	StoreDirectory string `json:"store_directory"`
}

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

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

type LoggerConfig struct {
	LogLevel   int    `json:"level"`
	TargetPath string `json:"output_path"`
}

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

type Model interface {
	/* PushTransform - Push a single transform to our model, and if successful, return the updated
	 * transform along with the new version of the document.
	 */
	PushTransform(ot interface{}) (interface{}, int, error)

	/* FlushTransforms - apply all unapplied transforms to content, and delete old applied
	 * in accordance with our retention period. Returns a bool indicating whether any changes
	 * were applied, and an error in case a fatal problem was encountered.
	 */
	FlushTransforms(content *interface{}, retention time.Duration) (bool, error)

	/* GetVersion - returns the current version of the document.
	 */
	GetVersion() int
}

type OModel struct {
	DocID     string        `json:"docid"`
	Version   int           `json:"version"`
	Applied   []*OTransform `json:"applied"`
	Unapplied []*OTransform `json:"unapplied"`
}

type OTransform struct {
	Position  int    `json:"position"`
	Delete    int    `json:"num_delete"`
	Insert    string `json:"insert"`
	Version   int    `json:"version"`
	TReceived int64  `json:"received,omitempty"`
}

type TokenAuthenticator interface {
	AuthoriseCreate(token string) bool
	AuthoriseJoin(token, documentID string) bool
}

type TokenAuthenticatorConfig struct {
	Type string `json:"type"`
}