Compare commits
No commits in common. "090cb6631efab167aea4ea4c792c68b270547f0d" and "83631251089c580eae4d3a80cdf24c99711e1bb3" have entirely different histories.
090cb6631e
...
8363125108
26 changed files with 93 additions and 1182 deletions
|
|
@ -1,31 +0,0 @@
|
||||||
{
|
|
||||||
"lexicon": 1,
|
|
||||||
"id": "my.spoor.content.defs",
|
|
||||||
"defs": {
|
|
||||||
"title": {
|
|
||||||
"type": "object",
|
|
||||||
"properties": {
|
|
||||||
"translationType": {
|
|
||||||
"type": "string",
|
|
||||||
"format": "nsid",
|
|
||||||
"knownValues": [
|
|
||||||
"my.spoor.content.defs#titleHomophonic",
|
|
||||||
"my.spoor.content.defs#titleNative",
|
|
||||||
"my.spoor.content.defs#titleTranslation"
|
|
||||||
]
|
|
||||||
},
|
|
||||||
"lang": {
|
|
||||||
"type": "string",
|
|
||||||
"format": "language"
|
|
||||||
},
|
|
||||||
"value": { "type": "string", "minLength": 1 }
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"titleHomophonic": { "type": "token",
|
|
||||||
"description": "A phonetic transcription of the native title such that when read it will sound like the native title." },
|
|
||||||
"titleNative": { "type": "token",
|
|
||||||
"description": "The title in its native script" },
|
|
||||||
"titleTranslation": { "type": "token",
|
|
||||||
"description": "A translation of the title" }
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -3,20 +3,10 @@
|
||||||
"id": "my.spoor.content.external",
|
"id": "my.spoor.content.external",
|
||||||
"defs": {
|
"defs": {
|
||||||
"main": {
|
"main": {
|
||||||
"type": "record",
|
|
||||||
"key": "nsid",
|
|
||||||
"record": {
|
|
||||||
"type": "object",
|
"type": "object",
|
||||||
"required": [ "source", "queryable" ],
|
"required": [ "source", "queryable" ],
|
||||||
|
"key": "nsid",
|
||||||
"properties": {
|
"properties": {
|
||||||
"titles": {
|
|
||||||
"type": "array",
|
|
||||||
"minLength": 1,
|
|
||||||
"items": {
|
|
||||||
"type": "ref",
|
|
||||||
"ref": "my.spoor.content.defs#title"
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"source": {
|
"source": {
|
||||||
"type": "string",
|
"type": "string",
|
||||||
"description": "An nsid for a specific data source. The domain authority governs how to process the queryable",
|
"description": "An nsid for a specific data source. The domain authority governs how to process the queryable",
|
||||||
|
|
@ -27,14 +17,12 @@
|
||||||
},
|
},
|
||||||
"queryable": {
|
"queryable": {
|
||||||
"type": "union",
|
"type": "union",
|
||||||
"description": "All the data needed to query the content from the source",
|
"description": "All the data needed to query the content from the source"
|
||||||
"refs": []
|
|
||||||
},
|
},
|
||||||
"overrides": {
|
"overrides": {
|
||||||
"type": "union",
|
"type": "object",
|
||||||
"description": "User defined overrides for the returned content",
|
"description": "User defined overrides for the returned content",
|
||||||
"refs": []
|
"properties": {}
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -3,18 +3,16 @@
|
||||||
"id": "my.spoor.content.media",
|
"id": "my.spoor.content.media",
|
||||||
"defs": {
|
"defs": {
|
||||||
"main": {
|
"main": {
|
||||||
"type": "record",
|
|
||||||
"key": "nsid",
|
|
||||||
"record": {
|
|
||||||
"type": "object",
|
"type": "object",
|
||||||
"required": [ "titles", "lastUpdated" ],
|
"key": "nsid",
|
||||||
|
"required": [ "titles", "durationData", "lastUpdated" ],
|
||||||
"properties": {
|
"properties": {
|
||||||
"titles": {
|
"titles": {
|
||||||
"type": "array",
|
"type": "array",
|
||||||
"minLength": 1,
|
"minLength": 1,
|
||||||
"items": {
|
"items": {
|
||||||
"type": "ref",
|
"type": "ref",
|
||||||
"ref": "my.spoor.content.defs#title"
|
"ref": "my.spoor.content.title"
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
"durationData": {
|
"durationData": {
|
||||||
|
|
@ -35,7 +33,6 @@
|
||||||
"description": "Client-declared timestamp for when this activity was last updated"
|
"description": "Client-declared timestamp for when this activity was last updated"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
|
||||||
},
|
},
|
||||||
"television": {
|
"television": {
|
||||||
"type": "object",
|
"type": "object",
|
||||||
|
|
|
||||||
27
lexicons/my/spoor/content/title.json
Normal file
27
lexicons/my/spoor/content/title.json
Normal file
|
|
@ -0,0 +1,27 @@
|
||||||
|
{
|
||||||
|
"lexicon": 1,
|
||||||
|
"id": "my.spoor.content.title",
|
||||||
|
"defs": {
|
||||||
|
"main": {
|
||||||
|
"type": "object",
|
||||||
|
"properties": {
|
||||||
|
"language": {
|
||||||
|
"type": "string",
|
||||||
|
"format": "nsid",
|
||||||
|
"knownValues": [
|
||||||
|
"my.spoor.content.title#romanization",
|
||||||
|
"my.spoor.content.title#english",
|
||||||
|
"my.spoor.content.title#native"
|
||||||
|
]
|
||||||
|
},
|
||||||
|
"value": { "type": "string", "minLength": 1 }
|
||||||
|
}
|
||||||
|
},
|
||||||
|
"romanization": { "type": "token",
|
||||||
|
"description": "Romanization of the native title" },
|
||||||
|
"english": { "type": "token",
|
||||||
|
"description": "English translation or title" },
|
||||||
|
"native": { "type": "token",
|
||||||
|
"description": "Native title" }
|
||||||
|
}
|
||||||
|
}
|
||||||
637
Cargo.lock → rust/Cargo.lock
generated
637
Cargo.lock → rust/Cargo.lock
generated
|
|
@ -17,18 +17,6 @@ version = "2.0.0"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "512761e0bb2578dd7380c6baaa0f4ce03e84f95e960231d1dec8bf4d7d6e2627"
|
checksum = "512761e0bb2578dd7380c6baaa0f4ce03e84f95e960231d1dec8bf4d7d6e2627"
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "ahash"
|
|
||||||
version = "0.8.11"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "e89da841a80418a9b391ebaea17f5c112ffaaa96f621d2c285b5174da76b9011"
|
|
||||||
dependencies = [
|
|
||||||
"cfg-if",
|
|
||||||
"once_cell",
|
|
||||||
"version_check",
|
|
||||||
"zerocopy 0.7.35",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "aho-corasick"
|
name = "aho-corasick"
|
||||||
version = "1.1.3"
|
version = "1.1.3"
|
||||||
|
|
@ -59,12 +47,6 @@ dependencies = [
|
||||||
"libc",
|
"libc",
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "anyhow"
|
|
||||||
version = "1.0.98"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "e16d2d3311acee920a9eb8d33b8cbc1787ce4a264e85f964c2404b969bdcd487"
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "async-lock"
|
name = "async-lock"
|
||||||
version = "3.4.0"
|
version = "3.4.0"
|
||||||
|
|
@ -76,17 +58,6 @@ dependencies = [
|
||||||
"pin-project-lite",
|
"pin-project-lite",
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "async-trait"
|
|
||||||
version = "0.1.88"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "e539d3fca749fcee5236ab05e93a52867dd549cc157c8cb7f99595f3cedffdb5"
|
|
||||||
dependencies = [
|
|
||||||
"proc-macro2",
|
|
||||||
"quote",
|
|
||||||
"syn",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "atoi"
|
name = "atoi"
|
||||||
version = "2.0.0"
|
version = "2.0.0"
|
||||||
|
|
@ -105,7 +76,7 @@ dependencies = [
|
||||||
"atrium-common",
|
"atrium-common",
|
||||||
"atrium-xrpc",
|
"atrium-xrpc",
|
||||||
"chrono",
|
"chrono",
|
||||||
"http 1.3.1",
|
"http",
|
||||||
"ipld-core",
|
"ipld-core",
|
||||||
"langtag",
|
"langtag",
|
||||||
"regex",
|
"regex",
|
||||||
|
|
@ -131,23 +102,13 @@ dependencies = [
|
||||||
"web-time",
|
"web-time",
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "atrium-lex"
|
|
||||||
version = "0.1.0"
|
|
||||||
source = "git+https://github.com/sugyan/atrium.git?rev=f162f815a04b5ecb0421b390d521c883c41d5f75#f162f815a04b5ecb0421b390d521c883c41d5f75"
|
|
||||||
dependencies = [
|
|
||||||
"serde",
|
|
||||||
"serde_repr",
|
|
||||||
"serde_with",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "atrium-xrpc"
|
name = "atrium-xrpc"
|
||||||
version = "0.12.2"
|
version = "0.12.2"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "18a9e526cb2ed3e0a2ca78c3ce2a943d9041a68e067dadf42923b523771e07df"
|
checksum = "18a9e526cb2ed3e0a2ca78c3ce2a943d9041a68e067dadf42923b523771e07df"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"http 1.3.1",
|
"http",
|
||||||
"serde",
|
"serde",
|
||||||
"serde_html_form",
|
"serde_html_form",
|
||||||
"serde_json",
|
"serde_json",
|
||||||
|
|
@ -171,7 +132,7 @@ dependencies = [
|
||||||
"bytes",
|
"bytes",
|
||||||
"form_urlencoded",
|
"form_urlencoded",
|
||||||
"futures-util",
|
"futures-util",
|
||||||
"http 1.3.1",
|
"http",
|
||||||
"http-body",
|
"http-body",
|
||||||
"http-body-util",
|
"http-body-util",
|
||||||
"hyper",
|
"hyper",
|
||||||
|
|
@ -203,7 +164,7 @@ checksum = "68464cd0412f486726fb3373129ef5d2993f90c34bc2bc1c1e9943b2f4fc7ca6"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"bytes",
|
"bytes",
|
||||||
"futures-core",
|
"futures-core",
|
||||||
"http 1.3.1",
|
"http",
|
||||||
"http-body",
|
"http-body",
|
||||||
"http-body-util",
|
"http-body-util",
|
||||||
"mime",
|
"mime",
|
||||||
|
|
@ -247,18 +208,6 @@ version = "0.2.11"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "4cbbc9d0964165b47557570cce6c952866c2678457aca742aafc9fb771d30270"
|
checksum = "4cbbc9d0964165b47557570cce6c952866c2678457aca742aafc9fb771d30270"
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "base64"
|
|
||||||
version = "0.13.1"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "9e1b586273c5702936fe7b7d6896644d8be71e6314cfe09d3167c95f712589e8"
|
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "base64"
|
|
||||||
version = "0.21.7"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "9d297deb1925b89f2ccc13d7635fa0714f12c87adce1c75356b39ca9b7178567"
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "base64"
|
name = "base64"
|
||||||
version = "0.22.1"
|
version = "0.22.1"
|
||||||
|
|
@ -289,31 +238,6 @@ dependencies = [
|
||||||
"generic-array",
|
"generic-array",
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "bon"
|
|
||||||
version = "3.6.3"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "ced38439e7a86a4761f7f7d5ded5ff009135939ecb464a24452eaa4c1696af7d"
|
|
||||||
dependencies = [
|
|
||||||
"bon-macros",
|
|
||||||
"rustversion",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "bon-macros"
|
|
||||||
version = "3.6.3"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "0ce61d2d3844c6b8d31b2353d9f66cf5e632b3e9549583fe3cac2f4f6136725e"
|
|
||||||
dependencies = [
|
|
||||||
"darling",
|
|
||||||
"ident_case",
|
|
||||||
"prettyplease",
|
|
||||||
"proc-macro2",
|
|
||||||
"quote",
|
|
||||||
"rustversion",
|
|
||||||
"syn",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "bumpalo"
|
name = "bumpalo"
|
||||||
version = "3.17.0"
|
version = "3.17.0"
|
||||||
|
|
@ -338,8 +262,6 @@ version = "1.2.20"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "04da6a0d40b948dfc4fa8f5bbf402b0fc1a64a28dbf7d12ffd683550f2c1b63a"
|
checksum = "04da6a0d40b948dfc4fa8f5bbf402b0fc1a64a28dbf7d12ffd683550f2c1b63a"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"jobserver",
|
|
||||||
"libc",
|
|
||||||
"shlex",
|
"shlex",
|
||||||
]
|
]
|
||||||
|
|
||||||
|
|
@ -393,16 +315,6 @@ version = "0.9.6"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "c2459377285ad874054d797f3ccebf984978aa39129f6eafde5cdc8315b612f8"
|
checksum = "c2459377285ad874054d797f3ccebf984978aa39129f6eafde5cdc8315b612f8"
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "core-foundation"
|
|
||||||
version = "0.9.4"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "91e195e091a93c46f7102ec7818a2aa394e1e1771c3ab4825963fa03e45afb8f"
|
|
||||||
dependencies = [
|
|
||||||
"core-foundation-sys",
|
|
||||||
"libc",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "core-foundation-sys"
|
name = "core-foundation-sys"
|
||||||
version = "0.8.7"
|
version = "0.8.7"
|
||||||
|
|
@ -485,41 +397,6 @@ dependencies = [
|
||||||
"typenum",
|
"typenum",
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "darling"
|
|
||||||
version = "0.20.11"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "fc7f46116c46ff9ab3eb1597a45688b6715c6e628b5c133e288e709a29bcb4ee"
|
|
||||||
dependencies = [
|
|
||||||
"darling_core",
|
|
||||||
"darling_macro",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "darling_core"
|
|
||||||
version = "0.20.11"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "0d00b9596d185e565c2207a0b01f8bd1a135483d02d9b7b0a54b11da8d53412e"
|
|
||||||
dependencies = [
|
|
||||||
"fnv",
|
|
||||||
"ident_case",
|
|
||||||
"proc-macro2",
|
|
||||||
"quote",
|
|
||||||
"strsim",
|
|
||||||
"syn",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "darling_macro"
|
|
||||||
version = "0.20.11"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "fc34b93ccb385b40dc71c6fceac4b2ad23662c7eeb248cf10d529b7e055b6ead"
|
|
||||||
dependencies = [
|
|
||||||
"darling_core",
|
|
||||||
"quote",
|
|
||||||
"syn",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "dashmap"
|
name = "dashmap"
|
||||||
version = "6.1.0"
|
version = "6.1.0"
|
||||||
|
|
@ -571,47 +448,6 @@ dependencies = [
|
||||||
"zeroize",
|
"zeroize",
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "deranged"
|
|
||||||
version = "0.4.0"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "9c9e6a11ca8224451684bc0d7d5a7adbf8f2fd6887261a1cfc3c0432f9d4068e"
|
|
||||||
dependencies = [
|
|
||||||
"powerfmt",
|
|
||||||
"serde",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "derive_builder"
|
|
||||||
version = "0.20.2"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "507dfb09ea8b7fa618fcf76e953f4f5e192547945816d5358edffe39f6f94947"
|
|
||||||
dependencies = [
|
|
||||||
"derive_builder_macro",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "derive_builder_core"
|
|
||||||
version = "0.20.2"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "2d5bcf7b024d6835cfb3d473887cd966994907effbe9227e8c8219824d06c4e8"
|
|
||||||
dependencies = [
|
|
||||||
"darling",
|
|
||||||
"proc-macro2",
|
|
||||||
"quote",
|
|
||||||
"syn",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "derive_builder_macro"
|
|
||||||
version = "0.20.2"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "ab63b0e2bf4d5928aff72e83a7dace85d7bba5fe12dcc3c5a572d78caffd3f3c"
|
|
||||||
dependencies = [
|
|
||||||
"derive_builder_core",
|
|
||||||
"syn",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "digest"
|
name = "digest"
|
||||||
version = "0.10.7"
|
version = "0.10.7"
|
||||||
|
|
@ -666,22 +502,6 @@ dependencies = [
|
||||||
"windows-sys 0.59.0",
|
"windows-sys 0.59.0",
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "esquema-codegen"
|
|
||||||
version = "0.1.0"
|
|
||||||
source = "git+https://github.com/fatfingers23/esquema.git?branch=main#9ef00b9d631b746bd6396fb46ba255eb9360e43f"
|
|
||||||
dependencies = [
|
|
||||||
"atrium-lex",
|
|
||||||
"heck 0.4.1",
|
|
||||||
"itertools",
|
|
||||||
"prettyplease",
|
|
||||||
"proc-macro2",
|
|
||||||
"quote",
|
|
||||||
"serde",
|
|
||||||
"serde_json",
|
|
||||||
"syn",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "etcetera"
|
name = "etcetera"
|
||||||
version = "0.8.0"
|
version = "0.8.0"
|
||||||
|
|
@ -728,7 +548,6 @@ checksum = "da0e4dd2a88388a1f4ccc7c9ce104604dab68d9f408dc34cd45823d5a9069095"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"futures-core",
|
"futures-core",
|
||||||
"futures-sink",
|
"futures-sink",
|
||||||
"nanorand",
|
|
||||||
"spin",
|
"spin",
|
||||||
]
|
]
|
||||||
|
|
||||||
|
|
@ -867,10 +686,8 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "c4567c8db10ae91089c99af84c68c38da3ec2f087c3f82960bcdbf3656b6f4d7"
|
checksum = "c4567c8db10ae91089c99af84c68c38da3ec2f087c3f82960bcdbf3656b6f4d7"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"cfg-if",
|
"cfg-if",
|
||||||
"js-sys",
|
|
||||||
"libc",
|
"libc",
|
||||||
"wasi 0.11.0+wasi-snapshot-preview1",
|
"wasi 0.11.0+wasi-snapshot-preview1",
|
||||||
"wasm-bindgen",
|
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
|
|
@ -891,12 +708,6 @@ version = "0.31.1"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "07e28edb80900c19c28f1072f2e8aeca7fa06b23cd4169cefe1af5aa3260783f"
|
checksum = "07e28edb80900c19c28f1072f2e8aeca7fa06b23cd4169cefe1af5aa3260783f"
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "hashbrown"
|
|
||||||
version = "0.12.3"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "8a9ee70c43aaf417c914396645a0fa852624801b24ebb7ae78fe8272889ac888"
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "hashbrown"
|
name = "hashbrown"
|
||||||
version = "0.14.5"
|
version = "0.14.5"
|
||||||
|
|
@ -923,12 +734,6 @@ dependencies = [
|
||||||
"hashbrown 0.15.2",
|
"hashbrown 0.15.2",
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "heck"
|
|
||||||
version = "0.4.1"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "95505c38b4572b2d910cecb0281560f54b440a19336cbbcb27bf6ce6adc6f5a8"
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "heck"
|
name = "heck"
|
||||||
version = "0.5.0"
|
version = "0.5.0"
|
||||||
|
|
@ -968,17 +773,6 @@ dependencies = [
|
||||||
"windows-sys 0.59.0",
|
"windows-sys 0.59.0",
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "http"
|
|
||||||
version = "0.2.12"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "601cbb57e577e2f5ef5be8e7b83f0f63994f25aa94d673e54a92d5c516d101f1"
|
|
||||||
dependencies = [
|
|
||||||
"bytes",
|
|
||||||
"fnv",
|
|
||||||
"itoa",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "http"
|
name = "http"
|
||||||
version = "1.3.1"
|
version = "1.3.1"
|
||||||
|
|
@ -997,7 +791,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "1efedce1fb8e6913f23e0c92de8e62cd5b772a67e7b3946df930a62566c93184"
|
checksum = "1efedce1fb8e6913f23e0c92de8e62cd5b772a67e7b3946df930a62566c93184"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"bytes",
|
"bytes",
|
||||||
"http 1.3.1",
|
"http",
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
|
|
@ -1008,7 +802,7 @@ checksum = "b021d93e26becf5dc7e1b75b1bed1fd93124b374ceb73f43d4d4eafec896a64a"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"bytes",
|
"bytes",
|
||||||
"futures-core",
|
"futures-core",
|
||||||
"http 1.3.1",
|
"http",
|
||||||
"http-body",
|
"http-body",
|
||||||
"pin-project-lite",
|
"pin-project-lite",
|
||||||
]
|
]
|
||||||
|
|
@ -1034,7 +828,7 @@ dependencies = [
|
||||||
"bytes",
|
"bytes",
|
||||||
"futures-channel",
|
"futures-channel",
|
||||||
"futures-util",
|
"futures-util",
|
||||||
"http 1.3.1",
|
"http",
|
||||||
"http-body",
|
"http-body",
|
||||||
"httparse",
|
"httparse",
|
||||||
"httpdate",
|
"httpdate",
|
||||||
|
|
@ -1052,7 +846,7 @@ checksum = "497bbc33a26fdd4af9ed9c70d63f61cf56a938375fbb32df34db9b1cd6d643f2"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"bytes",
|
"bytes",
|
||||||
"futures-util",
|
"futures-util",
|
||||||
"http 1.3.1",
|
"http",
|
||||||
"http-body",
|
"http-body",
|
||||||
"hyper",
|
"hyper",
|
||||||
"pin-project-lite",
|
"pin-project-lite",
|
||||||
|
|
@ -1202,12 +996,6 @@ dependencies = [
|
||||||
"syn",
|
"syn",
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "ident_case"
|
|
||||||
version = "1.0.1"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "b9e0384b61958566e926dc50660321d12159025e767c18e043daf26b70104c39"
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "idna"
|
name = "idna"
|
||||||
version = "1.0.3"
|
version = "1.0.3"
|
||||||
|
|
@ -1229,17 +1017,6 @@ dependencies = [
|
||||||
"icu_properties",
|
"icu_properties",
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "indexmap"
|
|
||||||
version = "1.9.3"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "bd070e393353796e801d209ad339e89596eb4c8d430d18ede6a1cced8fafbd99"
|
|
||||||
dependencies = [
|
|
||||||
"autocfg",
|
|
||||||
"hashbrown 0.12.3",
|
|
||||||
"serde",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "indexmap"
|
name = "indexmap"
|
||||||
version = "2.9.0"
|
version = "2.9.0"
|
||||||
|
|
@ -1261,31 +1038,12 @@ dependencies = [
|
||||||
"serde_bytes",
|
"serde_bytes",
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "itertools"
|
|
||||||
version = "0.10.5"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "b0fd2260e829bddf4cb6ea802289de2f86d6a7a690192fbe91b3f46e0f2c8473"
|
|
||||||
dependencies = [
|
|
||||||
"either",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "itoa"
|
name = "itoa"
|
||||||
version = "1.0.15"
|
version = "1.0.15"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "4a5f13b858c8d314ee3e8f639011f7ccefe71f97f96e50151fb991f267928e2c"
|
checksum = "4a5f13b858c8d314ee3e8f639011f7ccefe71f97f96e50151fb991f267928e2c"
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "jobserver"
|
|
||||||
version = "0.1.33"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "38f262f097c174adebe41eb73d66ae9c06b2844fb0da69969647bbddd9b0538a"
|
|
||||||
dependencies = [
|
|
||||||
"getrandom 0.3.2",
|
|
||||||
"libc",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "js-sys"
|
name = "js-sys"
|
||||||
version = "0.3.77"
|
version = "0.3.77"
|
||||||
|
|
@ -1417,16 +1175,6 @@ version = "2.7.4"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "78ca9ab1a0babb1e7d5695e3530886289c18cf2f87ec19a575a0abdce112e3a3"
|
checksum = "78ca9ab1a0babb1e7d5695e3530886289c18cf2f87ec19a575a0abdce112e3a3"
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "metrics"
|
|
||||||
version = "0.24.2"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "25dea7ac8057892855ec285c440160265225438c3c45072613c25a4b26e98ef5"
|
|
||||||
dependencies = [
|
|
||||||
"ahash",
|
|
||||||
"portable-atomic",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "mime"
|
name = "mime"
|
||||||
version = "0.3.17"
|
version = "0.3.17"
|
||||||
|
|
@ -1497,15 +1245,6 @@ dependencies = [
|
||||||
"unsigned-varint",
|
"unsigned-varint",
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "nanorand"
|
|
||||||
version = "0.7.0"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "6a51313c5820b0b02bd422f4b44776fbf47961755c74ce64afc73bfad10226c3"
|
|
||||||
dependencies = [
|
|
||||||
"getrandom 0.2.15",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "nu-ansi-term"
|
name = "nu-ansi-term"
|
||||||
version = "0.46.0"
|
version = "0.46.0"
|
||||||
|
|
@ -1533,12 +1272,6 @@ dependencies = [
|
||||||
"zeroize",
|
"zeroize",
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "num-conv"
|
|
||||||
version = "0.1.0"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "51d515d32fb182ee37cda2ccdcb92950d6a3c2893aa280e540671c2cd0f3b1d9"
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "num-integer"
|
name = "num-integer"
|
||||||
version = "0.1.46"
|
version = "0.1.46"
|
||||||
|
|
@ -1584,12 +1317,6 @@ version = "1.21.3"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "42f5e15c9953c5e4ccceeb2e7382a716482c34515315f7b03532b8b4e8393d2d"
|
checksum = "42f5e15c9953c5e4ccceeb2e7382a716482c34515315f7b03532b8b4e8393d2d"
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "openssl-probe"
|
|
||||||
version = "0.1.6"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "d05e27ee213611ffe7d6348b942e8f942b37114c00cc03cec254295a4a17852e"
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "overload"
|
name = "overload"
|
||||||
version = "0.1.1"
|
version = "0.1.1"
|
||||||
|
|
@ -1685,29 +1412,13 @@ version = "1.11.0"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "350e9b48cbc6b0e028b0473b114454c6316e57336ee184ceab6e53f72c178b3e"
|
checksum = "350e9b48cbc6b0e028b0473b114454c6316e57336ee184ceab6e53f72c178b3e"
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "powerfmt"
|
|
||||||
version = "0.2.0"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "439ee305def115ba05938db6eb1644ff94165c5ab5e9420d1c1bcedbba909391"
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "ppv-lite86"
|
name = "ppv-lite86"
|
||||||
version = "0.2.21"
|
version = "0.2.21"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "85eae3c4ed2f50dcfe72643da4befc30deadb458a9b590d720cde2f2b1e97da9"
|
checksum = "85eae3c4ed2f50dcfe72643da4befc30deadb458a9b590d720cde2f2b1e97da9"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"zerocopy 0.8.24",
|
"zerocopy",
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "prettyplease"
|
|
||||||
version = "0.2.32"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "664ec5419c51e34154eec046ebcba56312d5a2fc3b09a06da188e1ad21afadf6"
|
|
||||||
dependencies = [
|
|
||||||
"proc-macro2",
|
|
||||||
"syn",
|
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
|
|
@ -1817,44 +1528,6 @@ version = "0.8.5"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "2b15c43186be67a4fd63bee50d0303afffcef381492ebe2c5d87f324e1b8815c"
|
checksum = "2b15c43186be67a4fd63bee50d0303afffcef381492ebe2c5d87f324e1b8815c"
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "ring"
|
|
||||||
version = "0.17.14"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "a4689e6c2294d81e88dc6261c768b63bc4fcdb852be6d1352498b114f61383b7"
|
|
||||||
dependencies = [
|
|
||||||
"cc",
|
|
||||||
"cfg-if",
|
|
||||||
"getrandom 0.2.15",
|
|
||||||
"libc",
|
|
||||||
"untrusted",
|
|
||||||
"windows-sys 0.52.0",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "rocketman"
|
|
||||||
version = "0.2.0"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "4a3aae946adbfdcf80cad8793e02d8eb94be06c925331aa56aeb446795893361"
|
|
||||||
dependencies = [
|
|
||||||
"anyhow",
|
|
||||||
"async-trait",
|
|
||||||
"bon",
|
|
||||||
"derive_builder",
|
|
||||||
"flume",
|
|
||||||
"futures-util",
|
|
||||||
"metrics",
|
|
||||||
"rand",
|
|
||||||
"serde",
|
|
||||||
"serde_json",
|
|
||||||
"tokio",
|
|
||||||
"tokio-tungstenite",
|
|
||||||
"tracing",
|
|
||||||
"tracing-subscriber",
|
|
||||||
"url",
|
|
||||||
"zstd",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "rsa"
|
name = "rsa"
|
||||||
version = "0.9.8"
|
version = "0.9.8"
|
||||||
|
|
@ -1882,10 +1555,7 @@ dependencies = [
|
||||||
"atrium-api",
|
"atrium-api",
|
||||||
"axum",
|
"axum",
|
||||||
"axum-macros",
|
"axum-macros",
|
||||||
"esquema-codegen",
|
"http",
|
||||||
"http 1.3.1",
|
|
||||||
"regex",
|
|
||||||
"rocketman",
|
|
||||||
"serde",
|
"serde",
|
||||||
"serde_json",
|
"serde_json",
|
||||||
"sqlx",
|
"sqlx",
|
||||||
|
|
@ -1920,49 +1590,6 @@ dependencies = [
|
||||||
"windows-sys 0.59.0",
|
"windows-sys 0.59.0",
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "rustls"
|
|
||||||
version = "0.21.12"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "3f56a14d1f48b391359b22f731fd4bd7e43c97f3c50eee276f3aa09c94784d3e"
|
|
||||||
dependencies = [
|
|
||||||
"log",
|
|
||||||
"ring",
|
|
||||||
"rustls-webpki",
|
|
||||||
"sct",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "rustls-native-certs"
|
|
||||||
version = "0.6.3"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "a9aace74cb666635c918e9c12bc0d348266037aa8eb599b5cba565709a8dff00"
|
|
||||||
dependencies = [
|
|
||||||
"openssl-probe",
|
|
||||||
"rustls-pemfile",
|
|
||||||
"schannel",
|
|
||||||
"security-framework",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "rustls-pemfile"
|
|
||||||
version = "1.0.4"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "1c74cae0a4cf6ccbbf5f359f08efdf8ee7e1dc532573bf0db71968cb56b1448c"
|
|
||||||
dependencies = [
|
|
||||||
"base64 0.21.7",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "rustls-webpki"
|
|
||||||
version = "0.101.7"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "8b6275d1ee7a1cd780b64aca7726599a1dbc893b1e64144529e55c3c2f745765"
|
|
||||||
dependencies = [
|
|
||||||
"ring",
|
|
||||||
"untrusted",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "rustversion"
|
name = "rustversion"
|
||||||
version = "1.0.20"
|
version = "1.0.20"
|
||||||
|
|
@ -1975,15 +1602,6 @@ version = "1.0.20"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "28d3b2b1366ec20994f1fd18c3c594f05c5dd4bc44d8bb0c1c632c8d6829481f"
|
checksum = "28d3b2b1366ec20994f1fd18c3c594f05c5dd4bc44d8bb0c1c632c8d6829481f"
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "schannel"
|
|
||||||
version = "0.1.27"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "1f29ebaa345f945cec9fbbc532eb307f0fdad8161f281b6369539c8d84876b3d"
|
|
||||||
dependencies = [
|
|
||||||
"windows-sys 0.59.0",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "scoped-tls"
|
name = "scoped-tls"
|
||||||
version = "1.0.1"
|
version = "1.0.1"
|
||||||
|
|
@ -1996,39 +1614,6 @@ version = "1.2.0"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "94143f37725109f92c262ed2cf5e59bce7498c01bcc1502d7b9afe439a4e9f49"
|
checksum = "94143f37725109f92c262ed2cf5e59bce7498c01bcc1502d7b9afe439a4e9f49"
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "sct"
|
|
||||||
version = "0.7.1"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "da046153aa2352493d6cb7da4b6e5c0c057d8a1d0a9aa8560baffdd945acd414"
|
|
||||||
dependencies = [
|
|
||||||
"ring",
|
|
||||||
"untrusted",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "security-framework"
|
|
||||||
version = "2.11.1"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "897b2245f0b511c87893af39b033e5ca9cce68824c4d7e7630b5a1d339658d02"
|
|
||||||
dependencies = [
|
|
||||||
"bitflags",
|
|
||||||
"core-foundation",
|
|
||||||
"core-foundation-sys",
|
|
||||||
"libc",
|
|
||||||
"security-framework-sys",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "security-framework-sys"
|
|
||||||
version = "2.14.0"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "49db231d56a190491cb4aeda9527f1ad45345af50b0851622a7adb8c03b01c32"
|
|
||||||
dependencies = [
|
|
||||||
"core-foundation-sys",
|
|
||||||
"libc",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "semver"
|
name = "semver"
|
||||||
version = "1.0.26"
|
version = "1.0.26"
|
||||||
|
|
@ -2071,7 +1656,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "9d2de91cf02bbc07cde38891769ccd5d4f073d22a40683aa4bc7a95781aaa2c4"
|
checksum = "9d2de91cf02bbc07cde38891769ccd5d4f073d22a40683aa4bc7a95781aaa2c4"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"form_urlencoded",
|
"form_urlencoded",
|
||||||
"indexmap 2.9.0",
|
"indexmap",
|
||||||
"itoa",
|
"itoa",
|
||||||
"ryu",
|
"ryu",
|
||||||
"serde",
|
"serde",
|
||||||
|
|
@ -2099,17 +1684,6 @@ dependencies = [
|
||||||
"serde",
|
"serde",
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "serde_repr"
|
|
||||||
version = "0.1.20"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "175ee3e80ae9982737ca543e96133087cbd9a485eecc3bc4de9c1a37b47ea59c"
|
|
||||||
dependencies = [
|
|
||||||
"proc-macro2",
|
|
||||||
"quote",
|
|
||||||
"syn",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "serde_urlencoded"
|
name = "serde_urlencoded"
|
||||||
version = "0.7.1"
|
version = "0.7.1"
|
||||||
|
|
@ -2122,34 +1696,6 @@ dependencies = [
|
||||||
"serde",
|
"serde",
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "serde_with"
|
|
||||||
version = "2.3.3"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "07ff71d2c147a7b57362cead5e22f772cd52f6ab31cfcd9edcd7f6aeb2a0afbe"
|
|
||||||
dependencies = [
|
|
||||||
"base64 0.13.1",
|
|
||||||
"chrono",
|
|
||||||
"hex",
|
|
||||||
"indexmap 1.9.3",
|
|
||||||
"serde",
|
|
||||||
"serde_json",
|
|
||||||
"serde_with_macros",
|
|
||||||
"time",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "serde_with_macros"
|
|
||||||
version = "2.3.3"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "881b6f881b17d13214e5d494c939ebab463d01264ce1811e9d4ac3a882e7695f"
|
|
||||||
dependencies = [
|
|
||||||
"darling",
|
|
||||||
"proc-macro2",
|
|
||||||
"quote",
|
|
||||||
"syn",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "sha1"
|
name = "sha1"
|
||||||
version = "0.10.6"
|
version = "0.10.6"
|
||||||
|
|
@ -2263,7 +1809,7 @@ version = "0.8.5"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "f743f2a3cea30a58cd479013f75550e879009e3a02f616f18ca699335aa248c3"
|
checksum = "f743f2a3cea30a58cd479013f75550e879009e3a02f616f18ca699335aa248c3"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"base64 0.22.1",
|
"base64",
|
||||||
"bytes",
|
"bytes",
|
||||||
"crc",
|
"crc",
|
||||||
"crossbeam-queue",
|
"crossbeam-queue",
|
||||||
|
|
@ -2275,7 +1821,7 @@ dependencies = [
|
||||||
"futures-util",
|
"futures-util",
|
||||||
"hashbrown 0.15.2",
|
"hashbrown 0.15.2",
|
||||||
"hashlink",
|
"hashlink",
|
||||||
"indexmap 2.9.0",
|
"indexmap",
|
||||||
"log",
|
"log",
|
||||||
"memchr",
|
"memchr",
|
||||||
"once_cell",
|
"once_cell",
|
||||||
|
|
@ -2312,7 +1858,7 @@ checksum = "882ceaa29cade31beca7129b6beeb05737f44f82dbe2a9806ecea5a7093d00b7"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"dotenvy",
|
"dotenvy",
|
||||||
"either",
|
"either",
|
||||||
"heck 0.5.0",
|
"heck",
|
||||||
"hex",
|
"hex",
|
||||||
"once_cell",
|
"once_cell",
|
||||||
"proc-macro2",
|
"proc-macro2",
|
||||||
|
|
@ -2337,7 +1883,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "0afdd3aa7a629683c2d750c2df343025545087081ab5942593a5288855b1b7a7"
|
checksum = "0afdd3aa7a629683c2d750c2df343025545087081ab5942593a5288855b1b7a7"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"atoi",
|
"atoi",
|
||||||
"base64 0.22.1",
|
"base64",
|
||||||
"bitflags",
|
"bitflags",
|
||||||
"byteorder",
|
"byteorder",
|
||||||
"bytes",
|
"bytes",
|
||||||
|
|
@ -2379,7 +1925,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "a0bedbe1bbb5e2615ef347a5e9d8cd7680fb63e77d9dafc0f29be15e53f1ebe6"
|
checksum = "a0bedbe1bbb5e2615ef347a5e9d8cd7680fb63e77d9dafc0f29be15e53f1ebe6"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"atoi",
|
"atoi",
|
||||||
"base64 0.22.1",
|
"base64",
|
||||||
"bitflags",
|
"bitflags",
|
||||||
"byteorder",
|
"byteorder",
|
||||||
"crc",
|
"crc",
|
||||||
|
|
@ -2450,12 +1996,6 @@ dependencies = [
|
||||||
"unicode-properties",
|
"unicode-properties",
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "strsim"
|
|
||||||
version = "0.11.1"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "7da8b5736845d9f2fcb837ea5d9e2628564b3b043a70948a3f0b778838c5fb4f"
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "subtle"
|
name = "subtle"
|
||||||
version = "2.6.1"
|
version = "2.6.1"
|
||||||
|
|
@ -2559,37 +2099,6 @@ dependencies = [
|
||||||
"once_cell",
|
"once_cell",
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "time"
|
|
||||||
version = "0.3.41"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "8a7619e19bc266e0f9c5e6686659d394bc57973859340060a69221e57dbc0c40"
|
|
||||||
dependencies = [
|
|
||||||
"deranged",
|
|
||||||
"itoa",
|
|
||||||
"num-conv",
|
|
||||||
"powerfmt",
|
|
||||||
"serde",
|
|
||||||
"time-core",
|
|
||||||
"time-macros",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "time-core"
|
|
||||||
version = "0.1.4"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "c9e9a38711f559d9e3ce1cdb06dd7c5b8ea546bc90052da6d06bb76da74bb07c"
|
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "time-macros"
|
|
||||||
version = "0.2.22"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "3526739392ec93fd8b359c8e98514cb3e8e021beb4e5f597b00a0221f8ed8a49"
|
|
||||||
dependencies = [
|
|
||||||
"num-conv",
|
|
||||||
"time-core",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "tinystr"
|
name = "tinystr"
|
||||||
version = "0.7.6"
|
version = "0.7.6"
|
||||||
|
|
@ -2642,16 +2151,6 @@ dependencies = [
|
||||||
"syn",
|
"syn",
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "tokio-rustls"
|
|
||||||
version = "0.24.1"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "c28327cf380ac148141087fbfb9de9d7bd4e84ab5d2c28fbc911d753de8a7081"
|
|
||||||
dependencies = [
|
|
||||||
"rustls",
|
|
||||||
"tokio",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "tokio-stream"
|
name = "tokio-stream"
|
||||||
version = "0.1.17"
|
version = "0.1.17"
|
||||||
|
|
@ -2663,22 +2162,6 @@ dependencies = [
|
||||||
"tokio",
|
"tokio",
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "tokio-tungstenite"
|
|
||||||
version = "0.20.1"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "212d5dcb2a1ce06d81107c3d0ffa3121fe974b73f068c8282cb1c32328113b6c"
|
|
||||||
dependencies = [
|
|
||||||
"futures-util",
|
|
||||||
"log",
|
|
||||||
"rustls",
|
|
||||||
"rustls-native-certs",
|
|
||||||
"tokio",
|
|
||||||
"tokio-rustls",
|
|
||||||
"tungstenite",
|
|
||||||
"webpki-roots",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "tower"
|
name = "tower"
|
||||||
version = "0.5.2"
|
version = "0.5.2"
|
||||||
|
|
@ -2780,26 +2263,6 @@ dependencies = [
|
||||||
"syn",
|
"syn",
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "tungstenite"
|
|
||||||
version = "0.20.1"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "9e3dac10fd62eaf6617d3a904ae222845979aec67c615d1c842b4002c7666fb9"
|
|
||||||
dependencies = [
|
|
||||||
"byteorder",
|
|
||||||
"bytes",
|
|
||||||
"data-encoding",
|
|
||||||
"http 0.2.12",
|
|
||||||
"httparse",
|
|
||||||
"log",
|
|
||||||
"rand",
|
|
||||||
"rustls",
|
|
||||||
"sha1",
|
|
||||||
"thiserror 1.0.69",
|
|
||||||
"url",
|
|
||||||
"utf-8",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "typenum"
|
name = "typenum"
|
||||||
version = "1.18.0"
|
version = "1.18.0"
|
||||||
|
|
@ -2839,12 +2302,6 @@ version = "0.8.0"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "eb066959b24b5196ae73cb057f45598450d2c5f71460e98c49b738086eff9c06"
|
checksum = "eb066959b24b5196ae73cb057f45598450d2c5f71460e98c49b738086eff9c06"
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "untrusted"
|
|
||||||
version = "0.9.0"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "8ecb6da28b8a351d773b68d5825ac39017e680750f980f3a1a85cd8dd28a47c1"
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "url"
|
name = "url"
|
||||||
version = "2.5.4"
|
version = "2.5.4"
|
||||||
|
|
@ -2856,12 +2313,6 @@ dependencies = [
|
||||||
"percent-encoding",
|
"percent-encoding",
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "utf-8"
|
|
||||||
version = "0.7.6"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "09cc8ee72d2a9becf2f2febe0205bbed8fc6615b7cb429ad062dc7b7ddd036a9"
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "utf16_iter"
|
name = "utf16_iter"
|
||||||
version = "1.0.5"
|
version = "1.0.5"
|
||||||
|
|
@ -2990,12 +2441,6 @@ dependencies = [
|
||||||
"wasm-bindgen",
|
"wasm-bindgen",
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "webpki-roots"
|
|
||||||
version = "0.25.4"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "5f20c57d8d7db6d3b86154206ae5d8fba62dd39573114de97c2cb0578251f8e1"
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "whoami"
|
name = "whoami"
|
||||||
version = "1.6.0"
|
version = "1.6.0"
|
||||||
|
|
@ -3344,33 +2789,13 @@ dependencies = [
|
||||||
"synstructure",
|
"synstructure",
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "zerocopy"
|
|
||||||
version = "0.7.35"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "1b9b4fd18abc82b8136838da5d50bae7bdea537c574d8dc1a34ed098d6c166f0"
|
|
||||||
dependencies = [
|
|
||||||
"zerocopy-derive 0.7.35",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "zerocopy"
|
name = "zerocopy"
|
||||||
version = "0.8.24"
|
version = "0.8.24"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "2586fea28e186957ef732a5f8b3be2da217d65c5969d4b1e17f973ebbe876879"
|
checksum = "2586fea28e186957ef732a5f8b3be2da217d65c5969d4b1e17f973ebbe876879"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"zerocopy-derive 0.8.24",
|
"zerocopy-derive",
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "zerocopy-derive"
|
|
||||||
version = "0.7.35"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "fa4f8080344d4671fb4e831a13ad1e68092748387dfc4f55e356242fae12ce3e"
|
|
||||||
dependencies = [
|
|
||||||
"proc-macro2",
|
|
||||||
"quote",
|
|
||||||
"syn",
|
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
|
|
@ -3432,31 +2857,3 @@ dependencies = [
|
||||||
"quote",
|
"quote",
|
||||||
"syn",
|
"syn",
|
||||||
]
|
]
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "zstd"
|
|
||||||
version = "0.13.3"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "e91ee311a569c327171651566e07972200e76fcfe2242a4fa446149a3881c08a"
|
|
||||||
dependencies = [
|
|
||||||
"zstd-safe",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "zstd-safe"
|
|
||||||
version = "7.2.4"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "8f49c4d5f0abb602a93fb8736af2a4f4dd9512e36f7f570d66e65ff867ed3b9d"
|
|
||||||
dependencies = [
|
|
||||||
"zstd-sys",
|
|
||||||
]
|
|
||||||
|
|
||||||
[[package]]
|
|
||||||
name = "zstd-sys"
|
|
||||||
version = "2.0.15+zstd.1.5.7"
|
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
|
||||||
checksum = "eb81183ddd97d0c74cedf1d50d85c8d08c1b8b68ee863bdee9e706eedba1a237"
|
|
||||||
dependencies = [
|
|
||||||
"cc",
|
|
||||||
"pkg-config",
|
|
||||||
]
|
|
||||||
|
|
@ -10,12 +10,7 @@ atrium-api = { version = "0.25.2", default-features = false }
|
||||||
axum = { version = "0.8.3", features = ["json"] }
|
axum = { version = "0.8.3", features = ["json"] }
|
||||||
axum-macros = "0.5.0"
|
axum-macros = "0.5.0"
|
||||||
http = "1.3.1"
|
http = "1.3.1"
|
||||||
regex = "1.11.1"
|
|
||||||
rocketman = "0.2.0"
|
|
||||||
serde = "1.0.219"
|
serde = "1.0.219"
|
||||||
serde_json = "1.0.140"
|
serde_json = "1.0.140"
|
||||||
sqlx = { version = "0.8.5", features = ["postgres", "runtime-tokio"] }
|
sqlx = { version = "0.8.5", features = ["postgres", "runtime-tokio"] }
|
||||||
tokio = { version = "1.44.2", features = ["macros", "rt-multi-thread"] }
|
tokio = { version = "1.44.2", features = ["macros", "rt-multi-thread"] }
|
||||||
|
|
||||||
[build-dependencies]
|
|
||||||
esquema-codegen = { git = "https://github.com/fatfingers23/esquema.git", branch = "main" }
|
|
||||||
6
flake.lock → rust/flake.lock
generated
6
flake.lock → rust/flake.lock
generated
|
|
@ -41,11 +41,11 @@
|
||||||
"nixpkgs": "nixpkgs_2"
|
"nixpkgs": "nixpkgs_2"
|
||||||
},
|
},
|
||||||
"locked": {
|
"locked": {
|
||||||
"lastModified": 1746585402,
|
"lastModified": 1744857263,
|
||||||
"narHash": "sha256-Pf+ufu6bYNA1+KQKHnGMNEfTwpD9ZIcAeLoE2yPWIP0=",
|
"narHash": "sha256-M4X/CnquHozzgwDk+CbFb8Sb4rSGJttfNOKcpRwziis=",
|
||||||
"owner": "oxalica",
|
"owner": "oxalica",
|
||||||
"repo": "rust-overlay",
|
"repo": "rust-overlay",
|
||||||
"rev": "72dd969389583664f87aa348b3458f2813693617",
|
"rev": "9f3d63d569536cd661a4adcf697e32eb08d61e31",
|
||||||
"type": "github"
|
"type": "github"
|
||||||
},
|
},
|
||||||
"original": {
|
"original": {
|
||||||
1
rust/src/atproto.rs
Normal file
1
rust/src/atproto.rs
Normal file
|
|
@ -0,0 +1 @@
|
||||||
|
pub use atrium_api::types::string::Nsid;
|
||||||
|
|
@ -1,6 +1,5 @@
|
||||||
use crate::{
|
use crate::{
|
||||||
atproto::Nsid,
|
atproto::Nsid,
|
||||||
injester::start_injester,
|
|
||||||
router::{
|
router::{
|
||||||
Router,
|
Router,
|
||||||
Endpoint,
|
Endpoint,
|
||||||
|
|
@ -15,7 +14,6 @@ use crate::{
|
||||||
use http::status::StatusCode;
|
use http::status::StatusCode;
|
||||||
|
|
||||||
mod atproto;
|
mod atproto;
|
||||||
mod injester;
|
|
||||||
mod router;
|
mod router;
|
||||||
mod db;
|
mod db;
|
||||||
|
|
||||||
|
|
@ -26,9 +24,6 @@ async fn main() {
|
||||||
let post_nsid = Nsid::new(String::from("me.woach.post")).expect("me.woach.post is a valid nsid");
|
let post_nsid = Nsid::new(String::from("me.woach.post")).expect("me.woach.post is a valid nsid");
|
||||||
router = router.add_endpoint(Endpoint::new_xrpc_query(get_nsid, test));
|
router = router.add_endpoint(Endpoint::new_xrpc_query(get_nsid, test));
|
||||||
router = router.add_endpoint(Endpoint::new_xrpc_procedure(post_nsid, test2));
|
router = router.add_endpoint(Endpoint::new_xrpc_procedure(post_nsid, test2));
|
||||||
tokio::spawn(async move {
|
|
||||||
start_injester();
|
|
||||||
});
|
|
||||||
router.serve().await;
|
router.serve().await;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -1,70 +0,0 @@
|
||||||
use atrium_api::types::string::{
|
|
||||||
AtIdentifier,
|
|
||||||
RecordKey,
|
|
||||||
};
|
|
||||||
use regex::Regex;
|
|
||||||
|
|
||||||
pub use atrium_api::types::string::{
|
|
||||||
Nsid,
|
|
||||||
Did,
|
|
||||||
Handle,
|
|
||||||
};
|
|
||||||
|
|
||||||
enum Authority {
|
|
||||||
Did(Did),
|
|
||||||
Handle(Handle),
|
|
||||||
}
|
|
||||||
|
|
||||||
impl Authority {
|
|
||||||
pub fn new(authority: String) -> Result<Self, &'static str> {
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// This implementation does not support Query or Fragments, and thus follows
|
|
||||||
// the following schema: "at://" AUTHORITY [ "/" COLLECTION [ "/" RKEY ] ]
|
|
||||||
pub struct Uri {
|
|
||||||
authority: Authority,
|
|
||||||
collection: Option<Nsid>,
|
|
||||||
rkey: Option<RecordKey>,
|
|
||||||
}
|
|
||||||
|
|
||||||
// TODO: Replace super basic URI regex with real uri parsing
|
|
||||||
const URI_REGEX: Regex = Regex::new(
|
|
||||||
r"/^at:\/\/([\w\.\-_~:]+)(?:\/([\w\.\-_~:]+)(?:)\/([\w\.\-_~:]+))?$/i"
|
|
||||||
).expect("valid regex");
|
|
||||||
|
|
||||||
impl Uri {
|
|
||||||
pub fn new(uri: String) -> Result<Self, &'static str> {
|
|
||||||
let Some(captures) = URI_REGEX.captures(&uri) else {
|
|
||||||
return Err("Invalid Uri");
|
|
||||||
};
|
|
||||||
// TODO: Convert authority if its a did or a handle
|
|
||||||
let Some(Ok(authority)) = captures.get(1).map(|mtch| {
|
|
||||||
Authority::new(mtch.as_str().to_string())
|
|
||||||
}) else {
|
|
||||||
return Err("Invalid Authority")
|
|
||||||
};
|
|
||||||
let collection = captures.get(2).map(|mtch| {
|
|
||||||
Nsid::new(mtch.as_str().to_string())
|
|
||||||
});
|
|
||||||
let rkey = captures.get(3).map(|mtch| {
|
|
||||||
RecordKey::new(mtch.as_str().to_string())
|
|
||||||
});
|
|
||||||
Ok(Uri { authority, collection, rkey })
|
|
||||||
}
|
|
||||||
|
|
||||||
pub fn as_string(&self) -> String {
|
|
||||||
let mut uri = String::from("at://");
|
|
||||||
uri.push_str(match &self.authority {
|
|
||||||
Authority::Handle(h) => &*h,
|
|
||||||
Authority::Did(d) => &*d,
|
|
||||||
});
|
|
||||||
if let Some(nsid) = &self.collection {
|
|
||||||
uri.push_str(&*nsid);
|
|
||||||
}
|
|
||||||
if let Some(rkey) = &self.rkey {
|
|
||||||
uri.push_str(&*rkey);
|
|
||||||
}
|
|
||||||
uri
|
|
||||||
}
|
|
||||||
}
|
|
||||||
113
src/db.rs
113
src/db.rs
|
|
@ -1,113 +0,0 @@
|
||||||
use crate::atproto::{
|
|
||||||
Did,
|
|
||||||
Uri,
|
|
||||||
}
|
|
||||||
use sqlx::{
|
|
||||||
query,
|
|
||||||
Database,
|
|
||||||
Pool,
|
|
||||||
Postgres,
|
|
||||||
pool::PoolOptions,
|
|
||||||
postgres::{
|
|
||||||
PgConnectOptions,
|
|
||||||
PgSslMode,
|
|
||||||
},
|
|
||||||
Result,
|
|
||||||
};
|
|
||||||
use std::string::ToString;
|
|
||||||
|
|
||||||
pub struct Db<Dbimp: Database> {
|
|
||||||
pool: Pool<Dbimp>
|
|
||||||
}
|
|
||||||
|
|
||||||
pub struct User {
|
|
||||||
userdid: Did,
|
|
||||||
handle: Handle,
|
|
||||||
}
|
|
||||||
|
|
||||||
#[non_exhaustive]
|
|
||||||
enum Role {
|
|
||||||
Owner,
|
|
||||||
Participant
|
|
||||||
}
|
|
||||||
|
|
||||||
impl ToString for Role {
|
|
||||||
fn to_string(&self) -> String {
|
|
||||||
match *self {
|
|
||||||
Role::Owner => "owner".to_string(),
|
|
||||||
Role::Participant => "participant".to_string(),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
struct Participant {
|
|
||||||
participantdid: Did,
|
|
||||||
role: Role,
|
|
||||||
}
|
|
||||||
|
|
||||||
pub struct Session {
|
|
||||||
sessionuri: Uri,
|
|
||||||
label: Option<String>,
|
|
||||||
participants: Vec<Participant>,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl Db<Postgres> {
|
|
||||||
async fn connect() -> Result<Self> {
|
|
||||||
let conn = PgConnectOptions::new()
|
|
||||||
.host("localhost")
|
|
||||||
.port(5432)
|
|
||||||
.username("postgres")
|
|
||||||
.password("062217")
|
|
||||||
.database("anisky")
|
|
||||||
.ssl_mode(PgSslMode::Disable);
|
|
||||||
|
|
||||||
let pool = match PoolOptions::new().connect_with(conn).await {
|
|
||||||
Ok(p) => p,
|
|
||||||
Err(e) => return Err(e),
|
|
||||||
};
|
|
||||||
|
|
||||||
Ok(Db { pool })
|
|
||||||
}
|
|
||||||
//
|
|
||||||
// pub async fn add_user(&self, user: &User) -> Result<()> {
|
|
||||||
// query!(r#"
|
|
||||||
// INSERT INTO users(userdid, handle) VALUES ($1, $2)
|
|
||||||
// "#,
|
|
||||||
// user.userdid, user.handle
|
|
||||||
// ).execute(self.pool).await?;
|
|
||||||
// Ok(())
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
// pub async fn add_session(&self, session: &Session) -> Result<()> {
|
|
||||||
// let mut transaction = self.pool.begin().await?;
|
|
||||||
//
|
|
||||||
// query!(r#"
|
|
||||||
// INSERT INTO sessions(sessionuri, label) VALUES ($1, $2)
|
|
||||||
// "#,
|
|
||||||
// session.sessionuri, session.label
|
|
||||||
// ).execute(&mut *transaction).await?;
|
|
||||||
//
|
|
||||||
// for participant in session.participants {
|
|
||||||
// query!(r#"
|
|
||||||
// INSERT INTO participants(sessionuri, userdid, role) VALUES ($1, $2, $3)
|
|
||||||
// "#,
|
|
||||||
// session.sessionuri, participant.userdid, participant.role.to_string()
|
|
||||||
// ).execute(&mut *transaction).await?;
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
// transaction.commit().await
|
|
||||||
// }
|
|
||||||
//
|
|
||||||
// pub async fn add_participant(&self, session: Session,
|
|
||||||
// participant: Participant) -> Result<Session> {
|
|
||||||
// query!(r#"
|
|
||||||
// INSERT INTO participants(sessionuri, userdid, role) VALUES ($1, $2, $3)
|
|
||||||
// "#,
|
|
||||||
// session.sessionuri, participant.userdid, participant.role.to_string()
|
|
||||||
// ).execute(self.pool).await?;
|
|
||||||
//
|
|
||||||
// session.participants.push(participant);
|
|
||||||
//
|
|
||||||
// Ok(session)
|
|
||||||
// }
|
|
||||||
}
|
|
||||||
|
|
@ -1,30 +0,0 @@
|
||||||
use crate::db::Db;
|
|
||||||
use rocketman::{
|
|
||||||
options::JetstreamOptions
|
|
||||||
ingestion::LexiconIngestor
|
|
||||||
};
|
|
||||||
|
|
||||||
enum Injester {
|
|
||||||
Jetstream(Jetstream)
|
|
||||||
}
|
|
||||||
|
|
||||||
struct SpoorJetstream;
|
|
||||||
|
|
||||||
impl LexiconIngestor for SpoorJetstream {
|
|
||||||
async fn ingest(&self, message: Event<Value>) -> Result<()> {
|
|
||||||
if let Some(commit) = &message.commit {
|
|
||||||
match commit.operation {
|
|
||||||
Operation::Create | Operation::Update => {
|
|
||||||
|
|
||||||
}
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
return Err("Message has no commit");
|
|
||||||
}
|
|
||||||
Ok(())
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
pub async fn start_ingester(db: Db) {
|
|
||||||
let opts = JetstreamOptions::builder()
|
|
||||||
}
|
|
||||||
|
|
@ -1,3 +0,0 @@
|
||||||
// @generated - This file is generated by esquema-codegen (forked from atrium-codegen). DO NOT EDIT.
|
|
||||||
pub mod record;
|
|
||||||
pub mod my;
|
|
||||||
|
|
@ -1,3 +0,0 @@
|
||||||
// @generated - This file is generated by esquema-codegen (forked from atrium-codegen). DO NOT EDIT.
|
|
||||||
//!Definitions for the `my` namespace.
|
|
||||||
pub mod spoor;
|
|
||||||
|
|
@ -1,4 +0,0 @@
|
||||||
// @generated - This file is generated by esquema-codegen (forked from atrium-codegen). DO NOT EDIT.
|
|
||||||
//!Definitions for the `my.spoor` namespace.
|
|
||||||
pub mod content;
|
|
||||||
pub mod log;
|
|
||||||
|
|
@ -1,17 +0,0 @@
|
||||||
// @generated - This file is generated by esquema-codegen (forked from atrium-codegen). DO NOT EDIT.
|
|
||||||
//!Definitions for the `my.spoor.content` namespace.
|
|
||||||
pub mod defs;
|
|
||||||
pub mod external;
|
|
||||||
pub mod media;
|
|
||||||
#[derive(Debug)]
|
|
||||||
pub struct External;
|
|
||||||
impl atrium_api::types::Collection for External {
|
|
||||||
const NSID: &'static str = "my.spoor.content.external";
|
|
||||||
type Record = external::Record;
|
|
||||||
}
|
|
||||||
#[derive(Debug)]
|
|
||||||
pub struct Media;
|
|
||||||
impl atrium_api::types::Collection for Media {
|
|
||||||
const NSID: &'static str = "my.spoor.content.media";
|
|
||||||
type Record = media::Record;
|
|
||||||
}
|
|
||||||
|
|
@ -1,19 +0,0 @@
|
||||||
// @generated - This file is generated by esquema-codegen (forked from atrium-codegen). DO NOT EDIT.
|
|
||||||
//!Definitions for the `my.spoor.content.defs` namespace.
|
|
||||||
#[derive(serde::Serialize, serde::Deserialize, Debug, Clone, PartialEq, Eq)]
|
|
||||||
#[serde(rename_all = "camelCase")]
|
|
||||||
pub struct TitleData {
|
|
||||||
#[serde(skip_serializing_if = "core::option::Option::is_none")]
|
|
||||||
pub lang: core::option::Option<atrium_api::types::string::Language>,
|
|
||||||
#[serde(skip_serializing_if = "core::option::Option::is_none")]
|
|
||||||
pub translation_type: core::option::Option<atrium_api::types::string::Nsid>,
|
|
||||||
#[serde(skip_serializing_if = "core::option::Option::is_none")]
|
|
||||||
pub value: core::option::Option<String>,
|
|
||||||
}
|
|
||||||
pub type Title = atrium_api::types::Object<TitleData>;
|
|
||||||
///A phonetic transcription of the native title such that when read it will sound like the native title.
|
|
||||||
pub const TITLE_HOMOPHONIC: &str = "my.spoor.content.defs#titleHomophonic";
|
|
||||||
///The title in its native script
|
|
||||||
pub const TITLE_NATIVE: &str = "my.spoor.content.defs#titleNative";
|
|
||||||
///A translation of the title
|
|
||||||
pub const TITLE_TRANSLATION: &str = "my.spoor.content.defs#titleTranslation";
|
|
||||||
|
|
@ -1,28 +0,0 @@
|
||||||
// @generated - This file is generated by esquema-codegen (forked from atrium-codegen). DO NOT EDIT.
|
|
||||||
//!Definitions for the `my.spoor.content.external` namespace.
|
|
||||||
use atrium_api::types::TryFromUnknown;
|
|
||||||
#[derive(serde::Serialize, serde::Deserialize, Debug, Clone, PartialEq, Eq)]
|
|
||||||
#[serde(rename_all = "camelCase")]
|
|
||||||
pub struct RecordData {
|
|
||||||
///User defined overrides for the returned content
|
|
||||||
#[serde(skip_serializing_if = "core::option::Option::is_none")]
|
|
||||||
pub overrides: core::option::Option<atrium_api::types::Union<RecordOverridesRefs>>,
|
|
||||||
///All the data needed to query the content from the source
|
|
||||||
pub queryable: atrium_api::types::Union<RecordQueryableRefs>,
|
|
||||||
///An nsid for a specific data source. The domain authority governs how to process the queryable
|
|
||||||
pub source: atrium_api::types::string::Nsid,
|
|
||||||
#[serde(skip_serializing_if = "core::option::Option::is_none")]
|
|
||||||
pub titles: core::option::Option<Vec<crate::my::spoor::content::defs::Title>>,
|
|
||||||
}
|
|
||||||
pub type Record = atrium_api::types::Object<RecordData>;
|
|
||||||
impl From<atrium_api::types::Unknown> for RecordData {
|
|
||||||
fn from(value: atrium_api::types::Unknown) -> Self {
|
|
||||||
Self::try_from_unknown(value).unwrap()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
#[derive(serde::Serialize, serde::Deserialize, Debug, Clone, PartialEq, Eq)]
|
|
||||||
#[serde(tag = "$type")]
|
|
||||||
pub enum RecordOverridesRefs {}
|
|
||||||
#[derive(serde::Serialize, serde::Deserialize, Debug, Clone, PartialEq, Eq)]
|
|
||||||
#[serde(tag = "$type")]
|
|
||||||
pub enum RecordQueryableRefs {}
|
|
||||||
|
|
@ -1,44 +0,0 @@
|
||||||
// @generated - This file is generated by esquema-codegen (forked from atrium-codegen). DO NOT EDIT.
|
|
||||||
//!Definitions for the `my.spoor.content.media` namespace.
|
|
||||||
use atrium_api::types::TryFromUnknown;
|
|
||||||
#[derive(serde::Serialize, serde::Deserialize, Debug, Clone, PartialEq, Eq)]
|
|
||||||
#[serde(rename_all = "camelCase")]
|
|
||||||
pub struct RecordData {
|
|
||||||
#[serde(skip_serializing_if = "core::option::Option::is_none")]
|
|
||||||
pub duration_data: core::option::Option<
|
|
||||||
atrium_api::types::Union<RecordDurationDataRefs>,
|
|
||||||
>,
|
|
||||||
///Client-declared timestamp for when this activity was last updated
|
|
||||||
pub last_updated: atrium_api::types::string::Datetime,
|
|
||||||
#[serde(skip_serializing_if = "core::option::Option::is_none")]
|
|
||||||
pub poster_image: core::option::Option<atrium_api::types::BlobRef>,
|
|
||||||
pub titles: Vec<crate::my::spoor::content::defs::Title>,
|
|
||||||
}
|
|
||||||
pub type Record = atrium_api::types::Object<RecordData>;
|
|
||||||
impl From<atrium_api::types::Unknown> for RecordData {
|
|
||||||
fn from(value: atrium_api::types::Unknown) -> Self {
|
|
||||||
Self::try_from_unknown(value).unwrap()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
#[derive(serde::Serialize, serde::Deserialize, Debug, Clone, PartialEq, Eq)]
|
|
||||||
#[serde(rename_all = "camelCase")]
|
|
||||||
pub struct BookData {
|
|
||||||
#[serde(skip_serializing_if = "core::option::Option::is_none")]
|
|
||||||
pub chapters: core::option::Option<usize>,
|
|
||||||
}
|
|
||||||
pub type Book = atrium_api::types::Object<BookData>;
|
|
||||||
#[derive(serde::Serialize, serde::Deserialize, Debug, Clone, PartialEq, Eq)]
|
|
||||||
#[serde(rename_all = "camelCase")]
|
|
||||||
pub struct TelevisionData {
|
|
||||||
#[serde(skip_serializing_if = "core::option::Option::is_none")]
|
|
||||||
pub episodes: core::option::Option<usize>,
|
|
||||||
}
|
|
||||||
pub type Television = atrium_api::types::Object<TelevisionData>;
|
|
||||||
#[derive(serde::Serialize, serde::Deserialize, Debug, Clone, PartialEq, Eq)]
|
|
||||||
#[serde(tag = "$type")]
|
|
||||||
pub enum RecordDurationDataRefs {
|
|
||||||
#[serde(rename = "my.spoor.content.media#television")]
|
|
||||||
MySpoorContentMediaTelevision(Box<crate::my::spoor::content::media::Television>),
|
|
||||||
#[serde(rename = "my.spoor.content.media#book")]
|
|
||||||
MySpoorContentMediaBook(Box<crate::my::spoor::content::media::Book>),
|
|
||||||
}
|
|
||||||
|
|
@ -1,16 +0,0 @@
|
||||||
// @generated - This file is generated by esquema-codegen (forked from atrium-codegen). DO NOT EDIT.
|
|
||||||
//!Definitions for the `my.spoor.log` namespace.
|
|
||||||
pub mod activity;
|
|
||||||
pub mod session;
|
|
||||||
#[derive(Debug)]
|
|
||||||
pub struct Activity;
|
|
||||||
impl atrium_api::types::Collection for Activity {
|
|
||||||
const NSID: &'static str = "my.spoor.log.activity";
|
|
||||||
type Record = activity::Record;
|
|
||||||
}
|
|
||||||
#[derive(Debug)]
|
|
||||||
pub struct Session;
|
|
||||||
impl atrium_api::types::Collection for Session {
|
|
||||||
const NSID: &'static str = "my.spoor.log.session";
|
|
||||||
type Record = session::Record;
|
|
||||||
}
|
|
||||||
|
|
@ -1,26 +0,0 @@
|
||||||
// @generated - This file is generated by esquema-codegen (forked from atrium-codegen). DO NOT EDIT.
|
|
||||||
//!Definitions for the `my.spoor.log.activity` namespace.
|
|
||||||
use atrium_api::types::TryFromUnknown;
|
|
||||||
#[derive(serde::Serialize, serde::Deserialize, Debug, Clone, PartialEq, Eq)]
|
|
||||||
#[serde(rename_all = "camelCase")]
|
|
||||||
pub struct RecordData {
|
|
||||||
///Client-declared timestamp for when this activity was created
|
|
||||||
pub created_at: atrium_api::types::string::Datetime,
|
|
||||||
///User-declared timestamp for when they performed the activity. Null implies unknown time.
|
|
||||||
#[serde(skip_serializing_if = "core::option::Option::is_none")]
|
|
||||||
pub performed_at: core::option::Option<atrium_api::types::string::Datetime>,
|
|
||||||
pub progress: atrium_api::types::Union<RecordProgressRefs>,
|
|
||||||
pub session: crate::com::atproto::repo::strong_ref::Main,
|
|
||||||
}
|
|
||||||
pub type Record = atrium_api::types::Object<RecordData>;
|
|
||||||
impl From<atrium_api::types::Unknown> for RecordData {
|
|
||||||
fn from(value: atrium_api::types::Unknown) -> Self {
|
|
||||||
Self::try_from_unknown(value).unwrap()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
#[derive(serde::Serialize, serde::Deserialize, Debug, Clone, PartialEq, Eq)]
|
|
||||||
#[serde(tag = "$type")]
|
|
||||||
pub enum RecordProgressRefs {
|
|
||||||
#[serde(rename = "my.spoor.log.activity#indexProgress")]
|
|
||||||
MySpoorLogActivityIndexProgress(Box<crate::my::spoor::log::activity::IndexProgress>),
|
|
||||||
}
|
|
||||||
|
|
@ -1,20 +0,0 @@
|
||||||
// @generated - This file is generated by esquema-codegen (forked from atrium-codegen). DO NOT EDIT.
|
|
||||||
//!Definitions for the `my.spoor.log.session` namespace.
|
|
||||||
use atrium_api::types::TryFromUnknown;
|
|
||||||
#[derive(serde::Serialize, serde::Deserialize, Debug, Clone, PartialEq, Eq)]
|
|
||||||
#[serde(rename_all = "camelCase")]
|
|
||||||
pub struct RecordData {
|
|
||||||
pub content: crate::com::atproto::repo::strong_ref::Main,
|
|
||||||
///Client-declared timestamp for when this activity was created
|
|
||||||
pub created_at: atrium_api::types::string::Datetime,
|
|
||||||
#[serde(skip_serializing_if = "core::option::Option::is_none")]
|
|
||||||
pub label: core::option::Option<String>,
|
|
||||||
#[serde(skip_serializing_if = "core::option::Option::is_none")]
|
|
||||||
pub other_participants: core::option::Option<Vec<atrium_api::types::string::Did>>,
|
|
||||||
}
|
|
||||||
pub type Record = atrium_api::types::Object<RecordData>;
|
|
||||||
impl From<atrium_api::types::Unknown> for RecordData {
|
|
||||||
fn from(value: atrium_api::types::Unknown) -> Self {
|
|
||||||
Self::try_from_unknown(value).unwrap()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,65 +0,0 @@
|
||||||
// @generated - This file is generated by esquema-codegen (forked from atrium-codegen). DO NOT EDIT.
|
|
||||||
//!A collection of known record types.
|
|
||||||
#[derive(serde::Serialize, serde::Deserialize, Debug, Clone, PartialEq, Eq)]
|
|
||||||
#[serde(tag = "$type")]
|
|
||||||
pub enum KnownRecord {
|
|
||||||
#[serde(rename = "my.spoor.content.external")]
|
|
||||||
LexiconsMySpoorContentExternal(
|
|
||||||
Box<crate::lexicons::my::spoor::content::external::Record>,
|
|
||||||
),
|
|
||||||
#[serde(rename = "my.spoor.content.media")]
|
|
||||||
LexiconsMySpoorContentMedia(Box<crate::lexicons::my::spoor::content::media::Record>),
|
|
||||||
#[serde(rename = "my.spoor.log.activity")]
|
|
||||||
LexiconsMySpoorLogActivity(Box<crate::lexicons::my::spoor::log::activity::Record>),
|
|
||||||
#[serde(rename = "my.spoor.log.session")]
|
|
||||||
LexiconsMySpoorLogSession(Box<crate::lexicons::my::spoor::log::session::Record>),
|
|
||||||
}
|
|
||||||
impl From<crate::lexicons::my::spoor::content::external::Record> for KnownRecord {
|
|
||||||
fn from(record: crate::lexicons::my::spoor::content::external::Record) -> Self {
|
|
||||||
KnownRecord::LexiconsMySpoorContentExternal(Box::new(record))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
impl From<crate::lexicons::my::spoor::content::external::RecordData> for KnownRecord {
|
|
||||||
fn from(
|
|
||||||
record_data: crate::lexicons::my::spoor::content::external::RecordData,
|
|
||||||
) -> Self {
|
|
||||||
KnownRecord::LexiconsMySpoorContentExternal(Box::new(record_data.into()))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
impl From<crate::lexicons::my::spoor::content::media::Record> for KnownRecord {
|
|
||||||
fn from(record: crate::lexicons::my::spoor::content::media::Record) -> Self {
|
|
||||||
KnownRecord::LexiconsMySpoorContentMedia(Box::new(record))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
impl From<crate::lexicons::my::spoor::content::media::RecordData> for KnownRecord {
|
|
||||||
fn from(
|
|
||||||
record_data: crate::lexicons::my::spoor::content::media::RecordData,
|
|
||||||
) -> Self {
|
|
||||||
KnownRecord::LexiconsMySpoorContentMedia(Box::new(record_data.into()))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
impl From<crate::lexicons::my::spoor::log::activity::Record> for KnownRecord {
|
|
||||||
fn from(record: crate::lexicons::my::spoor::log::activity::Record) -> Self {
|
|
||||||
KnownRecord::LexiconsMySpoorLogActivity(Box::new(record))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
impl From<crate::lexicons::my::spoor::log::activity::RecordData> for KnownRecord {
|
|
||||||
fn from(record_data: crate::lexicons::my::spoor::log::activity::RecordData) -> Self {
|
|
||||||
KnownRecord::LexiconsMySpoorLogActivity(Box::new(record_data.into()))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
impl From<crate::lexicons::my::spoor::log::session::Record> for KnownRecord {
|
|
||||||
fn from(record: crate::lexicons::my::spoor::log::session::Record) -> Self {
|
|
||||||
KnownRecord::LexiconsMySpoorLogSession(Box::new(record))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
impl From<crate::lexicons::my::spoor::log::session::RecordData> for KnownRecord {
|
|
||||||
fn from(record_data: crate::lexicons::my::spoor::log::session::RecordData) -> Self {
|
|
||||||
KnownRecord::LexiconsMySpoorLogSession(Box::new(record_data.into()))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
impl Into<atrium_api::types::Unknown> for KnownRecord {
|
|
||||||
fn into(self) -> atrium_api::types::Unknown {
|
|
||||||
atrium_api::types::TryIntoUnknown::try_into_unknown(&self).unwrap()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue