model

type Activity struct {
	ID                ActivityID        `db:"id"`
	UniqueID          string            `db:"unique_id"`
	SubscriptionToken SubscriptionToken `db:"subscription_token"`
	UserID            UserID            `db:"user_id"`
	Data              *ActivityData     `db:"data"`
	CreatedAt         time.Time         `db:"created_at"`
}

type ActivityData struct {
	PlaylistID      PlaylistID     `json:"playlist_id"`
	PlaylistOwnerID UserID         `json:"playlist_owner_id"`
	TrackAdded      *TrackAdded    `json:"track_added,omitempty"`
	TrackMetadata   *TrackMetadata `json:"track_metadata"`
	ActorUserID     UserID         `json:"actor_user_id,omitempty"`
	OccuredAt       time.Time      `json:"occurred_at"`
}

type ActivityID int64

type DBConfig struct {
	HostName string
	Port     int
	User     string
	Password string
	Database string `yaml:"db_name"`
}

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

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

type PlaylistID string

type PlaylistStore interface {
	CreateSubscription(sub *Subscription) (*Subscription, error)
	UpdateSubscriptions(subs []*Subscription) error
	DeleteSubscription(token SubscriptionToken) (bool, error)
	ListSubscriptionsForUser(userID UserID) ([]*Subscription, error)
	ListSubscriptionsToCheck(from time.Time, limit int) ([]*Subscription, error)

	AppendActivities(sub *Subscription, data []*ActivityData) ([]*Activity, error)
	ListActivityForUser(userID UserID, to ActivityID, limit int) ([]*Activity, error)
}

type Subscription struct {
	Token           SubscriptionToken `db:"token"`
	UserID          UserID            `db:"user_id"`
	PlaylistID      PlaylistID        `db:"playlist_id"`
	PlaylistOwnerID UserID            `db:"playlist_owner_id"`
	PlaylistName    string            `db:"playlist_name"`
	PlaylistVersion string            `db:"playlist_version"`
	PlaylistTracks  []byte            `db:"playlist_tracks"`
	NextCheckAt     *time.Time        `db:"next_check_at"`
	CreatedAt       time.Time         `db:"created_at"`
	UpdatedAt       time.Time         `db:"updated_at"`
}

type SubscriptionID int64

type SubscriptionToken string

type TrackAdded struct {
}

type TrackMetadata struct {
	TrackID     string   `json:"track_id"`
	Name        string   `json:"name"`
	ArtistNames []string `json:"artist_names,omitempty"`
	AlbumName   string   `json:"album_name,omitempty"`
	URL         string   `json:"url,omitempty"`
	URI         string   `json:"uri,omitempty"`
}

type User struct {
	ID                 UserID      `db:"id"`
	AccessToken        string      `db:"access_token"`
	RefreshToken       string      `db:"refresh_token"`
	ExpiresAt          time.Time   `db:"expires_at"`
	Name               string      `db:"name"`
	Email              string      `db:"email"`
	LastSeenActivityID *ActivityID `db:"last_seen_activity_id"`
	CreatedAt          time.Time   `db:"created_at"`
	UpdatedAt          time.Time   `db:"updated_at"`
}

type UserID string

type UserStore interface {
	GetUser(userID UserID) (*User, error)
	UpsertUser(user *User) (*User, error)
}