<commit_before>jraphical = require 'jraphical'

JTag   = require './tag'
amqp   = require 'amqp'
{argv} = require 'optimist'

KONFIG = require('koding-config-manager').load("main.#{argv.c}")

USER_EXCHANGE_OPTIONS =
  type       : 'fanout'
  autoDelete : no
  durable    : yes

tagModifierMQ = amqp.createConnection KONFIG.mq

tagModifierMQ.on 'ready', ->

  emitter = (tag, status) ->
    tagModifierMQ.exchange 'topicModifierExchange', USER_EXCHANGE_OPTIONS, (exchange) ->
      {tagId} = tag
      exchange.publish 'modifyTag', {tagId, status}
      exchange.close()

  JTag.on 'TagIsDeleted', (tag) ->
    emitter tag, 'delete'

  JTag.on 'TagIsSynonym', (tag) ->
    emitter tag, 'merge'
<commit_msg>Moderation: instead of tagId, tag is appended to tag events<commit_after>jraphical = require 'jraphical'

JTag   = require './tag'
amqp   = require 'amqp'
{argv} = require 'optimist'

KONFIG = require('koding-config-manager').load("main.#{argv.c}")

USER_EXCHANGE_OPTIONS =
  type       : 'fanout'
  autoDelete : no
  durable    : yes

tagModifierMQ = amqp.createConnection KONFIG.mq

tagModifierMQ.on 'ready', ->

  emitter = (tag, status) ->
    tagModifierMQ.exchange 'topicModifierExchange', USER_EXCHANGE_OPTIONS, (exchange) ->
      tagId = tag.getId()
      exchange.publish 'modifyTag', {tagId, status}
      exchange.close()

  JTag.on 'TagIsDeleted', (tag) ->
    emitter tag, 'delete'

  JTag.on 'TagIsSynonym', (tag) ->
    emitter tag, 'merge'

{'fraction_non_alphanumeric': 0.140218878248974, 'fraction_numerical': 0.0, 'mean_word_length': 3.6444444444444444, 'pattern_counts': {'":': 0, '<': 3, '<?xml version=': 0, '>': 13, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '5898049', 'n_tokens_mistral': 529, 'n_tokens_neox': 521, 'n_words': 113}