From 71e26f92c3337fa72de3fa2ecf4d0b9c79ba6f14 Mon Sep 17 00:00:00 2001 From: asim Date: Wed, 3 Nov 2021 15:28:08 +0000 Subject: [PATCH] Commit from GitHub Actions (Generate Clients & Examples) --- clients/ts/package.json | 2 +- examples/mq/publish/go/publishAMessage.go | 2 +- .../stream/sendMessage/curl/sendMessage.sh | 7 +++++++ examples/stream/sendMessage/go/sendMessage.go | 18 ++++++++++++++++++ .../stream/sendMessage/node/sendMessage.js | 13 +++++++++++++ 5 files changed, 40 insertions(+), 2 deletions(-) create mode 100755 examples/stream/sendMessage/curl/sendMessage.sh create mode 100755 examples/stream/sendMessage/go/sendMessage.go create mode 100755 examples/stream/sendMessage/node/sendMessage.js diff --git a/clients/ts/package.json b/clients/ts/package.json index 08ee73e..fbd1c40 100644 --- a/clients/ts/package.json +++ b/clients/ts/package.json @@ -78,5 +78,5 @@ "prepare": "npm run build" }, "types": "index.d.ts", - "version": "1.0.618" + "version": "1.0.619" } \ No newline at end of file diff --git a/examples/mq/publish/go/publishAMessage.go b/examples/mq/publish/go/publishAMessage.go index 159c090..6cbfe0d 100755 --- a/examples/mq/publish/go/publishAMessage.go +++ b/examples/mq/publish/go/publishAMessage.go @@ -12,9 +12,9 @@ func PublishAmessage() { mqService := mq.NewMqService(os.Getenv("MICRO_API_TOKEN")) rsp, err := mqService.Publish(&mq.PublishRequest{ Message: map[string]interface{}{ - "id": "1", "type": "signup", "user": "john", + "id": "1", }, Topic: "events", }) diff --git a/examples/stream/sendMessage/curl/sendMessage.sh b/examples/stream/sendMessage/curl/sendMessage.sh new file mode 100755 index 0000000..ec4dc58 --- /dev/null +++ b/examples/stream/sendMessage/curl/sendMessage.sh @@ -0,0 +1,7 @@ +curl "https://api.m3o.com/v1/stream/SendMessage" \ +-H "Content-Type: application/json" \ +-H "Authorization: Bearer $MICRO_API_TOKEN" \ +-d '{ + "channel": "general", + "text": "Hey checkout this tweet https://twitter.com/m3oservices/status/1455291054295498752" +}' \ No newline at end of file diff --git a/examples/stream/sendMessage/go/sendMessage.go b/examples/stream/sendMessage/go/sendMessage.go new file mode 100755 index 0000000..d11e011 --- /dev/null +++ b/examples/stream/sendMessage/go/sendMessage.go @@ -0,0 +1,18 @@ +package example + +import ( + "fmt" + "os" + + "github.com/micro/services/clients/go/stream" +) + +// SendMessage a message to the stream. +func SendMessage() { + streamService := stream.NewStreamService(os.Getenv("MICRO_API_TOKEN")) + rsp, err := streamService.SendMessage(&stream.SendMessageRequest{ + Channel: "general", + Text: "Hey checkout this tweet https://twitter.com/m3oservices/status/1455291054295498752", + }) + fmt.Println(rsp, err) +} diff --git a/examples/stream/sendMessage/node/sendMessage.js b/examples/stream/sendMessage/node/sendMessage.js new file mode 100755 index 0000000..bf191eb --- /dev/null +++ b/examples/stream/sendMessage/node/sendMessage.js @@ -0,0 +1,13 @@ +const { StreamService } = require("m3o/stream"); + +// SendMessage a message to the stream. +async function sendMessage() { + let streamService = new StreamService(process.env.MICRO_API_TOKEN); + let rsp = await streamService.sendMessage({ + channel: "general", + text: "Hey checkout this tweet https://twitter.com/m3oservices/status/1455291054295498752", + }); + console.log(rsp); +} + +sendMessage();