af83/edwig

Similar blocks of code found in 18 locations. Consider refactoring.

Open

func (request *XMLGeneralMessageRequest) RouteRef() []string {
    if len(request.routeRef) == 0 {
        nodes := request.findNodes("RouteRef")
        for _, routeRef := range nodes {
            request.routeRef = append(request.routeRef, strings.TrimSpace(routeRef.NativeNode().Content()))

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    for _, partner := range manager.byId {
        dbPartner, err := manager.newDbPartner(partner)
        if err != nil {
            tx.Rollback()
            return http.StatusInternalServerError, fmt.Errorf("internal error: %v", err)

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (line *Line) DiscoveryCode(codeSpace string) (Code, bool) {
    ref, ok := line.Referent()
    if ok {
        _, ok := ref.Code(codeSpace)
        if ok {

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    for _, referential := range manager.byId {
        dbReferential, err := manager.newDbReferential(referential)
        if err != nil {
            tx.Rollback()
            return http.StatusInternalServerError, fmt.Errorf("internal error: %v", err)

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (stopArea *StopArea) SPDCode(codeSpace string) (Code, bool) {
    ref, ok := stopArea.Referent()
    if ok {
        _, ok := ref.Code(codeSpace)
        if ok {

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

func (connector *SIRILiteVehicleMonitoringRequestBroadcaster) handleRef(refType, origin string, references model.References) string {
    reference, ok := references.Get(refType)
    if !ok || reference.Code == nil || (refType == "DestinationRef" && connector.noDestinationRefRewritingFrom(origin)) {
        return ""
    }

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

func (connector *SIRIVehicleMonitoringRequestBroadcaster) handleRef(refType, origin string, references model.References) string {
    reference, ok := references.Get(refType)
    if !ok || reference.Code == nil || (refType == "DestinationRef" && connector.noDestinationRefRewritingFrom(origin)) {
        return ""
    }

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

func (connector *SIRIVehicleMonitoringSubscriptionBroadcaster) handleRef(refType, origin string, references model.References) string {
    reference, ok := references.Get(refType)
    if !ok || reference.Code == nil || (refType == "DestinationRef" && connector.noDestinationRefRewritingFrom(origin)) {
        return ""
    }

• Read up
  Read up

Method MemoryStopAreas.Load has 6 return statements (exceeds 4 allowed).

Open

func (manager *MemoryStopAreas) Load(referentialSlug string) error {
    var selectStopAreas []SelectStopArea
    modelName := manager.model.Date()

    sqlQuery := fmt.Sprintf("select * from stop_areas where referential_slug = '%s' and model_name = '%s'", referentialSlug, modelName.String())

Method BroadcastStopMonitoringBuilder.BuildMonitoredStopVisit has 6 return statements (exceeds 4 allowed).

Open

func (builder *BroadcastStopMonitoringBuilder) BuildMonitoredStopVisit(stopVisit *model.StopVisit) *siri.SIRIMonitoredStopVisit {
    stopPointRef, stopPointRefCode, ok := builder.stopPointRef(stopVisit.StopAreaId)
    if !ok {
        logger.Log.Printf("Ignore StopVisit %v without StopArea or with StopArea without correct Code", stopVisit.Id())
        return nil

Method Controller.serve has 6 return statements (exceeds 4 allowed).

Open

func (controller *Controller) serve(response http.ResponseWriter, request *http.Request, requestData *RequestData) {
    // Check request body
    if requestData.Method == "PUT" || (requestData.Method == "POST" && requestData.Id != "save" && requestData.Action != "reload") {
        requestData.Body = getRequestBody(response, request)
        if requestData.Body == nil {

Method BroadcastGeneralMessageBuilder.BuildGeneralMessage has 6 return statements (exceeds 4 allowed).

Open

func (builder *BroadcastGeneralMessageBuilder) BuildGeneralMessage(situation model.Situation) *siri.SIRIGeneralMessage {
    if !builder.canBroadcast(situation) {
        return nil
    }

Method VehicleMonitoringUpdateEventBuilder.handleCoordinates has 6 return statements (exceeds 4 allowed).

Open

func (builder *VehicleMonitoringUpdateEventBuilder) handleCoordinates(xmlVehicleActivity *sxml.XMLVehicleActivity) (lon, lat float64, e error) {
    longitude, _ := strconv.ParseFloat(xmlVehicleActivity.Longitude(), 64)
    latitude, _ := strconv.ParseFloat(xmlVehicleActivity.Latitude(), 64)

    if latitude != 0 || longitude != 0 {

Method BroadcastStopMonitoringBuilder.BuildCancelledStopVisit has 6 return statements (exceeds 4 allowed).

Open

func (builder *BroadcastStopMonitoringBuilder) BuildCancelledStopVisit(stopVisit *model.StopVisit) *siri.SIRICancelledStopVisit {
    vehicleJourney, ok := builder.partner.Model().VehicleJourneys().Find(stopVisit.VehicleJourneyId)
    if !ok {
        logger.Log.Printf("Ignore CancelledStopVisit %s without Vehiclejourney", stopVisit.Id())
        return nil

Method MemoryStopVisits.Load has 6 return statements (exceeds 4 allowed).

Open

func (manager *MemoryStopVisits) Load(referentialSlug string) error {
    var selectStopVisits []SelectStopVisit
    modelName := manager.model.Date()

    sqlQuery := fmt.Sprintf("select * from stop_visits where referential_slug = '%s' and model_name = '%s'", referentialSlug, modelName.String())

Method EstimatedTimetableLastChange.Haschanged has 6 return statements (exceeds 4 allowed).

Open

func (ettlc *EstimatedTimetableLastChange) Haschanged(stopVisit *model.StopVisit) bool {
    // Don't send info on cancelled or departed SV
    if ettlc.departureStatus == model.STOP_VISIT_DEPARTURE_DEPARTED || ettlc.departureStatus == model.STOP_VISIT_DEPARTURE_CANCELLED || ettlc.arrivalStatuts == model.STOP_VISIT_ARRIVAL_ARRIVED || ettlc.arrivalStatuts == model.STOP_VISIT_ARRIVAL_CANCELLED {
        return false
    }

Method VehicleMonitoringLastChange.HasChanged has 6 return statements (exceeds 4 allowed).

Open

func (vmlc *VehicleMonitoringLastChange) HasChanged(v *model.Vehicle) bool {
    // Check LinkDistance
    if vmlc.LinkDistance != v.LinkDistance {
        return true
    }

Method GtfsHandler.serve has 6 return statements (exceeds 4 allowed).

Open

func (handler *GtfsHandler) serve(response http.ResponseWriter, request *http.Request, resource string) {
    // Find Partner by authorization Key
    partner, ok := handler.referential.Partners().FindByCredential(handler.token)
    if !ok {
        http.Error(response, "Invalid Authorization Token", http.StatusUnauthorized)

Method SIRIEstimatedTimetableSubscriptionBroadcaster.stopPointRef has 6 return statements (exceeds 4 allowed).

Open

func (connector *SIRIEstimatedTimetableSubscriptionBroadcaster) stopPointRef(stopAreaId model.StopAreaId) (*model.StopArea, string, bool) {
    stopPointRef, ok := connector.Partner().Model().StopAreas().Find(stopAreaId)
    if !ok {
        return &model.StopArea{}, "", false
    }

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (s *PartnerSettings) VehicleJourneyRemoteCodeSpaceWithFallback(connectorName string) []string {
    value, ok := s.vehicleJourneyRemoteCodeSpacesByConnector.Load(connectorName)
    if ok {
        return value.([]string)
    }

• Read up
  Read up