forked from customerio/go-customerio
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Added beta api, added MVP for collections
- Loading branch information
Showing
9 changed files
with
508 additions
and
5 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,88 @@ | ||
| package customerio | ||
|
|
||
| import ( | ||
| "fmt" | ||
| "net/http" | ||
| ) | ||
|
|
||
| // UpdateCollection will create or update a collection with raw data | ||
| // See: https://customer.io/docs/api/#operation/addCollection | ||
| // See: https://customer.io/docs/api/#operation/updateCollection | ||
| // | ||
| // The name of the collection. This is how you'll reference your collection in message. | ||
| // Updating the data or url for your collection fully replaces the contents of the collection. | ||
| // Data example: {"data":[{"property1":null,"property2":null}]}} | ||
| func (c *Client) UpdateCollection(collectionID, collectionName string, items []map[string]interface{}) error { | ||
| if collectionName == "" { | ||
| return ParamError{Param: "collectionName"} | ||
| } | ||
| /* | ||
| if len(data) > 56000 { // todo: is there a limit? | ||
| return errors.New("collection body size limited to 56000") | ||
| } | ||
| */ | ||
|
|
||
| // Create or Update (if id is given) | ||
| var err error | ||
| if len(collectionID) == 0 { | ||
| _, err = c.request( | ||
| http.MethodPost, | ||
| fmt.Sprintf("%s/v1/api/collections", c.options.betaURL), | ||
| map[string]interface{}{ | ||
| "data": items, | ||
| "name": collectionName, | ||
| }, | ||
| ) | ||
| } else { | ||
| _, err = c.request( | ||
| http.MethodPut, | ||
| fmt.Sprintf("%s/v1/api/collections/%s", c.options.betaURL, collectionID), | ||
| map[string]interface{}{ | ||
| "data": items, | ||
| "name": collectionName, | ||
| }, | ||
| ) | ||
| } | ||
|
|
||
| return err | ||
| } | ||
|
|
||
| // UpdateCollectionViaURL will create or update a collection using a URL to a JSON file | ||
| // See: https://customer.io/docs/api/#operation/addCollection | ||
| // See: https://customer.io/docs/api/#operation/updateCollection | ||
| // | ||
| // The name of the collection. This is how you'll reference your collection in message. | ||
| // | ||
| // The URL where your data is stored. | ||
| // If your URL does not include a Content-Type, Customer.io assumes your data is JSON. | ||
| // This URL can also be a google sheet that you've shared with cio_share@customer.io. | ||
| // Updating the data or url for your collection fully replaces the contents of the collection. | ||
| func (c *Client) UpdateCollectionViaURL(collectionID, collectionName string, jsonURL string) error { | ||
| if collectionName == "" { | ||
| return ParamError{Param: "collectionName"} | ||
| } | ||
|
|
||
| // Create or Update (if id is given) | ||
| var err error | ||
| if len(collectionID) == 0 { | ||
| _, err = c.request( | ||
| http.MethodPost, | ||
| fmt.Sprintf("%s/v1/api/collections", c.options.betaURL), | ||
| map[string]interface{}{ | ||
| "url": jsonURL, | ||
| "name": collectionName, | ||
| }, | ||
| ) | ||
| } else { | ||
| _, err = c.request( | ||
| http.MethodPut, | ||
| fmt.Sprintf("%s/v1/api/collections/%s", c.options.betaURL, collectionID), | ||
| map[string]interface{}{ | ||
| "url": jsonURL, | ||
| "name": collectionName, | ||
| }, | ||
| ) | ||
| } | ||
|
|
||
| return err | ||
| } |
Oops, something went wrong.