job

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

type ColumnName string

type ConfigJob struct {
	StoragePath  string `koanf:"storage_path"`
	CsvFile      string `koanf:"csv_file"`
	XlsxFile     string `koanf:"xlsx_file"`
	ProcessCount int    `koanf:"process_count"`
	BufferSize   int    `koanf:"buffer_size"`
}

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

type ContributorRecord struct {
	RowNumber      int
	GithubID       int64
	GithubUsername string
	DisplayName    string
	ProfileImage   string
	Bio            string
	PrivacyMode    string
	Email          string
	CreatedAt      time.Time
}

type ContributorRepo interface {
	Upsert(ctx context.Context, contributor contributor.UpsertContributorRequest) (contributor.UpsertContributorResponse, error)
}

type FailRecord struct {
	ID           uint
	JobID        uint
	RecordNumber int
	Reason       string
	RawData      []string
	RetryCount   int
	LastError    string
	ErrType      RecordErrType
	CreatedAt    time.Time
	UpdatedAt    *time.Time
}

type FailRepository interface {
	Create(ctx context.Context, failRecord FailRecord) error
	GetByJobID(ctx context.Context, jobID uint) ([]FailRecord, error)
}

type FileProcessor interface {
	Process(file *os.File) (ProcessResult, error)
}

type GetFailRecordsResponse struct {
	ID           uint          `json:"id"`
	JobID        uint          `json:"job_id"`
	RecordNumber int           `json:"record_number"`
	Reason       string        `json:"reason"`
	RawData      []string      `json:"raw_data"`
	RetryCount   int           `json:"retry_count"`
	LastError    string        `json:"last_error"`
	ErrType      RecordErrType `json:"err_type"`
	CreatedAt    time.Time     `json:"created_at"`
	UpdatedAt    *time.Time    `json:"updated_at"`
}

type GetJobResponse struct {
	ID             uint      `json:"ID"`
	TotalRecords   int       `json:"total_records,omitempty"`
	SuccessCount   int       `json:"success_count,omitempty"`
	FailCount      int       `json:"fail_count,omitempty"`
	IdempotencyKey string    `json:"idempotency_key"`
	FileHash       string    `json:"file_hash"`
	FileName       string    `json:"file_name"`
	FilePath       string    `json:"file_path"`
	Status         Status    `json:"status"`
	CreatedAt      time.Time `json:"created_at"`
	UpdatedAt      time.Time `json:"updated_at,omitempty"`
}

type ImportContributorRequest struct {
	File           multipart.File `json:"file"`
	FileName       string         `json:"file_name"`
	FileType       string         `json:"file_type"`
	IdempotencyKey string         `json:"idempotency_key"`
}

type ImportContributorResponse struct {
	JobID   uint   `json:"job_id"`
	Message string `json:"message"`
}

type Job struct {
	ID             uint
	TotalRecords   int
	SuccessCount   int
	FailCount      int
	IdempotencyKey string
	FileHash       string
	FileName       string
	FilePath       string
	Status         Status
	CreatedAt      time.Time
	UpdatedAt      time.Time
}

type ProcessResult struct {
	Total          int
	Success        int
	Fail           int
	SuccessRecords []ContributorRecord
	FailRecords    []FailRecord
}

type ProduceJob struct {
	JobID          uint
	IdempotencyKey string
}

type Publisher interface {
	Publish(ctx context.Context, pj ProduceJob) error
}

type RecordErrType int

type RecordProcessError struct {
	Type RecordErrType
	Err  error
}

type Repository interface {
	CreateJob(ctx context.Context, job Job) (uint, error)
	GetJobByIdempotencyKey(ctx context.Context, key string) (*Job, error)
	GetJobByFileHash(ctx context.Context, fileHash string) (*Job, error)
	GetJobByID(ctx context.Context, ID uint) (Job, error)
	UpdateStatus(ctx context.Context, jobID uint, status Status) error
	UpdateJob(ctx context.Context, job Job) error
}

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

type Status string

type ValidateConfig struct {
	HttpFileType []string `koanf:"http_file_type"`
}

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

type ValidatorJobRepo interface {
	ImportJobRequestValidate(req ImportContributorRequest) error
}

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