mock_data.go 22 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163
  1. // Copyright 2021-2023 EMQ Technologies Co., Ltd.
  2. //
  3. // Licensed under the Apache License, Version 2.0 (the "License");
  4. // you may not use this file except in compliance with the License.
  5. // You may obtain a copy of the License at
  6. //
  7. // http://www.apache.org/licenses/LICENSE-2.0
  8. //
  9. // Unless required by applicable law or agreed to in writing, software
  10. // distributed under the License is distributed on an "AS IS" BASIS,
  11. // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  12. // See the License for the specific language governing permissions and
  13. // limitations under the License.
  14. package mocknode
  15. import (
  16. "encoding/base64"
  17. "os"
  18. "path"
  19. "github.com/lf-edge/ekuiper/internal/conf"
  20. "github.com/lf-edge/ekuiper/internal/xsql"
  21. )
  22. // TestData The time diff must larger than timeleap
  23. var TestData = map[string][]*xsql.Tuple{
  24. "demo": {
  25. {
  26. Emitter: "demo",
  27. Message: map[string]interface{}{
  28. "color": "red",
  29. "size": 3,
  30. "ts": 1541152486013,
  31. },
  32. Timestamp: 1541152486013,
  33. },
  34. {
  35. Emitter: "demo",
  36. Message: map[string]interface{}{
  37. "color": "blue",
  38. "size": 6,
  39. "ts": 1541152486822,
  40. },
  41. Timestamp: 1541152486822,
  42. },
  43. {
  44. Emitter: "demo",
  45. Message: map[string]interface{}{
  46. "color": "blue",
  47. "size": 2,
  48. "ts": 1541152487632,
  49. },
  50. Timestamp: 1541152487632,
  51. },
  52. {
  53. Emitter: "demo",
  54. Message: map[string]interface{}{
  55. "color": "yellow",
  56. "size": 4,
  57. "ts": 1541152488442,
  58. },
  59. Timestamp: 1541152488442,
  60. },
  61. {
  62. Emitter: "demo",
  63. Message: map[string]interface{}{
  64. "color": "red",
  65. "size": 1,
  66. "ts": 1541152489252,
  67. },
  68. Timestamp: 1541152489252,
  69. },
  70. },
  71. "demoError": {
  72. {
  73. Emitter: "demoError",
  74. Message: map[string]interface{}{
  75. "color": "blue",
  76. "size": "red",
  77. "ts": 1541152486013,
  78. },
  79. Timestamp: 1541152486013,
  80. },
  81. {
  82. Emitter: "demoError",
  83. Message: map[string]interface{}{
  84. "color": "blue",
  85. "size": 6,
  86. "ts": 1541152486822,
  87. },
  88. Timestamp: 1541152486822,
  89. },
  90. {
  91. Emitter: "demoError",
  92. Message: map[string]interface{}{
  93. "color": "blue",
  94. "size": 2,
  95. "ts": 1541152487632,
  96. },
  97. Timestamp: 1541152487632,
  98. },
  99. {
  100. Emitter: "demoError",
  101. Message: map[string]interface{}{
  102. "color": 7,
  103. "size": 4,
  104. "ts": 1541152488442,
  105. },
  106. Timestamp: 1541152488442,
  107. },
  108. {
  109. Emitter: "demoError",
  110. Message: map[string]interface{}{
  111. "color": "red",
  112. "size": "blue",
  113. "ts": 1541152489252,
  114. },
  115. Timestamp: 1541152489252,
  116. },
  117. },
  118. "demo1": {
  119. {
  120. Emitter: "demo1",
  121. Message: map[string]interface{}{
  122. "temp": 25.5,
  123. "hum": 65,
  124. "from": "device1",
  125. "ts": 1541152486013,
  126. },
  127. Timestamp: 1541152486115,
  128. },
  129. {
  130. Emitter: "demo1",
  131. Message: map[string]interface{}{
  132. "temp": 27.5,
  133. "hum": 59,
  134. "from": "device2",
  135. "ts": 1541152486823,
  136. },
  137. Timestamp: 1541152486903,
  138. },
  139. {
  140. Emitter: "demo1",
  141. Message: map[string]interface{}{
  142. "temp": 28.1,
  143. "hum": 75,
  144. "from": "device3",
  145. "ts": 1541152487632,
  146. },
  147. Timestamp: 1541152487702,
  148. },
  149. {
  150. Emitter: "demo1",
  151. Message: map[string]interface{}{
  152. "temp": 27.4,
  153. "hum": 80,
  154. "from": "device1",
  155. "ts": 1541152488442,
  156. },
  157. Timestamp: 1541152488605,
  158. },
  159. {
  160. Emitter: "demo1",
  161. Message: map[string]interface{}{
  162. "temp": 25.5,
  163. "hum": 62,
  164. "from": "device3",
  165. "ts": 1541152489252,
  166. },
  167. Timestamp: 1541152489305,
  168. },
  169. },
  170. "sessionDemo": {
  171. {
  172. Emitter: "sessionDemo",
  173. Message: map[string]interface{}{
  174. "temp": 25.5,
  175. "hum": 65,
  176. "ts": 1541152486013,
  177. },
  178. Timestamp: 1541152486013,
  179. },
  180. {
  181. Emitter: "sessionDemo",
  182. Message: map[string]interface{}{
  183. "temp": 27.5,
  184. "hum": 59,
  185. "ts": 1541152486823,
  186. },
  187. Timestamp: 1541152486823,
  188. },
  189. {
  190. Emitter: "sessionDemo",
  191. Message: map[string]interface{}{
  192. "temp": 28.1,
  193. "hum": 75,
  194. "ts": 1541152487932,
  195. },
  196. Timestamp: 1541152487932,
  197. },
  198. {
  199. Emitter: "sessionDemo",
  200. Message: map[string]interface{}{
  201. "temp": 27.4,
  202. "hum": 80,
  203. "ts": 1541152488442,
  204. },
  205. Timestamp: 1541152488442,
  206. },
  207. {
  208. Emitter: "sessionDemo",
  209. Message: map[string]interface{}{
  210. "temp": 25.5,
  211. "hum": 62,
  212. "ts": 1541152489252,
  213. },
  214. Timestamp: 1541152489252,
  215. },
  216. {
  217. Emitter: "sessionDemo",
  218. Message: map[string]interface{}{
  219. "temp": 26.2,
  220. "hum": 63,
  221. "ts": 1541152490062,
  222. },
  223. Timestamp: 1541152490062,
  224. },
  225. {
  226. Emitter: "sessionDemo",
  227. Message: map[string]interface{}{
  228. "temp": 26.8,
  229. "hum": 71,
  230. "ts": 1541152490872,
  231. },
  232. Timestamp: 1541152490872,
  233. },
  234. {
  235. Emitter: "sessionDemo",
  236. Message: map[string]interface{}{
  237. "temp": 28.9,
  238. "hum": 85,
  239. "ts": 1541152491682,
  240. },
  241. Timestamp: 1541152491682,
  242. },
  243. {
  244. Emitter: "sessionDemo",
  245. Message: map[string]interface{}{
  246. "temp": 29.1,
  247. "hum": 92,
  248. "ts": 1541152492492,
  249. },
  250. Timestamp: 1541152492492,
  251. },
  252. {
  253. Emitter: "sessionDemo",
  254. Message: map[string]interface{}{
  255. "temp": 32.2,
  256. "hum": 99,
  257. "ts": 1541152493202,
  258. },
  259. Timestamp: 1541152493202,
  260. },
  261. {
  262. Emitter: "sessionDemo",
  263. Message: map[string]interface{}{
  264. "temp": 30.9,
  265. "hum": 87,
  266. "ts": 1541152494112,
  267. },
  268. Timestamp: 1541152494112,
  269. },
  270. },
  271. "demoE": {
  272. {
  273. Emitter: "demoE",
  274. Message: map[string]interface{}{
  275. "color": "red",
  276. "size": 3,
  277. "ts": 1541152486013,
  278. },
  279. Timestamp: 1541152586023,
  280. },
  281. {
  282. Emitter: "demoE",
  283. Message: map[string]interface{}{
  284. "color": "blue",
  285. "size": 2,
  286. "ts": 1541152487632,
  287. },
  288. Timestamp: 1541152587822,
  289. },
  290. {
  291. Emitter: "demoE",
  292. Message: map[string]interface{}{
  293. "color": "red",
  294. "size": 1,
  295. "ts": 1541152489252,
  296. },
  297. Timestamp: 1541152589632,
  298. },
  299. { // dropped item
  300. Emitter: "demoE",
  301. Message: map[string]interface{}{
  302. "color": "blue",
  303. "size": 6,
  304. "ts": 1541152486822,
  305. },
  306. Timestamp: 1541152589842,
  307. },
  308. {
  309. Emitter: "demoE",
  310. Message: map[string]interface{}{
  311. "color": "yellow",
  312. "size": 4,
  313. "ts": 1541152488442,
  314. },
  315. Timestamp: 1541152590052,
  316. },
  317. { // To lift the watermark and issue all windows
  318. Emitter: "demoE",
  319. Message: map[string]interface{}{
  320. "color": "yellow",
  321. "size": 4,
  322. "ts": 1541152492342,
  323. },
  324. Timestamp: 1541152598888,
  325. },
  326. },
  327. "demo1E": {
  328. {
  329. Emitter: "demo1E",
  330. Message: map[string]interface{}{
  331. "temp": 27.5,
  332. "hum": 59,
  333. "ts": 1541152486823,
  334. },
  335. Timestamp: 1541152587250,
  336. },
  337. {
  338. Emitter: "demo1E",
  339. Message: map[string]interface{}{
  340. "temp": 25.5,
  341. "hum": 65,
  342. "ts": 1541152486013,
  343. },
  344. Timestamp: 1541152587751,
  345. },
  346. {
  347. Emitter: "demo1E",
  348. Message: map[string]interface{}{
  349. "temp": 27.4,
  350. "hum": 80,
  351. "ts": 1541152488442,
  352. },
  353. Timestamp: 1541152589252,
  354. },
  355. {
  356. Emitter: "demo1E",
  357. Message: map[string]interface{}{
  358. "temp": 28.1,
  359. "hum": 75,
  360. "ts": 1541152487632,
  361. },
  362. Timestamp: 1541152589753,
  363. },
  364. {
  365. Emitter: "demo1E",
  366. Message: map[string]interface{}{
  367. "temp": 25.5,
  368. "hum": 62,
  369. "ts": 1541152489252,
  370. },
  371. Timestamp: 1541152589954,
  372. },
  373. {
  374. Emitter: "demo1E",
  375. Message: map[string]interface{}{
  376. "temp": 25.5,
  377. "hum": 62,
  378. "ts": 1541152499252,
  379. },
  380. Timestamp: 1541152599755,
  381. },
  382. },
  383. "sessionDemoE": {
  384. {
  385. Emitter: "sessionDemoE",
  386. Message: map[string]interface{}{
  387. "temp": 25.5,
  388. "hum": 65,
  389. "ts": 1541152486013,
  390. },
  391. Timestamp: 1541152586250,
  392. },
  393. {
  394. Emitter: "sessionDemoE",
  395. Message: map[string]interface{}{
  396. "temp": 28.1,
  397. "hum": 75,
  398. "ts": 1541152487932,
  399. },
  400. Timestamp: 1541152587951,
  401. },
  402. {
  403. Emitter: "sessionDemoE",
  404. Message: map[string]interface{}{
  405. "temp": 27.5,
  406. "hum": 59,
  407. "ts": 1541152486823,
  408. },
  409. Timestamp: 1541152588552,
  410. },
  411. {
  412. Emitter: "sessionDemoE",
  413. Message: map[string]interface{}{
  414. "temp": 25.5,
  415. "hum": 62,
  416. "ts": 1541152489252,
  417. },
  418. Timestamp: 1541152589353,
  419. },
  420. {
  421. Emitter: "sessionDemoE",
  422. Message: map[string]interface{}{
  423. "temp": 27.4,
  424. "hum": 80,
  425. "ts": 1541152488442,
  426. },
  427. Timestamp: 1541152589854,
  428. },
  429. {
  430. Emitter: "sessionDemoE",
  431. Message: map[string]interface{}{
  432. "temp": 26.2,
  433. "hum": 63,
  434. "ts": 1541152490062,
  435. },
  436. Timestamp: 1541152590155,
  437. },
  438. {
  439. Emitter: "sessionDemoE",
  440. Message: map[string]interface{}{
  441. "temp": 28.9,
  442. "hum": 85,
  443. "ts": 1541152491682,
  444. },
  445. Timestamp: 1541152591686,
  446. },
  447. {
  448. Emitter: "sessionDemoE",
  449. Message: map[string]interface{}{
  450. "temp": 26.8,
  451. "hum": 71,
  452. "ts": 1541152490872,
  453. },
  454. Timestamp: 1541152591972,
  455. },
  456. {
  457. Emitter: "sessionDemoE",
  458. Message: map[string]interface{}{
  459. "temp": 29.1,
  460. "hum": 92,
  461. "ts": 1541152492492,
  462. },
  463. Timestamp: 1541152592592,
  464. },
  465. {
  466. Emitter: "sessionDemoE",
  467. Message: map[string]interface{}{
  468. "temp": 30.9,
  469. "hum": 87,
  470. "ts": 1541152494112,
  471. },
  472. Timestamp: 1541152594212,
  473. },
  474. {
  475. Emitter: "sessionDemoE",
  476. Message: map[string]interface{}{
  477. "temp": 32.2,
  478. "hum": 99,
  479. "ts": 1541152493202,
  480. },
  481. Timestamp: 1541152595202,
  482. },
  483. {
  484. Emitter: "sessionDemoE",
  485. Message: map[string]interface{}{
  486. "temp": 32.2,
  487. "hum": 99,
  488. "ts": 1541152499202,
  489. },
  490. Timestamp: 1541152599402,
  491. },
  492. },
  493. "demoErr": {
  494. {
  495. Emitter: "demoErr",
  496. Message: map[string]interface{}{
  497. "color": "red",
  498. "size": 3,
  499. "ts": 1541152486013,
  500. },
  501. Timestamp: 1541152486221,
  502. },
  503. {
  504. Emitter: "demoErr",
  505. Message: map[string]interface{}{
  506. "color": 2,
  507. "size": 5,
  508. "ts": 1541152487632,
  509. },
  510. Timestamp: 1541152487722,
  511. },
  512. {
  513. Emitter: "demoErr",
  514. Message: map[string]interface{}{
  515. "color": "red",
  516. "size": 1,
  517. "ts": 1541152489252,
  518. },
  519. Timestamp: 1541152489332,
  520. },
  521. { // dropped item
  522. Emitter: "demoErr",
  523. Message: map[string]interface{}{
  524. "color": "blue",
  525. "size": 6,
  526. "ts": 1541152486822,
  527. },
  528. Timestamp: 1541152489822,
  529. },
  530. {
  531. Emitter: "demoErr",
  532. Message: map[string]interface{}{
  533. "color": "yellow",
  534. "size": 4,
  535. "ts": 1541152488442,
  536. },
  537. Timestamp: 1541152490042,
  538. },
  539. { // To lift the watermark and issue all windows
  540. Emitter: "demoErr",
  541. Message: map[string]interface{}{
  542. "color": "yellow",
  543. "size": 4,
  544. "ts": 1541152492342,
  545. },
  546. Timestamp: 1541152493842,
  547. },
  548. },
  549. "ldemo": {
  550. {
  551. Emitter: "ldemo",
  552. Message: map[string]interface{}{
  553. "color": "red",
  554. "size": 3,
  555. "ts": 1541152486013,
  556. },
  557. Timestamp: 1541152486013,
  558. },
  559. {
  560. Emitter: "ldemo",
  561. Message: map[string]interface{}{
  562. "color": "blue",
  563. "size": "string",
  564. "ts": 1541152486822,
  565. },
  566. Timestamp: 1541152486822,
  567. },
  568. {
  569. Emitter: "ldemo",
  570. Message: map[string]interface{}{
  571. "size": 3,
  572. "ts": 1541152487632,
  573. },
  574. Timestamp: 1541152487632,
  575. },
  576. {
  577. Emitter: "ldemo",
  578. Message: map[string]interface{}{
  579. "color": 49,
  580. "size": 2,
  581. "ts": 1541152488442,
  582. },
  583. Timestamp: 1541152488442,
  584. },
  585. {
  586. Emitter: "ldemo",
  587. Message: map[string]interface{}{
  588. "color": "red",
  589. "ts": 1541152489252,
  590. },
  591. Timestamp: 1541152489252,
  592. },
  593. },
  594. "ldemo1": {
  595. {
  596. Emitter: "ldemo1",
  597. Message: map[string]interface{}{
  598. "temp": 25.5,
  599. "hum": 65,
  600. "ts": 1541152486013,
  601. },
  602. Timestamp: 1541152486013,
  603. },
  604. {
  605. Emitter: "ldemo1",
  606. Message: map[string]interface{}{
  607. "temp": 27.5,
  608. "hum": 59,
  609. "ts": 1541152486823,
  610. },
  611. Timestamp: 1541152486823,
  612. },
  613. {
  614. Emitter: "ldemo1",
  615. Message: map[string]interface{}{
  616. "temp": 28.1,
  617. "hum": 75,
  618. "ts": 1541152487632,
  619. },
  620. Timestamp: 1541152487632,
  621. },
  622. {
  623. Emitter: "ldemo1",
  624. Message: map[string]interface{}{
  625. "temp": 27.4,
  626. "hum": 80,
  627. "ts": "1541152488442",
  628. },
  629. Timestamp: 1541152488442,
  630. },
  631. {
  632. Emitter: "ldemo1",
  633. Message: map[string]interface{}{
  634. "temp": 25.5,
  635. "hum": 62,
  636. "ts": 1541152489252,
  637. },
  638. Timestamp: 1541152489252,
  639. },
  640. },
  641. "lsessionDemo": {
  642. {
  643. Emitter: "lsessionDemo",
  644. Message: map[string]interface{}{
  645. "temp": 25.5,
  646. "hum": 65,
  647. "ts": 1541152486013,
  648. },
  649. Timestamp: 1541152486013,
  650. },
  651. {
  652. Emitter: "lsessionDemo",
  653. Message: map[string]interface{}{
  654. "temp": 27.5,
  655. "hum": 59,
  656. "ts": 1541152486823,
  657. },
  658. Timestamp: 1541152486823,
  659. },
  660. {
  661. Emitter: "lsessionDemo",
  662. Message: map[string]interface{}{
  663. "temp": 28.1,
  664. "hum": 75,
  665. "ts": 1541152487932,
  666. },
  667. Timestamp: 1541152487932,
  668. },
  669. {
  670. Emitter: "lsessionDemo",
  671. Message: map[string]interface{}{
  672. "temp": 27.4,
  673. "hum": 80,
  674. "ts": 1541152488442,
  675. },
  676. Timestamp: 1541152488442,
  677. },
  678. {
  679. Emitter: "lsessionDemo",
  680. Message: map[string]interface{}{
  681. "temp": 25.5,
  682. "hum": 62,
  683. "ts": 1541152489252,
  684. },
  685. Timestamp: 1541152489252,
  686. },
  687. {
  688. Emitter: "lsessionDemo",
  689. Message: map[string]interface{}{
  690. "temp": 26.2,
  691. "hum": 63,
  692. "ts": 1541152490062,
  693. },
  694. Timestamp: 1541152490062,
  695. },
  696. {
  697. Emitter: "lsessionDemo",
  698. Message: map[string]interface{}{
  699. "temp": 26.8,
  700. "hum": 71,
  701. "ts": 1541152490872,
  702. },
  703. Timestamp: 1541152490872,
  704. },
  705. {
  706. Emitter: "lsessionDemo",
  707. Message: map[string]interface{}{
  708. "temp": 28.9,
  709. "hum": 85,
  710. "ts": 1541152491682,
  711. },
  712. Timestamp: 1541152491682,
  713. },
  714. {
  715. Emitter: "lsessionDemo",
  716. Message: map[string]interface{}{
  717. "temp": 29.1,
  718. "hum": 92,
  719. "ts": 1541152492492,
  720. },
  721. Timestamp: 1541152492492,
  722. },
  723. {
  724. Emitter: "lsessionDemo",
  725. Message: map[string]interface{}{
  726. "temp": 2.2,
  727. "hum": 99,
  728. "ts": 1541152493202,
  729. },
  730. Timestamp: 1541152493202,
  731. },
  732. {
  733. Emitter: "lsessionDemo",
  734. Message: map[string]interface{}{
  735. "temp": 30.9,
  736. "hum": 87,
  737. "ts": 1541152494112,
  738. },
  739. Timestamp: 1541152494112,
  740. },
  741. },
  742. "text": {
  743. {
  744. Emitter: "text",
  745. Message: map[string]interface{}{
  746. "slogan": "Impossible is nothing",
  747. "brand": "Adidas",
  748. },
  749. Timestamp: 1541152486500,
  750. },
  751. {
  752. Emitter: "text",
  753. Message: map[string]interface{}{
  754. "slogan": "Stronger than dirt",
  755. "brand": "Ajax",
  756. },
  757. Timestamp: 1541152487400,
  758. },
  759. {
  760. Emitter: "text",
  761. Message: map[string]interface{}{
  762. "slogan": "Belong anywhere",
  763. "brand": "Airbnb",
  764. },
  765. Timestamp: 1541152488300,
  766. },
  767. {
  768. Emitter: "text",
  769. Message: map[string]interface{}{
  770. "slogan": "I can'T believe I ate the whole thing",
  771. "brand": "Alka Seltzer",
  772. },
  773. Timestamp: 1541152489200,
  774. },
  775. {
  776. Emitter: "text",
  777. Message: map[string]interface{}{
  778. "slogan": "You're in good hands",
  779. "brand": "Allstate",
  780. },
  781. Timestamp: 1541152490100,
  782. },
  783. {
  784. Emitter: "text",
  785. Message: map[string]interface{}{
  786. "slogan": "Don'T leave home without it",
  787. "brand": "American Express",
  788. },
  789. Timestamp: 1541152491200,
  790. },
  791. {
  792. Emitter: "text",
  793. Message: map[string]interface{}{
  794. "slogan": "Think different",
  795. "brand": "Apple",
  796. },
  797. Timestamp: 1541152492300,
  798. },
  799. {
  800. Emitter: "text",
  801. Message: map[string]interface{}{
  802. "slogan": "We try harder",
  803. "brand": "Avis",
  804. },
  805. Timestamp: 1541152493400,
  806. },
  807. },
  808. "binDemo": {
  809. {
  810. Emitter: "binDemo",
  811. Message: map[string]interface{}{
  812. "self": Image,
  813. },
  814. Timestamp: 1541152486013,
  815. },
  816. },
  817. "fakeBin": {
  818. {
  819. Emitter: "fakeBin",
  820. Message: map[string]interface{}{
  821. "self": []byte("golang"),
  822. },
  823. Timestamp: 1541152486013,
  824. },
  825. {
  826. Emitter: "fakeBin",
  827. Message: map[string]interface{}{
  828. "self": []byte("peacock"),
  829. },
  830. Timestamp: 1541152487013,
  831. },
  832. {
  833. Emitter: "fakeBin",
  834. Message: map[string]interface{}{
  835. "self": []byte("bullfrog"),
  836. },
  837. Timestamp: 1541152488013,
  838. },
  839. },
  840. "helloStr": {
  841. {
  842. Emitter: "helloStr",
  843. Message: map[string]interface{}{
  844. "name": "world",
  845. },
  846. Timestamp: 1541152486013,
  847. },
  848. {
  849. Emitter: "helloStr",
  850. Message: map[string]interface{}{
  851. "name": "golang",
  852. },
  853. Timestamp: 1541152487013,
  854. },
  855. {
  856. Emitter: "helloStr",
  857. Message: map[string]interface{}{
  858. "name": "peacock",
  859. },
  860. Timestamp: 1541152488013,
  861. },
  862. },
  863. "commands": {
  864. {
  865. Emitter: "commands",
  866. Message: map[string]interface{}{
  867. "cmd": "get",
  868. "base64_img": "my image",
  869. "encoded_json": "{\"name\": \"name1\",\"size\": 22}",
  870. },
  871. Timestamp: 1541152486013,
  872. },
  873. {
  874. Emitter: "commands",
  875. Message: map[string]interface{}{
  876. "cmd": "detect",
  877. "base64_img": "my image",
  878. "encoded_json": "{\"name\": \"name2\",\"size\": 33}",
  879. },
  880. Timestamp: 1541152487013,
  881. },
  882. {
  883. Emitter: "commands",
  884. Message: map[string]interface{}{
  885. "cmd": "delete",
  886. "base64_img": "my image",
  887. "encoded_json": "{\"name\": \"name3\",\"size\": 11}",
  888. },
  889. Timestamp: 1541152488013,
  890. },
  891. },
  892. "demoTable": {
  893. {
  894. Emitter: "demoTable",
  895. Message: map[string]interface{}{
  896. "ts": 1541152486013,
  897. "device": "device1",
  898. },
  899. Timestamp: 1541152486501,
  900. },
  901. {
  902. Emitter: "demoTable",
  903. Message: map[string]interface{}{
  904. "ts": 1541152486822,
  905. "device": "device2",
  906. },
  907. Timestamp: 1541152486502,
  908. },
  909. {
  910. Emitter: "demoTable",
  911. Message: map[string]interface{}{
  912. "ts": 1541152487632,
  913. "device": "device3",
  914. },
  915. Timestamp: 1541152488001,
  916. },
  917. {
  918. Emitter: "demoTable",
  919. Message: map[string]interface{}{
  920. "ts": 1541152488442,
  921. "device": "device4",
  922. },
  923. Timestamp: 1541152488002,
  924. },
  925. {
  926. Emitter: "demoTable",
  927. Message: map[string]interface{}{
  928. "ts": 1541152489252,
  929. "device": "device5",
  930. },
  931. Timestamp: 1541152488003,
  932. },
  933. },
  934. "shelves": {
  935. {
  936. Emitter: "shelves",
  937. Message: map[string]interface{}{
  938. "name": "name1",
  939. "size": 2,
  940. "shelf": map[string]interface{}{
  941. "id": 1541152486013,
  942. "theme": "tandra",
  943. "subfield": "sub1",
  944. },
  945. },
  946. Timestamp: 1541152486501,
  947. },
  948. {
  949. Emitter: "shelves",
  950. Message: map[string]interface{}{
  951. "name": "name2",
  952. "size": 3,
  953. "shelf": map[string]interface{}{
  954. "id": 1541152486822,
  955. "theme": "claro",
  956. "subfield": "sub2",
  957. },
  958. },
  959. Timestamp: 1541152486502,
  960. },
  961. {
  962. Emitter: "shelves",
  963. Message: map[string]interface{}{
  964. "name": "name3",
  965. "size": 4,
  966. "shelf": map[string]interface{}{
  967. "id": 1541152487632,
  968. "theme": "dark",
  969. "subfield": "sub3",
  970. },
  971. },
  972. Timestamp: 1541152488001,
  973. },
  974. },
  975. "mes": {
  976. {
  977. Emitter: "mes",
  978. Message: map[string]interface{}{
  979. "message_id": "1541152486013",
  980. "text": "message1",
  981. },
  982. Timestamp: 1541152486501,
  983. },
  984. {
  985. Emitter: "mes",
  986. Message: map[string]interface{}{
  987. "message_id": "1541152486501",
  988. "text": "message2",
  989. },
  990. Timestamp: 1541152486501,
  991. },
  992. {
  993. Emitter: "mes",
  994. Message: map[string]interface{}{
  995. "message_id": "1541152487013",
  996. "text": "message3",
  997. },
  998. Timestamp: 1541152487501,
  999. },
  1000. },
  1001. "demoArr": {
  1002. {
  1003. Emitter: "demoArr",
  1004. Message: map[string]interface{}{
  1005. "arr": []int{1, 2, 3, 4, 5},
  1006. "x": 1,
  1007. "y": 2,
  1008. "arr2": []interface{}{
  1009. map[string]interface{}{
  1010. "a": 1,
  1011. "b": 2,
  1012. },
  1013. map[string]interface{}{
  1014. "a": 3,
  1015. "b": 4,
  1016. },
  1017. },
  1018. "a": 6,
  1019. "arr3": []interface{}{1, 2, 3},
  1020. },
  1021. Timestamp: 1541152489253,
  1022. },
  1023. },
  1024. "demoArr2": {
  1025. {
  1026. Emitter: "demoArr2",
  1027. Message: map[string]interface{}{
  1028. "arr": []interface{}{1, 2, 3, 4, 5},
  1029. "x": 1,
  1030. },
  1031. Timestamp: 1541152489253,
  1032. },
  1033. {
  1034. Emitter: "demoArr2",
  1035. Message: map[string]interface{}{
  1036. "arr": []interface{}{1, 2, 3, 4, 5},
  1037. "x": 1,
  1038. },
  1039. Timestamp: 1541152489254,
  1040. },
  1041. },
  1042. "demoE2": {
  1043. {
  1044. Emitter: "demoE2",
  1045. Message: map[string]interface{}{
  1046. "temp": 27.5,
  1047. "hum": 59,
  1048. "ts": 1541152486000,
  1049. },
  1050. Timestamp: 1541152486000,
  1051. },
  1052. {
  1053. Emitter: "demoE2",
  1054. Message: map[string]interface{}{
  1055. "temp": 25.5,
  1056. "hum": 65,
  1057. "ts": 1541152487000,
  1058. },
  1059. Timestamp: 1541152487000,
  1060. },
  1061. {
  1062. Emitter: "demoE2",
  1063. Message: map[string]interface{}{
  1064. "temp": 25.5,
  1065. "hum": 65,
  1066. "ts": 1541152488000,
  1067. },
  1068. Timestamp: 1541152488000,
  1069. },
  1070. },
  1071. "demoE3": {
  1072. {
  1073. Emitter: "demoE3",
  1074. Message: map[string]interface{}{
  1075. "temp": 26.0,
  1076. "ts": 1541152486000,
  1077. },
  1078. Timestamp: 1541152486000,
  1079. },
  1080. {
  1081. Emitter: "demoE3",
  1082. Message: map[string]interface{}{
  1083. "temp": 27.0,
  1084. "ts": 1541152487000,
  1085. },
  1086. Timestamp: 1541152487000,
  1087. },
  1088. {
  1089. Emitter: "demoE3",
  1090. Message: map[string]interface{}{
  1091. "temp": 28.0,
  1092. "ts": 1541152488000,
  1093. },
  1094. Timestamp: 1541152488000,
  1095. },
  1096. {
  1097. Emitter: "demoE3",
  1098. Message: map[string]interface{}{
  1099. "temp": 28.5,
  1100. "ts": 1541152488500,
  1101. },
  1102. Timestamp: 1541152488500,
  1103. },
  1104. {
  1105. Emitter: "demoE3",
  1106. Message: map[string]interface{}{
  1107. "temp": 29.0,
  1108. "ts": 1541152489000,
  1109. },
  1110. Timestamp: 1541152488500,
  1111. },
  1112. {
  1113. Emitter: "demoE3",
  1114. Message: map[string]interface{}{
  1115. "temp": 29.5,
  1116. "ts": 1541152489500,
  1117. },
  1118. Timestamp: 1541152489500,
  1119. },
  1120. },
  1121. "optional_commands": {
  1122. {
  1123. Emitter: "optional_commands",
  1124. Message: map[string]interface{}{
  1125. "base64_img": "my image1",
  1126. },
  1127. Timestamp: 1541152486013,
  1128. },
  1129. {
  1130. Emitter: "optional_commands",
  1131. Message: map[string]interface{}{
  1132. "base64_img": "my image2",
  1133. },
  1134. Timestamp: 1541152487013,
  1135. },
  1136. {
  1137. Emitter: "optional_commands",
  1138. Message: map[string]interface{}{
  1139. "base64_img": "my image3",
  1140. },
  1141. Timestamp: 1541152488013,
  1142. },
  1143. },
  1144. }
  1145. var Image, _ = getImg()
  1146. func getImg() ([]byte, string) {
  1147. docsFolder, err := conf.GetLoc("docs/")
  1148. if err != nil {
  1149. conf.Log.Fatalf("Cannot find docs folder: %v", err)
  1150. }
  1151. image, err := os.ReadFile(path.Join(docsFolder, "cover.jpg"))
  1152. if err != nil {
  1153. conf.Log.Fatalf("Cannot read image: %v", err)
  1154. }
  1155. b64img := base64.StdEncoding.EncodeToString(image)
  1156. return image, b64img
  1157. }