Moesif Middleware for Go

Built For Software License Source Code

Go Middleware that logs API Calls and sends to Moesif for API analytics and log analysis.

Source Code on GitHub

How to install

Run the following commands:

moesifmiddleware-go can be installed like any other Go library through go get:

go get github.com/moesif/moesifmiddleware-go

Or, if you are already using Go Modules, specify a version number as well:

go get github.com/moesif/moesifmiddleware-go@v1.2.3

How to use

Add middleware to your application.

import(
    moesifmiddleware "github.com/moesif/moesifmiddleware-go"
)

func handle(w http.ResponseWriter, r *http.Request) {
	// Your API Logic
}

var moesifOptions = map[string]interface{} {
        "Application_Id": "Your Moesif Application Id",
        "Log_Body": true,
}
http.Handle("/api", moesifmiddleware.MoesifMiddleware(http.HandlerFunc(handle), moesifOption))

Your Moesif Application Id can be found in the Moesif Portal. After signing up for a Moesif account, your Moesif Application Id will be displayed during the onboarding steps.

Optional: Capturing outgoing API calls

In addition to your own APIs, you can also start capturing calls out to third party services via the following method:

moesifmiddleware.StartCaptureOutgoing(moesifOption)

handler func(ResponseWriter, *Request)

(required), HandlerFunc registers the handler function for the given pattern.

moesifOption

(required), map[string]interface{}, are the configuration options for your application. Please find the details below on how to configure options.

Configuration options

Application_Id

(required), string, is obtained via your Moesif Account, this is required. Your Moesif Application Id can be found in the Moesif Portal. After signing up for a Moesif account, your Moesif Application Id will be displayed during the onboarding steps.

You can always find your Moesif Application Id at any time by logging into the Moesif Portal, click on the top right menu, and then clicking Installation.

Should_Skip

(optional) (request, response) => boolean, a function that takes a request and a response, and returns true if you want to skip this particular event.

Identify_User

(optional, but highly recommended) (request, response) => string, a function that takes a request and response, and returns a string that is the user id used by your system. While Moesif tries to identify users automatically, but different frameworks and your implementation might be very different, it would be helpful and much more accurate to provide this function.

Identify_Company

(optional) (request, response) => string, a function that takes a request and response, and returns a string that is the company id for this event.

Get_Metadata

(optional) (request, response) => dictionary, a function that takes a request and response, and returns a dictionary (must be able to be encoded into JSON). This allows you to associate this event with custom metadata. For example, you may want to save a VM instance_id, a trace_id, or a tenant_id with the request.

Get_Session_Token

(optional) (request, response) => string, a function that takes a request and response, and returns a string that is the session token for this event. Moesif tries to get the session token automatically, but if this doesn’t work for your service, you should use this to identify sessions.

Request_Header_Masks

(optional) () => []string, a function that returns array of strings to mask specific request header fields.

Request_Body_Masks

(optional) () => []string, a function that returns array of strings to mask specific request body fields.

Response_Header_Masks

(optional) () => []string, a function that returns array of strings to mask specific response header fields.

Response_Body_Masks

(optional) () => []string, a function that returns array of strings to mask specific response body fields.

Debug

(optional) boolean, a flag to see debugging messages.

Log_Body

(optional) boolean, Default true. Set to false to remove logging request and response body to Moesif.

Event_Queue_Size

(optional) int, An optional field name which specify the maximum number of events to hold in queue before sending to Moesif. In case of network issues when not able to connect/send event to Moesif, skips adding new events to the queue to prevent memory overflow. Default value is 10000.

Batch_Size

(optional) int, An optional field name which specify the maximum batch size when sending to Moesif. Default value is 200.

Timer_Wake_Up_Seconds

(optional) int, An optional field which specifies a time (every n seconds) how often background thread runs to send events to moesif. Default value is 2 seconds.

Options for logging outgoing calls

The options below are applied to outgoing API calls. The request and response objects passed in are Request request and Response response objects.

Should_Skip_Outgoing

(optional) (request, response) => boolean, a function that takes a request and response, and returns true if you want to skip this particular event.

Identify_User_Outgoing

(optional, but highly recommended) (request, response) => string, a function that takes request and response, and returns a string that is the user id used by your system. While Moesif tries to identify users automatically, but different frameworks and your implementation might be very different, it would be helpful and much more accurate to provide this function.

Identify_Company_Outgoing

(optional) (request, response) => string, a function that takes request and response, and returns a string that is the company id for this event.

Get_Metadata_Outgoing

(optional) (request, response) => dictionary, a function that takes request and response, and returns a dictionary (must be able to be encoded into JSON). This allows to associate this event with custom metadata. For example, you may want to save a VM instance_id, a trace_id, or a tenant_id with the request.

Get_Session_Token_Outgoing

(optional) (request, response) => string, a function that takes request and response, and returns a string that is the session token for this event. Again, Moesif tries to get the session token automatically, but if you setup is very different from standard, this function will be very help for tying events together, and help you replay the events.

Log_Body_Outgoing

(optional) boolean, Default true. Set to false to remove logging request and response body to Moesif.

Update User

UpdateUser method

Create or update a user profile in Moesif. The metadata field can be any customer demographic or other info you want to store. Only the UserId field is required. This method is a convenient helper that calls the Moesif API lib. For details, visit the Go API Reference.

import (
	moesifmiddleware "github.com/moesif/moesifmiddleware-go"
)

func literalFieldValue(value string) *string {
    return &value
}

var moesifOptions = map[string]interface{} {
	"Application_Id": "Your Moesif Application Id",
	"Log_Body": true,
}

// Campaign object is optional, but useful if you want to track ROI of acquisition channels
// See https://www.moesif.com/docs/api#users for campaign schema
campaign := models.CampaignModel {
  UtmSource: literalFieldValue("google"),
  UtmMedium: literalFieldValue("cpc"), 
  UtmCampaign: literalFieldValue("adwords"),
  UtmTerm: literalFieldValue("api+tooling"),
  UtmContent: literalFieldValue("landing"),
}
  
// metadata can be any custom dictionary
metadata := map[string]interface{}{
  "email": "john@acmeinc.com",
  "first_name": "John",
  "last_name": "Doe",
  "title": "Software Engineer",
  "sales_info": map[string]interface{}{
      "stage": "Customer",
      "lifetime_value": 24000,
      "account_owner": "mary@contoso.com",
  },
}

// Only UserId is required
user := models.UserModel{
  UserId:  "12345",
  CompanyId:  literalFieldValue("67890"), // If set, associate user with a company object
  Campaign:  &campaign,
  Metadata:  &metadata,
}

// Update User
moesifmiddleware.UpdateUser(&user, moesifOption)

UpdateUsersBatch method

Similar to UpdateUser, but used to update a list of users in one batch. Only the UserId field is required. This method is a convenient helper that calls the Moesif API lib. For details, visit the Go API Reference.


import (
	moesifmiddleware "github.com/moesif/moesifmiddleware-go"
)

func literalFieldValue(value string) *string {
    return &value
}

var moesifOptions = map[string]interface{} {
	"Application_Id": "Your Moesif Application Id",
}

// List of Users
var users []*models.UserModel

// Campaign object is optional, but useful if you want to track ROI of acquisition channels
// See https://www.moesif.com/docs/api#users for campaign schema
campaign := models.CampaignModel {
  UtmSource: literalFieldValue("google"),
  UtmMedium: literalFieldValue("cpc"), 
  UtmCampaign: literalFieldValue("adwords"),
  UtmTerm: literalFieldValue("api+tooling"),
  UtmContent: literalFieldValue("landing"),
}
  
// metadata can be any custom dictionary
metadata := map[string]interface{}{
  "email": "john@acmeinc.com",
  "first_name": "John",
  "last_name": "Doe",
  "title": "Software Engineer",
  "sales_info": map[string]interface{}{
      "stage": "Customer",
      "lifetime_value": 24000,
      "account_owner": "mary@contoso.com",
  },
}

// Only UserId is required
userA := models.UserModel{
  UserId:  "12345",
  CompanyId:  literalFieldValue("67890"), // If set, associate user with a company object
  Campaign:  &campaign,
  Metadata:  &metadata,
}

users = append(users, &userA)

// Update User
moesifmiddleware.UpdateUsersBatch(users, moesifOption)

Update Company

UpdateCompany method

Create or update a company profile in Moesif. The metadata field can be any company demographic or other info you want to store. Only the CompanyId field is required. This method is a convenient helper that calls the Moesif API lib. For details, visit the Go API Reference.

import (
	moesifmiddleware "github.com/moesif/moesifmiddleware-go"
)

func literalFieldValue(value string) *string {
    return &value
}

var moesifOptions = map[string]interface{} {
	"Application_Id": "Your Moesif Application Id",
}

// Campaign object is optional, but useful if you want to track ROI of acquisition channels
// See https://www.moesif.com/docs/api#update-a-company for campaign schema
campaign := models.CampaignModel {
  UtmSource: literalFieldValue("google"),
  UtmMedium: literalFieldValue("cpc"), 
  UtmCampaign: literalFieldValue("adwords"),
  UtmTerm: literalFieldValue("api+tooling"),
  UtmContent: literalFieldValue("landing"),
}
  
// metadata can be any custom dictionary
metadata := map[string]interface{}{
  "org_name": "Acme, Inc",
  "plan_name": "Free",
  "deal_stage": "Lead",
  "mrr": 24000,
  "demographics": map[string]interface{}{
      "alexa_ranking": 500000,
      "employee_count": 47,
  },
}

// Prepare company model
company := models.CompanyModel{
	CompanyId:		  "67890",	// The only required field is your company id
	CompanyDomain:  literalFieldValue("acmeinc.com"), // If domain is set, Moesif will enrich your profiles with publicly available info 
	Campaign: 		  &campaign,
	Metadata:		    &metadata,
}

// Update Company
moesifmiddleware.UpdateCompany(&company, moesifOption)

UpdateCompaniesBatch method

Similar to UpdateCompany, but used to update a list of companies in one batch. Only the CompanyId field is required. This method is a convenient helper that calls the Moesif API lib. For details, visit the Go API Reference.


import (
	moesifmiddleware "github.com/moesif/moesifmiddleware-go"
)

func literalFieldValue(value string) *string {
    return &value
}

var moesifOptions = map[string]interface{} {
	"Application_Id": "Your Moesif Application Id",
}

// List of Companies
var companies []*models.CompanyModel

// Campaign object is optional, but useful if you want to track ROI of acquisition channels
// See https://www.moesif.com/docs/api#update-a-company for campaign schema
campaign := models.CampaignModel {
  UtmSource: literalFieldValue("google"),
  UtmMedium: literalFieldValue("cpc"), 
  UtmCampaign: literalFieldValue("adwords"),
  UtmTerm: literalFieldValue("api+tooling"),
  UtmContent: literalFieldValue("landing"),
}
  
// metadata can be any custom dictionary
metadata := map[string]interface{}{
  "org_name": "Acme, Inc",
  "plan_name": "Free",
  "deal_stage": "Lead",
  "mrr": 24000,
  "demographics": map[string]interface{}{
      "alexa_ranking": 500000,
      "employee_count": 47,
  },
}

// Prepare company model
companyA := models.CompanyModel{
	CompanyId:		  "67890",	// The only required field is your company id
	CompanyDomain:  literalFieldValue("acmeinc.com"), // If domain is set, Moesif will enrich your profiles with publicly available info 
	Campaign: 		  &campaign,
	Metadata:		    &metadata,
}

companies = append(companies, &companyA)

// Update Companies
moesifmiddleware.UpdateCompaniesBatch(companies, moesifOption)

Update Subscription

UpdateSubscription method

Create or update a subscription profile in Moesif. The metadata field can be any subscription demographic or other info you want to store. Only the SubscriptionId and CompanyId fields are required. This method is a convenient helper that calls the Moesif API lib. For details, visit the Go API Reference.

import (
	moesifmiddleware "github.com/moesif/moesifmiddleware-go"
)

func literalFieldValue(value string) *string {
    return &value
}

var moesifOptions = map[string]interface{} {
	"Application_Id": "Your Moesif Application Id",
}

// metadata can be any custom dictionary
metadata := map[string]interface{}{
  "plan_name": "Pro",
  "deal_stage": "Customer",
  "mrr": 48000,
  "demographics": map[string]interface{}{
      "subscription_length": 12,
      "subscription_type": "annual",
  },
}

// Prepare subscription model
subscription := models.SubscriptionModel{
	SubscriptionId: "12345",	// Required subscription id
  CompanyId: "67890",       // Required company id
	Metadata: &metadata,
}

// Update Subscription
moesifmiddleware.UpdateSubscription(&subscription, moesifOptions)

UpdateSubscriptionsBatch method

Similar to UpdateSubscription, but used to update a list of subscriptions in one batch. Only the SubscriptionId and CompanyId fields are required. This method is a convenient helper that calls the Moesif API lib. For details, visit the Go API Reference.

import (
	moesifmiddleware "github.com/moesif/moesifmiddleware-go"
)

func literalFieldValue(value string) *string {
    return &value
}

var moesifOptions = map[string]interface{} {
	"Application_Id": "Your Moesif Application Id",
}

// List of Subscriptions
var subscriptions []*models.SubscriptionModel

// metadata can be any custom dictionary
metadata := map[string]interface{}{
  "plan_name": "Pro",
  "deal_stage": "Customer",
  "mrr": 48000,
  "demographics": map[string]interface{}{
      "subscription_length": 12,
      "subscription_type": "annual",
  },
}

// Prepare subscription model
subscriptionA := models.SubscriptionModel{
	SubscriptionId: "12345",	// Required subscription id
  CompanyId: "67890",       // Required company id
	Metadata: &metadata,
}

subscriptions = append(subscriptions, &subscriptionA)

// Update Subscriptions
moesifmiddleware.UpdateSubscriptionsBatch(subscriptions, moesifOptions)

Example

Other integrations

To view more documentation on integration options, please visit the Integration Options Documentation.