test/energy
1
0
Fork 0
mirror of https://gitee.com/energye/energy.git synced 2024-11-30 02:37:46 +08:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

U: ipc.Emit 函数增加返回值 "bool"

Browse Source
This commit is contained in:
杨红岩 2023-12-13 18:15:34 +08:00
parent 959b809091
commit 819d01571c
5 changed files with 141 additions and 119 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
cef/application_run.go
View File

@ -13,7 +13,6 @@
package cef
import (
"github.com/energye/energy/v2/cef/internal/ipc"
"github.com/energye/energy/v2/cef/lclwidget"
"github.com/energye/energy/v2/cef/process"
"github.com/energye/energy/v2/common"
@ -39,12 +38,12 @@ var (
browserProcessStartAfterCallback browserProcessStartAfterCallbackFunc
)
func init() {
if process.Args.IsMain() || process.Args.IsRender() {
// 设置BrowserWindow到IPC实现
ipc.SetBrowserWindow(BrowserWindow)
}
}
//func init() {
// if process.Args.IsMain() || process.Args.IsRender() {
// // 设置BrowserWindow到IPC实现
// ipc.SetBrowserWindow(BrowserWindow)
// }
//}
type browserProcessStartAfterCallbackFunc func(success bool)

63
cef/browser_main_window.go
View File

@ -14,7 +14,6 @@ package cef
import (
"github.com/energye/energy/v2/cef/internal/ipc"
"github.com/energye/energy/v2/cef/ipc/target"
. "github.com/energye/energy/v2/cef/process"
. "github.com/energye/energy/v2/consts"
"github.com/energye/golcl/lcl"
@ -201,37 +200,37 @@ func (m *browserWindow) GetBrowser(browseId int32) *ICefBrowser {
// LookForMainWindow
// 找到一个最小的窗口ID做主下一个主窗口
func (m *browserWindow) LookForMainWindow() (window target.IWindow) {
var (
browseId int32 = 0
browseWindow IBrowserWindow
)
// 找到最小浏览器ID做下一个主窗口
for bid, info := range m.GetWindowInfos() {
if info.IsClosing() {
// 已被关闭的窗口忽略
continue
} else if info.WindowType() == WT_MAIN_BROWSER {
// 如果是主窗口直接返回
browseWindow = info
break
}
// 找到最小browserID做为主窗口
if browseId == 0 {
browseId = bid
browseWindow = info
} else if bid < browseId {
browseId = bid
browseWindow = info
}
}
if browseWindow != nil {
// 设置为主窗口
browseWindow.SetWindowType(WT_MAIN_BROWSER)
window = browseWindow.AsTargetWindow()
}
return
}
//func (m *browserWindow) LookForMainWindow() (window target.IWindow) {
// var (
// browseId int32 = 0
// browseWindow IBrowserWindow
// )
// // 找到最小浏览器ID做下一个主窗口
// for bid, info := range m.GetWindowInfos() {
// if info.IsClosing() {
// // 已被关闭的窗口忽略
// continue
// } /* else if info.WindowType() == WT_MAIN_BROWSER {
// // 如果是主窗口直接返回
// browseWindow = info
// break
// }*/
// // 找到最小browserID做为主窗口
// if browseId == 0 {
// browseId = bid
// browseWindow = info
// } else if bid < browseId {
// browseId = bid
// browseWindow = info
// }
// }
// if browseWindow != nil {
// // 设置为主窗口
// browseWindow.SetWindowType(WT_MAIN_BROWSER)
// window = browseWindow.AsTargetWindow()
// }
// return
//}
// SetOnAfterCreated
func (m *BrowserEvent) SetOnAfterCreated(event chromiumEventOnAfterCreatedEx) {

55
cef/internal/ipc/ipc.go
View File

@ -44,7 +44,7 @@ type browserIPC struct {
emitLock sync.Mutex
messageLock sync.Mutex
window target.IWindow
browserWindow target.IBrowserWindow
//browserWindow target.IBrowserWindow
}
// SyncChan
@ -98,11 +98,11 @@ func SetProcessMessage(pm target.IWindow) {
// SetBrowserWindow
// Set BrowserWindow on initialization
func SetBrowserWindow(bw target.IBrowserWindow) {
if browser.browserWindow == nil {
browser.browserWindow = bw
}
}
//func SetBrowserWindow(bw target.IBrowserWindow) {
// if browser.browserWindow == nil {
// browser.browserWindow = bw
// }
//}
// On
//
@ -146,17 +146,19 @@ func RemoveOn(name string) {
//
// Event that triggers listening
// default to triggering the main process
func Emit(name string, argument ...any) {
func Emit(name string, argument ...any) bool {
if name == "" || browser.window == nil {
return
return false
}
browser.messageLock.Lock()
defer browser.messageLock.Unlock()
// When the window is closed, select a new window as the main window
if browser.window == nil || browser.window.IsClosing() {
browser.window = browser.browserWindow.LookForMainWindow()
return false
//browser.window = browser.browserWindow.LookForMainWindow()
}
browser.window.ProcessMessage().EmitRender(0, name, nil, argument...)
return true
}
// EmitAndCallback
@ -164,36 +166,40 @@ func Emit(name string, argument ...any) {
// Event that triggers listening
// with callback function
// default to the main process
func EmitAndCallback(name string, argument []any, fn any) {
func EmitAndCallback(name string, argument []any, fn any) bool {
if name == "" || browser.window == nil {
return
return false
}
browser.messageLock.Lock()
defer browser.messageLock.Unlock()
messageId := browser.addEmitCallback(fn)
// When the window is closed, select a new window as the main window
// When the window is closed
if browser.window == nil || browser.window.IsClosing() {
browser.window = browser.browserWindow.LookForMainWindow()
return false
//browser.window = browser.browserWindow.LookForMainWindow()
}
messageId := browser.addEmitCallback(fn)
if ok := browser.window.ProcessMessage().EmitRender(messageId, name, nil, argument...); !ok {
//fail in send
if messageId > 0 {
removeEmitCallback(messageId)
}
return false
}
return true
}
// EmitTarget
//
// Trigger an event for the specified target to listen to
func EmitTarget(name string, tag target.ITarget, argument ...any) {
func EmitTarget(name string, tag target.ITarget, argument ...any) bool {
if name == "" {
return
return false
}
if tag != nil {
// Send Go
if (tag.ChannelId() > 0 && tag.TargetType() == target.TgGoSub) || (tag.TargetType() == target.TgGoMain) {
emitSendToGoChannel(0, tag, name, argument)
return
return true
}
}
// Send JS
@ -201,34 +207,43 @@ func EmitTarget(name string, tag target.ITarget, argument ...any) {
if window == nil {
window = browser.window
}
if window.IsClosing() {
return false
}
window.ProcessMessage().EmitRender(0, name, tag, argument...)
return true
}
// EmitTargetAndCallback
//
// Trigger an event with a callback function for the specified target to listen on
func EmitTargetAndCallback(name string, tag target.ITarget, argument []any, fn any) {
func EmitTargetAndCallback(name string, tag target.ITarget, argument []any, fn any) bool {
if name == "" {
return
return false
}
var messageId int32 = 0
if tag != nil {
if (tag.ChannelId() > 0 && tag.TargetType() == target.TgGoSub) || (tag.TargetType() == target.TgGoMain) {
messageId = browser.addEmitCallback(fn)
emitSendToGoChannel(messageId, tag, name, argument)
return
return true
}
}
var window = tag.Window()
if window == nil {
window = browser.window
}
if window.IsClosing() {
return false
}
messageId = browser.addEmitCallback(fn)
if ok := window.ProcessMessage().EmitRender(messageId, name, tag, argument...); !ok {
if messageId > 0 {
removeEmitCallback(messageId)
}
return false
}
return true
}
// CheckOnEvent

123
cef/ipc/ipc.go
View File

@ -21,40 +21,45 @@ import (
"github.com/energye/energy/v2/cef/ipc/types"
)
//On
// IPC GO 监听事件
// On
//
// IPC GO 监听事件
//
// 参数
// 支持 JavaScript 对应 Go 的基本类型和复合类型
// name: 事件名称
// fn : 事件回调函数 EmitContextCallback 或 func(...) [result...] {}
// options: 监听选项, 配置监听规则
//
// 支持 JavaScript 对应 Go 的基本类型和复合类型
// name: 事件名称
// fn : 事件回调函数 EmitContextCallback 或 func(...) [result...] {}
// options: 监听选项, 配置监听规则
//
// 入参
// 基本类型: int(int8 ~ uint64), bool, float(float32、float64), string
//
// 复合类型: slice, map, struct
// 基本类型: int(int8 ~ uint64), bool, float(float32、float64), string
//
// slice: 根据js实际类型定义, []any | []interface{} | [][data type]
// map: key 只能 string 类型, value 基本类型+复合类型
// struct: 首字母大写, 字段类型匹配
// type ArgsStructDemo struct {
// Key1 string
// Key2 string
// Key3 string
// Key4 int
// Key5 float64
// Key6 bool
// Sub1 SubStructXXX
// Sub2 *SubStructXXX
// }
// 复合类型: slice, map, struct
//
// slice: 根据js实际类型定义, []any | []interface{} | [][data type]
// map: key 只能 string 类型, value 基本类型+复合类型
// struct: 首字母大写, 字段类型匹配
// type ArgsStructDemo struct {
// Key1 string
// Key2 string
// Key3 string
// Key4 int
// Key5 float64
// Key6 bool
// Sub1 SubStructXXX
// Sub2 *SubStructXXX
// }
//
// 出参
// fn 回调函数的出参与入参使用方式相同
//
// fn 回调函数的出参与入参使用方式相同
func On(name string, fn any, options ...types.OnOptions) {
ipc.On(name, fn, options...)
}
//RemoveOn
// RemoveOn
// IPC GO 移除监听事件
func RemoveOn(name string) {
if name == "" {
@ -63,54 +68,58 @@ func RemoveOn(name string) {
ipc.RemoveOn(name)
}
//Emit
// IPC GO 中触发 Go | JS 监听的事件, 默认主进程
// Emit
// IPC GO 中触发 Go | JS 监听的事件, 主窗口
//
// 参数
// name: 监听的事件名
// []argument: 入参
// 基本类型: int(int8 ~ uint64), bool, float(float32、float64), string
// 复合类型: slice, map, struct
func Emit(name string, argument ...any) {
ipc.Emit(name, argument...)
//
// name: 监听的事件名
// []argument: 入参
// 基本类型: int(int8 ~ uint64), bool, float(float32、float64), string
// 复合类型: slice, map, struct
func Emit(name string, argument ...any) bool {
return ipc.Emit(name, argument...)
}
//EmitAndCallback
// IPC GO 中触发 Go | JS 监听的事件, 默认主进程
// EmitAndCallback
// IPC GO 中触发 Go | JS 监听的事件, 主窗口
//
// 参数
// name: 监听的事件名
// []argument: 入参
// 基本类型: int(int8 ~ uint64), bool, float(float32、float64), string
// 复合类型: slice, map, struct
// callback: 回调函数, 接收返回值. 函数类型 EmitContextCallback 或 func(...) [result...] {}
func EmitAndCallback(name string, argument []any, callback any) {
ipc.EmitAndCallback(name, argument, callback)
//
// name: 监听的事件名
// []argument: 入参
// 基本类型: int(int8 ~ uint64), bool, float(float32、float64), string
// 复合类型: slice, map, struct
// callback: 回调函数, 接收返回值. 函数类型 EmitContextCallback 或 func(...) [result...] {}
func EmitAndCallback(name string, argument []any, callback any) bool {
return ipc.EmitAndCallback(name, argument, callback)
}
//EmitTarget
// EmitTarget
// IPC GO 中触发指定目标 Go | JS 监听的事件
//
// 参数
// name: 监听的事件名
// target: 接收事件的目标
// []argument: 入参
// 基本类型: int(int8 ~ uint64), bool, float(float32、float64), string
// 复合类型: slice, map, struct
func EmitTarget(name string, target target.ITarget, argument ...any) {
ipc.EmitTarget(name, target, argument...)
//
// name: 监听的事件名
// target: 接收事件的目标
// []argument: 入参
// 基本类型: int(int8 ~ uint64), bool, float(float32、float64), string
// 复合类型: slice, map, struct
func EmitTarget(name string, target target.ITarget, argument ...any) bool {
return ipc.EmitTarget(name, target, argument...)
}
//EmitTargetAndCallback
// EmitTargetAndCallback
// IPC GO 中触发指定目标 Go | JS 监听的事件
//
// 参数
// name: 监听的事件名
// target: 接收事件的目标
// []argument: 入参
// 基本类型: int(int8 ~ uint64), bool, float(float32、float64), string
// 复合类型: slice, map, struct
// callback: 回调函数, 接收返回值. 函数类型 EmitContextCallback 或 func(...) [result...] {}
func EmitTargetAndCallback(name string, target target.ITarget, argument []any, callback any) {
ipc.EmitTargetAndCallback(name, target, argument, callback)
//
// name: 监听的事件名
// target: 接收事件的目标
// []argument: 入参
// 基本类型: int(int8 ~ uint64), bool, float(float32、float64), string
// 复合类型: slice, map, struct
// callback: 回调函数, 接收返回值. 函数类型 EmitContextCallback 或 func(...) [result...] {}
func EmitTargetAndCallback(name string, target target.ITarget, argument []any, callback any) bool {
return ipc.EmitTargetAndCallback(name, target, argument, callback)
}

6
cef/ipc/target/target.go
View File

@ -57,9 +57,9 @@ type IWindow interface {
ProcessMessage() IProcessMessage
}
type IBrowserWindow interface {
LookForMainWindow() (window IWindow)
}
//type IBrowserWindow interface {
// LookForMainWindow() (window IWindow)
//}
// NewTarget Create a new Emit target
//