+ Now go check out the click tracking in your app's Begin Data console → +
+
+
+[](https://begin.com)
+
+Example app demonstrating publishing and subscribing to an event function.
+
+## Deploy your own
+
+[](https://begin.com/apps/create?template=https://github.com/begin-examples/node-events)
+
+Deploy your own clone of this app to Begin!
+
+## Getting started
+
+- Start the local dev server: `npm start`
+- Lint your code: `npm run lint` (after you've installed a linter, of course)
+- Run your tests: `npm t` (don't forget to write some!)
+
+## Reference
+
+- [Event Functions tutorial](https://docs.begin.com/en/guides/events/) - basics on working with Event functions.
+- [Events reference documentation](https://docs.begin.com/en/event-functions/provisioning) - basics on expanding the capabilities of your app
+
+Head to [docs.begin.com](https://docs.begin.com/) to learn more!
\ No newline at end of file
diff --git a/src/events/my-event/.arc-config b/src/events/my-event/.arc-config
new file mode 100644
index 0000000..2091b85
--- /dev/null
+++ b/src/events/my-event/.arc-config
@@ -0,0 +1,5 @@
+@aws
+runtime nodejs12.x
+# memory 1152
+# timeout 30
+# concurrency 1
diff --git a/src/events/my-event/index.js b/src/events/my-event/index.js
new file mode 100644
index 0000000..1715656
--- /dev/null
+++ b/src/events/my-event/index.js
@@ -0,0 +1,17 @@
+const arc = require('@architect/functions')
+const data = require('@begin/data')
+const table = 'interactions'
+const key = 'clicks'
+
+async function myEvent(event) {
+ let { name } = event
+ await data.incr({
+ table,
+ key,
+ prop: name
+ })
+
+ return
+}
+
+exports.handler = arc.events.subscribe(myEvent)
diff --git a/src/http/post-my_event/.arc-config b/src/http/post-my_event/.arc-config
new file mode 100644
index 0000000..2091b85
--- /dev/null
+++ b/src/http/post-my_event/.arc-config
@@ -0,0 +1,5 @@
+@aws
+runtime nodejs12.x
+# memory 1152
+# timeout 30
+# concurrency 1
diff --git a/src/http/post-my_event/index.js b/src/http/post-my_event/index.js
new file mode 100644
index 0000000..f4c3353
--- /dev/null
+++ b/src/http/post-my_event/index.js
@@ -0,0 +1,13 @@
+const arc = require('@architect/functions')
+
+exports.handler = async function http (req) {
+ const name = 'my-event'
+ const payload = arc.http.helpers.bodyParser(req)
+ await arc.events.publish({ name, payload })
+ return {
+ statusCode: 302,
+ headers: {
+ location: '/'
+ }
+ }
+}
diff --git a/test/example/00-web-integration-example-test.js b/test/example/00-web-integration-example-test.js
new file mode 100644
index 0000000..0a6b594
--- /dev/null
+++ b/test/example/00-web-integration-example-test.js
@@ -0,0 +1,58 @@
+let test = require('tape')
+let tiny = require('tiny-json-http')
+let sandbox = require('@architect/sandbox')
+let url = 'http://localhost:3333'
+
+/**
+ * Sandbox / http test
+ * - Demonstrates execising basic web integration tests using the local dev server
+ */
+test('Set up env', t => {
+ t.plan(1)
+ t.ok(sandbox, 'sandbox loaded')
+})
+
+test('Start sandbox', async t => {
+ t.plan(1)
+ let result = await sandbox.start()
+ t.ok(result, 'Sandbox started!')
+})
+
+test('get / (continuation-passing style)', t => {
+ t.plan(1)
+ tiny.get({ url },
+ function win(err, result) {
+ if (err) {
+ t.fail(err)
+ } else {
+ t.ok(result, `Got result ${result.body.toString().substring(0, 50)}...`)
+ }
+ })
+})
+
+test('get / (promise style)', t => {
+ t.plan(1)
+ tiny.get({ url })
+ .then(function win(result) {
+ t.ok(result, `Got result ${result.body.toString().substring(0, 50)}...`)
+ })
+ .catch(function fail(err) {
+ t.fail(err)
+ })
+})
+
+test('get / (async/await style)', async t => {
+ t.plan(1)
+ try {
+ let result = await tiny.get({ url })
+ t.ok(result, `Got result ${result.body.toString().substring(0, 50)}...`)
+ } catch (err) {
+ t.fail(err)
+ }
+})
+
+test('Shut down sandbox', async t => {
+ t.plan(1)
+ let result = await sandbox.end()
+ t.equal(result, 'Sandbox successfully shut down')
+})
diff --git a/test/example/01-begin-data-example-test.js b/test/example/01-begin-data-example-test.js
new file mode 100644
index 0000000..0eb2bf3
--- /dev/null
+++ b/test/example/01-begin-data-example-test.js
@@ -0,0 +1,125 @@
+let test = require('tape')
+let data = require('@begin/data')
+let sandbox = require('@architect/sandbox')
+let logJSON = i => console.log(JSON.stringify(i,null,2))
+
+/**
+ * Begin Data test
+ * - Demonstrates basic usage of Begin Data, a fast, free, durable, wide-column persistence store already built into your app
+ */
+test('Set up env', t => {
+ t.plan(4)
+ t.ok(data, 'Begin Data loaded')
+ t.ok(data.get, 'data.get ready')
+ t.ok(data.set, 'data.set ready')
+ t.ok(data.destroy, 'data.destroy ready')
+})
+
+test('Start sandbox', async t=> {
+ t.plan(1)
+ let result = await sandbox.start()
+ t.ok(result, 'Sandbox started!')
+})
+
+test('data.set (one document)', async t => {
+ t.plan(1)
+ let result = await data.set({
+ table: 'tasks',
+ key: 'task1'
+ })
+ t.ok(result.key === 'task1', 'Wrote document')
+ logJSON(result)
+})
+
+test('data.get (one document)', async t => {
+ t.plan(1)
+ let task = await data.get({
+ table: 'tasks',
+ key: 'task1'
+ })
+ t.ok(task.key === 'task1', 'Read document')
+ logJSON(task)
+})
+
+test('data.destroy (one document)', async t => {
+ t.plan(1)
+ let result = await data.destroy({
+ table: 'tasks',
+ key: 'task1'
+ })
+ t.ok(result, 'Deleted document')
+ logJSON(result)
+})
+
+/**
+ * If no key is supplied, one is created automatically
+ */
+test('data.set generates a unique key', async t => {
+ t.plan(1)
+ let result = await data.set({
+ table: 'tasks'
+ })
+ t.ok(result.key, 'Saved document has a key')
+ logJSON(result)
+})
+
+/**
+ * Any (meta)data is allowed
+ */
+test('data.set allows for any JSON document; only table and key are reserved', async t => {
+ t.plan(1)
+ let result = await data.set({
+ table: 'tasks',
+ message: 'hello world',
+ complete: false,
+ timeframe: new Date(Date.now()).toISOString()
+ })
+ t.ok(Object.getOwnPropertyNames(result.key).length > 2, 'Saved document has multiple properties')
+ logJSON(result)
+})
+
+/**
+ * Save a batch of documents by passing an array
+ */
+test('data.set accepts an array to batch save documents', async t => {
+ t.plan(1)
+ let result = await data.set([{
+ table: 'tasks',
+ message: 'catch sunshine every day',
+ complete: true,
+ timeframe: new Date(Date.now()).toISOString()
+ },
+ {
+ table: 'tasks',
+ message: 'leave the phone at home on accident purpose',
+ complete: false,
+ timeframe: new Date(Date.now()).toISOString()
+ },
+ {
+ table: 'tasks',
+ message: 'walk the seawall',
+ complete: false,
+ timeframe: new Date(Date.now()).toISOString()
+
+ }])
+ t.equal(result.length, 3, 'Saved document batch')
+ logJSON(result)
+})
+
+/**
+ * Scan a table
+ */
+test('data.get can read an entire table', async t => {
+ t.plan(1)
+ let result = await data.get({
+ table: 'tasks'
+ })
+ t.ok(result.length > 1, 'Got docs')
+ logJSON(result)
+})
+
+test('Shut down sandbox', async t => {
+ t.plan(1)
+ let result = await sandbox.end()
+ t.equal(result, 'Sandbox successfully shut down')
+})