feat(core): activate diff in log.md

packages/core/src/actions/log/md.coffee.md

@@ -49,6 +49,8 @@ nikita(async function(){
  handler = ({config}) ->
  state = {}
  await @call $: log_fs, config, serializer:
+ 'diff': (log) ->
+ "\n```diff\n#{log.message}```\n" if log.message
  'nikita:action:start': ({action}) ->
  act = action.parent
  bastard = undefined
@@ -58,7 +60,17 @@ nikita(async function(){
  act = act.parent
  content = []
  if config.enter and action.metadata.module and action.metadata.log isnt false and bastard isnt true
- content.push "\nEntering #{action.metadata.module} (#{(action.metadata.position.map (index) -> index + 1).join '.'})\n"
+ content.push [
+ '\n'
+ 'Entering'
+ ' '
+ "#{action.metadata.module}"
+ ' '
+ '('
+ "#{(action.metadata.position.map (index) -> index + 1).join '.'}"
+ ')'
+ '\n'
+ ].join ''
  return content.join '' unless action.metadata.header
  walk = (parent) ->
  precious = parent.metadata.header

packages/core/src/actions/log/stream.coffee.md

@@ -41,6 +41,10 @@ Write log to custom destinations in a user provided format.
  # Events
  close = ->
  config.stream.close() if config.end
+ events.on 'diff', (log) ->
+ return unless config.serializer.diff
+ data = config.serializer.diff log
+ config.stream.write data if data?
  events.on 'nikita:action:start', ->
  return unless config.serializer['nikita:action:start']
  data = await config.serializer['nikita:action:start'].apply null, arguments
@@ -62,15 +66,11 @@ Write log to custom destinations in a user provided format.
  data = config.serializer.stdout_stream log
  config.stream.write data if data?
  events.on 'nikita:resolved', ({action}) ->
- # console.log 'nikita:resolved', position, uuid, action.metadata.position, !!action.parent
- # return unless position.slice(0, -1).join('.') is action.metadata.position.join('.')
  if config.serializer['nikita:resolved']
  data = config.serializer['nikita:resolved'].apply null, arguments
  config.stream.write data if data?
  close()
  events.on 'nikita:rejected', ({action}) ->
- # console.log 'nikita:rejected', position, uuid, action.metadata, !!action.parent
- # return unless position.slice(0, -1).join('.') is action.metadata.position.join('.')
  if config.serializer['nikita:rejected']
  data = config.serializer['nikita:rejected'].apply null, arguments
  config.stream.write data if data?

packages/core/test/actions/log/md.coffee

@@ -61,9 +61,7 @@ describe 'actions.log.md', ->
  log message: 'ok 1'
  await @call ->
  new Promise (resolve) ->
- setTimeout ->
- resolve()
- , 500
+ setTimeout resolve 200
  @call $header: 'h2', ({tools: {log}}) ->
  log message: 'ok 2'
  @fs.assert
@@ -164,6 +162,23 @@ describe 'actions.log.md', ->
  ```
  """
 
+ describe 'event `diff`', ->
+
+ they 'write message in code block', ({ssh}) ->
+ nikita
+ $ssh: ssh
+ $tmpdir: true
+ , ({metadata: {tmpdir}}) ->
+ await @log.md basedir: tmpdir, enter: false
+ await @call ({tools: {log}}) ->
+ log message: '1 + new line', type: 'diff'
+ @fs.base.readFile
+ target: "#{tmpdir}/localhost.log"
+ encoding: 'ascii'
+ .should.be.resolvedWith
+ data: '\n```diff\n1 + new line```\n'
+
+
  describe 'config `enter`', ->
 
  they 'disabled when false', ({ssh}) ->

packages/file/test/diff.coffee → packages/file/test/index.diff.coffee

@@ -93,3 +93,25 @@ describe 'file config diff', ->
  content: 'some content'
  diff: (text, raw) -> diff = text
  diff.should.eql '1 + some content\n'
+
+ they 'honored by `log.md` action', ({ssh}) ->
+ nikita
+ $ssh: ssh
+ $tmpdir: true
+ , ({metadata: {tmpdir}}) ->
+ await @log.md
+ basedir: tmpdir
+ filename: 'nikita.log'
+ await @file
+ target: "#{tmpdir}/file"
+ content: 'some content'
+ diff: (text, raw) -> diff = text
+ {data} = await @fs.base.readFile
+ $log: false
+ target: "#{tmpdir}/nikita.log"
+ encoding: 'ascii'
+ data.should.containEql '''
+ ```diff
+ 1 + some content
+ ```
+ '''