12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163 |
- // Copyright 2021-2023 EMQ Technologies Co., Ltd.
- //
- // Licensed under the Apache License, Version 2.0 (the "License");
- // you may not use this file except in compliance with the License.
- // You may obtain a copy of the License at
- //
- // http://www.apache.org/licenses/LICENSE-2.0
- //
- // Unless required by applicable law or agreed to in writing, software
- // distributed under the License is distributed on an "AS IS" BASIS,
- // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- // See the License for the specific language governing permissions and
- // limitations under the License.
- package mocknode
- import (
- "encoding/base64"
- "os"
- "path"
- "github.com/lf-edge/ekuiper/internal/conf"
- "github.com/lf-edge/ekuiper/internal/xsql"
- )
- // TestData The time diff must larger than timeleap
- var TestData = map[string][]*xsql.Tuple{
- "demo": {
- {
- Emitter: "demo",
- Message: map[string]interface{}{
- "color": "red",
- "size": 3,
- "ts": 1541152486013,
- },
- Timestamp: 1541152486013,
- },
- {
- Emitter: "demo",
- Message: map[string]interface{}{
- "color": "blue",
- "size": 6,
- "ts": 1541152486822,
- },
- Timestamp: 1541152486822,
- },
- {
- Emitter: "demo",
- Message: map[string]interface{}{
- "color": "blue",
- "size": 2,
- "ts": 1541152487632,
- },
- Timestamp: 1541152487632,
- },
- {
- Emitter: "demo",
- Message: map[string]interface{}{
- "color": "yellow",
- "size": 4,
- "ts": 1541152488442,
- },
- Timestamp: 1541152488442,
- },
- {
- Emitter: "demo",
- Message: map[string]interface{}{
- "color": "red",
- "size": 1,
- "ts": 1541152489252,
- },
- Timestamp: 1541152489252,
- },
- },
- "demoError": {
- {
- Emitter: "demoError",
- Message: map[string]interface{}{
- "color": "blue",
- "size": "red",
- "ts": 1541152486013,
- },
- Timestamp: 1541152486013,
- },
- {
- Emitter: "demoError",
- Message: map[string]interface{}{
- "color": "blue",
- "size": 6,
- "ts": 1541152486822,
- },
- Timestamp: 1541152486822,
- },
- {
- Emitter: "demoError",
- Message: map[string]interface{}{
- "color": "blue",
- "size": 2,
- "ts": 1541152487632,
- },
- Timestamp: 1541152487632,
- },
- {
- Emitter: "demoError",
- Message: map[string]interface{}{
- "color": 7,
- "size": 4,
- "ts": 1541152488442,
- },
- Timestamp: 1541152488442,
- },
- {
- Emitter: "demoError",
- Message: map[string]interface{}{
- "color": "red",
- "size": "blue",
- "ts": 1541152489252,
- },
- Timestamp: 1541152489252,
- },
- },
- "demo1": {
- {
- Emitter: "demo1",
- Message: map[string]interface{}{
- "temp": 25.5,
- "hum": 65,
- "from": "device1",
- "ts": 1541152486013,
- },
- Timestamp: 1541152486115,
- },
- {
- Emitter: "demo1",
- Message: map[string]interface{}{
- "temp": 27.5,
- "hum": 59,
- "from": "device2",
- "ts": 1541152486823,
- },
- Timestamp: 1541152486903,
- },
- {
- Emitter: "demo1",
- Message: map[string]interface{}{
- "temp": 28.1,
- "hum": 75,
- "from": "device3",
- "ts": 1541152487632,
- },
- Timestamp: 1541152487702,
- },
- {
- Emitter: "demo1",
- Message: map[string]interface{}{
- "temp": 27.4,
- "hum": 80,
- "from": "device1",
- "ts": 1541152488442,
- },
- Timestamp: 1541152488605,
- },
- {
- Emitter: "demo1",
- Message: map[string]interface{}{
- "temp": 25.5,
- "hum": 62,
- "from": "device3",
- "ts": 1541152489252,
- },
- Timestamp: 1541152489305,
- },
- },
- "sessionDemo": {
- {
- Emitter: "sessionDemo",
- Message: map[string]interface{}{
- "temp": 25.5,
- "hum": 65,
- "ts": 1541152486013,
- },
- Timestamp: 1541152486013,
- },
- {
- Emitter: "sessionDemo",
- Message: map[string]interface{}{
- "temp": 27.5,
- "hum": 59,
- "ts": 1541152486823,
- },
- Timestamp: 1541152486823,
- },
- {
- Emitter: "sessionDemo",
- Message: map[string]interface{}{
- "temp": 28.1,
- "hum": 75,
- "ts": 1541152487932,
- },
- Timestamp: 1541152487932,
- },
- {
- Emitter: "sessionDemo",
- Message: map[string]interface{}{
- "temp": 27.4,
- "hum": 80,
- "ts": 1541152488442,
- },
- Timestamp: 1541152488442,
- },
- {
- Emitter: "sessionDemo",
- Message: map[string]interface{}{
- "temp": 25.5,
- "hum": 62,
- "ts": 1541152489252,
- },
- Timestamp: 1541152489252,
- },
- {
- Emitter: "sessionDemo",
- Message: map[string]interface{}{
- "temp": 26.2,
- "hum": 63,
- "ts": 1541152490062,
- },
- Timestamp: 1541152490062,
- },
- {
- Emitter: "sessionDemo",
- Message: map[string]interface{}{
- "temp": 26.8,
- "hum": 71,
- "ts": 1541152490872,
- },
- Timestamp: 1541152490872,
- },
- {
- Emitter: "sessionDemo",
- Message: map[string]interface{}{
- "temp": 28.9,
- "hum": 85,
- "ts": 1541152491682,
- },
- Timestamp: 1541152491682,
- },
- {
- Emitter: "sessionDemo",
- Message: map[string]interface{}{
- "temp": 29.1,
- "hum": 92,
- "ts": 1541152492492,
- },
- Timestamp: 1541152492492,
- },
- {
- Emitter: "sessionDemo",
- Message: map[string]interface{}{
- "temp": 32.2,
- "hum": 99,
- "ts": 1541152493202,
- },
- Timestamp: 1541152493202,
- },
- {
- Emitter: "sessionDemo",
- Message: map[string]interface{}{
- "temp": 30.9,
- "hum": 87,
- "ts": 1541152494112,
- },
- Timestamp: 1541152494112,
- },
- },
- "demoE": {
- {
- Emitter: "demoE",
- Message: map[string]interface{}{
- "color": "red",
- "size": 3,
- "ts": 1541152486013,
- },
- Timestamp: 1541152586023,
- },
- {
- Emitter: "demoE",
- Message: map[string]interface{}{
- "color": "blue",
- "size": 2,
- "ts": 1541152487632,
- },
- Timestamp: 1541152587822,
- },
- {
- Emitter: "demoE",
- Message: map[string]interface{}{
- "color": "red",
- "size": 1,
- "ts": 1541152489252,
- },
- Timestamp: 1541152589632,
- },
- { // dropped item
- Emitter: "demoE",
- Message: map[string]interface{}{
- "color": "blue",
- "size": 6,
- "ts": 1541152486822,
- },
- Timestamp: 1541152589842,
- },
- {
- Emitter: "demoE",
- Message: map[string]interface{}{
- "color": "yellow",
- "size": 4,
- "ts": 1541152488442,
- },
- Timestamp: 1541152590052,
- },
- { // To lift the watermark and issue all windows
- Emitter: "demoE",
- Message: map[string]interface{}{
- "color": "yellow",
- "size": 4,
- "ts": 1541152492342,
- },
- Timestamp: 1541152598888,
- },
- },
- "demo1E": {
- {
- Emitter: "demo1E",
- Message: map[string]interface{}{
- "temp": 27.5,
- "hum": 59,
- "ts": 1541152486823,
- },
- Timestamp: 1541152587250,
- },
- {
- Emitter: "demo1E",
- Message: map[string]interface{}{
- "temp": 25.5,
- "hum": 65,
- "ts": 1541152486013,
- },
- Timestamp: 1541152587751,
- },
- {
- Emitter: "demo1E",
- Message: map[string]interface{}{
- "temp": 27.4,
- "hum": 80,
- "ts": 1541152488442,
- },
- Timestamp: 1541152589252,
- },
- {
- Emitter: "demo1E",
- Message: map[string]interface{}{
- "temp": 28.1,
- "hum": 75,
- "ts": 1541152487632,
- },
- Timestamp: 1541152589753,
- },
- {
- Emitter: "demo1E",
- Message: map[string]interface{}{
- "temp": 25.5,
- "hum": 62,
- "ts": 1541152489252,
- },
- Timestamp: 1541152589954,
- },
- {
- Emitter: "demo1E",
- Message: map[string]interface{}{
- "temp": 25.5,
- "hum": 62,
- "ts": 1541152499252,
- },
- Timestamp: 1541152599755,
- },
- },
- "sessionDemoE": {
- {
- Emitter: "sessionDemoE",
- Message: map[string]interface{}{
- "temp": 25.5,
- "hum": 65,
- "ts": 1541152486013,
- },
- Timestamp: 1541152586250,
- },
- {
- Emitter: "sessionDemoE",
- Message: map[string]interface{}{
- "temp": 28.1,
- "hum": 75,
- "ts": 1541152487932,
- },
- Timestamp: 1541152587951,
- },
- {
- Emitter: "sessionDemoE",
- Message: map[string]interface{}{
- "temp": 27.5,
- "hum": 59,
- "ts": 1541152486823,
- },
- Timestamp: 1541152588552,
- },
- {
- Emitter: "sessionDemoE",
- Message: map[string]interface{}{
- "temp": 25.5,
- "hum": 62,
- "ts": 1541152489252,
- },
- Timestamp: 1541152589353,
- },
- {
- Emitter: "sessionDemoE",
- Message: map[string]interface{}{
- "temp": 27.4,
- "hum": 80,
- "ts": 1541152488442,
- },
- Timestamp: 1541152589854,
- },
- {
- Emitter: "sessionDemoE",
- Message: map[string]interface{}{
- "temp": 26.2,
- "hum": 63,
- "ts": 1541152490062,
- },
- Timestamp: 1541152590155,
- },
- {
- Emitter: "sessionDemoE",
- Message: map[string]interface{}{
- "temp": 28.9,
- "hum": 85,
- "ts": 1541152491682,
- },
- Timestamp: 1541152591686,
- },
- {
- Emitter: "sessionDemoE",
- Message: map[string]interface{}{
- "temp": 26.8,
- "hum": 71,
- "ts": 1541152490872,
- },
- Timestamp: 1541152591972,
- },
- {
- Emitter: "sessionDemoE",
- Message: map[string]interface{}{
- "temp": 29.1,
- "hum": 92,
- "ts": 1541152492492,
- },
- Timestamp: 1541152592592,
- },
- {
- Emitter: "sessionDemoE",
- Message: map[string]interface{}{
- "temp": 30.9,
- "hum": 87,
- "ts": 1541152494112,
- },
- Timestamp: 1541152594212,
- },
- {
- Emitter: "sessionDemoE",
- Message: map[string]interface{}{
- "temp": 32.2,
- "hum": 99,
- "ts": 1541152493202,
- },
- Timestamp: 1541152595202,
- },
- {
- Emitter: "sessionDemoE",
- Message: map[string]interface{}{
- "temp": 32.2,
- "hum": 99,
- "ts": 1541152499202,
- },
- Timestamp: 1541152599402,
- },
- },
- "demoErr": {
- {
- Emitter: "demoErr",
- Message: map[string]interface{}{
- "color": "red",
- "size": 3,
- "ts": 1541152486013,
- },
- Timestamp: 1541152486221,
- },
- {
- Emitter: "demoErr",
- Message: map[string]interface{}{
- "color": 2,
- "size": 5,
- "ts": 1541152487632,
- },
- Timestamp: 1541152487722,
- },
- {
- Emitter: "demoErr",
- Message: map[string]interface{}{
- "color": "red",
- "size": 1,
- "ts": 1541152489252,
- },
- Timestamp: 1541152489332,
- },
- { // dropped item
- Emitter: "demoErr",
- Message: map[string]interface{}{
- "color": "blue",
- "size": 6,
- "ts": 1541152486822,
- },
- Timestamp: 1541152489822,
- },
- {
- Emitter: "demoErr",
- Message: map[string]interface{}{
- "color": "yellow",
- "size": 4,
- "ts": 1541152488442,
- },
- Timestamp: 1541152490042,
- },
- { // To lift the watermark and issue all windows
- Emitter: "demoErr",
- Message: map[string]interface{}{
- "color": "yellow",
- "size": 4,
- "ts": 1541152492342,
- },
- Timestamp: 1541152493842,
- },
- },
- "ldemo": {
- {
- Emitter: "ldemo",
- Message: map[string]interface{}{
- "color": "red",
- "size": 3,
- "ts": 1541152486013,
- },
- Timestamp: 1541152486013,
- },
- {
- Emitter: "ldemo",
- Message: map[string]interface{}{
- "color": "blue",
- "size": "string",
- "ts": 1541152486822,
- },
- Timestamp: 1541152486822,
- },
- {
- Emitter: "ldemo",
- Message: map[string]interface{}{
- "size": 3,
- "ts": 1541152487632,
- },
- Timestamp: 1541152487632,
- },
- {
- Emitter: "ldemo",
- Message: map[string]interface{}{
- "color": 49,
- "size": 2,
- "ts": 1541152488442,
- },
- Timestamp: 1541152488442,
- },
- {
- Emitter: "ldemo",
- Message: map[string]interface{}{
- "color": "red",
- "ts": 1541152489252,
- },
- Timestamp: 1541152489252,
- },
- },
- "ldemo1": {
- {
- Emitter: "ldemo1",
- Message: map[string]interface{}{
- "temp": 25.5,
- "hum": 65,
- "ts": 1541152486013,
- },
- Timestamp: 1541152486013,
- },
- {
- Emitter: "ldemo1",
- Message: map[string]interface{}{
- "temp": 27.5,
- "hum": 59,
- "ts": 1541152486823,
- },
- Timestamp: 1541152486823,
- },
- {
- Emitter: "ldemo1",
- Message: map[string]interface{}{
- "temp": 28.1,
- "hum": 75,
- "ts": 1541152487632,
- },
- Timestamp: 1541152487632,
- },
- {
- Emitter: "ldemo1",
- Message: map[string]interface{}{
- "temp": 27.4,
- "hum": 80,
- "ts": "1541152488442",
- },
- Timestamp: 1541152488442,
- },
- {
- Emitter: "ldemo1",
- Message: map[string]interface{}{
- "temp": 25.5,
- "hum": 62,
- "ts": 1541152489252,
- },
- Timestamp: 1541152489252,
- },
- },
- "lsessionDemo": {
- {
- Emitter: "lsessionDemo",
- Message: map[string]interface{}{
- "temp": 25.5,
- "hum": 65,
- "ts": 1541152486013,
- },
- Timestamp: 1541152486013,
- },
- {
- Emitter: "lsessionDemo",
- Message: map[string]interface{}{
- "temp": 27.5,
- "hum": 59,
- "ts": 1541152486823,
- },
- Timestamp: 1541152486823,
- },
- {
- Emitter: "lsessionDemo",
- Message: map[string]interface{}{
- "temp": 28.1,
- "hum": 75,
- "ts": 1541152487932,
- },
- Timestamp: 1541152487932,
- },
- {
- Emitter: "lsessionDemo",
- Message: map[string]interface{}{
- "temp": 27.4,
- "hum": 80,
- "ts": 1541152488442,
- },
- Timestamp: 1541152488442,
- },
- {
- Emitter: "lsessionDemo",
- Message: map[string]interface{}{
- "temp": 25.5,
- "hum": 62,
- "ts": 1541152489252,
- },
- Timestamp: 1541152489252,
- },
- {
- Emitter: "lsessionDemo",
- Message: map[string]interface{}{
- "temp": 26.2,
- "hum": 63,
- "ts": 1541152490062,
- },
- Timestamp: 1541152490062,
- },
- {
- Emitter: "lsessionDemo",
- Message: map[string]interface{}{
- "temp": 26.8,
- "hum": 71,
- "ts": 1541152490872,
- },
- Timestamp: 1541152490872,
- },
- {
- Emitter: "lsessionDemo",
- Message: map[string]interface{}{
- "temp": 28.9,
- "hum": 85,
- "ts": 1541152491682,
- },
- Timestamp: 1541152491682,
- },
- {
- Emitter: "lsessionDemo",
- Message: map[string]interface{}{
- "temp": 29.1,
- "hum": 92,
- "ts": 1541152492492,
- },
- Timestamp: 1541152492492,
- },
- {
- Emitter: "lsessionDemo",
- Message: map[string]interface{}{
- "temp": 2.2,
- "hum": 99,
- "ts": 1541152493202,
- },
- Timestamp: 1541152493202,
- },
- {
- Emitter: "lsessionDemo",
- Message: map[string]interface{}{
- "temp": 30.9,
- "hum": 87,
- "ts": 1541152494112,
- },
- Timestamp: 1541152494112,
- },
- },
- "text": {
- {
- Emitter: "text",
- Message: map[string]interface{}{
- "slogan": "Impossible is nothing",
- "brand": "Adidas",
- },
- Timestamp: 1541152486500,
- },
- {
- Emitter: "text",
- Message: map[string]interface{}{
- "slogan": "Stronger than dirt",
- "brand": "Ajax",
- },
- Timestamp: 1541152487400,
- },
- {
- Emitter: "text",
- Message: map[string]interface{}{
- "slogan": "Belong anywhere",
- "brand": "Airbnb",
- },
- Timestamp: 1541152488300,
- },
- {
- Emitter: "text",
- Message: map[string]interface{}{
- "slogan": "I can'T believe I ate the whole thing",
- "brand": "Alka Seltzer",
- },
- Timestamp: 1541152489200,
- },
- {
- Emitter: "text",
- Message: map[string]interface{}{
- "slogan": "You're in good hands",
- "brand": "Allstate",
- },
- Timestamp: 1541152490100,
- },
- {
- Emitter: "text",
- Message: map[string]interface{}{
- "slogan": "Don'T leave home without it",
- "brand": "American Express",
- },
- Timestamp: 1541152491200,
- },
- {
- Emitter: "text",
- Message: map[string]interface{}{
- "slogan": "Think different",
- "brand": "Apple",
- },
- Timestamp: 1541152492300,
- },
- {
- Emitter: "text",
- Message: map[string]interface{}{
- "slogan": "We try harder",
- "brand": "Avis",
- },
- Timestamp: 1541152493400,
- },
- },
- "binDemo": {
- {
- Emitter: "binDemo",
- Message: map[string]interface{}{
- "self": Image,
- },
- Timestamp: 1541152486013,
- },
- },
- "fakeBin": {
- {
- Emitter: "fakeBin",
- Message: map[string]interface{}{
- "self": []byte("golang"),
- },
- Timestamp: 1541152486013,
- },
- {
- Emitter: "fakeBin",
- Message: map[string]interface{}{
- "self": []byte("peacock"),
- },
- Timestamp: 1541152487013,
- },
- {
- Emitter: "fakeBin",
- Message: map[string]interface{}{
- "self": []byte("bullfrog"),
- },
- Timestamp: 1541152488013,
- },
- },
- "helloStr": {
- {
- Emitter: "helloStr",
- Message: map[string]interface{}{
- "name": "world",
- },
- Timestamp: 1541152486013,
- },
- {
- Emitter: "helloStr",
- Message: map[string]interface{}{
- "name": "golang",
- },
- Timestamp: 1541152487013,
- },
- {
- Emitter: "helloStr",
- Message: map[string]interface{}{
- "name": "peacock",
- },
- Timestamp: 1541152488013,
- },
- },
- "commands": {
- {
- Emitter: "commands",
- Message: map[string]interface{}{
- "cmd": "get",
- "base64_img": "my image",
- "encoded_json": "{\"name\": \"name1\",\"size\": 22}",
- },
- Timestamp: 1541152486013,
- },
- {
- Emitter: "commands",
- Message: map[string]interface{}{
- "cmd": "detect",
- "base64_img": "my image",
- "encoded_json": "{\"name\": \"name2\",\"size\": 33}",
- },
- Timestamp: 1541152487013,
- },
- {
- Emitter: "commands",
- Message: map[string]interface{}{
- "cmd": "delete",
- "base64_img": "my image",
- "encoded_json": "{\"name\": \"name3\",\"size\": 11}",
- },
- Timestamp: 1541152488013,
- },
- },
- "demoTable": {
- {
- Emitter: "demoTable",
- Message: map[string]interface{}{
- "ts": 1541152486013,
- "device": "device1",
- },
- Timestamp: 1541152486501,
- },
- {
- Emitter: "demoTable",
- Message: map[string]interface{}{
- "ts": 1541152486822,
- "device": "device2",
- },
- Timestamp: 1541152486502,
- },
- {
- Emitter: "demoTable",
- Message: map[string]interface{}{
- "ts": 1541152487632,
- "device": "device3",
- },
- Timestamp: 1541152488001,
- },
- {
- Emitter: "demoTable",
- Message: map[string]interface{}{
- "ts": 1541152488442,
- "device": "device4",
- },
- Timestamp: 1541152488002,
- },
- {
- Emitter: "demoTable",
- Message: map[string]interface{}{
- "ts": 1541152489252,
- "device": "device5",
- },
- Timestamp: 1541152488003,
- },
- },
- "shelves": {
- {
- Emitter: "shelves",
- Message: map[string]interface{}{
- "name": "name1",
- "size": 2,
- "shelf": map[string]interface{}{
- "id": 1541152486013,
- "theme": "tandra",
- "subfield": "sub1",
- },
- },
- Timestamp: 1541152486501,
- },
- {
- Emitter: "shelves",
- Message: map[string]interface{}{
- "name": "name2",
- "size": 3,
- "shelf": map[string]interface{}{
- "id": 1541152486822,
- "theme": "claro",
- "subfield": "sub2",
- },
- },
- Timestamp: 1541152486502,
- },
- {
- Emitter: "shelves",
- Message: map[string]interface{}{
- "name": "name3",
- "size": 4,
- "shelf": map[string]interface{}{
- "id": 1541152487632,
- "theme": "dark",
- "subfield": "sub3",
- },
- },
- Timestamp: 1541152488001,
- },
- },
- "mes": {
- {
- Emitter: "mes",
- Message: map[string]interface{}{
- "message_id": "1541152486013",
- "text": "message1",
- },
- Timestamp: 1541152486501,
- },
- {
- Emitter: "mes",
- Message: map[string]interface{}{
- "message_id": "1541152486501",
- "text": "message2",
- },
- Timestamp: 1541152486501,
- },
- {
- Emitter: "mes",
- Message: map[string]interface{}{
- "message_id": "1541152487013",
- "text": "message3",
- },
- Timestamp: 1541152487501,
- },
- },
- "demoArr": {
- {
- Emitter: "demoArr",
- Message: map[string]interface{}{
- "arr": []int{1, 2, 3, 4, 5},
- "x": 1,
- "y": 2,
- "arr2": []interface{}{
- map[string]interface{}{
- "a": 1,
- "b": 2,
- },
- map[string]interface{}{
- "a": 3,
- "b": 4,
- },
- },
- "a": 6,
- "arr3": []interface{}{1, 2, 3},
- },
- Timestamp: 1541152489253,
- },
- },
- "demoArr2": {
- {
- Emitter: "demoArr2",
- Message: map[string]interface{}{
- "arr": []interface{}{1, 2, 3, 4, 5},
- "x": 1,
- },
- Timestamp: 1541152489253,
- },
- {
- Emitter: "demoArr2",
- Message: map[string]interface{}{
- "arr": []interface{}{1, 2, 3, 4, 5},
- "x": 1,
- },
- Timestamp: 1541152489254,
- },
- },
- "demoE2": {
- {
- Emitter: "demoE2",
- Message: map[string]interface{}{
- "temp": 27.5,
- "hum": 59,
- "ts": 1541152486000,
- },
- Timestamp: 1541152486000,
- },
- {
- Emitter: "demoE2",
- Message: map[string]interface{}{
- "temp": 25.5,
- "hum": 65,
- "ts": 1541152487000,
- },
- Timestamp: 1541152487000,
- },
- {
- Emitter: "demoE2",
- Message: map[string]interface{}{
- "temp": 25.5,
- "hum": 65,
- "ts": 1541152488000,
- },
- Timestamp: 1541152488000,
- },
- },
- "demoE3": {
- {
- Emitter: "demoE3",
- Message: map[string]interface{}{
- "temp": 26.0,
- "ts": 1541152486000,
- },
- Timestamp: 1541152486000,
- },
- {
- Emitter: "demoE3",
- Message: map[string]interface{}{
- "temp": 27.0,
- "ts": 1541152487000,
- },
- Timestamp: 1541152487000,
- },
- {
- Emitter: "demoE3",
- Message: map[string]interface{}{
- "temp": 28.0,
- "ts": 1541152488000,
- },
- Timestamp: 1541152488000,
- },
- {
- Emitter: "demoE3",
- Message: map[string]interface{}{
- "temp": 28.5,
- "ts": 1541152488500,
- },
- Timestamp: 1541152488500,
- },
- {
- Emitter: "demoE3",
- Message: map[string]interface{}{
- "temp": 29.0,
- "ts": 1541152489000,
- },
- Timestamp: 1541152488500,
- },
- {
- Emitter: "demoE3",
- Message: map[string]interface{}{
- "temp": 29.5,
- "ts": 1541152489500,
- },
- Timestamp: 1541152489500,
- },
- },
- "optional_commands": {
- {
- Emitter: "optional_commands",
- Message: map[string]interface{}{
- "base64_img": "my image1",
- },
- Timestamp: 1541152486013,
- },
- {
- Emitter: "optional_commands",
- Message: map[string]interface{}{
- "base64_img": "my image2",
- },
- Timestamp: 1541152487013,
- },
- {
- Emitter: "optional_commands",
- Message: map[string]interface{}{
- "base64_img": "my image3",
- },
- Timestamp: 1541152488013,
- },
- },
- }
- var Image, _ = getImg()
- func getImg() ([]byte, string) {
- docsFolder, err := conf.GetLoc("docs/")
- if err != nil {
- conf.Log.Fatalf("Cannot find docs folder: %v", err)
- }
- image, err := os.ReadFile(path.Join(docsFolder, "cover.jpg"))
- if err != nil {
- conf.Log.Fatalf("Cannot read image: %v", err)
- }
- b64img := base64.StdEncoding.EncodeToString(image)
- return image, b64img
- }
|