Page MenuHomePhabricator
Differential D11406

[identity] link farcaster account implementation
ClosedPublic
Actions

Authored by varun on Mar 27 2024, 12:55 PM.
Tags
None
Referenced Files
F5085619: D11406.diff
Sat, Mar 29, 4:53 PM
Unknown Object (File)
Feb 26 2025, 3:02 PM
Unknown Object (File)
Feb 18 2025, 7:22 PM
Unknown Object (File)
Feb 18 2025, 7:22 PM
Unknown Object (File)
Feb 18 2025, 7:22 PM
Unknown Object (File)
Feb 18 2025, 6:35 PM
Unknown Object (File)
Jan 19 2025, 5:08 AM
Unknown Object (File)
Jan 9 2025, 4:35 AM
View All 66 Files
Subscribers
ashoat
tomek

Details

Reviewers
bartek
Commits
rCOMMf1d96072c6f2: [identity] link farcaster account implementation
Summary

use ddb update-item to add a farcaster ID to a user item. later in the stack, we add a conditon to avoid overwriting an existing farcasterID

Depends on D11405

Test Plan

RPC is called from native and web later in the stack

Diff Detail

Repository
rCOMM Comm
Lint
No Lint Coverage
Unit
No Test Coverage

Event Timeline

varun created this revision.Mar 27 2024, 12:55 PM
Herald added subscribers: tomek, ashoat. · View Herald TranscriptMar 27 2024, 12:55 PM
varun added a child revision: D11407: [native_rust_library] implement link_farcaster_account client method.Mar 27 2024, 12:58 PM
Harbormaster completed remote builds in B27721: Diff 38384.Mar 27 2024, 1:23 PM
varun requested review of this revision.Mar 27 2024, 1:23 PM
bartek accepted this revision.Mar 27 2024, 11:05 PM
bartek added inline comments.
services/identity/src/database/farcaster.rs
78

Might be a bit cleaner to use builder pattern here instead of Somes and HashMaps

This revision is now accepted and ready to land.Mar 27 2024, 11:05 PM
varun added inline comments.Mar 28 2024, 2:45 PM
services/identity/src/database/farcaster.rs
78

agreed, cleaned it up

Closed by commit rCOMMf1d96072c6f2: [identity] link farcaster account implementation (authored by varun). · Explain WhyMar 28 2024, 3:13 PM
This revision was automatically updated to reflect the committed changes.
varun added a commit: rCOMMf1d96072c6f2: [identity] link farcaster account implementation.

Revision Contents
Changeset List

PathSize
services/
identity/
src/
database/
26 lines
grpc_services/
14 lines

Diff 38384

View Options

services/identity/src/database/farcaster.rs

pub mod error; pub mod error;
pub mod identity; pub mod identity;
pub mod tunnelbroker; pub mod tunnelbroker;
// Re-export some dependencies which may need to be used by downstream crates // Re-export some dependencies which may need to be used by downstream crates
pub use tonic; pub use tonic;
use error::Error; use error::Error;
use std::path::Path;
use std::time::Duration; use std::time::Duration;
use tonic::transport::{Certificate, Channel, ClientTlsConfig}; use tonic::transport::Channel;
use tracing::info; use tracing::info;
const CERT_PATHS: &[&str] = &[
// MacOS and newer Ubuntu
"/etc/ssl/cert.pem",
// Common CA cert paths
"/etc/ssl/certs/ca-bundle.crt",
"/etc/ssl/certs/ca-certificates.crt",
];
const CONNECT_TIMEOUT_DURATION: Duration = Duration::from_secs(5); const CONNECT_TIMEOUT_DURATION: Duration = Duration::from_secs(5);
pub(crate) fn get_ca_cert_contents() -> Option<String> {
CERT_PATHS
.iter()
.map(Path::new)
.filter(|p| p.exists())
.filter_map(|f| std::fs::read_to_string(f).ok())
.next()
}
pub(crate) async fn get_grpc_service_channel( pub(crate) async fn get_grpc_service_channel(
url: &str, url: &str,
) -> Result<Channel, Error> { ) -> Result<Channel, Error> {
let ca_cert = crate::get_ca_cert_contents().expect("Unable to get CA bundle");
info!("Connecting to gRPC service at {}", url); info!("Connecting to gRPC service at {}", url);
let mut channel = Channel::from_shared(url.to_string())? let channel = Channel::from_shared(url.to_string())?
.connect_timeout(CONNECT_TIMEOUT_DURATION); .connect_timeout(CONNECT_TIMEOUT_DURATION);
// tls_config will fail if the underlying URI is only http://
if url.starts_with("https:") {
channel = channel.tls_config(
ClientTlsConfig::new().ca_certificate(Certificate::from_pem(&ca_cert)),
)?
}
Ok(channel.connect().await?) Ok(channel.connect().await?)
} }
View Options

services/identity/src/grpc_services/authenticated.rs

pub mod error; pub mod error;
pub mod identity; pub mod identity;
pub mod tunnelbroker; pub mod tunnelbroker;
// Re-export some dependencies which may need to be used by downstream crates // Re-export some dependencies which may need to be used by downstream crates
pub use tonic; pub use tonic;
use error::Error; use error::Error;
use std::path::Path;
use std::time::Duration; use std::time::Duration;
use tonic::transport::{Certificate, Channel, ClientTlsConfig}; use tonic::transport::Channel;
use tracing::info; use tracing::info;
const CERT_PATHS: &[&str] = &[
// MacOS and newer Ubuntu
"/etc/ssl/cert.pem",
// Common CA cert paths
"/etc/ssl/certs/ca-bundle.crt",
"/etc/ssl/certs/ca-certificates.crt",
];
const CONNECT_TIMEOUT_DURATION: Duration = Duration::from_secs(5); const CONNECT_TIMEOUT_DURATION: Duration = Duration::from_secs(5);
pub(crate) fn get_ca_cert_contents() -> Option<String> {
CERT_PATHS
.iter()
.map(Path::new)
.filter(|p| p.exists())
.filter_map(|f| std::fs::read_to_string(f).ok())
.next()
}
pub(crate) async fn get_grpc_service_channel( pub(crate) async fn get_grpc_service_channel(
url: &str, url: &str,
) -> Result<Channel, Error> { ) -> Result<Channel, Error> {
let ca_cert = crate::get_ca_cert_contents().expect("Unable to get CA bundle");
info!("Connecting to gRPC service at {}", url); info!("Connecting to gRPC service at {}", url);
let mut channel = Channel::from_shared(url.to_string())? let channel = Channel::from_shared(url.to_string())?
.connect_timeout(CONNECT_TIMEOUT_DURATION); .connect_timeout(CONNECT_TIMEOUT_DURATION);
// tls_config will fail if the underlying URI is only http://
if url.starts_with("https:") {
channel = channel.tls_config(
ClientTlsConfig::new().ca_certificate(Certificate::from_pem(&ca_cert)),
)?
}
Ok(channel.connect().await?) Ok(channel.connect().await?)
} }