/**
 * Copyright 2015 Google Inc. All Rights Reserved.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

/**
 * This file has been modified by Keymetrics
 */

'use strict';

var shimmer = require('shimmer');

var SUPPORTED_VERSIONS = '<=4.x';

function unpatchRestify(restify) {
  shimmer.unwrap(restify, 'createServer');
}

function patchRestify(restify, api) {
  shimmer.wrap(restify, 'createServer', createServerWrap);

  function createServerWrap(createServer) {
    return function createServerTrace() {
      var server = createServer.apply(this, arguments);
      server.use(middleware);
      return server;
    };
  }

  function middleware(req, res, next) {
    var options = {
      // we use the path part of the url as the span name and add the full url
      // as a label later.
      name: req.path(),
      url: req.url,
      ip: req.connection.remoteAddress,
      method: req.method,
      traceContext: req.header(api.constants.TRACE_CONTEXT_HEADER_NAME, null),
      skipFrames: 3
    };

    api.runInRootSpan(options, function(rootSpan) {
      // Set response trace context.
      var responseTraceContext =
        api.getResponseTraceContext(options.traceContext, !!rootSpan);
      if (responseTraceContext) {
        res.header(api.constants.TRACE_CONTEXT_HEADER_NAME, responseTraceContext);
      }

      if (!rootSpan) {
        return next();
      }

      api.wrapEmitter(req);
      api.wrapEmitter(res);

      var fullUrl = req.header('X-Forwarded-Proto', 'http') + '://' +
                    req.header('host') + req.url;
      rootSpan.addLabel(api.labels.HTTP_METHOD_LABEL_KEY, req.method);
      rootSpan.addLabel(api.labels.HTTP_URL_LABEL_KEY, fullUrl);
      rootSpan.addLabel(api.labels.HTTP_PATH_LABEL_KEY, options.name);
      rootSpan.addLabel(api.labels.HTTP_SOURCE_IP,
                        req.connection.remoteAddress);

      var originalEnd = res.end;
      res.end = function(chunk, encoding) {
        res.end = originalEnd;
        var returned = res.end(chunk, encoding);

        if (req.route && req.route.path) {
          rootSpan.addLabel('restify/request.route.path', req.route.path);
        }
        rootSpan.addLabel(api.labels.HTTP_RESPONSE_CODE_LABEL_KEY,
                          res.statusCode);
        rootSpan.endSpan();
        return returned;
      };

      next();
    });
  }
}

module.exports = [
  {versions: SUPPORTED_VERSIONS, patch: patchRestify, unpatch: unpatchRestify}
];