res_handler_header_injector.go

package main

import (
	"github.com/lonelycode/tykcommon"
	"github.com/mitchellh/mapstructure"
	"net/http"
)

type HeaderInjectorOptions struct {
	AddHeaders    map[string]string `mapstructure:"add_headers" bson:"add_headers" json:"add_headers"`
	RemoveHeaders []string          `mapstructure:"remove_headers" bson:"remove_headers" json:"remove_headers"`
}

type HeaderInjector struct {
	Spec   *APISpec
	config HeaderInjectorOptions
}

func (h HeaderInjector) New(c interface{}, spec *APISpec) (TykResponseHandler, error) {
	thisHandler := HeaderInjector{}
	thisModuleConfig := HeaderInjectorOptions{}

	err := mapstructure.Decode(c, &thisModuleConfig)
	if err != nil {
		log.Error(err)
		return nil, err
	}

	thisHandler.config = thisModuleConfig
	thisHandler.Spec = spec

	return thisHandler, nil
}

func (h HeaderInjector) HandleResponse(rw http.ResponseWriter, res *http.Response, req *http.Request, ses *SessionState) error {
	// TODO: This should only target specific paths

	// Uee the request status validator to see if it's in our response list
	var stat RequestStatus
	var meta interface{}
	var found bool

	_, versionPaths, _, _ := h.Spec.GetVersionData(req)
	found, meta = h.Spec.CheckSpecMatchesStatus(req.URL.Path, req.Method, versionPaths, HeaderInjectedResponse)

	if found {
		stat = StatusHeaderInjected
	}

	if stat == StatusHeaderInjected {
		thisMeta := meta.(*tykcommon.HeaderInjectionMeta)

		for _, dKey := range thisMeta.DeleteHeaders {
			res.Header.Del(dKey)
		}

		for nKey, nVal := range thisMeta.AddHeaders {
			res.Header.Add(nKey, nVal)
		}

	}

	// Global header options
	for _, n := range h.config.RemoveHeaders {
		res.Header.Del(n)
	}

	for h, v := range h.config.AddHeaders {
		res.Header.Add(h, v)
	}

	return nil
}