RxDB - Replication with Laravel Orion
The Orion replication provides handlers for run replication with Orion REST API as the transportation layer.
npm i rxdb-orion
The package usage is simple, but there are some important rules to follow
- Array properties with ref will be replicated using
syncroute - For other relationship properties, a specific replication will be required for each one.
import { replicateOrion } from 'rxdb-orion';
import { userSchema } from './schemas/user';
import { roleSchema } from './schemas/role';
const database = await createRxDatabase({
name: 'mydb',
storage: getRxStorageDexie(),
});
await database.addCollections({
users: {
schema: userSchema,
},
roles: {
schema: roleSchema,
},
});
const replicationState = replicateOrion({
url: 'http://my.fake.api/users',
params: { include: 'roles' },
collection: users,
batchSize: 3,
});
await replicationState.start();It is common for an application to require handling multiple replications.
For this reason, the package includes the Manager class to assist in such situations.
As Laravel Orion backend is unable to send events to the client,
the manager executes reSync() every 10000ms by default.
You can customize the interval as you see fit.
import { replicateOrion, Manager } from 'rxdb-orion';
const manager = new Manager([
replicateOrion({
url: 'http://my.fake.api/users',
params: { include: 'roles' },
collection: users,
batchSize: 3,
}),
replicateOrion({
url: 'http://my.fake.api/categories',
collection: categories,
batchSize: 3,
}),
], 5000);
await manager.start();The package uses a Scope to request all documents that have been written after the given checkpoint.
Therefore, it is recommended to create a trait for making the necessary model customizations.
<?php
namespace App\Traits;
use Carbon\Carbon;
use Carbon\CarbonImmutable;
trait Syncable {
/**
* Initialize the trait
*
* @return void
*/
protected function initializeSyncable()
{
$this->append('_deleted');
}
/**
* Determine if model is deleted
*
* @return boolean
*/
protected function getDeletedAttribute()
{
return $this->deleted_at !== null;
}
/**
* Cast a date for timestamp
*
* @param \DateTimeInterface $date
* @return string
*/
protected function serializeDate(\DateTimeInterface $date)
{
$instance = $date instanceof \DateTimeImmutable
? CarbonImmutable::instance($date)
: Carbon::instance($date);
return $instance->timestamp;
}
/**
* Scope a query to only include models changed after given value.
*
* @param \Illuminate\Database\Eloquent\Builder $query
* @param int $updatedAt
* @param string $id
* @return \Illuminate\Database\Eloquent\Builder
*/
public function scopeMinUpdatedAt($query, $updatedAt, $id)
{
$datetime = Carbon::createFromTimestamp($value);
return $query
->where('updated_at', '>', $updatedAt)
->orWhere(function($query) use ($updatedAt, $id) {
$query->where('updated_at', $updatedAt)->where('id', '>', $id);
})
->orderBy('updated_at');
}
}<?php
namespace App\Models;
use Illuminate\Database\Eloquent\Model;
class User extends Model {
use Syncable;
....
}
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent