hanfuit
645b64fe21
服务端（Go）： - GM 塞背包/带属性装备发放：在线角色推送 op14 增量物品行，背包实时刷新，无需回角色选择界面 - GM 改金币/改等级：去掉在线拒绝，落库后推送 op14 钱包/op37 等级状态，在线实时刷新 - 等级端点统一切换到新版 GMSetCharacterLevel（自带在线刷新） - 无限/锁死疲劳模式 + 燃烧疲劳：每房间消耗 2 点、打怪与通关经验双倍 - 燃烧疲劳开关时给所有在线角色推送系统提示（op12 mode 0） - 深渊史诗掉率：GM 全局倍率 + 城镇增益药剂窗口倍率，真实接入掉落结算 启动器（Python/JS）： - 标题栏自绘、窗口 1204x717、禁止拖拽改大小、仅最小化/关闭 - GM 工具：疲劳与燃烧、深渊史诗掉率、拍卖行上架（单一定价对齐） - 拍卖行上架前端对齐服务端单一价格语义，修复 400 报错
76 lines
2.8 KiB
Go
76 lines
2.8 KiB
Go
package dnfbridge
|
|
|
|
import (
|
|
"encoding/base64"
|
|
"encoding/json"
|
|
"errors"
|
|
"fmt"
|
|
)
|
|
|
|
var errRuntimeRaidCreatedRecoverySeed = errors.New("runtime created raid recovery seed is invalid")
|
|
|
|
// runtimeRaidCreatedRecoverySeed is a local-only deployment migration for an
|
|
// exact unstarted object that is still owned by the process being replaced.
|
|
// It is deliberately unable to describe a started raid or lifecycle progress;
|
|
// normal reconnects restore those from the live server-owned runtime state.
|
|
type runtimeRaidCreatedRecoverySeed struct {
|
|
RaidKey uint32 `json:"raid_key"`
|
|
LeaderID uint16 `json:"leader_id"`
|
|
RouteOrRaidType byte `json:"route_or_raid_type"`
|
|
NameBytes []byte `json:"name_bytes"`
|
|
TailFlag byte `json:"tail_flag"`
|
|
SingleRaidType byte `json:"single_raid_type"`
|
|
}
|
|
|
|
func (s *Service) restoreRuntimeCreatedRaidSeed() error {
|
|
if s == nil || s.options.raidCreatedRecoverySeed == "" {
|
|
return nil
|
|
}
|
|
if !s.localDebugMode {
|
|
return fmt.Errorf("%w: local debug mode is required", errRuntimeRaidCreatedRecoverySeed)
|
|
}
|
|
raw, err := base64.StdEncoding.DecodeString(s.options.raidCreatedRecoverySeed)
|
|
if err != nil {
|
|
return fmt.Errorf("%w: decode base64: %v", errRuntimeRaidCreatedRecoverySeed, err)
|
|
}
|
|
var seed runtimeRaidCreatedRecoverySeed
|
|
if err := json.Unmarshal(raw, &seed); err != nil {
|
|
return fmt.Errorf("%w: decode json: %v", errRuntimeRaidCreatedRecoverySeed, err)
|
|
}
|
|
if seed.RaidKey == 0 || seed.LeaderID == 0 || uint16(seed.RaidKey) != seed.LeaderID ||
|
|
seed.RaidKey>>16 == 0 || len(seed.NameBytes) == 0 || len(seed.NameBytes) > 0xff ||
|
|
seed.TailFlag > 1 || seed.SingleRaidType != 0 {
|
|
return fmt.Errorf("%w: unsupported created object", errRuntimeRaidCreatedRecoverySeed)
|
|
}
|
|
|
|
s.raidMu.Lock()
|
|
defer s.raidMu.Unlock()
|
|
s.ensureRuntimeRaidMapsLocked()
|
|
if len(s.raids) != 0 || s.runtimeRaidByMemberLocked(seed.LeaderID) != nil {
|
|
return fmt.Errorf("%w: runtime raid state is not empty", errRuntimeRaidCreatedRecoverySeed)
|
|
}
|
|
member := s.newRuntimeRaidMemberLocked(seed.LeaderID, runtimeRaidDefaultGroup, 0)
|
|
state := &runtimeRaidState{
|
|
RaidKey: seed.RaidKey,
|
|
LeaderID: seed.LeaderID,
|
|
RouteOrRaidType: seed.RouteOrRaidType,
|
|
NameBytes: append([]byte(nil), seed.NameBytes...),
|
|
TailFlag: seed.TailFlag,
|
|
SingleRaidType: seed.SingleRaidType,
|
|
Members: []runtimeRaidMemberState{member},
|
|
Lifecycle: runtimeRaidLifecycleState{
|
|
Status: runtimeRaidLifecycleCreated,
|
|
},
|
|
}
|
|
s.raids[state.RaidKey] = state
|
|
s.logInfo("dnfbridge local created raid recovery seed restored",
|
|
"raid_key", state.RaidKey,
|
|
"leader_id", state.LeaderID,
|
|
"member_count", len(state.Members),
|
|
"route_or_raid_type", state.RouteOrRaidType,
|
|
"tail_flag", state.TailFlag,
|
|
"single_raid_type", state.SingleRaidType,
|
|
"source", "operator_supplied_current_process_packet_evidence")
|
|
return nil
|
|
}
|