Sunbird-Lern · sntiwari1 · Oct 7, 2025 · Oct 7, 2025 · Oct 7, 2025 · Oct 7, 2025
diff --git a/UPGRADE_README.md b/UPGRADE_README.md
@@ -0,0 +1,111 @@
+# Play Framework 3.0.5 and Apache Pekko 1.0.2 Upgrade
+
+## Overview
+
+This document describes the upgrade of userorg-service from Play Framework 2.7.2 with Akka 2.5.22 to Play Framework 3.0.5 with Apache Pekko 1.0.2.
+
+## Why This Upgrade
+
+1. License Compliance: Akka changed from Apache 2.0 to Business Source License 1.1, requiring commercial licenses for production use. Apache Pekko maintains Apache 2.0 license.
+2. Security: Play 2.7.2 and Akka 2.5.22 no longer receive security updates.
+3. Modernization: Access to latest features and performance improvements.
+
+## Technology Stack Changes
+
+- Play Framework: 2.7.2 to 3.0.5
+- Actor Framework: Akka 2.5.22 to Apache Pekko 1.0.2
+- Scala: 2.12.11 to 2.13.12
+- Guice: 3.0 to 5.1.0
+- SLF4J: 1.6.1 to 2.0.9
+- Logback: 1.2.3 to 1.4.14
+- Jackson: 2.13.5 to 2.14.3
+- Netty: 4.1.44 to 4.1.93
+
+## Key Changes
+
+### Dependencies
+
+All Maven POM files updated with new versions. Play Framework groupId changed from com.typesafe.play to org.playframework. Scala library exclusions added to prevent version conflicts between Scala 2.12 and 2.13.
+
+### Source Code
+
+329 Akka imports migrated to Pekko across 130+ Java files:
+- akka.actor.* to org.apache.pekko.actor.*
+- akka.pattern.* to org.apache.pekko.pattern.*
+- akka.routing.* to org.apache.pekko.routing.*
+- akka.util.* to org.apache.pekko.util.*
+- akka.testkit.* to org.apache.pekko.testkit.*
+
+### Configuration
+
+application.conf files updated with Pekko namespaces:
+- akka {} to pekko {}
+- Actor system configurations migrated
+- Serialization bindings updated
+- Dispatcher references changed
+
+### Play 3.0 API Updates
+
+- ActorStartModule: Implements play.libs.pekko.PekkoGuiceSupport
+- CustomGzipFilter: Updated to Play 3.0 filter API
+- ErrorHandler: Migrated exception handling to Pekko
+
+### Test Framework
+
+38+ test files updated:
+- Replaced JavaTestKit.duration() with java.time.Duration.ofSeconds()
+- Resolved Duration class ambiguity between java.time and scala.concurrent
+- Fixed import conflicts
+
+### Scala Version Conflicts
+
+Added exclusions to prevent Scala 2.12 transitive dependencies:
+- Excluded scala-library and scala-reflect from cloud-store-sdk in platform-common
+- Excluded scala-library and scala-reflect from platform-common and service dependencies in controller
+- Explicitly declared scala-library 2.13.12 dependency
+
+## Build Instructions
+
+Build all modules:
+```
+mvn clean install -Dmaven.test.skip=true
+```
+
+Build with test compilation:
+```
+mvn clean install -DskipTests
+```
+
+Create distribution package:
+```
+cd controller
+mvn play2:dist
+```
+
+## Migration Impact
+
+Business Logic: No changes to business logic or functionality
+API Compatibility: Maintained, as Pekko is API-compatible with Akka 2.6
+Code Changes: Primarily package name updates from akka to pekko
+License: Now compliant with Apache 2.0 throughout the stack
+
+## Testing Recommendations
+
+1. Execute full unit test suite
+2. Run integration tests for actor communication
+3. Perform regression testing for all features
+4. Conduct performance benchmarking
+5. Test under production-like load
+
+## Files Modified
+
+- POM files
+- Java source files
+- configuration files
+- test files
+
+## Known Issues
+
+Scala 2.12/2.13 Conflict: If you encounter NoClassDefFoundError for scala.collection.GenMap, verify dependency tree to ensure no Scala 2.12 artifacts are present. Run mvn dependency:tree and add exclusions for any scala-library or scala-reflect with version 2.12.
+
+Play 3 will automatically apply gzip based on the Accept-Encoding header. You don’t need a custom Java filter.
diff --git a/controller/app/controllers/BaseController.java b/controller/app/controllers/BaseController.java
@@ -5,10 +5,10 @@
 import static util.PrintEntryExitLog.printExitLogOnFailure;
 import static util.PrintEntryExitLog.printExitLogOnSuccessResponse;
 
-import akka.actor.ActorRef;
-import akka.actor.ActorSelection;
-import akka.pattern.PatternsCS;
-import akka.util.Timeout;
+import org.apache.pekko.actor.ActorRef;
+import org.apache.pekko.actor.ActorSelection;
+import org.apache.pekko.pattern.PatternsCS;
+import org.apache.pekko.util.Timeout;
 import com.fasterxml.jackson.core.type.TypeReference;
 import com.fasterxml.jackson.databind.JsonNode;
 import com.fasterxml.jackson.databind.ObjectMapper;
@@ -62,9 +62,9 @@ public class BaseController extends Controller {
   private static final LoggerUtil logger = new LoggerUtil(BaseController.class);
 
   private static final ObjectMapper objectMapper = new ObjectMapper();
-  public static final int AKKA_WAIT_TIME = 30;
+  public static final int PEKKO_WAIT_TIME = 30;
   private static final String version = "v1";
-  protected Timeout timeout = new Timeout(AKKA_WAIT_TIME, TimeUnit.SECONDS);
+  protected Timeout timeout = new Timeout(PEKKO_WAIT_TIME, TimeUnit.SECONDS);
   private static final String debugEnabled = "false";
 
   private org.sunbird.request.Request initRequest(
@@ -680,7 +680,7 @@ private static long calculateApiTimeTaken(Long startTime) {
   }
 
   /**
-   * This method will make a call to Akka actor and return CompletionStage.
+   * This method will make a call to Pekko actor and return CompletionStage.
    *
    * @param actorRef ActorSelection
    * @param request Request

diff --git a/controller/app/controllers/bulkapimanagement/BulkUploadController.java b/controller/app/controllers/bulkapimanagement/BulkUploadController.java
@@ -1,6 +1,6 @@
 package controllers.bulkapimanagement;
 
-import akka.actor.ActorRef;
+import org.apache.pekko.actor.ActorRef;
 import java.util.Map;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.CompletionStage;

diff --git a/controller/app/controllers/feed/FeedController.java b/controller/app/controllers/feed/FeedController.java
@@ -1,6 +1,6 @@
 package controllers.feed;
 
-import akka.actor.ActorRef;
+import org.apache.pekko.actor.ActorRef;
 import controllers.BaseController;
 import controllers.feed.validator.FeedRequestValidator;
 import java.util.concurrent.CompletionStage;

diff --git a/controller/app/controllers/healthmanager/HealthController.java b/controller/app/controllers/healthmanager/HealthController.java
@@ -1,7 +1,7 @@
 /** */
 package controllers.healthmanager;
 
-import akka.actor.ActorRef;
+import org.apache.pekko.actor.ActorRef;
 import controllers.BaseController;
 import java.util.ArrayList;
 import java.util.HashMap;

diff --git a/controller/app/controllers/location/LocationController.java b/controller/app/controllers/location/LocationController.java
@@ -1,6 +1,6 @@
 package controllers.location;
 
-import akka.actor.ActorRef;
+import org.apache.pekko.actor.ActorRef;
 import com.fasterxml.jackson.databind.JsonNode;
 import controllers.BaseController;
 import java.util.Map;

diff --git a/controller/app/controllers/notesmanagement/NotesController.java b/controller/app/controllers/notesmanagement/NotesController.java
@@ -1,6 +1,6 @@
 package controllers.notesmanagement;
 
-import akka.actor.ActorRef;
+import org.apache.pekko.actor.ActorRef;
 import com.fasterxml.jackson.databind.JsonNode;
 import controllers.BaseController;
 import controllers.notesmanagement.validator.NoteRequestValidator;

diff --git a/controller/app/controllers/notificationservice/EmailServiceController.java b/controller/app/controllers/notificationservice/EmailServiceController.java
@@ -1,6 +1,6 @@
 package controllers.notificationservice;
 
-import akka.actor.ActorRef;
+import org.apache.pekko.actor.ActorRef;
 import com.fasterxml.jackson.databind.JsonNode;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import controllers.BaseController;

diff --git a/controller/app/controllers/organisationmanagement/KeyManagementController.java b/controller/app/controllers/organisationmanagement/KeyManagementController.java
@@ -1,6 +1,6 @@
 package controllers.organisationmanagement;
 
-import akka.actor.ActorRef;
+import org.apache.pekko.actor.ActorRef;
 import controllers.BaseController;
 import java.util.concurrent.CompletionStage;
 import javax.inject.Inject;

diff --git a/controller/app/controllers/organisationmanagement/OrgController.java b/controller/app/controllers/organisationmanagement/OrgController.java
@@ -1,6 +1,6 @@
 package controllers.organisationmanagement;
 
-import akka.actor.ActorRef;
+import org.apache.pekko.actor.ActorRef;
 import controllers.BaseController;
 import java.util.concurrent.CompletionStage;
 import javax.inject.Inject;

diff --git a/controller/app/controllers/otp/OtpController.java b/controller/app/controllers/otp/OtpController.java
@@ -1,6 +1,6 @@
 package controllers.otp;
 
-import akka.actor.ActorRef;
+import org.apache.pekko.actor.ActorRef;
 import controllers.BaseController;
 import controllers.otp.validator.OtpRequestValidator;
 import java.util.concurrent.CompletionStage;

diff --git a/controller/app/controllers/storage/FileStorageController.java b/controller/app/controllers/storage/FileStorageController.java
@@ -1,6 +1,6 @@
 package controllers.storage;
 
-import akka.actor.ActorRef;
+import org.apache.pekko.actor.ActorRef;
 import com.fasterxml.jackson.databind.JsonNode;
 import controllers.BaseController;
 import java.io.ByteArrayInputStream;

diff --git a/controller/app/controllers/sync/SyncController.java b/controller/app/controllers/sync/SyncController.java
@@ -1,7 +1,7 @@
 /** */
 package controllers.sync;
 
-import akka.actor.ActorRef;
+import org.apache.pekko.actor.ActorRef;
 import com.fasterxml.jackson.databind.JsonNode;
 import controllers.BaseController;
 import java.util.HashMap;

diff --git a/controller/app/controllers/systemsettings/SystemSettingsController.java b/controller/app/controllers/systemsettings/SystemSettingsController.java
@@ -1,6 +1,6 @@
 package controllers.systemsettings;
 
-import akka.actor.ActorRef;
+import org.apache.pekko.actor.ActorRef;
 import controllers.BaseController;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.CompletionStage;

diff --git a/controller/app/controllers/tac/UserTnCController.java b/controller/app/controllers/tac/UserTnCController.java
@@ -1,6 +1,6 @@
 package controllers.tac;
 
-import akka.actor.ActorRef;
+import org.apache.pekko.actor.ActorRef;
 import controllers.BaseController;
 import controllers.tac.validator.UserTnCRequestValidator;
 import java.util.concurrent.CompletionStage;

diff --git a/controller/app/controllers/tenantmigration/TenantMigrationController.java b/controller/app/controllers/tenantmigration/TenantMigrationController.java
@@ -1,6 +1,6 @@
 package controllers.tenantmigration;
 
-import akka.actor.ActorRef;
+import org.apache.pekko.actor.ActorRef;
 import controllers.BaseController;
 import java.util.concurrent.CompletionStage;
 import javax.inject.Inject;

diff --git a/controller/app/controllers/tenantpreference/TenantPreferenceController.java b/controller/app/controllers/tenantpreference/TenantPreferenceController.java
@@ -1,6 +1,6 @@
 package controllers.tenantpreference;
 
-import akka.actor.ActorRef;
+import org.apache.pekko.actor.ActorRef;
 import controllers.BaseController;
 import java.util.concurrent.CompletionStage;
 import javax.inject.Inject;

diff --git a/controller/app/controllers/usermanagement/IdentifierFreeUpController.java b/controller/app/controllers/usermanagement/IdentifierFreeUpController.java
@@ -1,6 +1,6 @@
 package controllers.usermanagement;
 
-import akka.actor.ActorRef;
+import org.apache.pekko.actor.ActorRef;
 import controllers.BaseController;
 import java.util.concurrent.CompletionStage;
 import javax.inject.Inject;

diff --git a/controller/app/controllers/usermanagement/ResetPasswordController.java b/controller/app/controllers/usermanagement/ResetPasswordController.java
@@ -1,6 +1,6 @@
 package controllers.usermanagement;
 
-import akka.actor.ActorRef;
+import org.apache.pekko.actor.ActorRef;
 import controllers.BaseController;
 import controllers.usermanagement.validator.ResetPasswordRequestValidator;
 import java.util.concurrent.CompletionStage;

diff --git a/controller/app/controllers/usermanagement/UserConsentController.java b/controller/app/controllers/usermanagement/UserConsentController.java
@@ -1,6 +1,6 @@
 package controllers.usermanagement;
 
-import akka.actor.ActorRef;
+import org.apache.pekko.actor.ActorRef;
 import controllers.BaseController;
 import controllers.usermanagement.validator.UserConsentRequestValidator;
 import java.util.concurrent.CompletionStage;

diff --git a/controller/app/controllers/usermanagement/UserController.java b/controller/app/controllers/usermanagement/UserController.java
@@ -1,6 +1,6 @@
 package controllers.usermanagement;
 
-import akka.actor.ActorRef;
+import org.apache.pekko.actor.ActorRef;
 import controllers.BaseController;
 import controllers.usermanagement.validator.UserGetRequestValidator;
 import java.util.HashMap;

diff --git a/controller/app/controllers/usermanagement/UserLoginController.java b/controller/app/controllers/usermanagement/UserLoginController.java
@@ -1,6 +1,6 @@
 package controllers.usermanagement;
 
-import akka.actor.ActorRef;
+import org.apache.pekko.actor.ActorRef;
 import controllers.BaseController;
 import java.util.concurrent.CompletionStage;
 import javax.inject.Inject;

diff --git a/controller/app/controllers/usermanagement/UserMergeController.java b/controller/app/controllers/usermanagement/UserMergeController.java
@@ -1,6 +1,6 @@
 package controllers.usermanagement;
 
-import akka.actor.ActorRef;
+import org.apache.pekko.actor.ActorRef;
 import controllers.BaseController;
 import java.util.Optional;
 import java.util.concurrent.CompletionStage;

diff --git a/controller/app/controllers/usermanagement/UserRoleController.java b/controller/app/controllers/usermanagement/UserRoleController.java
@@ -1,6 +1,6 @@
 package controllers.usermanagement;
 
-import akka.actor.ActorRef;
+import org.apache.pekko.actor.ActorRef;
 import controllers.BaseController;
 import controllers.usermanagement.validator.UserRoleRequestValidator;
 import java.util.concurrent.CompletionStage;

diff --git a/controller/app/controllers/usermanagement/UserStatusController.java b/controller/app/controllers/usermanagement/UserStatusController.java
@@ -1,6 +1,6 @@
 package controllers.usermanagement;
 
-import akka.actor.ActorRef;
+import org.apache.pekko.actor.ActorRef;
 import controllers.BaseController;
 import controllers.usermanagement.validator.UserStatusRequestValidator;
 import java.util.concurrent.CompletionStage;

diff --git a/controller/app/controllers/usermanagement/UserTypeController.java b/controller/app/controllers/usermanagement/UserTypeController.java
@@ -1,6 +1,6 @@
 package controllers.usermanagement;
 
-import akka.actor.ActorRef;
+import org.apache.pekko.actor.ActorRef;
 import controllers.BaseController;
 import java.util.concurrent.CompletionStage;
 import javax.inject.Inject;

diff --git a/controller/app/filters/AccessLogFilter.java b/controller/app/filters/AccessLogFilter.java
@@ -1,6 +1,6 @@
 package filters;
 
-import akka.util.ByteString;
+import org.apache.pekko.util.ByteString;
 import java.util.concurrent.Executor;
 import javax.inject.Inject;
 import play.libs.streams.Accumulator;