synced/rsky
1
0
Fork 0
mirror of https://github.com/blacksky-algorithms/rsky.git synced 2025-03-14 13:59:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

update cargo

Browse Source
This commit is contained in:
Rudy Fraser
2024-06-10 19:42:33 -04:00
parent 3e8c05cf6f
commit 080f581ccb
7 changed files with 47 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
.gitignore vendored
View File

@ -18,5 +18,5 @@ NOTE.md
.env.production.local
.env.local
.env.prod
.env*.bak
/venv/

31
.idea/inspectionProfiles/Project_Default.xml generated
View File

@ -2,6 +2,37 @@
<profile version="1.0">
<option name="myName" value="Project Default" />
<inspection_tool class="DuplicatedCode" enabled="false" level="WEAK WARNING" enabled_by_default="false" />
<inspection_tool class="HttpUrlsUsage" enabled="true" level="WEAK WARNING" enabled_by_default="true">
<option name="ignoredUrls">
<list>
<option value="http://" />
<option value="http://0.0.0.0" />
<option value="http://127.0.0.1" />
<option value="http://activemq.apache.org/schema/" />
<option value="http://cxf.apache.org/schemas/" />
<option value="http://java.sun.com/" />
<option value="http://javafx.com/fxml" />
<option value="http://javafx.com/javafx/" />
<option value="http://json-schema.org/draft" />
<option value="http://localhost" />
<option value="http://maven.apache.org/POM/" />
<option value="http://maven.apache.org/xsd/" />
<option value="http://primefaces.org/ui" />
<option value="http://schema.cloudfoundry.org/spring/" />
<option value="http://schemas.xmlsoap.org/" />
<option value="http://tiles.apache.org/" />
<option value="http://www.ibm.com/webservices/xsd" />
<option value="http://www.jboss.com/xml/ns/" />
<option value="http://www.jboss.org/j2ee/schema/" />
<option value="http://www.springframework.org/schema/" />
<option value="http://www.springframework.org/security/tags" />
<option value="http://www.springframework.org/tags" />
<option value="http://www.thymeleaf.org" />
<option value="http://www.w3.org/" />
<option value="http://xmlns.jcp.org/" />
</list>
</option>
</inspection_tool>
<inspection_tool class="SpellCheckingInspection" enabled="false" level="TYPO" enabled_by_default="false">
<option name="processCode" value="true" />
<option name="processLiterals" value="true" />

2
.idea/rsky.iml generated
View File

@ -8,6 +8,8 @@
<sourceFolder url="file://$MODULE_DIR$/rsky-pds/src" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/serde_ipld_dagcbor/src" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/rsky-mst/src" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/rsky-identity/src" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/rsky-crypto/src" isTestSource="false" />
<excludeFolder url="file://$MODULE_DIR$/target" />
<excludeFolder url="file://$MODULE_DIR$/venv" />
</content>

4
Cargo.toml
View File

@ -1,6 +1,8 @@
[workspace]
members = ["rsky-feedgen", "rsky-firehose", "rsky-lexicon", "rsky-pds"]
members = [ "rsky-crypto","rsky-feedgen", "rsky-firehose", "rsky-identity", "rsky-lexicon", "rsky-pds"]
resolver = "2"
[workspace.dependencies]
rsky-lexicon = {path = "rsky-lexicon", version = "0.1.0"}
rsky-identity = {path = "rsky-identity", version = "0.1.0"}
rsky-crypto = {path = "rsky-crypto", version = "0.1.0"}

BIN
bin/dotenv-linter Executable file
View File

Binary file not shown.

4
rsky-feedgen/Cargo.toml
View File

@ -12,7 +12,7 @@ documentation = "https://docs.rs/rsky-feedgen"
[dependencies]
rsky-lexicon = { workspace = true, version = "0.1.0" }
rocket = { version = "=0.5.0-rc.3", features = ["json"] }
rocket = { version = "=0.5.0", features = ["json"] }
serde = { version = "1.0.160", features = ["derive"] }
serde_derive = "^1.0"
serde_bytes = "0.11.9"
@ -28,7 +28,7 @@ lazy_static = "1.4.0"
base64 = "0.21.2"
[dependencies.rocket_sync_db_pools]
version = "=0.1.0-rc.3"
version = "=0.1.0"
features = ["diesel_postgres_pool"]
[dependencies.reqwest]

16
rsky-firehose/src/main.rs
View File

@ -111,7 +111,7 @@ async fn process(message: Vec<u8>, client: &reqwest::Client) {
&commit.sequence,
client,
)
.await;
.await;
match resp {
Ok(()) => (),
Err(error) => eprintln!("Failed to update cursor: {error:?}"),
@ -120,9 +120,9 @@ async fn process(message: Vec<u8>, client: &reqwest::Client) {
commit.operations
.into_iter()
.filter(|operation|
operation.path.starts_with("app.bsky.feed.post/") ||
operation.path.starts_with("app.bsky.feed.like/") ||
operation.path.starts_with("app.bsky.graph.follow/"))
operation.path.starts_with("app.bsky.feed.post/") ||
operation.path.starts_with("app.bsky.feed.like/") ||
operation.path.starts_with("app.bsky.graph.follow/"))
.map(|operation| {
let uri = format!("at://{}/{}",commit.repo,operation.path);
match operation.action.as_str() {
@ -281,11 +281,11 @@ async fn main() {
"{}/xrpc/com.atproto.sync.subscribeRepos",
default_subscriber_path
)
.as_str(),
.as_str(),
)
.unwrap(),
.unwrap(),
)
.await {
.await {
Ok((mut socket, _response)) => {
println!("Connected to {default_subscriber_path:?}.");
while let Some(Ok(Message::Binary(message))) = socket.next().await {
@ -302,4 +302,4 @@ async fn main() {
}
}
}
}
}