admin permitions

app/src/main/java/com/templateapp/cloudapi/business/datasource/network/auth/network_responses/RegistrationResponse.kt

@@ -1,5 +1,6 @@
 package com.templateapp.cloudapi.business.datasource.network.auth.network_responses
 
+import com.google.gson.annotations.Expose
 import com.google.gson.annotations.SerializedName
 import com.templateapp.cloudapi.business.datasource.network.responseObjects.User
 
@@ -9,7 +10,11 @@ class RegistrationResponse(
  var error: String,
 
  @SerializedName("success")
- var success: String
+ var success: String,
+
+ @SerializedName("response")
+ @Expose
+ val response: String?,
 
 
 )

app/src/main/java/com/templateapp/cloudapi/business/datasource/network/main/AccountDto.kt

@@ -20,7 +20,6 @@ class AccountDto(
  @SerializedName("age")
  val age: Int,
 
-
  @SerializedName("enabled")
  val enabled: Boolean,
 

app/src/main/java/com/templateapp/cloudapi/business/domain/models/Device.kt

@@ -0,0 +1,17 @@
+package com.templateapp.cloudapi.business.domain.models
+
+import com.templateapp.cloudapi.business.datasource.cache.account.RoleEntity
+
+data class Device(
+ val _id: String,
+ val serialNumber : String
+)
+
+
+
+
+
+
+
+
+

app/src/main/java/com/templateapp/cloudapi/business/domain/util/Constants.kt

@@ -4,9 +4,9 @@ class Constants {
 
  companion object{
 
- const val BASE_URL = "http://192.168.1.8:3000/"
- const val PASSWORD_RESET_URL: String = "http://192.168.1.8:3000/passwordresetform"
- const val REGISTER_ADMIN_URL: String = "http://192.168.1.8:3000/registeruser"
+ const val BASE_URL = "http://appcloud-env.eba-theyd4uu.eu-central-1.elasticbeanstalk.com/"
+ const val PASSWORD_RESET_URL: String = "http://appcloud-env.eba-theyd4uu.eu-central-1.elasticbeanstalk.com/passwordresetform"
+ const val REGISTER_ADMIN_URL: String = "http://appcloud-env.eba-theyd4uu.eu-central-1.elasticbeanstalk.com/registeruser"
 
 
  const val NETWORK_TIMEOUT = 6000L

app/src/main/java/com/templateapp/cloudapi/business/interactors/auth/Register.kt

@@ -28,20 +28,32 @@ class Register(
  fun execute(
  email: String,
 
- ): Flow<DataState<String>> = flow {
- emit(DataState.loading<String>())
+ ): Flow<DataState<Response>> = flow {
+ emit(DataState.loading<Response>())
  val registerResponse = service.register(
  email = email,
 
  )
- // Incorrect login credentials counts as a 200 response from server, so need to handle that
- registerResponse.error?.let{
- throw Exception(it)
+
+ registerResponse.response?.let {
+ if(registerResponse.response != SuccessHandling.SUCCESS_ACCOUNT_UPDATED){
+ throw Exception(ErrorHandling.ERROR_UPDATE_ACCOUNT)
+ }
+ }?:run{
+ throw Exception(ErrorHandling.ERROR_UPDATE_ACCOUNT)
  }
 
  // cache account information
 
- emit(DataState.data(data = "Success", response = null))
+ emit(DataState.data<Response>(
+ data = Response(
+ message = SuccessHandling.SUCCESS_ACCOUNT_UPDATED,
+ uiComponentType = UIComponentType.Toast(),
+ messageType = MessageType.Success()
+ ),
+ response = null
+ ))
+
  }.catch { e ->
  emit(handleUseCaseException(e, serverMsgTranslator))
  }

app/src/main/java/com/templateapp/cloudapi/presentation/UDP_Client.java

@@ -0,0 +1,63 @@
+package com.templateapp.cloudapi.presentation;
+
+import java.net.DatagramPacket;
+import java.net.DatagramSocket;
+import java.net.InetAddress;
+
+import android.annotation.SuppressLint;
+import android.os.AsyncTask;
+import android.os.Build;
+
+public class UDP_Client
+{
+
+ private InetAddress IPAddress = null;
+ private String message = "Hello Android!" ;
+ private AsyncTask<Void, Void, Void> async_cient;
+ public String Message;
+
+
+ @SuppressLint("NewApi")
+ public void NachrichtSenden()
+ {
+ async_cient = new AsyncTask<Void, Void, Void>()
+ {
+ @Override
+ protected Void doInBackground(Void... params)
+ {
+ DatagramSocket ds = null;
+
+ try
+ {
+ byte[] ipAddr = new byte[]{ (byte) 255, (byte) 255,(byte)255, (byte) 255};
+ InetAddress addr = InetAddress.getByAddress(ipAddr);
+ ds = new DatagramSocket(3000);
+ DatagramPacket dp;
+ dp = new DatagramPacket(Message.getBytes(), Message.getBytes().length, addr, 3000);
+ ds.setBroadcast(true);
+ ds.send(dp);
+ }
+ catch (Exception e)
+ {
+ e.printStackTrace();
+ }
+ finally
+ {
+ if (ds != null)
+ {
+ ds.close();
+ }
+ }
+ return null;
+ }
+
+ protected void onPostExecute(Void result)
+ {
+ super.onPostExecute(result);
+ }
+ };
+
+ if (Build.VERSION.SDK_INT >= 11) async_cient.executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR);
+ else async_cient.execute();
+ }
+}

app/src/main/java/com/templateapp/cloudapi/presentation/auth/launcher/LauncherFragment.kt

@@ -9,6 +9,7 @@ import androidx.navigation.fragment.findNavController
 import com.templateapp.cloudapi.R
 import com.templateapp.cloudapi.business.datasource.network.main.OpenApiMainService
 import com.templateapp.cloudapi.databinding.FragmentLauncherBinding
+import com.templateapp.cloudapi.presentation.UDP_Client
 import com.templateapp.cloudapi.presentation.auth.BaseAuthFragment
 import com.templateapp.cloudapi.presentation.auth.register.RegisterState
 import kotlinx.coroutines.flow.*
@@ -34,6 +35,9 @@ class LauncherFragment: BaseAuthFragment() {
 
  //search()
 
+ /* val Client = UDP_Client()
+ Client.Message = "Your message"
+ Client.NachrichtSenden()*/
  var openApiMainService: OpenApiMainService
 
 

app/src/main/java/com/templateapp/cloudapi/presentation/auth/register/RegisterEvents.kt

@@ -1,5 +1,7 @@
 package com.templateapp.cloudapi.presentation.auth.register
 
+import com.templateapp.cloudapi.presentation.main.account.update.UpdateAccountEvents
+
 
 sealed class RegisterEvents{
 
@@ -11,5 +13,7 @@ sealed class RegisterEvents{
  val email: String
  ): RegisterEvents()
 
+
+ object OnUpdateComplete: RegisterEvents()
  object OnRemoveHeadFromQueue: RegisterEvents()
 }

app/src/main/java/com/templateapp/cloudapi/presentation/auth/register/RegisterFragment.kt

@@ -49,7 +49,14 @@ class RegisterFragment : BaseAuthFragment() {
  viewModel.onTriggerEvent(RegisterEvents.OnRemoveHeadFromQueue)
  }
  })
+ if(state.isComplete){
+ findNavController().popBackStack(R.id.accountFragment, false)
+ Toast.makeText(context ,"You have successfully sent an email", Toast.LENGTH_SHORT).show();
+ }
+
  }
+
+
  }
 
  private fun setRegisterFields(
@@ -67,7 +74,7 @@ class RegisterFragment : BaseAuthFragment() {
  viewModel.onTriggerEvent(RegisterEvents.Register(
  email = binding.inputEmail.text.toString(),
  ))
- Toast.makeText(context,"You have successfully sent an email",Toast.LENGTH_SHORT).show();
+
  }
 
  override fun onPause() {

app/src/main/java/com/templateapp/cloudapi/presentation/auth/register/RegisterState.kt

@@ -6,5 +6,7 @@ import com.templateapp.cloudapi.business.domain.util.StateMessage
 data class RegisterState(
  val isLoading: Boolean = false,
  val email: String = "",
+
+ val isComplete: Boolean = false,
  val queue: Queue<StateMessage> = Queue(mutableListOf()),
 )

app/src/main/java/com/templateapp/cloudapi/presentation/auth/register/RegisterViewModel.kt

@@ -1,13 +1,16 @@
 package com.templateapp.cloudapi.presentation.auth.register
 
 import android.util.Log
+import android.widget.Toast
 import androidx.lifecycle.MutableLiveData
 import androidx.lifecycle.ViewModel
 import androidx.lifecycle.viewModelScope
 import com.templateapp.cloudapi.business.domain.util.StateMessage
+import com.templateapp.cloudapi.business.domain.util.SuccessHandling
 import com.templateapp.cloudapi.business.domain.util.UIComponentType
 import com.templateapp.cloudapi.business.domain.util.doesMessageAlreadyExistInQueue
 import com.templateapp.cloudapi.business.interactors.auth.Register
+import com.templateapp.cloudapi.presentation.main.account.update.UpdateAccountEvents
 import com.templateapp.cloudapi.presentation.session.SessionEvents
 import com.templateapp.cloudapi.presentation.session.SessionManager
 import dagger.hilt.android.lifecycle.HiltViewModel
@@ -40,6 +43,16 @@ constructor(
  is RegisterEvents.OnRemoveHeadFromQueue -> {
  removeHeadFromQueue()
  }
+
+ is RegisterEvents.OnUpdateComplete -> {
+ onUpdateComplete()
+ }
+ }
+ }
+
+ private fun onUpdateComplete(){
+ state.value?.let { state ->
+ this.state.value = state.copy(isComplete = true)
  }
  }
 
@@ -79,10 +92,20 @@ constructor(
  ).onEach { dataState ->
  this.state.value = state.copy(isLoading = dataState.isLoading)
 
- dataState.data?.let { success ->
- //sessionManager.onTriggerEvent(SessionEvents.Login(success))
+ dataState.data?.let { response ->
+ if(response.message == SuccessHandling.SUCCESS_ACCOUNT_UPDATED){
+ onTriggerEvent(RegisterEvents.OnUpdateComplete)
+ }else{
+
+ appendToMessageQueue(
+ stateMessage = StateMessage(
+ response = response
+ )
+ )
+ }
  }
 
+
  dataState.stateMessage?.let { stateMessage ->
  appendToMessageQueue(stateMessage)
  }

app/src/main/java/com/templateapp/cloudapi/presentation/main/account/detail/AccountEvents.kt

@@ -1,14 +1,22 @@
 package com.templateapp.cloudapi.presentation.main.account.detail
 
+import com.templateapp.cloudapi.presentation.main.account.settings.SettingsEvents
+import com.templateapp.cloudapi.presentation.main.account.update.UpdateAccountEvents
+
 
 sealed class AccountEvents{
 
- object GetAccount: AccountEvents()
+ object ManageUsers: AccountEvents()
 
- object Logout: AccountEvents()
 
- object ManageUsers: AccountEvents()
+ object ManageDevices: AccountEvents()
+
+ object GetAccount: AccountEvents()
+
+ object MyAccount: AccountEvents()
 
  object OnRemoveHeadFromQueue: AccountEvents()
 
+ object OnAdmin: AccountEvents()
+
 }