io/clipboard,app: add WriteOp, ReadOp

Previously, the only way to manipulate the clipboard (read or write) is
using the `app.Window`.

The new `clipboard.ReadOp` and `clipboard.WriteOp`makes possible to
read/write from the widget.

Signed-off-by: Inkeliz <inkeliz@inkeliz.com>

io/router/clipboard.go

@@ -0,0 +1,66 @@
+// SPDX-License-Identifier: Unlicense OR MIT
+
+package router
+
+import (
+	"gioui.org/internal/opconst"
+	"gioui.org/internal/ops"
+	"gioui.org/io/event"
+)
+
+type clipboardQueue struct {
+	receivers map[event.Tag]struct{}
+	// request avoid read clipboard every frame while waiting.
+	requested bool
+	text      *string
+	reader    ops.Reader
+}
+
+// WriteClipboard returns the most recent text to be copied
+// to the clipboard, if any.
+func (q *clipboardQueue) WriteClipboard() (string, bool) {
+	if q.text == nil {
+		return "", false
+	}
+	text := *q.text
+	q.text = nil
+	return text, true
+}
+
+// ReadClipboard reports if any new handler is waiting
+// to read the clipboard.
+func (q *clipboardQueue) ReadClipboard() bool {
+	if len(q.receivers) <= 0 || q.requested {
+		return false
+	}
+	q.requested = true
+	return true
+}
+
+func (q *clipboardQueue) Push(e event.Event, events *handlerEvents) {
+	for r := range q.receivers {
+		events.Add(r, e)
+		delete(q.receivers, r)
+	}
+}
+
+func (q *clipboardQueue) ProcessWriteClipboard(d []byte, refs []interface{}) {
+	if opconst.OpType(d[0]) != opconst.TypeClipboardWrite {
+		panic("invalid op")
+	}
+	q.text = refs[0].(*string)
+}
+
+func (q *clipboardQueue) ProcessReadClipboard(d []byte, refs []interface{}) {
+	if opconst.OpType(d[0]) != opconst.TypeClipboardRead {
+		panic("invalid op")
+	}
+	if q.receivers == nil {
+		q.receivers = make(map[event.Tag]struct{})
+	}
+	tag := refs[0].(event.Tag)
+	if _, ok := q.receivers[tag]; !ok {
+		q.receivers[tag] = struct{}{}
+		q.requested = false
+	}
+}

io/router/clipboard_test.go

@@ -0,0 +1,153 @@
+package router
+
+import (
+	"gioui.org/io/clipboard"
+	"gioui.org/io/event"
+	"gioui.org/op"
+	"testing"
+)
+
+func TestClipboardDuplicateEvent(t *testing.T) {
+	ops, router, handler := new(op.Ops), new(Router), make([]int, 2)
+
+	// Both must receive the event once
+	clipboard.ReadOp{Tag: &handler[0]}.Add(ops)
+	clipboard.ReadOp{Tag: &handler[1]}.Add(ops)
+
+	router.Frame(ops)
+	event := clipboard.Event{Text: "Test"}
+	router.Add(event)
+	assertClipboardReadOp(t, router, 0)
+	assertClipboardEvent(t, router.Events(&handler[0]), true)
+	assertClipboardEvent(t, router.Events(&handler[1]), true)
+	ops.Reset()
+
+	// No ReadOp
+
+	router.Frame(ops)
+	assertClipboardReadOp(t, router, 0)
+	assertClipboardEvent(t, router.Events(&handler[0]), false)
+	assertClipboardEvent(t, router.Events(&handler[1]), false)
+	ops.Reset()
+
+	clipboard.ReadOp{Tag: &handler[0]}.Add(ops)
+
+	router.Frame(ops)
+	// No ClipboardEvent sent
+	assertClipboardReadOp(t, router, 1)
+	assertClipboardEvent(t, router.Events(&handler[0]), false)
+	assertClipboardEvent(t, router.Events(&handler[1]), false)
+	ops.Reset()
+}
+
+func TestQueueProcessReadClipboard(t *testing.T) {
+	ops, router, handler := new(op.Ops), new(Router), make([]int, 2)
+	ops.Reset()
+
+	// Request read
+	clipboard.ReadOp{Tag: &handler[0]}.Add(ops)
+
+	router.Frame(ops)
+	assertClipboardReadOp(t, router, 1)
+	ops.Reset()
+
+	for i := 0; i < 3; i++ {
+		// No ReadOp
+		// One receiver must still wait for response
+
+		router.Frame(ops)
+		assertClipboardReadOpDuplicated(t, router, 1)
+		ops.Reset()
+	}
+
+	router.Frame(ops)
+	// Send the clipboard event
+	event := clipboard.Event{Text: "Text 2"}
+	router.Add(event)
+	assertClipboardReadOp(t, router, 0)
+	assertClipboardEvent(t, router.Events(&handler[0]), true)
+	ops.Reset()
+
+	// No ReadOp
+	// There's no receiver waiting
+
+	router.Frame(ops)
+	assertClipboardReadOp(t, router, 0)
+	assertClipboardEvent(t, router.Events(&handler[0]), false)
+	ops.Reset()
+}
+
+func TestQueueProcessWriteClipboard(t *testing.T) {
+	ops, router := new(op.Ops), new(Router)
+	ops.Reset()
+
+	clipboard.WriteOp{Text: "Write 1"}.Add(ops)
+
+	router.Frame(ops)
+	assertClipboardWriteOp(t, router, "Write 1")
+	ops.Reset()
+
+	// No WriteOp
+
+	router.Frame(ops)
+	assertClipboardWriteOp(t, router, "")
+	ops.Reset()
+
+	clipboard.WriteOp{Text: "Write 2"}.Add(ops)
+
+	router.Frame(ops)
+	assertClipboardReadOp(t, router, 0)
+	assertClipboardWriteOp(t, router, "Write 2")
+	ops.Reset()
+}
+
+func assertClipboardEvent(t *testing.T, events []event.Event, expected bool) {
+	t.Helper()
+	var evtClipboard int
+	for _, e := range events {
+		switch e.(type) {
+		case clipboard.Event:
+			evtClipboard++
+		}
+	}
+	if evtClipboard <= 0 && expected {
+		t.Error("expected to receive some event")
+	}
+	if evtClipboard > 0 && !expected {
+		t.Error("unexpected event received")
+	}
+}
+
+func assertClipboardReadOp(t *testing.T, router *Router, expected int) {
+	t.Helper()
+	if len(router.cqueue.receivers) != expected {
+		t.Error("unexpected number of receivers")
+	}
+	if router.cqueue.ReadClipboard() != (expected > 0) {
+		t.Error("missing requests")
+	}
+}
+
+func assertClipboardReadOpDuplicated(t *testing.T, router *Router, expected int) {
+	t.Helper()
+	if len(router.cqueue.receivers) != expected {
+		t.Error("receivers removed")
+	}
+	if router.cqueue.ReadClipboard() != false {
+		t.Error("duplicated requests")
+	}
+}
+
+func assertClipboardWriteOp(t *testing.T, router *Router, expected string) {
+	t.Helper()
+	if (router.cqueue.text != nil) != (expected != "") {
+		t.Error("text not defined")
+	}
+	text, ok := router.cqueue.WriteClipboard()
+	if ok != (expected != "") {
+		t.Error("duplicated requests")
+	}
+	if text != expected {
+		t.Errorf("got text %s, expected %s", text, expected)
+	}
+}

io/router/router.go

@@ -16,6 +16,7 @@ import (
 
 	"gioui.org/internal/opconst"
 	"gioui.org/internal/ops"
+	"gioui.org/io/clipboard"
 	"gioui.org/io/event"
 	"gioui.org/io/key"
 	"gioui.org/io/pointer"
@@ -28,6 +29,7 @@ import (
 type Router struct {
 	pqueue pointerQueue
 	kqueue keyQueue
+	cqueue clipboardQueue
 
 	handlers handlerEvents
 
@@ -88,6 +90,8 @@ func (q *Router) Add(events ...event.Event) bool {
 			q.pqueue.Push(e, &q.handlers)
 		case key.EditEvent, key.Event, key.FocusEvent:
 			q.kqueue.Push(e, &q.handlers)
+		case clipboard.Event:
+			q.cqueue.Push(e, &q.handlers)
 		}
 	}
 	return q.handlers.HadEvents()
@@ -99,6 +103,18 @@ func (q *Router) TextInputState() TextInputState {
 	return q.kqueue.InputState()
 }
 
+// WriteClipboard returns the most recent text to be copied
+// to the clipboard, if any.
+func (q *Router) WriteClipboard() (string, bool) {
+	return q.cqueue.WriteClipboard()
+}
+
+// ReadClipboard reports if any new handler is waiting
+// to read the clipboard.
+func (q *Router) ReadClipboard() bool {
+	return q.cqueue.ReadClipboard()
+}
+
 func (q *Router) collect() {
 	for encOp, ok := q.reader.Decode(); ok; encOp, ok = q.reader.Decode() {
 		switch opconst.OpType(encOp.Data[0]) {
@@ -115,6 +131,10 @@ func (q *Router) collect() {
 			}
 			q.profiling = true
 			q.profHandlers[op.Tag] = struct{}{}
+		case opconst.TypeClipboardRead:
+			q.cqueue.ProcessReadClipboard(encOp.Data, encOp.Refs)
+		case opconst.TypeClipboardWrite:
+			q.cqueue.ProcessWriteClipboard(encOp.Data, encOp.Refs)
 		}
 	}
 }