aboutsummaryrefslogtreecommitdiff
path: root/weechat/lua
diff options
context:
space:
mode:
authorNeodarZ <neodarz@neodarz.net>2017-04-04 00:02:52 +0200
committerNeodarZ <neodarz@neodarz.net>2017-04-04 00:02:52 +0200
commit1361c93f4fc25f777dada92803190ade737e8224 (patch)
treec91a2c2e04f6bcf166779010a80c8c3d4e491d43 /weechat/lua
parentab59c79c8b61d5443895d82f756a447fbebe91aa (diff)
parent139556cfa80861bd3f54f5836c5399850572c98b (diff)
downloaddotfiles_ascii-1361c93f4fc25f777dada92803190ade737e8224.tar.xz
dotfiles_ascii-1361c93f4fc25f777dada92803190ade737e8224.zip
Merge branch 'master' of ssh://git.neodarz.net/home/git/pub_repo/neodarz/scripts_shit/dotfiles_ascii
Diffstat (limited to 'weechat/lua')
l---------weechat/lua/autoload/emoji.lua1
l---------weechat/lua/autoload/matrix.lua1
-rw-r--r--weechat/lua/emoji.lua207
-rw-r--r--weechat/lua/matrix.lua3354
4 files changed, 3563 insertions, 0 deletions
diff --git a/weechat/lua/autoload/emoji.lua b/weechat/lua/autoload/emoji.lua
new file mode 120000
index 0000000..91557c7
--- /dev/null
+++ b/weechat/lua/autoload/emoji.lua
@@ -0,0 +1 @@
+../emoji.lua \ No newline at end of file
diff --git a/weechat/lua/autoload/matrix.lua b/weechat/lua/autoload/matrix.lua
new file mode 120000
index 0000000..d91a9aa
--- /dev/null
+++ b/weechat/lua/autoload/matrix.lua
@@ -0,0 +1 @@
+/home/neodarz/.weechat/lua/matrix.lua \ No newline at end of file
diff --git a/weechat/lua/emoji.lua b/weechat/lua/emoji.lua
new file mode 100644
index 0000000..75d4b44
--- /dev/null
+++ b/weechat/lua/emoji.lua
@@ -0,0 +1,207 @@
+-- Copyright 2016 xt <xt@bash.no>
+--
+-- This program is free software: you can redistribute it and/or modify
+-- it under the terms of the GNU General Public License as published by
+-- the Free Software Foundation, either version 3 of the License, or
+-- (at your option) any later version.
+--
+-- This program is distributed in the hope that it will be useful,
+-- but WITHOUT ANY WARRANTY; without even the implied warranty of
+-- MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+-- GNU General Public License for more details.
+--
+-- You should have received a copy of the GNU General Public License
+-- along with this program. If not, see <http://www.gnu.org/licenses/>.
+--
+
+
+--[[
+
+
+Emoji output/input shortcode helper for WeeChat.
+
+Usage:
+ Type :emojiname: from http://www.emoji-cheat-sheet.com/ or :partial match<tab>
+
+
+ Changelog:
+ version 3, 2016-11-04, xt
+ * add a slack specific shortcode
+ version 2, 2016-10-31, xt
+ * some cleanup
+ * ability replace incoming
+ version 1, 2016-02-29, xt
+ * initial version
+
+
+EMOJI CONVERSION SCRIPT:
+import json
+
+e = json.loads(open('emoji.json').read())
+print "emoji = {"
+emojis = []
+for k, v in e.items():
+ shortname = v['shortname'].strip(':')
+ ubytes = []
+ cps = v['unicode'].split('-')
+ for c in cps:
+ ubytes.append(unichr(int(c, 16)))
+ if shortname in ['end', 'repeat']:
+ shortname = '["%s"]' %shortname
+ elif '-' in shortname:
+ shortname = '["%s"]' %shortname
+ elif shortname[0].isdigit():
+ shortname = '["%s"]' %shortname
+ else:
+ try:
+ shortname = int(shortname)
+ shortname = '["%s"]' %shortname
+ except:
+ pass
+ emojis.append((shortname+'="'+u"".join(ubytes)+'",').encode('UTF-8'))
+print "".join(emojis)
+print "}"
+--]]
+
+local SCRIPT_NAME = "emoji"
+local SCRIPT_AUTHOR = "xt <xt@bash.no>"
+local SCRIPT_VERSION = "3"
+local SCRIPT_LICENSE = "GPL3"
+local SCRIPT_DESC = "Emoji output helper"
+
+
+-- luacheck: ignore weechat
+local w = weechat
+local emoji = {
+four="4โƒฃ",kiss_ww="๐Ÿ‘ฉโค๐Ÿ’‹๐Ÿ‘ฉ",maple_leaf="๐Ÿ",waxing_gibbous_moon="๐ŸŒ”",bike="๐Ÿšฒ",recycle="โ™ป",family_mwgb="๐Ÿ‘จ๐Ÿ‘ฉ๐Ÿ‘ง๐Ÿ‘ฆ",flag_dk="๐Ÿ‡ฉ๐Ÿ‡ฐ",thought_balloon="๐Ÿ’ญ",oncoming_automobile="๐Ÿš˜",guardsman_tone5="๐Ÿ’‚๐Ÿฟ",tickets="๐ŸŽŸ",school="๐Ÿซ",house_abandoned="๐Ÿš",blue_book="๐Ÿ“˜",video_game="๐ŸŽฎ",triumph="๐Ÿ˜ค",suspension_railway="๐ŸšŸ",umbrella="โ˜”",levitate="๐Ÿ•ด",cactus="๐ŸŒต",monorail="๐Ÿš",stars="๐ŸŒ ",new="๐Ÿ†•",herb="๐ŸŒฟ",pouting_cat="๐Ÿ˜พ",blue_heart="๐Ÿ’™",["100"]="๐Ÿ’ฏ",leaves="๐Ÿƒ",family_mwbb="๐Ÿ‘จ๐Ÿ‘ฉ๐Ÿ‘ฆ๐Ÿ‘ฆ",information_desk_person_tone2="๐Ÿ’๐Ÿผ",dragon_face="๐Ÿฒ",track_next="โญ",cloud_snow="๐ŸŒจ",flag_jp="๐Ÿ‡ฏ๐Ÿ‡ต",children_crossing="๐Ÿšธ",information_desk_person_tone1="๐Ÿ’๐Ÿป",arrow_up_down="โ†•",mount_fuji="๐Ÿ—ป",massage_tone1="๐Ÿ’†๐Ÿป",flag_mq="๐Ÿ‡ฒ๐Ÿ‡ถ",massage_tone3="๐Ÿ’†๐Ÿฝ",massage_tone2="๐Ÿ’†๐Ÿผ",massage_tone5="๐Ÿ’†๐Ÿฟ",flag_je="๐Ÿ‡ฏ๐Ÿ‡ช",flag_jm="๐Ÿ‡ฏ๐Ÿ‡ฒ",flag_jo="๐Ÿ‡ฏ๐Ÿ‡ด",red_car="๐Ÿš—",hospital="๐Ÿฅ",red_circle="๐Ÿ”ด",princess="๐Ÿ‘ธ",tm="โ„ข",curly_loop="โžฐ",boy_tone5="๐Ÿ‘ฆ๐Ÿฟ",pouch="๐Ÿ‘",boy_tone3="๐Ÿ‘ฆ๐Ÿฝ",boy_tone1="๐Ÿ‘ฆ๐Ÿป",izakaya_lantern="๐Ÿฎ",fist_tone5="โœŠ๐Ÿฟ",fist_tone4="โœŠ๐Ÿพ",fist_tone1="โœŠ๐Ÿป",fist_tone3="โœŠ๐Ÿฝ",fist_tone2="โœŠ๐Ÿผ",arrow_lower_left="โ†™",game_die="๐ŸŽฒ",pushpin="๐Ÿ“Œ",dividers="๐Ÿ—‚",dolphin="๐Ÿฌ",night_with_stars="๐ŸŒƒ",cruise_ship="๐Ÿ›ณ",white_medium_small_square="โ—ฝ",kissing_closed_eyes="๐Ÿ˜š",earth_americas="๐ŸŒŽ",["end"]="๐Ÿ”š",mouse="๐Ÿญ",rewind="โช",beach="๐Ÿ–",pizza="๐Ÿ•",briefcase="๐Ÿ’ผ",customs="๐Ÿ›ƒ",heartpulse="๐Ÿ’—",sparkler="๐ŸŽ‡",sparkles="โœจ",hand_splayed_tone1="๐Ÿ–๐Ÿป",snowman2="โ˜ƒ",tulip="๐ŸŒท",speaking_head="๐Ÿ—ฃ",ambulance="๐Ÿš‘",office="๐Ÿข",clapper="๐ŸŽฌ",keyboard="โŒจ",japan="๐Ÿ—พ",post_office="๐Ÿฃ",dizzy_face="๐Ÿ˜ต",imp="๐Ÿ‘ฟ",flag_ve="๐Ÿ‡ป๐Ÿ‡ช",coffee="โ˜•",flag_vg="๐Ÿ‡ป๐Ÿ‡ฌ",flag_va="๐Ÿ‡ป๐Ÿ‡ฆ",flag_vc="๐Ÿ‡ป๐Ÿ‡จ",flag_vn="๐Ÿ‡ป๐Ÿ‡ณ",flag_vi="๐Ÿ‡ป๐Ÿ‡ฎ",open_mouth="๐Ÿ˜ฎ",flag_vu="๐Ÿ‡ป๐Ÿ‡บ",page_with_curl="๐Ÿ“ƒ",bank="๐Ÿฆ",bread="๐Ÿž",oncoming_police_car="๐Ÿš”",capricorn="โ™‘",point_left="๐Ÿ‘ˆ",tokyo_tower="๐Ÿ—ผ",fishing_pole_and_fish="๐ŸŽฃ",thumbsdown="๐Ÿ‘Ž",telescope="๐Ÿ”ญ",spider="๐Ÿ•ท",u7121="๐Ÿˆš",camera_with_flash="๐Ÿ“ธ",lifter="๐Ÿ‹",sweet_potato="๐Ÿ ",lock_with_ink_pen="๐Ÿ”",ok_woman_tone2="๐Ÿ™†๐Ÿผ",ok_woman_tone3="๐Ÿ™†๐Ÿฝ",smirk="๐Ÿ˜",baggage_claim="๐Ÿ›„",cherry_blossom="๐ŸŒธ",sparkle="โ‡",zap="โšก",construction_site="๐Ÿ—",dancers="๐Ÿ‘ฏ",flower_playing_cards="๐ŸŽด",hatching_chick="๐Ÿฃ",free="๐Ÿ†“",bullettrain_side="๐Ÿš„",poultry_leg="๐Ÿ—",grapes="๐Ÿ‡",smirk_cat="๐Ÿ˜ผ",lollipop="๐Ÿญ",water_buffalo="๐Ÿƒ",black_medium_small_square="โ—พ",atm="๐Ÿง",gift_heart="๐Ÿ’",older_woman_tone5="๐Ÿ‘ต๐Ÿฟ",older_woman_tone4="๐Ÿ‘ต๐Ÿพ",older_woman_tone1="๐Ÿ‘ต๐Ÿป",older_woman_tone3="๐Ÿ‘ต๐Ÿฝ",older_woman_tone2="๐Ÿ‘ต๐Ÿผ",scissors="โœ‚",woman_tone2="๐Ÿ‘ฉ๐Ÿผ",basketball="๐Ÿ€",hammer_pick="โš’",top="๐Ÿ”",clock630="๐Ÿ•ก",raising_hand_tone5="๐Ÿ™‹๐Ÿฟ",railway_track="๐Ÿ›ค",nail_care="๐Ÿ’…",crossed_flags="๐ŸŽŒ",minibus="๐Ÿš",white_sun_cloud="๐ŸŒฅ",shower="๐Ÿšฟ",smile_cat="๐Ÿ˜ธ",dog2="๐Ÿ•",loud_sound="๐Ÿ”Š",kaaba="๐Ÿ•‹",runner="๐Ÿƒ",ram="๐Ÿ",writing_hand="โœ",rat="๐Ÿ€",rice_scene="๐ŸŽ‘",milky_way="๐ŸŒŒ",vulcan_tone5="๐Ÿ––๐Ÿฟ",necktie="๐Ÿ‘”",kissing_cat="๐Ÿ˜ฝ",snowflake="โ„",paintbrush="๐Ÿ–Œ",crystal_ball="๐Ÿ”ฎ",mountain_bicyclist_tone4="๐Ÿšต๐Ÿพ",mountain_bicyclist_tone3="๐Ÿšต๐Ÿฝ",mountain_bicyclist_tone2="๐Ÿšต๐Ÿผ",mountain_bicyclist_tone1="๐Ÿšต๐Ÿป",koko="๐Ÿˆ",flag_it="๐Ÿ‡ฎ๐Ÿ‡น",flag_iq="๐Ÿ‡ฎ๐Ÿ‡ถ",flag_is="๐Ÿ‡ฎ๐Ÿ‡ธ",flag_ir="๐Ÿ‡ฎ๐Ÿ‡ท",flag_im="๐Ÿ‡ฎ๐Ÿ‡ฒ",flag_il="๐Ÿ‡ฎ๐Ÿ‡ฑ",flag_io="๐Ÿ‡ฎ๐Ÿ‡ด",flag_in="๐Ÿ‡ฎ๐Ÿ‡ณ",flag_ie="๐Ÿ‡ฎ๐Ÿ‡ช",flag_id="๐Ÿ‡ฎ๐Ÿ‡ฉ",flag_ic="๐Ÿ‡ฎ๐Ÿ‡จ",ballot_box_with_check="โ˜‘",mountain_bicyclist_tone5="๐Ÿšต๐Ÿฟ",metal="๐Ÿค˜",dog="๐Ÿถ",pineapple="๐Ÿ",no_good_tone3="๐Ÿ™…๐Ÿฝ",no_good_tone2="๐Ÿ™…๐Ÿผ",no_good_tone1="๐Ÿ™…๐Ÿป",scream="๐Ÿ˜ฑ",no_good_tone5="๐Ÿ™…๐Ÿฟ",no_good_tone4="๐Ÿ™…๐Ÿพ",flag_ua="๐Ÿ‡บ๐Ÿ‡ฆ",bomb="๐Ÿ’ฃ",flag_ug="๐Ÿ‡บ๐Ÿ‡ฌ",flag_um="๐Ÿ‡บ๐Ÿ‡ฒ",flag_us="๐Ÿ‡บ๐Ÿ‡ธ",construction_worker_tone1="๐Ÿ‘ท๐Ÿป",radio="๐Ÿ“ป",flag_uy="๐Ÿ‡บ๐Ÿ‡พ",flag_uz="๐Ÿ‡บ๐Ÿ‡ฟ",person_with_blond_hair_tone1="๐Ÿ‘ฑ๐Ÿป",cupid="๐Ÿ’˜",mens="๐Ÿšน",rice="๐Ÿš",point_right_tone1="๐Ÿ‘‰๐Ÿป",point_right_tone3="๐Ÿ‘‰๐Ÿฝ",point_right_tone2="๐Ÿ‘‰๐Ÿผ",sunglasses="๐Ÿ˜Ž",point_right_tone4="๐Ÿ‘‰๐Ÿพ",watch="โŒš",frowning="๐Ÿ˜ฆ",watermelon="๐Ÿ‰",wedding="๐Ÿ’’",person_frowning_tone4="๐Ÿ™๐Ÿพ",person_frowning_tone5="๐Ÿ™๐Ÿฟ",person_frowning_tone2="๐Ÿ™๐Ÿผ",person_frowning_tone3="๐Ÿ™๐Ÿฝ",person_frowning_tone1="๐Ÿ™๐Ÿป",flag_gw="๐Ÿ‡ฌ๐Ÿ‡ผ",flag_gu="๐Ÿ‡ฌ๐Ÿ‡บ",flag_gt="๐Ÿ‡ฌ๐Ÿ‡น",flag_gs="๐Ÿ‡ฌ๐Ÿ‡ธ",flag_gr="๐Ÿ‡ฌ๐Ÿ‡ท",flag_gq="๐Ÿ‡ฌ๐Ÿ‡ถ",flag_gp="๐Ÿ‡ฌ๐Ÿ‡ต",flag_gy="๐Ÿ‡ฌ๐Ÿ‡พ",flag_gg="๐Ÿ‡ฌ๐Ÿ‡ฌ",flag_gf="๐Ÿ‡ฌ๐Ÿ‡ซ",microscope="๐Ÿ”ฌ",flag_gd="๐Ÿ‡ฌ๐Ÿ‡ฉ",flag_gb="๐Ÿ‡ฌ๐Ÿ‡ง",flag_ga="๐Ÿ‡ฌ๐Ÿ‡ฆ",flag_gn="๐Ÿ‡ฌ๐Ÿ‡ณ",flag_gm="๐Ÿ‡ฌ๐Ÿ‡ฒ",flag_gl="๐Ÿ‡ฌ๐Ÿ‡ฑ",japanese_ogre="๐Ÿ‘น",flag_gi="๐Ÿ‡ฌ๐Ÿ‡ฎ",flag_gh="๐Ÿ‡ฌ๐Ÿ‡ญ",man_with_turban="๐Ÿ‘ณ",star_and_crescent="โ˜ช",writing_hand_tone3="โœ๐Ÿฝ",dromedary_camel="๐Ÿช",hash="#โƒฃ",hammer="๐Ÿ”จ",hourglass="โŒ›",postbox="๐Ÿ“ฎ",writing_hand_tone5="โœ๐Ÿฟ",writing_hand_tone4="โœ๐Ÿพ",wc="๐Ÿšพ",aquarius="โ™’",couple_with_heart="๐Ÿ’‘",ok_woman="๐Ÿ™†",raised_hands_tone4="๐Ÿ™Œ๐Ÿพ",cop="๐Ÿ‘ฎ",raised_hands_tone1="๐Ÿ™Œ๐Ÿป",cow="๐Ÿฎ",raised_hands_tone3="๐Ÿ™Œ๐Ÿฝ",white_large_square="โฌœ",pig_nose="๐Ÿฝ",ice_skate="โ›ธ",hotsprings="โ™จ",tone5="๐Ÿฟ",three="3โƒฃ",beer="๐Ÿบ",stadium="๐ŸŸ",airplane_departure="๐Ÿ›ซ",heavy_division_sign="โž—",flag_black="๐Ÿด",mushroom="๐Ÿ„",record_button="โบ",vulcan="๐Ÿ––",dash="๐Ÿ’จ",wind_chime="๐ŸŽ",anchor="โš“",seven="7โƒฃ",flag_hr="๐Ÿ‡ญ๐Ÿ‡ท",roller_coaster="๐ŸŽข",pen_ballpoint="๐Ÿ–Š",sushi="๐Ÿฃ",flag_ht="๐Ÿ‡ญ๐Ÿ‡น",flag_hu="๐Ÿ‡ญ๐Ÿ‡บ",flag_hk="๐Ÿ‡ญ๐Ÿ‡ฐ",dizzy="๐Ÿ’ซ",flag_hn="๐Ÿ‡ญ๐Ÿ‡ณ",flag_hm="๐Ÿ‡ญ๐Ÿ‡ฒ",arrow_forward="โ–ถ",violin="๐ŸŽป",orthodox_cross="โ˜ฆ",id="๐Ÿ†”",heart_decoration="๐Ÿ’Ÿ",first_quarter_moon="๐ŸŒ“",satellite="๐Ÿ“ก",tone3="๐Ÿฝ",christmas_tree="๐ŸŽ„",unicorn="๐Ÿฆ„",broken_heart="๐Ÿ’”",ocean="๐ŸŒŠ",hearts="โ™ฅ",snowman="โ›„",person_with_blond_hair_tone4="๐Ÿ‘ฑ๐Ÿพ",person_with_blond_hair_tone5="๐Ÿ‘ฑ๐Ÿฟ",person_with_blond_hair_tone2="๐Ÿ‘ฑ๐Ÿผ",person_with_blond_hair_tone3="๐Ÿ‘ฑ๐Ÿฝ",yen="๐Ÿ’ด",straight_ruler="๐Ÿ“",sleepy="๐Ÿ˜ช",green_apple="๐Ÿ",white_medium_square="โ—ป",flag_fr="๐Ÿ‡ซ๐Ÿ‡ท",grey_exclamation="โ•",innocent="๐Ÿ˜‡",flag_fm="๐Ÿ‡ซ๐Ÿ‡ฒ",flag_fo="๐Ÿ‡ซ๐Ÿ‡ด",flag_fi="๐Ÿ‡ซ๐Ÿ‡ฎ",flag_fj="๐Ÿ‡ซ๐Ÿ‡ฏ",flag_fk="๐Ÿ‡ซ๐Ÿ‡ฐ",menorah="๐Ÿ•Ž",yin_yang="โ˜ฏ",clock130="๐Ÿ•œ",gift="๐ŸŽ",prayer_beads="๐Ÿ“ฟ",stuck_out_tongue="๐Ÿ˜›",om_symbol="๐Ÿ•‰",city_dusk="๐ŸŒ†",massage_tone4="๐Ÿ’†๐Ÿพ",couple_ww="๐Ÿ‘ฉโค๐Ÿ‘ฉ",crown="๐Ÿ‘‘",sparkling_heart="๐Ÿ’–",clubs="โ™ฃ",person_with_pouting_face="๐Ÿ™Ž",newspaper2="๐Ÿ—ž",fog="๐ŸŒซ",dango="๐Ÿก",large_orange_diamond="๐Ÿ”ถ",flag_tn="๐Ÿ‡น๐Ÿ‡ณ",flag_to="๐Ÿ‡น๐Ÿ‡ด",point_up="โ˜",flag_tm="๐Ÿ‡น๐Ÿ‡ฒ",flag_tj="๐Ÿ‡น๐Ÿ‡ฏ",flag_tk="๐Ÿ‡น๐Ÿ‡ฐ",flag_th="๐Ÿ‡น๐Ÿ‡ญ",flag_tf="๐Ÿ‡น๐Ÿ‡ซ",flag_tg="๐Ÿ‡น๐Ÿ‡ฌ",corn="๐ŸŒฝ",flag_tc="๐Ÿ‡น๐Ÿ‡จ",flag_ta="๐Ÿ‡น๐Ÿ‡ฆ",flag_tz="๐Ÿ‡น๐Ÿ‡ฟ",flag_tv="๐Ÿ‡น๐Ÿ‡ป",flag_tw="๐Ÿ‡น๐Ÿ‡ผ",flag_tt="๐Ÿ‡น๐Ÿ‡น",flag_tr="๐Ÿ‡น๐Ÿ‡ท",eight_spoked_asterisk="โœณ",trophy="๐Ÿ†",black_small_square="โ–ช",o="โญ•",no_bell="๐Ÿ”•",curry="๐Ÿ›",alembic="โš—",sob="๐Ÿ˜ญ",waxing_crescent_moon="๐ŸŒ’",tiger2="๐Ÿ…",two="2โƒฃ",sos="๐Ÿ†˜",compression="๐Ÿ—œ",heavy_multiplication_x="โœ–",tennis="๐ŸŽพ",fireworks="๐ŸŽ†",skull_crossbones="โ˜ ",astonished="๐Ÿ˜ฒ",congratulations="ใŠ—",grey_question="โ”",arrow_upper_left="โ†–",arrow_double_up="โซ",triangular_flag_on_post="๐Ÿšฉ",gemini="โ™Š",door="๐Ÿšช",ship="๐Ÿšข",point_down_tone3="๐Ÿ‘‡๐Ÿฝ",point_down_tone4="๐Ÿ‘‡๐Ÿพ",point_down_tone5="๐Ÿ‘‡๐Ÿฟ",movie_camera="๐ŸŽฅ",ng="๐Ÿ†–",couple_mm="๐Ÿ‘จโค๐Ÿ‘จ",football="๐Ÿˆ",asterisk="*โƒฃ",taurus="โ™‰",articulated_lorry="๐Ÿš›",police_car="๐Ÿš“",flushed="๐Ÿ˜ณ",spades="โ™ ",cloud_lightning="๐ŸŒฉ",wine_glass="๐Ÿท",clock830="๐Ÿ•ฃ",punch_tone2="๐Ÿ‘Š๐Ÿผ",punch_tone3="๐Ÿ‘Š๐Ÿฝ",punch_tone1="๐Ÿ‘Š๐Ÿป",department_store="๐Ÿฌ",punch_tone4="๐Ÿ‘Š๐Ÿพ",punch_tone5="๐Ÿ‘Š๐Ÿฟ",crocodile="๐ŸŠ",white_square_button="๐Ÿ”ณ",hole="๐Ÿ•ณ",boy_tone2="๐Ÿ‘ฆ๐Ÿผ",mountain_cableway="๐Ÿš ",melon="๐Ÿˆ",persevere="๐Ÿ˜ฃ",trident="๐Ÿ”ฑ",head_bandage="๐Ÿค•",u7a7a="๐Ÿˆณ",cool="๐Ÿ†’",high_brightness="๐Ÿ”†",deciduous_tree="๐ŸŒณ",white_flower="๐Ÿ’ฎ",gun="๐Ÿ”ซ",flag_sk="๐Ÿ‡ธ๐Ÿ‡ฐ",flag_sj="๐Ÿ‡ธ๐Ÿ‡ฏ",flag_si="๐Ÿ‡ธ๐Ÿ‡ฎ",flag_sh="๐Ÿ‡ธ๐Ÿ‡ญ",flag_so="๐Ÿ‡ธ๐Ÿ‡ด",flag_sn="๐Ÿ‡ธ๐Ÿ‡ณ",flag_sm="๐Ÿ‡ธ๐Ÿ‡ฒ",flag_sl="๐Ÿ‡ธ๐Ÿ‡ฑ",flag_sc="๐Ÿ‡ธ๐Ÿ‡จ",flag_sb="๐Ÿ‡ธ๐Ÿ‡ง",flag_sa="๐Ÿ‡ธ๐Ÿ‡ฆ",flag_sg="๐Ÿ‡ธ๐Ÿ‡ฌ",flag_tl="๐Ÿ‡น๐Ÿ‡ฑ",flag_se="๐Ÿ‡ธ๐Ÿ‡ช",arrow_left="โฌ…",flag_sz="๐Ÿ‡ธ๐Ÿ‡ฟ",flag_sy="๐Ÿ‡ธ๐Ÿ‡พ",small_orange_diamond="๐Ÿ”ธ",flag_ss="๐Ÿ‡ธ๐Ÿ‡ธ",flag_sr="๐Ÿ‡ธ๐Ÿ‡ท",flag_sv="๐Ÿ‡ธ๐Ÿ‡ป",flag_st="๐Ÿ‡ธ๐Ÿ‡น",file_folder="๐Ÿ“",flag_td="๐Ÿ‡น๐Ÿ‡ฉ",["1234"]="๐Ÿ”ข",smiling_imp="๐Ÿ˜ˆ",surfer_tone2="๐Ÿ„๐Ÿผ",surfer_tone3="๐Ÿ„๐Ÿฝ",surfer_tone4="๐Ÿ„๐Ÿพ",surfer_tone5="๐Ÿ„๐Ÿฟ",amphora="๐Ÿบ",baseball="โšพ",boy="๐Ÿ‘ฆ",flag_es="๐Ÿ‡ช๐Ÿ‡ธ",raised_hands="๐Ÿ™Œ",flag_eu="๐Ÿ‡ช๐Ÿ‡บ",flag_et="๐Ÿ‡ช๐Ÿ‡น",heavy_plus_sign="โž•",bow="๐Ÿ™‡",flag_ea="๐Ÿ‡ช๐Ÿ‡ฆ",flag_ec="๐Ÿ‡ช๐Ÿ‡จ",flag_ee="๐Ÿ‡ช๐Ÿ‡ช",light_rail="๐Ÿšˆ",flag_eg="๐Ÿ‡ช๐Ÿ‡ฌ",flag_eh="๐Ÿ‡ช๐Ÿ‡ญ",massage="๐Ÿ’†",man_with_gua_pi_mao_tone4="๐Ÿ‘ฒ๐Ÿพ",man_with_gua_pi_mao_tone3="๐Ÿ‘ฒ๐Ÿฝ",outbox_tray="๐Ÿ“ค",clock330="๐Ÿ•ž",projector="๐Ÿ“ฝ",sake="๐Ÿถ",confounded="๐Ÿ˜–",angry="๐Ÿ˜ ",iphone="๐Ÿ“ฑ",sweat_smile="๐Ÿ˜…",aries="โ™ˆ",ear_of_rice="๐ŸŒพ",mouse2="๐Ÿ",bicyclist_tone4="๐Ÿšด๐Ÿพ",bicyclist_tone5="๐Ÿšด๐Ÿฟ",guardsman="๐Ÿ’‚",bicyclist_tone1="๐Ÿšด๐Ÿป",bicyclist_tone2="๐Ÿšด๐Ÿผ",bicyclist_tone3="๐Ÿšด๐Ÿฝ",envelope="โœ‰",money_with_wings="๐Ÿ’ธ",beers="๐Ÿป",heart_exclamation="โฃ",notepad_spiral="๐Ÿ—’",cat="๐Ÿฑ",running_shirt_with_sash="๐ŸŽฝ",ferry="โ›ด",spy="๐Ÿ•ต",chart_with_upwards_trend="๐Ÿ“ˆ",green_heart="๐Ÿ’š",confused="๐Ÿ˜•",angel_tone4="๐Ÿ‘ผ๐Ÿพ",scorpius="โ™",sailboat="โ›ต",elephant="๐Ÿ˜",map="๐Ÿ—บ",disappointed_relieved="๐Ÿ˜ฅ",flag_xk="๐Ÿ‡ฝ๐Ÿ‡ฐ",motorway="๐Ÿ›ฃ",sun_with_face="๐ŸŒž",birthday="๐ŸŽ‚",mag="๐Ÿ”",date="๐Ÿ“…",dove="๐Ÿ•Š",man="๐Ÿ‘จ",octopus="๐Ÿ™",wheelchair="โ™ฟ",truck="๐Ÿšš",sa="๐Ÿˆ‚",shield="๐Ÿ›ก",haircut="๐Ÿ’‡",last_quarter_moon_with_face="๐ŸŒœ",rosette="๐Ÿต",currency_exchange="๐Ÿ’ฑ",mailbox_with_no_mail="๐Ÿ“ญ",bath="๐Ÿ›€",clock930="๐Ÿ•ค",bowling="๐ŸŽณ",turtle="๐Ÿข",pause_button="โธ",construction_worker="๐Ÿ‘ท",unlock="๐Ÿ”“",anger_right="๐Ÿ—ฏ",beetle="๐Ÿž",girl="๐Ÿ‘ง",sunrise="๐ŸŒ…",exclamation="โ—",flag_dz="๐Ÿ‡ฉ๐Ÿ‡ฟ",family_mmgg="๐Ÿ‘จ๐Ÿ‘จ๐Ÿ‘ง๐Ÿ‘ง",factory="๐Ÿญ",flag_do="๐Ÿ‡ฉ๐Ÿ‡ด",flag_dm="๐Ÿ‡ฉ๐Ÿ‡ฒ",flag_dj="๐Ÿ‡ฉ๐Ÿ‡ฏ",mouse_three_button="๐Ÿ–ฑ",flag_dg="๐Ÿ‡ฉ๐Ÿ‡ฌ",flag_de="๐Ÿ‡ฉ๐Ÿ‡ช",star_of_david="โœก",reminder_ribbon="๐ŸŽ—",grimacing="๐Ÿ˜ฌ",thumbsup_tone3="๐Ÿ‘๐Ÿฝ",thumbsup_tone2="๐Ÿ‘๐Ÿผ",thumbsup_tone1="๐Ÿ‘๐Ÿป",musical_note="๐ŸŽต",thumbsup_tone5="๐Ÿ‘๐Ÿฟ",thumbsup_tone4="๐Ÿ‘๐Ÿพ",high_heel="๐Ÿ‘ ",green_book="๐Ÿ“—",headphones="๐ŸŽง",flag_aw="๐Ÿ‡ฆ๐Ÿ‡ผ",stop_button="โน",yum="๐Ÿ˜‹",flag_aq="๐Ÿ‡ฆ๐Ÿ‡ถ",warning="โš ",cheese="๐Ÿง€",ophiuchus="โ›Ž",revolving_hearts="๐Ÿ’ž",one="1โƒฃ",ring="๐Ÿ’",point_right="๐Ÿ‘‰",sheep="๐Ÿ‘",bookmark="๐Ÿ”–",spider_web="๐Ÿ•ธ",eyes="๐Ÿ‘€",flag_ro="๐Ÿ‡ท๐Ÿ‡ด",flag_re="๐Ÿ‡ท๐Ÿ‡ช",flag_rs="๐Ÿ‡ท๐Ÿ‡ธ",sweat_drops="๐Ÿ’ฆ",flag_ru="๐Ÿ‡ท๐Ÿ‡บ",flag_rw="๐Ÿ‡ท๐Ÿ‡ผ",middle_finger="๐Ÿ–•",race_car="๐ŸŽ",evergreen_tree="๐ŸŒฒ",biohazard="โ˜ฃ",girl_tone3="๐Ÿ‘ง๐Ÿฝ",scream_cat="๐Ÿ™€",computer="๐Ÿ’ป",hourglass_flowing_sand="โณ",flag_lb="๐Ÿ‡ฑ๐Ÿ‡ง",tophat="๐ŸŽฉ",clock1230="๐Ÿ•ง",tractor="๐Ÿšœ",u6709="๐Ÿˆถ",u6708="๐Ÿˆท",crying_cat_face="๐Ÿ˜ฟ",angel="๐Ÿ‘ผ",ant="๐Ÿœ",information_desk_person="๐Ÿ’",anger="๐Ÿ’ข",mailbox_with_mail="๐Ÿ“ฌ",pencil2="โœ",wink="๐Ÿ˜‰",thermometer="๐ŸŒก",relaxed="โ˜บ",printer="๐Ÿ–จ",credit_card="๐Ÿ’ณ",checkered_flag="๐Ÿ",family_mmg="๐Ÿ‘จ๐Ÿ‘จ๐Ÿ‘ง",pager="๐Ÿ“Ÿ",family_mmb="๐Ÿ‘จ๐Ÿ‘จ๐Ÿ‘ฆ",radioactive="โ˜ข",fried_shrimp="๐Ÿค",link="๐Ÿ”—",walking="๐Ÿšถ",city_sunset="๐ŸŒ‡",shopping_bags="๐Ÿ›",hockey="๐Ÿ’",arrow_up="โฌ†",gem="๐Ÿ’Ž",negative_squared_cross_mark="โŽ",worried="๐Ÿ˜Ÿ",walking_tone5="๐Ÿšถ๐Ÿฟ",walking_tone1="๐Ÿšถ๐Ÿป",hear_no_evil="๐Ÿ™‰",convenience_store="๐Ÿช",seat="๐Ÿ’บ",girl_tone1="๐Ÿ‘ง๐Ÿป",cloud_rain="๐ŸŒง",girl_tone2="๐Ÿ‘ง๐Ÿผ",girl_tone5="๐Ÿ‘ง๐Ÿฟ",girl_tone4="๐Ÿ‘ง๐Ÿพ",parking="๐Ÿ…ฟ",pisces="โ™“",calendar="๐Ÿ“†",loudspeaker="๐Ÿ“ข",camping="๐Ÿ•",bicyclist="๐Ÿšด",label="๐Ÿท",diamonds="โ™ฆ",older_man_tone1="๐Ÿ‘ด๐Ÿป",older_man_tone3="๐Ÿ‘ด๐Ÿฝ",older_man_tone2="๐Ÿ‘ด๐Ÿผ",older_man_tone5="๐Ÿ‘ด๐Ÿฟ",older_man_tone4="๐Ÿ‘ด๐Ÿพ",microphone2="๐ŸŽ™",raising_hand="๐Ÿ™‹",hot_pepper="๐ŸŒถ",guitar="๐ŸŽธ",tropical_drink="๐Ÿน",upside_down="๐Ÿ™ƒ",restroom="๐Ÿšป",pen_fountain="๐Ÿ–‹",comet="โ˜„",cancer="โ™‹",jeans="๐Ÿ‘–",flag_qa="๐Ÿ‡ถ๐Ÿ‡ฆ",boar="๐Ÿ—",turkey="๐Ÿฆƒ",person_with_blond_hair="๐Ÿ‘ฑ",oden="๐Ÿข",stuck_out_tongue_closed_eyes="๐Ÿ˜",helicopter="๐Ÿš",control_knobs="๐ŸŽ›",performing_arts="๐ŸŽญ",tiger="๐Ÿฏ",foggy="๐ŸŒ",sound="๐Ÿ”‰",flag_cz="๐Ÿ‡จ๐Ÿ‡ฟ",flag_cy="๐Ÿ‡จ๐Ÿ‡พ",flag_cx="๐Ÿ‡จ๐Ÿ‡ฝ",speech_balloon="๐Ÿ’ฌ",seedling="๐ŸŒฑ",flag_cr="๐Ÿ‡จ๐Ÿ‡ท",envelope_with_arrow="๐Ÿ“ฉ",flag_cp="๐Ÿ‡จ๐Ÿ‡ต",flag_cw="๐Ÿ‡จ๐Ÿ‡ผ",flag_cv="๐Ÿ‡จ๐Ÿ‡ป",flag_cu="๐Ÿ‡จ๐Ÿ‡บ",flag_ck="๐Ÿ‡จ๐Ÿ‡ฐ",flag_ci="๐Ÿ‡จ๐Ÿ‡ฎ",flag_ch="๐Ÿ‡จ๐Ÿ‡ญ",flag_co="๐Ÿ‡จ๐Ÿ‡ด",flag_cn="๐Ÿ‡จ๐Ÿ‡ณ",flag_cm="๐Ÿ‡จ๐Ÿ‡ฒ",u5408="๐Ÿˆด",flag_cc="๐Ÿ‡จ๐Ÿ‡จ",flag_ca="๐Ÿ‡จ๐Ÿ‡ฆ",flag_cg="๐Ÿ‡จ๐Ÿ‡ฌ",flag_cf="๐Ÿ‡จ๐Ÿ‡ซ",flag_cd="๐Ÿ‡จ๐Ÿ‡ฉ",purse="๐Ÿ‘›",telephone="โ˜Ž",sleeping="๐Ÿ˜ด",point_down_tone1="๐Ÿ‘‡๐Ÿป",frowning2="โ˜น",point_down_tone2="๐Ÿ‘‡๐Ÿผ",muscle_tone4="๐Ÿ’ช๐Ÿพ",muscle_tone5="๐Ÿ’ช๐Ÿฟ",synagogue="๐Ÿ•",muscle_tone1="๐Ÿ’ช๐Ÿป",muscle_tone2="๐Ÿ’ช๐Ÿผ",muscle_tone3="๐Ÿ’ช๐Ÿฝ",clap_tone5="๐Ÿ‘๐Ÿฟ",clap_tone4="๐Ÿ‘๐Ÿพ",clap_tone1="๐Ÿ‘๐Ÿป",train2="๐Ÿš†",clap_tone2="๐Ÿ‘๐Ÿผ",oil="๐Ÿ›ข",diamond_shape_with_a_dot_inside="๐Ÿ’ ",barber="๐Ÿ’ˆ",metal_tone3="๐Ÿค˜๐Ÿฝ",ice_cream="๐Ÿจ",rowboat_tone4="๐Ÿšฃ๐Ÿพ",burrito="๐ŸŒฏ",metal_tone1="๐Ÿค˜๐Ÿป",joystick="๐Ÿ•น",rowboat_tone1="๐Ÿšฃ๐Ÿป",taxi="๐Ÿš•",u7533="๐Ÿˆธ",racehorse="๐ŸŽ",snowboarder="๐Ÿ‚",thinking="๐Ÿค”",wave_tone1="๐Ÿ‘‹๐Ÿป",wave_tone2="๐Ÿ‘‹๐Ÿผ",wave_tone3="๐Ÿ‘‹๐Ÿฝ",wave_tone4="๐Ÿ‘‹๐Ÿพ",wave_tone5="๐Ÿ‘‹๐Ÿฟ",desktop="๐Ÿ–ฅ",stopwatch="โฑ",pill="๐Ÿ’Š",skier="โ›ท",orange_book="๐Ÿ“™",dart="๐ŸŽฏ",disappointed="๐Ÿ˜ž",grin="๐Ÿ˜",place_of_worship="๐Ÿ›",japanese_goblin="๐Ÿ‘บ",arrows_counterclockwise="๐Ÿ”„",laughing="๐Ÿ˜†",clap="๐Ÿ‘",left_right_arrow="โ†”",japanese_castle="๐Ÿฏ",nail_care_tone4="๐Ÿ’…๐Ÿพ",nail_care_tone5="๐Ÿ’…๐Ÿฟ",nail_care_tone2="๐Ÿ’…๐Ÿผ",nail_care_tone3="๐Ÿ’…๐Ÿฝ",nail_care_tone1="๐Ÿ’…๐Ÿป",raised_hand_tone4="โœ‹๐Ÿพ",raised_hand_tone5="โœ‹๐Ÿฟ",raised_hand_tone1="โœ‹๐Ÿป",raised_hand_tone2="โœ‹๐Ÿผ",raised_hand_tone3="โœ‹๐Ÿฝ",point_left_tone3="๐Ÿ‘ˆ๐Ÿฝ",point_left_tone2="๐Ÿ‘ˆ๐Ÿผ",tanabata_tree="๐ŸŽ‹",point_left_tone5="๐Ÿ‘ˆ๐Ÿฟ",point_left_tone4="๐Ÿ‘ˆ๐Ÿพ",o2="๐Ÿ…พ",knife="๐Ÿ”ช",volcano="๐ŸŒ‹",kissing_heart="๐Ÿ˜˜",on="๐Ÿ”›",ok="๐Ÿ†—",package="๐Ÿ“ฆ",island="๐Ÿ",arrow_right="โžก",chart_with_downwards_trend="๐Ÿ“‰",haircut_tone3="๐Ÿ’‡๐Ÿฝ",wolf="๐Ÿบ",ox="๐Ÿ‚",dagger="๐Ÿ—ก",full_moon_with_face="๐ŸŒ",syringe="๐Ÿ’‰",flag_by="๐Ÿ‡ง๐Ÿ‡พ",flag_bz="๐Ÿ‡ง๐Ÿ‡ฟ",flag_bq="๐Ÿ‡ง๐Ÿ‡ถ",flag_br="๐Ÿ‡ง๐Ÿ‡ท",flag_bs="๐Ÿ‡ง๐Ÿ‡ธ",flag_bt="๐Ÿ‡ง๐Ÿ‡น",flag_bv="๐Ÿ‡ง๐Ÿ‡ป",flag_bw="๐Ÿ‡ง๐Ÿ‡ผ",flag_bh="๐Ÿ‡ง๐Ÿ‡ญ",flag_bi="๐Ÿ‡ง๐Ÿ‡ฎ",flag_bj="๐Ÿ‡ง๐Ÿ‡ฏ",flag_bl="๐Ÿ‡ง๐Ÿ‡ฑ",flag_bm="๐Ÿ‡ง๐Ÿ‡ฒ",flag_bn="๐Ÿ‡ง๐Ÿ‡ณ",flag_bo="๐Ÿ‡ง๐Ÿ‡ด",flag_ba="๐Ÿ‡ง๐Ÿ‡ฆ",flag_bb="๐Ÿ‡ง๐Ÿ‡ง",flag_bd="๐Ÿ‡ง๐Ÿ‡ฉ",flag_be="๐Ÿ‡ง๐Ÿ‡ช",flag_bf="๐Ÿ‡ง๐Ÿ‡ซ",flag_bg="๐Ÿ‡ง๐Ÿ‡ฌ",satellite_orbital="๐Ÿ›ฐ",radio_button="๐Ÿ”˜",arrow_heading_down="โคต",rage="๐Ÿ˜ก",whale2="๐Ÿ‹",vhs="๐Ÿ“ผ",hand_splayed_tone3="๐Ÿ–๐Ÿฝ",strawberry="๐Ÿ“",["non-potable_water"]="๐Ÿšฑ",hand_splayed_tone5="๐Ÿ–๐Ÿฟ",star2="๐ŸŒŸ",toilet="๐Ÿšฝ",ab="๐Ÿ†Ž",cinema="๐ŸŽฆ",floppy_disk="๐Ÿ’พ",princess_tone4="๐Ÿ‘ธ๐Ÿพ",princess_tone5="๐Ÿ‘ธ๐Ÿฟ",princess_tone2="๐Ÿ‘ธ๐Ÿผ",nerd="๐Ÿค“",telephone_receiver="๐Ÿ“ž",princess_tone1="๐Ÿ‘ธ๐Ÿป",arrow_double_down="โฌ",clock1030="๐Ÿ•ฅ",flag_pr="๐Ÿ‡ต๐Ÿ‡ท",flag_ps="๐Ÿ‡ต๐Ÿ‡ธ",poop="๐Ÿ’ฉ",flag_pw="๐Ÿ‡ต๐Ÿ‡ผ",flag_pt="๐Ÿ‡ต๐Ÿ‡น",flag_py="๐Ÿ‡ต๐Ÿ‡พ",pear="๐Ÿ",m="โ“‚",flag_pa="๐Ÿ‡ต๐Ÿ‡ฆ",flag_pf="๐Ÿ‡ต๐Ÿ‡ซ",flag_pg="๐Ÿ‡ต๐Ÿ‡ฌ",flag_pe="๐Ÿ‡ต๐Ÿ‡ช",flag_pk="๐Ÿ‡ต๐Ÿ‡ฐ",flag_ph="๐Ÿ‡ต๐Ÿ‡ญ",flag_pn="๐Ÿ‡ต๐Ÿ‡ณ",flag_pl="๐Ÿ‡ต๐Ÿ‡ฑ",flag_pm="๐Ÿ‡ต๐Ÿ‡ฒ",mask="๐Ÿ˜ท",hushed="๐Ÿ˜ฏ",sunrise_over_mountains="๐ŸŒ„",partly_sunny="โ›…",dollar="๐Ÿ’ต",helmet_with_cross="โ›‘",smoking="๐Ÿšฌ",no_bicycles="๐Ÿšณ",man_with_gua_pi_mao="๐Ÿ‘ฒ",tv="๐Ÿ“บ",open_hands="๐Ÿ‘",rotating_light="๐Ÿšจ",information_desk_person_tone4="๐Ÿ’๐Ÿพ",information_desk_person_tone5="๐Ÿ’๐Ÿฟ",part_alternation_mark="ใ€ฝ",pray_tone5="๐Ÿ™๐Ÿฟ",pray_tone4="๐Ÿ™๐Ÿพ",pray_tone3="๐Ÿ™๐Ÿฝ",pray_tone2="๐Ÿ™๐Ÿผ",pray_tone1="๐Ÿ™๐Ÿป",smile="๐Ÿ˜„",large_blue_circle="๐Ÿ”ต",man_tone4="๐Ÿ‘จ๐Ÿพ",man_tone5="๐Ÿ‘จ๐Ÿฟ",fax="๐Ÿ“ ",woman="๐Ÿ‘ฉ",man_tone1="๐Ÿ‘จ๐Ÿป",man_tone2="๐Ÿ‘จ๐Ÿผ",man_tone3="๐Ÿ‘จ๐Ÿฝ",eye_in_speech_bubble="๐Ÿ‘๐Ÿ—จ",blowfish="๐Ÿก",card_box="๐Ÿ—ƒ",ticket="๐ŸŽซ",ramen="๐Ÿœ",twisted_rightwards_arrows="๐Ÿ”€",swimmer_tone4="๐ŸŠ๐Ÿพ",swimmer_tone5="๐ŸŠ๐Ÿฟ",swimmer_tone1="๐ŸŠ๐Ÿป",swimmer_tone2="๐ŸŠ๐Ÿผ",swimmer_tone3="๐ŸŠ๐Ÿฝ",saxophone="๐ŸŽท",bath_tone1="๐Ÿ›€๐Ÿป",notebook_with_decorative_cover="๐Ÿ“”",bath_tone3="๐Ÿ›€๐Ÿฝ",ten="๐Ÿ”Ÿ",raising_hand_tone4="๐Ÿ™‹๐Ÿพ",tea="๐Ÿต",raising_hand_tone1="๐Ÿ™‹๐Ÿป",raising_hand_tone2="๐Ÿ™‹๐Ÿผ",raising_hand_tone3="๐Ÿ™‹๐Ÿฝ",zero="0โƒฃ",ribbon="๐ŸŽ€",santa_tone1="๐ŸŽ…๐Ÿป",abc="๐Ÿ”ค",clock="๐Ÿ•ฐ",purple_heart="๐Ÿ’œ",bow_tone1="๐Ÿ™‡๐Ÿป",no_smoking="๐Ÿšญ",flag_cl="๐Ÿ‡จ๐Ÿ‡ฑ",surfer="๐Ÿ„",newspaper="๐Ÿ“ฐ",busstop="๐Ÿš",new_moon="๐ŸŒ‘",traffic_light="๐Ÿšฅ",thumbsup="๐Ÿ‘",no_entry="โ›”",name_badge="๐Ÿ“›",classical_building="๐Ÿ›",hamster="๐Ÿน",pick="โ›",two_women_holding_hands="๐Ÿ‘ญ",family_mmbb="๐Ÿ‘จ๐Ÿ‘จ๐Ÿ‘ฆ๐Ÿ‘ฆ",family="๐Ÿ‘ช",rice_cracker="๐Ÿ˜",wind_blowing_face="๐ŸŒฌ",inbox_tray="๐Ÿ“ฅ",tired_face="๐Ÿ˜ซ",carousel_horse="๐ŸŽ ",eye="๐Ÿ‘",poodle="๐Ÿฉ",chestnut="๐ŸŒฐ",slight_smile="๐Ÿ™‚",mailbox_closed="๐Ÿ“ช",cloud_tornado="๐ŸŒช",jack_o_lantern="๐ŸŽƒ",lifter_tone3="๐Ÿ‹๐Ÿฝ",lifter_tone2="๐Ÿ‹๐Ÿผ",lifter_tone1="๐Ÿ‹๐Ÿป",lifter_tone5="๐Ÿ‹๐Ÿฟ",lifter_tone4="๐Ÿ‹๐Ÿพ",nine="9โƒฃ",chocolate_bar="๐Ÿซ",v="โœŒ",man_with_turban_tone4="๐Ÿ‘ณ๐Ÿพ",man_with_turban_tone5="๐Ÿ‘ณ๐Ÿฟ",man_with_turban_tone2="๐Ÿ‘ณ๐Ÿผ",man_with_turban_tone3="๐Ÿ‘ณ๐Ÿฝ",man_with_turban_tone1="๐Ÿ‘ณ๐Ÿป",family_wwbb="๐Ÿ‘ฉ๐Ÿ‘ฉ๐Ÿ‘ฆ๐Ÿ‘ฆ",hamburger="๐Ÿ”",accept="๐Ÿ‰‘",airplane="โœˆ",dress="๐Ÿ‘—",speedboat="๐Ÿšค",ledger="๐Ÿ“’",goat="๐Ÿ",flag_ae="๐Ÿ‡ฆ๐Ÿ‡ช",flag_ad="๐Ÿ‡ฆ๐Ÿ‡ฉ",flag_ag="๐Ÿ‡ฆ๐Ÿ‡ฌ",flag_af="๐Ÿ‡ฆ๐Ÿ‡ซ",flag_ac="๐Ÿ‡ฆ๐Ÿ‡จ",flag_am="๐Ÿ‡ฆ๐Ÿ‡ฒ",flag_al="๐Ÿ‡ฆ๐Ÿ‡ฑ",flag_ao="๐Ÿ‡ฆ๐Ÿ‡ด",flag_ai="๐Ÿ‡ฆ๐Ÿ‡ฎ",flag_au="๐Ÿ‡ฆ๐Ÿ‡บ",flag_at="๐Ÿ‡ฆ๐Ÿ‡น",fork_and_knife="๐Ÿด",fast_forward="โฉ",flag_as="๐Ÿ‡ฆ๐Ÿ‡ธ",flag_ar="๐Ÿ‡ฆ๐Ÿ‡ท",cow2="๐Ÿ„",flag_ax="๐Ÿ‡ฆ๐Ÿ‡ฝ",flag_az="๐Ÿ‡ฆ๐Ÿ‡ฟ",a="๐Ÿ…ฐ",volleyball="๐Ÿ",dragon="๐Ÿ‰",wrench="๐Ÿ”ง",point_up_2="๐Ÿ‘†",egg="๐Ÿณ",small_red_triangle="๐Ÿ”บ",soon="๐Ÿ”œ",bow_tone4="๐Ÿ™‡๐Ÿพ",joy_cat="๐Ÿ˜น",pray="๐Ÿ™",dark_sunglasses="๐Ÿ•ถ",rugby_football="๐Ÿ‰",soccer="โšฝ",dolls="๐ŸŽŽ",monkey_face="๐Ÿต",clap_tone3="๐Ÿ‘๐Ÿฝ",bar_chart="๐Ÿ“Š",european_castle="๐Ÿฐ",military_medal="๐ŸŽ–",frame_photo="๐Ÿ–ผ",rice_ball="๐Ÿ™",trolleybus="๐ŸšŽ",older_woman="๐Ÿ‘ต",information_source="โ„น",postal_horn="๐Ÿ“ฏ",house="๐Ÿ ",fish="๐ŸŸ",bride_with_veil="๐Ÿ‘ฐ",fist="โœŠ",lipstick="๐Ÿ’„",fountain="โ›ฒ",cyclone="๐ŸŒ€",thumbsdown_tone2="๐Ÿ‘Ž๐Ÿผ",thumbsdown_tone3="๐Ÿ‘Ž๐Ÿฝ",thumbsdown_tone1="๐Ÿ‘Ž๐Ÿป",thumbsdown_tone4="๐Ÿ‘Ž๐Ÿพ",thumbsdown_tone5="๐Ÿ‘Ž๐Ÿฟ",cookie="๐Ÿช",heartbeat="๐Ÿ’“",blush="๐Ÿ˜Š",fire_engine="๐Ÿš’",feet="๐Ÿพ",horse="๐Ÿด",blossom="๐ŸŒผ",crossed_swords="โš”",station="๐Ÿš‰",clock730="๐Ÿ•ข",banana="๐ŸŒ",relieved="๐Ÿ˜Œ",hotel="๐Ÿจ",park="๐Ÿž",aerial_tramway="๐Ÿšก",flag_sd="๐Ÿ‡ธ๐Ÿ‡ฉ",panda_face="๐Ÿผ",b="๐Ÿ…ฑ",flag_sx="๐Ÿ‡ธ๐Ÿ‡ฝ",six_pointed_star="๐Ÿ”ฏ",shaved_ice="๐Ÿง",chipmunk="๐Ÿฟ",mountain="โ›ฐ",koala="๐Ÿจ",white_small_square="โ–ซ",open_hands_tone2="๐Ÿ‘๐Ÿผ",open_hands_tone3="๐Ÿ‘๐Ÿฝ",u55b6="๐Ÿˆบ",open_hands_tone1="๐Ÿ‘๐Ÿป",open_hands_tone4="๐Ÿ‘๐Ÿพ",open_hands_tone5="๐Ÿ‘๐Ÿฟ",baby_tone5="๐Ÿ‘ถ๐Ÿฟ",baby_tone4="๐Ÿ‘ถ๐Ÿพ",baby_tone3="๐Ÿ‘ถ๐Ÿฝ",baby_tone2="๐Ÿ‘ถ๐Ÿผ",baby_tone1="๐Ÿ‘ถ๐Ÿป",chart="๐Ÿ’น",beach_umbrella="โ›ฑ",basketball_player_tone5="โ›น๐Ÿฟ",basketball_player_tone4="โ›น๐Ÿพ",basketball_player_tone1="โ›น๐Ÿป",basketball_player_tone3="โ›น๐Ÿฝ",basketball_player_tone2="โ›น๐Ÿผ",mans_shoe="๐Ÿ‘ž",shinto_shrine="โ›ฉ",ideograph_advantage="๐Ÿ‰",airplane_arriving="๐Ÿ›ฌ",golf="โ›ณ",minidisc="๐Ÿ’ฝ",hugging="๐Ÿค—",crayon="๐Ÿ–",point_down="๐Ÿ‘‡",copyright="ยฉ",person_with_pouting_face_tone2="๐Ÿ™Ž๐Ÿผ",person_with_pouting_face_tone3="๐Ÿ™Ž๐Ÿฝ",person_with_pouting_face_tone1="๐Ÿ™Ž๐Ÿป",person_with_pouting_face_tone4="๐Ÿ™Ž๐Ÿพ",person_with_pouting_face_tone5="๐Ÿ™Ž๐Ÿฟ",busts_in_silhouette="๐Ÿ‘ฅ",alarm_clock="โฐ",couplekiss="๐Ÿ’",circus_tent="๐ŸŽช",sunny="โ˜€",incoming_envelope="๐Ÿ“จ",yellow_heart="๐Ÿ’›",cry="๐Ÿ˜ข",x="โŒ",arrow_up_small="๐Ÿ”ผ",art="๐ŸŽจ",surfer_tone1="๐Ÿ„๐Ÿป",bride_with_veil_tone4="๐Ÿ‘ฐ๐Ÿพ",bride_with_veil_tone5="๐Ÿ‘ฐ๐Ÿฟ",bride_with_veil_tone2="๐Ÿ‘ฐ๐Ÿผ",bride_with_veil_tone3="๐Ÿ‘ฐ๐Ÿฝ",bride_with_veil_tone1="๐Ÿ‘ฐ๐Ÿป",hibiscus="๐ŸŒบ",black_joker="๐Ÿƒ",raised_hand="โœ‹",no_mouth="๐Ÿ˜ถ",basketball_player="โ›น",champagne="๐Ÿพ",no_entry_sign="๐Ÿšซ",older_man="๐Ÿ‘ด",moyai="๐Ÿ—ฟ",mailbox="๐Ÿ“ซ",slight_frown="๐Ÿ™",statue_of_liberty="๐Ÿ—ฝ",mega="๐Ÿ“ฃ",eggplant="๐Ÿ†",rose="๐ŸŒน",bell="๐Ÿ””",battery="๐Ÿ”‹",wastebasket="๐Ÿ—‘",dancer="๐Ÿ’ƒ",page_facing_up="๐Ÿ“„",church="โ›ช",underage="๐Ÿ”ž",secret="ใŠ™",clock430="๐Ÿ•Ÿ",fork_knife_plate="๐Ÿฝ",u7981="๐Ÿˆฒ",fire="๐Ÿ”ฅ",cold_sweat="๐Ÿ˜ฐ",flag_er="๐Ÿ‡ช๐Ÿ‡ท",family_mwgg="๐Ÿ‘จ๐Ÿ‘ฉ๐Ÿ‘ง๐Ÿ‘ง",heart_eyes="๐Ÿ˜",guardsman_tone1="๐Ÿ’‚๐Ÿป",guardsman_tone2="๐Ÿ’‚๐Ÿผ",guardsman_tone3="๐Ÿ’‚๐Ÿฝ",guardsman_tone4="๐Ÿ’‚๐Ÿพ",earth_africa="๐ŸŒ",arrow_right_hook="โ†ช",spy_tone2="๐Ÿ•ต๐Ÿผ",closed_umbrella="๐ŸŒ‚",bikini="๐Ÿ‘™",vertical_traffic_light="๐Ÿšฆ",kissing="๐Ÿ˜—",loop="โžฟ",potable_water="๐Ÿšฐ",pound="๐Ÿ’ท",["fleur-de-lis"]="โšœ",key2="๐Ÿ—",heavy_dollar_sign="๐Ÿ’ฒ",shamrock="โ˜˜",boy_tone4="๐Ÿ‘ฆ๐Ÿพ",shirt="๐Ÿ‘•",kimono="๐Ÿ‘˜",left_luggage="๐Ÿ›…",meat_on_bone="๐Ÿ–",ok_woman_tone4="๐Ÿ™†๐Ÿพ",ok_woman_tone5="๐Ÿ™†๐Ÿฟ",arrow_heading_up="โคด",calendar_spiral="๐Ÿ—“",snail="๐ŸŒ",ok_woman_tone1="๐Ÿ™†๐Ÿป",arrow_down_small="๐Ÿ”ฝ",leopard="๐Ÿ†",paperclips="๐Ÿ–‡",cityscape="๐Ÿ™",woman_tone1="๐Ÿ‘ฉ๐Ÿป",slot_machine="๐ŸŽฐ",woman_tone3="๐Ÿ‘ฉ๐Ÿฝ",woman_tone4="๐Ÿ‘ฉ๐Ÿพ",woman_tone5="๐Ÿ‘ฉ๐Ÿฟ",euro="๐Ÿ’ถ",musical_score="๐ŸŽผ",triangular_ruler="๐Ÿ“",flags="๐ŸŽ",five="5โƒฃ",love_hotel="๐Ÿฉ",hotdog="๐ŸŒญ",speak_no_evil="๐Ÿ™Š",eyeglasses="๐Ÿ‘“",dancer_tone4="๐Ÿ’ƒ๐Ÿพ",dancer_tone5="๐Ÿ’ƒ๐Ÿฟ",vulcan_tone4="๐Ÿ––๐Ÿพ",bridge_at_night="๐ŸŒ‰",writing_hand_tone1="โœ๐Ÿป",couch="๐Ÿ›‹",vulcan_tone1="๐Ÿ––๐Ÿป",vulcan_tone2="๐Ÿ––๐Ÿผ",vulcan_tone3="๐Ÿ––๐Ÿฝ",womans_hat="๐Ÿ‘’",sandal="๐Ÿ‘ก",cherries="๐Ÿ’",full_moon="๐ŸŒ•",flag_om="๐Ÿ‡ด๐Ÿ‡ฒ",play_pause="โฏ",couple="๐Ÿ‘ซ",money_mouth="๐Ÿค‘",womans_clothes="๐Ÿ‘š",globe_with_meridians="๐ŸŒ",bath_tone5="๐Ÿ›€๐Ÿฟ",bangbang="โ€ผ",stuck_out_tongue_winking_eye="๐Ÿ˜œ",heart="โค",bamboo="๐ŸŽ",mahjong="๐Ÿ€„",waning_gibbous_moon="๐ŸŒ–",back="๐Ÿ”™",point_up_2_tone4="๐Ÿ‘†๐Ÿพ",point_up_2_tone5="๐Ÿ‘†๐Ÿฟ",lips="๐Ÿ‘„",point_up_2_tone1="๐Ÿ‘†๐Ÿป",point_up_2_tone2="๐Ÿ‘†๐Ÿผ",point_up_2_tone3="๐Ÿ‘†๐Ÿฝ",candle="๐Ÿ•ฏ",middle_finger_tone3="๐Ÿ–•๐Ÿฝ",middle_finger_tone2="๐Ÿ–•๐Ÿผ",middle_finger_tone1="๐Ÿ–•๐Ÿป",middle_finger_tone5="๐Ÿ–•๐Ÿฟ",middle_finger_tone4="๐Ÿ–•๐Ÿพ",heavy_minus_sign="โž–",nose="๐Ÿ‘ƒ",zzz="๐Ÿ’ค",stew="๐Ÿฒ",santa="๐ŸŽ…",tropical_fish="๐Ÿ ",point_up_tone1="โ˜๐Ÿป",point_up_tone3="โ˜๐Ÿฝ",point_up_tone2="โ˜๐Ÿผ",point_up_tone5="โ˜๐Ÿฟ",point_up_tone4="โ˜๐Ÿพ",field_hockey="๐Ÿ‘",school_satchel="๐ŸŽ’",womens="๐Ÿšบ",baby_symbol="๐Ÿšผ",baby_chick="๐Ÿค",ok_hand_tone2="๐Ÿ‘Œ๐Ÿผ",ok_hand_tone3="๐Ÿ‘Œ๐Ÿฝ",ok_hand_tone1="๐Ÿ‘Œ๐Ÿป",ok_hand_tone4="๐Ÿ‘Œ๐Ÿพ",ok_hand_tone5="๐Ÿ‘Œ๐Ÿฟ",family_mmgb="๐Ÿ‘จ๐Ÿ‘จ๐Ÿ‘ง๐Ÿ‘ฆ",last_quarter_moon="๐ŸŒ—",tada="๐ŸŽ‰",clock530="๐Ÿ• ",question="โ“",registered="ยฎ",level_slider="๐ŸŽš",black_circle="โšซ",atom="โš›",penguin="๐Ÿง",electric_plug="๐Ÿ”Œ",skull="๐Ÿ’€",kiss_mm="๐Ÿ‘จโค๐Ÿ’‹๐Ÿ‘จ",walking_tone4="๐Ÿšถ๐Ÿพ",fries="๐ŸŸ",up="๐Ÿ†™",walking_tone3="๐Ÿšถ๐Ÿฝ",walking_tone2="๐Ÿšถ๐Ÿผ",athletic_shoe="๐Ÿ‘Ÿ",hatched_chick="๐Ÿฅ",black_nib="โœ’",black_large_square="โฌ›",bow_and_arrow="๐Ÿน",rainbow="๐ŸŒˆ",metal_tone5="๐Ÿค˜๐Ÿฟ",metal_tone4="๐Ÿค˜๐Ÿพ",lemon="๐Ÿ‹",metal_tone2="๐Ÿค˜๐Ÿผ",peach="๐Ÿ‘",peace="โ˜ฎ",steam_locomotive="๐Ÿš‚",oncoming_bus="๐Ÿš",heart_eyes_cat="๐Ÿ˜ป",smiley="๐Ÿ˜ƒ",haircut_tone1="๐Ÿ’‡๐Ÿป",haircut_tone2="๐Ÿ’‡๐Ÿผ",u6e80="๐Ÿˆต",haircut_tone4="๐Ÿ’‡๐Ÿพ",haircut_tone5="๐Ÿ’‡๐Ÿฟ",black_medium_square="โ—ผ",closed_book="๐Ÿ“•",desert="๐Ÿœ",expressionless="๐Ÿ˜‘",dvd="๐Ÿ“€",construction_worker_tone2="๐Ÿ‘ท๐Ÿผ",construction_worker_tone3="๐Ÿ‘ท๐Ÿฝ",construction_worker_tone4="๐Ÿ‘ท๐Ÿพ",construction_worker_tone5="๐Ÿ‘ท๐Ÿฟ",mag_right="๐Ÿ”Ž",bento="๐Ÿฑ",scroll="๐Ÿ“œ",flag_nl="๐Ÿ‡ณ๐Ÿ‡ฑ",flag_no="๐Ÿ‡ณ๐Ÿ‡ด",flag_ni="๐Ÿ‡ณ๐Ÿ‡ฎ",european_post_office="๐Ÿค",flag_ne="๐Ÿ‡ณ๐Ÿ‡ช",flag_nf="๐Ÿ‡ณ๐Ÿ‡ซ",flag_ng="๐Ÿ‡ณ๐Ÿ‡ฌ",flag_na="๐Ÿ‡ณ๐Ÿ‡ฆ",flag_nc="๐Ÿ‡ณ๐Ÿ‡จ",alien="๐Ÿ‘ฝ",first_quarter_moon_with_face="๐ŸŒ›",flag_nz="๐Ÿ‡ณ๐Ÿ‡ฟ",flag_nu="๐Ÿ‡ณ๐Ÿ‡บ",golfer="๐ŸŒ",flag_np="๐Ÿ‡ณ๐Ÿ‡ต",flag_nr="๐Ÿ‡ณ๐Ÿ‡ท",anguished="๐Ÿ˜ง",mosque="๐Ÿ•Œ",point_left_tone1="๐Ÿ‘ˆ๐Ÿป",ear_tone1="๐Ÿ‘‚๐Ÿป",ear_tone2="๐Ÿ‘‚๐Ÿผ",ear_tone3="๐Ÿ‘‚๐Ÿฝ",ear_tone4="๐Ÿ‘‚๐Ÿพ",ear_tone5="๐Ÿ‘‚๐Ÿฟ",eight_pointed_black_star="โœด",wave="๐Ÿ‘‹",runner_tone5="๐Ÿƒ๐Ÿฟ",runner_tone4="๐Ÿƒ๐Ÿพ",runner_tone3="๐Ÿƒ๐Ÿฝ",runner_tone2="๐Ÿƒ๐Ÿผ",runner_tone1="๐Ÿƒ๐Ÿป",railway_car="๐Ÿšƒ",notes="๐ŸŽถ",no_good="๐Ÿ™…",trackball="๐Ÿ–ฒ",spaghetti="๐Ÿ",love_letter="๐Ÿ’Œ",clipboard="๐Ÿ“‹",baby_bottle="๐Ÿผ",bird="๐Ÿฆ",card_index="๐Ÿ“‡",punch="๐Ÿ‘Š",leo="โ™Œ",house_with_garden="๐Ÿก",family_wwgg="๐Ÿ‘ฉ๐Ÿ‘ฉ๐Ÿ‘ง๐Ÿ‘ง",family_wwgb="๐Ÿ‘ฉ๐Ÿ‘ฉ๐Ÿ‘ง๐Ÿ‘ฆ",see_no_evil="๐Ÿ™ˆ",metro="๐Ÿš‡",popcorn="๐Ÿฟ",apple="๐ŸŽ",scales="โš–",sleeping_accommodation="๐Ÿ›Œ",clock230="๐Ÿ•",tools="๐Ÿ› ",cloud="โ˜",honey_pot="๐Ÿฏ",ballot_box="๐Ÿ—ณ",frog="๐Ÿธ",camera="๐Ÿ“ท",crab="๐Ÿฆ€",video_camera="๐Ÿ“น",pencil="๐Ÿ“",thunder_cloud_rain="โ›ˆ",mountain_bicyclist="๐Ÿšต",tangerine="๐ŸŠ",train="๐Ÿš‹",rabbit="๐Ÿฐ",baby="๐Ÿ‘ถ",palm_tree="๐ŸŒด",capital_abcd="๐Ÿ” ",put_litter_in_its_place="๐Ÿšฎ",coffin="โšฐ",abcd="๐Ÿ”ก",lock="๐Ÿ”’",pig2="๐Ÿ–",family_mwg="๐Ÿ‘จ๐Ÿ‘ฉ๐Ÿ‘ง",point_right_tone5="๐Ÿ‘‰๐Ÿฟ",trumpet="๐ŸŽบ",film_frames="๐ŸŽž",six="6โƒฃ",leftwards_arrow_with_hook="โ†ฉ",earth_asia="๐ŸŒ",heavy_check_mark="โœ”",notebook="๐Ÿ““",taco="๐ŸŒฎ",tomato="๐Ÿ…",robot="๐Ÿค–",mute="๐Ÿ”‡",symbols="๐Ÿ”ฃ",motorcycle="๐Ÿ",thermometer_face="๐Ÿค’",paperclip="๐Ÿ“Ž",moneybag="๐Ÿ’ฐ",neutral_face="๐Ÿ˜",white_sun_rain_cloud="๐ŸŒฆ",snake="๐Ÿ",kiss="๐Ÿ’‹",blue_car="๐Ÿš™",confetti_ball="๐ŸŽŠ",tram="๐ŸšŠ",repeat_one="๐Ÿ”‚",smiley_cat="๐Ÿ˜บ",beginner="๐Ÿ”ฐ",mobile_phone_off="๐Ÿ“ด",books="๐Ÿ“š",["8ball"]="๐ŸŽฑ",cocktail="๐Ÿธ",flag_ge="๐Ÿ‡ฌ๐Ÿ‡ช",horse_racing_tone2="๐Ÿ‡๐Ÿผ",flag_mh="๐Ÿ‡ฒ๐Ÿ‡ญ",flag_mk="๐Ÿ‡ฒ๐Ÿ‡ฐ",flag_mm="๐Ÿ‡ฒ๐Ÿ‡ฒ",flag_ml="๐Ÿ‡ฒ๐Ÿ‡ฑ",flag_mo="๐Ÿ‡ฒ๐Ÿ‡ด",flag_mn="๐Ÿ‡ฒ๐Ÿ‡ณ",flag_ma="๐Ÿ‡ฒ๐Ÿ‡ฆ",flag_mc="๐Ÿ‡ฒ๐Ÿ‡จ",flag_me="๐Ÿ‡ฒ๐Ÿ‡ช",flag_md="๐Ÿ‡ฒ๐Ÿ‡ฉ",flag_mg="๐Ÿ‡ฒ๐Ÿ‡ฌ",flag_mf="๐Ÿ‡ฒ๐Ÿ‡ซ",flag_my="๐Ÿ‡ฒ๐Ÿ‡พ",flag_mx="๐Ÿ‡ฒ๐Ÿ‡ฝ",flag_mz="๐Ÿ‡ฒ๐Ÿ‡ฟ",mountain_snow="๐Ÿ”",flag_mp="๐Ÿ‡ฒ๐Ÿ‡ต",flag_ms="๐Ÿ‡ฒ๐Ÿ‡ธ",flag_mr="๐Ÿ‡ฒ๐Ÿ‡ท",flag_mu="๐Ÿ‡ฒ๐Ÿ‡บ",flag_mt="๐Ÿ‡ฒ๐Ÿ‡น",flag_mw="๐Ÿ‡ฒ๐Ÿ‡ผ",flag_mv="๐Ÿ‡ฒ๐Ÿ‡ป",timer="โฒ",passport_control="๐Ÿ›‚",small_blue_diamond="๐Ÿ”น",lion_face="๐Ÿฆ",white_check_mark="โœ…",bouquet="๐Ÿ’",track_previous="โฎ",monkey="๐Ÿ’",tone4="๐Ÿพ",closed_lock_with_key="๐Ÿ”",family_wwb="๐Ÿ‘ฉ๐Ÿ‘ฉ๐Ÿ‘ฆ",family_wwg="๐Ÿ‘ฉ๐Ÿ‘ฉ๐Ÿ‘ง",tone1="๐Ÿป",crescent_moon="๐ŸŒ™",shell="๐Ÿš",gear="โš™",tone2="๐Ÿผ",small_red_triangle_down="๐Ÿ”ป",nut_and_bolt="๐Ÿ”ฉ",umbrella2="โ˜‚",unamused="๐Ÿ˜’",fuelpump="โ›ฝ",bed="๐Ÿ›",bee="๐Ÿ",round_pushpin="๐Ÿ“",flag_white="๐Ÿณ",microphone="๐ŸŽค",bus="๐ŸšŒ",eight="8โƒฃ",handbag="๐Ÿ‘œ",medal="๐Ÿ…",arrows_clockwise="๐Ÿ”ƒ",urn="โšฑ",bookmark_tabs="๐Ÿ“‘",new_moon_with_face="๐ŸŒš",fallen_leaf="๐Ÿ‚",horse_racing="๐Ÿ‡",chicken="๐Ÿ”",ear="๐Ÿ‘‚",wheel_of_dharma="โ˜ธ",arrow_lower_right="โ†˜",man_with_gua_pi_mao_tone5="๐Ÿ‘ฒ๐Ÿฟ",scorpion="๐Ÿฆ‚",waning_crescent_moon="๐ŸŒ˜",man_with_gua_pi_mao_tone2="๐Ÿ‘ฒ๐Ÿผ",man_with_gua_pi_mao_tone1="๐Ÿ‘ฒ๐Ÿป",bug="๐Ÿ›",virgo="โ™",libra="โ™Ž",angel_tone1="๐Ÿ‘ผ๐Ÿป",angel_tone3="๐Ÿ‘ผ๐Ÿฝ",angel_tone2="๐Ÿ‘ผ๐Ÿผ",angel_tone5="๐Ÿ‘ผ๐Ÿฟ",sagittarius="โ™",bear="๐Ÿป",information_desk_person_tone3="๐Ÿ’๐Ÿฝ",no_mobile_phones="๐Ÿ“ต",hand_splayed="๐Ÿ–",motorboat="๐Ÿ›ฅ",calling="๐Ÿ“ฒ",interrobang="โ‰",oncoming_taxi="๐Ÿš–",flag_lt="๐Ÿ‡ฑ๐Ÿ‡น",flag_lu="๐Ÿ‡ฑ๐Ÿ‡บ",flag_lr="๐Ÿ‡ฑ๐Ÿ‡ท",flag_ls="๐Ÿ‡ฑ๐Ÿ‡ธ",flag_ly="๐Ÿ‡ฑ๐Ÿ‡พ",bellhop="๐Ÿ›Ž",arrow_down="โฌ‡",flag_lc="๐Ÿ‡ฑ๐Ÿ‡จ",flag_la="๐Ÿ‡ฑ๐Ÿ‡ฆ",flag_lk="๐Ÿ‡ฑ๐Ÿ‡ฐ",flag_li="๐Ÿ‡ฑ๐Ÿ‡ฎ",ferris_wheel="๐ŸŽก",hand_splayed_tone2="๐Ÿ–๐Ÿผ",large_blue_diamond="๐Ÿ”ท",cat2="๐Ÿˆ",icecream="๐Ÿฆ",tent="โ›บ",joy="๐Ÿ˜‚",hand_splayed_tone4="๐Ÿ–๐Ÿพ",file_cabinet="๐Ÿ—„",key="๐Ÿ”‘",weary="๐Ÿ˜ฉ",bath_tone2="๐Ÿ›€๐Ÿผ",flag_lv="๐Ÿ‡ฑ๐Ÿ‡ป",low_brightness="๐Ÿ”…",rowboat_tone5="๐Ÿšฃ๐Ÿฟ",rowboat_tone2="๐Ÿšฃ๐Ÿผ",rowboat_tone3="๐Ÿšฃ๐Ÿฝ",four_leaf_clover="๐Ÿ€",space_invader="๐Ÿ‘พ",cl="๐Ÿ†‘",cd="๐Ÿ’ฟ",bath_tone4="๐Ÿ›€๐Ÿพ",flag_za="๐Ÿ‡ฟ๐Ÿ‡ฆ",swimmer="๐ŸŠ",wavy_dash="ใ€ฐ",flag_zm="๐Ÿ‡ฟ๐Ÿ‡ฒ",flag_zw="๐Ÿ‡ฟ๐Ÿ‡ผ",raised_hands_tone5="๐Ÿ™Œ๐Ÿฟ",two_hearts="๐Ÿ’•",bulb="๐Ÿ’ก",cop_tone4="๐Ÿ‘ฎ๐Ÿพ",cop_tone5="๐Ÿ‘ฎ๐Ÿฟ",cop_tone2="๐Ÿ‘ฎ๐Ÿผ",cop_tone3="๐Ÿ‘ฎ๐Ÿฝ",cop_tone1="๐Ÿ‘ฎ๐Ÿป",open_file_folder="๐Ÿ“‚",homes="๐Ÿ˜",raised_hands_tone2="๐Ÿ™Œ๐Ÿผ",fearful="๐Ÿ˜จ",grinning="๐Ÿ˜€",bow_tone5="๐Ÿ™‡๐Ÿฟ",santa_tone3="๐ŸŽ…๐Ÿฝ",santa_tone2="๐ŸŽ…๐Ÿผ",santa_tone5="๐ŸŽ…๐Ÿฟ",santa_tone4="๐ŸŽ…๐Ÿพ",bow_tone2="๐Ÿ™‡๐Ÿผ",bow_tone3="๐Ÿ™‡๐Ÿฝ",bathtub="๐Ÿ›",ping_pong="๐Ÿ“",u5272="๐Ÿˆน",rooster="๐Ÿ“",vs="๐Ÿ†š",bullettrain_front="๐Ÿš…",airplane_small="๐Ÿ›ฉ",white_circle="โšช",balloon="๐ŸŽˆ",cross="โœ",princess_tone3="๐Ÿ‘ธ๐Ÿฝ",speaker="๐Ÿ”ˆ",zipper_mouth="๐Ÿค",u6307="๐Ÿˆฏ",whale="๐Ÿณ",pensive="๐Ÿ˜”",signal_strength="๐Ÿ“ถ",muscle="๐Ÿ’ช",rocket="๐Ÿš€",camel="๐Ÿซ",boot="๐Ÿ‘ข",flashlight="๐Ÿ”ฆ",spy_tone4="๐Ÿ•ต๐Ÿพ",spy_tone5="๐Ÿ•ต๐Ÿฟ",ski="๐ŸŽฟ",spy_tone3="๐Ÿ•ต๐Ÿฝ",musical_keyboard="๐ŸŽน",spy_tone1="๐Ÿ•ต๐Ÿป",rolling_eyes="๐Ÿ™„",clock1="๐Ÿ•",clock2="๐Ÿ•‘",clock3="๐Ÿ•’",clock4="๐Ÿ•“",clock5="๐Ÿ•”",clock6="๐Ÿ••",clock7="๐Ÿ•–",clock8="๐Ÿ•—",clock9="๐Ÿ•˜",doughnut="๐Ÿฉ",dancer_tone1="๐Ÿ’ƒ๐Ÿป",dancer_tone2="๐Ÿ’ƒ๐Ÿผ",dancer_tone3="๐Ÿ’ƒ๐Ÿฝ",candy="๐Ÿฌ",two_men_holding_hands="๐Ÿ‘ฌ",badminton="๐Ÿธ",bust_in_silhouette="๐Ÿ‘ค",writing_hand_tone2="โœ๐Ÿผ",sunflower="๐ŸŒป",["e-mail"]="๐Ÿ“ง",chains="โ›“",kissing_smiling_eyes="๐Ÿ˜™",fish_cake="๐Ÿฅ",no_pedestrians="๐Ÿšท",v_tone4="โœŒ๐Ÿพ",v_tone5="โœŒ๐Ÿฟ",v_tone1="โœŒ๐Ÿป",v_tone2="โœŒ๐Ÿผ",v_tone3="โœŒ๐Ÿฝ",arrow_backward="โ—€",clock12="๐Ÿ•›",clock10="๐Ÿ•™",clock11="๐Ÿ•š",sweat="๐Ÿ˜“",mountain_railway="๐Ÿšž",tongue="๐Ÿ‘…",black_square_button="๐Ÿ”ฒ",do_not_litter="๐Ÿšฏ",nose_tone4="๐Ÿ‘ƒ๐Ÿพ",nose_tone5="๐Ÿ‘ƒ๐Ÿฟ",nose_tone2="๐Ÿ‘ƒ๐Ÿผ",nose_tone3="๐Ÿ‘ƒ๐Ÿฝ",nose_tone1="๐Ÿ‘ƒ๐Ÿป",horse_racing_tone5="๐Ÿ‡๐Ÿฟ",horse_racing_tone4="๐Ÿ‡๐Ÿพ",horse_racing_tone3="๐Ÿ‡๐Ÿฝ",ok_hand="๐Ÿ‘Œ",horse_racing_tone1="๐Ÿ‡๐Ÿป",custard="๐Ÿฎ",rowboat="๐Ÿšฃ",white_sun_small_cloud="๐ŸŒค",flag_kr="๐Ÿ‡ฐ๐Ÿ‡ท",cricket="๐Ÿ",flag_kp="๐Ÿ‡ฐ๐Ÿ‡ต",flag_kw="๐Ÿ‡ฐ๐Ÿ‡ผ",flag_kz="๐Ÿ‡ฐ๐Ÿ‡ฟ",flag_ky="๐Ÿ‡ฐ๐Ÿ‡พ",construction="๐Ÿšง",flag_kg="๐Ÿ‡ฐ๐Ÿ‡ฌ",flag_ke="๐Ÿ‡ฐ๐Ÿ‡ช",flag_ki="๐Ÿ‡ฐ๐Ÿ‡ฎ",flag_kh="๐Ÿ‡ฐ๐Ÿ‡ญ",flag_kn="๐Ÿ‡ฐ๐Ÿ‡ณ",flag_km="๐Ÿ‡ฐ๐Ÿ‡ฒ",cake="๐Ÿฐ",flag_wf="๐Ÿ‡ผ๐Ÿ‡ซ",mortar_board="๐ŸŽ“",pig="๐Ÿท",flag_ws="๐Ÿ‡ผ๐Ÿ‡ธ",person_frowning="๐Ÿ™",arrow_upper_right="โ†—",book="๐Ÿ“–",clock1130="๐Ÿ•ฆ",boom="๐Ÿ’ฅ",["repeat"]="๐Ÿ”",star="โญ",rabbit2="๐Ÿ‡",footprints="๐Ÿ‘ฃ",ghost="๐Ÿ‘ป",droplet="๐Ÿ’ง",vibration_mode="๐Ÿ“ณ",flag_ye="๐Ÿ‡พ๐Ÿ‡ช",flag_yt="๐Ÿ‡พ๐Ÿ‡น",
+}
+emoji['slightly_smiling_face'] = ':)'
+
+local function str2emoji(str)
+ if not str then return '' end
+ return (str:gsub(':[a-zA-Z0-9%-_]+:', function(word)
+ return emoji[word:match(':(.+):')] or word
+ end))
+end
+
+function emoji_replace_input_string(buffer)
+ -- Get input contents
+ local input_s = w.buffer_get_string(buffer, 'input')
+ -- Skip modification of settings
+ if input_s:match('^/set ') then
+ return w.WEECHAT_RC_OK
+ end
+ w.buffer_set(buffer, 'input', str2emoji(input_s))
+ return w.WEECHAT_RC_OK
+end
+
+function emoji_input_replacer(data, buffer, command)
+ if command == '/input return' then
+ return emoji_replace_input_string(buffer)
+ end
+ return w.WEECHAT_RC_OK
+end
+
+function emoji_live_input_replace(data, modifier, modifier_data, msg)
+ return str2emoji(msg)
+end
+
+function emoji_out_replace(data, modifier, modifier_data, msg)
+ return str2emoji(msg)
+end
+
+function unshortcode_cb(data, modifier, modifier_data, msg)
+ return str2emoji(msg)
+end
+
+function emoji_complete_next_cb(data, buffer, command)
+ local input_s = w.buffer_get_string(buffer, 'input')
+ -- Require : in word
+ if not input_s:match(':') then
+ return w.WEECHAT_RC_OK
+ end
+ local current_pos = w.buffer_get_integer(buffer, "input_pos") - 1
+ --local input_length = w.buffer_get_integer(buffer, "input_length")
+ while current_pos >= 1 and input_s.sub(current_pos, current_pos) ~= ':' do
+ current_pos = current_pos - 1
+ end
+ if current_pos < 1 then
+ current_pos = 1
+ end
+
+ -- TODO: Support non-end-word editing
+ local oword = input_s:sub(current_pos)
+ local word = oword:match(':(.*)')
+ for e, b in pairs(emoji) do
+ if e:match(word) then
+ local new = (input_s:gsub(":"..word, b))
+ w.buffer_set(buffer, 'input', new)
+ --w.buffer_set(buffer, "input_pos", str(w.buffer_get_integer(buffer, "input_pos") + 1))
+ return w.WEECHAT_RC_OK_EAT
+ end
+ end
+
+ return w.WEECHAT_RC_OK
+end
+
+function emoji_completion_cb(data, completion_item, buffer, completion)
+ for k, v in pairs(emoji) do
+ w.hook_completion_list_add(completion, ":"..k..":", 0, w.WEECHAT_LIST_POS_SORT)
+ end
+ return w.WEECHAT_RC_OK
+end
+
+function incoming_cb(data, modifier, modifier_data, msg)
+ --local plugin, buffer_name, tags = modifier_data:match('^(.-);(.-);(.-)$')
+ -- Only replace in incoming "messages"
+ if modifier_data:match('nick_') then
+ return str2emoji(msg)
+ end
+ return msg
+end
+
+function e_init()
+ if w.register(
+ SCRIPT_NAME,
+ SCRIPT_AUTHOR,
+ SCRIPT_VERSION,
+ SCRIPT_LICENSE,
+ SCRIPT_DESC,
+ '',
+ '') then
+ -- Hook input enter
+ w.hook_command_run('/input return', 'emoji_input_replacer', '')
+
+ -- Hook irc out for relay clients
+ --w.hook_modifier('input_text_for_buffer', 'emoji_out_replace', '')
+ w.hook_modifier('irc_out1_PRIVMSG', 'emoji_out_replace', '')
+ -- Replace while typing
+ w.hook_modifier('input_text_display_with_cursor', 'emoji_live_input_replace', '')
+ -- Hook tab complete
+ w.hook_command_run("/input complete_next", "emoji_complete_next_cb", "")
+ -- Hook for working togheter with other scripts
+ w.hook_modifier('emoji_unshortcode', 'unshortcode_cb', '')
+
+ w.hook_completion("emojis", "complete :emoji:s", "emoji_completion_cb", "")
+ local settings = {
+ incoming = {'on', 'Also try to replace shortcodes to emoji in incoming messages'}
+ }
+ -- set default settings
+ local version = tonumber(w.info_get('version_number', '') or 0)
+ for option, value in pairs(settings) do
+ if w.config_is_set_plugin(option) ~= 1 then
+ w.config_set_plugin(option, value[1])
+ end
+ if version >= 0x00030500 then
+ w.config_set_desc_plugin(option, ('%s (default: "%s")'):format(
+ value[2], value[1]))
+ end
+ end
+ -- Hook incoming message
+ if w.config_get_plugin('incoming') == 'on' then
+ w.hook_modifier("weechat_print", 'incoming_cb', '')
+ end
+ end
+end
+
+e_init()
diff --git a/weechat/lua/matrix.lua b/weechat/lua/matrix.lua
new file mode 100644
index 0000000..2ce0a2c
--- /dev/null
+++ b/weechat/lua/matrix.lua
@@ -0,0 +1,3354 @@
+-- WeeChat Matrix.org Client
+-- vim: expandtab:ts=4:sw=4:sts=4
+-- luacheck: globals weechat command_help command_connect matrix_command_cb matrix_away_command_run_cb configuration_changed_cb real_http_cb matrix_unload http_cb upload_cb send buffer_input_cb poll polltimer_cb cleartyping otktimer_cb join_command_cb part_command_cb leave_command_cb me_command_cb topic_command_cb upload_command_cb query_command_cb create_command_cb createalias_command_cb invite_command_cb list_command_cb op_command_cb voice_command_cb devoice_command_cb kick_command_cb deop_command_cb nick_command_cb whois_command_cb notice_command_cb msg_command_cb encrypt_command_cb public_command_cb names_command_cb more_command_cb roominfo_command_cb name_command_cb closed_matrix_buffer_cb closed_matrix_room_cb typing_notification_cb buffer_switch_cb typing_bar_item_cb
+
+--[[
+ Author: xt <xt@xt.gg>
+ Thanks to Ryan Huber of wee_slack.py for some ideas and inspiration.
+
+ This script is considered alpha quality as only the bare minimal of
+ functionality is in place and it is not very well tested.
+
+ It is known to be able to crash WeeChat in certain scenarioes so all
+ usage of this script is at your own risk.
+
+ If at any point there seems to be problem, make sure you update to
+ the latest version of this script. You can also try reloading the
+ script using /lua reload matrix to refresh all the state.
+
+Power Levels
+------------
+
+A default Matrix room has power level between 0 to 100.
+This script maps this as follows:
+
+ ~ Room creator
+ & Power level 100
+ @ Power level 50
+ + Power level > 0
+
+ TODO
+ ----
+ /ban
+ Giving people arbitrary power levels
+ Lazyload messages instead of HUGE initialSync
+ Dynamically fetch more messages in backlog when user reaches the
+ oldest message using pgup
+ Need a way to change room join rule
+ Fix broken state after failed initial connect
+ Fix parsing of multiple join messages
+ Friendlier error message on bad user/password
+ Parse some HTML and turn into color/bold/etc
+ Support weechat.look.prefix_same_nick
+
+]]
+
+local json = require 'cjson' -- apt-get install lua-cjson
+local olmstatus, olm = pcall(require, 'olm') -- LuaJIT olm FFI binding ln -s ~/olm/olm.lua /usr/local/share/lua/5.1
+local w = weechat
+
+local SCRIPT_NAME = "matrix"
+local SCRIPT_AUTHOR = "xt <xt@xt.gg>"
+local SCRIPT_VERSION = "3"
+local SCRIPT_LICENSE = "MIT"
+local SCRIPT_DESC = "Matrix.org chat plugin"
+local SCRIPT_COMMAND = SCRIPT_NAME
+
+local WEECHAT_VERSION
+
+local SERVER
+local STDOUT = {}
+local OUT = {}
+local BUFFER
+local Room
+local MatrixServer
+local Olm
+local DEBUG = false
+-- How many seconds to timeout if nothing happened on the server. If something
+-- happens before it will return sooner.
+-- default Nginx proxy timeout is 60s, so we go slightly lower
+local POLL_INTERVAL = 55
+
+local default_color = w.color('default')
+-- Cache error variables so we don't have to look them up for every error
+-- message, a normal user will not change these ever anyway.
+local errprefix
+local errprefix_c
+
+local HOMEDIR
+local OLM_ALGORITHM = 'm.olm.v1.curve25519-aes-sha2'
+local OLM_KEY = 'secr3t' -- TODO configurable using weechat sec data
+local v2_api_ns = '_matrix/client/v2_alpha'
+
+local function tprint(tbl, indent, out)
+ if not indent then indent = 0 end
+ if not out then out = BUFFER end
+ for k, v in pairs(tbl) do
+ local formatting = string.rep(" ", indent) .. k .. ": "
+ if type(v) == "table" then
+ w.print(out, formatting)
+ tprint(v, indent+1, out)
+ elseif type(v) == 'boolean' then
+ w.print(out, formatting .. tostring(v))
+ elseif type(v) == 'userdata' then
+ w.print(out, formatting .. tostring(v))
+ else
+ w.print(out, formatting .. v)
+ end
+ end
+end
+
+local function mprint(message)
+ -- Print message to matrix buffer
+ if type(message) == 'table' then
+ tprint(message)
+ else
+ message = tostring(message)
+ w.print(BUFFER, message)
+ end
+end
+
+local function perr(message)
+ if message == nil then return end
+ -- Print error message to the matrix "server" buffer using WeeChat styled
+ -- error message
+ mprint(
+ errprefix_c ..
+ errprefix ..
+ '\t' ..
+ default_color ..
+ tostring(message)
+ )
+end
+
+local function dbg(message)
+ perr('- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -')
+ if type(message) == 'table' then
+ tprint(message)
+ else
+ message = ("DEBUG\t%s"):format(tostring(message))
+ mprint(BUFFER, message)
+ end
+end
+
+local dtraceback = debug.traceback
+-- luacheck: ignore debug
+debug.traceback = function (...)
+ if select('#', ...) >= 1 then
+ local err, lvl = ...
+ local trace = dtraceback(err, (lvl or 2)+1)
+ perr(trace)
+ end
+ -- direct call to debug.traceback: return the original.
+ -- debug.traceback(nil, level) doesn't work in Lua 5.1
+ -- (http://lua-users.org/lists/lua-l/2011-06/msg00574.html), so
+ -- simply remove first frame from the stack trace
+ return (dtraceback(...):gsub("(stack traceback:\n)[^\n]*\n", "%1"))
+end
+
+local function weechat_eval(text)
+ if WEECHAT_VERSION >= 0x00040200 then
+ return w.string_eval_expression(text,{},{},{})
+ end
+ return text
+end
+
+local urllib = {}
+urllib.quote = function(str)
+ if not str then return '' end
+ if type(str) == 'number' then return str end
+ return str:gsub(
+ '([^%w ])',
+ function (c)
+ return string.format ("%%%02X", string.byte(c))
+ end
+ ):gsub(' ', '+')
+end
+urllib.urlencode = function(tbl)
+ local out = {}
+ for k, v in pairs(tbl) do
+ table.insert(out, urllib.quote(k)..'='..urllib.quote(v))
+ end
+ return table.concat(out, '&')
+end
+
+local function accesstoken_redact(str)
+ return (str:gsub('access.*token=[0-9a-zA-Z%%]*', 'access_token=[redacted]'))
+end
+
+local transaction_id_counter = 0
+local function get_next_transaction_id()
+ transaction_id_counter = transaction_id_counter + 1
+ return transaction_id_counter
+end
+
+--[[
+-- Function for signing json, unused for now, we hand craft the required
+-- signed json in the encryption function. But I think this function will be
+-- needed in the future so leaving it here in a commented version
+local function sign_json(json_object, signing_key, signing_name)
+ -- See: https://github.com/matrix-org/matrix-doc/blob/master/specification/31_event_signing.rst
+ -- Maybe use:http://regex.info/code/JSON.lua which sorts keys
+ local signatures = json_object.signatures or {}
+ json_object.signatures = nil
+
+ local unsigned = json_object.unsigned or nil
+ json_object.unsigned = nil
+
+ -- TODO ensure canonical json
+ local signed = signing_key:sign(json.encode(json_object))
+ local signature_base64 = encode_base64(signed.signature)
+
+ local key_id = ("%s:%s"):format(signing_key.agl, signing_key.version)
+ signatures[signing_name] = {[key_id] = signature_base64}
+
+ json_object.signatures = signatures
+ if unsigned then
+ json_object.unsigned = unsigned
+ end
+
+ return json_object
+end
+--]]
+
+local function split_args(args)
+ local function_name, arg = args:match('^(.-) (.*)$')
+ return function_name, arg
+end
+
+local function byte_to_tag(s, byte, open_tag, close_tag)
+ if s:match(byte) then
+ local inside = false
+ local open_tags = 0
+ local htmlbody = s:gsub(byte, function(c)
+ if inside then
+ inside = false
+ return close_tag
+ end
+ inside = true
+ open_tags = open_tags + 1
+ return open_tag
+ end)
+ local _, count = htmlbody:gsub(close_tag, '')
+ -- Ensure we close tags
+ if count < open_tags then
+ htmlbody = htmlbody .. close_tag
+ end
+ return htmlbody
+ end
+ return s
+end
+
+local function irc_formatting_to_html(s)
+ -- TODO, support foreground and background?
+ local ct = {'white','black','blue','green','red','maroon','purple',
+ 'orange','yellow','lightgreen','teal','cyan', 'lightblue',
+ 'fuchsia', 'gray', 'lightgray'}
+
+ s = byte_to_tag(s, '\02', '<em>', '</em>')
+ s = byte_to_tag(s, '\029', '<i>', '</i>')
+ s = byte_to_tag(s, '\031', '<u>', '</u>')
+ -- First do full color strings with reset.
+ -- Iterate backwards to catch long colors before short
+ for i=#ct,1,-1 do
+ s = s:gsub(
+ '\003'..tostring(i-1)..'(.-)\003',
+ '<font color="'..ct[i]..'">%1</font>')
+ end
+
+ -- Then replace unmatch colors
+ -- Iterate backwards to catch long colors before short
+ for i=#ct,1,-1 do
+ local c = ct[i]
+ s = byte_to_tag(s, '\003'..tostring(i-1),
+ '<font color="'..c..'">', '</font>')
+ end
+ return s
+end
+
+local function strip_irc_formatting(s)
+ if not s then return '' end
+ return (s
+ :gsub("\02", "")
+ :gsub("\03%d%d?,%d%d?", "")
+ :gsub("\03%d%d?", "")
+ :gsub("\03", "")
+ :gsub("\15", "")
+ :gsub("\17", "")
+ :gsub("\18", "")
+ :gsub("\22", "")
+ :gsub("\29", "")
+ :gsub("\31", ""))
+end
+
+local function irc_formatting_to_weechat_color(s)
+ -- TODO, support foreground and background?
+ -- - is atribute to remove formatting
+ -- | is to keep formatting during color changes
+ s = byte_to_tag(s, '\02', w.color'bold', w.color'-bold')
+ s = byte_to_tag(s, '\029', w.color'italic', w.color'-italic')
+ s = byte_to_tag(s, '\031', w.color'underline', w.color'-underline')
+ -- backwards to catch long numbers before short
+ for i=16,1,-1 do
+ i = tostring(i)
+ s = byte_to_tag(s, '\003'..i,
+ w.color("|"..i), w.color("-"..i))
+ end
+ return s
+end
+
+function matrix_unload()
+ w.print('', 'matrix: Unloading')
+ -- Clear/free olm memory if loaded
+ if olmstatus then
+ w.print('', 'matrix: Saving olm state')
+ SERVER.olm:save()
+ w.print('', 'matrix: Clearing olm state from memory')
+ SERVER.olm.account:clear()
+ --SERVER.olm = nil
+ end
+ w.print('', 'matrix: done cleaning up!')
+ return w.WEECHAT_RC_OK
+end
+
+local function wconf(optionname)
+ return w.config_string(w.config_get(optionname))
+end
+
+local function wcolor(optionname)
+ return w.color(wconf(optionname))
+end
+
+function command_help(current_buffer, args)
+ if args then
+ local help_cmds = {args=args}
+ if not help_cmds then
+ w.print("", "Command not found: " .. args)
+ return
+ end
+ for cmd, helptext in pairs(help_cmds) do
+ w.print('', w.color("bold") .. cmd)
+ w.print('', (helptext or 'No help text').strip())
+ w.print('', '')
+ end
+ end
+
+end
+
+function command_connect(current_buffer, args)
+ if not SERVER.connected then
+ SERVER:connect()
+ end
+ return w.WEECHAT_RC_OK
+end
+
+function matrix_command_cb(data, current_buffer, args)
+ if args == 'connect' then
+ return command_connect(current_buffer)
+ elseif args == 'debug' then
+ if DEBUG then
+ DEBUG = false
+ w.print('', SCRIPT_NAME..': debugging messages disabled')
+ else
+ DEBUG = true
+ w.print('', SCRIPT_NAME..': debugging messages enabled')
+ end
+ elseif args:match('^msg ') then
+ local _
+ _, args = split_args(args) -- remove cmd
+ local roomarg, msg = split_args(args)
+ local room
+ for id, r in pairs(SERVER.rooms) do
+ -- Send /msg to a ID
+ if id == roomarg then
+ room = r
+ break
+ elseif roomarg == r.name then
+ room = r
+ break
+ elseif roomarg == r.roomname then
+ room = r
+ break
+ end
+ end
+
+ if room then
+ room:Msg(msg)
+ return w.WEECHAT_RC_OK_EAT
+ end
+ else
+ perr("Command not found: " .. args)
+ end
+
+ return w.WEECHAT_RC_OK
+end
+
+function matrix_away_command_run_cb(data, buffer, args)
+ -- Callback for command /away -all
+ local _
+ _, args = split_args(args) -- remove cmd
+ local msg
+ _, msg = split_args(args)
+ w.buffer_set(BUFFER, "localvar_set_away", msg)
+ for id, room in pairs(SERVER.rooms) do
+ if msg and msg ~= '' then
+ w.buffer_set(room.buffer, "localvar_set_away", msg)
+ else
+ -- Delete takes empty string, and not nil
+ w.buffer_set(room.buffer, "localvar_del_away", '')
+ end
+ end
+ if msg and msg ~= '' then
+ SERVER:SendPresence('unavailable', msg)
+ mprint 'You have been marked as unavailable'
+ else
+ SERVER:SendPresence('online', nil)
+ mprint 'You have been marked as online'
+ end
+ return w.WEECHAT_RC_OK
+end
+
+function configuration_changed_cb(data, option, value)
+ if value == 'on' then
+ DEBUG = true
+ w.print('', SCRIPT_NAME..': debugging messages enabled')
+ else
+ DEBUG = false
+ w.print('', SCRIPT_NAME..': debugging messages disabled')
+ end
+end
+
+local function http(url, post, cb, timeout, extra, api_ns)
+ if not post then
+ post = {}
+ end
+ if not cb then
+ cb = 'http_cb'
+ end
+ if not timeout then
+ timeout = 60*1000
+ end
+ if not extra then
+ extra = nil
+ end
+ if not api_ns then
+ api_ns = "_matrix/client/r0"
+ end
+
+ -- Add accept encoding by default if it's not already there
+ if not post.accept_encoding then
+ post.accept_encoding = 'application/json'
+ end
+ if not post.header then
+ post.header = 1 -- Request http headers in the response
+ end
+
+ if not url:match'https?://' then
+ local homeserver_url = w.config_get_plugin('homeserver_url')
+ homeserver_url = homeserver_url .. api_ns
+ url = homeserver_url .. url
+ end
+
+ if DEBUG then
+ dbg{request={
+ url=accesstoken_redact(url),
+ post=post,extra=extra}
+ }
+ end
+ w.hook_process_hashtable('url:' .. url, post, timeout, cb, extra)
+end
+
+local function parse_http_statusline(line)
+ local httpversion, status_code, reason_phrase = line:match("^HTTP/(1%.[01]) (%d%d%d) (.-)\r?\n")
+ if not httpversion then
+ return
+ end
+ return httpversion, tonumber(status_code), reason_phrase
+end
+
+function real_http_cb(extra, command, rc, stdout, stderr)
+ if DEBUG then
+ dbg{reply={
+ command=accesstoken_redact(command),
+ extra=extra,rc=rc,stdout=stdout,stderr=stderr}
+ }
+ end
+
+ if stderr and stderr ~= '' then
+ mprint(('error: %s'):format(stderr))
+ return w.WEECHAT_RC_OK
+ end
+
+ -- Because of a bug in WeeChat sometimes the stdout gets prepended by
+ -- any number of BEL chars (hex 07). Let's have a nasty workaround and
+ -- just replace them away.
+ if WEECHAT_VERSION < 0x01030000 then -- fixed in 1.3
+ stdout = (stdout:gsub('^\007*', ''))
+ end
+
+ if stdout ~= '' then
+ if not STDOUT[command] then
+ STDOUT[command] = {}
+ end
+ table.insert(STDOUT[command], stdout)
+ end
+
+ if tonumber(rc) >= 0 then
+ stdout = table.concat(STDOUT[command] or {})
+ STDOUT[command] = nil
+ local httpversion, status_code, reason_phrase = parse_http_statusline(stdout)
+ if not httpversion then
+ perr(('Invalid http request: %s'):format(stdout))
+ return w.WEECHAT_RC_OK
+ end
+ if status_code >= 500 then
+ perr(('HTTP API returned error. Code: %s, reason: %s'):format(status_code, reason_phrase))
+ return w.WEECHAT_RC_OK
+ end
+ -- Skip to data
+ stdout = (stdout:match('.-\r?\n\r?\n(.*)'))
+ -- Protected call in case of JSON errors
+ local success, js = pcall(json.decode, stdout)
+ if not success then
+ mprint(('error\t%s during json load: %s'):format(js, stdout))
+ return w.WEECHAT_RC_OK
+ end
+ if js['errcode'] or js['error'] then
+ if command:find'login' then
+ w.print('', ('matrix: Error code during login: %s, code: %s'):format(
+ js['error'], js['errcode']))
+ w.print('', 'matrix: Please verify your username and password')
+ else
+ perr('API call returned error: '..js['error'] .. '('..tostring(js.errcode)..')')
+ end
+ return w.WEECHAT_RC_OK
+ end
+ -- Get correct handler
+ if command:find('login') then
+ for k, v in pairs(js) do
+ SERVER[k] = v
+ end
+ SERVER.connected = true
+ SERVER:initial_sync()
+ elseif command:find'/rooms/.*/initialSync' then
+ local myroom = SERVER:addRoom(js)
+ for _, chunk in ipairs(js['presence']) do
+ myroom:ParseChunk(chunk, true, 'presence')
+ end
+ for _, chunk in ipairs(js['messages']['chunk']) do
+ myroom:ParseChunk(chunk, true, 'messages')
+ end
+ elseif command:find'/sync' then
+ SERVER.end_token = js.next_batch
+
+ -- We have a new end token, which means we safely can release the
+ -- poll lock
+ SERVER.poll_lock = false
+
+ local backlog = false
+ local initial = false
+ if extra == 'initial' then
+ initial = true
+ backlog = true
+ end
+
+ -- Start with setting the global presence variable on the server
+ -- so when the nicks get added to the room they can get added to
+ -- the correct nicklist group according to if they have presence
+ -- or not
+ for _, e in ipairs(js.presence.events) do
+ SERVER:UpdatePresence(e)
+ end
+ for membership, rooms in pairs(js['rooms']) do
+ -- If we left the room, simply ignore it
+ if membership ~= 'leave' or (membership == 'leave' and (not backlog)) then
+ for identifier, room in pairs(rooms) do
+ -- Monkey patch it to look like v1 object
+ room.room_id = identifier
+ local myroom
+ if initial then
+ myroom = SERVER:addRoom(room)
+ else
+ myroom = SERVER.rooms[identifier]
+ -- Chunk for non-existing room
+ if not myroom then
+ myroom = SERVER:addRoom(room)
+ if not membership == 'invite' then
+ perr('Event for unknown room')
+ end
+ end
+ end
+ -- First of all parse invite states.
+ local inv_states = room.invite_state
+ if inv_states then
+ local chunks = room.invite_state.events or {}
+ for _, chunk in ipairs(chunks) do
+ myroom:ParseChunk(chunk, backlog, 'states')
+ end
+ end
+ -- Parse states before messages so we can add nicks and stuff
+ -- before messages start appearing
+ local states = room.state
+ if states then
+ local chunks = room.state.events or {}
+ for _, chunk in ipairs(chunks) do
+ myroom:ParseChunk(chunk, backlog, 'states')
+ end
+ end
+ local timeline = room.timeline
+ if timeline then
+ -- Save the prev_batch on the initial message so we
+ -- know for later when we picked up the sync
+ if initial then
+ myroom.prev_batch = timeline.prev_batch
+ end
+ local chunks = timeline.events or {}
+ for _, chunk in ipairs(chunks) do
+ myroom:ParseChunk(chunk, backlog, 'messages')
+ end
+ end
+ local ephemeral = room.ephemeral
+ -- Ignore Ephemeral Events during initial sync
+ if (extra and extra ~= 'initial') and ephemeral then
+ local chunks = ephemeral.events or {}
+ for _, chunk in ipairs(chunks) do
+ myroom:ParseChunk(chunk, backlog, 'states')
+ end
+ end
+ if backlog then
+ -- All the state should be done. Try to get a good name for the room now.
+ myroom:SetName(myroom.identifier)
+ end
+ end
+ end
+ end
+ -- Now we have created rooms and can go over the rooms and update
+ -- the presence for each nick
+ for _, e in pairs(js.presence.events) do
+ SERVER:UpdatePresence(e)
+ end
+ if initial then
+ SERVER:post_initial_sync()
+ end
+ SERVER:poll()
+ elseif command:find'messages' then
+ local identifier = extra
+ local myroom = SERVER.rooms[identifier]
+ myroom.prev_batch = js['end']
+ -- Freeze buffer
+ myroom:Freeze()
+ -- Clear buffer
+ myroom:Clear()
+ -- We request backwards direction, so iterate backwards
+ for i=#js.chunk,1,-1 do
+ local chunk = js.chunk[i]
+ myroom:ParseChunk(chunk, true, 'messages')
+ end
+ -- Thaw!
+ myroom:Thaw()
+ elseif command:find'/join/' then
+ -- We came from a join command, fecth some messages
+ local found = false
+ for id, _ in pairs(SERVER.rooms) do
+ if id == js.room_id then
+ found = true
+ -- this is a false positive for example when getting
+ -- invited. need to investigate more
+ --mprint('error\tJoined room, but already in it.')
+ break
+ end
+ end
+ if not found then
+ local data = urllib.urlencode({
+ access_token= SERVER.access_token,
+ --limit= w.config_get_plugin('backlog_lines'),
+ limit = 10,
+ })
+ http(('/rooms/%s/initialSync?%s'):format(
+ urllib.quote(js.room_id), data))
+ end
+ elseif command:find'leave' then
+ -- We store room_id in extra
+ local room_id = extra
+ SERVER:delRoom(room_id)
+ elseif command:find'/keys/claim' then
+ local count = 0
+ for user_id, v in pairs(js.one_time_keys or {}) do
+ for device_id, keys in pairs(v or {}) do
+ for key_id, key in pairs(keys or {}) do
+ SERVER.olm.otks[user_id..':'..device_id] = {[device_id]=key}
+ perr(('olm: Recieved OTK for user %s for device id %s'):format(user_id, device_id))
+ count = count + 1
+ SERVER.olm:create_session(user_id, device_id)
+ end
+ end
+ end
+ elseif command:find'/keys/query' then
+ for k, v in pairs(js.device_keys or {}) do
+ SERVER.olm.device_keys[k] = v
+
+ -- Claim keys for all only if missing session
+ for device_id, device_data in pairs(v) do
+ -- First try to create session from saved data
+ -- if that doesn't success we will download otk
+ local device_key = device_data.keys['curve25519:'..device_id]
+ local sessions = SERVER.olm:get_sessions(device_key)
+ if #sessions == 0 then
+ perr('olm: Downloading otk for user '..k..', and device_id: '..device_id)
+ SERVER.olm:claim(k, device_id)
+ else
+ perr('olm: Reusing existing session for user '..k)
+ end
+ end
+ end
+ elseif command:find'/keys/upload' then
+ local key_count = 0
+ local sensible_number_of_keys = 20
+ for algo, count in pairs(js.one_time_key_counts) do
+ key_count = count
+ SERVER.olm.key_count = key_count
+ end
+ if DEBUG then
+ perr('olm: Number of own OTKs uploaded to server: '..key_count)
+ end
+ -- TODO make endless loop prevention in case of server error
+ if key_count < sensible_number_of_keys then
+ SERVER.olm:upload_keys()
+ end
+ elseif command:find'upload' then
+ -- We store room_id in extra
+ local room_id = extra
+ if js.content_uri then
+ SERVER:Msg(room_id, js.content_uri)
+ end
+ -- luacheck: ignore 542
+ elseif command:find'/typing/' then
+ -- either it errs or it is empty
+ elseif command:find'/state/' then
+ -- TODO errorcode: M_FORBIDDEN
+ -- either it errs or it is empty
+ --dbg({state= js})
+ elseif command:find'/send/' then
+ -- XXX Errorhandling
+ -- TODO save event id to use for localecho
+ local event_id = js.event_id
+ local room_id = extra
+ -- When using relay client, WeeChat doesn't get any buffer_switch
+ -- signals, and thus cannot know when the relay client reads any
+ -- messages. https://github.com/weechat/weechat/issues/180
+ -- As a better than nothing approach we send read receipt when
+ -- user sends a message, since most likely the user has read
+ -- messages in that room if sending messages to it.
+ SERVER:SendReadReceipt(room_id, event_id)
+ elseif command:find'createRoom' then
+ -- We get join events, so we don't have to do anything
+ elseif command:find'/publicRooms' then
+ mprint 'Public rooms:'
+ mprint '\tUsers\tName\tTopic\tAliases'
+ table.sort(js.chunk, function(a, b)
+ return a.num_joined_members > b.num_joined_members
+ end)
+ for _, r in ipairs(js.chunk) do
+ local name = ''
+ if r.name and r.name ~= json.null then
+ name = r.name:gsub('\n', '')
+ end
+ local topic = ''
+ if r.topic and r.topic ~= json.null then
+ topic = r.topic:gsub('\n', '')
+ end
+ mprint(('%s %s %s %s')
+ :format(
+ r.num_joined_members or '',
+ name or '',
+ topic or '',
+ table.concat(r.aliases or {}, ', ')))
+ end
+ -- luacheck: ignore 542
+ elseif command:find'/invite' then
+ elseif command:find'receipt' then
+ -- we don't care about receipts for now
+ elseif command:find'directory/room' then
+ --- XXX: parse result
+ mprint 'Created new alias for room'
+ elseif command:match'presence/.*/status' then
+ -- Return of SendPresence which we don't have to handle because
+ -- it will be sent back to us as an event
+ else
+ dbg{['error'] = {msg='Unknown command in http cb', command=command,
+ js=js}}
+ end
+ end
+
+ if tonumber(rc) == -2 then -- -2 == WEECHAT_HOOK_PROCESS_ERROR
+ perr(('Call to API errored in command %s, maybe timeout?'):format(
+ accesstoken_redact(command)))
+ -- Empty cache in case of errors
+ if STDOUT[command] then
+ STDOUT[command] = nil
+ end
+ -- Release poll lock in case of errors
+ SERVER.poll_lock = false
+ end
+
+ return w.WEECHAT_RC_OK
+end
+
+function http_cb(data, command, rc, stdout, stderr)
+ local status, result = pcall(real_http_cb, data, command, rc, stdout, stderr)
+ if not status then
+ perr('Error in http_cb: ' .. tostring(result))
+ perr(debug.traceback())
+ end
+ return result
+end
+
+function upload_cb(data, command, rc, stdout, stderr)
+ local success, js = pcall(json.decode, stdout)
+ if not success then
+ mprint(('error\t%s when getting uploaded URI: %s'):format(js, stdout))
+ return w.WEECHAT_RC_OK
+ end
+
+ local uri = js.content_uri
+ if not uri then
+ mprint(('error\tNo content_uri after upload. Stdout: %s, stderr: %s'):format(stdout, stderr))
+ return w.WEECHAT_RC_OK
+ end
+
+ local room_id = data
+ local body = 'Image'
+ local msgtype = 'm.image'
+ SERVER:Msg(room_id, body, msgtype, uri)
+
+ return w.WEECHAT_RC_OK
+end
+
+Olm = {}
+Olm.__index = Olm
+Olm.create = function()
+ local olmdata = {}
+ setmetatable(olmdata, Olm)
+ if not olmstatus then
+ w.print('', SCRIPT_NAME .. ': Unable to load olm encryption library. Not enabling encryption. Please see documentation (README.md) for information on how to enable.')
+ return
+ end
+
+ local account = olm.Account.new()
+ olmdata.account = account
+ olmdata.sessions = {}
+ olmdata.device_keys = {}
+ olmdata.otks = {}
+ -- Try to read account from filesystem, if not generate a new account
+ local fd = io.open(HOMEDIR..'account.olm', 'rb')
+ local pickled = ''
+ if fd then
+ pickled = fd:read'*all'
+ fd:close()
+ end
+ if pickled == '' then
+ account:create()
+ local _, err = account:generate_one_time_keys(5)
+ perr(err)
+ else
+ local _, err = account:unpickle(OLM_KEY, pickled)
+ perr(err)
+ end
+ local identity = json.decode(account:identity_keys())
+ -- TODO figure out what device id is supposed to be
+ olmdata.device_id = identity.ed25519:match'%w*' -- problems with nonalfanum
+ olmdata.device_key = identity.curve25519
+ w.print('', 'matrix: Encryption loaded. To send encrypted messages in a room, use command /encrypt on with a room as active current buffer')
+ if DEBUG then
+ dbg{olm={
+ 'Loaded identity:',
+ json.decode(account:identity_keys())
+ }}
+ end
+ return olmdata
+end
+
+function Olm:save()
+ -- Save account and every pickled session
+ local pickle, err = self.account:pickle(OLM_KEY)
+ perr(err)
+ local fd = io.open(HOMEDIR..'account.olm', 'wb')
+ fd:write(pickle)
+ fd:close()
+ --for key, pickled in pairs(self.sessions) do
+ -- local user_id, device_id = key:match('(.*):(.+)')
+ -- self.write_session_to_file(pickled, user_id, device_id)
+ --end
+end
+
+function Olm:query(user_ids) -- Query keys from other user_id
+ if DEBUG then
+ perr('olm: querying user_ids')
+ tprint(user_ids)
+ end
+ local auth = urllib.urlencode{access_token=SERVER.access_token}
+ local data = {
+ device_keys = {}
+ }
+ for _, uid in pairs(user_ids) do
+ data.device_keys[uid] = {false}
+ end
+ http('/keys/query/?'..auth,
+ {postfields=json.encode(data)},
+ 'http_cb',
+ 5*1000, nil,
+ v2_api_ns
+ )
+end
+
+function Olm:check_server_keycount()
+ local data = urllib.urlencode{access_token=SERVER.access_token}
+ http('/keys/upload/'..self.device_id..'?'..data,
+ {},
+ 'http_cb', 5*1000, nil, v2_api_ns
+ )
+end
+
+function Olm:upload_keys()
+ if DEBUG then
+ perr('olm: Uploading keys')
+ end
+ local id_keys = json.decode(self.account:identity_keys())
+ local user_id = SERVER.user_id
+ local one_time_keys = {}
+ local otks = json.decode(self.account:one_time_keys())
+ local keyCount = 0
+ for id, k in pairs(otks.curve25519) do
+ keyCount = keyCount + 1
+ end
+ perr('olm: keycount: '..tostring(keyCount))
+ if keyCount < 5 then -- try to always have 5 keys
+ perr('olm: newly generated keys: '..tostring(tonumber(
+ self.account:generate_one_time_keys(5 - keyCount))))
+ otks = json.decode(self.account:one_time_keys())
+ end
+
+ for id, key in pairs(otks.curve25519) do
+ one_time_keys['curve25519:'..id] = key
+ keyCount = keyCount + 1
+ end
+
+ -- Construct JSON manually so it's ready for signing
+ local keys_json = '{"algorithms":["' .. OLM_ALGORITHM .. '"]'
+ .. ',"device_id":"' .. self.device_id .. '"'
+ .. ',"keys":'
+ .. '{"ed25519:' .. self.device_id .. '":"'
+ .. id_keys.ed25519
+ .. '","curve25519:' .. self.device_id .. '":"'
+ .. id_keys.curve25519
+ .. '"}'
+ .. ',"user_id":"' .. user_id
+ .. '"}'
+
+ local success, key_data = pcall(json.decode, keys_json)
+ -- TODO save key data to device_keys so we don't have to download
+ -- our own keys from the servers?
+ if not success then
+ perr(('olm: upload_keys: %s when converting to json: %s')
+ :format(key_data, keys_json))
+ end
+
+ local msg = {
+ device_keys = key_data,
+ one_time_keys = one_time_keys
+ }
+ msg.device_keys.signatures = {
+ [user_id] = {
+ ["ed25519:"..self.device_id] = self.account:sign(keys_json)
+ }
+ }
+ local data = urllib.urlencode{
+ access_token = SERVER.access_token
+ }
+ http('/keys/upload/'..self.device_id..'?'..data, {
+ postfields = json.encode(msg)
+ }, 'http_cb', 5*1000, nil, v2_api_ns)
+
+ self.account:mark_keys_as_published()
+
+end
+
+function Olm:claim(user_id, device_id) -- Fetch one time keys
+ if DEBUG then
+ perr(('olm: Claiming OTK for user: %s and device: %s'):format(user_id, device_id))
+ end
+ -- TODO take a list of ids for batch downloading
+ local auth = urllib.urlencode{ access_token = SERVER.access_token }
+ local data = {
+ one_time_keys = {
+ [user_id] = {
+ [device_id] = 'curve25519'
+ }
+ }
+ }
+ http('/keys/claim?'..auth,
+ {postfields=json.encode(data)},
+ 'http_cb', 30*1000, nil, v2_api_ns
+ )
+end
+
+function Olm:create_session(user_id, device_id)
+ perr(('olm: creating session for user: %s, and device: %s'):format(user_id, device_id))
+ local device_data = self.device_keys[user_id][device_id]
+ if not device_data then
+ perr(('olm: missing device data for user: %s, and device: %s'):format(user_id, device_id))
+ return
+ end
+ local device_key = device_data.keys['curve25519:'..device_id]
+ if not device_key then
+ perr("olm: Missing key for user: "..user_id.." and device: "..device_id.."")
+ return
+ end
+ local sessions = self:get_sessions(device_key)
+ if not sessions[device_key] then
+ perr(('olm: creating NEW session for: %s, and device: %s'):format(user_id, device_id))
+ local session = olm.Session.new()
+ local otk = self.otks[user_id..':'..device_id]
+ if not otk then
+ perr("olm: Missing OTK for user: "..user_id.." and device: "..device_id.."")
+ else
+ otk = otk[device_id]
+ end
+ if otk then
+ session:create_outbound(self.account, device_key, otk)
+ local session_id = session:session_id()
+ perr('olm: Session ID:'..tostring(session_id))
+ self:store_session(device_key, session)
+ end
+ session:clear()
+ end
+end
+
+function Olm:get_sessions(device_key)
+ if DEBUG then
+ perr("olm: get_sessions: device: "..device_key.."")
+ end
+ local sessions = self.sessions[device_key]
+ if not sessions then
+ sessions = self:read_session(device_key)
+ end
+ return sessions
+end
+
+function Olm:read_session(device_key)
+ local session_filename = HOMEDIR..device_key..'.session.olm'
+ local fd, err = io.open(session_filename, 'rb')
+ if fd then
+ perr(('olm: reading saved session device: %s'):format(device_key))
+ local sessions = fd:read'*all'
+ sessions = json.decode(sessions)
+ self.sessions[device_key] = sessions
+ fd:close()
+ return sessions
+ else
+ perr(('olm: Error: %s, reading saved session device: %s'):format(err, device_key))
+ end
+ return {}
+end
+
+function Olm:store_session(device_key, session)
+ local session_id = session:session_id()
+ if DEBUG then
+ perr("olm: store_session: device: "..device_key..", Session ID: "..session_id)
+ end
+ local sessions = self.sessions[device_key] or {}
+ local pickled = session:pickle(OLM_KEY)
+ sessions[session_id] = pickled
+ self.sessions[device_key] = sessions
+ self:write_session_to_file(sessions, device_key)
+end
+
+function Olm:write_session_to_file(sessions, device_key)
+ local session_filename = HOMEDIR..device_key..'.session.olm'
+ local fd, err = io.open(session_filename, 'wb')
+ if fd then
+ fd:write(json.encode(sessions))
+ fd:close()
+ else
+ perr('olm: error saving session: '..tostring(err))
+ end
+end
+
+MatrixServer = {}
+MatrixServer.__index = MatrixServer
+
+MatrixServer.create = function()
+ local server = {}
+ setmetatable(server, MatrixServer)
+ server.nick = nil
+ server.connecting = false
+ server.connected = false
+ server.rooms = {}
+ -- Store user presences here since they are not local to the rooms
+ server.presence = {}
+ server.end_token = 'END'
+ server.typing_time = os.time()
+ server.typingtimer = w.hook_timer(10*1000, 0, 0, "cleartyping", "")
+
+ -- Use a lock to prevent multiple simul poll with same end token, which
+ -- could lead to duplicate messages
+ server.poll_lock = false
+ server.olm = Olm.create()
+ if server.olm then -- might not be available
+ -- Run save so we do not lose state. Create might create new account,
+ -- new keys, etc.
+ server.olm:save()
+ end
+ return server
+end
+
+function MatrixServer:UpdatePresence(c)
+ local user_id = c.sender or c.content.user_id
+ self.presence[user_id] = c.content.presence
+ for id, room in pairs(self.rooms) do
+ room:UpdatePresence(c.sender, c.content.presence)
+ end
+end
+
+function MatrixServer:findRoom(buffer_ptr)
+ for id, room in pairs(self.rooms) do
+ if room.buffer == buffer_ptr then
+ return room
+ end
+ end
+end
+
+function MatrixServer:connect()
+ if not self.connecting then
+ local user = weechat_eval(w.config_get_plugin('user'))
+ local password = weechat_eval(w.config_get_plugin('password'))
+ if user == '' or password == '' then
+ w.print('', 'Please set your username and password using the settings system and then type /matrix connect')
+ return
+ end
+
+ self.connecting = true
+ w.print('', 'matrix: Connecting to homeserver URL: '..
+ w.config_get_plugin('homeserver_url'))
+ local post = {
+ ["type"]="m.login.password",
+ ["user"]=user,
+ ["password"]=password
+ }
+ http('/login', {
+ postfields = json.encode(post)
+ }, 'http_cb', 5*1000) -- Set a short timeout so user can get more immidiate feedback
+ end
+end
+
+function MatrixServer:initial_sync()
+ BUFFER = w.buffer_new(SCRIPT_NAME, "", "", "closed_matrix_buffer_cb", "")
+ w.buffer_set(BUFFER, "short_name", SCRIPT_NAME)
+ w.buffer_set(BUFFER, "name", SCRIPT_NAME)
+ w.buffer_set(BUFFER, "localvar_set_type", "server")
+ w.buffer_set(BUFFER, "localvar_set_server", SCRIPT_NAME)
+ w.buffer_set(BUFFER, "title", ("Matrix: %s"):format(
+ w.config_get_plugin'homeserver_url'))
+ if w.config_string(w.config_get('irc.look.server_buffer')) == 'merge_with_core' then
+ w.buffer_merge(BUFFER, w.buffer_search_main())
+ end
+ w.buffer_set(BUFFER, "display", "auto")
+ local data = urllib.urlencode({
+ access_token = self.access_token,
+ timeout = 1000*POLL_INTERVAL,
+ full_state = 'true',
+ filter = json.encode({ -- timeline filter
+ room = {
+ timeline = {
+ limit = tonumber(w.config_get_plugin('backlog_lines'))
+ }
+ },
+ presence = {
+ not_types = {'*'}, -- dont want presence
+ }
+ })
+ })
+ local extra = 'initial'
+ -- New v2 sync API is slow. Until we can easily ignore archived rooms
+ -- let's increase the timer for the initial login
+ local login_timer = 60*5*1000
+ http('/sync?'..data, nil, 'http_cb', login_timer, extra)
+end
+
+function MatrixServer:post_initial_sync()
+ -- Timer used in cased of errors to restart the polling cycle
+ -- During normal operation the polling should re-invoke itself
+ SERVER.polltimer = w.hook_timer(POLL_INTERVAL*1000, 0, 0, "polltimer_cb", "")
+ if olmstatus then
+ -- timer that checks number of otks available on the server
+ SERVER.otktimer = w.hook_timer(5*60*1000, 0, 0, "otktimer_cb", "")
+ SERVER.olm:query{SERVER.user_id}
+ --SERVER.olm.upload_keys()
+ SERVER.olm:check_server_keycount()
+ end
+end
+
+function MatrixServer:getMessages(room_id, dir, from, limit)
+ if not dir then dir = 'b' end
+ if not from then from = 'END' end
+ if not limit then limit = w.config_get_plugin('backlog_lines') end
+ local data = urllib.urlencode({
+ access_token = self.access_token,
+ dir = dir,
+ from = from,
+ limit = limit,
+ })
+ http(('/rooms/%s/messages?%s')
+ :format(urllib.quote(room_id), data), nil, nil, nil, room_id)
+end
+
+function MatrixServer:Join(room)
+ if not self.connected then
+ --XXX'''
+ return
+ end
+
+ mprint('\tJoining room '..room)
+ room = urllib.quote(room)
+ http('/join/' .. room,
+ {postfields = "access_token="..self.access_token})
+end
+
+function MatrixServer:part(room)
+ if not self.connected then
+ --XXX'''
+ return
+ end
+
+ local id = urllib.quote(room.identifier)
+ local data = urllib.urlencode({
+ access_token= self.access_token,
+ })
+ http(('/rooms/%s/leave?%s'):format(id, data), {postfields = "{}"},
+ 'http_cb', 10000, room.identifier)
+end
+
+function MatrixServer:poll()
+ if self.connected == false then
+ return
+ end
+ if self.poll_lock then
+ return
+ end
+ self.poll_lock = true
+ self.polltime = os.time()
+ local filter = {}
+ if w.config_get_plugin('presence_filter') == 'on' then
+ filter = { -- timeline filter
+ presence = {
+ not_types = {'*'}, -- dont want presence
+ },
+ room = {
+ ephemeral = {
+ not_types = {'*'}, -- dont want read receipt and typing notices
+ }
+ }
+ }
+ end
+ local data = urllib.urlencode({
+ access_token = self.access_token,
+ timeout = 1000*POLL_INTERVAL,
+ full_state = 'false',
+ filter = json.encode(filter),
+ since = self.end_token
+ })
+ http('/sync?'..data, nil, 'http_cb', (POLL_INTERVAL+10)*1000)
+end
+
+function MatrixServer:addRoom(room)
+ -- Just in case, we check for duplicates here
+ if self.rooms[room['room_id']] then
+ return self.rooms[room['room_id']]
+ end
+ local myroom = Room.create(room)
+ myroom:create_buffer()
+ self.rooms[room['room_id']] = myroom
+ return myroom
+end
+
+function MatrixServer:delRoom(room_id)
+ for id, room in pairs(self.rooms) do
+ if id == room_id then
+ mprint('\tLeft room '..room.name)
+ room:destroy()
+ self.rooms[id] = nil
+ break
+ end
+ end
+end
+
+function MatrixServer:SendReadReceipt(room_id, event_id)
+ -- TODO: prevent sending multiple identical read receipts
+ local r_type = 'm.read'
+ local auth = urllib.urlencode{access_token=self.access_token}
+ room_id = urllib.quote(room_id)
+ event_id = urllib.quote(event_id)
+ local url = '/rooms/'..room_id..'/receipt/'..r_type..'/'..event_id..'?'..auth
+ http(url,
+ {customrequest = 'POST'},
+ 'http_cb',
+ 5*1000
+ )
+end
+
+function MatrixServer:Msg(room_id, body, msgtype, url)
+ -- check if there's an outgoing message timer already
+ self:ClearSendTimer()
+
+ if not msgtype then
+ msgtype = 'm.text'
+ end
+
+ if not OUT[room_id] then
+ OUT[room_id] = {}
+ end
+ -- Add message to outgoing queue of messages for this room
+ table.insert(OUT[room_id], {msgtype, body, url})
+
+ self:StartSendTimer()
+end
+
+function MatrixServer:StartSendTimer()
+ local send_delay = 50 -- Wait this long for paste detection
+ self.sendtimer = w.hook_timer(send_delay, 0, 1, "send", "")
+end
+
+function MatrixServer:ClearSendTimer()
+ -- Clear timer if it exists
+ if self.sendtimer then
+ w.unhook(self.sendtimer)
+ end
+ self.sendtimer = nil
+end
+
+function send(cbdata, calls)
+ SERVER:ClearSendTimer()
+ -- Find the room
+ local room
+
+ for id, msgs in pairs(OUT) do
+ -- Clear message
+ OUT[id] = nil
+ local body = {}
+ local htmlbody = {}
+ local msgtype
+ local url
+
+ local ishtml = false
+
+ for _, r in pairs(SERVER.rooms) do
+ if r.identifier == id then
+ room = r
+ break
+ end
+ end
+
+ for _, msg in pairs(msgs) do
+ -- last msgtype will override any other for simplicity's sake
+ msgtype = msg[1]
+ local html = irc_formatting_to_html(msg[2])
+ if html ~= msg[2] then
+ ishtml = true
+ end
+ table.insert(htmlbody, html )
+ table.insert(body, msg[2] )
+ if msg[3] then -- Primarily image upload
+ url = msg[3]
+ end
+ end
+ body = table.concat(body, '\n')
+
+ -- Run IRC modifiers (XXX: maybe run out1 also?
+ body = w.hook_modifier_exec('irc_out1_PRIVMSG', '', body)
+
+ if w.config_get_plugin('local_echo') == 'on' or
+ room.encrypted then
+ -- Generate local echo
+ local color = default_color
+ if msgtype == 'm.text' then
+ --- XXX: no localecho for encrypted messages?
+ local tags = 'notify_none,localecho,no_highlight'
+ if room.encrypted then
+ tags = tags .. ',no_log'
+ color = w.color(w.config_get_plugin(
+ 'encrypted_message_color'))
+ end
+ w.print_date_tags(room.buffer, nil,
+ tags, ("%s\t%s%s"):format(
+ room:formatNick(SERVER.user_id),
+ color,
+ irc_formatting_to_weechat_color(body)
+ )
+ )
+ elseif msgtype == 'm.emote' then
+ local prefix_c = wcolor'weechat.color.chat_prefix_action'
+ local prefix = wconf'weechat.look.prefix_action'
+ local tags = 'notify_none,localecho,irc_action,no_highlight'
+ if room.encrypted then
+ tags = tags .. ',no_log'
+ color = w.color(w.config_get_plugin(
+ 'encrypted_message_color'))
+ end
+ w.print_date_tags(room.buffer, nil,
+ tags, ("%s%s\t%s%s%s %s"):format(
+ prefix_c,
+ prefix,
+ w.color('chat_nick_self'),
+ room.users[SERVER.user_id],
+ color,
+ irc_formatting_to_weechat_color(body)
+ )
+ )
+ end
+ end
+
+ local data = {
+ postfields = {
+ msgtype = msgtype,
+ body = body,
+ url = url,
+ }}
+
+ if ishtml then
+ htmlbody = table.concat(htmlbody, '\n')
+ data.postfields.body = strip_irc_formatting(body)
+ data.postfields.format = 'org.matrix.custom.html'
+ data.postfields.formatted_body = htmlbody
+ end
+
+ local api_event_function = 'm.room.message'
+
+ if olmstatus and room.encrypted then
+ api_event_function = 'm.room.encrypted'
+ local olmd = SERVER.olm
+
+ data.postfields.algorithm = OLM_ALGORITHM
+ data.postfields.sender_key = olmd.device_key
+ data.postfields.ciphertext = {}
+
+ -- Count number of devices we are sending to
+ local recipient_count = 0
+
+ for user_id, _ in pairs(room.users) do
+ for device_id, device_data in pairs(olmd.device_keys[user_id] or {}) do -- FIXME check for missing keys?
+
+ local device_key
+ -- TODO save this better somehow?
+ for key_id, key_data in pairs(device_data.keys) do
+ if key_id:match('^curve25519') then
+ device_key = key_data
+ end
+ end
+ local sessions = olmd:get_sessions(device_key)
+ -- Use the session with the lowest ID
+ -- TODO: figure out how to pick session better?
+ table.sort(sessions)
+ local pickled = next(sessions)
+ if pickled then
+ local session = olm.Session.new()
+ session:unpickle(OLM_KEY, pickled)
+ local session_id = session:session_id()
+ perr(('Session ID: %s, user_id: %s, device_id: %s'):
+ format(session_id, user_id, device_id))
+ local payload = {
+ room_id = room.identifier,
+ ['type'] = "m.room.message",
+ fingerprint = "", -- TODO: Olm:sha256 participants
+ sender_device = olmd.device_id,
+ content = {
+ msgtype = msgtype,
+ body = data.postfields.body or '',
+ url = url
+ }
+ }
+ -- encrypt body
+ local mtype, e_body = session:encrypt(json.encode(payload))
+ local ciphertext = {
+ ["type"] = mtype,
+ body = e_body
+ }
+ data.postfields.ciphertext[device_key] = ciphertext
+ recipient_count = recipient_count + 1
+
+ -- Save session
+ olmd:store_session(device_key, session)
+ session:clear()
+ end
+ end
+ end
+ -- remove cleartext from original msg
+ data.postfields.body = nil
+ data.postfields.formatted_body = nil
+
+ if recipient_count == 0 then
+ perr('Aborted sending of encrypted message: could not find any valid recipients')
+ return
+ end
+ end
+
+ data.postfields = json.encode(data.postfields)
+ data.customrequest = 'PUT'
+
+ http(('/rooms/%s/send/%s/%s?access_token=%s')
+ :format(
+ urllib.quote(id),
+ api_event_function,
+ get_next_transaction_id(),
+ urllib.quote(SERVER.access_token)
+ ),
+ data,
+ nil,
+ nil,
+ id -- send room id to extra
+ )
+ end
+end
+
+function MatrixServer:emote(room_id, body)
+ self:Msg(room_id, body, 'm.emote')
+end
+
+function MatrixServer:notice(room_id, body)
+ self:Msg(room_id, body, 'm.notice')
+end
+
+function MatrixServer:state(room_id, key, data)
+ http(('/rooms/%s/state/%s?access_token=%s')
+ :format(urllib.quote(room_id),
+ urllib.quote(key),
+ urllib.quote(self.access_token)),
+ {customrequest = 'PUT',
+ postfields = json.encode(data),
+ })
+end
+
+function MatrixServer:set_membership(room_id, userid, data)
+ http(('/rooms/%s/state/m.room.member/%s?access_token=%s')
+ :format(urllib.quote(room_id),
+ urllib.quote(userid),
+ urllib.quote(self.access_token)),
+ {customrequest = 'PUT',
+ postfields = json.encode(data),
+ })
+end
+
+function MatrixServer:SendPresence(p, status_msg)
+ -- One of: ["online", "offline", "unavailable", "free_for_chat"]
+ local data = {
+ presence = p,
+ status_msg = status_msg
+ }
+ http(('/presence/%s/status?access_token=%s')
+ :format(
+ urllib.quote(self.user_id),
+ urllib.quote(self.access_token)),
+ {customrequest = 'PUT',
+ postfields = json.encode(data),
+ })
+end
+
+function MatrixServer:SendTypingNotice(room_id)
+ local data = {
+ typing = true,
+ timeout = 4*1000
+ }
+ http(('/rooms/%s/typing/%s?access_token=%s')
+ :format(urllib.quote(room_id),
+ urllib.quote(self.user_id),
+ urllib.quote(self.access_token)),
+ {customrequest = 'PUT',
+ postfields = json.encode(data),
+ })
+end
+
+function MatrixServer:Upload(room_id, filename)
+ local content_type = 'image/jpeg'
+ if filename:match'%.[Pp][nN][gG]$' then
+ content_type = 'image/png'
+ end
+ local url = w.config_get_plugin('homeserver_url') ..
+ ('_matrix/media/r0/upload?access_token=%s')
+ :format( urllib.quote(SERVER.access_token) )
+ w.hook_process_hashtable('curl', {
+ arg1 = '--data-binary', -- no encoding of data
+ arg2 = '@'..filename, -- @means curl will load the filename
+ arg3 = '-XPOST', -- HTTP POST method
+ arg4 = '-H', -- header
+ arg5 = 'Content-Type: '..content_type,
+ arg6 = '-s', -- silent
+ arg7 = url,
+ }, 30*1000, 'upload_cb', room_id)
+end
+
+function MatrixServer:CreateRoom(public, alias, invites)
+ local data = {}
+ if alias then
+ data.room_alias_name = alias
+ end
+ if public then
+ data.visibility = 'public'
+ else
+ data.visibility = 'private'
+ end
+ if invites then
+ data.invite = invites
+ end
+ http(('/createRoom?access_token=%s')
+ :format(urllib.quote(self.access_token)),
+ {customrequest = 'POST',
+ postfields = json.encode(data),
+ })
+end
+
+function MatrixServer:CreateRoomAlias(room_id, alias)
+ local data = {room_id = room_id}
+ alias = urllib.quote(alias)
+ http(('/directory/room/%s?access_token=%s')
+ :format(alias, urllib.quote(self.access_token)),
+ {customrequest = 'PUT',
+ postfields = json.encode(data),
+ })
+end
+
+function MatrixServer:ListRooms(arg)
+ local apipart = ('/publicRooms?access_token=%s'):format(urllib.quote(self.access_token))
+ if arg then
+ local url = 'https://' .. arg .. "/_matrix/client/r0"
+ http(url..apipart)
+ else
+ http(apipart)
+ end
+end
+
+function MatrixServer:Invite(room_id, user_id)
+ local data = {
+ user_id = user_id
+ }
+ http(('/rooms/%s/invite?access_token=%s')
+ :format(urllib.quote(room_id),
+ urllib.quote(self.access_token)),
+ {customrequest = 'POST',
+ postfields = json.encode(data),
+ })
+end
+
+function MatrixServer:Nick(displayname)
+ local data = {
+ displayname = displayname,
+ }
+ http(('/profile/%s/displayname?access_token=%s')
+ :format(
+ urllib.quote(self.user_id),
+ urllib.quote(self.access_token)),
+ {customrequest = 'PUT',
+ postfields = json.encode(data),
+ })
+end
+
+function buffer_input_cb(b, buffer, data)
+ for r_id, room in pairs(SERVER.rooms) do
+ if buffer == room.buffer then
+ SERVER:Msg(r_id, data)
+ break
+ end
+ end
+ return w.WEECHAT_RC_OK
+end
+
+Room = {}
+Room.__index = Room
+Room.create = function(obj)
+ local room = {}
+ setmetatable(room, Room)
+ room.buffer = nil
+ room.identifier = obj['room_id']
+ local _, server = room.identifier:match('^(.*):(.+)$')
+ room.server = server
+ room.member_count = 0
+ -- Cache users for presence/nicklist
+ room.users = {}
+ -- Table of ids currently typing
+ room.typing_ids = {}
+ -- Cache the rooms power levels state
+ room.power_levels = {users={}, users_default=0}
+ -- Encryption status of room
+ room.encrypted = false
+ room.visibility = 'public'
+ room.join_rule = nil
+ room.roomname = nil -- m.room.name
+ room.aliases = nil -- aliases
+ room.canonical_alias = nil
+
+ -- We might not be a member yet
+ local state_events = obj.state or {}
+ for _, state in ipairs(state_events) do
+ if state['type'] == 'm.room.aliases' then
+ local name = state.content.aliases[1]
+ if name then
+ room.name, _ = name:match('(.+):(.+)')
+ end
+ end
+ end
+ if not room.name then
+ room.name = room.identifier
+ end
+ if not room.server then
+ room.server = 'matrix'
+ end
+
+ room.visibility = obj.visibility
+ if not obj['visibility'] then
+ room.visibility = 'public'
+ end
+
+ return room
+end
+
+function Room:SetName(name)
+ if not name or name == '' or name == json.null then
+ return
+ end
+ -- override hierarchy
+ if self.roomname and self.roomname ~= '' then
+ name = self.roomname
+ elseif self.canonical_alias then
+ name = self.canonical_alias
+ local short_name, _ = self.canonical_alias:match('^(.-):(.+)$')
+ if short_name then
+ name = short_name
+ end
+ elseif self.aliases then
+ local alias = self.aliases[1]
+ if name then
+ local _
+ name, _ = alias:match('(.+):(.+)')
+ end
+ else
+ -- NO names. Set dynamic name based on members
+ local new = {}
+ for id, nick in pairs(self.users) do
+ -- Set the name to the other party
+ if id ~= SERVER.user_id then
+ new[#new+1] = nick
+ end
+ end
+ name = table.concat(new, ',')
+ end
+
+ if not name or name == '' or name == json.null then
+ return
+ end
+
+ -- Check for dupe
+ local buffer_name = w.buffer_get_string(self.buffer, 'name')
+ if buffer_name == name then
+ return
+ end
+
+
+ w.buffer_set(self.buffer, "short_name", name)
+ w.buffer_set(self.buffer, "name", name)
+ -- Doesn't work
+ w.buffer_set(self.buffer, "plugin", "matrix")
+ w.buffer_set(self.buffer, "full_name",
+ self.server.."."..name)
+ w.buffer_set(self.buffer, "localvar_set_channel", name)
+end
+
+function Room:Topic(topic)
+ SERVER:state(self.identifier, 'm.room.topic', {topic=topic})
+end
+
+function Room:Name(name)
+ SERVER:state(self.identifier, 'm.room.name', {name=name})
+end
+
+function Room:public()
+ SERVER:state(self.identifier, 'm.room.join_rules', {join_rule='public'})
+end
+
+function Room:Upload(filename)
+ SERVER:Upload(self.identifier, filename)
+end
+
+function Room:Msg(msg)
+ SERVER:Msg(self.identifier, msg)
+end
+
+function Room:emote(msg)
+ SERVER:emote(self.identifier, msg)
+end
+
+function Room:Notice(msg)
+ SERVER:notice(self.identifier, msg)
+end
+
+function Room:SendTypingNotice()
+ SERVER:SendTypingNotice(self.identifier)
+end
+
+function Room:create_buffer()
+ --local buffer = w.buffer_search("", ("%s.%s"):format(self.server, self.name))
+ self.buffer = w.buffer_new(("%s.%s")
+ :format(self.server, self.name), "buffer_input_cb",
+ self.name, "closed_matrix_room_cb", "")
+ -- Needs to correspond with return values from Room:GetNickGroup()
+ -- We will use 5 nick groups:
+ -- 1: Ops
+ -- 2: Half-ops
+ -- 3: Voice
+ -- 4: People with presence
+ -- 5: People without presence
+ self.nicklist_groups = {
+ -- Emulate OPs
+ w.nicklist_add_group(self.buffer,
+ '', "000|o", "weechat.color.nicklist_group", 1),
+ w.nicklist_add_group(self.buffer,
+ '', "001|h", "weechat.color.nicklist_group", 1),
+ -- Emulate half-op
+ w.nicklist_add_group(self.buffer,
+ '', "002|v", "weechat.color.nicklist_group", 1),
+ -- Defined in weechat's irc-nick.h
+ w.nicklist_add_group(self.buffer,
+ '', "998|...", "weechat.color.nicklist_group", 1),
+ w.nicklist_add_group(self.buffer,
+ '', "999|...", "weechat.color.nicklist_group", 1),
+ }
+ w.buffer_set(self.buffer, "nicklist", "1")
+ -- Set to 1 for easier debugging of nick groups
+ w.buffer_set(self.buffer, "nicklist_display_groups", "0")
+ w.buffer_set(self.buffer, "localvar_set_server", self.server)
+ w.buffer_set(self.buffer, "localvar_set_roomid", self.identifier)
+ self:SetName(self.name)
+ if self.membership == 'invite' then
+ self:addNick(self.inviter)
+ if w.config_get_plugin('autojoin_on_invite') ~= 'on' then
+ w.print_date_tags(
+ self.buffer,
+ nil,
+ 'notify_message',
+ ('You have been invited to join room %s by %s. Type /join in this buffer to join.')
+ :format(
+ self.name,
+ self.inviter,
+ self.identifier)
+ )
+ end
+ end
+end
+
+function Room:Freeze()
+ -- Function that saves all the lines in a buffer in a cache to be thawed
+ -- later. Used to redraw buffer when user requests more lines. Since
+ -- WeeChat can only render lines in order this is the workaround
+ local freezer = {}
+ local lines = w.hdata_pointer(w.hdata_get('buffer'), self.buffer, 'own_lines')
+ if lines == '' then return end
+ -- Start at top
+ local line = w.hdata_pointer(w.hdata_get('lines'), lines, 'first_line')
+ if line == '' then return end
+ local hdata_line = w.hdata_get('line')
+ local hdata_line_data = w.hdata_get('line_data')
+ while #line > 0 do
+ local data = w.hdata_pointer(hdata_line, line, 'data')
+ local tags = {}
+ local tag_count = w.hdata_integer(hdata_line_data, data, "tags_count")
+ if tag_count > 0 then
+ for i = 0, tag_count-1 do
+ local tag = w.hdata_string(hdata_line_data, data, i .. "|tags_array")
+ -- Skip notify tags since this is backlog
+ if not tag:match'^notify' then
+ tags[#tags+1] = tag
+ end
+ end
+ end
+ tags[#tags+1] = 'no_log'
+ freezer[#freezer+1] = {
+ time = w.hdata_integer(hdata_line_data, data, 'time'),
+ tags = tags,
+ prefix = w.hdata_string(hdata_line_data, data, 'prefix'),
+ message = w.hdata_string(hdata_line_data, data, 'message'),
+ }
+ -- Move forward since we start at top
+ line = w.hdata_move(hdata_line, line, 1)
+ end
+ self.freezer = freezer
+end
+
+function Room:Thaw()
+ for _,l in ipairs(self.freezer) do
+ w.print_date_tags(
+ self.buffer,
+ l.time,
+ table.concat(l.tags, ','),
+ l.prefix .. '\t' .. l.message
+ )
+ end
+ -- Clear old data
+ self.freezer = nil
+end
+
+function Room:Clear()
+ w.buffer_clear(self.buffer)
+end
+
+function Room:destroy()
+ w.buffer_close(self.buffer)
+end
+
+function Room:_nickListChanged()
+ -- Check the user count, if it's 2 or less then we decide this buffer
+ -- is a "private" one like IRC's query type
+ if self.member_count == 3 then
+ w.buffer_set(self.buffer, "localvar_set_type", 'channel')
+ self.buffer_type = 'channel'
+ elseif self.member_count == 2 then
+ -- At the point where we reach two nicks, set the buffer name to be
+ -- the display name of the other guy that is not our self since it's
+ -- in effect a query, but the matrix protocol doesn't have such
+ -- a concept
+ w.buffer_set(self.buffer, "localvar_set_type", 'private')
+ self.buffer_type = 'query'
+ elseif self.member_count == 1 then
+ if not self.roomname and not self.aliases then
+ -- Set the name to ourselves
+ self:SetName(self.users[SERVER.user_id])
+ end
+ end
+end
+
+function Room:addNick(user_id, displayname)
+ local newnick = false
+ -- Sanitize displaynames a bit
+ if not displayname
+ or displayname == json.null
+ or displayname == ''
+ or displayname:match'^%s+$' then
+ displayname = user_id:match('@(.*):.+')
+ end
+ if not self.users[user_id] then
+ self.member_count = self.member_count + 1
+ newnick = true
+ end
+
+ if self.users[user_id] ~= displayname then
+ self.users[user_id] = displayname
+ end
+
+ local nick_c = self:GetPresenceNickColor(user_id, SERVER.presence[user_id])
+ -- Check if this is ourselves
+ if user_id == SERVER.user_id then
+ w.buffer_set(self.buffer, "highlight_words", displayname)
+ w.buffer_set(self.buffer, "localvar_set_nick", displayname)
+ end
+
+ local ngroup, nprefix, nprefix_color = self:GetNickGroup(user_id)
+ -- Check if nick already exists
+ --local nick_ptr = w.nicklist_search_nick(self.buffer, '', displayname)
+ --if nick_ptr == '' then
+ local nick_ptr = w.nicklist_add_nick(self.buffer,
+ self.nicklist_groups[ngroup],
+ displayname,
+ nick_c, nprefix, nprefix_color, 1)
+ --else
+ -- -- TODO CHANGE nickname here
+ --end
+ if nick_ptr == '' then
+ -- Duplicate nick names :(
+ -- We just add the full id to the nicklist so atleast it will show
+ -- but we should probably assign something new and track the state
+ -- so we can print msgs with non-conflicting nicks too
+ w.nicklist_add_nick(self.buffer,
+ self.nicklist_groups[ngroup],
+ user_id,
+ nick_c, nprefix, nprefix_color, 1)
+ -- Since we can't allow duplicate displaynames, we just use the
+ -- user_id straight up. Maybe we could invent some clever
+ -- scheme here, like user(homeserver), user (2) or something
+ self.users[user_id] = user_id
+ end
+
+ if newnick then -- run this after nick been added so it can be used
+ self:_nickListChanged()
+ end
+
+ return displayname
+end
+
+function Room:GetNickGroup(user_id)
+ -- TODO, cache
+ local ngroup = 5
+ local nprefix = ' '
+ local nprefix_color = ''
+ if self:GetPowerLevel(user_id) >= 100 then
+ ngroup = 1
+ nprefix = '&'
+ nprefix_color = 'lightgreen'
+ if user_id == self.creator then
+ nprefix = '~'
+ nprefix_color = 'lightred'
+ end
+ elseif self:GetPowerLevel(user_id) >= 50 then
+ ngroup = 2
+ nprefix = '@'
+ nprefix_color = 'lightgreen'
+ elseif self:GetPowerLevel(user_id) > 0 then
+ ngroup = 3
+ nprefix = '+'
+ nprefix_color = 'yellow'
+ elseif SERVER.presence[user_id] then
+ -- User has a presence, put him in group3
+ ngroup = 4
+ end
+ return ngroup, nprefix, nprefix_color
+end
+
+function Room:GetPowerLevel(user_id)
+ return tonumber(self.power_levels.users[user_id] or self.power_levels.users_default or 0)
+end
+
+function Room:ClearTyping()
+ for user_id, nick in pairs(self.users) do
+ local _, nprefix, nprefix_color = self:GetNickGroup(user_id)
+ self:UpdateNick(user_id, 'prefix', nprefix)
+ self:UpdateNick(user_id, 'prefix_color', nprefix_color)
+ end
+end
+
+function Room:GetPresenceNickColor(user_id, presence)
+ local nick = self.users[user_id]
+ local nick_c
+ if user_id == SERVER.user_id then
+ -- Always use correct color for self
+ nick_c = 'weechat.color.chat_nick_self'
+ elseif presence == 'online' then
+ nick_c = w.info_get('irc_nick_color_name', nick)
+ elseif presence == 'unavailable' then
+ nick_c = 'weechat.color.nicklist_away'
+ elseif presence == 'offline' then
+ nick_c = 'red'
+ elseif presence == nil then
+ nick_c = 'bar_fg'
+ else
+ dbg{err='unknown presence type',presence=presence}
+ end
+ return nick_c
+end
+
+function Room:UpdatePresence(user_id, presence)
+ if presence == 'typing' then
+ self:UpdateNick(user_id, 'prefix', '!')
+ self:UpdateNick(user_id, 'prefix_color', 'magenta')
+ return
+ end
+ local nick_c = self:GetPresenceNickColor(user_id, presence)
+ self:UpdateNick(user_id, 'color', nick_c)
+end
+
+function Room:UpdateNick(user_id, key, val)
+ local nick = self.users[user_id]
+ if not nick then return end
+ local nick_ptr = w.nicklist_search_nick(self.buffer, '', nick)
+
+ if nick_ptr ~= '' and key and val then
+ -- Check if we need to move the nick into another group
+ local group_ptr = w.nicklist_nick_get_pointer(self.buffer, nick_ptr,
+ 'group')
+ local ngroup, nprefix, nprefix_color = self:GetNickGroup(user_id)
+ if group_ptr ~= self.nicklist_groups[ngroup] then
+ local nick_c = w.nicklist_nick_get_string(self.buffer, nick_ptr,
+ 'color')
+ -- No WeeChat API for changing a nick's group so we will have to
+ -- delete the nick from the old nicklist and add it to the correct
+ -- nicklist group
+ w.nicklist_remove_nick(self.buffer, nick_ptr)
+ -- TODO please check if this call fails, if it does it means the
+ -- WeeChat version is old and has a bug so it can't remove nicks
+ -- and so it needs some workaround
+ nick_ptr = w.nicklist_add_nick(self.buffer,
+ self.nicklist_groups[ngroup],
+ nick,
+ nick_c, nprefix, nprefix_color, 1)
+ end
+ -- Check if we are clearing a typing notice, and don't issue updates
+ -- if we are, because it spams the API so much, including potential
+ -- relay clients
+ if key == 'prefix' and val == ' ' then
+ -- TODO check existing values like + and @ too
+ local prefix = w.nicklist_nick_get_string(self.buffer, nick_ptr,
+ key)
+ if prefix == '!' then
+ w.nicklist_nick_set(self.buffer, nick_ptr, key, val)
+ end
+ elseif key == 'prefix_color' then
+ local prefix_color = w.nicklist_nick_get_string(self.buffer,
+ nick_ptr, key)
+ if prefix_color ~= val then
+ w.nicklist_nick_set(self.buffer, nick_ptr, key, val)
+ end
+ else
+ -- Check if we are actually updating something, so there's less
+ -- updates issued (I think WeeChat sends all changes as nicklist
+ -- diffs to both UI code and to relay clients
+ local existing = w.nicklist_nick_get_string(self.buffer, nick_ptr, key)
+ if val ~= existing then
+ w.nicklist_nick_set(self.buffer, nick_ptr, key, val)
+ end
+ end
+ end
+end
+
+function Room:delNick(id)
+ if self.users[id] then
+ local nick = self.users[id]
+ local nick_ptr = w.nicklist_search_nick(self.buffer, '', nick)
+ if nick_ptr ~= '' then
+ w.nicklist_remove_nick(self.buffer, nick_ptr)
+ end
+ self.users[id] = nil
+ self.member_count = self.member_count - 1
+ self:_nickListChanged()
+ return true
+ end
+end
+
+function Room:UpdateLine(id, message)
+ local lines = w.hdata_pointer(w.hdata_get('buffer'), self.buffer, 'own_lines')
+ if lines == '' then return end
+ local line = w.hdata_pointer(w.hdata_get('lines'), lines, 'last_line')
+ if line == '' then return end
+ local hdata_line = w.hdata_get('line')
+ local hdata_line_data = w.hdata_get('line_data')
+ while #line > 0 do
+ local needsupdate = false
+ local data = w.hdata_pointer(hdata_line, line, 'data')
+ local tags = {}
+ local tag_count = w.hdata_integer(hdata_line_data, data, "tags_count")
+ if tag_count > 0 then
+ for i = 0, tag_count-1 do
+ local tag = w.hdata_string(hdata_line_data, data, i .. "|tags_array")
+ tags[#tags+1] = tag
+ if tag:match(id) then
+ needsupdate = true
+ end
+ end
+ if needsupdate then
+ w.hdata_update(hdata_line_data, data, {
+ prefix = nil,
+ message = message,
+ tags_array = table.concat(tags, ','),
+ })
+ return true
+ end
+ end
+ line = w.hdata_move(hdata_line, line, -1)
+ end
+ return false
+end
+
+function Room:formatNick(user_id)
+ -- Turns a nick name into a weechat-styled nickname. This means giving
+ -- it colors, and proper prefix and suffix
+ local nick = self.users[user_id]
+ if not nick then
+ return user_id
+ end
+ -- Remove nasty white space
+ nick = nick:gsub('[\n\t]', '')
+ local color
+ if user_id == SERVER.user_id then
+ color = w.color('chat_nick_self')
+ else
+ color = w.info_get('irc_nick_color', nick)
+ end
+ local _, nprefix, nprefix_c = self:GetNickGroup(user_id)
+ local prefix = wconf('weechat.look.nick_prefix')
+ local prefix_c = wcolor('weechat.color.chat_nick_prefix')
+ local suffix = wconf('weechat.look.nick_suffix')
+ local suffix_c = wcolor('weechat.color.chat_nick_suffix')
+ local nick_f = prefix_c
+ .. prefix
+ .. wcolor(nprefix_c)
+ .. nprefix
+ .. color
+ .. nick
+ .. suffix_c
+ .. suffix
+ return nick_f
+end
+
+function Room:decryptChunk(chunk)
+ -- vector client doesn't provide this
+ chunk.content.msgtype = 'm.text'
+
+ if not olmstatus then
+ chunk.content.body = 'encrypted message, unable to decrypt'
+ return chunk
+ end
+
+ chunk.content.body = 'encrypted message, unable to decrypt'
+ local device_key = chunk.content.sender_key
+ -- Find our id
+ local ciphertexts = chunk.content.ciphertext
+ local ciphertext
+ if not ciphertexts then
+ chunk.content.body = 'Recieved an encrypted message, but could not find ciphertext array'
+ else
+ ciphertext = ciphertexts[SERVER.olm.device_key]
+ end
+ if not ciphertext then
+ chunk.content.body = 'Recieved an encrypted message, but could not find cipher for ourselves from the sender.'
+ return chunk
+ end
+
+ local session
+ local decrypted
+ local err
+ local found_session = false
+ local sessions = SERVER.olm:get_sessions(device_key)
+ for id, pickle in pairs(sessions) do
+ -- Check if we already successfully decrypted with a sesssion, if that
+ -- is the case we break the loop
+ if decrypted then
+ break
+ end
+ session = olm.Session.new()
+ session:unpickle(OLM_KEY, pickle)
+ local matches_inbound = session:matches_inbound(ciphertext.body)
+ ---if ciphertext.type == 0 and matches_inbound then
+ if matches_inbound then
+ found_session = true
+ end
+ local cleartext
+ cleartext, err = session:decrypt(ciphertext.type, ciphertext.body)
+ if not err then
+ if DEBUG then
+ perr(('olm: Able to decrypt with an existing session %s'):format(session:session_id()))
+ end
+ decrypted = cleartext
+ SERVER.olm:store_session(device_key, session)
+ else
+ chunk.content.body = "Decryption error: "..err
+ if DEBUG then
+ perr(('olm: Unable to decrypt with an existing session: %s. Session-ID: %s'):format(err, session:session_id()))
+ end
+ end
+ session:clear()
+ end
+ if ciphertext.type == 0 and not found_session and not decrypted then
+ session = olm.Session.new()
+ local _
+ _, err = session:create_inbound_from(
+ SERVER.olm.account, device_key, ciphertext.body)
+ if err then
+ session:clear()
+ chunk.content.body = "Decryption error: create inbound "..err
+ return chunk
+ end
+ decrypted, err = session:decrypt(ciphertext.type, ciphertext.body)
+ if err then
+ session:clear()
+ chunk.content.body = "Decryption error: "..err
+ return chunk
+ end
+ -- TODO SERVER.olm.account:remove_one_time_keys(session)
+ local session_id = session:session_id()
+ perr(('Session ID: %s, user_id: %s, device_id: %s'):
+ format(session_id, SERVER.user_id, SERVER.olm.device_id))
+ SERVER.olm:store_session(device_key, session)
+ session:clear()
+ if err then
+ chunk.content.body = "Decryption error: "..err
+ return chunk
+ end
+ end
+
+ if decrypted then
+ local success, payload = pcall(json.decode, decrypted)
+ if not success then
+ chunk.content.body = "Payload error: "..payload
+ return chunk
+ end
+ -- TODO use the room id from payload for security
+ chunk.content.msgtype = payload.content.msgtype
+ -- Style the message so user can tell if it's
+ -- an encrypted message or not
+ local color = w.color(w.config_get_plugin(
+ 'encrypted_message_color'))
+ chunk.content.body = color .. payload.content.body
+ end
+
+ return chunk
+end
+
+-- Parses a chunk of json meant for a room
+function Room:ParseChunk(chunk, backlog, chunktype)
+ local taglist = {}
+ local tag = function(tag)
+ -- Helper function to add tags
+ if type(tag) == 'table' then
+ for _, t in ipairs(tag) do
+ taglist[t] = true
+ end
+ else
+ taglist[tag] = true
+ end
+ end
+ local tags = function()
+ -- Helper for returning taglist for this message
+ local out = {}
+ for k, v in pairs(taglist) do
+ table.insert(out, k)
+ end
+ return table.concat(out, ',')
+ end
+ if not backlog then
+ backlog = false
+ end
+
+ if backlog then
+ tag{'no_highlight','notify_none','no_log'}
+ end
+
+ local is_self = false
+ local was_decrypted = false
+
+ -- Sender of chunk, used to be chunk.user_id, v2 uses chunk.sender
+ local sender = chunk.sender or chunk.user_id
+ -- Check if own message
+ if sender == SERVER.user_id then
+ is_self = true
+ tag{'no_highlight','notify_none'}
+ end
+ -- Add Event ID to each line so can use it later to match on for things
+ -- like redactions and localecho, etc
+ tag{chunk.event_id}
+
+ -- Some messages are missing ts
+ local origin_server_ts = chunk['origin_server_ts'] or 0
+ local time_int = origin_server_ts/1000
+
+ if chunk['type'] == 'm.room.message' or chunk['type'] == 'm.room.encrypted' then
+ if chunk['type'] == 'm.room.encrypted' then
+ tag{'no_log'} -- Don't log encrypted message
+ chunk = self:decryptChunk(chunk)
+ was_decrypted = true
+ end
+
+ if not backlog and not is_self then
+ tag'notify_message'
+ if self.buffer_type == 'query' then
+ tag'notify_private'
+ end
+ end
+
+ local color = default_color
+ local content = chunk['content']
+ local body = content['body']
+
+ if not content['msgtype'] then
+ -- We don't support redactions
+ return
+ end
+
+ -- If it has transaction id, it is from this client.
+ local is_from_this_client = false
+ if chunk.unsigned and chunk.unsigned.transaction_id then
+ is_from_this_client = true
+ end
+
+ -- luacheck: ignore 542
+ if content['msgtype'] == 'm.text' then
+ -- TODO
+ -- Parse HTML here:
+ -- content.format = 'org.matrix.custom.html'
+ -- fontent.formatted_body...
+ elseif content['msgtype'] == 'm.image' then
+ local url = content['url']
+ if type(url) ~= 'string' then
+ url = ''
+ end
+ url = url:gsub('mxc://',
+ w.config_get_plugin('homeserver_url')
+ .. '_matrix/media/v1/download/')
+ -- Synapse homeserver supports arbitrary file endings, so we put
+ -- filename at the end to make it nicer for URL "sniffers" to
+ -- realise it's a image URL
+ body = url .. '/' .. content.body
+ elseif content.msgtype == 'm.file' or content.msgtype == 'm.video' or
+ content.msgtype == 'm.audio' then
+ local url = content['url'] or ''
+ url = url:gsub('mxc://',
+ w.config_get_plugin('homeserver_url')
+ .. '_matrix/media/v1/download/')
+ body = 'File upload: ' ..
+ tostring(content['body'])
+ .. ' ' .. url
+ elseif content['msgtype'] == 'm.notice' then
+ color = wcolor('irc.color.notice')
+ body = content['body']
+ elseif content['msgtype'] == 'm.emote' then
+ local nick_c
+ local nick = self.users[sender] or sender
+ if is_self then
+ nick_c = w.color('chat_nick_self')
+ else
+ nick_c = w.info_get('irc_nick_color', nick)
+ end
+ tag"irc_action"
+ local prefix_c = wcolor'weechat.color.chat_prefix_action'
+ local prefix = wconf'weechat.look.prefix_action'
+ body = ("%s%s %s%s"):format(
+ nick_c, nick, color, content['body']
+ )
+ prefix = prefix_c .. prefix
+ local data = ("%s\t%s"):format(prefix, body)
+ if not backlog and is_self and is_from_this_client and
+ ( w.config_get_plugin('local_echo') == 'on'
+ or was_decrypted -- local echo for encryption
+ )
+ then
+ -- We have already locally echoed this line
+ return
+ else
+ return w.print_date_tags(self.buffer, time_int, tags(), data)
+ end
+ else
+ -- Unknown content type, but if it contains an URL we will print
+ -- URL and body
+ local url = content['url']
+ if url ~= nil then
+ url = url:gsub('mxc://',
+ w.config_get_plugin('homeserver_url')
+ .. '_matrix/media/v1/download/')
+ body = content['body'] .. ' ' .. url
+ end
+ dbg {
+ warning='Warning: unknown/unhandled content type',
+ event=content
+ }
+ end
+ if not backlog and is_self and is_from_this_client
+ -- TODO better check, to work for multiple weechat clients
+ and (
+ w.config_get_plugin('local_echo') == 'on'
+ or was_decrypted -- local echo for encrypted messages
+ )
+ and (-- we don't generate local echo for files and images
+ content.msgtype == 'm.text'
+ )
+ then
+ -- We have already locally echoed this line
+ return
+ end
+ local data = ("%s\t%s%s"):format(
+ self:formatNick(sender),
+ color,
+ body)
+ w.print_date_tags(self.buffer, time_int, tags(), data)
+ elseif chunk['type'] == 'm.room.topic' then
+ local title = chunk['content']['topic']
+ if not title then
+ title = ''
+ end
+ w.buffer_set(self.buffer, "title", title)
+ local color = wcolor("irc.color.topic_new")
+ local nick = self.users[sender] or sender
+ local data = ('--\t%s%s has changed the topic to "%s%s%s"'):format(
+ nick,
+ default_color,
+ color,
+ title,
+ default_color
+ )
+ w.print_date_tags(self.buffer, chunk.origin_server_ts, tags(),
+ data)
+ elseif chunk['type'] == 'm.room.name' then
+ local name = chunk['content']['name']
+ if name ~= '' or name ~= json.null then
+ self.roomname = name
+ self:SetName(name)
+ end
+ elseif chunk['type'] == 'm.room.member' then
+ if chunk['content']['membership'] == 'join' then
+ tag"irc_join"
+ --- FIXME shouldn't be neccessary adding all the time
+ local name = self.users[sender] or self:addNick(sender, chunk.content.displayname)
+ if not name or name == json.null or name == '' then
+ name = sender
+ end
+ -- Check if the chunk has prev_content or not
+ -- if there is prev_content there wasn't a join but a nick change
+ -- or duplicate join
+ local prev_content = chunk.unsigned and chunk.unsigned.prev_content
+ if prev_content
+ and prev_content.membership == 'join'
+ and chunktype == 'messages' then
+ local oldnick = prev_content.displayname
+ if not oldnick or oldnick == json.null then
+ oldnick = sender
+ else
+ if oldnick == name then
+ -- Maybe they changed their avatar or something else
+ -- that we don't care about (or multiple joins)
+ return
+ end
+ if not backlog then
+ self:delNick(sender)
+ self:addNick(sender, chunk.content.displayname)
+ end
+ end
+ local pcolor = wcolor'weechat.color.chat_prefix_network'
+ tag'irc_nick'
+ local data = ('%s--\t%s%s%s is now known as %s%s'):format(
+ pcolor,
+ w.info_get('irc_nick_color', oldnick),
+ oldnick,
+ default_color,
+ w.info_get('irc_nick_color', name),
+ name)
+ w.print_date_tags(self.buffer, time_int, tags(), data)
+ elseif chunktype == 'messages' then
+ tag"irc_smart_filter"
+ local data = ('%s%s\t%s%s%s (%s%s%s) joined the room.'):format(
+ wcolor('weechat.color.chat_prefix_join'),
+ wconf('weechat.look.prefix_join'),
+ w.info_get('irc_nick_color', name),
+ name,
+ wcolor('irc.color.message_join'),
+ wcolor'weechat.color.chat_host',
+ sender,
+ wcolor('irc.color.message_join')
+ )
+ w.print_date_tags(self.buffer, time_int, tags(), data)
+ -- if this is an encrypted room, also download key
+ if olmstatus and self.encrypted then
+ SERVER.olm:query{sender}
+ end
+ end
+ elseif chunk['content']['membership'] == 'leave' then
+ if chunktype == 'messages' then
+ local nick = self.users[chunk.state_key] or sender
+ local prev = chunk.unsigned.prev_content
+ if (prev and
+ prev.displayname and
+ prev.displayname ~= json.null) then
+ nick = prev.displayname
+ end
+ if sender ~= chunk.state_key then -- Kick
+ tag{"irc_quit","irc_kick","irc_smart_filter"}
+ local reason = chunk.content.reason or ''
+ local sender_nick = self.users[chunk.sender]
+ local data = ('%s%s\t%s%s%s has kicked %s%s%s (%s).'):format(
+ wcolor('weechat.color.chat_prefix_quit'),
+ wconf('weechat.look.prefix_quit'),
+ w.info_get('irc_nick_color', sender_nick),
+ sender_nick,
+ wcolor('irc.color.message_quit'),
+ w.info_get('irc_nick_color', nick),
+ nick,
+ default_color,
+ reason
+ )
+ w.print_date_tags(self.buffer, time_int, tags(), data)
+ else
+ tag{"irc_quit","irc_smart_filter"}
+ local data = ('%s%s\t%s%s%s left the room.'):format(
+ wcolor('weechat.color.chat_prefix_quit'),
+ wconf('weechat.look.prefix_quit'),
+ w.info_get('irc_nick_color', nick),
+ nick,
+ wcolor('irc.color.message_quit')
+ )
+ w.print_date_tags(self.buffer, time_int, tags(), data)
+ end
+ end
+ self:delNick(chunk.state_key)
+ elseif chunk['content']['membership'] == 'invite' then
+ -- Check if we were the one being invited
+ if chunk.state_key == SERVER.user_id and (
+ (not backlog and chunktype == 'messages') or
+ chunktype == 'states') then
+ --self:addNick(sender)
+ if w.config_get_plugin('autojoin_on_invite') == 'on' then
+ SERVER:Join(self.identifier)
+ mprint(('%s invited you'):format(sender))
+ else
+ mprint(('You have been invited to join room %s by %s. Type /join %s to join.')
+ :format(
+ self.name,
+ sender,
+ self.identifier))
+ end
+ end
+ if chunktype == 'messages' then
+ tag"irc_invite"
+ local prefix_c = wcolor'weechat.color.chat_prefix_action'
+ local prefix = wconf'weechat.look.prefix_action'
+ local data = ("%s%s\t%s invited %s to join"):format(
+ prefix_c,
+ prefix,
+ self.users[sender] or sender,
+ self.users[chunk.state_key] or chunk.state_key
+ )
+ w.print_date_tags(self.buffer, time_int, tags(), data)
+ end
+ elseif chunk['content']['membership'] == 'ban' then
+ if chunktype == 'messages' then
+ tag"irc_ban"
+ local prefix_c = wcolor'weechat.color.chat_prefix_action'
+ local prefix = wconf'weechat.look.prefix_action'
+ local data = ("%s%s\t%s banned %s"):format(
+ prefix_c,
+ prefix,
+ self.users[sender] or sender,
+ self.users[chunk.state_key] or chunk.state_key
+ )
+ w.print_date_tags(self.buffer, time_int, tags(), data)
+ end
+ else
+ dbg{err= 'unknown membership type in ParseChunk', chunk= chunk}
+ end
+ -- if it's backlog this is done at the end from the caller place
+ if not backlog then
+ -- Run SetName on each member change in case we need to update room name
+ self:SetName(self.identifier)
+ end
+ elseif chunk['type'] == 'm.room.create' then
+ self.creator = chunk.content.creator
+ elseif chunk['type'] == 'm.room.power_levels' then
+ if chunk.content.users then
+ self.power_levels = chunk.content
+ for user_id, lvl in pairs(self.power_levels.users) do
+ -- TODO
+ -- calculate changes here and generate message lines
+ -- describing the change
+ end
+ for user_id, lvl in pairs(self.power_levels.users) do
+ local _, nprefix, nprefix_color = self:GetNickGroup(user_id)
+ self:UpdateNick(user_id, 'prefix', nprefix)
+ self:UpdateNick(user_id, 'prefix_color', nprefix_color)
+ end
+ end
+ elseif chunk['type'] == 'm.room.join_rules' then
+ -- TODO: parse join_rules events --
+ self.join_rules = chunk.content
+ elseif chunk['type'] == 'm.typing' then
+ -- Store the typing ids in a table that the bar item can use
+ local typing_ids = {}
+ for _, id in ipairs(chunk.content.user_ids) do
+ self:UpdatePresence(id, 'typing')
+ typing_ids[#typing_ids+1] = self.users[id]
+ end
+ self.typing_ids = typing_ids
+ w.bar_item_update('matrix_typing_notice')
+ elseif chunk['type'] == 'm.presence' then
+ SERVER:UpdatePresence(chunk)
+ elseif chunk['type'] == 'm.room.aliases' then
+ -- Use first alias, weechat doesn't really support multiple aliases
+ self.aliases = chunk.content.aliases
+ self:SetName(chunk.content.aliases[1])
+ elseif chunk['type'] == 'm.room.canonical_alias' then
+ self.canonical_alias = chunk.content.alias
+ self:SetName(self.canonical_alias)
+ elseif chunk['type'] == 'm.room.redaction' then
+ local redact_id = chunk.redacts
+ --perr('Redacting message ' .. redact_id)
+ local result = self:UpdateLine(redact_id, w.color'darkgray'..'(redacted)')
+ if not result and not backlog then
+ -- backlog doesn't send original message
+ perr 'Could not find message to redact :('
+ end
+ elseif chunk['type'] == 'm.room.history_visibility' then
+ self.history_visibility = chunk.content.history_visibility
+ -- luacheck: ignore 542
+ elseif chunk['type'] == 'm.receipt' then
+ -- TODO: figure out if we can do something sensible with read receipts
+ else
+ if DEBUG then
+ perr(('Unknown event type %s%s%s in room %s%s%s'):format(
+ w.color'bold',
+ chunk.type,
+ default_color,
+ w.color'bold',
+ self.name,
+ default_color))
+ dbg{chunk=chunk}
+ end
+ end
+end
+
+function Room:Op(nick)
+ for id, name in pairs(self.users) do
+ if name == nick then
+ -- patch the locally cached power levels
+ self.power_levels.users[id] = 99
+ SERVER:state(self.identifier, 'm.room.power_levels',
+ self.power_levels)
+ break
+ end
+ end
+end
+
+function Room:Voice(nick)
+ for id, name in pairs(self.users) do
+ if name == nick then
+ -- patch the locally cached power levels
+ self.power_levels.users[id] = 25
+ SERVER:state(self.identifier, 'm.room.power_levels',
+ self.power_levels)
+ break
+ end
+ end
+end
+
+function Room:Devoice(nick)
+ for id, name in pairs(self.users) do
+ if name == nick then
+ -- patch the locally cached power levels
+ self.power_levels.users[id] = 0
+ SERVER:state(self.identifier, 'm.room.power_levels',
+ self.power_levels)
+ break
+ end
+ end
+end
+
+function Room:Deop(nick)
+ for id, name in pairs(self.users) do
+ if name == nick then
+ -- patch the locally cached power levels
+ self.power_levels.users[id] = 0
+ SERVER:state(self.identifier, 'm.room.power_levels',
+ self.power_levels)
+ break
+ end
+ end
+end
+
+function Room:Kick(nick, reason)
+ for id, name in pairs(self.users) do
+ if name == nick then
+ local data = {
+ membership = 'leave',
+ reason = 'Kicked by '..SERVER.user_id
+ }
+ SERVER:set_membership(self.identifier, id, data)
+ break
+ end
+ end
+end
+
+function Room:Whois(nick)
+ for id, name in pairs(self.users) do
+ if name == nick then
+ local pcolor = wcolor'weechat.color.chat_prefix_network'
+ local data = ('%s--\t%s%s%s has user id %s%s'):format(
+ pcolor,
+ w.info_get('irc_nick_color', nick),
+ nick,
+ default_color,
+ w.info_get('irc_nick_color', id),
+ id)
+ w.print_date_tags(self.buffer, nil, 'notify_message', data)
+ local pdata = ('%s--\t%s%s%s has presence %s%s'):format(
+ pcolor,
+ w.info_get('irc_nick_color', nick),
+ nick,
+ default_color,
+ pcolor,
+ SERVER.presence[id] or 'offline')
+ w.print_date_tags(self.buffer, nil, 'notify_message', pdata)
+ -- TODO support printing status_msg field in presence data here
+ break
+ end
+ end
+end
+
+function Room:Invite(id)
+ SERVER:Invite(self.identifier, id)
+end
+
+function Room:Encrypt()
+ self.encrypted = true
+ -- Download keys for all members
+ self:Download_keys()
+ -- Create sessions
+ -- Pickle.
+ -- Save
+end
+function Room:Download_keys()
+ for id, name in pairs(self.users) do
+ -- TODO enable batch downloading of keys here when synapse can handle it
+ SERVER.olm:query({id})
+ end
+end
+
+function Room:MarkAsRead()
+ -- Get event id from tag of last line in buffer
+ local lines = w.hdata_pointer(w.hdata_get('buffer'), self.buffer, 'own_lines')
+ if lines == '' then return end
+ local line = w.hdata_pointer(w.hdata_get('lines'), lines, 'last_line')
+ if line == '' then return end
+ local hdata_line = w.hdata_get('line')
+ local hdata_line_data = w.hdata_get('line_data')
+ local data = w.hdata_pointer(hdata_line, line, 'data')
+ local tag_count = w.hdata_integer(hdata_line_data, data, "tags_count")
+ if tag_count > 0 then
+ for i = 0, tag_count-1 do
+ local tag = w.hdata_string(hdata_line_data, data, i .. "|tags_array")
+ -- Event ids are like $142533663810152bfUKc:matrix.org
+ if tag:match'^%$.*:' then
+ SERVER:SendReadReceipt(self.identifier, tag)
+ break
+ end
+ end
+ end
+end
+
+function poll(a, b)
+ SERVER:poll()
+ return w.WEECHAT_RC_OK
+end
+
+function polltimer_cb(a, b)
+ local now = os.time()
+ if (now - SERVER.polltime) > POLL_INTERVAL+10 then
+ -- Release the poll lock
+ SERVER.poll_lock = false
+ SERVER:poll()
+ end
+ return w.WEECHAT_RC_OK
+end
+
+function otktimer_cb(a, b)
+ SERVER.olm:check_server_keycount()
+ return w.WEECHAT_RC_OK
+end
+
+function cleartyping(a, b)
+ for id, room in pairs(SERVER.rooms) do
+ room:ClearTyping()
+ end
+ return w.WEECHAT_RC_OK
+end
+
+function join_command_cb(data, current_buffer, args)
+ local room = SERVER:findRoom(current_buffer)
+ if current_buffer == BUFFER or room then
+ local _, alias = split_args(args)
+ if not alias then
+ -- To support running /join on a invited room without args
+ SERVER:Join(room.identifier)
+ else
+ SERVER:Join(alias)
+ end
+ return w.WEECHAT_RC_OK_EAT
+ else
+ return w.WEECHAT_RC_OK
+ end
+end
+
+function part_command_cb(data, current_buffer, args)
+ local room = SERVER:findRoom(current_buffer)
+ if room then
+ SERVER:part(room)
+ return w.WEECHAT_RC_OK_EAT
+ else
+ return w.WEECHAT_RC_OK
+ end
+end
+
+function leave_command_cb(data, current_buffer, args)
+ return part_command_cb(data, current_buffer, args)
+end
+
+function me_command_cb(data, current_buffer, args)
+ local room = SERVER:findRoom(current_buffer)
+ if room then
+ local _, message = split_args(args)
+ room:emote(message or '')
+ return w.WEECHAT_RC_OK_EAT
+ else
+ return w.WEECHAT_RC_OK
+ end
+end
+
+function topic_command_cb(data, current_buffer, args)
+ local room = SERVER:findRoom(current_buffer)
+ if room then
+ local _, topic = split_args(args)
+ room:Topic(topic)
+ return w.WEECHAT_RC_OK_EAT
+ else
+ return w.WEECHAT_RC_OK
+ end
+end
+
+function upload_command_cb(data, current_buffer, args)
+ local room = SERVER:findRoom(current_buffer)
+ if room then
+ local _, upload = split_args(args)
+ room:Upload(upload)
+ return w.WEECHAT_RC_OK_EAT
+ else
+ return w.WEECHAT_RC_OK
+ end
+end
+
+function query_command_cb(data, current_buffer, args)
+ local room = SERVER:findRoom(current_buffer)
+ if room then
+ local _, query = split_args(args)
+ for id, displayname in pairs(room.users) do
+ if displayname == query then
+ -- Create a new room and invite the guy
+ SERVER:CreateRoom(false, nil, {id})
+ return w.WEECHAT_RC_OK_EAT
+ end
+ end
+ else
+ return w.WEECHAT_RC_OK
+ end
+end
+
+function create_command_cb(data, current_buffer, args)
+ local command, arg = split_args(args)
+ local room = SERVER:findRoom(current_buffer)
+ if (room or current_buffer == BUFFER) and command == '/create' then
+ if arg then
+ -- Room names are supposed to be without # and homeserver, so
+ -- we try to help the user out here
+ local alias = arg:match'#?(.*):?'
+ -- Create a non-public room with argument as alias
+ SERVER:CreateRoom(false, alias, nil)
+ else
+ mprint 'Use /create room-name'
+ end
+ return w.WEECHAT_RC_OK_EAT
+ else
+ return w.WEECHAT_RC_OK
+ end
+end
+
+function createalias_command_cb(data, current_buffer, args)
+ local room = SERVER:findRoom(current_buffer)
+ if room then
+ local _, alias = split_args(args)
+ SERVER:CreateRoomAlias(room.identifier, alias)
+ return w.WEECHAT_RC_OK_EAT
+ elseif current_buffer == BUFFER then
+ mprint 'Use /createalias #alias:homeserver.domain from a room'
+ return w.WEECHAT_RC_OK_EAT
+ else
+ return w.WEECHAT_RC_OK
+ end
+end
+
+function invite_command_cb(data, current_buffer, args)
+ local room = SERVER:findRoom(current_buffer)
+ if room then
+ local _, invitee = split_args(args)
+ room:Invite(invitee)
+ return w.WEECHAT_RC_OK_EAT
+ else
+ return w.WEECHAT_RC_OK
+ end
+end
+
+function list_command_cb(data, current_buffer, args)
+ local room = SERVER:findRoom(current_buffer)
+ if room or current_buffer == BUFFER then
+ local _, target = split_args(args)
+ SERVER:ListRooms(target)
+ return w.WEECHAT_RC_OK_EAT
+ else
+ return w.WEECHAT_RC_OK
+ end
+end
+
+function op_command_cb(data, current_buffer, args)
+ local room = SERVER:findRoom(current_buffer)
+ if room then
+ local _, target = split_args(args)
+ room:Op(target)
+ return w.WEECHAT_RC_OK_EAT
+ else
+ return w.WEECHAT_RC_OK
+ end
+end
+
+function voice_command_cb(data, current_buffer, args)
+ local room = SERVER:findRoom(current_buffer)
+ if room then
+ local _, target = split_args(args)
+ room:Voice(target)
+ return w.WEECHAT_RC_OK_EAT
+ else
+ return w.WEECHAT_RC_OK
+ end
+end
+
+function devoice_command_cb(data, current_buffer, args)
+ local room = SERVER:findRoom(current_buffer)
+ if room then
+ local _, target = split_args(args)
+ room:Devoice(target)
+ return w.WEECHAT_RC_OK_EAT
+ else
+ return w.WEECHAT_RC_OK
+ end
+end
+function deop_command_cb(data, current_buffer, args)
+ local room = SERVER:findRoom(current_buffer)
+ if room then
+ local _, target = split_args(args)
+ room:Deop(target)
+ return w.WEECHAT_RC_OK_EAT
+ else
+ return w.WEECHAT_RC_OK
+ end
+end
+
+function kick_command_cb(data, current_buffer, args)
+ local room = SERVER:findRoom(current_buffer)
+ if room then
+ local _, target = split_args(args)
+ room:Kick(target)
+ return w.WEECHAT_RC_OK_EAT
+ else
+ return w.WEECHAT_RC_OK
+ end
+end
+
+function nick_command_cb(data, current_buffer, args)
+ local room = SERVER:findRoom(current_buffer)
+ if room or current_buffer == BUFFER then
+ local _, nick = split_args(args)
+ SERVER:Nick(nick)
+ return w.WEECHAT_RC_OK_EAT
+ else
+ return w.WEECHAT_RC_OK
+ end
+end
+
+function whois_command_cb(data, current_buffer, args)
+ local room = SERVER:findRoom(current_buffer)
+ if room then
+ local _, nick = split_args(args)
+ room:Whois(nick)
+ return w.WEECHAT_RC_OK_EAT
+ else
+ return w.WEECHAT_RC_OK
+ end
+end
+
+function notice_command_cb(data, current_buffer, args)
+ -- TODO sending from matrix buffer given a room name
+ local room = SERVER:findRoom(current_buffer)
+ if room then
+ local _, msg = split_args(args)
+ room:Notice(msg)
+ return w.WEECHAT_RC_OK_EAT
+ else
+ return w.WEECHAT_RC_OK
+ end
+end
+
+function msg_command_cb(data, current_buffer, args)
+ local _, msgmask = split_args(args)
+ local mask, msg = split_args(msgmask)
+ local room
+ -- WeeChat uses * as a mask for current buffer
+ if mask == '*' then
+ room = SERVER:findRoom(current_buffer)
+ else
+ for id, r in pairs(SERVER.rooms) do
+ -- Send /msg to a ID
+ if id == mask then
+ room = r
+ break
+ elseif mask == r.name then
+ room = r
+ break
+ end
+ end
+ end
+
+ if room then
+ room:Msg(msg)
+ return w.WEECHAT_RC_OK_EAT
+ else
+ return w.WEECHAT_RC_OK
+ end
+end
+
+function encrypt_command_cb(data, current_buffer, args)
+ local room = SERVER:findRoom(current_buffer)
+ if room then
+ local _, arg = split_args(args)
+ if arg == 'on' then
+ mprint('Enabling encryption for outgoing messages in room ' .. tostring(room.name))
+ room:Encrypt()
+ elseif arg == 'off' then
+ mprint('Disabling encryption for outgoing messages in room ' .. tostring(room.name))
+ room.encrypted = false
+ else
+ w.print(current_buffer, 'Use /encrypt on or /encrypt off to turn encryption on or off')
+ end
+ return w.WEECHAT_RC_OK_EAT
+ else
+ return w.WEECHAT_RC_OK
+ end
+end
+
+function public_command_cb(data, current_buffer, args)
+ local room = SERVER:findRoom(current_buffer)
+ if room then
+ mprint('Marking room as public: ' .. tostring(room.name))
+ room:public()
+ return w.WEECHAT_RC_OK_EAT
+ else
+ mprint('Run command from a room')
+ return w.WEECHAT_RC_OK
+ end
+end
+
+function names_command_cb(cbdata, current_buffer, args)
+ local room = SERVER:findRoom(current_buffer)
+ if room then
+ local nrcolor = function(nr)
+ return wcolor'weechat.color.chat_channel'
+ .. tostring(nr)
+ .. default_color
+ end
+ local buffer_name = nrcolor(w.buffer_get_string(room.buffer, 'name'))
+ local delim_c = wcolor'weechat.color.chat_delimiters'
+ local tags = 'no_highlight,no_log,irc_names'
+ local pcolor = wcolor'weechat.color.chat_prefix_network'
+ local ngroups = {}
+ local nicks = {}
+ for id, name in pairs(room.users) do
+ local ncolor
+ if id == SERVER.user_id then
+ ncolor = w.color('chat_nick_self')
+ else
+ ncolor = w.info_get('irc_nick_color', name)
+ end
+ local ngroup, nprefix, nprefix_color = room:GetNickGroup(id)
+ if nprefix == ' ' then nprefix = '' end
+ nicks[#nicks+1] = ('%s%s%s%s'):format(
+ w.color(nprefix_color),
+ nprefix,
+ ncolor,
+ name
+ )
+ if not ngroups[ngroup] then
+ ngroups[ngroup] = 0
+ end
+ ngroups[ngroup] = ngroups[ngroup] + 1
+ end
+ local line1 = ('%s--\tNicks %s: %s[%s%s]'):format(
+ pcolor,
+ buffer_name,
+ delim_c,
+ table.concat(nicks, ' '),
+ delim_c
+ )
+ w.print_date_tags(room.buffer, 0, tags, line1)
+ local line2 = (
+ '%s--\tChannel %s: %s nicks %s(%s%s ops, %s voice, %s normals%s)'
+ ):format(
+ pcolor,
+ buffer_name,
+ nrcolor(room.member_count),
+ delim_c,
+ default_color,
+ nrcolor((ngroups[1] or 0) + (ngroups[2] or 0)),
+ nrcolor(ngroups[3] or 0),
+ nrcolor((ngroups[4] or 0) + (ngroups[5] or 0)),
+ delim_c
+ )
+ w.print_date_tags(room.buffer, 0, tags, line2)
+ return w.WEECHAT_RC_OK_EAT
+ else
+ perr('Could not find room')
+ return w.WEECHAT_RC_OK
+ end
+end
+
+function more_command_cb(data, current_buffer, args)
+ local room = SERVER:findRoom(current_buffer)
+ if room then
+ SERVER:getMessages(room.identifier, 'b', room.prev_batch, 120)
+ return w.WEECHAT_RC_OK_EAT
+ else
+ perr('/more Could not find room')
+ end
+ return w.WEECHAT_RC_OK
+end
+
+function roominfo_command_cb(data, current_buffer, args)
+ local room = SERVER:findRoom(current_buffer)
+ if room then
+ dbg{room=room}
+ return w.WEECHAT_RC_OK_EAT
+ else
+ perr('/roominfo Could not find room')
+ end
+ return w.WEECHAT_RC_OK
+end
+
+function name_command_cb(data, current_buffer, args)
+ local room = SERVER:findRoom(current_buffer)
+ if room then
+ local _, name = split_args(args)
+ room:Name(name)
+ return w.WEECHAT_RC_OK_EAT
+ else
+ perr('/name Could not find room')
+ end
+ return w.WEECHAT_RC_OK
+end
+
+function closed_matrix_buffer_cb(data, buffer)
+ BUFFER = nil
+ return w.WEECHAT_RC_OK
+end
+
+function closed_matrix_room_cb(data, buffer)
+ -- WeeChat closed our room
+ local room = SERVER:findRoom(buffer)
+ if room then
+ room.buffer = nil
+ perr('Room got closed: '..room.name)
+ SERVER.rooms[room.identifier] = nil
+ return w.WEECHAT_RC_OK
+ end
+ return w.WEECHAT_RC_ERR
+end
+
+function typing_notification_cb(signal, sig_type, data)
+ -- Ignore commands
+ if data:match'^/' then
+ return w.WEECHAT_RC_OK
+ end
+ -- Is this signal coming from a matrix buffer?
+ local room = SERVER:findRoom(data)
+ if room then
+ local input = w.buffer_get_string(data, "input")
+ -- Start sending when it reaches > 4 and doesn't start with command
+ if #input > 4 and not input:match'^/' then
+ local now = os.time()
+ -- Generate typing events every 4th second
+ if SERVER.typing_time + 4 < now then
+ SERVER.typing_time = now
+ room:SendTypingNotice()
+ end
+ end
+ end
+
+ return w.WEECHAT_RC_OK
+end
+
+function buffer_switch_cb(signal, sig_type, data)
+ -- Update bar item
+ w.bar_item_update('matrix_typing_notice')
+ local current_buffer = w.current_buffer()
+ local room = SERVER:findRoom(current_buffer)
+ if room then
+ room:MarkAsRead()
+ end
+ return w.WEECHAT_RC_OK
+end
+
+function typing_bar_item_cb(data, buffer, args)
+ local current_buffer = w.current_buffer()
+ local room = SERVER:findRoom(current_buffer)
+ if not room then return '' end
+ local typing_ids = table.concat(room.typing_ids, ' ')
+ if #typing_ids > 0 then
+ return "Typing: ".. typing_ids
+ end
+ return ''
+end
+
+if w.register(SCRIPT_NAME, SCRIPT_AUTHOR, SCRIPT_VERSION, SCRIPT_LICENSE, SCRIPT_DESC, "matrix_unload", "UTF-8") then
+ -- Save WeeChat version to a global so other functionality can see it
+ local version = w.info_get('version_number', '') or 0
+ WEECHAT_VERSION = tonumber(version)
+ local settings = {
+ homeserver_url= {'https://matrix.org/', 'Full URL including port to your homeserver (including trailing slash) or use default matrix.org'},
+ user= {'', 'Your homeserver username'},
+ password= {'', 'Your homeserver password'},
+ backlog_lines= {'120', 'Number of lines to fetch from backlog upon connecting'},
+ presence_filter = {'off', 'Filter presence messages and ephemeral events (for performance)'},
+ autojoin_on_invite = {'on', 'Automatically join rooms you are invited to'},
+ typing_notices = {'on', 'Send typing notices when you type'},
+ local_echo = {'on', 'Print lines locally instead of waiting for return from server'},
+ debug = {'off', 'Print a lot of extra information to help with finding bugs and other problems.'},
+ encrypted_message_color = {'lightgreen', 'Print encrypted mesages with this color'},
+ --olm_secret = {'', 'Password used to secure olm stores'},
+ }
+ -- set default settings
+ for option, value in pairs(settings) do
+ if w.config_is_set_plugin(option) ~= 1 then
+ w.config_set_plugin(option, value[1])
+ end
+ if WEECHAT_VERSION >= 0x00030500 then
+ w.config_set_desc_plugin(option, ('%s (default: "%s")'):format(
+ value[2], value[1]))
+ end
+ end
+ errprefix = wconf'weechat.look.prefix_error'
+ errprefix_c = wcolor'weechat.color.chat_prefix_error'
+ HOMEDIR = w.info_get('weechat_dir', '') .. '/'
+ local commands = {
+ 'join', 'part', 'leave', 'me', 'topic', 'upload', 'query', 'list',
+ 'op', 'voice', 'deop', 'devoice', 'kick', 'create', 'createalias', 'invite', 'nick',
+ 'whois', 'notice', 'msg', 'encrypt', 'public', 'names', 'more',
+ 'roominfo', 'name'
+ }
+ for _, c in pairs(commands) do
+ w.hook_command_run('/'..c, c..'_command_cb', '')
+ end
+
+ if w.config_get_plugin('typing_notices') == 'on' then
+ w.hook_signal('input_text_changed', "typing_notification_cb", '')
+ end
+
+ if w.config_get_plugin('debug') == 'on' then
+ DEBUG = true
+ end
+
+ w.hook_config('plugins.var.lua.matrix.debug', 'configuration_changed_cb', '')
+
+ local cmds = {'help', 'connect', 'debug', 'msg'}
+ w.hook_command(SCRIPT_COMMAND, 'Plugin for matrix.org chat protocol',
+ '[command] [command options]',
+ 'Commands:\n' ..table.concat(cmds, '\n') ..
+ '\nUse /matrix help [command] to find out more\n' ..
+ '\nSupported slash commands (i.e. /commands):\n' ..
+ table.concat(commands, ', '),
+ -- Completions
+ table.concat(cmds, '|'),
+ 'matrix_command_cb', '')
+
+ w.hook_command_run('/away -all*', 'matrix_away_command_run_cb', '')
+ SERVER = MatrixServer.create()
+
+ if WEECHAT_VERSION < 0x01040000 then
+ perr(SCRIPT_NAME .. ': Please upgrade your WeeChat before using this script. Using this script on older WeeChat versions may lead to crashes. Many bugs have been fixed in newer versions of WeeChat.')
+ perr(SCRIPT_NAME .. ': Refusing to automatically connect you. If you insist, type /'..SCRIPT_COMMAND..' connect, and do not act surprised if it crashes :-)')
+ else
+ SERVER:connect()
+ end
+
+ w.hook_signal('buffer_switch', "buffer_switch_cb", "")
+ w.bar_item_new('matrix_typing_notice', 'typing_bar_item_cb', '')
+end