object

type CreateObjectSpec struct {
	ObjectType string                 `json:"objectType" validate:"required,valid_object_type"`
	ObjectId   string                 `json:"objectId"   validate:"omitempty,valid_object_id"`
	Meta       map[string]interface{} `json:"meta"`
}

type FilterOptions struct {
	ObjectType string `json:"objectType,omitempty"`
}

type ListObjectSpecV1 []ObjectSpec

type ListObjectsSpecV2 struct {
	Results    []ObjectSpec    `json:"results"`
	NextCursor *service.Cursor `json:"nextCursor,omitempty"`
	PrevCursor *service.Cursor `json:"prevCursor,omitempty"`
}

type Model interface {
	GetID() int64
	GetObjectType() string
	GetObjectId() string
	GetMeta() *string
	SetMeta(meta map[string]interface{}) error
	GetCreatedAt() time.Time
	GetUpdatedAt() time.Time
	GetDeletedAt() *time.Time
	ToObjectSpec() (*ObjectSpec, error)
}

type MySQLRepository struct {
	database.SQLRepository
}

type Object struct {
	ID         int64      `mysql:"id"         postgres:"id"          sqlite:"id"`
	ObjectType string     `mysql:"objectType" postgres:"object_type" sqlite:"objectType"`
	ObjectId   string     `mysql:"objectId"   postgres:"object_id"   sqlite:"objectId"`
	Meta       *string    `mysql:"meta"       postgres:"meta"        sqlite:"meta"`
	CreatedAt  time.Time  `mysql:"createdAt"  postgres:"created_at"  sqlite:"createdAt"`
	UpdatedAt  time.Time  `mysql:"updatedAt"  postgres:"updated_at"  sqlite:"updatedAt"`
	DeletedAt  *time.Time `mysql:"deletedAt"  postgres:"deleted_at"  sqlite:"deletedAt"`
}

type ObjectListParamParser struct{}

type ObjectRepository interface {
	Create(ctx context.Context, object Model) (int64, error)
	GetById(ctx context.Context, id int64) (Model, error)
	GetByObjectTypeAndId(ctx context.Context, objectType string, objectId string) (Model, error)
	BatchGetByObjectTypeAndIds(ctx context.Context, objectType string, objectIds []string) ([]Model, error)
	List(ctx context.Context, filterOptions *FilterOptions, listParams service.ListParams) ([]Model, *service.Cursor, *service.Cursor, error)
	UpdateByObjectTypeAndId(ctx context.Context, objectType string, objectId string, object Model) error
	DeleteByObjectTypeAndId(ctx context.Context, objectType string, objectId string) error
	DeleteWarrantsMatchingObject(ctx context.Context, objectType string, objectId string) error
	DeleteWarrantsMatchingSubject(ctx context.Context, subjectType string, subjectId string) error
}

type ObjectService struct {
	service.BaseService
	// contains filtered or unexported fields
}

type ObjectSpec struct {
	// NOTE: ID is required here for internal use.
	// However, we don't return it to the client.
	ID         int64                  `json:"-"`
	ObjectType string                 `json:"objectType"`
	ObjectId   string                 `json:"objectId"`
	Meta       map[string]interface{} `json:"meta,omitempty"`
	CreatedAt  time.Time              `json:"createdAt"`
}

type PostgresRepository struct {
	database.SQLRepository
}

type SQLiteRepository struct {
	database.SQLRepository
}

type Service interface {
	Create(ctx context.Context, objectSpec CreateObjectSpec) (*ObjectSpec, error)
	GetByObjectTypeAndId(ctx context.Context, objectType string, objectId string) (*ObjectSpec, error)
	BatchGetByObjectTypeAndIds(ctx context.Context, objectType string, objectIds []string) ([]ObjectSpec, error)
	List(ctx context.Context, filterOptions *FilterOptions, listParams service.ListParams) ([]ObjectSpec, *service.Cursor, *service.Cursor, error)
	UpdateByObjectTypeAndId(ctx context.Context, objectType string, objectId string, updateSpec UpdateObjectSpec) (*ObjectSpec, error)
	DeleteByObjectTypeAndId(ctx context.Context, objectType string, objectId string) (*wookie.Token, error)
}

type UpdateObjectSpec struct {
	Meta map[string]interface{} `json:"meta"`
}