forked from rojo-rbx/rojo
Compare commits
27 Commits
v7.0.0-rc.
...
v7.0.0
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
07637dfe96 | ||
|
|
f389a4a1db | ||
|
|
af077c796c | ||
|
|
1c319f2fa8 | ||
|
|
e8afa03f7b | ||
|
|
9b22545842 | ||
|
|
adc733d25c | ||
|
|
6896257647 | ||
|
|
1d9845a6cb | ||
|
|
8461339e9a | ||
|
|
9904d94e4c | ||
|
|
da25c80d0b | ||
|
|
5fa63733fd | ||
|
|
8b54bf0ba1 | ||
|
|
173dc12cb3 | ||
|
|
e136529ff0 | ||
|
|
75542dacb3 | ||
|
|
07abfbde43 | ||
|
|
96112fe118 | ||
|
|
9d0b313261 | ||
|
|
277ddfa9be | ||
|
|
5d88bdb256 | ||
|
|
8d29b43155 | ||
|
|
cc071a6415 | ||
|
|
8954def25c | ||
|
|
d484098781 | ||
|
|
9f06cbf3a0 |
2
.github/workflows/ci.yml
vendored
2
.github/workflows/ci.yml
vendored
@@ -16,7 +16,7 @@ jobs:
|
|||||||
|
|
||||||
strategy:
|
strategy:
|
||||||
matrix:
|
matrix:
|
||||||
rust_version: [stable, "1.46.0"]
|
rust_version: [stable, "1.55.0"]
|
||||||
|
|
||||||
steps:
|
steps:
|
||||||
- uses: actions/checkout@v1
|
- uses: actions/checkout@v1
|
||||||
|
|||||||
37
CHANGELOG.md
37
CHANGELOG.md
@@ -2,7 +2,36 @@
|
|||||||
|
|
||||||
## Unreleased Changes
|
## Unreleased Changes
|
||||||
|
|
||||||
## [7.0.0-rc.1][7.0.0-rc.1] (August 23, 2021)
|
## [7.0.0] - December 10, 2021
|
||||||
|
* Fixed Rojo's interactions with properties enabled by FFlags that are not yet enabled. ([#493])
|
||||||
|
* Improved output in Roblox Studio plugin when bad property data is encountered.
|
||||||
|
* Reintroduced support for CFrame shorthand syntax in Rojo project and `.meta.json` files, matching Rojo 6. ([#430])
|
||||||
|
* Connection settings are now remembered when reconnecting in Roblox Studio. ([#500])
|
||||||
|
* Updated reflection database to Roblox v503.
|
||||||
|
|
||||||
|
[#430]: https://github.com/rojo-rbx/rojo/issues/430
|
||||||
|
[#493]: https://github.com/rojo-rbx/rojo/pull/493
|
||||||
|
[#500]: https://github.com/rojo-rbx/rojo/pull/500
|
||||||
|
[7.0.0]: https://github.com/rojo-rbx/rojo/releases/tag/v7.0.0
|
||||||
|
|
||||||
|
## [7.0.0-rc.3] - October 19, 2021
|
||||||
|
This is the last release candidate for Rojo 7. In an effort to get Rojo 7 out the door, we'll be freezing features from here on out, something we should've done a couple months ago.
|
||||||
|
|
||||||
|
Expect to see Rojo 7 stable soon!
|
||||||
|
|
||||||
|
* Added support for writing `Tags` in project files, model files, and meta files. ([#484])
|
||||||
|
* Adjusted Studio plugin colors to match Roblox Studio palette. ([#482])
|
||||||
|
* Improved experimental two-way sync feature by batching changes. ([#478])
|
||||||
|
|
||||||
|
[#482]: https://github.com/rojo-rbx/rojo/pull/482
|
||||||
|
[#484]: https://github.com/rojo-rbx/rojo/pull/484
|
||||||
|
[#478]: https://github.com/rojo-rbx/rojo/pull/478
|
||||||
|
[7.0.0-rc.3]: https://github.com/rojo-rbx/rojo/releases/tag/v7.0.0-rc.3
|
||||||
|
|
||||||
|
## 7.0.0-rc.2 - October 19, 2021
|
||||||
|
(Botched release due to Git mishap, oops!)
|
||||||
|
|
||||||
|
## [7.0.0-rc.1] - August 23, 2021
|
||||||
In Rojo 6 and previous Rojo 7 alphas, an explicit Vector3 property would be written like this:
|
In Rojo 6 and previous Rojo 7 alphas, an explicit Vector3 property would be written like this:
|
||||||
|
|
||||||
```json
|
```json
|
||||||
@@ -45,9 +74,9 @@ The shorthand property format that most users use is not impacted. For reference
|
|||||||
* Added the `fmt-project` subcommand for formatting Rojo project files.
|
* Added the `fmt-project` subcommand for formatting Rojo project files.
|
||||||
* Improved error output for many subcommands.
|
* Improved error output for many subcommands.
|
||||||
* Updated to stable versions of rbx-dom libraries.
|
* Updated to stable versions of rbx-dom libraries.
|
||||||
* Updated async infrastructure, which should fix a handful of bugs. ([#459][#459])
|
* Updated async infrastructure, which should fix a handful of bugs. ([#459])
|
||||||
* Fixed syncing refs in the Roblox Studio plugin ([#462][#462], [#466][#466])
|
* Fixed syncing refs in the Roblox Studio plugin ([#462], [#466])
|
||||||
* Added support for long paths on Windows. ([#464][#464])
|
* Added support for long paths on Windows. ([#464])
|
||||||
|
|
||||||
[#459]: https://github.com/rojo-rbx/rojo/pull/459
|
[#459]: https://github.com/rojo-rbx/rojo/pull/459
|
||||||
[#462]: https://github.com/rojo-rbx/rojo/pull/462
|
[#462]: https://github.com/rojo-rbx/rojo/pull/462
|
||||||
|
|||||||
@@ -29,21 +29,27 @@ Sometimes there's something that Rojo doesn't do that it probably should.
|
|||||||
|
|
||||||
Please file issues and we'll try to help figure out what the best way forward is.
|
Please file issues and we'll try to help figure out what the best way forward is.
|
||||||
|
|
||||||
|
## Local Development Gotchas
|
||||||
|
|
||||||
|
If your build fails with "Error: failed to open file `D:\code\rojo\plugin\modules\roact\src`" you need to update your Git submodules.
|
||||||
|
Run the command and try building again: `git submodule update --init --recursive`.
|
||||||
|
|
||||||
## Pushing a Rojo Release
|
## Pushing a Rojo Release
|
||||||
The Rojo release process is pretty manual right now. If you need to do it, here's how:
|
The Rojo release process is pretty manual right now. If you need to do it, here's how:
|
||||||
|
|
||||||
1. Bump server version in [`Cargo.toml`](Cargo.toml)
|
1. Bump server version in [`Cargo.toml`](Cargo.toml)
|
||||||
2. Bump plugin version in [`plugin/src/Config.lua`](plugin/src/Config.lua)
|
2. Bump plugin version in [`plugin/src/Config.lua`](plugin/src/Config.lua)
|
||||||
3. Run `cargo test` to update `Cargo.lock` and double-check tests
|
3. Run `cargo test` to update `Cargo.lock` and run tests
|
||||||
4. Update [`CHANGELOG.md`](CHANGELOG.md)
|
4. Update [`CHANGELOG.md`](CHANGELOG.md)
|
||||||
5. Commit!
|
5. Commit!
|
||||||
* `git add . && git commit -m "Release vX.Y.Z"`
|
* `git add . && git commit -m "Release vX.Y.Z"`
|
||||||
6. Tag the commit with the version from `Cargo.toml` prepended with a v, like `v0.4.13`
|
6. Tag the commit
|
||||||
|
* `git tag vX.Y.Z`
|
||||||
7. Publish the CLI
|
7. Publish the CLI
|
||||||
* `cargo publish`
|
* `cargo publish`
|
||||||
8. Publish the Plugin
|
8. Publish the Plugin
|
||||||
* `rojo publish plugin --asset_id 6415005344`
|
* `cargo run -- upload plugin --asset_id 6415005344`
|
||||||
* `rojo build plugin -o Rojo.rbxm`
|
* `cargo run -- build plugin --output Rojo.rbxm`
|
||||||
9. Push commits and tags
|
9. Push commits and tags
|
||||||
* `git push && git push --tags`
|
* `git push && git push --tags`
|
||||||
10. Copy GitHub release content from previous release
|
10. Copy GitHub release content from previous release
|
||||||
|
|||||||
410
Cargo.lock
generated
410
Cargo.lock
generated
File diff suppressed because it is too large
Load Diff
82
Cargo.toml
82
Cargo.toml
@@ -1,6 +1,6 @@
|
|||||||
[package]
|
[package]
|
||||||
name = "rojo"
|
name = "rojo"
|
||||||
version = "7.0.0-rc.1"
|
version = "7.0.0"
|
||||||
authors = ["Lucien Greathouse <me@lpghatguy.com>"]
|
authors = ["Lucien Greathouse <me@lpghatguy.com>"]
|
||||||
description = "Enables professional-grade development tools for Roblox developers"
|
description = "Enables professional-grade development tools for Roblox developers"
|
||||||
license = "MPL-2.0"
|
license = "MPL-2.0"
|
||||||
@@ -37,10 +37,6 @@ members = [
|
|||||||
name = "librojo"
|
name = "librojo"
|
||||||
path = "src/lib.rs"
|
path = "src/lib.rs"
|
||||||
|
|
||||||
[[bin]]
|
|
||||||
name = "rojo"
|
|
||||||
path = "src/bin.rs"
|
|
||||||
|
|
||||||
[[bench]]
|
[[bench]]
|
||||||
name = "build"
|
name = "build"
|
||||||
harness = false
|
harness = false
|
||||||
@@ -55,41 +51,41 @@ memofs = { version = "0.2.0", path = "memofs" }
|
|||||||
# rbx_reflection_database = { path = "../rbx-dom/rbx_reflection_database" }
|
# rbx_reflection_database = { path = "../rbx-dom/rbx_reflection_database" }
|
||||||
# rbx_xml = { path = "../rbx-dom/rbx_xml" }
|
# rbx_xml = { path = "../rbx-dom/rbx_xml" }
|
||||||
|
|
||||||
rbx_binary = "0.6.1"
|
rbx_binary = "0.6.4"
|
||||||
rbx_dom_weak = "2.1.0"
|
rbx_dom_weak = "2.3.0"
|
||||||
rbx_reflection = "4.1.0"
|
rbx_reflection = "4.2.0"
|
||||||
rbx_reflection_database = "0.2.1"
|
rbx_reflection_database = "0.2.2"
|
||||||
rbx_xml = "0.12.1"
|
rbx_xml = "0.12.3"
|
||||||
|
|
||||||
anyhow = "1.0.27"
|
anyhow = "1.0.44"
|
||||||
backtrace = "0.3"
|
backtrace = "0.3.61"
|
||||||
bincode = "1.2.1"
|
bincode = "1.3.3"
|
||||||
crossbeam-channel = "0.5.1"
|
crossbeam-channel = "0.5.1"
|
||||||
csv = "1.1.1"
|
csv = "1.1.6"
|
||||||
env_logger = "0.9.0"
|
env_logger = "0.9.0"
|
||||||
fs-err = "2.2.0"
|
fs-err = "2.6.0"
|
||||||
futures = "0.3.16"
|
futures = "0.3.17"
|
||||||
globset = "0.4.4"
|
globset = "0.4.8"
|
||||||
humantime = "2.1.0"
|
humantime = "2.1.0"
|
||||||
hyper = { version = "0.14.11", features = ["server", "tcp", "http1"] }
|
hyper = { version = "0.14.13", features = ["server", "tcp", "http1"] }
|
||||||
jod-thread = "0.1.0"
|
jod-thread = "0.1.2"
|
||||||
lazy_static = "1.4.0"
|
lazy_static = "1.4.0"
|
||||||
log = "0.4.8"
|
log = "0.4.14"
|
||||||
maplit = "1.0.1"
|
maplit = "1.0.2"
|
||||||
notify = "4.0.14"
|
notify = "4.0.17"
|
||||||
opener = "0.5.0"
|
opener = "0.5.0"
|
||||||
regex = "1.3.1"
|
regex = "1.5.4"
|
||||||
reqwest = "0.9.20"
|
reqwest = "0.9.24"
|
||||||
ritz = "0.1.0"
|
ritz = "0.1.0"
|
||||||
rlua = "0.17.0"
|
rlua = "0.17.1"
|
||||||
roblox_install = "1.0.0"
|
roblox_install = "1.0.0"
|
||||||
serde = { version = "1.0", features = ["derive", "rc"] }
|
serde = { version = "1.0.130", features = ["derive", "rc"] }
|
||||||
serde_json = "1.0"
|
serde_json = "1.0.68"
|
||||||
structopt = "0.3.5"
|
structopt = "0.3.23"
|
||||||
termcolor = "1.0.5"
|
termcolor = "1.1.2"
|
||||||
thiserror = "1.0.11"
|
thiserror = "1.0.30"
|
||||||
tokio = { version = "1.9.0", features = ["rt", "rt-multi-thread"] }
|
tokio = { version = "1.12.0", features = ["rt", "rt-multi-thread"] }
|
||||||
uuid = { version = "0.8.1", features = ["v4", "serde"] }
|
uuid = { version = "0.8.2", features = ["v4", "serde"] }
|
||||||
|
|
||||||
[target.'cfg(windows)'.dependencies]
|
[target.'cfg(windows)'.dependencies]
|
||||||
winreg = "0.9.0"
|
winreg = "0.9.0"
|
||||||
@@ -97,20 +93,20 @@ winreg = "0.9.0"
|
|||||||
[build-dependencies]
|
[build-dependencies]
|
||||||
memofs = { version = "0.2.0", path = "memofs" }
|
memofs = { version = "0.2.0", path = "memofs" }
|
||||||
|
|
||||||
embed-resource = "1.6"
|
embed-resource = "1.6.4"
|
||||||
anyhow = "1.0.27"
|
anyhow = "1.0.44"
|
||||||
bincode = "1.2.1"
|
bincode = "1.3.3"
|
||||||
fs-err = "2.3.0"
|
fs-err = "2.6.0"
|
||||||
maplit = "1.0.1"
|
maplit = "1.0.2"
|
||||||
|
|
||||||
[dev-dependencies]
|
[dev-dependencies]
|
||||||
rojo-insta-ext = { path = "rojo-insta-ext" }
|
rojo-insta-ext = { path = "rojo-insta-ext" }
|
||||||
|
|
||||||
criterion = "0.3"
|
criterion = "0.3.5"
|
||||||
insta = { version = "1.3.0", features = ["redactions"] }
|
insta = { version = "1.8.0", features = ["redactions"] }
|
||||||
lazy_static = "1.2"
|
lazy_static = "1.4.0"
|
||||||
paste = "1.0.5"
|
paste = "1.0.5"
|
||||||
pretty_assertions = "0.7.2"
|
pretty_assertions = "0.7.2"
|
||||||
serde_yaml = "0.8.9"
|
serde_yaml = "0.8.21"
|
||||||
tempfile = "3.0"
|
tempfile = "3.2.0"
|
||||||
walkdir = "2.1"
|
walkdir = "2.3.2"
|
||||||
|
|||||||
Submodule plugin/modules/testez updated: 6e9157db3c...25d957d4d5
@@ -388,6 +388,11 @@ types = {
|
|||||||
end,
|
end,
|
||||||
},
|
},
|
||||||
|
|
||||||
|
Tags = {
|
||||||
|
fromPod = identity,
|
||||||
|
toPod = identity,
|
||||||
|
},
|
||||||
|
|
||||||
Vector2 = {
|
Vector2 = {
|
||||||
fromPod = unpackDecoder(Vector2.new),
|
fromPod = unpackDecoder(Vector2.new),
|
||||||
|
|
||||||
|
|||||||
@@ -20,7 +20,21 @@ local function set(container, key, value)
|
|||||||
end
|
end
|
||||||
|
|
||||||
function PropertyDescriptor.fromRaw(data, className, propertyName)
|
function PropertyDescriptor.fromRaw(data, className, propertyName)
|
||||||
|
local key, value = next(data.DataType)
|
||||||
|
|
||||||
return setmetatable({
|
return setmetatable({
|
||||||
|
-- The meanings of the key and value in DataType differ when the type of
|
||||||
|
-- the property is Enum. When the property is of type Enum, the key is
|
||||||
|
-- the name of the type:
|
||||||
|
--
|
||||||
|
-- { Enum = "<name of enum>" }
|
||||||
|
--
|
||||||
|
-- When the property is not of type Enum, the value is the name of the
|
||||||
|
-- type:
|
||||||
|
--
|
||||||
|
-- { Value = "<data type>" }
|
||||||
|
dataType = key == "Enum" and key or value,
|
||||||
|
|
||||||
scriptability = data.Scriptability,
|
scriptability = data.Scriptability,
|
||||||
className = className,
|
className = className,
|
||||||
name = propertyName,
|
name = propertyName,
|
||||||
|
|||||||
@@ -251,6 +251,16 @@
|
|||||||
},
|
},
|
||||||
"ty": "String"
|
"ty": "String"
|
||||||
},
|
},
|
||||||
|
"Tags": {
|
||||||
|
"value": {
|
||||||
|
"Tags": [
|
||||||
|
"foo",
|
||||||
|
"con'fusion?!",
|
||||||
|
"bar"
|
||||||
|
]
|
||||||
|
},
|
||||||
|
"ty": "Tags"
|
||||||
|
},
|
||||||
"UDim": {
|
"UDim": {
|
||||||
"value": {
|
"value": {
|
||||||
"UDim": [
|
"UDim": [
|
||||||
|
|||||||
@@ -6,12 +6,10 @@ local CollectionService = game:GetService("CollectionService")
|
|||||||
return {
|
return {
|
||||||
Instance = {
|
Instance = {
|
||||||
Tags = {
|
Tags = {
|
||||||
read = function(instance, key)
|
read = function(instance)
|
||||||
local tagList = CollectionService:GetTags(instance)
|
return true, CollectionService:GetTags(instance)
|
||||||
|
|
||||||
return true, table.concat(tagList, "\0")
|
|
||||||
end,
|
end,
|
||||||
write = function(instance, key, value)
|
write = function(instance, _, value)
|
||||||
local existingTags = CollectionService:GetTags(instance)
|
local existingTags = CollectionService:GetTags(instance)
|
||||||
|
|
||||||
local unseenTags = {}
|
local unseenTags = {}
|
||||||
@@ -19,8 +17,7 @@ return {
|
|||||||
unseenTags[tag] = true
|
unseenTags[tag] = true
|
||||||
end
|
end
|
||||||
|
|
||||||
local tagList = string.split(value, "\0")
|
for _, tag in ipairs(value) do
|
||||||
for _, tag in ipairs(tagList) do
|
|
||||||
unseenTags[tag] = nil
|
unseenTags[tag] = nil
|
||||||
CollectionService:AddTag(instance, tag)
|
CollectionService:AddTag(instance, tag)
|
||||||
end
|
end
|
||||||
|
|||||||
File diff suppressed because it is too large
Load Diff
@@ -14,6 +14,8 @@ local PORT_WIDTH = 74
|
|||||||
local DIVIDER_WIDTH = 1
|
local DIVIDER_WIDTH = 1
|
||||||
local HOST_OFFSET = 12
|
local HOST_OFFSET = 12
|
||||||
|
|
||||||
|
local lastHost, lastPort
|
||||||
|
|
||||||
local e = Roact.createElement
|
local e = Roact.createElement
|
||||||
|
|
||||||
local function AddressEntry(props)
|
local function AddressEntry(props)
|
||||||
@@ -24,7 +26,7 @@ local function AddressEntry(props)
|
|||||||
layoutOrder = props.layoutOrder,
|
layoutOrder = props.layoutOrder,
|
||||||
}, {
|
}, {
|
||||||
Host = e("TextBox", {
|
Host = e("TextBox", {
|
||||||
Text = "",
|
Text = lastHost or "",
|
||||||
Font = Enum.Font.Code,
|
Font = Enum.Font.Code,
|
||||||
TextSize = 18,
|
TextSize = 18,
|
||||||
TextColor3 = theme.AddressEntry.TextColor,
|
TextColor3 = theme.AddressEntry.TextColor,
|
||||||
@@ -43,7 +45,7 @@ local function AddressEntry(props)
|
|||||||
}),
|
}),
|
||||||
|
|
||||||
Port = e("TextBox", {
|
Port = e("TextBox", {
|
||||||
Text = "",
|
Text = lastPort or "",
|
||||||
Font = Enum.Font.Code,
|
Font = Enum.Font.Code,
|
||||||
TextSize = 18,
|
TextSize = 18,
|
||||||
TextColor3 = theme.AddressEntry.TextColor,
|
TextColor3 = theme.AddressEntry.TextColor,
|
||||||
@@ -121,6 +123,9 @@ function NotConnectedPage:render()
|
|||||||
local hostText = self.hostRef.current.Text
|
local hostText = self.hostRef.current.Text
|
||||||
local portText = self.portRef.current.Text
|
local portText = self.portRef.current.Text
|
||||||
|
|
||||||
|
lastHost = hostText
|
||||||
|
lastPort = portText
|
||||||
|
|
||||||
self.props.onConnect(
|
self.props.onConnect(
|
||||||
#hostText > 0 and hostText or Config.defaultHost,
|
#hostText > 0 and hostText or Config.defaultHost,
|
||||||
#portText > 0 and portText or Config.defaultPort
|
#portText > 0 and portText or Config.defaultPort
|
||||||
|
|||||||
@@ -34,7 +34,7 @@ end
|
|||||||
local BRAND_COLOR = hexColor(0xE13835)
|
local BRAND_COLOR = hexColor(0xE13835)
|
||||||
|
|
||||||
local lightTheme = strict("LightTheme", {
|
local lightTheme = strict("LightTheme", {
|
||||||
BackgroundColor = hexColor(0xF0F0F0),
|
BackgroundColor = hexColor(0xFFFFFF),
|
||||||
Button = {
|
Button = {
|
||||||
Solid = {
|
Solid = {
|
||||||
ActionFillColor = hexColor(0xFFFFFF),
|
ActionFillColor = hexColor(0xFFFFFF),
|
||||||
@@ -67,7 +67,7 @@ local lightTheme = strict("LightTheme", {
|
|||||||
BackgroundColor = BRAND_COLOR,
|
BackgroundColor = BRAND_COLOR,
|
||||||
},
|
},
|
||||||
Inactive = {
|
Inactive = {
|
||||||
IconColor = hexColor(0xCACACA),
|
IconColor = hexColor(0xEEEEEE),
|
||||||
BorderColor = hexColor(0xAFAFAF),
|
BorderColor = hexColor(0xAFAFAF),
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
@@ -77,11 +77,11 @@ local lightTheme = strict("LightTheme", {
|
|||||||
},
|
},
|
||||||
BorderedContainer = {
|
BorderedContainer = {
|
||||||
BorderColor = hexColor(0xCBCBCB),
|
BorderColor = hexColor(0xCBCBCB),
|
||||||
BackgroundColor = hexColor(0xE0E0E0),
|
BackgroundColor = hexColor(0xEEEEEE),
|
||||||
},
|
},
|
||||||
Spinner = {
|
Spinner = {
|
||||||
ForegroundColor = BRAND_COLOR,
|
ForegroundColor = BRAND_COLOR,
|
||||||
BackgroundColor = hexColor(0xE0E0E0),
|
BackgroundColor = hexColor(0xEEEEEE),
|
||||||
},
|
},
|
||||||
ConnectionDetails = {
|
ConnectionDetails = {
|
||||||
ProjectNameColor = hexColor(0x00000),
|
ProjectNameColor = hexColor(0x00000),
|
||||||
@@ -108,7 +108,7 @@ local lightTheme = strict("LightTheme", {
|
|||||||
})
|
})
|
||||||
|
|
||||||
local darkTheme = strict("DarkTheme", {
|
local darkTheme = strict("DarkTheme", {
|
||||||
BackgroundColor = hexColor(0x272727),
|
BackgroundColor = hexColor(0x2E2E2E),
|
||||||
Button = {
|
Button = {
|
||||||
Solid = {
|
Solid = {
|
||||||
ActionFillColor = hexColor(0xFFFFFF),
|
ActionFillColor = hexColor(0xFFFFFF),
|
||||||
@@ -147,15 +147,15 @@ local darkTheme = strict("DarkTheme", {
|
|||||||
},
|
},
|
||||||
AddressEntry = {
|
AddressEntry = {
|
||||||
TextColor = hexColor(0xFFFFFF),
|
TextColor = hexColor(0xFFFFFF),
|
||||||
PlaceholderColor = hexColor(0x717171)
|
PlaceholderColor = hexColor(0x8B8B8B)
|
||||||
},
|
},
|
||||||
BorderedContainer = {
|
BorderedContainer = {
|
||||||
BorderColor = hexColor(0x535353),
|
BorderColor = hexColor(0x535353),
|
||||||
BackgroundColor = hexColor(0x323232),
|
BackgroundColor = hexColor(0x2B2B2B),
|
||||||
},
|
},
|
||||||
Spinner = {
|
Spinner = {
|
||||||
ForegroundColor = BRAND_COLOR,
|
ForegroundColor = BRAND_COLOR,
|
||||||
BackgroundColor = hexColor(0x323232),
|
BackgroundColor = hexColor(0x2B2B2B),
|
||||||
},
|
},
|
||||||
ConnectionDetails = {
|
ConnectionDetails = {
|
||||||
ProjectNameColor = hexColor(0xFFFFFF),
|
ProjectNameColor = hexColor(0xFFFFFF),
|
||||||
|
|||||||
40
plugin/src/ChangeBatcher/createPatchSet.lua
Normal file
40
plugin/src/ChangeBatcher/createPatchSet.lua
Normal file
@@ -0,0 +1,40 @@
|
|||||||
|
--[[
|
||||||
|
Take an InstanceMap and a dictionary mapping instances to sets of property
|
||||||
|
names. Populate a patch with the encoded values of all the given properties
|
||||||
|
on all the given instances (or, if any changes set Parent to nil, removals
|
||||||
|
of instances) and return the patch.
|
||||||
|
]]
|
||||||
|
|
||||||
|
local Log = require(script.Parent.Parent.Parent.Log)
|
||||||
|
|
||||||
|
local PatchSet = require(script.Parent.Parent.PatchSet)
|
||||||
|
|
||||||
|
local encodePatchUpdate = require(script.Parent.encodePatchUpdate)
|
||||||
|
|
||||||
|
return function(instanceMap, propertyChanges)
|
||||||
|
local patch = PatchSet.newEmpty()
|
||||||
|
|
||||||
|
for instance, properties in pairs(propertyChanges) do
|
||||||
|
local instanceId = instanceMap.fromInstances[instance]
|
||||||
|
|
||||||
|
if instanceId == nil then
|
||||||
|
Log.warn("Ignoring change for instance {:?} as it is unknown to Rojo", instance)
|
||||||
|
continue
|
||||||
|
end
|
||||||
|
|
||||||
|
if properties.Parent then
|
||||||
|
if instance.Parent == nil then
|
||||||
|
table.insert(patch.removed, instanceId)
|
||||||
|
else
|
||||||
|
Log.warn("Cannot sync non-nil Parent property changes yet")
|
||||||
|
end
|
||||||
|
else
|
||||||
|
local update = encodePatchUpdate(instance, instanceId, properties)
|
||||||
|
table.insert(patch.updated, update)
|
||||||
|
end
|
||||||
|
|
||||||
|
propertyChanges[instance] = nil
|
||||||
|
end
|
||||||
|
|
||||||
|
return patch
|
||||||
|
end
|
||||||
74
plugin/src/ChangeBatcher/createPatchSet.spec.lua
Normal file
74
plugin/src/ChangeBatcher/createPatchSet.spec.lua
Normal file
@@ -0,0 +1,74 @@
|
|||||||
|
return function()
|
||||||
|
local PatchSet = require(script.Parent.Parent.PatchSet)
|
||||||
|
local InstanceMap = require(script.Parent.Parent.InstanceMap)
|
||||||
|
|
||||||
|
local createPatchSet = require(script.Parent.createPatchSet)
|
||||||
|
|
||||||
|
it("should return a patch", function()
|
||||||
|
local patch = createPatchSet(InstanceMap.new(), {})
|
||||||
|
|
||||||
|
assert(PatchSet.validate(patch))
|
||||||
|
end)
|
||||||
|
|
||||||
|
it("should contain updates for every instance with property changes", function()
|
||||||
|
local instanceMap = InstanceMap.new()
|
||||||
|
|
||||||
|
local part1 = Instance.new("Part")
|
||||||
|
instanceMap:insert("PART_1", part1)
|
||||||
|
|
||||||
|
local part2 = Instance.new("Part")
|
||||||
|
instanceMap:insert("PART_2", part2)
|
||||||
|
|
||||||
|
local changes = {
|
||||||
|
[part1] = {
|
||||||
|
Position = true,
|
||||||
|
Size = true,
|
||||||
|
Color = true,
|
||||||
|
},
|
||||||
|
[part2] = {
|
||||||
|
CFrame = true,
|
||||||
|
Velocity = true,
|
||||||
|
Transparency = true,
|
||||||
|
},
|
||||||
|
}
|
||||||
|
|
||||||
|
local patch = createPatchSet(instanceMap, changes)
|
||||||
|
|
||||||
|
expect(#patch.updated).to.equal(2)
|
||||||
|
end)
|
||||||
|
|
||||||
|
it("should not contain any updates for removed instances", function()
|
||||||
|
local instanceMap = InstanceMap.new()
|
||||||
|
|
||||||
|
local part1 = Instance.new("Part")
|
||||||
|
instanceMap:insert("PART_1", part1)
|
||||||
|
|
||||||
|
local changes = {
|
||||||
|
[part1] = {
|
||||||
|
Parent = true,
|
||||||
|
Position = true,
|
||||||
|
Size = true,
|
||||||
|
},
|
||||||
|
}
|
||||||
|
|
||||||
|
local patch = createPatchSet(instanceMap, changes)
|
||||||
|
|
||||||
|
expect(#patch.removed).to.equal(1)
|
||||||
|
expect(#patch.updated).to.equal(0)
|
||||||
|
end)
|
||||||
|
|
||||||
|
it("should remove instances from the property change table", function()
|
||||||
|
local instanceMap = InstanceMap.new()
|
||||||
|
|
||||||
|
local part1 = Instance.new("Part")
|
||||||
|
instanceMap:insert("PART_1", part1)
|
||||||
|
|
||||||
|
local changes = {
|
||||||
|
[part1] = {},
|
||||||
|
}
|
||||||
|
|
||||||
|
createPatchSet(instanceMap, changes)
|
||||||
|
|
||||||
|
expect(next(changes)).to.equal(nil)
|
||||||
|
end)
|
||||||
|
end
|
||||||
39
plugin/src/ChangeBatcher/encodePatchUpdate.lua
Normal file
39
plugin/src/ChangeBatcher/encodePatchUpdate.lua
Normal file
@@ -0,0 +1,39 @@
|
|||||||
|
local Log = require(script.Parent.Parent.Parent.Log)
|
||||||
|
local RbxDom = require(script.Parent.Parent.Parent.RbxDom)
|
||||||
|
|
||||||
|
local encodeProperty = require(script.Parent.encodeProperty)
|
||||||
|
|
||||||
|
return function(instance, instanceId, properties)
|
||||||
|
local update = {
|
||||||
|
id = instanceId,
|
||||||
|
changedProperties = {},
|
||||||
|
}
|
||||||
|
|
||||||
|
for propertyName in pairs(properties) do
|
||||||
|
if propertyName == "Name" then
|
||||||
|
update.changedName = instance.Name
|
||||||
|
else
|
||||||
|
local descriptor = RbxDom.findCanonicalPropertyDescriptor(instance.ClassName, propertyName)
|
||||||
|
|
||||||
|
if not descriptor then
|
||||||
|
Log.debug("Could not sync back property {:?}.{}", instance, propertyName)
|
||||||
|
continue
|
||||||
|
end
|
||||||
|
|
||||||
|
local encodeSuccess, encodeResult = encodeProperty(instance, propertyName, descriptor)
|
||||||
|
|
||||||
|
if not encodeSuccess then
|
||||||
|
Log.debug("Could not sync back property {:?}.{}: {}", instance, propertyName, encodeResult)
|
||||||
|
continue
|
||||||
|
end
|
||||||
|
|
||||||
|
update.changedProperties[propertyName] = encodeResult
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
|
if next(update.changedProperties) == nil and update.changedName == nil then
|
||||||
|
return nil
|
||||||
|
end
|
||||||
|
|
||||||
|
return update
|
||||||
|
end
|
||||||
62
plugin/src/ChangeBatcher/encodePatchUpdate.spec.lua
Normal file
62
plugin/src/ChangeBatcher/encodePatchUpdate.spec.lua
Normal file
@@ -0,0 +1,62 @@
|
|||||||
|
return function()
|
||||||
|
local encodePatchUpdate = require(script.Parent.encodePatchUpdate)
|
||||||
|
|
||||||
|
it("should return an update when there are property changes", function()
|
||||||
|
local part = Instance.new("Part")
|
||||||
|
local properties = {
|
||||||
|
CFrame = true,
|
||||||
|
Color = true,
|
||||||
|
}
|
||||||
|
local update = encodePatchUpdate(part, "PART", properties)
|
||||||
|
|
||||||
|
expect(update.id).to.equal("PART")
|
||||||
|
expect(update.changedProperties.CFrame).to.be.ok()
|
||||||
|
expect(update.changedProperties.Color).to.be.ok()
|
||||||
|
end)
|
||||||
|
|
||||||
|
it("should return nil when there are no property changes", function()
|
||||||
|
local part = Instance.new("Part")
|
||||||
|
local properties = {
|
||||||
|
NonExistentProperty = true,
|
||||||
|
}
|
||||||
|
local update = encodePatchUpdate(part, "PART", properties)
|
||||||
|
|
||||||
|
expect(update).to.equal(nil)
|
||||||
|
end)
|
||||||
|
|
||||||
|
it("should set changedName in the update when the instance's Name changes", function()
|
||||||
|
local part = Instance.new("Part")
|
||||||
|
local properties = {
|
||||||
|
Name = true,
|
||||||
|
}
|
||||||
|
|
||||||
|
part.Name = "We'reGettingToTheCoolPart"
|
||||||
|
|
||||||
|
local update = encodePatchUpdate(part, "PART", properties)
|
||||||
|
|
||||||
|
expect(update.changedName).to.equal("We'reGettingToTheCoolPart")
|
||||||
|
end)
|
||||||
|
|
||||||
|
it("should correctly encode property values", function()
|
||||||
|
local part = Instance.new("Part")
|
||||||
|
local properties = {
|
||||||
|
Position = true,
|
||||||
|
Color = true,
|
||||||
|
}
|
||||||
|
|
||||||
|
part.Position = Vector3.new(0, 100, 0)
|
||||||
|
part.Color = Color3.new(0.8, 0.2, 0.9)
|
||||||
|
|
||||||
|
local update = encodePatchUpdate(part, "PART", properties)
|
||||||
|
local position = update.changedProperties.Position
|
||||||
|
local color = update.changedProperties.Color
|
||||||
|
|
||||||
|
expect(position.Vector3[1]).to.equal(0)
|
||||||
|
expect(position.Vector3[2]).to.equal(100)
|
||||||
|
expect(position.Vector3[3]).to.equal(0)
|
||||||
|
|
||||||
|
expect(color.Color3[1]).to.be.near(0.8, 0.01)
|
||||||
|
expect(color.Color3[2]).to.be.near(0.2, 0.01)
|
||||||
|
expect(color.Color3[3]).to.be.near(0.9, 0.01)
|
||||||
|
end)
|
||||||
|
end
|
||||||
21
plugin/src/ChangeBatcher/encodeProperty.lua
Normal file
21
plugin/src/ChangeBatcher/encodeProperty.lua
Normal file
@@ -0,0 +1,21 @@
|
|||||||
|
local Log = require(script.Parent.Parent.Parent.Log)
|
||||||
|
local RbxDom = require(script.Parent.Parent.Parent.RbxDom)
|
||||||
|
|
||||||
|
return function(instance, propertyName, propertyDescriptor)
|
||||||
|
local readSuccess, readResult = propertyDescriptor:read(instance)
|
||||||
|
|
||||||
|
if not readSuccess then
|
||||||
|
Log.warn("Could not sync back property {:?}.{}: {}", instance, propertyName, readResult)
|
||||||
|
return false, nil
|
||||||
|
end
|
||||||
|
|
||||||
|
local dataType = propertyDescriptor.dataType
|
||||||
|
local encodeSuccess, encodeResult = RbxDom.EncodedValue.encode(readResult, dataType)
|
||||||
|
|
||||||
|
if not encodeSuccess then
|
||||||
|
Log.warn("Could not sync back property {:?}.{}: {}", instance, propertyName, encodeResult)
|
||||||
|
return false, nil
|
||||||
|
end
|
||||||
|
|
||||||
|
return true, encodeResult
|
||||||
|
end
|
||||||
81
plugin/src/ChangeBatcher/init.lua
Normal file
81
plugin/src/ChangeBatcher/init.lua
Normal file
@@ -0,0 +1,81 @@
|
|||||||
|
--[[
|
||||||
|
The ChangeBatcher is responsible for collecting and dispatching changes made
|
||||||
|
to tracked instances during two-way sync.
|
||||||
|
]]
|
||||||
|
|
||||||
|
local RunService = game:GetService("RunService")
|
||||||
|
|
||||||
|
local PatchSet = require(script.Parent.PatchSet)
|
||||||
|
|
||||||
|
local createPatchSet = require(script.createPatchSet)
|
||||||
|
|
||||||
|
local ChangeBatcher = {}
|
||||||
|
ChangeBatcher.__index = ChangeBatcher
|
||||||
|
|
||||||
|
local BATCH_INTERVAL = 0.2
|
||||||
|
|
||||||
|
function ChangeBatcher.new(instanceMap, onChangesFlushed)
|
||||||
|
local self
|
||||||
|
|
||||||
|
local renderSteppedConnection = RunService.RenderStepped:Connect(function(dt)
|
||||||
|
self:__cycle(dt)
|
||||||
|
end)
|
||||||
|
|
||||||
|
self = setmetatable({
|
||||||
|
__accumulator = 0,
|
||||||
|
__renderSteppedConnection = renderSteppedConnection,
|
||||||
|
__instanceMap = instanceMap,
|
||||||
|
__onChangesFlushed = onChangesFlushed,
|
||||||
|
__pendingPropertyChanges = {},
|
||||||
|
}, ChangeBatcher)
|
||||||
|
|
||||||
|
return self
|
||||||
|
end
|
||||||
|
|
||||||
|
function ChangeBatcher:stop()
|
||||||
|
self.__renderSteppedConnection:Disconnect()
|
||||||
|
self.__pendingPropertyChanges = {}
|
||||||
|
end
|
||||||
|
|
||||||
|
function ChangeBatcher:add(instance, propertyName)
|
||||||
|
local properties = self.__pendingPropertyChanges[instance]
|
||||||
|
|
||||||
|
if not properties then
|
||||||
|
properties = {}
|
||||||
|
self.__pendingPropertyChanges[instance] = properties
|
||||||
|
end
|
||||||
|
|
||||||
|
properties[propertyName] = true
|
||||||
|
end
|
||||||
|
|
||||||
|
function ChangeBatcher:__cycle(dt)
|
||||||
|
self.__accumulator += dt
|
||||||
|
|
||||||
|
if self.__accumulator >= BATCH_INTERVAL then
|
||||||
|
self.__accumulator -= BATCH_INTERVAL
|
||||||
|
|
||||||
|
local patch = self:__flush()
|
||||||
|
|
||||||
|
if patch then
|
||||||
|
self.__onChangesFlushed(patch)
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
|
self.__instanceMap:unpauseAllInstances()
|
||||||
|
end
|
||||||
|
|
||||||
|
function ChangeBatcher:__flush()
|
||||||
|
if next(self.__pendingPropertyChanges) == nil then
|
||||||
|
return nil
|
||||||
|
end
|
||||||
|
|
||||||
|
local patch = createPatchSet(self.__instanceMap, self.__pendingPropertyChanges)
|
||||||
|
|
||||||
|
if PatchSet.isEmpty(patch) then
|
||||||
|
return nil
|
||||||
|
end
|
||||||
|
|
||||||
|
return patch
|
||||||
|
end
|
||||||
|
|
||||||
|
return ChangeBatcher
|
||||||
101
plugin/src/ChangeBatcher/init.spec.lua
Normal file
101
plugin/src/ChangeBatcher/init.spec.lua
Normal file
@@ -0,0 +1,101 @@
|
|||||||
|
return function()
|
||||||
|
local ChangeBatcher = require(script.Parent)
|
||||||
|
local InstanceMap = require(script.Parent.Parent.InstanceMap)
|
||||||
|
local PatchSet = require(script.Parent.Parent.PatchSet)
|
||||||
|
|
||||||
|
local noop = function() end
|
||||||
|
|
||||||
|
describe("new", function()
|
||||||
|
it("should create a new ChangeBatcher", function()
|
||||||
|
local instanceMap = InstanceMap.new()
|
||||||
|
local changeBatcher = ChangeBatcher.new(instanceMap, noop)
|
||||||
|
|
||||||
|
expect(changeBatcher.__pendingPropertyChanges).to.be.a("table")
|
||||||
|
expect(next(changeBatcher.__pendingPropertyChanges)).to.equal(nil)
|
||||||
|
expect(changeBatcher.__onChangesFlushed).to.equal(noop)
|
||||||
|
expect(changeBatcher.__instanceMap).to.equal(instanceMap)
|
||||||
|
expect(typeof(changeBatcher.__renderSteppedConnection)).to.equal("RBXScriptConnection")
|
||||||
|
end)
|
||||||
|
end)
|
||||||
|
|
||||||
|
describe("stop", function()
|
||||||
|
it("should disconnect the RenderStepped connection", function()
|
||||||
|
local changeBatcher = ChangeBatcher.new(InstanceMap.new(), noop)
|
||||||
|
|
||||||
|
changeBatcher:stop()
|
||||||
|
|
||||||
|
expect(changeBatcher.__renderSteppedConnection.Connected).to.equal(false)
|
||||||
|
end)
|
||||||
|
end)
|
||||||
|
|
||||||
|
describe("add", function()
|
||||||
|
it("should add property changes to be considered for the current batch", function()
|
||||||
|
local instanceMap = InstanceMap.new()
|
||||||
|
local changeBatcher = ChangeBatcher.new(instanceMap, noop)
|
||||||
|
local part = Instance.new("Part")
|
||||||
|
|
||||||
|
instanceMap:insert("PART", part)
|
||||||
|
changeBatcher:add(part, "Name")
|
||||||
|
|
||||||
|
local properties = changeBatcher.__pendingPropertyChanges[part]
|
||||||
|
|
||||||
|
expect(properties).to.be.a("table")
|
||||||
|
expect(properties.Name).to.be.ok()
|
||||||
|
|
||||||
|
changeBatcher:add(part, "Position")
|
||||||
|
expect(properties.Position).to.be.ok()
|
||||||
|
end)
|
||||||
|
end)
|
||||||
|
|
||||||
|
describe("__cycle", function()
|
||||||
|
it("should immediately unpause any paused instances after each cycle", function()
|
||||||
|
local instanceMap = InstanceMap.new()
|
||||||
|
local changeBatcher = ChangeBatcher.new(instanceMap, noop)
|
||||||
|
local part = Instance.new("Part")
|
||||||
|
|
||||||
|
instanceMap.pausedUpdateInstances[part] = true
|
||||||
|
|
||||||
|
changeBatcher:__cycle(0)
|
||||||
|
|
||||||
|
expect(instanceMap.pausedUpdateInstances[part]).to.equal(nil)
|
||||||
|
end)
|
||||||
|
end)
|
||||||
|
|
||||||
|
describe("__flush", function()
|
||||||
|
it("should return nil when there are no changes to process", function()
|
||||||
|
local changeBatcher = ChangeBatcher.new(InstanceMap.new(), noop)
|
||||||
|
expect(changeBatcher:__flush()).to.equal(nil)
|
||||||
|
end)
|
||||||
|
|
||||||
|
it("should return a patch when there are changes to process and the resulting patch is non-empty", function()
|
||||||
|
local instanceMap = InstanceMap.new()
|
||||||
|
local changeBatcher = ChangeBatcher.new(instanceMap, noop)
|
||||||
|
local part = Instance.new("Part")
|
||||||
|
|
||||||
|
instanceMap:insert("PART", part)
|
||||||
|
|
||||||
|
changeBatcher.__pendingPropertyChanges[part] = {
|
||||||
|
Position = true,
|
||||||
|
Name = true,
|
||||||
|
}
|
||||||
|
|
||||||
|
local patch = changeBatcher:__flush()
|
||||||
|
|
||||||
|
assert(PatchSet.validate(patch))
|
||||||
|
end)
|
||||||
|
|
||||||
|
it("should return nil when there are changes to process and the resulting patch is empty", function()
|
||||||
|
local instanceMap = InstanceMap.new()
|
||||||
|
local changeBatcher = ChangeBatcher.new(instanceMap, noop)
|
||||||
|
local part = Instance.new("Part")
|
||||||
|
|
||||||
|
instanceMap:insert("PART", part)
|
||||||
|
|
||||||
|
changeBatcher.__pendingPropertyChanges[part] = {
|
||||||
|
NonExistentProperty = true,
|
||||||
|
}
|
||||||
|
|
||||||
|
expect(changeBatcher:__flush()).to.equal(nil)
|
||||||
|
end)
|
||||||
|
end)
|
||||||
|
end
|
||||||
@@ -5,7 +5,7 @@ local isDevBuild = script.Parent.Parent:FindFirstChild("ROJO_DEV_BUILD") ~= nil
|
|||||||
return strict("Config", {
|
return strict("Config", {
|
||||||
isDevBuild = isDevBuild,
|
isDevBuild = isDevBuild,
|
||||||
codename = "Epiphany",
|
codename = "Epiphany",
|
||||||
version = {7, 0, 0, "-rc.1"},
|
version = {7, 0, 0},
|
||||||
expectedServerVersionString = "7.0 or newer",
|
expectedServerVersionString = "7.0 or newer",
|
||||||
protocolVersion = 4,
|
protocolVersion = 4,
|
||||||
defaultHost = "localhost",
|
defaultHost = "localhost",
|
||||||
|
|||||||
@@ -1,3 +1,5 @@
|
|||||||
|
local RunService = game:GetService("RunService")
|
||||||
|
|
||||||
local Log = require(script.Parent.Parent.Log)
|
local Log = require(script.Parent.Parent.Log)
|
||||||
|
|
||||||
--[[
|
--[[
|
||||||
@@ -135,29 +137,31 @@ function InstanceMap:destroyId(id)
|
|||||||
end
|
end
|
||||||
|
|
||||||
--[[
|
--[[
|
||||||
Pause updates for an instance momentarily and invoke a callback.
|
Pause updates for an instance.
|
||||||
|
|
||||||
If the callback throws an error, InstanceMap will still be kept in a
|
|
||||||
consistent state.
|
|
||||||
]]
|
]]
|
||||||
function InstanceMap:pauseInstance(instance, callback)
|
function InstanceMap:pauseInstance(instance)
|
||||||
local id = self.fromInstances[instance]
|
local id = self.fromInstances[instance]
|
||||||
|
|
||||||
-- If we don't know about this instance, ignore it and do not invoke the
|
-- If we don't know about this instance, ignore it.
|
||||||
-- callback.
|
|
||||||
if id == nil then
|
if id == nil then
|
||||||
return
|
return
|
||||||
end
|
end
|
||||||
|
|
||||||
self.pausedUpdateInstances[instance] = true
|
self.pausedUpdateInstances[instance] = true
|
||||||
local success, result = xpcall(callback, debug.traceback)
|
end
|
||||||
self.pausedUpdateInstances[instance] = false
|
|
||||||
|
|
||||||
if success then
|
--[[
|
||||||
return result
|
Unpause updates for an instance.
|
||||||
else
|
]]
|
||||||
error(result, 2)
|
function InstanceMap:unpauseInstance(instance)
|
||||||
end
|
self.pausedUpdateInstances[instance] = nil
|
||||||
|
end
|
||||||
|
|
||||||
|
--[[
|
||||||
|
Unpause updates for all instances.
|
||||||
|
]]
|
||||||
|
function InstanceMap:unpauseAllInstances()
|
||||||
|
table.clear(self.pausedUpdateInstances)
|
||||||
end
|
end
|
||||||
|
|
||||||
function InstanceMap:__connectSignals(instance)
|
function InstanceMap:__connectSignals(instance)
|
||||||
@@ -200,6 +204,12 @@ function InstanceMap:__maybeFireInstanceChanged(instance, propertyName)
|
|||||||
return
|
return
|
||||||
end
|
end
|
||||||
|
|
||||||
|
if RunService:IsRunning() then
|
||||||
|
-- We probably don't want to pick up property changes to save to the
|
||||||
|
-- filesystem in a running game.
|
||||||
|
return
|
||||||
|
end
|
||||||
|
|
||||||
self.onInstanceChanged(instance, propertyName)
|
self.onInstanceChanged(instance, propertyName)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|||||||
@@ -63,7 +63,7 @@ local function applyPatch(instanceMap, patch)
|
|||||||
local failedToReify = reify(instanceMap, patch.added, id, parentInstance)
|
local failedToReify = reify(instanceMap, patch.added, id, parentInstance)
|
||||||
|
|
||||||
if not PatchSet.isEmpty(failedToReify) then
|
if not PatchSet.isEmpty(failedToReify) then
|
||||||
Log.debug("Failed to reify as part of applying a patch: {}", failedToReify)
|
Log.debug("Failed to reify as part of applying a patch: {:#?}", failedToReify)
|
||||||
PatchSet.assign(unappliedPatch, failedToReify)
|
PatchSet.assign(unappliedPatch, failedToReify)
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
@@ -77,6 +77,10 @@ local function applyPatch(instanceMap, patch)
|
|||||||
continue
|
continue
|
||||||
end
|
end
|
||||||
|
|
||||||
|
-- Pause updates on this instance to avoid picking up our changes when
|
||||||
|
-- two-way sync is enabled.
|
||||||
|
instanceMap:pauseInstance(instance)
|
||||||
|
|
||||||
-- Track any part of this update that could not be applied.
|
-- Track any part of this update that could not be applied.
|
||||||
local unappliedUpdate = {
|
local unappliedUpdate = {
|
||||||
id = update.id,
|
id = update.id,
|
||||||
|
|||||||
@@ -75,9 +75,13 @@ local function diff(instanceMap, virtualInstances, rootId)
|
|||||||
changedProperties[propertyName] = virtualValue
|
changedProperties[propertyName] = virtualValue
|
||||||
end
|
end
|
||||||
else
|
else
|
||||||
-- virtualValue can be empty in certain cases, and this may print out nil to the user.
|
|
||||||
local propertyType = next(virtualValue)
|
local propertyType = next(virtualValue)
|
||||||
Log.warn("Failed to decode property of type {}", propertyType)
|
Log.warn(
|
||||||
|
"Failed to decode property {}.{}. Encoded property was: {:#?}",
|
||||||
|
virtualInstance.ClassName,
|
||||||
|
propertyName,
|
||||||
|
virtualValue
|
||||||
|
)
|
||||||
end
|
end
|
||||||
else
|
else
|
||||||
local err = existingValueOrErr
|
local err = existingValueOrErr
|
||||||
|
|||||||
@@ -40,6 +40,13 @@ local function getProperty(instance, propertyName)
|
|||||||
})
|
})
|
||||||
end
|
end
|
||||||
|
|
||||||
|
if err.kind == RbxDom.Error.Kind.Roblox and err.extra:find("is not a valid member of") then
|
||||||
|
return false, Error.new(Error.UnknownProperty, {
|
||||||
|
className = instance.ClassName,
|
||||||
|
propertyName = propertyName,
|
||||||
|
})
|
||||||
|
end
|
||||||
|
|
||||||
return false, Error.new(Error.OtherPropertyError, {
|
return false, Error.new(Error.OtherPropertyError, {
|
||||||
className = instance.ClassName,
|
className = instance.ClassName,
|
||||||
propertyName = propertyName,
|
propertyName = propertyName,
|
||||||
|
|||||||
@@ -255,7 +255,7 @@ return function()
|
|||||||
Name = "Child A",
|
Name = "Child A",
|
||||||
Properties = {
|
Properties = {
|
||||||
Value = {
|
Value = {
|
||||||
Ref = "Child B",
|
Ref = "CHILD_B",
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
Children = {},
|
Children = {},
|
||||||
@@ -287,7 +287,7 @@ return function()
|
|||||||
-- constructed as part of a recursive call before the parent has totally
|
-- constructed as part of a recursive call before the parent has totally
|
||||||
-- finished. Given deferred refs, this should not fail, but it is a good
|
-- finished. Given deferred refs, this should not fail, but it is a good
|
||||||
-- case to test.
|
-- case to test.
|
||||||
it("should apply properties containing refs to later siblings correctly", function()
|
it("should apply properties containing refs to later children correctly", function()
|
||||||
local virtualInstances = {
|
local virtualInstances = {
|
||||||
ROOT = {
|
ROOT = {
|
||||||
ClassName = "ObjectValue",
|
ClassName = "ObjectValue",
|
||||||
|
|||||||
@@ -5,6 +5,7 @@ local Log = require(script.Parent.Parent.Log)
|
|||||||
local Fmt = require(script.Parent.Parent.Fmt)
|
local Fmt = require(script.Parent.Parent.Fmt)
|
||||||
local t = require(script.Parent.Parent.t)
|
local t = require(script.Parent.Parent.t)
|
||||||
|
|
||||||
|
local ChangeBatcher = require(script.Parent.ChangeBatcher)
|
||||||
local InstanceMap = require(script.Parent.InstanceMap)
|
local InstanceMap = require(script.Parent.InstanceMap)
|
||||||
local PatchSet = require(script.Parent.PatchSet)
|
local PatchSet = require(script.Parent.PatchSet)
|
||||||
local Reconciler = require(script.Parent.Reconciler)
|
local Reconciler = require(script.Parent.Reconciler)
|
||||||
@@ -56,10 +57,19 @@ function ServeSession.new(options)
|
|||||||
-- Declare self ahead of time to capture it in a closure
|
-- Declare self ahead of time to capture it in a closure
|
||||||
local self
|
local self
|
||||||
local function onInstanceChanged(instance, propertyName)
|
local function onInstanceChanged(instance, propertyName)
|
||||||
self:__onInstanceChanged(instance, propertyName)
|
if not self.__twoWaySync then
|
||||||
|
return
|
||||||
|
end
|
||||||
|
|
||||||
|
self.__changeBatcher:add(instance, propertyName)
|
||||||
|
end
|
||||||
|
|
||||||
|
local function onChangesFlushed(patch)
|
||||||
|
self.__apiContext:write(patch)
|
||||||
end
|
end
|
||||||
|
|
||||||
local instanceMap = InstanceMap.new(onInstanceChanged)
|
local instanceMap = InstanceMap.new(onInstanceChanged)
|
||||||
|
local changeBatcher = ChangeBatcher.new(instanceMap, onChangesFlushed)
|
||||||
local reconciler = Reconciler.new(instanceMap)
|
local reconciler = Reconciler.new(instanceMap)
|
||||||
|
|
||||||
local connections = {}
|
local connections = {}
|
||||||
@@ -82,6 +92,7 @@ function ServeSession.new(options)
|
|||||||
__twoWaySync = options.twoWaySync,
|
__twoWaySync = options.twoWaySync,
|
||||||
__reconciler = reconciler,
|
__reconciler = reconciler,
|
||||||
__instanceMap = instanceMap,
|
__instanceMap = instanceMap,
|
||||||
|
__changeBatcher = changeBatcher,
|
||||||
__statusChangedCallback = nil,
|
__statusChangedCallback = nil,
|
||||||
__connections = connections,
|
__connections = connections,
|
||||||
}
|
}
|
||||||
@@ -179,55 +190,6 @@ function ServeSession:__onActiveScriptChanged(activeScript)
|
|||||||
self.__apiContext:open(scriptId)
|
self.__apiContext:open(scriptId)
|
||||||
end
|
end
|
||||||
|
|
||||||
function ServeSession:__onInstanceChanged(instance, propertyName)
|
|
||||||
if not self.__twoWaySync then
|
|
||||||
return
|
|
||||||
end
|
|
||||||
|
|
||||||
local instanceId = self.__instanceMap.fromInstances[instance]
|
|
||||||
|
|
||||||
if instanceId == nil then
|
|
||||||
Log.warn("Ignoring change for instance {:?} as it is unknown to Rojo", instance)
|
|
||||||
return
|
|
||||||
end
|
|
||||||
|
|
||||||
local remove = nil
|
|
||||||
|
|
||||||
local update = {
|
|
||||||
id = instanceId,
|
|
||||||
changedProperties = {},
|
|
||||||
}
|
|
||||||
|
|
||||||
if propertyName == "Name" then
|
|
||||||
update.changedName = instance.Name
|
|
||||||
elseif propertyName == "Parent" then
|
|
||||||
if instance.Parent == nil then
|
|
||||||
update = nil
|
|
||||||
remove = instanceId
|
|
||||||
else
|
|
||||||
Log.warn("Cannot sync non-nil Parent property changes yet")
|
|
||||||
return
|
|
||||||
end
|
|
||||||
else
|
|
||||||
local success, encoded = self.__reconciler:encodeApiValue(instance[propertyName])
|
|
||||||
|
|
||||||
if not success then
|
|
||||||
Log.warn("Could not sync back property {:?}.{}", instance, propertyName)
|
|
||||||
return
|
|
||||||
end
|
|
||||||
|
|
||||||
update.changedProperties[propertyName] = encoded
|
|
||||||
end
|
|
||||||
|
|
||||||
local patch = {
|
|
||||||
removed = {remove},
|
|
||||||
added = {},
|
|
||||||
updated = {update},
|
|
||||||
}
|
|
||||||
|
|
||||||
self.__apiContext:write(patch)
|
|
||||||
end
|
|
||||||
|
|
||||||
function ServeSession:__initialSync(rootInstanceId)
|
function ServeSession:__initialSync(rootInstanceId)
|
||||||
return self.__apiContext:read({ rootInstanceId })
|
return self.__apiContext:read({ rootInstanceId })
|
||||||
:andThen(function(readResponseBody)
|
:andThen(function(readResponseBody)
|
||||||
@@ -290,6 +252,7 @@ function ServeSession:__stopInternal(err)
|
|||||||
self:__setStatus(Status.Disconnected, err)
|
self:__setStatus(Status.Disconnected, err)
|
||||||
self.__apiContext:disconnect()
|
self.__apiContext:disconnect()
|
||||||
self.__instanceMap:stop()
|
self.__instanceMap:stop()
|
||||||
|
self.__changeBatcher:stop()
|
||||||
|
|
||||||
for _, connection in ipairs(self.__connections) do
|
for _, connection in ipairs(self.__connections) do
|
||||||
connection:Disconnect()
|
connection:Disconnect()
|
||||||
|
|||||||
@@ -9,7 +9,7 @@
|
|||||||
},
|
},
|
||||||
|
|
||||||
"TestEZ": {
|
"TestEZ": {
|
||||||
"$path": "modules/testez/lib"
|
"$path": "modules/testez"
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
|
|
||||||
|
|||||||
@@ -0,0 +1,17 @@
|
|||||||
|
---
|
||||||
|
source: tests/tests/build.rs
|
||||||
|
expression: contents
|
||||||
|
|
||||||
|
---
|
||||||
|
<roblox version="4">
|
||||||
|
<Item class="Folder" referent="0">
|
||||||
|
<Properties>
|
||||||
|
<string name="Name">root</string>
|
||||||
|
</Properties>
|
||||||
|
<Item class="Folder" referent="1">
|
||||||
|
<Properties>
|
||||||
|
<string name="Name">folder</string>
|
||||||
|
</Properties>
|
||||||
|
</Item>
|
||||||
|
</Item>
|
||||||
|
</roblox>
|
||||||
@@ -0,0 +1,22 @@
|
|||||||
|
---
|
||||||
|
source: tests/tests/build.rs
|
||||||
|
expression: contents
|
||||||
|
|
||||||
|
---
|
||||||
|
<roblox version="4">
|
||||||
|
<Item class="Folder" referent="0">
|
||||||
|
<Properties>
|
||||||
|
<string name="Name">root</string>
|
||||||
|
</Properties>
|
||||||
|
<Item class="Folder" referent="1">
|
||||||
|
<Properties>
|
||||||
|
<string name="Name">folder</string>
|
||||||
|
</Properties>
|
||||||
|
<Item class="Folder" referent="2">
|
||||||
|
<Properties>
|
||||||
|
<string name="Name">child-projectname</string>
|
||||||
|
</Properties>
|
||||||
|
</Item>
|
||||||
|
</Item>
|
||||||
|
</Item>
|
||||||
|
</roblox>
|
||||||
@@ -0,0 +1,12 @@
|
|||||||
|
---
|
||||||
|
source: tests/tests/build.rs
|
||||||
|
expression: contents
|
||||||
|
|
||||||
|
---
|
||||||
|
<roblox version="4">
|
||||||
|
<Item class="Folder" referent="0">
|
||||||
|
<Properties>
|
||||||
|
<string name="Name">root</string>
|
||||||
|
</Properties>
|
||||||
|
</Item>
|
||||||
|
</roblox>
|
||||||
@@ -1,6 +1,7 @@
|
|||||||
---
|
---
|
||||||
source: tests/tests/build.rs
|
source: tests/tests/build.rs
|
||||||
expression: contents
|
expression: contents
|
||||||
|
|
||||||
---
|
---
|
||||||
<roblox version="4">
|
<roblox version="4">
|
||||||
<Item class="Folder" referent="0">
|
<Item class="Folder" referent="0">
|
||||||
@@ -25,14 +26,12 @@ expression: contents
|
|||||||
<R22>1</R22>
|
<R22>1</R22>
|
||||||
</CoordinateFrame>
|
</CoordinateFrame>
|
||||||
<Ref name="PrimaryPart">null</Ref>
|
<Ref name="PrimaryPart">null</Ref>
|
||||||
<BinaryString name="Tags">
|
<BinaryString name="Tags"></BinaryString>
|
||||||
</BinaryString>
|
|
||||||
</Properties>
|
</Properties>
|
||||||
<Item class="StringValue" referent="2">
|
<Item class="StringValue" referent="2">
|
||||||
<Properties>
|
<Properties>
|
||||||
<string name="Name">Cool StringValue</string>
|
<string name="Name">Cool StringValue</string>
|
||||||
<BinaryString name="Tags">
|
<BinaryString name="Tags"></BinaryString>
|
||||||
</BinaryString>
|
|
||||||
<string name="Value">Did you know that BaseValue.Changed is different than Instance.Changed?</string>
|
<string name="Value">Did you know that BaseValue.Changed is different than Instance.Changed?</string>
|
||||||
</Properties>
|
</Properties>
|
||||||
</Item>
|
</Item>
|
||||||
|
|||||||
@@ -1,27 +1,25 @@
|
|||||||
---
|
---
|
||||||
source: tests/tests/build.rs
|
source: tests/tests/build.rs
|
||||||
expression: contents
|
expression: contents
|
||||||
|
|
||||||
---
|
---
|
||||||
<roblox version="4">
|
<roblox version="4">
|
||||||
<Item class="Folder" referent="0">
|
<Item class="Folder" referent="0">
|
||||||
<Properties>
|
<Properties>
|
||||||
<string name="Name">rbxmx_ref</string>
|
<string name="Name">rbxmx_ref</string>
|
||||||
<BinaryString name="Tags">
|
<BinaryString name="Tags"></BinaryString>
|
||||||
</BinaryString>
|
|
||||||
</Properties>
|
</Properties>
|
||||||
<Item class="StringValue" referent="1">
|
<Item class="StringValue" referent="1">
|
||||||
<Properties>
|
<Properties>
|
||||||
<string name="Name">Target</string>
|
<string name="Name">Target</string>
|
||||||
<BinaryString name="Tags">
|
<BinaryString name="Tags"></BinaryString>
|
||||||
</BinaryString>
|
|
||||||
<string name="Value">Pointed to by ObjectValue</string>
|
<string name="Value">Pointed to by ObjectValue</string>
|
||||||
</Properties>
|
</Properties>
|
||||||
</Item>
|
</Item>
|
||||||
<Item class="ObjectValue" referent="2">
|
<Item class="ObjectValue" referent="2">
|
||||||
<Properties>
|
<Properties>
|
||||||
<string name="Name">Pointer</string>
|
<string name="Name">Pointer</string>
|
||||||
<BinaryString name="Tags">
|
<BinaryString name="Tags"></BinaryString>
|
||||||
</BinaryString>
|
|
||||||
<Ref name="Value">1</Ref>
|
<Ref name="Value">1</Ref>
|
||||||
</Properties>
|
</Properties>
|
||||||
</Item>
|
</Item>
|
||||||
|
|||||||
@@ -32,6 +32,20 @@ expression: contents
|
|||||||
<Item class="Part" referent="4">
|
<Item class="Part" referent="4">
|
||||||
<Properties>
|
<Properties>
|
||||||
<string name="Name">Color</string>
|
<string name="Name">Color</string>
|
||||||
|
<CoordinateFrame name="CFrame">
|
||||||
|
<X>1</X>
|
||||||
|
<Y>2</Y>
|
||||||
|
<Z>3</Z>
|
||||||
|
<R00>0</R00>
|
||||||
|
<R01>1</R01>
|
||||||
|
<R02>0</R02>
|
||||||
|
<R10>0</R10>
|
||||||
|
<R11>0</R11>
|
||||||
|
<R12>1</R12>
|
||||||
|
<R20>1</R20>
|
||||||
|
<R21>0</R21>
|
||||||
|
<R22>0</R22>
|
||||||
|
</CoordinateFrame>
|
||||||
<Color3uint8 name="Color3uint8">8404992</Color3uint8>
|
<Color3uint8 name="Color3uint8">8404992</Color3uint8>
|
||||||
</Properties>
|
</Properties>
|
||||||
</Item>
|
</Item>
|
||||||
|
|||||||
@@ -0,0 +1,230 @@
|
|||||||
|
---
|
||||||
|
source: tests/tests/build.rs
|
||||||
|
expression: contents
|
||||||
|
|
||||||
|
---
|
||||||
|
<roblox version="4">
|
||||||
|
<Item class="Folder" referent="0">
|
||||||
|
<Properties>
|
||||||
|
<string name="Name">weldconstraint</string>
|
||||||
|
<BinaryString name="AttributesSerialize">
|
||||||
|
</BinaryString>
|
||||||
|
<int64 name="SourceAssetId">-1</int64>
|
||||||
|
<BinaryString name="Tags"></BinaryString>
|
||||||
|
</Properties>
|
||||||
|
<Item class="Part" referent="1">
|
||||||
|
<Properties>
|
||||||
|
<string name="Name">A</string>
|
||||||
|
<bool name="Anchored">false</bool>
|
||||||
|
<BinaryString name="AttributesSerialize">
|
||||||
|
</BinaryString>
|
||||||
|
<float name="BackParamA">-0.5</float>
|
||||||
|
<float name="BackParamB">0.5</float>
|
||||||
|
<token name="BackSurface">0</token>
|
||||||
|
<token name="BackSurfaceInput">0</token>
|
||||||
|
<float name="BottomParamA">-0.5</float>
|
||||||
|
<float name="BottomParamB">0.5</float>
|
||||||
|
<token name="BottomSurface">0</token>
|
||||||
|
<token name="BottomSurfaceInput">0</token>
|
||||||
|
<CoordinateFrame name="CFrame">
|
||||||
|
<X>-14</X>
|
||||||
|
<Y>0.5</Y>
|
||||||
|
<Z>-5</Z>
|
||||||
|
<R00>1</R00>
|
||||||
|
<R01>0</R01>
|
||||||
|
<R02>0</R02>
|
||||||
|
<R10>0</R10>
|
||||||
|
<R11>1</R11>
|
||||||
|
<R12>0</R12>
|
||||||
|
<R20>0</R20>
|
||||||
|
<R21>0</R21>
|
||||||
|
<R22>1</R22>
|
||||||
|
</CoordinateFrame>
|
||||||
|
<bool name="CanCollide">true</bool>
|
||||||
|
<bool name="CanQuery">true</bool>
|
||||||
|
<bool name="CanTouch">true</bool>
|
||||||
|
<bool name="CastShadow">true</bool>
|
||||||
|
<int name="CollisionGroupId">0</int>
|
||||||
|
<Color3uint8 name="Color3uint8">10724005</Color3uint8>
|
||||||
|
<PhysicalProperties name="CustomPhysicalProperties">
|
||||||
|
<CustomPhysics>false</CustomPhysics>
|
||||||
|
</PhysicalProperties>
|
||||||
|
<token name="formFactorRaw">1</token>
|
||||||
|
<float name="FrontParamA">-0.5</float>
|
||||||
|
<float name="FrontParamB">0.5</float>
|
||||||
|
<token name="FrontSurface">0</token>
|
||||||
|
<token name="FrontSurfaceInput">0</token>
|
||||||
|
<float name="LeftParamA">-0.5</float>
|
||||||
|
<float name="LeftParamB">0.5</float>
|
||||||
|
<token name="LeftSurface">0</token>
|
||||||
|
<token name="LeftSurfaceInput">0</token>
|
||||||
|
<bool name="Locked">false</bool>
|
||||||
|
<bool name="Massless">false</bool>
|
||||||
|
<token name="Material">256</token>
|
||||||
|
<CoordinateFrame name="PivotOffset">
|
||||||
|
<X>0</X>
|
||||||
|
<Y>0</Y>
|
||||||
|
<Z>0</Z>
|
||||||
|
<R00>1</R00>
|
||||||
|
<R01>0</R01>
|
||||||
|
<R02>0</R02>
|
||||||
|
<R10>0</R10>
|
||||||
|
<R11>1</R11>
|
||||||
|
<R12>0</R12>
|
||||||
|
<R20>0</R20>
|
||||||
|
<R21>0</R21>
|
||||||
|
<R22>1</R22>
|
||||||
|
</CoordinateFrame>
|
||||||
|
<float name="Reflectance">0</float>
|
||||||
|
<float name="RightParamA">-0.5</float>
|
||||||
|
<float name="RightParamB">0.5</float>
|
||||||
|
<token name="RightSurface">0</token>
|
||||||
|
<token name="RightSurfaceInput">0</token>
|
||||||
|
<int name="RootPriority">0</int>
|
||||||
|
<Vector3 name="RotVelocity">
|
||||||
|
<X>0</X>
|
||||||
|
<Y>0</Y>
|
||||||
|
<Z>0</Z>
|
||||||
|
</Vector3>
|
||||||
|
<token name="shape">1</token>
|
||||||
|
<Vector3 name="size">
|
||||||
|
<X>4</X>
|
||||||
|
<Y>1</Y>
|
||||||
|
<Z>2</Z>
|
||||||
|
</Vector3>
|
||||||
|
<int64 name="SourceAssetId">-1</int64>
|
||||||
|
<BinaryString name="Tags"></BinaryString>
|
||||||
|
<float name="TopParamA">-0.5</float>
|
||||||
|
<float name="TopParamB">0.5</float>
|
||||||
|
<token name="TopSurface">0</token>
|
||||||
|
<token name="TopSurfaceInput">0</token>
|
||||||
|
<float name="Transparency">0</float>
|
||||||
|
<Vector3 name="Velocity">
|
||||||
|
<X>0</X>
|
||||||
|
<Y>0</Y>
|
||||||
|
<Z>0</Z>
|
||||||
|
</Vector3>
|
||||||
|
</Properties>
|
||||||
|
<Item class="WeldConstraint" referent="2">
|
||||||
|
<Properties>
|
||||||
|
<string name="Name">WeldConstraint</string>
|
||||||
|
<BinaryString name="AttributesSerialize">
|
||||||
|
</BinaryString>
|
||||||
|
<CoordinateFrame name="CFrame0">
|
||||||
|
<X>7</X>
|
||||||
|
<Y>0.000001013279</Y>
|
||||||
|
<Z>-3</Z>
|
||||||
|
<R00>1</R00>
|
||||||
|
<R01>0</R01>
|
||||||
|
<R02>0</R02>
|
||||||
|
<R10>0</R10>
|
||||||
|
<R11>1</R11>
|
||||||
|
<R12>0</R12>
|
||||||
|
<R20>0</R20>
|
||||||
|
<R21>0</R21>
|
||||||
|
<R22>1</R22>
|
||||||
|
</CoordinateFrame>
|
||||||
|
<Ref name="Part0Internal">1</Ref>
|
||||||
|
<Ref name="Part1Internal">3</Ref>
|
||||||
|
<int64 name="SourceAssetId">-1</int64>
|
||||||
|
<int name="State">3</int>
|
||||||
|
<BinaryString name="Tags"></BinaryString>
|
||||||
|
</Properties>
|
||||||
|
</Item>
|
||||||
|
</Item>
|
||||||
|
<Item class="Part" referent="3">
|
||||||
|
<Properties>
|
||||||
|
<string name="Name">B</string>
|
||||||
|
<bool name="Anchored">false</bool>
|
||||||
|
<BinaryString name="AttributesSerialize">
|
||||||
|
</BinaryString>
|
||||||
|
<float name="BackParamA">-0.5</float>
|
||||||
|
<float name="BackParamB">0.5</float>
|
||||||
|
<token name="BackSurface">0</token>
|
||||||
|
<token name="BackSurfaceInput">0</token>
|
||||||
|
<float name="BottomParamA">-0.5</float>
|
||||||
|
<float name="BottomParamB">0.5</float>
|
||||||
|
<token name="BottomSurface">0</token>
|
||||||
|
<token name="BottomSurfaceInput">0</token>
|
||||||
|
<CoordinateFrame name="CFrame">
|
||||||
|
<X>-7</X>
|
||||||
|
<Y>0.500001</Y>
|
||||||
|
<Z>-8</Z>
|
||||||
|
<R00>1</R00>
|
||||||
|
<R01>0</R01>
|
||||||
|
<R02>0</R02>
|
||||||
|
<R10>0</R10>
|
||||||
|
<R11>1</R11>
|
||||||
|
<R12>0</R12>
|
||||||
|
<R20>0</R20>
|
||||||
|
<R21>0</R21>
|
||||||
|
<R22>1</R22>
|
||||||
|
</CoordinateFrame>
|
||||||
|
<bool name="CanCollide">true</bool>
|
||||||
|
<bool name="CanQuery">true</bool>
|
||||||
|
<bool name="CanTouch">true</bool>
|
||||||
|
<bool name="CastShadow">true</bool>
|
||||||
|
<int name="CollisionGroupId">0</int>
|
||||||
|
<Color3uint8 name="Color3uint8">10724005</Color3uint8>
|
||||||
|
<PhysicalProperties name="CustomPhysicalProperties">
|
||||||
|
<CustomPhysics>false</CustomPhysics>
|
||||||
|
</PhysicalProperties>
|
||||||
|
<token name="formFactorRaw">1</token>
|
||||||
|
<float name="FrontParamA">-0.5</float>
|
||||||
|
<float name="FrontParamB">0.5</float>
|
||||||
|
<token name="FrontSurface">0</token>
|
||||||
|
<token name="FrontSurfaceInput">0</token>
|
||||||
|
<float name="LeftParamA">-0.5</float>
|
||||||
|
<float name="LeftParamB">0.5</float>
|
||||||
|
<token name="LeftSurface">0</token>
|
||||||
|
<token name="LeftSurfaceInput">0</token>
|
||||||
|
<bool name="Locked">false</bool>
|
||||||
|
<bool name="Massless">false</bool>
|
||||||
|
<token name="Material">256</token>
|
||||||
|
<CoordinateFrame name="PivotOffset">
|
||||||
|
<X>0</X>
|
||||||
|
<Y>0</Y>
|
||||||
|
<Z>0</Z>
|
||||||
|
<R00>1</R00>
|
||||||
|
<R01>0</R01>
|
||||||
|
<R02>0</R02>
|
||||||
|
<R10>0</R10>
|
||||||
|
<R11>1</R11>
|
||||||
|
<R12>0</R12>
|
||||||
|
<R20>0</R20>
|
||||||
|
<R21>0</R21>
|
||||||
|
<R22>1</R22>
|
||||||
|
</CoordinateFrame>
|
||||||
|
<float name="Reflectance">0</float>
|
||||||
|
<float name="RightParamA">-0.5</float>
|
||||||
|
<float name="RightParamB">0.5</float>
|
||||||
|
<token name="RightSurface">0</token>
|
||||||
|
<token name="RightSurfaceInput">0</token>
|
||||||
|
<int name="RootPriority">0</int>
|
||||||
|
<Vector3 name="RotVelocity">
|
||||||
|
<X>0</X>
|
||||||
|
<Y>0</Y>
|
||||||
|
<Z>0</Z>
|
||||||
|
</Vector3>
|
||||||
|
<token name="shape">1</token>
|
||||||
|
<Vector3 name="size">
|
||||||
|
<X>4</X>
|
||||||
|
<Y>1</Y>
|
||||||
|
<Z>2</Z>
|
||||||
|
</Vector3>
|
||||||
|
<int64 name="SourceAssetId">-1</int64>
|
||||||
|
<BinaryString name="Tags"></BinaryString>
|
||||||
|
<float name="TopParamA">-0.5</float>
|
||||||
|
<float name="TopParamB">0.5</float>
|
||||||
|
<token name="TopSurface">0</token>
|
||||||
|
<token name="TopSurfaceInput">0</token>
|
||||||
|
<float name="Transparency">0</float>
|
||||||
|
<Vector3 name="Velocity">
|
||||||
|
<X>0</X>
|
||||||
|
<Y>0</Y>
|
||||||
|
<Z>0</Z>
|
||||||
|
</Vector3>
|
||||||
|
</Properties>
|
||||||
|
</Item>
|
||||||
|
</Item>
|
||||||
|
</roblox>
|
||||||
@@ -0,0 +1,9 @@
|
|||||||
|
{
|
||||||
|
"name": "root",
|
||||||
|
"tree": {
|
||||||
|
"$className": "Folder",
|
||||||
|
"folder": {
|
||||||
|
"$path": "folder"
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,6 @@
|
|||||||
|
{
|
||||||
|
"name": "child-projectname",
|
||||||
|
"tree": {
|
||||||
|
"$className": "Folder"
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,9 @@
|
|||||||
|
{
|
||||||
|
"name": "root",
|
||||||
|
"tree": {
|
||||||
|
"$className": "Folder",
|
||||||
|
"folder": {
|
||||||
|
"$path": "folder"
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,6 @@
|
|||||||
|
{
|
||||||
|
"name": "child-projectname",
|
||||||
|
"tree": {
|
||||||
|
"$className": "Folder"
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,6 @@
|
|||||||
|
{
|
||||||
|
"name": "root",
|
||||||
|
"tree": {
|
||||||
|
"$className": "Folder"
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -14,7 +14,13 @@
|
|||||||
"Color": {
|
"Color": {
|
||||||
"$className": "Part",
|
"$className": "Part",
|
||||||
"$properties": {
|
"$properties": {
|
||||||
"Color": [0.5, 0.25, 0]
|
"Color": [0.5, 0.25, 0],
|
||||||
|
"CFrame": [
|
||||||
|
1, 2, 3,
|
||||||
|
0, 1, 0,
|
||||||
|
0, 0, 1,
|
||||||
|
1, 0, 0
|
||||||
|
]
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
|
|
||||||
|
|||||||
@@ -0,0 +1,6 @@
|
|||||||
|
{
|
||||||
|
"name": "weldconstraint",
|
||||||
|
"tree": {
|
||||||
|
"$path": "two-parts-welded.rbxmx"
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -1,7 +1,9 @@
|
|||||||
use std::borrow::Borrow;
|
use std::borrow::Borrow;
|
||||||
|
|
||||||
use anyhow::format_err;
|
use anyhow::format_err;
|
||||||
use rbx_dom_weak::types::{Color3, Content, Enum, Variant, VariantType, Vector2, Vector3};
|
use rbx_dom_weak::types::{
|
||||||
|
CFrame, Color3, Content, Enum, Matrix3, Tags, Variant, VariantType, Vector2, Vector3,
|
||||||
|
};
|
||||||
use rbx_reflection::{DataType, PropertyDescriptor};
|
use rbx_reflection::{DataType, PropertyDescriptor};
|
||||||
use serde::{Deserialize, Serialize};
|
use serde::{Deserialize, Serialize};
|
||||||
|
|
||||||
@@ -32,10 +34,12 @@ impl UnresolvedValue {
|
|||||||
pub enum AmbiguousValue {
|
pub enum AmbiguousValue {
|
||||||
Bool(bool),
|
Bool(bool),
|
||||||
String(String),
|
String(String),
|
||||||
|
StringArray(Vec<String>),
|
||||||
Number(f64),
|
Number(f64),
|
||||||
Array2([f64; 2]),
|
Array2([f64; 2]),
|
||||||
Array3([f64; 3]),
|
Array3([f64; 3]),
|
||||||
Array4([f64; 4]),
|
Array4([f64; 4]),
|
||||||
|
Array12([f64; 12]),
|
||||||
}
|
}
|
||||||
|
|
||||||
impl AmbiguousValue {
|
impl AmbiguousValue {
|
||||||
@@ -93,6 +97,9 @@ impl AmbiguousValue {
|
|||||||
(VariantType::Int64, AmbiguousValue::Number(value)) => Ok((value as i64).into()),
|
(VariantType::Int64, AmbiguousValue::Number(value)) => Ok((value as i64).into()),
|
||||||
|
|
||||||
(VariantType::String, AmbiguousValue::String(value)) => Ok(value.into()),
|
(VariantType::String, AmbiguousValue::String(value)) => Ok(value.into()),
|
||||||
|
(VariantType::Tags, AmbiguousValue::StringArray(value)) => {
|
||||||
|
Ok(Tags::from(value).into())
|
||||||
|
}
|
||||||
(VariantType::Content, AmbiguousValue::String(value)) => {
|
(VariantType::Content, AmbiguousValue::String(value)) => {
|
||||||
Ok(Content::from(value).into())
|
Ok(Content::from(value).into())
|
||||||
}
|
}
|
||||||
@@ -109,6 +116,18 @@ impl AmbiguousValue {
|
|||||||
Ok(Color3::new(value[0] as f32, value[1] as f32, value[2] as f32).into())
|
Ok(Color3::new(value[0] as f32, value[1] as f32, value[2] as f32).into())
|
||||||
}
|
}
|
||||||
|
|
||||||
|
(VariantType::CFrame, AmbiguousValue::Array12(value)) => {
|
||||||
|
let value = value.map(|v| v as f32);
|
||||||
|
let pos = Vector3::new(value[0], value[1], value[2]);
|
||||||
|
let orientation = Matrix3::new(
|
||||||
|
Vector3::new(value[3], value[4], value[5]),
|
||||||
|
Vector3::new(value[6], value[7], value[8]),
|
||||||
|
Vector3::new(value[9], value[10], value[11]),
|
||||||
|
);
|
||||||
|
|
||||||
|
Ok(CFrame::new(pos, orientation).into())
|
||||||
|
}
|
||||||
|
|
||||||
(_, unresolved) => Err(format_err!(
|
(_, unresolved) => Err(format_err!(
|
||||||
"Wrong type of value for property {}.{}. Expected {:?}, got {}",
|
"Wrong type of value for property {}.{}. Expected {:?}, got {}",
|
||||||
class_name,
|
class_name,
|
||||||
@@ -129,10 +148,12 @@ impl AmbiguousValue {
|
|||||||
match self {
|
match self {
|
||||||
AmbiguousValue::Bool(_) => "a bool",
|
AmbiguousValue::Bool(_) => "a bool",
|
||||||
AmbiguousValue::String(_) => "a string",
|
AmbiguousValue::String(_) => "a string",
|
||||||
|
AmbiguousValue::StringArray(_) => "an array of strings",
|
||||||
AmbiguousValue::Number(_) => "a number",
|
AmbiguousValue::Number(_) => "a number",
|
||||||
AmbiguousValue::Array2(_) => "an array of two numbers",
|
AmbiguousValue::Array2(_) => "an array of two numbers",
|
||||||
AmbiguousValue::Array3(_) => "an array of three numbers",
|
AmbiguousValue::Array3(_) => "an array of three numbers",
|
||||||
AmbiguousValue::Array4(_) => "an array of four numbers",
|
AmbiguousValue::Array4(_) => "an array of four numbers",
|
||||||
|
AmbiguousValue::Array12(_) => "an array of twelve numbers",
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -7,15 +7,16 @@ use serde::Serialize;
|
|||||||
|
|
||||||
use crate::snapshot::{InstanceContext, InstanceMetadata, InstanceSnapshot};
|
use crate::snapshot::{InstanceContext, InstanceMetadata, InstanceSnapshot};
|
||||||
|
|
||||||
use super::{meta_file::AdjacentMetadata, middleware::SnapshotInstanceResult};
|
use super::{meta_file::AdjacentMetadata, util::PathExt};
|
||||||
|
|
||||||
pub fn snapshot_csv(
|
pub fn snapshot_csv(
|
||||||
_context: &InstanceContext,
|
_context: &InstanceContext,
|
||||||
vfs: &Vfs,
|
vfs: &Vfs,
|
||||||
path: &Path,
|
path: &Path,
|
||||||
instance_name: &str,
|
) -> anyhow::Result<Option<InstanceSnapshot>> {
|
||||||
) -> SnapshotInstanceResult {
|
let name = path.file_name_trim_end(".csv")?;
|
||||||
let meta_path = path.with_file_name(format!("{}.meta.json", instance_name));
|
|
||||||
|
let meta_path = path.with_file_name(format!("{}.meta.json", name));
|
||||||
let contents = vfs.read(path)?;
|
let contents = vfs.read(path)?;
|
||||||
|
|
||||||
let table_contents = convert_localization_csv(&contents).with_context(|| {
|
let table_contents = convert_localization_csv(&contents).with_context(|| {
|
||||||
@@ -26,7 +27,7 @@ pub fn snapshot_csv(
|
|||||||
})?;
|
})?;
|
||||||
|
|
||||||
let mut snapshot = InstanceSnapshot::new()
|
let mut snapshot = InstanceSnapshot::new()
|
||||||
.name(instance_name)
|
.name(name)
|
||||||
.class_name("LocalizationTable")
|
.class_name("LocalizationTable")
|
||||||
.properties(hashmap! {
|
.properties(hashmap! {
|
||||||
"Contents".to_owned() => table_contents.into(),
|
"Contents".to_owned() => table_contents.into(),
|
||||||
@@ -143,14 +144,10 @@ Ack,Ack!,,An exclamation of despair,¡Ay!"#,
|
|||||||
|
|
||||||
let mut vfs = Vfs::new(imfs);
|
let mut vfs = Vfs::new(imfs);
|
||||||
|
|
||||||
let instance_snapshot = snapshot_csv(
|
let instance_snapshot =
|
||||||
&InstanceContext::default(),
|
snapshot_csv(&InstanceContext::default(), &mut vfs, Path::new("/foo.csv"))
|
||||||
&mut vfs,
|
.unwrap()
|
||||||
Path::new("/foo.csv"),
|
.unwrap();
|
||||||
"foo",
|
|
||||||
)
|
|
||||||
.unwrap()
|
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
insta::assert_yaml_snapshot!(instance_snapshot);
|
insta::assert_yaml_snapshot!(instance_snapshot);
|
||||||
}
|
}
|
||||||
@@ -175,14 +172,10 @@ Ack,Ack!,,An exclamation of despair,¡Ay!"#,
|
|||||||
|
|
||||||
let mut vfs = Vfs::new(imfs);
|
let mut vfs = Vfs::new(imfs);
|
||||||
|
|
||||||
let instance_snapshot = snapshot_csv(
|
let instance_snapshot =
|
||||||
&InstanceContext::default(),
|
snapshot_csv(&InstanceContext::default(), &mut vfs, Path::new("/foo.csv"))
|
||||||
&mut vfs,
|
.unwrap()
|
||||||
Path::new("/foo.csv"),
|
.unwrap();
|
||||||
"foo",
|
|
||||||
)
|
|
||||||
.unwrap()
|
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
insta::assert_yaml_snapshot!(instance_snapshot);
|
insta::assert_yaml_snapshot!(instance_snapshot);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -4,9 +4,13 @@ use memofs::{DirEntry, IoResultExt, Vfs};
|
|||||||
|
|
||||||
use crate::snapshot::{InstanceContext, InstanceMetadata, InstanceSnapshot};
|
use crate::snapshot::{InstanceContext, InstanceMetadata, InstanceSnapshot};
|
||||||
|
|
||||||
use super::{meta_file::DirectoryMetadata, middleware::SnapshotInstanceResult, snapshot_from_vfs};
|
use super::{meta_file::DirectoryMetadata, snapshot_from_vfs};
|
||||||
|
|
||||||
pub fn snapshot_dir(context: &InstanceContext, vfs: &Vfs, path: &Path) -> SnapshotInstanceResult {
|
pub fn snapshot_dir(
|
||||||
|
context: &InstanceContext,
|
||||||
|
vfs: &Vfs,
|
||||||
|
path: &Path,
|
||||||
|
) -> anyhow::Result<Option<InstanceSnapshot>> {
|
||||||
let passes_filter_rules = |child: &DirEntry| {
|
let passes_filter_rules = |child: &DirEntry| {
|
||||||
context
|
context
|
||||||
.path_ignore_rules
|
.path_ignore_rules
|
||||||
|
|||||||
@@ -9,14 +9,14 @@ use crate::{
|
|||||||
snapshot::{InstanceContext, InstanceMetadata, InstanceSnapshot},
|
snapshot::{InstanceContext, InstanceMetadata, InstanceSnapshot},
|
||||||
};
|
};
|
||||||
|
|
||||||
use super::{meta_file::AdjacentMetadata, middleware::SnapshotInstanceResult};
|
use super::{meta_file::AdjacentMetadata, util::PathExt};
|
||||||
|
|
||||||
pub fn snapshot_json(
|
pub fn snapshot_json(
|
||||||
context: &InstanceContext,
|
context: &InstanceContext,
|
||||||
vfs: &Vfs,
|
vfs: &Vfs,
|
||||||
path: &Path,
|
path: &Path,
|
||||||
instance_name: &str,
|
) -> anyhow::Result<Option<InstanceSnapshot>> {
|
||||||
) -> SnapshotInstanceResult {
|
let name = path.file_name_trim_end(".json")?;
|
||||||
let contents = vfs.read(path)?;
|
let contents = vfs.read(path)?;
|
||||||
|
|
||||||
let value: serde_json::Value = serde_json::from_slice(&contents)
|
let value: serde_json::Value = serde_json::from_slice(&contents)
|
||||||
@@ -28,10 +28,10 @@ pub fn snapshot_json(
|
|||||||
"Source".to_owned() => as_lua.into(),
|
"Source".to_owned() => as_lua.into(),
|
||||||
};
|
};
|
||||||
|
|
||||||
let meta_path = path.with_file_name(format!("{}.meta.json", instance_name));
|
let meta_path = path.with_file_name(format!("{}.meta.json", name));
|
||||||
|
|
||||||
let mut snapshot = InstanceSnapshot::new()
|
let mut snapshot = InstanceSnapshot::new()
|
||||||
.name(instance_name)
|
.name(name)
|
||||||
.class_name("ModuleScript")
|
.class_name("ModuleScript")
|
||||||
.properties(properties)
|
.properties(properties)
|
||||||
.metadata(
|
.metadata(
|
||||||
@@ -107,7 +107,6 @@ mod test {
|
|||||||
&InstanceContext::default(),
|
&InstanceContext::default(),
|
||||||
&mut vfs,
|
&mut vfs,
|
||||||
Path::new("/foo.json"),
|
Path::new("/foo.json"),
|
||||||
"foo",
|
|
||||||
)
|
)
|
||||||
.unwrap()
|
.unwrap()
|
||||||
.unwrap();
|
.unwrap();
|
||||||
|
|||||||
@@ -9,14 +9,15 @@ use crate::{
|
|||||||
snapshot::{InstanceContext, InstanceSnapshot},
|
snapshot::{InstanceContext, InstanceSnapshot},
|
||||||
};
|
};
|
||||||
|
|
||||||
use super::middleware::SnapshotInstanceResult;
|
use super::util::PathExt;
|
||||||
|
|
||||||
pub fn snapshot_json_model(
|
pub fn snapshot_json_model(
|
||||||
context: &InstanceContext,
|
context: &InstanceContext,
|
||||||
vfs: &Vfs,
|
vfs: &Vfs,
|
||||||
path: &Path,
|
path: &Path,
|
||||||
instance_name: &str,
|
) -> anyhow::Result<Option<InstanceSnapshot>> {
|
||||||
) -> SnapshotInstanceResult {
|
let name = path.file_name_trim_end(".model.json")?;
|
||||||
|
|
||||||
let contents = vfs.read(path)?;
|
let contents = vfs.read(path)?;
|
||||||
let contents_str = str::from_utf8(&contents)
|
let contents_str = str::from_utf8(&contents)
|
||||||
.with_context(|| format!("File was not valid UTF-8: {}", path.display()))?;
|
.with_context(|| format!("File was not valid UTF-8: {}", path.display()))?;
|
||||||
@@ -30,7 +31,7 @@ pub fn snapshot_json_model(
|
|||||||
|
|
||||||
let mut snapshot = instance
|
let mut snapshot = instance
|
||||||
.core
|
.core
|
||||||
.into_snapshot(instance_name.to_owned())
|
.into_snapshot(name.to_owned())
|
||||||
.with_context(|| format!("Could not load JSON model: {}", path.display()))?;
|
.with_context(|| format!("Could not load JSON model: {}", path.display()))?;
|
||||||
|
|
||||||
snapshot.metadata = snapshot
|
snapshot.metadata = snapshot
|
||||||
@@ -135,7 +136,6 @@ mod test {
|
|||||||
&InstanceContext::default(),
|
&InstanceContext::default(),
|
||||||
&mut vfs,
|
&mut vfs,
|
||||||
Path::new("/foo.model.json"),
|
Path::new("/foo.model.json"),
|
||||||
"foo",
|
|
||||||
)
|
)
|
||||||
.unwrap()
|
.unwrap()
|
||||||
.unwrap();
|
.unwrap();
|
||||||
|
|||||||
@@ -6,13 +6,14 @@ use memofs::{IoResultExt, Vfs};
|
|||||||
|
|
||||||
use crate::snapshot::{InstanceContext, InstanceMetadata, InstanceSnapshot};
|
use crate::snapshot::{InstanceContext, InstanceMetadata, InstanceSnapshot};
|
||||||
|
|
||||||
use super::{
|
use super::{dir::snapshot_dir, meta_file::AdjacentMetadata, util::match_trailing};
|
||||||
dir::snapshot_dir, meta_file::AdjacentMetadata, middleware::SnapshotInstanceResult,
|
|
||||||
util::match_trailing,
|
|
||||||
};
|
|
||||||
|
|
||||||
/// Core routine for turning Lua files into snapshots.
|
/// Core routine for turning Lua files into snapshots.
|
||||||
pub fn snapshot_lua(context: &InstanceContext, vfs: &Vfs, path: &Path) -> SnapshotInstanceResult {
|
pub fn snapshot_lua(
|
||||||
|
context: &InstanceContext,
|
||||||
|
vfs: &Vfs,
|
||||||
|
path: &Path,
|
||||||
|
) -> anyhow::Result<Option<InstanceSnapshot>> {
|
||||||
let file_name = path.file_name().unwrap().to_string_lossy();
|
let file_name = path.file_name().unwrap().to_string_lossy();
|
||||||
|
|
||||||
let (class_name, instance_name) = if let Some(name) = match_trailing(&file_name, ".server.lua")
|
let (class_name, instance_name) = if let Some(name) = match_trailing(&file_name, ".server.lua")
|
||||||
@@ -63,7 +64,7 @@ pub fn snapshot_lua_init(
|
|||||||
context: &InstanceContext,
|
context: &InstanceContext,
|
||||||
vfs: &Vfs,
|
vfs: &Vfs,
|
||||||
init_path: &Path,
|
init_path: &Path,
|
||||||
) -> SnapshotInstanceResult {
|
) -> anyhow::Result<Option<InstanceSnapshot>> {
|
||||||
let folder_path = init_path.parent().unwrap();
|
let folder_path = init_path.parent().unwrap();
|
||||||
let dir_snapshot = snapshot_dir(context, vfs, folder_path)?.unwrap();
|
let dir_snapshot = snapshot_dir(context, vfs, folder_path)?.unwrap();
|
||||||
|
|
||||||
@@ -71,8 +72,8 @@ pub fn snapshot_lua_init(
|
|||||||
anyhow::bail!(
|
anyhow::bail!(
|
||||||
"init.lua, init.server.lua, and init.client.lua can \
|
"init.lua, init.server.lua, and init.client.lua can \
|
||||||
only be used if the instance produced by the containing \
|
only be used if the instance produced by the containing \
|
||||||
directory would be a Folder.\n\n\
|
directory would be a Folder.\n\
|
||||||
|
\n\
|
||||||
The directory {} turned into an instance of class {}.",
|
The directory {} turned into an instance of class {}.",
|
||||||
folder_path.display(),
|
folder_path.display(),
|
||||||
dir_snapshot.class_name
|
dir_snapshot.class_name
|
||||||
|
|||||||
@@ -1,3 +0,0 @@
|
|||||||
use crate::snapshot::InstanceSnapshot;
|
|
||||||
|
|
||||||
pub type SnapshotInstanceResult = anyhow::Result<Option<InstanceSnapshot>>;
|
|
||||||
@@ -11,7 +11,6 @@ mod json;
|
|||||||
mod json_model;
|
mod json_model;
|
||||||
mod lua;
|
mod lua;
|
||||||
mod meta_file;
|
mod meta_file;
|
||||||
mod middleware;
|
|
||||||
mod project;
|
mod project;
|
||||||
mod rbxm;
|
mod rbxm;
|
||||||
mod rbxmx;
|
mod rbxmx;
|
||||||
@@ -22,7 +21,7 @@ use std::path::Path;
|
|||||||
|
|
||||||
use memofs::{IoResultExt, Vfs};
|
use memofs::{IoResultExt, Vfs};
|
||||||
|
|
||||||
use crate::snapshot::InstanceContext;
|
use crate::snapshot::{InstanceContext, InstanceSnapshot};
|
||||||
|
|
||||||
use self::{
|
use self::{
|
||||||
csv::snapshot_csv,
|
csv::snapshot_csv,
|
||||||
@@ -30,12 +29,11 @@ use self::{
|
|||||||
json::snapshot_json,
|
json::snapshot_json,
|
||||||
json_model::snapshot_json_model,
|
json_model::snapshot_json_model,
|
||||||
lua::{snapshot_lua, snapshot_lua_init},
|
lua::{snapshot_lua, snapshot_lua_init},
|
||||||
middleware::SnapshotInstanceResult,
|
|
||||||
project::snapshot_project,
|
project::snapshot_project,
|
||||||
rbxm::snapshot_rbxm,
|
rbxm::snapshot_rbxm,
|
||||||
rbxmx::snapshot_rbxmx,
|
rbxmx::snapshot_rbxmx,
|
||||||
txt::snapshot_txt,
|
txt::snapshot_txt,
|
||||||
util::match_file_name,
|
util::PathExt,
|
||||||
};
|
};
|
||||||
|
|
||||||
pub use self::project::snapshot_project_node;
|
pub use self::project::snapshot_project_node;
|
||||||
@@ -46,7 +44,7 @@ pub fn snapshot_from_vfs(
|
|||||||
context: &InstanceContext,
|
context: &InstanceContext,
|
||||||
vfs: &Vfs,
|
vfs: &Vfs,
|
||||||
path: &Path,
|
path: &Path,
|
||||||
) -> SnapshotInstanceResult {
|
) -> anyhow::Result<Option<InstanceSnapshot>> {
|
||||||
let meta = match vfs.metadata(path).with_not_found()? {
|
let meta = match vfs.metadata(path).with_not_found()? {
|
||||||
Some(meta) => meta,
|
Some(meta) => meta,
|
||||||
None => return Ok(None),
|
None => return Ok(None),
|
||||||
@@ -75,7 +73,7 @@ pub fn snapshot_from_vfs(
|
|||||||
|
|
||||||
snapshot_dir(context, vfs, path)
|
snapshot_dir(context, vfs, path)
|
||||||
} else {
|
} else {
|
||||||
if let Some(name) = match_file_name(path, ".lua") {
|
if let Ok(name) = path.file_name_trim_end(".lua") {
|
||||||
match name {
|
match name {
|
||||||
// init scripts are handled elsewhere and should not turn into
|
// init scripts are handled elsewhere and should not turn into
|
||||||
// their own children.
|
// their own children.
|
||||||
@@ -83,23 +81,23 @@ pub fn snapshot_from_vfs(
|
|||||||
|
|
||||||
_ => return snapshot_lua(context, vfs, path),
|
_ => return snapshot_lua(context, vfs, path),
|
||||||
}
|
}
|
||||||
} else if let Some(_name) = match_file_name(path, ".project.json") {
|
} else if path.file_name_ends_with(".project.json") {
|
||||||
return snapshot_project(context, vfs, path);
|
return snapshot_project(context, vfs, path);
|
||||||
} else if let Some(name) = match_file_name(path, ".model.json") {
|
} else if path.file_name_ends_with(".model.json") {
|
||||||
return snapshot_json_model(context, vfs, path, name);
|
return snapshot_json_model(context, vfs, path);
|
||||||
} else if let Some(_name) = match_file_name(path, ".meta.json") {
|
} else if path.file_name_ends_with(".meta.json") {
|
||||||
// .meta.json files do not turn into their own instances.
|
// .meta.json files do not turn into their own instances.
|
||||||
return Ok(None);
|
return Ok(None);
|
||||||
} else if let Some(name) = match_file_name(path, ".json") {
|
} else if path.file_name_ends_with(".json") {
|
||||||
return snapshot_json(context, vfs, path, name);
|
return snapshot_json(context, vfs, path);
|
||||||
} else if let Some(name) = match_file_name(path, ".csv") {
|
} else if path.file_name_ends_with(".csv") {
|
||||||
return snapshot_csv(context, vfs, path, name);
|
return snapshot_csv(context, vfs, path);
|
||||||
} else if let Some(name) = match_file_name(path, ".txt") {
|
} else if path.file_name_ends_with(".txt") {
|
||||||
return snapshot_txt(context, vfs, path, name);
|
return snapshot_txt(context, vfs, path);
|
||||||
} else if let Some(name) = match_file_name(path, ".rbxmx") {
|
} else if path.file_name_ends_with(".rbxmx") {
|
||||||
return snapshot_rbxmx(context, vfs, path, name);
|
return snapshot_rbxmx(context, vfs, path);
|
||||||
} else if let Some(name) = match_file_name(path, ".rbxm") {
|
} else if path.file_name_ends_with(".rbxm") {
|
||||||
return snapshot_rbxm(context, vfs, path, name);
|
return snapshot_rbxm(context, vfs, path);
|
||||||
}
|
}
|
||||||
|
|
||||||
Ok(None)
|
Ok(None)
|
||||||
|
|||||||
@@ -11,13 +11,13 @@ use crate::{
|
|||||||
},
|
},
|
||||||
};
|
};
|
||||||
|
|
||||||
use super::{middleware::SnapshotInstanceResult, snapshot_from_vfs};
|
use super::snapshot_from_vfs;
|
||||||
|
|
||||||
pub fn snapshot_project(
|
pub fn snapshot_project(
|
||||||
context: &InstanceContext,
|
context: &InstanceContext,
|
||||||
vfs: &Vfs,
|
vfs: &Vfs,
|
||||||
path: &Path,
|
path: &Path,
|
||||||
) -> SnapshotInstanceResult {
|
) -> anyhow::Result<Option<InstanceSnapshot>> {
|
||||||
let project = Project::load_from_slice(&vfs.read(path)?, path)
|
let project = Project::load_from_slice(&vfs.read(path)?, path)
|
||||||
.with_context(|| format!("File was not a valid Rojo project: {}", path.display()))?;
|
.with_context(|| format!("File was not a valid Rojo project: {}", path.display()))?;
|
||||||
|
|
||||||
@@ -63,7 +63,7 @@ pub fn snapshot_project_node(
|
|||||||
node: &ProjectNode,
|
node: &ProjectNode,
|
||||||
vfs: &Vfs,
|
vfs: &Vfs,
|
||||||
parent_class: Option<&str>,
|
parent_class: Option<&str>,
|
||||||
) -> SnapshotInstanceResult {
|
) -> anyhow::Result<Option<InstanceSnapshot>> {
|
||||||
let project_folder = project_path.parent().unwrap();
|
let project_folder = project_path.parent().unwrap();
|
||||||
|
|
||||||
let class_name_from_project = node
|
let class_name_from_project = node
|
||||||
@@ -80,13 +80,13 @@ pub fn snapshot_project_node(
|
|||||||
if let Some(path) = &node.path {
|
if let Some(path) = &node.path {
|
||||||
// If the path specified in the project is relative, we assume it's
|
// If the path specified in the project is relative, we assume it's
|
||||||
// relative to the folder that the project is in, project_folder.
|
// relative to the folder that the project is in, project_folder.
|
||||||
let path = if path.is_relative() {
|
let full_path = if path.is_relative() {
|
||||||
Cow::Owned(project_folder.join(path))
|
Cow::Owned(project_folder.join(path))
|
||||||
} else {
|
} else {
|
||||||
Cow::Borrowed(path)
|
Cow::Borrowed(path)
|
||||||
};
|
};
|
||||||
|
|
||||||
if let Some(snapshot) = snapshot_from_vfs(context, vfs, &path)? {
|
if let Some(snapshot) = snapshot_from_vfs(context, vfs, &full_path)? {
|
||||||
class_name_from_path = Some(snapshot.class_name);
|
class_name_from_path = Some(snapshot.class_name);
|
||||||
|
|
||||||
// Properties from the snapshot are pulled in unchanged, and
|
// Properties from the snapshot are pulled in unchanged, and
|
||||||
@@ -107,9 +107,14 @@ pub fn snapshot_project_node(
|
|||||||
// on.
|
// on.
|
||||||
metadata = snapshot.metadata;
|
metadata = snapshot.metadata;
|
||||||
} else {
|
} else {
|
||||||
// TODO: Should this issue an error instead?
|
anyhow::bail!(
|
||||||
log::warn!(
|
"Rojo project referred to a file using $path that could not be turned into a Roblox Instance by Rojo.\n\
|
||||||
"$path referred to a path that could not be turned into an instance by Rojo"
|
Check that the file exists and is a file type known by Rojo.\n\
|
||||||
|
\n\
|
||||||
|
Project path: {}\n\
|
||||||
|
File $path: {}",
|
||||||
|
project_path.display(),
|
||||||
|
path.display(),
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -5,14 +5,15 @@ use memofs::Vfs;
|
|||||||
|
|
||||||
use crate::snapshot::{InstanceContext, InstanceMetadata, InstanceSnapshot};
|
use crate::snapshot::{InstanceContext, InstanceMetadata, InstanceSnapshot};
|
||||||
|
|
||||||
use super::middleware::SnapshotInstanceResult;
|
use super::util::PathExt;
|
||||||
|
|
||||||
pub fn snapshot_rbxm(
|
pub fn snapshot_rbxm(
|
||||||
context: &InstanceContext,
|
context: &InstanceContext,
|
||||||
vfs: &Vfs,
|
vfs: &Vfs,
|
||||||
path: &Path,
|
path: &Path,
|
||||||
instance_name: &str,
|
) -> anyhow::Result<Option<InstanceSnapshot>> {
|
||||||
) -> SnapshotInstanceResult {
|
let name = path.file_name_trim_end(".rbxm")?;
|
||||||
|
|
||||||
let temp_tree = rbx_binary::from_reader(vfs.read(path)?.as_slice())
|
let temp_tree = rbx_binary::from_reader(vfs.read(path)?.as_slice())
|
||||||
.with_context(|| format!("Malformed rbxm file: {}", path.display()))?;
|
.with_context(|| format!("Malformed rbxm file: {}", path.display()))?;
|
||||||
|
|
||||||
@@ -21,7 +22,7 @@ pub fn snapshot_rbxm(
|
|||||||
|
|
||||||
if children.len() == 1 {
|
if children.len() == 1 {
|
||||||
let snapshot = InstanceSnapshot::from_tree(&temp_tree, children[0])
|
let snapshot = InstanceSnapshot::from_tree(&temp_tree, children[0])
|
||||||
.name(instance_name)
|
.name(name)
|
||||||
.metadata(
|
.metadata(
|
||||||
InstanceMetadata::new()
|
InstanceMetadata::new()
|
||||||
.instigating_source(path)
|
.instigating_source(path)
|
||||||
@@ -60,7 +61,6 @@ mod test {
|
|||||||
&InstanceContext::default(),
|
&InstanceContext::default(),
|
||||||
&mut vfs,
|
&mut vfs,
|
||||||
Path::new("/foo.rbxm"),
|
Path::new("/foo.rbxm"),
|
||||||
"foo",
|
|
||||||
)
|
)
|
||||||
.unwrap()
|
.unwrap()
|
||||||
.unwrap();
|
.unwrap();
|
||||||
|
|||||||
@@ -5,14 +5,15 @@ use memofs::Vfs;
|
|||||||
|
|
||||||
use crate::snapshot::{InstanceContext, InstanceMetadata, InstanceSnapshot};
|
use crate::snapshot::{InstanceContext, InstanceMetadata, InstanceSnapshot};
|
||||||
|
|
||||||
use super::middleware::SnapshotInstanceResult;
|
use super::util::PathExt;
|
||||||
|
|
||||||
pub fn snapshot_rbxmx(
|
pub fn snapshot_rbxmx(
|
||||||
context: &InstanceContext,
|
context: &InstanceContext,
|
||||||
vfs: &Vfs,
|
vfs: &Vfs,
|
||||||
path: &Path,
|
path: &Path,
|
||||||
instance_name: &str,
|
) -> anyhow::Result<Option<InstanceSnapshot>> {
|
||||||
) -> SnapshotInstanceResult {
|
let name = path.file_name_trim_end(".rbxmx")?;
|
||||||
|
|
||||||
let options = rbx_xml::DecodeOptions::new()
|
let options = rbx_xml::DecodeOptions::new()
|
||||||
.property_behavior(rbx_xml::DecodePropertyBehavior::ReadUnknown);
|
.property_behavior(rbx_xml::DecodePropertyBehavior::ReadUnknown);
|
||||||
|
|
||||||
@@ -24,7 +25,7 @@ pub fn snapshot_rbxmx(
|
|||||||
|
|
||||||
if children.len() == 1 {
|
if children.len() == 1 {
|
||||||
let snapshot = InstanceSnapshot::from_tree(&temp_tree, children[0])
|
let snapshot = InstanceSnapshot::from_tree(&temp_tree, children[0])
|
||||||
.name(instance_name)
|
.name(name)
|
||||||
.metadata(
|
.metadata(
|
||||||
InstanceMetadata::new()
|
InstanceMetadata::new()
|
||||||
.instigating_source(path)
|
.instigating_source(path)
|
||||||
@@ -73,7 +74,6 @@ mod test {
|
|||||||
&InstanceContext::default(),
|
&InstanceContext::default(),
|
||||||
&mut vfs,
|
&mut vfs,
|
||||||
Path::new("/foo.rbxmx"),
|
Path::new("/foo.rbxmx"),
|
||||||
"foo",
|
|
||||||
)
|
)
|
||||||
.unwrap()
|
.unwrap()
|
||||||
.unwrap();
|
.unwrap();
|
||||||
|
|||||||
@@ -6,14 +6,15 @@ use memofs::{IoResultExt, Vfs};
|
|||||||
|
|
||||||
use crate::snapshot::{InstanceContext, InstanceMetadata, InstanceSnapshot};
|
use crate::snapshot::{InstanceContext, InstanceMetadata, InstanceSnapshot};
|
||||||
|
|
||||||
use super::{meta_file::AdjacentMetadata, middleware::SnapshotInstanceResult};
|
use super::{meta_file::AdjacentMetadata, util::PathExt};
|
||||||
|
|
||||||
pub fn snapshot_txt(
|
pub fn snapshot_txt(
|
||||||
context: &InstanceContext,
|
context: &InstanceContext,
|
||||||
vfs: &Vfs,
|
vfs: &Vfs,
|
||||||
path: &Path,
|
path: &Path,
|
||||||
instance_name: &str,
|
) -> anyhow::Result<Option<InstanceSnapshot>> {
|
||||||
) -> SnapshotInstanceResult {
|
let name = path.file_name_trim_end(".txt")?;
|
||||||
|
|
||||||
let contents = vfs.read(path)?;
|
let contents = vfs.read(path)?;
|
||||||
let contents_str = str::from_utf8(&contents)
|
let contents_str = str::from_utf8(&contents)
|
||||||
.with_context(|| format!("File was not valid UTF-8: {}", path.display()))?
|
.with_context(|| format!("File was not valid UTF-8: {}", path.display()))?
|
||||||
@@ -23,10 +24,10 @@ pub fn snapshot_txt(
|
|||||||
"Value".to_owned() => contents_str.into(),
|
"Value".to_owned() => contents_str.into(),
|
||||||
};
|
};
|
||||||
|
|
||||||
let meta_path = path.with_file_name(format!("{}.meta.json", instance_name));
|
let meta_path = path.with_file_name(format!("{}.meta.json", name));
|
||||||
|
|
||||||
let mut snapshot = InstanceSnapshot::new()
|
let mut snapshot = InstanceSnapshot::new()
|
||||||
.name(instance_name)
|
.name(name)
|
||||||
.class_name("StringValue")
|
.class_name("StringValue")
|
||||||
.properties(properties)
|
.properties(properties)
|
||||||
.metadata(
|
.metadata(
|
||||||
@@ -58,14 +59,10 @@ mod test {
|
|||||||
|
|
||||||
let mut vfs = Vfs::new(imfs.clone());
|
let mut vfs = Vfs::new(imfs.clone());
|
||||||
|
|
||||||
let instance_snapshot = snapshot_txt(
|
let instance_snapshot =
|
||||||
&InstanceContext::default(),
|
snapshot_txt(&InstanceContext::default(), &mut vfs, Path::new("/foo.txt"))
|
||||||
&mut vfs,
|
.unwrap()
|
||||||
Path::new("/foo.txt"),
|
.unwrap();
|
||||||
"foo",
|
|
||||||
)
|
|
||||||
.unwrap()
|
|
||||||
.unwrap();
|
|
||||||
|
|
||||||
insta::assert_yaml_snapshot!(instance_snapshot);
|
insta::assert_yaml_snapshot!(instance_snapshot);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,5 +1,7 @@
|
|||||||
use std::path::Path;
|
use std::path::Path;
|
||||||
|
|
||||||
|
use anyhow::Context;
|
||||||
|
|
||||||
/// If the given string ends up with the given suffix, returns the portion of
|
/// If the given string ends up with the given suffix, returns the portion of
|
||||||
/// the string before the suffix.
|
/// the string before the suffix.
|
||||||
pub fn match_trailing<'a>(input: &'a str, suffix: &str) -> Option<&'a str> {
|
pub fn match_trailing<'a>(input: &'a str, suffix: &str) -> Option<&'a str> {
|
||||||
@@ -11,10 +13,31 @@ pub fn match_trailing<'a>(input: &'a str, suffix: &str) -> Option<&'a str> {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/// If the given path has a file name, and that file name ends with the given
|
pub trait PathExt {
|
||||||
/// suffix, returns the portion of the file name before the given suffix.
|
fn file_name_ends_with(&self, suffix: &str) -> bool;
|
||||||
pub fn match_file_name<'a>(path: &'a Path, suffix: &str) -> Option<&'a str> {
|
fn file_name_trim_end<'a>(&'a self, suffix: &str) -> anyhow::Result<&'a str>;
|
||||||
let file_name = path.file_name()?.to_str()?;
|
}
|
||||||
|
|
||||||
match_trailing(&file_name, suffix)
|
impl<P> PathExt for P
|
||||||
|
where
|
||||||
|
P: AsRef<Path>,
|
||||||
|
{
|
||||||
|
fn file_name_ends_with(&self, suffix: &str) -> bool {
|
||||||
|
self.as_ref()
|
||||||
|
.file_name()
|
||||||
|
.and_then(|name| name.to_str())
|
||||||
|
.map(|name| name.ends_with(suffix))
|
||||||
|
.unwrap_or(false)
|
||||||
|
}
|
||||||
|
|
||||||
|
fn file_name_trim_end<'a>(&'a self, suffix: &str) -> anyhow::Result<&'a str> {
|
||||||
|
let path = self.as_ref();
|
||||||
|
let file_name = path
|
||||||
|
.file_name()
|
||||||
|
.and_then(|name| name.to_str())
|
||||||
|
.with_context(|| format!("Path did not have a file name: {}", path.display()))?;
|
||||||
|
|
||||||
|
match_trailing(&file_name, suffix)
|
||||||
|
.with_context(|| format!("Path did not end in {}: {}", suffix, path.display()))
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -11,9 +11,9 @@ use crate::{
|
|||||||
snapshot::{InstanceWithMeta, PatchSet, PatchUpdate},
|
snapshot::{InstanceWithMeta, PatchSet, PatchUpdate},
|
||||||
web::{
|
web::{
|
||||||
interface::{
|
interface::{
|
||||||
ErrorResponse, Instance, InstanceMetadata as WebInstanceMetadata, InstanceUpdate,
|
ErrorResponse, Instance, OpenResponse, ReadResponse, ServerInfoResponse,
|
||||||
OpenResponse, ReadResponse, ServerInfoResponse, SubscribeMessage, SubscribeResponse,
|
SubscribeMessage, SubscribeResponse, WriteRequest, WriteResponse, PROTOCOL_VERSION,
|
||||||
WriteRequest, WriteResponse, PROTOCOL_VERSION, SERVER_VERSION,
|
SERVER_VERSION,
|
||||||
},
|
},
|
||||||
util::{json, json_ok},
|
util::{json, json_ok},
|
||||||
},
|
},
|
||||||
@@ -99,44 +99,7 @@ impl ApiService {
|
|||||||
|
|
||||||
let api_messages = messages
|
let api_messages = messages
|
||||||
.into_iter()
|
.into_iter()
|
||||||
.map(|message| {
|
.map(|patch| SubscribeMessage::from_patch_update(&tree, patch))
|
||||||
let removed = message.removed;
|
|
||||||
|
|
||||||
let mut added = HashMap::new();
|
|
||||||
for id in message.added {
|
|
||||||
let instance = tree.get_instance(id).unwrap();
|
|
||||||
added.insert(id, Instance::from_rojo_instance(instance));
|
|
||||||
|
|
||||||
for instance in tree.descendants(id) {
|
|
||||||
added.insert(instance.id(), Instance::from_rojo_instance(instance));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
let updated = message
|
|
||||||
.updated
|
|
||||||
.into_iter()
|
|
||||||
.map(|update| {
|
|
||||||
let changed_metadata = update
|
|
||||||
.changed_metadata
|
|
||||||
.as_ref()
|
|
||||||
.map(WebInstanceMetadata::from_rojo_metadata);
|
|
||||||
|
|
||||||
InstanceUpdate {
|
|
||||||
id: update.id,
|
|
||||||
changed_name: update.changed_name,
|
|
||||||
changed_class_name: update.changed_class_name,
|
|
||||||
changed_properties: update.changed_properties,
|
|
||||||
changed_metadata,
|
|
||||||
}
|
|
||||||
})
|
|
||||||
.collect();
|
|
||||||
|
|
||||||
SubscribeMessage {
|
|
||||||
removed,
|
|
||||||
added,
|
|
||||||
updated,
|
|
||||||
}
|
|
||||||
})
|
|
||||||
.collect();
|
.collect();
|
||||||
|
|
||||||
json_ok(SubscribeResponse {
|
json_ok(SubscribeResponse {
|
||||||
|
|||||||
@@ -7,12 +7,14 @@ use std::{
|
|||||||
collections::{HashMap, HashSet},
|
collections::{HashMap, HashSet},
|
||||||
};
|
};
|
||||||
|
|
||||||
use rbx_dom_weak::types::{Ref, Variant};
|
use rbx_dom_weak::types::{Ref, Variant, VariantType};
|
||||||
use serde::{Deserialize, Serialize};
|
use serde::{Deserialize, Serialize};
|
||||||
|
|
||||||
use crate::{
|
use crate::{
|
||||||
session_id::SessionId,
|
session_id::SessionId,
|
||||||
snapshot::{InstanceMetadata as RojoInstanceMetadata, InstanceWithMeta},
|
snapshot::{
|
||||||
|
AppliedPatchSet, InstanceMetadata as RojoInstanceMetadata, InstanceWithMeta, RojoTree,
|
||||||
|
},
|
||||||
};
|
};
|
||||||
|
|
||||||
/// Server version to report over the API, not exposed outside this crate.
|
/// Server version to report over the API, not exposed outside this crate.
|
||||||
@@ -30,6 +32,53 @@ pub struct SubscribeMessage<'a> {
|
|||||||
pub updated: Vec<InstanceUpdate>,
|
pub updated: Vec<InstanceUpdate>,
|
||||||
}
|
}
|
||||||
|
|
||||||
|
impl<'a> SubscribeMessage<'a> {
|
||||||
|
pub(crate) fn from_patch_update(tree: &'a RojoTree, patch: AppliedPatchSet) -> Self {
|
||||||
|
let removed = patch.removed;
|
||||||
|
|
||||||
|
let mut added = HashMap::new();
|
||||||
|
for id in patch.added {
|
||||||
|
let instance = tree.get_instance(id).unwrap();
|
||||||
|
added.insert(id, Instance::from_rojo_instance(instance));
|
||||||
|
|
||||||
|
for instance in tree.descendants(id) {
|
||||||
|
added.insert(instance.id(), Instance::from_rojo_instance(instance));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
let updated = patch
|
||||||
|
.updated
|
||||||
|
.into_iter()
|
||||||
|
.map(|update| {
|
||||||
|
let changed_metadata = update
|
||||||
|
.changed_metadata
|
||||||
|
.as_ref()
|
||||||
|
.map(InstanceMetadata::from_rojo_metadata);
|
||||||
|
|
||||||
|
let changed_properties = update
|
||||||
|
.changed_properties
|
||||||
|
.into_iter()
|
||||||
|
.filter(|(_key, value)| property_filter(value.as_ref()))
|
||||||
|
.collect();
|
||||||
|
|
||||||
|
InstanceUpdate {
|
||||||
|
id: update.id,
|
||||||
|
changed_name: update.changed_name,
|
||||||
|
changed_class_name: update.changed_class_name,
|
||||||
|
changed_properties,
|
||||||
|
changed_metadata,
|
||||||
|
}
|
||||||
|
})
|
||||||
|
.collect();
|
||||||
|
|
||||||
|
Self {
|
||||||
|
removed,
|
||||||
|
added,
|
||||||
|
updated,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
#[derive(Debug, Serialize, Deserialize)]
|
#[derive(Debug, Serialize, Deserialize)]
|
||||||
#[serde(rename_all = "camelCase")]
|
#[serde(rename_all = "camelCase")]
|
||||||
pub struct InstanceUpdate {
|
pub struct InstanceUpdate {
|
||||||
@@ -75,14 +124,8 @@ impl<'a> Instance<'a> {
|
|||||||
let properties = source
|
let properties = source
|
||||||
.properties()
|
.properties()
|
||||||
.iter()
|
.iter()
|
||||||
.filter_map(|(key, value)| {
|
.filter(|(_key, value)| property_filter(Some(value)))
|
||||||
// SharedString values can't be serialized via Serde
|
.map(|(key, value)| (key.clone(), Cow::Borrowed(value)))
|
||||||
if matches!(value, Variant::SharedString(_)) {
|
|
||||||
return None;
|
|
||||||
}
|
|
||||||
|
|
||||||
Some((key.clone(), Cow::Borrowed(value)))
|
|
||||||
})
|
|
||||||
.collect();
|
.collect();
|
||||||
|
|
||||||
Instance {
|
Instance {
|
||||||
@@ -97,6 +140,18 @@ impl<'a> Instance<'a> {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
fn property_filter(value: Option<&Variant>) -> bool {
|
||||||
|
let ty = value.map(|value| value.ty());
|
||||||
|
|
||||||
|
// Lua can't do anything with SharedString values. They also can't be
|
||||||
|
// serialized directly by Serde!
|
||||||
|
if ty == Some(VariantType::SharedString) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
|
||||||
/// Response body from /api/rojo
|
/// Response body from /api/rojo
|
||||||
#[derive(Debug, Serialize, Deserialize)]
|
#[derive(Debug, Serialize, Deserialize)]
|
||||||
#[serde(rename_all = "camelCase")]
|
#[serde(rename_all = "camelCase")]
|
||||||
|
|||||||
@@ -1,12 +0,0 @@
|
|||||||
{
|
|
||||||
"name": "weldconstraint",
|
|
||||||
"tree": {
|
|
||||||
"$className": "DataModel",
|
|
||||||
|
|
||||||
"Workspace": {
|
|
||||||
"Parts": {
|
|
||||||
"$path": "two-parts-welded.rbxmx"
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -1,5 +1,6 @@
|
|||||||
use std::{
|
use std::{
|
||||||
fs, io,
|
fs,
|
||||||
|
io::{self, Read},
|
||||||
path::{Path, PathBuf},
|
path::{Path, PathBuf},
|
||||||
process::Child,
|
process::Child,
|
||||||
};
|
};
|
||||||
@@ -50,5 +51,17 @@ pub struct KillOnDrop(pub Child);
|
|||||||
impl Drop for KillOnDrop {
|
impl Drop for KillOnDrop {
|
||||||
fn drop(&mut self) {
|
fn drop(&mut self) {
|
||||||
let _ = self.0.kill();
|
let _ = self.0.kill();
|
||||||
|
|
||||||
|
if let Some(mut stdout) = self.0.stdout.take() {
|
||||||
|
let mut output = Vec::new();
|
||||||
|
let _ = stdout.read_to_end(&mut output);
|
||||||
|
print!("{}", String::from_utf8_lossy(&output));
|
||||||
|
}
|
||||||
|
|
||||||
|
if let Some(mut stderr) = self.0.stderr.take() {
|
||||||
|
let mut output = Vec::new();
|
||||||
|
let _ = stderr.read_to_end(&mut output);
|
||||||
|
eprint!("{}", String::from_utf8_lossy(&output));
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -41,6 +41,9 @@ gen_build_tests! {
|
|||||||
json_model_legacy_name,
|
json_model_legacy_name,
|
||||||
module_in_folder,
|
module_in_folder,
|
||||||
module_init,
|
module_init,
|
||||||
|
project_composed_default,
|
||||||
|
project_composed_file,
|
||||||
|
project_root_name,
|
||||||
rbxm_in_folder,
|
rbxm_in_folder,
|
||||||
rbxmx_in_folder,
|
rbxmx_in_folder,
|
||||||
rbxmx_ref,
|
rbxmx_ref,
|
||||||
@@ -50,6 +53,7 @@ gen_build_tests! {
|
|||||||
txt,
|
txt,
|
||||||
txt_in_folder,
|
txt_in_folder,
|
||||||
unresolved_values,
|
unresolved_values,
|
||||||
|
weldconstraint,
|
||||||
}
|
}
|
||||||
|
|
||||||
fn run_build_test(test_name: &str) {
|
fn run_build_test(test_name: &str) {
|
||||||
@@ -60,7 +64,7 @@ fn run_build_test(test_name: &str) {
|
|||||||
let output_dir = tempdir().expect("couldn't create temporary directory");
|
let output_dir = tempdir().expect("couldn't create temporary directory");
|
||||||
let output_path = output_dir.path().join(format!("{}.rbxmx", test_name));
|
let output_path = output_dir.path().join(format!("{}.rbxmx", test_name));
|
||||||
|
|
||||||
let status = Command::new(ROJO_PATH)
|
let output = Command::new(ROJO_PATH)
|
||||||
.args(&[
|
.args(&[
|
||||||
"build",
|
"build",
|
||||||
input_path.to_str().unwrap(),
|
input_path.to_str().unwrap(),
|
||||||
@@ -69,10 +73,13 @@ fn run_build_test(test_name: &str) {
|
|||||||
])
|
])
|
||||||
.env("RUST_LOG", "error")
|
.env("RUST_LOG", "error")
|
||||||
.current_dir(working_dir)
|
.current_dir(working_dir)
|
||||||
.status()
|
.output()
|
||||||
.expect("Couldn't start Rojo");
|
.expect("Couldn't start Rojo");
|
||||||
|
|
||||||
assert!(status.success(), "Rojo did not exit successfully");
|
print!("{}", String::from_utf8_lossy(&output.stdout));
|
||||||
|
eprint!("{}", String::from_utf8_lossy(&output.stderr));
|
||||||
|
|
||||||
|
assert!(output.status.success(), "Rojo did not exit successfully");
|
||||||
|
|
||||||
let contents = fs::read_to_string(&output_path).expect("Couldn't read output file");
|
let contents = fs::read_to_string(&output_path).expect("Couldn't read output file");
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user