\",\n \"status\": \"ACTIVE\",\n \"email_header\": null,\n \"email_footer\": null,\n \"created_by\": null,\n \"updated_by\": null,\n \"tenant_code\": \"default\",\n \"organization_code\": \"default_code\",\n \"created_at\": \"2025-05-08T11:43:06.000Z\",\n \"updated_at\": \"2025-05-08T11:43:06.000Z\",\n \"deleted_at\": null\n }",
"options": {
"raw": {
"language": "json"
@@ -1722,9 +4532,9 @@
}
},
"url": {
- "raw": "{{UserDevBaseUrl}}user/v1/notification/template/14",
+ "raw": "{{UserDevBaseUrl}}user/v1/notification/template/8",
"host": ["{{UserDevBaseUrl}}user"],
- "path": ["v1", "notification", "template", "14"]
+ "path": ["v1", "notification", "template", "8"]
}
},
"response": []
@@ -1741,12 +4551,12 @@
"header": [
{
"key": "X-auth-token",
- "value": " {{token}}",
+ "value": "{{token}}",
"type": "text"
}
],
"url": {
- "raw": "{{UserDevBaseUrl}}user/v1/user-role/list?page=1&limit=10&search=system&organization_id=1&language=kn",
+ "raw": "{{UserDevBaseUrl}}user/v1/user-role/list?page=1&limit=100&status=ACTIVE",
"host": ["{{UserDevBaseUrl}}user"],
"path": ["v1", "user-role", "list"],
"query": [
@@ -1756,19 +4566,16 @@
},
{
"key": "limit",
- "value": "10"
+ "value": "100"
},
{
"key": "search",
- "value": "system"
- },
- {
- "key": "organization_id",
- "value": "1"
+ "value": "system",
+ "disabled": true
},
{
"key": "user_type",
- "value": "2",
+ "value": "1",
"disabled": true
},
{
@@ -1778,12 +4585,12 @@
},
{
"key": "status",
- "value": "ACTIVE",
- "disabled": true
+ "value": "ACTIVE"
},
{
"key": "language",
- "value": "kn"
+ "value": "kn",
+ "disabled": true
}
]
}
@@ -1791,13 +4598,13 @@
"response": []
},
{
- "name": "Default List User Roles",
+ "name": "[DEPRECATED]Default List User Roles",
"request": {
"method": "GET",
"header": [
{
"key": "X-auth-token",
- "value": " {{token}}",
+ "value": "{{token}}",
"type": "text"
}
],
@@ -1850,13 +4657,13 @@
"header": [
{
"key": "X-auth-token",
- "value": " {{token}}",
+ "value": "{{token}}",
"type": "text"
}
],
"body": {
"mode": "raw",
- "raw": "{ \n\"id\":\"12\",\n\"title\":\"head_master\", \n\"label\":\"Head Master\",\n\"user_type\": 1, \n \"meta\": {\n \"entityTypes\" : [ \n {\n \"entityTypeId\" : \"5f32d8228e0dc8312404056e\", \n \"entityType\" : \"state\" \n }\n ]\n },\n\"status\":\"ACTIVE\", \n\"visibility\":\"PUBLIC\",\n \"translations\" : {\n \"hi\" : {\n \"title\" : \"हेड मास्टर\"\n },\n \"kn\" : {\n \"title\" : \"ಹೆಡ್ ಮಾಸ್ಟರ್\"\n },\n \"te\" : {\n \"title\" : \"హెడ్ మాస్టర్\"\n },\n \"bn\" : {\n \"title\" : \"হেড মাস্টার\"\n },\n \"gu\" : {\n \"title\" : \"હેડ માસ્તર\"\n },\n \"ta\" : {\n \"title\" : \"தலைமை ஆசிரியர்\"\n },\n \"pa\" : {\n \"title\" : \"ਹੈੱਡ ਮਾਸਟਰ\"\n },\n \"ml\" : {\n \"title\" : \"ഹെഡ് മാസ്റ്റർ\"\n },\n \"mr\" : {\n \"title\" : \"मुख्याध्यापक\"\n },\n \"ur\" : {\n \"title\" : \"ہیڈ ماسٹر\"\n },\n \"or\" : {\n \"title\" : \"ହେଡ୍ ମାଷ୍ଟର |\"\n }\n }\n} ",
+ "raw": "{\n \"title\": \"session_manager\",\n \"user_type\": 0,\n \"visibility\": \"PUBLIC\",\n \"label\": \"Session Manager\",\n \"status\": \"ACTIVE\"\n}",
"options": {
"raw": {
"language": "json"
@@ -1878,13 +4685,13 @@
"header": [
{
"key": "X-auth-token",
- "value": " {{token}}",
+ "value": "{{token}}",
"type": "text"
}
],
"body": {
"mode": "raw",
- "raw": "{ \n\"id\":\"12\",\n\"title\":\"head_master\", \n\"label\":\"Head Master\",\n\"user_type\": 1, \n \"meta\": {\n \"entityTypes\" : [ \n {\n \"entityTypeId\" : \"5f32d8228e0dc8312404056e\", \n \"entityType\" : \"state\" \n }\n ]\n },\n\"status\":\"ACTIVE\", \n\"visibility\":\"PUBLIC\",\n \"translations\" : {\n \"hi\" : {\n \"title\" : \"हेड मास्टर\"\n },\n \"kn\" : {\n \"title\" : \"ಹೆಡ್ ಮಾಸ್ಟರ್\"\n },\n \"te\" : {\n \"title\" : \"హెడ్ మాస్టర్\"\n },\n \"bn\" : {\n \"title\" : \"হেড মাস্টার\"\n },\n \"gu\" : {\n \"title\" : \"હેડ માસ્તર\"\n },\n \"ta\" : {\n \"title\" : \"தலைமை ஆசிரியர்\"\n },\n \"pa\" : {\n \"title\" : \"ਹੈੱਡ ਮਾਸਟਰ\"\n },\n \"ml\" : {\n \"title\" : \"ഹെഡ് മാസ്റ്റർ\"\n },\n \"mr\" : {\n \"title\" : \"मुख्याध्यापक\"\n },\n \"ur\" : {\n \"title\" : \"ہیڈ ماسٹر\"\n },\n \"or\" : {\n \"title\" : \"ହେଡ୍ ମାଷ୍ଟର |\"\n }\n }\n} ",
+ "raw": "{\n \"title\": \"mentee\",\n \"label\": \"Mentee ROLE\",\n \"user_type\": 0,\n \"status\": \"ACTIVE\",\n \"visibility\": \"PUBLIC\",\n \"translations\": null\n}",
"options": {
"raw": {
"language": "json"
@@ -1898,7 +4705,7 @@
"variable": [
{
"key": "id",
- "value": "10"
+ "value": "5"
}
]
}
@@ -1912,92 +4719,20 @@
"header": [
{
"key": "X-auth-token",
- "value": " {{token}}",
+ "value": "bearer {{token}}",
"type": "text"
}
],
"url": {
- "raw": "{{UserDevBaseUrl}}user/v1/user-role/delete/:id",
- "host": ["{{UserDevBaseUrl}}user"],
- "path": ["v1", "user-role", "delete", ":id"],
- "variable": [
- {
- "key": "id",
- "value": "7"
- }
- ]
- }
- },
- "response": []
- },
- {
- "name": "Create User Roles",
- "request": {
- "method": "POST",
- "header": [
- {
- "key": "X-auth-token",
- "value": " {{token}}"
- }
- ],
- "body": {
- "mode": "raw",
- "raw": "{\n\"title\": \"test_role\",\n\"user_type\": 1,\n\"status\": \"ACTIVE\",\n\"visibility\": \"PUBLIC\"\n}",
- "options": {
- "raw": {
- "language": "json"
- }
- }
- },
- "url": {
- "raw": "{{UserDevBaseUrl}}elevate-user/v1/user-role/create",
- "host": ["{{UserDevBaseUrl}}elevate-user"],
- "path": ["v1", "user-role", "create"]
- }
- },
- "response": []
- },
- {
- "name": "Update User Roles",
- "request": {
- "method": "POST",
- "header": [
- {
- "key": "X-auth-token",
- "value": " {{token}}"
- }
- ],
- "body": {
- "mode": "raw",
- "raw": "{\n \"title\": \"test_role_one_updated\",\n \"user_type\": 1,\n \"visibility\": \"PUBLIC\",\n \"status\": \"ACTIVE\"\n}",
- "options": {
- "raw": {
- "language": "json"
- }
- }
- },
- "url": {
- "raw": "{{UserDevBaseUrl}}elevate-user/v1/user-role/update/13",
- "host": ["{{UserDevBaseUrl}}elevate-user"],
- "path": ["v1", "user-role", "update", "13"]
- }
- },
- "response": []
- },
- {
- "name": "Delete User Roles",
- "request": {
- "method": "DELETE",
- "header": [
- {
- "key": "X-auth-token",
- "value": " {{token}}"
- }
- ],
- "url": {
- "raw": "{{UserDevBaseUrl}}elevate-user/v1/user-role/delete/13",
- "host": ["{{UserDevBaseUrl}}elevate-user"],
- "path": ["v1", "user-role", "delete", "13"]
+ "raw": "{{UserDevBaseUrl}}user/v1/user-role/delete/:id",
+ "host": ["{{UserDevBaseUrl}}user"],
+ "path": ["v1", "user-role", "delete", ":id"],
+ "variable": [
+ {
+ "key": "id",
+ "value": "7"
+ }
+ ]
}
},
"response": []
@@ -2017,7 +4752,7 @@
"header": [
{
"key": "X-auth-token",
- "value": " {{token}}",
+ "value": "bearer {{token}}",
"type": "text"
}
],
@@ -2045,7 +4780,7 @@
"header": [
{
"key": "X-auth-token",
- "value": " {{token}}",
+ "value": "bearer {{token}}",
"type": "text"
}
],
@@ -2084,7 +4819,7 @@
"header": [
{
"key": "X-auth-token",
- "value": " {{token}}",
+ "value": "bearer {{token}}",
"type": "text"
}
],
@@ -2119,7 +4854,7 @@
"header": [
{
"key": "X-auth-token",
- "value": " {{token}}",
+ "value": "bearer {{token}}",
"type": "text"
}
],
@@ -2150,7 +4885,7 @@
"header": [
{
"key": "X-auth-token",
- "value": " {{token}}",
+ "value": "bearer {{token}}",
"type": "text"
}
],
@@ -2178,7 +4913,7 @@
"header": [
{
"key": "X-auth-token",
- "value": " {{token}}",
+ "value": "bearer {{token}}",
"type": "text"
}
],
@@ -2220,7 +4955,7 @@
"header": [
{
"key": "X-auth-token",
- "value": " {{token}}",
+ "value": "bearer {{token}}",
"type": "text"
}
],
@@ -2253,7 +4988,7 @@
"header": [
{
"key": "X-auth-token",
- "value": " {{token}}",
+ "value": "bearer {{token}}",
"type": "text"
}
],
@@ -2284,7 +5019,7 @@
"header": [
{
"key": "X-auth-token",
- "value": " {{token}}",
+ "value": "bearer {{token}}",
"type": "text"
}
],
@@ -2318,13 +5053,293 @@
"header": [
{
"key": "X-auth-token",
- "value": " {{token}}",
+ "value": "bearer {{token}}",
+ "type": "text"
+ }
+ ],
+ "body": {
+ "mode": "raw",
+ "raw": "{\n \"permission_id\" : 1\n}",
+ "options": {
+ "raw": {
+ "language": "json"
+ }
+ }
+ },
+ "url": {
+ "raw": "{{UserDevBaseUrl}}mentoring/v1/role-permission-mapping/delete/:role_id",
+ "host": ["{{UserDevBaseUrl}}mentoring"],
+ "path": ["v1", "role-permission-mapping", "delete", ":role_id"],
+ "variable": [
+ {
+ "key": "role_id",
+ "value": "5"
+ }
+ ]
+ }
+ },
+ "response": []
+ },
+ {
+ "name": "List RolePermission",
+ "request": {
+ "method": "POST",
+ "header": [
+ {
+ "key": "X-auth-token",
+ "value": "bearer {{token}}",
+ "type": "text"
+ }
+ ],
+ "url": {
+ "raw": "{{UserDevBaseUrl}}mentoring/v1/role-permission-mapping/list",
+ "host": ["{{UserDevBaseUrl}}mentoring"],
+ "path": ["v1", "role-permission-mapping", "list"]
+ }
+ },
+ "response": []
+ }
+ ]
+ },
+ {
+ "name": "Public",
+ "item": [
+ {
+ "name": "Branding",
+ "request": {
+ "method": "GET",
+ "header": [
+ {
+ "key": "Origin",
+ "value": "{{origin}}",
+ "type": "text",
+ "disabled": true
+ },
+ {
+ "key": "x-tenant-code",
+ "value": "shikshalokam",
+ "type": "text"
+ }
+ ],
+ "url": {
+ "raw": "{{UserDevBaseUrl}}user/v1/public/branding",
+ "host": ["{{UserDevBaseUrl}}user"],
+ "path": ["v1", "public", "branding"],
+ "query": [
+ {
+ "key": "org_code",
+ "value": "default_code",
+ "description": "Optional",
+ "disabled": true
+ }
+ ]
+ }
+ },
+ "response": []
+ },
+ {
+ "name": "Check username",
+ "request": {
+ "method": "GET",
+ "header": [
+ {
+ "key": "Origin",
+ "value": "{{origin}}",
+ "type": "text"
+ }
+ ],
+ "url": {
+ "raw": "{{UserDevBaseUrl}}user/v1/public/checkUsername?username=nevil_ngrcbhcfke-k1x",
+ "host": ["{{UserDevBaseUrl}}user"],
+ "path": ["v1", "public", "checkUsername"],
+ "query": [
+ {
+ "key": "username",
+ "value": "nevil_ngrcbhcfke-k1x"
+ }
+ ]
+ }
+ },
+ "response": []
+ },
+ {
+ "name": "User Invite",
+ "protocolProfileBehavior": {
+ "disableBodyPruning": true
+ },
+ "request": {
+ "method": "GET",
+ "header": [
+ {
+ "key": "Origin",
+ "value": "{{origin}}",
"type": "text"
}
],
"body": {
"mode": "raw",
- "raw": "{\n \"permission_id\" : 1\n}",
+ "raw": "{\n \"tenant_code\": \"default\"\n}",
+ "options": {
+ "raw": {
+ "language": "json"
+ }
+ }
+ },
+ "url": {
+ "raw": "{{UserDevBaseUrl}}user/v1/public/userInvites?invitation_key",
+ "host": ["{{UserDevBaseUrl}}user"],
+ "path": ["v1", "public", "userInvites"],
+ "query": [
+ {
+ "key": "invitation_key",
+ "value": null
+ }
+ ]
+ }
+ },
+ "response": []
+ }
+ ]
+ },
+ {
+ "name": "Tenant",
+ "item": [
+ {
+ "name": "Tenant Create or Update",
+ "request": {
+ "method": "POST",
+ "header": [
+ {
+ "key": "Content-Type",
+ "value": "application/json"
+ },
+ {
+ "key": "origin",
+ "value": "https://dev.elevate-mentoring.shikshalokam.org"
+ },
+ {
+ "key": "X-auth-token",
+ "value": "{{token}}"
+ }
+ ],
+ "body": {
+ "mode": "raw",
+ "raw": "{\n \"name\": \"shikshagraha\",\n \"description\": \"ShikshaLokam\",\n \"logo\": \"https:\",\n \"theming\": {},\n \"meta\": {\n \"test\": \"2341\",\n \"eee\": {\n \"sss\": 123,\n \"array\": [\n {\n \"abc\": \"1232\"\n }\n ]\n }\n },\n \"domains\": \"shikshalokam-qa.tekdinext.com\"\n}",
+ "options": {
+ "raw": {
+ "language": "json"
+ }
+ }
+ },
+ "url": {
+ "raw": "{{UserDevBaseUrl}}user/v1/tenant/update/dummy",
+ "host": ["{{UserDevBaseUrl}}user"],
+ "path": ["v1", "tenant", "update", "dummy"]
+ },
+ "description": "Generated from cURL: curl --location 'https://saas-qa.tekdinext.com/user/v1/tenant/update' \\\n--header 'Content-Type: application/json' \\\n--header 'origin: https://dev.elevate-mentoring.shikshalokam.org' \\\n--header 'X-auth-token: bearer {{token}}' \\\n--data '{\n \"name\": \"Test\",\n \"code\": \"test\",\n \"description\": \"Test domain\",\n \"logo\": \"\",\n \"theming\": {},\n \"meta\": {},\n \"domains\": \"https://test.123.domain.com\"\n}'"
+ },
+ "response": []
+ },
+ {
+ "name": "Tenant add domain",
+ "request": {
+ "auth": {
+ "type": "noauth"
+ },
+ "method": "POST",
+ "header": [
+ {
+ "key": "Content-Type",
+ "value": "application/json"
+ },
+ {
+ "key": "origin",
+ "value": "https://dev.elevate-mentoring.shikshalokam.org",
+ "disabled": true
+ },
+ {
+ "key": "X-auth-token",
+ "value": "{{token}}"
+ }
+ ],
+ "body": {
+ "mode": "raw",
+ "raw": "{\n \"domains\": [\n \"https://test.2.domain.com\"\n ]\n}",
+ "options": {
+ "raw": {
+ "language": "json"
+ }
+ }
+ },
+ "url": {
+ "raw": "{{UserDevBaseUrl}}user/v1/tenant/addDomain/shikshagraha",
+ "host": ["{{UserDevBaseUrl}}user"],
+ "path": ["v1", "tenant", "addDomain", "shikshagraha"]
+ }
+ },
+ "response": []
+ },
+ {
+ "name": "Bulk User Create",
+ "request": {
+ "method": "POST",
+ "header": [
+ {
+ "key": "Content-Type",
+ "value": "application/json"
+ },
+ {
+ "key": "X-auth-token",
+ "value": "{{token}}"
+ },
+ {
+ "key": "tenant",
+ "value": "shikshagraha",
+ "disabled": true
+ },
+ {
+ "key": "organization",
+ "value": "sot",
+ "disabled": true
+ }
+ ],
+ "body": {
+ "mode": "raw",
+ "raw": "{\n \"file_path\": \"users/1-1761570904451-users/1-1756128403580-27-oct-bulkupload.csv\",\n \"upload_type\": \"upload\"\n}"
+ },
+ "url": {
+ "raw": "{{UserDevBaseUrl}}user/v1/tenant/bulkUserCreate",
+ "host": ["{{UserDevBaseUrl}}user"],
+ "path": ["v1", "tenant", "bulkUserCreate"]
+ }
+ },
+ "response": []
+ },
+ {
+ "name": "Tenant remove Domain",
+ "request": {
+ "auth": {
+ "type": "noauth"
+ },
+ "method": "POST",
+ "header": [
+ {
+ "key": "Content-Type",
+ "value": "application/json"
+ },
+ {
+ "key": "origin",
+ "value": "https://dev.elevate-mentoring.shikshalokam.org",
+ "disabled": true
+ },
+ {
+ "key": "X-auth-token",
+ "value": "{{token}}"
+ }
+ ],
+ "body": {
+ "mode": "raw",
+ "raw": "{\n \"domains\": [\n \"new.domain.scd\"\n ]\n}",
"options": {
"raw": {
"language": "json"
@@ -2332,119 +5347,161 @@
}
},
"url": {
- "raw": "{{UserDevBaseUrl}}mentoring/v1/role-permission-mapping/delete/:role_id",
- "host": ["{{UserDevBaseUrl}}mentoring"],
- "path": ["v1", "role-permission-mapping", "delete", ":role_id"],
- "variable": [
- {
- "key": "role_id",
- "value": "5"
- }
- ]
+ "raw": "{{UserDevBaseUrl}}user/v1/tenant/removeDomain/dummy",
+ "host": ["{{UserDevBaseUrl}}user"],
+ "path": ["v1", "tenant", "removeDomain", "dummy"]
}
},
"response": []
},
{
- "name": "List RolePermission",
+ "name": "Tenant Read",
"request": {
- "method": "POST",
+ "auth": {
+ "type": "noauth"
+ },
+ "method": "GET",
"header": [
+ {
+ "key": "Content-Type",
+ "value": "application/json"
+ },
{
"key": "X-auth-token",
- "value": " {{token}}",
- "type": "text"
+ "value": "{{token}}"
}
],
"url": {
- "raw": "{{UserDevBaseUrl}}mentoring/v1/role-permission-mapping/list",
- "host": ["{{UserDevBaseUrl}}mentoring"],
- "path": ["v1", "role-permission-mapping", "list"]
+ "raw": "{{UserDevBaseUrl}}user/v1/tenant/read/default",
+ "host": ["{{UserDevBaseUrl}}user"],
+ "path": ["v1", "tenant", "read", "default"]
}
},
"response": []
- }
- ]
- },
- {
- "name": "Public",
- "item": [
+ },
{
- "name": "Branding",
+ "name": "Tenant read(internal)",
"request": {
+ "auth": {
+ "type": "noauth"
+ },
"method": "GET",
"header": [
{
- "key": "X-auth-token",
- "value": " {{token}}"
+ "key": "Content-Type",
+ "value": "application/json"
+ },
+ {
+ "key": "internal_access_token",
+ "value": "{{internal_access_token}}",
+ "type": "text"
}
],
"url": {
- "raw": "{{UserDevBaseUrl}}/user/v1/public/branding",
- "host": ["{{UserDevBaseUrl}}"],
- "path": ["user", "v1", "public", "branding"],
- "query": [
- {
- "key": "org_code",
- "value": "default_code",
- "disabled": true
- }
- ]
+ "raw": "{{UserDevBaseUrl}}user/v1/tenant/readInternal/shikshalokam",
+ "host": ["{{UserDevBaseUrl}}user"],
+ "path": ["v1", "tenant", "readInternal", "shikshalokam"]
}
},
"response": []
},
{
- "name": "Public userInvites",
+ "name": "Tenant List",
"request": {
+ "auth": {
+ "type": "noauth"
+ },
"method": "GET",
"header": [
+ {
+ "key": "Content-Type",
+ "value": "application/json"
+ },
{
"key": "origin",
- "value": "{{origin}}"
+ "value": "localhost"
+ },
+ {
+ "key": "X-auth-token",
+ "value": "{{token}}"
}
],
"url": {
- "raw": "{{UserDevBaseUrl}}user/v1/public/userInvites?invitation_key=bfbaad67-a63a-44a2-804c-09c685233207",
+ "raw": "{{UserDevBaseUrl}}user/v1/tenant/list",
"host": ["{{UserDevBaseUrl}}user"],
- "path": ["v1", "public", "userInvites"],
- "query": [
- {
- "key": "invitation_key",
- "value": "bfbaad67-a63a-44a2-804c-09c685233207"
- }
- ]
- },
- "description": "Generated from cURL: curl --location 'http://localhost:3001/user/v1/public/userInvites?invitation_key=bfbaad67-a63a-44a2-804c-09c685233207' \\\n--header 'origin: shikshagraha-qa.tekdinext.com'"
+ "path": ["v1", "tenant", "list"]
+ }
},
"response": []
}
]
},
{
- "name": "Tenant",
+ "name": "Health",
"item": [
{
- "name": "Tenant Create or Update",
+ "name": "New Request",
"request": {
- "method": "POST",
+ "method": "GET",
+ "header": [],
+ "url": {
+ "raw": "{{UserDevBaseUrl}}user/health",
+ "host": ["{{UserDevBaseUrl}}user"],
+ "path": ["health"]
+ }
+ },
+ "response": []
+ }
+ ]
+ },
+ {
+ "name": "Feature",
+ "item": [
+ {
+ "name": "Delete Feature",
+ "request": {
+ "method": "DELETE",
"header": [
{
- "key": "Content-Type",
- "value": "application/json"
+ "key": "X-auth-token",
+ "value": "{{token}}"
},
{
- "key": "origin",
- "value": "https://dev.elevate-mentoring.shikshalokam.org"
+ "key": "content-type",
+ "value": "application/json"
+ }
+ ],
+ "url": {
+ "raw": "{{UserDevBaseUrl}}user/v1/feature/delete/high",
+ "host": ["{{UserDevBaseUrl}}user"],
+ "path": ["v1", "feature", "delete", "high"]
+ }
+ },
+ "response": []
+ },
+ {
+ "name": "Create Feature",
+ "request": {
+ "auth": {
+ "type": "noauth"
+ },
+ "method": "POST",
+ "header": [
+ {
+ "key": "internal_access_token",
+ "value": "{{internal_access_token}}",
+ "type": "text",
+ "disabled": true
},
{
"key": "X-auth-token",
- "value": " {{token}}"
+ "value": "{{token}}",
+ "type": "text"
}
],
"body": {
"mode": "raw",
- "raw": "{\n \"name\": \"Test\",\n \"code\": \"test\",\n \"description\": \"Test domain\",\n \"logo\": \"\",\n \"theming\": {},\n \"meta\": {},\n \"domains\": \"https://test.123.domain.com\"\n}",
+ "raw": "{\n \"code\": \"mithra\",\n \"label\": \"Mithra\"\n}",
"options": {
"raw": {
"language": "json"
@@ -2452,16 +5509,15 @@
}
},
"url": {
- "raw": "{{UserDevBaseUrl}}/user/v1/tenant/update",
- "host": ["{{UserDevBaseUrl}}"],
- "path": ["user", "v1", "tenant", "update"]
- },
- "description": "Generated from cURL: curl --location 'https://saas-qa.tekdinext.com/user/v1/tenant/update' \\\n--header 'Content-Type: application/json' \\\n--header 'origin: https://dev.elevate-mentoring.shikshalokam.org' \\\n--header 'X-auth-token: {{token}}' \\\n--data '{\n \"name\": \"Test\",\n \"code\": \"test\",\n \"description\": \"Test domain\",\n \"logo\": \"\",\n \"theming\": {},\n \"meta\": {},\n \"domains\": \"https://test.123.domain.com\"\n}'"
+ "raw": "{{UserDevBaseUrl}}user/v1/feature/update",
+ "host": ["{{UserDevBaseUrl}}user"],
+ "path": ["v1", "feature", "update"]
+ }
},
"response": []
},
{
- "name": "Tenant add domain",
+ "name": "Update Feature",
"request": {
"auth": {
"type": "noauth"
@@ -2469,21 +5525,20 @@
"method": "POST",
"header": [
{
- "key": "Content-Type",
- "value": "application/json"
- },
- {
- "key": "origin",
- "value": "https://dev.elevate-mentoring.shikshalokam.org"
+ "key": "internal_access_token",
+ "value": "{{internal_access_token}}",
+ "type": "text",
+ "disabled": true
},
{
"key": "X-auth-token",
- "value": " {{token}}"
+ "value": "{{token}}",
+ "type": "text"
}
],
"body": {
"mode": "raw",
- "raw": "{\n \"domains\" : [\"https://test.2.domain.com\"]\n}",
+ "raw": "{\n\n \"label\": \"HIGH\",\n \"description\": \"heyy\"\n \n}",
"options": {
"raw": {
"language": "json"
@@ -2491,37 +5546,75 @@
}
},
"url": {
- "raw": "{{UserDevBaseUrl}}/user/v1/tenant/addDomain/test",
- "host": ["{{UserDevBaseUrl}}"],
- "path": ["user", "v1", "tenant", "addDomain", "test"]
+ "raw": "{{UserDevBaseUrl}}user/v1/feature/update/high",
+ "host": ["{{UserDevBaseUrl}}user"],
+ "path": ["v1", "feature", "update", "high"]
}
},
"response": []
},
{
- "name": "Tenant remove Domain",
+ "name": "List Feature",
"request": {
"auth": {
"type": "noauth"
},
- "method": "POST",
+ "method": "GET",
"header": [
{
- "key": "Content-Type",
- "value": "application/json"
+ "key": "X-auth-token",
+ "value": "{{token}}"
},
{
- "key": "origin",
- "value": "https://dev.elevate-mentoring.shikshalokam.org"
+ "key": "internal_access_token",
+ "value": "{{internal_access_token}}",
+ "disabled": true
+ }
+ ],
+ "url": {
+ "raw": "{{UserDevBaseUrl}}user/v1/feature/list?search=",
+ "host": ["{{UserDevBaseUrl}}user"],
+ "path": ["v1", "feature", "list"],
+ "query": [
+ {
+ "key": "search",
+ "value": ""
+ }
+ ]
+ }
+ },
+ "response": []
+ }
+ ]
+ },
+ {
+ "name": "Organization Feature",
+ "item": [
+ {
+ "name": "Create Org Feature",
+ "request": {
+ "method": "POST",
+ "header": [
+ {
+ "key": "internal_access_token",
+ "value": "{{internal_access_token}}",
+ "type": "text",
+ "disabled": true
},
{
"key": "X-auth-token",
- "value": " {{token}}"
+ "value": "{{token}}",
+ "type": "text"
+ },
+ {
+ "key": "organizationcode",
+ "value": "shikshagraha",
+ "type": "text"
}
],
"body": {
"mode": "raw",
- "raw": "{\n \"domains\" : [\"https://test.2.domain.com\"]\n}",
+ "raw": "{\n \"feature_code\": \"mithra\",\n \"feature_name\": \"Mithra\"\n}",
"options": {
"raw": {
"language": "json"
@@ -2529,38 +5622,37 @@
}
},
"url": {
- "raw": "{{UserDevBaseUrl}}/user/v1/tenant/removeDomain/test",
- "host": ["{{UserDevBaseUrl}}"],
- "path": ["user", "v1", "tenant", "removeDomain", "test"]
+ "raw": "{{UserDevBaseUrl}}user/v1/organization-feature/create",
+ "host": ["{{UserDevBaseUrl}}user"],
+ "path": ["v1", "organization-feature", "create"]
}
},
"response": []
},
{
- "name": "User Bulk Upload",
+ "name": "Update Org Feature",
"request": {
- "method": "POST",
+ "method": "PATCH",
"header": [
- {
- "key": "Content-Type",
- "value": "application/json"
- },
{
"key": "X-auth-token",
- "value": "{{token}}"
+ "value": "{{token}}",
+ "type": "text"
},
{
- "key": "tenant",
- "value": "{{tenant_code}}"
+ "key": "organizationcode",
+ "value": "default_code",
+ "type": "text"
},
{
- "key": "organization",
- "value": "{{org_code}}"
+ "key": "tenantcode",
+ "value": "shikshalokam",
+ "type": "text"
}
],
"body": {
"mode": "raw",
- "raw": "{\n \"file_path\" : \"users/1-1749801919492-bulkupload.csv\",\n \"editable_fields\" : [\"name\"]\n}",
+ "raw": "{\n \"enabled\": true,\n \"feature_name\": \"Mitra\",\n \"meta\": {\n \"url\": \"https://dev.elevate-mitra.shikshalokam.org/mohini/sso?accToken=\",\n \"icon\": \"/assets/images/ic_mitra.svg\",\n \"theme\": {\n \"primaryColor\": \"#572E91\",\n \"secondaryColor\": \"#FF9911\"\n },\n \"title\": \"MITRA\",\n \"sameOrigin\": true\n }\n}",
"options": {
"raw": {
"language": "json"
@@ -2568,91 +5660,153 @@
}
},
"url": {
- "raw": "{{UserDevBaseUrl}}user/v1/tenant/bulkUserCreate",
+ "raw": "{{UserDevBaseUrl}}user/v1/organization-feature/update/mitra",
"host": ["{{UserDevBaseUrl}}user"],
- "path": ["v1", "tenant", "bulkUserCreate"]
- },
- "description": "Generated from cURL: curl --location 'http://localhost:3001/user/v1/tenant/bulkUserCreate' \\\n--header 'Content-Type: application/json' \\\n--header 'X-auth-token: {{token}}' \\\n--header 'tenant: shikshagraha' \\\n--header 'organization: blr' \\\n--data '{\n \"file_path\" : \"users/1-1749801919492-bulkupload.csv\",\n \"editable_fields\" : [\"name\"]\n}'"
+ "path": ["v1", "organization-feature", "update", "mitra"]
+ }
},
"response": []
},
{
- "name": "Tenant Read",
+ "name": "List Org Feature",
"request": {
- "auth": {
- "type": "noauth"
- },
"method": "GET",
"header": [
{
- "key": "Content-Type",
- "value": "application/json"
+ "key": "X-auth-token",
+ "value": "{{token}}"
},
{
- "key": "origin",
- "value": "https://dev.elevate-mentoring.shikshalokam.org"
+ "key": "internal_access_token",
+ "value": "{{internal_access_token}}",
+ "disabled": true
},
{
- "key": "X-auth-token",
- "value": " {{token}}"
+ "key": "organizationcode",
+ "value": "default_code",
+ "description": "default_code",
+ "type": "text"
+ },
+ {
+ "key": "tenantcode",
+ "value": "shikshalokam",
+ "type": "text"
}
],
"url": {
- "raw": "{{UserDevBaseUrl}}/user/v1/tenant/read/test",
- "host": ["{{UserDevBaseUrl}}"],
- "path": ["user", "v1", "tenant", "read", "test"]
+ "raw": "{{UserDevBaseUrl}}user/v1/organization-feature/read",
+ "host": ["{{UserDevBaseUrl}}user"],
+ "path": ["v1", "organization-feature", "read"]
}
},
"response": []
},
{
- "name": "Tenant List",
+ "name": "Delete Org Feature",
"request": {
- "auth": {
- "type": "noauth"
- },
- "method": "GET",
+ "method": "DELETE",
"header": [
{
- "key": "Content-Type",
- "value": "application/json"
- },
- {
- "key": "origin",
- "value": "https://dev.elevate-mentoring.shikshalokam.org"
+ "key": "X-auth-token",
+ "value": "eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJkYXRhIjp7ImlkIjoyLCJuYW1lIjoiUHJpeWFua2EiLCJzZXNzaW9uX2lkIjo2LCJvcmdhbml6YXRpb25faWRzIjpbIjEiXSwib3JnYW5pemF0aW9uX2NvZGVzIjpbImRlZmF1bHQiXSwidGVuYW50X2NvZGUiOiJkZWZhdWx0Iiwib3JnYW5pemF0aW9ucyI6W3siaWQiOjEsIm5hbWUiOiJEZWZhdWx0IE9yZ2FuaXphdGlvbiIsImNvZGUiOiJkZWZhdWx0IiwiZGVzY3JpcHRpb24iOiJEZWZhdWx0IE9yZ2FuaXNhdGlvbiIsInN0YXR1cyI6IkFDVElWRSIsInJlbGF0ZWRfb3JncyI6bnVsbCwidGVuYW50X2NvZGUiOiJkZWZhdWx0IiwibWV0YSI6bnVsbCwiY3JlYXRlZF9ieSI6bnVsbCwidXBkYXRlZF9ieSI6bnVsbCwicm9sZXMiOlt7ImlkIjo1LCJ0aXRsZSI6Im1lbnRlZSIsImxhYmVsIjpudWxsLCJ1c2VyX3R5cGUiOjAsInN0YXR1cyI6IkFDVElWRSIsIm9yZ2FuaXphdGlvbl9pZCI6MSwidmlzaWJpbGl0eSI6IlBVQkxJQyIsInRlbmFudF9jb2RlIjoiZGVmYXVsdCIsInRyYW5zbGF0aW9ucyI6bnVsbH0seyJpZCI6NiwidGl0bGUiOiJhZG1pbiIsImxhYmVsIjpudWxsLCJ1c2VyX3R5cGUiOjEsInN0YXR1cyI6IkFDVElWRSIsIm9yZ2FuaXphdGlvbl9pZCI6MSwidmlzaWJpbGl0eSI6IlBVQkxJQyIsInRlbmFudF9jb2RlIjoiZGVmYXVsdCIsInRyYW5zbGF0aW9ucyI6bnVsbH1dfV19LCJpYXQiOjE3NDg4NjU1MjgsImV4cCI6MzU0ODg2NTUyOH0.CEYacOe-nJoFICsH3kMgGRfrftS-W0vRW2m7Y0cprtg"
},
{
- "key": "X-auth-token",
- "value": " {{token}}"
+ "key": "content-type",
+ "value": "application/json"
}
],
"url": {
- "raw": "{{UserDevBaseUrl}}/user/v1/tenant/list",
- "host": ["{{UserDevBaseUrl}}"],
- "path": ["user", "v1", "tenant", "list"]
+ "raw": "{{UserDevBaseUrl}}user/v1/organization-feature/update/3",
+ "host": ["{{UserDevBaseUrl}}user"],
+ "path": ["v1", "organization-feature", "update", "3"]
}
},
"response": []
}
]
+ }
+ ],
+ "event": [
+ {
+ "listen": "prerequest",
+ "script": {
+ "type": "text/javascript",
+ "packages": {},
+ "exec": [
+ "// Check if overrides should be enabled (toggle via environment variable)",
+ "const useOverrides = pm.environment.get('admin_use_overrides') === 'true';",
+ "",
+ "if (useOverrides) {",
+ " // Get values from environment variables",
+ " const orgCode = pm.environment.get('admin_org_code');",
+ " const tenantCode = pm.environment.get('admin_tenant_code');",
+ "",
+ " // Validate: If any is set, ensure all are provided (mirrors your middleware logic)",
+ " if (orgCode || tenantCode) {",
+ " /* if (!orgId || !orgCode || !tenantCode) {",
+ " console.log('Warning: Partial overrides detected. All three must be set in environment.');",
+ " // Optionally, throw to halt: throw new Error('All override values required');",
+ " } else { */",
+ " // Add headers dynamically",
+ " console.log('Replacing.....');",
+ "",
+ " pm.request.headers.add({",
+ " key: 'X-Org-Code',",
+ " value: orgCode",
+ " });",
+ " pm.request.headers.add({",
+ " key: 'X-Tenant-Code',",
+ " value: tenantCode",
+ " });",
+ " console.log('Admin override headers added successfully.');",
+ " // }",
+ " }",
+ "} else {",
+ " console.log('Admin overrides disabled—no extra headers added.');",
+ "}"
+ ]
+ }
},
{
- "name": "Health Check",
- "item": [
- {
- "name": "health",
- "request": {
- "method": "GET",
- "header": [],
- "url": {
- "raw": "{{UserDevBaseUrl}}/user/health",
- "host": ["{{UserDevBaseUrl}}"],
- "path": ["user", "health"]
- }
- },
- "response": []
- }
- ]
+ "listen": "test",
+ "script": {
+ "type": "text/javascript",
+ "packages": {},
+ "exec": [""]
+ }
+ }
+ ],
+ "variable": [
+ {
+ "key": "UserDevBaseUrl",
+ "value": "https://saas-qa.tekdinext.com/",
+ "type": "string"
+ },
+ {
+ "key": "token",
+ "value": "",
+ "type": "string"
+ },
+ {
+ "key": "MAILSLURP_KEY",
+ "value": "",
+ "type": "string",
+ "disabled": true
+ },
+ {
+ "key": "inboxId",
+ "value": "",
+ "disabled": true
+ },
+ {
+ "key": "emailAddress",
+ "value": "",
+ "disabled": true
+ },
+ {
+ "key": "otp",
+ "value": "",
+ "disabled": true
}
]
}
diff --git a/src/configs/kafka.js b/src/configs/kafka.js
index 6e4017d6..e46db1db 100644
--- a/src/configs/kafka.js
+++ b/src/configs/kafka.js
@@ -14,37 +14,65 @@ const { elevateLog } = require('elevate-logger')
const logger = elevateLog.init()
module.exports = async () => {
+ console.log('🚀 [USER SERVICE KAFKA] ===== STARTING KAFKA CONFIGURATION =====')
+ console.log('🚀 [USER SERVICE KAFKA] Environment variables:')
+ console.log('🚀 [USER SERVICE KAFKA] KAFKA_URL:', process.env.KAFKA_URL)
+ console.log('🚀 [USER SERVICE KAFKA] KAFKA_GROUP_ID:', process.env.KAFKA_GROUP_ID)
+ console.log('🚀 [USER SERVICE KAFKA] EVENT_USER_KAFKA_TOPIC:', process.env.EVENT_USER_KAFKA_TOPIC)
+ console.log('🚀 [USER SERVICE KAFKA] CLEAR_INTERNAL_CACHE:', process.env.CLEAR_INTERNAL_CACHE)
+
const kafkaIps = process.env.KAFKA_URL.split(',')
+ console.log('🚀 [USER SERVICE KAFKA] Kafka brokers:', kafkaIps)
+
const KafkaClient = new Kafka({
- clientId: 'mentoring',
+ clientId: 'user-service',
brokers: kafkaIps,
})
+ console.log('🚀 [USER SERVICE KAFKA] Creating producer and consumer...')
const producer = KafkaClient.producer()
const consumer = KafkaClient.consumer({ groupId: process.env.KAFKA_GROUP_ID })
+ console.log('🚀 [USER SERVICE KAFKA] Connecting producer...')
await producer.connect()
+ console.log('🚀 [USER SERVICE KAFKA] ✅ Producer connected successfully')
+
+ console.log('🚀 [USER SERVICE KAFKA] Connecting consumer...')
await consumer.connect()
+ console.log('🚀 [USER SERVICE KAFKA] ✅ Consumer connected successfully')
producer.on('producer.connect', () => {
logger.info(`KafkaProvider: connected`)
+ console.log('🚀 [USER SERVICE KAFKA] Producer event: connected')
})
producer.on('producer.disconnect', () => {
logger.error(`KafkaProvider: could not connect`, {
triggerNotification: true,
})
+ console.log('🚀 [USER SERVICE KAFKA] Producer event: disconnected')
})
const subscribeToConsumer = async () => {
- await consumer.subscribe({ topics: [process.env.CLEAR_INTERNAL_CACHE] })
+ console.log('🚀 [USER SERVICE KAFKA] Setting up consumer subscriptions...')
+ const topics = [process.env.CLEAR_INTERNAL_CACHE].filter(Boolean)
+ console.log('🚀 [USER SERVICE KAFKA] Subscribing to topics:', topics)
+
+ await consumer.subscribe({ topics })
await consumer.run({
eachMessage: async ({ topic, partition, message }) => {
try {
+ console.log('🚀 [USER SERVICE KAFKA] Cache clear message received:', {
+ topic,
+ partition,
+ offset: message.offset
+ })
let streamingData = JSON.parse(message.value)
if (streamingData.type == 'CLEAR_INTERNAL_CACHE') {
+ console.log('🚀 [USER SERVICE KAFKA] Processing cache clear for:', streamingData.value)
utils.internalDel(streamingData.value)
}
} catch (error) {
+ console.log('🚀 [USER SERVICE KAFKA] ❌ Consumer error:', error.message)
logger.error('Subscribe to consumer failed:' + error, {
triggerNotification: true,
})
@@ -52,8 +80,13 @@ module.exports = async () => {
},
})
}
+
+ console.log('🚀 [USER SERVICE KAFKA] Starting consumer subscriptions...')
subscribeToConsumer()
+ console.log('🚀 [USER SERVICE KAFKA] Setting global variables...')
global.kafkaProducer = producer
global.kafkaClient = KafkaClient
+
+ console.log('🚀 [USER SERVICE KAFKA] ===== KAFKA CONFIGURATION COMPLETED =====')
}
diff --git a/src/controllers/v1/account.js b/src/controllers/v1/account.js
index ab01de63..e059b0b0 100644
--- a/src/controllers/v1/account.js
+++ b/src/controllers/v1/account.js
@@ -40,6 +40,7 @@ module.exports = class Account {
}
const device_info = req.headers && req.headers['device-info'] ? JSON.parse(req.headers['device-info']) : {}
+
try {
const createdAccount = await accountService.create(params, device_info, domain)
return createdAccount
diff --git a/src/envVariables.js b/src/envVariables.js
index 1e8a3208..2fca2daf 100644
--- a/src/envVariables.js
+++ b/src/envVariables.js
@@ -511,6 +511,11 @@ let enviromentVariables = {
optional: true,
default: 'x-tenant-code',
},
+ SERVICE_NAME: {
+ message: 'Required SERVICE_NAME',
+ optional: true,
+ default: 'UserService',
+ },
}
let success = true
diff --git a/src/generics/kafka-communication.js b/src/generics/kafka-communication.js
index 6fd9ce8d..f2b97ab9 100644
--- a/src/generics/kafka-communication.js
+++ b/src/generics/kafka-communication.js
@@ -17,10 +17,42 @@ const pushEmailToKafka = async (message) => {
const pushUserEventsToKafka = async (message) => {
try {
- const payload = { topic: process.env.EVENT_USER_KAFKA_TOPIC, messages: [{ value: JSON.stringify(message) }] }
- return await pushPayloadToKafka(payload)
+ console.log('📤 [USER KAFKA PRODUCER] ===== KAFKA USER EVENT DETAILS =====')
+ console.log('📤 [USER KAFKA PRODUCER] Target Topic:', process.env.EVENT_USER_KAFKA_TOPIC)
+ console.log('📤 [USER KAFKA PRODUCER] Kafka Producer Status:', kafkaProducer ? 'Connected' : 'Not Connected')
+ console.log('📤 [USER KAFKA PRODUCER] Message Details:')
+ console.log('📤 [USER KAFKA PRODUCER] Entity:', message.entity)
+ console.log('📤 [USER KAFKA PRODUCER] Event Type:', message.eventType)
+ console.log('📤 [USER KAFKA PRODUCER] Entity ID:', message.entityId)
+ console.log('📤 [USER KAFKA PRODUCER] Tenant Code:', message.tenant_code)
+ console.log('📤 [USER KAFKA PRODUCER] Created By:', message.created_by)
+ console.log('📤 [USER KAFKA PRODUCER] Organizations:', message.organizations?.length || 0, 'orgs')
+
+ const messageString = JSON.stringify(message)
+ console.log('📤 [USER KAFKA PRODUCER] Payload Size:', messageString.length, 'bytes')
+ console.log('📤 [USER KAFKA PRODUCER] First 200 chars:', messageString.substring(0, 200) + '...')
+
+ const payload = { topic: process.env.EVENT_USER_KAFKA_TOPIC, messages: [{ value: messageString }] }
+ console.log('📤 [USER KAFKA PRODUCER] Kafka Payload Prepared:')
+ console.log('📤 [USER KAFKA PRODUCER] Topic:', payload.topic)
+ console.log('📤 [USER KAFKA PRODUCER] Messages Count:', payload.messages.length)
+
+ console.log('📤 [USER KAFKA PRODUCER] Sending to Kafka...')
+ const response = await pushPayloadToKafka(payload)
+
+ console.log('📤 [USER KAFKA PRODUCER] ✅ Kafka Response Received:')
+ console.log('📤 [USER KAFKA PRODUCER] Success:', response ? 'Yes' : 'No')
+ if (response && response[0]) {
+ console.log('📤 [USER KAFKA PRODUCER] Topic:', response[0].topicName)
+ console.log('📤 [USER KAFKA PRODUCER] Partition:', response[0].partition)
+ console.log('📤 [USER KAFKA PRODUCER] Offset:', response[0].baseOffset)
+ }
+ console.log('📤 [USER KAFKA PRODUCER] ===== KAFKA USER EVENT COMPLETED =====')
+
+ return response
} catch (error) {
- console.log(error)
+ console.log('📤 [USER KAFKA PRODUCER] ❌ ERROR in pushUserEventsToKafka:', error.message)
+ console.log('📤 [USER KAFKA PRODUCER] ❌ Error stack:', error.stack)
return error
}
}
@@ -50,9 +82,41 @@ const pushOrganizationEventsToKafka = async (message) => {
const pushPayloadToKafka = async (payload) => {
try {
+ console.log('📤 [KAFKA PRODUCER] ===== SENDING PAYLOAD TO KAFKA =====')
+ console.log('📤 [KAFKA PRODUCER] Producer Ready:', !!kafkaProducer)
+ console.log('📤 [KAFKA PRODUCER] Payload Topic:', payload.topic)
+ console.log('📤 [KAFKA PRODUCER] Message Count:', payload.messages.length)
+ console.log('📤 [KAFKA PRODUCER] Kafka Brokers:', process.env.KAFKA_URL || 'Not configured')
+
+ console.log('📤 [KAFKA PRODUCER] Calling kafkaProducer.send()...')
+ const startTime = Date.now()
let response = await kafkaProducer.send(payload)
+ const endTime = Date.now()
+
+ console.log('📤 [KAFKA PRODUCER] ✅ Kafka Send Completed:')
+ console.log('📤 [KAFKA PRODUCER] Duration:', endTime - startTime, 'ms')
+ console.log('📤 [KAFKA PRODUCER] Response Type:', typeof response)
+ console.log('📤 [KAFKA PRODUCER] Response Array Length:', Array.isArray(response) ? response.length : 'Not an array')
+
+ if (response && Array.isArray(response) && response.length > 0) {
+ response.forEach((result, index) => {
+ console.log(`📤 [KAFKA PRODUCER] Result ${index}:`)
+ console.log(`📤 [KAFKA PRODUCER] Topic: ${result.topicName}`)
+ console.log(`📤 [KAFKA PRODUCER] Partition: ${result.partition}`)
+ console.log(`📤 [KAFKA PRODUCER] Base Offset: ${result.baseOffset}`)
+ console.log(`📤 [KAFKA PRODUCER] Log Start Offset: ${result.logStartOffset}`)
+ })
+ }
+ console.log('📤 [KAFKA PRODUCER] ===== KAFKA SEND COMPLETED =====')
+
return response
} catch (error) {
+ console.log('📤 [KAFKA PRODUCER] ❌ ERROR in pushPayloadToKafka:', error.message)
+ console.log('📤 [KAFKA PRODUCER] ❌ Error details:', {
+ name: error.name,
+ code: error.code,
+ stack: error.stack?.split('\n').slice(0, 3).join('\n')
+ })
return error
}
}
diff --git a/src/health-checks/health-check.js b/src/health-checks/health-check.js
index 747c7259..0be924dc 100644
--- a/src/health-checks/health-check.js
+++ b/src/health-checks/health-check.js
@@ -9,16 +9,21 @@
const { healthCheckHandler } = require('elevate-services-health-check')
const healthCheckConfig = require('./health.config')
const { v1: uuidv1 } = require('uuid')
+const packageFile = require('../package.json')
let health_check = async function (req, res) {
try {
- const response = await healthCheckHandler(healthCheckConfig, req.query.basicCheck, req.query.serviceName)
+ const response = await healthCheckHandler(
+ healthCheckConfig,
+ req.query.basicCheck,
+ req.query.serviceName,
+ packageFile.version
+ )
res.status(200).json(response)
} catch (err) {
console.error('Health config validation failed:', err.message || err)
res.status(400).json({
id: 'userService.Health.API',
- ver: '1.0',
ts: new Date(),
params: {
resmsgid: uuidv1(),
@@ -41,7 +46,6 @@ let healthCheckStatus = function (req, res) {
let response = function (req, result) {
return {
id: 'User.service.Health.API',
- ver: '1.0',
ts: new Date(),
params: {
resmsgid: uuidv1(),
diff --git a/src/health-checks/health.config.js b/src/health-checks/health.config.js
index 4d0b1bf2..fcd30d25 100644
--- a/src/health-checks/health.config.js
+++ b/src/health-checks/health.config.js
@@ -7,7 +7,6 @@
module.exports = {
name: process.env.SERVICE_NAME,
- version: '1.0.0',
checks: {
kafka: {
enabled: true,
diff --git a/src/helpers/eventBroadcasterMain.js b/src/helpers/eventBroadcasterMain.js
index 1e832f35..86270263 100644
--- a/src/helpers/eventBroadcasterMain.js
+++ b/src/helpers/eventBroadcasterMain.js
@@ -27,11 +27,13 @@ const isEventEnabled = (eventGroup) => {
case 'organizationEvents':
return process.env.EVENT_ENABLE_ORG_EVENTS !== 'false'
case 'userEvents':
- return process.env.EVENT_ENABLE_USER_EVENTS !== 'false'
+ const apiEnabled = process.env.EVENT_ENABLE_USER_EVENTS !== 'false'
+ return apiEnabled
case 'tenantEvents':
return process.env.EVENT_ENABLE_TENANT_EVENTS !== 'false'
case 'userEvents-kafka':
- return process.env.EVENT_ENABLE_USER_KAFKA_EVENTS !== 'false'
+ const kafkaEnabled = process.env.EVENT_ENABLE_USER_KAFKA_EVENTS !== 'false'
+ return kafkaEnabled
case 'tenantEvents-kafka':
return process.env.EVENT_ENABLE_TENANT_KAFKA_EVENTS !== 'false'
case 'organizationEvents-kafka':
@@ -43,7 +45,6 @@ const isEventEnabled = (eventGroup) => {
exports.eventBroadcasterMain = async (eventGroup, { requestBody, headers = {}, isInternal = true }) => {
try {
- console.log('API Event ')
if (!requestBody) throw new Error('Event Body Generation Failed')
if (!isEventEnabled(eventGroup)) throw new Error(`Events Not Enabled For The Group "${eventGroup}"`)
if (isInternal) headers.internal_access_token = process.env.INTERNAL_ACCESS_TOKEN
@@ -52,13 +53,12 @@ exports.eventBroadcasterMain = async (eventGroup, { requestBody, headers = {}, i
return requester.post(endPoint, '', headers, requestBody)
})
const results = await Promise.allSettled(requestPromises)
- console.log('PROMISE ------->>> ', results)
results.forEach((result, index) => {
if (result.status === 'rejected')
console.error(`Error for endpoint ${endPoints[index].url}:`, result.reason)
})
} catch (err) {
- console.log(err)
+ console.log(`[EVENT BROADCASTER] API Event error: ${err.message}`)
}
}
exports.eventBroadcasterKafka = async (eventGroup, { requestBody }) => {
@@ -78,17 +78,14 @@ exports.eventBroadcasterKafka = async (eventGroup, { requestBody }) => {
await kafkaCommunication.pushTenantEventsToKafka(requestBody)
break
default:
- console.log('No Kafka Event Group Found')
break
}
} catch (err) {
- console.log(err)
+ console.log(`[EVENT BROADCASTER] Kafka Event error: ${err.message}`)
}
}
exports.broadcastEvent = async (eventGroup, { requestBody, headers = {}, isInternal = true }) => {
try {
- //TODO: Remove this log after testing
- console.log(util.inspect(requestBody, { depth: null, colors: true, compact: false }))
// Fire both broadcaster functions concurrently
const broadcastPromises = [
@@ -102,12 +99,13 @@ exports.broadcastEvent = async (eventGroup, { requestBody, headers = {}, isInter
// Check for failed promises and throw warnings
results.forEach((result, index) => {
if (result.status === 'rejected') {
- const broadcaster = index === 0 ? 'eventBroadcasterMain' : 'eventBroadcasterKafka'
- console.warn(`Warning: ${broadcaster} failed for eventGroup "${eventGroup}": ${result.reason}`)
+ const broadcaster = index === 0 ? 'eventBroadcasterMain (API)' : 'eventBroadcasterKafka'
+ } else {
+ const broadcaster = index === 0 ? 'eventBroadcasterMain (API)' : 'eventBroadcasterKafka'
}
})
} catch (err) {
// Log any unexpected errors from the promise settlement
- console.error('Error in broadcastEvent:', err)
+ console.error('[EVENT BROADCASTER] Error in broadcastEvent:', err)
}
}
diff --git a/src/package.json b/src/package.json
index 10b60fc5..e541c3a4 100644
--- a/src/package.json
+++ b/src/package.json
@@ -1,6 +1,6 @@
{
"name": "com.shikshalokam.mentoring.userservice",
- "version": "1.0.0",
+ "version": "3.3.24",
"description": "A user service for mentoring capability",
"main": "app.js",
"bin": {
@@ -45,7 +45,7 @@
"elevate-encryption": "^1.0.1",
"elevate-logger": "^3.1.0",
"elevate-node-cache": "^1.0.6",
- "elevate-services-health-check": "^0.0.6",
+ "elevate-services-health-check": "^0.0.9",
"email-validator": "^2.0.4",
"express": "^4.17.1",
"express-fileupload": "^1.2.1",
diff --git a/src/services/account.js b/src/services/account.js
index 88d9b71e..33c8afe1 100644
--- a/src/services/account.js
+++ b/src/services/account.js
@@ -67,6 +67,7 @@ module.exports = class AccountHelper {
})
const tenantDomain = await tenantDomainQueries.findOne({ domain })
+
if (!tenantDomain) {
return notFoundResponse('TENANT_DOMAIN_NOT_FOUND_PING_ADMIN')
}
@@ -75,6 +76,7 @@ module.exports = class AccountHelper {
code: tenantDomain.tenant_code,
status: common.ACTIVE_STATUS,
})
+
if (!tenantDetail) {
return notFoundResponse('TENANT_NOT_FOUND_PING_ADMIN')
}
@@ -102,6 +104,7 @@ module.exports = class AccountHelper {
responseCode: 'CLIENT_ERROR',
})
}
+ } else {
}
// Handle email encryption if provided
@@ -109,8 +112,12 @@ module.exports = class AccountHelper {
let plaintextEmailId = null
if (bodyData.email) {
plaintextEmailId = bodyData.email.toLowerCase()
- encryptedEmailId = emailEncryption.encrypt(plaintextEmailId)
- bodyData.email = encryptedEmailId
+ try {
+ encryptedEmailId = emailEncryption.encrypt(plaintextEmailId)
+ bodyData.email = encryptedEmailId
+ } catch (encryptError) {
+ throw encryptError
+ }
}
// Handle phone encryption if provided
@@ -118,9 +125,13 @@ module.exports = class AccountHelper {
let plaintextPhoneNumber = null
if (bodyData.phone && bodyData.phone_code) {
plaintextPhoneNumber = bodyData.phone
- encryptedPhoneNumber = emailEncryption.encrypt(plaintextPhoneNumber)
- bodyData.phone = encryptedPhoneNumber
- bodyData.phone_code = bodyData.phone_code // Store phone_code separately
+ try {
+ encryptedPhoneNumber = emailEncryption.encrypt(plaintextPhoneNumber)
+ bodyData.phone = encryptedPhoneNumber
+ bodyData.phone_code = bodyData.phone_code // Store phone_code separately
+ } catch (encryptError) {
+ throw encryptError
+ }
}
const criteria = []
@@ -624,13 +635,13 @@ module.exports = class AccountHelper {
broadcastEvent('userEvents', { requestBody: eventBody, isInternal: true })
+
return responses.successResponse({
statusCode: httpStatusCode.created,
message: 'USER_CREATED_SUCCESSFULLY',
result,
})
} catch (error) {
- console.log(error)
throw error
}
}
@@ -827,7 +838,6 @@ module.exports = class AccountHelper {
result,
})
} catch (error) {
- console.log(error)
throw error
}
}
@@ -870,7 +880,6 @@ module.exports = class AccountHelper {
message: 'LOGGED_OUT_SUCCESSFULLY',
})
} catch (error) {
- console.log(error)
throw error
}
}
@@ -1105,7 +1114,6 @@ module.exports = class AccountHelper {
message: 'OTP_SENT_SUCCESSFULLY',
})
} catch (error) {
- console.log(error)
throw error
}
}
@@ -1525,7 +1533,6 @@ module.exports = class AccountHelper {
result,
})
} catch (error) {
- console.log(error)
throw error
}
}
@@ -1677,7 +1684,6 @@ module.exports = class AccountHelper {
})
}
} catch (error) {
- console.log(error)
throw error
}
}
@@ -1709,7 +1715,6 @@ module.exports = class AccountHelper {
// Clear Redis cache asynchronously (fire and forget)
const redisUserKey = `${common.redisUserPrefix}${tenantCode}_${userId}`
utilsHelper.redisDel(redisUserKey).catch((err) => {
- console.error('Redis delete error:', err)
})
return responses.successResponse({
@@ -1829,7 +1834,6 @@ module.exports = class AccountHelper {
message: 'USER_ROLE_UPDATED_SUCCESSFULLY',
})
} catch (error) {
- console.log(error)
throw error
}
}
@@ -1933,7 +1937,6 @@ module.exports = class AccountHelper {
},
})
} catch (error) {
- console.log(error)
throw error
}
}
@@ -2032,7 +2035,6 @@ module.exports = class AccountHelper {
result,
})
} catch (error) {
- console.log(error)
throw error
}
}
@@ -2070,7 +2072,6 @@ module.exports = class AccountHelper {
user.email = emailEncryption.decrypt(user.email)
userIdsAndInvalidEmails.push(user.id)
} catch (err) {
- console.error(`Decryption failed for email: ${encryptedEmail}`, err)
const originalEmail = emailEncryption.decrypt(encryptedEmail)
userIdsAndInvalidEmails.push(originalEmail)
}
@@ -2079,7 +2080,6 @@ module.exports = class AccountHelper {
const originalEmail = emailEncryption.decrypt(encryptedEmail)
userIdsAndInvalidEmails.push(originalEmail)
} catch (err) {
- console.error(`Decryption failed for email: ${encryptedEmail}`, err)
userIdsAndInvalidEmails.push('Decryption failed')
}
}