How to use sendMessage method of api Package

1package main2import (3	"encoding/json"4	"fmt"5	"io/ioutil"6	"log"7	"os"8	"strconv"9	"strings"10	"time"11	"github.com/asticode/go-astikit"12	"github.com/asticode/go-astilectron"13	"github.com/gojektech/heimdall/httpclient"14)15//ATHAN16//Athan grabs main data header from Json17type Athan struct {18	Data YtData `json:"data"`19}20//YtData grabs secondary header under "Athan"21type YtData struct {22	Timings YtTime `json:"timings"`23}24//YtTime Gets 3rd Header from Json file, which is where the athan times are located25type YtTime struct {26	F string `json:"Fajr"`27	D string `json:"Dhuhr"`28	A string `json:"Asr"`29	M string `json:"Maghrib"`30	I string `json:"Isha"`31}32//Config Get Config settings from config.json file33type Config struct {34	Location struct {35		City     string `json:"City"`36		Country  string `json:"Country"`37		State    string `json:"State"`38		TimeZone string `json:"TimeZone"`39		MP3      string `json:"MP3"`40	}41}42//Split API43const (44	MainAPI    string = "http://api.aladhan.com/v1/timingsByCity?city="45	CountryAPI string = "&country="46	StateAPI   string = "&state="47	MethodAPI  string = "&method="48)49var config Config50//END ATHAN51var w *astilectron.Window52func SaveConfigs(city, state, TimeZone, mp3 string) {53	// {54	// 	"location":{55	// 	   "City":"Anaheim",56	// 	   "State":"CA",57	// 	   "Country":"US",58	// 	   "TimeZone":"America/Los_Angeles"59	// 	}60	//  }61	Format := "{ \"location\":{ \"City\":" + "\"" + city + "\"," + "\"State\":" + "\"" + state + "\"," + "\"Country\":\"US\", \"TimeZone\":" + "\"" + TimeZone + "\"," + "\"MP3\": " + "\"" + mp3 + "\" } }"62	//Format := "{\n\t\"location\":{\n\t\t\"City\":" + "\"" + city + "\"" + ",\n\t\t\"State\":" + "\"" + state + "\"" + ",\n\t\t\"Country\":\"US\",\n\t\t\"TimeZone\":" + "\"" + TimeZone + "\"\n\t}\n}"63	fs, err := os.Create("config.json")64	if err != nil {65		fmt.Println(err)66	}67	fs.Write([]byte(Format))68	defer fs.Close()69}70func main() {71	//Athan72	var err error73	//Connect to Json file for settings and paramaters74	config, err = LoadConfig("config.json")75	if err != nil {76		log.Fatal("Error importing config.json file", err)77	}78	Y := ACal()79	go func() {80		for range time.Tick(time.Second * 35) {81			//Grab Updated Config Files82			config, err := LoadConfig("config.json")83			if err != nil {84				log.Fatal("Error importing config.json file", err)85			}86			//Get Local time test87			t := time.Now()88			location, err := time.LoadLocation(config.Location.TimeZone)89			if err != nil {90				log.Fatal("Unable to get Local Location", err)91			}92			CurrentTime := fmt.Sprint(t.In(location).Format("15:04"))93			//Duhur94			pd, _ := time.Parse("15:04", Y.Data.Timings.D)95			pd = pd.Add(time.Minute * time.Duration(-30))96			pds := fmt.Sprintf(pd.Format("15:04"))97			//Asr98			pa, _ := time.Parse("15:04", Y.Data.Timings.A)99			pa = pa.Add(time.Minute * time.Duration(-30))100			pas := fmt.Sprintf(pa.Format("15:04"))101			//Magrib102			pm, _ := time.Parse("15:04", Y.Data.Timings.M)103			pm = pm.Add(time.Minute * time.Duration(-30))104			pam := fmt.Sprintf(pm.Format("15:04"))105			//Isha106			pi, _ := time.Parse("15:04", Y.Data.Timings.I)107			pi = pi.Add(time.Minute * time.Duration(-30))108			pai := fmt.Sprintf(pi.Format("15:04"))109			//Checks if its time for Fajir110			if Y.Data.Timings.F == CurrentTime {111				//fmt.Println("Time for Fajir")112				w.SendMessage("Nowfajir:"+Y.Data.Timings.F, func(m *astilectron.EventMessage) {})113				w.Show()114			}115			if pds == CurrentTime {116				w.SendMessage("Upduhur:"+Y.Data.Timings.F, func(m *astilectron.EventMessage) {})117				w.Show()118			}119			//Checks if its time for Duhur120			if Y.Data.Timings.D == CurrentTime {121				//fmt.Println("Time for Duhur")122				w.SendMessage("Nowduhur:", func(m *astilectron.EventMessage) {})123				w.Show()124			}125			if pas == CurrentTime {126				w.SendMessage("Upasr:"+Y.Data.Timings.F, func(m *astilectron.EventMessage) {})127				w.Show()128			}129			//Checks if its time for Asr130			if Y.Data.Timings.A == CurrentTime {131				//fmt.Println("Time for Asr")132				w.SendMessage("Nowasr:", func(m *astilectron.EventMessage) {})133				w.Show()134			}135			if pam == CurrentTime {136				w.SendMessage("Upmagrib:"+Y.Data.Timings.F, func(m *astilectron.EventMessage) {})137				w.Show()138			}139			//Checks if its time for Magrib140			if Y.Data.Timings.M == CurrentTime {141				w.SendMessage("Nowmagrib:", func(m *astilectron.EventMessage) {})142				w.Show()143			}144			if pai == CurrentTime {145				w.SendMessage("Upisha:"+Y.Data.Timings.F, func(m *astilectron.EventMessage) {})146				w.Show()147			}148			//Checks if time for Isha149			if Y.Data.Timings.I == CurrentTime {150				//fmt.Println("Time for Isha")151				w.SendMessage("Nowisha:", func(m *astilectron.EventMessage) {})152				w.Show()153				Y = ACal() //Recall Json Data}154			}155		} // End Loop156	}()157	//End Athan158	// Set logger159	l := log.New(log.Writer(), log.Prefix(), log.Flags())160	// Create astilectron161	a, err := astilectron.New(l, astilectron.Options{162		AppName:            "Athan",163		BaseDirectoryPath:  "Athan",164		AppIconDefaultPath: "D:\\Experiments\\Toast\\icon.png",165	})166	if err != nil {167		l.Fatal(fmt.Errorf("main: creating astilectron failed: %w", err))168	}169	defer a.Close()170	// Handle signals171	a.HandleSignals()172	// Start173	if err = a.Start(); err != nil {174		l.Fatal(fmt.Errorf("main: starting astilectron failed: %w", err))175	}176	//Create the main menu177	if w, err = a.NewWindow("athan/index.html", &astilectron.WindowOptions{178		Center:    astikit.BoolPtr(true),179		Height:    astikit.IntPtr(480), //480180		Width:     astikit.IntPtr(350),181		MaxHeight: astikit.IntPtr(480),182		MaxWidth:  astikit.IntPtr(350),183		MinHeight: astikit.IntPtr(480),184		MinWidth:  astikit.IntPtr(350),185	}); err != nil {186		l.Fatal(fmt.Errorf("main: new window failed: %w", err))187	}188	//Create main menu189	if err = w.Create(); err != nil {190		l.Fatal(fmt.Errorf("main: creating window failed: %w", err))191	}192	//Fajir193	f := strings.Split(Y.Data.Timings.F, ":")194	fc, _ := strconv.Atoi(f[0])195	fv := fc - 12196	fc2 := strconv.Itoa(fv)197	var fl string198	if fc >= 13 {199		fl = fc2200	} else {201		fl = Y.Data.Timings.F202	}203	//Duhur204	d := strings.Split(Y.Data.Timings.D, ":")205	dc, _ := strconv.Atoi(d[0])206	dv := dc - 12207	dc2 := strconv.Itoa(dv)208	var dl string209	if dc >= 13 {210		dl = dc2211	} else {212		dl = Y.Data.Timings.D213	}214	//Asr215	a1 := strings.Split(Y.Data.Timings.A, ":")216	ac, _ := strconv.Atoi(a1[0])217	av := ac - 12218	ac2 := strconv.Itoa(av)219	//Magrib220	m1 := strings.Split(Y.Data.Timings.M, ":")221	mc, _ := strconv.Atoi(m1[0])222	mv := mc - 12223	mc2 := strconv.Itoa(mv)224	//Magrib225	i1 := strings.Split(Y.Data.Timings.I, ":")226	ic, _ := strconv.Atoi(i1[0])227	iv := ic - 12228	ic2 := strconv.Itoa(iv)229	//Send the prayer times to main page230	w.SendMessage("fajir:"+fl, func(m *astilectron.EventMessage) {})231	w.SendMessage("duhur:"+dl, func(m *astilectron.EventMessage) {})232	w.SendMessage("asr:"+ac2+":"+a1[0], func(m *astilectron.EventMessage) {})233	w.SendMessage("magrib:"+mc2+":"+m1[0], func(m *astilectron.EventMessage) {})234	w.SendMessage("isha:"+ic2+":"+i1[0], func(m *astilectron.EventMessage) {})235	//Refresh the prayer times every 5 minutes236	go func() {237		for range time.Tick(time.Minute * 5) {238			w.SendMessage("fajir:"+fl, func(m *astilectron.EventMessage) {})239			w.SendMessage("duhur:"+dl, func(m *astilectron.EventMessage) {})240			w.SendMessage("asr:"+ac2+":"+a1[0], func(m *astilectron.EventMessage) {})241			w.SendMessage("magrib:"+mc2+":"+m1[0], func(m *astilectron.EventMessage) {})242			w.SendMessage("isha:"+ic2+":"+i1[0], func(m *astilectron.EventMessage) {})243		}244	}()245	//Create a tray icon the the athan app246	var t = a.NewTray(&astilectron.TrayOptions{247		Image:   astikit.StrPtr("D:\\Experiments\\Toast\\icon.png"),248		Tooltip: astikit.StrPtr("Windows Athan"),249	})250	//Create tray251	t.Create()252	var i int = 1253	//Click on the the tray254	t.On(astilectron.EventNameTrayEventClicked, func(e astilectron.Event) (deleteListener bool) {255		if i%2 == 0 {256			w.Hide()257			i = i + 1258		} else {259			w.Show()260			i = i + 1261		}262		fmt.Println("TRAY HAS BEEN CLICKED")263		return264	})265	//Dont allow resize266	w.On(astilectron.EventNameWindowEventMinimize, func(e astilectron.Event) (deleteListener bool) {267		w.Hide()268		return269	})270	w.OnMessage(func(m *astilectron.EventMessage) interface{} {271		// Unmarshal272		var s string273		m.Unmarshal(&s)274		var sr *astilectron.Window275		// Process message276		if s == "edit" {277			config, err = LoadConfig("config.json")278			if err != nil {279				log.Fatal("Error importing config.json file", err)280			}281			//Edit the athan location282			if sr, err = a.NewWindow("athan/edit.html", &astilectron.WindowOptions{283				Center:    astikit.BoolPtr(true),284				Height:    astikit.IntPtr(500),285				Width:     astikit.IntPtr(400),286				MaxHeight: astikit.IntPtr(500),287				MaxWidth:  astikit.IntPtr(400),288				MinHeight: astikit.IntPtr(500),289				MinWidth:  astikit.IntPtr(400),290			}); err != nil {291				l.Fatal(fmt.Errorf("main: new window failed: %w", err))292			}293			// Create windows294			if err = sr.Create(); err != nil {295				l.Fatal(fmt.Errorf("main: creating window failed: %w", err))296			}297			//Send the prefilled data298			sr.SendMessage("SetDataState:"+config.Location.State, func(m *astilectron.EventMessage) {})299			sr.SendMessage("SetDataCity:"+config.Location.City, func(m *astilectron.EventMessage) {})300			sr.SendMessage("SetDataTimeZone:"+config.Location.TimeZone, func(m *astilectron.EventMessage) {})301			sr.SendMessage("SetDataMP3:"+config.Location.MP3, func(m *astilectron.EventMessage) {})302		}303		sr.OnMessage(func(m *astilectron.EventMessage) interface{} {304			// Unmarshal305			var s string306			m.Unmarshal(&s)307			// Process message308			if strings.Contains(s, "back") {309				clean := strings.Replace(s, "back:", "", -1)310				split := strings.Split(clean, ":")311				SaveConfigs(split[0], split[1], split[2], split[3])312				config, err = LoadConfig("config.json")313				if err != nil {314					log.Fatal("Error importing config.json file", err)315				}316				sr.SendMessage("Restart:", func(m *astilectron.EventMessage) {})317				w.SendMessage("Restart:", func(m *astilectron.EventMessage) {})318			}319			return nil320		})321		return nil322	})323	// Blocking pattern324	a.Wait()325}326//ACal API Function327func ACal() Athan {328	//var Meth = strconv.Itoa(config.Calculation.Method)329	var Meth = "2"330	var AthanAPI = MainAPI + config.Location.City + CountryAPI + config.Location.Country + StateAPI + config.Location.State + MethodAPI + Meth331	FormatAPI := fmt.Sprintf(AthanAPI)332	// Create a new HTTP client with a default timeout333	timeout := 3000 * time.Millisecond334	client := httpclient.NewClient(httpclient.WithHTTPTimeout(timeout))335	// Use the clients GET method to create and execute the request336	resp, err := client.Get(FormatAPI, nil)337	if err != nil {338		panic(err)339	}340	defer resp.Body.Close()341	if err != nil {342		log.Fatal(err)343	}344	body, err := ioutil.ReadAll(resp.Body)345	var Y Athan346	err = json.Unmarshal(body, &Y)347	if err != nil {348		log.Fatal(err)349	}350	return Y351}352//LoadConfig file353func LoadConfig(filename string) (Config, error) {354	var config Config355	configFile, err := os.Open(filename)356	if err != nil {357		log.Fatal("Error importing config.json file", err)358	}359	defer configFile.Close()360	if err != nil {361		return config, err362	}363	jsonParser := json.NewDecoder(configFile)364	err = jsonParser.Decode(&config)365	return config, err366}...

...114	return s115}116func getWelcomeMessage(s *Session) {117	message := viper.GetString("messages.welcome")118	sendMessage(s, message)119}120func getAboutMessage(s *Session) {121	message := viper.GetString("messages.about")122	sendMessage(s, message)123}124func getWarnMessage(s *Session) {125	message := viper.GetString("messages.warn")126	sendMessage(s, message)127}128func getFeesMesssage(s *Session) {129	picture := "pictures/btse-fees.jpg"130	sendPicture(s, picture)131	message := viper.GetString("messages.fees")132	sendMessageWithoutReply(s, message)133}134func getRegisterMessage(s *Session) {135	message := viper.GetString("messages.register")136	sendMessage(s, message)137}138func getSupportMessage(s *Session) {139	message := viper.GetString("messages.support")140	sendMessage(s, message)141}142func getEmailMessage(s *Session) {143	message := viper.GetString("messages.email")144	sendMessage(s, message)145}146func getReferralMessage(s *Session) {147	message := viper.GetString("messages.referral")148	sendMessage(s, message)149}150func getTestnetMessage(s *Session) {151	message := viper.GetString("messages.testnet")152	sendMessage(s, message)153}154func getMediaMessage(s *Session) {155	message := viper.GetString("messages.media")156	sendMessage(s, message)157}158func getNewsMessage(s *Session) {159	message := viper.GetString("messages.news")160	sendMessage(s, message)161}162func getLearnMessage(s *Session)  {163	message := viper.GetString("messages.learn")164	sendMessage(s, message)165}166func getApiMessage(s *Session) {167	message := viper.GetString("messages.api")168	sendMessage(s, message)169}170func getAppMessage(s *Session) {171	message := viper.GetString("messages.app")172	sendMessage(s, message)173}174func getBonusMessage(s *Session) {175	message := viper.GetString("messages.bonus")176	sendMessage(s, message)177}178func getCurrenciesMessage(s *Session) {179	message := viper.GetString("messages.currencies")180	sendMessage(s, message)181}182func getDepositMessage(s *Session) {183	message := viper.GetString("messages.deposit")184	sendMessage(s, message)185}186func getWithdrawMessage(s *Session) {187	picture := "pictures/deposit-withdrawal-fees.jpg"188	message := viper.GetString("messages.withdraw")189	sendMessage(s, message)190	sendPictureWithoutReply(s, picture)191}192func getContractsMessage(s *Session) {193	message := viper.GetString("messages.contracts")194	sendMessage(s, message)195}196func getSecurityMessage(s *Session) {197	message := viper.GetString("messages.security")198	sendMessage(s, message)199}200func getKycMessage(s *Session) {201	message := viper.GetString("messages.kyc")202	sendMessage(s, message)203}204func getGroupsMessage(s *Session) {205	message := viper.GetString("messages.groups")206	sendMessage(s, message)207}208func sendPicture(s *Session, picture string) {209	message := tgbotapi.NewPhotoUpload(s.update.Message.Chat.ID, picture)210	message.ReplyToMessageID = s.update.Message.MessageID211	s.bot.Send(message)212}213func sendPictureWithoutReply(s *Session, picture string) {214	message := tgbotapi.NewPhotoUpload(s.update.Message.Chat.ID, picture)215	s.bot.Send(message)216}217func sendMessageWithoutReply(s *Session, message string) {218	msg := tgbotapi.NewMessage(s.update.Message.Chat.ID, message)219	msg.ParseMode = PARSEMODE220	s.bot.Send(msg)221}222func sendMessage(s *Session, message string) {223	msg := tgbotapi.NewMessage(s.update.Message.Chat.ID, message)224	msg.ReplyToMessageID = s.update.Message.MessageID225	msg.ParseMode = PARSEMODE226	s.bot.Send(msg)227}...

1package onsmqtt2//Licensed under the Apache License, Version 2.0 (the "License");3//you may not use this file except in compliance with the License.4//You may obtain a copy of the License at5//6//http://www.apache.org/licenses/LICENSE-2.07//8//Unless required by applicable law or agreed to in writing, software9//distributed under the License is distributed on an "AS IS" BASIS,10//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.11//See the License for the specific language governing permissions and12//limitations under the License.13//14// Code generated by Alibaba Cloud SDK Code Generator.15// Changes may cause incorrect behavior and will be lost if the code is regenerated.16import (17	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests"18	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses"19)20// SendMessage invokes the onsmqtt.SendMessage API synchronously21// api document: https://help.aliyun.com/api/onsmqtt/sendmessage.html22func (client *Client) SendMessage(request *SendMessageRequest) (response *SendMessageResponse, err error) {23	response = CreateSendMessageResponse()24	err = client.DoAction(request, response)25	return26}27// SendMessageWithChan invokes the onsmqtt.SendMessage API asynchronously28// api document: https://help.aliyun.com/api/onsmqtt/sendmessage.html29// asynchronous document: https://help.aliyun.com/document_detail/66220.html30func (client *Client) SendMessageWithChan(request *SendMessageRequest) (<-chan *SendMessageResponse, <-chan error) {31	responseChan := make(chan *SendMessageResponse, 1)32	errChan := make(chan error, 1)33	err := client.AddAsyncTask(func() {34		defer close(responseChan)35		defer close(errChan)36		response, err := client.SendMessage(request)37		if err != nil {38			errChan <- err39		} else {40			responseChan <- response41		}42	})43	if err != nil {44		errChan <- err45		close(responseChan)46		close(errChan)47	}48	return responseChan, errChan49}50// SendMessageWithCallback invokes the onsmqtt.SendMessage API asynchronously51// api document: https://help.aliyun.com/api/onsmqtt/sendmessage.html52// asynchronous document: https://help.aliyun.com/document_detail/66220.html53func (client *Client) SendMessageWithCallback(request *SendMessageRequest, callback func(response *SendMessageResponse, err error)) <-chan int {54	result := make(chan int, 1)55	err := client.AddAsyncTask(func() {56		var response *SendMessageResponse57		var err error58		defer close(result)59		response, err = client.SendMessage(request)60		callback(response, err)61		result <- 162	})63	if err != nil {64		defer close(result)65		callback(nil, err)66		result <- 067	}68	return result69}70// SendMessageRequest is the request struct for api SendMessage71type SendMessageRequest struct {72	*requests.RpcRequest73	NoPersistFlag requests.Boolean `position:"Query" name:"NoPersistFlag"`74	MqttTopic     string           `position:"Query" name:"MqttTopic"`75	InstanceId    string           `position:"Query" name:"InstanceId"`76	Payload       string           `position:"Query" name:"Payload"`77	ReceiptId     string           `position:"Query" name:"ReceiptId"`78}79// SendMessageResponse is the response struct for api SendMessage80type SendMessageResponse struct {81	*responses.BaseResponse82	MsgId     string `json:"MsgId" xml:"MsgId"`83	RequestId string `json:"RequestId" xml:"RequestId"`84}85// CreateSendMessageRequest creates a request to invoke SendMessage API86func CreateSendMessageRequest() (request *SendMessageRequest) {87	request = &SendMessageRequest{88		RpcRequest: &requests.RpcRequest{},89	}90	request.InitWithApiInfo("OnsMqtt", "2019-12-11", "SendMessage", "onsmqtt", "openAPI")91	return92}93// CreateSendMessageResponse creates a response to parse from SendMessage response94func CreateSendMessageResponse() (response *SendMessageResponse) {95	response = &SendMessageResponse{96		BaseResponse: &responses.BaseResponse{},97	}98	return99}...

1    import (2    func main() {3        http.HandleFunc("/", handler)4        http.HandleFunc("/1", handler1)5        http.HandleFunc("/2", handler2)6        http.HandleFunc("/3", handler3)7        http.HandleFunc("/4", handler4)8        http.HandleFunc("/5", handler5)9        http.HandleFunc("/6", handler6)10        http.HandleFunc("/7", handler7)11        http.HandleFunc("/8", handler8)12        http.HandleFunc("/9", handler9)13        http.HandleFunc("/10", handler10)14        log.Fatal(http.ListenAndServe(":8080", nil))15    }16    func handler(w http.ResponseWriter, r *http.Request) {17        fmt.Fprintf(w, "Hello, %q", html.EscapeString(r.URL.Path))18    }19    func handler1(w http.ResponseWriter, r *http.Request) {20        fmt.Fprintf(w, "Hello, %q", html.EscapeString(r.URL.Path))21    }22    func handler2(w http.ResponseWriter, r *http.Request) {23        fmt.Fprintf(w, "Hello, %q", html.EscapeString(r.URL.Path))24    }25    func handler3(w http.ResponseWriter, r *http.Request) {26        fmt.Fprintf(w, "Hello, %q", html.EscapeString(r.URL.Path))27    }28    func handler4(w http.ResponseWriter, r *http.Request) {29        fmt.Fprintf(w, "Hello, %q", html.EscapeString(r.URL.Path))30    }31    func handler5(w http.ResponseWriter, r *http.Request

1api.sendMessage("Hello", "World");2api.sendEmail("Hello", "World");3api.sendMessage("Hello", "World");4api.sendEmail("Hello", "World");5func init() {6}7func init() {

1import (2func main() {3   s := sse.NewServer(nil)4   s.CreateStream("stream-1")5   s.SendMessage("stream-1", sse.SimpleMessage("Hello World"))6   log.Fatal(s.ListenAndServe(":8080"))7}8import (9func main() {10   s := sse.NewServer(nil)11   s.CreateStream("stream-1")12   s.ReceiveMessage("stream-1", func(msg *sse.Event) {13      fmt.Println("Received:", msg.Data())14   })15   log.Fatal(s.ListenAndServe(":8080"))16}17import (18func main() {19   s := sse.NewServer(nil)20   s.CreateStream("stream-1")21   s.SendJSONMessage("stream-1", map[string]string{"hello": "world"})22   log.Fatal(s.ListenAndServe(":8080"))23}24import (25func main() {26   s := sse.NewServer(nil)27   s.CreateStream("stream-1")28   s.ReceiveJSONMessage("stream-1", func(msg *sse.Event) {29      fmt.Println("Received:", msg.Data())30   })31   log.Fatal(s.ListenAndServe(":8080"))32}33import (34func main() {35   s := sse.NewServer(nil)36   s.CreateStream("stream-1")37   s.SendJSONMessage("stream-1", map[string]string{"hello": "world"})38   log.Fatal(s.ListenAndServe(":8080"))39}