diff --git a/api_logs/api-logs.go b/api_logs/api-logs.go
index e41caecfd937d175a8f7b0a0cc9335ce3760f8de..bfd4ad1f3eb87f61e0b5e90e13dd0ceba0a92927 100644
--- a/api_logs/api-logs.go
+++ b/api_logs/api-logs.go
@@ -2,7 +2,7 @@ package api_logs
import (
"github.com/thoas/go-funk"
- "gitlab.bob.co.za/bob-public-utils/bobgroup-go-utils/string_utils"
+ "gitlab.bob.co.za/bob-public-utils/bobgroup-go-utils/number_utils"
"net/url"
"strings"
"time"
@@ -41,7 +41,7 @@ func GenerateIncomingAPILog(startTime time.Time, requestID *string, claim map[st
if accountID == 0 {
if accountIDParam, ok := req.QueryStringParameters["account_id"]; ok {
- if i64, err := string_utils.StringToInt64(accountIDParam); err == nil && i64 > 0 {
+ if i64, err := number_utils.StringToInt64(accountIDParam); err == nil && i64 > 0 {
accountID = i64
}
}
@@ -49,7 +49,7 @@ func GenerateIncomingAPILog(startTime time.Time, requestID *string, claim map[st
if providerID == 0 {
if providerIDParam, ok := req.QueryStringParameters["provider_id"]; ok {
- if i64, err := string_utils.StringToInt64(providerIDParam); err == nil && i64 > 0 {
+ if i64, err := number_utils.StringToInt64(providerIDParam); err == nil && i64 > 0 {
providerID = i64
}
}
diff --git a/api_responses/api_responses.go b/api_responses/api_responses.go
index 4774cc3513f5ad0a641487362475a99afc653340..b728cb5f0ba6bac519729c12c1b5edde4006c800 100644
--- a/api_responses/api_responses.go
+++ b/api_responses/api_responses.go
@@ -4,6 +4,7 @@ import (
"encoding/json"
"errors"
"fmt"
+ "gitlab.bob.co.za/bob-public-utils/bobgroup-go-utils/map_utils"
"net/http"
"regexp"
"strconv"
@@ -46,14 +47,14 @@ func Error(err error, msg string, statusCode int) (events.APIGatewayProxyRespons
if err != nil {
return events.APIGatewayProxyResponse{
StatusCode: statusCode,
- Headers: utils.MergeMaps(utils.CorsHeaders(), responses.ContentTypeJSONHeader),
+ Headers: map_utils.MergeMaps(utils.CorsHeaders(), responses.ContentTypeJSONHeader),
Body: "{ \"error\": \"" + http.StatusText(http.StatusInternalServerError) + "\"}",
}, nil
}
return events.APIGatewayProxyResponse{
StatusCode: statusCode,
- Headers: utils.MergeMaps(utils.CorsHeaders(), responses.ContentTypeJSONHeader),
+ Headers: map_utils.MergeMaps(utils.CorsHeaders(), responses.ContentTypeJSONHeader),
Body: string(bodyBytes),
}, errors.New(msg)
}
@@ -136,7 +137,7 @@ func DatabaseServerError(err error, msg string) (events.APIGatewayProxyResponse,
if marshalError != nil {
return events.APIGatewayProxyResponse{
StatusCode: statusCode,
- Headers: utils.MergeMaps(utils.CorsHeaders(), responses.ContentTypeJSONHeader),
+ Headers: map_utils.MergeMaps(utils.CorsHeaders(), responses.ContentTypeJSONHeader),
Body: "{ \"error\": \"" + http.StatusText(http.StatusInternalServerError) + "\"}",
}, nil
}
@@ -148,7 +149,7 @@ func DatabaseServerError(err error, msg string) (events.APIGatewayProxyResponse,
return events.APIGatewayProxyResponse{
StatusCode: statusCode,
- Headers: utils.MergeMaps(utils.CorsHeaders(), responses.ContentTypeJSONHeader),
+ Headers: map_utils.MergeMaps(utils.CorsHeaders(), responses.ContentTypeJSONHeader),
Body: string(bodyBytes),
}, err
}
@@ -230,7 +231,7 @@ func ClientError(status int, message string) (events.APIGatewayProxyResponse, er
return events.APIGatewayProxyResponse{
StatusCode: status,
- Headers: utils.MergeMaps(utils.CorsHeaders(), responses.ContentTypeJSONHeader),
+ Headers: map_utils.MergeMaps(utils.CorsHeaders(), responses.ContentTypeJSONHeader),
Body: string(b),
}, errors.New(message)
}
diff --git a/audit/audit.go b/audit/audit.go
index 4b27f0e229b9ab07ec4bbcaf6b91ce519a50d157..580513581cf6a07d8e1e2f08a9fdcff7fa8e6294 100644
--- a/audit/audit.go
+++ b/audit/audit.go
@@ -4,6 +4,7 @@ import (
"encoding/json"
"fmt"
"gitlab.bob.co.za/bob-public-utils/bobgroup-go-utils/errors"
+ "gitlab.bob.co.za/bob-public-utils/bobgroup-go-utils/number_utils"
"reflect"
"regexp"
"strconv"
@@ -77,7 +78,7 @@ func GetChanges(original interface{}, new interface{}) (map[string]interface{},
continue
}
- index, _ := string_utils.StringToInt64(indexString)
+ index, _ := number_utils.StringToInt64(indexString)
field := ToSnakeCase(change.Path[2])
if len(change.Path) == 5 && string_utils.IsNumericString(change.Path[3]) {
diff --git a/handler_utils/debug.go b/handler_utils/debug.go
index c6c8ea99c18c6d88e907a7afa3cf7cda5b3139b8..06817f60158d452ff4db373db3003365b913a2a7 100644
--- a/handler_utils/debug.go
+++ b/handler_utils/debug.go
@@ -98,7 +98,7 @@ func ServeSQSFunctions(ctx context.Context, lambdaHandler lambda.Handler, w http
Body: body,
MessageAttributes: map[string]events.SQSMessageAttribute{
"type": {
- StringValue: utils.PointerValue(sqsType),
+ StringValue: utils.ValueToPointer(sqsType),
},
},
},
diff --git a/responses/responses.go b/responses/responses.go
index 0cec3b118b4f7021ac4961ba1bd5581078cd85c8..78d1d9243c28eaf364f5cfa3152aab6317a0c536 100644
--- a/responses/responses.go
+++ b/responses/responses.go
@@ -2,6 +2,7 @@ package responses
import (
"encoding/json"
+ "gitlab.bob.co.za/bob-public-utils/bobgroup-go-utils/map_utils"
"net/http"
"gitlab.bob.co.za/bob-public-utils/bobgroup-go-utils/logs"
@@ -29,7 +30,7 @@ func NotFoundResponse(err error) (events.APIGatewayProxyResponse, error) {
func NoContent() (events.APIGatewayProxyResponse, error) {
return events.APIGatewayProxyResponse{
StatusCode: http.StatusNoContent,
- Headers: utils.MergeMaps(utils.CorsHeaders(), ContentTypeJSONHeader),
+ Headers: map_utils.MergeMaps(utils.CorsHeaders(), ContentTypeJSONHeader),
}, nil
}
@@ -45,7 +46,7 @@ func TooManyRequests(message string) (events.APIGatewayProxyResponse, error) {
return events.APIGatewayProxyResponse{
StatusCode: http.StatusTooManyRequests,
- Headers: utils.MergeMaps(utils.CorsHeaders(), ContentTypeJSONHeader),
+ Headers: map_utils.MergeMaps(utils.CorsHeaders(), ContentTypeJSONHeader),
Body: string(responseJson),
}, nil
}
@@ -85,7 +86,7 @@ func GenericResponse(statusCode int, body string, headers map[string]string) (ev
return events.APIGatewayProxyResponse{
StatusCode: statusCode,
Body: body + "\n",
- Headers: utils.MergeMaps(utils.CorsHeaders(), headers),
+ Headers: map_utils.MergeMaps(utils.CorsHeaders(), headers),
}, nil
}
@@ -101,7 +102,7 @@ func MaintenanceResponse(message string) events.APIGatewayProxyResponse {
return events.APIGatewayProxyResponse{
StatusCode: http.StatusTeapot,
Body: message,
- Headers: utils.MergeMaps(utils.CorsHeaders(), ContentTypeJSONHeader),
+ Headers: map_utils.MergeMaps(utils.CorsHeaders(), ContentTypeJSONHeader),
}
}
@@ -109,13 +110,13 @@ func RateLimitResponse(message string) events.APIGatewayProxyResponse {
return events.APIGatewayProxyResponse{
StatusCode: http.StatusTooManyRequests,
Body: message,
- Headers: utils.MergeMaps(utils.CorsHeaders(), ContentTypeJSONHeader),
+ Headers: map_utils.MergeMaps(utils.CorsHeaders(), ContentTypeJSONHeader),
}
}
func OptionsResponse() events.APIGatewayProxyResponse {
return events.APIGatewayProxyResponse{
StatusCode: http.StatusNoContent,
- Headers: utils.MergeMaps(utils.CorsHeaders(), ContentTypeJSONHeader),
+ Headers: map_utils.MergeMaps(utils.CorsHeaders(), ContentTypeJSONHeader),
}
}