import kotlinx.serialization.Serializable

@Serializable
data class Message(
    val message: String
)

interface SocketAPI {

    @Event(value = "{event}")
    fun helloEvent(
        @Event(value = "event") event: String
    ): Flow<Message>


    /**
     * This is an example to show backend side
     *
     *  ```js
     *  socket.emit('ping', {
     *      'message': 'pong'
     *  })
     *  ```
     *
     *  @return Response (Message) from server
     *  @author by Mr. Adkhambek
     *  @see <a href="https://github.com/MrAdkhambek/Moon/blob/main/IO.Socket%20echo/app.js">Github</a>
     */
    @Event(value = "ping")
    fun helloEvent(): Flow<Message>

    /**
     * This is an example to show backend side
     *
     *  ```js
     *  socket.on('test', (arg) => {
     *          // TODO
     *  })
     *  ```
     *
     *  @param message is Request
     *  @author by Mr. Adkhambek
     *  @see <a href="https://github.com/MrAdkhambek/Moon/blob/main/IO.Socket%20echo/app.js">Github</a>
     */
    @Event(value = "test")
    suspend fun testEvent(message: Message)

    /**
     * This is an example to show backend side
     *
     *  ```js
     *  socket.on('testAck', (arg, ack) => {
     *      // TODO
     *      ack([
     *          {
     *              'message': 'pong 1'
     *          },
     *          {
     *              'message': 'pong 2'
     *          }
     *      ])
     *  })
     *  ```
     *
     *  @param message is Request
     *  @return Response (Message) from server
     *  @author by Mr. Adkhambek
     *  @see <a href="https://github.com/MrAdkhambek/Moon/blob/main/IO.Socket%20echo/app.js">Github</a>
     */
    @Event(value = "testAck")
    suspend fun testAckEvent(message: Message): List<Message>
}

val logger: Logger = TODO()
val socket: io.socket.client.Socket = TODO()
val convertor: EventConvertor.Factory = TODO()

// Create moon object with Factory pattern
val moon = Moon.Factory().create(socket, logger, convertor)
moon.connect() // or socket.connect()

// Create API Interface object
val socketAPI = moon.create(SocketAPI::class.java)
// or shorter version
val socketAPI: SocketAPI = moon.create()

class ViewModel(
    private val socketAPI: SocketAPI
) {

    val events: Flow<SomeClass> = socketAPI.eventWithBody()

    fun singleEvent(body: SomeClass) {
        viewModelScope.launch {
            val eventResponse = socketAPI.singleEvent(body)
        }
    }
}

class ViewModel(
    private val moon: Moon,
) {
    /**
     * For listen socket state
     * @see <a href="https://github.com/MrAdkhambek/Moon/blob/f5dd034d25efcb5c066fa29ff4b7ca3d037890cf/moon/src/main/java/me/adkhambek/moon/Moon.kt#L193">Moon.Status</a>
     */
    val state: StateFlow<Moon.Status> get() = moon.state
}

public fun Moon.Companion.factory(): Moon.Factory

public fun Moon.Factory.create(
    uri: String,
    logger: Logger,
    vararg converterFactories: EventConvertor.Factory,
): Moon

public fun Moon.Factory.create(
    uri: String,
    opts: Options,
    logger: Logger,
    vararg converterFactories: EventConvertor.Factory,
): Moon

public fun Moon.Factory.create(
    uri: URI,
    logger: Logger,
    vararg converterFactories: EventConvertor.Factory,
): Moon

public fun Moon.Factory.create(
    uri: URI,
    opts: Options,
    logger: Logger,
    vararg converterFactories: EventConvertor.Factory,
): Moon