aljaz/turso
1
0
Fork 0
mirror of https://github.com/aljazceru/turso.git synced 2026-01-06 09:44:21 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix clippy

Browse Source
This commit is contained in:
Nikita Sivukhin
2025-09-19 13:25:52 +04:00
parent 7049f3ddae
commit cfc8728774
2 changed files with 18 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
bindings/javascript/src/browser.rs
View File

@@ -64,7 +64,7 @@ pub struct OpfsInner {
}
thread_local! {
static OPFS: Arc<Opfs> = Arc::new(Opfs::new());
static OPFS: Arc<Opfs> = Arc::new(Opfs::default());
}
#[napi]
@@ -74,9 +74,6 @@ struct OpfsFile {
opfs: Opfs,
}
// unsafe impl Send for OpfsFile {}
// unsafe impl Sync for OpfsFile {}
unsafe impl Send for Opfs {}
unsafe impl Sync for Opfs {}
@@ -107,15 +104,6 @@ pub fn opfs() -> Arc<Opfs> {
}
impl Opfs {
pub fn new() -> Self {
Self {
inner: Arc::new(OpfsInner {
completion_no: RefCell::new(0),
completions: RefCell::new(HashMap::new()),
}),
}
}
pub fn complete(&self, completion_no: u32, result: i32) {
let completion = {
let mut completions = self.inner.completions.borrow_mut();
@@ -148,6 +136,18 @@ impl Clock for Opfs {
}
}
impl Default for Opfs {
fn default() -> Self {
Self {
#[allow(clippy::arc_with_non_send_sync)]
inner: Arc::new(OpfsInner {
completion_no: RefCell::new(0),
completions: RefCell::new(HashMap::new()),
}),
}
}
}
#[link(wasm_import_module = "env")]
extern "C" {
fn lookup_file(path: *const u8, path_len: usize) -> i32;

10
bindings/javascript/sync/src/lib.rs
View File

@@ -255,7 +255,7 @@ impl SyncEngine {
#[napi]
pub fn push(&self) -> GeneratorHolder {
self.run(async move |coro, guard| {
let sync_engine = try_read(&guard)?;
let sync_engine = try_read(guard)?;
let sync_engine = try_unwrap(&sync_engine)?;
sync_engine.push_changes_to_remote(coro).await?;
Ok(None)
@@ -265,7 +265,7 @@ impl SyncEngine {
#[napi]
pub fn stats(&self) -> GeneratorHolder {
self.run(async move |coro, guard| {
let sync_engine = try_read(&guard)?;
let sync_engine = try_read(guard)?;
let sync_engine = try_unwrap(&sync_engine)?;
let stats = sync_engine.stats(coro).await?;
Ok(Some(GeneratorResponse::SyncEngineStats {
@@ -282,7 +282,7 @@ impl SyncEngine {
#[napi]
pub fn wait(&self) -> GeneratorHolder {
self.run(async move |coro, guard| {
let sync_engine = try_read(&guard)?;
let sync_engine = try_read(guard)?;
let sync_engine = try_unwrap(&sync_engine)?;
Ok(Some(GeneratorResponse::SyncEngineChanges {
changes: SyncEngineChanges {
@@ -296,7 +296,7 @@ impl SyncEngine {
pub fn apply(&self, changes: &mut SyncEngineChanges) -> GeneratorHolder {
let status = changes.status.take().unwrap();
self.run(async move |coro, guard| {
let sync_engine = try_read(&guard)?;
let sync_engine = try_read(guard)?;
let sync_engine = try_unwrap(&sync_engine)?;
sync_engine.apply_changes_from_remote(coro, status).await?;
Ok(None)
@@ -306,7 +306,7 @@ impl SyncEngine {
#[napi]
pub fn checkpoint(&self) -> GeneratorHolder {
self.run(async move |coro, guard| {
let sync_engine = try_read(&guard)?;
let sync_engine = try_read(guard)?;
let sync_engine = try_unwrap(&sync_engine)?;
sync_engine.checkpoint(coro).await?;
Ok(None)