From c843d1bd22d5cee0702ce6e70594e7fb251a6b04 Mon Sep 17 00:00:00 2001
From: Razvan <tangent.jotey@gmail.com>
Date: Wed, 31 Jan 2024 08:29:05 +0100
Subject: [PATCH] chore(api): making configuration parameter optional for
 `source()`

---
 package.json                  | 2 +-
 src/components/example.svelte | 2 +-
 src/lib/source.js             | 7 +++++--
 src/routes/events/+server.js  | 1 -
 4 files changed, 7 insertions(+), 5 deletions(-)

diff --git a/package.json b/package.json
index 278a678..914d855 100644
--- a/package.json
+++ b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "sveltekit-sse",
-  "version": "0.8.0",
+  "version": "0.8.1",
   "scripts": {
     "dev": "vite dev",
     "build": "vite build && npm run package",
diff --git a/src/components/example.svelte b/src/components/example.svelte
index 68af021..e0ed95a 100644
--- a/src/components/example.svelte
+++ b/src/components/example.svelte
@@ -1,6 +1,6 @@
 <script>
   import { source } from '$lib/source.js'
-  const connection = source('/events', { beacon: 1000 })
+  const connection = source('/events')
   const channel = connection.select('cat-quote')
   /**
    * @type {import('svelte/store').Readable<null|import('../routes/events/+server').Quote>}
diff --git a/src/lib/source.js b/src/lib/source.js
index f9410df..9a6083a 100644
--- a/src/lib/source.js
+++ b/src/lib/source.js
@@ -295,10 +295,13 @@ function defaultJsonOrPredicate({ error, previous }) {
  * > })
  * > ```
  * @param {string} from Path to the stream.
- * @param {SourceConfiguration} configuration
+ * @param {SourceConfiguration} [configuration]
  * @returns
  */
-export function source(from, { close, error, beacon = 5000, options = {} }) {
+export function source(
+  from,
+  { close, error, beacon = 5000, options = {} } = {},
+) {
   /** @type {SourceState} */
   let state = {
     eventsCounter: 0,
diff --git a/src/routes/events/+server.js b/src/routes/events/+server.js
index e662f98..1674f6d 100644
--- a/src/routes/events/+server.js
+++ b/src/routes/events/+server.js
@@ -59,7 +59,6 @@ async function dumpData({ emit, lock }) {
 export function POST({ request }) {
   return events({
     request,
-    timeout: 3000,
     start(connection) {
       dumpData(connection)
     },