From 60e21cd6d6b8143995e0c5f3fa18fa07dc8ff7c2 Mon Sep 17 00:00:00 2001 From: Jan Semmelink <jan@uafrica.com> Date: Mon, 18 Oct 2021 08:32:13 +0200 Subject: [PATCH] Remove old comment --- audit/audit.go | 138 ------------------------------------------------- 1 file changed, 138 deletions(-) diff --git a/audit/audit.go b/audit/audit.go index 1a7f371..2fdf2bf 100644 --- a/audit/audit.go +++ b/audit/audit.go @@ -6,141 +6,3 @@ type Auditor interface { WriteValues(startTime, endTime time.Time, requestID string, values map[string]interface{}) error WriteEvent(requestID string, event Event) error } - -// func getAuthUsername(identity events.APIGatewayRequestIdentity) string { -// if identity.CognitoAuthenticationProvider != "" { -// split := strings.Split(identity.CognitoAuthenticationProvider, ":") -// return split[len(split)-1] -// } - -// // IAM -// split := strings.Split(identity.UserArn, ":user/") -// return split[len(split)-1] -// } - -// func SaveAPIRequest(req events.APIGatewayProxyRequest, response events.APIGatewayProxyResponse, startTime time.Time, currentRequestID *string) { -// claim, err := claims.RetrieveClaims(&req) -// authType := determineAuthType(req.RequestContext.Identity) -// authUsername := getAuthUsername(req.RequestContext.Identity) - -// responseBody := response.Body -// responseSize := int64(len(responseBody)) -// // SQS has a 256KB limit, so let's limit the response to 96KB -// if len(responseBody) > 12000 { -// responseBody = responseBody[:12000] + "..." -// } - -// var relevantID *string -// mappedResponse := map[string]interface{}{} -// err = json.Unmarshal([]byte(req.Body), &mappedResponse) - -// if err == nil { -// val, present := mappedResponse["id"] -// if present { -// valString := utils.Int64ToString(int64(val.(float64))) -// relevantID = &valString -// } -// } - -// accountID := fmt.Sprintf("%d", *claim.AccountID) -// apiLog := types.ApiLog{ -// AccountID: &accountID, -// UserID: claim.UserID, -// Path: req.Path, -// HTTPMethod: req.HTTPMethod, -// Timestamp: time.Now(), -// Request: map[string]interface{}{ -// "Body": req.Body, -// "QueryStringParameters": req.QueryStringParameters, -// }, -// Response: map[string]interface{}{ -// "Body": responseBody, -// }, -// ResponseCode: response.StatusCode, -// ExecutionTime: time.Now().Sub(startTime).Milliseconds(), -// RequestID: currentRequestID, -// RelevantID: relevantID, -// InitialAuthUsername: &authUsername, -// InitialAuthType: authType, -// IP: &req.RequestContext.Identity.SourceIP, -// UserAgent: &req.RequestContext.Identity.UserAgent, -// ResponseSize: responseSize, -// } - -// data, err := json.Marshal(apiLog) -// if err != nil { -// logs.LogErrorMessage("Failed to encode audit event", err) -// return -// } - -// _ = sqs.ApiLogEvent( -// map[string]string{}, -// string(data), -// currentRequestID, -// ) -// } - -// func SaveThirdPartyAPIRequest(url string, method string, requestBody string, responseBody string, responseStatus int, startTime time.Time, currentRequestID *string) { - -// responseSize := int64(len(responseBody)) -// // SQS has a 256KB limit, so let's limit the response to 96KB -// if len(responseBody) > 12000 { -// responseBody = responseBody[:12000] + "..." -// } - -// var relevantID *string -// mappedResponse := map[string]interface{}{} -// err := json.Unmarshal([]byte(requestBody), &mappedResponse) - -// if err == nil { -// val, present := mappedResponse["id"] -// if present { -// valString := utils.Int64ToString(int64(val.(float64))) -// relevantID = &valString -// } -// } - -// apiLog := types.ApiLog{ -// AccountID: nil, -// UserID: nil, -// Path: url, -// HTTPMethod: method, -// Timestamp: time.Now(), -// Request: map[string]interface{}{ -// "Body": requestBody, -// }, -// Response: map[string]interface{}{ -// "Body": responseBody, -// }, -// ResponseCode: responseStatus, -// ExecutionTime: time.Now().Sub(startTime).Milliseconds(), -// RequestID: currentRequestID, -// RelevantID: relevantID, -// InitialAuthUsername: nil, -// InitialAuthType: nil, -// IP: nil, -// UserAgent: nil, -// ResponseSize: responseSize, -// } - -// data, err := json.Marshal(apiLog) -// if err != nil { -// logs.LogErrorMessage("Failed to encode audit event", err) -// return -// } - -// _ = sqs.ApiLogEvent( -// map[string]string{}, -// string(data), -// currentRequestID, -// ) -// } - -// func determineAuthType(identity events.APIGatewayRequestIdentity) *string { -// result := "cognito" -// if identity.CognitoAuthenticationType == "" { -// result = "iam" -// } - -// return &result -// } -- GitLab