全栈项目

import com.varabyte.kobweb.gradle.application.util.configAsKobwebApplication

plugins {
    alias(libs.plugins.kotlin.multiplatform)
    alias(libs.plugins.jetbrains.compose)
    alias(libs.plugins.kobweb.application)
}

/* ... */

kotlin {
    configAsKobwebApplication(includeServer = true)
    sourceSets {
        /* ... */
        jvmMain.dependencies {
            /* ... */
        }
    }
}
 
 
 
 
 

@Api
suspend fun echo(ctx: ApiContext) {
    // ctx.req 用于传入请求，ctx.res 用于响应客户端

    // 参数从 URL 解析，例如这里的 "/api/echo?message=..."
    val msg = ctx.req.params["message"] ?: ""
    ctx.res.setBodyText(msg)
}

@Page
@Composable
fun ApiDemoPage() {
  val coroutineScope = rememberCoroutineScope()

  Button(onClick = {
    coroutineScope.launch {
      println("回显: " + window.api.get("echo?message=hello").decodeToString())
    }
  }) { Text("点击我") }
}

@Api
suspend fun error404(ctx: ApiContext) {
}

@Api
suspend fun noActionButOk(ctx: ApiContext) {
    ctx.res.status = 200
}

@Api
suspend fun updateUser(ctx: ApiContext) {
    if (ctx.req.method != HttpMethod.POST) return
    // ...
    ctx.res.status = 200
}

@Api
suspend fun redirect(ctx: ApiContext) {
    if (ctx.req.method != HttpMethod.GET) return
    ctx.res.headers["Location"] = "..."
    ctx.res.status = 302
  
    // 注意：为此提供了一个便捷方法：
    // `ctx.res.setAsRedirect("...", 302)
}

@ApiInterceptor
suspend fun interceptRequest(ctx: ApiInterceptorContext): Response {
    return when {
        ctx.path == "/example" -> Response().apply { setBodyText("已拦截！") }
        // 默认：将请求传递给通常处理它的路由
        else -> ctx.dispatcher.dispatch()
    }
}

@ApiInterceptor
suspend fun interceptRequest(ctx: ApiInterceptorContext): Response {
    return when {
        // 用户会认为 "/legacy" 处理了请求；
        // 实际上是 "/new" 处理的
        ctx.path == "/legacy" -> ctx.dispatcher.dispatch("/new")
        else -> ctx.dispatcher.dispatch()
    }
}

@ApiInterceptor
suspend fun interceptResponse(ctx: ApiInterceptorContext): Response {
    return ctx.dispatcher.dispatch().also { res ->
        res.headers["X-Intercepted"] = "true"
    }
}

@Api("{}")
suspend fun fetchArticle(ctx: ApiContext) {
    val articleId = ctx.req.params["article"] ?: return
    // ...
}

coroutineScope.launch {
    // 这将导致服务器上的 "article" 变量
    // 被设置为 "123"
    val articleText = window.api.get("articles/123").decodeToString()
    // ...
}

@InitApi
fun initDatabase(ctx: InitApiContext) {
    val db = MutableDatabase()
    db.createTable("users", listOf("id", "name")).apply {
        addRow(listOf("1", "Alice"))
        addRow(listOf("2", "Bob"))
    }
    db.loadResource("products.csv")

    ctx.data.add<Database>(db)
}

@Api
fun getUsers(ctx: ApiContext) {
  if (ctx.req.method != HttpMethod.GET) return
  val db = ctx.data.getValue<Database>()
  ctx.res.setBodyText(db.query("SELECT * FROM users").toString())
}
 
 
 
 

val echo = object : ApiStream {
  override suspend fun onClientConnected(ctx: ClientConnectedContext) {
    // Optional: ctx.stream.broadcast a message to all other clients that a new stream connected
    // Optional: Update ctx.data here, initializing data associated with ctx.stream.id
  }
  override suspend fun onTextReceived(ctx: TextReceivedContext) {
    ctx.stream.send(ctx.text)
  }
  override suspend fun onClientDisconnected(ctx: ClientDisconnectedContext) {
    // Optional: ctx.stream.broadcast a message to all other clients that a stream disconnected
    // Optional: Update ctx.data here, removing data associated with ctx.stream.id
  }
}

@Page
@Composable
fun ApiStreamDemoPage() {
    val echoStream = rememberApiStream("echo", object : ApiStreamListener {
        override fun onConnected(ctx: ConnectedContext) {}
        override fun onTextReceived(ctx: TextReceivedContext) {
            console.log("回显: ${ctx.text}")
        }
        override fun onDisconnected(ctx: DisconnectedContext) {}
    })

    Button(onClick = {
        echoStream.send("你好！")
    }) { Text("点击我") }
}

val echo = object : ApiStream {
  override suspend fun onTextReceived(ctx: TextReceivedContext) {
    ctx.stream.send(ctx.text)
  }
}

val echoStream = rememberApiStream("echo", object : ApiStreamListener {
  override fun onTextReceived(ctx: TextReceivedContext) {
    console.log("Echoed: ${ctx.text}")
  }
})

val echo = ApiStream { ctx -> ctx.stream.send(ctx.text) }

val echoStream = rememberApiStream("echo") {
  ctx -> console.log("Echoed: ${ctx.text}")
}

server:
    logging:
        level: DEBUG # ALL, TRACE, DEBUG, INFO, WARN, ERROR, OFF
        enableConsoleLogging: true # 如果为 false，日志不会写入 stdout/stderr
        enableFileLogging: true # 如果为 false，不会创建日志文件
        logRoot: ".kobweb/server/logs"
        clearLogsOnStart: true # 警告 - 如果为 true，会清除 logRoot 中的所有文件，所以不要在那里放其他文件！
        logFileBaseName: "kobweb-server" # 例如 "kobweb-server.log"，"kobweb-server.2023-04-13.log"
        maxFileCount: null # null = 无限制。每天创建一个日志文件，所以 30 = 1 个月的日志
        totalSizeCap: 10MiB # null = 无限制。接受的单位：B, K, M, G, KB, MB, GB, KiB, MiB, GiB
        compressHistory: true # 如果为 true，旧日志文件会用 gzip 压缩

server:
    cors:
        hosts:
            - name: "example.com"
              schemes:
                  - "https"