ditt

type APIHandler interface {

	// Login creates an authenticated session if credentials match a registered user
	Login(ctx context.Context, username string, password string) (bool, error)

	// AddUsers parses user data list from the "reader" stream and store them in the database
	AddUsers(ctx context.Context, reader io.Reader) error

	// DeleteUser deletes the user identified by "userId' from the database
	DeleteUser(ctx context.Context, userId string) error

	// GetUser retrieves the data of the user identified by "userId"
	GetUser(ctx context.Context, userId string) (UserData, error)

	// GetUserList retrieves a set of users from the database
	GetUserList(ctx context.Context, opts ListOptions) (*UserDataList, error)

	// UpdateUser updates the data of the user identified by "userId"
	UpdateUser(ctx context.Context, userId string, userData UserData) error
}

type BaseHandler struct {
	Next APIHandler
}

type ConcurrentUserDataProcessingRunner struct {
	Provider            UserDataProvider
	Processor           UserDataProcessor
	TasksResultsSignals chan<- chan UserDataProcessingResult
	ResultSignal        chan<- chan error
}

type Config struct {
	Port      int `json:"port"`
	TlsConfig *tls.Config
}

type Files interface {
	Save(userId string, data string) error
	Delete(userId string) error
	Get(userId string) (string, error)
}

type ListOptions struct {
	Offset int `json:"offset"`
	Count  int `json:"count"`
}

type UserData string

type UserDataCallback func(UserData) error

type UserDataList struct {
	Offset       int        `json:"offset"`
	UserDataList []UserData `json:"user_data_list"`
}

type UserDataProcessingResult struct {
	Err    error
	UserId string
	Data   UserData
}

type UserDataProcessor interface {
	ProcessData(data UserData) (UserData, error)
}

type UserDataProcessorFunc func(data UserData) (UserData, error)

type UserDataProvider func(callback UserDataCallback) error

type UserDataStore interface {

	// Save saves user data
	Save(data UserData) error

	// Delete deletes the userData matching the given id
	Delete(id string) error

	// Get retrieves userData matching the given id
	Get(id string) (UserData, error)

	// ListForUser fetches a range of UserData that matches the userId
	// and pass each pass each parsed userdata to the callback
	ListForUser(userId string, offset, count int, callback UserDataCallback) error

	// List fetches a range of UserData and pass each pass each
	// parsed userdata to the callback
	List(offset, count int, callback UserDataCallback) error
}