force

package
v1.0.0-24 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 3, 2021 License: MIT Imports: 20 Imported by: 0

Documentation

Overview

A Go package that provides bindings to the force.com REST API

See http://www.salesforce.com/us/developer/docs/api_rest/

Index

Constants

View Source 
const (
	BaseQueryString string = "SELECT %v FROM %v"
)
View Source 
const BreakerTimeout = time.Second * 30

Variables

View Source 
var (
	CometdVersion string = "50.0"
	TopicMode            = map[string]string{
		"CDC":       "/data/%vChangeEvent",
		"Event":     "/event/%v",
		"PushTopic": "/topic/%v",
	}
)

CometdVersion global var

Functions

func BuildQuery 

func BuildQuery(fields, table string, constraints []string) string

func IsBreakerClosed 

func IsBreakerClosed() bool

Types

type ApiError 

type ApiError struct {
	Fields           []string `json:"fields,omitempty" force:"fields,omitempty"`
	Message          string   `json:"message,omitempty" force:"message,omitempty"`
	ErrorCode        string   `json:"errorCode,omitempty" force:"errorCode,omitempty"`
	ErrorName        string   `json:"error,omitempty" force:"error,omitempty"`
	ErrorDescription string   `json:"error_description,omitempty" force:"error_description,omitempty"`
}

func (ApiError) Error 

func (e ApiError) Error() string

func (ApiError) String 

func (e ApiError) String() string

func (ApiError) Validate 

func (e ApiError) Validate() bool

type ApiErrors 

type ApiErrors []*ApiError

Custom Error to handle salesforce api responses.

func (ApiErrors) Error 

func (e ApiErrors) Error() string

func (ApiErrors) String 

func (e ApiErrors) String() string

func (ApiErrors) Validate 

func (e ApiErrors) Validate() bool

type ChildRelationship 

type ChildRelationship struct {
	Field               string `json:"field"`
	ChildSObject        string `json:"childSObject"`
	DeprecatedAndHidden bool   `json:"deprecatedAndHidden"`
	CascadeDelete       bool   `json:"cascadeDelete"`
	RestrictedDelete    bool   `json:"restrictedDelete"`
	RelationshipName    string `json:"relationshipName"`
}

type ForceApi 

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

func Create 

func Create(version, uri, clientId, clientSecret, userName, password,
	securityToken, environment string) (*ForceApi, error)

func CreateWithAccessToken 

func CreateWithAccessToken(version, clientId, accessToken, instanceUrl string) (*ForceApi, error)

func CreateWithRefreshToken 

func CreateWithRefreshToken(version, clientId, clientSecret, refreshToken, environment string) (*ForceApi, error)

func (*ForceApi) ConnectToStreamingAPIWithHandshake 

func (forceAPI *ForceApi) ConnectToStreamingAPIWithHandshake(ctx context.Context) error

ConnectToStreamingAPIWithHandshake connects to streaming API

func (*ForceApi) Delete 

func (forceApi *ForceApi) Delete(path string, params url.Values) error

Delete issues a DELETE to the specified path with the given payload

func (*ForceApi) DeleteSObject 

func (forceApi *ForceApi) DeleteSObject(id string, in SObject) (err error)

func (*ForceApi) DeleteSObjectByExternalId 

func (forceApi *ForceApi) DeleteSObjectByExternalId(id string, in SObject) (err error)

func (*ForceApi) DescribeSObject 

func (forceApi *ForceApi) DescribeSObject(in SObject) (resp *SObjectDescription, err error)

func (*ForceApi) DescribeSObjects 

func (forceAPI *ForceApi) DescribeSObjects() (map[string]*SObjectMetaData, error)

func (*ForceApi) DisconnectStreamingAPI 

func (forceAPI *ForceApi) DisconnectStreamingAPI(ctx context.Context) error

ConnectToStreamingAPI connects to streaming API

func (*ForceApi) Get 

func (forceApi *ForceApi) Get(path string, params url.Values, out interface{}) error

Get issues a GET to the specified path with the given params and put the umarshalled (json) result in the third parameter

func (*ForceApi) GetAccessToken 

func (forceApi *ForceApi) GetAccessToken() string

func (*ForceApi) GetInstanceURL 

func (forceApi *ForceApi) GetInstanceURL() string

func (*ForceApi) GetLimits 

func (forceApi *ForceApi) GetLimits() (limits *Limits, err error)

func (*ForceApi) GetSObject 

func (forceApi *ForceApi) GetSObject(id string, fields []string, out SObject) (err error)

func (*ForceApi) GetSObjectByExternalId 

func (forceApi *ForceApi) GetSObjectByExternalId(id string, fields []string, out SObject) (err error)

func (*ForceApi) GetStreams 

func (forceApi *ForceApi) GetStreams() *StreamsForce

GetStreams returns stream object

func (*ForceApi) InsertSObject 

func (forceApi *ForceApi) InsertSObject(in SObject) (resp *SObjectResponse, err error)

func (*ForceApi) Patch 

func (forceApi *ForceApi) Patch(path string, params url.Values, payload, out interface{}) error

Patch issues a PATCH to the specified path with the given params and payload and put the unmarshalled (json) result in the third parameter

func (*ForceApi) Post 

func (forceApi *ForceApi) Post(path string, params url.Values, payload, out interface{}) error

Post issues a POST to the specified path with the given params and payload and put the unmarshalled (json) result in the third parameter

func (*ForceApi) Put 

func (forceApi *ForceApi) Put(path string, params url.Values, payload, out interface{}) error

Put issues a PUT to the specified path with the given params and payload and put the unmarshalled (json) result in the third parameter

func (*ForceApi) Query 

func (forceApi *ForceApi) Query(query string, out interface{}) (err error)

Use the Query resource to execute a SOQL query that returns all the results in a single response, or if needed, returns part of the results and an identifier used to retrieve the remaining results.

func (*ForceApi) QueryAll 

func (forceApi *ForceApi) QueryAll(query string, out interface{}) (err error)

Use the QueryAll resource to execute a SOQL query that includes information about records that have been deleted because of a merge or delete. Use QueryAll rather than Query, because the Query resource will automatically filter out items that have been deleted.

func (*ForceApi) QueryNext 

func (forceApi *ForceApi) QueryNext(uri string, out interface{}) (err error)

func (*ForceApi) RefreshToken 

func (forceApi *ForceApi) RefreshToken() error

func (*ForceApi) Stream 

func (forceAPI *ForceApi) Stream(ctx context.Context) error

Stream consume stream to streaming API. Do handshake first before calling di function

func (*ForceApi) Subscribe 

func (forceAPI *ForceApi) Subscribe(ctx context.Context, mode, topic string, callback func([]byte, ...interface{})) ([]byte, error)

Subscribe receives message from any mode such as: "CDC" : Change Data Capture "PushTopic" : Push Topic "Event" : Event

func (*ForceApi) TraceOff 

func (forceApi *ForceApi) TraceOff()

TraceOff turns off tracing. It is idempotent.

func (*ForceApi) TraceOn 

func (forceApi *ForceApi) TraceOn(prefix string, logger ForceApiLogger)

TraceOn turns on logging for this ForceApi. After this is called, all requests, responses, and raw response bodies will be sent to the logger. If prefix is a non-empty string, it will be written to the front of all logged strings, which can aid in filtering log lines.

Use TraceOn if you want to spy on the ForceApi requests and responses.

Note that the base log.Logger type satisfies ForceApiLogger, but adapters can easily be written for other logging packages (e.g., the golang-sanctioned glog framework).

func (*ForceApi) Unsubscribe 

func (forceAPI *ForceApi) Unsubscribe(ctx context.Context, mode, topic string) ([]byte, error)

Unsubscribe from

func (*ForceApi) UpdateSObject 

func (forceApi *ForceApi) UpdateSObject(id string, in SObject) (err error)

func (*ForceApi) UpsertSObjectByExternalId 

func (forceApi *ForceApi) UpsertSObjectByExternalId(id string, in SObject) (resp *SObjectResponse, err error)

type ForceApiLogger 

type ForceApiLogger interface {
	Printf(format string, v ...interface{})
}

type Limit 

type Limit struct {
	Remaining float64
	Max       float64
}

type Limits 

type Limits map[string]Limit

type PicklistValue 

type PicklistValue struct {
	Value       string `json:"value"`
	DefaulValue bool   `json:"defaultValue"`
	ValidFor    string `json:"validFor"`
	Active      bool   `json:"active"`
	Label       string `json:"label"`
}

type RecordTypeInfo 

type RecordTypeInfo struct {
	Name                     string            `json:"name"`
	Available                bool              `json:"available"`
	RecordTypeId             string            `json:"recordTypeId"`
	URLs                     map[string]string `json:"urls"`
	DefaultRecordTypeMapping bool              `json:"defaultRecordTypeMapping"`
}

type RefreshTokenResponse 

type RefreshTokenResponse struct {
	ID          string `json:"id"`
	IssuedAt    string `json:"issued_at"`
	Signature   string `json:"signature"`
	AccessToken string `json:"access_token"`
}

type SObject 

type SObject interface {
	ApiName() string
	ExternalIdApiName() string
}

SObject interface all standard and custom objects must implement. Needed for uri generation.

type SObjectApiResponse 

type SObjectApiResponse struct {
	Encoding     string             `json:"encoding"`
	MaxBatchSize int64              `json:"maxBatchSize"`
	SObjects     []*SObjectMetaData `json:"sobjects"`
}

type SObjectDescription 

type SObjectDescription struct {
	Name                string               `json:"name"`
	Fields              []*SObjectField      `json:"fields"`
	KeyPrefix           string               `json:"keyPrefix"`
	Layoutable          bool                 `json:"layoutable"`
	Activateable        bool                 `json:"activateable"`
	LabelPlural         string               `json:"labelPlural"`
	Custom              bool                 `json:"custom"`
	CompactLayoutable   bool                 `json:"compactLayoutable"`
	Label               string               `json:"label"`
	Searchable          bool                 `json:"searchable"`
	URLs                map[string]string    `json:"urls"`
	Queryable           bool                 `json:"queryable"`
	Deletable           bool                 `json:"deletable"`
	Updateable          bool                 `json:"updateable"`
	Createable          bool                 `json:"createable"`
	CustomSetting       bool                 `json:"customSetting"`
	Undeletable         bool                 `json:"undeletable"`
	Mergeable           bool                 `json:"mergeable"`
	Replicateable       bool                 `json:"replicateable"`
	Triggerable         bool                 `json:"triggerable"`
	FeedEnabled         bool                 `json:"feedEnabled"`
	Retrievable         bool                 `json:"retrieveable"`
	SearchLayoutable    bool                 `json:"searchLayoutable"`
	LookupLayoutable    bool                 `json:"lookupLayoutable"`
	Listviewable        bool                 `json:"listviewable"`
	DeprecatedAndHidden bool                 `json:"deprecatedAndHidden"`
	RecordTypeInfos     []*RecordTypeInfo    `json:"recordTypeInfos"`
	ChildRelationsips   []*ChildRelationship `json:"childRelationships"`

	AllFields string `json:"-"` // Not from force.com API. Used to generate SELECT * queries.
}

type SObjectField 

type SObjectField struct {
	Length                   float64          `json:"length"`
	Name                     string           `json:"name"`
	Type                     string           `json:"type"`
	DefaultValue             string           `json:"defaultValue"`
	RestrictedPicklist       bool             `json:"restrictedPicklist"`
	NameField                bool             `json:"nameField"`
	ByteLength               float64          `json:"byteLength"`
	Precision                float64          `json:"precision"`
	Filterable               bool             `json:"filterable"`
	Sortable                 bool             `json:"sortable"`
	Unique                   bool             `json:"unique"`
	CaseSensitive            bool             `json:"caseSensitive"`
	Calculated               bool             `json:"calculated"`
	Scale                    float64          `json:"scale"`
	Label                    string           `json:"label"`
	NamePointing             bool             `json:"namePointing"`
	Custom                   bool             `json:"custom"`
	HtmlFormatted            bool             `json:"htmlFormatted"`
	DependentPicklist        bool             `json:"dependentPicklist"`
	Permissionable           bool             `json:"permissionable"`
	ReferenceTo              []string         `json:"referenceTo"`
	RelationshipOrder        float64          `json:"relationshipOrder"`
	SoapType                 string           `json:"soapType"`
	CalculatedValueFormula   string           `json:"calculatedValueFormula"`
	DefaultValueFormula      string           `json:"defaultValueFormula"`
	DefaultedOnCreate        bool             `json:"defaultedOnCreate"`
	Digits                   float64          `json:"digits"`
	Groupable                bool             `json:"groupable"`
	Nillable                 bool             `json:"nillable"`
	InlineHelpText           string           `json:"inlineHelpText"`
	WriteRequiresMasterRead  bool             `json:"writeRequiresMasterRead"`
	PicklistValues           []*PicklistValue `json:"picklistValues"`
	Updateable               bool             `json:"updateable"`
	Createable               bool             `json:"createable"`
	DeprecatedAndHidden      bool             `json:"deprecatedAndHidden"`
	DisplayLocationInDecimal bool             `json:"displayLocationInDecimal"`
	CascadeDelete            bool             `json:"cascasdeDelete"`
	RestrictedDelete         bool             `json:"restrictedDelete"`
	ControllerName           string           `json:"controllerName"`
	ExternalId               bool             `json:"externalId"`
	IdLookup                 bool             `json:"idLookup"`
	AutoNumber               bool             `json:"autoNumber"`
	RelationshipName         string           `json:"relationshipName"`
}

type SObjectMetaData 

type SObjectMetaData struct {
	Name                string            `json:"name"`
	Label               string            `json:"label"`
	KeyPrefix           string            `json:"keyPrefix"`
	LabelPlural         string            `json:"labelPlural"`
	Custom              bool              `json:"custom"`
	Layoutable          bool              `json:"layoutable"`
	Activateable        bool              `json:"activateable"`
	URLs                map[string]string `json:"urls"`
	Searchable          bool              `json:"searchable"`
	Updateable          bool              `json:"updateable"`
	Createable          bool              `json:"createable"`
	DeprecatedAndHidden bool              `json:"deprecatedAndHidden"`
	CustomSetting       bool              `json:"customSetting"`
	Deletable           bool              `json:"deletable"`
	FeedEnabled         bool              `json:"feedEnabled"`
	Mergeable           bool              `json:"mergeable"`
	Queryable           bool              `json:"queryable"`
	Replicateable       bool              `json:"replicateable"`
	Retrieveable        bool              `json:"retrieveable"`
	Undeletable         bool              `json:"undeletable"`
	Triggerable         bool              `json:"triggerable"`
}

type SObjectResponse 

type SObjectResponse struct {
	Id      string    `force:"id,omitempty"`
	Errors  ApiErrors `force:"error,omitempty"` //TODO: Not sure if ApiErrors is the right object
	Success bool      `force:"success,omitempty"`
}

SObjectResponse struct received from force.com API after insert of an sobject.

type StreamsForce 

type StreamsForce struct {
	APIForce       *ForceApi
	ClientID       string
	Subscribes     syncmap.SubscribeMap
	Timeout        int
	LongPoolClient *http.Client
}

StreamsForce struct

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.