fix(scheduler-utils): fix accidental change in scheduler utils

permaweb · Feb 9, 2024 · 9118b1d · 9118b1d
1 parent b12602d
commit 9118b1d
Show file tree

Hide file tree

Showing 2 changed files with 20 additions and 6 deletions.
diff --git a/scheduler-utils/src/client/in-memory.js b/scheduler-utils/src/client/in-memory.js
@@ -29,15 +29,29 @@ export function createLruCache ({ size }) {
 }
 
 export function getByProcessWith ({ cache = internalCache }) {
-  return async (processId) => {
+  return async (process) => {
     if (!internalSize) return
-    return cache.get(processId)
+    return cache.get(process)
   }
 }
 
 export function setByProcessWith ({ cache = internalCache }) {
-  return async (processId, processData) => {
+  return async (process, { url, address }, ttl) => {
     if (!internalSize) return
-    return cache.set(processId, processData)
+    return cache.set(process, { url, address }, { ttl })
+  }
+}
+
+export function getByOwnerWith ({ cache = internalCache }) {
+  return async (owner) => {
+    if (!internalSize) return
+    return cache.get(owner)
+  }
+}
+
+export function setByOwnerWith ({ cache = internalCache }) {
+  return async (owner, url, ttl) => {
+    if (!internalSize) return
+    return cache.set(owner, { url, address: owner }, { ttl })
   }
 }
diff --git a/servers/mu/src/domain/clients/in-memory.js b/servers/mu/src/domain/clients/in-memory.js
@@ -36,8 +36,8 @@ export function getByProcessWith ({ cache = internalCache }) {
 }
 
 export function setByProcessWith ({ cache = internalCache }) {
-  return async (processId, processData, ttl) => {
+  return async (processId, processData) => {
     if (!internalSize) return
-    return cache.set(processId, processData, { ttl })
+    return cache.set(processId, processData)
   }
 }