pkg

type BulkJobRecord struct {
	ID                              string  `json:"id"`
	Operation                       string  `json:"operation"`
	Object                          string  `json:"object"`
	CreatedById                     string  `json:"createdById"`
	CreatedDate                     string  `json:"createdDate"`
	SystemModstamp                  string  `json:"systemModstamp"`
	State                           string  `json:"state"`
	ConcurrencyMode                 string  `json:"concurrencyMode"`
	ContentType                     string  `json:"contentType"`
	ApiVersion                      float64 `json:"apiVersion"`
	LineEnding                      string  `json:"lineEnding"`
	ColumnDelimiter                 string  `json:"columnDelimiter"`
	NumberRecordsProcessed          int64   `json:"numberRecordsProcessed"`
	Retries                         int64   `json:"retries"`
	TotalProcessingTimeMilliseconds int64   `json:"totalProcessingTime"`
}

type CollectionsDeleteRequest struct {
	AllOrNone bool     `json:"allOrNone"`
	Ids       []string `json:"ids"`
}

type CollectionsRequest struct {
	AllOrNone bool `json:"allOrNone"`
	// the use of json.RawMessage here is to avoid the need to unmarshal the
	// provided records json and remarshal it.
	Records []json.RawMessage `json:"records"`
}

type CollectionsResponseError struct {
	StatusCode string   `json:"statusCode"`
	Message    string   `json:"message"`
	Fields     []string `json:"fields"`
}

type CollectionsResponseItem struct {
	Id      string                     `json:"id"`
	Success bool                       `json:"success"`
	Errors  []CollectionsResponseError `json:"errors"`
}

type CompositeObject struct {
	// SalesforceId is only used for UpdateObjects and DeleteObjects
	SalesforceId string
	// ReferenceId is used to correlate the response to the request
	ReferenceId string
	// ObjectType is the salesforce object type, e.g. "Account"
	ObjectType string
	// Body is the json body to send to salesforce
	Body []byte
}

type CompositeRequest struct {
	AllOrNone        bool                  `json:"allOrNone"`
	CompositeRequest []CompositeSubRequest `json:"compositeRequest"`
}

type CompositeResponse struct {
	CompositeResponse []CompositeSubResponse `json:"compositeResponse"`
}

type CompositeSubRequest struct {
	// the use of json.RawMessage here is to avoid the need to unmarshal the
	// body from json and remarshal it.
	Body        json.RawMessage `json:"body,omitempty"`
	HttpHeaders interface{}     `json:"httpHeaders,omitempty"`
	Method      string          `json:"method"`
	ReferenceId string          `json:"referenceId"`
	Url         string          `json:"url"`
}

type CompositeSubResponse struct {
	Body           CompositeSubResponseBody `json:"body"`
	HttpStatusCode int                      `json:"httpStatusCode"`
	ReferenceId    string                   `json:"referenceId"`
}

type CompositeSubResponseBody struct {
	Id      string `json:"id"`
	Success bool   `json:"success"`
	// TODO strongly type this when we figure out the possibilities. the docs
	// don't specify what this field is supposed to be
	Errors []interface{} `json:"errors"`
}

type Config struct {
	BaseUrl        string `valid:"url,required"`
	ApiVersion     string `valid:"required"`
	ClientId       string `valid:"required"`
	ClientSecret   string `valid:"required"`
	Username       string `valid:"required"`
	Password       string `valid:"required"`
	GrantType      string `valid:"required"`
	FastHTTPClient *fasthttp.Client
}

type DescribeObjectResponse struct {
	Name   string                         `json:"name"`
	Fields []DescribeObjectResponseFields `json:"fields"`
}

type DescribeObjectResponseFields struct {
	Name       string `json:"name"`
	Type       string `json:"type"`
	Calculated bool   `json:"calculated"`
	Createable bool   `json:"createable"`
}

type GetBulkQueryJobResultsResponse struct {
	NumberOfRecords int
	Locator         string
	Body            []byte
}

type Limit struct {
	Max       int `json:"Max"`
	Remaining int `json:"Remaining"`
}

type LimitsResponse struct {
	AnalyticsExternalDataSizeMB                 Limit               `json:"AnalyticsExternalDataSizeMB"`
	ConcurrentAsyncGetReportInstances           Limit               `json:"ConcurrentAsyncGetReportInstances"`
	ConcurrentEinsteinDataInsightsStoryCreation Limit               `json:"ConcurrentEinsteinDataInsightsStoryCreation"`
	ConcurrentEinsteinDiscoveryStoryCreation    Limit               `json:"ConcurrentEinsteinDiscoveryStoryCreation"`
	ConcurrentSyncReportRuns                    Limit               `json:"ConcurrentSyncReportRuns"`
	DailyAnalyticsDataflowJobExecutions         Limit               `json:"DailyAnalyticsDataflowJobExecutions"`
	DailyAnalyticsUploadedFilesSizeMB           Limit               `json:"DailyAnalyticsUploadedFilesSizeMB"`
	DailyApiRequests                            Limit               `json:"DailyApiRequests"`
	DailyAsyncApexExecutions                    Limit               `json:"DailyAsyncApexExecutions"`
	DailyAsyncApexTests                         Limit               `json:"DailyAsyncApexTests"`
	DailyBulkApiBatches                         Limit               `json:"DailyBulkApiBatches"`
	DailyBulkV2QueryFileStorageMB               Limit               `json:"DailyBulkV2QueryFileStorageMB"`
	DailyBulkV2QueryJobs                        Limit               `json:"DailyBulkV2QueryJobs"`
	DailyDeliveredPlatformEvents                Limit               `json:"DailyDeliveredPlatformEvents"`
	DailyDurableGenericStreamingApiEvents       Limit               `json:"DailyDurableGenericStreamingApiEvents"`
	DailyDurableStreamingApiEvents              Limit               `json:"DailyDurableStreamingApiEvents"`
	DailyEinsteinDataInsightsStoryCreation      Limit               `json:"DailyEinsteinDataInsightsStoryCreation"`
	DailyEinsteinDiscoveryOptimizationJobRuns   Limit               `json:"DailyEinsteinDiscoveryOptimizationJobRuns"`
	DailyEinsteinDiscoveryPredictAPICalls       Limit               `json:"DailyEinsteinDiscoveryPredictAPICalls"`
	DailyEinsteinDiscoveryPredictionsByCDC      Limit               `json:"DailyEinsteinDiscoveryPredictionsByCDC"`
	DailyEinsteinDiscoveryStoryCreation         Limit               `json:"DailyEinsteinDiscoveryStoryCreation"`
	DailyFunctionsApiCallLimit                  Limit               `json:"DailyFunctionsApiCallLimit"`
	DailyGenericStreamingApiEvents              Limit               `json:"DailyGenericStreamingApiEvents"`
	DailyStandardVolumePlatformEvents           Limit               `json:"DailyStandardVolumePlatformEvents"`
	DailyStreamingApiEvents                     Limit               `json:"DailyStreamingApiEvents"`
	DailyWorkflowEmails                         Limit               `json:"DailyWorkflowEmails"`
	DataStorageMB                               Limit               `json:"DataStorageMB"`
	DurableStreamingApiConcurrentClients        Limit               `json:"DurableStreamingApiConcurrentClients"`
	FileStorageMB                               Limit               `json:"FileStorageMB"`
	HourlyAsyncReportRuns                       Limit               `json:"HourlyAsyncReportRuns"`
	HourlyDashboardRefreshes                    Limit               `json:"HourlyDashboardRefreshes"`
	HourlyDashboardResults                      Limit               `json:"HourlyDashboardResults"`
	HourlyDashboardStatuses                     Limit               `json:"HourlyDashboardStatuses"`
	HourlyLongTermIdMapping                     Limit               `json:"HourlyLongTermIdMapping"`
	HourlyManagedContentPublicRequests          Limit               `json:"HourlyManagedContentPublicRequests"`
	HourlyODataCallout                          Limit               `json:"HourlyODataCallout"`
	HourlyPublishedPlatformEvents               Limit               `json:"HourlyPublishedPlatformEvents"`
	HourlyPublishedStandardVolumePlatformEvents Limit               `json:"HourlyPublishedStandardVolumePlatformEvents"`
	HourlyShortTermIdMapping                    Limit               `json:"HourlyShortTermIdMapping"`
	HourlySyncReportRuns                        Limit               `json:"HourlySyncReportRuns"`
	HourlyTimeBasedWorkflow                     Limit               `json:"HourlyTimeBasedWorkflow"`
	MassEmail                                   Limit               `json:"MassEmail"`
	MonthlyEinsteinDiscoveryStoryCreation       Limit               `json:"MonthlyEinsteinDiscoveryStoryCreation"`
	MonthlyPlatformEventsUsageEntitlement       Limit               `json:"MonthlyPlatformEventsUsageEntitlement"`
	Package2VersionCreates                      Limit               `json:"Package2VersionCreates"`
	Package2VersionCreatesWithoutValidation     Limit               `json:"Package2VersionCreatesWithoutValidation"`
	PermissionSets                              PermissionSetsLimit `json:"PermissionSets"`
	PrivateConnectOutboundCalloutHourlyLimitMB  Limit               `json:"PrivateConnectOutboundCalloutHourlyLimitMB"`
	PublishCallbackUsageInApex                  Limit               `json:"PublishCallbackUsageInApex"`
	SingleEmail                                 Limit               `json:"SingleEmail"`
	StreamingApiConcurrentClients               Limit               `json:"StreamingApiConcurrentClients"`
}

type ListBulkJobsResponse struct {
	Done           bool            `json:"done"`
	Records        []BulkJobRecord `json:"records"`
	NextRecordsUrl string          `json:"nextRecordsUrl"`
}

type ObjectResponse struct {
	Id      string
	Errors  []string
	Success bool
}

type PermissionSetsLimit struct {
	Max          int   `json:"Max"`
	Remaining    int   `json:"Remaining"`
	CreateCustom Limit `json:"CreateCustom"`
}

type SalesforceCredentials struct {
	AccessToken string `json:"access_token"`
	InstanceUrl string `json:"instance_url"`
	Id          string `json:"id"`
	TokenType   string `json:"token_type"`
	IssuedAt    int    `json:"issued_at,string"`
	Signature   string `json:"signature"`
}

type SalesforceUtils struct {
	Config         Config
	Credentials    SalesforceCredentials
	FastHTTPClient *fasthttp.Client
}

type SoqlResponse struct {
	Done           bool
	TotalSize      int
	Records        []interface{}
	NextRecordsUrl string
}