af83/edwig

package api

import (
    "fmt"

    "bitbucket.org/enroute-mobi/ara/audit"
    "bitbucket.org/enroute-mobi/ara/clock"
    "bitbucket.org/enroute-mobi/ara/core"
    "bitbucket.org/enroute-mobi/ara/logger"
    "bitbucket.org/enroute-mobi/ara/remote"
    "bitbucket.org/enroute-mobi/ara/siri/sxml"
)

type SIRILinesDiscoveryRequestHandler struct {
    xmlRequest  *sxml.XMLLinesDiscoveryRequest
    referential *core.Referential
}

func (handler *SIRILinesDiscoveryRequestHandler) RequestorRef() string {
    return handler.xmlRequest.RequestorRef()
}

func (handler *SIRILinesDiscoveryRequestHandler) ConnectorType() string {
    return core.SIRI_LINES_DISCOVERY_REQUEST_BROADCASTER
}

func (handler *SIRILinesDiscoveryRequestHandler) Respond(params HandlerParams) {
    logger.Log.Debugf("LinesDiscovery %s\n", handler.xmlRequest.MessageIdentifier())

    t := clock.DefaultClock().Now()

    response, _ := params.connector.(core.LinesDiscoveryRequestBroadcaster).Lines(handler.xmlRequest, params.message)
    xmlResponse, err := response.BuildXML(params.envelopeType)
    if err != nil {
        SIRIError{
            errCode:         "InternalServiceError",
            errDescription:  fmt.Sprintf("Internal Error: %v", err),
            referentialSlug: string(handler.referential.Slug()),
            envelopeType:    params.envelopeType,
            response:        params.rw,
        }.Send()
        return
    }

    // Wrap soap and send response
    buffer := remote.NewSIRIBuffer(params.envelopeType)
    buffer.WriteXML(xmlResponse)

    n, err := buffer.WriteTo(params.rw)
    if err != nil {
        SIRIError{
            errCode:         "InternalServiceError",
            errDescription:  fmt.Sprintf("Internal Error: %v", err),
            referentialSlug: string(handler.referential.Slug()),
            envelopeType:    params.envelopeType,
            response:        params.rw,
        }.Send()
        return
    }

    params.message.Type = audit.LINES_DISCOVERY_REQUEST
    params.message.RequestRawMessage = handler.xmlRequest.RawXML()
    params.message.ResponseRawMessage = xmlResponse
    params.message.ResponseSize = n
    params.message.ProcessingTime = clock.DefaultClock().Since(t).Seconds()
    audit.CurrentBigQuery(string(handler.referential.Slug())).WriteEvent(params.message)
}