in internal/dal/catalog.go [149:161]
func (c *catalogDALImpl) buildEventCatalog(serviceName string, channel asyncapi.Channel,
operation asyncapi.Operation) *model.EventCatalog {
var record model.EventCatalog
record.ServiceName = serviceName
record.OperationID = fmt.Sprintf("file://%s.yaml#%s", serviceName, operation.ID())
record.ChannelName = channel.ID()
record.Type = string(operation.Type())
record.Status = constants.NormalStatus
record.CreateTime = time.Now()
record.UpdateTime = time.Now()
record.Schema = gconv.String(operation.Messages()[0].Payload())
return &record
}