from generation.isPipeMany import *

def pipeBusSource(name, entity, busKey, structure, fmt):
    valueType = structure.model.fields[name][0]
    print(f"pipeBS-1 name: '{name}'")
    if isPipeMany(name, entity):
      itemType = structure.model.fields[key][0]
      valueType = f"MPAK.Many<{itemType}>"
      print(f"pipeBS-2 name: '{name}'")

    return fmt \
        .replace("%BUS_KEY%", busKey) \
        .replace("%BUS_VALUE_TYPE%", valueType)