Commit from m3o/m3o action

Add Discord banner to README

README.md

@@ -1,3 +1,11 @@
+<p align="center">
+	<a href="https://discord.gg/TBR9bRjd6Z">
+		<img src="https://discordapp.com/api/guilds/861917584437805127/widget.png?style=banner2" alt="Discord Banner"/>
+	</a>
+</p>
+
+---
+
 # M3O Go Client [![godoc](https://godoc.org/github.com/m3o/m3o-go?status.svg)](https://godoc.org/github.com/m3o/m3o-go) [![Go Report Card](https://goreportcard.com/badge/github.com/m3o/m3o-go)](https://goreportcard.com/report/github.com/m3o/m3o-go) [![Apache 2.0 License](https://img.shields.io/github/license/m3o/m3o-go)](https://github.com/m3o/m3o-go/blob/master/LICENSE)
 
 This is the Go client to access APIs on the M3O Platform

address/address.go

@@ -4,6 +4,10 @@ import (
 	"go.m3o.com/client"
 )
 
+type Address interface {
+	LookupPostcode(*LookupPostcodeRequest) (*LookupPostcodeResponse, error)
+}
+
 func NewAddressService(token string) *AddressService {
 	return &AddressService{
 		client: client.NewClient(&client.Options{

answer/answer.go

@@ -4,6 +4,10 @@ import (
 	"go.m3o.com/client"
 )
 
+type Answer interface {
+	Question(*QuestionRequest) (*QuestionResponse, error)
+}
+
 func NewAnswerService(token string) *AnswerService {
 	return &AnswerService{
 		client: client.NewClient(&client.Options{

app/app.go

@@ -4,6 +4,17 @@ import (
 	"go.m3o.com/client"
 )
 
+type App interface {
+	Delete(*DeleteRequest) (*DeleteResponse, error)
+	List(*ListRequest) (*ListResponse, error)
+	Regions(*RegionsRequest) (*RegionsResponse, error)
+	Reserve(*ReserveRequest) (*ReserveResponse, error)
+	Resolve(*ResolveRequest) (*ResolveResponse, error)
+	Run(*RunRequest) (*RunResponse, error)
+	Status(*StatusRequest) (*StatusResponse, error)
+	Update(*UpdateRequest) (*UpdateResponse, error)
+}
+
 func NewAppService(token string) *AppService {
 	return &AppService{
 		client: client.NewClient(&client.Options{
@@ -56,7 +67,7 @@ func (t *AppService) Resolve(request *ResolveRequest) (*ResolveResponse, error)
 
 }
 
-// Run an app from a source repo. Specify region etc.
+// Run an app from source
 func (t *AppService) Run(request *RunRequest) (*RunResponse, error) {
 
 	rsp := &RunResponse{}
@@ -139,7 +150,7 @@ type ResolveResponse struct {
 type RunRequest struct {
 	// branch. defaults to master
 	Branch string `json:"branch"`
-	// associatede env vars to pass in
+	// associated env vars to pass in
 	EnvVars map[string]string `json:"env_vars"`
 	// name of the app
 	Name string `json:"name"`
@@ -194,6 +205,8 @@ type StatusResponse struct {
 }
 
 type UpdateRequest struct {
+	// Additional env vars to update
+	EnvVars map[string]string `json:"env_vars"`
 	// name of the app
 	Name string `json:"name"`
 }

avatar/avatar.go

@@ -4,6 +4,10 @@ import (
 	"go.m3o.com/client"
 )
 
+type Avatar interface {
+	Generate(*GenerateRequest) (*GenerateResponse, error)
+}
+
 func NewAvatarService(token string) *AvatarService {
 	return &AvatarService{
 		client: client.NewClient(&client.Options{
@@ -16,7 +20,7 @@ type AvatarService struct {
 	client *client.Client
 }
 
-//
+// Generate an unique avatar
 func (t *AvatarService) Generate(request *GenerateRequest) (*GenerateResponse, error) {
 
 	rsp := &GenerateResponse{}
@@ -25,22 +29,21 @@ func (t *AvatarService) Generate(request *GenerateRequest) (*GenerateResponse, e
 }
 
 type GenerateRequest struct {
-	// encode format of avatar image, `png` or `jpeg`, default is `jpeg`
+	// encode format of avatar image: `png` or `jpeg`; default is `jpeg`
 	Format string `json:"format"`
-	// avatar's gender, `male` or `female`, default is `male`
+	// avatar's gender: `male` or `female`; default is `male`
 	Gender string `json:"gender"`
-	// if upload to m3o CDN, default is `false`
-	// if update = true, then it'll return the CDN url
+	// set to true to upload to the M3O CDN and receive the url
 	Upload bool `json:"upload"`
-	// avatar's username, unique username will generates the unique avatar;
-	// if username == "", will generate a random avatar in every request
-	// if upload == true, username will be used as CDN filename rather than a random uuid string
+	// avatar's username, unique username will generate the unique avatar;
+	// if empty, every request generates a random avatar;
+	// if upload == true, username will be the CDN filename rather than a random uuid string
 	Username string `json:"username"`
 }
 
 type GenerateResponse struct {
-	// base64encode string of the avatar image
+	// base64 encoded string of the avatar image
 	Base64 string `json:"base64"`
-	// Micro's CDN url of the avatar image
+	// M3O's CDN url of the avatar image
 	Url string `json:"url"`
 }

cache/cache.go

@@ -4,6 +4,15 @@ import (
 	"go.m3o.com/client"
 )
 
+type Cache interface {
+	Decrement(*DecrementRequest) (*DecrementResponse, error)
+	Delete(*DeleteRequest) (*DeleteResponse, error)
+	Get(*GetRequest) (*GetResponse, error)
+	Increment(*IncrementRequest) (*IncrementResponse, error)
+	ListKeys(*ListKeysRequest) (*ListKeysResponse, error)
+	Set(*SetRequest) (*SetResponse, error)
+}
+
 func NewCacheService(token string) *CacheService {
 	return &CacheService{
 		client: client.NewClient(&client.Options{
@@ -48,6 +57,14 @@ func (t *CacheService) Increment(request *IncrementRequest) (*IncrementResponse,
 
 }
 
+// List all the available keys
+func (t *CacheService) ListKeys(request *ListKeysRequest) (*ListKeysResponse, error) {
+
+	rsp := &ListKeysResponse{}
+	return rsp, t.client.Call("cache", "ListKeys", request, rsp)
+
+}
+
 // Set an item in the cache. Overwrites any existing value already set.
 func (t *CacheService) Set(request *SetRequest) (*SetResponse, error) {
 
@@ -108,6 +125,13 @@ type IncrementResponse struct {
 	Value int64 `json:"value,string"`
 }
 
+type ListKeysRequest struct {
+}
+
+type ListKeysResponse struct {
+	Keys []string `json:"keys"`
+}
+
 type SetRequest struct {
 	// The key to update
 	Key string `json:"key"`

carbon/carbon.go

@@ -0,0 +1,52 @@
+package carbon
+
+import (
+	"go.m3o.com/client"
+)
+
+type Carbon interface {
+	Offset(*OffsetRequest) (*OffsetResponse, error)
+}
+
+func NewCarbonService(token string) *CarbonService {
+	return &CarbonService{
+		client: client.NewClient(&client.Options{
+			Token: token,
+		}),
+	}
+}
+
+type CarbonService struct {
+	client *client.Client
+}
+
+// Purchase 1KG (0.001 tonne) of carbon offsets in a single request
+func (t *CarbonService) Offset(request *OffsetRequest) (*OffsetResponse, error) {
+
+	rsp := &OffsetResponse{}
+	return rsp, t.client.Call("carbon", "Offset", request, rsp)
+
+}
+
+type OffsetRequest struct {
+}
+
+type OffsetResponse struct {
+	// the metric used e.g KG or Tonnes
+	Metric string `json:"metric"`
+	// projects it was allocated to
+	Projects []Project `json:"projects"`
+	// number of tonnes
+	Tonnes float64 `json:"tonnes"`
+	// number of units purchased
+	Units int32 `json:"units"`
+}
+
+type Project struct {
+	// name of the project
+	Name string `json:"name"`
+	// percentage that went to this
+	Percentage float64 `json:"percentage"`
+	// amount in tonnes
+	Tonnes float64 `json:"tonnes"`
+}

chat/chat.go

@@ -0,0 +1,256 @@
+package chat
+
+import (
+	"go.m3o.com/client"
+)
+
+type Chat interface {
+	Create(*CreateRequest) (*CreateResponse, error)
+	Delete(*DeleteRequest) (*DeleteResponse, error)
+	History(*HistoryRequest) (*HistoryResponse, error)
+	Invite(*InviteRequest) (*InviteResponse, error)
+	Join(*JoinRequest) (*JoinResponseStream, error)
+	Kick(*KickRequest) (*KickResponse, error)
+	Leave(*LeaveRequest) (*LeaveResponse, error)
+	List(*ListRequest) (*ListResponse, error)
+	Send(*SendRequest) (*SendResponse, error)
+}
+
+func NewChatService(token string) *ChatService {
+	return &ChatService{
+		client: client.NewClient(&client.Options{
+			Token: token,
+		}),
+	}
+}
+
+type ChatService struct {
+	client *client.Client
+}
+
+// Create a new chat room
+func (t *ChatService) Create(request *CreateRequest) (*CreateResponse, error) {
+
+	rsp := &CreateResponse{}
+	return rsp, t.client.Call("chat", "Create", request, rsp)
+
+}
+
+// Delete a chat room
+func (t *ChatService) Delete(request *DeleteRequest) (*DeleteResponse, error) {
+
+	rsp := &DeleteResponse{}
+	return rsp, t.client.Call("chat", "Delete", request, rsp)
+
+}
+
+// List the messages in a chat
+func (t *ChatService) History(request *HistoryRequest) (*HistoryResponse, error) {
+
+	rsp := &HistoryResponse{}
+	return rsp, t.client.Call("chat", "History", request, rsp)
+
+}
+
+// Invite a user to a chat room
+func (t *ChatService) Invite(request *InviteRequest) (*InviteResponse, error) {
+
+	rsp := &InviteResponse{}
+	return rsp, t.client.Call("chat", "Invite", request, rsp)
+
+}
+
+// Join a chat room
+func (t *ChatService) Join(request *JoinRequest) (*JoinResponseStream, error) {
+	stream, err := t.client.Stream("chat", "Join", request)
+	if err != nil {
+		return nil, err
+	}
+	return &JoinResponseStream{
+		stream: stream,
+	}, nil
+
+}
+
+type JoinResponseStream struct {
+	stream *client.Stream
+}
+
+func (t *JoinResponseStream) Recv() (*JoinResponse, error) {
+	var rsp JoinResponse
+	if err := t.stream.Recv(&rsp); err != nil {
+		return nil, err
+	}
+	return &rsp, nil
+}
+
+// Kick a user from a chat room
+func (t *ChatService) Kick(request *KickRequest) (*KickResponse, error) {
+
+	rsp := &KickResponse{}
+	return rsp, t.client.Call("chat", "Kick", request, rsp)
+
+}
+
+// Leave a chat room
+func (t *ChatService) Leave(request *LeaveRequest) (*LeaveResponse, error) {
+
+	rsp := &LeaveResponse{}
+	return rsp, t.client.Call("chat", "Leave", request, rsp)
+
+}
+
+// List available chats
+func (t *ChatService) List(request *ListRequest) (*ListResponse, error) {
+
+	rsp := &ListResponse{}
+	return rsp, t.client.Call("chat", "List", request, rsp)
+
+}
+
+// Connect to a chat to receive a stream of messages
+// Send a message to a chat
+func (t *ChatService) Send(request *SendRequest) (*SendResponse, error) {
+
+	rsp := &SendResponse{}
+	return rsp, t.client.Call("chat", "Send", request, rsp)
+
+}
+
+type CreateRequest struct {
+	// chat description
+	Description string `json:"description"`
+	// name of the room
+	Name string `json:"name"`
+	// whether its a private room
+	Private bool `json:"private"`
+	// optional list of user ids
+	UserIds string `json:"user_ids"`
+}
+
+type CreateResponse struct {
+	// the unique chat room
+	Room *Room `json:"room"`
+}
+
+type DeleteRequest struct {
+	// the chat room id to delete
+	RoomId string `json:"room_id"`
+}
+
+type DeleteResponse struct {
+	Room *Room `json:"room"`
+}
+
+type HistoryRequest struct {
+	// the chat room id to get
+	RoomId string `json:"room_id"`
+}
+
+type HistoryResponse struct {
+	// messages in the chat room
+	Messages []Message `json:"messages"`
+}
+
+type InviteRequest struct {
+	// the room id
+	RoomId string `json:"room_id"`
+	// the user id
+	UserId string `json:"user_id"`
+}
+
+type InviteResponse struct {
+	Room *Room `json:"room"`
+}
+
+type JoinRequest struct {
+	// chat room to join
+	RoomId string `json:"room_id"`
+	// user id joining
+	UserId string `json:"user_id"`
+}
+
+type JoinResponse struct {
+	Message *Message `json:"message"`
+}
+
+type KickRequest struct {
+	// the chat room id
+	RoomId string `json:"room_id"`
+	// the user id
+	UserId string `json:"user_id"`
+}
+
+type KickResponse struct {
+	Room *Room `json:"room"`
+}
+
+type LeaveRequest struct {
+	// the chat room id
+	RoomId string `json:"room_id"`
+	// the user id
+	UserId string `json:"user_id"`
+}
+
+type LeaveResponse struct {
+	Room *Room `json:"room"`
+}
+
+type ListRequest struct {
+	// optional user id to filter by
+	UserId string `json:"user_id"`
+}
+
+type ListResponse struct {
+	Rooms []Room `json:"rooms"`
+}
+
+type Message struct {
+	// a client side id, should be validated by the server to make the request retry safe
+	Client string `json:"client"`
+	// id of the message, allocated by the server
+	Id string `json:"id"`
+	// id of the chat the message is being sent to / from
+	RoomId string `json:"room_id"`
+	// time the message was sent in RFC3339 format
+	SentAt string `json:"sent_at"`
+	// subject of the message
+	Subject string `json:"subject"`
+	// text of the message
+	Text string `json:"text"`
+	// id of the user who sent the message
+	UserId string `json:"user_id"`
+}
+
+type Room struct {
+	// time of creation
+	CreatedAt string `json:"created_at"`
+	// description of the that
+	Description string `json:"description"`
+	// unique room id
+	Id string `json:"id"`
+	// name of the chat
+	Name string `json:"name"`
+	// whether its a private room
+	Private bool `json:"private"`
+	// list of users
+	UserIds string `json:"user_ids"`
+}
+
+type SendRequest struct {
+	// a client side id, should be validated by the server to make the request retry safe
+	Client string `json:"client"`
+	// id of the chat room the message is being sent to / from
+	RoomId string `json:"room_id"`
+	// subject of the message
+	Subject string `json:"subject"`
+	// text of the message
+	Text string `json:"text"`
+	// id of the user who sent the message
+	UserId string `json:"user_id"`
+}
+
+type SendResponse struct {
+	// the message which was created
+	Message *Message `json:"message"`
+}

comments/comments.go

@@ -0,0 +1,162 @@
+package comments
+
+import (
+	"go.m3o.com/client"
+)
+
+type Comments interface {
+	Create(*CreateRequest) (*CreateResponse, error)
+	Delete(*DeleteRequest) (*DeleteResponse, error)
+	Events(*EventsRequest) (*EventsResponseStream, error)
+	List(*ListRequest) (*ListResponse, error)
+	Read(*ReadRequest) (*ReadResponse, error)
+	Update(*UpdateRequest) (*UpdateResponse, error)
+}
+
+func NewCommentsService(token string) *CommentsService {
+	return &CommentsService{
+		client: client.NewClient(&client.Options{
+			Token: token,
+		}),
+	}
+}
+
+type CommentsService struct {
+	client *client.Client
+}
+
+// Create a new comment
+func (t *CommentsService) Create(request *CreateRequest) (*CreateResponse, error) {
+
+	rsp := &CreateResponse{}
+	return rsp, t.client.Call("comments", "Create", request, rsp)
+
+}
+
+// Delete a comment
+func (t *CommentsService) Delete(request *DeleteRequest) (*DeleteResponse, error) {
+
+	rsp := &DeleteResponse{}
+	return rsp, t.client.Call("comments", "Delete", request, rsp)
+
+}
+
+// Subscribe to comments events
+func (t *CommentsService) Events(request *EventsRequest) (*EventsResponseStream, error) {
+	stream, err := t.client.Stream("comments", "Events", request)
+	if err != nil {
+		return nil, err
+	}
+	return &EventsResponseStream{
+		stream: stream,
+	}, nil
+
+}
+
+type EventsResponseStream struct {
+	stream *client.Stream
+}
+
+func (t *EventsResponseStream) Recv() (*EventsResponse, error) {
+	var rsp EventsResponse
+	if err := t.stream.Recv(&rsp); err != nil {
+		return nil, err
+	}
+	return &rsp, nil
+}
+
+// List all the comments
+func (t *CommentsService) List(request *ListRequest) (*ListResponse, error) {
+
+	rsp := &ListResponse{}
+	return rsp, t.client.Call("comments", "List", request, rsp)
+
+}
+
+// Read a comment
+func (t *CommentsService) Read(request *ReadRequest) (*ReadResponse, error) {
+
+	rsp := &ReadResponse{}
+	return rsp, t.client.Call("comments", "Read", request, rsp)
+
+}
+
+// Update a comment
+func (t *CommentsService) Update(request *UpdateRequest) (*UpdateResponse, error) {
+
+	rsp := &UpdateResponse{}
+	return rsp, t.client.Call("comments", "Update", request, rsp)
+
+}
+
+type Comment struct {
+	// time at which the comment was created
+	Created string `json:"created"`
+	// unique id for the comment, generated if not specified
+	Id string `json:"id"`
+	// subject of the comment
+	Subject string `json:"subject"`
+	// text of the comment
+	Text string `json:"text"`
+	// time at which the comment was updated
+	Updated string `json:"updated"`
+}
+
+type CreateRequest struct {
+	// comment subject
+	Subject string `json:"subject"`
+	// comment items
+	Text string `json:"text"`
+}
+
+type CreateResponse struct {
+	// The created comment
+	Comment *Comment `json:"comment"`
+}
+
+type DeleteRequest struct {
+	// specify the id of the comment
+	Id string `json:"id"`
+}
+
+type DeleteResponse struct {
+	Comment *Comment `json:"comment"`
+}
+
+type EventsRequest struct {
+	// optionally specify a comment id
+	Id string `json:"id"`
+}
+
+type EventsResponse struct {
+	// the comment which the operation occured on
+	Comment *Comment `json:"comment"`
+	// the event which occured; create, delete, update
+	Event string `json:"event"`
+}
+
+type ListRequest struct {
+}
+
+type ListResponse struct {
+	// the comment of comments
+	Comments []Comment `json:"comments"`
+}
+
+type ReadRequest struct {
+	// the comment id
+	Id string `json:"id"`
+}
+
+type ReadResponse struct {
+	// The comment
+	Comment *Comment `json:"comment"`
+}
+
+type UpdateRequest struct {
+	Comment *Comment `json:"comment"`
+}
+
+type UpdateResponse struct {
+	Comment *Comment `json:"comment"`
+}

contact/contact.go

@@ -0,0 +1,200 @@
+package contact
+
+import (
+	"go.m3o.com/client"
+)
+
+type Contact interface {
+	Create(*CreateRequest) (*CreateResponse, error)
+	Delete(*DeleteRequest) (*DeleteResponse, error)
+	List(*ListRequest) (*ListResponse, error)
+	Read(*ReadRequest) (*ReadResponse, error)
+	Update(*UpdateRequest) (*UpdateResponse, error)
+}
+
+func NewContactService(token string) *ContactService {
+	return &ContactService{
+		client: client.NewClient(&client.Options{
+			Token: token,
+		}),
+	}
+}
+
+type ContactService struct {
+	client *client.Client
+}
+
+// Create a contact
+func (t *ContactService) Create(request *CreateRequest) (*CreateResponse, error) {
+
+	rsp := &CreateResponse{}
+	return rsp, t.client.Call("contact", "Create", request, rsp)
+
+}
+
+// Delete a contact
+func (t *ContactService) Delete(request *DeleteRequest) (*DeleteResponse, error) {
+
+	rsp := &DeleteResponse{}
+	return rsp, t.client.Call("contact", "Delete", request, rsp)
+
+}
+
+// List contacts
+func (t *ContactService) List(request *ListRequest) (*ListResponse, error) {
+
+	rsp := &ListResponse{}
+	return rsp, t.client.Call("contact", "List", request, rsp)
+
+}
+
+// Read contact details
+func (t *ContactService) Read(request *ReadRequest) (*ReadResponse, error) {
+
+	rsp := &ReadResponse{}
+	return rsp, t.client.Call("contact", "Read", request, rsp)
+
+}
+
+// Update a contact
+func (t *ContactService) Update(request *UpdateRequest) (*UpdateResponse, error) {
+
+	rsp := &UpdateResponse{}
+	return rsp, t.client.Call("contact", "Update", request, rsp)
+
+}
+
+type Address struct {
+	// the label of the address
+	Label string `json:"label"`
+	// the address location
+	Location string `json:"location"`
+}
+
+type ContactInfo struct {
+	// the address
+	Addresses []Address `json:"addresses"`
+	// the birthday
+	Birthday string `json:"birthday"`
+	// create date string in RFC3339
+	CreatedAt string `json:"created_at"`
+	// the emails
+	Emails []Email `json:"emails"`
+	// contact id
+	Id string `json:"id"`
+	// the contact links
+	Links []Link `json:"links"`
+	// the contact name
+	Name string `json:"name"`
+	// note of the contact
+	Note string `json:"note"`
+	// the phone numbers
+	Phones []Phone `json:"phones"`
+	// the social media username
+	SocialMedias *SocialMedia `json:"social_medias"`
+	// update date string in RFC3339
+	UpdatedAt string `json:"updated_at"`
+}
+
+type CreateRequest struct {
+	// optional, location
+	Addresses []Address `json:"addresses"`
+	// optional, birthday
+	Birthday string `json:"birthday"`
+	// optional, emails
+	Emails []Email `json:"emails"`
+	// optional, links
+	Links []Link `json:"links"`
+	// required, the name of the contact
+	Name string `json:"name"`
+	// optional, note of the contact
+	Note string `json:"note"`
+	// optional, phone numbers
+	Phones []Phone `json:"phones"`
+	// optional, social media
+	SocialMedias *SocialMedia `json:"social_medias"`
+}
+
+type CreateResponse struct {
+	Contact *ContactInfo `json:"contact"`
+}
+
+type DeleteRequest struct {
+	// the id of the contact
+	Id string `json:"id"`
+}
+
+type DeleteResponse struct {
+}
+
+type Email struct {
+	// the email address
+	Address string `json:"address"`
+	// the label of the email
+	Label string `json:"label"`
+}
+
+type Link struct {
+	// the label of the link
+	Label string `json:"label"`
+	// the url of the contact
+	Url string `json:"url"`
+}
+
+type ListRequest struct {
+	// optional, default is 30
+	Limit int32 `json:"limit"`
+	// optional
+	Offset int32 `json:"offset"`
+}
+
+type ListResponse struct {
+	Contacts []ContactInfo `json:"contacts"`
+}
+
+type Phone struct {
+	// the label of the phone number
+	Label string `json:"label"`
+	// phone number
+	Number string `json:"number"`
+}
+
+type ReadRequest struct {
+	Id string `json:"id"`
+}
+
+type ReadResponse struct {
+	Contact *ContactInfo `json:"contact"`
+}
+
+type SocialMedia struct {
+	// the label of the social
+	Label string `json:"label"`
+	// the username of social media
+	Username string `json:"username"`
+}
+
+type UpdateRequest struct {
+	// optional, addresses
+	Addresses []Address `json:"addresses"`
+	// optional, birthday
+	Birthday string `json:"birthday"`
+	// optional, emails
+	Emails []Email `json:"emails"`
+	// required, the contact id
+	Id string `json:"id"`
+	// optional, links
+	Links []Link `json:"links"`
+	// required, the name
+	Name string `json:"name"`
+	// optional, note
+	Note string `json:"note"`
+	// optional, phone number
+	Phones []Phone `json:"phones"`
+	// optional, social media
+	SocialMedias *SocialMedia `json:"social_medias"`
+}
+
+type UpdateResponse struct {
+	Contact *ContactInfo `json:"contact"`
+}

crypto/crypto.go

@@ -4,6 +4,14 @@ import (
 	"go.m3o.com/client"
 )
 
+type Crypto interface {
+	History(*HistoryRequest) (*HistoryResponse, error)
+	News(*NewsRequest) (*NewsResponse, error)
+	Price(*PriceRequest) (*PriceResponse, error)
+	Quote(*QuoteRequest) (*QuoteResponse, error)
+	Symbols(*SymbolsRequest) (*SymbolsResponse, error)
+}
+
 func NewCryptoService(token string) *CryptoService {
 	return &CryptoService{
 		client: client.NewClient(&client.Options{
@@ -48,6 +56,14 @@ func (t *CryptoService) Quote(request *QuoteRequest) (*QuoteResponse, error) {
 
 }
 
+// Returns the full list of supported symbols
+func (t *CryptoService) Symbols(request *SymbolsRequest) (*SymbolsResponse, error) {
+
+	rsp := &SymbolsResponse{}
+	return rsp, t.client.Call("crypto", "Symbols", request, rsp)
+
+}
+
 type Article struct {
 	// the date published
 	Date string `json:"date"`
@@ -126,3 +142,15 @@ type QuoteResponse struct {
 	// the UTC timestamp of the quote
 	Timestamp string `json:"timestamp"`
 }
+
+type Symbol struct {
+	Name   string `json:"name"`
+	Symbol string `json:"symbol"`
+}
+
+type SymbolsRequest struct {
+}
+
+type SymbolsResponse struct {
+	Symbols []Symbol `json:"symbols"`
+}

currency/currency.go

@@ -4,6 +4,13 @@ import (
 	"go.m3o.com/client"
 )
 
+type Currency interface {
+	Codes(*CodesRequest) (*CodesResponse, error)
+	Convert(*ConvertRequest) (*ConvertResponse, error)
+	History(*HistoryRequest) (*HistoryResponse, error)
+	Rates(*RatesRequest) (*RatesResponse, error)
+}
+
 func NewCurrencyService(token string) *CurrencyService {
 	return &CurrencyService{
 		client: client.NewClient(&client.Options{

db/db.go

@@ -4,6 +4,18 @@ import (
 	"go.m3o.com/client"
 )
 
+type Db interface {
+	Count(*CountRequest) (*CountResponse, error)
+	Create(*CreateRequest) (*CreateResponse, error)
+	Delete(*DeleteRequest) (*DeleteResponse, error)
+	DropTable(*DropTableRequest) (*DropTableResponse, error)
+	ListTables(*ListTablesRequest) (*ListTablesResponse, error)
+	Read(*ReadRequest) (*ReadResponse, error)
+	RenameTable(*RenameTableRequest) (*RenameTableResponse, error)
+	Truncate(*TruncateRequest) (*TruncateResponse, error)
+	Update(*UpdateRequest) (*UpdateResponse, error)
+}
+
 func NewDbService(token string) *DbService {
 	return &DbService{
 		client: client.NewClient(&client.Options{

email/email.go

@@ -4,6 +4,12 @@ import (
 	"go.m3o.com/client"
 )
 
+type Email interface {
+	Parse(*ParseRequest) (*ParseResponse, error)
+	Send(*SendRequest) (*SendResponse, error)
+	Validate(*ValidateRequest) (*ValidateResponse, error)
+}
+
 func NewEmailService(token string) *EmailService {
 	return &EmailService{
 		client: client.NewClient(&client.Options{
@@ -16,6 +22,14 @@ type EmailService struct {
 	client *client.Client
 }
 
+// Parse an RFC5322 address e.g "Joe Blogs <joe@example.com>"
+func (t *EmailService) Parse(request *ParseRequest) (*ParseResponse, error) {
+
+	rsp := &ParseResponse{}
+	return rsp, t.client.Call("email", "Parse", request, rsp)
+
+}
+
 // Send an email by passing in from, to, subject, and a text or html body
 func (t *EmailService) Send(request *SendRequest) (*SendResponse, error) {
 
@@ -24,6 +38,26 @@ func (t *EmailService) Send(request *SendRequest) (*SendResponse, error) {
 
 }
 
+// Validate an email address format
+func (t *EmailService) Validate(request *ValidateRequest) (*ValidateResponse, error) {
+
+	rsp := &ValidateResponse{}
+	return rsp, t.client.Call("email", "Validate", request, rsp)
+
+}
+
+type ParseRequest struct {
+	// The address to parse. Can be of the format "Joe Blogs <joe@example.com>" or "joe@example.com"
+	Address string `json:"address"`
+}
+
+type ParseResponse struct {
+	// the email address
+	Address string `json:"address"`
+	// associated name e.g Joe Blogs
+	Name string `json:"name"`
+}
+
 type SendRequest struct {
 	// the display name of the sender
 	From string `json:"from"`
@@ -41,3 +75,11 @@ type SendRequest struct {
 
 type SendResponse struct {
 }
+
+type ValidateRequest struct {
+	Address string `json:"address"`
+}
+
+type ValidateResponse struct {
+	IsValid bool `json:"is_valid"`
+}

emoji/emoji.go

@@ -4,6 +4,12 @@ import (
 	"go.m3o.com/client"
 )
 
+type Emoji interface {
+	Find(*FindRequest) (*FindResponse, error)
+	Flag(*FlagRequest) (*FlagResponse, error)
+	Print(*PrintRequest) (*PrintResponse, error)
+}
+
 func NewEmojiService(token string) *EmojiService {
 	return &EmojiService{
 		client: client.NewClient(&client.Options{
@@ -41,14 +47,6 @@ func (t *EmojiService) Print(request *PrintRequest) (*PrintResponse, error) {
 
 }
 
-// Send an emoji to anyone via SMS. Messages are sent in the form '<message> Sent from <from>'
-func (t *EmojiService) Send(request *SendRequest) (*SendResponse, error) {
-
-	rsp := &SendResponse{}
-	return rsp, t.client.Call("emoji", "Send", request, rsp)
-
-}
-
 type FindRequest struct {
 	// the alias code e.g :beer:
 	Alias string `json:"alias"`
@@ -78,17 +76,3 @@ type PrintResponse struct {
 	// text with rendered emojis
 	Text string `json:"text"`
 }
-
-type SendRequest struct {
-	// the name of the sender from e.g Alice
-	From string `json:"from"`
-	// message to send including emoji aliases
-	Message string `json:"message"`
-	// phone number to send to (including international dialing code)
-	To string `json:"to"`
-}
-
-type SendResponse struct {
-	// whether or not it succeeded
-	Success bool `json:"success"`
-}

evchargers/evchargers.go

@@ -4,6 +4,11 @@ import (
 	"go.m3o.com/client"
 )
 
+type Evchargers interface {
+	ReferenceData(*ReferenceDataRequest) (*ReferenceDataResponse, error)
+	Search(*SearchRequest) (*SearchResponse, error)
+}
+
 func NewEvchargersService(token string) *EvchargersService {
 	return &EvchargersService{
 		client: client.NewClient(&client.Options{

event/event.go

@@ -4,6 +4,12 @@ import (
 	"go.m3o.com/client"
 )
 
+type Event interface {
+	Consume(*ConsumeRequest) (*ConsumeResponseStream, error)
+	Publish(*PublishRequest) (*PublishResponse, error)
+	Read(*ReadRequest) (*ReadResponse, error)
+}
+
 func NewEventService(token string) *EventService {
 	return &EventService{
 		client: client.NewClient(&client.Options{

examples/address/README.md

@@ -1,6 +1,6 @@
 # Address
 
-An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/Address/api](https://m3o.com/Address/api).
+An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/address/api](https://m3o.com/address/api).
 
 Endpoints:
 

examples/answer/README.md

@@ -1,6 +1,6 @@
 # Answer
 
-An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/Answer/api](https://m3o.com/Answer/api).
+An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/answer/api](https://m3o.com/answer/api).
 
 Endpoints:
 

examples/app/README.md

@@ -1,9 +1,37 @@
 # App
 
-An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/App/api](https://m3o.com/App/api).
+An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/app/api](https://m3o.com/app/api).
 
 Endpoints:
 
+## Resolve
+
+Resolve an app by id to its raw backend endpoint
+
+
+[https://m3o.com/app/api#Resolve](https://m3o.com/app/api#Resolve)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/app"
+)
+
+// Resolve an app by id to its raw backend endpoint
+func ResolveAppById() {
+	appService := app.NewAppService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := appService.Resolve(&app.ResolveRequest{
+		Id: "helloworld",
+
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
 ## Update
 
 Update the app. The latest source code will be downloaded, built and deployed.
@@ -117,7 +145,7 @@ func ListTheApps() {
 ```
 ## Run
 
-Run an app from a source repo. Specify region etc.
+Run an app from source
 
 
 [https://m3o.com/app/api#Run](https://m3o.com/app/api#Run)
@@ -132,7 +160,7 @@ import(
 	"go.m3o.com/app"
 )
 
-// Run an app from a source repo. Specify region etc.
+// Run an app from source
 func RunAnApp() {
 	appService := app.NewAppService(os.Getenv("M3O_API_TOKEN"))
 	rsp, err := appService.Run(&app.RunRequest{
@@ -202,31 +230,3 @@ func GetTheStatusOfAnApp() {
 	
 }
 ```
-## Resolve
-
-Resolve an app by id to its raw backend endpoint
-
-
-[https://m3o.com/app/api#Resolve](https://m3o.com/app/api#Resolve)
-
-```go
-package example
-
-import(
-	"fmt"
-	"os"
-
-	"go.m3o.com/app"
-)
-
-// Resolve an app by id to its raw backend endpoint
-func ResolveAppById() {
-	appService := app.NewAppService(os.Getenv("M3O_API_TOKEN"))
-	rsp, err := appService.Resolve(&app.ResolveRequest{
-		Id: "helloworld",
-
-	})
-	fmt.Println(rsp, err)
-	
-}
-```

examples/app/run/runAnApp/main.go

@@ -7,7 +7,7 @@ import (
 	"go.m3o.com/app"
 )
 
-// Run an app from a source repo. Specify region etc.
+// Run an app from source
 func main() {
 	appService := app.NewAppService(os.Getenv("M3O_API_TOKEN"))
 	rsp, err := appService.Run(&app.RunRequest{

examples/avatar/README.md

@@ -1,12 +1,12 @@
 # Avatar
 
-An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/Avatar/api](https://m3o.com/Avatar/api).
+An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/avatar/api](https://m3o.com/avatar/api).
 
 Endpoints:
 
 ## Generate
 
-
+Generate an unique avatar
 
 
 [https://m3o.com/avatar/api#Generate](https://m3o.com/avatar/api#Generate)
@@ -21,39 +21,8 @@ import(
 	"go.m3o.com/avatar"
 )
 
-// 
+// Generate an unique avatar
 func GenerateAvatarAndReturnBase64stringOfTheAvatar() {
-	avatarService := avatar.NewAvatarService(os.Getenv("M3O_API_TOKEN"))
-	rsp, err := avatarService.Generate(&avatar.GenerateRequest{
-		Format: "png",
-Gender: "female",
-Upload: true,
-Username: "",
-
-	})
-	fmt.Println(rsp, err)
-	
-}
-```
-## Generate
-
-
-
-
-[https://m3o.com/avatar/api#Generate](https://m3o.com/avatar/api#Generate)
-
-```go
-package example
-
-import(
-	"fmt"
-	"os"
-
-	"go.m3o.com/avatar"
-)
-
-// 
-func GenerateAnAvatarAndUploadTheAvatarToMicrosCdn() {
 	avatarService := avatar.NewAvatarService(os.Getenv("M3O_API_TOKEN"))
 	rsp, err := avatarService.Generate(&avatar.GenerateRequest{
 		Format: "jpeg",
@@ -66,3 +35,34 @@ Username: "",
 	
 }
 ```
+## Generate
+
+Generate an unique avatar
+
+
+[https://m3o.com/avatar/api#Generate](https://m3o.com/avatar/api#Generate)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/avatar"
+)
+
+// Generate an unique avatar
+func GenerateAnAvatarAndUploadTheAvatarToMicrosCdn() {
+	avatarService := avatar.NewAvatarService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := avatarService.Generate(&avatar.GenerateRequest{
+		Format: "png",
+Gender: "female",
+Upload: true,
+Username: "",
+
+	})
+	fmt.Println(rsp, err)
+	
+}
+```

examples/avatar/generate/generateAnAvatarAndUploadTheAvatarToMicrosCdn/main.go

@@ -7,13 +7,13 @@ import (
 	"go.m3o.com/avatar"
 )
 
-//
+// Generate an unique avatar
 func main() {
 	avatarService := avatar.NewAvatarService(os.Getenv("M3O_API_TOKEN"))
 	rsp, err := avatarService.Generate(&avatar.GenerateRequest{
-		Format:   "jpeg",
+		Format:   "png",
 		Gender:   "female",
-		Upload:   false,
+		Upload:   true,
 		Username: "",
 	})
 	fmt.Println(rsp, err)

examples/avatar/generate/generateAvatarAndReturnBase64stringOfTheAvatar/main.go

@@ -7,13 +7,13 @@ import (
 	"go.m3o.com/avatar"
 )
 
-//
+// Generate an unique avatar
 func main() {
 	avatarService := avatar.NewAvatarService(os.Getenv("M3O_API_TOKEN"))
 	rsp, err := avatarService.Generate(&avatar.GenerateRequest{
-		Format:   "png",
+		Format:   "jpeg",
 		Gender:   "female",
-		Upload:   true,
+		Upload:   false,
 		Username: "",
 	})
 	fmt.Println(rsp, err)

examples/cache/README.md

@@ -1,9 +1,65 @@
 # Cache
 
-An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/Cache/api](https://m3o.com/Cache/api).
+An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/cache/api](https://m3o.com/cache/api).
 
 Endpoints:
 
+## Decrement
+
+Decrement a value (if it's a number). If key not found it is equivalent to set.
+
+
+[https://m3o.com/cache/api#Decrement](https://m3o.com/cache/api#Decrement)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/cache"
+)
+
+// Decrement a value (if it's a number). If key not found it is equivalent to set.
+func DecrementAvalue() {
+	cacheService := cache.NewCacheService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := cacheService.Decrement(&cache.DecrementRequest{
+		Key: "counter",
+Value: 2,
+
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## ListKeys
+
+List all the available keys
+
+
+[https://m3o.com/cache/api#ListKeys](https://m3o.com/cache/api#ListKeys)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/cache"
+)
+
+// List all the available keys
+func ListTheKeys() {
+	cacheService := cache.NewCacheService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := cacheService.ListKeys(&cache.ListKeysRequest{
+		
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
 ## Set
 
 Set an item in the cache. Overwrites any existing value already set.
@@ -118,32 +174,3 @@ Value: 2,
 	
 }
 ```
-## Decrement
-
-Decrement a value (if it's a number). If key not found it is equivalent to set.
-
-
-[https://m3o.com/cache/api#Decrement](https://m3o.com/cache/api#Decrement)
-
-```go
-package example
-
-import(
-	"fmt"
-	"os"
-
-	"go.m3o.com/cache"
-)
-
-// Decrement a value (if it's a number). If key not found it is equivalent to set.
-func DecrementAvalue() {
-	cacheService := cache.NewCacheService(os.Getenv("M3O_API_TOKEN"))
-	rsp, err := cacheService.Decrement(&cache.DecrementRequest{
-		Key: "counter",
-Value: 2,
-
-	})
-	fmt.Println(rsp, err)
-	
-}
-```

examples/cache/listKeys/listTheKeys/main.go

@@ -0,0 +1,15 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/cache"
+)
+
+// List all the available keys
+func main() {
+	cacheService := cache.NewCacheService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := cacheService.ListKeys(&cache.ListKeysRequest{})
+	fmt.Println(rsp, err)
+}

examples/carbon/README.md

@@ -0,0 +1,33 @@
+# Carbon
+
+An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/carbon/api](https://m3o.com/carbon/api).
+
+Endpoints:
+
+## Offset
+
+Purchase 1KG (0.001 tonne) of carbon offsets in a single request
+
+
+[https://m3o.com/carbon/api#Offset](https://m3o.com/carbon/api#Offset)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/carbon"
+)
+
+// Purchase 1KG (0.001 tonne) of carbon offsets in a single request
+func OffsetCarbon() {
+	carbonService := carbon.NewCarbonService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := carbonService.Offset(&carbon.OffsetRequest{
+		
+	})
+	fmt.Println(rsp, err)
+	
+}
+```

examples/carbon/offset/offsetCarbon/main.go

@@ -0,0 +1,15 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/carbon"
+)
+
+// Purchase 1KG (0.001 tonne) of carbon offsets in a single request
+func main() {
+	carbonService := carbon.NewCarbonService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := carbonService.Offset(&carbon.OffsetRequest{})
+	fmt.Println(rsp, err)
+}

examples/chat/README.md

@@ -0,0 +1,269 @@
+# Chat
+
+An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/chat/api](https://m3o.com/chat/api).
+
+Endpoints:
+
+## Create
+
+Create a new chat room
+
+
+[https://m3o.com/chat/api#Create](https://m3o.com/chat/api#Create)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/chat"
+)
+
+// Create a new chat room
+func CreateAnewChat() {
+	chatService := chat.NewChatService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := chatService.Create(&chat.CreateRequest{
+		Description: "The general chat room",
+Name: "general",
+
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## Invite
+
+Invite a user to a chat room
+
+
+[https://m3o.com/chat/api#Invite](https://m3o.com/chat/api#Invite)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/chat"
+)
+
+// Invite a user to a chat room
+func InviteAuser() {
+	chatService := chat.NewChatService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := chatService.Invite(&chat.InviteRequest{
+		
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## Send
+
+Connect to a chat to receive a stream of messages
+Send a message to a chat
+
+
+[https://m3o.com/chat/api#Send](https://m3o.com/chat/api#Send)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/chat"
+)
+
+// Connect to a chat to receive a stream of messages
+// Send a message to a chat
+func SendAmessage() {
+	chatService := chat.NewChatService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := chatService.Send(&chat.SendRequest{
+		Client: "web",
+Subject: "Random",
+Text: "Hey whats up?",
+
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## History
+
+List the messages in a chat
+
+
+[https://m3o.com/chat/api#History](https://m3o.com/chat/api#History)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/chat"
+)
+
+// List the messages in a chat
+func GetChatHistory() {
+	chatService := chat.NewChatService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := chatService.History(&chat.HistoryRequest{
+		
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## Join
+
+Join a chat room
+
+
+[https://m3o.com/chat/api#Join](https://m3o.com/chat/api#Join)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/chat"
+)
+
+// Join a chat room
+func JoinAroom() {
+	chatService := chat.NewChatService(os.Getenv("M3O_API_TOKEN"))
+	
+	stream, err := chatService.Join(&chat.JoinRequest{
+		
+	})
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+
+	for {
+			rsp, err := stream.Recv()
+			if err != nil {
+					fmt.Println(err)
+					return
+			}
+
+			fmt.Println(rsp)
+	}
+}
+```
+## Kick
+
+Kick a user from a chat room
+
+
+[https://m3o.com/chat/api#Kick](https://m3o.com/chat/api#Kick)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/chat"
+)
+
+// Kick a user from a chat room
+func KickAuserFromAroom() {
+	chatService := chat.NewChatService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := chatService.Kick(&chat.KickRequest{
+		
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## Leave
+
+Leave a chat room
+
+
+[https://m3o.com/chat/api#Leave](https://m3o.com/chat/api#Leave)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/chat"
+)
+
+// Leave a chat room
+func LeaveAroom() {
+	chatService := chat.NewChatService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := chatService.Leave(&chat.LeaveRequest{
+		
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## List
+
+List available chats
+
+
+[https://m3o.com/chat/api#List](https://m3o.com/chat/api#List)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/chat"
+)
+
+// List available chats
+func ListChatRooms() {
+	chatService := chat.NewChatService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := chatService.List(&chat.ListRequest{
+		
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## Delete
+
+Delete a chat room
+
+
+[https://m3o.com/chat/api#Delete](https://m3o.com/chat/api#Delete)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/chat"
+)
+
+// Delete a chat room
+func DeleteAchat() {
+	chatService := chat.NewChatService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := chatService.Delete(&chat.DeleteRequest{
+		
+	})
+	fmt.Println(rsp, err)
+	
+}
+```

examples/chat/create/createANewChat/main.go

@@ -0,0 +1,18 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/chat"
+)
+
+// Create a new chat room
+func main() {
+	chatService := chat.NewChatService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := chatService.Create(&chat.CreateRequest{
+		Description: "The general chat room",
+		Name:        "general",
+	})
+	fmt.Println(rsp, err)
+}

examples/chat/delete/deleteAChat/main.go

@@ -0,0 +1,15 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/chat"
+)
+
+// Delete a chat room
+func main() {
+	chatService := chat.NewChatService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := chatService.Delete(&chat.DeleteRequest{})
+	fmt.Println(rsp, err)
+}

examples/chat/history/getChatHistory/main.go

@@ -0,0 +1,15 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/chat"
+)
+
+// List the messages in a chat
+func main() {
+	chatService := chat.NewChatService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := chatService.History(&chat.HistoryRequest{})
+	fmt.Println(rsp, err)
+}

examples/chat/invite/inviteAUser/main.go

@@ -0,0 +1,15 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/chat"
+)
+
+// Invite a user to a chat room
+func main() {
+	chatService := chat.NewChatService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := chatService.Invite(&chat.InviteRequest{})
+	fmt.Println(rsp, err)
+}

examples/chat/join/joinARoom/main.go

@@ -0,0 +1,28 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/chat"
+)
+
+// Join a chat room
+func main() {
+	chatService := chat.NewChatService(os.Getenv("M3O_API_TOKEN"))
+	stream, err := chatService.Join(&chat.JoinRequest{})
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+
+	for {
+		rsp, err := stream.Recv()
+		if err != nil {
+			fmt.Println(err)
+			return
+		}
+
+		fmt.Println(rsp)
+	}
+}

examples/chat/kick/kickAUserFromARoom/main.go

@@ -0,0 +1,15 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/chat"
+)
+
+// Kick a user from a chat room
+func main() {
+	chatService := chat.NewChatService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := chatService.Kick(&chat.KickRequest{})
+	fmt.Println(rsp, err)
+}

examples/chat/leave/leaveARoom/main.go

@@ -0,0 +1,15 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/chat"
+)
+
+// Leave a chat room
+func main() {
+	chatService := chat.NewChatService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := chatService.Leave(&chat.LeaveRequest{})
+	fmt.Println(rsp, err)
+}

examples/chat/list/listChatRooms/main.go

@@ -0,0 +1,15 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/chat"
+)
+
+// List available chats
+func main() {
+	chatService := chat.NewChatService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := chatService.List(&chat.ListRequest{})
+	fmt.Println(rsp, err)
+}

examples/chat/send/sendAMessage/main.go

@@ -0,0 +1,20 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/chat"
+)
+
+// Connect to a chat to receive a stream of messages
+// Send a message to a chat
+func main() {
+	chatService := chat.NewChatService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := chatService.Send(&chat.SendRequest{
+		Client:  "web",
+		Subject: "Random",
+		Text:    "Hey whats up?",
+	})
+	fmt.Println(rsp, err)
+}

examples/comments/README.md

@@ -0,0 +1,190 @@
+# Comments
+
+An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/comments/api](https://m3o.com/comments/api).
+
+Endpoints:
+
+## Create
+
+Create a new comment
+
+
+[https://m3o.com/comments/api#Create](https://m3o.com/comments/api#Create)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/comments"
+)
+
+// Create a new comment
+func CreateAcomment() {
+	commentsService := comments.NewCommentsService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := commentsService.Create(&comments.CreateRequest{
+		Text: "This is my comment",
+
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## Read
+
+Read a comment
+
+
+[https://m3o.com/comments/api#Read](https://m3o.com/comments/api#Read)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/comments"
+)
+
+// Read a comment
+func ReadAcomment() {
+	commentsService := comments.NewCommentsService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := commentsService.Read(&comments.ReadRequest{
+		Id: "63c0cdf8-2121-11ec-a881-0242e36f037a",
+
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## List
+
+List all the comments
+
+
+[https://m3o.com/comments/api#List](https://m3o.com/comments/api#List)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/comments"
+)
+
+// List all the comments
+func ListAllComments() {
+	commentsService := comments.NewCommentsService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := commentsService.List(&comments.ListRequest{
+		
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## Update
+
+Update a comment
+
+
+[https://m3o.com/comments/api#Update](https://m3o.com/comments/api#Update)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/comments"
+)
+
+// Update a comment
+func UpdateAcomment() {
+	commentsService := comments.NewCommentsService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := commentsService.Update(&comments.UpdateRequest{
+		Comment: &comments.Comment{
+		Id: "63c0cdf8-2121-11ec-a881-0242e36f037a",
+	Subject: "Update Comment",
+	Text: "Updated comment text",
+	},
+
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## Delete
+
+Delete a comment
+
+
+[https://m3o.com/comments/api#Delete](https://m3o.com/comments/api#Delete)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/comments"
+)
+
+// Delete a comment
+func DeleteAcomment() {
+	commentsService := comments.NewCommentsService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := commentsService.Delete(&comments.DeleteRequest{
+		Id: "63c0cdf8-2121-11ec-a881-0242e36f037a",
+
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## Events
+
+Subscribe to comments events
+
+
+[https://m3o.com/comments/api#Events](https://m3o.com/comments/api#Events)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/comments"
+)
+
+// Subscribe to comments events
+func SubscribeToEvents() {
+	commentsService := comments.NewCommentsService(os.Getenv("M3O_API_TOKEN"))
+	
+	stream, err := commentsService.Events(&comments.EventsRequest{
+		Id: "63c0cdf8-2121-11ec-a881-0242e36f037a",
+
+	})
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+
+	for {
+			rsp, err := stream.Recv()
+			if err != nil {
+					fmt.Println(err)
+					return
+			}
+
+			fmt.Println(rsp)
+	}
+}
+```

examples/comments/create/createAComment/main.go

@@ -0,0 +1,17 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/comments"
+)
+
+// Create a new comment
+func main() {
+	commentsService := comments.NewCommentsService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := commentsService.Create(&comments.CreateRequest{
+		Text: "This is my comment",
+	})
+	fmt.Println(rsp, err)
+}

examples/comments/delete/deleteAComment/main.go

@@ -0,0 +1,17 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/comments"
+)
+
+// Delete a comment
+func main() {
+	commentsService := comments.NewCommentsService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := commentsService.Delete(&comments.DeleteRequest{
+		Id: "63c0cdf8-2121-11ec-a881-0242e36f037a",
+	})
+	fmt.Println(rsp, err)
+}

examples/comments/events/subscribeToEvents/main.go

@@ -0,0 +1,30 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/comments"
+)
+
+// Subscribe to comments events
+func main() {
+	commentsService := comments.NewCommentsService(os.Getenv("M3O_API_TOKEN"))
+	stream, err := commentsService.Events(&comments.EventsRequest{
+		Id: "63c0cdf8-2121-11ec-a881-0242e36f037a",
+	})
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+
+	for {
+		rsp, err := stream.Recv()
+		if err != nil {
+			fmt.Println(err)
+			return
+		}
+
+		fmt.Println(rsp)
+	}
+}

examples/comments/list/listAllComments/main.go

@@ -0,0 +1,15 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/comments"
+)
+
+// List all the comments
+func main() {
+	commentsService := comments.NewCommentsService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := commentsService.List(&comments.ListRequest{})
+	fmt.Println(rsp, err)
+}

examples/comments/read/readAComment/main.go

@@ -0,0 +1,17 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/comments"
+)
+
+// Read a comment
+func main() {
+	commentsService := comments.NewCommentsService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := commentsService.Read(&comments.ReadRequest{
+		Id: "63c0cdf8-2121-11ec-a881-0242e36f037a",
+	})
+	fmt.Println(rsp, err)
+}

examples/comments/update/updateAComment/main.go

@@ -0,0 +1,21 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/comments"
+)
+
+// Update a comment
+func main() {
+	commentsService := comments.NewCommentsService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := commentsService.Update(&comments.UpdateRequest{
+		Comment: &comments.Comment{
+			Id:      "63c0cdf8-2121-11ec-a881-0242e36f037a",
+			Subject: "Update Comment",
+			Text:    "Updated comment text",
+		},
+	})
+	fmt.Println(rsp, err)
+}

examples/contact/README.md

@@ -0,0 +1,219 @@
+# Contact
+
+An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/contact/api](https://m3o.com/contact/api).
+
+Endpoints:
+
+## Delete
+
+Delete a contact
+
+
+[https://m3o.com/contact/api#Delete](https://m3o.com/contact/api#Delete)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/contact"
+)
+
+// Delete a contact
+func DeleteAcontact() {
+	contactService := contact.NewContactService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := contactService.Delete(&contact.DeleteRequest{
+		Id: "42e48a3c-6221-11ec-96d2-acde48001122",
+
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## List
+
+List contacts
+
+
+[https://m3o.com/contact/api#List](https://m3o.com/contact/api#List)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/contact"
+)
+
+// List contacts
+func ListContactsWithDefaultOffsetAndLimitDefaultLimitIs20() {
+	contactService := contact.NewContactService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := contactService.List(&contact.ListRequest{
+		
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## List
+
+List contacts
+
+
+[https://m3o.com/contact/api#List](https://m3o.com/contact/api#List)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/contact"
+)
+
+// List contacts
+func ListContactsWithSpecificOffsetAndLimit() {
+	contactService := contact.NewContactService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := contactService.List(&contact.ListRequest{
+		Limit: 1,
+Offset: 1,
+
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## Create
+
+Create a contact
+
+
+[https://m3o.com/contact/api#Create](https://m3o.com/contact/api#Create)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/contact"
+)
+
+// Create a contact
+func CreateAcontact() {
+	contactService := contact.NewContactService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := contactService.Create(&contact.CreateRequest{
+		Addresses: []contact.Address{
+contact.Address{
+		Label: "company address",
+		Location: "123 street address",
+}},
+Birthday: "1995-01-01",
+Emails: []contact.Email{
+contact.Email{
+		Address: "home@example.com",
+		Label: "home",
+}},
+Links: []contact.Link{
+contact.Link{
+		Label: "blog",
+		Url: "https://blog.joe.me",
+}},
+Name: "joe",
+Note: "this person is very important",
+Phones: []contact.Phone{
+contact.Phone{
+		Label: "home",
+		Number: "010-12345678",
+}},
+
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## Update
+
+Update a contact
+
+
+[https://m3o.com/contact/api#Update](https://m3o.com/contact/api#Update)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/contact"
+)
+
+// Update a contact
+func UpdateAcontact() {
+	contactService := contact.NewContactService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := contactService.Update(&contact.UpdateRequest{
+		Addresses: []contact.Address{
+contact.Address{
+		Label: "company address",
+		Location: "123 street address",
+}},
+Birthday: "1995-01-01",
+Emails: []contact.Email{
+contact.Email{
+		Address: "home@example.com",
+		Label: "home",
+}},
+Id: "42e48a3c-6221-11ec-96d2-acde48001122",
+Links: []contact.Link{
+contact.Link{
+		Label: "blog",
+		Url: "https://blog.joe.me",
+}},
+Name: "joe",
+Note: "this person is very important",
+Phones: []contact.Phone{
+contact.Phone{
+		Label: "home",
+		Number: "010-12345678",
+}},
+
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## Read
+
+Read contact details
+
+
+[https://m3o.com/contact/api#Read](https://m3o.com/contact/api#Read)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/contact"
+)
+
+// Read contact details
+func GetAcontact() {
+	contactService := contact.NewContactService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := contactService.Read(&contact.ReadRequest{
+		Id: "42e48a3c-6221-11ec-96d2-acde48001122",
+
+	})
+	fmt.Println(rsp, err)
+	
+}
+```

examples/contact/create/createAContact/main.go

@@ -0,0 +1,39 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/contact"
+)
+
+// Create a contact
+func main() {
+	contactService := contact.NewContactService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := contactService.Create(&contact.CreateRequest{
+		Addresses: []contact.Address{
+			contact.Address{
+				Label:    "company address",
+				Location: "123 street address",
+			}},
+		Birthday: "1995-01-01",
+		Emails: []contact.Email{
+			contact.Email{
+				Address: "home@example.com",
+				Label:   "home",
+			}},
+		Links: []contact.Link{
+			contact.Link{
+				Label: "blog",
+				Url:   "https://blog.joe.me",
+			}},
+		Name: "joe",
+		Note: "this person is very important",
+		Phones: []contact.Phone{
+			contact.Phone{
+				Label:  "home",
+				Number: "010-12345678",
+			}},
+	})
+	fmt.Println(rsp, err)
+}

examples/contact/delete/deleteAContact/main.go

@@ -0,0 +1,17 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/contact"
+)
+
+// Delete a contact
+func main() {
+	contactService := contact.NewContactService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := contactService.Delete(&contact.DeleteRequest{
+		Id: "42e48a3c-6221-11ec-96d2-acde48001122",
+	})
+	fmt.Println(rsp, err)
+}

examples/contact/list/listContactsWithDefaultOffsetAndLimitDefaultLimitIs20/main.go

@@ -0,0 +1,15 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/contact"
+)
+
+// List contacts
+func main() {
+	contactService := contact.NewContactService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := contactService.List(&contact.ListRequest{})
+	fmt.Println(rsp, err)
+}

examples/contact/list/listContactsWithSpecificOffsetAndLimit/main.go

@@ -0,0 +1,18 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/contact"
+)
+
+// List contacts
+func main() {
+	contactService := contact.NewContactService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := contactService.List(&contact.ListRequest{
+		Limit:  1,
+		Offset: 1,
+	})
+	fmt.Println(rsp, err)
+}

examples/contact/read/getAContact/main.go

@@ -0,0 +1,17 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/contact"
+)
+
+// Read contact details
+func main() {
+	contactService := contact.NewContactService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := contactService.Read(&contact.ReadRequest{
+		Id: "42e48a3c-6221-11ec-96d2-acde48001122",
+	})
+	fmt.Println(rsp, err)
+}

examples/contact/update/updateAContact/main.go

@@ -0,0 +1,40 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/contact"
+)
+
+// Update a contact
+func main() {
+	contactService := contact.NewContactService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := contactService.Update(&contact.UpdateRequest{
+		Addresses: []contact.Address{
+			contact.Address{
+				Label:    "company address",
+				Location: "123 street address",
+			}},
+		Birthday: "1995-01-01",
+		Emails: []contact.Email{
+			contact.Email{
+				Address: "home@example.com",
+				Label:   "home",
+			}},
+		Id: "42e48a3c-6221-11ec-96d2-acde48001122",
+		Links: []contact.Link{
+			contact.Link{
+				Label: "blog",
+				Url:   "https://blog.joe.me",
+			}},
+		Name: "joe",
+		Note: "this person is very important",
+		Phones: []contact.Phone{
+			contact.Phone{
+				Label:  "home",
+				Number: "010-12345678",
+			}},
+	})
+	fmt.Println(rsp, err)
+}

examples/crypto/README.md

@@ -1,6 +1,6 @@
 # Crypto
 
-An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/Crypto/api](https://m3o.com/Crypto/api).
+An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/crypto/api](https://m3o.com/crypto/api).
 
 Endpoints:
 
@@ -116,3 +116,30 @@ func GetPreviousClose() {
 	
 }
 ```
+## Symbols
+
+Returns the full list of supported symbols
+
+
+[https://m3o.com/crypto/api#Symbols](https://m3o.com/crypto/api#Symbols)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/crypto"
+)
+
+// Returns the full list of supported symbols
+func GetListOfAllSupportedSymbols() {
+	cryptoService := crypto.NewCryptoService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := cryptoService.Symbols(&crypto.SymbolsRequest{
+		
+	})
+	fmt.Println(rsp, err)
+	
+}
+```

examples/crypto/symbols/getListOfAllSupportedSymbols/main.go

@@ -0,0 +1,15 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/crypto"
+)
+
+// Returns the full list of supported symbols
+func main() {
+	cryptoService := crypto.NewCryptoService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := cryptoService.Symbols(&crypto.SymbolsRequest{})
+	fmt.Println(rsp, err)
+}

examples/currency/README.md

@@ -1,38 +1,9 @@
 # Currency
 
-An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/Currency/api](https://m3o.com/Currency/api).
+An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/currency/api](https://m3o.com/currency/api).
 
 Endpoints:
 
-## History
-
-Returns the historic rates for a currency on a given date
-
-
-[https://m3o.com/currency/api#History](https://m3o.com/currency/api#History)
-
-```go
-package example
-
-import(
-	"fmt"
-	"os"
-
-	"go.m3o.com/currency"
-)
-
-// Returns the historic rates for a currency on a given date
-func HistoricRatesForAcurrency() {
-	currencyService := currency.NewCurrencyService(os.Getenv("M3O_API_TOKEN"))
-	rsp, err := currencyService.History(&currency.HistoryRequest{
-		Code: "USD",
-Date: "2021-05-30",
-
-	})
-	fmt.Println(rsp, err)
-	
-}
-```
 ## Codes
 
 Codes returns the supported currency codes for the API
@@ -147,3 +118,32 @@ To: "GBP",
 	
 }
 ```
+## History
+
+Returns the historic rates for a currency on a given date
+
+
+[https://m3o.com/currency/api#History](https://m3o.com/currency/api#History)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/currency"
+)
+
+// Returns the historic rates for a currency on a given date
+func HistoricRatesForAcurrency() {
+	currencyService := currency.NewCurrencyService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := currencyService.History(&currency.HistoryRequest{
+		Code: "USD",
+Date: "2021-05-30",
+
+	})
+	fmt.Println(rsp, err)
+	
+}
+```

examples/db/README.md

@@ -1,178 +1,9 @@
 # Db
 
-An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/Db/api](https://m3o.com/Db/api).
+An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/db/api](https://m3o.com/db/api).
 
 Endpoints:
 
-## Read
-
-Read data from a table. Lookup can be by ID or via querying any field in the record.
-
-
-[https://m3o.com/db/api#Read](https://m3o.com/db/api#Read)
-
-```go
-package example
-
-import(
-	"fmt"
-	"os"
-
-	"go.m3o.com/db"
-)
-
-// Read data from a table. Lookup can be by ID or via querying any field in the record.
-func ReadRecords() {
-	dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
-	rsp, err := dbService.Read(&db.ReadRequest{
-		Query: "age == 43",
-Table: "example",
-
-	})
-	fmt.Println(rsp, err)
-	
-}
-```
-## DropTable
-
-Drop a table in the DB
-
-
-[https://m3o.com/db/api#DropTable](https://m3o.com/db/api#DropTable)
-
-```go
-package example
-
-import(
-	"fmt"
-	"os"
-
-	"go.m3o.com/db"
-)
-
-// Drop a table in the DB
-func DropTable() {
-	dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
-	rsp, err := dbService.DropTable(&db.DropTableRequest{
-		Table: "example",
-
-	})
-	fmt.Println(rsp, err)
-	
-}
-```
-## RenameTable
-
-Rename a table
-
-
-[https://m3o.com/db/api#RenameTable](https://m3o.com/db/api#RenameTable)
-
-```go
-package example
-
-import(
-	"fmt"
-	"os"
-
-	"go.m3o.com/db"
-)
-
-// Rename a table
-func RenameTable() {
-	dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
-	rsp, err := dbService.RenameTable(&db.RenameTableRequest{
-		From: "examples2",
-To: "examples3",
-
-	})
-	fmt.Println(rsp, err)
-	
-}
-```
-## Truncate
-
-Truncate the records in a table
-
-
-[https://m3o.com/db/api#Truncate](https://m3o.com/db/api#Truncate)
-
-```go
-package example
-
-import(
-	"fmt"
-	"os"
-
-	"go.m3o.com/db"
-)
-
-// Truncate the records in a table
-func TruncateTable() {
-	dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
-	rsp, err := dbService.Truncate(&db.TruncateRequest{
-		Table: "example",
-
-	})
-	fmt.Println(rsp, err)
-	
-}
-```
-## Count
-
-Count records in a table
-
-
-[https://m3o.com/db/api#Count](https://m3o.com/db/api#Count)
-
-```go
-package example
-
-import(
-	"fmt"
-	"os"
-
-	"go.m3o.com/db"
-)
-
-// Count records in a table
-func CountEntriesInAtable() {
-	dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
-	rsp, err := dbService.Count(&db.CountRequest{
-		Table: "example",
-
-	})
-	fmt.Println(rsp, err)
-	
-}
-```
-## ListTables
-
-List tables in the DB
-
-
-[https://m3o.com/db/api#ListTables](https://m3o.com/db/api#ListTables)
-
-```go
-package example
-
-import(
-	"fmt"
-	"os"
-
-	"go.m3o.com/db"
-)
-
-// List tables in the DB
-func ListTables() {
-	dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
-	rsp, err := dbService.ListTables(&db.ListTablesRequest{
-		
-	})
-	fmt.Println(rsp, err)
-	
-}
-```
 ## Create
 
 Create a record in the database. Optionally include an "id" field otherwise it's set automatically.
@@ -268,3 +99,172 @@ Table: "example",
 	
 }
 ```
+## Count
+
+Count records in a table
+
+
+[https://m3o.com/db/api#Count](https://m3o.com/db/api#Count)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/db"
+)
+
+// Count records in a table
+func CountEntriesInAtable() {
+	dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := dbService.Count(&db.CountRequest{
+		Table: "example",
+
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## Read
+
+Read data from a table. Lookup can be by ID or via querying any field in the record.
+
+
+[https://m3o.com/db/api#Read](https://m3o.com/db/api#Read)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/db"
+)
+
+// Read data from a table. Lookup can be by ID or via querying any field in the record.
+func ReadRecords() {
+	dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := dbService.Read(&db.ReadRequest{
+		Query: "age == 43",
+Table: "example",
+
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## Truncate
+
+Truncate the records in a table
+
+
+[https://m3o.com/db/api#Truncate](https://m3o.com/db/api#Truncate)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/db"
+)
+
+// Truncate the records in a table
+func TruncateTable() {
+	dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := dbService.Truncate(&db.TruncateRequest{
+		Table: "example",
+
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## DropTable
+
+Drop a table in the DB
+
+
+[https://m3o.com/db/api#DropTable](https://m3o.com/db/api#DropTable)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/db"
+)
+
+// Drop a table in the DB
+func DropTable() {
+	dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := dbService.DropTable(&db.DropTableRequest{
+		Table: "example",
+
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## ListTables
+
+List tables in the DB
+
+
+[https://m3o.com/db/api#ListTables](https://m3o.com/db/api#ListTables)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/db"
+)
+
+// List tables in the DB
+func ListTables() {
+	dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := dbService.ListTables(&db.ListTablesRequest{
+		
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## RenameTable
+
+Rename a table
+
+
+[https://m3o.com/db/api#RenameTable](https://m3o.com/db/api#RenameTable)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/db"
+)
+
+// Rename a table
+func RenameTable() {
+	dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := dbService.RenameTable(&db.RenameTableRequest{
+		From: "examples2",
+To: "examples3",
+
+	})
+	fmt.Println(rsp, err)
+	
+}
+```

examples/db/update/updateARecord/main.go

@@ -12,8 +12,8 @@ func main() {
 	dbService := db.NewDbService(os.Getenv("M3O_API_TOKEN"))
 	rsp, err := dbService.Update(&db.UpdateRequest{
 		Record: map[string]interface{}{
-			"id":  "1",
 			"age": 43,
+			"id":  "1",
 		},
 		Table: "example",
 	})

examples/email/README.md

@@ -1,6 +1,6 @@
 # Email
 
-An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/Email/api](https://m3o.com/Email/api).
+An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/email/api](https://m3o.com/email/api).
 
 Endpoints:
 
@@ -36,3 +36,59 @@ Please verify your email by clicking this link: $micro_verification_link`,
 	
 }
 ```
+## Parse
+
+Parse an RFC5322 address e.g "Joe Blogs <joe@example.com>"
+
+
+[https://m3o.com/email/api#Parse](https://m3o.com/email/api#Parse)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/email"
+)
+
+// Parse an RFC5322 address e.g "Joe Blogs <joe@example.com>"
+func ParseEmail() {
+	emailService := email.NewEmailService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := emailService.Parse(&email.ParseRequest{
+		Address: "Joe Blogs <joe@example.com>",
+
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## Validate
+
+Validate an email address format
+
+
+[https://m3o.com/email/api#Validate](https://m3o.com/email/api#Validate)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/email"
+)
+
+// Validate an email address format
+func ValidateEmail() {
+	emailService := email.NewEmailService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := emailService.Validate(&email.ValidateRequest{
+		Address: "joe@example.com",
+
+	})
+	fmt.Println(rsp, err)
+	
+}
+```

examples/email/parse/parseEmail/main.go

@@ -0,0 +1,17 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/email"
+)
+
+// Parse an RFC5322 address e.g "Joe Blogs <joe@example.com>"
+func main() {
+	emailService := email.NewEmailService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := emailService.Parse(&email.ParseRequest{
+		Address: "Joe Blogs <joe@example.com>",
+	})
+	fmt.Println(rsp, err)
+}

examples/email/validate/validateEmail/main.go

@@ -0,0 +1,17 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/email"
+)
+
+// Validate an email address format
+func main() {
+	emailService := email.NewEmailService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := emailService.Validate(&email.ValidateRequest{
+		Address: "joe@example.com",
+	})
+	fmt.Println(rsp, err)
+}

examples/emoji/README.md

@@ -1,6 +1,6 @@
 # Emoji
 
-An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/Emoji/api](https://m3o.com/Emoji/api).
+An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/emoji/api](https://m3o.com/emoji/api).
 
 Endpoints:
 
@@ -89,33 +89,3 @@ func PrintTextIncludingEmoji() {
 	
 }
 ```
-## Send
-
-Send an emoji to anyone via SMS. Messages are sent in the form '<message> Sent from <from>'
-
-
-[https://m3o.com/emoji/api#Send](https://m3o.com/emoji/api#Send)
-
-```go
-package example
-
-import(
-	"fmt"
-	"os"
-
-	"go.m3o.com/emoji"
-)
-
-// Send an emoji to anyone via SMS. Messages are sent in the form '<message> Sent from <from>'
-func SendAtextContainingAnEmojiToAnyoneViaSms() {
-	emojiService := emoji.NewEmojiService(os.Getenv("M3O_API_TOKEN"))
-	rsp, err := emojiService.Send(&emoji.SendRequest{
-		From: "Alice",
-Message: "let's grab a :beer:",
-To: "+44782669123",
-
-	})
-	fmt.Println(rsp, err)
-	
-}
-```

examples/emoji/send/sendATextContainingAnEmojiToAnyoneViaSms.go

@@ -1,19 +0,0 @@
-package example
-
-import (
-	"fmt"
-	"os"
-
-	"go.m3o.com/emoji"
-)
-
-// Send an emoji to anyone via SMS. Messages are sent in the form '<message> Sent from <from>'
-func SendAtextContainingAnEmojiToAnyoneViaSms() {
-	emojiService := emoji.NewEmojiService(os.Getenv("M3O_API_TOKEN"))
-	rsp, err := emojiService.Send(&emoji.SendRequest{
-		From:    "Alice",
-		Message: "let's grab a :beer:",
-		To:      "+44782669123",
-	})
-	fmt.Println(rsp, err)
-}

examples/emoji/send/sendATextContainingAnEmojiToAnyoneViaSms/main.go

@@ -1,19 +0,0 @@
-package main
-
-import (
-	"fmt"
-	"os"
-
-	"go.m3o.com/emoji"
-)
-
-// Send an emoji to anyone via SMS. Messages are sent in the form '<message> Sent from <from>'
-func main() {
-	emojiService := emoji.NewEmojiService(os.Getenv("M3O_API_TOKEN"))
-	rsp, err := emojiService.Send(&emoji.SendRequest{
-		From:    "Alice",
-		Message: "let's grab a :beer:",
-		To:      "+44782669123",
-	})
-	fmt.Println(rsp, err)
-}

examples/evchargers/README.md

@@ -1,6 +1,6 @@
 # Evchargers
 
-An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/Evchargers/api](https://m3o.com/Evchargers/api).
+An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/evchargers/api](https://m3o.com/evchargers/api).
 
 Endpoints:
 

examples/event/README.md

@@ -1,6 +1,6 @@
 # Event
 
-An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/Event/api](https://m3o.com/Event/api).
+An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/event/api](https://m3o.com/event/api).
 
 Endpoints:
 

examples/event/publish/publishAnEvent/main.go

@@ -12,9 +12,9 @@ func main() {
 	eventService := event.NewEventService(os.Getenv("M3O_API_TOKEN"))
 	rsp, err := eventService.Publish(&event.PublishRequest{
 		Message: map[string]interface{}{
-			"user": "john",
 			"id":   "1",
 			"type": "signup",
+			"user": "john",
 		},
 		Topic: "user",
 	})

examples/file/README.md

@@ -1,67 +1,9 @@
 # File
 
-An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/File/api](https://m3o.com/File/api).
+An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/file/api](https://m3o.com/file/api).
 
 Endpoints:
 
-## Read
-
-Read a file by path
-
-
-[https://m3o.com/file/api#Read](https://m3o.com/file/api#Read)
-
-```go
-package example
-
-import(
-	"fmt"
-	"os"
-
-	"go.m3o.com/file"
-)
-
-// Read a file by path
-func ReadFile() {
-	fileService := file.NewFileService(os.Getenv("M3O_API_TOKEN"))
-	rsp, err := fileService.Read(&file.ReadRequest{
-		Path: "/document/text-files/file.txt",
-Project: "examples",
-
-	})
-	fmt.Println(rsp, err)
-	
-}
-```
-## Delete
-
-Delete a file by project name/path
-
-
-[https://m3o.com/file/api#Delete](https://m3o.com/file/api#Delete)
-
-```go
-package example
-
-import(
-	"fmt"
-	"os"
-
-	"go.m3o.com/file"
-)
-
-// Delete a file by project name/path
-func DeleteFile() {
-	fileService := file.NewFileService(os.Getenv("M3O_API_TOKEN"))
-	rsp, err := fileService.Delete(&file.DeleteRequest{
-		Path: "/document/text-files/file.txt",
-Project: "examples",
-
-	})
-	fmt.Println(rsp, err)
-	
-}
-```
 ## Save
 
 Save a file
@@ -122,3 +64,61 @@ func ListFiles() {
 	
 }
 ```
+## Read
+
+Read a file by path
+
+
+[https://m3o.com/file/api#Read](https://m3o.com/file/api#Read)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/file"
+)
+
+// Read a file by path
+func ReadFile() {
+	fileService := file.NewFileService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := fileService.Read(&file.ReadRequest{
+		Path: "/document/text-files/file.txt",
+Project: "examples",
+
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## Delete
+
+Delete a file by project name/path
+
+
+[https://m3o.com/file/api#Delete](https://m3o.com/file/api#Delete)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/file"
+)
+
+// Delete a file by project name/path
+func DeleteFile() {
+	fileService := file.NewFileService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := fileService.Delete(&file.DeleteRequest{
+		Path: "/document/text-files/file.txt",
+Project: "examples",
+
+	})
+	fmt.Println(rsp, err)
+	
+}
+```

examples/forex/README.md

@@ -1,6 +1,6 @@
 # Forex
 
-An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/Forex/api](https://m3o.com/Forex/api).
+An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/forex/api](https://m3o.com/forex/api).
 
 Endpoints:
 

examples/function/README.md

@@ -1,9 +1,37 @@
 # Function
 
-An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/Function/api](https://m3o.com/Function/api).
+An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/function/api](https://m3o.com/function/api).
 
 Endpoints:
 
+## Proxy
+
+Return the backend url for proxying
+
+
+[https://m3o.com/function/api#Proxy](https://m3o.com/function/api#Proxy)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/function"
+)
+
+// Return the backend url for proxying
+func ProxyUrl() {
+	functionService := function.NewFunctionService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := functionService.Proxy(&function.ProxyRequest{
+		Id: "helloworld",
+
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
 ## Deploy
 
 Deploy a group of functions
@@ -25,19 +53,132 @@ import(
 func DeployAfunction() {
 	functionService := function.NewFunctionService(os.Getenv("M3O_API_TOKEN"))
 	rsp, err := functionService.Deploy(&function.DeployRequest{
-		Entrypoint: "helloworld",
+		Branch: "main",
+Entrypoint: "Helloworld",
 Name: "helloworld",
-Repo: "github.com/m3o/nodejs-function-example",
-Runtime: "nodejs14",
+Region: "europe-west1",
+Repo: "https://github.com/m3o/m3o",
+Runtime: "go116",
+Subfolder: "examples/go-function",
 
 	})
 	fmt.Println(rsp, err)
 	
+}
+```
+## Delete
+
+Delete a function by name
+
+
+[https://m3o.com/function/api#Delete](https://m3o.com/function/api#Delete)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/function"
+)
+
+// Delete a function by name
+func DeleteAfunction() {
+	functionService := function.NewFunctionService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := functionService.Delete(&function.DeleteRequest{
+		Name: "helloworld",
+
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## Reserve
+
+Reserve function names and resources beyond free quota
+
+
+[https://m3o.com/function/api#Reserve](https://m3o.com/function/api#Reserve)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/function"
+)
+
+// Reserve function names and resources beyond free quota
+func ReserveAfunction() {
+	functionService := function.NewFunctionService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := functionService.Reserve(&function.ReserveRequest{
+		Name: "helloworld",
+
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## Runtimes
+
+Return a list of supported runtimes
+
+
+[https://m3o.com/function/api#Runtimes](https://m3o.com/function/api#Runtimes)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/function"
+)
+
+// Return a list of supported runtimes
+func ListRuntimes() {
+	functionService := function.NewFunctionService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := functionService.Runtimes(&function.RuntimesRequest{
+		
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## Regions
+
+Return a list of supported regions
+
+
+[https://m3o.com/function/api#Regions](https://m3o.com/function/api#Regions)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/function"
+)
+
+// Return a list of supported regions
+func ListRegions() {
+	functionService := function.NewFunctionService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := functionService.Regions(&function.RegionsRequest{
+		
+	})
+	fmt.Println(rsp, err)
+	
 }
 ```
 ## Update
 
-Update a function
+Update a function. Downloads the source, builds and redeploys
 
 
 [https://m3o.com/function/api#Update](https://m3o.com/function/api#Update)
@@ -52,14 +193,11 @@ import(
 	"go.m3o.com/function"
 )
 
-// Update a function
+// Update a function. Downloads the source, builds and redeploys
 func UpdateAfunction() {
 	functionService := function.NewFunctionService(os.Getenv("M3O_API_TOKEN"))
 	rsp, err := functionService.Update(&function.UpdateRequest{
-		Entrypoint: "helloworld",
-Name: "helloworld",
-Repo: "github.com/m3o/nodejs-function-example",
-Runtime: "nodejs14",
+		Name: "helloworld",
 
 	})
 	fmt.Println(rsp, err)
@@ -89,6 +227,7 @@ func CallAfunction() {
 	rsp, err := functionService.Call(&function.CallRequest{
 		Name: "helloworld",
 Request: map[string]interface{}{
+	"name": "Alice",
 },
 
 	})
@@ -121,34 +260,6 @@ func ListFunctions() {
 	})
 	fmt.Println(rsp, err)
 	
-}
-```
-## Delete
-
-Delete a function by name
-
-
-[https://m3o.com/function/api#Delete](https://m3o.com/function/api#Delete)
-
-```go
-package example
-
-import(
-	"fmt"
-	"os"
-
-	"go.m3o.com/function"
-)
-
-// Delete a function by name
-func DeleteAfunction() {
-	functionService := function.NewFunctionService(os.Getenv("M3O_API_TOKEN"))
-	rsp, err := functionService.Delete(&function.DeleteRequest{
-		Name: "helloworld",
-
-	})
-	fmt.Println(rsp, err)
-	
 }
 ```
 ## Describe

examples/function/call/callAFunction/main.go

@@ -11,8 +11,10 @@ import (
 func main() {
 	functionService := function.NewFunctionService(os.Getenv("M3O_API_TOKEN"))
 	rsp, err := functionService.Call(&function.CallRequest{
-		Name:    "helloworld",
-		Request: map[string]interface{}{},
+		Name: "helloworld",
+		Request: map[string]interface{}{
+			"name": "Alice",
+		},
 	})
 	fmt.Println(rsp, err)
 }

examples/function/delete/deleteAFunction.go

@@ -11,8 +11,7 @@ import (
 func DeleteAfunction() {
 	functionService := function.NewFunctionService(os.Getenv("M3O_API_TOKEN"))
 	rsp, err := functionService.Delete(&function.DeleteRequest{
-		Name:    "my-first-func",
-		Project: "tests",
+		Name: "my-first-func",
 	})
 	fmt.Println(rsp, err)
 }

examples/function/deploy/deployAFunction.go

@@ -13,7 +13,6 @@ func DeployAfunction() {
 	rsp, err := functionService.Deploy(&function.DeployRequest{
 		Entrypoint: "helloworld",
 		Name:       "my-first-func",
-		Project:    "tests",
 		Repo:       "github.com/m3o/nodejs-function-example",
 		Runtime:    "nodejs14",
 	})

examples/function/deploy/deployAFunction/main.go

@@ -11,10 +11,13 @@ import (
 func main() {
 	functionService := function.NewFunctionService(os.Getenv("M3O_API_TOKEN"))
 	rsp, err := functionService.Deploy(&function.DeployRequest{
-		Entrypoint: "helloworld",
+		Branch:     "main",
+		Entrypoint: "Helloworld",
 		Name:       "helloworld",
-		Repo:       "github.com/m3o/nodejs-function-example",
-		Runtime:    "nodejs14",
+		Region:     "europe-west1",
+		Repo:       "https://github.com/m3o/m3o",
+		Runtime:    "go116",
+		Subfolder:  "examples/go-function",
 	})
 	fmt.Println(rsp, err)
 }

examples/function/describe/describeFunctionStatus.go

@@ -11,8 +11,7 @@ import (
 func DescribeFunctionStatus() {
 	functionService := function.NewFunctionService(os.Getenv("M3O_API_TOKEN"))
 	rsp, err := functionService.Describe(&function.DescribeRequest{
-		Name:    "my-first-func",
-		Project: "tests",
+		Name: "my-first-func",
 	})
 	fmt.Println(rsp, err)
 }

examples/function/proxy/proxyUrl/main.go

@@ -0,0 +1,17 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/function"
+)
+
+// Return the backend url for proxying
+func main() {
+	functionService := function.NewFunctionService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := functionService.Proxy(&function.ProxyRequest{
+		Id: "helloworld",
+	})
+	fmt.Println(rsp, err)
+}

examples/function/regions/listRegions/main.go

@@ -0,0 +1,15 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/function"
+)
+
+// Return a list of supported regions
+func main() {
+	functionService := function.NewFunctionService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := functionService.Regions(&function.RegionsRequest{})
+	fmt.Println(rsp, err)
+}

examples/function/reserve/reserveAFunction/main.go

@@ -0,0 +1,17 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/function"
+)
+
+// Reserve function names and resources beyond free quota
+func main() {
+	functionService := function.NewFunctionService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := functionService.Reserve(&function.ReserveRequest{
+		Name: "helloworld",
+	})
+	fmt.Println(rsp, err)
+}

examples/function/runtimes/listRuntimes/main.go

@@ -0,0 +1,15 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/function"
+)
+
+// Return a list of supported runtimes
+func main() {
+	functionService := function.NewFunctionService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := functionService.Runtimes(&function.RuntimesRequest{})
+	fmt.Println(rsp, err)
+}

examples/function/update/updateAFunction/main.go

@@ -7,14 +7,11 @@ import (
 	"go.m3o.com/function"
 )
 
-// Update a function
+// Update a function. Downloads the source, builds and redeploys
 func main() {
 	functionService := function.NewFunctionService(os.Getenv("M3O_API_TOKEN"))
 	rsp, err := functionService.Update(&function.UpdateRequest{
-		Entrypoint: "helloworld",
-		Name:       "helloworld",
-		Repo:       "github.com/m3o/nodejs-function-example",
-		Runtime:    "nodejs14",
+		Name: "helloworld",
 	})
 	fmt.Println(rsp, err)
 }

examples/geocoding/README.md

@@ -1,6 +1,6 @@
 # Geocoding
 
-An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/Geocoding/api](https://m3o.com/Geocoding/api).
+An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/geocoding/api](https://m3o.com/geocoding/api).
 
 Endpoints:
 

examples/gifs/README.md

@@ -1,6 +1,6 @@
 # Gifs
 
-An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/Gifs/api](https://m3o.com/Gifs/api).
+An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/gifs/api](https://m3o.com/gifs/api).
 
 Endpoints:
 

examples/google/README.md

@@ -1,6 +1,6 @@
 # Google
 
-An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/Google/api](https://m3o.com/Google/api).
+An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/google/api](https://m3o.com/google/api).
 
 Endpoints:
 

examples/helloworld/README.md

@@ -1,6 +1,6 @@
 # Helloworld
 
-An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/Helloworld/api](https://m3o.com/Helloworld/api).
+An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/helloworld/api](https://m3o.com/helloworld/api).
 
 Endpoints:
 
@@ -22,7 +22,7 @@ import(
 )
 
 // Call returns a personalised "Hello $name" response
-func CallTheHelloworldService() {
+func CallHelloworld() {
 	helloworldService := helloworld.NewHelloworldService(os.Getenv("M3O_API_TOKEN"))
 	rsp, err := helloworldService.Call(&helloworld.CallRequest{
 		Name: "John",
@@ -50,7 +50,7 @@ import(
 )
 
 // Stream returns a stream of "Hello $name" responses
-func StreamsResponsesFromTheServerUsingWebsockets() {
+func StreamHelloworld() {
 	helloworldService := helloworld.NewHelloworldService(os.Getenv("M3O_API_TOKEN"))
 	
 	stream, err := helloworldService.Stream(&helloworld.StreamRequest{

examples/helloworld/call/callHelloworld/main.go

@@ -0,0 +1,17 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/helloworld"
+)
+
+// Call returns a personalised "Hello $name" response
+func main() {
+	helloworldService := helloworld.NewHelloworldService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := helloworldService.Call(&helloworld.CallRequest{
+		Name: "John",
+	})
+	fmt.Println(rsp, err)
+}

examples/helloworld/stream/streamHelloworld/main.go

@@ -0,0 +1,31 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/helloworld"
+)
+
+// Stream returns a stream of "Hello $name" responses
+func main() {
+	helloworldService := helloworld.NewHelloworldService(os.Getenv("M3O_API_TOKEN"))
+	stream, err := helloworldService.Stream(&helloworld.StreamRequest{
+		Messages: 10,
+		Name:     "John",
+	})
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+
+	for {
+		rsp, err := stream.Recv()
+		if err != nil {
+			fmt.Println(err)
+			return
+		}
+
+		fmt.Println(rsp)
+	}
+}

examples/holidays/README.md

@@ -1,36 +1,9 @@
 # Holidays
 
-An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/Holidays/api](https://m3o.com/Holidays/api).
+An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/holidays/api](https://m3o.com/holidays/api).
 
 Endpoints:
 
-## Countries
-
-Get the list of countries that are supported by this API
-
-
-[https://m3o.com/holidays/api#Countries](https://m3o.com/holidays/api#Countries)
-
-```go
-package example
-
-import(
-	"fmt"
-	"os"
-
-	"go.m3o.com/holidays"
-)
-
-// Get the list of countries that are supported by this API
-func ListCountries() {
-	holidaysService := holidays.NewHolidaysService(os.Getenv("M3O_API_TOKEN"))
-	rsp, err := holidaysService.Countries(&holidays.CountriesRequest{
-		
-	})
-	fmt.Println(rsp, err)
-	
-}
-```
 ## List
 
 List the holiday dates for a given country and year
@@ -59,3 +32,30 @@ func GetHolidays() {
 	
 }
 ```
+## Countries
+
+Get the list of countries that are supported by this API
+
+
+[https://m3o.com/holidays/api#Countries](https://m3o.com/holidays/api#Countries)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/holidays"
+)
+
+// Get the list of countries that are supported by this API
+func ListCountries() {
+	holidaysService := holidays.NewHolidaysService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := holidaysService.Countries(&holidays.CountriesRequest{
+		
+	})
+	fmt.Println(rsp, err)
+	
+}
+```

examples/id/README.md

@@ -1,36 +1,9 @@
 # Id
 
-An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/Id/api](https://m3o.com/Id/api).
+An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/id/api](https://m3o.com/id/api).
 
 Endpoints:
 
-## Types
-
-List the types of IDs available. No query params needed.
-
-
-[https://m3o.com/id/api#Types](https://m3o.com/id/api#Types)
-
-```go
-package example
-
-import(
-	"fmt"
-	"os"
-
-	"go.m3o.com/id"
-)
-
-// List the types of IDs available. No query params needed.
-func ListTheTypesOfIdsAvailable() {
-	idService := id.NewIdService(os.Getenv("M3O_API_TOKEN"))
-	rsp, err := idService.Types(&id.TypesRequest{
-		
-	})
-	fmt.Println(rsp, err)
-	
-}
-```
 ## Generate
 
 Generate a unique ID. Defaults to uuid.
@@ -143,3 +116,30 @@ func GenerateAbigflakeId() {
 	
 }
 ```
+## Types
+
+List the types of IDs available. No query params needed.
+
+
+[https://m3o.com/id/api#Types](https://m3o.com/id/api#Types)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/id"
+)
+
+// List the types of IDs available. No query params needed.
+func ListTheTypesOfIdsAvailable() {
+	idService := id.NewIdService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := idService.Types(&id.TypesRequest{
+		
+	})
+	fmt.Println(rsp, err)
+	
+}
+```

examples/image/README.md

@@ -1,37 +1,9 @@
 # Image
 
-An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/Image/api](https://m3o.com/Image/api).
+An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/image/api](https://m3o.com/image/api).
 
 Endpoints:
 
-## Delete
-
-Delete an image previously uploaded.
-
-
-[https://m3o.com/image/api#Delete](https://m3o.com/image/api#Delete)
-
-```go
-package example
-
-import(
-	"fmt"
-	"os"
-
-	"go.m3o.com/image"
-)
-
-// Delete an image previously uploaded.
-func DeleteAnUploadedImage() {
-	imageService := image.NewImageService(os.Getenv("M3O_API_TOKEN"))
-	rsp, err := imageService.Delete(&image.DeleteRequest{
-		Url: "https://cdn.m3ocontent.com/micro/images/micro/41e23b39-48dd-42b6-9738-79a313414bb8/cat.png",
-
-	})
-	fmt.Println(rsp, err)
-	
-}
-```
 ## Resize
 
 Resize an image on the fly without storing it (by sending and receiving a base64 encoded image), or resize and upload depending on parameters.
@@ -256,3 +228,31 @@ Url: "somewebsite.com/cat.png",
 	
 }
 ```
+## Delete
+
+Delete an image previously uploaded.
+
+
+[https://m3o.com/image/api#Delete](https://m3o.com/image/api#Delete)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/image"
+)
+
+// Delete an image previously uploaded.
+func DeleteAnUploadedImage() {
+	imageService := image.NewImageService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := imageService.Delete(&image.DeleteRequest{
+		Url: "https://cdn.m3ocontent.com/micro/images/micro/41e23b39-48dd-42b6-9738-79a313414bb8/cat.png",
+
+	})
+	fmt.Println(rsp, err)
+	
+}
+```

examples/ip/README.md

@@ -1,6 +1,6 @@
 # Ip
 
-An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/Ip/api](https://m3o.com/Ip/api).
+An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/ip/api](https://m3o.com/ip/api).
 
 Endpoints:
 

examples/joke/README.md

@@ -1,6 +1,6 @@
 # Joke
 
-An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/Joke/api](https://m3o.com/Joke/api).
+An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/joke/api](https://m3o.com/joke/api).
 
 Endpoints:
 

examples/lists/README.md

@@ -0,0 +1,187 @@
+# Lists
+
+An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/lists/api](https://m3o.com/lists/api).
+
+Endpoints:
+
+## Create
+
+Create a new list
+
+
+[https://m3o.com/lists/api#Create](https://m3o.com/lists/api#Create)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/lists"
+)
+
+// Create a new list
+func CreateAlist() {
+	listsService := lists.NewListsService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := listsService.Create(&lists.CreateRequest{
+		
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## Read
+
+Read a list
+
+
+[https://m3o.com/lists/api#Read](https://m3o.com/lists/api#Read)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/lists"
+)
+
+// Read a list
+func ReadAlist() {
+	listsService := lists.NewListsService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := listsService.Read(&lists.ReadRequest{
+		Id: "63c0cdf8-2121-11ec-a881-0242e36f037a",
+
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## List
+
+List all the lists
+
+
+[https://m3o.com/lists/api#List](https://m3o.com/lists/api#List)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/lists"
+)
+
+// List all the lists
+func ListAllLists() {
+	listsService := lists.NewListsService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := listsService.List(&lists.ListRequest{
+		
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## Update
+
+Update a list
+
+
+[https://m3o.com/lists/api#Update](https://m3o.com/lists/api#Update)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/lists"
+)
+
+// Update a list
+func UpdateAlist() {
+	listsService := lists.NewListsService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := listsService.Update(&lists.UpdateRequest{
+		List: &lists.List{
+		Id: "63c0cdf8-2121-11ec-a881-0242e36f037a",
+			},
+
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## Delete
+
+Delete a list
+
+
+[https://m3o.com/lists/api#Delete](https://m3o.com/lists/api#Delete)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/lists"
+)
+
+// Delete a list
+func DeleteAlist() {
+	listsService := lists.NewListsService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := listsService.Delete(&lists.DeleteRequest{
+		Id: "63c0cdf8-2121-11ec-a881-0242e36f037a",
+
+	})
+	fmt.Println(rsp, err)
+	
+}
+```
+## Events
+
+Subscribe to lists events
+
+
+[https://m3o.com/lists/api#Events](https://m3o.com/lists/api#Events)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/lists"
+)
+
+// Subscribe to lists events
+func SubscribeToEvents() {
+	listsService := lists.NewListsService(os.Getenv("M3O_API_TOKEN"))
+	
+	stream, err := listsService.Events(&lists.EventsRequest{
+		Id: "63c0cdf8-2121-11ec-a881-0242e36f037a",
+
+	})
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+
+	for {
+			rsp, err := stream.Recv()
+			if err != nil {
+					fmt.Println(err)
+					return
+			}
+
+			fmt.Println(rsp)
+	}
+}
+```

examples/lists/create/createAList/main.go

@@ -0,0 +1,15 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/lists"
+)
+
+// Create a new list
+func main() {
+	listsService := lists.NewListsService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := listsService.Create(&lists.CreateRequest{})
+	fmt.Println(rsp, err)
+}

examples/lists/delete/deleteAList/main.go

@@ -0,0 +1,17 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/lists"
+)
+
+// Delete a list
+func main() {
+	listsService := lists.NewListsService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := listsService.Delete(&lists.DeleteRequest{
+		Id: "63c0cdf8-2121-11ec-a881-0242e36f037a",
+	})
+	fmt.Println(rsp, err)
+}

examples/lists/events/subscribeToEvents/main.go

@@ -0,0 +1,30 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/lists"
+)
+
+// Subscribe to lists events
+func main() {
+	listsService := lists.NewListsService(os.Getenv("M3O_API_TOKEN"))
+	stream, err := listsService.Events(&lists.EventsRequest{
+		Id: "63c0cdf8-2121-11ec-a881-0242e36f037a",
+	})
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+
+	for {
+		rsp, err := stream.Recv()
+		if err != nil {
+			fmt.Println(err)
+			return
+		}
+
+		fmt.Println(rsp)
+	}
+}

examples/lists/list/listAllLists/main.go

@@ -0,0 +1,15 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/lists"
+)
+
+// List all the lists
+func main() {
+	listsService := lists.NewListsService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := listsService.List(&lists.ListRequest{})
+	fmt.Println(rsp, err)
+}

examples/lists/read/readAList/main.go

@@ -0,0 +1,17 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/lists"
+)
+
+// Read a list
+func main() {
+	listsService := lists.NewListsService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := listsService.Read(&lists.ReadRequest{
+		Id: "63c0cdf8-2121-11ec-a881-0242e36f037a",
+	})
+	fmt.Println(rsp, err)
+}

examples/lists/update/updateAList/main.go

@@ -0,0 +1,19 @@
+package main
+
+import (
+	"fmt"
+	"os"
+
+	"go.m3o.com/lists"
+)
+
+// Update a list
+func main() {
+	listsService := lists.NewListsService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := listsService.Update(&lists.UpdateRequest{
+		List: &lists.List{
+			Id: "63c0cdf8-2121-11ec-a881-0242e36f037a",
+		},
+	})
+	fmt.Println(rsp, err)
+}

examples/location/README.md

@@ -1,45 +1,9 @@
 # Location
 
-An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/Location/api](https://m3o.com/Location/api).
+An [m3o.com](https://m3o.com) API. For example usage see [m3o.com/location/api](https://m3o.com/location/api).
 
 Endpoints:
 
-## Save
-
-Save an entity's current position
-
-
-[https://m3o.com/location/api#Save](https://m3o.com/location/api#Save)
-
-```go
-package example
-
-import(
-	"fmt"
-	"os"
-
-	"go.m3o.com/location"
-)
-
-// Save an entity's current position
-func SaveAnEntity() {
-	locationService := location.NewLocationService(os.Getenv("M3O_API_TOKEN"))
-	rsp, err := locationService.Save(&location.SaveRequest{
-		Entity: &location.Entity{
-	Id: "1",
-	Location: &location.Point{
-		Latitude: 51.511061,
-		Longitude: -0.120022,
-		Timestamp: 1622802761,
-},
-	Type: "bike",
-},
-
-	})
-	fmt.Println(rsp, err)
-	
-}
-```
 ## Read
 
 Read an entity by its ID
@@ -102,3 +66,39 @@ Type: "bike",
 	
 }
 ```
+## Save
+
+Save an entity's current position
+
+
+[https://m3o.com/location/api#Save](https://m3o.com/location/api#Save)
+
+```go
+package example
+
+import(
+	"fmt"
+	"os"
+
+	"go.m3o.com/location"
+)
+
+// Save an entity's current position
+func SaveAnEntity() {
+	locationService := location.NewLocationService(os.Getenv("M3O_API_TOKEN"))
+	rsp, err := locationService.Save(&location.SaveRequest{
+		Entity: &location.Entity{
+	Id: "1",
+	Location: &location.Point{
+		Latitude: 51.511061,
+		Longitude: -0.120022,
+		Timestamp: 1622802761,
+},
+	Type: "bike",
+},
+
+	})
+	fmt.Println(rsp, err)
+	
+}
+```