Page MenuHomePhabricator
Differential D12078

[web] implement Outbound P2P Messages API on worker
ClosedPublic
Actions

Authored by kamil on May 16 2024, 10:14 AM.
Tags
None
Referenced Files
Unknown Object (File)
Fri, Mar 7, 4:59 AM
Unknown Object (File)
Wed, Mar 5, 1:42 PM
Unknown Object (File)
Mon, Mar 3, 2:19 AM
Unknown Object (File)
Sat, Feb 22, 10:53 PM
Unknown Object (File)
Fri, Feb 21, 7:09 AM
Unknown Object (File)
Fri, Feb 21, 7:09 AM
Unknown Object (File)
Fri, Feb 21, 7:09 AM
Unknown Object (File)
Fri, Feb 21, 7:09 AM
View All 79 Files
Subscribers
ashoat

Details

Reviewers
tomek
bartek
marcin
Commits
rCOMM824fab482d4b: [web] implement Outbound P2P Messages API on worker
Summary

Worker code to interact with SQLite.

Depends on D12075

Test Plan

Tested in D12080

Diff Detail

Repository
rCOMM Comm
Lint
No Lint Coverage
Unit
No Test Coverage

Revision Contents
Changeset List

PathSize
web/
database/
3 lines
shared-worker/
worker/
23 lines
types/
42 lines

Diff 40297

View Options

web/database/sqlite-api.js

use tracing::error;
pub type BoxedError = Box<dyn std::error::Error + Send + Sync + 'static>; pub type BoxedError = Box<dyn std::error::Error + Send + Sync + 'static>;
#[derive( #[derive(
Debug, derive_more::Display, derive_more::From, derive_more::Error, Debug, derive_more::Display, derive_more::From, derive_more::Error,
)] )]
pub enum WebsocketError { pub enum WebsocketError {
InvalidMessage, InvalidMessage,
InvalidSearchQuery,
UnauthorizedDevice, UnauthorizedDevice,
SendError, SendError,
SearchError, SearchError,
AuthError, AuthError,
SerializationError, SerializationError,
} }
impl From<serde_json::Error> for WebsocketError {
fn from(err: serde_json::Error) -> Self {
tracing::error!("Error serializing: {}", err);
WebsocketError::SerializationError
}
}
impl From<reqwest::Error> for WebsocketError {
fn from(err: reqwest::Error) -> Self {
tracing::error!("Error with search request: {}", err);
WebsocketError::SearchError
}
}
View Options

web/shared-worker/worker/shared-worker.js

use tracing::error;
pub type BoxedError = Box<dyn std::error::Error + Send + Sync + 'static>; pub type BoxedError = Box<dyn std::error::Error + Send + Sync + 'static>;
#[derive( #[derive(
Debug, derive_more::Display, derive_more::From, derive_more::Error, Debug, derive_more::Display, derive_more::From, derive_more::Error,
)] )]
pub enum WebsocketError { pub enum WebsocketError {
InvalidMessage, InvalidMessage,
InvalidSearchQuery,
UnauthorizedDevice, UnauthorizedDevice,
SendError, SendError,
SearchError, SearchError,
AuthError, AuthError,
SerializationError, SerializationError,
} }
impl From<serde_json::Error> for WebsocketError {
fn from(err: serde_json::Error) -> Self {
tracing::error!("Error serializing: {}", err);
WebsocketError::SerializationError
}
}
impl From<reqwest::Error> for WebsocketError {
fn from(err: reqwest::Error) -> Self {
tracing::error!("Error with search request: {}", err);
WebsocketError::SearchError
}
}
View Options

web/types/worker-types.js

use tracing::error;
pub type BoxedError = Box<dyn std::error::Error + Send + Sync + 'static>; pub type BoxedError = Box<dyn std::error::Error + Send + Sync + 'static>;
#[derive( #[derive(
Debug, derive_more::Display, derive_more::From, derive_more::Error, Debug, derive_more::Display, derive_more::From, derive_more::Error,
)] )]
pub enum WebsocketError { pub enum WebsocketError {
InvalidMessage, InvalidMessage,
InvalidSearchQuery,
UnauthorizedDevice, UnauthorizedDevice,
SendError, SendError,
SearchError, SearchError,
AuthError, AuthError,
SerializationError, SerializationError,
} }
impl From<serde_json::Error> for WebsocketError {
fn from(err: serde_json::Error) -> Self {
tracing::error!("Error serializing: {}", err);
WebsocketError::SerializationError
}
}
impl From<reqwest::Error> for WebsocketError {
fn from(err: reqwest::Error) -> Self {
tracing::error!("Error with search request: {}", err);
WebsocketError::SearchError
}
}