From 307e07b4c8c0bc965ad09b7e9c76538ff94691ad Mon Sep 17 00:00:00 2001
From: Lea Anthony <lea.anthony@gmail.com>
Date: Tue, 20 Oct 2020 06:45:46 +1100
Subject: [PATCH] Finish events page

---
 v2/test/kitchensink/events.go                 |  13 ++
 .../frontend/src/pages/events/Events.svelte   |   3 +
 .../pages/events/OnMultiple/OnMultiple.svelte | 120 ++++++++++++++++++
 .../src/pages/events/OnMultiple/code.go       |  18 +++
 .../src/pages/events/OnMultiple/code.jsx      |   8 ++
 .../pages/events/OnMultiple/description.txt   |   3 +
 .../frontend/src/pages/events/Once/code.go    |   6 +-
 .../frontend/src/pages/events/Once/code.jsx   |   7 +-
 8 files changed, 169 insertions(+), 9 deletions(-)
 create mode 100644 v2/test/kitchensink/frontend/src/pages/events/OnMultiple/OnMultiple.svelte
 create mode 100644 v2/test/kitchensink/frontend/src/pages/events/OnMultiple/code.go
 create mode 100644 v2/test/kitchensink/frontend/src/pages/events/OnMultiple/code.jsx
 create mode 100644 v2/test/kitchensink/frontend/src/pages/events/OnMultiple/description.txt

diff --git a/v2/test/kitchensink/events.go b/v2/test/kitchensink/events.go
index e8e4d2774..bb4f50173 100644
--- a/v2/test/kitchensink/events.go
+++ b/v2/test/kitchensink/events.go
@@ -40,6 +40,19 @@ func (e *Events) Once(eventName string) {
 	})
 }
 
+// OnMultiple will subscribe to the given event name, with a maximum
+// set by maxCallbacks
+func (e *Events) OnMultiple(eventName string, maxCallbacks int) {
+	e.runtime.Events.OnMultiple(eventName, func(args ...interface{}) {
+		type callbackData struct {
+			Name string
+			Data []interface{}
+		}
+		result := callbackData{Name: eventName, Data: args}
+		e.runtime.Events.Emit("onmultiple event fired by go subscriber", result)
+	}, maxCallbacks)
+}
+
 // Emit will emit
 func (e *Events) Emit(eventName string, data []interface{}) {
 	e.runtime.Events.Emit(eventName, data...)
diff --git a/v2/test/kitchensink/frontend/src/pages/events/Events.svelte b/v2/test/kitchensink/frontend/src/pages/events/Events.svelte
index c34f92a4e..73544d6e3 100644
--- a/v2/test/kitchensink/frontend/src/pages/events/Events.svelte
+++ b/v2/test/kitchensink/frontend/src/pages/events/Events.svelte
@@ -2,6 +2,7 @@
     import On from './On/On.svelte';
     import Emit from './Emit/Emit.svelte';
     import Once from './Once/Once.svelte';
+    import OnMultiple from './OnMultiple/OnMultiple.svelte';
 </script>
 
 <div>
@@ -22,6 +23,8 @@
     <br/>     
     <Once></Once>
     <br/>
+    <OnMultiple></OnMultiple>
+    <br/>
     <Emit></Emit>
 </div>
 
diff --git a/v2/test/kitchensink/frontend/src/pages/events/OnMultiple/OnMultiple.svelte b/v2/test/kitchensink/frontend/src/pages/events/OnMultiple/OnMultiple.svelte
new file mode 100644
index 000000000..085282ab3
--- /dev/null
+++ b/v2/test/kitchensink/frontend/src/pages/events/OnMultiple/OnMultiple.svelte
@@ -0,0 +1,120 @@
+<script>
+    import { Events } from '@wails/runtime';
+    import { writable } from 'svelte/store';
+    import CodeBlock from '../../../components/CodeBlock.svelte';
+    import CodeSnippet from '../../../components/CodeSnippet.svelte';
+    import description from './description.txt';
+    import { UniqueID } from '../../../utils/utils';
+    import FakeTerm from '../../../components/FakeTerm.svelte';
+    import jsCode from './code.jsx';
+    import goCode from './code.go';
+    import { loggingOutput } from '../On/store';
+
+    let isJs = false;
+    $: lang = isJs ? 'Javascript' : 'Go';
+
+    // Listeners
+    let listeners = writable([]);
+    let counts = {};
+    let id = UniqueID('events');
+
+    let eventName = "";
+    let maxCallbacks = 1;
+
+    function removeSubscriber(eventName, source) {
+        listeners.update( (current) => {
+            let name = '"' + eventName + '" (' + source + ')';
+            const index = current.indexOf(name);
+            if (index > -1) { 
+                current.splice(index, 1); 
+            }
+            return current;
+        });
+    }
+
+    function updateLog(eventName, data, source) {
+        let name = '"' + eventName + '" (' + source + ")";
+        console.log(counts);
+        counts[name].current = counts[name].current + 1;
+        console.log(counts);
+        let countText = counts[name].current + "/" + counts[name].max;
+        if( counts[name].current === counts[name].max) {
+            removeSubscriber(name);
+        }
+        loggingOutput.update( (log) => {
+            let datatext = (data ? JSON.stringify(data) : "(No data given)");
+            let destroyText = "";
+            if( counts[name].current === counts[name].max) {
+                destroyText = " (Listener Now Destroyed) ";
+            }
+            return log + "[" + eventName + " (" + source + ") " + countText + "] data: " + datatext + destroyText + "\n";
+        });
+    }
+
+    // Subscribe to the Go event calls
+    Events.On("onmultiple event fired by go subscriber", (input) => {
+        // Format the data for printing
+        updateLog(input.Name, input.Data, "Go");
+    });
+
+    function subscribe() {
+        if (eventName.length == 0) {
+            return
+        }
+
+        let name = '"' + eventName + '" (' + (isJs ? 'JS' : 'Go') + ")"
+        if( $listeners.includes(name) ) {
+            return
+        }
+
+        // Add eventName to listeners list
+        listeners.update( (current) => {
+            return current.concat(name);
+        });
+
+        counts[name] = { max: maxCallbacks, current: 0 }
+        if( isJs ) {
+            Events.OnMultiple(eventName, (...data) => {
+                updateLog(eventName, data, "JS");
+            }, maxCallbacks);
+        } else {
+            // We call a function in Go to register a subscriber
+            // for us
+            backend.main.Events.OnMultiple(eventName, maxCallbacks);
+        }
+    }
+
+    $: testcodeJs = "import { Events } from '@wails/runtime';\nEvents.OnMultiple('" + eventName + "', callback, " + maxCallbacks + ");";
+    $: testcodeGo = '// runtime is given through WailsInit()\nruntime.Events.OnMultiple("' + eventName + '", func(optionalData ...interface{} {\n // Process data\n}), " + maxCallbacks + ")'; 
+
+</script>
+
+<CodeBlock bind:isJs={isJs} {jsCode} {goCode} {id} title="Events.OnMultiple(eventName, callback)" {description}>
+    <div class="logging-form">
+        <form data-wails-no-drag class="mw-full"> 
+            <div class="form-group">
+                <label for="{id}-eventName" class="required">Event Name to subscribe to</label>
+                <input type="text" class="form-control" id="{id}-eventName" placeholder="MyEventName" bind:value="{eventName}" required="required">
+            </div>
+            <div class="form-group">
+                <label for="{id}-maxTimes" class="required">Number of times the callback should fire</label>
+                <input type="number" class="form-control" id="{id}-maxTimes" placeholder="1" bind:value="{maxCallbacks}">
+            </div>
+            <input class="btn btn-primary" type="button" on:click="{subscribe}" value="Subscribe using {lang} runtime">
+            <CodeSnippet bind:isJs={isJs} jsCode={testcodeJs} goCode={testcodeGo}></CodeSnippet>
+            {#if $listeners.length > 0 }
+            <div class="form-group" style="margin-top:10px">
+                Subscribed to:
+                <ul class="list">
+                {#each $listeners as listener}
+                    <li>{listener}</li>
+                {/each}
+            </div>
+            Now use <code>Events.Emit</code> to trigger the subscribers!<br/>
+            <div style="margin-top: 10px">Subscriber output will be printed below:</div>
+            <FakeTerm text={$loggingOutput} style="height: 300px; overflow: scroll"></FakeTerm>
+            {/if}
+
+        </form>
+    </div>
+</CodeBlock>
diff --git a/v2/test/kitchensink/frontend/src/pages/events/OnMultiple/code.go b/v2/test/kitchensink/frontend/src/pages/events/OnMultiple/code.go
new file mode 100644
index 000000000..e34cad17f
--- /dev/null
+++ b/v2/test/kitchensink/frontend/src/pages/events/OnMultiple/code.go
@@ -0,0 +1,18 @@
+package main
+
+import wails "github.com/wailsapp/wails/v2"
+
+type MyStruct struct {
+	runtime *wails.Runtime
+}
+
+func (m *MyStruct) WailsInit(runtime *wails.Runtime) error {
+
+	maxAttempts := 3
+	runtime.Events.OnMultiple("unlock attempts", func(optionalData ...interface{}) {
+		// Do something (at most) maxAttempts times
+	}, maxAttempts)
+
+	m.runtime = runtime
+	return nil
+}
diff --git a/v2/test/kitchensink/frontend/src/pages/events/OnMultiple/code.jsx b/v2/test/kitchensink/frontend/src/pages/events/OnMultiple/code.jsx
new file mode 100644
index 000000000..9bc9ae422
--- /dev/null
+++ b/v2/test/kitchensink/frontend/src/pages/events/OnMultiple/code.jsx
@@ -0,0 +1,8 @@
+import { Events } from '@wails/runtime';
+
+let notes = [];
+
+// Do some things
+Events.On("notes loaded", (newNotes) => {
+  notes = newNotes;
+});
diff --git a/v2/test/kitchensink/frontend/src/pages/events/OnMultiple/description.txt b/v2/test/kitchensink/frontend/src/pages/events/OnMultiple/description.txt
new file mode 100644
index 000000000..4a8d3fae2
--- /dev/null
+++ b/v2/test/kitchensink/frontend/src/pages/events/OnMultiple/description.txt
@@ -0,0 +1,3 @@
+<code>Events.OnMultiple()</code> is used to subscribe to events. It takes a number which is the 
+total number of times that the callback will be fired when an event matching the given event 
+name is received.
diff --git a/v2/test/kitchensink/frontend/src/pages/events/Once/code.go b/v2/test/kitchensink/frontend/src/pages/events/Once/code.go
index d712ab702..d4972985a 100644
--- a/v2/test/kitchensink/frontend/src/pages/events/Once/code.go
+++ b/v2/test/kitchensink/frontend/src/pages/events/Once/code.go
@@ -8,10 +8,8 @@ type MyStruct struct {
 
 func (m *MyStruct) WailsInit(runtime *wails.Runtime) error {
 
-	runtime.Events.On("notes updated", func(optionalData ...interface{}) {
-		// Get notes
-		notes := optionalData[0].(*Notes)
-		// Save the notes to disk
+	runtime.Events.Once("initialised", func(optionalData ...interface{}) {
+		// Do something once
 	})
 
 	m.runtime = runtime
diff --git a/v2/test/kitchensink/frontend/src/pages/events/Once/code.jsx b/v2/test/kitchensink/frontend/src/pages/events/Once/code.jsx
index 9bc9ae422..579e0731d 100644
--- a/v2/test/kitchensink/frontend/src/pages/events/Once/code.jsx
+++ b/v2/test/kitchensink/frontend/src/pages/events/Once/code.jsx
@@ -1,8 +1,5 @@
 import { Events } from '@wails/runtime';
 
-let notes = [];
-
-// Do some things
-Events.On("notes loaded", (newNotes) => {
-  notes = newNotes;
+Events.Once("initialised", () => {
+  // Do something once  
 });