domain

type Consumption struct {
	ID                 uuid.UUID `json:"id"`
	MeterID            int       `json:"meter_id"`
	Active             float64   `json:"active"`
	ReactiveInductive  float64   `json:"reactive_inductive"`
	ReactiveCapacitive float64   `json:"reactive_capacitive"`
	Exported           float64   `json:"exported"`
	Period             string    `json:"period"`
	Timestamp          time.Time `json:"timestamp"`
}

type ConsumptionRepository interface {
	Save(ctx context.Context, consumption *Consumption) error
	FindByID(c context.Context, id uuid.UUID) (*Consumption, error)
	FindByPeriod(c context.Context, period_type, start, end string, meterIDs []int, pagination *Pagination) (*Response, error)
}

type ConsumptionUsecase interface {
	GetConsumptionByID(id uuid.UUID) (*Consumption, error)
	GetConsumptionsByPeriod(period_type, start, end string, meterIDs []int, pagination *Pagination) (*Response, error)
}

type ErrorResponse struct {
	Message string `json:"message"`
}

type JwtCustomClaims struct {
	Email string    `json:"email"`
	ID    uuid.UUID `json:"id"`
	jwt.StandardClaims
}

type JwtCustomRefreshClaims struct {
	ID uuid.UUID `json:"id"`
	jwt.StandardClaims
}

type LoginRequest struct {
	Email    string `json:"email,omitempty" jsonschema:"required,description=Email of the user,title=Email"`
	Password string `json:"password,omitempty" jsonschema:"required,description=Password of the user,title=Password"`
}

type LoginResponse struct {
	AccessToken  string `json:"accessToken"`
	RefreshToken string `json:"refreshToken"`
}

type LoginUsecase interface {
	GetUserByEmail(c context.Context, email string) (*User, error)
	CreateAccessToken(user *User, secret string, expiry int) (accessToken string, err error)
	CreateRefreshToken(user *User, secret string, expiry int) (refreshToken string, err error)
}

type Meter struct {
	ID      uuid.UUID
	Address string
}

type MeterRepository interface {
	FindByID(ctx context.Context, id uuid.UUID) (*Meter, error)
	FindMany(ctx context.Context, pagination *Pagination) ([]*Meter, error)
}

type MeterUsecase interface {
	GetMeterById(id uuid.UUID) (*Meter, error)
	GetManyMeters(pagination *Pagination) ([]*Meter, error)
}

type Pagination struct {
	Limit  *int `json:"limit,omitempty"`
	Offset *int `json:"offset,omitempty"`
}

type RefreshTokenRequest struct {
	RefreshToken string `form:"refreshToken" binding:"required"`
}

type RefreshTokenResponse struct {
	AccessToken  string `json:"accessToken"`
	RefreshToken string `json:"refreshToken"`
}

type RefreshTokenUsecase interface {
	GetUserByEmail(c context.Context, id string) (*User, error)
	CreateAccessToken(user *User, secret string, expiry int) (accessToken string, err error)
	CreateRefreshToken(user *User, secret string, expiry int) (refreshToken string, err error)
	ExtractIDFromToken(requestToken string, secret string) (string, error)
}

type Response struct {
	Period    []string                 `json:"period"`
	DataGraph []map[string]interface{} `json:"data_graph"`
}

type SignupRequest struct {
	Email    string `json:"email,omitempty" jsonschema:"description=Email,format=email,title=Email,required"`
	Password string `json:"password,omitempty" jsonschema:"description=Password,title=Password,required"`
}

type SignupResponse struct {
	AccessToken  string `json:"accessToken"`
	RefreshToken string `json:"refreshToken"`
}

type SignupUsecase interface {
	Create(c context.Context, user *User) (*User, error)
	GetUserByEmail(c context.Context, email string) (*User, error)
	CreateAccessToken(user *User, secret string, expiry int) (accessToken string, err error)
	CreateRefreshToken(user *User, secret string, expiry int) (refreshToken string, err error)
}

type SuccessResponse struct {
	Message string `json:"message"`
}

type User struct {
	ID       uuid.UUID `json:"id"`
	Email    string    `json:"email"`
	Password string    `json:"password,omitempty"`
}

type UserRepository interface {
	Create(ctx context.Context, user *User) (*User, error)
	FindByID(ctx context.Context, id uuid.UUID) (*User, error)
	FindByEmail(ctx context.Context, email string) (*User, error)
	Update(ctx context.Context, user *User) (*User, error)
}

type UserUseCase interface {
	GetByID(ctx context.Context, id uuid.UUID) (*User, error)
	GetByEmail(ctx context.Context, email string) (*User, error)
	Create(ctx context.Context, user *User) error
	Update(ctx context.Context, user *User) error
	Delete(ctx context.Context, id uuid.UUID) error
}