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):
      valueType = f"MPAK.Many<{valueType}>"

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