fix(userstorage & kong): temp fix

backend/kong-gateway/kong.deployment.yml

@@ -118,10 +118,6 @@ services:
               proto: /usr/local/share/lua/5.1/kong/protos/handle_temporary_contents.proto
 
 plugins:
-  - name: file-log
-    service: verify-user-service
-    config:
-      path: /usr/local/share/lua/5.1/kong/plugins/authn-kong/user-storage.log
   - name: cors
     config:
       origins:

backend/kong-gateway/rawstring-adapter/handler.lua

@@ -6,24 +6,34 @@ local RawStringAdapterHandler = {
 }
 
 function RawStringAdapterHandler:access(config)
+    -- Retrieve the raw body directly without transformation
     local raw_body, err = kong.request.get_raw_body()
-    if err then
-        kong.log.err("Error reading request body: ", err)
-        return
+    if err or not raw_body then
+        kong.log.err("Error reading request body or body is empty: ", err)
+        return kong.response.exit(400, { message = "Bad request" })
     end
 
-    local body_json = cjson.encode(raw_body)
-    if not body_json then
-        kong.log.err("Failed to encode JSON")
-        return
+    -- Attempt to decode and re-encode to ensure it's valid JSON
+    local decoded_json, decode_err = cjson.decode(raw_body)
+    if decode_err then
+        kong.log.err("Failed to decode JSON: ", decode_err)
+        return kong.response.exit(400, { message = "Invalid JSON" })
     end
 
+    local encoded_json, encode_err = cjson.encode(decoded_json)
+    if encode_err then
+        kong.log.err("Failed to re-encode JSON: ", encode_err)
+        return kong.response.exit(500, { message = "Internal Server Error" })
+    end
+
+    -- Forward the validated and re-encoded JSON
+    kong.service.request.set_raw_body(encoded_json)
+
+    -- Optionally, forward headers as is
     local headers = kong.request.get_headers()
     for k, v in pairs(headers) do
         kong.service.request.set_header(k, v)
     end
-
-    kong.service.request.set_raw_body(body_json)
 end
 
 return RawStringAdapterHandler

backend/simple/user-storage/Dockerfile

@@ -31,6 +31,7 @@ RUN GRPC_HEALTH_PROBE_VERSION=v0.4.13 && \
 
 FROM node:20.11.1-alpine3.19
 ENV NODE_ENV production
+ENV ENVIRONMENT development
 WORKDIR /app
 
 COPY --from=build /app/dist ./dist

backend/simple/user-storage/UserStorage.Dockerfile

@@ -54,6 +54,7 @@ WORKDIR /app
 
 # Set the environment to production to optimize for production
 ENV NODE_ENV production
+ENV ENVIRONMENT production
 
 # Copy compiled protobuf definitions to the container
 COPY protos /app/dist/protos

backend/simple/user-storage/src/services/redis.service.ts

@@ -13,6 +13,7 @@ class RedisService {
       socket: {
         host: REDIS_CONFIG.REDIS_HOST,
         port: REDIS_CONFIG.REDIS_PORT,
+        tls: process.env.ENVIRONMENT === 'production',
       },
     });