From e0d4e34e05a1eb6c637fdc539be0f567ffdbedc0 Mon Sep 17 00:00:00 2001 From: asim Date: Fri, 29 Oct 2021 12:42:57 +0000 Subject: [PATCH] Commit from GitHub Actions (Generate Clients & Examples) --- examples/db/create/go/createARecord.go | 2 +- .../notes/subscribe/curl/subscribeToEvents.sh | 6 ++++++ .../notes/subscribe/go/subscribeToEvents.go | 17 +++++++++++++++++ .../notes/subscribe/node/subscribeToEvents.js | 12 ++++++++++++ examples/stream/publish/go/publishAMessage.go | 2 +- 5 files changed, 37 insertions(+), 2 deletions(-) create mode 100755 examples/notes/subscribe/curl/subscribeToEvents.sh create mode 100755 examples/notes/subscribe/go/subscribeToEvents.go create mode 100755 examples/notes/subscribe/node/subscribeToEvents.js diff --git a/examples/db/create/go/createARecord.go b/examples/db/create/go/createARecord.go index 003184c..283dd5d 100755 --- a/examples/db/create/go/createARecord.go +++ b/examples/db/create/go/createARecord.go @@ -12,10 +12,10 @@ func CreateArecord() { dbService := db.NewDbService(os.Getenv("MICRO_API_TOKEN")) rsp, err := dbService.Create(&db.CreateRequest{ Record: map[string]interface{}{ + "id": "1", "name": "Jane", "age": 42, "isActive": true, - "id": "1", }, Table: "users", }) diff --git a/examples/notes/subscribe/curl/subscribeToEvents.sh b/examples/notes/subscribe/curl/subscribeToEvents.sh new file mode 100755 index 0000000..c199047 --- /dev/null +++ b/examples/notes/subscribe/curl/subscribeToEvents.sh @@ -0,0 +1,6 @@ +curl "https://api.m3o.com/v1/notes/Subscribe" \ +-H "Content-Type: application/json" \ +-H "Authorization: Bearer $MICRO_API_TOKEN" \ +-d '{ + "id": "63c0cdf8-2121-11ec-a881-0242e36f037a" +}' \ No newline at end of file diff --git a/examples/notes/subscribe/go/subscribeToEvents.go b/examples/notes/subscribe/go/subscribeToEvents.go new file mode 100755 index 0000000..c3d225f --- /dev/null +++ b/examples/notes/subscribe/go/subscribeToEvents.go @@ -0,0 +1,17 @@ +package example + +import ( + "fmt" + "os" + + "github.com/micro/services/clients/go/notes" +) + +// Specify the note to events +func SubscribeToEvents() { + notesService := notes.NewNotesService(os.Getenv("MICRO_API_TOKEN")) + rsp, err := notesService.Subscribe(¬es.SubscribeRequest{ + Id: "63c0cdf8-2121-11ec-a881-0242e36f037a", + }) + fmt.Println(rsp, err) +} diff --git a/examples/notes/subscribe/node/subscribeToEvents.js b/examples/notes/subscribe/node/subscribeToEvents.js new file mode 100755 index 0000000..108579e --- /dev/null +++ b/examples/notes/subscribe/node/subscribeToEvents.js @@ -0,0 +1,12 @@ +const { NotesService } = require("m3o/notes"); + +// Specify the note to events +async function subscribeToEvents() { + let notesService = new NotesService(process.env.MICRO_API_TOKEN); + let rsp = await notesService.subscribe({ + id: "63c0cdf8-2121-11ec-a881-0242e36f037a", + }); + console.log(rsp); +} + +subscribeToEvents(); diff --git a/examples/stream/publish/go/publishAMessage.go b/examples/stream/publish/go/publishAMessage.go index eee4024..7a0d501 100755 --- a/examples/stream/publish/go/publishAMessage.go +++ b/examples/stream/publish/go/publishAMessage.go @@ -12,9 +12,9 @@ func PublishAmessage() { streamService := stream.NewStreamService(os.Getenv("MICRO_API_TOKEN")) rsp, err := streamService.Publish(&stream.PublishRequest{ Message: map[string]interface{}{ + "user": "john", "id": "1", "type": "signup", - "user": "john", }, Topic: "events", })