app/com.greybox.projectmesh.server/AppServer

AppServer

class AppServer(appContext: Context, httpClient: OkHttpClient, mLogger: MNetLogger, name: String, port: Int = 0, val localVirtualAddr: InetAddress, receiveDir: File, json: Json, db: MeshDatabase, val di: DI, userRepository: UserRepository) : NanoHTTPD, Closeable, DIAware

Constructors

AppServer

constructor(appContext: Context, httpClient: OkHttpClient, mLogger: MNetLogger, name: String, port: Int = 0, localVirtualAddr: InetAddress, receiveDir: File, json: Json, db: MeshDatabase, di: DI, userRepository: UserRepository)

Types

Companion

object Companion

IncomingTransferInfo

@Serializable

data class IncomingTransferInfo(val id: Int, val requestReceivedTime: Long = System.currentTimeMillis(), val fromHost: InetAddress, val deviceName: String = "Unknown Device", val name: String, val status: AppServer.Status = Status.PENDING, val size: Int, val transferred: Int = 0, val transferTime: Int = 1, val file: File? = null)

OutgoingTransferInfo

data class OutgoingTransferInfo(val id: Int, val name: String, val uri: Uri, val toHost: InetAddress, val status: AppServer.Status = Status.PENDING, val size: Int, val transferred: Int = 0)

Status

enum Status : Enum<AppServer.Status>

Properties

open override val di: DI

diContext

open val diContext: DIContext<*>

diTrigger

open val diTrigger: DITrigger?

hostname

open val hostname: String?

incomingTransfers

val incomingTransfers: Flow<List<AppServer.IncomingTransferInfo>>

isAlive

val isAlive: Boolean

listeningPort

val listeningPort: Int

localPort

val localPort: Int

localVirtualAddr

val localVirtualAddr: InetAddress

outgoingTransfers

val outgoingTransfers: Flow<List<AppServer.OutgoingTransferInfo>>

serverSocketFactory

open var serverSocketFactory: NanoHTTPD.ServerSocketFactory?

tempFileManagerFactory

open var tempFileManagerFactory: NanoHTTPD.TempFileManagerFactory?

Functions

acceptIncomingTransfer

fun acceptIncomingTransfer(transfer: AppServer.IncomingTransferInfo, destFile: File, fromPort: Int = DEFAULT_PORT)

addOutgoingTransfer

fun addOutgoingTransfer(uri: Uri, toNode: InetAddress, toPort: Int = DEFAULT_PORT): AppServer.OutgoingTransferInfo

checkDeviceReachable

fun checkDeviceReachable(remoteAddr: InetAddress, port: Int = DEFAULT_PORT): Boolean

Checks if a device is reachable at the application level This performs a lightweight check without doing a full user info exchange

open override fun close()

closeAllConnections

open fun closeAllConnections()

makeSecure

open fun makeSecure(sslServerSocketFactory: SSLServerSocketFactory?, sslProtocols: Array<out String?>?)

markAllUsersOffline

fun markAllUsersOffline()

onDeclineIncomingTransfer

suspend fun onDeclineIncomingTransfer(transfer: AppServer.IncomingTransferInfo, fromPort: Int = DEFAULT_PORT)

onDeleteIncomingTransfer

suspend fun onDeleteIncomingTransfer(incomingTransfer: AppServer.IncomingTransferInfo)

pushUserInfoTo

fun pushUserInfoTo(remoteAddr: InetAddress, port: Int = DEFAULT_PORT)

removeOutgoingTransfer

fun removeOutgoingTransfer(transferId: Int)

requestRemoteUserInfo

fun requestRemoteUserInfo(remoteAddr: InetAddress, port: Int = DEFAULT_PORT)

restart

fun restart()

sendChatMessageWithStatus

suspend fun sendChatMessageWithStatus(address: InetAddress, time: Long, message: String, f: URI?): Boolean

Send a chat message and return delivery status

sendDeviceName

suspend fun sendDeviceName(wifiAddress: InetAddress, port: Int = DEFAULT_PORT)

serve

open override fun serve(session: NanoHTTPD.IHTTPSession): NanoHTTPD.Response

open fun ~~serve~~(uri: String?, method: NanoHTTPD.Method?, headers: Map<String?, String?>?, parms: Map<String?, String?>?, files: Map<String?, String?>?): NanoHTTPD.Response?

setAsyncRunner

open fun setAsyncRunner(asyncRunner: NanoHTTPD.AsyncRunner?)

start

open fun start()

open fun start(timeout: Int)

open fun start(timeout: Int, daemon: Boolean)

stop

open fun stop()

updateUserConnectionStatus

fun updateUserConnectionStatus(userUuid: String, isOnline: Boolean, userAddress: String?)

updateUserOnlineStatus

fun updateUserOnlineStatus(userUuid: String, isOnline: Boolean, userAddress: String?)

wasStarted

fun wasStarted(): Boolean