Merge pull request #1018 from permaweb/jfrain99/remove-logs

chore(mu): removed old logs
permaweb · Sep 20, 2024 · 9ed6347 · 9ed6347
2 parents 75d0388 + cb58bb4
commit 9ed6347
Show file tree

Hide file tree

Showing 5 changed files with 2 additions and 6 deletions.
diff --git a/servers/mu/src/domain/api/processSpawn.js b/servers/mu/src/domain/api/processSpawn.js
@@ -38,7 +38,6 @@ export function processSpawnWith ({
  *
  * See: https://github.com/permaweb/ao/issues/730
  */
- console.log({ res })
  return pullResult({
  processId: res.processTx,
  messageId: res.processTx,
@@ -77,7 +76,6 @@ export function processSpawnWith ({
  .map(setStage('pull-result', 'end'))
  .bimap(
  (e) => {
- console.log(500)
  return new Error(e, { cause: e.cause })
  },
  logger.tap({ log: 'Successfully processed spawn', end: true })

diff --git a/servers/mu/src/domain/api/processSpawn.test.js b/servers/mu/src/domain/api/processSpawn.test.js
@@ -16,7 +16,6 @@ describe('processSpawnWith', () => {
  locateProcess: async () => ({ id: 'process-id', url: 'url-123' }),
  locateNoRedirect: async () => false,
  writeDataItem: async (item) => {
- console.log(501, { item })
  return { ...item, id: 'id-123', timestamp: '1234567' }
  },
  buildAndSign: async (tx) => ({ ...tx, signed: true, data: 'data', id: 'id-123' }),

diff --git a/servers/mu/src/domain/clients/worker.js b/servers/mu/src/domain/clients/worker.js
@@ -4,12 +4,12 @@ import { tap } from 'ramda'
 import cron from 'node-cron'
 
 import { createTaskQueue, enqueueWith, dequeueWith, removeDequeuedTasksWith } from './taskQueue.js'
-import { deleteOldTracesWith } from './cron.js'
 import { domainConfigSchema, config } from '../../config.js'
 // Without this import the worker crashes
 import { createResultApis } from '../../domain/index.js'
 import { createSqliteClient } from './sqlite.js'
 import { broadcastEnqueueWith, enqueueResultsWith, processResultWith, processResultsWith } from './worker-fn.js'
+import { deleteOldTracesWith } from './tracer.js'
 
 const broadcastChannel = new BroadcastChannel('mu-worker')
 

diff --git a/servers/mu/src/domain/dal.js b/servers/mu/src/domain/dal.js
@@ -174,7 +174,7 @@ export const fetchSchedulerProcessSchema = z.function()
  owner: processOwnerSchema,
  tags: tagArraySchema,
  timestamp: z.coerce.number(),
- data: z.string(),
+ data: z.string().nullish(),
  anchor: z.string().nullish(),
  epoch: z.coerce.number().nullish(),
  nonce: z.coerce.number().nullish(),

diff --git a/servers/mu/src/domain/lib/pull-result.js b/servers/mu/src/domain/lib/pull-result.js
@@ -62,7 +62,6 @@ export function pullResultWith (env) {
  const fetchResult = fetchResultWith(env)
 
  return (ctx) => {
- console.log(600, { ctx })
  if (!checkStage('pull-result')(ctx) && !checkStage('pull-initial-result')(ctx)) return Resolved(ctx)
  return of(ctx)
  .map((ctx) => ({ ...ctx, tx: ctx.tx }))