batch

type ApiClient struct {
	*Config
}

type Config struct {
	HttpClient  *http.Client
	ApiToken    string
	Version     string
	APIEndpoint string
}

type CreateCollectionRequest struct {
	Name                string `json:"name"`
	Notes               string `json:"notes"`
	SchemaID            string `json:"schema_id"`
	DatalakeID          string `json:"datalake_id"`
	EnvelopeType        string `json:"envelope_type"`
	EnvelopeRootMessage string `json:"envelope_root_message"`
	PayloadRootMessage  string `json:"payload_root_message"`
	PayloadFieldID      int    `json:"payload_field_id"`
}

type CreateCollectionResponse struct {
	ID        string `json:"id"`
	Token     string `json:"token"`
	CreatedAt string `json:"created_at"`
	UpdatedAt string `json:"updated_at"`
}

type CreateTeamMemberRequest struct {
	Name     string   `json:"name"`
	Email    string   `json:"email"`
	Password string   `json:"password"`
	Roles    []string `json:"roles"`
}

type CreateTeamMemberResponse struct {
	Id             string `json:"id"`
	Name           string `json:"name"`
	Email          string `json:"email"`
	AvailableTeams []struct {
		Id   string `json:"id"`
		Name string `json:"name"`
	} `json:"available_teams"`
	Roles []string `json:"roles"`
}

type ErrorResponse struct {
	Errors []*ResponseError `json:"errors"`
}

type Filter struct {
	Name   string
	Values []string
}

type IBatchAPI interface {
	CreateCollection(params *CreateCollectionRequest) (*CreateCollectionResponse, diag.Diagnostics)
	DeleteCollection(collectionID string) (*UpdateCollectionResponse, diag.Diagnostics)
	GetCollection(collectionID string) (*ReadCollectionResponse, diag.Diagnostics)
	UpdateCollection(collectionID string, params *UpdateCollectionRequest) (*UpdateCollectionResponse, diag.Diagnostics)

	CreateTeamMember(params *CreateTeamMemberRequest) (*CreateTeamMemberResponse, diag.Diagnostics)
	DeleteTeamMember(id string) diag.Diagnostics
	GetTeamMember(accountID string) (*ReadTeamMemberResponse, diag.Diagnostics)
	UpdateTeamMember(id string, params *UpdateTeamMemberRequest) (*UpdateTeamMemberResponse, diag.Diagnostics)

	GetDataLake(filters []*Filter) (map[string]interface{}, diag.Diagnostics)

	GetSchema(filters []*Filter) (map[string]interface{}, diag.Diagnostics)
}

type ReadCollectionResponse struct {
	ID                  string `json:"id"`
	Token               string `json:"token"`
	Name                string `json:"name"`
	Notes               string `json:"notes"`
	Archived            bool   `json:"archived"`
	SchemaID            string `json:"schema_id"`
	DatalakeID          string `json:"datalake_id"`
	EnvelopeType        string `json:"envelope_type"`
	EnvelopeRootMessage string `json:"envelope_root_message"`
	PayloadRootMessage  string `json:"payload_root_message"`
	PayloadFieldID      int    `json:"payload_field_id"`
	CreatedAt           string `json:"created_at"`
	UpdatedAt           string `json:"updated_at"`
}

type ReadTeamMemberResponse struct {
	Id             string `json:"id"`
	Name           string `json:"name"`
	Email          string `json:"email"`
	AvailableTeams []struct {
		Id   string `json:"id"`
		Name string `json:"name"`
	} `json:"available_teams"`
	Roles []string `json:"roles"`
}

type ResponseError struct {
	Code     int    `json:"code"`
	Domain   string `json:"domain"`
	Status   string `json:"status"`
	RawError string `json:"raw_error"`
	Message  string `json:"message"`
	Field    string `json:"field"`
}

type UpdateCollectionRequest struct {
	CollectionID string `json:"collection_id"`
	Name         string `json:"name,omitempty"`
	Notes        string `json:"notes,omitempty"`
	Archived     bool   `json:"archived,omitempty"`
}

type UpdateCollectionResponse struct {
	ID                  string `json:"id"`
	Name                string `json:"name"`
	Notes               string `json:"notes"`
	SchemaID            string `json:"schema_id"`
	DatalakeID          string `json:"datalake_id"`
	EnvelopeType        string `json:"envelope_type"`
	EnvelopeRootMessage string `json:"envelope_root_message"`
	PayloadRootMessage  string `json:"payload_root_message"`
	PayloadFieldID      int    `json:"payload_field_id"`
	Paused              bool   `json:"paused"`
	CreatedAt           string `json:"created_at"`
	UpdatedAt           string `json:"updated_at"`
	Archived            bool   `json:"archived"`
}

type UpdateTeamMemberRequest struct {
	Name     string   `json:"name"`
	Email    string   `json:"email"`
	Password string   `json:"password"`
	Roles    []string `json:"roles"`
}

type UpdateTeamMemberResponse struct {
	Id             string `json:"id"`
	Name           string `json:"name"`
	Email          string `json:"email"`
	AvailableTeams []struct {
		Id   string `json:"id"`
		Name string `json:"name"`
	} `json:"available_teams"`
	Roles []string `json:"roles"`
}