Effect CommunityEC
Effect Community•12mo ago•
7 replies
Kris

Providing a custom logging service to each map execution from within an effect

I understand how to provide services at the top level of an execution, but I'm not sure how to provide services from within an execution.

For example, a logging service that appends an ID to each log for every mapped operation of an array (to that function, and any calls that it makes).

const main = async (events: Events[]) => {
  const Services = Layer.mergeAll(...services)
  await Effect.runPromise(Effect.provide(generatorMain(events), Services))
}

export const generatorMain = (events: Events[]) =>
  Effect.gen(function* () {
    yield* Effect.all(events.map(processRecord), { mode: 'either' })
  })

// inject a custon logger here, and to any function calls below
export const processRecord = (record: SQSRecord) =>
  Effect.gen(function* () {
    // this is where i'm lost
    const logger = LoggerServiceFactory(record.id) 
    logger.log('Processing record', record)
    // [record.id] Processing record { }
  })


Should I restructure the main function so that each event runs as its own effect with its own services?

In short, each concurrent execution needs its own instance of LoggerService, with its own ID.
Was this page helpful?