Compare commits
52 Commits
feat/table
...
main
Author | SHA1 | Date |
---|---|---|
Tomáš Mládek | 72b928067c | |
Tomáš Mládek | 7e9d4349af | |
Tomáš Mládek | 426c584215 | |
Tomáš Mládek | 1118a5cfeb | |
Tomáš Mládek | e9dd4d1383 | |
Tomáš Mládek | e06d2bccfe | |
Tomáš Mládek | 9f61581ba7 | |
Tomáš Mládek | bc74fbfff6 | |
Tomáš Mládek | 8d165e1f8c | |
Tomáš Mládek | 97f6dd86bf | |
Tomáš Mládek | 041c058a77 | |
Tomáš Mládek | 1bd83062bb | |
Tomáš Mládek | 58c5329781 | |
Tomáš Mládek | 07a150b99d | |
Tomáš Mládek | 1738643050 | |
Tomáš Mládek | 3b32597fb6 | |
Tomáš Mládek | a30ef465a3 | |
Tomáš Mládek | 069c86855b | |
Tomáš Mládek | f9002604fe | |
Tomáš Mládek | edc666f56a | |
Tomáš Mládek | 750bca9ee0 | |
Tomáš Mládek | 703a3e5391 | |
Tomáš Mládek | 50020b969e | |
Tomáš Mládek | 60a8b15164 | |
Tomáš Mládek | 17bc53a6fe | |
Tomáš Mládek | f9037a4370 | |
Tomáš Mládek | 196447da0f | |
Tomáš Mládek | 05ee557d1a | |
Tomáš Mládek | 02bfe94f39 | |
Tomáš Mládek | 0e59bc8bd5 | |
Tomáš Mládek | 8932341445 | |
Tomáš Mládek | 1f270d6dc7 | |
Tomáš Mládek | 669b348160 | |
Tomáš Mládek | 175518e3a6 | |
Tomáš Mládek | 94818b992a | |
Tomáš Mládek | f2261998ee | |
Tomáš Mládek | 730cc02d7a | |
Tomáš Mládek | 4d8ac0717d | |
Tomáš Mládek | 68e7d67d7b | |
Tomáš Mládek | cb7dfadf3d | |
Tomáš Mládek | 35e1e902a2 | |
Tomáš Mládek | 1e9f83d043 | |
Tomáš Mládek | 88170789a0 | |
Tomáš Mládek | e03e09ccaf | |
Tomáš Mládek | 58ca734443 | |
Tomáš Mládek | 7897ce7354 | |
Tomáš Mládek | d87405ae5b | |
Tomáš Mládek | c5e14eae0d | |
Tomáš Mládek | 4ccfc63318 | |
Tomáš Mládek | 894faa94ae | |
Tomáš Mládek | 0b488d9384 | |
Tomáš Mládek | 121c615642 |
|
@ -1,6 +1,6 @@
|
|||
<component name="ProjectRunConfigurationManager">
|
||||
<configuration default="false" name="dev backend" type="CargoCommandRunConfiguration" factoryName="Cargo Command">
|
||||
<option name="command" value="run -- serve ./example_vault --clean --no-browser --reinitialize --rescan-mode mirror" />
|
||||
<option name="command" value="run -- serve ./example_vault --clean --no-browser --reinitialize --rescan-mode mirror --secret upend" />
|
||||
<option name="workingDirectory" value="file://$PROJECT_DIR$" />
|
||||
<envs />
|
||||
<option name="emulateTerminal" value="true" />
|
||||
|
|
|
@ -0,0 +1,19 @@
|
|||
<component name="ProjectRunConfigurationManager">
|
||||
<configuration default="false" name="dev backend storybook" type="CargoCommandRunConfiguration" factoryName="Cargo Command">
|
||||
<option name="command" value="run -- serve ./example_vault --clean --no-browser --reinitialize --rescan-mode mirror --bind 127.0.0.1:8099" />
|
||||
<option name="workingDirectory" value="file://$PROJECT_DIR$" />
|
||||
<envs />
|
||||
<option name="emulateTerminal" value="true" />
|
||||
<option name="channel" value="DEFAULT" />
|
||||
<option name="requiredFeatures" value="true" />
|
||||
<option name="allFeatures" value="false" />
|
||||
<option name="withSudo" value="false" />
|
||||
<option name="buildTarget" value="REMOTE" />
|
||||
<option name="backtrace" value="SHORT" />
|
||||
<option name="isRedirectInput" value="false" />
|
||||
<option name="redirectInputPath" value="" />
|
||||
<method v="2">
|
||||
<option name="CARGO.BUILD_TASK_PROVIDER" enabled="true" />
|
||||
</method>
|
||||
</configuration>
|
||||
</component>
|
|
@ -0,0 +1,7 @@
|
|||
<component name="ProjectRunConfigurationManager">
|
||||
<configuration default="false" name="storybook" type="CompoundRunConfigurationType">
|
||||
<toRun name="dev backend storybook" type="CargoCommandRunConfiguration" />
|
||||
<toRun name="storybook:serve" type="js.build_tools.npm" />
|
||||
<method v="2" />
|
||||
</configuration>
|
||||
</component>
|
|
@ -0,0 +1,12 @@
|
|||
<component name="ProjectRunConfigurationManager">
|
||||
<configuration default="false" name="storybook:serve" type="js.build_tools.npm" nameIsGenerated="true">
|
||||
<package-json value="$PROJECT_DIR$/webui/package.json" />
|
||||
<command value="run" />
|
||||
<scripts>
|
||||
<script value="storybook:serve" />
|
||||
</scripts>
|
||||
<node-interpreter value="project" />
|
||||
<envs />
|
||||
<method v="2" />
|
||||
</configuration>
|
||||
</component>
|
|
@ -0,0 +1,11 @@
|
|||
<component name="ProjectRunConfigurationManager">
|
||||
<configuration default="false" name="test js sdk" type="JavaScriptTestRunnerJest">
|
||||
<config-file value="$PROJECT_DIR$/sdks/js/jest.config.js" />
|
||||
<node-interpreter value="project" />
|
||||
<jest-package value="$PROJECT_DIR$/sdks/js/node_modules/jest" />
|
||||
<working-dir value="$PROJECT_DIR$" />
|
||||
<envs />
|
||||
<scope-kind value="ALL" />
|
||||
<method v="2" />
|
||||
</configuration>
|
||||
</component>
|
|
@ -6,7 +6,7 @@ pipeline:
|
|||
environment:
|
||||
- FORCE_COLOR=1
|
||||
- EARTHLY_EXEC_CMD="/bin/sh"
|
||||
secrets: [EARTHLY_CONFIGURATION]
|
||||
secrets: [ EARTHLY_CONFIGURATION ]
|
||||
commands:
|
||||
- mkdir ~/.earthly && echo "$EARTHLY_CONFIGURATION" > ~/.earthly/config.yaml
|
||||
- earthly bootstrap
|
||||
|
@ -19,7 +19,7 @@ pipeline:
|
|||
environment:
|
||||
- FORCE_COLOR=1
|
||||
- EARTHLY_EXEC_CMD="/bin/sh"
|
||||
secrets: [EARTHLY_CONFIGURATION]
|
||||
secrets: [ EARTHLY_CONFIGURATION ]
|
||||
commands:
|
||||
- mkdir ~/.earthly && echo "$EARTHLY_CONFIGURATION" > ~/.earthly/config.yaml
|
||||
- earthly bootstrap
|
||||
|
@ -52,13 +52,14 @@ pipeline:
|
|||
SSH_CONFIG,
|
||||
SSH_UPLOAD_KEY,
|
||||
SSH_KNOWN_HOSTS,
|
||||
SENTRY_AUTH_TOKEN
|
||||
]
|
||||
commands:
|
||||
- mkdir ~/.earthly && echo "$EARTHLY_CONFIGURATION" > ~/.earthly/config.yaml
|
||||
- earthly bootstrap
|
||||
- earthly --secret GPG_SIGN_KEY --secret SSH_CONFIG --secret SSH_UPLOAD_KEY --secret SSH_KNOWN_HOSTS +deploy-appimage-nightly
|
||||
when:
|
||||
branch: [main]
|
||||
branch: [ main ]
|
||||
|
||||
docker:nightly:
|
||||
image: earthly/earthly:v0.8.3
|
||||
|
@ -67,7 +68,7 @@ pipeline:
|
|||
environment:
|
||||
- FORCE_COLOR=1
|
||||
- EARTHLY_EXEC_CMD="/bin/sh"
|
||||
secrets: [EARTHLY_CONFIGURATION, DOCKER_USER, DOCKER_PASSWORD]
|
||||
secrets: [ EARTHLY_CONFIGURATION, DOCKER_USER, DOCKER_PASSWORD, SENTRY_AUTH_TOKEN ]
|
||||
commands:
|
||||
- echo $${DOCKER_PASSWORD}| docker login --username $${DOCKER_USER} --password-stdin
|
||||
- mkdir ~/.earthly && echo "$EARTHLY_CONFIGURATION" > ~/.earthly/config.yaml
|
||||
|
@ -75,7 +76,7 @@ pipeline:
|
|||
- earthly --push +docker-minimal
|
||||
- earthly --push +docker
|
||||
when:
|
||||
branch: [main]
|
||||
branch: [ main ]
|
||||
|
||||
docker:release:
|
||||
image: earthly/earthly:v0.8.3
|
||||
|
@ -84,7 +85,7 @@ pipeline:
|
|||
environment:
|
||||
- FORCE_COLOR=1
|
||||
- EARTHLY_EXEC_CMD="/bin/sh"
|
||||
secrets: [EARTHLY_CONFIGURATION, DOCKER_USER, DOCKER_PASSWORD]
|
||||
secrets: [ EARTHLY_CONFIGURATION, DOCKER_USER, DOCKER_PASSWORD, SENTRY_AUTH_TOKEN ]
|
||||
commands:
|
||||
- echo $${DOCKER_PASSWORD}| docker login --username $${DOCKER_USER} --password-stdin
|
||||
- mkdir ~/.earthly && echo "$EARTHLY_CONFIGURATION" > ~/.earthly/config.yaml
|
||||
|
@ -94,7 +95,7 @@ pipeline:
|
|||
- earthly --strict --push +docker --tag=latest
|
||||
- earthly --strict --push +docker --tag=$CI_COMMIT_TAG
|
||||
when:
|
||||
event: [tag]
|
||||
event: [ tag ]
|
||||
|
||||
jslib:publish:
|
||||
image: earthly/earthly:v0.8.3
|
||||
|
@ -103,13 +104,13 @@ pipeline:
|
|||
environment:
|
||||
- FORCE_COLOR=1
|
||||
- EARTHLY_EXEC_CMD="/bin/sh"
|
||||
secrets: [EARTHLY_CONFIGURATION, NPM_TOKEN]
|
||||
secrets: [ EARTHLY_CONFIGURATION, NPM_TOKEN ]
|
||||
commands:
|
||||
- mkdir ~/.earthly && echo "$EARTHLY_CONFIGURATION" > ~/.earthly/config.yaml
|
||||
- earthly bootstrap
|
||||
- earthly --strict --push --secret NPM_TOKEN +publish-js-all
|
||||
when:
|
||||
branch: [main]
|
||||
branch: [ main ]
|
||||
|
||||
gitea:prerelease:
|
||||
image: earthly/earthly:v0.8.3
|
||||
|
@ -126,7 +127,7 @@ pipeline:
|
|||
- rm -rf dist
|
||||
when:
|
||||
event: [ tag ]
|
||||
|
||||
|
||||
appimage:release:
|
||||
image: earthly/earthly:v0.8.3
|
||||
volumes:
|
||||
|
@ -134,15 +135,15 @@ pipeline:
|
|||
environment:
|
||||
- FORCE_COLOR=1
|
||||
- EARTHLY_EXEC_CMD="/bin/sh"
|
||||
secrets: [ EARTHLY_CONFIGURATION, REGISTRY, REGISTRY_USER, REGISTRY_PASSWORD ]
|
||||
secrets: [ EARTHLY_CONFIGURATION, REGISTRY, REGISTRY_USER, REGISTRY_PASSWORD, SENTRY_AUTH_TOKEN ]
|
||||
commands:
|
||||
- mkdir ~/.earthly && echo "$EARTHLY_CONFIGURATION" > ~/.earthly/config.yaml
|
||||
- earthly bootstrap
|
||||
- mkdir -p dist/
|
||||
- earthly --strict -a '+appimage-signed/*' dist/
|
||||
when:
|
||||
event: [tag]
|
||||
|
||||
event: [ tag ]
|
||||
|
||||
# todo: webext
|
||||
|
||||
gitea:release:
|
||||
|
@ -157,4 +158,4 @@ pipeline:
|
|||
target: main
|
||||
note: CHANGELOG_CURRENT.md
|
||||
when:
|
||||
event: [tag]
|
||||
event: [ tag ]
|
|
@ -487,6 +487,18 @@ version = "1.6.0"
|
|||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "bddcadddf5e9015d310179a59bb28c4d4b9920ad0f11e8e14dbadf654890c9a6"
|
||||
|
||||
[[package]]
|
||||
name = "argon2"
|
||||
version = "0.5.3"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "3c3610892ee6e0cbce8ae2700349fcf8f98adb0dbfbee85aec3c9179d29cc072"
|
||||
dependencies = [
|
||||
"base64ct",
|
||||
"blake2",
|
||||
"cpufeatures",
|
||||
"password-hash",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "arrayref"
|
||||
version = "0.3.7"
|
||||
|
@ -555,6 +567,12 @@ version = "0.21.3"
|
|||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "414dcefbc63d77c526a76b3afcf6fbb9b5e2791c19c3aa2297733208750c6e53"
|
||||
|
||||
[[package]]
|
||||
name = "base64ct"
|
||||
version = "1.6.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "8c3c1a368f70d6cf7302d78f8f7093da241fb8e8807c05cc9e51a125895a6d5b"
|
||||
|
||||
[[package]]
|
||||
name = "bitflags"
|
||||
version = "1.3.2"
|
||||
|
@ -567,6 +585,15 @@ version = "2.4.0"
|
|||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "b4682ae6287fcf752ecaabbfcc7b6f9b72aa33933dc23a554d853aea8eea8635"
|
||||
|
||||
[[package]]
|
||||
name = "blake2"
|
||||
version = "0.10.6"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "46502ad458c9a52b69d4d4d32775c788b7a1b85e8bc9d482d92250fc0e3f8efe"
|
||||
dependencies = [
|
||||
"digest",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "blake2b_simd"
|
||||
version = "1.0.1"
|
||||
|
@ -863,9 +890,9 @@ dependencies = [
|
|||
|
||||
[[package]]
|
||||
name = "cpufeatures"
|
||||
version = "0.2.9"
|
||||
version = "0.2.12"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "a17b76ff3a4162b0b27f354a0c87015ddad39d35f9c0c36607a3bdd175dde1f1"
|
||||
checksum = "53fe5e26ff1b7aef8bca9c6080520cfb8d9333c7568e1829cef191a9723e5504"
|
||||
dependencies = [
|
||||
"libc",
|
||||
]
|
||||
|
@ -1110,6 +1137,7 @@ checksum = "9ed9a281f7bc9b7576e61468ba615a66a5c8cfdff42420a70aa82701a3b1e292"
|
|||
dependencies = [
|
||||
"block-buffer",
|
||||
"crypto-common",
|
||||
"subtle",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
|
@ -1745,9 +1773,9 @@ dependencies = [
|
|||
|
||||
[[package]]
|
||||
name = "libc"
|
||||
version = "0.2.147"
|
||||
version = "0.2.153"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "b4668fb0ea861c1df094127ac5f1da3409a82116a4ba74fca2e58ef927159bb3"
|
||||
checksum = "9c198f91728a82281a64e1f4f9eeb25d82cb32a5de251c6bd1b5154d63a8e7bd"
|
||||
|
||||
[[package]]
|
||||
name = "libsqlite3-sys"
|
||||
|
@ -2254,6 +2282,17 @@ version = "1.0.0"
|
|||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "944553dd59c802559559161f9816429058b869003836120e262e8caec061b7ae"
|
||||
|
||||
[[package]]
|
||||
name = "password-hash"
|
||||
version = "0.5.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "346f04948ba92c43e8469c1ee6736c7563d71012b17d40745260fe106aac2166"
|
||||
dependencies = [
|
||||
"base64ct",
|
||||
"rand_core",
|
||||
"subtle",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "paste"
|
||||
version = "1.0.14"
|
||||
|
@ -2914,6 +2953,12 @@ version = "0.10.0"
|
|||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "73473c0e59e6d5812c5dfe2a064a6444949f089e20eec9a2e5506596494e4623"
|
||||
|
||||
[[package]]
|
||||
name = "subtle"
|
||||
version = "2.5.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "81cdd64d312baedb58e21336b31bc043b77e01cc99033ce76ef539f78e965ebc"
|
||||
|
||||
[[package]]
|
||||
name = "syn"
|
||||
version = "1.0.109"
|
||||
|
@ -3379,6 +3424,7 @@ name = "upend-db"
|
|||
version = "0.0.2"
|
||||
dependencies = [
|
||||
"anyhow",
|
||||
"argon2",
|
||||
"chrono",
|
||||
"diesel",
|
||||
"diesel_migrations",
|
||||
|
@ -3394,6 +3440,7 @@ dependencies = [
|
|||
"nonempty",
|
||||
"num_cpus",
|
||||
"once_cell",
|
||||
"password-hash",
|
||||
"rayon",
|
||||
"regex",
|
||||
"serde",
|
||||
|
|
28
Earthfile
28
Earthfile
|
@ -37,7 +37,7 @@ base-node:
|
|||
|
||||
base-frontend:
|
||||
FROM +base-node
|
||||
COPY +jslib/jslib sdks/js
|
||||
COPY +jslib/dist sdks/js/dist
|
||||
WORKDIR webui
|
||||
RUN rm -rf node_modules && pnpm install --frozen-lockfile
|
||||
|
||||
|
@ -65,14 +65,14 @@ wasmlib:
|
|||
wasm-pack build --target nodejs --out-dir pkg-node
|
||||
RUN sed -e 's%"name": "upend_wasm"%"name": "@upnd/wasm-web"%' -i pkg-web/package.json && \
|
||||
sed -e 's%"name": "upend_wasm"%"name": "@upnd/wasm-node"%' -i pkg-node/package.json
|
||||
SAVE ARTIFACT pkg-web AS LOCAL wasm/pkg-web
|
||||
SAVE ARTIFACT pkg-node AS LOCAL wasm/pkg-node
|
||||
SAVE ARTIFACT pkg-web
|
||||
SAVE ARTIFACT pkg-node
|
||||
|
||||
jslib:
|
||||
FROM +base-node
|
||||
WORKDIR sdks/js
|
||||
RUN pnpm build
|
||||
SAVE ARTIFACT . jslib
|
||||
SAVE ARTIFACT dist
|
||||
|
||||
webext:
|
||||
FROM +base-node
|
||||
|
@ -228,7 +228,7 @@ publish-js-wasm:
|
|||
base-npm-publish:
|
||||
FROM +base-node
|
||||
RUN --secret NPM_TOKEN echo "//registry.npmjs.org/:_authToken=$NPM_TOKEN" > $HOME/.npmrc
|
||||
COPY +jslib/jslib sdks/js
|
||||
COPY +jslib/dist sdks/js/dist
|
||||
|
||||
NPM_PUBLISH:
|
||||
FUNCTION
|
||||
|
@ -269,4 +269,20 @@ update-changelog:
|
|||
LOCALLY
|
||||
COPY +changelog/CHANGELOG.md .
|
||||
RUN git add CHANGELOG.md && git commit -m "release: Update CHANGELOG"
|
||||
RUN --push git push
|
||||
RUN --push git push
|
||||
|
||||
dev-local:
|
||||
FROM debian:bookworm
|
||||
COPY +jslib/dist /js-dist
|
||||
COPY +wasmlib/pkg-web /wasm-web
|
||||
COPY +wasmlib/pkg-node /wasm-node
|
||||
SAVE ARTIFACT /js-dist AS LOCAL sdks/js/dist
|
||||
SAVE ARTIFACT /wasm-web AS LOCAL wasm/pkg-web
|
||||
SAVE ARTIFACT /wasm-node AS LOCAL wasm/pkg-node
|
||||
|
||||
dev-update-sdk:
|
||||
LOCALLY
|
||||
WORKDIR sdks/js
|
||||
RUN pnpm build
|
||||
WORKDIR webui
|
||||
RUN pnpm install
|
|
@ -103,12 +103,14 @@ impl Address {
|
|||
UP_UUID => Ok(Address::Uuid(
|
||||
Uuid::from_slice(digest.as_slice()).map_err(UpEndError::from_any)?,
|
||||
)),
|
||||
UP_ATTRIBUTE => Ok(Address::Attribute(
|
||||
String::from_utf8(digest)
|
||||
.map_err(UpEndError::from_any)?
|
||||
.as_str()
|
||||
.parse()?,
|
||||
)),
|
||||
UP_ATTRIBUTE => {
|
||||
let attribute = String::from_utf8(digest).map_err(UpEndError::from_any)?;
|
||||
if attribute.is_empty() {
|
||||
Ok(Address::Attribute(Attribute::null()))
|
||||
} else {
|
||||
Ok(Address::Attribute(attribute.parse()?))
|
||||
}
|
||||
}
|
||||
UP_URL => Ok(Address::Url(
|
||||
Url::parse(&String::from_utf8(digest).map_err(UpEndError::from_any)?)
|
||||
.map_err(UpEndError::from_any)?,
|
||||
|
@ -255,6 +257,9 @@ mod tests {
|
|||
use uuid::Uuid;
|
||||
|
||||
use crate::addressing::{Address, IDENTITY};
|
||||
use crate::constants::{
|
||||
TYPE_ATTRIBUTE_ADDRESS, TYPE_HASH_ADDRESS, TYPE_URL_ADDRESS, TYPE_UUID_ADDRESS,
|
||||
};
|
||||
use crate::hash::{LargeMultihash, UpMultihash};
|
||||
|
||||
use super::UpEndError;
|
||||
|
@ -267,6 +272,11 @@ mod tests {
|
|||
let encoded = addr.encode()?;
|
||||
let decoded = Address::decode(&encoded)?;
|
||||
assert_eq!(addr, decoded);
|
||||
|
||||
let addr = &*TYPE_HASH_ADDRESS;
|
||||
let encoded = addr.encode()?;
|
||||
let decoded = Address::decode(&encoded)?;
|
||||
assert_eq!(addr, &decoded);
|
||||
Ok(())
|
||||
}
|
||||
|
||||
|
@ -276,6 +286,11 @@ mod tests {
|
|||
let encoded = addr.encode()?;
|
||||
let decoded = Address::decode(&encoded)?;
|
||||
assert_eq!(addr, decoded);
|
||||
|
||||
let addr = &*TYPE_UUID_ADDRESS;
|
||||
let encoded = addr.encode()?;
|
||||
let decoded = Address::decode(&encoded)?;
|
||||
assert_eq!(addr, &decoded);
|
||||
Ok(())
|
||||
}
|
||||
|
||||
|
@ -285,6 +300,11 @@ mod tests {
|
|||
let encoded = addr.encode()?;
|
||||
let decoded = Address::decode(&encoded)?;
|
||||
assert_eq!(addr, decoded);
|
||||
|
||||
let addr = &*TYPE_ATTRIBUTE_ADDRESS;
|
||||
let encoded = addr.encode()?;
|
||||
let decoded = Address::decode(&encoded)?;
|
||||
assert_eq!(addr, &decoded);
|
||||
Ok(())
|
||||
}
|
||||
|
||||
|
@ -294,6 +314,11 @@ mod tests {
|
|||
let encoded = addr.encode()?;
|
||||
let decoded = Address::decode(&encoded)?;
|
||||
assert_eq!(addr, decoded);
|
||||
|
||||
let addr = &*TYPE_URL_ADDRESS;
|
||||
let encoded = addr.encode()?;
|
||||
let decoded = Address::decode(&encoded)?;
|
||||
assert_eq!(addr, &decoded);
|
||||
Ok(())
|
||||
}
|
||||
}
|
||||
|
|
|
@ -49,6 +49,7 @@ pub struct Entry {
|
|||
pub attribute: Attribute,
|
||||
pub value: EntryValue,
|
||||
pub provenance: String,
|
||||
pub user: Option<String>,
|
||||
pub timestamp: NaiveDateTime,
|
||||
}
|
||||
|
||||
|
@ -61,6 +62,7 @@ pub struct InvariantEntry {
|
|||
pub value: EntryValue,
|
||||
}
|
||||
|
||||
#[allow(clippy::large_enum_variant)]
|
||||
#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
|
||||
#[serde(tag = "t", content = "c")]
|
||||
pub enum EntryValue {
|
||||
|
@ -80,6 +82,7 @@ impl TryFrom<&InvariantEntry> for Entry {
|
|||
attribute: invariant.attribute.clone(),
|
||||
value: invariant.value.clone(),
|
||||
provenance: "INVARIANT".to_string(),
|
||||
user: None,
|
||||
timestamp: NaiveDateTime::from_timestamp_opt(0, 0).unwrap(),
|
||||
})
|
||||
}
|
||||
|
|
|
@ -79,6 +79,7 @@ impl TryFrom<lexpr::Value> for Attribute {
|
|||
}
|
||||
}
|
||||
|
||||
#[allow(clippy::large_enum_variant)]
|
||||
#[derive(Debug, Clone, PartialEq)]
|
||||
pub enum QueryPart {
|
||||
Matches(PatternQuery),
|
||||
|
|
|
@ -4,5 +4,4 @@ pub struct UpEndConfig {
|
|||
pub desktop_enabled: bool,
|
||||
pub trust_executables: bool,
|
||||
pub secret: String,
|
||||
pub key: Option<String>,
|
||||
}
|
||||
|
|
|
@ -13,7 +13,7 @@ use upend_db::stores::Blob;
|
|||
use upend_db::{
|
||||
jobs::{JobContainer, JobState},
|
||||
stores::{fs::FILE_MIME_KEY, UpStore},
|
||||
BlobMode, UpEndConnection,
|
||||
BlobMode, OperationContext, UpEndConnection,
|
||||
};
|
||||
|
||||
lazy_static! {
|
||||
|
@ -26,6 +26,7 @@ lazy_static! {
|
|||
attribute: ATTR_LABEL.parse().unwrap(),
|
||||
value: "ID3".into(),
|
||||
provenance: "INVARIANT".to_string(),
|
||||
user: None,
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
};
|
||||
}
|
||||
|
@ -39,6 +40,7 @@ impl Extractor for ID3Extractor {
|
|||
connection: &UpEndConnection,
|
||||
store: Arc<Box<dyn UpStore + Send + Sync>>,
|
||||
mut job_container: JobContainer,
|
||||
context: OperationContext,
|
||||
) -> Result<Vec<Entry>> {
|
||||
if let Address::Hash(hash) = address {
|
||||
let files = store.retrieve(hash)?;
|
||||
|
@ -72,14 +74,16 @@ impl Extractor for ID3Extractor {
|
|||
"TYER" | "TBPM" => EntryValue::guess_from(text),
|
||||
_ => text.clone().into(),
|
||||
},
|
||||
provenance: "SYSTEM EXTRACTOR".to_string(),
|
||||
provenance: context.provenance.clone() + "EXTRACTOR",
|
||||
user: context.user.clone(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
},
|
||||
Entry {
|
||||
entity: Address::Attribute(format!("ID3_{}", frame.id()).parse()?),
|
||||
attribute: ATTR_LABEL.parse().unwrap(),
|
||||
value: format!("ID3: {}", frame.name()).into(),
|
||||
provenance: "SYSTEM EXTRACTOR".to_string(),
|
||||
provenance: context.provenance.clone() + "EXTRACTOR",
|
||||
user: context.user.clone(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
},
|
||||
]);
|
||||
|
@ -97,12 +101,14 @@ impl Extractor for ID3Extractor {
|
|||
Blob::from_filepath(&tmp_path),
|
||||
None,
|
||||
Some(BlobMode::StoreOnly),
|
||||
context.clone(),
|
||||
)?;
|
||||
result.push(Entry {
|
||||
entity: address.clone(),
|
||||
attribute: "ID3_PICTURE".parse()?,
|
||||
value: EntryValue::Address(Address::Hash(hash)),
|
||||
provenance: "SYSTEM EXTRACTOR".to_string(),
|
||||
provenance: context.provenance.clone() + "EXTRACTOR",
|
||||
user: context.user.clone(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
});
|
||||
has_pictures = true;
|
||||
|
@ -112,7 +118,8 @@ impl Extractor for ID3Extractor {
|
|||
entity: Address::Attribute("ID3_PICTURE".parse()?),
|
||||
attribute: ATTR_LABEL.parse().unwrap(),
|
||||
value: "ID3 Embedded Image".into(),
|
||||
provenance: "SYSTEM EXTRACTOR".to_string(),
|
||||
provenance: context.provenance.clone() + "EXTRACTOR",
|
||||
user: context.user.clone(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
})
|
||||
}
|
||||
|
@ -126,7 +133,8 @@ impl Extractor for ID3Extractor {
|
|||
entity: Address::Attribute(e.attribute.clone()),
|
||||
attribute: ATTR_OF.parse().unwrap(),
|
||||
value: EntryValue::Address(ID3_TYPE_INVARIANT.entity().unwrap()),
|
||||
provenance: "SYSTEM EXTRACTOR".to_string(),
|
||||
provenance: context.provenance.clone() + "EXTRACTOR",
|
||||
user: context.user.clone(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
})
|
||||
.collect::<Vec<Entry>>(),
|
||||
|
@ -138,7 +146,8 @@ impl Extractor for ID3Extractor {
|
|||
entity: address.clone(),
|
||||
attribute: ATTR_IN.parse().unwrap(),
|
||||
value: EntryValue::Address(ID3_TYPE_INVARIANT.entity().unwrap()),
|
||||
provenance: "SYSTEM EXTRACTOR".to_string(),
|
||||
provenance: context.provenance.clone() + "EXTRACTOR",
|
||||
user: context.user.clone(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
},
|
||||
]);
|
||||
|
|
|
@ -12,7 +12,7 @@ use upend_base::{
|
|||
use upend_db::{
|
||||
jobs::{JobContainer, JobState},
|
||||
stores::{fs::FILE_MIME_KEY, UpStore},
|
||||
UpEndConnection,
|
||||
OperationContext, UpEndConnection,
|
||||
};
|
||||
|
||||
pub struct ExifExtractor;
|
||||
|
@ -31,6 +31,7 @@ lazy_static! {
|
|||
value: "EXIF".into(),
|
||||
provenance: "INVARIANT".to_string(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
user: None
|
||||
};
|
||||
}
|
||||
|
||||
|
@ -41,6 +42,7 @@ impl Extractor for ExifExtractor {
|
|||
_connection: &UpEndConnection,
|
||||
store: Arc<Box<dyn UpStore + Send + Sync>>,
|
||||
mut job_container: JobContainer,
|
||||
context: OperationContext,
|
||||
) -> Result<Vec<Entry>> {
|
||||
if let Address::Hash(hash) = address {
|
||||
let files = store.retrieve(hash)?;
|
||||
|
@ -86,14 +88,16 @@ impl Extractor for ExifExtractor {
|
|||
EntryValue::guess_from(format!("{}", field.display_value()))
|
||||
}
|
||||
},
|
||||
provenance: "SYSTEM EXTRACTOR".to_string(),
|
||||
provenance: context.provenance.clone() + "EXTRACTOR",
|
||||
user: context.user.clone(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
},
|
||||
Entry {
|
||||
entity: Address::Attribute(attribute),
|
||||
attribute: ATTR_LABEL.parse().unwrap(),
|
||||
value: format!("EXIF: {}", tag_description).into(),
|
||||
provenance: "SYSTEM EXTRACTOR".to_string(),
|
||||
provenance: context.provenance.clone() + "EXTRACTOR",
|
||||
user: context.user.clone(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
},
|
||||
]);
|
||||
|
@ -109,7 +113,8 @@ impl Extractor for ExifExtractor {
|
|||
entity: Address::Attribute(e.attribute.clone()),
|
||||
attribute: ATTR_OF.parse().unwrap(),
|
||||
value: EntryValue::Address(EXIF_TYPE_INVARIANT.entity().unwrap()),
|
||||
provenance: "SYSTEM EXTRACTOR".to_string(),
|
||||
provenance: context.provenance.clone() + "EXTRACTOR",
|
||||
user: context.user.clone(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
})
|
||||
.collect::<Vec<Entry>>(),
|
||||
|
@ -123,7 +128,8 @@ impl Extractor for ExifExtractor {
|
|||
entity: address.clone(),
|
||||
attribute: ATTR_IN.parse().unwrap(),
|
||||
value: EntryValue::Address(EXIF_TYPE_INVARIANT.entity().unwrap()),
|
||||
provenance: "SYSTEM EXTRACTOR".to_string(),
|
||||
provenance: context.provenance.clone() + "EXTRACTOR",
|
||||
user: context.user.clone(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
},
|
||||
]);
|
||||
|
|
|
@ -3,6 +3,7 @@ use std::{process::Command, sync::Arc};
|
|||
use super::Extractor;
|
||||
use anyhow::{anyhow, Result};
|
||||
use lazy_static::lazy_static;
|
||||
use tracing::{debug, trace};
|
||||
use upend_base::{
|
||||
addressing::Address,
|
||||
constants::{ATTR_IN, ATTR_KEY, ATTR_LABEL, ATTR_OF},
|
||||
|
@ -11,7 +12,7 @@ use upend_base::{
|
|||
use upend_db::{
|
||||
jobs::{JobContainer, JobState},
|
||||
stores::{fs::FILE_MIME_KEY, UpStore},
|
||||
UpEndConnection,
|
||||
OperationContext, UpEndConnection,
|
||||
};
|
||||
|
||||
const DURATION_KEY: &str = "MEDIA_DURATION";
|
||||
|
@ -27,6 +28,7 @@ lazy_static! {
|
|||
value: "Multimedia".into(),
|
||||
provenance: "INVARIANT".to_string(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
user: None,
|
||||
};
|
||||
pub static ref DURATION_OF_MEDIA: Entry = Entry {
|
||||
entity: Address::Attribute(DURATION_KEY.parse().unwrap()),
|
||||
|
@ -34,6 +36,7 @@ lazy_static! {
|
|||
value: EntryValue::Address(MEDIA_TYPE_INVARIANT.entity().unwrap()),
|
||||
provenance: "INVARIANT".to_string(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
user: None,
|
||||
};
|
||||
}
|
||||
|
||||
|
@ -46,6 +49,7 @@ impl Extractor for MediaExtractor {
|
|||
_connection: &UpEndConnection,
|
||||
store: Arc<Box<dyn UpStore + Send + Sync>>,
|
||||
mut job_container: JobContainer,
|
||||
context: OperationContext,
|
||||
) -> Result<Vec<Entry>> {
|
||||
if let Address::Hash(hash) = address {
|
||||
let files = store.retrieve(hash)?;
|
||||
|
@ -94,7 +98,8 @@ impl Extractor for MediaExtractor {
|
|||
entity: address.clone(),
|
||||
attribute: DURATION_KEY.parse().unwrap(),
|
||||
value: EntryValue::Number(duration),
|
||||
provenance: "SYSTEM EXTRACTOR".to_string(),
|
||||
provenance: context.provenance.clone() + "EXTRACTOR",
|
||||
user: context.user.clone(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
},
|
||||
(&MEDIA_TYPE_INVARIANT as &InvariantEntry)
|
||||
|
@ -106,7 +111,8 @@ impl Extractor for MediaExtractor {
|
|||
entity: address.clone(),
|
||||
attribute: ATTR_IN.parse().unwrap(),
|
||||
value: EntryValue::Address(MEDIA_TYPE_INVARIANT.entity().unwrap()),
|
||||
provenance: "SYSTEM EXTRACTOR".to_string(),
|
||||
provenance: context.provenance.clone() + "EXTRACTOR",
|
||||
user: context.user.clone(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
},
|
||||
];
|
||||
|
|
|
@ -6,7 +6,9 @@ use std::{
|
|||
};
|
||||
use tracing::{debug, info, trace};
|
||||
use upend_base::{addressing::Address, entry::Entry};
|
||||
use upend_db::{jobs::JobContainer, stores::UpStore, UpEndConnection, UpEndDatabase};
|
||||
use upend_db::{
|
||||
jobs::JobContainer, stores::UpStore, OperationContext, UpEndConnection, UpEndDatabase,
|
||||
};
|
||||
|
||||
#[cfg(feature = "extractors-web")]
|
||||
pub mod web;
|
||||
|
@ -27,6 +29,7 @@ pub trait Extractor {
|
|||
connection: &UpEndConnection,
|
||||
store: Arc<Box<dyn UpStore + Send + Sync>>,
|
||||
job_container: JobContainer,
|
||||
context: OperationContext,
|
||||
) -> Result<Vec<Entry>>;
|
||||
|
||||
fn is_needed(&self, _address: &Address, _connection: &UpEndConnection) -> Result<bool> {
|
||||
|
@ -39,9 +42,10 @@ pub trait Extractor {
|
|||
connection: &UpEndConnection,
|
||||
store: Arc<Box<dyn UpStore + Send + Sync>>,
|
||||
job_container: JobContainer,
|
||||
context: OperationContext,
|
||||
) -> Result<usize> {
|
||||
if self.is_needed(address, connection)? {
|
||||
let entries = self.get(address, connection, store, job_container)?;
|
||||
let entries = self.get(address, connection, store, job_container, context)?;
|
||||
trace!("For \"{address}\", got: {entries:?}");
|
||||
|
||||
connection.transaction(|| {
|
||||
|
@ -62,6 +66,7 @@ pub fn extract_all<D: Borrow<UpEndDatabase>>(
|
|||
db: D,
|
||||
store: Arc<Box<dyn UpStore + Send + Sync>>,
|
||||
mut job_container: JobContainer,
|
||||
context: OperationContext,
|
||||
) -> Result<usize> {
|
||||
info!("Extracting metadata for all addresses.");
|
||||
|
||||
|
@ -77,7 +82,13 @@ pub fn extract_all<D: Borrow<UpEndDatabase>>(
|
|||
.par_iter()
|
||||
.map(|address| {
|
||||
let connection = db.connection()?;
|
||||
let entry_count = extract(address, &connection, store.clone(), job_container.clone());
|
||||
let entry_count = extract(
|
||||
address,
|
||||
&connection,
|
||||
store.clone(),
|
||||
job_container.clone(),
|
||||
context.clone(),
|
||||
);
|
||||
|
||||
let mut cnt = count.write().unwrap();
|
||||
*cnt += 1;
|
||||
|
@ -107,6 +118,7 @@ pub fn extract(
|
|||
connection: &UpEndConnection,
|
||||
store: Arc<Box<dyn UpStore + Send + Sync>>,
|
||||
job_container: JobContainer,
|
||||
context: OperationContext,
|
||||
) -> usize {
|
||||
let mut entry_count = 0;
|
||||
trace!("Extracting metadata for {address:?}");
|
||||
|
@ -118,6 +130,7 @@ pub fn extract(
|
|||
connection,
|
||||
store.clone(),
|
||||
job_container.clone(),
|
||||
context.clone(),
|
||||
);
|
||||
|
||||
match extract_result {
|
||||
|
@ -133,6 +146,7 @@ pub fn extract(
|
|||
connection,
|
||||
store.clone(),
|
||||
job_container.clone(),
|
||||
context.clone(),
|
||||
);
|
||||
|
||||
match extract_result {
|
||||
|
@ -148,6 +162,7 @@ pub fn extract(
|
|||
connection,
|
||||
store.clone(),
|
||||
job_container.clone(),
|
||||
context.clone(),
|
||||
);
|
||||
|
||||
match extract_result {
|
||||
|
@ -158,8 +173,13 @@ pub fn extract(
|
|||
|
||||
#[cfg(feature = "extractors-media")]
|
||||
{
|
||||
let extract_result =
|
||||
media::MediaExtractor.insert_info(address, connection, store.clone(), job_container);
|
||||
let extract_result = media::MediaExtractor.insert_info(
|
||||
address,
|
||||
connection,
|
||||
store.clone(),
|
||||
job_container,
|
||||
context.clone(),
|
||||
);
|
||||
|
||||
match extract_result {
|
||||
Ok(count) => entry_count += count,
|
||||
|
|
|
@ -14,7 +14,7 @@ use upend_base::entry::EntryValue;
|
|||
use upend_db::jobs::JobContainer;
|
||||
use upend_db::jobs::JobState;
|
||||
use upend_db::stores::UpStore;
|
||||
use upend_db::UpEndConnection;
|
||||
use upend_db::{OperationContext, UpEndConnection};
|
||||
use webpage::HTML;
|
||||
|
||||
pub struct WebExtractor;
|
||||
|
@ -26,6 +26,7 @@ impl Extractor for WebExtractor {
|
|||
_connection: &UpEndConnection,
|
||||
_store: Arc<Box<dyn UpStore + Send + Sync>>,
|
||||
mut job_container: JobContainer,
|
||||
context: OperationContext,
|
||||
) -> Result<Vec<Entry>> {
|
||||
if let Address::Url(url) = address {
|
||||
let mut job_handle =
|
||||
|
@ -42,21 +43,24 @@ impl Extractor for WebExtractor {
|
|||
entity: address.clone(),
|
||||
attribute: "HTML_TITLE".parse().unwrap(),
|
||||
value: html_title.clone().into(),
|
||||
provenance: "SYSTEM EXTRACTOR".to_string(),
|
||||
provenance: context.provenance.clone() + "EXTRACTOR",
|
||||
user: context.user.clone(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
}),
|
||||
html.title.map(|html_title| Entry {
|
||||
entity: address.clone(),
|
||||
attribute: ATTR_LABEL.parse().unwrap(),
|
||||
value: html_title.into(),
|
||||
provenance: "SYSTEM EXTRACTOR".to_string(),
|
||||
provenance: context.provenance.clone() + "EXTRACTOR",
|
||||
user: context.user.clone(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
}),
|
||||
html.description.map(|html_desc| Entry {
|
||||
entity: address.clone(),
|
||||
attribute: "HTML_DESCRIPTION".parse().unwrap(),
|
||||
value: html_desc.into(),
|
||||
provenance: "SYSTEM EXTRACTOR".to_string(),
|
||||
provenance: context.provenance.clone() + "EXTRACTOR",
|
||||
user: context.user.clone(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
}),
|
||||
];
|
||||
|
@ -67,7 +71,8 @@ impl Extractor for WebExtractor {
|
|||
entity: address.clone(),
|
||||
attribute: ATTR_LABEL.parse()?,
|
||||
value: value.clone().into(),
|
||||
provenance: "SYSTEM EXTRACTOR".to_string(),
|
||||
provenance: context.provenance.clone() + "EXTRACTOR",
|
||||
user: context.user.clone(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
}));
|
||||
}
|
||||
|
@ -76,7 +81,8 @@ impl Extractor for WebExtractor {
|
|||
entity: address.clone(),
|
||||
attribute: attribute.parse()?,
|
||||
value: value.into(),
|
||||
provenance: "SYSTEM EXTRACTOR".to_string(),
|
||||
provenance: context.provenance.clone() + "EXTRACTOR",
|
||||
user: context.user.clone(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
}));
|
||||
}
|
||||
|
@ -85,7 +91,8 @@ impl Extractor for WebExtractor {
|
|||
entity: address.clone(),
|
||||
attribute: "OG_IMAGE".parse()?,
|
||||
value: image.url.into(),
|
||||
provenance: "SYSTEM EXTRACTOR".to_string(),
|
||||
provenance: context.provenance.clone() + "EXTRACTOR",
|
||||
user: context.user.clone(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
}))
|
||||
}
|
||||
|
@ -101,7 +108,8 @@ impl Extractor for WebExtractor {
|
|||
entity: Address::Attribute(e.attribute.clone()),
|
||||
attribute: ATTR_OF.parse().unwrap(),
|
||||
value: EntryValue::Address(TYPE_URL_ADDRESS.clone()),
|
||||
provenance: "SYSTEM EXTRACTOR".to_string(),
|
||||
provenance: context.provenance.clone() + "EXTRACTOR",
|
||||
user: context.user.clone(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
},
|
||||
e,
|
||||
|
@ -149,7 +157,13 @@ mod test {
|
|||
let address = Address::Url(Url::parse("https://upend.dev").unwrap());
|
||||
assert!(WebExtractor.is_needed(&address, &connection)?);
|
||||
|
||||
WebExtractor.insert_info(&address, &connection, store, job_container)?;
|
||||
WebExtractor.insert_info(
|
||||
&address,
|
||||
&connection,
|
||||
store,
|
||||
job_container,
|
||||
OperationContext::default(),
|
||||
)?;
|
||||
|
||||
assert!(!WebExtractor.is_needed(&address, &connection)?);
|
||||
|
||||
|
|
|
@ -16,7 +16,7 @@ use std::collections::HashMap;
|
|||
use std::net::SocketAddr;
|
||||
use std::path::Path;
|
||||
use std::path::PathBuf;
|
||||
use std::sync::Arc;
|
||||
use std::sync::{Arc, Mutex};
|
||||
use tracing::trace;
|
||||
use tracing::{debug, error, info, warn};
|
||||
use tracing_subscriber::filter::{EnvFilter, LevelFilter};
|
||||
|
@ -26,7 +26,7 @@ use upend_base::hash::{sha256hash, UpMultihash};
|
|||
use upend_db::jobs::JobContainer;
|
||||
use upend_db::stores::fs::FsStore;
|
||||
use upend_db::stores::UpStore;
|
||||
use upend_db::{BlobMode, UpEndDatabase};
|
||||
use upend_db::{BlobMode, OperationContext, UpEndDatabase};
|
||||
|
||||
use crate::util::exec::block_background;
|
||||
|
||||
|
@ -80,7 +80,7 @@ enum Commands {
|
|||
entity: String,
|
||||
/// The attribute of the entry.
|
||||
attribute: String,
|
||||
/// The value; its type will be heurestically determined.
|
||||
/// The value; its type will be heuristically determined.
|
||||
value: String,
|
||||
/// Output format
|
||||
#[arg(short, long, default_value = "tsv")]
|
||||
|
@ -172,10 +172,6 @@ struct ServeArgs {
|
|||
#[arg(long, env = "UPEND_SECRET")]
|
||||
secret: Option<String>,
|
||||
|
||||
/// Authentication key users must supply.
|
||||
#[arg(long, env = "UPEND_KEY")]
|
||||
key: Option<String>,
|
||||
|
||||
/// Allowed host/domain name the API can serve.
|
||||
#[arg(long, env = "UPEND_ALLOW_HOST")]
|
||||
allow_host: Vec<String>,
|
||||
|
@ -349,7 +345,7 @@ async fn main() -> Result<()> {
|
|||
if !exists {
|
||||
warn!(
|
||||
"Couldn't locate Web UI directory ({:?}), disabling...",
|
||||
WEBUI_PATH.to_owned()
|
||||
*WEBUI_PATH
|
||||
);
|
||||
}
|
||||
exists
|
||||
|
@ -415,9 +411,9 @@ async fn main() -> Result<()> {
|
|||
})),
|
||||
desktop_enabled: !args.no_desktop,
|
||||
trust_executables: args.trust_executables,
|
||||
key: args.key,
|
||||
secret,
|
||||
},
|
||||
public: Arc::new(Mutex::new(upend.connection()?.get_users()?.is_empty())),
|
||||
};
|
||||
|
||||
// Start HTTP server
|
||||
|
@ -451,13 +447,18 @@ async fn main() -> Result<()> {
|
|||
block_background::<_, _, anyhow::Error>(move || {
|
||||
let connection: upend_db::UpEndConnection = upend.connection()?;
|
||||
|
||||
let tree_mode = args.rescan_mode.unwrap_or_else(|| {
|
||||
let tree_mode = if let Some(rescan_mode) = args.rescan_mode {
|
||||
connection.set_vault_options(upend_db::VaultOptions {
|
||||
blob_mode: Some(rescan_mode.clone()),
|
||||
})?;
|
||||
rescan_mode
|
||||
} else {
|
||||
connection
|
||||
.get_vault_options()
|
||||
.unwrap()
|
||||
.blob_mode
|
||||
.unwrap_or_default()
|
||||
});
|
||||
};
|
||||
|
||||
let _ = state.store.update(
|
||||
&upend,
|
||||
|
@ -466,8 +467,14 @@ async fn main() -> Result<()> {
|
|||
initial: false,
|
||||
tree_mode,
|
||||
},
|
||||
OperationContext::default(),
|
||||
);
|
||||
let _ = extractors::extract_all(
|
||||
upend,
|
||||
state.store,
|
||||
job_container,
|
||||
OperationContext::default(),
|
||||
);
|
||||
let _ = extractors::extract_all(upend, state.store, job_container);
|
||||
Ok(())
|
||||
});
|
||||
}
|
||||
|
|
|
@ -1,10 +1,10 @@
|
|||
use anyhow::anyhow;
|
||||
use anyhow::Result;
|
||||
use std::collections::HashMap;
|
||||
use std::io::Read;
|
||||
use std::path::Path;
|
||||
use std::process::Command;
|
||||
|
||||
use anyhow::Result;
|
||||
use tracing::{debug, trace};
|
||||
|
||||
use super::Previewable;
|
||||
|
||||
|
|
|
@ -1,10 +1,10 @@
|
|||
use anyhow::anyhow;
|
||||
use anyhow::Result;
|
||||
use std::collections::HashMap;
|
||||
use std::io::Read;
|
||||
use std::path::Path;
|
||||
use std::process::Command;
|
||||
|
||||
use anyhow::Result;
|
||||
use tracing::{debug, trace};
|
||||
|
||||
use super::Previewable;
|
||||
|
||||
|
|
|
@ -26,7 +26,7 @@ use serde_json::json;
|
|||
use std::collections::HashMap;
|
||||
use std::convert::{TryFrom, TryInto};
|
||||
use std::io::Write;
|
||||
use std::sync::Arc;
|
||||
use std::sync::{Arc, Mutex};
|
||||
use std::time::{SystemTime, UNIX_EPOCH};
|
||||
use tempfile::NamedTempFile;
|
||||
use tracing::{debug, info, trace};
|
||||
|
@ -41,6 +41,7 @@ use upend_db::jobs;
|
|||
use upend_db::stores::UpdateOptions;
|
||||
use upend_db::stores::{Blob, UpStore};
|
||||
use upend_db::BlobMode;
|
||||
use upend_db::OperationContext;
|
||||
use upend_db::UpEndDatabase;
|
||||
use upend_db::VaultOptions;
|
||||
use url::Url;
|
||||
|
@ -57,69 +58,146 @@ pub struct State {
|
|||
pub job_container: jobs::JobContainer,
|
||||
pub preview_store: Option<Arc<PreviewStore>>,
|
||||
pub preview_thread_pool: Option<Arc<rayon::ThreadPool>>,
|
||||
pub public: Arc<Mutex<bool>>,
|
||||
}
|
||||
|
||||
#[derive(Debug, Serialize, Deserialize)]
|
||||
struct JwtClaims {
|
||||
user: String,
|
||||
exp: usize,
|
||||
}
|
||||
|
||||
#[derive(Deserialize)]
|
||||
pub struct LoginRequest {
|
||||
key: String,
|
||||
pub struct UserPayload {
|
||||
username: String,
|
||||
password: String,
|
||||
}
|
||||
|
||||
#[derive(Deserialize)]
|
||||
pub struct LoginQueryParams {
|
||||
via: Option<String>,
|
||||
}
|
||||
|
||||
#[post("/api/auth/login")]
|
||||
pub async fn login(
|
||||
state: web::Data<State>,
|
||||
payload: web::Json<LoginRequest>,
|
||||
payload: web::Json<UserPayload>,
|
||||
query: web::Query<LoginQueryParams>,
|
||||
) -> Result<HttpResponse, Error> {
|
||||
if state.config.key.is_none() || Some(&payload.key) == state.config.key.as_ref() {
|
||||
let claims = JwtClaims {
|
||||
exp: (SystemTime::now()
|
||||
.duration_since(UNIX_EPOCH)
|
||||
.map_err(ErrorInternalServerError)?
|
||||
.as_secs()
|
||||
+ 7 * 24 * 60 * 60) as usize,
|
||||
};
|
||||
let conn = state.upend.connection().map_err(ErrorInternalServerError)?;
|
||||
|
||||
let token = jsonwebtoken::encode(
|
||||
&jsonwebtoken::Header::default(),
|
||||
&claims,
|
||||
&jsonwebtoken::EncodingKey::from_secret(state.config.secret.as_ref()),
|
||||
)
|
||||
.map_err(ErrorInternalServerError)?;
|
||||
|
||||
Ok(HttpResponse::Ok().json(json!({ "token": token })))
|
||||
} else {
|
||||
Err(ErrorUnauthorized("Incorrect token."))
|
||||
match conn.authenticate_user(&payload.username, &payload.password) {
|
||||
Ok(()) => {
|
||||
let token = create_token(&payload.username, &state.config.secret)?;
|
||||
match query.via.as_deref() {
|
||||
Some("cookie") => Ok(HttpResponse::NoContent()
|
||||
.append_header((http::header::SET_COOKIE, format!("key={}; Path=/", token)))
|
||||
.finish()),
|
||||
_ => Ok(HttpResponse::Ok().json(json!({ "key": token }))),
|
||||
}
|
||||
}
|
||||
Err(_) => Err(ErrorUnauthorized("Invalid credentials.")),
|
||||
}
|
||||
}
|
||||
|
||||
fn check_auth(req: &HttpRequest, state: &State) -> Result<(), actix_web::Error> {
|
||||
if let Some(key) = &state.config.key {
|
||||
if let Some(auth_header) = req.headers().get("Authorization") {
|
||||
let auth_header = auth_header.to_str().map_err(|err| {
|
||||
ErrorBadRequest(format!("Invalid value in Authorization header: {err:?}"))
|
||||
})?;
|
||||
#[post("/api/auth/logout")]
|
||||
pub async fn logout() -> Result<HttpResponse, Error> {
|
||||
Ok(HttpResponse::NoContent()
|
||||
.append_header((http::header::SET_COOKIE, "key=; Path=/; Max-Age=0"))
|
||||
.finish())
|
||||
}
|
||||
|
||||
let token = jsonwebtoken::decode::<JwtClaims>(
|
||||
auth_header,
|
||||
&jsonwebtoken::DecodingKey::from_secret(key.as_ref()),
|
||||
&jsonwebtoken::Validation::default(),
|
||||
);
|
||||
#[post("/api/auth/register")]
|
||||
pub async fn register(
|
||||
req: HttpRequest,
|
||||
state: web::Data<State>,
|
||||
payload: web::Json<UserPayload>,
|
||||
) -> Result<HttpResponse, Error> {
|
||||
check_auth(&req, &state)?;
|
||||
|
||||
token
|
||||
.map(|_| ())
|
||||
.map_err(|err| ErrorUnauthorized(format!("Invalid token: {err:?}")))
|
||||
} else {
|
||||
Err(ErrorUnauthorized("Authorization required."))
|
||||
let conn = state.upend.connection().map_err(ErrorInternalServerError)?;
|
||||
|
||||
match conn.set_user(&payload.username, &payload.password) {
|
||||
Ok(_) => {
|
||||
*state.public.lock().unwrap() = false;
|
||||
let token = create_token(&payload.username, &state.config.secret)?;
|
||||
Ok(HttpResponse::Ok().json(json!({ "token": token })))
|
||||
}
|
||||
Err(e) => Err(ErrorInternalServerError(e)),
|
||||
}
|
||||
}
|
||||
|
||||
#[get("/api/auth/whoami")]
|
||||
pub async fn whoami(req: HttpRequest, state: web::Data<State>) -> Result<HttpResponse, Error> {
|
||||
let user = check_auth(&req, &state)?;
|
||||
Ok(HttpResponse::Ok().json(json!({ "user": user })))
|
||||
}
|
||||
|
||||
fn check_auth(req: &HttpRequest, state: &State) -> Result<Option<String>, actix_web::Error> {
|
||||
if *state.public.lock().unwrap() {
|
||||
return Ok(None);
|
||||
}
|
||||
|
||||
let header_key = req.headers().get("Authorization").and_then(|value| {
|
||||
value.to_str().ok().and_then(|value| {
|
||||
if value.starts_with("Bearer ") {
|
||||
Some(value.trim_start_matches("Bearer ").to_string())
|
||||
} else {
|
||||
None
|
||||
}
|
||||
})
|
||||
});
|
||||
|
||||
let cookie_key = req.cookies().ok().and_then(|cookies| {
|
||||
cookies
|
||||
.iter()
|
||||
.find(|c| c.name() == "key")
|
||||
.map(|cookie| cookie.value().to_string())
|
||||
});
|
||||
|
||||
let query_key = req.query_string().split('&').find_map(|pair| {
|
||||
let parts = pair.split('=').collect::<Vec<&str>>();
|
||||
match parts[..] {
|
||||
["auth_key", value] => Some(value.to_string()),
|
||||
_ => None,
|
||||
}
|
||||
});
|
||||
|
||||
let key = header_key.or(cookie_key).or(query_key);
|
||||
|
||||
if let Some(key) = key {
|
||||
let token = jsonwebtoken::decode::<JwtClaims>(
|
||||
&key,
|
||||
&jsonwebtoken::DecodingKey::from_secret(state.config.secret.as_ref()),
|
||||
&jsonwebtoken::Validation::default(),
|
||||
);
|
||||
match token {
|
||||
Ok(token) => Ok(Some(token.claims.user)),
|
||||
Err(err) => Err(ErrorUnauthorized(format!("Invalid token: {err:?}"))),
|
||||
}
|
||||
} else {
|
||||
Ok(())
|
||||
Err(ErrorUnauthorized("Authorization required."))
|
||||
}
|
||||
}
|
||||
|
||||
fn create_token(username: &str, secret: &str) -> Result<String, Error> {
|
||||
let claims = JwtClaims {
|
||||
user: username.to_string(),
|
||||
exp: (SystemTime::now()
|
||||
.duration_since(UNIX_EPOCH)
|
||||
.map_err(ErrorInternalServerError)?
|
||||
.as_secs()
|
||||
+ 7 * 24 * 60 * 60) as usize,
|
||||
};
|
||||
|
||||
jsonwebtoken::encode(
|
||||
&jsonwebtoken::Header::default(),
|
||||
&claims,
|
||||
&jsonwebtoken::EncodingKey::from_secret(secret.as_ref()),
|
||||
)
|
||||
.map_err(ErrorInternalServerError)
|
||||
}
|
||||
|
||||
#[derive(Deserialize)]
|
||||
pub struct RawRequest {
|
||||
native: Option<String>,
|
||||
|
@ -128,10 +206,13 @@ pub struct RawRequest {
|
|||
|
||||
#[get("/api/raw/{hash}")]
|
||||
pub async fn get_raw(
|
||||
req: HttpRequest,
|
||||
state: web::Data<State>,
|
||||
web::Query(query): web::Query<RawRequest>,
|
||||
hash: web::Path<String>,
|
||||
) -> Result<impl Responder, Error> {
|
||||
check_auth(&req, &state)?;
|
||||
|
||||
let address =
|
||||
Address::decode(&b58_decode(hash.into_inner()).map_err(ErrorInternalServerError)?)
|
||||
.map_err(ErrorInternalServerError)?;
|
||||
|
@ -218,9 +299,12 @@ pub async fn get_raw(
|
|||
|
||||
#[head("/api/raw/{hash}")]
|
||||
pub async fn head_raw(
|
||||
req: HttpRequest,
|
||||
state: web::Data<State>,
|
||||
hash: web::Path<String>,
|
||||
) -> Result<HttpResponse, Error> {
|
||||
check_auth(&req, &state)?;
|
||||
|
||||
let address =
|
||||
Address::decode(&b58_decode(hash.into_inner()).map_err(ErrorInternalServerError)?)
|
||||
.map_err(ErrorInternalServerError)?;
|
||||
|
@ -254,10 +338,13 @@ pub async fn head_raw(
|
|||
|
||||
#[get("/api/thumb/{hash}")]
|
||||
pub async fn get_thumbnail(
|
||||
req: HttpRequest,
|
||||
state: web::Data<State>,
|
||||
hash: web::Path<String>,
|
||||
web::Query(query): web::Query<HashMap<String, String>>,
|
||||
) -> Result<Either<NamedFile, HttpResponse>, Error> {
|
||||
check_auth(&req, &state)?;
|
||||
|
||||
#[cfg(feature = "previews")]
|
||||
if let Some(preview_store) = &state.preview_store {
|
||||
let hash = hash.into_inner();
|
||||
|
@ -299,7 +386,13 @@ pub async fn get_thumbnail(
|
|||
}
|
||||
|
||||
#[post("/api/query")]
|
||||
pub async fn get_query(state: web::Data<State>, query: String) -> Result<HttpResponse, Error> {
|
||||
pub async fn get_query(
|
||||
req: HttpRequest,
|
||||
state: web::Data<State>,
|
||||
query: String,
|
||||
) -> Result<HttpResponse, Error> {
|
||||
check_auth(&req, &state)?;
|
||||
|
||||
let connection = state.upend.connection().map_err(ErrorInternalServerError)?;
|
||||
|
||||
let in_query: Query = query.parse().map_err(ErrorBadRequest)?;
|
||||
|
@ -341,9 +434,12 @@ impl EntriesAsHash for Vec<Entry> {
|
|||
|
||||
#[get("/api/obj/{address_str}")]
|
||||
pub async fn get_object(
|
||||
req: HttpRequest,
|
||||
state: web::Data<State>,
|
||||
address: web::Path<Address>,
|
||||
) -> Result<HttpResponse, Error> {
|
||||
check_auth(&req, &state)?;
|
||||
|
||||
let connection = state.upend.connection().map_err(ErrorInternalServerError)?;
|
||||
let address = address.into_inner();
|
||||
|
||||
|
@ -385,6 +481,7 @@ pub struct InEntry {
|
|||
pub value: EntryValue,
|
||||
}
|
||||
|
||||
#[allow(clippy::large_enum_variant)]
|
||||
#[derive(Debug, Clone, Deserialize)]
|
||||
#[serde(untagged, deny_unknown_fields)]
|
||||
pub enum PutInput {
|
||||
|
@ -405,7 +502,7 @@ pub async fn put_object(
|
|||
payload: web::Json<PutInput>,
|
||||
web::Query(query): web::Query<UpdateQuery>,
|
||||
) -> Result<HttpResponse, Error> {
|
||||
check_auth(&req, &state)?;
|
||||
let user = check_auth(&req, &state)?;
|
||||
|
||||
let (entry_address, entity_address) = {
|
||||
let connection = state.upend.connection().map_err(ErrorInternalServerError)?;
|
||||
|
@ -414,6 +511,7 @@ pub async fn put_object(
|
|||
debug!("PUTting {in_entry:?}");
|
||||
|
||||
let provenance = query.provenance.clone();
|
||||
let _user = user.clone();
|
||||
let process_inentry = move |in_entry: InEntry| -> Result<Entry> {
|
||||
if let Some(entity) = in_entry.entity {
|
||||
Ok(Entry {
|
||||
|
@ -427,6 +525,7 @@ pub async fn put_object(
|
|||
.trim()
|
||||
.to_string(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
user: _user.clone(),
|
||||
})
|
||||
} else {
|
||||
Ok(Entry::try_from(&InvariantEntry {
|
||||
|
@ -468,15 +567,25 @@ pub async fn put_object(
|
|||
let _address = address.clone();
|
||||
let _job_container = state.job_container.clone();
|
||||
let _store = state.store.clone();
|
||||
let _user = user.clone();
|
||||
block_background::<_, _, anyhow::Error>(move || {
|
||||
let entry_count =
|
||||
extractors::extract(&_address, &connection, _store, _job_container);
|
||||
let entry_count = extractors::extract(
|
||||
&_address,
|
||||
&connection,
|
||||
_store,
|
||||
_job_container,
|
||||
OperationContext {
|
||||
user: _user,
|
||||
provenance: "API".to_string(),
|
||||
},
|
||||
);
|
||||
|
||||
debug!("Added {entry_count} extracted entries for {_address:?}");
|
||||
Ok(())
|
||||
});
|
||||
|
||||
let connection = state.upend.connection().map_err(ErrorInternalServerError)?;
|
||||
let _user = user.clone();
|
||||
web::block(move || {
|
||||
connection.transaction::<_, anyhow::Error, _>(|| {
|
||||
if connection.retrieve_object(&address)?.is_empty() {
|
||||
|
@ -495,6 +604,7 @@ pub async fn put_object(
|
|||
})
|
||||
.trim()
|
||||
.to_string(),
|
||||
user: _user,
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
})?;
|
||||
}
|
||||
|
@ -517,7 +627,7 @@ pub async fn put_blob(
|
|||
state: web::Data<State>,
|
||||
mut payload: Multipart,
|
||||
) -> Result<HttpResponse, Error> {
|
||||
check_auth(&req, &state)?;
|
||||
let user = check_auth(&req, &state)?;
|
||||
|
||||
if let Some(mut field) = payload.try_next().await? {
|
||||
let mut file = NamedTempFile::new()?;
|
||||
|
@ -556,6 +666,7 @@ pub async fn put_blob(
|
|||
let connection = state.upend.connection().map_err(ErrorInternalServerError)?;
|
||||
let _store = state.store.clone();
|
||||
let _filename = filename.clone();
|
||||
let _user = user.clone();
|
||||
let hash = web::block(move || {
|
||||
let options = connection.get_vault_options()?;
|
||||
_store
|
||||
|
@ -564,6 +675,10 @@ pub async fn put_blob(
|
|||
Blob::from_filepath(file.path()),
|
||||
_filename,
|
||||
options.blob_mode,
|
||||
OperationContext {
|
||||
user: _user,
|
||||
provenance: "API".to_string(),
|
||||
},
|
||||
)
|
||||
.map_err(anyhow::Error::from)
|
||||
})
|
||||
|
@ -589,8 +704,18 @@ pub async fn put_blob(
|
|||
let _job_container = state.job_container.clone();
|
||||
let _store = state.store.clone();
|
||||
let connection = state.upend.connection().map_err(ErrorInternalServerError)?;
|
||||
let _user = user.clone();
|
||||
block_background::<_, _, anyhow::Error>(move || {
|
||||
let entry_count = extractors::extract(&_address, &connection, _store, _job_container);
|
||||
let entry_count = extractors::extract(
|
||||
&_address,
|
||||
&connection,
|
||||
_store,
|
||||
_job_container,
|
||||
OperationContext {
|
||||
user: _user,
|
||||
provenance: "API".to_string(),
|
||||
},
|
||||
);
|
||||
debug!("Added {entry_count} extracted entries for {_address:?}");
|
||||
Ok(())
|
||||
});
|
||||
|
@ -608,7 +733,7 @@ pub async fn put_object_attribute(
|
|||
value: web::Json<EntryValue>,
|
||||
web::Query(query): web::Query<UpdateQuery>,
|
||||
) -> Result<HttpResponse, Error> {
|
||||
check_auth(&req, &state)?;
|
||||
let user = check_auth(&req, &state)?;
|
||||
let (address, attribute) = path.into_inner();
|
||||
let connection = state.upend.connection().map_err(ErrorInternalServerError)?;
|
||||
|
||||
|
@ -631,6 +756,7 @@ pub async fn put_object_attribute(
|
|||
})
|
||||
.trim()
|
||||
.to_string(),
|
||||
user: user.clone(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
};
|
||||
|
||||
|
@ -735,7 +861,12 @@ pub async fn get_address(
|
|||
}
|
||||
|
||||
#[get("/api/all/attributes")]
|
||||
pub async fn get_all_attributes(state: web::Data<State>) -> Result<HttpResponse, Error> {
|
||||
pub async fn get_all_attributes(
|
||||
req: HttpRequest,
|
||||
state: web::Data<State>,
|
||||
) -> Result<HttpResponse, Error> {
|
||||
check_auth(&req, &state)?;
|
||||
|
||||
let connection = state.upend.connection().map_err(ErrorInternalServerError)?;
|
||||
let attributes = web::block(move || connection.get_all_attributes())
|
||||
.await?
|
||||
|
@ -778,6 +909,8 @@ pub async fn list_hier(
|
|||
path: web::Path<String>,
|
||||
req: HttpRequest,
|
||||
) -> Result<HttpResponse, Error> {
|
||||
let user = check_auth(&req, &state)?;
|
||||
|
||||
let connection = state.upend.connection().map_err(ErrorInternalServerError)?;
|
||||
if path.is_empty() {
|
||||
Ok(HttpResponse::MovedPermanently()
|
||||
|
@ -788,9 +921,19 @@ pub async fn list_hier(
|
|||
trace!(r#"Listing path "{}""#, upath);
|
||||
|
||||
let create = !req.method().is_safe();
|
||||
let path = web::block(move || resolve_path(&connection, &upath, create))
|
||||
.await?
|
||||
.map_err(ErrorNotFound)?;
|
||||
let path = web::block(move || {
|
||||
resolve_path(
|
||||
&connection,
|
||||
&upath,
|
||||
create,
|
||||
OperationContext {
|
||||
user,
|
||||
provenance: "API".to_string(),
|
||||
},
|
||||
)
|
||||
})
|
||||
.await?
|
||||
.map_err(ErrorNotFound)?;
|
||||
match path.last() {
|
||||
Some(addr) => Ok(HttpResponse::Found()
|
||||
.append_header((http::header::LOCATION, format!("../../api/obj/{}", addr)))
|
||||
|
@ -801,7 +944,11 @@ pub async fn list_hier(
|
|||
}
|
||||
|
||||
#[get("/api/hier_roots")]
|
||||
pub async fn list_hier_roots(state: web::Data<State>) -> Result<HttpResponse, Error> {
|
||||
pub async fn list_hier_roots(
|
||||
req: HttpRequest,
|
||||
state: web::Data<State>,
|
||||
) -> Result<HttpResponse, Error> {
|
||||
check_auth(&req, &state)?;
|
||||
let connection = state.upend.connection().map_err(ErrorInternalServerError)?;
|
||||
|
||||
let result = web::block(move || {
|
||||
|
@ -829,7 +976,7 @@ pub async fn api_refresh(
|
|||
state: web::Data<State>,
|
||||
web::Query(query): web::Query<RescanRequest>,
|
||||
) -> Result<HttpResponse, Error> {
|
||||
check_auth(&req, &state)?;
|
||||
let user = check_auth(&req, &state)?;
|
||||
|
||||
let connection = state.upend.connection().map_err(ErrorInternalServerError)?;
|
||||
|
||||
|
@ -846,11 +993,19 @@ pub async fn api_refresh(
|
|||
.unwrap_or_default(),
|
||||
),
|
||||
},
|
||||
OperationContext {
|
||||
user: user.clone(),
|
||||
provenance: "API".to_string(),
|
||||
},
|
||||
);
|
||||
let _ = crate::extractors::extract_all(
|
||||
state.upend.clone(),
|
||||
state.store.clone(),
|
||||
state.job_container.clone(),
|
||||
OperationContext {
|
||||
user: user.clone(),
|
||||
provenance: "API".to_string(),
|
||||
},
|
||||
);
|
||||
Ok(())
|
||||
});
|
||||
|
@ -858,13 +1013,15 @@ pub async fn api_refresh(
|
|||
}
|
||||
|
||||
#[get("/api/stats/vault")]
|
||||
pub async fn vault_stats(state: web::Data<State>) -> Result<HttpResponse, Error> {
|
||||
pub async fn vault_stats(req: HttpRequest, state: web::Data<State>) -> Result<HttpResponse, Error> {
|
||||
check_auth(&req, &state)?;
|
||||
let connection = state.upend.connection().map_err(ErrorInternalServerError)?;
|
||||
Ok(HttpResponse::Ok().json(connection.get_stats().map_err(ErrorInternalServerError)?))
|
||||
}
|
||||
|
||||
#[get("/api/stats/store")]
|
||||
pub async fn store_stats(state: web::Data<State>) -> Result<HttpResponse, Error> {
|
||||
pub async fn store_stats(req: HttpRequest, state: web::Data<State>) -> Result<HttpResponse, Error> {
|
||||
check_auth(&req, &state)?;
|
||||
Ok(HttpResponse::Ok().json(json!({
|
||||
"main": state.store.stats().map_err(ErrorInternalServerError)?
|
||||
})))
|
||||
|
@ -877,9 +1034,11 @@ pub struct JobsRequest {
|
|||
|
||||
#[get("/api/jobs")]
|
||||
pub async fn get_jobs(
|
||||
req: HttpRequest,
|
||||
state: web::Data<State>,
|
||||
web::Query(query): web::Query<JobsRequest>,
|
||||
) -> Result<HttpResponse, Error> {
|
||||
check_auth(&req, &state)?;
|
||||
let jobs = state
|
||||
.job_container
|
||||
.get_jobs()
|
||||
|
@ -906,12 +1065,14 @@ pub async fn get_info(state: web::Data<State>) -> Result<HttpResponse, Error> {
|
|||
upend_db::common::build::PKG_VERSION,
|
||||
build::PKG_VERSION
|
||||
),
|
||||
"desktop": state.config.desktop_enabled
|
||||
"desktop": state.config.desktop_enabled,
|
||||
"public": *state.public.lock().unwrap(),
|
||||
})))
|
||||
}
|
||||
|
||||
#[get("/api/options")]
|
||||
pub async fn get_options(state: web::Data<State>) -> Result<HttpResponse, Error> {
|
||||
pub async fn get_options(req: HttpRequest, state: web::Data<State>) -> Result<HttpResponse, Error> {
|
||||
check_auth(&req, &state)?;
|
||||
let connection = state.upend.connection().map_err(ErrorInternalServerError)?;
|
||||
Ok(HttpResponse::Ok().json(
|
||||
connection
|
||||
|
@ -939,7 +1100,11 @@ pub async fn put_options(
|
|||
}
|
||||
|
||||
#[get("/api/migration/user-entries")]
|
||||
pub async fn get_user_entries(state: web::Data<State>) -> Result<HttpResponse, Error> {
|
||||
pub async fn get_user_entries(
|
||||
req: HttpRequest,
|
||||
state: web::Data<State>,
|
||||
) -> Result<HttpResponse, Error> {
|
||||
check_auth(&req, &state)?;
|
||||
let connection = state.upend.connection().map_err(ErrorInternalServerError)?;
|
||||
|
||||
let result = web::block(move || connection.get_explicit_entries())
|
||||
|
@ -1214,6 +1379,7 @@ mod tests {
|
|||
initial: true,
|
||||
tree_mode: upend_db::BlobMode::default(),
|
||||
},
|
||||
OperationContext::default(),
|
||||
)
|
||||
.unwrap();
|
||||
|
||||
|
@ -1225,11 +1391,11 @@ mod tests {
|
|||
desktop_enabled: false,
|
||||
trust_executables: false,
|
||||
secret: "secret".to_string(),
|
||||
key: None,
|
||||
},
|
||||
job_container,
|
||||
preview_store: None,
|
||||
preview_thread_pool: None,
|
||||
public: Arc::new(Mutex::new(true)),
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
|
@ -46,6 +46,9 @@ where
|
|||
.app_data(actix_web::web::Data::new(state))
|
||||
.wrap(actix_web::middleware::Logger::default().exclude("/api/jobs"))
|
||||
.service(routes::login)
|
||||
.service(routes::register)
|
||||
.service(routes::logout)
|
||||
.service(routes::whoami)
|
||||
.service(routes::get_raw)
|
||||
.service(routes::head_raw)
|
||||
.service(routes::get_thumbnail)
|
||||
|
|
|
@ -26,13 +26,16 @@ once_cell = "1.7.2"
|
|||
lru = "0.7.0"
|
||||
|
||||
diesel = { version = "1.4", features = [
|
||||
"sqlite",
|
||||
"r2d2",
|
||||
"chrono",
|
||||
"serde_json",
|
||||
"sqlite",
|
||||
"r2d2",
|
||||
"chrono",
|
||||
"serde_json",
|
||||
] }
|
||||
diesel_migrations = "1.4"
|
||||
libsqlite3-sys = { version = "^0", features = ["bundled"] }
|
||||
password-hash = "0.5.0"
|
||||
argon2 = "0.5.3"
|
||||
|
||||
|
||||
chrono = { version = "0.4", features = ["serde"] }
|
||||
serde = { version = "1.0", features = ["derive"] }
|
||||
|
@ -42,10 +45,10 @@ regex = "1"
|
|||
|
||||
multibase = "0.9"
|
||||
multihash = { version = "*", default-features = false, features = [
|
||||
"alloc",
|
||||
"multihash-impl",
|
||||
"sha2",
|
||||
"identity",
|
||||
"alloc",
|
||||
"multihash-impl",
|
||||
"sha2",
|
||||
"identity",
|
||||
] }
|
||||
uuid = { version = "1.4", features = ["v4"] }
|
||||
url = { version = "2", features = ["serde"] }
|
||||
|
|
|
@ -0,0 +1 @@
|
|||
DROP TABLE users;
|
|
@ -0,0 +1,7 @@
|
|||
CREATE TABLE users
|
||||
(
|
||||
id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL,
|
||||
username VARCHAR NOT NULL,
|
||||
password VARCHAR NOT NULL,
|
||||
UNIQUE (username)
|
||||
);
|
|
@ -0,0 +1,2 @@
|
|||
ALTER TABLE data
|
||||
DROP COLUMN user;
|
|
@ -0,0 +1,2 @@
|
|||
ALTER TABLE data
|
||||
ADD COLUMN user VARCHAR;
|
|
@ -178,9 +178,7 @@ pub fn execute(
|
|||
var_name.clone(),
|
||||
subquery_results
|
||||
.iter()
|
||||
.map(|e| {
|
||||
e.attribute.parse().map(|a| EntryPart::Attribute(a))
|
||||
})
|
||||
.map(|e| e.attribute.parse().map(EntryPart::Attribute))
|
||||
.collect::<Result<Vec<EntryPart>, _>>()?,
|
||||
);
|
||||
}
|
||||
|
|
|
@ -14,6 +14,7 @@ impl TryFrom<&models::Entry> for Entry {
|
|||
attribute: e.attribute.parse()?,
|
||||
value: value_str.parse().unwrap(),
|
||||
provenance: e.provenance.clone(),
|
||||
user: e.user.clone(),
|
||||
timestamp: e.timestamp,
|
||||
})
|
||||
} else if let Some(value_num) = e.value_num {
|
||||
|
@ -22,6 +23,7 @@ impl TryFrom<&models::Entry> for Entry {
|
|||
attribute: e.attribute.parse()?,
|
||||
value: EntryValue::Number(value_num),
|
||||
provenance: e.provenance.clone(),
|
||||
user: e.user.clone(),
|
||||
timestamp: e.timestamp,
|
||||
})
|
||||
} else {
|
||||
|
@ -30,6 +32,7 @@ impl TryFrom<&models::Entry> for Entry {
|
|||
attribute: e.attribute.parse()?,
|
||||
value: EntryValue::Number(f64::NAN),
|
||||
provenance: e.provenance.clone(),
|
||||
user: e.user.clone(),
|
||||
timestamp: e.timestamp,
|
||||
})
|
||||
}
|
||||
|
@ -53,6 +56,7 @@ impl TryFrom<&Entry> for models::Entry {
|
|||
value_num: None,
|
||||
immutable: false,
|
||||
provenance: e.provenance.clone(),
|
||||
user: e.user.clone(),
|
||||
timestamp: e.timestamp,
|
||||
};
|
||||
|
||||
|
|
|
@ -6,6 +6,7 @@ use lru::LruCache;
|
|||
use tracing::trace;
|
||||
use uuid::Uuid;
|
||||
|
||||
use crate::OperationContext;
|
||||
use upend_base::addressing::Address;
|
||||
use upend_base::constants::ATTR_LABEL;
|
||||
use upend_base::constants::{ATTR_IN, HIER_ROOT_ADDR, HIER_ROOT_INVARIANT};
|
||||
|
@ -91,6 +92,7 @@ pub fn fetch_or_create_dir(
|
|||
parent: Option<Address>,
|
||||
directory: UNode,
|
||||
create: bool,
|
||||
context: OperationContext,
|
||||
) -> Result<Address> {
|
||||
match parent.clone() {
|
||||
Some(address) => trace!("FETCHING/CREATING {}/{:#}", address, directory),
|
||||
|
@ -137,7 +139,8 @@ pub fn fetch_or_create_dir(
|
|||
entity: new_directory_address.clone(),
|
||||
attribute: ATTR_LABEL.parse().unwrap(),
|
||||
value: directory.to_string().into(),
|
||||
provenance: "SYSTEM FS".to_string(),
|
||||
provenance: context.provenance.clone() + "HIER",
|
||||
user: context.user.clone(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
};
|
||||
connection.insert_entry(directory_entry)?;
|
||||
|
@ -147,7 +150,8 @@ pub fn fetch_or_create_dir(
|
|||
entity: new_directory_address.clone(),
|
||||
attribute: ATTR_IN.parse().unwrap(),
|
||||
value: parent.into(),
|
||||
provenance: "SYSTEM FS".to_string(),
|
||||
provenance: context.provenance.clone() + "HIER",
|
||||
user: context.user.clone(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
}
|
||||
} else {
|
||||
|
@ -155,7 +159,8 @@ pub fn fetch_or_create_dir(
|
|||
entity: new_directory_address.clone(),
|
||||
attribute: ATTR_IN.parse().unwrap(),
|
||||
value: HIER_ROOT_ADDR.clone().into(),
|
||||
provenance: "SYSTEM FS".to_string(),
|
||||
provenance: context.provenance.clone() + "HIER",
|
||||
user: context.user.clone(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
}
|
||||
})?;
|
||||
|
@ -177,6 +182,7 @@ pub fn resolve_path(
|
|||
connection: &UpEndConnection,
|
||||
path: &UHierPath,
|
||||
create: bool,
|
||||
context: OperationContext,
|
||||
) -> Result<Vec<Address>> {
|
||||
let mut result: Vec<Address> = vec![];
|
||||
let mut path_stack = path.0.to_vec();
|
||||
|
@ -188,6 +194,7 @@ pub fn resolve_path(
|
|||
result.last().cloned(),
|
||||
path_stack.pop().unwrap(),
|
||||
create,
|
||||
context.clone(),
|
||||
)?;
|
||||
result.push(dir_address);
|
||||
}
|
||||
|
@ -201,6 +208,7 @@ pub fn resolve_path_cached(
|
|||
connection: &UpEndConnection,
|
||||
path: &UHierPath,
|
||||
create: bool,
|
||||
context: OperationContext,
|
||||
cache: &Arc<Mutex<ResolveCache>>,
|
||||
) -> Result<Vec<Address>> {
|
||||
let mut result: Vec<Address> = vec![];
|
||||
|
@ -216,7 +224,7 @@ pub fn resolve_path_cached(
|
|||
result.push(address.clone());
|
||||
} else {
|
||||
drop(cache_lock);
|
||||
let address = fetch_or_create_dir(connection, parent, node, create)?;
|
||||
let address = fetch_or_create_dir(connection, parent, node, create, context.clone())?;
|
||||
result.push(address.clone());
|
||||
cache.lock().unwrap().put(key, address);
|
||||
}
|
||||
|
@ -286,11 +294,23 @@ mod tests {
|
|||
let open_result = UpEndDatabase::open(&temp_dir, true).unwrap();
|
||||
let connection = open_result.db.connection().unwrap();
|
||||
|
||||
let foo_result = fetch_or_create_dir(&connection, None, UNode("foo".to_string()), true);
|
||||
let foo_result = fetch_or_create_dir(
|
||||
&connection,
|
||||
None,
|
||||
UNode("foo".to_string()),
|
||||
true,
|
||||
OperationContext::default(),
|
||||
);
|
||||
assert!(foo_result.is_ok());
|
||||
let foo_result = foo_result.unwrap();
|
||||
|
||||
let bar_result = fetch_or_create_dir(&connection, None, UNode("bar".to_string()), true);
|
||||
let bar_result = fetch_or_create_dir(
|
||||
&connection,
|
||||
None,
|
||||
UNode("bar".to_string()),
|
||||
true,
|
||||
OperationContext::default(),
|
||||
);
|
||||
assert!(bar_result.is_ok());
|
||||
let bar_result = bar_result.unwrap();
|
||||
|
||||
|
@ -299,6 +319,7 @@ mod tests {
|
|||
Some(bar_result.clone()),
|
||||
UNode("baz".to_string()),
|
||||
true,
|
||||
OperationContext::default(),
|
||||
);
|
||||
assert!(baz_result.is_ok());
|
||||
let baz_result = baz_result.unwrap();
|
||||
|
@ -306,7 +327,12 @@ mod tests {
|
|||
let roots = list_roots(&connection);
|
||||
assert_eq!(roots.unwrap(), [foo_result, bar_result.clone()]);
|
||||
|
||||
let resolve_result = resolve_path(&connection, &"bar/baz".parse().unwrap(), false);
|
||||
let resolve_result = resolve_path(
|
||||
&connection,
|
||||
&"bar/baz".parse().unwrap(),
|
||||
false,
|
||||
OperationContext::default(),
|
||||
);
|
||||
|
||||
assert!(resolve_result.is_ok());
|
||||
assert_eq!(
|
||||
|
@ -314,10 +340,20 @@ mod tests {
|
|||
vec![bar_result.clone(), baz_result.clone()]
|
||||
);
|
||||
|
||||
let resolve_result = resolve_path(&connection, &"bar/baz/bax".parse().unwrap(), false);
|
||||
let resolve_result = resolve_path(
|
||||
&connection,
|
||||
&"bar/baz/bax".parse().unwrap(),
|
||||
false,
|
||||
OperationContext::default(),
|
||||
);
|
||||
assert!(resolve_result.is_err());
|
||||
|
||||
let resolve_result = resolve_path(&connection, &"bar/baz/bax".parse().unwrap(), true);
|
||||
let resolve_result = resolve_path(
|
||||
&connection,
|
||||
&"bar/baz/bax".parse().unwrap(),
|
||||
true,
|
||||
OperationContext::default(),
|
||||
);
|
||||
assert!(resolve_result.is_ok());
|
||||
|
||||
let bax_result = fetch_or_create_dir(
|
||||
|
@ -325,6 +361,7 @@ mod tests {
|
|||
Some(baz_result.clone()),
|
||||
UNode("bax".to_string()),
|
||||
false,
|
||||
OperationContext::default(),
|
||||
);
|
||||
assert!(bax_result.is_ok());
|
||||
let bax_result = bax_result.unwrap();
|
||||
|
|
|
@ -1,4 +1,4 @@
|
|||
use super::schema::{data, meta};
|
||||
use super::schema::{data, meta, users};
|
||||
use chrono::NaiveDateTime;
|
||||
use serde::Serialize;
|
||||
|
||||
|
@ -13,6 +13,7 @@ pub struct Entry {
|
|||
pub value_num: Option<f64>,
|
||||
pub immutable: bool,
|
||||
pub provenance: String,
|
||||
pub user: Option<String>,
|
||||
pub timestamp: NaiveDateTime,
|
||||
}
|
||||
|
||||
|
@ -23,3 +24,11 @@ pub struct MetaValue {
|
|||
pub key: String,
|
||||
pub value: String,
|
||||
}
|
||||
|
||||
#[derive(Queryable, Insertable, Serialize, Clone, Debug)]
|
||||
#[table_name = "users"]
|
||||
pub struct UserValue {
|
||||
pub id: i32,
|
||||
pub username: String,
|
||||
pub password: String,
|
||||
}
|
||||
|
|
|
@ -8,6 +8,7 @@ table! {
|
|||
value_num -> Nullable<Double>,
|
||||
immutable -> Bool,
|
||||
provenance -> Text,
|
||||
user -> Nullable<Text>,
|
||||
timestamp -> Timestamp,
|
||||
}
|
||||
}
|
||||
|
@ -20,4 +21,10 @@ table! {
|
|||
}
|
||||
}
|
||||
|
||||
allow_tables_to_appear_in_same_query!(data, meta,);
|
||||
table! {
|
||||
users (id) {
|
||||
id -> Integer,
|
||||
username -> Text,
|
||||
password -> Text,
|
||||
}
|
||||
}
|
||||
|
|
101
db/src/lib.rs
101
db/src/lib.rs
|
@ -26,6 +26,7 @@ use crate::inner::models;
|
|||
use crate::inner::schema::data;
|
||||
use crate::util::LoggerSink;
|
||||
use anyhow::{anyhow, Result};
|
||||
use argon2::{Argon2, PasswordHash, PasswordHasher, PasswordVerifier};
|
||||
use diesel::prelude::*;
|
||||
use diesel::r2d2::{self, ConnectionManager};
|
||||
use diesel::result::{DatabaseErrorKind, Error};
|
||||
|
@ -116,7 +117,7 @@ pub const DATABASE_FILENAME: &str = "upend.sqlite3";
|
|||
|
||||
impl UpEndDatabase {
|
||||
pub fn open<P: AsRef<Path>>(dirpath: P, reinitialize: bool) -> Result<OpenResult> {
|
||||
embed_migrations!("./migrations/upend/");
|
||||
embed_migrations!("./migrations/upend");
|
||||
|
||||
let upend_path = dirpath.as_ref().join(UPEND_SUBDIR);
|
||||
|
||||
|
@ -273,6 +274,63 @@ impl UpEndConnection {
|
|||
Ok(VaultOptions { blob_mode })
|
||||
}
|
||||
|
||||
pub fn get_users(&self) -> Result<Vec<String>> {
|
||||
use crate::inner::schema::users::dsl;
|
||||
|
||||
let _lock = self.lock.read().unwrap();
|
||||
let conn = self.pool.get()?;
|
||||
|
||||
let result = dsl::users.select(dsl::username).load::<String>(&conn)?;
|
||||
|
||||
Ok(result)
|
||||
}
|
||||
|
||||
pub fn set_user(&self, username: &str, password: &str) -> Result<bool> {
|
||||
use crate::inner::schema::users::dsl;
|
||||
|
||||
let salt = password_hash::SaltString::generate(&mut password_hash::rand_core::OsRng);
|
||||
let argon2 = Argon2::default();
|
||||
let hashed_password = argon2
|
||||
.hash_password(password.as_ref(), &salt)
|
||||
.map_err(|e| anyhow!(e))?
|
||||
.to_string();
|
||||
|
||||
let _lock = self.lock.write().unwrap();
|
||||
let conn = self.pool.get()?;
|
||||
let result = diesel::replace_into(dsl::users)
|
||||
.values((
|
||||
dsl::username.eq(username),
|
||||
dsl::password.eq(hashed_password),
|
||||
))
|
||||
.execute(&conn)?;
|
||||
Ok(result > 0)
|
||||
}
|
||||
|
||||
pub fn authenticate_user(&self, username: &str, password: &str) -> Result<()> {
|
||||
use crate::inner::schema::users::dsl;
|
||||
|
||||
let conn = self.pool.get()?;
|
||||
let user_result = dsl::users
|
||||
.filter(dsl::username.eq(username))
|
||||
.load::<models::UserValue>(&conn)?;
|
||||
|
||||
match user_result.first() {
|
||||
Some(user) => {
|
||||
let parsed_hash = PasswordHash::new(&user.password).map_err(|e| anyhow!(e))?;
|
||||
let argon2 = Argon2::default();
|
||||
argon2
|
||||
.verify_password(password.as_ref(), &parsed_hash)
|
||||
.map_err(|e| anyhow!(e))
|
||||
}
|
||||
None => {
|
||||
let argon2 = Argon2::default();
|
||||
let _ = argon2
|
||||
.verify_password(password.as_ref(), &PasswordHash::new(&DUMMY_HASH).unwrap());
|
||||
Err(anyhow!("user not found"))
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
pub fn retrieve_entry(&self, hash: &UpMultihash) -> Result<Option<Entry>> {
|
||||
use crate::inner::schema::data::dsl::*;
|
||||
|
||||
|
@ -488,6 +546,16 @@ impl UpEndConnection {
|
|||
}
|
||||
}
|
||||
|
||||
lazy_static! {
|
||||
static ref DUMMY_HASH: String = Argon2::default()
|
||||
.hash_password(
|
||||
"password".as_ref(),
|
||||
&password_hash::SaltString::generate(&mut password_hash::rand_core::OsRng)
|
||||
)
|
||||
.unwrap()
|
||||
.to_string();
|
||||
}
|
||||
|
||||
#[cfg(test)]
|
||||
mod test {
|
||||
use upend_base::constants::{ATTR_IN, ATTR_LABEL};
|
||||
|
@ -602,6 +670,22 @@ mod test {
|
|||
assert_eq!(result[0].entity, edge_entity);
|
||||
assert_eq!(result[0].value, EntryValue::Address(random_entity));
|
||||
}
|
||||
|
||||
#[test]
|
||||
fn test_users() {
|
||||
let tempdir = TempDir::new().unwrap();
|
||||
let result = UpEndDatabase::open(&tempdir, false).unwrap();
|
||||
let db = result.db;
|
||||
|
||||
let connection = db.connection().unwrap();
|
||||
|
||||
assert!(connection.authenticate_user("thm", "hunter2").is_err());
|
||||
connection.set_user("thm", "hunter2").unwrap();
|
||||
connection.authenticate_user("thm", "hunter2").unwrap();
|
||||
assert!(connection.authenticate_user("thm", "password").is_err());
|
||||
connection.set_user("thm", "password").unwrap();
|
||||
connection.authenticate_user("thm", "password").unwrap();
|
||||
}
|
||||
}
|
||||
|
||||
#[derive(Debug, Serialize, Deserialize)]
|
||||
|
@ -637,3 +721,18 @@ impl std::str::FromStr for BlobMode {
|
|||
}
|
||||
}
|
||||
}
|
||||
|
||||
#[derive(Debug, Clone)]
|
||||
pub struct OperationContext {
|
||||
pub user: Option<String>,
|
||||
pub provenance: String,
|
||||
}
|
||||
|
||||
impl Default for OperationContext {
|
||||
fn default() -> Self {
|
||||
Self {
|
||||
user: None,
|
||||
provenance: "SYSTEM".to_string(),
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
|
@ -6,6 +6,7 @@ macro_rules! upend_insert_val {
|
|||
attribute: $attribute.parse().unwrap(),
|
||||
value: upend_base::entry::EntryValue::String(String::from($value)),
|
||||
provenance: "SYSTEM INIT".to_string(),
|
||||
user: None,
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
})
|
||||
}};
|
||||
|
@ -19,6 +20,7 @@ macro_rules! upend_insert_addr {
|
|||
attribute: $attribute.parse().unwrap(),
|
||||
value: upend_base::entry::EntryValue::Address($addr.clone()),
|
||||
provenance: "SYSTEM INIT".to_string(),
|
||||
user: None,
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
})
|
||||
}};
|
||||
|
|
|
@ -5,7 +5,8 @@ use crate::hierarchies::{resolve_path, resolve_path_cached, ResolveCache, UHierP
|
|||
use crate::jobs::{JobContainer, JobHandle};
|
||||
use crate::util::hash_at_path;
|
||||
use crate::{
|
||||
BlobMode, ConnectionOptions, LoggingHandler, UpEndConnection, UpEndDatabase, UPEND_SUBDIR,
|
||||
BlobMode, ConnectionOptions, LoggingHandler, OperationContext, UpEndConnection, UpEndDatabase,
|
||||
UPEND_SUBDIR,
|
||||
};
|
||||
use anyhow::{anyhow, Result};
|
||||
use chrono::prelude::*;
|
||||
|
@ -95,6 +96,7 @@ impl FsStore {
|
|||
db: D,
|
||||
job_handle: JobHandle,
|
||||
options: UpdateOptions,
|
||||
context: OperationContext,
|
||||
) -> Result<Vec<UpdatePathOutcome>> {
|
||||
let start = Instant::now();
|
||||
info!("Vault rescan started.");
|
||||
|
@ -136,6 +138,7 @@ impl FsStore {
|
|||
|
||||
// Actual processing
|
||||
let count = RwLock::new(0_usize);
|
||||
#[allow(clippy::type_complexity)]
|
||||
let resolve_cache: Arc<Mutex<LruCache<(Option<Address>, UNode), Address>>> =
|
||||
Arc::new(Mutex::new(LruCache::new(256)));
|
||||
let total = paths.len() as f32;
|
||||
|
@ -152,6 +155,7 @@ impl FsStore {
|
|||
&existing_files,
|
||||
&resolve_cache,
|
||||
quick_check,
|
||||
context.clone(),
|
||||
);
|
||||
|
||||
let mut cnt = count.write().unwrap();
|
||||
|
@ -238,6 +242,7 @@ impl FsStore {
|
|||
Ok(all_outcomes)
|
||||
}
|
||||
|
||||
#[allow(clippy::too_many_arguments)]
|
||||
fn process_directory_entry<D: Borrow<UpEndDatabase>>(
|
||||
&self,
|
||||
db: D,
|
||||
|
@ -247,6 +252,7 @@ impl FsStore {
|
|||
existing_files: &Arc<RwLock<Vec<db::File>>>,
|
||||
resolve_cache: &Arc<Mutex<ResolveCache>>,
|
||||
quick_check: bool,
|
||||
context: OperationContext,
|
||||
) -> Result<UpdatePathOutcome> {
|
||||
trace!("Processing: {:?}", path);
|
||||
|
||||
|
@ -364,6 +370,7 @@ impl FsStore {
|
|||
size,
|
||||
mtime,
|
||||
Some(resolve_cache),
|
||||
context,
|
||||
)
|
||||
.map(|_| {
|
||||
info!("Added: {:?}", path);
|
||||
|
@ -420,6 +427,7 @@ impl FsStore {
|
|||
size: i64,
|
||||
mtime: Option<NaiveDateTime>,
|
||||
resolve_cache: Option<&Arc<Mutex<ResolveCache>>>,
|
||||
context: OperationContext,
|
||||
) -> Result<Address> {
|
||||
let normalized_path = self.normalize_path(path)?;
|
||||
let new_file = db::NewFile {
|
||||
|
@ -442,6 +450,7 @@ impl FsStore {
|
|||
value: (size as f64).into(),
|
||||
provenance: "SYSTEM INIT".to_string(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
user: context.user.clone(),
|
||||
};
|
||||
|
||||
let mime_type = tree_magic_mini::from_filepath(path).map(|s| s.to_string());
|
||||
|
@ -451,6 +460,7 @@ impl FsStore {
|
|||
value: mime_type.into(),
|
||||
provenance: "SYSTEM INIT".to_string(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
user: context.user.clone(),
|
||||
});
|
||||
|
||||
let added_entry = Entry {
|
||||
|
@ -463,6 +473,7 @@ impl FsStore {
|
|||
.into(),
|
||||
provenance: "SYSTEM INIT".to_string(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
user: context.user.clone(),
|
||||
};
|
||||
|
||||
let components = normalized_path.components().collect::<Vec<Component>>();
|
||||
|
@ -486,13 +497,16 @@ impl FsStore {
|
|||
.into(),
|
||||
provenance: "SYSTEM INIT".to_string(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
user: context.user.clone(),
|
||||
};
|
||||
let label_entry_addr = connection.insert_entry(label_entry)?;
|
||||
|
||||
if let Some(upath) = upath {
|
||||
let resolved_path = match resolve_cache {
|
||||
Some(cache) => resolve_path_cached(connection, &upath, true, cache)?,
|
||||
None => resolve_path(connection, &upath, true)?,
|
||||
Some(cache) => {
|
||||
resolve_path_cached(connection, &upath, true, context.clone(), cache)?
|
||||
}
|
||||
None => resolve_path(connection, &upath, true, context.clone())?,
|
||||
};
|
||||
let parent_dir = resolved_path.last().unwrap();
|
||||
|
||||
|
@ -502,6 +516,7 @@ impl FsStore {
|
|||
value: parent_dir.clone().into(),
|
||||
provenance: "SYSTEM INIT".to_string(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
user: context.user.clone(),
|
||||
};
|
||||
let dir_has_entry_addr = connection.insert_entry(dir_has_entry)?;
|
||||
|
||||
|
@ -511,6 +526,7 @@ impl FsStore {
|
|||
value: label_entry_addr.into(),
|
||||
provenance: "SYSTEM INIT".to_string(),
|
||||
timestamp: chrono::Utc::now().naive_utc(),
|
||||
user: context.user.clone(),
|
||||
};
|
||||
connection.insert_entry(alias_entry)?;
|
||||
}
|
||||
|
@ -649,6 +665,7 @@ impl UpStore for FsStore {
|
|||
blob: Blob,
|
||||
name_hint: Option<String>,
|
||||
blob_mode: Option<BlobMode>,
|
||||
context: OperationContext,
|
||||
) -> Result<UpMultihash, super::StoreError> {
|
||||
let file_path = blob.get_file_path();
|
||||
let hash = hash_at_path(file_path).map_err(|e| StoreError::Unknown(e.to_string()))?;
|
||||
|
@ -702,6 +719,7 @@ impl UpStore for FsStore {
|
|||
size,
|
||||
mtime,
|
||||
None,
|
||||
context,
|
||||
)
|
||||
.map_err(|e| StoreError::Unknown(e.to_string()))?;
|
||||
}
|
||||
|
@ -714,6 +732,7 @@ impl UpStore for FsStore {
|
|||
db: &UpEndDatabase,
|
||||
mut job_container: JobContainer,
|
||||
options: UpdateOptions,
|
||||
context: OperationContext,
|
||||
) -> Result<Vec<UpdatePathOutcome>, StoreError> {
|
||||
trace!(
|
||||
"Running a vault update of {:?}, options = {:?}.",
|
||||
|
@ -724,7 +743,7 @@ impl UpStore for FsStore {
|
|||
|
||||
match job_result {
|
||||
Ok(job_handle) => {
|
||||
let result = self.rescan_vault(db, job_handle, options);
|
||||
let result = self.rescan_vault(db, job_handle, options, context);
|
||||
|
||||
if let Err(err) = &result {
|
||||
error!("Update did not succeed! {:?}", err);
|
||||
|
@ -834,6 +853,7 @@ mod test {
|
|||
initial: true,
|
||||
tree_mode: BlobMode::default(),
|
||||
},
|
||||
OperationContext::default(),
|
||||
);
|
||||
assert!(rescan_result.is_ok());
|
||||
}
|
||||
|
@ -880,6 +900,7 @@ mod test {
|
|||
initial: quick,
|
||||
tree_mode: BlobMode::default(),
|
||||
},
|
||||
OperationContext::default(),
|
||||
);
|
||||
|
||||
assert!(rescan_result.is_ok());
|
||||
|
@ -900,6 +921,7 @@ mod test {
|
|||
initial: quick,
|
||||
tree_mode: BlobMode::default(),
|
||||
},
|
||||
OperationContext::default(),
|
||||
);
|
||||
|
||||
assert!(rescan_result.is_ok());
|
||||
|
@ -923,6 +945,7 @@ mod test {
|
|||
initial: quick,
|
||||
tree_mode: BlobMode::default(),
|
||||
},
|
||||
OperationContext::default(),
|
||||
);
|
||||
|
||||
assert!(rescan_result.is_ok());
|
||||
|
@ -975,6 +998,7 @@ mod test {
|
|||
initial: quick,
|
||||
tree_mode: BlobMode::default(),
|
||||
},
|
||||
OperationContext::default(),
|
||||
);
|
||||
|
||||
assert!(rescan_result.is_ok());
|
||||
|
@ -1077,6 +1101,7 @@ mod test {
|
|||
initial: true,
|
||||
tree_mode,
|
||||
},
|
||||
OperationContext::default(),
|
||||
)
|
||||
.unwrap();
|
||||
|
||||
|
@ -1087,7 +1112,7 @@ mod test {
|
|||
paths.iter().for_each(|path| {
|
||||
let upath: UHierPath = path.parse().unwrap();
|
||||
assert!(
|
||||
resolve_path(&connection, &upath, false).is_ok(),
|
||||
resolve_path(&connection, &upath, false, OperationContext::default()).is_ok(),
|
||||
"Failed: {}",
|
||||
upath
|
||||
);
|
||||
|
|
|
@ -1,6 +1,7 @@
|
|||
use std::path::{Path, PathBuf};
|
||||
|
||||
use super::{UpEndConnection, UpEndDatabase};
|
||||
use crate::OperationContext;
|
||||
use crate::{jobs::JobContainer, BlobMode};
|
||||
use upend_base::hash::UpMultihash;
|
||||
|
||||
|
@ -61,12 +62,14 @@ pub trait UpStore {
|
|||
blob: Blob,
|
||||
name_hint: Option<String>,
|
||||
blob_mode: Option<BlobMode>,
|
||||
context: OperationContext,
|
||||
) -> Result<UpMultihash>;
|
||||
fn update(
|
||||
&self,
|
||||
database: &UpEndDatabase,
|
||||
job_container: JobContainer,
|
||||
options: UpdateOptions,
|
||||
context: OperationContext,
|
||||
) -> Result<Vec<UpdatePathOutcome>>;
|
||||
fn stats(&self) -> Result<serde_json::Value>;
|
||||
}
|
||||
|
|
|
@ -1,6 +1,6 @@
|
|||
{
|
||||
"name": "@upnd/upend",
|
||||
"version": "0.4.1",
|
||||
"version": "0.5.5",
|
||||
"description": "Client library to interact with the UpEnd system.",
|
||||
"main": "dist/index.js",
|
||||
"types": "dist/index.d.ts",
|
||||
|
|
|
@ -22,6 +22,12 @@ const dbg = debug("upend:api");
|
|||
|
||||
export type { AddressComponents };
|
||||
|
||||
export type UpendApiError = {
|
||||
kind: "Unauthorized" | "HttpError" | "FetchError" | "Unknown";
|
||||
message?: string;
|
||||
error?: Error;
|
||||
};
|
||||
|
||||
export class UpEndApi {
|
||||
private instanceUrl = "";
|
||||
private readonly wasmExtensions: UpEndWasmExtensions | undefined = undefined;
|
||||
|
@ -29,15 +35,21 @@ export class UpEndApi {
|
|||
|
||||
private queryOnceLRU = new LRU<string, UpListing>({ max: 128 });
|
||||
private inFlightRequests: { [key: string]: Promise<UpListing> | null } = {};
|
||||
private key: string | undefined;
|
||||
private readonly onError: ((error: UpendApiError) => void) | undefined;
|
||||
|
||||
constructor(config: {
|
||||
constructor(config?: {
|
||||
instanceUrl?: string;
|
||||
wasmExtensions?: UpEndWasmExtensions;
|
||||
timeout?: number;
|
||||
authKey?: string;
|
||||
onError?: (error: UpendApiError) => void;
|
||||
}) {
|
||||
this.setInstanceUrl(config.instanceUrl || "http://localhost:8093");
|
||||
this.wasmExtensions = config.wasmExtensions;
|
||||
this.timeout = config.timeout || 30_000;
|
||||
this.setInstanceUrl(config?.instanceUrl || "http://localhost:8093");
|
||||
this.wasmExtensions = config?.wasmExtensions;
|
||||
this.timeout = config?.timeout || 30_000;
|
||||
this.key = config?.authKey;
|
||||
this.onError = config?.onError;
|
||||
}
|
||||
|
||||
public setInstanceUrl(apiUrl: string) {
|
||||
|
@ -53,10 +65,10 @@ export class UpEndApi {
|
|||
options?: ApiFetchOptions,
|
||||
): Promise<UpObject> {
|
||||
dbg("Fetching Entity %s", address);
|
||||
const signal = this.getAbortSignal(options);
|
||||
const entityFetch = await fetch(`${this.apiUrl}/obj/${address}`, {
|
||||
signal,
|
||||
});
|
||||
const entityFetch = await this.fetch(
|
||||
`${this.apiUrl}/obj/${address}`,
|
||||
options,
|
||||
);
|
||||
const entityResult = (await entityFetch.json()) as EntityListing;
|
||||
const entityListing = new UpListing(entityResult.entries);
|
||||
return entityListing.getObject(address);
|
||||
|
@ -64,8 +76,7 @@ export class UpEndApi {
|
|||
|
||||
public async fetchEntry(address: string, options?: ApiFetchOptions) {
|
||||
dbg("Fetching entry %s", address);
|
||||
const signal = this.getAbortSignal(options);
|
||||
const response = await fetch(`${this.apiUrl}/raw/${address}`, { signal });
|
||||
const response = await this.fetch(`${this.apiUrl}/raw/${address}`, options);
|
||||
const data = await response.json();
|
||||
const listing = new UpListing({ address: data });
|
||||
return listing.entries[0];
|
||||
|
@ -82,12 +93,10 @@ export class UpEndApi {
|
|||
if (!this.inFlightRequests[queryStr]) {
|
||||
dbg(`Querying: ${query}`);
|
||||
this.inFlightRequests[queryStr] = new Promise((resolve, reject) => {
|
||||
const signal = this.getAbortSignal(options);
|
||||
fetch(`${this.apiUrl}/query`, {
|
||||
this.fetch(`${this.apiUrl}/query`, options, {
|
||||
method: "POST",
|
||||
body: queryStr,
|
||||
keepalive: true,
|
||||
signal,
|
||||
})
|
||||
.then(async (response) => {
|
||||
if (!response.ok) {
|
||||
|
@ -117,12 +126,10 @@ export class UpEndApi {
|
|||
options?: ApiFetchOptions,
|
||||
): Promise<PutResult> {
|
||||
dbg("Putting %O", input);
|
||||
const signal = this.getAbortSignal(options);
|
||||
const response = await fetch(`${this.apiUrl}/obj`, {
|
||||
method: "PUT",
|
||||
const response = await this.fetch(`${this.apiUrl}/obj`, options, {
|
||||
headers: { "Content-Type": "application/json" },
|
||||
method: "PUT",
|
||||
body: JSON.stringify(input),
|
||||
signal,
|
||||
});
|
||||
|
||||
return await response.json();
|
||||
|
@ -141,12 +148,10 @@ export class UpEndApi {
|
|||
url += `?provenance=${provenance}`;
|
||||
}
|
||||
|
||||
const signal = this.getAbortSignal(options);
|
||||
const response = await fetch(url, {
|
||||
const response = await this.fetch(url, options, {
|
||||
method: "PUT",
|
||||
headers: { "Content-Type": "application/json" },
|
||||
body: JSON.stringify(value),
|
||||
signal,
|
||||
});
|
||||
|
||||
return await response.json();
|
||||
|
@ -203,10 +208,9 @@ export class UpEndApi {
|
|||
xhr.send(formData);
|
||||
});
|
||||
} else {
|
||||
const response = await fetch(`${this.apiUrl}/blob`, {
|
||||
const response = await this.fetch(`${this.apiUrl}/blob`, options, {
|
||||
method: "PUT",
|
||||
body: formData,
|
||||
signal,
|
||||
});
|
||||
|
||||
if (!response.ok) {
|
||||
|
@ -222,12 +226,20 @@ export class UpEndApi {
|
|||
options?: ApiFetchOptions,
|
||||
): Promise<void> {
|
||||
dbg("Deleting entry %s", address);
|
||||
const signal = this.getAbortSignal(options);
|
||||
await fetch(`${this.apiUrl}/obj/${address}`, { method: "DELETE", signal });
|
||||
await this.fetch(`${this.apiUrl}/obj/${address}`, options, {
|
||||
method: "DELETE",
|
||||
});
|
||||
}
|
||||
|
||||
public getRaw(address: Address, preview = false) {
|
||||
return `${this.apiUrl}/${preview ? "thumb" : "raw"}/${address}`;
|
||||
public getRaw(
|
||||
address: Address,
|
||||
config?: { preview?: boolean; authenticated?: boolean },
|
||||
) {
|
||||
let result = `${this.apiUrl}/${config?.preview ? "thumb" : "raw"}/${address}`;
|
||||
if (config?.authenticated) {
|
||||
result += `?auth_key=${this.key}`;
|
||||
}
|
||||
return result;
|
||||
}
|
||||
|
||||
public async fetchRaw(
|
||||
|
@ -236,26 +248,24 @@ export class UpEndApi {
|
|||
options?: ApiFetchOptions,
|
||||
) {
|
||||
dbg("Getting %s raw (preview = %s)", address, preview);
|
||||
const signal = this.getAbortSignal(options);
|
||||
return await fetch(this.getRaw(address, preview), { signal });
|
||||
return await this.fetch(this.getRaw(address, { preview }), options);
|
||||
}
|
||||
|
||||
public async refreshVault(options?: ApiFetchOptions) {
|
||||
dbg("Triggering vault refresh");
|
||||
const signal = this.getAbortSignal(options);
|
||||
return await fetch(`${this.apiUrl}/refresh`, { method: "POST", signal });
|
||||
return await this.fetch(`${this.apiUrl}/refresh`, options, {
|
||||
method: "POST",
|
||||
});
|
||||
}
|
||||
|
||||
public async nativeOpen(address: Address, options?: ApiFetchOptions) {
|
||||
dbg("Opening %s natively", address);
|
||||
const signal = this.getAbortSignal(options);
|
||||
return fetch(`${this.apiUrl}/raw/${address}?native=1`, { signal });
|
||||
return this.fetch(`${this.apiUrl}/raw/${address}?native=1`, options);
|
||||
}
|
||||
|
||||
public async fetchRoots(options?: ApiFetchOptions): Promise<ListingResult> {
|
||||
dbg("Fetching hierarchical roots...");
|
||||
const signal = this.getAbortSignal(options);
|
||||
const response = await fetch(`${this.apiUrl}/hier_roots`, { signal });
|
||||
const response = await this.fetch(`${this.apiUrl}/hier_roots`, options);
|
||||
const roots = await response.json();
|
||||
dbg("Hierarchical roots: %O", roots);
|
||||
return roots;
|
||||
|
@ -263,8 +273,7 @@ export class UpEndApi {
|
|||
|
||||
public async fetchJobs(options?: ApiFetchOptions): Promise<IJob[]> {
|
||||
// dbg("Fetching jobs...");
|
||||
const signal = this.getAbortSignal(options);
|
||||
const response = await fetch(`${this.apiUrl}/jobs`, { signal });
|
||||
const response = await this.fetch(`${this.apiUrl}/jobs`, options);
|
||||
return await response.json();
|
||||
}
|
||||
|
||||
|
@ -272,8 +281,7 @@ export class UpEndApi {
|
|||
options?: ApiFetchOptions,
|
||||
): Promise<AttributeListingResult> {
|
||||
dbg("Fetching all attributes...");
|
||||
const signal = this.getAbortSignal(options);
|
||||
const response = await fetch(`${this.apiUrl}/all/attributes`, { signal });
|
||||
const response = await this.fetch(`${this.apiUrl}/all/attributes`, options);
|
||||
const result = await response.json();
|
||||
dbg("All attributes: %O", result);
|
||||
return await result;
|
||||
|
@ -281,19 +289,25 @@ export class UpEndApi {
|
|||
|
||||
public async fetchInfo(options?: ApiFetchOptions): Promise<VaultInfo> {
|
||||
dbg("Fetching vault info...");
|
||||
const signal = this.getAbortSignal(options);
|
||||
const response = await fetch(`${this.apiUrl}/info`, { signal });
|
||||
const response = await this.fetch(`${this.apiUrl}/info`, options);
|
||||
const result = await response.json();
|
||||
dbg("Vault info: %O", result);
|
||||
return result;
|
||||
}
|
||||
|
||||
public async fetchOptions(options?: ApiFetchOptions): Promise<VaultOptions> {
|
||||
dbg("Fetching vault options...");
|
||||
const response = await this.fetch(`${this.apiUrl}/options`, options);
|
||||
const result = await response.json();
|
||||
dbg("Vault options: %O", result);
|
||||
return result;
|
||||
}
|
||||
|
||||
public async fetchStoreInfo(
|
||||
options?: ApiFetchOptions,
|
||||
): Promise<{ [key: string]: StoreInfo }> {
|
||||
dbg("Fetching store info...");
|
||||
const signal = this.getAbortSignal(options);
|
||||
const response = await fetch(`${this.apiUrl}/stats/store`, { signal });
|
||||
const response = await this.fetch(`${this.apiUrl}/stats/store`, options);
|
||||
const result = await response.json();
|
||||
dbg("Store info: %O");
|
||||
return await result;
|
||||
|
@ -309,16 +323,15 @@ export class UpEndApi {
|
|||
await this.wasmExtensions.init();
|
||||
return this.wasmExtensions.AddressTypeConstants[input];
|
||||
}
|
||||
const signal = this.getAbortSignal(options);
|
||||
response = await fetch(`${this.apiUrl}/address?type=${input}`, {
|
||||
signal,
|
||||
});
|
||||
response = await this.fetch(
|
||||
`${this.apiUrl}/address?type=${input}`,
|
||||
options,
|
||||
);
|
||||
} else {
|
||||
if ("urlContent" in input) {
|
||||
const signal = this.getAbortSignal(options);
|
||||
response = await fetch(
|
||||
response = await this.fetch(
|
||||
`${this.apiUrl}/address?url_content=${input.urlContent}`,
|
||||
{ signal },
|
||||
options,
|
||||
);
|
||||
} else {
|
||||
throw new Error("Input cannot be empty.");
|
||||
|
@ -352,8 +365,7 @@ export class UpEndApi {
|
|||
public async getVaultOptions(
|
||||
options?: ApiFetchOptions,
|
||||
): Promise<VaultOptions> {
|
||||
const signal = this.getAbortSignal(options);
|
||||
const response = await fetch(`${this.apiUrl}/options`, { signal });
|
||||
const response = await this.fetch(`${this.apiUrl}/options`, options);
|
||||
return await response.json();
|
||||
}
|
||||
|
||||
|
@ -369,12 +381,10 @@ export class UpEndApi {
|
|||
payload["blob_mode"] = blob_mode;
|
||||
}
|
||||
|
||||
const signal = this.getAbortSignal(apiOptions);
|
||||
const response = await fetch(`${this.apiUrl}/options`, {
|
||||
const response = await this.fetch(`${this.apiUrl}/options`, apiOptions, {
|
||||
method: "PUT",
|
||||
headers: { "Content-Type": "application/json" },
|
||||
body: JSON.stringify(payload),
|
||||
signal,
|
||||
});
|
||||
|
||||
if (!response.ok) {
|
||||
|
@ -382,14 +392,145 @@ export class UpEndApi {
|
|||
}
|
||||
}
|
||||
|
||||
public async authenticate(
|
||||
credentials: {
|
||||
username: string;
|
||||
password: string;
|
||||
},
|
||||
mode: "key",
|
||||
options?: ApiFetchOptions,
|
||||
): Promise<{ key: string }>;
|
||||
public async authenticate(
|
||||
credentials: {
|
||||
username: string;
|
||||
password: string;
|
||||
},
|
||||
mode?: "cookie",
|
||||
options?: ApiFetchOptions,
|
||||
): Promise<void>;
|
||||
public async authenticate(
|
||||
credentials: {
|
||||
username: string;
|
||||
password: string;
|
||||
},
|
||||
mode: "key" | "cookie" | undefined,
|
||||
options?: ApiFetchOptions,
|
||||
): Promise<{ key: string } | void> {
|
||||
const via = mode || "cookie";
|
||||
const response = await this.fetch(
|
||||
`${this.apiUrl}/auth/login?via=${via}`,
|
||||
options,
|
||||
{
|
||||
method: "POST",
|
||||
headers: { "Content-Type": "application/json" },
|
||||
body: JSON.stringify(credentials),
|
||||
},
|
||||
);
|
||||
|
||||
if (!response.ok) {
|
||||
throw Error(await response.text());
|
||||
}
|
||||
|
||||
if (mode === "key") {
|
||||
const data = await response.json();
|
||||
if (!data.key) {
|
||||
throw Error("No key returned from server.");
|
||||
}
|
||||
this.key = data.key;
|
||||
return data.key;
|
||||
}
|
||||
}
|
||||
|
||||
public async register(credentials: {
|
||||
username: string;
|
||||
password: string;
|
||||
}): Promise<void> {
|
||||
await this.fetch(`${this.apiUrl}/auth/register`, undefined, {
|
||||
method: "POST",
|
||||
headers: { "Content-Type": "application/json" },
|
||||
body: JSON.stringify(credentials),
|
||||
});
|
||||
}
|
||||
|
||||
public async authStatus(
|
||||
options?: ApiFetchOptions,
|
||||
): Promise<{ user: string } | undefined> {
|
||||
const response = await this.fetch(`${this.apiUrl}/auth/whoami`, options);
|
||||
return await response.json();
|
||||
}
|
||||
|
||||
public async resetAuth(mode: "key"): Promise<void>;
|
||||
public async resetAuth(
|
||||
mode?: "cookie",
|
||||
options?: ApiFetchOptions,
|
||||
): Promise<void>;
|
||||
public async resetAuth(
|
||||
mode?: "key" | "cookie",
|
||||
options?: ApiFetchOptions,
|
||||
): Promise<void> {
|
||||
if (mode === "key") {
|
||||
this.key = undefined;
|
||||
} else {
|
||||
await this.fetch(`${this.apiUrl}/auth/logout`, options, {
|
||||
method: "POST",
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
private getAbortSignal(options: ApiFetchOptions | undefined) {
|
||||
const controller = options?.abortController || new AbortController();
|
||||
const timeout = options?.timeout || this.timeout;
|
||||
if (timeout > 0) {
|
||||
setTimeout(() => controller.abort(), timeout);
|
||||
setTimeout(() => {
|
||||
dbg("Aborting request after %d ms", timeout);
|
||||
controller.abort();
|
||||
}, timeout);
|
||||
}
|
||||
return controller.signal;
|
||||
}
|
||||
|
||||
private async fetch(
|
||||
url: string,
|
||||
options: ApiFetchOptions | undefined,
|
||||
requestInit?: RequestInit & { headers?: Record<string, string> },
|
||||
): Promise<Response> {
|
||||
const signal = this.getAbortSignal(options);
|
||||
const headers = requestInit?.headers || {};
|
||||
if (this.key) {
|
||||
headers["Authorization"] = `Bearer ${this.key}`;
|
||||
}
|
||||
|
||||
let result: Response;
|
||||
let error: UpendApiError | undefined;
|
||||
try {
|
||||
result = await fetch(url, {
|
||||
...requestInit,
|
||||
signal,
|
||||
headers,
|
||||
});
|
||||
if (!result.ok) {
|
||||
if (result.status === 401) {
|
||||
error = { kind: "Unauthorized", message: await result.text() };
|
||||
} else {
|
||||
error = {
|
||||
kind: "HttpError",
|
||||
message: `HTTP Error ${result.status}: ${result.statusText}`,
|
||||
};
|
||||
}
|
||||
}
|
||||
} catch (e) {
|
||||
error = { kind: "FetchError", error: e as Error };
|
||||
}
|
||||
|
||||
if (error) {
|
||||
if (this.onError) {
|
||||
this.onError(error);
|
||||
}
|
||||
throw error;
|
||||
}
|
||||
|
||||
return result!;
|
||||
}
|
||||
}
|
||||
|
||||
export interface ApiFetchOptions {
|
||||
|
@ -398,6 +539,7 @@ export interface ApiFetchOptions {
|
|||
}
|
||||
|
||||
export type VaultBlobMode = "Flat" | "Mirror" | "Incoming";
|
||||
|
||||
export interface VaultOptions {
|
||||
blob_mode: VaultBlobMode;
|
||||
}
|
||||
|
|
|
@ -121,6 +121,7 @@ export class UpEntry extends UpObject implements IEntry {
|
|||
attribute: string;
|
||||
value: IValue;
|
||||
provenance: string;
|
||||
user: string;
|
||||
timestamp: string;
|
||||
|
||||
constructor(address: string, entry: IEntry, listing: UpListing) {
|
||||
|
@ -130,6 +131,7 @@ export class UpEntry extends UpObject implements IEntry {
|
|||
this.attribute = entry.attribute;
|
||||
this.value = entry.value;
|
||||
this.provenance = entry.provenance;
|
||||
this.user = entry.user;
|
||||
this.timestamp = entry.timestamp;
|
||||
}
|
||||
|
||||
|
|
|
@ -18,6 +18,8 @@ export interface IEntry {
|
|||
value: IValue;
|
||||
/** The origin or provenance of the data entry (e.g. SYSTEM or USER API...) */
|
||||
provenance: string;
|
||||
/** The user who created the data entry. */
|
||||
user: string;
|
||||
/** The timestamp when the data entry was created in RFC 3339 format. */
|
||||
timestamp: string;
|
||||
}
|
||||
|
@ -97,6 +99,7 @@ export interface VaultInfo {
|
|||
location: string;
|
||||
version: string;
|
||||
desktop: boolean;
|
||||
public: boolean;
|
||||
}
|
||||
|
||||
export interface StoreInfo {
|
||||
|
|
|
@ -5,7 +5,8 @@ module.exports = {
|
|||
'eslint:recommended',
|
||||
'plugin:@typescript-eslint/recommended',
|
||||
'plugin:svelte/recommended',
|
||||
'prettier'
|
||||
'prettier',
|
||||
'plugin:storybook/recommended'
|
||||
],
|
||||
parser: '@typescript-eslint/parser',
|
||||
plugins: ['@typescript-eslint'],
|
||||
|
|
|
@ -10,3 +10,6 @@ vite.config.js.timestamp-*
|
|||
vite.config.ts.timestamp-*
|
||||
|
||||
/static/vendor
|
||||
|
||||
# Sentry Config File
|
||||
.sentryclirc
|
||||
|
|
|
@ -0,0 +1,26 @@
|
|||
import type { StorybookConfig } from '@storybook/sveltekit';
|
||||
|
||||
const config: StorybookConfig = {
|
||||
stories: ['../src/**/*.mdx', '../src/**/*.stories.@(js|jsx|mjs|ts|tsx)'],
|
||||
addons: [
|
||||
'@storybook/addon-links',
|
||||
'@storybook/addon-essentials',
|
||||
'@storybook/addon-interactions'
|
||||
],
|
||||
framework: {
|
||||
name: '@storybook/sveltekit',
|
||||
options: {}
|
||||
},
|
||||
docs: {
|
||||
autodocs: 'tag'
|
||||
},
|
||||
viteFinal: (config) => {
|
||||
config.server!.proxy = {
|
||||
'/api': {
|
||||
target: 'http://localhost:8099/'
|
||||
}
|
||||
};
|
||||
return config;
|
||||
}
|
||||
};
|
||||
export default config;
|
|
@ -0,0 +1,16 @@
|
|||
import type { Preview } from '@storybook/svelte';
|
||||
import '../src/lib/styles/main.scss';
|
||||
|
||||
const preview: Preview = {
|
||||
parameters: {
|
||||
actions: { argTypesRegex: '^on[A-Z].*' },
|
||||
controls: {
|
||||
matchers: {
|
||||
color: /(background|color)$/i,
|
||||
date: /Date$/i
|
||||
}
|
||||
}
|
||||
}
|
||||
};
|
||||
|
||||
export default preview;
|
|
@ -10,9 +10,19 @@
|
|||
"check": "svelte-kit sync && svelte-check --tsconfig ./tsconfig.json",
|
||||
"check:watch": "svelte-kit sync && svelte-check --tsconfig ./tsconfig.json --watch",
|
||||
"lint": "prettier --check . && eslint .",
|
||||
"format": "prettier --write ."
|
||||
"format": "prettier --write .",
|
||||
"storybook": "concurrently \"npm run storybook:serve\" \"cargo run -- serve ../example_vault --clean --no-browser --reinitialize --rescan-mode mirror --bind 127.0.0.1:8099\"",
|
||||
"storybook:serve": "storybook dev -p 6006",
|
||||
"build-storybook": "storybook build"
|
||||
},
|
||||
"devDependencies": {
|
||||
"@storybook/addon-essentials": "^7.6.16",
|
||||
"@storybook/addon-interactions": "^7.6.16",
|
||||
"@storybook/addon-links": "^7.6.16",
|
||||
"@storybook/blocks": "^7.6.16",
|
||||
"@storybook/svelte": "^7.6.16",
|
||||
"@storybook/sveltekit": "^7.6.16",
|
||||
"@storybook/test": "^7.6.16",
|
||||
"@sveltejs/adapter-auto": "^3.0.0",
|
||||
"@sveltejs/kit": "^2.0.0",
|
||||
"@sveltejs/vite-plugin-svelte": "^3.0.0",
|
||||
|
@ -21,9 +31,11 @@
|
|||
"@typescript-eslint/parser": "^6.0.0",
|
||||
"eslint": "^8.56.0",
|
||||
"eslint-config-prettier": "^9.1.0",
|
||||
"eslint-plugin-storybook": "^0.8.0",
|
||||
"eslint-plugin-svelte": "^2.35.1",
|
||||
"prettier": "^3.1.1",
|
||||
"prettier-plugin-svelte": "^3.1.2",
|
||||
"storybook": "^7.6.16",
|
||||
"svelte": "^4.2.7",
|
||||
"svelte-check": "^3.6.0",
|
||||
"tslib": "^2.4.1",
|
||||
|
@ -33,6 +45,7 @@
|
|||
"dependencies": {
|
||||
"@ibm/plex": "^6.3.0",
|
||||
"@recogito/annotorious": "^2.7.11",
|
||||
"@sentry/sveltekit": "^7.109.0",
|
||||
"@sveltejs/adapter-static": "^3.0.1",
|
||||
"@types/d3": "^7.4.3",
|
||||
"@types/debug": "^4.1.12",
|
||||
|
|
6898
webui/pnpm-lock.yaml
6898
webui/pnpm-lock.yaml
File diff suppressed because it is too large
Load Diff
|
@ -0,0 +1,23 @@
|
|||
import * as Sentry from '@sentry/sveltekit';
|
||||
import { handleErrorWithSentry, replayIntegration } from '@sentry/sveltekit';
|
||||
|
||||
Sentry.init({
|
||||
dsn: 'https://9b966481f93abec5d80f1d48dd1afec1@o4506614333308928.ingest.us.sentry.io/4506614334423040',
|
||||
tracesSampleRate: 1.0,
|
||||
|
||||
// This sets the sample rate to be 10%. You may want this to be 100% while
|
||||
// in development and sample at a lower rate in production
|
||||
replaysSessionSampleRate: 0.1,
|
||||
|
||||
// If the entire session is not sampled, use the below sample rate to sample
|
||||
// sessions when an error occurs.
|
||||
replaysOnErrorSampleRate: 1.0,
|
||||
|
||||
// If you don't want to use Session Replay, just remove the line below:
|
||||
integrations: [replayIntegration(), Sentry.feedbackIntegration({ colorScheme: 'dark' })],
|
||||
|
||||
enabled: process.env.NODE_ENV !== 'development'
|
||||
});
|
||||
|
||||
// If you have a custom error handler, pass it to `handleErrorWithSentry`
|
||||
export const handleError = handleErrorWithSentry();
|
|
@ -0,0 +1,17 @@
|
|||
import { sequence } from '@sveltejs/kit/hooks';
|
||||
import * as Sentry from '@sentry/sveltekit';
|
||||
import { handleErrorWithSentry, sentryHandle } from '@sentry/sveltekit';
|
||||
|
||||
Sentry.init({
|
||||
dsn: 'https://9b966481f93abec5d80f1d48dd1afec1@o4506614333308928.ingest.us.sentry.io/4506614334423040',
|
||||
tracesSampleRate: 1.0
|
||||
|
||||
// uncomment the line below to enable Spotlight (https://spotlightjs.com)
|
||||
// spotlight: import.meta.env.DEV,
|
||||
});
|
||||
|
||||
// If you have custom handlers, make sure to place them after `sentryHandle()` in the `sequence` function.
|
||||
export const handle = sequence(sentryHandle());
|
||||
|
||||
// If you have a custom error handler, pass it to `handleErrorWithSentry`
|
||||
export const handleError = handleErrorWithSentry();
|
|
@ -1,6 +1,29 @@
|
|||
import { UpEndApi } from '@upnd/upend';
|
||||
import { UpEndWasmExtensionsWeb } from '@upnd/upend/wasm/web';
|
||||
import wasmURL from '@upnd/wasm-web/upend_wasm_bg.wasm?url';
|
||||
import { type StartStopNotifier, writable, type Writable } from 'svelte/store';
|
||||
import * as Sentry from '@sentry/sveltekit';
|
||||
|
||||
const wasm = new UpEndWasmExtensionsWeb(wasmURL);
|
||||
export default new UpEndApi({ instanceUrl: '/', wasmExtensions: wasm });
|
||||
const api = new UpEndApi({ instanceUrl: '/', wasmExtensions: wasm });
|
||||
export default api;
|
||||
|
||||
export const currentUser: Writable<string | undefined> = writable(
|
||||
undefined as string | undefined,
|
||||
((set) => {
|
||||
api.authStatus().then((result) => {
|
||||
set(result?.user);
|
||||
Sentry.setUser({ id: result?.user });
|
||||
});
|
||||
}) as StartStopNotifier<string | undefined>
|
||||
);
|
||||
|
||||
export async function login(credentials: { username: string; password: string }) {
|
||||
await api.authenticate(credentials);
|
||||
window.location.reload();
|
||||
}
|
||||
|
||||
export async function logout() {
|
||||
await api.resetAuth();
|
||||
window.location.reload();
|
||||
}
|
||||
|
|
|
@ -1,10 +1,12 @@
|
|||
<script context="module" lang="ts">
|
||||
import mitt from 'mitt';
|
||||
import type { Address } from '@upnd/upend/types';
|
||||
|
||||
export type AddEvents = {
|
||||
choose: void;
|
||||
files: File[];
|
||||
urls: string[];
|
||||
destination: Address;
|
||||
};
|
||||
export const addEmitter = mitt<AddEvents>();
|
||||
</script>
|
||||
|
@ -17,15 +19,23 @@
|
|||
import { goto } from '$app/navigation';
|
||||
import { i18n } from '$lib/i18n';
|
||||
import { selected } from '$lib/components/EntitySelect.svelte';
|
||||
import Modal from '$lib/components/layout/Modal.svelte';
|
||||
import Selector, { type SelectorValue } from '$lib/components/utils/Selector.svelte';
|
||||
import { ATTR_IN } from '@upnd/upend/constants';
|
||||
|
||||
let files: File[] = [];
|
||||
let URLs: string[] = [];
|
||||
let uploading = false;
|
||||
let abortController: AbortController | undefined;
|
||||
|
||||
let destination: Address | undefined;
|
||||
|
||||
let progress: Record<string, number> = {};
|
||||
let totalProgress: number | undefined;
|
||||
|
||||
$: visible = files.length + URLs.length > 0;
|
||||
let filesElement: HTMLDivElement;
|
||||
|
||||
$: visible = files.length + URLs.length > 0 || destination;
|
||||
|
||||
addEmitter.on('files', (ev) => {
|
||||
ev.forEach((file) => {
|
||||
|
@ -36,20 +46,52 @@
|
|||
});
|
||||
});
|
||||
|
||||
addEmitter.on('destination', (ev) => {
|
||||
destination = ev;
|
||||
});
|
||||
|
||||
function onDestinationSelected(ev: CustomEvent<SelectorValue | undefined>) {
|
||||
if (ev.detail?.t === 'Address') {
|
||||
destination = ev.detail.c;
|
||||
} else {
|
||||
destination = undefined;
|
||||
}
|
||||
}
|
||||
|
||||
async function upload() {
|
||||
uploading = true;
|
||||
|
||||
try {
|
||||
abortController = new AbortController();
|
||||
const addresses: string[] = [];
|
||||
for (const file of files) {
|
||||
for (const [idx, file] of files.entries()) {
|
||||
filesElement
|
||||
?.querySelectorAll('.entry')
|
||||
[idx]?.scrollIntoView({ behavior: 'smooth', block: 'center' });
|
||||
|
||||
const address = await api.putBlob(file, {
|
||||
abortController,
|
||||
onProgress: (p) => {
|
||||
progress[file.name] = (p.loaded / p.total) * 100;
|
||||
totalProgress = Object.values(progress).reduce((a, b) => a + b, 0) / files.length;
|
||||
},
|
||||
timeout: -1
|
||||
});
|
||||
if (destination) {
|
||||
await api.putEntry({
|
||||
entity: address,
|
||||
attribute: ATTR_IN,
|
||||
value: {
|
||||
t: 'Address',
|
||||
c: destination
|
||||
}
|
||||
});
|
||||
}
|
||||
addresses.push(address);
|
||||
|
||||
if (!uploading) {
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
if (addresses.length == 1) {
|
||||
|
@ -67,11 +109,17 @@
|
|||
}
|
||||
|
||||
function reset() {
|
||||
if (!uploading) {
|
||||
files = [];
|
||||
URLs = [];
|
||||
progress = {};
|
||||
if (uploading) {
|
||||
const msg = $i18n.t('Are you sure you want to cancel the upload?');
|
||||
if (!confirm(msg)) return;
|
||||
}
|
||||
abortController?.abort();
|
||||
|
||||
files = [];
|
||||
URLs = [];
|
||||
progress = {};
|
||||
uploading = false;
|
||||
destination = undefined;
|
||||
}
|
||||
|
||||
function onKeydown(event: KeyboardEvent) {
|
||||
|
@ -84,14 +132,21 @@
|
|||
reset();
|
||||
}
|
||||
}
|
||||
|
||||
function onBeforeUnload(ev: BeforeUnloadEvent) {
|
||||
if (files.length || uploading) {
|
||||
ev.preventDefault();
|
||||
ev.returnValue = true;
|
||||
}
|
||||
}
|
||||
</script>
|
||||
|
||||
<svelte:window on:beforeunload={onBeforeUnload} />
|
||||
<svelte:body on:keydown={onKeydown} />
|
||||
|
||||
<!-- svelte-ignore a11y-click-events-have-key-events a11y-no-static-element-interactions -->
|
||||
<div class="addmodal-container" class:visible class:uploading on:click={reset}>
|
||||
<div class="addmodal" on:click|stopPropagation>
|
||||
<div class="files">
|
||||
{#if visible}
|
||||
<Modal on:close={reset}>
|
||||
<div class="files" bind:this={filesElement}>
|
||||
{#each files as file}
|
||||
<div class="entry">
|
||||
<div class="row">
|
||||
|
@ -128,17 +183,28 @@
|
|||
{/if}
|
||||
</div>
|
||||
<div class="controls">
|
||||
<IconButton small disabled={uploading} name="upload" on:click={upload}>
|
||||
{$i18n.t('Upload')}
|
||||
</IconButton>
|
||||
<div class="controls-destination">
|
||||
<div class="label"><Icon plain name="download" /> {$i18n.t('Destination')}</div>
|
||||
<Selector
|
||||
initial={destination ? { t: 'Address', c: destination } : undefined}
|
||||
types={['Address', 'NewAddress']}
|
||||
placeholder={$i18n.t('Choose automatically') || ''}
|
||||
on:input={onDestinationSelected}
|
||||
/>
|
||||
</div>
|
||||
<div class="controls-submit">
|
||||
<IconButton small disabled={uploading} name="upload" on:click={upload}>
|
||||
{$i18n.t('Upload')}
|
||||
</IconButton>
|
||||
</div>
|
||||
</div>
|
||||
{#if uploading}
|
||||
<div class="progress">
|
||||
<ProgressBar value={totalProgress} />
|
||||
</div>
|
||||
{/if}
|
||||
</div>
|
||||
</div>
|
||||
</Modal>
|
||||
{/if}
|
||||
|
||||
<style lang="scss">
|
||||
.addmodal-container {
|
||||
|
@ -163,6 +229,8 @@
|
|||
filter: brightness(0.85);
|
||||
}
|
||||
}
|
||||
|
||||
z-index: 99;
|
||||
}
|
||||
|
||||
.addmodal {
|
||||
|
@ -232,8 +300,23 @@
|
|||
.controls {
|
||||
display: flex;
|
||||
justify-content: center;
|
||||
align-items: center;
|
||||
font-size: 3em;
|
||||
margin-top: 0.5rem;
|
||||
gap: 1rem;
|
||||
}
|
||||
|
||||
.controls-destination {
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
gap: 0.5rem;
|
||||
|
||||
font-size: 1rem;
|
||||
flex-grow: 3;
|
||||
}
|
||||
|
||||
.controls-submit {
|
||||
margin: 0 1rem;
|
||||
}
|
||||
|
||||
.progress {
|
||||
|
|
|
@ -11,7 +11,6 @@
|
|||
export let address: string | undefined = undefined;
|
||||
export let index: number;
|
||||
export let only: boolean;
|
||||
export let background: string | undefined = undefined;
|
||||
export let forceDetail = false;
|
||||
let shifted = false;
|
||||
let key = Math.random();
|
||||
|
@ -64,35 +63,13 @@
|
|||
window.addEventListener('mouseup', onMouseUp);
|
||||
}
|
||||
|
||||
let resultBackground = background;
|
||||
let imageBackground: string | undefined = undefined;
|
||||
$: {
|
||||
if (background?.startsWith('url(')) {
|
||||
imageBackground = background;
|
||||
resultBackground = 'transparent';
|
||||
} else {
|
||||
resultBackground = background;
|
||||
imageBackground = undefined;
|
||||
}
|
||||
resultBackground ||= 'var(--background-lighter)';
|
||||
}
|
||||
|
||||
function reload() {
|
||||
key = Math.random();
|
||||
}
|
||||
</script>
|
||||
|
||||
<!-- svelte-ignore a11y-no-static-element-interactions -->
|
||||
<div
|
||||
class="browse-column"
|
||||
class:detail
|
||||
style="--background: {resultBackground}"
|
||||
class:image-background={Boolean(imageBackground)}
|
||||
on:mousemove={(ev) => (shifted = ev.shiftKey)}
|
||||
>
|
||||
{#if imageBackground}
|
||||
<div class="background" style="background-image: {imageBackground}" />
|
||||
{/if}
|
||||
<div class="browse-column" class:detail on:mousemove={(ev) => (shifted = ev.shiftKey)}>
|
||||
<div class="view" style="--width: {width}px">
|
||||
<header>
|
||||
{#if address}
|
||||
|
@ -165,7 +142,7 @@
|
|||
display: flex;
|
||||
flex-direction: column;
|
||||
|
||||
background: var(--background);
|
||||
background: var(--background-lighter);
|
||||
color: var(--foreground-lighter);
|
||||
border: 1px solid var(--foreground-lightest);
|
||||
border-radius: 0.5em;
|
||||
|
|
|
@ -6,6 +6,7 @@
|
|||
import LabelBorder from './utils/LabelBorder.svelte';
|
||||
import { createEventDispatcher } from 'svelte';
|
||||
import { type Address } from '@upnd/upend/types';
|
||||
import Icon from '$lib/components/utils/Icon.svelte';
|
||||
const dispatch = createEventDispatcher<{
|
||||
highlighted: string | undefined;
|
||||
add: Address;
|
||||
|
@ -16,6 +17,7 @@
|
|||
export let hide = false;
|
||||
|
||||
export let header = '';
|
||||
export let icon: string | null = null;
|
||||
export let confirmRemoveMessage: string | null = $i18n.t('Are you sure you want to remove this?');
|
||||
export let emptyMessage = $i18n.t('Nothing to show.');
|
||||
|
||||
|
@ -24,8 +26,8 @@
|
|||
|
||||
$: if (adding && selector) selector.focus();
|
||||
|
||||
async function add(ev: CustomEvent<SelectorValue>) {
|
||||
if (ev.detail.t !== 'Address') {
|
||||
async function add(ev: CustomEvent<SelectorValue | undefined>) {
|
||||
if (ev.detail?.t !== 'Address') {
|
||||
return;
|
||||
}
|
||||
dispatch('add', ev.detail.c);
|
||||
|
@ -39,7 +41,10 @@
|
|||
</script>
|
||||
|
||||
<LabelBorder {hide}>
|
||||
<span slot="header">{header}</span>
|
||||
<span slot="header"
|
||||
>{#if icon}<Icon plain name={icon} />
|
||||
{/if}{header}</span
|
||||
>
|
||||
|
||||
{#if adding}
|
||||
<div class="selector">
|
||||
|
|
|
@ -90,14 +90,14 @@
|
|||
{#if group}
|
||||
{#if icon}
|
||||
<div class="icon">
|
||||
<Icon name={icon} />
|
||||
<Icon plain name={icon} />
|
||||
</div>
|
||||
{/if}
|
||||
<UpObject link address={group} labels={title ? [title] : undefined} />
|
||||
{:else}
|
||||
{#if icon}
|
||||
<div class="icon">
|
||||
<Icon name={icon} />
|
||||
<Icon plain name={icon} />
|
||||
</div>
|
||||
{/if}
|
||||
{title || ''}
|
||||
|
|
|
@ -22,12 +22,12 @@
|
|||
import { debug } from 'debug';
|
||||
import { Any } from '@upnd/upend/query';
|
||||
import { isDefined } from '$lib/util/werk';
|
||||
import Icon from '$lib/components/utils/Icon.svelte';
|
||||
const dbg = debug('kestrel:Inspect');
|
||||
|
||||
const dispatch = createEventDispatcher<{
|
||||
resolved: string[];
|
||||
close: void;
|
||||
background: string | undefined;
|
||||
}>();
|
||||
|
||||
export let address: string;
|
||||
|
@ -193,7 +193,7 @@
|
|||
const allAttributes = (
|
||||
await Promise.all(
|
||||
($entity?.attr[`~${ATTR_OF}`] ?? []).map(async (e) => {
|
||||
return { address: e.entity, components: await api.addressToComponents(e.entity) };
|
||||
return { address: e.address, components: await api.addressToComponents(e.entity) };
|
||||
})
|
||||
)
|
||||
)
|
||||
|
@ -393,19 +393,6 @@
|
|||
);
|
||||
}
|
||||
});
|
||||
|
||||
$: {
|
||||
const cover = $entity?.attr['COVER']?.[0];
|
||||
if (!cover) {
|
||||
dispatch('background', undefined);
|
||||
} else {
|
||||
switch (cover.value.t) {
|
||||
case 'Address':
|
||||
dispatch('background', `url('${api.getRaw(cover.value.c)}')`);
|
||||
break;
|
||||
}
|
||||
}
|
||||
}
|
||||
</script>
|
||||
|
||||
<div
|
||||
|
@ -457,6 +444,7 @@
|
|||
{#if currentUntypedProperties.length > 0}
|
||||
<EntryView
|
||||
title={$i18n.t('Other Properties') || ''}
|
||||
icon="shape-triangle"
|
||||
widgets={attributeWidgets}
|
||||
entries={currentUntypedProperties}
|
||||
on:change={onChange}
|
||||
|
@ -467,6 +455,7 @@
|
|||
{#if currentUntypedLinks.length > 0}
|
||||
<EntryView
|
||||
title={$i18n.t('Links') || ''}
|
||||
icon="right-arrow-circle"
|
||||
widgets={linkWidgets}
|
||||
entries={currentUntypedLinks}
|
||||
on:change={onChange}
|
||||
|
@ -477,6 +466,7 @@
|
|||
{#if !correctlyTagged || !incorrectlyTagged}
|
||||
<EntryView
|
||||
title={`${$i18n.t('Members')}`}
|
||||
icon="link"
|
||||
widgets={taggedWidgets}
|
||||
entries={tagged}
|
||||
on:change={onChange}
|
||||
|
@ -485,6 +475,7 @@
|
|||
{:else}
|
||||
<EntryView
|
||||
title={`${$i18n.t('Typed Members')} (${correctlyTagged.length})`}
|
||||
icon="link"
|
||||
widgets={taggedWidgets}
|
||||
entries={tagged.filter((e) => correctlyTagged?.includes(e.entity))}
|
||||
on:change={onChange}
|
||||
|
@ -492,6 +483,7 @@
|
|||
/>
|
||||
<EntryView
|
||||
title={`${$i18n.t('Untyped members')} (${incorrectlyTagged.length})`}
|
||||
icon="unlink"
|
||||
widgets={taggedWidgets}
|
||||
entries={tagged.filter((e) => incorrectlyTagged?.includes(e.entity))}
|
||||
on:change={onChange}
|
||||
|
@ -502,6 +494,7 @@
|
|||
{#if currentBacklinks.length > 0}
|
||||
<EntryView
|
||||
title={`${$i18n.t('Referred to')} (${currentBacklinks.length})`}
|
||||
icon="left-arrow-circle"
|
||||
entries={currentBacklinks}
|
||||
on:change={onChange}
|
||||
{address}
|
||||
|
@ -510,7 +503,10 @@
|
|||
|
||||
{#if $entityInfo?.t === 'Attribute'}
|
||||
<LabelBorder>
|
||||
<span slot="header">{$i18n.t('Used')} ({attributesUsed.length})</span>
|
||||
<span slot="header">
|
||||
<Icon plain name="color" />
|
||||
{$i18n.t('Used')} ({attributesUsed.length})
|
||||
</span>
|
||||
<EntryList columns="entity,value" entries={attributesUsed} orderByValue />
|
||||
</LabelBorder>
|
||||
{/if}
|
||||
|
@ -527,13 +523,13 @@
|
|||
<h2>{$i18n.t('Attributes')}</h2>
|
||||
<EntryList
|
||||
entries={$entity?.attributes || []}
|
||||
columns={detail ? 'timestamp, provenance, attribute, value' : 'attribute, value'}
|
||||
columns={detail ? 'timestamp, user, provenance, attribute, value' : 'attribute, value'}
|
||||
on:change={onChange}
|
||||
/>
|
||||
<h2>{$i18n.t('Backlinks')}</h2>
|
||||
<EntryList
|
||||
entries={$entity?.backlinks || []}
|
||||
columns={detail ? 'timestamp, provenance, entity, attribute' : 'entity, attribute'}
|
||||
columns={detail ? 'timestamp, user, provenance, entity, attribute' : 'entity, attribute'}
|
||||
on:change={onChange}
|
||||
/>
|
||||
</div>
|
||||
|
|
|
@ -39,6 +39,7 @@
|
|||
<EntitySetEditor
|
||||
entities={Object.keys(groups)}
|
||||
header={$i18n.t('Groups') || ''}
|
||||
icon="link-alt"
|
||||
hide={Object.keys(groups).length === 0}
|
||||
on:add={(e) => addGroup(e.detail)}
|
||||
on:remove={(e) => removeGroup(e.detail)}
|
||||
|
|
|
@ -10,6 +10,8 @@
|
|||
import { ATTR_OF } from '@upnd/upend/constants';
|
||||
import { createEventDispatcher } from 'svelte';
|
||||
import LabelBorder from './utils/LabelBorder.svelte';
|
||||
import Icon from '$lib/components/utils/Icon.svelte';
|
||||
|
||||
const dispatch = createEventDispatcher();
|
||||
|
||||
export let entity: Readable<UpObject | undefined>;
|
||||
|
@ -21,6 +23,7 @@
|
|||
|
||||
let types: Array<{ address: string; entry: UpEntry; required: UpEntry | undefined }> = [];
|
||||
$: updateTypes($entity?.attr[`~${ATTR_OF}`] || []);
|
||||
|
||||
async function updateTypes(entries: UpEntry[]) {
|
||||
types = [];
|
||||
const query = await api.query(
|
||||
|
@ -47,8 +50,8 @@
|
|||
});
|
||||
}
|
||||
|
||||
async function add(ev: CustomEvent<SelectorValue>) {
|
||||
if (!$entity || ev.detail.t !== 'Attribute') {
|
||||
async function add(ev: CustomEvent<SelectorValue | undefined>) {
|
||||
if (!$entity || ev.detail?.t !== 'Attribute') {
|
||||
return;
|
||||
}
|
||||
|
||||
|
@ -98,7 +101,7 @@
|
|||
|
||||
{#if types.length || $entity?.attr['~IN']?.length}
|
||||
<LabelBorder hide={types.length === 0}>
|
||||
<span slot="header">{$i18n.t('Type Attributes')}</span>
|
||||
<span slot="header"><Icon plain name="list-check" /> {$i18n.t('Type Attributes')}</span>
|
||||
{#if adding}
|
||||
<div class="selector">
|
||||
<Selector
|
||||
|
@ -122,7 +125,11 @@
|
|||
class:required={type.required}
|
||||
on:click={() => setRequired(type.entry, !type.required)}
|
||||
>
|
||||
{type.required ? $i18n.t('Required') : $i18n.t('Optional')}
|
||||
{#if type.required}
|
||||
<Icon plain name="lock" /> {$i18n.t('Required')}
|
||||
{:else}
|
||||
<Icon plain name="lock-open" /> {$i18n.t('Optional')}
|
||||
{/if}
|
||||
</button>
|
||||
<div class="controls">
|
||||
<IconButton name="x-circle" on:click={() => remove(type.entry)} />
|
||||
|
|
|
@ -0,0 +1,69 @@
|
|||
<script lang="ts">
|
||||
import { i18n } from '$lib/i18n';
|
||||
import Icon from '$lib/components/utils/Icon.svelte';
|
||||
import { login } from '$lib/api';
|
||||
import Modal from '$lib/components/layout/Modal.svelte';
|
||||
import { type UpendApiError } from '@upnd/upend/api';
|
||||
|
||||
let username = '';
|
||||
let password = '';
|
||||
let error: string | undefined;
|
||||
let authenticating = false;
|
||||
|
||||
async function submit() {
|
||||
error = undefined;
|
||||
try {
|
||||
authenticating = true;
|
||||
await login({ username, password });
|
||||
} catch (e) {
|
||||
error = (e as UpendApiError).message || (e as UpendApiError).kind;
|
||||
} finally {
|
||||
authenticating = false;
|
||||
}
|
||||
}
|
||||
</script>
|
||||
|
||||
<Modal disabled={authenticating}>
|
||||
<h2>
|
||||
<Icon name="lock" />
|
||||
{$i18n.t('Authorization required')}
|
||||
</h2>
|
||||
<form on:submit|preventDefault={submit}>
|
||||
<input
|
||||
name="username"
|
||||
placeholder={$i18n.t('Username')}
|
||||
type="text"
|
||||
bind:value={username}
|
||||
required
|
||||
/>
|
||||
<input
|
||||
name="password"
|
||||
placeholder={$i18n.t('Password')}
|
||||
type="password"
|
||||
bind:value={password}
|
||||
required
|
||||
/>
|
||||
<button type="submit"> <Icon plain name="log-in" /> {$i18n.t('Login')}</button>
|
||||
</form>
|
||||
{#if error}
|
||||
<div class="error">{error}</div>
|
||||
{/if}
|
||||
</Modal>
|
||||
|
||||
<style lang="scss">
|
||||
@use '$lib/styles/colors';
|
||||
|
||||
h2 {
|
||||
text-align: center;
|
||||
margin: 0 0 1rem 0;
|
||||
}
|
||||
|
||||
form {
|
||||
display: contents;
|
||||
}
|
||||
|
||||
.error {
|
||||
color: colors.$red;
|
||||
text-align: center;
|
||||
}
|
||||
</style>
|
|
@ -229,9 +229,9 @@
|
|||
resizeObserver.observe(viewEl as any);
|
||||
});
|
||||
|
||||
async function onSelectorInput(ev: CustomEvent<SelectorValue>) {
|
||||
async function onSelectorInput(ev: CustomEvent<SelectorValue | undefined>) {
|
||||
const value = ev.detail;
|
||||
if (value.t !== 'Address') return;
|
||||
if (value?.t !== 'Address') return;
|
||||
const address = value.c;
|
||||
|
||||
const [xValue, yValue] = selectorCoords as any;
|
||||
|
@ -261,7 +261,7 @@
|
|||
types={['Attribute', 'NewAttribute']}
|
||||
initial={x ? { t: 'Attribute', name: x } : undefined}
|
||||
on:input={(ev) => {
|
||||
if (ev.detail.t === 'Attribute') x = ev.detail.name;
|
||||
if (ev.detail?.t === 'Attribute') x = ev.detail.name;
|
||||
}}
|
||||
/>
|
||||
<div class="value">
|
||||
|
@ -277,7 +277,7 @@
|
|||
types={['Attribute', 'NewAttribute']}
|
||||
initial={y ? { t: 'Attribute', name: y } : undefined}
|
||||
on:input={(ev) => {
|
||||
if (ev.detail.t === 'Attribute') y = ev.detail.name;
|
||||
if (ev.detail?.t === 'Attribute') y = ev.detail.name;
|
||||
}}
|
||||
/>
|
||||
<div class="value">
|
||||
|
|
|
@ -1,7 +1,8 @@
|
|||
<script lang="ts">
|
||||
import type { UpEntry } from '@upnd/upend';
|
||||
import { attributeLabels } from '../../util/labels';
|
||||
import { attributeLabels } from '$lib/util/labels';
|
||||
import UpObject from './UpObject.svelte';
|
||||
import Ellipsis from '$lib/components/utils/Ellipsis.svelte';
|
||||
export let resolve = true;
|
||||
|
||||
export let entry: UpEntry;
|
||||
|
@ -12,13 +13,13 @@
|
|||
<UpObject plain link address={entry.entity} labels={resolve ? undefined : []} />
|
||||
</div>
|
||||
<div class="attribute" title={entry.attribute}>
|
||||
{$attributeLabels[entry.attribute] || entry.attribute}
|
||||
<Ellipsis value={$attributeLabels[entry.attribute] || entry.attribute} />
|
||||
</div>
|
||||
<div class="value value-{entry.value.t.toLowerCase()}">
|
||||
{#if entry.value.t === 'Address'}
|
||||
<UpObject link address={entry.value.c} labels={resolve ? undefined : []} />
|
||||
{:else}
|
||||
{entry.value.c}
|
||||
<Ellipsis value={entry.value.c?.toString() || ''} />
|
||||
{/if}
|
||||
</div>
|
||||
</div>
|
||||
|
@ -41,14 +42,22 @@
|
|||
}
|
||||
|
||||
.attribute {
|
||||
position: relative;
|
||||
top: 0.2em;
|
||||
flex-grow: 1;
|
||||
text-align: center;
|
||||
font-weight: 300;
|
||||
&::before {
|
||||
content: '→\00a0';
|
||||
}
|
||||
font-size: 0.9em;
|
||||
&::after {
|
||||
content: '\00a0→';
|
||||
|
||||
position: absolute;
|
||||
top: calc(-50% + 2px);
|
||||
left: calc(50% - 2px);
|
||||
|
||||
transform: translateX(-50%);
|
||||
font-size: 0.66em;
|
||||
font-weight: normal;
|
||||
}
|
||||
}
|
||||
|
||||
|
|
|
@ -11,7 +11,7 @@
|
|||
import { vaultInfo } from '$lib/util/info';
|
||||
import type { BrowseContext } from '$lib/util/browse';
|
||||
import { Query, type UpObject } from '@upnd/upend';
|
||||
import type { ADDRESS_TYPE, EntityInfo, IValue } from '@upnd/upend/types';
|
||||
import type { ADDRESS_TYPE, EntityInfo } from '@upnd/upend/types';
|
||||
import { useEntity } from '$lib/entity';
|
||||
import { i18n } from '$lib/i18n';
|
||||
import api from '$lib/api';
|
||||
|
@ -29,7 +29,7 @@
|
|||
export let labels: string[] | undefined = undefined;
|
||||
export let link = false;
|
||||
export let banner = false;
|
||||
export let resolve = !(labels || []).length || banner;
|
||||
export let resolve: boolean = !(labels || []).length || banner;
|
||||
export let backpath = 0;
|
||||
export let select = true;
|
||||
export let plain = false;
|
||||
|
@ -152,6 +152,22 @@
|
|||
dispatch('change', { type: 'upsert', attribute: ATTR_LABEL, value: ev.detail });
|
||||
}
|
||||
}
|
||||
|
||||
let background: string | undefined;
|
||||
$: background = $entity?.get('COVER')?.toString();
|
||||
|
||||
let resultBackground = background;
|
||||
let imageBackground: string | undefined = undefined;
|
||||
$: {
|
||||
if (background) {
|
||||
imageBackground = `url(${api.getRaw(background)})`;
|
||||
resultBackground = 'transparent';
|
||||
} else {
|
||||
resultBackground = background;
|
||||
imageBackground = undefined;
|
||||
}
|
||||
resultBackground ||= 'var(--background-lighter)';
|
||||
}
|
||||
</script>
|
||||
|
||||
<div
|
||||
|
@ -160,6 +176,8 @@
|
|||
class:right-active={address == $addresses[$index + 1]}
|
||||
class:selected={select && $selected.includes(address)}
|
||||
class:plain
|
||||
style="--background: {resultBackground}"
|
||||
class:image-background={Boolean(imageBackground)}
|
||||
>
|
||||
<div
|
||||
class="address"
|
||||
|
@ -167,27 +185,23 @@
|
|||
class:banner
|
||||
class:show-type={$entityInfo?.t === 'Url' && !addressIds.length}
|
||||
>
|
||||
{#if imageBackground}
|
||||
<div class="image-gradient"></div>
|
||||
<div class="image-background" style="background-image: {imageBackground}"></div>
|
||||
{/if}
|
||||
<HashBadge {address} />
|
||||
<div class="separator" />
|
||||
<div class="label" class:resolving title={displayLabel}>
|
||||
<Editable
|
||||
value={{ t: 'String', c: displayLabel }}
|
||||
editable={banner}
|
||||
types={['String']}
|
||||
on:edit={onLabelEdit}
|
||||
>
|
||||
<div class="label-inner">
|
||||
{#if banner && hasFile}
|
||||
<UpObjectLabel label={displayLabel} backpath={resolvedBackpath} />
|
||||
{:else if link}
|
||||
<UpLink to={{ entity: address }}>
|
||||
<UpObjectLabel label={displayLabel} backpath={resolvedBackpath} />
|
||||
</UpLink>
|
||||
{:else}
|
||||
<UpObjectLabel label={displayLabel} backpath={resolvedBackpath} />
|
||||
{/if}
|
||||
</div>
|
||||
</Editable>
|
||||
{#if banner && !link}
|
||||
<Editable value={{ t: 'String', c: displayLabel }} types={['String']} on:edit={onLabelEdit}>
|
||||
<UpObjectLabel label={displayLabel} backpath={resolvedBackpath} />
|
||||
</Editable>
|
||||
{:else if link}
|
||||
<UpLink passthrough to={{ entity: address }}>
|
||||
<UpObjectLabel label={displayLabel} backpath={resolvedBackpath} />
|
||||
</UpLink>
|
||||
{:else}
|
||||
<UpObjectLabel label={displayLabel} backpath={resolvedBackpath} />
|
||||
{/if}
|
||||
{#if $entity?.get(ATTR_KEY) && !$entity?.get(ATTR_KEY)?.toString()?.startsWith('TYPE_')}
|
||||
<div class="key">{$entity.get(ATTR_KEY)}</div>
|
||||
{/if}
|
||||
|
@ -265,6 +279,7 @@
|
|||
}
|
||||
|
||||
.address {
|
||||
position: relative;
|
||||
flex-grow: 1;
|
||||
min-width: 0;
|
||||
|
||||
|
@ -276,7 +291,7 @@
|
|||
font-family: var(--monospace-font);
|
||||
line-break: anywhere;
|
||||
|
||||
background: var(--background-lighter);
|
||||
background: var(--background);
|
||||
border: 0.1em solid var(--foreground-lighter);
|
||||
border-radius: 0.2em;
|
||||
|
||||
|
@ -292,14 +307,21 @@
|
|||
}
|
||||
|
||||
.label {
|
||||
flex-grow: 1;
|
||||
min-width: 0;
|
||||
|
||||
display: flex;
|
||||
flex-wrap: wrap;
|
||||
align-items: baseline;
|
||||
margin-left: 0.25em;
|
||||
|
||||
:global(a) {
|
||||
text-decoration: none;
|
||||
}
|
||||
}
|
||||
|
||||
.label-inner {
|
||||
max-width: 100%;
|
||||
margin-right: 0.25em;
|
||||
}
|
||||
|
||||
&.banner .label {
|
||||
|
@ -329,27 +351,37 @@
|
|||
}
|
||||
|
||||
&:not(.banner) .key {
|
||||
flex-grow: 1;
|
||||
text-align: right;
|
||||
display: inline-block;
|
||||
margin-left: 0.5em;
|
||||
}
|
||||
|
||||
&.show-type .secondary,
|
||||
&.banner .secondary {
|
||||
display: unset;
|
||||
}
|
||||
}
|
||||
|
||||
.label {
|
||||
flex-grow: 1;
|
||||
min-width: 0;
|
||||
|
||||
:global(a) {
|
||||
text-decoration: none;
|
||||
.image-gradient {
|
||||
position: absolute;
|
||||
top: 0;
|
||||
left: 0;
|
||||
right: 0;
|
||||
bottom: 0;
|
||||
background: linear-gradient(90deg, rgba(0, 0, 0, 0.66) 16%, var(--background) 66%);
|
||||
z-index: -1;
|
||||
}
|
||||
}
|
||||
|
||||
.separator {
|
||||
width: 0.5em;
|
||||
.image-background {
|
||||
position: absolute;
|
||||
top: 0;
|
||||
left: 0;
|
||||
right: 0;
|
||||
bottom: 0;
|
||||
z-index: -2;
|
||||
|
||||
background-size: cover;
|
||||
background-position: center;
|
||||
filter: brightness(0.8);
|
||||
}
|
||||
}
|
||||
|
||||
.icon {
|
||||
|
@ -361,6 +393,7 @@
|
|||
}
|
||||
|
||||
.link-button {
|
||||
padding: 0.25em;
|
||||
opacity: 0.66;
|
||||
transition:
|
||||
opacity 0.2s,
|
||||
|
|
|
@ -22,7 +22,7 @@
|
|||
</div>
|
||||
{/if}
|
||||
<div class="label">
|
||||
<UpObject {address} {labels} {banner} {select} on:resolved />
|
||||
<UpObject {address} {labels} {banner} {select} link on:resolved />
|
||||
</div>
|
||||
</div>
|
||||
</UpLink>
|
||||
|
|
|
@ -24,7 +24,8 @@
|
|||
|
||||
<style lang="scss">
|
||||
.upobject-label {
|
||||
max-width: 100%;
|
||||
flex-grow: 1;
|
||||
min-width: 0;
|
||||
}
|
||||
|
||||
.backpath {
|
||||
|
|
|
@ -2,7 +2,7 @@
|
|||
import Icon from '../utils/Icon.svelte';
|
||||
import Jobs from './Jobs.svelte';
|
||||
import Notifications from './Notifications.svelte';
|
||||
import { i18n } from '../../i18n';
|
||||
import { i18n } from '$lib/i18n';
|
||||
|
||||
let hidden = true;
|
||||
let activeJobs: number;
|
||||
|
@ -20,6 +20,8 @@
|
|||
on:keydown={(ev) => {
|
||||
if (['Space', 'Enter'].includes(ev.key)) hidden = !hidden;
|
||||
}}
|
||||
role="button"
|
||||
tabindex="-1"
|
||||
>
|
||||
<div class="info">
|
||||
{#if activeJobs > 0}
|
||||
|
@ -42,6 +44,7 @@
|
|||
position: fixed;
|
||||
bottom: 0;
|
||||
width: 100%;
|
||||
z-index: 9;
|
||||
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
|
|
|
@ -7,8 +7,11 @@
|
|||
import { i18n } from '$lib/i18n';
|
||||
import { goto } from '$app/navigation';
|
||||
import { onMount } from 'svelte';
|
||||
import { vaultInfo } from '$lib/util/info';
|
||||
import HeaderUserDropdown from '$lib/components/layout/HeaderUserDropdown.svelte';
|
||||
|
||||
let selector: Selector;
|
||||
let userDropdown = false;
|
||||
|
||||
let lastSearched: SelectorValue[] = [];
|
||||
|
||||
|
@ -25,7 +28,7 @@
|
|||
lastSearched = lastSearched.slice(0, 10);
|
||||
}
|
||||
|
||||
async function onInput(event: CustomEvent<SelectorValue>) {
|
||||
async function onInput(event: CustomEvent<SelectorValue | undefined>) {
|
||||
const value = event.detail;
|
||||
if (!value) return;
|
||||
|
||||
|
@ -57,6 +60,7 @@
|
|||
}
|
||||
|
||||
let fileInput: HTMLInputElement;
|
||||
|
||||
function onFileChange() {
|
||||
if (fileInput.files?.length) {
|
||||
addEmitter.emit('files', Array.from(fileInput.files));
|
||||
|
@ -91,13 +95,21 @@
|
|||
<Icon name="search" slot="prefix" />
|
||||
</Selector>
|
||||
</div>
|
||||
<button class="button" on:click={() => addEmitter.emit('choose')}>
|
||||
<button on:click={() => addEmitter.emit('choose')}>
|
||||
<Icon name="upload" />
|
||||
<input type="file" multiple bind:this={fileInput} on:change={onFileChange} />
|
||||
</button>
|
||||
<button class="button" on:click={() => rescan()} title="Rescan vault">
|
||||
<button on:click={() => rescan()} title="Rescan vault">
|
||||
<Icon name="refresh" />
|
||||
</button>
|
||||
<button
|
||||
class="user"
|
||||
disabled={$vaultInfo?.public}
|
||||
on:click|stopPropagation={() => (userDropdown = true)}
|
||||
>
|
||||
<Icon name="user" />
|
||||
</button>
|
||||
<HeaderUserDropdown bind:open={userDropdown} />
|
||||
</div>
|
||||
|
||||
<style lang="scss">
|
||||
|
|
|
@ -0,0 +1,140 @@
|
|||
<script lang="ts">
|
||||
import api, { currentUser, logout } from '$lib/api';
|
||||
import { type UpendApiError } from '@upnd/upend/api';
|
||||
import { i18n } from '$lib/i18n';
|
||||
import Icon from '$lib/components/utils/Icon.svelte';
|
||||
import { slide } from 'svelte/transition';
|
||||
import Modal from '$lib/components/layout/Modal.svelte';
|
||||
|
||||
export let open = false;
|
||||
|
||||
let changePasswordModal = false;
|
||||
let currentPassword = '';
|
||||
let newPassword = '';
|
||||
let newPasswordConfirm = '';
|
||||
|
||||
async function changePassword() {
|
||||
try {
|
||||
const result = await api.authenticate(
|
||||
{ username: $currentUser!, password: currentPassword },
|
||||
'key'
|
||||
);
|
||||
if (result) {
|
||||
await api.register({ username: $currentUser!, password: newPassword });
|
||||
alert($i18n.t('Password changed successfully').toString());
|
||||
changePasswordModal = false;
|
||||
}
|
||||
} catch (e: unknown) {
|
||||
alert(
|
||||
$i18n.t('Error authenticating: {error}', { error: (e as UpendApiError).message }).toString()
|
||||
);
|
||||
}
|
||||
}
|
||||
</script>
|
||||
|
||||
<svelte:body
|
||||
on:click={() => {
|
||||
open = false;
|
||||
}}
|
||||
/>
|
||||
|
||||
{#if open}
|
||||
<!-- svelte-ignore a11y-no-static-element-interactions a11y-click-events-have-key-events -->
|
||||
<div class="user-dropdown" transition:slide on:click|stopPropagation>
|
||||
<div class="user">
|
||||
<Icon plain name="user" />
|
||||
{$currentUser || '???'}
|
||||
</div>
|
||||
<button on:click={() => (changePasswordModal = true)}>
|
||||
<Icon name="lock" />{$i18n.t('Change password')}</button
|
||||
>
|
||||
<button on:click={() => logout()}> <Icon name="log-out" />{$i18n.t('Log out')}</button>
|
||||
</div>
|
||||
{/if}
|
||||
|
||||
{#if changePasswordModal}
|
||||
<Modal on:close={() => (changePasswordModal = false)}>
|
||||
<h2>
|
||||
<Icon name="lock" />
|
||||
{$i18n.t('Change password')}
|
||||
</h2>
|
||||
<form class="change-password">
|
||||
<label>
|
||||
<span>{$i18n.t('Current password')}</span>
|
||||
<input type="password" bind:value={currentPassword} required />
|
||||
</label>
|
||||
<label>
|
||||
<span>{$i18n.t('New password')}</span>
|
||||
<input type="password" bind:value={newPassword} required />
|
||||
</label>
|
||||
<label>
|
||||
<span>{$i18n.t('Confirm new password')}</span>
|
||||
<input type="password" bind:value={newPasswordConfirm} required />
|
||||
</label>
|
||||
<button
|
||||
type="submit"
|
||||
on:click={() => changePassword()}
|
||||
disabled={newPassword !== newPasswordConfirm || !newPassword}
|
||||
>{$i18n.t('Change password')}</button
|
||||
>
|
||||
</form>
|
||||
</Modal>
|
||||
{/if}
|
||||
|
||||
<style>
|
||||
.user-dropdown {
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
gap: 0.5rem;
|
||||
|
||||
background: var(--background);
|
||||
border-radius: 4px;
|
||||
border: 1px solid var(--foreground);
|
||||
padding: 0.5em;
|
||||
position: absolute;
|
||||
top: 3.5rem;
|
||||
right: 0.5rem;
|
||||
box-shadow: 0 0 0.5rem rgba(0, 0, 0, 0.5);
|
||||
z-index: 99;
|
||||
}
|
||||
|
||||
.user {
|
||||
font-weight: 500;
|
||||
margin: 0 1rem;
|
||||
}
|
||||
|
||||
button,
|
||||
.user {
|
||||
display: flex;
|
||||
align-items: center;
|
||||
gap: 0.5rem;
|
||||
}
|
||||
|
||||
h2 {
|
||||
text-align: center;
|
||||
margin: 0 0 1rem 0;
|
||||
}
|
||||
|
||||
.change-password {
|
||||
display: grid;
|
||||
grid-template-columns: 1fr 1fr;
|
||||
align-items: center;
|
||||
gap: 0.5rem 1rem;
|
||||
|
||||
& label {
|
||||
display: contents;
|
||||
|
||||
& span {
|
||||
text-align: right;
|
||||
}
|
||||
}
|
||||
|
||||
& button {
|
||||
grid-column: span 2;
|
||||
justify-content: center;
|
||||
justify-self: center;
|
||||
font-weight: 500;
|
||||
margin-top: 1rem;
|
||||
}
|
||||
}
|
||||
</style>
|
|
@ -0,0 +1,59 @@
|
|||
<script lang="ts">
|
||||
import { fade } from 'svelte/transition';
|
||||
import { createEventDispatcher } from 'svelte';
|
||||
const dispatch = createEventDispatcher();
|
||||
export let disabled = false;
|
||||
export let dismissable = true;
|
||||
|
||||
function close() {
|
||||
if (!dismissable) return;
|
||||
dispatch('close');
|
||||
}
|
||||
|
||||
function onKeydown(event: KeyboardEvent) {
|
||||
if (event.key === 'Escape') close();
|
||||
}
|
||||
</script>
|
||||
|
||||
<svelte:body on:keydown={onKeydown} />
|
||||
|
||||
<!-- svelte-ignore a11y-click-events-have-key-events a11y-no-static-element-interactions -->
|
||||
<div class="modal-container" on:click={close} transition:fade={{ duration: 200 }}>
|
||||
<div class="modal" class:disabled on:click|stopPropagation>
|
||||
<slot />
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<style>
|
||||
.modal-container {
|
||||
position: fixed;
|
||||
left: 0;
|
||||
top: 0;
|
||||
width: 100vw;
|
||||
height: 100vh;
|
||||
background: rgba(0, 0, 0, 0.66);
|
||||
|
||||
z-index: 999;
|
||||
}
|
||||
|
||||
.modal {
|
||||
position: fixed;
|
||||
left: 50%;
|
||||
top: 50%;
|
||||
transform: translate(-50%, -50%);
|
||||
background: var(--background);
|
||||
color: var(--foreground);
|
||||
border-radius: 5px;
|
||||
border: 1px solid var(--foreground);
|
||||
padding: 2rem;
|
||||
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
gap: 1rem;
|
||||
|
||||
&.disabled {
|
||||
filter: brightness(0.66);
|
||||
pointer-events: none;
|
||||
}
|
||||
}
|
||||
</style>
|
|
@ -20,7 +20,7 @@
|
|||
$: if (editing && selector) selector.focus();
|
||||
$: if (!focus && !hover) editing = false;
|
||||
|
||||
function onInput(ev: CustomEvent<SelectorValue>) {
|
||||
function onInput(ev: CustomEvent<SelectorValue | undefined>) {
|
||||
newValue = ev.detail;
|
||||
selector.focus();
|
||||
}
|
||||
|
@ -72,6 +72,10 @@
|
|||
</div>
|
||||
|
||||
<style lang="scss">
|
||||
.editable {
|
||||
max-width: 100%;
|
||||
}
|
||||
|
||||
.edit-icon {
|
||||
opacity: 0;
|
||||
transition: opacity 0.2s ease-in-out;
|
||||
|
|
|
@ -35,6 +35,7 @@
|
|||
flex-direction: column;
|
||||
align-items: center;
|
||||
|
||||
padding: 0.25em;
|
||||
border: 0;
|
||||
background: transparent;
|
||||
cursor: pointer;
|
||||
|
|
|
@ -1,4 +1,6 @@
|
|||
<script lang="ts">
|
||||
import { slide } from 'svelte/transition';
|
||||
|
||||
export let hide = false;
|
||||
let hidden = true;
|
||||
</script>
|
||||
|
@ -6,28 +8,35 @@
|
|||
<section class="labelborder" class:hide class:hidden>
|
||||
<header
|
||||
on:click={() => {
|
||||
if (hide) {
|
||||
hidden = !hidden;
|
||||
}
|
||||
if (hide) hidden = !hidden;
|
||||
}}
|
||||
on:keydown={(ev) => {
|
||||
if (['Space', 'Enter'].includes(ev.key) && hide) hidden = !hidden;
|
||||
}}
|
||||
role="button"
|
||||
tabindex="0"
|
||||
>
|
||||
<slot name="header-full">
|
||||
<h3><slot name="header" /></h3>
|
||||
<h3>
|
||||
<slot name="header" />
|
||||
</h3>
|
||||
</slot>
|
||||
</header>
|
||||
<div class="content">
|
||||
<slot />
|
||||
</div>
|
||||
{#if !hide || !hidden}
|
||||
<div class="content" transition:slide>
|
||||
<slot />
|
||||
</div>
|
||||
{:else}
|
||||
<div class="hidden-indicator" />
|
||||
{/if}
|
||||
</section>
|
||||
|
||||
<style lang="scss">
|
||||
<style>
|
||||
section.labelborder {
|
||||
margin-top: 0.66rem;
|
||||
transition: opacity 0.5s ease-in-out;
|
||||
|
||||
header {
|
||||
& header {
|
||||
display: flex;
|
||||
align-items: end;
|
||||
justify-content: space-between;
|
||||
|
@ -36,28 +45,24 @@
|
|||
padding-bottom: 0.33rem;
|
||||
margin-bottom: 0.33rem;
|
||||
|
||||
h3 {
|
||||
& h3 {
|
||||
margin: 0;
|
||||
}
|
||||
}
|
||||
|
||||
&.hide {
|
||||
header {
|
||||
& header {
|
||||
cursor: pointer;
|
||||
}
|
||||
}
|
||||
|
||||
transition: opacity 0.2s ease-in-out;
|
||||
&.hidden {
|
||||
opacity: 0.66;
|
||||
&.hide.hidden {
|
||||
opacity: 0.66;
|
||||
}
|
||||
|
||||
header {
|
||||
border-bottom-width: 0.5px;
|
||||
}
|
||||
|
||||
.content {
|
||||
display: none;
|
||||
}
|
||||
}
|
||||
& .hidden-indicator {
|
||||
border-top: 1px solid var(--foreground);
|
||||
margin-top: calc(-0.33rem + 2px);
|
||||
}
|
||||
}
|
||||
</style>
|
||||
|
|
|
@ -6,6 +6,7 @@
|
|||
import LabelBorder from './LabelBorder.svelte';
|
||||
import { i18n } from '$lib/i18n';
|
||||
import { format } from 'date-fns';
|
||||
import Icon from '$lib/components/utils/Icon.svelte';
|
||||
const dispatch = createEventDispatcher<{ change: WidgetChange }>();
|
||||
|
||||
export let address: string;
|
||||
|
@ -34,7 +35,7 @@
|
|||
</script>
|
||||
|
||||
<LabelBorder hide={!notes?.length}>
|
||||
<span slot="header">Notes</span>
|
||||
<span slot="header"><Icon plain name="note" /> {$i18n.t('Notes')}</span>
|
||||
<div class="notes" contenteditable on:input={onInput} bind:this={contentEl}>
|
||||
{#each (notes || '\n').split('\n') as line, idx}
|
||||
{#if idx > 0}<br />{/if}
|
||||
|
|
|
@ -93,7 +93,10 @@
|
|||
import debug from 'debug';
|
||||
import Spinner from './Spinner.svelte';
|
||||
|
||||
const dispatch = createEventDispatcher();
|
||||
const dispatch = createEventDispatcher<{
|
||||
input: SelectorValue | undefined;
|
||||
focus: boolean;
|
||||
}>();
|
||||
const dbg = debug('kestrel:Selector');
|
||||
let selectorEl: HTMLElement;
|
||||
|
||||
|
@ -145,6 +148,7 @@
|
|||
current = undefined;
|
||||
dispatch('input', current);
|
||||
}
|
||||
$: if (!inputValue) reset();
|
||||
|
||||
let options: SelectorOption[] = [];
|
||||
let searchResult: UpListing | undefined = undefined;
|
||||
|
|
|
@ -11,6 +11,7 @@
|
|||
import Selector, { type SelectorValue } from '../utils/Selector.svelte';
|
||||
import { createEventDispatcher } from 'svelte';
|
||||
import type { WidgetChange } from '$lib/types/base';
|
||||
import { addEmitter } from '$lib/components/AddModal.svelte';
|
||||
import debug from 'debug';
|
||||
const dispatch = createEventDispatcher();
|
||||
const dbg = debug(`kestrel:EntityList`);
|
||||
|
@ -123,7 +124,7 @@
|
|||
|
||||
$: if (adding && addSelector) addSelector.focus();
|
||||
|
||||
function addEntity(ev: CustomEvent<SelectorValue>) {
|
||||
function addEntity(ev: CustomEvent<SelectorValue | undefined>) {
|
||||
dbg('Adding entity', ev.detail);
|
||||
const addAddress = ev.detail?.t == 'Address' ? ev.detail.c : undefined;
|
||||
if (!addAddress) return;
|
||||
|
@ -166,7 +167,12 @@
|
|||
}}
|
||||
/>
|
||||
<div class="icon">
|
||||
<IconButton name="trash" color="#dc322f" on:click={() => removeEntity(entity)} />
|
||||
<IconButton
|
||||
plain
|
||||
name="trash"
|
||||
color="#dc322f"
|
||||
on:click={() => removeEntity(entity)}
|
||||
/>
|
||||
</div>
|
||||
{:else}
|
||||
<div class="object">
|
||||
|
@ -181,7 +187,12 @@
|
|||
/>
|
||||
</div>
|
||||
<div class="icon">
|
||||
<IconButton name="trash" color="#dc322f" on:click={() => removeEntity(entity)} />
|
||||
<IconButton
|
||||
plain
|
||||
name="trash"
|
||||
color="#dc322f"
|
||||
on:click={() => removeEntity(entity)}
|
||||
/>
|
||||
</div>
|
||||
{/if}
|
||||
{:else}
|
||||
|
@ -192,26 +203,39 @@
|
|||
{#if address}
|
||||
<div class="add">
|
||||
{#if adding}
|
||||
<Selector
|
||||
bind:this={addSelector}
|
||||
placeholder={$i18n.t('Search database or paste an URL') || ''}
|
||||
types={['Address', 'NewAddress']}
|
||||
on:input={addEntity}
|
||||
on:focus={(ev) => {
|
||||
if (!ev.detail) {
|
||||
adding = false;
|
||||
}
|
||||
}}
|
||||
/>
|
||||
<div class="main">
|
||||
<Selector
|
||||
bind:this={addSelector}
|
||||
placeholder={$i18n.t('Add or create an entry') || ''}
|
||||
types={['Address', 'NewAddress']}
|
||||
on:input={addEntity}
|
||||
on:focus={(ev) => {
|
||||
if (!ev.detail) {
|
||||
adding = false;
|
||||
}
|
||||
}}
|
||||
/>
|
||||
</div>
|
||||
{:else}
|
||||
<IconButton
|
||||
name="plus-circle"
|
||||
outline
|
||||
subdued
|
||||
on:click={() => {
|
||||
adding = true;
|
||||
}}
|
||||
/>
|
||||
<div class="main">
|
||||
<IconButton
|
||||
name="plus-circle"
|
||||
outline
|
||||
subdued
|
||||
on:click={() => {
|
||||
adding = true;
|
||||
}}
|
||||
/>
|
||||
</div>
|
||||
{#if address}
|
||||
<IconButton
|
||||
outline
|
||||
subdued
|
||||
name="upload"
|
||||
title={$i18n.t('Upload a file') || ''}
|
||||
on:click={() => addEmitter.emit('destination', address || '')}
|
||||
/>
|
||||
{/if}
|
||||
{/if}
|
||||
</div>
|
||||
{/if}
|
||||
|
@ -262,7 +286,9 @@
|
|||
.item {
|
||||
display: flex;
|
||||
.object {
|
||||
width: 100%;
|
||||
flex-grow: 1;
|
||||
max-width: 100%;
|
||||
min-width: 0;
|
||||
}
|
||||
|
||||
.icon {
|
||||
|
@ -298,9 +324,21 @@
|
|||
}
|
||||
}
|
||||
|
||||
.icon {
|
||||
display: flex;
|
||||
align-items: center;
|
||||
margin-left: 0.25em;
|
||||
}
|
||||
|
||||
.add {
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
gap: 0.5em;
|
||||
|
||||
& .main {
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
flex-grow: 1;
|
||||
}
|
||||
}
|
||||
|
||||
.entitylist.style-grid .add {
|
||||
|
|
|
@ -34,6 +34,7 @@
|
|||
|
||||
const TIMESTAMP_COL = 'timestamp';
|
||||
const PROVENANCE_COL = 'provenance';
|
||||
const USER_COL = 'user';
|
||||
const ENTITY_COL = 'entity';
|
||||
const ATTR_COL = 'attribute';
|
||||
const VALUE_COL = 'value';
|
||||
|
@ -56,7 +57,7 @@
|
|||
let newEntryValue: SelectorValue | undefined;
|
||||
|
||||
$: if (adding && newAttrSelector) newAttrSelector.focus();
|
||||
$: if (!addFocus && !addHover) adding = false;
|
||||
$: if (!addFocus && !addHover && !newEntryAttribute && !newEntryValue) adding = false;
|
||||
|
||||
async function addEntry(attribute: string, value: SelectorValue) {
|
||||
dispatch('change', {
|
||||
|
@ -188,6 +189,7 @@
|
|||
const COLUMN_LABELS: { [key: string]: string } = {
|
||||
timestamp: $i18n.t('Added at'),
|
||||
provenance: $i18n.t('Provenance'),
|
||||
user: $i18n.t('User'),
|
||||
entity: $i18n.t('Entity'),
|
||||
attribute: $i18n.t('Attribute'),
|
||||
value: $i18n.t('Value')
|
||||
|
@ -243,6 +245,16 @@
|
|||
</div>
|
||||
{:else if column == PROVENANCE_COL}
|
||||
<div class="cell">{entry.provenance}</div>
|
||||
{:else if column == USER_COL}
|
||||
<div class="cell">
|
||||
{#if entry.user}
|
||||
{entry.user}
|
||||
{:else}
|
||||
<div class="unset">
|
||||
{$i18n.t('unset')}
|
||||
</div>
|
||||
{/if}
|
||||
</div>
|
||||
{:else if column == ENTITY_COL}
|
||||
<div class="cell entity mark-entity">
|
||||
<UpObject
|
||||
|
@ -352,7 +364,8 @@
|
|||
<div class="cell mark-attribute">
|
||||
<Selector
|
||||
types={['Attribute', 'NewAttribute']}
|
||||
on:input={(ev) => (newEntryAttribute = ev.detail.name)}
|
||||
on:input={(ev) =>
|
||||
(newEntryAttribute = ev.detail?.t === 'Attribute' ? ev.detail?.name : '')}
|
||||
on:focus={(ev) => (addFocus = ev.detail)}
|
||||
keepFocusOnSet
|
||||
bind:this={newAttrSelector}
|
||||
|
@ -415,7 +428,7 @@
|
|||
|
||||
.attr-action {
|
||||
display: flex;
|
||||
justify-content: center;
|
||||
justify-content: end;
|
||||
align-items: center;
|
||||
}
|
||||
|
||||
|
|
|
@ -22,6 +22,7 @@ select {
|
|||
font-size: 2em;
|
||||
}
|
||||
|
||||
button,
|
||||
.button {
|
||||
border: 1px solid var(--foreground);
|
||||
border-radius: 4px;
|
||||
|
@ -52,6 +53,23 @@ select {
|
|||
}
|
||||
}
|
||||
|
||||
input[type='text'],
|
||||
input[type='password'] {
|
||||
padding: 0.25em;
|
||||
|
||||
border: 1px solid var(--foreground-lighter);
|
||||
border-radius: 4px;
|
||||
background: var(--background);
|
||||
color: var(--foreground);
|
||||
|
||||
transition: box-shadow 0.25s;
|
||||
|
||||
&:focus {
|
||||
box-shadow: -1px -1px 2px 2px var(--primary);
|
||||
outline: none;
|
||||
}
|
||||
}
|
||||
|
||||
.mark-entity::first-letter,
|
||||
.mark-entity *::first-letter {
|
||||
color: color.scale(color.mix(colors.$base1, colors.$red), $saturation: -33%);
|
||||
|
|
|
@ -1,9 +1,22 @@
|
|||
import api from '$lib/api';
|
||||
import { readable } from 'svelte/store';
|
||||
import { readable, type Readable } from 'svelte/store';
|
||||
import type { VaultInfo } from '@upnd/upend/types';
|
||||
import type { VaultOptions } from '@upnd/upend/api';
|
||||
|
||||
export const vaultInfo = readable(undefined as VaultInfo | undefined, (set) => {
|
||||
api.fetchInfo().then(async (info: VaultInfo) => {
|
||||
set(info);
|
||||
});
|
||||
});
|
||||
export const vaultInfo: Readable<VaultInfo | undefined> = readable(
|
||||
undefined as VaultInfo | undefined,
|
||||
(set) => {
|
||||
api.fetchInfo().then(async (info: VaultInfo) => {
|
||||
set(info);
|
||||
});
|
||||
}
|
||||
);
|
||||
|
||||
export const vaultOptions: Readable<VaultOptions | undefined> = readable(
|
||||
undefined as VaultOptions | undefined,
|
||||
(set) => {
|
||||
api.fetchOptions().then(async (options: VaultOptions) => {
|
||||
set(options);
|
||||
});
|
||||
}
|
||||
);
|
||||
|
|
|
@ -4,6 +4,17 @@
|
|||
import Footer from '$lib/components/layout/Footer.svelte';
|
||||
import DropPasteHandler from '$lib/components/DropPasteHandler.svelte';
|
||||
import AddModal from '$lib/components/AddModal.svelte';
|
||||
import { onMount } from 'svelte';
|
||||
import { goto } from '$app/navigation';
|
||||
import { vaultInfo, vaultOptions } from '$lib/util/info';
|
||||
import LoginModal from '$lib/components/LoginModal.svelte';
|
||||
import { currentUser } from '$lib/api';
|
||||
|
||||
onMount(() => {
|
||||
if ($vaultOptions && !$vaultOptions.blob_mode) {
|
||||
goto('/setup');
|
||||
}
|
||||
});
|
||||
</script>
|
||||
|
||||
<Header />
|
||||
|
@ -13,4 +24,7 @@
|
|||
<Footer />
|
||||
|
||||
<AddModal />
|
||||
<DropPasteHandler />>
|
||||
{#if $vaultInfo && !$vaultInfo.public && !$currentUser}
|
||||
<LoginModal />
|
||||
{/if}
|
||||
<DropPasteHandler />
|
||||
|
|
|
@ -157,14 +157,6 @@
|
|||
}
|
||||
];
|
||||
|
||||
fetch('/api/options')
|
||||
.then((res) => res.json())
|
||||
.then((options) => {
|
||||
if (!options.blob_mode) {
|
||||
goto('/setup');
|
||||
}
|
||||
});
|
||||
|
||||
$: updateTitle($vaultInfo?.name || $i18n.t('Home') || 'Home');
|
||||
</script>
|
||||
|
||||
|
|
|
@ -15,7 +15,6 @@
|
|||
let root: HTMLDivElement;
|
||||
let identities: string[] = [];
|
||||
$: addresses = $page.params.addresses.split(',');
|
||||
let backgrounds: Record<string, string | undefined> = {};
|
||||
|
||||
function add(value: SelectorValue) {
|
||||
if (value.t !== 'Address') return;
|
||||
|
@ -98,7 +97,6 @@
|
|||
{only}
|
||||
on:close={() => close(index)}
|
||||
on:detail={(ev) => onDetailChanged(index, ev)}
|
||||
background="var(--background-lightest)"
|
||||
>
|
||||
<CombineColumn spec={address} on:close={() => close(index)} />
|
||||
</BrowseColumn>
|
||||
|
@ -111,7 +109,6 @@
|
|||
close(index);
|
||||
}}
|
||||
on:detail={(ev) => onDetailChanged(index, ev)}
|
||||
background="var(--background-lightest)"
|
||||
>
|
||||
<SelectedColumn />
|
||||
</BrowseColumn>
|
||||
|
@ -148,20 +145,13 @@
|
|||
{address}
|
||||
{index}
|
||||
{only}
|
||||
background={backgrounds[address]}
|
||||
on:close={() => close(index)}
|
||||
on:resolved={(ev) => onIdentified(index, ev)}
|
||||
on:detail={(ev) => onDetailChanged(index, ev)}
|
||||
on:combine={() => addCombine(address)}
|
||||
let:detail
|
||||
>
|
||||
<Inspect
|
||||
{address}
|
||||
{detail}
|
||||
on:resolved
|
||||
on:close
|
||||
on:background={(ev) => (backgrounds[address] = ev.detail)}
|
||||
/>
|
||||
<Inspect {address} {detail} on:resolved on:close />
|
||||
</BrowseColumn>
|
||||
{/if}
|
||||
</div>
|
||||
|
|
|
@ -0,0 +1,48 @@
|
|||
import type { Meta, StoryObj } from '@storybook/svelte';
|
||||
import BlobPreview from '../lib/components/display/BlobPreview.svelte';
|
||||
import {
|
||||
audioAddress,
|
||||
imageAddress,
|
||||
imageVerticalAddress,
|
||||
stlAddress,
|
||||
videoAddress,
|
||||
videoVerticalAddress
|
||||
} from './common';
|
||||
|
||||
const meta: Meta<BlobPreview> = {
|
||||
title: 'Blobs/BlobPreview',
|
||||
component: BlobPreview,
|
||||
tags: ['autodocs'],
|
||||
argTypes: {
|
||||
onLoaded: {
|
||||
action: 'loaded'
|
||||
}
|
||||
}
|
||||
};
|
||||
|
||||
export default meta;
|
||||
type Story = StoryObj<BlobPreview>;
|
||||
|
||||
export const Image: Story = {
|
||||
args: { address: imageAddress }
|
||||
};
|
||||
|
||||
export const ImageVertical: Story = {
|
||||
args: { address: imageVerticalAddress }
|
||||
};
|
||||
|
||||
export const Audio: Story = {
|
||||
args: { address: audioAddress }
|
||||
};
|
||||
|
||||
export const Video: Story = {
|
||||
args: { address: videoAddress }
|
||||
};
|
||||
|
||||
export const VideoVertical: Story = {
|
||||
args: { address: videoVerticalAddress }
|
||||
};
|
||||
|
||||
export const Model3d: Story = {
|
||||
args: { address: stlAddress }
|
||||
};
|
|
@ -0,0 +1,50 @@
|
|||
import type { Meta, StoryObj } from '@storybook/svelte';
|
||||
import BlobViewer from '../lib/components/display/BlobViewer.svelte';
|
||||
import {
|
||||
audioAddress,
|
||||
imageAddress,
|
||||
imageVerticalAddress,
|
||||
stlAddress,
|
||||
videoAddress,
|
||||
videoVerticalAddress
|
||||
} from './common';
|
||||
|
||||
const meta: Meta<BlobViewer> = {
|
||||
title: 'Blobs/BlobViewer',
|
||||
component: BlobViewer,
|
||||
tags: ['autodocs'],
|
||||
argTypes: {
|
||||
detail: {
|
||||
control: {
|
||||
type: 'boolean'
|
||||
}
|
||||
}
|
||||
}
|
||||
};
|
||||
|
||||
export default meta;
|
||||
type Story = StoryObj<BlobViewer>;
|
||||
|
||||
export const Image: Story = {
|
||||
args: { address: imageAddress }
|
||||
};
|
||||
|
||||
export const ImageVertical: Story = {
|
||||
args: { address: imageVerticalAddress }
|
||||
};
|
||||
|
||||
export const Audio: Story = {
|
||||
args: { address: audioAddress }
|
||||
};
|
||||
|
||||
export const Video: Story = {
|
||||
args: { address: videoAddress }
|
||||
};
|
||||
|
||||
export const VideoVertical: Story = {
|
||||
args: { address: videoVerticalAddress }
|
||||
};
|
||||
|
||||
export const Model3d: Story = {
|
||||
args: { address: stlAddress }
|
||||
};
|
|
@ -0,0 +1,27 @@
|
|||
import type { Meta, StoryObj } from '@storybook/svelte';
|
||||
import EntityList from '../lib/components/widgets/EntityList.svelte';
|
||||
import { imageAddress, imageVerticalAddress, videoAddress, videoVerticalAddress } from './common';
|
||||
|
||||
const meta: Meta<EntityList> = {
|
||||
title: 'Widgets/EntityList',
|
||||
component: EntityList,
|
||||
tags: ['autodocs'],
|
||||
args: {
|
||||
entities: [imageAddress, imageVerticalAddress, videoAddress, videoVerticalAddress]
|
||||
}
|
||||
};
|
||||
|
||||
export default meta;
|
||||
type Story = StoryObj<EntityList>;
|
||||
|
||||
export const Thumbnails: Story = {
|
||||
args: {
|
||||
thumbnails: true
|
||||
}
|
||||
};
|
||||
|
||||
export const Plain: Story = {
|
||||
args: {
|
||||
thumbnails: false
|
||||
}
|
||||
};
|
|
@ -0,0 +1,11 @@
|
|||
<slot />
|
||||
|
||||
<style>
|
||||
:global(body.sb-main-fullscreen) {
|
||||
height: 100vh;
|
||||
}
|
||||
|
||||
:global(#storybook-root) {
|
||||
display: contents;
|
||||
}
|
||||
</style>
|
|
@ -0,0 +1,11 @@
|
|||
<div class="narrow">
|
||||
<slot />
|
||||
</div>
|
||||
|
||||
<style>
|
||||
.narrow {
|
||||
width: 256px;
|
||||
border: 1px dashed red;
|
||||
padding: 1em 0;
|
||||
}
|
||||
</style>
|
|
@ -0,0 +1,90 @@
|
|||
import type { Meta, StoryObj } from '@storybook/svelte';
|
||||
import Selector from '../lib/components/utils/Selector.svelte';
|
||||
import NarrowDecorator from './NarrowDecorator.svelte';
|
||||
|
||||
const meta: Meta<Selector> = {
|
||||
title: 'Widgets/Selector',
|
||||
component: Selector,
|
||||
tags: ['autodocs'],
|
||||
argTypes: {
|
||||
onInput: {
|
||||
action: 'input'
|
||||
},
|
||||
onFocus: {
|
||||
action: 'focus'
|
||||
}
|
||||
// eslint-disable-next-line @typescript-eslint/no-explicit-any
|
||||
} as any
|
||||
};
|
||||
|
||||
export default meta;
|
||||
type Story = StoryObj<Selector>;
|
||||
|
||||
export const Attribute: Story = {
|
||||
args: {
|
||||
types: ['Attribute', 'NewAttribute']
|
||||
}
|
||||
};
|
||||
|
||||
export const AttributeInitial: Story = {
|
||||
args: {
|
||||
types: ['Attribute'],
|
||||
initial: {
|
||||
t: 'Attribute',
|
||||
name: 'INITIAL_ATTR'
|
||||
}
|
||||
}
|
||||
};
|
||||
|
||||
export const AllValues: Story = {
|
||||
args: {
|
||||
types: ['Attribute', 'NewAttribute', 'Address', 'NewAddress', 'String', 'Number']
|
||||
}
|
||||
};
|
||||
|
||||
export const Entities: Story = {
|
||||
args: {
|
||||
types: ['Address', 'NewAddress']
|
||||
}
|
||||
};
|
||||
|
||||
export const ExistingEntities: Story = {
|
||||
args: {
|
||||
types: ['Address']
|
||||
}
|
||||
};
|
||||
|
||||
export const Strings: Story = {
|
||||
args: {
|
||||
types: ['String']
|
||||
}
|
||||
};
|
||||
|
||||
export const StringInitial: Story = {
|
||||
args: {
|
||||
types: ['String'],
|
||||
initial: {
|
||||
t: 'String',
|
||||
c: 'An Initial String.'
|
||||
}
|
||||
}
|
||||
};
|
||||
|
||||
export const Numbers: Story = {
|
||||
args: {
|
||||
types: ['Number']
|
||||
}
|
||||
};
|
||||
|
||||
export const MultipleValues: Story = {
|
||||
args: {
|
||||
types: ['String', 'Number']
|
||||
}
|
||||
};
|
||||
|
||||
export const Narrow: Story = {
|
||||
args: {
|
||||
types: AllValues.args!.types
|
||||
},
|
||||
decorators: [() => NarrowDecorator as any]
|
||||
};
|
|
@ -0,0 +1,47 @@
|
|||
import type { Meta, StoryObj } from '@storybook/svelte';
|
||||
import { UpEntry, UpListing } from '@upnd/upend';
|
||||
import { entryAddress, videoAddress } from './common';
|
||||
import NarrowDecorator from './NarrowDecorator.svelte';
|
||||
import UpEntryComponent from '../lib/components/display/UpEntry.svelte';
|
||||
|
||||
const entry = new UpEntry(
|
||||
entryAddress,
|
||||
{
|
||||
entity: videoAddress,
|
||||
attribute: 'ATTRIBUTE_PERHAPS_LONG',
|
||||
value: { t: 'String', c: 'This Is A Video' },
|
||||
provenance: 'MOCK',
|
||||
timestamp: new Date().toISOString()
|
||||
},
|
||||
new UpListing({})
|
||||
);
|
||||
|
||||
const meta: Meta<UpEntryComponent> = {
|
||||
title: 'Display/UpEntry',
|
||||
component: UpEntryComponent,
|
||||
tags: ['autodocs'],
|
||||
args: {
|
||||
entry
|
||||
},
|
||||
argTypes: {
|
||||
address: {
|
||||
defaultValue: entry,
|
||||
name: 'Entry'
|
||||
},
|
||||
onResolved: {
|
||||
action: 'resolved'
|
||||
}
|
||||
}
|
||||
};
|
||||
|
||||
export default meta;
|
||||
type Story = StoryObj<UpEntryComponent>;
|
||||
|
||||
export const Default: Story = {};
|
||||
|
||||
export const Overflow: Story = {
|
||||
args: {
|
||||
labels: ['qwertyuiopasdfghjklzxcvbnmqwertyuiopasdfghjklzxcvbnm'.repeat(3)]
|
||||
},
|
||||
decorators: [() => NarrowDecorator as any]
|
||||
};
|
|
@ -0,0 +1,76 @@
|
|||
import type { Meta, StoryObj } from '@storybook/svelte';
|
||||
import UpObject from '../lib/components/display/UpObject.svelte';
|
||||
import { videoAddress } from './common';
|
||||
import NarrowDecorator from './NarrowDecorator.svelte';
|
||||
|
||||
const address = videoAddress;
|
||||
|
||||
const meta: Meta<UpObject> = {
|
||||
title: 'Display/UpObject',
|
||||
component: UpObject,
|
||||
tags: ['autodocs'],
|
||||
args: {
|
||||
address
|
||||
},
|
||||
argTypes: {
|
||||
address: {
|
||||
defaultValue: address,
|
||||
name: 'Address',
|
||||
type: 'string'
|
||||
},
|
||||
onResolved: {
|
||||
action: 'resolved'
|
||||
}
|
||||
}
|
||||
};
|
||||
|
||||
export default meta;
|
||||
type Story = StoryObj<UpObject>;
|
||||
|
||||
// More on writing stories with args: https://storybook.js.org/docs/7.0/svelte/writing-stories/args
|
||||
export const Default: Story = {};
|
||||
|
||||
export const WithLabels: Story = {
|
||||
args: {
|
||||
labels: ['Label 1', 'Label B', 'Label III']
|
||||
}
|
||||
};
|
||||
|
||||
export const Link: Story = {
|
||||
args: {
|
||||
link: true
|
||||
}
|
||||
};
|
||||
|
||||
export const Keyed: Story = {
|
||||
args: {
|
||||
address: 'zb2rhmpmTFPxdhaxTQg5Ug3KHFU8DZNUPh8TaPY2v8UQVJbQk'
|
||||
}
|
||||
};
|
||||
|
||||
export const Banner: Story = {
|
||||
args: {
|
||||
banner: true
|
||||
}
|
||||
};
|
||||
|
||||
export const BannerWithLabels: Story = {
|
||||
args: {
|
||||
banner: true,
|
||||
labels: ['Label 1', 'Label B', 'Label III']
|
||||
}
|
||||
};
|
||||
|
||||
export const KeyedBanner: Story = {
|
||||
args: {
|
||||
address: 'zb2rhmpmTFPxdhaxTQg5Ug3KHFU8DZNUPh8TaPY2v8UQVJbQk',
|
||||
banner: true
|
||||
}
|
||||
};
|
||||
|
||||
export const Overflow: Story = {
|
||||
args: {
|
||||
labels: ['qwertyuiopasdfghjklzxcvbnmqwertyuiopasdfghjklzxcvbnm'.repeat(3)]
|
||||
},
|
||||
decorators: [() => NarrowDecorator as any]
|
||||
};
|
|
@ -0,0 +1,44 @@
|
|||
import type { Meta, StoryObj } from '@storybook/svelte';
|
||||
import UpObjectCard from '../lib/components/display/UpObjectCard.svelte';
|
||||
import { imageAddress } from './common';
|
||||
|
||||
const address = imageAddress;
|
||||
|
||||
const meta: Meta<UpObjectCard> = {
|
||||
title: 'Display/UpObjectCard',
|
||||
component: UpObjectCard,
|
||||
tags: ['autodocs'],
|
||||
args: {
|
||||
address
|
||||
},
|
||||
argTypes: {
|
||||
address: {
|
||||
defaultValue: address,
|
||||
name: 'Address',
|
||||
type: 'string'
|
||||
}
|
||||
}
|
||||
};
|
||||
|
||||
export default meta;
|
||||
type Story = StoryObj<UpObjectCard>;
|
||||
|
||||
export const Default: Story = {};
|
||||
|
||||
export const WithLabels: Story = {
|
||||
args: {
|
||||
labels: ['Label 1', 'Label B', 'Label III']
|
||||
}
|
||||
};
|
||||
|
||||
export const WithoutThumbnail: Story = {
|
||||
args: {
|
||||
thumbnail: false
|
||||
}
|
||||
};
|
||||
|
||||
export const Small: Story = {
|
||||
args: {
|
||||
banner: false
|
||||
}
|
||||
};
|
|
@ -0,0 +1,11 @@
|
|||
export const imageAddress = 'zb2rhYSdmX5kD5vkUErWkmTpyhGugBX8WqBuLLQdgox8ztwwx';
|
||||
export const imageVerticalAddress = 'zb2rhmTC5cXbcQ3kgXkcksWWBbR4VrzU5L3S9kbyMPCicVy9L';
|
||||
|
||||
export const audioAddress = 'zb2rhj3LpjUDtka3WuygZJGcEbgmrEyjBY6Y6ya9PVVEkbkke';
|
||||
|
||||
export const videoAddress = 'zb2rhnhv2Me2ZWohSYp7kyf1KAQbZ1zsLficHsaWTgoex67iJ';
|
||||
export const videoVerticalAddress = 'zb2rhocWjf4rc39Wi7TDv6KaVxs2iTQqN6CVYR6m7M8AYgp9c';
|
||||
|
||||
export const stlAddress = 'zb2rhbprcQL38kifW8aMW8cvgWymtaBEe6fK9n3nzDum25Paf';
|
||||
|
||||
export const entryAddress = 'zb2rhkxWUCBYuXGF4dCEDWrR48V19ujimULcSGvThknLEBrDm';
|
|
@ -10,7 +10,8 @@
|
|||
"sourceMap": true,
|
||||
"strict": true,
|
||||
"moduleResolution": "bundler"
|
||||
}
|
||||
},
|
||||
"exclude": ["node_modules", "dist", "src/stories"]
|
||||
// Path aliases are handled by https://kit.svelte.dev/docs/configuration#alias
|
||||
//
|
||||
// If you want to overwrite includes/excludes, make sure to copy over the relevant includes/excludes
|
||||
|
|
|
@ -1,9 +1,19 @@
|
|||
import { sentrySvelteKit } from '@sentry/sveltekit';
|
||||
import { sveltekit } from '@sveltejs/kit/vite';
|
||||
import { defineConfig } from 'vite';
|
||||
|
||||
// https://vitejs.dev/config/
|
||||
export default defineConfig({
|
||||
plugins: [sveltekit()],
|
||||
plugins: [
|
||||
sentrySvelteKit({
|
||||
sourceMapsUploadOptions: {
|
||||
org: 'upend',
|
||||
project: 'upend-kestrel',
|
||||
authToken: process.env.SENTRY_AUTH_TOKEN
|
||||
}
|
||||
}),
|
||||
sveltekit()
|
||||
],
|
||||
server: {
|
||||
proxy: {
|
||||
'/api': {
|
||||
|
|
Loading…
Reference in New Issue