mirror of
https://github.com/slhaf/Partner.git
synced 2026-06-28 01:59:17 +08:00
Compare commits
5 Commits
buildable/
...
cb8ddfe4e2
| Author | SHA1 | Date | |
|---|---|---|---|
| cb8ddfe4e2 | |||
| 756c0a12ad | |||
| 8a5b844a4a | |||
|
|
8d29ea4c9e | ||
|
|
4770eaf42f |
@@ -10,7 +10,7 @@
|
|||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<artifactId>partnerctl</artifactId>
|
<artifactId>partnerctl</artifactId>
|
||||||
<version>1.0.0</version>
|
<version>1.0.1</version>
|
||||||
|
|
||||||
<properties>
|
<properties>
|
||||||
<maven.compiler.source>21</maven.compiler.source>
|
<maven.compiler.source>21</maven.compiler.source>
|
||||||
@@ -123,6 +123,7 @@
|
|||||||
<buildArg>-H:+ReportExceptionStackTraces</buildArg>
|
<buildArg>-H:+ReportExceptionStackTraces</buildArg>
|
||||||
<buildArg>--initialize-at-build-time=kotlin.DeprecationLevel</buildArg>
|
<buildArg>--initialize-at-build-time=kotlin.DeprecationLevel</buildArg>
|
||||||
<buildArg>-H:IncludeResourceBundles=i18n.messages</buildArg>
|
<buildArg>-H:IncludeResourceBundles=i18n.messages</buildArg>
|
||||||
|
<buildArg>-H:IncludeLocales=zh-CN</buildArg>
|
||||||
</buildArgs>
|
</buildArgs>
|
||||||
</configuration>
|
</configuration>
|
||||||
</plugin>
|
</plugin>
|
||||||
|
|||||||
@@ -2,13 +2,12 @@ package work.slhaf.partner.ctl.commands
|
|||||||
|
|
||||||
import kotlinx.serialization.json.*
|
import kotlinx.serialization.json.*
|
||||||
import picocli.CommandLine
|
import picocli.CommandLine
|
||||||
|
import work.slhaf.partner.ctl.commands.InitCommand.InstallChoice.BUILD_FROM_SOURCE
|
||||||
|
import work.slhaf.partner.ctl.commands.InitCommand.InstallChoice.DOWNLOAD_JAR
|
||||||
import work.slhaf.partner.ctl.commands.data.GatewayConfig
|
import work.slhaf.partner.ctl.commands.data.GatewayConfig
|
||||||
import work.slhaf.partner.ctl.commands.data.OpenAiCompatible
|
import work.slhaf.partner.ctl.commands.data.OpenAiCompatible
|
||||||
import work.slhaf.partner.ctl.commands.data.ProviderConfig
|
import work.slhaf.partner.ctl.commands.data.ProviderConfig
|
||||||
import work.slhaf.partner.ctl.commands.init.buildFromSource
|
import work.slhaf.partner.ctl.commands.init.*
|
||||||
import work.slhaf.partner.ctl.commands.init.configureExternalGateway
|
|
||||||
import work.slhaf.partner.ctl.commands.init.configureOpenAiCompatible
|
|
||||||
import work.slhaf.partner.ctl.commands.init.configureWebSocketGateway
|
|
||||||
import work.slhaf.partner.ctl.i18n.I18n.text
|
import work.slhaf.partner.ctl.i18n.I18n.text
|
||||||
import work.slhaf.partner.ctl.support.CommandInterrupted
|
import work.slhaf.partner.ctl.support.CommandInterrupted
|
||||||
import work.slhaf.partner.ctl.support.inheritCommand
|
import work.slhaf.partner.ctl.support.inheritCommand
|
||||||
@@ -176,11 +175,15 @@ class InitCommand : Runnable {
|
|||||||
|
|
||||||
val installChoice = prompt.select(
|
val installChoice = prompt.select(
|
||||||
label = text("init.install.method.label"),
|
label = text("init.install.method.label"),
|
||||||
choices = listOf(Choice(text("init.install.method.buildFromSource"), InstallChoice.BUILD_FROM_SOURCE))
|
choices = listOf(
|
||||||
|
Choice(text("init.install.method.buildFromSource"), BUILD_FROM_SOURCE),
|
||||||
|
Choice(text("init.install.method.downloadFromRelease"), DOWNLOAD_JAR)
|
||||||
|
)
|
||||||
)
|
)
|
||||||
|
|
||||||
when (installChoice) {
|
when (installChoice) {
|
||||||
InstallChoice.BUILD_FROM_SOURCE -> buildFromSource(home, prompt)
|
BUILD_FROM_SOURCE -> buildFromSource(home, prompt)
|
||||||
|
DOWNLOAD_JAR -> downloadFromRelease(home, prompt)
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
@@ -348,7 +351,8 @@ class InitCommand : Runnable {
|
|||||||
}
|
}
|
||||||
|
|
||||||
private enum class InstallChoice {
|
private enum class InstallChoice {
|
||||||
BUILD_FROM_SOURCE
|
BUILD_FROM_SOURCE,
|
||||||
|
DOWNLOAD_JAR
|
||||||
}
|
}
|
||||||
|
|
||||||
private enum class ModelProviderChoice(val display: String) {
|
private enum class ModelProviderChoice(val display: String) {
|
||||||
|
|||||||
@@ -1,11 +1,15 @@
|
|||||||
package work.slhaf.partner.ctl.commands.init
|
package work.slhaf.partner.ctl.commands.init
|
||||||
|
|
||||||
|
import work.slhaf.partner.ctl.i18n.I18n.text
|
||||||
import work.slhaf.partner.ctl.support.SourceBuildInstallSpec
|
import work.slhaf.partner.ctl.support.SourceBuildInstallSpec
|
||||||
import work.slhaf.partner.ctl.support.buildAndInstallFromSource
|
import work.slhaf.partner.ctl.support.buildAndInstallFromSource
|
||||||
|
import work.slhaf.partner.ctl.support.downloadTo
|
||||||
|
import work.slhaf.partner.ctl.support.registryIndex
|
||||||
import work.slhaf.partner.ctl.ui.Prompt
|
import work.slhaf.partner.ctl.ui.Prompt
|
||||||
import java.nio.file.Files
|
import java.nio.file.Files
|
||||||
import java.nio.file.Path
|
import java.nio.file.Path
|
||||||
import java.nio.file.Paths
|
import java.nio.file.Paths
|
||||||
|
import kotlin.io.path.exists
|
||||||
import kotlin.io.path.isDirectory
|
import kotlin.io.path.isDirectory
|
||||||
import kotlin.io.path.name
|
import kotlin.io.path.name
|
||||||
|
|
||||||
@@ -40,3 +44,41 @@ private fun findLargestJar(directory: Path): Path? {
|
|||||||
.orElse(null)
|
.orElse(null)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
fun downloadFromRelease(home: Path, prompt: Prompt) {
|
||||||
|
prompt.info(text("init.install.method.downloadFromRelease.startDownloading"))
|
||||||
|
val path = home.resolve("resources/partner-core.jar").toAbsolutePath().normalize()
|
||||||
|
downloadTo(registryIndex.partner.latestRelease.url, path) { downloaded, total ->
|
||||||
|
if (total != null && total > 0) {
|
||||||
|
val percent = downloaded * 100 / total
|
||||||
|
updateLine(
|
||||||
|
text(
|
||||||
|
"init.install.method.downloadFromRelease.progress.percent",
|
||||||
|
percent
|
||||||
|
)
|
||||||
|
)
|
||||||
|
} else {
|
||||||
|
updateLine(
|
||||||
|
text(
|
||||||
|
"init.install.method.downloadFromRelease.progress.size",
|
||||||
|
downloaded / 1024
|
||||||
|
)
|
||||||
|
)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
finishLine(text("init.install.method.downloadFromRelease.done"))
|
||||||
|
if (!path.exists()) {
|
||||||
|
throw IllegalStateException("Unable to find downloaded partner release at $path")
|
||||||
|
}
|
||||||
|
prompt.success(text("init.install.method.downloadFromRelease.success"))
|
||||||
|
}
|
||||||
|
|
||||||
|
fun updateLine(text: String) {
|
||||||
|
print("\r\u001B[2K$text")
|
||||||
|
System.out.flush()
|
||||||
|
}
|
||||||
|
|
||||||
|
fun finishLine(text: String) {
|
||||||
|
updateLine(text)
|
||||||
|
println()
|
||||||
|
}
|
||||||
@@ -6,7 +6,7 @@ import kotlinx.serialization.json.Json
|
|||||||
private const val registryUrl = "https://raw.githubusercontent.com/slhaf/Partner/refs/heads/master/registry"
|
private const val registryUrl = "https://raw.githubusercontent.com/slhaf/Partner/refs/heads/master/registry"
|
||||||
private const val indexUrl = "$registryUrl/index.json"
|
private const val indexUrl = "$registryUrl/index.json"
|
||||||
|
|
||||||
private val registryIndex = run {
|
val registryIndex = run {
|
||||||
Json.decodeFromString<RegistryIndex>(fetchText(indexUrl))
|
Json.decodeFromString<RegistryIndex>(fetchText(indexUrl))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -5,11 +5,15 @@ import java.net.InetSocketAddress
|
|||||||
import java.net.ProxySelector
|
import java.net.ProxySelector
|
||||||
import java.net.URI
|
import java.net.URI
|
||||||
import java.net.http.*
|
import java.net.http.*
|
||||||
|
import java.nio.file.Files
|
||||||
|
import java.nio.file.Path
|
||||||
|
import java.nio.file.StandardCopyOption
|
||||||
import java.time.Duration
|
import java.time.Duration
|
||||||
|
import kotlin.io.path.isDirectory
|
||||||
|
|
||||||
private val httpClient: HttpClient = HttpClient.newBuilder()
|
private val httpClient: HttpClient = HttpClient.newBuilder()
|
||||||
.connectTimeout(Duration.ofSeconds(20))
|
.connectTimeout(Duration.ofSeconds(20))
|
||||||
.followRedirects(HttpClient.Redirect.NEVER)
|
.followRedirects(HttpClient.Redirect.NORMAL)
|
||||||
.apply {
|
.apply {
|
||||||
proxySelectorFromEnv()?.let(::proxy)
|
proxySelectorFromEnv()?.let(::proxy)
|
||||||
}
|
}
|
||||||
@@ -72,3 +76,60 @@ fun fetchText(url: String): String {
|
|||||||
|
|
||||||
throw IOException("Failed to fetch $url after retries", lastError)
|
throw IOException("Failed to fetch $url after retries", lastError)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
fun downloadTo(
|
||||||
|
url: String,
|
||||||
|
targetPath: Path,
|
||||||
|
onProgress: (downloaded: Long, total: Long?) -> Unit = { _, _ -> }
|
||||||
|
) {
|
||||||
|
if (targetPath.isDirectory()) {
|
||||||
|
throw IllegalArgumentException("Target path must be a file")
|
||||||
|
}
|
||||||
|
val targetPath = targetPath.toAbsolutePath().normalize()
|
||||||
|
val targetFile = targetPath.toFile()
|
||||||
|
val temp = Files.createTempFile(
|
||||||
|
"${targetFile.name}-${System.currentTimeMillis()}", ".${targetFile.extension}.download"
|
||||||
|
)
|
||||||
|
|
||||||
|
try {
|
||||||
|
val request = HttpRequest.newBuilder()
|
||||||
|
.uri(URI.create(url))
|
||||||
|
.GET()
|
||||||
|
.build()
|
||||||
|
|
||||||
|
val response = httpClient.send(
|
||||||
|
request,
|
||||||
|
HttpResponse.BodyHandlers.ofInputStream()
|
||||||
|
)
|
||||||
|
|
||||||
|
if (response.statusCode() !in 200..299) {
|
||||||
|
throw IllegalStateException("Failed to download from $url: HTTP ${response.statusCode()}")
|
||||||
|
}
|
||||||
|
|
||||||
|
val totalBytes = response.headers()
|
||||||
|
.firstValue("Content-Length")
|
||||||
|
.orElse(null)
|
||||||
|
?.toLongOrNull()
|
||||||
|
|
||||||
|
response.body().use { input ->
|
||||||
|
Files.newOutputStream(temp).use { output ->
|
||||||
|
val buffer = ByteArray(8192)
|
||||||
|
var downloaded = 0L
|
||||||
|
|
||||||
|
while (true) {
|
||||||
|
val read = input.read(buffer)
|
||||||
|
if (read < 0) break
|
||||||
|
|
||||||
|
output.write(buffer, 0, read)
|
||||||
|
downloaded += read
|
||||||
|
onProgress(downloaded, totalBytes)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
Files.move(temp, targetPath, StandardCopyOption.REPLACE_EXISTING)
|
||||||
|
} catch (e: Exception) {
|
||||||
|
Files.deleteIfExists(temp)
|
||||||
|
throw e
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|||||||
@@ -31,6 +31,12 @@ init.home.overwrite.refuseBroadDirectory=Refuse to overwrite suspiciously broad
|
|||||||
init.install.section=Install Partner
|
init.install.section=Install Partner
|
||||||
init.install.method.label=Choose an installation method
|
init.install.method.label=Choose an installation method
|
||||||
init.install.method.buildFromSource=Build Partner from source
|
init.install.method.buildFromSource=Build Partner from source
|
||||||
|
init.install.method.downloadFromRelease=Download Partner release
|
||||||
|
init.install.method.downloadFromRelease.startDownloading=Downloading Partner release...
|
||||||
|
init.install.method.downloadFromRelease.success=Partner release downloaded successfully.
|
||||||
|
init.install.method.downloadFromRelease.progress.percent=Downloading Partner release... {0}%
|
||||||
|
init.install.method.downloadFromRelease.progress.size=Downloading Partner release... {0} KB
|
||||||
|
init.install.method.downloadFromRelease.done=Downloading Partner release... Done
|
||||||
init.gateway.section=Configure Gateway
|
init.gateway.section=Configure Gateway
|
||||||
init.gateway.select.label=Select gateway
|
init.gateway.select.label=Select gateway
|
||||||
init.gateway.websocket.choice=WebSocket Gateway
|
init.gateway.websocket.choice=WebSocket Gateway
|
||||||
|
|||||||
@@ -31,6 +31,12 @@ init.home.overwrite.refuseBroadDirectory=拒绝覆盖范围过大的目录:{0}
|
|||||||
init.install.section=安装 Partner
|
init.install.section=安装 Partner
|
||||||
init.install.method.label=选择安装方式
|
init.install.method.label=选择安装方式
|
||||||
init.install.method.buildFromSource=从源码构建 Partner
|
init.install.method.buildFromSource=从源码构建 Partner
|
||||||
|
init.install.method.downloadFromRelease=下载 Partner 发布包
|
||||||
|
init.install.method.downloadFromRelease.startDownloading=正在下载 Partner 发布包...
|
||||||
|
init.install.method.downloadFromRelease.success=Partner 发布包下载完成。
|
||||||
|
init.install.method.downloadFromRelease.progress.percent=正在下载 Partner 发布包... {0}%
|
||||||
|
init.install.method.downloadFromRelease.progress.size=正在下载 Partner 发布包... {0} KB
|
||||||
|
init.install.method.downloadFromRelease.done=正在下载 Partner 发布包... 完成
|
||||||
init.gateway.section=配置网关
|
init.gateway.section=配置网关
|
||||||
init.gateway.select.label=选择网关
|
init.gateway.select.label=选择网关
|
||||||
init.gateway.websocket.choice=WebSocket Gateway
|
init.gateway.websocket.choice=WebSocket Gateway
|
||||||
|
|||||||
49
README.md
49
README.md
@@ -25,12 +25,54 @@ Partner 分为 `Partner-Framework` 与 `Partner-Core` 两层。前者提供配
|
|||||||
|
|
||||||
## 项目启动
|
## 项目启动
|
||||||
|
|
||||||
**环境要求**
|
### 环境要求
|
||||||
|
|
||||||
|
**基础运行要求**
|
||||||
|
|
||||||
- JDK 21
|
- JDK 21
|
||||||
- Maven 3.x
|
|
||||||
|
|
||||||
### 手动准备环境并启动
|
**仅在从源码构建 Partner Runtime 或外部模块时需要**
|
||||||
|
|
||||||
|
- Maven 3.x
|
||||||
|
- Git
|
||||||
|
|
||||||
|
### 推荐方式:PartnerCtl
|
||||||
|
|
||||||
|
`PartnerCtl` 用于完成 Partner 的首次初始化、运行时安装与启动管理。相比手动准备运行目录和配置文件,使用它可以更快完成最小可运行环境的搭建。
|
||||||
|
|
||||||
|
#### 初始化
|
||||||
|
|
||||||
|
```bash
|
||||||
|
partnerctl init
|
||||||
|
```
|
||||||
|
|
||||||
|
初始化流程会引导完成:
|
||||||
|
|
||||||
|
- 选择 `PARTNER_HOME`
|
||||||
|
- 安装 Partner Runtime
|
||||||
|
- 从源码构建
|
||||||
|
- 下载发布版 jar
|
||||||
|
- 配置 Gateway
|
||||||
|
- 配置模型 Provider
|
||||||
|
- 可选立即启动 Partner
|
||||||
|
|
||||||
|
#### 启动
|
||||||
|
|
||||||
|
如果初始化完成后未选择立即启动,可执行:
|
||||||
|
|
||||||
|
```bash
|
||||||
|
partnerctl run
|
||||||
|
```
|
||||||
|
|
||||||
|
如需后台运行:
|
||||||
|
|
||||||
|
```bash
|
||||||
|
partnerctl run -d
|
||||||
|
```
|
||||||
|
|
||||||
|
PartnerCtl 默认读取 `PARTNER_HOME` 指定的运行目录;若未设置,则使用 `~/.partner`。
|
||||||
|
|
||||||
|
### 手动方式:从源码构建并启动
|
||||||
|
|
||||||
#### 克隆项目并构建
|
#### 克隆项目并构建
|
||||||
|
|
||||||
@@ -162,4 +204,3 @@ Partner/
|
|||||||
## License
|
## License
|
||||||
|
|
||||||
暂未指定。
|
暂未指定。
|
||||||
|
|
||||||
|
|||||||
@@ -2,11 +2,11 @@
|
|||||||
"partner": {
|
"partner": {
|
||||||
"latestBuildable": {
|
"latestBuildable": {
|
||||||
"url": "https://github.com/slhaf/Partner.git",
|
"url": "https://github.com/slhaf/Partner.git",
|
||||||
"ref": "buildable/0.5.0"
|
"ref": "buildable/0.9.0-preview"
|
||||||
},
|
},
|
||||||
"latestRelease": {
|
"latestRelease": {
|
||||||
"url": "https://github.com/slhaf/Partner/releases/download/release-core%2F0.5.0/partner-core-0.5.0.jar",
|
"url": "https://github.com/slhaf/Partner/releases/download/release-core%2F0.9.0-preview/partner-core-0.9.0-preview.jar",
|
||||||
"version": "0.5.0"
|
"version": "0.9.0-preview"
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
"externalModules": [
|
"externalModules": [
|
||||||
|
|||||||
Reference in New Issue
Block a user