Merge pull request #1 from hyper63/feat/optional-creds

feat: make credentials optional

.github/workflows/test.yml

@@ -2,7 +2,7 @@ name: Test
 
 on:
   push:
-    branches: '*'
+    branches: '**'
     tags-ignore: '*'
 
 jobs:

async-fetch.js

@@ -1,17 +1,25 @@
 import { base64Encode, crocks, R } from "./deps.js";
 
 const { Async } = crocks;
-const { ifElse } = R;
+const { ifElse, assoc, pipe, identity } = R;
 
 // TODO: Tyler. wrap with opionated approach like before with https://github.com/vercel/fetch
 const asyncFetch = (fetch) => Async.fromPromise(fetch);
 
-const createHeaders = (username, password) => ({
-  "Content-Type": "application/json",
-  authorization: `Basic ${
-    base64Encode(new TextEncoder().encode(username + ":" + password))
-  }`,
-});
+const createHeaders = (username, password) =>
+  pipe(
+    assoc("Content-Type", "application/json"),
+    ifElse(
+      () => username && password,
+      assoc(
+        "authorization",
+        `Basic ${
+          base64Encode(new TextEncoder().encode(username + ":" + password))
+        }`,
+      ),
+      identity,
+    ),
+  )({});
 
 const handleResponse = (pred) =>
   ifElse(

mod.js

@@ -3,15 +3,15 @@ import { R } from "./deps.js";
 import { asyncFetch, createHeaders, handleResponse } from "./async-fetch.js";
 import adapter from "./adapter.js";
 
-const { mergeDeepRight, defaultTo, pipe } = R;
+const { mergeDeepLeft, defaultTo, pipe } = R;
 
 export default function ElasticsearchAdapter(config) {
   return Object.freeze({
     id: "elasticsearch",
     port: "search",
     load: pipe(
       defaultTo({}),
-      mergeDeepRight(config),
+      mergeDeepLeft(config), // perfer config over what's passed from previous load
     ),
     link: (env) =>
       () => {