Compare commits

...

19 Commits

Author SHA1 Message Date
yutent 64dc70b594 js调用python改为异步; js调用python方法异常信息改为Error对象;优化自定义桥接方法的异常处理 2024-01-24 17:37:31 +08:00
yutent 3062354338 js注入改为开始时注入, 窗口增加hide和show 2个回调 2023-09-13 14:04:51 +08:00
yutent ece744aafe 增加shell操作 2023-09-12 18:55:32 +08:00
yutent b398551deb native对象及属性改为只读 2023-09-12 14:28:04 +08:00
yutent 5da22eed8e 移除locale的注入及navigator.language的重写; native对象改为只读 2023-09-12 14:15:27 +08:00
yutent f9c4007e3f 调整环境变量 2023-09-12 14:12:29 +08:00
yutent 2682af069b 修复打包 2023-09-11 14:31:18 +08:00
yutent 838d9d1134 修复依赖缺失 2023-09-11 13:22:53 +08:00
yutent c17d171ad8 增加app_name和app_version的设置及注入 2023-09-08 18:55:49 +08:00
yutent b9e7144271 quit方法移入app对象; app新增relaunch方法 2023-09-08 18:38:39 +08:00
yutent 6e0beb6a66 跳出循环 2023-09-08 17:50:10 +08:00
yutent 89717b4019 0.6.0 2023-09-08 17:25:11 +08:00
yutent 6f7141560a 窗口增加uuid属性; 新建窗口增加icon支持;增加父窗口向子窗口发送消息 2023-09-08 17:22:59 +08:00
yutent 4ef23a703d 移除多余的引入 2023-09-08 16:03:09 +08:00
yutent c1f7e8e503 0.5.0 2023-09-08 15:09:22 +08:00
yutent 80872e0678 使用python在多窗口之间做桥接 2023-09-08 15:06:42 +08:00
yutent 1f2273150c 修复窗口移动API; 增加新窗口打开的支持 2023-09-07 19:58:17 +08:00
yutent ed5dcf1245 增加403,404页面; 支持前端history路由 2023-09-07 11:39:56 +08:00
yutent d499991831 优化打包脚本; load方法支持http远程地址 2023-09-07 10:41:42 +08:00
12 changed files with 822 additions and 463 deletions

1
.gitignore vendored
View File

@ -1,2 +1,3 @@
__pycache__ __pycache__
unpack
*.deb *.deb

View File

@ -7,6 +7,7 @@ if [ -d unpack ]; then
sudo rm -rf unpack sudo rm -rf unpack
fi fi
find usr -type d -name __pycache__ | xargs rm -rf
mkdir -p unpack/DEBIAN mkdir -p unpack/DEBIAN
@ -21,6 +22,7 @@ sed -i "s/{{size}}/${_size}/" DEBIAN/control
sed -i "s/{{version}}/${version}/" DEBIAN/control sed -i "s/{{version}}/${version}/" DEBIAN/control
cd .. cd ..
sudo chown -R root:root unpack/
dpkg-deb -b unpack/ "python3-webengine-gtk3-${version}.deb" dpkg-deb -b unpack/ "python3-webengine-gtk3-${version}.deb"
sudo rm -rf unpack sudo rm -rf unpack

2
debian/control vendored
View File

@ -4,7 +4,7 @@ Section: develop
Priority: optional Priority: optional
Maintainer: Yutent <yutent.io@gmail.com> Maintainer: Yutent <yutent.io@gmail.com>
Architecture: all Architecture: all
Depends: python3 (>=3.10), python3-gi, gir1.2-gtk-3.0, python3-pil, python3-gi-cairo, gir1.2-gdkpixbuf-2.0 Depends: python3 (>=3.10), python3-gi, gir1.2-webkit2-4.1, gir1.2-gtk-3.0, python3-pil, python3-gi-cairo, gir1.2-gdkpixbuf-2.0
Recommends: gir1.2-ayatanaappindicator3-0.1, gir1.2-notify-0.7, gir1.2-keybinder-3.0 Recommends: gir1.2-ayatanaappindicator3-0.1, gir1.2-notify-0.7, gir1.2-keybinder-3.0
Installed-Size: {{size}} Installed-Size: {{size}}
Homepage: https://git.wkit.fun/appcat/python3-webengine-gtk3 Homepage: https://git.wkit.fun/appcat/python3-webengine-gtk3

View File

@ -0,0 +1,67 @@
#!/usr/bin/env python3
import gi
gi.require_version('Gtk', '3.0')
gi.require_version("WebKit2", "4.1")
from gi.repository import Gtk, WebKit2
def create_same_window(origin, req):
WebEngine = type(origin)
w, h = origin.window.get_size()
win = Gtk.Window()
win.set_default_size(w, h)
web = WebEngine(win, origin)
web.set_zoom_level(origin.get_zoom_level())
web.set_settings(origin.get_settings())
web.load_request(req)
win.add(web)
win.show_all()
def create_custom_window(origin, options):
WebEngine = type(origin)
_w, _h = origin.window.get_size()
w = options.get('width') or _w
h = options.get('height') or _h
win = Gtk.Window()
win.set_default_size(w, h)
wmclass = options.get('wmclass') or 'WebEngine Window'
win.set_wmclass(wmclass, 'WebEngine')
win.set_title(options.get('title') or 'WebEngine')
if options.get('icon_path'):
win.set_icon_from_file(options['icon_path'])
if options.get('icon'):
win.set_icon_name(options['icon'])
if options.get('frame') == False:
win.set_decorated(False)
if options.get('x') is not None and options.get('y') is not None:
win.move(options.get('x'), options.get('y'))
if options.get('always_on_top') == True:
win.set_keep_above(options['always_on_top'])
if options.get('resizable') == False:
win.set_resizable(False)
web = WebEngine(win, origin, options.get('uuid'))
web.set_root(origin.root, True)
web.set_zoom_level(origin.get_zoom_level())
web.set_settings(origin.get_settings())
web.load(options.get('url'))
win.add(web)
win.show_all()
return web

View File

@ -0,0 +1,13 @@
#!/usr/bin/env python3
import os
home_dir = os.getenv('HOME')
env = {
"HOME_DIR": home_dir,
"CONFIG_DIR": os.path.join(home_dir, '.config'),
"CACHE_DIR": os.path.join(home_dir, '.cache'),
"LANG": os.environ['LANG'] or "en_US.UTF-8"
}

View File

@ -15,11 +15,16 @@ class Inject:
self.manager = webview.get_user_content_manager() self.manager = webview.get_user_content_manager()
script_data = open(self.abspath('./inject.js'), 'r').read() code = open(self.abspath('./inject.js'), 'r').read()
frame = WebKit2.UserContentInjectedFrames.ALL_FRAMES frame = WebKit2.UserContentInjectedFrames.ALL_FRAMES
time = WebKit2.UserScriptInjectionTime.END time = WebKit2.UserScriptInjectionTime.START
script_data = script_data.replace("'{{env}}'", json.dumps(env))
script = WebKit2.UserScript(script_data, frame, time, None, None) code = code.replace("'{{env}}'", json.dumps(env))
code = code.replace("{{uuid}}", webview.uuid)
code = code.replace("{{app_name}}", webview.app_name)
code = code.replace("{{app_version}}", webview.app_version)
script = WebKit2.UserScript(code, frame, time, None, None)
self.manager.add_script(script) self.manager.add_script(script)

View File

@ -1,8 +1,13 @@
import os import gi, os
gi.require_version("WebKit2", "4.1")
from gi.repository import Gio, WebKit2 from gi.repository import Gio, WebKit2
from ._mimetypes import get_mimetype
from ._mimetypes import get_mimetype
from ._version import version
__dir__ = os.path.dirname(os.path.realpath(__file__))
class Protocal: class Protocal:
root = '' root = ''
@ -22,29 +27,61 @@ class Protocal:
return os.path.join(self.root, filepath) return os.path.join(self.root, filepath)
def _get_error_page(self, tips = '404 not found!'):
data = f"""
<!doctype html>
<html lang="zh-CN">
<head>
<meta charset="utf-8">
<title>Page not found</title>
<style>body {{text-align: center;-webkit-user-select:none}} cite {{font-size:12px}}</style>
</head>
<body>
<h1>Oops!</h1>
<h2>{tips}</h2>
<hr>
<cite>WebEngine v{version}</cite>
</body>
</html>
"""
return data
def handle_response(self, req): def handle_response(self, req):
schema = req.get_scheme() schema = req.get_scheme()
pathname = req.get_path()[1:] pathname = req.get_path()[1:]
ext = pathname.split('.')[-1] ext = pathname.split('.')[-1]
mimetype = get_mimetype(ext)
if pathname == ext:
pathname = 'index.html'
# print('----------------------------------------') # print('----------------------------------------')
# print(req.get_uri(),schema, pathname, ext, get_mimetype(ext)) # print(req.get_uri(),schema, pathname, ext, mimetype)
# print('----------------------------------------') # print('----------------------------------------')
if schema == self.protocal: if schema == self.protocal:
data = open(self.abspath(pathname)).read() filepath = self.abspath(pathname)
if os.path.isfile(filepath):
try:
with open(filepath) as f:
data = f.read()
except Exception:
data = self._get_error_page('403 Forbidden!')
else:
data = self._get_error_page()
data = Gio.MemoryInputStream.new_from_data(data.encode()) data = Gio.MemoryInputStream.new_from_data(data.encode())
# ------- 更多功能的reponse ---------------- # ------- 更多功能的reponse ----------------
# res = WebKit2.URISchemeResponse.new(data, -1) # res = WebKit2.URISchemeResponse.new(data, -1)
# res.set_content_type(get_mimetype(ext)) # res.set_content_type(mimetype)
# res.set_http_headers('text/html') # res.set_http_headers('text/html')
# res.set_status(200) # res.set_status(200)
# req.finish_with_response(res) # req.finish_with_response(res)
# ---------------------------------------- # ----------------------------------------
# 简单的response # 简单的response
req.finish(data, -1, get_mimetype(ext)) req.finish(data, -1, mimetype)
def create_protocal(root): def create_protocal(root):

View File

@ -6,8 +6,8 @@
import gi, os import gi, os
gi.require_version("WebKit2", "4.1") gi.require_version("WebKit2", "4.1")
from gi.repository import WebKit2 from gi.repository import WebKit2
from ._version import version from ._version import version
@ -22,7 +22,7 @@ class Settings(WebKit2.Settings):
self.set_javascript_can_open_windows_automatically(True) self.set_javascript_can_open_windows_automatically(True)
self.set_user_agent_with_application_details('WebEngine', version) self.set_useragent_with_app('WebEngine', version)
# indexedDB 和 localStorage 和 离线缓存 # indexedDB 和 localStorage 和 离线缓存
@ -43,6 +43,9 @@ class Settings(WebKit2.Settings):
self.set_media_playback_allows_inline(True) self.set_media_playback_allows_inline(True)
def set_useragent_with_app(self, name, ver):
self.set_user_agent_with_application_details(name, ver)
def set_useragent(self, str): def set_useragent(self, str):
self.set_user_agent(str) self.set_user_agent(str)
@ -75,6 +78,9 @@ def create_setting(options = None):
setting.enable_devtools() setting.enable_devtools()
setting.mock_devices() setting.mock_devices()
if options.get('app_name') and options.get('app_version'):
setting.set_useragent_with_app(options['app_name'], options['app_version'])
if options.get('useragent'): if options.get('useragent'):
setting.set_useragent(options.get('useragent')) setting.set_useragent(options.get('useragent'))
@ -86,6 +92,9 @@ def create_setting(options = None):
def wrapper(app, extra = None): def wrapper(app, extra = None):
if options is not None:
app.app_name = options.get('app_name')
app.app_version = options.get('app_version')
app.set_settings(setting) app.set_settings(setting)
return wrapper return wrapper

View File

@ -3,8 +3,12 @@
# @author yutent<yutent.io@gmail.com> # @author yutent<yutent.io@gmail.com>
# @date 2023/07/28 14:39:33 # @date 2023/07/28 14:39:33
import gi import gi, threading
from gi.repository.GdkPixbuf import Pixbuf gi.require_version('Gtk', '3.0')
from gi.repository import GdkPixbuf, GObject
def noop():
pass
def get_monitor_info(monitor): def get_monitor_info(monitor):
return { return {
@ -50,7 +54,7 @@ def pixbuf_to_dict(pixbuf, filename = ''):
def dict_to_pixbuf(data): def dict_to_pixbuf(data):
if data: if data:
image = Pixbuf.new_from_data( image = GdkPixbuf.Pixbuf.new_from_data(
data = bytes(data['bytes']), data = bytes(data['bytes']),
colorspace = data['colorspace'], colorspace = data['colorspace'],
has_alpha = data['has_alpha'], has_alpha = data['has_alpha'],
@ -63,3 +67,33 @@ def dict_to_pixbuf(data):
image = None image = None
return image return image
# 定义一个异步修饰器, 用于在子线程中运行一些会阻塞主线程的任务
def run_async(func):
def wrapper(*args, **kwargs):
thread = threading.Thread(target=func, args=args, kwargs=kwargs)
thread.daemon = True
thread.start()
return thread
return wrapper
# 类型js的settimeout的修饰器
def set_timeout(timeout = 0.5):
def decorator(callback):
def wrapper(*args):
t = threading.Timer(timeout, callback, args=args)
t.start()
return t
return wrapper
return decorator
# 定义一个修饰器, 用于将当前方法转到主线程中运行 (子线程中调用方法时)
def idle(func):
def wrapper(*args):
GObject.idle_add(func, *args)
return wrapper

View File

@ -1,4 +1,4 @@
#!/usr/bin/env python3 #!/usr/bin/env python3
build = (0, 4, 0) build = (0, 7, 0)
version = '.'.join(map(str, build)) version = '.'.join(map(str, build))

View File

@ -3,13 +3,15 @@
# @date 2023/08/08 14:07:26 # @date 2023/08/08 14:07:26
import gi, os, json, shutil, hashlib, time, threading import gi, os, sys, json
import webbrowser, shutil, hashlib, random
gi.require_version('Gtk', '3.0') gi.require_version('Gtk', '3.0')
gi.require_version("WebKit2", "4.1") gi.require_version("WebKit2", "4.1")
from gi.repository import GObject, Gtk, Gdk, WebKit2, GLib, Gio, GdkPixbuf from gi.repository import GObject, Gtk, Gdk, WebKit2, GLib, Gio, GdkPixbuf
from ._custom_window import create_same_window, create_custom_window
# 优先尝试使用指示器, 没有再使用 Gtk.StatusIcon # 优先尝试使用指示器, 没有再使用 Gtk.StatusIcon
@ -30,56 +32,50 @@ try:
except: except:
Keybinder = None Keybinder = None
from ._env import env
from ._version import version
from ._settings import create_setting from ._settings import create_setting
from ._protocal import create_protocal from ._protocal import create_protocal
from ._notify import create_notify from ._notify import create_notify
from ._inject import Inject from ._inject import Inject
from ._utils import get_monitor_info, pixbuf_to_dict, dict_to_pixbuf from ._utils import noop, get_monitor_info, pixbuf_to_dict, dict_to_pixbuf, run_async, idle
env = {
"HOME_DIR": os.getenv('HOME'),
"CONFIG_DIR": os.path.join(os.getenv('HOME'), '.config'),
"CACHE_DIR": os.path.join(os.getenv('HOME'), '.cache')
}
def noop():
pass
# 类型js的settimeout的修饰器
def set_timeout(timeout = 0.5):
def decorator(callback):
def wrapper(*args):
t = threading.Timer(timeout, callback, args=args)
t.start()
return t
return wrapper
return decorator
class WebEngine(WebKit2.WebView): class WebEngine(WebKit2.WebView):
__gsignals__ = { __gsignals__ = {
'quit': (GObject.SignalFlags.RUN_FIRST, None, ()) 'quit': (GObject.SignalFlags.RUN_FIRST, None, ())
} }
app_name = 'WebEngine'
app_version = version
uuid = None
root = None root = None
window = None window = None
opener = None
children = set()
custom_bridge = None custom_bridge = None
def __init__(self, window): def __init__(self, win, opener = None, uuid = None):
WebKit2.WebView.__init__(self) WebKit2.WebView.__init__(self)
self.window = window if uuid is None:
self.uuid = random.randbytes(8).hex()
else:
self.uuid = uuid
self.opener = opener
self.window = win
if opener is not None:
opener.children.add(self)
if win.get_title() is None:
win.set_title(self.app_name)
if win.get_icon() is None and win.get_icon_name() is None:
win.set_icon_name('web-browser')
self.clipboard = Gtk.Clipboard.get(Gdk.SELECTION_CLIPBOARD) self.clipboard = Gtk.Clipboard.get(Gdk.SELECTION_CLIPBOARD)
self.display = Gdk.Display.get_default() self.display = Gdk.Display.get_default()
@ -98,24 +94,44 @@ class WebEngine(WebKit2.WebView):
self.connect('create', self.create_new_window) self.connect('create', self.create_new_window)
# 允许前端 widnow.close() 关闭窗口
self.connect('close', self.close_window)
# 通过外部关闭窗口时从父级中移除
win.connect("destroy", self.remove_from_opener)
win.connect('hide', lambda w: self.call_js('hide'))
win.connect('show', lambda w: self.call_js('show'))
def remove_from_opener(self, win = None):
if self.opener is not None:
try:
self.opener.children.remove(self)
except:
pass
def close_window(self, wv = None):
self.remove_from_opener()
self.window.close()
# 响应原生js的 window.open
def create_new_window(self, webview, nav): def create_new_window(self, webview, nav):
req = nav.get_request() req = nav.get_request()
w, h = self.window.get_size() return create_same_window(self, req)
win = Gtk.Window()
web = WebEngine(win)
web.set_settings(self.get_settings())
web.set_zoom_level(self.get_zoom_level())
web.load_request(req)
win.set_default_size(w, h)
win.add(web)
win.show_all()
def set_root(self, root): # 手动创建窗口
def new_window_by_custom(self, options = {}):
return create_custom_window(self, options)
def set_root(self, root, has_protocol = False):
self.root = root self.root = root
if has_protocol:
return self
return self.use(create_protocal(root)) return self.use(create_protocal(root))
@ -125,20 +141,28 @@ class WebEngine(WebKit2.WebView):
def load(self, url = '/index.html'): def load(self, url = '/index.html'):
if url.startswith('http://') or url.startswith('https://'):
self.load_uri(url)
else:
if self.root is None: if self.root is None:
raise EnvironmentError('web root dir not set!') raise EnvironmentError('web root dir not set!')
else: else:
if url.startswith('/'):
self.load_uri(f"app://{url}") self.load_uri(f"app://{url}")
elif url.startswith('app://'):
self.load_uri(url)
else:
raise ValueError('url must starts with "/" or "app://"')
@idle
def call_js(self, method, data = None, err = None): def call_js(self, method, data = None, err = None):
if err is not None: if err is not None:
err = str(err) err = str(err)
scripts = 'native.$emit("' + method + '", ' + json.dumps(err) + ', ' + json.dumps(data) + ')' scripts = 'native.$emit("' + method + '", ' + json.dumps(err) + ', ' + json.dumps(data) + ')'
self.evaluate_javascript(scripts, -1) self.evaluate_javascript(scripts, -1)
@run_async
def called_by_js(self, webview, message): def called_by_js(self, webview, message):
data = json.loads(message.get_js_value().to_json(0)) data = json.loads(message.get_js_value().to_json(0))
@ -151,21 +175,16 @@ class WebEngine(WebKit2.WebView):
match event: match event:
case 'init':
output = env case 'app':
_error, output = self._app_handler(params)
case 'fs': case 'fs':
_error, output = self._fs_setting(params) _error, output = self._fs_handler(params)
case 'clipboard': case 'clipboard':
_error, output = self._clipboard_setting(params) _error, output = self._clipboard_handler(params)
# 退出app
case 'quit':
self.window.close()
self.emit('quit')
# 读取图片, 返回图片像素数据 # 读取图片, 返回图片像素数据
case 'image': case 'image':
@ -185,7 +204,7 @@ class WebEngine(WebKit2.WebView):
case 'keybinder': case 'keybinder':
_error, output = self._keybinder_setting(params) _error, output = self._keybinder_handler(params)
case 'tray': case 'tray':
@ -195,8 +214,37 @@ class WebEngine(WebKit2.WebView):
elif params['action'] == 'remove': elif params['action'] == 'remove':
pass pass
case 'opener':
callback = 'opener_message'
output = params.get('data')
uuid = json.dumps(self.uuid if self.opener else None)
scripts = f"native.$emit('opener_message', {json.dumps(output)}, {uuid})"
if self.opener is None:
self.evaluate_javascript(scripts, -1)
else:
self.opener.evaluate_javascript(scripts, -1)
return
case 'children':
callback = 'opener_message'
output = params.get('data')
uuid = params.get('uuid')
scripts = f"native.$emit('opener_message', {json.dumps(output)})"
if len(self.children) == 0:
self.evaluate_javascript(scripts, -1)
else:
if uuid is None:
for child in self.children:
child.evaluate_javascript(scripts, -1)
else:
for child in self.children:
if child.uuid == uuid:
child.evaluate_javascript(scripts, -1)
break
return
case 'window': case 'window':
_error, output = self._window_setting(params) _error, output = self._window_handler(params)
case 'notify': case 'notify':
@ -213,25 +261,61 @@ class WebEngine(WebKit2.WebView):
case 'proxy': case 'proxy':
_error, output = self._proxy_setting(params) _error, output = self._proxy_handler(params)
case 'md5': case 'md5':
output = hashlib.md5(str(params.get('value'))).hexdigest() output = hashlib.md5(str(params.get('value'))).hexdigest()
case _: case _:
if self.custom_bridge is None: if self.custom_bridge is not None:
pass try:
else: _error, output = self.custom_bridge(event, params) or (None, None)
_error, output = self.custom_bridge(event, params) except Exception as err:
print(err)
_error = err
# 有回调则返回结果 # 有回调则返回结果
if callback: if callback:
self.call_js(callback, output, _error) self.call_js(callback, output, _error)
def _app_handler(self, params = {}):
_error = None
output = None
match(params.get('action')):
# 退出app
case 'quit':
self.close_window()
self.emit('quit')
def _fs_setting(self, params = {}): case 'relaunch':
py = sys.executable
os.execl(py, py, *sys.argv)
return (_error, output)
def _shell_handler(self, params = {}):
_error = None
output = None
path = params.get('path')
match(params.get('action')):
case 'openExternal':
webbrowser.open(params.get('url'))
case 'showItemInFolder':
os.system(f"xdg-open '{path}'")
case 'openPath':
os.system(f"xdg-open '{path}'")
case 'trashItem':
pass
def _fs_handler(self, params = {}):
_error = None _error = None
output = None output = None
filepath = params.get('filepath') filepath = params.get('filepath')
@ -301,11 +385,14 @@ class WebEngine(WebKit2.WebView):
case 'isdir': case 'isdir':
output = os.path.isdir(filepath) output = os.path.isdir(filepath)
case 'mkdir':
output = os.makedirs(filepath)
return (_error, output) return (_error, output)
def _clipboard_setting(self, params = {}): def _clipboard_handler(self, params = {}):
_error = None _error = None
output = None output = None
@ -342,7 +429,7 @@ class WebEngine(WebKit2.WebView):
return (_error, output) return (_error, output)
def _keybinder_setting(self, params = {}): def _keybinder_handler(self, params = {}):
_error = None _error = None
output = None output = None
keymap = params.get('value') keymap = params.get('value')
@ -373,11 +460,18 @@ class WebEngine(WebKit2.WebView):
def _window_setting(self, params = {}): def _window_handler(self, params = {}):
_error = None _error = None
output = None output = None
match(params.get('action')): match(params.get('action')):
case 'create':
self.new_window_by_custom(params.get('options'))
case 'close':
self.close_window()
case 'fullscreen': case 'fullscreen':
self.window.fullscreen() self.window.fullscreen()
@ -428,7 +522,7 @@ class WebEngine(WebKit2.WebView):
def _proxy_setting(self, params = {}): def _proxy_handler(self, params = {}):
dm = self.get_website_data_manager() dm = self.get_website_data_manager()
output = True output = True
_error = None _error = None
@ -445,3 +539,4 @@ class WebEngine(WebKit2.WebView):
output = False output = False
return (_error, output) return (_error, output)

View File

@ -3,7 +3,7 @@
* @author yutent<yutent.io@gmail.com> * @author yutent<yutent.io@gmail.com>
* @date 2023/07/21 17:38:11 * @date 2023/07/21 17:38:11
*/ */
!(function () {
const MIME_TYPES = { const MIME_TYPES = {
html: 'text/html', html: 'text/html',
json: 'application/json', json: 'application/json',
@ -45,6 +45,11 @@ const KEYS_MAP = {
super: '<Super>' super: '<Super>'
} }
const NO_CALLBACK = false
const CALL_ONCE = true
const __events__ = Symbol('events')
function defer() { function defer() {
let obj = {} let obj = {}
obj.promise = new Promise((resolve, reject) => { obj.promise = new Promise((resolve, reject) => {
@ -58,22 +63,23 @@ function rand(prefix = 'cb_') {
return prefix + Math.random().toString().slice(2) return prefix + Math.random().toString().slice(2)
} }
function handler(event, data = {}, once = true) { function handler(event, data = {}, need = CALL_ONCE) {
let _ = defer() let _ = defer()
let callback let callback
if (typeof once === 'boolean') { if (need === NO_CALLBACK) {
_.resolve(true)
} else {
callback = rand() callback = rand()
native[once ? '$once' : '$on'](callback, (err, res) => { native.$once(callback, (err, res) => {
if (err) { if (err) {
_.reject(err) _.reject(new Error(err))
} else { } else {
_.resolve(res) _.resolve(res)
} }
}) })
} else {
_.resolve(true)
} }
window.webkit.messageHandlers.app.postMessage({ window.webkit.messageHandlers.app.postMessage({
event, event,
data, data,
@ -86,6 +92,34 @@ function base64(str = '') {
return btoa(str).replace(/[+=\/]/g, '') return btoa(str).replace(/[+=\/]/g, '')
} }
function _postMessage(data = {}, uuid = null) {
let ev = new Event('message')
Object.assign(ev, {
data,
source: {
postMessage(msg) {
native.children.postMessage(msg, uuid)
}
}
})
window.dispatchEvent(ev)
}
function readonly(obj, key, value) {
Object.defineProperty(obj, key, {
get() {
return value
},
enumerable: false
})
}
function _extend(origin, options = {}) {
for (let k in options) {
readonly(origin, k, options[k])
}
}
class NativeImage { class NativeImage {
#origin #origin
@ -139,15 +173,15 @@ class NativeImage {
} }
} }
class EventEmitter { class Native {
// //
__events__ = Object.create(null) [__events__] = Object.create(null)
$on(name, fn) { $on(name, fn) {
if (this.__events__[name]) { if (this[__events__][name]) {
this.__events__[name].push(fn) this[__events__][name].push(fn)
} else { } else {
this.__events__[name] = [fn] this[__events__][name] = [fn]
} }
} }
@ -157,18 +191,20 @@ class EventEmitter {
} }
$off(name, fn) { $off(name, fn) {
if (this.__events__[name]) { if (this[__events__][name]) {
if (fn) { if (fn) {
this.__events__[name] = this.__events__[name].filter(it => it !== fn) this[__events__][name] = this[__events__][name].filter(
it => it !== fn
)
} else { } else {
this.__events__[name] = [] this[__events__][name] = []
} }
} }
} }
$emit(name, ...args) { $emit(name, ...args) {
if (this.__events__[name]) { if (this[__events__][name]) {
for (let fn of this.__events__[name]) { for (let fn of this[__events__][name]) {
try { try {
fn.apply(this, args) fn.apply(this, args)
if (fn.__once__) { if (fn.__once__) {
@ -182,17 +218,34 @@ class EventEmitter {
} }
$destroy() { $destroy() {
this.__events__ = Object.create(null) this[__events__] = Object.create(null)
} }
} }
window.native = new EventEmitter() readonly(window, 'native', new Native())
Object.assign(native, { native.$on('opener_message', (data, uuid) => _postMessage(data, uuid))
_extend(native, {
env: '{{env}}', env: '{{env}}',
app: {
name: '{{app_name}}',
version: '{{app_version}}',
quit() { quit() {
return handler('quit', {}, null) return handler('app', { action: 'quit' }, NO_CALLBACK)
},
relaunch() {
return handler('app', { action: 'relaunch' }, NO_CALLBACK)
},
getLocale() {
return native.env.LANG
}
},
shell: {
openExternal(url) {},
showItemInFolder(path) {},
openPath(path) {},
trashItem(path) {}
}, },
fs: { fs: {
access(filepath, mode = 'r') { access(filepath, mode = 'r') {
@ -240,6 +293,9 @@ Object.assign(native, {
}, },
copy(filepath, target) { copy(filepath, target) {
return handler('fs', { action: 'copy', filepath, target }) return handler('fs', { action: 'copy', filepath, target })
},
mkdir(filepath) {
return handler('fs', { action: 'mkdir', filepath })
} }
}, },
image(filepath) { image(filepath) {
@ -250,7 +306,7 @@ Object.assign(native, {
return handler('clipboard', { action: 'wait_for_text' }) return handler('clipboard', { action: 'wait_for_text' })
}, },
writeText(value) { writeText(value) {
return handler('clipboard', { action: 'set_text', value }, null) return handler('clipboard', { action: 'set_text', value }, NO_CALLBACK)
}, },
readImage() { readImage() {
return handler('clipboard', { action: 'wait_for_image' }).then(r => return handler('clipboard', { action: 'wait_for_image' }).then(r =>
@ -262,10 +318,10 @@ Object.assign(native, {
if (typeof value === 'object') { if (typeof value === 'object') {
value = value.toJSON() value = value.toJSON()
} }
return handler('clipboard', { action: 'set_image', value }, null) return handler('clipboard', { action: 'set_image', value }, NO_CALLBACK)
}, },
clear() { clear() {
return handler('clipboard', { action: 'clear' }) return handler('clipboard', { action: 'clear' }, NO_CALLBACK)
} }
}, },
screen: { screen: {
@ -338,48 +394,87 @@ Object.assign(native, {
return handler('tray', { action: 'set_status', value: status }) return handler('tray', { action: 'set_status', value: status })
} }
}, },
opener: {
postMessage(data = {}) {
return handler('opener', { action: 'postmessage', data }, NO_CALLBACK)
}
},
children: {
postMessage(data = {}, uuid = null) {
return handler(
'children',
{ action: 'postmessage', data, uuid },
NO_CALLBACK
)
}
},
window: { window: {
uuid: '{{uuid}}',
create(options = {}) {
return handler('window', { action: 'create', options })
},
close() {
return handler('window', { action: 'close' })
},
isVisible() { isVisible() {
return handler('window', { action: 'is_visible' }) return handler('window', { action: 'is_visible' })
}, },
toggleVisible() { toggleVisible() {
handler('window', { action: 'toggle_visible' }, null) handler('window', { action: 'toggle_visible' }, NO_CALLBACK)
}, },
hide() { hide() {
handler('window', { action: 'hide' }, null) handler('window', { action: 'hide' }, NO_CALLBACK)
}, },
show() { show() {
handler('window', { action: 'show' }, null) handler('window', { action: 'show' }, NO_CALLBACK)
}, },
fullscreen() { fullscreen() {
handler('window', { action: 'fullscreen' }, null) handler('window', { action: 'fullscreen' }, NO_CALLBACK)
}, },
unfullscreen() { unfullscreen() {
handler('window', { action: 'unfullscreen' }, null) handler('window', { action: 'unfullscreen' }, NO_CALLBACK)
}, },
maximize() { maximize() {
handler('window', { action: 'maximize' }, null) handler('window', { action: 'maximize' }, NO_CALLBACK)
}, },
unmaximize() { unmaximize() {
handler('window', { action: 'unmaximize' }, null) handler('window', { action: 'unmaximize' }, NO_CALLBACK)
}, },
setTitle(title = '') { setTitle(title = '') {
handler('window', { action: 'set_title', value: title }, null) handler('window', { action: 'set_title', value: title }, NO_CALLBACK)
}, },
resize(width = 0, height = 0) { resize(width = 0, height = 0) {
handler('window', { action: 'resize', value: { width, height } }, null) handler(
'window',
{ action: 'resize', value: { width, height } },
NO_CALLBACK
)
}, },
move(x = 0, y = 0) { move(x = 0, y = 0) {
handler('window', { action: 'resize', value: { x, y } }, null) handler('window', { action: 'move', value: { x, y } }, NO_CALLBACK)
}, },
setOpacity(opacity = 1) { setOpacity(opacity = 1) {
handler('window', { action: 'set_opacity', value: opacity }, null) handler(
'window',
{ action: 'set_opacity', value: opacity },
NO_CALLBACK
)
}, },
alwayOnTop(setting = true) { alwayOnTop(setting = true) {
handler('window', { action: 'set_keep_above', value: setting }, null) handler(
'window',
{ action: 'set_keep_above', value: setting },
NO_CALLBACK
)
}, },
alwayOnBotttom(setting = true) { alwayOnBotttom(setting = true) {
handler('window', { action: 'set_keep_below', value: setting }, null) handler(
'window',
{ action: 'set_keep_below', value: setting },
NO_CALLBACK
)
} }
}, },
notify({ title, summary, icon, progress = 0, urgency = 0, callback }) { notify({ title, summary, icon, progress = 0, urgency = 0, callback }) {
@ -391,7 +486,7 @@ Object.assign(native, {
handler( handler(
'notify', 'notify',
{ title, summary, icon, progress, urgency, callback: eventName }, { title, summary, icon, progress, urgency, callback: eventName },
null NO_CALLBACK
) )
}, },
@ -401,15 +496,16 @@ Object.assign(native, {
proxy: { proxy: {
disable() { disable() {
return handler('proxy', { action: 'disable' }) return handler('proxy', { action: 'disable' }, NO_CALLBACK)
}, },
system() { system() {
return handler('proxy', { action: 'system' }) return handler('proxy', { action: 'system' }, NO_CALLBACK)
}, },
custom(url = '', ignore = null) { custom(url = '', ignore = null) {
return handler('proxy', { action: 'enable', url, ignore }) return handler('proxy', { action: 'enable', url, ignore }, NO_CALLBACK)
} }
}, },
handler handler
}) })
})()